HuaYiZhongHeng/ZhongHeLiTiKu.git

¶Ô±ÈÐÂÎÄ¼þ
			@@ -0,0 +1,62 @@
			ï»¿#region << ç æ¬ æ³¨ é >>
			/*----------------------------------------------------------------
			* å½åç©ºé´ï¼WIDESEAWCS_TaskInfoRepository
			* åå»ºèï¼è¡ç«¥åº
			* åå»ºæ¶é´ï¼2024/8/2 16:13:36
			* çæ¬ï¼V1.0.0
			* æè¿°ï¼
			*
			* ----------------------------------------------------------------
			* ä¿®æ¹äººï¼
			* ä¿®æ¹æ¶é´ï¼
			* çæ¬ï¼V1.0.1
			* ä¿®æ¹è¯´æï¼
			*
			----------------------------------------------------------------/
			#endregion << ç æ¬ æ³¨ é >>

			using System;
			using System.Collections.Generic;
			using System.Linq;
			using System.Text;
			using System.Threading.Tasks;
			using WIDESEA_Core.Attributes;
			using WIDESEA_Core.BaseRepository;
			using WIDESEA_Core.Helper;
			using WIDESEA_ITaskInfoRepository;
			using WIDESEA_Model.Models;

			namespace WIDESEA_TaskInfoRepository
			{
			public class TaskRepository : RepositoryBase<Dt_Task>, ITaskRepository
			{
			public TaskRepository(IUnitOfWorkManage unitOfWorkManage) : base(unitOfWorkManage)
			{
			}

			public int GetTaskNum(string sequenceName)
			{
			return Db.Ado.GetScalar($"SELECT NEXT VALUE FOR {sequenceName}").ObjToInt();
			}

			public override int AddData(Dt_Task entity)
			{
			return base.AddData(entity);
			}

			public override int AddData(List<Dt_Task> listEntity)
			{
			if (listEntity.GroupBy(x => x.PalletCode).Select(x => x.Count()).Any(x => x > 1))
			{
			throw new Exception("ä»»å¡æ°ç»æ°æ®æçå·éå¤");
			}

			if (QueryFirst(x => listEntity.Select(v => v.PalletCode).Contains(x.PalletCode)) != null)
			{
			throw new Exception("æéå¤ä»»å¡");
			}

			return base.AddData(listEntity);
			}
			}
			}