提交hsn

This commit is contained in:
quyixiao 2025-11-20 23:50:03 +08:00
parent 11bea6afc0
commit 44f1eba5d6

View File

@ -2,14 +2,14 @@ package com.heyu.api.listener.delay.handler;
import com.alibaba.fastjson.JSONObject;
import com.heyu.api.data.dao.vv.VvTradeOrderLineStatusLogDao;
import com.heyu.api.data.enums.OrderStatusEnums;
import com.heyu.api.data.dao.vv.VvPackageDao;
import com.heyu.api.data.dao.vv.VvTradeOrderLineDao;
import com.heyu.api.data.dto.PackageDelivedDelayDTO;
import com.heyu.api.data.entity.vv.VvPackageEntity;
import com.heyu.api.data.entity.vv.VvTradeOrderLineEntity;
import com.heyu.api.data.enums.OrderStatusEnums;
import com.heyu.api.data.enums.RoleEnums;
import com.heyu.api.data.service.vv.VvTradeOrderConvertService;
import com.heyu.api.data.utils.R;
import com.heyu.api.listener.BaseDelayedHandler;
import lombok.extern.slf4j.Slf4j;
@ -32,20 +32,21 @@ public class DeliveredHandler extends BaseDelayedHandler {
@Autowired
private VvTradeOrderLineStatusLogDao vvTradeOrderLineStatusLogDao;
private VvTradeOrderConvertService vvTradeOrderConvertService;
@Override
public R handler(String message) {
log.info("DeliveredHandler receive message:{}", message);
PackageDelivedDelayDTO packageDelivedDelayDTO = JSONObject.parseObject(message, PackageDelivedDelayDTO.class);
// 更新包信息
VvPackageEntity vvPackage = vvPackageDao.selectVvPackageById(packageDelivedDelayDTO.getPackageId());
vvPackage.setIscheck("3");
vvPackage.setGmtDelivered(new Date());
vvPackage.setDeliveredBy(RoleEnums.job.getRole());
vvPackageDao.insertOrUpdateVvPackage(vvPackage);
vvPackage.setDeliveredBy(RoleEnums.system.getRole());
vvPackageDao.updateVvPackageById(vvPackage);
// 更新子单信息
List<VvTradeOrderLineEntity> vvTradeOrderLineEntityList = vvTradeOrderLineDao.selectVvTradeOrderLineByTrackNumber(vvPackage.getTrackNumber());
@ -55,15 +56,17 @@ public class DeliveredHandler extends BaseDelayedHandler {
vvTradeOrderLineEntity.setStatus(OrderStatusEnums.delivered.getStatus());
vvTradeOrderLineDao.updateVvTradeOrderLineById(vvTradeOrderLineEntity);
vvTradeOrderConvertService.addOrderLineStatusLog(vvTradeOrderLineEntity.getId(),
OrderStatusEnums.delivered,
RoleEnums.system.getRole()
);
}
return R.ok();
}
}