TaskJobService.cs 90 KB

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