处理发送个人消息

core/framework/libraries/sendmembermsg.php

@@ -1,119 +0,0 @@
-<?php
-/**
- *
- *
- *
- * @package    library* www.33hao.com 专业团队 提供售后服务
- */
-
-require_once(BASE_ROOT_PATH . '/helper/push_sender.php');
-require_once(BASE_ROOT_PATH . '/helper/sms_helper.php');
-
-class sendMemberMsg
-{
-    private $code = '';
-    private $member_id = 0;
-    private $member_info = array();
-    private $mobile = '';
-
-    public function set($key,$value){
-        $this->$key = $value;
-    }
-
-    public function send($param = array())
-    {
-        $msg_tpl = rkcache('member_msg_tpl', true);
-        if (!isset($msg_tpl[$this->code]) || $this->member_id <= 0) {
-            return false;
-        }
-
-        $tpl_info = $msg_tpl[$this->code];
-
-        $setting_info = Model('member_msg_setting')->getMemberMsgSettingInfo(array('mmt_code' => $this->code, 'member_id' => $this->member_id), 'is_receive');
-        if (empty($setting_info) || $setting_info['is_receive'])
-        {
-            // 发送站内信
-            if ($tpl_info['mmt_message_switch']) {
-                $message = ncReplaceText($tpl_info['mmt_message_content'],$param);
-                $this->sendMessage($message);
-            }
-
-            $push_success = false;
-            if ($tpl_info['mmt_push_switch']) {
-                $message = ncReplaceText($tpl_info['mmt_push_content'],$param);
-                $info = push_helper::format_msg($this->member_id,$message);
-                $sender = new push_sender();
-                $push_success = $sender->send($info);
-            }
-
-            // 发送短消息
-            if ($push_success == false && $tpl_info['mmt_short_switch'])
-            {
-                $sms_code = $setting_info['mmt_short_code'];
-                $this->getMemberInfo();
-                if (!empty($this->mobile)) {
-                    $this->member_info['member_mobile'] = $this->mobile;
-                }
-
-                if ($this->member_info['member_mobile_bind'] && !empty($this->member_info['member_mobile'])) {
-                    $param['site_name'] = C('site_name');
-                    $message = ncReplaceText($tpl_info['mmt_short_content'],$param);
-                    $this->sendShort($this->member_info['member_mobile'], $message);
-                }
-            }
-        }
-    }
-
-    /**
-     * 会员详细信息
-     */
-    private function getMemberInfo() {
-        if (empty($this->member_info)) {
-            $this->member_info = Model('member')->getMemberInfoByID($this->member_id);
-        }
-    }
-
-    /**
-     * 发送站内信
-     * @param unknown $message
-     */
-    private function sendMessage($message) {
-        //添加短消息
-        $model_message = Model('message');
-        $insert_arr = array();
-        $insert_arr['from_member_id'] = 0;
-        $insert_arr['member_id'] = $this->member_id;
-        $insert_arr['msg_content'] = $message;
-        $insert_arr['message_type'] = 1;
-
-        $model_message->saveMessage($insert_arr);
-    }
-
-    /**
-     * 发送短消息
-     * @param unknown $number
-     * @param unknown $message
-     */
-    private function sendShort($number, $message) {
-        $sms = new Sms();
-        $sms->send($number, $message);
-    }
-
-    /**
-     * 发送邮件
-     * @param unknown $number
-     * @param unknown $subject
-     * @param unknown $message
-     */
-    private function sendMail($number, $subject, $message) {
-    	//即时发送邮箱 v3-b11
-    	$email = new Email();
-        $email->send_sys_email($number,$subject,$message);
-        // 计划任务代码
-        /*$insert = array();
-        $insert['mail'] = $number;
-        $insert['subject'] = $subject;
-        $insert['contnet'] = $message;
-        Model('mail_cron')->addMailCron($insert);*/
-    }
-}

core/framework/libraries/sms.php

@@ -95,8 +95,14 @@ class Sms
         return $this->send_msg($mobile, $content['datas'], $templates[$type]);
     }
 
-    public function send_oper($mobile,$type) {
-        return $this->send_msg($mobile, array('time'=>'5'), $type);
+    public function send_oper($mobile,$type,$params = null)
+    {
+        if($params == null) {
+            return $this->send_msg($mobile, array('time'=>'5'), $type);
+        } else {
+            $params['time'] = '5';
+            return $this->send_msg($mobile, $params, $type);
+        }
     }
 
     /*

crontab/control/date.php

@@ -531,6 +531,8 @@ class dateControl extends BaseCronControl
                         'goods_url' => urlShop('goods', 'index', array('goods_id' => $val['goods_id']))
                 );
                 $param['number'] = array('mobile' => $val['an_mobile'], 'email' => $val['an_email']);
+                $param['sms_param'] = array('goods_name' => $val['goods_name']);
+
                 QueueClient::push('sendMemberMsg', $param);
             }
     

data/logic/queue.logic.php

@@ -78,7 +78,7 @@ class queueLogic
     public function editVoucherState($voucher_list)
     {
         $model_voucher = Model('voucher');
-        $send = new sendMemberMsg();
+        $send = new message_sender();
         foreach ($voucher_list as $store_id => $voucher_info) {
             $update = $model_voucher->editVoucher(array('voucher_state' => 2), array('voucher_id' => $voucher_info['voucher_id']), $voucher_info['voucher_owner_id']);
             if ($update) {
@@ -213,10 +213,12 @@ class queueLogic
      */
     public function sendMemberMsg($param)
     {
-        $send = new sendMemberMsg();
+        $send = new message_sender();
 
         $send->set('code', $param['code']);
         $send->set('member_id', $param['member_id']);
+        $send->set('sms_param', $param['sms_param']);
+
         if (!empty($param['number']['mobile'])) $send->set('mobile', $param['number']['mobile']);
         if (!empty($param['number']['email'])) $send->set('email', $param['number']['email']);
         $send->send($param['param']);

queue/model/queue.model.php

@@ -48,7 +48,7 @@ class queueModel extends Model{
 //             if (!$update) throw new Exception('代金券更新失败');
 
             // 发送用户店铺消息
-            $send = new sendMemberMsg();
+            $send = new message_sender();
             $send->set('member_id', $voucher_info['voucher_owner_id']);
             $send->set('code', 'voucher_use');
             $param = array();
@@ -147,7 +147,7 @@ class queueModel extends Model{
      * 发送会员消息
      */
     public function sendMemberMsg($param) {
-        $send = new sendMemberMsg();
+        $send = new message_sender();
         $send->set('code', $param['code']);
         $send->set('member_id', $param['member_id']);
         $send->send($param['param']);