HttpRequestService.cs 122 KB

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