wkcrm/application/common/command/ImportFollowRecord.php

<?php
namespace app\common\command;

use app\admin\model\Record;
use app\admin\model\User;
use app\crm\model\Customer;
use think\Config;
use think\console\Command;
use think\console\Input;
use think\console\input\Argument;
use think\console\Output;
use think\Request;

class ImportFollowRecord extends Command
{
    protected function configure()
    {
        $this->setName('import:record')
            ->addArgument('file_path', null, '导入文件路径')
            ->setDescription('导入跟进记录');
    }

    protected function execute(Input $input, Output $output)
    {
        /**
         * 第三行开始、共六列
         * 
         * 客户名称*	客户号码*	跟进方式*	跟进内容*	跟进人*	 跟进时间
         */
        set_time_limit(0);
        Request::instance()->module('crm');
        Config::load(APP_PATH . '../config/database.php', 'database');

        $file_path = $input->getArgument('file_path');

        $user_list = User::field(['id', 'realname'])->select();
        $user_map = array_column($user_list, 'id', 'realname');

        if (file_exists($file_path)) {

            // 加载导入数据文件
            $objRender = \PhpOffice\PhpSpreadsheet\IOFactory::createReader('Xlsx');
            $objRender->setReadDataOnly(true);
            $ExcelObj = $objRender->load($file_path);

            // 指定工作表
            $sheet = $ExcelObj->getSheet(0);

            // 总行数
            $max_row = $sheet->getHighestRow();
            $max_column = $sheet->getHighestColumn();

            $log_file = RUNTIME_PATH . 'import_record/' . date('Y_m_d_H_i') . '.log';
            $data_file = RUNTIME_PATH . 'import_record/' . date('Y_m_d_H_i') . '.data';
            if (!file_exists(RUNTIME_PATH . 'import_record')) {
                $res = mkdir(RUNTIME_PATH . 'import_record', '0777', true);
                if (!$res) {
                    $output->writeln('Runtime 目录无权限');
                    return;
                }
            }

            $ask = $output->ask($input, '共 ' . ($max_row - 2) . ' 条数据，开始导入(yes OR no)？', 'no');
            if ($ask != 'yes') {
                $output->writeln('已取消');
                return;
            }

            for ($i = 3; $i <= $max_row; $i++) {
                $res = $sheet->rangeToArray("A{$i}:F{$i}")[0];

                $user_id = $user_map[$res[4]] ?? 1;

                $time = strtotime($res[5]);

                $mobile = preg_replace('/[^\d]/', '', $res[1]);

                $customer_id = Customer::where(['name' => $res[0], 'mobile' => $mobile])->value('customer_id');

                if (!$customer_id) {
                    $info = "{$res[0]}@{$res[1]}  未找到客户". PHP_EOL;
                    $output->writeln($info);
                    file_put_contents($log_file, $info . PHP_EOL, FILE_APPEND);

                    file_put_contents($data_file, json_encode($res) . PHP_EOL, FILE_APPEND);

                    continue;
                }

                $data = [
                    'types' => 'crm_customer',
                    'types_id' => $customer_id,
                    'content' => $res[3],
                    'category' => $res[2],
                    'next_time' => 0,
                    'business_ids' => '',
                    'contacts_ids' => '',
                    'create_time' => $time,
                    'update_time' => $time,
                    'create_user_id' => $user_id,
                ];

                if (!Record::insert($data)) {
                    $info = "{$res[0]}@{$res[1]} 写入数据库失败" . PHP_EOL;
                    $output->writeln($info);
                    file_put_contents($log_file, $info . PHP_EOL, FILE_APPEND);

                    file_put_contents($data_file, json_encode($res) . PHP_EOL, FILE_APPEND);
                }

            }

        } else {
            $output->writeln('请输入正确的文件路径');
        }
    }
}