修改红包退款通知

data/model/predeposit.model.php

@@ -447,6 +447,17 @@ class predepositModel extends Model {
                 $data_msg['freeze_amount'] = 0;
                 $data_msg['desc'] = $data_log['lg_desc'];
                 break;
+            case 'bonus_expire' :
+                $data_log['lg_av_amount'] = -$data['amount'];
+                $data_log['lg_desc'] = '红包过期，红包单号: '.$data['pdr_sn'] ;
+                $data_log['lg_admin_name'] = $data['admin_name'];
+                $data_pd['available_predeposit'] = array('exp','available_predeposit-'.$data['amount']);
+
+                $data_msg['av_amount'] = -$data['amount'];
+                $data_msg['freeze_amount'] = 0;
+                $data_msg['desc'] = $data_log['lg_desc'];
+
+                break;
 				////////////////////zmr>v20////////////////////////////////////
             case 'sys_add_money':
                 $data_log['lg_av_amount'] = $data['amount'];

data/model/user_bonus.model.php

@@ -231,8 +231,8 @@ class user_bonusModel extends Model
             return false;
         }
 
-        $cur_time = time();
-        $field = "bonus_id,user_id,type_sn,user_mobile,(usable_time-{$cur_time}) as leftsecs";
+        //$field = "bonus_id,user_id,type_sn,user_mobile,(usable_time-{$cur_time}) as leftsecs";
+        $field = "*";
         $day_secs = 24 * 3600;
         $left_warn_secs = intval($left_days) * $day_secs;
         $period_secs = intval($interval_days) * $day_secs;
@@ -254,9 +254,9 @@ class user_bonusModel extends Model
 
     public function getExpired()
     {
-        $field = 'bonus_id,user_id,type_sn,bonus_value';
+        //$field = 'bonus_id,user_id,type_sn,bonus_value';
         $cond = array('expired' => 0,'usable_time' => array('elt',time()));
-        $ret = $this->getBonusList($cond,$field);
+        $ret = $this->getBonusList($cond,"*");
 
         return $ret;
     }

helper/notify_helper.php

@@ -8,7 +8,7 @@
  */
 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
@@ -21,22 +21,26 @@ class notify_helper
 
     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) {
-            $user_id = $val["user_id"];
-            $remain_days = self::secs_days(intval($val["leftsecs"]));
+            $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'] = $user_id;
-            $param['text'] = "红包过期通知:您领取的红包将在{$remain_days}天内过期.";
+            $param['member_id'] = $bonus->user_id();
+            $param['text'] = "红包过期通知:您价值{$amount}元的红包将在{$remain_days}天内过期,请尽分享给好友或者买买买~";
             $param['go_type'] = 'bonus';
 
             QueueClient::push('upushSendMsg', $param);
-            array_push($ids,intval($val["bonus_id"]));
+            array_push($ids,$bonus->bonus_id());
         }
 
         if (!empty($ids)) {
@@ -51,18 +55,20 @@ class notify_helper
 
         $ids = array();
         foreach ($items as $key => $val) {
-            $user_id = $val["user_id"];
+            $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'] = "红包过期通知:您领取的红包已经过期.";
+            $param['text'] = "红包过期通知:很遗憾,您价值{$amount}元的红包已经过期了,您干哈不早点分享给您的朋友呢:(";
             $param['go_type'] = 'bonus';
             QueueClient::push('upushSendMsg', $param);
 
-            array_push($ids,intval($val["bonus_id"]));
+            array_push($ids,$bonus->bonus_id());
         }
 
         if (!empty($ids)) {