fix(jg):安装告知列查询别调整

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

@@ -283,4 +283,20 @@ public class JgInstallationNoticeDto extends BaseDto {
 
     @ApiModelProperty (value = "其他附件")
     private List<Map<String, Object>> otherAccessoriesList;
+
+    @ApiModelProperty(value = "告知书编号")
+    private String informNumber;
+
+    @ApiModelProperty(value = "96333码")
+    private String code96333;
+
+    @ApiModelProperty(value = "设备代码")
+    private String equCode;
+
+    @ApiModelProperty(value = "设备品种")
+    private String equDefine;
+
+    @ApiModelProperty(value = "设备类别")
+    private String equipCategory;
+
 }

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-api/src/main/java/com/yeejoin/amos/boot/module/jg/api/mapper/JgInstallationNoticeMapper.java

@@ -24,7 +24,7 @@ public interface JgInstallationNoticeMapper extends CustomBaseMapper<JgInstallat
      * @param type  类型：enterprise-企业端、supervision-监管端
      * @return 安装告知列表
      */
-    Page<JgInstallationNotice> queryForPage(Page<JgInstallationNotice> page, @Param("param") JgInstallationNoticeDto model, @Param("type") String type, @Param("orgCode") String orgCode);
+    Page<Map<String, Object>> queryForPage(Page<JgInstallationNotice> page, @Param("param") JgInstallationNoticeDto model, @Param("type") String type, @Param("orgCode") String orgCode);
 
     /**
      * 根据安装告知编号查询设备、设计、制造等信息

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

@@ -44,7 +44,7 @@ public interface IJgInstallationNoticeService extends IService<JgInstallationNot
      * @param type  类型：enterprise-企业端、supervision-监管端
      * @return 安装告知列表
      */
-    Page<JgInstallationNoticeDto> queryForJgInstallationNoticePage(Page<JgInstallationNotice> page, JgInstallationNoticeDto model, String type, ReginParams reginParams);
+    Page<Map<String, Object>> queryForJgInstallationNoticePage(Page<JgInstallationNotice> page, JgInstallationNoticeDto model, String type, ReginParams reginParams);
 
     /**
      * 批量删除

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

@@ -2,16 +2,16 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.yeejoin.amos.boot.module.jg.api.mapper.JgInstallationNoticeMapper">
 
-    <select id="queryForPage" resultType="com.yeejoin.amos.boot.module.jg.api.entity.JgInstallationNotice">
+    <select id="queryForPage" resultType="java.util.Map">
         select
         isn.sequence_nbr AS sequenceNbr,
         isn.apply_no AS applyNo,
         isn.supervisory_code AS supervisoryCode,
-        isn.notice_date AS noticeDate,
+        DATE_FORMAT(isn.notice_date,'%Y-%m-%d') AS noticeDate,
         isn.use_unit_name AS useUnitName,
         isn.receive_org_name AS receiveOrgName,
         isn.region_no AS regionNo,
-        isn.install_start_date AS installStartDate,
+        DATE_FORMAT(isn.install_start_date,'%Y-%m-%d') AS installStartDate,
         isn.address AS address,
         isn.notice_status AS noticeStatus,
         isn.install_unit_name AS installUnitName,
@@ -19,20 +19,27 @@
         isn.city_name AS cityName,
         isn.county_name AS countyName,
         isn.instance_id AS instanceId,
+        isn.inform_number AS informNumber,
         isn.promoter,
         isn.next_execute_ids AS nextExecuteIds,
         isn.instance_status AS instanceStatus,
-        isn.handle_date AS handleDate,
+        DATE_FORMAT(isn.handle_date,'%Y-%m-%d') AS handleDate,
+        other.CODE96333 AS code96333,
         (select name from tz_equipment_category ec WHERE ec.code = ri.equ_category) AS equList,
         isn.notice_report_url AS noticeReportUrl,
         isn.create_user_id as createUserId,
         isn.next_task_id AS nextTaskId,
         isn.next_execute_user_ids as nextExecuteUserIds,
-        concat(ibjui."PROVINCE_NAME", '', ibjui."CITY_NAME", '', ibjui."COUNTY_NAME", '', ibjui."STREET_NAME", '', ibjui."ADDRESS") as equAddress
+        ri.EQU_CODE AS equCode,
+        (select name from tz_equipment_category ec WHERE ec.code = ri.EQU_DEFINE) AS equDefine,
+        (SELECT name from tz_equipment_category  where  code = ri.EQU_LIST) AS equListName,
+        concat(ibjui."PROVINCE_NAME", '', ibjui."CITY_NAME", '', ibjui."COUNTY_NAME", '', ibjui."STREET_NAME") as equAddress,
+        ibjui."ADDRESS" as detailedAddress
         FROM tzs_jg_installation_notice isn
         LEFT JOIN tzs_jg_installation_notice_eq insEq on insEq.equip_transfer_id = isn.sequence_nbr
         LEFT JOIN idx_biz_jg_use_info ibjui on insEq.equ_id = ibjui.RECORD
         LEFT JOIN idx_biz_jg_register_info ri ON ri.record = insEq.equ_id
+        LEFT JOIN idx_biz_jg_other_info  other on other.RECORD = insEq.equ_id
         <where>
             isn.is_delete = false
             <if test="param != null ">
@@ -42,15 +49,47 @@
                 <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_credit_code = #{param.useUnitName}
-                </if>
-                <if test="param.installUnitName != null and param.installUnitName != ''">
-                    AND isn.install_unit_credit_code = #{param.installUnitName}
+                <if test="param.installUnitId != null and param.installUnitId != ''">
+                    AND isn.install_unit_credit_code = #{param.installUnitId}
                 </if>
                 <if test="param.noticeStatus != null and param.noticeStatus != ''">
                     AND isn.notice_status = #{param.noticeStatus}
                 </if>
+                <if test="param.noticeDate != null and param.noticeDate != ''">
+                    AND to_char(isn.notice_date, 'YYYY-MM-DD') LIKE concat('%', to_char(#{param.noticeDate}, 'YYYY-MM-DD'), '%')
+                </if>
+                <if test="param.informNumber != null and param.informNumber != ''">
+                    AND isn."inform_number" LIKE concat('%',#{param.informNumber},'%')
+                </if>
+                <if test="param.supervisoryCode != null and param.supervisoryCode != ''">
+                    AND isn."supervisory_code" LIKE concat('%',#{param.supervisoryCode},'%')
+                </if>
+                <if test="param.code96333 != null and param.code96333 != ''">
+                    AND other."CODE96333" LIKE concat('%',#{param.code96333},'%')
+                </if>
+                <if test="param.equCode != null and param.equCode != ''">
+                    AND ri."EQU_CODE" LIKE concat('%',#{param.equCode},'%')
+                </if>
+                <if test="param.equList != null and param.equList != ''">
+                    AND ri."EQU_LIST" = #{param.equList}
+                </if>
+                <if test="param.equipCategory != null and param.equipCategory != ''">
+                    AND ri."equ_category" = #{param.equipCategory}
+                </if>
+                <if test="param.equDefine != null and param.equDefine != ''">
+                    AND ri."EQU_DEFINE" = #{param.equDefine}
+                </if>
+                <if test="param.equAddress != null and param.equAddress != ''">
+                    AND (
+                    ibjui."PROVINCE_NAME" LIKE CONCAT('%', #{param.equAddress}, '%')
+                    OR ibjui."CITY_NAME" LIKE CONCAT('%', #{param.equAddress}, '%')
+                    OR ibjui."COUNTY_NAME" LIKE CONCAT('%', #{param.equAddress}, '%')
+                    OR ibjui."STREET_NAME" LIKE CONCAT('%', #{param.equAddress}, '%')
+                    )
+                </if>
+                <if test="param.useUnitCreditCode != null and param.useUnitCreditCode != ''">
+                    AND isn.use_unit_credit_code = #{param.useUnitCreditCode}
+                </if>
             </if>
             <if test="type == 'supervision'">
                 AND (isn.receive_org_credit_code = #{orgCode} or isn.transfer_to_user_ids like concat('%',#{param.transferToUserIds},'%'))
@@ -88,9 +127,9 @@
             isn.use_unit_name AS useUnitName,
             isn.inform_number AS informNumber,
             isn.other_accessories AS otherAccessories,
-            (select name from tz_equipment_category tec2 where ri."EQU_DEFINE"::text = tec2.code::text) AS equCategory,
-            (select name from tz_equipment_category tec1 where ri."EQU_LIST"::text = tec1.code::text) AS equList,
-            (select name from tz_equipment_category tec where ri."EQU_CATEGORY"::text = tec.code::text) AS equDefine,
+            tec2.name                       AS equCategory,
+            tec1.name                       AS equList,
+            tec.name                        AS equDefine,
             if(ri.EQU_CODE is null or ri.EQU_CODE = 'null', '', ri.EQU_CODE) AS equRegisterCode,
             re.equ_id as equId,
             ri.PRODUCT_NAME AS productName,
@@ -118,19 +157,25 @@
             fi.factory_standard AS factoryStandard,
             fi.product_quality_yield_prove AS productQualityYieldProve,
             fi.ins_use_maintain_explain AS insUseMaintainExplain,
-            (select useUnit.use_contact from tz_base_enterprise_info useUnit Where useUnit.use_unit_code = isn.use_unit_credit_code) AS safetyManager,
-            (select useUnit.contact_phone from tz_base_enterprise_info useUnit where useUnit.use_unit_code = isn.use_unit_credit_code) AS safetyManagerPhone,
-            (select useUnit.use_code from tz_base_enterprise_info useUnit Where useUnit.use_unit_code = isn.use_unit_credit_code) AS useCode,
-            (select idi.INSPECT_REPORT from idx_biz_jg_inspection_detection_info idi Where idi.record = re.equ_id) as inspectReport,
-            (select useUnit.address from tz_base_enterprise_info useUnit Where useUnit.use_unit_code = isn.use_unit_credit_code) as useUnitLeaderAddress,
-            (select use_code from tz_base_enterprise_info tbei Where tbei.use_code = isn.install_unit_credit_code) AS installUnitCreditCode,
-            (select address from tz_base_enterprise_info tbei Where tbei.use_code = isn.install_unit_credit_code) AS installUnitAddress
+            useUnit.use_contact AS safetyManager,
+            useUnit.contact_phone AS safetyManagerPhone,
+            useUnit.use_code AS useCode,
+            installUnit.use_code AS installUnitCreditCode,
+            useUnit.address as useUnitLeaderAddress,
+            re.equ_id as equId,
+            installUnit.address installUnitAddress,
+            (select idi.INSPECT_REPORT from idx_biz_jg_inspection_detection_info idi Where idi.record = re.equ_id ORDER BY idi.INSPECT_DATE desc LIMIT 1) as inspectReport
             FROM
             tzs_jg_installation_notice isn
         LEFT JOIN tzs_jg_installation_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 tz_base_enterprise_info useUnit ON useUnit.use_unit_code = isn.use_unit_credit_code
+        LEFT JOIN tz_base_enterprise_info installUnit ON installUnit.use_code = isn.install_unit_credit_code
+        LEFT JOIN amos_tzs_biz.tz_equipment_category tec ON ri."EQU_CATEGORY"::text = tec.code::text
+        LEFT JOIN amos_tzs_biz.tz_equipment_category tec1 ON ri."EQU_LIST"::text = tec1.code::text
+        LEFT JOIN amos_tzs_biz.tz_equipment_category tec2 ON ri."EQU_DEFINE"::text = tec2.code::text
         WHERE
             isn.sequence_nbr = #{sequenceNbr}
             LIMIT 1

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

@@ -162,6 +162,20 @@ public class CommonController extends BaseController {
         return ResponseHelper.buildResponse(commonService.getSecurityAdmin(type, useUnitCode));
     }
 
+    /**
+     * 设备分类
+     * @param type 1，设备种类  2，设备类别  3，设备品种
+     * @return
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @GetMapping(value = "/equipmentClassification")
+    @ApiOperation(httpMethod = "GET", value = "设备分类", notes = "1，设备种类  2，设备类别  3，设备品种")
+    public ResponseModel<List<EquipmentCategory>> equipmentClassification(@RequestParam(value = "type") String type) {
+        return ResponseHelper.buildResponse(commonService.equipmentClassification(type));
+    }
+
+
+
 
     /**
      * 查询安全管理员的基本信息

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

@@ -137,10 +137,11 @@ public class JgInstallationNoticeController extends BaseController {
     @TycloudOperation(ApiLevel = UserType.AGENCY)
     @PostMapping(value = "/page")
     @ApiOperation(httpMethod = "GET", value = "安装告知分页查询", notes = "安装告知分页查询")
-    public ResponseModel<Page<JgInstallationNoticeDto>> queryForPage(
+    public ResponseModel<Page<Map<String, Object>>> queryForPage(
             @ApiParam(value = "当前页码", required = true) @RequestParam(value = "current", defaultValue = "1") int current,
             @ApiParam(value = "每页大小", required = true) @RequestParam(value = "size", defaultValue = "20") int size,
-            @ApiParam(value = "类型：enterprise-企业端、supervision-监管端", required = true) @RequestParam(value = "type", defaultValue = "enterprise") String type,
+            @ApiParam(value = "类型：enterprise-企业端、supervision-监管端", required = true)
+            @RequestParam(value = "type", defaultValue = "enterprise") String type,
             @RequestBody(required = false) JgInstallationNoticeDto model
     ) {
         Page<JgInstallationNotice> page = new Page<>(current, size);

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

@@ -147,6 +147,13 @@ public interface ICommonService {
     Integer countEquipInUseTimesForDel(String record);
 
     /**
+     * 设备分类
+     * @param type 1，设备种类  2，设备类别  3，设备品种
+     * @return
+     */
+    List<EquipmentCategory> equipmentClassification(String type);
+
+    /**
      * 套打使用标志生成
      * @param  useFlagParamDto 参数
      * @param response 文件信息

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

@@ -90,6 +90,7 @@ import java.net.URLEncoder;
 import java.nio.file.Files;
 import java.util.*;
 import java.util.concurrent.TimeUnit;
+import java.util.regex.Pattern;
 import java.util.stream.Collectors;
 
 /**
@@ -1665,6 +1666,29 @@ public class CommonServiceImpl implements ICommonService {
         }
     }
 
+    /**
+     * 设备分类
+      * @param type 1，设备种类  2，设备类别  3，设备品种
+     * @return
+     */
+    @Override
+    public List<EquipmentCategory> equipmentClassification(String type){
+        List<EquipmentCategory> categoryList = equipmentCategoryMapper.selectList(new QueryWrapper<>());
+        List<EquipmentCategory> result = Collections.emptyList();
+        switch (type){
+            case "1":
+                result = categoryList.stream().filter(category -> Pattern.compile("^[^\\D0]*000$").matcher(category.getCode()).matches()).collect(Collectors.toList());
+                break;
+            case "2":
+                result = categoryList.stream().filter(category -> Pattern.compile("^[^\\D0]*00$").matcher(category.getCode()).matches()).collect(Collectors.toList());
+                break;
+            case "3":
+                result = categoryList.stream().filter(category -> Pattern.compile("^[^\\D0]*0$").matcher(category.getCode()).matches()).collect(Collectors.toList());
+                break;
+        }
+        return result;
+    }
+
     @Override
     public void fightUseFlagGenerate(UseFlagParamDto useFlagParamDto, HttpServletResponse response) {
         Objects.requireNonNull(useFlagParamDto, "参数不能为空");

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

@@ -1188,15 +1188,15 @@ public class IdxBizJgRegisterInfoServiceImpl extends BaseService<IdxBizJgRegiste
                 boolMust.must(nullOrEmptyQuery);
             } else if (ValidationUtil.equals(queryType, "WB")) {
                 // 查询 维保备案【可绑定设备列表】【(EQU_STATE=== null ||  ""）】
-                BoolQueryBuilder nullOrEmptyQuery = QueryBuilders.boolQuery()
-                        .mustNot(QueryBuilders.wildcardQuery("EQU_STATE", "*"));
-                boolMust.must(nullOrEmptyQuery);
+                BoolQueryBuilder wbBuilder = QueryBuilders.boolQuery();
+                wbBuilder.mustNot(QueryBuilders.existsQuery("EQU_STATE"));
+                boolMust.must(wbBuilder);
             } else if (!ObjectUtils.isEmpty(queryType) && ValidationUtil.equals(queryType, "SY")) {
-                // 查询 使用登记【可选设备列表】【(EQU_STATUS=== null || "" ) && (USE_ORG_CODE ==="" || null)】
-                BoolQueryBuilder nullOrEmptyQuery = QueryBuilders.boolQuery()
-                        .mustNot(QueryBuilders.wildcardQuery("EQU_STATE", "*"))
-                        .mustNot(QueryBuilders.wildcardQuery("USE_ORG_CODE", "*"));
-                boolMust.must(nullOrEmptyQuery);
+                // 查询 使用登记【可选设备列表】【(EQU_STATUS=== null || "" ) && (USE_ORG_CODE（使用登记证编号） ==="" || null)】
+                BoolQueryBuilder syBuilder = QueryBuilders.boolQuery();
+                syBuilder.mustNot(QueryBuilders.existsQuery("EQU_STATE"));
+                syBuilder.mustNot(QueryBuilders.wildcardQuery("USE_ORG_CODE", "*"));
+                boolMust.must(syBuilder);
             }
         }
 

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

@@ -386,28 +386,21 @@ public class JgInstallationNoticeServiceImpl extends BaseService<JgInstallationN
      * @return 安装告知列表
      */
     @Override
-    public Page<JgInstallationNoticeDto> queryForJgInstallationNoticePage(Page<JgInstallationNotice> page, JgInstallationNoticeDto model, String type , ReginParams reginParams) {
+    public Page<Map<String, Object>> queryForJgInstallationNoticePage(Page<JgInstallationNotice> page, JgInstallationNoticeDto model, String type , ReginParams reginParams) {
 
         String orgCode;
         orgCode = reginParams.getCompany().getCompanyCode();
         model.setTransferToUserIds(reginParams.getUserModel().getUserId());
-        Page<JgInstallationNotice> noticePage = jgInstallationNoticeMapper.queryForPage(page, model, type, orgCode);
-
-        // 将Page<JgInstallationNotice>转化为Page<JgInstallationNoticeDto>
-        Page<JgInstallationNoticeDto> noticeDtoPage = new Page<>();
-        BeanUtils.copyProperties(noticePage, noticeDtoPage, "records");
-        List<JgInstallationNoticeDto> records = noticePage.getRecords().stream().map(notice -> {
-            JgInstallationNoticeDto noticeDto = new JgInstallationNoticeDto();
-            BeanUtils.copyProperties(notice, noticeDto);
-            if (Objects.nonNull(notice.getNoticeStatus())) {
-                String noticeStatusDesc = FlowStatusEnum.getNameByType(Long.valueOf(notice.getNoticeStatus()));
-                noticeDto.setNoticeStatusDesc(noticeStatusDesc);
-            }
-            return noticeDto;
+        Page<Map<String, Object>> noticePage = jgInstallationNoticeMapper.queryForPage(page, model, type, orgCode);
+        List<Map<String, Object>> mappedRecords = noticePage.getRecords().stream().peek(notice -> {
+            Optional<Long> noticeStatusOpt = Optional.ofNullable((String) notice.get("noticeStatus")).map(Long::valueOf);
+            noticeStatusOpt.ifPresent(status -> {
+                String noticeStatusDesc = FlowStatusEnum.getNameByType(status);
+                notice.put("noticeStatusDesc", noticeStatusDesc);
+            });
         }).collect(Collectors.toList());
-        noticeDtoPage.setRecords(records);
-
-        return noticeDtoPage;
+        noticePage.setRecords(mappedRecords);
+        return noticePage;
     }
 
     /**
@@ -490,7 +483,7 @@ public class JgInstallationNoticeServiceImpl extends BaseService<JgInstallationN
         Map<String, Object> placeholders = new HashMap<>();
         placeholders.put("doMain", TZSDOMAIN);
         placeholders.put("installUnitName", getValue.apply("installUnitName"));
-        placeholders.put("informNumber", "".equals(getValue.apply("informNumber")) ?  getValue.apply("applyNo") : getValue.apply("informNumber"));
+        placeholders.put("informNumber", getValue.apply("informNumber"));
         placeholders.put("productName", getValue.apply("productName"));
         placeholders.put("equipType", getValue.apply("equType"));
         placeholders.put("equipCode", getValue.apply("equRegisterCode"));