churen/app/shop/lib/Refund.php

<?php

namespace Shop\Lib;

use Dever;

class Refund
{
	# 设置订单的类型
    public function set($type)
    {
        $this->type = $type;
    	$this->order_table = 'shop/' . $type . '_order';
    	$this->goods_table = 'shop/' . $type . '_order_goods';
        $this->refund_table = 'shop/' . $type . '_order_refund';
        if ($type == 'buy') {
            $this->lib = 'mshop/lib/' . $type;
        } else {
            $this->lib = 'shop/lib/' . $type;
        }

        return $this;
    }

    # 获取退款记录
    public function getList($type, $id, $order_id)
    {
        $order = Dever::load($this->lib)->set($type, 1)->getView($id, $order_id, false);
        $where['order_id'] = $order_id;

        $data = Dever::db($this->refund_table)->select_page($where);

        if ($data) {
            $goods_status = Dever::db($this->goods_table)->config['status'];
            $refund_status = Dever::db($this->refund_table)->config['status'];
            $refund_process = Dever::db($this->refund_table)->config['process'];
            foreach ($data as $k => $v) {
                $data[$k]['cdate'] = date('Y-m-d H:i', $v['cdate']);
                if ($v['order_goods_id'] != -1 && $order['price'] > $v['cash']) {
                    $data[$k]['goods'] = Dever::db($this->goods_table)->getDataByIds(array('ids' => $v['order_goods_id']));
                } else {
                    $data[$k]['goods'] = Dever::db($this->goods_table)->getDataByIds(array('order_id' => $v['order_id']));
                }
                
                $data[$k]['status_name'] = $refund_status[$v['status']];
                $data[$k]['process_name'] = $refund_process[$v['process']];
                if ($data[$k]['goods']) {
                    foreach ($data[$k]['goods'] as $k1 => $v1) {
                        $data[$k]['goods'][$k1]['info'] = Dever::load('goods/lib/info')->getPayInfo($v1['goods_id'], $v1['sku_id']);
                        $data[$k]['goods'][$k1]['status_name'] = $goods_status[$v1['status']];
                    }
                }
            }
        }

        return $data;
    }

    # 更新退款记录
    public function up($order_id, $order_goods_id, $status, $price, $p_price, $num = false, $desc = '', $pic = '', $process = 1)
    {
        $data['order_id'] = $order_id;
        if (!$order_goods_id) {
            $where['order_id'] = $order_id;
            $goods = Dever::db($this->goods_table)->getIds($where);
            if ($goods) {
                $order_goods_id = implode(',', array_keys($goods));
            }
            $data['type'] = 1;
        } else {
            $data['type'] = 2;
        }
        $data['order_goods_id'] = $order_goods_id;
        $info = Dever::db($this->refund_table)->find($data);

        $data['status'] = $status;
        $data['cash'] = $price;
        if ($p_price) {
            $data['p_cash'] = $p_price;
        }
        
        if ($num) {
            $data['num'] = $num;
        }
        $data['desc'] = $desc;
        $data['pic'] = $pic;
        $data['process'] = $process;
        if ($info) {
            $data['where_id'] = $info['id'];
            $state = Dever::db($this->refund_table)->update($data);
            if ($state) {
                $data['id'] = $info['id'];
                return $data;
            }
        } else {
            $state = Dever::db($this->refund_table)->insert($data);
            if ($state) {
                $data['id'] = $state;
                return $data;
            }
        }

        return false;
    }

    # 申请退款
    public function apply($type, $id, $order_id, $order_goods_id, $status = 1, $num = 0, $desc = '', $pic = '', $process = 2)
    {
        if ($status != 1 && $status != 2 && $status != 3) {
            Dever::alert('当前订单状态不允许退货退款');
        }

        $data = Dever::load($this->lib)->set($type, 1)->getView($id, $order_id, false);

        if (isset($data['withdraw']) && $data['withdraw'] == 2) {
            Dever::alert('当前订单状态不允许退货退款');
        }
        $auth = false;
        if ($this->type == 'sell' && $type == 1) {
            if ($data['status'] == 2) {
                $auth = true;
            }
        } else {
            $config = array(2,3,4,5,6);
            if (in_array($data['status'], $config)) {
                $auth = true;
            }
        }
        if ($auth) {
            if ($order_goods_id) {
                $info = Dever::db($this->goods_table)->find(array('id' => $order_goods_id, 'order_id' => $data['id'], 'status' => 1));
                if ($info) {
                    if (!$num) {
                        $num = $info['num'];   
                    }
                    Dever::db($this->goods_table)->update(array('where_id' => $info['id'], 'status' => 2));
                    $info['total_price'] = $info['price'] * $num;
                	if (isset($info['coupon_cash']) && $info['coupon_cash']) {
                		$cash = $info['total_price'] - $info['coupon_cash'];
                	} else {
                		$cash = $info['total_price'];
                	}

                    if (isset($info['p_price'])) {
                        $p_cash = $info['p_price'] * $num;
                    } else {
                        $p_cash = 0;
                    }
                } else {
                    Dever::alert('您没有权限操作');
                }
            } else {
                if (!$num) {
                    $num = $data['num'];
                }
                $cash = $data['price'] - $data['refund_cash'];
                if (isset($data['p_price']) && isset($data['refund_p_cash'])) {
                    $p_cash = $data['p_price'] - $data['refund_p_cash'];
                } else {
                    $p_cash = 0;
                }

                if (isset($data['ps_cash']) && $data['ps_cash'] > 0 && $data['status'] >= 3) {
                    # 已发货不退配送费
                    $cash -= $data['ps_cash'];
                }
            }

            if ($cash > 0) {
                $log = $this->up($data['id'], $order_goods_id, $status, $cash, $p_cash, $num, $desc, $pic, $process);

                if (!$log) {
                    Dever::alert('退款失败');
                }
                if ($this->type == 'buy') {
                    # 如果是采购单，这里要把库存先减掉
                    if ($data['status'] == 5 || $data['status'] == 6) {
                        $oper_data = Dever::db($this->goods_table)->getDataByIds(array('ids' => $log['order_goods_id']));
                        Dever::load('shop/lib/goods')->oper($data, 2, 1, $oper_data);
                    }

                    if ($data['source_id'] && $data['source_id'] > 0) {
                        $data['num'] = $num;
                        Dever::load('cash/lib/order')->up($data, 2, 1, $log);
                    } else {
                        $data['num'] = $num;
                        Dever::load('cash/lib/order')->up($data, 1, 3);
                    }

                    # 发消息给供应商
                    if ($data['source_id'] && Dever::project('message')) {
                        $msg = '您的订单'.$data['order_num'].'，有新的商品问题。';
                        $msg_param['type'] = 1;
                        $msg_param['id'] = $data['id'];
                        $msg_param = Dever::json_encode($msg_param);
                        $pid = $data['source_type'] + 1;
                        Dever::load('message/lib/data')->push(-1, $data['source_id'], '退货与报损通知', $msg, 2, $pid, false, $msg_param);
                    }
                }

                $update = array();
                $update['where_id'] = $data['id'];
                $update['refund_cash'] = $data['refund_cash'] + $cash;
                if (isset($data['refund_p_cash'])) {
                    $update['refund_p_cash'] = $data['refund_p_cash'] + $p_cash;
                }
                $update['refund_status'] = 2;
                
                Dever::db($this->order_table)->update($update);

                if ($id && $process == 2) {
                    $this->action($log, $process, $data);
                }
            } else {
                Dever::alert('您没有可以退款的金额');
            }
        } else {
            Dever::alert('您没有权限操作');
        }
        return 'reload';
    }

    # 确认退款
    public function action($info, $process, $order = false, $cash = true)
    {
        if (!is_array($info)) {
            $info = Dever::db($this->refund_table)->find($info);
        }

        if (!$info) {
            Dever::alert('您没有权限操作');
        }

        if (!$order) {
            $order = Dever::db($this->order_table)->find($info['order_id']);
        }

        if (!$order) {
            Dever::alert('您没有权限操作');
        }

        if (isset($order['withdraw']) && $order['withdraw'] == 2) {
            Dever::alert('当前订单状态不允许退货退款');
        }

        $state = Dever::db($this->refund_table)->update(array('where_id' => $info['id'], 'process' => $process));

        if (!$state) {
        	Dever::alert('操作失败');
        }

        $update = array();
        if ($process == 3) {
            if ($info['num'] && $info['num'] > 0) {
                //$update['num'] = $order['num'] + $info['num'];
            }
            $update['refund_cash'] = $order['refund_cash'] - $info['cash'];
            if (isset($order['refund_p_cash'])) {
                $update['refund_p_cash'] = $order['refund_p_cash'] - $info['p_cash'];
            }
            $update['where_id'] = $order['id'];
            $update['refund_status'] = 1;
            
            $state = Dever::db($this->order_table)->update($update);

            if ($info['type'] == 2) {
                Dever::db($this->goods_table)->update(array('where_id' => $info['order_goods_id'], 'status' => 1));
            }

            if ($cash && $this->type == 'buy' && $order['source_id'] && $order['source_id'] > 0) {
                $order['num'] = $info['num'];
                Dever::load('cash/lib/order')->up($order, 2, 3, $info);
            }
        } else {
            if ($info['type'] == 2) {
                $state = Dever::db($this->goods_table)->update(array('where_id' => $info['order_goods_id'], 'status' => 3));
                if ($state) {
                    $this->notice($state, $order, $info);
                    # 检查这个订单下的商品是不是都退了
                    $total = Dever::db($this->goods_table)->getTotal(array('order_id' => $order['id'], 'status' => '1,2'));

                    if ($total <= 0) {
                        $update['operdate'] = time();
                        $update['status'] = 8;
                    } elseif ($order['status'] == 5) {
                        $update['status'] = 6;
                    }

                    if ($update) {
                        $update['where_id'] = $order['id'];
                        $update['refund_status'] = 1;
                        $state = Dever::db($this->order_table)->update($update);
                    }
                }
            } else {
                $update['where_id'] = $order['id'];
                $update['operdate'] = time();
                if (isset($order['ps_cash']) && $order['ps_cash'] > 0 && $order['status'] < 3) {
                    # 配送费退掉
                    //$update['ps_cash'] = 0;
                }
                $update['status'] = 8;
                $state = Dever::db($this->order_table)->update($update);
                if ($state) {
                    $this->notice($state, $order, $info);
                    if (isset($order['user_coupon_id']) && $order['user_coupon_id']) {
                        # 还原优惠券
                        Dever::db('shop/user_coupon')->update(array('where_id' => $order['user_coupon_id'], 'status' => 1));
                    }
                }
            }

            if ($cash && $this->type == 'buy' && $order['source_id'] && $order['source_id'] > 0) {
                $order['num'] = $info['num'];
                if (isset($update['status'])) {
                    $order['status'] = $update['status'];
                }
                
                Dever::load('cash/lib/order')->up($order, 2, 2, $info);
            }
        }

        $data = Dever::db($this->goods_table)->getDataByIds(array('ids' => $info['order_goods_id']));
        if ($this->type == 'sell' && $process == 2) {
            # 如果是销售单，退款后要减少销量
            Dever::load('shop/lib/goods')->oper($order, 2, 2, $data);
        } elseif ($this->type == 'buy' && $process == 3 && ($order['status'] == 5 || $order['status'] == 6)) {
            # 如果是采购单，退款后要恢复库存
            Dever::load('shop/lib/goods')->oper($order, 1, 1, $data);
        }

        return 'reload';
    }

    # 获取部分退款的详情
    public function getInfo($type, $id, $order_id, $order_goods_id)
    {
        $data = Dever::load($this->lib)->set($type, 1)->getView($id, $order_id, false);
        $info = Dever::db($this->goods_table)->find(array('id' => $order_goods_id, 'order_id' => $data['id'], 'status' => 1));
        if ($info) {
            if ($type > 10) {
                $info['price'] = $info['p_price'];
            }
        	if (isset($info['coupon_cash']) && $info['coupon_cash']) {
        		$info['tui_price'] = ($info['price'] * $info['num']) - $info['coupon_cash'];
        	} else {
        		$info['tui_price'] = $info['price'] * $info['num'];
        	}

            $info['tui_one_price'] = $info['price'];
            $info['goods'] = Dever::db('goods/info')->find($info['goods_id']);
        }
        return $info;
    }

    # 退款通知
    public function notice($state, $data, $info)
    {
        if ($state && isset($data['uid']) && $data['uid'] > 0) {
            $refund_cash = $info['cash'];
            $refund_order_id = $info['id'];

            $shop = Dever::db('shop/info')->one($data['shop_id']);
            $msg_param['type'] = 1;//消息类型1是订单消息
            $msg_param['id'] = $data['id'];
            $msg_param['name'] = $shop['name'];
            $msg_param = Dever::json_encode($msg_param);
            $msg = '您有一笔订单已退款，退款将在3个工作日内返回原支付账户';
            Dever::load('message/lib/data')->push(-1, $data['uid'], '退款成功通知', $msg, 2, 1, false, $msg_param);

            # 退款到原支付账户 待处理
            $param = array
            (
                'project_id' => 1,
                'channel_id' => 1,
                'system_source' => 5,
                'order_id' => $data['order_num'],
                'refund_cash' => $refund_cash,
                'refund_order_id' => $refund_order_id
            );

            $result = Dever::load('pay/api.refund', $param);

            if (!$result) {
                # 退款失败，抛出错误
                throw new \Exception('退款失败');
                Dever::alert('退款失败');
            }

            if (Dever::load('wechat_applet')) {
                $config = Dever::db($this->order_table)->config;
                $user = Dever::db('passport/wechat')->one(array('uid' => $data['uid'], 'system_id' => 1, 'system_source' => 5));
                if ($user && $user['openid']) {
                    $send = array
                    (
                        'character_string1' => array
                        (
                            'value' => $data['order_num'],
                        ),
                        'amount3' => array
                        (
                            'value' => $refund_cash . '元',
                        ),
                        'thing7' => array
                        (
                            'value' => '您的退款已到账，请查看~',
                        ),
                    );

                    $send = Dever::json_encode($send);
                    Dever::load('wechat_applet/subscribe')->sendOne('order_refund', 1, $user['openid'], 'pages/app/order/order?id=' . $data['id'], $send, Dever::config('base')->wechat_applet);
                }
            }
        }
    }
}