From 9eeda0d3049b71877c373c04d65533939b5582ef Mon Sep 17 00:00:00 2001
From: yujian <yujian@123.com>
Date: 星期一, 02 九月 2019 09:55:55 +0800
Subject: [PATCH] getBoss方法只查询有效上级信息

---
 fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TLJBuyGoodsServiceImpl.java |   26 ++++++++++++++++++++++----
 1 files changed, 22 insertions(+), 4 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TLJBuyGoodsServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TLJBuyGoodsServiceImpl.java
index 6a9dd20..eadb46c 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TLJBuyGoodsServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TLJBuyGoodsServiceImpl.java
@@ -3,6 +3,7 @@
 import java.math.BigDecimal;
 import java.util.ArrayList;
 import java.util.Collections;
+import java.util.Comparator;
 import java.util.Date;
 import java.util.HashMap;
 import java.util.List;
@@ -22,6 +23,7 @@
 import com.yeshi.fanli.entity.taobao.TaoKeAppInfo;
 import com.yeshi.fanli.entity.taobao.dataoke.DaTaoKeDetailV2;
 import com.yeshi.fanli.exception.taobao.TaoKeApiException;
+import com.yeshi.fanli.exception.tlj.TaoLiJinCreateException;
 import com.yeshi.fanli.service.inter.goods.TaoBaoGoodsBriefService;
 import com.yeshi.fanli.service.inter.taobao.TLJBuyGoodsService;
 import com.yeshi.fanli.service.inter.taobao.TaoBaoGoodsUpdateService;
@@ -66,6 +68,8 @@
 			goods.setUpdateTime(new Date());
 		if (taoKeAppInfo != null)
 			goods.setAppKey(taoKeAppInfo.getAppKey());
+		if (goods.getWeight() == null)
+			goods.setWeight(1);
 		tljBuyGoodsDao.save(goods);
 	}
 
@@ -96,7 +100,7 @@
 					// 杩囨护娣樼ぜ閲戝ぇ浜�10鍧楅挶鐨�
 					BigDecimal hongBao = TaoBaoUtil.getGoodsHongBaoMoney(list.get(i).getGoods(),
 							TaoBaoConstant.OWN_BUY_WITHOUT_FANLI_RATE);
-					if (hongBao.compareTo(new BigDecimal(10)) > 0) {
+					if (hongBao.compareTo(new BigDecimal(20)) > 0) {
 						list.remove(i--);
 					}
 				}
@@ -105,6 +109,14 @@
 				goodsList.addAll(list);
 		}
 		Collections.shuffle(goodsList);
+		Comparator<TLJBuyGoods> cm = new Comparator<TLJBuyGoods>() {
+
+			@Override
+			public int compare(TLJBuyGoods o1, TLJBuyGoods o2) {
+				return o1.getWeight() != null && o2.getWeight() != null ? o2.getWeight() - o1.getWeight() : 0;
+			}
+		};
+		Collections.sort(goodsList, cm);
 		return goodsList;
 	}
 
@@ -173,14 +185,15 @@
 			taoLiJinDTO = TaoKeApiUtil.createTaoLiJin(auctionId, "娣樼ぜ閲戦獙璇�", new BigDecimal("1.00"), 1, new Date(),
 					new Date(System.currentTimeMillis() + 1000 * 60 * 60 * 6), new Date(),
 					new Date(System.currentTimeMillis() + 1000 * 60 * 60 * 6), app);
-		} catch (TaoKeApiException e) {
-			if (e.getCode() == TaoKeApiException.CODE_TLJ_FORBIDDEN) {
+		} catch (TaoLiJinCreateException e1) {
+			if (e1.getCode() == TaoLiJinCreateException.CODE_TLJ_FORBIDDEN) {
 				// 璇ュ晢鍝佷笉鏀寔鍒涘缓娣樼ぜ閲戠孩鍖�
 				deleteByGoodsId(auctionId);
 				return false;
-			} else if (e.getCode() == TaoKeApiException.CODE_TLJ_NO_MONEY) {
+			} else if (e1.getCode() == TaoLiJinCreateException.CODE_TLJ_NO_MONEY) {
 				// 瀹樻柟鐜╂硶閽卞寘浣欓涓嶈冻 TODO
 			}
+		} catch (TaoKeApiException e) {
 		}
 		return true;
 	}
@@ -254,4 +267,9 @@
 		return tljBuyGoodsDao.selectByAuctionIdAndDay(auctionId, day);
 	}
 
+	@Override
+	public void removeGoods(Long auctionId) {
+		tljBuyGoodsDao.deleteByAuctionId(auctionId);
+	}
+
 }
\ No newline at end of file

--
Gitblit v1.8.0