小程序微信支付完成通知结果处理，回调处理

时间：2024-02-24 16:06:51
/**

     * 支付完成通知

     * @param request

     * @param response

     * @return

     * @throws Exception

     */

    @RequestMapping(value = "/notify",method = RequestMethod.POST)

    public String notify(HttpServletRequest request, HttpServletResponse response) throws Exception {

        BufferedReader br = new BufferedReader(new InputStreamReader((ServletInputStream)request.getInputStream()));

        String line = null;

        StringBuilder sb = new StringBuilder();

        while((line = br.readLine())!=null){

            sb.append(line);

        }

        //解析并给微信发回收到通知确认

        Map map =  PayUtils.doXMLParse(sb.toString());

        String returnCode = map.get("return_code").toString();

        if(returnCode.equals("SUCCESS")){

            String resultCode = map.get("result_code").toString();

            if(resultCode.equals("SUCCESS")){

                SortedMap packageParams = new TreeMap<String, String>();

                packageParams.put("appid", map.get("appid").toString());

                packageParams.put("attach", map.get("attach").toString());

                packageParams.put("bank_type", map.get("bank_type").toString());

                packageParams.put("cash_fee", map.get("cash_fee").toString());

                packageParams.put("fee_type", map.get("fee_type").toString());

                packageParams.put("is_subscribe", map.get("is_subscribe").toString());

                packageParams.put("mch_id", map.get("mch_id").toString());

                packageParams.put("nonce_str", map.get("nonce_str").toString());

                packageParams.put("openid", map.get("openid").toString());

                packageParams.put("out_trade_no", map.get("out_trade_no").toString());

                packageParams.put("result_code", map.get("result_code").toString());

                packageParams.put("return_code", map.get("return_code").toString());

                packageParams.put("time_end", map.get("time_end").toString());

                packageParams.put("total_fee", map.get("total_fee").toString());

                packageParams.put("trade_type", map.get("trade_type").toString());

                packageParams.put("transaction_id", map.get("transaction_id").toString());

                String sign = PayUtils.createSign(packageParams,key);

                String originSign = map.get("sign").toString();

                if(sign.equals(originSign)){

                    //签名一致，保存支付流水

                    String xml="<xml>"

                              +"<return_code>SUCCESS</return_code>"

                              +"<return_msg>OK</return_msg>"

                              +"</xml>";

                    ProfPayLog payLog = new ProfPayLog();

                    payLog.setCreatedAt(new Date());

                    payLog.setSource(Source.WeiXin);

                    DecimalFormat df = new DecimalFormat("######0.00");

                    payLog.setTotalFee(String.valueOf(df.format((Double.valueOf(map.get("total_fee").toString())/100))));

                    payLog.setTradeNo(map.get("out_trade_no").toString());

                    payLog.setTransactionId(map.get("transaction_id").toString());

                    String attach = map.get("attach").toString();//userId+"#wx#"+activityId

                    payLog.setUserId(attach.split("#wx#")[0]);

                    payLog.setType(ProfPayLog.Type.Pay);

                    WxappUser user = wxappUserService.find(Long.valueOf(attach.split("#wx#")[0]));

                    WxappActivity activity = wxappActivityService.find(Long.valueOf(attach.split("#wx#")[1]));

                    WxappActivityApply activityApply = wxappActivityApplyService.findActivityApplyByUserAndActivity(user, activity);

                    if(activityApply.getPayLogId() != null){

                        System.out.println("=========已经完成了存储支付流水=========");

                        return xml;

                    }else{

                        System.out.println("=========完成第一次保存支付流水=========");

                        payLog = wxappPayService.save(payLog);

                        //在活动申请表中关联上支付流水的id

                        activityApply.setPayLogId(String.valueOf(payLog.getId()));

                        wxappActivityApplyService.save(activityApply);

                        return xml;

                    }

                }else{

                    String xml="<xml>"

                              +"<return_code>FAIL</return_code>"

                              +"<return_msg>签名不一致</return_msg>"

                              +"</xml>";

                    return xml;

                }

            }else{

                String xml="<xml>"

                          +"<return_code>FAIL</return_code>"

                          +"<return_msg>支付通知失败</return_msg>"

                          +"</xml>";

                        return xml;

            }

        } else {

            String xml="<xml>"

                  +"<return_code>FAIL</return_code>"

                  +"<return_msg>支付通知失败</return_msg>"

                  +"</xml>";

                return xml;

        }

    }

 

/**

     * 支付完成通知

     * @param request

     * @param response

     * @return

     * @throws Exception

     */

    @RequestMapping(value = "/notify",method = RequestMethod.POST)

    public String notify(HttpServletRequest request, HttpServletResponse response) throws Exception {

        BufferedReader br = new BufferedReader(new InputStreamReader((ServletInputStream)request.getInputStream()));

        String line = null;

        StringBuilder sb = new StringBuilder();

        while((line = br.readLine())!=null){

            sb.append(line);

        }

        //解析并给微信发回收到通知确认

        Map map =  PayUtils.doXMLParse(sb.toString());

        String returnCode = map.get("return_code").toString();

        if(returnCode.equals("SUCCESS")){

            String resultCode = map.get("result_code").toString();

            if(resultCode.equals("SUCCESS")){

                SortedMap packageParams = new TreeMap<String, String>();

                packageParams.put("appid", map.get("appid").toString());

                packageParams.put("attach", map.get("attach").toString());

                packageParams.put("bank_type", map.get("bank_type").toString());

                packageParams.put("cash_fee", map.get("cash_fee").toString());

                packageParams.put("fee_type", map.get("fee_type").toString());

                packageParams.put("is_subscribe", map.get("is_subscribe").toString());

                packageParams.put("mch_id", map.get("mch_id").toString());

                packageParams.put("nonce_str", map.get("nonce_str").toString());

                packageParams.put("openid", map.get("openid").toString());

                packageParams.put("out_trade_no", map.get("out_trade_no").toString());

                packageParams.put("result_code", map.get("result_code").toString());

                packageParams.put("return_code", map.get("return_code").toString());

                packageParams.put("time_end", map.get("time_end").toString());

                packageParams.put("total_fee", map.get("total_fee").toString());

                packageParams.put("trade_type", map.get("trade_type").toString());

                packageParams.put("transaction_id", map.get("transaction_id").toString());

                String sign = PayUtils.createSign(packageParams,key);

                String originSign = map.get("sign").toString();

                if(sign.equals(originSign)){

                    //签名一致，保存支付流水

                    String xml="<xml>"

                              +"<return_code>SUCCESS</return_code>"

                              +"<return_msg>OK</return_msg>"

                              +"</xml>";

                    ProfPayLog payLog = new ProfPayLog();

                    payLog.setCreatedAt(new Date());

                    payLog.setSource(Source.WeiXin);

                    DecimalFormat df = new DecimalFormat("######0.00");

                    payLog.setTotalFee(String.valueOf(df.format((Double.valueOf(map.get("total_fee").toString())/100))));

                    payLog.setTradeNo(map.get("out_trade_no").toString());

                    payLog.setTransactionId(map.get("transaction_id").toString());

                    String attach = map.get("attach").toString();//userId+"#wx#"+activityId

                    payLog.setUserId(attach.split("#wx#")[0]);

                    payLog.setType(ProfPayLog.Type.Pay);

                    WxappUser user = wxappUserService.find(Long.valueOf(attach.split("#wx#")[0]));

                    WxappActivity activity = wxappActivityService.find(Long.valueOf(attach.split("#wx#")[1]));

                    WxappActivityApply activityApply = wxappActivityApplyService.findActivityApplyByUserAndActivity(user, activity);

                    if(activityApply.getPayLogId() != null){

                        System.out.println("=========已经完成了存储支付流水=========");

                        return xml;

                    }else{

                        System.out.println("=========完成第一次保存支付流水=========");

                        payLog = wxappPayService.save(payLog);

                        //在活动申请表中关联上支付流水的id

                        activityApply.setPayLogId(String.valueOf(payLog.getId()));

                        wxappActivityApplyService.save(activityApply);

                        return xml;

                    }

                }else{

                    String xml="<xml>"

                              +"<return_code>FAIL</return_code>"

                              +"<return_msg>签名不一致</return_msg>"

                              +"</xml>";

                    return xml;

                }

            }else{

                String xml="<xml>"

                          +"<return_code>FAIL</return_code>"

                          +"<return_msg>支付通知失败</return_msg>"

                          +"</xml>";

                        return xml;

            }

        } else {

            String xml="<xml>"

                  +"<return_code>FAIL</return_code>"

                  +"<return_msg>支付通知失败</return_msg>"

                  +"</xml>";

                return xml;

        }

    }

相关文章