AiDOPWarehouse/server/Plugins/Admin.NET.Plugin.AiDOP/Controllers/S0/Manufacturing/AdoS0MfgLinePostsController.cs

using Admin.NET.Plugin.AiDOP.Dto.S0.Manufacturing;
using Admin.NET.Plugin.AiDOP.Dto.S0.Sales;
using Admin.NET.Plugin.AiDOP.Entity.S0.Manufacturing;
using Admin.NET.Plugin.AiDOP.Infrastructure;

namespace Admin.NET.Plugin.AiDOP.Controllers.S0.Manufacturing;

[ApiController]
[Route("api/s0/manufacturing/line-posts")]
[NonUnify]
public class AdoS0MfgLinePostsController : ControllerBase
{
    private readonly SqlSugarRepository<AdoS0LineSkillMaster> _postRep;
    private readonly SqlSugarRepository<AdoS0LineSkillDetail> _skillRep;
    private readonly SqlSugarRepository<AdoS0MfgPersonSkill> _personSkillRep;
    private readonly SqlSugarRepository<AdoS0LineMaster> _lineMasterRep;

    public AdoS0MfgLinePostsController(
        SqlSugarRepository<AdoS0LineSkillMaster> postRep,
        SqlSugarRepository<AdoS0LineSkillDetail> skillRep,
        SqlSugarRepository<AdoS0MfgPersonSkill> personSkillRep,
        SqlSugarRepository<AdoS0LineMaster> lineMasterRep)
    {
        _postRep = postRep;
        _skillRep = skillRep;
        _personSkillRep = personSkillRep;
        _lineMasterRep = lineMasterRep;
    }

    [HttpGet]
    public async Task<IActionResult> GetPagedAsync([FromQuery] AdoS0LineSkillMasterQueryDto q)
    {
        if (!AdoS0TenantScope.TryResolveRequired(out var tenantId, out var tenantError)) return tenantError!;
        var page = q.Page;
        var pageSize = q.PageSize;
        (page, pageSize) = PagingGuard.Normalize(page, pageSize);

        var domain = q.Domain?.Trim();
        var query = _postRep.ScopedTo(tenantId)
            .WhereIF(!string.IsNullOrWhiteSpace(domain), x => x.Domain == domain)
            .WhereIF(!string.IsNullOrWhiteSpace(q.Keyword),
                x => x.ProdLine.Contains(q.Keyword!) || x.JOBNo.Contains(q.Keyword!) || (x.JOBDescr != null && x.JOBDescr.Contains(q.Keyword!)));

        var total = await query.CountAsync();
        var list = await query
            .OrderByDescending(x => x.UpdateTime ?? x.CreateTime)
            .Skip((page - 1) * pageSize)
            .Take(pageSize)
            .ToListAsync();

        // 补展示字段：按 (Domain, ProdLine) 元组反查 LineMaster.Describe，避免跨域错配
        var domains = list.Select(x => x.Domain).Distinct().ToList();
        var lineCodes = list.Select(x => x.ProdLine).Distinct().ToList();
        var lineMap = await _lineMasterRep.ScopedTo(tenantId)
            .Where(lm => domains.Contains(lm.Domain) && lineCodes.Contains(lm.Line))
            .Select(lm => new { lm.Domain, lm.Line, lm.Describe })
            .ToListAsync();
        var describeByKey = lineMap
            .GroupBy(x => (x.Domain, x.Line))
            .ToDictionary(g => g.Key, g => g.First().Describe ?? string.Empty);
        var shaped = list.Select(x => new
        {
            id = x.Id,
            domain = x.Domain,
            prodLine = x.ProdLine,
            prodLineDisplay = $"{x.ProdLine} {(describeByKey.TryGetValue((x.Domain, x.ProdLine), out var d) ? d : string.Empty)}".Trim(),
            jobNo = x.JOBNo,
            jobDescr = x.JOBDescr,
            site = x.Site,
            orderby = x.Orderby,
            wType = x.WType,
            runCrew = x.RunCrew,
            createUser = x.CreateUser,
            createTime = x.CreateTime,
            updateUser = x.UpdateUser,
            updateTime = x.UpdateTime
        }).ToList();

        return Ok(new { total, page, pageSize, list = shaped });
    }

    [HttpGet("{id:long}")]
    public async Task<IActionResult> GetDetailAsync(long id)
    {
        if (!AdoS0TenantScope.TryResolveRequired(out var tenantId, out var tenantError)) return tenantError!;
        var header = await _postRep.ByIdScopedAsync(id, tenantId);
        if (header == null) return NotFound();
        var skills = await _skillRep.ScopedTo(tenantId)
            .Where(x => x.LineSkillMasterId == id)
            .OrderBy(x => x.Id)
            .ToListAsync();
        return Ok(new { header, linePostSkills = skills });
    }

    [HttpPost]
    public async Task<IActionResult> CreateAsync([FromBody] AdoS0LineSkillMasterUpsertDto dto)
    {
        if (!AdoS0TenantScope.TryResolveRequired(out var tenantId, out var tenantError)) return tenantError!;
        var fkErr = await ValidatePersonSkillsAsync(dto, tenantId);
        if (fkErr != null) return BadRequest(new { message = fkErr });

        var db = _postRep.Context;
        await db.Ado.BeginTranAsync();
        try
        {
            var now = DateTime.Now;
            var post = new AdoS0LineSkillMaster
            {
                TenantId = tenantId,
                Domain = dto.Domain.Trim(),
                ProdLine = dto.ProdLine.Trim(),
                JOBNo = dto.JOBNo.Trim(),
                JOBDescr = dto.JOBDescr,
                Site = dto.Site,
                Orderby = dto.Orderby,
                WType = dto.WType,
                RunCrew = dto.RunCrew,
                CreateUser = dto.CreateUser ?? dto.UpdateUser,
                CreateTime = dto.CreateTime ?? dto.UpdateTime ?? now,
                UpdateUser = dto.UpdateUser,
                UpdateTime = dto.UpdateTime
            };
            post = await _postRep.AsInsertable(post).ExecuteReturnEntityAsync();

            foreach (var s in dto.Skills)
            {
                var row = MapSkill(post.Id, s, tenantId);
                await _skillRep.AsInsertable(row).ExecuteCommandAsync();
            }

            await db.Ado.CommitTranAsync();
            return await GetDetailAsync(post.Id);
        }
        catch
        {
            await db.Ado.RollbackTranAsync();
            throw;
        }
    }

    [HttpPut("{id:long}")]
    public async Task<IActionResult> UpdateAsync(long id, [FromBody] AdoS0LineSkillMasterUpsertDto dto)
    {
        if (!AdoS0TenantScope.TryResolveRequired(out var tenantId, out var tenantError)) return tenantError!;
        var header = await _postRep.ByIdScopedAsync(id, tenantId);
        if (header == null) return NotFound();

        var fkErr = await ValidatePersonSkillsAsync(dto, tenantId);
        if (fkErr != null) return BadRequest(new { message = fkErr });

        var db = _postRep.Context;
        await db.Ado.BeginTranAsync();
        try
        {
            header.Domain = dto.Domain.Trim();
            header.ProdLine = dto.ProdLine.Trim();
            header.JOBNo = dto.JOBNo.Trim();
            header.JOBDescr = dto.JOBDescr;
            header.Site = dto.Site;
            header.Orderby = dto.Orderby;
            header.WType = dto.WType;
            header.RunCrew = dto.RunCrew;
            header.UpdateUser = dto.UpdateUser;
            header.UpdateTime = dto.UpdateTime ?? DateTime.Now;
            await _postRep.AsUpdateable(header).ExecuteCommandAsync();

            await _skillRep.AsDeleteable().Where(x => x.LineSkillMasterId == id).ExecuteCommandAsync();
            foreach (var s in dto.Skills)
            {
                var row = MapSkill(id, s, tenantId);
                await _skillRep.AsInsertable(row).ExecuteCommandAsync();
            }

            await db.Ado.CommitTranAsync();
            return await GetDetailAsync(id);
        }
        catch
        {
            await db.Ado.RollbackTranAsync();
            throw;
        }
    }

    [HttpDelete("{id:long}")]
    public async Task<IActionResult> DeleteAsync(long id)
    {
        if (!AdoS0TenantScope.TryResolveRequired(out var tenantId, out var tenantError)) return tenantError!;
        var header = await _postRep.ByIdScopedAsync(id, tenantId);
        if (header == null) return NotFound();

        var db = _postRep.Context;
        await db.Ado.BeginTranAsync();
        try
        {
            await _skillRep.AsDeleteable().Where(x => x.LineSkillMasterId == id).ExecuteCommandAsync();
            await _postRep.DeleteAsync(header);
            await db.Ado.CommitTranAsync();
            return Ok(new { message = "删除成功" });
        }
        catch
        {
            await db.Ado.RollbackTranAsync();
            throw;
        }
    }

    private async Task<string?> ValidatePersonSkillsAsync(AdoS0LineSkillMasterUpsertDto dto, long tenantId)
    {
        if (dto.Skills == null || dto.Skills.Count == 0)
            return null;

        var ids = dto.Skills.Select(s => s.PersonSkillId).Distinct().ToList();
        var cnt = await _personSkillRep.ScopedTo(tenantId)
            .Where(p => ids.Contains(p.Id))
            .CountAsync();
        return cnt == ids.Count ? null : "存在无效的人员技能主数据引用";
    }

    private static AdoS0LineSkillDetail MapSkill(long lineSkillMasterId, AdoS0LineSkillDetailUpsertDto s, long tenantId)
    {
        return new AdoS0LineSkillDetail
        {
            TenantId = tenantId,
            LineSkillMasterId = lineSkillMasterId,
            PersonSkillId = s.PersonSkillId,
            RequiredLevel = s.RequiredLevel,
            Remark = s.Remark,
            EffectiveDate = s.EffectiveDate,
            IsEnabled = s.IsEnabled,
            CreateTime = DateTime.Now
        };
    }
}