支付宝支付

src/main/java/com/yunzhi/niucai/common/CommConstants.java

@@ -31,4 +31,19 @@ public class CommConstants {
      * 篮球
      */
     public final static String LOTTERY_BASKETBALL = "basketball";
+
+    /**
+     * 支付中状态
+     */
+    public final static Integer SRTATUS_PAYING = 3;
+
+    /**
+     * 重新置为有效状态
+     */
+    public final static Integer SRTATUS_EFFECTIVE = 3;
+
+    /**
+     * 支付成功
+     */
+    public final static String TRADE_STATUS_SUCCESS = "TRADE_SUCCESS";
 }

src/main/java/com/yunzhi/niucai/controller/AliPayController.java

@@ -3,15 +3,28 @@ package com.yunzhi.niucai.controller;
 import com.alipay.easysdk.factory.Factory;
 import com.alipay.easysdk.kernel.Config;
 import com.alipay.easysdk.payment.app.models.AlipayTradeAppPayResponse;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.yunzhi.niucai.common.BaseController;
+import com.yunzhi.niucai.common.CommConstants;
 import com.yunzhi.niucai.common.ResponseBean;
 import com.yunzhi.niucai.config.InterceptorConfig;
+import com.yunzhi.niucai.entity.TaCustomer;
+import com.yunzhi.niucai.entity.TaOrder;
+import com.yunzhi.niucai.entity.TaShopApp;
+import com.yunzhi.niucai.service.ITaOrderService;
+import com.yunzhi.niucai.service.ITaShopAppService;
 import com.yunzhi.niucai.vo.LoginParam;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.ApiParam;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.web.bind.annotation.*;
 
 import javax.servlet.http.HttpServletRequest;
+import java.math.BigInteger;
+import java.security.SecureRandom;
+import java.util.Date;
 import java.util.Iterator;
 import java.util.Map;
 
@@ -19,52 +32,71 @@ import java.util.Map;
 @Api(tags = "登入/登出")
 @RestController
 @RequestMapping("/aliPay")
-public class AliPayController {
+public class AliPayController extends BaseController {
 
-    @GetMapping("/create")
+    @Autowired
+    public ITaShopAppService iTaShopAppService;
+
+    @Autowired
+    private ITaOrderService taOrderService;
+
+    @Value("${aliPay.notifyUrl}")
+    private String aliPayNotifyUrl;
+
+    @PostMapping("/create")
     @ApiOperation(value = "创建订单", notes = "创建订单", httpMethod = "POST", response = ResponseBean.class)
-    public ResponseBean create() throws Exception {
-        Factory.setOptions(getOptions());
-        AlipayTradeAppPayResponse pay = Factory.Payment.App().pay("测试", "12345678", "1");
+    public ResponseBean create(HttpServletRequest request, @RequestBody TaOrder taOrder) throws Exception {
+        Factory.setOptions(getOptions(taOrder));
+        String outTradeNo = "ALI" + System.currentTimeMillis() + randomString(5);
+        AlipayTradeAppPayResponse pay = Factory.Payment.App().pay("支付宝支付", outTradeNo, String.valueOf(taOrder.getAmount() / 100));
+        // 更新商户订单号并改为支付中
+        taOrder.setOutTradeNo(outTradeNo);
+        taOrder.setStatus(CommConstants.SRTATUS_PAYING);
+        taOrderService.updateById(taOrder);
         return ResponseBean.success(pay);
     }
 
-    public Config getOptions() {
+    public String randomString(int length) {
+        String str = new BigInteger(130, new SecureRandom()).toString(32);
+        return str.substring(0, length);
+    }
+
+    public Config getOptions(TaOrder taOrder) throws Exception {
         Config config = new Config();
         config.protocol = "https";
         config.gatewayHost = "openapi.alipay.com";
         config.signType = "RSA2";
 
-        config.appId = "2021001190647352";
-
+        TaShopApp taShopApp = iTaShopAppService.getOne(new QueryWrapper<TaShopApp>().eq("shop_id", taOrder.getShopId()));
+        config.appId = taShopApp.getAppid();
         // 私钥
-        config.merchantPrivateKey = "MIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQCsQCrrvTMjGfUay2yJv9DbjhkA7CBwcuWWaFosTfhKgaY+KGsLaY1DWvLgx3bQ85PZQoMRewzdPkZZw3nRAgt0SqI1sP3/ix0aRALNuQ3Y4386LqNieHObsjCvNaT5O1sETdPuceyH8Wny0tT8zCxfmKCuDOAJbUrN0Tx0jPHf42bucepKx7BNGwtSNGppOvdXqZgZ3px77lbGsiTibKJXi+w6fjYx2ZI7+QaK36177xMzYhct4IT0r5FXjKUz7wlsebvU72gNVLOeDBVMWb0GvX2FpnZ2XsT+Dn7vxfY1Tp/HEy9K/646TrM/h53wxoUTxVWYPj6dZEVQBFNskXlVAgMBAAECggEBAIEo5IY8KropXqcm3k40LPJVDN6qMHDhVtJ/kQ4jsQh9SyDUwd+e2DQnYHO4XZm066o/u3RCJpVHew0YDKHyvJAI3rUP8IXL1Ji7YrbMClwVynLgQdc2psmaxfK7cOcJ4OfLTB1CA7C0D1PrT5X3q1ZLZkDcmqm28B6AxKpIfZ349TxsAJPG7LhKJgkNcgign7qvU9L0CQB9PoMNDgsvOLH5gisW3hVqDveQuYTgUCafr0LeKTL5AAG5rw9TzGzkjlnOPTWZL+Lhfw9CIFzrdj0iyT7IrcgAiAZ4k47EGZnOT3ter5f1sd/YIVAjYdFORyA7BM8yIlr06oz6RkCuMQkCgYEA2U/M6iSc7L9f5ogsl/zwV3RAjTq5tcFcu4Zr591hvm0y8+NneSeDClwy9rq+AC3+kPEbYD1V0as4AbKetVLoCb7WZegQn5DeYCAfLpPmVlcQ+6UQSEdKVgff2xXxbF+EJwANsZJp/+fcS5ySS5TqVneU1xvyirBDs0czTa10EFMCgYEAyuqp+b4grQhFs5KISlUbNPFtsm9/RimBuRbEp3pEpGrHYzvb8Gn4p89FnQKvM05WFQkvLZ/g5nh/wbDavzWSF+5rQaaymYntLxhbXPqMaRxWIjQtTU0gP4pgOQ/Pzm7Sj3tL/XEK51CyTsFN+bOooK7JRQ5aDUWo0cmcoWCdOrcCgYASfGZbGKg8v37h9n2MpFixp9MB8JfxrTQ9Q48UV1HESDfIZXTc6o6MKBGxyWr2SvNX0xrYEf+l6WHHSzGTDS1t/szwOFCJsmIoXTMp3C0A9UEdlwoOi/n33Y2ebnxuEqYER03i6CiaO1gTGoubYFya5GtF7TuxrpLjwk/L8NBpvwKBgQCU4BSzcgYhTYduF509BDIA5v03xEwZ2wwdExJXWgKQqvL84IceXXGdFRqa9sQ6HUhVCLb/f2SPU2tQXYQwc4prWnaA5V/1/FbzjahCkGSCHdMoJyXxqBt34vt0AiDR8Uc1FB4NpWl9ixw3YeXmxSR8N6DdtIjnYetZd9UeJXdWAwKBgQDOFZRNcWNFxo97dXNTmAUhfOts3pRpooXUjqy9SpDsmfxn7EUTGEzo6V036a6bHYBW0XG8RozRv6AAkU2hmN2RBZRCiCaz1l++4wNxnVp64kxTP2M+VvqH8P+aRfRRlny1kBedpbVDF+w4nHBL7sZDCyOR0aer1VcEuL3n5zcnvA==";
-
+        config.merchantPrivateKey = taShopApp.getMerchantPrivateKey();
         //支付宝公钥字符串
-         config.alipayPublicKey = "MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAkH7Ka+0aQDGjegXicoe7Sks+5LccNe4JQ/j61r3fa7dFmFPstKIVogjDre+Ua3Q+YXqJoYTsT5BL5aNrfWfI+B1xk66E/shOk18WhP8xwIjZhgjKDGh73fJzHMSeDqbatJzbyoeNgGimBx4ljg2Io1tT4IznRGT9zqbvLcS+72QNbnCp7DEjL6FD9gS0Wjfb+Fn+qWd8koOCGcX+JsQfKXNyUBG7AAcdcfht+/qJ6QR1XH1nMaXEid0rWgmjG6bqY/jKL0Y08lc6GdMrZw1TM7E4GcUL+qvBCsnbH2keC/3YZrUMpJw7wWhEgz6h3549SftFUh0SOLBQGWK5VVFEHQIDAQAB";
-
-        //可设置异步通知接收服务地址（可选）
-        config.notifyUrl = "http://127.0.0.1:8080/aliPay/callback";
-
-        //可设置AES密钥，调用AES加解密相关接口时需要（可选）
-//        config.encryptKey = "<-- 请填写您的AES密钥，例如：aa4BtZ4tspm2wnXLb1ThQA== -->";
-
+         config.alipayPublicKey = taShopApp.getAlipayPublicKey();
+        //可设置异步通知接收服务地址
+        config.notifyUrl = aliPayNotifyUrl;
         return config;
     }
 
     @GetMapping("/callback")
     public void callback(HttpServletRequest request){
-        // 查看支付宝回调并调整业务，等调试在完善
-        Map<String, String[]> parameterMap = request.getParameterMap();
-        for (Iterator iter = parameterMap.entrySet().iterator(); iter.hasNext();) {
-            Map.Entry element = (Map.Entry) iter.next();
-            Object strKey = element.getKey();
-            String[] strArr = (String[])element.getValue();
-            System.out.println(strKey);
-            for (String str : strArr) {
-                System.out.println(str);
-            }
+        String tradeNo = request.getParameter("trade_no");
+        String appId = request.getParameter("app_id");
+        String outTradeNo = request.getParameter("out_trade_no");
+        String tradeStatus = request.getParameter("trade_status");
+        TaOrder taOrder = taOrderService.getOne(new QueryWrapper<TaOrder>().eq("out_trade_no", outTradeNo));
+        // 支付失败
+        if (!tradeStatus.equals(CommConstants.TRADE_STATUS_SUCCESS)){
+            taOrder.setStatus(CommConstants.SRTATUS_EFFECTIVE);
+            taOrderService.updateById(taOrder);
+            return;
         }
+        // 支付成功
+        //创建订单支付
 
+        // 更新为已支付状态
+        taOrder.setIsPayed(true);
+        taOrder.setStatus(CommConstants.SRTATUS_EFFECTIVE);
+        taOrderService.updateById(taOrder);
     }
 }

src/main/java/com/yunzhi/niucai/entity/TaOrder.java

@@ -57,5 +57,6 @@ public class TaOrder implements Serializable {
     @ApiModelProperty(value = "状态 1有效,0无效")
     private Integer status;
 
-
+    @ApiModelProperty(value = "商户网站唯一订单号")
+    private String outTradeNo;
 }

src/main/resources/application-dev.yml

@@ -18,4 +18,7 @@ logging:
 #    code: "0301"
 #    sign: 牛彩
 #    # 有效时间 单位秒
-#    expire: 300
+#    expire: 300
+
+aliPay:
+  notifyUrl: http://127.0.0.1:8080/aliPay/callback