TaskJobService.cs 91 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714
  1. using HslCommunication;
  2. using HslCommunication.Profinet.Siemens;
  3. using IMCS.CCS.Common.Redis;
  4. using IMCS.CCS.DeviceProtocol;
  5. using IMCS.CCS.Entitys;
  6. using IMCS.CCS.Models.vo;
  7. using IMCS.CCS.Services;
  8. using IMCS_CCS.Model.vo;
  9. using IMCS_CCS.Utils;
  10. using Microsoft.Extensions.Configuration;
  11. using Newtonsoft.Json;
  12. using S7.Net;
  13. using System;
  14. using System.Collections.Generic;
  15. using System.Linq;
  16. using System.Threading;
  17. using System.Threading.Tasks;
  18. using IMCS.CCS.Models;
  19. namespace IMCS.CCS.Service.Impl
  20. {
  21. /// <summary>
  22. /// 任务调度服务
  23. /// </summary>
  24. public class TaskJobService : ITaskJobService
  25. {
  26. private readonly IRedisService _redisService;
  27. private readonly IDeviceService _deviceService;
  28. private readonly IApiRequestService _apiRequestService;
  29. private readonly ITaskCallbackService _taskCallbackService;
  30. private readonly ICcsTagValueService _ccsTagValueService;
  31. private readonly IEquipmentMonitorService _equipmentMonitorService;
  32. private readonly IDictionaryService _dictionaryService;
  33. private readonly ICcsActionAddressService _ccsActionAddressService;
  34. private string ecsUrlContext;
  35. private string ecsRootUrlContext;
  36. private string fanucUrlContext;
  37. private string opcuacUrlContext;
  38. private string hdhUrlContext;
  39. private Dictionary<String, int> syncStatusMap = new Dictionary<String, int>();
  40. private string LOG_TITLE_OPCUA = "OPCUA采集";
  41. private string LOG_TITLE_S7 = "S7采集";
  42. private string LOG_TITLE_CALLBACK = "回调任务";
  43. private string LOG_TITLE_DEVICE = "设备监控";
  44. private string callback_redis_key = "IMCS_CCS:CallbackTaskList";
  45. private string device_redis_key = "IMCS_CCS:DeviceList";
  46. public IConfiguration Configuration { get; }
  47. public TaskJobService(IRedisService redisService,
  48. ITaskCallbackService taskCallbackService,
  49. IDeviceService deviceService,
  50. IApiRequestService apiRequestService,
  51. ICcsTagValueService ccsTagValueService,
  52. IEquipmentMonitorService equipmentMonitorService,
  53. IDictionaryService dictionaryService,
  54. ICcsActionAddressService ccsActionAddressService,
  55. IConfiguration configuration)
  56. {
  57. _redisService = redisService;
  58. _taskCallbackService = taskCallbackService;
  59. _deviceService = deviceService;
  60. _apiRequestService = apiRequestService;
  61. _ccsTagValueService = ccsTagValueService;
  62. _equipmentMonitorService = equipmentMonitorService;
  63. _dictionaryService = dictionaryService;
  64. _ccsActionAddressService = ccsActionAddressService;
  65. Configuration = configuration;
  66. ecsUrlContext = Configuration.GetConnectionString("ecsUrlContext");
  67. fanucUrlContext = Configuration.GetConnectionString("fanucUrlContext");
  68. opcuacUrlContext = Configuration.GetConnectionString("opcuacUrlContext");
  69. hdhUrlContext = Configuration.GetConnectionString("hdhUrlContext");
  70. ecsRootUrlContext = Configuration.GetConnectionString("ecsRootUrlContext");
  71. syncStatusMap.Add("离线", 0);
  72. syncStatusMap.Add("空闲", 1);
  73. syncStatusMap.Add("生产中", 2);
  74. syncStatusMap.Add("报警", 3);
  75. //在线状态默认传参后台空闲状态
  76. syncStatusMap.Add("在线", 1);
  77. }
  78. /// <summary>
  79. /// 采集数据OPCUA
  80. /// </summary>
  81. /// <returns></returns>
  82. public async Task<string> DataCollectOPCUAJob()
  83. {
  84. try
  85. {
  86. List<Device> deviceList = await getDeviceList();
  87. deviceList = deviceList.Where(x => x.ProtocolType.Equals(ProtocalTypeEnum.OPCUA.ToString()) && x.State).ToList();
  88. foreach (Device device in deviceList)
  89. {
  90. List<CcsTagValue> tagValues = new List<CcsTagValue>();
  91. string redis_key = "IMCS_CCS:" + device.Ip + ":" + device.ProtocolType;
  92. var data = await _redisService.Database.StringGetAsync(redis_key);
  93. if (data.IsNullOrEmpty)
  94. {
  95. CcsTagValue tagQuery = new CcsTagValue();
  96. tagQuery.ProtocolType = device.ProtocolType;
  97. tagQuery.Ip = device.Ip;
  98. tagValues = _ccsTagValueService.GetList(tagQuery);
  99. //首次设置redis
  100. if (tagValues != null && tagValues.Count > 0)
  101. {
  102. await _redisService.Database.StringSetAsync(redis_key, JsonConvert.SerializeObject(tagValues));
  103. }
  104. }
  105. else
  106. {
  107. tagValues = JsonConvert.DeserializeObject<List<CcsTagValue>>(data);
  108. }
  109. if (tagValues != null && tagValues.Count > 0)
  110. {
  111. List<CcsTagValue> changTagValues = new List<CcsTagValue>();
  112. List<string> addresses = new List<string>();
  113. foreach (CcsTagValue tagValue in tagValues)
  114. {
  115. addresses.Add(tagValue.Address);
  116. }
  117. //调用opcua是否连接接口
  118. RequestOpcUaData opcUaReq = new RequestOpcUaData();
  119. opcUaReq.ServerUrl = device.ServerUrl;
  120. opcUaReq.UserName = device.UserName;
  121. opcUaReq.Password = device.Password;
  122. opcUaReq.Type = OpcUaActionTypeEnum.Read.ToString();
  123. opcUaReq.Addresses = addresses;
  124. var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, opcuacUrlContext, opcUaReq, null);
  125. ResponseOpcUaData responseOpcUaData = JsonConvert.DeserializeObject<ResponseOpcUaData>(Result.Message);
  126. if (!Result.IsSuccess || !responseOpcUaData.result)
  127. {
  128. device.State = false;
  129. await _deviceService.UpdateDevice(device);
  130. Log.Instance.WriteLogAdd("OpcUA采集异常,连不上设备", LOG_TITLE_OPCUA);
  131. return "采集失败,连不上设备";
  132. }
  133. List<string> values = responseOpcUaData.values;
  134. if (values != null)
  135. {
  136. for (int i = 0; i < tagValues.Count; i++)
  137. {
  138. CcsTagValue tagValueData = (CcsTagValue)tagValues[i];
  139. //科学计数法转换
  140. if (values[i].Contains("E") && tagValueData.Type == TagValueReadTypeEnum.Double.ToString())
  141. {
  142. Decimal d = ChangeToDecimal(values[i]);
  143. values[i] = d.ToString();
  144. }
  145. if (tagValueData.TagValue != values[i])
  146. {
  147. tagValueData.TagValue = values[i];
  148. tagValueData.UpdateTime = DateTime.Now;
  149. changTagValues.Add(tagValueData);
  150. Log.Instance.WriteLogAdd("OpcUA采集,Ip:" + tagValueData.Ip + " 地址:" + tagValueData.Address + ",值:" + tagValueData.TagValue + ",发生变化", LOG_TITLE_OPCUA);
  151. //有变化更新数据库
  152. await _ccsTagValueService.Update(tagValueData);
  153. }
  154. }
  155. }
  156. //值有变化,重新设置一次redis
  157. if (changTagValues != null && changTagValues.Count > 0)
  158. {
  159. await _redisService.Database.StringSetAsync(redis_key, JsonConvert.SerializeObject(tagValues));
  160. }
  161. CcsTagValue tagQuery = new CcsTagValue();
  162. tagQuery.ProtocolType = device.ProtocolType;
  163. tagQuery.Ip = device.Ip;
  164. tagValues = _ccsTagValueService.GetList(tagQuery);
  165. //机床复位
  166. CcsTagValue tagValue1 = tagValues.Where(t => t.Address == "ns=2;s=/Plc/M1500.2").FirstOrDefault();
  167. CcsTagValue tagValue2 = tagValues.Where(t => t.Address == "ns=2;s=/Plc/M1500.4").FirstOrDefault();
  168. if (tagValue1.TagValue == "True" && tagValue2.TagValue == "True")
  169. {
  170. opcUaReq.Addresses = new List<string>() { "ns=2;s=/Plc/M1999.1" };
  171. opcUaReq.Values = new List<string>() { "False" };
  172. opcUaReq.Type = OpcUaActionTypeEnum.Write.ToString();
  173. await _apiRequestService.RequestAsync(RequsetModeEnum.Post, opcuacUrlContext, opcUaReq, null);
  174. }
  175. }
  176. else
  177. {
  178. Log.Instance.WriteLogAdd("OpcUA采集异常,没有采集数据===", LOG_TITLE_OPCUA);
  179. return "没有采集数据";
  180. }
  181. }
  182. return "OpcUA采集成功";
  183. }
  184. catch (Exception ex)
  185. {
  186. Log.Instance.WriteLogAdd("OpcUA采集异常===>>" + ex.Message, LOG_TITLE_OPCUA);
  187. return "OpcUA采集失败";
  188. }
  189. }
  190. /// <summary>
  191. /// 采集数据S7
  192. /// </summary>
  193. /// <returns></returns>
  194. public async Task<string> DataCollectS7Job()
  195. {
  196. try
  197. {
  198. List<Device> deviceList = await getDeviceList();
  199. deviceList = deviceList.Where(x => x.ProtocolType.Equals(ProtocalTypeEnum.S7_1500.ToString()) && x.State).ToList();
  200. foreach (Device device in deviceList)
  201. {
  202. List<CcsTagValue> tagValues = new List<CcsTagValue>();
  203. string redis_key = "IMCS_CCS:" + device.Ip + ":" + device.ProtocolType;
  204. var data = await _redisService.Database.StringGetAsync(redis_key);
  205. if (data.IsNullOrEmpty)
  206. {
  207. CcsTagValue tagQuery = new CcsTagValue();
  208. tagQuery.ProtocolType = device.ProtocolType;
  209. tagQuery.Ip = device.Ip;
  210. tagValues = _ccsTagValueService.GetList(tagQuery);
  211. //首次设置redis
  212. if (tagValues != null && tagValues.Count > 0)
  213. {
  214. await _redisService.Database.StringSetAsync(redis_key, JsonConvert.SerializeObject(tagValues));
  215. }
  216. }
  217. else
  218. {
  219. tagValues = JsonConvert.DeserializeObject<List<CcsTagValue>>(data);
  220. }
  221. if (tagValues != null && tagValues.Count > 0)
  222. {
  223. tagValues = JsonConvert.DeserializeObject<List<CcsTagValue>>(data);
  224. List<CcsTagValue> changTagValues = new List<CcsTagValue>();
  225. //Plc s7 = DevicePlcS7.S7(device.ServerUrl, ProtocalTypeEnum.S7_1500.ToString());
  226. SiemensS7Net s7 = DevicePlcS7.SiemensS7(device.ServerUrl);
  227. OperateResult ConnectionResult = s7.ConnectServer();
  228. if (!ConnectionResult.IsSuccess)
  229. {
  230. device.State = false;
  231. await _deviceService.UpdateDevice(device);
  232. s7.ConnectClose();
  233. Log.Instance.WriteLogAdd("S7采集异常,plc连不上", LOG_TITLE_S7);
  234. return "采集失败,plc连不上";
  235. }
  236. else
  237. {
  238. foreach (CcsTagValue tagValueData in tagValues)
  239. {
  240. string operateResult = "";
  241. if (tagValueData.Type.Equals(TagValueReadTypeEnum.BOOL.ToString()))
  242. {
  243. operateResult = s7.ReadBool(tagValueData.Address).Content.ToString();
  244. }
  245. else if (tagValueData.Type.Equals(TagValueReadTypeEnum.SHORT.ToString()))
  246. {
  247. operateResult = s7.ReadInt16(tagValueData.Address).Content.ToString();
  248. }
  249. else if (tagValueData.Type.Equals(TagValueReadTypeEnum.String.ToString()))
  250. {
  251. operateResult = s7.ReadString(tagValueData.Address).Content.ToString();
  252. }
  253. else if (tagValueData.Type.Equals(TagValueReadTypeEnum.Array.ToString()))
  254. {
  255. operateResult = ToolUtils.ReturnStringByBytes(s7.Read(tagValueData.Address,40).Content);
  256. }
  257. if (!string.IsNullOrEmpty(operateResult) && tagValueData.TagValue != operateResult)
  258. {
  259. tagValueData.TagValue = operateResult.ToString();
  260. tagValueData.UpdateTime = DateTime.Now;
  261. changTagValues.Add(tagValueData);
  262. Log.Instance.WriteLogAdd("S7采集,Ip:" + tagValueData.Ip + " 地址:" + tagValueData.Address + ",值:" + tagValueData.TagValue + ",发生变化", LOG_TITLE_S7);
  263. //有变化更新数据库
  264. await _ccsTagValueService.Update(tagValueData);
  265. }
  266. Thread.Sleep(50);
  267. }
  268. s7.ConnectClose();
  269. //值有变化,重新设置一次redis
  270. if (changTagValues != null && changTagValues.Count > 0)
  271. {
  272. await _redisService.Database.StringSetAsync(redis_key, JsonConvert.SerializeObject(tagValues));
  273. }
  274. }
  275. }
  276. }
  277. return "S7采集成功";
  278. }
  279. catch (Exception ex)
  280. {
  281. Log.Instance.WriteLogAdd("S7采集异常===>>" + ex.Message, LOG_TITLE_S7);
  282. return "S7采集失败";
  283. }
  284. }
  285. /// <summary>
  286. /// 采集数据FANUC
  287. /// </summary>
  288. /// <returns></returns>
  289. public async Task<string> DataCollectFanucJob()
  290. {
  291. try
  292. {
  293. List<Device> deviceList = await getDeviceList();
  294. deviceList = deviceList.Where(x => x.ProtocolType.Equals(ProtocalTypeEnum.FANUC.ToString()) && x.State).ToList();
  295. foreach (Device device in deviceList)
  296. {
  297. List<CcsTagValue> tagValues = new List<CcsTagValue>();
  298. string redis_key = "IMCS_CCS:" + device.Ip + ":" + device.ProtocolType;
  299. var data = await _redisService.Database.StringGetAsync(redis_key);
  300. if (data.IsNullOrEmpty)
  301. {
  302. CcsTagValue tagQuery = new CcsTagValue();
  303. tagQuery.ProtocolType = device.ProtocolType;
  304. tagQuery.Ip = device.Ip;
  305. tagValues = _ccsTagValueService.GetList(tagQuery);
  306. //首次设置redis
  307. if (tagValues != null && tagValues.Count > 0)
  308. {
  309. await _redisService.Database.StringSetAsync(redis_key, JsonConvert.SerializeObject(tagValues));
  310. }
  311. }
  312. else
  313. {
  314. tagValues = JsonConvert.DeserializeObject<List<CcsTagValue>>(data);
  315. }
  316. if (tagValues != null && tagValues.Count > 0)
  317. {
  318. tagValues = JsonConvert.DeserializeObject<List<CcsTagValue>>(data);
  319. List<CcsTagValue> changTagValues = new List<CcsTagValue>();
  320. string Url = fanucUrlContext + "?ip=" + device.Ip + "&port=" + device.Port;
  321. //调用发那科是否连接接口
  322. var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Get, Url + "&fun=Connect", null, null);
  323. if (!Result.IsSuccess || Result.Message != "0")
  324. {
  325. device.State = false;
  326. await _deviceService.UpdateDevice(device);
  327. Log.Instance.WriteLogAdd("FANUC采集异常,FANUC连不上", LOG_TITLE_S7);
  328. return "采集失败,FANUC连不上";
  329. }
  330. else
  331. {
  332. //调用发那科采集接口
  333. Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Get, Url + "&fun=All", null, null);
  334. ResponseFanucData fanucData = JsonConvert.DeserializeObject<ResponseFanucData>(Result.Message);
  335. foreach (CcsTagValue tagValueData in tagValues)
  336. {
  337. string operateResult = GetFanucValue(fanucData, tagValueData.Address);
  338. if (tagValueData.TagValue != operateResult)
  339. {
  340. tagValueData.TagValue = operateResult.ToString();
  341. tagValueData.UpdateTime = DateTime.Now;
  342. changTagValues.Add(tagValueData);
  343. Log.Instance.WriteLogAdd("FANUC采集,Ip:" + tagValueData.Ip + " 地址:" + tagValueData.Address + ",值:" + tagValueData.TagValue + ",发生变化", LOG_TITLE_S7);
  344. //有变化更新数据库
  345. await _ccsTagValueService.Update(tagValueData);
  346. }
  347. Thread.Sleep(50);
  348. }
  349. //值有变化,重新设置一次redis
  350. if (changTagValues != null && changTagValues.Count > 0)
  351. {
  352. await _redisService.Database.StringSetAsync(redis_key, JsonConvert.SerializeObject(tagValues));
  353. }
  354. }
  355. }
  356. }
  357. return "FANUC采集成功";
  358. }
  359. catch (Exception ex)
  360. {
  361. Log.Instance.WriteLogAdd("FANUC采集异常===>>" + ex.Message, LOG_TITLE_S7);
  362. return "FANUC采集失败";
  363. }
  364. }
  365. /// <summary>
  366. /// 上传程序回调任务
  367. /// </summary>
  368. /// <returns></returns>
  369. public async Task<string> CallbackJob1()
  370. {
  371. List<TaskCallback> list = new List<TaskCallback>();
  372. var taskCallbackListData = await _redisService.Database.StringGetAsync(callback_redis_key);
  373. if (taskCallbackListData.IsNullOrEmpty)
  374. {
  375. list = await _taskCallbackService.GetAllList();
  376. }
  377. else
  378. {
  379. list = JsonConvert.DeserializeObject<List<TaskCallback>>(taskCallbackListData);
  380. }
  381. TaskCallback task = list.Where(x => x.OperateType.Equals(ActionTypeEnum.UploadFile.ToString())).FirstOrDefault();
  382. if (task == null)
  383. {
  384. return "无回调任务";
  385. }
  386. string message = "";
  387. try
  388. {
  389. DateTime currentTime = DateTime.Now;
  390. if (currentTime.Subtract(task.CreateTime).TotalSeconds > 5)
  391. {
  392. CallBackRequestData requestData = new CallBackRequestData();
  393. requestData.taskId = long.Parse(task.TaskId);
  394. requestData.taskNodeId = long.Parse(task.TaskNodeId);
  395. var result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, ecsUrlContext, requestData, null);
  396. ResponseECSCallbackData responseECSCallback = JsonConvert.DeserializeObject<ResponseECSCallbackData>(result.Message);
  397. if (result.IsSuccess && responseECSCallback.code == 0)
  398. {
  399. task.State = false;
  400. task.UpdateTime = DateTime.Now;
  401. await _taskCallbackService.CreateOrUpdateAndCache(task);
  402. message = task.OperateName + "==>taskId:" + task.TaskId + ",taskNodeId:" + task.TaskNodeId + ",请求结果:" + result.Message + ";";
  403. Log.Instance.WriteLogAdd(message, LOG_TITLE_CALLBACK);
  404. }
  405. else
  406. {
  407. message = message + JsonConvert.SerializeObject(task) + ",请求失败! WebApi 返回结果" + ";";
  408. Log.Instance.WriteLogAdd("回调异常,请求接口失败" + JsonConvert.SerializeObject(result), LOG_TITLE_CALLBACK);
  409. }
  410. }
  411. return string.IsNullOrEmpty(message) ? "无回调任务" : message;
  412. }
  413. catch (Exception ex)
  414. {
  415. Log.Instance.WriteLogAdd("回调异常===>>" + ex.Message, LOG_TITLE_CALLBACK);
  416. return "回调异常" + ex.Message;
  417. }
  418. }
  419. /// <summary>
  420. /// 柔性产线,伺服等取和放回调任务
  421. /// </summary>
  422. /// <returns></returns>
  423. public async Task<string> CallbackJob2()
  424. {
  425. List<TaskCallback> taskList = new List<TaskCallback>();
  426. var taskCallbackListData = await _redisService.Database.StringGetAsync(callback_redis_key);
  427. if (taskCallbackListData.IsNullOrEmpty)
  428. {
  429. taskList = await _taskCallbackService.GetAllList();
  430. }
  431. else
  432. {
  433. taskList = JsonConvert.DeserializeObject<List<TaskCallback>>(taskCallbackListData);
  434. }
  435. //在线设备
  436. List<Device> deviceList = await getDeviceList();
  437. taskList = taskList.Where(x => x.OperateType.Equals(ActionTypeEnum.GetFlexibleWire.ToString())
  438. || x.OperateType.Equals(ActionTypeEnum.SendFlexibleWire.ToString())
  439. || x.OperateType.Equals(ActionTypeEnum.MoveRobotPosition.ToString())
  440. || x.OperateType.Equals(ActionTypeEnum.GetIntelligenceUnit.ToString())
  441. || x.OperateType.Equals(ActionTypeEnum.SendIntelligenceUnit.ToString())
  442. || x.OperateType.Equals(ActionTypeEnum.GetQualityCenter.ToString())
  443. || x.OperateType.Equals(ActionTypeEnum.SendQualityCenter.ToString())
  444. || x.OperateType.Equals(ActionTypeEnum.GetServoStacker.ToString())
  445. || x.OperateType.Equals(ActionTypeEnum.SendServoStacker.ToString())
  446. || x.OperateType.Equals(ActionTypeEnum.SendLinShift.ToString())
  447. || x.OperateType.Equals(ActionTypeEnum.SendLinShiftFine.ToString())).ToList();
  448. TaskCallback task = taskList.Where(key => deviceList.Any(device => device.Ip == key.IP)).FirstOrDefault() ;
  449. if (task == null)
  450. {
  451. return "无回调任务" ;
  452. }
  453. string message = "";
  454. try
  455. {
  456. DateTime currentTime = DateTime.Now;
  457. CcsTagValue tagValueQuery = new CcsTagValue();
  458. tagValueQuery.Ip = task.IP;
  459. //tagValueQuery.Address = task.Address;
  460. List<CcsTagValue> tagValues = _ccsTagValueService.GetList(tagValueQuery).ToList();
  461. CcsTagValue callBacktagValue = tagValues.Where(o => o.Address == task.Address).FirstOrDefault();
  462. if (callBacktagValue != null && callBacktagValue.TagValue == task.CallbackValue)
  463. {
  464. CallBackRequestData requestData = new CallBackRequestData();
  465. requestData.taskId = long.Parse(task.TaskId);
  466. requestData.taskNodeId = long.Parse(task.TaskNodeId);
  467. var result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, ecsUrlContext, requestData, null);
  468. ResponseECSCallbackData responseECSCallback = JsonConvert.DeserializeObject<ResponseECSCallbackData>(result.Message);
  469. if (result.IsSuccess && responseECSCallback.code == 0)
  470. {
  471. task.State = false;
  472. task.UpdateTime = DateTime.Now;
  473. await _taskCallbackService.CreateOrUpdateAndCache(task);
  474. message = task.OperateName + "==>taskId:" + task.TaskId + ",taskNodeId:" + task.TaskNodeId + ",请求结果:" + result.Message + ";";
  475. Log.Instance.WriteLogAdd(message, LOG_TITLE_CALLBACK);
  476. }
  477. else
  478. {
  479. message = message + JsonConvert.SerializeObject(task) + ",请求失败! WebApi 返回结果" + ";";
  480. Log.Instance.WriteLogAdd("回调异常,请求接口失败" + JsonConvert.SerializeObject(result), LOG_TITLE_CALLBACK);
  481. }
  482. }
  483. //回调检测到失败,回调通知ecs
  484. if (!string.IsNullOrEmpty(task.FailAddress) || !string.IsNullOrEmpty(task.FailAddress2) || !string.IsNullOrEmpty(task.FailAddress3))
  485. {
  486. bool failFalg = false;
  487. if (!string.IsNullOrEmpty(task.FailAddress))
  488. {
  489. List<CcsTagValue> FailCallbackTagValues = tagValues.Where(o => o.Address == task.FailAddress && o.TagValue == task.CallbackFailValue).ToList();
  490. if (FailCallbackTagValues != null && FailCallbackTagValues.Count > 0)
  491. {
  492. failFalg = true;
  493. }
  494. }
  495. if (!string.IsNullOrEmpty(task.FailAddress2))
  496. {
  497. List<CcsTagValue> FailCallbackTagValues = tagValues.Where(o => o.Address == task.FailAddress2 && o.TagValue == task.CallbackFailValue2).ToList();
  498. if (FailCallbackTagValues != null && FailCallbackTagValues.Count > 0)
  499. {
  500. failFalg = true;
  501. }
  502. }
  503. if (!string.IsNullOrEmpty(task.FailAddress3))
  504. {
  505. List<CcsTagValue> FailCallbackTagValues = tagValues.Where(o => o.Address == task.FailAddress3 && o.TagValue == task.CallbackFailValue3).ToList();
  506. if (FailCallbackTagValues != null && FailCallbackTagValues.Count > 0)
  507. {
  508. failFalg = true;
  509. }
  510. }
  511. if (failFalg)
  512. {
  513. CallBackRequestData requestData = new CallBackRequestData();
  514. requestData.taskId = long.Parse(task.TaskId);
  515. requestData.taskNodeId = long.Parse(task.TaskNodeId);
  516. requestData.code = "0";
  517. requestData.msg = "操作失败";
  518. var result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, ecsUrlContext, requestData, null);
  519. if (result.IsSuccess)
  520. {
  521. task.State = false;
  522. task.UpdateTime = DateTime.Now;
  523. await _taskCallbackService.CreateOrUpdateAndCache(task);
  524. message = task.OperateName + "==>taskId:" + task.TaskId + ",taskNodeId:" + task.TaskNodeId + message + ",请求结果:" + result.Message + ";";
  525. Log.Instance.WriteLogAdd(message, LOG_TITLE_CALLBACK);
  526. }
  527. else
  528. {
  529. message = message + JsonConvert.SerializeObject(task) + ",请求失败! WebApi 返回结果" + ";";
  530. Log.Instance.WriteLogAdd("回调异常,请求接口失败" + JsonConvert.SerializeObject(task), LOG_TITLE_CALLBACK);
  531. }
  532. }
  533. }
  534. return string.IsNullOrEmpty(message) ? "无回调任务" : message;
  535. }
  536. catch (Exception ex)
  537. {
  538. Log.Instance.WriteLogAdd("回调异常===>>" + ex.Message, LOG_TITLE_CALLBACK);
  539. return "回调异常" + ex.Message;
  540. }
  541. }
  542. /// <summary>
  543. /// 打标机回调任务
  544. /// </summary>
  545. /// <returns></returns>
  546. public async Task<string> CallbackJob3()
  547. {
  548. List<TaskCallback> taskList = new List<TaskCallback>();
  549. var taskCallbackListData = await _redisService.Database.StringGetAsync(callback_redis_key);
  550. if (taskCallbackListData.IsNullOrEmpty)
  551. {
  552. taskList = await _taskCallbackService.GetAllList();
  553. }
  554. else
  555. {
  556. taskList = JsonConvert.DeserializeObject<List<TaskCallback>>(taskCallbackListData);
  557. }
  558. List<Device> deviceList = await getDeviceList();
  559. //在线设备
  560. taskList = taskList.Where(x => x.OperateType.Equals(ActionTypeEnum.StartLabelMachine.ToString()) && x.State).ToList();
  561. TaskCallback task = taskList.Where(key => deviceList.Any(device => device.Ip == key.IP)).FirstOrDefault();
  562. if (task == null)
  563. {
  564. return "无回调任务";
  565. }
  566. string message = "";
  567. try
  568. {
  569. DateTime currentTime = DateTime.Now;
  570. CcsTagValue tagValueQuery = new CcsTagValue();
  571. tagValueQuery.Ip = task.IP;
  572. List<CcsTagValue> tagValues = _ccsTagValueService.GetList(tagValueQuery).ToList();
  573. CcsTagValue callBacktagValue = tagValues.Where(o => o.Address == task.Address).FirstOrDefault();
  574. CcsTagValue callBacktagValue2 = tagValues.Where(o => o.Address == task.Address2).FirstOrDefault();
  575. if (callBacktagValue != null && callBacktagValue2 != null && callBacktagValue.TagValue == task.CallbackValue && callBacktagValue2.TagValue == task.CallbackValue2)
  576. {
  577. CallBackRequestData requestData = new CallBackRequestData();
  578. requestData.taskId = long.Parse(task.TaskId);
  579. requestData.taskNodeId = long.Parse(task.TaskNodeId);
  580. var result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, ecsUrlContext, requestData, null);
  581. ResponseECSCallbackData responseECSCallback = JsonConvert.DeserializeObject<ResponseECSCallbackData>(result.Message);
  582. if (result.IsSuccess && responseECSCallback.code == 0)
  583. {
  584. /*if (!string.IsNullOrEmpty(task.SuccessResetAddress))
  585. {
  586. Plc s7 = DevicePlcS7.S7(task.IP, ProtocalTypeEnum.S7_1500.ToString());
  587. if (s7.IsConnected == true)
  588. {
  589. string ResetAddress = ToolUtils.AddressConvertDBW(task.SuccessResetAddress);
  590. //short mc = 0;
  591. short mc = (short)int.Parse(task.SuccessResetValue);
  592. s7.Write(ResetAddress, mc);
  593. s7.Close();
  594. }
  595. }*/
  596. task.State = false;
  597. task.UpdateTime = DateTime.Now;
  598. await _taskCallbackService.CreateOrUpdateAndCache(task);
  599. message = task.OperateName + "==>taskId:" + task.TaskId + ",taskNodeId:" + task.TaskNodeId + ",请求结果:" + result.Message + ";";
  600. Log.Instance.WriteLogAdd(message, LOG_TITLE_CALLBACK);
  601. }
  602. else
  603. {
  604. message = message + JsonConvert.SerializeObject(task) + ",请求失败! WebApi 返回结果" + ";";
  605. Log.Instance.WriteLogAdd("回调异常,请求接口失败" + JsonConvert.SerializeObject(task), LOG_TITLE_CALLBACK);
  606. }
  607. }
  608. //回调检测到失败,回调通知ecs
  609. if (!string.IsNullOrEmpty(task.FailAddress) || !string.IsNullOrEmpty(task.FailAddress2) || !string.IsNullOrEmpty(task.FailAddress3))
  610. {
  611. bool failFalg = false;
  612. if (!string.IsNullOrEmpty(task.FailAddress))
  613. {
  614. List<CcsTagValue> FailCallbackTagValues = tagValues.Where(o => o.Address == task.FailAddress && o.TagValue == task.CallbackFailValue).ToList();
  615. if (FailCallbackTagValues != null && FailCallbackTagValues.Count > 0)
  616. {
  617. failFalg = true;
  618. }
  619. }
  620. if (!string.IsNullOrEmpty(task.FailAddress2))
  621. {
  622. List<CcsTagValue> FailCallbackTagValues = tagValues.Where(o => o.Address == task.FailAddress2 && o.TagValue == task.CallbackFailValue2).ToList();
  623. if (FailCallbackTagValues != null && FailCallbackTagValues.Count > 0)
  624. {
  625. failFalg = true;
  626. }
  627. }
  628. if (!string.IsNullOrEmpty(task.FailAddress3))
  629. {
  630. List<CcsTagValue> FailCallbackTagValues = tagValues.Where(o => o.Address == task.FailAddress3 && o.TagValue == task.CallbackFailValue3).ToList();
  631. if (FailCallbackTagValues != null && FailCallbackTagValues.Count > 0)
  632. {
  633. failFalg = true;
  634. }
  635. }
  636. if (failFalg)
  637. {
  638. CallBackRequestData requestData = new CallBackRequestData();
  639. requestData.taskId = long.Parse(task.TaskId);
  640. requestData.taskNodeId = long.Parse(task.TaskNodeId);
  641. requestData.code = "0";
  642. requestData.msg = "操作失败";
  643. var result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, ecsUrlContext, requestData, null);
  644. ResponseECSCallbackData responseECSCallback = JsonConvert.DeserializeObject<ResponseECSCallbackData>(result.Message);
  645. if (result.IsSuccess && responseECSCallback.code == 0)
  646. {
  647. task.State = false;
  648. task.UpdateTime = DateTime.Now;
  649. await _taskCallbackService.CreateOrUpdateAndCache(task);
  650. message = task.OperateName + "==>taskId:" + task.TaskId + ",taskNodeId:" + task.TaskNodeId + message + ",请求结果:" + result.Message + ";";
  651. Log.Instance.WriteLogAdd(message, LOG_TITLE_CALLBACK);
  652. }
  653. else
  654. {
  655. message = message + JsonConvert.SerializeObject(task) + ",请求失败! WebApi 返回结果" + ";";
  656. Log.Instance.WriteLogAdd("回调异常,请求接口失败" + JsonConvert.SerializeObject(result), LOG_TITLE_CALLBACK);
  657. }
  658. }
  659. }
  660. return string.IsNullOrEmpty(message) ? "无回调任务" : message;
  661. }
  662. catch (Exception ex)
  663. {
  664. Log.Instance.WriteLogAdd("回调异常===>>" + ex.Message, LOG_TITLE_CALLBACK);
  665. return "回调异常" + ex.Message;
  666. }
  667. }
  668. /// <summary>
  669. /// 启动机床程序回调任务
  670. /// </summary>
  671. /// <returns></returns>
  672. public async Task<string> CallbackJob4()
  673. {
  674. List<TaskCallback> taskList = new List<TaskCallback>();
  675. var taskCallbackListData = await _redisService.Database.StringGetAsync(callback_redis_key);
  676. if (taskCallbackListData.IsNullOrEmpty)
  677. {
  678. taskList = await _taskCallbackService.GetAllList();
  679. }
  680. else
  681. {
  682. taskList = JsonConvert.DeserializeObject<List<TaskCallback>>(taskCallbackListData);
  683. }
  684. List<Device> deviceList = await getDeviceList();
  685. //在线设备
  686. taskList = taskList.Where(x => x.OperateType.Equals(ActionTypeEnum.StartNCProgram.ToString()) && x.State).ToList();
  687. TaskCallback task = taskList.Where(key => deviceList.Any(device => device.Ip == key.IP)).FirstOrDefault();
  688. if (task == null)
  689. {
  690. return "无回调任务";
  691. }
  692. string message = "";
  693. try
  694. {
  695. DateTime currentTime = DateTime.Now;
  696. CcsTagValue tagValueQuery = new CcsTagValue();
  697. tagValueQuery.Ip = task.IP;
  698. //tagValueQuery.Address = task.Address;
  699. List<CcsTagValue> tagValues = _ccsTagValueService.GetList(tagValueQuery);
  700. CcsTagValue tagValue = tagValues.Where(o => o.Address == task.Address).FirstOrDefault();
  701. if (tagValue != null && tagValue.TagValue == task.CallbackValue)
  702. {
  703. CallBackRequestData requestData = new CallBackRequestData();
  704. requestData.taskId = long.Parse(task.TaskId);
  705. requestData.taskNodeId = long.Parse(task.TaskNodeId);
  706. var result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, ecsUrlContext, requestData, null);
  707. ResponseECSCallbackData responseECSCallback = JsonConvert.DeserializeObject<ResponseECSCallbackData>(result.Message);
  708. if (result.IsSuccess && responseECSCallback.code == 0)
  709. {
  710. task.State = false;
  711. task.UpdateTime = DateTime.Now;
  712. await _taskCallbackService.CreateOrUpdateAndCache(task);
  713. message = task.OperateName + "==>taskId:" + task.TaskId + ",taskNodeId:" + task.TaskNodeId + ",请求结果:" + result.Message + ";";
  714. Log.Instance.WriteLogAdd(message, LOG_TITLE_CALLBACK);
  715. }
  716. else
  717. {
  718. message = message + JsonConvert.SerializeObject(task) + ",请求失败! WebApi 返回结果" + ";";
  719. Log.Instance.WriteLogAdd("回调异常,请求接口失败" + JsonConvert.SerializeObject(result), LOG_TITLE_CALLBACK);
  720. }
  721. }
  722. //回调检测到失败,回调通知ecs
  723. if (!string.IsNullOrEmpty(task.FailAddress) || !string.IsNullOrEmpty(task.FailAddress2) || !string.IsNullOrEmpty(task.FailAddress3))
  724. {
  725. bool failFalg = false;
  726. if (!string.IsNullOrEmpty(task.FailAddress))
  727. {
  728. List<CcsTagValue> FailCallbackTagValues = tagValues.Where(o => o.Address == task.FailAddress && o.TagValue == task.CallbackFailValue).ToList();
  729. if (FailCallbackTagValues != null && FailCallbackTagValues.Count > 0)
  730. {
  731. failFalg = true;
  732. }
  733. }
  734. if (!string.IsNullOrEmpty(task.FailAddress2))
  735. {
  736. List<CcsTagValue> FailCallbackTagValues = tagValues.Where(o => o.Address == task.FailAddress2 && o.TagValue == task.CallbackFailValue2).ToList();
  737. if (FailCallbackTagValues != null && FailCallbackTagValues.Count > 0)
  738. {
  739. failFalg = true;
  740. }
  741. }
  742. if (!string.IsNullOrEmpty(task.FailAddress3))
  743. {
  744. List<CcsTagValue> FailCallbackTagValues = tagValues.Where(o => o.Address == task.FailAddress3 && o.TagValue == task.CallbackFailValue3).ToList();
  745. if (FailCallbackTagValues != null && FailCallbackTagValues.Count > 0)
  746. {
  747. failFalg = true;
  748. }
  749. }
  750. if (failFalg)
  751. {
  752. CallBackRequestData requestData = new CallBackRequestData();
  753. requestData.taskId = long.Parse(task.TaskId);
  754. requestData.taskNodeId = long.Parse(task.TaskNodeId);
  755. requestData.code = "0";
  756. requestData.msg = "操作失败";
  757. var result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, ecsUrlContext, requestData, null);
  758. ResponseECSCallbackData responseECSCallback = JsonConvert.DeserializeObject<ResponseECSCallbackData>(result.Message);
  759. if (result.IsSuccess && responseECSCallback.code == 0)
  760. {
  761. task.State = false;
  762. task.UpdateTime = DateTime.Now;
  763. await _taskCallbackService.CreateOrUpdateAndCache(task);
  764. message = task.OperateName + "==>taskId:" + task.TaskId + ",taskNodeId:" + task.TaskNodeId + message + ",请求结果:" + result.Message + ";";
  765. Log.Instance.WriteLogAdd(message, LOG_TITLE_CALLBACK);
  766. }
  767. else
  768. {
  769. message = message + JsonConvert.SerializeObject(task) + ",请求失败! WebApi 返回结果" + ";";
  770. Log.Instance.WriteLogAdd("回调异常,请求接口失败" + JsonConvert.SerializeObject(result), LOG_TITLE_CALLBACK);
  771. }
  772. }
  773. }
  774. return string.IsNullOrEmpty(message) ? "无回调任务" : message;
  775. }
  776. catch (Exception ex)
  777. {
  778. Log.Instance.WriteLogAdd("回调异常===>>" + ex.Message, LOG_TITLE_CALLBACK);
  779. return "回调异常" + ex.Message;
  780. }
  781. }
  782. /// <summary>
  783. /// 启动清洗机回调任务
  784. /// </summary>
  785. /// <returns></returns>
  786. public async Task<string> CallbackJob5()
  787. {
  788. List<TaskCallback> taskList = new List<TaskCallback>();
  789. var taskCallbackListData = await _redisService.Database.StringGetAsync(callback_redis_key);
  790. if (taskCallbackListData.IsNullOrEmpty)
  791. {
  792. taskList = await _taskCallbackService.GetAllList();
  793. }
  794. else
  795. {
  796. taskList = JsonConvert.DeserializeObject<List<TaskCallback>>(taskCallbackListData);
  797. }
  798. List<Device> deviceList = await getDeviceList();
  799. //在线设备
  800. taskList = taskList.Where(x => x.OperateType.Equals(ActionTypeEnum.StartCleanMachine.ToString()) && x.State).ToList();
  801. TaskCallback task = taskList.Where(key => deviceList.Any(device => device.Ip == key.IP)).FirstOrDefault();
  802. if (task == null)
  803. {
  804. return "无回调任务";
  805. }
  806. string message = "";
  807. try
  808. {
  809. DateTime currentTime = DateTime.Now;
  810. CcsTagValue tagValueQuery = new CcsTagValue();
  811. tagValueQuery.Ip = task.IP;
  812. //tagValueQuery.Address = task.Address;
  813. List<CcsTagValue> tagValues = _ccsTagValueService.GetList(tagValueQuery).ToList();
  814. CcsTagValue tagValue = tagValues.Where(o => o.Address == task.Address).FirstOrDefault();
  815. if (tagValue != null && tagValue.TagValue == task.CallbackValue)
  816. {
  817. CallBackRequestData requestData = new CallBackRequestData();
  818. requestData.taskId = long.Parse(task.TaskId);
  819. requestData.taskNodeId = long.Parse(task.TaskNodeId);
  820. var result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, ecsUrlContext, requestData, null);
  821. ResponseECSCallbackData responseECSCallback = JsonConvert.DeserializeObject<ResponseECSCallbackData>(result.Message);
  822. if (result.IsSuccess && responseECSCallback.code == 0)
  823. {
  824. task.State = false;
  825. task.UpdateTime = DateTime.Now;
  826. await _taskCallbackService.CreateOrUpdateAndCache(task);
  827. message = task.OperateName + "==>taskId:" + task.TaskId + ",taskNodeId:" + task.TaskNodeId + ",请求结果:" + result.Message + ";";
  828. Log.Instance.WriteLogAdd(message, LOG_TITLE_CALLBACK);
  829. }
  830. else
  831. {
  832. message = message + JsonConvert.SerializeObject(task) + ",请求失败! WebApi 返回结果" + ";";
  833. Log.Instance.WriteLogAdd("回调异常,请求接口失败" + JsonConvert.SerializeObject(result), LOG_TITLE_CALLBACK);
  834. }
  835. }
  836. //回调检测到失败,回调通知ecs
  837. if (!string.IsNullOrEmpty(task.FailAddress) || !string.IsNullOrEmpty(task.FailAddress2) || !string.IsNullOrEmpty(task.FailAddress3))
  838. {
  839. bool failFalg = false;
  840. if (!string.IsNullOrEmpty(task.FailAddress))
  841. {
  842. List<CcsTagValue> FailCallbackTagValues = tagValues.Where(o => o.Address == task.FailAddress && o.TagValue == task.CallbackFailValue).ToList();
  843. if (FailCallbackTagValues != null && FailCallbackTagValues.Count > 0)
  844. {
  845. failFalg = true;
  846. }
  847. }
  848. if (!string.IsNullOrEmpty(task.FailAddress2))
  849. {
  850. List<CcsTagValue> FailCallbackTagValues = tagValues.Where(o => o.Address == task.FailAddress2 && o.TagValue == task.CallbackFailValue2).ToList();
  851. if (FailCallbackTagValues != null && FailCallbackTagValues.Count > 0)
  852. {
  853. failFalg = true;
  854. }
  855. }
  856. if (!string.IsNullOrEmpty(task.FailAddress3))
  857. {
  858. List<CcsTagValue> FailCallbackTagValues = tagValues.Where(o => o.Address == task.FailAddress3 && o.TagValue == task.CallbackFailValue3).ToList();
  859. if (FailCallbackTagValues != null && FailCallbackTagValues.Count > 0)
  860. {
  861. failFalg = true;
  862. }
  863. }
  864. if (failFalg)
  865. {
  866. CallBackRequestData requestData = new CallBackRequestData();
  867. requestData.taskId = long.Parse(task.TaskId);
  868. requestData.taskNodeId = long.Parse(task.TaskNodeId);
  869. requestData.code = "0";
  870. requestData.msg = "操作失败";
  871. var result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, ecsUrlContext, requestData, null);
  872. ResponseECSCallbackData responseECSCallback = JsonConvert.DeserializeObject<ResponseECSCallbackData>(result.Message);
  873. if (result.IsSuccess && responseECSCallback.code == 0)
  874. {
  875. task.State = false;
  876. task.UpdateTime = DateTime.Now;
  877. await _taskCallbackService.CreateOrUpdateAndCache(task);
  878. message = task.OperateName + "==>taskId:" + task.TaskId + ",taskNodeId:" + task.TaskNodeId + message + ",请求结果:" + result.Message + ";";
  879. Log.Instance.WriteLogAdd(message, LOG_TITLE_CALLBACK);
  880. }
  881. else
  882. {
  883. message = message + JsonConvert.SerializeObject(task) + ",请求失败! WebApi 返回结果" + ";";
  884. Log.Instance.WriteLogAdd("回调异常,请求接口失败" + JsonConvert.SerializeObject(result), LOG_TITLE_CALLBACK);
  885. }
  886. }
  887. }
  888. return string.IsNullOrEmpty(message) ? "无回调任务" : message;
  889. }
  890. catch (Exception ex)
  891. {
  892. Log.Instance.WriteLogAdd("回调异常===>>" + ex.Message, LOG_TITLE_CALLBACK);
  893. return "回调异常" + ex.Message;
  894. }
  895. }
  896. /// <summary>
  897. /// 放三坐标回调任务
  898. /// </summary>
  899. /// <returns></returns>
  900. public async Task<string> CallbackJob6()
  901. {
  902. List<TaskCallback> taskList = new List<TaskCallback>();
  903. var taskCallbackListData = await _redisService.Database.StringGetAsync(callback_redis_key);
  904. if (taskCallbackListData.IsNullOrEmpty)
  905. {
  906. taskList = await _taskCallbackService.GetAllList();
  907. }
  908. else
  909. {
  910. taskList = JsonConvert.DeserializeObject<List<TaskCallback>>(taskCallbackListData);
  911. }
  912. List<Device> deviceList = await getDeviceList();
  913. //在线设备
  914. taskList = taskList.Where(x => x.OperateType.Equals(ActionTypeEnum.SendThreeCoordinates.ToString()) && x.State).ToList();
  915. TaskCallback task = taskList.Where(key => deviceList.Any(device => device.Ip == key.IP)).FirstOrDefault();
  916. if (task == null)
  917. {
  918. return "无回调任务";
  919. }
  920. string message = "";
  921. try
  922. {
  923. DateTime currentTime = DateTime.Now;
  924. CcsTagValue tagValueQuery = new CcsTagValue();
  925. tagValueQuery.Ip = task.IP;
  926. List<CcsTagValue> tagValues = _ccsTagValueService.GetList(tagValueQuery).ToList();
  927. CcsTagValue tagValue = tagValues.Where(o => o.Address == task.Address).FirstOrDefault();
  928. //点位放在描述里判断左中右
  929. string pos = task.Description;
  930. string posValue = "";
  931. int key = 0;
  932. if (pos == "L")
  933. {
  934. posValue = EnumHelper.GetDescription(ThreeCoordinatesFinishedEnum.L);
  935. key = (int)ThreeCoordinatesPosEnum.L;
  936. }
  937. else if (pos == "M")
  938. {
  939. posValue = EnumHelper.GetDescription(ThreeCoordinatesFinishedEnum.M);
  940. key = (int)ThreeCoordinatesPosEnum.M;
  941. }
  942. else if (pos == "R")
  943. {
  944. posValue = EnumHelper.GetDescription(ThreeCoordinatesFinishedEnum.R);
  945. key = (int)ThreeCoordinatesPosEnum.R;
  946. }
  947. CcsTagValue tagValue2 = tagValues.Where(o => o.Address == posValue && o.TagValue != "0").FirstOrDefault();
  948. if (tagValue != null && tagValue2 != null && (tagValue.TagValue == task.CallbackValue))
  949. {
  950. CallBackThreeCoordinatesRequestData requestData = new CallBackThreeCoordinatesRequestData();
  951. requestData.taskId = long.Parse(task.TaskId);
  952. requestData.taskNodeId = long.Parse(task.TaskNodeId);
  953. //查询三坐标已测量工件id和工位
  954. SiemensS7Net s7 = DevicePlcS7.SiemensS7(task.IP);
  955. HslCommunication.OperateResult ConnectionResult = s7.ConnectServer();
  956. if (!ConnectionResult.IsSuccess)
  957. {
  958. s7.ConnectClose();
  959. Log.Instance.WriteLogAdd(ActionTypeEnum.SendThreeCoordinates + "放三坐标异常===>>" + "PLC连接不上",
  960. EnumHelper.GetDescription(ActionTypeEnum.SendThreeCoordinates));
  961. }
  962. /* CcsActionAddress actionAddressQuery = new CcsActionAddress();
  963. actionAddressQuery.Type = "CALLBACK_CHECK_COOR";
  964. List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);
  965. CcsActionAddress freeActionAdress = new CcsActionAddress();
  966. //查询空闲位置
  967. List<CcsActionAddress> CcsActionAddressChecks = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CHECK.ToString()).ToList();
  968. foreach (CcsActionAddress actionAddress in CcsActionAddressChecks)
  969. {
  970. if (!string.IsNullOrEmpty(actionAddress.Address) && !string.IsNullOrEmpty(actionAddress.Value))
  971. {
  972. var operateResult = s7.ReadInt16(actionAddress.Address);
  973. if (operateResult.ToString() == actionAddress.Value)
  974. {
  975. freeActionAdress = actionAddress;
  976. break;
  977. }
  978. }
  979. }
  980. //判断是否可取滑台
  981. if (freeActionAdress != null)
  982. {*/
  983. //根据sort顺序,查询左中右可取位置,写入地址列表
  984. CcsActionAddress actionAddressGet = new CcsActionAddress();
  985. actionAddressGet.Type = "CALLBACK_GET_COOR";
  986. actionAddressGet.Sort = key;
  987. List<CcsActionAddress> GetCcsActionAddresses = _ccsActionAddressService.GetList(actionAddressGet);
  988. //赋值测量结果
  989. requestData.result = tagValue2.TagValue;
  990. //根据工件id确认哪个位置已测量,赋值工位id
  991. string srcWorkId = task.CallbackFailValue3; //原工件id
  992. var workIdResult = s7.Read(EnumHelper.GetDescription(ThreeCoordinatesFinishedWrokIdEnum.L), 40);
  993. if (ToolUtils.ReturnStringByBytes(workIdResult.Content) == srcWorkId)
  994. {
  995. requestData.stationId = "L";
  996. }
  997. if (string.IsNullOrEmpty(requestData.stationId))
  998. {
  999. workIdResult = s7.Read(EnumHelper.GetDescription(ThreeCoordinatesFinishedWrokIdEnum.M), 40);
  1000. if (ToolUtils.ReturnStringByBytes(workIdResult.Content) == srcWorkId)
  1001. {
  1002. requestData.stationId = "M";
  1003. }
  1004. }
  1005. if (string.IsNullOrEmpty(requestData.stationId))
  1006. {
  1007. workIdResult = s7.Read(EnumHelper.GetDescription(ThreeCoordinatesFinishedWrokIdEnum.R),40);
  1008. if (ToolUtils.ReturnStringByBytes(workIdResult.Content) == srcWorkId)
  1009. {
  1010. requestData.stationId = "R";
  1011. }
  1012. }
  1013. foreach (CcsActionAddress actionAddress in GetCcsActionAddresses)
  1014. {
  1015. if (!string.IsNullOrEmpty(actionAddress.Address))
  1016. {
  1017. if (actionAddress.Value == "workId")
  1018. {
  1019. var operateResult = s7.Read(actionAddress.Address, 40) ;
  1020. requestData.workId = ToolUtils.ReturnStringByBytes(operateResult.Content);
  1021. }
  1022. else if (actionAddress.Value == "procedureNo")
  1023. {
  1024. var operateResult = s7.Read(actionAddress.Address,40);
  1025. requestData.procedureNo = ToolUtils.ReturnStringByBytes(operateResult.Content);
  1026. }
  1027. else if (actionAddress.Value == "workProgramName")
  1028. {
  1029. var operateResult = s7.Read(actionAddress.Address,40);
  1030. requestData.workProgramName = ToolUtils.ReturnStringByBytes(operateResult.Content);
  1031. }
  1032. }
  1033. }
  1034. s7.ConnectClose();
  1035. var result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, ecsUrlContext, requestData, null);
  1036. ResponseECSCallbackData responseECSCallback = JsonConvert.DeserializeObject<ResponseECSCallbackData>(result.Message);
  1037. if (result.IsSuccess && responseECSCallback.code == 0)
  1038. {
  1039. task.State = false;
  1040. task.UpdateTime = DateTime.Now;
  1041. await _taskCallbackService.CreateOrUpdateAndCache(task);
  1042. message = task.OperateName + "==>taskId:" + task.TaskId + ",taskNodeId:" + task.TaskNodeId + ",请求结果:" + result.Message + ";";
  1043. Log.Instance.WriteLogAdd(message, LOG_TITLE_CALLBACK);
  1044. }
  1045. else
  1046. {
  1047. message = message + JsonConvert.SerializeObject(task) + ",请求失败! WebApi 返回结果" + ";";
  1048. Log.Instance.WriteLogAdd("回调异常,请求接口失败" + JsonConvert.SerializeObject(result), LOG_TITLE_CALLBACK);
  1049. }
  1050. }
  1051. //回调检测到失败,回调通知ecs
  1052. if (!string.IsNullOrEmpty(task.FailAddress) || !string.IsNullOrEmpty(task.FailAddress2) || !string.IsNullOrEmpty(task.FailAddress3))
  1053. {
  1054. bool failFalg = false;
  1055. if (!string.IsNullOrEmpty(task.FailAddress))
  1056. {
  1057. List<CcsTagValue> FailCallbackTagValues = tagValues.Where(o => o.Address == task.FailAddress && o.TagValue == task.CallbackFailValue).ToList();
  1058. if (FailCallbackTagValues != null && FailCallbackTagValues.Count > 0)
  1059. {
  1060. failFalg = true;
  1061. }
  1062. }
  1063. if (!string.IsNullOrEmpty(task.FailAddress2))
  1064. {
  1065. List<CcsTagValue> FailCallbackTagValues = tagValues.Where(o => o.Address == task.FailAddress2 && o.TagValue == task.CallbackFailValue2).ToList();
  1066. if (FailCallbackTagValues != null && FailCallbackTagValues.Count > 0)
  1067. {
  1068. failFalg = true;
  1069. }
  1070. }
  1071. if (!string.IsNullOrEmpty(task.FailAddress3))
  1072. {
  1073. List<CcsTagValue> FailCallbackTagValues = tagValues.Where(o => o.Address == task.FailAddress3 && o.TagValue == task.CallbackFailValue3).ToList();
  1074. if (FailCallbackTagValues != null && FailCallbackTagValues.Count > 0)
  1075. {
  1076. failFalg = true;
  1077. }
  1078. }
  1079. if (failFalg)
  1080. {
  1081. CallBackRequestData requestData = new CallBackRequestData();
  1082. requestData.taskId = long.Parse(task.TaskId);
  1083. requestData.taskNodeId = long.Parse(task.TaskNodeId);
  1084. requestData.code = "0";
  1085. requestData.msg = "操作失败";
  1086. var result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, ecsUrlContext, requestData, null);
  1087. ResponseECSCallbackData responseECSCallback = JsonConvert.DeserializeObject<ResponseECSCallbackData>(result.Message);
  1088. if (result.IsSuccess && responseECSCallback.code == 0)
  1089. {
  1090. task.State = false;
  1091. task.UpdateTime = DateTime.Now;
  1092. await _taskCallbackService.CreateOrUpdateAndCache(task);
  1093. message = task.OperateName + "==>taskId:" + task.TaskId + ",taskNodeId:" + task.TaskNodeId + message + ",请求结果:" + result.Message + ";";
  1094. Log.Instance.WriteLogAdd(message, LOG_TITLE_CALLBACK);
  1095. }
  1096. else
  1097. {
  1098. message = message + JsonConvert.SerializeObject(task) + ",请求失败! WebApi 返回结果" + ";";
  1099. Log.Instance.WriteLogAdd("回调异常,请求接口失败" + JsonConvert.SerializeObject(result), LOG_TITLE_CALLBACK);
  1100. }
  1101. }
  1102. }
  1103. return string.IsNullOrEmpty(message) ? "无回调任务" : message;
  1104. }
  1105. catch (Exception ex)
  1106. {
  1107. Log.Instance.WriteLogAdd("回调异常===>>" + ex.Message, LOG_TITLE_CALLBACK);
  1108. return "回调异常" + ex.Message;
  1109. }
  1110. }
  1111. /// <summary>
  1112. /// 监控设备状态
  1113. /// </summary>
  1114. /// <returns></returns>
  1115. public async Task<string> MonitorEquipmentStatusJob()
  1116. {
  1117. try
  1118. {
  1119. string message = "MonitorEquipmentStatusJob调度成功";
  1120. List<Device> devices = await getDeviceList();
  1121. //在线设备
  1122. //ftp不监控
  1123. devices = devices.Where(x => !x.ProtocolType.Equals(ProtocalTypeEnum.FTP.ToString()) && x.State).ToList();
  1124. CcsTagValue tagQuery = new CcsTagValue();
  1125. List<CcsTagValue> tagValues = _ccsTagValueService.GetList(tagQuery);
  1126. List<EquipmentMonitor> equipmentMonitors = new List<EquipmentMonitor>();
  1127. string redis_key = "IMCS_CCS:MonitorEquipmentStatusJob";
  1128. var data = await _redisService.Database.StringGetAsync(redis_key);
  1129. if (data.IsNullOrEmpty)
  1130. {
  1131. equipmentMonitors = await _equipmentMonitorService.GetList();
  1132. //首次设置redis
  1133. if (tagValues != null && tagValues.Count > 0)
  1134. {
  1135. await _redisService.Database.StringSetAsync(redis_key, JsonConvert.SerializeObject(equipmentMonitors));
  1136. }
  1137. }
  1138. else
  1139. {
  1140. equipmentMonitors = JsonConvert.DeserializeObject<List<EquipmentMonitor>>(data);
  1141. }
  1142. //变化的设备
  1143. List<EquipmentMonitor> changeEquipmentMonitors = new List<EquipmentMonitor>();
  1144. foreach (EquipmentMonitor equipment in equipmentMonitors)
  1145. {
  1146. Device device = devices.Where(x => x.Ip.Equals(equipment.IP)).FirstOrDefault();
  1147. if (device == null)
  1148. {
  1149. if (equipment.Status != "离线")
  1150. {
  1151. equipment.Status = "离线";
  1152. changeEquipmentMonitors.Add(equipment);
  1153. }
  1154. continue;
  1155. }
  1156. else if (equipment.Name == "机械手")
  1157. {
  1158. CcsTagValue ccsTagValue = tagValues.Where(x => x.Ip.Equals(equipment.IP) && x.Address.Equals(equipment.Address)).FirstOrDefault();
  1159. if (ccsTagValue != null)
  1160. {
  1161. if (ccsTagValue.TagValue == "3")
  1162. {
  1163. if (equipment.Status != "报警")
  1164. {
  1165. equipment.Status = "报警";
  1166. changeEquipmentMonitors.Add(equipment);
  1167. }
  1168. continue;
  1169. }
  1170. }
  1171. CcsTagValue ccsTagValue2 = tagValues.Where(x => x.Ip.Equals(equipment.IP) && x.Address.Equals(equipment.Address2)).FirstOrDefault();
  1172. if (ccsTagValue2 != null)
  1173. {
  1174. if (ccsTagValue2.TagValue == "9")
  1175. {
  1176. if (equipment.Status != "报警")
  1177. {
  1178. equipment.Status = "报警";
  1179. changeEquipmentMonitors.Add(equipment);
  1180. }
  1181. continue;
  1182. }
  1183. }
  1184. if (ccsTagValue2.TagValue == "0" || ccsTagValue2.TagValue == "3" || ccsTagValue2.TagValue == "6" || ccsTagValue2.TagValue == "8")
  1185. {
  1186. if (equipment.Status != "空闲")
  1187. {
  1188. equipment.Status = "空闲";
  1189. changeEquipmentMonitors.Add(equipment);
  1190. }
  1191. continue;
  1192. }
  1193. if (equipment.Status != "生产中")
  1194. {
  1195. equipment.Status = "生产中";
  1196. changeEquipmentMonitors.Add(equipment);
  1197. }
  1198. }
  1199. else
  1200. {
  1201. if (equipment.Status != "在线")
  1202. {
  1203. equipment.Status = "在线";
  1204. changeEquipmentMonitors.Add(equipment);
  1205. }
  1206. }
  1207. }
  1208. //变化的修改 并且更新缓存
  1209. if (changeEquipmentMonitors.Count > 0)
  1210. {
  1211. List<ProductionStatus> productionStatusList = new List<ProductionStatus>();
  1212. foreach (EquipmentMonitor changeEquipment in changeEquipmentMonitors)
  1213. {
  1214. ProductionStatus productionStatus = new ProductionStatus();
  1215. productionStatus.id = changeEquipment.Id.ToString();
  1216. productionStatus.onlineStatus = syncStatusMap[changeEquipment.Status].ToString();
  1217. //equipment.Status == "离线" ? "0" : "1";
  1218. //productionStatus.alertMsg = equipment.AlertMsg;
  1219. if (productionStatus.onlineStatus != "3" && !string.IsNullOrEmpty(changeEquipment.Type))
  1220. {
  1221. if (changeEquipment.Type == "HEIDEHAIN")
  1222. {
  1223. RequestHeidhData hdhReq = new RequestHeidhData();
  1224. Device device = devices.Where(x => x.Ip.Equals(changeEquipment.IP)).FirstOrDefault();
  1225. hdhReq.ServerUrl = device.ServerUrl;
  1226. hdhReq.MachineName = device.UserName;
  1227. hdhReq.Type = OpcUaActionTypeEnum.Connect.ToString();
  1228. var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, hdhUrlContext, hdhReq, null);
  1229. if (Result.IsSuccess)
  1230. {
  1231. ResponseHeidhData responseData = JsonConvert.DeserializeObject<ResponseHeidhData>(Result.Message);
  1232. if (!string.IsNullOrEmpty(responseData.errorsInfo))
  1233. {
  1234. productionStatus.alertMsg = responseData.errorsInfo;
  1235. }
  1236. }
  1237. }
  1238. else if (changeEquipment.Type == "FANUC")
  1239. {
  1240. Device device = devices.Where(x => x.Ip.Equals(changeEquipment.IP)).FirstOrDefault();
  1241. string Url = fanucUrlContext + "?ip=" + device.Ip + "&port=" + device.Port;
  1242. //调用发那科接口
  1243. var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Get, Url + "&fun=AlmInfo", null, null);
  1244. if (Result.IsSuccess)
  1245. {
  1246. ResponseFanucData fncReq = new ResponseFanucData();
  1247. fncReq = JsonConvert.DeserializeObject<ResponseFanucData>(Result.Message);
  1248. List<AlmInfo> AlmMsg = fncReq.AlmMsg;
  1249. if (AlmMsg != null && AlmMsg.Count > 0)
  1250. {
  1251. var msgs = from o in AlmMsg select o.msg;
  1252. productionStatus.alertMsg = string.Join(",", msgs.ToArray());
  1253. }
  1254. }
  1255. }
  1256. }
  1257. else
  1258. {
  1259. //获取机械手报警信息
  1260. CcsTagValue plcWarnValue = tagValues.Where(x => x.Ip.Equals(changeEquipment.IP) && x.Address.Equals("DB200.34")).FirstOrDefault();
  1261. if (plcWarnValue != null)
  1262. {
  1263. ToolDto ccsDictionary = new ToolDto();
  1264. ccsDictionary.Type = "PlcWarnInfo";
  1265. List<ToolDto> dictList = await _dictionaryService.GetList(ccsDictionary);
  1266. if (dictList.Count > 0 && dictList[0] != null)
  1267. {
  1268. ToolDto dictObj = dictList.Where(x => x.Code.Equals(plcWarnValue.TagValue) && x.state).FirstOrDefault();
  1269. if (!string.IsNullOrEmpty(dictObj.DictValue.Trim()))
  1270. {
  1271. productionStatus.alertMsg = dictObj.DictValue.Trim();
  1272. }
  1273. }
  1274. }
  1275. }
  1276. productionStatusList.Add(productionStatus);
  1277. await _equipmentMonitorService.Update(changeEquipment);
  1278. }
  1279. await _redisService.Database.StringSetAsync(redis_key, JsonConvert.SerializeObject(equipmentMonitors));
  1280. //主动推送同步状态数据接口
  1281. RequestSynStatusData requestData = new RequestSynStatusData();
  1282. requestData.productionStatus = JsonConvert.SerializeObject(productionStatusList);
  1283. String synStatusUrl = ecsRootUrlContext + "/api/authority/synStatus/synProductionStatus";
  1284. var result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, synStatusUrl, requestData, null);
  1285. //解析回调数据结果
  1286. ResponseECSCallbackData responseECSCallback = JsonConvert.DeserializeObject<ResponseECSCallbackData>(result.Message);
  1287. if (responseECSCallback != null && responseECSCallback.code == 0)
  1288. {
  1289. Log.Instance.WriteLogAdd("同步设备状态成功", LOG_TITLE_CALLBACK);
  1290. }
  1291. else
  1292. {
  1293. Log.Instance.WriteLogAdd("同步设备状态操作失败:" + responseECSCallback.msg, LOG_TITLE_CALLBACK);
  1294. }
  1295. }
  1296. return message;
  1297. }
  1298. catch (Exception ex)
  1299. {
  1300. Log.Instance.WriteLogAdd("MonitorEquipmentStatusJob:" + ex.Message, LOG_TITLE_DEVICE);
  1301. return "MonitorEquipmentStatusJob : " + ex.Message;
  1302. }
  1303. }
  1304. /// <summary>
  1305. /// 监控设备状态
  1306. /// </summary>
  1307. /// <returns></returns>
  1308. public async Task<string> DeviceStatusJob()
  1309. {
  1310. try
  1311. {
  1312. string message = "";
  1313. List<Device> devices = await getDeviceList();
  1314. //在线设备
  1315. List<Device> changeDevices = new List<Device>();
  1316. //ftp不监控
  1317. devices = devices.Where(x => !x.ProtocolType.Equals(ProtocalTypeEnum.FTP.ToString())).ToList();
  1318. foreach (Device device in devices)
  1319. {
  1320. if (device.ProtocolType.Equals(ProtocalTypeEnum.S7_1500.ToString()))
  1321. {
  1322. try
  1323. {
  1324. Plc s7 = DevicePlcS7.S7(device.ServerUrl, ProtocalTypeEnum.S7_1500.ToString());
  1325. if (s7.IsConnected != true)
  1326. {
  1327. Device oldDevice = await _deviceService.GetDeviceById(device.Id);
  1328. if (oldDevice != null && oldDevice.State)
  1329. {
  1330. device.State = false;
  1331. await _deviceService.UpdateDevice(device);
  1332. changeDevices.Add(device);
  1333. }
  1334. s7.Close();
  1335. Log.Instance.WriteLogAdd("plc连接失败,或已离线", LOG_TITLE_DEVICE);
  1336. message = message + ",plc连接失败,或已离线,ip:" + device.Ip + ",协议类型:" + device.ProtocolType;
  1337. continue;
  1338. }
  1339. else
  1340. {
  1341. Device oldDevice = await _deviceService.GetDeviceById(device.Id);
  1342. if (oldDevice != null && !oldDevice.State)
  1343. {
  1344. oldDevice.State = true;
  1345. await _deviceService.UpdateDevice(oldDevice);
  1346. changeDevices.Add(device);
  1347. }
  1348. s7.Close();
  1349. Log.Instance.WriteLogAdd("plc连接失败,或已离线", LOG_TITLE_DEVICE);
  1350. message = message + ",plc连接成功,ip:" + device.Ip + ",协议类型:" + device.ProtocolType;
  1351. continue;
  1352. }
  1353. }
  1354. catch (Exception s7ex)
  1355. {
  1356. Device oldDevice = await _deviceService.GetDeviceById(device.Id);
  1357. if (oldDevice != null && oldDevice.State)
  1358. {
  1359. device.State = false;
  1360. await _deviceService.UpdateDevice(device);
  1361. changeDevices.Add(device);
  1362. }
  1363. Log.Instance.WriteLogAdd("plc连接失败,或已离线", LOG_TITLE_DEVICE);
  1364. message = message + ",plc连接失败,plc连不上" + s7ex.Message + ",ip:" + device.Ip + ",协议类型:" + device.ProtocolType;
  1365. }
  1366. }
  1367. else if (device.ProtocolType.Equals(ProtocalTypeEnum.OPCUA.ToString()))
  1368. {
  1369. try
  1370. {
  1371. //调用opcua是否连接接口
  1372. RequestOpcUaData opcUaReq = new RequestOpcUaData();
  1373. opcUaReq.ServerUrl = device.ServerUrl;
  1374. opcUaReq.UserName = device.UserName;
  1375. opcUaReq.Password = device.Password;
  1376. opcUaReq.Type = OpcUaActionTypeEnum.Connect.ToString();
  1377. var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, opcuacUrlContext, opcUaReq, null);
  1378. ResponseOpcUaData responseOpcUaData = JsonConvert.DeserializeObject<ResponseOpcUaData>(Result.Message);
  1379. if (!Result.IsSuccess || !responseOpcUaData.result)
  1380. {
  1381. device.State = false;
  1382. Device oldDevice = await _deviceService.GetDeviceById(device.Id);
  1383. if (oldDevice!= null && oldDevice.State)
  1384. {
  1385. await _deviceService.UpdateDevice(device);
  1386. changeDevices.Add(device);
  1387. }
  1388. Log.Instance.WriteLogAdd("OPCUA连接异常,或已离线,ip:" + device.Ip + ",协议类型:" + device.ProtocolType, LOG_TITLE_OPCUA);
  1389. message = message + ",OPCUA连接异常,或以离线,ip:" + device.Ip + ",协议类型:" + device.ProtocolType; ;
  1390. continue;
  1391. }
  1392. else
  1393. {
  1394. device.State = true;
  1395. await _deviceService.UpdateDevice(device);
  1396. changeDevices.Add(device);
  1397. Log.Instance.WriteLogAdd("OPCUA连接成功,ip:" + device.Ip + ",协议类型:" + device.ProtocolType, LOG_TITLE_DEVICE);
  1398. continue;
  1399. }
  1400. }
  1401. catch (Exception opcex)
  1402. {
  1403. Device oldDevice = await _deviceService.GetDeviceById(device.Id);
  1404. if (oldDevice != null && oldDevice.State)
  1405. {
  1406. device.State = false;
  1407. await _deviceService.UpdateDevice(device);
  1408. changeDevices.Add(device);
  1409. }
  1410. Log.Instance.WriteLogAdd("OPCUA连接异常,或以离线" + opcex.Message + ",ip:" + device.Ip + ", 协议类型: " + device.ProtocolType, LOG_TITLE_DEVICE);
  1411. continue;
  1412. }
  1413. }
  1414. else if (device.ProtocolType.Equals(ProtocalTypeEnum.FANUC.ToString()))
  1415. {
  1416. try
  1417. {
  1418. string Url = fanucUrlContext + "?ip=" + device.Ip + "&port=" + device.Port;
  1419. //调用发那科是否连接接口
  1420. var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Get, Url + "&fun=Connect", null, null);
  1421. if (Result.IsSuccess && Result.Message == "0")
  1422. {
  1423. Device oldDevice = await _deviceService.GetDeviceById(device.Id);
  1424. if (oldDevice!= null && !oldDevice.State)
  1425. {
  1426. oldDevice.State = true;
  1427. await _deviceService.UpdateDevice(oldDevice);
  1428. changeDevices.Add(oldDevice);
  1429. }
  1430. Log.Instance.WriteLogAdd("Fanuc连接成功,ip:" + device.Ip + ",协议类型:" + device.ProtocolType, LOG_TITLE_DEVICE);
  1431. continue;
  1432. }
  1433. else
  1434. {
  1435. Device oldDevice = await _deviceService.GetDeviceById(device.Id);
  1436. if (oldDevice != null && oldDevice.State)
  1437. {
  1438. oldDevice.State = false;
  1439. await _deviceService.UpdateDevice(oldDevice);
  1440. changeDevices.Add(oldDevice);
  1441. }
  1442. Log.Instance.WriteLogAdd("Fanuc连接异常,或已离线,ip:" + device.Ip + ",协议类型:" + device.ProtocolType, LOG_TITLE_OPCUA);
  1443. message = message + ",Fanuc连接异常,或以离线,ip:" + device.Ip + ",协议类型:" + device.ProtocolType; ;
  1444. continue;
  1445. }
  1446. }
  1447. catch (Exception opcex)
  1448. {
  1449. Device oldDevice = await _deviceService.GetDeviceById(device.Id);
  1450. if (oldDevice != null && oldDevice.State)
  1451. {
  1452. oldDevice.State = false;
  1453. await _deviceService.UpdateDevice(oldDevice);
  1454. changeDevices.Add(oldDevice);
  1455. }
  1456. Log.Instance.WriteLogAdd("Fanuc连接异常,或以离线" + opcex.Message + ",ip:" + device.Ip + ", 协议类型: " + device.ProtocolType, LOG_TITLE_DEVICE);
  1457. continue;
  1458. }
  1459. }
  1460. else if (device.ProtocolType.Equals(ProtocalTypeEnum.HEIDEHAIN.ToString()))
  1461. {
  1462. try
  1463. {
  1464. RequestHeidhData hdhReq = new RequestHeidhData();
  1465. hdhReq.ServerUrl = device.ServerUrl;
  1466. hdhReq.MachineName = device.UserName;
  1467. hdhReq.Type = OpcUaActionTypeEnum.Connect.ToString();
  1468. var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, hdhUrlContext, hdhReq, null);
  1469. ResponseHeidhData responseData = JsonConvert.DeserializeObject<ResponseHeidhData>(Result.Message);
  1470. if (!Result.IsSuccess || !responseData.result)
  1471. {
  1472. Device oldDevice = await _deviceService.GetDeviceById(device.Id);
  1473. if (oldDevice != null && oldDevice.State)
  1474. {
  1475. oldDevice.State = false;
  1476. await _deviceService.UpdateDevice(oldDevice);
  1477. changeDevices.Add(oldDevice);
  1478. }
  1479. Log.Instance.WriteLogAdd("海德汉连接异常,或已离线,ip:" + device.Ip + ",协议类型:" + device.ProtocolType, LOG_TITLE_OPCUA);
  1480. message = message + ",海德汉连接异常,或以离线,ip:" + device.Ip + ",协议类型:" + device.ProtocolType; ;
  1481. continue;
  1482. }
  1483. else
  1484. {
  1485. Device oldDevice = await _deviceService.GetDeviceById(device.Id);
  1486. if (oldDevice != null && !oldDevice.State)
  1487. {
  1488. oldDevice.State = true;
  1489. await _deviceService.UpdateDevice(oldDevice);
  1490. changeDevices.Add(oldDevice);
  1491. }
  1492. Log.Instance.WriteLogAdd("海德汉连接成功,ip:" + device.Ip + ",协议类型:" + device.ProtocolType, LOG_TITLE_DEVICE);
  1493. continue;
  1494. }
  1495. }
  1496. catch (Exception opcex)
  1497. {
  1498. Device oldDevice = await _deviceService.GetDeviceById(device.Id);
  1499. if (oldDevice != null && oldDevice.State)
  1500. {
  1501. oldDevice.State = false;
  1502. await _deviceService.UpdateDevice(oldDevice);
  1503. changeDevices.Add(oldDevice);
  1504. }
  1505. Log.Instance.WriteLogAdd("Fanuc连接异常,或以离线" + opcex.Message + ",ip:" + device.Ip + ", 协议类型: " + device.ProtocolType, LOG_TITLE_DEVICE);
  1506. continue;
  1507. }
  1508. }
  1509. }
  1510. if (changeDevices != null)
  1511. {
  1512. await _redisService.Database.StringSetAsync(device_redis_key, JsonConvert.SerializeObject(devices));
  1513. }
  1514. return message;
  1515. }
  1516. catch (Exception ex)
  1517. {
  1518. Log.Instance.WriteLogAdd("设备连接异常,或以离线" + ex.Message, LOG_TITLE_DEVICE);
  1519. return "设备连接异常,或以离线" + ex.Message;
  1520. }
  1521. }
  1522. /// <summary>
  1523. /// 删除redis
  1524. /// </summary>
  1525. /// <returns></returns>
  1526. public void removeRedis()
  1527. {
  1528. List<Device> devices = _deviceService.GetDeviceAllList();
  1529. string redis_key = "IMCS_CCS:";
  1530. _redisService.Database.KeyDelete(device_redis_key);
  1531. _redisService.Database.KeyDelete(callback_redis_key);
  1532. foreach (Device device in devices)
  1533. {
  1534. _redisService.Database.KeyDelete(redis_key + device.Ip + ":" + device.ProtocolType);
  1535. }
  1536. }
  1537. /// <summary>
  1538. /// fanuc根据类型获取值
  1539. /// </summary>
  1540. /// <returns></returns>
  1541. private string GetFanucValue(ResponseFanucData fanucData, string address)
  1542. {
  1543. string value = "";
  1544. if (address == FanucAddressEnum.MainProg.ToString())
  1545. {
  1546. value = fanucData.MainProg;
  1547. }
  1548. else if (address == FanucAddressEnum.Status.ToString())
  1549. {
  1550. value = fanucData.Status;
  1551. }
  1552. else if (address == FanucAddressEnum.PowerOnTime.ToString())
  1553. {
  1554. value = fanucData.PowerOnTime;
  1555. }
  1556. else if (address == FanucAddressEnum.ActSpindle.ToString())
  1557. {
  1558. value = fanucData.ActSpindle;
  1559. }
  1560. return value;
  1561. }
  1562. /// <summary>
  1563. /// 数字科学计数法处理
  1564. /// </summary>
  1565. /// <param name="strData"></param>
  1566. /// <returns></returns>
  1567. private Decimal ChangeToDecimal(string strData)
  1568. {
  1569. Decimal dData = 0.0M;
  1570. if (strData.Contains("E"))
  1571. {
  1572. dData = Convert.ToDecimal(Decimal.Parse(strData.ToString(), System.Globalization.NumberStyles.Float));
  1573. }
  1574. else
  1575. {
  1576. dData = Convert.ToDecimal(strData);
  1577. }
  1578. return dData;
  1579. }
  1580. /// <summary>
  1581. /// 获取redis 设备列表
  1582. /// </summary>
  1583. /// <param name="strData"></param>
  1584. /// <returns></returns>
  1585. private async Task<List<Device>> getDeviceList()
  1586. {
  1587. List<Device> deviceList = new List<Device>();
  1588. var deviceListData = await _redisService.Database.StringGetAsync(device_redis_key);
  1589. if (deviceListData.IsNullOrEmpty)
  1590. {
  1591. deviceList = _deviceService.GetDeviceAllList();
  1592. await _redisService.Database.StringSetAsync(device_redis_key, JsonConvert.SerializeObject(deviceList));
  1593. }
  1594. else
  1595. {
  1596. deviceList = JsonConvert.DeserializeObject<List<Device>>(deviceListData);
  1597. }
  1598. return deviceList;
  1599. }
  1600. }
  1601. }