Merge remote-tracking branch 'origin/div' into div

admin

2020-02-18 ddf5db7d31af51fcf697eac0cee7dd46ff73bcc1

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

@@ -13,36 +13,48 @@


import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.RequestMapping;

import org.yeshi.utils.IPUtil;

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

import com.yeshi.fanli.entity.admin.count.CountUserInfo;

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

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

import com.yeshi.fanli.entity.bus.user.ForbiddenUserIdentifyCode.ForbiddenUserIdentifyCodeTypeEnum;

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

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

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

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

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

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

import com.yeshi.fanli.entity.bus.user.vip.UserVIPInfo;

import com.yeshi.fanli.entity.common.AdminUser;

import com.yeshi.fanli.entity.money.UserMoneyDetail;

import com.yeshi.fanli.exception.user.ForbiddenUserIdentifyCodeException;

import com.yeshi.fanli.exception.user.vip.UserVIPInfoException;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.count.UserInfoCountService;

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

import com.yeshi.fanli.service.inter.money.extract.BindingAccountService;

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

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

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

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

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

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

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

import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;

import com.yeshi.fanli.service.inter.user.tb.UserExtraTaoBaoInfoService;

import com.yeshi.fanli.service.inter.user.vip.UserVIPInfoService;

import com.yeshi.fanli.tag.PageEntity;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TimeUtil;

import com.yeshi.fanli.util.annotation.RequestSerializableByKey;

import com.yeshi.fanli.vo.user.UserGoldCoinVO;

import com.yeshi.fanli.vo.user.UserInfoVO;



@@ -84,6 +96,13 @@


   @Resource

   private UserAccountService userAccountService;

	
   @Resource

   private UserActiveLogService userActiveLogService;

	
   @Resource

   private UserVIPInfoService userVIPInfoService;

	


   /**

    * 查询用户信息列表 正常用户/异常用户

@@ -105,7 +124,7 @@
    * @param out

    */

   @RequestMapping(value = "query")

   public void query(String callback, Integer pageIndex, Integer pageSize, String key, Integer keyType, Integer rank,

   public void query(String callback, Integer pageIndex, Integer pageSize, String key, Integer keyType, Integer rank,Integer userType,

         Integer days, String startTime, String endTime, Integer orderMode, Integer type, PrintWriter out) {



      try {

@@ -155,14 +174,14 @@
         }



         List<UserInfoVO> userList = userInfoService.query((pageIndex - 1) * pageSize, pageSize, type, key, keyType,

               userRank, days, startTime, endTime, orderField, orderMode);

               userRank, days, startTime, endTime, orderField, orderMode,userType);



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

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

            return;

         }



         long count = userInfoService.queryCount(type, key, keyType, userRank, days, startTime, endTime);

         long count = userInfoService.queryCount(type, key, keyType, userRank, days, startTime, endTime,userType);



         int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);

         PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage);

@@ -300,7 +319,7 @@


         UserInfo find = userInfoService.getUserById(uid);

         if (find == null) {

            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("不存在该用户！"));

            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("用户被封禁或不存在"));

            return;

         }



@@ -346,13 +365,81 @@
         }



         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("解绑成功"));



      } catch (Exception e) {

         e.printStackTrace();

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

      }

   }

	
	


   /**

    * 修改用户备注

    * @param callback

    * @param uid

    * @param mark

    * @param out

    */

   @RequestMapping("addUserMark")

   public void addUserMark(String callback, Long uid, String mark, PrintWriter out) {

      try {

         if (uid == null || uid <= 0 || StringUtil.isNullOrEmpty(mark))

            return;

         UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);

         if (userInfoExtra == null) 
            return;

         UserInfoExtra updateExtra = new UserInfoExtra();

         updateExtra.setId(userInfoExtra.getId());

         updateExtra.setMark(mark);

         userInfoExtraService.saveUserInfoExtra(updateExtra);

      } catch (Exception e) {

         e.printStackTrace();

      }

   }



   /**

    * 删除用户-改变其状态

    * @param callback

    * @param idArray

    * @param out

    */

   @RequestMapping(value = "deleteUser")

   public void delete(String callback, String idArray, HttpServletRequest request,  PrintWriter out) {

      try {

			
         AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN);

         if (admin == null) {

            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("当前账户失效,请重新登陆。")));

            return;

         }

			
         if (StringUtil.isNullOrEmpty(idArray)) {

            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("请选择操作的数据"));

            return;

         }



         Gson gson = new Gson();

         List<Long> list = gson.fromJson(idArray, new TypeToken<ArrayList<Long>>() {}.getType());

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

            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("未检测到删除的数据"));

            return;

         }

			
         for (Long id: list) {

            UserInfo user = new UserInfo(id);

            user.setState(UserInfo.STATE_DELETE);

            user.setStateDesc(admin.getId()+" " + admin.getName()+ "后台手动删除");

            userInfoService.updateByPrimaryKeySelective(user);

         }

         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("成功删除"));

      } catch (Exception e) {

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("删除失败"));

         e.printStackTrace();

      }

   }

	
	
	
   /**

    * 封禁用户ID

    * 

@@ -804,99 +891,117 @@
   @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 {

         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;

         }



         Date beginDate = null;

         Date endDate = null;

			
         if (dateType == 1) {

            beginDate = TimeUtil.parse(startTime);

            endDate = TimeUtil.parse(endTime);

         } else if (dateType == 2) {

            Calendar calendar=Calendar.getInstance();  
            int currentYear = calendar.get(Calendar.YEAR);

            if (!StringUtil.isNullOrEmpty(year)) {

               currentYear = Integer.parseInt(year);

            }

            calendar.clear();

             calendar.set(Calendar.YEAR, currentYear);

             beginDate =calendar.getTime();

		
            calendar.clear();

            calendar.set(Calendar.YEAR, currentYear);

            calendar.roll(Calendar.DAY_OF_YEAR, -1);

            endDate=calendar.getTime(); 
         } else if (dateType == 3) {

            beginDate = TimeUtil.parse("2018-01-01");

            endDate = new Date();

         }

         Gson gson = new Gson();

         Object objectDate = null;

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



			
         // 渠道

         List<String> channelList = null;

         if (channelArray != null && channelArray.trim().length() > 0) {

            channelList = gson.fromJson(channelArray, new TypeToken<ArrayList<String>>() {

            }.getType());

         }

			
         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 = "总计";

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

            for (String channel : channelList) {

               List<Object> list = getNewUserData(dateList, dateType, beginDate, endDate, channel);

               JSONObject innerList = new JSONObject();

               innerList.put("name", channel);

               innerList.put("data", gson.toJson(list));

               line_list.add(innerList);

            }



         } else {

            List<Object> list = getNewUserData(dateList, dateType, beginDate, endDate, null);

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

            }



            innerList.put("name", "全部");

            innerList.put("data", gson.toJson(list));

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



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

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



      } catch (Exception e) {

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

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("系统异常"));

         e.printStackTrace();

      }

   }

	
	
   private List<Object> getNewUserData(List<String> dateList, Integer dateType, Date beginDate, Date endDate, String channel) {

      List<Object> list = new ArrayList<>();

      List<CountUserInfo> listHistory = userInfoCountService.getNewUserData(beginDate, endDate, channel);

      for (String date: dateList) {

         int value = 0;

         if (listHistory != null) {

            for (CountUserInfo history: listHistory) {

               if (dateType == 1) {

                  String gernalTime = TimeUtil.getGernalTime(history.getDay().getTime());

                  if (gernalTime.equalsIgnoreCase(date)) {

                     value += history.getNum();

                     continue;

                  }

               } else if (dateType == 2){

                  String gernalTime = TimeUtil.getMonthOnlyMM(history.getDay());

                  if(gernalTime.startsWith("0")) {

                     gernalTime = gernalTime.substring(1, 2);

                  }

							
                  if (gernalTime.equalsIgnoreCase(date)) {

                     value +=  history.getNum();

                     continue;

                  }

               } else if (dateType == 3) {

                  String gernalTime = TimeUtil.getYearOnlyYYYY(history.getDay());

                  if (gernalTime.equalsIgnoreCase(date)) {

                     value +=  history.getNum();

                     continue;

                  }

               }

            }

         }

         list.add(value + "");

      }

		
      return list;

   }



   /**

@@ -975,7 +1080,7 @@
         JSONArray line_list = new JSONArray();

         for (String channel : channelList) {



            List<Map<String, Object>> list = userInfoCountService.getTodayBuyRate(channel, dateType, year,

            List<ChartTDO> list = userInfoCountService.getTodayBuyRate(channel, dateType, year,

                  startTime, endTime);



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

@@ -1098,7 +1203,7 @@
    * @param out

    */

   @RequestMapping(value = "getGoldTop")

   public void getGoldTop(String callback, Integer pageIndex, Integer pageSize, Integer type,

   public void getGoldTop(String callback, Integer pageIndex, Integer pageSize, Integer type, String key,

         PrintWriter out) {

      if (type == null) {

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("type不能为空"));

@@ -1114,11 +1219,11 @@
      long count = 0;

      List<UserGoldCoinVO> list = null;

      if (type == 0) {

         count = userInfoCountService.countByHasGoldCoin();

         list = userInfoCountService.listByHasGoldCoin((pageIndex - 1) * pageSize, pageSize);

         count = userInfoCountService.countByHasGoldCoin(key);

         list = userInfoCountService.listByHasGoldCoin((pageIndex - 1) * pageSize, pageSize, key);

      } else if (type == 1 || type == 2) {

         count = userInfoCountService.countByUserGoldCoin(type);

         list = userInfoCountService.listByUserGoldCoin((pageIndex - 1) * pageSize, pageSize, type);

         count = userInfoCountService.countByUserGoldCoin(type, key);

         list = userInfoCountService.listByUserGoldCoin((pageIndex - 1) * pageSize, pageSize, type, key);

      }

      

      if(list == null)

@@ -1134,4 +1239,215 @@
      JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));

   }

   

	
   /**

    * 计当天活跃用户中有多少个用户是90天前才活跃过，期间从未活跃的用户数量

    * @param callback

    * @param dateType

    * @param year

    * @param startTime

    * @param endTime

    * @param out

    */

   @RequestMapping(value = "getUserActiveCharts")

   public void getUserActiveCharts(String callback, Integer dateType, String year, String startTime,

         String endTime, PrintWriter out){

      try {

         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;

         }



			
         Date beginDate = null;

         Date endDate = null;

			
         if (dateType == 1) {

            beginDate = TimeUtil.parse(startTime);

            endDate = TimeUtil.parse(endTime);

         } else if (dateType == 2) {

            Calendar calendar=Calendar.getInstance();  
            int currentYear = calendar.get(Calendar.YEAR);

            if (!StringUtil.isNullOrEmpty(year)) {

               currentYear = Integer.parseInt(year);

            }

				
            calendar.clear();

             calendar.set(Calendar.YEAR, currentYear);

             beginDate =calendar.getTime();

		
            calendar.clear();

            calendar.set(Calendar.YEAR, currentYear);

            calendar.roll(Calendar.DAY_OF_YEAR, -1);

            endDate=calendar.getTime(); 
         } else if (dateType == 3) {

            beginDate = TimeUtil.parse("2018-01-01");

            endDate = new Date();

         }

         Gson gson = new Gson();

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

			
         List<Object> list = new ArrayList<>();

         List<UserActiveNumHistory> listHistory = userActiveLogService.query(beginDate, endDate);

         for (String date: dateList) {

            ChartTDO chartTDO = new ChartTDO();

            chartTDO.setShowDate(date);

            int value = 0;

				
            if (listHistory != null) {

               for (UserActiveNumHistory history: listHistory) {

                  if (dateType == 1) {

                     String gernalTime = TimeUtil.getGernalTime(history.getDay().getTime());

                     if (gernalTime.equalsIgnoreCase(date)) {

                        value += history.getNum();

                        continue;

                     }

                  } else if (dateType == 2){

                     String gernalTime = TimeUtil.getMonthOnlyMM(history.getDay());

                     if(gernalTime.startsWith("0")) {

                        gernalTime = gernalTime.substring(1, 2);

                     }

                     if (gernalTime.equalsIgnoreCase(date)) {

                        value += history.getNum();

                        continue;

                     }

                  } else if (dateType == 3) {

                     String gernalTime = TimeUtil.getYearOnlyYYYY(history.getDay());

                     if (gernalTime.equalsIgnoreCase(date)) {

                        value += history.getNum();

                        continue;

                     }

                  }

               }

            }

				
            chartTDO.setShowValue(value + "");

            list.add(value + "");

         }

			
         JSONObject innerList = new JSONObject();

         innerList.put("name", "数量");

         innerList.put("data", gson.toJson(list));



         JSONArray line_list = new JSONArray();

         line_list.add(innerList);



         JSONObject data = new JSONObject();

         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 pageIndex

    * @param pageSize

    * @param key 搜索：暂只提供uid

    * @param state 状态：

    * @param out

    */

   @RequestMapping(value = "queryVip")

   public void queryVip(String callback, Integer pageIndex, Integer pageSize, String key, Integer state, PrintWriter out) {

      try {

         List<UserVIPInfo> list = userVIPInfoService.listQuery(pageIndex, pageSize, key, state);

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

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

            return;

         }

			
         long count = userVIPInfoService.countQuery(key, state);

         int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);

         PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage);



         GsonBuilder gsonBuilder = new GsonBuilder();

         gsonBuilder.serializeNulls();

         Gson gson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create();



         JSONObject data = new JSONObject();

         data.put("pe", pe);

         data.put("result_list", gson.toJson(list));

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

      } catch (Exception e) {

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

         e.printStackTrace();

      }

   }



	


   /**

    * 超级会员升级通过

    * @param callback

    * @param id

    * @param out

    * @param request

    */

   @RequestSerializableByKey(key = "'passVIP-' +#id")

   @RequestMapping(value = "passVIP")

   public void passVIP(String callback, Long id,  PrintWriter out, HttpServletRequest request) {

      try {

         /* 检验是否登陆 */

         AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN);

         if (admin == null) {

            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("当前账户失效,请重新登陆。"));

            return;

         }

         userVIPInfoService.passVIPApply(id);

         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("操作成功"));

         LogHelper.userInfo("[ip:" + IPUtil.getRemotIP(request) + "]" + admin.getName() + "通过了[id=" + id + "]的升级超级会员申请!");

      } catch (UserVIPInfoException e) {

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e.getMsg()));

         return;

      } catch (Exception e) {

         e.printStackTrace();

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作失败"));

         return;

      }

   }

	
	
   /**

    * 超级会员升级拒绝

    * @param callback

    * @param id

    * @param reason

    * @param out

    * @param request

    */

	
   @RequestMapping(value = "rejectVIP")

   public void rejectVIP(String callback, Long id, String reason, PrintWriter out,   HttpServletRequest request) {

      try {

         /* 检验是否登陆 */

         AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN);

         if (admin == null) {

            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("当前账户失效,请重新登陆"));

            return;

         }

         userVIPInfoService.rejectVIPApply(id, reason);

         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("拒绝成功"));

         LogHelper.userInfo("[ip:" + IPUtil.getRemotIP(request) + "][管理员:" + admin.getName() + "] 拒绝提现id=" + id + "的升级超级会员申请不存在!");

      } catch (UserVIPInfoException e) {

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e.getMsg()));

         return;

      } catch (Exception e) {

         e.printStackTrace();

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作失败"));

         return;

      }

   }



}