478 lines
20 KiB
PHP
478 lines
20 KiB
PHP
|
<?php
|
||
|
|
|
||
|
|
namespace app\merchant\service;
|
||
|
|
|
||
|
|
use app\core\Service;
|
||
|
|
use think\admin\extend\CodeExtend;
|
||
|
|
use app\merchant\service\MerchantService;
|
||
|
|
use app\channel\service\ChannelService;
|
||
|
|
use app\channel\service\ProductService;
|
||
|
|
use app\merchant\service\PercentService;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 商户已完成订单服务
|
||
|
|
* Class MerchantService
|
||
|
|
* @package app\merchant\service
|
||
|
|
*/
|
||
|
|
class OrderLastHistoryService extends Service
|
||
|
|
{
|
||
|
|
/**
|
||
|
|
* 设置默认操作表
|
||
|
|
* @var string
|
||
|
|
*/
|
||
|
|
public $table = 'merchant_order_last_history';
|
||
|
|
|
||
|
|
# 提交订单
|
||
|
|
public function up($data)
|
||
|
|
{
|
||
|
|
$id = $this->db()->insert($data);
|
||
|
|
|
||
|
|
return $id;
|
||
|
|
}
|
||
|
|
|
||
|
|
# 获取某一个商户的订单总额
|
||
|
|
public function getTotal($mid, $status = 1)
|
||
|
|
{
|
||
|
|
$where['mid'] = $mid;
|
||
|
|
if ($status > 0) {
|
||
|
|
$where['status'] = $status;
|
||
|
|
}
|
||
|
|
return $this->db()->where($where)->sum('cash');
|
||
|
|
}
|
||
|
|
|
||
|
|
# 查找订单
|
||
|
|
public function get($order_id, $merchant_order_id = false, $mid = false)
|
||
|
|
{
|
||
|
|
if ($merchant_order_id) {
|
||
|
|
$where['merchant_order_id'] = $merchant_order_id;
|
||
|
|
} else {
|
||
|
|
if (is_numeric($order_id)) {
|
||
|
|
$where['id'] = $order_id;
|
||
|
|
} else {
|
||
|
|
$where['order_id'] = $order_id;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
if ($mid) {
|
||
|
|
$where['mid'] = $mid;
|
||
|
|
}
|
||
|
|
return $this->db()->where($where)->find();
|
||
|
|
}
|
||
|
|
|
||
|
|
# 查找下单订单
|
||
|
|
public function getData()
|
||
|
|
{
|
||
|
|
$cur = time();
|
||
|
|
$time = 12 * 3600;
|
||
|
|
$whereRaw = $cur . '-unix_timestamp(create_at) <=' . $time;
|
||
|
|
return $this->db()->whereRaw('status = 1 and ' . $whereRaw)->order('id asc')->select();
|
||
|
|
}
|
||
|
|
|
||
|
|
# 查找回调错误的订单
|
||
|
|
public function getErrorData()
|
||
|
|
{
|
||
|
|
return $this->db()->whereRaw('merchant_callback_error = 2 and merchant_callback_num < 5 and status in(2,3)')->order('id asc')->select();
|
||
|
|
}
|
||
|
|
|
||
|
|
# 获取某一个商户的订单数量
|
||
|
|
public function getOrderTotal($mid, $status = 1)
|
||
|
|
{
|
||
|
|
$where['mid'] = $mid;
|
||
|
|
if ($status > 0) {
|
||
|
|
$where['status'] = $status;
|
||
|
|
}
|
||
|
|
return $this->db()->where($where)->count();
|
||
|
|
}
|
||
|
|
public function cancelOrder($v){
|
||
|
|
$v['order']=$v['order_id'];
|
||
|
|
MerchantService::instance()->qxdd($v);
|
||
|
|
}
|
||
|
|
# 获取成功的订单
|
||
|
|
public function getTotalData($day, $cid = false, $pid = false)
|
||
|
|
{
|
||
|
|
if (!$day) {
|
||
|
|
$day = date('Y-m-d', strtotime('-1 day'));
|
||
|
|
}
|
||
|
|
$begin = $day . ' 00:00:00';
|
||
|
|
$after = $day . ' 23:59:59';
|
||
|
|
$time = [$begin, $after];
|
||
|
|
$db = $this->db()->whereRaw('status in(2,3) ');
|
||
|
|
$where = array();
|
||
|
|
if ($cid) {
|
||
|
|
$where['cid'] = $cid;
|
||
|
|
}
|
||
|
|
if ($pid) {
|
||
|
|
$where['pid'] = $pid;
|
||
|
|
}
|
||
|
|
if ($where) {
|
||
|
|
$db->where($where);
|
||
|
|
}
|
||
|
|
$data = $db->whereBetween('create_at', $time)->order('id asc')->select()->toArray();
|
||
|
|
|
||
|
|
$result = array();
|
||
|
|
if ($data) {
|
||
|
|
$result['success'] = 0;
|
||
|
|
$result['fail'] = 0;
|
||
|
|
$result['total'] = 0;
|
||
|
|
$result['product_cash'] = 0;
|
||
|
|
$result['actual_cash'] = 0;
|
||
|
|
$result['profit'] = 0;
|
||
|
|
|
||
|
|
# 计算每个产品的总数
|
||
|
|
$result['product'] = array();
|
||
|
|
# 计算每个商户的总数
|
||
|
|
$result['merchant'] = array();
|
||
|
|
# 计算每个商户的总数
|
||
|
|
$result['merchant_total'] = array();
|
||
|
|
# 产品信息
|
||
|
|
$result['product_info'] = array();
|
||
|
|
|
||
|
|
$productService = ProductService::instance();
|
||
|
|
foreach ($data as $k => $v) {
|
||
|
|
# 检查是否是固定数值
|
||
|
|
if (!isset($result['product_info'][$v['pid']])) {
|
||
|
|
$result['product_info'][$v['pid']] = $productService->getInfo($v['pid']);
|
||
|
|
}
|
||
|
|
|
||
|
|
$product = $result['product_info'][$v['pid']];
|
||
|
|
if ($product) {
|
||
|
|
if ($product['rule']) {
|
||
|
|
$product['percent'] = MerchantService::instance()->getPercent($product['percent'], $v['account'], $v['product_key'], $v['cash'], $product['rule'], $v['isp']);
|
||
|
|
}
|
||
|
|
|
||
|
|
$product_percent_type = 1;
|
||
|
|
if (isset($product['percent_type']) && $product['percent_type']) {
|
||
|
|
$product_percent_type = $product['percent_type'];
|
||
|
|
}
|
||
|
|
if ($product_percent_type == 2) {
|
||
|
|
$v['product_cash'] = $product['percent'];
|
||
|
|
} else {
|
||
|
|
$v['product_cash'] = $product['percent']*$v['cash'];
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
if ($v['status'] == 3) {
|
||
|
|
$result['fail'] += $v['cash'];
|
||
|
|
} else {
|
||
|
|
$result['success'] += $v['cash'];
|
||
|
|
|
||
|
|
if (!isset($result['product'][$v['pid']])) {
|
||
|
|
$result['product'][$v['pid']]['num'] = 0;
|
||
|
|
$result['product'][$v['pid']]['actual_num'] = 0;
|
||
|
|
$result['product'][$v['pid']]['percent'] = array();
|
||
|
|
|
||
|
|
}
|
||
|
|
$result['product'][$v['pid']]['num'] += $v['cash'];
|
||
|
|
$result['product'][$v['pid']]['actual_num'] += $v['product_cash'];
|
||
|
|
$result['product'][$v['pid']]['actual_num'] = round($result['product'][$v['pid']]['actual_num'], 2);
|
||
|
|
// var_dump($v);die;
|
||
|
|
|
||
|
|
if (isset($result['product_info'][$v['pid']]['percent_type']) && $result['product_info'][$v['pid']]['percent_type'] == 2) {
|
||
|
|
$percent = $v['product_cash'];
|
||
|
|
} else {
|
||
|
|
$percent = $v['product_cash']/$v['cash'];
|
||
|
|
}
|
||
|
|
|
||
|
|
$percent = 'k_' . $percent;
|
||
|
|
|
||
|
|
if (!isset($result['product'][$v['pid']]['percent'][$percent][$v['cash']])) {
|
||
|
|
$result['product'][$v['pid']]['percent'][$percent][$v['cash']]['num'] = 0;
|
||
|
|
$result['product'][$v['pid']]['percent'][$percent][$v['cash']]['cash'] = $v['product_cash'];
|
||
|
|
}
|
||
|
|
|
||
|
|
$result['product'][$v['pid']]['percent'][$percent][$v['cash']]['num'] += 1;
|
||
|
|
|
||
|
|
if (!isset($result['merchant'][$v['mid']][$v['pid']])) {
|
||
|
|
$result['merchant'][$v['mid']][$v['pid']]['num'] = 0;
|
||
|
|
$result['merchant'][$v['mid']][$v['pid']]['actual_num'] = 0;
|
||
|
|
$result['merchant'][$v['mid']][$v['pid']]['product_num'] = 0;
|
||
|
|
$result['merchant'][$v['mid']][$v['pid']]['percent'] = array();
|
||
|
|
$result['merchant'][$v['mid']][$v['pid']]['profit'] = 0;
|
||
|
|
}
|
||
|
|
$result['merchant'][$v['mid']][$v['pid']]['num'] += $v['cash'];
|
||
|
|
$result['merchant'][$v['mid']][$v['pid']]['actual_num'] += $v['actual_cash'];
|
||
|
|
$result['merchant'][$v['mid']][$v['pid']]['product_num'] += $v['product_cash'];
|
||
|
|
|
||
|
|
$result['merchant'][$v['mid']][$v['pid']]['actual_num'] = round($result['merchant'][$v['mid']][$v['pid']]['actual_num'], 2);
|
||
|
|
|
||
|
|
$result['merchant'][$v['mid']][$v['pid']]['product_num'] = round($result['merchant'][$v['mid']][$v['pid']]['product_num'], 2);
|
||
|
|
$result['merchant'][$v['mid']][$v['pid']]['profit'] += $v['actual_cash'] - $v['product_cash'];
|
||
|
|
$result['merchant'][$v['mid']][$v['pid']]['profit'] = round($result['merchant'][$v['mid']][$v['pid']]['profit'], 2);
|
||
|
|
|
||
|
|
if (isset($result['product_info'][$v['pid']]['percent_type']) && $result['product_info'][$v['pid']]['percent_type'] == 2) {
|
||
|
|
$percent = $v['actual_cash'];
|
||
|
|
} else {
|
||
|
|
$percent = $v['actual_cash']/$v['cash'];
|
||
|
|
}
|
||
|
|
|
||
|
|
$percent = 'k_' . $percent;
|
||
|
|
|
||
|
|
if (!isset($result['merchant'][$v['mid']][$v['pid']]['percent'][$percent][$v['cash']])) {
|
||
|
|
$result['merchant'][$v['mid']][$v['pid']]['percent'][$percent][$v['cash']]['num'] = 0;
|
||
|
|
$result['merchant'][$v['mid']][$v['pid']]['percent'][$percent][$v['cash']]['cash'] = $v['actual_cash'];
|
||
|
|
}
|
||
|
|
$result['merchant'][$v['mid']][$v['pid']]['percent'][$percent][$v['cash']]['num'] += 1;
|
||
|
|
|
||
|
|
|
||
|
|
if (!isset($result['merchant_total'][$v['mid']][$v['product_key']])) {
|
||
|
|
$result['merchant_total'][$v['mid']][$v['product_key']]['num'] = 0;
|
||
|
|
$result['merchant_total'][$v['mid']][$v['product_key']]['actual_num'] = 0;
|
||
|
|
$result['merchant_total'][$v['mid']][$v['product_key']]['product_num'] = 0;
|
||
|
|
$result['merchant_total'][$v['mid']][$v['product_key']]['cash'] = array();
|
||
|
|
$result['merchant_total'][$v['mid']][$v['product_key']]['profit'] = 0;
|
||
|
|
}
|
||
|
|
$result['merchant_total'][$v['mid']][$v['product_key']]['num'] += $v['cash'];
|
||
|
|
$result['merchant_total'][$v['mid']][$v['product_key']]['actual_num'] += $v['actual_cash'];
|
||
|
|
$result['merchant_total'][$v['mid']][$v['product_key']]['product_num'] += $v['product_cash'];
|
||
|
|
|
||
|
|
$result['merchant_total'][$v['mid']][$v['product_key']]['actual_num'] = round($result['merchant_total'][$v['mid']][$v['product_key']]['actual_num'], 2);
|
||
|
|
|
||
|
|
$result['merchant_total'][$v['mid']][$v['product_key']]['product_num'] = round($result['merchant_total'][$v['mid']][$v['product_key']]['product_num'], 2);
|
||
|
|
$result['merchant_total'][$v['mid']][$v['product_key']]['profit'] += $v['actual_cash'] - $v['product_cash'];
|
||
|
|
$result['merchant_total'][$v['mid']][$v['product_key']]['profit'] = round($result['merchant_total'][$v['mid']][$v['product_key']]['profit'], 2);
|
||
|
|
if (!isset($result['merchant_total'][$v['mid']][$v['product_key']]['cash'][$v['cash']])) {
|
||
|
|
$result['merchant_total'][$v['mid']][$v['product_key']]['cash'][$v['cash']]['num'] = 0;
|
||
|
|
$result['merchant_total'][$v['mid']][$v['product_key']]['cash'][$v['cash']]['actual_num'] = 0;
|
||
|
|
$result['merchant_total'][$v['mid']][$v['product_key']]['cash'][$v['cash']]['product_num'] = 0;
|
||
|
|
}
|
||
|
|
$result['merchant_total'][$v['mid']][$v['product_key']]['cash'][$v['cash']]['num'] += $v['cash'];
|
||
|
|
$result['merchant_total'][$v['mid']][$v['product_key']]['cash'][$v['cash']]['actual_num'] += $v['actual_cash'];
|
||
|
|
$result['merchant_total'][$v['mid']][$v['product_key']]['cash'][$v['cash']]['product_num'] += $v['product_cash'];
|
||
|
|
|
||
|
|
$result['merchant_total'][$v['mid']][$v['product_key']]['cash'][$v['cash']]['actual_num'] = round($result['merchant_total'][$v['mid']][$v['product_key']]['cash'][$v['cash']]['actual_num'], 2);
|
||
|
|
|
||
|
|
$result['merchant_total'][$v['mid']][$v['product_key']]['cash'][$v['cash']]['product_num'] = round($result['merchant_total'][$v['mid']][$v['product_key']]['cash'][$v['cash']]['product_num'], 2);
|
||
|
|
|
||
|
|
|
||
|
|
$result['product_cash'] += $v['product_cash'];
|
||
|
|
$result['actual_cash'] += $v['actual_cash'];
|
||
|
|
|
||
|
|
$result['profit'] = round($result['actual_cash'] - $result['product_cash'], 2);
|
||
|
|
}
|
||
|
|
|
||
|
|
/*
|
||
|
|
if (isset($result['product_info'][$v['pid']]['percent_type']) && $result['product_info'][$v['pid']]['percent_type'] == 2 && $v['status'] != 3) {
|
||
|
|
$result['success'] += $v['cash'];
|
||
|
|
|
||
|
|
if (!isset($result['product'][$v['pid']])) {
|
||
|
|
$result['product'][$v['pid']] = 0;
|
||
|
|
}
|
||
|
|
if (!isset($result['product_num'][$v['pid']])) {
|
||
|
|
$result['product_num'][$v['pid']] = 0;
|
||
|
|
}
|
||
|
|
$result['product'][$v['pid']] += $v['cash'];
|
||
|
|
$result['product_num'][$v['pid']] += 1;
|
||
|
|
|
||
|
|
if (!isset($result['merchant'][$v['mid']][$v['pid']])) {
|
||
|
|
$result['merchant'][$v['mid']][$v['pid']] = 0;
|
||
|
|
}
|
||
|
|
if (!isset($result['merchant_num'][$v['mid']][$v['pid']])) {
|
||
|
|
$result['merchant_num'][$v['mid']][$v['pid']] = 0;
|
||
|
|
}
|
||
|
|
$result['merchant'][$v['mid']][$v['pid']] += $v['cash'];
|
||
|
|
$result['merchant_num'][$v['mid']][$v['pid']] += 1;
|
||
|
|
} else {
|
||
|
|
if ($v['status'] == 2) {
|
||
|
|
$result['success'] += $v['cash'];
|
||
|
|
|
||
|
|
if (!isset($result['product'][$v['pid']])) {
|
||
|
|
$result['product'][$v['pid']] = 0;
|
||
|
|
}
|
||
|
|
$result['product'][$v['pid']] += $v['cash'];
|
||
|
|
|
||
|
|
if (!isset($result['merchant'][$v['mid']][$v['pid']])) {
|
||
|
|
$result['merchant'][$v['mid']][$v['pid']] = 0;
|
||
|
|
}
|
||
|
|
$result['merchant'][$v['mid']][$v['pid']] += $v['cash'];
|
||
|
|
|
||
|
|
} else {
|
||
|
|
$result['fail'] += $v['cash'];
|
||
|
|
}
|
||
|
|
}
|
||
|
|
*/
|
||
|
|
}
|
||
|
|
|
||
|
|
$result['total'] = $result['success'] + $result['fail'];
|
||
|
|
}
|
||
|
|
|
||
|
|
$test = input('test');
|
||
|
|
if ($test == 1) {
|
||
|
|
print_r($result);die;
|
||
|
|
}
|
||
|
|
|
||
|
|
return $result;
|
||
|
|
}
|
||
|
|
|
||
|
|
# 修改商户回调信息
|
||
|
|
public function upMerchantMsg($order_id, $num, $msg, $error = 0)
|
||
|
|
{
|
||
|
|
$data['merchant_callback_msg'] = $msg;
|
||
|
|
$data['merchant_callback_at'] = date('Y-m-d H:i:s');
|
||
|
|
$data['merchant_callback_num'] = $num + 1;
|
||
|
|
if ($error > 0) {
|
||
|
|
$data['merchant_callback_error'] = $error;
|
||
|
|
}
|
||
|
|
|
||
|
|
if (is_numeric($order_id)) {
|
||
|
|
$where['id'] = $order_id;
|
||
|
|
} else {
|
||
|
|
$where['order_id'] = $order_id;
|
||
|
|
}
|
||
|
|
$this->db()->where($where)->update($data);
|
||
|
|
}
|
||
|
|
|
||
|
|
# 修正未扣款的订单
|
||
|
|
public function kou($day = false)
|
||
|
|
{
|
||
|
|
if (!$day) {
|
||
|
|
$day = date('Y-m-d', strtotime('-1 day'));
|
||
|
|
}
|
||
|
|
$begin = $day . ' 00:00:00';
|
||
|
|
$after = $day . ' 23:59:59';
|
||
|
|
$time = [$begin, $after];
|
||
|
|
$db = $this->db()->whereRaw('status in(2,3) ');
|
||
|
|
$data = $db->whereBetween('create_at', $time)->order('id asc')->select()->toArray();
|
||
|
|
|
||
|
|
if ($data) {
|
||
|
|
$service = MerchantLogService::instance();
|
||
|
|
foreach ($data as $k => $v) {
|
||
|
|
$where = array();
|
||
|
|
$where['mid'] = $v['mid'];
|
||
|
|
if (strstr($v['order_id'], '_')) {
|
||
|
|
$temp = explode('_', $v['order_id']);
|
||
|
|
$v['order_id'] = $temp[0];
|
||
|
|
}
|
||
|
|
$where['order_id'] = $v['order_id'];
|
||
|
|
$log = $service->db()->where($where)->select()->toArray();
|
||
|
|
$num = count($log);
|
||
|
|
if ($v['status'] == 3) {
|
||
|
|
# 只有一条，要补充一下
|
||
|
|
if ($num == 1) {
|
||
|
|
if ($log[0]['type'] == 3) {
|
||
|
|
MerchantService::instance()->resFrozenAccount($v, $v['order_id'], $v['mid'], $v['pid'], $v['product_key'], $v['cash'], $v['project_id'], $v['account'], $v['isp']);
|
||
|
|
} elseif ($log[0]['type'] == 4) {
|
||
|
|
MerchantService::instance()->setFrozenAccount($v, $v['order_id'], $v['mid'], $v['pid'], $v['product_key'], $v['cash'], $v['project_id'], $v['account'], $v['isp'], $v['create_at']);
|
||
|
|
}
|
||
|
|
|
||
|
|
} elseif ($num == 2) {
|
||
|
|
foreach ($log as $k1 => $v1) {
|
||
|
|
$service->db()->where(array('id' => $v1['id']))->update(array('order_date' => $v['create_at'], 'create_at' => $v['create_at']));
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
} elseif ($v['status'] == 2) {
|
||
|
|
if ($num <= 0) {
|
||
|
|
MerchantService::instance()->setFrozenAccount($v, $v['order_id'], $v['mid'], $v['pid'], $v['product_key'], $v['cash'], $v['project_id'], $v['account'], $v['isp'], $v['create_at']);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
# 删除订单
|
||
|
|
public function del($id)
|
||
|
|
{
|
||
|
|
$where['id'] = $id;
|
||
|
|
return $this->db()->where($where)->delete();
|
||
|
|
}
|
||
|
|
|
||
|
|
# 删除重复数据
|
||
|
|
public function delcf($day)
|
||
|
|
{
|
||
|
|
if (!$day) {
|
||
|
|
$day = date('Y-m-d', strtotime('-1 day'));
|
||
|
|
}
|
||
|
|
$begin = $day . ' 00:00:00';
|
||
|
|
$after = $day . ' 23:59:59';
|
||
|
|
$time = [$begin, $after];
|
||
|
|
$db = $this->db();
|
||
|
|
$data = $db->whereBetween('create_at', $time)->order('id asc')->select()->toArray();
|
||
|
|
|
||
|
|
if ($data) {
|
||
|
|
$result = array();
|
||
|
|
foreach ($data as $k => $v) {
|
||
|
|
if (!isset($result[$v['order_id']])) {
|
||
|
|
$result[$v['order_id']] = array();
|
||
|
|
}
|
||
|
|
$result[$v['order_id']][] = $v['id'];
|
||
|
|
}
|
||
|
|
|
||
|
|
foreach ($result as $k => $v) {
|
||
|
|
$num = count($v);
|
||
|
|
if ($num > 1 && isset($v[0]) && isset($v[1])) {
|
||
|
|
$this->db()->where(array('id' => $v[0]))->delete();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public function callSend($v, $type, $limit = true)
|
||
|
|
{
|
||
|
|
if ($v['status'] == 2 || $v['status'] == 3) {
|
||
|
|
if (!$v['channel_callback_msg']) {
|
||
|
|
$v['channel_callback_msg'] = '{}';
|
||
|
|
}
|
||
|
|
$request = json_decode($v['channel_callback_msg'], true);
|
||
|
|
|
||
|
|
$update['project_id'] = false;
|
||
|
|
if (isset($v['project_id'])) {
|
||
|
|
$update['project_id'] = $v['project_id'];
|
||
|
|
}
|
||
|
|
if (isset($v['card_id'])) {
|
||
|
|
$update['card_id'] = $v['card_id'];
|
||
|
|
}
|
||
|
|
$update['account'] = $v['account'];
|
||
|
|
$update['status'] = $v['status'];
|
||
|
|
$update['data'] = $request;
|
||
|
|
$update['cash'] = $v['cash'];
|
||
|
|
$update['merchant_order_id'] = $v['merchant_order_id'];
|
||
|
|
$update['order_id'] = $v['order_id'];
|
||
|
|
$update['notify_num'] = $v['merchant_callback_num'];
|
||
|
|
|
||
|
|
$number = '';
|
||
|
|
if (isset($request['s_nubmer']) && $request['s_nubmer']) {
|
||
|
|
$number = $request['s_nubmer'];
|
||
|
|
} elseif (isset($request['s_number']) && $request['s_number']) {
|
||
|
|
$number = $request['s_number'];
|
||
|
|
}
|
||
|
|
|
||
|
|
$order_name = 's_nubmer';
|
||
|
|
if ($number && $order_name) {
|
||
|
|
$update[$order_name] = $number;
|
||
|
|
} elseif ($number) {
|
||
|
|
$update['s_nubmer'] = $number;
|
||
|
|
}
|
||
|
|
|
||
|
|
if (isset($request['code']) && $request['code']) {
|
||
|
|
$update['code'] = $request['code'];
|
||
|
|
}
|
||
|
|
if (isset($request['msg']) && $request['msg']) {
|
||
|
|
$update['msg'] = $request['msg'];
|
||
|
|
}
|
||
|
|
|
||
|
|
if (isset($v['isp']) && $v['isp']) {
|
||
|
|
$update['isp'] = $v['isp'];
|
||
|
|
}
|
||
|
|
|
||
|
|
if (isset($v['param']) && $v['param']) {
|
||
|
|
$v['param'] = json_decode($v['param'], true);
|
||
|
|
} else {
|
||
|
|
$v['param'] = false;
|
||
|
|
}
|
||
|
|
if ($v['param'] && isset($v['param']['notify']) && $v['param']['notify']) {
|
||
|
|
$update['notify'] = $v['param']['notify'];
|
||
|
|
}
|
||
|
|
# 商户后续操作
|
||
|
|
//if (!$v['merchant_callback_msg'] && !$v['merchant_callback_at']) {
|
||
|
|
if (isset($v['error_account_oper']) && $v['error_account_oper'] == 1 && $type == 1) {
|
||
|
|
# 需要进行扣费
|
||
|
|
MerchantService::instance()->up($v['id'], $v['mid'], $v['pid'], $v['product_key'], $update);
|
||
|
|
} else {
|
||
|
|
# 直接发送
|
||
|
|
MerchantService::instance()->notify($v['id'], $v['mid'], $v['pid'], $v['product_key'], $update, $type, $limit);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
}
|