HttpRequestService.cs 131 KB

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