|
@@ -15,14 +15,12 @@ import cn.iocoder.yudao.module.pms.controller.admin.inspect.order.vo.IotInspectO
|
|
|
import cn.iocoder.yudao.module.pms.controller.admin.inspect.route.vo.IotInspectRouteRespVO;
|
|
import cn.iocoder.yudao.module.pms.controller.admin.inspect.route.vo.IotInspectRouteRespVO;
|
|
|
import cn.iocoder.yudao.module.pms.controller.admin.iotdeviceperson.vo.IotDevicePersonPageReqVO;
|
|
import cn.iocoder.yudao.module.pms.controller.admin.iotdeviceperson.vo.IotDevicePersonPageReqVO;
|
|
|
import cn.iocoder.yudao.module.pms.controller.admin.vo.IotDevicePageReqVO;
|
|
import cn.iocoder.yudao.module.pms.controller.admin.vo.IotDevicePageReqVO;
|
|
|
|
|
+import cn.iocoder.yudao.module.pms.controller.admin.vo.IotDeviceSimple;
|
|
|
import cn.iocoder.yudao.module.pms.dal.dataobject.IotDeviceDO;
|
|
import cn.iocoder.yudao.module.pms.dal.dataobject.IotDeviceDO;
|
|
|
import cn.iocoder.yudao.module.pms.dal.dataobject.inspect.*;
|
|
import cn.iocoder.yudao.module.pms.dal.dataobject.inspect.*;
|
|
|
import cn.iocoder.yudao.module.pms.dal.dataobject.iotdeviceperson.IotDevicePersonDO;
|
|
import cn.iocoder.yudao.module.pms.dal.dataobject.iotdeviceperson.IotDevicePersonDO;
|
|
|
import cn.iocoder.yudao.module.pms.dal.mysql.IotDeviceMapper;
|
|
import cn.iocoder.yudao.module.pms.dal.mysql.IotDeviceMapper;
|
|
|
-import cn.iocoder.yudao.module.pms.dal.mysql.inspect.IotInspectItemMapper;
|
|
|
|
|
-import cn.iocoder.yudao.module.pms.dal.mysql.inspect.IotInspectOrderDetailMapper;
|
|
|
|
|
-import cn.iocoder.yudao.module.pms.dal.mysql.inspect.IotInspectOrderMapper;
|
|
|
|
|
-import cn.iocoder.yudao.module.pms.dal.mysql.inspect.IotInspectPlanMapper;
|
|
|
|
|
|
|
+import cn.iocoder.yudao.module.pms.dal.mysql.inspect.*;
|
|
|
import cn.iocoder.yudao.module.pms.message.PmsMessage;
|
|
import cn.iocoder.yudao.module.pms.message.PmsMessage;
|
|
|
import cn.iocoder.yudao.module.pms.service.IotDeviceService;
|
|
import cn.iocoder.yudao.module.pms.service.IotDeviceService;
|
|
|
import cn.iocoder.yudao.module.pms.service.iotdeviceperson.IotDevicePersonService;
|
|
import cn.iocoder.yudao.module.pms.service.iotdeviceperson.IotDevicePersonService;
|
|
@@ -81,6 +79,8 @@ public class IotInspectOrderServiceImpl implements IotInspectOrderService {
|
|
|
private IotDeviceService iotDeviceService;
|
|
private IotDeviceService iotDeviceService;
|
|
|
@Autowired
|
|
@Autowired
|
|
|
private DeptApi deptApi;
|
|
private DeptApi deptApi;
|
|
|
|
|
+ @Autowired
|
|
|
|
|
+ private IotInspectOrderDeviceMapper iotInspectOrderDeviceMapper;
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
@Transactional(rollbackFor = Exception.class)
|
|
@@ -343,6 +343,20 @@ public class IotInspectOrderServiceImpl implements IotInspectOrderService {
|
|
|
CompletableFuture.runAsync(()->{
|
|
CompletableFuture.runAsync(()->{
|
|
|
//发送消息
|
|
//发送消息
|
|
|
pmsMessage.sendMessage(iotInspectOrderDO.getId(), iotInspectOrderDO.getInspectOrderTitle(), PmsConstants.GENERATE_INSPECT, k, user.getMobile());
|
|
pmsMessage.sendMessage(iotInspectOrderDO.getId(), iotInspectOrderDO.getInspectOrderTitle(), PmsConstants.GENERATE_INSPECT, k, user.getMobile());
|
|
|
|
|
+ List<IotDeviceSimple> iotDeviceDOS = iotDeviceMapper.selectCodeAndNameList();
|
|
|
|
|
+ //写入子表
|
|
|
|
|
+ Set<Long> collect = results.stream().map(IotInspectOrderDetailDO::getDeviceId).collect(Collectors.toSet());
|
|
|
|
|
+ List<IotInspectOrderDeviceDO> inspectDevices = new ArrayList<>();
|
|
|
|
|
+ collect.forEach(deviceId -> iotDeviceDOS.stream().filter(g -> deviceId.equals(g.getId())).findFirst().ifPresent(iotDeviceDO -> {
|
|
|
|
|
+ IotInspectOrderDeviceDO iotInspectOrderDeviceDO = new IotInspectOrderDeviceDO();
|
|
|
|
|
+ iotInspectOrderDeviceDO.setDeviceId(deviceId);
|
|
|
|
|
+ iotInspectOrderDeviceDO.setOrderId(iotInspectOrderDO.getId());
|
|
|
|
|
+ iotInspectOrderDeviceDO.setDeviceName(iotDeviceDO.getDeviceName());
|
|
|
|
|
+ iotInspectOrderDeviceDO.setDeviceCode(iotDeviceDO.getDeviceCode());
|
|
|
|
|
+ iotInspectOrderDeviceDO.setDeleted(false);
|
|
|
|
|
+ inspectDevices.add(iotInspectOrderDeviceDO);
|
|
|
|
|
+ }));
|
|
|
|
|
+ iotInspectOrderDeviceMapper.insertBatch(inspectDevices);
|
|
|
});
|
|
});
|
|
|
});
|
|
});
|
|
|
}
|
|
}
|