| | |
| | | @RequestMapping("/data") |
| | | public class DataStatisticsController extends BaseController { |
| | | private String PREFIX = "/system/dataStatistics/"; |
| | | |
| | | private Integer resolveOperatorId(Integer operatorId) { |
| | | Integer objectType = UserExt.getUser().getObjectType(); |
| | | if (Integer.valueOf(2).equals(objectType)) { |
| | | return UserExt.getUser().getObjectId(); |
| | | } |
| | | return operatorId; |
| | | } |
| | | |
| | | private Integer resolveStoreId(Integer storeId) { |
| | | Integer objectType = UserExt.getUser().getObjectType(); |
| | | if (!Integer.valueOf(2).equals(objectType) || storeId == null) { |
| | | return storeId; |
| | | } |
| | | TStore store = storeService.getById(storeId); |
| | | if (store != null && UserExt.getUser().getObjectId().equals(store.getOperatorId())) { |
| | | return storeId; |
| | | } |
| | | return null; |
| | | } |
| | | |
| | | @Autowired |
| | | private ICityService cityService; |
| | | @Resource |
| | |
| | | @RequestMapping(value = "/getIncomeData") |
| | | @ResponseBody |
| | | public Object getIncomeData(Integer operatorId,Integer storeId) { |
| | | // operatorId = resolveOperatorId(operatorId); |
| | | // storeId = resolveStoreId(operatorId); |
| | | Integer objectId = UserExt.getUser().getObjectId(); |
| | | List<Integer> cityManagerId= new ArrayList<>(); |
| | | if(objectId>0){ |
| | | operatorId=objectId; |
| | | if(storeId==null){ |
| | | cityManagerId= storeService.list(new QueryWrapper<TStore>().eq("cityManagerId", objectId)).stream().map(TStore::getId).collect(Collectors.toList()); |
| | | }else { |
| | | cityManagerId.add(storeId); |
| | | } |
| | | |
| | | } |
| | | // 报名课程查询query |
| | | RegisterOrderQuery query = new RegisterOrderQuery(); |
| | | // 充值记录查询query |
| | |
| | | } |
| | | }else { |
| | | List<Integer> list = new ArrayList<>(); |
| | | |
| | | |
| | | list.add(storeId); |
| | | |
| | | |
| | | query.setStoresIds(list); |
| | | siteBookingQuery.setStoreIds(list); |
| | | competitionQuery.setStoreId(storeId); |
| | |
| | | } |
| | | |
| | | // 积分商品 |
| | | List<PointMerchandiseIncomeVo> amount = pointMercharsClient.getAmount(); |
| | | List<PointMerchandiseIncomeVo> amount = pointMercharsClient.getAmount(cityManagerId); |
| | | for (PointMerchandiseIncomeVo pointMerchandiseIncomeVo : amount) { |
| | | IncomeVO temp = new IncomeVO(); |
| | | if (pointMerchandiseIncomeVo==null) continue; |
| | |
| | | @RequestMapping(value = "/backYys") |
| | | @ResponseBody |
| | | public Object backYys(Integer id) { |
| | | id = resolveOperatorId(id); |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | | List<Integer> userPt = appUserClient.getUserYYs(id); |
| | | if(userPt.size()==0){ |
| | |
| | | @RequestMapping(value = "/stuYys") |
| | | @ResponseBody |
| | | public Object stuYys(Integer id) { |
| | | id = resolveOperatorId(id); |
| | | List<TStore> list4 = storeService.list(new QueryWrapper<TStore>().eq("operatorId", id).eq("state", 1)); |
| | | List<Integer> collect1 = list4.stream().map(TStore::getId).collect(Collectors.toList()); |
| | | //课程 |
| | |
| | | @RequestMapping(value = "/courseYys") |
| | | @ResponseBody |
| | | public Object courseYys(Integer id) { |
| | | id = resolveOperatorId(id); |
| | | List<Integer> userPt = appUserClient.getUserYYs(id); |
| | | HashMap<String, Object> map = coursePackagePaymentClient.coursePt(userPt); |
| | | return map; |
| | |
| | | @RequestMapping(value = "/userAndVipYys") |
| | | @ResponseBody |
| | | public Object userAndVipYys(Integer id) { |
| | | id = resolveOperatorId(id); |
| | | List<TStore> list4 = storeService.list(new QueryWrapper<TStore>().eq("operatorId", id).eq("state", 1)); |
| | | List<Integer> collect1 = list4.stream().map(TStore::getId).collect(Collectors.toList()); |
| | | //课程 |
| | |
| | | @RequestMapping(value = "/actYys") |
| | | @ResponseBody |
| | | public Object actYys(Integer id) { |
| | | id = resolveOperatorId(id); |
| | | CompetionVO competionVO = new CompetionVO(); |
| | | List<TStore> list4 = storeService.list(new QueryWrapper<TStore>().eq("operatorId", id).eq("state", 1)); |
| | | List<Integer> collect1 = list4.stream().map(TStore::getId).collect(Collectors.toList()); |
| | |
| | | //门票 |
| | | |
| | | |
| | | competionVO.setIds(list); |
| | | competionVO.setIds(list2); |
| | | competionVO.setOperatorId(id); |
| | | competionVO.setStoreIds(collect1); |
| | | HashMap<String, Object> map = competitionClient.actYys(competionVO); |
| | | |
| | | List<TStore> lists = storeService.list(new LambdaQueryWrapper<TStore>().eq(TStore::getOperatorId, id)); |
| | |
| | | @ResponseBody |
| | | @RequestMapping("/selectYys") |
| | | public Object selectYys(Integer id,String time) { |
| | | id = resolveOperatorId(id); |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | | // 找出平台的用户 |
| | | // List<User> list = sysUserService.list(new LambdaQueryWrapper<User>().eq(User::getObjectType, 2)); |
| | |
| | | @RequestMapping("/stuUserDataYys") |
| | | @ResponseBody |
| | | public Object stuUserDataYys(Integer id) { |
| | | id = resolveOperatorId(id); |
| | | List<TStore> list4 = storeService.list(new QueryWrapper<TStore>().eq("operatorId", id).eq("state", 1)); |
| | | List<Integer> collect1 = list4.stream().map(TStore::getId).collect(Collectors.toList()); |
| | | //课程 |
| | |
| | | @RequestMapping("/selectYysJx") |
| | | @ResponseBody |
| | | public Object selectYysJx(Integer id) { |
| | | id = resolveOperatorId(id); |
| | | List<TStore> list4 = storeService.list(new QueryWrapper<TStore>().eq("operatorId", id).eq("state", 1)); |
| | | List<Integer> collect1 = list4.stream().map(TStore::getId).collect(Collectors.toList()); |
| | | //课程 |