| | |
| | | @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); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * 初始化数据 |
| | |
| | | |
| | | @Override |
| | | public void addFansInfo(Long workerId, Long bossId, Date successTime) { |
| | | |
| | | LogHelper.test("addFansInfo-新增-" + workerId); |
| | | |
| | | UserInfo userInfo = userInfoService.selectByPKey(workerId); |
| | | if (userInfo == null) { |
| | | return; |
| | |
| | | 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) { |
| | |
| | | } 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) { |
| | |
| | | } 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); |
| | |
| | | } 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; |
| | | } |
| | |
| | | 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) { |