churen/service/option/lib/Import.php

<?php

namespace Option\Lib;

use Dever;

include('/share/lib/php/dever_package/excel/src/PHPExcel.php');

class Import
{
    # 导入账户
    public function get_api()
    {
        Dever::config('base')->hook = true;
        $file = Dever::data() . 'q.xlsx';

        $data = Dever::excelImport($file, 1, 5, 'excel');

        $table = array();
        $table['head'] = array('序列号', '姓名', '手机号', '身份证号', '说明');
        $table['body'] = array();

        $table_status = array();
        $table_status['head'] = array('主账号', '子账号');
        $table_status['body'] = array();
        $table_status['body'][0][0] = 0;
        $table_status['body'][0][1] = 0;

        $check = array();

        if ($data) {
            $member = array();
            foreach ($data as $k => $v) {
                $state = preg_match(Dever::rule('mobile'), $v['C']);
                if ($state) {
                    $key = $v['A'];
                    $where['key'] = $v['A'];
                    $where['mobile'] = $v['C'];
                    $where['clear'] = true;
                    $info = Dever::db('option/member')->find($where);
                    $update = $where;
                    $update['idcard'] = $v['D'];
                    $update['name'] = $v['B'];
                    $update['main'] = $v['E'] == 1 ? 1 : 2;
                    if (!$info) {
                        $update['status'] = 2;
                        $id = Dever::db('option/member')->insert($update);
                    } else {
                        $update['where_id'] = $info['id'];
                        $id = Dever::db('option/member')->update($update);
                    }
                    if (!$id) {
                        $table['body'][] = array($update['key'], $update['name'], $update['mobile'], $update['idcard'], '账户导入失败，请重新导入');
                    } else {
                        if ($update['main'] == 2) {
                            $table_status['body'][0][1] += 1;
                        }
                    }
                    $check[$key] = 2;
                    if ($id && $update['main'] == 1) {
                        $check[$key] = 1;
                        if (!isset($member[$key])) {
                            $member[$key] = array();
                        }
                        $account = Dever::db('option/member')->find(array('mid' => $id));
                        if (!$account) {
                            $member[$key] = Dever::db('option/account')->insert(array('mid' => $id, 'audit' => 1));
                        } else {
                            $member[$key] = $account['id'];
                        }
                        if (!$member[$key]) {
                            $table['body'][] = array($update['key'], $update['name'], $update['mobile'], $update['idcard'], '生成主账户失败');
                        } else {
                            $table_status['body'][0][0] += 1;
                        }
                    }
                }
            }

            if ($member) {
                foreach ($member as $k => $v) {
                    $where = array();
                    $where['option_key'] = $k;
                    $where['set_aid'] = $v;
                    $state = Dever::db('option/member')->updates($where);
                }
            }
        }
        $result['导入状态'] = array
        (
            'type' => 'table',
            'content' => $table_status,
        );

        $result['导入异常'] = array
        (
            'type' => 'table',
            'content' => $table,
        );
        $html = Dever::show('', $result, false, false);
        return $html;
    }

    # 检测文档
    public function check_api()
    {
        Dever::config('base')->hook = true;
        $file = Dever::data() . 'q.xlsx';

        $data = Dever::excelImport($file, 1, 5, 'excel');

        $table = array();
        $table['head'] = array('序列号', '说明');
        $table['body'] = array();

        $table_status = array();
        $table_status['head'] = array('主账号', '子账号');
        $table_status['body'] = array();
        $table_status['body'][0][0] = 0;
        $table_status['body'][0][1] = 0;

        $check = array();

        if ($data) {
            $member = array();
            foreach ($data as $k => $v) {
                $state = preg_match(Dever::rule('mobile'), $v['C']);
                if ($state) {
                    $key = $v['A'];
                    $update = array();
                    $update['main'] = $v['E'] == 1 ? 1 : 2;
                    $check[$key] = 2;
                    if ($update['main'] == 1) {
                        $check[$key] = 1;
                        $table_status['body'][0][0] += 1;
                    } else {
                        $table_status['body'][0][1] += 1;
                    }
                }
            }

            if ($member) {
                foreach ($member as $k => $v) {
                    $where = array();
                    $where['option_key'] = $k;
                    $where['set_aid'] = $v;
                    $state = Dever::db('option/member')->updates($where);
                }
            }
        }
        $result['数据统计'] = array
        (
            'type' => 'table',
            'content' => $table_status,
        );

        foreach ($check as $k => $v) {
            if ($v == 2) {
                $table[$k] = array($k, '无主账号');
            }
        }

        $result['数据异常'] = array
        (
            'type' => 'table',
            'content' => $table,
        );
        $html = Dever::show('', $result, false, false);
        return $html;
    }

    # 导入交付记录
    public function get_jiaofu_api()
    {
        Dever::config('base')->hook = true;

        $file = Dever::data() . 'qiquan.xlsx';

        $data = Dever::excelImport($file, 2, 5, 'excel');

        if ($data) {
            foreach ($data as $k => $v) {
                $state = preg_match(Dever::rule('mobile'), $v['A']);
                if ($state && $v['C'] > 0) {
                    $where['mobile'] = $v['A'];
                    $type_name = $v['D'];
                    if ($type_name == '期权') {
                        $type = 1;
                    } else {
                        $type = 4;
                    }
                    $info = Dever::db('option/member')->find($where);
                    if ($info) {
                        $account = Dever::db('option/account')->find($info['aid']);
                        if ($account && $account['status'] < 3) {
                            Dever::load('option/lib/cash')->up($info['id'], $account['id'], $type, $v['C'], $v['E'], false);
                        }
                    }
                }
            }
        }
        return 'ok';
    }

    # 导入发放记录
    public function get_fafang_api()
    {
        Dever::config('base')->hook = true;
        $file = Dever::data() . 'qiquan.xlsx';

        $data = Dever::excelImport($file, 3, 5, 'excel');

        if ($data) {
            foreach ($data as $k => $v) {
                $state = preg_match(Dever::rule('mobile'), $v['A']);
                if ($state && $v['C'] > 0) {
                    $where['mobile'] = $v['A'];
                    $type_name = $v['D'];
                    if ($type_name == '期权') {
                        $type = 2;
                    } else {
                        $type = 5;
                    }
                    $info = Dever::db('option/member')->find($where);
                    if ($info) {
                        $account = Dever::db('option/account')->find($info['aid']);
                        if ($account && $account['status'] < 3) {
                            Dever::load('option/lib/cash')->up($info['id'], $account['id'], $type, $v['C'], $v['E'], false);
                        }
                    }
                }
            }
        }
        return 'ok';
    }
}