| | |
| | | } |
| | | |
| | | @Override |
| | | public R<TUser> userInfoParent() { |
| | | return R.fail("获取用户信息失败" + cause.getMessage()); |
| | | } |
| | | |
| | | @Override |
| | | public R<Boolean> addIntegralDetail(String integral, String method) { |
| | | return R.fail("生成积分明细信息失败" + cause.getMessage()); |
| | | } |
| | | |
| | | @Override |
| | | public R<Boolean> addIntegralDetailParent(String integral, String method) { |
| | | return R.fail("添加积分明细失败" + cause.getMessage()); |
| | | } |
| | | |
| | | @Override |
| | | public R<Boolean> exchangeIntegral(Integer integral, String method) { |
| | | return R.fail("用户积分变动失败" + cause.getMessage()); |
| | | } |
| | | |
| | | @Override |
| | | public R<Boolean> exchangeIntegralParent(Integer integral, String method) { |
| | | return R.fail("修改积分变动失败" + cause.getMessage()); |
| | | } |
| | | |
| | | @Override |
| | | public R<Boolean> addIntegralDetail1(String integral, String method) { |
| | | return null; |
| | | } |
| | |
| | | */ |
| | | @GetMapping("/base/study/addIntegralDetail") |
| | | R<Boolean> addIntegralDetail(@RequestParam("integral") String integral, @RequestParam("method") String method); |
| | | @GetMapping("/base/study/addIntegralDetailParent") |
| | | R<Boolean> addIntegralDetailParent(@RequestParam("integral") String integral, @RequestParam("method") String method); |
| | | |
| | | /** |
| | | * 用户积分变动(增加或减少)-用于远程调用 |
| | |
| | | @GetMapping("/base/study/exchangeIntegral") |
| | | @ApiOperation(value = "用户积分变动", tags = {"用户积分变动"}) |
| | | R<Boolean> exchangeIntegral(@RequestParam("integral") Integer integral, @RequestParam("method") String method); |
| | | @GetMapping("/base/study/exchangeIntegralParent") |
| | | @ApiOperation(value = "用户积分变动", tags = {"用户积分变动"}) |
| | | R<Boolean> exchangeIntegralParent(@RequestParam("integral") Integer integral, @RequestParam("method") String method); |
| | | |
| | | /** |
| | | * 生成积分明细-用于远程调用 |
| | |
| | | // 扣除用户积分 |
| | | result = result && studyClient.exchangeIntegral(needIntegral, Constants.BURDEN).getData(); |
| | | return result; |
| | | }private Boolean exchangeGoodParent(GoodExchangeDTO goodExchange, Recipient recipient, Integer number, |
| | | Integer goodId, int needIntegral) { |
| | | // 兑换成功,生成订单信息、生成积分明细(积分明细需要远程调用rouyi-study服务) |
| | | TOrder order = orderInfo(goodExchange, recipient, number, goodId, needIntegral); |
| | | boolean result = orderService.save(order); |
| | | // 远程调用,生成积分明细 |
| | | result = result && studyClient.addIntegralDetailParent(Constants.BURDEN + needIntegral, Constants.SHOPPING_CONSUME).getData(); |
| | | // 扣除用户积分 |
| | | result = result && studyClient.exchangeIntegralParent(needIntegral, Constants.BURDEN).getData(); |
| | | return result; |
| | | } |
| | | |
| | | @Override |
| | |
| | | return R.exchangeError("当前商品库存不足"); |
| | | } |
| | | // 兑换成功,生成订单信息、生成积分明细(积分明细需要远程调用rouyi-study服务) |
| | | boolean result = exchangeGood(goodExchange, recipient, number, goodId, needIntegral); |
| | | boolean result = exchangeGoodParent(goodExchange, recipient, number, goodId, needIntegral); |
| | | // 扣除库存 |
| | | result = result && this.lambdaUpdate().set(TGoods::getTotal, good.getTotal() - number) |
| | | .eq(TGoods::getId, good.getId()).update(); |
| | |
| | | return R.exchangeError("商品兑换失败!"); |
| | | } |
| | | } else { |
| | | boolean result = exchangeGood(goodExchange, recipient, number, goodId, needIntegral); |
| | | boolean result = exchangeGoodParent(goodExchange, recipient, number, goodId, needIntegral); |
| | | if (!result) { |
| | | return R.exchangeError("商品兑换失败!"); |
| | | } |
| | |
| | | integralRecord.setUpdateTime(new Date()); |
| | | return R.ok(integralRecordService.save(integralRecord)); |
| | | } |
| | | @GetMapping("/addIntegralDetailParent") |
| | | // @ApiOperation(value = "添加-积分明细", tags = {"添加-积分明细"}) |
| | | @ApiImplicitParams({ |
| | | @ApiImplicitParam(value = "积分数量", name = "integral", dataType = "Integer", required = true), |
| | | @ApiImplicitParam(value = "变动源(完成学习、完成游戏...)", name = "method", dataType = "String", required = true) |
| | | }) |
| | | public R<Boolean> addIntegralDetailParent(@RequestParam("integral") String integral, @RequestParam("method") String method) { |
| | | // 当前登录用户 |
| | | LoginUserParent userStudy = tokenService.getLoginUser1(); |
| | | // 生成积分明细信息 |
| | | TIntegralRecord integralRecord = new TIntegralRecord(); |
| | | integralRecord.setIntegral(integral); |
| | | integralRecord.setMethod(method); |
| | | integralRecord.setUserId(userStudy.getUserid()); |
| | | integralRecord.setDisabled(Boolean.FALSE); |
| | | integralRecord.setCreateBy(userStudy.getPhone()); |
| | | integralRecord.setCreateTime(new Date()); |
| | | integralRecord.setUpdateBy(userStudy.getPhone()); |
| | | integralRecord.setUpdateTime(new Date()); |
| | | return R.ok(integralRecordService.save(integralRecord)); |
| | | } |
| | | |
| | | @GetMapping("/addIntegralDetail1") |
| | | // @ApiOperation(value = "添加-积分明细", tags = {"添加-积分明细"}) |
| | |
| | | } |
| | | return R.ok(userService.updateById(user)); |
| | | } |
| | | @GetMapping("/exchangeIntegralParent") |
| | | // @ApiOperation(value = "用户积分变动", tags = {"用户积分变动"}) |
| | | public R<Boolean> exchangeIntegralParent(@RequestParam("integral") Integer integral, @RequestParam("method") String method) { |
| | | if (tokenService.getLoginUser1()==null){ |
| | | return R.tokenError("登录失效"); |
| | | } |
| | | TUser user = userService.getById(tokenService.getLoginUser1().getUserid()); |
| | | if (Constants.BURDEN.equals(method)) { |
| | | user.setIntegral(user.getIntegral() - integral); |
| | | } else { |
| | | user.setIntegral(user.getIntegral() + integral); |
| | | } |
| | | return R.ok(userService.updateById(user)); |
| | | } |
| | | |
| | | @GetMapping("/exchangeIntegral1") |
| | | // @ApiOperation(value = "用户积分变动", tags = {"用户积分变动"}) |