wonderful/act/lib/Pay.php

<?php
#新版本的异步支付
namespace Act\Lib;

use Dever;

class Pay
{
    private $key = 'jmss_2018';

    # 退款操作
    public function order($id, $name, $data)
    {
        $status = Dever::param('status', $data);

        if ($status == 5 && $id > 0) {
            $send = array();
            $info = Dever::db('act/order')->one($id);
            $send['pay_project_id'] = 1;
            $send['pay_uid'] = $info['uid'];
            $send['pay_order_id'] = $info['order_id'];
            $send['pay_tk_pic'] = Dever::param('tk_pic', $data);
            $send['pay_tk_time'] = Dever::param('tk_time', $data);
            $send['pay_tk_desc'] = Dever::param('tk_desc', $data);
            $send['pay_status'] = $status;
            $send['dever_token'] = $this->key;

            if ($info['buy_id'] > 0) {
                $buy = Dever::db('journal/buy_num')->one($info['buy_id']);

                if ($buy) {
                    if ($info['buy_num'] > 0) {
                        $num = $info['buy_num'];
                    } else {
                        $num = $buy['num'];
                    }
                    # 减少积分
                    $score = $num * 20;

                    $user = Dever::db('score/user')->one(array('uid' => $info['uid']));
                    if ($user) {
                        $user_id = $user['id'];
                        $user_score = $user['score'];
                        $user_score = $user_score - $score;
                        if ($user_score < 0) {
                            $user_score = 0;
                        }
                        Dever::db('score/user')->update(array('where_id' => $user_id, 'score' => $user_score));
                    }

                    # 减少排行榜
                    $journal_num = Dever::db('act/journal_num')->one(array('uid' => $info['uid'], 'journal_id' => $info['product_id']));
                    if ($journal_num) {
                        $journal_num_id = $journal_num['id'];
                        $journal_num = $journal_num['num'];
                        $journal_num = $journal_num - $num;
                        if ($journal_num < 0) {
                            $journal_num = 0;
                        }
                        Dever::db('act/journal_num')->update(array('where_id' => $journal_num_id, 'num' => $journal_num));
                    }

                    # 减少订阅本数 这个定时跑就行了 不管了
                    $journal = Dever::db('journal/info')->one($info['product_id']);
                    if ($journal) {
                        $journal_id = $journal['id'];
                        $journal_num = $journal['num_ding'];
                        $journal_num = $journal_num - $num;
                        if ($journal_num < 0) {
                            $journal_num = 0;
                        }
                        Dever::db('journal/info')->update(array('where_id' => $journal_id, 'num_ding' => $journal_num));
                    }
                }
            }
            Dever::load('pay/lib/set.updateStatus', $send);
        }
    }

	/**
	 * 支付成功后，调取的接口 这里的安全以后再升级吧，升级成和pay/lib/set.updateStatus一样的
	 *
	 * @return mixed
	 */
	public function act_api($param = array())
	{
        $send = Dever::preInput('pay_');
        $key = md5($this->key);
        ksort($send);
        $send['signature'] = md5($key . '&' . http_build_query($send));
        $signature = Dever::input('signature');
        if ($send['signature'] == $signature) {
            $product_id = $send['pay_product_id'];
            $uid = $send['pay_uid'];
            $cash = $send['pay_cash'];
            $order_id = $send['pay_order_id'];
            $status = $send['pay_status'];
            $msg = $send['pay_msg'];

            $order = Dever::db('act/order')->one(array('order_id' => $order_id, 'uid' => $uid));

            if ($send['pay_status'] == 2 && $order) {
                
                $update = array();
                $update['where_id'] = $order['id'];
                $update['status'] = 2;
                if ($order['type'] == 3 && !$order['code']) {
                    if ($order['system'] == 2) {
                        $code = Dever::load('code/lib/core')->createCodeByOrder($order);
                    } else {
                        $code = Dever::load('code/lib/core')->createCodeByOrder($order, -1);
                    }
                    
                    if ($code) {
                        $update['code'] = $code;
                    }
                }

                Dever::db('act/order')->update($update);

                $score = false;
                $num = false;
                $journal = Dever::load('act/order')->getJournal($order['product_id']);
                if ($order['buy_id'] > 0) {
                    $buy = Dever::load('act/order')->getBuy($order['buy_id']);
                    if ($buy && $buy['score'] > 0) {
                    	$score = $buy['num'] * $buy['score'];
                    } else {
                    	if ($order['type'] == 1) {
	                    	# 直接购买
	                    	$col = 'score';
	                    } elseif ($order['type'] == 3) {
	                    	$col = 'dh_score';
	                    }

	                    if ($journal && $buy && $journal[$col] > 0) {
	                        $score = $buy['num'] * $journal[$col];
	                    } elseif ($journal && $buy) {
	                        $num = $buy['num'];
	                    }
                    }

                    if ($buy && $buy['num']) {

                        $active = Dever::load('act/order')->getActive($order['product_id']);
                        $active_state = true;
                        if ($active && $active['status'] == 2) {
                            //$active_state = false;
                        }
                        if ($active && time() > $active['end']) {
                            $active_state = false;
                        }
                        if ($active_state) {
                            # 增加本数
                            Dever::load('act/lib/num')->submit($order['product_id'], $order['uid'], $buy['num']);
                        }
                    }
                }
                # 积分
                Dever::score($order['uid'], 'buy_journal', '购买小刊', '', $score, $num);

                if ($order['system'] == 2) {
                    return;
                }

                # 发消息
                $journal['id'] = $order['product_id'];
                $journal['name'] = $order['name'];
                if (strstr('-', $journal['name'])) {
                	$name = explode('-', $journal['name']);
                	$journal['name'] = $name[0];
                }
                
                //$journal = Dever::db('journal/info')->one($order['product_id']);

                if (Dever::project('message')) {
                    Dever::load('message/lib/data')->push(-1, $order['uid'], '购买提醒', '购买成功，您获得了 '.$journal['name'].' 的阅读资格！', 11, $order['cate_id'], 1, Dever::load('act/lib/note')->push(4, $journal['id'], $journal['name']));
                }

                $user = Dever::db('passport/user')->one($order['uid']);

                # 发短信
                /*
                if (isset($user['mobile']) && $user['mobile'] && Dever::project('sms') && $order['cate_id'] == 1) {
                    $send = array();
                    $send['name'] = $journal['name'];
                    Dever::load('sms/api.send', 'buy_journal', $user['mobile'], $send);
                }
                */

                # 发模板消息
                $wechat = Dever::db('passport/wechat')->one(array('uid' => $order['uid'], 'type' => 1, 'system_id' => $order['cate_id']));
                if ($wechat && Dever::project('wechat_applet')) {
                    $send['key'] = 'buy_journal';
                    $send['project_id'] = $order['cate_id'];
                    $send['touser'] = $wechat['openid'];
                    $send['page'] = Dever::config('base')->applet_index . '?scene=' . $order['uid'] . ',' . '4,' . $order['product_id'];
                    $send['data'] = array
                    (
                        'keyword1' => array('value' => date('Y年m月d日 H:i', $order['cdate'])),
                        'keyword2' => array('value' => '购买成功，您获得了 '.$journal['name'].' 的阅读资格！'),
                    );
                    $send['data'] = json_encode($send['data']);
                    $send['form_id'] = Dever::load('act/lib/form')->get($order['uid'], 2, $order['cate_id']);

                    if ($send['form_id']) {
                        Dever::load('wechat_applet/msg.send', $send);
                    }
                }

            } else {
                Dever::db('act/order')->update(array('where_id' => $order['id'], 'status' => 3));
            }
        }

        return 'ok';
	}

    public function send_api()
    {
        $uid = Dever::input('uid', 8);
        # 发模板消息
        $wechat = Dever::db('passport/wechat')->one(array('uid' => $uid));
        if ($wechat && Dever::project('wechat_applet')) {
            $send['key'] = 'buy_journal';
            $send['project_id'] = 2;
            $send['touser'] = $wechat['openid'];
            $send['page'] = Dever::config('base')->applet_index . '?scene=' . Dever::login($uid) . ',' . '4,' . $order['product_id'];
            $send['data'] = array
            (
                'keyword1' => array('value' => date('Y年m月d日 H:i', $order['cdate'])),
                'keyword2' => array('value' => '购买成功，您获得了 '.$journal['name'].' 的阅读资格！'),
            );
            $send['data'] = json_encode($send['data']);
            $send['form_id'] = Dever::load('act/lib/form')->get($uid, 2, $order['cate_id']);

            if ($send['form_id']) {
                Dever::load('wechat_applet/msg.send', $send);
            }
        }
    }
}