优化代码

service-job/src/main/java/com/java110/job/adapt/hcIot/tempCarFee/AddTempCarFeeConfigToIotAdapt.java

@@ -73,11 +73,11 @@ public class AddTempCarFeeConfigToIotAdapt extends DatabusAdaptImpl {
 
     public void execute(Business business, List<Business> businesses) {
         JSONObject data = business.getData();
+        JSONArray  businessTempCarFeeConfigs = new JSONArray();
         if (data.containsKey(TempCarFeeConfigPo.class.getSimpleName())) {
             Object bObj = data.get(TempCarFeeConfigPo.class.getSimpleName());
-            JSONArray businessTempCarFeeConfigs = null;
+
             if (bObj instanceof JSONObject) {
-                businessTempCarFeeConfigs = new JSONArray();
                 businessTempCarFeeConfigs.add(bObj);
             } else if (bObj instanceof List) {
                 businessTempCarFeeConfigs = JSONArray.parseArray(JSONObject.toJSONString(bObj));
@@ -85,11 +85,17 @@ public class AddTempCarFeeConfigToIotAdapt extends DatabusAdaptImpl {
                 businessTempCarFeeConfigs = (JSONArray) bObj;
             }
             //JSONObject businessTempCarFeeConfig = data.getJSONObject("businessTempCarFeeConfig");
-            for (int bTempCarFeeConfigIndex = 0; bTempCarFeeConfigIndex < businessTempCarFeeConfigs.size(); bTempCarFeeConfigIndex++) {
-                JSONObject businessTempCarFeeConfig = businessTempCarFeeConfigs.getJSONObject(bTempCarFeeConfigIndex);
-                doSendTempCarFeeConfig(business, businessTempCarFeeConfig);
+
+        }else {
+            if (data instanceof JSONObject) {
+                businessTempCarFeeConfigs.add(data);
             }
         }
+
+        for (int bTempCarFeeConfigIndex = 0; bTempCarFeeConfigIndex < businessTempCarFeeConfigs.size(); bTempCarFeeConfigIndex++) {
+            JSONObject businessTempCarFeeConfig = businessTempCarFeeConfigs.getJSONObject(bTempCarFeeConfigIndex);
+            doSendTempCarFeeConfig(business, businessTempCarFeeConfig);
+        }
     }
 
     private void doSendTempCarFeeConfig(Business business, JSONObject businessTempCarFeeConfig) {

service-job/src/main/java/com/java110/job/adapt/hcIot/tempCarFee/DeleteTempCarFeeConfigToIotAdapt.java

@@ -64,23 +64,28 @@ public class DeleteTempCarFeeConfigToIotAdapt extends DatabusAdaptImpl {
     @Override
     public void execute(Business business, List<Business> businesses) {
         JSONObject data = business.getData();
+        JSONArray  businessTempCarFeeConfigs = new JSONArray();
         if (data.containsKey(TempCarFeeConfigPo.class.getSimpleName())) {
             Object bObj = data.get(TempCarFeeConfigPo.class.getSimpleName());
-            JSONArray businessTempCarFeeConfigs = null;
+
             if (bObj instanceof JSONObject) {
-                businessTempCarFeeConfigs = new JSONArray();
+
                 businessTempCarFeeConfigs.add(bObj);
             } else if (bObj instanceof List) {
                 businessTempCarFeeConfigs = JSONArray.parseArray(JSONObject.toJSONString(bObj));
             } else {
                 businessTempCarFeeConfigs = (JSONArray) bObj;
             }
-            //JSONObject businessTempCarFeeConfig = data.getJSONObject("businessTempCarFeeConfig");
-            for (int bTempCarFeeConfigIndex = 0; bTempCarFeeConfigIndex < businessTempCarFeeConfigs.size(); bTempCarFeeConfigIndex++) {
-                JSONObject businessTempCarFeeConfig = businessTempCarFeeConfigs.getJSONObject(bTempCarFeeConfigIndex);
-                doSendTempCarFeeConfig(business, businessTempCarFeeConfig);
+        }else {
+            if (data instanceof JSONObject) {
+                businessTempCarFeeConfigs.add(data);
             }
         }
+        //JSONObject businessTempCarFeeConfig = data.getJSONObject("businessTempCarFeeConfig");
+        for (int bTempCarFeeConfigIndex = 0; bTempCarFeeConfigIndex < businessTempCarFeeConfigs.size(); bTempCarFeeConfigIndex++) {
+            JSONObject businessTempCarFeeConfig = businessTempCarFeeConfigs.getJSONObject(bTempCarFeeConfigIndex);
+            doSendTempCarFeeConfig(business, businessTempCarFeeConfig);
+        }
     }
 
     private void doSendTempCarFeeConfig(Business business, JSONObject businessTempCarFeeConfig) {

service-job/src/main/java/com/java110/job/adapt/hcIot/tempCarFee/ModifyTempCarFeeConfigToIotAdapt.java

@@ -78,11 +78,10 @@ public class ModifyTempCarFeeConfigToIotAdapt extends DatabusAdaptImpl {
 
     public void execute(Business business, List<Business> businesses) {
         JSONObject data = business.getData();
+        JSONArray  businessTempCarFeeConfigs = new JSONArray();
         if (data.containsKey(TempCarFeeConfigPo.class.getSimpleName())) {
             Object bObj = data.get(TempCarFeeConfigPo.class.getSimpleName());
-            JSONArray businessTempCarFeeConfigs = null;
             if (bObj instanceof JSONObject) {
-                businessTempCarFeeConfigs = new JSONArray();
                 businessTempCarFeeConfigs.add(bObj);
             } else if (bObj instanceof List) {
                 businessTempCarFeeConfigs = JSONArray.parseArray(JSONObject.toJSONString(bObj));
@@ -90,11 +89,16 @@ public class ModifyTempCarFeeConfigToIotAdapt extends DatabusAdaptImpl {
                 businessTempCarFeeConfigs = (JSONArray) bObj;
             }
             //JSONObject businessTempCarFeeConfig = data.getJSONObject("businessTempCarFeeConfig");
-            for (int bTempCarFeeConfigIndex = 0; bTempCarFeeConfigIndex < businessTempCarFeeConfigs.size(); bTempCarFeeConfigIndex++) {
-                JSONObject businessTempCarFeeConfig = businessTempCarFeeConfigs.getJSONObject(bTempCarFeeConfigIndex);
-                doSendTempCarFeeConfig(business, businessTempCarFeeConfig);
+
+        }else {
+            if (data instanceof JSONObject) {
+                businessTempCarFeeConfigs.add(data);
             }
         }
+        for (int bTempCarFeeConfigIndex = 0; bTempCarFeeConfigIndex < businessTempCarFeeConfigs.size(); bTempCarFeeConfigIndex++) {
+            JSONObject businessTempCarFeeConfig = businessTempCarFeeConfigs.getJSONObject(bTempCarFeeConfigIndex);
+            doSendTempCarFeeConfig(business, businessTempCarFeeConfig);
+        }
     }
 
     private void doSendTempCarFeeConfig(Business business, JSONObject businessTempCarFeeConfig) {