game-sdk/simplewind/extend/huoMpMsg/model/MpMsgLogModel.php

<?php
/**
 * MpMsgLogModel.php UTF-8
 * 微信小程序客服消息
 *
 * @date    : 2018/9/14 18:27
 *
 * @license 这不是一个自由软件，未经授权不许任何使用和传播。
 * @author  : wuyonghong <wyh@huosdk.com>
 * @version : HuoMp 1.0
 */

namespace huoMpMsg\model;

use huo\model\log\LogModel;

class MpMsgLogModel extends LogModel {
    /* 数据库名 */
    protected $table = 'mp_log_mp_msg';

    /**
     * 插入数据
     *
     * @param      $data
     * @param bool $replace
     * @param bool $get_last_insert_id
     *
     * @return bool|int|string
     */
    public function insertLog($data, $replace = false, $get_last_insert_id = true) {
        $_data['mp_id'] = get_val($data, 'mp_id', '');
        $_data['wx_msg_id'] = get_val($data, 'wx_msg_id', 0);
        $_data['source_id'] = get_val($data, 'source_id', '');
        $_data['open_id'] = get_val($data, 'open_id', '');
        $_data['msg_type'] = get_val($data, 'msg_type', 'text');
        $_data['pic_url'] = get_val($data, 'pic_url', '');
        $_data['media_id'] = get_val($data, 'media_id', '');
        $_data['title'] = get_val($data, 'title', '');
        $_data['mini_app_id'] = get_val($data, 'mini_app_id', '');
        $_data['page_path'] = get_val($data, 'page_path', '');
        $_data['thumb_url'] = get_val($data, 'thumb_url', '');
        $_data['thumb_media_id'] = get_val($data, 'thumb_media_id', '');
        $_data['text'] = get_val($data, 'text', '');
        $_data['wx_create_time'] = get_val($data, 'wx_create_time', 0);
        $_data['create_time'] = time();
        $_data['date'] = date('Y-m-d', $_data['create_time']);

        return parent::insertLog($_data, $replace, $get_last_insert_id);
    }

    /**
     * @return bool|int
     * @throws \think\db\exception\BindParamException
     * @throws \think\exception\PDOException
     */
    function checkTable() {
        $this->table = $this->getPartitionTableName(
            $this->partition_data, $this->partition_field, $this->partition_rule
        );
        $_sql = "CREATE TABLE IF NOT EXISTS `".$this->table."` (";
        $_sql .= "  `id` int(11) unsigned NOT NULL AUTO_INCREMENT COMMENT 'ID',";
        $_sql .= "  `date` date NOT NULL COMMENT '日期',";
        $_sql .= "  `wx_msg_id` bigint(20) unsigned NOT NULL DEFAULT '0' COMMENT 'MsgId 消息id，64位整型',";
        $_sql .= "  `mp_id` varchar(32) NOT NULL DEFAULT '' COMMENT '小程序、公众号appid 支付商户号',";
        $_sql .= "  `source_id` varchar(64) NOT NULL DEFAULT '0' COMMENT 'ToUserName 小程序的原始ID',";
        $_sql .= "  `open_id` varchar(64) NOT NULL DEFAULT '' COMMENT 'FromUserName 发送者的openid',";
        $_sql .= "  `msg_type` varchar(16) NOT NULL DEFAULT 'text' COMMENT 'MsgType 消息类型',";
        $_sql .= "  `pic_url` varchar(255) NOT NULL DEFAULT '' COMMENT 'PicUrl 图片链接（由系统生成）',";
        $_sql .= "  `media_id` varchar(64) NOT NULL DEFAULT '' COMMENT 'MediaId 图片消息媒体id，',";
        $_sql .= "  `title` varchar(64) NOT NULL DEFAULT '' COMMENT 'Title 标题',";
        $_sql .= "  `mini_app_id` varchar(64) NOT NULL DEFAULT '' COMMENT 'AppId 小程序appid',";
        $_sql .= "  `page_path` varchar(32) NOT NULL DEFAULT '' COMMENT 'PagePath 小程序appid',";
        $_sql .= "  `thumb_url` varchar(255) NOT NULL DEFAULT '' COMMENT 'ThumbUrl 封面图片的临时cdn链接',";
        $_sql .= "  `thumb_media_id` varchar(255) NOT NULL DEFAULT '' COMMENT 'ThumbMediaId 封面图片的临时素材id',";
        $_sql .= "  `text` text NOT NULL COMMENT 'Content 文本消息内容',";
        $_sql .= "  `wx_create_time` bigint(20) unsigned NOT NULL DEFAULT '0' COMMENT 'CreateTime 消息创建时间(整型）',";
        $_sql .= "  `create_time` bigint(20) unsigned NOT NULL DEFAULT '0' COMMENT '创建时间',";
        $_sql .= "  PRIMARY KEY (`id`),";
        $_sql .= "  UNIQUE KEY `mmm_msg_unique` (`wx_msg_id`),";
        $_sql .= "  KEY `mmm_type_index` (`msg_type`),";
        $_sql .= "  KEY `mmm_time_index` (`wx_create_time`)";
        $_sql .= ") ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='微信小程序客服消息';";

        return $this->execute($_sql);
    }

    /**
     * 是否存在此消息
     *
     * @param integer $wx_msg_id 微信消息ID
     *
     * @return int
     */
    public function hasMsg($wx_msg_id) {
        $_date = date('Y-m-d');
        $_map['wx_msg_id'] = $wx_msg_id;
        $_cnt = $this->computeTable($_date)->where($_map)->count();
        if ($_cnt > 0) {
            return $_cnt;
        }

        return 0;
    }
}