feats

src/main/java/com/yunzhi/niucai/alipay/AlipayFactory.java

@@ -0,0 +1,59 @@
+package com.yunzhi.niucai.alipay;
+
+import com.alipay.api.AlipayClient;
+import com.alipay.api.DefaultAlipayClient;
+import com.yunzhi.niucai.alipay.vo.ITokenResolve;
+import com.yunzhi.niucai.entity.TaAlipay;
+import com.yunzhi.niucai.service.ITaAlipayService;
+import com.yunzhi.niucai.service.ITaShopAppService;
+import com.yunzhi.niucai.service.impl.TaShopAppServiceImpl;
+import org.springframework.beans.factory.InitializingBean;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+
+@Component
+public class AlipayFactory implements InitializingBean {
+    private AlipayClient alipayClient;
+
+    @Resource(name = "taShopAppServiceImpl")
+    private ITokenResolve tokenResolve;
+
+    @Autowired
+    private Config config;
+
+    @Autowired
+    ITaShopAppService iTaShopAppService;
+
+    @Autowired
+    ITaAlipayService iTaAlipayService;
+
+    public PayService getService(Integer shopId) {
+        return new PayService(shopId, alipayClient, tokenResolve, config);
+    }
+
+    private AlipayClient getAlipayClient(Config config) {
+        return new DefaultAlipayClient(config.getApiURL(),
+                config.getAppid(),
+                config.getPrivateKey(),
+                config.getFormat(),
+                config.getCharset(),
+                config.getPublicKey(),
+                config.getSignType());
+    }
+
+    @Override
+    public void afterPropertiesSet() throws Exception {
+        // 写死, 取第一个
+        TaAlipay taAlipay = iTaAlipayService.getById(1);
+        this.config = new Config()
+                .setAppid(taAlipay.getAppid())
+                .setPrivateKey(taAlipay.getMerchantPrivateKey())
+                .setPublicKey(taAlipay.getAlipayPublicKey());
+
+        //
+        this.alipayClient = getAlipayClient(this.config);
+    }
+}

src/main/java/com/yunzhi/niucai/alipay/Config.java

@@ -0,0 +1,21 @@
+package com.yunzhi.niucai.alipay;
+
+import lombok.Data;
+import lombok.experimental.Accessors;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+@Data
+@Accessors(chain = true)
+@Component
+@ConfigurationProperties(prefix = "alipay")
+public class Config {
+    String appid;
+    String privateKey;
+    String publicKey;
+    String format;
+    String charset;
+    String signType;
+    String apiURL;
+    String notifyURL;
+}

src/main/java/com/yunzhi/niucai/alipay/PayService.java

@@ -0,0 +1,94 @@
+package com.yunzhi.niucai.alipay;
+
+
+import com.alibaba.fastjson.JSONObject;
+import com.alipay.api.AlipayApiException;
+import com.alipay.api.AlipayClient;
+import com.alipay.api.request.AlipayOpenAuthTokenAppRequest;
+import com.alipay.api.request.AlipayTradeAppPayRequest;
+import com.alipay.api.response.AlipayOpenAuthTokenAppResponse;
+import com.alipay.api.response.AlipayTradeAppPayResponse;
+import com.yunzhi.niucai.alipay.vo.ITokenResolve;
+import com.yunzhi.niucai.alipay.vo.PayParam;
+import lombok.extern.slf4j.Slf4j;
+
+import java.util.HashMap;
+import java.util.Map;
+
+@Slf4j
+public class PayService {
+    private ITokenResolve iTokenResolve;
+    private AlipayClient alipayClient;
+    private Config config;
+    private Integer shopId;
+
+    public PayService(Integer shopId, AlipayClient alipayClient, ITokenResolve iTokenResolve, Config config) {
+        this.shopId = shopId;
+        this.iTokenResolve = iTokenResolve;
+        this.alipayClient = alipayClient;
+        this.config = config;
+    }
+
+    /**
+     * 支付
+     * @param payParam
+     * @return
+     * @throws AlipayApiException
+     */
+    public AlipayTradeAppPayResponse Pay(PayParam payParam) throws AlipayApiException {
+        AlipayTradeAppPayRequest aliPayRequest = new AlipayTradeAppPayRequest();
+
+        String token = null;
+        if (this.iTokenResolve.isTokenExpired(this.shopId)) {
+            AlipayOpenAuthTokenAppResponse refreshResponse = refreshToken();
+            if (null != refreshResponse) {
+                token = refreshResponse.getAppAuthToken();
+            }
+        } else {
+            token = this.iTokenResolve.getAuthToken(this.shopId);
+        }
+
+        aliPayRequest.putOtherTextParam("app_auth_token", token);
+        aliPayRequest.setNotifyUrl(this.config.getNotifyURL());
+
+        if (null == payParam.getTimeoutExpress()) {
+            payParam.setTimeoutExpress("30m");
+        }
+
+        aliPayRequest.setBizContent(JSONObject.toJSONString(payParam));
+        try {
+            AlipayTradeAppPayResponse response = alipayClient.sdkExecute(aliPayRequest);
+            if (response.isSuccess()) {
+                return response;
+            } else {
+                log.error(String.format("支付宝下单失败, 商户ID %s : 错误码[%s], 错误说明[%s]", this.shopId, response.getSubCode(), response.getSubMsg()));
+                return null;
+            }
+        } catch (AlipayApiException e) {
+            log.error(String.format("使用支付宝下单失败: %s", e.getErrMsg()));
+            e.printStackTrace();
+            throw e;
+        }
+    }
+
+    private AlipayOpenAuthTokenAppResponse refreshToken() throws AlipayApiException {
+
+        AlipayOpenAuthTokenAppRequest request = new AlipayOpenAuthTokenAppRequest();
+
+        String refreshToken = this.iTokenResolve.getRefreshToken(this.shopId);
+        Map<String, String> param = new HashMap<String, String>() {{
+            put("grant_type", "refresh_token");
+            put("refresh_token", refreshToken);
+        }};
+
+        request.setBizContent(JSONObject.toJSONString(param));
+        AlipayOpenAuthTokenAppResponse response = alipayClient.execute(request);
+        if(response.isSuccess()){
+            this.iTokenResolve.refreshAuthToken(this.shopId, response.getAppAuthToken(), response.getAppRefreshToken(), response.getExpiresIn());
+            return response;
+        } else {
+            log.error(String.format("刷新支付宝 APP_AUTH_TOKEN 失败, 商户ID %s : 错误码[%s], 错误说明[%s]", this.shopId, response.getSubCode(), response.getSubMsg()));
+            return null;
+        }
+    }
+}

src/main/java/com/yunzhi/niucai/alipay/vo/ITokenResolve.java

@@ -0,0 +1,32 @@
+package com.yunzhi.niucai.alipay.vo;
+
+public interface ITokenResolve {
+
+    /**
+     * Token 是否过期
+     * @param shopId
+     * @return
+     */
+    boolean isTokenExpired(Integer shopId);
+
+    /**
+     * 获取 Token
+     * @param shopId
+     * @return
+     */
+    String getAuthToken(Integer shopId);
+
+    /**
+     * 获取 refreshToken
+     * @param shopId
+     * @return
+     */
+    String getRefreshToken(Integer shopId);
+
+    /**
+     * 刷新 Token
+     * @param shopId
+     * @return
+     */
+    void refreshAuthToken(Integer shopId, String authToken, String refreshToken, String expiresIn);
+}

src/main/java/com/yunzhi/niucai/alipay/vo/PayParam.java

@@ -0,0 +1,30 @@
+package com.yunzhi.niucai.alipay.vo;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+
+@ApiModel(description = "支付宝下单参数")
+@Data
+@Accessors(chain = true)
+public class PayParam {
+
+    @ApiModelProperty("总金额, 单位元, 2位小数到分")
+    @JSONField(name = "total_amount")
+    private String totalAmount;
+
+    @ApiModelProperty("商品的标题")
+    @JSONField(name = "subject")
+    private String subject;
+
+    @ApiModelProperty("唯一订单号")
+    @JSONField(name = "out_trade_no")
+    private String outTradeNo;
+
+    @ApiModelProperty("逾期时间 取值范围：5m～15d。m-分钟，h-小时，d-天")
+    @JSONField(name = "timeout_express")
+    private String timeoutExpress;
+}

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

@@ -56,4 +56,7 @@ public class TaShopApp implements Serializable {
 
     @ApiModelProperty(value = "对应的alipay应用")
     private Integer alipayId;
+
+    @ApiModelProperty(value = "Token 有效期, 单位秒")
+    private String expiresIn;
 }

src/main/java/com/yunzhi/niucai/service/impl/TaAlipayServiceImpl.java

@@ -6,6 +6,9 @@ import com.alipay.api.DefaultAlipayClient;
 import com.alipay.api.request.AlipayTradeAppPayRequest;
 import com.alipay.api.response.AlipayTradeAppPayResponse;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.yunzhi.niucai.alipay.AlipayFactory;
+import com.yunzhi.niucai.alipay.PayService;
+import com.yunzhi.niucai.alipay.vo.PayParam;
 import com.yunzhi.niucai.common.CommConstants;
 import com.yunzhi.niucai.common.ResponseBean;
 import com.yunzhi.niucai.entity.TaAlipay;
@@ -41,8 +44,8 @@ public class TaAlipayServiceImpl extends ServiceImpl<TaAlipayMapper, TaAlipay> i
     @Autowired
     private ITaOrderService taOrderService;
 
-    @Value("${aliPay.notifyUrl}")
-    private String aliPayNotifyUrl;
+    @Autowired
+    private AlipayFactory alipayFactory;
 
     @Autowired
     private TaAlipayMapper taAlipayMapper;
@@ -56,32 +59,26 @@ public class TaAlipayServiceImpl extends ServiceImpl<TaAlipayMapper, TaAlipay> i
      */
     @Override
     public ResponseBean orderPaying(TaOrder taOrder, TaShopApp taShopApp) throws AlipayApiException {
-        TaAlipay taAlipay = taAlipayMapper.selectById(taShopApp.getAlipayId());
+        PayService payService = alipayFactory.getService(taOrder.getShopId());
+
         String outTradeNo = "ALI" + System.currentTimeMillis() + randomString(5);
-        AlipayClient alipayClient = new DefaultAlipayClient("https://openapi.alipay.com/gateway.do", taAlipay.getAppid(), taAlipay.getMerchantPrivateKey(), "json", "GBK", taAlipay.getAlipayPublicKey(), "RSA2");
-        AlipayTradeAppPayRequest aliPayRequest = new AlipayTradeAppPayRequest();
-        aliPayRequest.putOtherTextParam("app_auth_token", taShopApp.getAppAuthToken());
-        aliPayRequest.setNotifyUrl(aliPayNotifyUrl);
-        aliPayRequest.setBizContent("{" +
-                "\"timeout_express\":\"30m\"," +
-                "\"total_amount\":\""+taOrder.getCharge() / 100 +"\"," +
-                "\"subject\":\"支付宝支付\"," +
-                "\"out_trade_no\":\""+outTradeNo+"\"," +
-                "  }");
-        AlipayTradeAppPayResponse response = alipayClient.sdkExecute(aliPayRequest);
-        if(response.isSuccess()){
-            // 更新商户订单号并改为支付中
-            taOrder.setOutTradeNo(outTradeNo);
-            taOrder.setStatus(CommConstants.SRTATUS_PAYING);
-            taOrder.setUpdateDate(LocalDateTime.now());
-            taOrderService.updateById(taOrder);
-            // 更新token是最后使用时间
-            taShopApp.setUpdateTokenDate(LocalDateTime.now());
-            iTaShopAppService.updateById(taShopApp);
-        } else {
-            System.out.println("调用失败");
+        String subject = "支付宝支付";
+        String totalAmount = String.format("%.2f", (float) taOrder.getCharge() / 100);
+        PayParam payParam = new PayParam()
+                .setOutTradeNo(outTradeNo)
+                .setSubject(subject)
+                .setTotalAmount(totalAmount);
+
+        AlipayTradeAppPayResponse response = payService.Pay(payParam);
+        if (null == response) {
+            return null;
         }
-        return ResponseBean.success(response);
+
+        taOrder.setOutTradeNo(outTradeNo);
+        taOrder.setStatus(CommConstants.SRTATUS_PAYING);
+        taOrderService.updateById(taOrder);
+
+        return null;
     }
 
     /**

src/main/java/com/yunzhi/niucai/service/impl/TaShopAppServiceImpl.java

@@ -1,11 +1,16 @@
 package com.yunzhi.niucai.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.yunzhi.niucai.alipay.vo.ITokenResolve;
+import com.yunzhi.niucai.common.StringUtils;
 import com.yunzhi.niucai.entity.TaShopApp;
 import com.yunzhi.niucai.mapper.TaShopAppMapper;
 import com.yunzhi.niucai.service.ITaShopAppService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import org.springframework.stereotype.Service;
 
+import java.time.LocalDateTime;
+
 /**
  * <p>
  * 门店应用表  服务实现类
@@ -15,6 +20,45 @@ import org.springframework.stereotype.Service;
  * @since 2020-09-23
  */
 @Service
-public class TaShopAppServiceImpl extends ServiceImpl<TaShopAppMapper, TaShopApp> implements ITaShopAppService {
+public class TaShopAppServiceImpl extends ServiceImpl<TaShopAppMapper, TaShopApp> implements ITaShopAppService, ITokenResolve {
+
+    @Override
+    public boolean isTokenExpired(Integer shopId) {
+        TaShopApp taShopApp = getByShopId(shopId);
+        String expires = taShopApp.getExpiresIn();
+        if (StringUtils.isEmpty(expires)) {
+            expires = "0";
+        }
+
+        long expiresIn = Long.parseLong(expires);
+        return taShopApp.getUpdateTokenDate().plusSeconds(expiresIn).isBefore(LocalDateTime.now());
+    }
+
+    private TaShopApp getByShopId(Integer shopId) {
+        QueryWrapper<TaShopApp> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("shop_id", shopId);
+        
+        return getOne(queryWrapper);
+    }
+
+    @Override
+    public String getAuthToken(Integer shopId) {
+        return getByShopId(shopId).getAppAuthToken();
+    }
+
+    @Override
+    public String getRefreshToken(Integer shopId) {
+        return getByShopId(shopId).getAppRefreshToken();
+    }
+
+    @Override
+    public void refreshAuthToken(Integer shopId, String authToken, String refreshToken, String expiresIn) {
+        TaShopApp taShopApp = getByShopId(shopId);
+        taShopApp.setAppAuthToken(authToken);
+        taShopApp.setAppRefreshToken(refreshToken);
+        taShopApp.setExpiresIn(expiresIn);
+        taShopApp.setUpdateTokenDate(LocalDateTime.now());
 
+        updateById(taShopApp);
+    }
 }

src/main/resources/application.yml

@@ -27,6 +27,16 @@ aliyun:
     bucketName: njcj
     bucketURL: https://njcj.oss-cn-shanghai.aliyuncs.com
 
+###
+alipay:
+  appid:
+  privateKey:
+  publicKey:
+  apiURL: https://openapi.alipay.com/gateway.do
+  format: json
+  charset: UTF-8
+  signType: RSA2
+
 ###
 weixin:
   miniapp: