Compare commits

...

2 Commits

  1. 13
      src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.Application/EdiReceive/ImportRecordAppService.cs
  2. 67
      src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.Application/MsgBaseData/AssemblyCfgs/AssemblyCfgErpAppService.cs
  3. 6
      src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.Application/PrintTable/WaitPrintAppService.cs
  4. 10
      src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.Application/WY.NewJit.Application.xml
  5. 6
      src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.Domain/EdiReceive/Services/EdiParseDomainService.cs

13
src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.Application/EdiReceive/ImportRecordAppService.cs

@ -78,6 +78,9 @@ namespace WY.NewJit.EdiReceive
} }
} }
private readonly IUnitOfWorkManager _unitOfWorkManager;
#endregion #endregion
@ -91,7 +94,8 @@ namespace WY.NewJit.EdiReceive
IBlobContainer<OurFileContainer> blobContainer, IBlobContainer<OurFileContainer> blobContainer,
DicDomainService dicDomainService, DicDomainService dicDomainService,
EdiParseDomainService ediParseDomainService, EdiParseDomainService ediParseDomainService,
Microsoft.Extensions.Configuration.IConfiguration configuration) Microsoft.Extensions.Configuration.IConfiguration configuration,
IUnitOfWorkManager unitOfWorkManager)
{ {
_importRecordRepository = importRecordRepository; _importRecordRepository = importRecordRepository;
_logger = logger; _logger = logger;
@ -100,6 +104,7 @@ namespace WY.NewJit.EdiReceive
_dicDomainService = dicDomainService; _dicDomainService = dicDomainService;
_ediParseDomainService = ediParseDomainService; _ediParseDomainService = ediParseDomainService;
_configuration = configuration; _configuration = configuration;
_unitOfWorkManager = unitOfWorkManager;
} }
#region 私有方法 #region 私有方法
@ -423,7 +428,7 @@ namespace WY.NewJit.EdiReceive
/// <param name="files">导入文件</param> /// <param name="files">导入文件</param>
/// <param name="forceExecute">校验出错时,是否强制执行</param> /// <param name="forceExecute">校验出错时,是否强制执行</param>
/// <returns>执行成功返回真</returns> /// <returns>执行成功返回真</returns>
[UnitOfWork] [UnitOfWork(IsDisabled =true)]
[HttpPost] [HttpPost]
[Route("import")] [Route("import")]
[DisableRequestSizeLimit] [DisableRequestSizeLimit]
@ -465,6 +470,8 @@ namespace WY.NewJit.EdiReceive
return ret; return ret;
} }
using (var uow = _unitOfWorkManager.Begin())
{
var srcLst = impResult.Data.AsEnumerable().ToList(); var srcLst = impResult.Data.AsEnumerable().ToList();
var tarLst = ObjectMapper.Map<List<ImportRecordDto>, List<ImportRecord>>(srcLst); var tarLst = ObjectMapper.Map<List<ImportRecordDto>, List<ImportRecord>>(srcLst);
foreach (var tar in tarLst) foreach (var tar in tarLst)
@ -482,9 +489,11 @@ namespace WY.NewJit.EdiReceive
{ {
return ret2; return ret2;
} }
await uow.CompleteAsync();
ret.Status = true; ret.Status = true;
return ret; return ret;
} }
}
catch (Exception ex) catch (Exception ex)
{ {
ret.Status = false; ret.Status = false;

67
src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.Application/MsgBaseData/AssemblyCfgs/AssemblyCfgErpAppService.cs

@ -741,6 +741,14 @@ SELECT top 1 v.Id
ret.Status = false; ret.Status = false;
return ret; return ret;
} }
var err2 = CheckMaterialRepeatByAssembly(srcLst, material3Lst);
if (!string.IsNullOrEmpty(err2))
{
ret.Message = err2;
ret.Status = false;
return ret;
}
#endregion #endregion
#region 插入数据 #region 插入数据
List<AssemblyCfgGroup> assemblyCfgGroups = new List<AssemblyCfgGroup>(); List<AssemblyCfgGroup> assemblyCfgGroups = new List<AssemblyCfgGroup>();
@ -835,6 +843,65 @@ SELECT top 1 v.Id
return error; return error;
} }
/// <summary>
/// 导入总成时,校验规格说明包含的4个物料号分别是1001,1002,1003,1004
/// </summary>
/// <param name="srcLst">导入总成list</param>
/// <param name="material3Lst">总成物料list</param>
/// <returns></returns>
private string CheckMaterialRepeatByAssembly(List<ImportErpAssemblyGroupDto> srcLst, List<MaterialExt> material3Lst)
{
StringBuilder strBuild = new StringBuilder();
string[] arr = new string[4] { "1001", "1002", "1003", "1004" };
string arrStr = string.Join(',', arr);
var qry = from item in srcLst
group item by item.SpecExplain into g
select new
{
SpecExplain = g.Key,
ColorExplain = g.ElementAt(0).ColorExplain,
Details = g.Select(itm => itm.MaterialNum).ToList()
};
foreach (var item in qry)
{
if (item.Details.Count != 4)
{
strBuild.AppendLine($"规格说明{item.SpecExplain}包含的物料号不是4个");
}
//遍历物料号
List<string> strLst = new List<string>();
foreach (string materialNum in item.Details)
{
var materialObj = material3Lst.FirstOrDefault(itm => itm.RelationKey == materialNum);
if (materialObj == null)
{
strBuild.AppendLine($"规格说明{item.SpecExplain}:物料号{materialNum}在物料表不存在!");
}
else
{
if (arr.Contains(materialObj.MaterialType2) == true)
{
strLst.Add(materialObj.MaterialType2);
}
else
{
strBuild.AppendLine($"规格说明{item.SpecExplain}:物料号{materialNum}的MaterialType2不是【{arrStr}】其中之一!");
}
}
}
if (string.IsNullOrEmpty(strBuild.ToString()))
{
if (strLst.Count != strLst.Distinct().Count())
{
string repeatLst = string.Join(',', strLst);
strBuild.AppendLine($"规格说明{item.SpecExplain}包含的配置号重复{repeatLst}");
}
}
}
return strBuild.ToString();
}
//[UnitOfWork] //[UnitOfWork]
//[HttpPost] //[HttpPost]

6
src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.Application/PrintTable/WaitPrintAppService.cs

@ -830,7 +830,7 @@ namespace WY.NewJit.PrintTable
&& itm.PrintType == PrintTypeEnum.OrderPrint //顺序打印 && itm.PrintType == PrintTypeEnum.OrderPrint //顺序打印
).MinAsync(itm => itm.HostSN2); ).MinAsync(itm => itm.HostSN2);
int minHostSN = minHostSN2 % 100000; int minHostSN = minHostSN2 % 100000;
if (input.BeginHostSN != minHostSN) if (input.BeginHostSN != minHostSN2)
{ {
retLst.Add($"输入的大众起始大众顺序号{input.BeginHostSN}和未打印表中的最小大众顺序号{minHostSN2}不相等!"); retLst.Add($"输入的大众起始大众顺序号{input.BeginHostSN}和未打印表中的最小大众顺序号{minHostSN2}不相等!");
return new ListResultDto<string>(retLst); return new ListResultDto<string>(retLst);
@ -853,7 +853,7 @@ namespace WY.NewJit.PrintTable
string breakNumStr = string.Join(" ", breakNumLst); string breakNumStr = string.Join(" ", breakNumLst);
// string breakNumStr = string.Concat(breakNumLst); // string breakNumStr = string.Concat(breakNumLst);
retLst.Add($"存在断号:{breakNumStr}"); retLst.Add($"存在断号:{breakNumStr}");
return new ListResultDto<string>(retLst); //return new ListResultDto<string>(retLst);
} }
//判断未知总成 //判断未知总成
bool containNotMatch = billLst.Any(itm => itm.BillStatus == BillStatusEnum.NotMatch); bool containNotMatch = billLst.Any(itm => itm.BillStatus == BillStatusEnum.NotMatch);
@ -863,7 +863,7 @@ namespace WY.NewJit.PrintTable
string str = string.Join(" ", lst); string str = string.Join(" ", lst);
//string str = string.Concat(lst); //string str = string.Concat(lst);
retLst.Add($"存在未知总成:{str}"); retLst.Add($"存在未知总成:{str}");
return new ListResultDto<string>(retLst); //return new ListResultDto<string>(retLst);
} }
return new ListResultDto<string>(retLst); return new ListResultDto<string>(retLst);

10
src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.Application/WY.NewJit.Application.xml

@ -49,7 +49,7 @@
错误信息前缀 错误信息前缀
</summary> </summary>
</member> </member>
<member name="M:WY.NewJit.EdiReceive.ImportRecordAppService.#ctor(Volo.Abp.Domain.Repositories.IRepository{WY.NewJit.EdiReceive.Entitys.ImportRecord,System.Guid},Microsoft.Extensions.Logging.ILogger{WY.NewJit.EdiReceive.ImportRecordAppService},WY.NewJit.EntityFrameworkCore.NewJitDapperRepository,Volo.Abp.BlobStoring.IBlobContainer{WY.NewJit.Common.OurFileContainer},WY.NewJit.MsgBaseData.DicDomainService,WY.NewJit.EdiReceive.Services.EdiParseDomainService,Microsoft.Extensions.Configuration.IConfiguration)"> <member name="M:WY.NewJit.EdiReceive.ImportRecordAppService.#ctor(Volo.Abp.Domain.Repositories.IRepository{WY.NewJit.EdiReceive.Entitys.ImportRecord,System.Guid},Microsoft.Extensions.Logging.ILogger{WY.NewJit.EdiReceive.ImportRecordAppService},WY.NewJit.EntityFrameworkCore.NewJitDapperRepository,Volo.Abp.BlobStoring.IBlobContainer{WY.NewJit.Common.OurFileContainer},WY.NewJit.MsgBaseData.DicDomainService,WY.NewJit.EdiReceive.Services.EdiParseDomainService,Microsoft.Extensions.Configuration.IConfiguration,Volo.Abp.Uow.IUnitOfWorkManager)">
<summary> <summary>
构造函数 构造函数
</summary> </summary>
@ -414,6 +414,14 @@
<param name="files"></param> <param name="files"></param>
<returns></returns> <returns></returns>
</member> </member>
<member name="M:WY.NewJit.MsgBaseData.AssemblyCfgErpAppService.CheckMaterialRepeatByAssembly(System.Collections.Generic.List{WY.NewJit.MsgBaseData.ImportErpAssemblyGroupDto},System.Collections.Generic.List{WY.NewJit.Extends.PaiGe.MaterialExt})">
<summary>
导入总成时,校验规格说明包含的4个物料号分别是1001,1002,1003,1004
</summary>
<param name="srcLst">导入总成list</param>
<param name="material3Lst">总成物料list</param>
<returns></returns>
</member>
<member name="M:WY.NewJit.MsgBaseData.AssemblyCfgErpAppService.RemoveRepeatErpAssembly(System.Int32)"> <member name="M:WY.NewJit.MsgBaseData.AssemblyCfgErpAppService.RemoveRepeatErpAssembly(System.Int32)">
<summary> <summary>
系统初始化时使用,去掉重复的ERP总成 系统初始化时使用,去掉重复的ERP总成

6
src/Modules/新版JIT或JIS系统服务端/src/WY.NewJit.Domain/EdiReceive/Services/EdiParseDomainService.cs

@ -400,10 +400,14 @@ namespace WY.NewJit.EdiReceive.Services
int curVal = notRepeatOrder[curIdx].HostSN; int curVal = notRepeatOrder[curIdx].HostSN;
int priorIdx = curIdx - 1; int priorIdx = curIdx - 1;
int priorVal = notRepeatOrder[priorIdx].HostSN; int priorVal = notRepeatOrder[priorIdx].HostSN;
if (curVal - priorVal != 1) if (curVal - priorVal > 1)
{ {
sb.AppendLine($"流水号{priorVal}和{curVal}之间存在断号"); sb.AppendLine($"流水号{priorVal}和{curVal}之间存在断号");
} }
else if (curVal - priorVal == 0)
{
sb.AppendLine($"流水号{priorVal}和{curVal}之间存在重复");
}
} }
return sb.ToString(); return sb.ToString();
} }

Loading…
Cancel
Save