修改事件确认中设备操作执行代码

zc-business/src/main/java/com/zc/business/service/impl/DcEmergencyPlansServiceImpl.java

@@ -21,6 +21,8 @@ import com.zc.business.service.DcEmergencyPlansService;
 import com.zc.business.service.DcExecuteActionService;
 import com.zc.business.service.IDcDeviceService;
 import com.zc.common.core.httpclient.exception.HttpException;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -31,6 +33,7 @@ import java.util.*;
 import java.util.stream.Collectors;
 
 @Service
+@Slf4j
 public class DcEmergencyPlansServiceImpl implements DcEmergencyPlansService {
 
     @Resource
@@ -46,6 +49,9 @@ public class DcEmergencyPlansServiceImpl implements DcEmergencyPlansService {
     @Resource
     private EventPlanAssocMapper eventPlanAssocMapper;
 
+    @Resource
+    private ThreadPoolTaskExecutor threadPoolTaskExecutor;
+
 
     /**
      * 查询事件预案
@@ -207,6 +213,7 @@ public class DcEmergencyPlansServiceImpl implements DcEmergencyPlansService {
     public Map<String, List<DcInfoBoardTemplate>> getBoardTemplate(List<DcDevice> dcDevices) {
         Map<String, List<DcInfoBoardTemplate>> map = new HashMap<>();
         dcDevices.forEach(dcDevice -> {
+            threadPoolTaskExecutor.execute(() -> {
                 try {
                     if (StringUtils.isEmpty(dcDevice.getIotDeviceId())) {
                         return;
@@ -247,12 +254,14 @@ public class DcEmergencyPlansServiceImpl implements DcEmergencyPlansService {
                     e.printStackTrace();
                 }
             });
+        });
 
         return map;
     }
 
     /**
      * 执行操作中的规则筛选
+     *
      * @param dcExecuteAction
      * @param markArray
      * @param direction
@@ -276,8 +285,7 @@ public class DcEmergencyPlansServiceImpl implements DcEmergencyPlansService {
             List<String> deviceList = (List<String>) otherConfig.get("deviceList");
             queryWrapper.in(DcDevice::getIotDeviceId, deviceList);
             dcDevices = dcDeviceService.list(queryWrapper);
-        }
+        } else if (searchRule.equals(2)) {
-        else if (searchRule.equals(2)) {
 
             // 事件上游最近
             if (direction.equals("1")) {
@@ -318,8 +326,7 @@ public class DcEmergencyPlansServiceImpl implements DcEmergencyPlansService {
                 }
             }
 
-        }
+        } else if (searchRule.equals(3)) {
-        else if (searchRule.equals(3)) {
             // 事件下游最近
             if (direction.equals("1")) {
                 // 上行 取最大的几个
@@ -360,8 +367,7 @@ public class DcEmergencyPlansServiceImpl implements DcEmergencyPlansService {
                     dcDevices = dcDevices.subList(0, dcExecuteAction.getNumber());
                 }
             }
-        }
+        } else {
-        else {
             // 最近公里数
             Integer kilometers = Integer.parseInt(markArray[0].replaceAll("K", ""));
             // 根据事件桩号、公里数 计算出 桩号范围
@@ -400,6 +406,7 @@ public class DcEmergencyPlansServiceImpl implements DcEmergencyPlansService {
 
     /**
      * 感知事件-情报板自动生成
+     *
      * @param dcEventAnDcEmergencyPlans
      * @return
      */
@@ -429,6 +436,7 @@ public class DcEmergencyPlansServiceImpl implements DcEmergencyPlansService {
 
     /**
      * 交通事件-情报板自动生成
+     *
      * @return
      */
     @Override
@@ -484,6 +492,7 @@ public class DcEmergencyPlansServiceImpl implements DcEmergencyPlansService {
 
     /**
      * 感知事件确认
+     *
      * @param dcEventAnDcEmergencyPlans 事件数据 和 事件预案数据
      * @return
      */
@@ -501,6 +510,7 @@ public class DcEmergencyPlansServiceImpl implements DcEmergencyPlansService {
 
     /**
      * 事件确认
+     *
      * @param dcEventAnDcEmergencyPlans 事件数据 和 事件预案数据
      * @return
      */
@@ -575,18 +585,20 @@ public class DcEmergencyPlansServiceImpl implements DcEmergencyPlansService {
     /**
      * 根据不通设备类型，执行不通的功能操作
      */
-    public void invokedFunction(
+    public void invokedFunction(Integer operationType,
-                                Integer operationType,
                                 List<DcDevice> dcDevices,
                                 JSONObject otherConfig,
-                                JSONArray resultArray) throws HttpException, IOException {
+                                JSONArray resultArray) {
-        String iotDeviceId = "";
+
-        String functionId = "";
 
         for (DcDevice device : dcDevices) {
+
+            threadPoolTaskExecutor.execute(() -> {
+                String iotDeviceId = "";
+                String functionId = "";
                 iotDeviceId = device.getIotDeviceId();
                 HashMap<String, Object> props = new HashMap<>();
-
+                try {
                     if (device.getDeviceType().equals(DeviceTypeConstants.DRIVING_GUIDANCE)) {
                         // 行车诱导
                         functionId = DeviceFunctionIdConstants.DRIVING_GUIDANCE;
@@ -613,16 +625,19 @@ public class DcEmergencyPlansServiceImpl implements DcEmergencyPlansService {
                         result.put("result", ajaxResult);
                         resultArray.add(result);
 
+
                     }
                     else if (device.getDeviceType().equals(DeviceTypeConstants.VARIABLE_INFORMATION_FLAG)) {
                         if (operationType == 1) {
+
                             // 执行操作
                             // 可变信息标志  分三步
                             // 1:执行11功能码
                             functionId = DeviceFunctionIdConstants.VARIABLE_INFORMATION_FLAG_11;
                             props.put("fileName", "play011.lst");
                             props.put("size", "65535");
-                    AjaxResult ajaxResult11 = dcDeviceController.invokedFunction(iotDeviceId, functionId, props);
+                            AjaxResult ajaxResult11;
+                            ajaxResult11 = dcDeviceController.invokedFunction(iotDeviceId, functionId, props);
                             if (ajaxResult11.get("code").equals(200)) {
                                 // 2:执行13功能码
                                 HashMap<String, Object> props11 = new HashMap<>();
@@ -653,7 +668,8 @@ public class DcEmergencyPlansServiceImpl implements DcEmergencyPlansService {
                                 parameters.put("formatStyle", dcInfoBoardTemplate.getFormatStyle());
                                 list.add(parameters);
                                 props11.put("parameters", list);
-                        AjaxResult ajaxResult13 = dcDeviceController.invokedFunction(iotDeviceId, functionId, props11);
+                                AjaxResult ajaxResult13 = null;
+                                ajaxResult13 = dcDeviceController.invokedFunction(iotDeviceId, functionId, props11);
                                 JSONObject result = new JSONObject();
                                 if (ajaxResult13.get("code").equals(200)) {
                                     HashMap<String, Object> props1B = new HashMap<>();
@@ -661,22 +677,25 @@ public class DcEmergencyPlansServiceImpl implements DcEmergencyPlansService {
                                     functionId = DeviceFunctionIdConstants.VARIABLE_INFORMATION_FLAG_1B;
                                     props1B.put("fileId", "11");
                                     AjaxResult ajaxResult1B = dcDeviceController.invokedFunction(iotDeviceId, functionId, props1B);
-
                                     result.put("device", device.getId());
                                     result.put("result", ajaxResult1B);
                                     resultArray.add(result);
+
                                 } else {
                                     result.put("device", device.getId());
                                     result.put("result", ajaxResult13);
                                     resultArray.add(result);
                                 }
                             }
-                }
+
-                else {
+                        } else {
                             // 恢复操作
                             props.put("fileId", "10");
                             functionId = DeviceFunctionIdConstants.VARIABLE_INFORMATION_FLAG_1B;
-                    AjaxResult ajaxResult1B = dcDeviceController.invokedFunction(iotDeviceId, functionId, props);
+                            AjaxResult ajaxResult1B;
+
+                            ajaxResult1B = dcDeviceController.invokedFunction(iotDeviceId, functionId, props);
+
                             JSONObject result = new JSONObject();
                             result.put("device", device.getId());
                             result.put("result", ajaxResult1B);
@@ -696,38 +715,45 @@ public class DcEmergencyPlansServiceImpl implements DcEmergencyPlansService {
                         JSONArray termList = new JSONArray();
                         termList.add(JSON.parseObject(device.getOtherConfig()));
                         params.put("termList", termList);
+
                         JSONObject returnResult = broadcastController.nearCamListDistance(params);
                         JSONObject result = new JSONObject();
                         result.put("device", device.getId());
                         result.put("result", returnResult);
                         resultArray.add(result);
+
+
                     }
                     else if (device.getDeviceType().equals(DeviceTypeConstants.LASER_FATIGUE_AWAKENING)) {
                         // 激光疲劳唤醒
                         functionId = otherConfig.get("state").toString();
 
                         AjaxResult ajaxResultState = dcDeviceController.invokedFunction(iotDeviceId, functionId, new HashMap<>());
-                // 将调用结果存入到 resultArray（操作结果） 中
                         JSONObject result = new JSONObject();
                         result.put("device", device.getId());
                         result.put("result", ajaxResultState);
                         resultArray.add(result);
+
                         // 操作时长
                         String operationDuration = "SETTM" + otherConfig.get("operationDuration").toString();
                         HashMap<String, Object> propsTime = new HashMap<>();
                         propsTime.put("SET", operationDuration);
                         functionId = DeviceFunctionIdConstants.VARIABLE_INFORMATION_FLAG_SETTM;
+
                         AjaxResult ajaxResult = dcDeviceController.invokedFunction(iotDeviceId, functionId, propsTime);
                         JSONObject resultTime = new JSONObject();
                         resultTime.put("device", device.getId());
                         resultTime.put("result", ajaxResult);
                         resultArray.add(resultTime);
-            } else {
-                break;
-            }
-
 
                     }
+                } catch (HttpException | IOException e) {
+                    log.error(e.toString());
+                    throw new RuntimeException(e);
+                }
+            });
+        }
+
     }