测试数据

application/models/Business/Goods/GoodsCommonService.php

@@ -1156,6 +1156,7 @@ class GoodsCommonServiceModel extends \Business\AbstractModel
         $topSaleList = array();
         for($i=0;$i<2000;$i++){
             $storeId = $storeTopSaleGoodsModel->getChangedSaleStoreId();
+            \Our\Log::getInstance()->write('店铺ID'.$storeId);
             if($storeId===false){
                 break;
             }
@@ -1170,7 +1171,12 @@ class GoodsCommonServiceModel extends \Business\AbstractModel
             }
         }
         if($topSaleList){
+            \Our\Log::getInstance()->write(json_encode($topSaleList,true));
             $result = $storeTopSaleGoodsModel->insertAllOrUpdate($topSaleList);
+            $storeTopSaleGoodsRedis = \Redis\Db4\StoreTopSaleGoodsRedisModel::getInstance();
+            foreach($storeIds as $tempStoreId){
+                $storeTopSaleGoodsRedis->tableDel($tempStoreId);
+            }
             \Our\Log::getInstance()->write('店铺销量前三更新'.($result?'success':'fail'));
         }
         \Our\Log::getInstance()->write('本次没有店铺数据需要更新');

application/models/DAO/Goods/StoreTopSaleGoods.php

@@ -94,6 +94,8 @@ FROM han_goods_common t1 where t1.goods_state={1} and t1.goods_verify={2} and t1
 left join han_goods_score_statistics b
 on a.goods_commonid = b.goods_commonid
 WHERE a.group_id<=3 AND a.sale_num>0 order by a.group_id asc limit 3',\Our\ApiConst::defaultGoodsScore,\Our\ApiConst::onlineGoodsState,\Our\ApiConst::onlineGoodsVerify,$storeId,\Our\ApiConst::onlineGoodsDel);
+
+        \Our\Log::getInstance()->write('店铺sql查询'.$sql);
         $list = $this->db->query($sql)->rows;
         if($list){
             $newlist = array();
@@ -146,6 +148,7 @@ WHERE a.group_id<=3 AND a.sale_num>0 and a.goods_state=1 and a.goods_verify=1 an
         if ($insertAllSql != $baseSql) {
             $insertAllSql = rtrim($insertAllSql, ',');
             $insertAllSql .= 'ON DUPLICATE KEY UPDATE goods_commonid = VALUES(goods_commonid),goods_score=VALUES(goods_score),goods_name=VALUES(goods_name),goods_image=VALUES(goods_image)';
+            \Our\Log::getInstance()->write($insertAllSql);
             $one = $this->db->insert($this->_tableName)->query($insertAllSql);
             if ($one === false) {
                 $error++;