TaskJobService.cs 94 KB

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