admin
2025-02-25 30d8e227e8d823b6c38c3b9c90ac2df03b63befe
fanli/src/main/java/com/yeshi/fanli/service/impl/user/invite/TeamFansInfoServiceImpl.java
@@ -66,30 +66,6 @@
   @Resource
   private UserActiveLogService userActiveLogService;
   @Override
   public void save(TeamFansInfo record) {
      if (record == null || record.getWorkerId() == null) {
         return;
      }
      // 无邀请关系 不操作
      ThreeSale threeSale = threeSaleSerivce.selectByWorkerId(record.getWorkerId());
      if (threeSale == null)
         return;
      record.setId(record.getWorkerId().toString());
      TeamFansInfo teamFansInfo = teamFansInfoDao.get(record.getId());
      if (teamFansInfo != null) {
         teamFansInfoDao.updateSelective(record);
         LogHelper.test("队员粉丝信息:更新-" + record.getId());
      } else {
         initData(record);
         record.setCrateTime(new Date());
         LogHelper.test("队员粉丝信息:新增-" + record.getId());
         teamFansInfoDao.save(record);
      }
   }
   /**
    * 初始化数据
@@ -139,6 +115,9 @@
   @Override
   public void addFansInfo(Long workerId, Long bossId, Date successTime) {
      LogHelper.test("addFansInfo-新增-" + workerId);
      UserInfo userInfo = userInfoService.selectByPKey(workerId);
      if (userInfo == null) {
         return;
@@ -248,11 +227,17 @@
      focusInfo.setStateValid(stateValid);
      focusInfo.setLevel(level);
      focusInfo.setId(workerId.toString());
      save(focusInfo);
      focusInfo.setCrateTime(new Date());
      // 初始化值
      initData(focusInfo);
      teamFansInfoDao.save(focusInfo);
   }
   @Override
   public void updateMemoName(Long workerId, int type, String memoName) {
      LogHelper.test("updateMemoName-更新-" + workerId);
      TeamFansInfo teamFansInfo = new TeamFansInfo();
      teamFansInfo.setWorkerId(workerId);
      if (type == 1) {
@@ -260,11 +245,12 @@
      } else {
         teamFansInfo.setMemoNameSup(memoName);
      }
      save(teamFansInfo);
      update(teamFansInfo);
   }
   @Override
   public void updateTags(Long workerId, int type, String tags) {
      LogHelper.test("updateTags-更新-" + workerId);
      TeamFansInfo teamFansInfo = new TeamFansInfo();
      teamFansInfo.setWorkerId(workerId);
      if (type == 1) {
@@ -272,43 +258,48 @@
      } else {
         teamFansInfo.setTagsSup(tags);
      }
      save(teamFansInfo);
      update(teamFansInfo);
   }
   @Override
   public void updateNickName(Long workerId, String nickName) {
      LogHelper.test("updateNickName-更新-" + workerId);
      TeamFansInfo teamFansInfo = new TeamFansInfo();
      teamFansInfo.setWorkerId(workerId);
      teamFansInfo.setNickName(nickName);
      save(teamFansInfo);
      update(teamFansInfo);
   }
   @Override
   public void updateStateValid(Long workerId, boolean stateValid) {
      LogHelper.test("updateStateValid-更新-" + workerId);
      TeamFansInfo teamFansInfo = new TeamFansInfo();
      teamFansInfo.setWorkerId(workerId);
      teamFansInfo.setStateValid(stateValid);
      save(teamFansInfo);
      update(teamFansInfo);
   }
   @Override
   public void updateTaobaoBind(Long workerId, boolean taobaoBind) {
      LogHelper.test("updateTaobaoBind-更新-" + workerId);
      TeamFansInfo teamFansInfo = new TeamFansInfo();
      teamFansInfo.setWorkerId(workerId);
      teamFansInfo.setTaobaoBind(taobaoBind);
      save(teamFansInfo);
      update(teamFansInfo);
   }
   @Override
   public void updateActiveTime(Long workerId, Date activeTime) {
      LogHelper.test("updateActiveTime-更新-" + workerId);
      TeamFansInfo teamFansInfo = new TeamFansInfo();
      teamFansInfo.setWorkerId(workerId);
      teamFansInfo.setActiveTime(activeTime);
      save(teamFansInfo);
      update(teamFansInfo);
   }
   @Override
   public void updateWeixinId(Long workerId, String weixinId) {
      LogHelper.test("updateWeixinId-更新-" + workerId);
      TeamFansInfo teamFansInfo = new TeamFansInfo();
      teamFansInfo.setWorkerId(workerId);
      teamFansInfo.setWeixinId(weixinId);
@@ -317,43 +308,48 @@
      } else {
         teamFansInfo.setWeixinIdExist(true);
      }
      save(teamFansInfo);
      update(teamFansInfo);
   }
   @Override
   public void updateInviteCode(Long workerId, String inviteCode) {
      LogHelper.test("updateInviteCode-更新-" + workerId);
      TeamFansInfo teamFansInfo = new TeamFansInfo();
      teamFansInfo.setWorkerId(workerId);
      teamFansInfo.setInviteCode(inviteCode);
      save(teamFansInfo);
      update(teamFansInfo);
   }
   @Override
   public void updatePhone(Long workerId, String phone) {
      LogHelper.test("updatePhone-更新-" + workerId);
      TeamFansInfo teamFansInfo = new TeamFansInfo();
      teamFansInfo.setWorkerId(workerId);
      teamFansInfo.setPhone(phone);
      save(teamFansInfo);
      update(teamFansInfo);
   }
   @Override
   public void updateLevel(Long workerId, UserLevelEnum level) {
      LogHelper.test("updateLevel-更新-" + workerId);
      TeamFansInfo teamFansInfo = new TeamFansInfo();
      teamFansInfo.setLevel(level);
      teamFansInfo.setWorkerId(workerId);
      save(teamFansInfo);
      update(teamFansInfo);
   }
   @Override
   public void updatePhoneOpen(Long workerId, boolean phoneOpen) {
      LogHelper.test("updatePhoneOpen-更新-" + workerId);
      TeamFansInfo teamFansInfo = new TeamFansInfo();
      teamFansInfo.setWorkerId(workerId);
      teamFansInfo.setPhoneOpen(phoneOpen);
      save(teamFansInfo);
      update(teamFansInfo);
   }
   @Override
   public void updateIncome(Long workerId, BigDecimal income) {
      LogHelper.test("updateIncome-更新-" + workerId);
      if (income == null) {
         income = BigDecimal.ZERO;
      }
@@ -362,19 +358,34 @@
      teamFansInfo.setWorkerId(workerId);
      teamFansInfo.setIncome(income.multiply(BigDecimal.valueOf(100)).setScale(0, BigDecimal.ROUND_DOWN).intValue());
      teamFansInfo.setIncomeTime(new Date());
      save(teamFansInfo);
      update(teamFansInfo);
   }
   @Override
   public void updateFansNum(Long workerId) {
      LogHelper.test("updateFansNum-更新-" + workerId);
      long firstTeam = threeSaleSerivce.countFirstTeam(workerId);
      long secondTeam = threeSaleSerivce.countSecondTeam(workerId);
      int fansNum = (int) (firstTeam + secondTeam);
      TeamFansInfo teamFansInfo = new TeamFansInfo();
      teamFansInfo.setWorkerId(workerId);
      teamFansInfo.setFansNum(fansNum);
      save(teamFansInfo);
      update(teamFansInfo);
   }
   private void update(TeamFansInfo record) {
      if (record == null || record.getWorkerId() == null) {
         return;
      }
      // 无邀请关系 不操作
      ThreeSale threeSale = threeSaleSerivce.selectByWorkerId(record.getWorkerId());
      if (threeSale == null)
         return;
      record.setId(record.getWorkerId().toString());
      teamFansInfoDao.updateSelective(record);
   }
   @Override
   public List<TeamFansInfo> query(int start, int count, int type, Long uid, ThreeSaleFocusDTO focusDTO) {