* @version : HUOSDK 8.0 */ namespace huo\logic\finance; use huo\logic\member\MemberLogic; use huo\model\common\CommonModel; use huo\model\finance\PtbChargeModel; use huolib\constant\CommonConst; use huolib\tool\StrUtils; class PtbChargeLogic extends CommonModel { /** * @param array $param * * @return array */ protected function getWhere($param = []) { $_map = []; if (!empty($param['start_time']) && !empty($param['end_time'])) { $_map['ptb_charge_model.create_time'] = ['between', [strtotime($param['start_time']), CommonConst::CONST_DAY_SECONDS + strtotime( $param['end_time'] )]]; } else if (!empty($param['start_time'])) { $_map['ptb_charge_model.create_time'] = ['gt', strtotime($param['start_time'])]; } else if (!empty($param['end_time'])) { $_map['ptb_charge_model.create_time'] = ['lt', CommonConst::CONST_DAY_SECONDS + strtotime($param['end_time'])]; } if (!empty($param['order_id'])) { $_map['order_id'] = $param['order_id']; } if (!empty($param['mem_id'])) { $_map['mem_id'] = $param['mem_id']; } if (!empty($param['from_id'])) { $_map['from_id'] = $param['from_id']; } if (!empty($param['status'])) { $_map['ptb_charge_model.status'] = $param['status']; } if (!empty($param['type'])) { $_map['ptb_charge_model.type'] = $param['type']; } if (!empty($param['username'])) { $_mem_ids = (new MemberLogic())->getIdsByUsername($param['username']); $_map['ptb_charge_model.mem_id'] = ['in', $_mem_ids]; } return $_map; } public function getField($agent_id) { return []; } /** * 获取获取记录 * * @param $mem_id * @param $param * @param string $page * @param string $order * * @return array */ public function getMemList($mem_id, $param = [], $page = '1,10', $order = '-create_time') { $_map = $this->getWhere($param); $_field = $this->getField($mem_id); if (!empty($mem_id)) { $_map['mem_id'] = $mem_id; } return $this->getList($_field, $_map, $page, $order); } /** * 获取列表 * * @param array $field * @param array $where * @param string $page * @param string $order * * @return array */ public function getList($field = [], $where, $page = '1,10', $order = '-create_time') { $_map = $where; $_model = new PtbChargeModel(); $_count = $_model->alias('ptb_charge_model')->where($_map)->count(); if (empty($_count)) { return [ 'count' => 0, 'sum' => [], 'list' => [] ]; } $_sum_field = [ 'sum(amount)' => 'sum_amount', 'sum(real_amount)' => 'sum_real_amount', 'sum(rebate_cnt)' => 'sum_rebate_cnt', 'sum(ptb_cnt)' => 'sum_ptb_cnt' ]; $_sum_data = $_model ->alias('ptb_charge_model') ->field($_sum_field) ->where($where) ->find(); if (is_object($_sum_data)) { $_sum_data = $_sum_data->toArray(); } $_sum = []; foreach ($_sum_data as $_k => $_v) { $_sum[$_k] = StrUtils::formatNumber($_v); } $_field = $field; if (empty($field)) { $_field = []; } $_order = $_model->orderFilter($order); $_datas = $_model ->alias('ptb_charge_model') ->with('mem,agent') ->where($where) ->field($_field) ->order($_order) ->page($page) ->select(); if (is_object($_datas)) { $_datas = $_datas->toArray(); } if (empty($_datas)) { return [ 'count' => $_count, 'sum' => $_sum, 'list' => [] ]; } foreach ($_datas as $_k => $_v) { $_datas[$_k]['username'] = !empty($_v['mem']) ? $_v['mem']['username'] : ''; $_datas[$_k]['agent_name'] = !empty($_v['agent']) ? $_v['agent']['user_login'] : ''; } return [ 'count' => $_count, 'sum' => $_sum, 'list' => $_datas ]; } public function getIncomeList($where = [], $page = '1,10', $order = '-create_time') { $_map = $this->getWhere($where); $_field = []; return $this->getList($_field, $_map, $page, $order); } /** * @param $order_id * * @return array|false|\PDOStatement|string|PtbChargeModel */ public function getDetailByOrderId($order_id) { $_ptb_charge = (new PtbChargeModel())->where('order_id', '=', $order_id)->find(); return $_ptb_charge; } }