using HanHe.Utility.Data;
|
using HH.MData;
|
using HH.WMS.Common;
|
using HH.WMS.Entitys.Autobom;
|
using HH.WMS.Entitys.Common;
|
using HH.WMS.Entitys.External;
|
using MongoDB.Driver;
|
using MongoDB.Driver.Builders;
|
using Newtonsoft.Json;
|
using System;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Data.Common;
|
using System.Data.OracleClient;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace HH.WMS.DAL.External
|
{
|
public class TN_WM_TRANSPORT_TASKDAL : BaseDAL
|
{
|
#region 获取流转任务
|
/// <summary>
|
/// 获取流转任务
|
/// </summary>
|
/// <param name="ObjType">对象</param>
|
/// <param name="ObjNo">对象编码</param>
|
/// <param name="TaskNo">任务编码</param>
|
/// <param name="TaskState">任务状态</param>
|
/// <param name="ps"></param>
|
/// <param name="pg"></param>
|
/// <returns></returns>
|
/// <history>[HanHe(xdl)] CREATED 2018/04/28</history>
|
public List<TN_WM_TRANSPORT_TASKEntity> GetSearchList(string strWhere, string strOrder, int pageSize, int pageIndex, out int totalPages, out int totalRows)
|
{
|
string sql = @"(SELECT CN_S_TASK_NO,CN_S_CIR_OBJ,CN_S_CIR_OBJ_CODE,CN_S_START_BIT,CN_S_END_BIT,CN_S_PRO_CODE,CN_S_STATE,CN_T_START,
|
CN_T_END,CN_S_BF_TASK_NO,CN_S_AF_TASK_NO,CN_S_STOCK_CODE,
|
CN_S_START_AREA,CN_S_END_AREA,CN_N_PRIORITY,CN_S_CREATOR,
|
CN_S_CREATOR_BY,CN_T_CREATE,CN_S_MODIFY,CN_S_MODIFY_BY,
|
CN_T_MODIFY,CN_S_REMARK,CN_S_TASK_TYPE FROM TN_WM_TRANSPORT_TASK) t";
|
DbCommand cmd = DataAccess.GetStoredProcCommand("prc_query");
|
this.DataAccess.AddInParameter(cmd, "TableName", ComDbType.STRING, sql);
|
this.DataAccess.AddInParameter(cmd, "WhereStr", ComDbType.STRING, strWhere);
|
this.DataAccess.AddInParameter(cmd, "OrderByStr", ComDbType.STRING, strOrder);
|
this.DataAccess.AddInParameter(cmd, "PageSize", ComDbType.INT, pageSize);
|
this.DataAccess.AddInParameter(cmd, "PageIndex", ComDbType.INT, pageIndex);
|
this.DataAccess.AddOutParameter(cmd, "TotalPage", ComDbType.INT, 4);
|
this.DataAccess.AddOutParameter(cmd, "TotalRecord", ComDbType.INT, 4);
|
|
//如果是oracle 增加特性
|
if (!string.IsNullOrEmpty(Now_dbType) && Now_dbType.Equals("ORACLE"))
|
{
|
//处理游标类型 因DbType无游标类型,游标类型单独处理
|
ComDbType.AddOrcOutParameter(cmd, "v_cur", OracleType.Cursor);
|
}
|
try
|
{
|
//获得列表
|
List<TN_WM_TRANSPORT_TASKEntity> list = DataAccessExtensive.ExecuteListEntity<TN_WM_TRANSPORT_TASKEntity>(this.DataAccess, cmd, SetEntity);
|
|
totalPages = Convert.ToInt32(this.DataAccess.GetParameterValue(cmd, "TotalPage"));
|
totalRows = Convert.ToInt32(this.DataAccess.GetParameterValue(cmd, "TotalRecord"));
|
return list;
|
}
|
catch (Exception)
|
{
|
throw;
|
}
|
}
|
|
/// <summary>
|
/// 设置实体的各列
|
/// <summary>
|
private void SetEntity(TN_WM_TRANSPORT_TASKEntity entity, IDataReader reader)
|
{
|
SetEntityUti(entity, "CN_S_TASK_NO", "CN_S_TASK_NO", reader);
|
SetEntityUti(entity, "CN_S_CIR_OBJ", "CN_S_CIR_OBJ", reader);
|
SetEntityUti(entity, "CN_S_CIR_OBJ_CODE", "CN_S_CIR_OBJ_CODE", reader);
|
SetEntityUti(entity, "CN_S_START_BIT", "CN_S_START_BIT", reader);
|
SetEntityUti(entity, "CN_S_END_BIT", "CN_S_END_BIT", reader);
|
SetEntityUti(entity, "CN_S_PRO_CODE", "CN_S_PRO_CODE", reader);
|
SetEntityUti(entity, "CN_S_STATE", "CN_S_STATE", reader);
|
SetEntityUti(entity, "CN_T_START", "CN_T_START", reader);
|
SetEntityUti(entity, "CN_T_END", "CN_T_END", reader);
|
SetEntityUti(entity, "CN_S_BF_TASK_NO", "CN_S_BF_TASK_NO", reader);
|
SetEntityUti(entity, "CN_S_AF_TASK_NO", "CN_S_AF_TASK_NO", reader);
|
SetEntityUti(entity, "CN_S_STOCK_CODE", "CN_S_STOCK_CODE", reader);
|
SetEntityUti(entity, "CN_S_START_AREA", "CN_S_START_AREA", reader);
|
SetEntityUti(entity, "CN_S_END_AREA", "CN_S_END_AREA", reader);
|
SetEntityUti(entity, "CN_S_TASK_TYPE", "CN_S_TASK_TYPE", reader);
|
SetEntityUti(entity, "CN_N_PRIORITY", "CN_N_PRIORITY", reader);
|
SetEntityUti(entity, "CN_S_CREATOR", "CN_S_CREATOR", reader);
|
SetEntityUti(entity, "CN_S_CREATOR_BY", "CN_S_CREATOR_BY", reader);
|
SetEntityUti(entity, "CN_T_CREATE", "CN_T_CREATE", reader);
|
SetEntityUti(entity, "CN_S_MODIFY", "CN_S_MODIFY", reader);
|
SetEntityUti(entity, "CN_S_MODIFY_BY", "CN_S_MODIFY_BY", reader);
|
SetEntityUti(entity, "CN_T_MODIFY", "CN_T_MODIFY", reader);
|
SetEntityUti(entity, "CN_S_REMARK", "CN_S_REMARK", reader);
|
}
|
#endregion
|
|
/// <summary>
|
/// 获取流转任务对象
|
/// </summary>
|
/// <param name="taskNo"></param>
|
/// <returns></returns>
|
/// <history>[HanHe(xdl)] CREATED 2018/04/28</history>
|
public TN_WM_TRANSPORT_TASKEntity GetTransportTask(string taskNo)
|
{
|
string strSql = "SELECT * FROM TN_WM_TRANSPORT_TASK WHERE 1=1 AND CN_S_TASK_NO='" + taskNo + "'";
|
TN_WM_TRANSPORT_TASKEntity transportTask;
|
try
|
{
|
DbCommand cmd = DataAccess.GetSqlStringCommand(strSql);
|
transportTask = DataAccessExtensive.ExecuteSingleEntity<TN_WM_TRANSPORT_TASKEntity>(this.DataAccess, cmd, SetEntity);
|
}
|
catch (Exception ex)
|
{
|
Log.Info("HH.BWMS.DAL.TaskMgr.TN_WM_TRANSPORT_TASKDAL.GetTransportTask", JsonConvert.SerializeObject(ex));
|
return null;
|
}
|
return transportTask;
|
}
|
|
/// <summary>
|
/// 获取流转任务对象列表
|
/// </summary>
|
/// <param name="strWhere"></param>
|
/// <returns></returns>
|
/// <history>[HanHe(xdl)] CREATED 2018/04/28</history>
|
public List<TN_WM_TRANSPORT_TASKEntity> GetTransportTaskList(string strWhere)
|
{
|
string strSql = "SELECT * FROM TN_WM_TRANSPORT_TASK WHERE 1=1 " + strWhere + "";
|
List<TN_WM_TRANSPORT_TASKEntity> lstTransportTask;
|
DbCommand cmd = DataAccess.GetSqlStringCommand(strSql);
|
lstTransportTask = DataAccessExtensive.ExecuteListEntity<TN_WM_TRANSPORT_TASKEntity>(this.DataAccess, cmd, SetEntity);
|
return lstTransportTask;
|
}
|
|
|
|
/// <summary>
|
/// 根据任务号获取任务实体
|
/// </summary>
|
/// <param name="CN_S_TASK_NO"></param>
|
/// <returns></returns>
|
public DataTable GetTaskEntity(string CN_S_TASK_NO)
|
{
|
string strSql = "SELECT * FROM TN_WM_TRANSPORT_TASK WHERE 1=1 AND CN_S_TASK_NO='" + CN_S_TASK_NO + "'";
|
DataTable dt = new DataTable();
|
try
|
{
|
DbCommand cmd = DataAccess.GetSqlStringCommand(strSql);
|
dt = DataAccessExtensive.ExecuteDataTable(this.DataAccess, cmd);
|
}
|
catch (Exception ex)
|
{
|
return dt;
|
throw ex;
|
}
|
return dt;
|
}
|
|
#region 新增
|
/// <summary>
|
/// 增加一条数据
|
/// </summary>
|
/// <history>[HanHe(DBS)] CREATED 2018/4/12</history>
|
public SqlExecuteResult Add(List<TN_WM_TRANSPORT_TASKEntity> entitys, DbTransaction trans)
|
{
|
string sql = @"INSERT INTO TN_WM_TRANSPORT_TASK
|
(CN_S_TASK_NO
|
,CN_S_CIR_OBJ
|
,CN_S_CIR_OBJ_CODE
|
,CN_S_START_BIT
|
,CN_S_END_BIT
|
,CN_S_PRO_CODE
|
,CN_S_STATE
|
,CN_S_TASK_TYPE
|
,CN_S_BF_TASK_NO
|
,CN_S_AF_TASK_NO
|
,CN_S_STOCK_CODE
|
,CN_S_START_AREA
|
,CN_S_END_AREA
|
,CN_S_START_AREA_TYPE
|
,CN_S_END_AREA_TYPE
|
,CN_C_START_IS_CONTROL_QTY
|
,CN_C_END_IS_CONTROL_QTY
|
,CN_S_START_CONTROL_INV
|
,CN_S_END_CONTROL_INV
|
,CN_N_PRIORITY
|
,CN_S_CREATOR
|
,CN_S_CREATOR_BY
|
,CN_T_CREATE
|
,CN_T_MODIFY,CN_S_REMARK,CN_C_IS_AUTO,CN_S_PROJECT_CODE)
|
VALUES
|
(:CN_S_TASK_NO,:CN_S_CIR_OBJ,:CN_S_CIR_OBJ_CODE,:CN_S_START_BIT,:CN_S_END_BIT
|
,:CN_S_PRO_CODE,:CN_S_STATE,:CN_S_TASK_TYPE,
|
:CN_S_BF_TASK_NO,:CN_S_AF_TASK_NO,:CN_S_STOCK_CODE,:CN_S_START_AREA,:CN_S_END_AREA,:CN_S_START_AREA_TYPE,:CN_S_END_AREA_TYPE,:CN_C_START_IS_CONTROL_QTY,:CN_C_END_IS_CONTROL_QTY,:CN_S_START_CONTROL_INV,:CN_S_END_CONTROL_INV,:CN_N_PRIORITY,:CN_S_CREATOR
|
,:CN_S_CREATOR_BY,:CN_T_CREATE,:CN_T_MODIFY,:CN_S_REMARK,:CN_C_IS_AUTO,:CN_S_PROJECT_CODE)";
|
|
List<DbCommand> cmds = new List<DbCommand>();
|
foreach (TN_WM_TRANSPORT_TASKEntity entity in entitys)
|
{
|
DbCommand cmd = DataAccess.GetSqlStringCommand(sql);
|
|
DataAccess.AddInParameter(cmd, "@CN_S_TASK_NO", DbType.String, entity.CN_S_TASK_NO);
|
DataAccess.AddInParameter(cmd, "@CN_S_CIR_OBJ", DbType.String, entity.CN_S_CIR_OBJ);
|
DataAccess.AddInParameter(cmd, "@CN_S_CIR_OBJ_CODE", DbType.String, entity.CN_S_CIR_OBJ_CODE);
|
DataAccess.AddInParameter(cmd, "@CN_S_START_BIT", DbType.String, entity.CN_S_START_BIT);
|
DataAccess.AddInParameter(cmd, "@CN_S_END_BIT", DbType.String, entity.CN_S_END_BIT);
|
DataAccess.AddInParameter(cmd, "@CN_S_PRO_CODE", DbType.String, entity.CN_S_PRO_CODE);
|
DataAccess.AddInParameter(cmd, "@CN_S_STATE", DbType.String, entity.CN_S_STATE);
|
DataAccess.AddInParameter(cmd, "@CN_S_TASK_TYPE", DbType.String, entity.CN_S_TASK_TYPE);
|
DataAccess.AddInParameter(cmd, "@CN_S_BF_TASK_NO", DbType.String, entity.CN_S_BF_TASK_NO);
|
DataAccess.AddInParameter(cmd, "@CN_S_AF_TASK_NO", DbType.String, entity.CN_S_AF_TASK_NO);
|
DataAccess.AddInParameter(cmd, "@CN_S_STOCK_CODE", DbType.String, entity.CN_S_STOCK_CODE);
|
DataAccess.AddInParameter(cmd, "@CN_S_START_AREA", DbType.String, entity.CN_S_START_AREA);
|
DataAccess.AddInParameter(cmd, "@CN_S_END_AREA", DbType.String, entity.CN_S_END_AREA);
|
DataAccess.AddInParameter(cmd, "@CN_S_START_AREA_TYPE", DbType.String, entity.CN_S_START_AREA_TYPE);
|
DataAccess.AddInParameter(cmd, "@CN_S_END_AREA_TYPE", DbType.String, entity.CN_S_END_AREA_TYPE);
|
DataAccess.AddInParameter(cmd, "@CN_C_START_IS_CONTROL_QTY", DbType.String, entity.CN_C_START_IS_CONTROL_QTY);
|
DataAccess.AddInParameter(cmd, "@CN_C_END_IS_CONTROL_QTY", DbType.String, entity.CN_C_END_IS_CONTROL_QTY);
|
DataAccess.AddInParameter(cmd, "@CN_S_START_CONTROL_INV", DbType.String, entity.CN_S_START_CONTROL_INV);
|
DataAccess.AddInParameter(cmd, "@CN_S_END_CONTROL_INV", DbType.String, entity.CN_S_END_CONTROL_INV);
|
DataAccess.AddInParameter(cmd, "@CN_N_PRIORITY", DbType.Int16, entity.CN_N_PRIORITY);
|
DataAccess.AddInParameter(cmd, "@CN_S_CREATOR", DbType.String, entity.CN_S_CREATOR);
|
DataAccess.AddInParameter(cmd, "@CN_S_CREATOR_BY", DbType.String, entity.CN_S_CREATOR_BY);
|
DataAccess.AddInParameter(cmd, "@CN_T_CREATE", DbType.DateTime, entity.CN_T_CREATE);
|
DataAccess.AddInParameter(cmd, "@CN_T_MODIFY", DbType.DateTime, entity.CN_T_MODIFY);
|
DataAccess.AddInParameter(cmd, "@CN_S_REMARK", DbType.String, entity.CN_S_REMARK);
|
DataAccess.AddInParameter(cmd, "@CN_C_IS_AUTO", DbType.String, entity.CN_C_IS_AUTO);
|
DataAccess.AddInParameter(cmd, "@CN_S_PROJECT_CODE", DbType.String, entity.CN_S_PROJECT_CODE);
|
cmds.Add(cmd);
|
}
|
return ExecuteCommands(cmds, trans);
|
}
|
|
public SqlExecuteResult Add(TN_WM_TRANSPORT_TASKEntity entity, DbTransaction trans)
|
{
|
string sql = @"INSERT INTO TN_WM_TRANSPORT_TASK
|
(CN_S_TASK_NO
|
,CN_S_CIR_OBJ
|
,CN_S_CIR_OBJ_CODE
|
,CN_S_START_BIT
|
,CN_S_END_BIT
|
,CN_S_PRO_CODE
|
,CN_S_STATE
|
,CN_S_TASK_TYPE
|
,CN_S_BF_TASK_NO
|
,CN_S_AF_TASK_NO
|
,CN_S_STOCK_CODE
|
,CN_S_START_AREA
|
,CN_S_END_AREA
|
,CN_S_START_AREA_TYPE
|
,CN_S_END_AREA_TYPE
|
,CN_C_START_IS_CONTROL_QTY
|
,CN_C_END_IS_CONTROL_QTY
|
,CN_S_START_CONTROL_INV
|
,CN_S_END_CONTROL_INV
|
,CN_N_PRIORITY
|
,CN_S_CREATOR
|
,CN_S_CREATOR_BY
|
,CN_T_CREATE
|
,CN_T_MODIFY,CN_S_REMARK,CN_C_IS_AUTO,CN_S_PROJECT_CODE)
|
VALUES
|
(:CN_S_TASK_NO,:CN_S_CIR_OBJ,:CN_S_CIR_OBJ_CODE,:CN_S_START_BIT,:CN_S_END_BIT
|
,:CN_S_PRO_CODE,:CN_S_STATE,:CN_S_TASK_TYPE,
|
:CN_S_BF_TASK_NO,:CN_S_AF_TASK_NO,:CN_S_STOCK_CODE,:CN_S_START_AREA,:CN_S_END_AREA,:CN_S_START_AREA_TYPE,:CN_S_END_AREA_TYPE,:CN_C_START_IS_CONTROL_QTY,:CN_C_END_IS_CONTROL_QTY,:CN_S_START_CONTROL_INV,:CN_S_END_CONTROL_INV,:CN_N_PRIORITY,:CN_S_CREATOR
|
,:CN_S_CREATOR_BY,:CN_T_CREATE,:CN_T_MODIFY,:CN_S_REMARK,:CN_C_IS_AUTO,:CN_S_PROJECT_CODE)";
|
|
DbCommand cmd = DataAccess.GetSqlStringCommand(sql);
|
|
DataAccess.AddInParameter(cmd, "@CN_S_TASK_NO", DbType.String, entity.CN_S_TASK_NO);
|
DataAccess.AddInParameter(cmd, "@CN_S_CIR_OBJ", DbType.String, entity.CN_S_CIR_OBJ);
|
DataAccess.AddInParameter(cmd, "@CN_S_CIR_OBJ_CODE", DbType.String, entity.CN_S_CIR_OBJ_CODE);
|
DataAccess.AddInParameter(cmd, "@CN_S_START_BIT", DbType.String, entity.CN_S_START_BIT);
|
DataAccess.AddInParameter(cmd, "@CN_S_END_BIT", DbType.String, entity.CN_S_END_BIT);
|
DataAccess.AddInParameter(cmd, "@CN_S_PRO_CODE", DbType.String, entity.CN_S_PRO_CODE);
|
DataAccess.AddInParameter(cmd, "@CN_S_STATE", DbType.String, entity.CN_S_STATE);
|
DataAccess.AddInParameter(cmd, "@CN_S_TASK_TYPE", DbType.String, entity.CN_S_TASK_TYPE);
|
DataAccess.AddInParameter(cmd, "@CN_S_BF_TASK_NO", DbType.String, entity.CN_S_BF_TASK_NO);
|
DataAccess.AddInParameter(cmd, "@CN_S_AF_TASK_NO", DbType.String, entity.CN_S_AF_TASK_NO);
|
DataAccess.AddInParameter(cmd, "@CN_S_STOCK_CODE", DbType.String, entity.CN_S_STOCK_CODE);
|
DataAccess.AddInParameter(cmd, "@CN_S_START_AREA", DbType.String, entity.CN_S_START_AREA);
|
DataAccess.AddInParameter(cmd, "@CN_S_END_AREA", DbType.String, entity.CN_S_END_AREA);
|
DataAccess.AddInParameter(cmd, "@CN_S_START_AREA_TYPE", DbType.String, entity.CN_S_START_AREA_TYPE);
|
DataAccess.AddInParameter(cmd, "@CN_S_END_AREA_TYPE", DbType.String, entity.CN_S_END_AREA_TYPE);
|
DataAccess.AddInParameter(cmd, "@CN_C_START_IS_CONTROL_QTY", DbType.String, entity.CN_C_START_IS_CONTROL_QTY);
|
DataAccess.AddInParameter(cmd, "@CN_C_END_IS_CONTROL_QTY", DbType.String, entity.CN_C_END_IS_CONTROL_QTY);
|
DataAccess.AddInParameter(cmd, "@CN_S_START_CONTROL_INV", DbType.String, entity.CN_S_START_CONTROL_INV);
|
DataAccess.AddInParameter(cmd, "@CN_S_END_CONTROL_INV", DbType.String, entity.CN_S_END_CONTROL_INV);
|
DataAccess.AddInParameter(cmd, "@CN_N_PRIORITY", DbType.Int16, entity.CN_N_PRIORITY);
|
DataAccess.AddInParameter(cmd, "@CN_S_CREATOR", DbType.String, entity.CN_S_CREATOR);
|
DataAccess.AddInParameter(cmd, "@CN_S_CREATOR_BY", DbType.String, entity.CN_S_CREATOR_BY);
|
DataAccess.AddInParameter(cmd, "@CN_T_CREATE", DbType.DateTime, entity.CN_T_CREATE);
|
DataAccess.AddInParameter(cmd, "@CN_T_MODIFY", DbType.DateTime, entity.CN_T_MODIFY);
|
DataAccess.AddInParameter(cmd, "@CN_S_REMARK", DbType.String, entity.CN_S_REMARK);
|
DataAccess.AddInParameter(cmd, "@CN_C_IS_AUTO", DbType.String, entity.CN_C_IS_AUTO);
|
DataAccess.AddInParameter(cmd, "@CN_S_PROJECT_CODE", DbType.String, entity.CN_S_PROJECT_CODE);
|
return ExecuteCommand(cmd, trans);
|
}
|
#endregion
|
|
#region 更改任务状态为执行中
|
/// <summary>
|
/// 更改任务执行状态
|
/// </summary>
|
/// <param name="taskNo"></param>
|
/// <param name="taskState"></param>
|
/// <param name="trans"></param>
|
/// <returns></returns>
|
public SqlExecuteResult UpdateState(string taskNo, string taskState, DbTransaction trans)
|
{
|
string strSql = "UPDATE TN_WM_TRANSPORT_TASK SET CN_S_STATE=:CN_S_STATE where CN_S_TASK_NO=:CN_S_TASK_NO";
|
DbCommand cmd = DataAccess.GetSqlStringCommand(strSql.ToString());
|
DataAccess.AddInParameter(cmd, "CN_S_STATE", DbType.String, taskState);
|
DataAccess.AddInParameter(cmd, "CN_T_END", DbType.Date, DateTime.Now);
|
DataAccess.AddInParameter(cmd, "CN_S_TASK_NO", DbType.String, taskNo);
|
return ExecuteCommand(cmd, trans);
|
}
|
|
/// <summary>
|
/// 更新任务执行开始时间
|
/// </summary>
|
/// <param name="taskNo"></param>
|
/// <param name="trans"></param>
|
/// <returns></returns>
|
public SqlExecuteResult UpdateStartTime(string taskNo, DbTransaction trans)
|
{
|
string strSql = "UPDATE TN_WM_TRANSPORT_TASK SET CN_T_START=:CN_T_START where CN_S_TASK_NO=:CN_S_TASK_NO";
|
DbCommand cmd = DataAccess.GetSqlStringCommand(strSql.ToString());
|
DataAccess.AddInParameter(cmd, "CN_T_START", DbType.Date, DateTime.Now);
|
DataAccess.AddInParameter(cmd, "CN_S_TASK_NO", DbType.String, taskNo);
|
return ExecuteCommand(cmd, trans);
|
}
|
#endregion
|
|
#region 根据任务编号获取任务实体
|
/// <summary>
|
/// 根据任务编号获取任务实体
|
/// </summary>
|
/// <param name="taskNo">任务编号</param>
|
/// <param name="trans"></param>
|
/// <returns></returns>
|
public TN_WM_TRANSPORT_TASKEntity GetTaskByNo(string taskNo)
|
{
|
TN_WM_TRANSPORT_TASKEntity taskEntity = new TN_WM_TRANSPORT_TASKEntity();
|
|
string sql = @" select * from TN_WM_TRANSPORT_TASK WHERE CN_S_TASK_NO ='" + taskNo + "'";
|
DbCommand cmd = DataAccess.GetSqlStringCommand(sql);
|
try
|
{
|
//获得 实体
|
taskEntity = DataAccessExtensive.ExecuteSingleEntity<TN_WM_TRANSPORT_TASKEntity>(this.DataAccess, cmd, SetEntity);
|
return taskEntity;
|
}
|
catch (Exception)
|
{
|
throw;
|
}
|
}
|
#endregion
|
|
#region 根据流程编号获取实体
|
/// <summary>
|
/// 根据流程编号获取实体
|
/// </summary>
|
/// <param name="proCode"></param>
|
/// <returns></returns>
|
public List<TN_AB_B_PRO_EVENT_DEFEntity> GetEntityByProCode(string proCode)
|
{
|
IMongoQuery query = Query.EQ("CN_S_PRO_CODE", proCode);
|
return MongoDBSingleton.Instance.Find<TN_AB_B_PRO_EVENT_DEFEntity>(query, "TN_AB_B_PRO_EVENT_DEF");
|
}
|
#endregion
|
|
public List<TN_WM_TRANSPORT_TASKEntity> GetNotEndTask(string startBit)
|
{
|
string strSql = @"select CN_S_TASK_NO from TN_WM_TRANSPORT_TASK
|
where (CN_S_START_BIT=:CN_S_START_BIT or CN_S_END_BIT=:CN_S_END_BIT)
|
and CN_S_STATE in('未执行','执行中','取货完成')";
|
|
DbCommand cmd = DataAccess.GetSqlStringCommand(strSql.ToString());
|
|
DataAccess.AddInParameter(cmd, "CN_S_START_BIT", DbType.String, startBit);
|
DataAccess.AddInParameter(cmd, "CN_S_END_BIT", DbType.String, startBit);
|
return DataAccessExtensive.ExecuteListEntity<TN_WM_TRANSPORT_TASKEntity>(this.DataAccess, cmd, (entity, reader) =>
|
{
|
entity.CN_S_TASK_NO = reader["CN_S_TASK_NO"].ToString().Trim();
|
});
|
}
|
|
#region 改变任务状态
|
/// <summary>
|
/// 改变任务状态
|
/// </summary>
|
/// <param name="lstGuid">主键</param>
|
/// <param name="State">状态</param>
|
/// <returns></returns>
|
public SqlExecuteResult CheckState(string taskNo, string State, DbTransaction trans)
|
{
|
StringBuilder strSql = new StringBuilder();
|
strSql.Append(" UPDATE TN_WM_TRANSPORT_TASK SET CN_S_STATE=@CN_S_STATE ");
|
if (State == "执行中")
|
{
|
strSql.Append(",CN_T_START=@CN_T_START ");
|
}
|
if (State == "完成")
|
{
|
strSql.Append(",CN_T_END=@CN_T_END ");
|
}
|
strSql.Append(" where CN_S_TASK_NO=@CN_S_TASK_NO ");
|
DbCommand cmd = DataAccess.GetSqlStringCommand(strSql.ToString());
|
DataAccess.AddInParameter(cmd, "CN_S_STATE", ComDbType.STRING, State);
|
DataAccess.AddInParameter(cmd, "CN_S_TASK_NO", ComDbType.STRING, taskNo);
|
DataAccess.AddInParameter(cmd, "CN_T_START", ComDbType.DATE, DateTime.Now);
|
DataAccess.AddInParameter(cmd, "CN_T_END", ComDbType.DATE, DateTime.Now);
|
return ExecuteCommand(cmd, trans);
|
}
|
#endregion
|
|
/// <summary>
|
/// 判断指定托盘是否存在未执行结束的任务
|
/// </summary>
|
/// <param name="objCode"></param>
|
/// <returns></returns>
|
public bool GetNotExecutedTaskByObj(string objCode)
|
{
|
string strSql = @"select CN_S_CIR_OBJ_CODE from TN_WM_TRANSPORT_TASK where
|
CN_S_CIR_OBJ_CODE=:CN_S_CIR_OBJ_CODE and CN_S_STATE in('未执行','执行中','取货完成')";
|
|
DbCommand cmd = DataAccess.GetSqlStringCommand(strSql.ToString());
|
|
DataAccess.AddInParameter(cmd, "CN_S_CIR_OBJ_CODE", DbType.String, objCode);
|
DataTable dt = DataAccessExtensive.ExecuteDataTable(this.DataAccess, cmd);
|
return dt.Rows.Count > 0;
|
}
|
|
public SqlExecuteResult UpdateTaskPostion(string taskNo, string position, string area, string type, DbTransaction trans)
|
{
|
string sql = string.Empty;
|
if (type == "start")
|
{
|
sql = "UPDATE TN_WM_TRANSPORT_TASK SET CN_S_START_BIT ='" + position + "',CN_S_START_AREA='" + area + "' WHERE CN_S_TASK_NO=:CN_S_TASK_NO";
|
}
|
else
|
{
|
sql = "UPDATE TN_WM_TRANSPORT_TASK SET CN_S_END_BIT ='" + position + "',CN_S_END_AREA='" + area + "' WHERE CN_S_TASK_NO=:CN_S_TASK_NO";
|
}
|
DbCommand cmd = DataAccess.GetSqlStringCommand(sql);
|
DataAccess.AddInParameter(cmd, "CN_S_TASK_NO", DbType.String, taskNo);
|
return ExecuteCommand(cmd, trans);
|
}
|
public SqlExecuteResult UpdateTaskAuto(string taskNo, string taskState, DbTransaction trans)
|
{
|
string strSql = "UPDATE TN_WM_TRANSPORT_TASK SET CN_C_IS_AUTO=:CN_C_IS_AUTO where CN_S_TASK_NO=:CN_S_TASK_NO";
|
DbCommand cmd = DataAccess.GetSqlStringCommand(strSql.ToString());
|
DataAccess.AddInParameter(cmd, "CN_C_IS_AUTO", ComDbType.CHAR, taskState);
|
DataAccess.AddInParameter(cmd, "CN_S_TASK_NO", DbType.String, taskNo);
|
return ExecuteCommand(cmd, trans);
|
}
|
}
|
}
|
