package com.lunhan.water.host.controller.api;
|
|
import com.lunhan.water.common.ExecutedResult;
|
import com.lunhan.water.common.PagerResult;
|
import com.lunhan.water.common.jwt.LoginUserDTO;
|
import com.lunhan.water.common.util.ParameterUtil;
|
import com.lunhan.water.common.validator.ParameterValidateResult;
|
import com.lunhan.water.common.validator.ParameterValidator;
|
import com.lunhan.water.entity.enums.EPayType;
|
import com.lunhan.water.entity.request.paymentrecords.ReqBuyWater;
|
import com.lunhan.water.entity.request.rechargerecords.Recharge;
|
import com.lunhan.water.entity.request.userlogin.ReqModifyUserLogin;
|
import com.lunhan.water.entity.search.SearchPaymentRecords;
|
import com.lunhan.water.entity.search.SearchRechargeRecords;
|
import com.lunhan.water.entity.search.SearchWaterFacility;
|
import com.lunhan.water.host.BasicController;
|
import com.lunhan.water.repository.po.UserLoginPO;
|
import com.lunhan.water.repository.vo.PaymentRecordsVO;
|
import com.lunhan.water.repository.vo.RechargeRecordsVO;
|
import com.lunhan.water.repository.vo.UserLoginVO;
|
import com.lunhan.water.repository.vo.WaterFacilityVO;
|
import com.lunhan.water.service.PaymentRecordsService;
|
import com.lunhan.water.service.RechargeRecordsService;
|
import com.lunhan.water.service.UserLoginService;
|
import com.lunhan.water.service.WaterFacilityService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.*;
|
|
import java.math.BigDecimal;
|
import java.util.Objects;
|
|
@RestController
|
@RequestMapping(value = "api/user")
|
public class UserController extends BasicController {
|
@Autowired
|
private PaymentRecordsService paymentRecordsService;
|
@Autowired
|
private RechargeRecordsService rechargeRecordsService;
|
@Autowired
|
private UserLoginService userLoginService;
|
@Autowired
|
private WaterFacilityService waterFacilityService;
|
/**
|
* 查询用户信息
|
* @author lin.liu
|
*/
|
@GetMapping(value = "getUser")
|
public ExecutedResult<UserLoginVO> getUser() {
|
return userLoginService.getUser(this.getTokenUser());
|
}
|
/**
|
* 编辑用户头像信息
|
* @author lin.liu
|
*/
|
@PostMapping(value = "editUser")
|
public ExecutedResult<String> editUser(@RequestBody ReqModifyUserLogin request ) {
|
return userLoginService.modify(request);
|
}
|
/**
|
* 用户取水
|
* @author lin.liu
|
*/
|
@PostMapping(value = "userWaterInTaking")
|
public ExecutedResult<String> userWaterInTaking(@RequestBody ReqBuyWater request) {
|
return paymentRecordsService.userWaterInTaking(this.getTokenUser(),request);
|
}
|
/**
|
* 查询取水设备列表
|
* @author lin.liu
|
*/
|
@PostMapping(value = "searchFacility")
|
public ExecutedResult<PagerResult<WaterFacilityVO>> searchFacility(@RequestBody SearchWaterFacility request) {
|
//#region 参数验证
|
ParameterValidator validator = new ParameterValidator()
|
// 必须大于0
|
.addGreater(ParameterUtil.named("纬度"), request.getLatitude(), 0L)
|
.addGreater(ParameterUtil.named("经度"), request.getLongitude(), 0L)
|
;
|
ParameterValidateResult result = validator.validate();
|
if (result.getIsFiled()) {
|
return failed(result.getErrorMsg());
|
}
|
return waterFacilityService.search(request);
|
}
|
|
/**
|
* 查询[消费记录]
|
* @author lin.liu
|
*/
|
@PostMapping(value = "searchPaymentRecords")
|
public ExecutedResult<PagerResult<PaymentRecordsVO>> searchPaymentRecords(@RequestBody SearchPaymentRecords request) {
|
//#region 参数验证
|
LoginUserDTO tokenUser = this.getTokenUser();
|
UserLoginPO user = userLoginService.get4Openid(tokenUser.getUserId());
|
if(Objects.isNull(user)){
|
return ExecutedResult.failed("用户信息不存在!");
|
}
|
request.setUserId(user.getId());
|
return paymentRecordsService.search(request);
|
}
|
/**
|
* 查询[充值记录]
|
* @author lin.liu
|
*/
|
@PostMapping(value = "searchRechargeRecords")
|
public ExecutedResult<PagerResult<RechargeRecordsVO>> searchRechargeRecords(@RequestBody SearchRechargeRecords request) {
|
LoginUserDTO tokenUser = this.getTokenUser();
|
UserLoginPO user = userLoginService.get4Openid(tokenUser.getUserId());
|
if(Objects.isNull(user)){
|
return ExecutedResult.failed("用户信息不存在!");
|
}
|
request.setUserId(user.getId());
|
return rechargeRecordsService.search(request);
|
}
|
/**
|
* 用户充值
|
*
|
* @author li。ling。yu
|
* @date 2023/08/04
|
*/
|
@PostMapping(value = "fees")
|
public ExecutedResult<String> pay(@RequestBody Recharge request) {
|
//#region 参数验证
|
ParameterValidator validator = new ParameterValidator()
|
// 必须大于0
|
.addGreater(ParameterUtil.named("充值金额"), request.getRechargeAmount(), BigDecimal.ZERO)
|
;
|
LoginUserDTO loginUser = super.getTokenUser();
|
ParameterValidateResult result = validator.validate();
|
if (result.getIsFiled()) {
|
return failed(result.getErrorMsg());
|
}
|
//#endregion
|
return this.rechargeRecordsService.recharge(request,loginUser);
|
}
|
}
|
