diff --git a/casic-metering-dao/src/main/resources/mapper/business/BizBusinessDeviceMeasureApprovalMapper.xml b/casic-metering-dao/src/main/resources/mapper/business/BizBusinessDeviceMeasureApprovalMapper.xml index b13ce50..56a707f 100644 --- a/casic-metering-dao/src/main/resources/mapper/business/BizBusinessDeviceMeasureApprovalMapper.xml +++ b/casic-metering-dao/src/main/resources/mapper/business/BizBusinessDeviceMeasureApprovalMapper.xml @@ -90,7 +90,7 @@ WHERE template_name= #{templateName} AND template_type= #{coverModuleName} - AND template_desc =#{descn} + AND template_desc like concat('%',#{descn},'%') diff --git a/casic-metering-dao/src/main/resources/mapper/business/BizBusinessDeviceMeasureApprovalMapper.xml b/casic-metering-dao/src/main/resources/mapper/business/BizBusinessDeviceMeasureApprovalMapper.xml index b13ce50..56a707f 100644 --- a/casic-metering-dao/src/main/resources/mapper/business/BizBusinessDeviceMeasureApprovalMapper.xml +++ b/casic-metering-dao/src/main/resources/mapper/business/BizBusinessDeviceMeasureApprovalMapper.xml @@ -90,7 +90,7 @@ WHERE template_name= #{templateName} AND template_type= #{coverModuleName} - AND template_desc =#{descn} + AND template_desc like concat('%',#{descn},'%') diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/GenericEqptDataProvider.java b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/GenericEqptDataProvider.java index b17b574..871ddd6 100644 --- a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/GenericEqptDataProvider.java +++ b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/GenericEqptDataProvider.java @@ -1,7 +1,5 @@ package com.casic.missiles.service.Impl.eqpt; -import cn.hutool.core.bean.BeanUtil; -import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; import com.baomidou.mybatisplus.core.toolkit.ObjectUtils; @@ -12,30 +10,21 @@ import com.casic.missiles.mapper.business.BizBusinessDeviceMeasureApprovalMapper; import com.casic.missiles.mapper.equipment.BizEquipmentStandardCheckRecordApprovalMapper; import com.casic.missiles.model.business.BizBusinessDeviceMeasureApproval; -import com.casic.missiles.model.business.BizBusinessDeviceMeasureDataCalibrator; -import com.casic.missiles.model.equipment.BizEquipmentInfo; -import com.casic.missiles.model.equipment.BizEquipmentStandardCheckDataCalibrator; import com.casic.missiles.model.equipment.BizEquipmentStandardCheckRecordApproval; import com.casic.missiles.service.Impl.eqpt.standard.StandardEquipmentPrint; import com.casic.missiles.service.listeners.register.PrintFileRegister; -import com.casic.missiles.utils.SnowflakeUtil; import com.casic.missiles.utils.SpringContextUtil; -import com.gexin.fastjson.JSON; -import liquibase.pro.packaged.A; -import liquibase.pro.packaged.M; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; -import org.docx4j.wml.R; import org.springframework.stereotype.Component; -import java.text.SimpleDateFormat; import java.util.*; import java.util.concurrent.CompletableFuture; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; -import java.util.stream.Collectors; + /** * 通用的装置数据提供器 @@ -50,9 +39,6 @@ private final PrintFileRegister printFileRegister; - private static ThreadPoolExecutor threadPool = new ThreadPoolExecutor(4, 10, 100, - TimeUnit.SECONDS, new LinkedBlockingQueue<>(10)); - /** * 核查记录生成更新证书的任务 */ @@ -61,6 +47,7 @@ if (ObjectUtils.isEmpty(request) || StringUtils.isEmpty(request.getBelongStandardEquipment())) { throw new BusinessException(BusinessExceptionEnum.MEASURE_STANDARD_IS_NULL); } + log.info("check data is check,please wait ..."); //生成核查记录单 StandardEquipmentPrint standardEquipmentPrint = SpringContextUtil.getBean(request.getBelongStandardEquipment()); List checkCertificateFileList = standardEquipmentPrint.doCheckCertificateFile(request); @@ -89,6 +76,9 @@ * @param oldCertificateFile */ public void excuteMeasureTaskAsyn(Map map, Long id, String oldCertificateFile) { + ThreadPoolExecutor threadPool = new ThreadPoolExecutor(1, 2, 100, + TimeUnit.SECONDS, new LinkedBlockingQueue<>(2)); + log.info("measure data is check,please wait ..."); List customTemplateUrls = new ArrayList<>(); customTemplateUrls.add(oldCertificateFile); //生成证书报告的,需要改变为动态选择性 @@ -126,6 +116,8 @@ public void excuteCheckTaskAsyn(Map map, Long id, String oldCertificateFile) { List customTemplateUrls = new ArrayList<>(); customTemplateUrls.add(oldCertificateFile); + ThreadPoolExecutor threadPool = new ThreadPoolExecutor(1, 2, 100, + TimeUnit.SECONDS, new LinkedBlockingQueue<>(2)); //生成证书报告的 CompletableFuture certificateFutureTask = CompletableFuture.supplyAsync( () -> printFileRegister.registerPrintFile(MULTIFUNCTION_CHECK_DATA, "数据打印", null, map, true, null, customTemplateUrls), threadPool); @@ -155,6 +147,8 @@ * 生成更新证书的任务 */ public void measureCertificateTask(BizBusinessDeviceMeasureApproval request) { + ThreadPoolExecutor threadPool = new ThreadPoolExecutor(2, 2, 100, + TimeUnit.SECONDS, new LinkedBlockingQueue<>(2)); StandardEquipmentPrint equipmentPrint = getStandardEquipmentPrint(request); log.info("---111111111"); //生成证书报告的 @@ -172,7 +166,7 @@ List certificateFileUrl = certificateFutureTask.join(); String originalRecordFileUrl = originalFutureTask.join(); BizBusinessDeviceMeasureApprovalMapper bizBusinessMapper = SpringContextUtil.getBean(BizBusinessDeviceMeasureApprovalMapper.class); - log.info("----------------获取生成的数据结果"); + log.info("----------------get result orign is {},certificate is {}",originalRecordFileUrl,certificateFileUrl); if (CollectionUtils.isNotEmpty(certificateFileUrl) || StringUtils.isNotEmpty(originalRecordFileUrl)) { //生成证书文件 if (CollectionUtils.isNotEmpty(certificateFileUrl)) { @@ -192,6 +186,7 @@ throw new BusinessException(BusinessExceptionEnum.MEASURE_FILE_CREATE_FAILED); } } catch (Exception ex) { + log.info("---- data is exception, this is {}", ex); throw new BusinessException(BusinessExceptionEnum.MEASURE_APPROVAL_GET_FAILED); } }).join(); diff --git a/casic-metering-dao/src/main/resources/mapper/business/BizBusinessDeviceMeasureApprovalMapper.xml b/casic-metering-dao/src/main/resources/mapper/business/BizBusinessDeviceMeasureApprovalMapper.xml index b13ce50..56a707f 100644 --- a/casic-metering-dao/src/main/resources/mapper/business/BizBusinessDeviceMeasureApprovalMapper.xml +++ b/casic-metering-dao/src/main/resources/mapper/business/BizBusinessDeviceMeasureApprovalMapper.xml @@ -90,7 +90,7 @@ WHERE template_name= #{templateName} AND template_type= #{coverModuleName} - AND template_desc =#{descn} + AND template_desc like concat('%',#{descn},'%') diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/GenericEqptDataProvider.java b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/GenericEqptDataProvider.java index b17b574..871ddd6 100644 --- a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/GenericEqptDataProvider.java +++ b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/GenericEqptDataProvider.java @@ -1,7 +1,5 @@ package com.casic.missiles.service.Impl.eqpt; -import cn.hutool.core.bean.BeanUtil; -import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; import com.baomidou.mybatisplus.core.toolkit.ObjectUtils; @@ -12,30 +10,21 @@ import com.casic.missiles.mapper.business.BizBusinessDeviceMeasureApprovalMapper; import com.casic.missiles.mapper.equipment.BizEquipmentStandardCheckRecordApprovalMapper; import com.casic.missiles.model.business.BizBusinessDeviceMeasureApproval; -import com.casic.missiles.model.business.BizBusinessDeviceMeasureDataCalibrator; -import com.casic.missiles.model.equipment.BizEquipmentInfo; -import com.casic.missiles.model.equipment.BizEquipmentStandardCheckDataCalibrator; import com.casic.missiles.model.equipment.BizEquipmentStandardCheckRecordApproval; import com.casic.missiles.service.Impl.eqpt.standard.StandardEquipmentPrint; import com.casic.missiles.service.listeners.register.PrintFileRegister; -import com.casic.missiles.utils.SnowflakeUtil; import com.casic.missiles.utils.SpringContextUtil; -import com.gexin.fastjson.JSON; -import liquibase.pro.packaged.A; -import liquibase.pro.packaged.M; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; -import org.docx4j.wml.R; import org.springframework.stereotype.Component; -import java.text.SimpleDateFormat; import java.util.*; import java.util.concurrent.CompletableFuture; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; -import java.util.stream.Collectors; + /** * 通用的装置数据提供器 @@ -50,9 +39,6 @@ private final PrintFileRegister printFileRegister; - private static ThreadPoolExecutor threadPool = new ThreadPoolExecutor(4, 10, 100, - TimeUnit.SECONDS, new LinkedBlockingQueue<>(10)); - /** * 核查记录生成更新证书的任务 */ @@ -61,6 +47,7 @@ if (ObjectUtils.isEmpty(request) || StringUtils.isEmpty(request.getBelongStandardEquipment())) { throw new BusinessException(BusinessExceptionEnum.MEASURE_STANDARD_IS_NULL); } + log.info("check data is check,please wait ..."); //生成核查记录单 StandardEquipmentPrint standardEquipmentPrint = SpringContextUtil.getBean(request.getBelongStandardEquipment()); List checkCertificateFileList = standardEquipmentPrint.doCheckCertificateFile(request); @@ -89,6 +76,9 @@ * @param oldCertificateFile */ public void excuteMeasureTaskAsyn(Map map, Long id, String oldCertificateFile) { + ThreadPoolExecutor threadPool = new ThreadPoolExecutor(1, 2, 100, + TimeUnit.SECONDS, new LinkedBlockingQueue<>(2)); + log.info("measure data is check,please wait ..."); List customTemplateUrls = new ArrayList<>(); customTemplateUrls.add(oldCertificateFile); //生成证书报告的,需要改变为动态选择性 @@ -126,6 +116,8 @@ public void excuteCheckTaskAsyn(Map map, Long id, String oldCertificateFile) { List customTemplateUrls = new ArrayList<>(); customTemplateUrls.add(oldCertificateFile); + ThreadPoolExecutor threadPool = new ThreadPoolExecutor(1, 2, 100, + TimeUnit.SECONDS, new LinkedBlockingQueue<>(2)); //生成证书报告的 CompletableFuture certificateFutureTask = CompletableFuture.supplyAsync( () -> printFileRegister.registerPrintFile(MULTIFUNCTION_CHECK_DATA, "数据打印", null, map, true, null, customTemplateUrls), threadPool); @@ -155,6 +147,8 @@ * 生成更新证书的任务 */ public void measureCertificateTask(BizBusinessDeviceMeasureApproval request) { + ThreadPoolExecutor threadPool = new ThreadPoolExecutor(2, 2, 100, + TimeUnit.SECONDS, new LinkedBlockingQueue<>(2)); StandardEquipmentPrint equipmentPrint = getStandardEquipmentPrint(request); log.info("---111111111"); //生成证书报告的 @@ -172,7 +166,7 @@ List certificateFileUrl = certificateFutureTask.join(); String originalRecordFileUrl = originalFutureTask.join(); BizBusinessDeviceMeasureApprovalMapper bizBusinessMapper = SpringContextUtil.getBean(BizBusinessDeviceMeasureApprovalMapper.class); - log.info("----------------获取生成的数据结果"); + log.info("----------------get result orign is {},certificate is {}",originalRecordFileUrl,certificateFileUrl); if (CollectionUtils.isNotEmpty(certificateFileUrl) || StringUtils.isNotEmpty(originalRecordFileUrl)) { //生成证书文件 if (CollectionUtils.isNotEmpty(certificateFileUrl)) { @@ -192,6 +186,7 @@ throw new BusinessException(BusinessExceptionEnum.MEASURE_FILE_CREATE_FAILED); } } catch (Exception ex) { + log.info("---- data is exception, this is {}", ex); throw new BusinessException(BusinessExceptionEnum.MEASURE_APPROVAL_GET_FAILED); } }).join(); diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/standard/impl/MultiCalibrationBuilder.java b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/standard/impl/MultiCalibrationBuilder.java index a7a12ad..81469e2 100644 --- a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/standard/impl/MultiCalibrationBuilder.java +++ b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/standard/impl/MultiCalibrationBuilder.java @@ -96,6 +96,7 @@ } return urlList; } catch (Exception ex) { + log.info("-----package data is exception, this is {}", ex); throw new BusinessException(BusinessExceptionEnum.MEASURE_APPROVAL_UPDATE_FAILED); } } diff --git a/casic-metering-dao/src/main/resources/mapper/business/BizBusinessDeviceMeasureApprovalMapper.xml b/casic-metering-dao/src/main/resources/mapper/business/BizBusinessDeviceMeasureApprovalMapper.xml index b13ce50..56a707f 100644 --- a/casic-metering-dao/src/main/resources/mapper/business/BizBusinessDeviceMeasureApprovalMapper.xml +++ b/casic-metering-dao/src/main/resources/mapper/business/BizBusinessDeviceMeasureApprovalMapper.xml @@ -90,7 +90,7 @@ WHERE template_name= #{templateName} AND template_type= #{coverModuleName} - AND template_desc =#{descn} + AND template_desc like concat('%',#{descn},'%') diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/GenericEqptDataProvider.java b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/GenericEqptDataProvider.java index b17b574..871ddd6 100644 --- a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/GenericEqptDataProvider.java +++ b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/GenericEqptDataProvider.java @@ -1,7 +1,5 @@ package com.casic.missiles.service.Impl.eqpt; -import cn.hutool.core.bean.BeanUtil; -import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; import com.baomidou.mybatisplus.core.toolkit.ObjectUtils; @@ -12,30 +10,21 @@ import com.casic.missiles.mapper.business.BizBusinessDeviceMeasureApprovalMapper; import com.casic.missiles.mapper.equipment.BizEquipmentStandardCheckRecordApprovalMapper; import com.casic.missiles.model.business.BizBusinessDeviceMeasureApproval; -import com.casic.missiles.model.business.BizBusinessDeviceMeasureDataCalibrator; -import com.casic.missiles.model.equipment.BizEquipmentInfo; -import com.casic.missiles.model.equipment.BizEquipmentStandardCheckDataCalibrator; import com.casic.missiles.model.equipment.BizEquipmentStandardCheckRecordApproval; import com.casic.missiles.service.Impl.eqpt.standard.StandardEquipmentPrint; import com.casic.missiles.service.listeners.register.PrintFileRegister; -import com.casic.missiles.utils.SnowflakeUtil; import com.casic.missiles.utils.SpringContextUtil; -import com.gexin.fastjson.JSON; -import liquibase.pro.packaged.A; -import liquibase.pro.packaged.M; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; -import org.docx4j.wml.R; import org.springframework.stereotype.Component; -import java.text.SimpleDateFormat; import java.util.*; import java.util.concurrent.CompletableFuture; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; -import java.util.stream.Collectors; + /** * 通用的装置数据提供器 @@ -50,9 +39,6 @@ private final PrintFileRegister printFileRegister; - private static ThreadPoolExecutor threadPool = new ThreadPoolExecutor(4, 10, 100, - TimeUnit.SECONDS, new LinkedBlockingQueue<>(10)); - /** * 核查记录生成更新证书的任务 */ @@ -61,6 +47,7 @@ if (ObjectUtils.isEmpty(request) || StringUtils.isEmpty(request.getBelongStandardEquipment())) { throw new BusinessException(BusinessExceptionEnum.MEASURE_STANDARD_IS_NULL); } + log.info("check data is check,please wait ..."); //生成核查记录单 StandardEquipmentPrint standardEquipmentPrint = SpringContextUtil.getBean(request.getBelongStandardEquipment()); List checkCertificateFileList = standardEquipmentPrint.doCheckCertificateFile(request); @@ -89,6 +76,9 @@ * @param oldCertificateFile */ public void excuteMeasureTaskAsyn(Map map, Long id, String oldCertificateFile) { + ThreadPoolExecutor threadPool = new ThreadPoolExecutor(1, 2, 100, + TimeUnit.SECONDS, new LinkedBlockingQueue<>(2)); + log.info("measure data is check,please wait ..."); List customTemplateUrls = new ArrayList<>(); customTemplateUrls.add(oldCertificateFile); //生成证书报告的,需要改变为动态选择性 @@ -126,6 +116,8 @@ public void excuteCheckTaskAsyn(Map map, Long id, String oldCertificateFile) { List customTemplateUrls = new ArrayList<>(); customTemplateUrls.add(oldCertificateFile); + ThreadPoolExecutor threadPool = new ThreadPoolExecutor(1, 2, 100, + TimeUnit.SECONDS, new LinkedBlockingQueue<>(2)); //生成证书报告的 CompletableFuture certificateFutureTask = CompletableFuture.supplyAsync( () -> printFileRegister.registerPrintFile(MULTIFUNCTION_CHECK_DATA, "数据打印", null, map, true, null, customTemplateUrls), threadPool); @@ -155,6 +147,8 @@ * 生成更新证书的任务 */ public void measureCertificateTask(BizBusinessDeviceMeasureApproval request) { + ThreadPoolExecutor threadPool = new ThreadPoolExecutor(2, 2, 100, + TimeUnit.SECONDS, new LinkedBlockingQueue<>(2)); StandardEquipmentPrint equipmentPrint = getStandardEquipmentPrint(request); log.info("---111111111"); //生成证书报告的 @@ -172,7 +166,7 @@ List certificateFileUrl = certificateFutureTask.join(); String originalRecordFileUrl = originalFutureTask.join(); BizBusinessDeviceMeasureApprovalMapper bizBusinessMapper = SpringContextUtil.getBean(BizBusinessDeviceMeasureApprovalMapper.class); - log.info("----------------获取生成的数据结果"); + log.info("----------------get result orign is {},certificate is {}",originalRecordFileUrl,certificateFileUrl); if (CollectionUtils.isNotEmpty(certificateFileUrl) || StringUtils.isNotEmpty(originalRecordFileUrl)) { //生成证书文件 if (CollectionUtils.isNotEmpty(certificateFileUrl)) { @@ -192,6 +186,7 @@ throw new BusinessException(BusinessExceptionEnum.MEASURE_FILE_CREATE_FAILED); } } catch (Exception ex) { + log.info("---- data is exception, this is {}", ex); throw new BusinessException(BusinessExceptionEnum.MEASURE_APPROVAL_GET_FAILED); } }).join(); diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/standard/impl/MultiCalibrationBuilder.java b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/standard/impl/MultiCalibrationBuilder.java index a7a12ad..81469e2 100644 --- a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/standard/impl/MultiCalibrationBuilder.java +++ b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/standard/impl/MultiCalibrationBuilder.java @@ -96,6 +96,7 @@ } return urlList; } catch (Exception ex) { + log.info("-----package data is exception, this is {}", ex); throw new BusinessException(BusinessExceptionEnum.MEASURE_APPROVAL_UPDATE_FAILED); } } diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/listeners/processor/CertificateReportEventPostProcessor.java b/casic-metering-service/src/main/java/com/casic/missiles/service/listeners/processor/CertificateReportEventPostProcessor.java index 22597c2..508863c 100644 --- a/casic-metering-service/src/main/java/com/casic/missiles/service/listeners/processor/CertificateReportEventPostProcessor.java +++ b/casic-metering-service/src/main/java/com/casic/missiles/service/listeners/processor/CertificateReportEventPostProcessor.java @@ -26,6 +26,7 @@ import com.casic.missiles.service.Impl.eqpt.GenericEqptDataProvider; import com.casic.missiles.service.listeners.NotifyEventPostProcessor; import com.casic.missiles.utils.SpringContextUtil; +import com.gexin.fastjson.JSON; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.stereotype.Service; @@ -99,6 +100,7 @@ try { //存储到证书打印表 saveCertificatePrintInfo(deviceMeasureApproval); + log.info("-----------------{}", JSON.toJSON(deviceMeasureApproval)); GenericEqptDataProvider genericEqptDataProvider=SpringContextUtil.getBean(GenericEqptDataProvider.class); Map map = BeanUtil.beanToMap(deviceMeasureApproval); genericEqptDataProvider.excuteMeasureTaskAsyn(map,deviceMeasureApproval.getId(),deviceMeasureApproval.getCertificateWordFile()); diff --git a/casic-metering-dao/src/main/resources/mapper/business/BizBusinessDeviceMeasureApprovalMapper.xml b/casic-metering-dao/src/main/resources/mapper/business/BizBusinessDeviceMeasureApprovalMapper.xml index b13ce50..56a707f 100644 --- a/casic-metering-dao/src/main/resources/mapper/business/BizBusinessDeviceMeasureApprovalMapper.xml +++ b/casic-metering-dao/src/main/resources/mapper/business/BizBusinessDeviceMeasureApprovalMapper.xml @@ -90,7 +90,7 @@ WHERE template_name= #{templateName} AND template_type= #{coverModuleName} - AND template_desc =#{descn} + AND template_desc like concat('%',#{descn},'%') diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/GenericEqptDataProvider.java b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/GenericEqptDataProvider.java index b17b574..871ddd6 100644 --- a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/GenericEqptDataProvider.java +++ b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/GenericEqptDataProvider.java @@ -1,7 +1,5 @@ package com.casic.missiles.service.Impl.eqpt; -import cn.hutool.core.bean.BeanUtil; -import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; import com.baomidou.mybatisplus.core.toolkit.ObjectUtils; @@ -12,30 +10,21 @@ import com.casic.missiles.mapper.business.BizBusinessDeviceMeasureApprovalMapper; import com.casic.missiles.mapper.equipment.BizEquipmentStandardCheckRecordApprovalMapper; import com.casic.missiles.model.business.BizBusinessDeviceMeasureApproval; -import com.casic.missiles.model.business.BizBusinessDeviceMeasureDataCalibrator; -import com.casic.missiles.model.equipment.BizEquipmentInfo; -import com.casic.missiles.model.equipment.BizEquipmentStandardCheckDataCalibrator; import com.casic.missiles.model.equipment.BizEquipmentStandardCheckRecordApproval; import com.casic.missiles.service.Impl.eqpt.standard.StandardEquipmentPrint; import com.casic.missiles.service.listeners.register.PrintFileRegister; -import com.casic.missiles.utils.SnowflakeUtil; import com.casic.missiles.utils.SpringContextUtil; -import com.gexin.fastjson.JSON; -import liquibase.pro.packaged.A; -import liquibase.pro.packaged.M; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; -import org.docx4j.wml.R; import org.springframework.stereotype.Component; -import java.text.SimpleDateFormat; import java.util.*; import java.util.concurrent.CompletableFuture; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; -import java.util.stream.Collectors; + /** * 通用的装置数据提供器 @@ -50,9 +39,6 @@ private final PrintFileRegister printFileRegister; - private static ThreadPoolExecutor threadPool = new ThreadPoolExecutor(4, 10, 100, - TimeUnit.SECONDS, new LinkedBlockingQueue<>(10)); - /** * 核查记录生成更新证书的任务 */ @@ -61,6 +47,7 @@ if (ObjectUtils.isEmpty(request) || StringUtils.isEmpty(request.getBelongStandardEquipment())) { throw new BusinessException(BusinessExceptionEnum.MEASURE_STANDARD_IS_NULL); } + log.info("check data is check,please wait ..."); //生成核查记录单 StandardEquipmentPrint standardEquipmentPrint = SpringContextUtil.getBean(request.getBelongStandardEquipment()); List checkCertificateFileList = standardEquipmentPrint.doCheckCertificateFile(request); @@ -89,6 +76,9 @@ * @param oldCertificateFile */ public void excuteMeasureTaskAsyn(Map map, Long id, String oldCertificateFile) { + ThreadPoolExecutor threadPool = new ThreadPoolExecutor(1, 2, 100, + TimeUnit.SECONDS, new LinkedBlockingQueue<>(2)); + log.info("measure data is check,please wait ..."); List customTemplateUrls = new ArrayList<>(); customTemplateUrls.add(oldCertificateFile); //生成证书报告的,需要改变为动态选择性 @@ -126,6 +116,8 @@ public void excuteCheckTaskAsyn(Map map, Long id, String oldCertificateFile) { List customTemplateUrls = new ArrayList<>(); customTemplateUrls.add(oldCertificateFile); + ThreadPoolExecutor threadPool = new ThreadPoolExecutor(1, 2, 100, + TimeUnit.SECONDS, new LinkedBlockingQueue<>(2)); //生成证书报告的 CompletableFuture certificateFutureTask = CompletableFuture.supplyAsync( () -> printFileRegister.registerPrintFile(MULTIFUNCTION_CHECK_DATA, "数据打印", null, map, true, null, customTemplateUrls), threadPool); @@ -155,6 +147,8 @@ * 生成更新证书的任务 */ public void measureCertificateTask(BizBusinessDeviceMeasureApproval request) { + ThreadPoolExecutor threadPool = new ThreadPoolExecutor(2, 2, 100, + TimeUnit.SECONDS, new LinkedBlockingQueue<>(2)); StandardEquipmentPrint equipmentPrint = getStandardEquipmentPrint(request); log.info("---111111111"); //生成证书报告的 @@ -172,7 +166,7 @@ List certificateFileUrl = certificateFutureTask.join(); String originalRecordFileUrl = originalFutureTask.join(); BizBusinessDeviceMeasureApprovalMapper bizBusinessMapper = SpringContextUtil.getBean(BizBusinessDeviceMeasureApprovalMapper.class); - log.info("----------------获取生成的数据结果"); + log.info("----------------get result orign is {},certificate is {}",originalRecordFileUrl,certificateFileUrl); if (CollectionUtils.isNotEmpty(certificateFileUrl) || StringUtils.isNotEmpty(originalRecordFileUrl)) { //生成证书文件 if (CollectionUtils.isNotEmpty(certificateFileUrl)) { @@ -192,6 +186,7 @@ throw new BusinessException(BusinessExceptionEnum.MEASURE_FILE_CREATE_FAILED); } } catch (Exception ex) { + log.info("---- data is exception, this is {}", ex); throw new BusinessException(BusinessExceptionEnum.MEASURE_APPROVAL_GET_FAILED); } }).join(); diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/standard/impl/MultiCalibrationBuilder.java b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/standard/impl/MultiCalibrationBuilder.java index a7a12ad..81469e2 100644 --- a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/standard/impl/MultiCalibrationBuilder.java +++ b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/standard/impl/MultiCalibrationBuilder.java @@ -96,6 +96,7 @@ } return urlList; } catch (Exception ex) { + log.info("-----package data is exception, this is {}", ex); throw new BusinessException(BusinessExceptionEnum.MEASURE_APPROVAL_UPDATE_FAILED); } } diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/listeners/processor/CertificateReportEventPostProcessor.java b/casic-metering-service/src/main/java/com/casic/missiles/service/listeners/processor/CertificateReportEventPostProcessor.java index 22597c2..508863c 100644 --- a/casic-metering-service/src/main/java/com/casic/missiles/service/listeners/processor/CertificateReportEventPostProcessor.java +++ b/casic-metering-service/src/main/java/com/casic/missiles/service/listeners/processor/CertificateReportEventPostProcessor.java @@ -26,6 +26,7 @@ import com.casic.missiles.service.Impl.eqpt.GenericEqptDataProvider; import com.casic.missiles.service.listeners.NotifyEventPostProcessor; import com.casic.missiles.utils.SpringContextUtil; +import com.gexin.fastjson.JSON; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.stereotype.Service; @@ -99,6 +100,7 @@ try { //存储到证书打印表 saveCertificatePrintInfo(deviceMeasureApproval); + log.info("-----------------{}", JSON.toJSON(deviceMeasureApproval)); GenericEqptDataProvider genericEqptDataProvider=SpringContextUtil.getBean(GenericEqptDataProvider.class); Map map = BeanUtil.beanToMap(deviceMeasureApproval); genericEqptDataProvider.excuteMeasureTaskAsyn(map,deviceMeasureApproval.getId(),deviceMeasureApproval.getCertificateWordFile()); diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/listeners/register/data/ElectronicSignSeal.java b/casic-metering-service/src/main/java/com/casic/missiles/service/listeners/register/data/ElectronicSignSeal.java index 3d33192..9fe5034 100644 --- a/casic-metering-service/src/main/java/com/casic/missiles/service/listeners/register/data/ElectronicSignSeal.java +++ b/casic-metering-service/src/main/java/com/casic/missiles/service/listeners/register/data/ElectronicSignSeal.java @@ -12,6 +12,7 @@ import com.casic.missiles.model.file.ImageConfig; import com.casic.missiles.service.flowable.ApprovalOperateService; import com.casic.missiles.utils.SpringContextUtil; +import lombok.extern.slf4j.Slf4j; import org.apache.commons.collections.CollectionUtils; import org.apache.commons.lang3.StringUtils; @@ -22,6 +23,7 @@ /** * @author cz */ +@Slf4j public class ElectronicSignSeal extends ElectronicSignTemplate implements FilePrintEnum { @@ -118,7 +120,7 @@ } } } else { - if(!metaDataMap.containsKey(flowField)||ObjectUtils.isEmpty(metaDataMap.get(flowField))){ + if (!metaDataMap.containsKey(flowField) || ObjectUtils.isEmpty(metaDataMap.get(flowField))) { return; } //配置参数中包含有工作流的字段 @@ -194,6 +196,7 @@ filePrintRegister.getParams().put("comment" + timeSeqCount, approvalLog.getComment().getComment()); } timeSeqCount++; + log.info(":-----{}", filePrintRegister.getTemDir() + signFileName + "------" + StringUtils.isEmpty(signFileName)); //设置集合 electronicImage.setElectronicSealImageUrl(filePrintRegister.getTemDir() + signFileName); electronicImage.setImageConfig(approvalImageList.get(i)); diff --git a/casic-metering-dao/src/main/resources/mapper/business/BizBusinessDeviceMeasureApprovalMapper.xml b/casic-metering-dao/src/main/resources/mapper/business/BizBusinessDeviceMeasureApprovalMapper.xml index b13ce50..56a707f 100644 --- a/casic-metering-dao/src/main/resources/mapper/business/BizBusinessDeviceMeasureApprovalMapper.xml +++ b/casic-metering-dao/src/main/resources/mapper/business/BizBusinessDeviceMeasureApprovalMapper.xml @@ -90,7 +90,7 @@ WHERE template_name= #{templateName} AND template_type= #{coverModuleName} - AND template_desc =#{descn} + AND template_desc like concat('%',#{descn},'%') diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/GenericEqptDataProvider.java b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/GenericEqptDataProvider.java index b17b574..871ddd6 100644 --- a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/GenericEqptDataProvider.java +++ b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/GenericEqptDataProvider.java @@ -1,7 +1,5 @@ package com.casic.missiles.service.Impl.eqpt; -import cn.hutool.core.bean.BeanUtil; -import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.lang.Assert; import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; import com.baomidou.mybatisplus.core.toolkit.ObjectUtils; @@ -12,30 +10,21 @@ import com.casic.missiles.mapper.business.BizBusinessDeviceMeasureApprovalMapper; import com.casic.missiles.mapper.equipment.BizEquipmentStandardCheckRecordApprovalMapper; import com.casic.missiles.model.business.BizBusinessDeviceMeasureApproval; -import com.casic.missiles.model.business.BizBusinessDeviceMeasureDataCalibrator; -import com.casic.missiles.model.equipment.BizEquipmentInfo; -import com.casic.missiles.model.equipment.BizEquipmentStandardCheckDataCalibrator; import com.casic.missiles.model.equipment.BizEquipmentStandardCheckRecordApproval; import com.casic.missiles.service.Impl.eqpt.standard.StandardEquipmentPrint; import com.casic.missiles.service.listeners.register.PrintFileRegister; -import com.casic.missiles.utils.SnowflakeUtil; import com.casic.missiles.utils.SpringContextUtil; -import com.gexin.fastjson.JSON; -import liquibase.pro.packaged.A; -import liquibase.pro.packaged.M; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; -import org.docx4j.wml.R; import org.springframework.stereotype.Component; -import java.text.SimpleDateFormat; import java.util.*; import java.util.concurrent.CompletableFuture; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; -import java.util.stream.Collectors; + /** * 通用的装置数据提供器 @@ -50,9 +39,6 @@ private final PrintFileRegister printFileRegister; - private static ThreadPoolExecutor threadPool = new ThreadPoolExecutor(4, 10, 100, - TimeUnit.SECONDS, new LinkedBlockingQueue<>(10)); - /** * 核查记录生成更新证书的任务 */ @@ -61,6 +47,7 @@ if (ObjectUtils.isEmpty(request) || StringUtils.isEmpty(request.getBelongStandardEquipment())) { throw new BusinessException(BusinessExceptionEnum.MEASURE_STANDARD_IS_NULL); } + log.info("check data is check,please wait ..."); //生成核查记录单 StandardEquipmentPrint standardEquipmentPrint = SpringContextUtil.getBean(request.getBelongStandardEquipment()); List checkCertificateFileList = standardEquipmentPrint.doCheckCertificateFile(request); @@ -89,6 +76,9 @@ * @param oldCertificateFile */ public void excuteMeasureTaskAsyn(Map map, Long id, String oldCertificateFile) { + ThreadPoolExecutor threadPool = new ThreadPoolExecutor(1, 2, 100, + TimeUnit.SECONDS, new LinkedBlockingQueue<>(2)); + log.info("measure data is check,please wait ..."); List customTemplateUrls = new ArrayList<>(); customTemplateUrls.add(oldCertificateFile); //生成证书报告的,需要改变为动态选择性 @@ -126,6 +116,8 @@ public void excuteCheckTaskAsyn(Map map, Long id, String oldCertificateFile) { List customTemplateUrls = new ArrayList<>(); customTemplateUrls.add(oldCertificateFile); + ThreadPoolExecutor threadPool = new ThreadPoolExecutor(1, 2, 100, + TimeUnit.SECONDS, new LinkedBlockingQueue<>(2)); //生成证书报告的 CompletableFuture certificateFutureTask = CompletableFuture.supplyAsync( () -> printFileRegister.registerPrintFile(MULTIFUNCTION_CHECK_DATA, "数据打印", null, map, true, null, customTemplateUrls), threadPool); @@ -155,6 +147,8 @@ * 生成更新证书的任务 */ public void measureCertificateTask(BizBusinessDeviceMeasureApproval request) { + ThreadPoolExecutor threadPool = new ThreadPoolExecutor(2, 2, 100, + TimeUnit.SECONDS, new LinkedBlockingQueue<>(2)); StandardEquipmentPrint equipmentPrint = getStandardEquipmentPrint(request); log.info("---111111111"); //生成证书报告的 @@ -172,7 +166,7 @@ List certificateFileUrl = certificateFutureTask.join(); String originalRecordFileUrl = originalFutureTask.join(); BizBusinessDeviceMeasureApprovalMapper bizBusinessMapper = SpringContextUtil.getBean(BizBusinessDeviceMeasureApprovalMapper.class); - log.info("----------------获取生成的数据结果"); + log.info("----------------get result orign is {},certificate is {}",originalRecordFileUrl,certificateFileUrl); if (CollectionUtils.isNotEmpty(certificateFileUrl) || StringUtils.isNotEmpty(originalRecordFileUrl)) { //生成证书文件 if (CollectionUtils.isNotEmpty(certificateFileUrl)) { @@ -192,6 +186,7 @@ throw new BusinessException(BusinessExceptionEnum.MEASURE_FILE_CREATE_FAILED); } } catch (Exception ex) { + log.info("---- data is exception, this is {}", ex); throw new BusinessException(BusinessExceptionEnum.MEASURE_APPROVAL_GET_FAILED); } }).join(); diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/standard/impl/MultiCalibrationBuilder.java b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/standard/impl/MultiCalibrationBuilder.java index a7a12ad..81469e2 100644 --- a/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/standard/impl/MultiCalibrationBuilder.java +++ b/casic-metering-service/src/main/java/com/casic/missiles/service/Impl/eqpt/standard/impl/MultiCalibrationBuilder.java @@ -96,6 +96,7 @@ } return urlList; } catch (Exception ex) { + log.info("-----package data is exception, this is {}", ex); throw new BusinessException(BusinessExceptionEnum.MEASURE_APPROVAL_UPDATE_FAILED); } } diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/listeners/processor/CertificateReportEventPostProcessor.java b/casic-metering-service/src/main/java/com/casic/missiles/service/listeners/processor/CertificateReportEventPostProcessor.java index 22597c2..508863c 100644 --- a/casic-metering-service/src/main/java/com/casic/missiles/service/listeners/processor/CertificateReportEventPostProcessor.java +++ b/casic-metering-service/src/main/java/com/casic/missiles/service/listeners/processor/CertificateReportEventPostProcessor.java @@ -26,6 +26,7 @@ import com.casic.missiles.service.Impl.eqpt.GenericEqptDataProvider; import com.casic.missiles.service.listeners.NotifyEventPostProcessor; import com.casic.missiles.utils.SpringContextUtil; +import com.gexin.fastjson.JSON; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.stereotype.Service; @@ -99,6 +100,7 @@ try { //存储到证书打印表 saveCertificatePrintInfo(deviceMeasureApproval); + log.info("-----------------{}", JSON.toJSON(deviceMeasureApproval)); GenericEqptDataProvider genericEqptDataProvider=SpringContextUtil.getBean(GenericEqptDataProvider.class); Map map = BeanUtil.beanToMap(deviceMeasureApproval); genericEqptDataProvider.excuteMeasureTaskAsyn(map,deviceMeasureApproval.getId(),deviceMeasureApproval.getCertificateWordFile()); diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/listeners/register/data/ElectronicSignSeal.java b/casic-metering-service/src/main/java/com/casic/missiles/service/listeners/register/data/ElectronicSignSeal.java index 3d33192..9fe5034 100644 --- a/casic-metering-service/src/main/java/com/casic/missiles/service/listeners/register/data/ElectronicSignSeal.java +++ b/casic-metering-service/src/main/java/com/casic/missiles/service/listeners/register/data/ElectronicSignSeal.java @@ -12,6 +12,7 @@ import com.casic.missiles.model.file.ImageConfig; import com.casic.missiles.service.flowable.ApprovalOperateService; import com.casic.missiles.utils.SpringContextUtil; +import lombok.extern.slf4j.Slf4j; import org.apache.commons.collections.CollectionUtils; import org.apache.commons.lang3.StringUtils; @@ -22,6 +23,7 @@ /** * @author cz */ +@Slf4j public class ElectronicSignSeal extends ElectronicSignTemplate implements FilePrintEnum { @@ -118,7 +120,7 @@ } } } else { - if(!metaDataMap.containsKey(flowField)||ObjectUtils.isEmpty(metaDataMap.get(flowField))){ + if (!metaDataMap.containsKey(flowField) || ObjectUtils.isEmpty(metaDataMap.get(flowField))) { return; } //配置参数中包含有工作流的字段 @@ -194,6 +196,7 @@ filePrintRegister.getParams().put("comment" + timeSeqCount, approvalLog.getComment().getComment()); } timeSeqCount++; + log.info(":-----{}", filePrintRegister.getTemDir() + signFileName + "------" + StringUtils.isEmpty(signFileName)); //设置集合 electronicImage.setElectronicSealImageUrl(filePrintRegister.getTemDir() + signFileName); electronicImage.setImageConfig(approvalImageList.get(i)); diff --git a/casic-metering-service/src/main/java/com/casic/missiles/service/listeners/util/ParseWord07.java b/casic-metering-service/src/main/java/com/casic/missiles/service/listeners/util/ParseWord07.java index 5791a39..faf91dd 100644 --- a/casic-metering-service/src/main/java/com/casic/missiles/service/listeners/util/ParseWord07.java +++ b/casic-metering-service/src/main/java/com/casic/missiles/service/listeners/util/ParseWord07.java @@ -198,6 +198,7 @@ if (CollectionUtil.isNotEmpty(mergeColNames)) { //遍寻列,同时增加下标超值判断 int positionIndex = tryGetInitialMergeRow(table); + //查询合并索引的列 List mergeIndexList = checkThisTableCellMergeIndex(positionIndex, table, mergeColNames); Map mergeIndexMap = mergeIndexList.stream().collect(Collectors.toMap(e -> e, e -> e)); @@ -251,7 +252,7 @@ ); int colIndex = 0; List mergeIndexList = new ArrayList<>(); - for (int i = 0; i < --positionIndex; i++) { + for (int i = 0; i <= positionIndex; i++) { XWPFTableRow row = table.getRow(i); //标题合并行 while (colIndex < row.getTableCells().size()) {