jh-admin/addon/store/shopapi/controller/Message.php

<?php
/**
 * SaaSMall商城系统 - 团队十年电商经验汇集巨献!
 * =========================================================
 * Copy right 2019-2029 上海牛之云网络科技有限公司, 保留所有权利。
 * ----------------------------------------------
 * 官方网址: https://www.gobuysaas.com
 * 这不是一个自由软件！您只能在不用于商业目的的前提下对程序代码进行修改和使用。
 * 任何企业和个人不允许对程序代码以任何形式任何目的再发布。
 * =========================================================
 */

namespace addon\store\shopapi\controller;

use app\model\message\Message as MessageModel;
use app\model\message\Sms;
use app\model\site\Site;


class Message extends BaseStoreApi
{
    /**
     *  消息管理 列表
     */
    public function lists()
    {
        $site_model = new Site();
        $site_addon = $site_info = $site_model->getSiteAddonStr($this->site_id);
        $site_addon = $site_addon[ 'data' ];

        $message_model = new MessageModel();
        //买家消息
        $member_message_list_result = $message_model->getSmsMessageList($this->site_id, [ [ 'app', 'in', [ 'system', $this->app_module ] ], [ 'addon', 'in', array_merge(explode(',', $site_addon), [ '' ]) ], [ 'message_type', '=', 1 ] ]);
        $member_message_list = $member_message_list_result[ "data" ];
        //卖家通知
        $shop_message_list_result = $message_model->getSmsMessageList($this->site_id, [ [ 'app', 'in', [ 'system', $this->app_module ] ], [ 'addon', 'in', array_merge(explode(',', $site_addon), [ '' ]) ], [ 'message_type', '=', 2 ] ]);
        $shop_message_list = $shop_message_list_result[ "data" ];
        $data = [];
        $data[ 'member_message_list' ] = $member_message_list;
        $data[ 'shop_message_list' ] = $shop_message_list;
        return $this->response($this->success($data));
    }

    /**
     * 编辑短信模板(跳转)
     */
    public function editSmsMessage()
    {
        $keywords = isset($this->params[ 'keywords' ]) ? $this->params[ 'keywords' ] : '';
        $sms_model = new Sms();
        $edit_data_result = $sms_model->doEditSmsMessage();

        if (empty($edit_data_result[ "data" ][ 0 ])) return $this->response($this->error([], "没有开启的短信方式!"));

        $edit_data = $edit_data_result[ "data" ][ 0 ];
        $edit_url = $edit_data[ "shop_url" ];
        return $this->response($this->success(addon_url($edit_url, [ "keywords" => $keywords ])));
    }

    /**
     * 短信记录
     */
    public function smsRecords()
    {
        $sms_model = new Sms();

        $page = isset($this->params[ 'page' ]) ? $this->params[ 'page' ] : 1;
        $page_size = isset($this->params[ 'page_size' ]) ? $this->params[ 'page_size' ] : PAGE_LIST_ROWS;
        $search_text = isset($this->params[ 'search_text' ]) ? $this->params[ 'search_text' ] : '';
        $status = isset($this->params[ 'status' ]) ? $this->params[ 'status' ] : '';
        $condition = [ [ 'site_id', '=', $this->site_id ] ];
        if (!empty($search_text)) {
            $condition[] = [ "keywords_name", "like", "%" . $search_text . "%" ];
        }
        if ($status !== '') {
            $condition[] = [ 'status', '=', $status ];
        }
        $list = $sms_model->getSmsRecordsPageList($condition, $page, $page_size);
        return $this->response($list);

    }

    public function smsData()
    {
        $site_model = new Site();
        $site_info = $site_model->getSiteInfo([ [ 'site_id', '=', $this->site_id ] ], 'sms_num,sms_used_num');
        $sms_data = [
            'total_num' => $site_info[ 'data' ][ 'sms_num' ] + $site_info[ 'data' ][ 'sms_used_num' ],
            'sms_num' => $site_info[ 'data' ][ 'sms_num' ],
            'sms_used_num' => $site_info[ 'data' ][ 'sms_used_num' ]
        ];
        return $this->response($this->success($sms_data));
    }

    /**
     * 删除短信记录
     */
    public function deleteSmsRecords()
    {
        $ids = isset($this->params[ 'ids' ]) ? $this->params[ 'ids' ] : '';

        $sms_model = new Sms();
        $condition = array (
            [ "id", "in", $ids ], [ 'site_id', '=', $this->site_id ]
        );
        $result = $sms_model->deleteSmsRecords($condition);
        return $this->response($result);
    }


    /**
     * 编辑短信模板(跳转)
     */
    public function editEmailMessage()
    {
        $message_model = new MessageModel();
        $keywords = isset($this->params[ 'keywords' ]) ? $this->params[ 'keywords' ] : '';
        $email_title = isset($this->params[ 'email_title' ]) ? $this->params[ 'email_title' ] : '';//邮件标题
        $email_content = isset($this->params[ 'email_content' ]) ? $this->params[ 'email_content' ] : '';//邮件内容
        $email_is_open = isset($this->params[ 'email_is_open' ]) ? $this->params[ 'email_is_open' ] : 0;//邮件开关

        $info_result = $message_model->getMessageInfo($this->site_id, $keywords);
        $info = $info_result[ "data" ];

        if (empty($info)) return $this->response($this->error([], "不存在的模板信息!"));

        $data = array (
            'email_title' => $email_title,
            'email_content' => $email_content,
            "email_is_open" => $email_is_open,
        );
        $condition = array (
            [ "keywords", "=", $keywords ],
            [ 'site_id', '=', $this->site_id ],
            [ 'app_module', '=', $this->app_module ]
        );
        $this->addLog("编辑邮箱模板:" . $keywords);
        $res = $message_model->editMessage($data, $condition);
        return $this->response($res);

    }

    /**
     * 短信详情
     */
    public function messageInfo()
    {
        $message_model = new MessageModel();
        $keywords = isset($this->params[ 'keywords' ]) ? $this->params[ 'keywords' ] : '';
        $info_result = $message_model->getMessageInfo($this->site_id, $keywords);
        return $this->response($info_result);
    }

    public function edit()
    {

        $keywords = isset($this->params[ 'keywords' ]) ? $this->params[ 'keywords' ] : '';
        $sms_is_open = isset($this->params[ 'sms_is_open' ]) ? $this->params[ 'sms_is_open' ] : 0;

        $res = event('EditMessage', [ 'sms_is_open' => $sms_is_open, 'site_id' => $this->site_id, 'keywords' => $keywords ]);
        return $this->response($this->success(isset($res[ 0 ]) ? $res[ 0 ] : []));
    }


    /**
     * 短信重新发送
     */
    public function sendMessage()
    {
        $id = isset($this->params[ 'id' ]) ? $this->params[ 'id' ] : '';

        $sms_model = new Sms();
        $result = $sms_model->againSendSms($id);
        return $this->response($this->success($result));
    }
}