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.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 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;
|
|
/**
|
* 定时任务-等级晋升维持
|
*/
|
@Slf4j
|
@Component
|
@EnableScheduling
|
@Api(tags = "API通用接口")
|
public class UserV3UpDownWork {
|
|
@Autowired
|
private ISystemSetService setService;
|
|
@Autowired
|
private IMemUserService memUserService;
|
|
@Autowired
|
private IMemUserRelationService memUserRelationService;
|
|
@Autowired
|
private IMallOrderService mallOrderService;
|
|
/**
|
* 每天执行1次
|
*/
|
@Scheduled(cron = "0 1 0 */1 * *")
|
public void run() {
|
// 【职级晋升维持】黄金营销员-晋升：可于{1次日/2次月/3次季度}晋升为城市合伙人
|
Integer set_304 = setService.getIntegerById(EnumSystemSetKey.SET_304.index);
|
if (set_304 == 1) {
|
v3Up();
|
} if (set_304 == 2 && DateUtil.thisDayOfMonth() == 1) {
|
v3Up();
|
} if (set_304 == 3 && DateUtil.isSameDay(DateUtil.date(), DateUtil.beginOfQuarter(DateUtil.date()))) {
|
v3Up();
|
}
|
}
|
|
public void v3Up() {
|
// 自然季度开始结束时间
|
String beginTime = DateUtil.beginOfQuarter(DateUtil.date()).toString();
|
String endTime = DateUtil.endOfQuarter(DateUtil.date()).toString();
|
|
// 黄金营销员列表
|
List<MemUser> v3UserList = memUserService.list(
|
Wrappers.<MemUser>query().lambda()
|
.select(MemUser::getId, MemUser::getRealName, MemUser::getCreditScore, MemUser::getMemberGradeId)
|
.eq(MemUser::getIsDelete, EnumIsDelete.EXISTED.index) // 非注销
|
.eq(MemUser::getIsLeaveOffice, 0) // 非离职
|
.eq(MemUser::getMemberGradeId, EnumMemberGrade.G_3.index)
|
.ge(MemUser::getCreditScore, setService.getIntegerById(EnumSystemSetKey.SET_303.index))
|
);
|
|
for (MemUser user : v3UserList) {
|
Integer set_301 = setService.getIntegerById(EnumSystemSetKey.SET_301.index);
|
// 直接推荐{}个黄金营销员
|
Integer shareV3Count = memUserRelationService.directTeamCount(
|
user.getId(),
|
Arrays.asList(EnumMemberGrade.G_3.index),
|
beginTime,
|
endTime
|
);
|
if (shareV3Count < set_301) {
|
continue;
|
}
|
Integer set_302 = setService.getIntegerById(EnumSystemSetKey.SET_302.index);
|
BigDecimal v3DirectTeamMoney = mallOrderService.getV3DirectTeamSumMoney(
|
user.getId(),
|
Arrays.asList(EnumMallOrderState.SUCCESS.index),
|
beginTime,
|
endTime
|
);
|
if (v3DirectTeamMoney.compareTo(BigDecimal.valueOf(set_302 * 10000)) == -1) {
|
continue;
|
}
|
|
log.info("【黄金营销员晋升为城市合伙人】用户：{} / {}，直推黄金营销员：{}个，直属团队达成{}元业绩，品行分：{}",
|
user.getId(), user.getRealName(), shareV3Count, v3DirectTeamMoney, user.getCreditScore()
|
);
|
// 晋升为-城市合伙人
|
user.setMemberGradeId(EnumMemberGrade.G_4.index);
|
user.setMemberGradeTime(DateUtil.date());
|
user.setCreditScore(BigDecimal.valueOf(100));
|
user.updateById();
|
}
|
}
|
|
}
|
