<?php

/**
 * Notes:临时数据操作
 * Created on: 2021/9/18 17:15
 * Created by: dengbw
 */
class Temp extends HD_Controller
{

    private $log_file;

    public function __construct()
    {
        parent::__construct();
        $this->log_file = 'temp.log';
    }

    /**
     * Notes:更新客户线下来源
     * Created on: 2022/3/09 11:58
     * Created by: dengbw
     * https://liche-api-dev.xiaoyu.com/plan/temp/receiver_customer_of
     * https://api.liche.cn/plan/temp/receiver_customer_of
     */
    public function receiver_customer_of()
    {
        $this->load->model('receiver/receiver_customers_model', 'mdCustomers');
        $param = $this->input->get();
        $param['page'] = intval($param['page']);
        $param['size'] = intval($param['size']);
        !$param['size'] && $param['size'] = 50;
        !$param['page'] && $param['page'] = 1;
        $counts = intval($param['counts']);
        ob_start(); //打开缓冲区
        $where = array("cf_clues !=''" => null, 'of_id' => 0);
        $res = $this->mdCustomers->select($where, 'id ASC', $param['page'], $param['size'], 'id,cf_clues');
        if (!$res) {
            echo '<br>本次更新客户线下来源完成了：';
            echo '<br><br>成功更新 <span style="color: red;">' . $counts . '</span> 条';
            echo '<br><br><a href="/plan/temp/receiver_customer_of">点击将再次更新客户线下来源>>></a>';
            exit;
        }
        $log = array();
        foreach ($res as $key => $value) {
            $of_id = 0;
            $cf_clues = $value['cf_clues'];
            if ($cf_clues == '自然进店') {
                $of_id = 1;
            } else if ($cf_clues == '外展' || $cf_clues == 'DM' || $cf_clues == '外展外拓') {
                $of_id = 4;
            } else if ($cf_clues == '转介绍') {
                $of_id = 2;
            } else if ($cf_clues == '网站' || $cf_clues == '垂直媒体') {
                $of_id = 3;
            } else if ($cf_clues == '自媒体' || $cf_clues == '其他') {
                $of_id = 5;
            }
            if ($of_id) {
                $this->mdCustomers->update(['of_id' => $of_id], ['id' => $value['id']]);
                $log[] = array('id' => $value['id'], 'of_id' => $of_id);
                $counts++;
            }
        }
        echo '<br>成功更新：';
        $log && print_r($log);
        echo '<br><br>数据库获取：';
        echo json_encode($res, JSON_UNESCAPED_UNICODE);
        header('refresh:3;url=/plan/temp/receiver_customer_of?counts=' . $counts . '&size=' . $param['size'] . '&page=' . ($param['page'] + 1));
        ob_end_flush();//输出全部内容到浏览器
    }

    /**
     * Notes:新增街道
     * Created on: 2021/12/14 11:58
     * Created by: dengbw
     * https://liche-api-dev.xiaoyu.com/plan/temp/add_street
     * https://api.liche.cn/plan/temp/add_street
     */
    public function add_street()
    {
        $this->load->model('sys/Sys_area_model', 'mdSysArea');
        $this->load->model('sys/Sys_street_model', 'mdSysStreet');
        $this->load->model('sys/Bs_street_model', 'mdBsStreet');//表已经删除
        $param = $this->input->get();
        $param['page'] = intval($param['page']);
        $param['size'] = intval($param['size']);
        !$param['size'] && $param['size'] = 5;
        !$param['page'] && $param['page'] = 1;
        $counts = intval($param['counts']);
        ob_start(); //打开缓冲区
        $res = $this->mdSysArea->select(['status' => 1], 'id ASC', $param['page'], $param['size'], 'county_id');
        if (!$res) {
            echo '<br>本次新增街道完成了：';
            echo '<br><br>成功新增街道 <span style="color: red;">' . $counts . '</span> 条';
            echo '<br><br><a href="/plan/temp/add_street">点击将再次新增街道>>></a>';
            exit;
        }
        $log = array();
        foreach ($res as $key => $value) {
            $res_bs = $this->mdBsStreet->select(['AREA_CODE' => $value['county_id']], 'STREET_ID ASC', 0, 0, 'STREET_CODE,STREET_NAME');
            $add = [];
            foreach ($res_bs as $key2 => $value2) {
                $add[] = ['county_id' => $value['county_id'], 'street_id' => $value2['STREET_CODE'], 'street_name' => $value2['STREET_NAME']];
                $log[] = array('street_name' => $value2['STREET_NAME'], 'street_id' => $value2['STREET_CODE']);
                $counts++;
            }
            if ($add) {
                $this->mdSysStreet->add_batch($add);
            }
        }
        echo '<br>成功更新：';
        $log && print_r($log);
        echo '<br><br>数据库获取：';
        echo json_encode($res, JSON_UNESCAPED_UNICODE);
        header('refresh:3;url=/plan/temp/add_street?counts=' . $counts . '&size=' . $param['size'] . '&page=' . ($param['page'] + 1));
        ob_end_flush();//输出全部内容到浏览器
    }

    /**
     * Notes:更新狸车宝渠道门店
     * Created on: 2021/9/18 11:58
     * Created by: dengbw
     * https://liche-api-dev.xiaoyu.com/plan/temp/channel_biz
     * https://api.liche.cn/plan/temp/channel_biz
     */
    public function channel_biz()
    {
        $this->load->model('app/licheb/App_licheb_users_model', 'mdUsers');
        $this->load->model('app/licheb/App_licheb_channel_biz_model', 'mdChannelBiz');
        $param = $this->input->get();
        $param['page'] = intval($param['page']);
        $param['size'] = intval($param['size']);
        !$param['size'] && $param['size'] = 50;
        !$param['page'] && $param['page'] = 1;
        $counts = intval($param['counts']);
        ob_start(); //打开缓冲区
        $where = array('status ' => 1, 'group_id' => 4);
        $res = $this->mdUsers->select($where, 'id ASC', $param['page'], $param['size'], 'id,biz_id,uname');
        if (!$res) {
            echo '<br>本次更新狸车宝渠道门店完成了：';
            echo '<br><br>成功更新 <span style="color: red;">' . $counts . '</span> 条';
            echo '<br><br><a href="/plan/temp/channel_biz">点击将再次更新狸车宝渠道门店>>></a>';
            exit;
        }
        $log = array();
        foreach ($res as $key => $value) {
            if ($value['biz_id']) {
                $biz_id_arr = explode(',', $value['biz_id']);
                foreach ($biz_id_arr as $key2 => $value2) {
                    $where = ["uid" => $value['id'], 'biz_id' => $value2];
                    $re_cb = $this->mdChannelBiz->get($where);
                    if (!$re_cb) {
                        $where['c_time'] = time();
                        $this->mdChannelBiz->add($where);
                    }
                }
                $log[] = array('uname' => $value['uname'], 'biz_id' => $value['biz_id']);
                $counts++;
            }
        }
        echo '<br>成功更新：';
        $log && print_r($log);
        echo '<br><br>数据库获取：';
        echo json_encode($res, JSON_UNESCAPED_UNICODE);
        header('refresh:3;url=/plan/temp/channel_biz?counts=' . $counts . '&size=' . $param['size'] . '&page=' . ($param['page'] + 1));
        ob_end_flush();//输出全部内容到浏览器
    }

    /**
     * Notes:更新商品操作日志
     * Created on: 2021/9/18 11:58
     * Created by: dengbw
     * https://liche-api-dev.xiaoyu.com/plan/temp/items_oplogs
     * https://api.liche.cn/plan/temp/items_oplogs
     */
    public function items_oplogs()
    {
        $this->load->model('items/items_model', 'mdItems');
        $this->load->model('items/items_oplogs_model', 'mdItemsOplogs');
        $this->load->library('entity/items_entity');
        $param = $this->input->get();
        $param['page'] = intval($param['page']);
        $param['size'] = intval($param['size']);
        !$param['size'] && $param['size'] = 50;
        !$param['page'] && $param['page'] = 1;
        $counts = intval($param['counts']);
        ob_start(); //打开缓冲区
        $where = array('status >' => 0, 'in_time <>' => '0000-00-00 00:00:00');
        $res = $this->mdItems->select($where, 'id ASC', $param['page'], $param['size'], 'id,biz_id,addr_id,in_time');
        if (!$res) {
            echo '<br>本次更新商品操作日志完成了：';
            echo '<br><br>成功更新 <span style="color: red;">' . $counts . '</span> 条';
            echo '<br><br><a href="/plan/temp/items_oplogs">点击将再次更新商品操作日志>>></a>';
            exit;
        }
        $log = array();
        foreach ($res as $key => $value) {
            $re_c = $this->mdItemsOplogs->get(array('item_id' => $value['id'], 'biz_id' => $value['biz_id'], 'type' => 1));
            if (!$re_c['id']) {
                if ($value['biz_id'] == -1 && !$value['addr_id']) {
                    continue;
                }
                $params = array('item_id' => $value['id'], 'type' => 1, 'uid' => 0, 'uname' => '系统'
                , 'com_time' => $value['in_time'], 'biz_id' => $value['biz_id'], 'addr_id' => $value['addr_id']);
                $this->items_entity->add_log($params);
                $log[] = array('id' => $value['id']);
                $counts++;
            }
        }
        echo '<br>成功更新：';
        $log && print_r($log);
        echo '<br><br>数据库获取：';
        echo json_encode($res, JSON_UNESCAPED_UNICODE);
        header('refresh:3;url=/plan/temp/items_oplogs?counts=' . $counts . '&size=' . $param['size'] . '&page=' . ($param['page'] + 1));
        ob_end_flush();//输出全部内容到浏览器
    }

    /**
     * Notes:更新客户表来源id
     * Created on: 2021/9/18 11:58
     * Created by: dengbw
     * https://liche-api-dev.xiaoyu.com/plan/temp/receiver_customer
     * https://api.liche.cn/plan/temp/receiver_customer
     */
    public function receiver_customer()
    {
        $this->load->model('receiver/receiver_clues_model', 'mdClues');
        $this->load->model('receiver/receiver_customers_model', 'mdCustomers');
        $param = $this->input->get();
        $param['page'] = intval($param['page']);
        $param['size'] = intval($param['size']);
        !$param['size'] && $param['size'] = 50;
        !$param['page'] && $param['page'] = 1;
        $counts = intval($param['counts']);
        ob_start(); //打开缓冲区
        $where = array('rid >' => 0);
        $res = $this->mdCustomers->select($where, 'id ASC', $param['page'], $param['size'], 'id,rid,cf_id');
        if (!$res) {
            echo '<br>本次更新客户来源id完成了：';
            echo '<br><br>成功更新 <span style="color: red;">' . $counts . '</span> 条';
            echo '<br><br><a href="/plan/xmcard/tem_wxqy">点击将再次更新客户来源id>>></a>';
            exit;
        }
        $log = array();
        foreach ($res as $key => $value) {
            $re_c = $this->mdClues->get(array('id' => $value['rid']));
            if ($re_c['cf_id']) {
                $this->mdCustomers->update(array('cf_id' => $re_c['cf_id']), array('id' => $value['id']));
                $log[] = array('id' => $value['id'], 'cf_id' => $re_c['cf_id']);
                $counts++;
            }
        }
        echo '<br>成功更新：';
        $log && print_r($log);
        echo '<br><br>数据库获取：';
        echo json_encode($res, JSON_UNESCAPED_UNICODE);
        header('refresh:3;url=/plan/temp/receiver_customer?counts=' . $counts . '&size=' . $param['size'] . '&page=' . ($param['page'] + 1));
        ob_end_flush();//输出全部内容到浏览器
    }

    //更新下定时间
    public function order_time()
    {
        $this->load->model('receiver/order/receiver_orders_model');
        $this->load->model('app/liche/app_liche_orders_model');

        $param = $this->input->get();
        $param['page'] = intval($param['page']);
        $param['size'] = intval($param['size']);
        !$param['size'] && $param['size'] = 50;
        !$param['page'] && $param['page'] = 1;

        $where = [
            'status>' => 0,
            'order_time' => '0000-00-00 00:00:00',
        ];
        $rows = $this->receiver_orders_model->select($where, 'id ASC', $param['page'], $param['size'], 'id');
        if ($rows) {
            foreach ($rows as $key => $val) {
                $pay_row = $this->app_liche_orders_model->get(['o_id' => $val['id'], 'status' => 1, 'type' => 1]);
                if (!$pay_row) {
                    $pay_row = $this->app_liche_orders_model->get(['o_id' => $val['id'], 'status' => 1, 'type' => 4]);
                }
                if ($pay_row) {
                    $this->receiver_orders_model->update(['order_time' => $pay_row['pay_time']], ['id' => $val['id']]);
                }
            }
            $ids = implode(',', array_column($rows, 'id'));
            echo "do:{$ids} ";
        } else {
            echo 'finish';
        }
    }

    //创建支付订单
    public function c_payorder()
    {
        $this->load->model('receiver/order/receiver_orders_model');
        $this->load->model('app/liche/app_liche_users_model');
        $this->load->model('app/liche/app_liche_orders_model');
        $this->load->library('receiver/orders_entity');

        $params = $this->input->get();
        $params['page'] = intval($params['page']);
        $params['size'] = intval($params['size']);
        !$params['size'] && $params['size'] = 10;
        !$params['page'] && $params['page'] = 1;

        if ($params['id']) {
            $where = [
                'id' => $params['id']
            ];
        } else {
            $where = [
                'status>' => 0,
                'status<' => 3,
                'biz_id !=' => 1
            ];
        }
        $rows = $this->receiver_orders_model->select($where, 'id asc', $params['page'], $params['size']);
        if ($rows) {
            $data = [];
            foreach ($rows as $key => $val) {
                $userinfo = $this->app_liche_users_model->get(['mobile' => $val['mobile']]);
                $result = $this->orders_entity->check_finish_v2($val['id'], $userinfo);
                $data[] = [
                    'id' => $val['id'],
                    'result' => $result,
                ];
            }
            echo json_encode($data, JSON_UNESCAPED_UNICODE);
        } else {
            echo 'finish';
        }
    }
}