using Rhea.Common;
|
using Microsoft.AspNetCore.Http;
|
using SqlSugar;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Linq.Expressions;
|
using System.Text;
|
using System.Threading;
|
using System.Threading.Tasks;
|
using Tiger.Model;
|
|
using Newtonsoft.Json;
|
using Apache.NMS.ActiveMQ.Commands;
|
using Tiger.IBusiness;
|
|
namespace Tiger.Business.WMS.Transaction
|
{
|
/// <summary>
|
/// 货架遥控事务
|
/// </summary>
|
public class ShelfRemote : WMSTransactionBase, IShelfRemote
|
{
|
public IShelfRemote Init(string id, string userCode, string apiHost)
|
{
|
TransID = id;
|
UserCode = userCode;
|
ApiHost = apiHost;
|
Logger.Console.Info($"Start {this.GetType().Name} Transaction[ID: {TransID}]");
|
return this;
|
}
|
|
#region Propertys & Variables
|
public string UserCode { get; set; }
|
public long UserId { get; set; }
|
public string CurInv { get; set; }
|
public AuthOption option { get; set; }
|
#endregion
|
|
#region Functions
|
/// <summary>
|
/// CloseShelfAllLight
|
/// </summary>
|
/// <returns></returns>
|
public async Task<ApiAction> CloseShelfAllLight(string shelfStr)
|
{
|
var action = new ApiAction(true);
|
try
|
{
|
var shelfs = shelfStr.Split(new string[] { "," }, StringSplitOptions.RemoveEmptyEntries).Select(q => q + "F").ToList();
|
shelfs.AddRange(shelfs.Select(q => q.Substring(0, q.Length - 1) + "R").ToList());
|
var success = new List<string>();
|
foreach (var shelf in shelfs)
|
{
|
var result = await Share.Shelf.DownAll(shelf);
|
if (result.IsSuccess)
|
{
|
success.Add(shelf);
|
}
|
}
|
shelfs.RemoveAll(q => success.Contains(q));
|
if (success.Count == 0)
|
{
|
action.IsSuccessed = false;
|
action.LocaleMsg = Biz.L($"货架[{string.Join(",", shelfs)}]灭灯失败");
|
}
|
else
|
{
|
action.IsSuccessed = true;
|
action.LocaleMsg = Biz.L($"货架[{string.Join(",", success)}]灭灯成功{(shelfs.IsNullOrEmpty() ? "" : $"，货架[{string.Join(",", shelfs)}]灭灯失败")}");
|
}
|
}
|
catch (Exception ex)
|
{
|
action.CatchExceptionWithLog(ex, $"Close shelf all light[{shelfStr}] exception");
|
}
|
return action;
|
}
|
|
public async Task<ApiAction> Test(string billCode)
|
{
|
var action = new ApiAction();
|
try
|
{
|
string CurOrg = billCode;
|
}
|
catch (Exception ex)
|
{
|
action.CatchExceptionWithLog(ex, $"其他入库单[]过账异常");
|
}
|
return action;
|
}
|
#endregion
|
|
public override bool Close(bool needSaveHistoryLog = false)
|
{
|
//保存操作日志
|
|
this.IsFinished = true;
|
return IsFinished ? base.Close(needSaveHistoryLog) : IsFinished;
|
}
|
|
}//endClass
|
}
|
