feata

src/main/java/com/yunzhi/niucai/common/ArrayUtils.java

@@ -0,0 +1,4 @@
+package com.yunzhi.niucai.common;
+
+public class ArrayUtils {
+}

src/main/java/com/yunzhi/niucai/common/BizUtils.java

@@ -112,4 +112,16 @@ public class BizUtils {
         // 计算排列 7 个 选 3 个
         return EncryptUtils.combination(leftSize, canUse);
     }
+
+    public static int getSameNums(List<String> tar, List<String> src, List<String> dan) {
+        if (null == tar || tar.size() == 0) {
+            return 0;
+        }
+
+        if (null == src && src.size() == 0) {
+            return 0;
+        }
+
+        return 0;
+    }
 }

src/main/java/com/yunzhi/niucai/common/CommConstants.java

@@ -0,0 +1,34 @@
+package com.yunzhi.niucai.common;
+
+public class CommConstants {
+
+    /**
+     * 大乐透
+     */
+    public final static String LOTTERY_LOTTERY = "lottery";
+
+    /**
+     * 排列三
+     */
+    public final static String LOTTERY_P3 = "p3";
+
+    /**
+     * 排列五
+     */
+    public final static String LOTTERY_P5 = "p5";
+
+    /**
+     * 双色球
+     */
+    public final static String LOTTERY_DOUBLE = "double-color";
+
+    /**
+     * 足球
+     */
+    public final static String LOTTERY_FOOTBALL = "football";
+
+    /**
+     * 篮球
+     */
+    public final static String LOTTERY_BASKETBALL = "basketball";
+}

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

@@ -60,6 +60,9 @@ public class TaCustomerBetting implements Serializable {
     @ApiModelProperty(value = "投注期数")
     private String issueNo;
 
+    @ApiModelProperty(value = "开奖日期")
+    private String openingDate;
+
     @ApiModelProperty(value = "投注倍数")
     private Integer bettingTimes;
 
@@ -102,4 +105,8 @@ public class TaCustomerBetting implements Serializable {
     @ApiModelProperty(value = "体彩相关明细")
     @TableField(exist = false)
     List<TaCustomerBettingSport> bettingSports;
+
+    @ApiModelProperty(value = "投注方案")
+    @TableField(exist = false)
+    TaBettingPlan bettingPlan;
 }

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

@@ -3,7 +3,10 @@ package com.yunzhi.niucai.service;
 import com.yunzhi.niucai.entity.TaBettingPlan;
 import com.yunzhi.niucai.entity.TaCustomerBetting;
 import com.baomidou.mybatisplus.extension.service.IService;
+import com.yunzhi.niucai.entity.TaLotteryResult;
+import com.yunzhi.niucai.entity.TdLottery;
 
+import java.util.List;
 import java.util.Map;
 
 /**
@@ -19,4 +22,6 @@ public interface ITaCustomerBettingService extends IService<TaCustomerBetting> {
     TaCustomerBetting saveByBetting(TaBettingPlan taBettingPlan) throws Exception;
 
     Map<String, Object> getSummaryOf(Integer id) throws Exception;
+
+    List<TaCustomerBetting> getAllUnOpenBettingsBy(TdLottery lottery, TaLotteryResult lotteryResult) throws Exception;
 }

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

@@ -15,4 +15,6 @@ import com.yunzhi.niucai.vo.SignUpParam;
 public interface ITaCustomerService extends IService<TaCustomer> {
 
     boolean signUp(SignUpParam signUpParam) throws Exception;
+
+    TaCustomer getCustomerByPhone(String phone) throws Exception;
 }

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

@@ -17,4 +17,6 @@ import java.util.List;
 public interface ITdLotteryOnSaleService extends IService<TdLotteryOnSale> {
 
     List<TdLotteryOnSale> getByLottery(TdLottery lottery) throws Exception;
+
+    List<TdLotteryOnSale> getByWeekDay(int weekDay) throws Exception;
 }

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

@@ -2,6 +2,7 @@ package com.yunzhi.niucai.service.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.yunzhi.niucai.common.BizUtils;
+import com.yunzhi.niucai.common.DateUtils;
 import com.yunzhi.niucai.common.EncryptUtils;
 import com.yunzhi.niucai.common.StringUtils;
 import com.yunzhi.niucai.entity.*;
@@ -174,6 +175,14 @@ public class TaBettingPlanServiceImpl extends ServiceImpl<TaBettingPlanMapper, T
             }
         }
 
+        // 销售时间
+        if (taBettingPlan.getIsSport()) {
+            String currentTime = LocalDateTime.now().format(DateTimeFormatter.ofPattern("HH:mm"));
+            if (currentTime.compareTo(taShopLottery.getOpeningTime()) < 0 || currentTime.compareTo(taShopLottery.getClosingTime()) > 0) {
+                throw new Exception("非当前店铺彩票开售时间");
+            }
+        }
+
         return;
     }
 
@@ -298,7 +307,11 @@ public class TaBettingPlanServiceImpl extends ServiceImpl<TaBettingPlanMapper, T
                 throw new Exception("投注彩种缺失开奖结果相关数据");
             }
 
-            Integer newIssueNo = Integer.valueOf(taLotteryResult.getIssueNo()) + 1;
+            String lastOpeningDate = taLotteryResult.getOpeningDate();
+            Integer lastIssueNo = Integer.valueOf(taLotteryResult.getIssueNo());
+
+            // 默认期数是最近一次开奖 + 1
+            Integer newIssueNo = lastIssueNo + 1;
 
             // 查询当前彩种的停售时间
             List<TdLotteryOnSale> onSaleSettings = tdLottery.getOnSaleSettings();
@@ -306,26 +319,28 @@ public class TaBettingPlanServiceImpl extends ServiceImpl<TaBettingPlanMapper, T
                 throw new Exception("投注彩种缺失开奖配置相关数据");
             }
 
+            // 找出今天对应的开奖设置
             LocalDateTime now = LocalDateTime.now();
-
-            // 今天是周几
             int weekDay = now.getDayOfWeek().getValue();
             TdLotteryOnSale saleSetting = getSaleSetting(onSaleSettings, weekDay);
-            if (weekDay == saleSetting.getWeekDay()) {
-                // 如果是今天开奖, 要看是否过了开奖时间
+
+            // 如果是今天开奖
+            if (weekDay == saleSetting.getWeekDay() && DateUtils.today().equals(lastOpeningDate)) {
+                // 找出店铺设置的停售时间
+                TaShopLottery taShopLottery = iTaShopLotteryService.getSettingBy(taBettingPlan.getShopId(), taBettingPlan.getLotteryId());
+                if (null == taShopLottery) {
+                    throw new Exception("当前店铺没有相关彩种设置");
+                }
+
+                // 如果超过了店铺的停售时间, 那么今天购买的只能是下期
                 String currentTime = now.format(DateTimeFormatter.ofPattern("HH:mm"));
-                if (currentTime.compareTo(saleSetting.getLotteryTime()) >= 0) {
+                if (currentTime.compareTo(taShopLottery.getClosingTime()) >= 0) {
                     newIssueNo += 1;
                 }
-                // 查看是否过了店家开售时间
-                // todo
             }
 
             taBettingPlan.setIssueNo(String.valueOf(newIssueNo));
         }
-
-        // todo 校验停售时间
-
     }
 
     private TdLotteryOnSale getSaleSetting(List<TdLotteryOnSale> onSaleSettings, int weekDay) {

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

@@ -106,6 +106,28 @@ public class TaCustomerBettingServiceImpl extends ServiceImpl<TaCustomerBettingM
         return result;
     }
 
+    @Override
+    public List<TaCustomerBetting> getAllUnOpenBettingsBy(TdLottery lottery, TaLotteryResult lotteryResult) throws Exception {
+        QueryWrapper<TaCustomerBetting> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("lottery_id", lottery.getLotteryId());
+        queryWrapper.eq("issue_no", lotteryResult.getIssueNo());
+        queryWrapper.eq("is_open", false);
+        queryWrapper.eq("status", StatusEnum.NORMAL.getCode());
+
+        List<TaCustomerBetting> list = list(queryWrapper);
+        if (null != list && list.size() > 0) {
+            for (TaCustomerBetting betting : list) {
+                if (lottery.getIsSport()) {
+                    betting.setBettingSports(getBettingSportByBetting(betting));
+                }
+
+                betting.setBettingPlan(iTaBettingPlanService.getDetailOfPlanById(betting.getPlanId()));
+            }
+        }
+
+        return list;
+    }
+
     private List<TaCustomerBettingSport> getBettingSportByBetting(TaCustomerBetting betting) throws Exception {
         QueryWrapper<TaCustomerBettingSport> queryWrapper = new QueryWrapper<>();
         queryWrapper.eq("betting_id", betting.getBettingId());

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

@@ -13,10 +13,13 @@ import com.yunzhi.niucai.service.ITaCustomerService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.yunzhi.niucai.service.ITaShopService;
 import com.yunzhi.niucai.vo.SignUpParam;
+import org.apache.ibatis.annotations.Param;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.util.List;
+
 /**
  * <p>
  * 客户 服务实现类
@@ -43,6 +46,23 @@ public class TaCustomerServiceImpl extends ServiceImpl<TaCustomerMapper, TaCusto
         taCustomer.setReferralCode(signUpParam.getReferralCode());
         taCustomer.setStatus(StatusEnum.NORMAL.getCode());
 
+        // 手机号唯一
+        TaCustomer customerByPhone = getCustomerByPhone(signUpParam.getPhone());
+        if (null != customerByPhone) {
+            throw new Exception("当前手机号已经注册");
+        }
+
+        // 生成自己的邀请码
+        boolean exists = true;
+        while (exists) {
+            String inviteCode = ReferralCodeEnum.CUSTOMER_START.getCode() + "-" + EncryptUtils.randDigitStr(6);
+            TaCustomer exitCust = getByInviteCode(inviteCode);
+            if (exitCust == null) {
+                exists = false;
+                taCustomer.setInviteCode(inviteCode);
+            }
+        }
+
         if (!save(taCustomer)) {
             throw new Exception("生成个人信息失败");
         }
@@ -90,6 +110,14 @@ public class TaCustomerServiceImpl extends ServiceImpl<TaCustomerMapper, TaCusto
         return true;
     }
 
+    @Override
+    public TaCustomer getCustomerByPhone(String phone) throws Exception {
+        QueryWrapper<TaCustomer> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("phone", phone);
+        queryWrapper.gt("status", StatusEnum.DELETED.getCode());
+        return getOne(queryWrapper);
+    }
+
     private TaCustomer getByInviteCode(String inviteCode) throws Exception {
         QueryWrapper<TaCustomer> queryWrapper = new QueryWrapper<>();
         queryWrapper.eq("invite_code", inviteCode);

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

@@ -1,15 +1,21 @@
 package com.yunzhi.niucai.service.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
-import com.yunzhi.niucai.entity.TaLotteryResult;
-import com.yunzhi.niucai.entity.TdLottery;
+import com.yunzhi.niucai.common.CommConstants;
+import com.yunzhi.niucai.entity.*;
 import com.yunzhi.niucai.enums.StatusEnum;
 import com.yunzhi.niucai.mapper.TaLotteryResultMapper;
+import com.yunzhi.niucai.service.ITaCustomerBettingService;
 import com.yunzhi.niucai.service.ITaLotteryResultService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.yunzhi.niucai.service.ITdLotteryOnSaleService;
+import com.yunzhi.niucai.service.ITdLotteryService;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
 import java.util.List;
 
 /**
@@ -20,8 +26,19 @@ import java.util.List;
  * @author yansen
  * @since 2020-08-27
  */
+@Slf4j
 @Service
 public class TaLotteryResultServiceImpl extends ServiceImpl<TaLotteryResultMapper, TaLotteryResult> implements ITaLotteryResultService {
+
+    @Autowired
+    ITdLotteryService iTdLotteryService;
+
+    @Autowired
+    ITdLotteryOnSaleService iTdLotteryOnSaleService;
+
+    @Autowired
+    ITaCustomerBettingService iTaCustomerBettingService;
+
     @Autowired
     TaLotteryResultMapper taLotteryResultMapper;
 
@@ -36,8 +53,107 @@ public class TaLotteryResultServiceImpl extends ServiceImpl<TaLotteryResultMappe
         queryWrapper.eq("lottery_id", tdLottery.getLotteryId());
         queryWrapper.eq("status", StatusEnum.NORMAL.getCode());
         queryWrapper.orderByDesc("opening_date");
-        queryWrapper.last("limti 1");
+        queryWrapper.last("limit 1");
+
+        return getOne(queryWrapper);
+    }
+
+    /**
+     * 校验客户是否中奖, 如果中奖，则进行中奖相关更新
+     * @throws Exception
+     */
+    public void checkAndSetLotteryPrize() throws Exception {
+        LocalDateTime now = LocalDateTime.now();
+        String today = now.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
+        int weekDay = now.getDayOfWeek().getValue();
+        List<TdLotteryOnSale> onSaleList = iTdLotteryOnSaleService.getByWeekDay(weekDay);
+        if (null == onSaleList || onSaleList.size() == 0) {
+            log.info(today + "未找到有开奖设置");
+            return;
+        }
+
+        for (TdLotteryOnSale onSale : onSaleList) {
+            String lotteryId = onSale.getLotteryId();
+            log.info(String.format("彩种 %s %s 开奖, 开始检测中奖人员", lotteryId, today));
+
+            // 彩种字典
+            TdLottery lottery = iTdLotteryService.getById(lotteryId);
+
+            // 当前彩种的开奖结果
+            TaLotteryResult lotteryResult = getLotteryResultBy(onSale.getLotteryId(), today);
+            if (null == lotteryResult) {
+                log.error(String.format("彩种 %s 未抓取到开奖结果", lotteryId));
+                continue;
+            }
+
+            switch (lotteryId) {
+                case CommConstants.LOTTERY_LOTTERY:
+                    validLotteryCustomer(lottery, lotteryResult);
+                    break;
+                case CommConstants.LOTTERY_P3:
+                    validP3Customer(lottery, lotteryResult);
+                    break;
+                case CommConstants.LOTTERY_P5:
+                    validP5Customer(lottery, lotteryResult);
+                    break;
+                case CommConstants.LOTTERY_DOUBLE:
+                    validDoubleCustomer(lottery, lotteryResult);
+                    break;
+                case CommConstants.LOTTERY_FOOTBALL:
+                    validFootballCustomer(lottery, lotteryResult);
+                    break;
+                case CommConstants.LOTTERY_BASKETBALL:
+                    validBasketballCustomer(lottery, lotteryResult);
+                    break;
+                default:
+                    break;
+            }
+        }
+    }
+
+    private void validLotteryCustomer(TdLottery lottery, TaLotteryResult lotteryResult) throws Exception {
+        List<TaCustomerBetting> customerBettingList = iTaCustomerBettingService.getAllUnOpenBettingsBy(lottery, lotteryResult);
+        if (null == customerBettingList || customerBettingList.size() == 0) {
+            log.info(String.format("大乐透 %s 期无人投注", lotteryResult.getIssueNo()));
+            return;
+        }
+        
+        for (TaCustomerBetting customerBetting : customerBettingList) {
+            TaBettingPlan taBettingPlan = customerBetting.getBettingPlan();
+            if (null == taBettingPlan) {
+                log.error(String.format("ID %s 的投注没有投注方案", customerBetting.getBettingId()));
+                continue;
+            }
 
+            if (null == taBettingPlan.getItemList() || taBettingPlan.getItemList().size() == 0) {
+                log.error(String.format("ID %s 的投注没有投注明细", customerBetting.getBettingId()));
+                continue;
+            }
+
+
+        }
+    }
+
+    private void validP3Customer(TdLottery lottery, TaLotteryResult lotteryResult) throws Exception {
+    }
+
+    private void validP5Customer(TdLottery lottery, TaLotteryResult lotteryResult) throws Exception {
+    }
+
+    private void validDoubleCustomer(TdLottery lottery, TaLotteryResult lotteryResult) throws Exception {
+    }
+
+    private void validFootballCustomer(TdLottery lottery, TaLotteryResult lotteryResult) throws Exception {
+    }
+
+    private void validBasketballCustomer(TdLottery lottery, TaLotteryResult lotteryResult) throws Exception {
+    }
+
+    public TaLotteryResult getLotteryResultBy(String lotteryId, String openingDate) throws Exception {
+        QueryWrapper<TaLotteryResult> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("lottery_id", lotteryId);
+        queryWrapper.eq("opening_date", openingDate);
+        queryWrapper.eq("status", StatusEnum.NORMAL.getCode());
         return getOne(queryWrapper);
     }
 }

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

@@ -31,4 +31,14 @@ public class TdLotteryOnSaleServiceImpl extends ServiceImpl<TdLotteryOnSaleMappe
 
         return list(queryWrapper);
     }
+
+    @Override
+    public List<TdLotteryOnSale> getByWeekDay(int weekDay) throws Exception {
+        QueryWrapper<TdLotteryOnSale> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("week_day", weekDay);
+        queryWrapper.eq("status", StatusEnum.NORMAL.getCode());
+        queryWrapper.orderByAsc("serial_no");
+
+        return list(queryWrapper);
+    }
 }