diff --git a/esua-epdc/epdc-module/epdc-points/epdc-points-server/src/main/java/com/elink/esua/epdc/service/impl/PointsLogsServiceImpl.java b/esua-epdc/epdc-module/epdc-points/epdc-points-server/src/main/java/com/elink/esua/epdc/service/impl/PointsLogsServiceImpl.java index 1b815ac6..7b8f1f69 100755 --- a/esua-epdc/epdc-module/epdc-points/epdc-points-server/src/main/java/com/elink/esua/epdc/service/impl/PointsLogsServiceImpl.java +++ b/esua-epdc/epdc-module/epdc-points/epdc-points-server/src/main/java/com/elink/esua/epdc/service/impl/PointsLogsServiceImpl.java @@ -460,16 +460,15 @@ public class PointsLogsServiceImpl extends BaseServiceImpl result = usersFeignClient.handleUserPoints(userPointsFormDTO); if (!result.success()) { return new Result().error(result.getMsg()); } - + // 保存积分日志 + PointsLogsEntity pointsLogsEntity = packagePointsLogs(userById.getData(), formDto); + this.insert(pointsLogsEntity); return new Result(); } diff --git a/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/java/com/elink/esua/epdc/service/impl/UserServiceImpl.java b/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/java/com/elink/esua/epdc/service/impl/UserServiceImpl.java index edb0184e..b7100b82 100644 --- a/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/java/com/elink/esua/epdc/service/impl/UserServiceImpl.java +++ b/esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/java/com/elink/esua/epdc/service/impl/UserServiceImpl.java @@ -975,6 +975,7 @@ public class UserServiceImpl extends BaseServiceImpl implem * @Date 2019/12/13 15:02 **/ @Override + @Transactional(rollbackFor = Exception.class) public Result handleUserPoints(EpdcUserPointsFormDTO formDTO) { UserEntity userEntity = baseDao.selectById(formDTO.getUserId()); if (null == userEntity) {