* @version : HUOSDK 8.0 */ namespace huomp\logic\finance; use huo\controller\finance\AoRequest; use huo\model\agent\AgentOrderModel; use huo\model\common\CommonModel; use huo\model\user\UserModel; use huolib\constant\AgentConst; use huolib\constant\CommonConst; use huolib\tool\StrUtils; use huolib\tool\Time; class AgentOrderLogic extends CommonModel { /** * 统计总收入 今日收入 昨日收入 * * @param int $agent_id 渠道ID * @param int $role_type 角色类型 * * @return array * sum_share_total 统计总收入 * today_share_total 今日收入 * yesterday_share_total 昨日收入 */ public function getStaticShareMoney($agent_id, $role_type = AgentConst::ROLE_TYPE_AGENT) { $_sum = 'agent_gain'; if (AgentConst::ROLE_TYPE_GROUP == $role_type) { $_sum = 'parent_gain'; } $_map['agent_id'] = $agent_id; $_order_model = new AgentOrderModel(); $_rdata['sum_share_total'] = $_order_model->where($_map)->sum($_sum); list($today_start, $today_end) = Time::today(); $_map['create_time'] = ['gt', $today_start]; $_rdata['today_share_total'] = $_order_model->where($_map)->sum($_sum); $_map['create_time'] = ['between', [$today_start - CommonConst::CONST_DAY_SECONDS, $today_start]]; $_rdata['yesterday_share_total'] = $_order_model->where($_map)->sum($_sum); return $_rdata; } /** * @param array $param * * @param int $agent_id * * @return array */ protected function getWhere($param = [], $agent_id = 0) { $_map = []; if (!empty($param['start_time']) && !empty($param['start_time'])) { $_map['create_time'] = ['between', [strtotime($param['start_time']), CommonConst::CONST_DAY_SECONDS + strtotime($param['end_time'])]]; } else if (!empty($param['start_time'])) { $_map['create_time'] = ['gt', strtotime($param['start_time'])]; } else if (!empty($param['end_time'])) { $_map['create_time'] = ['lt', CommonConst::CONST_DAY_SECONDS + strtotime($param['end_time'])]; } if (!empty($param['status'])) { $_map['status'] = $param['status']; } if (!empty($param['agent_id'])) { $_map['agent_id'] = $param['agent_id']; } if (empty($_map['agent_id']) && !empty($param['agent_name'])) { $_ids = (new UserModel())->getIdsByNickName($param['agent_name']); $_map['agent_id'] = ['in', $_ids]; } if (!empty($param['parent_id'])) { $_map['parent_id'] = $param['parent_id']; } if (empty($_map['parent_id']) && !empty($param['parent_agent_name'])) { $_ids = (new UserModel())->getIdsByNickName($param['parent_agent_name']); $_map['parent_id'] = ['in', $_ids]; } if (!empty($param['order_id'])) { $_map['order_id'] = $param['order_id']; } if (!empty($param['app_id'])) { $_map['app_id'] = $param['app_id']; } if (!empty($param['flag'])) { $_map['flag'] = $param['flag']; } if (empty($_map['flag'])) { $_map['flag'] = ['in', [AoRequest::FLAG_REGISTER, AoRequest::FLAG_OPEN_GAME, AoRequest::FLAG_INVITE_REGISTER, AoRequest::FLAG_INVITE_OPEN_GAME]]; } return $_map; } /** * 获取收入记录 * * @param $param * @param string $page * @param string $order * * @return array */ public function getIncomeList($param, $page = '1,10', $order = '-create_time') { $_map = $this->getWhere($param); $_field = [ 'id' => 'id', 'order_id' => 'order_id', 'agent_id' => 'agent_id', 'app_id' => 'app_id', 'create_time' => 'create_time', 'parent_id' => 'parent_id', 'flag' => 'flag', 'status' => 'status', 'agent_gain' => 'agent_gain', 'parent_gain' => 'parent_gain', 'remark' => 'remark', ]; return $this->getList($_field, $_map, $page, $order); } /** * @param array $field * @param array $where * @param string $page * @param string $order * * @return array * @throws \think\Exception * @throws \think\db\exception\DataNotFoundException * @throws \think\db\exception\ModelNotFoundException * @throws \think\exception\DbException */ public function getList($field, $where, $page = '1,10', $order = '-create_time') { $_sum_data['agent_gain'] = 0; $_sum_data['parent_gain'] = 0; $_map = $where; $_ao_model = new AgentOrderModel(); $_count = $_ao_model->where($_map)->count(); if (empty($_count)) { return [ 'count' => 0, 'sum' => $_sum_data, 'list' => [] ]; } $_sum_field = [ 'sum(agent_gain)' => 'sum_agent_gain', 'sum(parent_gain)' => 'sum_parent_gain', ]; $_ao_sum_data = $_ao_model ->field($_sum_field) ->where($where) ->find(); if (is_object($_ao_sum_data)) { $_ao_sum_data = $_ao_sum_data->toArray(); } $_sum_data['agent_gain'] = StrUtils::formatNumber($_ao_sum_data['sum_agent_gain']); $_sum_data['parent_gain'] = StrUtils::formatNumber($_ao_sum_data['sum_parent_gain']); $_sum_data['sum_agent_gain'] = StrUtils::formatNumber($_ao_sum_data['sum_agent_gain']); $_sum_data['sum_parent_gain'] = StrUtils::formatNumber($_ao_sum_data['sum_parent_gain']); $_field = []; $_field = array_merge($_field, $field); $_order = $_ao_model->orderFilter($order); $_ao_datas = $_ao_model ->with('game,agent,parentagent') ->field($_field) ->where($where) ->order($_order) ->page($page) ->select(); if (is_object($_ao_datas)) { $_ao_datas = $_ao_datas->toArray(); } if (empty($_ao_datas)) { return [ 'count' => $_count, 'sum' => $_sum_data, 'list' => [] ]; } $_data = []; foreach ($_ao_datas as $_ao_data) { foreach ($_field as $_v) { $_list[$_v] = $_ao_data[$_v]; } $_list['agent_name'] = $_ao_data['agent']['user_nicename']; $_list['parent_name'] = !empty($_ao_data['parentagent']) ? $_ao_data['parentagent']['user_nicename'] : ''; $_list['gamename'] = !empty($_ao_data['game']) ? $_ao_data['game']['name'] : ''; $_data[] = $_list; } return [ 'count' => $_count, 'sum' => $_sum_data, 'list' => $_data ]; } }