明星电力充电桩
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
zhibing.pu
2024-08-26 9f35dc84a6af0a9019e5ae2c8ac4b2c8e2c99fe9 
 ruoyi-service/ruoyi-account/src/main/java/com/ruoyi/account/controller/TAppUserController.java


@@ -13,6 +13,7 @@


import com.ruoyi.account.service.*;


import com.ruoyi.account.util.PointDetailUtil;


import com.ruoyi.account.util.SignDayUtil;


import com.ruoyi.account.util.carBrand.CarBrandUtil;


import com.ruoyi.account.wx.model.WeixinProperties;


import com.ruoyi.account.util.GiveVipUtil;


import com.ruoyi.common.core.constant.Constants;


@@ -24,6 +25,7 @@


import com.ruoyi.common.core.utils.bean.BeanUtils;


import com.ruoyi.common.core.web.domain.AjaxResult;


import com.ruoyi.common.core.web.domain.BasePojo;


import com.ruoyi.common.core.web.page.BasePage;


import com.ruoyi.common.redis.service.RedisService;


import com.ruoyi.common.security.auth.AuthUtil;


import com.ruoyi.common.security.service.TokenService;


@@ -110,9 +112,24 @@




    @Resource


    private VipClient vipClient;


    @Resource


    private TInviteUserService inviteUserService;








    /**


     * 远程调用 积分兑换订单 退款回退积分


     * @return


     */


    @PostMapping(value = "/refundPoints/{param}")


    public R refundPoints(@PathVariable("param")String param) {


        String[] split = param.split("-");


        String userId = split[0];


        String points = split[1];


        TAppUser byId = appUserService.getById(userId);


        byId.setPoints(byId.getPoints()+Integer.parseInt(points));


        appUserService.updateById(byId);


        return R.ok();


    }




    @ApiOperation(value = "查询当前用户是否为会员 0否1是", tags = {"小程序--查询当前用户是否为会员"})


    @PostMapping(value = "/getUserInfo")


@@ -401,6 +418,9 @@


    @ApiOperation(value = "用户详情积分明细", tags = {"后台-用户管理-用户列表","小程序-个人中心"})


    @PostMapping(value = "/user/points/page")


    public R<Page<TAppUserIntegralChange>> pointsDetail(@RequestBody PointsQueryDto pointsQueryDto) {


        if (pointsQueryDto.getUserId()==null){


            pointsQueryDto.setUserId(tokenService.getLoginUserApplet().getUserId());


        }


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


        if (pointsQueryDto.getType()!=null){


            types.add(1);


@@ -416,6 +436,8 @@


                .in(!types.isEmpty(), TAppUserIntegralChange::getChangeType, types).page(Page.of(pointsQueryDto.getPageCurr(), pointsQueryDto.getPageSize()));




        for (TAppUserIntegralChange record : page.getRecords()) {


            record.setDateTime(record.getCreateTime());


            record.setUid(record.getId().toString());


            if (record.getChangeType()==2){


                R<TChargingOrder> tChargingOrderR = chargingOrderClient.orderDetail(Long.valueOf(record.getExtension()));


                if (tChargingOrderR.getData()!=null) {


@@ -432,6 +454,13 @@




        return R.ok(page);




    }




    @ApiOperation(value = "积分详情", tags = {"小程序-个人中心"})


    @GetMapping(value = "/user/points/detail")


    public R<TAppUserIntegralChange> pointsDetail(String id) {


        TAppUserIntegralChange byId = integralChangeService.getById(id);


        return R.ok(byId);


    }




    @ApiOperation(value = "冻结解冻用户", tags = {"后台-用户管理-用户列表"})


@@ -490,6 +519,9 @@


        appUserInfoDto.setCouponNum(Math.toIntExact(coupons));


        //当前绑定的车辆


        List<TAppUserCar> list = carService.lambdaQuery().eq(TAppUserCar::getAppUserId, userId).list();


        for (TAppUserCar tAppUserCar : list) {


            tAppUserCar.setUid(tAppUserCar.getId().toString());


        }


        appUserInfoDto.setUserCars(list);


        return R.ok(appUserInfoDto);




@@ -519,6 +551,14 @@


    }






    @ApiOperation(value = "优惠卷详情（1可使用2不可用）", tags = {"小程序-个人中心"})


    @PostMapping(value = "/user/coupon/getById")


    public R<TAppCoupon> couponGetById(@RequestParam("id")Long id) {


        TAppCoupon appCoupon = appCouponService.getById(id);


        return R.ok(appCoupon);


    }








    @ApiOperation(value = "赠送会员", tags = {"用户管理-用户列表"})


    @PostMapping(value = "/user/give/vip")


@@ -539,18 +579,43 @@


        }


        //增加vipDetail


        giveVipUtil.sendVip(nowUser, giveVipDto.getVipId(),plusDay);






        appUserService.updateById(nowUser);


        //执行一次赠送优惠卷的定时任务


        }


        return R.ok();


    }




    @ApiOperation(value = "已赠送列表", tags = {"小程序-个人中心-邀请好友"})


    @PostMapping(value = "/user/invite/page")


    public R<Page<TInviteUser>> invitePage(@RequestBody BasePage basePage) {


        Long userId = tokenService.getLoginUserApplet().getUserId();




        Page<TInviteUser> page = inviteUserService.lambdaQuery().eq(TInviteUser::getAppUserId, userId).isNotNull(TInviteUser::getAward).orderByDesc(TInviteUser::getCreateTime).page(Page.of(basePage.getPageCurr(), basePage.getPageSize()));


        return R.ok(page);


    }




    @ApiOperation(value = "已赠送列表", tags = {"小程序-个人中心-邀请好友"})


    @PostMapping(value = "/user/invite/info")


    public R<InviteInfoDto> inviteInfo() {


        Long userId = tokenService.getLoginUserApplet().getUserId();


        Integer point = 0;


        List<TInviteUser> list = inviteUserService.lambdaQuery().eq(TInviteUser::getAppUserId, userId).isNotNull(TInviteUser::getAward).orderByDesc(TInviteUser::getCreateTime).list();


        for (TInviteUser tInviteUser : list) {


            point = point +tInviteUser.getAward();


        }


        InviteInfoDto inviteInfoDto = new InviteInfoDto();


        inviteInfoDto.setPoint(point);


        inviteInfoDto.setInviteNum(list.size());






        return R.ok(inviteInfoDto);


    }








    @ApiOperation(value = "更换手机号", tags = {"小程序-用户管理-更换手机号"})


    @PostMapping(value = "/user/updatePhone")


    public AjaxResult<String> updatePhone(@Validated @RequestBody UpdatePhoneDTO dto) {


        String code = redisService.getCacheObject(dto.getPhone() + Constants.APPLET);


        String code = redisService.getCacheObject(dto.getPhone() + Constants.UPDATE_PHONE);


        if(StringUtils.isEmpty(code)){


            return AjaxResult.error("验证码已过期,请重新获取验证码!");


        }


@@ -649,7 +714,7 @@


        //签到加积分记录


        R<TIntegralRule> set = integralRuleClient.getSet();


        TIntegralRule data = set.getData();


        JSONObject jsonObject = JSON.parseObject(data.getAddVehiclesEarnsPoints());


        JSONObject jsonObject = JSON.parseObject(data.getSignInForPoints());


        //增加每日积分


        Integer points = 0;


        Integer point = jsonObject.getInteger("num1");


@@ -725,7 +790,7 @@


        LoginUserApplet loginUserApplet = tokenService.getLoginUserApplet();


        Long userId = loginUserApplet.getUserId();


        TAppUser byId = appUserService.getById(userId);




        appUserCar.setAppUserId(userId);




        //如果是第一次添加车辆，增加积分


        Long count = appUserCarService.lambdaQuery().eq(TAppUserCar::getAppUserId, userId).count();


@@ -766,5 +831,42 @@




        return R.ok();


    }


    @ApiOperation(value = "添加编辑车辆", tags = {"小程序-个人中心-车辆"})


    @DeleteMapping(value = "/user/car/delete")


    public R carDelete(String id) {


        boolean b = appUserCarService.removeById(id);


        return R.ok();


    }


    @ApiOperation(value = "车辆详情", tags = {"小程序-个人中心-车辆"})


    @GetMapping(value = "/user/car/detail")


    public R<TAppUserCar> carDetail(String id) {


        TAppUserCar byId = appUserCarService.getById(id);


        return R.ok(byId);


    }




    @ApiOperation(value = "获取车辆品牌", tags = {"小程序-个人中心-车辆"})


    @GetMapping(value = "/user/car/getBrands")


    public R getBrands(String name) throws Exception {


        String brand = CarBrandUtil.getBrand();


        JSONObject jsonObject = JSON.parseObject(brand);


        JSONArray data = jsonObject.getJSONArray("data");


        return R.ok(data);




    }




    @ApiOperation(value = "根据品牌获取车型", tags = {"小程序-个人中心-车辆"})


    @GetMapping(value = "/user/car/getModel")


    public R getModel(String id) throws Exception {


        String modelById = CarBrandUtil.getModelById(id);


        JSONObject jsonObject = JSON.parseObject(modelById);


        JSONArray data = jsonObject.getJSONArray("data");


        JSONArray backList = new JSONArray();


        for (Object datum : data) {


            JSONObject jsonObject1 = JSON.parseObject(datum.toString());


            JSONArray list = jsonObject1.getJSONArray("list");


            backList.addAll(list);


        }


        return R.ok(backList);


    }


}