DDMesApi.git - Gitblit

			@@ -1,4 +1,5 @@
			using Dapper;
			using Newtonsoft.Json.Linq;
			using System;
			using System.Collections.Generic;
			using System.Data;
			@@ -77,7 +78,7 @@
			// --------------查询指定数据--------------
			var total = 0; //总条数
			var sql = @"select A.id, A.status,A.wo,A.materiel_code as partcode,B.partname,B.partspec,A.qty,A.relse_qty,A.wkshp_code,C.org_name as wkshp_name,
			A.stck_code,D.name as stck_name,A.planstartdate,A.planenddate,U.username as createuser,A.createdate
			A.stck_code,D.name as stck_name,A.saleOrderDeliveryDate,A.planstartdate,A.planenddate,U.username as createuser,A.createdate
			from TKimp_Ewo A
			left join TMateriel_Info B on A.materiel_code=B.partcode
			left join TOrganization C on A.wkshp_code=C.org_code
			@@ -1589,7 +1590,7 @@
			#endregion

			#region[生产开报工,报工提交]
			public static ToMessage SavaMesOrderStepReport(string mesordercode, string partcode, string stepseq, string stepcode, string eqpcode, string usergroupcode, string reportuser, string taskqty, string startqty, string reportqty, string ngqty, string badcode, string remarks, string username)
			public static ToMessage SavaMesOrderStepReport(string mesordercode, string partcode, string stepseq, string stepcode, string eqpcode,string inbarcode, string usergroupcode, string reportuser, string taskqty, string startqty, string reportqty, string ngqty, string badcode, string remarks, string username)
			{
			var sql = "";
			string[] arra = new string[] { };
			@@ -1639,6 +1640,7 @@
			dynamicParamsTran.Add("@stepseq", stepseq);
			dynamicParamsTran.Add("@stepcode", stepcode);
			dynamicParamsTran.Add("@eqpcode", eqpcode);
			dynamicParamsTran.Add("@inbarcode", inbarcode);
			dynamicParamsTran.Add("@usergroupcode", usergroupcode);
			dynamicParamsTran.Add("@reportuser", reportuser);
			dynamicParamsTran.Add("@taskqty", taskqty);
			@@ -1673,6 +1675,7 @@
			dynamicParamsTran.Add("@stepseq", stepseq);
			dynamicParamsTran.Add("@stepcode", stepcode);
			dynamicParamsTran.Add("@eqpcode", eqpcode);
			dynamicParamsTran.Add("@inbarcode", inbarcode);
			dynamicParamsTran.Add("@usergroupcode", usergroupcode);
			dynamicParamsTran.Add("@reportuser", reportuser);
			dynamicParamsTran.Add("@taskqty", taskqty);
			@@ -1788,7 +1791,7 @@
			#endregion

			#region[生产开报工, 收料提交]
			public static ToMessage SavaMesOrderStepIn(string mesordercode, string partcode, string stepseq, string stepcode, string wxcode, string inuser, string taskqty, string sqty, string ngqty, string badcode, string remarks, string username)
			public static ToMessage SavaMesOrderStepIn(string mesordercode, string partcode, string stepseq, string stepcode, string wxcode,string inbarcode, string inuser, string taskqty, string sqty, string ngqty, string badcode, string remarks, string username)
			{
			var sql = "";
			string[] arra1 = new string[] { };
			@@ -1872,6 +1875,7 @@
			dynamicParamsTran.Add("@stepseq", stepseq);
			dynamicParamsTran.Add("@stepcode", stepcode);
			dynamicParamsTran.Add("@wxcode", wxcode);
			dynamicParamsTran.Add("@inbarcode", inbarcode);
			dynamicParamsTran.Add("@inuser", inuser);
			dynamicParamsTran.Add("@taskqty", taskqty);
			dynamicParamsTran.Add("@sqty", sqty);
			@@ -1905,6 +1909,7 @@
			dynamicParamsTran.Add("@stepseq", stepseq);
			dynamicParamsTran.Add("@stepcode", stepcode);
			dynamicParamsTran.Add("@wxcode", wxcode);
			dynamicParamsTran.Add("@inbarcode", inbarcode);
			dynamicParamsTran.Add("@inuser", inuser);
			dynamicParamsTran.Add("@taskqty", taskqty);
			dynamicParamsTran.Add("@sqty", sqty);
			@@ -3402,5 +3407,449 @@
			}
			#endregion


			#region[生产入库条码补打]
			public static ToMessage ProductInHouseLabCode(string ordercode)
			{
			string sql = "";
			var dynamicParams = new DynamicParameters();
			try
			{
			//获取末道工序报工条码数据
			sql = @"select * from(
			select A.inbarcode,A.wo_code,P.partcode,P.partname,P.partspec,
			A.good_qty,U.username,A.lm_date
			from TK_Wrk_Record A
			inner join TK_Wrk_Step S on A.wo_code=S.wo_code and A.step_code=S.step_code
			inner join TMateriel_Info P on A.materiel_code=P.partcode
			inner join TUser U on A.lm_user=U.usercode
			where A.style='B' and S.isend='Y' and A.good_qty>0 and A.inbarcode<>''
			union all
			select A.inbarcode,A.wo_code,P.partcode,P.partname,P.partspec,
			A.sqty as sqty,U.username,A.lm_date
			from TK_Wrk_OutRecord A
			inner join TK_Wrk_Step S on A.wo_code=S.wo_code and A.step_code=S.step_code
			inner join TMateriel_Info P on A.materiel_code=P.partcode
			inner join TUser U on A.lm_user=U.usercode
			where A.style='S' and S.isend='Y' and A.sqty>0 and A.inbarcode<>''
			) as AA where AA.wo_code=@ordercode";
			dynamicParams.Add("@ordercode", ordercode);
			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 ProductInHouseWkshopOrder(string ordertype, string wkshopcode)
			{
			string sql = "";
			var dynamicParams = new DynamicParameters();
			try
			{
			if (ordertype == "Y") //有源单
			{
			sql = @"select distinct AA.ordercode from (
			select A.m_po as ordercode
			from TK_Wrk_Man A
			inner join TK_Wrk_Step B on A.wo_code=B.wo_code
			inner join TK_Wrk_Record S on B.wo_code=S.wo_code and B.step_code=S.step_code
			where S.style='B' and S.inbarcode<>'' and B.isend='Y' and A.m_po<>'' and S.good_qty>0 and S.good_qty>isnull(S.inhouseqty,0) and A.wkshp_code=@wkshopcode
			union all
			select A.m_po as ordercode
			from TK_Wrk_Man A
			inner join TK_Wrk_Step B on A.wo_code=B.wo_code
			inner join TK_Wrk_OutRecord S on B.wo_code=S.wo_code and B.step_code=S.step_code
			where S.style='S' and S.inbarcode<>'' and B.isend='Y' and A.m_po<>'' and S.sqty>0 and S.sqty>isnull(S.inhouseqty,0) and A.wkshp_code=@wkshopcode
			) as AA";
			}
			if (ordertype == "N")
			{
			sql = @"select distinct AA.ordercode from (
			select A.wo_code as ordercode
			from TK_Wrk_Man A
			inner join TK_Wrk_Step B on A.wo_code=B.wo_code
			inner join TK_Wrk_Record S on B.wo_code=S.wo_code and B.step_code=S.step_code
			where S.style='B' and S.inbarcode<>'' and B.isend='Y' and A.m_po='' and S.good_qty>0 and S.good_qty>isnull(S.inhouseqty,0) and A.wkshp_code=@wkshopcode
			union all
			select A.wo_code as ordercode
			from TK_Wrk_Man A
			inner join TK_Wrk_Step B on A.wo_code=B.wo_code
			inner join TK_Wrk_OutRecord S on B.wo_code=S.wo_code and B.step_code=S.step_code
			where S.style='S' and S.inbarcode<>'' and B.isend='Y' and A.m_po='' and S.sqty>0 and S.sqty>isnull(S.inhouseqty,0) and A.wkshp_code=@wkshopcode
			) as AA";
			}

			dynamicParams.Add("@wkshopcode", wkshopcode);
			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 ProductInHouseOrderSearch(string wkshopcode, string erpordercode, string mesordercode, string partcode, string partname, string partspec, string startorderdate, string endorderdate)
			{
			var dynamicParams = new DynamicParameters();
			string search = "";
			try
			{
			if (wkshopcode != "" && wkshopcode != null)
			{
			search += "and AA.wkshp_code=@wkshopcode ";
			dynamicParams.Add("@wkshopcode", wkshopcode);
			}
			if (erpordercode != "" && erpordercode != null)
			{
			search += "and AA.m_po like '%'+@erpordercode+'%' ";
			dynamicParams.Add("@erpordercode", erpordercode);
			}
			if (mesordercode != "" && mesordercode != null)
			{
			search += "and AA.wo_code like '%'+@mesordercode+'%' ";
			dynamicParams.Add("@mesordercode", mesordercode);
			}
			if (partcode != "" && partcode != null)
			{
			search += "and AA.partcode like '%'+@partcode+'%' ";
			dynamicParams.Add("@partcode", partcode);
			}
			if (partname != "" && partname != null)
			{
			search += "and AA.partname like '%'+@partname+'%' ";
			dynamicParams.Add("@partname", partname);
			}
			if (partspec != "" && partspec != null)
			{
			search += "and AA.partspec like '%'+@partspec+'%' ";
			dynamicParams.Add("@partspec", partspec);
			}
			if (startorderdate != "" && startorderdate != null)
			{
			search += "and AA.lm_date between @startorderdate and @endorderdate ";
			dynamicParams.Add("@opencheckdate", startorderdate + " 00:00:00");
			dynamicParams.Add("@endorderdate", endorderdate + " 23:59:59");
			}
			// --------------查询指定数据--------------
			var total = 0; //总条数
			var sql = @"select * from(
			select A.inbarcode,E.saleOrderid,isnull(E.saleOrderCode,'') as saleOrderCode,E.saleOrderDetailId,E.woid as mpoid,M.m_po,E.sbid,M.id as wo_id,A.wo_code,E.materiel_id,P.partcode,P.partname,P.partspec,E.unitid,E.unitcode,E.unitname,
			A.step_code,E.wkshp_id,M.wkshp_code,stck_id,K.code as stockcode,k.name as stockname,
			E.saleOrderqty,E.qty,M.plan_qty,A.good_qty,isnull(A.inhouseqty,0) as inhouseqty,A.good_qty-isnull(A.inhouseqty,0) as stinhouseqty,M.lm_date,A.style
			from TK_Wrk_Record A
			inner join TK_Wrk_Step S on A.wo_code=S.wo_code and A.step_code=S.step_code
			inner join TK_Wrk_Man M on S.wo_code=M.wo_code
			inner join TMateriel_Info P on M.materiel_code=P.partcode
			left join TKimp_Ewo E on M.sourceid=E.id
			left join T_Sec_Stck K on E.stck_code=K.code
			where A.style='B' and A.inbarcode<>'' and S.isend='Y' and A.good_qty>0
			union all
			select A.inbarcode,E.saleOrderid,isnull(E.saleOrderCode,'') as saleOrderCode,E.saleOrderDetailId,E.woid as mpoid,M.m_po,E.sbid,M.id as wo_id,A.wo_code,E.materiel_id,P.partcode,P.partname,P.partspec,E.unitid,E.unitcode,E.unitname,
			A.step_code,E.wkshp_id,M.wkshp_code,stck_id,K.code as stockcode,k.name as stockname,
			E.saleOrderqty,E.qty,M.plan_qty,A.sqty as sqty,isnull(A.inhouseqty,0) as inhouseqty,A.sqty-isnull(A.inhouseqty,0) as stinhouseqty,M.lm_date,A.style
			from TK_Wrk_OutRecord A
			inner join TK_Wrk_Step S on A.wo_code=S.wo_code and A.step_code=S.step_code
			inner join TK_Wrk_Man M on S.wo_code=M.wo_code
			inner join TMateriel_Info P on M.materiel_code=P.partcode
			left join TKimp_Ewo E on M.sourceid=E.id
			left join T_Sec_Stck K on E.stck_code=K.code
			where A.style='S' and A.inbarcode<>'' and S.isend='Y' and A.sqty>0
			) as AA where AA.good_qty>AA.inhouseqty " + search;
			var data = DapperHelper.selectdata(sql, dynamicParams);
			mes.code = "200";
			mes.Message = "查询成功!";
			mes.count = total;
			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 ProductInHouseOrderCodeSearch(string rightcode)
			{
			try
			{
			mes = SeachEncodeJob.EncodingSeach(rightcode);
			return mes;

			}
			catch (Exception e)
			{
			mes.code = "300";
			mes.count = 0;
			mes.Message = e.Message;
			mes.data = null;
			}
			return mes;
			}
			#endregion

			#region[生产入库提交]
			public static ToMessage ProductInHouseOrderSeave(string username, JObject obj)
			{
			var sql = "";
			List<object> list = new List<object>();
			var dynamicParams = new DynamicParameters();
			var dynamicParams1 = new DynamicParameters();
			try
			{
			string sub = obj["sub"].ToString();//明细
			string subsum = obj["subsum"].ToString();//汇总
			//获取报工明细
			JArray sub_arra = (JArray)Newtonsoft.Json.JsonConvert.DeserializeObject(sub);
			//获取汇总
			JArray subsum_arra = (JArray)Newtonsoft.Json.JsonConvert.DeserializeObject(subsum);

			//回写报工记录主表、工单工序表已入库数量、写入MES库存表
			for (int i = 0; i < sub_arra.Count; i++)
			{
			if (sub_arra[i]["style"].ToString() == "B")
			{
			//回写报工记录主表的入库数量
			sql = @"update TK_Wrk_Record set inhouseqty=inhouseqty+@stinhouseqty where inbarcode=@inbarcode";
			list.Add(new
			{
			str = sql,
			parm = new
			{
			stinhouseqty = decimal.Parse(sub_arra[i]["stinhouseqty"].ToString()),
			inbarcode = sub_arra[i]["inbarcode"].ToString()
			}
			});
			}
			if (sub_arra[i]["style"].ToString() == "S")
			{
			//回写外协收料记录主表的入库数量
			sql = @"update TK_Wrk_OutRecord set inhouseqty=inhouseqty+@stinhouseqty where inbarcode=@inbarcode";
			list.Add(new
			{
			str = sql,
			parm = new
			{
			stinhouseqty = decimal.Parse(sub_arra[i]["stinhouseqty"].ToString()),
			inbarcode = sub_arra[i]["inbarcode"].ToString()
			}
			});
			}
			//回写工单工序表末道工序已入库数量
			sql = @"update TK_Wrk_Step set inhouseqty=inhouseqty+@stinhouseqty where wo_code=@wo_code and step_code=@step_code and isend='Y'";
			list.Add(new
			{
			str = sql,
			parm = new
			{
			stinhouseqty = decimal.Parse(sub_arra[i]["stinhouseqty"].ToString()),
			wo_code = sub_arra[i]["wo_code"].ToString(),
			step_code = sub_arra[i]["step_code"].ToString()
			}
			});
			//写入MES库存表
			sql = @"insert into TK_WMS_Stock(hbillno,labcode,materiel_code,storehouse_code,qty,lm_user,lm_date)
			values(@hbillno,@labcode,@materiel_code,@storehouse_code,@qty,@lm_user,@lm_date)";
			list.Add(new
			{
			str = sql,
			parm = new
			{
			hbillno = obj["head"]["hbillno"].ToString(),
			labcode = sub_arra[i]["inbarcode"].ToString(),
			materiel_code = sub_arra[i]["partcode"].ToString(),
			storehouse_code = sub_arra[i]["stockcode"].ToString(),
			qty = decimal.Parse(sub_arra[i]["stinhouseqty"].ToString()),
			lm_user = username,
			lm_date = DateTime.Now.ToString()
			}
			});
			}
			//写MES入库记录主表
			sql = @"insert into TK_WMS_Inwh_Main(docu_typecode,hbillno,hsoucenillnoid,hsoucenillno,saleorderid,saleordercode,status,wkshpcode,lm_user,lm_date)
			values(@docu_typecode,@hbillno,@hsoucenillnoid,@hsoucenillno,@saleorderid,@saleordercode,@status,@wkshpcode,@lm_user,@lm_date)";
			list.Add(new
			{
			str = sql,
			parm = new
			{
			docu_typecode = "1202",
			hbillno = obj["head"]["hbillno"].ToString(),
			hsoucenillnoid = obj["head"]["sourceVoucherId"].ToString(),
			hsoucenillno = obj["head"]["sourceVoucherCode"].ToString(),
			saleorderid = obj["head"]["saleOrderId"].ToString(),
			saleordercode = obj["head"]["saleOrderCode"].ToString(),
			status = "NEW",
			wkshpcode = obj["head"]["wkshpcode"].ToString(),
			lm_user = username,
			lm_date = DateTime.Now.ToString()
			}
			});

			//获取ERP入库表sql
			//DataTable dt = DapperHelper.lissql("h_p_MesInErpProductWareHous");
			//写入ERP入库记录主表
			//sql = @"" + dt.Rows[0]["cname"].ToString() + "";
			//list.Add(new
			//{
			// str = sql,
			// parm = new
			// {
			// code = obj["head"]["hbillno"].ToString(),
			// sourceVoucherId = obj["head"]["sourceVoucherId"].ToString(),
			// sourceVoucherCode = obj["head"]["sourceVoucherCode"].ToString(),
			// saleOrderId = obj["head"]["saleOrderId"].ToString(),
			// saleOrderCode = obj["head"]["saleOrderCode"].ToString(),
			// rdDirectionFlag = obj["head"]["rdDirectionFlag"].ToString(),
			// makerid = obj["head"]["makerid"].ToString(),
			// maker = obj["head"]["maker"].ToString(),
			// accountingyear = obj["head"]["accountingyear"].ToString(),
			// VoucherYear = obj["head"]["VoucherYear"].ToString(),
			// VoucherPeriod = obj["head"]["VoucherPeriod"].ToString(),
			// ManufactureOrderCode = obj["head"]["ManufactureOrderCode"].ToString(),
			// idbusitype = obj["head"]["idbusitype"].ToString(),
			// iddepartment = obj["head"]["iddepartment"].ToString(),
			// idrdstyle = obj["head"]["idrdstyle"].ToString(),
			// idwarehouse = obj["head"]["idwarehouse"].ToString(),
			// voucherState = obj["head"]["voucherState"].ToString(),
			// idvouchertype = obj["head"]["idvouchertype"].ToString(),
			// voucherdate = obj["head"]["voucherdate"].ToString(),
			// madedate = obj["head"]["madedate"].ToString(),
			// createdtime = obj["head"]["createdtime"].ToString(),
			// DataSource = obj["head"]["DataSource"].ToString(),
			// idsourcevouchertype= obj["head"]["idsourcevouchertype"].ToString()

			// }
			//});
			//写入ERP、MES入库记录子表
			for (int j = 0; j < subsum_arra.Count; j++)
			{
			//写入ERP入库记录子表
			//sql = @"" + dt.Rows[1]["cname"].ToString() + "";
			//list.Add(new
			//{
			// str = sql,
			// parm = new
			// {
			// code = subsum_arra[j]["code"].ToString(),
			// arrivalQuantity = subsum_arra[j]["arrivalQuantity"].ToString(),
			// quantity = subsum_arra[j]["quantity"].ToString(),
			// compositionQuantity = subsum_arra[j]["compositionQuantity"].ToString(),
			// baseQuantity = subsum_arra[j]["baseQuantity"].ToString(),
			// sourceVoucherId = subsum_arra[j]["sourceVoucherId"].ToString(),
			// sourceVoucherCode = subsum_arra[j]["sourceVoucherCode"].ToString(),
			// sourceVoucherDetailId = subsum_arra[j]["sourceVoucherDetailId"].ToString(),
			// idsourcevouchertype = subsum_arra[j]["idsourcevouchertype"].ToString(),
			// saleOrderId = subsum_arra[j]["saleOrderId"].ToString(),
			// saleOrderCode = subsum_arra[j]["saleOrderCode"].ToString(),
			// saleOrderDetailId = subsum_arra[j]["saleOrderDetailId"].ToString(),
			// ManufactureOrderId = subsum_arra[j]["ManufactureOrderId"].ToString(),
			// ManufactureOrderCode = subsum_arra[j]["ManufactureOrderCode"].ToString(),
			// ManufactureOrderDetailId = subsum_arra[j]["ManufactureOrderDetailId"].ToString(),
			// idbusiTypeByMergedFlow = subsum_arra[j]["idbusiTypeByMergedFlow"].ToString(),
			// idinventory = subsum_arra[j]["idinventory"].ToString(),
			// idbaseunit = subsum_arra[j]["idbaseunit"].ToString(),
			// idunit = subsum_arra[j]["idunit"].ToString(),
			// idwarehouse = subsum_arra[j]["idwarehouse"].ToString(),
			// SourceVoucherIdByMergedFlow = subsum_arra[j]["SourceVoucherIdByMergedFlow"].ToString(),
			// SourceVoucherCodeByMergedFlow = subsum_arra[j]["SourceVoucherCodeByMergedFlow"].ToString(),
			// SourceVoucherDetailIdByMergedFlow = subsum_arra[j]["SourceVoucherDetailIdByMergedFlow"].ToString(),
			// idsourceVoucherTypeByMergedFlow = subsum_arra[j]["idsourceVoucherTypeByMergedFlow"].ToString(),
			// createdtime = subsum_arra[j]["createdtime"].ToString(),
			// DataSource = subsum_arra[j]["DataSource"].ToString()
			// }
			//});
			//写入ERP现存量查询表
			//sql = @"" + dt.Rows[2]["cname"].ToString() + "";
			//list.Add(new
			//{
			// str = sql,
			// parm = new
			// {
			// idinventory = subsum_arra[j]["idinventory"].ToString(),
			// idwarehouse = subsum_arra[j]["idwarehouse"].ToString(),
			// propertyName = "ProductForReceive",
			// baseQuantity= subsum_arra[j]["quantity"].ToString(),
			// IdMarketingOrgan="1",
			// idbaseunit= subsum_arra[j]["idbaseunit"].ToString(),
			// updated= DateTime.Now.ToString(),
			// isCarriedForwardOut ="0",
			// isCarriedForwardIn = "0"
			// }
			//});



			//写入MES入库记录子表
			sql = @"insert into TK_WMS_Inwh_Sub(hbillno,rownumber,materiel_code,storehouse_code,qty)
			values(@hbillno,@rownumber,@materiel_code,@storehouse_code,@qty)";
			list.Add(new
			{
			str = sql,
			parm = new
			{
			hbillno = obj["head"]["hbillno"].ToString(),
			rownumber = subsum_arra[j]["rownumber"].ToString(),
			materiel_code = subsum_arra[j]["materiel_code"].ToString(),
			storehouse_code = subsum_arra[j]["warehouse"].ToString(),
			qty = decimal.Parse(subsum_arra[j]["quantity"].ToString())
			}
			});
			}
			//更新单据流水号
			List<object> list1 = SeachEncodeJob.StrEncodingUpdate(obj["head"]["rightcode"].ToString(), obj["head"]["incbit"].ToString());
			list.Add(list1[0]);
			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

			}
			}