异常修复

.idea/compiler.xml

@@ -9,9 +9,6 @@
         <module name="mainFactory" />
       </profile>
     </annotationProcessing>
-    <bytecodeTargetLevel>
-      <module name="mainFactory" target="17" />
-    </bytecodeTargetLevel>
   </component>
   <component name="JavacSettings">
     <option name="ADDITIONAL_OPTIONS_OVERRIDE">

mainFactory/src/main/java/org/bfkj/config/AppConfig.java

@@ -14,13 +14,12 @@ public class AppConfig {
     public static Integer SERVICE_ERR_MAX = 3; //服务最大连续异常次数
 
     public static  Integer  count = 0;
-    public static Long begin = 0L;
 
 
     public static HashMap<String, String> staticEvent = new HashMap<String, String>() {{
         put("select", "0");
         put("update", "2");
-        put("insert", "3");
+        put("insert", "1");
         put("delete", "3");
     }};
     /***

mainFactory/src/main/java/org/bfkj/protocol/MyKafKa.java

@@ -24,21 +24,21 @@ public class MyKafKa {
      * @return 读取内容信息
      */
     public Map<String, Object> readMethod(String sourceObjectName, String library_id, String connectConfig, String  pollNumber,String fetch) {
-        if (Objects.isNull(sourceObjectName)) {
-            return MapTools.processFail("队列为空");
-        }
-        Map<String, Object> connectConfigMaps;
-        connectConfigMaps = MapTools.mapStrToMap_connect(connectConfig);
-        if (!connectConfigMaps.containsKey("group.id")) {
-            connectConfigMaps.put("group.id", "groupid" + (String.format("%s", library_id)));
-        }
-        connectConfigMaps.put("max.poll.records", pollNumber == null ? 1 : Integer.parseInt(pollNumber));
-        connectConfigMaps.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
-        connectConfigMaps.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
-        if (MapTools.isNotBlank(fetch)){
-            connectConfigMaps.put("max.partition.fetch.bytes", 11534336);
-        }
         if (Objects.isNull(consumer)) {
+            if (Objects.isNull(sourceObjectName)) {
+                return MapTools.processFail("队列为空");
+            }
+            Map<String, Object> connectConfigMaps;
+            connectConfigMaps = MapTools.mapStrToMap_connect(connectConfig);
+            if (!connectConfigMaps.containsKey("group.id")) {
+                connectConfigMaps.put("group.id", "groupid" + (String.format("%s", library_id)));
+            }
+            connectConfigMaps.put("max.poll.records", pollNumber == null ? 1 : Integer.parseInt(pollNumber));
+            connectConfigMaps.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
+            connectConfigMaps.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
+            if (MapTools.isNotBlank(fetch)){
+                connectConfigMaps.put("max.partition.fetch.bytes", 11534336);
+            }
             consumer = new KafkaConsumer<>(connectConfigMaps);
             consumer.subscribe(Collections.singleton(sourceObjectName));
         }
@@ -46,9 +46,8 @@ public class MyKafKa {
         //todo 1. 如果一次行读取多条 2.偏移修改  : // Duration.ofSeconds(1): 如果没有数据则此处会等待1秒
         isPool = true;
         ConsumerRecords<String, Object> records = consumer.poll(Duration.ofSeconds(1));
-        int count = records.count();
         String message = "";
-        if (count > 0) {
+        if (records.count() > 0) {
             for (ConsumerRecord<String, Object> record : records.records(sourceObjectName)) {
                 message = message.concat(record.value().toString());
             }

mainFactory/src/main/java/org/bfkj/utils/DataFormat.java

@@ -371,6 +371,10 @@ public class DataFormat {
                                 HashMap<String, Object> objectObjectHashMap = new HashMap<>();
                                 objectObjectHashMap.putAll(tempDataMap);
                                 objectObjectHashMap.putAll(tempLuggageMap);
+
+                                if (Objects.isNull(objectObjectHashMap.get("abnormalState"))) {
+                                    objectObjectHashMap.remove("abnormalState");
+                                }
 //                                    tempDataMap.putAll(tempLuggageMap);//添加行李信息
                                 returnDataList.add(specialHandler(objectObjectHashMap, dataObjectId));//添加到返回数组中
                             }
@@ -392,411 +396,444 @@ public class DataFormat {
         }
     }
 
-    /**
-     * //必要的特殊处理：
-     * //承运航班：如果有F则F否则如果有I则I否则空
-     * //起飞机场：如果有F则V否则如果有I则I否则空
-     * //降落机场：如果有F则F否则V
-     * //读取地点：如果有J则J否则如果有D则D否则有H则H
-     * //读取时间：如果有J则J否则如果有D则D否则接收时间
-     * //当前结果：如果有dataState则dataState否则有B则B否则有X则X
-     *
-     * @return
-     */
-
-
+        /**
+         * //必要的特殊处理：
+         * //承运航班：如果有F则F否则如果有I则I否则空
+         * //起飞机场：如果有F则V否则如果有I则I否则空
+         * //降落机场：如果有F则F否则V
+         * //读取地点：如果有J则J否则如果有D则D否则有H则H
+         * //读取时间：如果有J则J否则如果有D则D否则接收时间
+         * //当前结果：如果有dataState则dataState否则有B则B否则有X则X
+         *
+         * @return
+         */
+
+
+        public static Map<String, Object> specialHandler (HashMap < String, Object > inMap, String dataObjectId){
+            String outAirport = inMap.containsKey("flightNo") ? "sourceAirport" : (inMap.containsKey("inairport") ? "inairport" : null);
+            if (MapTools.isNotBlank(outAirport)) {
+                inMap.put("outAirport", inMap.get(outAirport));
+            }
+            String landAirport = inMap.containsKey("target_airport") ? "target_airport" : (inMap.containsKey("sourceAirport") ? "sourceAirport" : null);
+            if (MapTools.isNotBlank(landAirport)) {
+                inMap.put("landAirport", inMap.get(landAirport));
+            }
 
-    public static Map<String, Object> specialHandler(HashMap<String, Object> inMap, String dataObjectId) {
-        String outAirport = inMap.containsKey("flightNo") ? "sourceAirport" : (inMap.containsKey("inairport") ? "inairport" : null);
-        if (MapTools.isNotBlank(outAirport)) {
-            inMap.put("outAirport", inMap.get(outAirport));
-        }
-        String landAirport = inMap.containsKey("target_airport") ? "target_airport" : (inMap.containsKey("sourceAirport") ? "sourceAirport" : null);
-        if (MapTools.isNotBlank(landAirport)) {
-            inMap.put("landAirport", inMap.get(landAirport));
-        }
+            String carrierFlights = inMap.containsKey("flightNo") ? "flightNo" : (inMap.containsKey("inflightNo") ? "inflightNo" : null);
+            if (MapTools.isNotBlank(carrierFlights)) {
+                inMap.put("carrierFlights", inMap.get(carrierFlights));
+            }
+            String carrierFlightsDate = inMap.containsKey("flightDate") ? "flightDate" : (inMap.containsKey("inflightDate") ? "inflightDate" : null);
+            if (MapTools.isNotBlank(carrierFlightsDate)) {
+                inMap.put("carrierFlightsDate", inMap.get(carrierFlightsDate));
+            }
 
-        String carrierFlights = inMap.containsKey("flightNo") ? "flightNo" : (inMap.containsKey("inflightNo") ? "inflightNo" : null);
-        if (MapTools.isNotBlank(carrierFlights)) {
-            inMap.put("carrierFlights", inMap.get(carrierFlights));
-        }
-        String carrierFlightsDate = inMap.containsKey("flightDate") ? "flightDate" : (inMap.containsKey("inflightDate") ? "inflightDate" : null);
-        if (MapTools.isNotBlank(carrierFlightsDate)) {
-            inMap.put("carrierFlightsDate", inMap.get(carrierFlightsDate));
-        }
+            String readAddess = inMap.containsKey("location_code") ? "location_code" : (inMap.containsKey("checkInLocation") ? "checkInLocation" : inMap.containsKey("operationArea") ? "operationArea" : (inMap.containsKey("location_describe") ? "location_describe" : null));
+            if (MapTools.isNotBlank(readAddess)) {
+                inMap.put("readAddess", inMap.get(readAddess));
+            }
+            String readTime = inMap.containsKey("processing_time") ? "processing_time" : (inMap.containsKey("checkInDate") ? "checkInDate" : null);
+            inMap.put("readTime", MapTools.isBlank(readTime) ? sdf.format(new Date(MapTools.isBlank(dataObjectId) ? (System.currentTimeMillis()) : Long.parseLong(dataObjectId.substring(0, 13)))) : inMap.get(readTime));
 
-        String readAddess = inMap.containsKey("location_code") ? "location_code" : (inMap.containsKey("checkInLocation") ? "checkInLocation" : inMap.containsKey("operationArea") ? "operationArea" : (inMap.containsKey("location_describe") ? "location_describe" : null));
-        if (MapTools.isNotBlank(readAddess)) {
-            inMap.put("readAddess", inMap.get(readAddess));
-        }
-        String readTime = inMap.containsKey("processing_time") ? "processing_time" : (inMap.containsKey("checkInDate") ? "checkInDate" : null);
-        inMap.put("readTime", MapTools.isBlank(readTime) ? sdf.format(new Date(MapTools.isBlank(dataObjectId) ? (System.currentTimeMillis()) : Long.parseLong(dataObjectId.substring(0, 13)))) : inMap.get(readTime));
+            String currentResult = inMap.containsKey("dataState") ? "dataState" : (inMap.containsKey("abnormalState") ? "abnormalState" : inMap.containsKey("securityInspectionResults") ? "securityInspectionResults" : null);
+            if (MapTools.isNotBlank(readAddess) && Objects.nonNull(inMap.get(currentResult))) {
+                inMap.put("currentResult", inMap.get(currentResult));
+            }
 
-        String currentResult = inMap.containsKey("dataState") ? "dataState" : (inMap.containsKey("abnormalState") ? "abnormalState" : inMap.containsKey("securityInspectionResults") ? "securityInspectionResults" : null);
-        if (MapTools.isNotBlank(readAddess) && Objects.nonNull(inMap.get(currentResult))) {
-            inMap.put("currentResult", inMap.get(currentResult));
+            if (inMap.containsKey("dataType") && Objects.equals(inMap.get("dataType"), "BSM")) {
+                inMap.put("nodeCode", "CHECKIN");
+            }
+            if (Objects.nonNull(inMap.get("readAddess")) && "ARRIVED,LOAD,INFL,SECURITY,SORT,UNLOAD".contains(inMap.get("readAddess").toString())) {
+                inMap.put("nodeCode", inMap.get("readAddess"));
+            }
+            if (Objects.nonNull(inMap.get("securityInspectionResults"))) {
+                inMap.put("nodeCode","SECURITY");
+            }
+            Object sourceSign = inMap.get("sourceSign");
+            Object secondary_code = inMap.get("secondary_code");
+            Object location_describe = inMap.get("location_describe");
+            Object to_location_describe = inMap.get("to_location_describe");
+            if (Objects.nonNull(sourceSign)){
+                if (!inMap.containsKey("nodeCode") && Objects.equals(sourceSign,"T") &&Objects.equals(secondary_code,"G") ){
+                    inMap.put("nodeCode","TRANSFER");
+                }
+                if (!inMap.containsKey("nodeCode") &&!Objects.equals(sourceSign,"X") &&Objects.equals(location_describe,"RM") && Objects.equals(to_location_describe,"AC") ){
+                    inMap.put("nodeCode","INFL");
+                }
+                if (!inMap.containsKey("nodeCode") &&Objects.equals(sourceSign,"X") &&Objects.equals(location_describe,"AC")){
+                    inMap.put("nodeCode","UNLOAD");
+                }
+                if (!inMap.containsKey("nodeCode") &&!Objects.equals(sourceSign,"X") &&Objects.equals(secondary_code,"S")){
+                    inMap.put("nodeCode","SORT");
+                }
+                if (!inMap.containsKey("nodeCode") &&!Objects.equals(sourceSign,"X") &&Objects.equals(secondary_code,"R")){
+                    inMap.put("nodeCode","LOAD");
+                }
+                if (!inMap.containsKey("nodeCode") &&Objects.equals(sourceSign,"X") && !Objects.equals(secondary_code,"S")){
+                    inMap.put("nodeCode","ARRIVED");
+                }
+            }
+            return inMap;
         }
-        return inMap;
-    }
 
-    /**
-     * xml转map 定制化
-     *
-     * @param xml                     字符串
-     * @param isTwoDimensionalization 是否需要二维化
-     * @param noDiKaList              是否需要dika
-     * @param translateName           需要转义的名称
-     * @return code message returnData
-     */
-    public static Map<String, Object> customMadexmlToMap(String xml, boolean isTwoDimensionalization, List<String> noDiKaList, Map<String, String> translateName) {
-        Map<String, Object> returnMap = xmlToMapFormat(xml); //  code ,message ,returenData
-        if (returnMap.get("code").equals("-1")) return returnMap;
-        if (isTwoDimensionalization) {
-            Map<String, Object> xmlMap = (Map<String, Object>) returnMap.get("returnData");
-            returnMap = twoDimensionalizationFormat(xmlMap, noDiKaList); //  code ,message ,returenData
-        }
-        if (returnMap.get("code").equals("-1")) return returnMap;
-        if (null != translateName && !translateName.isEmpty()) {
-            Object returnData = returnMap.get("returnData"); //  code ,message ,returenData
-            if (returnData instanceof Map) {
-                List<Map<String, Object>> inData = new ArrayList<>();
-                inData.add((Map) returnData);
-                returnMap = translateMapName(inData, translateName); // code message retrunData
-            } else if (returnData instanceof List) {
-                returnMap = translateMapName((List) returnData, translateName); // code message retrunData
+        /**
+         * xml转map 定制化
+         *
+         * @param xml                     字符串
+         * @param isTwoDimensionalization 是否需要二维化
+         * @param noDiKaList              是否需要dika
+         * @param translateName           需要转义的名称
+         * @return code message returnData
+         */
+        public static Map<String, Object> customMadexmlToMap (String xml,boolean isTwoDimensionalization, List<String > noDiKaList, Map < String, String > translateName){
+            Map<String, Object> returnMap = xmlToMapFormat(xml); //  code ,message ,returenData
+            if (returnMap.get("code").equals("-1")) return returnMap;
+            if (isTwoDimensionalization) {
+                Map<String, Object> xmlMap = (Map<String, Object>) returnMap.get("returnData");
+                returnMap = twoDimensionalizationFormat(xmlMap, noDiKaList); //  code ,message ,returenData
+                if (returnMap.get("code").equals("-1")) return returnMap;
             }
+            if (null != translateName && !translateName.isEmpty()) {
+                Object returnData = returnMap.get("returnData"); //  code ,message ,returenData
+                if (returnData instanceof Map) {
+                    List<Map<String, Object>> inData = new ArrayList<>();
+                    inData.add((Map) returnData);
+                    returnMap = translateMapName(inData, translateName); // code message retrunData
+                } else if (returnData instanceof List) {
+                    returnMap = translateMapName((List) returnData, translateName); // code message retrunData
+                }
+            }
+            for (Map<String, Object> tempMap : (List<Map<String, Object>>) returnMap.get("returnData")) {
+                tempMap.values().removeAll(Collections.singleton(null));
+                tempMap.values().removeAll(Collections.singleton(""));
+            }
+            return returnMap;
         }
-        for (Map<String, Object> tempMap : (List<Map<String, Object>>) returnMap.get("returnData")) {
-            tempMap.values().removeAll(Collections.singleton(null));
-            tempMap.values().removeAll(Collections.singleton(""));
-        }
-        return returnMap;
-    }
 
-    /**
-     * map key值转换
-     *
-     * @param returnDataList
-     * @param translateName
-     * @return
-     */
-    public static Map<String, Object> translateMapName(List<Map<String, Object>> returnDataList, Map<String, String> translateName) {
-        try {
-            List<Map<String, Object>> dataList = new ArrayList<>();
-            for (Map<String, Object> returnData : returnDataList) {
-                Map<String, Object> temMap = new HashMap<>();
-                for (String key : returnData.keySet()) {
-                    if (translateName.containsKey(key)) {
-                        temMap.put(translateName.get(key), returnData.get(key));
+        /**
+         * map key值转换
+         *
+         * @param returnDataList
+         * @param translateName
+         * @return
+         */
+        public static Map<String, Object> translateMapName (List < Map < String, Object >> returnDataList, Map < String, String > translateName){
+            try {
+                List<Map<String, Object>> dataList = new ArrayList<>();
+                for (Map<String, Object> returnData : returnDataList) {
+                    Map<String, Object> temMap = new HashMap<>();
+                    for (String key : returnData.keySet()) {
+                        if (translateName.containsKey(key)) {
+                            temMap.put(translateName.get(key), returnData.get(key));
+                        }
                     }
+                    dataList.add(temMap);
                 }
-                dataList.add(temMap);
+                return processSuccess(dataList);
+            } catch (Exception e) {
+                return processFail("translateMapName替换异常");
             }
-            return processSuccess(dataList);
-        } catch (Exception e) {
-            return processFail("translateMapName替换异常");
         }
-    }
-
-    /**
-     * xml 转map 通用化
-     *
-     * @param xml
-     * @return
-     */
-    public static Map<String, Object> xmlToMapFormat(String xml) {
-        try {
-            xml = xml.substring(xml.contains("<") ? xml.indexOf("<") : 0, xml.lastIndexOf(">") > 0 ? xml.lastIndexOf(">") + 1 : xml.length());
-            xml = (xml.contains("<?xml") ? "" : "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n").concat(xml);
-            Document doc = DocumentHelper.parseText(xml);
-            Element root = doc.getRootElement();
-            Map<String, Object> returnMap = xmlToMap(root);
 
-            return processSuccess(returnMap);
-        } catch (Exception e) {
-            return processFail("入参不是规则的xml ：" + xml);
+        /**
+         * xml 转map 通用化
+         *
+         * @param xml
+         * @return
+         */
+        public static Map<String, Object> xmlToMapFormat (String xml){
+            try {
+                String xmlStr = xml.substring(xml.contains("<") ? xml.indexOf("<") : 0, xml.lastIndexOf(">") > 0 ? xml.lastIndexOf(">") + 1 : xml.length());
+                xmlStr = (xmlStr.contains("<?xml") ? "" : "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n").concat(xmlStr);
+                Document doc = DocumentHelper.parseText(xmlStr);
+                Element root = doc.getRootElement();
+                Map<String, Object> returnMap = xmlToMap(root);
+                return processSuccess(returnMap);
+            } catch (Exception e) {
+                return processFail("入参不是规则的xml ：" + xml);
+            }
         }
-    }
 
-    /**
-     * map 二维化
-     *
-     * @param inMap      需要二维化map
-     * @param noDiKaList 需要dika
-     * @return
-     */
-    public static Map<String, Object> twoDimensionalizationFormat(Map<String, Object> inMap, List<String> noDiKaList) {
-        try {
-            List<Map<String, Object>> returnDataList = twoDimensionalization(inMap, "", noDiKaList); /*生命周期未添加*/
-            return processSuccess(returnDataList);
-        } catch (Exception e) {
-            return processFail(LogUtils.getException(e));
+        /**
+         * map 二维化
+         *
+         * @param inMap      需要二维化map
+         * @param noDiKaList 需要dika
+         * @return
+         */
+        public static Map<String, Object> twoDimensionalizationFormat (Map < String, Object > inMap, List < String > noDiKaList){
+            try {
+                List<Map<String, Object>> returnDataList = twoDimensionalization(inMap, "", noDiKaList); /*生命周期未添加*/
+                return processSuccess(returnDataList);
+            } catch (Exception e) {
+                return processFail(LogUtils.getException(e));
+            }
         }
-    }
 
-    public Map<String, Object> collectInsertOrUpdate(List<String> ids, String sourceTable, String sourceKey, String targetTable, List<String> uniqueList, boolean isActive, List<String> targetNull, String dbConnect) {
-        if ("".equals(dbConnect) || ids.isEmpty() || uniqueList.isEmpty()) {
-            return processSuccess(null);
+        public Map<String, Object> collectInsertOrUpdate (List < String > ids, String sourceTable, String sourceKey, String targetTable, List < String > uniqueList,
+        boolean isActive, List<String > targetNull, String dbConnect){
+            if ("".equals(dbConnect) || ids.isEmpty() || uniqueList.isEmpty()) {
+                return processSuccess(null);
 
-        }
-        MyDbHelper myDbHelper = ObjectMap.getordropMyDbHelper(dbConnect);
-        /*检测数据库中是否存在对应的表*/
-        Map<String, String> hasTableMap = myDbHelper.queryForObject("select COUNT(1) as count from information_schema.TABLES  where TABLE_NAME = ?", targetTable);
-        if (hasTableMap.get("code").equals("-1")) {
-            return processFail("算法工具类获取目标表结构执行SQL失败： " + hasTableMap.get("message"));
-        }
-        String count = hasTableMap.get("returnData");
-        if ("".equals(count) || "0".equals(count)) {
-            if (isActive) {
-                try {
-                    String tempSql = "CREATE TABLE if not EXISTS " + targetTable + " (" + targetTable + "_id int(11) NOT NULL AUTO_INCREMENT  PRIMARY KEY,`dataObjectId` VARCHAR(32) DEFAULT NULL ,`createtime` timestamp not null default current_timestamp) ";
-                    myDbHelper.execute(tempSql);
-                } catch (Exception e) {
-                    return processFail("collectInsertOrUpdate动态创建表结构失败 " + LogUtils.getException(e));
+            }
+            MyDbHelper myDbHelper = ObjectMap.getordropMyDbHelper(dbConnect);
+            /*检测数据库中是否存在对应的表*/
+            Map<String, String> hasTableMap = myDbHelper.queryForObject("select COUNT(1) as count from information_schema.TABLES  where TABLE_NAME = ?", targetTable);
+            if (hasTableMap.get("code").equals("-1")) {
+                return processFail("算法工具类获取目标表结构执行SQL失败： " + hasTableMap.get("message"));
+            }
+            String count = hasTableMap.get("returnData");
+            if ("".equals(count) || "0".equals(count)) {
+                if (isActive) {
+                    try {
+                        String tempSql = "CREATE TABLE if not EXISTS " + targetTable + " (" + targetTable + "_id int(11) NOT NULL AUTO_INCREMENT  PRIMARY KEY,`dataObjectId` VARCHAR(32) DEFAULT NULL ,`createtime` timestamp not null default current_timestamp) ";
+                        myDbHelper.execute(tempSql);
+                    } catch (Exception e) {
+                        return processFail("collectInsertOrUpdate动态创建表结构失败 " + LogUtils.getException(e));
+                    }
+                } else {
+                    return processFail("目标表不是动态表，数据库中不存在");
                 }
-            } else {
-                return processFail("目标表不是动态表，数据库中不存在");
             }
-        }
 
-        /*检测数据库中是否存在对应表的唯一键*/
-        List<String> allColumn = new ArrayList<>();
-        List<String> tempUnique;
-        List<String> addIndex = new ArrayList<>();
-        tempUnique = MapTools.deepCopy(uniqueList);
-        tempUnique = (tempUnique == null) ? new ArrayList<>() : tempUnique;
-        Map<String, Object> desc_1Map = myDbHelper.queryByParamsReturnList("desc " + targetTable);
-        List<Map<String, Object>> mapList = MapTools.getMapList(desc_1Map);
-        if (!desc_1Map.get("code").equals("0") || null == mapList) {
-            return processFail("目标表不是动态表，数据库中不存在");
-        }
-        for (String unique : uniqueList) {
-            for (Map<String, Object> fieldMap : mapList) {
-                String field = fieldMap.get("Field").toString();
-                Object key = fieldMap.get("key");
-                allColumn.add(field);
-                if (field.equals(unique)) {
-                    tempUnique.remove(unique);
-                    if (Objects.isNull(key)) {
-                        addIndex.add(field);
+            /*检测数据库中是否存在对应表的唯一键*/
+            List<String> allColumn = new ArrayList<>();
+            List<String> tempUnique;
+            List<String> addIndex = new ArrayList<>();
+            tempUnique = MapTools.deepCopy(uniqueList);
+            tempUnique = (tempUnique == null) ? new ArrayList<>() : tempUnique;
+            Map<String, Object> desc_1Map = myDbHelper.queryByParamsReturnList("desc " + targetTable);
+            List<Map<String, Object>> mapList = MapTools.getMapList(desc_1Map);
+            if (!desc_1Map.get("code").equals("0") || null == mapList) {
+                return processFail("目标表不是动态表，数据库中不存在");
+            }
+            for (String unique : uniqueList) {
+                for (Map<String, Object> fieldMap : mapList) {
+                    String field = fieldMap.get("Field").toString();
+                    Object key = fieldMap.get("key");
+                    allColumn.add(field);
+                    if (field.equals(unique)) {
+                        tempUnique.remove(unique);
+                        if (Objects.isNull(key)) {
+                            addIndex.add(field);
+                        }
                     }
                 }
             }
-        }
-        for (String field : tempUnique) {
-            myDbHelper.execute("alter table " + targetTable + " add " + field + " text ");
-        }
-        if (!addIndex.isEmpty()) {
-            myDbHelper.execute("alter table " + targetTable + " add  UNIQUE(" + String.join(",", addIndex) + ")");
-        }
-        tempUnique = MapTools.deepCopy(uniqueList);
-        try {
-            Map<String, Object> sourceDataListResult = myDbHelper.queryByParamsReturnList("select * from " + sourceTable + " where " + sourceKey + " in (" + String.join(",", ids) + ")");
-            List<Map<String, Object>> tempSourceData = MapTools.getMapList(sourceDataListResult);
-            if (!sourceDataListResult.get("code").equals("0") || null == tempSourceData) {
-                return processFail("查询数据数据失败");
-            }
-            for (Map<String, Object> currentData : tempSourceData) {
-                List<String> currentKeysList = new ArrayList<>(currentData.keySet());
-                for (String key : currentKeysList) {
-                    if (!allColumn.contains(key)) {
-                        myDbHelper.execute("alter table " + targetTable + " add " + key + " text ");
-                    }
+            for (String field : tempUnique) {
+                myDbHelper.execute("alter table " + targetTable + " add " + field + " text ");
+            }
+            if (!addIndex.isEmpty()) {
+                myDbHelper.execute("alter table " + targetTable + " add  UNIQUE(" + String.join(",", addIndex) + ")");
+            }
+            tempUnique = MapTools.deepCopy(uniqueList);
+            try {
+                Map<String, Object> sourceDataListResult = myDbHelper.queryByParamsReturnList("select * from " + sourceTable + " where " + sourceKey + " in (" + String.join(",", ids) + ")");
+                List<Map<String, Object>> tempSourceData = MapTools.getMapList(sourceDataListResult);
+                if (!sourceDataListResult.get("code").equals("0") || null == tempSourceData) {
+                    return processFail("查询数据数据失败");
                 }
-                List<String> uniqueKey = new ArrayList<>();
-                List<Object> uniqueValue = new ArrayList<>();
-                List<Object> columnValue = new ArrayList<>();
-                List<String> flag = new ArrayList<>();
-                for (String tpKey : currentData.keySet()) {
-                    Object tpValue = currentData.get(tpKey);
-                    if (Objects.isNull(tpValue) && !targetNull.contains(tpKey)) {
-                        currentKeysList.remove(tpKey);
-                        continue;
-                    }
-                    if (tempUnique.contains(tpKey)) {
-                        uniqueValue.add(tpValue);
-                        uniqueKey.add(tpKey);
-                        currentKeysList.remove(tpKey);
-                        continue;
+                for (Map<String, Object> currentData : tempSourceData) {
+                    List<String> currentKeysList = new ArrayList<>(currentData.keySet());
+                    for (String key : currentKeysList) {
+                        if (!allColumn.contains(key)) {
+                            myDbHelper.execute("alter table " + targetTable + " add " + key + " text ");
+                        }
                     }
+                    List<String> uniqueKey = new ArrayList<>();
+                    List<Object> uniqueValue = new ArrayList<>();
+                    List<Object> columnValue = new ArrayList<>();
+                    List<String> flag = new ArrayList<>();
+                    for (String tpKey : currentData.keySet()) {
+                        Object tpValue = currentData.get(tpKey);
+                        if (Objects.isNull(tpValue) && !targetNull.contains(tpKey)) {
+                            currentKeysList.remove(tpKey);
+                            continue;
+                        }
+                        if (tempUnique.contains(tpKey)) {
+                            uniqueValue.add(tpValue);
+                            uniqueKey.add(tpKey);
+                            currentKeysList.remove(tpKey);
+                            continue;
+                        }
 
-                    if (tpKey.equals("createtime") || tpKey.equals(sourceKey)) {
-                        currentKeysList.remove(tpKey);
-                        continue;
-                    }
-                    flag.add("?");
-                    columnValue.add(tpValue.toString());
-                }
-                String sql = "select count(1) count from " + targetTable + " where " + String.join(" and ", updateList(uniqueKey, "=?"));
-                Map<String, String> hasTargetTableMap = myDbHelper.queryForObject(sql, uniqueValue.toArray());
-                if (hasTargetTableMap.get("code").equals("-1")) {
-                    return processFail("算法工具类获取目标表结构执行SQL失败： " + hasTargetTableMap.get("message"));
-                }
-                String targetCount = hasTargetTableMap.get("returnData");
-                if ("".equals(targetCount) || "0".equals(targetCount)) {
-                    currentKeysList.addAll(uniqueKey);
-                    for (String ignored : uniqueKey) {
+                        if (tpKey.equals("createtime") || tpKey.equals(sourceKey)) {
+                            currentKeysList.remove(tpKey);
+                            continue;
+                        }
                         flag.add("?");
+                        columnValue.add(tpValue.toString());
+                    }
+                    String sql = "select count(1) count from " + targetTable + " where " + String.join(" and ", updateList(uniqueKey, "=?"));
+                    Map<String, String> hasTargetTableMap = myDbHelper.queryForObject(sql, uniqueValue.toArray());
+                    if (hasTargetTableMap.get("code").equals("-1")) {
+                        return processFail("算法工具类获取目标表结构执行SQL失败： " + hasTargetTableMap.get("message"));
+                    }
+                    String targetCount = hasTargetTableMap.get("returnData");
+                    if ("".equals(targetCount) || "0".equals(targetCount)) {
+                        currentKeysList.addAll(uniqueKey);
+                        for (String ignored : uniqueKey) {
+                            flag.add("?");
+                        }
+                        String tempSql = "insert into " + targetTable + "(" + String.join(",", currentKeysList) + ")" + "values  (" + String.join(",", flag) + ")";
+                        columnValue.addAll(uniqueValue);
+                        myDbHelper.updateByCondition(tempSql, null, columnValue.toArray());
+                    } else {
+                        columnValue.addAll(uniqueValue);
+                        myDbHelper.updateByCondition("update " + targetTable + " set " + String.join(",", updateList(currentKeysList, "=?")) + " where " + String.join(" and ", updateList(uniqueKey, "=?")),
+                                null, columnValue.toArray());
                     }
-                    String tempSql = "insert into " + targetTable + "(" + String.join(",", currentKeysList) + ")" + "values  (" + String.join(",", flag) + ")";
-                    columnValue.addAll(uniqueValue);
-                    myDbHelper.updateByCondition(tempSql, null, columnValue.toArray());
-                } else {
-                    columnValue.addAll(uniqueValue);
-                    myDbHelper.updateByCondition("update " + targetTable + " set " + String.join(",", updateList(currentKeysList, "=?")) + " where " + String.join(" and ", updateList(uniqueKey, "=?")),
-                            null, columnValue.toArray());
                 }
+            } catch (Exception e) {
+                return processFail("collectInsertOrUpdate SQL 执行异常 " + LogUtils.getException(e));
             }
-        } catch (Exception e) {
-            return processFail("collectInsertOrUpdate SQL 执行异常 " + LogUtils.getException(e));
+            return processSuccess(null);
         }
-        return processSuccess(null);
-    }
 
-    private static List<Map<String, Object>> twoDimensionalization(Map<String, Object> inMap, String keyName, List<String> noDiKaList) {
-        //初始化一个返回数组List<map<string,object>> returnList
-        List<Map<String, Object>> returnList = new ArrayList<>();
-        // 默认添加一个空MAP----returnList.add(new map)//目的是确保计算迪卡乘积以及最后的单值赋值不出现问题
-        returnList.add(new HashMap<>());
-        //循环入参inMap
-        for (String currentKeyName : inMap.keySet()) {
+        private static List<Map<String, Object>> twoDimensionalization (Map < String, Object > inMap, String keyName, List < String > noDiKaList){
+            //初始化一个返回数组List<map<string,object>> returnList
+            List<Map<String, Object>> returnList = new ArrayList<>();
+            // 默认添加一个空MAP----returnList.add(new map)//目的是确保计算迪卡乘积以及最后的单值赋值不出现问题
+            returnList.add(new HashMap<>());
+            //循环入参inMap
+            for (String currentKeyName : inMap.keySet()) {
 //            组装键名itemKeyName = (keyName为空？'':keyName) + '_' + currentKeyName
-            String itemKeyName = (Objects.equals(keyName, "") ? "" : keyName + '_') + currentKeyName;//组装键名
-            Object currentValue = inMap.get(currentKeyName);
-            if (currentValue instanceof List) {
-                List<Map<String, Object>> tempList = new ArrayList<>();
-                List<Object> list = (List<Object>) currentValue;
-                if (Objects.nonNull(noDiKaList) && noDiKaList.contains(itemKeyName)) {
-                    Map<String, Object> tempMap = new HashMap<>();
-                    tempMap.put(itemKeyName, currentValue.toString());
-                    tempList.add(tempMap);
-                } else {
-                    for (Object o : list) {
-                        if (o instanceof Map) {
-                            List<Map<String, Object>> tempListMap = twoDimensionalization((Map<String, Object>) o, itemKeyName, noDiKaList);
-                            tempListMap = dikaMap(returnList, tempListMap);//计算迪卡乘积
-                            tempList.addAll(tempListMap);
-                        } else {
-                            tempList.add(new HashMap<>() {{
-                                put(itemKeyName, o);
-                            }});
-                        }
-                    }
-                }
-                returnList = tempList;
-            } else {
-                if (currentValue instanceof Map) {
-                    List<Map<String, Object>> tempListMap = twoDimensionalization((Map<String, Object>) currentValue, itemKeyName, noDiKaList);//递归下一级
+                String itemKeyName = (Objects.equals(keyName, "") ? "" : keyName + '_') + currentKeyName;//组装键名
+                Object currentValue = inMap.get(currentKeyName);
+                if (currentValue instanceof List) {
                     List<Map<String, Object>> tempList = new ArrayList<>();
+                    List<Object> list = (List<Object>) currentValue;
                     if (Objects.nonNull(noDiKaList) && noDiKaList.contains(itemKeyName)) {
                         Map<String, Object> tempMap = new HashMap<>();
                         tempMap.put(itemKeyName, currentValue.toString());
                         tempList.add(tempMap);
-                        returnList = tempList;
                     } else {
-                        returnList = dikaMap(returnList, tempListMap);//计算迪卡乘积后替换当前的returnList
+                        for (Object o : list) {
+                            if (o instanceof Map) {
+                                List<Map<String, Object>> tempListMap = twoDimensionalization((Map<String, Object>) o, itemKeyName, noDiKaList);
+                                tempListMap = dikaMap(returnList, tempListMap);//计算迪卡乘积
+                                tempList.addAll(tempListMap);
+                            } else {
+                                tempList.add(new HashMap<>() {{
+                                    put(itemKeyName, o);
+                                }});
+                            }
+                        }
                     }
+                    returnList = tempList;
                 } else {
-                    for (Map<String, Object> map : returnList) {//循环returnList
-                        map.put(itemKeyName, currentValue);////值不为MAP也不是数组则直接添加
+                    if (currentValue instanceof Map) {
+                        List<Map<String, Object>> tempListMap = twoDimensionalization((Map<String, Object>) currentValue, itemKeyName, noDiKaList);//递归下一级
+                        List<Map<String, Object>> tempList = new ArrayList<>();
+                        if (Objects.nonNull(noDiKaList) && noDiKaList.contains(itemKeyName)) {
+                            Map<String, Object> tempMap = new HashMap<>();
+                            tempMap.put(itemKeyName, currentValue.toString());
+                            tempList.add(tempMap);
+                            returnList = tempList;
+                        } else {
+                            returnList = dikaMap(returnList, tempListMap);//计算迪卡乘积后替换当前的returnList
+                        }
+                    } else {
+                        for (Map<String, Object> map : returnList) {//循环returnList
+                            map.put(itemKeyName, currentValue);////值不为MAP也不是数组则直接添加
+                        }
                     }
                 }
             }
+            return returnList;//返回returnList
         }
-        return returnList;//返回returnList
-    }
 
 
-    //MAP二维化辅助方法，返回List<map<string,object>>
-    private static List<Map<String, Object>> dikaMap(List<Map<String, Object>> parentList, List<Map<String, Object>> childList) {
+        //MAP二维化辅助方法，返回List<map<string,object>>
+        private static List<Map<String, Object>> dikaMap (List < Map < String, Object >> parentList, List < Map < String, Object >> childList){
 //        初始化一个返回数组
-        List<Map<String, Object>> returnList = new ArrayList<>();
-        for (Map<String, Object> childwMap : childList) {
-            HashMap<String, Object> childwMapClone = MapTools.clone(childwMap);
-            if (Objects.isNull(childwMapClone)) childwMapClone = new HashMap<>();
-            for (Map<String, Object> parentMap : parentList) {
-                HashMap<String, Object> parentMapClone = MapTools.clone(parentMap);
-                if (Objects.isNull(parentMapClone)) {
-                    parentMapClone = new HashMap<>();
+            List<Map<String, Object>> returnList = new ArrayList<>();
+            for (Map<String, Object> childwMap : childList) {
+                HashMap<String, Object> childwMapClone = MapTools.clone(childwMap);
+                if (Objects.isNull(childwMapClone)) childwMapClone = new HashMap<>();
+                for (Map<String, Object> parentMap : parentList) {
+                    HashMap<String, Object> parentMapClone = MapTools.clone(parentMap);
+                    if (Objects.isNull(parentMapClone)) {
+                        parentMapClone = new HashMap<>();
+                    }
+                    parentMapClone.putAll(childwMapClone);
+                    returnList.add(parentMapClone);//注意使用HashMap.putall实现深拷贝
                 }
-                parentMapClone.putAll(childwMapClone);
-                returnList.add(parentMapClone);//注意使用HashMap.putall实现深拷贝
             }
+            return returnList;
         }
-        return returnList;
-    }
 
-    private static Map<String, Object> xmlToMap(Element element) {
-        String currentName = element.getName(); //当前节点名称
-        String currentValue = MapTools.getText(element.getTextTrim());// 当前节点值
+        private static Map<String, Object> xmlToMap (Element element){
+            String currentName = element.getName(); //当前节点名称
+            String currentValue = MapTools.getText(element.getTextTrim());// 当前节点值
 
-        Map<String, Object> returnMap = new HashMap<>();//初始化一个返回的结构
-        Map<String, Object> attrMap = new HashMap<>(); //初始化一个当前节点的属性结构
-        List<Attribute> attributes = element.attributes();  //属性处理
-        for (Attribute childAttribute : attributes) { //循环当前节点所有属性
-            attrMap.put(childAttribute.getName(), childAttribute.getValue());//逐个添加属性值到属性结构
-        }
-        List<Element> childNodes = element.elements(); //获取当前节点的所有子节点
-        if (childNodes.isEmpty() && !attrMap.isEmpty()) { // //无子节点且当前节点存在属性则
-            attrMap.put(currentName, currentValue); //当前节点值添加到属性中
-        }
-        for (Element childElement : childNodes) { //循环所有子节点，如果没有子节点不会进入循环
-            String childName = childElement.getName(); //获取子节点名称
-            if (attrMap.containsKey(childName)) { //已经存在相同子节点名称的值代表需要形成数组
-                Object oldValue = attrMap.get(childName); //获取已经存在的值
-                List<Object> newList = new ArrayList<>();
-                if (oldValue instanceof List) { //如果旧值已经是数组则
-                    newList = (List<Object>) oldValue; //强制转换为数组
+            Map<String, Object> returnMap = new HashMap<>();//初始化一个返回的结构
+            Map<String, Object> attrMap = new HashMap<>(); //初始化一个当前节点的属性结构
+            List<Attribute> attributes = element.attributes();  //属性处理
+            for (Attribute childAttribute : attributes) { //循环当前节点所有属性
+                attrMap.put(childAttribute.getName(), childAttribute.getValue());//逐个添加属性值到属性结构
+            }
+            List<Element> childNodes = element.elements(); //获取当前节点的所有子节点
+            if (childNodes.isEmpty() && !attrMap.isEmpty()) { // //无子节点且当前节点存在属性则
+                attrMap.put(currentName, currentValue); //当前节点值添加到属性中
+            }
+            for (Element childElement : childNodes) { //循环所有子节点，如果没有子节点不会进入循环
+                String childName = childElement.getName(); //获取子节点名称
+                if (attrMap.containsKey(childName)) { //已经存在相同子节点名称的值代表需要形成数组
+                    Object oldValue = attrMap.get(childName); //获取已经存在的值
+                    List<Object> newList = new ArrayList<>();
+                    if (oldValue instanceof List) { //如果旧值已经是数组则
+                        newList = (List<Object>) oldValue; //强制转换为数组
+                    } else {
+                        newList.add(oldValue); //转换为数组，旧值添加到数组中
+                    }
+                    newList.add(xmlToMap(childElement).get(childName));//添加子节点的数据，递归获取子节点的数据
+                    attrMap.put(childName, newList);//添加到返回结构中;
                 } else {
-                    newList.add(oldValue); //转换为数组，旧值添加到数组中
+                    attrMap.put(childName, xmlToMap(childElement).get(childName));//递归获取子节点的数据;
                 }
-                newList.add(xmlToMap(childElement).get(childName));//添加子节点的数据，递归获取子节点的数据
-                attrMap.put(childName, newList);//添加到返回结构中;
-            } else {
-                attrMap.put(childName, xmlToMap(childElement).get(childName));//递归获取子节点的数据;
             }
+            returnMap.put(currentName, attrMap.isEmpty() ? currentValue : attrMap);//添加当前节点的属性以及值（包括了子节点）
+            return returnMap;
         }
-        returnMap.put(currentName, attrMap.isEmpty() ? currentValue : attrMap);//添加当前节点的属性以及值（包括了子节点）
-        return returnMap;
-    }
 
-    private static String TypeBDateChange(String inDate, String inTime) {
-        //如果日期不为空
-        if (MapTools.isNotBlank(inDate)) {
-            String dayStr = inDate.trim().substring(0, 2);
-            String monthStr = EMonth.get(inDate.trim().substring(2, 5));
-            Calendar currentDate = Calendar.getInstance();
-            int yearStr = currentDate.get(Calendar.YEAR);
-            //处理跨年问题
-            int systemDay = currentDate.get(Calendar.DATE);
-            if (currentDate.get(Calendar.MONTH) + 1 == 12 && systemDay > 20 && Integer.parseInt(monthStr) == 1 && Integer.parseInt(dayStr) < 10) {
-                yearStr = yearStr + 1;
-            }
-            if (currentDate.get(Calendar.MONTH) + 1 == 1 && systemDay < 10 && Integer.parseInt(monthStr) == 12 && Integer.parseInt(dayStr) > 20) {
-                yearStr = yearStr - 1;
-            }
-            return yearStr + "-" + monthStr + "-" + dayStr;
-        }
-        if (MapTools.isNotBlank(inTime)) {
-            String dateType = inTime.substring(inTime.length() - 1);
-            dateType = MapTools.isNumber(dateType) ? "L" : dateType;
-            String h = inTime.length() > 1 ? inTime.substring(0, 2) : "00";
-            String m = inTime.length() > 3 ? inTime.substring(2, 4) : "00";
-            String s = inTime.length() > 5 ? inTime.substring(4, 6) : "00";
-            // 组合时间
-            return h + ":" + m + ":" + s + " " + dateType;
+        private static String TypeBDateChange (String inDate, String inTime){
+            //如果日期不为空
+            if (MapTools.isNotBlank(inDate)) {
+                String dayStr = inDate.trim().substring(0, 2);
+                String monthStr = EMonth.get(inDate.trim().substring(2, 5));
+                Calendar currentDate = Calendar.getInstance();
+                int yearStr = currentDate.get(Calendar.YEAR);
+                //处理跨年问题
+                int systemDay = currentDate.get(Calendar.DATE);
+                if (currentDate.get(Calendar.MONTH) + 1 == 12 && systemDay > 20 && Integer.parseInt(monthStr) == 1 && Integer.parseInt(dayStr) < 10) {
+                    yearStr = yearStr + 1;
+                }
+                if (currentDate.get(Calendar.MONTH) + 1 == 1 && systemDay < 10 && Integer.parseInt(monthStr) == 12 && Integer.parseInt(dayStr) > 20) {
+                    yearStr = yearStr - 1;
+                }
+                return yearStr + "-" + monthStr + "-" + dayStr;
+            }
+            if (MapTools.isNotBlank(inTime)) {
+                String dateType = inTime.substring(inTime.length() - 1);
+                dateType = MapTools.isNumber(dateType) ? "L" : dateType;
+                String h = inTime.length() > 1 ? inTime.substring(0, 2) : "00";
+                String m = inTime.length() > 3 ? inTime.substring(2, 4) : "00";
+                String s = inTime.length() > 5 ? inTime.substring(4, 6) : "00";
+                // 组合时间
+                return h + ":" + m + ":" + s + " " + dateType;
+            }
+            return null;
         }
-        return null;
-    }
 
-    /**
-     * 修改list内容
-     *
-     * @param list 源list
-     * @param spc  针对每条数据添加的字符
-     * @return 新list
-     */
-    private List<String> updateList(List<String> list, String spc) {
-        return list.stream().map(x -> x + spc).collect(Collectors.toList());
-    }
-}
+        /**
+         * 修改list内容
+         *
+         * @param list 源list
+         * @param spc  针对每条数据添加的字符
+         * @return 新list
+         */
+        private List<String> updateList (List < String > list, String spc){
+            return list.stream().map(x -> x + spc).collect(Collectors.toList());
+        }
+    }

mainFactory/src/main/java/org/bfkj/utils/LogUtils.java

@@ -14,6 +14,8 @@ public class LogUtils { // 依据服务编号ID获取服务类型，如果是异
         ThreadPoolTaskExecutor threadPoolTaskExecutor = SpringContextBeans.getBean("ThreadPoolTaskExecutor");
         threadPoolTaskExecutor.submit(() -> logWrite(location, success, calculationLocation, logContent, serviceId, workId, iNDataContent, dataObjectId, OutDataContent, event));
     }
+
+    private static  Long deleteTime = 0L;
     /*
     算法输入数据
     算法返回结果
@@ -52,6 +54,10 @@ public class LogUtils { // 依据服务编号ID获取服务类型，如果是异
         if (Objects.nonNull(myDbHelper.getErrorMessage())) {
             System.out.println("记录日志： 获取" + dbText + "MyDbHelper对象失败,日志信息 ：" + myDbHelper.getErrorMessage());
         }
+        if (MapTools.isNotBlank(serviceId) && (System.currentTimeMillis()-deleteTime) > 10000){
+            myDbHelper.updateByCondition("DELETE FROM log_success  WHERE id  < (SELECT MIN(T.ID)  FROM  (SELECT ID FROM log_success  WHERE serviceId =? ORDER BY createtime DESC    LIMIT 100 ) as T  )",null,serviceId);
+            deleteTime = System.currentTimeMillis();
+        }
         Map<String, Object> shortMap = myDbHelper.generalProcess("1", tableName, null, null, logParam, false, null, null);
         if (!shortMap.get("code").equals("0")) {
             System.out.println("记录日志： 写入" + dbText + "日志失败 ：" + shortMap.get("message") + "\n数据：" + MapTools.objectToString(logParam));

mainFactory/src/main/java/org/bfkj/utils/MyDbHelper.java

@@ -164,10 +164,10 @@ public class MyDbHelper {
     public Map<String, Object> updateByCondition(String sql, List<Object[]> batchPm, Object... params) {
         try {
             Object tempObject;
-            if (Objects.nonNull(batchPm) && batchPm.get(0) != null) {
-                tempObject = theJdbcTemplate.batchUpdate(sql, batchPm);
-            } else {
+            if (Objects.isNull(batchPm) || Objects.isNull(batchPm.get(0)) || Objects.isNull(batchPm.get(0)[0])) {
                 tempObject = theJdbcTemplate.update(sql, params);
+            } else {
+                tempObject = theJdbcTemplate.batchUpdate(sql, batchPm);
             }
             return processSuccess(MapTools.jacksonObjToStr(tempObject), sql, (Objects.nonNull(batchPm) && batchPm.get(0) != null) ? MapTools.jacksonObjToStr(batchPm) : MapTools.jacksonObjToStr(params));
         } catch (Exception e) {
@@ -352,13 +352,13 @@ public class MyDbHelper {
                 return processFail("查询出现异常：" + LogUtils.getException(e), sql, parameterList);
             }
         }
-        if ("1".equals(event)) {//如果是新增则使用JDBC方式进行，方便获取新增后的主键
+        if ("1".equals(event) && sql.contains("?")) {//如果是新增则使用JDBC方式进行，方便获取新增后的主键
             return JDBCBatch(sql, parameterList, paramsList);
         }
         return updateByCondition(sql, parameterList);
     }
 
-    public Map<String, Object> JDBCBatch(String sql, List<Object[]> paramList, List<Map<String, Object>> paramsList) {
+    public  Map<String, Object> JDBCBatch(String sql, List<Object[]> paramList, List<Map<String, Object>> paramsList) {
         if (!sql.contains("?")) {  // Object[]
             return processSuccess(null, sql, paramsList);
         }