11

gx_api/GxPress/Api/GxPress.Api/AdminControllers/AdminPlatformDataController.cs

@@ -1,6 +1,7 @@
 using System.Collections.Generic;
 using System.Threading.Tasks;
 using GxPress.Result.DataCenter;
+using GxPress.Service.Interface.PlatformData;
 using Microsoft.AspNetCore.Authorization;
 using Microsoft.AspNetCore.Mvc;
 
@@ -14,9 +15,10 @@ namespace GxPress.Api.AdminControllers
     [Authorize]
     public class AdminPlatformDataController : Controller
     {
-        public AdminPlatformDataController()
+        private readonly IPlatformDataService platformDataService;
+        public AdminPlatformDataController(IPlatformDataService platformDataService)
         {
-
+            this.platformDataService = platformDataService;
         }
         /// <summary>
         /// 平台数据
@@ -26,7 +28,7 @@ namespace GxPress.Api.AdminControllers
         public async Task<PlatformDataResult> GetPlatformDataResult()
         {
             var result = new PlatformDataResult();
-            result.PlatformOperationDataResult = new PlatformOperationDataResult();
+            result.PlatformOperationDataResult = await platformDataService.GetPlatformDataAsync();
             result.UserIncreaseResult = new UserIncreaseResult();
             result.UserAreaDistributingResults = new List<UserAreaDistributingResult>();
             result.UserVipProportionResult = new UserVipProportionResult();

gx_api/GxPress/Api/GxPress.Api/Startup.cs

@@ -3,7 +3,9 @@ using GxPress.Api.ServiceExtensions;
 using GxPress.Common.AppOptions;
 using GxPress.Common.Tools;
 using GxPress.Service.Implement;
+using GxPress.Service.Implement.PlatformData;
 using GxPress.Service.Interface;
+using GxPress.Service.Interface.PlatformData;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Hosting;
 using Microsoft.AspNetCore.Http;
@@ -46,7 +48,6 @@ namespace GxPress.Api
             services.AddSingleton<ISchedulerFactory, StdSchedulerFactory>();
             // services.AddSingleton<IUserService, UserService>();
             services.AddSingleton<IApiLogService, ApiLogService>();
-
             services.AddControllers().AddNewtonsoftJson(options =>
             {
                 options.SerializerSettings.ContractResolver = new DefaultContractResolver();

gx_api/GxPress/Service/GxPress.Service.Implement/PlatformData/PlatformDataService.cs

@@ -1,4 +1,10 @@
+using System;
+using System.Threading.Tasks;
+using Dapper;
+using Datory;
+using GxPress.Common.Tools;
 using GxPress.Repository.Interface;
+using GxPress.Result.DataCenter;
 using GxPress.Service.Interface.PlatformData;
 
 namespace GxPress.Service.Implement.PlatformData
@@ -6,15 +12,49 @@ namespace GxPress.Service.Implement.PlatformData
     public class PlatformDataService : IPlatformDataService
     {
         private readonly IUserRepository userRepository;
+
         public PlatformDataService(IUserRepository userRepository)
         {
+
             this.userRepository = userRepository;
         }
-
-        // public async Task<PlatformDataResult> GetPlatformDataAsync()
-        // {
-        //     var result = new PlatformDataResult();
-        //     result.PlatformOperationDataResult = new PlatformOperationDataResult();
-        // }
+        /// <summary>
+        /// 平台运营数据
+        /// </summary>
+        /// <returns></returns>
+        public async Task<PlatformOperationDataResult> GetPlatformDataAsync()
+        {
+            var newUserTime = DateTime.Now.ToString("yyyy-MM-dd");
+            var onlineUserTime = DateTime.Now.AddMinutes(-10).ToString("yyyy-MM-dd HH:mm:ss");
+            var activityUserTime = DateTime.Now.AddMonths(-1).ToString("yyyy-MM-dd HH:mm:ss");
+            var sql = $@"SELECT 
+                            (SELECT 
+                                    COUNT(1)
+                                FROM
+                                    tede_user) AS SumUserCount,
+                            (SELECT 
+                                    COUNT(1)
+                                FROM
+                                    tede_user
+                                WHERE
+                                    CreatedDate > '{newUserTime}') AS NewUserCount,
+                            (SELECT 
+                                    COUNT(1)
+                                FROM
+                                    tede_user
+                                WHERE
+                                    LoginTime > '{onlineUserTime}') AS OnlineUserCount,
+                            (SELECT 
+                                    COUNT(1)
+                                FROM
+                                    tede_user
+                                WHERE
+                                    LoginTime > '{activityUserTime}') AS ActivityUserCount";
+            var connectionString = ConfigHelper.GetValue("Database:ConnectionString");
+            var database = new Database(DatabaseType.MySql, connectionString);
+            var connection = database.GetConnection();
+            var result = await connection.QueryFirstAsync<PlatformOperationDataResult>(sql);
+            return result;
+        }
     }
 }

gx_api/GxPress/Service/GxPress.Service.Interface/PlatformData/IPlatformDataService.cs

@@ -1,7 +1,14 @@
+using System.Threading.Tasks;
+using GxPress.Result.DataCenter;
+
 namespace GxPress.Service.Interface.PlatformData
 {
     public interface IPlatformDataService:IService
     {
-         
+        /// <summary>
+        /// 平台运营数据
+        /// </summary>
+        /// <returns></returns>
+        Task<PlatformOperationDataResult> GetPlatformDataAsync();
     }
 }