|
@@ -6,12 +6,13 @@ import cn.newfeifan.mall.module.distri.controller.app.sharepath.vo.*;
|
|
|
import cn.newfeifan.mall.module.distri.dal.dataobject.duser.DuserDO;
|
|
|
import cn.newfeifan.mall.module.distri.dal.dataobject.integral.IntegralDO;
|
|
|
import cn.newfeifan.mall.module.distri.dal.dataobject.orderpercentage.OrderPercentageDO;
|
|
|
+import cn.newfeifan.mall.module.distri.dal.dataobject.partitioncrash.PartitionCrashDO;
|
|
|
import cn.newfeifan.mall.module.distri.dal.dataobject.socialstatus.SocialStatusDO;
|
|
|
import cn.newfeifan.mall.module.distri.dal.mysql.orderpercentage.OrderPercentageMapper;
|
|
|
+import cn.newfeifan.mall.module.distri.dal.mysql.partitioncrash.PartitionCrashMapper;
|
|
|
import cn.newfeifan.mall.module.distri.enums.SocialStatusEnum;
|
|
|
import cn.newfeifan.mall.module.distri.service.duser.DuserService;
|
|
|
import cn.newfeifan.mall.module.distri.service.integral.IntegralService;
|
|
|
-import cn.newfeifan.mall.module.distri.service.partitioncrash.PartitionCrashService;
|
|
|
import cn.newfeifan.mall.module.distri.service.socialstatus.SocialStatusService;
|
|
|
import cn.newfeifan.mall.module.member.dal.dataobject.user.MemberUserDO;
|
|
|
import cn.newfeifan.mall.module.member.service.user.MemberUserService;
|
|
@@ -30,6 +31,9 @@ import cn.newfeifan.mall.framework.common.util.object.BeanUtils;
|
|
|
|
|
|
import cn.newfeifan.mall.module.distri.dal.mysql.sharepath.SharePathMapper;
|
|
|
|
|
|
+import java.time.LocalDate;
|
|
|
+import java.time.LocalDateTime;
|
|
|
+import java.time.LocalTime;
|
|
|
import java.util.List;
|
|
|
import java.util.Objects;
|
|
|
import java.util.stream.Collectors;
|
|
@@ -68,7 +72,7 @@ public class SharePathServiceImpl implements SharePathService {
|
|
|
private IntegralService integralService;
|
|
|
|
|
|
@Resource
|
|
|
- private PartitionCrashService partitionCrashService;
|
|
|
+ private PartitionCrashMapper partitionCrashMapper;
|
|
|
|
|
|
|
|
|
@Override
|
|
@@ -205,13 +209,19 @@ public class SharePathServiceImpl implements SharePathService {
|
|
|
}
|
|
|
|
|
|
private Long getResidueSocial(Long userId){
|
|
|
- if(!userId.equals(PT_ID)){
|
|
|
- Long ancestorIncreaseIntegral = sharePathMapper.getAncestorIncreaseIntegralByUserId(userId);
|
|
|
- if(ancestorIncreaseIntegral == null) ancestorIncreaseIntegral = 0L;
|
|
|
- Long residueSocial = partitionCrashService.getResidueSocial(userId);
|
|
|
- return ancestorIncreaseIntegral + residueSocial;
|
|
|
- }
|
|
|
- return 0L;
|
|
|
+// if(!userId.equals(PT_ID)){
|
|
|
+// Long ancestorIncreaseIntegral = sharePathMapper.getAncestorIncreaseIntegralByUserId(userId);
|
|
|
+// if(ancestorIncreaseIntegral == null) ancestorIncreaseIntegral = 0L;
|
|
|
+// Long residueSocial = partitionCrashService.getResidueSocial(userId);
|
|
|
+// return ancestorIncreaseIntegral + residueSocial;
|
|
|
+// }
|
|
|
+
|
|
|
+ LocalDateTime todayStart = LocalDateTime.of(LocalDate.now(), LocalTime.MIDNIGHT); // 今天的开始时间,即午夜12点
|
|
|
+ LocalDateTime localDateTime = todayStart.minusDays(1);
|
|
|
+ String yesterdayNo = "CRASH:" + userId + ":" + localDateTime.toString();
|
|
|
+ PartitionCrashDO yesterdayCrash = partitionCrashMapper.selectOne(new LambdaQueryWrapperX<PartitionCrashDO>().eqIfPresent(PartitionCrashDO::getPartNo, yesterdayNo));
|
|
|
+
|
|
|
+ return yesterdayCrash.getAfterHitQuota();
|
|
|
}
|
|
|
|
|
|
/**
|