Merge branch 'develop_tzs_register_to_0715' of…

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

@@ -2,6 +2,7 @@ package com.yeejoin.amos.boot.module.jg.api.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yeejoin.amos.boot.module.jg.api.dto.CompanyEquipCountDto;
 import com.yeejoin.amos.boot.module.jg.api.dto.JgVehicleInformationDto;
 import com.yeejoin.amos.boot.module.jg.api.entity.JgVehicleInformation;
 import com.yeejoin.amos.boot.module.jg.api.vo.SortVo;
@@ -39,4 +40,6 @@ public interface JgVehicleInformationMapper extends BaseMapper<JgVehicleInformat
 
     @Select("select name from tz_equipment_category where code=#{code}")
     String getEquCategoryNameByCode(String code);
+
+    List<CompanyEquipCountDto> queryForFlowingEquipList();
 }

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

@@ -192,23 +192,24 @@
         ORDER BY INSPECT_DATE desc LIMIT 1
     </select>
     <select id="getUseDetail" resultType="java.util.Map">
-        SELECT USE_UNIT_NAME as useUnitName,
-               USE_UNIT_CREDIT_CODE as useUnitCreditCode,
-               USE_PLACE as usePlace,
-               SAFETY_MANAGER as safetyManager,
-               SAFETY_MANAGER_CODE as safetyManagerCode,
-               PHONE as phone,
-               concat(ESTATE_UNIT_CREDIT_CODE, '_', ESTATE_UNIT_NAME)    as estateUnitName,
+        SELECT ibjui.USE_UNIT_NAME as useUnitName,
+                ibjui.USE_UNIT_CREDIT_CODE as useUnitCreditCode,
+                ibjui.USE_PLACE as usePlace,
+                ibjui.SAFETY_MANAGER as safetyManager,
+                ibjui.SAFETY_MANAGER_CODE as safetyManagerCode,
+               concat(tzi.sequence_nbr,'_',SAFETY_MANAGER) as safetyManagerSeq,
+               ibjui."PHONE" as phone,
+               concat(ibjui.ESTATE_UNIT_CREDIT_CODE, '_', ibjui.ESTATE_UNIT_NAME)    as estateUnitName,
 --                ESTATE_UNIT_NAME as estateUnitName,
 --                ESTATE_UNIT_CREDIT_CODE as estateUnitCreditCode,
-               ADDRESS as address,
-               PROVINCE as province,
-               CITY as city,
-               COUNTY as county,
-               USE_INNER_CODE as useInnerCode,
-               LONGITUDE_LATITUDE as longitudeLatitude,
-               FACTORY_USE_SITE_STREET as factoryUseSiteStreet
-        FROM "idx_biz_jg_use_info"  where RECORD = #{id}
+                ibjui.ADDRESS as address,
+                ibjui.PROVINCE as province,
+                ibjui.CITY as city,
+                ibjui.COUNTY as county,
+                ibjui.USE_INNER_CODE as useInnerCode,
+                ibjui.LONGITUDE_LATITUDE as longitudeLatitude,
+                ibjui.FACTORY_USE_SITE_STREET as factoryUseSiteStreet
+        FROM "idx_biz_jg_use_info"  ibjui left join tzs_user_info tzi on ibjui."PHONE" = tzi."phone"  where RECORD = #{id}
     </select>
     <select id="getEquipListPage" resultType="java.util.Map">
         SELECT jri.EQU_CODE as equCode,

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

@@ -261,5 +261,13 @@
         </foreach>
         ORDER BY ui.REC_DATE DESC
     </select>
-
+    <select id="queryForFlowingEquipList" resultType="com.yeejoin.amos.boot.module.jg.api.dto.CompanyEquipCountDto">
+        select a.use_unit_credit_code as companyCode,
+               group_concat(b.equ_id) as records
+        from tzs_jg_vehicle_information a,
+             tzs_jg_vehicle_information_eq b
+        where a.sequence_nbr = b.vehicle_id
+          and a.status in ('三级待受理', '二级待受理', '一级待受理')
+        GROUP BY a.use_unit_credit_code
+    </select>
 </mapper>

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

@@ -1696,6 +1696,7 @@ public class JgUseRegistrationServiceImpl extends BaseService<JgUseRegistrationD
             detail.putAll(inspectDetail);
         }
         if (!ObjectUtils.isEmpty(useDetail)) {
+            useDetail.put("safetyManager", useDetail.get("safetyManagerSeq"));
             detail.putAll(useDetail);
         }
         if (!ObjectUtils.isEmpty(desDetail)) {

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

+package com.yeejoin.amos.boot.module.jg.biz.service.impl;
+
+import com.yeejoin.amos.boot.module.jg.api.dto.CompanyEquipCountDto;
+import com.yeejoin.amos.boot.module.jg.api.mapper.JgMaintainNoticeMapper;
+import com.yeejoin.amos.boot.module.jg.api.mapper.JgVehicleInformationMapper;
+import lombok.extern.slf4j.Slf4j;
+import org.redisson.api.RBucket;
+import org.redisson.api.RedissonClient;
+import org.springframework.stereotype.Component;
+
+import java.util.Arrays;
+import java.util.List;
+import java.util.Set;
+import java.util.stream.Collectors;
+
+/**
+ * @author Administrator
+ */
+@Component
+@Slf4j
+public class JgVehicleInformationEquipUsedCheckImpl extends BaseEquipUsedCheckService {
+
+    private RedissonClient redissonClient;
+
+    private String bizType = "vehicleInformation";
+
+    private JgVehicleInformationMapper mapper;
+
+    public JgVehicleInformationEquipUsedCheckImpl(RedissonClient redissonClient, JgVehicleInformationMapper mapper) {
+        this.redissonClient = redissonClient;
+        this.mapper = mapper;
+    }
+
+
+    @Override
+    public RedissonClient getRedisClient() {
+        return redissonClient;
+    }
+
+    @Override
+    public String getApplyBizType() {
+        return bizType;
+    }
+
+
+    @Override
+    public void init() {
+        // 初始化已经完成或者在流程中安装告知的设备数据
+        List<CompanyEquipCountDto> companyEquipCountDtos = mapper.queryForFlowingEquipList();
+        companyEquipCountDtos.forEach(c -> {
+            RBucket<Set<String>> rBucket = redissonClient.getBucket(getFlowingEquipRedisKey(c.getCompanyCode(), bizType));
+            rBucket.set(Arrays.stream(c.getRecords().split(",")).collect(Collectors.toSet()));
+        });
+    }
+}

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

@@ -380,10 +380,8 @@ public class DPSubServiceImpl {
         JSONObject param = tab.getJSONObject("param");
         jsonObject.put("type", "text");
         jsonObject.put("value", value);
-        if (!ValidationUtil.isEmpty(paramFieldKeys)){
-            if (((JSONArray) paramFieldKeys).contains(fieldKey)){
-                jsonObject.put("value", param.getString(fieldKey));
-            }
+        if (!ValidationUtil.isEmpty(paramFieldKeys) && ((JSONArray) paramFieldKeys).contains(fieldKey)){
+            jsonObject.put("value", param.getString(fieldKey));
         } else {
             if ("upload".equals(xObj.getString("componentKey"))) {
                 jsonObject.put("type", "img");
@@ -395,15 +393,13 @@ public class DPSubServiceImpl {
                 if (!ValidationUtil.isEmpty(value)) {
                     JSONObject attachmentUploadDatasObj = new JSONObject();
                     attachmentUploadDatasObj.put("value", value);
-                    String accept = JsonValueUtils.getValueByKey(xObj, "visualParams", "visualParams.accept").toString();
-                    if (accept.contains("doc") || accept.contains("docx") || accept.contains("pdf") || accept.contains("xls") || accept.contains("xlsx")) {
-                        attachmentUploadDatasObj.put("label", "附件");
+                    String accept = xObj.getString("accept");
+                    attachmentUploadDatasObj.put("label", JsonValueUtils.getValueByKey(xObj, "visualParams", "visualParams.label"));
+                    if (accept.contains("doc") || accept.contains("docx") || accept.contains("pdf") || accept.contains("xls") || accept.contains("xlsx")){
                         attachmentUploadDatasObj.put("type", "file");
-                    } else if (accept.contains("png") || accept.contains("img")) {
-                        attachmentUploadDatasObj.put("label", "证照");
+                    } else if(accept.contains("png") || accept.contains("img")){
                         attachmentUploadDatasObj.put("type", "img");
-                    } else if (accept.contains("mp4") || accept.contains("flv")) {
-                        attachmentUploadDatasObj.put("label", "视频");
+                    } else if(accept.contains("mp4") || accept.contains("flv")){
                         attachmentUploadDatasObj.put("type", "video");
                     }
                     attachmentUploadDatas.add(attachmentUploadDatasObj);
@@ -431,7 +427,7 @@ public class DPSubServiceImpl {
             }
         }
         if (!"attachmentUpload".equals(xObj.getString("componentKey"))){
-            datas.add(jsonObject); 
+            datas.add(jsonObject);
         }
         return datas;
     }