using APT.BaseData.Domain.ApiModel;
using APT.BaseData.Domain.Entities.FM;
using APT.BaseData.Services.Services.FM;
using APT.Infrastructure.Core;
using APT.MS.Domain.Entities.LR;
using APT.MS.Domain.Entities.SC.PT;
using APT.MS.Domain.Entities.SK;
using APT.MS.Domain.Enums.SK;
using APT.Utility;
using ICSharpCode.SharpZipLib.Core;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.DependencyModel;
using NPOI.SS.Formula.Functions;
using NPOI.Util;
using Org.BouncyCastle.Asn1.Ess;
using System;
using System.Collections.Generic;
using System.Data;
using System.IO;
using System.Linq;
using System.Reflection.Metadata;
using Ubiety.Dns.Core;

namespace APT.SK.WebApi.Controllers.Api
{
    /// <summary>
    ///  检查内容
    /// </summary>
    [Route("api/SK/SKCheckContents")]
    public partial class CheckContentsController : AuthorizeApiController<T_SK_CHECK_CONTENTS>
    {
        /// <summary>
        /// 排序分页查询数据
        /// </summary>
        /// <param name="pageFilter">分页过滤实体</param>
        /// <returns></returns>
        [HttpPost, Route("SKOrderPaged")]
        public PagedActionResult<T_SK_CHECK_CONTENTS> SKOrderPaged([FromBody] KeywordPageFilter pageFilter)
        {
            if (pageFilter.Sort == "NAME")
            {
                pageFilter.Sort = "";
            }

            var filter = pageFilter.FilterGroup.Rules.FirstOrDefault(t => t.Field == "reset");
            if (filter != null && !string.IsNullOrEmpty(filter.Value.ToString()))
            {
                pageFilter.FilterGroup.Rules.Remove(filter);
            }
            pageFilter.Include.Add("Nav_ListCheckQuestion");
            return WitOrderPaged(null, pageFilter);
        }


        /// <summary>
        /// 获得单条实体数据
        /// </summary>
        /// <param name="filter">过滤实体</param>
        /// <returns></returns>
        [HttpPost, Route("SkGet")]
        public JsonActionResult<T_SK_CHECK_CONTENTS> SkGet([FromBody] KeywordFilter filter)
        {
            return SafeExecute<T_SK_CHECK_CONTENTS>(() =>
            {
               if(filter.FilterGroup.Rules.Any(t=>t.Field=="ID"))
                {
                    var ids = filter.FilterGroup.Rules.FirstOrDefault(t => t.Field == "ID").Value.ToString();
                    if(ids.Contains(","))
                    {
                        var idArr = ids.Split(",");
                        filter.FilterGroup.Rules.Remove(filter.FilterGroup.Rules.FirstOrDefault(t => t.Field == "ID"));
                        filter.FilterGroup.Rules.Add(new APT.Infrastructure.Core.FilterRule
                        {
                            Field = "ID",
                            Operate = FilterOperate.Equal,
                            Value = idArr.FirstOrDefault()
                        });
                    }
                }
                var entity = this.GetEntity<T_SK_CHECK_CONTENTS>(null,filter);
                return entity;
            });
        
        }

        /// <summary>
        /// 更新或新增数据
        /// </summary>
        /// <param name="entity">对象实体</param>
        /// <returns></returns>
        [HttpPost, Route("FullUpdate")]
        public JsonActionResult<bool> FullUpdate([FromBody] T_SK_CHECK_CONTENTS entity)
        {
            return SafeExecute<bool>(() =>
            {
                var olds = this.GetEntity<T_SK_CHECK_CONTENTS>(t => !t.IS_DELETED && t.CHECKCONTENT == entity.CHECKCONTENT && t.ID != entity.ID && t.PRODUCTION_UNIT_ID == entity.PRODUCTION_UNIT_ID);
                if (olds != null)
                {
                    throw new Exception("检查内容重复，请先修改");
                }
                var details = entity.Nav_ListCheckQuestion;
                entity.Nav_ListCheckQuestion = null;
                if (details != null && details.Any())
                {
                    foreach (var item in details)
                    {
                        item.ORG_ID = entity.ORG_ID;
                        item.CHECK_CONTENTS_ID = entity.ID;
                    }
                }
                var basics = entity.Nav_ContentsBasics;
                entity.Nav_ContentsBasics = null;
                if (basics != null && basics.Any())
                {
                    foreach (var item in basics)
                    {
                        item.ORG_ID = entity.ORG_ID;
                        item.CHECK_CONTENTS_ID = entity.ID;
                        item.Nav_Law = null;
                    }
                }
                this.UnifiedCommit(() =>
                {
                    if (entity != null)
                        UpdateEntityNoCommit(entity);
                    if (details != null && details.Any())
                        BantchSaveEntityNoCommit(details);
                    if (basics != null && basics.Any())
                        BantchSaveEntityNoCommit(basics);
                });
                return true;
            });
        }
        /// <summary>
        /// 检查内容对应的隐患描述
        /// </summary>
        /// <param name="filter"></param>
        /// <returns></returns>
        [HttpPost, Route("GetHiddenScripList")]
        public PagedActionResult<T_SK_CHECK_QUESTION> GetHiddenScripList([FromBody] KeywordPageFilter pageFilter)
        {
            if (pageFilter.Sort == "NAME")
            {
                pageFilter.Sort = "";
            }
            var result = new PagedActionResult<T_SK_CHECK_QUESTION>();
            var filter = pageFilter.FilterGroup.Rules.FirstOrDefault(t => t.Field == "CHECK_CONTENTS_ID");
            if (filter != null && !string.IsNullOrEmpty(filter.Value.ToString()))
            {
                pageFilter.FilterGroup.Rules.Remove(filter);
                result = this.GetOrderPageEntities<T_SK_CHECK_QUESTION>(t => t.CHECK_CONTENTS_ID == Guid.Parse(filter.Value.ToString()), pageFilter);
            }
            else
            {
                var resultTemp = this.GetEntities<T_SK_CHECK_QUESTION>(t => t.IS_DELETED == false, new BaseFilter(pageFilter.OrgId));
                var questionIds = resultTemp.Distinct(t => t.DESCREPTION).Select(m => m.ID).ToList();
                result = this.GetOrderPageEntities<T_SK_CHECK_QUESTION>(m => questionIds.Contains(m.ID), pageFilter);
            }
            return result;
        }
        /// <summary>
        /// 导入
        /// </summary>
        /// <param name="files"></param>
        /// <returns></returns>
        [HttpPost, Route("ImportUpdate")]
        public JsonActionResult<bool> ImportUpdate(IFormCollection files)
        {
            return SafeExecute<bool>(() =>
            {
                bool isOK = true;
                var orgId = APT.Infrastructure.Api.AppContext.CurrentSession.OrgId;
                var httpRequest = this.HttpContext.Request;
                string orgIdStr = httpRequest.Form["OrgId"];// 获取 组织        
                var dic = Path.Combine(System.AppContext.BaseDirectory, "tempImportFiles");
                if (!Directory.Exists(dic))
                    Directory.CreateDirectory(dic);
                foreach (var key in httpRequest.Form.Files)  // 文件键
                {
                    var postedFile = key;    // 获取文件键对应的文件对象
                    string filePath = Path.Combine(dic, DateTime.Now.ToString("yyyy_MM_dd_hh_mm_ss") + "_" + postedFile.FileName);
                    Byte[] fileData = new Byte[postedFile.Length];
                    Stream sr = postedFile.OpenReadStream();//创建数据流对象 
                    sr.Read(fileData, 0, (int)postedFile.Length);
                    using (FileStream fs = new FileStream(filePath, FileMode.CreateNew))
                    {
                        fs.Write(fileData, 0, fileData.Length);
                        fs.Flush();
                        fs.Close();
                    }

                    //获取数据
                    Dictionary<int, int> startRowIndexs = new Dictionary<int, int>();
                    startRowIndexs.Add(0, 1);//根据Excel格式数据赋值
                    var dataTables = FileUtils.ReadExcelByOledb(filePath, startRowIndexs);
                    string Msg = string.Empty;
                    isOK = InsertModel3(dataTables.Tables[0], orgId, ref Msg);

                    try
                    {
                        System.IO.File.Delete(filePath);
                    }
                    catch { }
                }

                return isOK;
            });
        }
        /// <summary>
        /// 导入
        /// </summary>
        /// <param name="dtSource"></param>
        /// <param name="orgId"></param>
        /// <param name="Msg"></param>
        /// <param name="rowIndex"></param>
        /// <returns></returns>
        /// <exception cref="Exception"></exception>
        public bool InsertModel(DataTable dtSource, Guid? orgId, ref string Msg, int rowIndex = 1)
        {
            var userId = APT.Infrastructure.Api.AppContext.CurrentSession.UserID;
            if (dtSource == null || dtSource.Rows.Count < rowIndex)
            {
                Msg = "未获取到导入数据";
                throw new Exception(Msg);
            }
            int rowAll = dtSource.Rows.Count;
            if (rowAll == 1)
            {
                throw new Exception("导入必须两条以上，一条请直接新增");
            }
            List<T_SK_CHECK_CONTENTS> contents = new List<T_SK_CHECK_CONTENTS>();
            List<T_SK_CHECK_QUESTION> qustions = new List<T_SK_CHECK_QUESTION>();
            Guid? checkId = null;
            var baseFilter = new BaseFilter(orgId);
            var oldContents = this.GetEntities<T_SK_CHECK_CONTENTS>(i => i.IS_DELETED == false, baseFilter, "Nav_ListCheckQuestion");
            for (int i = 0; i < rowAll; i++)
            {
                if (!string.IsNullOrEmpty(dtSource.Rows[i][0].ToString().Trim()))
                {
                    var first = oldContents.FirstOrDefault(x => x.CHECKCONTENT == dtSource.Rows[i][0].ToString().Trim());
                    if (first != null)//旧表已存在数据
                    {
                        checkId = first.ID;
                    }
                    else//不存在
                    {
                        T_SK_CHECK_CONTENTS content = new T_SK_CHECK_CONTENTS();
                        content.ORG_ID = orgId;
                        content.CHECKCONTENT = dtSource.Rows[i][0].ToString().Trim();
                        checkId = content.ID;
                        contents.Add(content);
                    }
                    var items = new List<string>();
                    var scores = new List<string>();
                    var methods = new List<string>();
                    var itemLists = dtSource.Rows[i][1].ToString().Trim().Split("。").ToList();
                    var scoreLists = dtSource.Rows[i][2].ToString().Trim().Split("。").ToList();
                    var methodLists = dtSource.Rows[i][3].ToString().Trim().Split("。").ToList();
                    foreach (var ite in itemLists)
                    {
                        if (!string.IsNullOrEmpty(ite))
                            items.Add(ite);
                    }
                    foreach (var ite in scoreLists)
                    {
                        if (!string.IsNullOrEmpty(ite))
                            scores.Add(ite);
                    }
                    foreach (var ite in methodLists)
                    {
                        if (!string.IsNullOrEmpty(ite))
                            methods.Add(ite);
                    }
                    if (items.Count != scores.Count || items.Count != methods.Count)
                        throw new Exception("第" + (i + 2) + "行，隐患描述与隐患等级与整改措施不匹配");
                    else
                    {
                        if (items != null && items.Any())
                        {
                            var NO = 1;
                            foreach (var item in items)
                            {
                                T_SK_CHECK_QUESTION question = new T_SK_CHECK_QUESTION();
                                question.CHECK_CONTENTS_ID = checkId;
                                question.ORG_ID = orgId;
                                var itemArr = item.Split("、");
                                if (itemArr.Length != 2)
                                {
                                    question.NUM = NO;
                                    question.DESCREPTION = item.ToString();
                                }
                                else
                                {
                                    question.NUM = int.Parse(itemArr[0]);
                                    question.DESCREPTION = itemArr[1].ToString();
                                }
                                qustions.Add(question);
                                NO++;
                            }
                        }
                        if (scores != null && scores.Any())
                        {
                            var NO = 1;
                            foreach (var item in scores)
                            {
                                var itemArr = item.Split("、");
                                if (itemArr.Length != 2)
                                {
                                    var question = qustions.FirstOrDefault(t => t.CHECK_CONTENTS_ID == checkId && t.NUM == NO);
                                    if (question != null)
                                    {
                                        question.QUESTION_LEVEL = item == "重大" ? SKHiddenLevel.Major : SKHiddenLevel.General;
                                    }
                                    else
                                        throw new Exception("隐患对应序号的层级未填写");
                                }
                                else
                                {
                                    var question = qustions.FirstOrDefault(t => t.CHECK_CONTENTS_ID == checkId && t.NUM == int.Parse(itemArr[0]));
                                    if (question != null)
                                        question.QUESTION_LEVEL = itemArr[1] == "重大" ? SKHiddenLevel.Major : SKHiddenLevel.General;
                                    else
                                        throw new Exception("隐患对应序号的层级未填写");
                                }
                                NO++;
                            }
                        }
                        if (methods != null && methods.Any())
                        {
                            var NO = 1;
                            foreach (var item in methods)
                            {
                                var itemArr = item.Split("、");
                                if (itemArr.Length != 2)
                                {
                                    var question = qustions.FirstOrDefault(t => t.CHECK_CONTENTS_ID == checkId && t.NUM == NO);
                                    if (question != null)
                                        question.DEMAND = item;
                                    else
                                        throw new Exception("隐患对应序号的整改措施未填写");
                                }
                                else
                                {
                                    var question = qustions.FirstOrDefault(t => t.CHECK_CONTENTS_ID == checkId && t.NUM == int.Parse(itemArr[0]));
                                    if (question != null)
                                        question.DEMAND = itemArr[1];
                                    else
                                        throw new Exception("隐患对应序号的整改措施未填写");
                                }
                                NO++;
                            }
                        }
                    }
                }
            }
            if (!string.IsNullOrEmpty(Msg))
            {
                throw new Exception(Msg);
            }
            else
            {
                UnifiedCommit(() =>
                {
                    if (contents != null && contents.Any())
                        BantchSaveEntityNoCommit(contents);
                    if (qustions != null && qustions.Any())
                        BantchSaveEntityNoCommit(qustions);
                });
                Msg = "导入成功！";
            }
            return true;
        }

        /// <summary>
        /// 导入
        /// </summary>
        /// <param name="dtSource"></param>
        /// <param name="orgId"></param>
        /// <param name="Msg"></param>
        /// <param name="rowIndex"></param>
        /// <returns></returns>
        /// <exception cref="Exception"></exception>
        public bool InsertModel2(DataTable dtSource, Guid? orgId, ref string Msg, int rowIndex = 1)
        {
            var userId = APT.Infrastructure.Api.AppContext.CurrentSession.UserID;
            if (dtSource == null || dtSource.Rows.Count < rowIndex)
            {
                Msg = "未获取到导入数据";
                throw new Exception(Msg);
            }
            int rowAll = dtSource.Rows.Count;
            if (rowAll == 1)
            {
                throw new Exception("导入必须两条以上，一条请直接新增");
            }
            List<T_SK_CHECK_CONTENTS> contents = new List<T_SK_CHECK_CONTENTS>();
            List<T_SK_CHECK_QUESTION> qustions = new List<T_SK_CHECK_QUESTION>();
            List<T_SK_CHECK_CONTENTS_BASIC> basics = new List<T_SK_CHECK_CONTENTS_BASIC>();
            List<T_SK_CHECK_QUESTION> qustionTemps = new List<T_SK_CHECK_QUESTION>();
            var baseFilter = new BaseFilter(orgId);
            var lawList = this.GetEntities<T_LR_LAW>(i => i.IS_DELETED == false, baseFilter);
            var productionUnits = this.GetEntities<T_FM_USER_PRODUCTION_UNIT_SET>(i => i.IS_DELETED == false, baseFilter);
            var oldContents = this.GetEntities<T_SK_CHECK_CONTENTS>(i => i.IS_DELETED == false, baseFilter);
            var oldHiddens = this.GetEntities<T_SK_CHECK_QUESTION>(i => i.IS_DELETED == false, baseFilter);
            var oldbass = this.GetEntities<T_SK_CHECK_CONTENTS_BASIC>(i => i.IS_DELETED == false, baseFilter);
            for (int i = 0; i < rowAll; i++)
            {
                if (!string.IsNullOrEmpty(dtSource.Rows[i][0].ToString().Trim()))
                {
                        var unit = productionUnits.FirstOrDefault(t => t.NAME == dtSource.Rows[i][0].ToString().Trim());
                        var first = oldContents.FirstOrDefault(x =>x.PRODUCTION_UNIT_ID == unit?.ID && x.CHECKCONTENT == dtSource.Rows[i][1].ToString().Trim());
                        if (first != null)//旧表已存在数据
                        {
                            Msg = Msg + "检查内容：" + dtSource.Rows[i][1].ToString().Trim() + "已存在,请直接到系统配置修改；";
                        //T_SK_CHECK_QUESTION content = new T_SK_CHECK_QUESTION();
                        //content.ORG_ID = orgId;
                        //content.CHECKCONTENT = dtSource.Rows[i][1].ToString().Trim();
                        //content.CHECK_BASICS = dtSource.Rows[i][2].ToString().Trim();
                        //content.CHECK_STANDARD = dtSource.Rows[i][3].ToString().Trim();
                        //content.DESCREPTION = dtSource.Rows[i][4].ToString().Trim();
                        //content.QUESTION_LEVEL_SHOW = dtSource.Rows[i][5].ToString().Trim();
                        //content.QUESTION_LEVEL = content.QUESTION_LEVEL_SHOW == "重大" ? SKHiddenLevel.Major : SKHiddenLevel.General;
                        //content.DEMAND = dtSource.Rows[i][6].ToString().Trim();
                        //content.PRODUCTION_UNIT_ID = unit?.ID;
                        //content.CHECK_CONTENTS_ID = first.ID;
                        //qustionTemps.Add(content);
                        //first.CHECK_STANDARD = content.CHECK_STANDARD;
                        //contents.Add(first);
                    }
                        else
                        {
                            T_SK_CHECK_QUESTION content = new T_SK_CHECK_QUESTION();
                            content.ORG_ID = orgId;
                            content.CHECKCONTENT = dtSource.Rows[i][1].ToString().Trim();
                            content.CHECK_BASICS = dtSource.Rows[i][2].ToString().Trim();
                            content.CHECK_STANDARD = dtSource.Rows[i][3].ToString().Trim();
                            content.DESCREPTION = dtSource.Rows[i][4].ToString().Trim();
                            content.QUESTION_LEVEL_SHOW = dtSource.Rows[i][5].ToString().Trim();
                            content.QUESTION_LEVEL = content.QUESTION_LEVEL_SHOW == "重大" ? SKHiddenLevel.Major : SKHiddenLevel.General;
                            content.DEMAND = dtSource.Rows[i][6].ToString().Trim();
                            content.PRODUCTION_UNIT_ID = unit?.ID;
                            qustionTemps.Add(content);
                        }
                }
            }
            if (qustionTemps != null && qustionTemps.Any())
            {
                //已有检查内容，隐患描述直接加
                //var contentList2 = qustionTemps.Where(m => m.CHECK_CONTENTS_ID != null).GroupBy(t => new { t.CHECK_CONTENTS_ID, t.PRODUCTION_UNIT_ID, t.CHECKCONTENT }).Distinct().ToList();
                //if (contentList2 != null && contentList2.Any())
                //{
                //    foreach (var item in contentList2)
                //    {
                //        var qus = qustionTemps.Where(t => t.CHECK_CONTENTS_ID == item.Key.CHECK_CONTENTS_ID && t.PRODUCTION_UNIT_ID == item.Key.PRODUCTION_UNIT_ID && t.CHECKCONTENT == item.Key.CHECKCONTENT).ToList();
                //        var j = 1;
                //        foreach (var que in qus)
                //        {
                //            var quFirst = oldHiddens.FirstOrDefault(t =>t.CHECK_CONTENTS_ID== item.Key.CHECK_CONTENTS_ID &&  t.DESCREPTION == que.DESCREPTION &&  t.DEMAND == que.DEMAND && t.QUESTION_LEVEL == que.QUESTION_LEVEL);
                //            if (quFirst == null)
                //            {
                //                T_SK_CHECK_QUESTION qu = new T_SK_CHECK_QUESTION();
                //                qu.CHECK_CONTENTS_ID = item.Key.CHECK_CONTENTS_ID;
                //                qu.ORG_ID = orgId;
                //                qu.DESCREPTION = que.DESCREPTION;
                //                qu.DEMAND = que.DEMAND;
                //                qu.QUESTION_LEVEL = que.QUESTION_LEVEL;
                //                qu.NUM = j;
                //                qustions.Add(qu);
                //                j++;
                //            }
                //            if (!string.IsNullOrEmpty(que.CHECK_BASICS))
                //            { 
                //                var laws=que.CHECK_BASICS.Split("；").ToList();
                //                foreach (var law in laws)
                //                {
                //                    var lawFirst = lawList.FirstOrDefault(t => t.NAME == law);
                //                    if (!string.IsNullOrEmpty(law))
                //                    {
                //                        if (lawFirst != null)
                //                        {
                //                            var laFirst = oldbass.FirstOrDefault(t => t.CHECK_CONTENTS_ID == item.Key.CHECK_CONTENTS_ID && t.LAW_ID == lawFirst.ID);
                //                            if (laFirst == null)
                //                            {
                //                                T_SK_CHECK_CONTENTS_BASIC bas = new T_SK_CHECK_CONTENTS_BASIC();
                //                                bas.ORG_ID = orgId;
                //                                bas.LAW_ID = lawFirst.ID;
                //                                basics.Add(bas);
                //                            }  
                //                        }
                //                        else
                //                        {
                //                            Msg = Msg + "找不到检查依据：" + law + ",请先到法律法规库添加";
                //                        }
                //                    }
                //                }
                //            }
                //        }
                //    }
                //}
                //新增的检查内容
                var contentList = qustionTemps.Where(m=>m.CHECK_CONTENTS_ID==null).GroupBy(t => new { t.PRODUCTION_UNIT_ID, t.CHECKCONTENT }).Distinct().ToList();
                if (contentList != null && contentList.Any())
                {
                    foreach (var item in contentList)
                    {
                        T_SK_CHECK_CONTENTS content = new T_SK_CHECK_CONTENTS();
                        content.ORG_ID = orgId;
                        content.PRODUCTION_UNIT_ID = item.Key.PRODUCTION_UNIT_ID;
                        content.CHECKCONTENT = item.Key.CHECKCONTENT;
                        content.CHECK_STANDARD = qustionTemps.FirstOrDefault(t => t.PRODUCTION_UNIT_ID == item.Key.PRODUCTION_UNIT_ID && t.CHECKCONTENT == item.Key.CHECKCONTENT)?.CHECK_STANDARD;
                        contents.Add(content);
                        var qus = qustionTemps.Where(t => t.PRODUCTION_UNIT_ID == item.Key.PRODUCTION_UNIT_ID && t.CHECKCONTENT == item.Key.CHECKCONTENT).ToList();
                        var j = 1;
                        foreach (var que in qus)
                        {
                            T_SK_CHECK_QUESTION qu = new T_SK_CHECK_QUESTION();
                            qu.CHECK_CONTENTS_ID = content.ID;
                            qu.ORG_ID = orgId;
                            qu.DESCREPTION = que.DESCREPTION;
                            qu.DEMAND = que.DEMAND;
                            qu.QUESTION_LEVEL = que.QUESTION_LEVEL;
                            qu.NUM = j;
                            qustions.Add(qu);
                            j++;
                            if (!string.IsNullOrEmpty(que.CHECK_BASICS))
                            {
                                var laws = que.CHECK_BASICS.Split("；").ToList();
                                foreach (var law in laws)
                                {
                                    var lawFirst = lawList.FirstOrDefault(t => t.NAME == law);
                                    if (!string.IsNullOrEmpty(law))
                                    {
                                        if (lawFirst != null)
                                        {
                                            T_SK_CHECK_CONTENTS_BASIC bas = new T_SK_CHECK_CONTENTS_BASIC();
                                            bas.ORG_ID = orgId;
                                            bas.LAW_ID = lawFirst.ID;
                                            basics.Add(bas);
                                        }
                                        else
                                        {
                                            Msg = Msg + "找不到检查依据：" + law + ",请先到法律法规库添加；";
                                        }
                                    }
                                }
                            }
                        }
                    }
                }
            }
            if (!string.IsNullOrEmpty(Msg))
            {
                throw new Exception(Msg);
            }
            else
            {
                UnifiedCommit(() =>
                {
                    if (contents != null && contents.Any())
                        BantchSaveEntityNoCommit(contents);
                    if (qustions != null && qustions.Any())
                        BantchSaveEntityNoCommit(qustions);
                });
                Msg = "导入成功！";
            }
            return true;
        }
        /// <summary>
        /// 导入
        /// </summary>
        /// <param name="dtSource"></param>
        /// <param name="orgId"></param>
        /// <param name="Msg"></param>
        /// <param name="rowIndex"></param>
        /// <returns></returns>
        /// <exception cref="Exception"></exception>
        public bool InsertModel3(DataTable dtSource, Guid? orgId, ref string Msg, int rowIndex = 1)
        {
            var userId = APT.Infrastructure.Api.AppContext.CurrentSession.UserID;
            if (dtSource == null || dtSource.Rows.Count < rowIndex)
            {
                Msg = "未获取到导入数据";
                throw new Exception(Msg);
            }
            int rowAll = dtSource.Rows.Count;
            if (rowAll == 1)
            {
                throw new Exception("导入必须两条以上，一条请直接新增");
            }
            List<T_SK_CHECK_CONTENTS> contents = new List<T_SK_CHECK_CONTENTS>();
            List<T_SK_CHECK_QUESTION> qustions = new List<T_SK_CHECK_QUESTION>();
            List<T_SK_CHECK_QUESTION> qustionTemps = new List<T_SK_CHECK_QUESTION>();
            var baseFilter = new BaseFilter(orgId);
            var productionUnits = this.GetEntities<T_FM_USER_PRODUCTION_UNIT_SET>(i => i.IS_DELETED == false, baseFilter);
            var oldContents = this.GetEntities<T_SK_CHECK_CONTENTS>(i => i.IS_DELETED == false, baseFilter);
            var oldHiddens = this.GetEntities<T_SK_CHECK_QUESTION>(i => i.IS_DELETED == false, baseFilter);
            
            for (int i = 0; i < rowAll; i++)
            {
                if (!string.IsNullOrEmpty(dtSource.Rows[i][0].ToString().Trim()))
                {
                    var unit = productionUnits.FirstOrDefault(t => t.NAME == dtSource.Rows[i][0].ToString().Trim());
                    if (unit == null)//旧表已存在数据
                    {
                        Msg = Msg + "生产单元：" + dtSource.Rows[i][0].ToString().Trim() + "不存在,请先到系统管理添加；";
                       
                    }
                    else
                    {
                        T_SK_CHECK_QUESTION content = new T_SK_CHECK_QUESTION();
                        content.ORG_ID = orgId;
                        content.CHECKCONTENT = dtSource.Rows[i][1].ToString().Replace("\n","").Trim();
                        content.CHECK_BASICS = dtSource.Rows[i][2].ToString().Replace("\n", "").Trim();
                        content.CHECK_STANDARD = dtSource.Rows[i][3].ToString().Replace("\n", "").Trim();
                        content.DESCREPTION = dtSource.Rows[i][4].ToString().Replace("\n", "").Trim();
                        content.QUESTION_LEVEL =  SKHiddenLevel.General;
                        content.DEMAND = dtSource.Rows[i][6].ToString().Replace("\n", "").Trim();
                        content.PRODUCTION_UNIT_ID = unit?.ID;
                        qustionTemps.Add(content);
                    }
                }
            }
            if (qustionTemps != null && qustionTemps.Any())
            {
                foreach (var item in qustionTemps)
                {
                    var conFirsts = item.CHECKCONTENT.Split("？").ToList();
                    var queFirsts = item.DESCREPTION.Split("。").ToList();
                    var mesFirsts = item.DEMAND.Split("。").ToList();
                    if (conFirsts != null && conFirsts.Any())
                    {
                        foreach (var first in conFirsts)
                        {
                            if (!string.IsNullOrEmpty(first))
                            {
                                var num = first.Split("*")[0];
                                var con = first.Split("*")[1];
                                T_SK_CHECK_CONTENTS content = new T_SK_CHECK_CONTENTS();
                                content.ORG_ID = orgId;
                                content.PRODUCTION_UNIT_ID = item.PRODUCTION_UNIT_ID;
                                content.CHECKCONTENT = con;
                                contents.Add(content);
                                var ques = queFirsts.Where(t => t.StartsWith(num)).ToList();
                                if (ques != null && ques.Any())
                                {
                                    var j = 0;
                                    foreach (var que in ques)
                                    {
                                        var quNum = que.Split("*")[0];
                                        var mes = mesFirsts.FirstOrDefault(t => t.StartsWith(quNum));
                                        T_SK_CHECK_QUESTION qu = new T_SK_CHECK_QUESTION();
                                        qu.CHECK_CONTENTS_ID = content.ID;
                                        qu.ORG_ID = orgId;
                                        qu.DESCREPTION = que.Split('*')[1];
                                        qu.DEMAND = mes.Split("*")[1];
                                        qu.QUESTION_LEVEL = item.QUESTION_LEVEL;
                                        qu.NUM = j;
                                        qustions.Add(qu);
                                        j++;
                                    }
                                }
                            }
                        }
                    }
                }
               
            }
            if (!string.IsNullOrEmpty(Msg))
            {
                throw new Exception(Msg);
            }
            else
            {
                UnifiedCommit(() =>
                {
                    if (contents != null && contents.Any())
                        BantchSaveEntityNoCommit(contents);
                    if (qustions != null && qustions.Any())
                        BantchSaveEntityNoCommit(qustions);
                });
                Msg = "导入成功！";
            }
            return true;
        }
    }
}