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 Microsoft.CodeAnalysis.Options;
|
using Tiger.Model.Entitys.MES.U9C;
|
using SqlSugar;
|
using System.Collections;
|
using System.Data.Entity.Core.Common.CommandTrees.ExpressionBuilder;
|
using static IronPython.Modules.PythonDateTime;
|
|
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;
|
}
|
|
//保存到数据库
|
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 list = db.Ado.SqlQuery<mes_AsnDocInfo>($"select * from mes_AsnDocInfo where ModifiedOn > '{input.startTime}' And ModifiedOn < '{input.endTime}'");
|
var orgs = Biz.Db.Queryable<SYS_ORGANIZATION>().ToList();
|
List<BIZ_U9_ASN> asns = new();
|
List<BIZ_U9_ASN_DTL> items = new();
|
List<BIZ_U9_ASN_SN> sns = 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),
|
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= "U9C_In_DocASN",
|
UPDATE_TIME = x.Max(t => t.ModifiedOn).ToDateTime(),
|
UPDATE_USER = "U9C_In_DocASN",
|
AUTH_ORG = orgs.FirstOrDefault(q => q.ID == x.Max(t => t.Org).ToString())?.ORG_CODE,
|
HANDLED=0,
|
HANDLED_DATE=DateTime.Now,
|
})
|
.ToList();
|
Logger.Scheduler.Info($"送货单表头信息存入实体中，总数：[{asns.Count}]");
|
foreach (var item in list)
|
{
|
BIZ_U9_ASN_DTL info = new() {
|
STATUS = BIZ_U9_ASN.STATUSs.Imported.GetValue(),
|
ORDER_NO = item.DocNo,
|
LINE_NO = item.DocLineNo.ToString(),
|
SUPP_CODE = item.SupplierCode,
|
ID = item.LineID.ToString(),
|
ITEM_CODE = item.ItemCode,
|
QTY_PACKING = item.PackQty.ToDouble(),
|
QTY = item.POQtyTU.ToDouble(),
|
SUPP_LOTNO = item.SupplierLot,
|
LOTNO = item.LotMater,
|
AUTH_ORG = orgs.FirstOrDefault(q => q.ID == item.Org.ToString())?.ORG_CODE,
|
CREATE_TIME = item.ModifiedOn,//--时间不更新
|
CREATE_USER = "U9C_In_DocASN",
|
UPDATE_TIME = item.ModifiedOn,
|
UPDATE_USER = "U9C_In_DocASN",
|
};
|
items.Add(info);
|
}
|
Logger.Scheduler.Info($"送货单明细行信息存入实体中，总数：[{items.Count}]");
|
foreach (var asn in asns)
|
{
|
var snlist = db.Queryable<mes_MaterialBarCode>().Where(x => x.Segment1 == asn.ORDER_NO ).ToList();
|
foreach (var item in snlist)
|
{
|
BIZ_U9_ASN_SN info = new()
|
{
|
STATUS = WMS_ITEM.STATUSs.Incoming.GetValue(),
|
ORDER_NO = item.Segment1,
|
LINE_NO = item.Segment2,
|
SN = item.Code,
|
ITEM_CODE = item.Segment5,
|
QTY = item.WhQty.ToDouble(),
|
LOTNO = item.Segment7,
|
AUTH_ORG = asn.AUTH_ORG,
|
CREATE_TIME = DateTime.Now,//--时间不更新
|
CREATE_USER = "U9C_In_DocASN",
|
UPDATE_TIME = DateTime.Now,
|
UPDATE_USER = "U9C_In_DocASN",
|
};
|
sns.Add(info);
|
}
|
Logger.Scheduler.Info($"送货单[{asn.ORDER_NO}]条码明细信息存入实体中，总数：[{snlist.Count}]");
|
}
|
db = Biz.Db;
|
//var dbTran = db.UseTran(() =>
|
//{
|
if (asns.Any())
|
{
|
if (asns.Count > 100)
|
{
|
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();
|
});
|
}
|
else
|
{
|
var s = db.Storageable(asns, "U9C_In_DocASN")
|
.WhereColumns(t => new { t.ORDER_NO, t.GHOST_ROW })
|
.ToStorage();
|
s.AsInsertable.ExecuteCommand();
|
s.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 (items.Any())
|
{
|
if (items.Count > 100)
|
{
|
db.Utilities.PageEach(items, 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.SUPP_LOTNO, q.LOTNO, q.AUTH_ORG,q.CREATE_USER, q.UPDATE_TIME ,q.UPDATE_USER }).ExecuteCommand();
|
});
|
}
|
else
|
{
|
var s = db.Storageable(items, "U9C_In_DocASN")
|
.WhereColumns(t => new { t.ORDER_NO,t.ID, t.GHOST_ROW })
|
.ToStorage();
|
s.AsInsertable.ExecuteCommand();
|
s.AsUpdateable.UpdateColumns(q => new { q.ORDER_NO,q.LINE_NO, q.SUPP_CODE, q.ID, q.ITEM_CODE, q.QTY_PACKING, q.QTY, q.SUPP_LOTNO, q.LOTNO, q.AUTH_ORG, q.CREATE_USER, q.UPDATE_TIME, q.UPDATE_USER }).ExecuteCommand();
|
}
|
}
|
if (sns.Any())
|
{
|
if (sns.Count > 100)
|
{
|
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();
|
});
|
}
|
else
|
{
|
var s = db.Storageable(sns, "U9C_In_DocASN")
|
.WhereColumns(t => new { t.ORDER_NO, t.LINE_NO, t.SN, t.GHOST_ROW })
|
.ToStorage();
|
s.AsInsertable.ExecuteCommand();
|
s.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 (!dbTran.IsSuccess)
|
//{
|
// action.CatchExceptionWithLog(dbTran.ErrorException, $"数据处理失败");
|
// Logger.Scheduler.Error(action.Message);
|
//}
|
Logger.Scheduler.Info($"送货单表头信息存入数据库，总数：[{asns.Count}]");
|
action.Message = $"送货单表头信息存入数据库，总数：[{asns.Count}]";
|
}
|
return action;
|
}
|
|
|
}
|
}
|
