xyzshop/helper/notify_helper.php

<?php

/**
 * Created by PhpStorm.
 * User: stanley-king
 * Date: 16/6/26
 * Time: 下午9:30
 */
require_once (BASE_ROOT_PATH . '/helper/account_helper.php');
require_once (BASE_ROOT_PATH . '/helper/predeposit_helper.php');
require_once (BASE_ROOT_PATH . '/helper/bonus_helper.php');


class notify_helper
{
    private static function secs_days($secs)
    {
        $days = intval($secs / 86400) + ($secs % 86400 != 0) ? 1 : 0;
        return $days;
    }

    static public function onBonusExpire($warn_remain_days, $warn_interval_days)
    {
        //todo 以后检查时间是否可能是负数
        $mod_bonus = Model("user_bonus");
        $items = $mod_bonus->getNeedWarn($warn_remain_days, $warn_interval_days);
        if($items == false) return;

        $ids = array();
        foreach ($items as $key => $val) {
            $bonus = bonus\user_bonus::create_by_param($val);

            $leftsecs = $bonus->usable_time() - time();
            $remain_days = self::secs_days($leftsecs);
            $amount = $bonus->remain_amount();

            $param = array();
            $param['member_id'] = $bonus->user_id();
            $param['text'] = "红包过期通知:您价值{$amount}元的红包将在{$remain_days}天内过期,请尽快分享给好友或者买买买~";
            $param['go_type'] = 'bonus';

            QueueClient::push('upushSendMsg', $param);
            array_push($ids,$bonus->bonus_id());
        }

        if (!empty($ids)) {
            $mod_bonus->edit(array('bonus_id' => array('in', $ids)),array("notify_time" => time()));
        }
    }

    static public function bonus_expired()
    {
        $mod_bonus = Model("user_bonus");
        $items = $mod_bonus->getExpired();

        $ids = array();
        foreach ($items as $key => $val) {
            $bonus = bonus\user_bonus::create_by_param($val);
            $user_id = $bonus->user_id();
            $amount = $bonus->remain_amount();

            $pred = new predeposit_helper($user_id);
            $pred->bonus_expire($val);

            $param = array();
            $param['member_id'] = $user_id;
            $param['text'] = "红包过期通知:很遗憾,您价值{$amount}元的红包已经过期了,您早点分享给朋友,也是个人情:(";
            $param['go_type'] = 'bonus';
            QueueClient::push('upushSendMsg', $param);

            array_push($ids,$bonus->bonus_id());
        }

        if (!empty($ids)) {
            $mod_bonus->edit(array('bonus_id' => array('in', $ids)),array("expired" => 1));
        }
    }
}