littleTiger/application/common/logic/MessageNoticeLogic.php

<?php
/**
 * tpshop
 * ============================================================================
 * 版权所有 2015-2027 深圳搜豹网络科技有限公司，并保留所有权利。
 * 网站地址: http://www.tp-shop.cn
 * ----------------------------------------------------------------------------
 * 这不是一个自由软件！您只能在不用于商业目的的前提下对程序代码进行修改和使用 .
 * 不允许对程序代码以任何形式任何目的的再发布。
 * ============================================================================
 * Author: IT宇宙人
 * Date: 2015-09-09
 */

namespace app\common\logic;

use app\common\model\CouponList;
use app\common\model\UserMessage;
use app\common\util\TpshopException;
use think\Model;
use think\db;

/**
 * 通知消息逻辑定义
 * Class CatsLogic
 * @package admin\Logic
 */
class MessageNoticeLogic extends MessageBase
{
    /**
     * 添加一条通知消息
     */
    public function addMessage(){
        $this->message['category'] = 0;
        db('message_notice')->insert($this->message);
        $message_id = db('message_notice')->getLastInsID();
        if($message_id) {
            $this->message['message_id'] = $message_id;
        }
    }
    /**
     * 发一条通知消息,数组参数如 data
     * @param array $send_data |发送内容
     */
    public function sendMessageNotice($send_data=[])
    {

        $data['message_type'] = 0; // 0个人，1全体
        $data['message_title'] = ''; //  消息标题,如果空,则用模板名称
        $data['message_content'] = ''; // 如果空，则用模板内容
        // type:0系统公告1降价通知2优惠券到账提醒3优惠券使用成功提醒4优惠券即将过期提醒5预售订单尾款支付提醒6提现到账提醒
        $data['type'] = 0;
        $data['prom_id'] = ''; // 活动id
        $data['message_uri'] = ''; // 查看详情
        $data['mmt_code'] = ''; // 消息模板编号
        $data['users'] = []; // 向用户发消息
        $data['message_val'] = []; // ['key1'=>'val','key2'=>'val']; // 模板消息变量名key和值
        $data = array_merge($data, $send_data);
        if (!empty($data['users'])) {
            $where['user_id'] = ['in', $data['users']];
            $where['email_validated'] = 1;
            $data['email'] = db('users')->where($where)->column('email');
        }
        $data['category'] = 0; // 通知类型
        $this->setSendData($data);
        $this->sendMessage();
    }

    /**
     * 删除消息
     * @param $prom_id |活动id
     * @param $type |活动类型
     * @throws \think\Exception
     */
    public function deletedMessage($prom_id, $type)
    {
        $message_id = db('message_notice')->where(['prom_id' => $prom_id, 'type' => $type])->value('message_id');
        if ($message_id) {
            db('message_notice')->where(['prom_id' => $prom_id, 'type' => $type])->delete();
            db('user_message')->where(['message_id' => $message_id, 'category' => 0])->delete();
        }
    }

    /**
     * 获取编号
     * @param $type
     * @return string
     */
    public function getCodeByType($type)
    {
        switch ($type) {
            case 0:
                $mmt_code = 'message_notice';
                break;
            case 1:
                $mmt_code = '';
                break;
            case 2:
                $mmt_code = 'coupon_get_notice';
                break;
            case 3:
                $mmt_code = 'coupon_use_notice';
                break;
            case 4:
                $mmt_code = 'coupon_will_expire_notice';
                break;
            case 5:
                $mmt_code = '';
                break;
            case 6:
                $mmt_code = 'withdrawals_notice';
                break;
            default:
                $mmt_code = '';
                break;
        }
        return $mmt_code;
    }

    /**
     * 提现到账消息,多次调用
     * @param $withdrawals_id
     * @param $uid
     * @param $money
     */
    public function withdrawalsNotice($withdrawals_id, $uid, $money)
    {
        $this->setType(6);
        $this->setMessageTitle('提现已到账');
        $this->setMessageContent(''); // 空着，使用模板内容
        $this->setPromId($withdrawals_id);
        $this->setUsers([$uid]);
        $this->setMessageVal(['money' => $money]);
        $this->sendMessage();
    }
    /**
     * 发放优惠券到账消息
     * @param $cid
     * @param $uid_arr
     */
    public function getCouponNotice($cid, $uid_arr)
    {
        $data['prom_id'] = $cid;
        $data['type'] = 2;
        $data['mmt_code'] = 'coupon_get_notice';
        $data['message_title'] = '优惠券已到账';

        $name = db('coupon')->where('id', $cid)->value('name');
        foreach ($uid_arr as $user_id) {
            $data['users'] = [$user_id];
            $data['message_content'] = $name;
            $this->sendMessageNotice($data);
        }
    }

    /**
     * 优惠券使用消息
     * @param order_id
     * @param couponId
     * @param user_id
     */
    public function useCouponNotice($order_id, $couponId, $user_id)
    {
        $data['prom_id'] = $order_id;
        $data['type'] = 3;
        $data['mmt_code'] = 'coupon_use_notice';
        $data['message_title'] = '优惠券已使用';
        $data['users'] = [$user_id];
        $cid = db('coupon_list')->where('id', $couponId)->value('cid');
        $data['message_content'] = db('coupon')->where('id', $cid)->value('name');
        $this->sendMessageNotice($data);
    }

    /**
     * 删除优惠券消息
     * @param $cid
     * @throws \think\Exception
     */
    public function delCouponNotice($cid)
    {

        $uid = db('coupon_list')->where('cid', $cid)->value('uid');
        if ($uid) {
            $where['type'] = 2;
            $where['prom_id'] = $cid;
            $message_id = db('message_notice')->where($where)->column('message_id');
            if ($message_id) {
                db('message_notice')->where($where)->delete();
                db('user_message')->where(['message_id' => ['in', $message_id], 'category' => 0])->delete();
            }
        }
    }

    /**
     * 优惠券将过期
     * @param user_id
     */
    public function couponWillExpire($user_id)
    {
        $where_list['uid'] = $user_id;
        $where_list['status'] = 0;
        $couponList = new CouponList();
        $coupon_list = $couponList->where($where_list)->select();
        foreach ($coupon_list as $coupon) {
            if ($coupon->coupon->is_expiring_notice == 1
                && $coupon->coupon->use_end_time > time()
                && $coupon->coupon->status == 1) {
                $this->couponWillExpireNotice($coupon['cid'], $user_id);
            }
        }

    }

    /**
     * 发送优惠券将过期消息
     * @param $cid
     * @param $user_id
     */
    public function couponWillExpireNotice($cid, $user_id)
    {
        // 谁没有领
        $where = [
            'message_type' => 0,
            'type' => 4,
            'prom_id' => $cid
        ];
        $message_id_arr = db('message_notice')->where($where)->column('message_id');
        $where_message['category'] = 0;
        $where_message['user_id'] = $user_id;
        $where_message['message_id'] = ['in', $message_id_arr];
        $message_id = db('user_message')->where($where_message)->value('message_id');
        if ($message_id) {
            return;
        }

        $data['prom_id'] = $cid;
        $data['type'] = 4;
        $data['mmt_code'] = 'coupon_will_expire_notice';
        $data['message_title'] = '优惠券即将过期';

        $message_content = db('coupon')->where('id', $cid)->value('name');
        $data['users'] = [$user_id];
        $data['message_content'] = $message_content;
        $this->sendMessageNotice($data);
    }

    /**
     * 检测必填参数
     * @return bool
     */
    public function checkParam()
    {
        if (empty($this->message['message_title']) || empty($this->message['mmt_code'])
            || empty($this->message['type']) || empty($this->message['send_time'])
        ) {
            return false;
        }
        return true;
    }

    /**
     * 必填
     * type: 0系统公告1降价通知2优惠券到账提醒3优惠券使用提醒4优惠券即将过期提醒5预售订单尾款支付提醒6提现到账提醒
     * @param $value
     */
    public function setType($value){
        $this->message['type'] = $value;
        $this->message['mmt_code'] = $this->getCodeByType($value);
    }
    /**
     * 可空
     * @param $value
     */
    public function setPromId($value){
        $this->message['prom_id'] = $value;
    }
}