JLApi.git - Gitblit

			@@ -42,408 +42,7 @@
			#endregion


			#region[ERP订单查询]
			public static ToMessage ErpOrderSearch(string stu_torgcode, string stu_torgtypecode, string erporderstus, string erpordercode, string partcode, string partname, string partspec, int startNum, string paydatestartdate, string paydateenddate, string paydatestartdate1, string paydateenddate2, string creatuser, int endNum, string prop, string order)
			{
			var dynamicParams = new DynamicParameters();
			string search = "";
			try
			{
			switch (stu_torgtypecode)
			{
			case "":
			break;
			case "D":
			search += "and L.org_code=@stu_torgcode ";
			dynamicParams.Add("@stu_torgcode", stu_torgcode);
			break;
			case "W":
			search += "and C.org_code=@stu_torgcode ";
			dynamicParams.Add("@stu_torgcode", stu_torgcode);
			break;
			default:
			break;
			}
			if (erporderstus != "" && erporderstus != null)
			{
			search += "and A.status=@erporderstus ";
			dynamicParams.Add("@erporderstus", erporderstus);
			}
			if (erpordercode != "" && erpordercode != null)
			{
			search += "and A.wo like '%'+@erpordercode+'%' ";
			dynamicParams.Add("@erpordercode", erpordercode);
			}
			if (partcode != "" && partcode != null)
			{
			search += "and A.materiel_code like '%'+@partcode+'%' ";
			dynamicParams.Add("@partcode", partcode);
			}
			if (partname != "" && partname != null)
			{
			search += "and B.partname like '%'+@partname+'%' ";
			dynamicParams.Add("@partname", partname);
			}
			if (partspec != "" && partspec != null)
			{
			search += "and B.partspec like '%'+@partspec+'%' ";
			dynamicParams.Add("@partspec", partspec);
			}
			if (paydatestartdate != "" && paydatestartdate != null)
			{
			search += "and A.planstartdate between @paydatestartdate and @paydateenddate ";
			dynamicParams.Add("@paydatestartdate", paydatestartdate + " 00:00:00");
			dynamicParams.Add("@paydateenddate", paydateenddate + " 23:59:59");
			}
			if (paydatestartdate1 != "" && paydatestartdate1 != null)
			{
			search += "and A.planenddate between @paydatestartdate1 and @paydateenddate2 ";
			dynamicParams.Add("@paydatestartdate1", paydatestartdate1);
			dynamicParams.Add("@paydateenddate2", paydateenddate2 + " 23:59:59");
			}
			if (creatuser != "" && creatuser != null)
			{
			search += "and U.username like '%'+@creatuser+'%' ";
			dynamicParams.Add("@creatuser", creatuser);
			}

			if (search == "")
			{
			search = "and 1=1 ";
			}
			// --------------查询指定数据--------------
			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,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
			left join T_Sec_Stck D on A.stck_code=D.code
			left join TUser U on A.createuser=U.usercode
			left join TOrganization L on C.parent_id=L.id
			where A.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[ERP订单下达]
			public static ToMessage MarkSaveErpOrder(string erporderid, string erpordercode, string partcode, string wkshopcode, string warehousecode, string erpqty, string markqty, string ordernum, string relse_qty, string saleOrderDeliveryDate, string username)
			{
			var sql = "";
			List<object> list = new List<object>();
			var dynamicParams = new DynamicParameters();

			try
			{
			list.Clear();
			//获取拆单数量:向下取整
			decimal cdqty = Math.Floor(decimal.Parse(markqty) / decimal.Parse(ordernum));
			//定义累计下单数量
			decimal sumqty = 0;
			//定义最新生成的工单号
			string wo = "";
			//定义工单流水号
			int num = 0;
			//循环下单单数(生成对应几张MES工单)
			for (int i = 1; i <= Convert.ToInt32(ordernum); i++)
			{
			sumqty += cdqty;
			//获取最大单据号
			if (i == 1) //首单获取工单号
			{
			sql = @"select isnull(max(cast(substring(wo_code,charindex('_',wo_code)+1,len(wo_code)-charindex('_',wo_code)) as numeric)),0)+1 as worknumb
			from TK_Wrk_Man where m_po=@erpordercode";
			dynamicParams.Add("@erpordercode", erpordercode);
			var data = DapperHelper.selectdata(sql, dynamicParams);
			num = Convert.ToInt32(data.Rows[0]["WORKNUMB"].ToString());
			wo = erpordercode + "_" + num;
			}
			else
			{
			num = num + 1;
			wo = erpordercode + "_" + num;
			}
			if (i == Convert.ToInt32(ordernum)) //最后一单时
			{
			sql = @"insert into TK_Wrk_Man(wo_code,wotype,status,wkshp_code,plan_qty,stck_code,materiel_code,sourceid,m_po,lm_user,lm_date,saleOrderDeliveryDate) values(@wo_code,@wotype,@status,@wkshp_code,@plan_qty,@stck_code,@materiel_code,@sourceid,@m_po,@username,@CreateDate,@saleOrderDeliveryDate)";
			list.Add(new
			{
			str = sql,
			parm = new
			{
			wo_code = wo,
			wotype = "PO",
			status = "NEW",
			wkshp_code = wkshopcode,
			plan_qty = cdqty + (decimal.Parse(markqty) - sumqty), //末单下单数量=切分数量+(下单数量-累计切分下单数量)
			stck_code = warehousecode,
			materiel_code = partcode,
			sourceid = erporderid,
			m_po = erpordercode,
			username = username,
			CreateDate = DateTime.Now.ToString(),
			saleOrderDeliveryDate = Convert.ToDateTime(saleOrderDeliveryDate)
			}
			});
			sumqty = sumqty + (decimal.Parse(markqty) - sumqty);
			}
			else
			{

			sql = @"insert into TK_Wrk_Man(wo_code,wotype,status,wkshp_code,plan_qty,stck_code,materiel_code,sourceid,m_po,lm_user,lm_date,saleOrderDeliveryDate) values(@wo_code,@wotype,@status,@wkshp_code,@plan_qty,@stck_code,@materiel_code,@sourceid,@m_po,@username,@CreateDate,@saleOrderDeliveryDate)";
			list.Add(new
			{
			str = sql,
			parm = new
			{
			wo_code = wo,
			wotype = "PO",
			status = "NEW",
			wkshp_code = wkshopcode,
			plan_qty = cdqty,
			stck_code = warehousecode,
			materiel_code = partcode,
			sourceid = erporderid,
			m_po = erpordercode,
			username = username,
			CreateDate = DateTime.Now.ToString(),
			saleOrderDeliveryDate = Convert.ToDateTime(saleOrderDeliveryDate)
			}
			});
			}
			}
			if (decimal.Parse(erpqty) == decimal.Parse(markqty) + decimal.Parse(relse_qty)) //如果ERP订单=下单数量+已下单数量,则更新ERP订单表状态为CREATED:已创建
			{
			sql = @"update TKimp_Ewo set status='CREATED',saleOrderDeliveryDate=@saleOrderDeliveryDate,relse_qty=relse_qty+@sumqty where wo=@wo and id=@erporderid";
			list.Add(new
			{
			str = sql,
			parm = new
			{
			wo = erpordercode,
			erporderid = erporderid,
			sumqty = sumqty,
			saleOrderDeliveryDate = Convert.ToDateTime(saleOrderDeliveryDate)
			}
			});
			}
			else //更新ERP订单表状态为CREATING:创建中
			{
			sql = @"update TKimp_Ewo set status='CREATING',saleOrderDeliveryDate=@saleOrderDeliveryDate,relse_qty=relse_qty+@sumqty where wo=@wo and id=@erporderid";
			list.Add(new
			{
			str = sql,
			parm = new
			{
			wo = erpordercode,
			erporderid = erporderid,
			sumqty = sumqty,
			saleOrderDeliveryDate = Convert.ToDateTime(saleOrderDeliveryDate)
			}
			});
			}
			bool aa = DapperHelper.DoTransaction(list);
			if (aa)
			{
			mes.code = "200";
			mes.count = 0;
			mes.Message = "下达MES工单成功!";
			mes.data = null;
			}
			else
			{
			mes.code = "300";
			mes.count = 0;
			mes.Message = "下达MES工单成功失败!";
			mes.data = null;
			}
			}
			catch (Exception e)
			{
			mes.code = "300";
			mes.count = 0;
			mes.Message = e.Message;
			mes.data = null;
			}
			return mes;
			}
			#endregion

			#region[ERP订单关闭]
			public static ToMessage ClosedErpOrder(string erporderid, string erpordercode, string username)
			{
			var sql = "";
			List<object> list = new List<object>();
			var dynamicParams = new DynamicParameters();
			try
			{
			sql = @"select * from TK_Wrk_Man where m_po=@erpordercode and status<> 'CLOSED'";
			dynamicParams.Add("@erpordercode", erpordercode);
			var data = DapperHelper.selectdata(sql, dynamicParams);
			if (data.Rows.Count > 0)
			{
			mes.code = "300";
			mes.count = 0;
			mes.Message = "当前订单有下达未关闭的MES工单,订单不允许关闭,请先删除或关闭相关工单!";
			mes.data = null;
			}
			else
			{
			//关闭订单
			sql = @"update TKimp_Ewo set status='CLOSED' where wo=@wo and id=@erporderid";
			list.Add(new
			{
			str = sql,
			parm = new
			{
			wo = erpordercode,
			erporderid = erporderid
			}
			});
			}
			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[MES工单查询]
			public static ToMessage MesOrderSearch(string stu_torgcode, string stu_torgtypecode, string mesorderstus, string mesordercode, string sourceorder, string ordertype, string partcode, string partname, string partspec, int startNum, string creatuser, string createdate, int endNum, string prop, string order)
			{
			var dynamicParams = new DynamicParameters();
			string search = "";
			try
			{
			switch (stu_torgtypecode)
			{
			case "":
			break;
			case "D":
			search += "and L.org_code=@stu_torgcode ";
			dynamicParams.Add("@stu_torgcode", stu_torgcode);
			break;
			case "W":
			search += "and C.org_code=@stu_torgcode ";
			dynamicParams.Add("@stu_torgcode", stu_torgcode);
			break;
			default:
			break;
			}
			if (mesorderstus != "" && mesorderstus != null)
			{
			search += "and A.status=@mesorderstus ";
			dynamicParams.Add("@mesorderstus", mesorderstus);
			}
			if (mesordercode != "" && mesordercode != null)
			{
			search += "and A.wo_code like '%'+@mesordercode+'%' ";
			dynamicParams.Add("@mesordercode", mesordercode);
			}
			if (sourceorder != "" && sourceorder != null)
			{
			search += "and A.m_po like '%'+@sourceorder+'%' ";
			dynamicParams.Add("@sourceorder", sourceorder);
			}
			if (ordertype != "" && ordertype != null)
			{
			search += "and A.wotype like '%'+@ordertype+'%' ";
			dynamicParams.Add("@ordertype", ordertype);
			}
			if (partcode != "" && partcode != null)
			{
			search += "and A.materiel_code like '%'+@partcode+'%' ";
			dynamicParams.Add("@partcode", partcode);
			}
			if (partname != "" && partname != null)
			{
			search += "and B.partname like '%'+@partname+'%' ";
			dynamicParams.Add("@partname", partname);
			}
			if (partspec != "" && partspec != null)
			{
			search += "and B.partspec like '%'+@partspec+'%' ";
			dynamicParams.Add("@partspec", partspec);
			}
			if (createdate != "" && createdate != null)
			{
			search += "and CONVERT(varchar(100),A.lm_date,23)=@createdate ";
			dynamicParams.Add("@createdate", createdate);
			}
			if (creatuser != "" && creatuser != null)
			{
			search += "and U.username like '%'+@creatuser+'%' ";
			dynamicParams.Add("@creatuser", creatuser);
			}

			if (search == "")
			{
			search = "and 1=1 ";
			}
			// --------------查询指定数据--------------
			var total = 0; //总条数
			var sql = @"select A.id, A.status,A.wotype,A.wo_code,A.materiel_code as partcode,B.partname,B.partspec,A.plan_qty,A.wkshp_code,C.org_name as wkshp_name,
			A.route_code,E.name as route_name,A.stck_code,F.name as stck_name,A.plan_startdate,A.plan_enddate,A.piroque,A.sourceid,A.m_po,U.username as lm_user,A.lm_date
			from TK_Wrk_Man A
			left join TMateriel_Info B on A.materiel_code=B.partcode
			left join TOrganization C on A.wkshp_code=C.org_code
			left join T_Sec_Stck D on A.stck_code=D.code
			left join TFlw_Rout E on A.route_code=E.code
			left join T_Sec_Stck F on A.stck_code=F.code
			left join TUser U on A.lm_user=U.usercode
			left join TOrganization L on C.parent_id=L.id
			where A.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[MES报废补单工单查询]
			public static ToMessage MesBadOrderSearch(string mesordercode, string sourceorder, string partcode, string partname, string partspec, int startNum, string creatuser, string createdate, int endNum, string prop, string order)