HttpRequestService.cs 122 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287
  1. using System.Collections.Generic;
  2. using System.Linq;
  3. using System.Threading.Tasks;
  4. using System.Threading;
  5. using IMCS.CCS.Entitys;
  6. using IMCS.CCS.Models.vo;
  7. using IMCS.CCS.Models;
  8. using IMCS.CCS.DeviceProtocol;
  9. using System;
  10. using S7.Net;
  11. using IMCS_CCS.Utils;
  12. using Newtonsoft.Json;
  13. using IMCS_CCS.Utils.DeviceProtocol;
  14. using HslCommunication.Profinet.Siemens;
  15. using Microsoft.Extensions.Configuration;
  16. using IMCS.CCS.Service;
  17. using IMCS_CCS.Model.vo;
  18. using FTP;
  19. using HslCommunication;
  20. using System.Text.RegularExpressions;
  21. namespace IMCS.CCS.Services
  22. {
  23. public class HttpRequestService : IHttpRequestService
  24. {
  25. private readonly IDeviceService _deviceService;
  26. private readonly ITaskCallbackService _taskCallbackService;
  27. private readonly ICcsActionService _ccsActionService;
  28. private readonly ICcsTagValueService _ccsTagValueService;
  29. private readonly IEquipmentMonitorService _equipmentMonitorService;
  30. private readonly ICcsActionAddressService _ccsActionAddressService;
  31. private readonly ITaskJobService _taskJobService;
  32. private int SLEEP_TIME = 1000;
  33. string LocalPath = "D:\\PROG";
  34. private string fanucUrlContext;
  35. private string opcuacUrlContext;
  36. private string hdhUrlContext;
  37. private string ftpUrlContext;
  38. private string ftpUserContext;
  39. private string ftpPwdContext;
  40. private string ecsRootUrlContext;
  41. public IConfiguration Configuration { get; }
  42. private readonly IApiRequestService _apiRequestService;
  43. public HttpRequestService(IDeviceService deviceService, ITaskCallbackService taskCallbackService,
  44. ICcsActionService ccsActionService, ICcsTagValueService ccsTagValueService,
  45. IEquipmentMonitorService equipmentMonitorService, ICcsActionAddressService ccsActionAddressService,
  46. IApiRequestService apiRequestService, ITaskJobService taskJobService,
  47. IConfiguration configuration)
  48. {
  49. _deviceService = deviceService;
  50. _taskCallbackService = taskCallbackService;
  51. _ccsActionService = ccsActionService;
  52. _ccsTagValueService = ccsTagValueService;
  53. _equipmentMonitorService = equipmentMonitorService;
  54. _ccsActionAddressService = ccsActionAddressService;
  55. _apiRequestService = apiRequestService;
  56. _taskJobService = taskJobService;
  57. Configuration = configuration;
  58. fanucUrlContext = Configuration.GetConnectionString("fanucUrlContext");
  59. opcuacUrlContext = Configuration.GetConnectionString("opcuacUrlContext");
  60. hdhUrlContext = Configuration.GetConnectionString("hdhUrlContext");
  61. ftpUrlContext = Configuration.GetConnectionString("FTPServer");
  62. ftpUserContext = Configuration.GetConnectionString("FTPUser");
  63. ftpPwdContext = Configuration.GetConnectionString("FTPPwd");
  64. ecsRootUrlContext = Configuration.GetConnectionString("ecsRootUrlContext");
  65. }
  66. /// <summary>
  67. /// 获取状态当前值
  68. /// </summary>
  69. public string GetTagValue(RequestTagValueData req)
  70. {
  71. CcsTagValue queryParam = new CcsTagValue();
  72. queryParam.Ip = req.ip;
  73. queryParam.Address = req.tagname;
  74. List<CcsTagValue> tagValues = _ccsTagValueService.GetList(queryParam);
  75. string tagValue = "0";
  76. if (tagValues != null && tagValues.Count > 0)
  77. {
  78. tagValue = tagValues[0].TagValue;
  79. }
  80. return tagValue;
  81. }
  82. /// <summary>
  83. /// 益模调用接口,显示3D
  84. /// </summary>
  85. public async Task<List<ResponseDigitalTwinsData>> GetDigitalTwins()
  86. {
  87. List<Device> devices = _deviceService.GetDeviceList();
  88. List<ResponseDigitalTwinsData> list = new List<ResponseDigitalTwinsData>();
  89. String query3dUrl = ecsRootUrlContext + "api/authority/agv/agvCallbackService/query3dResouceDataInfo";
  90. var result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, query3dUrl, new Object(), null);
  91. ResponsePageData<ResponseDigitalTwinsData> responseData = JsonConvert.DeserializeObject<ResponsePageData<ResponseDigitalTwinsData>>(result.Message);
  92. list = responseData.Data;
  93. foreach(ResponseDigitalTwinsData responseDigitalTwinsData in list)
  94. {
  95. EquipmentMonitor equipmentMonitor = await _equipmentMonitorService.GetById(long.Parse(responseDigitalTwinsData.resourceId));
  96. Device device = devices.Where(x => x.Ip.Equals(equipmentMonitor.IP)).FirstOrDefault();
  97. if (null!=device && equipmentMonitor.Type == "HEIDEHAIN")
  98. {
  99. RequestHeidhData hdhReq = new RequestHeidhData();
  100. hdhReq.ServerUrl = device.ServerUrl;
  101. hdhReq.MachineName = device.UserName;
  102. hdhReq.Type = "Collect";
  103. var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, hdhUrlContext, hdhReq, null);
  104. if (Result.IsSuccess)
  105. {
  106. ResponseHeidhData retData = JsonConvert.DeserializeObject<ResponseHeidhData>(Result.Message);
  107. if (!string.IsNullOrEmpty(retData.runDatasInfo.Trim()))
  108. {
  109. ResponseDigitalTwinsData twinsData = JsonConvert.DeserializeObject<ResponseDigitalTwinsData>(retData.runDatasInfo);
  110. responseDigitalTwinsData.feedRate = twinsData.feedRate;
  111. responseDigitalTwinsData.spindleMagnification = twinsData.spindleMagnification;
  112. }
  113. }
  114. }
  115. else if(null != device && equipmentMonitor.Type == "FANUC")
  116. {
  117. string Url = fanucUrlContext + "?ip=" + device.Ip + "&port=" + device.Port;
  118. //调用发那科接口
  119. var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Get, Url + "&fun=All", null, null);
  120. if (Result.IsSuccess)
  121. {
  122. ResponseFanucData responseFanucData = JsonConvert.DeserializeObject<ResponseFanucData>(Result.Message);
  123. responseDigitalTwinsData.feedRate = responseFanucData.ActFeed;
  124. responseDigitalTwinsData.spindleMagnification = responseFanucData.ActSpindle;
  125. //responseDigitalTwinsData.spindleSpeed = responseFanucData.
  126. //responseDigitalTwinsData.spindleLoad = responseFanucData.
  127. }
  128. }
  129. }
  130. return list;
  131. }
  132. /// <summary>
  133. /// 查询设备状态
  134. /// </summary>
  135. public async Task<List<EquipmentMonitor>> GetEquipMent()
  136. {
  137. return await _equipmentMonitorService.GetList();
  138. }
  139. /// <summary>
  140. /// 智能单元取物品
  141. /// </summary>
  142. public async Task<ResponseECSData> GetIntelligenceUnit(RequestData<LocationData> req)
  143. {
  144. ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId);
  145. try
  146. {
  147. List<Device> devices = _deviceService.GetDeviceList();
  148. Device device = devices.Where(x => x.Ip.Equals(req.url) && x.Port.Equals(req.port)).FirstOrDefault();
  149. if (device == null)
  150. {
  151. Log.Instance.WriteLogAdd(ActionTypeEnum.GetIntelligenceUnit + "设备已离线===>>" + JsonConvert.SerializeObject(req),
  152. EnumHelper.GetDescription(ActionTypeEnum.GetIntelligenceUnit));
  153. responseData.result = "false";
  154. return responseData;
  155. }
  156. CcsAction actionQuery = new CcsAction();
  157. actionQuery.OperateType = ActionTypeEnum.GetIntelligenceUnit.ToString();
  158. actionQuery.Ip = req.url;
  159. CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault();
  160. Plc s7 = DevicePlcS7.S7(req.url, ProtocalTypeEnum.S7_1500.ToString());
  161. if (s7.IsConnected != true)
  162. {
  163. Log.Instance.WriteLogAdd(ActionTypeEnum.GetIntelligenceUnit + "取物品异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
  164. EnumHelper.GetDescription(ActionTypeEnum.GetIntelligenceUnit));
  165. responseData.result = "false";
  166. return responseData;
  167. }
  168. CcsActionAddress actionAddressQuery = new CcsActionAddress();
  169. actionAddressQuery.ActionId = actionInfo.Id;
  170. List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);
  171. //查询条件
  172. List<CcsActionAddress> CcsActionAddressChecks = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CHECK.ToString()).ToList();
  173. foreach (CcsActionAddress actionAddress in CcsActionAddressChecks)
  174. {
  175. if (!string.IsNullOrEmpty(actionAddress.Address) && !string.IsNullOrEmpty(actionAddress.Value))
  176. {
  177. string CheckAddress = ToolUtils.AddressConvertDBW(actionAddress.Address);
  178. var operateResult = ((ushort)s7.Read(CheckAddress)).ConvertToShort();
  179. if (actionAddress.CheckType ? operateResult.ToString().Equals(actionAddress.Value) : operateResult.ToString() != actionAddress.Value)
  180. {
  181. s7.Close();
  182. Log.Instance.WriteLogAdd(ActionTypeEnum.GetIntelligenceUnit + "取物品异常===>>" + "条件不满足" + JsonConvert.SerializeObject(req),
  183. EnumHelper.GetDescription(ActionTypeEnum.GetIntelligenceUnit));
  184. responseData.result = "false";
  185. return responseData;
  186. }
  187. }
  188. }
  189. //查询写入地址列表
  190. List<CcsActionAddress> CcsActionAddressWrites = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.WRITE.ToString()).ToList();
  191. foreach (CcsActionAddress actionAddress in CcsActionAddressWrites)
  192. {
  193. if (!string.IsNullOrEmpty(actionAddress.Address))
  194. {
  195. string Address = ToolUtils.AddressConvertDBW(actionAddress.Address);
  196. s7.Write(Address, Convert.ToInt16(string.IsNullOrEmpty(actionAddress.Value) ? req.data.Location : actionAddress.Value)); ;
  197. Thread.Sleep(SLEEP_TIME);
  198. }
  199. }
  200. s7.Close();
  201. //插入回调
  202. TaskCallback taskCallbackData = new TaskCallback(req.url, ActionTypeEnum.GetIntelligenceUnit.ToString(),
  203. EnumHelper.GetDescription(ActionTypeEnum.GetIntelligenceUnit), req.taskId, req.taskNodeId);
  204. await _taskCallbackService.CreateOrUpdateAndCache(setCallBackValue(CcsActionAddresses, taskCallbackData));
  205. Log.Instance.WriteLogAdd(EnumHelper.GetDescription(ActionTypeEnum.GetIntelligenceUnit) + "取物品成功===>>" + JsonConvert.SerializeObject(req)
  206. , EnumHelper.GetDescription(ActionTypeEnum.GetIntelligenceUnit));
  207. return responseData;
  208. }
  209. catch (Exception ex)
  210. {
  211. Log.Instance.WriteLogAdd(ActionTypeEnum.GetIntelligenceUnit + "取物品异常===>>" + ex.Message + JsonConvert.SerializeObject(req),
  212. EnumHelper.GetDescription(ActionTypeEnum.GetIntelligenceUnit));
  213. responseData.result = "false";
  214. return responseData;
  215. }
  216. }
  217. /// <summary>
  218. /// 柔性线取物品
  219. /// </summary>
  220. public async Task<ResponseECSData> GetFlexibleWire(RequestData<LocationData> req)
  221. {
  222. ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId);
  223. try
  224. {
  225. List<Device> devices = _deviceService.GetDeviceList();
  226. Device device = devices.Where(x => x.Ip.Equals(req.url) && x.Port.Equals(req.port)).FirstOrDefault();
  227. if (device == null)
  228. {
  229. Log.Instance.WriteLogAdd(ActionTypeEnum.GetFlexibleWire + "设备已离线===>>" + JsonConvert.SerializeObject(req),
  230. EnumHelper.GetDescription(ActionTypeEnum.GetFlexibleWire));
  231. responseData.result = "false";
  232. return responseData;
  233. }
  234. CcsAction actionQuery = new CcsAction();
  235. actionQuery.OperateType = ActionTypeEnum.GetFlexibleWire.ToString();
  236. actionQuery.Ip = req.url;
  237. CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault();
  238. Plc s7 = DevicePlcS7.S7(req.url, ProtocalTypeEnum.S7_1500.ToString());
  239. if (s7.IsConnected != true)
  240. {
  241. s7.Close();
  242. Log.Instance.WriteLogAdd(ActionTypeEnum.GetFlexibleWire + "取物品异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
  243. EnumHelper.GetDescription(ActionTypeEnum.GetFlexibleWire));
  244. responseData.result = "false";
  245. return responseData;
  246. }
  247. CcsActionAddress actionAddressQuery = new CcsActionAddress();
  248. actionAddressQuery.ActionId = actionInfo.Id;
  249. List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);
  250. //查询条件
  251. List<CcsActionAddress> CcsActionAddressChecks = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CHECK.ToString()).ToList();
  252. foreach (CcsActionAddress actionAddress in CcsActionAddressChecks)
  253. {
  254. if (!string.IsNullOrEmpty(actionAddress.Address) && !string.IsNullOrEmpty(actionAddress.Value))
  255. {
  256. string CheckAddress = ToolUtils.AddressConvertDBW(actionAddress.Address);
  257. var operateResult = ((ushort)s7.Read(CheckAddress)).ConvertToShort();
  258. if (actionAddress.CheckType ? operateResult.ToString().Equals(actionAddress.Value) : operateResult.ToString() != actionAddress.Value)
  259. {
  260. s7.Close();
  261. Log.Instance.WriteLogAdd(ActionTypeEnum.GetFlexibleWire + "取物品异常===>>" + "条件不满足" + JsonConvert.SerializeObject(req),
  262. EnumHelper.GetDescription(ActionTypeEnum.GetFlexibleWire));
  263. responseData.result = "false";
  264. return responseData;
  265. }
  266. }
  267. }
  268. //查询写入地址列表
  269. List<CcsActionAddress> CcsActionAddressWrites = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.WRITE.ToString()).ToList();
  270. foreach (CcsActionAddress actionAddress in CcsActionAddressWrites)
  271. {
  272. if (!string.IsNullOrEmpty(actionAddress.Address))
  273. {
  274. string Address = ToolUtils.AddressConvertDBW(actionAddress.Address);
  275. s7.Write(Address, Convert.ToInt16(string.IsNullOrEmpty(actionAddress.Value) ? req.data.Location : actionAddress.Value)); ;
  276. Thread.Sleep(SLEEP_TIME);
  277. }
  278. }
  279. s7.Close();
  280. //插入回调
  281. TaskCallback taskCallbackData = new TaskCallback(req.url, ActionTypeEnum.GetFlexibleWire.ToString(),
  282. EnumHelper.GetDescription(ActionTypeEnum.GetFlexibleWire), req.taskId, req.taskNodeId);
  283. await _taskCallbackService.CreateOrUpdateAndCache(setCallBackValue(CcsActionAddresses, taskCallbackData));
  284. Log.Instance.WriteLogAdd(EnumHelper.GetDescription(ActionTypeEnum.GetFlexibleWire) + "取物品成功===>>" + JsonConvert.SerializeObject(req)
  285. , EnumHelper.GetDescription(ActionTypeEnum.GetFlexibleWire));
  286. return responseData;
  287. }
  288. catch (Exception ex)
  289. {
  290. Log.Instance.WriteLogAdd(ActionTypeEnum.GetFlexibleWire + "取物品异常===>>" + ex.Message + JsonConvert.SerializeObject(req),
  291. EnumHelper.GetDescription(ActionTypeEnum.GetFlexibleWire));
  292. responseData.result = "false";
  293. return responseData;
  294. }
  295. }
  296. /// <summary>
  297. /// 质量中心取物品
  298. /// </summary>
  299. public async Task<ResponseECSData> GetQualityCenter(RequestData<LocationData> req)
  300. {
  301. ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId);
  302. try
  303. {
  304. List<Device> devices = _deviceService.GetDeviceList();
  305. Device device = devices.Where(x => x.Ip.Equals(req.url) && x.Port.Equals(req.port)).FirstOrDefault();
  306. if (device == null)
  307. {
  308. Log.Instance.WriteLogAdd(ActionTypeEnum.GetQualityCenter + "设备已离线===>>" + JsonConvert.SerializeObject(req),
  309. EnumHelper.GetDescription(ActionTypeEnum.GetQualityCenter));
  310. responseData.result = "false";
  311. return responseData;
  312. }
  313. CcsAction actionQuery = new CcsAction();
  314. actionQuery.OperateType = ActionTypeEnum.GetQualityCenter.ToString();
  315. actionQuery.Ip = req.url;
  316. CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault();
  317. Plc s7 = DevicePlcS7.S7(req.url, ProtocalTypeEnum.S7_1500.ToString());
  318. if (s7.IsConnected != true)
  319. {
  320. s7.Close();
  321. Log.Instance.WriteLogAdd(ActionTypeEnum.GetQualityCenter + "取物品异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
  322. EnumHelper.GetDescription(ActionTypeEnum.GetQualityCenter));
  323. responseData.result = "false";
  324. return responseData;
  325. }
  326. CcsActionAddress actionAddressQuery = new CcsActionAddress();
  327. actionAddressQuery.ActionId = actionInfo.Id;
  328. List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);
  329. //查询条件
  330. List<CcsActionAddress> CcsActionAddressChecks = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CHECK.ToString()).ToList();
  331. foreach (CcsActionAddress actionAddress in CcsActionAddressChecks)
  332. {
  333. if (!string.IsNullOrEmpty(actionAddress.Address) && !string.IsNullOrEmpty(actionAddress.Value))
  334. {
  335. string CheckAddress = ToolUtils.AddressConvertDBW(actionAddress.Address);
  336. var operateResult = ((ushort)s7.Read(CheckAddress)).ConvertToShort();
  337. if (actionAddress.CheckType ? operateResult.ToString().Equals(actionAddress.Value) : operateResult.ToString() != actionAddress.Value)
  338. {
  339. s7.Close();
  340. Log.Instance.WriteLogAdd(ActionTypeEnum.GetQualityCenter + "取物品异常===>>" + "条件不满足" + JsonConvert.SerializeObject(req),
  341. EnumHelper.GetDescription(ActionTypeEnum.GetQualityCenter));
  342. responseData.result = "false";
  343. return responseData;
  344. }
  345. }
  346. }
  347. //查询写入地址列表
  348. List<CcsActionAddress> CcsActionAddressWrites = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.WRITE.ToString()).ToList();
  349. foreach (CcsActionAddress actionAddress in CcsActionAddressWrites)
  350. {
  351. if (!string.IsNullOrEmpty(actionAddress.Address))
  352. {
  353. string Address = ToolUtils.AddressConvertDBW(actionAddress.Address);
  354. s7.Write(Address, Convert.ToInt16(string.IsNullOrEmpty(actionAddress.Value) ? req.data.Location : actionAddress.Value)); ;
  355. Thread.Sleep(SLEEP_TIME);
  356. }
  357. }
  358. s7.Close();
  359. //插入回调
  360. TaskCallback taskCallbackData = new TaskCallback(req.url, ActionTypeEnum.GetQualityCenter.ToString(),
  361. EnumHelper.GetDescription(ActionTypeEnum.GetQualityCenter), req.taskId, req.taskNodeId);
  362. await _taskCallbackService.CreateOrUpdateAndCache(setCallBackValue(CcsActionAddresses, taskCallbackData));
  363. Log.Instance.WriteLogAdd(EnumHelper.GetDescription(ActionTypeEnum.GetQualityCenter) + "取物品成功===>>" + JsonConvert.SerializeObject(req)
  364. , EnumHelper.GetDescription(ActionTypeEnum.GetQualityCenter));
  365. return responseData;
  366. }
  367. catch (Exception ex)
  368. {
  369. Log.Instance.WriteLogAdd(ActionTypeEnum.GetQualityCenter + "取物品异常===>>" + ex.Message + JsonConvert.SerializeObject(req),
  370. EnumHelper.GetDescription(ActionTypeEnum.GetQualityCenter));
  371. responseData.result = "false";
  372. return responseData;
  373. }
  374. }
  375. /// <summary>
  376. /// 智能单元送物品
  377. /// </summary>
  378. public async Task<ResponseECSData> SendIntelligenceUnit(RequestData<LocationData> req)
  379. {
  380. ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId);
  381. try
  382. {
  383. List<Device> devices = _deviceService.GetDeviceList();
  384. Device device = devices.Where(x => x.Ip.Equals(req.url) && x.Port.Equals(req.port)).FirstOrDefault();
  385. if (device == null)
  386. {
  387. Log.Instance.WriteLogAdd(ActionTypeEnum.SendIntelligenceUnit + "设备已离线===>>" + JsonConvert.SerializeObject(req),
  388. EnumHelper.GetDescription(ActionTypeEnum.SendIntelligenceUnit));
  389. responseData.result = "false";
  390. return responseData;
  391. }
  392. CcsAction actionQuery = new CcsAction();
  393. actionQuery.OperateType = ActionTypeEnum.SendIntelligenceUnit.ToString();
  394. actionQuery.Ip = req.url;
  395. CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault();
  396. Plc s7 = DevicePlcS7.S7(req.url, ProtocalTypeEnum.S7_1500.ToString());
  397. if (s7.IsConnected != true)
  398. {
  399. s7.Close();
  400. Log.Instance.WriteLogAdd(ActionTypeEnum.SendIntelligenceUnit + "放物品异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
  401. EnumHelper.GetDescription(ActionTypeEnum.SendIntelligenceUnit));
  402. responseData.result = "false";
  403. return responseData;
  404. }
  405. CcsActionAddress actionAddressQuery = new CcsActionAddress();
  406. actionAddressQuery.ActionId = actionInfo.Id;
  407. List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);
  408. //查询条件
  409. List<CcsActionAddress> CcsActionAddressChecks = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CHECK.ToString()).ToList();
  410. foreach (CcsActionAddress actionAddress in CcsActionAddressChecks)
  411. {
  412. if (!string.IsNullOrEmpty(actionAddress.Address) && !string.IsNullOrEmpty(actionAddress.Value))
  413. {
  414. string CheckAddress = ToolUtils.AddressConvertDBW(actionAddress.Address);
  415. var operateResult = ((ushort)s7.Read(CheckAddress)).ConvertToShort();
  416. if (actionAddress.CheckType ? operateResult.ToString().Equals(actionAddress.Value) : operateResult.ToString() != actionAddress.Value)
  417. {
  418. s7.Close();
  419. Log.Instance.WriteLogAdd(ActionTypeEnum.SendIntelligenceUnit + "取物品异常===>>" + "条件不满足" + JsonConvert.SerializeObject(req),
  420. EnumHelper.GetDescription(ActionTypeEnum.SendIntelligenceUnit));
  421. responseData.result = "false";
  422. return responseData;
  423. }
  424. }
  425. }
  426. //查询写入地址列表
  427. List<CcsActionAddress> CcsActionAddressWrites = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.WRITE.ToString()).ToList();
  428. foreach (CcsActionAddress actionAddress in CcsActionAddressWrites)
  429. {
  430. if (!string.IsNullOrEmpty(actionAddress.Address))
  431. {
  432. string Address = ToolUtils.AddressConvertDBW(actionAddress.Address);
  433. s7.Write(Address, Convert.ToInt16(string.IsNullOrEmpty(actionAddress.Value) ? req.data.Location : actionAddress.Value)); ;
  434. Thread.Sleep(SLEEP_TIME);
  435. }
  436. }
  437. s7.Close();
  438. //插入回调
  439. TaskCallback taskCallbackData = new TaskCallback(req.url, ActionTypeEnum.SendIntelligenceUnit.ToString(),
  440. EnumHelper.GetDescription(ActionTypeEnum.SendIntelligenceUnit), req.taskId, req.taskNodeId);
  441. await _taskCallbackService.CreateOrUpdateAndCache(setCallBackValue(CcsActionAddresses, taskCallbackData));
  442. Log.Instance.WriteLogAdd(EnumHelper.GetDescription(ActionTypeEnum.SendIntelligenceUnit) + "放物品成功===>>" + JsonConvert.SerializeObject(req)
  443. , EnumHelper.GetDescription(ActionTypeEnum.SendIntelligenceUnit));
  444. return responseData;
  445. }
  446. catch (Exception ex)
  447. {
  448. Log.Instance.WriteLogAdd(ActionTypeEnum.SendIntelligenceUnit + "放物品故障===>>" + ex.Message + JsonConvert.SerializeObject(req),
  449. EnumHelper.GetDescription(ActionTypeEnum.SendIntelligenceUnit));
  450. responseData.result = "false";
  451. return responseData;
  452. }
  453. }
  454. /// <summary>
  455. /// 柔性线送物品
  456. /// </summary>
  457. public async Task<ResponseECSData> SendFlexibleWire(RequestData<LocationData> req)
  458. {
  459. ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId);
  460. try
  461. {
  462. List<Device> devices = _deviceService.GetDeviceList();
  463. Device device = devices.Where(x => x.Ip.Equals(req.url) && x.Port.Equals(req.port)).FirstOrDefault();
  464. if (device == null)
  465. {
  466. Log.Instance.WriteLogAdd(ActionTypeEnum.SendFlexibleWire + "设备已离线===>>" + JsonConvert.SerializeObject(req),
  467. EnumHelper.GetDescription(ActionTypeEnum.SendFlexibleWire));
  468. responseData.result = "false";
  469. return responseData;
  470. }
  471. CcsAction actionQuery = new CcsAction();
  472. actionQuery.OperateType = ActionTypeEnum.SendFlexibleWire.ToString();
  473. actionQuery.Ip = req.url;
  474. CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault();
  475. Plc s7 = DevicePlcS7.S7(req.url, ProtocalTypeEnum.S7_1500.ToString());
  476. if (s7.IsConnected != true)
  477. {
  478. s7.Close();
  479. Log.Instance.WriteLogAdd(ActionTypeEnum.SendFlexibleWire + "放物品异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
  480. EnumHelper.GetDescription(ActionTypeEnum.SendFlexibleWire));
  481. responseData.result = "false";
  482. return responseData;
  483. }
  484. CcsActionAddress actionAddressQuery = new CcsActionAddress();
  485. actionAddressQuery.ActionId = actionInfo.Id;
  486. List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);
  487. //查询条件
  488. List<CcsActionAddress> CcsActionAddressChecks = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CHECK.ToString()).ToList();
  489. foreach (CcsActionAddress actionAddress in CcsActionAddressChecks)
  490. {
  491. if (!string.IsNullOrEmpty(actionAddress.Address) && !string.IsNullOrEmpty(actionAddress.Value))
  492. {
  493. string CheckAddress = ToolUtils.AddressConvertDBW(actionAddress.Address);
  494. var operateResult = ((ushort)s7.Read(CheckAddress)).ConvertToShort();
  495. if (actionAddress.CheckType ? operateResult.ToString().Equals(actionAddress.Value) : operateResult.ToString() != actionAddress.Value)
  496. {
  497. s7.Close();
  498. Log.Instance.WriteLogAdd(ActionTypeEnum.SendFlexibleWire + "取物品异常===>>" + "条件不满足" + JsonConvert.SerializeObject(req),
  499. EnumHelper.GetDescription(ActionTypeEnum.SendFlexibleWire));
  500. responseData.result = "false";
  501. return responseData;
  502. }
  503. }
  504. }
  505. //查询写入地址列表
  506. List<CcsActionAddress> CcsActionAddressWrites = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.WRITE.ToString()).ToList();
  507. foreach (CcsActionAddress actionAddress in CcsActionAddressWrites)
  508. {
  509. if (!string.IsNullOrEmpty(actionAddress.Address))
  510. {
  511. string Address = ToolUtils.AddressConvertDBW(actionAddress.Address);
  512. s7.Write(Address, Convert.ToInt16(string.IsNullOrEmpty(actionAddress.Value) ? req.data.Location : actionAddress.Value)); ;
  513. Thread.Sleep(SLEEP_TIME);
  514. }
  515. }
  516. s7.Close();
  517. //插入回调
  518. TaskCallback taskCallbackData = new TaskCallback(req.url, ActionTypeEnum.SendFlexibleWire.ToString(),
  519. EnumHelper.GetDescription(ActionTypeEnum.SendFlexibleWire), req.taskId, req.taskNodeId);
  520. await _taskCallbackService.CreateOrUpdateAndCache(setCallBackValue(CcsActionAddresses, taskCallbackData));
  521. Log.Instance.WriteLogAdd(EnumHelper.GetDescription(ActionTypeEnum.SendFlexibleWire) + "放物品成功===>>" + JsonConvert.SerializeObject(req)
  522. , EnumHelper.GetDescription(ActionTypeEnum.SendFlexibleWire));
  523. return responseData;
  524. }
  525. catch (Exception ex)
  526. {
  527. Log.Instance.WriteLogAdd(ActionTypeEnum.SendFlexibleWire + "放物品异常===>>" + ex.Message + JsonConvert.SerializeObject(req),
  528. EnumHelper.GetDescription(ActionTypeEnum.SendFlexibleWire));
  529. responseData.result = "false";
  530. return responseData;
  531. }
  532. }
  533. /// <summary>
  534. /// 质量中心送物品
  535. /// </summary>
  536. public async Task<ResponseECSData> SendQualityCenter(RequestData<LocationData> req)
  537. {
  538. ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId);
  539. try
  540. {
  541. List<Device> devices = _deviceService.GetDeviceList();
  542. Device device = devices.Where(x => x.Ip.Equals(req.url) && x.Port.Equals(req.port)).FirstOrDefault();
  543. if (device == null)
  544. {
  545. Log.Instance.WriteLogAdd(ActionTypeEnum.SendQualityCenter + "设备已离线===>>" + JsonConvert.SerializeObject(req),
  546. EnumHelper.GetDescription(ActionTypeEnum.SendQualityCenter));
  547. responseData.result = "false";
  548. return responseData;
  549. }
  550. CcsAction actionQuery = new CcsAction();
  551. actionQuery.OperateType = ActionTypeEnum.SendQualityCenter.ToString();
  552. actionQuery.Ip = req.url;
  553. CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault();
  554. Plc s7 = DevicePlcS7.S7(req.url, ProtocalTypeEnum.S7_1500.ToString());
  555. if (s7.IsConnected != true)
  556. {
  557. s7.Close();
  558. Log.Instance.WriteLogAdd(ActionTypeEnum.SendQualityCenter + "放物品异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
  559. EnumHelper.GetDescription(ActionTypeEnum.SendQualityCenter));
  560. responseData.result = "false";
  561. return responseData;
  562. }
  563. CcsActionAddress actionAddressQuery = new CcsActionAddress();
  564. actionAddressQuery.ActionId = actionInfo.Id;
  565. List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);
  566. //查询条件
  567. List<CcsActionAddress> CcsActionAddressChecks = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CHECK.ToString()).ToList();
  568. foreach (CcsActionAddress actionAddress in CcsActionAddressChecks)
  569. {
  570. if (!string.IsNullOrEmpty(actionAddress.Address) && !string.IsNullOrEmpty(actionAddress.Value))
  571. {
  572. string CheckAddress = ToolUtils.AddressConvertDBW(actionAddress.Address);
  573. var operateResult = ((ushort)s7.Read(CheckAddress)).ConvertToShort();
  574. if (actionAddress.CheckType ? operateResult.ToString().Equals(actionAddress.Value) : operateResult.ToString() != actionAddress.Value)
  575. {
  576. s7.Close();
  577. Log.Instance.WriteLogAdd(ActionTypeEnum.SendFlexibleWire + "取物品异常===>>" + "条件不满足" + JsonConvert.SerializeObject(req),
  578. EnumHelper.GetDescription(ActionTypeEnum.SendFlexibleWire));
  579. responseData.result = "false";
  580. return responseData;
  581. }
  582. }
  583. }
  584. //查询写入地址列表
  585. List<CcsActionAddress> CcsActionAddressWrites = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.WRITE.ToString()).ToList();
  586. foreach (CcsActionAddress actionAddress in CcsActionAddressWrites)
  587. {
  588. if (!string.IsNullOrEmpty(actionAddress.Address))
  589. {
  590. string Address = ToolUtils.AddressConvertDBW(actionAddress.Address);
  591. s7.Write(Address, Convert.ToInt16(string.IsNullOrEmpty(actionAddress.Value) ? req.data.Location : actionAddress.Value)); ;
  592. Thread.Sleep(SLEEP_TIME);
  593. }
  594. }
  595. s7.Close();
  596. //插入回调
  597. TaskCallback taskCallbackData = new TaskCallback(req.url, ActionTypeEnum.SendQualityCenter.ToString(),
  598. EnumHelper.GetDescription(ActionTypeEnum.SendQualityCenter), req.taskId, req.taskNodeId);
  599. taskCallbackData = setCallBackValue(CcsActionAddresses, taskCallbackData);
  600. //清洗机启动时更新回调值
  601. if(!string.IsNullOrEmpty(req.data.Location) && req.data.Location == "123")
  602. {
  603. taskCallbackData.Address = "DB200.48";
  604. taskCallbackData.CallbackValue = "1";
  605. }
  606. await _taskCallbackService.CreateOrUpdateAndCache(taskCallbackData);
  607. Log.Instance.WriteLogAdd(EnumHelper.GetDescription(ActionTypeEnum.SendQualityCenter) + "放物品成功===>>" + JsonConvert.SerializeObject(req)
  608. , EnumHelper.GetDescription(ActionTypeEnum.SendQualityCenter));
  609. return responseData;
  610. }
  611. catch (Exception ex)
  612. {
  613. Log.Instance.WriteLogAdd(ActionTypeEnum.SendQualityCenter + "放物品故障===>>" + ex.Message + JsonConvert.SerializeObject(req),
  614. EnumHelper.GetDescription(ActionTypeEnum.SendQualityCenter));
  615. responseData.result = "false";
  616. return responseData;
  617. }
  618. }
  619. /// <summary>
  620. /// 柔性线机器人移动物品
  621. /// </summary>
  622. public async Task<ResponseECSData> MoveRobotPosition(RequestData<LocationData> req)
  623. {
  624. ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId);
  625. try
  626. {
  627. List<Device> devices = _deviceService.GetDeviceList();
  628. Device device = devices.Where(x => x.Ip.Equals(req.url) && x.Port.Equals(req.port)).FirstOrDefault();
  629. if (device == null)
  630. {
  631. Log.Instance.WriteLogAdd(ActionTypeEnum.MoveRobotPosition + "设备已离线===>>" + JsonConvert.SerializeObject(req),
  632. EnumHelper.GetDescription(ActionTypeEnum.MoveRobotPosition));
  633. responseData.result = "false";
  634. return responseData;
  635. }
  636. CcsAction actionQuery = new CcsAction();
  637. actionQuery.OperateType = ActionTypeEnum.MoveRobotPosition.ToString();
  638. actionQuery.Ip = req.url;
  639. CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault();
  640. SiemensS7Net s7 = DevicePlcS7.SiemensS7(req.url);
  641. HslCommunication.OperateResult ConnectionResult = s7.ConnectServer();
  642. if (!ConnectionResult.IsSuccess)
  643. {
  644. s7.ConnectClose();
  645. Log.Instance.WriteLogAdd(ActionTypeEnum.MoveRobotPosition + "移动物品异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
  646. EnumHelper.GetDescription(ActionTypeEnum.MoveRobotPosition));
  647. responseData.result = "false";
  648. return responseData;
  649. }
  650. CcsActionAddress actionAddressQuery = new CcsActionAddress();
  651. actionAddressQuery.ActionId = actionInfo.Id;
  652. List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);
  653. //查询条件
  654. List<CcsActionAddress> CcsActionAddressChecks = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CHECK.ToString()).ToList();
  655. foreach (CcsActionAddress actionAddress in CcsActionAddressChecks)
  656. {
  657. if (!string.IsNullOrEmpty(actionAddress.Address) && !string.IsNullOrEmpty(actionAddress.Value))
  658. {
  659. var operateResult = s7.ReadInt16(actionAddress.Address);
  660. if (actionAddress.CheckType ? operateResult.Content.ToString().Equals(actionAddress.Value) : operateResult.Content.ToString() != actionAddress.Value)
  661. {
  662. s7.ConnectClose();
  663. Log.Instance.WriteLogAdd(ActionTypeEnum.MoveRobotPosition + "取物品异常===>>" + "条件不满足" + JsonConvert.SerializeObject(req),
  664. EnumHelper.GetDescription(ActionTypeEnum.MoveRobotPosition));
  665. responseData.result = "false";
  666. return responseData;
  667. }
  668. }
  669. }
  670. //查询写入地址列表
  671. List<CcsActionAddress> CcsActionAddressWrites = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.WRITE.ToString()).ToList();
  672. foreach (CcsActionAddress actionAddress in CcsActionAddressWrites)
  673. {
  674. if (!string.IsNullOrEmpty(actionAddress.Address))
  675. {
  676. s7.Write(actionAddress.Address, Convert.ToInt16(string.IsNullOrEmpty(actionAddress.Value) ? req.data.Location : actionAddress.Value)); ;
  677. Thread.Sleep(SLEEP_TIME);
  678. }
  679. }
  680. s7.ConnectClose();
  681. //插入回调
  682. TaskCallback taskCallbackData = new TaskCallback(req.url, ActionTypeEnum.MoveRobotPosition.ToString(),
  683. EnumHelper.GetDescription(ActionTypeEnum.MoveRobotPosition), req.taskId, req.taskNodeId);
  684. await _taskCallbackService.CreateOrUpdateAndCache(setCallBackValue(CcsActionAddresses, taskCallbackData));
  685. Log.Instance.WriteLogAdd(EnumHelper.GetDescription(ActionTypeEnum.MoveRobotPosition) + "移动物品成功===>>" + JsonConvert.SerializeObject(req)
  686. , EnumHelper.GetDescription(ActionTypeEnum.MoveRobotPosition));
  687. return responseData;
  688. }
  689. catch (Exception ex)
  690. {
  691. Log.Instance.WriteLogAdd(ActionTypeEnum.MoveRobotPosition + "移动物品故障===>>" + ex.Message + JsonConvert.SerializeObject(req),
  692. EnumHelper.GetDescription(ActionTypeEnum.MoveRobotPosition));
  693. responseData.result = "false";
  694. return responseData;
  695. }
  696. }
  697. /// <summary>
  698. /// 上传文件
  699. /// </summary>
  700. public async Task<ResponseECSData> UploadFile(RequestData<UploadFileData> req)
  701. {
  702. ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId);
  703. try
  704. {
  705. List<Device> devices = _deviceService.GetDeviceAllList();
  706. Device deviceFtp = devices.Where(x => x.Ip.Equals(req.url)
  707. && x.ProtocolType.Equals(ProtocalTypeEnum.FTP.ToString())).FirstOrDefault();
  708. Device deviceFanuc = devices.Where(x => x.Ip.Equals(req.url)
  709. && x.ProtocolType.Equals(ProtocalTypeEnum.FANUC.ToString())).FirstOrDefault();
  710. Device deviceHeidenhain = devices.Where(x => x.Ip.Equals(req.url)
  711. && x.ProtocolType.Equals(ProtocalTypeEnum.HEIDEHAIN.ToString())).FirstOrDefault();
  712. if (deviceFtp == null && deviceFanuc == null && deviceHeidenhain == null)
  713. {
  714. Log.Instance.WriteLogAdd(ActionTypeEnum.UploadFile + "设备已离线===>>" + JsonConvert.SerializeObject(req),
  715. EnumHelper.GetDescription(ActionTypeEnum.UploadFile));
  716. responseData.result = "false";
  717. return responseData;
  718. }
  719. //西门子系统上传
  720. if (deviceFtp != null)
  721. {
  722. FtpClient ftpClient = new DeviceFtp().Connect(ftpUrlContext, ftpUserContext, ftpPwdContext);
  723. ftpClient.Get(req.data.fileName, LocalPath, req.data.fileName);
  724. ftpClient.DisConnect();
  725. try
  726. {
  727. DeviceSFTP sftp = new DeviceSFTP(deviceFtp.Ip, deviceFtp.Port, deviceFtp.UserName, deviceFtp.Password);
  728. bool ifcon = sftp.Connect();
  729. if (ifcon)
  730. {
  731. sftp.Put(LocalPath + "\\" + req.data.fileName, req.data.remotePath + req.data.fileName);
  732. sftp.Disconnect();
  733. }
  734. }
  735. catch (Exception exscp)
  736. {
  737. Log.Instance.WriteLogAdd(ActionTypeEnum.UploadFile + "上传异常,scp连接失败," + exscp.Message + "," + JsonConvert.SerializeObject(req),
  738. EnumHelper.GetDescription(ActionTypeEnum.UploadFile));
  739. responseData.result = "false";
  740. return responseData;
  741. }
  742. }
  743. else if (deviceFanuc != null)
  744. {
  745. Regex regex = new Regex(@"^(?<fpath>([a-zA-Z]:\\)([\s\.\-\w]+\\)*)(?<fname>[\w]+)(?<namext>(\.[\w]+)*)(?<suffix>\.[\w]+)");
  746. Match result = regex.Match(req.data.fileName);
  747. string strResult = result.Success ? result.Result("${fname}") + result.Result("${suffix}"): req.data.fileName;
  748. string Url = fanucUrlContext + "?ip=" + deviceFanuc.Ip + "&port=" + deviceFanuc.Port + "&prgname=" + strResult;
  749. //调用发那科上传接口
  750. var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Get, Url + "&fun=" + ActionTypeEnum.UploadFile.ToString(), null, null);
  751. if (!Result.IsSuccess)
  752. {
  753. Log.Instance.WriteLogAdd(ActionTypeEnum.UploadFile + "上传异常,scp连接失败," + Result.Message + "," + JsonConvert.SerializeObject(req),
  754. EnumHelper.GetDescription(ActionTypeEnum.UploadFile));
  755. responseData.result = "false";
  756. return responseData;
  757. }
  758. }else if(deviceHeidenhain != null)
  759. {
  760. RequestHeidhData hdhReq = new RequestHeidhData();
  761. hdhReq.ServerUrl = deviceHeidenhain.ServerUrl;
  762. hdhReq.MachineName = deviceHeidenhain.UserName;
  763. hdhReq.Path = req.data.fileName;
  764. hdhReq.Type = OpcUaActionTypeEnum.Upload.ToString();
  765. var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, hdhUrlContext, hdhReq, null);
  766. ResponseHeidhData responseHeidhData = JsonConvert.DeserializeObject<ResponseHeidhData>(Result.Message);
  767. if (!Result.IsSuccess || !responseHeidhData.result)
  768. {
  769. Log.Instance.WriteLogAdd(ActionTypeEnum.UploadFile + "上传异常===>>" + JsonConvert.SerializeObject(req),
  770. EnumHelper.GetDescription(ActionTypeEnum.UploadFile));
  771. responseData.result = "false";
  772. return responseData;
  773. }
  774. }
  775. //插入回调
  776. TaskCallback taskCallbackData = new TaskCallback(req.url, ActionTypeEnum.UploadFile.ToString(),
  777. EnumHelper.GetDescription(ActionTypeEnum.UploadFile), req.taskId, req.taskNodeId);
  778. await _taskCallbackService.CreateOrUpdateAndCache(taskCallbackData);
  779. Log.Instance.WriteLogAdd(ActionTypeEnum.UploadFile + "上传成功===>>" + JsonConvert.SerializeObject(req),
  780. EnumHelper.GetDescription(ActionTypeEnum.UploadFile));
  781. return responseData;
  782. }
  783. catch (Exception ex)
  784. {
  785. Log.Instance.WriteLogAdd(ActionTypeEnum.UploadFile + "上传异常===>>" + ex.Message + JsonConvert.SerializeObject(req),
  786. EnumHelper.GetDescription(ActionTypeEnum.UploadFile));
  787. responseData.result = "false";
  788. return responseData;
  789. }
  790. }
  791. /// <summary>
  792. /// 启动机床程序
  793. /// </summary>
  794. public async Task<ResponseECSData> StartNCProgram(RequestData<StartNCProgramData> req)
  795. {
  796. ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId);
  797. try
  798. {
  799. List<Device> devices = _deviceService.GetDeviceList();
  800. Device device = devices.Where(x => x.Ip.Equals(req.url) && x.Port.Equals(req.port)).FirstOrDefault();
  801. if (device == null)
  802. {
  803. Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "设备已离线===>>" + JsonConvert.SerializeObject(req),
  804. EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));
  805. responseData.result = "false";
  806. return responseData;
  807. }
  808. CcsAction actionQuery = new CcsAction();
  809. actionQuery.OperateType = ActionTypeEnum.StartNCProgram.ToString();
  810. actionQuery.Ip = req.url;
  811. CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault();
  812. CcsActionAddress actionAddressQuery = new CcsActionAddress();
  813. actionAddressQuery.ActionId = actionInfo.Id;
  814. List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);
  815. //opcua启动程序
  816. if (actionInfo.ProtocolType == ProtocalTypeEnum.OPCUA.ToString())
  817. {
  818. RequestOpcUaData opcUaReq = new RequestOpcUaData();
  819. opcUaReq.ServerUrl = device.ServerUrl;
  820. opcUaReq.UserName = device.UserName;
  821. opcUaReq.Password = device.Password;
  822. opcUaReq.Path = actionInfo.FilePath + req.data.remotePath;
  823. opcUaReq.Type = OpcUaActionTypeEnum.Connect.ToString();
  824. var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, opcuacUrlContext, opcUaReq, null);
  825. ResponseOpcUaData responseOpcUaData = JsonConvert.DeserializeObject<ResponseOpcUaData>(Result.Message);
  826. if (Result.IsSuccess && responseOpcUaData.result)
  827. {
  828. Thread.Sleep(1000);
  829. List<CcsActionAddress> CcsActionAddressChecks = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CHECK.ToString()).ToList();
  830. if (CcsActionAddressChecks != null)
  831. {
  832. List<string> checkAddresses = CcsActionAddressChecks.Select(t => t.Address).ToList();
  833. opcUaReq.Type = OpcUaActionTypeEnum.Read.ToString();
  834. opcUaReq.Addresses = checkAddresses;
  835. Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, opcuacUrlContext, opcUaReq, null);
  836. responseOpcUaData = JsonConvert.DeserializeObject<ResponseOpcUaData>(Result.Message);
  837. if (Result.IsSuccess && responseOpcUaData.result)
  838. {
  839. //条件校验
  840. for (int i = 0; i < CcsActionAddressChecks.Count; i++)
  841. {
  842. CcsActionAddress checkActionAddress = CcsActionAddressChecks[i];
  843. string checkValue = responseOpcUaData.values[i];
  844. if (checkValue != checkActionAddress.Value)
  845. {
  846. Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "启动异常===>>" + JsonConvert.SerializeObject(req),
  847. EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));
  848. responseData.result = "false";
  849. return responseData;
  850. }
  851. }
  852. }
  853. }
  854. List<CcsActionAddress> CcsActionAddressWrites = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.WRITE.ToString()).ToList();
  855. List<string> writeAddresses = CcsActionAddressWrites.Select(t => t.Address).ToList();
  856. List<string> writeValues = CcsActionAddressWrites.Select(t => t.Value).ToList();
  857. opcUaReq.Type = OpcUaActionTypeEnum.Write.ToString();
  858. opcUaReq.Addresses = writeAddresses;
  859. opcUaReq.Values = writeValues;
  860. /*opcUaReq.Addresses = new List<string>() { actionInfo.Address };
  861. opcUaReq.Values = new List<string>() { "True" };*/
  862. Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, opcuacUrlContext, opcUaReq, null);
  863. responseOpcUaData = JsonConvert.DeserializeObject<ResponseOpcUaData>(Result.Message);
  864. if (Result.IsSuccess && responseOpcUaData.result)
  865. {
  866. //插入回调
  867. TaskCallback taskCallbackData = new TaskCallback(req.url, ActionTypeEnum.StartNCProgram.ToString(),
  868. EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram), req.taskId, req.taskNodeId);
  869. await _taskCallbackService.CreateOrUpdateAndCache(setCallBackValue(CcsActionAddresses, taskCallbackData));
  870. Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "启动成功===>>" + JsonConvert.SerializeObject(req),
  871. EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));
  872. return responseData;
  873. }
  874. else
  875. {
  876. Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "启动异常===>>" + JsonConvert.SerializeObject(req),
  877. EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));
  878. responseData.result = "false";
  879. return responseData;
  880. }
  881. }
  882. else
  883. {
  884. Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "启动异常===>>" + JsonConvert.SerializeObject(req),
  885. EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));
  886. responseData.result = "false";
  887. return responseData;
  888. }
  889. }
  890. /* else if (actionInfo.ProtocolType == ProtocalTypeEnum.FANUC.ToString())
  891. {
  892. string Url = fanucUrlContext + "?ip=" + device.Ip + "&port=" + device.Port;
  893. //调用发那科是否连接接口
  894. var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Get, Url + "&fun=" + ActionTypeEnum.StartNCProgram.ToString()+ "&prgname="+req.data.remotePath, null, null);
  895. if (Result.IsSuccess && Result.Message == "0")
  896. {
  897. //插入回调
  898. TaskCallback taskCallbackData = new TaskCallback(req.url, ActionTypeEnum.StartNCProgram.ToString(),
  899. EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram), req.taskId, req.taskNodeId);
  900. await _taskCallbackService.CreateOrUpdateAndCache(setCallBackValue(CcsActionAddresses, taskCallbackData));
  901. Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "启动成功===>>" + JsonConvert.SerializeObject(req),
  902. EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));
  903. return responseData;
  904. }
  905. else
  906. {
  907. Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "启动异常===>>" + JsonConvert.SerializeObject(req),
  908. EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));
  909. responseData.result = "false";
  910. return responseData;
  911. }
  912. }*/
  913. else if (actionInfo.ProtocolType == ProtocalTypeEnum.FANUC.ToString())
  914. {
  915. string Url = fanucUrlContext + "?ip=" + device.Ip + "&port=" + device.Port;
  916. //调用发那科是否连接接口
  917. var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Get, Url + "&fun=" + OpcUaActionTypeEnum.SelectNcProgram.ToString()+"&prgname=" + req.data.remotePath, null, null);
  918. if(!Result.IsSuccess || Result.Message != "0")
  919. {
  920. Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "启动程序异常===>>" + JsonConvert.SerializeObject(req),
  921. EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));
  922. responseData.result = "false";
  923. return responseData;
  924. }
  925. //Plc s7 = DevicePlcS7.S7(actionInfo.PlcIp, ProtocalTypeEnum.S7_1500.ToString());
  926. SiemensS7Net s7 = DevicePlcS7.SiemensS7(actionInfo.PlcIp);
  927. OperateResult ConnectionResult = s7.ConnectServer();
  928. if (!ConnectionResult.IsSuccess)
  929. {
  930. s7.ConnectClose();
  931. Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "启动程序异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
  932. EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));
  933. responseData.result = "false";
  934. return responseData;
  935. }
  936. /*
  937. if (s7.IsConnected != true)
  938. {
  939. s7.Close();
  940. Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "启动程序异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
  941. EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));
  942. responseData.result = "false";
  943. return responseData;
  944. }*/
  945. //查询条件
  946. List<CcsActionAddress> CcsActionAddressChecks = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CHECK.ToString()).ToList();
  947. foreach (CcsActionAddress actionAddress in CcsActionAddressChecks)
  948. {
  949. if (!string.IsNullOrEmpty(actionAddress.Address) && !string.IsNullOrEmpty(actionAddress.Value))
  950. {
  951. string CheckAddress = ToolUtils.AddressConvertDBW(actionAddress.Address);
  952. var operateResult = s7.ReadInt16(CheckAddress).Content.ToString();
  953. if (actionAddress.CheckType ? operateResult.ToString().Equals(actionAddress.Value) : operateResult.ToString() != actionAddress.Value)
  954. {
  955. s7.ConnectClose();
  956. Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "启动程序异常===>>" + "条件不满足" + JsonConvert.SerializeObject(req),
  957. EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));
  958. responseData.result = "false";
  959. return responseData;
  960. }
  961. }
  962. }
  963. //查询写入地址列表
  964. List<CcsActionAddress> CcsActionAddressWrites = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.WRITE.ToString()).ToList();
  965. foreach (CcsActionAddress actionAddress in CcsActionAddressWrites)
  966. {
  967. if (!string.IsNullOrEmpty(actionAddress.Address))
  968. {
  969. string Address = ToolUtils.AddressConvertDBW(actionAddress.Address);
  970. s7.Write(actionAddress.Address, Convert.ToInt16(actionAddress.Value));
  971. Thread.Sleep(SLEEP_TIME);
  972. }
  973. }
  974. s7.ConnectClose();
  975. //插入回调
  976. TaskCallback taskCallbackData = new TaskCallback(req.url, ActionTypeEnum.StartNCProgram.ToString(),
  977. EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram), req.taskId, req.taskNodeId);
  978. await _taskCallbackService.CreateOrUpdateAndCache(setCallBackValue(CcsActionAddresses, taskCallbackData));
  979. Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "启动成功===>>" + JsonConvert.SerializeObject(req),
  980. EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));
  981. return responseData;
  982. }
  983. else if (actionInfo.ProtocolType == ProtocalTypeEnum.HEIDEHAIN.ToString())
  984. {
  985. RequestHeidhData hdhReq = new RequestHeidhData();
  986. hdhReq.ServerUrl = device.ServerUrl;
  987. hdhReq.MachineName = device.UserName;
  988. hdhReq.Path = req.data.remotePath;
  989. hdhReq.Type = OpcUaActionTypeEnum.SelectNcProgram.ToString();
  990. /*var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, hdhUrlContext, hdhReq, null);
  991. ResponseHeidhData responseHeidhData = JsonConvert.DeserializeObject<ResponseHeidhData>(Result.Message);
  992. if (!Result.IsSuccess || !responseHeidhData.result)
  993. {
  994. Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "启动程序异常===>>" + JsonConvert.SerializeObject(req),
  995. EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));
  996. responseData.result = "false";
  997. return responseData;
  998. }*/
  999. //调用机器人plc启动海德汉程序
  1000. // Plc s7 = DevicePlcS7.S7(actionInfo.PlcIp, ProtocalTypeEnum.S7_1500.ToString());
  1001. SiemensS7Net s7 = DevicePlcS7.SiemensS7(actionInfo.PlcIp);
  1002. OperateResult ConnectionResult = s7.ConnectServer();
  1003. if (!ConnectionResult.IsSuccess)
  1004. {
  1005. s7.ConnectClose();
  1006. Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "启动程序异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
  1007. EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));
  1008. responseData.result = "false";
  1009. return responseData;
  1010. }
  1011. //查询条件
  1012. List<CcsActionAddress> CcsActionAddressChecks = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CHECK.ToString()).ToList();
  1013. foreach (CcsActionAddress actionAddress in CcsActionAddressChecks)
  1014. {
  1015. if (!string.IsNullOrEmpty(actionAddress.Address) && !string.IsNullOrEmpty(actionAddress.Value))
  1016. {
  1017. string CheckAddress = ToolUtils.AddressConvertDBW(actionAddress.Address);
  1018. string operateResult = s7.ReadInt16(CheckAddress).Content.ToString();
  1019. if (actionAddress.CheckType ? operateResult.Equals(actionAddress.Value) : operateResult != actionAddress.Value)
  1020. {
  1021. s7.ConnectClose();
  1022. Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "启动程序异常===>>" + "条件不满足" + JsonConvert.SerializeObject(req),
  1023. EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));
  1024. responseData.result = "false";
  1025. return responseData;
  1026. }
  1027. }
  1028. }
  1029. //查询写入地址列表
  1030. List<CcsActionAddress> CcsActionAddressWrites = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.WRITE.ToString()).ToList();
  1031. if(CcsActionAddressWrites.Count < 2)
  1032. {
  1033. s7.ConnectClose();
  1034. Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "启动程序异常===>>" + "地址错误" + JsonConvert.SerializeObject(req),
  1035. EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));
  1036. responseData.result = "false";
  1037. return responseData;
  1038. }
  1039. //写入程序编号
  1040. //s7.Write(CcsActionAddressWrites[0].Address, Convert.ToInt16("0"));
  1041. string prgNo = !string.IsNullOrEmpty(req.data.remotePath)? req.data.remotePath.Substring(0, req.data.remotePath.Length-2) : CcsActionAddressWrites[0].Value;
  1042. s7.Write(CcsActionAddressWrites[0].Address, Convert.ToInt16(prgNo));
  1043. CcsActionAddress CcsActionAddressWriteCheck = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.WRITE_CHECK.ToString()).FirstOrDefault();
  1044. DateTime start_time = DateTime.Now;
  1045. Boolean isTimeOut = false;
  1046. while (s7.ReadInt16(CcsActionAddressWriteCheck.Address).Content.ToString().Equals("0"))
  1047. {
  1048. //等待条件满足继续下发
  1049. if (DateTime.Now.Subtract(start_time).TotalSeconds > 60)
  1050. {
  1051. isTimeOut = true;
  1052. break;
  1053. }
  1054. s7.Write(CcsActionAddressWrites[0].Address, Convert.ToInt16(prgNo));
  1055. }
  1056. //Thread.Sleep(30000);
  1057. if (isTimeOut)
  1058. {
  1059. s7.Write(CcsActionAddressWrites[0].Address, Convert.ToInt16("0"));
  1060. s7.Write(CcsActionAddressWriteCheck.Address, Convert.ToInt16("0"));
  1061. throw new Exception("等待手动操作超时异常");
  1062. }
  1063. //写入程序启动信号
  1064. //string StartAddress = ToolUtils.AddressConvertDBW("DB200.314");
  1065. //s7.Write(CcsActionAddressWrites[1].Address, Convert.ToInt16("3"));
  1066. //重置清零
  1067. //
  1068. Thread.Sleep(2000);
  1069. s7.Write(CcsActionAddressWrites[1].Address, Convert.ToInt16(CcsActionAddressWrites[1].Value) );
  1070. s7.Write(CcsActionAddressWrites[0].Address, Convert.ToInt16("0"));
  1071. s7.Write(CcsActionAddressWriteCheck.Address, Convert.ToInt16("0"));
  1072. s7.ConnectClose();
  1073. /*DateTime beginTime = DateTime.Now;
  1074. while (true)
  1075. {
  1076. CcsActionAddress CcsActionAddressWriteCheck = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.WRITE_CHECK.ToString()).FirstOrDefault();
  1077. if (CcsActionAddressWriteCheck != null)
  1078. {
  1079. string WriteCheckAddress = ToolUtils.AddressConvertDBW(CcsActionAddressWriteCheck.Address);
  1080. var operateResult = ((ushort)s7.Read(WriteCheckAddress)).ConvertToShort();
  1081. if (operateResult.ToString() == CcsActionAddressWriteCheck.Value)
  1082. {
  1083. break;
  1084. }
  1085. }
  1086. if (DateTime.Now.Subtract(beginTime).TotalMinutes > 1)
  1087. {
  1088. s7.Close();
  1089. Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "启动程序异常===>>" + "程序编号没有应用" + JsonConvert.SerializeObject(req),
  1090. EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));
  1091. responseData.result = "false";
  1092. return responseData;
  1093. }
  1094. }*/
  1095. //插入回调
  1096. TaskCallback taskCallbackData = new TaskCallback(req.url, ActionTypeEnum.StartNCProgram.ToString(),
  1097. EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram), req.taskId, req.taskNodeId);
  1098. await _taskCallbackService.CreateOrUpdateAndCache(setCallBackValue(CcsActionAddresses, taskCallbackData));
  1099. Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "启动成功===>>" + JsonConvert.SerializeObject(req),
  1100. EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));
  1101. return responseData;
  1102. }
  1103. else
  1104. {
  1105. Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "启动异常===>>" + JsonConvert.SerializeObject(req),
  1106. EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));
  1107. responseData.result = "false";
  1108. return responseData;
  1109. }
  1110. }
  1111. catch (Exception ex)
  1112. {
  1113. Log.Instance.WriteLogAdd(ActionTypeEnum.StartNCProgram + "程序异常===>>" + ex.Message + JsonConvert.SerializeObject(req),
  1114. EnumHelper.GetDescription(ActionTypeEnum.StartNCProgram));
  1115. responseData.result = "false";
  1116. return responseData;
  1117. }
  1118. }
  1119. /// <summary>
  1120. /// 粗偏写入
  1121. /// </summary>
  1122. public async Task<ResponseECSData> SendLinShift(RequestData<SendLinShiftData> req)
  1123. {
  1124. ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId);
  1125. try
  1126. {
  1127. List<Device> devices = _deviceService.GetDeviceList();
  1128. Device device = devices.Where(x => x.Ip.Equals(req.url) && x.Port.Equals(req.port)).FirstOrDefault();
  1129. if (device == null)
  1130. {
  1131. Log.Instance.WriteLogAdd(ActionTypeEnum.SendLinShift + "设备已离线===>>" + JsonConvert.SerializeObject(req),
  1132. EnumHelper.GetDescription(ActionTypeEnum.SendLinShift));
  1133. responseData.result = "false";
  1134. return responseData;
  1135. }
  1136. CcsAction actionQuery = new CcsAction();
  1137. actionQuery.OperateType = ActionTypeEnum.SendLinShift.ToString();
  1138. actionQuery.Ip = req.url;
  1139. CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault();
  1140. DeviceOPCUat opcUa = new DeviceOPCUat(device.ServerUrl, device.UserName, device.Password);
  1141. Thread.Sleep(500);
  1142. if (opcUa.IsConnection)
  1143. {
  1144. List<string> Tags = new List<string>();
  1145. string TagName = "";// actionInfo.Address;
  1146. string OpcTagNameX = TagName + "01]";
  1147. Tags.Add(OpcTagNameX);
  1148. string OpcTagNameY = TagName + "02]";
  1149. Tags.Add(OpcTagNameY);
  1150. string OpcTagNameZ = TagName + "03]";
  1151. Tags.Add(OpcTagNameZ);
  1152. string OpcTagNameA = TagName + "04]";
  1153. Tags.Add(OpcTagNameA);
  1154. string OpcTagNameB = TagName + "05]";
  1155. Tags.Add(OpcTagNameB);
  1156. List<string> values = new List<string>();
  1157. values.Add(req.data.X);
  1158. values.Add(req.data.Y);
  1159. values.Add(req.data.Z);
  1160. values.Add(req.data.A);
  1161. values.Add(req.data.B);
  1162. opcUa.OpcUa_WriteValue(values, Tags);
  1163. opcUa.disConnect();
  1164. //插入回调
  1165. TaskCallback taskCallbackData = new TaskCallback(req.url, ActionTypeEnum.SendLinShift.ToString(),
  1166. EnumHelper.GetDescription(ActionTypeEnum.SendLinShift), req.taskId, req.taskNodeId);
  1167. Log.Instance.WriteLogAdd(ActionTypeEnum.SendLinShift + "粗偏写入成功===>>" + JsonConvert.SerializeObject(req),
  1168. EnumHelper.GetDescription(ActionTypeEnum.SendLinShift));
  1169. return responseData;
  1170. }
  1171. else
  1172. {
  1173. Log.Instance.WriteLogAdd(ActionTypeEnum.SendLinShift + "粗偏写入异常===>>" + JsonConvert.SerializeObject(req),
  1174. EnumHelper.GetDescription(ActionTypeEnum.SendLinShift));
  1175. responseData.result = "false";
  1176. return responseData;
  1177. }
  1178. }
  1179. catch (Exception ex)
  1180. {
  1181. Log.Instance.WriteLogAdd(ActionTypeEnum.SendLinShift + "粗偏写入异常===>>" + ex.Message + JsonConvert.SerializeObject(req),
  1182. EnumHelper.GetDescription(ActionTypeEnum.SendLinShift));
  1183. responseData.result = "false";
  1184. return responseData;
  1185. }
  1186. }
  1187. /// <summary>
  1188. /// 精偏写入
  1189. /// </summary>
  1190. public async Task<ResponseECSData> SendLinShiftFine(RequestData<SendLinShiftData> req)
  1191. {
  1192. ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId);
  1193. try
  1194. {
  1195. List<Device> devices = _deviceService.GetDeviceList();
  1196. Device device = devices.Where(x => x.Ip.Equals(req.url) && x.Port.Equals(req.port)).FirstOrDefault();
  1197. if (device == null)
  1198. {
  1199. Log.Instance.WriteLogAdd(ActionTypeEnum.SendLinShiftFine + "设备已离线===>>" + JsonConvert.SerializeObject(req),
  1200. EnumHelper.GetDescription(ActionTypeEnum.SendLinShiftFine));
  1201. responseData.result = "false";
  1202. return responseData;
  1203. }
  1204. CcsAction actionQuery = new CcsAction();
  1205. actionQuery.OperateType = ActionTypeEnum.SendLinShiftFine.ToString();
  1206. actionQuery.Ip = req.url;
  1207. CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault();
  1208. DeviceOPCUat opcUa = new DeviceOPCUat(device.ServerUrl, device.UserName, device.Password);
  1209. Thread.Sleep(500);
  1210. if (opcUa.IsConnection)
  1211. {
  1212. List<string> Tags = new List<string>();
  1213. string TagName = "";// actionInfo.Address;
  1214. string OpcTagNameX = TagName + "06]";
  1215. Tags.Add(OpcTagNameX);
  1216. string OpcTagNameY = TagName + "07]";
  1217. Tags.Add(OpcTagNameY);
  1218. string OpcTagNameZ = TagName + "08]";
  1219. Tags.Add(OpcTagNameZ);
  1220. string OpcTagNameA = TagName + "09]";
  1221. Tags.Add(OpcTagNameA);
  1222. string OpcTagNameB = TagName + "10]";
  1223. Tags.Add(OpcTagNameB);
  1224. Tags.Add(OpcTagNameB);
  1225. List<string> values = new List<string>();
  1226. values.Add(req.data.X);
  1227. values.Add(req.data.Y);
  1228. values.Add(req.data.Z);
  1229. values.Add(req.data.A);
  1230. values.Add(req.data.B);
  1231. opcUa.OpcUa_WriteValue(values, Tags);
  1232. opcUa.disConnect();
  1233. //插入回调
  1234. TaskCallback taskCallbackData = new TaskCallback(req.url, ActionTypeEnum.SendLinShift.ToString(),
  1235. EnumHelper.GetDescription(ActionTypeEnum.SendLinShiftFine), req.taskId, req.taskNodeId);
  1236. Log.Instance.WriteLogAdd(ActionTypeEnum.SendLinShiftFine + "精偏写入成功===>>" + JsonConvert.SerializeObject(req),
  1237. EnumHelper.GetDescription(ActionTypeEnum.SendLinShiftFine));
  1238. return responseData;
  1239. }
  1240. else
  1241. {
  1242. Log.Instance.WriteLogAdd(ActionTypeEnum.SendLinShiftFine + "精偏写入异常===>>" + JsonConvert.SerializeObject(req),
  1243. EnumHelper.GetDescription(ActionTypeEnum.SendLinShiftFine));
  1244. responseData.result = "false";
  1245. return responseData;
  1246. }
  1247. }
  1248. catch (Exception ex)
  1249. {
  1250. Log.Instance.WriteLogAdd(ActionTypeEnum.SendLinShiftFine + "精偏写入异常===>>" + ex.Message + JsonConvert.SerializeObject(req),
  1251. EnumHelper.GetDescription(ActionTypeEnum.SendLinShiftFine));
  1252. responseData.result = "false";
  1253. return responseData;
  1254. }
  1255. }
  1256. /// <summary>
  1257. /// 启动清洗机
  1258. /// </summary>
  1259. public async Task<ResponseECSData> StartCleanMachine(RequestData<object> req)
  1260. {
  1261. ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId);
  1262. try
  1263. {
  1264. List<Device> devices = _deviceService.GetDeviceList();
  1265. Device device = devices.Where(x => x.Ip.Equals(req.url) && x.Port.Equals(req.port)).FirstOrDefault();
  1266. if (device == null)
  1267. {
  1268. Log.Instance.WriteLogAdd(ActionTypeEnum.StartCleanMachine + "设备已离线===>>" + JsonConvert.SerializeObject(req),
  1269. EnumHelper.GetDescription(ActionTypeEnum.StartCleanMachine));
  1270. responseData.result = "false";
  1271. return responseData;
  1272. }
  1273. CcsAction actionQuery = new CcsAction();
  1274. actionQuery.OperateType = ActionTypeEnum.StartCleanMachine.ToString();
  1275. actionQuery.Ip = req.url;
  1276. CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault();
  1277. SiemensS7Net s7 = DevicePlcS7.SiemensS7(req.url);
  1278. HslCommunication.OperateResult ConnectionResult = s7.ConnectServer();
  1279. if (!ConnectionResult.IsSuccess)
  1280. {
  1281. s7.ConnectClose();
  1282. Log.Instance.WriteLogAdd(ActionTypeEnum.StartCleanMachine + "启动故障===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
  1283. EnumHelper.GetDescription(ActionTypeEnum.StartCleanMachine));
  1284. responseData.result = "false";
  1285. return responseData;
  1286. }
  1287. CcsActionAddress actionAddressQuery = new CcsActionAddress();
  1288. actionAddressQuery.ActionId = actionInfo.Id;
  1289. List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);
  1290. //查询条件
  1291. List<CcsActionAddress> CcsActionAddressChecks = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CHECK.ToString()).ToList();
  1292. /*foreach (CcsActionAddress actionAddress in CcsActionAddressChecks)
  1293. {
  1294. if (!string.IsNullOrEmpty(actionAddress.Address) && !string.IsNullOrEmpty(actionAddress.Value))
  1295. {
  1296. string CheckAddress = ToolUtils.AddressConvertDBW(actionAddress.Address);
  1297. var operateResult = s7.ReadBool(CheckAddress);
  1298. if (actionAddress.CheckType ? operateResult.ToString().Equals(actionAddress.Value) : operateResult.ToString() != actionAddress.Value)
  1299. {
  1300. s7.ConnectClose();
  1301. Log.Instance.WriteLogAdd(ActionTypeEnum.StartCleanMachine + "启动异常===>>" + "条件不满足" + JsonConvert.SerializeObject(req),
  1302. EnumHelper.GetDescription(ActionTypeEnum.StartCleanMachine));
  1303. responseData.result = "false";
  1304. return responseData;
  1305. }
  1306. }
  1307. }
  1308. //查询写入地址列表
  1309. List<CcsActionAddress> CcsActionAddressWrites = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.WRITE.ToString()).ToList();
  1310. foreach (CcsActionAddress actionAddress in CcsActionAddressWrites)
  1311. {
  1312. if (!string.IsNullOrEmpty(actionAddress.Address))
  1313. {
  1314. s7.Write(actionAddress.Address, Convert.ToInt16(actionAddress.Value));
  1315. Thread.Sleep(200);
  1316. }
  1317. }*/
  1318. s7.ConnectClose();
  1319. //插入回调
  1320. TaskCallback taskCallbackData = new TaskCallback(req.url, ActionTypeEnum.StartCleanMachine.ToString(),
  1321. EnumHelper.GetDescription(ActionTypeEnum.StartCleanMachine), req.taskId, req.taskNodeId);
  1322. await _taskCallbackService.CreateOrUpdateAndCache(setCallBackValue(CcsActionAddresses, taskCallbackData));
  1323. Log.Instance.WriteLogAdd(EnumHelper.GetDescription(ActionTypeEnum.StartCleanMachine) + "启动成功===>>" + JsonConvert.SerializeObject(req)
  1324. , EnumHelper.GetDescription(ActionTypeEnum.StartCleanMachine));
  1325. return responseData;
  1326. }
  1327. catch (Exception ex)
  1328. {
  1329. Log.Instance.WriteLogAdd(ActionTypeEnum.StartCleanMachine + "启动故障===>>" + ex.Message + JsonConvert.SerializeObject(req),
  1330. EnumHelper.GetDescription(ActionTypeEnum.StartCleanMachine));
  1331. responseData.result = "false";
  1332. return responseData;
  1333. }
  1334. }
  1335. /// <summary>
  1336. /// 启动打标机
  1337. /// </summary>
  1338. public async Task<ResponseECSData> StartLabelMachine(RequestData<LabelData> req)
  1339. {
  1340. ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId);
  1341. try
  1342. {
  1343. List<Device> devices = _deviceService.GetDeviceList();
  1344. Device device = devices.Where(x => x.Ip.Equals(req.url) && x.Port.Equals(req.port)).FirstOrDefault();
  1345. if (device == null)
  1346. {
  1347. Log.Instance.WriteLogAdd(ActionTypeEnum.StartLabelMachine + "设备已离线===>>" + JsonConvert.SerializeObject(req),
  1348. EnumHelper.GetDescription(ActionTypeEnum.StartLabelMachine));
  1349. responseData.result = "false";
  1350. return responseData;
  1351. }
  1352. CcsAction actionQuery = new CcsAction();
  1353. actionQuery.OperateType = ActionTypeEnum.StartLabelMachine.ToString();
  1354. actionQuery.Ip = req.url;
  1355. List<CcsAction> actions = _ccsActionService.GetList(actionQuery);
  1356. CcsAction actionInfo = actions[0];
  1357. string TypeNo = req.data.TypeNo;
  1358. string SmallTypeNo = req.data.SmallTypeNo;
  1359. string OrderNo = req.data.OrderNo;
  1360. string TaskNo = req.data.TaskNo;
  1361. string ProductNo = req.data.TaskNo;
  1362. string BatchNo = req.data.BatchNo;
  1363. string SerialNo = req.data.SerialNo;
  1364. SiemensS7Net s7 = DevicePlcS7.SiemensS7(req.url);
  1365. HslCommunication.OperateResult ConnectionResult = s7.ConnectServer();
  1366. if (!ConnectionResult.IsSuccess)
  1367. {
  1368. s7.ConnectClose();
  1369. Log.Instance.WriteLogAdd(ActionTypeEnum.StartLabelMachine + "启动打标机异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
  1370. EnumHelper.GetDescription(ActionTypeEnum.StartLabelMachine));
  1371. responseData.result = "false";
  1372. return responseData;
  1373. }
  1374. CcsActionAddress actionAddressQuery = new CcsActionAddress();
  1375. actionAddressQuery.ActionId = actionInfo.Id;
  1376. List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);
  1377. //查询写入地址列表
  1378. List<CcsActionAddress> CcsActionAddressWrites = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.WRITE.ToString()).ToList();
  1379. foreach (CcsActionAddress actionAddress in CcsActionAddressWrites)
  1380. {
  1381. if (!string.IsNullOrEmpty(actionAddress.Address))
  1382. {
  1383. if (actionAddress.Sort == 1)
  1384. {
  1385. s7.Write(actionAddress.Address, ToolUtils.ReturnBtyesWtitString(TypeNo));
  1386. }else if (actionAddress.Sort == 2)
  1387. {
  1388. s7.Write(actionAddress.Address, ToolUtils.ReturnBtyesWtitString(SmallTypeNo));
  1389. }
  1390. else if (actionAddress.Sort == 3)
  1391. {
  1392. s7.Write(actionAddress.Address, ToolUtils.ReturnBtyesWtitString(OrderNo, 128));
  1393. }
  1394. else if (actionAddress.Sort == 4)
  1395. {
  1396. s7.Write(actionAddress.Address, ToolUtils.ReturnBtyesWtitString(TaskNo, 128));
  1397. }
  1398. else if (actionAddress.Sort == 5)
  1399. {
  1400. s7.Write(actionAddress.Address, ToolUtils.ReturnBtyesWtitString(ProductNo, 128));
  1401. }
  1402. else if (actionAddress.Sort == 6)
  1403. {
  1404. s7.Write(actionAddress.Address, ToolUtils.ReturnBtyesWtitString(BatchNo, 32));
  1405. }
  1406. else if (actionAddress.Sort == 7)
  1407. {
  1408. s7.Write(actionAddress.Address, ToolUtils.ReturnBtyesWtitString(SerialNo, 100));
  1409. }
  1410. else if (actionAddress.Sort == 8 || actionAddress.Sort == 9)
  1411. {
  1412. s7.Write(actionAddress.Address, Convert.ToInt16(actionAddress.Value));
  1413. }
  1414. Thread.Sleep(100);
  1415. }
  1416. }
  1417. s7.ConnectClose();
  1418. //插入回调
  1419. TaskCallback taskCallbackData = new TaskCallback(req.url, ActionTypeEnum.StartLabelMachine.ToString(),
  1420. EnumHelper.GetDescription(ActionTypeEnum.StartLabelMachine), req.taskId, req.taskNodeId);
  1421. await _taskCallbackService.CreateOrUpdateAndCache(setCallBackValue(CcsActionAddresses, taskCallbackData));
  1422. Log.Instance.WriteLogAdd(EnumHelper.GetDescription(ActionTypeEnum.StartLabelMachine) + "启动打标机成功===>>" + JsonConvert.SerializeObject(req)
  1423. , EnumHelper.GetDescription(ActionTypeEnum.StartLabelMachine));
  1424. return responseData;
  1425. }
  1426. catch (Exception ex)
  1427. {
  1428. Log.Instance.WriteLogAdd(ActionTypeEnum.StartLabelMachine + "启动打标机故障===>>" + ex.Message + JsonConvert.SerializeObject(req),
  1429. EnumHelper.GetDescription(ActionTypeEnum.StartLabelMachine));
  1430. responseData.result = "false";
  1431. return responseData;
  1432. }
  1433. }
  1434. /// <summary>
  1435. /// 查询三坐标检测空闲位置
  1436. /// </summary>
  1437. public async Task<ResponseECSData> QueryThreeCoordinatesFreePos(RequestToolData req)
  1438. {
  1439. ResponseECSData responseData = new ResponseECSData("", "");
  1440. try
  1441. {
  1442. List<Device> devices = _deviceService.GetDeviceList();
  1443. Device device = devices.Where(x => x.Ip.Equals(req.url) && x.Port.Equals(req.port)).FirstOrDefault();
  1444. if (device == null)
  1445. {
  1446. Log.Instance.WriteLogAdd(ActionTypeEnum.QueryThreeCoordinatesFreePos + "设备已离线===>>" + JsonConvert.SerializeObject(req),
  1447. EnumHelper.GetDescription(ActionTypeEnum.QueryThreeCoordinatesFreePos));
  1448. responseData.result = "false";
  1449. return responseData;
  1450. }
  1451. CcsAction actionQuery = new CcsAction();
  1452. actionQuery.OperateType = ActionTypeEnum.QueryThreeCoordinatesFreePos.ToString();
  1453. actionQuery.Ip = req.url;
  1454. CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault();
  1455. SiemensS7Net s7 = DevicePlcS7.SiemensS7(req.url);
  1456. HslCommunication.OperateResult ConnectionResult = s7.ConnectServer();
  1457. if (!ConnectionResult.IsSuccess)
  1458. {
  1459. s7.ConnectClose();
  1460. Log.Instance.WriteLogAdd(ActionTypeEnum.QueryThreeCoordinatesFreePos + "查询三坐标检测空闲位置===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
  1461. EnumHelper.GetDescription(ActionTypeEnum.QueryThreeCoordinatesFreePos));
  1462. responseData.result = "false";
  1463. return responseData;
  1464. }
  1465. CcsActionAddress actionAddressQuery = new CcsActionAddress();
  1466. actionAddressQuery.ActionId = actionInfo.Id;
  1467. List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);
  1468. //初始化为false,否则返回点位
  1469. responseData.result = "false";
  1470. //查询条件
  1471. List<CcsActionAddress> CcsActionAddressChecks = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CHECK.ToString()).ToList();
  1472. foreach (CcsActionAddress actionAddress in CcsActionAddressChecks)
  1473. {
  1474. if (!string.IsNullOrEmpty(actionAddress.Address) && !string.IsNullOrEmpty(actionAddress.Value))
  1475. {
  1476. var operateResult = s7.ReadInt16(actionAddress.Address);
  1477. if (operateResult.Content.ToString() == actionAddress.Value )
  1478. {
  1479. s7.ConnectClose();
  1480. Log.Instance.WriteLogAdd(ActionTypeEnum.QueryThreeCoordinatesFreePos + "三坐标检测空闲位置===>>"+ actionAddress.Address + JsonConvert.SerializeObject(req),
  1481. EnumHelper.GetDescription(ActionTypeEnum.QueryThreeCoordinatesFreePos));
  1482. responseData.result = Enum.GetName(typeof(ThreeCoordinatesPosEnum), actionAddress.Sort); //actionAddress.Address;
  1483. return responseData;
  1484. }
  1485. }
  1486. }
  1487. s7.ConnectClose();
  1488. return responseData;
  1489. }
  1490. catch (Exception ex)
  1491. {
  1492. Log.Instance.WriteLogAdd(ActionTypeEnum.QueryThreeCoordinatesFreePos + "查询三坐标检测空闲位置===>>" + ex.Message + JsonConvert.SerializeObject(req),
  1493. EnumHelper.GetDescription(ActionTypeEnum.QueryThreeCoordinatesFreePos));
  1494. responseData.result = "false";
  1495. return responseData;
  1496. }
  1497. }
  1498. /// <summary>
  1499. /// 放三坐标滑台
  1500. /// </summary>
  1501. public async Task<ResponseECSData> SendThreeCoordinates(RequestData<WorkData> req)
  1502. {
  1503. ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId);
  1504. try
  1505. {
  1506. List<Device> devices = _deviceService.GetDeviceList();
  1507. Device device = devices.Where(x => x.Ip.Equals(req.url) && x.Port.Equals(req.port)).FirstOrDefault();
  1508. if (device == null)
  1509. {
  1510. Log.Instance.WriteLogAdd(ActionTypeEnum.SendThreeCoordinates + "设备已离线===>>" + JsonConvert.SerializeObject(req),
  1511. EnumHelper.GetDescription(ActionTypeEnum.SendThreeCoordinates));
  1512. responseData.result = "false";
  1513. return responseData;
  1514. }
  1515. CcsAction actionQuery = new CcsAction();
  1516. actionQuery.OperateType = ActionTypeEnum.SendThreeCoordinates.ToString();
  1517. actionQuery.Ip = req.url;
  1518. CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault();
  1519. SiemensS7Net s7 = DevicePlcS7.SiemensS7(req.url);
  1520. HslCommunication.OperateResult ConnectionResult = s7.ConnectServer();
  1521. if (!ConnectionResult.IsSuccess)
  1522. {
  1523. s7.ConnectClose();
  1524. Log.Instance.WriteLogAdd(ActionTypeEnum.SendThreeCoordinates + "启动三坐标异常===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
  1525. EnumHelper.GetDescription(ActionTypeEnum.SendThreeCoordinates));
  1526. responseData.result = "false";
  1527. return responseData;
  1528. }
  1529. CcsActionAddress actionAddressQuery = new CcsActionAddress();
  1530. actionAddressQuery.ActionId = actionInfo.Id;
  1531. List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);
  1532. string stationId = req.data.stationId;
  1533. int key = 0;
  1534. if(stationId == "L")
  1535. {
  1536. key = (int)ThreeCoordinatesPosEnum.L;
  1537. }
  1538. else if (stationId == "M")
  1539. {
  1540. key = (int)ThreeCoordinatesPosEnum.M;
  1541. }
  1542. else if (stationId == "R")
  1543. {
  1544. key = (int)ThreeCoordinatesPosEnum.R;
  1545. }
  1546. //根据sort顺序,查询左中右空闲位置,写入地址列表
  1547. List<CcsActionAddress> CcsActionAddressWrites = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.WRITE.ToString() && o.Sort == key).ToList();
  1548. foreach (CcsActionAddress actionAddress in CcsActionAddressWrites)
  1549. {
  1550. if (!string.IsNullOrEmpty(actionAddress.Address))
  1551. {
  1552. if(actionAddress.Value == "workProgramName")
  1553. {
  1554. s7.Write(actionAddress.Address, ToolUtils.ReturnBtyesWtitString(req.data.workProgramName, 40));
  1555. }
  1556. else if (actionAddress.Value == "workId")
  1557. {
  1558. s7.Write(actionAddress.Address, ToolUtils.ReturnBtyesWtitString(req.data.workId, 40));
  1559. }
  1560. else if (actionAddress.Value == "procedureNo")
  1561. {
  1562. s7.Write(actionAddress.Address, ToolUtils.ReturnBtyesWtitString(req.data.procedureNo, 40));
  1563. }
  1564. Thread.Sleep(100);
  1565. }
  1566. }
  1567. //查询写入地址列表
  1568. List<CcsActionAddress> CcsActionAddressWriteSends = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.WRITE_SEND.ToString()).OrderBy(o=>o.Sort).ToList();
  1569. /*s7.Write("DB200.46", Convert.ToInt16(req.data.beginLocation));
  1570. Thread.Sleep(SLEEP_TIME);
  1571. s7.Write("DB200.50", Convert.ToInt16("1"));*/
  1572. /* Thread.Sleep(SLEEP_TIME);
  1573. s7.Write("DB200.48", Convert.ToInt16(req.data.Location));
  1574. Thread.Sleep(SLEEP_TIME);
  1575. s7.Write("DB200.50", Convert.ToInt16("4"));
  1576. Thread.Sleep(2000);*/
  1577. foreach (CcsActionAddress actionAddress in CcsActionAddressWriteSends)
  1578. {
  1579. if (!string.IsNullOrEmpty(actionAddress.Address))
  1580. {
  1581. s7.Write(actionAddress.Address, Convert.ToInt16(string.IsNullOrEmpty(actionAddress.Value) ? req.data.Location : actionAddress.Value));
  1582. Thread.Sleep(SLEEP_TIME);
  1583. }
  1584. }
  1585. s7.ConnectClose();
  1586. //插入回调
  1587. TaskCallback taskCallbackData = new TaskCallback(req.url, ActionTypeEnum.SendThreeCoordinates.ToString(),
  1588. EnumHelper.GetDescription(ActionTypeEnum.SendThreeCoordinates), req.taskId, req.taskNodeId);
  1589. taskCallbackData = setCallBackValue(CcsActionAddresses, taskCallbackData);
  1590. taskCallbackData.Description = stationId;
  1591. taskCallbackData.CallbackFailValue3 = req.data.workId;
  1592. await _taskCallbackService.CreateOrUpdateAndCache(taskCallbackData);
  1593. Log.Instance.WriteLogAdd(EnumHelper.GetDescription(ActionTypeEnum.SendThreeCoordinates) + "放测量三坐标成功===>>" + JsonConvert.SerializeObject(req)
  1594. , EnumHelper.GetDescription(ActionTypeEnum.SendThreeCoordinates));
  1595. return responseData;
  1596. }
  1597. catch (Exception ex)
  1598. {
  1599. Log.Instance.WriteLogAdd(ActionTypeEnum.SendThreeCoordinates + "放测量三坐标故障===>>" + ex.Message + JsonConvert.SerializeObject(req),
  1600. EnumHelper.GetDescription(ActionTypeEnum.SendThreeCoordinates));
  1601. responseData.result = "false";
  1602. return responseData;
  1603. }
  1604. }
  1605. /// <summary>
  1606. /// 伺服舵机取物品
  1607. /// </summary>
  1608. public async Task<ResponseECSData> GetServoStacker(RequestData<LocationData> req)
  1609. {
  1610. ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId);
  1611. try
  1612. {
  1613. List<Device> devices = _deviceService.GetDeviceList();
  1614. Device device = devices.Where(x => x.Ip.Equals(req.url) && x.Port.Equals(req.port)).FirstOrDefault();
  1615. if (device == null)
  1616. {
  1617. Log.Instance.WriteLogAdd(ActionTypeEnum.GetServoStacker + "设备已离线===>>" + JsonConvert.SerializeObject(req),
  1618. EnumHelper.GetDescription(ActionTypeEnum.GetServoStacker));
  1619. responseData.result = "false";
  1620. return responseData;
  1621. }
  1622. CcsAction actionQuery = new CcsAction();
  1623. actionQuery.OperateType = ActionTypeEnum.GetServoStacker.ToString();
  1624. actionQuery.Ip = req.url;
  1625. CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault();
  1626. SiemensS7Net s7 = DevicePlcS7.SiemensS7(req.url);
  1627. HslCommunication.OperateResult ConnectionResult = s7.ConnectServer();
  1628. if (!ConnectionResult.IsSuccess)
  1629. {
  1630. s7.ConnectClose();
  1631. Log.Instance.WriteLogAdd(ActionTypeEnum.GetServoStacker + "取物品故障===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
  1632. EnumHelper.GetDescription(ActionTypeEnum.GetServoStacker));
  1633. responseData.result = "false";
  1634. return responseData;
  1635. }
  1636. CcsActionAddress actionAddressQuery = new CcsActionAddress();
  1637. actionAddressQuery.ActionId = actionInfo.Id;
  1638. List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);
  1639. //查询条件
  1640. List<CcsActionAddress> CcsActionAddressChecks = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CHECK.ToString()).ToList();
  1641. foreach (CcsActionAddress actionAddress in CcsActionAddressChecks)
  1642. {
  1643. if (!string.IsNullOrEmpty(actionAddress.Address) && !string.IsNullOrEmpty(actionAddress.Value))
  1644. {
  1645. var operateResult = s7.ReadInt16(actionAddress.Address);
  1646. if (actionAddress.CheckType ? (operateResult.Content.ToString() == actionAddress.Value) : operateResult.Content.ToString() != actionAddress.Value)
  1647. {
  1648. s7.ConnectClose();
  1649. Log.Instance.WriteLogAdd(ActionTypeEnum.GetServoStacker + "取物品异常===>>" + "条件不满足" + JsonConvert.SerializeObject(req),
  1650. EnumHelper.GetDescription(ActionTypeEnum.GetServoStacker));
  1651. responseData.result = "false";
  1652. return responseData;
  1653. }
  1654. }
  1655. }
  1656. //查询写入地址列表
  1657. List<CcsActionAddress> CcsActionAddressWrites = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.WRITE.ToString()).ToList();
  1658. if (req.data.Location == "373")
  1659. {
  1660. s7.Write("DB200.46", Convert.ToInt16("373"));
  1661. s7.Write("DB200.48", Convert.ToInt16("16"));
  1662. Thread.Sleep(SLEEP_TIME);
  1663. s7.Write("DB200.50", Convert.ToInt16("1"));
  1664. }
  1665. else
  1666. {
  1667. foreach (CcsActionAddress actionAddress in CcsActionAddressWrites)
  1668. {
  1669. if (!string.IsNullOrEmpty(actionAddress.Address))
  1670. {
  1671. s7.Write(actionAddress.Address, Convert.ToInt16(string.IsNullOrEmpty(actionAddress.Value) ? req.data.Location : actionAddress.Value)); ;
  1672. Thread.Sleep(SLEEP_TIME);
  1673. }
  1674. }
  1675. }
  1676. s7.ConnectClose();
  1677. //插入回调
  1678. TaskCallback taskCallbackData = new TaskCallback(req.url, ActionTypeEnum.GetServoStacker.ToString(),
  1679. EnumHelper.GetDescription(ActionTypeEnum.GetServoStacker), req.taskId, req.taskNodeId);
  1680. await _taskCallbackService.CreateOrUpdateAndCache(setCallBackValue(CcsActionAddresses, taskCallbackData));
  1681. Log.Instance.WriteLogAdd(EnumHelper.GetDescription(ActionTypeEnum.GetServoStacker) + "取物品成功===>>" + JsonConvert.SerializeObject(req)
  1682. , EnumHelper.GetDescription(ActionTypeEnum.GetServoStacker));
  1683. return responseData;
  1684. }
  1685. catch (Exception ex)
  1686. {
  1687. Log.Instance.WriteLogAdd(ActionTypeEnum.GetServoStacker + "取物品故障===>>" + ex.Message + JsonConvert.SerializeObject(req),
  1688. EnumHelper.GetDescription(ActionTypeEnum.GetServoStacker));
  1689. responseData.result = "false";
  1690. return responseData;
  1691. }
  1692. }
  1693. /// <summary>
  1694. /// 伺服舵机放物品
  1695. /// </summary>
  1696. public async Task<ResponseECSData> SendServoStacker(RequestData<LocationData> req)
  1697. {
  1698. ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId);
  1699. try
  1700. {
  1701. List<Device> devices = _deviceService.GetDeviceList();
  1702. Device device = devices.Where(x => x.Ip.Equals(req.url) && x.Port.Equals(req.port)).FirstOrDefault();
  1703. if (device == null)
  1704. {
  1705. Log.Instance.WriteLogAdd(ActionTypeEnum.SendServoStacker + "设备已离线===>>" + JsonConvert.SerializeObject(req),
  1706. EnumHelper.GetDescription(ActionTypeEnum.SendServoStacker));
  1707. responseData.result = "false";
  1708. return responseData;
  1709. }
  1710. CcsAction actionQuery = new CcsAction();
  1711. actionQuery.OperateType = ActionTypeEnum.SendServoStacker.ToString();
  1712. actionQuery.Ip = req.url;
  1713. List<CcsAction> actions = _ccsActionService.GetList(actionQuery);
  1714. CcsAction actionInfo = actions[0];
  1715. SiemensS7Net s7 = DevicePlcS7.SiemensS7(req.url);
  1716. HslCommunication.OperateResult ConnectionResult = s7.ConnectServer();
  1717. if (!ConnectionResult.IsSuccess)
  1718. {
  1719. s7.ConnectClose();
  1720. Log.Instance.WriteLogAdd(ActionTypeEnum.SendServoStacker + "放物品故障===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
  1721. EnumHelper.GetDescription(ActionTypeEnum.SendServoStacker));
  1722. responseData.result = "false";
  1723. return responseData;
  1724. }
  1725. CcsActionAddress actionAddressQuery = new CcsActionAddress();
  1726. actionAddressQuery.ActionId = actionInfo.Id;
  1727. List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);
  1728. //查询条件
  1729. List<CcsActionAddress> CcsActionAddressChecks = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CHECK.ToString()).ToList();
  1730. foreach (CcsActionAddress actionAddress in CcsActionAddressChecks)
  1731. {
  1732. if (!string.IsNullOrEmpty(actionAddress.Address) && !string.IsNullOrEmpty(actionAddress.Value))
  1733. {
  1734. var operateResult = s7.ReadInt16(actionAddress.Address);
  1735. if (actionAddress.CheckType ? (operateResult.Content.ToString() == actionAddress.Value): operateResult.Content.ToString() != actionAddress.Value)
  1736. {
  1737. s7.ConnectClose();
  1738. Log.Instance.WriteLogAdd(ActionTypeEnum.SendServoStacker + "放物品异常===>>" + "条件不满足" + JsonConvert.SerializeObject(req),
  1739. EnumHelper.GetDescription(ActionTypeEnum.SendServoStacker));
  1740. responseData.result = "false";
  1741. return responseData;
  1742. }
  1743. }
  1744. }
  1745. //查询写入地址列表
  1746. List<CcsActionAddress> CcsActionAddressWrites = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.WRITE.ToString()).ToList();
  1747. foreach (CcsActionAddress actionAddress in CcsActionAddressWrites)
  1748. {
  1749. if (!string.IsNullOrEmpty(actionAddress.Address))
  1750. {
  1751. s7.Write(actionAddress.Address, Convert.ToInt16(string.IsNullOrEmpty(actionAddress.Value) ? req.data.Location : actionAddress.Value)); ;
  1752. Thread.Sleep(SLEEP_TIME);
  1753. }
  1754. }
  1755. s7.ConnectClose();
  1756. //插入回调
  1757. TaskCallback taskCallbackData = new TaskCallback(req.url, ActionTypeEnum.SendServoStacker.ToString(),
  1758. EnumHelper.GetDescription(ActionTypeEnum.SendServoStacker), req.taskId, req.taskNodeId);
  1759. await _taskCallbackService.CreateOrUpdateAndCache(setCallBackValue(CcsActionAddresses, taskCallbackData));
  1760. Log.Instance.WriteLogAdd(EnumHelper.GetDescription(ActionTypeEnum.SendServoStacker) + "放物品成功===>>" + JsonConvert.SerializeObject(req)
  1761. , EnumHelper.GetDescription(ActionTypeEnum.SendServoStacker));
  1762. return responseData;
  1763. }
  1764. catch (Exception ex)
  1765. {
  1766. Log.Instance.WriteLogAdd(ActionTypeEnum.SendServoStacker + "放物品故障===>>" + ex.Message + JsonConvert.SerializeObject(req),
  1767. EnumHelper.GetDescription(ActionTypeEnum.SendServoStacker));
  1768. responseData.result = "false";
  1769. return responseData;
  1770. }
  1771. }
  1772. /// <summary>
  1773. /// 刀具接口列表
  1774. /// </summary>
  1775. public async Task<List<ResponseToolData>> GetTools(RequestToolData req)
  1776. {
  1777. List<Device> devices = _deviceService.GetDeviceList();
  1778. Device device = devices.Where(x => x.Ip.Equals(req.url) && x.Port.Equals(req.port)).FirstOrDefault();
  1779. List<ResponseToolData> list = new List<ResponseToolData>();
  1780. if (device.ProtocolType == ProtocalTypeEnum.OPCUA.ToString())
  1781. {
  1782. CcsTagValue tagValueQuery = new CcsTagValue();
  1783. tagValueQuery.Ip = req.url;
  1784. tagValueQuery.Component = "刀具";
  1785. List<CcsTagValue> tagValues = _ccsTagValueService.GetList(tagValueQuery);
  1786. List<CcsTagValue> toolNumberList = tagValues.GroupBy(x => x.ComponentNumber)
  1787. .Select(group => new CcsTagValue
  1788. {
  1789. ComponentNumber = group.Key
  1790. }).ToList();
  1791. foreach (CcsTagValue toolNumber in toolNumberList)
  1792. {
  1793. ResponseToolData toolData = new ResponseToolData();
  1794. foreach (CcsTagValue tagValue in tagValues)
  1795. {
  1796. if (toolNumber.ComponentNumber == tagValue.ComponentNumber)
  1797. {
  1798. toolData.number = toolNumber.ComponentNumber;
  1799. if (tagValue.Description == "刀具寿命预警")
  1800. {
  1801. toolData.warnLife = tagValue.TagValue;
  1802. }
  1803. else if (tagValue.Description == "刀具寿命目标值")
  1804. {
  1805. toolData.targetLife = tagValue.TagValue;
  1806. }
  1807. else if (tagValue.Description == "工件数")
  1808. {
  1809. toolData.workPiece = tagValue.TagValue;
  1810. }
  1811. else if (tagValue.Description == "工件数预警值")
  1812. {
  1813. toolData.workPieceWarn = tagValue.TagValue;
  1814. }
  1815. else if (tagValue.Description == "工件数目标值")
  1816. {
  1817. toolData.workPieceTarget = tagValue.TagValue;
  1818. }
  1819. else if (tagValue.Description == "磨损量")
  1820. {
  1821. toolData.wear = tagValue.TagValue;
  1822. }
  1823. else if (tagValue.Description == "磨损量预警值")
  1824. {
  1825. toolData.wearWarn = tagValue.TagValue;
  1826. }
  1827. else if (tagValue.Description == "磨损量目标值")
  1828. {
  1829. toolData.wearTarget = tagValue.TagValue;
  1830. }
  1831. else if (tagValue.Description == "刀具名称")
  1832. {
  1833. toolData.name = tagValue.TagValue;
  1834. }
  1835. }
  1836. }
  1837. list.Add(toolData);
  1838. }
  1839. }
  1840. else if (device.ProtocolType == ProtocalTypeEnum.FANUC.ToString())
  1841. {
  1842. string Url = fanucUrlContext + "?ip=" + device.Ip + "&port=" + device.Port;
  1843. //调用发那科接口
  1844. var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Get, Url + "&fun=ToolList", null, null);
  1845. if (Result.IsSuccess)
  1846. {
  1847. List<ResponseToolData> responseFanucData = JsonConvert.DeserializeObject<List<ResponseToolData>>(Result.Message);
  1848. //list = JsonConvert.DeserializeObject<List<ResponseToolData>>(Result.Message.ToolLife);
  1849. //list = JsonConvert.DeserializeObject<List<ResponseToolData>>(responseFanucData.ToolLife);
  1850. list = responseFanucData;
  1851. }
  1852. }else if(device.ProtocolType == ProtocalTypeEnum.HEIDEHAIN.ToString())
  1853. {
  1854. RequestHeidhData hdhReq = new RequestHeidhData();
  1855. hdhReq.ServerUrl = device.ServerUrl;
  1856. hdhReq.MachineName = device.UserName;
  1857. hdhReq.Type = "ToolList";
  1858. var Result = await _apiRequestService.RequestAsync(RequsetModeEnum.Post, hdhUrlContext, hdhReq, null);
  1859. if (Result.IsSuccess)
  1860. {
  1861. ResponseHeidhData responseData = JsonConvert.DeserializeObject<ResponseHeidhData>(Result.Message);
  1862. list = JsonConvert.DeserializeObject<List<ResponseToolData>>(responseData.toolsInfo);
  1863. }
  1864. }
  1865. return list;
  1866. }
  1867. /// <summary>
  1868. /// 读RFID
  1869. /// </summary>
  1870. public async Task<ResponseECSData> ReadRFID(RequestData<RFIData> req)
  1871. {
  1872. ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId);
  1873. try
  1874. {
  1875. List<Device> devices = _deviceService.GetDeviceList();
  1876. Device device = devices.Where(x => x.Ip.Equals(req.url) && x.Port.Equals(req.port)).FirstOrDefault();
  1877. if (device == null)
  1878. {
  1879. Log.Instance.WriteLogAdd(ActionTypeEnum.ReadRFID + "设备已离线===>>" + JsonConvert.SerializeObject(req),
  1880. EnumHelper.GetDescription(ActionTypeEnum.ReadRFID));
  1881. responseData.result = "false";
  1882. return responseData;
  1883. }
  1884. CcsAction actionQuery = new CcsAction();
  1885. actionQuery.OperateType = ActionTypeEnum.ReadRFID.ToString();
  1886. actionQuery.Ip = req.url;
  1887. CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault();
  1888. SiemensS7Net s7 = DevicePlcS7.SiemensS7(req.url);
  1889. HslCommunication.OperateResult ConnectionResult = s7.ConnectServer();
  1890. if (!ConnectionResult.IsSuccess)
  1891. {
  1892. s7.ConnectClose();
  1893. Log.Instance.WriteLogAdd(ActionTypeEnum.ReadRFID + "读取RFID故障===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
  1894. EnumHelper.GetDescription(ActionTypeEnum.ReadRFID));
  1895. responseData.result = "false";
  1896. return responseData;
  1897. }
  1898. CcsActionAddress actionAddressQuery = new CcsActionAddress();
  1899. actionAddressQuery.ActionId = actionInfo.Id;
  1900. actionAddressQuery.Type = ActionAddressTypeEnum.WRITE.ToString() + req.data.positionIndex; //根据positionIndex确认哪个工作台
  1901. List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);
  1902. foreach (CcsActionAddress actionAddress in CcsActionAddresses)
  1903. {
  1904. if (!string.IsNullOrEmpty(actionAddress.Address))
  1905. {
  1906. if (string.IsNullOrEmpty(actionAddress.Value))
  1907. {
  1908. var resultBytes = s7.Read(actionAddress.Address, 360);
  1909. responseData.result = ToolUtils.ReturnStringByBytes(resultBytes.Content);
  1910. req.data.content = responseData.result;
  1911. }
  1912. else
  1913. {
  1914. s7.Write(actionAddress.Address, Convert.ToInt16(actionAddress.Value));
  1915. }
  1916. }
  1917. }
  1918. s7.ConnectClose();
  1919. Log.Instance.WriteLogAdd(EnumHelper.GetDescription(ActionTypeEnum.ReadRFID) + " 读取RFID成功===>>" + JsonConvert.SerializeObject(req)
  1920. , EnumHelper.GetDescription(ActionTypeEnum.ReadRFID));
  1921. return responseData;
  1922. }
  1923. catch (Exception ex)
  1924. {
  1925. Log.Instance.WriteLogAdd(ActionTypeEnum.ReadRFID + "读取RFID故障===>>" + ex.Message + JsonConvert.SerializeObject(req),
  1926. EnumHelper.GetDescription(ActionTypeEnum.ReadRFID));
  1927. responseData.result = "false";
  1928. return responseData;
  1929. }
  1930. }
  1931. /// <summary>
  1932. /// 写RFID
  1933. /// </summary>
  1934. public async Task<ResponseECSData> WriteRFID(RequestData<RFIData> req)
  1935. {
  1936. ResponseECSData responseData = new ResponseECSData(req.taskId, req.taskNodeId);
  1937. List<Device> devices = _deviceService.GetDeviceList();
  1938. try
  1939. {
  1940. Device device = devices.Where(x => x.Ip.Equals(req.url) && x.Port.Equals(req.port)).FirstOrDefault();
  1941. if (device == null)
  1942. {
  1943. Log.Instance.WriteLogAdd(ActionTypeEnum.WriteRFID + "设备已离线===>>" + JsonConvert.SerializeObject(req),
  1944. EnumHelper.GetDescription(ActionTypeEnum.WriteRFID));
  1945. responseData.result = "false";
  1946. return responseData;
  1947. }
  1948. CcsAction actionQuery = new CcsAction();
  1949. actionQuery.OperateType = ActionTypeEnum.WriteRFID.ToString();
  1950. actionQuery.Ip = req.url;
  1951. CcsAction actionInfo = _ccsActionService.GetList(actionQuery).FirstOrDefault();
  1952. SiemensS7Net s7 = DevicePlcS7.SiemensS7(req.url);
  1953. HslCommunication.OperateResult ConnectionResult = s7.ConnectServer();
  1954. if (!ConnectionResult.IsSuccess)
  1955. {
  1956. s7.ConnectClose();
  1957. Log.Instance.WriteLogAdd(ActionTypeEnum.WriteRFID + "写RFID故障===>>" + "PLC连接不上" + JsonConvert.SerializeObject(req),
  1958. EnumHelper.GetDescription(ActionTypeEnum.WriteRFID));
  1959. responseData.result = "false";
  1960. return responseData;
  1961. }
  1962. CcsActionAddress actionAddressQuery = new CcsActionAddress();
  1963. actionAddressQuery.ActionId = actionInfo.Id;
  1964. actionAddressQuery.Type = ActionAddressTypeEnum.WRITE.ToString() + req.data.positionIndex; //根据positionIndex确认哪个工作台
  1965. List<CcsActionAddress> CcsActionAddresses = _ccsActionAddressService.GetList(actionAddressQuery);
  1966. foreach (CcsActionAddress actionAddress in CcsActionAddresses)
  1967. {
  1968. if (!string.IsNullOrEmpty(actionAddress.Address))
  1969. {
  1970. if (string.IsNullOrEmpty(actionAddress.Value))
  1971. {
  1972. s7.Write(actionAddress.Address, ToolUtils.ReturnBtyesWtitString("", 360));
  1973. Thread.Sleep(100);
  1974. s7.Write(actionAddress.Address, ToolUtils.ReturnBtyesWtitString(req.data.content, 360));
  1975. //var resultBytes = s7.Read("DB200.868", 40);
  1976. //Console.WriteLine(ToolUtils.ReturnStringByBytes(resultBytes.Content));
  1977. }
  1978. else
  1979. {
  1980. s7.Write(actionAddress.Address, Convert.ToInt16(actionAddress.Value));
  1981. }
  1982. Thread.Sleep(SLEEP_TIME);
  1983. }
  1984. }
  1985. s7.ConnectClose();
  1986. Log.Instance.WriteLogAdd(EnumHelper.GetDescription(ActionTypeEnum.WriteRFID) + " 写RFID成功===>>" + JsonConvert.SerializeObject(req)
  1987. , EnumHelper.GetDescription(ActionTypeEnum.WriteRFID));
  1988. return responseData;
  1989. }
  1990. catch (Exception ex)
  1991. {
  1992. Log.Instance.WriteLogAdd(ActionTypeEnum.WriteRFID + "写RFID故障===>>" + ex.Message + JsonConvert.SerializeObject(req),
  1993. EnumHelper.GetDescription(ActionTypeEnum.WriteRFID));
  1994. responseData.result = "false";
  1995. return responseData;
  1996. }
  1997. }
  1998. //设置回调值
  1999. private TaskCallback setCallBackValue(List<CcsActionAddress> CcsActionAddresses, TaskCallback taskCallbackData)
  2000. {
  2001. List<CcsActionAddress> CcsActionAddressCallBacks = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CALLBACK.ToString()).ToList();
  2002. List<CcsActionAddress> CcsActionAddressCallBackFails = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.CALLBACK_FAIL.ToString()).ToList();
  2003. List<CcsActionAddress> CcsActionAddressCallBackResets = CcsActionAddresses.Where(o => o.Type == ActionAddressTypeEnum.RESET.ToString()).ToList();
  2004. foreach (CcsActionAddress actionAddress in CcsActionAddressCallBacks)
  2005. {
  2006. if (actionAddress.Sort == 1)
  2007. {
  2008. taskCallbackData.Address = actionAddress.Address;
  2009. taskCallbackData.CallbackValue = actionAddress.Value;
  2010. }
  2011. else if (actionAddress.Sort == 2)
  2012. {
  2013. taskCallbackData.Address2 = actionAddress.Address;
  2014. taskCallbackData.CallbackValue2 = actionAddress.Value;
  2015. }
  2016. else if (actionAddress.Sort == 3)
  2017. {
  2018. taskCallbackData.Address3 = actionAddress.Address;
  2019. taskCallbackData.CallbackValue3 = actionAddress.Value;
  2020. }
  2021. }
  2022. foreach (CcsActionAddress actionAddress in CcsActionAddressCallBackFails)
  2023. {
  2024. if (actionAddress.Sort == 1)
  2025. {
  2026. taskCallbackData.FailAddress = actionAddress.Address;
  2027. taskCallbackData.CallbackFailValue = actionAddress.Value;
  2028. }
  2029. else if (actionAddress.Sort == 2)
  2030. {
  2031. taskCallbackData.FailAddress2 = actionAddress.Address;
  2032. taskCallbackData.CallbackFailValue2 = actionAddress.Value;
  2033. }
  2034. else if (actionAddress.Sort == 3)
  2035. {
  2036. taskCallbackData.FailAddress3 = actionAddress.Address;
  2037. taskCallbackData.CallbackFailValue3 = actionAddress.Value;
  2038. }
  2039. }
  2040. foreach (CcsActionAddress actionAddress in CcsActionAddressCallBackResets)
  2041. {
  2042. if (actionAddress.Sort == 1)
  2043. {
  2044. taskCallbackData.SuccessResetAddress = actionAddress.Address;
  2045. taskCallbackData.SuccessResetValue = actionAddress.Value;
  2046. }
  2047. else if (actionAddress.Sort == 2)
  2048. {
  2049. taskCallbackData.SuccessResetAddress2 = actionAddress.Address;
  2050. taskCallbackData.SuccessResetValue2 = actionAddress.Value;
  2051. }
  2052. }
  2053. return taskCallbackData;
  2054. }
  2055. }
  2056. }