提交微信支付

liquidnet-bus-api/liquidnet-service-dragon-api/src/main/java/com/liquidnet/service/dragon/dto/DragonPayBaseReqDto.java

@@ -17,6 +17,9 @@ import java.math.BigDecimal;
  */
 @Data
 public class DragonPayBaseReqDto {
+    private String payType;
+    private String deviceFrom;
+    private String openId;
     private String type;
     private BigDecimal price;
     private String name;

liquidnet-bus-api/liquidnet-service-dragon-api/src/main/java/com/liquidnet/service/dragon/dto/DragonPayBaseRespDto.java

@@ -30,7 +30,7 @@ public class DragonPayBaseRespDto {
 
     private BigDecimal price;
 
-    private PayData pay_data;
+    private PayData payData;
 
     public static class PayData{
         @JsonProperty("appId")

liquidnet-bus-api/liquidnet-service-dragon-api/src/main/java/com/liquidnet/service/dragon/service/IDragonOrdersService.java

@@ -10,5 +10,5 @@ import java.math.BigDecimal;
 public interface IDragonOrdersService {
     void sendRedisQueue();
 
-    ResponseDto<DragonPayBaseRespDto> alipay(DragonPayBaseReqDto dragonPayBaseReqDto);
+    ResponseDto<DragonPayBaseRespDto> dragonPay(DragonPayBaseReqDto dragonPayBaseReqDto);
 }

liquidnet-bus-config/liquidnet-config/liquidnet-service-dragon-dev.yml

@@ -23,4 +23,13 @@ liquidnet:
     sslEnabled: false
     database: dev_ln_scene
   dragon:
-    alipay-gataway-url: https://openapi.alipay.com/gateway.do
+    alipay:
+      gataway-url: https://openapi.alipay.com/gateway.do
+      notify-url: https://testpay.zhengzai.tv/alipay
+    wepay:
+      gataway-url: https://openapi.alipay.com/gateway.do
+      notify-url: https://testpay.zhengzai.tv/wepay
+      merchantId: 1551961491
+      appId: wx3498304dda39c5a1
+      parentKey: itIuO65O9yKmemOu3S8g1S4orqvCGwXK
+

liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/channel/alipay/biz/AlipayBiz.java

+package com.liquidnet.service.dragon.channel.alipay.biz;
+
+import com.liquidnet.service.base.SqlMapping;
+import com.liquidnet.service.dragon.constant.DragonConstant;
+import com.liquidnet.service.dragon.dto.DragonPayBaseReqDto;
+import com.liquidnet.service.dragon.dto.DragonPayBaseRespDto;
+import com.liquidnet.service.dragon.entity.DragonOrders;
+import com.liquidnet.service.dragon.utils.MqHandleUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.time.LocalDateTime;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: AlipayBiz
+ * @Package com.liquidnet.service.dragon.channel.alipay.biz
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2021/7/10 16:21
+ */
+@Component
+public class AlipayBiz {
+    @Autowired
+    private MqHandleUtil mqHandleUtil;
+
+    public DragonOrders buildPayOrders(DragonPayBaseReqDto dragonPayBaseReqDto, DragonPayBaseRespDto respDto){
+        DragonOrders orders = new DragonOrders();
+//        orders.setMid();
+        orders.setStatus(Integer.valueOf(DragonConstant.PayStatusEnum.STATUS_UNPAID.getCode()));
+        orders.setCode(respDto.getCode());
+        orders.setType(dragonPayBaseReqDto.getType());
+        orders.setPrice(dragonPayBaseReqDto.getPrice());
+        orders.setName(dragonPayBaseReqDto.getName());
+        orders.setDetail(dragonPayBaseReqDto.getDetail());
+        orders.setOrderCode(dragonPayBaseReqDto.getOrderCode());
+        orders.setClientIp(dragonPayBaseReqDto.getClientIp());
+        orders.setNotifyUrl(dragonPayBaseReqDto.getNotifyUrl());
+        orders.setPaymentType(DragonConstant.PayTypeEnum.PAYMENT_TYPE_APP_IAP.getCode());
+//        orders.setPaymentId();
+        orders.setPaymentAt(LocalDateTime.now());
+//        orders.setFinishedAt();
+        orders.setCreatedAt(LocalDateTime.now());
+//        orders.setUpdatedAt();
+        // 修改退款订单
+        boolean insertResult = mqHandleUtil.sendMySqlRedis(
+                SqlMapping.get("dragon_orders.insert"),
+                new Object[]{orders.getStatus(), orders.getCode(), orders.getType()
+                        , orders.getPrice(), orders.getName(), orders.getDetail()
+                        , orders.getOrderCode(), orders.getClientIp()
+                        , orders.getNotifyUrl(), orders.getPaymentType(),
+                        orders.getPaymentId(), orders.getPaymentAt()
+                        , orders.getFinishedAt(), orders.getCreatedAt()
+                        , orders.getUpdatedAt()}
+        );
+        return orders;
+    }
+}

liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/channel/alipay/strategy/impl/AlipayStrategyAppImpl.java

 package com.liquidnet.service.dragon.channel.alipay.strategy.impl;
 
+import com.liquidnet.commons.lang.util.IDGenerator;
 import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.dragon.channel.alipay.biz.AlipayBiz;
+import com.liquidnet.service.dragon.channel.alipay.req.AlipayTradePayReq;
 import com.liquidnet.service.dragon.channel.alipay.strategy.IAlipayStrategy;
 import com.liquidnet.service.dragon.channel.alipay.strategy.annotation.StrategyAlipayHandler;
+import com.liquidnet.service.dragon.channel.alipay.util.AlipayUtil;
 import com.liquidnet.service.dragon.constant.DragonConstant;
 import com.liquidnet.service.dragon.dto.DragonPayBaseReqDto;
 import com.liquidnet.service.dragon.dto.DragonPayBaseRespDto;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.stereotype.Component;
 
+import java.util.Map;
+
 /**
  * @author AnJiabin <anjiabin@zhengzai.tv>
  * @version V1.0
@@ -20,8 +29,36 @@ import org.springframework.stereotype.Component;
 @Component
 @StrategyAlipayHandler(DragonConstant.DeviceFromEnum.APP)
 public class AlipayStrategyAppImpl  implements IAlipayStrategy {
+    @Autowired
+    StringRedisTemplate stringRedisTemplate;
+
+    @Value("liquidnet.dragon.alipay.gataway-url")
+    private String alipayGatewayUrl;
+
+    @Autowired
+    private AlipayBiz alipayBiz;
+
     @Override
     public ResponseDto<DragonPayBaseRespDto> dragonPay(DragonPayBaseReqDto dragonPayBaseReqDto) {
-        return null;
+        AlipayTradePayReq alipayTradePayReq = new AlipayTradePayReq();
+        alipayTradePayReq.setProductCode("QUICK_WAP_PAY");
+        alipayTradePayReq.setTotalAmount(dragonPayBaseReqDto.getPrice());
+        alipayTradePayReq.setSubject(dragonPayBaseReqDto.getName());
+        alipayTradePayReq.setBody(dragonPayBaseReqDto.getDetail());
+        //dragon中支付编号
+        alipayTradePayReq.setOutTradeNo(IDGenerator.payCode());
+        alipayTradePayReq.setTimeExpire(dragonPayBaseReqDto.getExpireTime());
+        //调用支付
+        Map<String, Object> result = AlipayUtil.tradeWapPay(alipayTradePayReq);
+        //拼接返回参数
+        DragonPayBaseRespDto respDto = new DragonPayBaseRespDto();
+        respDto.setCode(alipayTradePayReq.getOutTradeNo());
+        respDto.setOrder_code(dragonPayBaseReqDto.getOrderCode());
+        DragonPayBaseRespDto.PayData payData = new DragonPayBaseRespDto.PayData();
+        payData.setRedirectUrl(alipayGatewayUrl + result.get("body"));
+        respDto.setPayData(payData);
+        //支付订单持久化
+        alipayBiz.buildPayOrders(dragonPayBaseReqDto,respDto);
+        return ResponseDto.success(respDto);
     }
 }

liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/channel/alipay/strategy/impl/AlipayStrategyWapImpl.java

 package com.liquidnet.service.dragon.channel.alipay.strategy.impl;
 
+import com.liquidnet.commons.lang.util.IDGenerator;
 import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.dragon.channel.alipay.biz.AlipayBiz;
+import com.liquidnet.service.dragon.channel.alipay.req.AlipayTradePayReq;
 import com.liquidnet.service.dragon.channel.alipay.strategy.IAlipayStrategy;
 import com.liquidnet.service.dragon.channel.alipay.strategy.annotation.StrategyAlipayHandler;
+import com.liquidnet.service.dragon.channel.alipay.util.AlipayUtil;
 import com.liquidnet.service.dragon.constant.DragonConstant;
 import com.liquidnet.service.dragon.dto.DragonPayBaseReqDto;
 import com.liquidnet.service.dragon.dto.DragonPayBaseRespDto;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.stereotype.Component;
+import org.springframework.stereotype.Service;
+
+import java.util.Map;
 
 /**
  * @author AnJiabin <anjiabin@zhengzai.tv>
@@ -17,11 +27,39 @@ import org.springframework.stereotype.Component;
  * @Copyright: LightNet @ Copyright (c) 2021
  * @date 2021/7/10 14:34
  */
-@Component
+@Service
 @StrategyAlipayHandler(DragonConstant.DeviceFromEnum.WAP)
 public class AlipayStrategyWapImpl  implements IAlipayStrategy {
+    @Autowired
+    StringRedisTemplate stringRedisTemplate;
+
+    @Value("${liquidnet.dragon.alipay.gataway-url}")
+    private String alipayGatewayUrl;
+
+    @Autowired
+    private AlipayBiz alipayBiz;
+
     @Override
     public ResponseDto<DragonPayBaseRespDto> dragonPay(DragonPayBaseReqDto dragonPayBaseReqDto) {
-        return null;
+        AlipayTradePayReq alipayTradePayReq = new AlipayTradePayReq();
+        alipayTradePayReq.setProductCode("QUICK_WAP_PAY");
+        alipayTradePayReq.setTotalAmount(dragonPayBaseReqDto.getPrice());
+        alipayTradePayReq.setSubject(dragonPayBaseReqDto.getName());
+        alipayTradePayReq.setBody(dragonPayBaseReqDto.getDetail());
+        //dragon中支付编号
+        alipayTradePayReq.setOutTradeNo(IDGenerator.payCode());
+        alipayTradePayReq.setTimeExpire(dragonPayBaseReqDto.getExpireTime());
+        //调用支付
+        Map<String, Object> result = AlipayUtil.tradeWapPay(alipayTradePayReq);
+        //拼接返回参数
+        DragonPayBaseRespDto respDto = new DragonPayBaseRespDto();
+        respDto.setCode(alipayTradePayReq.getOutTradeNo());
+        respDto.setOrder_code(dragonPayBaseReqDto.getOrderCode());
+        DragonPayBaseRespDto.PayData payData = new DragonPayBaseRespDto.PayData();
+        payData.setRedirectUrl(alipayGatewayUrl + "?" + result.get("body"));
+        respDto.setPayData(payData);
+        //支付订单持久化
+        alipayBiz.buildPayOrders(dragonPayBaseReqDto,respDto);
+        return ResponseDto.success(respDto);
     }
 }

liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/channel/alipay/strategy/impl/AlipayStrategyWebImpl.java

 package com.liquidnet.service.dragon.channel.alipay.strategy.impl;
 
+import com.liquidnet.commons.lang.util.IDGenerator;
 import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.dragon.channel.alipay.biz.AlipayBiz;
+import com.liquidnet.service.dragon.channel.alipay.req.AlipayTradePayReq;
 import com.liquidnet.service.dragon.channel.alipay.strategy.IAlipayStrategy;
 import com.liquidnet.service.dragon.channel.alipay.strategy.annotation.StrategyAlipayHandler;
+import com.liquidnet.service.dragon.channel.alipay.util.AlipayUtil;
 import com.liquidnet.service.dragon.constant.DragonConstant;
 import com.liquidnet.service.dragon.dto.DragonPayBaseReqDto;
 import com.liquidnet.service.dragon.dto.DragonPayBaseRespDto;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.stereotype.Component;
 
+import java.util.Map;
+
 /**
  * @author AnJiabin <anjiabin@zhengzai.tv>
  * @version V1.0
@@ -20,9 +29,36 @@ import org.springframework.stereotype.Component;
 @Component
 @StrategyAlipayHandler(DragonConstant.DeviceFromEnum.WEB)
 public class AlipayStrategyWebImpl implements IAlipayStrategy {
+    @Autowired
+    StringRedisTemplate stringRedisTemplate;
+
+    @Value("liquidnet.dragon.alipay.gataway-url")
+    private String alipayGatewayUrl;
+
+    @Autowired
+    private AlipayBiz alipayBiz;
 
     @Override
     public ResponseDto<DragonPayBaseRespDto> dragonPay(DragonPayBaseReqDto dragonPayBaseReqDto) {
-        return null;
+        AlipayTradePayReq alipayTradePayReq = new AlipayTradePayReq();
+        alipayTradePayReq.setProductCode("QUICK_WAP_PAY");
+        alipayTradePayReq.setTotalAmount(dragonPayBaseReqDto.getPrice());
+        alipayTradePayReq.setSubject(dragonPayBaseReqDto.getName());
+        alipayTradePayReq.setBody(dragonPayBaseReqDto.getDetail());
+        //dragon中支付编号
+        alipayTradePayReq.setOutTradeNo(IDGenerator.payCode());
+        alipayTradePayReq.setTimeExpire(dragonPayBaseReqDto.getExpireTime());
+        //调用支付
+        Map<String, Object> result = AlipayUtil.tradeWapPay(alipayTradePayReq);
+        //拼接返回参数
+        DragonPayBaseRespDto respDto = new DragonPayBaseRespDto();
+        respDto.setCode(alipayTradePayReq.getOutTradeNo());
+        respDto.setOrder_code(dragonPayBaseReqDto.getOrderCode());
+        DragonPayBaseRespDto.PayData payData = new DragonPayBaseRespDto.PayData();
+        payData.setRedirectUrl(alipayGatewayUrl + result.get("body"));
+        respDto.setPayData(payData);
+        //支付订单持久化
+        alipayBiz.buildPayOrders(dragonPayBaseReqDto,respDto);
+        return ResponseDto.success(respDto);
     }
 }

liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/channel/alipay/util/AlipayUtil.java

@@ -44,46 +44,6 @@ public class AlipayUtil {
 
     }
 
-    /**
-     * 支付宝支付
-     * @param alipayTradePayReq
-     * @return
-     */
-    public static Map<String, Object> tradePagePay(AlipayTradePayReq alipayTradePayReq) {
-        logger.info("AlipayUtil.tradePay-->> req : {}",alipayTradePayReq.toString());
-        String timeExpress = "5m";// 支付超时，线下扫码交易定义为5分钟
-
-        AlipayClient alipayClient = PayAlipayUtils.getHttpClient();
-
-        SortedMap<String, Object> paramMap = new TreeMap<>();
-        paramMap.put("product_code", alipayTradePayReq.getProductCode());
-        paramMap.put("total_amount", alipayTradePayReq.getTotalAmount().toString());
-        paramMap.put("subject", alipayTradePayReq.getSubject());
-        paramMap.put("body", alipayTradePayReq.getBody());
-        paramMap.put("out_trade_no", alipayTradePayReq.getOutTradeNo());
-        paramMap.put("timeout_express", timeExpress);
-
-
-        AlipayTradePagePayRequest request = new AlipayTradePagePayRequest();
-        request.setNotifyUrl("https://testpay.zhengzai.tv");
-//        request.setTimestamp(DateUtil.now());
-        logger.info("bizContent :{}",JSONObject.toJSONString(paramMap));
-        request.setBizContent(JSONObject.toJSONString(paramMap));
-        try {
-            AlipayTradePagePayResponse response = alipayClient.sdkExecute(request);
-            JSONObject responseJSON = JSONObject.parseObject(JSONObject.toJSONString(response));
-            logger.info("支付宝返回结果:{}", responseJSON);
-            return responseJSON;
-        } catch (AlipayApiException e) {
-            logger.error("支付宝支付异常:{}", e);
-            JSONObject resultJSON = new JSONObject();
-            resultJSON.put("outTradeNo", alipayTradePayReq.getOutTradeNo());
-            resultJSON.put("totalAmount", alipayTradePayReq.getTotalAmount().toString());
-            resultJSON.put("errorCode", "9999");
-            return resultJSON;
-        }
-    }
-
     /**
      * 支付宝支付
      * @param alipayTradePayReq
@@ -93,7 +53,7 @@ public class AlipayUtil {
         logger.info("AlipayUtil.tradePay-->> req : {}",alipayTradePayReq.toString());
         String timeExpress = "5m";// 支付超时，线下扫码交易定义为5分钟
 
-        AlipayClient alipayClient = PayAlipayUtils.getHttpClient();
+        AlipayClient alipayClient = PayAlipayUtils.getInstance().getHttpClient();
 
         SortedMap<String, Object> paramMap = new TreeMap<>();
         paramMap.put("product_code", alipayTradePayReq.getProductCode());
@@ -127,6 +87,7 @@ public class AlipayUtil {
         }
     }
 
+
     /**
      * 订单查询
      *

liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/channel/strategy/impl/PayChannelStrategyAlipayImpl.java

 package com.liquidnet.service.dragon.channel.strategy.impl;
 
 import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.dragon.channel.alipay.strategy.AlipayStrategyContext;
 import com.liquidnet.service.dragon.channel.strategy.IPayChannelStrategy;
 import com.liquidnet.service.dragon.channel.strategy.annotation.StrategyPayChannelHandler;
 import com.liquidnet.service.dragon.constant.DragonConstant;
 import com.liquidnet.service.dragon.dto.DragonPayBaseReqDto;
 import com.liquidnet.service.dragon.dto.DragonPayBaseRespDto;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
-import java.util.ArrayList;
-import java.util.List;
-
 /**
  * @author AnJiabin <jiabin.an@lightnet.io>
  * @version V1.0
@@ -23,9 +22,11 @@ import java.util.List;
 @Component
 @StrategyPayChannelHandler(DragonConstant.PayChannelEnum.ALIPAY)
 public class PayChannelStrategyAlipayImpl implements IPayChannelStrategy {
+    @Autowired
+    private AlipayStrategyContext alipayStrategyContext;
 
     @Override
     public ResponseDto<DragonPayBaseRespDto> dragonPay(DragonPayBaseReqDto dragonPayBaseReqDto) {
-        return null;
+        return alipayStrategyContext.getStrategy(dragonPayBaseReqDto.getDeviceFrom()).dragonPay(dragonPayBaseReqDto);
     }
 }

liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/channel/strategy/impl/PayChannelStrategyWepayImpl.java

 package com.liquidnet.service.dragon.channel.strategy.impl;
 
 import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.dragon.channel.alipay.strategy.AlipayStrategyContext;
 import com.liquidnet.service.dragon.channel.strategy.IPayChannelStrategy;
 import com.liquidnet.service.dragon.channel.strategy.annotation.StrategyPayChannelHandler;
+import com.liquidnet.service.dragon.channel.wepay.strategy.WepayStrategyContext;
 import com.liquidnet.service.dragon.constant.DragonConstant;
 import com.liquidnet.service.dragon.dto.DragonPayBaseReqDto;
 import com.liquidnet.service.dragon.dto.DragonPayBaseRespDto;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 import java.util.ArrayList;
@@ -23,9 +26,11 @@ import java.util.List;
 @Component
 @StrategyPayChannelHandler(DragonConstant.PayChannelEnum.WEPAY)
 public class PayChannelStrategyWepayImpl implements IPayChannelStrategy {
+    @Autowired
+    private WepayStrategyContext wepayStrategyContext;
 
     @Override
     public ResponseDto<DragonPayBaseRespDto> dragonPay(DragonPayBaseReqDto dragonPayBaseReqDto) {
-        return null;
+        return wepayStrategyContext.getStrategy(dragonPayBaseReqDto.getDeviceFrom()).dragonPay(dragonPayBaseReqDto);
     }
 }

liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/channel/wepay/biz/WepayBiz.java

+package com.liquidnet.service.dragon.channel.wepay.biz;
+
+import com.liquidnet.service.dragon.channel.wepay.req.WepayPrePayReq;
+import com.liquidnet.service.dragon.dto.DragonPayBaseReqDto;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: WepayBiz
+ * @Package com.liquidnet.service.dragon.channel.wepay.biz
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2021/7/10 16:46
+ */
+@Slf4j
+@Component
+public class WepayBiz {
+    public WepayPrePayReq sealWeixinPerPay(DragonPayBaseReqDto dragonPayBaseReqDto) {
+        WepayPrePayReq WepayPrePayReq = new WepayPrePayReq();
+
+//        WepayPrePayReq.setAppid(appId);
+//        WepayPrePayReq.setMchId(mchId);
+//        WepayPrePayReq.setBody(productName);// 商品描述
+//        WepayPrePayReq.setAttach(remark);// 支付备注
+//        WepayPrePayReq.setOutTradeNo(bankOrderNo);// 银行订单号
+//
+//        Integer totalFee = orderPrice.multiply(BigDecimal.valueOf(100d)).intValue();
+//        WepayPrePayReq.setTotalFee(totalFee);// 订单金额
+//        WepayPrePayReq.setTimeStart(DateUtil.parse(orderTime, "yyyyMMddHHmmss"));// 订单开始时间
+////        WepayPrePayReq.setTimeExpire(DateUtil.formatDate(DateUtil.addMinute(orderTime, orderPeriod), "yyyyMMddHHmmss"));// 订单到期时间
+//        WepayPrePayReq.setNotifyUrl(WeixinConfigUtil.readConfig("notify_url"));// 通知地址
+////        WepayPrePayReq.setTradeType("");// 交易类型
+//        WepayPrePayReq.setProductId(productId);// 商品ID
+//        WepayPrePayReq.setOpenid(openId);// 用户标识
+//        WepayPrePayReq.setSpbillCreateIp(orderIp);// 下单IP
+
+        return WepayPrePayReq;
+    }
+}

liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/channel/wepay/config/WeixinConfigUtil.java

+/*
+ * Copyright 2015-2102 RonCoo(http://www.roncoo.com) Group.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.liquidnet.service.dragon.channel.wepay.config;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+
+import java.io.IOException;
+import java.util.Properties;
+
+/**
+ * <b>功能说明:微信属性文件工具类
+ * </b>
+ * @author  Peter
+ * <a href="http://www.roncoo.com">龙果学院(www.roncoo.com)</a>
+ */
+public class WeixinConfigUtil {
+
+    private static final Log LOG = LogFactory.getLog(WeixinConfigUtil.class);
+
+    /**
+     * 通过静态代码块读取上传文件的验证格式配置文件,静态代码块只执行一次(单例)
+     */
+    private static Properties properties = new Properties();
+
+    private WeixinConfigUtil() {
+
+    }
+
+    // 通过类装载器装载进来
+    static {
+        try {
+            // 从类路径下读取属性文件
+            properties.load(WeixinConfigUtil.class.getClassLoader()
+                    .getResourceAsStream("weixinpay_config.properties"));
+        } catch (IOException e) {
+            LOG.error(e);
+        }
+    }
+
+    /**
+     * 函数功能说明 ：读取配置项 Administrator 2012-12-14 修改者名字 ： 修改日期 ： 修改内容 ：
+     *
+     * @参数：
+     * @return void
+     * @throws
+     */
+    public static String readConfig(String key) {
+        return (String) properties.get(key);
+    }
+
+    //app_id
+    public static final String appId = (String) properties.get("appId");
+
+    //商户号
+    public static final String mch_id = (String) properties.get("mch_id");
+
+    //商户秘钥
+    public static final String partnerKey = (String) properties.get("partnerKey");
+
+    //小程序支付
+    public static final String xAuthUrl = (String) properties.get("x_auth_url");
+    public static final String xGrantType = (String) properties.get("x_grant_type");
+    public static final String xAppId = (String) properties.get("x_appId");
+    public static final String xPartnerKey = (String) properties.get("x_partnerKey");
+    public static final String xPayKey = (String) properties.get("x_payKey");
+    public static final String xMchId = (String) properties.get("x_mch_id");
+    public static final String x_notify_url = (String) properties.get("x_notify_url");
+}

liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/channel/wepay/req/WepayPrePayReq.java

+/*
+ * Copyright 2015-2102 RonCoo(http://www.roncoo.com) Group.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.liquidnet.service.dragon.channel.wepay.req;
+
+import com.liquidnet.commons.lang.util.IDGenerator;
+
+import java.io.Serializable;
+
+/**
+ * <b>功能说明:微信预支付实体类</b>
+ * @author  Peter
+ * <a href="http://www.roncoo.com">龙果学院(www.roncoo.com)</a>
+ */
+public class WepayPrePayReq implements Serializable {
+
+    /** 公众账号ID 必填 **/
+    private String appid;
+
+    /** 商户号 必填 **/
+    private String mchId;
+
+    /** 设备号  终端设备号(门店号或收银设备ID)，注意：PC网页或公众号内支付请传"WEB" 默认为'WEB'**/
+    private String deviceInfo = "WEB";
+
+    /** 随机字符串 **/
+    private String nonceStr = IDGenerator.get32UUID();
+
+    /** 签名 **/
+    private String sign;
+
+    /** 商品描述 **/
+    private String body;
+
+    /** 商品详情 **/
+    private String detail;
+
+    /** 附加数据 **/
+    private String attach;
+
+    /** 商户订单号 **/
+    private String outTradeNo;
+
+    /** 货币类型 默认为人民币 **/
+    private String feeType = "CNY";
+
+    /** 总金额 **/
+    private Integer totalFee;
+
+    /** 终端IP **/
+    private String spbillCreateIp;
+
+    /** 交易起始时间 **/
+    private String timeStart;
+
+    /** 交易结束时间 **/
+    private String timeExpire;
+
+    /** 商品标记 **/
+    private String goodsTag;
+
+    /** 通知地址 **/
+    private String notifyUrl;
+
+    /** 商品ID **/
+    private String productId;
+
+    /** 制定支付方式 **/
+    private String limitPay;
+
+    /** 用户标识 **/
+    private String openid;
+
+    public String getAppid() {
+        return appid;
+    }
+
+    public void setAppid(String appid) {
+        this.appid = appid;
+    }
+
+    public String getSign() {
+        return sign;
+    }
+
+    public void setSign(String sign) {
+        this.sign = sign;
+    }
+
+    public String getBody() {
+        return body;
+    }
+
+    public void setBody(String body) {
+        this.body = body;
+    }
+
+    public String getDetail() {
+        return detail;
+    }
+
+    public void setDetail(String detail) {
+        this.detail = detail;
+    }
+
+    public String getAttach() {
+        return attach;
+    }
+
+    public void setAttach(String attach) {
+        this.attach = attach;
+    }
+
+
+    public String getOpenid() {
+        return openid;
+    }
+
+    public void setOpenid(String openid) {
+        this.openid = openid;
+    }
+
+    public String getMchId() {
+        return mchId;
+    }
+
+    public void setMchId(String mchId) {
+        this.mchId = mchId;
+    }
+
+    public String getDeviceInfo() {
+        return deviceInfo;
+    }
+
+    public void setDeviceInfo(String deviceInfo) {
+        this.deviceInfo = deviceInfo;
+    }
+
+    public String getNonceStr() {
+        return nonceStr;
+    }
+
+    public void setNonceStr(String nonceStr) {
+        this.nonceStr = nonceStr;
+    }
+
+    public String getOutTradeNo() {
+        return outTradeNo;
+    }
+
+    public void setOutTradeNo(String outTradeNo) {
+        this.outTradeNo = outTradeNo;
+    }
+
+    public String getFeeType() {
+        return feeType;
+    }
+
+    public void setFeeType(String feeType) {
+        this.feeType = feeType;
+    }
+
+    public Integer getTotalFee() {
+        return totalFee;
+    }
+
+    public void setTotalFee(Integer totalFee) {
+        this.totalFee = totalFee;
+    }
+
+    public String getSpbillCreateIp() {
+        return spbillCreateIp;
+    }
+
+    public void setSpbillCreateIp(String spbillCreateIp) {
+        this.spbillCreateIp = spbillCreateIp;
+    }
+
+    public String getTimeStart() {
+        return timeStart;
+    }
+
+    public void setTimeStart(String timeStart) {
+        this.timeStart = timeStart;
+    }
+
+    public String getTimeExpire() {
+        return timeExpire;
+    }
+
+    public void setTimeExpire(String timeExpire) {
+        this.timeExpire = timeExpire;
+    }
+
+    public String getGoodsTag() {
+        return goodsTag;
+    }
+
+    public void setGoodsTag(String goodsTag) {
+        this.goodsTag = goodsTag;
+    }
+
+    public String getNotifyUrl() {
+        return notifyUrl;
+    }
+
+    public void setNotifyUrl(String notifyUrl) {
+        this.notifyUrl = notifyUrl;
+    }
+
+    public String getProductId() {
+        return productId;
+    }
+
+    public void setProductId(String productId) {
+        this.productId = productId;
+    }
+
+    public String getLimitPay() {
+        return limitPay;
+    }
+
+    public void setLimitPay(String limitPay) {
+        this.limitPay = limitPay;
+    }
+}

liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/channel/wepay/strategy/IWepayStrategy.java

+package com.liquidnet.service.dragon.channel.wepay.strategy;
+
+import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.dragon.dto.DragonPayBaseReqDto;
+import com.liquidnet.service.dragon.dto.DragonPayBaseRespDto;
+
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: Test
+ * @Package com.liquidnet.service.dragon.channel.strategy
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2021/7/10 14:27
+ */
+public interface IWepayStrategy {
+    ResponseDto<DragonPayBaseRespDto> dragonPay(DragonPayBaseReqDto dragonPayBaseReqDto);
+}

liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/channel/wepay/strategy/WepayStrategyContext.java

+package com.liquidnet.service.dragon.channel.wepay.strategy;
+
+import org.springframework.stereotype.Component;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: Test
+ * @Package com.liquidnet.service.dragon.channel.strategy
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2021/7/10 14:27
+ */
+@Component
+public class WepayStrategyContext {
+    private final Map<String, IWepayStrategy> handlerMap = new HashMap<>();
+
+    public IWepayStrategy getStrategy(String type) {
+        return handlerMap.get(type);
+    }
+
+    public void putStrategy(String code, IWepayStrategy strategy) {
+        handlerMap.put(code, strategy);
+    }
+}

liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/channel/wepay/strategy/WepayStrategyListener.java

+package com.liquidnet.service.dragon.channel.wepay.strategy;
+
+import com.liquidnet.service.dragon.channel.wepay.strategy.annotation.StrategyWepayHandler;
+import org.springframework.context.ApplicationListener;
+import org.springframework.context.event.ContextRefreshedEvent;
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: Test
+ * @Package com.liquidnet.service.dragon.channel.strategy
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2021/7/10 14:27
+ */
+@Component
+public class WepayStrategyListener implements ApplicationListener<ContextRefreshedEvent> {
+
+    @Override
+    public void onApplicationEvent(ContextRefreshedEvent event) {
+        Map<String, Object> beans = event.getApplicationContext().getBeansWithAnnotation(StrategyWepayHandler.class);
+        WepayStrategyContext strategyContext = event.getApplicationContext().getBean(WepayStrategyContext.class);
+        beans.forEach((name, bean) -> {
+            StrategyWepayHandler typeHandler = bean.getClass().getAnnotation(StrategyWepayHandler.class);
+            strategyContext.putStrategy(typeHandler.value().getCode(), (IWepayStrategy) bean);
+        });
+    }
+}
\ No newline at end of file

liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/channel/wepay/strategy/annotation/StrategyWepayHandler.java

+package com.liquidnet.service.dragon.channel.wepay.strategy.annotation;
+
+import com.liquidnet.service.dragon.constant.DragonConstant;
+
+import java.lang.annotation.*;
+
+/**
+ * @author AnJiabin <jiabin.an@lightnet.io>
+ * @version V1.0
+ * @Description: TODO
+ * @class: StrategyGetFundDataHandler
+ * @Package com.liquidnet.service.reconciliation.strategy.annotation
+ * @Copyright: LightNet @ Copyright (c) 2020
+ * @date 2020/10/27 15:29
+ */
+@Documented
+@Inherited
+@Target(ElementType.TYPE)
+@Retention(RetentionPolicy.RUNTIME)
+public @interface StrategyWepayHandler {
+    DragonConstant.DeviceFromEnum value();
+}

liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/channel/wepay/strategy/impl/AbstractWepayStrategy.java

+package com.liquidnet.service.dragon.channel.wepay.strategy.impl;
+
+import com.liquidnet.service.base.ResponseDto;
+import com.liquidnet.service.dragon.channel.wepay.strategy.IWepayStrategy;
+import com.liquidnet.service.dragon.channel.wepay.util.WepayUtil;
+import com.liquidnet.service.dragon.dto.DragonPayBaseReqDto;
+import com.liquidnet.service.dragon.dto.DragonPayBaseRespDto;
+import com.liquidnet.service.dragon.utils.PayWepayUtils;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.http.HttpEntity;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.util.EntityUtils;
+import org.springframework.beans.factory.annotation.Value;
+
+import java.util.SortedMap;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: AbstractWepayStrategy
+ * @Package com.liquidnet.service.dragon.channel.wepay.strategy.impl
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2021/7/11 11:56
+ */
+@Slf4j
+public abstract class AbstractWepayStrategy implements IWepayStrategy {
+    @Value("${liquidnet.dragon.wepay.parentKey}")
+    private String parentKey;
+
+    @Override
+    public ResponseDto<DragonPayBaseRespDto> dragonPay(DragonPayBaseReqDto dragonPayBaseReqDto) {
+
+        try {
+            //构造请求参数
+            SortedMap<String, Object> parameters = this.buildRequestParamMap(dragonPayBaseReqDto);
+            //生成签名
+            String sign = WepayUtil.getSign(parameters,parentKey);
+            parameters.put("sign", sign);
+            //构造支付请求xml
+            String data = WepayUtil.mapToXml(parameters);
+
+            HttpPost httpost = new HttpPost(this.getRequestUrl());
+            httpost.setEntity(new StringEntity(data, "UTF-8"));
+            CloseableHttpResponse response = PayWepayUtils.getInstance().getHttpClient().execute(httpost);
+            HttpEntity entity = response.getEntity();
+            //接受到返回信息
+            String jsonStr = EntityUtils.toString(response.getEntity(), "UTF-8");
+            EntityUtils.consume(entity);
+            log.info("dragonPay:wepay:wap response json: {} ",jsonStr);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return null;
+    }
+
+    /**
+     * 构造请求参数
+     * @return
+     */
+    abstract SortedMap<String, Object> buildRequestParamMap(DragonPayBaseReqDto dragonPayBaseReqDto);
+
+    /**
+     * 构造返回参数
+     */
+    abstract DragonPayBaseRespDto buildResponseDto();
+
+    protected abstract String getRequestUrl();
+}

liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/channel/wepay/strategy/impl/WepayStrategyAppImpl.java

+package com.liquidnet.service.dragon.channel.wepay.strategy.impl;
+
+import com.liquidnet.service.dragon.channel.wepay.strategy.annotation.StrategyWepayHandler;
+import com.liquidnet.service.dragon.constant.DragonConstant;
+import com.liquidnet.service.dragon.dto.DragonPayBaseReqDto;
+import com.liquidnet.service.dragon.dto.DragonPayBaseRespDto;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import java.util.SortedMap;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: AlipayStrategyWapImpl
+ * @Package com.liquidnet.service.dragon.channel.alipay.strategy.impl
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2021/7/10 14:34
+ */
+@Slf4j
+@Component
+@StrategyWepayHandler(DragonConstant.DeviceFromEnum.APP)
+public class WepayStrategyAppImpl extends AbstractWepayStrategy {
+
+    @Override
+    SortedMap<String, Object> buildRequestParamMap(DragonPayBaseReqDto dragonPayBaseReqDto) {
+        return null;
+    }
+
+    @Override
+    DragonPayBaseRespDto buildResponseDto() {
+        return null;
+    }
+
+    @Override
+    protected String getRequestUrl() {
+        return null;
+    }
+
+}

liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/channel/wepay/strategy/impl/WepayStrategyJsImpl.java

+package com.liquidnet.service.dragon.channel.wepay.strategy.impl;
+
+import com.liquidnet.service.dragon.channel.wepay.strategy.annotation.StrategyWepayHandler;
+import com.liquidnet.service.dragon.constant.DragonConstant;
+import com.liquidnet.service.dragon.dto.DragonPayBaseReqDto;
+import com.liquidnet.service.dragon.dto.DragonPayBaseRespDto;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import java.util.SortedMap;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: AlipayStrategyWapImpl
+ * @Package com.liquidnet.service.dragon.channel.alipay.strategy.impl
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2021/7/10 14:34
+ */
+@Slf4j
+@Component
+@StrategyWepayHandler(DragonConstant.DeviceFromEnum.JS)
+public class WepayStrategyJsImpl extends AbstractWepayStrategy{
+
+    @Override
+    SortedMap<String, Object> buildRequestParamMap(DragonPayBaseReqDto dragonPayBaseReqDto) {
+        return null;
+    }
+
+    @Override
+    DragonPayBaseRespDto buildResponseDto() {
+        return null;
+    }
+
+    @Override
+    protected String getRequestUrl() {
+        return null;
+    }
+
+}

liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/channel/wepay/strategy/impl/WepayStrategyWapImpl.java

+package com.liquidnet.service.dragon.channel.wepay.strategy.impl;
+
+import com.liquidnet.commons.lang.util.IDGenerator;
+import com.liquidnet.service.dragon.channel.wepay.strategy.annotation.StrategyWepayHandler;
+import com.liquidnet.service.dragon.constant.DragonConstant;
+import com.liquidnet.service.dragon.dto.DragonPayBaseReqDto;
+import com.liquidnet.service.dragon.dto.DragonPayBaseRespDto;
+import com.liquidnet.service.dragon.utils.PayWepayUtils;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import java.math.BigDecimal;
+import java.util.SortedMap;
+import java.util.TreeMap;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: AlipayStrategyWapImpl
+ * @Package com.liquidnet.service.dragon.channel.alipay.strategy.impl
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2021/7/10 14:34
+ */
+@Slf4j
+@Component
+@StrategyWepayHandler(DragonConstant.DeviceFromEnum.WAP)
+public class WepayStrategyWapImpl extends AbstractWepayStrategy{
+
+    @Override
+    SortedMap<String, Object> buildRequestParamMap(DragonPayBaseReqDto dragonPayBaseReqDto) {
+        String nonceStr = PayWepayUtils.getInstance().getNonceStr();
+        SortedMap<String, Object> parameters = new TreeMap<>();
+        parameters.put("mch_id", PayWepayUtils.getInstance().getMerchantId());
+        parameters.put("appid", PayWepayUtils.getInstance().getAppId());
+        parameters.put("nonce_str", nonceStr);
+        parameters.put("spbill_create_ip", dragonPayBaseReqDto.getClientIp());
+        parameters.put("total_fee", dragonPayBaseReqDto.getPrice().multiply(BigDecimal.valueOf(100L)).intValue());
+        parameters.put("body", dragonPayBaseReqDto.getName());
+        parameters.put("detail", dragonPayBaseReqDto.getDetail());
+        parameters.put("out_trade_no", IDGenerator.payCode());
+        parameters.put("time_expire", "20210908103456");
+        parameters.put("notify_url", "https://www.baidu.com");
+        parameters.put("trade_type", "MWEB");
+        return parameters;
+    }
+
+    @Override
+    DragonPayBaseRespDto buildResponseDto() {
+        return null;
+    }
+
+    @Override
+    protected String getRequestUrl() {
+        return "https://api.mch.weixin.qq.com/pay/unifiedorder";
+    }
+}

liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/channel/wepay/util/MD5Util.java

+/*
+ * Copyright 2015-2102 RonCoo(http://www.roncoo.com) Group.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.liquidnet.service.dragon.channel.wepay.util;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.security.MessageDigest;
+
+/**
+ * <b>功能说明:MD5签名工具类
+ * </b>
+ * @author  Peter
+ * <a href="http://www.roncoo.com">龙果学院(www.roncoo.com)</a>
+ */
+public class MD5Util {
+
+    private static final Logger LOG = LoggerFactory.getLogger(MD5Util.class);
+
+    /**
+     * 私有构造方法,将该工具类设为单例模式.
+     */
+    private MD5Util() {
+    }
+
+    private static final String[] hex = { "0", "1", "2", "3", "4", "5", "6", "7", "8", "9", "a", "b", "c", "d", "e", "f" };
+
+    public static String encode(String password) {
+        try {
+            MessageDigest md5 = MessageDigest.getInstance("MD5");
+            byte[] byteArray = md5.digest(password.getBytes("utf-8"));
+            String passwordMD5 = byteArrayToHexString(byteArray);
+            return passwordMD5;
+        } catch (Exception e) {
+            LOG.error(e.toString());
+        }
+        return password;
+    }
+
+    private static String byteArrayToHexString(byte[] byteArray) {
+        StringBuffer sb = new StringBuffer();
+        for (byte b : byteArray) {
+            sb.append(byteToHexChar(b));
+        }
+        return sb.toString();
+    }
+
+    private static Object byteToHexChar(byte b) {
+        int n = b;
+        if (n < 0) {
+            n = 256 + n;
+        }
+        int d1 = n / 16;
+        int d2 = n % 16;
+        return hex[d1] + hex[d2];
+    }
+}

liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/service/impl/DragonOrdersServiceImpl.java

 package com.liquidnet.service.dragon.service.impl;
 
-import com.liquidnet.commons.lang.util.IDGenerator;
 import com.liquidnet.service.base.ResponseDto;
-import com.liquidnet.service.base.SqlMapping;
-import com.liquidnet.service.dragon.channel.alipay.req.AlipayTradePayReq;
-import com.liquidnet.service.dragon.channel.alipay.util.AlipayUtil;
-import com.liquidnet.service.dragon.constant.DragonConstant;
+import com.liquidnet.service.dragon.channel.strategy.PayChannelStrategyContext;
 import com.liquidnet.service.dragon.dto.DragonPayBaseReqDto;
 import com.liquidnet.service.dragon.dto.DragonPayBaseRespDto;
-import com.liquidnet.service.dragon.entity.DragonOrders;
 import com.liquidnet.service.dragon.service.IDragonOrdersService;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
 import org.springframework.data.redis.connection.stream.MapRecord;
 import org.springframework.data.redis.connection.stream.StreamRecords;
 import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.stereotype.Service;
 
-import java.time.LocalDateTime;
 import java.util.HashMap;
-import java.util.LinkedList;
-import java.util.Map;
 
+@Slf4j
 @Service
 public class DragonOrdersServiceImpl implements IDragonOrdersService {
     @Autowired
     StringRedisTemplate stringRedisTemplate;
-    @Value("liquidnet.dragon.alipay-gataway-url")
-    private String alipayGatewayUrl;
+
+    @Autowired
+    private PayChannelStrategyContext payChannelStrategyContext;
 
     @Override
     public void sendRedisQueue() {
@@ -42,81 +36,7 @@ public class DragonOrdersServiceImpl implements IDragonOrdersService {
     }
 
     @Override
-    public ResponseDto<DragonPayBaseRespDto> alipay(DragonPayBaseReqDto dragonPayBaseReqDto) {
-        AlipayTradePayReq alipayTradePayReq = new AlipayTradePayReq();
-        alipayTradePayReq.setProductCode("QUICK_WAP_PAY");
-        alipayTradePayReq.setTotalAmount(dragonPayBaseReqDto.getPrice());
-        alipayTradePayReq.setSubject(dragonPayBaseReqDto.getName());
-        alipayTradePayReq.setBody(dragonPayBaseReqDto.getDetail());
-        //dragon中支付编号
-        alipayTradePayReq.setOutTradeNo(IDGenerator.payCode());
-        alipayTradePayReq.setTimeExpire(dragonPayBaseReqDto.getExpireTime());
-        Map<String, Object> result = AlipayUtil.tradeWapPay(alipayTradePayReq);
-        DragonPayBaseRespDto respDto = new DragonPayBaseRespDto();
-        respDto.setCode(alipayTradePayReq.getOutTradeNo());
-        respDto.setOrder_code(dragonPayBaseReqDto.getOrderCode());
-        DragonPayBaseRespDto.PayData payData = new DragonPayBaseRespDto.PayData();
-        payData.setRedirectUrl(alipayGatewayUrl + result.get("body"));
-        respDto.setPay_data(payData);
-        //支付订单持久化
-        this.buildPayOrders(dragonPayBaseReqDto,respDto);
-        return ResponseDto.success(respDto);
-    }
-
-    private DragonOrders buildPayOrders(DragonPayBaseReqDto dragonPayBaseReqDto,DragonPayBaseRespDto respDto){
-        DragonOrders orders = new DragonOrders();
-//        orders.setMid();
-        orders.setStatus(Integer.valueOf(DragonConstant.PayStatusEnum.STATUS_UNPAID.getCode()));
-        orders.setCode(respDto.getCode());
-        orders.setType(dragonPayBaseReqDto.getType());
-        orders.setPrice(dragonPayBaseReqDto.getPrice());
-        orders.setName(dragonPayBaseReqDto.getName());
-        orders.setDetail(dragonPayBaseReqDto.getDetail());
-        orders.setOrderCode(dragonPayBaseReqDto.getOrderCode());
-        orders.setClientIp(dragonPayBaseReqDto.getClientIp());
-        orders.setNotifyUrl(dragonPayBaseReqDto.getNotifyUrl());
-        orders.setPaymentType(DragonConstant.PayTypeEnum.PAYMENT_TYPE_APP_IAP.getCode());
-//        orders.setPaymentId();
-        orders.setPaymentAt(LocalDateTime.now());
-//        orders.setFinishedAt();
-        orders.setCreatedAt(LocalDateTime.now());
-//        orders.setUpdatedAt();
-        // 修改退款订单
-        boolean insertResult = sendMySqlRedis(
-                SqlMapping.get("dragon_orders.insert"),
-                new Object[]{orders.getStatus(), orders.getCode(), orders.getType()
-                        , orders.getPrice(), orders.getName(), orders.getDetail()
-                        , orders.getOrderCode(), orders.getClientIp()
-                        , orders.getNotifyUrl(), orders.getPaymentType(),
-                        orders.getPaymentId(), orders.getPaymentAt()
-                        , orders.getFinishedAt(), orders.getCreatedAt()
-                        , orders.getUpdatedAt()}
-        );
-        return orders;
-    }
-    /**
-     * 给 REDIS 队列发送消息 数据库相关
-     *
-     * @param sql  sql语句
-     * @param data 需要操作的数据
-     * @return
-     */
-    private boolean sendMySqlRedis(String sql, Object[] data) {
-        try {
-            LinkedList<String> sqls = new LinkedList<>();
-            sqls.add(sql);
-            LinkedList<Object[]> sqlsData = new LinkedList();
-            sqlsData.add(data);
-            String sqlData = SqlMapping.gets(sqls, sqlsData);
-
-            HashMap<String, String> map = new HashMap<>();
-            map.put("message", sqlData);
-            MapRecord<String, String, String> record = StreamRecords.mapBacked(map).withStreamKey(DragonConstant.MysqlRedisQueueEnum.DRAGON_PAY_KEY.getCode());
-            stringRedisTemplate.opsForStream().add(record);
-            return true;
-        } catch (Exception e) {
-            e.printStackTrace();
-            return false;
-        }
+    public ResponseDto<DragonPayBaseRespDto> dragonPay(DragonPayBaseReqDto dragonPayBaseReqDto) {
+        return payChannelStrategyContext.getStrategy(dragonPayBaseReqDto.getPayType()).dragonPay(dragonPayBaseReqDto);
     }
 }

liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/utils/MqHandleUtil.java

+package com.liquidnet.service.dragon.utils;
+
+import com.liquidnet.service.base.SqlMapping;
+import com.liquidnet.service.dragon.constant.DragonConstant;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.connection.stream.MapRecord;
+import org.springframework.data.redis.connection.stream.StreamRecords;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.stereotype.Component;
+
+import java.util.HashMap;
+import java.util.LinkedList;
+
+/**
+ * @author AnJiabin <anjiabin@zhengzai.tv>
+ * @version V1.0
+ * @Description: TODO
+ * @class: MqHandleUtil
+ * @Package com.liquidnet.service.dragon.utils
+ * @Copyright: LightNet @ Copyright (c) 2021
+ * @date 2021/7/10 16:23
+ */
+@Component
+public class MqHandleUtil {
+    @Autowired
+    StringRedisTemplate stringRedisTemplate;
+    /**
+     * 给 REDIS 队列发送消息 数据库相关
+     *
+     * @param sql  sql语句
+     * @param data 需要操作的数据
+     * @return
+     */
+    public boolean sendMySqlRedis(String sql, Object[] data) {
+        try {
+            LinkedList<String> sqls = new LinkedList<>();
+            sqls.add(sql);
+            LinkedList<Object[]> sqlsData = new LinkedList();
+            sqlsData.add(data);
+            String sqlData = SqlMapping.gets(sqls, sqlsData);
+
+            HashMap<String, String> map = new HashMap<>();
+            map.put("message", sqlData);
+            MapRecord<String, String, String> record = StreamRecords.mapBacked(map).withStreamKey(DragonConstant.MysqlRedisQueueEnum.DRAGON_PAY_KEY.getCode());
+            stringRedisTemplate.opsForStream().add(record);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+}