<?php
|
|
namespace app\admin\command;
|
use think\Db;
|
use think\console\Command;
|
use think\console\Input;
|
use think\console\Output;
|
use app\api\logic\taoke\device\Dataoke as LogicDataoke;
|
|
/**
|
* 专辑管理
|
*/
|
class Album extends Command
|
{
|
|
protected function configure()
|
{
|
$this->setName('album')->setDescription('同步专辑列表');
|
}
|
|
/**
|
*
|
* @param Input $input
|
* @param Output $output
|
* @return void
|
*/
|
protected function execute(Input $input, Output $output)
|
{
|
$pageSize = 100;
|
$page = 1;
|
//获取专辑列表
|
$LogicDataoke = new LogicDataoke();
|
$albumList = $LogicDataoke->albumList(0,0,$page,$pageSize);
|
Db::name('album')->where(['is_delete'=>0])->update(['is_delete'=>1]);
|
//Db::name('album_goods')->where(['is_delete'=>0])->update(['is_delete'=>1]);
|
if(!empty($albumList)){
|
foreach($albumList as $key => $item){
|
$album_id = $item['id'];
|
$find = Db::name('album')->where(['album_id'=>$album_id])->find();
|
$save_data = [
|
'album_id' => $album_id,
|
'uid' => $item['uid'],
|
'title' => isset($item['title']) ? $item['title'] : '',
|
'label' => isset($item['label']) ? $item['label'] : '',
|
'goods_count' => isset($item['goodsCount']) ? $item['goodsCount'] : '',
|
'like_num' => isset($item['likeNum']) ? $item['likeNum'] : '',
|
'promote_count' => isset($item['promoteCount']) ? $item['promoteCount'] : '',
|
'endType' => isset($item['endType']) ? $item['endType'] : '',
|
'release_time' => isset($item['releaseTime']) ? $item['releaseTime'] : '',
|
'end_time' => isset($item['endTime']) ? $item['endTime'] : '',
|
'good_list_json' => isset($item['goodsList']) ? json_encode($item['goodsList']) : '',
|
'update_time' => time(),
|
'is_delete'=>0
|
];
|
if(empty($find)){ //新增
|
$save_data['create_time'] = time();
|
Db::name('album')->insert($save_data);
|
$save_anchor = [
|
'uid' => $item['uid'],
|
'nickname' => $item['userName'],
|
'head_img' => $item['headImg'],
|
'user_desc' => $item['userDesc'],
|
'user_good_at' => json_encode($item['userGoodAt']),
|
'view_follow_num' => 0,
|
'user_view' => 0
|
];
|
$find_anchor = Db::name('album_author_info')->where(['uid'=>$item['uid']])->find();
|
if(empty($find_anchor)){
|
Db::name('album_author_info')->insert($save_anchor);
|
}
|
}else{
|
$res = Db::name('album')->where(['id'=>$find['id']])->update($save_data);
|
}
|
//更新商品列表
|
// $goodsList = $LogicDataoke->albumGoodsList($album_id);
|
// if(!empty($goodsList)){
|
// $save_goods = [];
|
// foreach($goodsList as $goods){
|
// $save_goods[] = [
|
// 'album_id' => $album_id,
|
// 'shopType' => isset($goods['shopType']) ? $goods['shopType'] : '',
|
// 'activityType' => isset($goods['activityType']) ? $goods['activityType'] : '',
|
// 'monthSales' => isset($goods['monthSales']) ? $goods['monthSales'] : '',
|
// 'dailySales' => isset($goods['dailySales']) ? $goods['dailySales'] : '',
|
// 'couponId' => isset($goods['couponId']) ? $goods['couponId'] : '',
|
// 'couponLink' => isset($goods['couponLink']) ? $goods['couponLink'] : '',
|
// 'couponPrice' => isset($goods['couponPrice']) ? $goods['couponPrice'] : '',
|
// 'goodsId' => isset($goods['goodsId']) ? $goods['goodsId'] : '',
|
// 'title' => isset($goods['title']) ? $goods['title'] : '',
|
// 'mainPic' => isset($goods['mainPic']) ? $goods['mainPic'] : '',
|
// 'specialText' => isset($goods['specialText']) ? $goods['specialText'] : '',
|
// 'originPrice' => isset($goods['originPrice']) ? $goods['originPrice'] : '',
|
// 'actualPrice' => isset($goods['actualPrice']) ? $goods['actualPrice'] : '',
|
// 'create_time' => time(),
|
// 'update_time' => time(),
|
// 'is_delete' => 0
|
// ];
|
// }
|
// if(!empty($save_goods)){
|
// Db::name('album_goods')->insertAll($save_goods);
|
// }
|
// }
|
}
|
Db::name('album')->where(['is_delete'=>1])->delete();
|
//Db::name('album_goods')->where(['is_delete'=>1])->delete();
|
|
}
|
$output->info("采集成功");
|
}
|
|
}
|
