BookingHeChuan/Myshipping.FlowCenter/Flowscheme/FlcFlowschemeService.cs

using Furion.DependencyInjection;
using Furion.DynamicApiController;
using Furion.FriendlyException;
using Myshipping.Core;
using Myshipping.Core.Entity;
using Myshipping.Core.Service;
using Myshipping.FlowCenter.Entity;
using Mapster;
using Microsoft.AspNetCore.Mvc;
using SqlSugar;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;

namespace Myshipping.FlowCenter.Service;

/// <summary>
/// 流程管理服务
/// </summary>
[ApiDescriptionSettings("FlowCenter", Name = "Flowscheme", Order = 100)]
public class FlcFlowschemeService : IFlcFlowschemeService, IDynamicApiController, ITransient
{
    private readonly SqlSugarRepository<FlcFlowscheme> _rep;
    private readonly IFlcFormManageService _flcFormService;
    private readonly ISysEmpService _sysEmpService;

    public FlcFlowschemeService(SqlSugarRepository<FlcFlowscheme> flcFormRep,
                        IFlcFormManageService flcFormService,
                         ISysEmpService sysEmpService)
    {
        _rep = flcFormRep;
        _flcFormService = flcFormService;
        _sysEmpService = sysEmpService;
    }

    /// <summary>
    /// 分页查询流程管理
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpGet("/flcFlowscheme/page")]
    public async Task<dynamic> Page([FromQuery] PageFlcFlowschemeInput input)
    {
        var entities = await _rep.AsQueryable()
            .LeftJoin<FlcForm>((u,b)=>u.FrmId==b.Id)
                                    .WhereIF(!string.IsNullOrWhiteSpace(input.SchemeName), u => u.SchemeName.Contains(input.SchemeName.Trim()))
                                   .WhereIF(!string.IsNullOrWhiteSpace(input.Id), u => u.Id == long.Parse(input.Id.Trim()))
                                   .WhereIF(!string.IsNullOrWhiteSpace(input.OrgId), u => u.OrgId == long.Parse(input.OrgId) || u.OrgId == null || u.OrgId == 0)
                                    .WhereIF(input.Status != null, u => u.Status == input.Status)
                                   .Where(u => u.Status != CommonStatus.DELETED)
                                   .OrderBy(u => u.Sort)
                                   .Select<FlcFlowschemeOutput>((u,b)=>new FlcFlowschemeOutput { 
                                        Id=u.Id.ToString(),
                                        Active=u.Active,
                                        AuthorizeType=u.AuthorizeType,
                                        FrmId=u.FrmId.ToString(),
                                        Name=b.Name,
                                        WebId = b.WebId,
                                        FrmType =u.FrmType,
                                        OrgId=u.OrgId.ToString(),
                                        Remark=u.Remark,
                                        SchemeCanUser=u.SchemeCanUser,
                                        SchemeCode=u.SchemeCode,
                                        SchemeContent=u.SchemeContent,
                                        SchemeName=u.SchemeName,
                                        SchemeType=u.SchemeType,
                                        SchemeVersion=u.SchemeVersion,
                                        Sort=u.Sort,
                                        Status=u.Status,
                                        Content=b.Content,
                                        ContentData=b.ContentData,
                                        ContentParse=b.ContentParse,
                                        Fields=b.Fields                      
                                   })
                                 .ToPagedListAsync(input.PageNo, input.PageSize);
        return entities.XnPagedResult();
    }

    /// <summary>
    /// 增加流程管理
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpPost("/flcFlowscheme/add")]
    public async Task Add(AddFlcFlowschemeInput input)
    {
        var isExist = await _rep.AnyAsync(u => u.SchemeName == input.SchemeName);
        if (isExist)
            throw Oops.Oh(ErrorCode.D2002);
        var formEntity = await _flcFormService.GetForm(new QueryFlcFormInput { Id = input.FrmId });
			if (formEntity == null)
            throw Oops.Oh(ErrorCode.F1000);
        input.Status = CommonStatus.DISABLE;
        var entity = input.Adapt<FlcFlowscheme>();
        entity.FrmType = formEntity.FrmType;
        await _rep.InsertAsync(entity);
    }

    /// <summary>
    /// 删除流程管理
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpPost("/flcFlowscheme/delete")]
    public async Task Delete(DeleteFlcFlowschemeInput input)
    {
        var flow = await _rep.FirstOrDefaultAsync(u => u.Id == long.Parse(input.Id));

        // 检测数据范围能不能操作这个表单
        (flow.CreatedUserId ?? 0).CheckDataScope();
        //假删除
        await _rep.UpdateAsync(a => a.Id == long.Parse(input.Id),a => new FlcFlowscheme
        {
            Status = CommonStatus.DELETED,
            IsDeleted = true,
        });
    }

    /// <summary>
    /// 更新流程管理
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpPost("/flcFlowscheme/edit")]
    public async Task Update(UpdateFlcFlowschemeInput input)
    {
        if (input.Id != "0" && !string.IsNullOrEmpty(input.Id))
        {
            var org = await _rep.FirstOrDefaultAsync(u => u.Id == long.Parse(input.Id));
            _ = org ?? throw Oops.Oh(ErrorCode.D2000);
        }

        var flcFlow = await _rep.FirstOrDefaultAsync(u => u.Id == long.Parse(input.Id));

        // 检测数据范围能不能操作这个表单
        (flcFlow.CreatedUserId ?? 0).CheckDataScope();

        var isExist = await _rep.AnyAsync(u => (u.SchemeName == input.SchemeName) && u.Id != flcFlow.Id);
        if (isExist)
            throw Oops.Oh(ErrorCode.D2002);
        var entity = input.Adapt<FlcFlowscheme>();
        var formEntity = await _flcFormService.GetForm(new QueryFlcFormInput { Id = flcFlow.FrmId.ToString() });
        if (formEntity == null)
            throw Oops.Oh(ErrorCode.F1000);
        entity.FrmType=formEntity.FrmType;
        await _rep.AsUpdateable(entity).IgnoreColumns(ignoreAllNullColumns:true).ExecuteCommandAsync();
    }

    /// <summary>
    /// 获取流程管理
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpGet("/flcFlowscheme/detail")]
    public async Task<FlcFlowschemeOutput> Get([FromQuery] DeleteFlcFlowschemeInput input)
    {
        var cachedata = await _rep.FirstOrDefaultAsync(u => u.Id == long.Parse(input.Id));
        var temp = cachedata.Adapt<FlcFlowschemeOutput>();
        var form = await _rep.Change<FlcForm>().AsQueryable().InSingleAsync(cachedata.FrmId);
        temp.WebId = form.WebId;
        temp.ContentData = form.ContentData;
        temp.Content = form.Content;
        //创建运行实例
        var flowinstance = new FlcFlowinstance();
        flowinstance.SchemeContent = temp.SchemeContent;
			if (flowinstance.SchemeContent.IsEmpty())
			{
            return temp;
			}
        var runtime = new FlowRuntime(flowinstance);
        if (runtime.nextNodeType != -1 && runtime.nextNode != null && runtime.nextNode.setInfo != null && runtime.nextNodeType != 4)
        {
            temp.NextNodeDesignateType = runtime.nextNode.setInfo.NodeDesignate;
            if (temp.NextNodeDesignateType == Setinfo.SPECIAL_USER)
            {
                temp.NextNodeDesignates = runtime.nextNode.setInfo.NodeDesignateData.ToArray();
                temp.NextMakerName = string.Join(',', _rep.Change<SysUser>().Where(a => temp.NextNodeDesignates.Contains(a.Id.ToString())).Select(a => a.Name).ToList());
            }
            else if (temp.NextNodeDesignateType == Setinfo.SPECIAL_ROLE)
            {
                temp.NextNodeDesignates = runtime.nextNode.setInfo.NodeDesignateData.ToArray();
                List<SysUser> list = new List<SysUser>();
                List<long> users = new List<long>();
                foreach (var item in temp.NextNodeDesignates)
                {
                    var usertemp = _rep.Change<SysUser>().AsQueryable().LeftJoin<SysUserRole>((a, b) => a.Id == b.SysUserId && b.SysRoleId == long.Parse(item)).Select((a, b) => a).Distinct().ToList();
                    var tempList = new List<SysUser>();
                    if (runtime.nextNode.setInfo.CurrentDepart)
                    {
                        var currentDepartment = new List<long>();
                        var empInfo = await _sysEmpService.GetEmpInfo(UserManager.UserId);
                        if (empInfo != null)
                        {
                            currentDepartment.Add(long.Parse(empInfo.OrgId));
                            if (empInfo.ExtOrgPos != null && empInfo.ExtOrgPos.Count > 0)
                                currentDepartment.AddRange(empInfo.ExtOrgPos.Select(a => a.OrgId));
                        }
                        foreach (var user in usertemp)
                        {
                            var nextCurrentDepartment = new List<long>();
                            var empTempInfo = await _sysEmpService.GetEmpInfo(UserManager.UserId);
                            if (empTempInfo != null)
                            {
                                nextCurrentDepartment.Add(long.Parse(empTempInfo.OrgId));
                                if (empInfo.ExtOrgPos != null && empTempInfo.ExtOrgPos.Count > 0)
                                    nextCurrentDepartment.AddRange(empTempInfo.ExtOrgPos.Select(a => a.OrgId));
                            }
                            if (JsonUtil.IsArrayIntersection(currentDepartment, nextCurrentDepartment))
                            {
                                tempList.Add(user);
                            }
                        }
                    }
                    else
                    {
                        tempList = usertemp;
                    }
                    var tempFinal = tempList.Select(a => a.Id).ToList();
                    users.AddRange(tempFinal);
                }
                users = users.Distinct().ToList();
                temp.NextMakerName = string.Join(',', _rep.Change<SysUser>().Where(a => users.Contains(a.Id)).Select(a => a.Name).ToList());
            }
        }
        return temp;
    }

    /// <summary>
    /// 获取流程管理列表
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    [HttpGet("/flcFlowscheme/list")]
    public async Task<List<FlcFlowschemeOutput>> List([FromQuery] FlcFlowschemeInput input)
    {
        var dataScopeList = await DataFilterExtensions.GetDataScopeIdList(FilterType.Org);
        var flows = await _rep.AsQueryable()
                            .LeftJoin<FlcForm>((u, b) => u.FrmId == b.Id)
                                   .WhereIF(!string.IsNullOrWhiteSpace(input.OrgId), u => u.OrgId == long.Parse(input.OrgId) || u.OrgId == null || u.OrgId == 0)
                                   .WhereIF(dataScopeList.Any(), u => dataScopeList.Contains(u.OrgId ?? 0))
                                   .Where(u => u.Status != CommonStatus.DELETED)
                                   .OrderBy(u => u.Sort)
                                    .Select<FlcFlowschemeOutput>((u, b) => new FlcFlowschemeOutput
                                    {
                                        Id = u.Id.ToString(),
                                        Active = u.Active,
                                        AuthorizeType = u.AuthorizeType,
                                        FrmId = u.FrmId.ToString(),
                                        FrmType = u.FrmType,
                                        OrgId = u.OrgId.ToString(),
                                        Name = b.Name,
                                        WebId=b.WebId,
                                        Remark = u.Remark,
                                        SchemeCanUser = u.SchemeCanUser,
                                        SchemeCode = u.SchemeCode,
                                        SchemeContent = u.SchemeContent,
                                        SchemeName = u.SchemeName,
                                        SchemeType = u.SchemeType,
                                        SchemeVersion = u.SchemeVersion,
                                        Sort = u.Sort,
                                        Status = u.Status,
                                        Content = b.Content,
                                        ContentData = b.ContentData,
                                        ContentParse = b.ContentParse,
                                        Fields = b.Fields
                                    })
                                   .ToListAsync();
        return flows;
    }
}