XkdMesApi.git - Gitblit

			@@ -1198,6 +1198,91 @@
			}
			#endregion

			#region[MES工单查看工单SOP]
			public static ToMessage MesOrderSopSearch(string wocode, string materielcode)
			{
			string sql = "";
			var dynamicParams = new DynamicParameters();
			try
			{
			//获取SOP文件信息
			sql = @"select filename,filepath,version from TWrkOrderSop
			where wo=@wocode and materielcode=@materielcode
			order by version";
			dynamicParams.Add("@wocode", wocode);
			dynamicParams.Add("@materielcode", materielcode);
			var data = DapperHelper.selectdata(sql, dynamicParams);
			if (data.Rows.Count > 0)
			{
			mes.code = "200";
			mes.message = "查询成功!";
			mes.data = data;
			}
			else
			{
			mes.code = "300";
			mes.message = "当前工单产品暂无SOP文件!";
			mes.data = null;
			}
			}
			catch (Exception e)
			{
			mes.code = "300";
			mes.count = 0;
			mes.message = e.Message;
			mes.data = null;
			}
			return mes;
			}
			#endregion

			#region[MES工单查看工艺SOP]
			public static ToMessage MesOrderProcessSopSearch(string materielcode, string routecode, string stepcode, User us)
			{
			var sql = "";
			List<object> list = new List<object>();
			var dynamicParams = new DynamicParameters();
			try
			{
			dynamic dynObj = JObject.Parse(us.mesSetting);
			bool route = dynObj.route;
			if (route) //工艺路线版
			{
			//获取SOP文件信息
			sql = @"select filename,filepath,version from TProcessSop
			where materielcode=@materielcode and routecode=@routecode and stepcode=@stepcode
			order by version";
			dynamicParams.Add("@materielcode", materielcode);
			dynamicParams.Add("@routecode", routecode);
			dynamicParams.Add("@stepcode", stepcode);
			}
			else
			{
			//获取SOP文件信息
			sql = @"select filename,filepath,version from TProcessSop
			where materielcode=@materielcode and stepcode=@stepcode
			order by version";
			dynamicParams.Add("@materielcode", materielcode);
			dynamicParams.Add("@stepcode", stepcode);
			}

			var data = DapperHelper.selectdata(sql, dynamicParams);
			mes.code = "200";
			mes.count = data.Rows.Count;
			mes.data = data;
			mes.message = "查询成功!";
			}
			catch (Exception e)
			{
			mes.code = "300";
			mes.count = 0;
			mes.message = e.Message;
			mes.data = null;
			}
			return mes;
			}
			#endregion


			#region[MES工单派发提交]
			public static ToMessage MesOrderDistribution(string[] wocodelist, User us)
			@@ -3392,7 +3477,7 @@
			}
			});
			//回写对应的报工记录主表合格数量、不良数量、报废数量
			sql = @"update TK_Wrk_Record set start_qty=start_qty+@good_qty, good_qty=good_qty+@good_qty,ng_qty=ng_qty+@ng_qty,laborbad_qty=laborbad_qty+@laborbad_qty,materielbad_qty=materielbad_qty+@materielbad_qty,
			sql = @"update TK_Wrk_Record set step_price=@step_price,start_qty=start_qty+@good_qty, good_qty=good_qty+@good_qty,ng_qty=ng_qty+@ng_qty,laborbad_qty=laborbad_qty+@laborbad_qty,materielbad_qty=materielbad_qty+@materielbad_qty,
			updatereportuser=@updatereportuser,updatereportdate=@updatereportdate
			where wo_code=@wo_code and step_code=@step_code and id=@id and style='B'";
			list.Add(new
			@@ -3400,6 +3485,7 @@
			str = sql,
			parm = new
			{
			step_price=decimal.Parse(json[0].unprice),
			good_qty = decimal.Parse(json[0].report_dvalue),
			ng_qty = this_ng_dvalue,
			laborbad_qty = this_laborbad_dvalue,
			@@ -3494,7 +3580,7 @@
			}
			});
			//回写对应的收料记录主表收料数量、不良数量、报废数量
			sql = @"update TK_Wrk_OutRecord set sqty=sqty+@good_qty,ng_qty=ng_qty+@ng_qty,laborbad_qty=laborbad_qty+@laborbad_qty,materielbad_qty=materielbad_qty+@materielbad_qty,
			sql = @"update TK_Wrk_OutRecord set step_price=@step_price,sqty=sqty+@good_qty,ng_qty=ng_qty+@ng_qty,laborbad_qty=laborbad_qty+@laborbad_qty,materielbad_qty=materielbad_qty+@materielbad_qty,
			updatereportuser=@updatereportuser,updatereportdate=@updatereportdate
			where wo_code=@wo_code and step_code=@step_code and id=@id and style='S' and wx_code=@wx_code";
			list.Add(new
			@@ -3502,6 +3588,7 @@
			str = sql,
			parm = new
			{
			step_price=decimal.Parse(json[0].unprice),
			good_qty = decimal.Parse(json[0].report_dvalue),
			ng_qty = this_ng_dvalue,
			laborbad_qty = this_laborbad_dvalue,
			@@ -3779,5 +3866,67 @@
			return mes;
			}
			#endregion

			#region[生产执行,报工弃审数据提交]
			public static ToMessage MesOrderStepReportNotVerifySeave(User us, string id, string steptype)
			{
			var sql = "";
			List<object> list = new List<object>();
			var dynamicParams = new DynamicParameters();
			try
			{
			if (steptype == "Z")//自制工序
			{
			//回写报工记录主表审核状态、审核人、审核时间
			sql = @"update TK_Wrk_Record set verify='N',verifyuser=@verifyuser,verifydate=@verifydate where id=@id";
			list.Add(new { str = sql, parm = new { verifyuser = "", verifydate = "", id = id } });
			//回写报工记录子表审核状态、审核人、审核时间
			sql = @"update TK_Wrk_RecordSub set verify='N',verifyuser=@verifyuser,verifydate=@verifydate where m_id=@id";
			list.Add(new { str = sql, parm = new { verifyuser = "", verifydate = "", id = id } });
			}
			if (steptype == "W")//外协工序
			{
			//回写外协记录主表审核状态、审核人、审核时间
			sql = @"update TK_Wrk_OutRecord set verify='N',verifyuser=@verifyuser,verifydate=@verifydate where id=@id";
			list.Add(new { str = sql, parm = new { verifyuser = "", verifydate = "", id = id } });
			//回写外协记录子表审核状态、审核人、审核时间
			sql = @"update TK_Wrk_OutRecordSub set verify='N',verifyuser=@verifyuser,verifydate=@verifydate where m_id=@id";
			list.Add(new { str = sql, parm = new { verifyuser = "", verifydate = "", id = id } });
			}
			bool aa = DapperHelper.DoTransaction(list);
			if (aa)
			{
			if (steptype == "Z")
			{
			//写入操作记录表
			LogHelper.DbOperateLog(us.usercode, "报工弃审", "自制报工记录id:" + string.Join(",", id), us.usertype);
			}
			if (steptype == "W")
			{
			LogHelper.DbOperateLog(us.usercode, "报工弃审", "外协收料记录id:" + string.Join(",", id), us.usertype);
			}
			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
			}
			}