From d0fe891cac88bbd5087a0ee90a41421bbf0ec5c5 Mon Sep 17 00:00:00 2001
From: Rodney Chen <rodney.chen@hotmail.com>
Date: 星期四, 28 十一月 2024 17:23:56 +0800
Subject: [PATCH] 优化了一些已知问题
---
Tiger.Model.Net/Base/TraceDebug.cs | 112 +++++++++++++++++++++++++++++++++++++
Tiger.Business.MES/Transaction/YadaPacking.cs | 57 ++++++++++--------
Tiger.Model.Net/Tiger.Model.Net.csproj | 1
Tiger.Api/Program.cs | 5 +
4 files changed, 147 insertions(+), 28 deletions(-)
diff --git a/Tiger.Api/Program.cs b/Tiger.Api/Program.cs
index 2a9a5cc..19ae675 100644
--- a/Tiger.Api/Program.cs
+++ b/Tiger.Api/Program.cs
@@ -17,7 +17,7 @@
using Autofac;
using Tiger.IBusiness;
-
+var begin = DateTime.Now;
try
{
//闈濽I绾跨▼鏈崟鑾峰紓甯稿鐞嗕簨浠�
@@ -95,7 +95,8 @@
//聽Call聽Configure(),聽passing聽in聽the聽dependencies
startup.Configure(app, app.Environment);
Logger.Console.Info($"Run {prod} Successful");
-
+ Logger.Console.Info($"Total Elapsed Time: {(DateTime.Now - begin).TotalSeconds:0.000} seconds");
+
app.Run();
Logger.Console.Info($"{prod} Host is shut down");
}
diff --git a/Tiger.Business.MES/Transaction/YadaPacking.cs b/Tiger.Business.MES/Transaction/YadaPacking.cs
index 0f68338..b390da5 100644
--- a/Tiger.Business.MES/Transaction/YadaPacking.cs
+++ b/Tiger.Business.MES/Transaction/YadaPacking.cs
@@ -13,6 +13,7 @@
using Tiger.Business.MES.WorkAction;
using Tiger.Model.MES.Yada;
using System.Data;
+using System.Diagnostics;
namespace Tiger.Business.MES.Transaction
{
@@ -40,10 +41,10 @@
public PackingAction TempPkgAction { get; set; }
public bool IsPrintCustomerLabel { get; set; }
public string ShippingOrder { get; set; }
+ public DbClient U9CDB { get; set; }
+ public Model.TraceDebug debug { get; set; }
public DateTime curtime = DateTime.Now;
public DateTime prevtime = DateTime.Now;
-
- public DbClient U9CDB { get; set; }
#endregion Propertys & Variables
#region Functions
@@ -54,7 +55,8 @@
/// <returns></returns>
public async Task<ApiAction<SubmitOutput>> Submit(SubmitInput input)
{
- curtime = prevtime = DateTime.Now; Logger.Console.Info($"{CurSN} : ***** 1 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;
+ debug = new(new StackFrame(true));
+ debug.Log(new StackFrame(true), "***** 1", info => { ConsoleExt.WriteLine(info.ToString()); });
var action = new ApiAction<SubmitOutput>(new SubmitOutput());
try
{
@@ -72,7 +74,7 @@
{
IsPrintCustomerLabel = input.Options["IsPrintCustomerLabel"].ToBoolean();
}
-
+
//if (input.Options.ContainsKey("ShippingOrder"))
//{
// ShippingOrder = IsPrintCustomerLabel ? input.Options["ShippingOrder"].ToString() : "";
@@ -93,17 +95,17 @@
{
//宸ユ鍒楄〃涓虹┖鎴栬�呭伐搴忚妭鐐瑰伐姝ユ湁鏈畬鎴愭椂锛屼紭鍏堝畬鎴愬伐搴忚妭鐐瑰伐姝�
if (Steps.IsNullOrEmpty() || !IsFinishNodeSteps)
- {
+ {
var wosns = MainDB.Queryable<BIZ_MES_WO_BATCH, BIZ_MES_WO_SN>((q, s) => new JoinQueryInfos(JoinType.Inner, q.ORDER_NO == s.WORK_ORDER && q.BATCH_NO == s.BATCH_NO))
.ByAuth(input.AuthOption)//.Where((q, s) => s.STATUS < BIZ_MES_WO_SN.STATUSs.Finished.GetValue())
.Where((q, s) => s.SN == input.SN || s.FLOW_SN == input.SN || s.TRAY_SN == input.SN).Select((q, s) => new { Batch = q, SN = s }).ToList();
- curtime = DateTime.Now; Logger.Console.Info($"{CurSN} : ***** 2 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;
+ debug.Log(new StackFrame(true), "***** 2", info => { ConsoleExt.WriteLine(info.ToString()); });
//鍏堝垽鏂綋鍓嶅伐鍗曚笉涓虹┖涓斿綋鍓嶅矖浣嶅湪褰撳墠宸ュ崟鏄笉鏄绔欙紝濡傛灉鏄垯涓嶅厑璁稿彉鏇村綋鍓嶅伐鍗曪紝灏濊瘯鎶婃潯鐮佺粦瀹氬埌褰撳墠宸ュ崟
if (!CurBatch.IsNullOrEmpty() && CurBatch.IsFirstNode(PostCode))
{
//鏇存柊CurBatch
CurBatch?.Update();
- curtime = DateTime.Now; Logger.Console.Info($"{CurSN} : ***** 3 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;
+ debug.Log(new StackFrame(true), "***** 3", info => { ConsoleExt.WriteLine(info.ToString()); });
var wosn = wosns.FirstOrDefault(q => q.Batch.ORDER_NO == CurBatch.WO.ORDER_NO && (q.SN.STATUS == BIZ_MES_WO_SN.STATUSs.Finished.GetValue() || q.SN.STATUS == BIZ_MES_WO_SN.STATUSs.Scrap.GetValue()));
if (!wosn.IsNullOrEmpty())
{
@@ -117,7 +119,7 @@
{
//鎻愪氦鏁版嵁
action = NodeSubmit(action, input);
- curtime = DateTime.Now; Logger.Console.Info($"{CurSN} : ***** 4 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;
+ debug.Log(new StackFrame(true), "***** 4", info => { ConsoleExt.WriteLine(info.ToString()); });
//鏇存柊宸ュ簭淇℃伅
if (!action.IsSuccessed)
{
@@ -238,23 +240,23 @@
{
//鏇存柊CurBatch
CurBatch?.Update();
- curtime = DateTime.Now; Logger.Console.Info($"{CurSN} : ***** 5 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;
+ debug.Log(new StackFrame(true), "***** 5", info => { ConsoleExt.WriteLine(info.ToString()); });
var submitStep = Steps.Where(q => q.ID == input.CurStepID && !q.IsFinished).FirstOrDefault();
//濡傛灉瀹㈡埛绔繑鍥炵殑褰撳墠宸ユID鎵句笉鍒版湭瀹屾垚鐨勮涓哄伐姝ワ紝鍒欑洿鎺ュ紑濮嬩笅涓�涓涓哄伐姝�
if (submitStep.IsNullOrEmpty())
{
action = BeginNextActionStep(input);
- curtime = DateTime.Now; Logger.Console.Info($"{CurSN} : ***** 6 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;
+ debug.Log(new StackFrame(true), "***** 6", info => { ConsoleExt.WriteLine(info.ToString()); });
}
else
{
action = submitStep.Submit(input);
- curtime = DateTime.Now; Logger.Console.Info($"{CurSN} : ***** 7 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;
+ debug.Log(new StackFrame(true), "***** 7", info => { ConsoleExt.WriteLine(info.ToString()); });
//濡傛灉褰撳墠宸ユ宸插畬鎴愶紝寮�濮嬫墽琛屼笅涓�宸ユ
if (action.IsSuccessed && submitStep.IsFinished)
{
action = BeginNextActionStep(input);
- curtime = DateTime.Now; Logger.Console.Info($"{CurSN} : ***** 8 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;
+ debug.Log(new StackFrame(true), "***** 8", info => { ConsoleExt.WriteLine(info.ToString()); });
}
//濡傛灉褰撳墠宸ユ鏈畬鎴�
else
@@ -299,7 +301,7 @@
//action.CatchExceptionWithLog(ex, $"鍖呰宸ュ簭锛氭彁浜ゆ搷浣滄暟鎹紓甯�");
action.CatchExceptionWithLog(ex, Biz.L("MES.Transaction.PackingNode.SubmitException"));
}
- curtime = DateTime.Now; Logger.Console.Info($"{CurSN} : ***** 9 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;
+ debug.Log(new StackFrame(true), "***** 9", info => { ConsoleExt.WriteLine(info.ToString()); });
return SetOutPutMqttMsg(action, input.Locale);
}
@@ -311,7 +313,7 @@
/// <returns></returns>
public ApiAction<SubmitOutput> NodeSubmit(ApiAction<SubmitOutput> action, SubmitInput input)
{
- curtime = DateTime.Now; Logger.Console.Info($"{CurSN} : ***** 10 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;
+ debug.Log(new StackFrame(true), "***** 10", info => { ConsoleExt.WriteLine(info.ToString()); });
var curNode = CurBatch.GetNode(PostCode);
try
{
@@ -395,14 +397,15 @@
//璁剧疆褰撳墠鎸囦护涓烘甯镐骇鍝佽繃绔�
NodeCmd = "NodeSubmit";
- curtime = DateTime.Now; Logger.Console.Info($"{CurSN} : ***** 11 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;
+ debug.Log(new StackFrame(true), "***** 11", info => { ConsoleExt.WriteLine(info.ToString()); });
//鑾峰彇鍑鸿揣鐘舵��
var ship = U9CDB.Queryable<mes_ShipList>().Where(q => q.MoDoc == CurBatch.WO.ORDER_NO && q.Status == 2 && SqlFunc.DateIsSame(q.BusinessDate, DateTime.Now)).First();
int CurShipQty = 0;
int WaitShipmentCarton = 0;
int WaitShipment = 0;
- if (ship.IsNullOrEmpty()) { IsPrintCustomerLabel = false; } else
+ if (ship.IsNullOrEmpty()) { IsPrintCustomerLabel = false; }
+ else
{
CurShipQty = ship.ShipQty;
IsPrintCustomerLabel = true;
@@ -439,7 +442,7 @@
// Context.Add("CurWaitShipmentCarton", WaitShipmentCarton);
//}
- curtime = DateTime.Now; Logger.Console.Info($"{CurSN} : ***** 12 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;
+ debug.Log(new StackFrame(true), "***** 12", info => { ConsoleExt.WriteLine(info.ToString()); });
//缁戝畾鏉＄爜鍒板伐鍗�
foreach (var wipSN in wipSNs)
{
@@ -583,7 +586,7 @@
var _curNodeSetting = curNodeSetting.Clone();
var _Batch = CurBatch.Batch.Clone();
- curtime = DateTime.Now; Logger.Console.Info($"{CurSN} : ***** 13 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;
+ debug.Log(new StackFrame(true), "***** 13", info => { ConsoleExt.WriteLine(info.ToString()); });
//鍒濆鍖栧伐姝ュ垪琛�
Steps.Clear();
var curStep = new WorkStep(IWorkStep.NodeTypes.Node, this)
@@ -707,7 +710,7 @@
//action.CatchExceptionWithLog(ex, $"{curNode.NODE_NAME}锛氬伐搴忚妭鐐瑰伐姝ユ彁浜ゆ暟鎹紓甯革紝璇锋鏌ュ伐搴忚妭鐐硅缃�");
action.CatchExceptionWithLog(ex, Biz.L("MES.Transaction.PackingNode.NodeSubmitException", curNode.NODE_NAME));
}
- curtime = DateTime.Now; Logger.Console.Info($"{CurSN} : ***** 13.1 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;
+ debug.Log(new StackFrame(true), "***** 13.1", info => { ConsoleExt.WriteLine(info.ToString()); });
return action;
}
@@ -721,7 +724,7 @@
var curPkg = Context.ContainsKey("CurPackage") ? Context["CurPackage"] as WipPkg : null;
var operInfo = SetOperNodeInfo(CurOperInfo(locale));
Action endAction = null;
- curtime = DateTime.Now; Logger.Console.Info($"{CurSN} : ***** 14 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;
+ debug.Log(new StackFrame(true), "***** 14", info => { ConsoleExt.WriteLine(info.ToString()); });
//濡傛灉褰撳墠鏉＄爜宸茬粡璧板埌娴佺▼缁堢偣鍒欒褰曟潯鐮佸畬宸�
if (operInfo.IsReachedEndNode)
@@ -789,7 +792,7 @@
//淇濆瓨鏁版嵁搴�
SaveStepsCommitActionToDB(endAction);
-
+
//淇濆瓨鎴愬姛锛岃繑鍥炶繃绔欐秷鎭�
operInfo.InputQty += CurWipSNs.Count;
action.Data.Data = new PackingActionOutput() { PkgInfo = curPkg };
@@ -806,7 +809,7 @@
//閲嶇疆宸ュ簭
ResetNode();
- curtime = DateTime.Now; Logger.Console.Info($"{CurSN} : ***** 15 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;
+ debug.Log(new StackFrame(true), "***** 15", info => { ConsoleExt.WriteLine(info.ToString()); });
return action;
}
@@ -955,7 +958,7 @@
var CurPkg = Context.ContainsKey("CurPackage") ? Context["CurPackage"] as WipPkg : null;
var LabelPV = MainDB.Queryable<BAS_LABEL_PV>().ToList();
var label = CurPkg.Item.LABEL_CODE.IsNullOrEmpty() ? null : MainDB.Queryable<BAS_LABEL_TEMP>().Where(q => q.LABEL_CODE == CurPkg.Item.LABEL_CODE).IncludesAllFirstLayer().First();
- var printLb = SetLabelVariables(LabelPV, label, new PackingAction(), CurPkg);
+ var printLb = SetLabelVariables(LabelPV, label, new PackingAction(), CurPkg);
action.Data = new PackingActionOutput()
{
ExecCode = "PrintTest",
@@ -979,9 +982,11 @@
var action = new ApiAction<ShipingInfo>();
try
{
- action.Data = new ShipingInfo() {
- IsPrintCustomerLabel= IsPrintCustomerLabel,
- ShipQty =Context.GetOrDefault("CurWaitShipment").ToInt32()>= Context.GetOrDefault("CurShipQty").ToInt32()? CurBatch.Batch.PLAN_QTY - Context.GetOrDefault("CurShipQty").ToInt32(): Context.GetOrDefault("CurShipQty").ToInt32() };
+ action.Data = new ShipingInfo()
+ {
+ IsPrintCustomerLabel = IsPrintCustomerLabel,
+ ShipQty = Context.GetOrDefault("CurWaitShipment").ToInt32() >= Context.GetOrDefault("CurShipQty").ToInt32() ? CurBatch.Batch.PLAN_QTY - Context.GetOrDefault("CurShipQty").ToInt32() : Context.GetOrDefault("CurShipQty").ToInt32()
+ };
}
catch (Exception ex)
{
diff --git a/Tiger.Model.Net/Base/TraceDebug.cs b/Tiger.Model.Net/Base/TraceDebug.cs
new file mode 100644
index 0000000..1b4cf13
--- /dev/null
+++ b/Tiger.Model.Net/Base/TraceDebug.cs
@@ -0,0 +1,112 @@
+锘縰sing SqlSugar.DbConvert;
+using System;
+using System.Collections.Generic;
+using System.Diagnostics;
+using System.Linq;
+using System.Reflection;
+using System.Text;
+using System.Threading.Tasks;
+using static Tiger.Model.MQTT;
+
+namespace Tiger.Model
+{
+ /// <summary>
+ /// 璋冭瘯
+ /// </summary>
+ public class TraceDebug
+ {
+ public TraceDebug(StackFrame frame)
+ {
+ var info = new TraceInfo("Begin Trace");
+ info.File = frame?.GetFileName();
+ info.Function = frame?.GetMethod().DeclaringType.FullName + "." + frame?.GetMethod().Name;
+ info.Line = frame?.GetFileLineNumber() ?? default;
+ TraceInfos.Add(info);
+ }
+ public TraceDebug(StackFrame frame, string title) : this(frame)
+ {
+ Title = title;
+ }
+
+ /// <summary>
+ /// 璋冭瘯鏍囬
+ /// </summary>
+ public string Title { get; set; } = "Trace Information";
+ /// <summary>
+ /// 璋冭瘯淇℃伅鍒楄〃
+ /// </summary>
+ public List<TraceInfo> TraceInfos { get; set; } = new List<TraceInfo>();
+ /// <summary>
+ /// 寮�濮嬭褰曟椂闂�
+ /// </summary>
+ public DateTime BeginTime { get; set; } = DateTime.Now;
+ /// <summary>
+ /// 鎸佺画鏃堕棿锛堢锛�
+ /// </summary>
+ public double Duration { get; set; } = 0;
+ public override string ToString() => $"========== {Title} ==========\r\n{string.Join("\r\n", TraceInfos.Select(q => " " + q.ToString()))}\r\n========== Total Elapsed Time: {Duration:0.000}s ==========";
+ public string ToDetailString() => $"========== {Title} ==========\r\n{string.Join("\r\n", TraceInfos.Select(q => " " + q.ToDetailString()))}\r\n========== Total Elapsed Time: {Duration:0.000}s ==========";
+ /// <summary>
+ /// 娣诲姞璋冭瘯淇℃伅
+ /// </summary>
+ public TraceDebug Log(StackFrame frame, string msg, Action<TraceInfo> doSomthing = null)
+ {
+ var f = new StackFrame(true);
+ var info = new TraceInfo(msg);
+ Duration = (info.ActionTime - BeginTime).TotalSeconds;
+ info.File = frame?.GetFileName();
+ info.Function = frame?.GetMethod().DeclaringType.FullName + "." + frame?.GetMethod().Name;
+ info.Line = frame?.GetFileLineNumber() ?? default;
+ info.Index = TraceInfos.Max(q => q.Index) + 1;
+ info.Duration = (info.ActionTime - TraceInfos.Max(q => q.ActionTime)).TotalSeconds;
+ //string w = null; w.ToString();
+ TraceInfos.Add(info);
+ doSomthing?.Invoke(info);
+ return this;
+ }
+ }
+
+ /// <summary>
+ /// 璋冭瘯淇℃伅
+ /// </summary>
+ public class TraceInfo
+ {
+ public TraceInfo()
+ {
+ }
+ public TraceInfo(string message)
+ {
+ Message = message;
+ }
+ /// <summary>
+ /// 搴忓彿
+ /// </summary>
+ public int Index { get; set; } = 0;
+ /// <summary>
+ /// 璋冭瘯鏂囦欢
+ /// </summary>
+ public string File { get; set; } = "Anonymous";
+ /// <summary>
+ /// 璋冭瘯鏂规硶
+ /// </summary>
+ public string Function { get; set; } = "Anonymous";
+ /// <summary>
+ /// 琛屽彿
+ /// </summary>
+ public int Line { get; set; } = 0;
+ /// <summary>
+ /// 淇℃伅
+ /// </summary>
+ public string Message { get; set; }
+ /// <summary>
+ /// 鎵ц鏃堕棿
+ /// </summary>
+ public DateTime ActionTime { get; set; } = DateTime.Now;
+ /// <summary>
+ /// 鎸佺画鏃堕棿锛堢锛�
+ /// </summary>
+ public double Duration { get; set; } = 0;
+ public override string ToString() => $"{ActionTime:yyyy/MM/dd HH:mm:ss.fff} > Trace[{Index}](took {Duration:0.000}s) : {Message}.";
+ public string ToDetailString() => $"{ActionTime:yyyy/MM/dd HH:mm:ss.fff} > Trace[{Index}](took {Duration:0.000}s) : {Message}.\r\n\tRun at {Function} in {File}:line {Line}";
+ }
+}
diff --git a/Tiger.Model.Net/Tiger.Model.Net.csproj b/Tiger.Model.Net/Tiger.Model.Net.csproj
index 39d5e4e..4c350b2 100644
--- a/Tiger.Model.Net/Tiger.Model.Net.csproj
+++ b/Tiger.Model.Net/Tiger.Model.Net.csproj
@@ -76,6 +76,7 @@
</ItemGroup>
<ItemGroup>
<Compile Include="Base\DbEntityBase.cs" />
+ <Compile Include="Base\TraceDebug.cs" />
<Compile Include="DTO\MESDTO.cs" />
<Compile Include="Entitys\MQTTEntity.cs" />
<Compile Include="Entitys\Api\Base.cs" />
--
Gitblit v1.9.3