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;