hasOne(Goods::class, ['id' => 'goods_id']); } public function getMall() { return $this->hasOne(Mall::class, ['id' => 'mall_id']); } /** * {@inheritdoc} */ public function attributeLabels() { return [ 'id' => 'ID', 'mall_id' => '商城ID', 'goods_id' => '商品id', 'total_views' => '浏览量', 'total_sales_volume' => '销量', 'total_pay_money' => '销售金额', 'add_card_numbers' => '加购数量', 'total_visitors' => '访客数', 'status' => '状态[-1:删除;0:禁用;1启用;]', 'created_at' => '创建时间', 'updated_at' => '上次更新数据时间', ]; } public static function setData($params) { try { if (empty($params['mall_id']) && empty($params['goods_id'])) { return false; } $model = self::findOne(['mall_id' => $params['mall_id'], 'goods_id' => $params['goods_id'], 'status' => [StatusEnum::ENABLED, StatusEnum::DISABLED]]); if (empty($model)) { $model = new self(); $model->mall_id = $params['mall_id']; $model->goods_id = $params['goods_id']; $model->loadDefaultValues(); } if (!empty($params['views'])) $model->total_views += $params['views']; if (!empty($params['sales_volume'])) $model->total_sales_volume += $params['sales_volume']; if (!empty($params['pay_money'])) $model->total_pay_money += $params['pay_money']; if (!empty($params['add_card_numbers'])) $model->add_card_numbers += $params['add_card_numbers']; if (!empty($params['visitors'])) $model->total_visitors += $params['visitors']; if (!$model->save()) throw new \Exception($model->getErrorMessage()); return $model; } catch (\Exception $e) { self::$static_error = $e->getMessage(); return false; } } public static function getMallGoodsList($mall_id) { $redis = \Yii::$app->redis; $redis_key = RedisKeyEnum::suffix(RedisKeyEnum::CENSUS_MALL_GOODS_SALES_VOLUME, '', true) . ':' . $mall_id; $result = $redis->zrevrange($redis_key, 0, 10, 'WITHSCORES'); $data = []; if ($result) { foreach ($result as $k => $v) { if ($k % 2 == 0) { $arr = explode(':', $v); $data[$k]['goods_id'] = array_pop($arr); } if ($k % 2 == 1) $data[$k - 1]['sales_num'] = $v; } }else{ $list = CensusMallGoods::lists(['where'=>[['mall_id'=>$mall_id]],'order'=>'total_sales_volume desc']); foreach ($list as $item){ $data[] = [ 'goods_id'=>$item['goods_id'], 'sales_num'=>$item['total_sales_volume'], ]; } } $goods_id_arr = array_column($data, 'goods_id'); $goods_list = Goods::lists(['where' => [['id' => $goods_id_arr]], 'select' => 'id,goods_name,cover_pic,status', 'index' => 'id']); $list = []; foreach ($data as $item) { if($goods_list[$item['goods_id']]['status'] == StatusEnum::ENABLED){ $list[] = [ 'goods_id' => $item['goods_id'], 'sales_num' => $item['sales_num'], 'goods_name' => $goods_list[$item['goods_id']]['goods_name'] ?? '', 'cover_pic' => $goods_list[$item['goods_id']]['cover_pic'] ?? '', ]; } } return $list; } }