From cd637932a970e7935b17d41568fe89c92775bccc Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 06 十二月 2019 17:18:27 +0800
Subject: [PATCH] 双12活动添加,邀请码发布修改,爬单新规则添加

---
 fanli/src/main/java/com/yeshi/fanli/controller/admin/ExtractAdminController.java |  100 +++++++++++++++++++++++++++++++++++++++-----------
 1 files changed, 78 insertions(+), 22 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/controller/admin/ExtractAdminController.java b/fanli/src/main/java/com/yeshi/fanli/controller/admin/ExtractAdminController.java
index 5f4b31a..f99b69a 100644
--- a/fanli/src/main/java/com/yeshi/fanli/controller/admin/ExtractAdminController.java
+++ b/fanli/src/main/java/com/yeshi/fanli/controller/admin/ExtractAdminController.java
@@ -22,11 +22,11 @@
 import org.springframework.web.bind.annotation.RequestMethod;
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.multipart.commons.CommonsMultipartFile;
-import org.yeshi.utils.CsvUtil;
 import org.yeshi.utils.DateUtil;
 import org.yeshi.utils.IPUtil;
 import org.yeshi.utils.JsonUtil;
 import org.yeshi.utils.entity.wx.RedPackRecord;
+import org.yeshi.utils.wx.WXRedPackUtil;
 
 import com.google.gson.Gson;
 import com.google.gson.GsonBuilder;
@@ -445,22 +445,25 @@
 					record.setExtraInfoStr(desc.toString());
 				}
 
-				if (warnLevel == 0) {
-					// 鏌ヨ鍚屽簵閾哄晢鍝侊紝鍚屽晢鍝佽鍗曡秴杩囦竴瀹氭暟閲忕殑
-					List<Integer> typeList = new ArrayList<>();
-					typeList.add(HongBaoV2.TYPE_ZIGOU);
-					long sameGoodsOrderCount = commonOrderCountService.countSameGoodsOrderByUidAndHongBaoType(typeList,
-							record.getExtract().getUserInfo().getId(),
-							Integer.parseInt(configService.get("admin_min_same_goods_order_count")));
-					long sameShopOrderCount = commonOrderCountService.countSameShopOrderByUidAndHongBaoType(typeList,
-							record.getExtract().getUserInfo().getId(),
-							Integer.parseInt(configService.get("admin_min_same_shop_order_count")));
-					if (sameGoodsOrderCount > 0 || sameShopOrderCount > 0) {
-						warnLevel = 3;
-						record.setExtraInfoStr(
-								String.format("鍚屽簵閾�:%s   鍚屽晢鍝�:%s", sameShopOrderCount, sameGoodsOrderCount));
-					}
-				}
+				// if (warnLevel == 0) {
+				// // 鏌ヨ鍚屽簵閾哄晢鍝侊紝鍚屽晢鍝佽鍗曡秴杩囦竴瀹氭暟閲忕殑
+				// List<Integer> typeList = new ArrayList<>();
+				// typeList.add(HongBaoV2.TYPE_ZIGOU);
+				// long sameGoodsOrderCount =
+				// commonOrderCountService.countSameGoodsOrderByUidAndHongBaoType(typeList,
+				// record.getExtract().getUserInfo().getId(),
+				// Integer.parseInt(configService.get("admin_min_same_goods_order_count")));
+				// long sameShopOrderCount =
+				// commonOrderCountService.countSameShopOrderByUidAndHongBaoType(typeList,
+				// record.getExtract().getUserInfo().getId(),
+				// Integer.parseInt(configService.get("admin_min_same_shop_order_count")));
+				// if (sameGoodsOrderCount > 0 || sameShopOrderCount > 0) {
+				// warnLevel = 3;
+				// record.setExtraInfoStr(
+				// String.format("鍚屽簵閾�:%s 鍚屽晢鍝�:%s", sameShopOrderCount,
+				// sameGoodsOrderCount));
+				// }
+				// }
 
 				record.setWarnLevel(warnLevel);
 
@@ -486,6 +489,27 @@
 			e.printStackTrace();
 			out.print(JsonUtil.loadFalseResult(e.getMessage()));
 		}
+	}
+
+	@RequestMapping(value = "getMyAuditedDanger")
+	public void getMyAuditedDanger(String callback, Long uid, PrintWriter out) {
+		if (uid == null) {
+			JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璇风櫥褰�"));
+			return;
+		}
+		// 鏌ヨ鍚屽簵閾哄晢鍝侊紝鍚屽晢鍝佽鍗曡秴杩囦竴瀹氭暟閲忕殑
+		List<Integer> typeList = new ArrayList<>();
+		typeList.add(HongBaoV2.TYPE_ZIGOU);
+		long sameGoodsOrderCount = commonOrderCountService.countSameGoodsOrderByUidAndHongBaoType(typeList, uid,
+				Integer.parseInt(configService.get("admin_min_same_goods_order_count")));
+		long sameShopOrderCount = commonOrderCountService.countSameShopOrderByUidAndHongBaoType(typeList, uid,
+				Integer.parseInt(configService.get("admin_min_same_shop_order_count")));
+		if (sameGoodsOrderCount > 0 || sameShopOrderCount > 0) {
+			String text = (String.format("鍚屽簵閾�:%s 鍚屽晢鍝�:%s", sameShopOrderCount, sameGoodsOrderCount));
+			JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(text));
+			return;
+		}
+		JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("搴楅摵/鍟嗗搧鏃犲紓甯�"));
 	}
 
 	/**
@@ -1083,10 +1107,18 @@
 		}
 	}
 
+	/**
+	 * 涓嬭浇鎻愮幇绾㈠寘Openid
+	 * 
+	 * @param callback
+	 * @param response
+	 * @param out
+	 */
 	@RequestMapping(value = "downAutoExtractTxt")
 	public void downAutoExtractTxt(String callback, HttpServletResponse response, PrintWriter out) {
 		try {
-			List<String> list = extractService.getAutoExtractOpenIds();
+			//List<String> list = extractService.getAutoExtractOpenIds();
+			List<String> list = extractService.getAutoExtractOpenIdsTo1212();
 			if (list == null || list.size() <= 1) {
 				JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏆傛棤鐢ㄦ埛婊¤冻鑷姩鎻愮幇鏉′欢"));
 				return;
@@ -1120,6 +1152,12 @@
 		}
 	}
 
+	/**
+	 * 涓婁紶鎻愮幇绾㈠寘Excel
+	 * 
+	 * @param file
+	 * @param out
+	 */
 	@RequestMapping(value = "uploadExcel", method = RequestMethod.POST)
 	public void uploadExcel(@RequestParam("file") CommonsMultipartFile file, PrintWriter out) {
 		if (file == null) {
@@ -1128,7 +1166,7 @@
 		}
 
 		try {
-			List<RedPackRecord> list = CsvUtil.getCsvData(file, RedPackRecord.class);
+			List<RedPackRecord> list = WXRedPackUtil.readCsv(file.getInputStream());
 			extractService.updateManualExtractRecord(list);
 			out.print(JsonUtil.loadTrueResult("涓婁紶鎴愬姛"));
 		} catch (ExtractException e) {
@@ -1139,10 +1177,27 @@
 		}
 	}
 
+	
+	public static String getValue(String[] item,int index){
+        if(item.length > index){
+            String value = item[index];
+            return value;
+        }
+        return "";
+    }
+	
+	/**
+	 * 棰勮绾㈠寘鍙戠敓浜�
+	 * 
+	 * @param callback
+	 * @param pageIndex
+	 * @param out
+	 */
 	@RequestMapping(value = "preAutoUser")
-	public void preAutoUser(String callback, Integer pageIndex, Integer pageSize, PrintWriter out) {
+	public void preAutoUser(String callback, Integer pageIndex, PrintWriter out) {
 		try {
-			List<UserInfo> list = extractService.preAutoUser();
+			//List<UserInfo> list = extractService.preAutoUser();
+			List<UserInfo> list = extractService.preAutoUserTo1212();
 			if (list == null || list.isEmpty()) {
 				JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏆傛棤鐢ㄦ埛婊¤冻鑷姩鎻愮幇鏉′欢"));
 				return;
@@ -1152,6 +1207,7 @@
 				pageIndex = 1;
 			}
 
+			Integer pageSize = 100;
 			if (pageSize == null || pageSize < 1) {
 				pageSize = Constant.PAGE_SIZE;
 			}
@@ -1180,5 +1236,5 @@
 			e.printStackTrace();
 		}
 	}
-
 }
+	

--
Gitblit v1.8.0