From b942203309c222a2c36b2d79e8aa1c00d10be47d Mon Sep 17 00:00:00 2001 From: aike <17730485278@139.com> Date: Thu, 27 Nov 2025 17:22:31 +0800 Subject: [PATCH] =?UTF-8?q?demand:=20=20=E6=BC=8F=E7=BB=84=E6=89=B9?= =?UTF-8?q?=E6=AC=A1=E7=9B=B8=E5=85=B3=E9=9C=80=E6=B1=82=20committer:=20he?= =?UTF-8?q?yu?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/xdadan/erp/web/emis/EmisCommonController.java | 6 ++++++ .../emis/service/impl/EmisTmsSiteBatchMissServiceImpl.java | 1 - 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/emis-biz-web/src/main/java/com/xdadan/erp/web/emis/EmisCommonController.java b/emis-biz-web/src/main/java/com/xdadan/erp/web/emis/EmisCommonController.java index dac675eb0..07072f950 100644 --- a/emis-biz-web/src/main/java/com/xdadan/erp/web/emis/EmisCommonController.java +++ b/emis-biz-web/src/main/java/com/xdadan/erp/web/emis/EmisCommonController.java @@ -28,6 +28,7 @@ import com.xdadan.erp.emis.domain.exception.EmisBizError; import com.xdadan.erp.emis.domain.stat.BillPayStatInfo; import com.xdadan.erp.emis.domain.stat.OpenBillStatInfo; import com.xdadan.erp.emis.domain.vo.AddressParseResult; +import com.xdadan.erp.emis.mapper.EmisTmsSiteBatchMissMapper; import com.xdadan.erp.emis.service.*; import com.xdadan.erp.emis.service.kefu.RL7moorService; import com.xdadan.erp.emis.service.print.IXddTplPrint; @@ -140,6 +141,9 @@ public class EmisCommonController extends EmisBaseController @Autowired private IEmisTransLineService emisTransLineService; + @Autowired + private EmisTmsSiteBatchMissMapper emisTmsSiteBatchMissMapper; + /** * 在线支付回调 * @param method @@ -965,6 +969,7 @@ public class EmisCommonController extends EmisBaseController // 如果lineCode为空,查询所有线路的lineCode,去重后循环调用 if (StringUtils.isEmpty(lineCode)) { log.info("lineCode is empty, querying all line codes"); + emisTmsSiteBatchMissMapper.deleteReally(lineCode); EmisTransLine queryLine = new EmisTransLine(); // queryLine.setStatus(1); // 只查询启用的线路 List lineList = emisTransLineService.selectEmisTransLineList(queryLine); @@ -995,6 +1000,7 @@ public class EmisCommonController extends EmisBaseController log.info("autoScanSiteBatch async task started for all line codes"); return AjaxResult.success("异步任务已启动,共处理 " + lineCodeSet.size() + " 个线路,请稍后查看执行结果"); } else { + emisTmsSiteBatchMissMapper.deleteReally(lineCode); // 异步执行任务 emisTmsSiteBatchMissService.autoScanSiteBatch(lineCode); log.info("autoScanSiteBatch async task started for lineCode: {}", lineCode); diff --git a/emis-biz/src/main/java/com/xdadan/erp/emis/service/impl/EmisTmsSiteBatchMissServiceImpl.java b/emis-biz/src/main/java/com/xdadan/erp/emis/service/impl/EmisTmsSiteBatchMissServiceImpl.java index 6c49fabcf..20b27faa3 100644 --- a/emis-biz/src/main/java/com/xdadan/erp/emis/service/impl/EmisTmsSiteBatchMissServiceImpl.java +++ b/emis-biz/src/main/java/com/xdadan/erp/emis/service/impl/EmisTmsSiteBatchMissServiceImpl.java @@ -305,7 +305,6 @@ public class EmisTmsSiteBatchMissServiceImpl extends EmisBaseService implements public void autoScanSiteBatch(String lineCode) { ExecutorService executorService = null; try { - emisTmsSiteBatchMissMapper.deleteReally(lineCode); long startTime = System.currentTimeMillis(); int pageSize = 1000; int offset = 0;