Commit c19aff4b by 泽锋 李

fix

parent bcb65349
...@@ -1118,7 +1118,7 @@ from dc_auto_turnover where gmt_modified>=@btime and gmt_modified<=@etime ...@@ -1118,7 +1118,7 @@ from dc_auto_turnover where gmt_modified>=@btime and gmt_modified<=@etime
{ {
// 每秒检查一次 // 每秒检查一次
Thread.Sleep(10 * 1000); Thread.Sleep(10 * 1000);
var count = _connection.QueryFirstOrDefault<int>(" select count(1) from dc_base_queue where consume_date is null ", commandTimeout: 0); var count = _connection.QueryFirstOrDefault<int>(" select count(1) from dc_base_queue where consume_date is null and queue_type=1 ", commandTimeout: 0);
if (count > 0) if (count > 0)
{ {
WaitTurnoverQueueTask(); WaitTurnoverQueueTask();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment