<?php
namespace app\common\model\plus\release;

use app\common\model\BaseModel;

/**
 * 消息模型
 */
class Chat extends BaseModel
{
    protected $pk = 'chat_id';
    protected $name = 'release_chat';

    /**
     * 关联会员表
     */
    public function user()
    {
        return $this->belongsTo("app\\common\\model\\user\\User", 'user_id', 'user_id');
    }


    //添加信息
    public function add($postdata,$user)
    {
        // 开启事务
        $this->startTrans();
        try {
            
            $ChatRelation = new ChatRelation();
            
            $info = $ChatRelation->where('user_id', '=', $user['user_id'])->where('other_user_id', '=', $postdata['you_user_id'])->find();
            if(empty($info)){
                $info = $ChatRelation->where('user_id', '=', $postdata['you_user_id'])->where('other_user_id', '=', $user['user_id'])->find();
            }
            if (!$info) {
                $save_data=[
                  'user_id'=>$user['user_id'],
                  'other_user_id'=>$postdata['you_user_id'],
                  'app_id'=>self::$app_id,
                ];
                $ChatRelation->save($save_data);
                $relation_id = $ChatRelation['relation_id'];
            } else {
                $relation_id = $info['relation_id'];
                $info->save(['update_time' => time()]);
            }

            $data=[
               'user_id'=>$user['user_id'],
               'content'=>$postdata['content'],
               'relation_id'=>$relation_id,
               'app_id'=>self::$app_id,
            ];
            $this->save($data);

            $this->commit();
            return true;
        } catch (\Exception $e) {
            log_write($e->getMessage());
            $this->rollback();
            return false;
        }

    }
}