|
using HH.WCS.QingXigongchang.core;
|
using HH.WCS.QingXigongchang.device;
|
using HH.WCS.QingXigongchang.process;
|
using HH.WCS.QingXigongchang.util;
|
using HH.WCS.QingXigongchang.wms;
|
using Newtonsoft.Json;
|
using Newtonsoft.Json.Linq;
|
using SqlSugar;
|
using System;
|
using System.Collections.Generic;
|
using System.Diagnostics;
|
using System.Linq;
|
using System.Reflection;
|
using System.Text.RegularExpressions;
|
using System.Threading;
|
using System.Web.Http;
|
using System.Web.Http.Results;
|
using static HH.WCS.QingXigongchang.api.ApiHelper;
|
using static HH.WCS.QingXigongchang.api.ApiModel;
|
using static HH.WCS.QingXigongchang.process.DeviceProcess;
|
using static HH.WCS.QingXigongchang.util.HttpHelper;
|
using Monitor = HH.WCS.QingXigongchang.core.Monitor;
|
|
namespace HH.WCS.QingXigongchang.api
|
{
|
/// <summary>
|
/// 第三方调用的接口
|
/// </summary>
|
[RoutePrefix("api")]
|
public class WmsController : System.Web.Http.ApiController
|
{
|
//[HttpPost]
|
//public SimpleResult AddTask(AddTaskModel model) {
|
// ApiHelper.AddTask(model);
|
// return new SimpleResult();
|
//}
|
|
//已经改用mobox上lua脚本处理
|
//[HttpPost]
|
//[Route("CleanReport")]
|
//public SimpleResult CleanReport(LocationModel model) {
|
// LogHelper.Debug("CleanReport Request：" + JsonConvert.SerializeObject(model));
|
// return ApiHelper.CleanReport(model);
|
|
//}
|
|
|
|
[HttpPost]
|
[Route("ResetDevice")]
|
public SimpleResult ResetDevice(DeviceModel model)
|
{
|
LogHelper.Info("ResetDevice Request：" + JsonConvert.SerializeObject(model));
|
return ApiHelper.ResetDevice(model);
|
|
}
|
|
|
/// <summary>
|
/// 锁一排
|
/// </summary>
|
/// <param name="itemCode"></param>
|
/// <param name="qty"></param>
|
/// <returns></returns>
|
[HttpGet]
|
[Route("LockRow")]
|
public SimpleResult LockRow(string area, int row)
|
{
|
SimpleResult result = new SimpleResult();
|
List<int> rows = new List<int>();
|
var areas = area?.Split(':').ToList();
|
var index = 0;
|
if (areas.Count() > 1) //KKQ split count =1
|
{
|
area = areas[0];
|
index = 1;
|
areas.RemoveAt(0);
|
rows = Array.ConvertAll<string, int>(areas.ToArray(), s => int.Parse(s)).ToList();
|
}
|
else
|
{
|
if (index < 1 && row == 0)
|
{
|
result.resultCode = 2;
|
result.resultMsg = $"库区排不可为空；";
|
return result;
|
}
|
rows.Add(row);
|
}
|
if (rows.Count == 0)
|
{
|
result.resultCode = 2;
|
result.resultMsg = $"库区排不可为空；";
|
return result;
|
}
|
|
return ApiHelper.Outgo1(area, rows);
|
}
|
|
[HttpGet]
|
[Route("ClearLoc")]
|
public SimpleResult ClearLoc(string area, int row)
|
{
|
SimpleResult result = new SimpleResult() { resultCode = 0 };
|
|
if (string.IsNullOrEmpty(area) || row < 1)
|
{
|
result.resultCode = 2;
|
result.resultMsg = $"库区排不可为空；";
|
return result;
|
}
|
|
return ApiHelper.clearLoc(area, new List<int> { row });
|
}
|
|
[HttpGet]
|
[Route("LockR")]
|
public SimpleResult LockR(string area, int row)
|
{
|
SimpleResult result = new SimpleResult() { resultCode = 0 };
|
|
if (string.IsNullOrEmpty(area) || row < 1)
|
{
|
result.resultCode = 2;
|
result.resultMsg = $"库区排不可为空；";
|
return result;
|
}
|
|
return ApiHelper.clearloc(area, new List<int> { row });
|
}
|
|
[HttpGet]
|
[Route("unLockR")]
|
public SimpleResult unLockR(string area, int row)
|
{
|
SimpleResult result = new SimpleResult() { resultCode = 0 };
|
|
if (string.IsNullOrEmpty(area) || row < 1)
|
{
|
result.resultCode = 2;
|
result.resultMsg = $"库区排不可为空；";
|
return result;
|
}
|
|
return ApiHelper.unlockrow(area, new List<int> { row });
|
}
|
|
|
[HttpGet]
|
[Route("unLockRow")]
|
public SimpleResult unLockRow(string area, int row)
|
{
|
List<int> rows = new List<int>();
|
var areas = area?.Split(':').ToList();
|
var index = 0;
|
if (areas.Count() > 1) //KKQ split count =1
|
{
|
area = areas[0];
|
index = 1;
|
areas.RemoveAt(0);
|
rows = Array.ConvertAll<string, int>(areas.ToArray(), s => int.Parse(s)).ToList();
|
}
|
else
|
{
|
SimpleResult result = new SimpleResult();
|
if (index < 1 && row == 0)
|
{
|
result.resultCode = 2;
|
result.resultMsg = $"库区排不可为空；";
|
return result;
|
}
|
rows.Add(row);
|
}
|
return ApiHelper.Outgo2(area, rows);
|
}
|
|
/// <summary>
|
/// 绑定单个
|
/// </summary>
|
/// <param name="itemCode"></param>
|
/// <param name="qty"></param>
|
/// <returns></returns>
|
[HttpGet]
|
[Route("BindLoc")]
|
public SimpleResult BindLoc(string loc, string IsJCJY)
|
{
|
SimpleResult res;
|
try
|
{
|
res = ApiHelper.Outgo3("---货位有库区。 。----", IsJCJY, loc);
|
}
|
catch (Exception ex)
|
{
|
res = new SimpleResult() { resultCode = 2, resultMsg = ex.Message };
|
}
|
return res;
|
}
|
|
[HttpGet]
|
[Route("RunOrder")]
|
public SimpleResult RunOrder(string WorkNo)
|
{
|
LogHelper.Info("RunOrder" + WorkNo);
|
SimpleResult res = new SimpleResult() { resultCode = 0, resultMsg = "" };
|
try
|
{
|
var Order = WCSHelper.GetWorkOrderByOrderNo(WorkNo);
|
|
if (Order == null)
|
return new SimpleResult() { resultCode = -1, resultMsg = "工单号不存在!" };
|
var sdvi = Settings.GetDeviceInfoList().Find(x => x.deviceName == Order.SQL_PLineNo);
|
if (sdvi == null)
|
return new SimpleResult() { resultCode = -1, resultMsg = "工单对应的产线号DeviceInfo不存在!" };
|
|
for (var i = 0; i < sdvi.location.Length; i++)
|
{
|
PlcHelper.SendHex(sdvi.address, "3F00" + (i + 1) + "0" + "0d0a");
|
}
|
}
|
catch (Exception ex)
|
{
|
res = new SimpleResult() { resultCode = -1, resultMsg = ex.Message };
|
}
|
return res;
|
}
|
|
/// <summary>
|
/// 成品绑定。
|
/// </summary>
|
/// <param name="loc">货位。</param>
|
/// <param name="LineNo">产线号 ,.防止因为后期增加多个产线 - </param>
|
/// <returns></returns>
|
[HttpGet]
|
[Route("BindCP")]
|
public SimpleResult BindLocCP(string loc, string LineNo, string arco)
|
{
|
SimpleResult res;
|
try
|
{
|
res = ApiHelper.BindCp(loc, LineNo, arco);
|
}
|
catch (Exception ex)
|
{
|
res = new SimpleResult() { resultCode = -1, resultMsg = ex.Message };
|
}
|
return res;
|
}
|
|
/// <summary>
|
/// 绑定 货位所在aroc 成品用
|
/// </summary>
|
/// <param name="loc"></param>
|
/// <param name="btype"></param>
|
/// <param name="arco"></param>
|
/// <returns></returns>
|
[HttpGet]
|
[Route("BindLoc2")]
|
public SimpleResult BindLoc2(string loc, string btype, string arco)
|
{
|
SimpleResult res;
|
try
|
{
|
res = ApiHelper.Outgo31(loc, btype, arco);
|
}
|
catch (Exception ex)
|
{
|
res = new SimpleResult() { resultCode = 2, resultMsg = ex.Message };
|
}
|
return res;
|
}
|
|
/// <summary>
|
/// 瓶坯。 满眶入库，转绑满眶出库。
|
/// </summary>
|
/// <param name="loc"></param>
|
/// <param name="LineNo"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[Route("BindLoc3")]
|
public SimpleResult BindLoc3(dynamic ooo)
|
{
|
var loc = ooo.loc.ToString();
|
var LineNo = ooo.LineNo.ToString();
|
string ItemCode = ooo.ItemCode.ToString();
|
|
LogHelper.Info("BindLoc3" + JsonConvert.SerializeObject(ooo));
|
if (string.IsNullOrEmpty(ItemCode) || string.IsNullOrEmpty(LineNo))
|
{
|
return SimpleResult.Error($"物料{ItemCode} 或 产线{LineNo} 不能空。");
|
}
|
SimpleResult res;
|
try
|
{
|
if (!ItemCode.Contains("纸箱"))
|
{
|
var item = ContainerHelper.GetItem(ItemCode);
|
if (item == null) { return SimpleResult.Error(ItemCode + "数据不存在"); }
|
ItemCode = item.S_ITEM_CODE;
|
}
|
res = ApiHelper.Outgo33(loc, LineNo + ">" + ItemCode);
|
}
|
catch (Exception ex)
|
{
|
res = new SimpleResult() { resultCode = 2, resultMsg = ex.Message };
|
}
|
return res;
|
}
|
|
/// <summary>
|
/// 空筐解绑。
|
/// </summary>
|
/// <param name="loc"></param>
|
/// <param name="LineNo"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[Route("unBindLoc3")]
|
public SimpleResult unBindLoc3(dynamic ooo)
|
{
|
var loc = ooo.loc.ToString();
|
|
LogHelper.Info("unBindLoc3" + JsonConvert.SerializeObject(ooo));
|
if (string.IsNullOrEmpty(loc))
|
{
|
return SimpleResult.Error($"参数：{loc} 不能空。");
|
}
|
SimpleResult res;
|
try
|
{
|
res = ApiHelper.unOutgo33(loc);
|
}
|
catch (Exception ex)
|
{
|
res = new SimpleResult() { resultCode = 2, resultMsg = ex.Message };
|
}
|
return res;
|
}
|
|
/// <summary>
|
/// 瓶坯 空 满 即产 绑定。
|
/// </summary>
|
/// <param name="loc">货位</param>
|
/// <param name="arco">area row col one</param>
|
/// <param name="JF">J 即产 F 非即产</param>
|
/// <returns></returns>
|
[HttpPost]
|
[Route("PPBindLocs")]
|
public SimpleResult PPBindLocs(dynamic ooo)
|
{
|
string loc = ooo.loc.ToString();
|
string arco = ooo.arco.ToString();
|
string item = ooo.item.ToString();
|
|
if (string.IsNullOrEmpty(item))
|
{
|
return SimpleResult.Error($"物料{item} 找不到物料");
|
}
|
SimpleResult res;
|
try
|
{
|
res = ApiHelper.Outgo34(loc, "", arco, item);
|
}
|
catch (Exception ex)
|
{
|
res = new SimpleResult() { resultCode = 2, resultMsg = ex.Message };
|
}
|
return res;
|
}
|
[HttpGet]
|
[Route("PPunBindLocs")]
|
public SimpleResult unPPBindLocs(string loc, string arco)
|
{
|
SimpleResult res;
|
try
|
{
|
res = ApiHelper.Outgo34(loc, "", arco, "", false);
|
}
|
catch (Exception ex)
|
{
|
res = new SimpleResult() { resultCode = 2, resultMsg = ex.Message };
|
}
|
return res;
|
}
|
|
|
|
[HttpGet]
|
[Route("unBindLoc")]
|
public SimpleResult unBindLoc(string loc, string arco)
|
{
|
return ApiHelper.unOutgo3("--- 不用传。----", loc, arco);
|
}
|
/// <summary>
|
/// 按列绑定
|
/// </summary>
|
/// <param name="area"></param>
|
/// <param name="col"></param>
|
/// <returns></returns>
|
[HttpGet]
|
[Route("BindLocs")]
|
public SimpleResult BindLocs(string area, string col)
|
{
|
SimpleResult result = new SimpleResult();
|
List<int> rows = new List<int>();
|
var areas = area?.Split(':').ToList();
|
var index = 0;
|
if (areas.Count() > 1) //KKQ split count =1
|
{
|
area = areas[0];
|
index = 1;
|
areas.RemoveAt(0);
|
rows = Array.ConvertAll<string, int>(areas.ToArray(), s => int.Parse(s)).ToList();
|
}
|
else
|
{
|
if (index < 1 && string.IsNullOrEmpty(col))
|
{
|
result.resultCode = 2;
|
result.resultMsg = $"库区列不可为空；";
|
return result;
|
}
|
rows.Add(Convert.ToInt32(col));
|
}
|
//KKQ:1:2:3
|
return ApiHelper.Outgo4(area, rows);
|
}
|
|
|
|
[HttpGet]
|
[Route("GetAREACount")]
|
public SimpleResult GetAREACount(string area, int count)
|
{
|
List<string> strl = new List<string>();
|
IEnumerable<Settings.deviceInfo> Li = from x in Settings.GetDeviceInfoList()
|
where x.deviceType == 8
|
select x;
|
Dictionary<string, int> dic = new Dictionary<string, int>();
|
foreach (Settings.deviceInfo i in Li)
|
{
|
ApiModel.SimpleResult r = ApiHelper.GetAREACount(i.deviceNo[0]);
|
string no = i.deviceNo[0];
|
if (!string.IsNullOrEmpty(Regex.Match(no, "^[1-9]+").Groups[0].Value))
|
{
|
no = "o" + no;
|
}
|
dic.Add(no, r.resultCode);
|
}
|
|
//dic.Add("o1PPMK", 1);
|
//dic.Add("o2PPMK", 2);
|
//dic.Add("o3PPMK", 3);
|
//dic.Add("o4PPMK", 4);
|
//dic.Add("o5PPMK", 5);
|
//dic.Add("o6PPMK", 6);
|
return new ApiModel.SimpleResult
|
{
|
resultCode = 1,
|
result = new List<object>
|
{
|
dic
|
}
|
};
|
//return new SimpleResult { resultCode = strl.Count > 0 ? 1 : 0, resultMsg = strl.Count > 0 ? $"库区大于{count}的库区有" + string.Join(",", strl) : $"暂时没有满框大于{count}的库区！" };
|
}
|
|
|
//{"No":"TN23060665395","State":6}
|
public class classs
|
{
|
public string No; public string State; public string ForkliftNo;
|
}
|
|
[HttpPost]
|
[Route("TestTask")]
|
public ReturnResult TestTask(classs c)
|
{
|
if (string.IsNullOrEmpty(c.No) || string.IsNullOrEmpty(c.State))
|
{
|
return new ReturnResult()
|
{
|
ResultCode = -1,
|
ResultMsg = "参数为空"
|
};
|
}
|
var b = c.State?.Split(';');
|
string msg = c.No + "";
|
foreach (string item in b)
|
{
|
ReturnResult rrr = TaskCore.OperateTaskStatus(new AgvTaskState
|
{
|
No = c.No,
|
State = Convert.ToInt32(item),
|
ForkliftNo = c.ForkliftNo
|
});
|
msg += $"执行任务状态“{item}” {(rrr.ResultCode == 0 ? "成功" : "失败")}！";
|
if (rrr.ResultCode != 0)
|
{
|
rrr.ResultMsg += ":::::" + msg;
|
return rrr;
|
}
|
Thread.Sleep(200);
|
}
|
|
return new ReturnResult();
|
//if (loc != "996")
|
// return loc ?? "222222222";
|
//else throw new System.Exception("Exception");
|
}
|
|
|
|
|
/// <summary>
|
/// 货位绑定 -
|
/// </summary>
|
/// <param name="loc">货位</param>
|
/// <param name="traylayers">层数 2、3</param>
|
/// <param name="type"> 空框， 1234号瓶盖</param>
|
/// <returns></returns>
|
/// <exception cref="System.Exception"></exception>
|
[HttpGet]
|
[Route("BindTrays")]
|
public SimpleResult BindTrays(string loc, int traylayers, string Note)
|
{
|
if (string.IsNullOrEmpty(loc) || !new string[] { "空框", "1号瓶盖", "2号瓶盖", "3号瓶盖", "4号瓶盖" }.Contains(Note) || !new int[] { 2, 3 }.Contains(traylayers))
|
{
|
return new SimpleResult() { resultCode = 2, resultMsg = $"参数不符合！货位：{loc},标识：{Note},层数：{traylayers}" };
|
}
|
var _bindloc = LocationHelper.GetLoc(loc);
|
if (_bindloc == null) return new SimpleResult() { resultCode = 2, resultMsg = "货位不存在。 " };
|
if (_bindloc.S_AREA_CODE != "IWF360" && _bindloc.S_AREA_CODE != "IWT11") return new SimpleResult() { resultCode = 2, resultMsg = "货位库区不是瓶盖大库。 " };
|
if ((_bindloc.N_CURRENT_NUM == 0 && traylayers == 3) || (_bindloc.N_CURRENT_NUM == 3 && traylayers == 2))
|
{
|
LocationHelper.lOCReSetValue(x => x.S_LOC_CODE == _bindloc.S_LOC_CODE, x =>
|
{
|
x.N_CURRENT_NUM = _bindloc.N_CURRENT_NUM + traylayers;
|
x.S_NOTE = Note;
|
});
|
}
|
else if (_bindloc.S_AREA_CODE == "IWT11")
|
{
|
LocationHelper.lOCReSetValue(x => x.S_LOC_CODE == _bindloc.S_LOC_CODE, x =>
|
{
|
x.N_CURRENT_NUM = traylayers;
|
x.S_NOTE = Note;
|
});
|
}
|
else
|
return new SimpleResult() { resultCode = 2, resultMsg = $"托盘数{traylayers} 和货位托盘数{_bindloc.N_CURRENT_NUM} 无法叠筐" };
|
return new SimpleResult() { resultCode = 0, resultMsg = "" };
|
}
|
|
|
/// <summary>
|
/// 报废货位
|
/// </summary>
|
/// <param name="loc"></param
|
/// <param name="all">1/0</param>
|
/// <returns></returns>
|
[HttpGet]
|
[Route("BFloc")]
|
public SimpleResult BFloc(string loc, string all)
|
{
|
if (string.IsNullOrEmpty(loc))
|
{
|
return new SimpleResult() { resultCode = 2, resultMsg = $"参数不符合！货位：{loc}" };
|
}
|
var _bindloc = LocationHelper.GetLoc(loc);
|
if (_bindloc == null) return new SimpleResult() { resultCode = 2, resultMsg = "货位不存在。 " };
|
//if (_bindloc.S_AREA_CODE != "IWF360") return new SimpleResult() { resultCode = 2, resultMsg = "货位库区不是瓶盖大库。 " };
|
if ((_bindloc.S_LOCK_STATE != "无" && _bindloc.S_LOCK_STATE != "空间锁"))
|
return new SimpleResult() { resultCode = 2, resultMsg = $"货位状态{_bindloc.S_LOCK_STATE} 不能报废。 " };
|
else
|
{
|
if (all == "1")
|
{
|
LocationHelper.lOCReSetValue(x => x.S_AREA_CODE == _bindloc.S_AREA_CODE && x.N_ROW == _bindloc.N_ROW, x =>
|
{
|
x.S_LOCK_STATE = "报废";
|
});
|
}
|
else
|
LocationHelper.lOCReSetValue(x => x.S_LOC_CODE == _bindloc.S_LOC_CODE, x =>
|
{
|
x.S_LOCK_STATE = "报废";
|
});
|
}
|
return new SimpleResult() { resultCode = 0, resultMsg = "" };
|
}
|
|
/// <summary>
|
/// 报废货位解除
|
/// </summary>
|
/// <param name="loc"></param>
|
/// <returns></returns>
|
[HttpGet]
|
[Route("unBFloc")]
|
public SimpleResult unBFloc(string loc, string all, string clear)
|
{
|
if (string.IsNullOrEmpty(loc))
|
{
|
return new SimpleResult() { resultCode = 2, resultMsg = $"参数不符合！货位：{loc}" };
|
}
|
var _bindloc = LocationHelper.GetLoc(loc);
|
if (_bindloc == null) return new SimpleResult() { resultCode = 2, resultMsg = "货位不存在。 " };
|
//if (_bindloc.S_AREA_CODE != "IWF360") return new SimpleResult() { resultCode = 2, resultMsg = "货位库区不是瓶盖大库。 " };
|
if (_bindloc.S_LOCK_STATE != "报废" && all != "1" && clear != "1")
|
{
|
return new SimpleResult() { resultCode = 2, resultMsg = $"货位状态{_bindloc.S_LOCK_STATE} 无需解除。 " };
|
}
|
|
{
|
if (all == "1")
|
{
|
LocationHelper.lOCReSetValue(x => x.S_AREA_CODE == _bindloc.S_AREA_CODE && x.N_ROW == _bindloc.N_ROW, x =>
|
{
|
x.S_LOCK_STATE = "无";
|
if (clear == "1")
|
{
|
x.S_NOTE = "";
|
x.N_CURRENT_NUM = 0;
|
x.T_EMPTY_TIME = null;
|
x.T_FULL_TIME = null;
|
}
|
});
|
}
|
else
|
LocationHelper.lOCReSetValue(x => x.S_LOC_CODE == _bindloc.S_LOC_CODE, x =>
|
{
|
x.S_LOCK_STATE = "无";
|
if (clear == "1")
|
{
|
x.S_NOTE = "";
|
x.N_CURRENT_NUM = 0;
|
x.T_EMPTY_TIME = null;
|
x.T_FULL_TIME = null;
|
}
|
});
|
}
|
if (clear == "1")
|
{ //这里清 托盘 -- 上面是清货位数据。
|
if (all == "1")
|
{
|
var loclist = LocationHelper.GetLocList(x => x.S_AREA_CODE == _bindloc.S_AREA_CODE && x.N_ROW == _bindloc.N_ROW)?.Select(x => x.S_LOC_CODE.Trim());
|
LocationHelper.DoAction(db =>
|
{
|
return db.Deleteable<LocCntrRel>().Where(it => loclist.Contains(it.S_LOC_CODE.Trim())).ExecuteCommand() > 0;
|
});
|
}
|
else
|
{
|
LocationHelper.DoAction(db =>
|
{
|
return db.Deleteable<LocCntrRel>().Where(it => it.S_LOC_CODE == _bindloc.S_LOC_CODE).ExecuteCommand() > 0;
|
});
|
}
|
}
|
return new SimpleResult() { resultCode = 0, resultMsg = "" };
|
}
|
|
|
[HttpGet]
|
[Route("Testttt")]
|
public string Testttt(string loc)
|
{
|
if (loc != "996")
|
return loc ?? "222222222";
|
else throw new System.Exception("Exception");
|
}
|
|
[HttpGet]
|
[Route("MeFlux")]
|
public dynamic Mescs()
|
{
|
var apih = new HttpHelper();
|
string token = HttpHelper.GetMd5Hash(Settings.securityKey + "from" + Settings.tokenfrom + "timestamp" + apih._time);
|
|
return new
|
{
|
token = token,
|
from = Settings.tokenfrom,
|
timestamp = apih._time
|
};
|
}
|
|
[HttpPost]
|
[Route("WebPost")]
|
public string WebPost(PostStyle postStyle)
|
{
|
return new HttpHelper().WebPost(postStyle.url, postStyle.postData);
|
}
|
|
/// <summary>
|
///
|
/// </summary>
|
/// <param name="Floc"></param>
|
/// <param name="Tloc"></param>
|
/// <returns></returns>
|
[HttpGet]
|
[Route("TakeP2P")]
|
public SimpleResult TakeP2P(string Floc, string Tloc)
|
{
|
Console.WriteLine($"TakeP2P:::::==>>>>>> floc {Floc} tloc{Tloc}");
|
LogHelper.Info($"floc {Floc} tloc{Tloc}");
|
if (string.IsNullOrEmpty(Floc))
|
Floc = "";
|
|
try
|
{
|
var FlociNFO = LocationHelper.GetLoc(Floc.Trim());
|
var TlociNFO = LocationHelper.GetLoc(Tloc.Trim());
|
|
if (FlociNFO == null || TlociNFO == null)
|
{
|
return SimpleResult.Error($"{(FlociNFO == null ? "起点货位数据为空。" : "")}{(TlociNFO == null ? "终点货位数据为空。" : "")}");
|
}
|
if (FlociNFO.S_LOCK_STATE != "无" || TlociNFO.S_LOCK_STATE != "无")
|
{
|
return SimpleResult.Error($"{(FlociNFO.S_LOCK_STATE != "无" ? $"起点货位状态{FlociNFO.S_LOCK_STATE}。" : "")}{(TlociNFO.S_LOCK_STATE != "无" ? $"起点货位状态{TlociNFO.S_LOCK_STATE}。" : "")}");
|
}
|
|
var B = TaskProcess.CreateTransport("", Floc.Trim(), Tloc.Trim(), "自由点对点转运", new List<string> { "不管控托盘" }, 1, 1, 1, 60);
|
|
LogHelper.Info($"创建自由点对点转运 指定点 {Floc.Trim()}->{Tloc.Trim()}");
|
if (B) return new SimpleResult();
|
return SimpleResult.Error("自由点对点转运 创建成功");
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error(ex.Message, ex);
|
return SimpleResult.Error(ex.Message);
|
}
|
}
|
/// <summary>
|
///
|
/// </summary>
|
/// <param name="Floc"></param>
|
/// <param name="Tloc"></param>
|
/// <returns></returns>
|
[HttpGet]
|
[Route("TakeP2PWithAllCntr")]
|
public SimpleResult TakeP2PWithAllCntr(string Floc, string Tloc)
|
{
|
Console.WriteLine($"TakeP2P:::::==>>>>>> floc {Floc} tloc{Tloc}");
|
LogHelper.Info($"floc {Floc} tloc{Tloc}");
|
if (string.IsNullOrEmpty(Floc))
|
Floc = "";
|
|
try
|
{
|
var FlociNFO = LocationHelper.GetLoc(Floc.Trim());
|
var TlociNFO = LocationHelper.GetLoc(Tloc.Trim());
|
|
if (FlociNFO == null || TlociNFO == null)
|
{
|
return SimpleResult.Error($"{(FlociNFO == null ? "起点货位数据为空。" : "")}{(TlociNFO == null ? "终点货位数据为空。" : "")}");
|
}
|
if (FlociNFO.S_LOCK_STATE != "无" || TlociNFO.S_LOCK_STATE != "无")
|
{
|
return SimpleResult.Error($"{(FlociNFO.S_LOCK_STATE != "无" ? $"起点货位状态{FlociNFO.S_LOCK_STATE}。" : "")}{(TlociNFO.S_LOCK_STATE != "无" ? $"起点货位状态{TlociNFO.S_LOCK_STATE}。" : "")}");
|
}
|
|
if (FlociNFO.N_CURRENT_NUM == 0 || TlociNFO.N_CURRENT_NUM > 0)
|
{
|
return SimpleResult.Error($"{Floc}起点无托盘 或者 {Tloc}终点有托盘。 任务不成立");
|
}
|
var loccntrs = LocationHelper.GetList<LocCntrRel>(x => x.S_LOC_CODE == FlociNFO.S_LOC_CODE);
|
if (loccntrs.Count == 0)
|
{
|
return SimpleResult.Error($"{Floc}起点有数量，但是没有绑定的托盘。");
|
}
|
|
var B = TaskProcess.CreateTransport("", Floc.Trim(), Tloc.Trim(), "带托盘点对点转运", loccntrs.Select(x => x.S_CNTR_CODE).ToList(), 1, 1, 1, 60);
|
|
LogHelper.Info($"创建 带托盘点对点转运 指定点 {Floc.Trim()}->{Tloc.Trim()}");
|
if (B) return new SimpleResult();
|
return SimpleResult.Error("带托盘点对点转运 创建失败");
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error(ex.Message, ex);
|
return SimpleResult.Error(ex.Message);
|
}
|
}
|
|
/// <summary>
|
/// 使用领料做 批量任务
|
/// </summary>
|
/// <param name="Endloc">直接写终点 是 输送线流程。 写 area-2-终点 是提升机流程。</param>
|
/// <param name="item"></param>
|
/// <param name="qty"></param>
|
/// <returns></returns>
|
[HttpPost]
|
[Route("GuoLai")]
|
public SimpleResult GuoLai(dynamic dyc)
|
{
|
LogHelper.Info($"GuoLai 使用领料做 批量任务 {JsonConvert.SerializeObject(dyc)}");
|
string Endloc = dyc.Endloc;
|
string item = dyc.item;
|
int qty = dyc.qty;
|
if (string.IsNullOrEmpty(Endloc) || (string.IsNullOrEmpty(item) && !Endloc.Contains("-2-")) || qty <= 0)
|
return SimpleResult.Error($"有参数为空或，数量不大于0{Endloc},{item},{qty}");
|
var db = new SqlHelper<object>().GetInstance();
|
var alr = db.Queryable<LingItemOrder>().Where(x => x.WorkFromNo == "Auto" && x.DeviceNo == Endloc.Trim() && x.State == "执行").First();
|
if (alr != null)
|
return SimpleResult.Error($"{Endloc} 已经存在执行中的。领料信息。 物料为{alr.ItemCode}");
|
var res = db.Insertable(new LingItemOrder
|
{
|
WorkNo = "LIOauto" + DateTime.Now.ToString("yyMMdd HH:mm"),
|
WorkFromNo = "Auto",
|
ItemCode = item,
|
OutAreaNum = qty + "",
|
DeviceNo = Endloc.Trim(),//// 直接写终点 是 输送线流程。 写 area-2-终点-2-任务类型 是提升机流程。
|
OutCurrentNum = "0",
|
State = "执行"
|
}).ExecuteCommand() > 0;
|
return res ? new SimpleResult() : SimpleResult.Error($"{Endloc}-{item} 创建叫料单据失败！请重来。");
|
}
|
|
[HttpPost]
|
[Route("GuoLaiCancle")]
|
public SimpleResult GuoLaiCancle(string Endloc, string item)
|
{
|
if (string.IsNullOrEmpty(Endloc) || string.IsNullOrEmpty(item))
|
return SimpleResult.Error($"有参数为空或，数量不大于0{Endloc},{item}");
|
var db = new SqlHelper<object>().GetInstance();
|
var alr = db.Queryable<LingItemOrder>().Where(x => x.WorkFromNo == "Auto" && x.DeviceNo == Endloc.Trim() && x.State == "执行").First();
|
if (alr == null)
|
return SimpleResult.Error($"{Endloc} 没有执行中的。领料信息。");
|
alr.State = "取消";
|
var res = db.Updateable(alr).UpdateColumns(it => new { it.State }).ExecuteCommand() > 0;
|
return res ? new SimpleResult() : SimpleResult.Error($"{Endloc} 执行取消叫料单据失败！");
|
}
|
|
[HttpGet]
|
[Route("Ctcp")]
|
public List<string> WebGst()
|
{
|
return TcpServer.clients.Keys.ToList();
|
}
|
|
[HttpGet]
|
[Route("Cdoor")]
|
public string WebGstDoor()
|
{
|
return JsonConvert.SerializeObject(new
|
{
|
clients = TcpServer.clients.Keys.ToList(),
|
doorStatus = DeviceProcess.doorStatus,
|
dsi = Monitor.dsi
|
});
|
return JsonConvert.SerializeObject(DeviceProcess.doorStatus);
|
}
|
|
|
|
[HttpGet]
|
[Route("GetUpu")]
|
public dynamic GetUpu()
|
{
|
Process currentProcess = Process.GetCurrentProcess();
|
string processName = currentProcess.ProcessName;
|
int processId = currentProcess.Id;
|
List<dynamic> data = new List<dynamic>();
|
foreach (ProcessThread thread in currentProcess.Threads)
|
{
|
string counterPath = $"Process({processName})\\Thread({thread.Id})";
|
var counter = new PerformanceCounter("Thread", "% Processor Time", thread.Id.ToString(), processName);
|
float cpuUsage = counter.NextValue();
|
data.Add(new
|
{
|
thread.Id,
|
counter,
|
cpu = $"{cpuUsage:F2}%"
|
});
|
}
|
return data;
|
}
|
|
|
[HttpGet]
|
[Route("CntrSplit")]
|
public SimpleResult CntrSplit()
|
{
|
List<LocCntrRel> lcrl = new List<LocCntrRel>();
|
var db = new SqlHelper<object>().GetInstance();
|
lcrl = db.Queryable<LocCntrRel>().Includes(x => x.CntrItemRel).Where(x => x.S_CNTR_CODE.Length == 48 && x.S_CNTR_CODE.StartsWith("F")).ToList();
|
int si = 0;
|
string msg = "";
|
var gP = lcrl.GroupBy(x => x.S_LOC_CODE);
|
Console.WriteLine($"托盘拆分。 总共{gP.Count()}个货位，{lcrl.Count}个合并的托盘。");
|
foreach (var s in gP)
|
{
|
si++;
|
db.BeginTran();
|
msg = "";
|
try
|
{
|
var loc = db.Queryable<Location>().Where(x => x.S_LOC_CODE == s.Key).First();
|
if (loc == null)
|
continue;
|
else
|
{
|
foreach (LocCntrRel item in s.ToList())
|
{
|
string cntrCode = item.S_CNTR_CODE;
|
|
var lcr = item.Clone();
|
var lcr2 = item.Clone();
|
|
lcr.S_CNTR_CODE = cntrCode.Substring(1, 23);
|
lcr.S_ID = Guid.NewGuid().ToString();
|
|
lcr2.S_CNTR_CODE = cntrCode.Substring(25, 23);
|
lcr2.S_ID = Guid.NewGuid().ToString();
|
|
var cir = item.CntrItemRel.Clone();
|
var cir2 = cir.Clone();
|
|
cir.S_CNTR_CODE = lcr.S_CNTR_CODE;
|
cir.S_ID = lcr.S_ID;
|
|
cir2.S_CNTR_CODE = lcr2.S_CNTR_CODE;
|
cir2.S_ID = lcr2.S_ID;
|
|
db.Insertable(lcr).ExecuteCommand();
|
db.Insertable(lcr2).ExecuteCommand();
|
db.Insertable(cir).ExecuteCommand();
|
db.Insertable(cir2).ExecuteCommand();
|
|
db.Deleteable(item).ExecuteCommand();
|
db.Deleteable(item.CntrItemRel).ExecuteCommand();
|
}
|
//loc.N_CAPACITY *= 2;
|
//loc.N_CURRENT_NUM *= 2;
|
if (loc.N_CURRENT_NUM > 0)
|
{
|
loc.T_EMPTY_TIME = null;
|
db.Updateable(loc).UpdateColumns(it => new { it.T_EMPTY_TIME }).ExecuteCommand();
|
}
|
//db.Updateable(loc).UpdateColumns(it => new { it.N_CAPACITY, it.N_CURRENT_NUM }).ExecuteCommand();
|
}
|
db.CommitTran();
|
Console.WriteLine($"{DateTime.Now.ToShortTimeString()} 提交第{si}个货位{s.Key}拆分数据");
|
}
|
catch (Exception ex)
|
{
|
db.RollbackTran();
|
Console.WriteLine(s.Key + " " + ex.Message);
|
}
|
finally
|
{
|
msg += s.Key;
|
}
|
}
|
|
return SimpleResult.Success(msg);
|
}
|
|
}
|
public class InmiTask
|
{
|
public string StartArea { get; set; }
|
public string EndbitArea { get; set; }
|
public string ItemCode { get; set; }
|
}
|
}
|
