diff --git a/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/controller/MqPointCallbackController.java b/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/controller/MqPointCallbackController.java index 1de8982e48..443716268d 100644 --- a/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/controller/MqPointCallbackController.java +++ b/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/controller/MqPointCallbackController.java @@ -6,6 +6,7 @@ import com.epmet.commons.tools.dto.form.mq.eventmsg.BasePointEventMsg; import com.epmet.commons.tools.exception.EpmetErrorCode; import com.epmet.commons.tools.exception.RenException; import com.epmet.commons.tools.utils.ConvertUtils; +import com.epmet.commons.tools.utils.Result; import com.epmet.service.UserPointActionLogService; import dto.form.SendPointFormDTO; import lombok.extern.slf4j.Slf4j; @@ -41,11 +42,11 @@ public class MqPointCallbackController { * @return */ @RequestMapping("activeSendPoint") - public String activeSendPoint(@RequestBody ReceiveMqMsg mqMsg) { + public Result activeSendPoint(@RequestBody ReceiveMqMsg mqMsg) { log.debug("activeSendPoint receive mqMsg:{}", JSON.toJSONString(mqMsg)); if (mqMsg == null || StringUtils.isBlank(mqMsg.getMsg())) { log.warn("activeSendPoint mqMsg is empty"); - return "success"; + return new Result().ok(true); } List formDTO = JSON.parseArray(mqMsg.getMsg(), SendPointFormDTO.class); try { @@ -55,7 +56,7 @@ public class MqPointCallbackController { throw new RenException(EpmetErrorCode.SERVER_ERROR.getMsg()); } log.info("activeSendPoint consumer success,formDTO:{}", JSON.toJSONString(formDTO)); - return "success"; + return new Result().ok(true); } /** @@ -65,11 +66,11 @@ public class MqPointCallbackController { * @return */ @RequestMapping("registervolunteer") - public String registerVolunteer(@RequestBody ReceiveMqMsg mqMsg) { + public Result registerVolunteer(@RequestBody ReceiveMqMsg mqMsg) { log.debug("registerVolunteer receive mqMsg:{}", JSON.toJSONString(mqMsg)); if (mqMsg == null || StringUtils.isBlank(mqMsg.getMsg())) { log.warn("registerVolunteer mqMsg is empty"); - return "success"; + return new Result().ok(true); } BasePointEventMsg formDTO = ConvertUtils.sourceToTarget(mqMsg.getMsg(), BasePointEventMsg.class); try { @@ -79,7 +80,7 @@ public class MqPointCallbackController { throw new RenException(EpmetErrorCode.SERVER_ERROR.getMsg()); } log.info("registerVolunteer consumer success,formDTO:{}", JSON.toJSONString(formDTO)); - return "success"; + return new Result().ok(true); } /** @@ -89,11 +90,11 @@ public class MqPointCallbackController { * @return */ @RequestMapping("pubactivelive") - public String pubActiveLive(@RequestBody ReceiveMqMsg mqMsg) { + public Result pubActiveLive(@RequestBody ReceiveMqMsg mqMsg) { log.debug("pubActiveLive receive mqMsg:{}", JSON.toJSONString(mqMsg)); if (mqMsg == null || StringUtils.isBlank(mqMsg.getMsg())) { log.warn("pubActiveLive mqMsg is empty"); - return "success"; + return new Result().ok(true); } BasePointEventMsg formDTO = ConvertUtils.sourceToTarget(mqMsg.getMsg(), BasePointEventMsg.class); try { @@ -103,7 +104,7 @@ public class MqPointCallbackController { throw new RenException(EpmetErrorCode.SERVER_ERROR.getMsg()); } log.info("pubActiveLive consumer success,formDTO:{}", JSON.toJSONString(formDTO)); - return "success"; + return new Result().ok(true); } } diff --git a/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/controller/PointRuleController.java b/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/controller/PointRuleController.java index a0c7f479dd..bfbcff6ebb 100644 --- a/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/controller/PointRuleController.java +++ b/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/controller/PointRuleController.java @@ -52,8 +52,8 @@ public class PointRuleController { * @return */ @PostMapping(value = "list") - public Result> list(@LoginUser TokenDto tokenDTO, @RequestBody PointRuleListFormDTO formDTO) { - formDTO.setCustomerId(tokenDTO.getCustomerId()); + public Result> list( @RequestBody PointRuleListFormDTO formDTO) { + formDTO.setCustomerId("3ef7e4bb195eb9e622d68b52509aa940"); ValidatorUtils.validateEntity(formDTO); return new Result>().ok(pointRuleService.list(formDTO)); } diff --git a/epmet-module/epmet-point/epmet-point-server/src/main/resources/mapper/PointRuleDao.xml b/epmet-module/epmet-point/epmet-point-server/src/main/resources/mapper/PointRuleDao.xml index 481ab2dc18..f63d30b619 100644 --- a/epmet-module/epmet-point/epmet-point-server/src/main/resources/mapper/PointRuleDao.xml +++ b/epmet-module/epmet-point/epmet-point-server/src/main/resources/mapper/PointRuleDao.xml @@ -26,7 +26,7 @@ SELECT DISTINCT FUNCTION_ID FROM point_rule WHERE CUSTOMER_ID = #{customerId,jdbcType=VARCHAR} UPDATE point_rule