wx.sstbc.com/app/Jobs/UpdateCompanyJob.php

<?php
/**
 * 更新公司信息
 */

namespace App\Jobs;

use App\Models\Company;
use App\Models\User;
use App\Repositories\YuanheRepository;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;

class UpdateCompanyJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    public $tries = 3;
    public $timeout = 300;

    public $userId;

    /**
     * Create a new job instance.
     *
     * @param int $userId 用户ID
     */
    public function __construct($userId)
    {
        $this->userId = $userId;
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        $user = User::find($this->userId);

        if (!$user || empty($user->company_name)) {
            return;
        }

        // 如果已经有公司关联，跳过
        if ($user->company_id) {
            return;
        }

        $YuanheRepository = new YuanheRepository();

        // 获取公司详细信息
        $result = $YuanheRepository->companyInfo(['enterpriseName' => $user->company_name]);

        if (!$result) {
            // 标识一下未匹配到公司，后续可以根据这个字段筛选出未匹配到公司的用户
            $user->company_id = 0;
            $user->save();
            return;
        }

        // 如果$result['enterpriseName']存在数字，跳过
        if (preg_match('/\d/', $result['enterpriseName'])) {
            $user->company_id = 0;
            $user->save();
            return;
        }

        if ($result['status'] == '未注册') {
            $user->company_id = 0;
            $user->save();
            return;
        }

        $where = ['company_name' => $result['enterpriseName']];
        $data = [
            'company_address' => $result['address'],
            'business_scope' => $result['businessScope'],
            'company_city' => $result['city'],
            'contact_mail' => $result['contactMail'],
            'contact_phone' => $result['contactPhone'],
            'company_area' => $result['country'],
            'credit_code' => $result['creditCode'],
            'enterprise_id' => $result['enterpriseId'],
            'company_name' => $result['enterpriseName'],
            'is_abroad' => $result['isAbroad'],
            'company_market' => $result['isOnStock'],
            'is_yh_invested' => $result['isYhInvested'],
            'logo' => $result['logo'],
            'company_legal_representative' => $result['operName'],
            'company_province' => $result['province'],
            'company_industry' => combineKeyValue($result['qccIndustry']),
            'regist_amount' => $result['registAmount'],
            'regist_capi_type' => $result['registCapiType'],
            'company_date' => $result['startDate'],
            'status' => $result['status'],
            'stock_date' => $result['stockDate'],
            'currency_type' => $result['currencyType'],
            'stock_number' => $result['stockNumber'],
            'stock_type' => $result['stockType'],
            'company_tag' => implode(',', $result['tagList']),
            // 更新日期
            'update_date' => $result['updatedDate'] ?? null,
            // 管理平台
            'project_users' => $result['projectUsers'] ?? null,
            // 股东信息
            'partners' => $result['partners'] ?? null,
        ];

        $company = Company::updateOrCreate($where, $data);

        // 更新用户关联
        $user->company_id = $company->id;
        $user->save();

        // 更新上市状态
        $this->updateMarketStatus($company->id);

        // 更新位置
        $this->updateLocation($company->id);
    }

    /**
     * 更新经纬度信息
     */
    private function updateLocation($companyId)
    {
        $company = Company::find($companyId);

        if (!$company || empty($company->company_address) || $company->company_longitude) {
            return;
        }

        $local = Company::addressTolocation($company->company_address);
        $company->company_longitude = $local['lng'];
        $company->company_latitude = $local['lat'];
        $company->save();
    }

    /**
     * 根据 company_tag 更新上市状态
     * 判断是否包含上市代码标签，如 688001.SH、000001.SZ、830001.BJ 等
     */
    private function updateMarketStatus($companyId)
    {
        $company = Company::find($companyId);

        if (!$company || empty($company->company_tag)) {
            return;
        }

        // 上市代码正则：匹配全球各地上市公司股票代码后缀
        // 支持的后缀：.SH,.SZ,.BJ,.TW,.HK,.SG,.US,.DE,.FR,.JP,.KR,.N,.O,.A,.PK,.Q,.TO,.AX,.L,.WS,.U,.PR,.B,.DB,.UN,.RT,.WT,.E,.C,.D,.F,.G,.H,.I,.J,.K,.L,.M,.N,.O,.P,.V,.Y,.Z
        // 简化匹配：只要字符串中包含分隔符(.)+指定后缀，就算上市（只匹配.开头的，不匹配-开头的）
        // 支持格式：688001.SH、AAPG.O、TSLA.US、华兴源创（688001.SH）等
        // 后缀按长度从长到短排序，避免短后缀误匹配
        $stockCodePattern = '/\.(SWR|SW|WR|SS|RS|SB|PK|TO|AX|WS|PR|DB|UN|RT|WT|SH|SZ|BJ|TW|HK|SG|US|DE|FR|JP|KR|A|B|C|D|E|F|G|H|I|J|K|L|M|N|O|P|Q|R|S|U|V|W|X|Y|Z)(?![A-Za-z0-9])/i';

        $hasStockCode = preg_match($stockCodePattern, $company->company_tag);
        // 检查是否包含"新三板"
        $hasXinsanban = strpos($company->company_tag, '新三板') !== false;
        // 如果匹配到股票代码或包含"新三板"，则标记为上市
        $newMarketStatus = ($hasStockCode || $hasXinsanban) ? 1 : 0;

        // 只有状态变化才更新
        if ($company->company_market != $newMarketStatus) {
            $company->company_market = $newMarketStatus;
            $company->save();
        }
    }
}