| | |
| | | public enum CommandType |
| | | { |
| | | None = 0, |
| | | Get = 1, |
| | | Set = 2, |
| | | Get = 1,//åä¿¡å· |
| | | Set = 2,//è®¾å¼ |
| | | } |
| | | |
| | | public enum CommandResult |
| | | { |
| | | SetOK = 0, |
| | | GetOK = 1, |
| | | GetError = 2, |
| | | SetOK = 0,//parseok |
| | | GetOK = 1,//03 |
| | | GetError = 2,//04 |
| | | } |
| | | private readonly IPutakeRepository _putakeRepository; |
| | | private readonly IProcessRepository _processRepository; |
| | |
| | | DeviceProtocolDetailDTO? deviceProtocolDetail = serialPortDevice.DeviceProtocolDetailDTOs.FirstOrDefault(x => x.DeviceProParamName == nameof(CommandType) && x.ProtocolDetailType == nameof(CommandType.Set)); |
| | | if (deviceProtocolDetail != null) |
| | | { |
| | | //æè¦å端è¿åç»æä¸ä¸ªç»å«ï¼åä»»å¡id |
| | | |
| | | //å
æ¥ç¶æåç»ï¼ææ¶é´éåº |
| | | string group = "çµæ°"; |
| | | |
| | | |
| | | string group = item.DeviceProDataBlock; |
| | | |
| | | |
| | | //è¿é夿ç»å«ä¸ä¸ªçæ¯é£ä¸ªï¼å°±æ¥é£ä¸ªå·¥èºè¡¨çå¼ |
| | | if (group=="çµæ°") |
| | | if (group == "çµæ°") |
| | | { |
| | | |
| | | //å
çå·¥èºè¡¨ä¸æ¥éª¤ä¸ä¸è¦æç弿å¤å°ä¸ª 忥çDt_TorqueOpè¡¨ä¸æ¯å¦æè¯¥ä»»å¡å·idåæ¥éª¤æ»æ°æ¯å¦æ»¡è¶³å·¥èºè¡¨ |
| | | // æ¥è¯¢ææå·¥èºæ°æ®ï¼æç
§æ¥éª¤å· SetpNum éå¢æåº |
| | | var processList = _processRepository.QueryData(x => x.CraftType == group) |
| | | .OrderBy(x => x.SetpNum) |
| | | .ToList(); |
| | | |
| | | foreach (var process in processList) |
| | | |
| | | // å
çDt_TorqueOpè¡¨ï¼æ¥è¯¢å°ç°å¨è¿æ¡æ°æ®çä»»å¡å·åæ¥éª¤ |
| | | var take = _putakeRepository.QueryData(x => x.Pustatus == 2 && x.Grouptype == group).OrderBy(x => x.Dispatchtime).First(); |
| | | if (take==null) |
| | | { |
| | | float torqueone = process.TorqueOne;//读å°å¼äº |
| | | float torquetow = process.TorqueTwo; |
| | | if (torqueone!=0) |
| | | { |
| | | serialPortDevice.Communicator.Write(item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue.Replace("[setNum]", (torqueone * 1000).ToString().PadLeft(7, '0')) + "\r"); |
| | | } |
| | | if (torquetow != 0) |
| | | { |
| | | serialPortDevice.Communicator.Write(item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue.Replace("[setNum]", (torquetow * 1000).ToString().PadLeft(7, '0')) + "\r"); |
| | | } |
| | | |
| | | // 计ç®å½åæ¥éª¤æéç Torque æ»æ° |
| | | int requiredTorqueCount = process.TorqueOneQuantity + process.TorqueTwoQuantity; |
| | | |
| | | // æ¥è¯¢å½åæ¥éª¤ç TorqueOp è®°å½ï¼å¹é
ProcessSteåç»ï¼æ£æ¥æ¯å¦è¾¾å°è¦æ± |
| | | int torqueCount = _orqueOpRepository.QueryData(x => x.ProcessSte == process.SetpNum&& x.GroupOp== group).Count(); |
| | | |
| | | if (torqueCount < requiredTorqueCount) |
| | | { |
| | | // 妿æ°é䏿»¡è¶³ï¼åæ¢è¯»å |
| | | |
| | | break; |
| | | } |
| | | //符åè¦æ±ï¼ç»§ç»è¯»åä¸ä¸æ¥ |
| | | |
| | | //çäºç©ºå°±å |
| | | } |
| | | |
| | | } |
| | | if (group == "æºæ¢°") |
| | | { |
| | | //æ¥å°æè¯¥æ¡æ°æ®äº |
| | | var process = _processRepository.QueryData(x => x.CraftType == group).OrderBy(x => x.SetpNum).First(); |
| | | |
| | | } |
| | | if (group == "å°æ²") |
| | | { |
| | | |
| | | } |
| | | |
| | | float torqueone = process.TorqueOne;//读å°å¼äº |
| | | float torquetow = process.TorqueTwo; |
| | | if (torqueone != 0) |
| | | { |
| | | serialPortDevice.Communicator.Write(item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue.Replace("[setNum]", (torqueone * 1000).ToString().PadLeft(7, '0')) + "\r"); |
| | | //è¿éç»å®è®¾å®å¼å°± æ¥åå¨å¼è¡¨ è¿ä¸ªæ°æ®æ¯å¦æ»¡è¶³äºï¼æ»¡è¶³äºå°±è¿è¡ä¸ä¸ä¸ªå¼ï¼ä¸æ»¡è¶³å°±ä¸åä¸ç´ç»å¼ |
| | | var num= _orqueOpRepository.QueryData(x => x.TakeId == take.Njtakeid && x.GroupOp == group && x.TorqueSize == torqueone).Count(); |
| | | if (num!= process.TorqueOneQuantity) |
| | | { |
| | | |
| | | } |
| | | |
| | | } |
| | | if (torquetow != 0) |
| | | { |
| | | serialPortDevice.Communicator.Write(item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue.Replace("[setNum]", (torquetow * 1000).ToString().PadLeft(7, '0')) + "\r"); |
| | | } |
| | | |
| | | // // 计ç®å½åæ¥éª¤æéç Torque æ»æ° |
| | | int requiredTorqueCount = process.TorqueOneQuantity + process.TorqueTwoQuantity; |
| | | |
| | | // æ¥è¯¢å½åæ¥éª¤ç TorqueOp è®°å½ï¼å¹é
ProcessSteåç»ï¼æ£æ¥æ¯å¦è¾¾å°è¦æ± |
| | | int torqueCount = _orqueOpRepository.QueryData(x => x.ProcessSte == process.SetpNum && x.GroupOp == group).Count(); |
| | | |
| | | if (torqueCount < requiredTorqueCount) |
| | | { |
| | | // 妿æ°é䏿»¡è¶³ï¼åæ¢è¯»å |
| | | |
| | | break; |
| | | } |
| | | #region |
| | | |
| | | // //å
çå·¥èºè¡¨ä¸æ¥éª¤ä¸ä¸è¦æç弿å¤å°ä¸ª 忥çDt_TorqueOpè¡¨ä¸æ¯å¦æè¯¥ä»»å¡å·idåæ¥éª¤æ»æ°æ¯å¦æ»¡è¶³å·¥èºè¡¨ |
| | | // // æ¥è¯¢ææå·¥èºæ°æ®ï¼æç
§æ¥éª¤å· SetpNum éå¢æåº |
| | | // var processList = _processRepository.QueryData(x => x.CraftType == group) |
| | | // .OrderBy(x => x.SetpNum) |
| | | // .ToList(); |
| | | |
| | | // foreach (var process in processList) |
| | | // { |
| | | // float torqueone = process.TorqueOne;//读å°å¼äº |
| | | // float torquetow = process.TorqueTwo; |
| | | // if (torqueone!=0) |
| | | // { |
| | | // serialPortDevice.Communicator.Write(item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue.Replace("[setNum]", (torqueone * 1000).ToString().PadLeft(7, '0')) + "\r"); |
| | | // } |
| | | // if (torquetow != 0) |
| | | // { |
| | | // serialPortDevice.Communicator.Write(item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue.Replace("[setNum]", (torquetow * 1000).ToString().PadLeft(7, '0')) + "\r"); |
| | | // } |
| | | |
| | | // // 计ç®å½åæ¥éª¤æéç Torque æ»æ° |
| | | // int requiredTorqueCount = process.TorqueOneQuantity + process.TorqueTwoQuantity; |
| | | |
| | | // // æ¥è¯¢å½åæ¥éª¤ç TorqueOp è®°å½ï¼å¹é
ProcessSteåç»ï¼æ£æ¥æ¯å¦è¾¾å°è¦æ± |
| | | // int torqueCount = _orqueOpRepository.QueryData(x => x.ProcessSte == process.SetpNum&& x.GroupOp== group).Count(); |
| | | |
| | | // if (torqueCount < requiredTorqueCount) |
| | | // { |
| | | // // 妿æ°é䏿»¡è¶³ï¼åæ¢è¯»å |
| | | |
| | | // break; |
| | | // } |
| | | // //符åè¦æ±ï¼ç»§ç»è¯»åä¸ä¸æ¥ |
| | | |
| | | } |
| | | |
| | | //} |
| | | //if (group == "æºæ¢°") |
| | | //{ |
| | | |
| | | //} |
| | | //if (group == "å°æ²") |
| | | //{ |
| | | |
| | | //} |
| | | #endregion |
| | | |
| | | |
| | | serialPortDevice.Communicator.Write(item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue.Replace("[setNum]", (5 * 1000).ToString().PadLeft(7, '0')) + "\r"); |
| | | //æå¼ä¸²å£æ¶å
è®¾å¼ |
| | | item.DeviceProParamName = CommandType.Set.ToString(); |
| | | } |
| | |
| | | |
| | | if (deviceProtocolDetail != null && receiveData.Contains(item.DeviceChildCode + deviceProtocolDetail.ProtocalDetailValue)) |
| | | { |
| | | //è¿éæåä¹åï¼è¦åå¨å°çDt_TorqueOpï¼åä»»å¡å·ï¼ç»ï¼å¼ï¼ |
| | | string group = ""; |
| | | if (group == "çµæ°") |
| | | { |
| | | var putake = _putakeRepository.QueryData(x => x.Pustatus == 2 && x.Grouptype == group).OrderByDescending(x => x.Dispatchtime).FirstOrDefault();//æ¯æ¬¡é½æ¿ææ©ç飿¡ |
| | | var punjid = putake.ID; |
| | | var Nj = new Dt_TorqueOp() |
| | | { |
| | | TakeId = putake.Njtakeid, |
| | | GroupOp = group, |
| | | //ProcessSte= processList |
| | | TorqueSize = receiveData |
| | | ////è¿éæåä¹åï¼è¦åå¨å°çDt_TorqueOpï¼åä»»å¡å·ï¼ç»ï¼å¼ï¼ |
| | | //string group = ""; |
| | | //if (group == "çµæ°") |
| | | //{ |
| | | // var putake = _putakeRepository.QueryData(x => x.Pustatus == 2 && x.Grouptype == group).OrderByDescending(x => x.Dispatchtime).FirstOrDefault();//æ¯æ¬¡é½æ¿ææ©ç飿¡ |
| | | // var punjid = putake.ID; |
| | | // var Nj = new Dt_TorqueOp() |
| | | // { |
| | | // TakeId = putake.Njtakeid, |
| | | // GroupOp = group, |
| | | // //ProcessSte= processList |
| | | // TorqueSize = receiveData |
| | | |
| | | }; |
| | | _orqueOpRepository.AddData(Nj); |
| | | // }; |
| | | // _orqueOpRepository.AddData(Nj); |
| | | |
| | | } |
| | | if (group == "æºæ¢°") |
| | | { |
| | | //} |
| | | //if (group == "æºæ¢°") |
| | | //{ |
| | | |
| | | } |
| | | if (group == "å°æ²") |
| | | //} |
| | | //if (group == "å°æ²") |
| | | |
| | | |
| | | item.DeviceProParamName = CommandType.Set.ToString(); |