diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/controller/BizMessageConsumerController.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/controller/BizMessageConsumerController.java index 191c66a..46029ca 100644 --- a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/controller/BizMessageConsumerController.java +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/controller/BizMessageConsumerController.java @@ -57,7 +57,7 @@ public class BizMessageConsumerController { vo.setMsgId(source.getId()); BeanUtils.copyProperties(source, vo); //已读 - this.service.updateStateById(source.getId()); + this.service.updateState(source.getId()); return vo; }).orElseGet(DescribeSiteMsgDetailVO::new); diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/BizMessageMapper.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/BizMessageMapper.java index 1317051..42dc549 100644 --- a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/BizMessageMapper.java +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/BizMessageMapper.java @@ -12,5 +12,5 @@ public interface BizMessageMapper extends BaseMapper { IPage findMessageVo(@Param("param") IPage page, @Param("userId") String userId); - Boolean updateStateById(@Param("id") String id); + Boolean updateState(@Param("userId") String userId,@Param("messageId") String messageId); } diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/mapper/BizMessageMapper.xml b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/mapper/BizMessageMapper.xml index 2cf3af7..aea8bcc 100644 --- a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/mapper/BizMessageMapper.xml +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/mapper/BizMessageMapper.xml @@ -38,9 +38,10 @@ ORDER BY createtime DESC - + update biz_message_authorize set state = 1 - where id=#{id} + where message_id=#{messageId} + and user_id =#{userId} \ No newline at end of file diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/BizMessageConsumerService.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/BizMessageConsumerService.java index 665fff4..56a61ad 100644 --- a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/BizMessageConsumerService.java +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/BizMessageConsumerService.java @@ -11,5 +11,5 @@ public interface BizMessageConsumerService { BizMessage getDetailById(String id); - Boolean updateStateById(String id); + Boolean updateState(String id); } diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/impl/BizMessageConsumerServiceImpl.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/impl/BizMessageConsumerServiceImpl.java index 4662e14..7cc339c 100644 --- a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/impl/BizMessageConsumerServiceImpl.java +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/impl/BizMessageConsumerServiceImpl.java @@ -74,12 +74,13 @@ public class BizMessageConsumerServiceImpl implements BizMessageConsumerService /** * 消息详情 已读修改 * - * @param id + * @param messageId * @return */ @Override - public Boolean updateStateById(String id){ - return mapper.updateStateById(id); + public Boolean updateState(String messageId){ + String userId = service.getCacheUser().getUserId(); + return mapper.updateState(userId,messageId); } /**