diff --git a/B3QingDaoWanFu/Tasks/RecheckTrustPayTask.cs b/B3QingDaoWanFu/Tasks/RecheckTrustPayTask.cs index ee0f797..9625a0c 100644 --- a/B3QingDaoWanFu/Tasks/RecheckTrustPayTask.cs +++ b/B3QingDaoWanFu/Tasks/RecheckTrustPayTask.cs @@ -11,6 +11,7 @@ using BWP.BWPTrustPayClient.TrustPayRequests; using Forks.EnterpriseServices.BusinessInterfaces; using Forks.EnterpriseServices.DomainObjects2; using Forks.EnterpriseServices.DomainObjects2.DQuery; +using Forks.EnterpriseServices.SqlDoms; using TSingSoft.WebPluginFramework; using TSingSoft.WebPluginFramework.QueueTasks; using TSingSoft.WebPluginFramework.TimerTasks; @@ -28,6 +29,7 @@ namespace BWP.B3QingDaoWanFu.Tasks { query.Where.Conditions.Add(DQCondition.IsNull(DQExpression.Field("Gathering_ID"))); query.Columns.Add(DQSelectColumn.Field("ID")); + query.Range = SelectRange.Top(5); var list = query.EExecuteList(); foreach (var id in list) { QueueTaskService.Add(new RecheckTrustPayTask(id));