map 改造

yujian

2019-10-08 0c78c7aaeaa5a427bc8a5c5faf3cd6bbb589c2da

 fanli/src/main/java/com/yeshi/fanli/controller/admin/OrderAdminController.java

@@ -1,6 +1,7 @@
package com.yeshi.fanli.controller.admin;



import java.io.PrintWriter;

import java.math.BigDecimal;

import java.util.ArrayList;

import java.util.List;

import java.util.Map;

@@ -10,30 +11,40 @@


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.entity.bus.user.HongBaoV2;

import com.yeshi.fanli.dto.ChartTDO;

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.taobao.TaoBaoWeiQuanDrawBack;

import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder;

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.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.taobao.TaoBaoOrderService;

import com.yeshi.fanli.service.inter.taobao.TaoBaoWeiQuanDrawBackService;

import com.yeshi.fanli.service.inter.taobao.TaoBaoWeiQuanOrderService;

import com.yeshi.fanli.service.inter.user.UserMoneyDetailService;

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;

@@ -69,6 +80,18 @@


   @Resource

   private UserMoneyDetailService userMoneyDetailService;



   @Resource

   private OrderProcessService orderProcessService;



   @Resource

   private HongBaoOrderService hongBaoOrderService;



   @Resource

   private UserMoneyDebtService userMoneyDebtService;



   @Resource

   private UserSystemCouponRecordService userSystemCouponRecordService;



   /**

    * 统计历史订单-淘宝订单

@@ -122,7 +145,8 @@
    */

   @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) {

         Integer state, Integer type, Integer orderState, String startTime, String endTime, Integer sourceType,

         PrintWriter out) {



      if (pageIndex == null || pageIndex < 1) {

         pageIndex = 1;

@@ -144,16 +168,13 @@
      }



      try {

         long count = 0;



         // 查询列表

         List<CommonOrderVO> list = commonOrderService.listQuery((pageIndex - 1) * pageSize, pageSize, keyType, key,

               state, type, orderState, startTime, endTime);

               state, type, orderState, startTime, endTime, sourceType);



         if (list != null && list.size() > 0) {

            // 统计总数

            count = commonOrderService.countQuery(keyType, key, state, type, orderState, startTime, endTime);

         }

         // 统计总数

         long count = commonOrderService.countQuery(keyType, key, state, type, orderState, startTime, endTime,

               sourceType);



         // 查询是否维权

         for (CommonOrderVO order : list) {

@@ -161,15 +182,16 @@
            TaoBaoWeiQuanOrder weiQuanOrder = taoBaoWeiQuanOrderService.listByorderItemId(order.getTradeId());

            if (weiQuanOrder != null)// 有维权

            {

               order.setWeiQuanState(weiQuanOrder.getState());

               order.setState(CommonOrder.STATE_WQ);

               TaoBaoWeiQuanDrawBack drawBack = taoBaoWeiQuanDrawBackService

                     .selectByOrderItemId(weiQuanOrder.getOrderItemId());

               if (drawBack != null) {// 已经退款

                  order.setWeiQuanState(weiQuanOrder.getState());



                  // 计算退款资金

                  UserMoneyDetail detail = null;

                  switch (order.getHongBaoType()) {

                  case HongBaoV2.TYPE_ZIGOU:

                  case 1:

                     detail = userMoneyDetailService.selectByTypeAndUidAndIdentifyCode(

                           UserMoneyDetailTypeEnum.fanliWeiQuan, Long.parseLong(order.getUserId()),

                           drawBack.getId());

@@ -178,16 +200,12 @@
                              UserMoneyDetailTypeEnum.weiQuan, Long.parseLong(order.getUserId()),

                              drawBack.getId());

                     break;

                  case HongBaoV2.TYPE_YIJI:

                  case HongBaoV2.TYPE_ERJI:

                  case HongBaoV2.TYPE_SHARE_YIJI:

                  case HongBaoV2.TYPE_SHARE_ERJI:

                  case 3:

                     detail = userMoneyDetailService.selectByTypeAndUidAndIdentifyCode(

                           UserMoneyDetailTypeEnum.inviteWeiQuan, Long.parseLong(order.getUserId()),

                           drawBack.getId());

                     break;



                  case HongBaoV2.TYPE_SHARE_GOODS:

                  case 2:

                     detail = userMoneyDetailService.selectByTypeAndUidAndIdentifyCode(

                           UserMoneyDetailTypeEnum.shareWeiQuan, Long.parseLong(order.getUserId()),

                           drawBack.getId());

@@ -197,7 +215,22 @@
                     // 退款成功

                     order.setWeiQuanBackMoney(detail.getMoney().abs().toString());

                  } else {// 尚未退款

                     order.setWeiQuanBackMoney("-" + order.getHongBao());

                     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 {// 尚未退款

@@ -370,7 +403,7 @@
         JSONArray line_list = new JSONArray();



         for (String channel : channelList) {

            List<Map<String, Object>> list = hongBaoV2CountService.count24HOderByChannel(channel, dateType, year,

            List<ChartTDO> list = hongBaoV2CountService.count24HOderByChannel(channel, dateType, year,

                  startTime, endTime);



            if ("all".equalsIgnoreCase(channel)) {

@@ -495,7 +528,6 @@
    */

   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;

@@ -539,7 +571,7 @@


      JSONArray line_list = new JSONArray();

      for (String channel : channelList) {

         List<Map<String, Object>> list = null;

         List<ChartTDO> list = null;

         if (countType == 1) {

            list = hongBaoV2CountService.countHongBaoNum(channel, dateType, state, year, startTime, endTime);

         } else if (countType == 2) {

@@ -564,7 +596,6 @@
            }

            innerList.put("data", gson.toJson(map.get("value")));

         }



         line_list.add(innerList);

      }



@@ -574,9 +605,7 @@
      } else {

         data.put("xAxis_list", gson.toJson(dateList));

      }



      data.put("line_list", line_list);



      return data;

   }



@@ -596,7 +625,6 @@
   @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));

@@ -643,15 +671,11 @@
      Gson gson = new Gson();

      Object objectDate = null;

      List<String> dateList = AdminUtils.getDateList(dateType, startTime, endTime, year);



      try {



         JSONArray line_list = new JSONArray();

         for (Integer type : channelList) {



            List<Map<String, Object>> list = hongBaoV2CountService.countHongBaoType(dateType, type, year, startTime,

            List<ChartTDO> list = hongBaoV2CountService.countHongBaoType(dateType, type, year, startTime,

                  endTime);



            JSONObject innerList = new JSONObject();

            if (type == 1) {

               innerList.put("name", "返利订单");

@@ -694,7 +718,7 @@
   }



   /**

    * 订单跟踪准确率(返利券用户订单/淘宝联盟订单)

    * 订单跟踪准确率(板栗快省用户订单/淘宝联盟订单)

    * 

    * @param callback

    * @param dateType

@@ -705,7 +729,7 @@
    */

   @RequestMapping(value = "getTrackAccuracyRate")

   public void getTrackAccuracyRate(String callback, Integer dateType, String year, String startTime, String endTime,

         PrintWriter out) {

         int sourceType, PrintWriter out) {



      if (dateType != 1 && (!StringUtil.isNullOrEmpty(startTime) || !StringUtil.isNullOrEmpty(endTime))) {

         startTime = null;

@@ -740,8 +764,8 @@


         JSONArray line_list = new JSONArray();



         List<Map<String, Object>> list = commonOrderCountService.getTrackAccuracyRate(dateType, year, startTime,

               endTime);

         List<ChartTDO> list = commonOrderCountService.getTrackAccuracyRate(dateType, year, startTime,

               endTime, sourceType);



         JSONObject innerList = new JSONObject();

         innerList.put("name", "总计");

@@ -904,7 +928,7 @@
      List<String> dateList = AdminUtils.getDateList(dateType, startTime, endTime, year);



      JSONArray line_list = new JSONArray();

      List<Map<String, Object>> list = null;

      List<ChartTDO> list = null;

      if (countType == 1) {

         list = commonOrderCountService.countWeiQaunOrderNumber(dateType, year, startTime, endTime);

      } else if (countType == 2) {

@@ -940,4 +964,23 @@
      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<TaoBaoWeiQuanOrder> 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("更新失败"));

      }

   }



}