ldw
@@ -0,0 +1,359 @@
|
||||
using HslCommunication.MQTT;
|
||||
using HslCommunication;
|
||||
using Newtonsoft.Json;
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Collections.ObjectModel;
|
||||
using System.Linq;
|
||||
using System.Text;
|
||||
using System.IO;
|
||||
using System.Threading.Tasks;
|
||||
using System.Security.Policy;
|
||||
using JinYuan.Models;
|
||||
|
||||
namespace JinYuan.Helper
|
||||
{
|
||||
public class SendDateMQTT
|
||||
{
|
||||
/// <summary>
|
||||
/// 单类
|
||||
/// </summary>
|
||||
private static SendDateMQTT _instance;
|
||||
private static readonly object _lock = new object();
|
||||
public static SendDateMQTT Instance
|
||||
{
|
||||
get
|
||||
{
|
||||
if (_instance == null)
|
||||
{
|
||||
lock (_lock)
|
||||
{
|
||||
if (_instance == null)
|
||||
{
|
||||
_instance = new SendDateMQTT();
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
return _instance;
|
||||
}
|
||||
}
|
||||
|
||||
private SendDateMQTT()
|
||||
{
|
||||
|
||||
Connect(MQTTServerAddress, MQTTServerPort, "admin", "123456");
|
||||
//mqttClient.OnMqttMessageReceived += MqttClient_OnMqttMessageReceived; // 调用一次即可
|
||||
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 打印日志方法
|
||||
/// </summary>
|
||||
/// <param name="Message"></param>日志信息
|
||||
/// <param name="FileName"></param>文件夹名字
|
||||
public static void LogMessage(string Message, string FileName)
|
||||
{
|
||||
string filePath = FileName + "//" + DateTime.Now.ToString("yyyy-MM-dd"); // 日志文件存放路径，默认在debug目录下
|
||||
string filePath2 = FileName + "//" + DateTime.Now.ToString("yyyy-MM-dd") + "//Mylog.txt";//也可以加上时间
|
||||
//string file=DateTime.Now+"log.txt";
|
||||
//检查文件夹是否存在，否则新建
|
||||
if (!Directory.Exists(filePath))
|
||||
{
|
||||
Directory.CreateDirectory(filePath);
|
||||
}
|
||||
string logMessage = $"{DateTime.Now}: {Message}";//打印出现的时间
|
||||
// 将消息写入日志文件
|
||||
using (StreamWriter writer = new StreamWriter(filePath2, true))
|
||||
{
|
||||
writer.WriteLine(logMessage);
|
||||
}
|
||||
}
|
||||
|
||||
HslCommunication.MQTT.MqttClient mqttClient = null;
|
||||
//10.22.160.144
|
||||
public string MQTTServerAddress = "10.22.161.1";
|
||||
public int MQTTServerPort = 2883;
|
||||
public string ClientId = "601UPW01";
|
||||
//PPM主题
|
||||
public string Topic = "EVE/60J/TrackInOut/601UPW01";//进出站
|
||||
public string Topic1 = "EVE/60J/CTPCTQ/601UPW01";
|
||||
public string BU_id = "EVE8BU";
|
||||
public string District_id = "JM";
|
||||
public string Factory_id = "60J";
|
||||
public string Production_line_id = "601L";
|
||||
public string Work_center_id = "601EIE02";
|
||||
public string Device_name = "601UPW01";
|
||||
public string Action_time = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
||||
|
||||
|
||||
|
||||
|
||||
/// <summary>
|
||||
/// 发送进出站数据
|
||||
/// </summary>
|
||||
/// <param name="topic"></param>
|
||||
/// <param name="IP"></param>
|
||||
/// <param name="Port"></param>
|
||||
/// <param name="cPQCPTDate"></param>
|
||||
public void EnterandExitSendMessge(int Station = 3)
|
||||
{
|
||||
try
|
||||
{
|
||||
////if (mqttClient != null)
|
||||
//// mqttClient.ConnectClose();
|
||||
if (!mqttClient.IsConnected)
|
||||
{
|
||||
Connect(MQTTServerAddress, MQTTServerPort, "admin", "123456");
|
||||
}
|
||||
SubscribeMessage(Topic);
|
||||
//进站
|
||||
if (Station == 0)
|
||||
{
|
||||
PublishMessage(Topic, EnterandExitMessge("0"));
|
||||
}
|
||||
//出站
|
||||
else if (Station == 1)
|
||||
{
|
||||
|
||||
PublishMessage(Topic, EnterandExitMessge("1"));
|
||||
}
|
||||
}
|
||||
catch (Exception err)
|
||||
{
|
||||
Logger.WriteError($"发送进出站数据错误，{err.Message}",err);
|
||||
}
|
||||
}
|
||||
/// <summary>
|
||||
/// 发送采集项数据
|
||||
/// </summary>
|
||||
/// <param name="topic"></param>
|
||||
/// <param name="IP"></param>
|
||||
/// <param name="Port"></param>
|
||||
/// <param name="cPQCPTDate"></param>
|
||||
public void CollectionSendMessge(CPQCPTDate cPQCPTDate)
|
||||
{
|
||||
try
|
||||
{
|
||||
if (!mqttClient.IsConnected)
|
||||
{
|
||||
Connect(MQTTServerAddress, MQTTServerPort, "admin", "123456");
|
||||
}
|
||||
SubscribeMessage(Topic1);
|
||||
PublishMessage(Topic1, CollectionMessge(cPQCPTDate));
|
||||
}
|
||||
catch (Exception err)
|
||||
{
|
||||
Logger.WriteError($"发送采集项数据错误，{err.Message}",err);
|
||||
}
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 连接
|
||||
/// </summary>
|
||||
/// <param name="ip"></param>
|
||||
/// <param name="port"></param>
|
||||
/// <param name="name"></param>
|
||||
/// <param name="pwd"></param>
|
||||
/// <param name="clientId"></param>
|
||||
public void Connect(string ip, int port, string name, string pwd, string clientId = "ClientId")
|
||||
{
|
||||
try
|
||||
{
|
||||
if (mqttClient != null)
|
||||
{
|
||||
Logger.WriteMqtt("MQTT 服务器关闭失败");
|
||||
mqttClient.ConnectClose();
|
||||
}
|
||||
|
||||
mqttClient = new MqttClient(new MqttConnectionOptions()
|
||||
{
|
||||
ClientId = clientId,
|
||||
IpAddress = ip,
|
||||
Port = port,
|
||||
Credentials = new MqttCredential(name, pwd), // 设置了用户名和密码
|
||||
});
|
||||
|
||||
OperateResult connect = mqttClient.ConnectServer();
|
||||
if (connect.IsSuccess)
|
||||
{
|
||||
Logger.WriteMqtt("MQTT 连接服务器成功");
|
||||
}
|
||||
else
|
||||
{
|
||||
Logger.WriteMqtt("MQTT 无法连接到服务器");
|
||||
}
|
||||
}
|
||||
catch (Exception err)
|
||||
{
|
||||
Logger.WriteError($"MQTT 无法连接到服务器: {err.Message}");
|
||||
}
|
||||
|
||||
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 发布信息
|
||||
/// </summary>
|
||||
/// <param name="topic"></param>
|
||||
public void PublishMessage(string topic, string Message)
|
||||
{
|
||||
try
|
||||
{
|
||||
OperateResult result = mqttClient.PublishMessage(new MqttApplicationMessage()
|
||||
{
|
||||
Topic = topic, // 主题
|
||||
QualityOfServiceLevel = MqttQualityOfServiceLevel.AtMostOnce, // 消息等级
|
||||
Payload = Encoding.UTF8.GetBytes(Message), // 数据
|
||||
Retain = false, // 是否保留
|
||||
});
|
||||
if (result.IsSuccess)
|
||||
{
|
||||
Logger.WriteMqtt($"发送消息到主题 [{topic}]: {Message}");
|
||||
}
|
||||
else
|
||||
{
|
||||
Logger.WriteMqtt($"发送消息到主题 [{topic}] 失败: {result.Message}");
|
||||
}
|
||||
}
|
||||
catch (Exception err)
|
||||
{
|
||||
Logger.WriteError($"MQTT 无法连接到服务器: {err.Message}");
|
||||
}
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 订阅主题
|
||||
/// </summary>
|
||||
/// <param name="topic"></param>
|
||||
public void SubscribeMessage(string Topic)
|
||||
{
|
||||
try
|
||||
{
|
||||
//mqttClient.OnMqttMessageReceived += MqttClient_OnMqttMessageReceived; // 调用一次即可
|
||||
OperateResult Result = mqttClient.SubscribeMessage(Topic); // 订阅A的主题
|
||||
if (Result.IsSuccess)
|
||||
{
|
||||
Logger.WriteMqtt($"订阅成功[{Topic}]");
|
||||
}
|
||||
else
|
||||
{
|
||||
Logger.WriteMqtt($"订阅失败[{Topic}]");
|
||||
}
|
||||
}
|
||||
catch (Exception err)
|
||||
{
|
||||
Logger.WriteError($"订阅失败[{err.Message}]");
|
||||
}
|
||||
}
|
||||
|
||||
private static void MqttClient_OnMqttMessageReceived(MqttClient client, MqttApplicationMessage message)
|
||||
{
|
||||
Logger.WriteMqtt($"收到服务器信息[{message.ToString()}]");
|
||||
}
|
||||
|
||||
/// <summary>
|
||||
/// 拼接进出站json
|
||||
/// </summary>
|
||||
/// <param name="action"></param>
|
||||
/// <returns></returns>
|
||||
public string EnterandExitMessge(string action)
|
||||
{
|
||||
string messgeJson = string.Empty;
|
||||
try
|
||||
{
|
||||
EnterandExit enterandExit = new EnterandExit()
|
||||
{
|
||||
bu_id = BU_id,
|
||||
district_id = District_id,
|
||||
factory_id = Factory_id,
|
||||
production_line_id = Production_line_id,
|
||||
production_processes_id = "",
|
||||
work_center_id = Work_center_id,
|
||||
station_id = "",
|
||||
device_name = Device_name,
|
||||
action = action,
|
||||
action_time = Action_time,
|
||||
};
|
||||
var messageJson = JsonConvert.SerializeObject(enterandExit, new JsonSerializerSettings
|
||||
{
|
||||
NullValueHandling = NullValueHandling.Ignore,
|
||||
Formatting = Formatting.None
|
||||
});
|
||||
messgeJson = messageJson;
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
Logger.WriteError($"方法：上传MQTTServer数据，上传失败: {ex.Message}", ex);
|
||||
}
|
||||
return messgeJson;
|
||||
}
|
||||
/// <summary>
|
||||
/// 拼接采集项数据
|
||||
/// </summary>
|
||||
/// <param name="cPQCPTDate"></param>
|
||||
/// <returns></returns>
|
||||
public string CollectionMessge(CPQCPTDate cPQCPTDate)
|
||||
{
|
||||
string messgejson = string.Empty;
|
||||
try
|
||||
{
|
||||
CollectionUpload enterandExit = new CollectionUpload()
|
||||
{
|
||||
bu_id = BU_id,
|
||||
district_id = District_id,
|
||||
factory_id = Factory_id,
|
||||
production_line_id = Production_line_id,
|
||||
production_processes_id = "",
|
||||
work_center_id = Work_center_id,
|
||||
station_id = "",
|
||||
device_name = Device_name,
|
||||
taglist = new List<Collection>
|
||||
{
|
||||
new Collection
|
||||
{
|
||||
device_time = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
|
||||
collection_items = new Dictionary<string, string>
|
||||
{
|
||||
{"CTP_PreWeighing_Value",cPQCPTDate.CTP_PreWeighing_Value },
|
||||
{"CTP_Liquid_Retention_Value",cPQCPTDate.CTP_Liquid_Retention_Value },
|
||||
{"CTP_Filling_Value",cPQCPTDate.CTP_Filling_Value},
|
||||
{"CTP_Liquid_Loss_Value", cPQCPTDate.CTP_Liquid_Loss_Value},
|
||||
{"CTP_Helium_Filling_Value",cPQCPTDate.CTP_Helium_Filling_Value},
|
||||
{"CTP_Belljar_Vacuum_Value",cPQCPTDate.CTP_Belljar_Vacuum_Value},
|
||||
{"CTP_Belljar_Vacuum_Time",cPQCPTDate.CTP_Belljar_Vacuum_Time},
|
||||
{"CTP_Belljar_HighPressure_Value",cPQCPTDate.CTP_Belljar_HighPressure_Value},
|
||||
{"CTP_Belljar_HighPressure_Time",cPQCPTDate.CTP_Belljar_HighPressure_Time},
|
||||
{"CTP_Belljar_Cycles_Number",cPQCPTDate.CTP_Belljar_Cycles_Number},
|
||||
{"CTP_Pre_Helium_Value",cPQCPTDate.CTP_Pre_Helium_Value},
|
||||
{"CTP_Post_Helium_Value",cPQCPTDate.CTP_Post_Helium_Value},
|
||||
{"CTP_Flat_Pressure",cPQCPTDate.CTP_Flat_Pressure},
|
||||
{"CTP_Cell_Thickness_Pressure",cPQCPTDate.CTP_Cell_Thickness_Pressure},
|
||||
{"CTQ_PostWeighing_Value",cPQCPTDate.CTQ_PostWeighing_Value},
|
||||
{"CTQ_Cell_Thickness",cPQCPTDate.CTQ_Cell_Thickness},
|
||||
{"CTQ_Finalpress_Rubber_Height",cPQCPTDate.CTQ_Finalpress_Rubber_Height},
|
||||
{"CTP_PreInjection_Pressure",cPQCPTDate.CTP_PreInjection_Pressure},
|
||||
{"CTQ_Electrolyte_Inventory",cPQCPTDate.CTQ_Electrolyte_Inventory},
|
||||
{"CTP_PreNailing_Stroke",cPQCPTDate.CTP_PreNailing_Stroke},
|
||||
{"CTP_PreHelium_Vacuum_Pressure",cPQCPTDate.CTP_PreHelium_Vacuum_Pressure},
|
||||
{"CTP_FinalNailing_Stroke",cPQCPTDate.CTP_FinalNailing_Stroke},
|
||||
{"CTQ_Finalpress_Rubber_Thickness",cPQCPTDate.CTQ_Finalpress_Rubber_Thickness},
|
||||
}
|
||||
}
|
||||
}
|
||||
};
|
||||
var messageJson = JsonConvert.SerializeObject(enterandExit, new JsonSerializerSettings
|
||||
{
|
||||
NullValueHandling = NullValueHandling.Ignore,
|
||||
Formatting = Formatting.None
|
||||
});
|
||||
messgejson = messageJson;
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
Logger.WriteError($"生成Json数据失败: {ex.Message}", ex);
|
||||
}
|
||||
return messgejson;
|
||||
}
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user