358 lines
15 KiB
C#
358 lines
15 KiB
C#
using AutoMapper;
|
|
using Microsoft.EntityFrameworkCore;
|
|
using Microsoft.EntityFrameworkCore.Storage;
|
|
using Newtonsoft.Json;
|
|
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.Dto.Erp;
|
|
using WMS.Web.Core.Dto.Erp.Customer;
|
|
using WMS.Web.Core.Dto.SerialNumbers;
|
|
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
|
|
{
|
|
/// <summary>
|
|
/// 序列号
|
|
/// </summary>
|
|
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, 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)
|
|
{
|
|
IDbContextTransaction _transaction = null;
|
|
if (isTransaction)
|
|
_transaction = _context.Database.BeginTransaction();
|
|
try
|
|
{
|
|
if (entitys != null && entitys.Count != 0)
|
|
{
|
|
await _context.SerialNumbers.AddRangeAsync(entitys);
|
|
await _context.SaveChangesAsync();
|
|
}
|
|
if (_transaction != null)
|
|
_transaction.Commit();
|
|
return true;
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
if (_transaction != null)
|
|
_transaction.Rollback();
|
|
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();
|
|
|
|
var ids_e = res.Select(s => s.Id).ToList();
|
|
//在序列表里没找到的序列码 则到老ops序列码数据里去处理 list比较 取差集
|
|
var ids_c = list.Except(ids_e);
|
|
if (ids_c.Count() > 0)
|
|
{
|
|
var entitys_ops = entitys.Where(w => ids_c.Contains(w.Id)).ToList();
|
|
var res_ops = await EditEntityList_Ops(entitys_ops, false);
|
|
if (!res_ops) return false;
|
|
}
|
|
|
|
_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="serialNumber"></param>
|
|
/// <returns></returns>
|
|
public async Task<SerialNumbersResponse> Get(string serialNumber)
|
|
{
|
|
List<ErpMaterialDto> materials = new List<ErpMaterialDto>();
|
|
var materials_result = await _erpService.BillQueryForMaterial();
|
|
if (materials_result.IsSuccess)
|
|
materials = materials_result.Data.ToList();
|
|
|
|
List<ErpCustomerDto> customers = new List<ErpCustomerDto>();
|
|
var customer_result = await _erpService.BillQueryForCustomer();
|
|
if (customer_result.IsSuccess)
|
|
customers = customer_result.Data.ToList();
|
|
|
|
var s = await _context.SerialNumbers
|
|
.FirstOrDefaultAsync(f => serialNumber.Equals(f.SerialNumber));
|
|
if (s == null)
|
|
{
|
|
var so = await _context.SerialNumbers_Ops
|
|
.FirstOrDefaultAsync(f => serialNumber.Equals(f.SerialNumber));
|
|
if (so == null)
|
|
return null;
|
|
else
|
|
s = _mapper.Map<SerialNumbers>(so);
|
|
}
|
|
SerialNumbersResponse respone = new SerialNumbersResponse()
|
|
{
|
|
MaterialName = _erpBasicDataExtendService.GetMaterialName(materials, s.MaterialNumber),
|
|
MaterialNumber = s.MaterialNumber,
|
|
Specifications = _erpBasicDataExtendService.GetMaterialSpecifications(materials, s.MaterialNumber),
|
|
CompleteCartonTime = s.CompleteCartonTime.DateToStringSeconds(),
|
|
InStockTime = s.InStockTime.DateToStringSeconds(),
|
|
OutStockTime = s.OutStockTime.DateToStringSeconds(),
|
|
PurchaseBillNo = s.PurchaseBillNo,
|
|
Customer = _erpBasicDataExtendService.GetCustomerName(customers, s.CustomerId),
|
|
SerialNumber = s.SerialNumber
|
|
};
|
|
if (!string.IsNullOrEmpty(s.SalBillNo))
|
|
{
|
|
var list = JsonConvert.DeserializeObject<List<string>>(s.SalBillNo);
|
|
if (list.Count() > 0)
|
|
respone.SalBillNo = list[0];
|
|
}
|
|
|
|
return respone;
|
|
}
|
|
|
|
/// <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();
|
|
var res_c = res.Clone();
|
|
|
|
var s_e = res.Select(s => s.SerialNumber).ToList();
|
|
//在序列表里没找到的序列码 则到老ops序列码数据里去处理 list比较 取差集
|
|
var s_c = serialNumbers.Except(s_e);
|
|
if (s_c.Count() > 0)
|
|
{
|
|
var entitys_ops = serialNumbers.Where(w => s_c.Contains(w)).ToList();
|
|
var r_o = await _context.SerialNumbers_Ops
|
|
.Where(f => serialNumbers.Contains(f.SerialNumber))
|
|
.ToListAsync();
|
|
|
|
res_c.AddRange(_mapper.Map<List<SerialNumbers>>(r_o.Clone()));
|
|
}
|
|
|
|
return res_c;
|
|
}
|
|
|
|
public async Task<List<SerialNumbers>> GetEntityListByBoxId(int boxId)
|
|
{
|
|
var res = await _context.SerialNumbers
|
|
.Where(f => f.BoxId == boxId)
|
|
.ToListAsync();
|
|
var res_c = res.Clone();
|
|
|
|
var r_o = await _context.SerialNumbers_Ops
|
|
.Where(f => f.BoxId == boxId)
|
|
.ToListAsync();
|
|
if (r_o.Count() > 0)
|
|
res_c.AddRange(_mapper.Map<List<SerialNumbers>>(r_o.Clone()));
|
|
|
|
return res_c;
|
|
}
|
|
/// <summary>
|
|
/// 根据箱Ids查询集合
|
|
/// </summary>
|
|
/// <param name="boxIds"></param>
|
|
/// <returns></returns>
|
|
public async Task<List<SerialNumbers>> GetEntityListByBoxIds(List<int> boxIds)
|
|
{
|
|
var res = await _context.SerialNumbers
|
|
.Where(f => boxIds.Contains(f.BoxId))
|
|
.ToListAsync();
|
|
var res_c = res.Clone();
|
|
|
|
var r_o = await _context.SerialNumbers_Ops
|
|
.Where(f => boxIds.Contains(f.BoxId))
|
|
.ToListAsync();
|
|
if (r_o.Count() > 0)
|
|
res_c.AddRange(_mapper.Map<List<SerialNumbers>>(r_o.Clone()));
|
|
|
|
return res_c;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 根据序列号
|
|
/// </summary>
|
|
/// <param name="serialNumbers"></param>
|
|
/// <returns></returns>
|
|
public async Task<MaterialResponse> GetSerialNumber(string serialNumber, string orgCode, bool IsOps = false)
|
|
{
|
|
MaterialResponse response = new MaterialResponse();
|
|
var materials_result = await _erpService.BillQueryForMaterial();
|
|
if (!materials_result.IsSuccess)
|
|
return response;
|
|
var materials = materials_result.Data.ToList();
|
|
|
|
var m = materials.Where(f => (f.Specifications.Equals(serialNumber) || f.MaterialNumber.Equals(serialNumber)));
|
|
if (!string.IsNullOrEmpty(orgCode))
|
|
m = m.Where(w => w.OrgCode.Equals(orgCode));
|
|
var material = m.FirstOrDefault();
|
|
if (material != null)
|
|
{
|
|
response.MaterialName = _erpBasicDataExtendService.GetMaterialName(materials, material.MaterialNumber);
|
|
response.MaterialNumber = material.MaterialNumber;
|
|
response.Specifications = _erpBasicDataExtendService.GetMaterialSpecifications(materials, material.MaterialNumber);
|
|
return response;
|
|
}
|
|
var entity = await _context.SerialNumbers
|
|
.GroupJoin(_context.BoxInventory.Include(x => x.Details), serial => serial.BoxId, boxInventory => boxInventory.BoxId, (serial, boxInventory) => new { serial, boxInventory })
|
|
.SelectMany(x => x.boxInventory.DefaultIfEmpty(), (p, boxInventory) => new { p.serial, boxInventory })
|
|
.GroupJoin(_context.Box, s => s.serial.BoxId, box => box.Id, (s, box) => new { s.serial, s.boxInventory, box })
|
|
.SelectMany(x => x.box.DefaultIfEmpty(), (p, box) => new { p.serial, p.boxInventory, box })
|
|
.FirstOrDefaultAsync(w => serialNumber.Equals(w.serial.SerialNumber));
|
|
if (entity == null || entity.serial == null)
|
|
{
|
|
if (IsOps)
|
|
return await GetSerialNumber_Ops(serialNumber);
|
|
else
|
|
return null;
|
|
}
|
|
response.IsOldOps = false;
|
|
response.BoxId = entity.serial.BoxId;
|
|
response.BoxBillNo = entity?.box?.BoxBillNo ?? "";
|
|
response.SubStockCode = entity?.boxInventory?.SubStockCode ?? "";
|
|
response.SerialNumber = entity.serial.SerialNumber;
|
|
response.MaterialName = _erpBasicDataExtendService.GetMaterialName(materials, entity.serial.MaterialNumber);
|
|
response.MaterialNumber = entity.serial.MaterialNumber;
|
|
response.Specifications = _erpBasicDataExtendService.GetMaterialSpecifications(materials, entity.serial.MaterialNumber);
|
|
if (entity.boxInventory != null)
|
|
response.IsBoxInventory = entity.boxInventory.Details.SelectMany(s => s.SerialNumbers).Where(w => serialNumber.Equals(w)).Count() >= 1 ? true : false;
|
|
|
|
|
|
return response;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 查询老ops序列码
|
|
/// </summary>
|
|
/// <param name="serialNumbers"></param>
|
|
/// <returns></returns>
|
|
private async Task<MaterialResponse> GetSerialNumber_Ops(string serialNumber)
|
|
{
|
|
MaterialResponse response = new MaterialResponse();
|
|
var materials_result = await _erpService.BillQueryForMaterial();
|
|
if (!materials_result.IsSuccess)
|
|
return response;
|
|
var materials = materials_result.Data.ToList();
|
|
|
|
var entity = await _context.SerialNumbers_Ops
|
|
.GroupJoin(_context.BoxInventory.Include(x => x.Details), serial => serial.BoxId, boxInventory => boxInventory.BoxId, (serial, boxInventory) => new { serial, boxInventory })
|
|
.SelectMany(x => x.boxInventory.DefaultIfEmpty(), (p, boxInventory) => new { p.serial, boxInventory })
|
|
.GroupJoin(_context.Box, s => s.serial.BoxId, box => box.Id, (s, box) => new { s.serial, s.boxInventory, box })
|
|
.SelectMany(x => x.box.DefaultIfEmpty(), (p, box) => new { p.serial, p.boxInventory, box })
|
|
.FirstOrDefaultAsync(w => serialNumber.Equals(w.serial.SerialNumber));
|
|
if (entity == null || entity.serial == null) return null;
|
|
response.IsOldOps = true;
|
|
response.BoxId = entity.serial.BoxId;
|
|
response.BoxBillNo = entity?.box?.BoxBillNo ?? "";
|
|
response.SubStockCode = entity?.boxInventory?.SubStockCode ?? "";
|
|
response.SerialNumber = entity.serial.SerialNumber;
|
|
response.MaterialName = _erpBasicDataExtendService.GetMaterialName(materials, entity.serial.MaterialNumber);
|
|
response.MaterialNumber = entity.serial.MaterialNumber;
|
|
response.Specifications = _erpBasicDataExtendService.GetMaterialSpecifications(materials, entity.serial.MaterialNumber);
|
|
if (entity.boxInventory != null)
|
|
response.IsBoxInventory = entity.boxInventory.Details.SelectMany(s => s.SerialNumbers).Where(w => serialNumber.Equals(w)).Count() >= 1 ? true : false;
|
|
|
|
|
|
return response;
|
|
}
|
|
/// <summary>
|
|
/// 老ops条码批量修改
|
|
/// </summary>
|
|
/// <param name="entitys"></param>
|
|
/// <param name="isTransaction"></param>
|
|
/// <returns></returns>
|
|
private async Task<bool> EditEntityList_Ops(List<SerialNumbers> entitys, bool isTransaction = true)
|
|
{
|
|
IDbContextTransaction _transaction = null;
|
|
if (isTransaction)
|
|
_transaction = _context.Database.BeginTransaction();
|
|
try
|
|
{
|
|
var opsList = _mapper.Map<List<SerialNumbers_Ops>>(entitys);
|
|
|
|
List<int> list = opsList.Select(s => s.Id).ToList();
|
|
|
|
var res = await _context.SerialNumbers_Ops
|
|
.Where(f => list.Contains(f.Id)).ToListAsync();
|
|
|
|
_mapper.ToMapList(opsList, res);
|
|
|
|
await _context.SaveChangesAsync();
|
|
if (_transaction != null)
|
|
_transaction.Commit();
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
if (_transaction != null)
|
|
_transaction.Rollback();
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 根据序列号查询老ops
|
|
/// </summary>
|
|
/// <param name="serialNumbers"></param>
|
|
/// <returns></returns>
|
|
public async Task<List<SerialNumbers>> GetEntityList_Ops(List<string> serialNumbers)
|
|
{
|
|
var res = await _context.SerialNumbers_Ops
|
|
.Where(f => serialNumbers.Contains(f.SerialNumber))
|
|
.ToListAsync();
|
|
|
|
return _mapper.Map<List<SerialNumbers>>(res.Clone());
|
|
}
|
|
}
|
|
}
|