@@ -1,340 +1,341 @@
// 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.Dtos.VisualDev;
// using JNPF.Common.Enums;
// using JNPF.Common.Security;
// using JNPF.FriendlyException;
// using JNPF.Systems.Entitys.System;
// using JNPF.Systems.Interfaces.System;
// using JNPF.VisualDev;
// using JNPF.VisualDev.Interfaces;
// using Mapster;
// using Microsoft.AspNetCore.Authorization;
// using Microsoft.AspNetCore.Mvc;
// using Microsoft.Extensions.Logging;
// using Newtonsoft.Json;
// using Newtonsoft.Json.Linq;
// using NPOI.HPSF;
// using Senparc.Weixin.Work.AdvancedAPIs.OaDataOpen;
// 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.Dto.Inputs;
// using Tnb.WarehouseMgr.Entities.Entity;
// using Tnb.WarehouseMgr.Interfaces;
// using Tnb.ProductionMgr.Entities.Entity;
// using Tnb.BasicData;
//
// namespace Tnb.WarehouseMgr
// {
// /// <summary>
// /// 材料出库单
// /// </summary>
// [OverideVisualDev(ModuleConsts.MODULE_WmsRawmatOutstock_ID)]
// [ServiceModule(BizTypeId)]
// public class WmsRawmatOutstockService : BaseWareHouseService
// {
// private const string BizTypeId = WmsWareHouseConst. BIZTYPE_WmsRawmatOutstock_ID;
// private readonly ISqlSugarClient _db;
// private readonly IUserManager _userManager;
// private readonly IBillRullService _billRullService;
// private readonly IRunService _runService;
// private readonly IVisualDevService _visualDevService;
// private readonly IWmsPDAScanInStockService _wmsPDAScanInStock;
// private readonly IWareHouseService _wareHouseService;
// public WmsRawmatOutstockService(
// ISqlSugarRepository< WmsCarryH> repository,
// IUserManager userManager,
// IBillRullService billRullService,
// IRunService runService,
// IVisualDevService visualDevService,
// IWmsPDAScanInStockService wmsPDAScanInStock,
// IWareHouseService wareHouseService)
// {
// _db = repository. AsSugarClient() ;
// _userManager = userManager;
// _billRullService = billRullService;
// _runService = runService;
// _visualDevService = visualDevService;
// _wmsPDAScanInStock = wmsPDAScanInStock;
// _wareHouseService = wareHouseService;
//
// OverideFuncs. GetDetailsAsync = GetDetailsAsync;
// }
//
//
// public override async Task ModifyAsync( WareHouseUpInput input)
// {
// if (input == null)
// {
// throw new ArgumentNullException( nameof(input)) ;
// }
//
// WmsRawmatOutstockD wmsRawmatOutstockD = await _db.Queryable<WmsRawmatOutstockD>().SingleAsync(x=>x.id==input.requireId);
// WmsRawmatOutstockH wmsRawmatOutstockH = await _db.Queryable<WmsRawmatOutstockH>().SingleAsync(x=>x.id==wmsRawmatOutstockD.bill_id);
// List<WmsCarryCode> wmsCarryCodes = await _db.Queryable<WmsCarryCode>()
// .Where(r => r.carry_id == input.wmsDistaskH.carry_id)
// .Where(r => r.material_id == wmsRawmatOutstockD.material_id && r.code_batch == wmsRawmatOutstockD.batchno)
// .ToListAsync();
//
// decimal qty = wmsCarryCodes.Sum(r => r.codeqty);
//
// List<String> unitCodes = wmsCarryCodes.Select(x => x.unit_id).Distinct().ToList();
// List<string> materialIds = wmsCarryCodes.Select(x => x.material_id).ToList();
// List<DictionaryDataEntity> unitDatas = await _db.Queryable<DictionaryTypeEntity>()
// .LeftJoin<DictionaryDataEntity>((x, y) => x.Id == y.DictionaryTypeId)
// .Where((x, y) => x.EnCode == DictConst.MeasurementUnit && unitCodes.Contains(y.EnCode))
// .Select((x, y) => y)
// .ToListAsync();
//
// string supplierId = WmsWareHouseConst.TIANYIGONGYINGSHANG_ID;
// List<string> tableIds = new List<string>();
// tableIds.Add(WmsWareHouseConst.AdministratorOrgId);
// tableIds.AddRange(materialIds);
// tableIds.Add(supplierId);
// tableIds.AddRange(unitDatas.Select(x => x.Id).ToList());
//
// List<ErpExtendField> erpExtendFields = await _db.Queryable<ErpExtendField>().Where(x => tableIds.Contains(x.table_id)).ToListAsync();
// string userId = wmsRawmatTransfero utstockH.create_id;
// string erpCreateId = erpExtendFields.Find(x => x.table_id == userId)?.user_id ?? "";
// ErpExtendField erpOrg = erpExtendFields.Find(x => x.table_id == (WmsWareHouseConst.AdministratorOrgId));
// string nowStr = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
// List<WmsErpWarehouserelaH> wmsErpWarehouserelaHs = await _db.Queryable<WmsErpWarehouserelaH>().Where(x=>!SqlFunc.IsNullOrEmpty(x.id)).ToListAsync();
//
// List<Dictionary<string, object>> requestData = new List<Dictionary<string, object>>();
// Dictionary<string, object> erpRequestData = new Dictionary<string, object>();
// erpRequestData.Add("billmaker", erpCreateId);
// erpRequestData.Add("ccostdomainoid", null);
// erpRequestData.Add("cdrawcalbodyoid", erpOrg.pk_org);
// erpRequestData.Add("cdrawcalbodyvid", erpOrg.pk_org_v);
//
// erpRequestData.Add("corpoid", erpOrg.corpoid);
// erpRequestData.Add("corpv id", erpOrg.corpv id);
// erpRequestData.Add("cdptid","1001A1100000001JFOPQ");//部门先写死
// erpRequestData.Add("cdptv id","0 001A1100000000AOMI Q");//部门先写死
// erpRequestData.Add("cother dptid","1 001A1100000001JFOP Q");//部门先写死
// erpRequestData.Add("cotherdptv id","0 001A1100000000AOMI Q");//部门先写死
// erpRequestData.Add("creationtime", nowStr);
// erpRequestData.Add("creator", erpCreateId );
// erpRequestData.Add("ctrantypeid", "0001H11000000000D32A");//先写死
// erpRequestData.Add("cwarehouseid", outWhid );//先写死
// erpRequestData.Add("dbilldate", wmsRawmatTransferoutstockH.create_time.Value.ToString("yyyy-MM-dd HH:mm:ss"));
// erpRequestData.Add("dmake date", nowStr );
// erpRequestData.Add("dshldarriv edate", nowStr);
// erpRequestData.Add("dshlddil iver date", nowStr);
// erpRequestData.Add("fbillflag", 1 );
// erpRequestData.Add("isbackdeliver", false );
// erpRequestData.Add("ntotalnum", qty );
// erpRequestData.Add("pk_org", erpOrg.pk_org );
// erpRequestData.Add("pk_org_v ", erpOrg.pk_org_v );
// erpRequestData.Add("pk_group ", erpOrg.pk_group );
// erpRequestData.Add("vbillcode", wmsRawmatTransferoutstockH.bill_code );
// erpRequestData.Add("vtrantypecode", "4Y-01");//先写死
//
// List<Dictionary<string, object>> erpRequestDataDetails = new List<Dictionary<string, object>>();
// foreach(var item in wmsCarryCodes)
// {
// // 出库数量wmsMaterialSignD.sign_qty
// erpRequestDataDetails.Add(new Dictionary<string, object>()
// {
// ["cmaterialoid"] = erpExtendFields.Find(x => x.table_id == item.material_id)?.cmaterialoid ?? "",
// ["cmaterialv id"] = erpExtendFields.Find(x => x.table_id == item.material_id)?.cmaterialv id ?? "",
// ["corpo id"] = erpOrg.corpoid ,
// ["corpv id"] = erpOrg.corpv id,
// ["crowno"] = (wmsCarryCodes.FindIndex(x => x.id == item.id) + 1) * 10 ,
// ["cunitid"] = erpExtendFields.Find(x => x.table_id == (unitDatas.Find (x => x.EnCode == item.unit_id)?.Id ?? ""))?.cunitid ?? "" ,
// ["nnum"] = item.codeqty ,
// ["nshould num"] = item.codeqty,
// ["pk_group"] = erpOrg.pk_group ,
// ["pk_org "] = erpOrg.pk_org ,
// ["pk_org_v "] = erpOrg.pk_org_v ,
// ["vbatchcode"] = item.code_batch ,
//
// });
// }
// erpRequestData.Add("dtls", erpRequestDataDetails);
// r equestData.Add(erpRequestData);
// BasFactoryConfig config = await _db.Queryable<BasFactoryConfig>().FirstAsync(x => x.enabled == 1 && x.key == FactoryConfigConst.BIPURL );
// ThirdWebapiRecord thirdWebapiRecord = new ThirdWebapiRecord( );
// t hirdWebapiRecord.id = SnowflakeIdHelper.NextI d();
// thirdWebapiRecord.third_name = WmsWareHouseConst.BIP ;
// thirdWebapiRecord.name = "材料出库单(自制)" ;
// thirdWebapiRecord.method = "POST ";
// thirdWebapiRecord.url = config.value + "uapws/rest/materialOut/self/save ";
// // thirdWebapiRecord.url = WmsWareHouseConst.BIP_DOMAIN + "uapws/rest/transIn /save";
// thirdWebapiRecord.request_data = JsonConvert.SerializeObject(requestData) ;
// thirdWebapiRecord.c reate_time = DateTime.Now ;
// await _db.Insertable(thirdWebapiRecord).ExecuteCommandAsync() ;
//
// }
//
// [NonAction]
// private async Task<dynamic> GetDetailsAsync(string id)
// {
// try
// {
// return await Task.FromResult(_db.Queryable<WmsRawmatOutstockD>().Where(r => r.bill_id == id).ToList());
// }
// catch (Exception ex)
// {
// return Task.FromResult(ex);
// }
// }
//
// /// <summary>
// /// 下发
// /// </summary>
// /// <param name="input"></param >
// /// <returns></returns >
// /// <exception cref="AppFriendlyException"></exception >
// [HttpPost, NonUnify, AllowAnonymous]
// public async Task<Entities.Dto.Outputs.Result> Distribute(RawmatOutstockInput input)
// {
// try
// {
// await _s_taskExecuteSemaphore_YCLOutstock.WaitAsync();
// if (string.IsNullOrEmpty(input.source_id))
// {
// throw new AppFriendlyException("来源单据id不可为空", 500);
// }
// if (input.carrys.Count == 0)
// {
// throw new AppFriendlyException("至少选择一个载具", 500);
// }
//
// WmsRawmatOutstockD wmsRawmatOutstockD = await _db.Queryable<WmsRawmatOutstockD>().FirstAsync(it => it.id == input.source_id);
// WmsRawmatOutstockH wmsRawmatOutstockH = await _db. Queryable< WmsRawmatOutstockH>().FirstAsync(it => it.id == wmsRawmatOutstockD.bill_id) ;
//
// List<WmsCarryH> _items = await _db.Queryable<WmsCarryH>().Where(r => input.carrys.Select(c => c.carry_code).Contains(r.carry_code)).ToListAsync();
//
// List<WmsCarryCode> wmsCarryCodes = await _db.Queryable<WmsCarryCode>().Where(r => _items.Select(c => c.id).Contains(r.carry_id)
// && r.material_id == wmsRawmatOutstockD.material_id && r.code_batch == wmsRawmatOutstockD.batchno).ToListAsync();
//
// List<WmsCarryH> items = new List<WmsCarryH>();
//
// foreach (var carry in input.carrys.Select(c => c.carry_code))
// {
// items.Add(_items.Where(r => r.carry_code == carry).First());
// }
//
// foreach (var item in items)
// {
// if (item.is_lock == 1)
// {
// throw new AppFriendlyException($"载具{item.carry_code}已锁定", 500);
// }
// BasLocation carrryLoc = await _db.Queryable<BasLocation>().Where(r => r.id == item.location_id).FirstAsync();
// if (carrryLoc == null || carrryLoc.is_type != "0")
// {
// throw new Exception($"托盘{item.carry_code}已经不在存储库位中，不能出库！");
// }
// }
//
// decimal? sign_qty = 0;
//
// decimal qty = wmsCarryCodes.Sum(c => c.codeqty);
// if (wmsRawmatOutstockD.actual_outstock_qty + qty > wmsRawmatOutstockD.qty)
// {
// // 最后一个托盘的数量
// decimal lastCarryQty = wmsCarryCodes.Where(r => r.carry_id == items[items.Count - 1].id).Sum(r => r.codeqty);
// // 如果最后一个托盘数量小于超出的出库数量
// if (lastCarryQty < wmsRawmatOutstockD.actual_outstock_qty + qty - wmsRawmatOutstockD.qty)
// {
// throw new AppFriendlyException($"本次出库数量{qty}已超过可出库数量{wmsRawmatOutstockD.qty - wmsRawmatOutstockD.actual_outstock_qty} 且无需选择{items[items.Count - 1].carry_code}", 500);
// }
// // 签收数量
// sign_qty = lastCarryQty - (wmsRawmatOutstockD.actual_outstock_qty + qty - wmsRawmatOutstockD.qty);
// }
//
// await _db.Ado.BeginTranAsync();
//
// List<BasLocation> endLocations = new List<BasLocation>();
//
// endLocations = _db.Queryable<BasLocation>().Where(r => _wareHouseService.GetFloor1YCLDBOutstockLocation().Contains(r.id) && r.is_lock == 0 && r.is_use == "0")
// .OrderBy("is_lock, task_nums, location_code").ToList();
//
// if (endLocations.Count() < items.Count)
// {
// throw new AppFriendlyException($@"可用的终点库位数量为{endLocations.Count()}个 下发数量为{items.Count}个 请检查终点库位的锁定和占用状态", 500);
// }
//
// foreach (var wmsCarryH in items)
// {
// BasLocation startLocation = await _db.Queryable<BasLocation>().Where(r => r.id == wmsCarryH.location_id).FirstAsync();
//
// BasLocation endLocation = null;
//
// endLocation = await _db.Queryable<BasLocation>().Where(r => _wareHouseService.GetFloor1YCLDBOutstockLocation().Contains(r.id) && r.is_lock == 0 && r.is_use == "0").OrderBy("is_lock, task_nums, location_code").FirstAsync();
//
// if (endLocation == null)
// {
// throw new AppFriendlyException($@"没有可用的终点库位！请检查终点库位的锁定和占用状态", 500);
// }
//
// WmsRawmatOutstockC wmsRawmatOutstockC = new WmsRawmatOutstockC();
// wmsRawmatOutstockC.bill_id = w msRawmatOutstockH.id ;
// wmsRawmatOutstockC.mat_ bill_id = wmsRawmatOutstockD.id ;
// wmsRawmatOutstockC.carry_id = wmsCarryH.id ;
// wmsRawmatOutstockC. carry_code = wmsCarryH.carry_code ;
// wmsRawmatOutstockC.create_id = input.create_id ;
// wmsRawmatOutstockC. create_time = DateTime.Now ;
// wmsRawmatOutstockC.startlocation_id = startLocation.id ;
// wmsRawmatOutstockC. startlocation_code = startLocation.location_code ;
// wmsRawmatOutstockC.endlocation_id = endLocation.id ;
// wmsRawmatOutstockC. endlocation_code = endLocation.location_code ;
// decimal carryQty = wmsCarryCodes.Where(r => r.carry_id == wmsCarryH.id).Sum(r => r.codeqty) ;
// wmsRawmatOutstockC.qty = carryQty ;
// wmsRawmatOutstockC.sign_qty = wmsCarryH.id == items[items.Count - 1].id && sign_qty > 0 ? sign_qty : carryQty;
//
// await _db.Insertable(wmsRawmatOutstockC).ExecuteCommandAsync();
//
// CommonCreatePretaskInput commonCreatePretaskInput = new CommonCreatePretaskInput();
// c ommonCreatePretaskInput.startlocation_id = startLocation.id ;
// commonCreatePretaskInput.end location_id = endLocation.id ;
// commonCreatePretaskInput.task_type = WmsWareHouseConst.WMS_PRETASK_OUTSTOCK_TYPE_ID ;
// commonCreatePretaskInput.biz_type = WmsWareHouseConst.BIZTYPE_WmsRawmatOutstock _ID;
// commonCreatePretaskInput.source_id = input.source_id ;
// commonCreatePretaskInput.carry_id = wmsCarryH.id ;
// commonCreatePretaskInput. carry_code = wmsCarryH.carry_code ;
// commonCreatePretaskInput.isExcuteMission = false ;
//
// Entities.Dto.Outputs.Result res = await _wareHouseService.CommonCreatePretask(commonCreatePretaskInput, _db);
//
// if (res.code != HttpStatusCode.OK)
// {
// Logger.LogInformation($@"生成预任务失败");
// throw new AppFriendlyException( $@"生成预任务失败", 500) ;
// }
// }
//
// // 更新子表已下发数量
// await _db.Updateable<WmsRawmatOutstockD>().SetColumns(r => r.actual_outstock_qty == r.actual_outstock_qty + qty).Where(r => r.id == input.source_id).ExecuteCommandAsync();
//
// await _db.Ado.CommitTranAsync();
// }
// catch (Exception ex)
// {
// await _db.Ado.RollbackTranAsync();
// Logger.LogError("【Distribute】" + ex.Message) ;
// Logger. LogError( "【Distribute】" + ex.StackTrace) ;
// return await ToApiResult(HttpStatusCode.InternalServerError, ex.Message) ;
// }
// finally
// {
// _ = _s_taskExecuteSemaphore_YCLOutstock.Release();
// InvokeGenPre taskExcute() ;
// }
//
// return await ToApiResult(HttpStatusCode.OK, "成功");
// }
//
// }
// }
:
= .
< >
,
= . ( )
=
=
=
=
=
=
. =
(
( input = =
new ( ( input ) )
// WmsRawmatOutstockD wmsRawmatOutstockD = await _db.Queryable<WmsRawmatOutstockD>().SingleAsync(x=>x.id==input.requireId);
// WmsRawmatOutstockH wmsRawmatOutstockH = await _db.Queryable<WmsRawmatOutstockH>().SingleAsync(x=>x.id==wmsRawmatOutstockD.bill_id);
// List<WmsCarryCode> wmsCarryCodes = await _db.Queryable<WmsCarryCode>()
// .Where(r => r.carry_id == input.wmsDistaskH.carry_id)
// .Where(r => r.material_id == wmsRawmatOutstockD.material_id && r.code_batch == wmsRawmatOutstockD.batchno)
// .ToListAsync();
//
// decimal qty = wmsCarryCodes.Sum(r => r.codeqty);
//
// List<String> unitCodes = wmsCarryCodes.Select(x => x.unit_id).Distinct().ToList();
// List<string> materialIds = wmsCarryCodes.Select(x => x.material_id).ToList();
// List<DictionaryDataEntity> unitDatas = await _db.Queryable<DictionaryTypeEntity>()
// .LeftJoin<DictionaryDataEntity>((x, y) => x.Id == y.DictionaryTypeId)
// .Where((x, y) => x.EnCode == DictConst.MeasurementUnit && unitCodes.Contains(y.EnCode))
// .Select((x, y) => y)
// .ToListAsync();
//
// string supplierId = WmsWareHouseConst.TIANYIGONGYINGSHANG_ID;
// List<string> tableIds = new List<string>();
// tableIds.Add(WmsWareHouseConst.AdministratorOrgId);
// tableIds.AddRange(materialIds);
// tableIds.Add(supplierId);
// tableIds.AddRange(unitDatas.Select(x => x.Id).ToList());
//
// List<ErpExtendField> erpExtendFields = await _db.Queryable<ErpExtendField>().Where(x => tableIds.Contains(x.table_id)).ToListAsync();
// string userId = wmsRawmatO utstockH.create_id;
// string erpCreateId = erpExtendFields.Find(x => x.table_id == userId)?.user_id ?? "";
// ErpExtendField erpOrg = erpExtendFields.Find(x => x.table_id == (WmsWareHouseConst.AdministratorOrgId));
// string nowStr = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
// List<WmsErpWarehouserelaH> wmsErpWarehouserelaHs = await _db.Queryable<WmsErpWarehouserelaH>().Where(x=>!SqlFunc.IsNullOrEmpty(x.id)).ToListAsync();
//
// List<Dictionary<string, object>> requestData = new List<Dictionary<string, object>>();
// Dictionary<string, object> erpRequestData = new Dictionary<string, object>();
// erpRequestData.Add("billmaker", erpCreateId);
// erpRequestData.Add("ccostdomainoid", null);
// erpRequestData.Add("cdrawcalbodyoid", erpOrg.pk_org);
// erpRequestData.Add("cdrawcalbodyvid", erpOrg.pk_org_v);
// erpRequestData.Add("cdrawwarehouseid", erpOrg.pk_org_v);
//
// erpRequestData.Add("corpo id", erpOrg.corpo id);
// erpRequestData.Add("corpvid", erpOrg.corpvid);
// erpRequestData.Add("cdptid","1 001A1100000001JFOP Q");//部门先写死
// erpRequestData.Add("cdptv id","0 001A1100000000AOMI Q");//部门先写死
// erpRequestData.Add("cotherdptid","1 001A1100000001JFOP Q");//部门先写死
// erpRequestData.Add("cotherdptvid","0001A1100000000AOMIQ");//部门先写死
// erpRequestData.Add("creationtime", nowStr );
// erpRequestData.Add("creator", erpCreateId);
// erpRequestData.Add("ctrantypeid", "0001H11000000000D32A" );//先写死
// erpRequestData.Add("cwarehouseid", outWhid);//先写死
// erpRequestData.Add("dbill date", wmsRawmatTransferoutstockH.create_time.Value.ToString("yyyy-MM-dd HH:mm:ss") );
// erpRequestData.Add("dmak edate", nowStr);
// erpRequestData.Add("dshldarr ivedate", nowStr);
// erpRequestData.Add("dshlddiliverdate", nowStr );
// erpRequestData.Add("fbillflag", 1 );
// erpRequestData.Add("isbackdeliver", false );
// erpRequestData.Add("ntotalnum", qty );
// erpRequestData.Add("pk_org", erpOrg.pk_org);
// erpRequestData.Add("pk_org_v ", erpOrg.pk_org_v );
// erpRequestData.Add("pk_group", erpOrg.pk_group );
// erpRequestData.Add("vbillcode", wmsRawmatTransferoutstockH.bill_code);
// erpRequestData.Add("vtrantypecode", "4Y-01");//先写死
//
// List<Dictionary<string, object>> erpRequestDataDetails = new List<Dictionary<string, object>>();
// foreach(var item in wmsCarryCodes)
{
// // 出库数量wmsMaterialSignD.sign_qty
// erpRequestDataDetails.Add(new Dictionary<string, object>()
// {
// ["cmaterialo id"] = erpExtendFields.Find(x => x.table_id == item.material_id)?.cmaterialo id ?? "",
// ["cmaterialv id"] = erpExtendFields.Find(x => x.table_id == item.material_id)?.cmaterialvid ?? "" ,
// ["corpo id"] = erpOrg.corpo id,
// ["corpvid"] = erpOrg.corpvid ,
// ["crowno"] = (wmsCarryCodes.FindIndex (x => x.id == item.id) + 1) * 10 ,
// ["cunitid"] = erpExtendFields.Find(x => x.table_id == (unitDatas.Find(x => x.EnCode == item.unit_id)?.Id ?? ""))?.cunitid ?? "" ,
// ["nnum"] = item.codeqty,
// ["nshouldnum"] = item.codeqty ,
// ["pk_group "] = erpOrg.pk_group ,
// ["pk_org"] = erpOrg.pk_org,
// ["pk_org_v"] = erpOrg.pk_org_v ,
// ["vbatchcode"] = item.code_batch,
//
// });
// }
// erpR equestData.Add("dtls", erpRequestDataDetails );
// requestData.Add(erpRequestData );
// BasFactoryConfig config = await _db.Queryable<BasFactoryConfig>().FirstAsync(x => x.enabled == 1 && x.key == FactoryConfigConst.BIPURL );
// T hirdWebapiRecord thirdWebapiRecord = new ThirdWebapiRecor d();
// thirdWebapiRecord.id = SnowflakeIdHelper.NextId() ;
// thirdWebapiRecord.third_ name = WmsWareHouseConst.BIP ;
// thirdWebapiRecord.name = "材料出库单(自制) ";
// thirdWebapiRecord.method = "POST ";
config.value + "uapws/rest/materialOut/self /save";
// // thirdWebapiRecord.url = WmsWareHouseConst.BIP_DOMAIN + "uapws/rest/transIn/save" ;
// thirdWebapiRecord.request_data = JsonConvert.SerializeObject(requestData) ;
// thirdWebapiRecord.create_time = DateTime.Now ;
// await _db.Insertable(thirdWebapiRecord).ExecuteCommandAsync();
}
[NonAction]
private async Task < dynamic > GetDetailsAsync ( string id )
{
try
{
return await Task . FromResult ( _db . Queryable < WmsRawmatOutstockD > ( ) . Where ( r = > r . bill_id = = id ) . ToList ( ) ) ;
}
catch ( Exception ex )
{
return Task . FromResult ( ex ) ;
}
<summary>
下发
/summary >
param name="input"></param >
returns></returns >
/// <exception cref="AppFriendlyException"></exception>
[HttpPost, NonUnify, AllowAnonymous]
public async Task < Entities . Dto . Outputs . Result > Distribute ( RawmatOutstockInput input )
{
try
{
await _s_taskExecuteSemaphore_YCLOutstock . WaitAsync ( ) ;
if ( string . IsNullOrEmpty ( input . source_id ) )
{
throw new AppFriendlyException ( "来源单据id不可为空" , 500 ) ;
}
if ( input . carrys . Count = = 0 )
{
throw new AppFriendlyException ( "至少选择一个载具" , 500 ) ;
}
D D = await _db . < D > ( ) . FirstAsync ( it = > it . id = = input . source_id )
WmsRawmatOutstockH wmsRawmatOutstockH = await _db . Queryable < WmsRawmatOutstockH > ( ) . FirstAsync ( it = > it . id = = wmsRawmatOutstockD . bill_id ) ;
List < WmsCarryH > _items = await _db . Queryable < WmsCarryH > ( ) . Where ( r = > input . carrys . Select ( c = > c . carry_code ) . Contains ( r . carry_code ) ) . ToListAsync ( ) ;
List < WmsCarryCode > wmsCarryCodes = await _db . Queryable < WmsCarryCode > ( ) . Where ( r = > _items . Select ( c = > c . id ) . Contains ( r . carry_id )
& & r . material_id = = wmsRawmatOutstockD . material_id & & r . code_batch = = wmsRawmatOutstockD . batchno ) . ToListAsync ( ) ;
List < WmsCarryH > items = new List < WmsCarryH > ( ) ;
foreach ( var carry in input . carrys . Select ( c = > c . carry_code ) )
{
items . Add ( _items . Where ( r = > r . carry_code = = carry ) . First ( ) ) ;
}
foreach ( var item in items )
{
if ( item . is_lock = = 1 )
{
throw new AppFriendlyException ( $"载具{item.carry_code}已锁定" , 500 ) ;
}
BasLocation carrryLoc = await _db . Queryable < BasLocation > ( ) . Where ( r = > r . id = = item . location_id ) . FirstAsync ( ) ;
if ( carrryLoc = = null | | carrryLoc . is_type ! = "0" )
{
throw new Exception ( $"托盘{item.carry_code}已经不在存储库位中，不能出库！" ) ;
}
decimal? sign_qty = 0 ;
decimal qty = wmsCarryCodes . Sum ( c = > c . codeqty ) ;
if ( wmsRawmatOutstockD . actual_outstock_qty + qty > wmsRawmatOutstockD . qty )
{
// 最后一个托盘的数量
decimal lastCarryQty = wmsCarryCodes . Where ( r = > r . carry_id = = items [ items . Count - 1 ] . id ) . Sum ( r = > r . codeqty ) ;
// 如果最后一个托盘数量小于超出的出库数量
if ( lastCarryQty < wmsRawmatOutstockD . actual_outstock_qty + qty - wmsRawmatOutstockD . qty )
{
throw new AppFriendlyException ( $"本次出库数量{qty}已超过可出库数量{wmsRawmatOutstockD.qty - wmsRawmatOutstockD.actual_outstock_qty} 且无需选择{items[items.Count - 1].carry_code}" , 500 ) ;
}
// 签收数量
sign_qty = lastCarryQty - ( wmsRawmatOutstockD . actual_outstock_qty + qty - wmsRawmatOutstockD . qty ) ;
}
await _db . Ado . BeginTranAsync ( ) ;
List < BasLocation > endLocations = new List < BasLocation > ( ) ;
endLocations = _db . Queryable < BasLocation > ( ) . Where ( r = > _wareHouseService . GetFloor1YCLDBOutstockLocation ( ) . Contains ( r . id ) & & r . is_lock = = 0 & & r . is_use = = "0" )
. OrderBy ( "is_lock, task_nums, location_code" ) . ToList ( ) ;
if ( endLocations . Count ( ) < items . Count )
{
throw new AppFriendlyException ( $@"可用的终点库位数量为{endLocations.Count()}个 下发数量为{items.Count}个 请检查终点库位的锁定和占用状态" , 500 ) ;
}
foreach ( var wmsCarryH in items )
{
BasLocation startLocation = await _db . Queryable < BasLocation > ( ) . Where ( r = > r . id = = wmsCarryH . location_id ) . FirstAsync ( ) ;
BasLocation endLocation = null ;
endLocation = await _db . Queryable < BasLocation > ( ) . Where ( r = > _wareHouseService . GetFloor1YCLDBOutstockLocation ( ) . Contains ( r . id ) & & r . is_lock = = 0 & & r . is_use = = "0" ) . OrderBy ( "is_lock, task_nums, location_code" ) . FirstAsync ( ) ;
if ( endLocation = = null )
{
throw new AppFriendlyException ( $@"没有可用的终点库位！请检查终点库位的锁定和占用状态" , 500 ) ;
}
WmsRawmatOutstockC = new W msRawmatOutstockC ( )
. = H . id
. mat_bill_id = wmsRawmatOutstockD . id
. id = wmsCarryH . id
. carry_code = wmsCarryH . carry_code
. id = input . create_id
. create_time = DateTime . Now
. id = . id
. startlocation_code = startLocation . location_code
. id = . id
wmsRawmatOutstockC . endlocation_code = endLocation . location_code
decimal carryQty = wmsCarryCodes . Where ( r = > r . carry_id = = wmsCarryH . id ) . Sum ( r = > r . codeqty )
. qty =
wmsRawmatOutstockC . sign_qty = wmsCarryH . id = = items [ items . Count - 1 ] . id & & sign_qty > 0 ? sign_qty : carryQty ;
await _db . Insertable ( wmsRawmatOutstockC ) . ExecuteCommandAsync ( ) ;
C ommonCreatePretaskInputcommonCreatePretaskInput = new CommonCreatePretaskInput ( )
. start location_id= startLocation . id
. endlocation_id = endLocation . id
. task_type = WmsWareHouseConst . WMS_PRETASK_OUTSTOCK_TYPE _ID
. biz_type = WmsWareHouseConst . BIZTYPE_WmsRawmatOutstock_ID
. source_id = input . source_id
. id = wmsCarryH . id
. carry_code = wmsCarryH . carry_code
commonCreatePretaskInput . isExcuteMission = false ;
Entities . Dto . Outputs . Result res = await _wareHouseService . CommonCreatePretask ( commonCreatePretaskInput , _db ) ;
if ( res . code ! = HttpStatusCode . OK )
{
Logger . LogInformation ( )
throw new AppFriendlyException ( $@"生成预任务失败" , 500 ) ;
}
// 更新子表已下发数量
await _db . Updateable < WmsRawmatOutstockD > ( ) . SetColumns ( r = > r . actual_outstock_qty = = r . actual_outstock_qty + qty ) . Where ( r = > r . id = = input . source_id ) . ExecuteCommandAsync ( ) ;
await _db . Ado . CommitTranAsync ( ) ;
}
catch ( Exception ex )
{
await _db . Ado . RollbackTranAsync ( )
. ( + ex . Message )
Logger . LogError ( "【Distribute】" + ex . StackTrace )
return await ToApiResult ( HttpStatusCode . InternalServerError , ex . Message ) ;
}
finally
{
_ = _s_ taskExe cuteSemaphore_YCLOutstock . Release ( )
InvokeGenPretaskExcute ( ) ;
}
return await ToApiResult ( HttpStatusCode . OK , "成功" ) ;
}
}
