server/Gameserver/Amfphp/Model/User/UserInteractModel.php

<?php

namespace loyalsoft;

/**
 * 用户交互信息数据模型
 * 注：mem中是独立于userInfo的存在, 以减少交互操作的时候出现写入冲突产生覆盖的情况。
 * attention: 读写数据的时候,利用redis的watch机制实现事务写入,加上自动重试机制. (Ps.这是目标,gwang.20170426153414)
 *
 * @version
 *          1.0.0 Created at 2017-3-25. by --gwang
 * @author gwang (mail@wanggangzero.cn)
 * @copyright ? 2017-3-25, SJZ LoyalSoft Corporation & gwang. All rights reserved.
 */
class UserInteractModel extends Object_ext
{

    public $uid;
    public $zoneid;
    // ------------字段声明-------------

    /**
     * 邮件列表
     * @var object
     */
    public $mailQueue;

    /**
     * 邮件序列id
     * @var int
     */
    public $mailMaxId = 0;

    /**
     * 系统邮件记录[存在于系统公共缓冲区的邮件仅能接收一次]
     * @var array
     */
    public $sysMailRecord;

// ------------ 初始化 ------------------

    /**
     * 创建账号的时候执行初始化.
     */
    public function initialize()
    {
        $this->mailQueue = ObjectInit();
        $this->mailMaxId = 10000;
        $this->sysMailRecord = ArrayInit();
    }

// ----------- 方法 ---------------------
    // <editor-fold defaultstate="collapsed" desc="     公开方法    ">

    /**
     * 新增系统邮件
     * @param int  $sysId    邮件的id
     * @param string $title  邮件标题
     * @param type $content  邮件正文
     * @param type $itemid   道具id （附加于tag字段）
     * @param type $startts  生效时间
     * @param type $endts    过期时间
     * @param type $interact  目标交互体
     */
    static function insertSysMail($sysId, $title, $content, $itemid, $startts, $endts, &$interact)
    {
        self::insertMail("0", "系统邮件", "", "", 1, $title, $content, $itemid, $startts, $endts, $interact);
        if ($sysId != 0) {
            $sysMailRecord = $interact->sysMailRecord;
            $sysMailRecord[] = $sysId;
            $interact->sysMailRecord = $sysMailRecord;
        }
    }

    /**
     * 新增邮件
     * @param string $fromoid 发送人的oid
     * @param type $name      发送人的呢称
     * @param type $pf        pf
     * @param type $img       图像
     * @param type $type      邮件类型
     * @param string $title   邮件标题
     * @param string $content 邮件正文
     * @param type $tag   额外标签可以传递数据
     * @param ts $startts 生效时间
     * @param ts $endts   过期时间
     * @param UserInteractModel $interact 目标交互体
     * @return void
     */
    static function insertMail($fromoid, $name, $pf, $img, $type, $title, $content, $tag, $startts, $endts, &$interact)
    {
        if (CommUtil::tsCurrent() > $endts) {
            return;
        }
        $interact->mailMaxId++;
        $mailMaxId = $interact->mailMaxId;
        $mail = new EmailModel;
        $mail->fromoid = $fromoid;
        $mail->name = $name;
        $mail->pf = $pf;
        $mail->img = $img;
        $mail->type = $type;
        $mail->title = $title;
        $mail->content = $content;
        $mail->tag = $tag;
        $mail->startts = $startts;
        $mail->endts = $endts;
        $mail->ts = CommUtil::tsCurrent();
        $interact->mailQueue->$mailMaxId = $mail;
        # 记录日志
        self::_insertMailRecord($interact->oid, $interact->zoneid, $mail, $mailMaxId);
    }

    /**
     * 插入发送邮件的日志
     * @param string uid
     * @param int $zoneid
     * @param EmailModel $mail
     * @param int $mailId
     */
    static function _insertMailRecord($uid, $zoneid, $mail, $mailId)
    {
        $sql = <<<ins
INSERT INTO `tab_mailrecord` (oid,`zoneid`,mailId, fromoid,`name`, pf,img,type,title,content,tag,startts,endts,insertts)
    VALUES ('%s',%d,%d,'%s','%s','%s','%s',%d,'%s','%s','%s',%d,%d,now());
ins;
        $insertstr = sprintf($sql, $uid, $zoneid, $mailId, $mail->fromoid, $mail->name, #
                $mail->pf, $mail->img, $mail->type, $mail->title, $mail->content, #
                $mail->tag, $mail->startts, $mail->endts);
        daoInst()->query($insertstr);
    }

    /**
     * 获取邮件序列[自动过滤尚未到(生效)期的邮件,自动删除已过期的邮件]
     * @param UserInteractModel $interact Description
     */
    static function getMailQueue($interact)
    {
        $mailList = ObjectInit();
        $mailQueue = $interact->mailQueue;
        foreach ($mailQueue as $mailId => $mail) {
            $ts = CommUtil::tsCurrent();
            if ($ts >= $mail->startts) {
                if ($ts > $mail->endts) {
                    self::deleteMail($mailId, $interact);
                } else {
                    $mailList->$mailId = $mail;
                }
            }
        }
        return $mailList;
    }

    /**
     * 删除邮件[附件接收完毕之后]
     * @param type $mailId
     * @param UserInteractModel $interact Description
     */
    static function deleteMail($mailId, &$interact)
    {
        self::_drawMailRecord($mailId, $interact); # 领取记录
        StlUtil::dictRemove($interact->mailQueue, $mailId);
    }

    /**
     * 更新领取记录
     * @param type $mailId
     * @param UserInteractModel $interact
     */
    static function _drawMailRecord($mailId, $interact)
    {
        $sql = "update tab_mailrecord set drawedts=now() where mailId=%d and zoneid=%s and uid=%s;";
        $updatestr = sprintf($sql, $mailId, $interact->zoneid, $interact->uid);
        daoInst()->query($updatestr);
    }

// </editor-fold>
}