1

gx_api/GxPress/Api/GxPress.Api/WebControllers/WebTopicController.cs

@@ -118,6 +118,8 @@ namespace GxPress.Api.WebControllers
         public async Task<PagedList<TopicListPageResult>> GetGroupTopicPageAsync(TopicDetailListRequest request)
         {
             request.UserId = _loginContext.AccountId;
+            if (request.UserId <= 0)
+                return await _topicRepository.GetAnonymousGroupTopicPageAsync(request);
             return await _topicService.GetGroupTopicPageAsync(request);
         }
         /// <summary>

gx_api/GxPress/Repository/GxPress.Repository.Implement/TopicRepository.cs

@@ -208,6 +208,137 @@ namespace GxPress.Repository.Implement
             return resultData;
         }
         /// <summary>
+        ///最新 小组话题分页列表 匿名用户登录获取
+        /// </summary>
+        /// <param name="request"></param>
+        /// <returns></returns>
+        public async Task<PagedList<TopicListPageResult>> GetAnonymousGroupTopicPageAsync(TopicDetailListRequest request)
+        {
+            var topicConst = AllTypeConst.Topic.GetHashCode();
+            var result = new PagedList<TopicListPageResult>();
+            var sqlStr = @" AND a.GroupId IN (SELECT 
+                                                Id
+                                            FROM
+                                                tede_group
+                                            WHERE
+                                                IsShow = 1) ";
+
+
+            if (!string.IsNullOrEmpty(request.Key))
+            {
+                sqlStr += $@"AND (a.Title LIKE '%{request.Key}%'
+                          OR a.Content LIKE '%{request.Key}%')";
+            }
+            string sql = $@"SELECT 
+                                a.Id,
+                                a.Title,
+                                a.UserId,
+                                a.ReadCount,
+                                a.CreatedDate,
+                                a.Content,
+                                a.GroupId,
+                                (SELECT 
+                                        COUNT(1)
+                                    FROM
+                                        tede_analyze
+                                    WHERE
+                                        TypeValue ={topicConst} AND SourceId = a.Id
+                                            AND AnalyzeType = 1) AS PraiseCount,
+                                (SELECT 
+                                        COUNT(1)
+                                    FROM
+                                        tede_analyze
+                                    WHERE
+                                        UserId ={request.UserId} AND TypeValue = {topicConst}
+                                            AND SourceId = a.Id
+                                            AND AnalyzeType = 1
+                                    LIMIT 0 , 1) AS IsPraise,
+                                (SELECT 
+                                        COUNT(1)
+                                    FROM
+                                        tede_comment
+                                    WHERE
+                                        ArticleId = a.Id AND pid = 0
+                                            AND TypeValue = 1) AS CommentCount,
+                                (SELECT 
+                                        COUNT(1)
+                                    FROM
+                                        tede_analyze
+                                    WHERE
+                                        UserId ={request.UserId} AND TypeValue ={topicConst}
+                                            AND SourceId = a.Id
+                                            AND AnalyzeType = 4) AS RetransmissionCount,
+                                (SELECT 
+                                        COUNT(1)
+                                    FROM
+                                        tede_analyze
+                                    WHERE
+                                        UserId ={request.UserId} AND TypeValue ={topicConst}
+                                            AND SourceId = a.Id
+                                            AND AnalyzeType = 4
+                                    LIMIT 0 , 1) AS IsRetransmission,
+                                (SELECT 
+                                        COUNT(1)
+                                    FROM
+                                        tede_analyze
+                                    WHERE
+                                        UserId ={request.UserId} AND TypeValue = {topicConst}
+                                            AND SourceId = a.Id
+                                            AND AnalyzeType = 4
+                                    LIMIT 0 , 1) AS IsCollect,
+                                (SELECT 
+                                        COUNT(1)
+                                    FROM
+                                        tede_analyze
+                                    WHERE
+                                        UserId ={request.UserId} AND TypeValue = {topicConst}
+                                            AND SourceId = a.Id
+                                            AND AnalyzeType = 4) AS CollectCount,
+                                b.Name as GroupName,
+                                c.Name as UserName,
+                                c.AvatarUrl,
+                                d.Id as DepartmentId,
+                                d.Name as DepartmentName
+                            FROM
+                                tede_topic a
+                                    INNER JOIN
+                                tede_group b ON a.GroupId = b.Id
+                                    INNER JOIN
+                                tede_user c ON c.Id = a.UserId
+                                  INNER JOIN
+                                tede_department d ON d.Id = c.DepartmentId
+                            WHERE
+                                a.GroupId > 0
+                                    {sqlStr}
+                            ORDER BY a.CreatedDate DESC limit @page,@pageSize";
+            string countSql = $@"SELECT 
+                                count(1)
+                            FROM
+                                tede_topic a
+                                    INNER JOIN
+                                tede_group b ON a.GroupId = b.Id
+                                    INNER JOIN
+                                tede_user c ON c.Id = a.UserId
+                            WHERE
+                                a.GroupId > 0
+                                   {sqlStr}
+                            ORDER BY a.CreatedDate DESC";
+            var databaseType = StringUtils.ToEnum<DatabaseType>(_databaseTypeStr, DatabaseType.MySql);
+            var database = new Database(databaseType, _connectionString);
+            var connection = database.GetConnection();
+            result.Items =
+                 await connection
+                      .QueryAsync<TopicListPageResult>(sql, new { page = (request.Page - 1) * request.PerPage, pageSize = request.PerPage });
+            foreach (var item in result.Items)
+            {
+                item.AvatarUrl = StringUtils.AddDomainMin(item.AvatarUrl);
+            }
+            result.Total = await connection.ExecuteScalarAsync<int>(countSql);
+            return result;
+        }
+
+
+        /// <summary>
         ///最新 小组话题分页列表
         /// </summary>
         /// <param name="request"></param>
@@ -366,6 +497,9 @@ namespace GxPress.Repository.Implement
             result.Total = await connection.ExecuteScalarAsync<int>(countSql);
             return result;
         }
+
+
+
         /// <summary>
         /// 获取共享小组
         /// </summary>

gx_api/GxPress/Repository/GxPress.Repository.Interface/ITopicRepository.cs

@@ -49,7 +49,7 @@ namespace GxPress.Repository.Interface
         /// <returns></returns>
         Task<List<JobTopicResult>> ExecuteTopic();
 
-        Task<PagedList<TopicListPageResult>> GetTopicPage(TopicPageSearchRequest request,string sql, string countSql);
+        Task<PagedList<TopicListPageResult>> GetTopicPage(TopicPageSearchRequest request, string sql, string countSql);
 
         Task<PagedList<TopicListPageResult>> GetTopicByGroupAsync(TopicPageSearchRequest request);
         /// <summary>
@@ -57,6 +57,12 @@ namespace GxPress.Repository.Interface
         /// </summary>
         /// <param name="request"></param>
         /// <returns></returns>
-      Task<PagedList<TopicListPageResult>> GetGroupTopicPageAsync(TopicDetailListRequest request);
+        Task<PagedList<TopicListPageResult>> GetGroupTopicPageAsync(TopicDetailListRequest request);
+        /// <summary>
+        ///最新 小组话题分页列表 匿名用户登录获取
+        /// </summary>
+        /// <param name="request"></param>
+        /// <returns></returns>
+        Task<PagedList<TopicListPageResult>> GetAnonymousGroupTopicPageAsync(TopicDetailListRequest request);
     }
 }