房间-定时任务-修改保存房间在线人数sql

accompany-base/accompany-basic/accompany-basic-service/src/main/java/com/accompany/core/mybatismapper/RoomMapper.java

@@ -38,5 +38,6 @@ public interface RoomMapper extends BaseMapper<Room> {
      */
     List<Room> queryRoomByPermitType(@Param("permitType") Byte permitType);
 
+    int updateOnlineNum(@Param("uid") Long uid, @Param("onlineNum") Integer onlineNum);
 
 }

accompany-base/accompany-basic/accompany-basic-service/src/main/resources/sqlmappers/RoomMapper.xml

@@ -771,4 +771,9 @@
         ORDER BY online_num desc,r.online_num DESC
     </select>
 
+    <update id="updateOnlineNum">
+        update room set online_num = #{onlineNum} where uid = #{uid} and online_num != #{onlineNum}
+    </update>
+
+
 </mapper>

accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/room/RoomService.java

@@ -1104,7 +1104,7 @@ public class RoomService extends BaseService {
     }
 
     public void updateRoomOnlineNumMysql(Long uid, int onlineNum) {
-        int row = roomMapper.update(Wrappers.<Room>lambdaQuery().eq(Room::getUid, uid).ne(Room::getOnlineNum, onlineNum));
+        int row = roomMapper.updateOnlineNum(uid, onlineNum);
         if (!SqlHelper.retBool(row)){
             return;
         }