zhuangpei-mesbackend/DOAN.Service/MES/process/ProcessmodelWorkStepService.cs

using Aliyun.OSS;
using DOAN.Model;
using DOAN.Model.Business;
using DOAN.Model.Dto;
using DOAN.Model.MES.dev;
using DOAN.Model.MES.dev.Dto;
using DOAN.Model.MES.process;
using DOAN.Repository;
using DOAN.Service.Business.IBusinessService;
using Infrastructure.Attribute;
using Infrastructure.Extensions;
using JinianNet.JNTemplate;
using NPOI.SS.Formula.Functions;
using NPOI.XSSF.Streaming.Values;
using SqlSugar;
using System;
using System.Linq;
using UAParser;

namespace DOAN.Service.Business
{
    /// <summary>
    /// Service业务层处理
    /// </summary>
    [AppService(ServiceType = typeof(IProcessmodelWorkStepService), ServiceLifetime = LifeTime.Transient)]
    public class ProcessmodelWorkStepService : BaseService<ProcessmodelWorkStep>, IProcessmodelWorkStepService
    {
        /// <summary>
        /// 查询列表
        /// </summary>
        /// <param name="parm"></param>
        /// <returns></returns>
        public PagedInfo<ProcessmodeWorkStepDto> GetList(ProcessmodelWorkStepQueryDto parm)
        {
            var predicate = Expressionable.Create<ProcessmodelWorkStep>()
                                          .AndIF(!string.IsNullOrEmpty(parm.StepCode), p => parm.StepCode.Contains(p.StepCode))
                                          .AndIF(!string.IsNullOrEmpty(parm.StepName), p => parm.StepName.Contains(p.StepName));

            var response = Queryable()
                .Where(predicate.ToExpression())
                .GroupBy(p => p.StepCode)
                .ToPage<ProcessmodelWorkStep, ProcessmodeWorkStepDto>(parm);

            return response;
        }


        /// <summary>
        /// 获取详情
        /// </summary>
        /// <param name="Id"></param>
        /// <returns></returns>
        public ProcessmodelWorkStep GetInfo(long Id)
        {
            var response = Queryable()
                .Where(x => x.Id == Id)
                .First();

            return response;
        }

        /// <summary>
        /// 添加
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public ProcessmodelWorkStep AddProcessmodelWorkStep(ProcessmodelWorkStep model)
        {
            return Context.Insertable(model).ExecuteReturnEntity();
        }

        /// <summary>
        /// 修改
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public int UpdateProcessmodelWorkStep(ProcessmodelWorkStep model)
        {
            //var response = Update(w => w.Id == model.Id, it => new ProcessmodelOperationStep()
            //{
            //    OperationStepCode = model.OperationStepCode,
            //    OperationStepName = model.OperationStepName,
            //    OperationCode = model.OperationCode,
            //    Description = model.Description,
            //    IsActive = model.IsActive,
            //    UpdateTime = model.UpdateTime,
            //    UpdateBy = model.UpdateBy,
            //    Remark = model.Remark,
            //});
            //return response;
            return Update(model, true);
        }

        /// <summary>
        /// 获取设备列表
        /// </summary>
        /// <param name="stepCode"></param>
        /// <returns></returns>
        public List<UniqueValueQueryDto> GetUniqueValueList(string stepCode)
        {
            bool stepCodeExists = Context.Queryable<ProcessmodelWorkStep>()
                             .Where(p => p.StepCode == stepCode)
                             .Any();

            if (!stepCodeExists)
            {
                return new List<UniqueValueQueryDto>();
            }

            var uniqueValues = Context.Queryable<ProcessmodelWorkStep>()
                                       .Where(p => p.StepCode == stepCode)
                                       .Distinct() 
                                       .ToList();

            List<UniqueValueQueryDto> result = [];
            foreach (var uniqueValue in uniqueValues)
            {
                var dictionary = Context.Queryable<DeviceAccount>().First(d => d.DeviceCode == uniqueValue.UniqueValue);
                result.Add(new UniqueValueQueryDto
                {
                    Id = uniqueValue.Id,
                    Value = uniqueValue.UniqueValue,
                    Name = dictionary.DeviceName
                });
            }

            return result;
        }

        public List<WorkshopDto> GetAccountList()
        {
            // 1. SqlSugar 链式查询：先查平数据（数据库端过滤，性能不浪费）
            var flatData = Context.Queryable<DeviceAccount>()
                // 过滤空值，避免分组垃圾数据
                .Where(d => !string.IsNullOrEmpty(d.Workshop) && !string.IsNullOrEmpty(d.Workline))
                // 只取需要的字段，减少数据传输
                .Select(d => new
                {
                    d.Workshop,
                    d.Workline,
                    d.DeviceCode,
                    d.DeviceName
                })
                .ToList(); // 加载到内存，后续内存分组（SqlSugar 内存分组不会报错）

            // 2. 手动构建 DTO 结构（最稳妥，不会有任何翻译问题）
            var result = new List<WorkshopDto>();

            // 先获取所有不重复的车间
            var allWorkshops = flatData.Select(d => d.Workshop).Distinct().ToList();

            foreach (var workshop in allWorkshops)
            {
                // 构建当前车间 DTO
                var workshopDto = new WorkshopDto { Workshop = workshop };

                // 获取当前车间下的所有数据
                var workshopData = flatData.Where(d => d.Workshop == workshop).ToList();

                // 获取当前车间下不重复的产线
                var allWorklines = workshopData.Select(d => d.Workline).Distinct().ToList();

                foreach (var workline in allWorklines)
                {
                    // 构建当前产线 DTO
                    var worklineDto = new WorklineDto { Workline = workline };

                    // 获取当前产线下的所有设备
                    var devices = workshopData
                        .Where(d => d.Workline == workline)
                        .Select(d => new DeviceDto
                        {
                            DeviceCode = d.DeviceCode,
                            DeviceName = d.DeviceName
                        })
                        .ToList();

                    worklineDto.Devices = devices;
                    workshopDto.Worklines.Add(worklineDto);
                }

                result.Add(workshopDto);
            }

            return result;
        }

        /// <summary>
        /// 新增设备
        /// </summary>
        /// <param name="parm"></param>
        /// <returns></returns>
        /// <exception cref="ArgumentException"></exception>
        /// <exception cref="Exception"></exception>
        public int AddUniqueValue(UniqueQueryDto parm)
        {

            // 查询工步基础信息
            var workStep = Context.Queryable<ProcessmodelWorkStep>()
                .Where(x => x.StepCode == parm.StepCode && x.ProcessCode == parm.ProcessCode)
                .First();

            if (workStep == null)
            {
                throw new Exception("未找到对应的工步信息");
            }

            // 插入新的工步记录
            var newWorkStep = new ProcessmodelWorkStep
            {
                StepCode = workStep.StepCode,
                StepName = workStep.StepName,
                ProcessCode = workStep.ProcessCode,
                Description = workStep.Description,
                IsActive = workStep.IsActive,
                UniqueValue = parm.DeviceCode,
                CreateTime = DateTime.Now
            };

            return Context.Insertable(newWorkStep).ExecuteCommand();
        }

        ///// <summary>
        ///// 删除设备
        ///// </summary>
        ///// <param name="id"></param>
        ///// <returns></returns>
        ///// <exception cref="NotImplementedException"></exception>
        //public int DeleteUniqueValue(long id)
        //{
        //    Context.Deleteable<ProcessmodelWorkStep>()
        //}
    }
}