request->get(); $accounts = PayAccount::serchAccount($query)->order('id', 'desc')->paginate(['list_rows' => $query['limit'], 'page' => $query['page']]); if ($accounts) { return json(['code' => 0, 'msg' => 'OK', 'count' => $accounts->total(), 'data' => $accounts->items()]); } else { return json(['code' => 1, 'msg' => '无数据记录', 'count' => 0, 'data' => []]); } } // 收款终端列表 public function getChannelList() { $aid = $this->request->post('aid'); $res = PayChannel::where(['account_id' => $aid])->order('last_time', 'desc')->select(); if ($res) { return json(backMsg(0, '获取成功', $res)); } else { return json(backMsg(1, '失败')); } } // 账号状态 public function accountEnable() { $info = $this->request->post(); $up_res = PayAccount::update($info); if ($up_res) { return json(backMsg(0, '成功')); } else { return json(backMsg(1, '失败')); } } // 添加账号 public function addAccount() { $info = $this->request->post(); $pid = $this->request->session('pid'); $info['pid'] = $pid; $info['params'] = '{}'; $check_acc = PayAccount::where(['account' => $info['account'], 'platform' => $info['platform'], 'pid' => $pid])->find(); if ($check_acc) { return json(backMsg(1, '账号已存在')); } $acc = PayAccount::create($info); if ($acc) { return json(backMsg(0, '添加成功')); } else { return json(backMsg(1, '添加失败')); } } // 编辑账号 public function editAccount() { $info = $this->request->post(); $up_res = PayAccount::update($info); if ($up_res) { return json(backMsg(0, '修改成功')); } else { return json(backMsg(1, '修改失败')); } } // 删除账号 public function delAccount() { $ids = $this->request->post('ids'); $res = PayAccount::destroy($ids); $res2 = PayChannel::whereIn('account_id', $ids)->select()->delete(); if ($res && $res2) { return json(backMsg(0, '已删除')); } else { return json(backMsg(1, '失败')); } } // 添加收款终端 public function addChannel() { $info = $this->request->post(); $check = PayChannel::where(['account_id' => $info['account_id'], 'channel' => $info['channel']])->count(); if ($check) { return json(backMsg(1, '编号已存在')); } $res = PayChannel::create($info); if ($res) { return json(backMsg(0, '添加成功')); } else { return json(backMsg(1, '添加失败')); } } // 编辑收款终端 public function editChannel() { $info = $this->request->post(); $up_res = PayChannel::update($info); if ($up_res) { return json(backMsg(0, '修改成功')); } else { return json(backMsg(1, '修改失败')); } } // 删除收款终端 public function delChannel() { $cid = $this->request->post('id'); $res = PayChannel::destroy($cid); if ($res) { return json(backMsg(0, '已删除')); } else { return json(backMsg(1, '失败')); } } // 上传二维码图片 public function uploadQrcode() { $img = $this->request->file('codeimg'); if (!$img) { return json(backMsg(1, '请选择要上传的文件')); } // 验证文件类型 $allowedTypes = ['image/png', 'image/jpeg', 'image/gif']; $fileMimeType = $img->getMime(); if (!in_array($fileMimeType, $allowedTypes)) { return json(backMsg(1, '只允许上传PNG、JPEG或GIF格式的图片')); } // 生成唯一文件名 $filename = 'img_' . time() . '_' . uniqid() . '.' . $img->getOriginalExtension(); // 设置文件保存路径 $path = public_path() . '/files/qrcode/'; if (!is_dir($path)) { mkdir($path, 0755, true); } // 移动文件到指定目录 $info = $img->move($path, $filename); if ($info) { $imgpath = '/files/qrcode/' . $filename; return json(backMsg(0, '上传成功', ['imgpath' => $imgpath])); } else { return json(backMsg(1, '上传失败')); } } // 获取账号交易流水 public function getAccountTrade() { $req_info = $this->request->get(); $req_pid = $req_info['pid']; $req_aid = $req_info['aid']; // 加载配置文件 $config = PayAccount::getAccountConfig($req_aid); if ($config === false) return json(backMsg(1, '账号配置文件错误')); if ($req_aid != $config['aid'] || $req_pid != session('pid')) return json(backMsg(1, '监听收款配置不一致')); // 登陆账号 $pay_config = ['username' => $config['account'], 'password' => $config['password']]; // 收款查询 $params = $config['params']; // 实例监听客户端 $payclient_name = $config['payclass']; $payclient_path = "\\payclient\\{$payclient_name}"; $Payclient = new $payclient_path($pay_config); // 获取支付明细 $records = $Payclient->getOrderInfo($params); if ($records['code'] === 0) { // 收款流水 return json(backMsg(0, '查询成功', $records['data'])); } else { return json(['code' => 1, 'msg' => $records['msg']]); } } }