package com.sinata.rest.modular.mall.service.impl;
|
|
import cn.hutool.core.date.DatePattern;
|
import cn.hutool.core.date.DateTime;
|
import cn.hutool.core.date.DateUtil;
|
import cn.hutool.core.util.StrUtil;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.sinata.rest.modular.mall.dao.MallCommissionSettlementMonthMapper;
|
import com.sinata.rest.modular.mall.model.MallCommissionSettlement;
|
import com.sinata.rest.modular.mall.model.MallCommissionSettlementMonth;
|
import com.sinata.rest.modular.mall.service.IMallCommissionSettlementMonthService;
|
import com.sinata.rest.modular.mall.service.IMallCommissionSettlementService;
|
import com.sinata.rest.modular.member.model.MemUser;
|
import com.sinata.rest.modular.member.service.IMemUserService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.annotation.Resource;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
/**
|
* <p>
|
* 佣金月结算 服务实现类
|
* </p>
|
*
|
* @author goku
|
* @since 2023-04-25
|
*/
|
@Slf4j
|
@Service
|
public class MallCommissionSettlementMonthServiceImpl extends ServiceImpl<MallCommissionSettlementMonthMapper, MallCommissionSettlementMonth> implements IMallCommissionSettlementMonthService {
|
|
@Resource
|
private IMemUserService memUserService;
|
@Resource
|
private IMallCommissionSettlementService mallCommissionSettlementService;
|
|
@Override
|
public List<MallCommissionSettlementMonth> getNotCommissionSettlementList(String beginTime, String endTime) {
|
return this.baseMapper.getNotCommissionSettlementList(beginTime, endTime);
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void commissionSettlementMonth() {
|
// 上月时间
|
DateTime lastMonth = DateUtil.offsetMonth(DateUtil.date(), -1);
|
String beginLastMonth = DateUtil.beginOfMonth(lastMonth).toString();
|
String endLastMonth = DateUtil.endOfMonth(lastMonth).toString();
|
// 结算月
|
String monthPattern = DateUtil.format(lastMonth, DatePattern.NORM_MONTH_FORMAT);
|
|
// 未结算佣金记录
|
List<MallCommissionSettlementMonth> notCommissionSettlementList = this.getNotCommissionSettlementList(beginLastMonth, endLastMonth);
|
|
// 查询记录关联用户列表
|
List<Integer> userIdList = notCommissionSettlementList.stream().map(MallCommissionSettlementMonth::getUserId).collect(Collectors.toList());
|
List<MemUser> memUserList = memUserService.list(
|
Wrappers.<MemUser>query().lambda()
|
.in(MemUser::getId, userIdList)
|
);
|
|
for (MallCommissionSettlementMonth m : notCommissionSettlementList) {
|
for (MemUser u : memUserList) {
|
// 匹配用户城市
|
if (u.getId().equals(m.getUserId()) && StrUtil.isNotBlank(u.getCityCode())) {
|
m.setProvinceCode(u.getCityCode().substring(0, 2) + "0000");
|
m.setCityCode(u.getCityCode().substring(0, 4) + "00");
|
m.setCountyCode(u.getCityCode());
|
break;
|
}
|
}
|
m.setMonth(monthPattern);
|
m.insert();
|
|
MallCommissionSettlement o = new MallCommissionSettlement();
|
o.setSettlementId(m.getId());
|
mallCommissionSettlementService.update(o,
|
Wrappers.<MallCommissionSettlement>update().lambda()
|
.eq(MallCommissionSettlement::getSettlementId, 0)
|
.eq(MallCommissionSettlement::getUserId, m.getUserId())
|
);
|
}
|
}
|
|
}
|
