修改MQ请求尸体，防止出错

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

@@ -20,6 +20,8 @@ public abstract class SqlCondBase<T extends SqlCondBase> implements SqlCond<T> {
 
     protected List<String> fields = new ArrayList<>();
 
+    protected Runnable debugRunnable = null;
+
     /**
      * 构造函数
      *
@@ -82,6 +84,10 @@ public abstract class SqlCondBase<T extends SqlCondBase> implements SqlCond<T> {
         if (sqlDataField.getCond() != this) {
             throw new RuntimeException("不能处理非本条件的字段");
         }
+        if (debugRunnable != null) {
+            // 用于断点调试的支持
+            debugRunnable.run();
+        }
         int condType = getCondType(model, sqlDataField);
         switch (condType) {
             case COND_TYPE_CONST_ONLY_PARA: {

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

@@ -19,7 +19,16 @@ public class SqlCondDefault extends SqlCondBase<SqlCondDefault> {
     }
 
     public SqlCondDefault(List<String> fields) {
+        this(null, fields);
+    }
+
+    public SqlCondDefault(Runnable debugRunnable, String... field) {
+        this(debugRunnable, Arrays.asList(field));
+    }
+
+    public SqlCondDefault(Runnable debugRunnable, List<String> fields) {
         super(fields);
+        super.debugRunnable = debugRunnable;
     }
 
 

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

@@ -37,7 +37,24 @@ public class SqlCondEquals extends SqlCondBase<SqlCondEquals> {
     }
 
     public SqlCondEquals(List<String> fields, Object... vals) {
+        this(null, fields, vals);
+    }
+
+    public SqlCondEquals(Runnable debugRunnable, String field, Object... vals) {
+        this(debugRunnable, Arrays.asList(field), vals);
+    }
+
+    public SqlCondEquals(Runnable debugRunnable, String[] fields, Object... vals) {
+        this(debugRunnable, Arrays.asList(fields), vals);
+    }
+
+    public SqlCondEquals(Runnable debugRunnable, TableFieldString field, Object... vals) {
+        this(debugRunnable, field.getFields(), vals);
+    }
+
+    public SqlCondEquals(Runnable debugRunnable, List<String> fields, Object... vals) {
         super(fields);
+        super.debugRunnable = debugRunnable;
         this.vals = vals;
         // 判断值是否为整形
         if (vals != null) {