Browse Source

积分部分接口修改,对多客户情况进行兼容

dev
wangchao 5 years ago
parent
commit
7329fc42ea
  1. 6
      epmet-module/epmet-point/epmet-point-client/pom.xml
  2. 3
      epmet-module/epmet-point/epmet-point-client/src/main/java/com/epmet/dto/form/CommonPageUserFormDTO.java
  3. 2
      epmet-module/epmet-point/epmet-point-client/src/main/java/com/epmet/dto/form/PointVerificationFormDTO.java
  4. 7
      epmet-module/epmet-point/epmet-point-client/src/main/java/com/epmet/feign/EpmetPointOpenFeignClient.java
  5. 5
      epmet-module/epmet-point/epmet-point-client/src/main/java/com/epmet/feign/fallback/EpmetPointOpenFeignClientFallback.java
  6. 4
      epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/controller/AdjustmentController.java
  7. 1
      epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/controller/ExchangeController.java
  8. 13
      epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/controller/ResiPointController.java
  9. 2
      epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/dao/PointVerificationLogDao.java
  10. 3
      epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/dao/UserPointActionLogDao.java
  11. 9
      epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/dao/UserPointTotalDao.java
  12. 3
      epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/PointAdjustmentLogService.java
  13. 14
      epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/UserPointTotalService.java
  14. 10
      epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/impl/PointAdjustmentLogServiceImpl.java
  15. 13
      epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/impl/PointVerificationLogServiceImpl.java
  16. 2
      epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/impl/UserPointActionLogServiceImpl.java
  17. 23
      epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/impl/UserPointTotalServiceImpl.java
  18. 24
      epmet-module/epmet-point/epmet-point-server/src/main/resources/mapper/PointVerificationLogDao.xml
  19. 2
      epmet-module/epmet-point/epmet-point-server/src/main/resources/mapper/UserPointActionLogDao.xml
  20. 15
      epmet-module/epmet-point/epmet-point-server/src/main/resources/mapper/UserPointTotalDao.xml
  21. 7
      epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/CommonUserFormDTO.java
  22. 4
      epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserServiceImpl.java

6
epmet-module/epmet-point/epmet-point-client/pom.xml

@ -27,6 +27,12 @@
<groupId>io.springfox</groupId> <groupId>io.springfox</groupId>
<artifactId>springfox-swagger-ui</artifactId> <artifactId>springfox-swagger-ui</artifactId>
</dependency> </dependency>
<dependency>
<groupId>com.epmet</groupId>
<artifactId>epmet-user-client</artifactId>
<version>2.0.0</version>
<scope>compile</scope>
</dependency>
</dependencies> </dependencies>
<build> <build>

3
epmet-module/epmet-point/epmet-point-client/src/main/java/com/epmet/dto/form/CommonPageUserFormDTO.java

@ -26,4 +26,7 @@ public class CommonPageUserFormDTO implements Serializable {
private Integer pageNo = 1; private Integer pageNo = 1;
private Integer pageSize = 10; private Integer pageSize = 10;
@NotBlank(message = "获取不到用户Id" , groups = PageUserGroup.class)
private String customerId;
} }

2
epmet-module/epmet-point/epmet-point-client/src/main/java/com/epmet/dto/form/PointVerificationFormDTO.java

@ -52,4 +52,6 @@ public class PointVerificationFormDTO implements Serializable {
@NotBlank(message = "缺失地址信息" , groups = PointVerificationGroup.class) @NotBlank(message = "缺失地址信息" , groups = PointVerificationGroup.class)
private String address; private String address;
private String customerId;
} }

7
epmet-module/epmet-point/epmet-point-client/src/main/java/com/epmet/feign/EpmetPointOpenFeignClient.java

@ -2,10 +2,11 @@ package com.epmet.feign;
import com.epmet.commons.tools.constant.ServiceConstant; import com.epmet.commons.tools.constant.ServiceConstant;
import com.epmet.commons.tools.utils.Result; import com.epmet.commons.tools.utils.Result;
import com.epmet.dto.form.CommonUserFormDTO;
import com.epmet.dto.result.ResiPointDetailResultDTO; import com.epmet.dto.result.ResiPointDetailResultDTO;
import com.epmet.feign.fallback.EpmetPointOpenFeignClientFallback; import com.epmet.feign.fallback.EpmetPointOpenFeignClientFallback;
import org.springframework.cloud.openfeign.FeignClient; import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PostMapping;
/** /**
* 本服务对外开放的API,其他服务通过引用此client调用该服务 * 本服务对外开放的API,其他服务通过引用此client调用该服务
@ -23,6 +24,6 @@ public interface EpmetPointOpenFeignClient {
* @author wangc * @author wangc
* @date 2020.07.22 15:58 * @date 2020.07.22 15:58
**/ **/
@GetMapping("/point/resi/point/mypoint") @PostMapping("/point/resi/point/mypoint")
Result<ResiPointDetailResultDTO> myPoint(); Result<ResiPointDetailResultDTO> myPoint(CommonUserFormDTO param);
} }

5
epmet-module/epmet-point/epmet-point-client/src/main/java/com/epmet/feign/fallback/EpmetPointOpenFeignClientFallback.java

@ -3,6 +3,7 @@ package com.epmet.feign.fallback;
import com.epmet.commons.tools.constant.ServiceConstant; import com.epmet.commons.tools.constant.ServiceConstant;
import com.epmet.commons.tools.utils.ModuleUtils; import com.epmet.commons.tools.utils.ModuleUtils;
import com.epmet.commons.tools.utils.Result; import com.epmet.commons.tools.utils.Result;
import com.epmet.dto.form.CommonUserFormDTO;
import com.epmet.dto.result.ResiPointDetailResultDTO; import com.epmet.dto.result.ResiPointDetailResultDTO;
import com.epmet.feign.EpmetPointOpenFeignClient; import com.epmet.feign.EpmetPointOpenFeignClient;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@ -16,7 +17,7 @@ import org.springframework.stereotype.Component;
@Component @Component
public class EpmetPointOpenFeignClientFallback implements EpmetPointOpenFeignClient { public class EpmetPointOpenFeignClientFallback implements EpmetPointOpenFeignClient {
@Override @Override
public Result<ResiPointDetailResultDTO> myPoint() { public Result<ResiPointDetailResultDTO> myPoint(CommonUserFormDTO param) {
return ModuleUtils.feignConError(ServiceConstant.EPMET_POINT_SERVER, "myPoint"); return ModuleUtils.feignConError(ServiceConstant.EPMET_POINT_SERVER, "myPoint",param);
} }
} }

4
epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/controller/AdjustmentController.java

@ -7,6 +7,7 @@ import com.epmet.commons.tools.enums.RequirePermissionEnum;
import com.epmet.commons.tools.security.dto.TokenDto; import com.epmet.commons.tools.security.dto.TokenDto;
import com.epmet.commons.tools.utils.Result; import com.epmet.commons.tools.utils.Result;
import com.epmet.commons.tools.validator.ValidatorUtils; import com.epmet.commons.tools.validator.ValidatorUtils;
import com.epmet.dto.form.CommonUserFormDTO;
import com.epmet.dto.form.CustomerUserFormDTO; import com.epmet.dto.form.CustomerUserFormDTO;
import com.epmet.dto.form.IssueInitiatorFormDTO; import com.epmet.dto.form.IssueInitiatorFormDTO;
import com.epmet.dto.form.PointAdjustmentFormDTO; import com.epmet.dto.form.PointAdjustmentFormDTO;
@ -59,7 +60,8 @@ public class AdjustmentController {
**/ **/
@PostMapping("userdetail") @PostMapping("userdetail")
@RequirePermission(requirePermission = RequirePermissionEnum.MORE_POINT_USER_MANAGE_DETAIL_VIEW) @RequirePermission(requirePermission = RequirePermissionEnum.MORE_POINT_USER_MANAGE_DETAIL_VIEW)
public Result<CustomerUserDetailResultDTO> userDetail(@RequestBody IssueInitiatorFormDTO param){ public Result<CustomerUserDetailResultDTO> userDetail(@LoginUser TokenDto staffToken,@RequestBody CommonUserFormDTO param){
param.setCustomerId(staffToken.getCustomerId());
ValidatorUtils.validateEntity(param,IssueInitiatorFormDTO.UserIdGroup.class); ValidatorUtils.validateEntity(param,IssueInitiatorFormDTO.UserIdGroup.class);
return new Result<CustomerUserDetailResultDTO>().ok(pointAdjustmentLogService.userDetail(param)); return new Result<CustomerUserDetailResultDTO>().ok(pointAdjustmentLogService.userDetail(param));
} }

1
epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/controller/ExchangeController.java

@ -39,6 +39,7 @@ public class ExchangeController {
@PostMapping("execute") @PostMapping("execute")
public Result<PointVerificationResultDTO> execute(@LoginUser TokenDto token, @RequestBody PointVerificationFormDTO verificationParam){ public Result<PointVerificationResultDTO> execute(@LoginUser TokenDto token, @RequestBody PointVerificationFormDTO verificationParam){
verificationParam.setOperatorId(token.getUserId()); verificationParam.setOperatorId(token.getUserId());
verificationParam.setCustomerId(token.getCustomerId());
ValidatorUtils.validateEntity(verificationParam, PointVerificationFormDTO.PointVerificationGroup.class); ValidatorUtils.validateEntity(verificationParam, PointVerificationFormDTO.PointVerificationGroup.class);
return new Result<PointVerificationResultDTO>().ok(pointVerificationLogService.verifyPoint(verificationParam)); return new Result<PointVerificationResultDTO>().ok(pointVerificationLogService.verifyPoint(verificationParam));
} }

13
epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/controller/ResiPointController.java

@ -5,7 +5,7 @@ import com.epmet.commons.tools.security.dto.TokenDto;
import com.epmet.commons.tools.utils.Result; import com.epmet.commons.tools.utils.Result;
import com.epmet.commons.tools.validator.ValidatorUtils; import com.epmet.commons.tools.validator.ValidatorUtils;
import com.epmet.dto.form.CommonPageUserFormDTO; import com.epmet.dto.form.CommonPageUserFormDTO;
import com.epmet.dto.form.ResiCommonUserIdFormDTO; import com.epmet.dto.form.CommonUserFormDTO;
import com.epmet.dto.form.ResiPointRankFormDTO; import com.epmet.dto.form.ResiPointRankFormDTO;
import com.epmet.dto.result.PointExchangeResponseResultDTO; import com.epmet.dto.result.PointExchangeResponseResultDTO;
import com.epmet.dto.result.ResiPointDetailResultDTO; import com.epmet.dto.result.ResiPointDetailResultDTO;
@ -46,12 +46,11 @@ public class ResiPointController {
* @author wangc * @author wangc
* @date 2020.07.22 15:58 * @date 2020.07.22 15:58
**/ **/
@GetMapping("mypoint") @PostMapping("mypoint")
public Result<ResiPointDetailResultDTO> myPoint(@LoginUser TokenDto dto){ public Result<ResiPointDetailResultDTO> myPoint(@LoginUser TokenDto dto, @RequestBody CommonUserFormDTO userParam){
ResiCommonUserIdFormDTO param = new ResiCommonUserIdFormDTO(); userParam.setUserId(dto.getUserId());
param.setUserId(dto.getUserId()); ValidatorUtils.validateEntity(userParam, CommonUserFormDTO.CustomerId_UserIdGroup.class);
ValidatorUtils.validateEntity(param,ResiCommonUserIdFormDTO.UserIdGroup.class); return new Result<ResiPointDetailResultDTO>().ok(userPointTotalService.getMyPoint(userParam));
return new Result<ResiPointDetailResultDTO>().ok(userPointTotalService.getMyPoint(param));
} }
/** /**

2
epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/dao/PointVerificationLogDao.java

@ -43,7 +43,7 @@ public interface PointVerificationLogDao extends BaseDao<PointVerificationLogEnt
* @author wangc * @author wangc
* @date 2020.07.22 15:38 * @date 2020.07.22 15:38
**/ **/
List<ResiPointLogPeriodResultDTO> selectVerificationLog(@Param("userId") String userId); List<ResiPointLogPeriodResultDTO> selectVerificationLog(@Param("userId") String userId,@Param("customerId")String customerId);
/** /**
* @Description 获取工作人员月度核销记录 * @Description 获取工作人员月度核销记录

3
epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/dao/UserPointActionLogDao.java

@ -42,7 +42,8 @@ public interface UserPointActionLogDao extends BaseDao<UserPointActionLogEntity>
* @author wangc * @author wangc
* @date 2020.07.22 13:56 * @date 2020.07.22 13:56
**/ **/
List<ResiPointLogPeriodResultDTO> selectPointActionLogList(@Param("userId") String userId); List<ResiPointLogPeriodResultDTO> selectPointActionLogList(@Param("userId") String userId,@Param("customerId")String customerId);
/** /**
* @Description 查询指定用户在某条规则下所得的积分总和 * @Description 查询指定用户在某条规则下所得的积分总和

9
epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/dao/UserPointTotalDao.java

@ -44,6 +44,15 @@ public interface UserPointTotalDao extends BaseDao<UserPointTotalEntity> {
**/ **/
ResiPointDetailResultDTO selectPointByUserId(@Param("userId")String userId); ResiPointDetailResultDTO selectPointByUserId(@Param("userId")String userId);
/**
* @Description 根据用户Id和客户Id查询他的累计积分以及可用积分
* @param userId
* @return
* @author wangc
* @date 2020.07.21 13:38
**/
ResiPointDetailResultDTO selectPointByCustomerUserId(@Param("userId")String userId,@Param("customerId")String customerId);
/** /**
* @Description 查询客户下的用户累计积分排名榜 * @Description 查询客户下的用户累计积分排名榜
* @param customerId * @param customerId

3
epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/PointAdjustmentLogService.java

@ -20,6 +20,7 @@ package com.epmet.service;
import com.epmet.commons.mybatis.service.BaseService; import com.epmet.commons.mybatis.service.BaseService;
import com.epmet.commons.tools.page.PageData; import com.epmet.commons.tools.page.PageData;
import com.epmet.dto.PointAdjustmentLogDTO; import com.epmet.dto.PointAdjustmentLogDTO;
import com.epmet.dto.form.CommonUserFormDTO;
import com.epmet.dto.form.IssueInitiatorFormDTO; import com.epmet.dto.form.IssueInitiatorFormDTO;
import com.epmet.dto.form.PointAdjustmentFormDTO; import com.epmet.dto.form.PointAdjustmentFormDTO;
import com.epmet.dto.result.CustomerUserDetailResultDTO; import com.epmet.dto.result.CustomerUserDetailResultDTO;
@ -113,7 +114,7 @@ public interface PointAdjustmentLogService extends BaseService<PointAdjustmentLo
* @author wangc * @author wangc
* @date 2020.07.27 10:57 * @date 2020.07.27 10:57
**/ **/
CustomerUserDetailResultDTO userDetail(IssueInitiatorFormDTO param); CustomerUserDetailResultDTO userDetail(CommonUserFormDTO param);
/** /**
* @Description 积分调整 * @Description 积分调整

14
epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/UserPointTotalService.java

@ -20,6 +20,7 @@ package com.epmet.service;
import com.epmet.commons.mybatis.service.BaseService; import com.epmet.commons.mybatis.service.BaseService;
import com.epmet.commons.tools.page.PageData; import com.epmet.commons.tools.page.PageData;
import com.epmet.dto.UserPointTotalDTO; import com.epmet.dto.UserPointTotalDTO;
import com.epmet.dto.form.CommonUserFormDTO;
import com.epmet.dto.form.ResiCommonUserIdFormDTO; import com.epmet.dto.form.ResiCommonUserIdFormDTO;
import com.epmet.dto.form.ResiPointRankFormDTO; import com.epmet.dto.form.ResiPointRankFormDTO;
import com.epmet.dto.result.ResiPointDetailResultDTO; import com.epmet.dto.result.ResiPointDetailResultDTO;
@ -99,12 +100,12 @@ public interface UserPointTotalService extends BaseService<UserPointTotalEntity>
/** /**
* @Description 获取指定居民的积分信息 * @Description 获取指定居民的积分信息
* @param userId * @param param
* @return * @return
* @author wangc * @author wangc
* @date 2020.07.22 15:58 * @date 2020.07.22 15:58
**/ **/
ResiPointDetailResultDTO getMyPoint(ResiCommonUserIdFormDTO userId); ResiPointDetailResultDTO getMyPoint(CommonUserFormDTO param);
/** /**
* @Description 获取客户下用户积分排名榜 * @Description 获取客户下用户积分排名榜
@ -125,4 +126,13 @@ public interface UserPointTotalService extends BaseService<UserPointTotalEntity>
void insertOrUpdate(UserPointTotalEntity entity); void insertOrUpdate(UserPointTotalEntity entity);
void testInsertOrUpdate(UserPointTotalEntity entity); void testInsertOrUpdate(UserPointTotalEntity entity);
/**
* @Description 获取指定居民的积分信息 - 使用客户Id匹配兼容多客户情况
* @param customerUserParam
* @return
* @author wangc
* @date 2020.07.22 15:58
**/
ResiPointDetailResultDTO getMyPointGroupByCustomer(CommonUserFormDTO customerUserParam);
} }

10
epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/impl/PointAdjustmentLogServiceImpl.java

@ -30,6 +30,7 @@ import com.epmet.commons.tools.utils.Result;
import com.epmet.dao.PointAdjustmentLogDao; import com.epmet.dao.PointAdjustmentLogDao;
import com.epmet.dao.UserPointActionLogDao; import com.epmet.dao.UserPointActionLogDao;
import com.epmet.dto.PointAdjustmentLogDTO; import com.epmet.dto.PointAdjustmentLogDTO;
import com.epmet.dto.form.CommonUserFormDTO;
import com.epmet.dto.form.IssueInitiatorFormDTO; import com.epmet.dto.form.IssueInitiatorFormDTO;
import com.epmet.dto.form.PointAdjustmentFormDTO; import com.epmet.dto.form.PointAdjustmentFormDTO;
import com.epmet.dto.form.ResiCommonUserIdFormDTO; import com.epmet.dto.form.ResiCommonUserIdFormDTO;
@ -150,13 +151,14 @@ public class PointAdjustmentLogServiceImpl extends BaseServiceImpl<PointAdjustme
* @date 2020.07.27 10:57 * @date 2020.07.27 10:57
**/ **/
@Override @Override
public CustomerUserDetailResultDTO userDetail(IssueInitiatorFormDTO param) { public CustomerUserDetailResultDTO userDetail(CommonUserFormDTO param) {
Result<CustomerUserDetailResultDTO> detailResult = epmetUserOpenFeignClient.customerUserDetail(param); IssueInitiatorFormDTO userParam = new IssueInitiatorFormDTO();
userParam.setUserId(param.getUserId());
Result<CustomerUserDetailResultDTO> detailResult = epmetUserOpenFeignClient.customerUserDetail(userParam);
if(!detailResult.success()){ if(!detailResult.success()){
throw new RenException(detailResult.getCode()); throw new RenException(detailResult.getCode());
} }
ResiCommonUserIdFormDTO userParam = ConvertUtils.sourceToTarget(param,ResiCommonUserIdFormDTO.class); ResiPointDetailResultDTO pointDto = userPointTotalService.getMyPointGroupByCustomer(param);
ResiPointDetailResultDTO pointDto = userPointTotalService.getMyPoint(userParam);
if(null != detailResult.getData()){ if(null != detailResult.getData()){
CustomerUserDetailResultDTO result = new CustomerUserDetailResultDTO(); CustomerUserDetailResultDTO result = new CustomerUserDetailResultDTO();
result.setPoint(null != pointDto ? pointDto.getUsablePoint() : NumConstant.ZERO); result.setPoint(null != pointDto ? pointDto.getUsablePoint() : NumConstant.ZERO);

13
epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/impl/PointVerificationLogServiceImpl.java

@ -147,7 +147,7 @@ public class PointVerificationLogServiceImpl extends BaseServiceImpl<PointVerifi
@Override @Override
public List<ResiPointLogListResultDTO> getMyExchangeRecord(CommonPageUserFormDTO pageUser) { public List<ResiPointLogListResultDTO> getMyExchangeRecord(CommonPageUserFormDTO pageUser) {
PageHelper.startPage(pageUser.getPageNo(),pageUser.getPageSize()); PageHelper.startPage(pageUser.getPageNo(),pageUser.getPageSize());
List<ResiPointLogPeriodResultDTO> logList = baseDao.selectVerificationLog(pageUser.getUserId()); List<ResiPointLogPeriodResultDTO> logList = baseDao.selectVerificationLog(pageUser.getUserId(),pageUser.getCustomerId());
List<ResiPointLogListResultDTO> result = new LinkedList<>(); List<ResiPointLogListResultDTO> result = new LinkedList<>();
if(null != logList && !logList.isEmpty()){ if(null != logList && !logList.isEmpty()){
Map<String,List<ResiPointLogPeriodResultDTO>> map = Map<String,List<ResiPointLogPeriodResultDTO>> map =
@ -256,9 +256,10 @@ public class PointVerificationLogServiceImpl extends BaseServiceImpl<PointVerifi
DimIdGenerator.DimIdBean dim = DimIdGenerator.getDimIdBean(new Date()); DimIdGenerator.DimIdBean dim = DimIdGenerator.getDimIdBean(new Date());
ResiCommonUserIdFormDTO userId = new ResiCommonUserIdFormDTO(); CommonUserFormDTO customerUserParam = new CommonUserFormDTO();
userId.setUserId(verificationParam.getUserId()); customerUserParam.setUserId(verificationParam.getUserId());
ResiPointDetailResultDTO currentPoint = userPointTotalService.getMyPoint(userId); customerUserParam.setCustomerId(verificationParam.getCustomerId());
ResiPointDetailResultDTO currentPoint = userPointTotalService.getMyPointGroupByCustomer(customerUserParam);
if(null == currentPoint || null == currentPoint.getUsablePoint() || currentPoint.getUsablePoint() < verificationParam.getPoint()){ if(null == currentPoint || null == currentPoint.getUsablePoint() || currentPoint.getUsablePoint() < verificationParam.getPoint()){
result.setSuccessFlag(false); result.setSuccessFlag(false);
result.setFailureReason(ModuleConstant.POINT_NOT_ENOUGH); result.setFailureReason(ModuleConstant.POINT_NOT_ENOUGH);
@ -280,14 +281,14 @@ public class PointVerificationLogServiceImpl extends BaseServiceImpl<PointVerifi
point *= NumConstant.ONE_NEG; point *= NumConstant.ONE_NEG;
} }
String customerId = ModuleConstant.EMPTY_STR; String customerId = verificationParam.getCustomerId();
String agencyId = ModuleConstant.EMPTY_STR; String agencyId = ModuleConstant.EMPTY_STR;
String operatorName = ModuleConstant.EMPTY_STR; String operatorName = ModuleConstant.EMPTY_STR;
PointVerificationStatisticalDailyEntity statistical = new PointVerificationStatisticalDailyEntity(); PointVerificationStatisticalDailyEntity statistical = new PointVerificationStatisticalDailyEntity();
if(staffResult.success() && null != staffResult.getData()){ if(staffResult.success() && null != staffResult.getData()){
statistical = ConvertUtils.sourceToTarget(staffResult.getData(),PointVerificationStatisticalDailyEntity.class); statistical = ConvertUtils.sourceToTarget(staffResult.getData(),PointVerificationStatisticalDailyEntity.class);
customerId = staffResult.getData().getCustomerId(); customerId = StringUtils.isBlank(customerId) ? staffResult.getData().getCustomerId() : customerId;
operatorName = staffResult.getData().getNickname(); operatorName = staffResult.getData().getNickname();
agencyId = staffResult.getData().getAgencyId(); agencyId = staffResult.getData().getAgencyId();
} }

2
epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/impl/UserPointActionLogServiceImpl.java

@ -139,7 +139,7 @@ public class UserPointActionLogServiceImpl extends BaseServiceImpl<UserPointActi
@Override @Override
public List<ResiPointLogListResultDTO> getMyPointRecord(CommonPageUserFormDTO pageUser) { public List<ResiPointLogListResultDTO> getMyPointRecord(CommonPageUserFormDTO pageUser) {
PageHelper.startPage(pageUser.getPageNo(),pageUser.getPageSize()); PageHelper.startPage(pageUser.getPageNo(),pageUser.getPageSize());
List<ResiPointLogPeriodResultDTO> logList = baseDao.selectPointActionLogList(pageUser.getUserId()); List<ResiPointLogPeriodResultDTO> logList = baseDao.selectPointActionLogList(pageUser.getUserId(),pageUser.getCustomerId());
List<ResiPointLogListResultDTO> result = new LinkedList<>(); List<ResiPointLogListResultDTO> result = new LinkedList<>();
if(null != logList && !logList.isEmpty()){ if(null != logList && !logList.isEmpty()){
Map<String,List<ResiPointLogPeriodResultDTO>> map = Map<String,List<ResiPointLogPeriodResultDTO>> map =

23
epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/impl/UserPointTotalServiceImpl.java

@ -27,6 +27,7 @@ import com.epmet.commons.tools.constant.FieldConstant;
import com.epmet.commons.tools.utils.Result; import com.epmet.commons.tools.utils.Result;
import com.epmet.dao.UserPointTotalDao; import com.epmet.dao.UserPointTotalDao;
import com.epmet.dto.UserPointTotalDTO; import com.epmet.dto.UserPointTotalDTO;
import com.epmet.dto.form.CommonUserFormDTO;
import com.epmet.dto.form.ResiCommonUserIdFormDTO; import com.epmet.dto.form.ResiCommonUserIdFormDTO;
import com.epmet.dto.form.ResiPointRankFormDTO; import com.epmet.dto.form.ResiPointRankFormDTO;
import com.epmet.dto.result.*; import com.epmet.dto.result.*;
@ -114,14 +115,14 @@ public class UserPointTotalServiceImpl extends BaseServiceImpl<UserPointTotalDao
/** /**
* @Description 获取指定居民的积分信息 * @Description 获取指定居民的积分信息
* @param userId * @param param
* @return * @return
* @author wangc * @author wangc
* @date 2020.07.22 15:58 * @date 2020.07.22 15:58
**/ **/
@Override @Override
public ResiPointDetailResultDTO getMyPoint(ResiCommonUserIdFormDTO userId) { public ResiPointDetailResultDTO getMyPoint(CommonUserFormDTO param) {
ResiPointDetailResultDTO result = baseDao.selectPointByUserId(userId.getUserId()); ResiPointDetailResultDTO result = baseDao.selectPointByCustomerUserId(param.getUserId(),param.getCustomerId());
if(null == result) return new ResiPointDetailResultDTO(); if(null == result) return new ResiPointDetailResultDTO();
if(null == result.getUsablePoint() || null == result.getAccumulatedPoint()) return new ResiPointDetailResultDTO(); if(null == result.getUsablePoint() || null == result.getAccumulatedPoint()) return new ResiPointDetailResultDTO();
return result; return result;
@ -249,4 +250,20 @@ public class UserPointTotalServiceImpl extends BaseServiceImpl<UserPointTotalDao
baseDao.insertOrUpdate(entity); baseDao.insertOrUpdate(entity);
} }
/**
* @Description 获取指定居民的积分信息 - 使用客户Id匹配兼容多客户情况
* @param customerUserParam
* @return
* @author wangc
* @date 2020.07.22 15:58
**/
@Override
public ResiPointDetailResultDTO getMyPointGroupByCustomer(CommonUserFormDTO customerUserParam) {
ResiPointDetailResultDTO result = baseDao.selectPointByUserId(customerUserParam.getUserId());
if(null == result) return new ResiPointDetailResultDTO();
if(null == result.getUsablePoint() || null == result.getAccumulatedPoint()) return new ResiPointDetailResultDTO();
return result;
}
} }

24
epmet-module/epmet-point/epmet-point-server/src/main/resources/mapper/PointVerificationLogDao.xml

@ -25,20 +25,24 @@
<!-- 查询指定用户兑换记录 传参:用户Id --> <!-- 查询指定用户兑换记录 传参:用户Id -->
<select id="selectVerificationLog" resultType="com.epmet.dto.result.ResiPointLogPeriodResultDTO"> <select id="selectVerificationLog" resultType="com.epmet.dto.result.ResiPointLogPeriodResultDTO">
SELECT SELECT
USER_ID, verify.USER_ID,
'积分兑换' AS TITLE, '积分兑换' AS TITLE,
concat( '兑换', EXCHANGED_ITEM ) AS REMARK, concat( '兑换', verify.EXCHANGED_ITEM ) AS REMARK,
concat( '-', POINT ) AS point, concat( '-', verify.POINT ) AS point,
DATE_FORMAT( CREATED_TIME, '%Y-%m-%d' ) AS DATE, DATE_FORMAT( verify.CREATED_TIME, '%Y-%m-%d' ) AS DATE,
DATE_FORMAT( CREATED_TIME, '%H:%i' ) AS TIME DATE_FORMAT( verify.CREATED_TIME, '%H:%i' ) AS TIME
FROM FROM
POINT_VERIFICATION_LOG POINT_VERIFICATION_LOG verify
LEFT JOIN
USER_POINT_ACTION_LOG action
ON verify.ACTION_ID = action.ID AND action.DEL_FLAG = '0'
WHERE WHERE
DEL_FLAG = '0' verify.DEL_FLAG = '0'
AND USER_ID = #{userId} AND verify.USER_ID = #{userId}
AND action.CUSTOMER_ID = #{customerId}
ORDER BY ORDER BY
CREATED_TIME DESC verify.CREATED_TIME DESC
</select> </select>
<!-- 获取工作人员月度核销记录 --> <!-- 获取工作人员月度核销记录 -->

2
epmet-module/epmet-point/epmet-point-server/src/main/resources/mapper/UserPointActionLogDao.xml

@ -36,6 +36,8 @@
DEL_FLAG = '0' DEL_FLAG = '0'
AND AND
USER_ID = #{userId} USER_ID = #{userId}
AND
CUSTOMER_ID = #{customerId}
ORDER BY ORDER BY
CREATED_TIME DESC CREATED_TIME DESC
</select> </select>

15
epmet-module/epmet-point/epmet-point-server/src/main/resources/mapper/UserPointTotalDao.xml

@ -31,6 +31,21 @@
USER_ID = #{userId} USER_ID = #{userId}
</select> </select>
<!-- 根据用户Id和客户Id查询他的累计积分以及可用积分 -->
<select id="selectPointByCustomerUserId" resultType="com.epmet.dto.result.ResiPointDetailResultDTO">
SELECT
USABLE_POINT AS usablePoint,
TOTAL_POINT AS accumulatedPoint
FROM
USER_POINT_TOTAL
WHERE
DEL_FLAG = '0'
AND
CUSTOMER_ID = #{customerId}
AND
USER_ID = #{userId}
</select>
<!-- 查询客户下的用户积分排行,分页 传参:customerId --> <!-- 查询客户下的用户积分排行,分页 传参:customerId -->
<select id="selectUserPointRank" resultType="com.epmet.dto.result.ResiPointRankResultDTO"> <select id="selectUserPointRank" resultType="com.epmet.dto.result.ResiPointRankResultDTO">
SELECT SELECT

7
epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/CommonUserFormDTO.java

@ -1,5 +1,6 @@
package com.epmet.dto.form; package com.epmet.dto.form;
import com.epmet.commons.tools.validator.group.CustomerClientShowGroup;
import lombok.Data; import lombok.Data;
import javax.validation.constraints.NotBlank; import javax.validation.constraints.NotBlank;
@ -15,15 +16,17 @@ import java.io.Serializable;
public class CommonUserFormDTO implements Serializable{ public class CommonUserFormDTO implements Serializable{
private static final long serialVersionUID = -7994579456530273809L; private static final long serialVersionUID = -7994579456530273809L;
public interface CustomerId_UserIdGroup extends CustomerClientShowGroup{}
/** /**
* 用户Id * 用户Id
* */ * */
@NotBlank(message = "用户Id不能为空") @NotBlank(message = "用户Id不能为空" , groups = CustomerId_UserIdGroup.class)
private String userId; private String userId;
/** /**
* 客户Id * 客户Id
* */ * */
@NotBlank(message = "客户Id不能为空") @NotBlank(message = "客户Id不能为空" , groups = CustomerId_UserIdGroup.class)
private String customerId; private String customerId;
} }

4
epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserServiceImpl.java

@ -202,7 +202,9 @@ public class UserServiceImpl extends BaseServiceImpl<UserDao, UserEntity> implem
userRoleFormDTO.setGridId(myResiUserInfoFormDTO.getGridId()); userRoleFormDTO.setGridId(myResiUserInfoFormDTO.getGridId());
result.setRoleList(userRoleDao.getUserRoleList(userRoleFormDTO)); result.setRoleList(userRoleDao.getUserRoleList(userRoleFormDTO));
Result<ResiPointDetailResultDTO> pointResult = epmetPointOpenFeignClient.myPoint(); CommonUserFormDTO pointParam = new CommonUserFormDTO();
pointParam.setCustomerId(myResiUserInfoFormDTO.getCustomerId());
Result<ResiPointDetailResultDTO> pointResult = epmetPointOpenFeignClient.myPoint(pointParam);
if(pointResult.success() && null != pointResult.getData()){ if(pointResult.success() && null != pointResult.getData()){
//累计积分 //累计积分
result.setPoint(pointResult.getData().getUsablePoint()); result.setPoint(pointResult.getData().getUsablePoint());

Loading…
Cancel
Save