| | |
| | | if (StartBit != null && Endbit != null) |
| | | { |
| | | var crs = _clrel.Select(x => x.S_CNTR_CODE).ToList(); |
| | | var b = TaskProcess.CreateTransport(od.SQL_WorkNo, StartBit.S_LOC_CODE, Endbit.S_LOC_CODE, "原物料搬运-纸箱", crs, StartBit.N_CURRENT_NUM - crs.Count + 1, 1, crs.Count, PLC.taskPri); |
| | | var EndBit = Endbit.S_LOC_CODE; |
| | | if (od.S_ROW == "YWLCQSX" || od.S_ROW == "YWLDQWJ") |
| | | { |
| | | EndBit = "YWLWJJB"; |
| | | } |
| | | var b = TaskProcess.CreateTransport(od.SQL_WorkNo, StartBit.S_LOC_CODE, EndBit, "原物料搬运-纸箱", crs, StartBit.N_CURRENT_NUM - crs.Count + 1, 1, crs.Count, PLC.taskPri, Endbit.S_LOC_CODE); |
| | | if (b) |
| | | { |
| | | |
| | | var r = new RowLock { S_LOCK_SRC = od.SQL_ItemCode, T_LOCK_TIME = DateTime.Now, S_LOCK_STATE = "出库锁", S_AREA_CODE = StartBit.S_AREA_CODE, N_ROW = StartBit.N_ROW }; |
| | | var db = new SqlHelper<object>().GetInstance(); |
| | | //给终点锁定住 |
| | | if (od.S_ROW == "YWLCQSX" || od.S_ROW == "YWLDQWJ") |
| | | { |
| | | var model = db.Queryable<Location>().Where(a => a.S_LOC_CODE == Endbit.S_LOC_CODE).First(); |
| | | |
| | | model.S_LOCK_STATE = "入库锁"; |
| | | var res = db.Updateable(model).UpdateColumns(it => new { it.S_LOCK_STATE }).ExecuteCommand() > 0; |
| | | LogHelper.Info(Endbit.S_LOC_CODE + "LockLoc:锁结果" + res); |
| | | } |
| | | //排锁 |
| | | var row = db.Queryable<RowLock>().Where(x => x.S_AREA_CODE == r.S_AREA_CODE && r.N_ROW == x.N_ROW).First(); |
| | | if (row != null) |
| | | { |