定时作业修改

ch-dao/src/main/java/com/wwdz/ch/db/dao/distribution/AuctionConfigDao.java

@@ -41,7 +41,7 @@ public interface AuctionConfigDao {
 
 
     /**
-     * 查询截拍未处理的商品记录
+     * 查询截拍后在一小时内的拍卖配置
      * @param
      * @return
      */
@@ -54,6 +54,14 @@ public interface AuctionConfigDao {
      */
     List<AuctionConfig> findTimeOutNotValidList();
 
+
+    /**
+     * 查询一小时内即将截拍的拍卖商品
+     * @param
+     * @return
+     */
+    List<AuctionConfig> findAbortEndList();
+
     /**
      * 更新截拍时间
      * @param itemId

ch-dao/src/main/java/com/wwdz/ch/db/impl/distribution/AuctionConfigDaoImpl.java

@@ -89,6 +89,19 @@ public class AuctionConfigDaoImpl implements AuctionConfigDao {
         return auctionConfigMapper.selectByExample(example);
     }
 
+    @Override
+    public List<AuctionConfig> findAbortEndList() {
+        AuctionConfigExample example = new AuctionConfigExample();
+        AuctionConfigExample.Criteria criteria = example.createCriteria();
+        Date now = new Date();
+        //查询即将在一小时内截单的拍卖
+        Instant instant = now.toInstant().plus(Duration.ofHours(1));
+        Date time = Date.from(instant);
+        criteria.andRealEndTimeLessThanOrEqualTo(time);
+        criteria.andIsValidEqualTo(true);
+        return auctionConfigMapper.selectByExample(example);
+    }
+
     @Override
     public int setEnd(long itemId) {
         AuctionConfigExample example = new AuctionConfigExample();

ch-wx-api/src/main/java/com/wwdz/ch/wx/job/AutoSendMsgJob.java

@@ -93,8 +93,8 @@ public class AutoSendMsgJob {
         }
         logger.info(">>>>>>>>>>>>>>>>>>>>>>> 自动发送拍卖通知任务，开始执行 <<<<<<<<<<<<<<<<<<<<<");
         try {
-            //查询一小时内拍卖截拍的商品，通知参与过出价的用户即将截拍
-            List<AuctionConfig> auctionConfigList = auctionConfigDao.findEndList();
+            //查询即将在一小时内截拍的商品，通知参与过出价的用户即将截拍
+            List<AuctionConfig> auctionConfigList = auctionConfigDao.findAbortEndList();
             logger.info(">>>>>> 一小时内即将截拍的商品数量 :{} <<<<<<<", auctionConfigList.size());
             auctionConfigList.forEach(auctionConfig -> {
                 long itemId = auctionConfig.getItemId();