using DS.WMS.Core.Code.Interface; using DS.Module.Core; using DS.Module.Core.Data; using DS.Module.Core.Extensions; using DS.Module.SqlSugar; using DS.Module.UserModule; using DS.WMS.Core.Code.Dtos; using DS.WMS.Core.Code.Entity; using DS.WMS.Core.Code.Interface; using DS.WMS.Core.Op.Entity; using DS.WMS.Core.Sys.Dtos; using DS.WMS.Core.Sys.Entity; using DS.WMS.Core.Sys.Interface; using Mapster; using Microsoft.Extensions.DependencyInjection; using SqlSugar; namespace DS.WMS.Core.Code.Method { public class DataRuleTemplateService: IDataRuleTemplateService { private readonly IServiceProvider _serviceProvider; private readonly ISqlSugarClient db; private readonly IUser user; private readonly ISaasDbService saasService; /// /// /// /// public DataRuleTemplateService(IServiceProvider serviceProvider) { _serviceProvider = serviceProvider; db = _serviceProvider.GetRequiredService(); user = _serviceProvider.GetRequiredService(); saasService = _serviceProvider.GetRequiredService(); } /// /// 列表 /// /// /// public async Task>> GetListByPage(PageRequest request) { var tenantDb = saasService.GetBizDbScopeById(user.TenantId); //序列化查询条件 var whereList = db.ConfigQuery.Context.Utilities.JsonToConditionalModels(request.QueryCondition); var data = await tenantDb.Queryable() .Where(whereList) .Select().ToQueryPageAsync(request.PageCondition); return data; } /// /// 编辑 /// /// /// public async Task EditDataRuleTemplate(CodeDataRuleTemplateReq req) { var tenantDb = saasService.GetBizDbScopeById(user.TenantId); if (req.Id == 0) { if (tenantDb.Queryable() .Where(x => x.PermissionId == req.PermissionId && x.TemplateName == req.TemplateName && x.RuleScope == req.RuleScope && x.RuleType == req.RuleType).Any()) { return await Task.FromResult(DataResult.Failed("数据权限模板已存在!", MultiLanguageConst.DataRuleTemplateExist)); } var data = req.Adapt(); var entity = await tenantDb.Insertable(data).ExecuteReturnEntityAsync(); return await Task.FromResult(DataResult.Successed("添加成功!", entity.Id, MultiLanguageConst.DataCreateSuccess)); } else { var info = await tenantDb.Queryable().Where(x => x.Id == req.Id).FirstAsync(); info = req.Adapt(info); await tenantDb.Updateable(info).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync(); return await Task.FromResult(DataResult.Successed("更新成功!", MultiLanguageConst.DataUpdateSuccess)); } } /// /// 详情 /// /// /// public async Task> GetDataRuleTemplateInfo(string id) { var tenantDb = saasService.GetBizDbScopeById(user.TenantId); var data = await tenantDb.Queryable() .Where(x => x.Id == long.Parse(id)) .Select() .FirstAsync(); return await Task.FromResult(DataResult.Success(data, MultiLanguageConst.DataQuerySuccess)); } /// /// 根据权限id获取数据权限模板 /// /// /// /// public async Task>> GetDataRuleTemplateSelectList(string id,string ruleType) { var tenantDb = saasService.GetBizDbScopeById(user.TenantId); var data = await tenantDb.Queryable() .Where(x => x.PermissionId == long.Parse(id) && x.Status == StatusEnum.Enable && x.RuleType == ruleType) .Select() .ToListAsync(); return await Task.FromResult(DataResult>.Success(data, MultiLanguageConst.DataQuerySuccess)); } public async Task BatchDelDataRuleTemplate(IdModel req) { var tenantDb = saasService.GetBizDbScopeById(user.TenantId); var list = await tenantDb.Queryable().Where(x => req.Ids.Contains(x.Id)).ToListAsync(); if (list.Count > 0) { tenantDb.Deleteable(list).ExecuteCommand(); } return await Task.FromResult(DataResult.Successed("删除成功!", MultiLanguageConst.DataDelSuccess)); } public async Task BatchCopyDataRuleTemplate(IdModel req) { var tenantDb = saasService.GetBizDbScopeById(user.TenantId); var list = await tenantDb.Queryable().Where(x => req.Ids.Contains(x.Id)).ToListAsync(); var newList = new List(); if (list.Count > 0) { foreach (var item in list) { var temp = item.Adapt(); temp.Id = 0; temp.TemplateName = item.TemplateName +"-复制"; newList.Add(temp); } await tenantDb.Insertable(newList).ExecuteCommandAsync(); } return await Task.FromResult(DataResult.Successed("复制成功!", MultiLanguageConst.DataCopySuccess)); } } }