FEDApi.git - Gitblit

			@@ -1341,5 +1341,310 @@
			return mes;
			}
			#endregion

			#region[工序关联缺陷查询]
			public static ToMessage StepAssociationDefect(string stepcode)
			{
			string sql = "";
			var dynamicParams = new DynamicParameters();
			List<StepDefect> list = new List<StepDefect>();
			try
			{
			//获取工序关联缺陷数据(包含关联标识)
			sql = @"select A.code,A.name,(case when B.defect_code is null then 'N' else 'Y' end) flag from TDefect A
			left join(
			select distinct defect_code from TDefect_Step where step_code='' and is_delete<>'1'
			) B on A.code=B.defect_code";
			dynamicParams.Add("@stepcode", stepcode);
			var data = DapperHelper.selectdata(sql, dynamicParams);
			for (int i = 0; i < data.Rows.Count; i++)
			{
			StepDefect dft = new StepDefect();
			dft.code = data.Rows[i]["CODE"].ToString();
			dft.name = data.Rows[i]["NAME"].ToString();
			dft.flag = data.Rows[i]["FLAG"].ToString();
			list.Add(dft);
			}
			mes.code = "200";
			mes.Message = "查询成功!";
			mes.data = list;
			}
			catch (Exception e)
			{
			mes.code = "300";
			mes.count = 0;
			mes.Message = e.Message;
			mes.data = null;
			}
			return mes;
			}
			#endregion

			#region[工序关联缺陷提交]
			public static ToMessage SaveStepAssociationDefect(string stepcode, string username, List<ObjectData> json)
			{
			var sql = "";
			List<object> list = new List<object>();
			try
			{
			list.Clear();
			if (json == null \|\| json.Count <= 0)
			{
			//清除工序关联缺陷表数据
			sql = @"delete TDefect_Step where step_code=@stepcode";
			list.Add(new { str = sql, parm = new { stepcode = stepcode } });
			//标记工序表关联工作站标识
			sql = @"update TStep is_defect='N' where stepcode=@stepcode";
			list.Add(new { str = sql, parm = new { stepcode = stepcode } });
			}
			else
			{
			//清除工序关联缺陷表数据
			sql = @"delete TDefect_Step where step_code=@stepcode";
			list.Add(new { str = sql, parm = new { stepcode = stepcode } });
			//循环写入用户关联角色表
			for (int i = 0; i < json.Count; i++)
			{
			sql = @"insert into TDefect_Step(defect_code,step_code,lm_user,lm_date) values(@defect_code,@stepcode,@lm_user,@lm_date)";
			list.Add(new
			{
			str = sql,
			parm = new
			{
			defect_code = json[i].code,
			stepcode = stepcode,
			lm_user = username,
			lm_date = DateTime.Now.ToString()
			}
			});
			}
			//标记物料表关联工艺路线标识
			sql = @"update TStep set is_defect='Y' where stepcode=@stepcode";
			list.Add(new { str = sql, parm = new { stepcode = stepcode } });
			}
			bool aa = DapperHelper.DoTransaction(list);
			if (aa)
			{
			mes.code = "200";
			mes.count = 0;
			mes.Message = "操作成功!";
			mes.data = null;
			}
			else
			{
			mes.code = "300";
			mes.count = 0;
			mes.Message = "操作失败!";
			mes.data = null;
			}
			}
			catch (Exception e)
			{
			mes.code = "300";
			mes.count = 0;
			mes.Message = e.Message;
			mes.data = null;
			}
			return mes;
			}
			#endregion




			#region[产品信息下拉框查询]
			public static ToMessage PartSelect()
			{
			string sql = "";
			try
			{
			//获取设备类型数据
			sql = @"select partcode,partname,partspec from TMateriel_Info where is_delete<>'1' ";
			var data = DapperHelper.selecttable(sql);
			mes.code = "200";
			mes.Message = "查询成功!";
			mes.data = data;
			}
			catch (Exception e)
			{
			mes.code = "300";
			mes.count = 0;
			mes.Message = e.Message;
			mes.data = null;
			}
			return mes;
			}
			#endregion

			#region[产品编码查找工艺路线下拉框]
			public static ToMessage PartSelectRpute(string partcode)
			{
			string sql = "";
			var dynamicParams = new DynamicParameters();
			try
			{
			//通过产品编码查找关联的工艺路线信息
			sql = @"select A.route_code,B.name as route_name
			from TMateriel_Route A
			inner join TFlw_Rout B on A.route_code=B.code
			where A.materiel_code=@partcode and B.is_delete<>'1' and A.is_delete<>'1'";
			dynamicParams.Add("@partcode", partcode);
			var data = DapperHelper.selectdata(sql, dynamicParams);
			mes.code = "200";
			mes.Message = "查询成功!";
			mes.data = data;
			}
			catch (Exception e)
			{
			mes.code = "300";
			mes.count = 0;
			mes.Message = e.Message;
			mes.data = null;
			}
			return mes;
			}
			#endregion

			#region[根据工艺路线编码查找关联工序集合]
			public static ToMessage RouteSelectStep(string routecode)
			{
			string sql = "";
			var dynamicParams = new DynamicParameters();
			try
			{
			//通过产品编码查找关联的工艺路线信息
			sql = @"select B.stepcode as code,B.stepname as name
			from TFlw_Rtdt A
			inner join TStep B on A.step_code=B.stepcode
			where A.rout_code=@routecode and B.is_delete<>'1' and A.is_delete<>'1';";
			dynamicParams.Add("@routecode", routecode);
			var data = DapperHelper.select<ObjectData>(sql, dynamicParams);
			mes.code = "200";
			mes.Message = "查询成功!";
			mes.data = data;
			}
			catch (Exception e)
			{
			mes.code = "300";
			mes.count = 0;
			mes.Message = e.Message;
			mes.data = null;
			}
			return mes;
			}
			#endregion

			#region[根据工序线编码查找关联设备集合]
			public static ToMessage StepSelectEqp(string partcode, string routecode, string stepcode, int startNum, int endNum, string prop, string order)
			{
			var dynamicParams = new DynamicParameters();
			string search = "";
			try
			{
			// --------------查询指定数据--------------
			var total = 0; //总条数
			var sql = @"select C.partcode,C.partname,B.wksp_code,T.org_name as wksp_name,A.eqp_value,A.stand_value,A.cavity_qty,A.unprice
			from (
			select materiel_code, eqp_code,eqp_value,stand_value,cavity_qty,unprice from TPrteEqp_Stad
			where materiel_code=@partcode and route_code=@routecode and step_code=@stepcode
			union all
			select @partcode as materiel_code,eqp_code,'0' as eqp_value,'0' as stand_value,'0' as cavity_qty,'0' as unprice
			from TFlw_Rteqp where step_code=@stepcode and style='E' and @partcode+eqp_code+step_code not in(select materiel_code+eqp_code+step_code from TPrteEqp_Stad)
			) A
			left join TEqpInfo B on A.eqp_code=B.code
			left join TOrganization T on B.wksp_code=T.org_code
			left join TMateriel_Info C on A.materiel_code=C.partcode
			where B.is_delete<>'1' and T.is_delete<>'1' and C.is_delete<>'1' ";
			dynamicParams.Add("@partcode", partcode);
			dynamicParams.Add("@routecode", routecode);
			dynamicParams.Add("@stepcode", stepcode);
			var data = DapperHelper.GetPageList<object>(sql, dynamicParams, prop, order, startNum, endNum, out total);
			mes.code = "200";
			mes.Message = "查询成功!";
			mes.count = total;
			mes.data = data.ToList();
			}
			catch (Exception e)
			{
			mes.code = "300";
			mes.count = 0;
			mes.Message = e.Message;
			mes.data = null;
			}
			return mes;
			}
			#endregion

			#region[节拍工价查询]
			public static ToMessage BeatRateSearch(string partcode, string partname, string partspec, string routecode, string stepcode, string eqpcode, string eqpname, int startNum, int endNum, string prop, string order)
			{
			var dynamicParams = new DynamicParameters();
			string search = "";
			try
			{
			if (partcode != "" && partcode != null)
			{
			search += "and partcode like '%'+@partcode+'%' ";
			dynamicParams.Add("@stepcode", partcode);
			}
			if (partname != "" && partname != null)
			{
			search += "and stepname like '%'+@partname+'%' ";
			dynamicParams.Add("@partname", partname);
			}
			if (partspec != "" && partspec != null)
			{
			search += "and stepname like '%'+@partspec+'%' ";
			dynamicParams.Add("@partspec", partspec);
			}
			if (routecode != "" && routecode != null)
			{
			search += "and enable=@routecode ";
			dynamicParams.Add("@routecode", routecode);
			}
			if (stepcode != "" && stepcode != null)
			{
			search += "and flwtype=@stepcode ";
			dynamicParams.Add("@stepcode", stepcode);
			}
			if (eqpcode != "" && eqpcode != null)
			{
			search += "and stepname like '%'+@eqpcode+'%' ";
			dynamicParams.Add("@eqpcode", eqpcode);
			}
			if (eqpname != "" && eqpname != null)
			{
			search += "and stepname like '%'+@eqpname+'%' ";
			dynamicParams.Add("@eqpname", eqpname);
			}
			if (search == "")
			{
			search = "and 1=1 ";
			}
			// --------------查询指定数据--------------
			var total = 0; //总条数
			var sql = @"select stepcode,stepname,flwtype,enable,descr,lm_user,lm_date,is_eqp,is_defect
			from TStep
			where is_delete<>'1' " + search;
			var data = DapperHelper.GetPageList<object>(sql, dynamicParams, prop, order, startNum, endNum, out total);
			mes.code = "200";
			mes.Message = "查询成功!";
			mes.count = total;
			mes.data = data.ToList();
			}
			catch (Exception e)
			{
			mes.code = "300";
			mes.count = 0;
			mes.Message = e.Message;
			mes.data = null;
			}
			return mes;
			}
			#endregion

			#region[节拍工价新增编辑]

			#endregion
			}
			}