book_admin/application/admin/command/TdcReadBookReport.php

<?php
/**
 * 用户阅读行为回传
 * Created by: PhpStorm
 * User: lytian
 * Date: 2020/3/5
 * Time: 14:15
 */

namespace app\admin\command;

use app\main\service\GdtService;
use think\Config;
use think\console\Command;
use think\console\Input;
use think\console\input\Option;
use think\console\Output;
use think\Db;
use think\Env;
use think\Request;

class TdcReadBookReport extends Command
{
    public function configure()
    {
        $this->setName('TdcReadBookReport')
            ->setDescription('用户阅读行为回传');
    }

    public function execute(Input $input, Output $output)
    {
        Request::instance()->module('admin'); //cli模式下无法获取到当前的项目模块，手动指定一下
        $id = 0;
        $go = true;
        $dt = date("Ymd", strtotime("-2 days"));
        $dbConfig = Config::get("expanddb");
        $db = Db::connect($dbConfig);
        $tdcAccount = model("TdcAccount")->find();
        $adId = Env::get("tdc.user_action_set_id");
        if (empty($tdcAccount)) {
            exit("未配置TDC账号，脚本执行结束");
        }
        $postData = [];
        while ($go) {
            $sql = "SELECT * FROM gdt_user_book_read WHERE id > {$id} AND dt = '{$dt}' ORDER BY id ASC LIMIT 1000";
            $rows = $db->query($sql);
            if ($rows) {
                foreach ($rows as $row) {
                    $id = $row['id'];
                    if (count($postData) > 30) {
                        //每30条请求一次接口
                        GdtService::instance()->apiUserActionAdd($tdcAccount['account_id'], $tdcAccount['access_token'], $postData, ['ad_source_id' => $adId]);
                        $postData = [];
                    }
                    $postData[] = $this->parseData($row);
                }
            } else {
                $go = false;
            }
        }
        if (count($postData) > 0) {
            GdtService::instance()->apiUserActionAdd($tdcAccount['account_id'], $tdcAccount['access_token'], $postData, ['ad_source_id' => $adId]);
            $postData = [];
        }
        exit("脚本执行结束");
    }

    private function parseData($data)
    {
        return
            [
                "action_time" => time(),
                "user_id" => [
                    "wechat_openid" => $data['openid'],
                    "wechat_app_id" => $data['appid'],
                ],
                "action_type" => 'VIEW_CONTENT',
                'action_param' => [
                    'content_type' => 'readings',
                    'object' => 'product',
                    'product_id' => strval($data['book_id']),
                    'first_category_id' => intval($data['first_category_id']),
                    'first_category_name' => strval($data['first_category_name']),
                    'second_category_id' => intval($data['second_category_id']),
                    'second_category_name' => strval($data['second_category_name']),
                    'reading_duration' => strval($data['read_time']),
                    'reading_chapters' => strval($data['read_num']),
                    'user_consumption' => strval($data['xf']),
                ],
            ];
    }
}