提交修改

This commit is contained in:
quyixiao 2025-11-22 10:25:51 +08:00
parent 1c24c6f5ab
commit 5bb2800bd7
2 changed files with 1 additions and 2 deletions

View File

@ -162,7 +162,6 @@ public class VvPackageServiceImpl extends ServiceImpl<VvPackageDao, VvPackageEnt
dto.setType(DelayTypeEnums.delivered.getType());
int second = DateUtils.betweenSecond(time, timeAfter15);
log.info("VvPackageServiceImpl delay send :{}", JSON.toJSONString(dto));
// 通过广播模式发布延时消息 延时30分钟 持久化消息 消费后销毁 这里无需指定路由会广播至每个绑定此交换机的队列
rabbitTemplate.convertAndSend(delayExchangeName, "", JSON.toJSONString(dto), message -> {
message.getMessageProperties().setDeliveryMode(MessageDeliveryMode.PERSISTENT);
@ -191,6 +190,7 @@ public class VvPackageServiceImpl extends ServiceImpl<VvPackageDao, VvPackageEnt
OrderStatusEnums.shipped.getDesc()
);
}
} else {
VvReverseOrderEntity vvReverseOrderEntity = vvReverseOrderDao.selectVvReverseOrderByTrackNumber(trackNumber);
vvReverseOrderEntity.setStatus(ReverseStatusEnums.shipped.getStatus());

View File

@ -63,7 +63,6 @@ public class AppKuaiDiCallBackController {
if (ourSign.equals(sign)) {
//TODO 业务处理
SubscribePushParamResp subscribePushParamResp = new Gson().fromJson(param, SubscribePushParamResp.class);
SubscribePushResult subscribePushResult = subscribePushParamResp.getLastResult();
if (subscribePushResult != null) {
vvPackageService.selectVvKuaidiAndUpdateData(subscribePushResult.getNu(), RoleEnums.kuaidi100_callback.getRole(), false);