game-sdk/simplewind/extend/huoAgentSwitch/logic/SwitchDataLogic.php

<?php
/**
 * SwitchDataLogic.php UTF-8
 * 切量数据产生逻辑处理
 *
 * @date    : 2018/5/31 19:37
 *
 * @license 这不是一个自由软件，未经授权不许任何使用和传播。
 * @author  : chenbingling <cbl@huosdk.com>
 * @version : HUOSDK 8.0
 */

namespace huoAgentSwitch\logic;

use huo\controller\agent\AgentCache;
use huo\controller\data\Day;
use huo\model\agent\AgentRelationModel;
use huo\model\common\CommonModel;
use huo\model\game\GameextModel;
use huoAgentSwitch\model\DayAgentSwitchModel;
use huoAgentSwitch\model\DayGameSwitchModel;
use huoAgentSwitch\model\DaySwitchModel;
use huoAgentSwitch\model\DgaSwitchModel;
use huolib\constant\AgentConst;
use huolib\constant\CommonConst;

class SwitchDataLogic extends CommonModel {
    private $base_filed
        = [
            'history_user_cnt',
            'active_cnt',
            'today_cnt',
            'ip_cnt',
            'click_cnt',
            'page_down_cnt',
            'down_cnt',
            'real_down_cnt',
            'user_cnt',
            'reg_cnt',
            'reg_device_cnt',
            'pay_user_cnt',
            'first_pay_user_cnt',
            'order_cnt',
            'fail_order_cnt',
            'un_order_cnt',
            'reg_order_cnt',
            'reg_pay_cnt',
            'sum_money',
            'sum_real_money',
            'share_money',
            'first_pay_money',
            'first_pay_sum_money',
            'reg_sum_money',
            'reg_real_sum_money',
            'day2',
            'day3',
            'day4',
            'day5',
            'day6',
            'day7',
            'day8',
            'day9',
            'day10',
            'day11',
            'day12',
            'day13',
            'day14',
            'day15',
            'day21',
            'day30',
            'day60',
            'device_day2',
            'device_day3',
            'device_day4',
            'device_day5',
            'device_day6',
            'device_day7',
            'device_day8',
            'device_day9',
            'device_day10',
            'device_day11',
            'device_day12',
            'device_day13',
            'device_day14',
            'device_day15',
            'device_day21',
            'device_day30',
            'device_day60'
        ];

    /**
     * 更新每日游戏渠道
     *
     * @param $data
     *
     * @return bool
     */
    public function upDayGameAgent($data) {
        $_map['date'] = $data['date'];
        $_map['app_id'] = $data['app_id'];
        $_map['agent_id'] = $data['agent_id'];
        $_model = new DgaSwitchModel();
//        try {
        $_rs = $this->updateData($_model, $_map, $data);
        if (false === $_rs) {
            // TODO: wuyonghong 2018/5/31 记录LOG
            return false;
        }
        if (!empty($data['origin_agent_id']) && $data['origin_agent_id'] != $data['agent_id']) {
            /* 更新原始渠道数据 */
            $_map['agent_id'] = $data['origin_agent_id'];
            $_rs = $this->updateData($_model, $_map, $data);
            if (false === $_rs) {
                // TODO: wuyonghong 2018/5/31 记录LOG
                return false;
            }
            $_agent_relation = new AgentRelationModel();
            /* 获得当前cps渠道 等级*/
            $_agent_map = ['agent_id' => $data['origin_agent_id'], 'p_id' => $data['origin_agent_id']];
            $_level = $_agent_relation->where($_agent_map)->value('level');
            for ($_i = AgentConst::AGENT_LEVEL_1; $_i < $_level; $_i++) {
                $_agent_map = ['agent_id' => $data['origin_agent_id'], 'agent_level' => $_i];
                $_p_id = $_agent_relation->where($_agent_map)->value('p_id');
                if (empty($_p_id)) {
                    continue;
                }
                /* 更新原始渠道数据 */
                $_map['agent_id'] = $_p_id;
                $_rs = $this->updateData($_model, $_map, $data);
                if (false === $_rs) {
                    // TODO: wuyonghong 2018/5/31 记录LOG
                }
            }
        }
        $_rs = $this->upDayGame($data);
        if (false === $_rs) {
            // TODO: wuyonghong 2018/5/31 记录LOG
            return false;
        }
        $_rs = $this->upDayAgent($data);
        if (false === $_rs) {
            // TODO: wuyonghong 2018/5/31 记录LOG
            return false;
        }
        $_rs = $this->upDay($data);
        if (false === $_rs) {
            // TODO: wuyonghong 2018/5/31 记录LOG
            return false;
        }

        return true;
//        } catch (DataNotFoundException $e) {
//            // TODO: wuyonghong 2018/5/31 记录LOG
//            return false;
//        } catch (ModelNotFoundException $e) {
//            // TODO: wuyonghong 2018/5/31 记录LOG
//            return false;
//        } catch (DbException $e) {
//            // TODO: wuyonghong 2018/5/31 记录LOG
//            return false;
//        } catch (Exception $e) {
//            // TODO: wuyonghong 2018/5/31 记录LOG
//            return false;
//        }
    }

    /**
     * 更新每日游戏数据
     *
     * @param $data
     *
     * @return bool
     */
    public function upDayGame($data) {
        $_map['date'] = $data['date'];
        $_map['app_id'] = $data['app_id'];
        $_model = new DayGameSwitchModel();
        $_rs = $this->updateData($_model, $_map, $data);
        if (false === $_rs) {
            // TODO: wuyonghong 2018/5/31 记录LOG
            return false;
        }

        return true;
    }

    /**
     * 更新每日渠道数据
     *
     * @param $data
     *
     * @return bool
     */
    public function upDayAgent($data) {
        $_map['date'] = $data['date'];
        $_map['agent_id'] = $data['agent_id'];
        $_model = new DayAgentSwitchModel();
        $_rs = $this->updateData($_model, $_map, $data, true);
        if (false === $_rs) {
            // TODO: wuyonghong 2018/5/31 记录LOG
            return false;
        }
        /* 更新渠道扩展信息 */
        $this->upAgentExt($_map['agent_id'], $data);
        if (!empty($data['origin_agent_id']) && $data['origin_agent_id'] != $data['agent_id']) {
            /* 更新原始渠道数据 */
            $_map['agent_id'] = $data['origin_agent_id'];
            $_rs = $this->updateData($_model, $_map, $data);
            if (false === $_rs) {
                // TODO: wuyonghong 2018/5/31 记录LOG
                return false;
            }
            /* 更新渠道扩展信息 */
            $this->upAgentExt($_map['agent_id'], $data);
            $_agent_relation = new AgentRelationModel();
            /* 获得当前cps渠道 等级*/
            $_agent_map = ['agent_id' => $data['origin_agent_id'], 'p_id' => $data['origin_agent_id']];
            $_level = $_agent_relation->where($_agent_map)->value('level');
            for ($_i = AgentConst::AGENT_LEVEL_1; $_i < $_level; $_i++) {
                $_agent_map = ['agent_id' => $data['origin_agent_id'], 'agent_level' => $_i];
                $_p_id = $_agent_relation->where($_agent_map)->value('p_id');
                if (empty($_p_id)) {
                    continue;
                }
                /* 更新原始渠道数据 */
                $_map['agent_id'] = $_p_id;
                $_rs = $this->updateData($_model, $_map, $data);
                if (false === $_rs) {
                    continue;
                    // TODO: wuyonghong 2018/5/31 记录LOG
                }
                /* 更新渠道扩展信息 */
                $this->upAgentExt($_map['agent_id'], $data);
            }
        }

        return true;
    }

    /**
     * 更新每日数据
     *
     * @param $data
     *
     * @return bool
     */
    public function upDay($data) {
        $_map['date'] = $data['date'];
        $_model = new DaySwitchModel();
        $_rs = $this->updateData($_model, $_map, $data, true);
        if (false === $_rs) {
            // TODO: wuyonghong 2018/5/31 记录LOG
            return false;
        }

        return true;
    }

    /**
     * 更新数据
     *
     * @param      $model
     * @param      $map
     * @param      $data
     * @param bool $rm_repeat
     *
     * @return mixed
     */
    public function updateData($model, $map, $data, $rm_repeat = false) {
        $_data = $data;
        $_rm_repeat = false;
        if (isset($_data['sum_login_cnt'])) {
            $_sum_login_cnt = $_data['sum_login_cnt'];
            if ($rm_repeat && $_sum_login_cnt > 1) {
                $_rm_repeat = true;
            }
            unset($_data['sum_login_cnt']);
        }
        $_map = $map;
        $_date = $data['date'];
        $_retain_day_arr = (new Day())->getRetainDayArr();
        foreach ($_retain_day_arr as $_v) {
            $_day = 'day'.$_v;
            $_device_day = 'device_day'.$_v;
            if ($_rm_repeat && $_data[$_day] > 0) {
                $_data[$_day] -= 1;
            }
            if ($_rm_repeat && $_data[$_device_day] > 0) {
                $_data[$_device_day] -= 1;
            }
            if (!empty($_data[$_day]) || !empty($_data[$_device_day])) {
                $_map['date'] = date('Y-m-d', strtotime($_date) - CommonConst::CONST_DAY_SECONDS * ($_v - 1));
                $_day_data[$_day] = $_data[$_day];
                $_day_data[$_device_day] = $_data[$_device_day];
                $this->updateOrInsert($model, $_map, $_day_data);
            }
            unset($_data[$_day]);
            unset($_data[$_device_day]);
        }
        if ($_rm_repeat && $_data['user_cnt'] > 0) {
            $_data['user_cnt'] -= 1;
        }

        return $this->updateOrInsert($model, $map, $_data);
    }

    /**
     * 更新或插入
     *
     * @param $model
     * @param $_map
     * @param $data
     *
     * @return mixed
     */
    public function updateOrInsert($model, $_map, $data) {
        $_data = $model->where($_map)->find();
        if (is_object($_data)) {
            $_data = $_data->toArray();
        }
        if (empty($_data)) {
            $_data = $_map;
            foreach ($this->base_filed as $_v) {
                if (isset($data[$_v])) {
                    $_data[$_v] = $data[$_v];
                }
            }
            $_rs = $model->insert($_data);
        } else {
            foreach ($this->base_filed as $_v) {
                if (isset($data[$_v])) {
                    $_data[$_v] += $data[$_v];
                }
            }
            $_rs = $model->where(['id' => $_data['id']])->update($_data);
        }

        return $_rs;
    }

    /**
     * 更新渠道扩展信息
     *
     * @param int   $app_id
     * @param array $data
     *
     * @return bool
     */
    public function upGameExt($app_id, $data) {
        if (empty($app_id)) {
            /* 不需要更新 */
            return true;
        }
        $_gc_class = new GameextModel();
        $_ge_data = $_gc_class->getInfoById($app_id);
        if (empty($_ge_data)) {
            /* 游戏不存在 */
            return true;
        }
        $_files = array(
            'active_cnt',
            'down_cnt',
            'real_down_cnt',
            'user_cnt',
            'reg_cnt',
            'reg_device_cnt',
            'pay_user_cnt',
            'first_pay_user_cnt',
            'order_cnt',
            'fail_order_cnt',
            'un_order_cnt',
            'reg_order_cnt',
            'reg_pay_cnt',
            'sum_money',
            'first_pay_money',
            'first_pay_sum_money',
            'reg_sum_money'
        );
        foreach ($_files as $f) {
            if (isset($data[$f])) {
                $_ge_data[$f] += $data[$f];
            }
        }
        if (empty($_ge_data)) {
            return true;
        }

        return $_gc_class->updateData($_ge_data, $app_id);
    }

    /**
     * 更新渠道扩展信息
     *
     * @param int   $agent_id
     * @param array $data
     *
     * @return bool
     */
    public function upAgentExt($agent_id = 0, $data) {
        if (empty($agent_id)) {
            /* 不需要更新 */
            return true;
        }
        $_ac_class = AgentCache::ins();
        $_ae_data = $_ac_class->getAgentExtByAgentId($agent_id);
        if (empty($_ae_data)) {
            /* 渠道不存在 */
            return true;
        }
        $_files = array(
            'history_user_cnt',
            'active_cnt',
            'down_cnt',
            'real_down_cnt',
            'user_cnt',
            'reg_cnt',
            'reg_device_cnt',
            'pay_user_cnt',
            'first_pay_user_cnt',
            'order_cnt',
            'fail_order_cnt',
            'un_order_cnt',
            'reg_order_cnt',
            'reg_pay_cnt',
            'sum_money',
            'first_pay_money',
            'first_pay_sum_money',
        );
        foreach ($_files as $f) {
            if (isset($data[$f])) {
                $_ae_data[$f] -= $data[$f];
            }
        }
        if (empty($_ae_data)) {
            return true;
        }

        return $_ac_class->updateAgentExt($agent_id, $_ae_data);
    }
}