签名调整

tz-module-pressure2/tz-module-pressure2-biz/src/main/java/cn/start/tz/module/pressure2/service/tasksign/TaskSignServiceImpl.java

@@ -11,22 +11,32 @@ import cn.start.tz.module.infra.api.sign.dto.CntSignReqDTO;
 import cn.start.tz.module.infra.api.sign.dto.CntSignResponseRepsDTO;
 import cn.start.tz.module.infra.api.sign.dto.QrCodeValuesDTO;
 import cn.start.tz.module.infra.api.sign.dto.SignValuesDTO;
+import cn.start.tz.module.pressure2.controller.admin.boilertaskorder.vo.BoilerTaskOrderSyncReportVO;
 import cn.start.tz.module.pressure2.controller.admin.boilertaskorder.vo.MajorIssuesSubmitVO;
 import cn.start.tz.module.pressure2.controller.admin.pipetaskorderinput.vo.PipeTaskOrderInputPrintReqVO;
 import cn.start.tz.module.pressure2.controller.appapi.boilertaskorder.vo.OrderFromPdfReqVO;
 import cn.start.tz.module.pressure2.controller.appapi.boilertaskorder.vo.TaskOrderPushReqVO;
 import cn.start.tz.module.pressure2.dal.dataobject.boilertaskorder.BoilerTaskOrderDO;
 import cn.start.tz.module.pressure2.dal.dataobject.boilertaskorderitemreport.BoilerTaskOrderItemReportDO;
+import cn.start.tz.module.pressure2.dal.dataobject.boilertaskordersecuritycheck.BoilerTaskOrderSecurityCheckDO;
 import cn.start.tz.module.pressure2.dal.dataobject.boilertaskordersignfile.BoilerTaskOrderSignFileDO;
+import cn.start.tz.module.pressure2.dal.dataobject.notificationformreport.NotificationformReportDO;
 import cn.start.tz.module.pressure2.dal.dataobject.orderreport.OrderReportDO;
 import cn.start.tz.module.pressure2.dal.dataobject.pipetaskorderitemreport.PipeTaskOrderItemReportDO;
+import cn.start.tz.module.pressure2.dal.dataobject.pipetaskordersecuritycheck.PipeTaskOrderSecurityCheckDO;
 import cn.start.tz.module.pressure2.dal.mysql.boilertaskorder.BoilerTaskOrderMapper;
 import cn.start.tz.module.pressure2.dal.mysql.boilertaskorderitemreport.BoilerTaskOrderItemReportMapper;
+import cn.start.tz.module.pressure2.dal.mysql.boilertaskordersecuritycheck.TaskOrderSecurityCheckMapper;
+import cn.start.tz.module.pressure2.dal.mysql.notificationformreport.NotificationformReportMapper;
 import cn.start.tz.module.pressure2.dal.mysql.orderreport.OrderReportMapper;
 import cn.start.tz.module.pressure2.dal.mysql.pipetaskorderitemreport.PipeTaskOrderItemReportMapper;
+import cn.start.tz.module.pressure2.dal.mysql.pipetaskordersecuritycheck.PipeTaskOrderSecurityCheckMapper;
 import cn.start.tz.module.pressure2.service.boilertaskorder.BoilerTaskOrderService;
+import cn.start.tz.module.pressure2.service.boilertaskordersecuritycheck.BoilerTaskOrderSecurityCheckService;
 import cn.start.tz.module.pressure2.service.boilertaskordersignfile.BoilerTaskOrderSignFileService;
+import cn.start.tz.module.pressure2.service.notificationformreport.NotificationformReportService;
 import cn.start.tz.module.pressure2.service.orderreport.OrderReportService;
+import cn.start.tz.module.pressure2.service.pipetaskorder.PipeTaskOrderService;
 import cn.start.tz.module.pressure2.service.pipetaskorderinput.PipeTaskOrderInputService;
 import cn.start.tz.module.system.api.user.AdminUserApi;
 import cn.start.tz.module.system.api.user.dto.AdminUserRespDTO;
@@ -66,6 +76,21 @@ public class TaskSignServiceImpl implements TaskSignService {
     @Resource
     private PipeTaskOrderInputService pipeTaskOrderInputService;
 
+    @Resource
+    private NotificationformReportMapper notificationformReportMapper;
+
+    @Resource
+    private BoilerTaskOrderService boilerTaskOrderService;
+
+    @Resource
+    private PipeTaskOrderService pipeTaskOrderService;
+
+    @Resource
+    private TaskOrderSecurityCheckMapper taskOrderSecurityCheckMapper;
+
+    @Resource
+    private PipeTaskOrderSecurityCheckMapper pipeTaskOrderSecurityCheckMapper;
+
     @Resource
     private OrderReportMapper orderReportMapper;
 
@@ -80,9 +105,6 @@ public class TaskSignServiceImpl implements TaskSignService {
     @Resource
     private AdminUserApi adminUserApi;
 
-    @Resource
-    private BoilerTaskOrderService boilerTaskOrderService;
-
     @Resource
     private BoilerTaskOrderSignFileService boilerTaskOrderSignFileService;
 
@@ -141,6 +163,71 @@ public class TaskSignServiceImpl implements TaskSignService {
             } else {
                 orderReportService.generatePipeOrderReport(taskOrderDO.getAcceptOrderId());
             }
+        }else if (reqVO.getBusinessType().equals(200)){
+            List<NotificationformReportDO> formReportDOS = notificationformReportMapper
+                    .selectList(NotificationformReportDO::getTaskOrderId, taskOrderDO.getId());
+            if (taskOrderDO.getEquipMainType().equals(200)) {
+                formReportDOS.forEach(formReportDO -> {
+                    BoilerTaskOrderSyncReportVO syncReportVO = new BoilerTaskOrderSyncReportVO();
+                    syncReportVO.setRefId(formReportDO.getId());
+                    syncReportVO.setReportType("record");
+                    boilerTaskOrderService.syncReportData(syncReportVO);
+                });
+            } else if (taskOrderDO.getEquipMainType().equals(300)){
+                formReportDOS.forEach(formReportDO -> {
+                    BoilerTaskOrderSyncReportVO syncReportVO = new BoilerTaskOrderSyncReportVO();
+                    syncReportVO.setRefId(formReportDO.getId());
+                    syncReportVO.setReportType("record");
+                    pipeTaskOrderService.syncReportData(syncReportVO);
+                });
+            }
+        }else if (reqVO.getBusinessType().equals(300)){
+
+            if (taskOrderDO.getEquipMainType().equals(200)) {
+                List<BoilerTaskOrderSecurityCheckDO> formReportDOS = taskOrderSecurityCheckMapper
+                        .selectList(BoilerTaskOrderSecurityCheckDO::getOrderId, taskOrderDO.getId());
+                formReportDOS.forEach(formReportDO -> {
+                    BoilerTaskOrderSyncReportVO syncReportVO = new BoilerTaskOrderSyncReportVO();
+                    syncReportVO.setRefId(formReportDO.getId());
+                    syncReportVO.setReportType("record");
+                    boilerTaskOrderService.syncReportData(syncReportVO);
+                });
+            } else if (taskOrderDO.getEquipMainType().equals(300)){
+                List<PipeTaskOrderSecurityCheckDO> formReportDOS = pipeTaskOrderSecurityCheckMapper
+                        .selectList(PipeTaskOrderSecurityCheckDO::getOrderId, taskOrderDO.getId());
+                formReportDOS.forEach(formReportDO -> {
+                    BoilerTaskOrderSyncReportVO syncReportVO = new BoilerTaskOrderSyncReportVO();
+                    syncReportVO.setRefId(formReportDO.getId());
+                    syncReportVO.setReportType("record");
+                    pipeTaskOrderService.syncReportData(syncReportVO);
+                });
+            }
+        }else if (reqVO.getBusinessType().equals(400)){
+
+            if (taskOrderDO.getEquipMainType().equals(200)) {
+                List<BoilerTaskOrderItemReportDO> formReportDOS = boilerTaskOrderItemReportMapper
+                        .selectList(new LambdaQueryWrapperX<BoilerTaskOrderItemReportDO>().
+                                eq(BoilerTaskOrderItemReportDO::getOrderId, taskOrderDO.getId()).
+                                eq(BoilerTaskOrderItemReportDO::getReportType, 500));
+                formReportDOS.forEach(formReportDO -> {
+                    BoilerTaskOrderSyncReportVO syncReportVO = new BoilerTaskOrderSyncReportVO();
+                    syncReportVO.setRefId(formReportDO.getId());
+                    syncReportVO.setReportType("record");
+                    boilerTaskOrderService.syncReportData(syncReportVO);
+                });
+            } else if (taskOrderDO.getEquipMainType().equals(300)){
+                List<PipeTaskOrderItemReportDO> formReportDOS = pipeTaskOrderItemReportMapper
+                        .selectList(new LambdaQueryWrapperX<PipeTaskOrderItemReportDO>().
+                                eq(PipeTaskOrderItemReportDO::getOrderId, taskOrderDO.getId()).
+                                eq(PipeTaskOrderItemReportDO::getReportType, 500));
+                formReportDOS.forEach(formReportDO -> {
+                    BoilerTaskOrderSyncReportVO syncReportVO = new BoilerTaskOrderSyncReportVO();
+                    syncReportVO.setRefId(formReportDO.getId());
+                    syncReportVO.setReportType("record");
+                    pipeTaskOrderService.syncReportData(syncReportVO);
+                });
+            }
+
         }
 
 //        String pdfUrl = printFromPdfDownload(orderFromPdfReqVO);