调整结构

src/WMS.Web.Repositories/SerialNumbersRepositories.cs

@@ -1,11 +1,17 @@
 using AutoMapper;
+using Microsoft.EntityFrameworkCore;
 using Microsoft.EntityFrameworkCore.Storage;
 using System;
 using System.Collections.Generic;
+using System.Linq;
 using System.Text;
 using System.Threading.Tasks;
+using WMS.Web.Core.Dto;
+using WMS.Web.Core.Help;
 using WMS.Web.Domain.Entitys;
 using WMS.Web.Domain.Infrastructure;
+using WMS.Web.Domain.IService.Public;
+using WMS.Web.Domain.Mappers;
 using WMS.Web.Repositories.Configuration;
 
 namespace WMS.Web.Repositories
@@ -13,17 +19,22 @@ namespace WMS.Web.Repositories
     /// <summary>
     /// 序列号
     /// </summary>
-   public class SerialNumbersRepositories: ISerialNumbersRepositories
+    public class SerialNumbersRepositories : ISerialNumbersRepositories
     {
         private readonly IMapper _mapper;
         private readonly IServiceProvider _serviceProvider;
         private readonly RepositoryDbContext _context;
+        private readonly IErpService _erpService;
+        private readonly IErpBasicDataExtendService _erpBasicDataExtendService;
 
-        public SerialNumbersRepositories(RepositoryDbContext context, IMapper mapper, IServiceProvider serviceProvider)
+        public SerialNumbersRepositories(RepositoryDbContext context, IMapper mapper,
+            IServiceProvider serviceProvider, IErpService erpService, IErpBasicDataExtendService erpBasicDataExtendService)
         {
             _context = context;
             _mapper = mapper;
             _serviceProvider = serviceProvider;
+            _erpService = erpService;
+            _erpBasicDataExtendService = erpBasicDataExtendService;
         }
 
         public async Task<bool> AddRange(List<SerialNumbers> entitys, bool isTransaction = true)
@@ -49,5 +60,72 @@ namespace WMS.Web.Repositories
                 return false;
             }
         }
+        /// <summary>
+        /// 批量修改
+        /// </summary>
+        /// <param name="entitys"></param>
+        /// <param name="isTransaction"></param>
+        /// <returns></returns>
+        public async Task<bool> EditEntityList(List<SerialNumbers> entitys, bool isTransaction = true)
+        {
+            IDbContextTransaction _transaction = null;
+            if (isTransaction)
+                _transaction = _context.Database.BeginTransaction();
+            try
+            {
+                List<int> list = entitys.Select(s => s.Id).ToList();
+
+                var res = await _context.SerialNumbers
+                    .Where(f => list.Contains(f.Id)).ToListAsync();
+
+                _mapper.ToMapList(entitys, res);
+
+                await _context.SaveChangesAsync();
+                if (_transaction != null)
+                    _transaction.Commit();
+            }
+            catch (Exception ex)
+            {
+                if (_transaction != null)
+                    _transaction.Rollback();
+                return false;
+            }
+            return true;
+        }
+        /// <summary>
+        /// 根据序列号查询
+        /// </summary>
+        /// <param name="serialNumbers"></param>
+        /// <returns></returns>
+        public async Task<List<SerialNumbers>> GetEntityList(List<string> serialNumbers)
+        {
+            var res = await _context.SerialNumbers
+                .Where(f => serialNumbers.Contains(f.SerialNumber))
+                .ToListAsync();
+
+            return res.Clone();
+        }
+
+        /// <summary>
+        /// 根据序列号
+        /// </summary>
+        /// <param name="serialNumbers"></param>
+        /// <returns></returns>
+        public async Task<SerialNumbersResponse> GetSerialNumber(string serialNumber)
+        {
+            SerialNumbersResponse response = new SerialNumbersResponse();
+            var materials_result = await _erpService.BillQueryForMaterial();
+            if (!materials_result.IsSuccess)
+                return response;
+            var materials = materials_result.Data.ToList();
+
+            var entity = await _context.SerialNumbers.FirstOrDefaultAsync(w => serialNumber.Equals(w.SerialNumber));
+            response.SerialNumber = entity.SerialNumber;
+            response.MaterialId = entity.MaterialId;
+            response.MaterialName = _erpBasicDataExtendService.GetMaterialName(materials, entity.MaterialId);
+            response.MaterialNumber = _erpBasicDataExtendService.GetMaterialNumber(materials, entity.MaterialId);
+            response.Specifications = _erpBasicDataExtendService.GetMaterialSpecifications(materials, entity.MaterialId);
+            return new SerialNumbersResponse();
+        }
     }
 }