using Tiobon.Core.IServices;
using Tiobon.Core.Model.Models;
using Tiobon.Core.Services.BASE;
using Tiobon.Core.IRepository.Base;
using Tiobon.Core.Common.Caches;
using Newtonsoft.Json.Linq;
using Tiobon.Core.Common;
using Tiobon.Core.Model;
using Newtonsoft.Json;
using Tiobon.Core.Common.Helper;
using SqlSugar;
using static Tiobon.Core.Model.Consts;
using NPOI.SS.UserModel;
using static Tiobon.Core.DataAccess.ReportHelper;
using Tiobon.Core.Common.DB.Dapper.Extensions;
using NPOI.HSSF.UserModel;
using NPOI.SS.Util;
using NPOI.XSSF.UserModel;
using Microsoft.AspNetCore.Http;
using System.Data;

namespace Tiobon.Core.Services;

/// <summary>
/// 培训记录 (服务)
/// </summary>
public class Ghre_StudyRecordServices : BaseServices<Ghre_StudyRecord, Ghre_StudyRecordDto, InsertGhre_StudyRecordInput, EditGhre_StudyRecordInput>, IGhre_StudyRecordServices
{
    private readonly IBaseRepository<Ghre_StudyRecord> _dal;
    private IGhre_CourseServices _ghre_CourseServices;
    public Ghre_StudyRecordServices(ICaching caching,
        IGhre_CourseServices ghre_CourseServices,
        IBaseRepository<Ghre_StudyRecord> dal)
    {
        this._dal = dal;
        base.BaseDal = dal;
        base._caching = caching;
        _ghre_CourseServices = ghre_CourseServices;
    }
    public override async Task<ServicePageResult<Ghre_StudyRecordDto>> QueryFilterPage(QueryBody filter, string condition, bool? IsEnable = true)
    {
        if (string.IsNullOrWhiteSpace(filter.orderBy))
            filter.orderBy = "CreateTime1 DESC";

        if (filter.pageSize == 0)
            filter.pageSize = 10000;

        var countSql = @$" SELECT COUNT(1) FROM  Ghre_StudyRecord_V";
        var sql = @$" SELECT *
                    FROM Ghre_StudyRecord_V  A";

        string conditions = " WHERE 1=1 ";

        if (IsEnable == true)
            conditions += " AND IsEnable = 1";
        else if (IsEnable == false)
            conditions += " AND IsEnable = 0";

        if (!string.IsNullOrWhiteSpace(condition))
            conditions += " AND " + condition;


        if (filter.jsonParam != null)
            foreach (JProperty jProperty in filter.jsonParam.Properties())
            {
                var name = jProperty.Name;
                var value = jProperty.Value.ToString();
                if (name == "page" || name == "pageSize")
                    continue;
                if (name == "Date")
                {
                    var jsonParam = JsonConvert.DeserializeObject<JsonParam1>(value);
                    conditions += $" AND ((ExamDate BETWEEN '{jsonParam.columnValue[0]}' AND '{jsonParam.columnValue[1]}') OR (CourseBeginTime BETWEEN '{jsonParam.columnValue[0]}' AND '{jsonParam.columnValue[1]}') OR (CourseEndTime BETWEEN '{jsonParam.columnValue[0]}' AND '{jsonParam.columnValue[1]}'))";

                    continue;
                }

                if (name == "IsPass" || name == "Source")
                {
                    value = value.Replace("Include", "Equal");
                }
                if (!string.IsNullOrWhiteSpace(value))
                    conditions = DealConditions(conditions, name, value);
            }

        sql += conditions;
        countSql += conditions;
        int total = await Db.Ado.GetIntAsync(countSql);

        sql = "SELECT * FROM (SELECT *, ROW_NUMBER() OVER (ORDER BY " + filter.orderBy + ") NUM FROM (SELECT * FROM (" + sql + " ";
        sql += ") A ) B ) C";

        sql += " WHERE NUM <= " + filter.pageNum * filter.pageSize + " AND NUM >" + (filter.pageNum - 1) * filter.pageSize;

        var entitys = await Db.Ado.SqlQueryAsync<Ghre_StudyRecordDto>(sql);

        entitys.ForEach(entity =>
        {
            if (!string.IsNullOrWhiteSpace(entity.Indate))
                entity.Indate = DateTimeHelper.ConvertToDayString(entity.Indate);
            entity.ExamDate = DateTimeHelper.ConvertToDayString(entity.ExamDate);

            if (entity.ActualBeginTime != null && entity.ActualEndTime != null)
            {
                TimeSpan timeDifference = entity.ActualEndTime.Value - entity.ActualBeginTime.Value;
                entity.ExamDuration = StringHelper.TrimNumber(Convert.ToDecimal(timeDifference.TotalMinutes), 2);
            }

            if (entity.CourseType == "ManualInsert")
                entity.UpdateYN = 1;
        });

        return new ServicePageResult<Ghre_StudyRecordDto>(filter.pageNum, total, filter.pageSize, entitys);

    }

    public async Task<ServicePageResult<Ghre_StudyRecordDto>> QueryStaff(QueryBody filter)
    {
        return await QueryFilterPage(filter, $"UserId={App.User.ID}", true);
    }

    public async Task<ServiceResult<ExcelData>> ExportStaffExcel(QueryExport body)
    {
        QueryBody filter = new QueryBody();
        filter.pageNum = 1;
        filter.pageSize = 1000000;
        filter.langId = body.langId;

        var ids = new List<long>();
        if (body.exportSet.SelectRowKeys != null && body.exportSet.SelectRowKeys.Any())
            ids = body.exportSet.SelectRowKeys;

        var data = await QueryFilterPage(filter, $"UserId={App.User.ID}", true);


        string sql = $@"SELECT *
                            FROM Ghrs_PageSettingQuery
                            WHERE     IsEnable = 1
                                  AND PageNo = '{body.menuName}'
                                  AND (defaultHidden = 'false' or defaultHidden is null)
                            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, body.exportSet.TitleName, "sheet1", physicsPath + path);
        var result = new ExcelData();
        result.filePath = path;
        result.fileName = body.exportSet.TitleName + ".xlsx";
        return ServiceResult<ExcelData>.OprateSuccess("导出成功", result);
    }

    public override async Task<long> Add(InsertGhre_StudyRecordInput entity)
    {
        if (await Db.Queryable<Ghre_StudyRecord>()
            .WhereIF(!entity.CourseId.IsNullOrEmpty(), x => x.CourseId == entity.CourseId)
            .WhereIF(!entity.CourseSceneId.IsNullOrEmpty(), x => x.CourseSceneId == entity.CourseSceneId)
            .AnyAsync(x => x.StaffId == entity.StaffId))
            throw new Exception("该用户存在相同学习记录！");

        if (entity.BeginTime != null && entity.EndTime != null)
        {
            if (entity.EndTime < entity.BeginTime)
                throw new Exception("学习结束时间需大于学习开始时间！");

            if (entity.EndTime > DateTime.Now)
                throw new Exception("学习结束时间需小于当前时间！");
            TimeSpan timeDifference = entity.EndTime.Value - entity.BeginTime.Value;
            entity.StudyDuration = (decimal)timeDifference.TotalMinutes;
        }

        var snap = await Db.Queryable<Ghre_CourseSnap>().FirstAsync(x => x.CourseId == entity.CourseId);
        entity.CourseSnapId = snap?.Id;
        entity.CourseType = "ManualInsert";
        var result = await base.Add(entity);

        var id = SnowFlakeSingle.Instance.NextId();
        var examRecord = new Ghre_ExamRecord()
        {
            Id = id,
            StudyRecordId = result,
            StaffId = entity.StaffId,
            CourseSnapId = snap?.Id,
            Score = entity.Score,
            AdjustScore = entity.AdjustScore,
            ExamDate = entity.ExamDate,
            IsPass = entity.IsPass,
        };
        await Db.Insertable(examRecord).ExecuteCommandAsync();

        return result;
    }

    public override async Task<bool> Update(long Id, EditGhre_StudyRecordInput editModel)
    {
        if (await Db.Queryable<Ghre_StudyRecord>()
            .WhereIF(!editModel.CourseId.IsNullOrEmpty(), x => x.CourseId == editModel.CourseId)
            .WhereIF(!editModel.CourseSceneId.IsNullOrEmpty(), x => x.CourseSceneId == editModel.CourseSceneId)
            .AnyAsync(x => x.StaffId == editModel.StaffId && x.Id != Id))
            throw new Exception("该用户存在相同学习记录！");

        if (editModel.BeginTime != null && editModel.EndTime != null)
        {
            if (editModel.EndTime < editModel.BeginTime)
                throw new Exception("学习结束时间需大于学习开始时间！");

            if (editModel.EndTime > DateTime.Now)
                throw new Exception("学习结束时间需小于当前时间！");
            TimeSpan timeDifference = editModel.EndTime.Value - editModel.BeginTime.Value;
            editModel.StudyDuration = (decimal)timeDifference.TotalMinutes;
        }

        var snap = await Db.Queryable<Ghre_CourseSnap>().FirstAsync(x => x.CourseId == editModel.CourseId);
        editModel.CourseSnapId = snap?.Id;
        editModel.CourseType = "ManualInsert";
        var result = await base.Update(Id, editModel);
        var snapId = snap?.Id;
        await Db.Updateable<Ghre_ExamRecord>()
            .SetColumns(it => new Ghre_ExamRecord()
            {
                StaffId = editModel.StaffId,
                CourseSnapId = snapId,
                Score = editModel.Score,
                AdjustScore = editModel.AdjustScore,
                ExamDate = editModel.ExamDate,
                IsPass = editModel.IsPass
            })
            .Where(it => it.StudyRecordId == Id)
            .ExecuteCommandAsync();

        return result;
    }

    public override async Task<ServiceFormResult<Ghre_StudyRecordDto>> QueryForm(QueryForm body)
    {
        var result = await base.QueryForm(body);

        var DT_TableDataT1 = result.result.DT_TableDataT1;
        for (int i = 0; i < DT_TableDataT1.Count; i++)
        {
            var record = await Db.Queryable<Ghre_ExamRecord>().FirstAsync(x => x.StudyRecordId == DT_TableDataT1[i].Id);

            if (record != null)
            {
                DT_TableDataT1[i].Score = record.Score;
                DT_TableDataT1[i].AdjustScore = record.AdjustScore;
                if (record.ExamDate != null)
                    DT_TableDataT1[i].ExamDate = record.ExamDate.Value.ToString();
                if (record.IsPass != null)
                    DT_TableDataT1[i].IsPass = record.IsPass == true ? "true" : "false";
            }

        }
        result.result.DT_TableDataT1 = DT_TableDataT1;
        return result;
    }

    public override async Task<ServiceResult<string>> DownloadExcel(string menuName)
    {
        var physicsPath = $"{Environment.CurrentDirectory}{Path.DirectorySeparatorChar}wwwroot";
        var path = $"{$"{Path.DirectorySeparatorChar}files{Path.DirectorySeparatorChar}ExcelTemplate{Path.DirectorySeparatorChar}"}";
        if (!Directory.Exists(physicsPath + path))
            Directory.CreateDirectory(physicsPath + path);

        Type entityType = typeof(Ghre_StudyRecord);
        var fileName = entityType.GetEntityTableName() + ".xlsx";
        //physicsPath = physicsPath + path + fileName;

        IWorkbook hssfworkbook;
        ISheet sheet;
        using (FileStream file = new FileStream(physicsPath + path + fileName, FileMode.Open, FileAccess.Read))
        {
            //hssfworkbook = new HSSFWorkbook(file);
            //hssfworkbook = new XSSFWorkbook(file);
            hssfworkbook = WorkbookFactory.Create(file);
        }
        ISheet sheet2 = hssfworkbook.CreateSheet("下拉数据");

        var newFileName = Guid.NewGuid() + ".xlsx";
        int listColIndex = 0;
        string sql = @"select 'Course' field, Id id, CourseNo no, CourseName name from Ghre_Course where IsEnable=1 and Status='Released'";
        var dataSourceLists = await Db.Ado.SqlQueryAsync<DataSourceList>(sql);
        if (dataSourceLists.Any())
        {
            var types = new List<string>
            {
            "学习记录"
            };

            types.ForEach(sheetName =>
            {
                int sheetIndex = hssfworkbook.GetSheetIndex(sheetName);
                if (sheetIndex >= 0)
                {
                    sheet = hssfworkbook.GetSheetAt(sheetIndex);

                    SetCellDropdownList(sheet, 0, 0, dataSourceLists.Select(x => x.name).ToArray());
                }

            });
            MemoryStream ms;
            using (ms = new MemoryStream())
            {
                hssfworkbook.Write(ms);
                ms.Flush();
                hssfworkbook.Dispose();
                //ms.Position = 0;
                //return ms;
            }
            using (FileStream fs = new FileStream(physicsPath + path + newFileName, FileMode.Create, FileAccess.Write))
            {
                byte[] data = ms.ToArray();
                fs.Write(data, 0, data.Length);
                fs.Flush();
            }

        }

        var physicsPath1 = physicsPath + path + fileName;
        if (dataSourceLists.Any())
            physicsPath1 = physicsPath + path + newFileName;
        var result = ServiceResult<string>.OprateSuccess("学习记录_" + DateTimeHelper.ConvertToSecondString1(DateTime.Now) + ".xlsx", physicsPath1);
        return result;
    }

    #region Excel导入
    public override async Task<ServiceResult<ExcelData>> ImportExcel(IFormFile file)
    {
        var data = new ExcelData();
        long id = SnowFlakeSingle.instance.getID();
        var physicsPath = $"{Environment.CurrentDirectory}{Path.DirectorySeparatorChar}wwwroot";
        var path = $"{$"{Path.DirectorySeparatorChar}files{Path.DirectorySeparatorChar}import{Path.DirectorySeparatorChar}{id}{Path.DirectorySeparatorChar}"}";
        if (!Directory.Exists(physicsPath + path))
            Directory.CreateDirectory(physicsPath + path);

        var filepath = physicsPath + path + file.FileName;
        using (var stream = File.Create(filepath))
        {
            await file.CopyToAsync(stream);
        }
        string extension = Path.GetExtension(filepath);

        bool isExistError = false;
        var id1 = SnowFlakeSingle.instance.getID();
        string errorFileName = path + SnowFlakeSingle.instance.getID() + extension;
        //types.ForEach(async x =>
        //{

        //    string questionType = ConvertQuestionType1(x);
        //    DataTable dt = NPOIHelper.ImportExcel(filepath, x);

        //    NPOIHelper.ExportExcel(dt, null, x, path + id1 + extension);
        //});
        DataTable dt = NPOIHelper.ImportExcel(filepath, "学习记录");
        if (dt.Columns["Comments"] == null)
            dt.Columns.Add("Comments", typeof(string));

        for (int i = 0; i < dt.Rows.Count; i++)
        {
            var comments = new List<string>();

            if (!dt.Columns.Contains("课程（必填）"))
            {
                comments.Add("未查询到【课程（必填）】列！");
                data.ErrorCount++;
                dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a));
                isExistError = true;
                continue;
            }
            if (!dt.Columns.Contains("课程场景"))
            {
                comments.Add("未查询到【课程场景】列！");
                data.ErrorCount++;
                dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a));
                isExistError = true;
                continue;
            }
            if (!dt.Columns.Contains("员工（必填）"))
            {
                comments.Add("未查询到【员工（必填）】列！");
                data.ErrorCount++;
                dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a));
                isExistError = true;
                continue;
            }
            if (!dt.Columns.Contains("考试日期（必填）"))
            {
                comments.Add("未查询到【考试日期（必填）】列！");
                data.ErrorCount++;
                dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a));
                isExistError = true;
                continue;
            }
            if (!dt.Columns.Contains("学习开始时间"))
            {
                comments.Add("未查询到【学习开始时间】列！");
                data.ErrorCount++;
                dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a));
                isExistError = true;
                continue;
            }
            if (!dt.Columns.Contains("学习结束时间"))
            {
                comments.Add("未查询到【学习结束时间】列！");
                data.ErrorCount++;
                dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a));
                isExistError = true;
                continue;
            }
            if (!dt.Columns.Contains("考试分数（必填）"))
            {
                comments.Add("未查询到【考试分数（必填）】列！");
                data.ErrorCount++;
                dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a));
                isExistError = true;
                continue;
            }
            if (!dt.Columns.Contains("调整分（必填）"))
            {
                comments.Add("未查询到【调整分（必填）】列！");
                data.ErrorCount++;
                dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a));
                isExistError = true;
                continue;
            }
            if (!dt.Columns.Contains("是否合格（必填）"))
            {
                comments.Add("未查询到【是否合格（必填）】列！");
                data.ErrorCount++;
                dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a));
                isExistError = true;
                continue;
            }
            if (!dt.Columns.Contains("备注"))
            {
                comments.Add("未查询到【备注】列！");
                data.ErrorCount++;
                dt.Rows[i]["Comments"] = string.Join(";", comments.Select(a => a));
                isExistError = true;
                continue;
            }

            var courseName = dt.Rows[i]["课程（必填）"].ToString();
            var staffName = dt.Rows[i]["员工（必填）"].ToString();
            var courseScene = dt.Rows[i]["课程场景"].ToString();
            var examDate = dt.Rows[i]["考试日期（必填）"].ToString();
            var courseBeginTime = dt.Rows[i]["学习开始时间"].ToString();
            var courseEndTime = dt.Rows[i]["学习结束时间"].ToString();
            var score = dt.Rows[i]["考试分数（必填）"].ToString();
            var adjustScore = dt.Rows[i]["调整分（必填）"].ToString();
            var isPass = dt.Rows[i]["是否合格（必填）"].ToString();
            var remarkSz = dt.Rows[i]["备注"].ToString();

            if (courseName.IsNullOrEmpty())
            {
                dt.Rows[i]["Comments"] = "课程为必填项！";
                data.ErrorCount++;
                isExistError = true;
                continue;
            }

            if (staffName.IsNullOrEmpty())
            {
                dt.Rows[i]["Comments"] = "员工为必填项！";
                data.ErrorCount++;
                isExistError = true;
                continue;
            }

            if (examDate.IsNullOrEmpty())
            {
                dt.Rows[i]["Comments"] = "考试日期为必填项！";
                data.ErrorCount++;
                isExistError = true;
                continue;
            }
            if (score.IsNullOrEmpty())
            {
                dt.Rows[i]["Comments"] = "考试分数为必填项！";
                data.ErrorCount++;
                isExistError = true;
                continue;
            }
            if (isPass.IsNullOrEmpty())
            {
                dt.Rows[i]["Comments"] = "是否合格为必填项！";
                data.ErrorCount++;
                isExistError = true;
                continue;
            }

            var staff = await Db.Queryable<Ghra_Staff>().Where(x => x.StaffEname == staffName || x.StaffName == staffName || x.PinYinName == staffName).FirstAsync();

            if (staff.IsNullOrEmpty())
            {
                dt.Rows[i]["Comments"] = "该员工在系统中不存在存在！";
                data.ErrorCount++;
                isExistError = true;
                continue;
            }
            var course = await _ghre_CourseServices.QuerySingleDto(x => x.CourseName == courseName);
            if (course.IsNullOrEmpty())
            {
                dt.Rows[i]["Comments"] = "该课程在系统中不存在存在！";
                data.ErrorCount++;
                isExistError = true;
                continue;
            }

            var scene = await Db.Queryable<Ghre_CourseScene>().Where(x => x.CourseName == courseScene).FirstAsync();

            DateTime? dtExamDate = null;
            try
            {
                dtExamDate = Convert.ToDateTime(examDate);
            }
            catch (Exception)
            {
                dt.Rows[i]["Comments"] = "无效的考试日期！";
                data.ErrorCount++;
                isExistError = true;
                continue;
            }

            DateTime? dtCourseBeginTime = null;
            if (dtCourseBeginTime.IsNotEmptyOrNull())
            {
                try
                {
                    dtCourseBeginTime = Convert.ToDateTime(dtCourseBeginTime);
                }
                catch (Exception)
                {
                    dt.Rows[i]["Comments"] = "无效的学习开始时间！";
                    data.ErrorCount++;
                    isExistError = true;
                    continue;
                }
            }

            DateTime? dtCourseEndTime = null;
            if (dtCourseEndTime.IsNotEmptyOrNull())
            {
                try
                {
                    dtCourseEndTime = Convert.ToDateTime(dtCourseEndTime);
                }
                catch (Exception)
                {
                    dt.Rows[i]["Comments"] = "无效的学习结束时间！";
                    data.ErrorCount++;
                    isExistError = true;
                    continue;
                }
            }

            decimal? Score = null;
            if (score.IsNotEmptyOrNull())
            {
                try
                {
                    Score = Convert.ToDecimal(score);
                }
                catch (Exception)
                {
                    dt.Rows[i]["Comments"] = "无效的考试分数！";
                    data.ErrorCount++;
                    isExistError = true;
                    continue;
                }
            }

            decimal? AdjustScore = null;
            if (adjustScore.IsNotEmptyOrNull())
            {
                try
                {
                    AdjustScore = Convert.ToDecimal(adjustScore);
                }
                catch (Exception)
                {
                    dt.Rows[i]["Comments"] = "无效的学习结束时间！";
                    data.ErrorCount++;
                    isExistError = true;
                    continue;
                }
            }

            try
            {
                var insert = new InsertGhre_StudyRecordInput()
                {
                    CourseId = course?.Id,
                    StaffId = staff.StaffID,
                    CourseSceneId = scene?.Id,
                    Score = Score,
                    AdjustScore = AdjustScore ?? 0,
                    IsPass = isPass == "是" ? true : false,
                    ExamDate = dtExamDate,
                    CourseBeginTime = dtCourseBeginTime,
                    CourseEndTime = dtCourseEndTime,
                    RemarkSz = remarkSz,
                };
                await Add(insert);
            }
            catch (Exception E)
            {
                dt.Rows[i]["Comments"] = E.Message;
                data.ErrorCount++;
                isExistError = true;
                continue;
            }


        }

        if (isExistError)
        {
            NPOIHelper.ExportExcel(dt, null, "学习记录", physicsPath + errorFileName);
            data.filePath = errorFileName;
        }

        return ServiceResult<ExcelData>.OprateSuccess("导入成功！", data);
    }

    #endregion

    public static void SetCellDropdownList(ISheet sheet, int firstcol, int lastcol, string[] vals)
    {

        //設置生成下拉框的行和列
        var cellRegions = new CellRangeAddressList(1, 65535, firstcol, lastcol);
        IDataValidation validation = null;

        if (sheet.GetType().Name.Contains("XSSF")) // .xlsx
        {
            XSSFDataValidationHelper helper = new XSSFDataValidationHelper((XSSFSheet)sheet);//获得一个数据验证Helper  
                                                                                             //IDataValidation
            validation = helper.CreateValidation(
            helper.CreateExplicitListConstraint(vals), cellRegions);//创建约束
        }
        else // HSSF .xls
        {
            //設置 下拉框內容
            DVConstraint constraint = DVConstraint.CreateExplicitListConstraint(vals);
            validation = new HSSFDataValidation(cellRegions, constraint);


            /*綁定下拉框和作用區域，並設置錯誤提示信息
            HSSFDataValidation dataValidate = new HSSFDataValidation(cellRegions, constraint);
            dataValidate.CreateErrorBox("輸入不合法", "請輸入或選擇下拉列表中的值。");
            dataValidate.ShowPromptBox = true;
*/
        }

        validation.CreateErrorBox("输入不合法", "请输入或选择下拉列表中的值。");
        validation.ShowPromptBox = true;

        sheet.AddValidationData(validation);
    }
    #region 获取ESS查询条件
    public async Task<ServiceResult<CoursePublicSearch>> QueryESSSearchFields(QueryBody body)
    {
        var entity = new CoursePublicSearch();
        string sql = @"SELECT Langkey field,
                       CASE {2}
                          WHEN 1 THEN isnull (Value01, LangValue)
                          WHEN 2 THEN isnull (Value02, LangValue)
                          WHEN 3 THEN isnull (Value03, LangValue)
                          WHEN 4 THEN isnull (Value04, LangValue)
                          WHEN 5 THEN isnull (Value05, LangValue)
                          WHEN 6 THEN isnull (Value06, LangValue)
                          WHEN 7 THEN isnull (Value07, LangValue)
                          WHEN 8 THEN isnull (Value08, LangValue)
                          WHEN 9 THEN isnull (Value09, LangValue)
                          WHEN 10 THEN isnull (Value10, LangValue)
                       END label
                FROM Ghrs_LangKey
                WHERE     IsEnable = 1
                      AND (LangKey LIKE 'GHR_Page%' OR LangKey LIKE 'GHR_Common%')";
        sql = string.Format(sql, body.menuName, App.User.ID, body.langId);
        entity.DT_PageMutiMsg = await Db.Ado.SqlQueryAsync<DT_PageMutiMsg>(sql);
        entity.SearchFields.Add(new CoursePublicSearchField()
        {
            label = "课程编号/名称",
            field = "CourseNoOrName",
            elementType = "Input",
            editable = true,
            required = false,
            multipleSelect = false,
        });
        entity.SearchFields.Add(new CoursePublicSearchField()
        {
            label = "课程分类",
            field = "CourseClassId",
            elementType = "ApiSelect",
            dataSource = "CommonList_TrainingCourseClass",
            editable = true,
            required = false,
            multipleSelect = false,
        });
        entity.SearchFields.Add(new CoursePublicSearchField()
        {
            label = "课程场景",
            field = "CourseSceneId",
            elementType = "ApiSelect",
            dataSource = "CommonList_TrainingCourseScene",
            editable = true,
            required = false,
            multipleSelect = false,
        });
        entity.SearchFields.Add(new CoursePublicSearchField()
        {
            label = "课程状态",
            field = "CourseStatus",
            elementType = "ApiSelect",
            dataSource = "TBParaDetail_Train_CourseIsOpen",
            editable = true,
            required = false,
            multipleSelect = false,
        });
        entity.SearchFields.Add(new CoursePublicSearchField()
        {
            label = "学习状态",
            field = "StudyStatus",
            elementType = "ApiSelect",
            dataSource = "TBParaDetail_Train_TrainingStudyStatus",
            editable = true,
            required = false,
            multipleSelect = false,
        });
        return ServiceResult<CoursePublicSearch>.OprateSuccess("", entity);
    }
    #endregion

    #region 获取我的学习
    /// <summary>
    /// 
    /// </summary>
    /// <param name="filter"></param>
    /// <param name="condition"></param>
    /// <param name="IsEnable"></param>
    /// <returns></returns>
    public async Task<ServicePageResult<Ghre_StudyRecordESS>> QueryESS(QueryBody filter, string condition, bool? IsEnable = true)
    {
        if (string.IsNullOrWhiteSpace(filter.orderBy))
            filter.orderBy = "JoinTime DESC";

        if (filter.pageSize == 0)
            filter.pageSize = 10000;

        var countSql = @$" SELECT COUNT(1) FROM  Ghre_StudyRecord_V";
        var sql = @$" SELECT A.Id,
                               A.StaffId,
                               A.CourseSnapId,
                               A.CourseId,
                               A.CoverUrl,
                               A.UseDefaultCoverImage,
                               A.DefaultCoverImageName,
                               A.CourseName,
                               A.StandardHour,
                               A.CourseCreditPoints CreditPoints,
                               A.CourseBeginTime CourseBeginDate,
                               A.CourseEndTime CourseEndDate,
                               A.ExamDate,
                               A.ExamBeginDate,
                               A.ExamEndDate,
                               A.JoinTime,
                               A.CourseClassId,
                               A.CourseSceneId,
                               A.CourseType,
                               A.ExamDateType,
                               A.AfterHowLong,
                               A.StudyProgress,
                               A.ExamId,A.ExamStatus
                        FROM Ghre_StudyRecord_V A";

        string conditions = $" WHERE UserId={App.User.ID} ";

        if (IsEnable == true)
            conditions += " AND IsEnable = 1";
        else if (IsEnable == false)
            conditions += " AND IsEnable = 0";

        if (!string.IsNullOrWhiteSpace(condition))
            conditions += " AND " + condition;


        if (filter.jsonParam != null)
            foreach (JProperty jProperty in filter.jsonParam.Properties())
            {
                var name = jProperty.Name;
                var value = jProperty.Value.ToString();
                if (name == "page" || name == "pageSize")
                    continue;
                if (name == "CourseNoOrName")
                {
                    var jsonParam = JsonConvert.DeserializeObject<JsonParam>(value);
                    conditions += $" AND CourseName LIKE '%{jsonParam.columnValue}%'";

                    continue;
                }
                if (name == "CourseClassId")
                {
                    var jsonParam = JsonConvert.DeserializeObject<JsonParam>(value);
                    conditions += $" AND CourseClassId LIKE '%{jsonParam.columnValue}%' ";

                    continue;
                }
                if (name == "CourseType")
                {
                    var jsonParam = JsonConvert.DeserializeObject<JsonParam>(value);

                    var value1 = jsonParam.columnValue;
                    conditions += $" AND {name} LIKE '%{jsonParam.columnValue}%'";

                    continue;
                }
                if (!string.IsNullOrWhiteSpace(value))
                {
                    var jsonParam = JsonConvert.DeserializeObject<JsonParam>(value);

                    switch (jsonParam.operationKey)
                    {
                        case "Include":
                            conditions += $" AND {name} LIKE '%{jsonParam.columnValue}%'";
                            break;
                        case "NotInclude":
                            conditions += $" AND {name} NOT LIKE '%{jsonParam.columnValue}%'";
                            break;
                        case "IsNull":
                            conditions += $" AND {name} IS NULL";
                            break;
                        case "NotNull":
                            conditions += $" AND {name} IS NOT NULL";
                            break;
                        case "Equal":
                            conditions += $" AND {name} ='{jsonParam.columnValue}'";
                            break;
                        case "NotEqual":
                            conditions += $" AND {name} !='{jsonParam.columnValue}'";
                            break;
                        case "GreaterOrEqual"://大于等于
                            conditions += $" AND {name} >='{jsonParam.columnValue}'";
                            break;
                        case "Greater"://大于
                            conditions += $" AND {name} >'{jsonParam.columnValue}'";
                            break;
                        case "LessOrEqual"://小于等于
                            conditions += $" AND {name} <='{jsonParam.columnValue}'";
                            break;
                        case "Less"://小于
                            conditions += $" AND {name} <'{jsonParam.columnValue}'";
                            break;
                        default:
                            break;
                    }
                }
            }

        sql += conditions;
        countSql += conditions;
        int total = await Db.Ado.GetIntAsync(countSql);

        sql = "SELECT * FROM (SELECT *, ROW_NUMBER() OVER (ORDER BY " + filter.orderBy + ") NUM FROM (SELECT * FROM (" + sql + " ";
        sql += ") A ) B ) C";

        sql += " WHERE NUM <= " + filter.pageNum * filter.pageSize + " AND NUM >" + (filter.pageNum - 1) * filter.pageSize;

        var entitys = await Db.Ado.SqlQueryAsync<Ghre_StudyRecordESS>(sql);
        var dt = DateTime.Now.Date;
        entitys.ForEach(x =>
        {
            if (x.CourseBeginDate != null && x.CourseEndDate != null)
                x.CourseDateString = DateTimeHelper.ConvertToDayString(x.CourseBeginDate) + "~" + DateTimeHelper.ConvertToDayString(x.CourseEndDate);

            if (!x.ExamId.IsNull())
            {
                if (x.ExamBeginDate != null && x.ExamEndDate != null)
                    x.ExamDateString = DateTimeHelper.ConvertToDayString(x.ExamBeginDate) + "~" + DateTimeHelper.ConvertToDayString(x.ExamEndDate);
                else x.ExamDateString = $"学完{x.AfterHowLong}天";
            }

            //if (x.CourseBeginDate != null && x.CourseEndDate != null)
            //    if (x.StudyProgress >= 100 || !(x.CourseBeginDate.Value.Date <= DateTime.Now.Date && x.CourseEndDate.Value.Date >= DateTime.Now.Date))
            //        x.DisableStudyBtn = true;

            if (x.StudyProgress < 100 || x.ExamId.IsNull())
                x.DisableExamBtn = true;
            if (x.FeedbackOrderId.IsNull())
                x.ShowFeedbackBtn = false;

            #region 处理学习进度

            if (x.ExamId.IsNull())
                x.ShowExamBtn = false;

            if (!x.ExamId.IsNull() && x.FeedbackOrderId.IsNull())
            {
                if (x.ExamStatus == DIC_EXAM_RECORD_STATUS.WAIT || x.ExamStatus.IsNull())
                    x.StudyProgress = x.StudyProgress / 2;
                else if (x.ExamStatus == DIC_EXAM_RECORD_STATUS.EXAMING)
                    x.StudyProgress = 75;
                else if (x.ExamStatus == DIC_EXAM_RECORD_STATUS.EXAM_END)
                    x.StudyProgress = 100;
            }

            if (!x.ExamId.IsNull() && !x.FeedbackOrderId.IsNull())
            {
                if (x.ExamStatus == DIC_EXAM_RECORD_STATUS.WAIT)
                    x.StudyProgress = x.StudyProgress / 3;
                else if (x.ExamStatus == DIC_EXAM_RECORD_STATUS.EXAMING)
                    x.StudyProgress = 45;
                else if (x.ExamStatus == DIC_EXAM_RECORD_STATUS.EXAM_END)
                    x.StudyProgress = 60;
            }
            #endregion
        });

        return new ServicePageResult<Ghre_StudyRecordESS>(filter.pageNum, total, filter.pageSize, entitys);

    }

    #endregion 

    #region 获取课程
    /// <summary>
    /// 获取课程
    /// </summary>
    /// <param name="courseId"></param> 
    /// <returns></returns>
    public async Task<ServiceResult<Ghre_StudyRecordCourse>> QueryCourse(QueryBody body, long id)
    {
        var course = new Ghre_StudyRecordCourse();

        string sql = @$"SELECT A.Id,
                               A.CourseId,
                               A.CourseSceneId,
                               ISNULL (B.CourseName, G.SceneName) CourseName,
                               B.UseDefaultCoverImage,
                               B.DefaultCoverImageName,
                               B.CoverUrl,
                               B.SchoolTeacherId,
                               B.SchoolId,
                               B.InOrOut,
                               E.TeacherName,
                               --  E.TeacherEName,


                               CASE B.InOrOut
                                  WHEN 'In' THEN C.StaffEname
                                  WHEN 'Out' THEN NULL
                                  ELSE NULL
                               END AS TeacherEName,
                               E.PhotoUrl TeacherPhotoUrl,
                               CASE B.InOrOut
                                  WHEN 'In'
                                  THEN
                                     dbo.FO_DeptInfo (E.DeptID,
                                                      getdate (),
                                                      1,
                                                      'DeptFullPateName')
                                  WHEN 'Out'
                                  THEN
                                     F.SchoolName
                                  ELSE
                                     NULL
                               END AS DeptOrSchoolName,
                               E.SkillPoints TeacherRemarkSz,
                               B.StandardHour,
                               B.CreditPoints,
                               B.Outline CourseRemarkSz,
                               A.StudyProgress,
                               A.CourseBeginTime,
                               A.CourseEndTime,
                               A.StandardDuration CourseStandardDuration,
                               A.StudyDuration
                        FROM Ghre_StudyRecord A
                             LEFT JOIN Ghre_Course B ON A.CourseId = B.Id
                             LEFT JOIN Ghra_Staff c ON B.TeacherId = c.StaffID
                             LEFT JOIN Ghre_Teacher E ON B.SchoolTeacherId = E.Id
                             LEFT JOIN Ghre_School F ON B.SchoolId = F.Id
                             LEFT JOIN Ghre_CourseScene G ON A.CourseSceneId = G.Id
                        WHERE A.Id = '{id}'";
        course = await Db.Ado.SqlQuerySingleAsync<Ghre_StudyRecordCourse>(sql);
        if (course.IsNull())
            return ServiceResult<Ghre_StudyRecordCourse>.OprateFailed("无效的学习记录ID！");

        if (course.CourseSceneId.IsNull())
        {
            sql = @$"SELECT A.Id, A.Source, A.Link
                        FROM Ghre_CourseWare A
                        WHERE A.CourseIds LIKE '%{course.CourseId}%' AND A.IsEnable = 1";

            course.CourseWareList = await Db.Ado.SqlQueryAsync<Ghre_StudyRecordCourseWare>(sql);

            course.CourseWareList.ForEach(x =>
            {
                x.CourseId = course.CourseId;
                x.CourseName = course.CourseName;
            });
            course.CourseTeacherList =
            [
                new Ghre_StudyRecordCourseTeacher() {
                    TeacherName = course.TeacherName,
                    TeacherEName = course.TeacherEName,
                    TeacherPhotoUrl = course.TeacherPhotoUrl,
                    DeptOrSchoolName = course.DeptOrSchoolName,
                    TeacherRemarkSz = course.TeacherRemarkSz
                }
            ];
        }
        else
        {
            course.CourseWareList = new List<Ghre_StudyRecordCourseWare>();
            course.CourseTeacherList = new List<Ghre_StudyRecordCourseTeacher>();
            var courses = await Db.Queryable<Ghre_Course>().Where(x => x.CourseSceneId == course.CourseSceneId && x.Status == Consts.DIC_COURSE_STATUS.RELEASED).ToListAsync();

            for (int i = 0; i < courses.Count; i++)
            {
                var course1 = courses[i];

                sql = @$"SELECT A.Id, A.Source, A.Link
                        FROM Ghre_CourseWare A
                        WHERE A.CourseIds LIKE '%{course1.Id}%' AND A.IsEnable = 1";

                var courseWareList = await Db.Ado.SqlQueryAsync<Ghre_StudyRecordCourseWare>(sql);
                courseWareList.ForEach(x =>
                {
                    x.CourseId = course.CourseId;
                    x.CourseName = course.CourseName;
                });
                course.CourseWareList.AddRange(courseWareList);



                sql = $@"SELECT a.ID,
                               C.TeacherName,
                               CASE A.InOrOut
                                  WHEN 'In' THEN B.StaffEname
                                  WHEN 'Out' THEN NULL
                                  ELSE NULL
                               END AS TeacherEName,
                               C.PhotoUrl TeacherPhotoUrl,
                               CASE A.InOrOut
                                  WHEN 'In'
                                  THEN
                                     dbo.FO_DeptInfo (b.DeptID,
                                                      getdate (),
                                                      1,
                                                      'DeptFullPateName')
                                  WHEN 'Out'
                                  THEN
                                     D.SchoolName
                                  ELSE
                                     NULL
                               END AS DeptOrSchoolName,
                               c.SkillPoints TeacherRemarkSz,
                               a.CourseName
                        FROM Ghre_Course A
                             LEFT JOIN Ghra_Staff B ON A.TeacherId = B.StaffID
                             LEFT JOIN Ghre_Teacher C ON A.SchoolTeacherId = C.Id
                             LEFT JOIN Ghre_School D ON C.SchoolId = D.Id
                        WHERE a.id = '{course1.Id}'";

                course.CourseTeacherList.Add(await Db.Ado.SqlQuerySingleAsync<Ghre_StudyRecordCourseTeacher>(sql));

            }
        }

        for (int j = 0; j < course.CourseWareList.Count; j++)
        {
            course.CourseWareList[j].Attachments = await Db.Queryable<Ghre_CourseWareAttachment>().Where(x => x.CourseWareId == course.CourseWareList[j].Id).ToListAsync();
        }

        if (course.CourseBeginTime != null && course.CourseEndTime != null)
            course.CourseDateString = DateTimeHelper.ConvertToDayString(course.CourseBeginTime) + "~" + DateTimeHelper.ConvertToDayString(course.CourseEndTime);

        if (course.CourseStandardDuration.IsNull())
        {
            sql = $@"SELECT ISNULL (A.Hours, 0) * 60 + A.Minutes Minutes
                            FROM Ghre_CourseWare A
                            WHERE A.Id IN
                                     (SELECT CourseWareId
                                      FROM Ghre_Course
                                      WHERE    Id = '{course.CourseId}'
                                            OR CourseSceneId = '{course.CourseSceneId}' AND IsEnable = 1)";
            var mins = await Db.Ado.GetDecimalAsync(sql);

            course.CourseStandardDuration = mins;
        }
        if (course.StudyDuration.IsNull()) course.StudyDuration = 0;
        return ServiceResult<Ghre_StudyRecordCourse>.OprateSuccess("查询成功！", course);
    }

    #endregion

    #region 加入学习
    public async Task<ServiceResult> Join(long courseId)
    {
        var staffId = GetStaffId();
        if (!await base.AnyAsync(x => x.CourseId == courseId && x.StaffId == staffId))
        {
            var course = await Db.Queryable<Ghre_Course>().Where(x => x.Id == courseId && x.Status == DIC_COURSE_STATUS.RELEASED).FirstAsync();
            if (course.IsNull())
                return ServiceResult.OprateFailed("无效的课程！");

            DateTime courseTime = Db.GetDate();
            var snap = await Db.Queryable<Ghre_CourseSnap>().FirstAsync(x => x.CourseId == courseId);

            var exam = await Db.Queryable<Ghre_Exam>()
                .Where(x => x.Status == DIC_EXAM_STATUS.RELEASED &&
                x.CourseId == courseId
                && ((x.DateType == DicExamDateType.EXAM_DATE
                && x.BeginTime.Value.Date <= DateTime.Now.Date && x.EndTime.Value.Date >= DateTime.Now.Date) || x.DateType == DicExamDateType.AFTER_HOW_LONG))
                .FirstAsync();
            await base.Add(new InsertGhre_StudyRecordInput
            {
                StaffId = staffId,
                CourseSnapId = snap?.Id,
                CourseId = courseId,
                JoinTime = courseTime,
                CourseBeginTime = courseTime.Date,
                CourseEndTime = courseTime.Date.AddMonths(snap?.ValidityPeriod ?? 1),
                CourseType = "ManualElective",
                CourseStatus = DIC_STUDY_RECORD_COURSE_STATUS_IN,
                StudyStatus = DIC_STUDY_RECORD_STUDY_STATUS.NO_JOIN,
                ExamId = exam?.Id
            });
        }
        return ServiceResult.OprateSuccess("加入成功！");
    }
    #endregion

    #region 记录学习时长
    public async Task<ServiceResult> RecordDuration(long studyRecordId, decimal? duration)
    {
        var staffId = GetStaffId();
        var sql = $"UPDATE Ghre_StudyRecord SET StudyDuration = ISNULL(StudyDuration, 0)+{duration} WHERE Id='{studyRecordId}' AND  StaffId='{staffId}'";
        await Db.Ado.ExecuteCommandAsync(sql);

        await Task.Factory.StartNew(async () => await GenerateStaffStudyRecord(Db, studyRecordId));


        return ServiceResult.OprateSuccess("记录成功！");
    }

    public async Task<bool> GenerateStaffStudyRecord(ISqlSugarClient Db, long studyRecordId)
    {
        var record = await Db.Queryable<Ghre_StudyRecord>().FirstAsync(x => x.Id == studyRecordId);


        decimal studyProgress = 0;
        var sql = $@"SELECT ISNULL (A.Hours, 0) * 60 + A.Minutes Minutes
                            FROM Ghre_CourseWare A
                            WHERE A.Id IN
                                     (SELECT CourseWareId
                                      FROM Ghre_Course
                                      WHERE    Id = '{record.CourseId}'
                                            OR CourseSceneId = '{record.CourseSceneId}' AND IsEnable = 1)";
        var mins = await Db.Ado.GetDecimalAsync(sql);

        if (mins > 0)
        {
            var duration = record.StudyDuration ?? 0;
            studyProgress = (duration / mins) * 100;
            if (studyProgress > 100)
                studyProgress = 100;
        }

        var studyStatus = DIC_STUDY_RECORD_STUDY_STATUS.NO_FINISH;
        if (studyProgress == 100)
            studyStatus = DIC_STUDY_RECORD_STUDY_STATUS.HAS_FINISH;

        sql = $"UPDATE Ghre_StudyRecord SET StudyProgress = {studyProgress},StudyStatus='{studyStatus}',StandardDuration='{mins}' WHERE Id='{studyRecordId}'";
        if (studyProgress > 0) await Db.Ado.ExecuteCommandAsync(sql);
        sql = $"UPDATE Ghre_StudyRecord SET BeginTime=GETDATE(),StudyStatus='{studyStatus}' WHERE BeginTime IS NULL AND Id='{studyRecordId}'";
        await Db.Ado.ExecuteCommandAsync(sql);

        if (studyProgress == 100)
        {
            sql = $"UPDATE Ghre_StudyRecord SET EndTime=GETDATE() WHERE EndTime IS NULL AND Id='{studyRecordId}'";
            await Db.Ado.ExecuteCommandAsync(sql);
        }
        return true;
    }
    #endregion

}