增加功能:离线导出

Bailun.DC.Models/Component/DTO/ResultDTO.cs

@@ -29,7 +29,7 @@ namespace Bailun.DC.Models.Component.DTO
         public object Data { get; set; }
     }
 
-    public class ResultDto<T> : ResultDTO
+    public class ResultDTO<T> : ResultDTO
     {
         /// <summary>
         /// 结果集

Bailun.DC.Models/Component/DTO/TableDTO.cs

@@ -47,6 +47,11 @@ namespace Bailun.DC.Models.Component.DTO
         public bool? IsShowExportButton { get; set; }
 
         /// <summary>
+        /// 是否显示离线导出按钮:(默认否)
+        /// </summary>
+        public bool? IsShowOfflineExportButton { get; set; }
+
+        /// <summary>
         /// 是否显示导入按钮:(默认否)
         /// </summary>
         public bool? IsShowImportButton { get; set; }

Bailun.DC.Models/Component/Entity/dc_component_offline_download.cs

+using Bailun.DC.Models.Component.Enum;
+using Dapper;
+using System;
+
+namespace Bailun.DC.Models.Component.Entity
+{
+    /// <summary>
+    /// 离线下载组件
+    /// </summary>
+    public class dc_component_offline_download
+    {
+        /// <summary>
+        /// ID
+        /// </summary>
+        public int id { get; set; }
+
+        /// <summary>
+        /// 编码
+        /// </summary>
+        public string code { get; set; }
+
+        /// <summary>
+        /// 名称
+        /// </summary>
+        public string name { get; set; }
+
+        /// <summary>
+        /// 后缀
+        /// </summary>
+        public string suffix { get; set; } 
+
+        /// <summary>
+        /// 状态：0：未执行, 1：执行中, 2：完成, 3：失败
+        /// </summary>
+        public OfflineDownloadStatusEnum? status { get; set; }
+
+        /// <summary>
+        /// 消息
+        /// </summary>
+        public string message { get; set; }
+
+        /// <summary>
+        /// 下载地址
+        /// </summary>
+        public string url { get; set; }
+
+        /// <summary>
+        /// 是否删除: 1:是; 0:否
+        /// </summary>
+        [IgnoreUpdate]
+        public bool is_delete { get; set; }
+
+        /// <summary>
+        /// 创建人ID
+        /// </summary>
+        public int? gmt_create_userid { get; set; }
+
+        /// <summary>
+        /// 创建人名称
+        /// </summary>
+        public string gmt_create_username { get; set; }
+
+        /// <summary>
+        /// 创建时间
+        /// </summary>
+        [IgnoreUpdate]
+        public DateTime gmt_create_time { get; set; }
+
+        /// <summary>
+        /// 更新时间
+        /// </summary>
+        public DateTime gmt_modified_time { get; set; }
+    }
+}

Bailun.DC.Models/Component/Entity/dc_component_table.cs

@@ -65,6 +65,11 @@ namespace Bailun.DC.Models.Component.Entity
         public bool is_show_export_button { get; set; }
 
         /// <summary>
+        /// 是否显示离线导出按钮:(默认否)
+        /// </summary>
+        public bool is_show_offline_export_button { get; set; }
+
+        /// <summary>
         /// 是否显示导入按钮:(默认否)
         /// </summary>
         public bool is_show_import_button { get; set; }

Bailun.DC.Models/Component/Enum/OfflineDownloadEnum.cs

+using System.ComponentModel;
+
+namespace Bailun.DC.Models.Component.Enum
+{
+    /// <summary>
+    /// 状态：0：未执行, 1：执行中, 2：完成, 3：失败
+    /// </summary>
+    public enum OfflineDownloadStatusEnum
+    {
+        /// <summary>
+        /// 未执行
+        /// </summary>
+        [Description("未执行")]
+        UnExecuted = 0,
+        /// <summary>
+        /// 执行中
+        /// </summary>
+        [Description("执行中")]
+        Executing = 1,
+        /// <summary>
+        /// 完成
+        /// </summary>
+        [Description("完成")]
+        Complete = 2,
+        /// <summary>
+        /// 失败
+        /// </summary>
+        [Description("失败")]
+        Fail = 3,
+    }
+}

Bailun.DC.Services/Component/OfflineDownloadService.cs

+using Bailun.DC.Common;
+using Bailun.DC.Models.Component.DTO;
+using Bailun.DC.Models.Component.Entity;
+using Bailun.DC.Models.Component.Enum;
+using Dapper;
+using MySql.Data.MySqlClient;
+using Newtonsoft.Json.Linq;
+using Qiniu.Http;
+using System;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace Bailun.DC.Services.Component
+{
+    /// <summary>
+    /// 查询组件
+    /// </summary>
+    public class OfflineDownloadService : BaseService
+    {
+
+        public ResultDTO Export(QueryFilterDTO queryFilter, string cookies)
+        {
+            ResultDTO<int?> result = default(ResultDTO<int?>);
+            TableService service = new TableService();
+            TableDTO entity = service.Get(queryFilter.Code);
+            if (entity != null)
+            {
+                string name = $"{string.Join(string.Empty, entity.ListCrumb)}_{DateTime.Now.ToString("yyyyMMddhhmm")}";
+                result = this.Save(queryFilter, name, cookies);
+                if (result?.Result == true)
+                {
+                    Task task = Task.Factory.StartNew(() =>
+                    {
+                        var exportResult = service.Export(queryFilter);
+                        if (exportResult.Item2 != null && exportResult.Item2?.Length > 0)
+                        {
+                            string suffix = exportResult.Item1.Substring(exportResult.Item1.IndexOf("."));
+                            var accesskey = NewConfigHelper.GetByName("QiNiu:AccessKey");
+                            var secretkey = NewConfigHelper.GetByName("QiNiu:SecretKey");
+                            var qiuniu = new QiNiuHelper(accesskey, secretkey);
+                            HttpResult httpResult = qiuniu.UploadStream(exportResult.Item2, $"{name}{suffix}");
+                            if (httpResult.Code == 200)
+                            {
+                                this.Save(result.Data.Value, suffix, $"http://dcfile.blsct.com/{name}{suffix}", OfflineDownloadStatusEnum.Complete, null);
+                            }
+                            else
+                            {
+                                this.Save(result.Data.Value, suffix, $"http://dcfile.blsct.com/{name}{suffix}", OfflineDownloadStatusEnum.Fail, $"{httpResult.RefText}_{httpResult.Text}");
+                            }
+                        }
+                        else
+                        {
+                            this.Save(result.Data.Value, null, null, OfflineDownloadStatusEnum.Fail, "无数据导出");
+                        }
+                    });
+                }
+            }
+            else
+            {
+                result = new ResultDTO<int?>() { Message = "参数异常" };
+            }
+
+            return result;
+        }
+
+        /// <summary>
+        /// 保存报表组件
+        /// </summary>
+        /// <param name="dto">报表组件对象</param>
+        /// <returns>保存结果</returns>
+        public ResultDTO<int?> Save(QueryFilterDTO queryFilter, string name, string cookies)
+        {
+            ResultDTO<int?> result = this.BeforeSave(queryFilter, cookies);
+
+            if (result.Result)
+            {
+                dc_component_offline_download entity = new dc_component_offline_download()
+                {
+                    code = queryFilter.Code,
+                    name = name,
+                    gmt_create_time = DateTime.Now,
+                    gmt_modified_time = DateTime.Now,
+                    status = OfflineDownloadStatusEnum.Executing
+                };
+                var user = HttpHelper.NetHelper.Request("http://sso.bailuntec.com/GetUserResource", new string[] { "Authorization" }, new string[] { cookies });
+                var json = JObject.Parse(user);
+                if (json["statusCode"].ToString() == "200" && json["result"]["success"].ToString().ToLower() == "true")
+                {
+                    entity.gmt_create_userid = int.TryParse(json["result"]["OaUserId"].ToString(), out int userid) ? userid : 0;
+                    entity.gmt_create_username = json["result"]["Account"].ToString() ?? "system";
+                }
+                else
+                {
+                    entity.gmt_create_userid = 0;
+                    entity.gmt_create_username = "system";
+                }
+                using (var db = DB)
+                {
+                    //开启事务
+                    MySqlTransaction transaction = db.BeginTransaction();
+                    try
+                    {
+                        int? id = db.Insert(entity);
+                        if (id == 0)
+                        {
+                            result.Result = false;
+                            result.Message = "保存失败";
+                        }
+                        else
+                        {
+                            //提交事务
+                            transaction.Commit();
+                            result.Data = id;
+                            result.Message = "保存成功";
+                        }
+                    }
+                    catch (Exception ex)
+                    {
+                        //回滚事务
+                        transaction.Rollback();
+                        result.Message = ex.Message;
+                        result.Result = false;
+                    }
+                }
+            }
+
+            return result;
+        }
+
+        /// <summary>
+        /// 保存报表组件
+        /// </summary>
+        /// <param name="id">ID</param>
+        /// <param name="is_delete">是否删除</param>
+        /// <returns>保存结果</returns>
+        public ResultDTO Save(int[] id, bool is_delete)
+        {
+            ResultDTO result = this.BeforeSave(id);
+
+            if (result.Result)
+            {
+                string sql = "update dc_component_offline_download set is_delete = @is_delete, gmt_modified_time = @gmt_modified_time where id in @id";
+                using (var db = DB)
+                {
+                    //开启事务
+                    MySqlTransaction transaction = db.BeginTransaction();
+                    try
+                    {
+                        int resultCount = db.Execute(sql, new { id = id, is_delete = is_delete, gmt_modified_time = DateTime.Now });
+                        if (resultCount == 0)
+                        {
+                            throw new Exception("保存失败");
+                        }
+                        else
+                        {
+                            //提交事务
+                            transaction.Commit();
+                            result.Message = "保存成功";
+                        }
+                    }
+                    catch (Exception ex)
+                    {
+                        //回滚事务
+                        transaction.Rollback();
+                        result.Message = ex.Message;
+                        result.Result = false;
+                    }
+                }
+            }
+
+            return result;
+        }
+
+        /// <summary>
+        /// 保存
+        /// </summary>
+        /// <param name="id">ID</param>
+        /// <param name="suffix">后缀</param>
+        /// <param name="url">地址</param>
+        /// <param name="status">状态</param>
+        /// <param name="message">信息</param>
+        /// <returns>保存结果</returns>
+        public ResultDTO Save(int id, string suffix, string url, OfflineDownloadStatusEnum status, string message)
+        {
+            ResultDTO result = this.BeforeSave(new int[] { id });
+
+            if (result.Result)
+            {
+                string sql = "update dc_component_offline_download set suffix = @suffix, url = @url, status = @status,message = @message, gmt_modified_time = @gmt_modified_time where id = @id";
+                using (var db = DB)
+                {
+                    //开启事务
+                    MySqlTransaction transaction = db.BeginTransaction();
+                    try
+                    {
+                        int resultCount = db.Execute(sql, new { id = id, suffix = suffix, url = url, status = status, message = message, gmt_modified_time = DateTime.Now });
+                        if (resultCount == 0)
+                        {
+                            result.Message = "保存失败";
+                            result.Result = false;
+                        }
+                        else
+                        {
+                            //提交事务
+                            transaction.Commit();
+                            result.Message = "保存成功";
+                        }
+                    }
+                    catch (Exception ex)
+                    {
+                        //回滚事务
+                        transaction.Rollback();
+                        result.Message = ex.Message;
+                        result.Result = false;
+                    }
+                }
+            }
+
+            return result;
+        }
+
+        /// <summary>
+        /// 保存报表组件
+        /// </summary>
+        /// <param name="dto">报表组件对象</param>
+        /// <returns>保存结果</returns>
+        private ResultDTO<int?> BeforeSave(QueryFilterDTO queryFilter, string cookies)
+        {
+            ResultDTO<int?> result = new ResultDTO<int?>();
+
+            if (queryFilter == null)
+            {
+                result.Message = "参数有误";
+            }
+            else if (string.IsNullOrWhiteSpace(queryFilter.Code))
+            {
+                result.Message = "编码不能为空";
+            }
+            else
+            {
+                result.Result = true;
+            }
+
+            return result;
+        }
+
+        /// <summary>
+        /// 保存报表组件
+        /// </summary>
+        /// <param name="id">ID</param>
+        /// <returns>保存结果</returns>
+        private ResultDTO BeforeSave(int[] id)
+        {
+            ResultDTO result = new ResultDTO();
+            if (id == null || id.Length == 0 || id.Contains(0))
+            {
+                result.Message = "ID不能为空";
+            }
+            else
+            {
+                result.Result = true;
+            }
+            return result;
+        }
+    }
+}

Bailun.DC.Services/Component/TableService.cs

@@ -51,6 +51,7 @@ namespace Bailun.DC.Services.Component
                         IsShowSearchButton = entity.is_show_search_button,
                         IsShowResetButton = entity.is_show_reset_button,
                         IsShowExportButton = entity.is_show_export_button,
+                        IsShowOfflineExportButton = entity.is_show_offline_export_button,
                         IsShowImportButton = entity.is_show_import_button,
                         IsShowSequenceColumn = entity.is_show_sequence_column,
                         OperateControlsPosition = entity.operate_controls_position,
@@ -472,14 +473,17 @@ namespace Bailun.DC.Services.Component
             return pageList;
         }
 
-        public (string, byte[]) Export(QueryFilterDTO queryFilter)
+        public (string, byte[]) Export(QueryFilterDTO queryFilter, TableDTO entity = null)
         {
             byte[] b = default(byte[]);
             string name = default(string);
             int dataCount = default(int);
             if (queryFilter != null)
             {
-                TableDTO entity = this.Get(queryFilter.Code);
+                if (entity == null)
+                {
+                    entity = this.Get(queryFilter.Code);
+                }
                 if (entity != null)
                 {
                     name = string.Join(string.Empty, entity.ListCrumb);
@@ -550,6 +554,7 @@ namespace Bailun.DC.Services.Component
                     is_show_search_button = dto.IsShowSearchButton ?? false,
                     is_show_reset_button = dto.IsShowResetButton ?? false,
                     is_show_export_button = dto.IsShowExportButton ?? false,
+                    is_show_offline_export_button = dto.IsShowOfflineExportButton ?? false,
                     is_show_import_button = dto.IsShowImportButton ?? false,
                     is_show_sequence_column = dto.IsShowSequenceColumn ?? false,
                     is_show_column_search = dto.IsShowColumnSearch ?? false,

Bailun.DC.Web/Areas/Component/Controllers/OfflineDownloadController.cs

+using Bailun.DC.Models.Component.DTO;
+using Bailun.DC.Services.Component;
+using Microsoft.AspNetCore.Mvc;
+using Newtonsoft.Json;
+using System;
+using System.IO;
+using System.Text;
+
+namespace Bailun.DC.Web.Areas.Component.Controllers
+{
+    [Area("Component")]
+    public class OfflineDownloadController : Base.BaseController
+    {
+        [HttpPost]
+        public JsonResult Export(QueryFilterDTO queryFilter)
+        {
+            ResultDTO result = default(ResultDTO);
+            try
+            {
+                if (Request.ContentType.Contains("application/json"))
+                {
+                    using (Stream stream = Request.Body)
+                    {
+                        byte[] buffer = new byte[Request.ContentLength.Value];
+                        stream.Read(buffer, 0, buffer.Length);
+                        string content = Encoding.UTF8.GetString(buffer);
+                        queryFilter = JsonConvert.DeserializeObject<QueryFilterDTO>(content);
+                    }
+                }
+                result = new OfflineDownloadService().Export(queryFilter, Request.Cookies["BailunToken"]);
+            }
+            catch (Exception ex)
+            {
+                result = new ResultDTO() { Message = ex.Message };
+            }
+
+            return Json(result);
+        }
+
+        [HttpPost]
+        public JsonResult Delete(int[] id)
+        {
+            ResultDTO result = default(ResultDTO);
+            try
+            {
+                result = new OfflineDownloadService().Save(id, true);
+            }
+            catch (Exception ex)
+            {
+                result = new ResultDTO() { Message = ex.Message };
+            }
+
+            return Json(result);
+        }
+    }
+}

Bailun.DC.Web/Areas/Component/Views/Form/Filter.cshtml

@@ -12,6 +12,7 @@
             <el-form-control v-if="filter.isShowSearchButton" v-bind:item="{type: 'button',name:'查询',buttonType:'primary',icon:'el-icon-search'}" v-on:click="onSearch"></el-form-control>
             <el-form-control v-if="filter.isShowResetButton" v-bind:item="{type: 'button',name:'重置',icon:'el-icon-refresh-right'}" v-on:click="onReset"></el-form-control>
             <el-form-control v-if="filter.isShowExportButton" v-bind:item="{type: 'button',name:'导出',buttonType:'success',icon:'el-icon-download'}" v-on:click="onExport"></el-form-control>
+            <el-form-control v-if="filter.isShowOfflineExportButton" v-bind:item="{type: 'button',name:'离线导出',buttonType:'success',icon:'el-icon-download'}" v-on:click="onOfflineExport"></el-form-control>
             <el-form-control v-if="filter.isShowImportButton" v-show="!filter.file || !filter.file.name" ref="file" v-bind:item="{type: 'file',name:'导入',action:filter.importApi,buttonType:'warning',icon:'el-icon-upload2',accept:'.xls,.xlsx'}" v-model="filter.file" v-on:import="onImport"></el-form-control>
             <el-form-control v-if="filter.isShowImportButton && filter.file && filter.file.name" class="el-upload-input" v-bind:item="{type: 'input',readonly:true}" v-model="filter.file.name"></el-form-control>
             <el-form-control v-if="filter.isShowImportButton && filter.file && filter.file.name" v-bind:item="{type: 'button',name:'上传',buttonType:'warning',icon:'el-icon-upload2'}" v-on:click="$refs.file.upLoad"></el-form-control>

Bailun.DC.Web/Areas/Component/Views/Table/Query.cshtml

@@ -5,6 +5,7 @@
                         v-on:search="onSearch"
                         v-on:reset="onReset"
                         v-on:export="onExport"
+                        v-on:offline-export="onOfflineExport"
                         v-on:click="onClick"></el-form-filter>
     </el-header>
     <el-main v-loading="$root.loading">

Bailun.DC.Web/wwwroot/js/component/el-form-filter.js

@@ -117,6 +117,10 @@
         onExport: function () {
             this.$emit("export", this.getFilter());
         },
+        //离线导出
+        onOfflineExport: function () {
+            this.$emit("offline-export", this.getFilter());
+        },
         //导入
         onImport: function (result, file, message) {
             if (result) {

Bailun.DC.Web/wwwroot/js/component/el-table-query.js

@@ -181,6 +181,28 @@
                 }
             }
         },
+        //离线导出
+        onOfflineExport: function (filterParams, cb) {
+            var that = this;
+            //异步请求
+            if (that.$refs.formFilter.validate()) {
+                that.$http.post("/Component/OfflineDownload/Export", ((filterParams.constructor === Object ? filterParams : null) || that.filterParams), { emulateJSON: true }).then(function (response) {
+                    var result = response.data;
+                    if (response.status === 200 && result.result) {
+                        that.$message({ message: '正在导出,请稍后在离线下载页面下载文件!', type: 'success' });
+                    } else {
+                        this.$message(result.message || " 未知错误!");
+                    }
+                }, function (error) {
+                    this.$message(error.statusText || " 未知错误!");
+                });
+            } else {
+                var message = that.$refs.formFilter.getValidateMessage();
+                if (message && message.length) {
+                    that.$message({ dangerouslyUseHTMLString: true, message: message.join("<br/>") });
+                }
+            }
+        },
         //单击事件
         onClick: function (fn) {
             var that = this;