package com.yeshi.fanli.controller.admin; import java.io.File; import java.io.FileInputStream; import java.io.InputStream; import java.io.PrintWriter; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Calendar; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; 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; import org.apache.poi.ss.usermodel.Cell; import org.apache.poi.ss.usermodel.Row; import org.apache.poi.ss.usermodel.Sheet; import org.apache.poi.ss.usermodel.Workbook; import org.apache.poi.ss.util.CellRangeAddress; 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; import com.yeshi.fanli.entity.bus.user.HongBao; import com.yeshi.fanli.entity.bus.user.MoneyRecord; import com.yeshi.fanli.entity.bus.user.Order; import com.yeshi.fanli.entity.bus.user.ThreeSale; import com.yeshi.fanli.entity.bus.user.UserInfo; import com.yeshi.fanli.entity.taobao.PidOrder; import com.yeshi.fanli.entity.taobao.ScanHistory; import com.yeshi.fanli.service.inter.config.ConfigService; import com.yeshi.fanli.service.inter.count.UserInfoCountService; import com.yeshi.fanli.service.inter.goods.ShareService; import com.yeshi.fanli.service.inter.hongbao.HongBaoService; import com.yeshi.fanli.service.inter.hongbao.ThreeSaleSerivce; import com.yeshi.fanli.service.inter.order.OrderItemServcie; import com.yeshi.fanli.service.inter.order.OrderService; import com.yeshi.fanli.service.inter.order.PidOrderService; import com.yeshi.fanli.service.inter.user.AccountDetailsService; import com.yeshi.fanli.service.inter.user.BindingAccountService; 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; import com.yeshi.fanli.util.GsonUtil; import com.yeshi.fanli.util.HongBaoUtil; import com.yeshi.fanli.util.StringUtil; import com.yeshi.fanli.util.TimeUtil; @Controller @RequestMapping("admin/new/api/v1/user") public class UserInfoAdminController { @Resource private UserInfoService userInfoService; @Resource private MoneyRecordService moneyRecordService; @Resource private OrderService orderService; @Resource private ScanHistoryService scanHistoryService; @Resource private ConfigService configService; @Resource private HongBaoService hongBaoService; @Resource private ExtractService extractService; @Resource private ThreeSaleSerivce threeSaleService; @Resource private OrderItemServcie orderItemService; @Resource private ShareService shareService; @Resource private PidOrderService pidOrderService; @Resource private AccountDetailsService accountDetailsService; @Resource private BindingAccountService bindingAccountService; @Resource private UserInfoCountService userInfoCountService; @Resource private UserActiveLogService userActiveLogService; @RequestMapping(value = "getUserList", method = RequestMethod.POST) public void getUserList(int pageIndex, String key, PrintWriter out) { List userList = userInfoService.getUserList(pageIndex - 1, key); int count = userInfoService.getUserCount(key); int totalPage = count % Constant.PAGE_SIZE == 0 ? count / Constant.PAGE_SIZE : count / Constant.PAGE_SIZE + 1; PageEntity pe = new PageEntity(pageIndex, Constant.PAGE_SIZE, count, totalPage); Map map = new HashMap(); map.put("key", key); pe.setParams(map); JSONObject data = new JSONObject(); data.put("pe", pe); data.put("userList", userList); out.print(JsonUtil.loadTrueResult(data)); } /** * * 方法说明: 三级分销 * * @author mawurui createTime 2018年5月21日 下午4:55:07 * @param pageIndex * @param key * @param out */ @RequestMapping(value = "getThreeSaleList", method = RequestMethod.POST) public void getThreeSaleList(int pageIndex, String key, PrintWriter out) { List list = threeSaleService.getLastestThreeSaleList(pageIndex, key); int count = threeSaleService.getLastestThreeSaleCount(key); int totalPage = (int) (count % Constant.PAGE_SIZE == 0 ? count / Constant.PAGE_SIZE : count / Constant.PAGE_SIZE + 1); PageEntity pe = new PageEntity(pageIndex, Constant.PAGE_SIZE, count, totalPage); Map map = new HashMap(); map.put("key", key); pe.setParams(map); JSONObject data = new JSONObject(); data.put("pe", pe); data.put("threeSaleList", list); out.print(JsonUtil.loadTrueResult(data)); } /** * * 方法说明: 查询所有用户分享赚列表 * * @author mawurui createTime 2018年4月24日 下午3:37:13 * @param pageIndex * @param uid * @param out */ @RequestMapping(value = "getShareMoneyList", method = RequestMethod.POST) public void getShareList(int pageIndex, PrintWriter out, String key) { // int totalCount = shareService.getShareMoneyCount(); // PageEntity pageEntity = new PageEntity(); // pageEntity.setPageIndex(pageIndex); // pageEntity.setPageSize(Constant.PAGE_SIZE); // pageEntity.setTotalCount(totalCount); int count = shareService.getCountByKey(key); int totalPage = count % Constant.PAGE_SIZE == 0 ? count / Constant.PAGE_SIZE : count / Constant.PAGE_SIZE + 1; PageEntity pe = new PageEntity(pageIndex, Constant.PAGE_SIZE, count, totalPage); List shareMoneyList = shareService.getShareMoneyList(pageIndex, key); JSONObject data = new JSONObject(); data.put("pageEntity", pe); data.put("shareMoneyList", JsonUtil.getSimpleGsonWithDate().toJson(shareMoneyList)); out.print(JsonUtil.loadTrueResult(data)); } /** * * @param pageIndex * @param type * 1- 1级分销 2-2级分销 * @param uid * @param key * @param out */ @RequestMapping(value = "getThreeSaleDetailList", method = RequestMethod.POST) public void getThreeSaleDetailList(int pageIndex, int type, long uid, String key, PrintWriter out) { List userList = null; long count = 0; if (type == 1) { userList = threeSaleService.getFirstUsers(uid, pageIndex); count = threeSaleService.getFirstUsersCount(uid); } else if (type == 2) { userList = threeSaleService.getSecondUsers(uid, pageIndex); count = threeSaleService.getSecondUsersCount(uid); } int totalPage = (int) (count % Constant.PAGE_SIZE == 0 ? count / Constant.PAGE_SIZE : count / Constant.PAGE_SIZE + 1); PageEntity pe = new PageEntity(pageIndex, Constant.PAGE_SIZE, count, totalPage); Map map = new HashMap(); map.put("key", key); pe.setParams(map); JSONObject data = new JSONObject(); data.put("pe", pe); data.put("userList", userList); out.print(JsonUtil.loadTrueResult(data)); } @RequestMapping(value = "getUserListByUid", method = RequestMethod.POST) public void getUserListByUid(long uid, PrintWriter out) { List userList = userInfoService.getUserListByUid(uid); int count = userList.size(); int totalPage = count % Constant.PAGE_SIZE == 0 ? count / Constant.PAGE_SIZE : count / Constant.PAGE_SIZE + 1; PageEntity pe = new PageEntity(1, Constant.PAGE_SIZE, count, totalPage); Map map = new HashMap(); pe.setParams(map); JSONObject data = new JSONObject(); data.put("pe", pe); data.put("userList", userList); out.print(JsonUtil.loadTrueResult(data)); } /** * * 方法说明: 查询用户订单状态 * * @author mawurui createTime 2018年5月17日 上午10:55:41 * @param pageIndex * @param uid * @param out */ @RequestMapping(value = "getUserOrderList", method = RequestMethod.POST) public void getUserOrderList(int pageIndex, long uid, PrintWriter out) { List orderList = orderService.getOrderByUid(pageIndex - 1, uid); int count = orderService.getCount(uid); int totalPage = count % Constant.PAGE_SIZE == 0 ? count / Constant.PAGE_SIZE : count / Constant.PAGE_SIZE + 1; PageEntity pe = new PageEntity(pageIndex, Constant.PAGE_SIZE, count, totalPage); JSONObject data = new JSONObject(); data.put("pe", pe); data.put("orderList", JsonUtil.getSimpleGsonWithDateAndSerialization().toJson(orderList)); out.print(JsonUtil.loadTrueResult(data)); } @RequestMapping(value = "getMoneyRecordList", method = RequestMethod.POST) public void getMoneyRecordList(int pageIndex, long uid, PrintWriter out) { List moneyRecordList = moneyRecordService.getMoneyRecord(uid, pageIndex - 1); if (moneyRecordList != null) for (MoneyRecord mr : moneyRecordList) { mr.setExtract(null); mr.setUserInfo(null); mr.setHongBao(null); } int count = moneyRecordService.getCount(uid); int totalPage = count % Constant.PAGE_SIZE == 0 ? count / Constant.PAGE_SIZE : count / Constant.PAGE_SIZE + 1; PageEntity pe = new PageEntity(pageIndex, Constant.PAGE_SIZE, count, totalPage); JSONObject data = new JSONObject(); data.put("pe", pe); data.put("moneyRecordList", GsonUtil.toJsonExpose(moneyRecordList)); out.print(JsonUtil.loadTrueResult(data)); } /** * * 方法说明: 查询用户-红包详情列表 * * @author mawurui createTime 2018年5月10日 上午11:48:58 * @param pageIndex * @param uid * @param out */ @RequestMapping(value = "getHongBaoList", method = RequestMethod.POST) public void getHongBaoList(int pageIndex, long uid, PrintWriter out) { JSONObject data = new JSONObject(); List list = hongBaoService.getHongBaoList(pageIndex, uid); if (list.size() != 0 || list != null) { for (HongBao hb : list) { int hbType = hb.getType(); if (hbType == HongBao.TYPE_SHARE_GOODS) { // type == 20 Long hongbaoId = hb.getId(); PidOrder pidOrder = pidOrderService.getPidOrderByHongBaoId(hongbaoId); Order order = new Order(); order.setThirdCreateTime(pidOrder.getOrderCreateTime()); order.setOrderId(pidOrder.getOrderId()); order.setThirdState(pidOrder.getState()); order.setMoney(pidOrder.getPayMoney()); hb.setOrder(order); } else if (hbType == HongBao.TYPE_SHARE_YIJI || hbType == HongBao.TYPE_SHARE_ERJI) { Long hongbaoId = hb.getParent().getId(); PidOrder pidOrder = pidOrderService.getPidOrderByHongBaoId(hongbaoId); Order order = new Order(); order.setThirdCreateTime(pidOrder.getOrderCreateTime()); order.setOrderId(pidOrder.getOrderId()); order.setThirdState(pidOrder.getState()); order.setMoney(pidOrder.getPayMoney()); hb.setOrder(order); } else if (hbType == HongBao.TYPE_XINREN) { Order order = new Order(); Long createtime = hb.getCreatetime(); if (createtime != null) { Date ThirdCreateTime = new Date(createtime); order.setThirdCreateTime(ThirdCreateTime); } hb.setOrder(order); } else if (hb.getParent() != null) { hb.setOrder(hb.getParent().getOrder()); } } } int count = hongBaoService.getCount(uid); PageEntity pe = new PageEntity(); pe.setPageIndex(pageIndex); pe.setPageSize(Constant.PAGE_SIZE); pe.setTotalCount(count); data.put("pe", pe); data.put("list", JsonUtil.getSimpleGsonWithDateAndSerialization().toJson(list)); out.print(JsonUtil.loadTrueResult(data)); } /** * * 方法说明: 查询 分享赚页面列表 * * @author mawurui createTime 2018年4月16日 上午9:54:39 * @param pageIndex * @param uid * @param out */ @RequestMapping(value = "getShareList", method = RequestMethod.POST) public void getShareList(int pageIndex, long uid, PrintWriter out) { int totalCount = shareService.getCount(uid); PageEntity pageEntity = new PageEntity(); pageEntity.setPageIndex(pageIndex); pageEntity.setPageSize(Constant.PAGE_SIZE); pageEntity.setTotalCount(totalCount); List shareList = shareService.getShareList(pageIndex, uid); if (shareList.size() != 0 || shareList != null) { for (HongBao hb : shareList) { int hbType = hb.getType(); if (hbType == HongBao.TYPE_SHARE_GOODS) { // type == 20 Long hongbaoId = hb.getId(); PidOrder pidOrder = pidOrderService.getPidOrderByHongBaoId(hongbaoId); Order order = new Order(); order.setThirdCreateTime(pidOrder.getCreateTime()); order.setThirdState(pidOrder.getState()); hb.setOrder(order); } else if (hb.getParent() != null) { hb.setOrder(hb.getParent().getOrder()); } } } JSONObject data = new JSONObject(); data.put("pageEntity", pageEntity); data.put("shareList", GsonUtil.toJsonExpose(shareList)); out.print(JsonUtil.loadTrueResult(data)); } /** * * 方法说明: 查询 邀请赚页面列表 * * @author mawurui createTime 2018年4月16日 上午9:54:39 * @param pageIndex * @param uid * @param out */ @RequestMapping(value = "getInviteList", method = RequestMethod.POST) public void getInviteList(int pageIndex, long uid, PrintWriter out) { int totalCount = shareService.getInviteCount(uid); PageEntity pageEntity = new PageEntity(); pageEntity.setPageIndex(pageIndex); pageEntity.setPageSize(Constant.PAGE_SIZE); pageEntity.setTotalCount(totalCount); List inviteList = shareService.getInviteList(pageIndex, uid); if (inviteList.size() != 0 || inviteList != null) { for (HongBao hb : inviteList) { int hbType = hb.getType(); if (hbType == HongBao.TYPE_SHARE_GOODS) { // type == 20 Long hongbaoId = hb.getId(); PidOrder pidOrder = pidOrderService.getPidOrderByHongBaoId(hongbaoId); Order order = new Order(); order.setThirdCreateTime(pidOrder.getCreateTime()); order.setThirdState(pidOrder.getState()); hb.setOrder(order); } else if (hb.getParent() != null) { hb.setOrder(hb.getParent().getOrder()); } } } JSONObject data = new JSONObject(); data.put("pageEntity", pageEntity); data.put("inviteList", JsonUtil.getSimpleGsonWithDateAndSerialization().toJson(inviteList)); out.print(JsonUtil.loadTrueResult(data)); } /** * * 方法说明: 清除用户手势密码 * * @author mawurui createTime 2018年5月4日 下午4:47:29 * @param uid * @param out */ @RequestMapping(value = "cleanPassword", method = RequestMethod.POST) public void cleanPassword(long id, PrintWriter out) { userInfoService.cleanPassword(id); out.print(JsonUtil.loadTrueResult("清除成功")); } @RequestMapping(value = "getScanHistoryList", method = RequestMethod.POST) public void getScanHistoryList(int pageIndex, long uid, PrintWriter out) { List scanHistoryList = scanHistoryService.getScanHistoryByUid(pageIndex - 1, uid); int count = scanHistoryService.getCountByUid(uid); int totalPage = count % Constant.PAGE_SIZE == 0 ? count / Constant.PAGE_SIZE : count / Constant.PAGE_SIZE + 1; PageEntity pe = new PageEntity(pageIndex, Constant.PAGE_SIZE, count, totalPage); JSONObject data = new JSONObject(); data.put("pe", pe); data.put("scanHistoryList", GsonUtil.toDFJson(scanHistoryList)); out.print(JsonUtil.loadTrueResult(data)); } @RequestMapping(value = "getAssets", method = RequestMethod.POST) public void getAssets(PrintWriter out) { String minMoney = configService.get(Constant.EXTRACT_MIN_MONEY); double min = Double.parseDouble(minMoney); double freeze = userInfoService.getFreezeAssets(min); double canAssets = userInfoService.getCanAssets(min); JSONObject data = new JSONObject(); data.put("freeze", freeze); data.put("can", canAssets); out.print(JsonUtil.loadTrueResult(data)); } /** * * 方法说明: Excel表格下载 * * @author mawurui createTime 2018年5月21日 下午2:14:44 * @param uid * @param response */ @SuppressWarnings("unused") @RequestMapping(value = "downDetailedExcel", produces = { "application/vnd.ms-excel;charset=UTF-8" }) public void downDetailedExcel(long uid, HttpServletResponse response) { try { List list = hongBaoService.getHongBaoListAll(uid); if (list.size() != 0 || list != null) { for (HongBao hb : list) { int hbType = hb.getType(); if (hbType == HongBao.TYPE_SHARE_GOODS) { // type == 20 Long hongbaoId = hb.getId(); PidOrder pidOrder = pidOrderService.getPidOrderByHongBaoId(hongbaoId); Order order = new Order(); order.setOrderId(pidOrder.getOrderId()); order.setMoney(pidOrder.getPayMoney()); order.setThirdCreateTime(pidOrder.getCreateTime()); order.setThirdState(pidOrder.getState()); hb.setOrder(order); } else if (hbType == HongBao.TYPE_SHARE_ERJI || hbType == HongBao.TYPE_SHARE_YIJI) { // type // == Long hongbaoId = hb.getParent().getId(); PidOrder pidOrder = pidOrderService.getPidOrderByHongBaoId(hongbaoId); Order order = new Order(); order.setOrderId(pidOrder.getOrderId()); order.setMoney(pidOrder.getPayMoney()); order.setThirdCreateTime(pidOrder.getCreateTime()); order.setThirdState(pidOrder.getState()); hb.setOrder(order); } else if (hb.getParent() != null) { hb.setOrder(hb.getParent().getOrder()); } } } File desc = new File(this.getClass().getResource("/muban.xls").toURI()); InputStream inStream = new FileInputStream(desc); Workbook wb = new HSSFWorkbook(inStream); Sheet sheet = wb.getSheetAt(0); int i = 1; for (; i <= list.size(); i++) { Row row = sheet.createRow(i); for (int c = 1; c < 10; c++) { row.createCell(c); } Cell cell = row.createCell(1); HongBao hongBao = list.get(i - 1); long createtime = hongBao.getCreatetime(); String create = TimeUtil.getWholeTime(createtime); cell.setCellValue(create); Cell cell2 = row.getCell(2); String title = HongBaoUtil.getHongBaoTitle(hongBao.getType()); cell2.setCellValue(title); Order order = hongBao.getOrder(); if (order != null) { Cell cell3 = row.getCell(3); Integer orderType = order.getOrderType(); if (orderType == null) { orderType = 1; } cell3.setCellValue(orderType == 1 ? "淘宝" : "其他"); String orderId = order.getOrderId(); if (orderId == null) { orderId = ""; } Cell cell4 = row.getCell(4); cell4.setCellValue(orderId); Cell cell5 = row.getCell(5); // List // orderItemService.findByOrderId(order.getId()); cell5.setCellValue(order.getMoney().doubleValue()); Cell cell6 = row.getCell(6); String stateStr = order.getThirdState(); cell6.setCellValue(stateStr); /* * Cell cell11 = row.getCell(11); //下单时间 long orderTime = * order.getCreatetime(); String oTime = * TimeUtil.getWholeTime(orderTime); * cell11.setCellValue(oTime); */ } else if (order == null) { Cell cell3 = row.getCell(3); cell3.setCellValue("淘宝"); Cell cell4 = row.getCell(4); cell4.setCellValue(""); Cell cell5 = row.getCell(5); cell5.setCellValue(""); Cell cell6 = row.getCell(6); cell6.setCellValue(""); } else if (hongBao.getParent() != null) {// 属于分销红包 String orderId = ""; if (hongBao.getParent().getParent() != null) { orderId = hongBao.getParent().getParent().getOrder().getOrderId(); } else { orderId = hongBao.getParent().getOrder().getOrderId(); } Cell cell4 = row.getCell(4); cell4.setCellValue(orderId); } Cell cell7 = row.getCell(7); cell7.setCellValue(hongBao.getMoney().doubleValue()); Cell cell8 = row.getCell(8); cell8.setCellValue(HongBaoUtil.convertState(hongBao.getState())); Cell cell9 = row.getCell(9); if (hongBao.getGetTime() != 0) { cell9.setCellValue(TimeUtil.getWholeTime(hongBao.getGetTime())); } } List extractList = extractService.getExtractInfoByUid(uid); int ii = i; for (int m = 0; m < extractList.size(); m++, ii++) { Row row = sheet.createRow(ii); for (int c = 1; c < 10; c++) { row.createCell(c); } Cell cell = row.getCell(1); Extract extract = extractList.get(m); cell.setCellValue(TimeUtil.getWholeTime(extract.getExtractTime())); Cell cell2 = row.getCell(2); cell2.setCellValue("提现"); Cell cell7 = row.getCell(7); cell7.setCellValue(-extract.getMoney().doubleValue()); } CellRangeAddress cellRangeAddress = new CellRangeAddress(0, sheet.getLastRowNum(), 1, 9); sheet.setAutoFilter(cellRangeAddress); wb.write(response.getOutputStream()); } catch (Exception e) { e.printStackTrace(); } } /** * 查询用户信息列表--相关数据统计 * @param callback * @param pageIndex * @param key 查询条件 * @param userType 用户类型:金冠、银冠、铜冠 * @param days 查询天数 * @param startTime 注册时间 * @param endTime 注册时间 * @param orderMode 排序方式 订单数量 今日订单 累计队员 * @param out */ @RequestMapping(value = "query") public void query(String callback, Integer pageIndex, Integer pageSize, String key, Integer userType, Integer days, String startTime, String endTime, Integer orderMode, PrintWriter out) { try { // 结束时间 2018-06-06 00:00:00 加上一天 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()); } if (pageIndex == null) pageIndex = 1; if (pageSize == null) pageSize = Constant.PAGE_SIZE; Integer orderField = null; if (orderMode != null) { if (orderMode == 1 || orderMode == 2){ orderField = orderMode; orderMode = 1; } else if (orderMode == 3 || orderMode == 4){ orderField = orderMode; orderMode = 2; } else if (orderMode == 5 || orderMode == 6){ orderField = orderMode; orderMode = 3; } } List userList = userInfoService.query((pageIndex - 1) * pageSize, pageSize, key, userType, days, startTime, endTime,orderField, orderMode); if (userList == null || userList.size() == 0) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无相关数据")); return; } long count = userInfoService.queryCount(key, userType, days, startTime, endTime); 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.create(); JSONObject data = new JSONObject(); data.put("pe", pe); //data.put("sumMoney", sumMoney); data.put("resultList", gson.toJson(userList)); JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data)); } catch (Exception e) { e.printStackTrace(); JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常")); } } /** * 统计今日用户总情况 * @param callback * @param out */ @RequestMapping(value = "countInfo") public void countInfo(String callback, PrintWriter out) { try { JSONObject data = new JSONObject(); // 总数-普通用户 long countNormal = userInfoCountService.countRank(0); // 总数-铜用户 long countCuprum = userInfoCountService.countRank(1); // 总数-银用户 long countSilver = userInfoCountService.countRank(2); // 总数-金用户 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) { minMoney = "20"; } double min = Double.parseDouble(minMoney); BigDecimal countCanAssets = userInfoCountService.countAllMoney(min); 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)); } catch (Exception e) { e.printStackTrace(); JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常")); } } /** * 修改用户的状态、等级信息 * @param callback * @param userInfo * @param out */ @RequestMapping(value = "setInfo") public void setInfo(String callback, UserInfo userInfo, PrintWriter out) { try { Long id = userInfo.getId(); if (id == null) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("请传递正确数据")); return; } UserInfo currentInfo = userInfoService.selectByPKey(id); if (currentInfo == null) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("该用户已不存在")); return; } boolean hasChange = false; // 等级修改 Integer rank = userInfo.getRank(); if (rank != null) { hasChange = true; currentInfo.setRank(rank); } // 状态修改 Integer state = userInfo.getState(); if (state != null) { hasChange = true; currentInfo.setState(state); } if (hasChange) { userInfoService.updateByPrimaryKeySelective(currentInfo); JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("修改成功")); } else { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("无可修改内容")); } } catch (Exception e) { e.printStackTrace(); JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("修改失败")); } } /** * 删除绑定的账户信息: 支付宝 微信 * @param callback * @param bindId * @param out */ @RequestMapping(value = "deleteBindingAccount") public void deleteBindingAccount(String callback, Long bindId, PrintWriter out) { try { if (bindId == null) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("请传递正确数据")); return; } int count = bindingAccountService.deleteByPrimaryKey(bindId); if (count > 0) { JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("删除成功")); } else { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("删除失败")); } } catch (Exception e) { e.printStackTrace(); JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常")); } } /** * * @param data * @param uid * 用户ID * @param type * 需要解绑的账户类型 */ @RequestMapping("unBindUserInfo") public void unBindUserInfo(String callback, Long id, Integer type, PrintWriter out) { try { if (id == null) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("不存在该用户!")); return; } if (type == null) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("账户类型不可为空!")); return; } UserInfo find = userInfoService.getUserById(id); if (find == null) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("不存在该用户!")); return; } String openid = find.getOpenid(); String wxUnionId = find.getWxUnionId(); String phone = find.getPhone(); if (1 == type) { if (StringUtil.isNullOrEmpty(openid)) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("当前用户未绑定支付宝!")); return; } } else if (2 == type) { if (StringUtil.isNullOrEmpty(wxUnionId)) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("当前用户未绑定微信!")); return; } } else if (3 == type) { if (StringUtil.isNullOrEmpty(phone)) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("当前用户未绑定手机号!")); return; } } else { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("账户类型有误!")); return; } userInfoService.deleteBindInfo(find, type); JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("解绑成功")); } catch (Exception e) { e.printStackTrace(); JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常")); } } @RequestMapping(value = "queryMyFirstTeams") public void queryMyFirstTeams(String callback, Integer pageIndex, Integer pageSize, String key, Long bossId, PrintWriter out) { try { if (bossId == null) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("请传递正确数据")); return; } if (pageIndex == null) pageIndex = 1; if (pageSize == null) pageSize = Constant.PAGE_SIZE; List firstTeamList = threeSaleService.queryMyFirstTeamList((pageIndex - 1) * pageSize, pageSize, key, bossId); if (firstTeamList == null || firstTeamList.size() == 0) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无一度队员")); return; } /* 获取邀请用户头像 、昵称 */ for (ThreeSale threeSale: firstTeamList) { UserInfo worker = threeSale.getWorker(); if (worker == null) { worker = new UserInfo(); threeSale.setWorker(worker); } else{ Long id = worker.getId(); UserInfo currentInfo = userInfoService.selectByPKey(id); if (currentInfo != null) { worker.setNickName(currentInfo.getNickName()); worker.setPortrait(currentInfo.getPortrait()); } } } long count = threeSaleService.queryCountMyFirstTeamList(key, bossId); 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.create(); JSONObject data = new JSONObject(); data.put("pe", pe); data.put("list", gson.toJson(firstTeamList)); JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data)); } catch (Exception e) { e.printStackTrace(); JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常")); } } @RequestMapping(value = "queryMySecondTeams") public void queryMySecondTeams(String callback, Integer pageIndex, Integer pageSize, String key, Long bossId, PrintWriter out) { try { if (bossId == null) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("请传递正确数据")); return; } if (pageIndex == null) pageIndex = 1; if (pageSize == null) pageSize = Constant.PAGE_SIZE; List firstTeamList = threeSaleService.queryMySecondTeamList((pageIndex - 1) * pageSize, pageSize, key, bossId); if (firstTeamList == null || firstTeamList.size() == 0) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无二度队员")); return; } /* 获取邀请用户头像 、昵称 */ for (ThreeSale threeSale: firstTeamList) { UserInfo worker = threeSale.getWorker(); if (worker == null) { worker = new UserInfo(); threeSale.setWorker(worker); } else{ Long id = worker.getId(); UserInfo currentInfo = userInfoService.selectByPKey(id); if (currentInfo != null) { worker.setNickName(currentInfo.getNickName()); worker.setPortrait(currentInfo.getPortrait()); } } } long count = threeSaleService.queryCountMySecondTeamList(key, bossId); 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.create(); JSONObject data = new JSONObject(); data.put("pe", pe); data.put("list", gson.toJson(firstTeamList)); JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data)); } catch (Exception e) { e.printStackTrace(); JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常")); } } @RequestMapping(value = "deleteThreeSale") public void deleteThreeSale(String callback, Long id, PrintWriter out) { try { if (id == null) { JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("请传递正确数据")); return; } int count = threeSaleService.deleteByPrimaryKey(id); if (count > 0) { JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("删除成功")); } else{ JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("删除失败")); } } catch (Exception e) { e.printStackTrace(); JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常")); } } /** * 队员关系 * @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) { 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 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 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 = "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 channelList = null; if (channelArray != null && channelArray.trim().length() > 0) { Gson gson = new Gson(); channelList = gson.fromJson(channelArray, new TypeToken>() {}.getType()); } if (channelList == null || channelList.size() == 0) { channelList = new ArrayList(); 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 dateList = AdminUtils.getDateList(dateType, startTime, endTime, year); JSONArray line_list = new JSONArray(); for (String channel : channelList) { List> 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 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) { 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 channelList = null; if (channelArray != null && channelArray.trim().length() > 0) { Gson gson = new Gson(); channelList = gson.fromJson(channelArray, new TypeToken>() {}.getType()); } if (channelList == null || channelList.size() == 0) { channelList = new ArrayList(); 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 dateList = AdminUtils.getDateList(dateType, startTime, endTime, year); JSONArray line_list = new JSONArray(); for (String channel : channelList) { List> 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 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 channelList = null; if (channelArray != null && channelArray.trim().length() > 0) { Gson gson = new Gson(); channelList = gson.fromJson(channelArray, new TypeToken>() {}.getType()); } if (channelList == null || channelList.size() == 0) { channelList = new ArrayList(); channelList.add("all"); } if (orderNum < 1) { orderNum = 1; } try { Gson gson = new Gson(); List dateList = AdminUtils.getDateList(1, startTime, endTime, null); JSONArray line_list = new JSONArray(); for (String channel : channelList) { List 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("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(); } } }