game-sdk/simplewind/huo/logic/data/DataLogic.php

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

namespace huo\logic\data;

use huo\controller\agent\AgentCache;
use huo\controller\data\Day;
use huo\model\common\CommonModel;
use huo\model\data\DayAgentModel;
use huo\model\data\DayGameAgentModel;
use huo\model\data\DayGameModel;
use huo\model\data\DayModel;
use huo\model\game\GameextModel;
use huolib\constant\CommonConst;

class DataLogic extends CommonModel {
    private $base_filed
        = [
            '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',
            'reg_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 DayGameAgentModel();
//        try {
        $_rs = $this->updateData($_model, $_map, $data);
        if (false === $_rs) {
            // TODO: wuyonghong 2018/5/31 记录LOG
            return false;
        }
        $_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 DayGameModel();
        $_rs = $this->updateData($_model, $_map, $data);
        if (false === $_rs) {
            // TODO: wuyonghong 2018/5/31 记录LOG
            return false;
        }
        /* 更新游戏扩展信息 */
        $this->upGameExt($_map['app_id'], $data);

        return true;
    }

    /**
     * 更新每日渠道数据
     *
     * @param $data
     *
     * @return bool
     */
    public function upDayAgent($data) {
        $_map['date'] = $data['date'];
        $_map['agent_id'] = $data['agent_id'];
        $_model = new DayAgentModel();
        $_rs = $this->updateData($_model, $_map, $data, true);
        if (false === $_rs) {
            // TODO: wuyonghong 2018/5/31 记录LOG
            return false;
        }
        /* 更新渠道扩展信息 */
        $this->upAgentExt($_map['agent_id'], $data);

        return true;
    }

    /**
     * 更新每日数据
     *
     * @param $data
     *
     * @return bool
     */
    public function upDay($data) {
        $_map['date'] = $data['date'];
        $_model = new DayModel();
        $_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];
                }
            }
            if (isset($data['reg_cnt_show'])) {
                $_data['reg_cnt_show'] = $data['reg_cnt_show'];
            }
            $_rs = $model->insert($_data);
        } else {
            foreach ($this->base_filed as $_v) {
                if (isset($data[$_v])) {
                    $_data[$_v] += $data[$_v];
                }
            }
            if (isset($data['reg_cnt_show'])) {
                $_data['reg_cnt_show'] = $data['reg_cnt_show'];
            }
            $_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->getDetail($app_id);
        if (empty($_ge_data)) {
            /* 游戏不存在 */
            return true;
        }
        $_ge_data['active_cnt'] += $data['active_cnt'];
        $_ge_data['down_cnt'] += $data['down_cnt'];
        $_ge_data['real_down_cnt'] += $data['real_down_cnt'];
        $_ge_data['user_cnt'] += $data['user_cnt'];
        $_ge_data['reg_cnt'] += $data['reg_cnt'];
        $_ge_data['reg_device_cnt'] += $data['reg_device_cnt'];
        $_ge_data['pay_user_cnt'] += $data['pay_user_cnt'];
        $_ge_data['first_pay_user_cnt'] += $data['first_pay_user_cnt'];
        $_ge_data['order_cnt'] += $data['order_cnt'];
        $_ge_data['fail_order_cnt'] += $data['fail_order_cnt'];
        $_ge_data['un_order_cnt'] += $data['un_order_cnt'];
        $_ge_data['reg_order_cnt'] += $data['reg_order_cnt'];
        $_ge_data['reg_pay_cnt'] += $data['reg_pay_cnt'];
        $_ge_data['sum_money'] += $data['sum_money'];
        $_ge_data['first_pay_money'] += $data['first_pay_money'];
        $_ge_data['first_pay_sum_money'] += $data['first_pay_sum_money'];
        $_ge_data['reg_sum_money'] += $data['reg_sum_money'];

        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;
        }
        $_ae_data['history_user_cnt'] += $data['history_user_cnt'];
        $_ae_data['active_cnt'] += $data['active_cnt'];
        $_ae_data['down_cnt'] += $data['down_cnt'];
        $_ae_data['real_down_cnt'] += $data['real_down_cnt'];
        $_ae_data['user_cnt'] += $data['user_cnt'];
        $_ae_data['reg_cnt'] += $data['reg_cnt'];
        $_ae_data['reg_device_cnt'] += $data['reg_device_cnt'];
        $_ae_data['pay_user_cnt'] += $data['pay_user_cnt'];
        $_ae_data['first_pay_user_cnt'] += $data['first_pay_user_cnt'];
        $_ae_data['order_cnt'] += $data['order_cnt'];
        $_ae_data['fail_order_cnt'] += $data['fail_order_cnt'];
        $_ae_data['un_order_cnt'] += $data['un_order_cnt'];
        $_ae_data['reg_order_cnt'] += $data['reg_order_cnt'];
        $_ae_data['reg_pay_cnt'] += $data['reg_pay_cnt'];
        $_ae_data['sum_money'] += $data['sum_money'];
        $_ae_data['first_pay_money'] += $data['first_pay_money'];
        $_ae_data['first_pay_sum_money'] += $data['first_pay_sum_money'];
        $_ae_data['reg_sum_money'] += $data['reg_sum_money'];

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