package com.yeshi.fanli.service.impl.user.invite;
|
|
import java.util.Date;
|
import java.util.List;
|
|
import javax.annotation.Resource;
|
|
import org.springframework.context.annotation.Lazy;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.yeshi.utils.DateUtil;
|
|
import com.yeshi.fanli.dao.mybatis.user.UserInviteSeparateMapper;
|
import com.yeshi.fanli.entity.bus.user.ThreeSale;
|
import com.yeshi.fanli.entity.bus.user.UserInfo;
|
import com.yeshi.fanli.entity.bus.user.UserInviteSeparate;
|
import com.yeshi.fanli.entity.bus.user.vip.UserVIPPreInfo;
|
import com.yeshi.fanli.service.inter.user.UserInfoService;
|
import com.yeshi.fanli.service.inter.user.UserInviteSeparateService;
|
import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;
|
import com.yeshi.fanli.service.inter.user.invite.UserInviteMsgNotificationService;
|
import com.yeshi.fanli.service.inter.user.vip.UserVIPPreInfoService;
|
import com.yeshi.fanli.service.inter.user.vip.UserVipConfigService;
|
|
@Service
|
public class UserInviteSeparateServiceImpl implements UserInviteSeparateService {
|
|
@Resource
|
private UserInviteSeparateMapper userInviteSeparateMapper;
|
|
@Resource
|
private UserVipConfigService userVipConfigService;
|
|
@Lazy
|
@Resource
|
private ThreeSaleSerivce threeSaleSerivce;
|
|
@Lazy
|
@Resource
|
private UserVIPPreInfoService userVIPPreInfoService;
|
|
@Lazy
|
@Resource
|
private UserInfoService userInfoService;
|
|
@Lazy
|
@Resource
|
private UserInviteMsgNotificationService userInviteMsgNotificationService;
|
|
@Override
|
public void insertSelective(UserInviteSeparate record) {
|
userInviteSeparateMapper.insertSelective(record);
|
}
|
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void addPreSeparateRecord(Long workerId, Long bossId) {
|
// 更新之前状态失效
|
userInviteSeparateMapper.updateStateByWorkerIdAndBossId(workerId, bossId, UserInviteSeparate.STATE_INVALID);
|
|
// 限制天数
|
int limitDays = Integer.parseInt(userVipConfigService.getValueByKey("invite_separate_limit_days"));
|
|
// 保存记录
|
UserInviteSeparate inviteSeparate = new UserInviteSeparate();
|
inviteSeparate.setBossId(bossId);
|
inviteSeparate.setWorkerId(workerId);
|
inviteSeparate.setState(UserInviteSeparate.STATE_INIT);
|
inviteSeparate.setEndTime(DateUtil.plusDayDate(limitDays, new Date()));
|
inviteSeparate.setCreateTime(new Date());
|
inviteSeparate.setUpdateTime(new Date());
|
userInviteSeparateMapper.insertSelective(inviteSeparate);
|
}
|
|
@Override
|
public void updateInvalidByBossId(Long uid) {
|
userInviteSeparateMapper.updateInvalidByBossId(uid);
|
}
|
|
@Override
|
public void updateStateByWorkerIdAndBossId(Long workerId, Long bossId, int state) {
|
userInviteSeparateMapper.updateStateByWorkerIdAndBossId(workerId, bossId, state);
|
}
|
|
@Override
|
public UserInviteSeparate selectByWorkerIdAndBossId(Long workerId, Long bossId) {
|
return userInviteSeparateMapper.selectByWorkerIdAndBossId(workerId, bossId);
|
}
|
|
@Override
|
public List<UserInviteSeparate> getHandleOverdue(int start, int count) {
|
return userInviteSeparateMapper.getHandleOverdue(start, count);
|
}
|
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void inviteSeparate(UserInviteSeparate record) {
|
if (record == null)
|
return;
|
|
Long workerId = record.getWorkerId();
|
Long bossId = record.getBossId();
|
ThreeSale threeSale = threeSaleSerivce.getMyBoss(workerId);
|
if (threeSale == null) {
|
// 成功脱离 不发消息
|
userInviteSeparateMapper.updateStateByWorkerIdAndBossId(workerId, bossId, UserInviteSeparate.STATE_SUCCESS);
|
return;
|
}
|
|
boolean separate = false;
|
UserVIPPreInfo info = userVIPPreInfoService.getVipByProcess(bossId, UserVIPPreInfo.PROCESS_1);
|
if (info == null) {
|
separate = true;
|
} else if (info.getCreateTime().getTime() >= record.getEndTime().getTime()) {
|
separate = true;
|
}
|
|
|
if (!separate) {
|
// 未脱离
|
userInviteSeparateMapper.updateStateByWorkerIdAndBossId(workerId, bossId, UserInviteSeparate.STATE_INVALID);
|
} else {
|
// 脱离关系
|
userInviteSeparateMapper.updateStateByWorkerIdAndBossId(workerId, bossId, UserInviteSeparate.STATE_SUCCESS);
|
// 脱离邀请关系
|
threeSaleSerivce.inviteSeparate(workerId, bossId);
|
|
|
UserInfo worker = userInfoService.selectByPKey(workerId);
|
|
// 提醒上级脱离
|
userInviteMsgNotificationService.fansDivorced(bossId, worker.getNickName(), new Date());
|
|
// 提醒上上级脱离
|
ThreeSale threeSaleSuper = threeSaleSerivce.getMyBoss(bossId);
|
if (threeSaleSuper != null) { // 粉丝升级提醒
|
Long bossIdSuper = threeSaleSuper.getBoss().getId();
|
UserInfo boss = userInfoService.selectByPKey(workerId);
|
userInviteMsgNotificationService.fansDivorcedIndirect(bossIdSuper, worker.getNickName(),
|
boss.getNickName(), new Date());
|
}
|
}
|
}
|
|
|
}
|
