yujian
2019-01-22 88b54772dbcf5ecab1e2316e4e4626ac901b8908
fanli/src/main/java/com/yeshi/fanli/controller/admin/UserInfoAdminController.java
@@ -4,7 +4,6 @@
import java.io.FileInputStream;
import java.io.InputStream;
import java.io.PrintWriter;
import java.math.BigDecimal;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Calendar;
@@ -33,6 +32,7 @@
import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.google.gson.reflect.TypeToken;
import com.yeshi.fanli.controller.admin.utils.AdminUtils;
import com.yeshi.fanli.entity.admin.UserInfoAdmin;
import com.yeshi.fanli.entity.bus.user.AccountDetails;
import com.yeshi.fanli.entity.bus.user.Extract;
@@ -658,8 +658,6 @@
            return;
         }
         
         //double sumMoney = userInfoService.querySumMoney(key, userType, days, startTime, endTime);
         long count = userInfoService.queryCount(key, userType, days, startTime, endTime);
         int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);
@@ -690,12 +688,8 @@
   @RequestMapping(value = "countInfo")
   public void countInfo(String callback, PrintWriter out) {
      try {
         // 总用户
         long countTotal = userInfoCountService.countNewUser(null, null);
         // 今日新增
         long countToday = userInfoCountService.countNewUser(1, null);
         // 本月新增
         long countMonth = userInfoCountService.countNewUser(null, 1);
         JSONObject data = new JSONObject();
         
         // 总数-普通用户
         long countNormal = userInfoCountService.countRank(0);
@@ -706,27 +700,43 @@
         // 总数-金用户
         long countGold = userInfoCountService.countRank(3);
         
         data.put("countNormal", countNormal);
         data.put("countCuprum", countCuprum);
         data.put("countSilver", countSilver);
         data.put("countGold", countGold);
         /*
         // 统计所有总金额
         BigDecimal countTotalMoney = userInfoCountService.countAllMoney(null);
         
         // 统计所有可提现金额
         String minMoney = configService.get(Constant.EXTRACT_MIN_MONEY);
         if (minMoney == null)
         if (minMoney == null) {
            minMoney = "20";
         }
         double min = Double.parseDouble(minMoney);
         BigDecimal countCanAssets = userInfoCountService.countAllMoney(min);
         JSONObject data = new JSONObject();
         data.put("countTotal", countTotal);
         data.put("countToday", countToday);
         data.put("countMonth", countMonth);
         data.put("countNormal", countNormal);
         data.put("countCuprum", countCuprum);
         data.put("countSilver", countSilver);
         data.put("countGold", countGold);
         data.put("countTotalMoney", countTotalMoney);
         data.put("countCanAssets", countCanAssets);
         */
         // 累计用户数量
         long totalUser = userInfoCountService.countNewUser(null, null);
         // 流失用户数量(180天未使用登录并且无任何资金流动的账号数量)
         long loseUser = userInfoCountService.countLoseUser(180);
         // 累计有购买用户数
         long orderUser = userInfoCountService.countHasOrderUser();
         data.put("totalUser", totalUser);
         data.put("loseUser", loseUser);
         data.put("orderUser", orderUser);
         // 今日新增用户数量
         long todayUser = userInfoCountService.countNewUser(1, null);
         // 本月新增用户数量
         long monthUser = userInfoCountService.countNewUser(null, 1);
         data.put("todayUser", todayUser);
         data.put("monthUser", monthUser);
         
         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));
         
@@ -1189,42 +1199,99 @@
    * @param endTime   2018-12-01 
    * @param out
    */
   @RequestMapping(value = "getSameDayUserByChannel")
   public void getSameDayUserByChannel(String callback, String channelArray, Integer dateType,
   @RequestMapping(value = "getNewUserCharts")
   public void getNewUserCharts(String callback, String channelArray, Integer dateType,
       String year, String startTime, String endTime, PrintWriter out) {
      
      validateParams(callback, channelArray, dateType,year,startTime,endTime,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<String> channelList = null;
      if (channelArray != null && channelArray.trim().length() > 0) {
         Gson gson = new Gson();
         channelList = gson.fromJson(channelArray, new TypeToken<ArrayList<String>>() {}.getType());
      }
      if (channelList == null || channelList.size() == 0) {
         channelList = new ArrayList<String>();
         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();
         List<String> list = gson.fromJson(channelArray, new TypeToken<ArrayList<String>>() {}.getType());
         if (list == null || list.size() == 0) {
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("参数格式不正确"));
            return;
         }
         Object objectDate = null;
         List<String> dateList = AdminUtils.getDateList(dateType, startTime, endTime, year);
         
         JSONArray array = new JSONArray();
         for (String channel: list) {
            JSONObject channelData = new JSONObject();
            List<Object> resultList = userActiveLogService.countSameDayByChannel(channel, dateType, year, startTime, endTime);
            if (resultList == null) {
               resultList = new ArrayList<Object>();
         JSONArray line_list = new JSONArray();
         for (String channel : channelList) {
            List<Map<String, Object>> list = userInfoCountService.countNewUserByDate(channel,
                  dateType, year, startTime, endTime);
            if ("all".equalsIgnoreCase(channel)) {
               channel = "总计";
            }
            channelData.put("name", channel);
            channelData.put("infos", resultList);
            array.add(channelData);
            JSONObject innerList = new JSONObject();
            innerList.put("name", channel);
            if (dateType != 3) {
               innerList.put("data", gson.toJson(AdminUtils.dayOrMonthDataFactory(dateType, dateList, list)));
            } else {
               // 年视图
               Map<String, Object> map = AdminUtils.yearsDataFactory(list);
               if (objectDate == null) {
                  objectDate = map.get("date");
               }
               innerList.put("data", gson.toJson(map.get("value")));
            }
            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));
         }
         
         JSONObject data = new JSONObject();
         data.put("result_list", array);
         data.put("line_list", line_list);
         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));
      } catch (Exception e) {
@@ -1243,126 +1310,172 @@
    * @param endTime   2018-12-01 
    * @param out
    */
   @RequestMapping(value = "getBuyProportion")
   public void getBuyProportion(String callback, String channelArray, Integer dateType,
   @RequestMapping(value = "getTodayBuyRate")
   public void getTodayBuyRate(String callback, String channelArray, Integer dateType,
       String year, String startTime, String endTime, Integer orderNum, PrintWriter out) {
      
      validateParams(callback, channelArray, dateType,year,startTime,endTime,out);
      String validateMsg = AdminUtils.validateParams(dateType, startTime, endTime);
      if (validateMsg != null) {
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(validateMsg));
         return;
      }
      if (dateType == 2 && StringUtil.isNullOrEmpty(year)) {
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("请输入年份"));
         return;
      }
      
      if (dateType != 1 && (!StringUtil.isNullOrEmpty(startTime) || !StringUtil.isNullOrEmpty(endTime))) {
         startTime = null;
         endTime = null;
      }
      List<String> channelList = null;
      if (channelArray != null && channelArray.trim().length() > 0) {
         Gson gson = new Gson();
         channelList = gson.fromJson(channelArray, new TypeToken<ArrayList<String>>() {}.getType());
      }
      if (channelList == null || channelList.size() == 0) {
         channelList = new ArrayList<String>();
         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<String> dateList = AdminUtils.getDateList(dateType, startTime, endTime, year);
         JSONArray line_list = new JSONArray();
         for (String channel : channelList) {
            List<Map<String, Object>> list = userInfoCountService.getTodayBuyRate(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<String, Object> 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();
      }
   }
   /**
    * 当周产生3单的新增用户概率
    * @param callback
    * @param channelArray 渠道名称
    * @param startTime
    * @param endTime
    * @param orderNum 订单数量
    * @param out
    */
   @RequestMapping(value = "getWeekBuyRate")
   public void getWeekBuyRate(String callback, String channelArray, String startTime, String endTime,
         Integer orderNum, PrintWriter out) {
      if (StringUtil.isNullOrEmpty(startTime) || StringUtil.isNullOrEmpty(endTime)) {
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("当周订单统计对应时间区域不能为空"));
         return;
      }
      List<String> channelList = null;
      if (channelArray != null && channelArray.trim().length() > 0) {
         Gson gson = new Gson();
         channelList = gson.fromJson(channelArray, new TypeToken<ArrayList<String>>() {}.getType());
      }
      if (channelList == null || channelList.size() == 0) {
         channelList = new ArrayList<String>();
         channelList.add("all");
      }
      if (orderNum < 1) {
         orderNum = 1;
      }
      
      try {
         Gson gson = new Gson();
         List<String> list = gson.fromJson(channelArray, new TypeToken<ArrayList<String>>() {}.getType());
         if (list == null || list.size() == 0) {
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("参数格式不正确"));
            return;
         }
         List<String> dateList = AdminUtils.getDateList(1, startTime, endTime, null);
         
         JSONArray array = new JSONArray();
         for (String channel: list) {
            JSONObject channelData = new JSONObject();
            List<Object> resultList = userActiveLogService.getBuyProportion(channel, dateType, year, startTime, endTime, orderNum);
            if (resultList == null) {
               resultList = new ArrayList<Object>();
            }
            channelData.put("name", channel);
            channelData.put("infos", resultList);
            array.add(channelData);
         }
         JSONObject data = new JSONObject();
         data.put("result_list", array);
         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));
      } catch (Exception e) {
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常"));
         e.printStackTrace();
      }
   }
   /**
    * 用户统计 :总用户、流失用户数量、累计有购买用户数
    * @param callback
    * @param out
    */
   @RequestMapping(value = "countUser")
   public void countUser(String callback, PrintWriter out) {
      try {
         // 总用户
         long totalUser = userInfoCountService.countNewUser(null, null);
         // 流失用户数量(180天未使用登录并且无任何资金流动的账号数量)
         long loseUser = userInfoCountService.countLoseUser(180);
         // 累计有购买用户数
         long orderUser = userInfoCountService.countHasOrderUser();
         JSONObject data = new JSONObject();
         data.put("totalUser", totalUser);
         data.put("loseUser", loseUser);
         data.put("orderUser", orderUser);
         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));
      } catch (Exception e) {
         e.printStackTrace();
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("统计异常"));
      }
   }
   /**
    * 统计历史新增用户
    * @param callback
    * @param dateType 类型  1日  2月  3年
    * @param year 2018
    * @param startTime 2018-12-01
    * @param endTime   2018-12-01
    * @param out
    */
   @RequestMapping(value = "getHistoryNewUser")
   public void getHistoryNewUser(String callback, Integer dateType, String year, String startTime,
         String endTime, PrintWriter out) {
      if (dateType == null) {
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("请选择显示方式"));
         return;
      }
      if (dateType == 1 && (StringUtil.isNullOrEmpty(startTime) && StringUtil.isNullOrEmpty(endTime))) {
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("请选择时间区间"));
         return;
      }
      if (!StringUtil.isNullOrEmpty(startTime) && StringUtil.isNullOrEmpty(endTime)) {
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("请选结束日期"));
         return;
      }
      if (StringUtil.isNullOrEmpty(startTime) && !StringUtil.isNullOrEmpty(endTime)) {
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("请选起始日期"));
         return;
      }
      if (dateType != 1 && (!StringUtil.isNullOrEmpty(startTime) || !StringUtil.isNullOrEmpty(endTime))) {
         startTime = null;
         endTime = null;
      }
      try {
         List<Object> resultList = userInfoCountService.countNewUserByDate(dateType, year, startTime, endTime);
         if (resultList == null) {
            resultList = new ArrayList<Object>();
         }
         JSONArray line_list = new JSONArray();
         for (String channel : channelList) {
            
            List<Object> list = userInfoCountService.getWeekBuyRate(channel, startTime, endTime,
                  orderNum, dateList);
            if ("all".equalsIgnoreCase(channel)) {
               channel = "总计";
            }
            JSONObject innerList = new JSONObject();
            innerList.put("name", channel);
            innerList.put("data", gson.toJson(list));
            line_list.add(innerList);
         }
         JSONObject data = new JSONObject();
         data.put("result_list", resultList);
         data.put("xAxis_list", gson.toJson(dateList));
         data.put("line_list", line_list);
         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));
      } catch (Exception e) {
@@ -1371,32 +1484,4 @@
      }
   }
   
   public void validateParams(String callback, String channelArray, Integer dateType,
          String year, String startTime, String endTime, PrintWriter out) {
      if (StringUtil.isNullOrEmpty(channelArray)) {
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("请选择统计对应名称"));
         return;
      }
      if (dateType == null) {
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("请选择排列方式"));
         return;
      }
      if (dateType == 1 && (StringUtil.isNullOrEmpty(startTime) && StringUtil.isNullOrEmpty(endTime))) {
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("请选择时间区间"));
         return;
      }
      if (!StringUtil.isNullOrEmpty(startTime) && StringUtil.isNullOrEmpty(endTime)) {
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("请选结束日期"));
         return;
      }
      if (StringUtil.isNullOrEmpty(startTime) && !StringUtil.isNullOrEmpty(endTime)) {
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("请选起始日期"));
         return;
      }
   }
}