using CommunityToolkit.Mvvm.ComponentModel;
|
using HMI.Base;
|
using HMI.Core.Entity;
|
using HMI.Core.Manager;
|
using HMI.Core.Util;
|
using HMI.UI.Util;
|
using LSMSInterface;
|
using Newtonsoft.Json;
|
using Newtonsoft.Json.Linq;
|
using Plugin.ChangeModel.Entity;
|
using System.Collections.ObjectModel;
|
using System.Data;
|
using System.IO;
|
using System.Windows;
|
using System.Windows.Controls;
|
|
namespace Plugin.ChangeModel
|
{
|
/// <summary>
|
/// ChangeModel.xaml 的交互逻辑
|
/// </summary>
|
[ObservableObject]
|
public partial class ChangeModel : SimpleMaskControl
|
{
|
public ChangeModel()
|
{
|
api = new LSMSApi();
|
DataContext = this;
|
InitializeComponent();
|
}
|
|
[ObservableProperty]
|
private ObservableCollection<CmLogData> datasource;
|
|
[ObservableProperty]
|
private ObservableCollection<string> lineNameSource;
|
|
[ObservableProperty]
|
private ObservableCollection<string> workorderSource;
|
|
[ObservableProperty]
|
private ObservableCollection<string> productModelSource;
|
|
[ObservableProperty]
|
private string currentLineName;
|
[ObservableProperty]
|
private string currentWorkorder;
|
[ObservableProperty]
|
private string currentProductModel;
|
[ObservableProperty]
|
private Visibility workOrderVisiable = Visibility.Collapsed;
|
|
private string configLineName;
|
private string mesIp;
|
private int mesPort;
|
private LSMSApi api;
|
private bool isMesConnected = false;
|
private SqliteHelper sqliteHelper;
|
|
public void ConnectMes()
|
{
|
string msg = string.Empty;
|
try
|
{
|
if (api.Connect(this.mesIp, this.mesPort, ref msg))
|
{
|
isMesConnected = true;
|
}
|
else
|
{
|
throw new Exception(msg);
|
}
|
}
|
catch (Exception ex)
|
{
|
isMesConnected = false;
|
log.Error("ConnectMes Failed.", ex);
|
MsgBoxHelper.Error(Window.GetWindow(this), this.lang("cm.mesConnectFail", ex.Message));
|
}
|
}
|
|
public override void InitFinish()
|
{
|
base.InitFinish();
|
ParameterData parameter;
|
try
|
{
|
parameter = ParameterManager.GetCommonParameterByName("MesIp");
|
mesIp = parameter.Value;
|
}
|
catch
|
{
|
mesIp = "127.0.0.1";
|
}
|
try
|
{
|
parameter = ParameterManager.GetCommonParameterByName("MesPort");
|
mesPort = int.Parse(parameter.Value);
|
}
|
catch
|
{
|
mesPort = 9909;
|
}
|
|
try
|
{
|
parameter = ParameterManager.GetCommonParameterByName("ChangeModelByWorkOrder");
|
var res = bool.Parse(parameter.Value);
|
if (res) WorkOrderVisiable = Visibility.Visible;
|
}
|
catch
|
{
|
WorkOrderVisiable = Visibility.Collapsed;
|
}
|
|
try
|
{
|
var dbPath = Path.Combine(BaseFolder, "ChangeModel.db");
|
if (!File.Exists(dbPath))
|
{
|
SqliteHelper.CreateDatabase(dbPath);
|
}
|
sqliteHelper = new SqliteHelper(dbPath);
|
sqliteHelper.ExecuteSql(@"CREATE TABLE IF NOT EXISTS change_model_record (
|
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
lineName TEXT NOT NULL,
|
workOrder TEXT,
|
productModel TEXT NOT NULL,
|
customProperty TEXT,
|
changeTime TIME,
|
changeResult TEXT,
|
info TEXT);");
|
}
|
catch (Exception ex)
|
{
|
log.Error("Init ChangeModel DB Failed.", ex);
|
}
|
}
|
|
public override void Active()
|
{
|
base.Active();
|
if (!isMesConnected)
|
{
|
ConnectMes();
|
RefreshLineNameSource();
|
}
|
}
|
|
public override void DoClose(object sender, EventArgs e)
|
{
|
try
|
{
|
sqliteHelper?.Dispose();
|
string errMsg = string.Empty;
|
api?.DisConnect(ref errMsg);
|
base.DoClose(sender, e);
|
}
|
catch {
|
}
|
}
|
|
private void RefreshLineNameSource()
|
{
|
try
|
{
|
if (PingMes(out string errMsg))
|
{
|
string lineStr = api.GetAllLine();
|
JObject job = (JObject)JsonConvert.DeserializeObject(lineStr);
|
LineNameSource = new ObservableCollection<string>(job["ProductLines"].ToString().Split(','));
|
try
|
{
|
var parameter = ParameterManager.GetCommonParameterByName("LineName");
|
configLineName = parameter.Value;
|
CurrentLineName = parameter.Value;
|
}
|
catch
|
{
|
|
}
|
}
|
else
|
{
|
throw new Exception(errMsg);
|
}
|
}
|
catch (Exception ex)
|
{
|
log.Error("RefreshLineNameSource Failed.", ex);
|
MsgBoxHelper.ErrorMessage(Window.GetWindow(this), this.lang("cm.rfhLineNameFail", ex.Message));
|
}
|
}
|
|
private void RefreshWorkOrderByLineName(string lineName)
|
{
|
try
|
{
|
if (PingMes(out string errMsg))
|
{
|
string workOrderStr = api.GetWorkOrderByLineName(lineName, out errMsg);
|
if (string.IsNullOrEmpty(errMsg))
|
{
|
JObject res = (JObject)JsonConvert.DeserializeObject(workOrderStr);
|
JArray workOrders = (JArray)res["Data"];
|
WorkorderSource = new ObservableCollection<string>(workOrders.Select(j => j["Code"].ToString()).ToArray());
|
}
|
|
string infoStr = api.GetProductInfoByLineName(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.FFF"), lineName, out errMsg);
|
if (string.IsNullOrEmpty(errMsg))
|
{
|
JObject job = JsonConvert.DeserializeObject(infoStr) as JObject;
|
CurrentWorkorder = job["Order"]?.ToString();
|
}
|
}
|
else
|
{
|
throw new Exception(errMsg);
|
}
|
}
|
catch (Exception ex)
|
{
|
log.Error("RefreshWorkOrderByLineName Failed.", ex);
|
MsgBoxHelper.ErrorMessage(Window.GetWindow(this), this.lang("cm.rfhWorkOrderFail", ex.Message));
|
}
|
}
|
|
private void RefreshProductByLineName(string lineName)
|
{
|
try
|
{
|
if (PingMes(out string errMsg))
|
{
|
string workOrderStr = api.GetProductsByLineName(lineName, out string ErrMsg);
|
if (string.IsNullOrEmpty(errMsg))
|
{
|
JObject res = (JObject)JsonConvert.DeserializeObject(workOrderStr);
|
JArray arr = res["Products"] as JArray;
|
ProductModelSource = new ObservableCollection<string>(arr.Select(j => j["model"].ToString()).ToArray());
|
}
|
|
string lineStr = api.GetProductInfoByLineName(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.FFF"), lineName, out errMsg);
|
if (string.IsNullOrEmpty(errMsg))
|
{
|
JObject job = (JObject)JsonConvert.DeserializeObject(lineStr);
|
CurrentProductModel = job["Model"]?.ToString();
|
}
|
}
|
else
|
{
|
throw new Exception(errMsg);
|
}
|
}
|
catch (Exception ex)
|
{
|
log.Error("RefreshProductByLineName Failed.", ex);
|
MsgBoxHelper.ErrorMessage(Window.GetWindow(this), this.lang("cm.rfhModelFail", ex.Message));
|
}
|
}
|
|
private void MesChangeModel()
|
{
|
ShowMask(() =>
|
{
|
if (PingMes(out string errMsg))
|
{
|
var info = new Dictionary<string, object>() {
|
{ "Model",CurrentProductModel}
|
};
|
if (WorkOrderVisiable == Visibility.Visible)
|
{
|
info["Order"] = CurrentWorkorder;
|
}
|
if (!api.ChangeModel2(CurrentLineName, info, out errMsg))
|
{
|
throw new Exception(errMsg);
|
}
|
sqliteHelper.ExecuteSql($@"INSERT INTO change_model_record (lineName, workOrder,productModel, customProperty,
|
changeTime,changeResult,info) Values
|
('{CurrentLineName}','{CurrentWorkorder}','{CurrentProductModel}',NULL,'{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.FFF")}', 'OK', NULL)");
|
RefreshLog();
|
if (!api.RefreshCache(out errMsg))
|
{
|
throw new Exception($"Refresh MES Cache Failed.: {errMsg}");
|
}
|
ToastHelper.Success("换型成功");
|
}
|
else
|
{
|
throw new Exception(errMsg);
|
}
|
},
|
(ex) =>
|
{
|
log.Error("MesChangeModel Failed.", ex);
|
MsgBoxHelper.ErrorMessage(Window.GetWindow(this), this.lang("cm.changeFail", ex.Message));
|
}, "请稍后", "换型中...");
|
}
|
|
|
|
private bool PingMes(out string errMsg)
|
{
|
errMsg = string.Empty;
|
if (!isMesConnected)
|
{
|
errMsg = "MES未连接，请先连接MES";
|
return false;
|
}
|
try
|
{
|
if (!api.IsConnect(ref errMsg))
|
{
|
isMesConnected = false;
|
return false;
|
}
|
return true;
|
}
|
catch (Exception ex)
|
{
|
errMsg = ex.Message;
|
isMesConnected = false;
|
return false;
|
}
|
}
|
|
private void RefreshLog()
|
{
|
try
|
{
|
DataTable dt = sqliteHelper.GetDataTable(@"SELECT lineName AS LineName
|
,productModel AS ProductModel
|
,customProperty AS CustomProperty
|
,changeTime AS ChangeTime
|
,changeResult AS ChangeResult
|
,info AS Info
|
FROM change_model_record order by changeTime desc limit 100;");
|
this.Dispatcher.BeginInvoke((Action)delegate ()
|
{
|
table.ItemsSource = dt.DefaultView;
|
});
|
}
|
catch (Exception ex)
|
{
|
log.Error("Refresh ChangeModel Log Failed.", ex);
|
ToastHelper.Error(this.lang("cm.rfhLogFail", ex.Message));
|
}
|
}
|
|
partial void OnCurrentLineNameChanged(string lineName)
|
{
|
RefreshWorkOrderByLineName(lineName);
|
RefreshProductByLineName(lineName);
|
}
|
|
|
private void Button_Click(object sender, RoutedEventArgs e)
|
{
|
switch ((sender as Button).Name)
|
{
|
case "changeModelBtn":
|
DoChangeModel();
|
break;
|
case "refreshLogBtn":
|
ShowMask(RefreshLog, null, "请稍后", "正在刷新...");
|
break;
|
case "refreshInfoBtn":
|
RefreshInfo();
|
break;
|
case "deleteLogBtn":
|
DeleteLog();
|
break;
|
default:
|
break;
|
}
|
}
|
|
private void DeleteLog()
|
{
|
if (MsgBoxHelper.WarnMessage(this, this.lang("cm.makeSureDelLog")) != MessageBoxResult.OK)
|
{
|
return;
|
}
|
ShowMask(() =>
|
{
|
try
|
{
|
sqliteHelper.ExecuteSql($@"DELETE FROM change_model_record WHERE ID NOT IN
|
(SELECT id FROM change_model_record Order by changeTime DESC limit 10);");
|
RefreshLog();
|
}
|
catch (Exception ex)
|
{
|
log.Error("DeleteLog Failed.", ex);
|
ToastHelper.Error(this.lang("cm.delLogFail", ex.Message));
|
}
|
}, null, "请稍后", "正在清理...");
|
}
|
|
private void RefreshInfo()
|
{
|
try
|
{
|
RefreshLineNameSource();
|
RefreshWorkOrderByLineName(CurrentLineName);
|
RefreshProductByLineName(CurrentLineName);
|
}
|
catch (Exception ex)
|
{
|
log.Error("Refresh Info Failed.", ex);
|
ToastHelper.Error(this.lang("cm.rfhInfoErr", ex.Message));
|
}
|
}
|
|
private void DoChangeModel()
|
{
|
if (string.IsNullOrEmpty(CurrentLineName) || string.IsNullOrEmpty(CurrentProductModel)) return;
|
if (MsgBoxHelper.WarnMessage(this, this.lang("cm.makeSureChangeModel")) != MessageBoxResult.OK)
|
{
|
return;
|
}
|
MesChangeModel();
|
}
|
|
private void SimpleControl_Loaded(object sender, RoutedEventArgs e)
|
{
|
RefreshLog();
|
}
|
}
|
}
|
