265 lines
14 KiB
C#
265 lines
14 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
using Aop.Api.Domain;
|
|
using JNPF.Common.Core.Manager;
|
|
using JNPF.Common.Enums;
|
|
using JNPF.Common.Extension;
|
|
using JNPF.Common.Security;
|
|
using JNPF.FriendlyException;
|
|
using JNPF.Systems.Interfaces.System;
|
|
using Mapster;
|
|
using Microsoft.AspNetCore.Mvc;
|
|
using SqlSugar;
|
|
using Tnb.BasicData.Entities;
|
|
using Tnb.WarehouseMgr.Entities;
|
|
using Tnb.WarehouseMgr.Entities.Attributes;
|
|
using Tnb.WarehouseMgr.Entities.Consts;
|
|
using Tnb.WarehouseMgr.Entities.Dto;
|
|
using Tnb.WarehouseMgr.Entities.Enums;
|
|
using Tnb.WarehouseMgr.Interfaces;
|
|
|
|
namespace Tnb.WarehouseMgr
|
|
{
|
|
/// <summary>
|
|
/// 齐套出库服务类
|
|
/// </summary>
|
|
[ServiceModule(BizTypeId)]
|
|
public class WmskittingOutService : BaseWareHouseService, IWmskittingOutService
|
|
{
|
|
private readonly ISqlSugarClient _db;
|
|
private readonly IWareHouseService _warehouseService;
|
|
private readonly IUserManager _userManager;
|
|
private readonly IBillRullService _billRullService;
|
|
private readonly IWmsCarryService _carryService;
|
|
private const string BizTypeId = "26169472620837";
|
|
public WmskittingOutService(ISqlSugarRepository<WmsKittingoutH> repository, IWareHouseService warehouseService, IUserManager userManager, IBillRullService billRullService, IWmsCarryService carryService)
|
|
{
|
|
_db = repository.AsSugarClient();
|
|
_warehouseService = warehouseService;
|
|
_userManager = userManager;
|
|
_billRullService = billRullService;
|
|
_carryService = carryService;
|
|
}
|
|
/// <summary>
|
|
/// 齐套出库（新增状态）
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
[HttpPost]
|
|
public async Task KittingOutByAdd()
|
|
{
|
|
try
|
|
{
|
|
await _db.Ado.BeginTranAsync();
|
|
|
|
var kittingOuts = await _db.Queryable<WmsKittingoutH>()
|
|
.Where(a => a.status == WmsWareHouseConst.BILLSTATUS_ADD_ID)
|
|
.OrderBy(a => a.seq)
|
|
.ToListAsync();
|
|
// 是否有已呼叫的齐套出库任务
|
|
// var set = true ; 如果有 把set修改为false
|
|
var items = await _db.Queryable<WmsKittingoutH>().Where(it => it.status == WmsWareHouseConst.BILLSTATUS_CALLED_ID).ToListAsync();
|
|
var isCalled = items?.Count > 0;
|
|
if (kittingOuts?.Count > 0)
|
|
{
|
|
foreach (var ko in kittingOuts)
|
|
{
|
|
var carrys = await _db.Queryable<WmsCarryH>().Where(it => it.collocation_scheme_id == ko.collocation_scheme_id && it.is_lock == 0).ToListAsync();
|
|
if (carrys?.Count > 0)
|
|
{
|
|
var firstCarry = carrys.FirstOrDefault();
|
|
GenPreTaskUpInput genPreTaskInput = new() { CarryId = firstCarry.id };
|
|
await _warehouseService.GenInStockTaskHandleAfter(genPreTaskInput, it => new WmsCarryH { is_lock = 1 }, null!);
|
|
ko.status = WmsWareHouseConst.BILLSTATUS_TOBESHIPPED_ID;
|
|
ko.carry_id = firstCarry.id;
|
|
ko.carry_code = firstCarry.carry_code;
|
|
await _db.Updateable(ko).UpdateColumns(it => new { it.status, it.carry_id, it.carry_code }).ExecuteCommandAsync();
|
|
}
|
|
else
|
|
{
|
|
//if(false) 跳出 插入完一次齐套分拣 set 改为false
|
|
if (!isCalled)
|
|
{
|
|
var setSortingH = ko.Adapt<WmsSetsortingH>();
|
|
setSortingH.warehouse_id = WmsWareHouseConst.WAREHOUSE_ZC_ID;
|
|
setSortingH.id = SnowflakeIdHelper.NextId();
|
|
setSortingH.kittingout_id = ko.id;
|
|
setSortingH.seq = ko.seq;
|
|
setSortingH.org_id = _userManager.User.OrganizeId;
|
|
setSortingH.create_id = _userManager.UserId;
|
|
setSortingH.create_time = DateTime.Now;
|
|
await _db.Insertable(setSortingH).ExecuteCommandAsync();
|
|
|
|
var kittingOutDetails = await _db.Queryable<WmsKittingoutD>().Where(it => it.bill_id == ko.id).ToListAsync();
|
|
var setSortDetails = kittingOutDetails.Adapt<List<WmsSetsortingD>>();
|
|
setSortDetails.ForEach(x =>
|
|
{
|
|
x.id = SnowflakeIdHelper.NextId();
|
|
x.bill_id = setSortingH.id;
|
|
x.warehouse_id = setSortingH.warehouse_id;
|
|
x.org_id = _userManager.User.OrganizeId;
|
|
x.create_id = _userManager.UserId;
|
|
x.create_time = DateTime.Now;
|
|
});
|
|
await _db.Insertable(setSortDetails).ExecuteCommandAsync();
|
|
ko.status = WmsWareHouseConst.BILLSTATUS_CALLED_ID;
|
|
await _db.Updateable(ko).UpdateColumns(it => it.status).ExecuteCommandAsync();
|
|
isCalled = true;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
await _db.Ado.CommitTranAsync();
|
|
}
|
|
catch (Exception)
|
|
{
|
|
await _db.Ado.RollbackTranAsync();
|
|
throw;
|
|
}
|
|
}
|
|
/// <summary>
|
|
/// 齐套出库，（待配送状态）
|
|
/// </summary>
|
|
/// <returns></returns>
|
|
[HttpPost]
|
|
public async Task KittingOutByIsToBeShipped()
|
|
{
|
|
|
|
var kittingOuts = await _db.Queryable<WmsKittingoutH>()
|
|
.Where(a => a.status == WmsWareHouseConst.BILLSTATUS_TOBESHIPPED_ID)
|
|
.OrderBy(a => a.seq)
|
|
.ToListAsync();
|
|
if (kittingOuts?.Count > 0)
|
|
{
|
|
var grpList = kittingOuts.GroupBy(g => g.location_id).ToList();
|
|
foreach (var koGrp in grpList)
|
|
{
|
|
var locs = await _db.Queryable<BasLocation>().Where(it => it.id == koGrp.Key && it.is_use == (int)EnumCarryStatus.空闲 && it.is_lock == 0).ToListAsync();
|
|
if (locs?.Count > 0)
|
|
{
|
|
|
|
var arr = koGrp.ToArray();
|
|
var ko = arr[^arr.Length];
|
|
var carry = await _db.Queryable<WmsCarryH>().SingleAsync(it => it.id == ko.carry_id);
|
|
if (carry != null)
|
|
{
|
|
WmsPointH sPoint = await _db.Queryable<WmsPointH>().FirstAsync(it => it.location_id == carry.location_id);
|
|
WmsPointH ePoint = await _db.Queryable<WmsPointH>().FirstAsync(it => it.location_id == ko.location_id);
|
|
if (sPoint != null && ePoint != null)
|
|
{
|
|
var points = await _warehouseService.PathAlgorithms(sPoint.id, ePoint.id);
|
|
if (points?.Count > 0)
|
|
{
|
|
if (points.Count <= 2) throw new AppFriendlyException("该路径不存在", 500);
|
|
var preTasks = points.Where(it => !it.location_id.IsNullOrEmpty()).GroupBy(g => g.area_code).Select(it =>
|
|
{
|
|
var sPoint = it.FirstOrDefault();
|
|
var ePoint = it.LastOrDefault();
|
|
|
|
WmsPretaskH preTask = new();
|
|
preTask.org_id = _userManager.User.OrganizeId;
|
|
preTask.startlocation_id = sPoint?.location_id;
|
|
preTask.startlocation_code = sPoint?.location_code;
|
|
preTask.endlocation_id = ePoint?.location_id;
|
|
preTask.endlocation_code = ePoint?.location_code;
|
|
preTask.start_floor = sPoint?.floor.ToString();
|
|
preTask.end_floor = ePoint?.floor.ToString();
|
|
preTask.bill_code = _billRullService.GetBillNumber(WmsWareHouseConst.WMS_PRETASK_H_ENCODE).GetAwaiter().GetResult();
|
|
preTask.status = WmsWareHouseConst.PRETASK_BILL_STATUS_DXF_ID;
|
|
preTask.biz_type = ko.biz_type;
|
|
preTask.task_type = WmsWareHouseConst.WMS_PRETASK_INSTOCK_TYPE_ID;
|
|
preTask.carry_id = ko.carry_id;
|
|
preTask.carry_code = ko.carry_code;
|
|
preTask.area_id = sPoint?.area_id;
|
|
preTask.area_code = it.Key;
|
|
preTask.require_id = ko.id;
|
|
preTask.require_code = ko.bill_code;
|
|
preTask.create_id = _userManager.UserId;
|
|
preTask.create_time = DateTime.Now;
|
|
return preTask;
|
|
}).ToList();
|
|
await _warehouseService.GenPreTask(preTasks, null!);
|
|
var subCarrys = await _db.Queryable<WmsCarryD>().Where(it => it.carry_id == ko.carry_id).ToListAsync();
|
|
var carryIds = subCarrys.Select(x => x.carry_id).Concat(new[] { ko.carry_id }).Distinct().ToList();
|
|
GenPreTaskUpInput genPreTaskInput = new() { CarryIds = carryIds, LocationIds = new List<string> { carry.location_id, ko.location_id } };
|
|
await _warehouseService.GenInStockTaskHandleAfter(genPreTaskInput, it => new WmsCarryH { is_lock = 1, carry_status = ((int)EnumCarryStatus.齐套).ToString() }, it => new BasLocation { is_lock = 1 });
|
|
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
public override async Task ModifyAsync(WareHouseUpInput input)
|
|
{
|
|
if (input == null) throw new ArgumentNullException(nameof(input));
|
|
try
|
|
{
|
|
await _db.Ado.BeginTranAsync();
|
|
|
|
var carryId = input.carryIds[^input.carryIds.Count];
|
|
var kods = await _db.Queryable<WmsKittingoutD>().Where(it => it.bill_id == input.requireId).ToListAsync();
|
|
//当前载具对应的所有条码插入
|
|
var carryCodes = await _db.Queryable<WmsCarryCode>().Where(it => it.carry_id == carryId).ToListAsync();
|
|
var kittingoutCodes = carryCodes.Adapt<List<WmsKittingoutCode>>();
|
|
kittingoutCodes.ForEach(x =>
|
|
{
|
|
var billDId = kods?.Find(xx => xx.material_id == x.material_id && xx.code_batch == x.code_batch)?.id;
|
|
if (billDId.IsNullOrEmpty())
|
|
{
|
|
billDId = kods?.Find(xx => xx.material_id == x.material_id)?.id;
|
|
}
|
|
x.id = SnowflakeIdHelper.NextId();
|
|
x.bill_id = input.requireId;
|
|
x.bill_d_id = billDId;
|
|
x.org_id = _userManager.User.OrganizeId;
|
|
x.create_id = _userManager.UserId;
|
|
x.create_time = DateTime.Now;
|
|
});
|
|
var row = await _db.Insertable(kittingoutCodes).ExecuteCommandAsync();
|
|
var detailIds = kittingoutCodes.Select(x => x.bill_d_id).ToList();
|
|
var curKittingoutDetails = kods.FindAll(x => detailIds.Contains(x.id));
|
|
var dic = kittingoutCodes.GroupBy(g => g.bill_d_id).ToDictionary(x => x.Key, x => x.Select(x => x.codeqty).ToList());
|
|
foreach (var kod in curKittingoutDetails)
|
|
{
|
|
if (dic.ContainsKey(kod.id))
|
|
{
|
|
kod.qty += dic[kod.id].Sum(d => d);
|
|
if (kod.qty >= kod.pr_qty)
|
|
{
|
|
kod.line_status = WmsWareHouseConst.BILLSTATUS_COMPLETE_ID;
|
|
}
|
|
else
|
|
{
|
|
kod.line_status = WmsWareHouseConst.BILLSTATUS_ON_ID;
|
|
}
|
|
}
|
|
}
|
|
await _db.Updateable(curKittingoutDetails).ExecuteCommandAsync();
|
|
var isOk = await _db.Updateable<WmsKittingoutH>().SetColumns(it => new WmsKittingoutH { status = WmsWareHouseConst.BILLSTATUS_COMPLETE_ID }).Where(it => it.id == input.requireId).ExecuteCommandHasChangeAsync();
|
|
var carry = await _db.Queryable<WmsCarryH>().SingleAsync(it => it.id == carryId);
|
|
if (carry != null)
|
|
{
|
|
row = await _carryService.UpdateNullCarry(carry);
|
|
isOk = row > 0;
|
|
}
|
|
if (!isOk) throw Oops.Oh(ErrorCode.COM1001);
|
|
|
|
await _db.Ado.CommitTranAsync();
|
|
}
|
|
catch (Exception)
|
|
{
|
|
await _db.Ado.RollbackTranAsync();
|
|
throw;
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
}
|