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.Linq;
|
using Newtonsoft.Json;
|
using System;
|
using System.Collections.Generic;
|
using System.Collections.ObjectModel;
|
using System.IO;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using System.Web.SessionState;
|
using System.Windows;
|
using System.Windows.Controls;
|
using System.Windows.Data;
|
using System.Windows.Documents;
|
using System.Windows.Input;
|
using System.Windows.Media;
|
using System.Windows.Media.Imaging;
|
using System.Windows.Navigation;
|
using System.Data;
|
using System.Windows.Media.Media3D;
|
|
namespace Plugin.MaterialOpt
|
{
|
/// <summary>
|
/// MaterialOpt.xaml 的交互逻辑
|
/// </summary>
|
[ObservableObject]
|
public partial class MaterialOpt : SimpleControl
|
{
|
public MaterialOpt()
|
{
|
DataContext = this;
|
api = new LSMSApi();
|
InitializeComponent();
|
}
|
|
[ObservableProperty]
|
private string currentProductSN;
|
[ObservableProperty]
|
private string currentMaterialSN;
|
[ObservableProperty]
|
private string currentMaterialName;
|
[ObservableProperty]
|
private string currentWorkstation;
|
[ObservableProperty]
|
private ObservableCollection<string> workstationSource;
|
|
private string lineName;
|
private string mesIp;
|
private int mesPort;
|
private LSMSApi api;
|
private bool isMesConnected = false;
|
private SqliteHelper sqliteHelper;
|
|
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("LineName");
|
lineName = parameter.Value;
|
}
|
catch
|
{
|
lineName = string.Empty;
|
}
|
|
//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, "MaterialOpt.db");
|
if (!File.Exists(dbPath))
|
{
|
SqliteHelper.CreateDatabase(dbPath);
|
}
|
sqliteHelper = new SqliteHelper(dbPath);
|
sqliteHelper.ExecuteSql(@"CREATE TABLE IF NOT EXISTS bind_record (
|
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
ProductSN TEXT NOT NULL,
|
MaterialSN TEXT NOT NULL,
|
MaterialName TEXT ,
|
Workstation TEXT ,
|
Time TIME);");
|
sqliteHelper.ExecuteSql(@"CREATE TABLE IF NOT EXISTS unbind_record (
|
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
ProductSN TEXT NOT NULL,
|
MaterialSN TEXT NOT NULL,
|
MaterialName TEXT ,
|
Workstation TEXT ,
|
Time TIME);");
|
}
|
catch (Exception ex)
|
{
|
log.Error("Init MaterialOpt DB Failed.", ex);
|
}
|
}
|
|
public override void Active()
|
{
|
base.Active();
|
//if (!isMesConnected)
|
//{
|
// ConnectMes();
|
// RefreshWorkstationSource();
|
//}
|
}
|
|
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));
|
}
|
}
|
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 RefreshWorkstationSource()
|
{
|
string errMsg = string.Empty;
|
try
|
{
|
if (api.Connect(mesIp, mesPort, ref errMsg))
|
{
|
string lineStr = api.GetAllStationByCurrentLine(lineName, out errMsg);
|
JObject res = (JObject)JsonConvert.DeserializeObject(lineStr);
|
string stations = res["WorkStations"]?.ToString();
|
if (string.IsNullOrEmpty(stations))
|
{
|
WorkstationSource = new ObservableCollection<string>();
|
}
|
else
|
{
|
WorkstationSource = new ObservableCollection<string>(stations.Split(','));
|
}
|
}
|
else
|
{
|
MsgBoxHelper.ErrorMessage(this, $"连接服务器失败: {errMsg}");
|
}
|
}
|
catch (Exception ex)
|
{
|
MsgBoxHelper.ErrorMessage(this, $"绑定失败: {errMsg}");
|
}
|
finally
|
{
|
api.DisConnect(ref errMsg);
|
}
|
}
|
|
private void Button_Click(object sender, RoutedEventArgs e)
|
{
|
var btn = sender as Button;
|
switch (btn.Name)
|
{
|
case "bindBtn":
|
BindMaterial();
|
break;
|
case "bindQryBtn":
|
mask.ShowMask(this, RefreshBindLog, null, "请稍后", "正在查询...");
|
break;
|
case "unbindBtn":
|
UnBindMaterial();
|
break;
|
case "unbindQryBtn":
|
mask.ShowMask(this, RefreshUnBindLog, null, "请稍后", "正在查询...");
|
break;
|
//case "rowUnBindBtn":
|
// UnBindMaterial(data.ItemArray[1].ToString(), data.ItemArray[2].ToString());
|
// break;
|
//case "rowReBindBtn":
|
// BindMaterial();
|
break;
|
default:
|
break;
|
}
|
}
|
|
private void BindMaterial()
|
{
|
if (string.IsNullOrEmpty(CurrentProductSN))
|
{
|
ToastHelper.Warning("请输入产品序列号");
|
return;
|
}
|
if (string.IsNullOrEmpty(CurrentMaterialSN))
|
{
|
ToastHelper.Warning("请输入物料条码");
|
return;
|
}
|
//if (string.IsNullOrEmpty(CurrentMaterialName))
|
//{
|
// ToastHelper.Warning("请输入物料名称");
|
// return;
|
//}
|
if (string.IsNullOrEmpty(CurrentWorkstation))
|
{
|
ToastHelper.Warning("请选择工站");
|
return;
|
}
|
|
if (MsgBoxHelper.WarnMessage(this, "确定绑定该物料吗?") != MessageBoxResult.OK)
|
{
|
return;
|
}
|
mask.ShowMask(this, () =>
|
{
|
string errMsg = string.Empty;
|
try
|
{
|
if (!api.Connect(mesIp, mesPort, ref errMsg))
|
{
|
throw new Exception($"连接服务器失败: {errMsg}");
|
}
|
string text2 = api.CheckBoolMaterial_2163(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.FFF"),
|
CurrentProductSN, CurrentWorkstation, CurrentMaterialName, CurrentMaterialSN, out errMsg);
|
if (!string.IsNullOrEmpty(errMsg))
|
{
|
throw new Exception(errMsg);
|
}
|
sqliteHelper.ExecuteSql($@"INSERT INTO bind_record (ProductSN, MaterialSN, Workstation, Time)
|
Values ('{CurrentProductSN}', '{CurrentMaterialSN}', '{CurrentWorkstation}','{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.FFF")}')");
|
ToastHelper.Success("绑定成功");
|
RefreshBindLog();
|
}
|
finally
|
{
|
api.DisConnect(ref errMsg);
|
}
|
},
|
(ex) =>
|
{
|
Dispatcher.BeginInvoke(new Action(() =>
|
{
|
MsgBoxHelper.Error(this, $"绑定失败: {ex.Message}");
|
}));
|
}, "请稍后", "正在绑定...");
|
}
|
|
private void UnBindMaterial(string productSN = null, string materialSN = null)
|
{
|
if (productSN == null)
|
{
|
productSN = CurrentProductSN;
|
}
|
if (materialSN == null)
|
{
|
materialSN = CurrentMaterialSN;
|
}
|
|
if (string.IsNullOrEmpty(productSN))
|
{
|
ToastHelper.Warning("请输入产品序列号");
|
return;
|
}
|
if (string.IsNullOrEmpty(materialSN))
|
{
|
ToastHelper.Warning("请输入物料条码");
|
return;
|
}
|
if (MsgBoxHelper.WarnMessage(this, "确定解绑该物料吗?") != MessageBoxResult.OK)
|
{
|
return;
|
}
|
|
mask.ShowMask(this, () =>
|
{
|
string errMsg = string.Empty;
|
try
|
{
|
if (!api.Connect(mesIp, mesPort, ref errMsg))
|
{
|
throw new Exception($"连接服务器失败: {errMsg}");
|
|
}
|
string text2 = api.UnBookMaterial(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.FFF"),
|
productSN, materialSN, out errMsg);
|
if (!string.IsNullOrEmpty(errMsg))
|
{
|
throw new Exception(errMsg);
|
}
|
sqliteHelper.ExecuteSql($@"INSERT INTO unbind_record (ProductSN, MaterialSN, Workstation, Time)
|
Values ('{productSN}', '{materialSN}', '', '{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.FFF")}')");
|
ToastHelper.Success("解绑成功");
|
RefreshUnBindLog();
|
}
|
finally
|
{
|
api.DisConnect(ref errMsg);
|
}
|
},
|
(ex) =>
|
{
|
Dispatcher.BeginInvoke(new Action(() =>
|
{
|
MsgBoxHelper.Error(this, $"解绑失败: {ex.Message}");
|
}));
|
}, "请稍后", "正在解绑...");
|
}
|
|
private void RefreshBindLog()
|
{
|
var dt = sqliteHelper.GetDataTable("SELECT * FROM bind_record ORDER BY Time DESC LIMIT 100");
|
this.Dispatcher.BeginInvoke(new Action(() =>
|
{
|
table.ItemsSource = dt.DefaultView;
|
}));
|
}
|
|
private void RefreshUnBindLog()
|
{
|
var dt = sqliteHelper.GetDataTable("SELECT * FROM unbind_record ORDER BY Time DESC LIMIT 100");
|
this.Dispatcher.BeginInvoke(new Action(() =>
|
{
|
unbindTable.ItemsSource = dt.DefaultView;
|
}));
|
}
|
|
private void SimpleControl_Loaded(object sender, RoutedEventArgs e)
|
{
|
RefreshWorkstationSource();
|
RefreshBindLog();
|
RefreshUnBindLog();
|
//try
|
//{
|
// ConnectMes();
|
// RefreshWorkstationSource();
|
//}
|
//catch (Exception ex)
|
//{
|
// log.Error("MaterialOpt Load Failed.", ex);
|
//}
|
}
|
|
private void table_SelectionChanged(object sender, SelectionChangedEventArgs e)
|
{
|
if (e.AddedItems == null || e.AddedItems.Count <= 0)
|
{
|
return;
|
}
|
var data = (e.AddedItems[0] as DataRowView).Row;
|
if (sender == table)
|
{
|
CurrentProductSN = data.ItemArray[1].ToString();
|
CurrentMaterialSN = data.ItemArray[2].ToString();
|
CurrentWorkstation = data.ItemArray[4].ToString();
|
}
|
else if (sender == unbindTable)
|
{
|
CurrentProductSN = data.ItemArray[1].ToString();
|
CurrentMaterialSN = data.ItemArray[2].ToString();
|
}
|
}
|
}
|
}
|
