/// ///Data Implemention Object ///BASIC CRUD CLASS FOR TABLE t_wmsStockPandian ///By wm ///on 10/11/2023 /// using System; using DeiNiu.Utils; using System.Data.SqlClient; using DeiNiu.Data.BaseObject; using System.Data; namespace DeiNiu.wms.Data.Model { #region WmsStockPandian_base_Imp [Serializable] class WmsStockPandian_base_Imp: BaseModel_Imp{ protected override void datarowToModel(DataRow dr, BaseModel obj) { if (dr != null ) { WmsStockPandian_base tmpObj = (WmsStockPandian_base)obj; if (dr.Table.Columns.Contains("id") && !(dr["id"] is DBNull)) { try { tmpObj.ID = Convert.ToInt32(dr["id"].ToString()); ; } catch (Exception er) { LogHelper.debug(this.GetType(), "value :"+ dr["id"].ToString()); LogHelper.debug(this.GetType(), er.Message); } } if (dr.Table.Columns.Contains("orderNo") && !(dr["orderNo"] is DBNull)) { try { tmpObj._orderNo = dr["orderNo"].ToString() ; tmpObj._OorderNo = dr["orderNo"].ToString() ; } catch (Exception er) { LogHelper.debug(this.GetType(), "value :"+ dr["orderNo"].ToString()); LogHelper.debug(this.GetType(), er.Message); } } if (dr.Table.Columns.Contains("ownerId") && !(dr["ownerId"] is DBNull)) { try { tmpObj._ownerId = Convert.ToInt32(dr["ownerId"].ToString()); ; tmpObj._OownerId = Convert.ToInt32(dr["ownerId"].ToString()); ; } catch (Exception er) { LogHelper.debug(this.GetType(), "value :"+ dr["ownerId"].ToString()); LogHelper.debug(this.GetType(), er.Message); } } if (dr.Table.Columns.Contains("type") && !(dr["type"] is DBNull)) { try { tmpObj._type = Convert.ToInt32(dr["type"].ToString()); ; tmpObj._Otype = Convert.ToInt32(dr["type"].ToString()); ; } catch (Exception er) { LogHelper.debug(this.GetType(), "value :"+ dr["type"].ToString()); LogHelper.debug(this.GetType(), er.Message); } } if (dr.Table.Columns.Contains("status") && !(dr["status"] is DBNull)) { try { tmpObj._status = Convert.ToInt32(dr["status"].ToString()); ; tmpObj._Ostatus = Convert.ToInt32(dr["status"].ToString()); ; } catch (Exception er) { LogHelper.debug(this.GetType(), "value :"+ dr["status"].ToString()); LogHelper.debug(this.GetType(), er.Message); } } if (dr.Table.Columns.Contains("planStartTime") && !(dr["planStartTime"] is DBNull)) { try { tmpObj._planStartTime = dr["planStartTime"].ToString() ; tmpObj._OplanStartTime = dr["planStartTime"].ToString() ; } catch (Exception er) { LogHelper.debug(this.GetType(), "value :"+ dr["planStartTime"].ToString()); LogHelper.debug(this.GetType(), er.Message); } } if (dr.Table.Columns.Contains("planEndTime") && !(dr["planEndTime"] is DBNull)) { try { tmpObj._planEndTime = dr["planEndTime"].ToString() ; tmpObj._OplanEndTime = dr["planEndTime"].ToString() ; } catch (Exception er) { LogHelper.debug(this.GetType(), "value :"+ dr["planEndTime"].ToString()); LogHelper.debug(this.GetType(), er.Message); } } if (dr.Table.Columns.Contains("startTime") && !(dr["startTime"] is DBNull)) { try { tmpObj._startTime = dr["startTime"].ToString() ; tmpObj._OstartTime = dr["startTime"].ToString() ; } catch (Exception er) { LogHelper.debug(this.GetType(), "value :"+ dr["startTime"].ToString()); LogHelper.debug(this.GetType(), er.Message); } } if (dr.Table.Columns.Contains("endTime") && !(dr["endTime"] is DBNull)) { try { tmpObj._endTime = dr["endTime"].ToString() ; tmpObj._OendTime = dr["endTime"].ToString() ; } catch (Exception er) { LogHelper.debug(this.GetType(), "value :"+ dr["endTime"].ToString()); LogHelper.debug(this.GetType(), er.Message); } } if (dr.Table.Columns.Contains("createby") && !(dr["createby"] is DBNull)) { try { tmpObj._createby = Convert.ToInt32(dr["createby"].ToString()); ; tmpObj._Ocreateby = Convert.ToInt32(dr["createby"].ToString()); ; } catch (Exception er) { LogHelper.debug(this.GetType(), "value :"+ dr["createby"].ToString()); LogHelper.debug(this.GetType(), er.Message); } } if (dr.Table.Columns.Contains("priority") && !(dr["priority"] is DBNull)) { try { tmpObj._priority = Convert.ToInt32(dr["priority"].ToString()); ; tmpObj._Opriority = Convert.ToInt32(dr["priority"].ToString()); ; } catch (Exception er) { LogHelper.debug(this.GetType(), "value :"+ dr["priority"].ToString()); LogHelper.debug(this.GetType(), er.Message); } } if (dr.Table.Columns.Contains("approvedby") && !(dr["approvedby"] is DBNull)) { try { tmpObj._approvedby = Convert.ToInt32(dr["approvedby"].ToString()); ; tmpObj._Oapprovedby = Convert.ToInt32(dr["approvedby"].ToString()); ; } catch (Exception er) { LogHelper.debug(this.GetType(), "value :"+ dr["approvedby"].ToString()); LogHelper.debug(this.GetType(), er.Message); } } if (dr.Table.Columns.Contains("inputValus") && !(dr["inputValus"] is DBNull)) { try { tmpObj._inputValus = dr["inputValus"].ToString() ; tmpObj._OinputValus = dr["inputValus"].ToString() ; } catch (Exception er) { LogHelper.debug(this.GetType(), "value :"+ dr["inputValus"].ToString()); LogHelper.debug(this.GetType(), er.Message); } } if (dr.Table.Columns.Contains("condition") && !(dr["condition"] is DBNull)) { try { tmpObj._condition = dr["condition"].ToString() ; tmpObj._Ocondition = dr["condition"].ToString() ; } catch (Exception er) { LogHelper.debug(this.GetType(), "value :"+ dr["condition"].ToString()); LogHelper.debug(this.GetType(), er.Message); } } if (dr.Table.Columns.Contains("adjustStatus") && !(dr["adjustStatus"] is DBNull)) { try { tmpObj._adjustStatus = Convert.ToInt32(dr["adjustStatus"].ToString()); ; tmpObj._OadjustStatus = Convert.ToInt32(dr["adjustStatus"].ToString()); ; } catch (Exception er) { LogHelper.debug(this.GetType(), "value :"+ dr["adjustStatus"].ToString()); LogHelper.debug(this.GetType(), er.Message); } } if (dr.Table.Columns.Contains("noticeErp") && !(dr["noticeErp"] is DBNull)) { try { tmpObj._noticeErp = Convert.ToBoolean(dr["noticeErp"].ToString()); ; tmpObj._OnoticeErp = Convert.ToBoolean(dr["noticeErp"].ToString()); ; } catch (Exception er) { LogHelper.debug(this.GetType(), "value :"+ dr["noticeErp"].ToString()); LogHelper.debug(this.GetType(), er.Message); } } if (dr.Table.Columns.Contains("operater") && !(dr["operater"] is DBNull)) { try { tmpObj._operater = Convert.ToInt32(dr["operater"].ToString()); ; tmpObj._Ooperater = Convert.ToInt32(dr["operater"].ToString()); ; } catch (Exception er) { LogHelper.debug(this.GetType(), "value :"+ dr["operater"].ToString()); LogHelper.debug(this.GetType(), er.Message); } } if (dr.Table.Columns.Contains("lastmodified") && !(dr["lastmodified"] is DBNull)) { try { tmpObj._lastmodified = dr["lastmodified"].ToString() ; } catch (Exception er) { LogHelper.debug(this.GetType(), "value :"+ dr["lastmodified"].ToString()); LogHelper.debug(this.GetType(), er.Message); } } if (dr.Table.Columns.Contains("createtime") && !(dr["createtime"] is DBNull)) { try { tmpObj._createtime = dr["createtime"].ToString() ; } catch (Exception er) { LogHelper.debug(this.GetType(), "value :"+ dr["createtime"].ToString()); LogHelper.debug(this.GetType(), er.Message); } } if (dr.Table.Columns.Contains("dr") && !(dr["dr"] is DBNull)) { try { tmpObj._dr = Convert.ToBoolean(dr["dr"].ToString()); ; } catch (Exception er) { LogHelper.debug(this.GetType(), "value :"+ dr["dr"].ToString()); LogHelper.debug(this.GetType(), er.Message); } } } } protected override void CmdPrepare(SqlCommand oraCmd) { WmsStockPandian_base tmpObj = (WmsStockPandian_base)modelObj; switch (this._op_flag) { case (int)op_flag.add: _strSql = "INSERT INTO dbo.T_WMSSTOCKPANDIAN({0}) VALUES({1} )"; _strSql = String.Format(_strSql, getFields(tmpObj), getValues(tmpObj)); break; case (int)op_flag.update: // _strSql = "UPDATE dbo.T_WMSSTOCKPANDIAN SET ORDERNO = @ORDERNO,OWNERID = @OWNERID,TYPE = @TYPE,STATUS = @STATUS,PLANSTARTTIME = @PLANSTARTTIME,PLANENDTIME = @PLANENDTIME,STARTTIME = @STARTTIME,ENDTIME = @ENDTIME,CREATEBY = @CREATEBY,PRIORITY = @PRIORITY,APPROVEDBY = @APPROVEDBY,INPUTVALUS = @INPUTVALUS,CONDITION = @CONDITION,ADJUSTSTATUS = @ADJUSTSTATUS,NOTICEERP = @NOTICEERP,OPERATER = @OPERATER,LASTMODIFIED = getdate() WHERE ID = @ID"; _strSql = "UPDATE dbo.T_WMSSTOCKPANDIAN {0} WHERE ID = @ID"; _strSql = String.Format(_strSql, getChangedFields(tmpObj) ); break; case (int)op_flag.delete: // _strSql = "UPDATE dbo.T_WMSSTOCKPANDIAN SET DR =0 WHERE ID = @ID"; _strSql = "delete from dbo.T_WMSSTOCKPANDIAN WHERE ID = @ID"; break; case (int)op_flag.getObj: _strSql = "SELECT * FROM dbo.T_WMSSTOCKPANDIAN WHERE ID = @ID"; break; case (int)op_flag.queryAll: _strSql = "SELECT * FROM dbo.T_WMSSTOCKPANDIAN WHERE DR =1 "; // if (this.rownumEnd >0 ) { // _strSql = "SELECT * FROM (SELECT *, ROW_NUMBER() OVER (ORDER BY ID DESC) as sortNo FROM dbo.T_WMSSTOCKPANDIAN WHERE DR =1 )AS SORTEDTB WHERE DR =1 AND sortNo BETWEEN @START AND @END"; } // _strSql += ";SELECT COUNT(*) FROM T_WMSSTOCKPANDIAN WHERE DR =1"; break; case (int)op_flag.queryActived: _strSql = "SELECT * FROM dbo.T_WMSSTOCKPANDIAN WHERE DR =1"; _strSql += ";SELECT COUNT(*) FROM T_WMSSTOCKPANDIAN WHERE DR =1"; break; case (int)op_flag.getPk: _strSql = "SELECT MAX(ID) FROM dbo.T_WMSSTOCKPANDIAN WHERE DR =1"; break; case (int) op_flag.getCount: _strSql = "SELECT COUNT(*) FROM T_WMSSTOCKPANDIAN WHERE DR =1"; break; } oraCmd.CommandText = _strSql; fillParameters(oraCmd,tmpObj); } private string getFields(WmsStockPandian_base tmpObj) { String colums =""; colums+= tmpObj._orderNo == null ? "" : "ORDERNO" + ","; colums+= tmpObj._ownerId == null ? "" : "OWNERID" + ","; colums+= tmpObj._type == null ? "" : "TYPE" + ","; colums+= tmpObj._status == null ? "" : "STATUS" + ","; colums+= tmpObj._planStartTime == null ? "" : "PLANSTARTTIME" + ","; colums+= tmpObj._planEndTime == null ? "" : "PLANENDTIME" + ","; colums+= tmpObj._startTime == null ? "" : "STARTTIME" + ","; colums+= tmpObj._endTime == null ? "" : "ENDTIME" + ","; colums+= tmpObj._createby == null ? "" : "CREATEBY" + ","; colums+= tmpObj._priority == null ? "" : "PRIORITY" + ","; colums+= tmpObj._approvedby == null ? "" : "APPROVEDBY" + ","; colums+= tmpObj._inputValus == null ? "" : "INPUTVALUS" + ","; colums+= tmpObj._condition == null ? "" : "CONDITION" + ","; colums+= tmpObj._adjustStatus == null ? "" : "ADJUSTSTATUS" + ","; colums+= tmpObj._noticeErp == null ? "" : "NOTICEERP" + ","; colums+= tmpObj._operater == null ? "" : "OPERATER" + ","; return colums.Substring(0,colums.Length -1) ; } private string getValues(WmsStockPandian_base tmpObj) { String values =""; values+= tmpObj._orderNo == null ? "" : "@ORDERNO" + ","; values+= tmpObj._ownerId == null ? "" : "@OWNERID" + ","; values+= tmpObj._type == null ? "" : "@TYPE" + ","; values+= tmpObj._status == null ? "" : "@STATUS" + ","; values+= tmpObj._planStartTime == null ? "" : "@PLANSTARTTIME" + ","; values+= tmpObj._planEndTime == null ? "" : "@PLANENDTIME" + ","; values+= tmpObj._startTime == null ? "" : "@STARTTIME" + ","; values+= tmpObj._endTime == null ? "" : "@ENDTIME" + ","; values+= tmpObj._createby == null ? "" : "@CREATEBY" + ","; values+= tmpObj._priority == null ? "" : "@PRIORITY" + ","; values+= tmpObj._approvedby == null ? "" : "@APPROVEDBY" + ","; values+= tmpObj._inputValus == null ? "" : "@INPUTVALUS" + ","; values+= tmpObj._condition == null ? "" : "@CONDITION" + ","; values+= tmpObj._adjustStatus == null ? "" : "@ADJUSTSTATUS" + ","; values+= tmpObj._noticeErp == null ? "" : "@NOTICEERP" + ","; values+= tmpObj._operater == null ? "" : "@OPERATER" + ","; return values.Substring(0,values.Length -1) ; } private string getChangedFields(WmsStockPandian_base tmpObj) { string updateFields = " set "; if (tmpObj._orderNo !=null && tmpObj._orderNo != tmpObj._OorderNo) { updateFields +="ORDERNO = @ORDERNO," ; } if (tmpObj._ownerId !=null && tmpObj._ownerId != tmpObj._OownerId) { updateFields +="OWNERID = @OWNERID," ; } if (tmpObj._type !=null && tmpObj._type != tmpObj._Otype) { updateFields +="TYPE = @TYPE," ; } if (tmpObj._status !=null && tmpObj._status != tmpObj._Ostatus) { updateFields +="STATUS = @STATUS," ; } if (tmpObj._planStartTime !=null && tmpObj._planStartTime != tmpObj._OplanStartTime) { updateFields +="PLANSTARTTIME = @PLANSTARTTIME," ; } if (tmpObj._planEndTime !=null && tmpObj._planEndTime != tmpObj._OplanEndTime) { updateFields +="PLANENDTIME = @PLANENDTIME," ; } if (tmpObj._startTime !=null && tmpObj._startTime != tmpObj._OstartTime) { updateFields +="STARTTIME = @STARTTIME," ; } if (tmpObj._endTime !=null && tmpObj._endTime != tmpObj._OendTime) { updateFields +="ENDTIME = @ENDTIME," ; } if (tmpObj._createby !=null && tmpObj._createby != tmpObj._Ocreateby) { updateFields +="CREATEBY = @CREATEBY," ; } if (tmpObj._priority !=null && tmpObj._priority != tmpObj._Opriority) { updateFields +="PRIORITY = @PRIORITY," ; } if (tmpObj._approvedby !=null && tmpObj._approvedby != tmpObj._Oapprovedby) { updateFields +="APPROVEDBY = @APPROVEDBY," ; } if (tmpObj._inputValus !=null && tmpObj._inputValus != tmpObj._OinputValus) { updateFields +="INPUTVALUS = @INPUTVALUS," ; } if (tmpObj._condition !=null && tmpObj._condition != tmpObj._Ocondition) { updateFields +="CONDITION = @CONDITION," ; } if (tmpObj._adjustStatus !=null && tmpObj._adjustStatus != tmpObj._OadjustStatus) { updateFields +="ADJUSTSTATUS = @ADJUSTSTATUS," ; } if (tmpObj._noticeErp !=null && tmpObj._noticeErp != tmpObj._OnoticeErp) { updateFields +="NOTICEERP = @NOTICEERP," ; } if (tmpObj._operater !=null && tmpObj._operater != tmpObj._Ooperater) { updateFields +="OPERATER = @OPERATER," ; } updateFields +="LASTMODIFIED = getdate()" ; return updateFields ; } private void fillParameters(SqlCommand oraCmd, WmsStockPandian_base tmpObj) { switch (this._op_flag) { case (int)op_flag.getObj: case (int)op_flag.delete: oraCmd.Parameters.AddWithValue("@ID", tmpObj.ID); return; case (int)op_flag.getPk: oraCmd.Parameters.AddWithValue("@ID", tmpObj.ID); return; case (int)op_flag.queryAll: if (this.rownumEnd > 0) { oraCmd.Parameters.AddWithValue("@START", this._rownumStart); oraCmd.Parameters.AddWithValue("@END", this._rownumEnd); } return; case 0: case (int)op_flag.queryActived: return; case (int)op_flag.update: oraCmd.Parameters.AddWithValue("@ID", tmpObj.ID); oraCmd.Parameters.AddWithValue("@ORDERNO", VerifyDbnull(tmpObj._orderNo)) ; oraCmd.Parameters.AddWithValue("@OWNERID", VerifyDbnull(tmpObj._ownerId)) ; oraCmd.Parameters.AddWithValue("@TYPE", VerifyDbnull(tmpObj._type)) ; oraCmd.Parameters.AddWithValue("@STATUS", VerifyDbnull(tmpObj._status)) ; oraCmd.Parameters.AddWithValue("@PLANSTARTTIME", VerifyDbnull(tmpObj._planStartTime)) ; oraCmd.Parameters.AddWithValue("@PLANENDTIME", VerifyDbnull(tmpObj._planEndTime)) ; oraCmd.Parameters.AddWithValue("@STARTTIME", VerifyDbnull(tmpObj._startTime)) ; oraCmd.Parameters.AddWithValue("@ENDTIME", VerifyDbnull(tmpObj._endTime)) ; oraCmd.Parameters.AddWithValue("@CREATEBY", VerifyDbnull(tmpObj._createby)) ; oraCmd.Parameters.AddWithValue("@PRIORITY", VerifyDbnull(tmpObj._priority)) ; oraCmd.Parameters.AddWithValue("@APPROVEDBY", VerifyDbnull(tmpObj._approvedby)) ; oraCmd.Parameters.AddWithValue("@INPUTVALUS", VerifyDbnull(tmpObj._inputValus)) ; oraCmd.Parameters.AddWithValue("@CONDITION", VerifyDbnull(tmpObj._condition)) ; oraCmd.Parameters.AddWithValue("@ADJUSTSTATUS", VerifyDbnull(tmpObj._adjustStatus)) ; oraCmd.Parameters.AddWithValue("@NOTICEERP", VerifyDbnull(tmpObj._noticeErp)) ; oraCmd.Parameters.AddWithValue("@OPERATER", VerifyDbnull(tmpObj._operater)) ; // oraCmd.Parameters.AddWithValue("@LASTMODIFIED", "getdate()") ; return; case (int)op_flag.add: if(tmpObj._orderNo!=null) oraCmd.Parameters.AddWithValue("@ORDERNO", VerifyDbnull(tmpObj._orderNo)) ; if(tmpObj._ownerId!=null) oraCmd.Parameters.AddWithValue("@OWNERID", VerifyDbnull(tmpObj._ownerId)) ; if(tmpObj._type!=null) oraCmd.Parameters.AddWithValue("@TYPE", VerifyDbnull(tmpObj._type)) ; if(tmpObj._status!=null) oraCmd.Parameters.AddWithValue("@STATUS", VerifyDbnull(tmpObj._status)) ; if(tmpObj._planStartTime!=null) oraCmd.Parameters.AddWithValue("@PLANSTARTTIME", VerifyDbnull(tmpObj._planStartTime)) ; if(tmpObj._planEndTime!=null) oraCmd.Parameters.AddWithValue("@PLANENDTIME", VerifyDbnull(tmpObj._planEndTime)) ; if(tmpObj._startTime!=null) oraCmd.Parameters.AddWithValue("@STARTTIME", VerifyDbnull(tmpObj._startTime)) ; if(tmpObj._endTime!=null) oraCmd.Parameters.AddWithValue("@ENDTIME", VerifyDbnull(tmpObj._endTime)) ; if(tmpObj._createby!=null) oraCmd.Parameters.AddWithValue("@CREATEBY", VerifyDbnull(tmpObj._createby)) ; if(tmpObj._priority!=null) oraCmd.Parameters.AddWithValue("@PRIORITY", VerifyDbnull(tmpObj._priority)) ; if(tmpObj._approvedby!=null) oraCmd.Parameters.AddWithValue("@APPROVEDBY", VerifyDbnull(tmpObj._approvedby)) ; if(tmpObj._inputValus!=null) oraCmd.Parameters.AddWithValue("@INPUTVALUS", VerifyDbnull(tmpObj._inputValus)) ; if(tmpObj._condition!=null) oraCmd.Parameters.AddWithValue("@CONDITION", VerifyDbnull(tmpObj._condition)) ; if(tmpObj._adjustStatus!=null) oraCmd.Parameters.AddWithValue("@ADJUSTSTATUS", VerifyDbnull(tmpObj._adjustStatus)) ; if(tmpObj._noticeErp!=null) oraCmd.Parameters.AddWithValue("@NOTICEERP", VerifyDbnull(tmpObj._noticeErp)) ; if(tmpObj._operater!=null) oraCmd.Parameters.AddWithValue("@OPERATER", VerifyDbnull(tmpObj._operater)) ; return; } } protected override enumDbInstance instance { get { return enumDbInstance.wms; } } } #endregion }