后端

yanjinhui

2025-03-10 f391144114bedefe44c700a590bd50272ff067ec

 ÏîÄ¿´úÂë/WIDESEAWCS_Server Õýʽ/SerialPortService/ProcessServer.cs

@@ -2,11 +2,14 @@
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Text.RegularExpressions;
using System.Threading.Tasks;
using SqlSugar;
using WIDESEA_ISerialPortRepository;
using WIDESEAWCS_Core;
using WIDESEAWCS_Core.BaseRepository;
using WIDESEAWCS_Core.BaseServices;
using WIDESEAWCS_DTO.SerialPort;
using WIDESEAWCS_ITaskInfoService;
using WIDESEAWCS_Model.Models;

@@ -14,11 +17,15 @@
{
    public class ProcessServer : ServiceBase<Dt_Process, IProcessRepository>, IProcessServer
    { 
        private readonly UnitOfWorkManage _unitOfWorkManage;
        public ProcessServer(IProcessRepository BaseDal, UnitOfWorkManage unitOfWorkManage) : base(BaseDal)
        
        private IUnitOfWorkManage _unitOfWorkManage;
        public ProcessServer(IProcessRepository BaseDal, IUnitOfWorkManage unitOfWorkManage) : base(BaseDal)
        {
            _unitOfWorkManage=unitOfWorkManage;
        }

     

        public WebResponseContent GetProcess(string gruop)
        {
            try
@@ -30,15 +37,11 @@
                _unitOfWorkManage.CommitTran();
                if (proce != null)
                {
                    return new WebResponseContent { Status = true, Data = gruop };
                    return new WebResponseContent { Status = true, Data = proce };
                }
                else
                {
                    return new WebResponseContent
                    {
                        Status = false,
                        Message = "数据为空"
                    };
                    return new WebResponseContent{ Status = false, Message = "数据为空"};
                }

            }
@@ -48,5 +51,113 @@
                return new WebResponseContent { Status = false, Message = "失败" + ex.Message };
            }
        }

        public WebResponseContent GetSleeveandStep(string gruops)
        {
            try
            {
                _unitOfWorkManage.BeginTran();
                var result = BaseDal.QueryData(x => x.CraftType == gruops) // å…ˆç­›é€‰ CraftType
                    .GroupBy(x => x.CraftType) // æŒ‰ CraftType åˆ†ç»„
                    .Select(g => new
                    {
                       maxNodal = g.Max(a=>a.Nodal),
                        sumTorqueSum = g.Sum(a=>a.TorqueSum)
                    }).ToList();
                _unitOfWorkManage.CommitTran() ;
                return new WebResponseContent { Status = true, Data = result };
            }
            catch (Exception ex)
            {
                _unitOfWorkManage.RollbackTran();
                return new WebResponseContent { Status = false, Message = "查询失败：" + ex.Message };
            }
        }


        public WebResponseContent AddProcess(AddProcessDTO addProcessDTO)
        {
            try
            {
                var proces = new Dt_Process();
                proces.Nodal=addProcessDTO.nodal;
                proces.CraftType=addProcessDTO.craftstype;
                proces.CraftsStep=addProcessDTO.craftsstep;
                proces.CraftContent=addProcessDTO.craftcontent;
                proces.TorqueSum = addProcessDTO.sleeveNum;
                proces.Tools=addProcessDTO.tools;
                _unitOfWorkManage.BeginTran() ;
                BaseDal.AddData(proces);
                _unitOfWorkManage.CommitTran();
                return new WebResponseContent { Status = true,Data=proces};
            }
            catch (Exception ex)
            {
                _unitOfWorkManage.RollbackTran() ;
                return new WebResponseContent { Status = false, Message = "查询失败：" + ex.Message };
            }
        }

        public WebResponseContent Upprocess(PutProcessDTO addProcessDTO)
        {
            try
            {
                var proces = BaseDal.QueryData(x => x.CraftID == addProcessDTO.id).FirstOrDefault();
                    if (proces == null)
                {
                    return new WebResponseContent { Status = false,Message="没有找到"};
                }
                proces.Nodal = addProcessDTO.nodal;
                proces.CraftType = addProcessDTO.craftstype;
                proces.CraftsStep = addProcessDTO.craftsstep;
                proces.CraftContent = addProcessDTO.craftcontent;
                proces.TorqueSum = addProcessDTO.sleeveNum;
                proces.Tools = addProcessDTO.tools;
                _unitOfWorkManage.BeginTran();
                BaseDal.UpdateData(proces);
                _unitOfWorkManage.CommitTran();
                return new WebResponseContent { Status = true, Data = proces };
            }
            catch (Exception ex)
            {
                _unitOfWorkManage.RollbackTran();
                return new WebResponseContent { Status = false, Message = "查询失败：" + ex.Message };
            }
        }

        public WebResponseContent Getcircuit(string groups)
        {
            try
            {
                List<Dt_Process> results = new List<Dt_Process>();
                int step = 1;

                while (true)
                {
                    // æŸ¥è¯¢å½“前步骤的数据
                    var circuit = BaseDal.QueryData(x => x.CraftType == groups && x.SetpNum == step)
                                         .FirstOrDefault();

                    // å¦‚果查询结果为空，则停止循环
                    if (circuit == null)
                    {
                        break;
                    }

                    // åŠ å…¥ç»“果列表
                    results.Add(circuit);

                    // é€’增 step，继续查询下一个步骤
                    step++;
                }

                return new WebResponseContent { Status = true, Data = results };
            }
            catch (Exception ex)
            {
                return new WebResponseContent { Status = false, Message = "查询失败：" + ex.Message };
            }
        }

    }
}