提交修改

This commit is contained in:
quyixiao 2025-11-09 09:55:29 +08:00
parent 4720d5e6be
commit 7a7f20aa54
2 changed files with 7 additions and 1 deletions

View File

@ -11,6 +11,7 @@ import com.heyu.api.data.entity.vv.VvTradeOrderLineEntity;
import com.heyu.api.data.enums.RoleEnums;
import com.heyu.api.data.utils.R;
import com.heyu.api.listener.BaseDelayedHandler;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@ -19,6 +20,7 @@ import java.util.List;
@Component("deliveredHandler")
@Slf4j
public class DeliveredHandler extends BaseDelayedHandler {
@Autowired
@ -29,6 +31,8 @@ public class DeliveredHandler extends BaseDelayedHandler {
@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());

View File

@ -7,6 +7,7 @@ import com.heyu.api.data.dto.WeiXinPayDelayDTO;
import com.heyu.api.data.entity.vv.VvTradeOrderLineEntity;
import com.heyu.api.data.utils.R;
import com.heyu.api.listener.BaseDelayedHandler;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@ -14,6 +15,7 @@ import java.util.Date;
import java.util.List;
@Slf4j
@Component("weiXinPayCloseHandler")
public class WeiXinPayCloseHandler extends BaseDelayedHandler {
@ -24,7 +26,7 @@ public class WeiXinPayCloseHandler extends BaseDelayedHandler {
@Override
public R handler(String message) {
log.info("weiXinPayCloseHandler receive message:{}", message);
WeiXinPayDelayDTO weiXinPayDelayDTO = JSONObject.parseObject(message, WeiXinPayDelayDTO.class);
List<VvTradeOrderLineEntity> vvTradeOrderLineEntities = vvTradeOrderLineDao.selectVvTradeOrderLineByTradeOrderId(weiXinPayDelayDTO.getTradeOrderId());