From 30d8e227e8d823b6c38c3b9c90ac2df03b63befe Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期二, 25 二月 2025 16:41:22 +0800 Subject: [PATCH] 淘宝转链接口更新 --- fanli/src/main/java/com/yeshi/fanli/service/impl/user/invite/TeamFansInfoServiceImpl.java | 162 +++++++++++++++++++++++++++++------------------------- 1 files changed, 87 insertions(+), 75 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/invite/TeamFansInfoServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/invite/TeamFansInfoServiceImpl.java index 7f63a40..3e4caa4 100644 --- a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/invite/TeamFansInfoServiceImpl.java +++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/invite/TeamFansInfoServiceImpl.java @@ -19,6 +19,7 @@ import com.yeshi.fanli.entity.bus.user.UserInfo; import com.yeshi.fanli.entity.bus.user.UserInfoExtra; import com.yeshi.fanli.entity.bus.user.vip.UserLevelEnum; +import com.yeshi.fanli.log.LogHelper; import com.yeshi.fanli.service.inter.count.HongBaoV2CountService; import com.yeshi.fanli.service.inter.order.CommonOrderService; import com.yeshi.fanli.service.inter.user.UserActiveLogService; @@ -37,68 +38,48 @@ @Resource private TeamFansInfoDao teamFansInfoDao; - + @Resource private ThreeSaleSerivce threeSaleSerivce; - + @Resource - private UserInfoService userInfoService; - + private UserInfoService userInfoService; + @Resource private UserInfoExtraService userInfoExtraService; - + @Resource private ThreeSaleExtraInfoSerivce threeSaleExtraInfoSerivce; - + @Resource private UserExtraTaoBaoInfoService userExtraTaoBaoInfoService; - + @Resource private HongBaoV2CountService hongBaoV2CountService; - + @Resource private UserInviteService userInviteService; - + @Resource private CommonOrderService commonOrderService; - + @Resource private UserActiveLogService userActiveLogService; - - - - @Override - public void save(TeamFansInfo record) { - if (record == null || record.getWorkerId() == null ) { - return; - } - record.setId(record.getWorkerId().toString()); - - TeamFansInfo teamFansInfo = teamFansInfoDao.get(record.getId()); - if (teamFansInfo != null) { - teamFansInfoDao.updateSelective(record); - } else { - initData(record); - record.setCrateTime(new Date()); - teamFansInfoDao.save(record); - } - } - - + /** * 鍒濆鍖栨暟鎹� * @param record */ private void initData(TeamFansInfo record) { if (StringUtil.isNullOrEmpty(record.getNickName())) - record.setNickName(""); + record.setNickName(""); if (record.getLevel() == null) - record.setLevel(UserLevelEnum.daRen); + record.setLevel(UserLevelEnum.daRen); if (record.getStateValid() == null) record.setStateValid(false); if (record.getTaobaoBind() == null) - record.setTaobaoBind(false); + record.setTaobaoBind(false); if (record.getWeixinId() == null) record.setWeixinId(""); if (record.getPhone() == null) @@ -123,17 +104,20 @@ record.setMemoNameSup(""); if (record.getTagsSup() == null) record.setTagsSup(""); - + if (StringUtil.isNullOrEmpty(record.getWeixinId())) { record.setWeixinIdExist(false); } else { record.setWeixinIdExist(true); } - + } - + @Override public void addFansInfo(Long workerId, Long bossId, Date successTime) { + + LogHelper.test("addFansInfo-鏂板-" + workerId); + UserInfo userInfo = userInfoService.selectByPKey(workerId); if (userInfo == null) { return; @@ -146,8 +130,7 @@ // 澶囨敞鍚� String memoName = null; - ThreeSaleExtraInfo threeSaleExtraInfo = threeSaleExtraInfoSerivce.getbyBossIdAndWorkerId(bossId, - workerId); + ThreeSaleExtraInfo threeSaleExtraInfo = threeSaleExtraInfoSerivce.getbyBossIdAndWorkerId(bossId, workerId); if (threeSaleExtraInfo != null) { if (!StringUtil.isNullOrEmpty(threeSaleExtraInfo.getNickname())) { memoName = threeSaleExtraInfo.getNickname(); @@ -244,12 +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) { @@ -257,12 +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) { @@ -270,46 +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); @@ -318,80 +308,102 @@ } 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 teamFansInfo = new TeamFansInfo(); 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) { return teamFansInfoDao.query(start, count, type, uid, focusDTO); } - + @Override public long count(int type, Long uid, ThreeSaleFocusDTO focusDTO) { return teamFansInfoDao.count(type, uid, focusDTO); } - + @Override public TeamFansInfo getbyWorkerId(Long workerId) { return teamFansInfoDao.getbyWorkerId(workerId); } + + @Override + public List<TeamFansInfo> queryByUserInfo(String key) { + return teamFansInfoDao.queryByUserInfo(key); + } } -- Gitblit v1.8.0