package com.yeshi.fanli.controller.admin; import java.io.PrintWriter; import java.util.ArrayList; import java.util.List; import java.util.Map; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import net.sf.json.JSONArray; 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 org.yeshi.utils.JsonUtil; import com.google.gson.Gson; import com.google.gson.reflect.TypeToken; import com.yeshi.fanli.controller.admin.utils.AdminUtils; import com.yeshi.fanli.entity.admin.OrderAdmin; import com.yeshi.fanli.exception.order.CommonOrderException; import com.yeshi.fanli.service.inter.count.HongBaoV2CountService; import com.yeshi.fanli.service.inter.count.TaoBaoOrderCountService; import com.yeshi.fanli.service.inter.hongbao.HongBaoService; import com.yeshi.fanli.service.inter.order.CommonOrderCountService; import com.yeshi.fanli.service.inter.order.CommonOrderService; import com.yeshi.fanli.service.inter.order.OrderService; import com.yeshi.fanli.service.inter.taobao.TaoBaoOrderService; import com.yeshi.fanli.tag.PageEntity; import com.yeshi.fanli.util.Constant; import com.yeshi.fanli.util.StringUtil; import com.yeshi.fanli.vo.order.CommonOrderVO; @Controller @RequestMapping("admin/new/api/v1/order") public class OrderAdminController { @Resource private OrderService orderService; @Resource private HongBaoService hongBaoService; @Resource private HongBaoV2CountService hongBaoV2CountService; @Resource private CommonOrderCountService commonOrderCountService; @Resource private CommonOrderService commonOrderService; @Resource private TaoBaoOrderService taoBaoOrderService; @Resource private TaoBaoOrderCountService taoBaoOrderCountService; /** * 统计历史订单-淘宝订单 * @param callback * @param request * @param out */ @RequestMapping(value = "countTaoBaoOrder") public void countTaoBaoOrder(String callback, HttpServletRequest request, PrintWriter out) { try { Map countByOdrerType = taoBaoOrderCountService.countByOdrerType(); JSONObject data = new JSONObject(); data.put("typeOrder", countByOdrerType); // 统计今日 未失效订单数量 相同订单号合并为一单 int todayOrder = taoBaoOrderCountService.countToday(); // 统计昨日 未失效订单数量 相同订单号合并为一单 int yesterdayOrder = taoBaoOrderCountService.countYesterday(); data.put("todayOrder", todayOrder); data.put("yesterdayOrder", yesterdayOrder); data.put("genzong", yesterdayOrder); data.put("yesterdayOrder", yesterdayOrder); JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data)); } catch (Exception e) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("统计失败")); e.printStackTrace(); } } @RequestMapping(value = "getOrderList", method = RequestMethod.POST) public void getOrderList(int pageIndex, String key, PrintWriter out) { List orderAdminList = hongBaoService.getOrderAdminList(pageIndex, key); int count = orderService.getCount(key); 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("orderList", JsonUtil.getSimpleGsonWithDateAndSerialization().toJson(orderAdminList)); out.print(JsonUtil.loadTrueResult(data)); } /** * 查询所有用户订单列表 * @param callback * @param pageIndex * @param pageSize * @param uid * @param state * @param type * @param orderState * @param orderNo * @param startTime * @param endTime * @param out */ @RequestMapping(value = "getUserOrderList") public void getUserOrderList(String callback, Integer pageIndex, Integer pageSize, Integer keyType, String key, Integer state, Integer type, Integer orderState, String startTime, String endTime, PrintWriter out) { if (pageIndex == null || pageIndex < 1) { pageIndex = 1; } if (pageSize == null) pageSize = Constant.PAGE_SIZE; if (state != null && state == 0) { state = null;// 所有状态 } if (type != null && type == 0) { type = null; // 所有类型订单 } if (endTime != null && endTime.trim().length() > 0) { endTime += " 23:59:59"; } try { long count = 0; // 查询列表 List list = commonOrderService.listQuery((pageIndex - 1) * pageSize, pageSize, keyType, key, state, type, orderState, startTime, endTime); if (list != null && list.size() > 0) { // 统计总数 count = commonOrderService.countQuery(keyType, key, state, type, orderState, startTime, endTime); } int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1); PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage); JSONObject data = new JSONObject(); data.put("pe", pe); data.put("result_list", list); JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data)); } catch (CommonOrderException e) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e.getMsg())); } catch (Exception e) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("查询失败")); e.printStackTrace(); } } /** * 查询订单列表用户uid * @param callback * @param pageIndex * @param pageSize * @param uid * @param state * @param type * @param orderState * @param orderNo * @param startTime * @param endTime * @param out */ @RequestMapping(value = "getHistoryOrder") public void getHistoryOrder(String callback, Integer pageIndex, Integer pageSize, Long uid, Integer state, Integer type, Integer orderState, String orderNo, String startTime, String endTime, PrintWriter out) { if (uid == null) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("uid不能为空")); return; } if (pageIndex == null || pageIndex < 1) { pageIndex = 1; } if (pageSize == null) pageSize = Constant.PAGE_SIZE; if (state != null && state == 0) { state = null;// 所有状态 } if (type != null && type == 0) { type = null; // 所有类型订单 } if (endTime != null && endTime.trim().length() > 0) { endTime += " 23:59:59"; } try { long count = 0; // 查询列表 List list = commonOrderService.listQueryByUid((pageIndex - 1) * pageSize, pageSize , uid, state, type, orderState, orderNo, startTime, endTime, null); if (list != null && list.size() > 0) { // 统计总数 count = commonOrderService.countQueryByUid(uid, state, type, orderState, orderNo, startTime, endTime, null); } int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1); PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage); JSONObject data = new JSONObject(); data.put("pe", pe); data.put("result_list", list); JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data)); } catch (CommonOrderException e) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e.getMsg())); } catch (Exception e) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("查询失败")); e.printStackTrace(); } } /** * 统计历史渠道产生订单的金额 * * @param callback * @param channelArray * 名字数组 * @param type * 统计类型 1-24小时 2-所有 * @param dateType * 类型 1日 2月 3年 * @param year * 2018 * @param startTime * 2018-12-01 * @param endTime * 2018-12-01 * @param out */ @RequestMapping(value = "get24HOderChannelCharts") public void get24HOderChannelCharts(String callback, String channelArray, 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 && (!StringUtil.isNullOrEmpty(startTime) || !StringUtil.isNullOrEmpty(endTime))) { startTime = null; endTime = null; } List channelList = null; if (channelArray != null && channelArray.trim().length() > 0) { Gson gson = new Gson(); channelList = gson.fromJson(channelArray, new TypeToken>() {}.getType()); } if (channelList == null || channelList.size() == 0) { channelList = new ArrayList(); channelList.add("all"); } 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 { Gson gson = new Gson(); Object objectDate = null; List dateList = AdminUtils.getDateList(dateType, startTime, endTime, year); JSONArray line_list = new JSONArray(); for (String channel : channelList) { List> list = hongBaoV2CountService.count24HOderByChannel(channel, dateType, year, startTime, endTime); if ("all".equalsIgnoreCase(channel)) { channel = "总计"; } JSONObject innerList = new JSONObject(); innerList.put("name", channel); if (dateType != 3) { innerList.put("data", gson.toJson(AdminUtils.dayOrMonthDataFactory(dateType, dateList, list))); } else { // 年视图 Map map = AdminUtils.yearsDataFactory(list); if (objectDate == null) { objectDate = map.get("date"); } innerList.put("data", gson.toJson(map.get("value"))); } 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); JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data)); } catch (Exception e) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常")); e.printStackTrace(); } } /** * 统计提现申请总次数 * @param callback * @param channelArray 渠道名 为空是统计所有 * @param dateType 显示视图:日-1 、月-2、 年-3 * @param state 状态: 1-未到账 2-已到账 3-已失效 * @param year * @param startTime * @param endTime * @param out */ @RequestMapping(value = "getHongBaoNum") public void getHongBaoNum(String callback,String channelArray, Integer dateType, Integer state, 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; } try { JSONObject data = countHistoryHongBao(channelArray, dateType, state, year, startTime, endTime, 1); JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data)); } catch (Exception e) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("系统异常")); e.printStackTrace(); } } /** * 统计提现申请总金额 * @param callback * @param channelArray 渠道名 为空是统计所有 * @param dateType 显示视图:日-1 、月-2、 年-3 * @param state 状态: 1-未到账 2-已到账 3-已失效 * @param year * @param startTime * @param endTime * @param out */ @RequestMapping(value = "getHongBaoMoney") public void getHongBaoMoney(String callback,String channelArray, Integer dateType, Integer state, 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; } try { JSONObject data = countHistoryHongBao(channelArray, dateType, state, year, startTime, endTime, 2); JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data)); } catch (Exception e) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("系统异常")); e.printStackTrace(); } } /** * 统计红包信息 * @param channelArray * @param dateType * @param state * @param year * @param startTime * @param endTime * @return * @throws Exception */ public JSONObject countHistoryHongBao(String channelArray, Integer dateType, Integer state, String year, String startTime, String endTime, int countType) throws Exception { if (dateType != 1 && (!StringUtil.isNullOrEmpty(startTime) || !StringUtil.isNullOrEmpty(endTime))) { startTime = null; endTime = null; } List channelList = null; if (channelArray != null && channelArray.trim().length() > 0) { Gson gson = new Gson(); channelList = gson.fromJson(channelArray, new TypeToken>() {}.getType()); } if (channelList == null || channelList.size() == 0) { channelList = new ArrayList(); channelList.add("all"); } 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; } Gson gson = new Gson(); Object objectDate = null; List dateList = AdminUtils.getDateList(dateType, startTime, endTime, year); JSONArray line_list = new JSONArray(); for (String channel : channelList) { List> list = null; if (countType == 1 ) { list = hongBaoV2CountService.countHongBaoNum(channel, dateType, state, year, startTime, endTime); } else if (countType == 2) { list = hongBaoV2CountService.countHongBaoMoney(channel, dateType, state, year, startTime, endTime); } if ("all".equalsIgnoreCase(channel)) { channel = "总计"; } JSONObject innerList = new JSONObject(); innerList.put("name", channel); if (dateType != 3) { innerList.put("data", gson.toJson(AdminUtils.dayOrMonthDataFactory(dateType, dateList, list))); } else { // 年视图 Map map = AdminUtils.yearsDataFactory(list); if (objectDate == null) { objectDate = map.get("date"); } innerList.put("data", gson.toJson(map.get("value"))); } 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); return data; } /** * 分类型订单数与比例 * @param callback * @param dateType 日 -1 月-2 年-3 * @param type 返利订单-1 分享订单-2 邀请订单-3 * @param year * @param startTime * @param endTime * @param out */ @RequestMapping(value = "getTypeNumber") public void getTypeNumber(String callback, Integer dateType, String typeArray, 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 && (!StringUtil.isNullOrEmpty(startTime) || !StringUtil.isNullOrEmpty(endTime))) { startTime = null; endTime = null; } List channelList = null; if (typeArray != null && typeArray.trim().length() > 0) { Gson gson = new Gson(); channelList = gson.fromJson(typeArray, new TypeToken>() {}.getType()); } if (channelList == null || channelList.size() == 0) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("订单类型不能为空")); 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; } Gson gson = new Gson(); Object objectDate = null; List dateList = AdminUtils.getDateList(dateType, startTime, endTime, year); try { JSONArray line_list = new JSONArray(); for (Integer type : channelList) { List> list = hongBaoV2CountService.countHongBaoType(dateType, type, year, startTime, endTime); JSONObject innerList = new JSONObject(); if (type == 1) { innerList.put("name", "返利订单"); } else if (type == 2) { innerList.put("name", "分享订单"); } else if (type == 3) { innerList.put("name", "邀请订单"); } if (dateType != 3) { innerList.put("data", gson.toJson(AdminUtils.dayOrMonthDataFactory(dateType, dateList, list))); } else { // 年视图 Map map = AdminUtils.yearsDataFactory(list); if (objectDate == null) { objectDate = map.get("date"); } innerList.put("data", gson.toJson(map.get("value"))); } 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); JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data)); } catch (Exception e) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常")); e.printStackTrace(); } } /** * 订单跟踪准确率(返利券用户订单/淘宝联盟订单) * @param callback * @param dateType * @param year * @param startTime * @param endTime * @param out */ @RequestMapping(value = "getTrackAccuracyRate") public void getTrackAccuracyRate(String callback, Integer dateType, String year, String startTime, String endTime, PrintWriter out) { if (dateType != 1 && (!StringUtil.isNullOrEmpty(startTime) || !StringUtil.isNullOrEmpty(endTime))) { startTime = null; endTime = null; } 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 { Gson gson = new Gson(); Object objectDate = null; List dateList = AdminUtils.getDateList(dateType, startTime, endTime, year); JSONArray line_list = new JSONArray(); List> list = commonOrderCountService.getTrackAccuracyRate(dateType, year, startTime, endTime); JSONObject innerList = new JSONObject(); innerList.put("name", "总计"); if (dateType != 3) { innerList.put("data", gson.toJson(AdminUtils.dayOrMonthDataFactory(dateType, dateList, list))); } else { // 年视图 Map map = AdminUtils.yearsDataFactory(list); if (objectDate == null) { objectDate = map.get("date"); } innerList.put("data", gson.toJson(map.get("value"))); } 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); JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data)); } catch (Exception e) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常")); e.printStackTrace(); } } /** * 当前未收货订单数 * @param callback * @param type 订单状态-暂未使用 * @param out */ @RequestMapping(value = "getHistoryUnreceived") public void getHistoryUnreceived(String callback, Integer type, PrintWriter out) { try { Long total = commonOrderCountService.countByState(1); if (total == null) { total = 0L; } JSONObject data = new JSONObject(); data.put("total", total); JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data)); } catch (Exception e) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常")); e.printStackTrace(); } } /** * 维权订单数 * @param callback * @param dateType * @param year * @param startTime * @param endTime * @param out */ @RequestMapping(value = "getWeiQaunOrderNumber") public void getWeiQaunOrderNumber(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; } try { JSONObject data = countWeiQaunOrder(dateType, year, startTime, endTime, 1); JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data)); } catch (Exception e) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("系统异常")); e.printStackTrace(); } } /** * 维权订单金额 * @param callback * @param dateType * @param year * @param startTime * @param endTime * @param out */ @RequestMapping(value = "getWeiQaunOrderMoney") public void getWeiQaunOrderMoney(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; } try { JSONObject data = countWeiQaunOrder(dateType, year, startTime, endTime, 2); JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data)); } catch (Exception e) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("系统异常")); e.printStackTrace(); } } /** * 统计红包信息 * @param channelArray * @param dateType * @param state * @param year * @param startTime * @param endTime * @return * @throws Exception */ public JSONObject countWeiQaunOrder(Integer dateType, String year, String startTime, String endTime, int countType) throws Exception { if (dateType != 1 && (!StringUtil.isNullOrEmpty(startTime) || !StringUtil.isNullOrEmpty(endTime))) { startTime = null; endTime = null; } 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; } Gson gson = new Gson(); Object objectDate = null; List dateList = AdminUtils.getDateList(dateType, startTime, endTime, year); JSONArray line_list = new JSONArray(); List> list = null; if (countType == 1 ) { list = commonOrderCountService.countWeiQaunOrderNumber(dateType, year, startTime, endTime); } else if (countType == 2) { list = commonOrderCountService.countWeiQaunOrderMoney(dateType, year, startTime, endTime); } JSONObject innerList = new JSONObject(); innerList.put("name", "总计"); if (dateType != 3) { innerList.put("data", gson.toJson(AdminUtils.dayOrMonthDataFactory(dateType, dateList, list))); } else { // 年视图 Map map = AdminUtils.yearsDataFactory(list); if (objectDate == null) { objectDate = map.get("date"); } innerList.put("data", gson.toJson(map.get("value"))); } 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); return data; } }