neko.backend/setMsgMarked.php at main · lclichen/neko.backend · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
<?php
header("content-type:text/html;charset=utf-8");
include_once __DIR__ . "/common.php";
$data = initPostData();
$token = $data['token'];
$msgid = (int)$data['msgid'];
$msg_status = $data['msg_status'];
$re_status = $data['re_status'];

$con = pdo_database();
$redata = array('code'=>10);
if ($token == '') {
    die('{"code":1006,"msg":"请先登录"}');
}

if ($token) {
    [$openid, $identity, $nickName] = pdoCheckUserPrivilege($con, $token);
    //var_dump([$token,$openid,$identity,$nickName]);
}

if ($openid) {
    switch ($msg_status) {
        case '0':
            // 这个简单一些，直接匹配openid和msgid即可。
            // 交互仅限于标记为已读或者从已读转换为未读？
            $sqlQuery = "UPDATE messages SET msg_status = 1 WHERE openid = :openid AND msgid = :msgid AND msg_status=0";
            $stmt = $con->prepare($sqlQuery);
            $stmt->execute(array(':openid' => $openid, ':msgid' => $msgid));
            $redata["msg"]="修改成功";
            break;
        case '2':
            // 只对msg_status=2的进行操作
            if ($re_status == 0){
                $sta = 3;
            } elseif ($re_status == 1) {
                $sta = 4;
            } else{
                $con = null;
                die('{"code":1001,"msg":"缺少输入参数"}');
            }
            if ($identity == 's') {
                $sqlQuery = "UPDATE messages SET msg_status=:sta WHERE msgid= :msgid AND msg_status=2";
            } elseif ($identity == 'a'){
                $sqlQuery = "UPDATE messages SET msg_status=:sta WHERE msgid= :msgid AND msg_status=2";
            }
            else {
                $con = null;
                die('{"code":1001,"msg":"输入参数错误"}');
            }
            $stmt = $con->prepare($sqlQuery);
            $result_1 = $stmt->execute(array(':sta' => $sta, ':msgid' => $msgid));
            // 根据消息内容（？）对对应的档案或用户进行处理，比如显示档案或授权用户权限(或许应该在)
            if (!$result_1) {
                $con = null;
                die('{"code":1001,"msg":"Msg更新失败"}');
            }
            $sqlSelect = "SELECT openid,msg,msg_with_user,msg_with_cat FROM messages WHERE msgid=:msgid";
            $sth = $con->prepare($sqlSelect);
            $sth->execute(array(':msgid' => $msgid));
            $resp = $sth->fetch(PDO::FETCH_ASSOC);
            $content = json_decode($resp['msg'])->content;
            if ($content == "template_3") {
                if ($re_status == 0){
                    // 拒绝
                    $result_2 = true;
                    setNewMsg($con, $resp['openid'], 0, 0, $resp['msg_with_user'], $resp['msg_with_cat'],
                    '{"content":"template_1"}');
                } elseif ($re_status == 1) {
                    $result_2 = update_once($con,"catsinfo","hide",0,"id",$resp['msg_with_cat']);
                    // 通过
                    setNewMsg($con, $resp['openid'], 0, 0, $resp['msg_with_user'], $resp['msg_with_cat'],
                    '{"content":"template_0"}');
                }
            } else {
                $result_2 = false;
            }
            if ($result_2) {
                $redata["msg"]="审核成功";
            } else {
                $redata["msg"]="此类消息审核系统尚未完成";
            }
            break;
        default:
            $con = null;
            die('{"code":1001,"msg":"输入参数错误"}');
            break;
    }
}
else {
    die('{"code":1002,"msg":"登录态已失效"}');
}

// $redata["msg"]="修改成功";
echo json_encode($redata,JSON_UNESCAPED_UNICODE);
$con = null;