8.7 部署-3

pay-mall-app/src/main/resources/application-dev.yml

@@ -17,6 +17,7 @@ app:
       chanel: c01
   rpc:
     mode: DUBBO
+
 # 线程池配置
 thread:
   pool:

pay-mall-app/src/main/resources/application-prod.yml

@@ -11,9 +11,23 @@ app:
       api-url: http://group-buying-sys:8091
       # 回调给自己，通常要是公网可访问的域名或网关地址
       # 如果 pay-mall 服务外部也同 host:8092，可以写：
-      notify-url: http://124.71.159.195:8092/api/v1/alipay/group_buy_notify
+      notify-url: http://group-buying-sys/api/v1/alipay/group_buy_notify
+      notify-type: MQ
       source: s01
-      chanel: c01
+      channel: c01
+  rpc:
+    mode: DUBBO
+
+# 线程池配置
+thread:
+  pool:
+    executor:
+      config:
+        core-pool-size: 20
+        max-pool-size: 50
+        keep-alive-time: 5000
+        block-queue-size: 5000
+        policy: CallerRunsPolicy
 
 spring:
   datasource:

pay-mall-infrastructure/pom.xml

@@ -52,6 +52,10 @@
             <groupId>org.apache.dubbo</groupId>
             <artifactId>dubbo-registry-nacos</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-configuration-processor</artifactId>
+        </dependency>
         <!-- 系统模块 -->
         <dependency>
             <groupId>edu.whut</groupId>

pay-mall-infrastructure/src/main/java/edu/whut/infrastructure/adapter/port/ProductPort.java

@@ -36,8 +36,8 @@ public class ProductPort implements IProductPort {
     /* -------------------- 公共配置 -------------------- */
     @Value("${app.config.group-buy-market.source}")
     private String source;
-    @Value("${app.config.group-buy-market.chanel}")
+    @Value("${app.config.group-buy-market.channel}")
-    private String chanel;
+    private String channel;
     @Value("${app.config.group-buy-market.notify-url}")
     private String notifyUrl;
     @Value("${app.config.group-buy-market.notify-type}")
@@ -97,7 +97,7 @@ public class ProductPort implements IProductPort {
     public void settlementMarketPayOrder(String userId, String orderId, Date orderTime) {
         SettlementMarketPayOrderRequestDTO req = new SettlementMarketPayOrderRequestDTO();
         req.setSource(source);
-        req.setChannel(chanel);
+        req.setChannel(channel);
         req.setUserId(userId);
         req.setOutTradeNo(orderId);
         req.setOutTradeTime(orderTime);
@@ -111,7 +111,7 @@ public class ProductPort implements IProductPort {
     public void refundMarketPayOrder(String userId, String orderId) {
         RefundMarketPayOrderRequestDTO req = new RefundMarketPayOrderRequestDTO();
         req.setSource(source);
-        req.setChannel(chanel);
+        req.setChannel(channel);
         req.setUserId(userId);
         req.setOutTradeNo(orderId);
         invoke("refundMarketPayOrder", req);
@@ -202,7 +202,7 @@ public class ProductPort implements IProductPort {
         dto.setGoodsId(goodsId);
         dto.setActivityId(activityId);
         dto.setSource(source);
-        dto.setChannel(chanel);
+        dto.setChannel(channel);
         dto.setOutTradeNo(orderId);
         if ("HTTP".equalsIgnoreCase(notifyType)) {
             dto.setNotifyUrl(notifyUrl);

pay-mall-trigger/src/main/java/edu/whut/trigger/http/AliPayController.java

@@ -72,7 +72,7 @@ public class AliPayController implements IPayService {
                     .data(payOrderEntity.getPayUrl())
                     .build();
         } catch (Exception e) {
-            log.error("商品下单，根据商品ID创建支付单失败 userId:{} productId:{}", createPayRequestDTO.getUserId(), createPayRequestDTO.getUserId(), e);
+            log.error("商品下单，根据商品ID创建支付单失败 userId:{} productId:{}", createPayRequestDTO.getUserId(), createPayRequestDTO.getProductId(), e);
             return Response.<String>builder()
                     .code(Constants.ResponseCode.UN_ERROR.getCode())
                     .info(Constants.ResponseCode.UN_ERROR.getInfo())