周海龙 / globalso · 提交

转到一个项目

作者 zhl
提交 b78710ac275e4fffdc36c0b51bad5d3cc7e4be59 1 个父辈 6939f7a5

同步询盘到数据库

内嵌 并排对比
正在显示 3 个修改的文件 包含 271 行增加 和 1 行删除
<?php
/**
* Created by PhpStorm.
* User: zhl
* Date: 2025/2/13
* Time: 16:45
*/
namespace App\Console\Commands\Inquiry;
use App\Services\InquiryRelayService;
use Illuminate\Console\Command;
class SyncInquiryRelay extends Command
{
/**
* The name and signature of the console command.
*
* @var string
*/
protected $signature = 'sync_inquiry_relay';
/**
* The console command description.
*
* @var string
*/
protected $description = '同步询盘信息：站群询盘，';
/**
* Create a new command instance.
*
* @return void
*/
public function __construct()
{
parent::__construct();
}
/**
* @return bool
*/
public function handle()
{
$this->getInquiryForm();
$this->getInquirySzcm();
return true;
}
/**
* 获取表单系统中询盘信息
*/
public function getInquiryForm()
{}
/**
* 获取秋哥asp采集询盘信息
*/
public function getInquirySzcm()
{
$serveice = new InquiryRelayService();
$result = $serveice->getInquirySzcm(1);
dd($result);
}
public function saveDate($data)
{
// 数据里面 可能没有 IP 这时候需要通过 submit_country 字段获取对应国家，在通过国家随机获取IP ， 如果IP submit_country 都没有就原样记录
if (empty($data['ip'])) {
}
$country = file_get_contents("http://ip.globalso.com?ip=" . $data['ip']);
}
}
\ No newline at end of file
... ...
... ... @@ -12,6 +12,12 @@ use App\Models\Base;
*/
class InquiryInfo extends Base
{
/**
* @var string 数据表
*/
protected $table = 'gl_inquiry_info';
// TODO 之前的状态， 留下可以找到之前的程序
const STATUS_ZERO = 0;//未转发
const STATUS_ONE = 1;//无效
... ... @@ -21,5 +27,87 @@ class InquiryInfo extends Base
const STATUS_FOUR = 4;//延时转发中
protected $table = 'gl_inquiry_info';
const STATUS_INIT = 0;
const STATUS_FINISH = 1;
const STATUS_INVALID = 2;
const STATUS_FAIL = 9;
const TYPE_SITE_GROUP = 1;
const TYPE_ADS = 2;
const TYPE_AI_SITE_GROUP = 3;
const TYPE_SPIDER = 4;
/**
* 状态映射
* @return array
*/
public function statusMap()
{
return [
self::STATUS_INIT => '未处理',
self::STATUS_FINISH => '已处理',
self::STATUS_INVALID => '无效数据',
self::STATUS_FAIL => '失败数据',
];
}
/**
* 类型映射
* @return array
*/
public function typeMap()
{
return [
self::TYPE_SITE_GROUP => '站群询盘',
self::TYPE_ADS => 'ads采集站询盘',
self::TYPE_AI_SITE_GROUP => 'AI站群询盘',
self::TYPE_SPIDER => '蜘蛛询盘',
];
}
/**
* 创建新盘信息
* @param $name
* @param $phone
* @param $email
* @param $ip
* @param $country
* @param $message
* @param $message_cn
* @param $type
* @param $inquiry_date
* @param $url
* @param $url_title
* @param $url_keyword
* @param $message_sign
* @param $origin_key
* @param string $image
* @return bool
*/
public function createInquiry($name, $phone, $email, $ip, $country, $message, $message_cn, $type, $inquiry_date, $url, $url_title, $url_keyword, $message_sign, $origin_key, $image = '')
{
try {
$self = new self();
$self->name = $name;
$self->phone = $phone;
$self->email = $email;
$self->ip = $ip;
$self->country = $country;
$self->message = $message;
$self->message_cn = $message_cn;
$self->type = $type;
$self->inquiry_date = $inquiry_date;
$self->url = $url;
$self->url_title = $url_title;
$self->url_keyword = $url_keyword;
$self->image = $image;
$self->origin_key = $origin_key;
$self->message_sign = $message_sign;
$self->save();
return true;
} catch (\Exception $e) {
return false;
}
}
}
... ...
<?php
/**
* Created by PhpStorm.
* User: zhl
* Date: 2025/2/13
* Time: 11:01
*/
namespace App\Services;
use Illuminate\Support\Facades\Log;
/**
* Class InquiryRelayService
* @package App\Services
*/
class InquiryRelayService
{
/**
* 获取询盘
* @return mixed|string
*/
public function getInquiryRelay()
{
$date = date('Y-m-d');
$token = md5($date . 'qqs');
$url = 'https://form.globalso.com/api/external-interface/echo_inquriy/d1483a8e57cb485a?date=' . $date . '&token=' . $token . '&type=2';
$result = http_get($url);
return $result;
}
/**
* 获取询盘
* @param $id
* @return array|bool
*/
public function getInquirySzcm($id)
{
try {
// 获取数据
$url = "https://api.szcmapi.com/get_inquiry.aspx?id=".$id;
$json = $this->szcmCurl($url);
// 兼容过去到的数据， 比较乱
$json = trim(str_replace("\r\n", '\n', (string) $json));
$json = str_replace('3/4"','3/4',$json);
$json = str_replace('"Steklopribor"','Steklopribor',$json);
$json = str_replace('"Net30 days"','Net30 days',$json);
$json = trim($json);
$json = str_replace("\n",'',$json);
$array = json_decode($json,true);
if (empty($array))
return false;
// 整合最终数据
$title = base64_decode($array['title']);
$title = str_replace("'",'',$title);
$title = html_entity_decode($title, ENT_QUOTES, 'UTF-8');
$title = str_replace("'",'',$title);
$message = html_entity_decode(addslashes(base64_decode($array['Message'])), ENT_QUOTES, 'UTF-8');
$message = str_replace("'",'',$message);
$email = trim($array['Email']);
$name = html_entity_decode($array['Name'], ENT_QUOTES, 'UTF-8');
$name = str_replace("'",'',$name);
$result = [
'image' => $array['image'] ?: '',
'time' => $array['submit_time'] ?: date('Y-m-d H:i:s'),
'name' => $name,
'email' => $email,
'phone' => $array['Phone'] ?: '',
'refer' => $array['refer'] ?: '',
'message' => $message,
'ip' => $array['submit_ip'] ?: '',
'source_address' => 'api.szcmapi.com',
'title' => $title,
'submit_country' => $array['submit_country'] ?: '',
'origin_key' => $array['Id'],
];
return $result;
} catch (\Exception $e) {
Log::error('获取询盘： getInquirySzcm : ' . $id . ', error: ' . $e->getMessage());
return false;
}
}
/**
* @param $url
* @return bool|string
*/
public function szcmCurl($url)
{
$agent = 'ChuangMao_API_Bot';
$ch = curl_init($url);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
curl_setopt($ch, CURLOPT_HEADER, false);
curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
curl_setopt($ch, CURLOPT_USERAGENT, $agent);
curl_setopt($ch, CURLOPT_AUTOREFERER, true);
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 120);
curl_setopt($ch, CURLOPT_TIMEOUT, 120);
curl_setopt($ch, CURLOPT_MAXREDIRS, 10);
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
curl_setopt($ch, CURLOPT_SSLVERSION, 'all');
$result = curl_exec($ch);
curl_close($ch);
return $result;
}
}
\ No newline at end of file
... ...