From f391144114bedefe44c700a590bd50272ff067ec Mon Sep 17 00:00:00 2001
From: yanjinhui <3306209981@qq.com>
Date: 星期一, 10 三月 2025 09:05:26 +0800
Subject: [PATCH] 后端
---
项目代码/WIDESEAWCS_Server 正式/SerialPortService/ProcessServer.cs | 127 +++++++++++++++++++++++++++++++++++++++--
1 files changed, 119 insertions(+), 8 deletions(-)
diff --git "a/\351\241\271\347\233\256\344\273\243\347\240\201/WIDESEAWCS_Server \346\255\243\345\274\217/SerialPortService/ProcessServer.cs" "b/\351\241\271\347\233\256\344\273\243\347\240\201/WIDESEAWCS_Server \346\255\243\345\274\217/SerialPortService/ProcessServer.cs"
index d0789f3..03893a0 100644
--- "a/\351\241\271\347\233\256\344\273\243\347\240\201/WIDESEAWCS_Server \346\255\243\345\274\217/SerialPortService/ProcessServer.cs"
+++ "b/\351\241\271\347\233\256\344\273\243\347\240\201/WIDESEAWCS_Server \346\255\243\345\274\217/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 };
+ }
+ }
+
}
}
--
Gitblit v1.9.3