huangyujie
/
qihang-ecom-erp-open
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

完善OMS消息通知

This commit is contained in:
Richie 2024-03-12 21:37:29 +08:00
parent 26771a837d
commit 4a5a3c529d
3 changed files with 16 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
oms-api/src/main/java/com/qihang/oms/mq/ApiMessageReceiver.java
View File

@ -44,17 +44,24 @@ public class ApiMessageReceiver implements MessageListener {
if(vo.getMqType() == MqType.ORDER_MESSAGE){ if(vo.getMqType() == MqType.ORDER_MESSAGE){
// 有新订单，插入新订单到shop_order // 有新订单，插入新订单到shop_order
logger.info("订单消息"+messageContent);
OOrderService orderService = SpringUtils.getBean(OOrderService.class); OOrderService orderService = SpringUtils.getBean(OOrderService.class);
if(vo.getShopType().getIndex() == EnumShopType.JD.getIndex()) { if(vo.getShopType().getIndex() == EnumShopType.JD.getIndex()) {
logger.info("订单消息JD"+messageContent);
orderService.jdOrderMessage(vo.getKeyId()); orderService.jdOrderMessage(vo.getKeyId());
}else if(vo.getShopType().getIndex() == EnumShopType.TAO.getIndex()) { }else if(vo.getShopType().getIndex() == EnumShopType.TAO.getIndex()) {
logger.info("订单消息TAO"+messageContent);
orderService.taoOrderMessage(vo.getKeyId()); orderService.taoOrderMessage(vo.getKeyId());
} }
}else if(vo.getMqType() == MqType.REFUND_MESSAGE){ }else if(vo.getMqType() == MqType.REFUND_MESSAGE){
logger.info("退款消息"+messageContent);
ORefundService refundService = SpringUtils.getBean(ORefundService.class); ORefundService refundService = SpringUtils.getBean(ORefundService.class);
refundService.jdRefundMessage(vo.getKeyId()); if(vo.getShopType().getIndex() == EnumShopType.JD.getIndex()) {
logger.info("退款消息JD" + messageContent);
refundService.jdRefundMessage(vo.getKeyId());
}else if(vo.getShopType().getIndex() == EnumShopType.TAO.getIndex()) {
logger.info("退款消息TAO"+messageContent);
refundService.taoRefundMessage(vo.getKeyId());
}
} }
} }
} }

1
oms-api/src/main/java/com/qihang/oms/service/ORefundService.java
View File

@ -12,4 +12,5 @@ import com.qihang.oms.domain.ORefund;
*/ */
public interface ORefundService extends IService<ORefund> { public interface ORefundService extends IService<ORefund> {
ResultVo<Integer> jdRefundMessage(String refundId); ResultVo<Integer> jdRefundMessage(String refundId);
ResultVo<Integer> taoRefundMessage(String refundId);
} }

5
oms-api/src/main/java/com/qihang/oms/service/impl/ORefundServiceImpl.java
View File

@ -98,6 +98,11 @@ public class ORefundServiceImpl extends ServiceImpl<ORefundMapper, ORefund>
} }
return null; return null;
} }
@Override
public ResultVo<Integer> taoRefundMessage(String refundId) {
return null;
}
} }