已阅

src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/controller/BizMessageConsumerController.java

@@ -1,6 +1,7 @@
 package com.chinaunicom.mall.ebtp.extend.bizmessage.controller;
 
 import com.chinaunicom.mall.ebtp.extend.bizmessage.dto.PageDTO;
+import com.chinaunicom.mall.ebtp.extend.bizmessage.entity.BizMessageAuthorize;
 import com.chinaunicom.mall.ebtp.extend.bizmessage.entity.BizMessageVo;
 import com.chinaunicom.mall.ebtp.extend.bizmessage.mybatis.IBizMessagePage;
 import com.chinaunicom.mall.ebtp.extend.bizmessage.service.BizMessageConsumerService;
@@ -58,9 +59,10 @@ public class BizMessageConsumerController {
             DescribeSiteMsgDetailVO vo = new DescribeSiteMsgDetailVO();
             vo.setMsgId(source.getId());
             BeanUtils.copyProperties(source, vo);
-            //已读
+            BizMessageAuthorize authorize = new BizMessageAuthorize();
-            //this.service.updateState(source.getId());
+            authorize.setMessageId(source.getId());
-
+            authorize = this.service.getAuthorize(authorize);
+            vo.setAuthorizestate(authorize.getState());
             return vo;
         }).orElseGet(DescribeSiteMsgDetailVO::new);
     }

src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/BizMessageMapper.java

@@ -3,6 +3,7 @@ package com.chinaunicom.mall.ebtp.extend.bizmessage.dao;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.chinaunicom.mall.ebtp.extend.bizmessage.entity.BizMessage;
+import com.chinaunicom.mall.ebtp.extend.bizmessage.entity.BizMessageAuthorize;
 import com.chinaunicom.mall.ebtp.extend.bizmessage.entity.BizMessageVo;
 import org.apache.ibatis.annotations.Param;
 
@@ -18,4 +19,6 @@ public interface BizMessageMapper extends BaseMapper<BizMessage> {
 
     List<BizMessageVo> findMessageVoList(BizMessageVo vo);
 
+    List<BizMessageAuthorize> findAuthorizeList(BizMessageAuthorize vo);
+
 }

src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/mapper/BizMessageMapper.xml

@@ -63,4 +63,22 @@
         ORDER BY createtime DESC
     </select>
 
+    <select id="findAuthorizeList" resultType="com.chinaunicom.mall.ebtp.extend.bizmessage.entity.BizMessageAuthorize" parameterType="com.chinaunicom.mall.ebtp.extend.bizmessage.entity.BizMessageAuthorize">
+
+        SELECT
+        *
+        FROM
+        biz_message_authorize
+        WHERE 1 = 1
+        <if test="userId!=null and userId!=''">
+            and user_id = #{userId}
+        </if>
+        <if test="messageId!=null and messageId!=''">
+            and message_id = #{messageId}
+        </if>
+        <if test="state!=null and state!=''">
+            and state = #{state}
+        </if>
+        ORDER BY createtime DESC
+    </select>
 </mapper>

src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/BizMessageConsumerService.java

@@ -2,6 +2,7 @@ package com.chinaunicom.mall.ebtp.extend.bizmessage.service;
 
 import com.chinaunicom.mall.ebtp.extend.bizmessage.dto.PageDTO;
 import com.chinaunicom.mall.ebtp.extend.bizmessage.entity.BizMessage;
+import com.chinaunicom.mall.ebtp.extend.bizmessage.entity.BizMessageAuthorize;
 import com.chinaunicom.mall.ebtp.extend.bizmessage.entity.BizMessageVo;
 import com.chinaunicom.mall.ebtp.extend.bizmessage.mybatis.IBizMessagePage;
 import com.chinaunicom.mall.ebtp.extend.bizmessage.vo.DescribeSiteMsgVO;
@@ -17,4 +18,11 @@ public interface BizMessageConsumerService {
     Boolean updateState(String id);
 
     List<BizMessageVo> selectMsgListByType(BizMessageVo vo);
+
+    /**
+     * 查询读取状态
+     * @param authorize
+     * @return
+     */
+    BizMessageAuthorize getAuthorize(BizMessageAuthorize authorize);
 }

src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/impl/BizMessageConsumerServiceImpl.java

@@ -6,6 +6,7 @@ import com.chinaunicom.mall.ebtp.common.base.service.IBaseCacheUserService;
 import com.chinaunicom.mall.ebtp.extend.bizmessage.dao.BizMessageMapper;
 import com.chinaunicom.mall.ebtp.extend.bizmessage.dto.PageDTO;
 import com.chinaunicom.mall.ebtp.extend.bizmessage.entity.BizMessage;
+import com.chinaunicom.mall.ebtp.extend.bizmessage.entity.BizMessageAuthorize;
 import com.chinaunicom.mall.ebtp.extend.bizmessage.entity.BizMessageVo;
 import com.chinaunicom.mall.ebtp.extend.bizmessage.mybatis.BizMessagePage;
 import com.chinaunicom.mall.ebtp.extend.bizmessage.mybatis.IBizMessagePage;
@@ -69,7 +70,8 @@ public class BizMessageConsumerServiceImpl implements BizMessageConsumerService
      */
     @Override
     public BizMessage getDetailById(String id) {
-        return mapper.selectById(id);
+        BizMessage message = mapper.selectById(id);
+        return message;
     }
 
     /**
@@ -125,4 +127,18 @@ public class BizMessageConsumerServiceImpl implements BizMessageConsumerService
 
         return rList;
     }
+
+
+    /**
+     * 查询读取状态
+     * @param authorize
+     * @return
+     */
+    @Override
+    public  BizMessageAuthorize getAuthorize(BizMessageAuthorize authorize){
+
+        authorize.setUserId(service.getCacheUser().getUserId());
+        List<BizMessageAuthorize> authorizes = this.mapper.findAuthorizeList(authorize);
+        return authorizes!=null?authorizes.get(0):new BizMessageAuthorize();
+    }
 }

src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/vo/DescribeSiteMsgDetailVO.java

@@ -26,4 +26,5 @@ public class DescribeSiteMsgDetailVO {
     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
     private Timestamp createtime;
 
+    private String authorizestate;
 }