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/mapper/JgChangeRegistrationUnitMapper.java

@@ -51,4 +51,6 @@ public interface JgChangeRegistrationUnitMapper extends CustomBaseMapper<JgChang
     String queryEquipIdBySeq(@Param("sequenceNbr") long sequenceNbr);
 
     List<CompanyEquipCountDto> queryForFlowingEquipList();
+
+    List<Map<String, Object>> getEstateUnitInfo(List<String> records);
 }

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

@@ -126,4 +126,21 @@
           and a.audit_status  in ('三级待受理', '二级待受理', '一级待受理')
         GROUP BY a.use_unit_credit_code
     </select>
+
+    <select id="getEstateUnitInfo" resultType="java.util.Map">
+        SELECT
+        CONCAT(jui.ESTATE_UNIT_CREDIT_CODE, '_', jui.ESTATE_UNIT_NAME) AS estateUnitName
+        FROM
+        idx_biz_jg_register_info ri
+        LEFT JOIN idx_biz_jg_use_info jui on ri.RECORD = jui.RECORD
+        WHERE ri."EQU_CATEGORY" = '2300'
+        AND jui."DATA_SOURCE" like 'jg%'
+        AND ri.whether_vehicle_cylinder = 1
+        AND jui."ESTATE_UNIT_NAME" IS NOT NULL
+        AND jui."ESTATE_UNIT_CREDIT_CODE" IS NOT NULL
+        AND jui.record in
+        <foreach collection="records" item="record" open="(" close=")" separator=",">
+            #{record}
+        </foreach>
+    </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/controller/JgChangeRegistrationUnitController.java

@@ -245,4 +245,15 @@ public class JgChangeRegistrationUnitController extends BaseController {
         return ResponseHelper.buildResponse("ok");
     }
 
+    /**
+     * 根据使用登记证编号查询设备信息
+     * @param record 使用登记证编号
+     * @return 设备信息
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @GetMapping(value = "/queryEquipInfoByRegistrationCode")
+    @ApiOperation(httpMethod = "GET", value = "根据使用登记证编号查询设备信息", notes = "根据使用登记证编号查询设备信息")
+    public ResponseModel<Map<String, Object>> queryEquipInfoByRegistrationCode(@RequestParam(value = "record") String record) {
+        return ResponseHelper.buildResponse(jgChangeRegistrationUnitServiceImpl.queryEquipInfoByRegistrationCode(record));
+    }
 }

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

@@ -197,22 +197,18 @@ public class JgChangeRegistrationUnitServiceImpl extends BaseService<JgChangeReg
 
     @Autowired
     JgUseRegistrationManageServiceImpl useRegistrationManageService;
-
     @Autowired
     private TzBaseEnterpriseInfoMapper tzBaseEnterpriseInfoMapper;
     @Autowired
     private IdxBizJgProjectContraptionServiceImplService projectContraptionService;
-
     @Autowired
     private EventPublisher eventPublisher;
-
     @Autowired
     private JgResumeInfoServiceImpl jgResumeInfoService;
     @Autowired
     private IdxBizJgSupervisionInfoMapper idxBizJgSupervisionInfoMapper;
-
     @Autowired
-    private CommonMapper commonMapper;
+    private JgUseRegistrationManageServiceImpl jgUseRegistrationManageService;
 
     /**
      * 根据sequenceNbr查询：1、查询单位变更信息，2、查询使用登记证列表
@@ -3660,4 +3656,35 @@ public class JgChangeRegistrationUnitServiceImpl extends BaseService<JgChangeReg
         commonServiceImpl.saveExecuteFlowData2Redis(dto.getInstanceId(), this.buildInstanceRuntimeData(registration));
         this.delRepeatUseEquipData(registration.getApplyNo(), registration.getStatus(), registration.getNewUseUnitCreditCode());
     }
+
+    @ResultFieldMapping({@ResultFieldMapping.ResultFieldMap(sourceField = "estateUnitCode", targetField = "estateUnitSeq", serviceClass = CommonServiceImpl.class, queryMethod = "queryTcmUnitSeqByCreditCode", secondParamValue = "CQ")})
+    public Map<String, Object> queryEquipInfoByRegistrationCode(String useRegistrationCode) {
+        HashMap<String, Object> map = new HashMap<>();
+        map.put("useRegistrationCode", useRegistrationCode);
+        JgUseRegistrationManage registrationManage =
+                jgUseRegistrationManageService.lambdaQuery()
+                        .eq(JgUseRegistrationManage::getUseRegistrationCode, useRegistrationCode)
+                        .eq(JgUseRegistrationManage::getIsDelete, 0)
+                        .last("LIMIT 1")
+                        .one();
+        List<JSONObject> jsonObjects = registrationManage == null ? Collections.emptyList():
+                Optional.ofNullable(jgUseRegistrationManageService.queryEquByCertificateSeq(registrationManage.getSequenceNbr())
+                ).orElse(Collections.emptyList());
+        if (!org.springframework.util.ObjectUtils.isEmpty(jsonObjects)) {
+            List<String> records = jsonObjects.stream().map(a -> String.valueOf(a.get("SEQUENCE_NBR"))).collect(Collectors.toList());
+            List<Map<String, Object>> equList = this.getBaseMapper().getEstateUnitInfo(records);
+            String estateUnitName = equList.stream()
+                    .map(e -> e.get("estateUnitName"))
+                    .filter(Objects::nonNull)
+                    .filter(String.class::isInstance)
+                    .map(String.class::cast)
+                    .findFirst()
+                    .orElse("");
+            if (!ValidationUtil.isEmpty(estateUnitName) && estateUnitName.contains("_")) {
+                map.put("estateUnitCode", estateUnitName.split("_")[0]);
+                map.put("estateUnitName", estateUnitName.split("_")[1]);
+            }
+        }
+        return map;
+    }
 }
\ No newline at end of file

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

@@ -16,10 +16,14 @@ import com.yeejoin.amos.boot.biz.common.bo.ReginParams;
 import com.yeejoin.amos.boot.biz.common.enums.TcmUnitTypeEnum;
 import com.yeejoin.amos.boot.biz.common.utils.RedisKey;
 import com.yeejoin.amos.boot.biz.common.utils.RedisUtils;
+import com.yeejoin.amos.boot.module.common.api.service.ICompensateFlowDataOfRedis;
 import com.yeejoin.amos.boot.module.common.biz.refresh.DataRefreshEvent;
 import com.yeejoin.amos.boot.module.jg.api.dto.*;
 import com.yeejoin.amos.boot.module.jg.api.entity.*;
-import com.yeejoin.amos.boot.module.jg.api.enums.*;
+import com.yeejoin.amos.boot.module.jg.api.enums.BusinessTypeEnum;
+import com.yeejoin.amos.boot.module.jg.api.enums.CompanyTypeEnum;
+import com.yeejoin.amos.boot.module.jg.api.enums.VehicleApanageEnum;
+import com.yeejoin.amos.boot.module.jg.api.enums.WorkFlowStatusEnum;
 import com.yeejoin.amos.boot.module.jg.api.mapper.JgChangeVehicleRegistrationUnitMapper;
 import com.yeejoin.amos.boot.module.jg.api.service.IJgChangeVehicleRegistrationUnitService;
 import com.yeejoin.amos.boot.module.jg.api.vo.SortVo;
@@ -29,7 +33,6 @@ import com.yeejoin.amos.boot.module.jg.biz.context.FlowingEquipRedisContext;
 import com.yeejoin.amos.boot.module.jg.biz.edit.permission.FillingEditPermForCurrentUser;
 import com.yeejoin.amos.boot.module.jg.biz.event.publisher.EventPublisher;
 import com.yeejoin.amos.boot.module.jg.biz.feign.TzsServiceFeignClient;
-import com.yeejoin.amos.boot.module.common.api.service.ICompensateFlowDataOfRedis;
 import com.yeejoin.amos.boot.module.ymt.api.entity.*;
 import com.yeejoin.amos.boot.module.ymt.api.enums.ApplicationFormTypeEnum;
 import com.yeejoin.amos.boot.module.ymt.api.enums.EquimentEnum;
@@ -865,13 +868,7 @@ public class JgChangeVehicleRegistrationUnitServiceImpl extends BaseService<JgCh
         return jgUseRegistrationManageService.queryUseRegistrationManagePage(page, dto, null);
     }
 
-    @ResultFieldMapping({
-            @ResultFieldMapping.ResultFieldMap(sourceField = "estateUnitCode",
-                    targetField = "estateUnitSeq",
-                    serviceClass = CommonServiceImpl.class,
-                    queryMethod = "queryTcmUnitSeqByCreditCode",
-                    secondParamValue = "CQ")
-    })
+    @ResultFieldMapping({@ResultFieldMapping.ResultFieldMap(sourceField = "estateUnitCode", targetField = "estateUnitSeq", serviceClass = CommonServiceImpl.class, queryMethod = "queryTcmUnitSeqByCreditCode", secondParamValue = "CQ")})
     public Map<String, Object> getEquList(String useRegistrationCode) {
         HashMap<String, Object> map = new HashMap<>();
         map.put("useRegistrationCode", useRegistrationCode);