From 88b54772dbcf5ecab1e2316e4e4626ac901b8908 Mon Sep 17 00:00:00 2001
From: yujian <yujian>
Date: 星期二, 22 一月 2019 15:58:24 +0800
Subject: [PATCH] 邀请码添加返回状态

---
 fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserShareGoodsRecordServiceImpl.java |  328 ++++++++++++++++++++++++++----------------------------
 1 files changed, 158 insertions(+), 170 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserShareGoodsRecordServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserShareGoodsRecordServiceImpl.java
index 4a73724..eb3e76b 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserShareGoodsRecordServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserShareGoodsRecordServiceImpl.java
@@ -61,31 +61,31 @@
 
 	@Resource(name = "taskExecutor")
 	private TaskExecutor executor;
-	
+
 	@Resource
 	private ConfigService configService;
-	
+
 	@Resource
 	private RedisManager redisManager;
-	
+
 	@Resource
 	private UserInfoMapper userInfoMapper;
-	
+
 	@Resource
 	private UserAccountService userAccountService;
-	
+
 	@Resource
 	private UserShareGoodsRecordMapper userShareGoodsRecordMapper;
-	
+
 	@Resource
 	private CommonGoodsService commonGoodsService;
-	
+
 	@Resource
 	private UserShareGoodsGroupService userShareGoodsGroupService;
-	
+
 	@Resource
 	private HongBaoManageService hongBaoManageService;
-	
+
 	@Resource
 	private UserGoodsStorageService userGoodsStorageService;
 
@@ -109,7 +109,6 @@
 		return userShareGoodsRecordMapper.updateByPrimaryKeySelective(record);
 	}
 
-
 	@Override
 	public List<UserShareGoodsRecord> listQueryByUid(long start, int count, Long uid, String source) {
 		return userShareGoodsRecordMapper.listQueryByUid(start, count, uid, source);
@@ -119,53 +118,51 @@
 	public long countQueryByUid(Long uid, String source) {
 		return userShareGoodsRecordMapper.countQueryByUid(uid, source);
 	}
-	
-	
+
 	@Override
 	public List<UserShareGoodsRecord> listCountRecord(List<Long> list) {
 		return userShareGoodsRecordMapper.listCountRecord(list);
 	}
-	
+
 	@Override
 	public List<UserShareGoodsRecord> getMyShareGoodsRecords(long start, int count, Long uid, String source) {
-		
+
 		List<UserShareGoodsRecord> list = listQueryByUid(start, count, uid, source);
 		if (list == null) {
 			list = new ArrayList<UserShareGoodsRecord>();
 		}
-		
+
 		if (list.size() > 0) {
 			List<Long> listId = new ArrayList<Long>();
-			
-			for (UserShareGoodsRecord userShareGoodsRecord: list) {
+
+			for (UserShareGoodsRecord userShareGoodsRecord : list) {
 				userShareGoodsRecord.setShareTime(userShareGoodsRecord.getUpdateTime().getTime());
 				userShareGoodsRecord.setCreateTime(null);
 				userShareGoodsRecord.setUpdateTime(null);
 				listId.add(userShareGoodsRecord.getId());
-				
+
 				// 鏀瑰彉鍥剧墖灏哄
 				String pictUrl = userShareGoodsRecord.getPicture();
 				if (!StringUtil.isNullOrEmpty(pictUrl) && !pictUrl.contains("320x320")) {
 					userShareGoodsRecord.setPicture(TbImgUtil.getTBSize320Img(pictUrl));
 				}
-				
-				
+
 			}
-			
+
 			// 浠婃棩娴忚缁熻
-			List<UserShareGoodsRecord> listTodayBrowse= userShareGoodsRecordMapper.listCountTodayBrowse(listId);
-			
+			List<UserShareGoodsRecord> listTodayBrowse = userShareGoodsRecordMapper.listCountTodayBrowse(listId);
+
 			// 璁㈠崟銆佹祻瑙堟暟閲忋�侀噾棰濈粺璁�
 			List<UserShareGoodsRecord> listCountRecord = listCountRecord(listId);
-			
+
 			if ((listCountRecord != null && listCountRecord.size() > 0)
-				|| (listTodayBrowse != null && listTodayBrowse.size() > 0)) {
-				
-				for (UserShareGoodsRecord shareRecord: list) {
-					Long id = shareRecord.getId() ;
-					
-					if (listTodayBrowse != null && listTodayBrowse.size() > 0){
-						for (UserShareGoodsRecord goodsRecord: listTodayBrowse) {
+					|| (listTodayBrowse != null && listTodayBrowse.size() > 0)) {
+
+				for (UserShareGoodsRecord shareRecord : list) {
+					Long id = shareRecord.getId();
+
+					if (listTodayBrowse != null && listTodayBrowse.size() > 0) {
+						for (UserShareGoodsRecord goodsRecord : listTodayBrowse) {
 							Long recordId = goodsRecord.getId();
 							if (id == recordId || id.equals(recordId)) {
 								shareRecord.setTodayBrowse(goodsRecord.getTodayBrowse());
@@ -173,23 +170,22 @@
 							}
 						}
 					}
-					
+
 					if (listCountRecord != null && listCountRecord.size() > 0) {
-						for (UserShareGoodsRecord goodsRecord: listCountRecord) {
+						for (UserShareGoodsRecord goodsRecord : listCountRecord) {
 							Long recordId = goodsRecord.getId();
 							if (id == recordId || id.equals(recordId)) {
 								shareRecord.setTotalBrowse(goodsRecord.getTotalBrowse());
 								shareRecord.setTotalOrder(goodsRecord.getTotalOrder());
-								
+
 								BigDecimal totalMoney = goodsRecord.getTotalMoney();
-								if (totalMoney != null && totalMoney.compareTo(new BigDecimal(0))>0 ) {
+								if (totalMoney != null && totalMoney.compareTo(new BigDecimal(0)) > 0) {
 									shareRecord.setTotalMoney(goodsRecord.getTotalMoney());
 								} else {
 									shareRecord.setTotalMoney(goodsRecord.getRevenueMoney());
 								}
 								shareRecord.setRevenueMoney(null);
-								
-								
+
 								Integer totalGoods = goodsRecord.getTotalGoods();
 								shareRecord.setTotalGoods(totalGoods);
 								if (totalGoods > 1) {
@@ -204,29 +200,28 @@
 				}
 			}
 		}
-		
+
 		return list;
 	}
-	
 
 	@Override
 	public void saveDetail(Long uid, Long auctionId, String type) throws UserShareGoodsRecordException {
-		
+
 		if (auctionId == null) {
 			throw new UserShareGoodsRecordException(1, "鍒嗕韩鍟嗗搧涓嶈兘涓虹┖");
 		}
-		
+
 		if (uid == null) {
 			throw new UserShareGoodsRecordException(1, "鐢ㄦ埛ID涓嶈兘涓虹┖");
 		}
-		
+
 		TaoBaoGoodsBrief goodsBrief = null;
 		try {
 			goodsBrief = redisManager.getTaoBaoGoodsBrief(auctionId);
 		} catch (TaobaoGoodsDownException e) {
 			throw new UserShareGoodsRecordException(1, "鍟嗗搧宸蹭笅鏋�");
 		}
-		
+
 		UserShareGoodsRecord userShareGoodsRecord = new UserShareGoodsRecord();
 		userShareGoodsRecord.setUid(uid);
 		userShareGoodsRecord.setSource(ShareSourceTypeEnum.goodsDetail);
@@ -234,22 +229,23 @@
 		// 鍗曚釜鍟嗗搧鍒嗕韩
 		singleGoodsShare(userShareGoodsRecord, goodsBrief);
 	}
-	
+
 	@Override
-	public void save(Long uid, ShareSourceTypeEnum source, String title, TaoBaoGoodsBrief taoBaoGoodsBrief) throws UserShareGoodsRecordException {
-		
+	public void save(Long uid, ShareSourceTypeEnum source, String title, TaoBaoGoodsBrief taoBaoGoodsBrief)
+			throws UserShareGoodsRecordException {
+
 		if (taoBaoGoodsBrief == null) {
 			throw new UserShareGoodsRecordException(1, "鍒嗕韩鍟嗗搧涓嶈兘涓虹┖");
 		}
-		
+
 		if (uid == null) {
 			throw new UserShareGoodsRecordException(1, "鐢ㄦ埛ID涓嶈兘涓虹┖");
 		}
-		
+
 		if (source == null) {
 			throw new UserShareGoodsRecordException(1, "鍒嗕韩鏉ユ簮涓嶈兘涓虹┖");
 		}
-		
+
 		UserShareGoodsRecord userShareGoodsRecord = new UserShareGoodsRecord();
 		userShareGoodsRecord.setUid(uid);
 		userShareGoodsRecord.setSource(source);
@@ -257,92 +253,92 @@
 		// 鍗曚釜鍟嗗搧鍒嗕韩
 		singleGoodsShare(userShareGoodsRecord, taoBaoGoodsBrief);
 	}
-	
-	
+
 	/**
 	 * 淇濆瓨鍒嗕韩璁板綍
-	 * @param userShareGoodsRecord 鍒嗕韩璁板綍锛� uid銆乸icture銆乻ource 涓哄繀杈撳叆
+	 * 
+	 * @param userShareGoodsRecord
+	 *            鍒嗕韩璁板綍锛� uid銆乸icture銆乻ource 涓哄繀杈撳叆
 	 * @throws UserShareGoodsRecordException
 	 */
 	@Override
-	public Map<String,Object> save(Long uid, ShareSourceTypeEnum source, String title, List<TaoBaoGoodsBrief> listGoods) throws UserShareGoodsRecordException {
-		
+	public Map<String, Object> save(Long uid, ShareSourceTypeEnum source, String title,
+			List<TaoBaoGoodsBrief> listGoods) throws UserShareGoodsRecordException {
+
 		if (listGoods == null || listGoods.size() < 0) {
 			throw new UserShareGoodsRecordException(1, "鍒嗕韩鍟嗗搧鏁伴噺涓嶈冻");
 		}
-		
+
 		if (uid == null) {
 			throw new UserShareGoodsRecordException(1, "鐢ㄦ埛ID涓嶈兘涓虹┖");
 		}
-		
+
 		if (source == null) {
 			throw new UserShareGoodsRecordException(1, "鍒嗕韩鏉ユ簮涓嶈兘涓虹┖");
 		}
-		
+
 		UserShareGoodsRecord userShareGoodsRecord = new UserShareGoodsRecord();
 		userShareGoodsRecord.setUid(uid);
 		userShareGoodsRecord.setSource(source);
 		userShareGoodsRecord.setTitle(title);
 		// 鍙栦竴涓晢鍝佸浘鐗囦綔涓轰富鍥�
 		userShareGoodsRecord.setPicture(listGoods.get(0).getPictUrl());
-		
+
 		Date date = new Date();
 		userShareGoodsRecord.setShareState(0); // 鍒濆鏈垎浜�
 		userShareGoodsRecord.setCreateTime(date);
 		userShareGoodsRecord.setUpdateTime(date);
 		userShareGoodsRecordMapper.insertSelective(userShareGoodsRecord);
-		
-		
-		Map<String,Object> map = new HashMap<String,Object>();
+
+		Map<String, Object> map = new HashMap<String, Object>();
 		// 澶氫釜鍟嗗搧鍒嗕韩
 		FileUploadResult loadResult = multipleGoodsShare(userShareGoodsRecord, listGoods);
 		map.put("loadResult", loadResult);
 		map.put("shareId", userShareGoodsRecord.getId());
-		
+
 		return map;
 	}
-	
+
 	/**
 	 * 鍗曚釜鍟嗗搧鍒嗕韩鐢熸垚璁板綍
+	 * 
 	 * @param userShareGoodsRecord
 	 * @param taoBaoGoodsBrief
 	 */
 	@Transactional
 	public void singleGoodsShare(UserShareGoodsRecord userShareGoodsRecord, TaoBaoGoodsBrief taoBaoGoodsBrief) {
-	
+
 		CommonGoods commonGoods = CommonGoodsFactory.create(taoBaoGoodsBrief);
 		commonGoods.setState(taoBaoGoodsBrief.getState());
 		try {
 			CommonGoods resultCommonGoods = commonGoodsService.addOrUpdateCommonGoods(commonGoods);
-			
+
 			if (resultCommonGoods == null) {
 				return;
 			}
-			
-			
+
 			UserShareGoodsGroup singleGoods = userShareGoodsGroupService.getSingleGoods(resultCommonGoods.getId(),
 					userShareGoodsRecord.getUid());
-			
+
 			if (singleGoods != null) {
 				// 鍗曚釜鍟嗗搧澶氭鍒嗕韩
 				userShareGoodsRecord.setPicture(taoBaoGoodsBrief.getPictUrl());
 				userShareGoodsRecord.setId(singleGoods.getRecordId());
 				userShareGoodsRecord.setUpdateTime(new Date());
 				userShareGoodsRecordMapper.updateByPrimaryKeySelective(userShareGoodsRecord);
-				
+
 				// 鏈�鏂板晢鍝�
 				singleGoods.setUpdateTime(new Date());
 				userShareGoodsGroupService.updateByPrimaryKeySelective(singleGoods);
-				
-			} else 
-			{
+
+			} else {
 				// 鍗曚釜鍟嗗搧绗竴娆″垎浜�
 				Date date = new Date();
 				userShareGoodsRecord.setPicture(taoBaoGoodsBrief.getPictUrl());
 				userShareGoodsRecord.setCreateTime(date);
 				userShareGoodsRecord.setUpdateTime(date);
 				userShareGoodsRecordMapper.insertSelective(userShareGoodsRecord);
-				
+
 				singleGoods = new UserShareGoodsGroup();
 				singleGoods.setTotalOrder(0);
 				singleGoods.setTotalBrowse(0);
@@ -352,42 +348,43 @@
 				singleGoods.setUpdateTime(date);
 				singleGoods.setCommonGoods(resultCommonGoods);
 				singleGoods.setRecordId(userShareGoodsRecord.getId());
-				
+
 				userShareGoodsGroupService.insertSelective(singleGoods);
 			}
-			
+
 		} catch (CommonGoodsException e) {
 			e.printStackTrace();
 		}
-		
+
 	}
-	
-	
+
 	/**
 	 * 澶氫釜鍟嗗搧鍒嗕韩鐢熸垚璁板綍
+	 * 
 	 * @param userShareGoodsRecord
 	 * @param listGoods
 	 */
 	@Transactional
-	public FileUploadResult multipleGoodsShare(UserShareGoodsRecord userShareGoodsRecord, List<TaoBaoGoodsBrief> listGoods) throws UserShareGoodsRecordException {
-		
+	public FileUploadResult multipleGoodsShare(UserShareGoodsRecord userShareGoodsRecord,
+			List<TaoBaoGoodsBrief> listGoods) throws UserShareGoodsRecordException {
+
 		// 鍒嗕韩璁板綍
 		Date date = new Date();
-		
+
 		List<TaoBaoGoodsBrief> listGoodsBrief = new ArrayList<TaoBaoGoodsBrief>();
 		List<UserShareGoodsGroup> listGroup = new ArrayList<UserShareGoodsGroup>();
-		
-		for (TaoBaoGoodsBrief taoBaoGoodsBrief: listGoods) {
+
+		for (TaoBaoGoodsBrief taoBaoGoodsBrief : listGoods) {
 			CommonGoods commonGoods = CommonGoodsFactory.create(taoBaoGoodsBrief);
 			commonGoods.setState(taoBaoGoodsBrief.getState());
 			try {
 				CommonGoods resultCommonGoods = commonGoodsService.addOrUpdateCommonGoods(commonGoods);
-			
+
 				if (resultCommonGoods != null) {
-					TaoBaoGoodsBrief goodsBrief =  TaoBaoUtil.convert(resultCommonGoods);
+					TaoBaoGoodsBrief goodsBrief = TaoBaoUtil.convert(resultCommonGoods);
 					listGoodsBrief.add(goodsBrief);
 				}
-				
+
 				UserShareGoodsGroup shareGoodsGroup = new UserShareGoodsGroup();
 				shareGoodsGroup.setTotalOrder(0);
 				shareGoodsGroup.setTotalBrowse(0);
@@ -397,44 +394,48 @@
 				shareGoodsGroup.setUpdateTime(date);
 				shareGoodsGroup.setCommonGoods(resultCommonGoods);
 				shareGoodsGroup.setRecordId(userShareGoodsRecord.getId());
-				
-				
+
 				listGroup.add(shareGoodsGroup);
-				
+
 			} catch (CommonGoodsException e) {
 				e.printStackTrace();
 				continue;
 			}
 		}
-		
+
 		FileUploadResult shareImg = createShareImg(userShareGoodsRecord, listGoodsBrief);
-		
+
 		if (listGroup.size() > 0) {
 			userShareGoodsGroupService.insertBatch(listGroup);
 		}
-		
+
 		return shareImg;
 	}
-	
+
 	/**
 	 * 鐢熸垚鍒嗕韩鍥�
-	 * @param uid 鐢ㄦ埛id
-	 * @param shareId 鍒嗕韩璁板綍id
-	 * @param source  鏉ユ簮
+	 * 
+	 * @param uid
+	 *            鐢ㄦ埛id
+	 * @param shareId
+	 *            鍒嗕韩璁板綍id
+	 * @param source
+	 *            鏉ユ簮
 	 * @param listGoods
 	 * @return
 	 * @throws UserShareGoodsRecordException
 	 */
-	public FileUploadResult createShareImg (UserShareGoodsRecord shareRecord, List<TaoBaoGoodsBrief> listGoods) 
-			throws UserShareGoodsRecordException{
-		
+	public FileUploadResult createShareImg(UserShareGoodsRecord shareRecord, List<TaoBaoGoodsBrief> listGoods)
+			throws UserShareGoodsRecordException {
+
 		Long uid = shareRecord.getUid();
 		Long shareId = shareRecord.getId();
 		String source = shareRecord.getSource().name();
-		
-		String url = String.format("http://%s/share_mushGoods.html?uid=%s&shareId=%s&source=%s", configService.getH5Host(),
-				AESUtil.encrypt(uid + "", Constant.UIDAESKEY), shareRecord.getId() + "", source +"");
-		
+
+		String url = String.format("http://%s/share_mushGoods.html?uid=%s&shareId=%s&source=%s",
+				configService.getH5Host(), AESUtil.encrypt(uid + "", Constant.UIDAESKEY), shareRecord.getId() + "",
+				source + "");
+
 		String shortLink = HttpUtil.getShortLink(url);
 		if (!StringUtil.isNullOrEmpty(shortLink)) {
 			url = shortLink;
@@ -447,15 +448,15 @@
 		} catch (Exception e) {
 			e.printStackTrace();
 		}
-		
+
 		// 鑾峰彇鍒扮敤鎴风殑澶村儚
 		UserInfo user = userInfoMapper.selectByPrimaryKey(uid);
 		if (user == null) {
 			throw new UserShareGoodsRecordException(1, "鐢ㄦ埛淇℃伅涓嶅瓨鍦�");
 		}
-		
+
 		InputStream portrait = null;
-	
+
 		if (!StringUtil.isNullOrEmpty(user.getPortrait())) {
 			try {
 				portrait = HttpUtil.downLoadImg(user.getPortrait());
@@ -473,23 +474,22 @@
 				}
 			}
 		}
-		
+
 		InputStream inputStream = ImageUtil.drawGoodsShareBigImg(erCodeInputStream, portrait, listGoods);
-		
+
 		FileUploadResult shareImg = COSManager.getInstance().uploadInputStream(inputStream,
 				"sharegoods/share_" + uid + "_" + shareId + "_" + System.currentTimeMillis() + ".png");
-	
+
 		return shareImg;
 	}
-	
-	
+
 	@Override
 	public JSONObject getGoodsGroup(Long recordId) throws UserShareGoodsRecordException {
-		
+
 		JSONArray array = new JSONArray();
 
 		List<UserShareGoodsGroup> list = userShareGoodsGroupService.listByRecordId(recordId);
-		
+
 		List<Long> listGid = new ArrayList<Long>();
 		for (UserShareGoodsGroup goodsGroup : list) {
 			CommonGoods commonGoods = goodsGroup.getCommonGoods();
@@ -498,7 +498,7 @@
 			}
 			listGid.add(commonGoods.getGoodsId());
 		}
-		
+
 		// API缃戠粶鎺ュ彛楠岃瘉鏄惁鍦ㄥ敭
 		List<TaoBaoGoodsBrief> listTaoKeGoods = null;
 		try {
@@ -510,23 +510,22 @@
 		} catch (Exception e) {
 			e.printStackTrace();
 		}
-		
 
 		Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())
 				.excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();
 
 		BigDecimal shareRate = hongBaoManageService.getShareRate(java.lang.System.currentTimeMillis());
-		
+
 		for (UserShareGoodsGroup goodsGroup : list) {
 			CommonGoods commonGoods = goodsGroup.getCommonGoods();
 			if (commonGoods == null) {
 				continue;
 			}
-			
-			if (listTaoKeGoods != null && listTaoKeGoods.size() > 0 ) {
-				int state = 1;  // 榛樿鍋滃敭
+
+			if (listTaoKeGoods != null && listTaoKeGoods.size() > 0) {
+				int state = 1; // 榛樿鍋滃敭
 				Long goodsId = commonGoods.getGoodsId();
-				for (TaoBaoGoodsBrief taoKeGoods: listTaoKeGoods) {
+				for (TaoBaoGoodsBrief taoKeGoods : listTaoKeGoods) {
 					Long auctionId = taoKeGoods.getAuctionId();
 					if (goodsId == auctionId || goodsId.equals(auctionId)) {
 						state = 0; // 鍦ㄥ敭
@@ -535,32 +534,31 @@
 				}
 				commonGoods.setState(state);
 			}
-			
+
 			TaoBaoGoodsBrief goodsBrief = TaoBaoUtil.convert(commonGoods);
-			
+
 			// 浠婃棩娴忚璁板綍澶勭悊
 			Date date = new Date();
 			Date browseTime = goodsGroup.getBrowseTime();
 			if (!DateUtil.isSameDay(browseTime, date)) {
 				goodsGroup.setTodayBrowse(0); // 涓嶆槸鍚屼竴澶╂祻瑙堣褰曡缃�0
 			}
-			
-			
+
 			JSONObject dataObject = new JSONObject();
-			dataObject.put("todayBrowse",goodsGroup.getTodayBrowse() );
-			dataObject.put("totalBrowse",goodsGroup.getTotalBrowse() );
+			dataObject.put("todayBrowse", goodsGroup.getTodayBrowse());
+			dataObject.put("totalBrowse", goodsGroup.getTotalBrowse());
 			dataObject.put("totalOrder", goodsGroup.getTotalOrder());
-			dataObject.put("totalMoney", "楼"+goodsGroup.getTotalMoney());
-			dataObject.put("goods", gson.toJson(TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief, shareRate+"", null)));
+			dataObject.put("totalMoney", "楼" + goodsGroup.getTotalMoney());
+			dataObject.put("goods", gson.toJson(TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief, shareRate + "", null)));
 			array.add(dataObject);
 		}
-		
+
 		String title = "";
 		UserShareGoodsRecord userShareGoodsRecord = userShareGoodsRecordMapper.selectByPrimaryKey(recordId);
-		if(userShareGoodsRecord != null) {
+		if (userShareGoodsRecord != null) {
 			title = userShareGoodsRecord.getTitle();
 		}
-		
+
 		JSONObject data = new JSONObject();
 		data.put("title", title);
 		data.put("count", list.size());
@@ -568,16 +566,13 @@
 		return data;
 	}
 
-	
 	@Override
 	public JSONObject getGoodsGroupDetail(Long recordId) throws UserShareGoodsRecordException {
-		
-		List<CommonGoods> listUpadteCommonGoods = new ArrayList<CommonGoods>();
 
 		JSONArray array = new JSONArray();
-		
+
 		List<UserShareGoodsGroup> list = userShareGoodsGroupService.listByRecordId(recordId);
-		
+
 		if (list != null && list.size() > 0) {
 
 			List<Long> listGid = new ArrayList<Long>();
@@ -588,7 +583,7 @@
 				}
 				listGid.add(commonGoods.getGoodsId());
 			}
-			
+
 			// API缃戠粶鎺ュ彛楠岃瘉鏄惁鍦ㄥ敭
 			List<TaoBaoGoodsBrief> listTaoKeGoods = null;
 			try {
@@ -600,23 +595,22 @@
 			} catch (Exception e) {
 				e.printStackTrace();
 			}
-			
-			
+
 			Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())
 					.excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();
-			
+
 			BigDecimal shareRate = hongBaoManageService.getShareRate(java.lang.System.currentTimeMillis());
-			
+
 			for (UserShareGoodsGroup goodsGroup : list) {
 				CommonGoods commonGoods = goodsGroup.getCommonGoods();
 				if (commonGoods == null) {
 					continue;
 				}
-				
-				if (listTaoKeGoods != null && listTaoKeGoods.size() > 0 ) {
-					int state = 1;  // 榛樿鍋滃敭
+
+				if (listTaoKeGoods != null && listTaoKeGoods.size() > 0) {
+					int state = 1; // 榛樿鍋滃敭
 					Long goodsId = commonGoods.getGoodsId();
-					for (TaoBaoGoodsBrief taoKeGoods: listTaoKeGoods) {
+					for (TaoBaoGoodsBrief taoKeGoods : listTaoKeGoods) {
 						Long auctionId = taoKeGoods.getAuctionId();
 						if (goodsId == auctionId || goodsId.equals(auctionId)) {
 							state = 0; // 鍦ㄥ敭
@@ -625,57 +619,51 @@
 					}
 					commonGoods.setState(state);
 				}
-				
+
 				TaoBaoGoodsBrief goodsBrief = TaoBaoUtil.convert(commonGoods);
-				
+
 				if (goodsBrief.getCouponLeftCount() < 1 || StringUtil.isNullOrEmpty(goodsBrief.getCouponInfo())) {
-    				goodsBrief.setState(1); // 宸叉姠鍏�
-    			}
-				
-				TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief, shareRate +"", null);
+					goodsBrief.setState(1); // 宸叉姠鍏�
+				}
+
+				TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief,
+						shareRate + "", null);
 				array.add(gson.toJson(taoBaoGoodsBriefExtra));
 			}
 
 		}
-		
+
 		String title = "";
 		UserShareGoodsRecord userShareGoodsRecord = userShareGoodsRecordMapper.selectByPrimaryKey(recordId);
-		if(userShareGoodsRecord != null) {
+		if (userShareGoodsRecord != null) {
 			title = userShareGoodsRecord.getTitle();
 		}
-		
+
 		JSONObject data = new JSONObject();
 		data.put("title", title);
 		data.put("count", list.size());
 		data.put("result_list", array);
 
-		if (listUpadteCommonGoods.size() > 0) {
-			executor.execute(new Runnable() {
-				@Override
-				public void run() {
-					try {
-						// 鏇存柊绠�鐗堜俊鎭�
-						commonGoodsService.updateBatchCommonGoods(listUpadteCommonGoods);
-					} catch (Exception e) {
-						e.printStackTrace();
-					}
-				}
-			});
-		}
-		
 		return data;
 	}
 
 	@Override
-	public void updateShareRecord (Long shareId) throws UserShareGoodsRecordException {
+	public void updateShareRecord(Long shareId) throws UserShareGoodsRecordException {
 		UserShareGoodsRecord shareRecord = userShareGoodsRecordMapper.selectByPrimaryKey(shareId);
 		if (shareRecord == null) {
 			throw new UserShareGoodsRecordException(1, "鍒嗕韩璁板綍涓嶅瓨鍦�");
 		}
-		
+
 		shareRecord.setShareState(1);// 鍒嗕韩鐢熸晥
 		updateByPrimaryKeySelective(shareRecord);
 		// 鏇存柊鍟嗗搧涓哄凡鍒嗕韩
 		userGoodsStorageService.updateShareState(shareId);
 	}
+
+	@Override
+	public long countShareRecordByUid(Long uid) {
+
+		return userShareGoodsRecordMapper.countQueryByUid(uid, null);
+
+	}
 }

--
Gitblit v1.8.0