churen/service/agent/lib/Import.php

<?php

namespace Agent\Lib;

use Dever;

class Import
{
    # 图片存放地址
    private $img_host = 'https://cryl.yijiuguanfang.com/attachment/';

    public function __construct()
    {
        $this->db = Dever::db('agent/test:old');
    }

    public function get_api()
    {
        //select count(*) as num,mobile from ims_ewei_shop_member where restatus = 0 and issuingstate = 1 and status = 1 and  prestatus = 1 and isagent = 1 group by mobile order by num desc
        # 获取已审核通过、权益已发放的用户
        $data = $this->db->fetchAll('select * from ims_ewei_shop_member where restatus = 0 and status = 1 and  prestatus = 1 and isagent = 1 order by id asc limit 10');

        print_r($data);die;

        foreach ($data as $k => $v) {

            # 创建代理商
            $where = array();
            $member = Dever::db('agent/member')->find($v['id']);
            if (!$member) {
                $data = $where;
                $data['id'] = $v['id'];
                $data['name'] = $v['realname'];
                $data['rdate'] = $v['agenttime'];
                $data['avatar'] = $v['avatar'];
                $data['username'] = $v['nickname'];
                $data['parent_mid'] = $v['agentid'];
                $data['role'] = $this->getRole($v['agentlevel']);
                $data['area'] = str_replace(' ', ',', $v['datavalue']);
                if ($v['streetvalue']) {
                    $data['area'] .= ',' . $v['streetvalue'];
                }

                if ($v['entertype'] == 1) {
                    $data['type'] = 1;
                } else {
                    $data['type'] = 2;
                }

                $data['sign'] = $v['contractsign'];
                $data['idcard'] = $v['idnumber'];
                if ($v['identity']) {
                    $identity = Dever::json_decode($v['identity']);
                    if (isset($identity[0])) {
                        $data['idcard_front'] = $identity[0];
                    }
                    if (isset($identity[1])) {
                        $data['idcard_back'] = $identity[1];
                    }
                }

                $data['company_name'] = $v['company'];

                $data['address'] = $v['province'] . $v['city'] . $v['area'] . $v['street'];

                $data['cash'] = $v['credit2'];
                $data['group_sell'] = $v['allcommission'];
                $data['status'] = 2;
                $data['import'] = 2;
                
                $mid = Dever::db('agent/member')->insert($data);
            } else {
                $mid = $v['id'];
            }

            if ($mid > 0) {
                # 创建代理商订单
                $order_where['mid'] = $mid;
                $order_where['mobile'] = $v['mobile'];
                $order_where['status'] = 4;
                $order = Dever::db('agent/order')->find($order_where);

                if (!$order) {
                    $order_data = $order_where;
                    $order_data['pay_status'] = 1;
                    $order_data['pay_status'] = 2;
                    $order_data['pay_type'] = 2;

                    $order_id = Dever::db('agent/order')->insert($order_data);
                }
            }
        }
        print_r($data);die;
    }

    # 状态对应
    private function getStatus($data)
    {
        # 完成权益发放、财务审核、初审的认为订单有效
        if ($data['issuingstate'] == 1 && $data['status'] == 1 && $data['prestatus'] == 1) {
            return 4;
        } elseif ($data['status'] == 1 && $data['prestatus'] == 1) {
            return 3;
        } elseif ($data['prestatus'] == 1) {
            return 2;
        } elseif ($data['restatus'] == 1) {
            return 5;
        } else {
            return 1;
        }
    }

    # 代理商角色对应
    private function getRole($role)
    {
        # key是历史数据 value是最新数据
        $config = array
        (
            # 创服
            5 => 5,

            # 创客
            4 => 6,

            # 逍客
            8 => 7,

            # 城市
            1 => 2,

            # 区县
            2 => 3,

            # 街道
            3 => 4,

            # 炒菜机分享会员
            6 => 8,

            # 热敏炉分享会员
            7 => 9,
        );

        if (isset($config[$role]) && $config[$role]) {
            return $config[$role];
        }

        return 1;
    }
}