xinyouhe/fdesk
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

公海区分

Browse Source
This commit is contained in:
WIN-C27C5MSVTPO\16961
2025-07-30 15:15:57 +08:00
parent c8fb9f5b19
commit 269bd7168e
4 changed files with 549 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/command/ImportCustomerCommand.php
+167
View File
@@ -0,0 +1,167 @@
<?php
namespace app\command;
use app\crm\model\Country;
use app\crm\model\Customer;
use PhpOffice\PhpSpreadsheet\IOFactory;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputOption;
class ImportCustomerCommand extends Command
{
protected static $defaultName = 'import:customer';
protected static $defaultDescription = '导入Excel文件到crm_customer表';
protected function configure()
{
// $this->addArgument('file', InputArgument::REQUIRED, 'Excel文件路径')
// ->addOption('user-id', 'u', InputOption::VALUE_REQUIRED, '用户ID', 0)
// ->addOption('channel-id', 'c', InputOption::VALUE_REQUIRED, '渠道ID', 5)
// ->addOption('corp-abbr', 'a', InputOption::VALUE_REQUIRED, '公司缩写', 2);
}
protected function execute(InputInterface $input, OutputInterface $output): int
{
// $filePath = $input->getArgument('file');
// $userId = $input->getOption('user-id');
// $channelId = $input->getOption('channel-id');
// $corpAbbr = $input->getOption('corp-abbr');
$filePath = 'C:\Users\16961\Downloads\中国制造 2023-2025-询盘导出.xls';
$userId = 0;
$channelId = 5;
$corpAbbr = 2;
// 检查文件是否存在
if (!file_exists($filePath)) {
$output->writeln("<error>文件不存在: {$filePath}</error>");
return self::FAILURE;
}
try {
$output->writeln("开始导入文件: {$filePath}");
// 加载Excel文件
$output->writeln("正在加载Excel文件...");
$spreadsheet = IOFactory::load($filePath);
$worksheet = $spreadsheet->getActiveSheet();
$output->writeln("Excel文件加载成功");
// 获取数据范围
$highestRow = $worksheet->getHighestRow();
$highestColumn = $worksheet->getHighestColumn();
$output->writeln("文件包含 {$highestRow} 行数据");
// 获取所有国家数据，用于匹配
$output->writeln("正在获取国家数据...");
$countries = Country::select('id', 'cn_addr', 'en_addr')->get()->keyBy(function($item) {
return strtolower(trim($item->cn_addr));
});
$output->writeln("获取到 " . $countries->count() . " 个国家数据");
$successCount = 0;
$errorCount = 0;
$errors = [];
// 从第二行开始读取数据（第一行是标题）
$output->writeln("开始读取Excel数据...");
for ($row = 2; $row <= $highestRow; $row++) {
try {
$output->writeln("正在处理第 {$row} 行...");
// 读取各列数据 - 使用坐标方法
try {
$countryName = trim($worksheet->getCell('B' . $row)->getValue() ?? '');
$customerName = trim($worksheet->getCell('C' . $row)->getValue() ?? '');
$inquiryProduct = trim($worksheet->getCell('E' . $row)->getValue() ?? '');
} catch (\Exception $cellError) {
$output->writeln("<error>读取第{$row}行单元格时出错: " . $cellError->getMessage() . "</error>");
continue;
}
$output->writeln("读取数据: 国家={$countryName}, 客户={$customerName}, 产品={$inquiryProduct}");
// 跳过空行
if (empty($customerName)) {
continue;
}
// 查找国家ID
$countryId = 0;
if (!empty($countryName)) {
$countryKey = strtolower($countryName);
if ($countries->has($countryKey)) {
$countryId = $countries->get($countryKey)->id;
} else {
// 尝试英文名称匹配
$countryByEn = $countries->first(function($item) use ($countryName) {
return strtolower(trim($item->en_addr)) === strtolower($countryName);
});
if ($countryByEn) {
$countryId = $countryByEn->id;
}
}
}
// 检查是否已存在相同客户名
// $existingCustomer = Customer::where('contacts', $customerName)->first();
// if ($existingCustomer) {
// $output->writeln("跳过已存在的客户: {$customerName}");
// continue;
// }
// 创建客户记录
$customerData = [
'user_id' => $userId,
'corp_abbr' => $corpAbbr,
'channel_id' => $channelId,
'country_id' => $countryId,
'contacts' => $customerName,
'desc_collect' => $inquiryProduct,
'grade' => 0, // 默认等级
'magnitude' => 1, // 默认商机
'type' => 1, // 默认类型
'sex' => 0, // 默认性别
'enter_user_id' => $userId,
];
$customer = Customer::create($customerData);
$successCount++;
$output->writeln("成功导入客户: {$customerName} (ID: {$customer->id})");
} catch (\Exception $e) {
$errorCount++;
$errorMsg = "第{$row}行导入失败: " . $e->getMessage();
$errorMsg .= "\n文件: " . $e->getFile() . " 行: " . $e->getLine();
$errorMsg .= "\n堆栈: " . $e->getTraceAsString();
$errors[] = $errorMsg;
$output->writeln("<error>{$errorMsg}</error>");
}
}
$output->writeln("\n导入完成!");
$output->writeln("成功导入: {$successCount} 条记录");
$output->writeln("失败: {$errorCount} 条记录");
if (!empty($errors)) {
$output->writeln("\n错误详情:");
foreach ($errors as $error) {
$output->writeln("<error>{$error}</error>");
}
}
return self::SUCCESS;
} catch (\Exception $e) {
$output->writeln("<error>导入过程中发生错误: " . $e->getMessage() . "</error>");
$output->writeln("<error>文件: " . $e->getFile() . " 行: " . $e->getLine() . "</error>");
$output->writeln("<error>堆栈: " . $e->getTraceAsString() . "</error>");
return self::FAILURE;
}
}
}
app/crm/service/CustomerService.php
+9
View File
@@ -2,6 +2,7 @@
namespace app\crm\service;
use app\common\model\Corp;
use app\common\model\User;
use app\crm\logic\CustomerLogic;
use app\crm\model\CarType;
@@ -83,6 +84,14 @@ class CustomerService
$query->onlyTrashed();
}
if ($seas == 'seas') {
$corpId = Corp::where('abbr', $params['corp_abbr'])->first()->value('id');
if($corpId == 1){
$query->whereIn('channel_id', [1,2,3,4,5,6,7,8]);
} elseif($corpId == 3) {
$query->whereIn('channel_id', [9,10,11]);
} else{
$query->whereIn('channel_id', [0]);
}
$query->withTrashed();
}
composer.json
+2 -1
View File
@@ -43,7 +43,8 @@
"webman/redis-queue": "^2.1",
"symfony/translation": "^7.3",
"symfony/filesystem": "^7.3",
"workerman/crontab": "^1.0"
"workerman/crontab": "^1.0",
"phpoffice/phpspreadsheet": "^4.5"
},
"suggest": {
"ext-event": "For better performance. "
composer.lock
Generated
+371 -1
View File
@@ -4,7 +4,7 @@
"Read more about it at https://getcomposer.org/doc/01-basic-usage.md#installing-dependencies",
"This file is @generated automatically"
],
"content-hash": "8ef9d9a07b2be477345002a7623ea951",
"content-hash": "471a31011b58e1e514bdb9c8963055ad",
"packages": [
{
"name": "aliyuncs/oss-sdk-php",
@@ -186,6 +186,85 @@
],
"time": "2024-02-09T16:56:22+00:00"
},
{
"name": "composer/pcre",
"version": "3.3.2",
"source": {
"type": "git",
"url": "https://github.com/composer/pcre.git",
"reference": "b2bed4734f0cc156ee1fe9c0da2550420d99a21e"
},
"dist": {
"type": "zip",
"url": "https://api.github.com/repos/composer/pcre/zipball/b2bed4734f0cc156ee1fe9c0da2550420d99a21e",
"reference": "b2bed4734f0cc156ee1fe9c0da2550420d99a21e",
"shasum": ""
},
"require": {
"php": "^7.4 || ^8.0"
},
"conflict": {
"phpstan/phpstan": "<1.11.10"
},
"require-dev": {
"phpstan/phpstan": "^1.12 || ^2",
"phpstan/phpstan-strict-rules": "^1 || ^2",
"phpunit/phpunit": "^8 || ^9"
},
"type": "library",
"extra": {
"phpstan": {
"includes": [
"extension.neon"
]
},
"branch-alias": {
"dev-main": "3.x-dev"
}
},
"autoload": {
"psr-4": {
"Composer\\Pcre\\": "src"
}
},
"notification-url": "https://packagist.org/downloads/",
"license": [
"MIT"
],
"authors": [
{
"name": "Jordi Boggiano",
"email": "j.boggiano@seld.be",
"homepage": "http://seld.be"
}
],
"description": "PCRE wrapping library that offers type-safe preg_* replacements.",
"keywords": [
"PCRE",
"preg",
"regex",
"regular expression"
],
"support": {
"issues": "https://github.com/composer/pcre/issues",
"source": "https://github.com/composer/pcre/tree/3.3.2"
},
"funding": [
{
"url": "https://packagist.com",
"type": "custom"
},
{
"url": "https://github.com/composer",
"type": "github"
},
{
"url": "https://tidelift.com/funding/github/packagist/composer/composer",
"type": "tidelift"
}
],
"time": "2024-11-12T16:29:46+00:00"
},
{
"name": "defuse/php-encryption",
"version": "v2.4.0",
@@ -2524,6 +2603,191 @@
],
"time": "2024-12-08T08:18:47+00:00"
},
{
"name": "maennchen/zipstream-php",
"version": "3.1.2",
"source": {
"type": "git",
"url": "https://github.com/maennchen/ZipStream-PHP.git",
"reference": "aeadcf5c412332eb426c0f9b4485f6accba2a99f"
},
"dist": {
"type": "zip",
"url": "https://api.github.com/repos/maennchen/ZipStream-PHP/zipball/aeadcf5c412332eb426c0f9b4485f6accba2a99f",
"reference": "aeadcf5c412332eb426c0f9b4485f6accba2a99f",
"shasum": ""
},
"require": {
"ext-mbstring": "*",
"ext-zlib": "*",
"php-64bit": "^8.2"
},
"require-dev": {
"brianium/paratest": "^7.7",
"ext-zip": "*",
"friendsofphp/php-cs-fixer": "^3.16",
"guzzlehttp/guzzle": "^7.5",
"mikey179/vfsstream": "^1.6",
"php-coveralls/php-coveralls": "^2.5",
"phpunit/phpunit": "^11.0",
"vimeo/psalm": "^6.0"
},
"suggest": {
"guzzlehttp/psr7": "^2.4",
"psr/http-message": "^2.0"
},
"type": "library",
"autoload": {
"psr-4": {
"ZipStream\\": "src/"
}
},
"notification-url": "https://packagist.org/downloads/",
"license": [
"MIT"
],
"authors": [
{
"name": "Paul Duncan",
"email": "pabs@pablotron.org"
},
{
"name": "Jonatan Männchen",
"email": "jonatan@maennchen.ch"
},
{
"name": "Jesse Donat",
"email": "donatj@gmail.com"
},
{
"name": "András Kolesár",
"email": "kolesar@kolesar.hu"
}
],
"description": "ZipStream is a library for dynamically streaming dynamic zip files from PHP without writing to the disk at all on the server.",
"keywords": [
"stream",
"zip"
],
"support": {
"issues": "https://github.com/maennchen/ZipStream-PHP/issues",
"source": "https://github.com/maennchen/ZipStream-PHP/tree/3.1.2"
},
"funding": [
{
"url": "https://github.com/maennchen",
"type": "github"
}
],
"time": "2025-01-27T12:07:53+00:00"
},
{
"name": "markbaker/complex",
"version": "3.0.2",
"source": {
"type": "git",
"url": "https://github.com/MarkBaker/PHPComplex.git",
"reference": "95c56caa1cf5c766ad6d65b6344b807c1e8405b9"
},
"dist": {
"type": "zip",
"url": "https://api.github.com/repos/MarkBaker/PHPComplex/zipball/95c56caa1cf5c766ad6d65b6344b807c1e8405b9",
"reference": "95c56caa1cf5c766ad6d65b6344b807c1e8405b9",
"shasum": ""
},
"require": {
"php": "^7.2 || ^8.0"
},
"require-dev": {
"dealerdirect/phpcodesniffer-composer-installer": "dev-master",
"phpcompatibility/php-compatibility": "^9.3",
"phpunit/phpunit": "^7.0 || ^8.0 || ^9.0",
"squizlabs/php_codesniffer": "^3.7"
},
"type": "library",
"autoload": {
"psr-4": {
"Complex\\": "classes/src/"
}
},
"notification-url": "https://packagist.org/downloads/",
"license": [
"MIT"
],
"authors": [
{
"name": "Mark Baker",
"email": "mark@lange.demon.co.uk"
}
],
"description": "PHP Class for working with complex numbers",
"homepage": "https://github.com/MarkBaker/PHPComplex",
"keywords": [
"complex",
"mathematics"
],
"support": {
"issues": "https://github.com/MarkBaker/PHPComplex/issues",
"source": "https://github.com/MarkBaker/PHPComplex/tree/3.0.2"
},
"time": "2022-12-06T16:21:08+00:00"
},
{
"name": "markbaker/matrix",
"version": "3.0.1",
"source": {
"type": "git",
"url": "https://github.com/MarkBaker/PHPMatrix.git",
"reference": "728434227fe21be27ff6d86621a1b13107a2562c"
},
"dist": {
"type": "zip",
"url": "https://api.github.com/repos/MarkBaker/PHPMatrix/zipball/728434227fe21be27ff6d86621a1b13107a2562c",
"reference": "728434227fe21be27ff6d86621a1b13107a2562c",
"shasum": ""
},
"require": {
"php": "^7.1 || ^8.0"
},
"require-dev": {
"dealerdirect/phpcodesniffer-composer-installer": "dev-master",
"phpcompatibility/php-compatibility": "^9.3",
"phpdocumentor/phpdocumentor": "2.*",
"phploc/phploc": "^4.0",
"phpmd/phpmd": "2.*",
"phpunit/phpunit": "^7.0 || ^8.0 || ^9.0",
"sebastian/phpcpd": "^4.0",
"squizlabs/php_codesniffer": "^3.7"
},
"type": "library",
"autoload": {
"psr-4": {
"Matrix\\": "classes/src/"
}
},
"notification-url": "https://packagist.org/downloads/",
"license": [
"MIT"
],
"authors": [
{
"name": "Mark Baker",
"email": "mark@demon-angel.eu"
}
],
"description": "PHP Class for working with matrices",
"homepage": "https://github.com/MarkBaker/PHPMatrix",
"keywords": [
"mathematics",
"matrix",
"vector"
],
"support": {
"issues": "https://github.com/MarkBaker/PHPMatrix/issues",
"source": "https://github.com/MarkBaker/PHPMatrix/tree/3.0.1"
},
"time": "2022-12-02T22:17:43+00:00"
},
{
"name": "monolog/monolog",
"version": "2.10.0",
@@ -2831,6 +3095,112 @@
},
"time": "2020-10-15T08:29:30+00:00"
},
{
"name": "phpoffice/phpspreadsheet",
"version": "4.5.0",
"source": {
"type": "git",
"url": "https://github.com/PHPOffice/PhpSpreadsheet.git",
"reference": "2ea9786632e6fac1aee601b6e426bcc723d8ce13"
},
"dist": {
"type": "zip",
"url": "https://api.github.com/repos/PHPOffice/PhpSpreadsheet/zipball/2ea9786632e6fac1aee601b6e426bcc723d8ce13",
"reference": "2ea9786632e6fac1aee601b6e426bcc723d8ce13",
"shasum": ""
},
"require": {
"composer/pcre": "^1||^2||^3",
"ext-ctype": "*",
"ext-dom": "*",
"ext-fileinfo": "*",
"ext-gd": "*",
"ext-iconv": "*",
"ext-libxml": "*",
"ext-mbstring": "*",
"ext-simplexml": "*",
"ext-xml": "*",
"ext-xmlreader": "*",
"ext-xmlwriter": "*",
"ext-zip": "*",
"ext-zlib": "*",
"maennchen/zipstream-php": "^2.1 || ^3.0",
"markbaker/complex": "^3.0",
"markbaker/matrix": "^3.0",
"php": "^8.1",
"psr/http-client": "^1.0",
"psr/http-factory": "^1.0",
"psr/simple-cache": "^1.0 || ^2.0 || ^3.0"
},
"require-dev": {
"dealerdirect/phpcodesniffer-composer-installer": "dev-main",
"dompdf/dompdf": "^2.0 || ^3.0",
"friendsofphp/php-cs-fixer": "^3.2",
"mitoteam/jpgraph": "^10.3",
"mpdf/mpdf": "^8.1.1",
"phpcompatibility/php-compatibility": "^9.3",
"phpstan/phpstan": "^1.1 || ^2.0",
"phpstan/phpstan-deprecation-rules": "^1.0 || ^2.0",
"phpstan/phpstan-phpunit": "^1.0 || ^2.0",
"phpunit/phpunit": "^10.5",
"squizlabs/php_codesniffer": "^3.7",
"tecnickcom/tcpdf": "^6.5"
},
"suggest": {
"dompdf/dompdf": "Option for rendering PDF with PDF Writer",
"ext-intl": "PHP Internationalization Functions",
"mitoteam/jpgraph": "Option for rendering charts, or including charts with PDF or HTML Writers",
"mpdf/mpdf": "Option for rendering PDF with PDF Writer",
"tecnickcom/tcpdf": "Option for rendering PDF with PDF Writer"
},
"type": "library",
"autoload": {
"psr-4": {
"PhpOffice\\PhpSpreadsheet\\": "src/PhpSpreadsheet"
}
},
"notification-url": "https://packagist.org/downloads/",
"license": [
"MIT"
],
"authors": [
{
"name": "Maarten Balliauw",
"homepage": "https://blog.maartenballiauw.be"
},
{
"name": "Mark Baker",
"homepage": "https://markbakeruk.net"
},
{
"name": "Franck Lefevre",
"homepage": "https://rootslabs.net"
},
{
"name": "Erik Tilt"
},
{
"name": "Adrien Crivelli"
}
],
"description": "PHPSpreadsheet - Read, Create and Write Spreadsheet documents in PHP - Spreadsheet engine",
"homepage": "https://github.com/PHPOffice/PhpSpreadsheet",
"keywords": [
"OpenXML",
"excel",
"gnumeric",
"ods",
"php",
"spreadsheet",
"xls",
"xlsx"
],
"support": {
"issues": "https://github.com/PHPOffice/PhpSpreadsheet/issues",
"source": "https://github.com/PHPOffice/PhpSpreadsheet/tree/4.5.0"
},
"time": "2025-07-24T05:15:59+00:00"
},
{
"name": "phpoption/phpoption",
"version": "1.9.3",