From 98b1a0affd69bbe63223c21fdd2c404e8bedfccb Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期三, 20 五月 2020 17:25:08 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/div' into 2.1.2 --- fanli/src/main/java/com/yeshi/fanli/controller/admin/ExtractAdminController.java | 2411 ++++++++++++++++++++++++---------------------------------- 1 files changed, 985 insertions(+), 1,426 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 b1f7de7..f35bcdc 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 @@ -1,1426 +1,985 @@ -package com.yeshi.fanli.controller.admin; - -import java.io.PrintWriter; -import java.math.BigDecimal; -import java.text.ParseException; -import java.text.SimpleDateFormat; -import java.util.ArrayList; -import java.util.Calendar; -import java.util.Date; -import java.util.HashMap; -import java.util.Iterator; -import java.util.List; -import java.util.Map; - -import javax.annotation.Resource; -import javax.servlet.http.HttpServletRequest; - -import net.sf.json.JSONObject; - -import org.springframework.stereotype.Controller; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RequestMethod; - -import com.google.gson.Gson; -import com.google.gson.GsonBuilder; -import com.yeshi.fanli.entity.bus.user.Extract; -import com.yeshi.fanli.entity.bus.user.ExtractAuditRecord; -import com.yeshi.fanli.entity.bus.user.HongBao; -import com.yeshi.fanli.entity.bus.user.Order; -import com.yeshi.fanli.entity.bus.user.OrderItem; -import com.yeshi.fanli.entity.bus.user.UserInfo; -import com.yeshi.fanli.entity.common.AdminUser; -import com.yeshi.fanli.entity.taobao.PidOrder; -import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief; -import com.yeshi.fanli.entity.taobao.TaoBaoOrder; -import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder; -import com.yeshi.fanli.exception.NotExistObjectException; -import com.yeshi.fanli.exception.ObjectStateException; -import com.yeshi.fanli.log.LogHelper; -import com.yeshi.fanli.service.AdminUserService; -import com.yeshi.fanli.service.inter.count.ExtractCountService; -import com.yeshi.fanli.service.inter.hongbao.HongBaoService; -import com.yeshi.fanli.service.inter.order.OrderItemServcie; -import com.yeshi.fanli.service.inter.order.PidOrderService; -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; -import com.yeshi.fanli.util.StringUtil; -import com.yeshi.fanli.util.TimeUtil; -import com.yeshi.fanli.util.taobao.TaoKeApiUtil; - -import org.yeshi.utils.DateUtil; -import org.yeshi.utils.IPUtil; -import org.yeshi.utils.JsonUtil; - -@Controller -@RequestMapping("admin/new/api/v1/extract") -public class ExtractAdminController { - - @Resource - private ExtractService extractService; - - @Resource - private ExtractCountService extractCountService; - - @Resource - private AccountMessageService accountMessageService; - - @Resource - private PushRecordService pushRecordService; - - @Resource - private PushController xingePushController; - - @Resource - private ExtractAuditRecordService extractAuditRecordService; - - @Resource - private HongBaoService hongBaoService; - - @Resource - private AdminUserService adminUserService; - - @Resource - private OrderItemServcie orderItemServcie; - - @Resource - private PidOrderService pidOrderService; - - @Resource - private RedisManager redisManager; - - @Resource - private TaoBaoOrderService taoBaoOrderService; - - @Resource - private TaoBaoWeiQuanOrderService taoBaoWeiQuanOrderService; - - private final static String TODAY = "1"; - private final static String THREE = "2"; - private final static String AWEEK = "3"; - - @RequestMapping(value = "getExtractList", method = RequestMethod.POST) - public void getExtractList(int pageIndex, PrintWriter out) { - List<Extract> extractList = extractService.getExtractList(pageIndex - 1); - int count = extractService.getCount(); - int totalPage = count % Constant.PAGE_SIZE == 0 ? count / Constant.PAGE_SIZE : count / Constant.PAGE_SIZE + 1; - PageEntity pe = new PageEntity(pageIndex, Constant.PAGE_SIZE, count, totalPage); - JSONObject data = new JSONObject(); - data.put("pe", pe); - data.put("extractList", extractList); - out.print(JsonUtil.loadTrueResult(data)); - } - - /** - * - * 鏂规硶璇存槑: 閫氳繃鎻愮幇璇锋眰 - * - * @author mawurui createTime 2018骞�3鏈�14鏃� 涓嬪崍3:15:42 - * @param id - * @param out - * @param request - */ - @RequestMapping(value = "passExtract", method = RequestMethod.POST) - public void passExtract(String callback, long id, PrintWriter out, HttpServletRequest request) { - - // TODO 闇�瑕侀偖绠卞彂閫佺煭淇¢獙璇� - - AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN); - - Integer integer = extractService.passExtract(id, admin); - Extract extract = extractService.getExtractById(id); - long uid = extract.getUserInfo().getId(); - - if (integer == null) { - out.print(JsonUtil.loadTrueResult("閫氳繃")); - LogHelper - .userInfo("[ip:" + IPUtil.getRemotIP(request) + "]" + admin.getName() + "閫氳繃浜哰id=" + id + "]鐨勬彁鐜扮敵璇�!"); // 鍚屾剰涔嬪悗鎴愬姛 - } else if (integer == 1) { - - out.print(JsonUtil.loadFalseResult("涓嶅瓨鍦ㄨ瀵硅薄")); // 鍚屾剰涔嬪悗澶辫触 - LogHelper.userInfo( - "[ip:" + IPUtil.getRemotIP(request) + "][绠$悊鍛�:" + admin.getName() + "] 鍚屾剰鎻愮幇id=" + id + "鐨勬彁鐜扮敵璇蜂笉瀛樺湪"); - String title = "浣犵殑鎻愮幇鐢宠琚┏鍥�"; - String content = "闈炲父閬楁喚锛屼綘鐨勬彁鐜扮敵璇疯椹冲洖銆傛垜浠�氳繃鏍稿鍙戠幇浣犵殑璐︾洰鏄庣粏鏈夎锛屾垜浠細鍦ㄥ璁″畬鎴愪箣鍚庣粰浣犲彂閫氱煡娑堟伅銆傚鏈夌枒闂鑱旂郴瀹㈡湇銆�"; - // xingePushController.pushSystemZnx(uid, title, content, out); - } else { - - LogHelper.userInfo( - "[ip:" + IPUtil.getRemotIP(request) + "][绠$悊鍛�:" + admin.getName() + "] 鍚屾剰鎻愮幇id=" + id + "鐨勬彁鐜扮敵璇风姸鎬佸紓甯�"); - out.print(JsonUtil.loadFalseResult("璇ョ姸鎬佷笉绛変簬涓嶄负鍒濆鐘舵��")); - String title = "浣犵殑鎻愮幇鐢宠涓嶆垚鍔�"; - String content = "璇风‘淇濅綘鐨勬彁鐜拌处鎴风殑闅愮璁剧疆涓� 鍏佽閭銆佹墜鏈哄彿銆佷細鍛樺悕鎵惧埌鎴戙�傚惁鍒欐棤娉曟垚鍔熷畬鎴愯浆璐︺�傚鏈夌枒闂鑱旂郴瀹㈡湇銆�"; - // xingePushController.pushSystemZnx(uid, title, content, out); - } - } - - /** - * - * 鏂规硶璇存槑: 閫氳繃鎻愮幇璇锋眰 鍙痡sonP鏂瑰紡 - * - * @param id - * @param code - * 楠岃瘉鐮� - * @param out - * @param request - */ - @RequestMapping(value = "passExtractJP") - public void passExtractJP(String callback, Long id, String code, PrintWriter out, HttpServletRequest request) { - - /* 妫�楠屾槸鍚︾櫥闄� */ - AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN); - if (admin == null) { - JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("褰撳墠璐︽埛澶辨晥,璇烽噸鏂扮櫥闄嗐��")); - return; - } - - /* 妫�楠屾槸鍚﹂�氳繃楠岃瘉 */ - String codeType = (String) request.getSession().getAttribute(Constant.SESSION_EXTRACT_VERIFY_RESULT); - if (!"1".equals(codeType)) { - JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(3, "閭楠岃瘉鏈�氳繃")); - return; - } - - /* 鍏佽鎻愮幇 鎿嶄綔 */ - Integer integer = extractService.passExtract(id, admin); - - Extract extract = extractService.getExtractById(id); - long uid = extract.getUserInfo().getId(); - - if (integer == null) { - JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("閫氳繃")); - - 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 + "鐨勬彁鐜扮敵璇蜂笉瀛樺湪"); - String title = "浣犵殑鎻愮幇鐢宠琚┏鍥�"; - String content = "闈炲父閬楁喚锛屼綘鐨勬彁鐜扮敵璇疯椹冲洖銆傛垜浠�氳繃鏍稿鍙戠幇浣犵殑璐︾洰鏄庣粏鏈夎锛屾垜浠細鍦ㄥ璁″畬鎴愪箣鍚庣粰浣犲彂閫氱煡娑堟伅銆傚鏈夌枒闂鑱旂郴瀹㈡湇銆�"; - // xingePushController.pushSystemZnx(uid, title, content, out); - } else { - JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璇ョ姸鎬佷笉绛変簬涓嶄负鍒濆鐘舵��")); - - LogHelper.userInfo( - "[ip:" + IPUtil.getRemotIP(request) + "][绠$悊鍛�:" + admin.getName() + "] 鍚屾剰鎻愮幇id=" + id + "鐨勬彁鐜扮敵璇风姸鎬佸紓甯�"); - String title = "浣犵殑鎻愮幇鐢宠涓嶆垚鍔�"; - String content = "璇风‘淇濅綘鐨勬彁鐜拌处鎴风殑闅愮璁剧疆涓� 鍏佽閭銆佹墜鏈哄彿銆佷細鍛樺悕鎵惧埌鎴戙�傚惁鍒欐棤娉曟垚鍔熷畬鎴愯浆璐︺�傚鏈夌枒闂鑱旂郴瀹㈡湇銆�"; - // xingePushController.pushSystemZnx(uid, title, content, out); - } - - } - - /** - * - * 鏂规硶璇存槑: 鎷掔粷鎻愮幇璇锋眰 - * - * @author mawurui createTime 2018骞�3鏈�14鏃� 涓嬪崍3:15:55 - * @param id - * @param reason - * @param out - * @param request - */ - @RequestMapping(value = "rejectExtract", method = RequestMethod.POST) - public void rejectExtract(String callback, long id, String reason, PrintWriter out, HttpServletRequest request) { - AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN); - - Extract extract = extractService.getExtractById(id); - long uid = extract.getUserInfo().getId(); - long extractTime = extract.getExtractTime(); - - try { - extractService.rejectExtract(id, reason, extractTime, admin);// 鎻愮幇澶辫触 - - // 璋冪敤鎺ㄩ�佺珯鍐呬俊缁欑敤鎴� - out.print(JsonUtil.loadTrueResult("鎷掔粷")); - LogHelper.userInfo("[ip:" + IPUtil.getRemotIP(request) + "]" + admin.getName() + "鎷掔粷浜哰id=" + id - + "]鐨勬彁鐜扮敵璇�!鎷掔粷鍘熷洜鏄�" + reason); - - String title = "浣犵殑鎻愮幇鐢宠琚┏鍥�"; - String content = "闈炲父閬楁喚锛屼綘鐨勬彁鐜扮敵璇疯椹冲洖銆傛垜浠�氳繃鏍稿鍙戠幇浣犵殑璐︾洰鏄庣粏鏈夎锛屾垜浠細鍦ㄥ璁″畬鎴愪箣鍚庣粰浣犲彂閫氱煡娑堟伅銆傚鏈夌枒闂鑱旂郴瀹㈡湇銆�"; - // xingePushController.pushSystemZnx(uid, title, content, out); - } catch (ObjectStateException e) { - LogHelper.userInfo( - "[ip:" + IPUtil.getRemotIP(request) + "][绠$悊鍛�:" + admin.getName() + "] 鎷掔粷鎻愮幇id=" + id + "鐨勬彁鐜扮敵璇风姸鎬佸紓甯�!"); // - - out.print(JsonUtil.loadFalseResult(e.getMessage())); - } catch (NotExistObjectException e) { - LogHelper.userInfo( - "[ip:" + IPUtil.getRemotIP(request) + "][绠$悊鍛�:" + admin.getName() + "] 鎷掔粷鎻愮幇id=" + id + "鐨勬彁鐜扮敵璇蜂笉瀛樺湪!"); - - out.print(JsonUtil.loadFalseResult(e.getMessage())); - } - } - - /** - * - * 鏂规硶璇存槑: 鎷掔粷鎻愮幇璇锋眰jsonP - * - * @author mawurui createTime 2018骞�3鏈�14鏃� 涓嬪崍3:15:55 - * @param id - * @param reason - * @param out - * @param request - */ - @RequestMapping(value = "rejectExtractJP") - public void rejectExtractJP(String callback, Long id, String code, String reason, PrintWriter out, - HttpServletRequest request) { - /* 妫�楠屾槸鍚︾櫥闄� */ - AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN); - if (admin == null) { - JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("褰撳墠璐︽埛澶辨晥,璇烽噸鏂扮櫥闄�")); - return; - } - - /* 妫�楠屾槸鍚﹂�氳繃楠岃瘉 */ - String codeType = (String) request.getSession().getAttribute(Constant.SESSION_EXTRACT_VERIFY_RESULT); - if (!"1".equals(codeType)) { - JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(3, "閭楠岃瘉鏈�氳繃")); - return; - } - - /* 鎷掔粷鎻愮幇 鎿嶄綔 */ - - try { - Extract extract = extractService.getExtractById(id); - long extractTime = extract.getExtractTime(); - extractService.rejectExtract(id, reason, extractTime, admin);// 鎻愮幇澶辫触 - - JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("鎷掔粷")); - - // 璋冪敤鎺ㄩ�佺珯鍐呬俊缁欑敤鎴� - // out.print(JsonUtil.loadTrueResult("鎷掔粷")); - LogHelper.userInfo("[ip:" + IPUtil.getRemotIP(request) + "]" + admin.getName() + "鎷掔粷浜哰id=" + id - + "]鐨勬彁鐜扮敵璇�!鎷掔粷鍘熷洜鏄�" + reason); - - String title = "浣犵殑鎻愮幇鐢宠琚┏鍥�"; - String content = "闈炲父閬楁喚锛屼綘鐨勬彁鐜扮敵璇疯椹冲洖銆傛垜浠�氳繃鏍稿鍙戠幇浣犵殑璐︾洰鏄庣粏鏈夎锛屾垜浠細鍦ㄥ璁″畬鎴愪箣鍚庣粰浣犲彂閫氱煡娑堟伅銆傚鏈夌枒闂鑱旂郴瀹㈡湇銆�"; - // xingePushController.pushSystemZnx(uid, title, content, out); - } catch (ObjectStateException e) { - LogHelper.userInfo( - "[ip:" + IPUtil.getRemotIP(request) + "][绠$悊鍛�:" + admin.getName() + "] 鎷掔粷鎻愮幇id=" + id + "鐨勬彁鐜扮敵璇风姸鎬佸紓甯�!"); // - - JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e.getMessage())); - - } catch (NotExistObjectException e) { - LogHelper.userInfo( - "[ip:" + IPUtil.getRemotIP(request) + "][绠$悊鍛�:" + admin.getName() + "] 鎷掔粷鎻愮幇id=" + id + "鐨勬彁鐜扮敵璇蜂笉瀛樺湪!"); - - JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e.getMessage())); - } - - } - - /** - * 璧勯噾鏍¢獙鏄惁寮傚父 - * - * @param uid - * @param out - */ - @RequestMapping(value = "checkExtract", method = RequestMethod.POST) - public void checkExtract(String uid, PrintWriter out) { - - JSONObject data = new JSONObject(); - - // 宸插埌璐︾殑绾㈠寘 - int count = hongBaoService.getCount(HongBao.STATE_YILINGQU); - if (count == 0) { - data.put("code", "0"); - out.print(data); - return; - } - - List<Integer> checked = extractService.checkExtract(uid); - if (checked != null && checked.size() > 0) { - Integer diversity = checked.get(0); - if (diversity == 0) { - data.put("code", "0"); - } else { - data.put("code", "1"); - } - } else { - data.put("code", "1"); - } - out.print(data); - } - - /** - * 鑾峰彇浠婃棩鎻愮幇璁板綍锛氫粖鏃ユ�婚銆佹�绘鏁般�佹垚鍔熸鏁般�佸け璐ユ鏁� 鑾峰彇绯荤粺鎻愮幇璁板綍锛氭�婚銆佹�绘鏁� - * - * @param out - */ - @RequestMapping(value = "countExtract") - public void countExtract(String callback, PrintWriter out) { - - Map<String, Object> totalcount = extractCountService.getTodayCount(); - - BigDecimal totalmoney = extractCountService.getTodayTotalSuccessMoney(); - - totalcount.put("totalmoney", totalmoney); - - Map<String, Object> resultData = extractCountService.countTotalSuccess(); - - JSONObject data = new JSONObject(); - data.put("todayCount", totalcount); - data.put("totalount", resultData); - - out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data))); - } - - /** - * 鏌ヨ鎵�鏈夊鏍歌褰曚俊鎭� - * - * @param callback - * @param pageIndex - * @param key - * @param startTime - * @param endTime - * @param out - */ - @RequestMapping(value = "getFinishRecordList") - public void getFinishRecordList(String callback, Integer pageIndex, String key, String startTime, String endTime, - PrintWriter out) { - - try { - - // 璧峰鏃堕棿 涓虹┖璁剧疆榛樿鍊硷細 - if (StringUtil.isNullOrEmpty(startTime)) { - startTime = "1970-01-01"; - } - - // 缁撴潫鏃堕棿 涓虹┖璁剧疆榛樿鍊煎綋鍓嶆棩鏈� - if (StringUtil.isNullOrEmpty(endTime)) { - Date curDate = new Date(); - endTime = TimeUtil.getSimpleDate(curDate); - } - - SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); - Date enddate = sdf.parse(endTime); - Calendar c = Calendar.getInstance(); - c.setTime(enddate); - c.add(Calendar.DAY_OF_MONTH, 1);// 浠婂ぉ+1澶� - - endTime = sdf.format(c.getTime()); - - if (pageIndex == null) - pageIndex = 1; - - int pageSize = Constant.PAGE_SIZE; - - List<ExtractAuditRecord> auditList = extractAuditRecordService.getList(pageIndex, pageSize, key, startTime, - endTime); - - int count = extractAuditRecordService.getCount(key, startTime, endTime); - int totalPage = count % pageSize == 0 ? count / pageSize : count / pageSize + 1; - PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage); - - if (auditList == null || auditList.size() == 0) { - out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("鏆傛棤鏁版嵁"))); - } else { - - for (ExtractAuditRecord extractAuditRecord : auditList) { - int countByUid = 0; - int countCancel = 0; - Extract extract = extractAuditRecord.getExtract(); - if (extract != null) { - UserInfo userInfo = extract.getUserInfo(); - Long id = userInfo.getId(); - countByUid = hongBaoService.getCountByUid(id); - countCancel = hongBaoService.getCountCancelByUid(id); - } - extractAuditRecord.setCancelOrderNum((long) countCancel); - extractAuditRecord.setOrderNum((long) countByUid); - } - - JSONObject data = new JSONObject(); - GsonBuilder gsonBuilder = new GsonBuilder(); - gsonBuilder.serializeNulls(); // 閲嶇偣 - Gson gson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create(); - - data.put("pe", pe); - data.put("auditList", gson.toJson(auditList)); - - out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data))); - } - - } catch (Exception e) { - e.printStackTrace(); - out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("鎿嶄綔寮傚父"))); - } - } - - /** - * 鏌ヨ瀹㈡湇涓汉鎻愮幇瀹℃壒璁板綍淇℃伅 - * - * @param callback - * @param pageIndex - * 椤电爜 - * @param key - * 绛涢�夋潯浠� - * @param timeSlot - * 鏌ヨ鏃堕棿娈� - * @param state - * 鏌ョ湅瀹℃牳鐘舵�� - * @param out - * @param request - */ - @RequestMapping(value = "getMyAuditedList") - public void getMyAuditedList(String callback, Integer pageIndex, String key, String timeSlot, Integer state, - PrintWriter out, HttpServletRequest request) { - - try { - - // AdminUser admin = (AdminUser) - // request.getSession().getAttribute(Constant.SESSION_ADMIN); - // if (admin == null) { - // JsonUtil.printMode(out, callback, - // JsonUtil.loadFalseResult("褰撳墠璐︽埛澶辨晥,璇烽噸鏂扮櫥闄�")); - // return; - // } - - int pageSize = Constant.PAGE_SIZE; - - Integer days = null; - if (TODAY.equals(timeSlot)) { - days = 0; // 浠婃棩 - } else if (THREE.equals(timeSlot)) { - days = 3; // 鍓�3澶� - } else if (AWEEK.equals(timeSlot)) { - days = 7; // 鍓�7澶� - } - - if (state != null && state != 0 && state != 1 && state != 2) { - state = null; - } - - // 鏌ヨ褰撳墠浜哄憳鐨勫鏍稿垪琛ㄤ俊鎭� - // Long adminId = admin.getId(); - // auditList = - // extractAuditRecordService.getMyAuditedTimeSlotList(pageIndex, - // pageSize, key,state, adminId, days); - // count = extractAuditRecordService.getMyAuditedTimeSlotCount(key, - // state, adminId,days); - - // 鏆備笉鍖哄垎璐﹀彿锛岄粯璁ゆ墍鏈� - List<ExtractAuditRecord> auditList = extractAuditRecordService.getMyAuditedTimeSlotList(pageIndex, pageSize, - key, state, null, days); - if (auditList == null || auditList.size() == 0) { - JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏆傛棤鏁版嵁")); - return; - } - - for (ExtractAuditRecord record : auditList) { - AdminUser adminUser = record.getAdminUser(); - if (adminUser == null) { - record.setAdminUser(new AdminUser()); - } - } - - int count = extractAuditRecordService.getMyAuditedTimeSlotCount(key, state, null, days); - int totalPage = count % pageSize == 0 ? count / pageSize : count / pageSize + 1; - PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage); - - GsonBuilder gsonBuilder = new GsonBuilder(); - gsonBuilder.serializeNulls(); - Gson gson = gsonBuilder.create(); - - JSONObject data = new JSONObject(); - data.put("pe", pe); - data.put("list", gson.toJson(auditList)); - - JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data)); - - } catch (Exception e) { - e.printStackTrace(); - out.print(JsonUtil.loadFalseResult(e.getMessage())); - } - } - - /** - * 鑾峰彇浠婃棩鎻愮幇璁板綍锛氫粖鏃ユ�婚銆佹�绘鏁般�佹垚鍔熸鏁般�佸け璐ユ鏁� 鑾峰彇绯荤粺鎻愮幇璁板綍锛氭�婚銆佹�绘鏁� - * - * @param out - */ - @RequestMapping(value = "getMyAuditedCount") - public void getMyAuditedCount(String callback, HttpServletRequest request, PrintWriter out) { - - AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN); - - if (admin == null) { - out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("褰撳墠璐︽埛澶辨晥,璇烽噸鏂扮櫥闄嗐��"))); - } else { - Long adminId = admin.getId(); - - int taskToday = extractCountService.countTodayApply(); - // int countTodayComplete = extractService.countTodayComplete(); - - // 浠婃棩绱澶勭悊鏁版嵁 - int countToday = extractAuditRecordService.getMyAuditedCountToday(adminId); - // 鏈懆绱澶勭悊鏁版嵁 - int countWeek = extractAuditRecordService.getMyAuditedCountWeek(adminId); - // 鏈湀绱澶勭悊鏁版嵁 - int countMonth = extractAuditRecordService.getMyAuditedCountMonth(adminId); - - JSONObject data = new JSONObject(); - data.put("adminUser", admin); - data.put("taskToday", taskToday); - data.put("countToday", countToday); - data.put("countWeek", countWeek); - data.put("countMonth", countMonth); - - out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data))); - } - - } - - /** - * 瀹㈡湇浠诲姟椤甸潰灞曠ず鏁版嵁锛氫紶鍏ユ彁鐜扮敵璇穒d 鍒欐樉绀哄綋鍓嶇敵璇凤紝鑻ユ棤id鍒欐樉绀哄鏈嶄换鍔′笅绗竴涓敵璇锋暟鎹� - * - * @param callback - * @param extractId - * 鎻愮幇id - * @param request - * @param out - */ - @RequestMapping(value = "getIaskInfo") - public void getIaskInfo(String callback, Long extractId, HttpServletRequest request, PrintWriter out) { - try { - - String surplusTime = ""; - JSONObject data = new JSONObject(); - Extract extract = new Extract(); - AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN); - if (admin == null) { - out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("褰撳墠璐︽埛澶辨晥,璇烽噸鏂扮櫥闄嗐��"))); - return; - } - - if (extractId != null) { - /* 浼犲叆鎻愮幇鐢宠id 鏌ヨ鍓嶅鏈嶄换鍔℃暟鎹� */ - - extract = extractService.selectByPrimaryKey(extractId); - if (extract == null) { - out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("褰撳墠鐢宠宸蹭笉瀛樺湪"))); - return; - } - - // 褰撳墠浠诲姟鎸囧畾涓鸿璐︽埛澶勭悊 - /* - * extract.setAdminId(admin.getId()); - * extractService.updateByPrimaryKeySelective(extract); - */ - - BigDecimal beforeMoney = null; - List<ExtractAuditRecord> records = extractAuditRecordService.getbyExtractId(extract.getId()); - if (records != null && records.size() > 0) { - ExtractAuditRecord extractAuditRecord = records.get(0); - if (extractAuditRecord != null) { - beforeMoney = extractAuditRecord.getBeforeMoney(); - } - } - - Long extractTime = extract.getExtractTime(); - SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); - Date date = new Date(extractTime); - Calendar c = Calendar.getInstance(); - c.setTime(date); - c.add(Calendar.DAY_OF_MONTH, 3);// 浠婂ぉ+3澶� - Date todayTime = new Date(); - String formattodayTime = sdf.format(todayTime); - String formatTime = sdf.format(c.getTime()); - - long diff = sdf.parse(formatTime).getTime() - sdf.parse(formattodayTime).getTime(); - if (diff <= 0) { - surplusTime = "宸茶秴鏃�"; - } else { - surplusTime = DateUtil.dateDiff(formattodayTime, formatTime); - } - - data.put("extract", extract); - data.put("beforeMoney", beforeMoney); - data.put("surplusTime", surplusTime); - - out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data))); - - } else { - /* 鏈紶鍏ユ彁鐜扮敵璇穒d 鏌ヨ褰撳墠瀹㈡湇浠诲姟 涓殑绗竴涓� 鏁版嵁 */ - - boolean newTask = false; - - // 鏌ヨ涔嬪墠鏈鐞嗗畬鐨勪换鍔� - extract = extractService.getMyTaskInfo(admin.getId()); - - if (extract == null) { - // 鏂颁换鍔� - extract = extractService.getNewTaskInfo(); - if (extract != null) - newTask = true; - } - - if (extract == null) { - out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("鏆傛棤鐢ㄦ埛鎻愮幇鐢宠"))); - } else { - - if (newTask) { - // 褰撳墠浠诲姟鎸囧畾涓鸿璐︽埛澶勭悊 - /* - * extract.setAdminId(admin.getId()); - * - * extractService.updateByPrimaryKeySelective(extract); - */ - } - - BigDecimal beforeMoney = null; - - List<ExtractAuditRecord> records = extractAuditRecordService.getbyExtractId(extract.getId()); - if (records != null && records.size() > 0) { - ExtractAuditRecord extractAuditRecord = records.get(0); - if (extractAuditRecord != null) { - beforeMoney = extractAuditRecord.getBeforeMoney(); - } - } - - Long extractTime = extract.getExtractTime(); - SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); - Date date = new Date(extractTime); - - Calendar c = Calendar.getInstance(); - c.setTime(date); - c.add(Calendar.DAY_OF_MONTH, 3);// 浠婂ぉ+3澶� - Date todayTime = new Date(); - - String formattodayTime = sdf.format(todayTime); - String formatTime = sdf.format(c.getTime()); - - long diff = sdf.parse(formatTime).getTime() - sdf.parse(formattodayTime).getTime(); - if (diff <= 0) { - surplusTime = "宸茶秴鏃�"; - } else { - surplusTime = DateUtil.dateDiff(formattodayTime, formatTime); - } - - data.put("extract", extract); - data.put("beforeMoney", beforeMoney); - data.put("surplusTime", surplusTime); - - out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data))); - } - - } - - } catch (ParseException e) { - // TODO Auto-generated catch block - e.printStackTrace(); - } - - } - - /** - * 鏌ヨ鐢ㄦ埛鍘嗗彶鎻愮幇璁板綍 - * - * @param callback - * @param pageIndex - * 椤电爜 - * @param key - * 鐢ㄦ埛id - * @param request - * @param out - */ - @RequestMapping(value = "getByUidList") - public void getByUidList(String callback, Integer pageIndex, Long uid, HttpServletRequest request, - PrintWriter out) { - try { - if (uid == null) { - JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鐢ㄦ埛涓嶅瓨鍦�")); - return; - } - - if (pageIndex == null) - pageIndex = 1; - - int pageSize = Constant.PAGE_SIZE; - - List<ExtractAuditRecord> list = extractAuditRecordService.getByUidList(pageIndex, pageSize, uid); - if (list == null || list.size() == 0) { - JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏆傛棤鎻愮幇璁板綍")); - return; - } - - int count = extractAuditRecordService.getByUidCount(uid); - int totalPage = count % pageSize == 0 ? count / pageSize : count / pageSize + 1; - PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage); - - GsonBuilder gsonBuilder = new GsonBuilder(); - gsonBuilder.serializeNulls(); // 閲嶇偣 - Gson gson = gsonBuilder.create(); - - JSONObject data = new JSONObject(); - data.put("pe", pe); - data.put("list", gson.toJson(list)); - - JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data)); - - } catch (Exception e) { - // TODO: handle exception - JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鎿嶄綔寮傚父")); - e.printStackTrace(); - } - } - - /** - * 鏁伴噺缁熻 - * - * @param callback - * @param uid - * 鐢ㄦ埛id - * @param request - * @param out - */ - @RequestMapping(value = "countByUid") - public void countByUid(String callback, Long uid, HttpServletRequest request, PrintWriter out) { - - try { - - // 缁熻宸查鍙栭噾棰� 璐︽埛鍘嗗彶鎬绘敹鐩� - double receiveMoneys = hongBaoService.countReceiveMoneysByUid(uid); - - // 鍘嗗彶鎻愮幇鎴愬姛閲戦 - double successMoneys = extractCountService.countSuccessMoneysByUid(uid); - - // 鍘嗗彶鎻愮幇鎬绘鏁般�佹垚鍔熸鏁般�佸け璐ユ鏁� - Map<String, Object> map = extractCountService.countRecordsByUid(uid); - - GsonBuilder gsonBuilder = new GsonBuilder(); - gsonBuilder.serializeNulls(); - Gson gson = gsonBuilder.create(); - - JSONObject data = new JSONObject(); - data.put("map", gson.toJson(map)); - data.put("successMoneys", gson.toJson(successMoneys)); - data.put("receiveMoneys", gson.toJson(receiveMoneys)); - - JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data)); - - } catch (Exception e) { - // TODO: handle exception - JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鎿嶄綔寮傚父")); - e.printStackTrace(); - } - } - - /** - * 鏍规嵁鐢ㄦ埛id鏌ヨ鐩稿簲璁㈠崟鍒楄〃 - * - * @param callback - * @param pageIndex - * @param key - * 鐢ㄦ埛id - * @param out - */ - @RequestMapping(value = "getOrderRecordList") - public void getOrderRecordList(String callback, Integer pageIndex, Integer pageSize, Long key, String startTime, - String endTime, PrintWriter out) { - - try { - - if (key == null) { - JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏈幏鍙栧埌鐢ㄦ埛id")); - return; - } - - if (!StringUtil.isNullOrEmpty(endTime)) { - SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); - Date enddate = sdf.parse(endTime); - Calendar c = Calendar.getInstance(); - c.setTime(enddate); - c.add(Calendar.DAY_OF_MONTH, 1);// 浠婂ぉ+1澶� - endTime = sdf.format(c.getTime()); - } - - if (pageIndex == null) - pageIndex = 1; - - if (pageSize == null) - pageSize = Constant.PAGE_SIZE; - - List<HongBao> list = hongBaoService.selectOrderByUid(pageIndex, pageSize, key, startTime, endTime); - if (list == null || list.size() == 0) { - JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璇ョ敤鎴锋棤璁㈠崟璁板綍")); - return; - } - - Map<String, List<TaoBaoWeiQuanOrder>> wq = new HashMap<String, List<TaoBaoWeiQuanOrder>>(); - for (HongBao hongBao : list) { - String orderId = hongBao.getOrderId(); - - List<TaoBaoWeiQuanOrder> weiQuanList = taoBaoWeiQuanOrderService.getWeiQuanSuccessOrders(orderId); - if (weiQuanList != null && weiQuanList.size() > 0) { - wq.put(orderId, weiQuanList); - } - } - - /* 楠岃瘉缃戠粶: */ - StringBuffer auctionIdBuf = new StringBuffer(); - - List<Map<String, Object>> listmap = new ArrayList<Map<String, Object>>(); - - for (HongBao hongBao : list) { - Map<String, Object> map = new HashMap<String, Object>(); - - Long preGettime = hongBao.getPreGettime(); - Long getTime = hongBao.getGetTime(); - Integer state = hongBao.getState(); - Integer type = hongBao.getType(); - String orderId = hongBao.getOrderId(); - - // 鍗曠瑪鏀剁泭閲戦 - BigDecimal money = hongBao.getMoney(); - - map.put("getTime", getTime); - - // 瀛愯鍗曞彿 - String orderItemId = ""; - map.put("orderItemId", orderItemId); - - /* 璁㈠崟鐘舵�佸垽鏂細1 璁㈠崟宸蹭粯娆� 2銆佽鍗曞凡缁撶畻 4銆佽鍗曞け鏁� */ - if (state == HongBao.STATE_SHIXIAO) { - map.put("orderState", 4); // 璁㈠崟澶辨晥 - } else if (state == HongBao.STATE_BUKELINGQU) { - Integer orderState = null; - - if (type == HongBao.TYPE_SHARE_GOODS) { - // 鍒嗕韩璁㈠崟 - Long hongbaoId = hongBao.getId(); - PidOrder pidOrder = pidOrderService.getPidOrderByHongBaoId(hongbaoId); - String pidstate = pidOrder.getState(); - if ("璁㈠崟浠樻".equals(pidstate)) { - orderState = 1; - } else if ("璁㈠崟缁撶畻".equals(pidstate)) { - orderState = 2; - } else if ("璁㈠崟澶辨晥".equals(pidstate)) { - orderState = 4; - } - } else { - if (preGettime != null && preGettime > 0) { - orderState = 2; // 璁㈠崟缁撶畻 - } else { - orderState = 1; // 璁㈠崟宸蹭粯娆� - } - } - map.put("orderState", orderState); - - } else if (state == HongBao.STATE_KELINGQU || state == HongBao.STATE_YILINGQU) { - map.put("orderState", 2); // 璁㈠崟缁撶畻 - } - - /* 璁㈠崟杩斿埄鐘舵�侊細 2鏈埌璐� 3宸插埌璐� 4宸插け鏁� */ - - if (HongBao.STATE_YILINGQU == state) { - map.put("moneyState", 3); // 宸插埌璐� - } else if (HongBao.STATE_BUKELINGQU == state || HongBao.STATE_KELINGQU == state) { - map.put("moneyState", 2); // 鏈埌璐� - } else { - map.put("moneyState", 4); // 宸插け鏁� - } - - /* 璁㈠崟绫诲瀷锛�1绯荤粺绾㈠寘 2銆佽嚜璐鍗� 3銆侀個璇疯鍗� 4 鍒嗕韩璁㈠崟 */ - int rebateSource = 0; - if (type == HongBao.TYPE_HUODONG || type == HongBao.TYPE_XINREN) { - // 3-娲诲姩绾㈠寘 4-鏂颁汉绾㈠寘 - rebateSource = 1; - } else if (type == HongBao.TYPE_JINGDONG || type == HongBao.TYPE_TAOBAO) { - // 鑷喘璁㈠崟 - rebateSource = 2; - } else if (type == HongBao.TYPE_YAOQING || type == HongBao.TYPE_YIJI || type == HongBao.TYPE_ERJI - || type == HongBao.TYPE_SHARE_ERJI || type == HongBao.TYPE_SHARE_YIJI) { - // 閭�璇蜂汉鑷喘璁㈠崟+閭�璇蜂汉鍒嗕韩璁㈠崟 - rebateSource = 3; - } else if (type == HongBao.TYPE_SHARE_GOODS) { - // 鍒嗕韩璁㈠崟 - rebateSource = 4; - } - map.put("rebateSource", rebateSource); - - // 鑾峰彇璁㈠崟淇℃伅 - Map<String, Object> inMap = getOrderItem(hongBao); - - OrderItem orderItem = (OrderItem) inMap.get("orderItem"); - Long endtime = (Long) inMap.get("endtime"); - Long thirdCreateTime = (Long) inMap.get("thirdCreateTime"); - - /* 鍒濆鍖� 绌哄�� */ - if (orderItem == null) { - orderItem = new OrderItem(); - map.put("goodsStae", "-1"); - } - - // 璁㈠崟鏉ユ簮 0 鏃� 1娣樺疂 2 浜笢 - map.put("orderSource", 1); - - // 褰撳墠瀹為檯杩斿埄閲戦 - orderItem.setFanMoney(money); - - String itemOrderId = orderItem.getOrderId(); - // 绾㈠寘瀵瑰簲璁㈠崟鍙� - if (StringUtil.isNullOrEmpty(itemOrderId)) - orderItem.setOrderId(orderId); - - Long auctionId = orderItem.getAuctionId(); - if (auctionId != null) { - auctionIdBuf.append(auctionId + ","); - } else { - if (!StringUtil.isNullOrEmpty(orderId)) { - List<TaoBaoOrder> taoBaoOrders = taoBaoOrderService.getTaoBaoOrderByOrderId(orderId); - if (taoBaoOrders != null && taoBaoOrders.size() > 0) { - TaoBaoOrder taoBaoOrder = taoBaoOrders.get(0); - Long auctionId2 = taoBaoOrder.getAuctionId(); - orderItem.setAuctionId(auctionId2); - auctionIdBuf.append(auctionId + ","); - - orderItem.setPayMoney(taoBaoOrder.getPayment()); - orderItem.setTitle(taoBaoOrder.getTitle()); - - String settlementTime = taoBaoOrder.getSettlementTime(); - - SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); - if (!StringUtil.isNullOrEmpty(settlementTime)) { - Date settleDate = sdf.parse(settlementTime); - endtime = settleDate.getTime(); - } - - String createTime = taoBaoOrder.getCreateTime(); - if (!StringUtil.isNullOrEmpty(createTime)) { - Date createDate = sdf.parse(createTime); - thirdCreateTime = createDate.getTime(); - } - - } - - } - } - - map.put("orderItem", orderItem); - - // 鏀惰揣鏃堕棿 - map.put("endtime", endtime); - // 涓嬪崟鏃堕棿 - map.put("thirdCreateTime", thirdCreateTime); - - listmap.add(map); - } - - /* 楠岃瘉缃戠粶: 鑾峰彇鍟嗗搧閾炬帴 鍥剧墖閾炬帴 */ - List<TaoBaoGoodsBrief> goodsBriefList = null; - if (auctionIdBuf != null && auctionIdBuf.length() > 0) { - String auctionIds = auctionIdBuf.toString(); - - String ids = auctionIds.substring(0, auctionIds.length() - 1); - goodsBriefList = TaoKeApiUtil.getBatchGoodsInfos(ids); - } - - List<Map<String, Object>> listResult = new ArrayList<Map<String, Object>>(); - - Iterator<Map<String, Object>> iterator = listmap.iterator(); - while (iterator.hasNext()) { - - Map<String, Object> map = iterator.next(); - - int goodsStae = 1; - String auctionUrl = ""; // 鍟嗗搧閾炬帴 - - OrderItem orderItem = (OrderItem) map.get("orderItem"); - Long auctionId = orderItem.getAuctionId(); - if (auctionId != null) { - if (goodsBriefList != null && goodsBriefList.size() > 0) { - for (TaoBaoGoodsBrief taoBaoGoodsBrief : goodsBriefList) { - Long auctionIdTB = taoBaoGoodsBrief.getAuctionId(); - if (auctionId.equals(auctionIdTB)) { - goodsStae = 0;// 鍦ㄥ敭 - auctionUrl = taoBaoGoodsBrief.getAuctionUrl(); - String pictUrl = taoBaoGoodsBrief.getPictUrl(); - orderItem.setPicture(pictUrl); - } - } - } - } - - map.put("goodsStae", goodsStae); // - map.put("auctionUrl", auctionUrl); // 鍟嗗搧閾炬帴 - listResult.add(map); - - } - - int count = hongBaoService.countOrderByUid(key, startTime, endTime); - int totalPage = count % pageSize == 0 ? count / pageSize : count / pageSize + 1; - PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage); - - // 璇ユ湡闂寸殑鎬绘敹鐩� - double countProfit = hongBaoService.countProfitByUid(key, startTime, endTime); - - JSONObject data = new JSONObject(); - data.put("pe", pe); - data.put("countProfit", countProfit); - data.put("listmap", listResult); - - out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data))); - - } catch (Exception e) { - e.printStackTrace(); - out.print(JsonUtil.loadFalseResult(e.getMessage())); - } - } - - /** - * 鏍规嵁鐢ㄦ埛id鏌ヨ鐩稿簲璁㈠崟鍒楄〃 - * - * @param callback - * @param pageIndex - * @param key - * 鐢ㄦ埛id - * @param out - */ - @RequestMapping(value = "getOrderList") - public void getOrderList(String callback, Integer pageIndex, Integer pageSize, Long key, String startTime, - String endTime, PrintWriter out) { - - try { - - if (key == null) { - JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏈幏鍙栧埌鐢ㄦ埛id")); - return; - } - - if (!StringUtil.isNullOrEmpty(endTime)) { - SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); - Date enddate = sdf.parse(endTime); - Calendar c = Calendar.getInstance(); - c.setTime(enddate); - c.add(Calendar.DAY_OF_MONTH, 1);// 浠婂ぉ+1澶� - endTime = sdf.format(c.getTime()); - } - - if (pageIndex == null) - pageIndex = 1; - - if (pageSize == null) - pageSize = Constant.PAGE_SIZE; - - List<HongBao> list = hongBaoService.selectOrderByUid(pageIndex, pageSize, key, startTime, endTime); - if (list == null || list.size() == 0) { - JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璇ョ敤鎴锋棤璁㈠崟璁板綍")); - return; - } - - /* 楠岃瘉缃戠粶: */ - StringBuffer auctionIdBuf = new StringBuffer(); - - List<Map<String, Object>> listmap = new ArrayList<Map<String, Object>>(); - - for (HongBao hongBao : list) { - Map<String, Object> map = new HashMap<String, Object>(); - - Long preGettime = hongBao.getPreGettime(); - Long getTime = hongBao.getGetTime(); - Integer state = hongBao.getState(); - Integer type = hongBao.getType(); - String orderId = hongBao.getOrderId(); - Date balanceTime = hongBao.getBalanceTime(); - - // 鑷喘璁㈠崟id - Long orderItemId = hongBao.getOrderItemId(); - // 鍗曠瑪鏀剁泭閲戦 - BigDecimal money = hongBao.getMoney(); - - map.put("getTime", getTime); - map.put("orderItemId", orderItemId); - - if (state == HongBao.STATE_SHIXIAO) { - if (balanceTime != null) { - map.put("orderState", 1); // 缁存潈鎴愬姛 - } else { - map.put("orderState", 2); // 璁㈠崟澶辨晥 - } - } else if (state == HongBao.STATE_BUKELINGQU || state == HongBao.STATE_KELINGQU) { - if (preGettime != null && preGettime > 0) { - map.put("orderState", 0); // 璁㈠崟缁撶畻 - } else { - map.put("orderState", 3); // 璁㈠崟浠樻涓� 鏈粨绠� - } - } else { - map.put("orderState", 0); // 璁㈠崟宸蹭粯娆�-宸茬粨绠� - } - - if (HongBao.STATE_YILINGQU == state) { - map.put("moneyState", 3); // 宸插埌璐� - } else if (HongBao.STATE_BUKELINGQU == state || HongBao.STATE_KELINGQU == state) { - map.put("moneyState", 2); // 鏈埌璐� - } else { - map.put("moneyState", 4); // 宸插け鏁� - } - - /* - * 1-娣樺疂璁㈠崟 2-浜笢璁㈠崟 3-娲诲姩绾㈠寘 4-鏂颁汉绾㈠寘 5.閭�璇峰ソ鍙嬬孩鍖�(甯冨績琛楃殑) 6.涓�绾у垎閿�绾㈠寘 7.浜岀骇鍒嗛攢绾㈠寘 - * 20-鍒嗕韩鍟嗗搧璁㈠崟 - */ - int rebateSource = 0; - if (type == HongBao.TYPE_HUODONG || type == HongBao.TYPE_XINREN) { - - /* 3-娲诲姩绾㈠寘 4-鏂颁汉绾㈠寘 */ - rebateSource = 1; - - } else if (type == HongBao.TYPE_JINGDONG || type == HongBao.TYPE_TAOBAO) { - - /* 鑷喘璁㈠崟 */ - rebateSource = 2; - - } else if (type == HongBao.TYPE_YIJI || type == HongBao.TYPE_ERJI || type == HongBao.TYPE_YAOQING - || type == HongBao.TYPE_SHARE_ERJI || type == HongBao.TYPE_SHARE_YIJI) { - - /* 閭�璇疯鍗� 鍒嗛攢绾㈠寘瀵瑰簲鐨勬渶涓婄骇绾㈠寘 */ - rebateSource = 3; - - } else if (type == HongBao.TYPE_SHARE_GOODS) { - - /* 鍒嗕韩璁㈠崟 */ - rebateSource = 4; - - } - map.put("rebateSource", rebateSource); - - // 鑾峰彇璁㈠崟淇℃伅 - Map<String, Object> inMap = getOrderItem(hongBao); - - OrderItem orderItem = (OrderItem) inMap.get("orderItem"); - Long endtime = (Long) inMap.get("endtime"); - Long thirdCreateTime = (Long) inMap.get("thirdCreateTime"); - - /* 鍒濆鍖� 绌哄�� */ - if (orderItem == null) { - orderItem = new OrderItem(); - map.put("goodsStae", "-1"); - } - - // 璁㈠崟鏉ユ簮 0 鏃� 1娣樺疂 2 浜笢 - map.put("orderSource", 1); - - // 褰撳墠瀹為檯杩斿埄閲戦 - orderItem.setFanMoney(money); - - String itemOrderId = orderItem.getOrderId(); - // 绾㈠寘瀵瑰簲璁㈠崟鍙� - if (StringUtil.isNullOrEmpty(itemOrderId)) - orderItem.setOrderId(orderId); - - Long auctionId = orderItem.getAuctionId(); - if (auctionId == null) { - if (!StringUtil.isNullOrEmpty(orderId)) { - List<TaoBaoOrder> taoBaoOrders = taoBaoOrderService.getTaoBaoOrderByOrderId(orderId); - if (taoBaoOrders != null && taoBaoOrders.size() > 0) { - TaoBaoOrder taoBaoOrder = taoBaoOrders.get(0); - Long auctionId2 = taoBaoOrder.getAuctionId(); - orderItem.setAuctionId(auctionId2); - auctionIdBuf.append(auctionId + ","); - - orderItem.setPayMoney(taoBaoOrder.getPayment()); - orderItem.setTitle(taoBaoOrder.getTitle()); - - String settlementTime = taoBaoOrder.getSettlementTime(); - - SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); - if (!StringUtil.isNullOrEmpty(settlementTime)) { - Date settleDate = sdf.parse(settlementTime); - endtime = settleDate.getTime(); - } - - String createTime = taoBaoOrder.getCreateTime(); - if (!StringUtil.isNullOrEmpty(createTime)) { - Date createDate = sdf.parse(createTime); - thirdCreateTime = createDate.getTime(); - } - - } - - } - } - - map.put("orderItem", orderItem); - - // 鏀惰揣鏃堕棿 - map.put("endtime", endtime); - // 涓嬪崟鏃堕棿 - map.put("thirdCreateTime", thirdCreateTime); - - listmap.add(map); - } - - int count = hongBaoService.countOrderByUid(key, startTime, endTime); - int totalPage = count % pageSize == 0 ? count / pageSize : count / pageSize + 1; - PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage); - - // 璇ユ湡闂寸殑鎬绘敹鐩� - double countProfit = hongBaoService.countProfitByUid(key, startTime, endTime); - - JSONObject data = new JSONObject(); - data.put("pe", pe); - data.put("countProfit", countProfit); - data.put("listmap", listmap); - - out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data))); - - } catch (Exception e) { - e.printStackTrace(); - out.print(JsonUtil.loadFalseResult(e.getMessage())); - } - } - - public Map<String, Object> getOrderItem(HongBao hongBao) { - - OrderItem orderItem = null; - - Long endtime = new Long(0); - Long thirdCreateTime = new Long(0); - - Map<String, Object> map = new HashMap<String, Object>(); - - Integer type = hongBao.getType(); - if (type == null) { - return map; - } - - if (type == HongBao.TYPE_HUODONG || type == HongBao.TYPE_XINREN) { - /* 3-娲诲姩绾㈠寘 4-鏂颁汉绾㈠寘 */ - - } else if (type == HongBao.TYPE_JINGDONG || type == HongBao.TYPE_TAOBAO) { - /* 鑷喘璁㈠崟 */ - - Long orderItemId = hongBao.getOrderItemId(); - orderItem = orderItemServcie.selectByPrimaryKey(orderItemId); - - // 涓嬪崟鏃堕棿 - Order order = hongBao.getOrder(); - if (order != null) { - Date thirdCreateTime2 = order.getThirdCreateTime(); - if (thirdCreateTime2 != null) { - thirdCreateTime = thirdCreateTime2.getTime(); - } - } - - if (orderItem != null) { - - // 缁撴潫鏃堕棿 - Long settlementTime = orderItem.getSettlementTime(); - if (settlementTime != 0) { - endtime = settlementTime; - } - - // 閫�娆炬椂闂翠笉涓虹┖ 鍒欏凡閫�娆炬椂闂翠负缁撴潫鏃堕棿 - Long refundTime = orderItem.getRefundTime(); - if (refundTime != 0) { - endtime = refundTime; - } - - } - - } else if (type == HongBao.TYPE_YIJI || type == HongBao.TYPE_ERJI || type == HongBao.TYPE_YAOQING - || type == HongBao.TYPE_SHARE_ERJI || type == HongBao.TYPE_SHARE_YIJI) { - /* 閭�璇疯鍗� 鍒嗛攢绾㈠寘瀵瑰簲鐨勬渶涓婄骇绾㈠寘 */ - - HongBao parent = hongBao.getParent(); - - if (parent != null) { - Long pid = parent.getId(); - HongBao phongbao = hongBaoService.selectByPrimaryKey(pid); - Map<String, Object> map2 = getOrderItem(phongbao); - return map2; - } - - } else if (type == HongBao.TYPE_SHARE_GOODS) { - /* 鍒嗕韩璁㈠崟 */ - - Long hongbaoId = hongBao.getId(); - PidOrder pidOrder = pidOrderService.getPidOrderByHongBaoId(hongbaoId); - - if (pidOrder != null) { - orderItem = new OrderItem(); - - orderItem.setOrderId(pidOrder.getOrderId()); - orderItem.setTitle(pidOrder.getGoodsTitle()); - orderItem.setPayMoney(pidOrder.getPayMoney()); - orderItem.setAuctionId(pidOrder.getAuctionId()); - - // 涓嬪崟鏃堕棿 - Date createTime = pidOrder.getCreateTime(); - if (createTime != null) { - thirdCreateTime = createTime.getTime(); - } - - // 缁撶畻鏃堕棿 - Date balanceTime = pidOrder.getBalanceTime(); - if (balanceTime != null) { - endtime = balanceTime.getTime(); - } - - String param = hongBao.getParam(); - if (!StringUtil.isNullOrEmpty(param)) { - String picture = param.substring(11, param.length()); - if (!StringUtil.isNullOrEmpty(picture)) { - orderItem.setPicture(picture.substring(0, picture.length() - 1)); - } - } - } - } - - map.put("orderItem", orderItem); - map.put("endtime", endtime); - map.put("thirdCreateTime", thirdCreateTime); - - return map; - - } - - /** - * 鏍¢獙鐢ㄦ埛璧勯噾鏄惁寮傚父 - * - * @param uid - * @param out - */ - @RequestMapping(value = "checkMoney") - public void checkMoney(String callback, String uid, PrintWriter out) { - - if (StringUtil.isNullOrEmpty(uid)) { - JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("UID涓嶈兘涓虹┖")); - return; - } - - // 宸插埌璐︾殑绾㈠寘 - int count = hongBaoService.getCount(HongBao.STATE_YILINGQU); - if (count == 0) { - JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璧勯噾寮傚父")); - return; - } - - List<Integer> listChecked = extractService.checkExtract(uid); - if (listChecked == null || listChecked.size() == 0) { - JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("璧勯噾姝e父")); - return; - } - - Integer diversity = listChecked.get(0); - if (diversity == 0) { - JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璧勯噾寮傚父")); - } else { - JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("璧勯噾姝e父")); - } - - } - -} +package com.yeshi.fanli.controller.admin; + +import java.io.OutputStream; +import java.io.PrintWriter; +import java.math.BigDecimal; +import java.net.URLDecoder; +import java.net.URLEncoder; +import java.text.ParseException; +import java.text.SimpleDateFormat; +import java.util.ArrayList; +import java.util.Calendar; +import java.util.Date; +import java.util.List; +import java.util.Map; + +import javax.annotation.Resource; +import javax.servlet.http.HttpServletRequest; +import javax.servlet.http.HttpServletResponse; + +import org.springframework.stereotype.Controller; +import org.springframework.web.bind.annotation.RequestMapping; +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.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.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; +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.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.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.RedisManager; +import com.yeshi.fanli.util.StringUtil; +import com.yeshi.fanli.util.TimeUtil; + +import net.sf.json.JSONObject; + +@Controller +@RequestMapping("admin/new/api/v1/extract") +public class ExtractAdminController { + + @Resource + private ExtractService extractService; + + @Resource + private ConfigService configService; + + @Resource + private UserInfoCountService userInfoCountService; + + @Resource + private ExtractCountService extractCountService; + + @Resource + private PushRecordService pushRecordService; + + @Resource + private PushController xingePushController; + + @Resource + private ExtractAuditRecordService extractAuditRecordService; + + @Resource + private HongBaoV2CountService hongBaoV2CountService; + + @Resource + private AdminUserService adminUserService; + + @Resource + private RedisManager redisManager; + + @Resource + private TaoBaoOrderService taoBaoOrderService; + + @Resource + private TaoBaoWeiQuanOrderService taoBaoWeiQuanOrderService; + + @Resource + private UserInfoExtraService userInfoExtraService; + + @Resource + private CommonOrderCountService commonOrderCountService; + + /** + * + * 鏂规硶璇存槑: 閫氳繃鎻愮幇璇锋眰 鍙痡sonP鏂瑰紡 + * + * @param id + * @param code + * 楠岃瘉鐮� + * @param out + * @param request + */ + @RequestMapping(value = "passExtractJP") + public void passExtractJP(String callback, Long id, String code, PrintWriter out, HttpServletRequest request) { + + /* 妫�楠屾槸鍚︾櫥闄� */ + AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN); + if (admin == null) { + JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("褰撳墠璐︽埛澶辨晥,璇烽噸鏂扮櫥闄嗐��")); + return; + } + + /* 妫�楠屾槸鍚﹂�氳繃楠岃瘉 */ + String codeType = (String) request.getSession().getAttribute(Constant.SESSION_EXTRACT_VERIFY_RESULT); + if (!"1".equals(codeType)) { + JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(3, "閭楠岃瘉鏈�氳繃")); + return; + } + + /* 鍏佽鎻愮幇 鎿嶄綔 */ + Integer integer = extractService.passExtract(id, admin); + + // 鏃ュ織璁板綍 + if (integer == null) { + JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("宸查�氳繃")); + 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 + "鐨勬彁鐜扮敵璇蜂笉瀛樺湪"); + } else { + JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("璇ョ敤鎴峰凡琚鐞�,璇峰埛鏂�")); + LogHelper.userInfo( + "[ip:" + IPUtil.getRemotIP(request) + "][绠$悊鍛�:" + admin.getName() + "] 鍚屾剰鎻愮幇id=" + id + "鐨勬彁鐜扮敵璇风姸鎬佸紓甯�"); + } + + } + + /** + * + * 鏂规硶璇存槑: 鎷掔粷鎻愮幇璇锋眰jsonP + * + * @author mawurui createTime 2018骞�3鏈�14鏃� 涓嬪崍3:15:55 + * @param id + * @param reason + * @param out + * @param request + */ + @RequestMapping(value = "rejectExtractJP") + public void rejectExtractJP(String callback, Long id, String code, String reason, PrintWriter out, + HttpServletRequest request) { + /* 妫�楠屾槸鍚︾櫥闄� */ + AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN); + if (admin == null) { + JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("褰撳墠璐︽埛澶辨晥,璇烽噸鏂扮櫥闄�")); + return; + } + + /* 妫�楠屾槸鍚﹂�氳繃楠岃瘉 */ + String codeType = (String) request.getSession().getAttribute(Constant.SESSION_EXTRACT_VERIFY_RESULT); + if (!"1".equals(codeType)) { + JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(3, "閭楠岃瘉鏈�氳繃")); + return; + } + + try { + // 缂栫爜杞崲 + reason = URLDecoder.decode(reason, "UTF-8"); + } catch (Exception e1) { + e1.printStackTrace(); + } + + try { + + extractService.rejectExtract(id, reason, admin);// 鎻愮幇澶辫触 + + JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("鎷掔粷鎴愬姛")); + + LogHelper.userInfo("[ip:" + IPUtil.getRemotIP(request) + "]" + admin.getName() + "鎷掔粷浜哰id=" + id + + "]鐨勬彁鐜扮敵璇�!鎷掔粷鍘熷洜鏄�" + reason); + + } catch (ObjectStateException e) { + LogHelper.userInfo( + "[ip:" + IPUtil.getRemotIP(request) + "][绠$悊鍛�:" + admin.getName() + "] 鎷掔粷鎻愮幇id=" + id + "鐨勬彁鐜扮敵璇风姸鎬佸紓甯�!"); // + + JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e.getMessage())); + + } catch (NotExistObjectException e) { + LogHelper.userInfo( + "[ip:" + IPUtil.getRemotIP(request) + "][绠$悊鍛�:" + admin.getName() + "] 鎷掔粷鎻愮幇id=" + id + "鐨勬彁鐜扮敵璇蜂笉瀛樺湪!"); + + JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e.getMessage())); + } + + } + + /** + * 鑾峰彇浠婃棩鎻愮幇璁板綍锛氫粖鏃ユ�婚銆佹�绘鏁般�佹垚鍔熸鏁般�佸け璐ユ鏁� 鑾峰彇绯荤粺鎻愮幇璁板綍锛氭�婚銆佹�绘鏁� + * + * @param out + */ + @RequestMapping(value = "countExtract") + public void countExtract(String callback, PrintWriter out) { + + Map<String, Object> totalcount = extractCountService.getTodayCount(); + + // 浠婃棩鎻愮幇鎴愬姛閲戦 + BigDecimal todayextractMoney = extractCountService.getTodayTotalSuccessMoney(); + + // 褰撳墠鐢ㄦ埛浣欓鎬昏锛氭墍鏈夌敤鎴锋�讳綑棰� + BigDecimal amountMoney = userInfoCountService.countAllMoney(null); + + // 鍙彁鐜伴噾棰濋檺鍒� + String minMoney = configService.get(ConfigKeyEnum.extractMoneyMin.getKey()); + if (minMoney == null) { + minMoney = "0"; + } + // 褰撳墠鍙彁鐜伴噾棰濇�昏锛� 瓒呰繃鏈�浣庢彁鐜伴噾棰�---璁″叆缁熻 + BigDecimal extractApply = userInfoCountService.countAllMoney(Double.parseDouble(minMoney)); + + // 绱宸叉彁鐜伴噾棰濇�昏锛氬凡鎻愮幇鎴愬姛鐨勬�婚/ 娆℃暟 + Map<String, Object> resultData = extractCountService.countTotalSuccess(); + + JSONObject data = new JSONObject(); + data.put("todayCount", totalcount); + data.put("todayextractMoney", todayextractMoney); + + data.put("amountMoney", amountMoney); // 鎵�鏈夌敤鎴锋�讳綑棰� + data.put("extractApply", extractApply); // 鍙彁鐜伴噾棰濇�昏 + data.put("extractNumber", resultData.get("totalamount")); // 鎻愮幇鎴愬姛娆℃暟 + data.put("extractMoney", resultData.get("totalmoney")); // 鎻愮幇鎴愬姛閲戦 + + out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data))); + } + + /** + * 鏌ヨ鎵�鏈夊鏍歌褰曚俊鎭� + * + * @param callback + * @param pageIndex + * @param key + * @param startTime + * @param endTime + * @param out + */ + @RequestMapping(value = "getFinishRecordList") + public void getFinishRecordList(String callback, Integer pageIndex, String key, String startTime, String endTime, + PrintWriter out) { + + try { + + // 璧峰鏃堕棿 涓虹┖璁剧疆榛樿鍊硷細 + if (StringUtil.isNullOrEmpty(startTime)) { + startTime = "1970-01-01"; + } + + // 缁撴潫鏃堕棿 涓虹┖璁剧疆榛樿鍊煎綋鍓嶆棩鏈� + if (StringUtil.isNullOrEmpty(endTime)) { + Date curDate = new Date(); + endTime = TimeUtil.getSimpleDate(curDate); + } + + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); + Date enddate = sdf.parse(endTime); + Calendar c = Calendar.getInstance(); + c.setTime(enddate); + c.add(Calendar.DAY_OF_MONTH, 1);// 浠婂ぉ+1澶� + + endTime = sdf.format(c.getTime()); + + if (pageIndex == null) + pageIndex = 1; + + int pageSize = Constant.PAGE_SIZE; + + List<ExtractAuditRecord> auditList = extractAuditRecordService.getList(pageIndex, pageSize, key, startTime, + endTime); + + int count = extractAuditRecordService.getCount(key, startTime, endTime); + int totalPage = count % pageSize == 0 ? count / pageSize : count / pageSize + 1; + PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage); + + if (auditList == null || auditList.size() == 0) { + out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("鏆傛棤鏁版嵁"))); + } else { + + for (ExtractAuditRecord extractAuditRecord : auditList) { + int countByUid = 0; + int countCancel = 0; + Extract extract = extractAuditRecord.getExtract(); + if (extract != null) { + UserInfo userInfo = extract.getUserInfo(); + Long id = userInfo.getId(); + countByUid = hongBaoV2CountService.countNumberByUid(id); + countCancel = hongBaoV2CountService.countNumberByUidAndState(id, HongBaoV2.STATE_SHIXIAO); + } + extractAuditRecord.setCancelOrderNum((long) countCancel); + extractAuditRecord.setOrderNum((long) countByUid); + } + + JSONObject data = new JSONObject(); + GsonBuilder gsonBuilder = new GsonBuilder(); + gsonBuilder.serializeNulls(); // 閲嶇偣 + Gson gson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create(); + + data.put("pe", pe); + data.put("auditList", gson.toJson(auditList)); + + out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data))); + } + + } catch (Exception e) { + e.printStackTrace(); + out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("鎿嶄綔寮傚父"))); + } + } + + /** + * 鏌ヨ瀹㈡湇涓汉鎻愮幇瀹℃壒璁板綍淇℃伅 + * + * @param callback + * @param pageIndex + * 椤电爜 + * @param key + * 绛涢�夋潯浠� + * @param timeSlot + * 鏌ヨ鏃堕棿娈� + * @param state + * 鏌ョ湅瀹℃牳鐘舵�� + * @param out + * @param request + */ + @RequestMapping(value = "getMyAuditedList") + public void getMyAuditedList(String callback, Integer pageIndex, String key, String timeSlot, Integer state, + PrintWriter out, HttpServletRequest request) { + + try { + + // AdminUser admin = (AdminUser) + // request.getSession().getAttribute(Constant.SESSION_ADMIN); + // if (admin == null) { + // JsonUtil.printMode(out, callback, + // JsonUtil.loadFalseResult("褰撳墠璐︽埛澶辨晥,璇烽噸鏂扮櫥闄�")); + // return; + // } + + int pageSize = Constant.PAGE_SIZE; + Integer days = null; + if ("1".equals(timeSlot)) { + days = 0; // 浠婃棩 + } else if ("2".equals(timeSlot)) { + days = 3; // 鍓�3澶� + } else if ("3".equals(timeSlot)) { + days = 7; // 鍓�7澶� + } + + if (state != null && state != 0 && state != 1 && state != 2) { + state = null; + } + + // 鏌ヨ褰撳墠浜哄憳鐨勫鏍稿垪琛ㄤ俊鎭� + // Long adminId = admin.getId(); + // auditList = + // extractAuditRecordService.getMyAuditedTimeSlotList(pageIndex, + // pageSize, key,state, adminId, days); + // count = extractAuditRecordService.getMyAuditedTimeSlotCount(key, + // state, adminId,days); + + // 鏆備笉鍖哄垎璐﹀彿锛岄粯璁ゆ墍鏈� + List<ExtractAuditRecord> auditList = extractAuditRecordService.getMyAuditedTimeSlotList(pageIndex, pageSize, + key, state, null, days); + if (auditList == null || auditList.size() == 0) { + JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏆傛棤鏁版嵁")); + return; + } + + for (ExtractAuditRecord record : auditList) { + AdminUser adminUser = record.getAdminUser(); + 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(); + if (extract != null) { + Integer extractState = extract.getState(); + if (extractState != null && extractState == Extract.STATE_NOT_PROCESS) { + UserInfo userInfo = extract.getUserInfo(); + if (userInfo != null) { + 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() > 0 + || 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()); + } + + if (record.getExtraInfo().getLess10OrderCount() != null && record.getExtraInfo().getLess10OrderCount() > 10) { + desc.append("鍒峰崟瀚岀枒\n#"); + } + + 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); + int totalPage = count % pageSize == 0 ? count / pageSize : count / pageSize + 1; + PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage); + + GsonBuilder gsonBuilder = new GsonBuilder(); + gsonBuilder.serializeNulls(); + gsonBuilder.setDateFormat("yyyy-MM-dd HH:mm:ss"); + + Gson gson = gsonBuilder.create(); + + JSONObject data = new JSONObject(); + data.put("pe", pe); + data.put("list", gson.toJson(auditList)); + + JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data)); + + } catch (Exception e) { + 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("搴楅摵/鍟嗗搧鏃犲紓甯�")); + } + + /** + * 鑾峰彇浠婃棩鎻愮幇璁板綍锛氫粖鏃ユ�婚銆佹�绘鏁般�佹垚鍔熸鏁般�佸け璐ユ鏁� 鑾峰彇绯荤粺鎻愮幇璁板綍锛氭�婚銆佹�绘鏁� + * + * @param out + */ + @RequestMapping(value = "getMyAuditedCount") + public void getMyAuditedCount(String callback, HttpServletRequest request, PrintWriter out) { + + AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN); + + if (admin == null) { + out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("褰撳墠璐︽埛澶辨晥,璇烽噸鏂扮櫥闄嗐��"))); + } else { + Long adminId = admin.getId(); + + int taskToday = extractCountService.countTodayApply(); + // int countTodayComplete = extractService.countTodayComplete(); + + // 浠婃棩绱澶勭悊鏁版嵁 + int countToday = extractAuditRecordService.getMyAuditedCountToday(adminId); + // 鏈懆绱澶勭悊鏁版嵁 + int countWeek = extractAuditRecordService.getMyAuditedCountWeek(adminId); + // 鏈湀绱澶勭悊鏁版嵁 + int countMonth = extractAuditRecordService.getMyAuditedCountMonth(adminId); + + JSONObject data = new JSONObject(); + data.put("adminUser", admin); + data.put("taskToday", taskToday); + data.put("countToday", countToday); + data.put("countWeek", countWeek); + data.put("countMonth", countMonth); + + out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data))); + } + + } + + /** + * 瀹㈡湇浠诲姟椤甸潰灞曠ず鏁版嵁锛氫紶鍏ユ彁鐜扮敵璇穒d 鍒欐樉绀哄綋鍓嶇敵璇凤紝鑻ユ棤id鍒欐樉绀哄鏈嶄换鍔′笅绗竴涓敵璇锋暟鎹� + * + * @param callback + * @param extractId + * 鎻愮幇id + * @param request + * @param out + */ + @RequestMapping(value = "getIaskInfo") + public void getIaskInfo(String callback, Long extractId, HttpServletRequest request, PrintWriter out) { + try { + + String surplusTime = ""; + JSONObject data = new JSONObject(); + Extract extract = new Extract(); + AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN); + if (admin == null) { + out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("褰撳墠璐︽埛澶辨晥,璇烽噸鏂扮櫥闄嗐��"))); + return; + } + + if (extractId != null) { + /* 浼犲叆鎻愮幇鐢宠id 鏌ヨ鍓嶅鏈嶄换鍔℃暟鎹� */ + + extract = extractService.selectByPrimaryKey(extractId); + if (extract == null) { + out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("褰撳墠鐢宠宸蹭笉瀛樺湪"))); + return; + } + + // 褰撳墠浠诲姟鎸囧畾涓鸿璐︽埛澶勭悊 + /* + * extract.setAdminId(admin.getId()); + * extractService.updateByPrimaryKeySelective(extract); + */ + + BigDecimal beforeMoney = null; + List<ExtractAuditRecord> records = extractAuditRecordService.getbyExtractId(extract.getId()); + if (records != null && records.size() > 0) { + ExtractAuditRecord extractAuditRecord = records.get(0); + if (extractAuditRecord != null) { + beforeMoney = extractAuditRecord.getBeforeMoney(); + } + } + + Long extractTime = extract.getExtractTime(); + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + Date date = new Date(extractTime); + Calendar c = Calendar.getInstance(); + c.setTime(date); + c.add(Calendar.DAY_OF_MONTH, 3);// 浠婂ぉ+3澶� + Date todayTime = new Date(); + String formattodayTime = sdf.format(todayTime); + String formatTime = sdf.format(c.getTime()); + + long diff = sdf.parse(formatTime).getTime() - sdf.parse(formattodayTime).getTime(); + if (diff <= 0) { + surplusTime = "宸茶秴鏃�"; + } else { + surplusTime = DateUtil.dateDiff(formattodayTime, formatTime); + } + + String mark = ""; + UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(extract.getUserInfo().getId()); + if (userInfoExtra != null && !StringUtil.isNullOrEmpty(userInfoExtra.getMark())) { + mark = "璀︽儠锛侊紒 " + userInfoExtra.getMark(); + } + + Integer countOrder = commonOrderCountService.countOderByUidAndLess10(extract.getUserInfo().getId()); + if (countOrder != null && countOrder >= 10) { + if (StringUtil.isNullOrEmpty(mark)) { + mark = "鍒峰崟棰勮锛侊紒"; + } else { + mark = mark + " 鍒峰崟棰勮锛侊紒"; + } + } + data.put("mark", mark); + data.put("extract", extract); + data.put("beforeMoney", beforeMoney); + data.put("surplusTime", surplusTime); + + out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data))); + + } else { + /* 鏈紶鍏ユ彁鐜扮敵璇穒d 鏌ヨ褰撳墠瀹㈡湇浠诲姟 涓殑绗竴涓� 鏁版嵁 */ + + boolean newTask = false; + + // 鏌ヨ涔嬪墠鏈鐞嗗畬鐨勪换鍔� + extract = extractService.getMyTaskInfo(admin.getId()); + + if (extract == null) { + // 鏂颁换鍔� + extract = extractService.getNewTaskInfo(); + if (extract != null) + newTask = true; + } + + if (extract == null) { + out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("鏆傛棤鐢ㄦ埛鎻愮幇鐢宠"))); + } else { + + if (newTask) { + // 褰撳墠浠诲姟鎸囧畾涓鸿璐︽埛澶勭悊 + /* + * extract.setAdminId(admin.getId()); + * + * extractService.updateByPrimaryKeySelective(extract); + */ + } + + BigDecimal beforeMoney = null; + + List<ExtractAuditRecord> records = extractAuditRecordService.getbyExtractId(extract.getId()); + if (records != null && records.size() > 0) { + ExtractAuditRecord extractAuditRecord = records.get(0); + if (extractAuditRecord != null) { + beforeMoney = extractAuditRecord.getBeforeMoney(); + } + } + + Long extractTime = extract.getExtractTime(); + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + Date date = new Date(extractTime); + + Calendar c = Calendar.getInstance(); + c.setTime(date); + c.add(Calendar.DAY_OF_MONTH, 3);// 浠婂ぉ+3澶� + Date todayTime = new Date(); + + String formattodayTime = sdf.format(todayTime); + String formatTime = sdf.format(c.getTime()); + + long diff = sdf.parse(formatTime).getTime() - sdf.parse(formattodayTime).getTime(); + if (diff <= 0) { + surplusTime = "宸茶秴鏃�"; + } else { + surplusTime = DateUtil.dateDiff(formattodayTime, formatTime); + } + + String mark = ""; + UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(extract.getUserInfo().getId()); + if (userInfoExtra != null && !StringUtil.isNullOrEmpty(userInfoExtra.getMark())) { + mark = "璀︽儠锛侊紒 " + userInfoExtra.getMark(); + } + + Integer countOrder = commonOrderCountService.countOderByUidAndLess10(extract.getUserInfo().getId()); + if (countOrder != null && countOrder >= 10) { + if (StringUtil.isNullOrEmpty(mark)) { + mark = "鍒峰崟棰勮锛侊紒"; + } else { + mark = mark + " 鍒峰崟棰勮锛侊紒"; + } + } + + data.put("mark", mark); + data.put("extract", extract); + data.put("beforeMoney", beforeMoney); + data.put("surplusTime", surplusTime); + + out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data))); + } + + } + + } catch (ParseException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + + } + + /** + * 鏌ヨ鐢ㄦ埛鍘嗗彶鎻愮幇璁板綍 + * + * @param callback + * @param pageIndex + * 椤电爜 + * @param key + * 鐢ㄦ埛id + * @param request + * @param out + */ + @RequestMapping(value = "getByUidList") + public void getByUidList(String callback, Integer pageIndex, Long uid, HttpServletRequest request, + PrintWriter out) { + try { + if (uid == null) { + JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鐢ㄦ埛涓嶅瓨鍦�")); + return; + } + + if (pageIndex == null) + pageIndex = 1; + + int pageSize = Constant.PAGE_SIZE; + + List<ExtractAuditRecord> list = extractAuditRecordService.getByUidList(pageIndex, pageSize, uid); + if (list == null || list.size() == 0) { + JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏆傛棤鎻愮幇璁板綍")); + 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); + + GsonBuilder gsonBuilder = new GsonBuilder(); + gsonBuilder.serializeNulls(); // 閲嶇偣 + Gson gson = gsonBuilder.create(); + + JSONObject data = new JSONObject(); + data.put("pe", pe); + data.put("list", gson.toJson(list)); + + JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data)); + + } catch (Exception e) { + // TODO: handle exception + JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鎿嶄綔寮傚父")); + e.printStackTrace(); + } + } + + /** + * 鏁伴噺缁熻 + * + * @param callback + * @param uid + * 鐢ㄦ埛id + * @param request + * @param out + */ + @RequestMapping(value = "countByUid") + public void countByUid(String callback, Long uid, HttpServletRequest request, PrintWriter out) { + + try { + + // 缁熻宸查鍙栭噾棰� 璐︽埛鍘嗗彶鎬绘敹鐩� + BigDecimal receiveMoneys = hongBaoV2CountService.countMoneyByUidAndState(uid, HongBaoV2.STATE_YILINGQU); + if (receiveMoneys == null) { + receiveMoneys = new BigDecimal(0); + } + + // 鍘嗗彶鎻愮幇鎴愬姛閲戦 + double successMoneys = extractCountService.countSuccessMoneysByUid(uid); + + // 鍘嗗彶鎻愮幇鎬绘鏁般�佹垚鍔熸鏁般�佸け璐ユ鏁� + Map<String, Object> map = extractCountService.countRecordsByUid(uid); + + GsonBuilder gsonBuilder = new GsonBuilder(); + gsonBuilder.serializeNulls(); + Gson gson = gsonBuilder.create(); + + JSONObject data = new JSONObject(); + data.put("map", gson.toJson(map)); + data.put("successMoneys", gson.toJson(successMoneys)); + data.put("receiveMoneys", gson.toJson(receiveMoneys)); + + JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data)); + + } catch (Exception e) { + JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鎿嶄綔寮傚父")); + e.printStackTrace(); + } + } + + /** + * 鏍¢獙鐢ㄦ埛璧勯噾鏄惁寮傚父 + * + * @param uid + * @param out + */ + @RequestMapping(value = "checkMoney") + public void checkMoney(String callback, String uid, PrintWriter out) { + + if (StringUtil.isNullOrEmpty(uid)) { + JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("UID涓嶈兘涓虹┖")); + return; + } + + try { + extractService.checkExtract(Long.parseLong(uid)); + JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("璧勯噾姝e父")); + } catch (ExtractException e) { + JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e.getMsg())); + } + } + + + /** + * 涓嬭浇鎻愮幇绾㈠寘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(); + if (list == null || list.size() <= 1) { + JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鏆傛棤鐢ㄦ埛婊¤冻鑷姩鎻愮幇鏉′欢")); + return; + } + + 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") + "\""); + + StringBuilder sb = new StringBuilder(); + 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(); + } 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) { + out.print(JsonUtil.loadFalseResult("涓婁紶鏂囦欢涓嶈兘涓虹┖锛�")); + return; + } + + try { + List<RedPackRecord> list = WXRedPackUtil.readCsv(file.getInputStream()); + extractService.updateManualExtractRecord(list); + out.print(JsonUtil.loadTrueResult("涓婁紶鎴愬姛")); + } catch (ExtractException e) { + out.print(JsonUtil.loadFalseResult(e.getMsg())); + } catch (Exception e) { + e.printStackTrace(); + 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, 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()); + } else { + JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("娌℃湁鏇村浜�")); + return; + } + + JSONObject data = new JSONObject(); + data.put("pe", pe); + data.put("result_list", listResult); + JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data)); + } catch (Exception e) { + JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("鎿嶄綔寮傚父")); + e.printStackTrace(); + } + } +} + -- Gitblit v1.8.0