using Newtonsoft.Json;
|
using Rhea.Common;
|
using SqlSugar;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading;
|
using System.Threading.Tasks;
|
using Tiger.Business.SqlSugarHepler;
|
using Tiger.IBusiness;
|
using Tiger.Model;
|
using Tiger.Model.Entitys.WMS.DTOS;
|
|
namespace Tiger.Business.WMS.Transaction
|
{
|
public class Resell : WMSTransactionBase, IResell
|
{
|
/// <summary>
|
/// T100接口URL
|
/// </summary>
|
public string t100Url { get; set; } = @"http://172.18.8.11/wstopprd/ws/r/awsp920";
|
/// <summary>
|
/// 事务初始化函数
|
/// </summary>
|
/// <param name="id"></param>
|
/// <param name="userCode"></param>
|
/// <param name="apiHost"></param>
|
/// <param name="orgCode"></param>
|
/// <returns></returns>
|
public IResell Init(string id, string userCode, string apiHost, string orgCode)
|
{
|
TransID = id;
|
UserCode = userCode;
|
ApiHost = apiHost;
|
OrgCode = orgCode;
|
Logger.Console.Info($"Start {this.GetType().Name} Transaction[ID: {TransID}]");
|
return this;
|
}
|
|
|
#region Propertys & Variables
|
public string BillCode { get; set; }
|
public string TARGET_ORG { get; set; }
|
public string UserCode { get; set; }
|
public long UserId { get; set; }
|
public string RackCode { get; set; }
|
public string WarehouseCode { get; set; }
|
public string WarehouseName { get; set; }
|
public string OrgCode { get; set; }
|
public WMS_SHELF Shelf { get; set; }
|
|
public ResellPuton ResellPuton1 { get; set; }
|
public BIZ_ERP_SALE_OUT res { get; set; }
|
#endregion
|
|
/// <summary>
|
/// 获取转卖单列表
|
/// </summary>
|
/// <param name="pageIndex"></param>
|
/// <param name="pageSize"></param>
|
/// <returns></returns>
|
public ApiAction<PageAble<BIZ_ERP_SALE_OUT>> GetResellHeaders(int pageIndex, int pageSize, string orgcode, string billcode)
|
{
|
var action = new ApiAction<PageAble<BIZ_ERP_SALE_OUT>>();
|
var query = Biz.Db.Queryable<BIZ_ERP_SALE_OUT>().Where(x =>
|
(x.STATUS == BIZ_ERP_SALE_OUT.STATUSs.INIT.GetValue()
|
|| x.STATUS == BIZ_ERP_SALE_OUT.STATUSs.WORKING.GetValue())
|
&& x.AUTH_ORG == orgcode)
|
.WhereIF(!billcode.IsNullOrEmpty(), x => x.BILLCODE.Contains(billcode))
|
.OrderByDescending(x => x.UPDATE_TIME.ToString("yyyy-MM-dd"))
|
.OrderBy(x => x.CREATE_TIME)
|
.ToPage(pageIndex, pageSize);
|
action.Data = query;
|
return action;
|
}
|
/// <summary>
|
/// 转卖单选择事件
|
/// </summary>
|
/// <param name="input"></param>
|
/// <returns></returns>
|
public async Task<ApiAction<Resell_Input>> SelectOrder(ResellInput input)
|
{
|
var action = new ApiAction<Resell_Input>();
|
try
|
{
|
//SelectOrderOption = input.AuthOption;
|
res = await Biz.Db.Queryable<BIZ_ERP_SALE_OUT>().Where(x => x.BILLCODE == input.ResellNo).Includes(q => q.DetailsWithGhost, d => d.ItemInfo).IncludesAllFirstLayer().FirstAsync();
|
//验证明细是否正确
|
if (!res.Details.Any())
|
{
|
action.IsSuccessed = false;
|
action.LocaleMsg = new("WMS.ProdMReq.SelectOrder.DtlsException", input.ResellNo);
|
return action;
|
}
|
BillCode = input.ResellNo;//单号
|
TARGET_ORG = res.TARGET_ORG;//目标据点
|
//OrgCode//原据点
|
//WareHouseCode//扫描仓库
|
action.LocaleMsg = Biz.L("选择多角转卖单成功");
|
action.Data = new Resell_Input
|
{
|
BILLCODE = BillCode,//单据
|
WAREHOUSECODE = "",//原仓库
|
TARGET_WAREHOUSECODE = "",//目标仓库
|
AUTH_ORG = "",//原据点
|
TARGET_ORG = "",//目标据点
|
};
|
}
|
catch (Exception ex)
|
{
|
action.CatchExceptionWithLog(ex, $"多角转卖单选择异常");
|
}
|
return action;
|
}
|
|
/// <summary>
|
/// 扫描物料并复核，如果物料已经完成移库则货架上亮灯提醒储位
|
/// </summary>
|
public async Task<ApiAction> ScanItem(ResellModel input)
|
{
|
var action = new ApiAction();
|
try
|
{
|
if (string.IsNullOrEmpty(input.SN))
|
{
|
action.IsSuccessed = false;
|
action.LocaleMsg = Biz.L("WMS.CustSupChk.ScanItem.SnEmptyFailure"); // $"条码不能为空！";
|
return action;
|
}
|
//货架为空则扫描的认为是货架
|
if (string.IsNullOrEmpty(RackCode))
|
{
|
var _action = await ScanShelf(input.SN);
|
action.LocaleMsg = _action.LocaleMsg;
|
action.IsSuccessed = _action.IsSuccessed;
|
if (!action.IsSuccessed)
|
{
|
action.Data = _action.Data;
|
return action;
|
}
|
else
|
{
|
//调用T100接口传入WarehouseCode,修改业务表信息
|
var To100param = new Resell_Input
|
{
|
BILLCODE=BillCode
|
};
|
|
var query = MaterialToErp(To100param);
|
//调用t100或修改业务表时发生错误
|
if(query.IsSuccessed == false)
|
{
|
action.IsSuccessed = false;
|
action.LocaleMsg = query.LocaleMsg;
|
return action;
|
}
|
//返回信息
|
action.Data = new Resell_Input
|
{
|
BILLCODE=BillCode,//单据
|
WAREHOUSECODE= RackCode,//原仓库
|
TARGET_WAREHOUSECODE="",//目标仓库
|
AUTH_ORG=OrgCode,//原据点
|
TARGET_ORG=TARGET_ORG,//目标据点
|
};
|
}
|
|
}
|
else
|
{
|
action.IsSuccessed = false;
|
action.LocaleMsg = Biz.L("该单已操作，请退出重新选单！");
|
return action;
|
}
|
}
|
catch (Exception ex)
|
{
|
//取消当前操作
|
|
action.CatchExceptionWithLog(ex, $"扫描物料[{input.SN}]复核异常");
|
}
|
return action;
|
}
|
|
/// <summary>
|
/// 扫描货架或者储位
|
/// </summary>
|
public async Task<ApiAction<ResellPuton>> ScanShelf(string Code)
|
{
|
var action = new ApiAction<ResellPuton>();
|
try
|
{
|
if (Code.IsNullOrEmpty())
|
{
|
action.IsSuccessed = false;
|
action.LocaleMsg = Biz.L("WMS.CustSupChk.ScanItem.ShelfCanNotEmpty");
|
return action;
|
}
|
|
ResellPuton1 = new ResellPuton();
|
|
// 查询货架信息
|
var whUnit = await Biz.Db.Queryable<V_WH_UNIT>().Where(t => t.WH_CODE.ToUpper() == Code.ToUpper() && t.AUTH_ORG == OrgCode).IncludesAllFirstLayer().FirstAsync();
|
|
// 扫描货架代码，且为智能货架
|
if (whUnit != null && whUnit.SHELF_TYPE == WMS_SHELF.SHELF_TYPEs.Smart.GetValue())
|
{
|
ResellPuton1.WarehouseCode = whUnit.WH_CODE;
|
ResellPuton1.RackCode = whUnit.SHELF_CODE;
|
ResellPuton1.ShelfType = whUnit.SHELF_TYPE;
|
ResellPuton1.IsSmartRack = true;
|
Shelf = whUnit.Shelf;
|
|
}
|
// 扫描库位代码
|
else
|
{
|
var nWh_code = await Biz.Db.Queryable<V_WH_UNIT>().Where(t => t.WH_CODE.ToUpper() == Code.ToUpper() && t.AUTH_ORG == OrgCode).FirstAsync();
|
if (nWh_code == null)
|
{
|
action.IsSuccessed = false;
|
action.LocaleMsg = Biz.L("WMS.CustSupChk.ScanItem.NotExist", Code);
|
return action;
|
}
|
|
if (nWh_code.IS_ACTIVE == "N")
|
{
|
action.IsSuccessed = false;
|
action.LocaleMsg = Biz.L("WMS.CustSupChk.ScanItem.ShelfOrLocationDisabled");
|
return action;
|
}
|
//if (nWh_code.SHELF_TYPE == WMS_SHELF.SHELF_TYPEs.Smart.GetValue() || nWh_code.SHELF_TYPE == WMS_SHELF.SHELF_TYPEs.QRCode.GetValue())
|
//{
|
// var locationData = Biz.Db.Queryable<WMS_ITEM>().Where(q => q.LOCATION_ID == nWh_code.LOCATION_ID && q.AUTH_ORG == OrgCode).First();
|
// if (!locationData.IsNullOrEmpty())
|
// {
|
// action.IsSuccessed = false;
|
// action.LocaleMsg = Biz.L($"系统当前库位存在料盘，请检查系统库存信息");
|
// return action;
|
|
// }
|
//}
|
|
ResellPuton1.LocationCode = nWh_code.LOCATION_CODE;
|
ResellPuton1.WarehouseCode = nWh_code.WH_CODE;
|
//CustomerSupplyPuton.Capacity = nLocation.MAXSIZE - nUsedCapacity;
|
//CustomerSupplyPuton.LotCount = nLocation.LOTCOUNT;
|
//CustomerSupplyPuton.MaxSize = nLocation.MAXSIZE;
|
ResellPuton1.IsSmartRack = false;
|
ResellPuton1.RackCode = nWh_code.SHELF_CODE;
|
}
|
WarehouseCode = ResellPuton1.WarehouseCode;
|
RackCode = ResellPuton1.RackCode;
|
ResellPuton1.IsScanShelf = true;
|
action.LocaleMsg = Biz.L("扫描成功");
|
action.Data = ResellPuton1;
|
}
|
catch (Exception ex)
|
{
|
//取消当前操作
|
|
action.CatchExceptionWithLog(ex, $"扫描货架或者储位[{Code}]异常");
|
}
|
return action;
|
}
|
/// <summary>
|
/// 领料单过账到T100
|
/// </summary>
|
/// <param name="param">单号</param>
|
/// <returns></returns>
|
public ApiAction MaterialToErp(Resell_Input param)
|
{
|
var action = new ApiAction();
|
List<Tot100pamar> dtl = new List<Tot100pamar>();
|
//foreach (var item in res.Details)
|
{
|
var t100 = new Tot100pamar()
|
{
|
l_seq="1",
|
imaxuc005=OrgCode,
|
imaxuc006=WarehouseCode,
|
imaxuc002=TARGET_ORG,
|
imaxuc003="",
|
};
|
dtl.Add(t100);
|
}
|
|
//Work.DoAsync(() =>
|
{
|
Thread.Sleep(3000);
|
var authOrg = GetAuthOrg(param.BILLCODE);
|
|
#region 创建请求实体
|
|
var model = new BodyDTO<PayLoad<Std_Data<Tot100>>>()
|
{
|
host = new HostDTO(),
|
datakey = new DataKey()
|
{
|
EntId = "88",
|
CompanyId = authOrg
|
},
|
service = new ServiceDTO()
|
{
|
name = "wms_get_cimm202"
|
},
|
payload = new PayLoad<Std_Data<Tot100>>()
|
{
|
std_data = new Std_Data<Tot100>()
|
{
|
parameter = new Tot100()
|
{
|
pamar = dtl
|
}
|
}
|
}
|
};
|
|
#endregion 创建请求实体
|
|
#region 发起请求
|
|
var result = new T100ActionResult<resultStd_inputdata>();
|
try
|
{
|
var requestJson = JsonConvert.SerializeObject(model);
|
var response = HttpHelper.PostAsync(t100Url, requestJson).Result;
|
result = JsonConvert.DeserializeObject<T100ActionResult<resultStd_inputdata>>(response.Message);
|
Logger.Scheduler.Info($"多角转卖对接T100过账提交Json: {requestJson}，返回Json: {response.Message}");
|
}
|
catch (Exception ex)
|
{
|
Logger.Default.Info($"多角转卖对接T100过账失败");
|
//return "0";
|
}
|
|
#endregion 发起请求
|
|
var db = Biz.Db;
|
var items = db.Queryable<WMS_ITEM>().Where(i => i.TRANS_NO == param.BILLCODE).ToList();
|
var items_pkg = db.Queryable<WMS_ITEM_PKG>().Where(i => i.TRANS_NO == param.BILLCODE).ToList();
|
var t100_res = result.payload.parameter?.returns;
|
//var wh_id=db.Queryable<WMS_WAREHOUSE>().Where(q=>q.WH_CODE==WarehouseCode).ToString();
|
List<WMS_ITEM_HIS> ItemHistorys = new List<WMS_ITEM_HIS>();
|
if (result.payload.std_data?.execution.code == "0")
|
{
|
if (items.Count > 0 && items_pkg.Count > 0)
|
{
|
|
foreach (var item in items)
|
{
|
item.AUTH_ORG = TARGET_ORG;
|
item.WH_ID = result.payload.parameter?.returns.FirstOrDefault().imaxuc003;
|
item.SOURCE_CODE = "BIZ_ERP_SALE_OUT";
|
|
|
WMS_ITEM_HIS his = new WMS_ITEM_HIS(item, $"多角转卖，销售单[{BillCode}][{string.Join(",", res.Details.Where(s => s.ITEM_CODE == item.ITEM_CODE).Select(q => q.BILLLINE))}]");
|
ItemHistorys.Add(his);
|
}
|
foreach (var item in items_pkg)
|
{
|
item.AUTH_ORG = TARGET_ORG;
|
item.WH_ID = result.payload.parameter?.returns.FirstOrDefault().imaxuc003;
|
item.SOURCE_CODE = "BIZ_ERP_SALE_OUT";
|
}
|
//业务表头
|
res.AUTH_ORG = TARGET_ORG;
|
res.WAREHOUSECODE = WarehouseCode;
|
res.STATUS = BIZ_ERP_SALE_OUT.STATUSs.COMPLETE.GetValue();
|
//业务表明细
|
foreach (var item in res.Details)
|
{
|
item.AUTH_ORG = TARGET_ORG;
|
item.WAREHOUSECODE = WarehouseCode;
|
item.LINESTATUS = BIZ_ERP_SALE_OUT.STATUSs.COMPLETE.GetValue();
|
}
|
//业务表条码
|
foreach (var item in res.SnList)
|
{
|
item.AUTH_ORG = TARGET_ORG;
|
//item.WAREHOUSECODE = WarehouseCode;
|
item.STATUS = WMS_ITEM.STATUSs.InStore.GetValue();
|
}
|
}
|
else
|
{
|
action.IsSuccessed = false;
|
action.LocaleMsg = Biz.L($"库存信息不足");
|
}
|
|
}
|
else
|
{
|
action.IsSuccessed = false;
|
action.LocaleMsg = Biz.L($"T100返回了错误[{result.payload.std_data?.execution.description}]");
|
}
|
//保存到数据库
|
var db2 = Biz.Db;
|
var dbTran = db2.UseTran(() =>
|
{
|
// 插入单据表头
|
db2.Updateable(res, UserCode).ExecuteCommand();
|
var x = db2.Storageable(res.Details, UserCode).ToStorage();
|
x.AsInsertable.ExecuteCommand();//不存在插入
|
x.AsUpdateable.IgnoreColumns(z => new { z.CREATE_TIME, z.CREATE_USER }).ExecuteCommand();//存在更新，更新时忽略字段CreationTime、CreatorUserId
|
|
db2.Updateable(res.SnList, UserCode).ExecuteCommand();
|
|
db2.Updateable(items, UserCode).ExecuteCommand();
|
db2.Updateable(items_pkg, UserCode).ExecuteCommand();
|
db2.Insertable(ItemHistorys, UserCode).ExecuteCommand();
|
|
});
|
if (!dbTran.IsSuccess)
|
{
|
Logger.Default.Fatal(dbTran.ErrorException, "Database transaction save exception");
|
this.Close(!dbTran.IsSuccess);
|
throw dbTran.ErrorException;
|
}
|
}
|
//});
|
return action;
|
}
|
|
/// <summary>
|
/// 根据工单号获取据点名称
|
/// </summary>
|
/// <param name="workOrder"></param>
|
/// <returns></returns>
|
public string GetAuthOrg(string workOrder)
|
{
|
var authOrg = string.Empty;
|
var org = workOrder.Substring(0, 2);
|
switch (org)
|
{
|
#region 循环取值
|
|
case "PH":
|
authOrg = "PHXC";
|
break;
|
|
case "YX":
|
authOrg = "YXYY";
|
break;
|
|
case "XP":
|
authOrg = "XCXP";
|
break;
|
|
case "XN":
|
authOrg = "XCXN";
|
break;
|
|
case "TH":
|
authOrg = "STTH";
|
break;
|
|
case "XC":
|
authOrg = "XCSJ";
|
break;
|
|
case "DG":
|
authOrg = "DGXC";
|
break;
|
|
case "HK":
|
authOrg = "HKXC";
|
break;
|
|
case "TX":
|
authOrg = "TXXC";
|
break;
|
|
case "LR":
|
authOrg = "XCLR";
|
break;
|
|
case "OM":
|
authOrg = "OMKJ";
|
break;
|
|
case "AH":
|
authOrg = "AHXC";
|
break;
|
|
case "YK":
|
authOrg = "XCYK";
|
break;
|
|
case "CC":
|
authOrg = "XCCC";
|
break;
|
|
case "TC":
|
authOrg = "XCTC";
|
break;
|
|
case "TK":
|
authOrg = "STTK";
|
break;
|
|
case "MM":
|
authOrg = "STMM";
|
break;
|
|
default:
|
throw new Exception($"单号前两位：{org}未能找到对应的据点，请确认！");
|
|
#endregion 循环取值
|
}
|
return authOrg;
|
}
|
|
public override bool Close(bool needSaveHistoryLog = false)
|
{
|
//保存操作日志
|
|
this.IsFinished = true;
|
return IsFinished ? base.Close(needSaveHistoryLog) : IsFinished;
|
}
|
}
|
}
|
