处理同一个设备多个用户登录的情况

2021-03-11 11:11:19 +08:00
parent 2cbbf0a516
commit 19bd5e83e5
2 changed files with 30 additions and 1 deletions
@@ -1555,6 +1555,35 @@ public class DatabaseStore {
        }
    }

+    void clearMultiUser(String uid, String clientId) {
+        long start = System.currentTimeMillis();
+        LOG.info("clearMultiUser {}, {}", uid, clientId);
+        Connection connection = null;
+        PreparedStatement statement = null;
+        try {
+            connection = DBUtil.getConnection();
+            String sql = "update t_user_session set _deleted = ?, _token = ?, _voip_token = ?, _dt = ?  where _cid = ? and _uid <> ? and _deleted = 0";
+
+            statement = connection.prepareStatement(sql);
+            int index = 1;
+            statement.setInt(index++, 1);
+            statement.setString(index++, "");
+            statement.setString(index++, "");
+            statement.setLong(index++, System.currentTimeMillis());
+
+            statement.setString(index++, clientId);
+            statement.setString(index++, uid);
+            int count = statement.executeUpdate();
+            LOG.info("Update rows {}", count);
+        } catch (SQLException e) {
+            // TODO Auto-generated catch block
+            e.printStackTrace();
+            Utility.printExecption(LOG, e, RDBS_Exception);
+        } finally {
+            DBUtil.closeDB(connection, statement);
+        }
+    }
+
    MemorySessionStore.Session createSession(String uid, String clientId, ClientSession clientSession, int platform) {
        Connection connection = null;
        PreparedStatement statement = null;
@@ -375,7 +375,7 @@ public class MemorySessionStore implements ISessionsStore {
            session.setPlatform(platform);
            databaseStore.updateSessionPlatform(username, clientID, platform);
        }
-
+        databaseStore.clearMultiUser(username, clientID);

        if (!supportMultiEndpoint && platform > 0) {
            databaseStore.clearMultiEndpoint(username, clientID, platform);