package com.yeshi.fanli.controller.admin; import java.io.PrintWriter; import java.math.BigDecimal; import java.util.ArrayList; import java.util.Date; import java.util.List; import java.util.Map; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.multipart.MultipartFile; import org.springframework.web.multipart.MultipartHttpServletRequest; 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.dto.ChartTDO; import com.yeshi.fanli.entity.bus.user.HongBaoV2; import com.yeshi.fanli.entity.money.UserMoneyDebt; import com.yeshi.fanli.entity.money.UserMoneyDebt.UserMoneyDebtTypeEnum; import com.yeshi.fanli.entity.money.UserMoneyDetail; import com.yeshi.fanli.entity.money.UserMoneyDetail.UserMoneyDetailTypeEnum; import com.yeshi.fanli.entity.order.CommonOrder; import com.yeshi.fanli.entity.order.HongBaoOrder; import com.yeshi.fanli.entity.order.UserOrderWeiQuanRecord; import com.yeshi.fanli.entity.system.ConfigKeyEnum; import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanDrawBack; import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder; import com.yeshi.fanli.exception.order.CommonOrderException; import com.yeshi.fanli.service.inter.config.ConfigService; import com.yeshi.fanli.service.inter.count.HongBaoV2CountService; import com.yeshi.fanli.service.inter.count.TaoBaoOrderCountService; import com.yeshi.fanli.service.inter.money.UserMoneyDebtService; import com.yeshi.fanli.service.inter.money.UserMoneyDetailService; import com.yeshi.fanli.service.inter.money.tb.TaoBaoWeiQuanDrawBackService; import com.yeshi.fanli.service.inter.order.CommonOrderCountService; import com.yeshi.fanli.service.inter.order.CommonOrderService; import com.yeshi.fanli.service.inter.order.HongBaoOrderService; import com.yeshi.fanli.service.inter.order.OrderProcessService; import com.yeshi.fanli.service.inter.order.OrderService; import com.yeshi.fanli.service.inter.order.UserOrderWeiQuanRecordService; import com.yeshi.fanli.service.inter.order.tb.TaoBaoOrderService; import com.yeshi.fanli.service.inter.order.tb.TaoBaoWeiQuanOrderService; import com.yeshi.fanli.service.inter.user.UserSystemCouponRecordService; import com.yeshi.fanli.tag.PageEntity; import com.yeshi.fanli.util.Constant; import com.yeshi.fanli.util.StringUtil; import com.yeshi.fanli.util.taobao.TaoBaoOrderUtil; import com.yeshi.fanli.vo.order.CommonOrderVO; import net.sf.json.JSONArray; import net.sf.json.JSONObject; @Controller @RequestMapping("admin/new/api/v1/order") public class OrderAdminController { @Resource private OrderService orderService; @Resource private HongBaoV2CountService hongBaoV2CountService; @Resource private CommonOrderCountService commonOrderCountService; @Resource private CommonOrderService commonOrderService; @Resource private TaoBaoOrderService taoBaoOrderService; @Resource private TaoBaoOrderCountService taoBaoOrderCountService; @Resource private TaoBaoWeiQuanDrawBackService taoBaoWeiQuanDrawBackService; @Resource private TaoBaoWeiQuanOrderService taoBaoWeiQuanOrderService; @Resource private UserMoneyDetailService userMoneyDetailService; @Resource private OrderProcessService orderProcessService; @Resource private HongBaoOrderService hongBaoOrderService; @Resource private UserMoneyDebtService userMoneyDebtService; @Resource private UserSystemCouponRecordService userSystemCouponRecordService; @Resource private ConfigService configService; @Resource private UserOrderWeiQuanRecordService userOrderWeiQuanRecordService; /** * 统计历史订单-淘宝订单 * * @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(); } } /** * 查询所有用户订单列表 * * @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, Integer sourceType, Integer riskType, 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 { Date minTime = null; BigDecimal money = null; List listShopId = null; List listGoodsId = null; // 风险 if (riskType != null && !StringUtil.isNullOrEmpty(key) && keyType != null && keyType == 2) { long uid = Long.parseLong(key); // 查询同店铺商品,同商品订单超过一定数量的 List typeList = new ArrayList<>(); typeList.add(HongBaoV2.TYPE_ZIGOU); if (riskType == 1) { listGoodsId = commonOrderCountService.getSameGoodsOrderByUidAndHongBaoType(typeList, uid, Integer.parseInt(configService.get(ConfigKeyEnum.adminMinSameGoodsOrderCount.getKey()))); if (listGoodsId == null || listGoodsId.isEmpty()) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无同商品订单")); return; } } else if (riskType == 2) { listShopId = commonOrderCountService.getSameShopOrderByUidAndHongBaoType(typeList, uid, Integer.parseInt(configService.get(ConfigKeyEnum.adminMinSameShopOrderCount.getKey()))); if (listShopId == null || listShopId.isEmpty()) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无同店铺订单")); return; } } else if (riskType == 3) { money = new BigDecimal(100); minTime = new Date(System.currentTimeMillis() - 1000 * 60 * 60 * 24 * 180L); } } // 查询列表 List list = commonOrderService.listQuery((pageIndex - 1) * pageSize, pageSize, keyType, key, state, type, orderState, startTime, endTime, sourceType, listShopId, listGoodsId, minTime, money); // 统计总数 long count = commonOrderService.countQuery(keyType, key, state, type, orderState, startTime, endTime, sourceType, listShopId, listGoodsId, minTime, money); // 查询是否维权 for (CommonOrderVO order : list) { if (order.getUserId() == null) continue; // 查询是否维权 TaoBaoWeiQuanOrder weiQuanOrder = taoBaoWeiQuanOrderService.listByorderItemId(order.getTradeId()); if (weiQuanOrder != null)// 有维权 { order.setWeiQuanState(weiQuanOrder.getState()); order.setState(CommonOrder.STATE_WQ); TaoBaoWeiQuanDrawBack drawBack = taoBaoWeiQuanDrawBackService.selectByOrderItemIdAndUid( weiQuanOrder.getOrderItemId(), Long.parseLong(order.getUserId())); if (drawBack != null) {// 已经退款 // 计算退款资金 UserMoneyDetail detail = null; switch (order.getHongBaoType()) { case 1: detail = userMoneyDetailService.selectByTypeAndUidAndIdentifyCode( UserMoneyDetailTypeEnum.fanliWeiQuan, Long.parseLong(order.getUserId()), drawBack.getId()); if (detail == null) detail = userMoneyDetailService.selectByTypeAndUidAndIdentifyCode( UserMoneyDetailTypeEnum.weiQuan, Long.parseLong(order.getUserId()), drawBack.getId()); break; case 3: detail = userMoneyDetailService.selectByTypeAndUidAndIdentifyCode( UserMoneyDetailTypeEnum.inviteWeiQuan, Long.parseLong(order.getUserId()), drawBack.getId()); break; case 2: detail = userMoneyDetailService.selectByTypeAndUidAndIdentifyCode( UserMoneyDetailTypeEnum.shareWeiQuan, Long.parseLong(order.getUserId()), drawBack.getId()); break; } if (detail != null) { // 退款成功 order.setWeiQuanBackMoney(detail.getMoney().abs().toString()); } else {// 尚未退款 order.setWeiQuanBackMoney(drawBack.getDrawBackMoney().toString()); // 查询出对应的hongBaoId CommonOrder commonOrder = commonOrderService.selectBySourceTypeAndTradeId( Constant.SOURCE_TYPE_TAOBAO, drawBack.getOrderItemId()); if (commonOrder != null) { HongBaoOrder hongBaoOrder = hongBaoOrderService .selectDetailByCommonOrderId(commonOrder.getId()); if (hongBaoOrder != null) { UserMoneyDebt debt = userMoneyDebtService.selectByTypeAndSourceId( UserMoneyDebtTypeEnum.order, hongBaoOrder.getHongBaoV2().getId()); if (debt != null && debt.getLeftMoney().compareTo(new BigDecimal(0)) > 0) { order.setWeiQuanBackMoney( new BigDecimal(0).subtract(debt.getLeftMoney()).toString());// 未扣除 } } } } } else {// 尚未退款 UserOrderWeiQuanRecord record = userOrderWeiQuanRecordService.selectByOrderInfoAndUid( Long.parseLong(order.getUserId()), weiQuanOrder.getOrderItemId(), Constant.SOURCE_TYPE_TAOBAO); if (record != null) order.setWeiQuanBackMoney("-" + record.getMoney()); else { order.setWeiQuanBackMoney("-" + order.getHongBao()); } } } } 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 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 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; } @RequestMapping(value = "uploadTaoBaoWeiQuanOrder") public void uploadWeiQuanOrder(String callback, HttpServletRequest request, PrintWriter out) { try { // 1. 先判断httpRequest 是否含有文件类型 if (request instanceof MultipartHttpServletRequest) { MultipartHttpServletRequest fileRequest = (MultipartHttpServletRequest) request; MultipartFile file = fileRequest.getFile("file"); List orderList = TaoBaoOrderUtil.getWeiQuanOrders(file.getInputStream()); for (TaoBaoWeiQuanOrder order : orderList) taoBaoWeiQuanOrderService.addWeiQuanOrder(order);// 添加维权订单到数据库 // 处理维权订单 orderProcessService.weiQuanOrder(orderList); } JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("更新成功")); } catch (Exception e) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("更新失败")); } } }