ngds/common/helpers/Excel.php

<?php
/**
 * Created by PhpStorm.
 * User: leo
 * Date: 2018/5/17
 * Time: 上午11:34
 */

namespace common\helpers;

use common\helpers\http\RemoteUploadApi;
use common\models\ExcelAddUser;
use common\models\ExcelChangeBalance;
use common\models\ExcelImport;
use common\models\ExcelRegInfo;
use common\models\ExcelWithdrawPaidFalse;
use common\models\Export;
use common\models\ExportFile;
use common\models\forms\AdminAddUserForm;
use common\models\forms\ChangeBalanceForm;
use common\models\forms\ExcelOrderDecForm;
use common\models\forms\ExcelOrderShopForm;
use common\models\forms\ExcelOrderStandardForm;
use common\models\forms\RegInfoAuditForm;
use common\models\forms\WithdrawForm;
use common\models\Uploads;
use common\models\UserNetwork;
use yii\base\BaseObject;
use yii\base\Exception;
use yii\base\StaticInstanceTrait;

class Excel extends BaseObject {
    use StaticInstanceTrait;

    const CHILD_PATH = 'excel_export';

    public $isRemote = true;
    public $uploadInfo;
    public $exportInfo;

    private $_errors = [];
    const EXCEL_STRUCTURE = [
        'addUser' => [
            'formClass' => AdminAddUserForm::class,
            'formScenario' => 'add',
            'formAction' => 'edit',
            'errorTipField' => 'USER_NAME',
            'excelTableClass' => ExcelAddUser::class,
            'excelTableField' => [
                '序号' => 'SORT',
                '会员编号' => 'USER_NAME',
                '会员姓名' => 'REAL_NAME',
                '会员级别' => 'DEC_LV',
                '身份证' => 'ID_CARD',
                '手机' => 'MOBILE',
                '备用手机号' => 'TEL',
                '省/市' => 'AREA_PROVINCE',
                '市/区' => 'AREA_CITY',
                '区/县' => 'AREA_COUNTY',
                '身份证地址' => 'ADDRESS',
                '开户银行' => 'OPEN_BANK',
                '开户行地址' => 'BANK_ADDRESS',
                '银行账号' => 'BANK_NO',
                '银行 省/市' => 'BANK_PROVINCE',
                '银行 市/区' => 'BANK_CITY',
                '银行 区/县' => 'BANK_COUNTY',
                '是否报单中心' => 'IS_DEC',
                '报单中心级别' => 'DEC_ROLE',
                '所属报单中心编号' => 'DEC_USER_NAME',
                '生日' => 'BIRTHDAY',
                '接点人' => 'CON_USER_NAME',
                '开拓人' => 'REC_USER_NAME',
                '区位' => 'LOCATION',
            ],
            'formField' => [
                'USER_NAME' => [
                    'name' => 'userName',
                    'type' => 'common',
                ],
                'REAL_NAME' => [
                    'name' => 'realName',
                    'type' => 'common',
                ],
                'DEC_LV' => [
                    'name' => 'decLv',
                    'type' => 'table',
                    'table' => 'DECLARATION_LEVEL',
                    'field' => 'LEVEL_NAME',
                    'select' => 'ID',
                ],
                'ID_CARD' => [
                    'name' => 'idCard',
                    'type' => 'common',
                ],
                'MOBILE' => [
                    'name' => 'mobile',
                    'type' => 'common',
                ],
                'TEL' => [
                    'name' => 'tel',
                    'type' => 'common',
                ],
                'AREA_PROVINCE' => [
                    'name' => 'areaSelected',
                    'isArray' => true,
                    'type' => 'table',
                    'table' => 'REGION',
                    'field' => 'REGION_NAME',
                    'where' => 'DEEP=2',
                    'select' => 'REGION_CODE',
                ],
                'AREA_CITY' => [
                    'name' => 'areaSelected',
                    'isArray' => true,
                    'type' => 'table',
                    'table' => 'REGION',
                    'field' => 'REGION_NAME',
                    'where' => 'DEEP=3',
                    'select' => 'REGION_CODE',
                ],
                'AREA_COUNTY' => [
                    'name' => 'areaSelected',
                    'isArray' => true,
                    'type' => 'table',
                    'table' => 'REGION',
                    'field' => 'REGION_NAME',
                    'where' => 'DEEP=4',
                    'select' => 'REGION_CODE',
                ],
                'ADDRESS' => [
                    'name' => 'address',
                    'type' => 'common',
                ],
                'OPEN_BANK' => [
                    'name' => 'openBank',
                    'type' => 'table',
                    'table' => 'OPEN_BANK',
                    'field' => 'BANK_NAME',
                    'select' => 'BANK_CODE',
                ],
                'BANK_ADDRESS' => [
                    'name' => 'bankAddress',
                    'type' => 'common',
                ],
                'BANK_NO' => [
                    'name' => 'bankNo',
                    'type' => 'common',
                ],
                'BANK_PROVINCE' => [
                    'name' => 'bankAreaSelected',
                    'isArray' => true,
                    'type' => 'table',
                    'table' => 'REGION',
                    'field' => 'REGION_NAME',
                    'where' => 'DEEP=2',
                    'select' => 'REGION_CODE',
                ],
                'BANK_CITY' => [
                    'name' => 'bankAreaSelected',
                    'isArray' => true,
                    'type' => 'table',
                    'table' => 'REGION',
                    'field' => 'REGION_NAME',
                    'where' => 'DEEP=3',
                    'select' => 'REGION_CODE',
                ],
                'BANK_COUNTY' => [
                    'name' => 'bankAreaSelected',
                    'isArray' => true,
                    'type' => 'table',
                    'table' => 'REGION',
                    'field' => 'REGION_NAME',
                    'where' => 'DEEP=4',
                    'select' => 'REGION_CODE',
                ],
                'IS_DEC' => [
                    'name' => 'isDec',
                    'type' => 'bool',
                ],
                'DEC_ROLE' => [
                    'name' => 'decRoleId',
                    'type' => 'table',
                    'table' => 'DEC_ROLE',
                    'field' => 'ROLE_NAME',
                    'select' => 'ID',
                    'isAllowNull' => true,
                ],
                'DEC_USER_NAME' => [
                    'name' => 'decUserName',
                    'type' => 'common',
                ],
                'BIRTHDAY' => [
                    'name' => 'birthday',
                    'type' => 'common',
                ],
                'CON_USER_NAME' => [
                    'name' => 'conUserName',
                    'type' => 'common',
                ],
                'REC_USER_NAME' => [
                    'name' => 'recUserName',
                    'type' => 'common',
                ],
                'LOCATION' => [
                    'name' => 'location',
                    'type' => 'int',
                ],
            ]
        ],
        'withdrawPaidFalse' => [
            'formClass' => WithdrawForm::class,
            'formScenario' => 'excelPaidFalse',
            'formAction' => 'excelPaidFalse',
            'errorTipField' => 'SN',
            'excelTableClass' => ExcelWithdrawPaidFalse::class,
            'excelTableField' => [
                '序号' => 'SORT',
                '提现流水号' => 'SN',
                '提现期数' => 'WITHDRAW_PERIOD_NUM',
                '付款日期' => 'PAID_AT',
                '付款失败原因' => 'PAID_FAIL_REMARK',
                '会员编号' => 'USER_NAME',
                '会员姓名' => 'REAL_NAME',
                '实付金额' => 'AMOUNT',
                '实时开户名' => 'BANK_REAL_NAME',
                '实时银行账户' => 'BANK_NO',
            ],
            'formField' => [
                'SN' => [
                    'name' => 'sn',
                    'type' => 'common',
                ],
                'WITHDRAW_PERIOD_NUM' => [
                    'name' => 'withdrawPeriodNum',
                    'type' => 'common',
                ],
                'PAID_AT' => [
                    'name' => 'paidAt',
                    'type' => 'common',
                ],
                'PAID_FAIL_REMARK' => [
                    'name' => 'paidFailRemark',
                    'type' => 'common',
                ],
                'USER_NAME' => [
                    'name' => 'userName',
                    'type' => 'common',
                ],
                'REAL_NAME' => [
                    'name' => 'realName',
                    'type' => 'common',
                ],
                'AMOUNT' => [
                    'name' => 'amount',
                    'type' => 'common',
                ],
                'BANK_REAL_NAME' => [
                    'name' => 'bankRealName',
                    'type' => 'common',
                ],
                'BANK_NO' => [
                    'name' => 'bankNo',
                    'type' => 'common',
                ],
            ]
        ],
        'changeBalance' => [
            'formClass' => ChangeBalanceForm::class,
            'formScenario' => 'excelChangeBalance',
            'formAction' => 'excelChangeBalance',
            'errorTipField' => 'USER_NAME',
            'excelTableClass' => ExcelChangeBalance::class,
            'excelTableField' => [
                '序号' => 'SORT',
                '会员编号' => 'USER_NAME',
                '会员姓名' => 'REAL_NAME',
                '账户类型' => 'TYPE',
                '交易类型' => 'DEAL_TYPE',
                '调整金额' => 'AMOUNT',
                '备注' => 'REMARK',
                '备注是否前台显示' => 'REMARK_IS_SHOW',
            ],
            'formField' => [
                'USER_NAME' => [
                    'name' => 'userName',
                    'type' => 'common',
                ],
                'REAL_NAME' => [
                    'name' => 'realName',
                    'type' => 'common',
                ],
                'TYPE' => [
                    'name' => 'type',
                    'type' => 'param',
                    'index' => 'bonusWalletType',
                ],
                'DEAL_TYPE' => [
                    'name' => 'dealType',
                    'type' => 'table',
                    'db' => 'db',
                    'table' => 'DEAL_TYPE',
                    'field' => 'TYPE_NAME',
                    'select' => 'ID',
                ],
                'AMOUNT' => [
                    'name' => 'amount',
                    'type' => 'common',
                ],
                'REMARK' => [
                    'name' => 'remark',
                    'type' => 'common',
                ],
                'REMARK_IS_SHOW' => [
                    'name' => 'isShow',
                    'type' => 'bool',
                ],
            ]
        ],
        'regInfo' => [
            'formClass' => RegInfoAuditForm::class,
            'formScenario' => 'excelAdd',
            'formAction' => 'excelAdd',
            'errorTipField' => 'USER_NAME',
            'excelTableClass' => ExcelRegInfo::class,
            'excelTableField' => [
                '序号' => 'SORT',
                '会员编号' => 'USER_NAME',
                '会员姓名' => 'REAL_NAME',
                '身份证' => 'ID_CARD',
                '注册类型' => 'REG_TYPE',
                '注册名称' => 'REG_NAME',
                '统一社会信用代码' => 'CREDIT_CODE',
                '经营场所' => 'PREMISES',
                '注册有效期' => 'REG_EXPIRES',
                '法人' => 'LEGAL_PERSON',
                '企业开户名称' => 'OPEN_NAME',
                '企业开户银行' => 'OPEN_BANK',
                '企业开户行地址' => 'BANK_ADDRESS',
                '企业银行账号' => 'BANK_NO',
                '企业银行 省/市' => 'BANK_PROVINCE',
                '企业银行 市/区' => 'BANK_CITY',
                '企业银行 区/县' => 'BANK_COUNTY',
                '备注' => 'REMARK',
            ],
            'formField' => [
                'USER_NAME' => [
                    'name' => 'userName',
                    'type' => 'common',
                ],
                'REAL_NAME' => [
                    'name' => 'realName',
                    'type' => 'common',
                ],
                'ID_CARD' => [
                    'name' => 'idCard',
                    'type' => 'common',
                ],
                'REG_TYPE' => [
                    'name' => 'type',
                    'type' => 'table',
                    'db' => 'db',
                    'table' => 'REG_TYPE',
                    'field' => 'TYPE_NAME',
                    'select' => 'ID',
                ],
                'REG_NAME' => [
                    'name' => 'regName',
                    'type' => 'common',
                ],
                'CREDIT_CODE' => [
                    'name' => 'creditCode',
                    'type' => 'common',
                ],
                'PREMISES' => [
                    'name' => 'premises',
                    'type' => 'common',
                ],
                'REG_EXPIRES' => [
                    'name' => 'regExpires',
                    'type' => 'common',
                ],
                'LEGAL_PERSON' => [
                    'name' => 'legalPerson',
                    'type' => 'common',
                ],
                'OPEN_NAME' => [
                    'name' => 'openName',
                    'type' => 'common',
                ],
                'OPEN_BANK' => [
                    'name' => 'openBank',
                    'type' => 'table',
                    'table' => 'OPEN_BANK',
                    'field' => 'BANK_NAME',
                    'select' => 'BANK_CODE',
                    'isAllowNull' => true,
                ],
                'BANK_ADDRESS' => [
                    'name' => 'bankAddress',
                    'type' => 'common',
                    'isAllowNull' => true,
                ],
                'BANK_NO' => [
                    'name' => 'bankNo',
                    'type' => 'common',
                    'isAllowNull' => true,
                ],
                'BANK_PROVINCE' => [
                    'name' => 'bankAreaSelected',
                    'isArray' => true,
                    'type' => 'table',
                    'table' => 'REGION',
                    'field' => 'REGION_NAME',
                    'where' => 'DEEP=2',
                    'select' => 'REGION_CODE',
                    'isAllowNull' => true,
                ],
                'BANK_CITY' => [
                    'name' => 'bankAreaSelected',
                    'isArray' => true,
                    'type' => 'table',
                    'table' => 'REGION',
                    'field' => 'REGION_NAME',
                    'where' => 'DEEP=3',
                    'select' => 'REGION_CODE',
                    'isAllowNull' => true,
                ],
                'BANK_COUNTY' => [
                    'name' => 'bankAreaSelected',
                    'isArray' => true,
                    'type' => 'table',
                    'table' => 'REGION',
                    'field' => 'REGION_NAME',
                    'where' => 'DEEP=4',
                    'select' => 'REGION_CODE',
                    'isAllowNull' => true,
                ],
                'REMARK' => [
                    'name' => 'createRemark',
                    'type' => 'common',
                ],
            ]
        ],
        'orderShop' => [
            'excelTableClass' => ExcelOrderShopForm::class,
            'excelTableAction' => 'run',
        ],
        'orderDec' => [
            'excelTableClass' => ExcelOrderDecForm::class,
            'excelTableAction' => 'run',
        ],
        'orderShopStandard' => [
            'excelTableClass' => ExcelOrderStandardForm::class,
            'excelTableAction' => 'run',
        ],
    ];

    public function init() {
        parent::init();
        $this->isRemote = \Yii::$app->params['isRemoteUpload'];
    }

    /**
     * 加入错误错误
     * @param $attr
     * @param $error
     */
    public function addError($attr, $error) {
        $this->_errors[$attr][] = $error;
    }

    /**
     * 获取错误信息
     * @return array
     */
    public function getErrors() {
        return $this->_errors;
    }

    /**
     * 导出到文件
     * @param $exportId
     * @param array $dataArr
     * @param array $columns
     * @param $fileName
     * @param callable|null $callBack
     * @return bool
     */
    public function exportToFile($exportId, array $dataArr, array $columns, $fileName, callable $callBack = null) {
        $result = true;
        $headers = $columns;
        $columns = array_keys($columns);
        $fileName = $fileName . '_export_' . date('YmdHis') . uniqid() . '.xlsx';
        $path = \Yii::getAlias('@common/runtime/' . self::CHILD_PATH . '/');
        if (!is_dir($path)) {
            mkdir($path, 0755);
        }
        try {
            \sunmoon\phpspreadsheet\Excel::export([
                'models' => $dataArr,
                'columns' => $columns,
                'headers' => $headers,
                'savePath' => $path,
                'asAttachment' => false,
                'format' => 'Xlsx',
                'fileName' => $fileName,
                'exit' => false,
                'exportIterationCallback' => $callBack,
            ]);
            // 把导出的文件上传至静态文件服务器
            if ($this->isRemote) {
                $remoteUploadApi = RemoteUploadApi::instance();
                if ($uploadResult = $remoteUploadApi->upload($path . $fileName)) {
                    $this->exportInfo = [
                        'fileName' => $uploadResult['name'],
                        'url' => $uploadResult['url'],
                        'fileSize' => $uploadResult['size'] ?? null,
                        'md5' => $uploadResult['md5'] ?? null,
                    ];
                } else {
                    throw new Exception('文件远程上传失败');
                }
                // 删除本地临时文件
                unlink($path . $fileName);
            } else {
                $this->exportInfo = [
                    'fileName' => $fileName,
                    'url' => $path . $fileName,
                    'fileSize' => null,
                    'md5' => null,
                ];
            }
            // 把文件对应的相关资料存入数据库中
            $uploads = new ExportFile();
            $uploads->FILE_NAME = $this->exportInfo['fileName'];
            $uploads->EXPORT_ID = $exportId;
            $uploads->URL = $this->exportInfo['url'];
            $uploads->FILE_SIZE = $this->exportInfo['fileSize'] ?? null;
            $uploads->MD5 = $this->exportInfo['md5'] ?? null;
            $uploads->CREATED_AT = Date::nowTime();
            if (!$uploads->save()) {
                throw new Exception(Form::formatErrorsForApi($uploads->getErrors()));
            }
        } catch (\Exception $e) {
            $this->addError('export', $e->getMessage());
            $result = false;
        }
        return $result;
    }

    /**
     * 过滤读取到的数据把空的未填写的行都删掉
     * @param $data
     * @return mixed
     */
    public static function filterData(&$data) {
        foreach ($data as $key => $value) {
            $isAllNull = true;
            foreach ($value as $k => $v) {
                if ($v !== null) {
                    $isAllNull = false;
                }
            }
            if ($isAllNull) {
                unset($data[$key]);
            }
        }
        return $data;
    }

    /**
     * 分页导入数据
     * @param $excelStructureKey
     * @param $excelImportId
     * @param int $rowCount
     * @param int $startRow
     * @param int $limit
     * @return int
     * @throws Exception
     */
    public function pageImportDataFromExcel($excelStructureKey, $excelImportId, $rowCount = 1000, $startRow = 1, $limit = 1000) {
        if ($startRow > 1) {
            $startRow = $startRow + 1;
            $limit = $limit - 1;
        }
        $fileNameArray = ExcelImport::find()->select('U.FILE_NAME')->from(ExcelImport::tableName() . ' AS ET')->join('LEFT JOIN', Uploads::tableName() . ' AS U', 'ET.UPLOAD_ID=U.ID')->where('ET.ID=:ID', [':ID' => $excelImportId])->asArray()->one();
        $filePath = \Yii::getAlias('@common/runtime/uploads/' . $fileNameArray['FILE_NAME']);
        if ($startRow > $rowCount) {
            return 0;
        }
        try {
            // 临时文件不存在则创建
            $tempFileName = \Yii::getAlias('@common/runtime/uploads/' . 'importTemp.txt');
            if (!file_exists($tempFileName)) {
                $fp = fopen($tempFileName, 'w+');
                fclose($fp);
            } else {
                if ($startRow == 1) {
                    file_put_contents($tempFileName, '');
                }
            }
            $data = \sunmoon\phpspreadsheet\Excel::import($filePath, [
                'setFirstRecordAsKeys' => true,
                'readStartRow' => $startRow,
                'readEndRow' => $startRow + $limit,
                'storeFile' => $tempFileName,
                'dropKeysRow' => $startRow == 1 ? false : true,
            ]);
        } catch (\Exception $e) {
            throw new Exception($e->getMessage());
        }
        self::filterData($data);


        if ($data) {

//            if($startRow != 1){
//                unset($data[0]);
//            }
//            if(!$data) return 0;
//            self::filterData($data);
            $this->importDataToExcelTable($excelStructureKey, $excelImportId, $data);
            return 1;
        } else {
            return 0;
        }
    }

    /**
     * Excel数据导入到待导入的表中
     * @param $excelStructureKey
     * @param $excelImportId
     * @param $excelData
     */
    public function importDataToExcelTable($excelStructureKey, $excelImportId, $excelData) {
        $tableClass = self::EXCEL_STRUCTURE[$excelStructureKey]['excelTableClass'];
        $tableIndex = self::EXCEL_STRUCTURE[$excelStructureKey]['excelTableField'];
        $insertData = [];

        foreach ($excelData as $data) {
            $oneInsertData = [
                'EXCEL_IMPORT_ID' => $excelImportId,
                'CREATED_AT' => Date::nowTime(),
            ];
            foreach ($data as $key => $value) {
                $oneInsertData[$tableIndex[$key]] = $value;
            }
            $insertData[] = $oneInsertData;
        }
        $tableClass::batchInsert($insertData);
    }

    /**
     * 分页从待导入表中导入数据到真实数据中
     * @param $excelStructureKey
     * @param $excelImportId
     * @param int $offset
     * @param int $limit
     * @return int
     * @throws Exception
     */
    public function pageImportDataFromExcelTable($excelStructureKey, $excelImportId, $offset = 0, $limit = 1000) {
        $tableClass = self::EXCEL_STRUCTURE[$excelStructureKey]['excelTableClass'];
        // 获取1000条数据
        $allData = $tableClass::find()->where('EXCEL_IMPORT_ID=:EXCEL_IMPORT_ID', [':EXCEL_IMPORT_ID' => $excelImportId])->orderBy('SORT ASC')->offset($offset)->limit($limit)->asArray()->all();
        if ($allData) {
            $this->importToDbWithForm($excelStructureKey, $allData);
            return 1;
        }
        return 0;
    }

    /**
     * 通过表单类导入
     * @param $excelStructureKey
     * @param $excelDatas
     * @throws Exception
     */
    public function importToDbWithForm($excelStructureKey, $excelDatas) {
        foreach ($excelDatas as $value) {
            $formClassName = self::EXCEL_STRUCTURE[$excelStructureKey]['formClass'];
            $formScenario = self::EXCEL_STRUCTURE[$excelStructureKey]['formScenario'];
            $formAction = self::EXCEL_STRUCTURE[$excelStructureKey]['formAction'];
            $formData = $this->excelDataToFormData($excelStructureKey, $value);
            if ($formData) {
                $form = new $formClassName();
                $form->scenario = $formScenario;
                foreach ($formData as $formKey => $formValue) {
                    $form->$formKey = $formValue;
                }
                $errorTipField = self::EXCEL_STRUCTURE[$excelStructureKey]['errorTipField'];
                $tableClass = self::EXCEL_STRUCTURE[$excelStructureKey]['excelTableClass'];

                if (!$form->$formAction()) {

                    // 失败信息写入到待导入数据库excel表中
                    $tableClass::updateAll(['STATUS' => 2, 'ERROR_REMARK' => Form::formatErrorsForApi($form->getErrors())], 'ID=:ID', [':ID' => $value['ID']]);
                    throw new Exception('错误序号【'.$value['SORT'].'】会员编号【'.$value['USER_NAME'].'】。导入' . $value[$errorTipField] . '发生错误，原因：' . Form::formatErrorsForApi($form->getErrors()));
                } else {
                    $tableClass::updateAll(['STATUS' => 1], 'ID=:ID', [':ID' => $value['ID']]);
                }
            }
        }
    }

    /**
     * excel数据转为表单可提交的数据
     * @param $excelStructureKey
     * @param $excelData
     * @return array
     * @throws Exception
     */
    public function excelDataToFormData($excelStructureKey, $excelData) {
        $formFieldArr = self::EXCEL_STRUCTURE[$excelStructureKey]['formField'];
        $excelTableField = self::EXCEL_STRUCTURE[$excelStructureKey]['excelTableField'];
        $sort = $excelData['SORT'];
        $result = [];
        foreach ($excelData as $key => $value) {
            if (in_array($key, ['ID', 'EXCEL_IMPORT_ID', 'STATUS', 'ERROR_REMARK', 'CREATED_AT', 'SORT', 'ROWNUMID'])) continue;
            if (!array_key_exists($key, $formFieldArr)) {
                throw new Exception('excel表格字段不符合要求，字段为:' . $key);
            }
            $resultKey = $formFieldArr[$key]['name'];
            // 这里要判断是否允许为空值，如果允许则可以直接付空值
            if (isset($formFieldArr[$key]['isAllowNull']) && $formFieldArr[$key]['isAllowNull'] && $value === null) {
                $result[$resultKey] = $value;
            } elseif ($formFieldArr[$key]['type'] === 'common') {
                $result[$resultKey] = $value;
            } elseif ($formFieldArr[$key]['type'] === 'bool') {
                $result[$resultKey] = intval($value == '是');
            } elseif ($formFieldArr[$key]['type'] === 'int') {
                $result[$resultKey] = intval($value);
            } elseif ($formFieldArr[$key]['type'] === 'param') {
                // 从param的数据中获取
                $tempArray = \Yii::$app->params[$formFieldArr[$key]['index']];
                if ($formFieldArr[$key]['name'] === 'nation') {
                    array_unshift($tempArray, [
                        'id' => '0',
                        'name' => '',
                    ]);
                    $nationsArray = array_column($tempArray, 'name');
                    $tempResultIndex = array_search($value, $nationsArray);
                    if ($tempResultIndex === false){
                        if($errTableField = array_search($key, $excelTableField)){
                            throw new Exception('序号' . $sort . '的表格【' . $errTableField . '】值填写有误，系统中未找到填写的"' . $value . '"');
                        }else{
                            throw new Exception('序号' . $sort . '的表格' . $key . '值填写有误，系统中未找到"' . $value . '"');
                        }
                    }
                    $result[$resultKey] = $tempArray[$tempResultIndex]['id'];
                } elseif ($formFieldArr[$key]['index'] === 'bonusWalletType') {
                    $nationsArray = array_column($tempArray, 'name');
                    $tempResultIndex = array_search($value, $nationsArray);
                    if ($tempResultIndex === false){
                        if($errTableField = array_search($key, $excelTableField)){
                            throw new Exception('序号' . $sort . '的表格【' . $errTableField . '】值填写有误，系统中未找到填写的"' . $value . '"');
                        }else{
                            throw new Exception('序号' . $sort . '的表格' . $key . '值填写有误，系统中未找到"' . $value . '"');
                        }
                    }
                    $result[$resultKey] = $nationsArray[$tempResultIndex];
                }
            } elseif ($formFieldArr[$key]['type'] === 'table') {
                // 从数据库中获取对应的参数值
                $db = $formFieldArr[$key]['db'] ?? 'db';
                $field = $formFieldArr[$key]['field'];
                $select = $formFieldArr[$key]['select'];
                $table = $formFieldArr[$key]['table'];
                $where = $field . '=:' . $field;
                $where .= (isset($formFieldArr[$key]['where']) && $formFieldArr[$key]['where']) ? ' AND ' . $formFieldArr[$key]['where'] : '';
                $bindValues = [$field => $value];
                $tempResult = \Yii::$app->$db->createCommand("SELECT $select FROM {{%$table}} WHERE $where")->bindValues($bindValues)->queryOne();
                if (!$tempResult){
                    if($errTableField = array_search($key, $excelTableField)){
                        throw new Exception('序号' . $sort . '的表格【' . $errTableField . '】值填写有误，系统中未找到填写的"' . $value . '"');
                    }else{
                        throw new Exception('序号' . $sort . '的表格' . $key . '值填写有误，系统中未找到"' . $value . '"');
                    }
                }
                if (isset($formFieldArr[$key]['isArray']) && $formFieldArr[$key]['isArray']) {
                    $result[$resultKey][] = $tempResult[$select];
                } else {
                    $result[$resultKey] = $tempResult[$select];
                }

            }
        }
        return $result;
    }

    /**
     * 分页导入数据
     * @param $excelStructureKey
     * @param $excelImportId
     * @param int $rowCount
     * @param int $startRow
     * @param int $limit
     * @param int $orderDay
     * @param int $orderType
     * @return int
     * @throws Exception
     */
    public function pageImportCustomDataFromExcel($excelStructureKey, $excelImportId, $rowCount, $startRow, $limit, $orderDay, $orderType = 'cash') {
        if ($startRow > 1) {
            $startRow = $startRow + 1;
            $limit = $limit - 1;
        }
        $fileNameArray = ExcelImport::find()->select('U.FILE_NAME')->from(ExcelImport::tableName() . ' AS ET')->join('LEFT JOIN', Uploads::tableName() . ' AS U', 'ET.UPLOAD_ID=U.ID')->where('ET.ID=:ID', [':ID' => $excelImportId])->asArray()->one();
        $filePath =  \Yii::$app->params['localUpload']['dns'] . $fileNameArray['FILE_NAME'];
//        $filePath = '/ng-stage/Volumes/HDD/workshop/old/ar.upload.ming/files/' . $fileNameArray['FILE_NAME'];
        if ($startRow > $rowCount) {
            return 0;
        }
        try {
            // 临时文件不存在则创建
            $tempFileName = \Yii::getAlias('@common/runtime/uploads/' . 'import'.$excelStructureKey.'Temp.txt');
            if (!file_exists($tempFileName)) {
                $fp = fopen($tempFileName, 'w+');
                fclose($fp);
            } else {
                if ($startRow == 1) {
                    file_put_contents($tempFileName, '');
                }
            }
            $data = \sunmoon\phpspreadsheet\Excel::import($filePath, [
                'setFirstRecordAsKeys' => true,
                'readStartRow' => $startRow,
                'readEndRow' => $startRow + $limit,
                'storeFile' => $tempFileName,
                'dropKeysRow' => $startRow == 1 ? false : true,
            ]);
        } catch (\Exception $e) {
            throw new Exception($e->getMessage());
        }
        self::filterData($data);


        if ($data) {
            $tableClass = self::EXCEL_STRUCTURE[$excelStructureKey]['excelTableClass'];
            $tableAction = self::EXCEL_STRUCTURE[$excelStructureKey]['excelTableAction'];
            $form = new $tableClass();
            if (!$form->$tableAction($data,$orderDay,$orderType)) {
                return 0;
            }
            return 1;
        } else {
            return 0;
        }
    }

    /**
     * 分页导入数据
     * @param string $fileName
     * @param int $rowCount
     * @param int $startRow
     * @param int $limit
     * @return array
     * @throws Exception
     */
    public function pageImportDataByExcelFile($fileName, $rowCount = 1000, $startRow = 1, $limit = 1000) {
        if ($startRow > 1) {
            $startRow = $startRow + 1;
            $limit = $limit - 1;
        }
        $filePath = \Yii::getAlias('@common/runtime/uploads/' . $fileName);
        if ($startRow > $rowCount) {
            return [];
        }
        try {
            // 临时文件不存在则创建
            $tempFileName = \Yii::getAlias('@common/runtime/uploads/' . 'importTemp.txt');
            if (!file_exists($tempFileName)) {
                $fp = fopen($tempFileName, 'w+');
                fclose($fp);
            } else {
                if ($startRow == 1) {
                    file_put_contents($tempFileName, '');
                }
            }
            $data = \sunmoon\phpspreadsheet\Excel::import($filePath, [
                'setFirstRecordAsKeys' => true,
                'readStartRow' => $startRow,
                'readEndRow' => $startRow + $limit,
                'storeFile' => $tempFileName,
                'dropKeysRow' => $startRow == 1 ? false : true,
            ]);
        } catch (\Exception $e) {
            throw new Exception($e->getMessage());
        }
        self::filterData($data);


        if ($data) {
            return $data;
        } else {
            return [];
        }
    }

}