using DS.Module.Core; using DS.Module.Core.Constants; 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 Mapster; using Microsoft.Extensions.DependencyInjection; using SqlSugar; namespace DS.WMS.Core.Code.Method; public class CodePackageService:ICodePackageService { private readonly IServiceProvider _serviceProvider; private readonly ISqlSugarClient db; private readonly IUser user; private readonly ISaasDbService saasService; /// /// /// /// public CodePackageService(IServiceProvider serviceProvider) { _serviceProvider = serviceProvider; db = _serviceProvider.GetRequiredService(); user = _serviceProvider.GetRequiredService(); saasService = _serviceProvider.GetRequiredService(); } public DataResult> GetListByPage(PageRequest request) { //序列化查询条件 var whereList = db.ConfigQuery.Context.Utilities.JsonToConditionalModels(request.QueryCondition); var data = db.Queryable() .Where(whereList) .Select().ToQueryPage(request.PageCondition); return data; } public DataResult EditCodePackage(CodePackageReq req) { if (req.Id == 0) { if (db.Queryable().Where(x=>x.PackageName == req.PackageName.Trim()).Any()) { return DataResult.Failed("包装类型已存在!",MultiLanguageConst.CodePackageExist); } var data = req.Adapt(); var entity = db.Insertable(data).RemoveDataCache(SqlSugarCacheConst.Package).ExecuteReturnEntity(); return DataResult.Successed("添加成功!", entity.Id,MultiLanguageConst.DataCreateSuccess); } else { var info = db.Queryable().Where(x => x.Id == req.Id).First(); info = req.Adapt(info); db.Updateable(info).RemoveDataCache(SqlSugarCacheConst.Package).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommand(); return DataResult.Successed("更新成功!",MultiLanguageConst.DataUpdateSuccess); } } public DataResult GetCodePackageInfo(string id) { var data = db.Queryable() .Where(a => a.Id == long.Parse(id)) .Select() .First(); return DataResult.Success(data,MultiLanguageConst.DataQuerySuccess); } public DataResult> GetClientListByPage(PageRequest request) { var tenantDb = saasService.GetBizDbScopeById(user.TenantId); //序列化查询条件 var whereList = db.ConfigQuery.Context.Utilities.JsonToConditionalModels(request.QueryCondition); var data = tenantDb.Queryable() .Where(whereList) .Select().ToQueryPage(request.PageCondition); return data; } public DataResult EditClientCodePackage(CodePackageReq req) { var tenantDb = saasService.GetBizDbScopeById(user.TenantId); if (req.Id == 0) { if (tenantDb.Queryable().Where(x=>x.PackageName == req.PackageName.Trim()).Any()) { return DataResult.Failed("包装类型已存在!",MultiLanguageConst.CodePackageExist); } var data = req.Adapt(); var entity = tenantDb.Insertable(data).RemoveDataCache(SqlSugarCacheConst.Package).ExecuteReturnEntity(); return DataResult.Successed("添加成功!", entity.Id,MultiLanguageConst.DataCreateSuccess); } else { var info = tenantDb.Queryable().Where(x => x.Id == req.Id).First(); info = req.Adapt(info); tenantDb.Updateable(info).RemoveDataCache(SqlSugarCacheConst.Package).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommand(); return DataResult.Successed("更新成功!",MultiLanguageConst.DataUpdateSuccess); } } public DataResult GetClientCodePackageInfo(string id) { var tenantDb = saasService.GetBizDbScopeById(user.TenantId); var data = tenantDb.Queryable() .Where(a => a.Id == long.Parse(id)) .Select() .First(); return DataResult.Success(data,MultiLanguageConst.DataQuerySuccess); } public DataResult> GetCodePackageList(PageRequest request) { var tenantDb = saasService.GetBizDbScopeById(user.TenantId); var existIds = tenantDb.Queryable() .Select(a => a.Id) .ToList(); //序列化查询条件 var whereList = db.ConfigQuery.Context.Utilities.JsonToConditionalModels(request.QueryCondition); var data = db.Queryable().Where(x=>x.Status == StatusEnum.Enable && !existIds.Contains(x.Id)) .Where(whereList) .Select().ToQueryPage(request.PageCondition); return data; } public DataResult ImportCodePackage(IdModel req) { var tenantDb = saasService.GetBizDbScopeById(user.TenantId); var list = db.Queryable().Where(x =>req.Ids.Contains(x.Id) ).ToList(); if (list.Count == 0) { return DataResult.Failed("包装类型导入无数据!",MultiLanguageConst.CodePackageImportNoData); } if (tenantDb.Queryable().Where(x =>req.Ids.Contains(x.Id) ).Any()) { return DataResult.Failed("存在已导入的包装类型!",MultiLanguageConst.CodePackageImportAlready); } tenantDb.Insertable(list).RemoveDataCache(SqlSugarCacheConst.Package).ExecuteCommand(); return DataResult.Successed("引入成功!",MultiLanguageConst.DataImportSuccess); } /// /// 获取当前租户已有的包装类型 /// /// public DataResult> GetExistCodePackageList() { var tenantDb = saasService.GetBizDbScopeById(user.TenantId); var data = tenantDb.Queryable() .Select(n=>n.Id.ToString()) .ToList(); return DataResult>.Success(data); } public DataResult BatchDelCodePackage(IdModel req) { var tenantDb = saasService.GetBizDbScopeById(user.TenantId); var list = tenantDb.Queryable().Where(x => req.Ids.Contains(x.Id)).ToList(); if (list.Count > 0) { tenantDb.Deleteable(list).RemoveDataCache(SqlSugarCacheConst.Package).ExecuteCommand(); } return DataResult.Successed("删除成功!", MultiLanguageConst.DataDelSuccess); } }