yujian
2020-03-31 684779576c02c13cb2a18a7d93e88da7e57fd4b8
fanli/src/main/java/com/yeshi/fanli/service/impl/user/invite/UserInviteSeparateServiceImpl.java
@@ -1,12 +1,18 @@
package com.yeshi.fanli.service.impl.user.invite;
import java.util.Date;
import java.util.List;
import javax.annotation.Resource;
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.UserInviteSeparate;
import com.yeshi.fanli.service.inter.user.UserInviteSeparateService;
import com.yeshi.fanli.service.inter.user.vip.UserVipConfigService;
@Service
public class UserInviteSeparateServiceImpl implements UserInviteSeparateService {
@@ -14,11 +20,38 @@
   @Resource
   private UserInviteSeparateMapper userInviteSeparateMapper;
   
   @Resource
   private UserVipConfigService userVipConfigService;
   @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) {
@@ -30,10 +63,17 @@
      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);
   }
}