| | |
| | | /// <summary> |
| | | /// 获取工艺路线图形数据 |
| | | /// </summary> |
| | | /// <param name="routerCode"></param> |
| | | /// <param name="routerId"></param> |
| | | /// <returns></returns> |
| | | public async Task<ApiAction<RouteData>> GetRouteData(string routerCode) |
| | | public async Task<ApiAction<RouteData>> GetRouteData(string routerId) |
| | | { |
| | | var res = new ApiAction<RouteData>(); |
| | | RouteData rotData = new RouteData(); |
| | |
| | | { |
| | | //工艺路线 |
| | | var route = await Db.Queryable<MES_ROUTE>() |
| | | .WhereIF(!string.IsNullOrEmpty(routerCode), x => x.ROT_CODE.Equals(routerCode)) |
| | | .WhereIF(!string.IsNullOrEmpty(routerId), x => x.ROT_CODE.Equals(routerId)) |
| | | .OrderBy(x => x.CREATE_TIME).FirstAsync(); |
| | | rotData.route = route; |
| | | //节点 |
| | | var nodes = await Db.Queryable<MES_ROUTE_NODE>() |
| | | .WhereIF(!string.IsNullOrEmpty(routerCode), x => x.ROT_CODE.Equals(routerCode)) |
| | | .WhereIF(!string.IsNullOrEmpty(routerId), x => x.ROT_ID.Equals(routerId)) |
| | | .ToListAsync(); |
| | | foreach (var node in nodes) |
| | | { |
| | |
| | | |
| | | //边 |
| | | var edges = await Db.Queryable<MES_ROUTE_EDGE>() |
| | | .WhereIF(!string.IsNullOrEmpty(routerCode), x => x.ROT_CODE.Equals(routerCode)) |
| | | .WhereIF(!string.IsNullOrEmpty(routerId), x => x.ROT_ID.Equals(routerId)) |
| | | .ToListAsync(); |
| | | foreach (var edge in edges) |
| | | { |
| | |
| | | var dbTran = db.UseTran(() => |
| | | { |
| | | var y = db.Storageable(routeEdge) |
| | | .WhereColumns(t => new { t.EDGE_CODE, t.GHOST_ROW }) |
| | | .WhereColumns(t => new { t.ID, t.GHOST_ROW }) |
| | | .ToStorage(); |
| | | y.AsInsertable.ExecuteCommand(); |
| | | y.AsUpdateable.IgnoreColumns(x => x.ID).ExecuteCommand(); |
| | | y.AsUpdateable.ExecuteCommand(); |
| | | }); |
| | | if (!dbTran.IsSuccess) |
| | | { |
| | |
| | | var dbTran = db.UseTran(() => |
| | | { |
| | | var y = db.Storageable(routeNode) |
| | | .WhereColumns(t => new { t.NODE_CODE, t.GHOST_ROW }) |
| | | .WhereColumns(t => new { t.ID, t.GHOST_ROW }) |
| | | .ToStorage(); |
| | | y.AsInsertable.ExecuteCommand(); |
| | | y.AsUpdateable.IgnoreColumns(x => x.ID).ExecuteCommand(); |
| | | y.AsUpdateable.ExecuteCommand(); |
| | | }); |
| | | if (!dbTran.IsSuccess) |
| | | { |