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));
        }
    }

    static public function release_bonus()
    {
        $bonus_type = Model('bonus_type');

        $one_hour = 60 * 60;
        $condition = array('remain_amount' => array('gt',0),'is_refund' => 0,'send_end_date' =>array('lt',time() - $one_hour));
        $bonus_types = $bonus_type->getTypeList($condition,'','*','',false);
        if(empty($bonus_types) || count($bonus_types) <= 0) {
            return;
        }

        foreach($bonus_types as $type)
        {
            try
            {
                $pred = new predeposit_helper($type['sender_id']);

                Model::beginTransaction();
                $bonus_type->edit(array('type_id' =>$type['type_id']),array('is_refund' => 1,'refund_time' => time()));
                if ($bonus_type->affected_rows() <= 0) {
                    Model::rollback();
                    $sresult = implode(',',$type);
                    Log::record("bonus refund 更新状态失败，result:{$sresult}.");
                } else {
                    $pred->bonus_refund($type);
                    $condition = array('type_id' =>$type['type_id'],'bonus_status' => array('in','0,1'));
                    Model('user_bonus')->where($condition)->delete();
                    Model::commit();
                }
            }
            catch (Exception $e)
            {
                Model::rollback();

                $sresult = implode(',',$type);
                Log::record('bonus refund : error:' . $e->getMessage() . " result:{$sresult}.");
            }
        }
    }
}