feats

src/main/java/com/yunzhi/niucai/entity/TaCustomerBettingItem.java

@@ -51,6 +51,9 @@ public class TaCustomerBettingItem implements Serializable {
     @ApiModelProperty(value = "中奖金额 单位分")
     private Integer winAmount;
 
+    @ApiModelProperty("开奖状态 0未处理,1处理中,2已结束")
+    private Integer openingStatus;
+
     @ApiModelProperty(value = "创建时间")
     private LocalDateTime createDate;
 

src/main/java/com/yunzhi/niucai/entity/TaCustomerBettingSport.java

@@ -51,6 +51,9 @@ public class TaCustomerBettingSport implements Serializable {
     @ApiModelProperty(value = "打单赔率")
     private String oddsPrinted;
 
+    @ApiModelProperty(value = "是否中奖")
+    private Boolean isWinning;
+
     @ApiModelProperty(value = "创建时间")
     private LocalDateTime createDate;
 

src/main/java/com/yunzhi/niucai/entity/TaMatch.java

@@ -138,6 +138,9 @@ public class TaMatch implements Serializable {
     @ApiModelProperty("彩种")
     private String lotteryId;
 
+    @ApiModelProperty("开奖状态 0未处理,1处理中,2已结束")
+    private Integer openingStatus;
+
     /**
      * 赔率
      */

src/main/java/com/yunzhi/niucai/enums/SportOpeningStatusEnum.java

@@ -0,0 +1,16 @@
+package com.yunzhi.niucai.enums;
+
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+@Getter
+@AllArgsConstructor
+public enum SportOpeningStatusEnum implements BaseEnum {
+    READY(0, "未处理"),
+    DOING(1, "处理中"),
+    FINISHED(2, "已完成");
+
+    private Integer code;
+    private String desc;
+}

src/main/java/com/yunzhi/niucai/mapper/TaCustomerBettingItemMapper.java

@@ -3,6 +3,9 @@ package com.yunzhi.niucai.mapper;
 import com.yunzhi.niucai.entity.TaCustomerBettingItem;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
 
 /**
  * <p>
@@ -15,4 +18,5 @@ import org.apache.ibatis.annotations.Mapper;
 @Mapper
 public interface TaCustomerBettingItemMapper extends BaseMapper<TaCustomerBettingItem> {
 
+    List<TaCustomerBettingItem> getUnDealItems(@Param("matchId") Integer matchId) throws Exception;
 }

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

@@ -28,4 +28,6 @@ public interface TaMatchMapper extends BaseMapper<TaMatch> {
     List<TaMatch> getMixedMatch(@Param("lottery") String lottery, @Param("status") Integer status) throws Exception;
 
     List<TaMatch> getLastResult() throws Exception;
+
+    List<TaMatch> getLastOpenAndUndoMatch(@Param("days") int days) throws Exception;
 }

src/main/java/com/yunzhi/niucai/service/ITaCustomerBettingItemService.java

@@ -2,6 +2,9 @@ package com.yunzhi.niucai.service;
 
 import com.yunzhi.niucai.entity.TaCustomerBettingItem;
 import com.baomidou.mybatisplus.extension.service.IService;
+import com.yunzhi.niucai.entity.TaMatch;
+
+import java.util.List;
 
 /**
  * <p>
@@ -13,4 +16,5 @@ import com.baomidou.mybatisplus.extension.service.IService;
  */
 public interface ITaCustomerBettingItemService extends IService<TaCustomerBettingItem> {
 
+    List<TaCustomerBettingItem> getUnDealItems(TaMatch taMatch) throws Exception;
 }

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

@@ -3,6 +3,8 @@ package com.yunzhi.niucai.service;
 import com.yunzhi.niucai.entity.TaCustomerBettingSport;
 import com.baomidou.mybatisplus.extension.service.IService;
 
+import java.util.List;
+
 /**
  * <p>
  * 客户投注竞彩明细  服务类
@@ -13,4 +15,5 @@ import com.baomidou.mybatisplus.extension.service.IService;
  */
 public interface ITaCustomerBettingSportService extends IService<TaCustomerBettingSport> {
 
+    List<TaCustomerBettingSport> getListByBetting(Integer bettingId, Integer itemNo) throws Exception;
 }

src/main/java/com/yunzhi/niucai/service/impl/TaCustomerBettingItemServiceImpl.java

@@ -1,11 +1,15 @@
 package com.yunzhi.niucai.service.impl;
 
 import com.yunzhi.niucai.entity.TaCustomerBettingItem;
+import com.yunzhi.niucai.entity.TaMatch;
 import com.yunzhi.niucai.mapper.TaCustomerBettingItemMapper;
 import com.yunzhi.niucai.service.ITaCustomerBettingItemService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
+
 /**
  * <p>
  * 客户投注明细  服务实现类
@@ -17,4 +21,11 @@ import org.springframework.stereotype.Service;
 @Service
 public class TaCustomerBettingItemServiceImpl extends ServiceImpl<TaCustomerBettingItemMapper, TaCustomerBettingItem> implements ITaCustomerBettingItemService {
 
+    @Autowired
+    TaCustomerBettingItemMapper taCustomerBettingItemMapper;
+
+    @Override
+    public List<TaCustomerBettingItem> getUnDealItems(TaMatch taMatch) throws Exception {
+        return taCustomerBettingItemMapper.getUnDealItems(taMatch.getMatchId());
+    }
 }

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

@@ -1,11 +1,14 @@
 package com.yunzhi.niucai.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.yunzhi.niucai.entity.TaCustomerBettingSport;
 import com.yunzhi.niucai.mapper.TaCustomerBettingSportMapper;
 import com.yunzhi.niucai.service.ITaCustomerBettingSportService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
+
 /**
  * <p>
  * 客户投注竞彩明细  服务实现类
@@ -17,4 +20,13 @@ import org.springframework.stereotype.Service;
 @Service
 public class TaCustomerBettingSportServiceImpl extends ServiceImpl<TaCustomerBettingSportMapper, TaCustomerBettingSport> implements ITaCustomerBettingSportService {
 
+    @Override
+    public List<TaCustomerBettingSport> getListByBetting(Integer bettingId, Integer itemNo) throws Exception {
+        QueryWrapper<TaCustomerBettingSport> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("betting_id", bettingId);
+        queryWrapper.eq("item_no", itemNo);
+        queryWrapper.orderByAsc("create_date");
+
+        return list(queryWrapper);
+    }
 }

src/main/java/com/yunzhi/niucai/service/impl/TaLotteryResultServiceImpl.java

@@ -14,6 +14,7 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
@@ -78,6 +79,7 @@ public class TaLotteryResultServiceImpl extends ServiceImpl<TaLotteryResultMappe
      * 校验客户是否中奖, 如果中奖，则进行中奖相关更新
      * @throws Exception
      */
+    @Transactional(rollbackFor = Exception.class)
     public void checkAndSetLotteryPrize() throws Exception {
         LocalDateTime now = LocalDateTime.now();
         String today = now.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));

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

@@ -2,17 +2,17 @@ package com.yunzhi.niucai.service.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.yunzhi.niucai.common.DateUtils;
-import com.yunzhi.niucai.entity.TaMatch;
-import com.yunzhi.niucai.entity.TaMatchOdds;
-import com.yunzhi.niucai.entity.TaMatchWay;
+import com.yunzhi.niucai.entity.*;
+import com.yunzhi.niucai.enums.SportOpeningStatusEnum;
 import com.yunzhi.niucai.enums.SportStatusEnum;
 import com.yunzhi.niucai.mapper.TaMatchMapper;
 import com.yunzhi.niucai.mapper.TaMatchOddsMapper;
-import com.yunzhi.niucai.service.ITaMatchService;
+import com.yunzhi.niucai.service.*;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.yunzhi.niucai.service.ITaMatchWayService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.util.ArrayList;
 import java.util.HashMap;
@@ -33,6 +33,15 @@ public class TaMatchServiceImpl extends ServiceImpl<TaMatchMapper, TaMatch> impl
     @Autowired
     ITaMatchWayService iTaMatchWayService;
 
+    @Autowired
+    ITaCustomerBettingService iTaCustomerBettingService;
+
+    @Autowired
+    ITaCustomerBettingItemService iTaCustomerBettingItemService;
+
+    @Autowired
+    ITaCustomerBettingSportService iTaCustomerBettingSportService;
+
     @Autowired
     TaMatchMapper taMatchMapper;
 
@@ -77,4 +86,78 @@ public class TaMatchServiceImpl extends ServiceImpl<TaMatchMapper, TaMatch> impl
     public List<TaMatch> getLastResult() throws Exception {
         return taMatchMapper.getLastResult();
     }
+
+    /**
+     * 体彩是否中奖
+     * @throws Exception
+     */
+    public void checkAndSetSportPrize() throws Exception {
+        List<TaMatch> matchList = taMatchMapper.getLastOpenAndUndoMatch(3);
+        if (null == matchList || matchList.size() == 0) {
+            return;
+        }
+
+        for (TaMatch taMatch : matchList) {
+            try {
+                taMatch.setOpeningStatus(SportOpeningStatusEnum.DOING.getCode());
+                updateById(taMatch);
+
+                String lotteryId = taMatch.getLotteryId();
+                switch (lotteryId) {
+                    case "football":
+                        setFootballPrize(taMatch);
+                        break;
+                    case "basketball":
+                        setBasketballPrize(taMatch);
+                        break;
+                    default:
+                        break;
+                }
+
+            } catch (Exception e) {
+                // TODO 比如错误日志记录
+                taMatch.setOpeningStatus(SportOpeningStatusEnum.READY.getCode());
+                updateById(taMatch);
+            }
+        }
+    }
+
+    /**
+     * 足球开奖
+     * @param taMatch
+     * @throws Exception
+     */
+    @Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRES_NEW)
+    private void setFootballPrize(TaMatch taMatch) throws Exception {
+        // 获取当前比赛的投注列表
+        List<TaCustomerBettingItem> bettingItemList = iTaCustomerBettingItemService.getUnDealItems(taMatch);
+        if (null == bettingItemList || bettingItemList.size() == 0) {
+            return;
+        }
+
+        for (TaCustomerBettingItem item: bettingItemList) {
+            // 主记录
+            TaCustomerBetting betting = iTaCustomerBettingService.getById(item.getBettingId());
+            // 投注列表
+            List<TaCustomerBettingSport> bettingSportList = iTaCustomerBettingSportService.getListByBetting(item.getBettingId(), item.getItemNo());
+
+            for (TaCustomerBettingSport bettingSport : bettingSportList) {
+
+            }
+        }
+    }
+
+    /**
+     * 篮球开奖
+     * @param taMatch
+     * @throws Exception
+     */
+    @Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRES_NEW)
+    private void setBasketballPrize(TaMatch taMatch) throws Exception {
+
+    }
+
+    private boolean isWining(TaMatch taMatch, TaCustomerBettingSport bettingSport) {
+        return false;
+    }
 }

src/main/resources/mapper/TaCustomerBettingItemMapper.xml

@@ -2,4 +2,14 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.yunzhi.niucai.mapper.TaCustomerBettingItemMapper">
 
+    <select id="getUnDealItems" resultType="com.yunzhi.niucai.entity.TaCustomerBettingItem">
+        SELECT
+            t.*
+        FROM
+            ta_customer_betting_item t
+        INNER JOIN ta_betting_plan_item s ON t.plan_item_no = s.item_no
+        WHERE
+            t.opening_status = 0
+            AND s.match_id = #{matchId};
+    </select>
 </mapper>

src/main/resources/mapper/TaMatchMapper.xml

@@ -28,4 +28,16 @@
             ) s
         GROUP BY s.lottery_id
     </select>
+    <select id="getLastOpenAndUndoMatch" resultType="com.yunzhi.niucai.entity.TaMatch">
+        SELECT
+            *
+        FROM
+            ta_match t
+        WHERE
+            t.`status` &gt; 1
+            AND t.opening_status = 0
+            AND t.match_date >= DATE_FORMAT( CURRENT_DATE - #{days}, '%Y-%m-%d' )
+        ORDER BY
+            t.match_id ASC
+    </select>
 </mapper>