Java開源生鮮電商平臺-支付模塊的設計與架構(源碼可下載)

来源:https://www.cnblogs.com/jurendage/archive/2018/05/14/9034444.html
-Advertisement-
Play Games

Java開源生鮮電商平臺-支付模塊的設計與架構(源碼可下載) 開源生鮮電商平臺支付目前支持支付寶與微信。針對的是APP端(android or IOS) 1。 資料庫表設計。 說明:無論是支付寶還是微信支付,都會有一個服務端的回調,業務根據回調的結果處理相應的業務邏輯。 pay_logs這個表主要是 ...


Java開源生鮮電商平臺-支付模塊的設計與架構(源碼可下載)

開源生鮮電商平臺支付目前支持支付寶與微信。針對的是APP端(android or IOS)

 

1。 資料庫表設計。

 

說明:無論是支付寶還是微信支付,都會有一個服務端的回調,業務根據回調的結果處理相應的業務邏輯。

           pay_logs這個表主要是記錄相關的用戶支付信息。是一個日誌記錄。

            比如:誰付款的,什麼時候付款的,訂單號多少,是支付寶還是微信,支付狀態是支付成功還是支付失敗,還是未支付。

      

           特別註意:訂單主表也有類似的回調信息。這樣用多張表記錄相應的信息,可以統計相應的業務指標,包括用戶的行為分析等。

 

            關於表的設計,我的經驗分享是:如果可以,核心業務表一定要有一個日誌記錄表,如果可以,可以用時間軸等方式進行數據的插入,與時間軸的顯示。

            時間軸可以清楚的知道用戶的行為點,幫助更加清晰的設計業務流程與系統架構。           

 

相應的支付寶回調代碼如下:(註意,這個業務模塊屬於買家。)

 

APP調用後端的業務代碼

/***
 * APP端調用請求支付寶
 */
@RestController
@RequestMapping("/buyer")
public class AlipayController extends BaseController
{
    private static final Logger logger = LoggerFactory.getLogger(AlipayController.class);
    /**
     * 伺服器通知地址
     */
    private static final String NOTIFY_URL="";
    
    /**待支付*/
    private static final int PAY_LOGS_READY=0;
    
    @Autowired
    private OrderInfoService orderInfoService;
    
    @Autowired
    private BuyerService buyerService;
    
    @Autowired
    private PayLogsService payLogsService;/**
     * APP端請求調用支付寶
     * @param request
     * @param response
     * @return
     */
    @RequestMapping(value="/alipay/invoke",method={RequestMethod.GET,RequestMethod.POST})
    public JsonResult alipayInvoke(HttpServletRequest req, HttpServletResponse resp)
    {
        String result="";
        try 
        {
            /**訂單號*/
            String orderNumber=this.getNotNull("orderNumber", req);
                    
            /**金額*/
            String money=this.getNotNull("money", req);
            
            /**優惠券id*/
            String couponReceiveId = req.getParameter("couponReceiveId");
            
            if(StringUtils.isBlank(orderNumber) || StringUtils.isBlank(money))
            {
                return new JsonResult(JsonResultCode.FAILURE,"請求參數有誤,請稍後重試","");
            }
            
            //對比金額
            OrderInfo orderInfo=this.orderInfoService.getOrderInfoByOrderNumber(orderNumber);
            if(orderInfo==null)
            {
                return new JsonResult(JsonResultCode.FAILURE,"訂單號不存在,請稍後重試","");
            }
            
            //獲取訂單的金額
            BigDecimal orderAmount=orderInfo.getOrderAmount();
            
            //減餘額
            Long buyerId=orderInfo.getBuyerId();
            
            Buyer buyer=this.buyerService.getBuyerById(buyerId);
            
            //用戶餘額
            BigDecimal balanceMoney=buyer.getBalanceMoney();
            
            //計算最終需要給支付寶的金額
            BigDecimal payAmount=orderAmount.subtract(balanceMoney);
            
            //買家支付時抵扣優惠券
            if(StringUtils.isNotBlank(couponReceiveId)){
                Long id = Long.parseLong(couponReceiveId);
                payAmount = couponReceiveService.deductionCouponMoney(id, orderNumber, payAmount);
            }
            
            logger.info("[AlipayController][alipayInvoke] orderNumber:" +orderNumber +" money:" +money+" orderAmount:"+orderAmount+" balanceMoney:"+balanceMoney+" payAmount:" +payAmount);
            
            //考慮重覆訂單的問題,會產生重覆日誌
            PayLogs payLogs=this.payLogsService.getPayLogsByOrderNumber(orderNumber);
            
            if(payLogs==null)
            {
                //創建訂單日誌
                PayLogs logs=new PayLogs();
                logs.setUserId(buyerId);
                logs.setOrderId(orderInfo.getOrderId());
                logs.setOrderNumber(orderNumber);
                logs.setOrderAmount(payAmount);
                logs.setStatus(PAY_LOGS_READY);
                logs.setCreateTime(new Date());
                int payLogsResult=payLogsService.addPayLogs(logs);
                logger.info("[AlipayController][alipayInvoke] 創建訂單日誌結果:" + (payLogsResult>0));
            }else
            {
                logger.info("[AlipayController][alipayInvoke] 創建重覆訂單");
            }
            
        
            AlipayClient alipayClient = new DefaultAlipayClient("https://openapi.alipay.com/gateway.do","","", "json","UTF-8","","RSA2");
            AlipayTradeAppPayRequest request = new AlipayTradeAppPayRequest();
            AlipayTradeAppPayModel model = new AlipayTradeAppPayModel();
            model.setBody("");
            model.setSubject("xxx");
            model.setOutTradeNo(orderNumber);
            model.setTimeoutExpress("15m");
            model.setTotalAmount(payAmount.toString());
            model.setProductCode("QUICK_MSECURITY_PAY");
            request.setBizModel(model);
            request.setNotifyUrl(NOTIFY_URL);
            
            AlipayTradeAppPayResponse response = alipayClient.sdkExecute(request);
            result=response.getBody();
            logger.info("[AlipayController][alipayNotify] result: " +result);
        } catch (AlipayApiException ex) 
        {
            logger.error("[AlipayController][alipayNotify] exception:",ex);
            return new JsonResult(JsonResultCode.FAILURE,"系統錯誤,請稍後重試","");
        }
        return new JsonResult(JsonResultCode.SUCCESS,"操作成功",result);
    } 
}

 

支付寶服務端回調代碼

 

import java.io.IOException;
import java.math.BigDecimal;
import java.util.Date;
import java.util.Enumeration;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;

import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;

import com.alipay.api.AlipayApiException;
import com.alipay.api.internal.util.AlipaySignature;
/**
 * alipay 支付寶服務端回調
 * 參考文檔:https://docs.open.alipay.com/204/105301/
 * 對於App支付產生的交易,支付寶會根據原始支付API中傳入的非同步通知地址notify_url,通過POST請求的形式將支付結果作為參數通知到商戶系統。
 */
@Controller
@RequestMapping("/buyer")
public class AlipayNotifyController extends BaseController {

    private static final Logger logger = LoggerFactory.getLogger(AlipayNotifyController.class);

    private static final String ALIPAYPUBLICKEY = "";

    private static final String CHARSET = "UTF-8";

    /**支付成功*/
    private static final int PAY_LOGS_SUCCESS=1;
    
    @Autowired
    private OrderInfoService orderInfoService;
   
    
    @RequestMapping(value = "/alipay/notify", method = { RequestMethod.GET, RequestMethod.POST })
    public void alipayNotify(HttpServletRequest request, HttpServletResponse response) throws IOException 
    {
        String url=request.getRequestURL().toString();
        
        logger.info("AlipayNotifyController.alipayNotify.s+tart");
        
        logger.info("[AlipayNotifyController][alipayNotify] url:" +url);
        
        ServletOutputStream out = response.getOutputStream();
        //支付寶交易號
        String alipayTradeNo=this.getNotNull("trade_no", request);
        
        //商戶訂單號
        String outerTradeNo=this.getNotNull("out_trade_no", request);
        
        //買家支付寶用戶號
        String buyerId=this.getNotNull("buyer_id", request);
        
        //買家支付寶賬號
        String buyerLogonId=this.getNotNull("buyer_logon_id", request);
        
        //交易狀態
        String tradeStatus=this.getNotNull("trade_status", request);
        
        //訂單金額,精確到小數點後2位
        String money=getNotNull("total_amount", request);
        
        logger.info("[AlipayNotifyController][alipayNotify] tradeStatus:" +tradeStatus+" money:"+money);
        
        StringBuffer buf = new StringBuffer();
        if (request.getMethod().equalsIgnoreCase("POST"))
        {
            Enumeration<String> em = request.getParameterNames();
            for (; em.hasMoreElements();)
            {
                Object o = em.nextElement();
                buf.append(o).append("=").append(request.getParameter(o.toString())).append(",");
            }
            logger.info("回調 method:post]http://" + request.getServerName() + request.getServletPath() + " [<prams:" + buf + ">]");
        } else
        {
            buf.append(request.getQueryString());
            logger.info("回調 method:get]http://" + request.getServerName() + request.getServletPath() + "?" + request.getQueryString());
        }
        
        //檢驗支付寶參數
        if(!verifyAlipay(request))
        {
               out.print("fail");
               return;
        }
        
        //交易成功
        if("TRADE_SUCCESS".equalsIgnoreCase(tradeStatus))
        {
            try
            {
                if(StringUtils.isNotBlank(outerTradeNo))
                {
                    //查詢當前訂單信息
                    OrderInfo info=this.orderInfoService.getOrderInfoByOrderNumber(outerTradeNo);
                    
                    if(info==null)
                    {
                        logger.error("[AlipayNotifyController][alipayNotify] info:" +info);
                        out.print("fail");
                           return;
                    }
                    
                    //訂單信息
                    OrderInfo orderInfo=new OrderInfo();
                    orderInfo.setOrderNumber(outerTradeNo);    
                    orderInfo.setCardCode("alipay");
                    orderInfo.setCardName("支付寶");
                    orderInfo.setCardNumber(buyerLogonId);
                    orderInfo.setCardOwner(buyerId);
                    orderInfo.setPayTime(new Date());
                    orderInfo.setOuterTradeNo(alipayTradeNo);
                    orderInfo.setPayStatus(PayStatus.PAY_SUCCESS);
                    orderInfo.setTradeStatus(TradeStatus.TRADE_PROGRESS);
                    orderInfo.setPayAmount(new BigDecimal(money));
                    orderInfo.setBuyerId(info.getBuyerId());
                    
                    //付款日誌
                    PayLogs payLogs=new PayLogs();
                    payLogs.setOrderNumber(outerTradeNo);
                    payLogs.setOuterTradeNo(alipayTradeNo);
                    payLogs.setStatus(PAY_LOGS_SUCCESS);
                    
                    orderInfoService.payReturn(orderInfo,payLogs);
                    out.print("success");
                    return;
                }
            }catch(Exception ex)
            {
                logger.error("[AlipayNotifyController][payReturn] 出現了異常:",ex);
                out.print("success");
                return;
            }
        }else
        {
            out.print("fail");
            return;
        }
    }
    /**
     * 檢驗支付寶
     * @param request
     * @return
     */
    @SuppressWarnings("rawtypes")
    public boolean verifyAlipay(HttpServletRequest request)
    {
        boolean flag=true;
        
        // 獲取支付寶POST過來反饋信息
        Map<String, String> params = new HashMap<String, String>();
        Map requestParams = request.getParameterMap();
        for (Iterator iter = requestParams.keySet().iterator(); iter.hasNext();) {
            String name = (String) iter.next();
            String[] values = (String[]) requestParams.get(name);
            String valueStr = "";
            for (int i = 0; i < values.length; i++) {
                valueStr = (i == values.length - 1) ? valueStr + values[i] : valueStr + values[i] + ",";
            }
            params.put(name, valueStr);
        }
        try
        {
            flag= AlipaySignature.rsaCheckV1(params, ALIPAYPUBLICKEY, CHARSET, "RSA2");
        } catch (AlipayApiException e) {
            e.printStackTrace();
            flag=false;
        }
        return flag;
    }
}

 

APP支付成功後,其實支付寶或者微信都會告訴你是否成功,只是這種通知是不可靠的,最可靠的的一種方式是支付寶或者微信的服務端回調。

根據回調處理相關的業務。

 

相應的微信回調代碼如下:(註意,這個業務模塊屬於買家。)

 

 

APP調用微信:

/***
 * APP端調用請求微信
 */
@RestController
@RequestMapping("/buyer")
public class WeiXinController extends BaseController
{
    private static final Logger logger = LoggerFactory.getLogger(WeiXinController.class);
    
    /**待支付*/
    private static final int PAY_LOGS_READY=0;
    
    @Autowired
    private OrderInfoService orderInfoService;
    
    @Autowired
    private BuyerService buyerService;
    
    @Autowired
    private PayLogsService payLogsService;
    
    @Autowired
    private CouponReceiveService couponReceiveService;
    
    /**
     * APP端請求調用微信
     * @param request
     * @param response
     * @return
     */
    @RequestMapping(value="/weixin/invoke",method={RequestMethod.GET,RequestMethod.POST})
    public JsonResult weixinInvoke(HttpServletRequest req, HttpServletResponse resp)
    {
        try 
        {
            /**訂單號*/
            String orderNumber=this.getNotNull("orderNumber", req);
                    
            /**金額*/
            String money=this.getNotNull("money", req);
            
            /**優惠券id*/
            String couponReceiveId = req.getParameter("couponReceiveId");
            
            if(StringUtils.isBlank(orderNumber) || StringUtils.isBlank(money))
            {
                return new JsonResult(JsonResultCode.FAILURE,"請求參數有誤,請稍後重試","");
            }
            
            //對比金額
            OrderInfo orderInfo=this.orderInfoService.getOrderInfoByOrderNumber(orderNumber);
            if(orderInfo==null)
            {
                return new JsonResult(JsonResultCode.FAILURE,"訂單號不存在,請稍後重試","");
            }
            
            //獲取訂單的金額
            BigDecimal orderAmount=orderInfo.getOrderAmount();
            
            //減餘額
            Long buyerId=orderInfo.getBuyerId();
            
            Buyer buyer=this.buyerService.getBuyerById(buyerId);
            
            //用戶餘額
            BigDecimal balanceMoney=buyer.getBalanceMoney();
            
            //計算最終需要給微信的金額
            BigDecimal payAmount=orderAmount.subtract(balanceMoney);
            
            //買家支付時抵扣優惠券
            if(StringUtils.isNotBlank(couponReceiveId)){
                Long id = Long.parseLong(couponReceiveId);
                payAmount = couponReceiveService.deductionCouponMoney(id, orderNumber, payAmount);
            }
            
            logger.info("[WeiXinController][weixinInvoke] orderNumber:" +orderNumber +" money:" +money+" orderAmount:"+orderAmount+" balanceMoney:"+balanceMoney+" payAmount:" +payAmount);
            
            //考慮重覆訂單的問題,會產生重覆日誌
            PayLogs payLogs=this.payLogsService.getPayLogsByOrderNumber(orderNumber);
            
            if(payLogs==null)
            {
                //創建訂單日誌
                PayLogs logs=new PayLogs();
                logs.setUserId(buyerId);
                logs.setOrderId(orderInfo.getOrderId());
                logs.setOrderNumber(orderNumber);
                logs.setOrderAmount(payAmount);
                logs.setStatus(PAY_LOGS_READY);
                logs.setCreateTime(new Date());
                int payLogsResult=payLogsService.addPayLogs(logs);
                logger.info("[WeiXinController][weixinInvoke] 創建訂單日誌結果:" + (payLogsResult>0));
            }else
            {
                logger.info("[WeiXinController][weixinInvoke] 創建重覆訂單");
            }
            
            //微信開始
            SortedMap<Object,Object> paramMap = new TreeMap<Object,Object>();  
            paramMap.put("appid", WeiXinUtil.APPID);
            paramMap.put("mch_id", WeiXinUtil.MCHID);
            
            String nonceStr=RandomUtil.generateString(8);
            // 隨機字元串    
            paramMap.put("nonce_str", nonceStr);
            paramMap.put("body","魔笛食材");// 商品描述  
            paramMap.put("out_trade_no", orderNumber);// 商戶訂單編號  
            paramMap.put("total_fee",Math.round(payAmount.doubleValue()*100));
            //IP地址
            String ip=IpUtils.getIpAddr(req);
            paramMap.put("spbill_create_ip",ip);
            paramMap.put("notify_url", WeiXinUtil.NOTIFYURL);// 回調地址  
            paramMap.put("trade_type",WeiXinUtil.TRADETYPE);// 交易類型APP  
            String sign=createSign(paramMap);
            paramMap.put("sign", sign);// 數字簽證  

            logger.info("weixin支付請求IP:" +ip+ " sign:" +sign);
            
            String xml = getRequestXML(paramMap);   
            
            String content = HttpClientUtil.getInstance().sendHttpPost(WeiXinUtil.URL,xml,"UTF-8");
            
            logger.info("weixin支付請求的內容content:" +content);
            
            JSONObject jsonObject = JSONObject.fromObject(XmltoJsonUtil.xml2JSON(content));
            
            JSONObject resultXml = jsonObject.getJSONObject("xml");
            
            //返回的編碼
            JSONArray returnCodeArray =resultXml.getJSONArray("return_code");
            
            //返回的消息
            JSONArray returnMsgArray =resultXml.getJSONArray("return_msg");
            
            //結果編碼
            JSONArray resultCodeArray =resultXml.getJSONArray("result_code");
            
            String returnCode= (String)returnCodeArray.get(0);
            
            String returnMsg= (String)returnMsgArray.get(0);
            
            String resultCode = (String)resultCodeArray.get(0);
            
            logger.info("[WeiXinController][weixinInvoke] returnCode: " +returnCode+" returnMsg:"+returnMsg +" resultCode:"+resultCode);
            
            if(resultCode.equalsIgnoreCase("FAIL"))
            {  
                return new JsonResult(JsonResultCode.FAILURE,"微信統一訂單下單失敗","");
            }
            
            if(resultCode.equalsIgnoreCase("SUCCESS"))
            {
                JSONArray prepayIdArray =resultXml.getJSONArray("prepay_id");
                
                String prepayId= (String)prepayIdArray.get(0);
                
                WeiXinBean weixin=new WeiXinBean();
                weixin.setAppid(WeiXinUtil.APPID);
                weixin.setPartnerid(WeiXinUtil.MCHID);
                weixin.setNoncestr(nonceStr);
                weixin.setPrepayid(prepayId);
                String timestamp=System.currentTimeMillis()/1000+"";
                weixin.setTimestamp(timestamp);
                //最終返回簽名
                SortedMap<Object,Object> apiMap = new TreeMap<Object,Object>();  
                apiMap.put("appid", WeiXinUtil.APPID);
                apiMap.put("partnerid", WeiXinUtil.MCHID);
                apiMap.put("prepayid", prepayId);
                apiMap.put("package","Sign=WXPay");
                apiMap.put("noncestr",nonceStr);
                apiMap.put("timestamp", timestamp);
                //再次簽名
                weixin.setSign(createSign(apiMap));
                return new JsonResult(JsonResultCode.SUCCESS,"微信統一訂單下單成功",weixin);
            }             
            return new JsonResult(JsonResultCode.FAILURE,"操作失敗","");
        } catch (Exception ex) 
        {
            logger.error("[WeiXinController][weixinInvoke] exception:",ex);
            return new JsonResult(JsonResultCode.FAILURE,"系統錯誤,請稍後重試","");
        }
    } 
    //拼接xml 請求路徑 
    @SuppressWarnings({"rawtypes"})
    private String getRequestXML(SortedMap<Object, Object> parame){  
        StringBuffer buffer = new StringBuffer();  
        buffer.append("<xml>");  
        Set set = parame.entrySet();  
        Iterator iterator = set.iterator();  
        while(iterator.hasNext()){  
            Map.Entry entry = (Map.Entry) iterator.next();  
            String key =String.valueOf(entry.getKey());  
            String value = String.valueOf(entry.getValue());
            //過濾相關欄位sign  
            if("sign".equalsIgnoreCase(key)){  
                buffer.append("<"+key+">"+"<![CDATA["+value+"]]>"+"</"+key+">");  
            }else{  
                buffer.append("<"+key+">"+value+"</"+key+">");  
            }             
        }  
        buffer.append("</xml>");  
        return buffer.toString();  
    }
    
    //創建md5 數字簽證  
    @SuppressWarnings({"rawtypes"})
    private String createSign(SortedMap<Object, Object> param){ 
         StringBuffer buffer = new StringBuffer();  
            Set set = param.entrySet();  
            Iterator<?> iterator = set.iterator();  
            while(iterator.hasNext()){  
                Map.Entry entry = (Map.Entry) iterator.next();  
                String key = String.valueOf(entry.getKey());  
                Object value =String.valueOf(entry.getValue());  
                if(null != value && !"".equals(value) && !"sign".equals(key) && !"key".equals(key)){  
                    buffer.append(key+"="+value+"&");  
                }             
            }  
            buffer.append("key="+WeiXinUtil.APIKEY);  
            String sign =EncryptUtil.getMD5(buffer.toString()).toUpperCase();   
            return sign;
    }
}

 

微信回調介面:

 

 

 

/**
 * weixin 微信服務端回調
 */
@Controller
@RequestMapping("/buyer")
public class WeiXinNotifyController extends BaseController {

    private static final Logger logger = LoggerFactory.getLogger(WeiXinNotifyController.class);

    /**支付成功*/
    private static final int PAY_LOGS_SUCCESS=1;
    
    @Autowired
    private OrderInfoService orderInfoService;
    
    @Autowired
    private CouponReceiveService couponReceiveService;
    
    @Autowired
    private GroupsService groupsService;
    
    @RequestMapping(value = "/weixin/notify", method = { RequestMethod.GET, RequestMethod.POST })
    public void weixinNotify(HttpServletRequest request, HttpServletResponse response) throws IOException 
    {
        String url=request.getRequestURL().toString();
        logger.info("WeiXinNotifyController.weixinNotify.start-->url:" +url);
        try
        {
            StringBuffer buf = new StringBuffer();
            if (request.getMethod().equalsIgnoreCase("POST"))
            {
                Enumeration<String> em = request.getParameterNames();
                for (; em.hasMoreElements();)
                {
                    Object o = em.nextElement();
                    buf.append(o).append("=").append(request.getParameter(o.toString())).append(",");
                }
                logger.info("回調 method:post]http://" + request.getServerName() + request.getServletPath() + " [<prams:" + buf + ">]");
            } else
            {
                buf.append(request.getQueryString());
                logger.info("回調 method:get]http://" + request.getServerName() + request.getServletPath() + "?" + request.getQueryString());
            }
            
            request.setCharacterEncoding("UTF-8");    
            response.setCharacterEncoding("UTF-8");    
            response.setContentType("text/html;charset=UTF-8");    
            response.setHeader("Access-Control-Allow-Origin", "*");     
            InputStream in=request.getInputStream();    
            ByteArrayOutputStream out=new ByteArrayOutputStream();    
            byte[] buffer =new byte[1024];    
            int len=0;    
            while((len=in.read(buffer))!=-1){    
                out.write(buffer, 0, len);    
            }    
            out.close();    
            in.close();    
            String content=new String(out.toByteArray(),"utf-8");//xml數據    
            
            logger.info("[WeiXinNotifyController][weixinNotify] content:" +content);
            
            //日誌顯示,存在為空的情況.
            if(StringUtils.isBlank(content))
            {
                logger.error("[WeiXinNotifyController][weixinNotify] content is blank,please check it");
                response.getWriter().write(setXml("FAIL", "ERROR"));
                return; 
            }
            
            JSONObject jsonObject = JSONObject.fromObject(XmltoJsonUtil.xml2JSON(content));
            
            JSONObject resultXml = jsonObject.getJSONObject("xml");
            JSONArray returnCode =  resultXml.getJSONArray("return_code");  
            String code = (String)returnCode.get(0);
            
            if(code.equalsIgnoreCase("FAIL"))
            {  
                response.getWriter().write(setXml("SUCCESS", "OK"));
                return;
            }else if(code.equalsIgnoreCase("SUCCESS"))
            {  
                //商戶訂單號即訂單編號
                String outerTradeNo =String.valueOf(resultXml.getJSONArray("out_trade_no").get(0));
                
                //微信交易訂單號
                String tradeNo = String.valueOf(resultXml.getJSONArray("transaction_id").get(0));
                
                //交易狀態
                String resultCode = String.valueOf(resultXml.getJSONArray("result_code").get(0));
                
                //金額
                String money =String.valueOf(resultXml.getJSONArray("total_fee").get(0));
                
                //微信的用戶ID
                String openId =String.valueOf(resultXml.getJSONArray("openid").get(0));
                
                logger.info("[WeiXinNotifyController][weixinNotify] resultCode:" +resultCode+" money:"+money);
                
                //根據這個判斷來獲取訂單交易是否OK
                if(!resultCode.equalsIgnoreCase("SUCCESS"))
                {
                    response.getWriter().write(setXml("FAIL", "ERROR"));
                    return;
                }
                
                try
                {
                    if(StringUtils.isNotBlank(outerTradeNo))
                    {
                        //查詢當前訂單信息
                        OrderInfo info=this.orderInfoService.getOrderInfoByOrderNumber(outerTradeNo);
                        
                        if(info==null)
                        {
                            logger.error("[WeiXinNotifyController][weixinNotify] info:" +info);
                            response.getWriter().write(setXml("FAIL", "ERROR"));
                            return;
                        }
                        
                        //訂單信息
                        OrderInfo orderInfo=new OrderInfo();
                        orderInfo.setOrderNumber(outerTradeNo);    
                        orderInfo.setCardCode("weixin");
                        orderInfo.setCardName("微信支付");
                        orderInfo.setCardNumber(openId);
                        orderInfo.setCardOwner(openId);
                        orderInfo.setPayTime(new Date());
                        orderInfo.setOuterTradeNo(tradeNo);
                        orderInfo.setPayStatus(PayStatus.PAY_SUCCESS);
                        orderInfo.setTradeStatus(TradeStatus.TRADE_PROGRESS);
                        orderInfo.setPayAmount(new BigDecimal(money).divide(new BigDecimal(100)));
                        orderInfo.setBuyerId(info.getBuyerId());
                        
                        //付款日誌
                        PayLogs payLogs=new PayLogs();
                        payLogs.setOrderNumber(outerTradeNo);
                        payLogs.setOuterTradeNo(tradeNo);
                        payLogs.setStatus(PAY_LOGS_SUCCESS);
                        
                        orderInfoService.payReturn(orderInfo,payLogs);
                        
                        //回寫團購成功狀態
                        groupsService.updateGbStatusByOrderNumber(outerTradeNo);
                        response.getWriter().write(setXml("SUCCESS", "OK"));
                        try
                        {
                            //更新優惠券狀態為已用
                            couponReceiveService.updateStatus(outerTradeNo);
                        }catch(Exception ex){
                            logger.error("[AlipayNotifyController][payReturn] 更新優惠券狀態異常:",ex);
                        }
                        return;
                    }
                }catch(Exception ex)
                {
                    logger.error("[WeiXinNotifyController][payReturn] 出現了異常:",ex);
                    response.getWriter().write(setXml("SUCCESS", "OK"));
                    return;
                }
            }             
        }catch(Exception e){
            logger.error("[WeiXinNotifyController][weixinNotify] exception:" ,e);
            response.getWriter().write(setXml("SUCCESS", "OK"));
            return;
        }  
    }  
    //返回微信服務  
    private String setXml(String returnCode,String returnMsg)
    {    
       return "<xml><return_code><![CDATA["+returnCode+"]]></return_code><return_msg><![CDATA["+returnMsg+"]]></return_msg></xml>";    
    }   
}

    Java開源生鮮電商平臺-支付表的設計與架構(源碼可下載),如果需要下載的話,可以在我的github下麵進行下載。 

 

相關的運營截圖如下:

 

 

 

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 開發中遇到一個需要優化的性能,頁面需要渲染很多table,而且可以自己添加table,所以就導致router改變時,清除這些DOM結構就會很慢,這就給用戶造成不好的體驗。 問題所在:清除渲染過多的DOM結構才導致遲緩; 解決方案:引入的table頁面作為一個子組件,存在切換table顯示內容的功能, ...
  • 2018年已經到了5月份,node的4.x版本也已經停止了維護 我司的某個服務也已經切到了8.x,目前正在做koa2.x的遷移 將之前的generator全部替換為async 但是,在替換的過程中,發現一些濫用async導致的時間上的浪費 所以來談一下,如何優化async代碼,更充分的利用非同步事件流 ...
  • 一. 數據切分 關係型資料庫本身比較容易成為系統瓶頸,單機存儲容量、連接數、處理能力都有限。當單表的數據量達到1000W或100G以後,由於查詢維度較多,即使添加從庫、優化索引,做很多操作時性能仍下降嚴重。此時就要考慮對其進行切分了,切分的目的就在於減少資料庫的負擔,縮短查詢時間。 資料庫分散式核心 ...
  • 學習設計模式時,看到一些術語,瞭解一下 is-a,has-a,like-a含義 假設你確定兩件對象之間是is-a的關係,代表繼承。比如菱形、圓形和方形都是形狀的一種。那麼他們都應該從形狀類繼承。 假設你確定兩件對象之間是has-a的關係,代表聚合,為從屬關係。比如電腦是由顯示器、CPU、硬碟等組成的 ...
  • 轉載請註明原文地址: http://www.cnblogs.com/geekda/p/9033815.html 單例模式是23種設計模式中比較常見的一種創建式模式,使用單例模式的目的就是為了節省系統資源,做到一次定義,到處使用的效果,目前使用比較廣泛的場景是spring 的bean,使用的是註冊式單 ...
  • 摘 要:隨著信息化教學的日益發展與網路課程資源建設的日趨完善,混合式教學模式正在成為教學改革的熱點方向之一。文章針對C++ 程式設計語言課程,基於網路課程資源設計一個混合式教學改革方案,並介紹在 3 個不同性質的教學班進行的教學試點情況,對試點的效果進行統計分析,並指出存在的問題。 引 言 今天母親 ...
  • 前言 瞭解什麼是分散式,得先瞭解應用系統的分層和分割。 分層 分層是將系統在橫向維度上切分成幾個部分,每個部分負責比較單一的職責,然後通過上層對下層的依賴和調用組成一個完整的系統。網站軟體系統可分層為應用層、服務層、數據層。 應用層:負責具體業務和視圖展示。(可再細分為視圖層和業務邏輯層) 服務層: ...
  • lask_login登錄實現Demo,涉及到Flask-SQLAlchemy、Flask-Login、Flask-WTF、PyMySQL等知識點,如果正在學習相關知識,這個或許是一個不錯的參照! ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...