pms 设备调拨同步接口

yudao-module-pms/yudao-module-pms-biz/src/main/java/cn/iocoder/yudao/module/pms/service/iotdeviceallotlog/IotDeviceAllotLogServiceImpl.java

@@ -11,7 +11,11 @@ import cn.iocoder.yudao.module.pms.dal.dataobject.IotDeviceDO;
 import cn.iocoder.yudao.module.pms.dal.dataobject.iotdeviceallotlog.IotDeviceAllotLogDO;
 import cn.iocoder.yudao.module.pms.dal.mysql.IotDeviceMapper;
 import cn.iocoder.yudao.module.pms.dal.mysql.iotdeviceallotlog.IotDeviceAllotLogMapper;
+import cn.iocoder.yudao.module.pms.service.failure.IotFailureReportService;
+import cn.iocoder.yudao.module.pms.service.inspect.IotInspectOrderService;
 import cn.iocoder.yudao.module.pms.service.iotdeviceperson.IotDevicePersonService;
+import cn.iocoder.yudao.module.pms.service.iotopeationfill.IotOpeationFillService;
+import cn.iocoder.yudao.module.pms.service.maintain.IotMaintainService;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.validation.annotation.Validated;
@@ -20,6 +24,7 @@ import javax.annotation.Resource;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.atomic.AtomicReference;
 import java.util.stream.Collectors;
 
 import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
@@ -40,6 +45,14 @@ public class IotDeviceAllotLogServiceImpl implements IotDeviceAllotLogService {
     private IotDeviceMapper iotDeviceMapper;
     @Resource
     private IotDevicePersonService iotDevicePersonService;
+    @Resource
+    private IotOpeationFillService iotOpeationFillService;
+    @Resource
+    private IotFailureReportService iotFailureReportService;
+    @Resource
+    private IotMaintainService iotMaintainService;
+    @Resource
+    private IotInspectOrderService iotInspectOrderService;
 
     @Override
     public Long createIotDeviceAllotLog(IotDeviceAllotLogSaveReqVO createReqVO) {
@@ -101,7 +114,9 @@ public class IotDeviceAllotLogServiceImpl implements IotDeviceAllotLogService {
         List<IotDeviceAllotLogDO> deviceAllotLogs = new ArrayList<>();
         List<IotDeviceDO> tobeUpdatedDevices = new ArrayList<>();
         List<IotDevicePersonRelationSaveReqVO> personRelations = new ArrayList<>();
+        AtomicReference<Long> deptId = new AtomicReference<>(0L);
         reqVOS.forEach(req -> {
+            deptId.set(req.getDeptId());
             if (deviceMap.containsKey(req.getDeviceId()) && !req.getDeptId().equals(deviceMap.get(req.getDeviceId()).getDeptId())) {
                 IotDeviceAllotLogDO tempDeviceAllot = new IotDeviceAllotLogDO();
                 tempDeviceAllot.setDeviceId(req.getDeviceId());
@@ -133,8 +148,16 @@ public class IotDeviceAllotLogServiceImpl implements IotDeviceAllotLogService {
         if (CollUtil.isNotEmpty(personRelations)) {
             iotDevicePersonService.saveDevicePersons(personRelations);
         }
-        // 同步修改 设备相关的 历史工单
 
+        // 同步修改 设备相关的 历史工单
+        // 同步修改运行记录的历史工单
+        iotOpeationFillService.syncWordOrderData(deviceIds, null, deptId.get());
+        // 同步修改维修历史工单
+        iotFailureReportService.syncWordOrderData(deviceIds, deptId.get());
+        // 同步修改巡检历史工单
+        iotMaintainService.syncWordOrderData(deviceIds, deptId.get());
+        iotInspectOrderService.syncWordOrderData(deviceIds, deptId.get());
+        // 同步修改保养历史工单
         return 1l;
     }