using MES.Service.DB;
|
using MES.Service.Dto.service;
|
using MES.Service.Modes;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace MES.Service.service.Warehouse
|
{
|
public class MesItemQtManager:Repository<MesItemQt>
|
{
|
public bool MiscellaneousIssues(MesItemQtDto mesItemQtDto)
|
{
|
var itemQtFrom = mesItemQtDto.from;
|
var itemQtLists = mesItemQtDto.items;
|
|
// 根据AsnNo和MesNo对明细进行分组
|
//var groupedItems = itemOutLists
|
// .GroupBy(item => new { item.AsnNo, item.MesNo, item.SqNo })
|
// .ToList();
|
|
bool result = true;
|
//foreach (var group in itemQtRKLists)
|
//{
|
//if (group.Key.AsnNo == null)
|
//{
|
// throw new NotImplementedException("AsnNo不能为空");
|
//}
|
|
//if (group.Key.MesNo == null)
|
//{
|
// throw new NotImplementedException("入库单单号不能为空");
|
//}
|
|
//if (group.Key.SqNo == null)
|
//{
|
// throw new NotImplementedException("退货申请单行号不能为空");
|
//}
|
|
// 创建一个临时的itemOutFrom对象，使用分组的Key作为主要属性
|
//var tempItemOutFrom = new ItemOutFrom
|
//{
|
// AsnNo = group.Key.AsnNo,
|
// MesNo = group.Key.MesNo,
|
// SqNo = group.Key.SqNo,
|
// // 继承原始itemOutFrom的其他属性
|
// RtnNo = itemOutFrom.RtnNo,
|
// Type = itemOutFrom.Type,
|
// CreateBy = itemOutFrom.CreateBy,
|
// FMRMODE = itemOutFrom.FMRMODE,
|
// DepotId = itemOutFrom.DepotId,
|
// SupperId = itemOutFrom.SupperId
|
//};
|
|
// 根据Type执行不同的逻辑
|
switch (itemQtFrom.Type)
|
{
|
case "1":
|
{
|
var mesInvItemOuts = Db.Queryable<MesItemQt>()
|
.Where(s => s.Qtck == itemQtFrom.ApplyNumber
|
|
)
|
.Count();
|
|
if (mesInvItemOuts > 0)
|
{
|
throw new NotImplementedException(
|
itemQtFrom.ApplyNumber +
|
"的杂发申请单已经存在");
|
}
|
|
// 为当前分组保存数据
|
var groupResult = Save(itemQtFrom, itemQtLists);
|
if (!groupResult)
|
{
|
result = false;
|
}
|
|
break;
|
}
|
case "4":
|
var removeResult = Remove(itemQtFrom);
|
if (!removeResult)
|
{
|
result = false;
|
}
|
|
break;
|
default:
|
result = false;
|
break;
|
}
|
//}
|
|
return result;
|
}
|
|
|
private bool Save(MesItemQtFrom from, List<MesItemQtList> items)
|
{
|
//var mesInvItemIns = Db.Queryable<MesInvItemIns>()
|
// .Where(s => s.BillTypeId == 100
|
// && s.TransctionNo == "101"
|
// && s.BillNo == from.MesNo
|
// ).First();
|
|
//if (mesInvItemIns == null)
|
//{
|
// throw new NotImplementedException("采购入库不存在");
|
//}
|
|
|
string SuppNo = "";
|
if (from.SupplierCode != "" && from.SupplierCode != null)
|
{
|
var mesLinkU9 = Db.Queryable<MesLinkU9>()
|
.Where(s => s.TableType == "MES_SUPPLIER"
|
&& s.U9Id == from.SupplierCode).First();
|
|
if (mesLinkU9 == null)
|
{
|
throw new NotImplementedException("供应商ID不存在或未同步于U9");
|
}
|
|
var mesSupplier = Db.Queryable<MesSupplier>()
|
.Where(s => s.Id == Decimal.Parse(mesLinkU9.MesId))
|
.First();
|
if (mesSupplier == null)
|
{
|
throw new NotImplementedException("[" + from.SupplierCode +
|
"]供应商不存在，请同步给MES");
|
}
|
SuppNo = mesSupplier.SuppNo;
|
}
|
var mesDepots = Db.Queryable<MesDepots>()
|
.Where(s => s.DepotId == Decimal.Parse(from.FromWarehouse)).First();
|
|
if (mesDepots == null)
|
{
|
throw new NotImplementedException("[" + from.FromWarehouse +
|
"]仓库不存在，请同步给MES");
|
}
|
|
var sysDepartment = Db.Queryable<SysDepartment>()
|
.Where(s => s.Departmentid == Decimal.Parse(from.ApplyDept)).First();
|
|
if (sysDepartment == null)
|
{
|
throw new NotImplementedException("[" + from.ApplyDept +
|
"]部门不存在，请同步给MES");
|
}
|
|
|
var nextSequenceValue =
|
Db.Ado.SqlQuery<decimal>("SELECT SEQ_QTCK.NEXTVAL FROM DUAL")
|
.First();
|
|
// var billCode =
|
// Db.Ado.SqlQuery<string>(
|
// "SELECT GETBILLCODE1('1000', '1000', 'TLSQ') FROM DUAL")
|
// .First();
|
//var billCode = from.RtnNo;
|
|
// 创建杂发申请单记录
|
var MesItemQtrk = new MesItemQt
|
{
|
Id = nextSequenceValue,
|
Qtck = from.ApplyNumber,
|
Qt001 = from.Equals(null) ? DateTime.Now : from.ApplyDate,
|
Qt002 = from.Equals(null) ? DateTime.Now : from.AuditDate,
|
Qt003 = from.DocumentType,
|
Qt004 = from.StockOutType,
|
Qt005 = from.CreatedBy,
|
Qt006 = from.WorkOrder,
|
Qt009 = sysDepartment.Departmentname,
|
Qt012 = sysDepartment.Departmentcode,
|
Qt010 = from.Reason,
|
Qt011 = mesDepots.DepotCode,
|
Qt008 = mesDepots.DepotName,
|
|
Qt015 = 1,
|
Qt016 = from.Auditor,
|
Qt017 = from.TaskNumber,
|
Qt018 = SuppNo,
|
Qt019 = from.Direction,
|
Qt020 = from.OwnerType,
|
CustomerCode = from.CustomerCode,
|
Receiver = from.Receiver,
|
Department = from.Department,
|
StockKeeper = from.StockKeeper,
|
SourceType = from.SourceType,
|
SourceDocument = from.SourceDocument,
|
ProductionRelated = from.ProductionRelated,
|
ProductionLine = from.ProductionLine,
|
ProductionActivity = from.ProductionActivity,
|
FinishedGoods = from.FinishedGoods,
|
ReversePosting = from.ReversePosting,
|
AccountingPeriod = from.AccountingPeriod,
|
Employee = from.Employee,
|
FalseReturn = from.FalseReturn,
|
ProjectCode = from.ProjectCode,
|
TaskCode = from.TaskCode,
|
Status = from.Status,
|
OwnerOrganization = from.OwnerOrganization
|
|
|
};
|
|
// 创建杂发申请单行记录
|
var mesItemQtDetail = new List<MesItemQtDatall>();
|
|
foreach (var ItemQtRKList in items)
|
{
|
// 检查必要字段是否为空
|
//if (string.IsNullOrEmpty(itemOutList.SrcDocNo))
|
//{
|
// throw new NotImplementedException("采购订单号不能为空");
|
//}
|
|
|
|
//var mesRohInData = Db.Queryable<MesRohInData>()
|
// .Where(s => s.BillNo == itemOutList.SrcDocNo
|
// && s.OrderLineId == itemOutList.SrcDocLineNo)
|
// .First();
|
|
//if (mesRohInData == null)
|
//{
|
// throw new NotImplementedException("采购订单不存在");
|
//}
|
|
//var deliveryDetail = Db.Queryable<DeliveryDetail>()
|
// .Where(a => a.Zzasn == from.AsnNo
|
// && Int32.Parse(a.ZzitemId) ==
|
// Int32.Parse(itemOutList.AsnLineNo))
|
// .Count();
|
|
//if (deliveryDetail <= 0)
|
//{
|
// throw new NotImplementedException("[" + from.AsnNo + "]的明细行[" +
|
// itemOutList.AsnLineNo +
|
// "]不存在");
|
//}
|
|
var itemIdLinkU9 = Db.Queryable<MesLinkU9>()
|
.Where(s => s.TableType == "MES_ITEMS"
|
&& s.U9Id == ItemQtRKList.ItemId).First();
|
|
if (itemIdLinkU9 == null)
|
{
|
throw new NotImplementedException("物料ID不存在或未同步于U9");
|
}
|
|
var mesItems = Db.Queryable<MesItems>()
|
.Where(s => s.Id == Decimal.Parse(itemIdLinkU9.MesId))
|
.First();
|
|
if (mesItems == null)
|
{
|
throw new NotImplementedException("[" + ItemQtRKList.ItemId +
|
"]物料不存在，请同步给MES");
|
}
|
var mesDepot = "";
|
if (ItemQtRKList.StorageLocation != null && ItemQtRKList.StorageLocation != null)
|
{
|
mesDepots = Db.Queryable<MesDepots>()
|
.Where(s => s.DepotId == Decimal.Parse(ItemQtRKList.StorageLocation)).First();
|
if (mesDepots == null)
|
{
|
throw new NotImplementedException("[" + ItemQtRKList.StorageLocation +
|
"]仓库不存在，请同步给MES");
|
}
|
mesDepot = mesDepots.DepotCode;
|
}
|
string supplierCode = "";
|
if (ItemQtRKList.SupplierCode != null && ItemQtRKList.SupplierCode != "")
|
{
|
var mesLinkU9 = Db.Queryable<MesLinkU9>()
|
.Where(s => s.TableType == "MES_SUPPLIER"
|
&& s.U9Id == ItemQtRKList.SupplierCode).First();
|
|
if (mesLinkU9 == null)
|
{
|
throw new NotImplementedException("[" + ItemQtRKList.SupplierCode +
|
"]供应商不存在，请同步给MES");
|
}
|
var mesSupplier = Db.Queryable<MesSupplier>()
|
.Where(s => s.Id == Decimal.Parse(mesLinkU9.MesId))
|
.First();
|
if (mesSupplier == null)
|
{
|
throw new NotImplementedException("[" + ItemQtRKList.SupplierCode +
|
"]供应商不存在，请同步给MES");
|
}
|
supplierCode = mesSupplier.SuppNo;
|
}
|
|
|
//var mesInvItemInCItems = Db.Queryable<MesInvItemInCItems>()
|
// .Where(s => s.ItemInId == mesInvItemIns.Id
|
// && s.ItemNo == mesItems.ItemNo
|
// && s.Ebeln == itemOutList.SrcDocNo
|
// && s.EbelnLineNo ==
|
// Decimal.Parse(itemOutList.SrcDocLineNo)
|
// && s.SuppNo == mesSupplier.SuppNo
|
// && Convert.ToInt32(s.ZzitemId) ==
|
// Convert.ToInt32(itemOutList.AsnLineNo)).First();
|
|
//if (mesInvItemInCItems == null)
|
//{
|
// throw new NotImplementedException("没有对应的入库明细");
|
//}
|
|
|
// 确保CbillNo不为空
|
if (ItemQtRKList.AppliedQuantity <= 0 || ItemQtRKList.AppliedQuantity == null)
|
{
|
throw new NotImplementedException("申请数量不能为0或NULL值！");
|
}
|
|
mesItemQtDetail.Add(new MesItemQtDatall
|
{
|
Mid = nextSequenceValue,
|
Qd002 = mesItems.ItemNo,
|
Qd003 = mesItems.ItemName,
|
Qd004 = mesItems.ItemModel,
|
Qd005 = mesItems.ColorName,
|
Qd006 = ItemQtRKList.PlannedQuantity,
|
Qd007 = ItemQtRKList.AppliedQuantity,
|
Qd008 = 0, // 已入数量默认为0
|
Qd009 = mesItems.ItemUnit,
|
Qd010 = ItemQtRKList.Remark,
|
Qd012 = mesItems.Id, // 物料内码
|
LineNumber = ItemQtRKList.LineNumber,
|
ProductionRelated = ItemQtRKList.ProductionRelated,
|
StorageType = ItemQtRKList.StorageType,
|
OwnerOrganization = ItemQtRKList.OwnerOrganization,
|
StorageLocation = mesDepot,
|
SupplierCode = supplierCode,
|
CustomerCode = ItemQtRKList.CustomerCode,
|
ProjectCode = ItemQtRKList.ProjectCode,
|
TaskCode = ItemQtRKList.TaskCode,
|
ProductionOrder = ItemQtRKList.ProductionOrder,
|
DailyPlan = ItemQtRKList.DailyPlan,
|
ProductionActivity = ItemQtRKList.ProductionActivity,
|
FinishedProduct = ItemQtRKList.FinishedProduct,
|
PickingUsage= ItemQtRKList.PickingUsage
|
|
|
});
|
}
|
|
var outItemCommand = Db.Insertable(mesItemQtDetail)
|
.PageSize(1).IgnoreColumnsNull().ExecuteCommand();
|
if (outItemCommand <= 0)
|
{
|
throw new Exception("创建杂发单子表失败");
|
}
|
|
// 插入采购退料单记录
|
var insertResult = Db.Insertable(MesItemQtrk).IgnoreColumns(true)
|
.ExecuteCommand();
|
if (insertResult <= 0)
|
{
|
throw new Exception("创建杂发单失败");
|
}
|
|
return outItemCommand + insertResult >= 2;
|
}
|
|
private bool Remove(MesItemQtFrom from)
|
{
|
// 查找要删除的杂发单
|
var mesItemQtrk = Db.Queryable<MesItemQt>()
|
.Where(s => s.Qtck == from.ApplyNumber
|
).ToList();
|
|
if (mesItemQtrk == null || mesItemQtrk.Count == 0)
|
{
|
throw new NotImplementedException("找不到对应的杂发单: " + from.ApplyNumber);
|
}
|
|
// 检查是否有已审核的单据，如果存在已审核(Status=1)则不允许删除
|
//if (mesInvItemOuts.Any(item => item.Status == 1))
|
//{
|
// throw new NotImplementedException("存在已审核的采购退料单，不允许删除");
|
//}
|
|
// 删除所有相关单据
|
foreach (var itemRK in mesItemQtrk)
|
{
|
// 查找要删除的杂发单明细
|
var mesInvItemOutItems = Db.Queryable<MesItemQtDatall>()
|
.Where(s => s.Mid == itemRK.Id)
|
.ToList();
|
|
if (mesInvItemOutItems == null || mesInvItemOutItems.Count == 0)
|
{
|
throw new NotImplementedException(
|
$"找不到杂发单[{from.ApplyNumber}]对应的明细");
|
}
|
|
// 删除杂发单明细
|
var deleteItemsResult = Db.Deleteable<MesItemQtDatall>()
|
.Where(s => s.Mid == itemRK.Id)
|
.ExecuteCommand();
|
|
if (deleteItemsResult <= 0)
|
{
|
throw new Exception($"找不到杂发单[ {from.ApplyNumber}]明细，删除失败");
|
}
|
|
// 删除杂发单
|
var deleteResult = Db.Deleteable<MesItemQt>()
|
.Where(s => s.Id == itemRK.Id)
|
.ExecuteCommand();
|
|
if (deleteResult <= 0)
|
{
|
throw new Exception($"删除杂发单[{from.ApplyNumber}]失败");
|
}
|
}
|
|
return true;
|
}
|
}
|
}
|
