diff --git a/demo-parent.iml b/demo-parent.iml
deleted file mode 100644
index 8cffef8f8c4301df1a8a7a3f088e426b49ce1220..0000000000000000000000000000000000000000
--- a/demo-parent.iml
+++ /dev/null
@@ -1,68 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/kafka/pom.xml b/demo/pom.xml
similarity index 51%
rename from kafka/pom.xml
rename to demo/pom.xml
index 6210217cb623516db04312bdc2d244cd3e40f0f7..d706fc4a64472e85145cdcab439d2b26a67f2482 100644
--- a/kafka/pom.xml
+++ b/demo/pom.xml
@@ -9,33 +9,29 @@
4.0.0
- kafka
-
+ demo
- org.springframework.kafka
- spring-kafka
+ org.springframework.boot
+ spring-boot-starter-web
- com.alibaba
- fastjson
- 1.2.56
+ com.baomidou
+ mybatis-plus-boot-starter
- org.projectlombok
- lombok
- provided
+ com.baomidou
+ mybatis-plus-generator
- org.springframework.kafka
- spring-kafka-test
- test
+ mysql
+ mysql-connector-java
+
- org.apache.commons
- commons-lang3
- 3.9
+ org.freemarker
+ freemarker
-
+
\ No newline at end of file
diff --git a/demo/src/main/java/com/duanledexianxianxian/demo/CodeGenerator.java b/demo/src/main/java/com/duanledexianxianxian/demo/CodeGenerator.java
new file mode 100644
index 0000000000000000000000000000000000000000..f4b222cf027fc7e234dacc5f92ea61d6f88ac298
--- /dev/null
+++ b/demo/src/main/java/com/duanledexianxianxian/demo/CodeGenerator.java
@@ -0,0 +1,130 @@
+package com.duanledexianxianxian.demo;
+
+import com.baomidou.mybatisplus.core.exceptions.MybatisPlusException;
+import com.baomidou.mybatisplus.core.toolkit.StringPool;
+import com.baomidou.mybatisplus.core.toolkit.StringUtils;
+import com.baomidou.mybatisplus.generator.AutoGenerator;
+import com.baomidou.mybatisplus.generator.InjectionConfig;
+import com.baomidou.mybatisplus.generator.config.*;
+import com.baomidou.mybatisplus.generator.config.po.TableInfo;
+import com.baomidou.mybatisplus.generator.config.rules.NamingStrategy;
+import com.baomidou.mybatisplus.generator.engine.FreemarkerTemplateEngine;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Scanner;
+
+/**
+ * 代码生成器
+ */
+public class CodeGenerator {
+ /**
+ * 读取控制台内容
+ *
+ * @param tip the tip
+ * @return the string
+ */
+ public static String scanner(String tip) {
+ Scanner scanner = new Scanner(System.in);
+ StringBuilder help = new StringBuilder();
+ help.append("请输入" + tip + "：");
+ System.out.println(help.toString());
+ if (scanner.hasNext()) {
+ String ipt = scanner.next();
+ if (StringUtils.isNotEmpty(ipt)) {
+ return ipt;
+ }
+ }
+ throw new MybatisPlusException("请输入正确的" + tip + "！");
+ }
+
+ /**
+ * The entry point of application.
+ *
+ * @param args the input arguments
+ */
+ public static void main(String[] args) {
+ // 代码生成器
+ AutoGenerator mpg = new AutoGenerator();
+
+ // 全局配置
+ GlobalConfig gc = new GlobalConfig();
+ // 项目路径
+ String projectPath = "F:/@project@/@dianli@/springboot-demo/demo";
+ gc.setOutputDir(projectPath + "/src/main/java");
+ gc.setAuthor("duanledexianxianxian");
+ gc.setOpen(false);
+ gc.setFileOverride(true);
+ gc.setBaseResultMap(true);
+ gc.setBaseColumnList(true);
+ // gc.setSwagger2(true); 实体属性 Swagger2 注解
+ mpg.setGlobalConfig(gc);
+
+ // 数据源配置
+ DataSourceConfig dsc = new DataSourceConfig();
+ dsc.setUrl("jdbc:mysql://rm-bp1451sz2b7q8w95xvo.mysql.rds.aliyuncs.com:3306/convention?useUnicode=true&useSSL=false&characterEncoding=utf8");
+ // dsc.setSchemaName("public");
+ dsc.setDriverName("com.mysql.cj.jdbc.Driver");
+ dsc.setUsername("convention");
+ dsc.setPassword("Convention123");
+ mpg.setDataSource(dsc);
+
+ // 包配置
+ PackageConfig pc = new PackageConfig();
+ pc.setModuleName(scanner("模块名"));
+ pc.setParent("com.duanledexianxianxian.demo");
+ mpg.setPackageInfo(pc);
+
+ // 自定义配置
+ InjectionConfig cfg = new InjectionConfig() {
+ @Override
+ public void initMap() {
+ // to do nothing
+ }
+ };
+
+ // 如果模板引擎是 freemarker
+ String templatePath = "/templates/mapper.xml.ftl";
+ // 如果模板引擎是 velocity
+ // String templatePath = "/templates/mapper.xml.vm";
+
+ // 自定义输出配置
+ List focList = new ArrayList<>();
+ // 自定义配置会被优先输出
+ focList.add(new FileOutConfig(templatePath) {
+ @Override
+ public String outputFile(TableInfo tableInfo) {
+ // 自定义输出文件名 ， 如果你 Entity 设置了前后缀、此处注意 xml 的名称会跟着发生变化！！
+ return projectPath + "/src/main/resources/mapper/" + pc.getModuleName()
+ + "/" + tableInfo.getEntityName() + "Mapper" + StringPool.DOT_XML;
+ }
+ });
+
+ cfg.setFileOutConfigList(focList);
+ mpg.setCfg(cfg);
+
+ // 配置模板
+ TemplateConfig templateConfig = new TemplateConfig();
+
+ templateConfig.setXml(null);
+ mpg.setTemplate(templateConfig);
+
+ // 策略配置
+ StrategyConfig strategy = new StrategyConfig();
+ strategy.setNaming(NamingStrategy.underline_to_camel);
+ strategy.setColumnNaming(NamingStrategy.underline_to_camel);
+// strategy.setSuperEntityClass("你自己的父类实体,没有就不用设置!");
+ strategy.setEntityLombokModel(true);
+ strategy.setRestControllerStyle(true);
+ // 公共父类
+// strategy.setSuperControllerClass("你自己的父类控制器,没有就不用设置!");
+ // 写于父类中的公共字段
+// strategy.setSuperEntityColumns("id");
+ strategy.setInclude(scanner("表名，多个英文逗号分割").split(","));
+ strategy.setControllerMappingHyphenStyle(true);
+ strategy.setTablePrefix(pc.getModuleName() + "_");
+ mpg.setStrategy(strategy);
+ mpg.setTemplateEngine(new FreemarkerTemplateEngine());
+ mpg.execute();
+ }
+}
diff --git a/demo/src/main/java/com/duanledexianxianxian/demo/common/util/BeanUtils.java b/demo/src/main/java/com/duanledexianxianxian/demo/common/util/BeanUtils.java
new file mode 100644
index 0000000000000000000000000000000000000000..d043c9f7d7ff7aeed0963b178f80cd76a3c2aa9c
--- /dev/null
+++ b/demo/src/main/java/com/duanledexianxianxian/demo/common/util/BeanUtils.java
@@ -0,0 +1,575 @@
+package com.duanledexianxianxian.demo.common.util;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.BeansException;
+import org.springframework.beans.FatalBeanException;
+import org.springframework.util.Assert;
+import org.springframework.util.ClassUtils;
+
+import java.beans.PropertyDescriptor;
+import java.lang.reflect.Field;
+import java.lang.reflect.Method;
+import java.lang.reflect.Modifier;
+import java.util.*;
+
+
+/**
+ * BeanUtil提供一系列与bean相关的操作.
+ *
+ * @author duanledexianxianxian
+ * @date 2019-02-14 23:35:22
+ */
+public class BeanUtils extends org.springframework.beans.BeanUtils {
+
+ /**
+ * The constant logger.
+ */
+ private static Logger logger = LoggerFactory.getLogger(BeanUtils.class);
+ /**
+ * The constant SERIAL_VERSION_UID.
+ */
+ private static final String SERIAL_VERSION_UID = "serialVersionUID";
+
+ /**
+ * The constant COMPARE_TYPE_INTEGER.
+ */
+ private static final String COMPARE_TYPE_INTEGER = "java.lang.Integer";
+ /**
+ * The constant COMPARE_TYPE_STRING.
+ */
+ private static final String COMPARE_TYPE_STRING = "java.lang.String";
+
+
+ /**
+ * Copy properties.
+ *
+ * @param source the source
+ * @param target the target
+ * @throws BeansException the beans exception
+ */
+ public static void copyProperties(Object source, Object target) throws BeansException {
+ copyProperties(source, target, null, (String[]) null);
+ }
+
+ /**
+ * Copy properties.
+ *
+ * @param source the source
+ * @param target the target
+ * @param editable the editable
+ * @param ignoreProperties the ignore properties
+ * @throws BeansException the beans exception
+ */
+ private static void copyProperties(Object source, Object target, Class editable, String... ignoreProperties)
+ throws BeansException {
+
+ Assert.notNull(source, "Source must not be null");
+ Assert.notNull(target, "Target must not be null");
+
+ Class actualEditable = target.getClass();
+ if (editable != null) {
+ if (!editable.isInstance(target)) {
+ throw new IllegalArgumentException("Target class [" + target.getClass().getName()
+ + "] not assignable to Editable class [" + editable.getName() + "]");
+ }
+ actualEditable = editable;
+ }
+ PropertyDescriptor[] targetPds = getPropertyDescriptors(actualEditable);
+ List ignoreList = (ignoreProperties != null ? Arrays.asList(ignoreProperties) : null);
+
+ for (PropertyDescriptor targetPd : targetPds) {
+ Method writeMethod = targetPd.getWriteMethod();
+ boolean ignoreCondition = ignoreList == null || !ignoreList.contains(targetPd.getName());
+ if (writeMethod != null && ignoreCondition) {
+ PropertyDescriptor sourcePd = getPropertyDescriptor(source.getClass(), targetPd.getName());
+ if (sourcePd != null) {
+ Method readMethod = sourcePd.getReadMethod();
+ boolean isAssignable = ClassUtils.isAssignable(writeMethod.getParameterTypes()[0], readMethod.getReturnType());
+ if (readMethod != null && isAssignable) {
+ try {
+ setReadMethod(readMethod);
+ Object value = readMethod.invoke(source);
+ // 这里判断以下value是否为空 当然这里也能进行一些特殊要求的处理 例如绑定时格式转换等等
+ setWriteMethodMethod(value, writeMethod, target);
+ } catch (Throwable ex) {
+ throw new FatalBeanException(
+ "Could not copy property '" + targetPd.getName() + "' from source to target", ex);
+ }
+ }
+ }
+ }
+ }
+ }
+
+ /**
+ * Sets read method.
+ *
+ * @param readMethod the read method
+ */
+ private static void setReadMethod(Method readMethod) {
+ if (!Modifier.isPublic(readMethod.getDeclaringClass().getModifiers())) {
+ readMethod.setAccessible(true);
+ }
+ }
+
+ /**
+ * Sets write method method.
+ *
+ * @param value the value
+ * @param writeMethod the write method
+ * @param target the target
+ * @throws Exception the exception
+ */
+ private static void setWriteMethodMethod(Object value, Method writeMethod, Object target) throws Exception {
+ if (value != null) {
+ if (!Modifier.isPublic(writeMethod.getDeclaringClass().getModifiers())) {
+ writeMethod.setAccessible(true);
+ }
+ writeMethod.invoke(target, value);
+ }
+ }
+
+
+ /**
+ * 复制对象.
+ *
+ * @param the type parameter
+ * @param entity the entity
+ * @param targetCls the target cls
+ * @return the t
+ */
+ public static T copyObject(Object entity, Class targetCls) {
+ // 如果entity,直接返回null
+ if (entity == null) {
+ return null;
+ }
+ Object target = null;
+ try {
+ target = targetCls.newInstance();
+ copyProperties(entity, target);
+ } catch (InstantiationException | IllegalAccessException e) {
+ logger.error("error:{}", e);
+ }
+ return (T) target;
+ }
+
+ /**
+ * 复制对象
+ *
+ * @param list the list
+ * @param targetCls the target cls
+ * @return list list
+ */
+ public static List copyList(List list, Class targetCls) {
+ List resultList = new ArrayList();
+ if (list != null && list.size() > 0) {
+ for (Object entity : list) {
+ resultList.add(copyObject(entity, targetCls));
+ }
+ }
+ return resultList;
+ }
+
+
+ /**
+ * java反射bean的get方法
+ *
+ * @param objectClass the object class
+ * @param fieldName the field name
+ * @return get method
+ */
+ @SuppressWarnings("unchecked")
+ public static Method getGetMethod(Class objectClass, String fieldName) {
+ StringBuffer sb = new StringBuffer();
+ sb.append("get");
+ sb.append(fieldName.substring(0, 1).toUpperCase());
+ sb.append(fieldName.substring(1));
+ try {
+ return objectClass.getMethod(sb.toString());
+ } catch (NoSuchMethodException e) {
+ e.printStackTrace();
+ logger.error("error:{}", e);
+ }
+ return null;
+ }
+
+
+ /**
+ * java反射bean的set方法
+ *
+ * @param objectClass the object class
+ * @param fieldName the field name
+ * @return set method
+ */
+ @SuppressWarnings("unchecked")
+ public static Method getSetMethod(Class objectClass, String fieldName) {
+ try {
+ Class[] parameterTypes = new Class[1];
+ Field field = objectClass.getDeclaredField(fieldName);
+ parameterTypes[0] = field.getType();
+ StringBuffer sb = new StringBuffer();
+ sb.append("set");
+ sb.append(fieldName.substring(0, 1).toUpperCase());
+ sb.append(fieldName.substring(1));
+ Method method = objectClass.getMethod(sb.toString(), parameterTypes);
+ return method;
+ } catch (Exception e) {
+ e.printStackTrace();
+ logger.error("error:{}", e);
+ }
+ return null;
+ }
+
+
+ /**
+ * 执行set方法
+ *
+ * @param o 执行对象
+ * @param fieldName 属性
+ * @param value 值
+ */
+ public static void invokeSet(Object o, String fieldName, Object value) {
+ Method method = getSetMethod(o.getClass(), fieldName);
+ try {
+ method.invoke(o, new Object[]{value});
+ } catch (Exception e) {
+ e.printStackTrace();
+ logger.error("error:{}", e);
+ }
+ }
+
+ /**
+ * 这个函数主要用于将字符串和数字型分开 前台都是字符串 根据model类型转换 现在仅支持String int 不是这两个类型不做set函数
.
+ *
+ * @param o the o
+ * @param fieldName the field name
+ * @param value the value
+ */
+ public static void invokeSetStringInt(Object o, String fieldName, String value) {
+ Method method = getGetMethod(o.getClass(), fieldName);
+ String type = method.getReturnType().getName();
+ if (COMPARE_TYPE_INTEGER.equals(type)) {
+ invokeSet(o, fieldName, (value == null) ? null : Integer.parseInt(value));
+ } else if (COMPARE_TYPE_STRING.equals(type)) {
+ invokeSet(o, fieldName, value);
+ } else {
+ logger.error("set 函数不能设置Sting和int以外的函数,设置类型:" + type + ",方法:" + method.getName());
+ }
+ }
+
+ /**
+ * 执行get方法
+ *
+ * @param o 执行对象
+ * @param fieldName 属性
+ * @return the object
+ */
+ public static Object invokeGet(Object o, String fieldName) {
+ Method method = getGetMethod(o.getClass(), fieldName);
+ try {
+ return method.invoke(o, new Object[0]);
+ } catch (Exception e) {
+ e.printStackTrace();
+ logger.error("error:{}", e);
+ }
+ return null;
+ }
+
+
+ /**
+ * 将返回值包装成String 如果是空则仍然保持空.
+ *
+ * @param o the o
+ * @param fieldName the field name
+ * @return the string
+ */
+ public static String invokeGetString(Object o, String fieldName) {
+ Object obj = invokeGet(o, fieldName);
+ return (obj == null) ? null : String.valueOf(obj);
+ }
+
+
+ /**
+ * Merger obj object.
+ *
+ * @param 项目域对象如果为空，则直接返回产品域对象项目域对象字段属性为空，则使用产品域覆盖项目域字段
+ * @param parent 产品域对象
+ * @param son 项目域对象
+ * @param refClass class对象
+ * @return the object
+ */
+ public static Object mergerObj(T parent, T son, Class refClass) {
+ Object obj = null;
+ try {
+ obj = refClass.newInstance();
+ if (parent == null) {
+ obj = son;
+ } else if (son == null) {
+ obj = parent;
+ } else {
+ for (Field field : refClass.getDeclaredFields()) {
+ String fieldName = field.getName();
+ if (SERIAL_VERSION_UID.equalsIgnoreCase(fieldName)) {
+ continue;
+ }
+ Object value = invokeGet(son, fieldName);
+ if (value == null) {
+ value = invokeGet(parent, fieldName);
+ }
+ invokeSet(obj, fieldName, value);
+ }
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ logger.error("error:{}", e);
+ }
+ logger.debug("Page object:" + obj);
+ return obj;
+ }
+
+
+ /**
+ * Merger obj object.
+ *
+ * @param the type parameter
+ * @param parent the parent
+ * @param son the son
+ * @param refClassParent the ref class parent
+ * @param refClassSon the ref class son
+ * @return the object
+ */
+ public static Object mergerObj(T parent, T son, Class refClassParent, Class refClassSon) {
+ return mergerObj(parent, son, refClassParent, refClassSon, null);
+ }
+
+
+ /**
+ * Merger obj object.
+ *
+ * @param 父对象为空，则直接返回子对象
+ * 子对象为空，则将子对象域父对象相同的字段拷贝给obj
+ * 父对象与子对象都不为空，现将子对象的值拷贝给obj，在将子对象与父对象相同的字段拷贝给obj
+ * 例如：比如指标与业务视图字段合并，则指标为父对象、业务视图字段为子对象变量命名有问题
+ * @param parent 父对象
+ * @param son 子对象
+ * @param refClassParent 父class对象
+ * @param refClassSon 子class对象
+ * @param prefix 前缀
+ * @return the object
+ */
+ public static Object mergerObj(T parent, T son, Class refClassParent,
+ Class refClassSon, String prefix) {
+ Map publicFieldMap = new HashMap<>(100);
+ Object obj = null;
+ try {
+ //比较父class对象与子class对象，找出字段相同的字段
+ for (Field pField : refClassParent.getDeclaredFields()) {
+ for (Field sField : refClassSon.getDeclaredFields()) {
+ if (sField.getName().equals(pField.getName())) {
+ publicFieldMap.put(pField.getName(), sField.getName());
+ break;
+ } else if (prefix != null && sField.getName().equals(prefix + pField.getName())) {
+ publicFieldMap.put(pField.getName(), sField.getName());
+ break;
+ }
+ }
+ }
+
+ obj = refClassSon.newInstance();
+ //父对象为空，直接返回父对象给obj
+ if (parent == null) {
+ obj = son;
+ } else
+ //子对象为空，将父对象中与子对象中相同字段的值复制给obj
+ if (son == null) {
+ for (Map.Entry entry : publicFieldMap.entrySet()) {
+ if (SERIAL_VERSION_UID.equalsIgnoreCase(entry.getValue())) {
+ continue;
+ }
+ Object value = invokeGet(parent, entry.getValue());
+ invokeSet(obj, entry.getValue(), value);
+ }
+ } else {
+ //先将子对象拷贝给obj
+ for (Field field : refClassSon.getDeclaredFields()) {
+ if (SERIAL_VERSION_UID.equalsIgnoreCase(field.getName())) {
+ continue;
+ }
+ Object value = invokeGet(son, field.getName());
+ invokeSet(obj, field.getName(), value);
+ }
+ //将相同字段的值拷贝给obj
+ for (Map.Entry entry : publicFieldMap.entrySet()) {
+ String pFieldName = entry.getKey();
+ if (SERIAL_VERSION_UID.equalsIgnoreCase(entry.getValue())) {
+ continue;
+ }
+ Object value = invokeGet(son, entry.getValue());
+ if (null == value || "".equals(value)) {
+ value = invokeGet(parent, pFieldName);
+ }
+ invokeSet(obj, entry.getValue(), value);
+ }
+ }
+ } catch (Exception e) {
+ logger.error("error:{}", e);
+ }
+ return obj;
+ }
+
+
+ /**
+ * Division obj t.
+ *
+ * @param the type parameter
+ * @param parent 父对象
+ * @param son 子对象
+ * @param newSon 新的子对象
+ * @param refClass class对象
+ * @return T t
+ */
+ public static T divisionObj(T parent, T son, T newSon, Class refClass) {
+ return divisionObj(parent, son, newSon, refClass, "");
+ }
+
+
+ /**
+ * 比较产品域对象、项目域对象、页面对象，返回最后需要插入数据库中的对象
+ *
+ * @param the type parameter
+ * @param parent 父对象
+ * @param son 子对象
+ * @param newSon 新的子对象
+ * @param refClass class对象
+ * @param excludeFields 不需要比较字段的列表
+ * @return T t
+ */
+ public static T divisionObj(T parent, T son, T newSon, Class refClass, String... excludeFields) {
+ for (Field field : refClass.getDeclaredFields()) {
+ if (SERIAL_VERSION_UID.equalsIgnoreCase(field.getName())) {
+ continue;
+ }
+ //排除不需要比较的字段
+ if (!"".equals(excludeFields) && Arrays.asList(excludeFields).contains(field.getName())) {
+ continue;
+ }
+ /*项目域不存在，则说明该元素只是项目化没有修改，表里面不存在*/
+ Object valueSon = (son == null) ? null : invokeGet(son, field.getName());
+ /*子对象的对应的属性为空，则继承与产品域的属性，如果没有修改则继续继承*/
+ if (valueSon == null) {
+ Object valueNewSon = invokeGet(newSon, field.getName());
+ Object valueParent = invokeGet(parent, field.getName());
+ if (valueParent != null && valueParent.equals(valueNewSon)) {
+ invokeSet(newSon, field.getName(), null);
+ }
+ }
+ }
+ return newSon;
+ }
+
+ /**
+ * 应用场景，产品域字段列表跟项目域字段列表合并，以keyName作为主键，相同的keyName，则使用项目域的覆盖产品域的
+ *
+ * @param the type parameter
+ * @param parentList 父域列表
+ * @param sonList 子域列表
+ * @param keyName 主键
+ * @return list list
+ */
+ public static List mergerList(List parentList, List sonList, String keyName) {
+ List resultList = new ArrayList();
+ Map map = new HashMap<>(100);
+ if (parentList == null) {
+ resultList.addAll(sonList);
+ return resultList;
+ }
+ if (sonList == null) {
+ resultList.addAll(parentList);
+ return resultList;
+ }
+ resultList.addAll(parentList);
+ for (T obj : parentList) {
+ Object keyFieldName = invokeGet(obj, keyName);
+ map.put(keyFieldName, obj);
+ }
+ int size = sonList.size();
+ for (int i = 0; i < size; i++) {
+ Object keyFieldName = invokeGet(sonList.get(i), keyName);
+ if (map.containsKey(keyFieldName)) {
+ resultList.remove(map.get(keyFieldName));
+ resultList.add(i, sonList.get(i));
+ } else {
+ resultList.add(sonList.get(i));
+ }
+ }
+ return resultList;
+ }
+
+
+ /**
+ * 返回dto的所有属性字段名称 返回其中所有字段(除serialVersionUID之外) 可以用于设置值.
+ *
+ * @param the type parameter
+ * @param refClass the ref class
+ * @return the string [ ]
+ */
+ public static String[] getAllFieldName(Class refClass) {
+ Field[] allField = refClass.getDeclaredFields();
+ List allFieldList = new ArrayList();
+ for (int i = 0, j = 0; i < allField.length; i++) {
+ String filedName = allField[i].getName();
+ if (!SERIAL_VERSION_UID.equalsIgnoreCase(filedName)) {
+ allFieldList.add(filedName);
+ }
+ }
+ return allFieldList.toArray(new String[allFieldList.size()]);
+ }
+
+
+ /**
+ * 返回dto的所有Field字段 返回其中所有字段(除serialVersionUID之外) 可以用于设置值.
+ *
+ * @param the type parameter
+ * @param refClass the ref class
+ * @return the field [ ]
+ */
+ public static Field[] getAllField(Class refClass) {
+ Field[] allField = refClass.getDeclaredFields();
+ List allFieldList = new ArrayList();
+ for (int i = 0, j = 0; i < allField.length; i++) {
+ if (!SERIAL_VERSION_UID.equalsIgnoreCase(allField[i].getName())) {
+ allFieldList.add(allField[i]);
+ }
+ }
+ return allFieldList.toArray(new Field[allFieldList.size()]);
+ }
+
+
+ /**
+ * 获取指定字段名称查找在class中的对应的Field对象(包括查找父类)
+ *
+ * @param clazz 指定的class
+ * @param fieldName 字段名称
+ * @return Field对象 class field
+ */
+ public static Field getClassField(Class clazz, String fieldName) {
+ if (!Object.class.getName().equals(clazz.getName())) {
+ Field[] declaredFields = clazz.getDeclaredFields();
+ for (Field field : declaredFields) {
+ if (field.getName().equals(fieldName)) {
+ return field;
+ }
+ }
+ Class superClass = clazz.getSuperclass();
+ if (superClass != null) {
+ // 简单的递归一下
+ return getClassField(superClass, fieldName);
+ }
+ }
+ return null;
+ }
+
+
+}
+
diff --git a/demo/src/main/java/com/duanledexianxianxian/demo/domain/dto/MenuDTO.java b/demo/src/main/java/com/duanledexianxianxian/demo/domain/dto/MenuDTO.java
new file mode 100644
index 0000000000000000000000000000000000000000..923d35d8d22b97a91d40eb2be55c7f80464a44cf
--- /dev/null
+++ b/demo/src/main/java/com/duanledexianxianxian/demo/domain/dto/MenuDTO.java
@@ -0,0 +1,48 @@
+package com.duanledexianxianxian.demo.domain.dto;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * 菜单传输对象
+ *
+ * @author duanledexianxianxian
+ * @since 2020 -03-19
+ */
+@Data
+public class MenuDTO implements Serializable {
+
+ /**
+ * The constant serialVersionUID.
+ */
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 菜单编号
+ */
+ private Long menuId;
+
+ /**
+ * 菜单url
+ */
+ private String menuUrl;
+
+ /**
+ * 菜单名称
+ */
+ private String menuName;
+
+ /**
+ * 菜单编码
+ */
+ private String menuCode;
+
+ /**
+ * 创建时间
+ */
+ private LocalDateTime createTime;
+
+
+}
diff --git a/demo/src/main/java/com/duanledexianxianxian/demo/domain/dto/UserDTO.java b/demo/src/main/java/com/duanledexianxianxian/demo/domain/dto/UserDTO.java
new file mode 100644
index 0000000000000000000000000000000000000000..1b0011b5e424ee8a8cf9601742aa4e5fa92ce923
--- /dev/null
+++ b/demo/src/main/java/com/duanledexianxianxian/demo/domain/dto/UserDTO.java
@@ -0,0 +1,54 @@
+package com.duanledexianxianxian.demo.domain.dto;
+
+import com.duanledexianxianxian.demo.domain.entity.Menu;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDate;
+import java.util.List;
+
+/**
+ * 用户传输对象
+ *
+ * @author duanledexianxianxian
+ * @since 2020 -03-19
+ */
+@Data
+public class UserDTO implements Serializable {
+
+ /**
+ * The constant serialVersionUID.
+ */
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 用户编号
+ */
+ private Long userId;
+
+ /**
+ * 用户名称
+ */
+ private String userName;
+
+ /**
+ * 用户昵称
+ */
+ private String nickName;
+
+ /**
+ * 年龄
+ */
+ private Integer age;
+
+ /**
+ * 生日
+ */
+ private LocalDate birthday;
+
+ /**
+ * 菜单列表
+ */
+ List menuList;
+
+}
diff --git a/demo/src/main/java/com/duanledexianxianxian/demo/domain/model/query/MenuForm.java b/demo/src/main/java/com/duanledexianxianxian/demo/domain/model/query/MenuForm.java
new file mode 100644
index 0000000000000000000000000000000000000000..8dfb283707af5c7262d44397b138022df44c9d85
--- /dev/null
+++ b/demo/src/main/java/com/duanledexianxianxian/demo/domain/model/query/MenuForm.java
@@ -0,0 +1,48 @@
+package com.duanledexianxianxian.demo.domain.model.query;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * 菜单表单对象
+ *
+ * @author duanledexianxianxian
+ * @since 2020-03-19
+ */
+@Data
+public class MenuForm implements Serializable {
+
+ private static final long serialVersionUID = 1L;
+ /**
+ * 用户编号
+ */
+ private Long userId;
+ /**
+ * 菜单编号
+ */
+ private Long menuId;
+
+ /**
+ * 菜单url
+ */
+ private String menuUrl;
+
+ /**
+ * 菜单名称
+ */
+ private String menuName;
+
+ /**
+ * 菜单编码
+ */
+ private String menuCode;
+
+ /**
+ * 创建时间
+ */
+ private LocalDateTime createTime;
+
+
+}
diff --git a/demo/src/main/java/com/duanledexianxianxian/demo/domain/model/query/MenuQuery.java b/demo/src/main/java/com/duanledexianxianxian/demo/domain/model/query/MenuQuery.java
new file mode 100644
index 0000000000000000000000000000000000000000..7abe4519669ed17de25fe16edde4d2e977ba28cb
--- /dev/null
+++ b/demo/src/main/java/com/duanledexianxianxian/demo/domain/model/query/MenuQuery.java
@@ -0,0 +1,23 @@
+package com.duanledexianxianxian.demo.domain.model.query;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 菜单查询对象
+ *
+ * @author duanledexianxianxian
+ * @since 2020 -03-19
+ */
+@Data
+public class MenuQuery implements Serializable {
+
+ /**
+ * 菜单名称
+ */
+ private String menuName;
+
+
+
+}
diff --git a/demo/src/main/java/com/duanledexianxianxian/demo/domain/model/query/UserForm.java b/demo/src/main/java/com/duanledexianxianxian/demo/domain/model/query/UserForm.java
new file mode 100644
index 0000000000000000000000000000000000000000..1c5d98a287b73ee2ed1cbe3eab2723272afb6a01
--- /dev/null
+++ b/demo/src/main/java/com/duanledexianxianxian/demo/domain/model/query/UserForm.java
@@ -0,0 +1,47 @@
+package com.duanledexianxianxian.demo.domain.model.query;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDate;
+
+/**
+ * 用户表单对象
+ *
+ * @author duanledexianxianxian
+ * @since 2020 -03-19
+ */
+@Data
+public class UserForm implements Serializable {
+
+ /**
+ * The constant serialVersionUID.
+ */
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 用户编号
+ */
+ private Long userId;
+
+ /**
+ * 用户名称
+ */
+ private String userName;
+
+ /**
+ * 用户昵称
+ */
+ private String nickName;
+
+ /**
+ * 年龄
+ */
+ private Integer age;
+
+ /**
+ * 生日
+ */
+ private LocalDate birthday;
+
+}
diff --git a/demo/src/main/java/com/duanledexianxianxian/demo/domain/model/query/UserQuery.java b/demo/src/main/java/com/duanledexianxianxian/demo/domain/model/query/UserQuery.java
new file mode 100644
index 0000000000000000000000000000000000000000..e31f052aed84c7fa674eda1e8784741a97b847a7
--- /dev/null
+++ b/demo/src/main/java/com/duanledexianxianxian/demo/domain/model/query/UserQuery.java
@@ -0,0 +1,40 @@
+package com.duanledexianxianxian.demo.domain.model.query;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDate;
+
+/**
+ * 用户查询对象
+ *
+ * @author duanledexianxianxian
+ * @since 2020 -03-19
+ */
+@Data
+public class UserQuery implements Serializable {
+
+ /**
+ * The constant serialVersionUID.
+ */
+ private static final long serialVersionUID = 1L;
+ /**
+ * The Page num.
+ */
+ Long pageNum=1L;
+ /**
+ * The Page size.
+ */
+ Long pageSize=10L;
+
+ /**
+ * 用户名称
+ */
+ private String userName;
+
+ /**
+ * 用户昵称
+ */
+ private String nickName;
+
+}
diff --git a/demo/src/main/java/com/duanledexianxianxian/demo/domain/model/vo/MenuVO.java b/demo/src/main/java/com/duanledexianxianxian/demo/domain/model/vo/MenuVO.java
new file mode 100644
index 0000000000000000000000000000000000000000..d52f421c30410495871d6337f1f3cc7dba713259
--- /dev/null
+++ b/demo/src/main/java/com/duanledexianxianxian/demo/domain/model/vo/MenuVO.java
@@ -0,0 +1,45 @@
+package com.duanledexianxianxian.demo.domain.model.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * 菜单vo对象
+ *
+ * @author duanledexianxianxian
+ * @since 2020-03-19
+ */
+@Data
+public class MenuVO implements Serializable {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 菜单编号
+ */
+ private Long menuId;
+
+ /**
+ * 菜单url
+ */
+ private String menuUrl;
+
+ /**
+ * 菜单名称
+ */
+ private String menuName;
+
+ /**
+ * 菜单编码
+ */
+ private String menuCode;
+
+ /**
+ * 创建时间
+ */
+ private LocalDateTime createTime;
+
+
+}
diff --git a/demo/src/main/java/com/duanledexianxianxian/demo/domain/model/vo/UserDetailVO.java b/demo/src/main/java/com/duanledexianxianxian/demo/domain/model/vo/UserDetailVO.java
new file mode 100644
index 0000000000000000000000000000000000000000..1164354fcec11c3c9aec20088334503eb30c574c
--- /dev/null
+++ b/demo/src/main/java/com/duanledexianxianxian/demo/domain/model/vo/UserDetailVO.java
@@ -0,0 +1,52 @@
+package com.duanledexianxianxian.demo.domain.model.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDate;
+import java.util.List;
+
+/**
+ * 用户vo对象
+ *
+ * @author duanledexianxianxian
+ * @since 2020 -03-19
+ */
+@Data
+public class UserDetailVO implements Serializable {
+
+ /**
+ * The constant serialVersionUID.
+ */
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 用户编号
+ */
+ private Long userId;
+
+ /**
+ * 用户名称
+ */
+ private String userName;
+
+ /**
+ * 用户昵称
+ */
+ private String nickName;
+
+ /**
+ * 年龄
+ */
+ private Integer age;
+
+ /**
+ * 生日
+ */
+ private LocalDate birthday;
+
+ /**
+ * The Menu list.
+ */
+ private List menuList;
+}
diff --git a/demo/src/main/java/com/duanledexianxianxian/demo/domain/model/vo/UserVO.java b/demo/src/main/java/com/duanledexianxianxian/demo/domain/model/vo/UserVO.java
new file mode 100644
index 0000000000000000000000000000000000000000..dd7f8e104bcffd683257480e3d2f25bb5a02d5b5
--- /dev/null
+++ b/demo/src/main/java/com/duanledexianxianxian/demo/domain/model/vo/UserVO.java
@@ -0,0 +1,47 @@
+package com.duanledexianxianxian.demo.domain.model.vo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.time.LocalDate;
+
+/**
+ * 用户vo对象
+ *
+ * @author duanledexianxianxian
+ * @since 2020 -03-19
+ */
+@Data
+public class UserVO implements Serializable {
+
+ /**
+ * The constant serialVersionUID.
+ */
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * 用户编号
+ */
+ private Long userId;
+
+ /**
+ * 用户名称
+ */
+ private String userName;
+
+ /**
+ * 用户昵称
+ */
+ private String nickName;
+
+ /**
+ * 年龄
+ */
+ private Integer age;
+
+ /**
+ * 生日
+ */
+ private LocalDate birthday;
+
+}
diff --git a/demo/src/main/resources/application.yml b/demo/src/main/resources/application.yml
new file mode 100644
index 0000000000000000000000000000000000000000..e69de29bb2d1d6434b8b29ae775ad8c2e48c5391
diff --git a/kafka/README.md b/kafka/README.md
deleted file mode 100644
index f5a3232cb9e2883aee348819de37a78964c2b4ad..0000000000000000000000000000000000000000
--- a/kafka/README.md
+++ /dev/null
@@ -1,23 +0,0 @@
-##### kafka配置
-
-```
-bootstrap.servers:kafka server的地址
-
-acks:写入kafka时，leader负责一个该partion读写，当写入partition时，需要将记录同步到repli节点，all是全部同步节点都返回成功，leader才返回ack。
-
-retris:写入失败时，重试次数。当leader节点失效，一个repli节点会替代成为leader节点，此时可能出现写入失败，当retris为0时，produce不会重复。retirs重发，此时repli节点完全成为leader节点，不会产生消息丢失。
-
-batch.size:produce积累到一定数据，一次发送。
-
-buffer.memory: produce积累数据一次发送，缓存大小达到buffer.memory就发送数据。
-
-linger.ms :当设置了缓冲区，消息就不会即时发送，如果消息总不够条数、或者消息不够buffer大小就不发送了吗？当消息超过linger时间，也会发送。
-
-key/value serializer：序列化类。
-```
-
-### 关于kafka序列化/反序列化
-
-https://www.jianshu.com/p/5da86afed228
-
-自定义Serializer和Deserializer非常痛苦，还有很多类型不支持，非常脆弱。复杂类型的支持更是一件痛苦的事情，不同版本之间的兼容性问题更是一个极大的挑战。由于Serializer和Deserializer影响到上下游系统，导致牵一发而动全身。自定义序列化&反序列化实现不是能力的体现，而是逗比的体现。所以强烈不建议自定义实现序列化&反序列化，推荐直接使用StringSerializer和StringDeserializer，然后使用json作为标准的数据传输格式。
\ No newline at end of file
diff --git a/kafka/kafka.iml b/kafka/kafka.iml
deleted file mode 100644
index 85ab1e7569283dbd96f1ec46a2719b900479c0e8..0000000000000000000000000000000000000000
--- a/kafka/kafka.iml
+++ /dev/null
@@ -1,101 +0,0 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/kafka/src/main/java/com/duanledexianxianxian/demo/kafka/Application.java b/kafka/src/main/java/com/duanledexianxianxian/demo/kafka/Application.java
deleted file mode 100644
index fd0a87d6545c90014c265cb206d0ff044509441f..0000000000000000000000000000000000000000
--- a/kafka/src/main/java/com/duanledexianxianxian/demo/kafka/Application.java
+++ /dev/null
@@ -1,21 +0,0 @@
-package com.duanledexianxianxian.demo.kafka;
-
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.boot.SpringApplication;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-
-/**
- * @author duanledexianxianxian
- * @date 2019/10/18 23:32
- * @since 1.0.0
- */
-@SpringBootApplication
-@Slf4j
-public class Application {
-
-
- public static void main(String[] args) {
- SpringApplication.run(Application.class, args);
-
- }
-}
diff --git a/kafka/src/main/java/com/duanledexianxianxian/demo/kafka/consumer/TestConsumer.java b/kafka/src/main/java/com/duanledexianxianxian/demo/kafka/consumer/TestConsumer.java
deleted file mode 100644
index 0459282455f46d3ca800e6163d8ae9df464cc1e9..0000000000000000000000000000000000000000
--- a/kafka/src/main/java/com/duanledexianxianxian/demo/kafka/consumer/TestConsumer.java
+++ /dev/null
@@ -1,26 +0,0 @@
-package com.duanledexianxianxian.demo.kafka.consumer;
-
-import org.apache.kafka.clients.consumer.ConsumerRecord;
-import org.springframework.kafka.annotation.KafkaListener;
-import org.springframework.stereotype.Component;
-
-/**
- * kafka消费者测试
- *
- * @author fengyuchenglun
- * @version 1.0.0
- */
-@Component
-public class TestConsumer {
-
- /**
- * Listen.
- *
- * @param record the record
- * @throws Exception the exception
- */
- @KafkaListener(topics = "topic_second")
- public void listen(ConsumerRecord record) throws Exception {
- System.out.printf("topic = %s, offset = %d, value = %s \n", record.topic(), record.offset(), record.value());
- }
-}
diff --git a/kafka/src/main/java/com/duanledexianxianxian/demo/kafka/controller/KafkaController.java b/kafka/src/main/java/com/duanledexianxianxian/demo/kafka/controller/KafkaController.java
deleted file mode 100644
index c6878baa7bc555ec7d8c111303a9b23c59c37696..0000000000000000000000000000000000000000
--- a/kafka/src/main/java/com/duanledexianxianxian/demo/kafka/controller/KafkaController.java
+++ /dev/null
@@ -1,24 +0,0 @@
-package com.duanledexianxianxian.demo.kafka.controller;
-
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.kafka.core.KafkaTemplate;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.RequestParam;
-import org.springframework.web.bind.annotation.RestController;
-
-/**
- * @author duanledexianxianxian
- * @date 2019/10/18 23:50
- * @since 1.0.0
- */
-@RestController
-public class KafkaController {
- @Autowired
- private KafkaTemplate kafkaTemplate;
-
- @GetMapping("/message/send")
- public boolean send(@RequestParam String message){
- kafkaTemplate.send("testTopic",message);
- return true;
- }
-}
diff --git a/kafka/src/main/java/com/duanledexianxianxian/demo/kafka/listener/AppListener.java b/kafka/src/main/java/com/duanledexianxianxian/demo/kafka/listener/AppListener.java
deleted file mode 100644
index fee2774b1152311fd8e99bb6f986f03a61a936d5..0000000000000000000000000000000000000000
--- a/kafka/src/main/java/com/duanledexianxianxian/demo/kafka/listener/AppListener.java
+++ /dev/null
@@ -1,66 +0,0 @@
-package com.duanledexianxianxian.demo.kafka.listener;
-
-import com.alibaba.fastjson.JSONObject;
-import com.duanledexianxianxian.demo.kafka.model.Student;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.lang3.RandomStringUtils;
-import org.apache.commons.lang3.RandomUtils;
-import org.apache.commons.lang3.concurrent.BasicThreadFactory;
-import org.apache.tomcat.util.threads.ThreadPoolExecutor;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.context.event.ApplicationReadyEvent;
-import org.springframework.context.ApplicationListener;
-import org.springframework.kafka.core.KafkaTemplate;
-import org.springframework.stereotype.Component;
-
-import java.time.LocalDateTime;
-import java.util.Random;
-import java.util.concurrent.*;
-
-/**
- * @author duanledexianxianxian
- * @date 2019/10/19 0:44
- * @since 1.0.0
- */
-@Component
-@Slf4j
-public class AppListener implements ApplicationListener {
- @Autowired
- private KafkaTemplate kafkaTemplate;
-
-
- @Override
- public void onApplicationEvent(ApplicationReadyEvent applicationReadyEvent) {
-
- ThreadFactory namedThreadFactory = new BasicThreadFactory.Builder().namingPattern("producer-kafka-pool-%d").daemon(true).build();
-
- ExecutorService pool = new ThreadPoolExecutor(5, 200,
- 0L, TimeUnit.MILLISECONDS,
- new LinkedBlockingQueue(1024), namedThreadFactory, new ThreadPoolExecutor.AbortPolicy());
- int i = 0;
- while (true) {
- int finalI = i;
- pool.execute(() -> {
- this.sendData(finalI);
- // sleep 5 seconds
- });
-
- try {
- Thread.sleep(new Random().nextInt(6) * 1000);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- i++;
- }
- }
-
- private void sendData(int i) {
- Student student = new Student();
- student.setStudentId(String.valueOf(i));
- student.setName("duanledexianxianxian" + new Random().nextInt(20));
- student.setAge(new Random().nextInt(19) + 6);
- student.setSex(Byte.valueOf(String.valueOf((new Random().nextInt(2)))));
- log.info("Thread:{} Send Data:{}", Thread.currentThread().getName(), student);
- kafkaTemplate.send("topic_first", JSONObject.toJSONString(student));
- }
-}
diff --git a/kafka/src/main/java/com/duanledexianxianxian/demo/kafka/model/Student.java b/kafka/src/main/java/com/duanledexianxianxian/demo/kafka/model/Student.java
deleted file mode 100644
index da1a5833b014512b2a2ade417f1c5646855ee6eb..0000000000000000000000000000000000000000
--- a/kafka/src/main/java/com/duanledexianxianxian/demo/kafka/model/Student.java
+++ /dev/null
@@ -1,35 +0,0 @@
-package com.duanledexianxianxian.demo.kafka.model;
-
-import lombok.Data;
-
-import java.io.Serializable;
-
-/**
- * 学生实体类
- *
- * @author duanledexianxianxian
- * @date 2019/10/19 0:32
- * @since 1.0.0
- */
-@Data
-public class Student implements Serializable {
- private static final long serialVersionUID = -4572819276161640638L;
- /**
- * 学生学号
- */
- private String studentId;
- /**
- * 学生姓名
- */
- private String name;
- /**
- * 学生年龄
- */
- private Integer age;
- /**
- * 学生性别
- * 0-男
- * 1-女
- */
- private Byte sex;
-}
diff --git a/kafka/src/main/resources/application.yml b/kafka/src/main/resources/application.yml
deleted file mode 100644
index 9ad2db81f0ce688fa3e4f33670058702e9bbd551..0000000000000000000000000000000000000000
--- a/kafka/src/main/resources/application.yml
+++ /dev/null
@@ -1,38 +0,0 @@
-spring:
- kafka:
- # 指定kafka server的地址，集群配多个，中间，逗号隔开
- bootstrap-servers: 113.105.144.9:9104
- #=============== provider =======================
- producer:
- # 写入失败时，重试次数。当leader节点失效，一个repli节点会替代成为leader节点，此时可能出现写入失败，
- # 当retris为0时，produce不会重复。retirs重发，此时repli节点完全成为leader节点，不会产生消息丢失。
- retries: 0
- # 每次批量发送消息的数量,produce积累到一定数据，一次发送
- batch-size: 16384
- # produce积累数据一次发送，缓存大小达到buffer.memory就发送数据
- buffer-memory: 33554432
- # 指定消息key和消息体的编解码方式
- key-serializer: org.apache.kafka.common.serialization.StringSerializer
- value-serializer: org.apache.kafka.common.serialization.StringSerializer
- properties:
- #当设置了缓冲区，消息就不会即时发送，如果消息总不够条数、或者消息不够buffer大小就不发送了吗？当消息超过linger时间，也会发送。
- linger.ms: 1
- #procedure要求leader在考虑完成请求之前收到的确认数，用于控制发送记录在服务端的持久化，其值可以为如下：
- #acks = 0 如果设置为零，则生产者将不会等待来自服务器的任何确认，该记录将立即添加到套接字缓冲区并视为已发送。在这种情况下，无法保证服务器已收到记录，并且重试配置将不会生效（因为客户端通常不会知道任何故障），为每条记录返回的偏移量始终设置为-1。
- #acks = 1 这意味着leader会将记录写入其本地日志，但无需等待所有副本服务器的完全确认即可做出回应，在这种情况下，如果leader在确认记录后立即失败，但在将数据复制到所有的副本服务器之前，则记录将会丢失。
- #acks = all 这意味着leader将等待完整的同步副本集以确认记录，这保证了只要至少一个同步副本服务器仍然存活，记录就不会丢失，这是最强有力的保证，这相当于acks = -1的设置。
- #可以设置的值为：all, -1, 0, 1
- acks: 1
-
- #=============== consumer =======================
- consumer:
- group-id: test
- # enable.auto.commit:true --> 设置自动提交offset
- enable-auto-commit: true
- # auto-commit'为true，则消费者偏移自动提交给Kafka的频率（以毫秒为单位），默认值为5000。:
- auto-commit-interval: 100ms
- # 指定消息key和消息体的编解码方式
- key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
- value-deserializer: org.apache.kafka.common.serialization.StringDeserializer
- properties:
- session.timeout.ms: 15000
\ No newline at end of file
diff --git a/menu/pom.xml b/menu/pom.xml
deleted file mode 100644
index 6aba2a9a81f7c9f92c106f8af51561d46cf1ae05..0000000000000000000000000000000000000000
--- a/menu/pom.xml
+++ /dev/null
@@ -1,16 +0,0 @@
-
-
-
- demo-parent
- com.duanledexianxianxian.demo
- 1.0-SNAPSHOT
-
- 4.0.0
-
- menu
-
-
-
-
\ No newline at end of file
diff --git a/menu/src/main/java/com/duanledexianxianxian/demo/Application.java b/menu/src/main/java/com/duanledexianxianxian/demo/Application.java
deleted file mode 100644
index 47325f18c6a484289ecb7cd759d3d9afd69b5b40..0000000000000000000000000000000000000000
--- a/menu/src/main/java/com/duanledexianxianxian/demo/Application.java
+++ /dev/null
@@ -1,94 +0,0 @@
-package com.duanledexianxianxian.demo;
-
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import com.google.common.collect.Lists;
-import org.springframework.beans.BeanUtils;
-import org.springframework.util.CollectionUtils;
-
-import java.util.Arrays;
-import java.util.List;
-import java.util.Map;
-import java.util.stream.Collectors;
-
-/**
- * @author duanledexianxianxian
- * @date 2020/1/12 23:51
- * @since 1.0.0
- */
-public class Application {
- private static String[][] menus = {
- {null, "0001", "用户管理", "/urlMgr"},
- {"0001", "00010001", "用户管理-添加用户", "/urlMgr/add"},
- {"0001", "00010002", "用户管理-修改用户", "/urlMgr/edit"},
- {"0001", "00010003", "用户管理-删除用户", "/urlMgr/delete"},
- {"0001", "00010004", "用户管理-查询用户", "/urlMgr/query"},
- {null, "0002", "系统管理", "/systemMgr"},
- {"0002", "00020001", "系统管理-系统管理0001", "/systemMgr/0001"},
- {"00020001", "000200010001", "系统管理-系统管理0001-系统管理0001", "/systemMgr/0001/0001"},
- {"000200010001", "0002000100010001", "系统管理-系统管理0001-系统管理0001-系统管理0001", "/systemMgr/0001/0001/0001"},
- };
-
- public static void main(String[] args) {
- List