using SqlSugar; using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using WIDESEA_IRecordRepository; using WIDESEAWCS_Common; using WIDESEAWCS_Core; using WIDESEAWCS_Core.BaseServices; using WIDESEAWCS_Core.Helper; using WIDESEAWCS_IBasicInfoService; using WIDESEAWCS_Model.Models; namespace WIDESEAWCS_BasicInfoService { public class LocationStatusChangeRecordService : ServiceBase, ILocationStatusChangeRecordService { public ILocationStatusChangeRecordRepository Repository => BaseDal; public LocationStatusChangeRecordService(ILocationStatusChangeRecordRepository BaseDal) : base(BaseDal) { } /// /// 货位变动记录添加(单个) /// public void AddLocationStatusChangeRecord(Dt_LocationInfo locationInfo, LocationStatusEnum lastStatus, LocationStatusEnum newStatus, LocationChangeType changeType, int? taskNum = null) { try { Dt_LocationStatusChangeRecord locationStatusChangeRecord = new Dt_LocationStatusChangeRecord() { AfterStatus = newStatus.ObjToInt(), BeforeStatus = lastStatus.ObjToInt(), ChangeType = changeType.ObjToInt(), LocationCode = locationInfo.LocationCode, LocationId = locationInfo.Id, TaskNum = taskNum, Creater = "", CreateDate = DateTime.Now, }; BaseDal.AddData(locationStatusChangeRecord); } catch (Exception ex) { throw new Exception($"{ex.Message}"); } } /// /// 货位变动记录添加(多个) /// public void AddLocationStatusChangeRecord(List locationInfos, LocationStatusEnum lastStatus, LocationStatusEnum newStatus, LocationChangeType changeType, List? taskNums = null) { try { List records = new List(); for (int i = 0; i < locationInfos.Count; i++) { Dt_LocationInfo locationInfo = locationInfos[i]; int? taskNum = (taskNums != null && taskNums.Count > 0 && taskNums.Count == locationInfos.Count) ? taskNums[i] : null; Dt_LocationStatusChangeRecord locationStatusChangeRecord = new Dt_LocationStatusChangeRecord() { AfterStatus = newStatus.ObjToInt(), BeforeStatus = lastStatus.ObjToInt(), ChangeType = changeType.ObjToInt(), LocationCode = locationInfo.LocationCode, LocationId = locationInfo.Id, TaskNum = taskNum, Creater = "", CreateDate = DateTime.Now, }; records.Add(locationStatusChangeRecord); } BaseDal.AddData(records); } catch (Exception ex) { throw new Exception($"{ex.Message}"); } } /// /// 获取指定货位变动记录 /// /// public WebResponseContent GetLocationState(int id) { WebResponseContent content = new WebResponseContent(); try { List location = BaseDal.QueryData(x => x.LocationId == id).OrderByDescending(x => x.CreateDate).ToList(); return content = WebResponseContent.Instance.OK(data: location); } catch (Exception ex) { return content = WebResponseContent.Instance.Error(ex.Message); } } } }