Commit 6e8ce87b by 查志伟

Merge branch 'feature/订单宝快餐点餐支持取消订单' into qa

parents 33ca3974 94cc2d1b
...@@ -12,6 +12,7 @@ import cn.freemud.service.impl.PayServiceImpl; ...@@ -12,6 +12,7 @@ import cn.freemud.service.impl.PayServiceImpl;
import cn.freemud.utils.ResponseUtil; import cn.freemud.utils.ResponseUtil;
import com.freemud.application.sdk.api.log.ApiAnnotation; import com.freemud.application.sdk.api.log.ApiAnnotation;
import com.freemud.application.sdk.api.log.LogParams; import com.freemud.application.sdk.api.log.LogParams;
import com.freemud.application.sdk.api.ordercenter.request.OrderExtInfoDto;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import org.springframework.validation.annotation.Validated; import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.PostMapping;
...@@ -112,6 +113,8 @@ public class ExposureOrderController { ...@@ -112,6 +113,8 @@ public class ExposureOrderController {
/** /**
* 公共支付接口查询mq,死信队列 * 公共支付接口查询mq,死信队列
* 支付回调的url必须在订单ext里的payCallbackUrl属性
* @see OrderExtInfoDto#getPayCallbackUrl()
*/ */
@ApiAnnotation(logMessage = "支付结果查询mq-(会员,点餐下单公共),死信队列") @ApiAnnotation(logMessage = "支付结果查询mq-(会员,点餐下单公共),死信队列")
@PostMapping("/payQueryMq") @PostMapping("/payQueryMq")
......
...@@ -134,15 +134,13 @@ public class OrderQueueService { ...@@ -134,15 +134,13 @@ public class OrderQueueService {
public void putPayQueryDelMq(PaymentMqMessageDto dto) { public void putPayQueryDelMq(PaymentMqMessageDto dto) {
MQMessage<PaymentMqMessageDto> mqMessage = new MQMessage<PaymentMqMessageDto>(); MQMessage<PaymentMqMessageDto> mqMessage = new MQMessage<PaymentMqMessageDto>();
mqMessage.setBody(dto); mqMessage.setBody(dto);
Integer ttl = 20 * 1000;
Header header = new Header(); Header header = new Header();
header.setKey("1"); header.setKey("1");
mqMessage.setHeader(header); mqMessage.setHeader(header);
byte[] notifyMsgBytes = JSON.toJSONString(mqMessage).getBytes(); byte[] notifyMsgBytes = JSON.toJSONString(mqMessage).getBytes();
MessageProperties messageProperties = new MessageProperties(); MessageProperties messageProperties = new MessageProperties();
messageProperties.setExpiration(ttl.toString()); messageProperties.setExpiration("5000"); //5秒
messageProperties.setContentType(MessageProperties.CONTENT_TYPE_JSON); messageProperties.setContentType(MessageProperties.CONTENT_TYPE_JSON);
Message delmessage = new Message(notifyMsgBytes, messageProperties); mqService.convertAndSend(TopicExchangeConfig.EXCHANGE_NAME, DlPayQueryMqConfig.KGD_PAY_QUERY_DL_KEY, new Message(notifyMsgBytes, messageProperties));
mqService.convertAndSend(TopicExchangeConfig.EXCHANGE_NAME, DlPayQueryMqConfig.KGD_PAY_QUERY_DL_KEY, delmessage);
} }
} }
...@@ -337,7 +337,7 @@ public class SaasOrderMangerServiceImpl implements OrderManagerService { ...@@ -337,7 +337,7 @@ public class SaasOrderMangerServiceImpl implements OrderManagerService {
return ResponseUtil.success(); return ResponseUtil.success();
} }
List<Integer> newOrderStatusList = Arrays.asList(OrderStatusV1.RECEIPT.getV2Code(), OrderStatusV1.COMPLETE.getV2Code(), OrderStatusV1.COMPLETE_MAKE.getV2Code()); List<Integer> newOrderStatusList = Arrays.asList(OrderStatusV1.RECEIPT.getV2Code(), OrderStatusV1.COMPLETE.getV2Code(), OrderStatusV1.COMPLETE_MAKE.getV2Code());
List<String> sourceList = Arrays.asList(OrderSourceV1.SAAS.getCode(), OrderSourceV1.ALIPAY.getCode(), OrderSourceV1.APP.getCode()); List<String> sourceList = Arrays.asList(OrderSourceV1.SAAS.getCode(), OrderSourceV1.ALIPAY.getCode(), OrderSourceV1.ALAPOS.getCode());
if (sourceList.contains(orderBean.getSource()) && newOrderStatusList.contains(orderBean.getStatusV2())) { if (sourceList.contains(orderBean.getSource()) && newOrderStatusList.contains(orderBean.getStatusV2())) {
return cancelDeliveryAndOrder(request, orderBean); return cancelDeliveryAndOrder(request, orderBean);
} else if (OrderSourceV1.MEAL.getCode().equals(orderBean.getSource())) { } else if (OrderSourceV1.MEAL.getCode().equals(orderBean.getSource())) {
......
...@@ -35,6 +35,7 @@ public enum OrderSourceV1 { ...@@ -35,6 +35,7 @@ public enum OrderSourceV1 {
// BEAUTIFUL("beautiful","美业", 28), // BEAUTIFUL("beautiful","美业", 28),
ASSISTANT("assistant","非码小助手", 29), ASSISTANT("assistant","非码小助手", 29),
SHERPAS("sherpas","食派士", 30), SHERPAS("sherpas","食派士", 30),
ALAPOS("alapos","订单宝", 38),
parkingmanual("parkingmanual", "农工商停车手工录单", 98), parkingmanual("parkingmanual", "农工商停车手工录单", 98),
PARKING("parking", "农工商停车", 99), PARKING("parking", "农工商停车", 99),
; ;
......
...@@ -210,11 +210,10 @@ public class OrderExtInfoDto { ...@@ -210,11 +210,10 @@ public class OrderExtInfoDto {
private String saleCouponPhone; private String saleCouponPhone;
/** /**
* 【华莱士】【订单C端记录不分账的卡面编号】不让走分账,卡面编号--11840,11845,11846,11853,11854,11855,11857,11858,11859,11860,11861,11862,11863,11864,11865,11866,11906 * 支付成功回调通知url
* * 记录在ext中, 支付成功补偿任务中会取
* 1 表示不分账 ,其他情况 不传值 给基础服务
*/ */
// private Integer unDistribution; private String payCallbackUrl;
/** /**
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment