dev

helper/refill/policy/quaility.php

@@ -349,27 +349,6 @@ class Quality
             $qualities_log("{$mchid}-{$card_type}-{$spec} pre_qualities",$pre_qualities);
 
 
-
-//            $times_qualities = $times_checker(true, $all_qualities, $used_times);
-//            $time_qualities = $timeout_checker(true, $all_qualities, $left_time);
-//            $pre_qualities = array_intersect($times_qualities, $time_qualities, $all_qualities);
-//
-//            if (count($pre_qualities) < count($all_qualities)) {
-//                $match_ratio = $this->mRatioCtl->ratio_match($mchid, $org_quality, $card_type, $spec, $all_qualities);
-//                Log::record("mchid={$mchid} must calc next quality match_ratio={$match_ratio}",Log::DEBUG);
-//            } else {
-//                $match_ratio = true;
-//            }
-//
-//            if (!$match_ratio) {
-//                $times_qualities = $times_checker(false, $all_qualities, $used_times);
-//                $time_qualities  = $timeout_checker(false, $all_qualities, $left_time);
-//                $pre_qualities = array_intersect($times_qualities, $time_qualities, $all_qualities);
-//
-//                Log::record("calc_quality timeing_checker result is empty", Log::DEBUG);
-//
-//            }
-
             if(!$timeing_checker($pre_qualities)) {
                 $pre_qualities = [];
                 Log::record("calc_quality timeing_checker result is empty", Log::DEBUG);

plot/refill/WriterConsumer.py

@@ -10,7 +10,7 @@ class WriterConsumer(Thread):
         self._messages = Queue(1000000)
         self._stopped = False
         self._handler = handler
-        self._max_threshold  = 5000
+        self._max_threshold  = 10000
         self._max_batch_size = 200000
         self._name = name