不记录系统日志

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

 package com.yanzuoguang.dao.cond;
 
+import com.yanzuoguang.dao.impl.SqlCodeParameter;
 import com.yanzuoguang.dao.impl.SqlDataField;
 import com.yanzuoguang.util.base.ObjectHelper;
+import com.yanzuoguang.util.helper.ArrayHelper;
 import com.yanzuoguang.util.helper.StringHelper;
 
 import java.util.Arrays;
@@ -51,6 +53,10 @@ public class SqlCondDefault extends SqlCondBase<SqlCondDefault> {
                 if (StringHelper.isEmpty(val) || StringHelper.isEmptyArray(val)) {
                     continue;
                 }
+                // 代码片段
+                if (val instanceof SqlCodeParameter && ArrayHelper.isEmpty(((SqlCodeParameter) val).getLatitude())) {
+                    continue;
+                }
                 // 只要有值不为空，则条件满足
                 return COND_TYPE_CODE_COND;
             }

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

@@ -653,6 +653,9 @@ public abstract class BaseDaoSql {
             String field = m.group(1);
             // 根据输入字段从参数中取值
             Object val = ObjectHelper.get(model, field);
+            if (val instanceof SqlCodeParameter) {
+                sql = getSqlCodeParameter(paras, sql, name, (SqlCodeParameter) val);
+            } else {
                 // 判断是否为数组
                 boolean isArray = ArrayHelper.isArrayOrList(val);
                 if (isArray) {
@@ -664,6 +667,7 @@ public abstract class BaseDaoSql {
                     paras.add(val);
                 }
             }
+        }
         return sql;
     }
 
@@ -715,6 +719,25 @@ public abstract class BaseDaoSql {
         return sql;
     }
 
+    /**
+     * 获取代码片段
+     *
+     * @param paras
+     * @param sql
+     * @param name
+     * @param val
+     * @return
+     */
+    protected String getSqlCodeParameter(List<Object> paras, String sql, String name, SqlCodeParameter val) {
+        StringBuilder sb = new StringBuilder();
+        for (Object item : val.getLatitude()) {
+            String codeTo = StringHelper.getCodeString(val.getLatitudeCode(), item);
+            sb.append(codeTo);
+        }
+        sql = sql.replaceFirst(name, sb.toString());
+        return sql;
+    }
+
     /**
      * 添加数组型参数
      *

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

@@ -13,7 +13,7 @@ import java.util.List;
 public class SqlCodeParameter {
 
     /**
-     * 纬度
+     * 纬度SQL语句，里面的{xxx}对应 latitude 数组中对象的字段.
      */
     private String latitudeCode = StringHelper.EMPTY;