TigerClouds-Tech/Server/TigerApi6_2024.git

			@@ -13,6 +13,7 @@
			using Microsoft.AspNetCore.Http;
			using Tiger.Model.Entitys.WMS.DTOS;
			using static Tiger.Model.BIZ_MES_WO;
			using Tiger.Model.Entitys.MES.Position;

			namespace Tiger.Business
			{
			@@ -271,11 +272,11 @@
			var result = new ApiAction();
			try
			{
			var _route = Db.Queryable<MES_ROUTE>().Where(x=>x.ROT_CODE == route.ROT_CODE).First();
			if (_route!=null && Db.Queryable<MES_ROUTE_NODE>().Where(x=>x.ROT_ID == _route.ID).Any())
			var _route = Db.Queryable<MES_ROUTE>().Where(x => x.ROT_CODE == route.ROT_CODE).First();
			if (_route != null && Db.Queryable<MES_ROUTE_NODE>().Where(x => x.ROT_ID == _route.ID).Any())
			{
			result.IsSuccessed = false;
			result.LocaleMsg = new($"工艺路线已经有设计记录，不能保存！");
			result.LocaleMsg = new($"工艺路线已经有设计记录，不能保存！");
			return result;
			}
			var db = Db;
			@@ -323,7 +324,7 @@
			}
			db.Deleteable<MES_ROUTE_NODE>(false).Where(x => x.ROT_ID == routeData.route.ID).ExecuteCommand();
			db.Deleteable<MES_ROUTE_EDGE>(false).Where(x => x.ROT_ID == routeData.route.ID).ExecuteCommand();
			db.Deleteable<MES_ROUTE_NODE_ACT>(false).Where(x=>x.ROT_ID == routeData.route.ID).ExecuteCommand();
			db.Deleteable<MES_ROUTE_NODE_ACT>(false).Where(x => x.ROT_ID == routeData.route.ID).ExecuteCommand();
			if (routeData.nodes != null)
			{
			db.Insertable(routeData.nodes).ExecuteCommand();
			@@ -355,7 +356,8 @@
			/// </summary>
			/// <param name="routeId"></param>
			/// <returns></returns>
			public async Task<ApiAction> DeleteRoute(string routeId) {
			public async Task<ApiAction> DeleteRoute(string routeId)
			{
			var result = new ApiAction();
			try
			{
			@@ -387,7 +389,8 @@
			/// </summary>
			/// <param name="nodePost"></param>
			/// <returns></returns>
			public async Task<ApiAction> SaveRouteNodePost(List<MES_ROUTE_NODE_POST> nodePost) {
			public async Task<ApiAction> SaveRouteNodePost(List<MES_ROUTE_NODE_POST> nodePost)
			{
			var result = new ApiAction();
			try
			{
			@@ -476,7 +479,7 @@
			var result = new ApiAction();
			try
			{
			var bizMesWo = await Db.Queryable<BIZ_MES_WO>().Where(x=> x.ORDER_NO == input.wo).FirstAsync();
			var bizMesWo = await Db.Queryable<BIZ_MES_WO>().Where(x => x.ORDER_NO == input.wo).FirstAsync();
			if (bizMesWo != null && bizMesWo.STATUS > (int)STATUSs.Imported && bizMesWo.STATUS < (int)STATUSs.Closed)
			{
			result.IsSuccessed = false;
			@@ -511,7 +514,8 @@
			}
			}
			//如果除了删除的当前工艺路线不存在其他绑定的工艺路线，则更新状态
			if (bizMesWo != null && !Db.Queryable<MES_WO_NODE>().Where(x => x.WORK_ORDER == input.wo && x.ROT_ID != _rotId).Any()) {
			if (bizMesWo != null && !Db.Queryable<MES_WO_NODE>().Where(x => x.WORK_ORDER == input.wo && x.ROT_ID != _rotId).Any())
			{
			bizMesWo.ROUTE_STATUS = (int)ROUTE_STATUSs.WaitSet;
			bizMesWo.STATUS = (int)STATUSs.Init;
			bizMesWo.ROUTE_CODE = "";
			@@ -551,6 +555,221 @@
			}
			return result;
			}
			}
			}

			#region 工单工艺路线相关


			/// <summary>
			/// 获取工单工艺路线图形数据
			/// </summary>
			/// <param name="workorder"></param>
			/// <returns></returns>
			public async Task<ApiAction<WoRouteData>> GetWoRouteData(string workorder)
			{
			var res = new ApiAction<WoRouteData>();
			WoRouteData rotData = new WoRouteData();
			try
			{
			if (string.IsNullOrEmpty(workorder))
			{
			res.IsSuccessed = false;
			res.LocaleMsg = new($"传入的工艺路线ID为空，不能查找工艺路线！");
			return res;
			}
			//工艺路线
			var route = await Db.Queryable<BIZ_MES_WO, MES_ROUTE>((q, s) => new JoinQueryInfos(JoinType.Inner, q.ROUTE_CODE == s.ROT_CODE))
			.Where((q, s) => q.ID.Equals(workorder) \|\| q.ORDER_NO == workorder).Select((q, s) => new MES_ROUTE
			{
			ID = s.ID,
			ROT_CODE = s.ROT_CODE,
			ROT_NAME = s.ROT_NAME,
			ROT_TYPE = s.ROT_TYPE,
			ROT_VER = s.ROT_VER,
			IS_ACTIVE = s.IS_ACTIVE,
			REMARK = s.REMARK,
			WORK_ORDER = q.ORDER_NO,
			PROD_CODE = q.ITEM_CODE,
			CUST_CODE = q.CUST_CODE,
			}).FirstAsync();
			rotData.route = route;
			if (route == null)
			{
			res.IsSuccessed = false;
			res.LocaleMsg = new($"不能查找到工单工艺路线！");
			return res;
			}
			//节点
			var nodes = await Db.Queryable<MES_WO_NODE>()
			.WhereIF(!string.IsNullOrEmpty(route.ID), x => x.WORK_ORDER.Equals(route.WORK_ORDER))
			.ToListAsync();
			foreach (var node in nodes)
			{
			node.node = new()
			{
			id = node.ID,
			type = node.GPH_TYPE,
			x = node.GPH_X,
			y = node.GPH_Y,
			properties = node.GPH_PROP,
			text = new()
			{
			x = node.GPH_X,
			y = node.GPH_Y,
			value = node.GPH_TEXT
			}
			};
			}
			rotData.nodes = nodes;

			var acts = await Db.Queryable<MES_WO_NODE_ACT>()
			.WhereIF(!string.IsNullOrEmpty(route.ID), x => x.WORK_ORDER.Equals(route.WORK_ORDER))
			.ToListAsync();
			foreach (var act in acts)
			{
			act.node = new()
			{
			id = act.ID,
			type = act.GPH_TYPE,
			x = act.GPH_X,
			y = act.GPH_Y,
			properties = act.GPH_PROP,
			text = new()
			{
			x = act.GPH_X,
			y = act.GPH_Y,
			value = act.GPH_TEXT
			}
			};
			}
			rotData.acts = acts;

			//边
			var edges = await Db.Queryable<MES_WO_EDGE>()
			.WhereIF(!string.IsNullOrEmpty(route.ID), x => x.WORK_ORDER.Equals(route.WORK_ORDER))
			.ToListAsync();
			foreach (var edge in edges)
			{
			edge.edge = new()
			{
			id = edge.ID,
			type = edge.GPH_TYPE,
			sourceNodeId = edge.SRC_NODE,
			targetNodeId = edge.TGT_NODE,
			properties = edge.GPH_PROP,
			startPoint = new()
			{
			x = edge.GPH_SRC_X,
			y = edge.GPH_SRC_Y,
			},
			endPoint = new()
			{
			x = edge.GPH_TGT_X,
			y = edge.GPH_TGT_Y,
			},
			pointsList = new()
			{
			new(){
			x = edge.GPH_SRC_X,
			y = edge.GPH_SRC_Y,
			},
			new(){
			x = edge.GPH_TGT_X,
			y = edge.GPH_TGT_Y,
			}
			}
			};
			}
			rotData.edges = edges;
			}
			catch (Exception ex)
			{
			res.CatchExceptionWithLog(ex, "查询异常");
			}
			res.Data = rotData;
			return res;
			}

			/// <summary>
			/// 保存工单工艺路线图形数据
			/// </summary>
			/// <param name="routeData"></param>
			/// <returns></returns>
			public async Task<ApiAction> SaveWoRouteData(WoRouteData routeData)
			{
			var result = new ApiAction();
			try
			{
			var db = Db;
			var dbTran = db.UseTran(() =>
			{
			//if (routeData.route != null)
			//{
			// var y = db.Storageable(routeData.route)
			// .WhereColumns(t => new { t.ROT_CODE, t.GHOST_ROW })
			// .ToStorage();
			// y.AsInsertable.ExecuteCommand();
			// y.AsUpdateable.IgnoreColumns(x => x.ID).ExecuteCommand();
			//}
			db.Deleteable<MES_WO_NODE>(false).Where(x => x.WORK_ORDER == routeData.route.WORK_ORDER).ExecuteCommand();
			db.Deleteable<MES_WO_EDGE>(false).Where(x => x.WORK_ORDER == routeData.route.WORK_ORDER).ExecuteCommand();
			db.Deleteable<MES_WO_NODE_ACT>(false).Where(x => x.WORK_ORDER == routeData.route.WORK_ORDER).ExecuteCommand();
			if (routeData.nodes != null)
			{
			db.Insertable(routeData.nodes).ExecuteCommand();
			}
			if (routeData.edges != null)
			{
			db.Insertable(routeData.edges).ExecuteCommand();
			}
			if (routeData.acts != null)
			{
			db.Insertable(routeData.acts).ExecuteCommand();
			}
			});
			if (!dbTran.IsSuccess)
			{
			result.IsSuccessed = false;
			result.LocaleMsg = new($"保存工单工艺路线图形数据异常");
			}
			}
			catch (Exception ex)
			{
			result.CatchExceptionWithLog(ex, "保存工单工艺路线图形数据异常");
			}
			return await Task.FromResult(result);
			}

			/// <summary>
			/// 保存工单工艺节点岗位资源
			/// </summary>
			/// <param name="nodePost"></param>
			/// <returns></returns>
			public async Task<ApiAction> SaveWoRouteNodePost(List<MES_WO_NODE_POST> nodePost)
			{
			var result = new ApiAction();
			try
			{
			var db = Db;
			var dbTran = db.UseTran(() =>
			{
			var y = db.Storageable(nodePost)
			.ToStorage();
			y.AsInsertable.ExecuteCommand();
			y.AsUpdateable.ExecuteCommand();
			});
			if (!dbTran.IsSuccess)
			{
			result.IsSuccessed = false;
			result.LocaleMsg = new($"保存工单工艺节点岗位资源数据异常");
			}
			}
			catch (Exception ex)
			{
			result.CatchExceptionWithLog(ex, "保存工单工艺节点岗位资源数据异常");
			}
			return await Task.FromResult(result);
			}
			#endregion
			} //endClass Route
			} //endClass Biz
			}