ufo / yohoufo-fore · Commits

Go to a project

Authored by caoyan
Commit f4142a32945ce4864807eab150ad5cca0539b48f 1 parent 7a8f1534

寄存

Inline Side-by-side
Showing 1 changed file with 6 additions and 4 deletions
... ... @@ -264,10 +264,12 @@ public class AppraiseService {
return;
}
storageDepositMapper.updateStorageStatus(deposit.getDepositCode(), StorageDepositStatusEnum.HAS_OUT.getCode(), OrderStatus.WAITING_PAY.getCode());
//发mq，延迟30天设置状态为已完成
yhProducer.send(TopicConstants.DEPOSIT_FINISH_DELIVERY, deposit, null, 60*24*30);
int num = storageDepositMapper.updateStorageStatus(deposit.getDepositCode(), StorageDepositStatusEnum.HAS_OUT.getCode(), OrderStatus.WAITING_PAY.getCode());
if(num > 0) {
//发mq，延迟30天设置状态为已完成
LOGGER.info("start send storageDeposit mq,topic is {}, depositCode is {}", TopicConstants.DEPOSIT_FINISH_DELIVERY, deposit.getDepositCode());
yhProducer.send(TopicConstants.DEPOSIT_FINISH_DELIVERY, deposit, null, 60*24*30);
}
}
private void deliveryDepositGoodsToBuyer(AppraiseExpressInfoBo appraiseExpressInfoBo, BuyerOrder buyerOrder) {
... ...