|
|
using GRreader;
|
|
|
using MaterialTraceability.Common;
|
|
|
using MaterialTraceability.Entity.DAO;
|
|
|
using MaterialTraceability.Entity.DTO;
|
|
|
using MaterialTraceability.Entity.UpLoad;
|
|
|
using MaterialTraceability.Rfid;
|
|
|
using MaterialTraceability.SqlSugar;
|
|
|
using MaterialTraceability.SqlSugar.ServiceImpl;
|
|
|
using SqlSugar;
|
|
|
using System;
|
|
|
using System.Collections.Generic;
|
|
|
using System.ComponentModel;
|
|
|
using System.Linq;
|
|
|
using System.Linq.Expressions;
|
|
|
using System.Reflection;
|
|
|
using System.Text;
|
|
|
using System.Threading;
|
|
|
using System.Threading.Tasks;
|
|
|
|
|
|
namespace MaterialTraceability.Business
|
|
|
{
|
|
|
public class EquipBusiness
|
|
|
{
|
|
|
Thread thread;
|
|
|
Thread Connect;
|
|
|
static List<ProEquip> _equipList = new List<ProEquip>();
|
|
|
public List<ProEquip> IpequipList = new List<ProEquip>();
|
|
|
bool ReadContinue = true;
|
|
|
private Semaphore m_ReadSem = new Semaphore(0, 100000);
|
|
|
public delegate void FrmDisplay();
|
|
|
public int waitTime = Convert.ToInt16(ConfigHelper.GetConfig("readTime"));
|
|
|
|
|
|
public event FrmDisplay EventDisplay;
|
|
|
private BackgroundWorker m_bgwDeviceDetect = new BackgroundWorker();
|
|
|
private ManualResetEvent StartDetectEvent = new ManualResetEvent(false);
|
|
|
private ManualResetEvent ExitEvent = new ManualResetEvent(false);
|
|
|
private ManualResetEvent DetectEvent = new ManualResetEvent(false);
|
|
|
|
|
|
private AppConfigDto appConfig = AppConfigDto.Instance;
|
|
|
private SqlSugarClient _db = SqlGenerator.GetMySqlInstance();
|
|
|
|
|
|
private IBaseServices<ProEquip> equipServices = new BaseServices<ProEquip>();
|
|
|
private IBaseServices<ProReadRecord> readServices = new BaseServices<ProReadRecord>();
|
|
|
|
|
|
/// <summary>
|
|
|
/// 获取标签信息
|
|
|
/// </summary>
|
|
|
/// <param name="equipid">设备编号</param>
|
|
|
/// <param name="isFilter">是否开启过滤</param>
|
|
|
/// <param name="eq"></param>
|
|
|
/// <returns></returns>
|
|
|
public List<TagInfo> gettaglist(string equipid,bool isFilter, out ProEquip eq)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
LogHelper.Info("进入gettaglist函数：" + equipid);
|
|
|
List<TagInfo> taglist = new List<TagInfo>();
|
|
|
List<TagInfo> result = new List<TagInfo>();
|
|
|
foreach (var equip in _equipList)
|
|
|
{
|
|
|
if (equip.equipId.ToString() == equipid)
|
|
|
{
|
|
|
taglist = equip.DeviceAdapter.Device_GetTagInfoList(DeviceType.Mesnac_GRUR445, waitTime * 1000);
|
|
|
if (taglist.Count < 1)
|
|
|
{
|
|
|
taglist = equip.DeviceAdapter.Device_GetTagInfoList(DeviceType.Mesnac_GRUR445, waitTime * 1000);
|
|
|
}
|
|
|
eq = equip;
|
|
|
LogHelper.RfidLog("gettaglist函数结果：" + JsonChange.ModeToJson(taglist));
|
|
|
if (isFilter)
|
|
|
{
|
|
|
#region 读取结果过滤，返回读取次数大于两次的数据 Add By WenJY 2023-05-11
|
|
|
result = taglist.Where(x => x.Count > 2).ToList();
|
|
|
LogHelper.Info($"gettaglist函数结果过滤，返回读取次数大于2的数据{JsonChange.ModeToJson(result)}");
|
|
|
#endregion
|
|
|
return result;
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
return taglist;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
eq = null;
|
|
|
LogHelper.Info($"gettaglist函数结果：{JsonChange.ModeToJson(taglist)}，设备编号{equipid}；未匹配到设备信息；");
|
|
|
return taglist;
|
|
|
}
|
|
|
catch(Exception ex)
|
|
|
{
|
|
|
LogHelper.Info($"gettaglist函数异常：{ex.Message}");
|
|
|
eq = null;
|
|
|
return null;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
/// 涂布、模切、冷压上料读取
|
|
|
/// </summary>
|
|
|
/// <param name="equipId"></param>
|
|
|
/// <param name="antana"></param>
|
|
|
/// <returns></returns>
|
|
|
public string ReadEPCByAntana(int equipId)
|
|
|
{
|
|
|
LogHelper.Info("进入ReadEPCByAntana函数");
|
|
|
ProEquip proEquip = _equipList.Where(x => x.equipId == equipId).FirstOrDefault();
|
|
|
List<TagInfo> info2 = this.gettaglist(proEquip.equipId.ToString(),false, out proEquip);
|
|
|
|
|
|
#region 2023/2/6关闭
|
|
|
// ----------------------------------------------------------------------2023/2/6关闭
|
|
|
// info2遍历信号强度、读取次数，上传至服务器数据库读取记录表ReadRecord,
|
|
|
// 过滤前的数据is_success字段统一设置成999，便于数据库查找观察
|
|
|
// 串读问题解决即删除方法，并减少web数据库表pro_readrecord的count和rssi字段
|
|
|
//List<ReadRecord> recordList = new List<ReadRecord>();
|
|
|
|
|
|
//foreach (TagInfo tag in info2)
|
|
|
//{
|
|
|
// ReadRecord info22 = new ReadRecord()
|
|
|
// {
|
|
|
// Count = tag.Count,
|
|
|
// RSSI = tag.RSSI,
|
|
|
// machineId = proEquip.machineId,
|
|
|
// resource = appConfig.resource,
|
|
|
// equipId = proEquip.equipId,
|
|
|
// positionId = proEquip.positionId,
|
|
|
// ant = tag.Antana,
|
|
|
// rfidStr = tag.EPCstring,
|
|
|
// is_success = 999,
|
|
|
// recordTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
|
|
|
// };
|
|
|
// recordList.Add(info22);
|
|
|
//}
|
|
|
//int resultCode = _db.Insertable<ReadRecord>(recordList).ExecuteCommand();
|
|
|
//if (resultCode > 0)
|
|
|
//{
|
|
|
// LogHelper.Info("标签强度上传成功");
|
|
|
//}
|
|
|
//LogHelper.Info("标签强度上传失败");
|
|
|
// -------------------------------------------------------------------
|
|
|
#endregion
|
|
|
|
|
|
if (info2.Count == 0)
|
|
|
{
|
|
|
return "";
|
|
|
}
|
|
|
CFliterRFID cFliterRFID = new CFliterRFID();
|
|
|
var result = cFliterRFID.filterByTagCount(info2);
|
|
|
|
|
|
if (result == "") return "";
|
|
|
if (StringExtension.IsBlank(result))
|
|
|
{
|
|
|
return "";
|
|
|
}
|
|
|
string info = result;
|
|
|
//info = info.Substring(0, info.Length - 2);
|
|
|
LogHelper.Info("ReadEpcByAntana函数读取结果：" + result);
|
|
|
ProReadRecord readRecord = new ProReadRecord()
|
|
|
{
|
|
|
MachineID = proEquip.machineId,
|
|
|
EquipID = proEquip.equipId,
|
|
|
PositionID = proEquip.positionId,
|
|
|
Ant = StringChange.ParseToInt(proEquip.equipAnt),
|
|
|
ReadEPC = result,
|
|
|
Result = StringExtension.IsBlank(result) ? "0" : "1",
|
|
|
ReadTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")
|
|
|
};
|
|
|
readServices.Add(readRecord);
|
|
|
return info;
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 读取EPC并过滤读取次数
|
|
|
/// </summary>
|
|
|
/// <param name="equipId"></param>
|
|
|
/// <returns></returns>
|
|
|
public string ReadEPCAndFliterCount(int equipId)
|
|
|
{
|
|
|
LogHelper.Info("进入ReadEPCByAntana函数");
|
|
|
ProEquip proEquip = _equipList.Where(x => x.equipId == equipId).FirstOrDefault();
|
|
|
List<TagInfo> info2 = this.gettaglist(proEquip.equipId.ToString(), true, out proEquip);
|
|
|
|
|
|
if (info2.Count == 0)
|
|
|
{
|
|
|
return "";
|
|
|
}
|
|
|
CFliterRFID cFliterRFID = new CFliterRFID();
|
|
|
var result = cFliterRFID.filterByTagCount(info2);
|
|
|
|
|
|
if (result == "") return "";
|
|
|
if (StringExtension.IsBlank(result))
|
|
|
{
|
|
|
return "";
|
|
|
}
|
|
|
string info = result;
|
|
|
LogHelper.Info("ReadEpcByAntana函数读取结果：" + result);
|
|
|
ProReadRecord readRecord = new ProReadRecord()
|
|
|
{
|
|
|
MachineID = proEquip.machineId,
|
|
|
EquipID = proEquip.equipId,
|
|
|
PositionID = proEquip.positionId,
|
|
|
Ant = StringChange.ParseToInt(proEquip.equipAnt),
|
|
|
ReadEPC = result,
|
|
|
Result = StringExtension.IsBlank(result) ? "0" : "1",
|
|
|
ReadTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")
|
|
|
};
|
|
|
readServices.Add(readRecord);
|
|
|
return info;
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
/// 生产过程中读取RFID信息
|
|
|
/// </summary>
|
|
|
/// <param name="equipId"></param>
|
|
|
/// <returns></returns>
|
|
|
public List<TagInfo> ReadEpcByProduction(int equipId)
|
|
|
{
|
|
|
LogHelper.Info("ReadEpcByProduction函数");
|
|
|
ProEquip proEquip = _equipList.Where(x => x.equipId == equipId).FirstOrDefault();
|
|
|
List<TagInfo> tagInfos = this.gettaglist(proEquip.equipId.ToString(),true, out proEquip);
|
|
|
|
|
|
if (tagInfos.Count == 0)
|
|
|
{
|
|
|
return null;
|
|
|
}
|
|
|
return tagInfos;
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 生产结束后过滤生产过程中读取的RFID信息
|
|
|
/// </summary>
|
|
|
/// <param name="tagInfos"></param>
|
|
|
/// <returns></returns>
|
|
|
public string FilterEpcByProductionEnd(List<TagInfo> tagInfos)
|
|
|
{
|
|
|
CFliterRFID cFliterRFID = new CFliterRFID();
|
|
|
var result = cFliterRFID.filterByTagCount(tagInfos);
|
|
|
|
|
|
if (result == "") return "";
|
|
|
if (StringExtension.IsBlank(result))
|
|
|
{
|
|
|
return "";
|
|
|
}
|
|
|
string info = result;
|
|
|
LogHelper.Info("FilterEpcByProductionEnd过滤结果：" + result);
|
|
|
|
|
|
return info;
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 冷压四通道，八通道读取
|
|
|
/// </summary>
|
|
|
/// <param name="positionGroup">设备位置列表，对应数据库里的</param>
|
|
|
/// <returns></returns>
|
|
|
public List<TagMessage> ReadEPCByAntanaGroup(List<int> positionGroup)
|
|
|
{
|
|
|
//必须是同一个设备的不同的天线号
|
|
|
List<TagMessage> tagList = new List<TagMessage>();
|
|
|
int position = positionGroup.FirstOrDefault();
|
|
|
ProEquip proEquip = _equipList.Where(x => x.positionId == position).FirstOrDefault();
|
|
|
//ProEquip proEquip = _equipList.Where(x => x.equipId == equipId).FirstOrDefault();//这里只获取了第一个，设备
|
|
|
var info2 = this.gettaglist(proEquip.equipId.ToString(),false, out proEquip);
|
|
|
/////做日志用,后期可以不用了
|
|
|
//foreach (var a in info2)
|
|
|
//{
|
|
|
// LogHelper.RfidLog("RFID读取日志："+a.);
|
|
|
//}
|
|
|
//
|
|
|
//把数据都都上来
|
|
|
if (info2.Count == 0)
|
|
|
{
|
|
|
return null;
|
|
|
}
|
|
|
string outepc = "";
|
|
|
|
|
|
#region ///先把小天线的最好结果取出来
|
|
|
int minpostion = FindMinAntPostion(positionGroup);
|
|
|
TagMessage ta = GetAntEPC(info2, minpostion, "");
|
|
|
outepc = ta.EPC;
|
|
|
tagList.Add(ta);
|
|
|
#endregion 如果不需要可以注释掉
|
|
|
|
|
|
foreach (var item in positionGroup)
|
|
|
{
|
|
|
if (minpostion == item)
|
|
|
continue;
|
|
|
tagList.Add(GetAntEPC(info2, item, outepc));
|
|
|
}
|
|
|
//做日志用
|
|
|
foreach (var a in tagList)
|
|
|
{
|
|
|
LogHelper.RfidLog("RFID读取日志：" + a.position + "位置读到标签：" + a.EPC);
|
|
|
}
|
|
|
return tagList;
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 获取小天线的position
|
|
|
/// </summary>
|
|
|
/// <param name="positionGroup"></param>
|
|
|
/// <returns></returns>
|
|
|
private int FindMinAntPostion(List<int> positionGroup)
|
|
|
{
|
|
|
int minPostion = 0;
|
|
|
foreach (var po in positionGroup)
|
|
|
{
|
|
|
//小天线的位置是1，3
|
|
|
if (po == 1 || po == 3)
|
|
|
{
|
|
|
minPostion = po;
|
|
|
//positionGroup.Remove(po);
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
return minPostion;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 获取天线最好的结果
|
|
|
/// </summary>
|
|
|
/// <param name="taglist"></param>
|
|
|
/// <param name="pos"></param>
|
|
|
/// <param name="outEPC">排除小天线的epc，如果是小天线写""</param>
|
|
|
/// <returns></returns>
|
|
|
private TagMessage GetAntEPC(List<TagInfo> taglist, int pos, string outEPC)
|
|
|
{
|
|
|
ProEquip equip = _equipList.Where(x => x.positionId == pos).FirstOrDefault();
|
|
|
CFliterRFID cFliterRFID = new CFliterRFID();
|
|
|
var result = cFliterRFID.filterByAnt(taglist, Convert.ToInt32(equip.equipAnt), outEPC);
|
|
|
TagMessage tag = new TagMessage()
|
|
|
{
|
|
|
EPC = result,
|
|
|
position = pos
|
|
|
};
|
|
|
LogHelper.Info("ReadEpcByAntana函数读取结果：" + result);
|
|
|
readServices.Add(new ProReadRecord()
|
|
|
{
|
|
|
MachineID = equip.machineId,
|
|
|
EquipID = equip.equipId,
|
|
|
PositionID = equip.positionId,
|
|
|
Ant = StringChange.ParseToInt(equip.equipAnt),
|
|
|
ReadEPC = result,
|
|
|
Result = StringExtension.IsBlank(result) ? "0" : "1",
|
|
|
ReadTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")
|
|
|
});
|
|
|
return tag;
|
|
|
}
|
|
|
|
|
|
//public string TBReadEPC(int equipId)
|
|
|
//{
|
|
|
// LogHelper.Info("进入TBReadEPC函数");
|
|
|
// ProEquip proEquip = _equipList.Where(x => x.equipId == equipId).FirstOrDefault();
|
|
|
// var info2 = this.gettaglist(proEquip.equipId.ToString(), out proEquip);
|
|
|
// if (info2.Count == 0)
|
|
|
// {
|
|
|
// return "";
|
|
|
// }
|
|
|
// CFliterRFID cFliterRFID = new CFliterRFID();
|
|
|
// var result = cFliterRFID.filterByAnt(info2, Convert.ToInt32(proEquip.equipAnt));
|
|
|
// if (result == null) return "";
|
|
|
// if (StringExtension.IsBlank(result.EPCstring))
|
|
|
// {
|
|
|
// return "";
|
|
|
// }
|
|
|
// string info = System.Text.Encoding.ASCII.GetString(result.EPC);
|
|
|
// info = info.Substring(0, info.Length - 2);
|
|
|
// LogHelper.Info("TBReadEPC函数读取结果：" + info);
|
|
|
// readServices.Add(new ProReadRecord()
|
|
|
// {
|
|
|
// MachineID = proEquip.machineId,
|
|
|
// EquipID = proEquip.equipId,
|
|
|
// PositionID = proEquip.positionId,
|
|
|
// Ant = StringChange.ParseToInt(proEquip.equipAnt),
|
|
|
// ReadEPC = info,
|
|
|
// Result = StringExtension.IsBlank(info) ? "0" : "1",
|
|
|
// ReadTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")
|
|
|
// });
|
|
|
// return info;
|
|
|
//}
|
|
|
|
|
|
|
|
|
public string ReadEPC(string equipid)
|
|
|
{
|
|
|
//LogService.Instance.Debug(equipid + "开始查找");
|
|
|
bool find = false;
|
|
|
string result = "";
|
|
|
foreach (var equip in _equipList)
|
|
|
{
|
|
|
if (equip.equipId.ToString() == equipid)
|
|
|
{
|
|
|
find = true;
|
|
|
ushort ant = Convert.ToUInt16(equip.equipAnt);
|
|
|
byte[] buffer = new byte[24];
|
|
|
for (int i = 0; i < StringChange.ParseToInt(ConfigHelper.GetConfig("readCount")); i++)
|
|
|
{
|
|
|
int count = i + 1;
|
|
|
//LogService.Instance.Debug("读取第" + count + "次");
|
|
|
LogHelper.Info("第" + count + "次开始读取RFID条码信息");
|
|
|
byte b = equip.DeviceAdapter.Device_GetOneIdentifyData(ref buffer, Convert.ToByte(equip.equipAnt), (ushort)(StringChange.ParseToInt(ConfigHelper.GetConfig("readTime")) * 1000));
|
|
|
string epcstring = Encoding.ASCII.GetString(buffer);
|
|
|
LogHelper.Info("RFID条码信息读取完成：" + epcstring);
|
|
|
//string epcstring = equip.DeviceAdapter.Device_GetOneIdentifyData((byte)ant, (ushort)(Unity.Unity.Instance.readTime * 1000));
|
|
|
if (epcstring != null && epcstring != "")
|
|
|
{
|
|
|
epcstring = epcstring.Substring(0, epcstring.Length - 2);
|
|
|
result = epcstring;
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
readServices.Add(new ProReadRecord()
|
|
|
{
|
|
|
MachineID = equip.machineId,
|
|
|
EquipID = equip.equipId,
|
|
|
PositionID = equip.positionId,
|
|
|
Ant = StringChange.ParseToInt(equip.equipAnt),
|
|
|
ReadEPC = result,
|
|
|
Result = StringExtension.IsBlank(result) ? "0" : "1",
|
|
|
ReadTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")
|
|
|
});
|
|
|
}
|
|
|
}
|
|
|
if (!find)
|
|
|
{
|
|
|
LogHelper.Info("未找到编码为" + equipid + "的设备");
|
|
|
}
|
|
|
return result;
|
|
|
}
|
|
|
|
|
|
public bool writeUser(string equipid, string epc, string writeData)
|
|
|
{
|
|
|
//LogService.Instance.Debug(equipid + "写入开始查找");
|
|
|
bool find = false;
|
|
|
bool result = false;
|
|
|
foreach (var equip in _equipList)
|
|
|
{
|
|
|
if (equip.equipId.ToString() == equipid)
|
|
|
{
|
|
|
find = true;
|
|
|
ushort ant = Convert.ToUInt16(equip.equipAnt);
|
|
|
byte[] buffer = new byte[24];
|
|
|
|
|
|
Byte[] filter = new Byte[epc.Length];
|
|
|
filter = Encoding.ASCII.GetBytes(epc);
|
|
|
Byte[] write = new byte[writeData.Length];
|
|
|
write = Encoding.ASCII.GetBytes(writeData);
|
|
|
for (int i = 0; i < 3; i++)
|
|
|
{
|
|
|
int count = i + 1;
|
|
|
//LogService.Instance.Debug("写入第" + count + "次");
|
|
|
int intrsult = equip.DeviceAdapter.Device_Write(G2MemBank.EPC, 0, 0, filter, G2MemBank.USER, 0, (ushort)(write.Length / 2), write, 1);
|
|
|
if (intrsult > 0)
|
|
|
{
|
|
|
result = true;
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
//LogService.Instance.Error(position + "未找到对应的设备");
|
|
|
|
|
|
if (!find)
|
|
|
{
|
|
|
//LogService.Instance.Debug("write未找到编码为" + equipid + "的设备");
|
|
|
}
|
|
|
return result;
|
|
|
}
|
|
|
|
|
|
|
|
|
private void bgwDeviceDetect_DoWork(object sender, DoWorkEventArgs e)
|
|
|
{
|
|
|
BackgroundWorker backgroundworker = sender as BackgroundWorker;
|
|
|
//StartDetectEvent.WaitOne(-1, false);
|
|
|
while (true)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
if (ExitEvent.WaitOne(0, false))
|
|
|
{
|
|
|
e.Cancel = true;
|
|
|
ExitEvent.Reset();
|
|
|
return;
|
|
|
}
|
|
|
foreach (var equip in IpequipList)
|
|
|
{
|
|
|
if (equip.DeviceAdapter == null)
|
|
|
{
|
|
|
equip.IsConnect = false;
|
|
|
}
|
|
|
if (equip.IsConnect == false)
|
|
|
{
|
|
|
if (equip.DeviceAdapter.Device_Connect())
|
|
|
{
|
|
|
byte iResult = equip.DeviceAdapter.Device_SendHeartPack();
|
|
|
if (iResult == 1)
|
|
|
{
|
|
|
equip.IsConnect = true;
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
equip.IsConnect = false;
|
|
|
equip.DeviceAdapter.Device_Destroy();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
byte iResult = equip.DeviceAdapter.Device_SendHeartPack();
|
|
|
if (iResult == 1)
|
|
|
{
|
|
|
equip.IsConnect = true;
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
equip.IsConnect = false;
|
|
|
}
|
|
|
}
|
|
|
EventDisplay?.Invoke();
|
|
|
}
|
|
|
|
|
|
DetectEvent.Reset();
|
|
|
DetectEvent.WaitOne(20 * 1000, false);
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
DetectEvent.Reset();
|
|
|
DetectEvent.WaitOne(10 * 1000, false);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
public bool InitEquipLsit()
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
GetAllEquipList();
|
|
|
if (_equipList.Count > 0)
|
|
|
{
|
|
|
//m_bgwDeviceDetect.DoWork += new DoWorkEventHandler(bgwDeviceDetect_DoWork);
|
|
|
//m_bgwDeviceDetect.RunWorkerAsync(this);
|
|
|
Connect = new Thread(ConnectEquip);
|
|
|
Connect.Start();
|
|
|
}
|
|
|
//thread = new Thread(ThreadChickState);
|
|
|
//thread.Start();
|
|
|
return true;
|
|
|
}
|
|
|
catch (Exception e)
|
|
|
{
|
|
|
//LogService.Instance.Debug("设备初始化失败，请检查类型是否正确" + e.ToString());
|
|
|
return false;
|
|
|
}
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 获取所有设备列表
|
|
|
/// </summary>
|
|
|
private async void GetAllEquipList()
|
|
|
{
|
|
|
AppConfigDto appConfig = AppConfigDto.Instance;
|
|
|
//DbHandler db = new DbHandler();
|
|
|
int machineId = appConfig.machineId;
|
|
|
Expression<Func<ProEquip, bool>> expression = s1 => true;
|
|
|
expression = expression.And(x => x.machineId == machineId);
|
|
|
_equipList = await equipServices.Query(expression);
|
|
|
|
|
|
foreach (var equip in _equipList)
|
|
|
{
|
|
|
foreach (var ipequip in IpequipList)
|
|
|
{
|
|
|
if (ipequip.equipIp == equip.equipIp)
|
|
|
{
|
|
|
equip.DeviceAdapter = ipequip.DeviceAdapter;
|
|
|
break;
|
|
|
}
|
|
|
}
|
|
|
if (equip.DeviceAdapter == null)
|
|
|
{
|
|
|
equip.DeviceAdapter = DynamicClass(equip.equipType);
|
|
|
if (equip.DeviceAdapter == null)
|
|
|
{
|
|
|
//LogService.Instance.Debug(equip.EquipIP + "设备实体类生成失败，请检查类型是否正确" + equip.EquipType);
|
|
|
continue;
|
|
|
}
|
|
|
string url = equip.equipIp + ":" + equip.equipPort;
|
|
|
if (appConfig.machineId == 1)
|
|
|
{
|
|
|
equip.DeviceAdapter.Device_Init(CommType.RJ45, url, DeviceType.Mesnac_GRUV100);
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
equip.DeviceAdapter.Device_Init(CommType.RJ45, url, DeviceType.RFly_I160);
|
|
|
}
|
|
|
IpequipList.Add(equip);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
private void ConnectEquip()
|
|
|
{
|
|
|
#region
|
|
|
//foreach (var equip in _equipList)
|
|
|
//{
|
|
|
// foreach (var ipequip in IpequipList)
|
|
|
// {
|
|
|
// if (ipequip.EquipIP == equip.EquipIP)
|
|
|
// {
|
|
|
// equip.DeviceAdapter = ipequip.DeviceAdapter;
|
|
|
// break;
|
|
|
// }
|
|
|
// }
|
|
|
// if (equip.DeviceAdapter == null)
|
|
|
// {
|
|
|
// equip.DeviceAdapter = DynamicClass(equip.EquipType);
|
|
|
// if (equip.DeviceAdapter == null)
|
|
|
// {
|
|
|
// LogService.Instance.Debug(equip.EquipIP+"设备实体类生成失败，请检查类型是否正确" + equip.EquipType);
|
|
|
// continue;
|
|
|
// }
|
|
|
// string url = equip.EquipIP + ":" + equip.EquipPort;
|
|
|
// equip.DeviceAdapter.Device_Init(CommType.RJ45, url, DeviceType.Mesnac_GRUV100);
|
|
|
// if (equip.DeviceAdapter.Device_Connect())
|
|
|
// {
|
|
|
// equip.IsConnect = true;
|
|
|
// }
|
|
|
// else
|
|
|
// {
|
|
|
// equip.IsConnect = false;
|
|
|
// }
|
|
|
// IpequipList.Add(equip);
|
|
|
// }
|
|
|
//}
|
|
|
#endregion
|
|
|
|
|
|
foreach (var equip in IpequipList)
|
|
|
{
|
|
|
if (equip.DeviceAdapter.Device_Connect())
|
|
|
{
|
|
|
equip.IsConnect = true;
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
equip.IsConnect = false;
|
|
|
}
|
|
|
foreach (var e in _equipList)
|
|
|
{
|
|
|
if (equip.equipIp == e.equipIp)
|
|
|
{
|
|
|
e.IsConnect = equip.IsConnect;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
m_ReadSem.Release();
|
|
|
}
|
|
|
|
|
|
private void ThreadChickState()
|
|
|
{
|
|
|
m_ReadSem.WaitOne(10000);
|
|
|
while (ReadContinue)
|
|
|
{
|
|
|
CheckEquipState();
|
|
|
//让界面显示
|
|
|
EventDisplay?.Invoke();
|
|
|
Thread.Sleep(10000);
|
|
|
}
|
|
|
|
|
|
}
|
|
|
public void CheckEquipState()
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
var info = _equipList.GroupBy(x => x.equipIp).Select(a => a.Key).ToList();
|
|
|
foreach (var item in info)
|
|
|
{
|
|
|
string timeStr = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
|
|
ProEquip equip = _equipList.Where(x => x.equipIp == item).FirstOrDefault();
|
|
|
int iflag;
|
|
|
iflag = equip.DeviceAdapter.Device_SendHeartPack();
|
|
|
LogHelper.RfidLog(String.Format("{0}设备状态检测：{1}", equip.equipIp, iflag));
|
|
|
if (iflag == 1)
|
|
|
{
|
|
|
Console.WriteLine(timeStr + "心跳成功！！！");
|
|
|
equip.IsConnect = true;
|
|
|
}
|
|
|
else if (iflag == 2)
|
|
|
{
|
|
|
Console.WriteLine(timeStr + "心跳超时！！！");
|
|
|
LogHelper.Info("心跳超时！！！");
|
|
|
equip.IsConnect = false;
|
|
|
}
|
|
|
else
|
|
|
{
|
|
|
Console.WriteLine(timeStr + "心跳失败，进行重连！！！");
|
|
|
equip.IsConnect = false;
|
|
|
ResertConnect(equip);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
LogHelper.Error("设备状态检测函数CheckEquipState异常", ex);
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 新加断开重连
|
|
|
/// </summary>
|
|
|
/// <param name="equip"></param>
|
|
|
private void ResertConnect(ProEquip equip)
|
|
|
{
|
|
|
///add by yinzf
|
|
|
try
|
|
|
{
|
|
|
Console.WriteLine(String.Format("{0}设备断开重连", equip.equipIp));
|
|
|
LogHelper.Info(String.Format("{0}设备断开重连", equip.equipIp));
|
|
|
equip.DeviceAdapter.Device_Destroy();
|
|
|
equip.DeviceAdapter.Device_ReConnect();
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
LogHelper.Info(String.Format("{0}设备重新连接失败{1}", equip.equipIp, ex.Message));
|
|
|
}
|
|
|
//end add
|
|
|
}
|
|
|
|
|
|
private void Reconnect(object o)
|
|
|
{
|
|
|
ProEquip equip = o as ProEquip;
|
|
|
if (equip != null)
|
|
|
{
|
|
|
equip.DeviceAdapter.Device_ReConnect();
|
|
|
}
|
|
|
}
|
|
|
|
|
|
/// <summary>
|
|
|
/// 动态生成业务处理代码
|
|
|
/// </summary>
|
|
|
/// <param name="st"></param>
|
|
|
/// <returns></returns>
|
|
|
private IDeviceAdapter DynamicClass(string equipType)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
string str = System.Environment.CurrentDirectory;
|
|
|
str = str + "\\MaterialTraceability.Rfid.dll";
|
|
|
Assembly assembly = Assembly.LoadFile(str); // 加载程序集（EXE 或 DLL）
|
|
|
dynamic obj = assembly.CreateInstance("MaterialTraceability.Rfid.Impl.RFly_I160Adapter"); // 创建类的实例
|
|
|
////根据类型，动态生成设备实体类
|
|
|
//Assembly assembly = Assembly.GetExecutingAssembly(); // 获取当前程序集
|
|
|
//string AssemName = "Mesnac.DeviceAdapter." + equipType;
|
|
|
//var obj = assembly.CreateInstance("HighWay.Ningde.Entity.ProBaoM", true);
|
|
|
//Mesnac.DeviceAdapter.GRUV100.GRUV100Adapter a = new Mesnac.DeviceAdapter.GRUV100.GRUV100Adapter();
|
|
|
return obj as IDeviceAdapter;
|
|
|
}
|
|
|
catch (Exception e)
|
|
|
{
|
|
|
//LogService.Instance.Debug("设备实体类生成失败，请检查类型是否正确"+e.ToString());
|
|
|
return null;
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
public List<ProEquip> Equiplist
|
|
|
{
|
|
|
get
|
|
|
{
|
|
|
return _equipList;
|
|
|
}
|
|
|
}
|
|
|
|
|
|
public void Dipose()
|
|
|
{
|
|
|
ReadContinue = false;
|
|
|
if (thread != null)
|
|
|
{
|
|
|
thread.Abort();
|
|
|
}
|
|
|
if (Connect != null)
|
|
|
{
|
|
|
Connect.Abort();
|
|
|
}
|
|
|
foreach (var equip in IpequipList)
|
|
|
{
|
|
|
equip.DeviceAdapter.Device_Destroy();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
|
|
public class TagMessage
|
|
|
{
|
|
|
/// <summary>
|
|
|
/// epc
|
|
|
/// </summary>
|
|
|
public string EPC { get; set; }
|
|
|
/// <summary>
|
|
|
/// 位置
|
|
|
/// </summary>
|
|
|
public int position { get; set; }
|
|
|
}
|
|
|
} |