blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
yujian
2019-01-14 b42e88afc77b0d40ea8bbad87df6cc22d03414e1 
 fanli/src/main/java/com/yeshi/fanli/controller/admin/UserInfoAdminController.java


@@ -4,7 +4,9 @@


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;



import java.util.Date;



import java.util.HashMap;



@@ -14,6 +16,7 @@


import javax.annotation.Resource;



import javax.servlet.http.HttpServletResponse;







import net.sf.json.JSONArray;



import net.sf.json.JSONObject;







import org.apache.poi.hssf.usermodel.HSSFWorkbook;



@@ -25,9 +28,12 @@


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



@@ -51,6 +57,7 @@


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



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



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



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



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



import com.yeshi.fanli.tag.PageEntity;



import com.yeshi.fanli.util.Constant;



@@ -58,8 +65,6 @@


import com.yeshi.fanli.util.HongBaoUtil;



import com.yeshi.fanli.util.StringUtil;



import com.yeshi.fanli.util.TimeUtil;







import org.yeshi.utils.JsonUtil;







@Controller



@RequestMapping("admin/new/api/v1/user")



@@ -105,6 +110,9 @@


   



   @Resource



   private UserInfoCountService userInfoCountService;



	


   @Resource



   private UserActiveLogService userActiveLogService;



   







   @RequestMapping(value = "getUserList", method = RequestMethod.POST)



@@ -651,8 +659,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);



@@ -700,7 +706,7 @@


         long countGold = userInfoCountService.countRank(3);



         



         // 统计所有总金额



         double countTotalMoney = userInfoCountService.countAllMoney(null);



         BigDecimal countTotalMoney = userInfoCountService.countAllMoney(null);



         



         // 统计所有可提现金额



         String minMoney = configService.get(Constant.EXTRACT_MIN_MONEY);



@@ -708,7 +714,7 @@


            minMoney = "20";



            



         double min = Double.parseDouble(minMoney);



         double countCanAssets = userInfoCountService.countAllMoney(min);



         BigDecimal countCanAssets = userInfoCountService.countAllMoney(min);



         



         JSONObject data = new JSONObject();



         data.put("countTotal", countTotal);



@@ -1173,9 +1179,263 @@


      }



   }



   



   public static void main(String[] args) {



      java.lang.System.out.println(java.lang.System.currentTimeMillis());



   /**



    * 根据渠道   统计当日新增用户数量



    * @param channelArray 名字数组



    * @param dateType 类型  1日  2月  3年



    * @param year 2018



    * @param startTime 2018-12-01 


    * @param endTime   2018-12-01 


    * @param out



    */



   @RequestMapping(value = "getNewUserCharts")



   public void getNewUserCharts(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<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.countNewUserByDate(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();



      }



   }



   



   



}	


   /**



    * 根据渠道   统计当日新增用户数量



    * @param channelArray 名字数组



    * @param dateType 类型  1日  2月  3年



    * @param year 2018



    * @param startTime 2018-12-01 


    * @param endTime   2018-12-01 


    * @param out



    */



   @RequestMapping(value = "getTodayBuyRate")



   public void getTodayBuyRate(String callback, String channelArray, Integer dateType, 


       String year, String startTime, String endTime, Integer orderNum, PrintWriter out) {



		


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



         startTime = 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;



         }



			


         JSONArray array = new JSONArray();







         for (String channel: list) {



            JSONObject channelData = new JSONObject();



            List<Object> resultList = null;



						


                  //userActiveLogService.getBuyProportion(channel, dateType, year, startTime, endTime, orderNum);



            if (resultList == null) {



               resultList = new ArrayList<Object>();



            }



            channelData.put("name", channel);



            channelData.put("data_list", 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();



      }



   }



	


	


   /**



    * 当周产生3单的新增用户概率 


    * @param callback



    * @param channelArray 渠道名称



    * @param startTime 


    * @param endTime



    * @param orderNum 订单数量



    * @param out



    */



   @RequestMapping(value = "getWeekProportion")



   public void getWeekProportion(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;



      }



		


      try {







         if (orderNum == null ) {



            orderNum = 0;



         }



			






         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");



         }



			


         JSONArray array = new JSONArray();



         for (String channel : channelList) {



            JSONObject channelData = new JSONObject();







				


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



                  //userActiveLogService.countOneWeekUserInfo(channel,    startTime, endTime, orderNum);







            if (resultList == null) {



               resultList = new ArrayList<Map<String, Object>>();



            }







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



               channel = "总计";



            }



				


            channelData.put("name", channel);



            channelData.put("data_list", resultList);



            array.add(channelData);



         }







         JSONObject data = new JSONObject();



         data.put("result_list", array);







      } 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("统计异常"));



      }



		


   }



	


}