Luy
/
NWeiWMS
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

AGV出入库逻辑调整

master
陆晔 2 years ago
parent
b57fb126cf
commit
1fdf9f31d9
3 changed files with 153 additions and 8 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 12
      ICSSoft.WMS.WebAPI/ICSSoft.DataProject/ICSManufactureService.cs
  2. 147
      ICSSoft.WMS.WebAPI/ICSSoft.DataProject/ICSSubmitService.cs
  3. 2
      ICSSoft.WMS.WebAPI/ICSSoft.DataProject/ICSWareHouseLotInfoService.cs

12
ICSSoft.WMS.WebAPI/ICSSoft.DataProject/ICSManufactureService.cs
View File

@ -557,6 +557,10 @@ namespace ICSSoft.DataProject
ServiceUnBindAgvPod.UnOrBindAgvPodClient client = new ServiceUnBindAgvPod.UnOrBindAgvPodClient();
ServiceUnBindAgvPod.UnBindAgvPodOperationResult agvresult = new ServiceUnBindAgvPod.UnBindAgvPodOperationResult();
agvresult = client.StartCallAgvTask(AGVInfo);
if (agvresult.code == -1 || agvresult.code == 5)
{
throw new Exception(agvresult.message);
}
#endregion
}
else
@ -570,19 +574,23 @@ namespace ICSSoft.DataProject
ServiceCallAgvTask.CallAgvTaskpositionCodePath AGVLineInfo = new ServiceCallAgvTask.CallAgvTaskpositionCodePath();
AGVInfo.reqCode = Year + Month + Day + Hour + Minute + Second;
AGVInfo.podCode = ContainerCode;
AGVInfo.taskTyp = "F02";
AGVInfo.taskTyp = "A01";
AGVLineInfo.positionCode = chkdt.Rows[0]["Desks"].ToString();
AGVLineInfo.type = "00";
AGVLineList.Add(AGVLineInfo);
AGVLineInfo = new ServiceCallAgvTask.CallAgvTaskpositionCodePath();
AGVLineInfo.positionCode = areadt.Rows[0]["F_Define1"].ToString();//空料架区位置编码待提供
AGVLineInfo.type = "04";
AGVLineInfo.type = "02";
AGVLineList.Add(AGVLineInfo);
AGVInfo.positionCodePath = AGVLineList.ToArray();
ServiceCallAgvTask.CallAgvTaskOperationResult agvresult = new ServiceCallAgvTask.CallAgvTaskOperationResult();
ServiceCallAgvTask.StartAgvTaskClient client = new ServiceCallAgvTask.StartAgvTaskClient();
agvresult = client.StartCallAgvTask(AGVInfo);
if (agvresult.code == -1 || agvresult.code == 5)
{
throw new Exception(agvresult.message);
}
#endregion
}
}

147
ICSSoft.WMS.WebAPI/ICSSoft.DataProject/ICSSubmitService.cs
View File

@ -7606,16 +7606,36 @@ WHERE WorkPoint='{0}' AND Quantity>ISNULL(TransferQuantity, 0) order by Transfer
}
else
{
if (JsonData.taskCode.Contains("CK"))
string chksql = @"select EATTRIBUTE1 from ICSAGVTaskLog
where ID='{0}'";
chksql = string.Format(chksql, JsonData.taskCode);
DataTable chkdt = DBHelper.SQlReturnData(chksql, cmd);
if (chkdt.Rows.Count == 0)
{
logsql = @"update ICSAGVTaskLog set MTIME=GETDATE(),EATTRIBUTE2='已完成',EATTRIBUTE3='{1}'
WHERE TaskCode='{0}'";
logsql = string.Format(logsql, JsonData.taskCode, JsonData.taskCode);
#region 更新AGV回调日志
logsql = @"update ICSAGVCallBackLog set Result='失败',Message='{1}'
where ReqCode='{0}'";
logsql = string.Format(logsql, JsonData.taskCode, "传入TaskCode不存在！");
DBHelper.ExecuteNonQuery(connString, CommandType.Text, logsql);
#endregion
res.code = "1";
res.message = "传入TaskCode不存在！";// "接口调用失败！";
res.reqCode = JsonData.reqCode;
return res;
}
else
{
ICSWareHouseLotInfoService.ActionAGVTaskEnd(JsonData.taskCode, JsonData.currentPositionCode, JsonData.taskCode, JsonData.action, JsonData.podCode, cmd, language);
if (chkdt.Rows[0]["EATTRIBUTE1"].ToString()=="出库")
{
logsql = @"update ICSAGVTaskLog set MTIME=GETDATE(),EATTRIBUTE2='已完成',EATTRIBUTE3='{1}'
WHERE ID='{0}'";
logsql = string.Format(logsql, JsonData.taskCode, JsonData.currentPositionCode);
DBHelper.ExecuteNonQuery(connString, CommandType.Text, logsql);
}
else
{
ICSWareHouseLotInfoService.ActionAGVTaskEnd(JsonData.taskCode, JsonData.currentPositionCode, JsonData.taskCode, JsonData.action, JsonData.podCode, cmd, language);
}
}
}
cmd.Transaction.Commit();
@ -8846,6 +8866,123 @@ WHERE WorkPoint='{0}' AND Quantity>ISNULL(TransferQuantity, 0) order by Transfer
}
#endregion
#region 调用AGV搬运任务失败后调用，用于删除入库时的库位占用
public static AGVResult AGVTaskEnd(AGVCallBackModel JsonData, string Jsonstr)
{
var language = LanguageHelper.GetName("WMSAPIInfo");
DataTable table = new DataTable();
string msg = "";
using (SqlConnection conn = new System.Data.SqlClient.SqlConnection(connString))
{
conn.Open();
SqlCommand cmd = new SqlCommand();
cmd.Connection = conn;
SqlTransaction sqlTran = conn.BeginTransaction();
cmd.Transaction = sqlTran;
try
{
#region 记录AGV回调日志
string logsql = @"INSERT INTO ICSAGVCallBackLog
(ID,ReqCode,InputJSON,Result,Message,EATTRIBUTE1)
SELECT NEWID(),'{0}','{1}','','',GETDATE()";
logsql = string.Format(logsql, JsonData.taskCode, Jsonstr);
DBHelper.ExecuteNonQuery(connString, CommandType.Text, logsql);
#endregion
AGVResult res = new AGVResult();
if (string.IsNullOrEmpty(JsonData.taskCode))
{
msg = "传入AGV任务ID不能为空!";
}
if (string.IsNullOrEmpty(JsonData.podCode))
{
msg = "传入料架不能为空!";
}
if (string.IsNullOrEmpty(JsonData.currentPositionCode))
{
msg = "传入入库具体点位不能为空!";
}
if (msg != "")
{
#region 更新AGV回调日志
logsql = @"update ICSAGVCallBackLog set Result='失败',Message='{1}'
where ReqCode='{0}'";
logsql = string.Format(logsql, JsonData.taskCode, msg);
DBHelper.ExecuteNonQuery(connString, CommandType.Text, logsql);
#endregion
res.code = "1";
res.message = msg;// "接口调用失败！";
res.reqCode = JsonData.reqCode;
return res;
}
else
{
string chksql = @"select EATTRIBUTE1 from ICSAGVTaskLog
where ID='{0}'";
chksql = string.Format(chksql, JsonData.taskCode);
DataTable chkdt = DBHelper.SQlReturnData(chksql, cmd);
if (chkdt.Rows.Count == 0)
{
#region 更新AGV回调日志
logsql = @"update ICSAGVCallBackLog set Result='失败',Message='{1}'
where ReqCode='{0}'";
logsql = string.Format(logsql, JsonData.taskCode, "传入TaskCode不存在！");
DBHelper.ExecuteNonQuery(connString, CommandType.Text, logsql);
#endregion
res.code = "1";
res.message = "传入TaskCode不存在！";// "接口调用失败！";
res.reqCode = JsonData.reqCode;
return res;
}
else
{
if (chkdt.Rows[0]["EATTRIBUTE1"].ToString() == "出库")
{
logsql = @"update ICSAGVTaskLog set MTIME=GETDATE(),EATTRIBUTE2='已完成',EATTRIBUTE3='{1}'
WHERE ID='{0}'";
logsql = string.Format(logsql, JsonData.taskCode, JsonData.currentPositionCode);
DBHelper.ExecuteNonQuery(connString, CommandType.Text, logsql);
}
else
{
ICSWareHouseLotInfoService.ActionAGVTaskEnd(JsonData.taskCode, JsonData.currentPositionCode, JsonData.taskCode, JsonData.action, JsonData.podCode, cmd, language);
}
}
}
cmd.Transaction.Commit();
res.code = "0";
res.message = "成功";// "接口调用成功！";
res.reqCode = JsonData.reqCode;
return res;
}
catch (Exception ex)
{
#region 更新AGV回调日志
string logsql = @"update ICSAGVCallBackLog set Result='失败',Message='{1}'
where ReqCode='{0}'";
logsql = string.Format(logsql, JsonData.reqCode, ex.Message);
DBHelper.ExecuteNonQuery(connString, CommandType.Text, logsql);
#endregion
if (cmd.Transaction != null)
cmd.Transaction.Rollback();
log.Error(ex.Message);
AGVResult res = new AGVResult();
res.code = "1";
res.message = ex.Message;// "接口调用失败！";
res.reqCode = JsonData.reqCode;
return res;
}
finally
{
if (conn.State == ConnectionState.Open)
{
conn.Close();
}
conn.Dispose();
}
}
}
#endregion
#region 临时接口（用于单独过账SAP接口 不经过WMS）
/// <summary>
/// 临时接口（用于单独过账SAP接口 不经过WMS）

2
ICSSoft.WMS.WebAPI/ICSSoft.DataProject/ICSWareHouseLotInfoService.cs
View File

@ -3300,7 +3300,7 @@ namespace ICSSoft.DataProject
sql = @"select TOP 1 A.LocationCode,A.StockInArea from ICSLocation A
LEFT JOIN ICSWareHouseLotInfo B ON B.LocationCode=A.LocationCode AND B.WorkPoint=A.WorkPoint AND ISNULL(B.Quantity,0)>0
where B.LocationCode IS NULL AND A.LocationCode like ('{0}'+'-'+'{1}%') AND ISNULL(A.EATTRIBUTE1,'')!=''
AND A.LocationCode NOT IN ({2}) AND ISNULL(A.Isoccupy,'')=''
AND A.EATTRIBUTE1 NOT IN ({2}) AND ISNULL(A.Isoccupy,'')=''
ORDER BY A.LocationCode";
sql = string.Format(sql, InWHCode, InLocationCode, LocationIsTaken);
dt = DBHelper.SQlReturnData(sql, cmd);

Write Preview
Loading…
Cancel
Save