ZQHApi.git - Gitblit

			@@ -1,4 +1,5 @@
			using Dapper;
			using Newtonsoft.Json.Linq;
			using System;
			using System.Collections.Generic;
			using System.Data;
			@@ -35,7 +36,7 @@
			//查询未关闭且未全部到货的采购订单
			sql = @"select distinct A.ordercode from T_PurchaseOrder A
			inner join T_PurchaseOrder_sub B on A.ordercode=B.purchaseorder_code
			where B.countarrivalquantity<quantity" + search;
			where B.countarrivalquantity<quantity and A.status<>'CLOSED'" + search;
			dynamicParams.Add("@purchordercode", purchordercode);
			var data = DapperHelper.selectdata(sql, dynamicParams);
			if (data.Rows.Count > 0)
			@@ -79,7 +80,7 @@
			left join TUom U on M.uom_code=U.code
			left join TCustomer C on B.customercode=C.code
			left join TOrganization T on A.departmentcode=T.org_code
			where A.ordercode=@purchordercode";
			where B.quantity>B.countarrivalquantity and A.ordercode=@purchordercode";
			dynamicParams.Add("@purchordercode", purchordercode);
			var data = DapperHelper.selectdata(sql, dynamicParams);
			if (data.Rows.Count > 0)
			@@ -109,7 +110,7 @@
			#region[采购到货：生成系统条码]
			public static ToMessage MesAppPurchOrderLabelBarCode(string partcode, string arrivalqty, string onelableqty)
			{
			mes = AppLableBarCode.EncodingSeach("2060", partcode, arrivalqty, onelableqty);
			mes = AppLableBarCode.EncodingSeach("2018", partcode, arrivalqty, onelableqty);
			return mes;
			}
			#endregion
			@@ -157,7 +158,7 @@
			{
			hbillno = djwo,
			hdate = DateTime.Now.ToString(),
			hacceptdate =hacceptdate==""?null:hacceptdate,
			hacceptdate = hacceptdate == "" ? null : hacceptdate,
			hbillstaus = orderstaus,
			hdepartmentcode = dpartment,
			hcustomercode = customercode,
			@@ -178,7 +179,7 @@
			parm = new
			{
			hbillno = djwo,
			rownumber=json[i].rownumber,
			rownumber = json[i].rownumber,
			hpartcode = json[i].hpartcode,
			hplanqty = decimal.Parse(json[i].hplanqty),
			hqty = decimal.Parse(json[i].hqty),
			@@ -192,8 +193,8 @@
			for (int j = 0; j < json[i].children.Count; j++)
			{
			//写入条码档案表
			sql = @"insert into T_BarCodeBill(rightcode,hbillno,hbilltype,hbarcode,hbarcodestatus,hbarcodetype,hmaterialcode,hqty,hbatchno,hcustomercode,hdeptcode,hsourcebillno,hsourcebilltype,barcodeposition,lm_user,lm_date)
			values(@rightcode,@hbillno,@hbilltype,@hbarcode,@hbarcodestatus,@hbarcodetype,@hmaterialcode,@hqty,@hbatchno,@hcustomercode,@hdeptcode,@hsourcebillno,@hsourcebilltype,@barcodeposition,@lm_user,@lm_date)";
			sql = @"insert into T_BarCodeBill(rightcode,hbillno,hbilltype,hbarcode,qualitystatus,hbarcodestatus,hbarcodetype,hmaterialcode,hqty,hbatchno,hcustomercode,hdeptcode,hsourcebillno,hsourcebilltype,barcodeposition,lm_user,lm_date)
			values(@rightcode,@hbillno,@hbilltype,@hbarcode,@qualitystatus,@hbarcodestatus,@hbarcodetype,@hmaterialcode,@hqty,@hbatchno,@hcustomercode,@hdeptcode,@hsourcebillno,@hsourcebilltype,@barcodeposition,@lm_user,@lm_date)";
			list.Add(new
			{
			str = sql,
			@@ -203,6 +204,7 @@
			hbillno = djwo,
			hbilltype = "1103", //采购到货单类型
			hbarcode = json[i].children[j].labcode,
			qualitystatus= json[i].hischeck=="Y"? "TS" : "CS",
			hbarcodestatus = "Y",
			hbarcodetype = "P",
			hmaterialcode = json[i].children[j].partnumber,
			@@ -212,7 +214,7 @@
			hdeptcode = dpartment,
			hsourcebillno = purordercode,
			hsourcebilltype = "1102",
			barcodeposition="2060;采购到货",
			barcodeposition = "2060;采购到货",
			lm_user = username,
			lm_date = DateTime.Now.ToString()
			}
			@@ -227,8 +229,8 @@
			{
			purordercode = purordercode,
			materiel_code = json[i].hpartcode,
			rownumber=json[i].rownumber,
			hqty=decimal.Parse(json[i].hqty)
			rownumber = json[i].rownumber,
			hqty = decimal.Parse(json[i].hqty)
			}
			});
			}
			@@ -315,13 +317,13 @@
			try
			{
			//选择采购订单带出订单下有到货的物料信息
			sql = @"select A.ordercode,M.partcode,M.partname,M.partspec,avg(S.hplanqty) as hplanqty,sum(S.hqty) as hqty
			sql = @"select A.ordercode,M.partcode,M.partname,M.partspec,A.customercode,A.departmentcode,avg(S.hplanqty) as hplanqty,sum(S.hqty) as hqty
			from T_PurchaseOrder A
			inner join T_PurchaseArrivalOrder B on A.ordercode=B.hsourcebillno
			inner join T_PurchaseArrivalOrder_sub S on B.hbillno=S.hbillno
			left join TMateriel_Info M on S.hpartcode=M.partcode
			where B.hbillstaus in('BINARIVE','INARIVE','BINSTOG') and A.ordercode=@ordercode
			group by A.ordercode,M.partcode,M.partname,M.partspec";
			group by A.ordercode,M.partcode,M.partname,M.partspec,A.customercode,A.departmentcode";
			dynamicParams.Add("@ordercode", ordercode);
			var data = DapperHelper.selectdata(sql, dynamicParams);
			if (data.Rows.Count > 0)
			@@ -349,15 +351,15 @@
			#endregion

			#region[采购入库扫描标签条码带出到货单信息]
			public static ToMessage MesAppPurchInStorScanLabCode(string labcode,string ordercode)
			public static ToMessage MesAppPurchInStorScanLabCode(string labcode, string ordercode)
			{
			string sql = "";
			var dynamicParams = new DynamicParameters();
			try
			{
			//判断条码状态
			mes = LabCodeStatusMessage.LabCodeStatus("2060", "1103",labcode);//功能编号、单据类型编码、标签编码
			if (mes.code == "300")
			mes = LabCodeStatusMessage.LabCodeStatus("2060", "1103", labcode);//功能编号、单据类型编码、标签编码
			if (mes.code == "300")
			{
			return mes;
			}
			@@ -365,10 +367,10 @@
			sql = @"select * from T_BarCodeBill where hsourcebillno=@ordercode";
			dynamicParams.Add("@ordercode", ordercode);
			var data0 = DapperHelper.selectdata(sql, dynamicParams);
			if (data0.Rows.Count < 0)
			if (data0.Rows.Count < 0)
			{
			mes.code = "300";
			mes.Message = "当前条码不是采购订单【"+ ordercode + "】生成条码!";
			mes.Message = "当前条码不是采购订单【" + ordercode + "】生成条码!";
			mes.data = null;
			return mes;
			}
			@@ -403,5 +405,300 @@
			}
			#endregion

			#region[采购入库提交]
			public static ToMessage MesAppPurchInStorSave(string ordercode, string username, string incontent)
			{
			var sql = "";
			string djwo = "", numvalue = "";
			List<object> list = new List<object>();
			List<ObjectData> obj = new List<ObjectData>();
			var dynamicParams = new DynamicParameters();
			try
			{
			string datetime = DateTime.Now.ToString(); //获取系统时间
			mes = SeachEncode.EncodingSeach("2061"); //APP端采购入库生成单号
			if (mes.code == "300")
			{
			return mes;
			}
			else
			{
			List<string> wo = (List<string>)mes.data;
			djwo = wo[0].ToString(); //获取单号
			numvalue = wo[1].ToString(); //获取流水号
			}
			//获取提交信息
			JArray arra = (JArray)Newtonsoft.Json.JsonConvert.DeserializeObject(incontent);
			list.Clear();
			//写入入库记录主表
			sql = @"insert into TK_WMS_Inwh_Main(docu_typecode,hbillno,hsoucenillno,status,hcustomer,hdempart,lm_user,lm_date)
			values(@docu_typecode,@hbillno,@hsoucenillno,@status,@hcustomer,@hdempart,@lm_user,@lm_date)";
			list.Add(new
			{
			str = sql,
			parm = new
			{
			docu_typecode = "1201",
			hbillno = djwo,
			hsoucenillno = ordercode,
			status = "NEW",
			hcustomer = arra[0]["customercode"].ToString(),
			hdempart = arra[0]["departmentcode"].ToString(),
			lm_user = username,
			lm_date = datetime
			}
			});
			//根据源单+物料查询采购订单到货总数、入库总数
			sql = @"select sum(B.quantity) as quantity,sum(B.countarrivalquantity) as countarrivalquantity,
			sum(B.countInquantity) as countInquantity
			from T_PurchaseOrder A
			inner join T_PurchaseOrder_sub B on A.ordercode=B.purchaseorder_code
			where ordercode=@ordercode";
			dynamicParams.Add("@ordercode", ordercode);
			var data0 = DapperHelper.selectdata(sql, dynamicParams);
			decimal quantity = decimal.Parse(data0.Rows[0]["quantity"].ToString()); //采购订单累计任务数量
			decimal countarrivalquantity = decimal.Parse(data0.Rows[0]["countarrivalquantity"].ToString()); //采购订单累计到货数量
			decimal countInquantity = decimal.Parse(data0.Rows[0]["countInquantity"].ToString()); //采购订单累计入库数量

			string storg = "";//采购订单入库状态
			decimal partlabqty = 0; //当前标签累计数量

			for (int i = 1; i <= arra.Count; i++)//循环获取物料信息
			{
			string labcode = "";//标签信息
			decimal suminqty = 0; //单标签入库总数量
			string batchno = ""; //批次号

			//查询汇总标签信息
			for (int j = 0; j < arra[i]["labcont"].Count(); j++)//循环获取标签信息
			{

			//更新到货单子表入库数量
			sql = @"update T_PurchaseArrivalOrder_sub set hinqty=isnull(hinqty,0)+@inqty where hbillno=@hbillno and hpartcode=@hpartcode";
			list.Add(new
			{
			str = sql,
			parm = new
			{
			hbillno = arra[i]["labcont"][j]["arrivelorder"].ToString(),
			hpartcode = arra[i]["partcode"].ToString(),
			hinqty = decimal.Parse(arra[i]["labcont"][j]["qty"].ToString())
			}
			});
			labcode = labcode + arra[i]["labcont"][j]["labcode"].ToString() + ",";
			suminqty = suminqty + decimal.Parse(arra[i]["labcont"][j]["qty"].ToString());
			partlabqty = partlabqty + decimal.Parse(arra[i]["labcont"][j]["qty"].ToString());
			batchno = arra[i]["labcont"][j]["batch"].ToString();
			}

			//更新采购订单子表入库数量
			sql = @"update T_PurchaseOrder_sub set countInquantity=isnull(countInquantity,0)+@countInquantity
			where purchaseorder_code=@purchaseorder_code and materiel_code=@materiel_code";
			list.Add(new
			{
			str = sql,
			parm = new
			{
			purchaseorder_code = ordercode,
			materiel_code = arra[i]["partcode"].ToString(),
			countInquantity = partlabqty
			}
			});

			//写入采购入库单子表
			sql = @"insert into TK_WMS_Inwh_Sub(hbillno,labcode,rownumber,materiel_code,storehouse_code,location_code,qty,batchno)
			values(@hbillno,@labcode,@rownumber,@materiel_code,@storehouse_code,@location_code,@qty,@batchno)";
			labcode = string.Format("'{0}'", labcode.Substring(0, labcode.Length - 1).Replace(",", "','"));
			list.Add(new
			{
			str = sql,
			parm = new
			{
			hbillno = djwo,
			labcode = labcode,
			rownumber = i,
			materiel_code = arra[i]["partcode"].ToString(),
			storehouse_code = arra[i]["storehousecode"].ToString(),
			location_code = arra[i]["warehousecode"].ToString(),
			qty = suminqty,
			batchno = batchno
			}
			});
			//写入库存表前查询当前物料在库存表中是否存在,写入或更新库存表
			sql = @"select * from TK_WMS_Stock where materiel_code=@materiel_code";
			dynamicParams.Add("@materiel_code", arra[i]["partcode"].ToString());
			var data1 = DapperHelper.selectdata(sql, dynamicParams);
			if (data1.Rows.Count > 0)
			{
			sql = @"update TK_WMS_Stock set qty=qty+@suminqty
			where materiel_code=@materiel_code";
			list.Add(new
			{
			str = sql,
			parm = new
			{
			materiel_code = arra[i]["partcode"].ToString(),
			suminqty = suminqty
			}
			});
			}
			else
			{
			sql = @"insert into TK_WMS_Stock(materiel_code,batchno,storehouse_code,location_code,customercode,qty,lm_user,lm_date)
			values(materiel_code,batchno,storehouse_code,location_code,customercode,qty,lm_user,lm_date)";
			list.Add(new
			{
			str = sql,
			parm = new
			{
			materiel_code = arra[i]["partcode"].ToString(),
			batchno = batchno,
			storehouse_code= arra[i]["storehousecode"].ToString(),
			location_code= arra[i]["warehousecode"].ToString(),
			customercode= arra[i]["customercode"].ToString(),
			qty= suminqty,
			lm_user=username,
			lm_date= datetime,
			}
			});
			}
			/写入ERP采购入库单***********
			* ***********************
			* **********************
			**********************/
			}
			//更新采购定单状态(部分入库、已入库)
			if ((countInquantity + partlabqty) < countarrivalquantity) //当前采购订单累计已入库+本次总入库<当前采购订单累计到货=部分入库
			{
			storg = "BINSTOG";
			}
			else
			{
			storg = "INSTOG";
			}
			//更新采购订单主表单据状态
			sql = @"update T_PurchaseOrder set status=@storg
			where ordercode=@ordercode";
			list.Add(new
			{
			str = sql,
			parm = new
			{
			ordercode = ordercode,
			storg = storg
			}
			});

			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 MesAppPurchaseReturnOrderSearch(string purchordercode)
			{
			string sql = "";
			string search = "";
			var dynamicParams = new DynamicParameters();
			try
			{
			if (purchordercode != "" && purchordercode != null) //订单号不为空
			{
			search += " and A.ordercode like '%'+@purchordercode+'%' ";
			}
			//查询未关闭且有到货的采购订单
			sql = @"select distinct A.ordercode from T_PurchaseOrder A
			inner join T_PurchaseOrder_sub B on A.ordercode=B.purchaseorder_code
			where B.countarrivalquantity<=quantity and A.status<>'CLOSED'" + search;
			dynamicParams.Add("@purchordercode", purchordercode);
			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 = "无订单数据!";
			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 MesAppPurchReturnOrderPartSearch(string purchordercode)
			{
			string sql = "";
			var dynamicParams = new DynamicParameters();
			try
			{
			//根据采购订单号查询非关闭状态下有到货且到货数量大于0的物料
			sql = @"select B.rownumber, B.materiel_code as partcode,M.partname,M.partspec,
			B.quantity,B.countarrivalquantity,U.code as uomcode,U.name as uomname
			from T_PurchaseOrder A
			inner join T_PurchaseOrder_sub B on A.ordercode=B.purchaseorder_code
			left join TMateriel_Info M on B.materiel_code=M.partcode
			left join TUom U on M.uom_code=U.code
			where B.countarrivalquantity>0 and A.status<>'CLOSED' and A.ordercode=@purchordercode";
			dynamicParams.Add("@purchordercode", purchordercode);
			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 = "暂无物料数据!";
			mes.data = null;
			}
			}
			catch (Exception e)
			{
			mes.code = "300";
			mes.count = 0;
			mes.Message = e.Message;
			mes.data = null;
			}
			return mes;
			}
			#endregion

			}
			}