using Rhea.Common;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using Tiger.Model.MES.Yada;
|
using Tiger.Model;
|
using Tiger.IBusiness;
|
using SqlSugar;
|
using System.Data.Entity.Core.Common.CommandTrees.ExpressionBuilder;
|
|
namespace Tiger.Business.WMS
|
{
|
public partial class U9C_WMS: IU9C_WMS
|
{
|
/// <summary>
|
/// 同步物料条码信息
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
public ApiAction In_BySync(U9C_Base_Input input)
|
{
|
var action = new ApiAction();
|
Logger.Scheduler.Info($"物料条码信息开始同步。。。数据检查进行中。。。");
|
Logger.Scheduler.Info($"{input.triggerDetail}");
|
DbClient db = Biz.DataSource["YadaU9C"].Client;
|
string UserCode = "System_In_BySync";
|
var list = db.Ado.SqlQuery<mes_MaterialBarCodeByBin>($"select *,cast('{DateTime.Now.ToString("yyyy-MM-dd")}' as DATETIME) as PROD_DATE,'' as Unit,'' as LotNo from mes_MaterialBarCodeByBin where ModifiedOn > '{input.startTime}' And ModifiedOn < '{input.endTime}'");
|
try
|
{
|
foreach (var item in list)
|
{
|
Barcode barcode = new Barcode(item.Code);
|
item.Code = item.Code;
|
item.Segment5 = barcode.ItemCode;
|
item.PROD_DATE = barcode.DateCode.ToDateTime();
|
item.Unit = barcode.Unit;
|
item.LotNo= barcode.LotNo.IsNullOrEmpty() ? item.Segment7 : barcode.LotNo;
|
}
|
|
//保存到数据库
|
var _db = Business.Biz.Db;
|
var dbTran = db.UseTran(() =>
|
{
|
//入库
|
_db.Insertable(list, UserCode).ExecuteCommand();
|
});
|
if (!dbTran.IsSuccess)
|
{
|
Logger.Default.Fatal(dbTran.ErrorException, "Database transaction save exception");
|
throw dbTran.ErrorException;
|
}
|
|
SugarParameter[] pars = Biz.Db.Ado.GetParameters(new { ERR_CODE = 0, ERR_MSG = "" });
|
pars[0].Direction = System.Data.ParameterDirection.Output;
|
pars[1].Direction = System.Data.ParameterDirection.Output;
|
var codeList = Biz.Db.Ado.UseStoredProcedure().SqlQuery<mes_MaterialBarCodeByBin>("SP_WMS_IMPORT_ITEM", pars);//返回List
|
if (pars[0].Value.ToInt32() == 0)
|
{
|
Logger.Scheduler.Info($"同步条码入库，总数：[{list.Count}]");
|
action.Message = $"同步条码入库，总数：[{list.Count}]";
|
}
|
else
|
{
|
Logger.Scheduler.Error(pars[1].Value.ToString());
|
}
|
}
|
catch (Exception ex)
|
{
|
action.CatchExceptionWithLog(ex, Biz.L(ex.Message));
|
}
|
return action;
|
}
|
|
/// <summary>
|
/// 同步送货单Asn信息
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
public ApiAction In_DocASN(U9C_Base_Input input)
|
{
|
var action = new ApiAction();
|
Logger.Scheduler.Info($"送货单Asn信息开始同步。。。数据检查进行中。。。");
|
Logger.Scheduler.Info($"{input.triggerDetail}");
|
DbClient db = Biz.DataSource["YadaU9C"].Client;
|
string UserCode = "U9C_In_DocASN";
|
var list = db.Queryable<mes_AsnDocInfo>().Where(x => x.ModifiedOn > input.startTime.ToDateTime() && x.ModifiedOn < input.endTime.ToDateTime()).ToList();
|
var orgs = Biz.Db.Queryable<SYS_ORGANIZATION>().ToList();
|
List<BIZ_U9_ASN> asns = new();
|
List<BIZ_U9_ASN_DTL> dtls = new();
|
List<BIZ_U9_ASN_SN> sns = new();
|
List<WMS_ITEM> items = new();
|
List<WMS_ITEM_HIS> hiss = new();
|
List<WMS_ITEM_EXT> itemExts = new();
|
List<WMS_ITEM_PKG> pkgs = new();
|
|
if (list != null && list.Count > 0)
|
{
|
asns = list
|
.GroupBy(x => new { x.DocNo })
|
.Select(x => new BIZ_U9_ASN
|
{
|
STATUS = BIZ_U9_ASN.STATUSs.Imported.GetValue(),
|
ORDER_NO = x.Key.DocNo,
|
ID = x.Max(t => t.AsnId).ToString(),
|
SUPP_CODE = x.Max(t => t.SupplierCode),
|
SUPP_NAME = x.Max(t => t.SupplierName),
|
DELIVERY_DATE = x.Max(t => t.ShipDate),
|
PLANARRIVED_DATE = x.Max(t => t.PlanArriveDate),
|
ORDER_DATE = x.Max(t => t.ModifiedOn),
|
CREATE_TIME = x.Max(t => t.ModifiedOn).ToDateTime(),//--时间不更新
|
CREATE_USER= UserCode,
|
UPDATE_TIME = x.Max(t => t.ModifiedOn).ToDateTime(),
|
UPDATE_USER = UserCode,
|
AUTH_ORG = orgs.FirstOrDefault(q => q.ID == x.Max(t => t.Org).ToString())?.ORG_CODE,
|
HANDLED=-1, //未处理
|
HANDLED_DATE=DateTime.Now,
|
})
|
.ToList();
|
Logger.Scheduler.Info($"送货单表头信息存入实体中，总数：[{asns.Count}]");
|
foreach (var dtl in list)
|
{
|
BIZ_U9_ASN_DTL info = new()
|
{
|
STATUS = BIZ_U9_ASN.STATUSs.Imported.GetValue(),
|
ORDER_NO = dtl.DocNo,
|
LINE_NO = dtl.DocLineNo.ToString(),
|
ID = dtl.LineID.ToString(),
|
ITEM_CODE = dtl.ItemCode,
|
QTY_PACKING = dtl.PackQty.ToDouble(),
|
QTY = dtl.ShipQtyTU.ToDouble(),
|
PO_QTY = dtl.POQtyTU,
|
SUPP_CODE = dtl.SupplierCode,
|
SUPP_LOTNO = dtl.SupplierLot,
|
LOTNO = dtl.LotMater,
|
AUTH_ORG = orgs.FirstOrDefault(q => q.ID == dtl.Org.ToString())?.ORG_CODE,
|
CREATE_TIME = dtl.ModifiedOn,//--时间不更新
|
CREATE_USER = UserCode,
|
UPDATE_TIME = dtl.ModifiedOn,
|
UPDATE_USER = UserCode
|
};
|
dtls.Add(info);
|
}
|
Logger.Scheduler.Info($"送货单明细行信息存入实体中，总数：[{dtls.Count}]");
|
foreach (var asn in asns)
|
{
|
var snlist = db.Queryable<mes_MaterialBarCode>().Where(x => x.Segment1 == asn.ORDER_NO || x.Segment2 == asn.ORDER_NO).ToList();
|
foreach (var sn in snlist)
|
{
|
var barcode = new Barcode(sn.Code);
|
var dtl = dtls.First(q => q.LINE_NO == barcode.OrderLine);
|
BIZ_U9_ASN_SN info = new()
|
{
|
AUTH_ORG = asn.AUTH_ORG,
|
CREATE_TIME = DateTime.Now,//--时间不更新
|
CREATE_USER = UserCode,
|
UPDATE_TIME = DateTime.Now,
|
UPDATE_USER = UserCode,
|
STATUS = WMS_ITEM.STATUSs.Incoming.GetValue(),
|
ORDER_NO = barcode.OrderNo,
|
LINE_NO = dtl.LINE_NO,
|
SN = barcode.SN,
|
META_SN = sn.Code,
|
ITEM_CODE = barcode.ItemCode,
|
QTY = sn.WhQty,
|
LOTNO = barcode.LotNo,
|
CARTON_NO = barcode.SN,
|
};
|
sns.Add(info);
|
if (!sn.Code.StartsWith("Carton"))
|
{
|
var item = new WMS_ITEM()
|
{
|
SN = barcode.SN,
|
ITEM_CODE = barcode.ItemCode,
|
AUTH_ORG = asn.AUTH_ORG,
|
STATUS = WMS_ITEM.STATUSs.Incoming.GetValue(),
|
QTY = sn.WhQty,
|
PROD_DATE = barcode.ProdDate ?? DateTime.Now,
|
UNIT = barcode.Unit,
|
TRANS_CODE = nameof(BIZ_U9_ASN),
|
TRANS_NO = info.ORDER_NO,
|
TRANS_LINE = info.LINE_NO,
|
SUPP_CODE = dtl.SUPP_CODE,
|
SUPP_LOTNO = dtl.SUPP_LOTNO,
|
};
|
items.Add(item);
|
hiss.Add(new WMS_ITEM_HIS(item, $"条码[{barcode.SN}]导入，操作单据[{item.TRANS_NO}]"));
|
var ext = new WMS_ITEM_EXT()
|
{
|
SN = barcode.SN,
|
META_SN = sn.Code,
|
QR_CODE = sn.Code,
|
};
|
itemExts.Add(ext);
|
var pkg = new WMS_ITEM_PKG()
|
{
|
SN = barcode.SN,
|
ITEM_CODE = barcode.ItemCode,
|
AUTH_ORG = asn.AUTH_ORG,
|
QTY = sn.WhQty,
|
UNIT = barcode.Unit,
|
TRANS_CODE = nameof(BIZ_U9_ASN),
|
TRANS_NO = info.ORDER_NO,
|
TRANS_LINE = info.LINE_NO,
|
SUPP_CODE = dtl.SUPP_CODE,
|
SUPP_LOTNO = dtl.SUPP_LOTNO,
|
};
|
pkgs.Add(pkg);
|
}
|
}
|
|
Logger.Scheduler.Info($"送货单[{asn.ORDER_NO}]条码明细信息存入实体中，总数：[{snlist.Count}]");
|
}
|
|
|
db = Biz.Db;
|
if (asns.Any())
|
{
|
db.Utilities.PageEach(asns, 100, pageList =>
|
{
|
var y = db.Storageable(pageList, "U9C_In_DocASN")
|
.WhereColumns(t => new { t.ORDER_NO, t.GHOST_ROW })
|
.ToStorage();
|
y.AsInsertable.ExecuteCommand();
|
y.AsUpdateable.IgnoreColumns(x => x.ID).UpdateColumns(q => new { q.ORDER_NO, q.SUPP_CODE, q.SUPP_NAME, q.DELIVERY_DATE,q.PLANARRIVED_DATE, q.ORDER_DATE, q.CREATE_USER, q.UPDATE_TIME, q.AUTH_ORG, q.UPDATE_USER, }).ExecuteCommand();
|
});
|
}
|
if (dtls.Any())
|
{
|
db.Utilities.PageEach(dtls, 100, pageList =>
|
{
|
var y = db.Storageable(pageList, "U9C_In_DocASN")
|
.WhereColumns(t => new { t.ORDER_NO, t.ID, t.GHOST_ROW })
|
.ToStorage();
|
y.AsInsertable.ExecuteCommand();
|
y.AsUpdateable.UpdateColumns(q => new { q.ORDER_NO, q.LINE_NO, q.SUPP_CODE, q.ID, q.ITEM_CODE, q.QTY_PACKING, q.QTY,q.PO_QTY, q.SUPP_LOTNO, q.LOTNO, q.AUTH_ORG, q.CREATE_USER, q.UPDATE_TIME, q.UPDATE_USER, }).ExecuteCommand();
|
});
|
}
|
if (sns.Any())
|
{
|
db.Utilities.PageEach(sns, 100, pageList =>
|
{
|
var y = db.Storageable(pageList, "U9C_In_DocASN")
|
.WhereColumns(t => new { t.ORDER_NO, t.LINE_NO, t.SN, t.GHOST_ROW })
|
.ToStorage();
|
y.AsInsertable.ExecuteCommand();
|
y.AsUpdateable.IgnoreColumns(x => x.ID).UpdateColumns(q => new { q.ORDER_NO, q.LINE_NO, q.SN, q.ITEM_CODE, q.QTY, q.LOTNO, q.AUTH_ORG, q.CREATE_TIME, q.CREATE_USER, q.UPDATE_TIME, q.UPDATE_USER, }).ExecuteCommand();
|
});
|
}
|
if (items.Any())
|
{
|
db.Utilities.PageEach(items, 100, pageList =>
|
{
|
var s = db.Storageable(pageList, "U9C_In_DocASN").WhereColumns(t => new { t.SN, t.GHOST_ROW }).ToStorage();
|
s.AsInsertable.ExecuteCommand();
|
s.AsUpdateable.IgnoreColumns(x => x.ID).UpdateColumns(q => new { q.ITEM_CODE, q.AUTH_ORG, q.STATUS, q.QTY, q.PROD_DATE, q.UNIT, q.TRANS_CODE, q.TRANS_NO, q.TRANS_LINE, q.SUPP_CODE, q.SUPP_LOTNO, q.UPDATE_TIME, q.UPDATE_USER, }).ExecuteCommand();
|
});
|
}
|
if (hiss.Any())
|
{
|
db.Insertable(hiss, "U9C_In_DocASN").ExecuteCommand();
|
}
|
if (itemExts.Any())
|
{
|
db.Utilities.PageEach(itemExts, 100, pageList =>
|
{
|
var s = db.Storageable(pageList, "U9C_In_DocASN").WhereColumns(t => new { t.SN, t.GHOST_ROW }).ToStorage();
|
s.AsInsertable.ExecuteCommand();
|
s.AsUpdateable.IgnoreColumns(x => x.ID).UpdateColumns(q => new { q.META_SN, q.QR_CODE, q.UPDATE_TIME, q.UPDATE_USER, }).ExecuteCommand();
|
});
|
}
|
if (items.Any())
|
{
|
db.Utilities.PageEach(pkgs, 100, pageList =>
|
{
|
var s = db.Storageable(pageList, "U9C_In_DocASN").WhereColumns(t => new { t.SN, t.GHOST_ROW }).ToStorage();
|
s.AsInsertable.ExecuteCommand();
|
s.AsUpdateable.IgnoreColumns(x => x.ID).UpdateColumns(q => new { q.ITEM_CODE, q.AUTH_ORG, q.QTY, q.UNIT, q.TRANS_CODE, q.TRANS_NO, q.TRANS_LINE, q.SUPP_CODE, q.SUPP_LOTNO, q.UPDATE_TIME, q.UPDATE_USER, }).ExecuteCommand();
|
});
|
}
|
Logger.Scheduler.Info($"送货单表头信息存入数据库，总数：[{asns.Count}]");
|
action.Message = $"送货单表头信息存入数据库，总数：[{asns.Count}]";
|
}
|
return action;
|
}
|
|
/// <summary>
|
/// 同步收货单信息
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
public ApiAction In_GetReceipt(U9C_Base_Input input)
|
{
|
var action = new ApiAction();
|
Logger.Scheduler.Info($"收货单信息开始同步。。。数据检查进行中。。。");
|
Logger.Scheduler.Info($"{input.triggerDetail}");
|
DbClient db = Biz.DataSource["YadaU9C"].Client;
|
string UserCode = "U9C_In_GetReceipt";
|
var list = db.Queryable<mes_ReturnedDocInfo>().Where(x => x.SplitFlag == 0 && x.ReceivementType == 0&& x.ModifiedOn > input.startTime.ToDateTime() && x.ModifiedOn < input.endTime.ToDateTime()).ToList();
|
var orgs = Biz.Db.Queryable<SYS_ORGANIZATION>().ToList();
|
List<BIZ_U9_RECEIPT> result = new();
|
List<BIZ_U9_RECEIPT_DTL> resultDt = new();
|
if (list != null && list.Count > 0)
|
{
|
result = list
|
.GroupBy(x => new { x.DocNo })
|
.Select(x => new BIZ_U9_RECEIPT
|
{
|
STATUS = BIZ_U9_RECEIPT.STATUSs.Init.GetValue(),
|
ORDER_NO = x.Key.DocNo,
|
SUPP_CODE = x.Max(t => t.SupplierCode),
|
SUPP_NAME = x.Max(t => t.SupplierName),
|
ORDER_DATE = x.Max(t => t.ModifiedOn),
|
//RECEIVER 收货人
|
//RECEIVE_DATE 收货日期
|
CREATE_TIME = x.Max(t => t.ModifiedOn).ToDateTime(),//--时间不更新
|
CREATE_USER = UserCode,
|
UPDATE_TIME = x.Max(t => t.ModifiedOn).ToDateTime(),
|
UPDATE_USER = UserCode,
|
AUTH_ORG = orgs.FirstOrDefault(q => q.ID == x.Max(t => t.Org).ToString())?.ORG_CODE,
|
HANDLED = -1,
|
HANDLED_DATE = DateTime.Now,
|
})
|
.ToList();
|
Logger.Scheduler.Info($"收货单表头信息存入实体中，总数：[{result.Count}]");
|
foreach (var item in list)
|
{
|
BIZ_U9_RECEIPT_DTL info = new()
|
{
|
STATUS = BIZ_U9_RMA.STATUSs.Imported.GetValue(), //状态
|
ORDER_NO = item.DocNo, //单据号
|
LINE_NO = item.DocLineNo.ToString(), //单据行号
|
ITEM_CODE = item.ItemCode, //物料编码
|
QTY = item.EyeballingQtyTU.ToDouble(), // mes单据数量 --U9退补数量
|
AUTH_ORG = orgs.FirstOrDefault(q => q.ID == item.Org.ToString())?.ORG_CODE, //生产单元授权标识字符
|
CREATE_TIME = item.ModifiedOn,//--时间不更新
|
CREATE_USER = UserCode,
|
UPDATE_TIME = item.ModifiedOn,
|
UPDATE_USER = UserCode
|
};
|
resultDt.Add(info);
|
}
|
Logger.Scheduler.Info($"收货单明细行信息存入实体中，总数：[{resultDt.Count}]");
|
db = Biz.Db;
|
if (result.Any())
|
{
|
db.Utilities.PageEach(result, 100, pageList =>
|
{
|
var y = db.Storageable(pageList, UserCode)
|
.WhereColumns(t => new { t.ORDER_NO, t.GHOST_ROW })
|
.ToStorage();
|
y.AsInsertable.ExecuteCommand();
|
y.AsUpdateable.IgnoreColumns(x => x.ID).UpdateColumns(q => new { q.STATUS, q.ORDER_NO, q.SUPP_CODE, q.SUPP_NAME, q.ORDER_DATE, q.AUTH_ORG, q.CREATE_USER, q.UPDATE_TIME, q.UPDATE_USER, q.HANDLED, q.HANDLED_DATE, }).ExecuteCommand();
|
});
|
}
|
|
if (resultDt.Any())
|
{
|
db.Utilities.PageEach(resultDt, 100, pageList =>
|
{
|
var y = db.Storageable(pageList, UserCode)
|
.WhereColumns(t => new { t.ORDER_NO, t.LINE_NO, t.GHOST_ROW })
|
.ToStorage();
|
y.AsInsertable.ExecuteCommand();
|
y.AsUpdateable.UpdateColumns(q => new { q.STATUS, q.ORDER_NO, q.LINE_NO, q.ITEM_CODE, q.QTY, q.AUTH_ORG, q.CREATE_USER, q.UPDATE_USER, q.UPDATE_TIME }).ExecuteCommand();
|
});
|
}
|
Logger.Scheduler.Info($"收货单表头信息存入数据库，总数：[{resultDt.Count}]");
|
action.Message = $"收货单表头信息存入数据库，总数：[{resultDt.Count}]";
|
}
|
return action;
|
}
|
|
|
/// <summary>
|
/// 同步退货单信息
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
public ApiAction In_GetReturn(U9C_Base_Input input)
|
{
|
var action = new ApiAction();
|
Logger.Scheduler.Info($"退货单信息开始同步。。。数据检查进行中。。。");
|
Logger.Scheduler.Info($"{input.triggerDetail}");
|
DbClient db = Biz.DataSource["YadaU9C"].Client;
|
string UserCode = "U9C_In_GetReturn";
|
var list = db.Queryable<mes_ReturnedDocInfo>().Where(x => x.SplitFlag == 0 && x.ReceivementType == 1 && x.ModifiedOn > input.startTime.ToDateTime() && x.ModifiedOn < input.endTime.ToDateTime()).ToList();
|
var orgs = Biz.Db.Queryable<SYS_ORGANIZATION>().ToList();
|
List<BIZ_U9_RMA> result = new();
|
List<BIZ_U9_RMA_DTL> resultDt = new();
|
if (list != null && list.Count > 0)
|
{
|
result = list
|
.GroupBy(x => new { x.DocNo })
|
.Select(x => new BIZ_U9_RMA
|
{
|
STATUS = BIZ_U9_RECEIPT.STATUSs.Init.GetValue(), //状态
|
ORDER_NO = x.Key.DocNo, //单号
|
SUPP_CODE = x.Max(t => t.SupplierCode), //供应商编码
|
SUPP_NAME = x.Max(t => t.SupplierName),//供应商名称
|
ORDER_DATE = x.Max(t => t.ModifiedOn), //单据日期
|
CREATE_TIME = x.Max(t => t.ModifiedOn).ToDateTime(),//--时间不更新
|
CREATE_USER = UserCode,
|
UPDATE_TIME = x.Max(t => t.ModifiedOn).ToDateTime(),
|
UPDATE_USER = UserCode,
|
AUTH_ORG = orgs.FirstOrDefault(q => q.ID == x.Max(t => t.Org).ToString())?.ORG_CODE,
|
HANDLED = -1,
|
HANDLED_DATE = DateTime.Now,
|
GHOST_ROW = false,
|
})
|
.ToList();
|
Logger.Scheduler.Info($"退货单表头信息存入实体中，总数：[{result.Count}]");
|
foreach (var item in list)
|
{
|
BIZ_U9_RMA_DTL info = new()
|
{
|
STATUS = BIZ_U9_RMA.STATUSs.Imported.GetValue(), //状态
|
ORDER_NO = item.DocNo, //单据号
|
LINE_NO = item.DocLineNo.ToString(), //单据行号
|
ITEM_CODE = item.ItemCode, //物料编码
|
QTY = item.RtnFillQtyTU.ToDouble(), // mes单据数量 --U9退补数量
|
AUTH_ORG = orgs.FirstOrDefault(q => q.ID == item.Org.ToString())?.ORG_CODE, //生产单元授权标识字符
|
CREATE_TIME = item.ModifiedOn,//--时间不更新
|
CREATE_USER = UserCode,
|
UPDATE_TIME = item.ModifiedOn,
|
UPDATE_USER = UserCode
|
};
|
resultDt.Add(info);
|
}
|
Logger.Scheduler.Info($"退货单明细行信息存入实体中，总数：[{resultDt.Count}]");
|
db = Biz.Db;
|
if (result.Any())
|
{
|
db.Utilities.PageEach(result, 100, pageList =>
|
{
|
var y = db.Storageable(pageList, UserCode)
|
.WhereColumns(t => new { t.ORDER_NO, t.GHOST_ROW })
|
.ToStorage();
|
y.AsInsertable.ExecuteCommand();
|
y.AsUpdateable.IgnoreColumns(x => x.ID).UpdateColumns(q => new { q.STATUS, q.ORDER_NO, q.SUPP_CODE, q.SUPP_NAME, q.ORDER_DATE, q.AUTH_ORG, q.CREATE_USER, q.UPDATE_TIME, q.UPDATE_USER, q.HANDLED, q.HANDLED_DATE, }).ExecuteCommand();
|
});
|
}
|
|
if (resultDt.Any())
|
{
|
db.Utilities.PageEach(resultDt, 100, pageList =>
|
{
|
var y = db.Storageable(pageList, UserCode)
|
.WhereColumns(t => new { t.ORDER_NO, t.LINE_NO, t.GHOST_ROW })
|
.ToStorage();
|
y.AsInsertable.ExecuteCommand();
|
y.AsUpdateable.UpdateColumns(q => new { q.STATUS, q.ORDER_NO, q.LINE_NO, q.ITEM_CODE, q.QTY, q.AUTH_ORG, q.CREATE_USER, q.UPDATE_USER, q.UPDATE_TIME }).ExecuteCommand();
|
});
|
}
|
Logger.Scheduler.Info($"退货单表头信息存入数据库，总数：[{resultDt.Count}]");
|
action.Message = $"退货单表头信息存入数据库，总数：[{resultDt.Count}]";
|
}
|
return action;
|
}
|
|
|
/// <summary>
|
/// 同步获取杂收单据信息
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
public ApiAction In_GetMiscRcvTrans(U9C_Base_Input input)
|
{
|
var action = new ApiAction();
|
Logger.Scheduler.Info($"杂收单据信息开始同步。。。数据检查进行中。。。");
|
Logger.Scheduler.Info($"{input.triggerDetail}");
|
DbClient db = Biz.DataSource["YadaU9C"].Client;
|
string UserCode = "U9C_In_GetMiscRcvTrans";
|
var list = db.Queryable<mes_MiscRcvTrans>().Where(x => x.ModifiedOn > input.startTime.ToDateTime() && x.ModifiedOn < input.endTime.ToDateTime()).ToList();
|
var listLine = db.Queryable<mes_MiscRcvTransLine>().Where(x => x.ModifiedOn > input.startTime.ToDateTime() && x.ModifiedOn < input.endTime.ToDateTime()).ToList();
|
var orgs = Biz.Db.Queryable<SYS_ORGANIZATION>().ToList();
|
List<BIZ_U9_MISC_IN> result = new();
|
List<BIZ_U9_MISC_IN_DTL> resultDt = new();
|
if (list != null && list.Count > 0)
|
{
|
result = list
|
.GroupBy(x => new { x.DocNo })
|
.Select(x => new BIZ_U9_MISC_IN
|
{
|
ORDER_NO = x.Key.DocNo, //单据号
|
STATUS = BIZ_U9_MISC_IN.STATUSs.Init.GetValue(), //状态
|
TYPE_CODE =x.Max(t =>t.MiscRcvDocType), //单据类型编码
|
TYPE_NAME= x.Max(t => t.MiscRcvDocTypeName), //单据类型名称
|
ERP_STATUS_CODE = x.Max(t => t.Status).ToString(), // ERP单据状态
|
ERP_STATUS_NAME = x.Max(t => t.StatusName), // ERP单据状态名称
|
ORDER_DATE = x.Max(t => t.ModifiedOn), //单据日期
|
CREATE_TIME = x.Max(t => t.ModifiedOn).ToDateTime(),//--时间不更新
|
// RECEIVER 收货人
|
//RECEIVE_DATE 收货日期
|
AUTH_ORG = orgs.FirstOrDefault(q => q.ID == x.Max(t => t.Org).ToString())?.ORG_CODE, //组织
|
CREATE_USER = UserCode,
|
UPDATE_TIME = x.Max(t => t.ModifiedOn).ToDateTime(),
|
UPDATE_USER = UserCode,
|
HANDLED = -1, //-1:未处理，0:同步处理完，>0:同步处理失败次数
|
HANDLED_DATE = DateTime.Now, //最后一次同步处理日期
|
})
|
.ToList();
|
Logger.Scheduler.Info($"杂收单据表头信息存入实体中，总数：[{result.Count}]");
|
foreach (var item in listLine)
|
{
|
var org = db.Queryable<mes_MiscRcvTrans>().Where(x => x.MiscRcvTransID == listLine.First().MiscRcvTransID).First();
|
BIZ_U9_MISC_IN_DTL info = new()
|
{
|
ORDER_NO = item.DocNo, //单据号
|
LINE_NO = item.DocLineNo.ToString(), //单据行号
|
STATUS = BIZ_U9_MISC_IN.STATUSs.Imported.GetValue(), //状态
|
ITEM_CODE = item.ItemCode, //物料编码
|
UNIT = item.StoreUOM,// UNIT 单位
|
QTY = item.StoreUOMQty,//QTY 单据数量
|
UNIT_COST = item. CostUOM, // 成本单位
|
QTY_GIFT = item.CostUOMQty, // 成本数量
|
COST_PRICE =item.CostPrice, // 单价
|
COST_MNY = item.CostMny, // 成本
|
WH_CODE = item.WhCode,// 存储地点
|
WH_NAME = item.WhName, // 存储地点名称
|
BNF_DEPT_CODE = item.BenefitDept,// 受益部门编码
|
BNF_DEPT_NAME = item.BenefitDeptName, // 收益部门名称
|
// ERP_CODE ERP编码
|
RETURN_REASON = item.ReturnStorageReason,// 退料原因
|
INSTORE_REASON = item.InStorageReason, // INSTORE_REASON 入库原因
|
AUTH_ORG = orgs.FirstOrDefault(q => q.ID == org.Org.ToString())?.ORG_CODE, //组织
|
CREATE_TIME = item.ModifiedOn,//--时间不更新
|
CREATE_USER = UserCode,
|
UPDATE_TIME = item.ModifiedOn,
|
UPDATE_USER = UserCode,
|
};
|
resultDt.Add(info);
|
}
|
Logger.Scheduler.Info($"杂收单据明细行信息存入实体中，总数：[{resultDt.Count}]");
|
db = Biz.Db;
|
if (result.Any())
|
{
|
db.Utilities.PageEach(result, 100, pageList =>
|
{
|
var y = db.Storageable(pageList, UserCode)
|
.WhereColumns(t => new { t.ORDER_NO, t.GHOST_ROW })
|
.ToStorage();
|
y.AsInsertable.ExecuteCommand();
|
y.AsUpdateable.IgnoreColumns(x => x.ID).UpdateColumns(q => new { q.STATUS, q.ORDER_NO, q.TYPE_CODE, q.TYPE_NAME, q.ERP_STATUS_CODE, q.ERP_STATUS_NAME, q.ORDER_DATE, q.AUTH_ORG, q.CREATE_USER, q.UPDATE_TIME, q.UPDATE_USER, q.HANDLED, q.HANDLED_DATE, }).ExecuteCommand();
|
});
|
}
|
|
if (resultDt.Any())
|
{
|
db.Utilities.PageEach(resultDt, 100, pageList =>
|
{
|
var y = db.Storageable(pageList, UserCode)
|
.WhereColumns(t => new { t.ORDER_NO, t.LINE_NO, t.GHOST_ROW })
|
.ToStorage();
|
y.AsInsertable.ExecuteCommand();
|
y.AsUpdateable.UpdateColumns(q => new { q.ORDER_NO, q.LINE_NO, q.STATUS, q.ITEM_CODE, q.UNIT, q.QTY, q.UNIT_COST, q.QTY_GIFT, q.COST_PRICE, q.COST_MNY, q.WH_CODE, q.WH_NAME, q.BNF_DEPT_CODE, q.BNF_DEPT_NAME, q.RETURN_REASON, q.INSTORE_REASON, q.AUTH_ORG, q.CREATE_USER, q.UPDATE_TIME, q.UPDATE_USER }).ExecuteCommand();
|
});
|
}
|
Logger.Scheduler.Info($"杂收单据表头信息存入数据库，总数：[{resultDt.Count}]");
|
action.Message = $"杂收单据表头信息存入数据库，总数：[{resultDt.Count}]";
|
}
|
return action;
|
}
|
|
/// <summary>
|
/// 同步获取杂发单据信息
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
public ApiAction In_GetMiscShip(U9C_Base_Input input)
|
{
|
var action = new ApiAction();
|
Logger.Scheduler.Info($"杂发单据信息开始同步。。。数据检查进行中。。。");
|
Logger.Scheduler.Info($"{input.triggerDetail}");
|
DbClient db = Biz.DataSource["YadaU9C"].Client;
|
string UserCode = "U9C_In_GetMiscShip";
|
var list = db.Queryable<mes_MiscShip>().Where(x => x.ModifiedOn > input.startTime.ToDateTime() && x.ModifiedOn < input.endTime.ToDateTime()).ToList();
|
var listLine = db.Queryable<mes_MiscShipLine>().Where(x => x.ModifiedOn > input.startTime.ToDateTime() && x.ModifiedOn < input.endTime.ToDateTime()).ToList();
|
var orgs = Biz.Db.Queryable<SYS_ORGANIZATION>().ToList();
|
List<BIZ_U9_MISC_OUT> result = new();
|
List<BIZ_U9_MISC_OUT_DTL> resultDt = new();
|
if (list != null && list.Count > 0)
|
{
|
result = list
|
.GroupBy(x => new { x.DocNo })
|
.Select(x => new BIZ_U9_MISC_OUT
|
{
|
ORDER_NO = x.Key.DocNo, //单据号
|
STATUS = BIZ_U9_MISC_OUT.STATUSs.Init.GetValue(), //状态
|
TYPE_CODE = x.Max(t => t.MiscShipDocType), //单据类型编码
|
TYPE_NAME = x.Max(t => t.MiscShipDocTypeName), //单据类型名称
|
ERP_STATUS_CODE = x.Max(t => t.Status).ToString(), // ERP单据状态
|
ERP_STATUS_NAME = x.Max(t => t.StatusName), // ERP单据状态名称
|
ORDER_DATE = x.Max(t => t.BusinessDate), //单据日期
|
/* PREP_PERSON //备料人
|
FINISH_TIME //备料完成时间
|
REQ_PERSON //领料人
|
REQ_DEPT //领料部门
|
DLVY_TIME //出库时间*/
|
CREATE_TIME = x.Max(t => t.ModifiedOn).ToDateTime(),//--时间不更新
|
AUTH_ORG = orgs.FirstOrDefault(q => q.ID == x.Max(t => t.Org).ToString())?.ORG_CODE, //组织
|
CREATE_USER = UserCode,
|
UPDATE_TIME = x.Max(t => t.ModifiedOn).ToDateTime(),
|
UPDATE_USER = UserCode,
|
HANDLED = -1, //-1:未处理，0:同步处理完，>0:同步处理失败次数
|
HANDLED_DATE = DateTime.Now, //最后一次同步处理日期
|
// COMMIT_JSON 过账提交的JSON
|
//COMMIT_MSG 过账提交的返回信息
|
})
|
.ToList();
|
Logger.Scheduler.Info($"杂发单据表头信息存入实体中，总数：[{result.Count}]");
|
foreach (var item in listLine)
|
{
|
var org = db.Queryable<mes_MiscShip>().Where(x => x.MiscShipID == listLine.First().MiscShipID).First();
|
BIZ_U9_MISC_OUT_DTL info = new()
|
{
|
ORDER_NO = item.DocNo, //单据号
|
LINE_NO = item.DocLineNo.ToString(), //单据行号
|
STATUS = BIZ_U9_RMA.STATUSs.Imported.GetValue(), //状态
|
ITEM_CODE = item.ItemCode, //物料编码
|
UNIT =item.StoreUOM,// UNIT 单位
|
QTY = item.StoreUOMQty,//QTY 单据数量
|
UNIT_COST = item.CostUOM, // 成本单位
|
QTY_GIFT = item.CostUOMQty, // 成本数量
|
COST_PRICE = item.CostPrice, // 单价
|
COST_MNY = item.CostMny, // 成本
|
WH_CODE = item.WhCode,// 存储地点
|
WH_NAME = item.WhName, // 存储地点名称
|
BNF_DEPT_CODE = item.BenefitDept,// 受益部门编码
|
BNF_DEPT_NAME = item.BenefitDeptName, // 收益部门名称
|
// ERP_CODE ERP编码
|
OUTSTORE_REASON = item.OutStorageReason, // OUTSTORE_REASON 出库原因
|
|
AUTH_ORG = orgs.FirstOrDefault(q => q.ID == org.Org.ToString())?.ORG_CODE, //组织
|
CREATE_TIME = item.ModifiedOn,//--时间不更新
|
CREATE_USER = UserCode,
|
UPDATE_TIME = item.ModifiedOn,
|
UPDATE_USER = UserCode,
|
};
|
resultDt.Add(info);
|
}
|
Logger.Scheduler.Info($"杂发单据明细行信息存入实体中，总数：[{resultDt.Count}]");
|
db = Biz.Db;
|
if (result.Any())
|
{
|
db.Utilities.PageEach(result, 100, pageList =>
|
{
|
var y = db.Storageable(pageList, UserCode)
|
.WhereColumns(t => new { t.ORDER_NO, t.GHOST_ROW })
|
.ToStorage();
|
y.AsInsertable.ExecuteCommand();
|
y.AsUpdateable.IgnoreColumns(x => x.ID).UpdateColumns(q => new { q.STATUS, q.ORDER_NO, q.TYPE_CODE, q.TYPE_NAME, q.ERP_STATUS_CODE, q.ERP_STATUS_NAME, q.ORDER_DATE, q.AUTH_ORG, q.CREATE_USER, q.UPDATE_TIME, q.UPDATE_USER, q.HANDLED, q.HANDLED_DATE, }).ExecuteCommand();
|
});
|
}
|
|
if (resultDt.Any())
|
{
|
db.Utilities.PageEach(resultDt, 100, pageList =>
|
{
|
var y = db.Storageable(pageList, UserCode)
|
.WhereColumns(t => new { t.ORDER_NO, t.LINE_NO, t.GHOST_ROW })
|
.ToStorage();
|
y.AsInsertable.ExecuteCommand();
|
y.AsUpdateable.UpdateColumns(q => new { q.ORDER_NO, q.LINE_NO, q.STATUS, q.ITEM_CODE, q.UNIT, q.QTY, q.UNIT_COST, q.QTY_GIFT, q.COST_PRICE, q.COST_MNY, q.WH_CODE, q.WH_NAME, q.BNF_DEPT_CODE, q.BNF_DEPT_NAME, q.OUTSTORE_REASON, q.AUTH_ORG, q.CREATE_USER, q.UPDATE_TIME, q.UPDATE_USER }).ExecuteCommand();
|
});
|
}
|
Logger.Scheduler.Info($"杂发单据表头信息存入数据库，总数：[{resultDt.Count}]");
|
action.Message = $"杂发单据表头信息存入数据库，总数：[{resultDt.Count}]";
|
}
|
return action;
|
}
|
}
|
}
|
