diff --git a/dao/om/implments/DemandHead.dao.impl.go b/dao/om/implments/DemandHead.dao.impl.go
index e56193f..70654a9 100644
--- a/dao/om/implments/DemandHead.dao.impl.go
+++ b/dao/om/implments/DemandHead.dao.impl.go
@@ -310,12 +310,13 @@ func (impl *DemandHeadDAOImplement) UpdateWhere(predicates []grmi.Predicate, ent
  ******************************************************************************/
 func (impl *DemandHeadDAOImplement) SelectUnparsedFile() ([]model.DemandHead, error) {
 
-	where := fmt.Sprintf("%s = ? and %s = ? and %s < ?",
+	where := fmt.Sprintf("%s = ? and %s = ? and %s < ? and %s != ?",
 		meta.DemandHead_PlantNr.ColumnName,
 		meta.DemandHead_Status.ColumnName,
 		meta.DemandHead_ErrNum.ColumnName,
-		)
-	session := impl.session.Table(impl.meta.TableName).Where(where, impl.plantNr, model.DemandHeadUnParsedStatus, model.DemandMaxTry)
+		meta.DemandHead_Source.ColumnName,
+	)
+	session := impl.session.Table(impl.meta.TableName).Where(where, impl.plantNr, model.DemandHeadUnParsedStatus, model.DemandMaxTry, model.ParseSourceInterval)
 	session = session.OrderBy(meta.DemandHead_PlantNr.ColumnName)
 	session = session.OrderBy(meta.DemandHead_FileNr.ColumnName).Limit(1)
 	data := make([]model.DemandHead, 0, 1)
@@ -324,4 +325,4 @@ func (impl *DemandHeadDAOImplement) SelectUnparsedFile() ([]model.DemandHead, er
 		return nil, grmi.NewDataBaseError(err)
 	}
 	return data, nil
-}
\ No newline at end of file
+}