好单库转链支持

admin

2020-06-15 3e4ef41ffacd7f5fda2e81c3810cd11a6375b83c

 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("save-更新-" + record.getId());
      } else {
         initData(record);
         record.setCrateTime(new Date());
         LogHelper.test("save-新增-" + record.getId());
         teamFansInfoDao.save(record);
      }
   }

   /**
    * 初始化数据
@@ -251,7 +227,12 @@
      focusInfo.setStateValid(stateValid);
      focusInfo.setLevel(level);
      focusInfo.setId(workerId.toString());
      save(focusInfo);
      focusInfo.setCrateTime(new Date());
		
      // 初始化值
      initData(focusInfo);
		
      teamFansInfoDao.save(focusInfo);
   }

   @Override
@@ -264,7 +245,7 @@
      } else {
         teamFansInfo.setMemoNameSup(memoName);
      }
      save(teamFansInfo);
      update(teamFansInfo);
   }

   @Override
@@ -277,7 +258,7 @@
      } else {
         teamFansInfo.setTagsSup(tags);
      }
      save(teamFansInfo);
      update(teamFansInfo);
   }

   @Override
@@ -286,7 +267,7 @@
      TeamFansInfo teamFansInfo = new TeamFansInfo();
      teamFansInfo.setWorkerId(workerId);
      teamFansInfo.setNickName(nickName);
      save(teamFansInfo);
      update(teamFansInfo);
   }

   @Override
@@ -295,7 +276,7 @@
      TeamFansInfo teamFansInfo = new TeamFansInfo();
      teamFansInfo.setWorkerId(workerId);
      teamFansInfo.setStateValid(stateValid);
      save(teamFansInfo);
      update(teamFansInfo);
   }

   @Override
@@ -304,7 +285,7 @@
      TeamFansInfo teamFansInfo = new TeamFansInfo();
      teamFansInfo.setWorkerId(workerId);
      teamFansInfo.setTaobaoBind(taobaoBind);
      save(teamFansInfo);
      update(teamFansInfo);
   }

   @Override
@@ -313,7 +294,7 @@
      TeamFansInfo teamFansInfo = new TeamFansInfo();
      teamFansInfo.setWorkerId(workerId);
      teamFansInfo.setActiveTime(activeTime);
      save(teamFansInfo);
      update(teamFansInfo);
   }

   @Override
@@ -327,7 +308,7 @@
      } else {
         teamFansInfo.setWeixinIdExist(true);
      }
      save(teamFansInfo);
      update(teamFansInfo);
   }

   @Override
@@ -336,7 +317,7 @@
      TeamFansInfo teamFansInfo = new TeamFansInfo();
      teamFansInfo.setWorkerId(workerId);
      teamFansInfo.setInviteCode(inviteCode);
      save(teamFansInfo);
      update(teamFansInfo);
   }

   @Override
@@ -345,7 +326,7 @@
      TeamFansInfo teamFansInfo = new TeamFansInfo();
      teamFansInfo.setWorkerId(workerId);
      teamFansInfo.setPhone(phone);
      save(teamFansInfo);
      update(teamFansInfo);
   }

   @Override
@@ -354,7 +335,7 @@
      TeamFansInfo teamFansInfo = new TeamFansInfo();
      teamFansInfo.setLevel(level);
      teamFansInfo.setWorkerId(workerId);
      save(teamFansInfo);
      update(teamFansInfo);
   }

   @Override
@@ -363,7 +344,7 @@
      TeamFansInfo teamFansInfo = new TeamFansInfo();
      teamFansInfo.setWorkerId(workerId);
      teamFansInfo.setPhoneOpen(phoneOpen);
      save(teamFansInfo);
      update(teamFansInfo);
   }

   @Override
@@ -377,7 +358,7 @@
      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
@@ -389,8 +370,22 @@
      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) {