随行付支付接口

YijiaRestful/src/main/java/com/platform/yijia/controller/PayController.java

@@ -0,0 +1,313 @@
+package com.platform.yijia.controller;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.alibaba.fastjson.parser.Feature;
+import com.google.gson.Gson;
+import com.platform.yijia.param.request.*;
+import com.platform.yijia.pojo.AppUserInfo;
+import com.platform.yijia.pojo.PayOrder;
+import com.platform.yijia.service.AppUserInfoService;
+import com.platform.yijia.service.PayOrderService;
+import com.platform.yijia.utils.*;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.*;
+
+import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.util.*;
+
+@Controller
+@RequestMapping("/api")
+public class PayController {
+    //private static Logger logger =(Logger) LoggerFactory.getLogger(PayController.class);
+    @Resource
+    private PayOrderService payOrderService;
+    @Resource
+    private AppUserInfoService appUserInfoService;
+    /**
+     * 支付接口，前台上传支付信息，支付数据落地生产订单，调用随行付支付接口
+     * @param
+     * @return
+     */
+    @RequestMapping(value = "/getJhPayInfo", consumes = "application/json", method = RequestMethod.POST)
+    @ResponseBody
+    public String getJhPayInfo(@RequestBody PayInfoRequest payInfoRequest){
+        Gson gson =new Gson();
+        ResultData resultData =null;
+        String token=payInfoRequest.getToken();//token
+        String userType=payInfoRequest.getUserType();//用户登录类型 1 公众号。2 小程序
+        String ordNo=payInfoRequest.getOrdNo();//订单号
+        //根据token 和登录类型 身份验证
+        AppUserInfo appUserInfo =new AppUserInfo();
+        //订单类型 是小程序还是公众号
+        appUserInfo.setUserType(userType);
+        if(userType.equals("1")){
+            //1 是公众号
+            appUserInfo.setBlogOpenid(token);
+        }else if(userType.equals("2")){
+            //2是小程序
+            appUserInfo.setMinaToken(token);
+        }
+        List<AppUserInfo> appUserInfoList =appUserInfoService.Authentication(appUserInfo);
+
+        if(appUserInfoList!=null&&appUserInfoList.size()>0){
+            //调用聚合支付
+            try{
+                //将业务参数存放在 JSON 对象中
+                JSONObject reqData = new JSONObject();
+                reqData.put("ordNo", ordNo); //商户订单号
+                reqData.put("mno", "399200427027644"); //商户编号
+                //reqData.put("subMechId", ""); //子商户号
+                reqData.put("amt", "0.01"); //订单总金额
+                //reqData.put("discountAmt", ""); //参与优惠金额
+                //reqData.put("unDiscountAmt", ""); //不参与优惠金额
+                reqData.put("payType", "WECHAT"); //支付渠道
+                reqData.put("payWay", "02"); //支付方式  02 公众号/服 务窗/js支付 03 小程序
+                //reqData.put("timeExpire", "10"); //订单失效时间, 以分钟为单位
+                //reqData.put("limitPay", "00"); //限制卡类型: 00-全部 01-限定不能使 用信用卡支付 默认值 00
+                reqData.put("subject", "聚合支付测试"); //订单标题
+                //reqData.put("hbFqNum", "6"); //花呗分期数,仅可上送 6 或 12
+                reqData.put("tradeSource", "01"); //交易来源 01服务商，02收银台，03硬件
+                reqData.put("trmIp", "172.16.2.1");//商家ip地址
+                // reqData.put("customerIp", ""); //持卡人ip地址，银联js支付时必传
+                reqData.put("userId", "2088101117955611"); //用户号 微信：openid； 支付宝：userid；银联：userid；微信&支付宝必传，银联js为非必传
+                //reqData.put("subAppid", "wx24210004370ec43b"); //微信子公众号
+                //reqData.put("outFrontUrl", ""); //js 支付，前台 成功通知地址
+                //reqData.put("outFrontFailUrl", ""); //js 支付，前台 事变通知地址
+                //reqData.put("notifyUrl", ""); //回调地址
+                //reqData.put("needReceipt", "00"); //电子发票功能 微信开具电子 发票使用
+                //reqData.put("ledgerAccountFlag", "00"); //是否做分账 分账交易使 用；00：做； 01：不做；不传默认为不做分账
+                //reqData.put("ledgerAccountEffectTime", "00"); //分账有效时间 单位为天；是 否做分账选择 00 时该字段必传
+                // reqData.put("ruleId", "00"); //同 步 分 账 规 则 id
+                // reqData.put("fusruleId", "00"); //同步分账规则
+                //reqData.put("ylTrmNo", ""); //银联终端号
+                //reqData.put("terminalId", ""); //TQ机具编号
+                reqData.put("deviceNo ", "1111"); //设备号
+                reqData.put("identityFlag", ""); //是否是实名支付
+//                reqData.put("buyerIdType", "IDCARD"); //证件类型
+//                reqData.put("buyerIdNo", "410523198701054018"); //证件号
+//                reqData.put("buyerName", "张三"); //买家姓名
+//                reqData.put("mobileNum", ""); //手机号
+                reqData.put("extend", ""); //备用
+                String req= SXFPaySign.getSXFPay(reqData);
+                // logger.debug("参数信息："+req);
+                System.out.println("req:" + req);
+                //此处不要改变reqData里面值的顺序用LinkedHashMap
+                HashMap reqMap = JSON.parseObject(req, LinkedHashMap.class, Feature.OrderedField);
+                //组装加密串
+                String signContent = RSASignature.getOrderContent(reqMap);
+                System.out.println("拼接后的参数：" + signContent);
+                //   logger.debug("拼接后的参数："+signContent);
+                //sign
+                String sign = RSASignature.encryptBASE64(RSASignature.sign(signContent, SXFPaySign.privateKey));
+                System.out.println("============签名:" + sign);
+                reqMap.put("sign", sign);
+                String reqStr = JSON.toJSONString(reqMap);
+                System.out.println("请求参数:" + reqMap);
+                System.out.println("请求参数:" + reqStr);
+                //调用第三方接口地址
+                String url = "https://openapi-test.tianquetech.com/order/jsapiScan";//测试地址
+                // String url = "https://openapi.suixingpay.com/order/jsapiScan";//生产地址
+                String resultJson = HttpUtils.connectPostUrl(url, reqStr);
+                System.out.println("返回信息：" + resultJson);
+                //   logger.debug("返回信息："+resultJson);
+                //不要对reqData排序 所以用LinkedHashMap
+                HashMap<String, Object> result = JSON.parseObject(resultJson, LinkedHashMap.class, Feature.OrderedField);
+                if ("0000".equals(result.get("code"))) {
+                    //验签
+                    String signResult = result.get("sign").toString();
+                    result.remove("sign");
+                    String resultStr = RSASignature.getOrderContent(result);
+                    System.out.println(resultStr);
+                    //sign
+                    String resultSign = RSASignature.encryptBASE64(RSASignature.sign(signContent, SXFPaySign.privateKey));
+                    System.out.println("resultSign:" + resultSign);
+                    //组装加密串
+                    if (RSASignature.doCheck(resultStr, signResult, SXFPaySign.sxfPublic)) {
+                        System.out.println("===================验签成功==============");
+                    }
+                }
+                resultData=ResultData.success(result);
+            }catch (Exception e){
+                resultData=ResultData.error(CodeMsg.YEWU_FAIL,"订单支付失败");
+                e.printStackTrace();
+            }
+        }else{
+            //返回失败支付失败信息
+            resultData=ResultData.error(CodeMsg.USER_NOT_EXSIST);
+        }
+        return gson.toJson(resultData);
+    }
+
+    /**
+     * 关单接口
+     */
+    @RequestMapping(value = "/getPayOrderClose", consumes = "application/json", method = RequestMethod.POST)
+    @ResponseBody
+    public String getPayOrderClose(@RequestBody PayCloseRequestParamter payCloseRequestParamter) {
+        String results="";
+        Gson gson =new Gson();
+        try {
+            JSONObject reqData = new JSONObject();
+            reqData.put("mno", payCloseRequestParamter.getMno()); //商户编号
+            reqData.put("origOrderNo", payCloseRequestParamter.getOrigOrderNo());
+            reqData.put("origUuid", payCloseRequestParamter.getOrigUuid());
+            String req= SXFPaySign.getSXFPay(reqData);
+            //此处不要改变reqData里面值的顺序用LinkedHashMap
+            HashMap reqMap = JSON.parseObject(req, LinkedHashMap.class, Feature.OrderedField);
+            //组装加密串
+            String signContent = RSASignature.getOrderContent(reqMap);
+            System.out.println("拼接后的参数：" + signContent);
+            //sign
+            String sign = RSASignature.encryptBASE64(RSASignature.sign(signContent, SXFPaySign.privateKey));
+            System.out.println("============签名:" + sign);
+            reqMap.put("sign", sign);
+            String reqStr = JSON.toJSONString(reqMap);
+            System.out.println("请求参数:" + reqMap);
+            System.out.println("请求参数:" + reqStr);
+            //调用第三方接口地址
+            String url = "https://openapi-test.tianquetech.com/query/close";//测试地址
+            // String url = "https://openapi.tianquetech.com/query/close";//生产地址
+            String resultJson = HttpUtils.connectPostUrl(url, reqStr);
+            System.out.println("返回信息：" + resultJson);
+            //不要对reqData排序 所以用LinkedHashMap
+            HashMap<String, Object> result = JSON.parseObject(resultJson, LinkedHashMap.class, Feature.OrderedField);
+            if ("0000".equals(result.get("code"))) {
+                //验签
+                String signResult = result.get("sign").toString();
+                result.remove("sign");
+                String resultStr = RSASignature.getOrderContent(result);
+                System.out.println(resultStr);
+                //sign
+                String resultSign = RSASignature.encryptBASE64(RSASignature.sign(signContent,SXFPaySign.privateKey));
+                System.out.println("resultSign:" + resultSign);
+                //组装加密串
+                if (RSASignature.doCheck(resultStr, signResult, SXFPaySign.sxfPublic)) {
+                    System.out.println("===================验签成功==============");
+                }
+
+            }
+            results=gson.toJson(result);
+        }catch (Exception e){
+            e.printStackTrace();
+        }
+        return results;
+    }
+
+    /**
+     * 异步回调通知
+     */
+    @RequestMapping(value = "/getCallback", consumes = "application/json", method = RequestMethod.POST)
+    @ResponseBody
+    public void getCallback(HttpServletRequest request,HttpServletResponse response){
+        //获取回调参数信息
+        String uuid=request.getParameter("uuid");////随行付交易流水号
+        String mno=request.getParameter("mno");//发起交易的商户编号
+        String ordNo=request.getParameter("ordNo");//商户生成的订单号
+        String origOrdNo=request.getParameter("origOrdNo");//反交易退款异步通知
+        String origUuid=request.getParameter("origUuid");//token
+        String scene=request.getParameter("scene");//用户登录
+        String amt=request.getParameter("amt");//用户登录
+        String buyerId=request.getParameter("buyerId");//用户登录
+        String buyerAccount=request.getParameter("buyerAccount");//用户登录
+        String transactionId=request.getParameter("transactionId");//用户登录
+        String drType=request.getParameter("drType");//借贷记标识 1-借,2-贷，3-其他
+        String payType=request.getParameter("payType");//对订单的描述，取值范围：WECHAT:微信,ALIPAY:支付宝,UNIONPAY:
+        String payBank=request.getParameter("payBank");//付款银行银行编码，例如 ICBC
+        String pointAmount=request.getParameter("pointAmount");//代金券金额
+        String totalOffstAmt=request.getParameter("totalOffstAmt");//消 费 者 付 款金额
+        String settleAmt=request.getParameter("settleAmt");//商家入账金额
+        String realRefundAmount=request.getParameter("realRefundAmount");//商家出账金额
+        String recFeeAmt=request.getParameter("recFeeAmt");//交易手续费
+        String recFeeRate=request.getParameter("recFeeRate");//交易手续费率
+        String timeStamp=request.getParameter("timeStamp");//响应时间
+        String sign=request.getParameter("sign");//签名
+        String bizCode=request.getParameter("bizCode");//业务返回码
+        String bizMsg=request.getParameter("bizMsg");//业 务 返 回 信息
+        String openid=request.getParameter("openid");//微 信 或 支 付宝身份id()opendid userid
+        String channelId=request.getParameter("channelId");//渠道商户号
+        String subMechId=request.getParameter("subMechId");//子商户号
+        String refBuyerAmt=request.getParameter("refBuyerAmt");//消 费 者 到 账金额
+        String extend=request.getParameter("extend");//备用
+        //将业务参数存放在 JSON 对象中
+        JSONObject reqData = new JSONObject();
+        reqData.put("uuid",uuid);
+        reqData.put("mno",mno);
+        reqData.put("ordNo",ordNo);
+        reqData.put("origOrdNo",origOrdNo);
+        reqData.put("origUuid",origUuid);
+        reqData.put("scene",scene);
+        reqData.put("amt",amt);
+        reqData.put("buyerId",buyerId);
+        reqData.put("buyerAccount",buyerAccount);
+        reqData.put("transactionId",transactionId);
+        reqData.put("drType",drType);
+        reqData.put("payType",payType);
+        reqData.put("payBank",payBank);
+        reqData.put("pointAmount",pointAmount);
+        reqData.put("totalOffstAmt",totalOffstAmt);
+        reqData.put("settleAmt",settleAmt);
+        reqData.put("realRefundAmount",realRefundAmount);
+        reqData.put("recFeeAmt",recFeeAmt);
+        reqData.put("recFeeRate",recFeeRate);
+        reqData.put("timeStamp",timeStamp);
+        reqData.put("sign",sign);
+        reqData.put("bizCode",bizCode);
+        reqData.put("bizMsg",bizMsg);
+        reqData.put("openid",openid);
+        reqData.put("channelId",channelId);
+        reqData.put("subMechId",subMechId);
+        reqData.put("refBuyerAmt",refBuyerAmt);
+        reqData.put("extend",extend);
+
+        //根据回调信息，先进行验签，验签后修改状态
+        Gson gson =new Gson();
+        JSONObject req = new JSONObject();
+      //  String resultJson = gson.toJson(callBack);
+       // System.out.println("返回信息：" + resultJson);
+        //不要对reqData排序 所以用LinkedHashMap
+//        HashMap<String, Object> result = JSON.parseObject(resultJson, LinkedHashMap.class, Feature.OrderedField);
+//        if ("0000".equals(result.get("code"))) {
+            //验签
+//            String signResult = result.get("sign").toString();
+//            result.remove("sign");
+//            String resultStr = RSASignature.getOrderContent(result);
+//            System.out.println(resultStr);
+            //sign
+           // String resultSign = RSASignature.encryptBASE64(RSASignature.sign(signContent,SXFPaySign.privateKey));
+            //组装加密串
+//            if (RSASignature.doCheck(resultStr, signResult, SXFPaySign.sxfPublic)) {
+//                System.out.println("===================验签成功==============");
+                //验签成功，修改订单状态
+               // List<PayOrder> list =payOrderService.getPayOrderList(callBack.getOrdNo());
+//                if(list!=null&&list.size()==1){
+//                    String status = list.get(0).getStatus();
+//                    //状态为未支付 1  修改状态为已支付
+//                    if(status.equals("1")){
+//                        PayOrder payOrder=new PayOrder();
+//                     //   payOrder.setOrderNo(callBack.getOrdNo());
+//                        payOrder.setStatus("2");
+//                        //根据修改状态
+//                        payOrderService.getUpdatePayOrder(payOrder);
+//                    }
+//
+//                }
+                req.put("code","success");
+                req.put("msg","成功");
+           // }
+        //}
+//        try {
+//            response.setContentType("application/json; charset=UTF-8");
+//            response.setCharacterEncoding("UTF-8");
+//            response.getWriter().print(req);
+//            response.getWriter().flush();
+//            response.getWriter().close();
+//        }catch (Exception e){
+//            e.printStackTrace();
+//        }
+    }
+}