|
@@ -212,8 +212,9 @@ public class Scheduler {
|
|
|
DistributeWaitingSendPoints::getSendTime))).orElse(new ArrayList<>());
|
|
DistributeWaitingSendPoints::getSendTime))).orElse(new ArrayList<>());
|
|
|
log.info("查询分销订单积分分发记录开始,条数:{}=======》", waitingSendPoints.size());
|
|
log.info("查询分销订单积分分发记录开始,条数:{}=======》", waitingSendPoints.size());
|
|
|
waitingSendPoints.forEach(wait -> {
|
|
waitingSendPoints.forEach(wait -> {
|
|
|
- Long userId = wait.getUserId();
|
|
|
|
|
- User user = userMapper.selectById(userId);
|
|
|
|
|
|
|
+ //积分待发人
|
|
|
|
|
+ Long sharedId = wait.getSharedId();
|
|
|
|
|
+ User user = userMapper.selectById(sharedId);
|
|
|
if (user == null) {
|
|
if (user == null) {
|
|
|
wait.setSendStatus(DistributeWaitingSendPoints.Status.not_exist);
|
|
wait.setSendStatus(DistributeWaitingSendPoints.Status.not_exist);
|
|
|
log.info("分销订单,发送积分用户不存在");
|
|
log.info("分销订单,发送积分用户不存在");
|