feats

src/main/java/com/yunzhi/niucai/controller/TaOrderController.java

@@ -0,0 +1,119 @@
+package com.yunzhi.niucai.controller;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yunzhi.niucai.common.BaseController;
+import com.yunzhi.niucai.common.ResponseBean;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.ApiParam;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+import com.yunzhi.niucai.service.ITaOrderService;
+import com.yunzhi.niucai.entity.TaOrder;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * <p>
+    * 订单主表  前端控制器
+    * </p>
+ *
+ * @author yansen
+ * @since 2020-09-09
+ */
+
+@Api(tags = "订单主表 ")
+@RestController
+@RequestMapping("/")
+public class TaOrderController extends BaseController {
+
+    private final Logger logger = LoggerFactory.getLogger(TaOrderController.class);
+
+    @Autowired
+    public ITaOrderService iTaOrderService;
+
+//
+//    /**
+//     * 分页查询列表
+//     * @param pageNum
+//     * @param pageSize
+//     * @return
+//     */
+//    @RequestMapping(value="/taOrder",method= RequestMethod.GET)
+//    @ApiOperation(value="列表", notes = "列表", httpMethod = "GET", response = ResponseBean.class)
+//    public ResponseBean taOrderList(@ApiParam("页码") @RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+//									 @ApiParam("单页数据量") @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize) throws Exception{
+//
+//		    IPage<TaOrder> pg = new Page<>(pageNum, pageSize);
+//            QueryWrapper<TaOrder> queryWrapper = new QueryWrapper<>();
+//            queryWrapper.orderByDesc("create_date");
+//
+//            IPage<TaOrder> result = iTaOrderService.page(pg, queryWrapper);
+//            return ResponseBean.success(result);
+//    }
+//
+//    /**
+//     * 保存对象
+//     * @param taOrder 实体对象
+//     * @return
+//     */
+//    @RequestMapping(value="/taOrder",method= RequestMethod.POST)
+//    @ApiOperation(value="保存", notes = "保存", httpMethod = "POST", response = ResponseBean.class)
+//    public ResponseBean taOrderAdd(@ApiParam("保存内容") @RequestBody TaOrder taOrder) throws Exception{
+//
+//        if (iTaOrderService.save(taOrder)){
+//            return ResponseBean.success(taOrder);
+//        }else {
+//            return ResponseBean.error("保存失败, 请重试", ResponseBean.ERROR_UNAVAILABLE);
+//        }
+//    }
+//
+//    /**
+//     * 根据id删除对象
+//     * @param id  实体ID
+//     */
+//    @RequestMapping(value="/taOrder/{id}", method= RequestMethod.DELETE)
+//    @ApiOperation(value="删除", notes = "删除", httpMethod = "DELETE", response = ResponseBean.class)
+//    public ResponseBean taOrderDelete(@ApiParam("对象ID") @PathVariable Integer id) throws Exception{
+//        if(iTaOrderService.removeById(id)){
+//            return ResponseBean.success("success");
+//        }else {
+//            return ResponseBean.error("删除失败, 请重试", ResponseBean.ERROR_UNAVAILABLE);
+//        }
+//    }
+//
+//    /**
+//     * 修改对象
+//     * @param id  实体ID
+//     * @param taOrder 实体对象
+//     * @return
+//     */
+//    @RequestMapping(value="/taOrder/{id}",method= RequestMethod.PUT)
+//    @ApiOperation(value="更新", notes = "更新", httpMethod = "PUT", response = ResponseBean.class)
+//    public ResponseBean taOrderUpdate(@ApiParam("对象ID") @PathVariable Integer id,
+//                                        @ApiParam("更新内容") @RequestBody TaOrder taOrder) throws Exception{
+//
+//        if (iTaOrderService.updateById(taOrder)){
+//            return ResponseBean.success(iTaOrderService.getById(id));
+//        }else {
+//            return ResponseBean.error("修改失败, 请重试", ResponseBean.ERROR_UNAVAILABLE);
+//        }
+//    }
+//
+//    /**
+//     * 根据id查询对象
+//     * @param id  实体ID
+//     */
+//    @RequestMapping(value="/taOrder/{id}",method= RequestMethod.GET)
+//    @ApiOperation(value="详情", notes = "详情", httpMethod = "GET", response = ResponseBean.class)
+//    public ResponseBean taOrderGet(@ApiParam("对象ID") @PathVariable Integer id) throws Exception{
+//        return ResponseBean.success(iTaOrderService.getById(id));
+//    }
+}

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

@@ -2,6 +2,9 @@ package com.yunzhi.niucai.entity;
 
 import java.time.LocalDateTime;
 import java.io.Serializable;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import lombok.experimental.Accessors;
@@ -24,6 +27,7 @@ public class SysRecommendShop implements Serializable {
     /**
      * 店铺ID
      */
+    @TableId(value = "shop_id", type = IdType.INPUT)
     private Integer shopId;
 
     /**
@@ -39,7 +43,7 @@ public class SysRecommendShop implements Serializable {
     /**
      * 状态
      */
-    private Boolean status;
+    private Integer status;
 
 
 }

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

@@ -74,10 +74,18 @@ public class TaBettingPlan implements Serializable {
     @TableField(exist = false)
     private Integer notesNum;
 
+    @ApiModelProperty("是否追加")
+    @TableField(exist = false)
+    private Boolean isAdd;
+
     @ApiModelProperty("投注金额: 单位分")
     @TableField(exist = false)
     private Integer totalPrice;
 
+    @ApiModelProperty("预期收益: 单位分")
+    @TableField(exist = false)
+    private String expectedEarning;
+
     @ApiModelProperty("投注店铺")
     @TableField(exist = false)
     private Integer shopId;
@@ -90,6 +98,10 @@ public class TaBettingPlan implements Serializable {
     @TableField(exist = false)
     private String issueNo;
 
+    @ApiModelProperty("投注人名称")
+    @TableField(exist = false)
+    private String customerName;
+
     @ApiModelProperty("方案明细")
     @TableField(exist = false)
     private List<TaBettingPlanItem> itemList;

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

@@ -4,7 +4,9 @@ import java.time.LocalDateTime;
 import java.io.Serializable;
 import java.util.List;
 
+import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
@@ -28,10 +30,11 @@ public class TaBettingPlanItem implements Serializable {
     private static final long serialVersionUID = 1L;
 
     @ApiModelProperty(value = "条目ID")
-    private String itemNo;
+    @TableId(value = "item_no", type = IdType.AUTO)
+    private Integer itemNo;
 
     @ApiModelProperty(value = "方案ID")
-    private String planId;
+    private Integer planId;
 
     @ApiModelProperty(value = "方案简介")
     private String summary;

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

@@ -55,7 +55,7 @@ public class TaBettingPlanSportDetail implements Serializable {
     private LocalDateTime createDate;
 
     @ApiModelProperty(value = "状态")
-    private Boolean status;
+    private Integer status;
 
 
 }

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

@@ -94,7 +94,7 @@ public class TaCustomerBetting implements Serializable {
     private LocalDateTime createDate;
 
     @ApiModelProperty(value = "状态")
-    private Boolean status;
+    private Integer status;
 
 
 }

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

@@ -55,7 +55,7 @@ public class TaCustomerBettingSport implements Serializable {
     private LocalDateTime createDate;
 
     @ApiModelProperty(value = "状态")
-    private Boolean status;
+    private Integer status;
 
 
 }

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

@@ -67,7 +67,7 @@ public class TaMatchWay implements Serializable {
     /**
      * 状态
      */
-    private Boolean status;
+    private Integer status;
 
 
 }

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

@@ -0,0 +1,61 @@
+package com.yunzhi.niucai.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import java.time.LocalDateTime;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.io.Serializable;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+/**
+ * <p>
+ * 订单主表 
+ * </p>
+ *
+ * @author yansen
+ * @since 2020-09-09
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@ApiModel(value="TaOrder对象", description="订单主表 ")
+public class TaOrder implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty(value = "订单ID")
+    @TableId(value = "order_id", type = IdType.INPUT)
+    private String orderId;
+
+    @ApiModelProperty(value = "订单类型 充值,购彩等")
+    private String orderType;
+
+    @ApiModelProperty(value = "数量 购彩则使用倍数")
+    private Integer amount;
+
+    @ApiModelProperty(value = "金额 单位分")
+    private Integer charge;
+
+    @ApiModelProperty(value = "店铺ID")
+    private Integer shopId;
+
+    @ApiModelProperty(value = "下单人")
+    private Integer customerId;
+
+    @ApiModelProperty(value = "对应投注")
+    private Integer bettingId;
+
+    @ApiModelProperty(value = "是否支付")
+    private Boolean isPayed;
+
+    @ApiModelProperty(value = "创建时间")
+    private LocalDateTime createDate;
+
+    @ApiModelProperty(value = "状态 1有效,0无效")
+    private Integer status;
+
+
+}

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

@@ -4,7 +4,9 @@ import java.time.LocalDateTime;
 import java.io.Serializable;
 import java.util.List;
 
+import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import lombok.experimental.Accessors;
@@ -27,6 +29,7 @@ public class TdLottery implements Serializable {
     /**
      * 彩种ID
      */
+    @TableId(value = "lottery_id", type = IdType.INPUT)
     private String lotteryId;
 
     /**

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

@@ -63,7 +63,7 @@ public class TdLotteryPrize implements Serializable {
     private Integer maxAddPrice;
 
     @ApiModelProperty(value = "状态")
-    private Boolean status;
+    private Integer status;
 
 
 }

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

@@ -4,7 +4,9 @@ import java.time.LocalDateTime;
 import java.io.Serializable;
 import java.util.List;
 
+import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
@@ -31,6 +33,7 @@ public class TdPlayWay implements Serializable {
      * 玩法编码 硬编码,不能修改
      */
     @ApiModelProperty("玩法编码")
+    @TableId(value = "way_code", type = IdType.INPUT)
     private String wayCode;
 
     /**

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

@@ -40,7 +40,7 @@ public class TdSportOnSale implements Serializable {
     private LocalDateTime createDate;
 
     @ApiModelProperty(value = "状态")
-    private Boolean status;
+    private Integer status;
 
 
 }

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

@@ -3,7 +3,9 @@ package com.yunzhi.niucai.entity;
 import java.time.LocalDateTime;
 import java.io.Serializable;
 
+import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
@@ -30,6 +32,7 @@ public class TdSportPass implements Serializable {
      * 过关 m*n格式
      */
     @ApiModelProperty("过关 m*n格式")
+    @TableId(value = "pass_code", type = IdType.INPUT)
     private String passCode;
 
     /**

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

@@ -3,6 +3,8 @@ package com.yunzhi.niucai.entity;
 import java.time.LocalDateTime;
 import java.io.Serializable;
 
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
@@ -29,6 +31,7 @@ public class TdSportRules implements Serializable {
      * 编码
      */
     @ApiModelProperty("编码")
+    @TableId(value = "rule_code", type = IdType.INPUT)
     private String ruleCode;
 
     /**

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

@@ -1,7 +1,5 @@
 package com.yunzhi.niucai.enums;
 
-import io.swagger.annotations.ApiModel;
-import io.swagger.annotations.ApiModelProperty;
 import lombok.AllArgsConstructor;
 import lombok.Getter;
 

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

@@ -0,0 +1,13 @@
+package com.yunzhi.niucai.enums;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+@Getter
+@AllArgsConstructor
+public enum OrderTypeEnum {
+    BUY_LOTTERY("buy-lottery", "购彩");
+
+    private String code;
+    private String desc;
+}

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

@@ -0,0 +1,21 @@
+package com.yunzhi.niucai.mapper;
+
+import com.yunzhi.niucai.entity.TaOrder;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Select;
+
+/**
+ * <p>
+ * 订单主表  Mapper 接口
+ * </p>
+ *
+ * @author yansen
+ * @since 2020-09-09
+ */
+@Mapper
+public interface TaOrderMapper extends BaseMapper<TaOrder> {
+
+    @Select("select val from sys_nextval where seq_key = #{seqKey}")
+    Integer nextval(String seqKey) throws Exception;
+}

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

@@ -1,5 +1,6 @@
 package com.yunzhi.niucai.service;
 
+import com.yunzhi.niucai.entity.TaBettingPlan;
 import com.yunzhi.niucai.entity.TaCustomerBetting;
 import com.baomidou.mybatisplus.extension.service.IService;
 
@@ -13,4 +14,5 @@ import com.baomidou.mybatisplus.extension.service.IService;
  */
 public interface ITaCustomerBettingService extends IService<TaCustomerBetting> {
 
+    TaCustomerBetting saveByBetting(TaBettingPlan taBettingPlan) throws Exception;
 }

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

@@ -0,0 +1,19 @@
+package com.yunzhi.niucai.service;
+
+import com.yunzhi.niucai.entity.TaBettingPlan;
+import com.yunzhi.niucai.entity.TaCustomerBetting;
+import com.yunzhi.niucai.entity.TaOrder;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ * 订单主表  服务类
+ * </p>
+ *
+ * @author yansen
+ * @since 2020-09-09
+ */
+public interface ITaOrderService extends IService<TaOrder> {
+
+    TaOrder placeOrderBy(TaBettingPlan taBettingPlan, TaCustomerBetting taCustomerBetting) throws Exception;
+}

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

@@ -5,11 +5,14 @@ import com.yunzhi.niucai.common.StringUtils;
 import com.yunzhi.niucai.entity.*;
 import com.yunzhi.niucai.enums.SportStatusEnum;
 import com.yunzhi.niucai.enums.StatusEnum;
+import com.yunzhi.niucai.mapper.TaBettingPlanItemMapper;
 import com.yunzhi.niucai.mapper.TaBettingPlanMapper;
+import com.yunzhi.niucai.mapper.TaBettingPlanSportDetailMapper;
 import com.yunzhi.niucai.service.*;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -44,19 +47,46 @@ public class TaBettingPlanServiceImpl extends ServiceImpl<TaBettingPlanMapper, T
     @Autowired
     ITaShopService iTaShopService;
 
+    @Autowired
+    ITaCustomerBettingService iTaCustomerBettingService;
+
+    @Autowired
+    ITaOrderService iTaOrderService;
+
+    @Autowired
+    TaBettingPlanItemMapper taBettingPlanItemMapper;
+
+    @Autowired
+    TaBettingPlanSportDetailMapper taBettingPlanSportDetailMapper;
+
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public boolean betting(TaBettingPlan taBettingPlan, TaCustomer customer) throws Exception {
         //
         validateBetting(taBettingPlan);
 
         taBettingPlan.setCustomerId(customer.getCustomerId());
+        taBettingPlan.setCustomerName(customer.getName());
         taBettingPlan.setStatus(StatusEnum.READY.getCode());
 
+        if (StringUtils.isEmpty(taBettingPlan.getAliaTitle())) {
+            String aliaTitle = taBettingPlan.getIsSport()
+                ? String.format("%s %s", taBettingPlan.getLotteryName(), taBettingPlan.getPassName())
+                    : String.format("%s", taBettingPlan.getLotteryName());
+            taBettingPlan.setAliaTitle(aliaTitle);
+        }
+
         // 入库
+        saveBettingPlan(taBettingPlan);
 
-        // 我的
+        // 生成我的下单
+        TaCustomerBetting taCustomerBetting = iTaCustomerBettingService.saveByBetting(taBettingPlan);
 
         // 下单
+        TaOrder order = iTaOrderService.placeOrderBy(taBettingPlan, taCustomerBetting);
+
+        // 支付接口
+
         return true;
     }
 
@@ -171,7 +201,7 @@ public class TaBettingPlanServiceImpl extends ServiceImpl<TaBettingPlanMapper, T
 
             // 不能超过限额
             Integer maxPrice = tdLottery.getMaxPrice();
-            if (tdLottery.getIsAdd()) {
+            if (null != taBettingPlan.getIsAdd() && taBettingPlan.getIsAdd()) {
                 maxPrice = tdLottery.getMaxAddPrice();
             }
             if (maxPrice < totalCharges) {
@@ -287,4 +317,28 @@ public class TaBettingPlanServiceImpl extends ServiceImpl<TaBettingPlanMapper, T
 
         return;
     }
+
+    private void saveBettingPlan(TaBettingPlan taBettingPlan) throws Exception {
+        if (!save(taBettingPlan)) {
+            throw new Exception("生成投注方案出错");
+        }
+
+        for (TaBettingPlanItem item: taBettingPlan.getItemList()) {
+            item.setPlanId(taBettingPlan.getPlanId());
+
+            int effectRows = taBettingPlanItemMapper.insert(item);
+            if (effectRows < 1) {
+                throw new Exception("生成投注方案明细出错");
+            }
+
+            if (null != item.getDetailList() && item.getDetailList().size() > 0) {
+                for(TaBettingPlanSportDetail detail: item.getDetailList()) {
+                    detail.setItemNo(item.getItemNo());
+                    if (taBettingPlanSportDetailMapper.insert(detail) < 1) {
+                        throw new Exception("生成投注方案玩法明细出错");
+                    }
+                }
+            }
+        }
+    }
 }

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

@@ -1,10 +1,14 @@
 package com.yunzhi.niucai.service.impl;
 
-import com.yunzhi.niucai.entity.TaCustomerBetting;
+import com.yunzhi.niucai.entity.*;
+import com.yunzhi.niucai.enums.StatusEnum;
 import com.yunzhi.niucai.mapper.TaCustomerBettingMapper;
+import com.yunzhi.niucai.mapper.TaCustomerBettingSportMapper;
 import com.yunzhi.niucai.service.ITaCustomerBettingService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 /**
  * <p>
@@ -17,4 +21,57 @@ import org.springframework.stereotype.Service;
 @Service
 public class TaCustomerBettingServiceImpl extends ServiceImpl<TaCustomerBettingMapper, TaCustomerBetting> implements ITaCustomerBettingService {
 
+    @Autowired
+    TaCustomerBettingSportMapper taCustomerBettingSportMapper;
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public TaCustomerBetting saveByBetting(TaBettingPlan plan) throws Exception {
+        TaCustomerBetting taCustomerBetting = new TaCustomerBetting();
+        taCustomerBetting.setCustomerId(plan.getCustomerId());
+        taCustomerBetting.setCustomerName(plan.getCustomerName());
+        taCustomerBetting.setShopId(plan.getShopId());
+        taCustomerBetting.setShopName(plan.getShopName());
+        taCustomerBetting.setPlanId(plan.getPlanId());
+        taCustomerBetting.setPlanName(plan.getAliaTitle());
+        taCustomerBetting.setLotteryId(plan.getLotteryId());
+        taCustomerBetting.setLotteryName(plan.getLotteryName());
+        taCustomerBetting.setIssueNo(plan.getIssueNo());
+        taCustomerBetting.setBettingTimes(plan.getTimes());
+        taCustomerBetting.setIsAdd(plan.getIsAdd());
+        taCustomerBetting.setNotesNum(plan.getNotesNum());
+        taCustomerBetting.setTotalPrice(plan.getTotalPrice());
+        taCustomerBetting.setExpectedEarning(plan.getExpectedEarning());
+        taCustomerBetting.setIsPrinted(false);
+        taCustomerBetting.setIsOpen(false);
+        taCustomerBetting.setIsWinning(false);
+        taCustomerBetting.setStatus(StatusEnum.READY.getCode());
+
+        if (!save(taCustomerBetting)) {
+            throw new Exception("生成我的投注失败");
+        }
+
+        if (null != plan.getItemList()) {
+            for (TaBettingPlanItem item: plan.getItemList()) {
+                if (null != item.getDetailList()) {
+                    for (TaBettingPlanSportDetail detail: item.getDetailList()) {
+                        TaCustomerBettingSport bettingSport = new TaCustomerBettingSport();
+                        bettingSport.setBettingId(taCustomerBetting.getBettingId());
+                        bettingSport.setItemNo(item.getItemNo());
+                        bettingSport.setDetailNo(detail.getSerialNo());
+                        bettingSport.setMatchId(item.getMatchId());
+                        bettingSport.setRuleCode(detail.getRuleCode());
+                        bettingSport.setOddsOrdered(detail.getOdds());
+                        bettingSport.setStatus(StatusEnum.NORMAL.getCode());
+
+                        if (taCustomerBettingSportMapper.insert(bettingSport) < 1) {
+                            throw new Exception("生成我的投注明细失败");
+                        }
+                    }
+                }
+            }
+        }
+
+        return taCustomerBetting;
+    }
 }

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

@@ -0,0 +1,71 @@
+package com.yunzhi.niucai.service.impl;
+
+import com.yunzhi.niucai.common.DateUtils;
+import com.yunzhi.niucai.common.StringUtils;
+import com.yunzhi.niucai.entity.TaBettingPlan;
+import com.yunzhi.niucai.entity.TaCustomerBetting;
+import com.yunzhi.niucai.entity.TaOrder;
+import com.yunzhi.niucai.enums.OrderTypeEnum;
+import com.yunzhi.niucai.enums.StatusEnum;
+import com.yunzhi.niucai.mapper.TaOrderMapper;
+import com.yunzhi.niucai.service.ITaOrderService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * <p>
+ * 订单主表  服务实现类
+ * </p>
+ *
+ * @author yansen
+ * @since 2020-09-09
+ */
+@Service
+public class TaOrderServiceImpl extends ServiceImpl<TaOrderMapper, TaOrder> implements ITaOrderService {
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public TaOrder placeOrderBy(TaBettingPlan taBettingPlan, TaCustomerBetting taCustomerBetting) throws Exception {
+        TaOrder order = new TaOrder();
+        order.setOrderId(nextOrderNo("BL", 16, true));
+        order.setOrderType(OrderTypeEnum.BUY_LOTTERY.getCode());
+        order.setAmount(taCustomerBetting.getBettingTimes());
+        order.setCharge(taCustomerBetting.getTotalPrice());
+        order.setShopId(taCustomerBetting.getShopId());
+        order.setCustomerId(taCustomerBetting.getCustomerId());
+        order.setBettingId(taCustomerBetting.getBettingId());
+        order.setIsPayed(false);    // 未支付
+        order.setStatus(StatusEnum.NORMAL.getCode());
+
+        if (!save(order)) {
+            throw new Exception("生成购彩订单失败");
+        }
+
+        return order;
+    }
+
+    private String nextOrderNo(String prefix, int length, boolean padDate) {
+        List<String> parts = new ArrayList<>();
+        parts.add(prefix);
+
+        String dtStr = null;
+        if (padDate) {
+            dtStr = DateUtils.todayCompact();
+            parts.add(dtStr);
+        }
+
+        int fillLength = length - prefix.length();
+        if (padDate) {
+            fillLength -= dtStr.length();
+        }
+
+        String zeros = StringUtils.repeat("0", fillLength);
+        parts.add(zeros);
+
+        return String.join("-", parts);
+    }
+}

src/main/resources/mapper/TaOrderMapper.xml

@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.yunzhi.niucai.mapper.TaOrderMapper">
+
+</mapper>