ds8-solution-pro/ds-wms-service/DS.WMS.Core/Flow/Method/ClientFlowInstanceService.cs

using DS.Module.Core;
using DS.Module.SqlSugar;
using DS.WMS.Core.Flow.Dtos;
using DS.WMS.Core.Flow.Entity;
using DS.WMS.Core.Flow.Interface;
using DS.WMS.Core.Op.Entity;
using DS.WMS.Core.Sys.Entity;
using Mapster;
using Microsoft.Extensions.DependencyInjection;

namespace DS.WMS.Core.Flow.Method;

public class ClientFlowInstanceService : FlowInstanceService, IClientFlowInstanceService
{
    readonly ISaasDbService saasService;

    public ClientFlowInstanceService(IServiceProvider serviceProvider) : base(serviceProvider)
    {
        saasService = serviceProvider.GetRequiredService<ISaasDbService>();
    }

    protected override FlowInstance BuildInstance(CreateFlowInstanceReq req)
    {
        if (string.IsNullOrEmpty(req.TemplateId.ToString()))
            return null;

        FlowTemplateTenant template = db.Queryable<FlowTemplateTenant>().First(x => x.Id == req.TemplateId);

        return template == null ? null : new FlowInstance
        {
            CustomName = template.Name,
            TemplateId = template.Id,
            BusinessId = req.BusinessId,
            BusinessType = req.BusinessType,
            PermissionId = template.PermissionId,
            ColumnView = template.ColumnView,
            Content = template.Content,
            CallbackURL = template.CallbackURL,
            AuditType = template.AuditType
        };
    }

    protected override string GetForkNodeMakers(FlowRuntime wfruntime, string forkNodeId)
    {
        string makerList = "";

        var nextNode = wfruntime.NextNode;

        var nextConditionNodeId = wfruntime.GetClientNextConditionNodeId(nextNode);
        var nextConditionNode = wfruntime.ChildNodes.First(x => x.Id == nextConditionNodeId);
        if (nextConditionNode.AssigneeType == "role")
        {
            var users = db.Queryable<SysRoleUser>().Where(x =>
                    nextConditionNode.Roles.Contains(x.RoleId.ToString()))
                .Select(x => x.UserId).Distinct().ToList();
            makerList = GenericHelper.ArrayToString(users, makerList);
        }
        else if (nextConditionNode.AssigneeType == "user")
        {
            makerList = string.Join(",", nextConditionNode.Users);
        }

        return makerList;
    }

    protected override FlowRuntime CreateRuntimeService(FlowInstance instance)
    {
        return new FlowRuntime(instance, db, saasService, user);
    }

    /// <summary>
    /// <20><>ȡָ<C8A1><D6B8><EFBFBD><EFBFBD><EFBFBD>͵Ĺ<CDB5><C4B9><EFBFBD><EFBFBD><EFBFBD>ʵ<EFBFBD><CAB5>
    /// </summary>
    /// <param name="businessId">ҵ<><D2B5>ID</param>
    /// <param name="businessType">ҵ<><D2B5><EFBFBD><EFBFBD><EFBFBD><EFBFBD></param>
    /// <param name="type">ģ<><C4A3><EFBFBD><EFBFBD><EFBFBD><EFBFBD></param>
    /// <returns></returns>
    public DataResult<FlowInstanceRes> GetFlowInstance(long businessId, BusinessType businessType, string type)
    {
        var entity = db.Queryable<FlowInstance>().Where(x => x.BusinessId == businessId && x.BusinessType == businessType && x.AuditType == type)
            .OrderByDescending(x => x.CreateTime).First();
        var result = entity == null ? null : entity.Adapt<FlowInstanceRes>();
        return DataResult<FlowInstanceRes>.Success(result);
    }

    /// <summary>
    /// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
    /// </summary>
    /// <param name="info"><3E><><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ʵ<EFBFBD><CAB5></param>
    /// <returns></returns>
    public DataResult AuditFlowInstance(FlowAuditInfo info)
    {
        if (info == null)
            return DataResult.Failed("<22>ù<EFBFBD><C3B9><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>!", MultiLanguageConst.FlowInstanceNotExist);

        if (info.Instance.FlowStatus == FlowStatusEnum.Approve.ToEnumInt())
            return DataResult.Failed("<22>ù<EFBFBD><C3B9><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>!", MultiLanguageConst.FlowInstanceFinished);

        return AuditFlowCore(info.Status, info.AuditNote, info.Instance);
    }
}