更新代码

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-api/src/main/java/com/yeejoin/amos/boot/module/jg/api/entity/JgTransferNotice.java

@@ -295,4 +295,7 @@ public class JgTransferNotice extends BaseEntity {
     @TableField(exist = false)
     private String equipCateName;
 
+    @TableField(value = "handle_date")
+    private Date handleDate;
+
 }

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-api/src/main/resources/mapper/JgTransferNoticeMapper.xml

@@ -22,7 +22,8 @@
         tjtn.next_execute_ids AS nextExecuteIds,
         tjtn.instance_status AS instanceStatus,
         tjtn.notice_report_url AS noticeReportUrl,
-        ec."name" AS equipCateName
+        ec."name" AS equipCateName,
+        tjtn.handle_date AS handleDate
         FROM
             tzs_jg_transfer_notice tjtn
             LEFT JOIN tzs_jg_transfer_notice_eq re ON re.equip_transfer_id = tjtn.sequence_nbr

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/service/impl/JgTransferNoticeServiceImpl.java

@@ -5,12 +5,15 @@ import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.aspose.words.SaveFormat;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.yeejoin.amos.boot.biz.common.bo.ReginParams;
+import com.yeejoin.amos.boot.biz.common.utils.DateUtils;
 import com.yeejoin.amos.boot.biz.common.utils.RedisKey;
 import com.yeejoin.amos.boot.biz.common.utils.RedisUtils;
 import com.yeejoin.amos.boot.module.jg.api.dto.ByteArrayMultipartFile;
 import com.yeejoin.amos.boot.module.jg.api.dto.JgTransferNoticeDto;
+import com.yeejoin.amos.boot.module.jg.api.entity.JgMaintainNoticeEq;
 import com.yeejoin.amos.boot.module.jg.api.entity.JgTransferNotice;
 import com.yeejoin.amos.boot.module.jg.api.entity.JgTransferNoticeEq;
 import com.yeejoin.amos.boot.module.jg.api.mapper.JgTransferNoticeEqMapper;
@@ -19,6 +22,7 @@ import com.yeejoin.amos.boot.module.jg.api.service.IJgTransferNoticeService;
 import com.yeejoin.amos.boot.module.jg.biz.feign.TzsServiceFeignClient;
 import com.yeejoin.amos.boot.module.jg.biz.utils.ImageUtils;
 import com.yeejoin.amos.boot.module.jg.biz.utils.WordTemplateUtils;
+import com.yeejoin.amos.boot.module.ymt.api.entity.RegistrationInfo;
 import com.yeejoin.amos.boot.module.ymt.api.enums.ApplicationFormTypeEnum;
 import com.yeejoin.amos.boot.module.ymt.api.enums.FlowStatusEnum;
 import com.yeejoin.amos.boot.module.ymt.api.mapper.EquipmentCategoryMapper;
@@ -50,6 +54,7 @@ import java.io.File;
 import java.io.FileInputStream;
 import java.io.IOException;
 import java.nio.file.Files;
+import java.text.ParseException;
 import java.util.*;
 import java.util.function.Function;
 import java.util.stream.Collectors;
@@ -549,15 +554,15 @@ public class JgTransferNoticeServiceImpl extends BaseService<JgTransferNoticeDto
                 model.setReceiveOrgName(receiveOrgIdList[1]);
             }
         }
-//
-//        String inspectUnitId = model.getInspectUnitId();
-//        if (!ObjectUtils.isEmpty(inspectUnitId)) {
-//            String[] inspectUnitIdList = inspectUnitId.split("_");
-//            if (inspectUnitIdList.length > 1) {
-//                model.setInspectUnitId(inspectUnitIdList[0]);
-//                model.setInspectUnitName(inspectUnitIdList[1]);
-//            }
-//        }
+
+        String constructionManagerId = model.getConstructionManagerId();
+        if (!ObjectUtils.isEmpty(constructionManagerId)) {
+            String[] constructionManagerIdList = constructionManagerId.split("_");
+            if (constructionManagerIdList.length > 1) {
+                model.setConstructionManagerId(constructionManagerIdList[0]);
+                model.setConstructionManager(constructionManagerIdList[1]);
+            }
+        }
 
         String factoryUseSiteStreet = model.getFactoryUseSiteStreet();
         if (!ObjectUtils.isEmpty(factoryUseSiteStreet)) {
@@ -620,81 +625,58 @@ public class JgTransferNoticeServiceImpl extends BaseService<JgTransferNoticeDto
         }
     }
 
+    @Transactional
     public void accept(JgTransferNoticeDto dto, String op) {
+        String[] taskName = new String[]{"流程结束"};
         ReginParams reginParams = JSONObject.parseObject(redisUtils.get(RedisKey.buildReginKey(RequestContext.getExeUserId(), RequestContext.getToken())).toString(), ReginParams.class);
         JgTransferNotice jgTransferNotice = this.jgTransferNoticeMapper.selectById(dto.getSequenceNbr());
         // 组装设备注册代码
-//        StringBuffer stringBuffer = new StringBuffer();
-//        String ym = null;
-//        try {
-//            ym = DateUtils.dateFormat(new Date(), DateUtils.DATE_PATTERN_MM);
-//        } catch (ParseException e) {
-//            log.error("日期转换失败：{}", e);
-//        }
-
-//        LambdaQueryWrapper<JgTransferNoticeEq> queryWrapper = new LambdaQueryWrapper<>();
-//        queryWrapper.eq(JgTransferNoticeEq::getEquipTransferId, dto.getSequenceNbr());
-//        JgTransferNoticeEq jgRelationEquip = jgTransferNoticeEqMapper.selectOne(queryWrapper);
-//
-//        LambdaQueryWrapper<OtherInfo> queryWrapper1 = new LambdaQueryWrapper<>();
-//        queryWrapper1.eq(OtherInfo::getRecord, jgRelationEquip.getEquId());
-//        OtherInfo tzsJgOtherInfo = tzsJgOtherInfoMapper.selectOne(queryWrapper1);
-//
-//        LambdaQueryWrapper<RegistrationInfo> queryWrapper2 = new LambdaQueryWrapper<>();
-//        queryWrapper2.eq(RegistrationInfo::getRecord, jgRelationEquip.getEquId());
-//        RegistrationInfo tzsJgRegistrationInfo = tzsJgRegistrationInfoMapper.selectOne(queryWrapper2);
-//
-//
-//        stringBuffer.append(tzsJgRegistrationInfo.getEquCategory()).append(JgTransferNotice.getCity()).append(ym);
-//        String equCode = stringBuffer.toString();
-//        String deviceRegistrationCode = iCreateCodeService.createDeviceRegistrationCode(equCode);
-//        Map<String, Object> map = new HashMap<>();
-//        map.put("cityCode", JgTransferNotice.getCity());
-//        map.put("countyCode", JgTransferNotice.getCounty());
-//        map.put("equCategory", tzsJgRegistrationInfo.getEquCategory());
-////        map.put("isXiXian", JgTransferNotice.getIsXixian() == null ? "0" : JgTransferNotice.getIsXixian());
-//        Map<String, Object> mapCode;
-//        ResponseModel<Map<String, Object>> code = tzsServiceFeignClient.createCode(map);
-//        mapCode = code.getResult();
-//
-//        LambdaQueryWrapper<SupervisoryCodeInfo> queryWrapper3 = new LambdaQueryWrapper<>();
-//        queryWrapper3.eq(SupervisoryCodeInfo::getSupervisoryCode, mapCode.get("superviseCode").toString());
-//        SupervisoryCodeInfo supervisoryCodeInfo = supervisoryCodeInfoMapper.selectOne(queryWrapper3);
-//        supervisoryCodeInfo.setStatus("1");
-//        supervisoryCodeInfoMapper.updateById(supervisoryCodeInfo);
-
+        StringBuffer stringBuffer = new StringBuffer();
+        String ym = null;
+        try {
+            ym = DateUtils.dateFormat(new Date(), DateUtils.DATE_PATTERN_MM);
+        } catch (ParseException e) {
+            log.error("日期转换失败：{}", e);
+        }
 
+        ArrayList<String> roleList = new ArrayList<>();
         boolean submit = submit(jgTransferNotice, op);
         if(submit) {
+            getNext(roleList, dto.getInstanceId(), taskName);
             jgTransferNotice.setPromoter(reginParams.getUserModel().getUserId());
             if("0".equals(op)) {
-                jgTransferNotice.setNoticeStatus(String.valueOf(FlowStatusEnum.TO_BE_FINISHED.getCode()));
-                this.generateTransferNoticeReport(jgTransferNotice.getSequenceNbr());
+                if (roleList.size() == 0) {
+                    LambdaQueryWrapper<JgTransferNoticeEq> queryWrapper = new LambdaQueryWrapper<>();
+                    queryWrapper.eq(JgTransferNoticeEq::getEquipTransferId, dto.getSequenceNbr());
+                    JgTransferNoticeEq jgTransferNoticeEq = jgTransferNoticeEqMapper.selectOne(queryWrapper);
+                    LambdaQueryWrapper<RegistrationInfo> queryWrapper2 = new LambdaQueryWrapper<>();
+                    queryWrapper2.eq(RegistrationInfo::getRecord, jgTransferNoticeEq.getEquId());
+                    RegistrationInfo tzsJgRegistrationInfo = tzsJgRegistrationInfoMapper.selectOne(queryWrapper2);
+                    stringBuffer.append(tzsJgRegistrationInfo.getEquCategory()).append(jgTransferNotice.getCity()).append(ym);
+                    Map<String, Object> map = new HashMap<>();
+                    map.put("cityCode", jgTransferNotice.getCity());
+                    map.put("countyCode", jgTransferNotice.getCounty());
+                    map.put("equCategory", tzsJgRegistrationInfo.getEquCategory());
+                    jgTransferNotice.setPromoter("");
+                    jgTransferNotice.setHandleDate(new Date());
+                    jgTransferNotice.setNoticeStatus(String.valueOf(FlowStatusEnum.TO_BE_FINISHED.getCode()));
+                    this.generateTransferNoticeReport(jgTransferNotice.getSequenceNbr());
+                } else {
+                    jgTransferNotice.setNextExecuteIds(String.join(",", roleList));
+                    if (!ObjectUtils.isEmpty(jgTransferNotice.getInstanceStatus())) {
+                        jgTransferNotice.setInstanceStatus(jgTransferNotice.getInstanceStatus() + "," + String.join(",", roleList));
+                    } else {
+                        jgTransferNotice.setInstanceStatus(String.join(",", roleList));
+                    }
+                    jgTransferNotice.setNoticeStatus(String.valueOf(FlowStatusEnum.TO_BE_SUBMITTED.getCode()));
+                    jgTransferNotice.setInstanceStatus(String.valueOf(FlowStatusEnum.REJECTED.getCode()));
+                }
             } else {
-                jgTransferNotice.setNoticeStatus(String.valueOf(FlowStatusEnum.TO_BE_SUBMITTED.getCode()));
-                jgTransferNotice.setInstanceStatus(String.valueOf(FlowStatusEnum.REJECTED.getCode()));
+                jgTransferNotice.setPromoter("");
+                jgTransferNotice.setNoticeStatus(String.valueOf(FlowStatusEnum.REJECTED.getCode()));
             }
             jgTransferNoticeMapper.updateById(jgTransferNotice);
         }
-
-//        // 组装监管码
-//        String division = "";
-//        if (((XIAN.equals(dto.getCity()) || XIAN_YANG.equals(dto.getCity())) && "1".equals(dto.getIsXixian()))) {
-//            division = "X";
-//        } else {
-//            //生成监管码前缀
-//            Map<String, Object> divisionMap = equipmentCategoryMapper.getAdministrativeDivision(EquipmentCategoryEnum.XZQH.getCode(), dto.getCounty());
-//            division = ObjectUtils.isEmpty(divisionMap) ? equipmentCategoryMapper.getAdministrativeDivision(EquipmentCategoryEnum.XZQH.getCode(), dto.getCity()).get("code").toString() : divisionMap.get("code").toString();
-//        }
-//
-//        // 组装96333码
-//        String prefix = "";
-//        if (((XIAN.equals(dto.getCity()) || XIAN_YANG.equals(dto.getCity())) && "1".equals(dto.getIsXixian()))) {
-//            prefix = EquipmentCategoryEnum.XXCSM.getValue();
-//        } else {
-//            Map<String, Object> elevatorMap = equipmentCategoryMapper.getAdministrativeDivision(EquipmentCategoryEnum.XZQHDT.getCode(), dto.getCounty());
-//            prefix = ObjectUtils.isEmpty(elevatorMap) ? equipmentCategoryMapper.getAdministrativeDivision(EquipmentCategoryEnum.XZQHDT.getCode(), dto.getCity()).get("code").toString() : elevatorMap.get("code").toString();
-//        }
     }
 
     void getNext(ArrayList<String> roleListFirst, String instanceId, String[] taskName) {