|
|
@@ -130,6 +130,7 @@ import cn.start.tz.module.pressure2.service.pipetaskorderinput.PipeTaskOrderInpu
|
|
|
import cn.start.tz.module.pressure2.service.pipetaskorderitemreportversion.PipeTaskOrderItemReportVersionService;
|
|
|
import cn.start.tz.module.pressure2.service.pipetaskorderoperation.PipeTaskOrderOperationService;
|
|
|
import cn.start.tz.module.pressure2.service.pipetaskordersecuritycheck.PipeTaskOrderSecurityCheckService;
|
|
|
+import cn.start.tz.module.pressure2.util.DeptDataPermissionUtil;
|
|
|
import cn.start.tz.module.pressure2.util.JsonDiffTool;
|
|
|
import cn.start.tz.module.system.api.clientunit.ClientUnitApi;
|
|
|
import cn.start.tz.module.system.api.orgcontact.OrgContactApi;
|
|
|
@@ -506,6 +507,13 @@ public class PipeTaskOrderServiceImpl extends ServiceImpl<PipeTaskOrderMapper, P
|
|
|
|
|
|
@Override
|
|
|
public PageResult<PipeTaskOrderRespVO> getPipeTaskOrderPage(BoilerTaskOrderPageReqVO pageReqVO) {
|
|
|
+
|
|
|
+// String userId = getLoginUserId();
|
|
|
+// pageReqVO.setUserId(userId);
|
|
|
+
|
|
|
+ //获取权限参数
|
|
|
+ pageReqVO = DeptDataPermissionUtil.generateDeptDataPermissionReq(pageReqVO);
|
|
|
+
|
|
|
PageResult<PipeTaskOrderRespVO> pageResult = new PageResult<>();
|
|
|
|
|
|
List<PipeTaskOrderRespVO> TaskOrderRespVOS = pipeTaskOrderMapper.selectPage(pageReqVO);
|
|
|
@@ -618,6 +626,16 @@ public class PipeTaskOrderServiceImpl extends ServiceImpl<PipeTaskOrderMapper, P
|
|
|
List<String> reportIds = new ArrayList<>();
|
|
|
for (PipeTaskOrderItemReportDO report : reportDOs) {
|
|
|
reportIds.add(report.getId());
|
|
|
+
|
|
|
+ //刷新报表数据
|
|
|
+ BoilerTaskOrderSyncReportVO syncReportVO = new BoilerTaskOrderSyncReportVO();
|
|
|
+ syncReportVO.setRefId(report.getId());
|
|
|
+ syncReportVO.setReportType("record");
|
|
|
+ com.alibaba.fastjson2.JSONObject params = new com.alibaba.fastjson2.JSONObject();
|
|
|
+ params.put("checkUserId",managerId);
|
|
|
+ syncReportVO.setParams(params);
|
|
|
+ syncReportData(syncReportVO);
|
|
|
+
|
|
|
}
|
|
|
List<PipeTaskOrderItemReportUserDO> reportUserDOs = pipeTaskOrderItemReportUserMapper.selectList(new LambdaQueryWrapperX<PipeTaskOrderItemReportUserDO>()
|
|
|
.in(PipeTaskOrderItemReportUserDO::getReportId, reportIds));
|
|
|
@@ -789,8 +807,9 @@ public class PipeTaskOrderServiceImpl extends ServiceImpl<PipeTaskOrderMapper, P
|
|
|
addReport1.setTemplateId(dynamicTbDO.getId());
|
|
|
addReport1.setFee(item.getFee());
|
|
|
addReport1.setOrderId(taskOrderDO.getId());
|
|
|
- addReport1.setTaskStatus(400);
|
|
|
+ addReport1.setTaskStatus(500);
|
|
|
addReport1.setReportNo(reportNo);
|
|
|
+ addReport1.setReportUrl(itemDO.getId());
|
|
|
//addReport1.setSort(index.getAndSet(index.get() + 1));
|
|
|
addReport1.setReportType(dynamicTbDO.getTbType());
|
|
|
|
|
|
@@ -814,7 +833,7 @@ public class PipeTaskOrderServiceImpl extends ServiceImpl<PipeTaskOrderMapper, P
|
|
|
addReport1.setTemplateId(dynamicTbDO.getId());
|
|
|
addReport1.setFee(item.getFee());
|
|
|
addReport1.setOrderId(taskOrderDO.getId());
|
|
|
- addReport1.setTaskStatus(400);
|
|
|
+ addReport1.setTaskStatus(500);
|
|
|
addReport1.setReportNo(reportNo);
|
|
|
//addReport1.setSort(index.getAndSet(index.get() + 1));
|
|
|
addReport1.setReportType(dynamicTbDO.getTbType());
|
|
|
@@ -878,6 +897,12 @@ public class PipeTaskOrderServiceImpl extends ServiceImpl<PipeTaskOrderMapper, P
|
|
|
@Override
|
|
|
public PageResult<PipeOrderItemPageRespVO> getOrderItemPage(BoilerTaskOrderPageReqVO pageReqVO) {
|
|
|
|
|
|
+// String userId = getLoginUserId();
|
|
|
+// pageReqVO.setUserId(userId);
|
|
|
+
|
|
|
+ //获取权限参数
|
|
|
+ pageReqVO = DeptDataPermissionUtil.generateDeptDataPermissionReq(pageReqVO);
|
|
|
+
|
|
|
PageResult<PipeOrderItemPageRespVO> pageResult = new PageResult<>();
|
|
|
|
|
|
List<PipeOrderItemPageRespVO> pipeOrderItemPageRespVOS = pipeTaskOrderMapper.selectItemPage(pageReqVO);
|
|
|
@@ -1227,7 +1252,7 @@ public class PipeTaskOrderServiceImpl extends ServiceImpl<PipeTaskOrderMapper, P
|
|
|
addReport.setTemplateId(vo.getTemplateId());
|
|
|
addReport.setFee(vo.getFee());
|
|
|
addReport.setOrderId(orderId);
|
|
|
- addReport.setTaskStatus(TaskOrderStatusEnum.CONFIRM.getStatus());
|
|
|
+ addReport.setTaskStatus(TaskOrderStatusEnum.ENTER.getStatus());
|
|
|
addReport.setSort(count + 1 + i);
|
|
|
|
|
|
// 计算当前是第几个(从 1 开始)
|
|
|
@@ -1318,7 +1343,7 @@ public class PipeTaskOrderServiceImpl extends ServiceImpl<PipeTaskOrderMapper, P
|
|
|
taskOrderItemReportUserDO.setUserId(orderItemEnterVO.getCheckId());
|
|
|
taskOrderItemReportUserDO.setGroupTeamId(orderItemEnterVO.getGroupTeamId());
|
|
|
|
|
|
- if (StringUtils.isBlank(taskOrderDO.getManagerId())) {
|
|
|
+ if (StringUtils.isBlank(orderItemEnterVO.getCheckId())) {
|
|
|
taskOrderItemReportUserDO.setUserId(taskOrderDO.getManagerId());
|
|
|
}
|
|
|
pipeTaskOrderItemReportUserMapper.insert(taskOrderItemReportUserDO);
|
|
|
@@ -1329,7 +1354,7 @@ public class PipeTaskOrderServiceImpl extends ServiceImpl<PipeTaskOrderMapper, P
|
|
|
syncReportVO.setRefId(addReport.getId());
|
|
|
syncReportVO.setReportType("record");
|
|
|
com.alibaba.fastjson2.JSONObject params = new com.alibaba.fastjson2.JSONObject();
|
|
|
- if (taskOrderDO != null && StringUtils.isBlank(taskOrderDO.getManagerId())) {
|
|
|
+ if (taskOrderDO != null && StringUtils.isBlank(orderItemEnterVO.getCheckId())) {
|
|
|
params.put("checkUserId",taskOrderDO.getManagerId());
|
|
|
}else{
|
|
|
params.put("checkUserId",orderItemEnterVO.getCheckId());
|
|
|
@@ -2017,6 +2042,7 @@ public class PipeTaskOrderServiceImpl extends ServiceImpl<PipeTaskOrderMapper, P
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
+ @Transactional
|
|
|
public void updateTaskOrderItemReportUser(PipeTaskOrderReportUserVO updateReqVO) {
|
|
|
|
|
|
pipeTaskOrderItemReportUserMapper.delete(PipeTaskOrderItemReportUserDO::getReportId, updateReqVO.getId());
|
|
|
@@ -2032,6 +2058,16 @@ public class PipeTaskOrderServiceImpl extends ServiceImpl<PipeTaskOrderMapper, P
|
|
|
// 设备关联 检验
|
|
|
pipeTaskOrderItemReportUserMapper.insertBatch(acceptOrderList);
|
|
|
|
|
|
+ //刷新报表数据
|
|
|
+ if (!acceptOrderList.isEmpty()){
|
|
|
+ BoilerTaskOrderSyncReportVO syncReportVO = new BoilerTaskOrderSyncReportVO();
|
|
|
+ syncReportVO.setRefId(updateReqVO.getId());
|
|
|
+ syncReportVO.setReportType("record");
|
|
|
+ com.alibaba.fastjson2.JSONObject params = new com.alibaba.fastjson2.JSONObject();
|
|
|
+ params.put("checkUserId",acceptOrderList.get(0).getUserId());
|
|
|
+ syncReportVO.setParams(params);
|
|
|
+ syncReportData(syncReportVO);
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
@@ -2081,7 +2117,12 @@ public class PipeTaskOrderServiceImpl extends ServiceImpl<PipeTaskOrderMapper, P
|
|
|
@Override
|
|
|
public PageResult<PipeOrderItemPageRespVO> recheckOrderItemPage(BoilerTaskOrderPageReqVO pageReqVO) {
|
|
|
|
|
|
- String userId = getLoginUserId();
|
|
|
+// String userId = getLoginUserId();
|
|
|
+// pageReqVO.setUserId(userId);
|
|
|
+
|
|
|
+ //获取权限参数
|
|
|
+ pageReqVO = DeptDataPermissionUtil.generateDeptDataPermissionReq(pageReqVO);
|
|
|
+
|
|
|
if (StringUtils.isNotEmpty(pageReqVO.getApproveStrIds())) {
|
|
|
pageReqVO.setApproveIds(List.of(pageReqVO.getApproveStrIds().split(",")));
|
|
|
}
|
|
|
@@ -2106,7 +2147,6 @@ public class PipeTaskOrderServiceImpl extends ServiceImpl<PipeTaskOrderMapper, P
|
|
|
pageReqVO.setCheckUserIds(List.of(pageReqVO.getCheckUserStrIds().split(",")));
|
|
|
}
|
|
|
|
|
|
-// pageReqVO.setUserId(userId);
|
|
|
pageReqVO.setTaskStatus(TaskOrderStatusEnum.RECHECK.getStatus());
|
|
|
if (CollUtil.isNotEmpty(pageReqVO.getRecheckStatusList())) {
|
|
|
pageReqVO.setRecheckStatusList(pageReqVO.getRecheckStatusList());
|
|
|
@@ -4572,6 +4612,74 @@ public class PipeTaskOrderServiceImpl extends ServiceImpl<PipeTaskOrderMapper, P
|
|
|
return false;
|
|
|
}
|
|
|
|
|
|
+ @Override
|
|
|
+ public Boolean syncAllReportData(BoilerTaskOrderSyncReportVO reqVO) {
|
|
|
+
|
|
|
+ PipeTaskOrderItemReportDO itemReportDO = taskOrderItemReportMapper.selectById(reqVO.getRefId());
|
|
|
+ if (itemReportDO != null) {
|
|
|
+ // 收集需要处理的模板 ID 及其类型列表
|
|
|
+ List<TemplateInfo> templateInfos = new ArrayList<>();
|
|
|
+ if (StringUtils.isNotBlank(itemReportDO.getTemplateId())) {
|
|
|
+ templateInfos.add(new TemplateInfo(itemReportDO.getTemplateId(), 1));
|
|
|
+ }
|
|
|
+ if (StringUtils.isNotBlank(itemReportDO.getReportTemplateId())) {
|
|
|
+ templateInfos.add(new TemplateInfo(itemReportDO.getReportTemplateId(), 2));
|
|
|
+ }
|
|
|
+ if (StringUtils.isNotBlank(itemReportDO.getResultTemplateId())) {
|
|
|
+ templateInfos.add(new TemplateInfo(itemReportDO.getResultTemplateId(), 3));
|
|
|
+ }
|
|
|
+
|
|
|
+ // 对每个模板 ID 进行循环同步处理
|
|
|
+ for (TemplateInfo templateInfo : templateInfos) {
|
|
|
+ DynamicTbDO dynamicTbDO = dynamicTbMapper.selectById(templateInfo.getTemplateId());
|
|
|
+ if (dynamicTbDO == null) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+
|
|
|
+ CreateInstantiateWithRuleVO ruleVO = new CreateInstantiateWithRuleVO();
|
|
|
+ ruleVO.setTemplateId(templateInfo.getTemplateId());
|
|
|
+ ruleVO.setRefId(reqVO.getRefId());
|
|
|
+ ruleVO.setRefName(itemReportDO.getReportName());
|
|
|
+ ruleVO.setReportType(templateInfo.getReportType());
|
|
|
+ if (reqVO.getParams() == null){
|
|
|
+ reqVO.setParams(new com.alibaba.fastjson2.JSONObject());
|
|
|
+ }
|
|
|
+ reqVO.getParams().put("equipMainType","pipe");
|
|
|
+ ruleVO.setParams(reqVO.getParams());
|
|
|
+
|
|
|
+ //获取 tbCode 的服务方法名
|
|
|
+ BoilerConnectTbServiceDO tbServiceDO = boilerConnectTbServiceMapper.selectOne(BoilerConnectTbServiceDO::getTbId, dynamicTbDO.getId());
|
|
|
+ if (tbServiceDO != null){
|
|
|
+ ruleVO.setServiceName(tbServiceDO.getInitServiceName());
|
|
|
+ dynamicTbInsService.createInstantiateWithRule(ruleVO);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 模板信息内部类
|
|
|
+ */
|
|
|
+ private static class TemplateInfo {
|
|
|
+ private final String templateId;
|
|
|
+ private final int reportType;
|
|
|
+
|
|
|
+ public TemplateInfo(String templateId, int reportType) {
|
|
|
+ this.templateId = templateId;
|
|
|
+ this.reportType = reportType;
|
|
|
+ }
|
|
|
+
|
|
|
+ public String getTemplateId() {
|
|
|
+ return templateId;
|
|
|
+ }
|
|
|
+
|
|
|
+ public int getReportType() {
|
|
|
+ return reportType;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
@Override
|
|
|
public List<PipeEquipInfoVO> getEquipsByOrderId(String orderId) {
|
|
|
|