blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
yujian
2019-01-05 4220ceb661146c58d1d6855f14dcdcc3d8c7bb24 
 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,10 +28,13 @@


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.entity.admin.UserInfoAdmin;



import com.yeshi.fanli.entity.bus.user.AccountDetails;



import com.yeshi.fanli.entity.bus.user.Extract;



import com.yeshi.fanli.entity.bus.user.HongBao;



import com.yeshi.fanli.entity.bus.user.MoneyRecord;



@@ -50,6 +56,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;



@@ -57,7 +64,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")



@@ -103,6 +109,9 @@


   



   @Resource



   private UserInfoCountService userInfoCountService;



	


   @Resource



   private UserActiveLogService userActiveLogService;



   







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



@@ -698,7 +707,7 @@


         long countGold = userInfoCountService.countRank(3);



         



         // 统计所有总金额



         double countTotalMoney = userInfoCountService.countAllMoney(null);



         BigDecimal countTotalMoney = userInfoCountService.countAllMoney(null);



         



         // 统计所有可提现金额



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



@@ -706,7 +715,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);



@@ -1024,10 +1033,370 @@


      }



   }



   



   public static void main(String[] args) {



	


	


   /**



    * 队员关系



    * @param pageIndex



    * @param key



    * @param state



    * @param startTime



    * @param endTime



    * @param out



    */



   @RequestMapping(value = "getRelationList")



   public void getRelationList(String callback, Integer pageIndex, Integer pageSize, Long uid, Integer type,



         Integer state, String startTime, String endTime, PrintWriter out) {



      



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



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



         pageIndex = 1;



      }







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



         pageSize = Constant.PAGE_SIZE;



      }



		


      try {



			


         if (!StringUtil.isNullOrEmpty(endTime)) {



            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");



            Date enddate = sdf.parse(endTime);



            Calendar c = Calendar.getInstance();



            c.setTime(enddate);



            c.add(Calendar.DAY_OF_MONTH, 1);// 今天+1天



            endTime = sdf.format(c.getTime());



         }



			


         List<ThreeSale> listQuery = null;



         if (type == 0) {



            // 上级用户



            if (uid == null) {



               JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("查询上级需输入用户id"));



               return;



            }



            listQuery = threeSaleService.listSuperiorQuery((pageIndex - 1) * pageSize, pageSize, state, uid);



         } else if (type == 1) {



            // 一级用户



            listQuery = threeSaleService.listFirstTeamQuery((pageIndex - 1) * pageSize, pageSize, uid, 


                  state, startTime, endTime);



         } else if (type == 2) {



            // 二级用户



            listQuery = threeSaleService.listSecondTeamQuery((pageIndex - 1) * pageSize, pageSize, uid,



                  state, startTime, endTime);



         }



			


         if (listQuery == null || listQuery.size() == 0) {



            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无数据"));



            return;



         }



			


         for (ThreeSale threeSale: listQuery) {



            Integer expire = threeSale.getExpire();



            if (threeSale.getState()) {



               threeSale.setExpire(1); // 邀请成功



            } else {



               if (expire != null && expire == 1) {



                  threeSale.setExpire(2); // 邀请失效



               } else {



                  threeSale.setExpire(0);// 已邀请



               }



            }



         }



			


         long count = 0;



         if (type == 0) {



            // 上级用户



            count = threeSaleService.countSuperiorQuery(state, uid);



         } else if (type == 1) {



            // 一级用户



            count = threeSaleService.countFirstTeamQuery(uid, state, startTime, endTime);



         } else if (type == 2) {



            // 二级用户



            count = threeSaleService.countSecondTeamQuery(uid, state, 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", listQuery);



			


         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 id



    * @param out



    */



   @RequestMapping(value = "getAccountDetails")



   public void getAccountDetails(String callback, Integer pageIndex,Integer pageSize, Long uid, PrintWriter out) {



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



         pageIndex = 1;



      }







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



         pageSize = Constant.PAGE_SIZE;



      }



		


      if (uid == null) {



         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("请传递正确数据"));



         return;



      }



		


      try {



			


         List<AccountDetails> detailsList = accountDetailsService.findAccountDetailsList(uid, pageIndex);



         if (detailsList == null || detailsList.size() == 0) {



            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无数据"));



            return;



         }



			


         int count = accountDetailsService.getCount(uid);



			


         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", GsonUtil.toJsonExpose(detailsList));



			


         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));



			


      } catch (Exception e) {



         e.printStackTrace();



         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("查询失败"));



      }



   }



	


   /**



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



    * @param channelArray 名字数组



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



    * @param year 2018



    * @param startTime 2018-12-01 


    * @param endTime   2018-12-01 


    * @param out



    */



   @RequestMapping(value = "getSameDayUserByChannel")



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


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



		


      validateParams(callback, channelArray, dateType,year,startTime,endTime,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 = userActiveLogService.countSameDayByChannel(channel, dateType, year, startTime, endTime);



            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 channelArray 名字数组



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



    * @param year 2018



    * @param startTime 2018-12-01 


    * @param endTime   2018-12-01 


    * @param out



    */



   @RequestMapping(value = "getBuyProportion")



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


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



		


      validateParams(callback, channelArray, dateType,year,startTime,endTime,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 = 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>();



         }



				


         JSONObject data = new JSONObject();



         data.put("result_list", resultList);



         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));







      } catch (Exception e) {



         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常"));



         e.printStackTrace();



      }



   }



	


   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;



      }



   }



}