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