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