1

gx_api/GxPress/Repository/GxPress.Repository.Implement/UserRepository.cs

@@ -840,17 +840,20 @@ namespace GxPress.Repository.Implement
         public async Task<UserCountResult> GetUserCountAsync(int userId)
         {
             var result = new UserCountResult();
-            string sql = $"select count(1) from tede_middle where FolderType={AllTypeConst.Inbox.GetHashCode()} and UserId={userId} and MiddleId in (select SourceId from tede_addressee where UserId={userId} and IsRead=0 and IsDelete=0 and SourceType={AllTypeConst.Notice.GetHashCode()})";
+            var noticeConstValue = AllTypeConst.Notice.GetHashCode();
+            var missiveConstValue = AllTypeConst.Missive.GetHashCode();
+            var anonymityConstValue = AllTypeConst.Anonymity.GetHashCode();
+            string sql = $"select count(1) from tede_middle where FolderType={AllTypeConst.Inbox.GetHashCode()} and UserId=6 and IsDelete=0 and MiddleId in (select SourceId from tede_addressee where UserId={userId} and IsRead=0 and IsDelete=0 and SourceType in({noticeConstValue},{missiveConstValue},{anonymityConstValue}))";
             var databaseType = StringUtils.ToEnum<DatabaseType>(_databaseTypeStr, DatabaseType.MySql);
             var database = new Database(databaseType, _connectionString);
             var connection = database.GetConnection();
             var noticeCount = await connection.ExecuteScalarAsync<int>(sql);
-            sql = $"select count(1) from tede_middle where FolderType={AllTypeConst.Inbox.GetHashCode()} and UserId={userId} and MiddleId in (select SourceId from tede_addressee where UserId={userId} and SourceType={AllTypeConst.Missive.GetHashCode()} and IsDelete=0 and IsRead=0)";
-            var missiveCount = await connection.ExecuteScalarAsync<int>(sql);
-            //sql = $"SELECT count(1) FROM tede_admin_verify where AdminId={userId} and DisposeType=0";
-           // noticeCount += await connection.ExecuteScalarAsync<int>(sql);
+            //     sql = $"select count(1) from tede_middle where FolderType={AllTypeConst.Inbox.GetHashCode()} and UserId={userId} and MiddleId in (select SourceId from tede_addressee where UserId={userId} and SourceType={AllTypeConst.Missive.GetHashCode()} and IsDelete=0 and IsRead=0)";
+            //     var missiveCount = await connection.ExecuteScalarAsync<int>(sql);
+            //     //sql = $"SELECT count(1) FROM tede_admin_verify where AdminId={userId} and DisposeType=0";
+            //    // noticeCount += await connection.ExecuteScalarAsync<int>(sql);
+            //     result.noticeCount = noticeCount;
             result.noticeCount = noticeCount;
-            result.missiveCount = missiveCount;
             return result;
         }
         /// <summary>