From ddf5db7d31af51fcf697eac0cee7dd46ff73bcc1 Mon Sep 17 00:00:00 2001 From: admin <2780501319@qq.com> Date: 星期二, 18 二月 2020 12:50:49 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/div' into div --- fanli/src/main/java/com/yeshi/fanli/controller/admin/ExtractAdminController.java | 585 ++++++++++++++++++++++++++++++++++++++------------------- 1 files changed, 389 insertions(+), 196 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 3bc09fb..6fac641 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,22 +22,25 @@ 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; 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.admin.count.CountUserInfo; import com.yeshi.fanli.entity.bus.user.Extract; import com.yeshi.fanli.entity.bus.user.ExtractAuditRecord; import com.yeshi.fanli.entity.bus.user.HongBaoV2; import com.yeshi.fanli.entity.bus.user.UserInfo; +import com.yeshi.fanli.entity.bus.user.UserInfoExtra; import com.yeshi.fanli.entity.common.AdminUser; +import com.yeshi.fanli.entity.system.ConfigKeyEnum; import com.yeshi.fanli.exception.ExtractException; import com.yeshi.fanli.exception.NotExistObjectException; import com.yeshi.fanli.exception.ObjectStateException; @@ -49,11 +52,14 @@ 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.CommonOrderCountService; 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.user.UserInfoExtraService; import com.yeshi.fanli.tag.PageEntity; import com.yeshi.fanli.util.Constant; +import com.yeshi.fanli.util.MoneyBigDecimalUtil; import com.yeshi.fanli.util.RedisManager; import com.yeshi.fanli.util.StringUtil; import com.yeshi.fanli.util.TimeUtil; @@ -100,6 +106,12 @@ @Resource private TaoBaoWeiQuanOrderService taoBaoWeiQuanOrderService; + + @Resource + private UserInfoExtraService userInfoExtraService; + + @Resource + private CommonOrderCountService commonOrderCountService; /** * @@ -222,8 +234,8 @@ // 褰撳墠鐢ㄦ埛浣欓鎬昏锛氭墍鏈夌敤鎴锋�讳綑棰� BigDecimal amountMoney = userInfoCountService.countAllMoney(null); - // 鍙彁鐜伴噾棰濋檺鍒� - String minMoney = configService.get(Constant.EXTRACT_MIN_MONEY); + // 鍙彁鐜伴噾棰濋檺鍒� + String minMoney = configService.get(ConfigKeyEnum.extractMoneyMin.getKey()); if (minMoney == null) { minMoney = "0"; } @@ -391,6 +403,11 @@ if (adminUser == null) { record.setAdminUser(new AdminUser()); } + // 鏌ヨ鐢ㄦ埛澶囨敞淇℃伅 + UserInfoExtra extra = userInfoExtraService.getUserInfoExtra(record.getExtract().getUserInfo().getId()); + if (extra != null) { + record.getExtract().getUserInfo().setStateDesc(extra.getMark()); + } int warnLevel = 0; Extract extract = record.getExtract(); @@ -415,7 +432,7 @@ desc.append("缁存潈璁㈠崟鏁�:" + record.getExtraInfo().getWeiQuanOrderCount() + "\n#"); desc.append("缁存潈璁㈠崟浣i噾:" + record.getExtraInfo().getWeiQuanOrderFanAmount() + "\n#"); if (record.getExtraInfo().getOrderCount50More() > 0 - || record.getExtraInfo().getWeiQuanOrderCount() > 1 + || record.getExtraInfo().getWeiQuanOrderCount() > 0 || record.getExtraInfo().getWeiQuanOrderFanAmount().compareTo(new BigDecimal(10)) >= 0) warnLevel = 2; } else { @@ -430,7 +447,29 @@ } 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(ConfigKeyEnum.adminMinSameGoodsOrderCount.getKey()))); + // long sameShopOrderCount = + // commonOrderCountService.countSameShopOrderByUidAndHongBaoType(typeList, + // record.getExtract().getUserInfo().getId(), + // Integer.parseInt(configService.get(ConfigKeyEnum.adminMinSameShopOrderCount.getKey()))); + // if (sameGoodsOrderCount > 0 || sameShopOrderCount > 0) { + // warnLevel = 3; + // record.setExtraInfoStr( + // String.format("鍚屽簵閾�:%s 鍚屽晢鍝�:%s", sameShopOrderCount, + // sameGoodsOrderCount)); + // } + // } + record.setWarnLevel(warnLevel); + } int count = extractAuditRecordService.getMyAuditedTimeSlotCount(key, state, null, days); @@ -440,7 +479,7 @@ GsonBuilder gsonBuilder = new GsonBuilder(); gsonBuilder.serializeNulls(); gsonBuilder.setDateFormat("yyyy-MM-dd HH:mm:ss"); - + Gson gson = gsonBuilder.create(); JSONObject data = new JSONObject(); @@ -453,6 +492,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(ConfigKeyEnum.adminMinSameGoodsOrderCount.getKey()))); + long sameShopOrderCount = commonOrderCountService.countSameShopOrderByUidAndHongBaoType(typeList, uid, + Integer.parseInt(configService.get(ConfigKeyEnum.adminMinSameShopOrderCount.getKey()))); + 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("搴楅摵/鍟嗗搧鏃犲紓甯�")); } /** @@ -555,6 +615,13 @@ surplusTime = DateUtil.dateDiff(formattodayTime, formatTime); } + String mark = ""; + UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(extract.getUserInfo().getId()); + if (userInfoExtra != null && !StringUtil.isNullOrEmpty(userInfoExtra.getMark())) { + mark = "璀︽儠锛侊紒 " + userInfoExtra.getMark(); + } + + data.put("mark", mark); data.put("extract", extract); data.put("beforeMoney", beforeMoney); data.put("surplusTime", surplusTime); @@ -618,6 +685,13 @@ surplusTime = DateUtil.dateDiff(formattodayTime, formatTime); } + String mark = ""; + UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(extract.getUserInfo().getId()); + if (userInfoExtra != null && !StringUtil.isNullOrEmpty(userInfoExtra.getMark())) { + mark = "璀︽儠锛侊紒 " + userInfoExtra.getMark(); + } + + data.put("mark", mark); data.put("extract", extract); data.put("beforeMoney", beforeMoney); data.put("surplusTime", surplusTime); @@ -784,81 +858,122 @@ @RequestMapping(value = "getAuditTotal") public void getAuditTotal(String callback, String stateArray, 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)); - return; - } - - if (dateType == 1 && year != null) { - year = null; // 璁剧疆涓虹┖ - } else if (dateType == 2) { - if (startTime != null) - startTime = null; - - if (endTime != null) - endTime = null; - - } else if (dateType == 3) { - if (year != null) - year = null; - - if (startTime != null) - startTime = null; - - if (endTime != null) - endTime = null; - } - try { - Object objectDate = null; - List<String> dateList = AdminUtils.getDateList(dateType, startTime, endTime, year); + String validateMsg = AdminUtils.validateParams(dateType, startTime, endTime); + if (validateMsg != null) { + JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(validateMsg)); + return; + } + + if (dateType != 1 && (!StringUtil.isNullOrEmpty(startTime) || !StringUtil.isNullOrEmpty(endTime))) { + startTime = null; + endTime = null; + } + Date beginDate = null; + Date endDate = null; + + if (dateType == 1) { + beginDate = TimeUtil.parse(startTime); + endDate = TimeUtil.parse(endTime); + } else if (dateType == 2) { + Calendar calendar=Calendar.getInstance(); + int currentYear = calendar.get(Calendar.YEAR); + if (!StringUtil.isNullOrEmpty(year)) { + currentYear = Integer.parseInt(year); + } + calendar.clear(); + calendar.set(Calendar.YEAR, currentYear); + beginDate =calendar.getTime(); + + calendar.clear(); + calendar.set(Calendar.YEAR, currentYear); + calendar.roll(Calendar.DAY_OF_YEAR, -1); + endDate=calendar.getTime(); + } else if (dateType == 3) { + beginDate = TimeUtil.parse("2018-01-01"); + endDate = new Date(); + } Gson gson = new Gson(); - List<Integer> stateList = gson.fromJson(stateArray, new TypeToken<ArrayList<Integer>>() { - }.getType()); - + List<String> dateList = AdminUtils.getDateList(dateType, startTime, endTime, year); + + String substring = stateArray.substring(1, stateArray.length()-1); + List<Integer> channelList = null; + if (stateArray != null && stateArray.trim().length() > 4) { + channelList = gson.fromJson(stateArray, new TypeToken<ArrayList<Integer>>() {}.getType()); + } + JSONArray line_list = new JSONArray(); - for (Integer state : stateList) { - JSONObject innerList = new JSONObject(); - if (state == null || state == 3) { - innerList.put("name", "鎬昏"); - } else if (state == 1) { - innerList.put("name", "閫氳繃鏁�"); - } else if (state == 2) { - innerList.put("name", "椹冲洖鏁�"); - } - - List<ChartTDO> list = extractAuditRecordService.countAuditTotal(state, dateType, year, - startTime, endTime); - if (dateType != 3) { - innerList.put("data", gson.toJson(AdminUtils.dayOrMonthDataFactory(dateType, dateList, list))); - } else { - // 骞磋鍥� - Map<String, Object> map = AdminUtils.yearsDataFactory(list); - - if (objectDate == null) { - objectDate = map.get("date"); + + if (channelList != null && channelList.size() > 0) { + for (Integer state : channelList) { + List<Object> list = getAuditData(dateList, dateType, beginDate, endDate, state); + String name = ""; + if (state == 1) { + name = "閫氳繃"; + } else if (state == 2) { + name = "椹冲洖"; } - innerList.put("data", gson.toJson(map.get("value"))); + JSONObject innerList = new JSONObject(); + innerList.put("name", name); + innerList.put("data", gson.toJson(list)); + line_list.add(innerList); } + } else { + List<Object> list = getAuditData(dateList, dateType, beginDate, endDate, null); + JSONObject innerList = new JSONObject(); + innerList.put("name", "鍏ㄩ儴"); + innerList.put("data", gson.toJson(list)); line_list.add(innerList); } JSONObject data = new JSONObject(); - if (objectDate != null) { - data.put("xAxis_list", gson.toJson(objectDate)); - } else { - data.put("xAxis_list", gson.toJson(dateList)); - } - data.put("line_list", line_list); + data.put("xAxis_list", gson.toJson(dateList)); JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data)); } catch (Exception e) { - JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鎿嶄綔寮傚父")); + JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("绯荤粺寮傚父")); e.printStackTrace(); } + } + + private List<Object> getAuditData(List<String> dateList, Integer dateType, Date beginDate, Date endDate, + Integer state) throws Exception{ + List<Object> list = new ArrayList<>(); + List<CountUserInfo> listHistory = extractAuditRecordService.getAuditCount(beginDate, endDate, state); + for (String date: dateList) { + int value = 0; + if (listHistory != null) { + for (CountUserInfo history: listHistory) { + if (dateType == 1) { + String gernalTime = TimeUtil.getGernalTime(history.getDay().getTime()); + if (gernalTime.equalsIgnoreCase(date)) { + value += history.getNum(); + continue; + } + } else if (dateType == 2){ + String gernalTime = TimeUtil.getMonthOnlyMM(history.getDay()); + if(gernalTime.startsWith("0")) { + gernalTime = gernalTime.substring(1, 2); + } + + if (gernalTime.equalsIgnoreCase(date)) { + value += history.getNum(); + continue; + } + } else if (dateType == 3) { + String gernalTime = TimeUtil.getYearOnlyYYYY(history.getDay()); + if (gernalTime.equalsIgnoreCase(date)) { + value += history.getNum(); + continue; + } + } + } + } + list.add(value + ""); + } + + return list; } /** @@ -880,66 +995,90 @@ @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)); - return; - } - - if (dateType == 1 && year != null) { - year = null; // 璁剧疆涓虹┖ - } else if (dateType == 2) { - if (startTime != null) - startTime = null; - - if (endTime != null) - endTime = null; - - } else if (dateType == 3) { - if (year != null) - year = null; - - if (startTime != null) - startTime = null; - - if (endTime != null) - endTime = null; - } - try { - - Object objectDate = null; - List<String> dateList = AdminUtils.getDateList(dateType, startTime, endTime, year); - - Gson gson = new Gson(); - JSONObject innerList = new JSONObject(); - innerList.put("name", "鎬昏"); - - List<ChartTDO> list = extractAuditRecordService.countExtractApplyMoney(null, dateType, year, - startTime, endTime); - - if (dateType != 3) { - innerList.put("data", gson.toJson(AdminUtils.dayOrMonthDataFactory(dateType, dateList, list))); - } else { - // 骞磋鍥� - Map<String, Object> map = AdminUtils.yearsDataFactory(list); - - if (objectDate == null) { - objectDate = map.get("date"); - } - innerList.put("data", gson.toJson(map.get("value"))); + String validateMsg = AdminUtils.validateParams(dateType, startTime, endTime); + if (validateMsg != null) { + JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(validateMsg)); + return; } + + if (dateType != 1 && (!StringUtil.isNullOrEmpty(startTime) || !StringUtil.isNullOrEmpty(endTime))) { + startTime = null; + endTime = null; + } + + Date beginDate = null; + Date endDate = null; + if (dateType == 1) { + beginDate = TimeUtil.parse(startTime); + endDate = TimeUtil.parse(endTime); + } else if (dateType == 2) { + Calendar calendar=Calendar.getInstance(); + int currentYear = calendar.get(Calendar.YEAR); + if (!StringUtil.isNullOrEmpty(year)) { + currentYear = Integer.parseInt(year); + } + + calendar.clear(); + calendar.set(Calendar.YEAR, currentYear); + beginDate =calendar.getTime(); + + calendar.clear(); + calendar.set(Calendar.YEAR, currentYear); + calendar.roll(Calendar.DAY_OF_YEAR, -1); + endDate=calendar.getTime(); + } else if (dateType == 3) { + beginDate = TimeUtil.parse("2018-01-01"); + endDate = new Date(); + } + Gson gson = new Gson(); + List<String> dateList = AdminUtils.getDateList(dateType, startTime, endTime, year); + + List<String> list = new ArrayList<>(); + List<CountUserInfo> listHistory = extractAuditRecordService.getApplyMoney(beginDate, endDate); + for (String date: dateList) { + BigDecimal money = new BigDecimal("0"); + if (listHistory == null) { + list.add(money.toString()); + continue; + } + + for (CountUserInfo history: listHistory) { + if (dateType == 1) { + String gernalTime = TimeUtil.getGernalTime(history.getDay().getTime()); + if (gernalTime.equalsIgnoreCase(date)) { + money = MoneyBigDecimalUtil.add(money, history.getMoney()); + continue; + } + } else if (dateType == 2){ + String gernalTime = TimeUtil.getMonthOnlyMM(history.getDay()); + if(gernalTime.startsWith("0")) { + gernalTime = gernalTime.substring(1, 2); + } + if (gernalTime.equalsIgnoreCase(date)) { + money = MoneyBigDecimalUtil.add(money, history.getMoney()); + continue; + } + } else if (dateType == 3) { + String gernalTime = TimeUtil.getYearOnlyYYYY(history.getDay()); + if (gernalTime.equalsIgnoreCase(date)) { + money = MoneyBigDecimalUtil.add(money, history.getMoney()); + continue; + } + } + } + list.add(money.toString()); + } + + JSONObject innerList = new JSONObject(); + innerList.put("name", "閲戦"); + innerList.put("data", gson.toJson(list)); JSONArray line_list = new JSONArray(); line_list.add(innerList); JSONObject data = new JSONObject(); - if (objectDate != null) { - data.put("xAxis_list", gson.toJson(objectDate)); - } else { - data.put("xAxis_list", gson.toJson(dateList)); - } - + data.put("xAxis_list", gson.toJson(dateList)); data.put("line_list", line_list); JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data)); } catch (Exception e) { @@ -969,74 +1108,107 @@ @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)); - return; - } - - if (dateType == 1 && year != null) { - year = null; // 璁剧疆涓虹┖ - } else if (dateType == 2) { - if (startTime != null) - startTime = null; - - if (endTime != null) - endTime = null; - - } else if (dateType == 3) { - if (year != null) - year = null; - - if (startTime != null) - startTime = null; - - if (endTime != null) - endTime = null; - } - try { - Object objectDate = null; + String validateMsg = AdminUtils.validateParams(dateType, startTime, endTime); + if (validateMsg != null) { + JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(validateMsg)); + return; + } + + if (dateType != 1 && (!StringUtil.isNullOrEmpty(startTime) || !StringUtil.isNullOrEmpty(endTime))) { + startTime = null; + endTime = null; + } + + + Date beginDate = null; + Date endDate = null; + + if (dateType == 1) { + beginDate = TimeUtil.parse(startTime); + endDate = TimeUtil.parse(endTime); + } else if (dateType == 2) { + Calendar calendar=Calendar.getInstance(); + int currentYear = calendar.get(Calendar.YEAR); + if (!StringUtil.isNullOrEmpty(year)) { + currentYear = Integer.parseInt(year); + } + + calendar.clear(); + calendar.set(Calendar.YEAR, currentYear); + beginDate =calendar.getTime(); + + calendar.clear(); + calendar.set(Calendar.YEAR, currentYear); + calendar.roll(Calendar.DAY_OF_YEAR, -1); + endDate=calendar.getTime(); + } else if (dateType == 3) { + beginDate = TimeUtil.parse("2018-01-01"); + endDate = new Date(); + } Gson gson = new Gson(); List<String> dateList = AdminUtils.getDateList(dateType, startTime, endTime, year); - - - JSONObject innerList = new JSONObject(); - innerList.put("name", "鎬昏"); - - List<ChartTDO> list = extractAuditRecordService.countExtractApplyNumber(null, dateType, year, - startTime, endTime); - - if (dateType != 3) { - innerList.put("data", gson.toJson(AdminUtils.dayOrMonthDataFactory(dateType, dateList, list))); - } else { - // 骞磋鍥� - Map<String, Object> map = AdminUtils.yearsDataFactory(list); - - if (objectDate == null) { - objectDate = map.get("date"); + + List<Object> list = new ArrayList<>(); + List<CountUserInfo> listHistory = extractAuditRecordService.geApplyNumber(beginDate, endDate); + for (String date: dateList) { + int value = 0; + if (listHistory == null) { + list.add(value + ""); + continue; } - innerList.put("data", gson.toJson(map.get("value"))); + + for (CountUserInfo history: listHistory) { + if (dateType == 1) { + String gernalTime = TimeUtil.getGernalTime(history.getDay().getTime()); + if (gernalTime.equalsIgnoreCase(date)) { + value += history.getNum(); + continue; + } + } else if (dateType == 2){ + String gernalTime = TimeUtil.getMonthOnlyMM(history.getDay()); + if(gernalTime.startsWith("0")) { + gernalTime = gernalTime.substring(1, 2); + } + if (gernalTime.equalsIgnoreCase(date)) { + value += history.getNum(); + continue; + } + } else if (dateType == 3) { + String gernalTime = TimeUtil.getYearOnlyYYYY(history.getDay()); + if (gernalTime.equalsIgnoreCase(date)) { + value += history.getNum(); + continue; + } + } + } + list.add(value + ""); } + + JSONObject innerList = new JSONObject(); + innerList.put("name", "鏁伴噺"); + innerList.put("data", gson.toJson(list)); JSONArray line_list = new JSONArray(); line_list.add(innerList); JSONObject data = new JSONObject(); - if (objectDate != null) { - data.put("xAxis_list", gson.toJson(objectDate)); - } else { - data.put("xAxis_list", gson.toJson(dateList)); - } - + data.put("xAxis_list", gson.toJson(dateList)); data.put("line_list", line_list); JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data)); } catch (Exception e) { - JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鎿嶄綔寮傚父")); + JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("绯荤粺寮傚父")); e.printStackTrace(); } } - + + /** + * 涓嬭浇鎻愮幇绾㈠寘Openid + * + * @param callback + * @param response + * @param out + */ @RequestMapping(value = "downAutoExtractTxt") public void downAutoExtractTxt(String callback, HttpServletResponse response, PrintWriter out) { try { @@ -1045,35 +1217,41 @@ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏆傛棤鐢ㄦ埛婊¤冻鑷姩鎻愮幇鏉′欢")); return; } - - String filepath = "鑷姩鎻愮幇OpenId "+ java.lang.System.currentTimeMillis() + ".txt"; + + String filepath = "鑷姩鎻愮幇OpenId " + java.lang.System.currentTimeMillis() + ".txt"; response.reset(); - response.setContentType("application/octet-stream"); - String fileName= URLDecoder.decode(filepath,"utf-8"); - response.addHeader("Content-Disposition","attachment;"+ "filename=\"" +URLEncoder.encode(fileName, "utf-8") + "\""); - + response.setContentType("application/octet-stream"); + String fileName = URLDecoder.decode(filepath, "utf-8"); + response.addHeader("Content-Disposition", + "attachment;" + "filename=\"" + URLEncoder.encode(fileName, "utf-8") + "\""); + StringBuilder sb = new StringBuilder(); - for(String t:list){ - sb.append(t+"\r\n"); + for (String t : list) { + sb.append(t + "\r\n"); } - + String opid_str = sb.toString(); if (!StringUtil.isNullOrEmpty(opid_str) && opid_str.endsWith("\r\n")) { opid_str = opid_str.substring(0, opid_str.length() - 2); } - - OutputStream os = response.getOutputStream(); - byte[] byt = opid_str.getBytes(); - os.write(byt); - os.flush(); - os.close(); + + OutputStream os = response.getOutputStream(); + byte[] byt = opid_str.getBytes(); + os.write(byt); + os.flush(); + os.close(); } catch (Exception e) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鎿嶄綔寮傚父")); e.printStackTrace(); } } - - + + /** + * 涓婁紶鎻愮幇绾㈠寘Excel + * + * @param file + * @param out + */ @RequestMapping(value = "uploadExcel", method = RequestMethod.POST) public void uploadExcel(@RequestParam("file") CommonsMultipartFile file, PrintWriter out) { if (file == null) { @@ -1082,7 +1260,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) { @@ -1092,41 +1270,56 @@ out.print(JsonUtil.loadFalseResult("涓婁紶澶辫触")); } } + + 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(); if (list == null || list.isEmpty()) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏆傛棤鐢ㄦ埛婊¤冻鑷姩鎻愮幇鏉′欢")); return; } - + if (pageIndex == null || pageIndex < 1) { pageIndex = 1; } + Integer pageSize = 100; if (pageSize == null || pageSize < 1) { pageSize = Constant.PAGE_SIZE; } - + int count = list.size(); int totalPage = count % pageSize == 0 ? count / pageSize : count / pageSize + 1; PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage); - + List<UserInfo> listResult = null; if (pageIndex < totalPage) { int start = (pageIndex - 1) * pageSize; listResult = list.subList(start, start + pageSize); } else if (pageIndex == totalPage) { - listResult = list.subList((pageIndex - 1) * pageSize, list.size()); + listResult = list.subList((pageIndex - 1) * pageSize, list.size()); } else { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("娌℃湁鏇村浜�")); return; } - + JSONObject data = new JSONObject(); data.put("pe", pe); data.put("result_list", listResult); @@ -1136,5 +1329,5 @@ e.printStackTrace(); } } - } + -- Gitblit v1.8.0