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

up

This commit is contained in:
Richie 2024-03-09 22:16:20 +08:00
parent 3008d26fe3
commit da8abf72b5
6 changed files with 1072 additions and 61 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1102
doc/sql/qihang-oms.sql
View File

File diff suppressed because one or more lines are too long

2
jd-api/src/main/java/com/qihang/jd/controller/RefundApiController.java
View File

@ -50,7 +50,7 @@ public class RefundApiController {
// request2.setCheckTimeStart("2023-12-01 16:11:40");
// request2.setCheckTimeEnd("2023-12-31 16:11:40");
request2.setPageIndex(1);
request2.setPageSize(10);
request2.setPageSize(100);
PopAfsRefundapplyQuerylistResponse response2=client.execute(request2);
System.out.println(request2);
return response2;

15
sys-api/src/main/java/com/qihang/sys/api/mq/ApiMessageReceiver.java
View File

@ -35,10 +35,10 @@ public class ApiMessageReceiver implements MessageListener {
*/
@Override
public void onMessage(Message message, byte[] pattern) {
RedisSerializer<String> valueSerializer = redisTemplate.getStringSerializer();
String deserialize = valueSerializer.deserialize(message.getBody());
// RedisSerializer<String> valueSerializer = redisTemplate.getStringSerializer();
// String deserialize = valueSerializer.deserialize(message.getBody());
//message 和 deserialize 都能拿到msg
logger.info("Received <" + message + ">");
// logger.info("Received <" + message + ">");
// System.out.println("deserialize = " + deserialize);
String messageContent = new String(message.getBody());
MqMessage vo = JSON.parseObject(messageContent, MqMessage.class);
@ -47,10 +47,13 @@ public class ApiMessageReceiver implements MessageListener {
if(vo.getMqType() == MqType.ORDER_MESSAGE){
// 有新订单，插入新订单到shop_order
logger.info("订单消息AAAAAAA");
logger.info("订单消息"+messageContent);
OOrderService orderService = SpringUtils.getBean(OOrderService.class);
if(vo.getShopType().getIndex() == EnumShopType.JD.getIndex())
orderService.jdOrderMessage(vo.getKeyId());
if(vo.getShopType().getIndex() == EnumShopType.JD.getIndex()) {
orderService.jdOrderMessage(vo.getKeyId());
}else if(vo.getShopType().getIndex() == EnumShopType.TAO.getIndex()) {
orderService.taoOrderMessage(vo.getKeyId());
}
}
}
}

1
sys-api/src/main/java/com/qihang/sys/api/service/OOrderService.java
View File

@ -13,4 +13,5 @@ import java.util.List;
*/
public interface OOrderService extends IService<OOrder> {
ResultVo<Integer> jdOrderMessage(String orderId);
ResultVo<Integer> taoOrderMessage(String orderId);
}

11
sys-api/src/main/java/com/qihang/sys/api/service/impl/OOrderServiceImpl.java
View File

@ -140,6 +140,17 @@ public class OOrderServiceImpl extends ServiceImpl<OOrderMapper, OOrder>
}
return null;
}
@Override
public ResultVo<Integer> taoOrderMessage(String orderId) {
log.info("Tao订单消息处理"+orderId);
// List<JdOrder> jdOrders = jdOrderMapper.selectList(new LambdaQueryWrapper<JdOrder>().eq(JdOrder::getOrderId, orderId));
// if(jdOrders == null || jdOrders.size() == 0) {
// // 没有找到订单信息
// return new ResultVo<>(ResultVoEnum.NotFound,"没有找到TAO订单："+orderId);
// }
return null;
}
}

2
tao-api/src/main/java/com/qihang/tao/service/impl/TaoRefundServiceImpl.java
View File

@ -40,7 +40,7 @@ public class TaoRefundServiceImpl extends ServiceImpl<TaoRefundMapper, TaoRefund
refund.setShopId(shopId);
refund.setCreateTime(new Date());
mapper.insert(refund);
return 0;
return ResultVoEnum.SUCCESS.getIndex();
}
}