using Furion.DependencyInjection;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using RoadFlow.Utility;
using Microsoft.Extensions.Localization;
using Newtonsoft.Json.Linq;
using Ewide.Core;
using System.IO;
using Microsoft.Extensions.Caching.Memory;
using Furion;

namespace RoadFlow.Data
{
    public class Flow : RoadFlowRepository<RoadFlow.Model.rf_flow>, IFlow, ITransient
    {
        IUserManager _userManager = App.GetService<IUserManager>();
        

        /// <summary>
        /// 查询一页数据
        /// </summary>
        /// <param name="count"></param>
        /// <param name="size"></param>
        /// <param name="number"></param>
        /// <param name="flowId">可管理的流程ID</param>
        /// <param name="whereLambda"></param>
        /// <param name="orderbyLambda"></param>
        /// <param name="isAsc"></param>
        /// <returns></returns>
        public List<Model.rf_flow> GetPagerList(out int count, int size, int number,
            List<string> flowIdList, string name, List<string> types, string order, int status = -1)
        {


            int total = 0;
            var list = db.Queryable<Model.rf_flow>()
              .WhereIF(status != -1, a => a.Status == status)
              .WhereIF(status == -1, a => a.Status != 3)
              .WhereIF(flowIdList != null && flowIdList.Count > 0, a => flowIdList.Contains(a.Id))
              //.WhereIF(flowIdList == null || flowIdList.Count == 0, a => 1 == 0)
              .WhereIF(!name.IsNullOrWhiteSpace(), a => a.Name.Contains(name.Trim()))
              .WhereIF(types != null && types.Count > 0, a => types.Contains(a.FlowType))
              .Select(a => new Model.rf_flow { Id = a.Id, Name = a.Name, CreateDate = a.CreateDate, CreateUser = a.CreateUser, Status = a.Status, Note = a.Note, SystemId = a.SystemId })
              .ToPageList(number, size, ref total);
            
            count = total;
            return list;

        }
        public List<Model.rf_flow> GetPagerList(out int count, int size, int number, List<string> flowIdList, string name, string type, string order, int status = -1)
        { 
            List<string> types = new();
            if (!type.IsNullOrWhiteSpace())
            {
                types.Add(type);
            }
            return this.GetPagerList(out count, size, number, flowIdList, name, types, order, status);
        }

        /// <summary>
        /// 得到一个用户可管理的流程
        /// </summary>
        /// <param name="userId"></param>
        /// <returns></returns>
        public List<string> GetManageFlowIds(string userId)
        {
            var flows = GetManageFlow(userId);
            List<string> guids = new List<string>();
            foreach (var flow in flows)
            {
                guids.Add(flow.Id);
            }
            return guids;
        }

        /// <summary>
        /// 得到一个用户可管理的流程
        /// </summary>
        /// <param name="userId"></param>
        /// <returns></returns>
        public List<Model.rf_flow> GetManageFlow(string userId)
        {
            var all = GetAll();
            if (all.Count == 0)
            {
                return new();
            }
            return all.FindAll(p => p.Manager.ContainsIgnoreCase(userId));
        }

        /// <summary>
        /// 得到状态显示
        /// </summary>
        /// <param name="status"></param>
        /// <param name="localizer">语言包</param>
        /// <returns></returns>
        public string GetStatusTitle(int status, IStringLocalizer localizer = null)
        {
            switch (status)
            {
                case 0:
                    return localizer == null ? "设计中" : localizer["State_Designing"].Value;
                case 1:
                    return localizer == null ? "已安装" : localizer["State_Installed"].Value;
                case 2:
                    return localizer == null ? "已卸载" : localizer["State_Uninstalled"].Value;
                case 3:
                    return localizer == null ? "已删除" : localizer["State_Deleted"].Value;
                default:
                    return string.Empty;
            }
        }


        /// <summary>
        /// 保存流程
        /// </summary>
        /// <param name="json"></param>
        /// <param name="localizer">语言包</param>
        /// <returns></returns>
        public string Save(string json, IStringLocalizer localizer = null)
        {
            JObject jObject;
            try
            {
                jObject = JObject.Parse(json);
            }
            catch
            {
                return localizer == null ? "JSON解析错误" : localizer["Save_JsonParseError"].Value;
            }
            if (null == jObject)
            {
                return localizer == null ? "JSON解析错误" : localizer["Save_JsonParseError"].Value;
            }
            string flowId = jObject.Value<string>("id");
            string name = jObject.Value<string>("name");
            string type = jObject.Value<string>("type");
            string systemId = jObject.Value<string>("systemId");
            if (!flowId.IsGuid(out Guid fid))
            {
                return localizer == null ? "流程ID错误" : localizer["Save_FlowIdError"].Value;
            }
            if (name.IsNullOrWhiteSpace())
            {
                return localizer == null ? "流程名称为空" : localizer["Save_FlowNameEmpty"].Value;
            }
            if (!type.IsGuid(out Guid typeId))
            {
                return localizer == null ? "流程分类错误" : localizer["Save_FlowTypeError"].Value;
            }

            Model.rf_flow flowModel = this.Get(flowId);
            bool isAdd = false;
            if (null == flowModel)
            {
                isAdd = true;
                flowModel = new Model.rf_flow
                {
                    Id = flowId,
                    CreateDate = DateExtensions.Now,
                    CreateUser = _userManager.UserId,
                    Status = 0
                };
            }
            flowModel.DesignerJSON = json;
            flowModel.InstanceManager = jObject.Value<string>("instanceManager");
            flowModel.Manager = jObject.Value<string>("manager");
            flowModel.Name = name;
            flowModel.FlowType = type;
            flowModel.Note = jObject.Value<string>("note");
            flowModel.SystemId = systemId.IsGuid(out Guid guid) ? systemId : new Guid().ToString();
            if (isAdd)
            {
                this.Add(flowModel);
            }
            else
            {
                this.Update(flowModel);
            }
            new Log().Add("保存了流程-" + flowModel.Name, _userManager.UserId, json, LogType.流程管理);
            return "1";
        }

        /// <summary>
        /// 查询一个流程
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public Model.rf_flow Get(string id)
        {
            return GetOneById(id);//GetAll().Find(p => p.Id == id);
        }


        /// <summary>
        /// 流程另存为
        /// </summary>
        /// <param name="flowId">流程ID</param>
        /// <param name="newFlowName">新的流程名称</param>
        /// <returns>返回guid字符串表示成功(新流程的ID)，其它为错误信息</returns>
        /// <param name="localizer">语言包</param>
        public string SaveAs(string flowId, string newFlowName, IStringLocalizer localizer = null)
        {
            var flowModel = Get(flowId);
            if (null == flowModel)
            {
                return localizer == null ? "未找到要另存的流程!" : localizer["SaveAsSave_NotFindFlow"];
            }
            flowModel.Id = GuidExtensions.NewGuid().ToString();
            flowModel.CreateDate = DateExtensions.Now;
            if (flowModel.InstallDate.HasValue)
            {
                flowModel.InstallDate = flowModel.CreateDate;
            }
            flowModel.Name = newFlowName;
            JObject jObject = null;
            if (!flowModel.RunJSON.IsNullOrWhiteSpace())
            {
                jObject = JObject.Parse(flowModel.RunJSON);
            }
            else if (!flowModel.DesignerJSON.IsNullOrWhiteSpace())
            {
                jObject = JObject.Parse(flowModel.DesignerJSON);
            }
            if (jObject != null)
            {
                jObject["id"] = flowModel.Id.ToString();
                jObject["name"] = flowModel.Name;
                JArray lines = jObject.Value<JArray>("lines");
                foreach (JObject stepJObject in jObject.Value<JArray>("steps"))
                {
                    string stepNewId = GuidExtensions.NewGuid().ToString();
                    string stepOldId = stepJObject.Value<string>("id");
                    foreach (JObject lineJObject in lines)
                    {
                        if (lineJObject.Value<string>("from").EqualsIgnoreCase(stepOldId))
                        {
                            lineJObject["from"] = stepNewId;
                        }
                        if (lineJObject.Value<string>("to").EqualsIgnoreCase(stepOldId))
                        {
                            lineJObject["to"] = stepNewId;
                        }
                    }
                    stepJObject["id"] = stepNewId;
                }
                foreach (JObject lineJObject1 in lines)
                {
                    lineJObject1["id"] = GuidExtensions.NewGuid().ToString();
                }
            }
            string json = jObject.ToString(Newtonsoft.Json.Formatting.None);
            if (!flowModel.RunJSON.IsNullOrWhiteSpace())
            {
                flowModel.RunJSON = json;
            }
            if (!flowModel.DesignerJSON.IsNullOrWhiteSpace())
            {
                flowModel.DesignerJSON = json;
            }
            Add(flowModel);
            return flowModel.Id.ToString();
        }



        /// <summary>
        /// 安装流程
        /// </summary>
        /// <param name="json"></param>
        /// <param name="logTitle">日志标题</param>
        /// <param name="localizer">语言包</param>
        /// <returns></returns>
        public string Install(string json, IStringLocalizer localizer = null)
        {
            string saveMsg = Save(json, localizer);
            if (!"1".Equals(saveMsg))
            {
                return saveMsg;
            }
            var flowRunModel = GetFlowRunModel(json, out string errMsg, localizer: localizer);
            if (null == flowRunModel)
            {
                return errMsg;
            }
            var flowModel = Get(flowRunModel.Id.ToString());
            if (null == flowModel)
            {
                return localizer == null ? "未找到流程实体" : localizer["Install_NoFindFlowModel"].Value;
            }
            flowModel.InstallDate = DateExtensions.Now;
            flowModel.InstallUser = _userManager.UserId;
            flowModel.RunJSON = json;
            flowModel.Status = 1;
            this.Install(flowModel);
            //清除运行时缓存
            ClearCache(flowModel.Id);
            new Log().Add("发布安装了流程-" + flowModel.Name, _userManager.UserId, json, LogType.流程管理, others: errMsg);
            return "1";
        }

        /// <summary>
        /// 安装流程
        /// </summary>
        /// <param name="flow">流程实体</param>
        /// <param name="appLibrary">应用程序库实体</param>
        public int Install(Model.rf_flow flow)
        {
            //取消了事务，sqlsugra的事务没弄懂
            #region 加入到应用程序库

            var applibraryModel = new Applibrary().GetAll().Find(p => p.Code.EqualsIgnoreCase(flow.Id.ToString()));
            bool isAdd = false;
            if (null == applibraryModel)
            {
                isAdd = true;
                applibraryModel = new Model.rf_applibrary
                {
                    Id = GuidExtensions.NewGuid().ToString()
                };
            }
            applibraryModel.Title = flow.Name;
            applibraryModel.Address = "/flow/run/index?flowid=" + flow.Id.ToString();
            applibraryModel.Code = flow.Id.ToString();
            applibraryModel.OpenMode = 0;
            applibraryModel.Type = flow.FlowType;
            applibraryModel.Note = flow.Note;

            //多语言设定流程名称(这里暂时设定一样，没有区分语言)
            applibraryModel.Title_en = applibraryModel.Title_en.IsNullOrWhiteSpace() ? flow.Name : applibraryModel.Title_en;
            applibraryModel.Title_zh = applibraryModel.Title_zh.IsNullOrWhiteSpace() ? flow.Name : applibraryModel.Title_zh;

            if (isAdd)
            {
                new Applibrary().Add(applibraryModel);
            }
            else
            {
                new Applibrary().Update(applibraryModel);
            }
            #endregion
            this.Update(flow);
            ClearCache();
            new Applibrary().ClearCache();
            return 1;
        }



        /// <summary>
        /// 卸载或作删除标记流程
        /// </summary>
        /// <param name="json"></param>
        /// <param name="logTitle">日志标题</param>
        /// <param name="status">状态，2卸载 3删除</param>
        /// <param name="localizer">语言包</param>
        /// <returns></returns>
        public string UnInstall(string json, int status, IStringLocalizer localizer = null)
        {
            JObject jObject;
            try
            {
                jObject = JObject.Parse(json);
            }
            catch
            {
                return localizer == null ? "JSON解析错误" : localizer["Save_JsonParseError"].Value;
            }
            if (null == jObject)
            {
                return localizer == null ? "JSON解析错误" : localizer["Save_JsonParseError"].Value;
            }
            string flowId = jObject.Value<string>("id");
            if (!flowId.IsGuid(out Guid flowGuid))
            {
                return localizer == null ? "流程id错误" : localizer["Save_JsonParseError"].Value;
            }
            var flowModel = Get(flowGuid.ToString());
            if (null == flowModel)
            {
                return localizer == null ? "未找到流程实体" : localizer["Install_NoFindFlowModel"].Value;
            }
            flowModel.Status = status;
            Update(flowModel);
            //清除运行时缓存
            ClearCache(flowModel.Id);
            new Log().Add((status == 2 ? "卸载" : status == 3 ? "作删除标记" : "") + "流程-" + flowModel.Name,_userManager.UserId, json, LogType.流程管理);
            return "1";
        }


        /// <summary>
        /// 得到流程运行时实体
        /// </summary>
        /// <param name="json">流程设置JSON</param>
        /// <param name="errMsg">加载错误时的错误信息</param>
        /// <param name="localizer">语言包</param>
        /// <returns></returns>
        public Model.FlowRun GetFlowRunModel(string json, out string errMsg, IStringLocalizer localizer = null)
        {
            errMsg = string.Empty;
            JObject jObject = null;
            try
            {
                jObject = JObject.Parse(json);
            }
            catch
            {
                errMsg = localizer == null ? "JSON解析错误" : localizer["Save_JsonParseError"].Value;
                return null;
            }
            if (null == jObject)
            {
                errMsg = localizer == null ? "JSON解析错误" : localizer["Save_JsonParseError"].Value;
                return null;
            }
            string id = jObject.Value<string>("id");
            string name = jObject.Value<string>("name");
            string type = jObject.Value<string>("type");
            string systemId = jObject.Value<string>("systemId");
            string mananger = jObject.Value<string>("manager");
            string instanceManager = jObject.Value<string>("instanceManager");
            if (!id.IsGuid(out Guid flowId))
            {
                errMsg = localizer == null ? "流程ID错误" : localizer["Save_FlowIdError"].Value;
                return null;
            }
            if (name.IsNullOrWhiteSpace())
            {
                errMsg = localizer == null ? "流程名称为空" : localizer["Save_FlowNameEmpty"].Value;
                return null;
            }
            if (!type.IsGuid(out Guid typeId))
            {
                errMsg = localizer == null ? "流程分类错误" : localizer["Save_FlowTypeError"].Value;
                return null;
            }
            if (mananger.IsNullOrWhiteSpace())
            {
                errMsg = localizer == null ? "流程管理者为空" : localizer["Install_ManagerEmpty"].Value;
                return null;
            }
            if (instanceManager.IsNullOrWhiteSpace())
            {
                errMsg = localizer == null ? "流程实例管理者为空" : localizer["Install_InstanceManagerEmpty"].Value;
                return null;
            }
            var flowModel = Get(id);
            if (null == flowModel)
            {
                errMsg = localizer == null ? "未找到该流程" : localizer["Install_NoFindFlowModel"].Value;
                return null;
            }
            var flowRunModel = new Model.FlowRun
            {
                Id = flowId,
                Name = name,
                Type = typeId,
                Manager = mananger,
                InstanceManager = instanceManager,
                FirstStepId = Guid.Empty,
                Note = jObject.Value<string>("note"),
                SystemId = systemId.IsGuid(out Guid guid) ? guid : new Guid?(),
                Debug = jObject.Value<string>("debug").IsInt(out int debug) ? debug : 0,
                DebugUserIds = new Organize().GetAllUsersId(jObject.Value<string>("debugUsers")),
                Status = flowModel.Status,
                CreateDate = flowModel.CreateDate,
                CreateUserId = flowModel.CreateUser,
                InstallDate = flowModel.InstallDate,
                InstallUserId = flowModel.InstallUser,
                Ico = jObject.Value<string>("ico"),
                Color = jObject.Value<string>("color")
            };

            #region 流程数据库连接信息
            JArray dbsArray = jObject.Value<JArray>("databases");
            List<Model.FlowRunModel.Database> databases = new List<Model.FlowRunModel.Database>();
            if (null != dbsArray)
            {
                foreach (JObject dbs in dbsArray)
                {
                    Model.FlowRunModel.Database database = new Model.FlowRunModel.Database
                    {
                        ConnectionId = dbs.Value<string>("link").IsGuid(out Guid cid) ? cid : Guid.Empty,
                        ConnectionName = dbs.Value<string>("linkName"),
                        Table = dbs.Value<string>("table"),
                        PrimaryKey = dbs.Value<string>("primaryKey")
                    };
                    databases.Add(database);
                }
            }
            flowRunModel.Databases = databases;
            #endregion

            #region 流程标识字段信息
            JObject titleFieldObject = jObject.Value<JObject>("titleField");
            Model.FlowRunModel.TitleField titleField = new Model.FlowRunModel.TitleField();
            if (null != titleFieldObject)
            {
                titleField.ConnectionId = titleFieldObject.Value<string>("link").IsGuid(out Guid cid) ? cid : Guid.Empty;
                titleField.Table = titleFieldObject.Value<string>("table");
                titleField.Field = titleFieldObject.Value<string>("field");
                titleField.Value = titleFieldObject.Value<string>("value");
                titleField.EventCompleted = titleFieldObject.Value<string>("eventCompleted");
                titleField.EventStop = titleFieldObject.Value<string>("eventStop");
            }
            flowRunModel.TitleField = titleField;
            #endregion

            #region 步骤基本信息
            JArray stepArray = jObject.Value<JArray>("steps");
            List<Model.FlowRunModel.Step> steps = new List<Model.FlowRunModel.Step>();
            if (null != stepArray)
            {
                foreach (JObject stepObject in stepArray)
                {
                    Model.FlowRunModel.Step stepModel = new Model.FlowRunModel.Step();
                    #region 坐标信息
                    JObject positionObject = stepObject.Value<JObject>("position");
                    if (null != positionObject)
                    {
                        stepModel.Position_X = positionObject.Value<string>("x").IsDecimal(out decimal x) ? x : 0;
                        stepModel.Position_Y = positionObject.Value<string>("y").IsDecimal(out decimal y) ? y : 0;
                    }
                    #endregion

                    #region 步骤信息
                    stepModel.Archives = stepObject.Value<string>("archives").IsBool(out bool archivesBool) ? archivesBool ? 1 : 0 : stepObject.Value<string>("archives").IsInt(out int archives) ? archives : 0;
                    stepModel.ExpiredPrompt = stepObject.Value<string>("expiredPrompt").IsBool(out bool expiredBool) ? expiredBool ? 1 : 0 : stepObject.Value<string>("expiredPrompt").IsInt(out int expiredPrompt) ? expiredPrompt : 0;
                    stepModel.ExpiredPromptDays = stepObject.Value<string>("expiredPromptDays").IsDecimal(out decimal expiredPromptDays) ? expiredPromptDays : 0;
                    stepModel.Id = stepObject.Value<string>("id").IsGuid(out Guid sid) ? sid : Guid.Empty;
                    stepModel.Type = stepObject.Value<string>("type").EqualsIgnoreCase("normal") ? 0 : 1;
                    stepModel.Name = stepObject.Value<string>("name");
                    stepModel.Dynamic = Config.EnableDynamicStep == false ? 0 : stepObject.Value<string>("dynamic").ToInt(0);
                    stepModel.DynamicField = stepObject.Value<string>("dynamicField");
                    stepModel.Note = stepObject.Value<string>("note");
                    stepModel.CommentDisplay = stepObject.Value<string>("opinionDisplay").IsBool(out bool opinionBool) ? opinionBool ? 1 : 0 : stepObject.Value<string>("opinionDisplay").IsInt(out int opinionDisplay) ? opinionDisplay : 0;
                    stepModel.SignatureType = stepObject.Value<string>("signatureType").IsInt(out int signatureType) ? signatureType : 0;
                    stepModel.WorkTime = stepObject.Value<string>("workTime").IsDecimal(out decimal workTime) ? workTime : 0;
                    stepModel.SendShowMessage = stepObject.Value<string>("sendShowMsg");
                    stepModel.BackShowMessage = stepObject.Value<string>("backShowMsg");
                    stepModel.SendSetWorkTime = stepObject.Value<string>("sendSetWorkTime").IsBool(out bool sendBool) ? sendBool ? 1 : 0 : stepObject.Value<string>("sendSetWorkTime").IsInt(out int sendSetWorkTime) ? sendSetWorkTime : 0;
                    stepModel.ExpiredExecuteModel = stepObject.Value<string>("timeOutModel").IsInt(out int timeOutModel) ? timeOutModel : 0;
                    stepModel.DataEditModel = stepObject.Value<string>("dataEditModel").IsInt(out int dataEditModel) ? dataEditModel : 0;
                    stepModel.Attachment = stepObject.Value<string>("attachment").IsBool(out bool attachmentBool) ? attachmentBool ? 1 : 0 : stepObject.Value<string>("attachment").ToInt(0);
                    stepModel.BatchExecute = stepObject.Value<string>("batch").IsBool(out bool batchBool) ? batchBool ? 1 : 0 : stepObject.Value<string>("batch").ToInt(0);

                    #region 基本信息
                    JObject baseObject = stepObject.Value<JObject>("behavior");
                    Model.FlowRunModel.StepBase stepBaseModel = new Model.FlowRunModel.StepBase();
                    if (null != baseObject)
                    {
                        stepBaseModel.BackModel = baseObject.Value<string>("backModel").IsInt(out int backModel) ? backModel : 0;
                        if (baseObject.Value<string>("backStep").IsGuid(out Guid backStepId))
                        {
                            stepBaseModel.BackStepId = backStepId;
                        }
                        stepBaseModel.BackType = baseObject.Value<string>("backType").IsInt(out int backType) ? backType : 0;
                        stepBaseModel.BackSelectUser = baseObject.Value<string>("backSelectUser").IsBool(out bool backUserBool) ? backUserBool ? 1 : 0 : baseObject.Value<string>("backSelectUser").IsInt(out int backSelectUser) ? backSelectUser : 0;
                        stepBaseModel.DefaultHandler = baseObject.Value<string>("defaultHandler");
                        stepBaseModel.FlowType = baseObject.Value<string>("flowType").IsInt(out int flowType) ? flowType : 2;
                        if (baseObject.Value<string>("handlerStep").IsGuid(out Guid handlerStepId))
                        {
                            stepBaseModel.HandlerStepId = handlerStepId;
                        }
                        stepBaseModel.HandlerType = baseObject.Value<string>("handlerType");
                        stepBaseModel.HanlderModel = baseObject.Value<string>("hanlderModel").IsInt(out int hanlderModel) ? hanlderModel : 0;
                        stepBaseModel.HanlderModelGroup = baseObject.Value<string>("hanlderModelGroup").IsInt(out int hanlderModelGroup) ? hanlderModelGroup : 0;
                        stepBaseModel.Percentage = baseObject.Value<string>("percentage").IsDecimal(out decimal percentage) ? percentage : 0;
                        stepBaseModel.RunSelect = baseObject.Value<string>("runSelect").IsBool(out bool runBool) ? runBool ? 1 : 0 : baseObject.Value<string>("runSelect").IsInt(out int runSelect) ? runSelect : 0;
                        stepBaseModel.SelectRange = baseObject.Value<string>("selectRange");
                        stepBaseModel.SelectRangeForDefaultHandler = baseObject.Value<string>("selectRangeForDefaultHandler").ToInt(-1);
                        stepBaseModel.ValueField = baseObject.Value<string>("valueField");
                        stepBaseModel.LastHadler = baseObject.Value<string>("lastHandler").IsBool(out bool lastBool) ? lastBool ? 1 : 0 : baseObject.Value<string>("lastHandler").IsInt(out int lastHandler) ? lastHandler : 0;
                        stepBaseModel.Countersignature = baseObject.Value<string>("countersignature").IsInt(out int countersignature) ? countersignature : 0;
                        stepBaseModel.CountersignatureStartStepId = baseObject.Value<string>("countersignatureStartStep").IsGuid(out Guid countersignatureStartStepId) ? new Guid?(countersignatureStartStepId) : new Guid?();
                        stepBaseModel.CountersignaturePercentage = baseObject.Value<string>("countersignaturePercentage").IsDecimal(out decimal countersignaturePercentage) ? countersignaturePercentage : 0;
                        stepBaseModel.SubFlowStrategy = baseObject.Value<string>("subflowstrategy").IsInt(out int subflowstrategy) ? subflowstrategy : 0;
                        stepBaseModel.ConcurrentModel = baseObject.Value<string>("concurrentModel").IsBool(out bool concurrentBool) ? concurrentBool ? 1 : 0 : baseObject.Value<string>("concurrentModel").IsInt(out int concurrentModel) ? concurrentModel : 0;
                        stepBaseModel.DefaultHandlerSqlOrMethod = baseObject.Value<string>("defaultHandlerSqlOrMethod");
                        stepBaseModel.AutoConfirm = baseObject.Value<string>("autoConfirm").IsBool(out bool autoBool) ? autoBool ? 1 : 0 : baseObject.Value<string>("autoConfirm").ToInt(0);
                        stepBaseModel.SkipIdenticalUser = baseObject.Value<string>("skipIdenticalUser").IsBool(out bool skipBool) ? skipBool ? 1 : 0 : baseObject.Value<string>("skipIdenticalUser").ToInt(0);
                        stepBaseModel.SkipMethod = baseObject.Value<string>("skipMethod");
                        stepBaseModel.SendToBackStep = baseObject.Value<string>("sendToBackStep").IsBool(out bool sendToBool) ? sendToBool ? 1 : 0 : baseObject.Value<string>("sendToBackStep").ToInt(0);
                    }
                    stepModel.StepBase = stepBaseModel;
                    #endregion

                    #region 抄送
                    Model.FlowRunModel.StepCopyFor stepCopyForModel = new Model.FlowRunModel.StepCopyFor();
                    JObject copyForObject = stepObject.Value<JObject>("copyFor");
                    if (null != copyForObject)
                    {
                        stepCopyForModel.MemberId = copyForObject.Value<string>("memberId");
                        stepCopyForModel.HandlerType = copyForObject.ContainsJArray("handlerType", out string handlerString) ? handlerString : copyForObject.Value<string>("handlerType");
                        stepCopyForModel.Steps = copyForObject.ContainsJArray("steps", out string stepsString) ? stepsString : copyForObject.Value<string>("steps");
                        stepCopyForModel.MethodOrSql = copyForObject.Value<string>("methodOrSql");
                        stepCopyForModel.CopyforTime = copyForObject.Value<string>("time").ToInt(0);
                        stepCopyForModel.SendMessageType = copyForObject.ContainsJArray("messageType", out string msgTypeString) ? msgTypeString : copyForObject.Value<string>("messageType");
                    }
                    stepModel.StepCopyFor = stepCopyForModel;
                    #endregion

                    #region 按钮信息
                    List<Model.FlowRunModel.StepButton> stepButtons = new List<Model.FlowRunModel.StepButton>();
                    JArray buttonArray = stepObject.Value<JArray>("buttons");
                    if (null != buttonArray)
                    {
                        foreach (JObject buttonObject in buttonArray)
                        {
                            Model.FlowRunModel.StepButton stepButtonModel = new Model.FlowRunModel.StepButton();
                            if (buttonObject.Value<string>("id").IsGuid(out Guid bid))
                            {
                                var flowButtonModel = new FlowButton().Get(bid.ToString());
                                stepButtonModel.Id = bid;
                                stepButtonModel.Note = "";
                                string showTitle = buttonObject.Value<string>("showTitle");
                                stepButtonModel.ShowTitle = showTitle;
                                stepButtonModel.Sort = buttonObject.Value<int>("sort");
                                //2020-11-24注释掉，便于多语言时，没有设置ShowTitle时根据语言读取按钮Title。
                                //if (null != flowButtonModel)
                                //{
                                //    stepButtonModel.Note = flowButtonModel.Note;
                                //    stepButtonModel.ShowTitle = showTitle.IsNullOrWhiteSpace() ? flowButtonModel.Title : showTitle;
                                //}
                            }
                            stepButtons.Add(stepButtonModel);
                        }
                    }
                    stepModel.StepButtons = stepButtons;
                    #endregion

                    #region 事件
                    JObject eventObject = stepObject.Value<JObject>("event");
                    Model.FlowRunModel.StepEvent stepEventModel = new Model.FlowRunModel.StepEvent();
                    if (null != eventObject)
                    {
                        stepEventModel.BackAfter = eventObject.Value<string>("backAfter");
                        stepEventModel.BackPassAfter = eventObject.Value<string>("backPassAfter");
                        stepEventModel.BackBefore = eventObject.Value<string>("backBefore");
                        stepEventModel.SubmitAfter = eventObject.Value<string>("submitAfter");
                        stepEventModel.SubmitPassAfter = eventObject.Value<string>("submitPassAfter");
                        stepEventModel.SubmitBefore = eventObject.Value<string>("submitBefore");
                        stepEventModel.SubFlowActivationBefore = eventObject.Value<string>("subflowActivationBefore");
                        stepEventModel.SubFlowCompletedBefore = eventObject.Value<string>("subflowCompletedBefore");
                    }
                    stepModel.StepEvent = stepEventModel;
                    #endregion

                    #region 表单
                    JArray formArray = stepObject.Value<JArray>("forms");
                    Model.FlowRunModel.StepForm stepFormModel = new Model.FlowRunModel.StepForm();
                    if (null != formArray && formArray.Count > 0)
                    {
                        JObject formObject = (JObject)formArray.First;
                        if (formObject.Value<string>("id").IsGuid(out Guid formId))
                        {
                            stepFormModel.Id = formId;
                        }
                        stepFormModel.Name = formObject.Value<string>("name");
                        if (formObject.Value<string>("idApp").IsGuid(out Guid appId))
                        {
                            stepFormModel.MobileId = appId;
                        }
                        stepFormModel.MobileName = formObject.Value<string>("nameApp");
                    }
                    stepModel.StepForm = stepFormModel;
                    #endregion

                    #region 字段状态
                    JArray fieldArray = stepObject.Value<JArray>("fieldStatus");
                    List<Model.FlowRunModel.StepFieldStatus> stepFieldStatuses = new List<Model.FlowRunModel.StepFieldStatus>();
                    if (null != fieldArray)
                    {
                        foreach (JObject fieldObject in fieldArray)
                        {
                            Model.FlowRunModel.StepFieldStatus stepFieldStatusModel = new Model.FlowRunModel.StepFieldStatus
                            {
                                Check = fieldObject.Value<string>("check").IsInt(out int check) ? check : 0,
                                Field = fieldObject.Value<string>("field"),
                                Status = fieldObject.Value<string>("status").IsInt(out int status) ? status : 0
                            };
                            stepFieldStatuses.Add(stepFieldStatusModel);
                        }
                    }
                    stepModel.StepFieldStatuses = stepFieldStatuses;
                    #endregion

                    #region 子流程
                    JObject subflowObject = stepObject.Value<JObject>("subflow");
                    Model.FlowRunModel.StepSubFlow stepSubFlowModel = new Model.FlowRunModel.StepSubFlow();
                    if (null != subflowObject)
                    {
                        if (subflowObject.Value<string>("flowId").IsGuid(out Guid subId))
                        {
                            stepSubFlowModel.SubFlowId = subId;
                        }
                        stepSubFlowModel.SubFlowStrategy = subflowObject.Value<string>("flowStrategy").IsInt(out int flowStrategy) ? flowStrategy : 0;
                        stepSubFlowModel.TaskType = subflowObject.Value<string>("taskType").IsInt(out int taskType) ? taskType : 0;
                    }
                    stepModel.StepSubFlow = stepSubFlowModel;
                    #endregion

                    steps.Add(stepModel);
                    #endregion
                }
            }
            flowRunModel.Steps = steps;
            if (steps.Count == 0)
            {
                errMsg = localizer == null ? "流程至少需要一个步骤" : localizer["Install_OneStep"].Value;
                return null;
            }
            #endregion

            #region 连线信息
            JArray lineArray = jObject.Value<JArray>("lines");
            List<Model.FlowRunModel.Line> lines = new List<Model.FlowRunModel.Line>();
            if (null != lineArray)
            {
                foreach (JObject lineObject in lineArray)
                {
                    Model.FlowRunModel.Line lineModel = new Model.FlowRunModel.Line
                    {
                        Id = lineObject.Value<string>("id").IsGuid(out Guid lid) ? lid : Guid.Empty,
                        FromId = lineObject.Value<string>("from").IsGuid(out Guid fid) ? fid : Guid.Empty,
                        ToId = lineObject.Value<string>("to").IsGuid(out Guid tid) ? tid : Guid.Empty,
                        CustomMethod = lineObject.Value<string>("customMethod"),
                        SqlWhere = lineObject.Value<string>("sql"),
                        JudgeType = lineObject.Value<string>("judagType").ToInt(0)
                    };
                    if (lineObject.Value<JArray>("organize") != null)
                    {
                        lineModel.OrganizeExpression = lineObject.Value<JArray>("organize").ToString(Newtonsoft.Json.Formatting.None);
                    }
                    lines.Add(lineModel);
                }
            }
            flowRunModel.Lines = lines;
            #endregion

            #region 设置开始步骤
            Model.FlowRunModel.Step firstStep = null;
            foreach (var step in flowRunModel.Steps)
            {
                if (flowRunModel.Lines.Find(p => p.ToId == step.Id) == null)
                {
                    firstStep = step;
                    break;
                }
            }
            if (null == firstStep)
            {
                errMsg = localizer == null ? "流程没有开始步骤" : localizer["Install_NotStartStep"].Value;
                return null;
            }
            flowRunModel.FirstStepId = firstStep.Id;
            #endregion

            return flowRunModel;
        }



        /// <summary>
        /// 导入流程
        /// </summary>
        /// <param name="json"></param>
        /// <param name="createFormFile">是否要创建表单文件，VUE导入时不需要创建</param>
        /// <returns>返回1表示成功，其它为错误信息</returns>
        public string ImportFlow(string json, bool createFormFile = true)
        {
            if (json.IsNullOrWhiteSpace())
            {
                return "要导入的JSON为空!";
            }
            JObject jObject;
            try
            {
                jObject = JObject.Parse(json);
            }
            catch
            {
                return "json解析错误!";
            }
            var flows = jObject.Value<JArray>("flows");
            if (null != flows)
            {
                foreach (JObject flow in flows)
                {
                    Model.rf_flow flowModel = flow.ToObject<Model.rf_flow>();
                    if (null == flowModel)
                    {
                        continue;
                    }
                    if (Get(flowModel.Id) != null)
                    {
                        Update(flowModel);
                    }
                    else
                    {
                        Add(flowModel);
                    }
                }
            }
            var applibarys = jObject.Value<JArray>("applibrarys");
            
            if (null != applibarys)
            {
                foreach (JObject app in applibarys)
                {
                    Model.rf_applibrary appLibraryModel = app.ToObject<Model.rf_applibrary>();
                    if (null == appLibraryModel)
                    {
                        continue;
                    }
                    if (new Applibrary().GetOneById(appLibraryModel.Id) != null)
                    {
                        new Applibrary().Update(appLibraryModel);
                    }
                    else
                    {
                        new Applibrary().Add(appLibraryModel);
                    }
                }
            }
            var forms = jObject.Value<JArray>("forms");
            //Form bform = new Form();
            if (null != forms)
            {
                foreach (JObject form in forms)
                {
                    Model.rf_form formModel = form.ToObject<Model.rf_form>();
                    if (null == formModel)
                    {
                        continue;
                    }
                    if (new Form().GetOneById(formModel.Id) != null)
                    {
                        new Form().Update(formModel);
                    }
                    else
                    {
                        new Form().Add(formModel);
                    }
                    //如果表单状态是发布，要发布表单
                    if (createFormFile && formModel.Status == 1)
                    {
                        #region 写入文件
                        string webRootPath = Tools.GetWebRootPath();
                        string path = webRootPath + "/RoadFlowResources/scripts/formDesigner/form/";
                        if (!Directory.Exists(path))
                        {
                            Directory.CreateDirectory(path);
                        }
                        string file = path + formModel.Id + ".rfhtml";
                        Stream stream = File.Open(file, FileMode.OpenOrCreate, FileAccess.ReadWrite, FileShare.None);
                        stream.SetLength(0);
                        StreamWriter sw = new StreamWriter(stream, Encoding.UTF8);
                        sw.Write(formModel.RunHtml);
                        sw.Close();
                        stream.Close();
                        #endregion
                    }
                }
            }
            return "1";
        }

        /// <summary>
        /// 查询一页数据
        /// </summary>
        /// <param name="count"></param>
        /// <param name="size"></param>
        /// <param name="number"></param>
        /// <param name="flowIdList"></param>
        /// <param name="name"></param>
        /// <param name="type"></param>
        /// <param name="order"></param>
        /// <param name="status">状态-1表示查询未删除的流程</param>
        /// <returns></returns>
       


        /// <summary>
        /// 得到一个用户可以发起的流程运行时实体列表
        /// </summary>
        /// <param name="userId"></param>
        /// <returns></returns>
        public List<Model.FlowRun> GetStartFlows(string userId)
        {
            List<Model.FlowRun> flowRuns = new List<Model.FlowRun>();
            var flows = GetAll();
            
            foreach (var flow in flows)
            {
                var flowRunModel = GetFlowRunModel(flow.Id);
                if (null == flowRunModel || flowRunModel.Status != 1 || flowRunModel.FirstStepId.IsEmptyGuid())
                {
                    continue;
                }
                var firstStepModel = flowRunModel.Steps.Find(p => p.Id == flowRunModel.FirstStepId);
                if (null == firstStepModel)
                {
                    continue;
                }
                if (firstStepModel.StepBase.DefaultHandler.IsNullOrWhiteSpace() || new UserDummy().Contains(firstStepModel.StepBase.DefaultHandler, userId))
                {
                    flowRuns.Add(flowRunModel);
                }
            }
            return flowRuns;
        }

        /// <summary>
        /// 得到流程运行时实体
        /// </summary>
        /// <param name="id">流程ID</param>
        /// <param name="isCache">是否从缓存中取</param>
        /// <param name="currentTask">当前任务实体(动态步骤时要取动态的步骤流程运行时实体)</param>
        /// <returns></returns>
        public Model.FlowRun GetFlowRunModel(string id, bool isCache = true, RoadFlow.Model.rf_flowtask currentTask = null)
        {
            //如果当前任务有之前步骤ID，则从动态流程中取JSON
            if (null != currentTask && currentTask.BeforeStepId.IsNotEmptyGuid())
            {
                string key = CACHEKEY + "_" + currentTask.BeforeStepId + "_" + currentTask.GroupId;
                if (isCache)
                {
                    object obj = this._memoryCache.Get(key);
                    if (null != obj)
                    {
                        return (Model.FlowRun)obj;
                    }
                }
                var flowDynamicModel = new FlowDynamic().Get(currentTask.BeforeStepId, currentTask.GroupId);
                var runModel = null == flowDynamicModel || flowDynamicModel.FlowJSON.IsNullOrWhiteSpace() ? null
                    : GetFlowRunModel(flowDynamicModel.FlowJSON, out string msg1);
                if (null != runModel)
                {
                    this._memoryCache.Set(key, runModel);
                    //Cache.IO.Insert(key, runModel);
                }
                return runModel;
            }
            //=========================================

            string cacheKey = CACHEKEY + id;
            if (isCache)
            {
                object obj = _memoryCache.Get(cacheKey);
                if (null != obj)
                {
                    return (Model.FlowRun)obj;
                }
            }
            var flowModel = Get(id);
            if (null == flowModel)
            {
                return null;
            }
            var flowRunModel = GetFlowRunModel(flowModel.RunJSON.IsNullOrWhiteSpace() ? flowModel.DesignerJSON : flowModel.RunJSON, out string msg);
            if (null != flowRunModel)
            {
                _memoryCache.Set(cacheKey, flowRunModel);
            }
            return flowRunModel;
        }


        /// <summary>
        /// 得到步骤名称
        /// </summary>
        /// <param name="flowId"></param>
        /// <param name="stepId"></param>
        /// <returns></returns>
        public string GetStepName(string flowId, Guid stepId)
        {
            return flowId.IsNullOrWhiteSpace() ? string.Empty : GetStepName(GetFlowRunModel(flowId), stepId);
        }

        /// <summary>
        /// 得到步骤名称
        /// </summary>
        /// <param name="flowId"></param>
        /// <param name="stepId"></param>
        /// <returns></returns>
        public string GetStepName(Model.FlowRun flowRunModel, Guid stepId)
        {
            if (null == flowRunModel)
            {
                return string.Empty;
            }
            if (stepId.IsEmptyGuid())
            {
                stepId = flowRunModel.FirstStepId;
            }
            var step = flowRunModel.Steps.Find(p => p.Id == stepId);
            return null == step ? string.Empty : step.Name;
        }

        /// <summary>
        /// 得到一个流程步骤的下一步骤集合
        /// </summary>
        /// <param name="flowRunModel">流程运行时实体</param>
        /// <param name="stepId">步骤ID</param>
        /// <returns></returns>
        public List<Model.FlowRunModel.Step> GetNextSteps(Model.FlowRun flowRunModel, Guid stepId)
        {
            List<Model.FlowRunModel.Step> steps = new List<Model.FlowRunModel.Step>();
            if (null == flowRunModel)
            {
                return steps;
            }
            var lines = flowRunModel.Lines.FindAll(p => p.FromId == stepId);
            foreach (var line in lines)
            {
                var step = flowRunModel.Steps.Find(p => p.Id == line.ToId);
                if (null != step)
                {
                    steps.Add(step);
                }
            }
            return steps.Count > 0 ? steps.OrderBy(p => p.Position_Y).ThenBy(p => p.Position_X).ToList() : steps;
        }


        /// <summary>
        /// 得到一个步骤的前面步骤集合
        /// </summary>
        /// <param name="flowRunModel"></param>
        /// <param name="stepId"></param>
        /// <returns></returns>
        public List<Model.FlowRunModel.Step> GetPrevSteps(Model.FlowRun flowRunModel, string stepId)
        {
            List<Model.FlowRunModel.Step> steps = new List<Model.FlowRunModel.Step>();
            if (null == flowRunModel || stepId.IsNullOrWhiteSpace())
            {
                return steps;
            }
            var lines = flowRunModel.Lines.FindAll(p => p.ToId == stepId.ToGuid());
            foreach (var line in lines)
            {
                var step = flowRunModel.Steps.Find(p => p.Id == line.FromId);
                if (null != step)
                {
                    steps.Add(step);
                }
            }
            return steps;
        }

        /// <summary>
        /// 得到两个步骤之间的步骤集合
        /// </summary>
        /// <param name="flowRunModel"></param>
        /// <param name="stepId1">开始步骤Id</param>
        /// <param name="stepId2">结束步骤Id</param>
        /// <returns></returns>
        public List<Model.FlowRunModel.Step> GetRangeSteps(Model.FlowRun flowRunModel, Guid stepId1, Guid stepId2)
        {
            if (stepId1.IsEmptyGuid())
            {
                return new List<Model.FlowRunModel.Step>();
            }
            var nextSteps = GetNextSteps(flowRunModel, stepId1);
            foreach (var nextStep in nextSteps)
            {
                var allNextSteps = GetAllNextSteps(flowRunModel, nextStep.Id);
                if (allNextSteps.Exists(p => p.Id == stepId2))
                {
                    List<Model.FlowRunModel.Step> steps = new List<Model.FlowRunModel.Step>() { nextStep };
                    foreach (var step in allNextSteps)
                    {
                        steps.Add(step);
                        if (step.Id == stepId2)
                        {
                            return steps;
                        }
                    }
                }
            }
            return new List<Model.FlowRunModel.Step>();
        }
        /// <summary>
        /// 得到一个步骤的所有后续步骤集合
        /// </summary>
        /// <param name="flowRunModel"></param>
        /// <param name="stepId"></param>
        /// <returns></returns>
        public List<Model.FlowRunModel.Step> GetAllNextSteps(Model.FlowRun flowRunModel, Guid stepId)
        {
            List<Model.FlowRunModel.Step> steps = new List<Model.FlowRunModel.Step>();
            AddNextSteps(flowRunModel, stepId, stepId, steps);
            return steps;
        }

        /// <summary>
        /// 递归添加一个步骤的后续步骤
        /// </summary>
        /// <param name="flowRunModel"></param>
        /// <param name="stepId"></param>
        /// <param name="startStepId">开始的步骤ID</param>
        /// <param name="steps"></param>
        private void AddNextSteps(Model.FlowRun flowRunModel, Guid stepId, Guid startStepId, List<Model.FlowRunModel.Step> steps)
        {
            var nexts = GetNextSteps(flowRunModel, stepId);
            foreach (var step in nexts)
            {
                if (!steps.Exists(p => p.Id == step.Id) && step.Id != startStepId)
                {
                    steps.Add(step);
                }
            }
            foreach (var step in nexts)
            {
                if (step.Id != startStepId)
                {
                    AddNextSteps(flowRunModel, step.Id, startStepId, steps);
                }
            }
        }


        /// <summary>
        /// 得到流程运行时实体
        /// </summary>
        /// <param name="id">流程ID</param>
        /// <param name="isCache">是否从缓存中取</param>
        /// <param name="currentTask">当前任务实体(动态步骤时要取动态的步骤流程运行时实体)</param>
        /// <returns></returns>
        public Model.FlowRun GetFlowRunModel(Guid id, bool isCache = true, Model.rf_flowtask currentTask = null)
        {
            //如果当前任务有之前步骤ID，则从动态流程中取JSON
            if (null != currentTask && currentTask.BeforeStepId.IsNotEmptyGuid())
            {
                string key = CACHEKEY + "_" + currentTask.BeforeStepId + "_" + currentTask.GroupId;
                if (isCache)
                {
                    object obj = _memoryCache.Get(key);
                    if (null != obj)
                    {
                        return (Model.FlowRun)obj;
                    }
                }
                var flowDynamicModel = new FlowDynamic().Get(currentTask.BeforeStepId, currentTask.GroupId);
                var runModel = null == flowDynamicModel || flowDynamicModel.FlowJSON.IsNullOrWhiteSpace() ? null
                    : GetFlowRunModel(flowDynamicModel.FlowJSON, out string msg1);
                if (null != runModel)
                {
                    _memoryCache.Set(key, runModel);
                }
                return runModel;
            }
            //=========================================

            string cacheKey = CACHEKEY + id.ToString();
            if (isCache)
            {
                object obj = _memoryCache.Get(cacheKey);
                if (null != obj)
                {
                    return (Model.FlowRun)obj;
                }
            }
            var flowModel = Get(id.ToString());
            if (null == flowModel)
            {
                return null;
            }
            var flowRunModel = GetFlowRunModel(flowModel.RunJSON.IsNullOrWhiteSpace() ? flowModel.DesignerJSON : flowModel.RunJSON, out string msg);
            if (null != flowRunModel)
            {
                _memoryCache.Set(cacheKey, flowRunModel);
            }
            return flowRunModel;
        }


        /// <summary>
        /// 判断一个步骤是否是最后一步
        /// </summary>
        /// <param name="flowRunModel">流程运行时实体</param>
        /// <param name="stepId">步骤ID</param>
        /// <returns></returns>
        public bool IsLastStep(Model.FlowRun flowRunModel, Guid stepId)
        {
            if (null == flowRunModel || flowRunModel.Lines.Count == 0)
            {
                return true;
            }
            return !flowRunModel.Lines.Exists(p => p.FromId == stepId);
        }

        /// <summary>
        /// 得到一个用户可管理实例的流程
        /// </summary>
        /// <param name="userId"></param>
        /// <returns></returns>
        public List<string> GetManageInstanceFlowIds(string userId)
        {
            var flows = GetListBy(x => x.InstanceManager.ToLower().Contains(userId.ToLower()));
            List<string> guids = new List<string>();
            foreach (var flow in flows)
            {
                guids.Add(flow.Id);
            }
            return guids;
        }

    }
}