支付补偿查询延时时间修改

order-application-service/src/main/java/cn/freemud/controller/ExposureOrderController.java

@@ -12,6 +12,7 @@ import cn.freemud.service.impl.PayServiceImpl;
 import cn.freemud.utils.ResponseUtil;
 import com.freemud.application.sdk.api.log.ApiAnnotation;
 import com.freemud.application.sdk.api.log.LogParams;
+import com.freemud.application.sdk.api.ordercenter.request.OrderExtInfoDto;
 import lombok.RequiredArgsConstructor;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -112,6 +113,8 @@ public class ExposureOrderController {
 
     /**
      * 公共支付接口查询mq,死信队列
+     * 支付回调的url必须在订单ext里的payCallbackUrl属性
+     * @see OrderExtInfoDto#getPayCallbackUrl()
      */
     @ApiAnnotation(logMessage = "支付结果查询mq-(会员，点餐下单公共),死信队列")
     @PostMapping("/payQueryMq")

order-application-service/src/main/java/cn/freemud/service/impl/OrderQueueService.java

@@ -134,15 +134,13 @@ public class OrderQueueService {
     public void putPayQueryDelMq(PaymentMqMessageDto dto) {
         MQMessage<PaymentMqMessageDto> mqMessage = new MQMessage<PaymentMqMessageDto>();
         mqMessage.setBody(dto);
-        Integer ttl = 20 * 1000;
         Header header = new Header();
         header.setKey("1");
         mqMessage.setHeader(header);
         byte[] notifyMsgBytes = JSON.toJSONString(mqMessage).getBytes();
         MessageProperties messageProperties = new MessageProperties();
-        messageProperties.setExpiration(ttl.toString());
+        messageProperties.setExpiration("5000"); //5秒
         messageProperties.setContentType(MessageProperties.CONTENT_TYPE_JSON);
-        Message delmessage = new Message(notifyMsgBytes, messageProperties);
-        mqService.convertAndSend(TopicExchangeConfig.EXCHANGE_NAME, DlPayQueryMqConfig.KGD_PAY_QUERY_DL_KEY, delmessage);
+        mqService.convertAndSend(TopicExchangeConfig.EXCHANGE_NAME, DlPayQueryMqConfig.KGD_PAY_QUERY_DL_KEY, new Message(notifyMsgBytes, messageProperties));
     }
 }

ordercenter-sdk/src/main/java/com/freemud/application/sdk/api/ordercenter/request/OrderExtInfoDto.java

@@ -210,11 +210,10 @@ public class OrderExtInfoDto {
     private String saleCouponPhone;
 
     /**
-     * 【华莱士】【订单C端记录不分账的卡面编号】不让走分账，卡面编号--11840，11845，11846，11853，11854，11855，11857，11858，11859，11860，11861，11862，11863，11864，11865，11866，11906
-     *
-     *  1 表示不分账 ,其他情况 不传值 给基础服务
+     * 支付成功回调通知url
+     * 记录在ext中， 支付成功补偿任务中会取
      */
-//    private Integer unDistribution;
+    private String payCallbackUrl;
 
 
     /**