ZQHApi.git - Gitblit

			@@ -629,7 +629,7 @@
			dynamicParams.Add("@step_code", dtck1.Rows[i]["step_code"].ToString());
			var dtck2 = DapperHelper.selectdata(sql, dynamicParams);
			int query = dtck2.AsEnumerable().Where<DataRow>(a => a["enable"].ToString() =="N").Count();
			if (dtck1.Rows.Count == query)
			if (dtck2.Rows.Count == query)
			{
			mes.code = "300";
			mes.count = 0;
			@@ -4010,6 +4010,254 @@
			}
			#endregion

			#region[NEW排产设备信息]
			public static List<AdvancedSchedulingDevice> NewOnclickAdvancedSchedulingDevice(List<ApsOrderSerch> json, ref ToMessage mes)
			{
			string sql = "", sql0 = "";
			var dynamicParams = new DynamicParameters();
			List<AdvancedSchedulingDevice> list = new List<AdvancedSchedulingDevice>();
			DataTable dt, dt1;
			//List<ApsOrderSerch> json = new List<ApsOrderSerch>();
			try
			{
			for (int w = 0; w < json.Count; w++)
			{


			DateTime beginDate = Convert.ToDateTime(json[w].startdate);
			DateTime endDate = DateTime.Parse(json[w].enddate);
			if (beginDate > endDate)
			{
			mes.code = "300";
			mes.count = 0;
			mes.Message = "要求交付时间不能小于当前系统时间！";
			mes.data = null;
			return list;
			}
			bool IsCap = false; //是否设置产能
			//通过工单查找对应车间工艺路线下关键工序所关联的设备是否可用
			sql = @"select distinct C.eqp_code ,D.Enable from TK_Wrk_Man A
			left join TFlw_Rout K on A.route_code=K.code
			left join TFlw_Rtdt B on K.code=B.rout_code and B.first_choke='Y'
			left join TFlw_Rteqp C on B.step_code= C.step_code
			left join TEqpInfo D on C.eqp_code=D.code
			where A.wo_code=@wocode and A.materiel_code=@partcode and D.wksp_code=@wkshpcode";
			dynamicParams.Add("@wocode", json[w].wocode);
			dynamicParams.Add("@partcode", json[w].partcode);
			dynamicParams.Add("@wkshpcode", json[w].wkshpcode);
			var dt_0 = DapperHelper.selectdata(sql, dynamicParams);
			if (dt_0.Rows.Count > 0)
			{
			int cout = dt_0.Rows.Count;
			int num = 0;
			for (int m = 0; m < dt_0.Rows.Count; m++)
			{
			if (dt_0.Rows[m]["Enable"].ToString() == "N")
			{
			num = num + 1;
			}
			}
			if (num == cout)
			{
			mes.code = "300";
			mes.count = 0;
			mes.Message = "设备不可用！";
			mes.data = null;
			return list;
			}
			}
			else
			{
			mes.code = "300";
			mes.count = 0;
			mes.Message = "工艺路线未关联设备！";
			mes.data = null;
			return list;
			}

			//通过工单查找工艺路线对应关键工序所关联的设备所属车间
			sql0 = @"select distinct D.wksp_code from TK_Wrk_Man A
			left join TFlw_Rout K on A.route_code=K.code
			left join TFlw_Rtdt B on K.code=B.rout_code and B.first_choke='Y'
			left join TFlw_Rteqp C on B.step_code= C.step_code
			left join TEqpInfo D on C.eqp_code=D.code
			where A.wo_code=@wocode and A.materiel_code=@partcode ";
			dynamicParams.Add("@wocode", json[w].wocode);
			dynamicParams.Add("@partcode", json[w].partcode);
			var dt0 = DapperHelper.selectdata(sql0, dynamicParams);
			if (dt0.Rows.Count > 0)
			{
			string sy = "0";
			for (int i = 0; i < dt0.Rows.Count; i++)
			{
			if (dt0.Rows[i]["WKSP_CODE"].ToString() == json[w].wkshpcode) //工单创建车间是否等于排产设备车间
			{
			sy = "1";
			break;
			}
			else
			{
			sy = "0";
			}
			}
			if (sy == "0")
			{
			mes.code = "300";
			mes.count = 0;
			mes.Message = "排产设备车间与工单创建的车间不同！";
			mes.data = null;
			return list;
			}
			else
			{
			List<APSList> listData = SchedulingMethod.SchedulingMethodTF(json[w].wocode, json[w].wkshpcode, json[w].partcode);
			for (DateTime date = beginDate; date <= endDate; date = date.AddDays(1))
			{
			AdvancedSchedulingDevice tbj = new AdvancedSchedulingDevice();
			tbj.wo_code = json[w].wocode;
			tbj.YearDate = date.ToString("yyyy-MM-dd");
			tbj.children = new List<AdvancedSchedulingDeviceCont>();
			for (int j = 0; j < listData.Count; j++)
			{
			if (listData[j].AdvaDevicCropMob.ToString() == "0" \|\| listData[j].AdvaDevicRhythm.ToString() == "")
			{
			mes.code = "300";
			mes.count = 0;
			mes.Message = "排程设备" + listData[j].eqp_id.ToString() + "稼动率不能为0或为空！";
			mes.data = null;
			return list;
			}
			if (listData[j].AdvaDevicRhythm.ToString() == "0" \|\| listData[j].AdvaDevicRhythm.ToString() == "")
			{
			mes.code = "300";
			mes.count = 0;
			mes.Message = "排程设备" + listData[j].eqp_id.ToString() + "未设置节拍！";
			mes.data = null;
			return list;
			}
			string sql1 = @"select wktme1_start,wktme2_start,wktme3_start,wktme4_start,wktme5_start,G.name
			from TWkm_capac_plan E
			left join TWkm_capac_plan_sub F on E.id=F.m_id
			left join TBas_wkshift_info G on F.wkshift_code=G.code
			where E.wkshop=@wkshop and E.eqp_typecode=@eqp_typecode and E.ClassType=@classtype
			and CONVERT(varchar(100), F.wkdate, 23)=@wkdate and E.enable='Y'";
			dynamicParams.Add("@wkshop", json[w].wkshpcode);
			dynamicParams.Add("@eqp_typecode", listData[j].Style.ToString());
			dynamicParams.Add("@classtype", listData[j].ClassType.ToString());
			dynamicParams.Add("@wkdate", date.ToString("yyyy-MM-dd"));
			dt1 = DapperHelper.selectdata(sql1, dynamicParams);

			AdvancedSchedulingDeviceCont tbjson = new AdvancedSchedulingDeviceCont();
			tbjson.AdvaDevicNumber = listData[j].eqp_id.ToString();
			tbjson.AdvaDevicName = listData[j].name.ToString();
			tbjson.AdvaDevicCropMob = listData[j].AdvaDevicCropMob.ToString(); //稼动率
			tbjson.AdvaDevicRhythm = listData[j].AdvaDevicRhythm.ToString(); //生产节拍
			if (dt1.Rows.Count > 0)
			{
			tbjson.OneStartDate = dt1.Rows[0]["wktme1_start"].ToString();
			tbjson.TwoStartDate = dt1.Rows[0]["wktme2_start"].ToString();
			tbjson.ThreeStartDate = dt1.Rows[0]["wktme3_start"].ToString();
			tbjson.FourStartDate = dt1.Rows[0]["wktme4_start"].ToString();
			tbjson.FiveStartDate = dt1.Rows[0]["wktme5_start"].ToString();
			tbj.children.Add(tbjson);
			IsCap = true;
			}
			else
			{

			tbjson.OneStartDate = "";
			tbjson.TwoStartDate = "";
			tbjson.ThreeStartDate = "";
			tbjson.FourStartDate = "";
			tbjson.FiveStartDate = "";
			tbj.children.Add(tbjson);
			}
			}

			list.Add(tbj);
			}
			if (list.Select(p => p.children).ToList().Count > 0)
			{
			int one = list.Where(t => t.children.Select(s => s.OneStartDate).Any(x => x != "")).ToList().Count;
			int two = list.Where(t => t.children.Select(s => s.TwoStartDate).Any(x => x != "")).ToList().Count;
			int three = list.Where(t => t.children.Select(s => s.ThreeStartDate).Any(x => x != "")).ToList().Count;
			int four = list.Where(t => t.children.Select(s => s.FourStartDate).Any(x => x != "")).ToList().Count;
			int five = list.Where(t => t.children.Select(s => s.FiveStartDate).Any(x => x != "")).ToList().Count;
			if (one <= 0 && two <= 0 && three <= 0 && four <= 0 && five <= 0)
			{
			mes.code = "300";
			mes.count = 0;
			mes.Message = "当前工单加工产品对应工艺路线设备未设置产能或未设置生产节拍！";
			mes.data = null;
			}
			}
			}
			}
			else
			{
			mes.code = "300";
			mes.count = 0;
			mes.Message = "设备没有关联车间！";
			mes.data = null;
			}
			}
			return list;
			}
			catch (Exception e)
			{
			mes.code = "300";
			mes.count = 0;
			mes.Message = e.Message;
			mes.data = null;
			}
			return list;
			}
			#endregion

			#region[New设备已排程信息]
			public static List<DataTable> NewAlreadyScheduling(List<ApsOrderSerch> json)
			{
			var dynamicParams = new DynamicParameters();
			DataTable dt;
			List<DataTable> list = new List<DataTable>();
			try
			{
			for (int i = 0; i < json.Count; i++)
			{
			List<APSList> listData = SchedulingMethod.SchedulingMethodTF(json[i].wocode, json[i].wkshpcode, json[i].partcode);
			string[] empIds = listData.Select(a => a.eqp_id).ToArray();
			string str = string.Join(",", empIds);
			string[] s1 = Array.ConvertAll<string, string>(str.Split(new char[] { ',' }, StringSplitOptions.RemoveEmptyEntries), s => s.ToString()); //string分割转string[]
			//string s1 = string.Format("'{0}'", str.Replace(",", "','"));

			string sql = @"select B.wo_code, B.eqp_code,B.time_start,B.time_end, 'S' status , B.alloc_qty,D.partcode as part_code,D.partname as part_name,T.name as uom_name
			from TK_Wrk_EqpAps B
			left join TK_Wrk_Man C on B.wo_code=C.wo_code
			left join TMateriel_Info D on C.materiel_code=D.partcode
			left join TUom T on D.uom_code=T.code
			where B.eqp_code in @eqpcode
			and convert(varchar(100),B.Time_Start,21)>=@startdate and convert(varchar(100),B.Time_End,21)<=@enddate order by time_end";
			dt = DapperHelper.selectlist(sql, new { eqpcode = s1.ToArray(), startdate = json[i].startdate + " 00:00:00", enddate = json[i].enddate + " 23:59:59" });
			//dynamicParams.Add("@s1", new { shopcode = s1.ToArray() });
			//dynamicParams.Add("@startdate", startdate + " 00:00:00");
			//dynamicParams.Add("@enddate", enddate + " 23:59:59");
			//var dt_0 = DapperHelper.selectdata(sql, dynamicParams);
			if (dt == null \|\| dt.Rows.Count == 0)
			{
			return null;
			}
			list.Add(dt);
			}
			}
			catch (Exception ex)
			{
			throw new Exception(ex.Message);
			}

			return list;
			}
			#endregion

			#region[排程数据提交]
			public static ToMessage SubmitAlreadyScheduling(string username, string wocode, string botprocecode, List<AlreadyScheduling> objs)
			{