wonderful/main/lib/Cron.php

<?php

namespace Main\Lib;

use Dever;

class Cron
{
    public function pays_api()
    {
        $where['product_id'] = 28;
        $where['type'] = 3;
        $where['status'] = 1;
        $where['cron_status'] = 1;
        $data = Dever::db('journal/order')->state($where);
        if ($data) {
            foreach ($data as $k => $v) {
                $this->getpays($v['order_id']);
                Dever::db('journal/order')->update(array('where_id' => $v['id'], 'cron_status' => 2));
            }
        }
    }

    private function getpays($order_id)
    {
        $url = 'http://mapi.jstyle.cn/pay/pay/?api.search&order_id='.$order_id.'&account_id=1';

        Dever::curl($url);
    }
	public function unpay_api()
	{}
	public function activeEnd_api()
	{}
	#用户未支付电子刊情况下，未支付订单超过2小时后，发送一次唤回支付提醒
    public function unpay()
    {
    	$time = 7200;
    	$where['cdate'] = time() + $time;
    	$where['note'] = 1;
    	$where['type'] = '1,3';
        $data = Dever::db('journal/order')->getDataByTime($where);

        if ($data) {
            foreach ($data as $k => $v) {
                $user = Dever::db('passport/user')->one($v['uid']);
                if (!$user) {
                    continue;
                }
                Dever::db('journal/order')->update(array('where_id' => $v['id'], 'note' => 2));

                $journal = Dever::db('journal/info')->one($v['product_id']);

                if (Dever::project('message')) {
                    Dever::load('message/lib/data')->push(-1, $v['uid'], '支付提醒', '您订阅的'.$journal['name'].'尚未支付！', 11, $v['cate_id'], 1, Dever::load('act/lib/note')->push(4, $journal['id'], $journal['name']));
                }
                
                # 发送短消息
                if (isset($user['mobile']) && $user['mobile'] && Dever::project('sms')) {
                    $send = array();
                    $send['name'] = $journal['name'];
                    //Dever::load('sms/api.send', 'note_live', $user['mobile'], $send);
                }

                # 发模板消息
                $wechat = Dever::db('passport/wechat')->one(array('uid' => $v['uid'], 'type' => 1, 'system_id' => $v['cate_id']));
                if ($wechat && Dever::project('wechat_applet')) {
                    $send['key'] = 'unbuy_journal';
                    $send['project_id'] = $v['cate_id'];
                    $send['touser'] = $wechat['openid'];
                    $send['page'] = Dever::config('base')->applet_index . '?scene=' . Dever::login($v['uid']) . ',' . '4,' . $v['product_id'];
                    $send['data'] = array
                    (
                        'keyword1' => array('value' => $journal['name']),
                        'keyword2' => array('value' => $v['cash']),
                        'keyword3' => array('value' => '您订阅的'.$journal['name'].'尚未支付！'),
                    );
                    $send['data'] = json_encode($send['data']);
                    $send['form_id'] = Dever::load('act/lib/form')->get($v['uid'], 2, $v['cate_id']);

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

        return 'ok';
    }

    #电子杂志活动结束前5个时，向己有电子刊阅读权限的用户发送活动结束提醒
    public function activeEnd()
    {
    	$time = 5*3600;
    	$where['ends'] = time();
        $where['end'] = $where['ends'] + $time;
        $data = Dever::db('journal/active')->getDataByTime($where);
        //echo Dever::sql();die;

        $test = Dever::input('test');
        if ($test == 1) {
            print_r($data);die;
        }
        if ($data) {
            foreach ($data as $ks => $vs) {

            	$journal = Dever::db('journal/info')->one($vs['info_id']);

            	$subscribe = Dever::db('act/subscribe')->state(array('note' => 1, 'type' => 4, 'data_id' => $vs['info_id']));

            	if ($subscribe) {
            		foreach ($subscribe as $k => $v) {
            			$user = Dever::db('passport/user')->one($v['uid']);
		                if ($user) {
		                    Dever::db('act/subscribe')->update(array('where_id' => $v['id'], 'note' => 2));

                            if (Dever::project('message')) {
                                Dever::load('message/lib/data')->push(-1, $v['uid'], '活动结束提醒', '您参与的'.$journal['name'].'积分排行榜活动还有5小时就要结束了，想要冲榜赢奖品的要抓紧机会呀〜', 11, $journal['cate_id'], 1, Dever::load('act/lib/note')->push(4, $journal['id'], $journal['name']));
                            }
                            
                            # 发送短消息
                            if (isset($user['mobile']) && $user['mobile'] && Dever::project('sms')) {
                                $send = array();
                                $send['name'] = $journal['name'];
                                //Dever::load('sms/api.send', 'note_live', $user['mobile'], $send);
                            }

                            # 发模板消息
                            $wechat = Dever::db('passport/wechat')->one(array('uid' => $v['uid'], 'type' => 1, 'system_id' => $journal['cate_id']));
                            if ($wechat && Dever::project('wechat_applet')) {
                                $send['key'] = 'service_end_note';
                                $send['project_id'] = $journal['cate_id'];
                                $send['touser'] = $wechat['openid'];
                                $send['page'] = Dever::config('base')->applet_index . '?scene=' . Dever::login($v['uid']) . ',' . '4,' . $journal['id'];
                                $send['data'] = array
                                (
                                    'keyword1' => array('value' => $journal['name']),
                                    'keyword2' => array('value' => date('Y-m-d H:i', $vs['end'])),
                                    'keyword3' => array('value' => '您参与的'.$journal['name'].'积分排行榜活动还有5小时就要结束了，想要冲榜赢奖品的要抓紧机会呀~'),
                                );
                                $send['data'] = json_encode($send['data']);
                                $send['form_id'] = Dever::load('act/lib/form')->get($v['uid'], 1, $journal['cate_id']);

                                if (!$send['form_id']) {
                                    $send['form_id'] = Dever::load('act/lib/form')->get($v['uid'], 2, $journal['cate_id']);
                                }

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

        return 'ok';
    }
}