ldj/Model/wms/data/WmsInUpPort_Imp.cs

120 lines
5.6 KiB
C#

/// <summary>
///INTERFACE IMPLIMENT FOR TABLE t_wmsInUpPort
///By wm with codesmith.
///on 04/16/2018
/// </summary>
using System;
using System.Data.SqlClient;
using DeiNiu.Utils;
namespace DeiNiu.wms.Data.Model
{
[Serializable] class WmsInUpPort_Imp : WmsInUpPort_base_Imp
{
protected override void CmdPrepare(SqlCommand sqlCmd)
{
base.CmdPrepare(sqlCmd);
WmsInUpPort mObj = ( WmsInUpPort)modelObj;
switch (_cust_op_flag)
{
case 99: //query with dic
_strSql = "SELECT *,ROW_NUMBER() OVER (ORDER BY ID DESC) as sortNo FROM t_wmsInUpPort WHERE DR = 1 " + mObj.CmdParameters[0].ToString();
_strSql = "SELECT * FROM (" + _strSql + " )AS SORTEDTB WHERE sortNo BETWEEN @START AND @END" + " ORDER BY ID DESC";
_strSql += ";SELECT COUNT(*) FROM t_wmsInUpPort WHERE DR = 1 " + mObj.CmdParameters[0].ToString();
sqlCmd.CommandText = _strSql;
sqlCmd.Parameters.AddWithValue("@START", this._rownumStart);
sqlCmd.Parameters.AddWithValue("@END", this._rownumEnd);
sqlCmd.CommandText = _strSql;
break;
case 100: //by name
_strSql = "SELECT * FROM t_wmsInUpPort WHERE NAME = @NAME";
sqlCmd.CommandText = _strSql;
sqlCmd.Parameters.AddWithValue("@NAME", mObj.CmdParameters[0] );
break;
case 200: //by id
_strSql = "SELECT * FROM t_wmsInUpPort WHERE id = @id";
sqlCmd.CommandText = _strSql;
sqlCmd.Parameters.AddWithValue("@id", mObj.CmdParameters[0]);
break;
case 300: //by count done flowno
_strSql = "SELECT count(*) FROM t_wmsInUpPort WHERE flowNo = @flowNo ";
_strSql +=" and state!=@status ";
sqlCmd.CommandText = _strSql;
sqlCmd.Parameters.AddWithValue("@status", (int)enumInStockDetailStatus.);
sqlCmd.Parameters.AddWithValue("@flowNo", mObj.CmdParameters[0]);
break;
case 310: //by detailId
_strSql = "SELECT count(*) FROM t_wmsInUpPort WHERE detailId = @detailId";
_strSql += " and state!=@status ";
sqlCmd.CommandText = _strSql;
sqlCmd.Parameters.AddWithValue("@status", (int)enumInStockDetailStatus.);
sqlCmd.Parameters.AddWithValue("@detailId", mObj.CmdParameters[0]);
break;
case 320: //by orderNo
_strSql = "SELECT count(1) FROM t_wmsInUpPort WHERE orderNo = @orderNo";
_strSql += " and state!=@status ";
sqlCmd.CommandText = _strSql;
sqlCmd.Parameters.AddWithValue("@status", (int)enumInStockDetailStatus.);
sqlCmd.Parameters.AddWithValue("@orderNo", mObj.CmdParameters[0]);
break;
case 400: //by orderNo
_strSql = "SELECT * FROM t_wmsInUpPort WHERE jobNo = @jobNo";
sqlCmd.CommandText = _strSql;
sqlCmd.Parameters.AddWithValue("@jobNo", mObj.CmdParameters[0]);
break;
case 500: //retrieve tasks
_strSql = "update t_wmsInUpPort set state =@state ,description = @desc WHERE skuId=@skuId and flowNo =@flowNo";
sqlCmd.CommandText = _strSql;
sqlCmd.Parameters.AddWithValue("@state", (int)enumInStockDetailStatus.);
sqlCmd.Parameters.AddWithValue("@flowNo", mObj.CmdParameters[0]);
sqlCmd.Parameters.AddWithValue("@skuId", mObj.CmdParameters[1]);
sqlCmd.Parameters.AddWithValue("@desc", mObj.CmdParameters[2]);
break;
case 600: //retrieve tasks
_strSql = "select * from t_wmsInUpPort WHERE skuId=@skuId and flowNo =@flowNo";
sqlCmd.CommandText = _strSql;
sqlCmd.Parameters.AddWithValue("@flowNo", mObj.CmdParameters[0]);
sqlCmd.Parameters.AddWithValue("@skuId", mObj.CmdParameters[1]);
break;
case 610: //retrieve tasks
_strSql = "select * from t_wmsInUpPort WHERE goodsId=@goodsId and productDate =@productDate and flowNo =@flowNo";
sqlCmd.CommandText = _strSql;
sqlCmd.Parameters.AddWithValue("@flowNo", mObj.CmdParameters[0]);
sqlCmd.Parameters.AddWithValue("@goodsId", mObj.CmdParameters[1]);
sqlCmd.Parameters.AddWithValue("@productDate", mObj.CmdParameters[2]);
break;
case 700: //all tasks
_strSql = "select * from t_wmsInUpPort WHERE state=@state and count> upCount";
sqlCmd.Parameters.AddWithValue("@state", (int)enumInStockDetailStatus.);
sqlCmd.CommandText = _strSql;
break;
case 800: //retrieve tasks
_strSql = "select * from t_wmsInUpPort WHERE recordId=@recordId ";
sqlCmd.CommandText = _strSql;
sqlCmd.Parameters.AddWithValue("@recordId", mObj.CmdParameters[0]);
break;
}
}
}
}