using Autofac.Core;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using WIDESEAWCS_Common;
|
using WIDESEAWCS_Core;
|
using WIDESEAWCS_Core.BaseRepository;
|
using WIDESEAWCS_Core.BaseServices;
|
using WIDESEAWCS_Core.Helper;
|
using WIDESEAWCS_IBasicInfoService;
|
using WIDESEAWCS_Model.Models;
|
|
namespace WIDESEAWCS_BasicInfoService
|
{
|
public class BoxingService : ServiceBase<Dt_Boxing, IRepository<Dt_Boxing>>, IBoxingService
|
{
|
private readonly IProcessInfoService _processInfoService;
|
// 直接注入 BoxingDetail 的仓储，替代注入 BoxingDetailService
|
private readonly IRepository<Dt_BoxingDetail> _boxingDetailRepo;
|
|
public BoxingService(
|
IRepository<Dt_Boxing> BaseDal,
|
IProcessInfoService processInfoService,
|
// 新增注入 BoxingDetail 仓储
|
IRepository<Dt_BoxingDetail> boxingDetailRepo
|
) : base(BaseDal)
|
{
|
_processInfoService = processInfoService;
|
_boxingDetailRepo = boxingDetailRepo; // 赋值
|
}
|
|
public IRepository<Dt_Boxing> Repository => BaseDal;
|
|
//删除当前托盘
|
public WebResponseContent DeleteCurrentTray()
|
{
|
try
|
{
|
var PalletCode = TcpClientExample.Start("192.168.2.120", 2001);
|
if (!PalletCode.IsNotEmptyOrNull() || PalletCode == "NoRead")
|
{
|
return WebResponseContent.Instance.Error("托盘码未扫到，请重试");
|
}
|
Db.Ado.BeginTran();
|
|
// 1. 删除 Boxing 主表数据
|
Dt_Boxing dt_Boxing = BaseDal.QueryFirst(x => x.PalletCode == PalletCode);
|
if (dt_Boxing != null)
|
{
|
BaseDal.DeleteData(dt_Boxing);
|
|
// 2. 直接通过仓储删除 BoxingDetail 数据（核心修改）
|
Dt_BoxingDetail dt_BoxingDetail = _boxingDetailRepo.QueryFirst(x => x.BoxingId == dt_Boxing.Id);
|
if (dt_BoxingDetail != null)
|
{
|
_boxingDetailRepo.DeleteData(dt_BoxingDetail);
|
}
|
}
|
|
// 3. 删除 ProcessInfo 数据
|
Dt_ProcessInfo dt_ProcessInfo = _processInfoService.Repository.QueryFirst(x => x.PalletCode == PalletCode);
|
if (dt_ProcessInfo != null)
|
{
|
_processInfoService.Repository.DeleteData(dt_ProcessInfo);
|
}
|
|
Db.Ado.CommitTran();
|
return WebResponseContent.Instance.OK("删除成功");
|
}
|
catch (Exception ex)
|
{
|
Db.Ado.RollbackTran();
|
throw new Exception(ex.Message);
|
}
|
}
|
|
}
|
}
|
