| | |
| | | data = num,//原先是1,单个写入 |
| | | port = plc.port |
| | | }); |
| | | CMMLog.Debug($"写入设备{plc.location}通道{plc.writeAddr}里面数据为1."); |
| | | Console.WriteLine($"写入设备{plc.location}通道{plc.writeAddr}里面数据为1."); |
| | | CMMLog.Debug($"写入设备{plc.location}通道{plc.writeAddr}里面数据为{JsonConvert.SerializeObject(num)}."); |
| | | Console.WriteLine($"写入设备{plc.location}通道{plc.writeAddr}里面数据为{JsonConvert.SerializeObject(num)}."); |
| | | ///小车和复称位对接 |
| | | //小车请求进料,并且查询设备是否允许AGV进入 |
| | | var readRes = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel |
| | |
| | | // num[b] = Convert.ToInt32(Convert.ToString(int.Parse(taskInfo.Ext2), 2).PadLeft(32, '0').ToString().Substring(k, 16), 2); |
| | | //} |
| | | |
| | | CMMLog.Debug($"{num}"); |
| | | Console.WriteLine(num); |
| | | CMMLog.Debug($"{JsonConvert.SerializeObject(num)}"); |
| | | var wirteall = OITcpHelper.RegisterWriteOutPutMulti(new OITcpHelper.RegisterWriteOutPutModelMulti |
| | | { |
| | | addr = plc.writeAddr + 5, |
| | |
| | | { |
| | | if(plc.deviceType == "22") |
| | | { |
| | | var newWeight = result.result[19] + "," + result.result[20]; |
| | | MongoDBSingleton.Instance.Update<MachineInfoTetracobalt>(Query.EQ("trayCode", model.ext2), Update.Set("secondNg", result.result[2]), UpdateFlags.None); |
| | | MongoDBSingleton.Instance.Update<MachineInfoTwoTetracobalt>(Query.EQ("trayCode", model.ext2), Update.Set("secondNg", result.result[2]).Set("oneTrayWeightFC",newWeight), UpdateFlags.None); |
| | | } |
| | | else |
| | | { |
| | |
| | | } |
| | | |
| | | if (result.result[0] == 3 && result.result[2] == 1) |
| | | //if (result.result[2] == 1) |
| | | { |
| | | CMMLog.Info($"SecondWeightActionOne:准备生成复称入缓存架任务,开始确定托盘号:{model.ext2}"); |
| | | if(plc.deviceType == "22") |
| | |
| | | var writeRes1 = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel |
| | | { |
| | | host = plc.ip, |
| | | addr = plc.writeAddr + 3,// + 4 |
| | | addr = plc.writeAddr, |
| | | data = 0, |
| | | port = plc.port |
| | | }); |
| | | |
| | | writeRes1 = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel |
| | | { |
| | | host = plc.ip, |
| | | addr = plc.writeAddr + 3, |
| | | data = 1, |
| | | port = plc.port |
| | | }); |
| | | //var writeRes1 = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel |
| | | //{ |
| | | // host = plc.ip, |
| | | // addr = plc.writeAddr + 3, |
| | | // data = 1, |
| | | // port = plc.port |
| | | //}); |
| | | } |
| | | } |
| | | |
| | |
| | | else if (readres.result[0] == 2) |
| | | { |
| | | TSHelper.GoToAGV(taskNo, 10, 3); |
| | | //var task = MongoDBSingleton.Instance.FindOne<TN_I_TASK_MST>(Query.EQ("CN_S_TASK_NO", taskNo), "TN_I_TASK_MST"); |
| | | //var machine = MongoDBSingleton.Instance.FindOne<WMSInfo>(Query.EQ("trayCode", task.CN_S_BATCH_NO), "WMSInfo"); |
| | | //if (machine != null) |
| | | //{ |
| | | // if (Settings.cacheStackWrite == "0") |
| | | // { |
| | | // int[] num = DiePan(machine); |
| | | // |
| | | // var wirteall01 = OITcpHelper.RegisterWriteOutPutMulti(new OITcpHelper.RegisterWriteOutPutModelMulti |
| | | // { |
| | | // addr = plc.writeAddr + 10, |
| | | // host = plc.ip, |
| | | // port = plc.port, |
| | | // data = num |
| | | // }); |
| | | // } |
| | | // else WriteCacheStackingData(plc, task, machine); |
| | | // |
| | | // var wirte = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel |
| | | // { |
| | | // addr = plc.writeAddr + 1, |
| | | // host = plc.ip, |
| | | // port = plc.port, |
| | | // data = 2 |
| | | // }); |
| | | //} |
| | | } |
| | | } |
| | | else CMMLog.Debug($"缓存入叠盘机,1013,plc=null!"); |
| | |
| | | |
| | | public static void WriteCacheStackingData(Settings.PlcInfo plc, TN_I_TASK_MST task, WMSInfo machine) |
| | | { |
| | | if (plc.deviceType == "22") |
| | | if (plc.deviceType == "23") |
| | | { |
| | | //四钴车间 |
| | | var machineTwo = MongoDBSingleton.Instance.FindOne<MachineInfoTwoTetracobalt>(Query.EQ("trayCode", task.CN_S_BATCH_NO), "MachineInfoTwoTetracobalt"); |
| | |
| | | CMMLog.Info($"3楼缓存架入叠托:写入数据:{JsonConvert.SerializeObject(num)},IPort:{plc.ip},{plc.port}"); |
| | | var wirteall01 = OITcpHelper.RegisterWriteOutPutMulti(new OITcpHelper.RegisterWriteOutPutModelMulti |
| | | { |
| | | addr = plc.writeAddr + 10, |
| | | addr = plc.writeAddr + 5, |
| | | host = plc.ip, |
| | | port = plc.port, |
| | | data = num |
| | |
| | | { |
| | | |
| | | var ErpItemInfo = MongoDBSingleton.Instance.FindOne<ERPItemTable>(Query.EQ("item_code", machineInfoTwo.materialCode), "ERPItemTable"); |
| | | CMMLog.Info($"3楼缓存架入叠托:收到信号5,查询MachineInfoTwoTetracobalt表信息:{JsonConvert.SerializeObject(ErpItemInfo)}。"); |
| | | CMMLog.Info($"3楼缓存架入叠托:收到信号4,查询ERPItemTable表信息:{JsonConvert.SerializeObject(ErpItemInfo)}。"); |
| | | |
| | | //偏移量 +11 通道范围: 40311 ~ 40390 |
| | | CMMLog.Info($"叠盘机数据处理."); |
| | | //10~19通道 |
| | | int[] num = new int[105];//总长度:80 |
| | | int[] num = new int[105];//总长度:105 |
| | | |
| | | #region 0~23 => 6~29 |
| | | int a = 0;//员工编号处理 |
| | |
| | | a = 0;//托盘码处理 |
| | | for (int b = 5; b <= 7; b++) |
| | | { |
| | | num[b] = int.Parse(AsciiToTen(machine.trayCode.Substring(a, 2))); |
| | | a = a + 2; |
| | | //num[b] = int.Parse(AsciiToTen(machine.trayCode.Substring(a, 2))); |
| | | //a = a + 2; |
| | | |
| | | num[b] = 0; |
| | | } |
| | | num[8] = int.Parse(AsciiToTen(machine.location));//包装机号 |
| | | for (int b = 9; b <= 10; b++) |
| | |
| | | int k = b % 2 == 0 ? 0 : 16; |
| | | num[b] = Convert.ToInt32(Convert.ToString(int.Parse(machine.oneTrayWeight), 2).PadLeft(32, '0').ToString().Substring(k, 16), 2); |
| | | } |
| | | for (int b = 15; b <= 16; b++) num[b] = 0;// 叠包后实际重量 && 复称结果 默认:0 |
| | | for (int b = 15; b <= 16; b++) |
| | | { |
| | | var arrTwo = machineInfoTwo.oneTrayWeightFC.Split(',').ToList(); |
| | | num[b] = int.Parse(arrTwo[b - 15]);//复称重量 |
| | | } |
| | | //for (int b = 15; b <= 16; b++) num[b] = 0;// 叠包后实际重量 && 复称结果 默认:0 |
| | | num[17] = int.Parse(machineInfoTwo.trayType); |
| | | |
| | | num[18] = machine.addState;//是否需要叠包 |
| | |
| | | var plc = Settings.GetPlcInfo().Where(a => a.deviceType == ip).FirstOrDefault(); |
| | | if(plc != null) |
| | | { |
| | | OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel |
| | | if(plc.deviceType == "23") |
| | | { |
| | | addr = plc.writeAddr + 1, |
| | | host = plc.ip, |
| | | data = 2,//4 |
| | | port = plc.port |
| | | }); |
| | | Thread.Sleep(100); |
| | | var readres = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel |
| | | { |
| | | dataNum = 2, |
| | | addr = plc.readAddr + 1, |
| | | host = plc.ip, |
| | | port = plc.port |
| | | }); |
| | | if (readres != null) |
| | | { |
| | | var taskInfo = MongoDBSingleton.Instance.FindOne<TN_I_TASK_MST>(Query.EQ("CN_S_TASK_NO", taskNo), "TN_I_TASK_MST"); |
| | | if (readres.result[0] == 3 && readres.result[1] == 1) |
| | | var wirte = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel |
| | | { |
| | | CMMLog.Debug($"3楼缓存架入叠托OK:TaskNo:{taskInfo.CN_S_TASK_NO},叠包OK写入值3。"); |
| | | //读码信息比对结果:OK 读到通道2参数为1时,小车将托盘放置在叠盘机上(改参数10为7) |
| | | var wirte = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel |
| | | addr = plc.writeAddr + 1, |
| | | host = plc.ip, |
| | | data = 3, |
| | | port = plc.port |
| | | }); |
| | | if (wirte.errCode == 0) |
| | | { |
| | | var taskInfo = MongoDBSingleton.Instance.FindOne<TN_I_TASK_MST>(Query.EQ("CN_S_TASK_NO", taskNo), "TN_I_TASK_MST"); |
| | | MongoDBSingleton.Instance.Remove<WMSInfo>(Query.EQ("trayCode", taskInfo.CN_S_BATCH_NO), RemoveFlags.Single); |
| | | |
| | | wirte = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel |
| | | { |
| | | addr = plc.writeAddr + 1, |
| | | host = plc.ip, |
| | | data = 3,//4 |
| | | data = 0, |
| | | port = plc.port |
| | | }); |
| | | if (wirte.errCode == 0) |
| | | TSHelper.GoToAGV(taskNo, 10, 7); |
| | | } |
| | | } |
| | | else |
| | | { |
| | | OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel |
| | | { |
| | | addr = plc.writeAddr + 1, |
| | | host = plc.ip, |
| | | data = 2, |
| | | port = plc.port |
| | | }); |
| | | var readres = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel |
| | | { |
| | | dataNum = 2, |
| | | addr = plc.readAddr + 1, |
| | | host = plc.ip, |
| | | port = plc.port |
| | | }); |
| | | if (readres != null) |
| | | { |
| | | var taskInfo = MongoDBSingleton.Instance.FindOne<TN_I_TASK_MST>(Query.EQ("CN_S_TASK_NO", taskNo), "TN_I_TASK_MST"); |
| | | if (readres.result[0] == 3 && readres.result[1] == 1) |
| | | { |
| | | //并删除WMSInfo中间表中对应托盘号的数据(也可在小车离开叠盘机之后删除,暂定通道2参数1) |
| | | CMMLog.Debug($"读码信息比对结果:OK ,并删除WMSInfo中间表中对应托盘号的数据"); |
| | | MongoDBSingleton.Instance.Remove<WMSInfo>(Query.EQ("trayCode", taskInfo.CN_S_BATCH_NO), RemoveFlags.Single); |
| | | CMMLog.Debug($"3楼缓存架入叠托OK:TaskNo:{taskInfo.CN_S_TASK_NO},叠包OK写入值4。"); |
| | | if (CacheStackingMouth8(plc)) |
| | | CMMLog.Debug($"3楼缓存架入叠托OK:TaskNo:{taskInfo.CN_S_TASK_NO},叠包OK写入值3。"); |
| | | //读码信息比对结果:OK 读到通道2参数为1时,小车将托盘放置在叠盘机上(改参数10为7) |
| | | var wirte = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel |
| | | { |
| | | CMMLog.Debug($"3楼缓存架入叠托OK:TaskNo:{taskInfo.CN_S_TASK_NO},叠包OK写入值成功,更改AGV参数10为7,让小车离开。"); |
| | | TSHelper.GoToAGV(taskNo, 10, 7); |
| | | addr = plc.writeAddr + 1, |
| | | host = plc.ip, |
| | | data = 3, |
| | | port = plc.port |
| | | }); |
| | | if (wirte.errCode == 0) |
| | | { |
| | | //并删除WMSInfo中间表中对应托盘号的数据(也可在小车离开叠盘机之后删除,暂定通道2参数1) |
| | | CMMLog.Debug($"读码信息比对结果:OK ,并删除WMSInfo中间表中对应托盘号的数据"); |
| | | MongoDBSingleton.Instance.Remove<WMSInfo>(Query.EQ("trayCode", taskInfo.CN_S_BATCH_NO), RemoveFlags.Single); |
| | | CMMLog.Debug($"3楼缓存架入叠托OK:TaskNo:{taskInfo.CN_S_TASK_NO},叠包OK写入值4。"); |
| | | if (CacheStackingMouth8(plc)) |
| | | { |
| | | CMMLog.Debug($"3楼缓存架入叠托OK:TaskNo:{taskInfo.CN_S_TASK_NO},叠包OK写入值成功,更改AGV参数10为7,让小车离开。"); |
| | | TSHelper.GoToAGV(taskNo, 10, 7); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | else if (readres.result[0] == 3 && readres.result[1] == 2) |
| | | { |
| | | CMMLog.Debug($"读码信息比对结果:条码与传送的数据不一致"); |
| | | //二期--调用 WMS 改道接口 获取 目标点位,并 更改 AGV 站点 |
| | | string ChangeBit = WMSHelper.WmsUpdateWay(taskInfo.CN_S_SOURCE_NO, plc.Extend); |
| | | if (!string.IsNullOrEmpty(ChangeBit)) |
| | | else if (readres.result[0] == 3 && readres.result[1] == 2) |
| | | { |
| | | int[] parms = { StockInstance.Instance.GetAGVCodeForBitCode(taskInfo.CN_S_END_BIT), StockInstance.Instance.GetAGVCodeForBitCode(ChangeBit) }; |
| | | TSHelper.ChangeParam(taskNo, 1, parms); |
| | | TSHelper.GoToAGV(taskNo, 3, 1);// 泰州格林美更改起点层数为1-荆门也需要更改 |
| | | CMMLog.Debug($"读码信息比对结果:条码与传送的数据不一致"); |
| | | //二期--调用 WMS 改道接口 获取 目标点位,并 更改 AGV 站点 |
| | | string ChangeBit = WMSHelper.WmsUpdateWay(taskInfo.CN_S_SOURCE_NO, plc.Extend); |
| | | if (!string.IsNullOrEmpty(ChangeBit)) |
| | | { |
| | | int[] parms = { StockInstance.Instance.GetAGVCodeForBitCode(taskInfo.CN_S_END_BIT), StockInstance.Instance.GetAGVCodeForBitCode(ChangeBit) }; |
| | | TSHelper.ChangeParam(taskNo, 1, parms); |
| | | TSHelper.GoToAGV(taskNo, 3, 1);// 泰州格林美更改起点层数为1-荆门也需要更改 |
| | | |
| | | //TSHelper.ChangeParam(taskNo, 1, StockInstance.Instance.GetAGVCodeForBitCode(taskInfo.CN_S_END_BIT)); |
| | | //TSHelper.ChangeParam(taskNo, 2, StockInstance.Instance.GetAGVCodeForBitCode(ChangeBit)); |
| | | TSHelper.GoToAGV(taskNo, 10, 8); |
| | | MongoDBSingleton.Instance.Update<TN_I_TASK_MST>(Query.EQ("CN_S_TASK_NO", taskNo), Update.Set("CN_S_END_BIT", ChangeBit).Set("CN_S_START_BIT", taskInfo.CN_S_END_BIT), "TN_I_TASK_MST", UpdateFlags.None); |
| | | //TSHelper.ChangeParam(taskNo, 1, StockInstance.Instance.GetAGVCodeForBitCode(taskInfo.CN_S_END_BIT)); |
| | | //TSHelper.ChangeParam(taskNo, 2, StockInstance.Instance.GetAGVCodeForBitCode(ChangeBit)); |
| | | TSHelper.GoToAGV(taskNo, 10, 8); |
| | | MongoDBSingleton.Instance.Update<TN_I_TASK_MST>(Query.EQ("CN_S_TASK_NO", taskNo), Update.Set("CN_S_END_BIT", ChangeBit).Set("CN_S_START_BIT", taskInfo.CN_S_END_BIT), "TN_I_TASK_MST", UpdateFlags.None); |
| | | } |
| | | else CMMLog.Debug($"调用WMS改道接口,未获取到可用点位。"); |
| | | Console.WriteLine($"读码信息比对结果:条码与传送的数据不一致"); |
| | | } |
| | | else CMMLog.Debug($"调用WMS改道接口,未获取到可用点位。"); |
| | | Console.WriteLine($"读码信息比对结果:条码与传送的数据不一致"); |
| | | //PLCControl.CacheStackingMouth6(plc); |
| | | } |
| | | //PLCControl.CacheStackingMouth6(plc); |
| | | } |
| | | |
| | | } |
| | | } |
| | | |
| | |
| | | /// <param name="taskNo"></param> |
| | | internal static void CacheStackingMouth6(Settings.PlcInfo plc) |
| | | { |
| | | //var readres = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel |
| | | //{ |
| | | // dataNum = 2, |
| | | // addr = plc.readAddr + 1, |
| | | // host = plc.ip, |
| | | // port = plc.port |
| | | //}); |
| | | //if (readres != null) |
| | | //{ |
| | | |
| | | //} |
| | | var wirte = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel |
| | | { |
| | | addr = plc.writeAddr + 1, |
| | | data = 3, |
| | | host = plc.ip, |
| | | port = plc.port |
| | | }); |
| | | Thread.Sleep(2000); |
| | | wirte = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel |
| | | { |
| | | addr = plc.writeAddr + 1, |
| | | data = 0, |
| | | host = plc.ip, |
| | | port = plc.port |
| | | }); |
| | | } |
| | | |
| | | /// <summary> |
| | |
| | | /// <param name="info"></param> |
| | | /// <param name="result"></param> |
| | | /// <param name="noPack">true : MES交互方式 false : 无MES交互方式</param> |
| | | private static void GetMachineDataTetracobalt(int[] result ,bool noPack = true) |
| | | private static void GetMachineDataTetracobalt(int[] result, ref string timeStamp, bool noPack = true) |
| | | { |
| | | CMMLog.Info($"数据处理流程:进入数据处理流程!"); |
| | | |
| | |
| | | info.addState = Convert.ToInt32(Completion(result[18]), 2); |
| | | if (info.addState == 0) CMMLog.Error($"数据处理流程:获取MODBUS信息异常:是否叠包值为0."); |
| | | info.packageCode = Convert.ToInt32(Completion(result[19]), 2).ToString(); |
| | | info.productTime = Convert.ToInt32(Completion(result[21]) + Completion(result[22]), 2).ToString(); |
| | | info.productTime = Convert.ToInt32(Completion(result[20]) + Completion(result[21]), 2).ToString(); |
| | | |
| | | //info.addWeight = Convert.ToInt32(Completion(result[10]) + Completion(result[11]), 2).ToString(); |
| | | //info.packNg = 1;//不需要此参数 result[12] |
| | |
| | | //注意:这里赋值中间表参数请对照信息交互表具体通道值对应 |
| | | UpdateBuilder update = Update.Set("palletLayers", info.secondNg.ToString()).Set("overlappingLayers", info.addState.ToString()).Set("bagNo", info.packageCode). |
| | | Set("lotNo", info.lotNo).Set("productType", info.productType).Set("materialCode", info.materialCode).Set("materialName", info.materialName).Set("measurementUnit", info.measurementUnit); |
| | | MongoDBSingleton.Instance.Update<MachineInfoTetracobalt>(Query.EQ("machineNo", location), update, "MachiMachineInfoTetracobaltneInfo", UpdateFlags.None); |
| | | MongoDBSingleton.Instance.Update<MachineInfoTetracobalt>(Query.EQ("machineNo", location), update, "MachineInfoTetracobalt", UpdateFlags.None); |
| | | MongoDBSingleton.Instance.Update<MachineInfoTwoTetracobalt>(Query.EQ("trayCode", trayCode), update, "MachineInfoTwoTetracobalt", UpdateFlags.None); |
| | | } |
| | | //在中间表中找到刚刚插入的MES数据(目前还没有读取并写入设备数据) |
| | | |
| | | timeStamp = ProcessHelper.GetTimeStamp(31, 1, 1); |
| | | trayCode = "VW" + timeStamp; |
| | | |
| | | var query1 = Query.And(Query.EQ("machineNo", location), Query.EQ("trayCode", "0")); |
| | | UpdateBuilder updateBuider = Update.Set("empCode", info.empCode).Set("location", info.location). |
| | | Set("trayCode", info.trayCode).Set("productWeight", info.productWeight). |
| | | Set("trayCode", trayCode).Set("productWeight", info.productWeight). |
| | | Set("trayCodeWeight", info.trayCodeWeight).Set("oneTrayWeight", info.oneTrayWeight).Set("trayType", info.trayType).Set("addState", info.addState). |
| | | Set("addWeight", info.addWeight).Set("packNg", info.packNg).Set("secondNg", info.secondNg).Set("productTime", info.productTime). |
| | | Set("addWeight", info.addWeight).Set("packNg", info.packNg).Set("secondNg", info.secondNg).Set("productTime", info.productTime).Set("packageCode", info.packageCode). |
| | | Set("jsonData", json).Set("modify", DateTime.Now); |
| | | MongoDBSingleton.Instance.Update<MachineInfoTetracobalt>(query1, updateBuider, "MachineInfoTetracobalt", UpdateFlags.None); |
| | | MongoDBSingleton.Instance.Update<MachineInfoTwoTetracobalt>(Query.EQ("trayCode", trayCode), updateBuider, "MachineInfoTwoTetracobalt", UpdateFlags.None); |
| | | MongoDBSingleton.Instance.Update<MachineInfoTwoTetracobalt>(query1, updateBuider, "MachineInfoTwoTetracobalt", UpdateFlags.None); |
| | | CMMLog.Info($"数据处理流程:更新MachineInfoTetracobalt中间表刚刚插入的MES数据!设备号为:{location},托盘号为:{trayCode}"); |
| | | } |
| | | else |
| | |
| | | if (trayCode.errCode == 0 && trayCode.result.Length == 105) |
| | | { |
| | | //获取托盘码等信息 读取通道 11、12、13的数据作为托盘码 读取其它通道 重量 叠包等信息 所有数据存入MachineInfo表 |
| | | GetMachineDataTetracobalt(trayCode.result, false); |
| | | string timeStamp = ""; |
| | | GetMachineDataTetracobalt(trayCode.result, ref timeStamp, false); |
| | | var tray = MongoDBSingleton.Instance.FindOne<MachineInfoTetracobalt>(Query.EQ("machineNo", pmInfo.location), "MachineInfoTetracobalt"); |
| | | if (tray != null) |
| | | { |
| | |
| | | CMMLog.Debug($"(四钴车间)包装下线流程-{pmInfo.location}:员工编码:{employeeId}"); |
| | | // 判断当前【员工编号】通道信息读出来的员工编号是否已经存在于我们的员工信息表-ERPEmployeeTable(查询字段-employee_id) |
| | | var erpEmployeeInfo = MongoDBSingleton.Instance.FindOne<ERPEmployeeTable>(Query.EQ("employee_id", employeeId), "ERPEmployeeTable"); |
| | | if (erpEmployeeInfo == null) IsContLaterCode = false; |
| | | var erpItemInfo = MongoDBSingleton.Instance.FindOne<ERPItemTable>(Query.EQ("item_code", tray.materialCode), "ERPItemTable"); |
| | | if (string.IsNullOrEmpty(tray.empCode) || string.IsNullOrEmpty(tray.materialCode) || erpEmployeeInfo == null || erpEmployeeInfo == null) |
| | | { |
| | | CMMLog.Debug($"(四钴车间)包装下线流程-{pmInfo.location}:人员表或者物料表未找到该数据,员工编号:{employeeId},物料编码:{tray.materialCode}!"); |
| | | IsContLaterCode = false; |
| | | } |
| | | else CMMLog.Debug($"(四钴车间)包装下线流程-{pmInfo.location}:员工编码查询成功"); |
| | | } |
| | | |
| | | if (IsContLaterCode) |
| | | { |
| | | string timeStamp = ProcessHelper.GetTimeStamp(31, 1, 1); |
| | | tray.trayCode = "VW" + timeStamp; |
| | | MongoDBSingleton.Instance.Update<MachineInfoTetracobalt>(Query.EQ("_id", tray._id), Update.Set("trayCode", tray.trayCode), UpdateFlags.None); |
| | | //检索员工信息成功 |
| | | var wirteall01 = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel |
| | | { |
| | | addr = pmInfo.writeAddr, |
| | | host = pmInfo.ip, |
| | | port = pmInfo.port, |
| | | data = 4 |
| | | }); |
| | | |
| | | //string timeStamp = ProcessHelper.GetTimeStamp(31, 1, 1); |
| | | //tray.trayCode = "VW" + timeStamp; |
| | | //MongoDBSingleton.Instance.Update<MachineInfoTetracobalt>(Query.EQ("_id", tray._id), Update.Set("trayCode", tray.trayCode), UpdateFlags.None); |
| | | //MongoDBSingleton.Instance.Update<MachineInfoTwoTetracobalt>(Query.EQ("_id", tray._id), Update.Set("trayCode", tray.trayCode), UpdateFlags.None); |
| | | CMMLog.Debug($"(四钴车间)包装下线流程-{pmInfo.location}:托盘码:{tray.trayCode}"); |
| | | if (tray.addState == 0) |
| | | { |
| | |
| | | { |
| | | if (action) |
| | | { |
| | | int[] num = new int[3] {1,1,1}; |
| | | int[] num = new int[3] {1,0,1}; |
| | | var writeRes = OITcpHelper.RegisterWriteOutPutMulti(new OITcpHelper.RegisterWriteOutPutModelMulti |
| | | { |
| | | host = plc.ip, |
| | |
| | | { |
| | | //推送小车进入 |
| | | TSHelper.GoToAGV(taskNo, 10, 3); |
| | | writeRes = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel |
| | | |
| | | int[] num1 = new int[2] { 1, 2}; |
| | | writeRes = OITcpHelper.RegisterWriteOutPutMulti(new OITcpHelper.RegisterWriteOutPutModelMulti |
| | | { |
| | | host = plc.ip, |
| | | addr = plc.writeAddr + 2, |
| | | data = 2, |
| | | addr = plc.writeAddr + 1, |
| | | data = num1, |
| | | port = plc.port |
| | | }); |
| | | CMMLog.Debug($"写入设备{plc.location}通道{plc.writeAddr + 2}里面数据为2."); |
| | | |
| | | //writeRes = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel |
| | | //{ |
| | | // host = plc.ip, |
| | | // addr = plc.writeAddr + 2, |
| | | // data = 2, |
| | | // port = plc.port |
| | | //}); |
| | | CMMLog.Debug($"写入设备{plc.location}通道{plc.writeAddr + 1}里面数据为{JsonConvert.SerializeObject(num1)}."); |
| | | } |
| | | } |
| | | } |
| | |
| | | { |
| | | if (action) |
| | | { |
| | | int[] num = new int[4] { 2, 0, 1, 1 }; |
| | | var writeRes = OITcpHelper.RegisterWriteOutPutMulti(new OITcpHelper.RegisterWriteOutPutModelMulti |
| | | var result = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel |
| | | { |
| | | dataNum = 1, |
| | | addr = plc.readAddr + 3, |
| | | host = plc.ip, |
| | | addr = plc.writeAddr, |
| | | data = num, |
| | | port = plc.port |
| | | }); |
| | | CMMLog.Debug($"写入设备{plc.location}通道{plc.writeAddr}里面数据为{JsonConvert.SerializeObject(num)}."); |
| | | CMMLog.Debug($"查询设备{plc.location}通道{plc.readAddr + 3}里面数据为{result.result[0]}."); |
| | | if (result.result[0] == 1) |
| | | { |
| | | int[] num = new int[4] { 2, 0, 0, 1 }; |
| | | var writeRes = OITcpHelper.RegisterWriteOutPutMulti(new OITcpHelper.RegisterWriteOutPutModelMulti |
| | | { |
| | | host = plc.ip, |
| | | addr = plc.writeAddr, |
| | | data = num, |
| | | port = plc.port |
| | | }); |
| | | CMMLog.Debug($"写入设备{plc.location}通道{plc.writeAddr}里面数据为{JsonConvert.SerializeObject(num)}."); |
| | | } |
| | | |
| | | var result = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel |
| | | result = OITcpHelper.RegisterReadOutPut(new OITcpHelper.RegisterReadOutPutModel |
| | | { |
| | | dataNum = 4, |
| | | addr = plc.readAddr, |
| | |
| | | CMMLog.Debug($"查询设备{plc.location}通道{plc.readAddr}里面数据为{result.result[0]}、{result.result[1]}、{result.result[3]}."); |
| | | if (result != null && result.errCode == 0) |
| | | { |
| | | if (result.result[0] == 2 && result.result[1] == 2 && result.result[2] == 2) |
| | | if (result.result[0] == 2 && result.result[1] == 2 && result.result[3] == 2) |
| | | { |
| | | //推送小车进入 |
| | | TSHelper.GoToAGV(taskNo, 10, 3); |
| | | writeRes = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel |
| | | TSHelper.GoToAGV(taskNo, 10, 1); |
| | | var writeRes = OITcpHelper.RegisterWriteOutPut(new OITcpHelper.RegisterWriteOutPutModel |
| | | { |
| | | host = plc.ip, |
| | | addr = plc.writeAddr + 3, |