From 8b505f74e1094fd67f86373ab9e9f80b54bca54e Mon Sep 17 00:00:00 2001
From: yujian <yujian@123.com>
Date: 星期五, 11 十月 2019 12:12:53 +0800
Subject: [PATCH] Merge branch 'div' of ssh://193.112.35.168:29418/fanli-server into div

---
 fanli/src/main/java/com/yeshi/fanli/controller/admin/ExtractAdminController.java |  100 ++++++++++++++++++++++++++++++--------------------
 1 files changed, 60 insertions(+), 40 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 d25c44e..7e853d1 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
@@ -16,7 +16,6 @@
 
 import org.springframework.stereotype.Controller;
 import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestMethod;
 import org.yeshi.utils.DateUtil;
 import org.yeshi.utils.IPUtil;
 import org.yeshi.utils.JsonUtil;
@@ -25,6 +24,7 @@
 import com.google.gson.GsonBuilder;
 import com.google.gson.reflect.TypeToken;
 import com.yeshi.fanli.controller.admin.utils.AdminUtils;
+import com.yeshi.fanli.dto.ChartTDO;
 import com.yeshi.fanli.entity.bus.user.Extract;
 import com.yeshi.fanli.entity.bus.user.ExtractAuditRecord;
 import com.yeshi.fanli.entity.bus.user.HongBaoV2;
@@ -36,15 +36,14 @@
 import com.yeshi.fanli.log.LogHelper;
 import com.yeshi.fanli.service.AdminUserService;
 import com.yeshi.fanli.service.inter.config.ConfigService;
-import com.yeshi.fanli.service.inter.count.ExtractCountService;
 import com.yeshi.fanli.service.inter.count.HongBaoV2CountService;
 import com.yeshi.fanli.service.inter.count.UserInfoCountService;
+import com.yeshi.fanli.service.inter.money.extract.ExtractAuditRecordService;
+import com.yeshi.fanli.service.inter.money.extract.ExtractCountService;
+import com.yeshi.fanli.service.inter.money.extract.ExtractService;
+import com.yeshi.fanli.service.inter.order.tb.TaoBaoOrderService;
+import com.yeshi.fanli.service.inter.order.tb.TaoBaoWeiQuanOrderService;
 import com.yeshi.fanli.service.inter.push.PushRecordService;
-import com.yeshi.fanli.service.inter.taobao.TaoBaoOrderService;
-import com.yeshi.fanli.service.inter.taobao.TaoBaoWeiQuanOrderService;
-import com.yeshi.fanli.service.inter.user.AccountMessageService;
-import com.yeshi.fanli.service.inter.user.ExtractAuditRecordService;
-import com.yeshi.fanli.service.inter.user.ExtractService;
 import com.yeshi.fanli.tag.PageEntity;
 import com.yeshi.fanli.util.Constant;
 import com.yeshi.fanli.util.RedisManager;
@@ -71,9 +70,6 @@
 	private ExtractCountService extractCountService;
 
 	@Resource
-	private AccountMessageService accountMessageService;
-
-	@Resource
 	private PushRecordService pushRecordService;
 
 	@Resource
@@ -96,7 +92,6 @@
 
 	@Resource
 	private TaoBaoWeiQuanOrderService taoBaoWeiQuanOrderService;
-
 
 	/**
 	 * 
@@ -131,17 +126,19 @@
 		// 鏃ュ織璁板綍
 		if (integer == null) {
 			JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("宸查�氳繃"));
-			LogHelper.userInfo("[ip:" + IPUtil.getRemotIP(request) + "]" + admin.getName() + "閫氳繃浜哰id=" + id + "]鐨勬彁鐜扮敵璇�!"); 
+			LogHelper
+					.userInfo("[ip:" + IPUtil.getRemotIP(request) + "]" + admin.getName() + "閫氳繃浜哰id=" + id + "]鐨勬彁鐜扮敵璇�!");
 		} else if (integer == 1) {
 			JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璇ユ彁鐜拌褰曞凡涓嶅瓨鍦�,璇峰埛鏂�"));
-			LogHelper.userInfo("[ip:" + IPUtil.getRemotIP(request) + "][绠$悊鍛�:" + admin.getName() + "] 鍚屾剰鎻愮幇id=" + id + "鐨勬彁鐜扮敵璇蜂笉瀛樺湪");
+			LogHelper.userInfo(
+					"[ip:" + IPUtil.getRemotIP(request) + "][绠$悊鍛�:" + admin.getName() + "] 鍚屾剰鎻愮幇id=" + id + "鐨勬彁鐜扮敵璇蜂笉瀛樺湪");
 		} else {
 			JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璇ョ敤鎴峰凡琚鐞�,璇峰埛鏂�"));
-			LogHelper.userInfo("[ip:" + IPUtil.getRemotIP(request) + "][绠$悊鍛�:" + admin.getName() + "] 鍚屾剰鎻愮幇id=" + id + "鐨勬彁鐜扮敵璇风姸鎬佸紓甯�");
+			LogHelper.userInfo(
+					"[ip:" + IPUtil.getRemotIP(request) + "][绠$悊鍛�:" + admin.getName() + "] 鍚屾剰鎻愮幇id=" + id + "鐨勬彁鐜扮敵璇风姸鎬佸紓甯�");
 		}
 
 	}
-
 
 	/**
 	 * 
@@ -170,7 +167,6 @@
 			return;
 		}
 
-
 		try {
 			// 缂栫爜杞崲
 			reason = URLDecoder.decode(reason, "UTF-8");
@@ -179,7 +175,7 @@
 		}
 
 		try {
-			
+
 			extractService.rejectExtract(id, reason, admin);// 鎻愮幇澶辫触
 
 			JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("鎷掔粷鎴愬姛"));
@@ -201,7 +197,6 @@
 		}
 
 	}
-
 
 	/**
 	 * 鑾峰彇浠婃棩鎻愮幇璁板綍锛氫粖鏃ユ�婚銆佹�绘鏁般�佹垚鍔熸鏁般�佸け璐ユ鏁� 鑾峰彇绯荤粺鎻愮幇璁板綍锛氭�婚銆佹�绘鏁�
@@ -393,16 +388,39 @@
 				Extract extract = record.getExtract();
 				if (extract != null) {
 					Integer extractState = extract.getState();
-					if (extractState != null && extractState == 0) {
+					if (extractState != null && extractState == Extract.STATE_NOT_PROCESS) {
 						UserInfo userInfo = extract.getUserInfo();
 						if (userInfo != null) {
-							double countTodayMoney = extractService.countTodayMoney(userInfo.getId());
-							if (countTodayMoney >= 100) {
+							BigDecimal countTodayMoney = extractService.sumTodayApplyMoney(userInfo.getId(),
+									TimeUtil.getGernalTime(extract.getExtractTime()));
+							if (countTodayMoney.compareTo(new BigDecimal(100)) > 0) {
 								warnLevel = 1;
 							}
 						}
 					}
+				}
 
+				if (record.getExtraInfo() != null) {
+					StringBuffer desc = new StringBuffer();
+					if (System.currentTimeMillis() > TimeUtil.convertToTimeTemp("2019-06-21", "yyyy-MM-dd")) {
+						desc.append("澶х瑪璁㈠崟鏁�:" + record.getExtraInfo().getOrderCount50More() + "\n#");
+						desc.append("缁存潈璁㈠崟鏁�:" + record.getExtraInfo().getWeiQuanOrderCount() + "\n#");
+						desc.append("缁存潈璁㈠崟浣i噾:" + record.getExtraInfo().getWeiQuanOrderFanAmount() + "\n#");
+						if (record.getExtraInfo().getOrderCount50More() > 0
+								|| record.getExtraInfo().getWeiQuanOrderCount() > 1
+								|| record.getExtraInfo().getWeiQuanOrderFanAmount().compareTo(new BigDecimal(10)) >= 0)
+							warnLevel = 2;
+					} else {
+						if (record.getExtraInfo().getOrderCount50More() > 0
+								|| record.getExtraInfo().getWeiQuanOrderCount() > 0
+								|| record.getExtraInfo().getWeiQuanOrderFanAmount().compareTo(new BigDecimal(0)) > 0)
+							warnLevel = 2;
+						desc.append("澶т簬50鍏冭鍗�:" + record.getExtraInfo().getOrderCount50More() + "\n#");
+						desc.append("缁存潈璁㈠崟鏁�:" + record.getExtraInfo().getWeiQuanOrderCount() + "\n#");
+						desc.append("缁存潈璁㈠崟閫�鍥為噾棰�:" + record.getExtraInfo().getWeiQuanOrderFanAmount() + "\n#");
+						desc.append("180澶╁畨鍏ㄨ鍗曟暟:" + record.getExtraInfo().getSafeOrderCount());
+					}
+					record.setExtraInfoStr(desc.toString());
 				}
 				record.setWarnLevel(warnLevel);
 			}
@@ -413,6 +431,8 @@
 
 			GsonBuilder gsonBuilder = new GsonBuilder();
 			gsonBuilder.serializeNulls();
+			gsonBuilder.setDateFormat("yyyy-MM-dd HH:mm:ss");
+			
 			Gson gson = gsonBuilder.create();
 
 			JSONObject data = new JSONObject();
@@ -637,6 +657,18 @@
 				return;
 			}
 
+			for (ExtractAuditRecord record : list) {
+
+				if (record.getExtraInfo() != null) {
+					StringBuffer desc = new StringBuffer();
+					desc.append("澶т簬50鍏冭鍗�:" + record.getExtraInfo().getOrderCount50More() + "\n#");
+					desc.append("缁存潈璁㈠崟鏁�:" + record.getExtraInfo().getWeiQuanOrderCount() + "\n#");
+					desc.append("缁存潈璁㈠崟閫�鍥為噾棰�:" + record.getExtraInfo().getWeiQuanOrderFanAmount() + "\n#");
+					desc.append("180澶╁畨鍏ㄨ鍗曟暟:" + record.getExtraInfo().getSafeOrderCount());
+					record.setExtraInfoStr(desc.toString());
+				}
+			}
+
 			int count = extractAuditRecordService.getByUidCount(uid);
 			int totalPage = count % pageSize == 0 ? count / pageSize : count / pageSize + 1;
 			PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage);
@@ -716,7 +748,7 @@
 		}
 
 		try {
-			extractService.checkExtract(uid);
+			extractService.checkExtract(Long.parseLong(uid));
 			JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("璧勯噾姝e父"));
 		} catch (ExtractException e) {
 			JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e.getMsg()));
@@ -790,9 +822,8 @@
 					innerList.put("name", "椹冲洖鏁�");
 				}
 
-				List<Map<String, Object>> list = extractAuditRecordService.countAuditTotal(state, dateType, year,
+				List<ChartTDO> list = extractAuditRecordService.countAuditTotal(state, dateType, year,
 						startTime, endTime);
-
 				if (dateType != 3) {
 					innerList.put("data", gson.toJson(AdminUtils.dayOrMonthDataFactory(dateType, dateList, list)));
 				} else {
@@ -804,7 +835,6 @@
 					}
 					innerList.put("data", gson.toJson(map.get("value")));
 				}
-
 				line_list.add(innerList);
 			}
 
@@ -816,9 +846,7 @@
 			}
 
 			data.put("line_list", line_list);
-
 			JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));
-
 		} catch (Exception e) {
 			JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鎿嶄綔寮傚父"));
 			e.printStackTrace();
@@ -844,7 +872,6 @@
 	@RequestMapping(value = "getExtractApplyMoney")
 	public void getExtractApplyMoney(String callback, Integer dateType, String year, String startTime, String endTime,
 			PrintWriter out) {
-
 		String validateMsg = AdminUtils.validateParams(dateType, startTime, endTime);
 		if (validateMsg != null) {
 			JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(validateMsg));
@@ -877,12 +904,10 @@
 			List<String> dateList = AdminUtils.getDateList(dateType, startTime, endTime, year);
 
 			Gson gson = new Gson();
-			JSONArray line_list = new JSONArray();
-
 			JSONObject innerList = new JSONObject();
 			innerList.put("name", "鎬昏");
 
-			List<Map<String, Object>> list = extractAuditRecordService.countExtractApplyMoney(null, dateType, year,
+			List<ChartTDO> list = extractAuditRecordService.countExtractApplyMoney(null, dateType, year,
 					startTime, endTime);
 
 			if (dateType != 3) {
@@ -897,6 +922,7 @@
 				innerList.put("data", gson.toJson(map.get("value")));
 			}
 
+			JSONArray line_list = new JSONArray();
 			line_list.add(innerList);
 
 			JSONObject data = new JSONObject();
@@ -907,9 +933,7 @@
 			}
 
 			data.put("line_list", line_list);
-
 			JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));
-
 		} catch (Exception e) {
 			JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鎿嶄綔寮傚父"));
 			e.printStackTrace();
@@ -937,7 +961,6 @@
 	@RequestMapping(value = "getExtractApplyNumber")
 	public void getExtractApplyNumber(String callback, Integer state, Integer dateType, String year, String startTime,
 			String endTime, PrintWriter out) {
-
 		String validateMsg = AdminUtils.validateParams(dateType, startTime, endTime);
 		if (validateMsg != null) {
 			JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(validateMsg));
@@ -965,17 +988,15 @@
 		}
 
 		try {
-
 			Object objectDate = null;
+			Gson gson = new Gson();
 			List<String> dateList = AdminUtils.getDateList(dateType, startTime, endTime, year);
 
-			Gson gson = new Gson();
-			JSONArray line_list = new JSONArray();
 
 			JSONObject innerList = new JSONObject();
 			innerList.put("name", "鎬昏");
 
-			List<Map<String, Object>> list = extractAuditRecordService.countExtractApplyNumber(null, dateType, year,
+			List<ChartTDO> list = extractAuditRecordService.countExtractApplyNumber(null, dateType, year,
 					startTime, endTime);
 
 			if (dateType != 3) {
@@ -990,6 +1011,7 @@
 				innerList.put("data", gson.toJson(map.get("value")));
 			}
 
+			JSONArray line_list = new JSONArray();
 			line_list.add(innerList);
 
 			JSONObject data = new JSONObject();
@@ -1000,9 +1022,7 @@
 			}
 
 			data.put("line_list", line_list);
-
 			JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));
-
 		} catch (Exception e) {
 			JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鎿嶄綔寮傚父"));
 			e.printStackTrace();

--
Gitblit v1.8.0