ExportExcel

Tiobon.Core.Api/Controllers/Base/BaseController.cs

@@ -211,9 +211,9 @@ public class BaseController<IServiceBase, TEntity, TEntityDto, TInsertDto, TEdit
     /// <param name="body"></param>
     /// <returns></returns>
     [HttpPost, Route("ExportExcel")]
-    public async Task<ServiceResult<long>> ExportExcel([FromBody] QueryBody body)
+    public async Task<ServiceResult<string>> ExportExcel([FromBody] QueryExport body)
     {
-        var data = (await InvokeServiceAsync("ExportExcel", [body])) as ServiceResult<long>;
+        var data = (await InvokeServiceAsync("ExportExcel", [body])) as ServiceResult<string>;
         return data;
     }
     #endregion

Tiobon.Core.Api/Tiobon.Core.xml

@@ -141,7 +141,7 @@
             <param name="Ids">主键IDs</param>
             <returns></returns>
         </member>
-        <member name="M:Tiobon.Core.Controllers.BaseController`5.ExportExcel(Tiobon.Core.Common.QueryBody)">
+        <member name="M:Tiobon.Core.Controllers.BaseController`5.ExportExcel(Tiobon.Core.Common.QueryExport)">
             <summary>
             Excel导出
             </summary>

Tiobon.Core.IServices/BASE/IBaseServices.cs

@@ -151,7 +151,7 @@ namespace Tiobon.Core.IServices.BASE
         Task<PageModel<TEntity>> QueryPage(Expression<Func<TEntity, bool>> whereExpression, int pageIndex = 1, int pageSize = 20, string orderByFields = null);
         Task<ServicePageResult<TEntityDto>> QueryFilterPage([FromBody] QueryBody body);
         Task<ServicePageResult<TEntityDto>> QueryFilterPage(QueryBody filter, string condition);
-        Task<ServiceResult<long>> ExportExcel([FromBody] QueryBody body);
+        Task<ServiceResult<string>> ExportExcel([FromBody] QueryExport body);
 
         Task<ServiceResult<ExcelData>> ImportExcel(IFormFile file);
 

Tiobon.Core.Services/BASE/BaseServices.cs

@@ -5,6 +5,8 @@ using AgileObjects.AgileMapper;
 using Microsoft.AspNetCore.Http;
 using Newtonsoft.Json;
 using Newtonsoft.Json.Linq;
+using OfficeOpenXml.Style;
+using OfficeOpenXml;
 using SqlSugar;
 using Tiobon.Core.Common;
 using Tiobon.Core.Common.Caches;
@@ -19,6 +21,12 @@ using Tiobon.Core.IRepository.Base;
 using Tiobon.Core.IServices.BASE;
 using Tiobon.Core.Model;
 using Tiobon.Core.Model.Models;
+using SixLabors.ImageSharp;
+using System.Reflection;
+using Microsoft.EntityFrameworkCore.Metadata.Internal;
+using System.Collections.Generic;
+using System.Collections;
+using Amazon.Runtime.Internal.Transform;
 
 namespace Tiobon.Core.Services.BASE;
 
@@ -788,34 +796,153 @@ public class BaseServices<TEntity, TEntityDto, TInsertDto, TEditDto> : IBaseServ
         return new ServicePageResult<TEntityDto>(filter.pageNum, total, filter.pageSize, entitys);
 
     }
-    public async Task<ServiceResult<long>> ExportExcel(QueryBody body)
+    public async Task<ServiceResult<string>> ExportExcel(QueryExport body)
     {
-        //sql = @$"SELECT field,
+        QueryBody filter = new QueryBody();
-        //               [dbo].[FLangKeyToValue] (mkey, {body.langId}, label)
+        filter.pageNum = 1;
-        //                  label,
+        filter.pageSize = 1000000;
-        //               required,
+        filter.langId = body.langId;
-        //               editable,
+        var data = await QueryFilterPage(filter);
-        //               rowNum,
-        //               colNum,
-        //               elementType,
-        //               dbo.FS_GetdataSourceBySet
-        //               (dataSource, APIDataSourceType, Ghrs_PageSettingEdit.APIDataSourceID)
-        //                  dataSource,
-        //               defaultHidden,
-        //               isPrimaryKey,
-        //               isSingleColumn
-        //        FROM Ghrs_PageSettingEdit
-        //        WHERE     IsEnable = 1
-        //              AND pageNo = '{body.menuName}'
-        //              AND elementType NOT IN ('FnKey', 'PageGroup');";
-        //dt = await Db.Ado.GetDataTableAsync(sql);
-
-        var data = await BaseDal.QueryFilterPage(body);
-        var fileId = await ReportHelper.SendFile(data.result.DT_TableDataT1.AsQueryable(), $"测试测试", null, null, null, null);
-        return ServiceResult<long>.OprateSuccess("导出成功", fileId);
 
+
+        string sql = $@"SELECT *
+                            FROM Ghrs_PageSettingQuery
+                            WHERE     IsEnable = 1
+                                  AND PageNo = '{body.menuName}'
+                                  AND defaultHidden = 'false'
+                            ORDER BY SortNo ASC";
+
+        var columns = await Db.Ado.SqlQueryAsync<QueryExportColumn>(sql); 
+
+        var fieldDescs = new Dictionary<string, string>();
+        if (body.exportSet.ExFields.Any())
+            body.exportSet.ExFields.ForEach(x =>
+            {
+                if (columns.Any(o => o.field == x))
+                    fieldDescs.Add(x, columns.FirstOrDefault(o => o.field == x)?.label);
+
+
+            });
+        else
+            fieldDescs = columns.ToDictionary(item => item.field, item => item.label);
+        var dt = ToDataTable(data.result.DT_TableDataT1, fieldDescs, null);
+        // 获取所有列名
+        var dtColumns = dt.Columns;
+
+        var id = SnowFlakeSingle.instance.getID();
+        var physicsPath = $"{Environment.CurrentDirectory}{Path.DirectorySeparatorChar}wwwroot";
+        var path = $"{$"{Path.DirectorySeparatorChar}files{Path.DirectorySeparatorChar}export{Path.DirectorySeparatorChar}{id}{Path.DirectorySeparatorChar}"}";
+        if (!Directory.Exists(physicsPath + path))
+            Directory.CreateDirectory(physicsPath + path);
+
+        path = path + body.exportSet.TitleName + ".xlsx";
+        NPOIHelper.ExportExcel(dt, null, "sheet1", physicsPath + path);
+        return ServiceResult<string>.OprateSuccess("导出成功", path);
     }
+    /// <summary>
+    /// 列名按照前端显示顺序导出
+    /// </summary>
+    /// <param name="columns"></param>
+    /// <param name="ExportFields"></param>
+    /// <returns></returns>
+    public static (List<string>, List<string>) Sort(Dictionary<string, string> columns, List<string> ExportFields)
+    {
+        List<string> fields = new List<string>();
+        List<string> colunms = new List<string>();
+        if (ExportFields == null || ExportFields.Count == 0)
+        {
+            return (columns.Keys.ToList(), columns.Values.ToList());
+        }
 
+        foreach (var field in ExportFields)
+        {
+            foreach (var item in columns)
+            {
+                if (item.Key == field)
+                {
+                    fields.Add(item.Key);
+                    colunms.Add(item.Value);
+                }
+            }
+        }
+
+        return (fields, colunms);
+    }
+    public static DataTable ToDataTable(List<TEntityDto> list, Dictionary<string, string> fieldDescs = null, params string[] propertyName)
+    {
+        var (fields, colunms) = Sort(fieldDescs, null);
+
+        List<string> propertyNameList = new List<string>();
+        if (propertyName != null)
+        {
+            propertyNameList.AddRange(propertyName);
+        }
+        DataTable result = new DataTable();
+        if (list.Count > 0)
+        {
+            PropertyInfo[] propertys = list[0].GetType().GetProperties();
+            for (int i = 0; i < fields.Count; i++)
+            {
+                foreach (PropertyInfo pi in propertys)
+                {
+                    if (propertyNameList.Count == 0)
+                    {
+                        //if (DBNull.Value.Equals(pi.PropertyType))
+                        //{
+                        //   // pi.PropertyType = DateTime;
+                        //}
+                        Type colType = pi.PropertyType;
+                        if (colType.IsGenericType && colType.GetGenericTypeDefinition() == typeof(Nullable<>))
+                        {
+                            colType = colType.GetGenericArguments()[0];
+                        }
+                        if (fields[i] == pi.Name)
+                        {
+                            result.Columns.Add(colunms[i], colType);
+                        }
+                        //result.Columns.Add(pi.Name, pi.PropertyType);
+                    }
+                    else
+                    {
+                        if (propertyNameList.Contains(pi.Name))
+                        {
+                            if (fields[i] == pi.Name)
+                                result.Columns.Add(fields[i], pi.PropertyType);
+                        }
+                    }
+                }
+            }
+            for (int i = 0; i < list.Count; i++)
+            {
+                ArrayList tempList = new ArrayList();
+                for (int j = 0; j < fields.Count; j++)
+                {
+                    foreach (PropertyInfo pi in propertys)
+                    {
+                        if (fields[j] == pi.Name)
+                        {
+                            if (propertyNameList.Count == 0)
+                            {
+                                object obj = pi.GetValue(list[i], null);
+                                tempList.Add(obj);
+                            }
+                            else
+                            {
+                                if (propertyNameList.Contains(pi.Name))
+                                {
+                                    object obj = pi.GetValue(list[i], null);
+                                    tempList.Add(obj);
+                                }
+                            }
+                        }
+                    }
+                }
+                object[] array = tempList.ToArray();
+                result.LoadDataRow(array, true);
+            }
+        }
+        return result;
+    }
     public async virtual Task<ServiceResult<ExcelData>> ImportExcel(IFormFile file)
     {
         //long id = SnowFlakeSingle.instance.getID();

Tiobon.Core.Services/CommonServices.cs

@@ -1347,7 +1347,7 @@ public partial class CommonServices : BaseServices<RootEntityTkey<int>>, ICommon
         var fieldDescs = columns.ToDictionary(item => item.label, item => convertColumns.Any(x => x.field == item.field) ? item.field + "1" : item.field);
 
 
-        var fileId = await ReportHelper.SendFile(dt, param.exportSet.TitleName, fieldDescs, null, null, null);
+        //var fileId = await ReportHelper.SendFile(dt, param.exportSet.TitleName, fieldDescs, null, null, null);
 
         return new ServiceResult<QueryExportReturn>() { Success = true, Message = "查询成功", Data = result, };
     }