using System;
|
using System.Collections;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Data.SqlTypes;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using Commom.Utility;
|
using Common;
|
//using Microsoft.Build.Utilities;
|
using Model;
|
using Model.WcsModel;
|
using Newtonsoft.Json;
|
using NLog;
|
using NPOI.SS.Formula.Functions;
|
using NPOI.SS.UserModel;
|
using static NPOI.HSSF.Util.HSSFColor;
|
|
namespace BLL.DAL
|
{
|
public class DAL_TaskMonitor
|
{
|
/// <summary>
|
/// 获取任务控制信息
|
/// </summary>
|
/// <param name="Json"></param>
|
/// <param name="pageInfo"></param>
|
/// <returns></returns>
|
public IList<WCSTasks> GetList(AjaxGetTaskList Json, ref PageInfo pageInfo)
|
{
|
try
|
{
|
StringBuilder strSql = new StringBuilder();
|
List<SqlParam> para = new List<SqlParam>();
|
|
// 0 未下发 1 已下发 2 ？ 3已完成
|
strSql.Append("select Id,TaskNo,CASE Type when '0' then '入库' when '1' then '出库' when '2' then '移库' else Type end as Type,");
|
strSql.Append("Status,IsSuccess,Information,Origin,SyncWms,StartLocat,EndLocat as EndLocate,PalletNo,TopTime,CancelDate,Levels,FinishDate,CreateTime,Demo ");
|
strSql.Append(" from WCSTasks where IsDel = '0' ");
|
|
|
if (!string.IsNullOrWhiteSpace(Json.TaskNo))
|
{
|
strSql.Append(" and TaskNo like '%" + Json.TaskNo + "%' ");
|
}
|
if (!string.IsNullOrWhiteSpace(Json.TaskType))
|
{
|
strSql.Append(" and Type = '" + Json.TaskType + "' ");
|
}
|
if (!string.IsNullOrWhiteSpace(Json.Origin))
|
{
|
strSql.Append(" and Origin = '" + Json.Origin + "' ");
|
}
|
if (!string.IsNullOrWhiteSpace(Json.SyncWms))
|
{
|
strSql.Append(" and SyncWms = '" + Json.SyncWms + "' ");
|
}
|
if (!string.IsNullOrWhiteSpace(Json.Status))
|
{
|
strSql.Append(" and Status = '" + Json.Status + "' ");
|
}
|
if (!string.IsNullOrWhiteSpace(Json.StartLocat))
|
{
|
strSql.Append(" and StartLocat like '%" + Json.StartLocat + "%' ");
|
}
|
if (!string.IsNullOrWhiteSpace(Json.PalletNo))
|
{
|
strSql.Append(" and PalletNo like '%" + Json.PalletNo + "%' ");
|
}
|
if (!string.IsNullOrWhiteSpace(Json.EndLocat))
|
{
|
strSql.Append(" and EndLocat like '%" + Json.EndLocat + "%' ");
|
}
|
//strSql.Append(" order by Levels,Status ");
|
|
SqlParam[] param = null;
|
if (para != null)
|
{
|
param = para.ToArray();
|
}
|
|
DataTable dt = DataFactory.SqlDataBase().GetPageList(strSql.ToString(), param, "Levels,TopTime desc,StartLocat asc,ISNULL(FinishDate,GETDATE())", "desc", ref pageInfo);
|
return ModelConvertHelper<WCSTasks>.DataTableToModel(dt);
|
}
|
catch
|
{
|
throw new NotImplementedException();
|
}
|
}
|
|
/// <summary>
|
/// 获取任务控制信息明细
|
/// </summary>
|
/// <param name="Json"></param>
|
/// <param name="pageInfo"></param>
|
/// <returns></returns>
|
public IList<WCSTasksMonitor> GetDetailList(AjaxGetTaskDetailList Json, ref PageInfo pageInfo)
|
{
|
try
|
{
|
StringBuilder strSql = new StringBuilder();
|
List<SqlParam> para = new List<SqlParam>();
|
|
//
|
strSql.Append("select Id,TaskNo,PlcId,PlcName,StartLocat,EndLocat,InteractiveMsg,ErrorMsg,IsDel,CreateTime,CreateUser,UpdateTime,UpdateUser from WCSTasksMonitor where IsDel = '0' ");
|
if (!string.IsNullOrWhiteSpace(Json.TaskNo))
|
{
|
strSql.Append(" and TaskNo = '" + Json.TaskNo + "' ");
|
}
|
DataTable dt = DataFactory.SqlDataBase().GetPageList(strSql.ToString(), null, "CreateTime", "desc", ref pageInfo);
|
return ModelConvertHelper<WCSTasksMonitor>.DataTableToModel(dt);
|
}
|
catch
|
{
|
throw new NotImplementedException();
|
}
|
}
|
|
|
/// <summary>
|
/// 手动添加任务 liudl Del 20231026
|
/// </summary>
|
/// <param name="model"></param>
|
/// <param name="loginUser"></param>
|
/// <returns></returns>
|
public bool Add(TaskMonitorModel model, string loginUser)
|
{
|
bool result = false;
|
try
|
{
|
Hashtable ht = new Hashtable();
|
|
ht["TaskType"] = model.TaskType.AddQuotes();
|
ht["InitialAddre"] = "'" + model.InitialAddre + "'";
|
ht["Palno"] = "'" + model.Palno + "'";
|
ht["TargetAddre"] = "'" + model.TargetAddre + "'";
|
ht["State"] = "'0'";
|
ht["IsSucceed"] = "'" + model.IsSucceed + "'";
|
ht["ErrorStr"] = "'" + model.ErrorStr + "'";
|
ht["PriorityLevel"] = model.PriorityLevel;
|
ht["Source"] = "'手动'";
|
ht["Demo"] = "'" + model.Demo + "'";
|
ht["Levels"] = "'0'";
|
|
ht["CreateUser"] = "'" + loginUser + "'";
|
ht["CreateTime"] = "Getdate()";
|
|
|
int _ret = DataFactory.SqlDataBase().InsertByHashtableNullParam("TaskMonitor", ht);
|
|
if (_ret == 1) result = true;
|
|
return result;
|
|
}
|
catch
|
{
|
return result;
|
}
|
}
|
|
/// <summary>
|
/// 手动添加任务
|
/// </summary>
|
/// <param name="models"></param>
|
/// <param name="loginName">登录人</param>
|
/// <returns></returns>
|
public bool AddTask(WCSTasks models, string loginName)
|
{
|
bool result = false;
|
int upt = 0;
|
try
|
{
|
StringBuilder sqlString = new StringBuilder();
|
DALWcsMessage wcsEdit = new DALWcsMessage();
|
|
sqlString.Clear();
|
// 验证任务是否已存在
|
sqlString.Append($"select count(Id) from WCSTasks where PalletNo = '{models.PalletNo}' adn (Status = '0' or Status = '1') ;");
|
DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
|
if (dt != null)
|
{
|
if (dt.Rows[0][0].ToString() != "0")
|
{
|
throw new Exception("等待或正在执行任务中托盘号:" + models.PalletNo + ";已存在!");
|
}
|
}
|
|
models.TaskNo = GetTaskNo();
|
string strry = "";
|
if (models.Type == "0" || models.Type == "2")//0入 1出 2移
|
{
|
sqlString.Clear();
|
//验证目标位置是否可用
|
sqlString.Append($"select * from WCSStorageLocat where IsDel = '0' and LocatNo = '{models.EndLocate}' and Status = '0'");
|
dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
|
if (dt == null || dt.Rows.Count == 0)
|
{
|
throw new Exception("目标位置不是空储位 不可入库或移库");
|
}
|
|
models.Levels = "1.5";
|
|
#region 目标巷道
|
|
var str = int.Parse(models.EndLocate.Substring(0, 2));
|
if (str == 1 || str == 2)
|
{
|
models.EndRoadway = "R01";
|
}
|
else if (str == 3 || str == 4)
|
{
|
models.EndRoadway = "R02";
|
}
|
else if (str == 5 || str == 6)
|
{
|
models.EndRoadway = "R03";
|
}
|
else if (str == 7 || str == 8)
|
{
|
models.EndRoadway = "R04";
|
}
|
else if (str == 9 || str == 10)
|
{
|
models.EndRoadway = "R05";
|
}
|
else if (str == 11 || str == 12)
|
{
|
models.EndRoadway = "R06";
|
}
|
else if (str == 13 || str == 14)
|
{
|
models.EndRoadway = "R07";
|
}
|
|
#endregion
|
}
|
if (models.Type == "1" || models.Type == "2")
|
{
|
sqlString.Clear();
|
//验证起始位置是否可用
|
sqlString.Append($"select * from WCSStorageLocat where IsDel = '0' and LocatNo = '{models.StartLocate}' and Status = '1'");
|
dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
|
if (dt == null || dt.Rows.Count == 0)
|
{
|
throw new Exception("起始位置不是有物品 不可出库或移库");
|
}
|
|
models.Levels = "2";
|
|
#region 起始巷道
|
|
var str = int.Parse(models.StartLocate.Substring(0, 2));
|
if (str == 1 || str == 2)
|
{
|
models.StartRoadway = "R01";
|
}
|
else if (str == 3 || str == 4)
|
{
|
models.StartRoadway = "R02";
|
}
|
else if (str == 5 || str == 6)
|
{
|
models.StartRoadway = "R03";
|
}
|
else if (str == 7 || str == 8)
|
{
|
models.StartRoadway = "R04";
|
}
|
else if (str == 9 || str == 10)
|
{
|
models.StartRoadway = "R05";
|
}
|
else if (str == 11 || str == 12)
|
{
|
models.StartRoadway = "R06";
|
}
|
else if (str == 13 || str == 14)
|
{
|
models.StartRoadway = "R07";
|
}
|
|
#endregion
|
}
|
|
if (models.Type == "0" || models.Type == "2")
|
{
|
//验证目标储位是否为空
|
if (!string.IsNullOrEmpty(models.EndLocate))
|
{
|
strry = IsLocatTrue(models.Type, models.EndLocate, "目标位置", loginName);
|
}
|
}
|
if (models.Type == "1" || models.Type == "2")
|
{
|
//验证起始储位是否为空
|
if (!string.IsNullOrEmpty(models.StartLocat))
|
{
|
strry = IsLocatTrue(models.Type, models.StartLocat, "起始位置", loginName);
|
}
|
}
|
|
if (!string.IsNullOrEmpty(strry))
|
{
|
throw new Exception(strry);
|
}
|
|
//修改储位状态
|
switch (models.Type)
|
{
|
case "0": //入库
|
wcsEdit.EditLocaetStatus("0", "0", "", models.EndLocate);
|
break;
|
case "1": //出库
|
wcsEdit.EditLocaetStatus("1", "0", models.StartLocat, "");
|
break;
|
case "2": //移库
|
wcsEdit.EditLocaetStatus("2", "0", models.StartLocat, models.EndLocate);
|
break;
|
default:
|
break;
|
}
|
|
WcsBoxInfo box = new WcsBoxInfo();
|
if (models.Type == "0")
|
{
|
//获取对应箱码信息
|
sqlString.Clear();
|
sqlString.Append($"select top 1 * from WCSBoxInfo where IsDel = '0' and PalletNo = '{models.PalletNo}' order by Id desc");
|
DataTable boxtable = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
|
if (boxtable.Rows.Count > 0)
|
{
|
box = (WcsBoxInfo)DataTableHelper.DataTableToIList<BoxInfo>(boxtable); //转换集合
|
}
|
}
|
|
// 新增任务
|
sqlString.Clear();
|
sqlString.Append("INSERT INTO WCSTasks (TaskNo,Type,Status,Origin,StartRoadway,StartLocat,EndLocat,EndRoadway,PalletNo,");
|
sqlString.Append("LotNo,SupplierLot,SkuNo,SkuName,Qty,IsSuccess,SyncWms,Demo,Levels,CreateUser,PalletType) VALUES (");
|
sqlString.Append($"'{models.TaskNo}','{models.Type}','0','{models.Origin}','{models.StartRoadway}','{models.StartLocate}',");
|
sqlString.Append($"'{models.EndLocate}','{models.EndRoadway}','{models.PalletNo}','{box.LotNo}','{models.SupplierLot}',");
|
sqlString.Append($"'{box.SkuNo}','{box.SkuName}','{models.Qty}','0','0','','{models.Levels}','{loginName}','0');");
|
var num = DataFactory.SqlDataBase().ExecuteBySql(sqlString);
|
|
if (num == 1)
|
{
|
DAL_OperationRecord oper = new DAL_OperationRecord();
|
var operation = new OperationModel()
|
{
|
MenuName = "任务管理",
|
FkNo = models.TaskNo + "-" + models.PalletNo,
|
Msg = "新增任务信息",
|
Type = "新增",
|
};
|
oper.AddOperation(operation, loginName);
|
result = true;
|
}
|
|
return result;
|
}
|
catch (Exception e)
|
{
|
throw new Exception(e.Message);
|
}
|
}
|
|
/// <summary>
|
/// 编辑备注
|
/// </summary>
|
/// <param name="models"></param>
|
/// <param name="loginName">登录人</param>
|
/// <returns></returns>
|
public bool UpdateTaskDemo(WCSTasks models, string loginName)
|
{
|
bool result = false;
|
try
|
{
|
StringBuilder sqlString = new StringBuilder();
|
// 编辑任务备注
|
sqlString.Append($"Update WCSTasks set Demo = '{models.Demo}',UpdateUser = '{loginName}',UpdateTime = '{DateTime.Now}' where TaskNo = '{models.TaskNo}' ");
|
var num = DataFactory.SqlDataBase().ExecuteBySql(sqlString);
|
|
if (num == 1)
|
{
|
DAL_OperationRecord oper = new DAL_OperationRecord();
|
var operation = new OperationModel()
|
{
|
MenuName = "任务管理",
|
FkNo = models.TaskNo + "-" + models.PalletNo,
|
Msg = "编辑任务备注",
|
Type = "编辑",
|
};
|
oper.AddOperation(operation, loginName);
|
result = true;
|
}
|
|
return result;
|
}
|
catch (Exception e)
|
{
|
throw new Exception(e.Message);
|
}
|
}
|
|
/// <summary>
|
/// 手动完成任务
|
/// </summary>
|
/// <param name="Id"></param>
|
/// <param name="loginName"></param>
|
/// <returns></returns>
|
public bool TaskMonitorComplete(string[] Id, string loginName, bool tuoji)
|
{
|
DALWcsMessage wcsEdit = new DALWcsMessage();
|
bool result = false;
|
try
|
{
|
int dt = DataFactory.SqlDataBase().IsExist("WCSTasks", "Id", Id);
|
if (dt >= Id.Length)
|
{
|
int i = 0;
|
while (i < Id.Length)
|
{
|
StringBuilder sql = new StringBuilder();
|
// 获取当前任务详细信息
|
sql.Append($"select * from WCSTasks where Id = '{Id[i]}';");
|
DataTable monitorDt = DataFactory.SqlDataBase().GetDataTableBySQL(sql);
|
if (monitorDt != null && monitorDt.Rows.Count > 0)
|
{
|
if (monitorDt.Rows[0]["Status"].ToString() != "1")
|
{
|
i++;
|
continue;
|
}
|
|
// 回传WMS任务完成
|
if (tuoji)
|
{
|
var wcsSql = new DALWcsMessage();
|
if (monitorDt.Rows[0]["Origin"].ToString() == "WMS") // WMS下发的任务
|
{
|
var task = new TaskReques
|
{
|
taskNo = monitorDt.Rows[0]["TaskNo"].ToString(),
|
PalletNo = monitorDt.Rows[0]["PalletNo"].ToString(),
|
TaskType = monitorDt.Rows[0]["Type"].ToString(),
|
TaskStatus = "2",
|
};
|
|
wcsSql.RequestTasks(task);
|
}
|
|
}
|
|
|
//修改储位状态
|
switch (monitorDt.Rows[0]["Type"].ToString())
|
{
|
case "0": //入库
|
wcsEdit.EditLocaetStatus("0", "2", "", monitorDt.Rows[0]["EndLocat"].ToString());
|
break;
|
case "1": //出库
|
wcsEdit.EditLocaetStatus("1", "2", monitorDt.Rows[0]["StartLocat"].ToString(), "");
|
break;
|
case "2": //移库
|
wcsEdit.EditLocaetStatus("2", "2", monitorDt.Rows[0]["StartLocat"].ToString(), monitorDt.Rows[0]["EndLocat"].ToString());
|
break;
|
default:
|
break;
|
}
|
|
sql.Clear();
|
|
// 修改任务状态
|
sql.Append($"update WCSTasks set Status=2,FinishDate = getdate() where Id='{Id[i]}';");
|
int _ret = DataFactory.SqlDataBase().ExecuteBySql(sql);
|
if (_ret >= 1)
|
{
|
DAL_OperationRecord oper = new DAL_OperationRecord();
|
var operation = new OperationModel()
|
{
|
MenuName = "任务管理",
|
FkNo = monitorDt.Rows[0]["TaskNo"].ToString() + "-" + monitorDt.Rows[0]["PalletNo"].ToString(),
|
Msg = "手动完成任务信息",
|
Type = "完成",
|
};
|
oper.AddOperation(operation, loginName);
|
result = true;
|
}
|
}
|
i++;
|
}
|
|
}
|
return result;
|
}
|
catch
|
{
|
return result;
|
}
|
}
|
|
/// <summary>
|
/// 取消任务
|
/// </summary>
|
/// <param name="Id"></param>
|
/// <param name="loginName"></param>
|
/// <returns></returns>
|
public bool TaskMonitorCancel(string[] Id, string loginName)
|
{
|
DALWcsMessage wcsEdit = new DALWcsMessage();
|
bool result = false;
|
try
|
{
|
int dt = DataFactory.SqlDataBase().IsExist("WCSTasks", "Id", Id);
|
if (dt >= Id.Length)
|
{
|
int i = 0;
|
while (i < Id.Length)
|
{
|
StringBuilder sql = new StringBuilder();
|
// 获取当前任务详细信息
|
sql.Append($"select * from WCSTasks where Id = '{Id[i]}';");
|
DataTable monitorDt = DataFactory.SqlDataBase().GetDataTableBySQL(sql);
|
if (monitorDt != null && monitorDt.Rows.Count > 0)
|
{
|
if (monitorDt.Rows[0]["Status"].ToString() != "0")
|
{
|
i++;
|
continue;
|
}
|
// 完成上架任务
|
var wcsSql = new DALWcsMessage();
|
if (monitorDt.Rows[0]["Origin"].ToString() == "WMS")
|
{
|
var task = new TaskReques
|
{
|
taskNo = monitorDt.Rows[0]["TaskNo"].ToString(),
|
PalletNo = monitorDt.Rows[0]["PalletNo"].ToString(),
|
TaskType = monitorDt.Rows[0]["Type"].ToString(),
|
TaskStatus = "4",
|
};
|
|
wcsSql.RequestTasks(task);
|
}
|
|
//修改储位状态
|
switch (monitorDt.Rows[0]["Type"].ToString())
|
{
|
case "0": //入库
|
wcsEdit.EditLocaetStatus("0", "2", "", monitorDt.Rows[0]["EndLocat"].ToString());
|
break;
|
case "1": //出库
|
wcsEdit.EditLocaetStatus("1", "2", monitorDt.Rows[0]["StartLocat"].ToString(), "");
|
break;
|
case "2": //移库
|
wcsEdit.EditLocaetStatus("2", "2", monitorDt.Rows[0]["StartLocat"].ToString(), monitorDt.Rows[0]["EndLocat"].ToString());
|
break;
|
default:
|
break;
|
}
|
|
|
sql.Clear();
|
// 修改任务状态
|
sql.Append("update WCSTasks set Status = 4,CancelDate=getdate() where Id='" + Id[i] + "'");
|
int _ret = DataFactory.SqlDataBase().ExecuteBySql(sql);
|
if (_ret >= 1)
|
{
|
DAL_OperationRecord oper = new DAL_OperationRecord();
|
var operation = new OperationModel()
|
{
|
MenuName = "任务管理",
|
FkNo = monitorDt.Rows[0]["TaskNo"].ToString() + "-" + monitorDt.Rows[0]["PalletNo"].ToString(),
|
Msg = "手动取消任务信息",
|
Type = "取消",
|
};
|
oper.AddOperation(operation, loginName);
|
result = true;
|
}
|
}
|
|
i++;
|
|
}
|
|
}
|
return result;
|
|
}
|
catch
|
{
|
return result;
|
}
|
}
|
|
/// <summary>
|
/// 手动再次回传WMS
|
/// </summary>
|
/// <param name="Id">任务ID集合</param>
|
/// <param name="loginName"></param>
|
/// <returns></returns>
|
public bool TaskMonitorBackhaul(string[] Id, string loginName)
|
{
|
bool result = false;
|
try
|
{
|
int dt = DataFactory.SqlDataBase().IsExist("WCSTasks", "Id", Id);
|
if (dt >= Id.Length)
|
{
|
int i = 0;
|
while (i < Id.Length)
|
{
|
StringBuilder sql = new StringBuilder();
|
// 获取当前任务详细信息
|
sql.Append($"select * from WCSTasks where Id = '{Id[i]}' and IsSuccess = '1';");
|
DataTable monitorDt = DataFactory.SqlDataBase().GetDataTableBySQL(sql);
|
if (monitorDt != null && monitorDt.Rows.Count > 0)
|
{
|
string taskStatus = monitorDt.Rows[0]["Status"].ToString();
|
if (taskStatus == "0" || taskStatus == "1" || taskStatus == "4")
|
{
|
i++;
|
continue;
|
}
|
DAL_OperationRecord oper = new DAL_OperationRecord();
|
var operation = new OperationModel()
|
{
|
MenuName = "任务管理",
|
FkNo = monitorDt.Rows[0]["TaskNo"].ToString() + "-" + monitorDt.Rows[0]["PalletNo"].ToString(),
|
Msg = "手动回传任务信息",
|
Type = "回传",
|
};
|
oper.AddOperation(operation, loginName);
|
// 完成上架任务
|
var wcsSql = new DALWcsMessage();
|
if (monitorDt.Rows[0]["Origin"].ToString() == "WMS")
|
{
|
var task = new TaskReques
|
{
|
taskNo = monitorDt.Rows[0]["TaskNo"].ToString(),
|
PalletNo = monitorDt.Rows[0]["PalletNo"].ToString(),
|
TaskType = monitorDt.Rows[0]["Type"].ToString(),
|
TaskStatus = monitorDt.Rows[0]["Status"].ToString(), // 获取再次
|
};
|
|
result = wcsSql.RequestTasks(task);
|
}
|
}
|
|
i++;
|
|
}
|
|
}
|
return result;
|
|
}
|
catch
|
{
|
return result;
|
}
|
}
|
|
/// <summary>
|
/// 同步WMS
|
/// </summary>
|
/// <param name="Id">任务ID集合</param>
|
/// <param name="loginName"></param>
|
/// <param name="tuoji"></param>
|
/// <returns></returns>
|
public bool TaskMonitorBackhaul1(string[] Id, string loginName, bool tuoji)
|
{
|
NLog.Logger logger = LogManager.GetCurrentClassLogger();
|
bool result = false;
|
try
|
{
|
if (tuoji == false)
|
{
|
throw new Exception("WMS系统已脱机，请恢复后点击！");
|
}
|
|
int dt = DataFactory.SqlDataBase().IsExist("WCSTasks", "Id", Id);
|
if (dt >= Id.Length)
|
{
|
int i = 0;
|
while (i < Id.Length)
|
{
|
string returnStr = "";
|
StringBuilder sql = new StringBuilder();
|
// 获取当前任务详细信息
|
sql.Append($"select * from WCSTasks where Id = '{Id[i]}';");
|
DataTable monitorDt = DataFactory.SqlDataBase().GetDataTableBySQL(sql);
|
|
if (monitorDt != null && monitorDt.Rows.Count > 0)
|
{
|
//根据当前任务获取同托盘是否存在之前未同步任务
|
sql.Clear();
|
sql.Append($"select * from WCSTasks where PalletNo = '{monitorDt.Rows[0]["PalletNo"].ToString()}' and SyncWms = '0' and Id != '{Id[i]}' order by CreateTime;");
|
DataTable palletTasks = DataFactory.SqlDataBase().GetDataTableBySQL(sql);
|
if (palletTasks != null && palletTasks.Rows.Count > 0)
|
{
|
for (int a = 0; a < palletTasks.Rows.Count; a++)
|
{
|
//判断当前同步任务的时间是否早于其它同托盘任务时间
|
if (Convert.ToDateTime(palletTasks.Rows[a]["CreateTime"]) < Convert.ToDateTime(monitorDt.Rows[0]["CreateTime"]))
|
{
|
throw new Exception("请按照时间进行依次同步！");
|
}
|
}
|
}
|
|
string taskStatus = monitorDt.Rows[0]["Status"].ToString();
|
if (taskStatus != "2")
|
{
|
i++;
|
continue;
|
}
|
#region 调用wms接口
|
//获取当前托盘箱码
|
List<BoxInfo> boxList = new List<BoxInfo>();
|
|
//根据任务的托盘、批次与物料进行获取箱码信息
|
sql.Clear();
|
sql.Append($"select * from WCSBoxInfo where IsDel = '0' and PalletNo = '{monitorDt.Rows[0]["PalletNo"].ToString()}' and LotNo = '{monitorDt.Rows[0]["LotNo"].ToString()}' and SkuNo = '{monitorDt.Rows[0]["SkuNo"].ToString()}'");
|
DataTable boxDt = DataFactory.SqlDataBase().GetDataTableBySQL(sql);
|
|
|
if (boxDt.Rows.Count > 0)
|
{
|
|
boxList = (List<BoxInfo>)DataTableHelper.DataTableToIList<BoxInfo>(boxDt); //转换集合
|
}
|
|
|
WmsTaskModel model = new WmsTaskModel()
|
{
|
TaskNo = monitorDt.Rows[0]["TaskNo"].ToString(), //任务号
|
Type = monitorDt.Rows[0]["Type"].ToString(), //任务类型
|
StartLocat = monitorDt.Rows[0]["StartLocat"].ToString(), //起始位置
|
EndLocat = monitorDt.Rows[0]["EndLocat"].ToString(), //目标位置
|
PalletNo = monitorDt.Rows[0]["PalletNo"].ToString(), //托盘编码
|
FinishDate = Convert.ToDateTime(monitorDt.Rows[0]["FinishDate"]), //完成时间
|
WCSName = loginName, //操作人
|
|
SkuNo = monitorDt.Rows[0]["SkuNo"].ToString(), //物料编码
|
SkuName = monitorDt.Rows[0]["SkuName"].ToString(), //物料名称
|
Standard = boxDt.Rows.Count == 0 ? "" : boxDt.Rows[0]["Standard"].ToString(), //规格
|
LotNo = monitorDt.Rows[0]["LotNo"].ToString(), //批次
|
SupplierLot = monitorDt.Rows[0]["SupplierLot"].ToString(), //供货批次
|
LotText = boxDt.Rows.Count == 0 ? "" : boxDt.Rows[0]["LotText"].ToString(), //批次描述
|
PackageStandard = boxDt.Rows.Count == 0 ? "" : boxDt.Rows[0]["PackageStandard"].ToString(), //包装规格
|
PalletType = monitorDt.Rows[0]["PalletType"].ToString(), //托盘类型
|
Qty = decimal.Parse(monitorDt.Rows[0]["Qty"].ToString()), //数量`
|
|
BoxInfoList = boxList //箱码集合
|
};
|
string json = JsonConvert.SerializeObject(model);
|
logger.Error(monitorDt.Rows[0]["TaskNo"].ToString() + "箱码及任务信息:" + json);
|
var response = Utility.Extra.HttpHelper.DoPost(DataFactory.GetWmsURL() + "/api/DownAPi/ReceiveWCSTaskSync", json);
|
logger.Error(monitorDt.Rows[0]["TaskNo"].ToString() + "同步任务:" + response);
|
PalletTasks taskModels = JsonConvert.DeserializeObject<PalletTasks>(response);
|
|
|
if (taskModels.StatusCode == "0")
|
{
|
StringBuilder sqlString = new StringBuilder();
|
//修改当前任务 是否同步状态改为已同步
|
sqlString.Append($"Update WCSTasks set IsSuccess = '0',SyncWms = '1' where TaskNo = '{monitorDt.Rows[0]["TaskNo"]}';");
|
DataFactory.SqlDataBase().ExecuteBySql(sqlString);
|
result = true;
|
}
|
else
|
{
|
returnStr = "-1:" + taskModels.Message;
|
}
|
|
#endregion
|
|
|
#region 操作日志
|
|
DAL_OperationRecord oper = new DAL_OperationRecord();
|
var operation = new OperationModel()
|
{
|
MenuName = "任务管理",
|
FkNo = monitorDt.Rows[0]["TaskNo"].ToString() + "-" + monitorDt.Rows[0]["PalletNo"].ToString(),
|
Msg = "手动同步任务信息",
|
Type = "同步",
|
};
|
oper.AddOperation(operation, loginName);
|
|
#endregion
|
}
|
|
i++;
|
|
}
|
|
}
|
return result;
|
|
}
|
catch
|
{
|
return result;
|
}
|
}
|
/// <summary>
|
/// 置顶任务
|
/// </summary>
|
/// <param name="Id">任务ID集合</param>
|
/// <param name="loginName"></param>
|
/// <returns></returns>
|
public bool StickyAlarm(string[] Id, string loginName)
|
{
|
bool result = false;
|
try
|
{
|
int dt = DataFactory.SqlDataBase().IsExist("WCSTasks", "Id", Id);
|
if (dt >= Id.Length)
|
{
|
int i = 0;
|
while (i < Id.Length)
|
{
|
StringBuilder sql = new StringBuilder();
|
// 获取当前任务详细信息
|
sql.Append($"select * from WCSTasks where Id = '{Id[i]}';");
|
DataTable monitorDt = DataFactory.SqlDataBase().GetDataTableBySQL(sql);
|
if (monitorDt != null && monitorDt.Rows.Count > 0)
|
{
|
//验证是否为深度2的且存在深度1任务
|
var shen = int.Parse(monitorDt.Rows[0]["StartLocat"].ToString().Substring(6, 2)).ToString();
|
if (shen == "2")
|
{
|
StringBuilder sql1 = new StringBuilder();
|
var Locat = monitorDt.Rows[0]["StartLocat"].ToString().Substring(0, 7).ToString() + "1";
|
// 获取当前任务详细信息
|
sql1.Append($"select * from WCSTasks where IsDel = '0' and Levels = '2' and StartLocat = '{Locat}';");//and Status = '0'
|
DataTable monitorDt1 = DataFactory.SqlDataBase().GetDataTableBySQL(sql1);
|
if (monitorDt1 != null && monitorDt1.Rows.Count > 0)
|
{
|
//验证外侧是否有不是等待执行状态的任务
|
sql1.Clear();
|
sql1.Append($"select * from WCSTasks where IsDel = '0' and Status = '0' and Levels = '2' and StartLocat = '{Locat}';");
|
DataTable monitorDt2 = DataFactory.SqlDataBase().GetDataTableBySQL(sql1);
|
if (monitorDt2 != null && monitorDt2.Rows.Count > 0)
|
{
|
sql.Clear();
|
sql.Append("update WCSTasks set Levels = '1',TopTime=getdate() where Id='" + monitorDt1.Rows[0]["Id"].ToString() + "'");
|
}
|
else
|
{
|
i++;
|
continue;
|
}
|
|
//result = false;
|
//break;
|
}
|
}
|
else
|
{
|
sql.Clear();
|
}
|
|
if (monitorDt.Rows[0]["Status"].ToString() != "0")
|
{
|
i++;
|
continue;
|
}
|
|
|
// 修改任务状态
|
sql.Append("update WCSTasks set Levels = '1',TopTime=getdate() where Id='" + Id[i] + "'");
|
int _ret = DataFactory.SqlDataBase().ExecuteBySql(sql);
|
if (_ret >= 1)
|
{
|
DAL_OperationRecord oper = new DAL_OperationRecord();
|
var operation = new OperationModel()
|
{
|
MenuName = "任务管理",
|
FkNo = monitorDt.Rows[0]["TaskNo"].ToString() + "-" + monitorDt.Rows[0]["PalletNo"].ToString(),
|
Msg = "置顶任务信息",
|
Type = "置顶",
|
};
|
oper.AddOperation(operation, loginName);
|
result = true;
|
}
|
}
|
|
i++;
|
|
}
|
|
}
|
return result;
|
|
}
|
catch
|
{
|
return result;
|
}
|
}
|
/// <summary>
|
/// 取消置顶任务
|
/// </summary>
|
/// <param name="Id">任务ID集合</param>
|
/// <param name="loginName"></param>
|
/// <returns></returns>
|
public bool NotStickyAlarm(string[] Id, string loginName)
|
{
|
bool result = false;
|
try
|
{
|
int dt = DataFactory.SqlDataBase().IsExist("WCSTasks", "Id", Id);
|
if (dt >= Id.Length)
|
{
|
int i = 0;
|
while (i < Id.Length)
|
{
|
StringBuilder sql = new StringBuilder();
|
// 获取当前任务详细信息
|
sql.Append($"select * from WCSTasks where Id = '{Id[i]}';");
|
DataTable monitorDt = DataFactory.SqlDataBase().GetDataTableBySQL(sql);
|
if (monitorDt != null && monitorDt.Rows.Count > 0)
|
{
|
|
//验证是否为深度1的且存在深度2的置顶任务
|
var shen = int.Parse(monitorDt.Rows[0]["StartLocat"].ToString().Substring(6, 2)).ToString();
|
if (shen == "1")
|
{
|
StringBuilder sql1 = new StringBuilder();
|
var Locat = monitorDt.Rows[0]["StartLocat"].ToString().Substring(0, 7).ToString() + "2";
|
// 获取当前任务详细信息
|
sql1.Append($"select * from WCSTasks where IsDel = '0' and Status = '0' and Levels = '1' and StartLocat = '{Locat}';");//and Status = '0'
|
DataTable monitorDt1 = DataFactory.SqlDataBase().GetDataTableBySQL(sql1);
|
if (monitorDt1 != null && monitorDt1.Rows.Count > 0)
|
{
|
//验证外侧是否有不是等待执行状态的任务
|
/*sql1.Clear();
|
sql1.Append($"select * from WCSTasks where IsDel = '0' and Status = '0' and Levels = '1' and StartLocat = '{Locat}';");
|
DataTable monitorDt2 = DataFactory.SqlDataBase().GetDataTableBySQL(sql1);
|
if (monitorDt2 != null && monitorDt2.Rows.Count > 0)
|
{*/
|
sql.Clear();
|
sql.Append("update WCSTasks set Levels = '2',TopTime=NULL where Id='" + monitorDt1.Rows[0]["Id"].ToString() + "'");
|
/*}
|
else
|
{
|
i++;
|
continue;
|
}*/
|
//result = false;
|
//break;
|
}
|
}
|
else
|
{
|
sql.Clear();
|
}
|
|
if (monitorDt.Rows[0]["Status"].ToString() != "0")
|
{
|
i++;
|
continue;
|
}
|
|
//sql.Clear();
|
// 修改任务状态
|
sql.Append("update WCSTasks set Levels = '2',TopTime=NULL where Id='" + Id[i] + "'");
|
int _ret = DataFactory.SqlDataBase().ExecuteBySql(sql);
|
if (_ret >= 1)
|
{
|
DAL_OperationRecord oper = new DAL_OperationRecord();
|
var operation = new OperationModel()
|
{
|
MenuName = "任务管理",
|
FkNo = monitorDt.Rows[0]["TaskNo"].ToString() + "-" + monitorDt.Rows[0]["PalletNo"].ToString(),
|
Msg = "取消置顶任务信息",
|
Type = "取消置顶",
|
};
|
oper.AddOperation(operation, loginName);
|
result = true;
|
}
|
}
|
|
i++;
|
|
}
|
|
}
|
return result;
|
|
}
|
catch
|
{
|
return result;
|
}
|
}
|
/// <summary>
|
/// 获取最新任务号
|
/// </summary>
|
/// <returns></returns>
|
public string GetTaskNo()
|
{
|
try
|
{
|
var taskStr = "";
|
//TK2023091900003
|
var codeFlag = "CS";
|
var time = DateTime.Now.ToString("yyyyMMdd").Trim();
|
|
|
StringBuilder sqlString = new StringBuilder();
|
// 验证任务是否已存在
|
sqlString.Append($"select TaskNo from WCSTasks where TaskNo like '{codeFlag + time}%' order by TaskNo desc;");
|
|
DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
|
if (dt.Rows.Count != 0)
|
{
|
var s = dt.Rows[0];
|
var maxNo = dt.Rows[0][0].ToString();
|
if (string.IsNullOrWhiteSpace(maxNo))
|
{
|
taskStr = codeFlag + time + "00001";
|
}
|
else
|
{
|
int lastNo = Convert.ToInt32(maxNo.Substring(10, 5)) + 1;
|
taskStr = codeFlag + time + (lastNo.ToString().PadLeft(5, '0'));
|
|
}
|
}
|
else
|
{
|
taskStr = codeFlag + time + "00001";
|
}
|
|
|
return taskStr;
|
}
|
catch (Exception e)
|
{
|
throw new Exception(e.Message);
|
}
|
}
|
|
/// <summary>
|
/// 根据深度1验证深度2是否可移入移出或出库。
|
/// </summary>
|
/// <param name="type">任务类型</param>
|
/// <param name="locatNo">储位地址</param>
|
/// <param name="msg">消息</param>
|
/// <param name="loginName">操作人</param>
|
/// <returns></returns>
|
public string IsLocatTrue(string type, string locatNo, string msg, string loginName)
|
{
|
try
|
{
|
StringBuilder sqlString = new StringBuilder();
|
var strry = "";
|
|
#region 仅提示
|
//验证是否为深度2
|
//if (int.Parse(locatNo.Substring(6, 2)).ToString() == "2")
|
//{
|
// string locat01 = locatNo.Substring(0, 6).ToString() + "01";
|
// //获取储位深度1状态
|
// sqlString.Clear();
|
// sqlString.Append($"select * from WCSStorageLocat where IsDel = '0' and LocatNo = '{locat01}'");
|
// DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
|
// WCSStorageLocat locat = (WCSStorageLocat)DataTableHelper.DataTableToIList<WCSStorageLocat>(dt);
|
|
// //若深度1为空储位 可进行移库 若为其它异常
|
// if (locat.Status != "0" || locat.Flag != "0")
|
// {
|
// strry = "储位：" + locat01 + "非空储位无法进行移、入、出库操作！";
|
// }
|
//}
|
//else (int.Parse(locatNo.Substring(6, 2)).ToString() == "1")
|
//{
|
// //获取储位深度2状态
|
// sqlString.Clear();
|
// sqlString.Append($"select * from WCSStorageLocat where IsDel = '0' and LocatNo = '{locatNo}'");
|
// DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
|
// WCSStorageLocat locat = (WCSStorageLocat)DataTableHelper.DataTableToIList<WCSStorageLocat>(dt);
|
|
// //深度2必须为有物品
|
// if (locat.Status != "1")
|
// {
|
// strry = "当前里储位不是有物品 不可存放在外储位！";
|
// }
|
//}
|
|
#endregion
|
|
#region 创建对应任务
|
|
//判断是否为入库任务
|
var end = int.Parse(locatNo.Substring(6, 2)).ToString();
|
//验证是否为深度2
|
if (end == "2")
|
{
|
//验证深度1是否为有物品 若有物品则创建对应移库任务。
|
string locat01 = locatNo.Substring(0, 6).ToString() + "01";
|
//获取储位深度1状态
|
sqlString.Clear();
|
sqlString.Append($"select * from WCSStorageLocat where IsDel = '0' and LocatNo = '{locat01}'");
|
DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
|
WCSStorageLocat locat = (WCSStorageLocat)DataTableHelper.DataTableToIList<WCSStorageLocat>(dt);
|
|
if (type == "0")
|
{
|
//若深度1为空储位 可进行移库 若为其它异常
|
if (locat.Status != "0" || locat.Flag != "0")
|
{
|
strry = "入库时 目标储位 外深度不是空储位！";
|
}
|
}
|
else if (type == "1")
|
{
|
|
|
//若深度1为空储位 可进行移库 若为其它异常
|
if (locat.Status == "1")
|
{
|
//创建对应移库任务
|
strry = LocatTrueTask(locat01, loginName);
|
}
|
else if (locat.Status == "0")
|
{
|
}
|
else
|
{
|
strry = "只有深度1为有物品时可进行移库！";
|
}
|
}
|
else if (type == "2")
|
{
|
//验证是起始或目标位置
|
if (msg == "起始位置")
|
{
|
//若深度1为空储位 可进行移库 若为其它异常
|
if (locat.Status == "1")
|
{
|
//创建对应移库任务
|
strry = LocatTrueTask(locat01, loginName);
|
}
|
else if (locat.Status == "0")
|
{
|
//深度1为空储位不管
|
}
|
else
|
{
|
strry = "只有深度1为有物品时可进行移库！";
|
}
|
}
|
else if (msg == "目标位置")
|
{
|
//若深度1为空储位 可进行移库 若为其它异常
|
if (locat.Status != "0" || locat.Flag != "0")
|
{
|
strry = "入库时 目标储位 外深度不是空储位！";
|
}
|
}
|
}
|
}
|
else
|
{
|
//获取储位深度2状态
|
sqlString.Clear();
|
sqlString.Append($"select * from WCSStorageLocat where IsDel = '0' and LocatNo = '{locatNo}'");
|
DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
|
WCSStorageLocat locat = (WCSStorageLocat)DataTableHelper.DataTableToIList<WCSStorageLocat>(dt);
|
|
//深度2必须为有物品
|
if (locat.Status != "1")
|
{
|
strry = "当前里储位不是有物品 不可存放在外储位！";
|
}
|
}
|
|
|
#endregion
|
return strry;
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
}
|
|
/// <summary>
|
/// 根据起始位置获取对应移库储位
|
/// </summary>
|
/// <returns></returns>
|
public string GetYKLocatNo(string locatNo, string roadway)
|
{
|
try
|
{
|
StringBuilder sqlString = new StringBuilder();
|
string nowAddress = "";
|
|
// 获取移库目标储位
|
var row = int.Parse(locatNo.Substring(0, 2));
|
var lie = int.Parse(locatNo.Substring(2, 2));
|
var ceng = int.Parse(locatNo.Substring(4, 2));
|
|
//根据起始位置获取移库信息
|
sqlString.Clear();
|
sqlString.Append($"select LocatNo,[Row],[Column],Layer, (ABS(Row-{row}) + ABS([Column]-{lie}) + ABS(Layer-{ceng})) as distNum from SysStorageLocat where Flag = '0' and Status = '0' and Depth = '02' and RoadwayNo = '{roadway}'order by distNum");
|
|
DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
|
List<WCSStorageLocat> addressModels = (List<WCSStorageLocat>)DataTableHelper.DataTableToIList<WCSStorageLocat>(dt);
|
if (addressModels.Count > 0) // 判断同巷道内排空库位
|
{
|
var listLocaete = new List<string>();
|
foreach (var item in addressModels)
|
{
|
// 目标内库位对应的外库位
|
string addressee = item.LocatNo.Substring(0, 6) + "01";
|
|
// 判断目标库位的外库位是否存在货物 (正常情况下正在移入情况不存在，因为移库先移入里面，后移入外面)
|
//SlotStatus 0: 空储位 1：有货 2：正在入库 3：正在出库 4：正在移入 5：正在移出
|
sqlString.Clear();
|
sqlString.Append($"select count(*) from SysStorageLocat where LocatNo = '{addressee}' and Status = '0' and Flag in ('0','1') ; ");
|
DataTable dt1= DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
|
List<WCSStorageLocat> models1 = (List<WCSStorageLocat>)DataTableHelper.DataTableToIList<WCSStorageLocat>(dt1);
|
if (models1.Count == 0)
|
{
|
continue;
|
}
|
else
|
{
|
nowAddress = item.LocatNo;
|
break;
|
}
|
}
|
}
|
if (nowAddress == "")
|
{
|
// 判断同巷道外排空库位
|
sqlString.Clear();
|
sqlString.Append($"select LocatNo,[Row],[Column],Layer, (ABS(Row-{row}) + ABS([Column]-{lie}) + ABS(Layer-{ceng})) as distNum from SysStorageLocat where Flag = '0' and Status = '0' and Depth = '01' and RoadwayNo = '{roadway}' order by distNum;");
|
DataTable dt2 = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
|
List<WCSStorageLocat> models2 = (List<WCSStorageLocat>)DataTableHelper.DataTableToIList<WCSStorageLocat>(dt2);
|
if (models2.Count > 0)
|
{
|
nowAddress = models2[0].LocatNo;
|
}
|
else
|
{
|
// 库内不存在空储位
|
nowAddress = "";
|
}
|
}
|
|
return nowAddress;
|
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
}
|
|
/// <summary>
|
/// 创建对应移库任务
|
/// </summary>
|
/// <param name="startLocat">起始位置</param>
|
/// <param name="loginName">操作人</param>
|
/// <returns></returns>
|
public string LocatTrueTask(string startLocat, string loginName)
|
{
|
try
|
{
|
WCSTasks models = new WCSTasks();
|
StringBuilder sqlString = new StringBuilder();
|
DALWcsMessage wcsEdit = new DALWcsMessage();
|
|
string str = "";
|
|
#region 起始巷道
|
var start = int.Parse(startLocat.Substring(0, 2));
|
if (start == 1 || start == 2)
|
{
|
models.StartRoadway = "R01";
|
}
|
else if (start == 3 || start == 4)
|
{
|
models.StartRoadway = "R02";
|
}
|
else if (start == 5 || start == 6)
|
{
|
models.StartRoadway = "R03";
|
}
|
else if (start == 7 || start == 8)
|
{
|
models.StartRoadway = "R04";
|
}
|
else if (start == 9 || start == 10)
|
{
|
models.StartRoadway = "R05";
|
}
|
else if (start == 11 || start == 12)
|
{
|
models.StartRoadway = "R06";
|
}
|
else if (start == 13 || start == 14)
|
{
|
models.StartRoadway = "R07";
|
}
|
#endregion
|
|
//获取移库目标位置
|
models.EndLocate = GetYKLocatNo(startLocat, models.StartRoadway);
|
|
models.TaskNo = GetTaskNo();
|
models.StartLocat = startLocat;
|
models.Type = "2";
|
|
|
#region 目标巷道
|
var end = int.Parse(models.EndLocate.Substring(0, 2));
|
if (end == 1 || end == 2)
|
{
|
models.EndRoadway = "R01";
|
}
|
else if (end == 3 || end == 4)
|
{
|
models.EndRoadway = "R02";
|
}
|
else if (end == 5 || end == 6)
|
{
|
models.EndRoadway = "R03";
|
}
|
else if (end == 7 || end == 8)
|
{
|
models.EndRoadway = "R04";
|
}
|
else if (end == 9 || end == 10)
|
{
|
models.EndRoadway = "R05";
|
}
|
else if (end == 11 || end == 12)
|
{
|
models.EndRoadway = "R06";
|
}
|
else if (end == 13 || end == 14)
|
{
|
models.EndRoadway = "R07";
|
}
|
#endregion
|
|
|
//修改储位状态
|
switch (models.Type)
|
{
|
case "0": //入库
|
wcsEdit.EditLocaetStatus("0", "0", "", models.EndLocate);
|
break;
|
case "1": //出库
|
wcsEdit.EditLocaetStatus("1", "0", models.StartLocat, "");
|
break;
|
case "2": //移库
|
wcsEdit.EditLocaetStatus("2", "0", models.StartLocat, models.EndLocate);
|
break;
|
default:
|
break;
|
}
|
|
//创建移库任务
|
// 新增任务
|
sqlString.Clear();
|
sqlString.Append("INSERT INTO WCSTasks (TaskNo,Type,Status,Origin,StartRoadway,StartLocat,EndLocat,EndRoadway,PalletNo,");
|
sqlString.Append("LotNo,SupplierLot,SkuNo,SkuName,Qty,IsSuccess,SyncWms,Demo,Levels,CreateUser,PalletType) VALUES (");
|
sqlString.Append($"'{models.TaskNo}','{models.Type}','0','WCS','{models.StartRoadway}','{models.StartLocate}',");
|
sqlString.Append($"'{models.EndLocate}','{models.EndRoadway}','','','',");
|
sqlString.Append($"'','','','0','0','','2','{loginName}','0');");
|
var num = DataFactory.SqlDataBase().ExecuteBySql(sqlString);
|
|
if (num <= 0)
|
{
|
str = "创建任务失败";
|
}
|
return str;
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
}
|
}
|
}
|
