1

application/service/queue/ImportTable2Queue.php

@@ -98,6 +98,7 @@ class ImportTable2Queue
                     Db::name('system_table2')->insertAll($insert_array);
                     Db::name('system_queue')->where('id',$info['id'])->setInc('deal_count',$count);
                     $insert_array = array();
+                    $count = 0;
                 }
             }
             Db::name('system_table2')->insertAll($insert_array);