玩湃
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
无关风月
3 天以前 b27efc697f2f81e0d0f247a2708e58af52a5df9b 
 cloud-server-management/src/main/java/com/dsh/guns/modular/system/controller/code/TAppUserController.java


@@ -13,6 +13,8 @@


import com.dsh.course.feignClient.activity.model.BodySideAppointment;


import com.dsh.course.feignClient.activity.model.QueryBodySideAppointment;


import com.dsh.course.feignClient.activity.model.QueryBodySideAppointmentVO;


import com.dsh.course.feignClient.communityWorldCup.Model.StoreIds;


import com.dsh.course.feignClient.communityWorldCup.WorldCupClient;


import com.dsh.course.feignClient.competition.CompetitionClient;


import com.dsh.course.feignClient.competition.model.Competition;


import com.dsh.course.feignClient.competition.model.ListQuery;


@@ -23,8 +25,10 @@


import com.dsh.guns.config.UserExt;


import com.dsh.guns.modular.system.controller.util.MD5;


import com.dsh.guns.modular.system.model.*;


import com.dsh.guns.modular.system.model.dto.UpdateIntegral;


import com.dsh.guns.modular.system.service.*;


import com.dsh.guns.modular.system.util.ResultUtil;


import io.swagger.models.auth.In;


import org.springframework.beans.BeanUtils;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Controller;


@@ -166,7 +170,26 @@


        model.addAttribute("students",tStudents);


        return PREFIX + "TAppUser_edit.html";


    }


    @RequestMapping("/changeIntegral/{id}")


    public String changeIntegral(Model model,@PathVariable("id") Integer id) {


        TAppUser data = appUserClient.queryById(id);


        model.addAttribute("data",data);


        return PREFIX + "TAppUser_changeIntegral.html";


    }




    @Autowired


    private WorldCupClient worldCupClient;


    @RequestMapping("/updateIntegral")


    @ResponseBody


    public ResultUtil updateIntegral(Integer id,Integer changeType, Integer integral, String remark){


        UpdateIntegral updateIntegral = new UpdateIntegral();


        updateIntegral.setId(id);


        updateIntegral.setChangeType(changeType);


        updateIntegral.setIntegral(integral);


        updateIntegral.setRemark(remark);


        System.err.println("积分修改是否成功:"+appUserClient.updateIntegral(updateIntegral));


        return ResultUtil.success();


    }


    /**


     * 获取所有用户信息


     * @return


@@ -212,14 +235,69 @@


            List<Integer> cpUsers = coursePackageClient.getCoursePackageByStoreIds(storeIds);


            // 获取游戏记录 拿到用户ids


            List<Integer> gameUsers = ballClient.getGameByStoreIds(storeIds);


            // 查询世界杯记录 获取用户ids


            StoreIds storeIds1 = new StoreIds();


            storeIds1.setStoreIds(storeIds);


            List<Integer> userIds = worldCupClient.getUserIds(storeIds1);


            // 用户ids


            List<Integer> users = new ArrayList<>();


            users.addAll(list);


            users.addAll(siteUsers);


            users.addAll(cpUsers);


            users.addAll(gameUsers);


            users.addAll(userIds);


            // 去重后的用户id


            List<Integer> collect = users.stream().distinct().collect(Collectors.toList());


            if (collect.isEmpty()){


                collect.add(-1);


            }


            queryAppUser.setUserIds(collect);


//            List<QueryAppUserVO> queryAppUserVOS1 = new ArrayList<>();


//            // 根据用户消费记录 去查询用户ids


//            for (Integer integer : collect) {


//                if (!collect1.contains(integer)){


//                    TAppUser tAppUser = appUserClient.queryAppUser1(integer);


//                    QueryAppUserVO queryAppUserVO = new QueryAppUserVO();


//                    BeanUtils.copyProperties(tAppUser,queryAppUserVO);


//                    queryAppUserVOS.add(queryAppUserVO);


//                }


//            }


        }


        if (objectType == 3){


            // 获取运营商下的所有门店id集合


            List<Integer> storeIds = new ArrayList<>();


            storeIds.add(objectId);


            // 根据门店id集合查询 属于该运营商下的门店举办的赛事


            ListQuery listQuery = new ListQuery();


            listQuery.setIds(storeIds);


            // 通过门店ids 获取赛事的支付记录 获取到用户的ids


            List<Integer> list = competitionClient.getUserIds(listQuery);


            // 获取场地预约记录 拿到用户ids


            List<Integer> siteUsers = siteBookingService.list(new QueryWrapper<SiteBooking>().in("storeId", storeIds)


                            .ne("status",0)


                            .ne("status",5)


                    )


                    .stream().map(SiteBooking::getAppUserId).collect(Collectors.toList());


            // 获取课程购买记录 拿到用户ids


            List<Integer> cpUsers = coursePackageClient.getCoursePackageByStoreIds(storeIds);


            // 获取游戏记录 拿到用户ids


            List<Integer> gameUsers = ballClient.getGameByStoreIds(storeIds);


            StoreIds storeIds1 = new StoreIds();


            storeIds1.setStoreIds(storeIds);


            // 查询世界杯记录 获取用户ids


            List<Integer> userIds = worldCupClient.getUserIds(storeIds1);


            // 用户ids


            List<Integer> users = new ArrayList<>();


            users.addAll(list);


            users.addAll(siteUsers);


            users.addAll(cpUsers);


            users.addAll(gameUsers);


            users.addAll(userIds);


            // 去重后的用户id


            List<Integer> collect = users.stream().distinct().collect(Collectors.toList());


            if (collect.isEmpty()){


                collect.add(-1);


            }


            queryAppUser.setUserIds(collect);


//            List<QueryAppUserVO> queryAppUserVOS1 = new ArrayList<>();


//            // 根据用户消费记录 去查询用户ids