using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using WIDESEA_ISerialPortRepository; using WIDESEAWCS_Core; using WIDESEAWCS_Core.BaseRepository; using WIDESEAWCS_Core.BaseServices; using WIDESEAWCS_ITaskInfoService; using WIDESEAWCS_Model.Models; namespace WIDESEAWCS_TaskInfoService { public class ProcessServer : ServiceBase, IProcessServer { private readonly UnitOfWorkManage _unitOfWorkManage; public ProcessServer(IProcessRepository BaseDal, UnitOfWorkManage unitOfWorkManage) : base(BaseDal) { _unitOfWorkManage=unitOfWorkManage; } public WebResponseContent GetProcess(string gruop) { try { _unitOfWorkManage.BeginTran(); var proce = BaseDal.QueryData(i => i.CraftType == gruop); _unitOfWorkManage.CommitTran(); if (proce != null) { return new WebResponseContent { Status = true, Data = gruop }; } else { return new WebResponseContent { Status = false, Message = "数据为空" }; } } catch (Exception ex) { _unitOfWorkManage.RollbackTran(); return new WebResponseContent { Status = false, Message = "失败" + ex.Message }; } } } }