feats

src/main/java/com/xiaoniu/niucai/mapper/TaMatchMapper.java

@@ -18,4 +18,6 @@ import java.util.List;
 @Mapper
 public interface TaMatchMapper extends BaseMapper<TaMatch> {
     List<TaMatch> getLastOpenAndUndoMatch(@Param("days") int days) throws Exception;
+
+    List<TaMatch> getLastExcAndUndoMatch(@Param("hours") int hours) throws Exception;
 }

src/main/java/com/xiaoniu/niucai/service/ITaCustomerBettingSportService.java

@@ -16,4 +16,6 @@ import java.util.List;
 public interface ITaCustomerBettingSportService extends IService<TaCustomerBettingSport> {
 
     List<TaCustomerBettingSport> getListByBetting(Integer bettingId, Integer itemNo) throws Exception;
+
+    boolean updateExcDrawnOdds(Integer bettingId, Integer itemNo) throws Exception;
 }

src/main/java/com/xiaoniu/niucai/service/ITaMatchService.java

@@ -13,4 +13,6 @@ import com.xiaoniu.niucai.entity.TaMatch;
  */
 public interface ITaMatchService extends IService<TaMatch> {
     void checkAndSetSportPrize() throws Exception;
+
+    void checkExcMatches() throws Exception;
 }

src/main/java/com/xiaoniu/niucai/service/impl/TaCustomerBettingSportServiceImpl.java

@@ -1,6 +1,7 @@
 package com.xiaoniu.niucai.service.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.xiaoniu.niucai.service.ITaCustomerBettingSportService;
 import com.xiaoniu.niucai.entity.TaCustomerBettingSport;
@@ -29,4 +30,15 @@ public class TaCustomerBettingSportServiceImpl extends ServiceImpl<TaCustomerBet
 
         return list(queryWrapper);
     }
+
+    @Override
+    public boolean updateExcDrawnOdds(Integer bettingId, Integer itemNo) throws Exception {
+        UpdateWrapper<TaCustomerBettingSport> updateWrapper = new UpdateWrapper<>();
+        updateWrapper.set("odds_drawn", 1);
+        updateWrapper.set("is_winning", 1);
+        updateWrapper.eq("betting_id", bettingId);
+        updateWrapper.eq("item_no", itemNo);
+
+        return update(updateWrapper);
+    }
 }

src/main/java/com/xiaoniu/niucai/service/impl/TaMatchServiceImpl.java

@@ -71,6 +71,7 @@ public class TaMatchServiceImpl extends ServiceImpl<TaMatchMapper, TaMatch> impl
                 taMatch.setOpeningStatus(SportOpeningStatusEnum.FINISHED.getCode());
                 updateById(taMatch);
             } catch (Exception e) {
+                e.printStackTrace();
                 // TODO 比如错误日志记录
                 taMatch.setOpeningStatus(SportOpeningStatusEnum.READY.getCode());
                 updateById(taMatch);
@@ -78,6 +79,53 @@ public class TaMatchServiceImpl extends ServiceImpl<TaMatchMapper, TaMatch> impl
         }
     }
 
+    /**
+     * 如果有比赛取消或者异常。那么等待 36 小时。
+     * 如果 36 小时之后还是异常。那么本场比赛赔率按 1 算
+     * @throws Exception
+     */
+    @Override
+    public void checkExcMatches() throws Exception {
+        List<TaMatch> matchList = taMatchMapper.getLastExcAndUndoMatch(36);
+        if (null == matchList || matchList.size() == 0) {
+            log.info("未检测到有待处理的异常比赛");
+            return;
+        }
+
+        for (TaMatch taMatch : matchList) {
+            try {
+                taMatch.setOpeningStatus(SportOpeningStatusEnum.DOING.getCode());
+                updateById(taMatch);
+                validateExcMatch(taMatch);
+                taMatch.setOpeningStatus(SportOpeningStatusEnum.FINISHED.getCode());
+                updateById(taMatch);
+            } catch (Exception e) {
+                e.printStackTrace();
+                // TODO 比如错误日志记录
+                taMatch.setOpeningStatus(SportOpeningStatusEnum.READY.getCode());
+                updateById(taMatch);
+            }
+        }
+    }
+
+    @Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRES_NEW)
+    private void validateExcMatch(TaMatch taMatch) throws Exception {
+        // 获取当前比赛的投注列表
+        List<TaCustomerBettingItem> bettingItemList = iTaCustomerBettingItemService.getByMatch(taMatch);
+        if (null == bettingItemList || bettingItemList.size() == 0) {
+            return;
+        }
+
+        for (TaCustomerBettingItem item: bettingItemList) {
+            item.setIsWinning(true);
+            item.setOpeningStatus(SportOpeningStatusEnum.FINISHED.getCode());
+            iTaCustomerBettingItemService.updateById(item);
+
+            // 更新赔率为 1
+            iTaCustomerBettingSportService.updateExcDrawnOdds(item.getBettingId(), item.getItemNo());
+        }
+    }
+
     /**
      * 校验比赛
      * @param taMatch

src/main/java/com/xiaoniu/niucai/task/Lottery.java

@@ -30,12 +30,20 @@ public class Lottery {
             log.error("校验数字彩开奖结果错误: {}", e.getMessage());
         }
 
-        // 体彩
+        // 体彩中奖
         try {
             iTaMatchService.checkAndSetSportPrize();
         } catch (Exception e) {
             e.printStackTrace();
             log.error("校验体彩开奖结果错误: {}", e.getMessage());
         }
+
+        // 体彩异常比赛
+        try {
+            iTaMatchService.checkExcMatches();
+        } catch (Exception e) {
+            e.printStackTrace();
+            log.error("校验异常比赛错误: {}", e.getMessage());
+        }
     }
 }

src/main/resources/mapper/TaMatchMapper.xml

@@ -14,4 +14,17 @@
         ORDER BY
             t.match_id ASC
     </select>
+
+    <select id="getLastExcAndUndoMatch" resultType="com.xiaoniu.niucai.entity.TaMatch">
+        SELECT
+            *
+        FROM
+        ta_match t
+        WHERE
+            t.`status` &gt; 3
+            AND t.opening_status = 0
+            AND CONCAT(t.match_date, ' ', t.match_time) &lt; DATE_FORMAT( DATE_SUB(now(), INTERVAL #{hours} HOUR), '%Y-%m-%d %H:%i' )
+        ORDER BY
+            t.match_id ASC
+    </select>
 </mapper>