消息中心设置已读

yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/imgmessageuser/ImgMessageUserMapper.java

@@ -14,4 +14,6 @@ public interface ImgMessageUserMapper extends BaseMapper<ImgMessageUser> {
 
 
     int updateMessageState(String sid);
+
+    int updateMessageStateByUserSid(String appletOpenid);
 }

yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/imgmessageuser/ImgMessageUserMapper.xml

@@ -30,4 +30,8 @@
     <update id="updateMessageState">
         update img_message_user set state = 1 where messageSid = #{sid}
     </update>
+
+    <update id="updateMessageStateByUserSid">
+        update img_message_user set state = 1 where openId = #{appletOpenid}
+    </update>
 </mapper>

yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/messagepushlog/MessagePushLogMapper.xml

@@ -67,11 +67,6 @@
     </update>
 
     <update id="updateMessageStateByUserSid">
-        update (select ru.* from risk_message_user ru where openId = #{appletOpenid}
-        union all
-        select mo.* from message_openid mo where openId = #{appletOpenid}
-        union all
-        select iu.* from img_message_user iu where iu.openId = #{appletOpenid}
-        )a set state = 1
+        update message_openid set state = 1 where openId = #{appletOpenid}
     </update>
 </mapper>

yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/messagepushlog/MessagePushLogService.java

@@ -273,6 +273,8 @@ public class MessagePushLogService extends MybatisBaseService<MessagePushLogMapp
         ResultBean rb = ResultBean.fireFail();
         SysUser sysUser = systemMapper.getAppletOpenidByUsersid(userSid);
         baseMapper.updateMessageStateByUserSid(sysUser.getAppletOpenid());
+        imgMessageUserMapper.updateMessageStateByUserSid(sysUser.getAppletOpenid());
+        riskMessageUserMapper.updateMessageStateByUserSid(sysUser.getAppletOpenid());
         return rb.success();
     }
 }

yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/riskmessageuser/RiskMessageUserMapper.java

@@ -15,4 +15,6 @@ public interface RiskMessageUserMapper extends BaseMapper<RiskMessageUser> {
 
 
     int updateMessageState(String sid);
+
+    int updateMessageStateByUserSid(String appletOpenid);
 }

yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/riskmessageuser/RiskMessageUserMapper.xml

@@ -30,4 +30,8 @@
     <update id="updateMessageState">
         update risk_message_user set state = 1 where messageSid = #{sid}
     </update>
+
+    <update id="updateMessageStateByUserSid">
+        update risk_message_user set state = 1 where openId = #{appletOpenid}
+    </update>
 </mapper>