直播间代码 添加回调

fs-live-app/src/main/java/com/fs/app/controller/HuifuPayController.java

@@ -0,0 +1,59 @@
+package com.fs.app.controller;
+
+import com.alibaba.fastjson.JSON;
+import com.fs.course.service.IFsUserCourseOrderService;
+import com.fs.course.service.IFsUserVipOrderService;
+import com.fs.his.service.IFsInquiryOrderService;
+import com.fs.his.service.IFsPackageOrderService;
+import com.fs.his.service.IFsStoreOrderService;
+import com.fs.huifuPay.domain.HuiFuOnlinePay;
+import com.fs.huifuPay.domain.HuiFuOnlineRefund;
+import com.fs.huifuPay.domain.HuiFuResult;
+import com.fs.live.service.ILiveOrderService;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping(value="/app/hfPay")
+public class HuifuPayController {
+    @Autowired
+    private ILiveOrderService liveOrderService;
+
+    org.slf4j.Logger logger= LoggerFactory.getLogger(getClass());
+    @RequestMapping("/payNotifyUrl")
+    public String asyncMessage(@RequestParam String resp_desc,@RequestParam String resp_code,@RequestParam String sign,@RequestParam String resp_data) {
+        HuiFuResult huiFuResult = JSON.parseObject(resp_data, HuiFuResult.class);
+        logger.info("汇付支付回调:"+huiFuResult);
+        if(huiFuResult.getResp_code().equals("00000000") && huiFuResult.getNotify_type().equals("1")){
+            String[] orderId=huiFuResult.getReq_seq_id().split("-");
+            switch (orderId[0]){
+                case "appLive":
+                    liveOrderService.payConfirm("",orderId[1],huiFuResult.getHf_seq_id(),"",1);
+                    break;
+            }
+        }
+
+        return "ok";
+    }
+
+
+    @RequestMapping("/payOnlineNotifyUrl")
+    public String asyncHuFuOnlinePay(@RequestParam String resp_desc,@RequestParam String resp_code,@RequestParam String sign,@RequestParam String resp_data) {
+        HuiFuOnlinePay huFuResult = JSON.parseObject(resp_data, HuiFuOnlinePay.class);
+        return "ok";
+    }
+    @RequestMapping("/onlineRefund")
+    public String onlineRefund(@RequestParam String resp_desc,@RequestParam String resp_code,@RequestParam String sign,@RequestParam String resp_data) {
+        HuiFuOnlineRefund huFuResult = JSON.parseObject(resp_data, HuiFuOnlineRefund.class);
+        return "ok";
+    }
+
+    @RequestMapping("/refundNotifyUrl")
+    public String refundMessage(@RequestParam String resp_desc,@RequestParam String resp_code,@RequestParam String sign,@RequestParam String resp_data) {
+        System.out.println(resp_data);
+        return "ok";
+    }
+}

fs-live-app/src/main/java/com/fs/app/controller/TzPayController.java

@@ -0,0 +1,61 @@
+package com.fs.app.controller;
+
+import com.fs.common.core.controller.BaseController;
+import com.fs.common.utils.spring.SpringUtils;
+import com.fs.course.service.IFsUserCourseOrderService;
+import com.fs.course.service.IFsUserVipOrderService;
+import com.fs.his.domain.FsPayConfig;
+import com.fs.his.service.IFsInquiryOrderService;
+import com.fs.his.service.IFsPackageOrderService;
+import com.fs.his.service.IFsStoreOrderService;
+import com.fs.live.service.ILiveOrderService;
+import com.fs.system.domain.SysConfig;
+import com.fs.system.mapper.SysConfigMapper;
+import com.fs.tzBankPay.doman.TzBankOrderDecrypt;
+import com.fs.tzBankPay.doman.TzBankRefundOrderDecrypt;
+import com.google.gson.Gson;
+import com.tzbank.util.CallBackUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+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.RestController;
+
+
+@RestController
+@RequestMapping("/app/tzPay")
+public class TzPayController extends BaseController
+{
+    @Autowired
+    private ILiveOrderService liveOrderService;
+    @RequestMapping(value = "/payNotify",method = RequestMethod.POST)
+    public String payNotify(@RequestBody String  decryptForm) throws Exception {
+        SysConfigMapper sysConfigMapper= SpringUtils.getBean(SysConfigMapper.class);
+        SysConfig sysConfig = sysConfigMapper.selectConfigByConfigKey("his.pay");
+        FsPayConfig fsPayConfig = new Gson().fromJson(sysConfig.getConfigValue(), FsPayConfig.class);
+        String decrypt = CallBackUtil.decrypt( fsPayConfig.getTzAppSecret(),decryptForm);
+        String filteredString = decrypt.replaceAll("[^\\x20-\\x7E]", "");
+        Gson gson = new Gson();
+        TzBankOrderDecrypt tzBankOrderDecrypt = gson.fromJson(filteredString, TzBankOrderDecrypt.class);
+        logger.info("台州银行支付回调:"+tzBankOrderDecrypt.getOrderFlowNo()+":"+tzBankOrderDecrypt);
+        if(tzBankOrderDecrypt.getStatus().equals("90")){
+            if(tzBankOrderDecrypt.getOrderNo().indexOf("appLive")>-1){
+                liveOrderService.payConfirm("",tzBankOrderDecrypt.getOrderNo().substring(6),tzBankOrderDecrypt.getOrderFlowNo(),tzBankOrderDecrypt.getPayType(),1);
+            }
+        }
+        return decrypt;
+    }
+
+
+    @RequestMapping(value = "/refundNotify",method = RequestMethod.POST)
+    public String refundNotify(@RequestBody String  decryptForm) throws Exception {
+        SysConfigMapper sysConfigMapper= SpringUtils.getBean(SysConfigMapper.class);
+        SysConfig sysConfig = sysConfigMapper.selectConfigByConfigKey("his.pay");
+        FsPayConfig fsPayConfig = new Gson().fromJson(sysConfig.getConfigValue(), FsPayConfig.class);
+        String decrypt = CallBackUtil.decrypt(fsPayConfig.getTzAppSecret(),decryptForm);
+        String filteredString = decrypt.replaceAll("[^\\x20-\\x7E]", "");
+        logger.info("台州银行退款回调:"+filteredString);
+        TzBankRefundOrderDecrypt o = new Gson().fromJson(filteredString, TzBankRefundOrderDecrypt.class);
+        return filteredString;
+    }
+}

fs-live-app/src/main/java/com/fs/app/controller/WxPayController.java

@@ -0,0 +1,110 @@
+package com.fs.app.controller;
+
+
+import com.fs.common.core.controller.BaseController;
+import com.fs.common.core.domain.R;
+import com.fs.course.service.IFsCourseRedPacketLogService;
+import com.fs.course.service.IFsUserCourseOrderService;
+import com.fs.course.service.IFsUserVipOrderService;
+import com.fs.his.param.WxSendRedPacketParam;
+import com.fs.his.service.IFsInquiryOrderService;
+import com.fs.his.service.IFsPackageOrderService;
+import com.fs.his.service.IFsStoreOrderService;
+import com.fs.his.service.IFsStorePaymentService;
+import com.fs.live.service.ILiveOrderService;
+import com.fs.sop.service.ISopUserLogsInfoService;
+import com.fs.system.service.ISysConfigService;
+import com.github.binarywang.wxpay.bean.notify.WxPayNotifyResponse;
+import com.github.binarywang.wxpay.bean.notify.WxPayOrderNotifyResult;
+import com.github.binarywang.wxpay.service.WxPayService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.apache.commons.io.IOUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+@Api("微信支付接口")
+@RestController
+@RequestMapping("/app/wxpay")
+public class WxPayController {
+    protected final Logger logger = LoggerFactory.getLogger(BaseController.class);
+    @Autowired
+    private WxPayService wxPayService;
+    @Autowired
+    private IFsStorePaymentService  paymentService;
+
+    @Autowired
+    private ISopUserLogsInfoService iSopUserLogsInfoService;
+
+    @Autowired
+    private ILiveOrderService liveOrderService;
+
+
+    /**
+     * 微信回调
+     * 回调接口代码内部自动校验结果签名和业务代码
+     * @param request
+     * @return
+     * @throws Exception
+     */
+    @ApiOperation("微信回调")
+    @PostMapping("/wxPayNotify")
+    public String wxPayNotify(HttpServletRequest request) throws Exception {
+
+        try {
+            String xmlResult = IOUtils.toString(request.getInputStream(), request.getCharacterEncoding());
+            WxPayOrderNotifyResult result = wxPayService.parseOrderNotifyResult(xmlResult);
+            System.out.println(result.getReturnCode());
+            if("SUCCESS".equals(result.getReturnCode())){
+                //订单号
+                String outtradeno = result.getOutTradeNo();
+                String tradeNo = result.getTransactionId();
+                System.out.println(outtradeno);
+                System.out.println(tradeNo);
+                String[] orderId=outtradeno.split("-");
+                switch (orderId[0]){
+                    case "appLive":
+                        liveOrderService.payConfirm("",orderId[1],tradeNo,"",1);
+                }
+                return WxPayNotifyResponse.success("处理成功!");
+            }else{
+                return WxPayNotifyResponse.fail("");
+            }
+
+        } catch (Exception e) {
+            logger.error("微信回调结果异常,异常原因{}", e.getMessage());
+            return WxPayNotifyResponse.fail(e.getMessage());
+        }
+    }
+
+    @PostMapping("/sendRedPacket")
+    public R sendRedPacket(@RequestBody WxSendRedPacketParam param){
+       return paymentService.sendRedPacketTest(param);
+    }
+
+    @PostMapping( "/TransferNotify")
+    public String TransferNotify(@RequestBody String notifyData,HttpServletRequest request, HttpServletResponse response) throws Exception {
+        return paymentService.transferNotify(notifyData,request);
+    }
+
+
+    @PostMapping( "/v3TransferNotify")
+    public String v3TransferNotify(@RequestBody String notifyData,HttpServletRequest request, HttpServletResponse response) throws Exception {
+        return paymentService.v3TransferNotify(notifyData,request);
+    }
+
+
+
+    @GetMapping("/test")
+    public void test(){
+        iSopUserLogsInfoService.updateSopUserInfoByExternalId(1L,123456L);
+    }
+
+
+
+}

fs-live-app/src/main/java/com/fs/app/controller/YbPayController.java

@@ -0,0 +1,63 @@
+package com.fs.app.controller;
+
+import com.fs.common.core.controller.BaseController;
+import com.fs.common.exception.CustomException;
+import com.fs.common.utils.spring.SpringUtils;
+import com.fs.course.service.IFsUserCourseOrderService;
+import com.fs.course.service.IFsUserVipOrderService;
+import com.fs.his.domain.FsPayConfig;
+import com.fs.his.service.IFsInquiryOrderService;
+import com.fs.his.service.IFsPackageOrderService;
+import com.fs.his.service.IFsStoreOrderService;
+import com.fs.live.service.ILiveOrderService;
+import com.fs.system.domain.SysConfig;
+import com.fs.system.mapper.SysConfigMapper;
+import com.fs.ybPay.domain.OrderCallback;
+import com.fs.ybPay.util.PayUtil;
+import com.google.gson.Gson;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.Map;
+
+/**
+ *
+ *
+ * @author fs
+ * @date 2023-07-12
+ */
+@RestController
+@RequestMapping("/app/pay")
+public class YbPayController extends BaseController
+{
+    @Autowired
+    private ILiveOrderService liveOrderService;
+    @PostMapping("/payNotify")
+    public String payNotify(@RequestBody Map<String, String> params, @RequestBody OrderCallback o) {
+        System.out.println("支付回调");
+        //验证
+        SysConfigMapper sysConfigMapper= SpringUtils.getBean(SysConfigMapper.class);
+        SysConfig sysConfig = sysConfigMapper.selectConfigByConfigKey("his.pay");
+        FsPayConfig fsPayConfig = new Gson().fromJson(sysConfig.getConfigValue(), FsPayConfig.class);
+        String sign = PayUtil.sign(params,fsPayConfig.getYbKey());
+        String sg = params.get("sign");
+        if (!sg.equals(sign)){
+            throw new CustomException("验签错误");
+        }
+        String[] orderId=o.getLowOrderId().split("-");
+        switch (orderId[0]){
+            case "appLive":
+                liveOrderService.payConfirm("",orderId[1],o.getUpOrderId(),"",1);
+                break;
+        }
+        System.out.println(o);
+        return "SUCCESS";
+    }
+
+
+
+
+}

fs-user-app/src/main/java/com/fs/app/controller/HuifuPayController.java

@@ -29,8 +29,6 @@ public class HuifuPayController {
     private IFsUserCourseOrderService courseOrderService;
     @Autowired
     private IFsUserVipOrderService vipOrderService;
-    @Autowired
-    private ILiveOrderService liveOrderService;
 
     org.slf4j.Logger logger= LoggerFactory.getLogger(getClass());
     @RequestMapping("/payNotifyUrl")
@@ -55,9 +53,6 @@ public class HuifuPayController {
                 case "appvip":
                     vipOrderService.payConfirm("",orderId[1],huiFuResult.getHf_seq_id(),"",1);
                     break;
-                case "appLive":
-                    liveOrderService.payConfirm("",orderId[1],huiFuResult.getHf_seq_id(),"",1);
-                    break;
             }
         }
 

fs-user-app/src/main/java/com/fs/app/controller/TzPayController.java

@@ -42,8 +42,6 @@ public class TzPayController extends BaseController
 
     @Autowired
     private IFsUserVipOrderService userVipOrderService;
-    @Autowired
-    private ILiveOrderService liveOrderService;
     @RequestMapping(value = "/payNotify",method = RequestMethod.POST)
     public String payNotify(@RequestBody String  decryptForm) throws Exception {
         SysConfigMapper sysConfigMapper= SpringUtils.getBean(SysConfigMapper.class);
@@ -70,9 +68,6 @@ public class TzPayController extends BaseController
             else if(tzBankOrderDecrypt.getOrderNo().indexOf("appvip")>-1){
                 userVipOrderService.payConfirm("",tzBankOrderDecrypt.getOrderNo().substring(6),tzBankOrderDecrypt.getOrderFlowNo(),tzBankOrderDecrypt.getPayType(),1);
             }
-            else if(tzBankOrderDecrypt.getOrderNo().indexOf("appLive")>-1){
-                liveOrderService.payConfirm("",tzBankOrderDecrypt.getOrderNo().substring(6),tzBankOrderDecrypt.getOrderFlowNo(),tzBankOrderDecrypt.getPayType(),1);
-            }
         }
         return decrypt;
     }

fs-user-app/src/main/java/com/fs/app/controller/WxPayController.java

@@ -74,8 +74,6 @@ public class WxPayController {
     @Autowired
     private ISopUserLogsInfoService iSopUserLogsInfoService;
 
-    @Autowired
-    private ILiveOrderService liveOrderService;
 
 
     /**
@@ -111,8 +109,6 @@ public class WxPayController {
                         courseOrderService.payConfirm("",orderId[1],tradeNo,"",1);
                     case "appvip":
                         userVipOrderService.payConfirm("",orderId[1],tradeNo,"",1);
-                    case "appLive":
-                        liveOrderService.payConfirm("",orderId[1],tradeNo,"",1);
                 }
                 return WxPayNotifyResponse.success("处理成功!");
             }else{

fs-user-app/src/main/java/com/fs/app/controller/YbPayController.java

@@ -44,8 +44,6 @@ public class YbPayController extends BaseController
     private IFsUserCourseOrderService courseOrderService;
     @Autowired
     private IFsUserVipOrderService userVipOrderService;
-    @Autowired
-    private ILiveOrderService liveOrderService;
     @PostMapping("/payNotify")
     public String payNotify(@RequestBody Map<String, String> params, @RequestBody OrderCallback o) {
         System.out.println("支付回调");
@@ -75,9 +73,6 @@ public class YbPayController extends BaseController
             case "appvip":
                 userVipOrderService.payConfirm("",orderId[1],o.getUpOrderId(),"",1);
                 break;
-            case "appLive":
-                liveOrderService.payConfirm("",orderId[1],o.getUpOrderId(),"",1);
-                break;
         }
         System.out.println(o);
         return "SUCCESS";