feats

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

@@ -220,7 +220,8 @@ public class PayController extends BaseController {
         }
 
         try {
-            iTaOrderService.payCallback(taOrder, outTradeNo, payStatus, failMessage, isSuccess, payTime);
+            TaOrderPay taOrderPay = iTaOrderPayService.getByTradeNo(outTradeNo);
+            iTaOrderService.payCallback(taOrder, taOrderPay, payStatus, failMessage, isSuccess, payTime);
         } catch (Exception e) {
             e.printStackTrace();
             log.error("支付回调处理失败[{}]: {}", outTradeNo, e.getMessage());

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

@@ -113,7 +113,7 @@ public class TaCustomerAccountController extends BaseController {
         payService.FundTrans(transParam);
 
         // 成功之后
-        iTaOrderService.payCallback(taOrder, taOrderPay.getTradeNo(), "SUCCESS", null, true, LocalDateTime.now());
+        iTaOrderService.payCallback(taOrder, taOrderPay, "SUCCESS", null, true, LocalDateTime.now());
 
         return ResponseBean.success("success");
     }

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

@@ -184,7 +184,7 @@ public class TaOrderController extends BaseController {
         payService.FundTrans(transParam);
 
         // 成功之后
-        iTaOrderService.payCallback(taOrder, taOrderPay.getTradeNo(), "SUCCESS", null, true, LocalDateTime.now());
+        iTaOrderService.payCallback(taOrder, taOrderPay, "SUCCESS", null, true, LocalDateTime.now());
 
         customerBetting.setIsCashed(true);
         iTaCustomerBettingService.updateById(customerBetting);

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

@@ -92,73 +92,6 @@ public class TaShopController extends BaseController {
         return ResponseBean.success(updatedValidInfo);
     }
 
-//    /**
-//     * 分页查询列表
-//     * @param pageNum
-//     * @param pageSize
-//     * @return
-//     */
-//    @RequestMapping(value="/app/shop",method= RequestMethod.GET)
-//    @ApiOperation(value="列表", notes = "列表", httpMethod = "GET", response = ResponseBean.class)
-//    public ResponseBean taShopList(@ApiParam("页码") @RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
-//                                   @ApiParam("单页数据量") @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize) throws Exception{
-//
-//		    IPage<TaShop> pg = new Page<>(pageNum, pageSize);
-//            QueryWrapper<TaShop> queryWrapper = new QueryWrapper<>();
-//            queryWrapper.orderByDesc("create_date");
-//
-//            IPage<TaShop> result = iTaShopService.page(pg, queryWrapper);
-//            return ResponseBean.success(result);
-//    }
-//
-//    /**
-//     * 保存对象
-//     * @param taShop 实体对象
-//     * @return
-//     */
-//    @RequestMapping(value="/taShop",method= RequestMethod.POST)
-//    @ApiOperation(value="保存", notes = "保存", httpMethod = "POST", response = ResponseBean.class)
-//    public ResponseBean taShopAdd(@ApiParam("保存内容") @RequestBody TaShop taShop) throws Exception{
-//
-//        if (iTaShopService.save(taShop)){
-//            return ResponseBean.success(taShop);
-//        }else {
-//            return ResponseBean.error("保存失败, 请重试", ResponseBean.ERROR_UNAVAILABLE);
-//        }
-//    }
-//
-//    /**
-//     * 根据id删除对象
-//     * @param id  实体ID
-//     */
-//    @RequestMapping(value="/taShop/{id}", method= RequestMethod.DELETE)
-//    @ApiOperation(value="删除", notes = "删除", httpMethod = "DELETE", response = ResponseBean.class)
-//    public ResponseBean taShopDelete(@ApiParam("对象ID") @PathVariable Integer id) throws Exception{
-//        if(iTaShopService.removeById(id)){
-//            return ResponseBean.success("success");
-//        }else {
-//            return ResponseBean.error("删除失败, 请重试", ResponseBean.ERROR_UNAVAILABLE);
-//        }
-//    }
-//
-//    /**
-//     * 修改对象
-//     * @param id  实体ID
-//     * @param taShop 实体对象
-//     * @return
-//     */
-//    @RequestMapping(value="/taShop/{id}",method= RequestMethod.PUT)
-//    @ApiOperation(value="更新", notes = "更新", httpMethod = "PUT", response = ResponseBean.class)
-//    public ResponseBean taShopUpdate(@ApiParam("对象ID") @PathVariable Integer id,
-//                                        @ApiParam("更新内容") @RequestBody TaShop taShop) throws Exception{
-//
-//        if (iTaShopService.updateById(taShop)){
-//            return ResponseBean.success(iTaShopService.getById(id));
-//        }else {
-//            return ResponseBean.error("修改失败, 请重试", ResponseBean.ERROR_UNAVAILABLE);
-//        }
-//    }
-//
     /**
      * 查询当前店铺信息
      */

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

@@ -71,6 +71,9 @@ public class TaOrder implements Serializable {
     @ApiModelProperty(value = "更新时间")
     private LocalDateTime updateDate;
 
+    @ApiModelProperty(value = "原始订单")
+    private String srcOrder;
+
     @ApiModelProperty(value = "客户投注")
     @TableField(exist = false)
     private TaCustomerBetting customerBetting;

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

@@ -0,0 +1,49 @@
+package com.yunzhi.niucai.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.time.LocalDateTime;
+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-10-19
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@ApiModel(value="TaShopAccount对象", description="店铺账户")
+public class TaShopAccount implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty(value = "账户ID")
+    @TableId(value = "account_id", type = IdType.AUTO)
+    private Integer accountId;
+
+    @ApiModelProperty(value = "店铺ID")
+    private Integer shopId;
+
+    @ApiModelProperty(value = "余额 单位分")
+    private Integer amount;
+
+    @ApiModelProperty(value = "充值 单位分")
+    private Integer cash;
+
+    @ApiModelProperty(value = "创建时间")
+    private LocalDateTime createDate;
+
+    @ApiModelProperty(value = "状态")
+    private Integer status;
+
+
+}

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

@@ -0,0 +1,61 @@
+package com.yunzhi.niucai.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.time.LocalDateTime;
+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-10-19
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@ApiModel(value="TaShopBill对象", description="店铺账户流水")
+public class TaShopBill implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty(value = "流水序号")
+    @TableId(value = "serial_no", type = IdType.AUTO)
+    private Integer serialNo;
+
+    @ApiModelProperty(value = "账户ID")
+    private Integer accountId;
+
+    @ApiModelProperty(value = "店铺ID")
+    private Integer shopId;
+
+    @ApiModelProperty(value = "费用类型")
+    private String feeType;
+
+    @ApiModelProperty(value = "费用简介")
+    private String summary;
+
+    @ApiModelProperty(value = "金额 单位分")
+    private Integer amount;
+
+    @ApiModelProperty(value = "收支类型 1收,-1支")
+    private Integer feeSign;
+
+    @ApiModelProperty(value = "订单号")
+    private String orderId;
+
+    @ApiModelProperty(value = "创建时间")
+    private LocalDateTime createDate;
+
+    @ApiModelProperty(value = "状态")
+    private Integer status;
+
+
+}

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

@@ -0,0 +1,18 @@
+package com.yunzhi.niucai.mapper;
+
+import com.yunzhi.niucai.entity.TaShopAccount;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * <p>
+ * 店铺账户 Mapper 接口
+ * </p>
+ *
+ * @author yansen
+ * @since 2020-10-19
+ */
+@Mapper
+public interface TaShopAccountMapper extends BaseMapper<TaShopAccount> {
+
+}

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

@@ -0,0 +1,18 @@
+package com.yunzhi.niucai.mapper;
+
+import com.yunzhi.niucai.entity.TaShopBill;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * <p>
+ * 店铺账户流水 Mapper 接口
+ * </p>
+ *
+ * @author yansen
+ * @since 2020-10-19
+ */
+@Mapper
+public interface TaShopBillMapper extends BaseMapper<TaShopBill> {
+
+}

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

@@ -4,6 +4,7 @@ import com.yunzhi.niucai.entity.TaCustomer;
 import com.yunzhi.niucai.entity.TaCustomerAccount;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.yunzhi.niucai.entity.TaOrder;
+import com.yunzhi.niucai.entity.TaOrderPay;
 
 /**
  * <p>
@@ -17,7 +18,7 @@ public interface ITaCustomerAccountService extends IService<TaCustomerAccount> {
 
     boolean newAccountBy(TaCustomer taCustomer) throws Exception;
 
-    void createBillBy(TaOrder taOrder, String feeType) throws Exception;
+    void createBillBy(TaOrder taOrder, TaOrderPay taOrderPay) throws Exception;
 
     TaCustomerAccount getByCustomer(Integer customerId) throws Exception;
 }

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

@@ -48,7 +48,7 @@ public interface ITaOrderService extends IService<TaOrder> {
      * @param isSuccess
      * @param payTime
      */
-    void payCallback(TaOrder taOrder, String outTradeNo, String payStatus, String failMessage, Boolean isSuccess, LocalDateTime payTime) throws Exception;
+    void payCallback(TaOrder taOrder, TaOrderPay taOrderPay, String payStatus, String failMessage, Boolean isSuccess, LocalDateTime payTime) throws Exception;
 
     /**
      * 转账提现订单

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

@@ -0,0 +1,20 @@
+package com.yunzhi.niucai.service;
+
+import com.yunzhi.niucai.entity.TaOrder;
+import com.yunzhi.niucai.entity.TaShopAccount;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ * 店铺账户 服务类
+ * </p>
+ *
+ * @author yansen
+ * @since 2020-10-19
+ */
+public interface ITaShopAccountService extends IService<TaShopAccount> {
+
+    void createBill(TaOrder taOrder, String feeType, Integer charge, int feeSign) throws Exception;
+
+    void createPlatBill(TaOrder taOrder, String feeType, Integer charge, int feeSign) throws Exception;
+}

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

@@ -1,5 +1,6 @@
 package com.yunzhi.niucai.service;
 
+import com.yunzhi.niucai.entity.TaOrder;
 import com.yunzhi.niucai.entity.TaShopApp;
 import com.baomidou.mybatisplus.extension.service.IService;
 

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

@@ -0,0 +1,16 @@
+package com.yunzhi.niucai.service;
+
+import com.yunzhi.niucai.entity.TaShopBill;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ * 店铺账户流水 服务类
+ * </p>
+ *
+ * @author yansen
+ * @since 2020-10-19
+ */
+public interface ITaShopBillService extends IService<TaShopBill> {
+
+}

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

@@ -4,12 +4,11 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.yunzhi.niucai.entity.*;
 import com.yunzhi.niucai.enums.AccFeeTypeEnum;
+import com.yunzhi.niucai.enums.OrderTypeEnum;
 import com.yunzhi.niucai.enums.StatusEnum;
 import com.yunzhi.niucai.mapper.TaCustomerAccountMapper;
-import com.yunzhi.niucai.service.ITaCustomerAccountService;
+import com.yunzhi.niucai.service.*;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.yunzhi.niucai.service.ITaCustomerBettingService;
-import com.yunzhi.niucai.service.ITaCustomerBillService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
@@ -30,6 +29,9 @@ public class TaCustomerAccountServiceImpl extends ServiceImpl<TaCustomerAccountM
     @Autowired
     ITaCustomerBettingService iTaCustomerBettingService;
 
+    @Autowired
+    ITaShopAccountService iTaShopAccountService;
+
     @Override
     public boolean newAccountBy(TaCustomer taCustomer) throws Exception {
         TaCustomerAccount account = new TaCustomerAccount();
@@ -40,7 +42,26 @@ public class TaCustomerAccountServiceImpl extends ServiceImpl<TaCustomerAccountM
     }
 
     @Override
-    public void createBillBy(TaOrder taOrder, String feeType) throws Exception {
+    public void createBillBy(TaOrder taOrder, TaOrderPay taOrderPay) throws Exception {
+        // 判断订单类型, 决定写哪个表
+        if (OrderTypeEnum.BETTING.getCode().equals(taOrder.getOrderType())) {
+            // 投注, 需要写客户的出记录，以及商户的入记录
+            createCustomerBill(taOrder, AccFeeTypeEnum.BETTING.getCode(), taOrder.getCharge(), -1);
+            iTaShopAccountService.createBill(taOrder, AccFeeTypeEnum.BETTING.getCode(), taOrder.getCharge(), 1);
+        } else if (OrderTypeEnum.CASH_OUT.getCode().equals(taOrder.getOrderType())) {
+            // 提现, 需要写客户的(彩金)出记录, 以及平台商户的出记录
+            createCustomerBill(taOrder, AccFeeTypeEnum.CASH_OUT.getCode(), taOrder.getCharge(), -1);
+            iTaShopAccountService.createPlatBill(taOrder, AccFeeTypeEnum.CASH_OUT.getCode(), taOrder.getCharge(), -1);
+        } else if (OrderTypeEnum.SENT_AWARD.getCode().equals(taOrder.getOrderType())) {
+            // 派奖, 需要写商户的出记录, 以及平台的入记录, 以及客户的入记录
+            TaCustomerBetting betting = iTaCustomerBettingService.getById(taOrder.getBettingId());
+            createCustomerBill(taOrder, AccFeeTypeEnum.DRAW_LOTTERY.getCode(), betting.getWinAmount(), 1);
+            iTaShopAccountService.createBill(taOrder, AccFeeTypeEnum.DRAW_LOTTERY.getCode(), betting.getWinAmount(), -1);
+            iTaShopAccountService.createPlatBill(taOrder, AccFeeTypeEnum.DRAW_LOTTERY.getCode(), betting.getWinAmount(), 1);
+        }
+    }
+
+    private void createCustomerBill(TaOrder taOrder, String feeType, Integer charge, Integer feeSign) throws Exception {
         TaCustomerAccount account = getByCustomer(taOrder.getCustomerId());
 
         TaCustomerBill taCustomerBill = new TaCustomerBill();
@@ -49,36 +70,30 @@ public class TaCustomerAccountServiceImpl extends ServiceImpl<TaCustomerAccountM
         taCustomerBill.setFeeType(feeType);
         taCustomerBill.setOrderId(taOrder.getOrderId());
         taCustomerBill.setAmount(taOrder.getCharge());
+        taCustomerBill.setFeeSign(feeSign);
 
         UpdateWrapper<TaCustomerAccount> updateWrapper = new UpdateWrapper<>();
-
         // 投注
         if (AccFeeTypeEnum.BETTING.getCode().equals(feeType)) {
-            updateWrapper.set("expense", account.getExpense() + taOrder.getCharge());
+            updateWrapper.set("expense", account.getExpense() + charge);
             updateWrapper.eq("account_id", account.getAccountId());
             updateWrapper.eq("expense", account.getExpense());
-            taCustomerBill.setFeeSign(-1);
         }
 
         // 提现
         if (AccFeeTypeEnum.CASH_OUT.getCode().equals(feeType)) {
-            updateWrapper.set("cash", account.getCash() - taOrder.getCharge());
+            updateWrapper.set("cash", account.getCash() - charge);
             updateWrapper.eq("account_id", account.getAccountId());
             updateWrapper.eq("cash", account.getCash());
-            taCustomerBill.setFeeSign(-1);
         }
 
         // 中奖
         if (AccFeeTypeEnum.DRAW_LOTTERY.getCode().equals(feeType)) {
-            TaCustomerBetting betting = iTaCustomerBettingService.getById(taOrder.getBettingId());
-
-            updateWrapper.set("cash", account.getCash() + betting.getWinAmount());
+            updateWrapper.set("cash", account.getCash() + charge);
             updateWrapper.eq("account_id", account.getAccountId());
             updateWrapper.eq("cash", account.getCash());
-            taCustomerBill.setFeeSign(1);
         }
 
-        // 更新
         update(updateWrapper);
         iTaCustomerBillService.save(taCustomerBill);
     }

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

@@ -67,7 +67,8 @@ public class TaOrderPayServiceImpl extends ServiceImpl<TaOrderPayMapper, TaOrder
         } else if (OrderTypeEnum.CASH_OUT.getCode().equals(taOrder.getOrderType())) {
             // 提现
             taOrderPay.setTradeType("b2c");
-            Map<String, String> payProfile = getPayTermProfile("b", taOrder.getShopId());
+            // 提现的付款放为平台
+            Map<String, String> payProfile = getPayTermProfile("b", 0);
             if (null != payProfile) {
                 taOrderPay.setPayee(payProfile.get("id"));
                 taOrderPay.setPayeeName(payProfile.get("name"));
@@ -85,7 +86,9 @@ public class TaOrderPayServiceImpl extends ServiceImpl<TaOrderPayMapper, TaOrder
                 taOrderPay.setPayee(payProfile.get("id"));
                 taOrderPay.setPayeeName(payProfile.get("name"));
             }
-            Map<String, String> remitterProfile = getPayTermProfile("b", taOrder.getCustomerId());
+
+            // 派奖的接受方位平台
+            Map<String, String> remitterProfile = getPayTermProfile("b", 0);
             if (null != payProfile) {
                 taOrderPay.setPayee(remitterProfile.get("id"));
                 taOrderPay.setPayeeName(remitterProfile.get("name"));

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

@@ -160,14 +160,17 @@ public class TaOrderServiceImpl extends ServiceImpl<TaOrderMapper, TaOrder> impl
 
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void payCallback(TaOrder taOrder, String outTradeNo, String payStatus, String failMessage, Boolean isSuccess, LocalDateTime payTime) throws Exception {
+    public void payCallback(TaOrder taOrder, TaOrderPay taOrderPay, String payStatus, String failMessage, Boolean isSuccess, LocalDateTime payTime) throws Exception {
+        if (null == taOrderPay) {
+            throw new Exception("支付详情记录未找到");
+        }
+
         if (null != isSuccess && isSuccess) {
             taOrder.setPayStatus(CommConstants.SRTATUS_EFFECTIVE);
         } else {
             taOrder.setPayStatus(CommConstants.SRTATUS_UNPAYED);
         }
 
-        TaOrderPay taOrderPay = iTaOrderPayService.getByTradeNo(outTradeNo);
         taOrderPay.setPayResult(payStatus);
         taOrderPay.setPayTime(payTime);
         taOrderPay.setFailReason(failMessage);
@@ -176,15 +179,7 @@ public class TaOrderServiceImpl extends ServiceImpl<TaOrderMapper, TaOrder> impl
         iTaOrderPayService.updateById(taOrderPay);
 
         if (null != isSuccess && isSuccess) {
-            String feeType = null;
-            String orderType = taOrder.getOrderType();
-            if (OrderTypeEnum.BETTING.getCode().equals(orderType)) {
-                feeType = AccFeeTypeEnum.BETTING.getCode();
-            } else if (OrderTypeEnum.CASH_OUT.getCode().equals(orderType)) {
-                feeType = AccFeeTypeEnum.CASH_OUT.getCode();
-            }
-
-            iTaCustomerAccountService.createBillBy(taOrder, feeType);
+            iTaCustomerAccountService.createBillBy(taOrder, taOrderPay);
         }
     }
 
@@ -208,13 +203,17 @@ public class TaOrderServiceImpl extends ServiceImpl<TaOrderMapper, TaOrder> impl
     public TaOrder createBy(TaOrder TaOrder, TaShop taShop, TaCustomerBetting customerBetting) throws Exception {
         TaOrder taOrder = new TaOrder();
         taOrder.setOrderId(nextOrderNo("SW", 16, true));
-        taOrder.setOrderType(OrderTypeEnum.CASH_OUT.getCode());
+        taOrder.setOrderType(OrderTypeEnum.SENT_AWARD.getCode());
         taOrder.setAmount(1);
         taOrder.setCharge(customerBetting.getWinAmount());
         taOrder.setShopId(taOrder.getShopId());
-        taOrder.setCustomerId(taShop.getShopId());
+
+        // 派奖的流程是 商户转账到平台
+        // 但是此处仍然写 商户 跟 客户的关系, 平台商户固定为 0
+        taOrder.setCustomerId(taOrder.getCustomerId());
         taOrder.setStatus(StatusEnum.NORMAL.getCode());
         taOrder.setPayStatus(CommConstants.SRTATUS_UNPAYED);
+        taOrder.setSrcOrder(taOrder.getOrderId());
 
         save(taOrder);
         return taOrder;

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

@@ -0,0 +1,66 @@
+package com.yunzhi.niucai.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.yunzhi.niucai.entity.TaOrder;
+import com.yunzhi.niucai.entity.TaShopAccount;
+import com.yunzhi.niucai.entity.TaShopBill;
+import com.yunzhi.niucai.mapper.TaShopAccountMapper;
+import com.yunzhi.niucai.service.ITaShopAccountService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.yunzhi.niucai.service.ITaShopBillService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * 店铺账户 服务实现类
+ * </p>
+ *
+ * @author yansen
+ * @since 2020-10-19
+ */
+@Service
+public class TaShopAccountServiceImpl extends ServiceImpl<TaShopAccountMapper, TaShopAccount> implements ITaShopAccountService {
+
+    @Autowired
+    ITaShopBillService iTaShopBillService;
+
+    @Override
+    public void createBill(TaOrder taOrder, String feeType, Integer charge, int feeSign) throws Exception {
+        TaShopAccount account = getByShop(taOrder.getShopId());
+
+        TaShopBill taShopBill = new TaShopBill();
+        taShopBill.setAccountId(account.getAccountId());
+        taShopBill.setShopId(account.getShopId());
+        taShopBill.setFeeType(feeType);
+        taShopBill.setAmount(charge);
+        taShopBill.setFeeSign(feeSign);
+        taShopBill.setOrderId(taOrder.getOrderId());
+
+        iTaShopBillService.save(taShopBill);
+    }
+
+    @Override
+    public void createPlatBill(TaOrder taOrder, String feeType, Integer charge, int feeSign) throws Exception {
+        // 平台商户 ID 为 0
+        TaShopAccount account = getByShop(0);
+
+        TaShopBill taShopBill = new TaShopBill();
+        taShopBill.setAccountId(account.getAccountId());
+        taShopBill.setShopId(account.getShopId());
+        taShopBill.setFeeType(feeType);
+        taShopBill.setAmount(charge);
+        taShopBill.setFeeSign(feeSign);
+        taShopBill.setOrderId(taOrder.getOrderId());
+
+        iTaShopBillService.save(taShopBill);
+    }
+
+    private TaShopAccount getByShop(Integer shopId) {
+        QueryWrapper<TaShopAccount> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("shop_id", shopId);
+        return getOne(queryWrapper);
+    }
+
+
+}

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

@@ -0,0 +1,20 @@
+package com.yunzhi.niucai.service.impl;
+
+import com.yunzhi.niucai.entity.TaShopBill;
+import com.yunzhi.niucai.mapper.TaShopBillMapper;
+import com.yunzhi.niucai.service.ITaShopBillService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * 店铺账户流水 服务实现类
+ * </p>
+ *
+ * @author yansen
+ * @since 2020-10-19
+ */
+@Service
+public class TaShopBillServiceImpl extends ServiceImpl<TaShopBillMapper, TaShopBill> implements ITaShopBillService {
+
+}

src/main/resources/mapper/TaShopAccountMapper.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.TaShopAccountMapper">
+
+</mapper>

src/main/resources/mapper/TaShopBillMapper.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.TaShopBillMapper">
+
+</mapper>