salemonth

application/models/Business/Goods/GoodsCommonService.php

@@ -929,8 +929,8 @@ class GoodsCommonServiceModel extends \Business\AbstractModel
         $orderDAO = \DAO\Order\OrderModel::getInstance();
         $goodsCommonDAO = \DAO\GoodsCommonModel::getInstance();
         $goodsCommonRedis = \Redis\Db4\GoodsCommonRedisModel::getInstance();
-        $pageSize = 1000;
-        $pageIndex = 0;
+        $pageIndex = \Our\PageConst::taskPageBegin;
+        $pageSize = \Our\PageConst::taskPageSize;
         $storeIds = $storeDAO->getOnlineStores(null, 'store_id');
         while (true) {
             $limit = array($pageIndex * $pageSize, $pageSize);

application/models/DAO/Order/Order.php

@@ -69,10 +69,14 @@ class OrderModel extends \DAO\AbstractModel
         return $this->db->from($this->_tableName)->where($where)->fetchNum();
     }
 
-    public function getCounts($where, $field, $group = false)
+    public function getCounts($where, $field, $group = false, $limit = [])
     {
         $this->setDb();
-        return $this->db->select($field)->from($this->_tableName)->where($where)->group($group)->fetchAll();
+        $this->db->select($field)->from($this->_tableName)->where($where)->group($group);
+        if($limit) {
+            $this->db->limit($limit[0],$limit[1]);
+        }
+        return $this->db->fetchAll();
     }
 
     public function getOrderCounts($where, $field)

scripts/crontab/store/storeMonthSales.php

@@ -6,11 +6,18 @@
  */
 define("APPLICATION_PATH", realpath(dirname(__FILE__) . '/../../../')); //指向public的上一级
 require APPLICATION_PATH . '/scripts/crontab/common.php';
-$data = \DAO\Order\OrderModel::getInstance()->getCounts('payment_time >= '.(time()-30*24*60*60),'count(order_id) as num,store_id','store_id');
+$pageIndex = \Our\PageConst::taskPageBegin;
+$pageSize = \Our\PageConst::taskPageSize;
+do{
+    $limit = array($pageIndex * $pageSize, $pageSize);
+    $data = \DAO\Order\OrderModel::getInstance()->getCounts('payment_time >= '.(time()-30*24*60*60),'count(order_id) as num,store_id','store_id',$limit);
 //$data = \DAO\Order\OrderModel::getInstance()->getCounts('payment_time >= 1518303150','store_id,count(order_id) as num','store_id');
-if($data){
-    foreach ($data as &$v){
-        $v['updatetime'] = time();
+    if($data){
+        foreach ($data as &$v){
+            $v['updatetime'] = time();
+        }
+        \DAO\StoreMonthSalesModel::getInstance()->insertAllOrUpdate($data);
     }
-    \DAO\StoreMonthSalesModel::getInstance()->insertAllOrUpdate($data);
-}
+    $pageIndex++;
+}while(!empty($data));
+