店铺销量前三商品更新成功

application/models/Business/Goods/GoodsCommonService.php

@@ -1163,14 +1163,15 @@ class GoodsCommonServiceModel extends \Business\AbstractModel
                 if(($storeIds&&in_array($storeId,$storeIds))){
                     continue;
                 }
-                $topSaleListTemp=$storeTopSaleGoodsModel->getStoreTopSaleGoodsListByStoreId($storeId);
+                $storeIds[] = $storeId;
+                $topSaleListTemp = $storeTopSaleGoodsModel->getStoreTopSaleGoodsListByStoreId($storeId);
                 $storeTopSaleList = $this->getNewStoreTopSaleGoodsList($topSaleListTemp,$storeId);
                 $topSaleList = $topSaleList?array_merge($topSaleList,$storeTopSaleList):$storeTopSaleList;
             }
         }
         if($topSaleList){
             $result = $storeTopSaleGoodsModel->insertAllOrUpdate($topSaleList);
-            \Our\Log::getInstance()->write('店铺销量更新'.($result?'success':'fail'));
+            \Our\Log::getInstance()->write('店铺销量前三更新'.($result?'success':'fail'));
         }
         \Our\Log::getInstance()->write('本次没有店铺数据需要更新');
     }

application/models/DAO/Goods/StoreTopSaleGoods.php

@@ -63,7 +63,7 @@ class StoreTopSaleGoodsModel extends \DAO\AbstractModel{
                 }else{
                     $singleStoreGoods = $this->getList(array('store_id'=>$storeId,'goods_commonid'=>array('neq','')));
                     if($singleStoreGoods){
-                        $ordesGoods = empty($orderGoods)?$singleStoreGoods:array_merge($orderGoods,$singleStoreGoods);
+                        $orderGoods = empty($orderGoods)?$singleStoreGoods:array_merge($orderGoods,$singleStoreGoods);
                         $storeTopSaleGoodsRedis->update($storeId,$singleStoreGoods,\Our\ApiConst::oneDaySecond);
                     }
                 }
@@ -93,8 +93,16 @@ FROM han_goods_common t1 where t1.goods_state={1} and t1.goods_verify={2} and t1
 ) a
 left join han_goods_score_statistics b
 on a.goods_commonid = b.goods_commonid
-WHERE a.group_id<=3 AND a.sale_num>0 ',\Our\ApiConst::defaultGoodsScore,\Our\ApiConst::onlineGoodsState,\Our\ApiConst::onlineGoodsVerify,$storeId,\Our\ApiConst::onlineGoodsDel);
+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);
         $list = $this->db->query($sql)->rows;
+        if($list){
+            $newlist = array();
+            foreach($list as $key=>$goods){
+                $goods['rank'] = $key+1;
+                $newlist[] = $goods;
+            }
+            return $newlist;
+        }
         return $list;
     }
 

conf/application.ini

@@ -318,7 +318,7 @@ elastic.master.host="192.168.1.201"
 elastic.master.port="9200"
 elastic.master.scheme="http";
 
-[lyz : common]
+[lyztest : common]
 ; 数据库配置
 resources.database.params.driver   = "pdo_mysql"
 resources.database.params.hostname = "127.0.0.1"
@@ -363,7 +363,7 @@ elastic.master.host="192.168.1.201"
 elastic.master.port="9200"
 elastic.master.scheme="http";
 
-[lyztest : common]
+[lyz : common]
 ; 数据库配置
 resources.database.params.driver   = "pdo_mysql"
 resources.database.params.hostname = "127.0.0.1"