消除成功接收处理

yzg-util-base/src/main/java/com/yanzuoguang/util/base/MethodField.java

@@ -6,6 +6,7 @@ import java.lang.reflect.Method;
 
 /**
  * 字段对应的类型的信息，依赖于字段操作类
+ * @author 颜佐光
  */
 public class MethodField {
     /**

yzg-util-base/src/main/java/com/yanzuoguang/util/base/ObjectHelper.java

@@ -13,6 +13,7 @@ import java.util.*;
 
 /**
  * 对象操作类，包含字段反射
+ * @author 颜佐光
  */
 public class ObjectHelper {
     /**

yzg-util-base/src/main/java/com/yanzuoguang/util/cache/MemoryCache.java

@@ -9,6 +9,7 @@ import java.util.Hashtable;
  * 内存缓存
  *
  * @param <T>
+ * @author 颜佐光
  */
 public class MemoryCache<T> {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/cache/MemoryCacheCenter.java

@@ -9,6 +9,7 @@ import java.util.Vector;
 
 /**
  * 内存缓存中心，负责自动清除过期缓存
+ * @author 颜佐光
  */
 public class MemoryCacheCenter {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/cache/MemoryCacheItem.java

@@ -6,6 +6,7 @@ import java.util.Date;
 /**
  * 内存缓存值
  * @param <T>
+ * @author 颜佐光
  */
 public class MemoryCacheItem<T> {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/contants/ResultConstants.java

@@ -3,6 +3,7 @@ package com.yanzuoguang.util.contants;
 /**
  * 系统服务返回code静态常量类
  * 要求所有返回code不要相同,便于统一规范服务代码
+ * @author 颜佐光
  */
 public final class ResultConstants {
     /**

yzg-util-base/src/main/java/com/yanzuoguang/util/contants/ResultMessageConstants.java

@@ -3,6 +3,7 @@ package com.yanzuoguang.util.contants;
 /**
  * 系统服务返回code静态常量类
  * 要求所有返回code不要相同,便于统一规范服务代码
+ * @author 颜佐光
  */
 public final class ResultMessageConstants {
     /**

yzg-util-base/src/main/java/com/yanzuoguang/util/exception/CodeException.java

@@ -2,7 +2,7 @@ package com.yanzuoguang.util.exception;
 
 /**
  * 途比达异常信息
- * Created by yanzu on 2018/7/13.
+ * @author 颜佐光
  */
 public class CodeException extends RuntimeException {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/exception/ExceptionHelper.java

@@ -6,6 +6,7 @@ import com.yanzuoguang.util.vo.ResponseResult;
 
 /**
  * 异常处理帮助类
+ * @author 颜佐光
  */
 public class ExceptionHelper {
     /**

yzg-util-base/src/main/java/com/yanzuoguang/util/exception/StatusException.java

@@ -3,6 +3,7 @@ package com.yanzuoguang.util.exception;
 
 /**
  * 状态异常错误
+ * @author 颜佐光
  */
 public class StatusException extends RuntimeException {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/extend/ConfigBase.java

@@ -4,6 +4,7 @@ import com.yanzuoguang.util.log.RunnableLog;
 
 /**
  * 配置参数
+ * @author 颜佐光
  */
 public class ConfigBase {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/helper/ByteHelper.java

@@ -8,6 +8,7 @@ import com.yanzuoguang.util.exception.CodeException;
  * <p>
  * Java和一些windows编程语言如c、c++、delphi所写的网络程序进行通讯时，需要进行相应的转换 高、低字节之间的转换
  * windows的字节序为低字节开头 linux,unix的字节序为高字节开头 java则无论平台变化，都是高字节开头
+ * @author 颜佐光
  */
 public class ByteHelper {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/helper/CheckerHelper.java

@@ -11,6 +11,7 @@ import java.util.regex.Pattern;
 
 /**
  * 参数业务逻辑校验
+ * @author 颜佐光
  */
 public final class CheckerHelper {
     public static final String PARAM_NOT_NULL_TIPS = "param [%s] is null";

yzg-util-base/src/main/java/com/yanzuoguang/util/helper/DateAutoHelper.java

@@ -8,6 +8,7 @@ import java.util.List;
 
 /**
  * 将时间格式字符串转换为时间
+ * @author 颜佐光
  */
 public class DateAutoHelper {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/helper/DateHelper.java

@@ -12,6 +12,7 @@ import java.util.Date;
 
 /**
  * 日期工具类
+ * @author 颜佐光
  */
 public class DateHelper {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/helper/EnumHelper.java

@@ -7,6 +7,7 @@ import java.util.HashMap;
 
 /**
  * 字符串和枚举进行转换
+ * @author 颜佐光
  */
 public class EnumHelper {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/helper/Event.java

@@ -7,6 +7,7 @@ import java.util.List;
  * Java事件处理类
  *
  * @param <T>
+ * @author 颜佐光
  */
 public class Event<T> {
     /**

yzg-util-base/src/main/java/com/yanzuoguang/util/helper/EventRun.java

@@ -4,6 +4,7 @@ package com.yanzuoguang.util.helper;
  * 执行的时候得事件处理类
  *
  * @param <T> 需要处理的数据的类型
+ * @author 颜佐光
  */
 public interface EventRun<T> {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/helper/FileHelper.java

@@ -11,6 +11,7 @@ import java.io.RandomAccessFile;
 
 /**
  * 登录相关函数
+ * @author 颜佐光
  */
 public class FileHelper {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/helper/HttpHelper.java

@@ -13,6 +13,7 @@ import java.net.URLConnection;
 
 /**
  * HTTP请求工具类
+ * @author 颜佐光
  */
 public class HttpHelper {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/helper/JsonHelper.java

@@ -5,7 +5,7 @@ import com.alibaba.fastjson.TypeReference;
 
 /**
  * JSON序列化的处理
- * Created by yanzu on 2017/5/28.
+ * @author 颜佐光
  */
 public class JsonHelper {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/helper/RunHelper.java

@@ -6,6 +6,7 @@ import com.yanzuoguang.util.thread.ThreadHelper;
 
 /**
  * 重复执行工具类
+ * @author 颜佐光
  */
 public class RunHelper {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/helper/StringHelper.java

@@ -14,6 +14,7 @@ import java.util.UUID;
 
 /**
  * 字符串帮主类
+ * @author 颜佐光
  */
 public class StringHelper {
     /**

yzg-util-base/src/main/java/com/yanzuoguang/util/helper/UrlHelper.java

@@ -9,6 +9,7 @@ import java.util.List;
 
 /**
  * 地址字符串处理
+ * @author 颜佐光
  */
 public class UrlHelper {
     /**

yzg-util-base/src/main/java/com/yanzuoguang/util/helper/ZipHelper.java

@@ -20,6 +20,11 @@ import java.util.zip.ZipFile;
 import java.util.zip.ZipOutputStream;
 
 
+/**
+ * ZIP压缩处理工具类
+ *
+ * @author 颜佐光
+ */
 public class ZipHelper {
 
     /**

yzg-util-base/src/main/java/com/yanzuoguang/util/log/Log.java

@@ -7,6 +7,7 @@ import java.util.HashMap;
 
 /**
  * 日志操作类
+ * @author 颜佐光
  */
 public class Log {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/log/LogDefault.java

@@ -4,6 +4,7 @@ import com.yanzuoguang.util.helper.DateHelper;
 
 /**
  * 日志处理默认处理函数
+ * @author 颜佐光
  */
 public class LogDefault implements RunnableLog {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/log/LogInfo.java

@@ -4,7 +4,7 @@ import java.util.Date;
 
 /**
  * 日志实体记录类
- * Created by yanzu on 2018/7/10.
+ * @author 颜佐光
  */
 public class LogInfo {
     /**

yzg-util-base/src/main/java/com/yanzuoguang/util/log/RunnableLog.java

@@ -2,6 +2,7 @@ package com.yanzuoguang.util.log;
 
 /**
  * 日志处理接口
+ * @author 颜佐光
  */
 public interface RunnableLog {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/table/TableHeadHelper.java

@@ -7,6 +7,7 @@ import java.util.Map;
 
 /**
  * 表头计算
+ * @author 颜佐光
  */
 public class TableHeadHelper {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/table/TableHeadItem.java

@@ -3,6 +3,7 @@ package com.yanzuoguang.util.table;
 
 /**
  * 列头
+ * @author 颜佐光
  */
 public class TableHeadItem {
     /**

yzg-util-base/src/main/java/com/yanzuoguang/util/thread/AbstractThreadList.java

@@ -9,6 +9,7 @@ import java.util.concurrent.TimeUnit;
 
 /**
  * 多线程处理队列
+ * @author 颜佐光
  */
 public abstract class AbstractThreadList<T extends Object> implements ThreadWaitExecute {
     private long threadID;

yzg-util-base/src/main/java/com/yanzuoguang/util/thread/ProcessData.java

@@ -5,6 +5,7 @@ import com.yanzuoguang.util.log.Log;
 
 /**
  * 进度数据
+ * @author 颜佐光
  */
 public class ProcessData {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/thread/RunInterval.java

@@ -2,6 +2,7 @@ package com.yanzuoguang.util.thread;
 
 /**
  * 循环执行任务
+ * @author 颜佐光
  */
 public class RunInterval {
     /**

yzg-util-base/src/main/java/com/yanzuoguang/util/thread/RunPlan.java

@@ -10,6 +10,7 @@ import java.util.List;
 
 /**
  * 自动执行任务
+ * @author 颜佐光
  */
 public class RunPlan {
     /**

yzg-util-base/src/main/java/com/yanzuoguang/util/thread/RunPlanData.java

@@ -4,6 +4,7 @@ import java.util.Date;
 
 /***
  * 任务项数据
+ * @author 颜佐光
  */
 public class RunPlanData {
     /**

yzg-util-base/src/main/java/com/yanzuoguang/util/thread/RunProcess.java

@@ -2,6 +2,7 @@ package com.yanzuoguang.util.thread;
 
 /**
  * 运行进度处理
+ * @author 颜佐光
  */
 public interface RunProcess {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/thread/RunnableData.java

@@ -4,6 +4,7 @@ import com.yanzuoguang.util.vo.ResponseResult;
 
 /**
  * 执行字符串
+ * @author 颜佐光
  */
 public interface RunnableData<T extends Object> {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/thread/RunnableList.java

@@ -4,6 +4,7 @@ import com.yanzuoguang.util.exception.CodeException;
 
 /**
  * 根据指定的线程数量， 执行多个Runnable对象
+ * @author 颜佐光
  */
 public class RunnableList extends AbstractThreadList<Runnable> {
     /**

yzg-util-base/src/main/java/com/yanzuoguang/util/thread/RunnableListAuto.java

@@ -6,6 +6,7 @@ import java.util.*;
 
 /**
  * 执行队列的数据,会根据其中的执行函数，自动优化执行循序
+ * @author 颜佐光
  */
 public final class RunnableListAuto {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/thread/RunnableListAutoItem.java

@@ -7,6 +7,7 @@ import java.util.Date;
 
 /**
  * 自动执行队列的某一项
+ * @author 颜佐光
  */
 public class RunnableListAutoItem implements Comparable<RunnableListAutoItem> {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/thread/ThreadHelper.java

@@ -9,6 +9,7 @@ import java.util.concurrent.Executors;
 
 /**
  * 线程帮助类
+ * @author 颜佐光
  */
 public class ThreadHelper {
     private static Object threadLock = new Object();

yzg-util-base/src/main/java/com/yanzuoguang/util/thread/ThreadListData.java

@@ -7,6 +7,7 @@ import java.util.Date;
  * 执行队列中的数据
  *
  * @param <T>
+ * @author 颜佐光
  */
 public class ThreadListData<T> {
     /**

yzg-util-base/src/main/java/com/yanzuoguang/util/thread/ThreadListNum.java

@@ -2,6 +2,7 @@ package com.yanzuoguang.util.thread;
 
 /**
  * 多线程处理时用于线程数量控制
+ * @author 颜佐光
  */
 public class ThreadListNum {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/thread/ThreadNext.java

@@ -5,6 +5,7 @@ import com.yanzuoguang.util.log.Log;
 
 /**
  * 线程执行类
+ * @author 颜佐光
  */
 public class ThreadNext {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/thread/ThreadWait.java

@@ -10,6 +10,7 @@ import java.util.TimerTask;
 
 /**
  * 等待某个任务完成后才能继续往下执行
+ * @author 颜佐光
  */
 public class ThreadWait {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/thread/ThreadWaitExecute.java

@@ -2,6 +2,7 @@ package com.yanzuoguang.util.thread;
 
 /**
  * 当前执行类库
+ * @author 颜佐光
  */
 public interface ThreadWaitExecute {
     /**

yzg-util-base/src/main/java/com/yanzuoguang/util/vo/BaseVo.java

@@ -6,6 +6,7 @@ import java.io.Serializable;
 
 /**
  * 基本数据类
+ * @author 颜佐光
  */
 public class BaseVo implements Serializable {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/vo/InitDao.java

@@ -2,6 +2,7 @@ package com.yanzuoguang.util.vo;
 
 /**
  * 初始化Dao数据
+ * @author 颜佐光
  */
 public interface InitDao {
     /**

yzg-util-base/src/main/java/com/yanzuoguang/util/vo/LogVo.java

@@ -2,6 +2,7 @@ package com.yanzuoguang.util.vo;
 
 /**
  * 日志实例
+ * @author 颜佐光
  */
 public class LogVo extends BaseVo {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/vo/MapRow.java

@@ -4,7 +4,7 @@ import java.util.HashMap;
 
 /**
  * 行映射
- * created by yanzu on 2017/5/31.
+ * @author 颜佐光
  */
 public class MapRow extends HashMap<String,Object> {
 }

yzg-util-base/src/main/java/com/yanzuoguang/util/vo/PageSizeData.java

@@ -4,7 +4,9 @@ import java.util.ArrayList;
 import java.util.List;
 
 /**
- * Created by yanzu on 2017/5/30.
+ * 查询分页数据结果呈现类
+ *
+ * @author 颜佐光
  */
 public class PageSizeData<T extends Object> extends PageSizeReqVo {
 

yzg-util-base/src/main/java/com/yanzuoguang/util/vo/PageSizeReq.java

@@ -2,6 +2,7 @@ package com.yanzuoguang.util.vo;
 
 /**
  * 查询时分页请求接口
+ * @author 颜佐光
  */
 public interface PageSizeReq {
     /**

yzg-util-base/src/main/java/com/yanzuoguang/util/vo/Ref.java

@@ -4,6 +4,7 @@ package com.yanzuoguang.util.vo;
  * 引用值，方便修改
  *
  * @param <T>
+ * @author 颜佐光
  */
 public class Ref<T> {
     public T value;

yzg-util-base/src/main/java/com/yanzuoguang/util/vo/ResponseResult.java

@@ -4,6 +4,7 @@ import com.yanzuoguang.util.contants.ResultConstants;
 
 /**
  * 接口之间的通讯结果
+ * @author 颜佐光
  */
 public class ResponseResult<T> extends BaseVo {
 

yzg-util-cloud/src/main/java/com/yanzuoguang/cloud/aop/BaseRequestAspect.java

@@ -19,6 +19,10 @@ import java.util.ArrayList;
 import java.util.List;
 import java.util.concurrent.LinkedBlockingQueue;
 
+/**
+ * 基本处理拦截类
+ * @author 颜佐光
+ */
 public class BaseRequestAspect implements ThreadNext.Next {
 
 

yzg-util-cloud/src/main/java/com/yanzuoguang/cloud/aop/FeignAspect.java

@@ -14,6 +14,7 @@ import org.springframework.stereotype.Component;
 
 /**
  * 接口切面，用于验证接口回调返回参数
+ * @author 颜佐光
  */
 @Aspect
 @Component

yzg-util-cloud/src/main/java/com/yanzuoguang/cloud/aop/HttpAspectUtil.java

@@ -8,6 +8,7 @@ import javax.servlet.http.HttpServletRequest;
 
 /**
  * 虚拟拦截类
+ * @author 颜佐光
  */
 public class HttpAspectUtil {
 

yzg-util-cloud/src/main/java/com/yanzuoguang/cloud/aop/LogFeign.java

@@ -5,6 +5,7 @@ import com.yanzuoguang.util.vo.ResponseResult;
 
 /**
  * 调用外置服务保存日志对象
+ * @author 颜佐光
  */
 public interface LogFeign {
 

yzg-util-cloud/src/main/java/com/yanzuoguang/cloud/aop/RequestCacheResult.java

@@ -4,6 +4,7 @@ import java.util.Date;
 
 /**
  * 请求缓存的数据
+ * @author 颜佐光
  */
 public class RequestCacheResult {
 

yzg-util-cloud/src/main/java/com/yanzuoguang/cloud/env/YzgEnvironmentPostProcessor.java

@@ -15,6 +15,7 @@ import org.springframework.stereotype.Component;
 
 /**
  * 环境变量处理,通过服务处理环境变量
+ * @author 颜佐光
  */
 @Component
 public class YzgEnvironmentPostProcessor implements EnvironmentPostProcessor {

yzg-util-cloud/src/main/java/com/yanzuoguang/cloud/helper/HttpFileHelper.java

@@ -8,6 +8,7 @@ import java.io.*;
 
 /**
  * HTTP文件
+ * @author 颜佐光
  */
 public class HttpFileHelper extends HttpHelper {
     

yzg-util-db/src/main/java/com/yanzuoguang/code/CodePwd.java

@@ -2,6 +2,7 @@ package com.yanzuoguang.code;
 
 /**
  * 加密算法生成接口
+ * @author 颜佐光
  */
 public interface CodePwd {
     /**

yzg-util-db/src/main/java/com/yanzuoguang/code/CodePwdImpl.java

@@ -10,6 +10,7 @@ import java.util.Random;
 
 /**
  * 加密算法0版实现
+ * @author 颜佐光
  */
 public class CodePwdImpl implements CodePwd {
 

yzg-util-db/src/main/java/com/yanzuoguang/dao/BaseDao.java

@@ -3,7 +3,7 @@ package com.yanzuoguang.dao;
 
 /**
  * 数据基本操作接口
- * created by yanzu on 2017/5/30.
+ * @author 颜佐光
  */
 public interface BaseDao {
 

yzg-util-db/src/main/java/com/yanzuoguang/dao/DaoConst.java

 package com.yanzuoguang.dao;
 
 /**
- * created by yanzu on 2017/5/30.
+ * DAO层处理基本美剧
+ *
+ * @author 颜佐光
  */
 public class DaoConst {
     /**

yzg-util-db/src/main/java/com/yanzuoguang/dao/impl/BaseDaoImpl.java

@@ -17,7 +17,7 @@ import java.util.Map;
 
 /**
  * 数据库操作的基本工具类
- * created by yanzu on 2017/5/30.
+ * @author 颜佐光
  */
 public abstract class BaseDaoImpl extends BaseDaoSql implements BaseDao {
 

yzg-util-db/src/main/java/com/yanzuoguang/dao/impl/BaseDaoSql.java

@@ -20,6 +20,7 @@ import java.util.regex.Pattern;
 
 /**
  * SQL语句基本操作类
+ * @author 颜佐光
  */
 public abstract class BaseDaoSql {
 

yzg-util-db/src/main/java/com/yanzuoguang/dao/impl/SqlData.java

@@ -7,7 +7,7 @@ import java.util.List;
 
 /**
  * SQL语句基本信息
- * created by yanzu on 2017/5/30.
+ * @author 颜佐光
  */
 public class SqlData {
 

yzg-util-db/src/main/java/com/yanzuoguang/dao/impl/SqlDataField.java

@@ -5,6 +5,7 @@ import java.util.List;
 
 /**
  * SQL语句的字段
+ * @author 颜佐光
  */
 public class SqlDataField {
 

yzg-util-db/src/main/java/com/yanzuoguang/dao/impl/TableFieldVo.java

@@ -4,7 +4,7 @@ import com.yanzuoguang.dao.DaoConst;
 
 /**
  * 表结构的基本信息
- * created by yanzu on 2017/5/30.
+ * @author 颜佐光
  */
 public class TableFieldVo {
 

yzg-util-db/src/main/java/com/yanzuoguang/dao/impl/TableSqlCache.java

@@ -14,7 +14,7 @@ import java.util.regex.Pattern;
 
 /**
  * 缓存的SQL语句信息
- * created by yanzu on 2017/5/30.
+ * @author 颜佐光
  */
 public class TableSqlCache {
 

yzg-util-db/src/main/java/com/yanzuoguang/db/DbExecute.java

@@ -6,7 +6,9 @@ import com.yanzuoguang.util.vo.MapRow;
 import java.util.List;
 
 /**
- * created by yanzu on 2017/5/30.
+ * 数据库链接处理工具类
+ *
+ * @author 颜佐光
  */
 public interface DbExecute {
 

yzg-util-db/src/main/java/com/yanzuoguang/db/impl/AllBeanRowMapper.java

@@ -25,7 +25,7 @@ import java.util.Map;
 
 /**
  * 将数据映射为结果
- * Created by yanzu on 2017/5/31.
+ * @author 颜佐光
  */
 public class AllBeanRowMapper<T> implements RowMapper<T> {
 

yzg-util-db/src/main/java/com/yanzuoguang/db/impl/DbExecuteImpl.java

@@ -18,6 +18,7 @@ import java.util.List;
 
 /**
  * 数据库操作类
+ * @author 颜佐光
  */
 @Component
 public class DbExecuteImpl implements DbExecute {

yzg-util-db/src/main/java/com/yanzuoguang/db/impl/DbPrintSql.java

@@ -7,6 +7,11 @@ import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
 
+/**
+ * 打印SQL语句日志工具类
+ *
+ * @author 颜佐光
+ */
 @Component
 public class DbPrintSql {
 

yzg-util-db/src/main/java/com/yanzuoguang/db/impl/DbRow.java

@@ -2,6 +2,7 @@ package com.yanzuoguang.db.impl;
 
 /**
  * 处理行数据
+ * @author 颜佐光
  */
 public interface DbRow<T> {
     /**

yzg-util-db/src/main/java/com/yanzuoguang/extend/ConfigDb.java

@@ -5,6 +5,7 @@ import org.springframework.stereotype.Component;
 
 /**
  * 打印SQL日志
+ * @author 颜佐光
  */
 @Component
 public class ConfigDb {

yzg-util-db/src/main/java/com/yanzuoguang/service/BaseService.java

@@ -4,7 +4,7 @@ import java.util.List;
 
 /**
  * 基本服务接口
- * created by yanzu on 2017/5/29.
+ * @author 颜佐光
  */
 public interface BaseService<T> {
     /**

yzg-util-db/src/main/java/com/yanzuoguang/service/impl/BaseServiceImpl.java

@@ -10,7 +10,7 @@ import java.util.List;
 
 /**
  * 基本服务实现
- * created by yanzu on 2017/5/31.
+ * @author 颜佐光
  */
 public abstract class BaseServiceImpl<T> implements BaseService<T> {
     /**

yzg-util-mq/src/main/java/com/yanzuoguang/mq/base/MqConfigurable.java

@@ -18,6 +18,10 @@ import org.springframework.stereotype.Component;
 import javax.annotation.Resource;
 import java.nio.charset.Charset;
 
+/**
+ * MQ队列相关配置信息
+ * @author 颜佐光
+ */
 @Configurable
 @Component
 public class MqConfigurable implements RabbitTemplate.ConfirmCallback, RabbitTemplate.ReturnCallback {

yzg-util-mq/src/main/java/com/yanzuoguang/mq/base/MqConsumeDynamic.java

@@ -12,6 +12,11 @@ import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
 
+/**
+ * MQ消费者通过代码初始化
+ *
+ * @author 颜佐光
+ */
 @Component
 public class MqConsumeDynamic {
 

yzg-util-mq/src/main/java/com/yanzuoguang/mq/base/MyRabbitTemplate.java

@@ -4,6 +4,7 @@ import org.springframework.amqp.rabbit.core.RabbitTemplate;
 
 /**
  * 我的处理实例
+ * @author 颜佐光
  */
 public class MyRabbitTemplate {
 

yzg-util-mq/src/main/java/com/yanzuoguang/mq/base/consumer/ConsumerSimpleMessageListenerContainer.java

@@ -2,6 +2,11 @@ package com.yanzuoguang.mq.base.consumer;
 
 import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer;
 
+/**
+ * 自定义消息容器类
+ *
+ * @author 颜佐光
+ */
 public class ConsumerSimpleMessageListenerContainer extends SimpleMessageListenerContainer {
 
 

yzg-util-mq/src/main/java/com/yanzuoguang/mq/dao/BeanDao.java

@@ -14,6 +14,10 @@ import org.springframework.stereotype.Component;
 import java.util.HashMap;
 import java.util.Map;
 
+/**
+ * 基本队列处理类
+ * @author 颜佐光
+ */
 @Component
 public class BeanDao {
 

yzg-util-mq/src/main/java/com/yanzuoguang/mq/dao/MessageDao.java

@@ -8,6 +8,7 @@ import java.util.List;
 
 /**
  * 日志接口基本操作类
+ * @author 颜佐光
  */
 public interface MessageDao extends BaseDao {
 

yzg-util-mq/src/main/java/com/yanzuoguang/mq/dao/QueueDao.java

@@ -10,6 +10,7 @@ import java.util.List;
 
 /**
  * 日志接口基本操作类
+ * @author 颜佐光
  */
 public interface QueueDao extends BaseDao {
 

yzg-util-mq/src/main/java/com/yanzuoguang/mq/dao/impl/MessageDaoImpl.java

@@ -12,6 +12,11 @@ import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
+/**
+ * 消息队列处理工具类
+ *
+ * @author 颜佐光
+ */
 @Component
 public class MessageDaoImpl extends BaseDaoImpl implements MessageDao {
     private static final String UPDATE_BATCH_SQL = "UPDATE_BATCH_SQL";

yzg-util-mq/src/main/java/com/yanzuoguang/mq/dao/impl/QueueDaoImpl.java

@@ -11,6 +11,11 @@ import org.springframework.stereotype.Component;
 
 import java.util.List;
 
+/**
+ * 消息队列Dao层实现类
+ *
+ * @author 颜佐光
+ */
 @Component
 public class QueueDaoImpl extends BaseDaoImpl implements QueueDao {
 

yzg-util-mq/src/main/java/com/yanzuoguang/mq/plan/MqMessageInitPlan.java

@@ -14,6 +14,7 @@ import java.util.List;
 
 /**
  * 消息队列初始化服务，用于重启时，初始化消息队列对象
+ * @author 颜佐光
  */
 @Component
 public class MqMessageInitPlan implements ThreadNext.Next, Runnable {

yzg-util-mq/src/main/java/com/yanzuoguang/mq/plan/MqQueueInitPlan.java

@@ -7,6 +7,7 @@ import org.springframework.stereotype.Component;
 
 /**
  * 消息队列初始化服务，用于重启时，初始化消息队列对象
+ * @author 颜佐光
  */
 @Component
 public class MqQueueInitPlan implements ThreadNext.Next {

yzg-util-mq/src/main/java/com/yanzuoguang/mq/service/MessageService.java

 package com.yanzuoguang.mq.service;
 
 
-import com.rabbitmq.client.Channel;
 import com.yanzuoguang.mq.vo.MessageVo;
-import org.springframework.amqp.core.Message;
 
 import java.util.List;
 
 /**
  * 发送消息服务
+ * @author 颜佐光
  */
 public interface MessageService {
 

yzg-util-mq/src/main/java/com/yanzuoguang/mq/service/MqService.java

@@ -10,6 +10,7 @@ import org.springframework.amqp.core.Message;
 
 /**
  * 消息队列服务
+ * @author 颜佐光
  */
 public interface MqService {
     /**

yzg-util-mq/src/main/java/com/yanzuoguang/mq/service/QueueService.java

@@ -7,6 +7,7 @@ import com.yanzuoguang.util.vo.PageSizeData;
 
 /**
  * 队列服务
+ * @author 颜佐光
  */
 public interface QueueService {
     /**

yzg-util-mq/src/main/java/com/yanzuoguang/mq/service/impl/MessageServiceImpl.java

@@ -22,6 +22,7 @@ import java.util.List;
 
 /**
  * 发送消息服务的实现
+ * @author 颜佐光
  */
 @Component
 public class MessageServiceImpl implements MessageService {

yzg-util-mq/src/main/java/com/yanzuoguang/mq/service/impl/MqServiceImpl.java

@@ -16,6 +16,10 @@ import org.springframework.stereotype.Component;
 
 import java.io.IOException;
 
+/**
+ * 消息队列服务实现类
+ * @author 颜佐光
+ */
 @Component
 public class MqServiceImpl implements MqService {
 

yzg-util-mq/src/main/java/com/yanzuoguang/mq/service/impl/QueueServiceImpl.java

@@ -15,6 +15,7 @@ import java.util.List;
 
 /**
  * 交换器服务类
+ * @author 颜佐光
  */
 @Component
 public class QueueServiceImpl implements QueueService {

yzg-util-mq/src/main/java/com/yanzuoguang/mq/vo/MessageVo.java

@@ -9,6 +9,7 @@ import com.yanzuoguang.util.vo.InitDao;
 
 /**
  * 发送消息
+ * @author 颜佐光
  */
 @TableAnnotation("Queue_Message")
 public class MessageVo extends BaseVo implements InitDao {

yzg-util-mq/src/main/java/com/yanzuoguang/mq/vo/QueueVo.java

@@ -9,6 +9,7 @@ import com.yanzuoguang.util.vo.InitDao;
 
 /**
  * 创建队列
+ * @author 颜佐光
  */
 @TableAnnotation("Queue_Queue")
 public class QueueVo extends BaseVo implements InitDao {

yzg-util-mq/src/main/java/com/yanzuoguang/mq/vo/req/QueueQueryReqVo.java

@@ -4,6 +4,7 @@ import com.yanzuoguang.util.vo.PageSizeReqVo;
 
 /**
  * 请求实体队列
+ * @author 颜佐光
  */
 public class QueueQueryReqVo extends PageSizeReqVo {
     /**