|
@@ -19,6 +19,8 @@ using FTP;
|
|
using HslCommunication;
|
|
using HslCommunication;
|
|
using System.Text.RegularExpressions;
|
|
using System.Text.RegularExpressions;
|
|
using System.IO;
|
|
using System.IO;
|
|
|
|
+using Org.BouncyCastle.Ocsp;
|
|
|
|
+using MySqlX.XDevAPI.Common;
|
|
|
|
|
|
namespace IMCS.CCS.Services
|
|
namespace IMCS.CCS.Services
|
|
{
|
|
{
|
|
@@ -871,5 +873,66 @@ namespace IMCS.CCS.Services
|
|
return taskCallbackData;
|
|
return taskCallbackData;
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ public async Task<ResponseECSData> PushPushToMachine(RequestData<CutterTestData> req)
|
|
|
|
+ {
|
|
|
|
+ Log.Instance.WriteLogAdd("机外对刀仪数据接受===>> "+ JsonConvert.SerializeObject(req),"机外对刀仪");
|
|
|
|
+ // 1、根据url查询设备信息 2、调用httpserveer 发送执行消息
|
|
|
|
+
|
|
|
|
+ ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId);
|
|
|
|
+ try
|
|
|
|
+ {
|
|
|
|
+ List<Device> devices = _deviceService.GetDeviceList();
|
|
|
|
+
|
|
|
|
+ Device device = devices.Where(x => x.Ip.Equals(req.url) && x.Port.Equals(req.port)).FirstOrDefault();
|
|
|
|
+
|
|
|
|
+ if (device == null)
|
|
|
|
+ {
|
|
|
|
+ Log.Instance.WriteLogAdd(ActionTypeEnum.StartCleanMachine + "设备已离线===>>" + JsonConvert.SerializeObject(req),
|
|
|
|
+ EnumHelper.GetDescription(ActionTypeEnum.StartCleanMachine));
|
|
|
|
+ responseData.result = "false";
|
|
|
|
+ responseData.resultMsg = ActionTypeEnum.StartCleanMachine + "设备已离线===>>" + JsonConvert.SerializeObject(req);
|
|
|
|
+ return responseData;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ if (device.ProtocolType == ProtocalTypeEnum.HEIDEHAIN.ToString())
|
|
|
|
+ {
|
|
|
|
+
|
|
|
|
+ RequestHeidhData hdhReq = new RequestHeidhData();
|
|
|
|
+ hdhReq.ServerUrl = device.ServerUrl;
|
|
|
|
+ hdhReq.MachineName = device.UserName;
|
|
|
|
+ hdhReq.Type = "ReadAndWriteTool";
|
|
|
|
+ hdhReq.CutterData = JsonConvert.SerializeObject(req.data);
|
|
|
|
+
|
|
|
|
+ var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, hdhUrlContext, hdhReq, null);
|
|
|
|
+ ResponseHeidhData responseHeidhData = JsonConvert.DeserializeObject<ResponseHeidhData>(Result.Message);
|
|
|
|
+ if (!Result.IsSuccess || !responseHeidhData.result)
|
|
|
|
+ {
|
|
|
|
+ Log.Instance.WriteLogAdd(ActionTypeEnum.UploadFile + "机外对刀仪数据上传异常===>>" + JsonConvert.SerializeObject(req)+"======结果数据:"+ Result, "机外对刀仪");
|
|
|
|
+ responseData.result = "false";
|
|
|
|
+ responseData.resultMsg = Result.Message;
|
|
|
|
+ }
|
|
|
|
+ else
|
|
|
|
+ {
|
|
|
|
+ responseData.result = "true";
|
|
|
|
+ responseData.resultMsg = "消费成功";
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ else {
|
|
|
|
+ responseData.result = "false";
|
|
|
|
+ responseData.resultMsg = "没找到对应的数类型方法";
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ catch (Exception ex) {
|
|
|
|
+
|
|
|
|
+ Log.Instance.WriteLogAdd(ActionTypeEnum.StartDryMachine + "任务下发异常===>>" + ex.Message + JsonConvert.SerializeObject(req),
|
|
|
|
+ EnumHelper.GetDescription(ActionTypeEnum.StartDryMachine));
|
|
|
|
+ responseData.result = "false";
|
|
|
|
+ responseData.resultMsg = ex.Message;
|
|
|
|
+ return responseData;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ return responseData;
|
|
|
|
+ }
|
|
}
|
|
}
|
|
}
|
|
}
|