feats

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

@@ -10,6 +10,7 @@ import com.yunzhi.niucai.common.StringUtils;
 import com.yunzhi.niucai.entity.TaShop;
 import com.yunzhi.niucai.entity.TaShopkeeper;
 import com.yunzhi.niucai.enums.StatusEnum;
+import com.yunzhi.niucai.service.ITaOrderService;
 import com.yunzhi.niucai.service.ITaShopService;
 import com.yunzhi.niucai.service.ITaShopkeeperService;
 import com.yunzhi.niucai.vo.AlipayAuthUser;
@@ -48,6 +49,9 @@ public class TaAlipayController extends BaseController {
     @Autowired
     private ITaShopkeeperService iTaShopkeeperService;
 
+    @Autowired
+    private ITaOrderService iTaOrderService;
+
     @GetMapping("/shop/alipay/appid")
     @ApiOperation(value="获取平台支付宝应用AppID", notes = "获取平台支付宝应用AppID", httpMethod = "GET", response = SportDicts.class)
     public ResponseBean getPlatAppID() {
@@ -112,10 +116,7 @@ public class TaAlipayController extends BaseController {
                 // 支付宝有 CREATE-创建, FINISH- 订单处理已完结, CLOSE-超时关闭
                 // 三种提醒
                 if (!"CREATE".equals(actionType)) {
-                    String outBizNO = transRes.getString("out_biz_no");
-                    String status = transRes.getString("status");
-                    String payDate = transRes.getString("pay_date");
-
+                    iTaOrderService.fundTransNotify(transRes);
                 }
 
             } catch (Exception e) {

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

@@ -1,5 +1,6 @@
 package com.yunzhi.niucai.service;
 
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.yunzhi.niucai.entity.TaBettingPlan;
 import com.yunzhi.niucai.entity.TaCustomerBetting;
@@ -29,4 +30,12 @@ public interface ITaOrderService extends IService<TaOrder> {
     TaOrder getByOutTradeNo(String outTradeNo);
 
     TaOrder getByBetting(TaCustomerBetting betting) throws Exception;
+
+    /**
+     * 转账结果提醒
+     * https://opendocs.alipay.com/apis/msgapi_60/alipay.fund.trans.order.changed
+     * @param transRes
+     * @throws Exception
+     */
+    void fundTransNotify(JSONObject transRes) throws Exception;
 }

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

@@ -1,5 +1,6 @@
 package com.yunzhi.niucai.service.impl;
 
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.yunzhi.niucai.common.CommConstants;
@@ -14,6 +15,7 @@ import com.yunzhi.niucai.enums.StatusEnum;
 import com.yunzhi.niucai.mapper.TaOrderMapper;
 import com.yunzhi.niucai.service.ITaBettingPlanService;
 import com.yunzhi.niucai.service.ITaCustomerBettingService;
+import com.yunzhi.niucai.service.ITaOrderPayService;
 import com.yunzhi.niucai.service.ITaOrderService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.yunzhi.niucai.vo.DrawOrderParam;
@@ -21,6 +23,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
@@ -42,6 +45,9 @@ public class TaOrderServiceImpl extends ServiceImpl<TaOrderMapper, TaOrder> impl
     @Autowired
     ITaBettingPlanService iTaBettingPlanService;
 
+    @Autowired
+    ITaOrderPayService iTaOrderPayService;
+
     @Autowired
     TaOrderMapper taOrderMapper;
 
@@ -141,6 +147,18 @@ public class TaOrderServiceImpl extends ServiceImpl<TaOrderMapper, TaOrder> impl
         return taOrder;
     }
 
+    @Override
+    public void fundTransNotify(JSONObject transRes) throws Exception {
+        // transRes 结构
+        // https://opendocs.alipay.com/apis/msgapi_60/alipay.fund.trans.order.changed#%E6%B6%88%E6%81%AF%E5%B1%9E%E6%80%A7
+        // 依据文档, 转账只有成功一种结果
+        String tradeNO = transRes.getString("out_biz_no");
+        String payDate = transRes.getString("pay_date");
+        LocalDateTime payTime = DateUtils.
+
+        iTaOrderPayService.updatePayResult(tradeNO, payDate, true, null);
+    }
+
     private String nextOrderNo(String prefix, int length, boolean padDate) throws Exception {
         List<String> parts = new ArrayList<>();
         parts.add(prefix);