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

@@ -178,7 +178,7 @@ public class JgVehicleInformationController extends BaseController {
 	 */
 	@TycloudOperation(ApiLevel = UserType.AGENCY)
 	@GetMapping(value = "/export")
-	@ApiOperation(httpMethod = "GET", value = "导出车用气瓶使用登记证", notes = "导出车用气瓶使用登记证")
+	@ApiOperation(httpMethod = "GET", value = "导出车用气瓶使用标志、使用登记证", notes = "普打、套打")
 	public void exportImageZip(HttpServletResponse response, @RequestParam("sequenceNbr") String sequenceNbr,
 							   @RequestParam(value = "printType", defaultValue = "0") String printType) {
 		jgVehicleInformationServiceImpl.exportVehicleUseRegistrationCertificate(sequenceNbr, response, printType);

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

@@ -70,40 +70,44 @@ public abstract class BaseEquipUsedCheckService implements IEquipUsedCheck {
      * 删除流程中的数据，释放redis空间（异常处理及驳回到发起节点、撤回到发起节点、完成时时进行）
      *
      * @param records  设备唯一标识
-     * @param companyCode 登录人的公司代码
+     * @param redisKey key
      */
     @Override
-    public void delDataForCheckEquipRepeatUsed(List<String> records, String companyCode) {
+    public void delDataForCheckWithKey(List<String> records, String redisKey) {
+        delRedisData(records, redisKey, getRedisClient());
+    }
+
+    @Override
+    public Set<String> getEquipInFlow(String companyCode) {
         RBucket<Set<String>> rBucket = getRedisClient().getBucket(this.getFlowingEquipRedisKey(companyCode, getApplyBizType()));
-        Set<String> equipListOfUsed = rBucket.get();
-        equipListOfUsed = equipListOfUsed.stream().filter(record -> !records.contains(record)).collect(Collectors.toSet());
-        rBucket.set(equipListOfUsed);
+        return rBucket.get();
     }
 
     /**
      * 删除流程中的数据，释放redis空间（异常处理及驳回到发起节点、撤回到发起节点、完成时时进行）
      *
      * @param records     设备唯一标识
-     * @param redisKey key
+     * @param companyCode 登录人的公司代码
      */
     @Override
-    public void delDataForCheckWithKey(List<String> records, String redisKey) {
-        delRedisData(records, redisKey, getRedisClient());
-    }
-
-    @Override
-    public Set<String> getEquipInFlow(String companyCode) {
+    public void delDataForCheckEquipRepeatUsed(List<String> records, String companyCode) {
         RBucket<Set<String>> rBucket = getRedisClient().getBucket(this.getFlowingEquipRedisKey(companyCode, getApplyBizType()));
-        return rBucket.get();
+        Set<String> equipListOfUsed = rBucket.get();
+        if(equipListOfUsed != null){
+            equipListOfUsed = equipListOfUsed.stream().filter(record -> !records.contains(record)).collect(Collectors.toSet());
+            rBucket.set(equipListOfUsed);
+        }
     }
 
 
     private void delRedisData(List<String> records, String redisKey, RedissonClient redissonClient) {
         RBucket<Set<String>> rBucket = redissonClient.getBucket(redisKey);
         Set<String> equipListOfUsed = rBucket.get();
+        if(equipListOfUsed != null){
             equipListOfUsed = equipListOfUsed.stream().filter(record -> !records.contains(record)).collect(Collectors.toSet());
             rBucket.set(equipListOfUsed);
         }
+    }
 
     public abstract RedissonClient getRedisClient();
 

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

@@ -856,15 +856,6 @@ public class CommonServiceImpl implements ICommonService {
             throw new RuntimeException(e);
         }
 
-//        // 上传pdf至文件服务器
-//        String url = this.uploadFile(pdfFile);
-
-        // 删除临时文件
-//        try {
-//            Files.deleteIfExists(pdfFile.toPath());
-//        } catch (IOException e) {
-//            log.error("删除临时文件失败：{}", e);
-//        }
 
         try {
             byte[] bytes = file2byte(pdfFile);
@@ -906,7 +897,6 @@ public class CommonServiceImpl implements ICommonService {
         // 生成二维码,之前为设备监管码，调整为申请单号
         String qrCode = ImageUtils.generateQRCode((String) map.getOrDefault("applyNo", ""), 100, 100);
         map.put("supervisoryCode", qrCode);  // 监管二维码 代码优化
-
         this.fillParamValueToPdf(map, response, "templates/use-registration-model.pdf", "套打使用登记证.pdf", 12.0f);
     }
 
@@ -948,7 +938,7 @@ public class CommonServiceImpl implements ICommonService {
      * @param printFileName 生成文件名称
      * @param textSize      字体大小
      */
-    private void fillParamValueToPdf(Map<String, Object> map, HttpServletResponse response, String pathResource, String printFileName, float textSize) {
+    void fillParamValueToPdf(Map<String, Object> map, HttpServletResponse response, String pathResource, String printFileName, float textSize) {
         // 读取资源文件夹下的模板
         ClassPathResource resource = new ClassPathResource(pathResource);
 

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

@@ -163,7 +163,7 @@ public class JgUseRegistrationServiceImpl extends BaseService<JgUseRegistrationD
      * @param auditPassDate   通过时间
      * @param exportParamsMap 参数map
      */
-    public static void getAuditPassedDate(Date auditPassDate, Map<String, Object> exportParamsMap) {
+    static void getAuditPassedDate(Date auditPassDate, Map<String, Object> exportParamsMap) {
         LocalDate today;
         if (ValidationUtil.isEmpty(auditPassDate)) {
             // 发证日期为空取当前时间

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

@@ -31,6 +31,7 @@ import com.yeejoin.amos.boot.module.jg.biz.config.LocalBadRequest;
 import com.yeejoin.amos.boot.module.jg.biz.dao.ESEquipmentCategory;
 import com.yeejoin.amos.boot.module.jg.biz.feign.TzsServiceFeignClient;
 import com.yeejoin.amos.boot.module.jg.biz.service.ICmWorkflowService;
+import com.yeejoin.amos.boot.module.jg.biz.utils.ImageUtils;
 import com.yeejoin.amos.boot.module.ymt.api.dto.ESEquipmentCategoryDto;
 import com.yeejoin.amos.boot.module.ymt.api.entity.*;
 import com.yeejoin.amos.boot.module.ymt.api.enums.ApplicationFormTypeEnum;
@@ -52,6 +53,7 @@ import org.redisson.api.RedissonClient;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.http.HttpStatus;
+import org.springframework.security.core.parameters.P;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.CollectionUtils;
@@ -130,6 +132,12 @@ public class JgVehicleInformationServiceImpl extends BaseService<JgVehicleInform
 
     private Map<String, Object> fillingMediumMap;
 
+    private static final String[] DEFAULT_KEYS = {
+            "useRegistrationCode", "useUnitName", "fullAddress", "equList", "equipDefine",
+            "equipCode", "equipCategory", "useInnerCode", "factoryNum", "giveOutYear",
+            "giveOutMonth", "giveOutDay"
+    };
+
 
     /**
      * 新增（提交）车用气瓶
@@ -950,11 +958,6 @@ public class JgVehicleInformationServiceImpl extends BaseService<JgVehicleInform
             populateEquipmentInformation(registerInfoList, exportParamsMap);
         }
 
-        //IdxBizJgUseInfo useInfo = idxBizJgUseInfoService.getOneData(vehicleInformationEqList.get(0).getEquId());
-        //if (useInfo != null && useInfo.getUseInnerCode() != null) {
-        //    exportParamsMap.put("useInnerCode", useInfo.getUseInnerCode());
-        //}
-
         List<IdxBizJgUseInfo> userInfoList = idxBizJgUseInfoService.list(new QueryWrapper<IdxBizJgUseInfo>().in("RECORD", vehicleInformationEqList.stream()
                 .map(JgVehicleInformationEq::getEquId)
                 .filter(Objects::nonNull)
@@ -984,25 +987,45 @@ public class JgVehicleInformationServiceImpl extends BaseService<JgVehicleInform
         this.generateReport(vehicleInformation, printType, exportParamsMap, response);
     }
 
+
+    private void generatePdfPrint(Map<String, Object> map, HttpServletResponse response) {
+        // 设置默认值
+        Arrays.stream(DEFAULT_KEYS).forEach(key -> map.computeIfAbsent(key, k -> ""));
+        // 生成二维码,之前为设备监管码，调整为申请单号
+        String qrCode = ImageUtils.generateQRCode((String) map.getOrDefault("applyNo", ""), 100, 100);
+        map.put("supervisoryCode", qrCode);
+        commonService.fillParamValueToPdf(map, response, "templates/use-registration-model-vehicle.pdf", "套打使用登记证.pdf", 12.0f);
+    }
+
     private void generateReport(JgVehicleInformation vehicleInformation, String printType, Map<String, Object> exportParamsMap, HttpServletResponse response) {
         switch (printType) {
             case "0":
+                // 使用登记证-普通打印--
                 commonService.generateCertificateReport(exportParamsMap, response);
                 break;
             case "1":
-                commonService.generatePdfPrint(exportParamsMap, response);
+                // 使用登记证-套打--
+                this.generatePdfPrint(exportParamsMap, response);
                 break;
             case "2":
+                // 使用标志-普通打印--
                 commonService.useFlagGenerate(buildUseFlagParam(vehicleInformation, exportParamsMap), response);
                 break;
             case "3":
-                commonService.fightUseFlagGenerate(buildUseFlagParam(vehicleInformation, exportParamsMap), response);
+                // 使用标志-套打--
+                commonService.fightUseFlagGenerate(this.setProductNameWithStatic(vehicleInformation, exportParamsMap), response);
                 break;
             default:
                 throw new BadRequest("Invalid print type");
         }
     }
 
+    private UseFlagParamDto setProductNameWithStatic(JgVehicleInformation vehicleInformation, Map<String, Object> exportParamsMap) {
+        UseFlagParamDto useFlagParamDto = buildUseFlagParam(vehicleInformation, exportParamsMap);
+        useFlagParamDto.setEquipDefine("车用气瓶");
+        return useFlagParamDto;
+    }
+
     private void populateEquipmentInformation(List<IdxBizJgRegisterInfo> registerInfoList, Map<String, Object> exportParamsMap) {
         Optional<IdxBizJgRegisterInfo> optionalRegisterInfo = registerInfoList.stream().findFirst();
         if (optionalRegisterInfo.isPresent()) {