跨境支付回调

@@ -8,6 +8,8 @@ import java.util.Map;
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
 import javax.servlet.http.HttpServletResponse;
 
 
+import com.yohoufo.order.service.pay.alipay.AlipayCrossBorderService;
+import com.yohoufo.order.service.pay.alipay.AlipayServiceAbstract;
 import com.yohoufo.order.service.pay.unionpay.JsUnionpayService;
 import com.yohoufo.order.service.pay.unionpay.JsUnionpayService;
 import net.sf.oval.constraint.AssertURL;
 import net.sf.oval.constraint.AssertURL;
 import org.apache.commons.lang.StringUtils;
 import org.apache.commons.lang.StringUtils;
@@ -64,6 +66,9 @@ public class PaymentController {
     AlipayOuyinService alipayService;
     AlipayOuyinService alipayService;
 
 
     @Autowired
     @Autowired
+    AlipayCrossBorderService alipayCrossBorderService;
+
+    @Autowired
     JsUnionpayService jsUnionpayService;
     JsUnionpayService jsUnionpayService;
 
 
     public static final String RETURN_CODE = "return_code";
     public static final String RETURN_CODE = "return_code";
@@ -243,8 +248,17 @@ public class PaymentController {
             return ;
             return ;
         }
         }
 
 
+        AlipayServiceAbstract alipayServiceAbstract;
+
+        // 跨境支付宝的回调
+        if (params.containsKey("currency")){
+            alipayServiceAbstract = alipayCrossBorderService;
+        }else{
+            alipayServiceAbstract = alipayService;
+        }
+
         //回调验证
         //回调验证
-        if(!alipayService.notifyVerify(params)) {
+        if(!alipayServiceAbstract.notifyVerify(params)) {
             notifyResponse.setNotifyResult(NotifyResponse.PAYMENT_NOTIFY_RESULT_VERFAIL);
             notifyResponse.setNotifyResult(NotifyResponse.PAYMENT_NOTIFY_RESULT_VERFAIL);
             alipayLogger.error("[{}] notification verify failed", out_trade_no);
             alipayLogger.error("[{}] notification verify failed", out_trade_no);
             return ;
             return ;
@@ -252,7 +266,7 @@ public class PaymentController {
 
 
         PaymentData paymentData = null;
         PaymentData paymentData = null;
         try {
         try {
-            paymentData = alipayService.getPaymentData(params);
+            paymentData = alipayServiceAbstract.getPaymentData(params);
 
 
             alipayLogger.info("method alipayService.getPaymentData is {}", paymentData);
             alipayLogger.info("method alipayService.getPaymentData is {}", paymentData);
 
 
@@ -412,7 +426,7 @@ public class PaymentController {
             return false;
             return false;
         }
         }
 
 
-        if (!trade_status.equals("TRADE_SUCCESS")) {
+        if (!trade_status.equals("TRADE_SUCCESS") && !trade_status.equals("TRADE_FINISHED")) {
             logger.info("[{}] trade_status: {}", params.get("out_trade_no"), trade_status);
             logger.info("[{}] trade_status: {}", params.get("out_trade_no"), trade_status);
             return false;
             return false;
         }
         }