添加支付宝支付接口

ace-common/src/main/java/com/github/wxiaoqi/security/common/util/process/SystemConfig.java

@@ -61,6 +61,35 @@ public class SystemConfig {
 	// 存放退款证书目录
 	public static String APICLIENT_CERT = SystemProperty.getConfig("APICLIENT_CERT");
 
+	/**
+	 * 支付宝支付相关配置
+	 */
+	public static final String ALIPAY_APPID = SystemProperty.getConfig("ALIPAY_APPID");
+	public static final String ALIPAY_PID = SystemProperty.getConfig("ALIPAY_PID");
+	public static final String ALIPAY_PUBLIC_KEY = SystemProperty.getConfig("ALIPAY_PUBLIC_KEY");
+	public static final String ALIPAY_ACOUNT = SystemProperty.getConfig("ALIPAY_ACOUNT");
+	public static final String ALIPAY_PRIVATE_KEY = SystemProperty.getConfig("ALIPAY_PRIVATE_KEY");
+
+	/**
+	 * 交易创建，等待买家付款
+	 */
+	public  static final String ALIPAY_WAIT_BUYER_PAY = "WAIT_BUYER_PAY";
+	/**
+	 * 未付款交易超时关闭，或支付完成后全额退款
+	 */
+	public  static final String ALIPAY_TRADE_CLOSED = "TRADE_CLOSED";
+	/**
+	 * 交易支付成功
+	 */
+	public  static final String ALIPAY_TRADE_SUCCESS = "TRADE_SUCCESS";
+	/**
+	 * 交易结束，不可退款
+	 */
+	public  static  final String ALIPAY_TRADE_FINISHED = "TRADE_FINISHED";
+
+	public static final String ALIPAY_PAY_BASE_URL = "https://openapi.alipay.com";
 
+	public static final String ALIPAY = "alipay";
 
+	public static final String WXPAY = "wxpay";
 }

ace-common/src/main/resources/properties/systemconfig.properties

@@ -36,3 +36,10 @@ APP_TRADE_TYPE=APP
 weixinHost=xxtest.upyuns.com
 #证书存放目录
 APICLIENT_CERT=D:\\cert\\1514583081_20181017_cert.p12
+
+#支付宝配置
+ALIPAY_APPID=2019070965781964
+ALIPAY_PID=2088531634846583
+ALIPAY_PUBLIC_KEY=MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAj/EMaAD2iJP3I5M0g6pssDDe3RxF5I3ECM/Kz/btM0RiW2g5oRrHSjtGuos9l1QhQAY0SrVqa2eZdPKUB3ZqJdimQiXr3dbiMvG9UCs8vVUcrtCHCBjDllKQLiYzboxE6JLXyfII5tIXbFKiGyiEyXQnffUhQ9uGyT2EGWGecz6PLIjDdbwpxuzF2gIUzV3bPxb+0axejBxJ/3zKnWrsbyq2nvs8XrzrR2CEggNqgqsKzaacCL1yZjXzQRseSnCMtgSxR5W5afbdY0zqbUlLHUrUZ8ycCRC0ECuI9HyTbuqtdWHEZH7vIH44wEQWZPDRhMfMZvzmPUgpTWZLv5BtaQIDAQAB
+ALIPAY_ACOUNT=xxfc810@163.com
+ALIPAY_PRIVATE_KEY=MIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQC3bANag6my6pjHWqwnSCffRonvOXE6uQgNNb+V23PV55zfcuC+jIgl9BRrIf4tax5f2itfDmlOdAX6mK8WJ620SHg777Q2KlgNTa25ta3xiEfgkb01SX9VyiaLPpP2TEo5LhhRcT+cUomIufQbVbm/jS8mRQ0qBoofbMfr7n9fBSiVDx/QX07qcJTc/MGCy79H5gUiy2fTOEMhTuNtPkoU3az7jXMQ5U/33ILFAJzPCMNJvQnCYxs/y5loxxHdVqV8FnuCWGEWNViuuBtFRVRNXkrs/x99nF0V5/FHnOZzdM3SWrKCpA/52G5QQrbhZXUhMyCs9stXvH+iVUC1JJ9DAgMBAAECggEAOGRf/5MdOGHCCQCKjyUzBQVV4RPDCS/cFtughH1M9sXXyCc0i8D/FtQc9vcjg2k8lHGqBfaTT8iCEhKhOemHETd6p8rBmCmamrR4JfGCghDJMHT+PATVvlWBViwuJ3o7E6tlVJzB1tjVahDpyQGpMwhAJ77xFiueiZzTNmlEBb02ByCG95vkBV7NQT8yO9/1i3eq/tMoY7FfJP5O4LQ41RmqU9TVaAnTfuE6gs5hJboNGbmSMs2w2M0tldibmWcsQsFFPLwbUz042czSVb9J7lsGJjCtsaBeUiJ15y66W9D3587JJar9p+EyA2LNbolgrrNi2AA9KU5wEW2w8XyoOQKBgQDZamXDQZK3N5E46Hp/79o0Q99jqj9sL/HCYB4+Z8dG/Mgs43HHpgd+gHVeSOgxXS7RxsLyjCsM97ysWk7sbafvqtsnYmPU2MzumykVVpgWO6dpBcwmf2Ygk2i2W77oEqIi2IUmzkvDhw9C8A8/oh+IuoyRouPGRHpykAF+uXKVhwKBgQDX+TfQDDPniSnA9kTlW5I44glRgogA4xJtAYLtEr2fH9Pys+lkOyRqQH5wbJVj27jzJ0lffNyyMxgbZ8KRiH+3qRa8wNazwwXlXmj4DQWZedkULOpgMdU4EbbkTQRU3onEpMAZhAmVvAV1KTozs4RKi+1fFZ9V6ZOtmvapNJuXZQKBgQC7Xb0rQ3SMHwAxGfCQFwVma2O2AX883iisCaemwkrze1+Lh8uDcisdMtlzEsO/3v09XdydqHxlZY6cvgssJ+hFXGoXi+xa/yfFLcR/FixlZK2Gja99MeeyhTcFiRWB7KT8ALrnUXvrmpZlanrJrQ8eBx6jV8ySDmu0FTSkoG8GOwKBgE5toxX7CHJBPhdjlvtPOJdNhiLCaw8fZpaNIPVkg9WgIkCVkuCiFYQ8LW44EDv2E4DBOITje+V+Zne1Q1PEJNUWIzqiMJWQ8bgsg6PoXqswM2N/OBF8pzg4PplDWppTQeZWCah6aVylrbmxIgCaZSUJEUchO/5f1xAJIR+rCgF9AoGBAKJVVbrKPWshQ4cTL6VzanowjpWCRUDR22Oz3nKIdRl1FX+DTXYE4Dwl38iiNHOJptS7VjU553BUZl7HxCmSBWUmtnV78NNnRKrFVUhQhIRYBjMn1W6MD0jlBkky6yXmXkPtlqU6vU19RzGrvv6fDdBf6v4AkD8kWXiH5j4XEiQS

xx-universal/xx-universal-server/pom.xml

@@ -78,6 +78,11 @@
             <version>2.0-SNAPSHOT</version>
             <scope>compile</scope>
         </dependency>
+        <dependency>
+            <groupId>com.alipay.sdk</groupId>
+            <artifactId>alipay-sdk-java</artifactId>
+            <version>3.7.26.ALL</version>
+        </dependency>
         <dependency>
             <groupId>antlr</groupId>
             <artifactId>antlr</artifactId>

xx-universal/xx-universal-server/src/main/java/com/xxfc/platform/universal/biz/OrderPayBiz.java

@@ -2,6 +2,17 @@ package com.xxfc.platform.universal.biz;
 
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
+import com.alipay.api.AlipayApiException;
+import com.alipay.api.AlipayClient;
+import com.alipay.api.AlipayConstants;
+import com.alipay.api.DefaultAlipayClient;
+import com.alipay.api.domain.AlipayTradeAppPayModel;
+import com.alipay.api.internal.util.AlipaySignature;
+import com.alipay.api.request.AlipayFundAuthOrderFreezeRequest;
+import com.alipay.api.request.AlipayTradeAppPayRequest;
+import com.alipay.api.response.AlipayFundAuthOrderFreezeResponse;
+import com.alipay.api.response.AlipayTradeAppPayResponse;
+import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
 import com.github.wxiaoqi.security.common.util.HTTPSUtils;
 import com.github.wxiaoqi.security.common.util.OrderUtil;
 import com.github.wxiaoqi.security.common.util.process.ResultCode;
@@ -20,6 +31,11 @@ import com.xxfc.platform.universal.entity.OrderPay;
 import com.xxfc.platform.universal.mapper.OrderPayMapper;
 import com.github.wxiaoqi.security.common.biz.BaseBiz;
 import tk.mybatis.mapper.entity.Example;
+
+import javax.servlet.http.HttpServletRequest;
+import java.math.BigDecimal;
+import java.util.HashMap;
+import java.util.Iterator;
 import java.util.List;
 import java.util.Map;
 
@@ -40,6 +56,9 @@ public class OrderPayBiz extends BaseBiz<OrderPayMapper,OrderPay> {
     @Autowired
     DictionaryBiz dictionaryBiz;
 
+    @Autowired
+    HttpServletRequest request;
+
     public JSONObject preparepay( OrderPayVo orderPayVo) {
         if(null == orderPayVo) {
             log.error("-----参数为空-----------");
@@ -124,6 +143,178 @@ public class OrderPayBiz extends BaseBiz<OrderPayMapper,OrderPay> {
         }
     }
 
+    /**
+     * 支付宝回调接口
+     * @return
+     */
+    public String alipayNotify() {
+        //获取支付宝POST过来反馈信息
+        Map<String,String> params = new HashMap<>();
+        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] + ",";
+            }
+            log.info(valueStr);
+            //乱码解决，这段代码在出现乱码时使用。
+            //valueStr = new String(valueStr.getBytes("ISO-8859-1"), "utf-8");
+            params.put(name, valueStr);
+        }
+        String msg = JSONObject.toJSONString(params);
+        log.info("alipay notify message={}", msg);
+//		//添加回调记录
+//		PaymentCallbackLog callbackLog = new PaymentCallbackLog();
+//		callbackLog.setPayCode(rstradeNo);
+//		callbackLog.setPayType(SystemConstant.PayType.ALIPAY);
+//		callbackLog.setOrderCode(rsOrderCode);
+//		callbackLog.setMessage(msg);
+//		paymentCallbackLogRepository.save(callbackLog);
+        //切记alipaypublickey是支付宝的公钥，请去open.alipay.com对应应用下查看。
+        //boolean AlipaySignature.rsaCheckV1(Map<String, String> params, String publicKey, String charset, String sign_type)
+        try {
+            boolean flag = AlipaySignature.rsaCheckV1(params, "", AlipayConstants.CHARSET_UTF8, AlipayConstants.SIGN_TYPE_RSA2);
+            if (!flag) {
+                log.info("alipay order rsaCheckV1 fail, result={}", msg);
+                return ObjectRestResponse.createDefaultFail().getMessage();
+            }
+            String rsTradeStatus = params.get("trade_status");
+            if (!SystemConfig.ALIPAY_TRADE_FINISHED.equals(rsTradeStatus) && !SystemConfig.ALIPAY_TRADE_SUCCESS.equals(rsTradeStatus)) {
+                log.info("alipay order trade_status has problem, result={}", msg);
+                return ObjectRestResponse.createDefaultFail().getMessage();
+            }
+            //String rsSellerId = params.get("seller_id");
+//
+//			PaymentRecord paymentRecord = paymentRecordRepository.findOneByOrderCode(rsOrderCode);
+//			//验证付款信息
+//			if (paymentRecord == null || !paymentRecord.getAmount().toString().equals(rsAmount)
+//					|| !aliPayConfig.getAppId().equals(rsAppId)) {
+//				log.info("alipay order notify fail, result={}", msg);
+//				return Response.FAILURE.getHeader().getMessage();
+//			}
+//			//重复回调
+//			if (paymentRecord.getStatus().intValue() != 1) {
+//				log.info("alipay order repeat notify, result={}", msg);
+//				return Response.SUCCESS().getHeader().getMessage();
+//			}
+//
+//			paymentRecord.setPayCode(rstradeNo);
+//			paymentRecord.setStatus(2);
+//			paymentRecordRepository.save(paymentRecord);
+
+//			Map<String, Object> sendMap =  DataUtils.objectToMap(paymentRecord);
+//			sendMap.put("amount", new BigDecimal(rsAmount).multiply(new BigDecimal(100)).intValue());
+//			sendMsgToOrder(JSONObject.toJSONString(sendMap));
+            return ObjectRestResponse.succ().getMessage();
+        } catch (AlipayApiException e) {
+            log.error("", e);
+        }
+        return ObjectRestResponse.createDefaultFail().getMessage();
+    }
+
+    /**
+     * 支付宝生成支付信息
+     * @param orderCode
+     * @param description
+     * @param payType
+     * @param amount
+     * @return
+     */
+    @SuppressWarnings("rawtypes")
+    private ObjectRestResponse generateAliPayment(String orderCode, String description, String payType, Integer amount
+                                       ) {
+        BigDecimal realAmount = new BigDecimal(amount.toString()).divide(new BigDecimal("100"), 2, BigDecimal.ROUND_UP);
+        String notifyUrl =SystemConfig.weixinHost + "/service/payment/notify/alipay";
+
+        //实例化客户端
+        AlipayClient alipayClient = new DefaultAlipayClient(SystemConfig.ALIPAY_PAY_BASE_URL + "/gateway.do",
+                SystemConfig.ALIPAY_APPID, SystemConfig.ALIPAY_PRIVATE_KEY, AlipayConstants.FORMAT_JSON,
+                AlipayConstants.CHARSET_UTF8, SystemConfig.ALIPAY_PUBLIC_KEY, AlipayConstants.SIGN_TYPE_RSA2);
+
+        //实例化具体API对应的request类,类名称和接口名称对应,当前调用接口名称：alipay.trade.app.pay
+		AlipayTradeAppPayRequest request = new AlipayTradeAppPayRequest();
+//		//SDK已经封装掉了公共参数，这里只需要传入业务参数。以下方法为sdk的model入参方式(model和biz_content同时存在的情况下取biz_content)。
+		AlipayTradeAppPayModel model = new AlipayTradeAppPayModel();
+		//model.setBody("我是测试数据");
+		model.setSubject(description);
+		model.setOutTradeNo(orderCode);
+		model.setTimeoutExpress("30m");
+		model.setTotalAmount(realAmount.toString());
+		model.setProductCode("QUICK_MSECURITY_PAY");
+		request.setBizModel(model);
+		request.setNotifyUrl(notifyUrl);
+
+//        AlipayFundAuthOrderFreezeRequest request = new AlipayFundAuthOrderFreezeRequest();
+//        String contentString = "{" +
+//                "\"auth_code\":\"" + orderCode + "\"," +
+//                "\"auth_code_type\":\"bar_code\"," +
+//                "\"out_order_no\":\"8077735255938023\"," +
+//                "\"out_request_no\":\"8077735255938032\"," +
+//                "\"order_title\":\"预授权冻结\"," +
+//                "\"amount\":0.01," +
+//                "\"payee_logon_id\":\"" + SystemConfig.ALIPAY_ACOUNT + "\"," +
+//                "\"payee_user_id\":\"" + SystemConfig.ALIPAY_PID + "\"," +
+//                "\"pay_timeout\":\"2d\"," +
+//                "\"extra_param\":\"{\\\"secondaryMerchantId\\\":\\\"17320004886\\\"}\"," +
+//                "\"product_code\":\"PRE_AUTH\"" ;
+//        log.info("content = {}", contentString);
+//        request.setBizContent(contentString);
+//        AlipayFundAuthOrderFreezeResponse response;
+//        try {
+//            response = alipayClient.execute(request);
+//            if(response.isSuccess()){
+//                System.out.println("调用成功");
+//                Map<String, Object> rt = new HashMap<>();
+//                rt.put("payType", payType);
+//                rt.put("payData", response.getBody());
+//                return ObjectRestResponse.succ(rt);
+//            } else {
+//                System.out.println("调用失败");
+//            }
+//        } catch (AlipayApiException e) {
+//            // TODO Auto-generated catch block
+//            e.printStackTrace();
+//        }
+
+
+		try {
+	        //这里和普通的接口调用不同，使用的是sdkExecute
+	       AlipayTradeAppPayResponse response = alipayClient.sdkExecute(request);
+	        System.out.println(response.getBody());//就是orderString 可以直接给客户端请求，无需再做处理。
+
+	        log.info("alipay result={}", response.getMsg());
+	        log.info("alipay result={}", response.getCode());
+	        log.info("alipay result={}", response.getBody());
+
+	        Map<String, Object> rt = new HashMap<>();
+	    	rt.put("payType", payType);
+	    	rt.put("payData", response.getBody());
+	    	return ObjectRestResponse.succ(rt);
+	    } catch (AlipayApiException e) {
+	        e.printStackTrace();
+		}
+        return ObjectRestResponse.createDefaultFail();
+    }
+
+    public ObjectRestResponse generatePayment(String orderCode, String description, String payType, Integer amount
+                                   ) {
+       ObjectRestResponse objectRestResponse = ObjectRestResponse.createDefaultFail();
+        switch (payType) {
+            case SystemConfig.ALIPAY:
+                objectRestResponse = generateAliPayment(orderCode, description, payType, amount);
+                break;
+            default:
+                log.info("不支持的付款类型，payType={}", payType);
+                break;
+        }
+        return objectRestResponse;
+    }
+
+
+
     public static void main(String[] args) {
         String url="https://xxtest.upyuns.com/api/order/baseOrder/app/unauth/notifyUrl?orderNo=20190603141137010007&tradeNo=20190603141137000002";
         String result="";

xx-universal/xx-universal-server/src/main/java/com/xxfc/platform/universal/controller/OrderPayController.java

@@ -35,6 +35,7 @@ public class OrderPayController extends BaseController<OrderPayBiz,OrderPay> {
         return baseBiz.preparepay(orderPayVo);
     }
 
+
     /**
      * 支付回调
      *
@@ -80,4 +81,18 @@ public class OrderPayController extends BaseController<OrderPayBiz,OrderPay> {
             out.print("<xml><return_code><![CDATA[SUCCESS]]></return_code><return_msg><![CDATA[]]></return_msg></xml>");
     }
 
+
+    @PostMapping(value = "/app/notify/alipay")
+    @IgnoreUserToken
+    public String alipayNotify(){
+        return baseBiz.alipayNotify();
+    }
+
+    @PostMapping(value = "/app/generate_payment")
+    public Object generatePayment(@RequestParam("orderCode") String orderCode, @RequestParam("description") String description,
+                                  @RequestParam("payType") String payType, @RequestParam("amount") Integer amount) {
+        Object resp = baseBiz.generatePayment(orderCode, description, payType, amount);
+        return resp;
+    }
+
 }
\ No newline at end of file