2016-07-18 16:39:37 +00:00
< ? php
if ( $myUser == null ) {
redirectToLogin ();
}
function handleMsgPost () {
global $myUser ;
if ( ! isset ( $_POST [ 'receiver' ])) {
return 'fail' ;
}
if ( ! isset ( $_POST [ 'message' ])) {
return 'fail' ;
}
if ( 0 > strlen ( $_POST [ 'message' ]) || strlen ( $_POST [ 'message' ]) > 65535 ) {
return 'fail' ;
}
$receiver = $_POST [ 'receiver' ];
2017-11-25 15:29:18 +00:00
$esc_message = DB :: escape ( $_POST [ 'message' ]);
2016-07-18 16:39:37 +00:00
$sender = $myUser [ 'username' ];
if ( ! validateUsername ( $receiver ) || ! queryUser ( $receiver )) {
return 'fail' ;
}
2017-11-25 15:29:18 +00:00
DB :: query ( " insert into user_msg (sender, receiver, message, send_time) values (' $sender ', ' $receiver ', ' $esc_message ', now()) " );
2016-07-18 16:39:37 +00:00
return " ok " ;
}
function getConversations () {
global $myUser ;
$username = $myUser [ 'username' ];
2017-11-25 15:29:18 +00:00
$result = DB :: query ( " select * from user_msg where sender = ' $username ' or receiver = ' $username ' order by send_time DESC " );
2016-07-18 16:39:37 +00:00
$ret = array ();
2017-11-25 15:29:18 +00:00
while ( $msg = DB :: fetch ( $result )) {
2016-07-18 16:39:37 +00:00
if ( $msg [ 'sender' ] !== $username ) {
if ( isset ( $ret [ $msg [ 'sender' ]])) {
$ret [ $msg [ 'sender' ]][ 1 ] |= ( $msg [ 'read_time' ] == null );
continue ;
}
$ret [ $msg [ 'sender' ]] = array ( $msg [ 'send_time' ], ( $msg [ 'read_time' ] == null ));
} else {
if ( isset ( $ret [ $msg [ 'receiver' ]])) continue ;
$ret [ $msg [ 'receiver' ]] = array ( $msg [ 'send_time' ], 0 );
}
}
$res = [];
foreach ( $ret as $name => $con ) {
$res [] = [ $con [ 0 ], $con [ 1 ], $name ];
}
usort ( $res , function ( $a , $b ) { return - strcmp ( $a [ 0 ], $b [ 0 ]); });
return json_encode ( $res );
}
function getHistory () {
global $myUser ;
$username = $myUser [ 'username' ];
if ( ! isset ( $_GET [ 'conversationName' ]) || ! validateUsername ( $_GET [ 'conversationName' ])) {
return '[]' ;
}
if ( ! isset ( $_GET [ 'pageNumber' ]) || ! validateUInt ( $_GET [ 'pageNumber' ])) {
return '[]' ;
}
$conversationName = $_GET [ 'conversationName' ];
$pageNumber = ( $_GET [ 'pageNumber' ] - 1 ) * 10 ;
2017-11-25 15:29:18 +00:00
DB :: query ( " update user_msg set read_time = now() where sender = ' $conversationName ' and receiver = ' $username ' and read_time is null " );
2016-07-18 16:39:37 +00:00
2017-11-25 15:29:18 +00:00
$result = DB :: query ( " select * from user_msg where (sender = ' $username ' and receiver = ' $conversationName ') or (sender = ' $conversationName ' and receiver = ' $username ') order by send_time DESC limit $pageNumber , 11 " );
2016-07-18 16:39:37 +00:00
$ret = array ();
2017-11-25 15:29:18 +00:00
while ( $msg = DB :: fetch ( $result )) {
2016-07-18 16:39:37 +00:00
$ret [] = array ( $msg [ 'message' ], $msg [ 'send_time' ], $msg [ 'read_time' ], $msg [ 'id' ], ( $msg [ 'sender' ] == $username ));
}
return json_encode ( $ret );
}
/*
function deleteMsg ( $msgId ) {
return 1 ;
$str = <<< EOD
select * from user_msg
where id = $msgId
and read_time is null
EOD ;
2017-11-25 15:29:18 +00:00
$result = DB :: query ( $str );
if ( DB :: fetch ( $result )) {
2016-07-18 16:39:37 +00:00
$str = <<< EOD
delete from user_msg
where id = $msgId
EOD ;
2017-11-25 15:29:18 +00:00
DB :: query ( $str );
2016-07-18 16:39:37 +00:00
return 1 ;
}
return 0 ;
}
*/
if ( isset ( $_POST [ 'user_msg' ])) {
die ( handleMsgPost ());
} elseif ( isset ( $_GET [ 'getConversations' ])) {
die ( getConversations ());
} elseif ( isset ( $_GET [ 'getHistory' ])) {
die ( getHistory ());
}
?>
< ? php echoUOJPageHeader ( '私信' ) ?>
< h1 class = " page-header " > 私信 </ h1 >
< div id = " conversations " >
</ div >
< div id = " history " style = " display:none " >
2019-09-10 02:15:20 +00:00
< div class = " card border-primary " >
< div class = " card-header bg-primary text-white " >
< button type = " button " id = " goBack " class = " btn btn-info btn-sm " style = " position:absolute " > 返回 </ button >
2016-07-18 16:39:37 +00:00
< div id = " conversation-name " class = " text-center " ></ div >
</ div >
2019-09-10 02:15:20 +00:00
< div class = " card-body " >
< ul class = " pagination top-buffer-no justify-content-between " >
< li class = " previous " >< a class = " btn btn-outline-secondary text-primary " href = " # " id = " pageLeft " >& larr ; 更早的消息 </ a ></ li >
2016-07-18 16:39:37 +00:00
< li class = " text-center " id = " pageShow " style = " line-height:32px " ></ li >
2019-09-10 02:15:20 +00:00
< li class = " next " >< a class = " btn btn-outline-secondary text-primary " href = " # " id = " pageRight " > 更新的消息 & rarr ; </ a ></ li >
2016-07-18 16:39:37 +00:00
</ ul >
< div id = " history-list " style = " min-height: 200px; " >
</ div >
2019-09-10 02:15:20 +00:00
< ul class = " pagination top-buffer-no justify-content-between " >
< li class = " previous " >< a class = " btn btn-outline-secondary text-primary " href = " #history " id = " pageLeft2 " >& larr ; 更早的消息 </ a ></ li >
< li class = " next " >< a class = " btn btn-outline-secondary text-primary " href = " #history " id = " pageRight2 " > 更新的消息 & rarr ; </ a ></ li >
2016-07-18 16:39:37 +00:00
</ ul >
< hr />
< form id = " form-message " >
< div class = " form-group " id = " form-group-message " >
< textarea id = " input-message " class = " form-control " ></ textarea >
< span id = " help-message " class = " help-block " ></ span >
</ div >
< div class = " text-right " >
< button type = " submit " id = " message-submit " class = " btn btn-info btn-md " > 发送 </ button >
</ div >
</ form >
</ div >
</ div >
</ div >
< script type = " text/javascript " >
$ ( document ) . ready ( function () {
$ . ajaxSetup ({ async : false });
refreshConversations ();
< ? php if ( isset ( $_GET [ 'enter' ])) : ?>
enterConversation ( " <?= $_GET['enter'] ?> " );
< ? php endif ?>
});
</ script >
< script type = " text/javascript " >
function addButton ( conversationName , send_time , type ) {
$ ( " #conversations " ) . append (
'<div class="row top-buffer-sm">' +
'<div class="col-sm-3">' +
'<button type="button" class="btn btn-' + ( type ? 'warning' : 'primary' ) + ' btn-block" ' +
'onclick="enterConversation(\'' + conversationName + '\')">' +
conversationName +
'</button>' +
'</div>' +
'<div class="col-sm-9" style="line-height:34px">' +
'最后发送时间:' + send_time +
'</div>' +
'</div>'
);
}
function addBubble ( content , send_time , read_time , msgId , conversation , page , type ) {
$ ( " #history-list " ) . append (
'<div style=' + ( type ? " margin-left:0%;margin-right:20%; " : " margin-left:20%;margin-right:0%; " ) + '>' +
2019-09-10 02:15:20 +00:00
'<div class="card border-info mb-4">' +
'<div class="card-body" style="background:#17a2b8; word-break: break-all">' +
2016-07-18 16:39:37 +00:00
'<div style="white-space:pre-wrap">' +
htmlspecialchars ( content ) +
'</div>' +
'</div>' +
'<div>' +
'<div class="row">' +
'<div class="col-sm-6">' +
'发送时间:' + send_time +
'</div>' +
'<div class="col-sm-6 text-right">' +
'查看时间:' + ( read_time == null ? '<strong>未查看</strong>' : read_time ) +
'</div>' +
'</div>' +
'</div>' +
'</div>' +
'</div>'
);
}
function submitMessagePost ( conversationName ) {
if ( $ ( '#input-message' ) . val () . length == 0 || $ ( '#input-message' ) . val () . length >= 65536 ) {
$ ( '#help-message' ) . text ( '私信长度必须在1~65535之间。' );
$ ( '#form-group-message' ) . addClass ( 'has-error' );
return ;
}
$ ( '#help-message' ) . text ( '' );
$ ( '#form-group-message' ) . removeClass ( 'has-error' );
$ . post ( '/user/msg' , {
user_msg : 1 ,
receiver : conversationName ,
message : $ ( '#input-message' ) . val ()
}, function ( msg ) {
$ ( '#input-message' ) . val ( " " );
});
}
function refreshHistory ( conversation , page ) {
$ ( " #history-list " ) . empty ();
var ret = false ;
$ ( '#conversation-name' ) . text ( conversation );
$ ( '#pageShow' ) . text ( " 第 " + page . toString () + " 页 " );
$ . get ( '/user/msg' , {
getHistory : '' ,
conversationName : conversation ,
pageNumber : page
}, function ( msg ) {
var result = JSON . parse ( msg );
var cnt = 0 , flag = 0 , F = 0 ;
if ( result . length == 11 ) flag = 1 , F = 1 ;
result . reverse ();
for ( msg in result ) {
if ( flag ) { flag = 0 ; continue ;}
var message = result [ msg ];
addBubble ( message [ 0 ], message [ 1 ], message [ 2 ], message [ 3 ], conversation , page , message [ 4 ]);
if (( ++ cnt ) + 1 == result . length && F ) break ;
}
if ( result . length == 11 ) ret = true ;
});
return ret ;
}
function refreshConversations () {
$ ( " #conversations " ) . empty ();
$ . get ( '/user/msg' , {
getConversations : " "
}, function ( msg ) {
var result = JSON . parse ( msg );
for ( i in result ) {
var conversation = result [ i ];
if ( conversation [ 1 ] == 1 ) {
addButton ( conversation [ 2 ], conversation [ 0 ], conversation [ 1 ]);
}
}
for ( i in result ) {
var conversation = result [ i ];
if ( conversation [ 1 ] == 0 ) {
addButton ( conversation [ 2 ], conversation [ 0 ], conversation [ 1 ]);
}
}
}
);
}
function enterConversation ( conversationName ) {
var slideTime = 300 ;
var page = 1 ;
$ ( " #conversations " ) . hide ( slideTime );
var changeAble = refreshHistory ( conversationName , page );
$ ( " #history " ) . slideDown ( slideTime );
$ ( '#form-message' ) . unbind ( " submit " ) . submit ( function () {
submitMessagePost ( conversationName );
page = 1 ;
changeAble = refreshHistory ( conversationName , page );
refreshConversations ();
return false ;
});
$ ( '#goBack' ) . unbind ( " click " ) . click ( function () {
refreshConversations ();
$ ( " #history " ) . slideUp ( slideTime );
$ ( " #conversations " ) . show ( slideTime );
return ;
});
$ ( '#pageLeft' ) . unbind ( " click " ) . click ( function () {
if ( changeAble ) page ++ ;
changeAble = refreshHistory ( conversationName , page );
return false ;
});
$ ( '#pageLeft2' ) . unbind ( " click " ) . click ( function () {
if ( changeAble ) page ++ ;
changeAble = refreshHistory ( conversationName , page );
});
$ ( '#pageRight' ) . unbind ( " click " ) . click ( function () {
if ( page > 1 ) page -- ;
changeAble = refreshHistory ( conversationName , page );
return false ;
});
$ ( '#pageRight2' ) . unbind ( " click " ) . click ( function () {
if ( page > 1 ) page -- ;
changeAble = refreshHistory ( conversationName , page );
});
}
</ script >
< ? php echoUOJPageFooter () ?>