|
|
@ -310,13 +310,12 @@ func (impl *DemandHeadDAOImplement) UpdateWhere(predicates []grmi.Predicate, ent |
|
|
|
******************************************************************************/ |
|
|
|
func (impl *DemandHeadDAOImplement) SelectUnparsedFile() ([]model.DemandHead, error) { |
|
|
|
|
|
|
|
where := fmt.Sprintf("%s = ? and %s = %d and %s < %d", |
|
|
|
where := fmt.Sprintf("%s = ? and %s = ? and %s < ?", |
|
|
|
meta.DemandHead_PlantNr.ColumnName, |
|
|
|
meta.DemandHead_Status.ColumnName, |
|
|
|
model.DemandHeadUnParsedStatus, |
|
|
|
meta.DemandHead_ErrNum.ColumnName, |
|
|
|
model.DemandMaxTry) |
|
|
|
session := impl.session.Table(impl.meta.TableName).Where(where, impl.plantNr) |
|
|
|
) |
|
|
|
session := impl.session.Table(impl.meta.TableName).Where(where, impl.plantNr, model.DemandHeadUnParsedStatus, model.DemandMaxTry) |
|
|
|
session = session.OrderBy(meta.DemandHead_PlantNr.ColumnName) |
|
|
|
session = session.OrderBy(meta.DemandHead_FileNr.ColumnName).Limit(1) |
|
|
|
data := make([]model.DemandHead, 0, 1) |
|
|
|