setName('fixUserFollow') ->setDescription('修复用户的关注状态'); } protected function execute(Input $input, Output $output) { Request::instance()->module('admin'); //cli模式下无法获取到当前的项目模块，手动指定一下 $filename = APP_PATH."1111.txt"; $handle = fopen ($filename, "r"); $adminIds = []; $i = 1; while (!feof($handle)) { $buffer = fgets($handle, 4096); $content = trim($buffer); if (empty($content)) { break; } try { $arr = explode(' ', $content); $appid = $arr[0]; $openid = $arr[1]; //查询admin_id if (!isset($adminIds[$appid])) { $adminInfo = AdminService::instance() ->getAdminConfigModel() ->where('appid', $appid) ->find(); $adminIds[$appid] = $adminInfo['admin_id']; } $admin_id = $adminIds[$appid]; $userId = OfficialAccountsService::instance() ->getOpenidModel() ->getUserId($admin_id, $openid); if ($userId) { if ( UserService::instance() ->getUserModel() ->setConnect($userId) ->update( ['is_subscribe' => 1, 'subscribe_time' => time()], ['id' => $userId]) ) { $userKey = CacheConstants::getUserCacheKey($userId); Redis::instance()->del($userKey); //发送客服消息 $adminConfig = new AdminConfig(); $adminInfo = $adminConfig->getAdminInfoAll($admin_id); $wechat = new WeChatObject($adminInfo); $officialAccount = $wechat->getOfficialAccount(); $host = AdminService::instance()->getAdminReferralDomain($admin_id)->data; $msg = '最近阅读链接'; $result = $officialAccount ->customer_service ->message(new Text($msg)) ->to($openid) ->send(); echo "第{$i}行--appid:{$appid} --openid:{$openid} --处理结果".json_encode($result, JSON_UNESCAPED_UNICODE); $adminConfig->getConnection()->free(); $adminConfig->getConnection()->close(); unset($adminConfig); } } }catch (Exception $e) { echo "第{$i}行--appid:{$appid} --openid:{$openid} --处理结果:".$e->getMessage(); } $i++; } fclose ($handle); $output->writeln("\n处理完毕！"); } }