<?php

class Account_entity{

    const TYPE_USER = 'user';
    const TYPE_BIZ = 'biz';
    const AC_TYPE_USER = 1;
    const AC_TYPE_BIZ = 2;

    const MONEY_FLOW_IN = 'in'; //资金流入
    const MONEY_FLOW_OUT = 'out'; //资金流出

    const TRADE_TYPE_CONSUME = 1; //入账
    const TRADE_TYPE_CASH = 2; //提现
    const TRADE_TYPE_CHARGE = 3; //冲正
    const TRADE_TYPE_TRANSFER = 4; //转账

    private $appid;
    private $ci;

    /**
     * 记账户流水暂存的余额
     * @var array
     */
    private $arr_tr_mleft = array();

    public function __construct($appid,$params=[]){
        $this->ci = & get_instance();
        $this->ci->load->model('app/user_account_model','account_model');
        $this->ci->load->model('app/user_accountlog_model','accountlog_model');
        $this->account_model = $this->ci->account_model;
        $this->accountlog_model = $this->ci->accountlog_model;
        $this->app_id = $appid;
        $params['order_id'] && $this->order_id = $params['order_id'];
        $params['jsondata'] && $this->jsondata = $params['jsondata'];
        $params['ck'] && $this->ck = $params['ck'];
    }
    
    /**
     * 充值
     * @param $account_id (账户ID)
     * @param $money (金额)
     * @param string $descrip (描述)
     * @param array $svr (account_id, rate)
     * @return array (sql数组)
     */
    public function charge($account_id, $money, $descrip = ''){

        $trade_type = self::TRADE_TYPE_CONSUME;
        !$descrip && $descrip = '入账';

        $ids = array($account_id);

        //日志余额
        $mleft = $this->get_logmleft($ids);

        /*交易开始*/
        $this->trade_start();

        $this->arr_tr_mleft = $mleft;
        $this->arr_tr_param = array('trade_type' => $trade_type, 'descrip' => $descrip);

        //入账
        $this->tr_money($account_id, $money, self::MONEY_FLOW_IN);

        $ret = $this->trade_complete();
        /*交易结束*/

        return $ret;
    }

    /**
     * 提现
     * @param $account_id
     * @param $money
     * @param string $descrip
     */
    public function cash($account_id, $money, $descrip = '提现'){
        $trade_type = self::TRADE_TYPE_CASH;

        //日志余额
        $mleft = $this->get_logmleft([$account_id]);

        /*交易开始*/
        $this->trade_start();

        $this->arr_tr_mleft = $mleft;
        $this->arr_tr_param = array('trade_type' => $trade_type, 'descrip' => $descrip);

        //入账
        $this->tr_money($account_id, $money, self::MONEY_FLOW_OUT);

        $ret = $this->trade_complete();
        /*交易结束*/

        return $ret;
    }

    /**
     * 获取存交易流水的余额
     * @param $account_ids
     * @return array
     */
    public function get_logmleft($account_ids){

        $mleft = array();
        foreach($account_ids as $v){
            $log = $this->get_accountlog('last', $v);
            $money_left = floatval($log['money_left']);

            if($money_left <= 0){
                $account = $this->get_account($v);
                $money_left = floatval($account['money_left']);
            }

            $mleft[$v] = $money_left;
        }

        return $mleft;
    }

    /**
     * 获取一条账户日志
     * @param string $type 类型(last 最后一条)
     * @param $account_id
     * @param $logid
     * @return mixed
     */
    public function get_accountlog($type = 'last', $account_id = 0, $logid = 0){
        $where = array();
        $account_id && $where['account_id'] = $account_id;
        $logid && $where['id'] = $logid;
        switch($type){
            default:
                $order = 'id DESC';
        }
        $list = $this->accountlog_model->select($where, $order, 1, 1);

        return $list ? $list[0] : array();
    }
    /**
     * 获取账户
     * @param $id (根据type组合)
     * @param $type (user|biz|sys)
     * @return mixed
     */
    public function get_account($id, $type = ''){
        $where = array('app_id' => $this->app_id);
        switch($type){
            case 'user':
                $where['type'] = self::AC_TYPE_USER;
                $where['app_uid'] = $id;
                break;
            case 'biz':
                $where['type'] = self::AC_TYPE_BIZ;
                $where['biz_id'] = $id;
                break;
            default:
                $where['id'] = $id;
        }

        $account = $this->account_model->get($where);

        return $account;
    }
    /**
     *
     * 开户
     * @param $id (根据type 可以是uid、biz_id)
     * @param string $type (user|biz)
     * @return int
     */
    public function new_account($id, $type = ''){
        $data = array('app_id' => $this->app_id, 'c_time' => time());
        switch($type){
            case self::TYPE_USER:
                $data['type'] = self::AC_TYPE_USER;
                $data['app_uid'] = $id;
                break;
            case self::TYPE_BIZ:
                $data['type'] = self::AC_TYPE_BIZ;
                $data['biz_id'] = $id;
                break;
            default:
                return 0;
        }
        $id = $this->account_model->add($data);

        return $id;
    }

    /**
     * 交易开始
     */
    public function trade_start(){
        $this->is_tr = true;
        $this->arr_tr_mleft = array();
        $this->arr_tr_param = array();
        $this->sql_array = array();
        //生成交易ID
        $this->sid = date('Ymd') . time() . str_pad(rand(0, 999), 3, '0', STR_PAD_LEFT);
    }
    /**
     * 交易完成
     * @return array
     */
    public function trade_complete(){
        $sql_arr = $this->sql_array;

        $status = true;
        $msg = '';

        if(!$this->is_tr){
            $status = false;
            $msg = '交易未初始化';
            goto end;
        }

        if(!$sql_arr){
            $status = false;
            $msg = '无交易数据';
            goto end;
        }

        end:
        //设置交易结束
        $this->is_tr = false;
        $this->arr_tr_mleft = array();
        $this->arr_tr_param = array();
        $this->sql_array = array();

        if(!$status){
            $sql_arr = array();
        }

        return $sql_arr;
    }
    /**
     * 交易金额
     * @param $account_id
     * @param $money (金额)
     * @param $type (资金类型)
     */
    protected function tr_money($account_id, $money, $type = 'in'){

        $money = floatval($money);

        if('out' == $type){
            $logmoney = -$money;
            $sql = "UPDATE `lc_app_user_account` SET money_left = money_left-{$money} WHERE id = {$account_id} AND money_left >= {$money}";
        } else {
            $logmoney = $money;
            $sql = "UPDATE `lc_app_user_account` SET money_total=money_total+{$money}, money_left = money_left+{$money} WHERE id = {$account_id}";
        }

        $this->sql_array[] = $sql;

        $this->tr_accountlog($account_id, $logmoney);
    }
    /**
     * 记录money log
     * @param $account_id (账户ID
     * @param $money (金额，负数表示出账)
     */
    private function tr_accountlog($account_id, $money){
        $descrip = $this->arr_tr_param['descrip'];

        $trade_type = $this->arr_tr_param['trade_type'];

        $money_left = $this->arr_tr_mleft[$account_id];
        $money_left += $money;//计算这次日志余额
        $this->arr_tr_mleft[$account_id] = $money_left;

        $c_time = $this->arr_tr_param['c_time'];
        !$c_time && $c_time = time();

        $data = array(
            'account_id' => $this->ci->db->escape($account_id),
            'trade_type' => $trade_type,
            'money_type' => 0,
            'money_in' => $money>0?$this->ci->db->escape($money):0,
            'money_out' => $money<0?$this->ci->db->escape(abs($money)):0,
            'money_left' => $money_left,
            'descrip' => $this->ci->db->escape($descrip),
            'c_time' => $this->ci->db->escape($c_time),
        );
        $this->ck && $data['ck'] = $this->ci->db->escape($this->ck);
		$this->order_id && $data['sid'] = $this->order_id;
        if($this->jsondata && is_array($this->jsondata)){
            $data['jsondata'] = "'".json_encode($this->jsondata,JSON_UNESCAPED_UNICODE)."'";
        }

        $str_key = '`' . implode('`,`', array_keys($data)) .'`';
        $str_val = "" . implode(",", array_values($data));
        $this->sql_array[] = "INSERT INTO `lc_app_user_accountlog` ({$str_key}) VALUES ($str_val)";
    }
}