diff --git a/coolstore-partner-dao/src/main/java/com/cool/store/dao/StoreDao.java b/coolstore-partner-dao/src/main/java/com/cool/store/dao/StoreDao.java index f1c3a4167..65c3575c0 100644 --- a/coolstore-partner-dao/src/main/java/com/cool/store/dao/StoreDao.java +++ b/coolstore-partner-dao/src/main/java/com/cool/store/dao/StoreDao.java @@ -99,7 +99,7 @@ public class StoreDao { /** * 查询所有门店id和门店编码 */ - public List getAllStoreIdAndNum() { - return storeMapper.getAllStoreIdAndNum(); + public List getAllStoreIdAndNum(List storeStatus) { + return storeMapper.getAllStoreIdAndNum(storeStatus); } } diff --git a/coolstore-partner-dao/src/main/java/com/cool/store/mapper/StoreMapper.java b/coolstore-partner-dao/src/main/java/com/cool/store/mapper/StoreMapper.java index dd1713201..25adad05a 100644 --- a/coolstore-partner-dao/src/main/java/com/cool/store/mapper/StoreMapper.java +++ b/coolstore-partner-dao/src/main/java/com/cool/store/mapper/StoreMapper.java @@ -58,5 +58,5 @@ public interface StoreMapper { /** * 查询所有门店id和门店编码 */ - List getAllStoreIdAndNum(); + List getAllStoreIdAndNum(@Param("storeStatus") List storeStatus); } diff --git a/coolstore-partner-dao/src/main/resources/mapper/StoreMapper.xml b/coolstore-partner-dao/src/main/resources/mapper/StoreMapper.xml index afb5a6ccd..df9ccf488 100644 --- a/coolstore-partner-dao/src/main/resources/mapper/StoreMapper.xml +++ b/coolstore-partner-dao/src/main/resources/mapper/StoreMapper.xml @@ -248,5 +248,11 @@ SELECT store_id, store_num FROM store_${enterpriseId} WHERE is_delete = 'effective' + + AND store_status IN + + #{item} + + diff --git a/coolstore-partner-web/src/main/java/com/cool/store/job/XxlJobHandler.java b/coolstore-partner-web/src/main/java/com/cool/store/job/XxlJobHandler.java index a2b4c3ee5..018120ad5 100644 --- a/coolstore-partner-web/src/main/java/com/cool/store/job/XxlJobHandler.java +++ b/coolstore-partner-web/src/main/java/com/cool/store/job/XxlJobHandler.java @@ -407,13 +407,18 @@ public class XxlJobHandler { @XxlJob("latestOrderDate") public void latestOrderDate() { log.info("------start latestOrderDate------"); + String param = XxlJobHelper.getJobParam(); + List storeStatus = null; + if (StringUtils.isNotBlank(param)) { + storeStatus = Arrays.asList(param.split(",")); + } boolean hasNext = true; int pageNum = 1; int pageSize = CommonConstants.BATCH_SIZE; DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd"); while (hasNext) { PageHelper.startPage(pageNum, pageSize); - List storeList = storeDao.getAllStoreIdAndNum(); + List storeList = storeDao.getAllStoreIdAndNum(storeStatus); if (CollectionUtils.isEmpty(storeList)) { break; }