demand: 漏组批次相关需求

committer: heyu
This commit is contained in:
aike 2025-11-27 17:22:31 +08:00
parent eacd02c100
commit b942203309
2 changed files with 6 additions and 1 deletions

View File

@ -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<EmisTransLine> 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);

View File

@ -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;