Merge branch 'develop_tzs_register' of…

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-api/src/main/java/com/yeejoin/amos/boot/module/jg/api/dto/JgChangeRegistrationReformDto.java

 package com.yeejoin.amos.boot.module.jg.api.dto;
 
+import com.baomidou.mybatisplus.annotation.TableField;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import com.yeejoin.amos.boot.biz.common.dto.BaseDto;
@@ -110,7 +111,6 @@ public class JgChangeRegistrationReformDto extends BaseDto {
     @ApiModelProperty(value = "任务发起人id")
     private String promoter;
 
-
     private List<String> roleIds;
 
     private String dataType;

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-api/src/main/java/com/yeejoin/amos/boot/module/jg/api/dto/JgEquipTransferDto.java

@@ -89,4 +89,25 @@ public class JgEquipTransferDto  extends BaseDto {
     @TableField(exist = false)
     @ApiModelProperty(value = "告知设备列表")
     private List<Map<String, Object>> deviceList;
+
+    @ApiModelProperty(value = "设备类别")
+    private String equCategory;
+
+    @ApiModelProperty(value = "设备品种")
+    private String equDefine;
+
+    @ApiModelProperty(value = "设备出厂编号")
+    private String factoryNum;
+
+    @ApiModelProperty(value = "设备注册代码")
+    private String equRegisterCode;
+
+    @ApiModelProperty(value = "监管码")
+    private String supervisoryCode;
+
+    @ApiModelProperty(value = "单位内编号")
+    private String useInnerCode;
+
+    @ApiModelProperty(value = "设备地址")
+    private String concatenatedAddress;
 }

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-api/src/main/java/com/yeejoin/amos/boot/module/jg/api/dto/JgInstallationNoticeDto.java

@@ -236,4 +236,11 @@ public class JgInstallationNoticeDto extends BaseDto {
 
     private String instanceStatus;
 
+    @ApiModelProperty(value = "设备地址")
+    private String equAddress;
+
+    @ApiModelProperty(value = "办理日期")
+    private Date handleDate;
+
+
 }

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-api/src/main/java/com/yeejoin/amos/boot/module/jg/api/dto/JgMaintainNoticeDto.java

@@ -2,7 +2,9 @@ package com.yeejoin.amos.boot.module.jg.api.dto;
 
 import com.baomidou.mybatisplus.annotation.TableField;
 import com.fasterxml.jackson.annotation.JsonFormat;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
 import com.yeejoin.amos.boot.biz.common.dto.BaseDto;
+import com.yeejoin.amos.boot.module.jg.api.common.BizCustomDateSerializer;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
@@ -31,6 +33,7 @@ public class JgMaintainNoticeDto extends BaseDto {
 
     @ApiModelProperty(value = "告知日期")
     @JsonFormat(pattern = "yyyy-MM-dd")
+    @JsonSerialize(using = BizCustomDateSerializer.class)
     private Date noticeDate;
 
     @ApiModelProperty(value = "告知状态")
@@ -58,6 +61,8 @@ public class JgMaintainNoticeDto extends BaseDto {
     private String executeSequence;
 
     @ApiModelProperty(value = "创建时间")
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    @JsonSerialize(using = BizCustomDateSerializer.class)
     private Date createDate;
 
     @ApiModelProperty(value = "创建人id ")
@@ -74,6 +79,7 @@ public class JgMaintainNoticeDto extends BaseDto {
 
     @ApiModelProperty(value = "受理完成日期")
     @JsonFormat(pattern = "yyyy-MM-dd")
+    @JsonSerialize(using = BizCustomDateSerializer.class)
     private Date acceptDate;
 
     @ApiModelProperty(value = "施工区域-省")
@@ -93,6 +99,7 @@ public class JgMaintainNoticeDto extends BaseDto {
 
     @ApiModelProperty(value = "计划施工日期")
     @JsonFormat(pattern = "yyyy-MM-dd")
+    @JsonSerialize(using = BizCustomDateSerializer.class)
     private Date planDate;
 
     @ApiModelProperty(value = "接收机构单位代码")
@@ -183,4 +190,17 @@ public class JgMaintainNoticeDto extends BaseDto {
 
     @ApiModelProperty(value = "节点执行人")
     private String promoter;
+
+    @ApiModelProperty(value = "设备类别")
+    private String equListCode;
+
+    @ApiModelProperty(value = "设备类别名称")
+    private String equCategory;
+
+    private List<String> roleIds;
+
+    private String dataType;
+
+    @ApiModelProperty(value = "状态")
+    private String status;
 }

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-api/src/main/java/com/yeejoin/amos/boot/module/jg/api/dto/JgReformNoticeDto.java

@@ -79,6 +79,8 @@ public class JgReformNoticeDto extends BaseDto {
     private String instanceStatus;
 
     @ApiModelProperty (value = "受理完成日期")
+    @JsonFormat(pattern = "yyyy-MM-dd")
+    @JsonSerialize(using = BizCustomDateSerializer.class)
     private Date acceptDate;
 
     @ApiModelProperty (value = "施工区域-省")
@@ -153,6 +155,12 @@ public class JgReformNoticeDto extends BaseDto {
 
     @ApiModelProperty (value = "是否西咸")
     private String isXixian;
+
+    @ApiModelProperty(value = "设备类别")
+    private String equListCode;
+
+    @ApiModelProperty(value = "设备类别名称")
+    private String equCategory;
     /* ----------------  -------------- */
 
     @TableField (exist = false)

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

@@ -202,4 +202,17 @@ public class JgChangeRegistrationReform extends BaseEntity {
     @TableField(value = "promoter")
     private String promoter;
 
+    /**
+     * 改造质量证明材料
+     */
+    @TableField(value = "transformation_quality_certificate")
+    private String transformationQualityCertificate;
+
+
+    /**
+     *改造监督检验证书
+     */
+    @TableField(value = "renovation_supervisioninspection_certificate")
+    private String renovationSupervisioninspectionCertificate;
+
 }

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

@@ -142,4 +142,25 @@ public class JgEquipTransfer extends BaseEntity {
     @TableField(value = "instance_roles")
     private String instanceRoles;
 
+    @TableField(exist = false)
+    private String equCategory;
+
+    @TableField(exist = false)
+    private String equDefine;
+
+    @TableField(exist = false)
+    private String factoryNum;
+
+    @TableField(exist = false)
+    private String equRegisterCode;
+
+    @TableField(exist = false)
+    private String supervisoryCode;
+
+    @TableField(exist = false)
+    private String useInnerCode;
+
+    @TableField(exist = false)
+    private String concatenatedAddress;
+
 }

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

@@ -378,4 +378,12 @@ public class JgInstallationNotice extends BaseEntity {
 
     @TableField("instance_status")
     private String instanceStatus;
+
+
+    @TableField("equ_address")
+    private String equAddress;
+
+    @TableField("handle_date")
+    private Date handleDate;
+
 }

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

@@ -293,4 +293,24 @@ public class JgMaintainNotice extends BaseEntity {
     @TableField(value = "promoter")
     private String promoter;
 
+    /**
+     * 设备类别
+     */
+    @TableField(value = "equ_list_code")
+    private String equListCode;
+
+    /**
+     * 设备类别名称
+     */
+    @TableField(value = "equ_category")
+    private String equCategory;
+    /**
+     * 状态
+     */
+    @TableField("status")
+    private String status;
+
+
+    @TableField("next_execute_ids")
+    private String nextExecuteIds;
 }

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

@@ -298,4 +298,15 @@ public class JgReformNotice extends BaseEntity {
      */
     @TableField("status")
     private String status;
+    /**
+     * 设备类别
+     */
+    @TableField(value = "equ_list_code")
+    private String equListCode;
+
+    /**
+     * 设备类别名称
+     */
+    @TableField(value = "equ_category")
+    private String equCategory;
 }

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-api/src/main/java/com/yeejoin/amos/boot/module/jg/api/enums/MaintainTypeEnum.java

-package com.yeejoin.amos.boot.module.jg.api.enums;
-
-/**
- * 办理状态枚举
- */
-public enum MaintainTypeEnum {
-    GENERAL(1, "一般维修"),
-    PRIORITY(2, "重点维修");
-
-    private final int code;
-
-    private final String name;
-
-    MaintainTypeEnum(int code, String name) {
-        this.code = code;
-        this.name = name;
-    }
-
-    public static String getNameByType(Long code) {
-        String name = null;
-        for (MaintainTypeEnum enumOne : MaintainTypeEnum.values()) {
-            if (enumOne.getCode() == code) {
-                name = enumOne.getName();
-                break;
-            }
-        }
-        return name;
-    }
-
-    public int getCode() {
-        return code;
-    }
-
-    public String getName() {
-        return name;
-    }
-}

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-api/src/main/java/com/yeejoin/amos/boot/module/jg/api/enums/UseStatusEnum.java

@@ -3,9 +3,6 @@ package com.yeejoin.amos.boot.module.jg.api.enums;
 import lombok.AllArgsConstructor;
 import lombok.Getter;
 
-import java.util.HashMap;
-import java.util.Map;
-
 /**
  * 使用登记状态西悉尼
  */
@@ -13,11 +10,10 @@ import java.util.Map;
 @AllArgsConstructor
 public enum UseStatusEnum {
 
-    SUBMIT("使用单位提交", "submit", "使用单位待提交"),
-    RECEIVE("一级受理", "receive", "一级待受理"),
-    PRELIMINARY("二级受理", "preliminary", "二级待受理"),
-    REEXAMINE("三级受理", "reexamine", "三级待受理");
-
+    SUBMIT("使用单位提交", "submit", "使用单位待提交", "一级受理已驳回", "使用单位提交已撤回"),
+    RECEIVE("一级受理", "receive", "一级待受理", "二级受理已驳回", "一级受理已撤回"),
+    PRELIMINARY("二级受理", "preliminary", "二级待受理", "三级受理已驳回", "二级受理已撤回"),
+    REEXAMINE("三级受理", "reexamine", "三级待受理","","");
 
 
     private final String name;
@@ -26,6 +22,10 @@ public enum UseStatusEnum {
 
     private final String pass;
 
+    private final String reject;
+
+    private final String rollBack;
+
 
 
     public static UseStatusEnum getMessage(String name){

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-api/src/main/java/com/yeejoin/amos/boot/module/jg/api/enums/WorkFlowStatusEnum.java

+package com.yeejoin.amos.boot.module.jg.api.enums;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+/**
+ * 使用登记状态西悉尼
+ */
+@Getter
+@AllArgsConstructor
+public enum WorkFlowStatusEnum {
+
+    /**
+     * 使用登记流程
+     */
+    USE_SUBMIT("使用单位提交", "useSubmit", "使用单位待提交", "一级受理已驳回", "使用单位提交已撤回"),
+    USE_RECEIVE("一级受理", "useReceive", "一级待受理", "二级受理已驳回", "一级受理已撤回"),
+    USE_PRELIMINARY("二级受理", "usePreliminary", "二级待受理", "三级受理已驳回", "二级受理已撤回"),
+    USE_REEXAMINE("三级受理", "useReexamine", "三级待受理","",""),
+
+
+    /**
+     * 维保流程
+     */
+    MAIN_SUBMIT("使用单位提交", "mainSubmit", "使用单位待提交", "维保单位已驳回", "使用单位撤回"),
+    MAIN_RECEIVE("维保单位审核确认", "mainReceive", "维保单位待受理", "监管单位已驳回", "维保单位撤回"),
+    MAIN_PRELIMINARY("监管单位审核", "mainPreliminary", "监管单位待受理", "", ""),
+
+
+    /**
+     * 电梯注销
+     */
+    CANCEL_SUBMIT("使用单位提交", "cancelSubmit", "使用单位待提交", "一级受理已驳回", "使用单位提交已撤回"),
+    CANCEL_RECEIVE("一级受理", "cancelReceive", "一级待受理", "二级受理已驳回", "一级受理已撤回"),
+    CANCEL_PRELIMINARY("二级受理", "cancelPreliminary", "二级待受理", "三级受理已驳回", "二级受理已撤回"),
+    CANCEL_REEXAMINE("三级受理", "cancelReexamine", "三级待受理", "", ""),
+
+    /**
+     * 改造登记流程
+     */
+    CHANGE_SUBMIT("使用单位提交", "changeSubmit", "使用单位待提交", "一级受理已驳回", "使用单位提交已撤回"),
+    CHANGE_RECEIVE("一级受理", "changeReceive", "一级待受理", "二级受理已驳回", "一级受理已撤回"),
+    CHANGE_PRELIMINARY("二级受理", "changePreliminary", "二级待受理", "三级受理已驳回", "二级受理已撤回"),
+    CHANGE_REEXAMINE("三级受理", "changeReexamine", "三级待受理", "", "");
+
+
+    private final String name;
+
+    private final String code;
+
+    private final String pass;
+
+    private final String reject;
+
+    private final String rollBack;
+
+
+
+    public static WorkFlowStatusEnum getMessage(String code){
+        for (WorkFlowStatusEnum constants : values()) {
+            if (constants.getCode().equals(code)) {
+                return constants;
+            }
+        }
+        return null;
+    }
+}

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-api/src/main/java/com/yeejoin/amos/boot/module/jg/api/service/IJgEquipTransferService.java

@@ -33,7 +33,7 @@ public interface IJgEquipTransferService  extends IService<JgEquipTransfer> {
      * @param sequenceNbr 主键
      * @return 设备移交详情
      */
-    Map<String, Map<String, Object>> queryBySequenceNbr(Long sequenceNbr);
+    Map<String, Object> queryBySequenceNbr(Long sequenceNbr);
 
     /**
      * 保存设备移交接口

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-api/src/main/java/com/yeejoin/amos/boot/module/jg/flc/api/fegin/WorkFlowFeignService.java

@@ -2,15 +2,10 @@ package com.yeejoin.amos.boot.module.jg.flc.api.fegin;
 
 
 import com.alibaba.fastjson.JSONObject;
-import com.yeejoin.amos.boot.biz.common.feign.FeignConfiguration;
 import com.yeejoin.amos.boot.biz.common.feign.MultipartSupportConfig;
-import com.yeejoin.amos.component.feign.config.InnerInvokException;
 import com.yeejoin.amos.component.feign.model.FeignClientResult;
-import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
-import com.yeejoin.amos.feign.privilege.model.VerifyCodeAuthModel;
 import org.springframework.cloud.openfeign.FeignClient;
 import org.springframework.web.bind.annotation.*;
-import org.typroject.tyboot.core.restful.utils.ResponseModel;
 
 import java.util.Map;
 

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

@@ -22,9 +22,49 @@
             jet.execute_sequence AS executeSequence,
             jet.instance_status AS instanceStatus,
             jet.accept_date AS acceptDate,
-            jet.task_name AS taskName
+            jet.task_name AS taskName,
+            ri.equ_list AS equList,
+            ri.equ_category AS equCategory,
+            ri.equ_define AS equDefine,
+            ri.product_name AS productName,
+            ri.brand_name AS brandName,
+            ri.equ_type AS equType,
+            ri.equ_price AS equPrice,
+            ri.product_photo AS productPhoto,
+            di.design_unit_credit_code AS designUnitCreditCode,
+            di.design_unit_name AS designUnitName,
+            di.design_license_num AS designLicenseNum,
+            di.design_use_date AS designUseDate,
+            di.design_date AS designDate,
+            di.drawing_do AS drawingDo,
+            di.appraisal_unit AS appraisalUnit,
+            di.appraisal_date AS appraisalDate,
+            di.design_doc AS designDoc,
+            di.design_standard AS designStandard,
+            fi.produce_unit_credit_code AS produceUnitCreditCode,
+            fi.produce_unit_name AS produceUnitName,
+            fi.produce_license_num AS produceLicenseNum,
+            fi.factory_num AS factoryNum,
+            fi.produce_date AS produceDate,
+            fi.imported AS imported,
+            fi.produce_country AS produceCountry,
+            fi.factory_standard AS factoryStandard,
+            fi.product_quality_yield_prove AS productQualityYieldProve,
+            fi.ins_use_maintain_explain AS insUseMaintainExplain,
+            ui.safety_manager AS safetyManager,
+            ui.phone AS safetyManagerPhone,
+            CONCAT(ui.PROVINCE_NAME,'', ui.CITY_NAME, ' ', ui.COUNTY_NAME, ' ', ui.ADDRESS, ' ', ui.street_name) AS concatenatedAddress,
+            ui.USE_INNER_CODE AS useInnerCode,
+            oi.SUPERVISORY_CODE AS supervisoryCode
         FROM
             tzs_jg_equip_transfer jet
+            LEFT JOIN tzs_jg_equip_transfer_eq ete ON ete.equip_transfer_id = jet.sequence_nbr
+            LEFT JOIN idx_biz_jg_register_info ri ON ri.record = ete.equ_id
+            LEFT JOIN idx_biz_jg_design_info di ON di.record = ete.equ_id
+            LEFT JOIN idx_biz_jg_factory_info fi ON fi.record = ete.equ_id
+            LEFT JOIN idx_biz_jg_inspection_detection_info idi ON idi.record = ete.equ_id
+            LEFT JOIN idx_biz_jg_use_info ui ON ui.record = ete.equ_id
+            LEFT JOIN idx_biz_jg_other_info oi ON oi.record = ete.equ_id
         <where>
             jet.is_delete = false
             <if test="param != null ">
@@ -67,7 +107,7 @@
             jet.execute_sequence AS executeSequence,
             jet.instance_status AS instanceStatus,
             jet.accept_date AS acceptDate,
-            jet.task_name AS taskName
+            jet.task_name AS taskName,
             ri.equ_list AS equList,
             ri.equ_category AS equCategory,
             ri.equ_define AS equDefine,
@@ -104,12 +144,12 @@
             ui.ADDRESS AS useUnitAddress
         FROM
             tzs_jg_equip_transfer jet
-                LEFT JOIN tzs_jg_equip_transfer_eq ete ON re.equip_transfer_id = jet.sequence_nbr
-                LEFT JOIN idx_biz_jg_register_info ri ON ri.record = ete.equ_id
-                LEFT JOIN idx_biz_jg_design_info di ON di.record = ete.equ_id
-                LEFT JOIN idx_biz_jg_factory_info fi ON fi.record = ete.equ_id
-                LEFT JOIN idx_biz_jg_inspection_detection_info idi ON idi.record = ete.equ_id
-                LEFT JOIN idx_biz_jg_use_info ui ON ui.record = ete.equ_id
+            LEFT JOIN tzs_jg_equip_transfer_eq ete ON ete.equip_transfer_id = jet.sequence_nbr
+            LEFT JOIN idx_biz_jg_register_info ri ON ri.record = ete.equ_id
+            LEFT JOIN idx_biz_jg_design_info di ON di.record = ete.equ_id
+            LEFT JOIN idx_biz_jg_factory_info fi ON fi.record = ete.equ_id
+            LEFT JOIN idx_biz_jg_inspection_detection_info idi ON idi.record = ete.equ_id
+            LEFT JOIN idx_biz_jg_use_info ui ON ui.record = ete.equ_id
         WHERE
             jet.sequence_nbr = #{sequenceNbr}
         LIMIT 1

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

@@ -11,6 +11,7 @@
             isn.use_unit_name AS useUnitName,
             isn.receive_org_name AS receiveOrgName,
             isn.region_no AS regionNo,
+            isn.install_start_date AS installStartDate,
             isn.address AS address,
             isn.notice_status AS noticeStatus,
             isn.install_unit_name AS installUnitName,
@@ -21,6 +22,9 @@
             isn.promoter,
             isn.next_execute_ids AS nextExecuteIds,
             isn.instance_status AS instanceStatus,
+            isn.equ_address AS equAddress,
+            isn.handle_date AS handleDate,
+            isn.equ_list AS equList,
             isn.notice_report_url AS noticeReportUrl
         FROM
             tzs_jg_installation_notice isn
@@ -30,14 +34,14 @@
                 <if test="param.applyNo != null and param.applyNo != ''">
                     AND isn.apply_no LIKE CONCAT('%', #{param.applyNo}, '%')
                 </if>
-                <if test="param.receiveOrgName != null and param.receiveOrgName != ''">
-                    AND isn.receive_org_name LIKE CONCAT('%', #{param.receiveOrgName}, '%')
+                <if test="param.receiveOrgCreditCode != null and param.receiveOrgCreditCode != ''">
+                    AND isn.receive_org_credit_code = #{param.receiveOrgCreditCode}
                 </if>
                 <if test="param.useUnitName != null and param.useUnitName != ''">
-                    AND isn.use_unit_name LIKE CONCAT('%', #{param.useUnitName}, '%')
+                    AND isn.use_unit_credit_code = #{param.useUnitName}
                 </if>
                 <if test="param.installUnitName != null and param.installUnitName != ''">
-                    AND isn.install_unit_name LIKE CONCAT('%', #{param.installUnitName}, '%')
+                    AND isn.install_unit_credit_code = #{param.installUnitName}
                 </if>
                 <if test="param.noticeStatus != null and param.noticeStatus != ''">
                     AND isn.notice_status = #{param.noticeStatus}
@@ -45,13 +49,14 @@
             </if>
             <if test="type == 'supervision'">
                 AND isn.receive_org_credit_code = #{orgCode}
+                AND isn.instance_id  is not null
             </if>
             <if test="type == 'enterprise'">
                 AND isn.install_unit_credit_code = #{orgCode}
             </if>
         </where>
         ORDER BY
-        isn.rec_date DESC
+        isn.create_date DESC
     </select>
 
     <select id="queryEquipInformation" resultType="java.util.Map">
@@ -62,6 +67,7 @@
             isn.province_name AS provinceName,
             isn.city_name AS cityName,
             isn.county_name AS countyName,
+            isn.street_name AS streetName,
             isn.address AS address,
             isn.install_start_date AS installStartDate,
             isn.install_license_no AS installLicenseNo,
@@ -98,12 +104,9 @@
             fi.factory_standard AS factoryStandard,
             fi.product_quality_yield_prove AS productQualityYieldProve,
             fi.ins_use_maintain_explain AS insUseMaintainExplain,
-            ui.safety_manager AS safetyManager,
-            ui.phone AS safetyManagerPhone,
-            ui.PROVINCE_NAME AS useUnitProvinceName,
-            ui.CITY_NAME AS useUnitCityName,
-            ui.COUNTY_NAME AS useUnitCountyName,
-            ui.ADDRESS AS useUnitAddress
+            ei.legal_person AS safetyManager,
+            ei.legal_phone AS safetyManagerPhone,
+            ei.address AS address
         FROM
             tzs_jg_installation_notice isn
                 LEFT JOIN tzs_jg_installation_notice_eq re ON re.equip_transfer_id = isn.sequence_nbr
@@ -112,6 +115,7 @@
                 LEFT JOIN idx_biz_jg_factory_info fi ON fi.record = re.equ_id
                 LEFT JOIN idx_biz_jg_inspection_detection_info idi ON idi.record = re.equ_id
                 LEFT JOIN idx_biz_jg_use_info ui ON ui.record = re.equ_id
+                LEFT JOIN tz_base_enterprise_info ei ON ei.use_code = isn.use_unit_credit_code
         WHERE
             isn.sequence_nbr = #{sequenceNbr}
         LIMIT 1

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

@@ -8,94 +8,102 @@
 
     <select id="queryForPage" resultType="com.yeejoin.amos.boot.module.jg.api.entity.JgMaintainNotice">
         select
-        tjmn.sequence_nbr AS sequenceNbr,
-        tjmn.apply_no AS applyNo,
-        tjmn.notice_date AS noticeDate,
-        tjmn.use_unit_name AS useUnitName,
-        tjmn.receive_org_name AS receiveOrgName,
-        tjmn.address AS address,
-        tjmn.notice_status AS noticeStatus,
-        tjmn.install_unit_name AS installUnitName,
-        tjmn.province,
-        tjmn.city,
-        tjmn.county,
-        tjmn.factory_use_site_street,
-        tjmn.street_name,
-        tjmn.street,
-        tjmn.maintain_type,
-        tjmn.plan_date,
-        tjmn.notice_report_url,
-        tjmn.province_name AS provinceName,
-        tjmn.city_name AS cityName,
-        tjmn.county_name AS countyName,
-        tjmn.promoter,
-        tjmn.instance_id AS instanceId
+        isn.sequence_nbr AS sequenceNbr,
+        isn.apply_no AS applyNo,
+        isn.notice_date AS noticeDate,
+        isn.use_unit_name AS useUnitName,
+        isn.receive_org_name AS receiveOrgName,
+        isn.address AS address,
+        isn.notice_status AS noticeStatus,
+        isn.install_unit_name AS installUnitName,
+        isn.province,
+        isn.city,
+        isn.county,
+        isn.factory_use_site_street,
+        isn.street_name,
+        isn.street,
+        isn.maintain_type,
+        isn.plan_date,
+        isn.notice_report_url,
+        isn.province_name AS provinceName,
+        isn.city_name AS cityName,
+        isn.county_name AS countyName,
+        isn.promoter,
+        isn.equ_category AS equCategory,
+        isn.equ_list_code AS equListCode,
+        isn.instance_id AS instanceId,
+        isn.accept_date AS acceptDate
         FROM
-        tzs_jg_maintain_notice tjmn
+        tzs_jg_maintain_notice isn
         <where>
-            tjmn.is_delete = 0
+            isn.is_delete = 0
             <if test="param != null ">
                 <if test="param.applyNo != null and param.applyNo != ''">
-                    AND tjmn.apply_no LIKE CONCAT('%', #{param.applyNo}, '%')
+                    AND isn.apply_no LIKE CONCAT('%', #{param.applyNo}, '%')
                 </if>
-                <if test="param.receiveOrgName != null and param.receiveOrgName != ''">
-                    AND tjmn.receive_org_name LIKE CONCAT('%', #{param.receiveOrgName}, '%')
+                <if test="param.receiveOrgCode != null and param.receiveOrgCode != ''">
+                    AND isn.receive_org_code = #{param.receiveOrgCode}
                 </if>
                 <if test="param.useUnitName != null and param.useUnitName != ''">
-                    AND tjmn.use_unit_name LIKE CONCAT('%', #{param.useUnitName}, '%')
+                    AND isn.use_unit_name LIKE CONCAT('%', #{param.useUnitName}, '%')
                 </if>
                 <if test="param.installUnitName != null and param.installUnitName != ''">
-                    AND tjmn.install_unit_name LIKE CONCAT('%', #{param.installUnitName}, '%')
+                    AND isn.install_unit_name LIKE CONCAT('%', #{param.installUnitName}, '%')
                 </if>
                 <if test="param.noticeStatus != null and param.noticeStatus != ''">
-                    AND tjmn.notice_status = #{param.noticeStatus}
+                    AND isn.notice_status = #{param.noticeStatus}
                 </if>
                 <if test="param.maintainType != null and param.maintainType != ''">
-                    AND tjmn.maintain_type = #{param.maintainType}
+                    AND isn.maintain_type = #{param.maintainType}
                 </if>
             </if>
             <if test="type == 'supervision'">
-                AND (tjmn.notice_status in ('6612', '6613', '6614') )
-                AND tjmn.receive_org_code = #{orgCode}
+                AND (isn.notice_status in ('6612', '6614', '6616') )
+                AND isn.receive_org_code = #{orgCode}
             </if>
             <if test="type == 'enterprise'">
-                AND tjmn.install_unit_credit_code = #{orgCode}
+                AND isn.install_unit_credit_code = #{orgCode}
             </if>
         </where>
         ORDER BY
-        tjmn.notice_date DESC
+        isn.apply_no DESC
     </select>
 
     <select id="queryEquipInformation" resultType="java.util.Map">
         select
-            tjmn.sequence_nbr AS sequenceNbr,
-            tjmn.apply_no AS applyNo,
-            tjmn.notice_date AS noticeDate,
-            tjmn.use_unit_name AS useUnitName,
-            tjmn.receive_org_name AS receiveOrgName,
-            tjmn.address AS address,
-            tjmn.notice_status AS noticeStatus,
-            tjmn.install_unit_name AS installUnitName,
-            tjmn.province,
-            tjmn.city,
-            tjmn.county,
-            tjmn.factory_use_site_street AS factoryUseSiteStreet,
-            tjmn.street_name AS streetName,
-            tjmn.street,
-            tjmn.maintain_type AS maintainType,
-            tjmn.plan_date AS planDate,
-            tjmn.notice_report_url AS noticeReportUrl,
-            tjmn.province_name AS provinceName,
-            tjmn.city_name AS cityName,
-            tjmn.county_name AS countyName,
-            tjmn.instance_id AS instanceId,
-            tjmn.promoter,
+            isn.sequence_nbr AS sequenceNbr,
+            isn.apply_no AS applyNo,
+            isn.notice_date AS noticeDate,
+            isn.use_unit_name AS useUnitName,
+            isn.receive_org_name AS receiveOrgName,
+            isn.address AS address,
+            isn.notice_status AS noticeStatus,
+            isn.install_unit_name AS installUnitName,
+            isn.province,
+            isn.city,
+            isn.county,
+            isn.factory_use_site_street AS factoryUseSiteStreet,
+            isn.street_name AS streetName,
+            isn.street,
+            isn.maintain_type AS maintainType,
+            isn.notice_report_url AS noticeReportUrl,
+            isn.province_name AS provinceName,
+            isn.city_name AS cityName,
+            isn.county_name AS countyName,
+            isn.instance_id AS instanceId,
+            isn.promoter,
+            isn.equ_category AS equCategory,
+            isn.equ_list_code AS equListCode,
+            isn.plan_date AS installStartDate,
+            isn.construction_manager AS installLeaderName,
+            isn.construction_manager_phone AS installLeaderPhone,
             ri.equ_list AS equList,
             ri.equ_category AS equCategory,
             ri.EQU_DEFINE AS equDefine,
             ri.product_name AS productName,
             ri.brand_name AS brandName,
             ri.equ_type AS equType,
+            ri.equ_code AS equRegisterCode,
             ri.equ_price AS equPrice,
             ri.product_photo AS productPhoto,
             di.design_unit_credit_code AS designUnitCreditCode,
@@ -111,7 +119,8 @@
             fi.produce_unit_credit_code AS produceUnitCreditCode,
             fi.produce_unit_name AS produceUnitName,
             fi.produce_license_num AS produceLicenseNum,
-            fi.factory_num AS factoryNum,
+            fi.FACTORY_NUM AS produceCode,
+            fi.FACTORY_NUM AS factoryNum,
             fi.produce_date AS produceDate,
             fi.imported AS imported,
             fi.produce_country AS produceCountry,
@@ -119,21 +128,22 @@
             fi.product_quality_yield_prove AS productQualityYieldProve,
             fi.ins_use_maintain_explain AS insUseMaintainExplain,
             ui.safety_manager AS safetyManager,
-            ui.phone AS safetyManagerPhone,
-            ui.PROVINCE_NAME AS useUnitProvinceName,
+            ei.legal_person AS safetyManager,
+            ei.legal_phone AS safetyManagerPhone,
             ui.CITY_NAME AS useUnitCityName,
             ui.COUNTY_NAME AS useUnitCountyName,
-            ui.ADDRESS AS useUnitAddress
+            ei.ADDRESS AS useUnitAddress
         FROM
-            tzs_jg_maintain_notice tjmn
-                LEFT JOIN tzs_jg_maintain_notice_eq re ON re.equip_transfer_id = tjmn.sequence_nbr
+            tzs_jg_maintain_notice isn
+                LEFT JOIN tzs_jg_maintain_notice_eq re ON re.equip_transfer_id = isn.sequence_nbr
                 LEFT JOIN idx_biz_jg_register_info ri ON ri.record = re.equ_id
                 LEFT JOIN idx_biz_jg_design_info di ON di.record = re.equ_id
                 LEFT JOIN idx_biz_jg_factory_info fi ON fi.record = re.equ_id
                 LEFT JOIN idx_biz_jg_inspection_detection_info idi ON idi.record = re.equ_id
                 LEFT JOIN idx_biz_jg_use_info ui ON ui.record = re.equ_id
+                LEFT JOIN tz_base_enterprise_info ei ON ei.use_code = isn.use_unit_credit_code
         WHERE
-            tjmn.sequence_nbr = #{sequenceNbr}
+            isn.sequence_nbr = #{sequenceNbr}
             LIMIT 1
     </select>
 </mapper>

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

@@ -26,7 +26,11 @@
         isn.receive_org_name AS receiveOrgName,
         isn.next_execute_ids as nextExecuteIds,
         isn.promoter,
-        isn.notice_report_url
+        isn.notice_report_url,
+        isn.accept_date,
+        isn.equ_list_code,
+        isn.equ_category,
+        isn.create_user_id
         FROM
         tzs_jg_reform_notice isn
         <where>
@@ -38,6 +42,9 @@
                 <if test="param.receiveOrgName != null and param.receiveOrgName != ''">
                     AND isn.receive_org_name LIKE CONCAT('%', #{param.receiveOrgName}, '%')
                 </if>
+                <if test="param.receiveOrgCode != null and param.receiveOrgCode != ''">
+                    AND isn.receive_org_code = #{param.receiveOrgCode}
+                </if>
                 <if test="param.useUnitName != null and param.useUnitName != ''">
                     AND isn.use_unit_name LIKE CONCAT('%', #{param.useUnitName}, '%')
                 </if>
@@ -49,16 +56,15 @@
                 </if>
             </if>
             <if test="type == 'supervision'">
-                AND isn.notice_status in ('6612', '6613', '6614')
+                AND (isn.notice_status in ('6612', '6613', '6614', '6616')  )
                 AND isn.receive_org_code = #{orgCode}
-                <!--                AND (isn.notice_status in ('6612', '6613', '6614') or isn.status in('6614') )-->
             </if>
             <if test="type == 'enterprise'">
                 AND isn.install_unit_credit_code = #{orgCode}
             </if>
         </where>
         ORDER BY
-        isn.notice_date DESC
+        isn.apply_no DESC
     </select>
 
     <select id="queryEquipInformation" resultType="java.util.Map">
@@ -82,10 +88,16 @@
         isn.next_execute_ids as nextExecuteIds,
         isn.promoter,
         isn.notice_status AS noticeStatus,
+<!--        isn.install_start_date AS installLicenseExpirationDate,-->
+<!--        isn.install_license_no AS installLicenseNo,-->
+        isn.plan_date AS installStartDate,
+        isn.construction_manager AS installLeaderName,
+        isn.construction_manager_phone AS installLeaderPhone,
         ri.equ_code AS equRegisterCode,
         ri.equ_list AS equList,
         ri.equ_category AS equCategory,
         ri.EQU_DEFINE AS equDefine,
+        fi.FACTORY_NUM AS produceCode,
         ri.product_name AS productName,
         ri.brand_name AS brandName,
         ri.equ_type AS equType,
@@ -111,12 +123,9 @@
         fi.factory_standard AS factoryStandard,
         fi.product_quality_yield_prove AS productQualityYieldProve,
         fi.ins_use_maintain_explain AS insUseMaintainExplain,
-        ui.safety_manager AS safetyManager,
-        ui.phone AS safetyManagerPhone,
-        ui.PROVINCE_NAME AS useUnitProvinceName,
-        ui.CITY_NAME AS useUnitCityName,
-        ui.COUNTY_NAME AS useUnitCountyName,
-        ui.ADDRESS AS useUnitAddress
+        ei.legal_person AS safetyManager,
+        ei.legal_phone AS safetyManagerPhone,
+        ei.ADDRESS AS useUnitAddress
         FROM
         tzs_jg_reform_notice isn
         LEFT JOIN tzs_jg_reform_notice_eq re ON re.equip_transfer_id = isn.sequence_nbr
@@ -125,6 +134,7 @@
         LEFT JOIN idx_biz_jg_factory_info fi ON fi.record = re.equ_id
         LEFT JOIN idx_biz_jg_inspection_detection_info idi ON idi.record = re.equ_id
         LEFT JOIN idx_biz_jg_use_info ui ON ui.record = re.equ_id
+        LEFT JOIN tz_base_enterprise_info ei ON ei.use_code = isn.use_unit_credit_code
         WHERE
         isn.sequence_nbr = #{sequenceNbr}
         LIMIT 1

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

@@ -55,14 +55,18 @@
 <!--            <if test="dto.useUnitName != null and dto.useUnitName != ''">-->
 <!--                and  use.USE_UNIT_NAME like concat('%',#{dto.useUnitName},'%')-->
 <!--            </if>-->
+<!--             -->
             <if test="roleIds != null and dto.type == 'supervision'">
                 <foreach collection='roleIds' item='role' open='and (' close=')' separator='or'>
-                    ur.audit_status like concat('%',#{role},'%')
+                    ur.instance_status like concat('%',#{role},'%')
                 </foreach>
             </if>
             <if test="dto.type == 'supervision'">
                 AND ur.receive_org_code = #{orgCode}
             </if>
+            <if test="dto.type == 'enterprise' ">
+                and ur.use_unit_code = #{orgCode}
+            </if>
 <!--            <if test="dto.type == 'enterprise'">-->
 <!--                AND use.USE_UNIT_CREDIT_CODE = #{orgCode}-->
 <!--            </if>-->

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/controller/CommonController.java

 package com.yeejoin.amos.boot.module.jg.biz.controller;
 
 
-import com.yeejoin.amos.boot.biz.common.bo.ReginParams;
 import com.yeejoin.amos.boot.biz.common.controller.BaseController;
 import com.yeejoin.amos.boot.module.jg.biz.service.ICommonService;
 import com.yeejoin.amos.boot.module.ymt.api.entity.EquipmentCategory;
 import com.yeejoin.amos.boot.module.ymt.api.enums.FlowStatusEnum;
-import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -23,7 +21,7 @@ import java.util.Arrays;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
-import java.util.function.Function;
+import java.util.Objects;
 import java.util.stream.Collectors;
 
 /**
@@ -103,7 +101,15 @@ public class CommonController extends BaseController {
 	public ResponseModel<Map<String,Object>> getUserInfo(@RequestParam(value = "sequenceNbr") String sequenceNbr) {
 		return ResponseHelper.buildResponse(commonService.getUserInfo(sequenceNbr));
 	}
-
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @GetMapping(value = "/getUserInfoSplit")
+    @ApiOperation(httpMethod = "GET", value = "查询安全管理员的基本信息", notes = "查询安全管理员的基本信息")
+    public ResponseModel<Map<String, Object>> getUserInfoSplit(@RequestParam(value = "sequenceNbr") String sequenceNbr) {
+        if (sequenceNbr.contains("_")) {
+            sequenceNbr = sequenceNbr.split("_")[0];
+        }
+        return ResponseHelper.buildResponse(commonService.getUserInfo(sequenceNbr));
+    }
 	/**
 	 * 查询企业的基本信息
 	 *
@@ -133,10 +139,13 @@ public class CommonController extends BaseController {
 	@ApiOperation (httpMethod = "GET", value = "流程状态枚举列表", notes = "流程状态枚举列表")
 	@GetMapping (value = "/flow-status/list")
 	public ResponseModel<List<Map<String, Object>>> selectForFlowStatusList() {
-		return ResponseHelper.buildResponse(Arrays.stream(FlowStatusEnum.values()).map(this::mapPointTypeToMap).collect(Collectors.toList()));
+		return ResponseHelper.buildResponse(Arrays.stream(FlowStatusEnum.values()).map(this::mapPointTypeToMap).filter(Objects::nonNull).collect(Collectors.toList()));
 	}
 
 	private Map<String, Object> mapPointTypeToMap(FlowStatusEnum e) {
+		if (FlowStatusEnum.TO_SUBMITTED.getCode() ==  e.getCode()) {
+			return null;
+		}
 		Map<String, Object> record = new HashMap<>();
 		record.put("key", e.getCode());
 		record.put("label", e.getName());

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/controller/JgChangeRegistrationReformController.java

@@ -55,7 +55,7 @@ public class JgChangeRegistrationReformController extends BaseController {
 	@PostMapping(value = "/flowExecute")
 	@ApiOperation(httpMethod = "POST", value = "执行流程", notes = "执行流程")
 	public ResponseModel<Object> flowExecute(@RequestBody JSONObject map) {
-		jgChangeRegistrationReformServiceImpl.flowExecute(Long.valueOf(String.valueOf(map.get("sequenceNbr"))),String.valueOf(map.get("instanceId")), String.valueOf(map.get("operate")), String.valueOf(map.get("comment")), true);
+		jgChangeRegistrationReformServiceImpl.flowExecute(Long.valueOf(String.valueOf(map.get("sequenceNbr"))),String.valueOf(map.get("instanceId")), String.valueOf(map.get("operate")), String.valueOf(map.get("comment")));
 		return ResponseHelper.buildResponse("ok");
 	}
 	@TycloudOperation(ApiLevel = UserType.AGENCY)
@@ -114,8 +114,8 @@ public class JgChangeRegistrationReformController extends BaseController {
 	@TycloudOperation(ApiLevel = UserType.AGENCY)
 	@ApiOperation(httpMethod = "GET", value = "获取详情", notes = "获取详情")
 	@GetMapping(value = "/getDetail")
-	public ResponseModel<Map<String, Object>> getDetail(@RequestParam("id") String id) {
-		return ResponseHelper.buildResponse(jgChangeRegistrationReformServiceImpl.getDetail(id));
+	public ResponseModel<Map<String, Object>> getDetail(@RequestParam("currentDocumentId") String currentDocumentId,@RequestParam("equipId") String equipId) {
+		return ResponseHelper.buildResponse(jgChangeRegistrationReformServiceImpl.getDetail(currentDocumentId,equipId));
 	}
 
 	@TycloudOperation(ApiLevel = UserType.AGENCY)

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/controller/JgEquipTransferByWorkFlowController.java

@@ -31,8 +31,6 @@ public class JgEquipTransferByWorkFlowController extends BaseController {
     @Autowired
     JgEquipTransferServiceImpl jgEquipTransferServiceImpl;
 
-    private static final String TABLE_PAGE_ID = "1734141426742095873";
-
     /**
      * 受理
      *
@@ -41,10 +39,7 @@ public class JgEquipTransferByWorkFlowController extends BaseController {
     @TycloudOperation(ApiLevel = UserType.AGENCY)
     @PostMapping(value = "/accept")
     @ApiOperation(httpMethod = "POST", value = "设备移交受理", notes = "设备移交受理")
-    public ResponseModel<JgEquipTransferDto> accept(@RequestBody Map<String, Object> model, String op) {
-        LinkedHashMap model1 = (LinkedHashMap)model.get("model");
-        LinkedHashMap equipTransferInfo = (LinkedHashMap)model1.get(TABLE_PAGE_ID);
-        JgEquipTransferDto jgEquipTransferDto = JSON.parseObject(JSON.toJSONString(equipTransferInfo), JgEquipTransferDto.class);
+    public ResponseModel<JgEquipTransferDto> accept(@RequestBody JgEquipTransferDto jgEquipTransferDto, String op) {
         jgEquipTransferServiceImpl.accept(jgEquipTransferDto,op);
         return ResponseHelper.buildResponse(null);
     }
@@ -57,13 +52,9 @@ public class JgEquipTransferByWorkFlowController extends BaseController {
     @TycloudOperation(ApiLevel = UserType.AGENCY)
     @PostMapping(value = "/cancel")
     @ApiOperation(httpMethod = "POST", value = "设备移交撤销", notes = "设备移交撤销")
-    public ResponseModel<JgEquipTransferDto> cancel(@RequestBody Map<String, Object> model) {
-        JgEquipTransferDto equipTransferInfo = BeanUtil.mapToBean(((LinkedHashMap) model.get(TABLE_PAGE_ID)), JgEquipTransferDto.class, true);
-        if (Objects.isNull(equipTransferInfo)) {
-            throw new IllegalArgumentException("参数equipTransferInfo不能为空");
-        }
-        jgEquipTransferServiceImpl.cancel(equipTransferInfo);
-        return ResponseHelper.buildResponse(equipTransferInfo);
+    public ResponseModel<JgEquipTransferDto> cancel(@RequestBody JgEquipTransferDto jgEquipTransferDto) {
+        jgEquipTransferServiceImpl.cancel(jgEquipTransferDto);
+        return ResponseHelper.buildResponse(null);
     }
 }
 

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/controller/JgEquipTransferController.java

 package com.yeejoin.amos.boot.module.jg.biz.controller;
 
-import cn.hutool.core.bean.BeanUtil;
+import com.yeejoin.amos.boot.module.jg.api.common.BaseException;
 import com.yeejoin.amos.boot.module.jg.api.entity.JgEquipTransfer;
+import com.yeejoin.amos.component.feign.utils.FeignUtil;
+import com.yeejoin.amos.feign.privilege.Privilege;
+import com.yeejoin.amos.feign.privilege.model.CompanyModel;
 import io.swagger.annotations.ApiParam;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.web.bind.annotation.RequestMapping;
@@ -11,6 +14,7 @@ import org.springframework.web.bind.annotation.RestController;
 import com.yeejoin.amos.boot.biz.common.controller.BaseController;
 import java.util.*;
 import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgEquipTransferServiceImpl;
+import org.typroject.tyboot.core.foundation.context.RequestContext;
 import org.typroject.tyboot.core.restful.utils.ResponseHelper;
 import org.typroject.tyboot.core.restful.utils.ResponseModel;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -31,8 +35,6 @@ import org.typroject.tyboot.core.foundation.enumeration.UserType;
 @RequestMapping(value = "/jg-equip-transfer")
 public class JgEquipTransferController extends BaseController {
 
-    private static final String TABLE_PAGE_ID = "1734141426742095873";
-
     @Autowired
     JgEquipTransferServiceImpl jgEquipTransferServiceImpl;
 
@@ -44,19 +46,17 @@ public class JgEquipTransferController extends BaseController {
     @TycloudOperation(ApiLevel = UserType.AGENCY)
     @PostMapping(value = "/save")
     @ApiOperation(httpMethod = "POST", value = "新增设备移交", notes = "新增设备移交")
-    public ResponseModel<Object> save(@RequestParam String submitType, @RequestBody Map<String, JgEquipTransferDto> modelMap) {
-        jgEquipTransferServiceImpl.saveOrUpdateModel(submitType, modelMap.get(TABLE_PAGE_ID), getSelectedOrgInfo());
+    public ResponseModel<Object> save(@RequestParam("submitType") String submitType, @RequestBody JgEquipTransferDto model) {
+        jgEquipTransferServiceImpl.saveOrUpdateModel(submitType, model, getSelectedOrgInfo());
         return ResponseHelper.buildResponse("ok");
     }
 
     @TycloudOperation(ApiLevel = UserType.AGENCY)
     @PutMapping(value = "/update")
     @ApiOperation(httpMethod = "PUT", value = "根据sequenceNbr更新设备移交", notes = "根据sequenceNbr更新设备移交")
-    public ResponseModel<JgEquipTransferDto> updateBySequenceNbr(@RequestParam String submitType, @RequestBody Map<String, Object> modelMap, @RequestParam(value = "op", required = false) String op) {
-        JgEquipTransferDto equipTransferDto = BeanUtil.mapToBean(((LinkedHashMap) modelMap.get(TABLE_PAGE_ID)), JgEquipTransferDto.class, true);
-        if (Objects.isNull(equipTransferDto)) {
-            throw new IllegalArgumentException("参数equipTransferDto不能为空");
-        }
+    public ResponseModel<JgEquipTransferDto> updateBySequenceNbr(@RequestParam("submitType") String submitType,
+                                                                 @RequestBody JgEquipTransferDto equipTransferDto,
+                                                                 @RequestParam(value = "op", required = false) String op) {
         return ResponseHelper.buildResponse(jgEquipTransferServiceImpl.updateEquipTransfer(submitType, equipTransferDto, op));
     }
 
@@ -68,7 +68,7 @@ public class JgEquipTransferController extends BaseController {
     @TycloudOperation(ApiLevel = UserType.AGENCY)
     @DeleteMapping(value = "/delete")
     @ApiOperation(httpMethod = "DELETE", value = "根据sequenceNbr删除设备移交", notes = "根据sequenceNbr删除设备移交")
-    public ResponseModel<Boolean> deleteBySequenceNbr(@RequestParam(value = "sequenceNbr") Long[] sequenceNbr) {
+    public ResponseModel<Boolean> deleteBySequenceNbr(@RequestParam(value = "sequenceNbr") Long sequenceNbr) {
         return ResponseHelper.buildResponse(jgEquipTransferServiceImpl.removeById(sequenceNbr));
     }
 
@@ -81,7 +81,7 @@ public class JgEquipTransferController extends BaseController {
     @TycloudOperation(ApiLevel = UserType.AGENCY)
     @DeleteMapping(value = "/deleteBatch")
     @ApiOperation(httpMethod = "DELETE", value = "批量删除设备移交", notes = "批量删除设备移交")
-    public ResponseModel<Object> deleteBySequenceNbr(@RequestParam String ids) {
+    public ResponseModel<Object> deleteBySequenceNbr(@RequestParam("ids") String ids) {
         if (StringUtils.isEmpty(ids)) {
             throw new RuntimeException("请选择需要删除的行！");
         }
@@ -97,7 +97,7 @@ public class JgEquipTransferController extends BaseController {
     @TycloudOperation(ApiLevel = UserType.AGENCY)
     @GetMapping(value = "/details")
     @ApiOperation(httpMethod = "GET", value = "根据sequenceNbr查询单个设备移交", notes = "根据sequenceNbr查询单个设备移交")
-    public ResponseModel<Map<String, Map<String, Object>>> selectOne(@RequestParam Long sequenceNbr) {
+    public ResponseModel<Map<String, Object>> selectOne(@RequestParam("sequenceNbr") Long sequenceNbr) {
         return ResponseHelper.buildResponse(jgEquipTransferServiceImpl.queryBySequenceNbr(sequenceNbr));
     }
 
@@ -113,10 +113,35 @@ public class JgEquipTransferController extends BaseController {
     @ApiOperation(httpMethod = "GET", value = "设备移交分页查询", notes = "设备移交分页查询")
     public ResponseModel<Page<JgEquipTransferDto>> queryForPage(@RequestParam(value = "current") int current,
                                                                 @RequestParam(value = "size") int size,
-                                                                @ApiParam(value = "类型：enterprise-企业端、supervision-监管端", required = true) @RequestParam(value = "type", defaultValue = "enterprise") String type,
+                                                                @ApiParam(value = "类型：useUnit-使用单位、installUnit-施工单位", required = true) @RequestParam(value = "type", defaultValue = "useUnit") String type,
                                                                 @RequestBody(required = false) JgEquipTransferDto dto) {
         Page<JgEquipTransfer> page = new Page<>(current, size);
         return ResponseHelper.buildResponse(jgEquipTransferServiceImpl.queryForJgEquipTransferPage(page, dto, type, getSelectedOrgInfo()));
     }
+
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @GetMapping(value = "/getCodeAndName")
+    @ApiOperation(httpMethod = "GET", value = "获取当前登录用户所在公司code和公司名称", notes = "获取当前登录用户所在公司code和公司名称")
+    public ResponseModel<Map<String, Object>> getCodeAndName() {
+
+        List<CompanyModel> companyModels = FeignUtil.remoteCall(() -> Privilege.companyClient.queryListByChild(RequestContext.getExeUserId()));
+        if (companyModels.isEmpty()) {
+            throw new BaseException("未指定人员归属单位信息");
+        }
+        String companyType = companyModels.get(0).getCompanyType();
+        String companyCode = companyModels.get(0).getCompanyCode();
+        String companyName = companyModels.get(0).getCompanyName();
+        Map<String, Object> map = new HashMap<>();
+        if("个人主体".equals(companyType)){
+            map.put("useUnitName", companyName.split("_")[1]);
+            map.put("useUnitCreditCode", companyCode.split("_")[1]);
+            map.put("companyType", "person");
+        } else {
+            map.put("useUnitName", companyName);
+            map.put("useUnitCreditCode", companyCode);
+            map.put("companyType", "company");
+        }
+        return ResponseHelper.buildResponse(map);
+    }
 }
 

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/controller/JgInstallationByWorkFlowController.java

@@ -80,8 +80,10 @@ public class JgInstallationByWorkFlowController {
     public ResponseModel<JgInstallationNoticeDto> accept(@RequestBody Map<String, Object> model, String op) {
         // TODO 受理安装告知流程
         LinkedHashMap model1 = (LinkedHashMap)model.get("model");
+        String opinion = (String)model.get("opinion");
         LinkedHashMap installationInfo = (LinkedHashMap)model1.get("installationInfo");
         JgInstallationNoticeDto jgInstallationNoticeDto = JSON.parseObject(JSON.toJSONString(installationInfo), JgInstallationNoticeDto.class);
+        jgInstallationNoticeDto.setProcessAdvice(opinion);
         jgInstallationNoticeServiceImpl.accept(jgInstallationNoticeDto,op);
         return ResponseHelper.buildResponse(null);
     }

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/controller/JgInstallationNoticeController.java

@@ -80,7 +80,7 @@ public class JgInstallationNoticeController extends BaseController {
     @TycloudOperation(ApiLevel = UserType.AGENCY)
     @DeleteMapping(value = "/delete")
     @ApiOperation(httpMethod = "DELETE", value = "根据sequenceNbr删除安装告知", notes = "根据sequenceNbr删除安装告知")
-    public ResponseModel<Boolean> deleteBySequenceNbr(@RequestParam(value = "sequenceNbr") Long[] sequenceNbr) {
+    public ResponseModel<Boolean> deleteBySequenceNbr(@RequestParam(value = "sequenceNbr") Long sequenceNbr) {
         return ResponseHelper.buildResponse(iJgInstallationNoticeService.removeById(sequenceNbr));
     }
 

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/controller/JgUseRegistrationController.java

@@ -47,7 +47,7 @@ public class JgUseRegistrationController extends BaseController {
     @PostMapping(value = "/flowExecute")
     @ApiOperation(httpMethod = "POST", value = "执行流程", notes = "执行流程")
     public ResponseModel<Object> flowExecute(@RequestBody JSONObject map) {
-        jgUseRegistrationServiceImpl.flowExecute(Long.valueOf(String.valueOf(map.get("sequenceNbr"))),String.valueOf(map.get("instanceId")), String.valueOf(map.get("operate")), String.valueOf(map.get("comment")), true);
+        jgUseRegistrationServiceImpl.flowExecute(Long.valueOf(String.valueOf(map.get("sequenceNbr"))),String.valueOf(map.get("instanceId")), String.valueOf(map.get("operate")), String.valueOf(map.get("comment")));
         return ResponseHelper.buildResponse("ok");
     }
 

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/IdxBizJgRegisterInfoServiceImpl.java

@@ -861,7 +861,9 @@ public class IdxBizJgRegisterInfoServiceImpl extends BaseService<IdxBizJgRegiste
             } catch (IllegalAccessException e) {
                 throw new RuntimeException(e);
             }
-            result.put(underscoreFieldName.toUpperCase(), value);
+            if(!ValidationUtil.isEmpty(value)){
+                result.put(underscoreFieldName.toUpperCase(), value);
+            }
         }
         return result;
     }

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/JgEquipTransferServiceImpl.java

@@ -160,8 +160,6 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J
             dto.setInstanceStatus(String.join(",", roleListFirst));
             dto.setPromoter(reginParams.getUserModel().getUserId());
             dto.setApplyStatus(taskName[0]);
-            dto.setInstallUnitName(reginParams.getCompany().getCompanyName());
-            dto.setInstallUnitCreditCode(reginParams.getCompany().getCompanyCode());
             jgEquipTransferEq.setEquId(String.valueOf(obj.get("SEQUENCE_NBR")));
             jgEquipTransferEq.setEquipTransferId(applyNo);
             if (!CollectionUtils.isEmpty(instanceIdList)) {
@@ -187,15 +185,6 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J
     private void convertField(JgEquipTransferDto model) {
         if (null == model)
             return;
-        // 分割单位
-        String useUnitId = model.getUseUnitCreditCode();
-        if (!ObjectUtils.isEmpty(useUnitId)) {
-            String[] useUnitList = useUnitId.split("_");
-            if (useUnitList.length > 1) {
-                model.setUseUnitCreditCode(useUnitList[0]);
-                model.setUseUnitName(useUnitList[1]);
-            }
-        }
         //  分割接收机构
         String installUnitId = model.getInstallUnitCreditCode();
         if (!ObjectUtils.isEmpty(installUnitId)) {
@@ -287,7 +276,7 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J
     }
 
     @Override
-    public Map<String, Map<String, Object>> queryBySequenceNbr(Long sequenceNbr) {
+    public Map<String, Object> queryBySequenceNbr(Long sequenceNbr) {
         JgEquipTransfer equipTransfer = this.baseMapper.selectById(sequenceNbr);
 
         if (Objects.isNull(equipTransfer)) {
@@ -305,11 +294,11 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J
         handleJsonArrayFields(equipTransferInfo, fields);
         handleJsonArrayFields(equipmentInfos.get(0), fields);
 
-        Map<String, Map<String, Object>> result = new HashMap<>();
-        result.put("installationInfo", equipTransferInfo);
-        result.put("equipmentInfo", equipmentInfos.get(0));
+        Map<String, Object> resultMap = new HashMap<>();
+        resultMap.put("transferInfo", equipmentInfos.get(0));
 
-        return result;
+        equipTransferInfo.forEach((key, value) -> resultMap.computeIfAbsent(key, k -> value));
+        return  resultMap;
     }
 
     @Override
@@ -320,8 +309,8 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J
 
     private Map<String, Object> createEquipTransferInfo(JgEquipTransfer equipTransfer) {
         Map<String, Object> equipTransferInfo = new HashMap<>(BeanUtil.beanToMap(equipTransfer));
-        equipTransferInfo.put("useUnitCreditCode", equipTransfer.getUseUnitCreditCode() + "_" + equipTransfer.getUseUnitName());
-        equipTransferInfo.put("installUnitCreditCode", equipTransfer.getInstallUnitCreditCode() + "_" + equipTransfer.getInstallUnitName());
+        //equipTransferInfo.put("useUnitCreditCode", equipTransfer.getUseUnitCreditCode() + "_" + equipTransfer.getUseUnitName());
+        //equipTransferInfo.put("installUnitCreditCode", equipTransfer.getInstallUnitCreditCode() + "_" + equipTransfer.getInstallUnitName());
         return equipTransferInfo;
     }
 

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/JgInstallationNoticeServiceImpl.java

@@ -37,6 +37,8 @@ import com.yeejoin.amos.feign.workflow.model.AjaxResult;
 import com.yeejoin.amos.feign.workflow.model.TaskResultDTO;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.transaction.support.TransactionSynchronization;
+import org.springframework.transaction.support.TransactionSynchronizationManager;
 import org.springframework.util.ObjectUtils;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.stereotype.Service;
@@ -319,21 +321,21 @@ public class JgInstallationNoticeServiceImpl extends BaseService<JgInstallationN
         placeholders.put("productName", getValue.apply("productName"));
         placeholders.put("equipType", getValue.apply("equType"));
         placeholders.put("equipCode", getValue.apply("equRegisterCode"));
-        placeholders.put("produceCode", getValue.apply("produceCode")); // TODO: 制造编号
+        placeholders.put("produceCode", getValue.apply("factoryNum")); // TODO: 出厂编号
         placeholders.put("produceUnitName", getValue.apply("produceUnitName"));
         placeholders.put("produceLicenseNum", getValue.apply("produceLicenseNum"));
-        placeholders.put("fullAddress", getValue.apply("provinceName") + getValue.apply("cityName") + getValue.apply("countyName") + getValue.apply("address"));
+        placeholders.put("installUnitAddress", getValue.apply("provinceName") + getValue.apply("cityName") + getValue.apply("countyName") + getValue.apply("streetName") + getValue.apply("address"));
         placeholders.put("installStartDate", getValue.apply("installStartDate"));
-        placeholders.put("installType", getValue.apply("installType")); // TODO: 施工类别
+        placeholders.put("installType", "安装告知"); // TODO: 施工类别
         placeholders.put("installLicenseNo", getValue.apply("installLicenseNo"));
         placeholders.put("installLicenseExpirationDate", getValue.apply("installLicenseExpirationDate"));
         placeholders.put("installLeaderName", getValue.apply("installLeaderName"));
         placeholders.put("installLeaderPhone", getValue.apply("installLeaderPhone"));
-        placeholders.put("installUnitAddress", getValue.apply("installUnitAddress")); // TODO: 施工单位地址
+        placeholders.put("fullAddress", getValue.apply("provinceName") + getValue.apply("cityName") + getValue.apply("countyName") + getValue.apply("streetName") + getValue.apply("address"));
         placeholders.put("useUnitName", getValue.apply("useUnitName"));
         placeholders.put("useUnitLeaderName", getValue.apply("safetyManager"));
         placeholders.put("useUnitLeaderPhone", getValue.apply("safetyManagerPhone"));
-        placeholders.put("useUnitLeaderAddress", getValue.apply("useUnitProvinceName") + getValue.apply("useUnitCityName") + getValue.apply("useUnitCountyName") + getValue.apply("useUnitAddress"));
+        placeholders.put("useUnitLeaderAddress", getValue.apply("address"));
         // 生成二维码
         String qrCode = ImageUtils.generateQRCode(getValue.apply("applyNo"), 300, 300);
         placeholders.put("qrCode", qrCode);
@@ -458,7 +460,7 @@ public class JgInstallationNoticeServiceImpl extends BaseService<JgInstallationN
                     TaskResultDTO dto = new TaskResultDTO();
                     dto.setResultCode("approvalStatus");
                     dto.setTaskId(taskId);
-                    dto.setComment("提交流程");
+                    dto.setComment("");
                     HashMap<String, Object> map = new HashMap<>();
                     map.put("approvalStatus", "0");
                     dto.setVariable(map);
@@ -498,6 +500,11 @@ public class JgInstallationNoticeServiceImpl extends BaseService<JgInstallationN
             }
             dto.setInstallUnitName(reginParams.getCompany().getCompanyName());
             dto.setInstallUnitCreditCode(reginParams.getCompany().getCompanyCode());
+            dto.setEquList((String.valueOf(obj.get("EQU_CATEGORY"))));
+            dto.setEntrustingUnitName(dto.getUseUnitName());
+            StringBuffer buffer = new StringBuffer();
+            buffer.append(dto.getProvinceName()).append(dto.getCityName()).append(dto.getCountyName()).append(dto.getAddress());
+            dto.setEquAddress(buffer.toString());
             jgRelationEquip.setEquId(String.valueOf(obj.get("SEQUENCE_NBR")));
             jgRelationEquip.setEquipTransferId(applyNo);
             if (!CollectionUtils.isEmpty(instanceIdList)) {
@@ -630,7 +637,9 @@ public class JgInstallationNoticeServiceImpl extends BaseService<JgInstallationN
         TaskResultDTO dto = new TaskResultDTO();
         dto.setResultCode("approvalStatus");
         dto.setTaskId(taskId);
-        dto.setComment("提交流程");
+        if(!ValidationUtil.isEmpty(notice.getProcessAdvice())) {
+            dto.setComment(notice.getProcessAdvice());
+        }
         HashMap<String, Object> map = new HashMap<>();
         map.put("approvalStatus", op);
         dto.setVariable(map);
@@ -664,10 +673,12 @@ public class JgInstallationNoticeServiceImpl extends BaseService<JgInstallationN
         }
     }
 
+    @Transactional
     public void accept(JgInstallationNoticeDto dto,String op) {
         String[] taskName = new String[]{"流程结束"};
         String userId = RequestContext.getExeUserId();
         JgInstallationNotice jgInstallationNotice = this.jgInstallationNoticeMapper.selectById(dto.getSequenceNbr());
+        jgInstallationNotice.setProcessAdvice(dto.getProcessAdvice());
         // 组装设备注册代码
         StringBuffer stringBuffer = new StringBuffer();
         String ym = null;
@@ -706,7 +717,7 @@ public class JgInstallationNoticeServiceImpl extends BaseService<JgInstallationN
                     map.put("cityCode",jgInstallationNotice.getCity());
                     map.put("countyCode",jgInstallationNotice.getCounty());
                     map.put("equCategory",tzsJgRegistrationInfo.getEquCategory());
-                    map.put("isXiXian", jgInstallationNotice.getIsXixian() == null ? "0" : jgInstallationNotice.getIsXixian());
+                    map.put("isXiXian", jgInstallationNotice.getIsXixian() == null ? "null" : jgInstallationNotice.getIsXixian().equals("0") ? "null" : "1");
                     Map<String, Object> mapCode;
                     ResponseModel<Map<String, Object>> code = tzsServiceFeignClient.createCode(map);
                     mapCode = code.getResult();
@@ -716,18 +727,21 @@ public class JgInstallationNoticeServiceImpl extends BaseService<JgInstallationN
                     SupervisoryCodeInfo supervisoryCodeInfo = supervisoryCodeInfoMapper.selectOne(queryWrapper3);
                     supervisoryCodeInfo.setStatus("1");
                     supervisoryCodeInfoMapper.updateById(supervisoryCodeInfo);
-
                     jgInstallationNotice.setNoticeStatus(String.valueOf(FlowStatusEnum.TO_BE_FINISHED.getCode()));
-                    this.generateInstallationNoticeReport(jgInstallationNotice.getSequenceNbr());
+                    jgInstallationNotice.setHandleDate(new Date());
+
+                    Map<String,Object> map1 =new HashMap<>();
+
                     // 更新其他业务表
-                    tzsJgOtherInfo.setCode96333(mapCode.get("code96333").toString());
+                    if(!ValidationUtil.isEmpty(mapCode.get("code96333"))) {
+                        tzsJgOtherInfo.setCode96333(mapCode.get("code96333").toString());
+                        map1.put("CODE96333",tzsJgOtherInfo.getCode96333() );
+                    }
                     tzsJgOtherInfo.setSupervisoryCode(mapCode.get("superviseCode").toString());
                     tzsJgRegistrationInfo.setEquCode(deviceRegistrationCode);
                     jgInstallationNotice.setEquRegisterCode(deviceRegistrationCode);
                     jgInstallationNotice.setSupervisoryCode(mapCode.get("superviseCode").toString());
                     Map<String,Map<String,Object>> objMap = new HashMap<>();
-                    Map<String,Object> map1 =new HashMap<>();
-                    map1.put("CODE96333",tzsJgOtherInfo.getCode96333() );
                     map1.put("EQU_CODE",tzsJgRegistrationInfo.getEquCode() );
                     map1.put("SUPERVISORY_CODE",tzsJgOtherInfo.getSupervisoryCode());
                     objMap.put(tzsJgOtherInfo.getRecord(),map1);
@@ -735,6 +749,13 @@ public class JgInstallationNoticeServiceImpl extends BaseService<JgInstallationN
                     tzsServiceFeignClient.commonUpdateEsDataByIds(objMap);
                     tzsJgOtherInfoMapper.updateById(tzsJgOtherInfo);
                     tzsJgRegistrationInfoMapper.updateById(tzsJgRegistrationInfo);
+
+                    TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
+                        @Override
+                        public void afterCommit() {
+                            generateInstallationNoticeReport(jgInstallationNotice.getSequenceNbr());
+                        }
+                    });
                 } else {
                     jgInstallationNotice.setNextExecuteIds(String.join(",", roleList));
                     if (!ObjectUtils.isEmpty(jgInstallationNotice.getInstanceStatus())) {

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/JgScrapCancelServiceImpl.java

@@ -239,111 +239,6 @@ public class JgScrapCancelServiceImpl extends BaseService<JgScrapCancelDto, JgSc
     }
 
 
-//    public String flowExecute(Long id,String instanceId, String operate, String comment, Boolean update) {
-//        String role = "";
-//        String taskName = "流程结束";
-//        ArrayList<String> roleList = new ArrayList<>();
-//        try {
-//            JSONObject task = workFlowFeginService.getTaskNoAuth(instanceId);
-//            JSONObject taskMessage = JSON.parseObject(JSON.toJSONString(task.get("data")));
-//            String taskId = taskMessage.getString("id");
-//            //组装信息
-//            TaskResultDTO dto = new TaskResultDTO();
-//            dto.setResultCode("approvalStatus");
-//            dto.setTaskId(taskId);
-//            dto.setComment(comment);
-//            HashMap<String, Object> map = new HashMap<>();
-//            map.put("approvalStatus", operate);
-//            dto.setVariable(map);
-//            //执行流程
-//            Workflow.taskClient.completeByTask(taskId, dto);
-//            // 查询下节点任务
-//            JSONObject taskNoAuth = workFlowFeginService.getTaskNoAuth(instanceId);
-//            if (!ObjectUtils.isEmpty(taskNoAuth.get("data"))) {
-//                JSONObject nextTask = JSON.parseObject(JSON.toJSONString(taskNoAuth.get("data")));
-//                String nextTaskId = nextTask.getString("id");
-//                taskName = nextTask.getString("name");
-//                AjaxResult taskGroupName = Workflow.taskClient.getTaskGroupName(nextTaskId);
-//                JSONArray data = JSON.parseArray(JSON.toJSONString(taskGroupName.get("data")));
-//                for (Object datum : data) {
-//                    if (((Map) datum).containsKey("groupId")) {
-//                        roleList.add(((Map) datum).get("groupId").toString());
-//                    }
-//                }
-//            }
-//        } catch (Exception e) {
-//            e.printStackTrace();
-//        }
-//        role= String.join(",", roleList);
-//        if (update) {
-//            Boolean rollBack = "1".equals(operate) ? true : false;
-//            updateStatus(id,instanceId, taskName, role, rollBack);
-//        }
-//        return role;
-//    }
-//
-//
-//    public void updateStatus(Long id , String instanceId, String taskName, String role, Boolean rollBack) {
-//        ReginParams reginParams = JSONObject.parseObject(redisUtils.get(RedisKey.buildReginKey(RequestContext.getExeUserId(), RequestContext.getToken())).toString(), ReginParams.class);
-//        LambdaQueryWrapper<JgScrapCancel> lambda = new QueryWrapper<JgScrapCancel>().lambda();
-//        lambda.eq(JgScrapCancel::getSequenceNbr, id);
-//        JgScrapCancel jgScrapCancel = this.getBaseMapper().selectOne(lambda);
-//        if ("流程结束".equals(taskName)) {
-//            jgScrapCancel.setStatus(taskName);
-//            jgScrapCancel.setAuditStatus(CancelWorkFlowStatusEnum.COMPLETE.getName());
-//
-//
-//            LambdaQueryWrapper<JgScrapCancelEq> lambdaEq = new QueryWrapper<JgScrapCancelEq>().lambda();
-//            lambdaEq.eq(JgScrapCancelEq::getEquipTransferId, id);
-//            JgScrapCancelEq jgScrapCancelEq = jgScrapCancelEqMapper.selectOne(lambdaEq);
-//
-//            ResponseModel<String> responseModel = tzsServiceFeignClient.useRegistrationCode(idxBizJgOtherInfoMapper.getSupervisoryCodeByEquipmentCode(jgScrapCancelEq.getEquId()));
-//            String newUseRegistrationCertificateNumber=responseModel.getResult().split("-")[0];
-//
-//            Map<String,Map<String,Object>> resultMap = new HashMap<>();
-//            Map<String,Object> map1 =new HashMap<>();
-//            map1.put("USE_ORG_CODE",newUseRegistrationCertificateNumber );
-//            if (CancelTypeEnum.SCRAPPED.getCode().equals(jgScrapCancel.getCancelType())) {
-//                IdxBizJgUseInfo idxBizJgUseInfo = new IdxBizJgUseInfo();
-//                idxBizJgUseInfo.setEquState(String.valueOf(EquimentEnum.BAOFEI.getCode()));
-//                LambdaQueryWrapper<IdxBizJgUseInfo> wrapper = new LambdaQueryWrapper<>();
-//                wrapper.eq(IdxBizJgUseInfo::getRecord, jgScrapCancelEq.getEquId());
-//                idxBizJgUseInfoMapper.update(idxBizJgUseInfo, wrapper);
-//                map1.put("EQU_STATE", String.valueOf(EquimentEnum.BAOFEI.getCode()));
-//            } else {
-//                SuperviseInfo superviseInfo = new SuperviseInfo();
-//                superviseInfo.setOrgBranchCode("");
-//                superviseInfo.setOrgBranchName("");
-//                LambdaQueryWrapper<SuperviseInfo> wrapper = new LambdaQueryWrapper<>();
-//                wrapper.eq(SuperviseInfo::getRecord, jgScrapCancelEq.getEquId());
-//                superviseInfoMapper.update(superviseInfo, wrapper);
-//                map1.put("ORG_BRANCH_CODE", "");
-//                map1.put("ORG_BRANCH_NAME", "");
-//            }
-//            resultMap.put(jgScrapCancelEq.getEquId(), map1);
-//            tzsServiceFeignClient.commonUpdateEsDataByIds(resultMap);
-//        } else {
-//            jgScrapCancel.setNextExecuteIds(role);
-//            jgScrapCancel.setPromoter(reginParams.getUserModel().getUserId());
-//            if (!ObjectUtils.isEmpty(jgScrapCancel.getInstanceStatus())) {
-//                jgScrapCancel.setInstanceStatus(jgScrapCancel.getInstanceStatus() + "," + role);
-//            } else {
-//                jgScrapCancel.setInstanceStatus(role);
-//            }
-//        }
-//        CancelWorkFlowStatusEnum message = CancelWorkFlowStatusEnum.getMessage(taskName);
-//        assert message != null;
-//        if (rollBack){
-//            jgScrapCancel.setAuditStatus(message.getRollBack());
-//            this.getBaseMapper().update(jgScrapCancel, lambda);
-//            this.getBaseMapper().updatePromoter(jgScrapCancel.getSequenceNbr());
-//        }else {
-//            jgScrapCancel.setAuditStatus(message.getPass());
-//            this.getBaseMapper().update(jgScrapCancel, lambda);
-//        }
-//    }
-
-
     public void deleteBatch(List<Long> ids) {
         JgScrapCancel jgScrapCancel = new JgScrapCancel();
         jgScrapCancel.setIsDelete(true);
@@ -386,9 +281,11 @@ public class JgScrapCancelServiceImpl extends BaseService<JgScrapCancelDto, JgSc
             if (submit) {
                 // 查询下节点任务
                 getNext(roleListSecond, jgScrapCancel.getInstanceId(), taskName);
+
+                String join = String.join(",", roleListSecond);
                 jgScrapCancel.setStatus(taskName[0]);
                 if (!ObjectUtils.isEmpty(jgScrapCancel.getInstanceStatus())) {
-                    jgScrapCancel.setInstanceStatus(jgScrapCancel.getInstanceStatus() + "," + roleListSecond);
+                    jgScrapCancel.setInstanceStatus(jgScrapCancel.getInstanceStatus() + "," + join);
                 } else {
                     jgScrapCancel.setInstanceStatus(String.join(",", roleListSecond));
                 }

amos-boot-system-tzs/amos-boot-module-jyjc/amos-boot-module-jyjc-api/src/main/java/com/yeejoin/amos/boot/module/jyjc/api/mapper/JyjcInspectionApplicationMapper.java

@@ -7,6 +7,7 @@ import com.yeejoin.amos.boot.module.jyjc.api.model.JyjcInspectionApplicationEqui
 import com.yeejoin.amos.boot.module.jyjc.api.model.JyjcInspectionApplicationModel;
 import org.springframework.data.repository.query.Param;
 
+import java.util.List;
 import java.util.Map;
 
 /**
@@ -19,6 +20,7 @@ public interface JyjcInspectionApplicationMapper extends BaseMapper<JyjcInspecti
 
 
    public Page<JyjcInspectionApplicationModel> queryForDataList( Page<JyjcInspectionApplication> page, String applicationNo, String inspectionClassify, String applicationUnitCode,String applicationUnitName, String equipClassify, String inspectionUnitCode,String inspectionUnitName, String applicationDate, String acceptDate, String inspectionChargePerson, String status , String bizType);
+//   public Page<JyjcInspectionApplicationModel> queryForDataList( Page<JyjcInspectionApplication> page, String applicationNo, String inspectionClassify, String applicationUnitCode,String applicationUnitName, String equipClassify, String inspectionUnitCode,String inspectionUnitName, String applicationDate, String acceptDate, String inspectionChargePerson, String status , String bizType, List<String> roleIds);
 
    Page<JyjcInspectionApplicationEquipModel> listByCategory(Page<JyjcInspectionApplicationEquipModel> page,@Param("equipClassify")  String equipClassify);
 

amos-boot-system-tzs/amos-boot-module-jyjc/amos-boot-module-jyjc-api/src/main/java/com/yeejoin/amos/boot/module/jyjc/api/model/JyjcInspectionResultModel.java

@@ -149,4 +149,7 @@ public class JyjcInspectionResultModel extends BaseModel {
 
     @ApiModelProperty(value = "报检单位")
     private String applicationUnitName;
+
+    @ApiModelProperty(value = "监管码")
+    private String supervisoryCode;
 }

amos-boot-system-tzs/amos-boot-module-jyjc/amos-boot-module-jyjc-api/src/main/java/com/yeejoin/amos/boot/module/jyjc/api/model/JyjcOpeningApplicationRequstDto.java

@@ -44,6 +44,6 @@ public class JyjcOpeningApplicationRequstDto {
     @ApiModelProperty (value = "申请时间")
     private String applyTime;
 
-
-
+    @ApiModelProperty (value = "supervision: 监管; enterprise: 企业")
+    private String type;
 }

amos-boot-system-tzs/amos-boot-module-jyjc/amos-boot-module-jyjc-api/src/main/resources/mapper/JyjcInspectionApplicationMapper.xml

@@ -47,7 +47,7 @@
             and inspection_unit_code in (select use_code from tz_base_enterprise_info where use_unit like concat('%',#{inspectionUnitName},'%'))
         </if>
         <if test="inspectionUnitCode != null and inspectionUnitCode != ''">
-            and inspection_unit_code = #{inspectionUnitCode}
+            and inspection_unit_code = #{inspectionUnitCode} and status != '6610'
         </if>
         <if test="applicationUnitCode != null and applicationUnitCode != ''">
             and application_unit_code = #{applicationUnitCode}
@@ -73,8 +73,13 @@
         <if test="bizType != null and bizType != ''">
             and biz_type = #{bizType}
         </if>
+<!--        <if test="roleIds.size()>0">-->
+<!--            <foreach collection="roleIds" item="item" separator="or">-->
+<!--                and workflow_role like concat('%',#{item},'%')-->
+<!--            </foreach>-->
+<!--        </if>-->
         </where>
-        order by tzjia.application_date desc
+        order by tzjia.application_no desc
     </select>
     <select id="listByCategory"
             resultType="com.yeejoin.amos.boot.module.jyjc.api.model.JyjcInspectionApplicationEquipModel">

amos-boot-system-tzs/amos-boot-module-jyjc/amos-boot-module-jyjc-api/src/main/resources/mapper/JyjcInspectionResultMapper.xml

@@ -10,10 +10,10 @@
         res.inspection_end_date, res.inspection_result_summary, res.non_conformance, res.rectification, res.remark,
         res.rec_user_id, res.rec_date, res.biz_type,res.equ_category, res.inspection_type, res.inspection_type_name,
         res.application_date,use_unit_name, use_unit_credit_code, province_name, city_name, county_name, street_name, equ_code, use_inner_code, ibjri.equ_list,
-         tec1.name equ_list_name, ibjri.equ_category
+         tec1.name equ_list_name, ibjri.equ_category , ibjoi.SUPERVISORY_CODE supervisoryCode
         , use_org_code, res.equ_define, ibjui.ADDRESS equUseAddress, bei.use_unit inspectionUnitName, bei1.use_unit applicationUnitName, cdb.name inspectionTypeName
         from tz_jyjc_inspection_result res
---         left join idx_biz_jg_other_info ibjoi on res.equip_unicode = ibjoi.supervisory_code
+        left join idx_biz_jg_other_info ibjoi on res.equip_unicode = ibjoi.record
         left join idx_biz_jg_use_info ibjui on ibjui.record = res.equip_unicode
         left join idx_biz_jg_register_info ibjri on ibjui.record = ibjri.record
         left join tz_equipment_category tec on ibjri.equ_category = tec.code

amos-boot-system-tzs/amos-boot-module-jyjc/amos-boot-module-jyjc-api/src/main/resources/mapper/JyjcOpeningApplicationMapper.xml

@@ -48,6 +48,9 @@
             <if test="applyStartTime != '' and applyStartTime != null">
                 and apply_time &gt;=#{applyStartTime}
             </if>
+            <if test="jyjcOpeningApplicationRequstDto.type == 'supervision'">
+                and status not in ('6610')
+            </if>
         </where>
         order by sequence_nbr desc
 

amos-boot-system-tzs/amos-boot-module-jyjc/amos-boot-module-jyjc-biz/src/main/java/com/yeejoin/amos/boot/module/jyjc/biz/controller/JyjcInspectionApplicationController.java

 package com.yeejoin.amos.boot.module.jyjc.biz.controller;
 
 
+import cn.hutool.core.util.StrUtil;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.yeejoin.amos.boot.biz.common.bo.ReginParams;
 import com.yeejoin.amos.boot.biz.common.controller.BaseController;
+import com.yeejoin.amos.boot.module.common.biz.utils.CommonResponseUtil;
 import com.yeejoin.amos.boot.module.jyjc.api.entity.JyjcInspectionApplication;
 import com.yeejoin.amos.boot.module.jyjc.api.model.JyjcInspectionApplicationEquipModel;
 import com.yeejoin.amos.boot.module.jyjc.api.model.JyjcInspectionApplicationModel;
@@ -15,6 +17,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 import org.typroject.tyboot.core.foundation.enumeration.UserType;
 import org.typroject.tyboot.core.restful.doc.TycloudOperation;
+import org.typroject.tyboot.core.restful.exception.instance.BadRequest;
 import org.typroject.tyboot.core.restful.utils.ResponseHelper;
 import org.typroject.tyboot.core.restful.utils.ResponseModel;
 
@@ -50,8 +53,16 @@ public class JyjcInspectionApplicationController extends BaseController {
 
 		ReginParams selectedOrgInfo = getSelectedOrgInfo();
 		model.put("applicationUnitCode",selectedOrgInfo.getCompany().getCompanyCode());
+
+		if (model.get("operationType").toString().equals("2") || model.get("operationType").toString().equals("0")){
+
+			if(null == model.get("equip") ||model.getJSONArray("equip").size() < 1 ){
+					return CommonResponseUtil.failure("未选择报检设备时不可提交");
+			}
+
+		}
 		return ResponseHelper.buildResponse(jyjcInspectionApplicationServiceImpl.save(model));
-	}
+    }
 
 
 
@@ -133,14 +144,16 @@ public class JyjcInspectionApplicationController extends BaseController {
 											  @RequestParam(required = false) String applicationDate,
 											  @RequestParam(required = false) String acceptDate,
 											  @RequestParam(required = false) String inspectionChargePerson,
-											  @RequestParam(required = false) String status , String bizType) {
+											  @RequestParam(required = false) String status ,
+											 @RequestParam(required = false) String roles,	  String bizType) {
 	    Page<JyjcInspectionApplication> page = new Page<JyjcInspectionApplication>();
 	    page.setCurrent(current);
 	    page.setSize(size);
 
 		ReginParams reginParams = getSelectedOrgInfo();
 		inspectionUnitCode = reginParams.getCompany().getCompanyCode();
-		return ResponseHelper.buildResponse(jyjcInspectionApplicationServiceImpl.queryForJyjcInspectionApplicationPage(page,applicationNo,inspectionClassify,applicationUnitCode,equipClassify,inspectionUnitCode,applicationUnitName,inspectionUnitName,applicationDate,acceptDate,inspectionChargePerson,status,bizType));
+		List<String> roleIds = StrUtil.split(roles, ",");
+		return ResponseHelper.buildResponse(jyjcInspectionApplicationServiceImpl.queryForJyjcInspectionApplicationPage(page,applicationNo,inspectionClassify,applicationUnitCode,equipClassify,inspectionUnitCode,applicationUnitName,inspectionUnitName,applicationDate,acceptDate,inspectionChargePerson,status,bizType ));
 	}
 
 
@@ -158,14 +171,18 @@ public class JyjcInspectionApplicationController extends BaseController {
 																				@RequestParam(required = false) String applicationDate,
 																				@RequestParam(required = false) String acceptDate,
 																				@RequestParam(required = false) String inspectionChargePerson,
-																				@RequestParam(required = false) String status , String bizType) {
+																					 @RequestParam(required = false) String roles,
+																					 @RequestParam(required = false) String status , String bizType) {
 		Page<JyjcInspectionApplication> page = new Page<JyjcInspectionApplication>();
 		page.setCurrent(current);
 		page.setSize(size);
 		ReginParams reginParams = getSelectedOrgInfo();
 		applicationUnitCode = reginParams.getCompany().getCompanyCode();
+			List<String> roleIds = StrUtil.split(roles, ",");
+//			return ResponseHelper.buildResponse(jyjcInspectionApplicationServiceImpl.queryForJyjcInspectionApplicationPage(page,applicationNo,inspectionClassify,applicationUnitCode,equipClassify,inspectionUnitCode,applicationUnitName,inspectionUnitName,applicationDate,acceptDate,inspectionChargePerson,status,bizType,roleIds));
 			return ResponseHelper.buildResponse(jyjcInspectionApplicationServiceImpl.queryForJyjcInspectionApplicationPage(page,applicationNo,inspectionClassify,applicationUnitCode,equipClassify,inspectionUnitCode,applicationUnitName,inspectionUnitName,applicationDate,acceptDate,inspectionChargePerson,status,bizType));
-		}
+
+	}
 
 			/**
              * 列表全部数据查询

amos-boot-system-tzs/amos-boot-module-jyjc/amos-boot-module-jyjc-biz/src/main/java/com/yeejoin/amos/boot/module/jyjc/biz/feign/TzsServiceFeignClient.java

+package com.yeejoin.amos.boot.module.jyjc.biz.feign;
+
+
+import com.yeejoin.amos.boot.biz.common.feign.FeignConfiguration;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.typroject.tyboot.core.restful.utils.ResponseModel;
+
+import java.util.Map;
+
+@FeignClient(name = "TZS-YMT", path = "/ymt", configuration =
+        {FeignConfiguration.class})
+public interface TzsServiceFeignClient {
+
+
+    /**
+     * 创建监管码及96333
+     *
+     * @param map 请求体
+     * @return
+     */
+    @RequestMapping(value = "/equipment-category/createSupervisorCode", method = RequestMethod.POST)
+    ResponseModel<Map<String, Object>> createCode(@RequestBody Map<String, Object> map);
+
+    /**
+     * 创建监管码及96333
+     *
+     * @param paramMap 请求体
+     * @return
+     */
+    @RequestMapping(value = "/equipment-category/commonUpdateEsData", method = RequestMethod.POST)
+    ResponseModel<Map<String, Object>> commonUpdateEsDataByIds(@RequestBody Map<String, Map<String, Object>> paramMap);
+
+
+    /**
+     * 申请单编号生成
+     * @param type 参考ApplicationFormTypeEnum中的枚举
+     * @param batchSize batchSize
+     * @return List
+     */
+    @RequestMapping(value = "/generate-code/applicationFormCode", method = RequestMethod.POST)
+    ResponseModel<Map<String, Object>> applicationFormCode(@RequestParam("type") String type,
+                                                     @RequestParam("batchSize") int batchSize);
+
+    /**
+     * 生成设备注册编码
+     * @param key 16位
+     * @return 生成设备注册编码(20位)
+     */
+    @RequestMapping(value = "/generate-code/deviceRegistrationCode", method = RequestMethod.POST)
+    ResponseModel<String> deviceRegistrationCode(@RequestParam("key") String key);
+
+    /**
+     * 使用登记证生成
+     * @param key 起11陕C
+     * @return 生成使用登记证编号(13位，起11陕C00001(23))
+     */
+    @RequestMapping(value = "/generate-code/useRegistrationCode", method = RequestMethod.POST)
+    ResponseModel<String> useRegistrationCode(@RequestParam("key") String key);
+
+
+}

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

@@ -95,8 +95,7 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec
     public JyjcInspectionApplicationModel save(@RequestBody JSONObject obj) {
         ReginParams reginParams = JSONObject.parseObject(redisUtils.get(RedisKey.buildReginKey(RequestContext.getExeUserId(), RequestContext.getToken())).toString(), ReginParams.class);
 
-        //开启报检流程工作流
-
+        //接口通用 部分页面按钮无法分开配置类型 所以根据业务情况 将带有工作流实例id的数据 接口类型设置为2 走编辑逻辑
         JyjcInspectionApplicationModel model = JSONObject.parseObject(JSON.toJSONString(obj), JyjcInspectionApplicationModel.class);
         if (CharSequenceUtil.isNotEmpty(model.getProcessInstanceId()) && model.getOperationType().equals("0")){
             model.setOperationType("2");
@@ -109,6 +108,7 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec
                 dto.setProcessDefinitionKey( model.getProcessKey());
                 dto.setBusinessKey(buildOrderNo());
                 try {
+                    //开启报检流程工作流
                     FeignClientResult ajaxResult = Workflow.taskV2Client.startByVariable(dto);
                     String id = ((Map) ajaxResult.getResult()).get("id").toString();
                     model.setProcessInstanceId(id);
@@ -130,7 +130,6 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec
                 }
              model.setStatus(String.valueOf(FlowStatusEnum.TO_SUBMITTED.getCode())); //6611 对应数据字典 检验流程状态 待受理
             } else if (model.getOperationType().equals("1")) {
-                model.setStatus(String.valueOf(FlowStatusEnum.TO_BE_SUBMITTED.getCode()));
             }
 
             LambdaQueryWrapper<JyjcOpeningApplication> wa = new LambdaQueryWrapper<JyjcOpeningApplication>().eq(JyjcOpeningApplication::getUnitCode, model.getInspectionUnitCode()).eq(JyjcOpeningApplication::getStatus, FlowStatusEnum.TO_BE_FINISHED.getCode());
@@ -145,7 +144,6 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec
 
             model.setApplicationNo(codes.get(0));
             model.setApplicationDate(new Date());
-
             model.setPromoter(reginParams.getUserModel().getUserId());
 
 
@@ -168,6 +166,7 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec
             // endregion
 
             if (null == model.getSequenceNbr()){
+                model.setStatus(String.valueOf(FlowStatusEnum.TO_BE_SUBMITTED.getCode()));
                 model = this.createWithModel(model);
             }else {
                 model = this.updateWithModel(model);
@@ -293,9 +292,10 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec
                                                                                  String applicationDate,
                                                                                  String acceptDate,
                                                                                  String inspectionChargePerson,
-                                                                                 String status, String bizType) {
+                                                                                 String status, String bizType ) {
 
-        return this.getBaseMapper().queryForDataList(page, applicationNo, inspectionClassify, applicationUnitCode, applicationUnitName, equipClassify, inspectionUnitCode, inspectionUnitName, applicationDate, acceptDate, inspectionChargePerson, status, bizType);
+//        return this.getBaseMapper().queryForDataList(page, applicationNo, inspectionClassify, applicationUnitCode, applicationUnitName, equipClassify, inspectionUnitCode, inspectionUnitName, applicationDate, acceptDate, inspectionChargePerson, status, bizType,roleIds);
+        return this.getBaseMapper().queryForDataList(page, applicationNo, inspectionClassify, applicationUnitCode, applicationUnitName, equipClassify, inspectionUnitCode, inspectionUnitName, applicationDate, acceptDate, inspectionChargePerson, status, bizType );
 
     }
 
@@ -505,10 +505,15 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec
             entity.setWorkflowRole(role);
         }
         entity.setStatus(status);
-        entity.setAcceptDate(new Date());
-        this.updateById(entity);
+       //此处自己撤销也赋予了办理日期 存在问题 与驳回 通过区分处理
         if (rollBack) {
             this.getBaseMapper().updatePromoter(entity.getSequenceNbr());
         }
+        //逻辑变更为 通过后才对办理时间赋值
+        if (status.equals(FlowStatusEnum.TO_BE_FINISHED.getCode())){
+            entity.setAcceptDate(new Date());
+        }
+        this.updateById(entity);
+
     }
 }
\ No newline at end of file

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

@@ -6,6 +6,7 @@ import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.yeejoin.amos.boot.biz.common.bo.CompanyBo;
 import com.yeejoin.amos.boot.biz.common.bo.ReginParams;
 import com.yeejoin.amos.boot.biz.common.utils.RedisKey;
@@ -19,6 +20,7 @@ import com.yeejoin.amos.boot.module.jyjc.api.model.JyjcOpeningApplicationRequstD
 import com.yeejoin.amos.boot.module.jyjc.api.service.IJyjcOpeningApplicationService;
 import com.yeejoin.amos.boot.module.jyjc.api.model.JyjcOpeningApplicationModel;
 import com.yeejoin.amos.boot.module.jyjc.biz.config.BaseException;
+import com.yeejoin.amos.boot.module.jyjc.biz.feign.TzsServiceFeignClient;
 import com.yeejoin.amos.boot.module.jyjc.biz.feign.WorkflowFeignClient;
 import com.yeejoin.amos.boot.module.ymt.api.dto.TzBaseUnitLicenceDto;
 import com.yeejoin.amos.boot.module.ymt.api.dto.TzsUserInfoDto;
@@ -48,6 +50,7 @@ import org.typroject.tyboot.core.rdbms.service.BaseService;
 import org.springframework.stereotype.Service;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import org.typroject.tyboot.core.restful.exception.instance.BadRequest;
+import org.typroject.tyboot.core.restful.utils.ResponseModel;
 
 import javax.annotation.Resource;
 import java.util.*;
@@ -69,6 +72,8 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp
     @Autowired
     private ICreateCodeService createCodeService;
     @Autowired
+    private TzsServiceFeignClient tzsServiceFeignClient;
+    @Autowired
     JyjcOpeningApplicationMapper jyjcOpeningApplicationMapper;
 
     @Resource(type = JyjcBaseMapper.class)
@@ -141,6 +146,7 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp
                 CompanyBo companyBo = commonserviceImpl.getReginParamsOfCurrentUser().getCompany();
                 model.setUnitCode(companyBo.getCompanyCode());
                 model.setUnitCodeName(companyBo.getCompanyName());
+                // ResponseModel<Map<String, Object>> result = tzsServiceFeignClient.applicationFormCode(ApplicationFormTypeEnum.JY.getCode(), 1);
                 List<String> codes = createCodeService.createApplicationFormCode(ApplicationFormTypeEnum.JY.getCode(), 1);
                 model.setApplicationSeq(codes.get(0));
                 model.setCreateUserId(reginParams.getUserModel().getUserId());
@@ -190,12 +196,45 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp
         }
         entity.setStatus(status);
         entity.setStatusName(FlowStatusEnum.getNameByType(Long.parseLong(status)));
+        // region 更新其他的数据为已作废
+        if (String.valueOf(FlowStatusEnum.TO_BE_FINISHED.getCode()).equals(status)) {
+            doDiscard(entity.getUnitCode(), entity.getSequenceNbr());
+            entity.setAcceptDate(new Date());
+        }
+        // endregion
         this.updateById(entity);
         if (rollBack) {
             this.getBaseMapper().updatePromoter(entity.getSequenceNbr());
         }
     }
 
+    /**
+     * 完成的时候废弃其他的
+     *
+     *
+     * @param unitCode unitCode
+     * @param sequenceNbr sequenceNbr
+     * @return {@link  Boolean}
+     * @author yangyang
+     * @throws
+     * @date 2023/12/22 09:23
+     */
+    public Boolean doDiscard(String unitCode, Long sequenceNbr) {
+        if (StringUtils.isBlank(unitCode) || sequenceNbr == null) {
+            return false;
+        }
+        List<Long> ids = this.lambdaQuery().select(JyjcOpeningApplication::getSequenceNbr)
+                             .eq(JyjcOpeningApplication::getUnitCode, unitCode)
+                             .list().stream().filter(o -> o.getSequenceNbr().compareTo(sequenceNbr) != 0)
+                             .map(JyjcOpeningApplication::getSequenceNbr).collect(Collectors.toList());
+        if (ValidationUtil.isEmpty(ids)) {
+            return false;
+        }
+        UpdateWrapper<JyjcOpeningApplication> updateWrapper = new UpdateWrapper<>();
+        updateWrapper.set("status", FlowStatusEnum.TO_BE_DISCARD.getCode()).set("status_name", FlowStatusEnum.TO_BE_DISCARD.getName()).in("SEQUENCE_NBR", ids);
+        return this.update(updateWrapper);
+    }
+
 
     /**
      * 分页查询
@@ -220,6 +259,8 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp
             applyStartTime = date + " 00:00:00";
             applyEndTime = date + " 23:59:59";
         }
+        // 设置为监管端
+        jyjcOpeningApplicationRequstDto.setType("supervision");
         return jyjcOpeningApplicationMapper.selectJyjcOpeningApplicationList(page, jyjcOpeningApplicationRequstDto, applyStartTime, applyEndTime);
     }
 
@@ -237,6 +278,7 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp
             applyStartTime = date + " 00:00:00";
             applyEndTime = date + " 23:59:59";
         }
+        jyjcOpeningApplicationRequstDto.setType("enterprise");
         return jyjcOpeningApplicationMapper.selectJyjcOpeningApplicationList(page, jyjcOpeningApplicationRequstDto, applyStartTime, applyEndTime);
     }
 
@@ -298,6 +340,7 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp
         // 获取检验人员信息
         QueryWrapper userInfoQueryWrapper = new QueryWrapper<>();
         userInfoQueryWrapper.eq("unit_code", unitCode);
+        userInfoQueryWrapper.eq("is_delete", true);
         List<TzsUserInfo> userInfos = userInfoMapper.selectList(userInfoQueryWrapper);
         if (!ValidationUtil.isEmpty(userInfos)) {
             // List<String> codes = userInfos.stream()
@@ -414,9 +457,9 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp
                         jyjcOpeningApplication.setDetectionRegion(detectionRegion);
                     }
 //                jyjcOpeningApplication.setDetectionRegionName(detectionRegionName);
-                    if(ObjectUtils.isEmpty(jyjcOpeningApplication.getAcceptDate())){
-                        jyjcOpeningApplication.setAcceptDate(new Date());
-                    }
+//                     if(ObjectUtils.isEmpty(jyjcOpeningApplication.getAcceptDate())){
+//                         jyjcOpeningApplication.setAcceptDate(new Date());
+//                     }
                     jyjcOpeningApplicationMapper.updateById(jyjcOpeningApplication);
                 }
                 role = (String) nextNodeInfo.get("role");

amos-boot-system-tzs/amos-boot-module-ymt/amos-boot-module-ymt-api/src/main/java/com/yeejoin/amos/boot/module/ymt/api/mapper/IdxBizJgRegisterInfoMapper.java

@@ -13,7 +13,7 @@ import org.apache.ibatis.annotations.Select;
  */
 public interface IdxBizJgRegisterInfoMapper extends BaseMapper<IdxBizJgRegisterInfo> {
 
-    @Select("select use_org_code from idx_biz_jg_register_info where record = #{equipCode}")
+    @Select("select \"USE_ORG_CODE\" from idx_biz_jg_register_info where \"RECORD\" = #{equipCode}")
    String getUseOrgCodeByEquip(@Param("equipCode") String equipCode);
 
     @Select("update idx_biz_jg_register_info set \"USE_ORG_CODE\" = #{useOrgCode} where \"RECORD\" = #{equipCode}")