TaskJobService.cs 87 KB

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