package com.sinata.rest.modular.mall.job;
|
|
import cn.hutool.core.date.DateUtil;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.sinata.common.enums.EnumIsDelete;
|
import com.sinata.common.enums.EnumMemberGrade;
|
import com.sinata.common.enums.EnumSystemSetKey;
|
import com.sinata.common.enums.mall.EnumMallOrderState;
|
import com.sinata.rest.core.support.DateTime;
|
import com.sinata.rest.modular.mall.service.IMallOrderService;
|
import com.sinata.rest.modular.member.model.MemUser;
|
import com.sinata.rest.modular.member.service.IMemUserRelationService;
|
import com.sinata.rest.modular.member.service.IMemUserService;
|
import com.sinata.rest.modular.system.service.ISystemSetService;
|
import io.swagger.annotations.Api;
|
import java.util.Date;
|
import java.util.stream.Collectors;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.EnableScheduling;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import java.math.BigDecimal;
|
import java.util.Arrays;
|
import java.util.List;
|
import org.springframework.transaction.annotation.Transactional;
|
|
/**
|
* 定时任务-等级晋升维持
|
*/
|
@Slf4j
|
@Component
|
@EnableScheduling
|
@Api(tags = "API通用接口")
|
public class UserV5UpDownWork {
|
|
@Autowired
|
private ISystemSetService setService;
|
|
@Autowired
|
private IMemUserService memUserService;
|
|
@Autowired
|
private IMemUserRelationService memUserRelationService;
|
|
@Autowired
|
private IMallOrderService mallOrderService;
|
|
/**
|
* 每月一号 0:30执行
|
*/
|
@Scheduled(cron = "0 30 0 1 * ?")
|
public void run() {
|
if (DateUtil.thisDayOfMonth() == 1) {
|
// 市场总监列表
|
List<MemUser> v5UserList = memUserService.list(
|
Wrappers.<MemUser>query().lambda()
|
.select(MemUser::getId, MemUser::getRealName, MemUser::getCreditScore, MemUser::getMemberGradeId, MemUser::getMemberGradeTime)
|
.eq(MemUser::getIsDelete, EnumIsDelete.EXISTED.index) // 非注销
|
.eq(MemUser::getIsLeaveOffice, 0) // 非离职
|
.eq(MemUser::getMemberGradeId, EnumMemberGrade.G_5.index)
|
);
|
//品行分小于60直接降级为黄金营销员
|
List<MemUser> list = v5UserList.stream().filter(user ->
|
user.getCreditScore().compareTo(BigDecimal.valueOf(60)) < 0).peek(item -> {
|
item.setMemberGradeId(EnumMemberGrade.G_3.index);
|
item.setMemberGradeTime(DateUtil.date());
|
item.setCreditScore(BigDecimal.valueOf(100));
|
}).collect(Collectors.toList());
|
memUserService.updateBatchById(list);
|
//剩下需要通过维持方案来判断的用户
|
List<MemUser> userList = v5UserList.stream().filter(user ->
|
user.getCreditScore().compareTo(BigDecimal.valueOf(60)) >= 0)
|
.collect(Collectors.toList());
|
for (MemUser user : userList) {
|
if (v5Case1(user.getId()) && v5Case2(user.getId())) {
|
log.info("【市场总监降级为城市合伙人】用户：{} / {}",
|
user.getId(), user.getRealName()
|
);
|
// 降级一级
|
user.setMemberGradeId(EnumMemberGrade.G_4.index);
|
user.setMemberGradeTime(DateUtil.date());
|
user.setCreditScore(BigDecimal.valueOf(100));
|
user.updateById();
|
}
|
}
|
}
|
}
|
|
public boolean v5Case1(Integer userId) {
|
boolean isDown = false;
|
|
Integer set_341 = setService.getIntegerById(EnumSystemSetKey.SET_341.index);
|
// 直接推荐不少于{}个黄金营销员
|
Integer shareV3Count = memUserRelationService.directTeamCount(
|
userId,
|
Arrays.asList(EnumMemberGrade.G_3.index),
|
null,
|
null
|
);
|
if (shareV3Count < set_341) {
|
isDown = true;
|
}
|
|
Integer set_342 = setService.getIntegerById(EnumSystemSetKey.SET_342.index);
|
// 育成{}个城市合伙人
|
Integer upV4Count = memUserRelationService.directTeamCount(
|
userId,
|
Arrays.asList(EnumMemberGrade.G_4.index),
|
null,
|
null
|
);
|
if (upV4Count < set_342) {
|
isDown = true;
|
}
|
|
|
// 滚动半年开始结束时间
|
String beginTime = DateUtil.offsetMonth(DateUtil.date(), -6).toString();
|
String endTime = DateUtil.date().toString();
|
|
Integer set_343 = setService.getIntegerById(EnumSystemSetKey.SET_343.index);
|
// 滚动半年度直属团队达成{}万业绩
|
BigDecimal v3DirectTeamMoney = mallOrderService.getV3DirectTeamSumMoney(
|
userId,
|
Arrays.asList(EnumMallOrderState.SUCCESS.index),
|
beginTime,
|
endTime
|
);
|
if (v3DirectTeamMoney.compareTo(BigDecimal.valueOf(set_343 * 10000)) == -1) {
|
isDown = true;
|
}
|
|
Integer set_344 = setService.getIntegerById(EnumSystemSetKey.SET_344.index);
|
// 新育成{}个城市合伙人
|
Integer upV4NewCount = memUserRelationService.directTeamCount(
|
userId,
|
Arrays.asList(EnumMemberGrade.G_4.index),
|
beginTime,
|
endTime
|
);
|
if (upV4NewCount < set_344) {
|
isDown = true;
|
}
|
|
return isDown;
|
}
|
|
public boolean v5Case2(Integer userId) {
|
boolean isDown = false;
|
|
// 滚动半年开始结束时间
|
String beginTime = DateUtil.offsetMonth(DateUtil.date(), -6).toString();
|
String endTime = DateUtil.date().toString();
|
|
Integer set_345 = setService.getIntegerById(EnumSystemSetKey.SET_345.index);
|
// 滚动半年度直接推荐{}个黄金营销员
|
Integer shareV3Count = memUserRelationService.directTeamCount(
|
userId,
|
Arrays.asList(EnumMemberGrade.G_3.index),
|
beginTime,
|
endTime
|
);
|
if (shareV3Count < set_345) {
|
isDown = true;
|
}
|
|
Integer set_346 = setService.getIntegerById(EnumSystemSetKey.SET_346.index);
|
// 育成{}个城市合伙人
|
Integer upV4Count = memUserRelationService.directTeamCount(
|
userId,
|
Arrays.asList(EnumMemberGrade.G_4.index),
|
beginTime,
|
endTime
|
);
|
if (upV4Count < set_346) {
|
isDown = true;
|
}
|
|
Integer set_347 = setService.getIntegerById(EnumSystemSetKey.SET_347.index);
|
// 直属团队达成{}万业绩
|
BigDecimal v3DirectTeamMoney = mallOrderService.getV3DirectTeamSumMoney(
|
userId,
|
Arrays.asList(EnumMallOrderState.SUCCESS.index),
|
beginTime,
|
endTime
|
);
|
if (v3DirectTeamMoney.compareTo(BigDecimal.valueOf(set_347 * 10000)) == -1) {
|
isDown = true;
|
}
|
|
return isDown;
|
}
|
|
}
|
