<?php namespace app\admin\controller; use app\common\controller\Backend; use EasyWeChat\Factory; use think\Db; /** * 佣金提现 * * @icon fa fa-circle-o */ class UserCommissionApply extends Backend { /** * UserCommissionApply模型对象 * @var \app\admin\model\UserCommissionApply */ protected $model = null; protected $config = null; public function _initialize() { parent::_initialize(); // 微信企业付款到零钱配置 $config = json_decode(\addons\shopro\model\Config::get(['name' => 'wechat'])->value, true); // app_id $platformConfig = json_decode(\addons\shopro\model\Config::get(['name' => 'wxMiniProgram'])->value, true); $config['app_id'] = $platformConfig['app_id']; // 微信支付证书 $config['cert_path'] = ROOT_PATH . 'public' . $config['cert_client']; $config['key_path'] = ROOT_PATH . 'public' . $config['cert_key']; $this->config = $config; $this->model = new \app\admin\model\UserCommissionApply; $this->view->assign("statusList", $this->model->getStatusList()); } public function import() { parent::import(); } /** * 默认生成的控制器所继承的父类中有index/add/edit/del/multi五个基础方法、destroy/restore/recyclebin三个回收站方法 * 因此在当前控制器中可不用编写增删改查的代码,除非需要自己控制这部分逻辑 * 需要将application/admin/library/traits/Backend.php中对应的方法复制到当前控制器,然后进行修改 */ /** * 查看 */ public function index() { //当前是否为关联查询 $this->relationSearch = false; //设置过滤方法 $this->request->filter(['strip_tags', 'trim']); if ($this->request->isAjax()) { //如果发送的来源是Selectpage,则转发到Selectpage if ($this->request->request('keyField')) { return $this->selectpage(); } list($where, $sort, $order, $offset, $limit) = $this->buildparams(); $list = $this->model ->where($where) ->order($sort, $order) ->paginate($limit); foreach ($list as $row) { $row->visible(['id','user_id','money','status','status_msg','createtime','updatetime']); } $result = array("total" => $list->total(), "rows" => $list->items()); return json($result); } return $this->view->fetch(); } public function applyOper($id) { $status = $this->request->post('status', -1); $status_msg = $this->request->post('status_msg', ''); $apply = $this->model->get($id); if ($apply->status != 0) { $this->error('该提现申请已处理,不能重复处理'); } $apply = Db::transaction(function () use ($apply, $status, $status_msg) { $apply->status = $status; $apply->status_msg = $status_msg; $apply->save(); if ($status == -1) { // 把提现的金额重新加回去 \addons\shopro\model\User::commissionAdd($apply->user_id, $apply->money, 'cash_error', $apply->id); } // 微信企业付款到零钱 $userOauth = \addons\shopro\model\UserOauth::get($apply->user_id); if($userOauth){ $app = Factory::payment($this->config); $partner_trade_no = date('Ymd') . substr(implode(NULL, array_map('ord', str_split(substr(uniqid(), 7, 13), 1))), 0, 8); $app->transfer->toBalance([ 'partner_trade_no' => $partner_trade_no, // 商户订单号,需保持唯一性(只能是字母或者数字,不能包含有符号) 'openid' => $userOauth['openid'], 'check_name' => 'NO_CHECK', // NO_CHECK:不校验真实姓名, FORCE_CHECK:强校验真实姓名 // 're_user_name' => '王小帅', // 如果 check_name 设置为FORCE_CHECK,则必填用户真实姓名 'amount' => $apply->money * 100, // 企业付款金额,单位为分 'desc' => '佣金提现', // 企业付款操作说明信息。必填 ]); $apply->isUpdate(true)->save(['partner_trade_no'=>$partner_trade_no]); } // 提现结果通知 // $user = \addons\shopro\model\User::where('id', $apply['user_id'])->find(); // $user->notify( // new \addons\shopro\notifications\Wallet([ // 'apply' => $apply, // 'event' => 'wallet_apply' // ]) // ); return $apply; }); return $this->success('操作成功', null, $apply); } // 查询付款到零钱的订单 public function searchToBalance($partner_trade_no){ $config = json_decode(\addons\shopro\model\Config::get(['name' => 'wechat'])->value, true); $platformConfig = json_decode(\addons\shopro\model\Config::get(['name' => 'wxMiniProgram'])->value, true); $config['app_id'] = $platformConfig['app_id']; // 微信支付证书 $config['cert_path'] = ROOT_PATH . 'public' . $config['cert_client']; $config['key_path'] = ROOT_PATH . 'public' . $config['cert_key']; $result = Factory::payment($config)->transfer->queryBalanceOrder($partner_trade_no); halt($result); } }