| | |
|---|
| | | package com.yeshi.fanli.controller.admin;
|
|---|
| | |
|
|---|
| | | import java.io.PrintWriter;
|
|---|
| | | import java.net.URLDecoder;
|
|---|
| | | import java.text.SimpleDateFormat;
|
|---|
| | | import java.util.ArrayList;
|
|---|
| | | import java.util.Calendar;
|
|---|
| | |
|---|
| | | 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.integral.IntegralDetail;
|
|---|
| | | 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.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.integral.IntegralDetailService;
|
|---|
| | | 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;
|
|---|
| | |
|---|
| | | @Resource
|
|---|
| | | private UserVIPInfoService userVIPInfoService;
|
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private IntegralDetailService integralDetailService;
|
|---|
| | | |
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 查询用户信息列表 正常用户/异常用户
|
|---|
| | |
|---|
| | | * @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 {
|
|---|
| | |
|---|
| | | }
|
|---|
| | |
|
|---|
| | | 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);
|
|---|
| | |
|---|
| | | @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<ChartTDO> 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;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | |
|---|
| | |
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 计当天活跃用户中有多少个用户是90天前才活跃过，期间从未活跃的用户数量
|
|---|
| | | * 获取金币排行榜
|
|---|
| | | * @param callback
|
|---|
| | | * @param dateType
|
|---|
| | | * @param year
|
|---|
| | | * @param startTime
|
|---|
| | | * @param endTime
|
|---|
| | | * @param pageIndex
|
|---|
| | | * @param pageSize
|
|---|
| | | * @param type
|
|---|
| | | * @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();
|
|---|
| | | @RequestMapping(value = "getGoldCoinRecord")
|
|---|
| | | public void getGoldCoinRecord(String callback, Integer pageIndex, Integer pageSize, String key, PrintWriter out) {
|
|---|
| | | if (pageIndex == null)
|
|---|
| | | pageIndex = 1;
|
|---|
| | |
|
|---|
| | | 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.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();
|
|---|
| | | if (pageSize == null)
|
|---|
| | | pageSize = 20;
|
|---|
| | | |
|---|
| | | List<IntegralDetail> list = integralDetailService.listQuery((pageIndex-1)* pageSize, pageSize, key);
|
|---|
| | | if (list == null || list.size() == 0) {
|
|---|
| | | JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无相关信息"));
|
|---|
| | | return;
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | for (IntegralDetail integralDetail: list) {
|
|---|
| | | Long uid = integralDetail.getUid();
|
|---|
| | | UserInfo userInfo = userInfoService.getUserById(uid);
|
|---|
| | | if (userInfo != null) {
|
|---|
| | | integralDetail.setNickName(userInfo.getNickName());
|
|---|
| | | integralDetail.setPortrait(userInfo.getPortrait());
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | long count = integralDetailService.countQuery(key);
|
|---|
| | | 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("list", gson.toJson(list));
|
|---|
| | | JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | |
|
|---|
| | | |
|---|
| | | /**
|
|---|
| | | *
|
|---|
| | | * @param callback
|
|---|
