Commit cb23925b authored by wwccw0591's avatar wwccw0591

ordi

parent 8a7be231
......@@ -21,9 +21,9 @@ class MessageController extends \Our\Controller_AbstractApi {
$pageIndex=isset($this->req['data']['pageIndex'])?$this->req['data']['pageIndex']:0;
$pageSize=isset($this->req['data']['pageSize'])?$this->req['data']['pageSize']:20;
if(!empty($this->req['data']['toType'])){
$returnMessage=\Our\RedisHelper::cachedFunction(\Redis\Db15\MessageRedisModel::getInstance(),array(&$this->messageService, 'getMemberList'),array($this->memberId,$this->req['data']['fromType'],$this->req['data']['toId'],$this->req['data']['toType'],'*',$pageIndex,$pageSize),\Our\ApiConst::oneHourCache,array($this->memberId));
$returnMessage=\Our\RedisHelper::cachedFunction(\Redis\Db15\MessageRedisModel::getInstance(),array(&$this->messageService, 'getMemberList'),array($this->memberId,$this->req['data']['fromType'],$this->req['data']['toId'],$this->req['data']['toType'],'*',$pageIndex,$pageSize),\Our\ApiConst::tenSecond,array($this->memberId));
}else{
$returnMessage=\Our\RedisHelper::cachedFunction(\Redis\Db15\MessageRedisModel::getInstance(),array(&$this->messageService, 'getList'),array($this->memberId,$pageIndex,$pageSize),\Our\ApiConst::oneHourCache,array($this->memberId));
$returnMessage=\Our\RedisHelper::cachedFunction(\Redis\Db15\MessageRedisModel::getInstance(),array(&$this->messageService, 'getList'),array($this->memberId,$pageIndex,$pageSize),\Our\ApiConst::tenSecond,array($this->memberId));
if($returnMessage){
$returnMessage['users']=$returnMessage['list'];
}else{
......@@ -140,4 +140,12 @@ class MessageController extends \Our\Controller_AbstractApi {
}
\Error\ErrorModel::throwException(\Error\CodeConfigModel::setMessageFail);
}
public function getSetAction(){
$memberCenterService=\Business\User\MemberCenterServiceModel::getInstance();
$messageSet=$memberCenterService->getMessageSet($this->memberId);
if(!empty($messageSet)){
$this->success($messageSet);
}
\Error\ErrorModel::throwException(\Error\CodeConfigModel::commonError);
}
}
......@@ -28,6 +28,8 @@ class ApiConst
//7天秒数
const sevenDaySecond = 604800;
const oneMinute = 60;
const tenSecond=10;
//八小时秒数
const EightHoursSecond = 28800;
const hundred = 100;
......
......@@ -165,20 +165,13 @@ class MessageServiceModel extends \Business\AbstractModel
public function getList($memberId, $pageIndex = ApiConst::pageIndex, $pageSize = ApiConst::pageSize)
{
$messageOneDao = \DAO\MessageOneModel::getInstance();
$messageHistoryDao=\DAO\MessageHistoryModel::getInstance();
$messageOneList = $messageOneDao->getListByMemberId($memberId, '*', $pageIndex, $pageSize);
foreach ($messageOneList['list'] as &$val) {
$self = $this->getUserByMemberIdAndSelfType($val['fromId'], $val['fromType']);
$toMember = $this->getUserByMemberIdAndSelfType($val['toId'], $val['toType']);
$val['message'] = unserialize($val['message']);
$val['toAvatar'] = $self['avatar'];
foreach($val['message']['buttons'] as &$button){
if($button['type']==ApiConst::messageButtonTypeConfirmButton || $button['type']==ApiConst::messageButtonTypeReciverButton){
$timeDiff=TIMESTAMP-$val['message']['createTime'];
if($timeDiff>(ApiConst::tenMinSecond-ApiConst::oneMinute)){
$button['showType']=ApiConst::messageButtonShowTypeGray;
}
}
}
$val['message'] =$messageHistoryDao->convertMessage($val['message']);
$val['fromAvatar'] = $toMember['avatar'];
// $val['toAvatar']=$this->getAvatar($val['toType'],$val['toId']);
// $val['fromAvatar']=$this->getAvatar($val['fromType'],$val['fromId']);
......@@ -232,8 +225,8 @@ class MessageServiceModel extends \Business\AbstractModel
$returnMemeber['fromAvatar'] = $self['avatar'];
$memberMessages = $messageHistory->getListByMemberIdAndToIdAndToType($memberId, $selfType, $toId, $toType, $field, $pageIndex, $pageSize);
foreach ($memberMessages['list'] as &$val) {
$val['message'] = unserialize($val['message']);
$val['message']['title'] = !empty($val['message']['title']) ? $val['message']['title'] : '';
$val['message'] = $messageHistory->convertMessage($val['message']);
}
$memberMessages['list'] = array_reverse($memberMessages['list']);
$returnMemeber['messages'] = $memberMessages;
......
......@@ -52,6 +52,26 @@ class MemberCenterServiceModel extends \Business\AbstractModel
$memberCenter['vibrate']=(int)$memberInfo['pushSet']['vibrate'];
return $memberCenter;
}
public function getMessageSet($memberId){
$memberInfo = \DAO\MemberModel::getInstance()->getInfo($memberId);
// $pushSet=array();
if(!empty($memberInfo['pushSet'])){
$pushSet=unserialize($memberInfo['pushSet']);
$pushSet=array(
'canPush'=>(int)$pushSet['canPush'],
'sound'=>(int)$pushSet['sound'],
'vibrate'=>(int)$pushSet['vibrate'],
);
}else{
$pushSet=array(
'canPush'=>ApiConst::openMessae,
'sound'=>ApiConst::openMessae,
'vibrate'=>ApiConst::openMessae,
);
}
return $pushSet;
}
public function getStatistics($memberId){
$memebrCenterDb1Redis = \Redis\Db1\MemberCenterRedisModel::getInstance();
$memberCenter = $memebrCenterDb1Redis->tableHGAll($memberId);
......
......@@ -83,6 +83,9 @@ class MessageModel extends \DAO\AbstractModel {
$messages['list']=$convertList;
return $messages;
}
/**
* 类实例
*
......
......@@ -92,6 +92,22 @@ class MessageHistoryModel extends \DAO\AbstractModel {
$res=$this->db->insert($this->_tableName)->rows($data)->execute();
return $res;
}
public function convertMessage($message){
$message = unserialize($message);
$message['title'] = !empty($message['title']) ? $message['title'] : '';
if(!empty($message['buttons'])){
foreach($message['buttons'] as &$button){
if($button['type']==ApiConst::messageButtonTypeConfirmButton || $button['type']==ApiConst::messageButtonTypeReciverButton){
$timeDiff=TIMESTAMP-$message['createTime'];
if($timeDiff>(ApiConst::tenMinSecond-ApiConst::oneMinute)){
$button['showType']=ApiConst::messageButtonShowTypeGray;
}
}
}
}
return $message;
}
/**
* 类实例
......
......@@ -124,6 +124,7 @@ class MessageOneModel extends \DAO\AbstractModel {
}
}
/**
* 类实例
*
......
......@@ -9,10 +9,10 @@
</head>
<body>
<form action="/message/get" method="post">
用户登录状态key:<input name="data[key]" value="6d212e880869eb4960cf81700f1369fe"/><br />
接受消息用户ID:<input name="data[toId]" value=""/><br />
接受消息用户类型:<input name="data[toType]" value="1" type="radio" checked/>系统消息 <input type="radio" name="data[toType]" value="2"/>订单消息 <input name="data[toType]" value="3" type="radio" />快递消息 <input type="radio" name="data[toType]" value="4"/>店铺消息 <input type="radio" name="data[toType]" value="5"/>普通消息 <input name="data[toType]" value="6" type="radio" />老师 <br />
自己发送消息的用户类型:<input name="data[fromType]" value=""/> <br />
用户登录状态key:<input name="data[key]" value="fd4b739c4815297044191451eabf0eb5"/><br />
接受消息用户ID:<input name="data[toId]" value="-2"/><br />
接受消息用户类型:<input name="data[toType]" value="1" type="radio" />系统消息 <input type="radio" name="data[toType]" value="2" checked/>订单消息 <input name="data[toType]" value="3" type="radio" />快递消息 <input type="radio" name="data[toType]" value="4"/>店铺消息 <input type="radio" name="data[toType]" value="5"/>普通消息 <input name="data[toType]" value="6" type="radio" />老师 <br />
自己发送消息的用户类型:<input name="data[fromType]" value="4"/> <br />
页码:<input name="data[pageIndex]" value="" /><br/>
每页条数:<input name="data[pageSize]" value="" /><br/>
<input type="submit" value="提交">
......
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml">
<head>
<meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
<title>获得已发送消息的用户列表和(系统消息,订单消息,快递用户消息最后一条消息)</title>
<style>
</style>
</head>
<body>
<form action="/message/getSet" method="post">
用户登录状态key:<input name="data[key]" value="ca44044c38f5a6d06ddd7304e1c7666c"/><br />
<input type="submit" value="提交">
</form>
</body>
</html>
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment