Skip to content

M
my-yaf-project
Commit 44edbf9a authored by wwccw0591's avatar wwccw0591
Browse files
Options

pc

parent 38ae7641
Show whitespace changes
Inline Side-by-side
Showing with 2 additions and 430 deletions
application/models/Business/Message/MessageService.php
View file @ 44edbf9a
......@@ -32,6 +32,8 @@ class MessageServiceModel extends \Business\AbstractModel
}
/**
* 登录业务
*
......@@ -53,434 +55,4 @@ class MessageServiceModel extends \Business\AbstractModel
return self::$_instance;
}
/**
* 适配数据
*
* @ccw
*/
public function getConvertArray($memberMessage, $message, $defalt = false)
{
if ($defalt) {
return array(
'messageId' => ApiConst::zero,
'messageTitle' => '身边店',
'messageContent' => ArrayConst::meg[$message['message_type']],
'messageType' => $message['message_type'],
'gmtCreate' => TIMESTAMP,
'isRead' => ApiConst::one,
'unReadCount' => ApiConst::zero,
'id' => ApiConst::zero,
'messageTplId' => ApiConst::zero,
);
} else {
return array(
'messageId' => $message['message_id'],
'messageTitle' => $message['message_title'] ? $message['message_title'] : '',
'messageContent' => $message['message_body'],
'messageType' => $message['message_type'],
'gmtCreate' => $memberMessage['gmt_create'],
'isRead' => $memberMessage['status'],
'id' => $message['record_id'],
'messageTplId' => $message['tpl_type'],
);
}
}
public function getUnreadCountByMemberIdAndType($toId)
{
$messageHistoryDao = \DAO\MessageHistoryModel::getInstance();
$count = $messageHistoryDao->getUnreadCountByToIdAndToType($toId);
return $count;
}
/**
* 根据消息类型获得一条消息，已经未读消息数量
*
* @ccw
*/
public function getOneByType($memberId, $type)
{
$this->memberMessageDao = MemberMessageModel::getInstance();
$this->messageDao = MessageModel::getInstance();
$memberMessage = $this->memberMessageDao->getOneByMemberIdAndType($memberId, $type);
if ($memberMessage) {
$message = $this->messageDao->getOneById($memberMessage['message_id'], $this->memberMessageField);
//获得未读的消息数量
$count = $this->memberMessageDao->getUnreadCountByMemberIdAndType($memberId, $type);
if ($message) {
$messages = $this->getConvertArray($memberMessage, $message);
}
}
if ($messages) {
$data['unreadCount'] = $count;
$data['list'] = $messages;
return $data;
}
return new \stdClass();
}
public function getAvatar($type, $userid = 0, $db = DbNameConst::masterDBConnectName)
{
$avatar = '';
if ($type == ApiConst::systemMessageType) {
$avatar = Common::getStaticFile(ImageConst::sysAvatarName, ImageConst::systemAvatar, ImageConst::imageDomain);
}
if ($type == ApiConst::orderMessageType) {
$avatar = Common::getStaticFile(ImageConst::orderAvatarName, ImageConst::systemAvatar);
}
if ($type == ApiConst::deliveryMessageType) {
$avatar = Common::getStaticFile(ImageConst::expressAvatarName, ImageConst::systemAvatar, ImageConst::imageDomain);
}
if ($type == ApiConst::storeMessageType) {
$store = \DAO\StoreModel::getInstance();
$storeData = \Our\RedisHelper::cachedFunction(\Redis\Db5\OrderRedisModel::getInstance(), array(&$store, 'getInfoById'), array($userid, $store->detailField), \Our\ApiConst::oneDaySecond);
$avatar = $storeData['storeLabel'];
// $avatar = $store->getInfoById($userid, 'store_label', 'store_label');
$avatar = Common::getStaticFile($avatar, ImageConst::storeLabel, ImageConst::imageDomain);
}
if ($type == ApiConst::memberMessageType || $type == ApiConst::serviceMessageType) {
$member = \DAO\MemberModel::getInstance();
$memerAvatar = $member->getInfo($userid, 'member_avatar');
$avatar = $member->getMemberAvatarUrl($userid, $memerAvatar);
}
return $avatar;
}
public function __destruct()
{
$store = \DAO\StoreModel::getInstance();
$member = \DAO\MemberModel::getInstance();
$messageHistoryDao = \DAO\MessageHistoryModel::getInstance();
$mesageOneDao = \DAO\MessageOneModel::getInstance();
$store->unsetDb();
$member->unsetDb();
$messageHistoryDao->unsetDb();
$mesageOneDao->unsetDb();
}
public function unsetDb()
{
$store = \DAO\StoreModel::getInstance();
$member = \DAO\MemberModel::getInstance();
$messageHistoryDao = \DAO\MessageHistoryModel::getInstance();
$mesageOneDao = \DAO\MessageOneModel::getInstance();
$store->unsetDb();
$member->unsetDb();
$messageHistoryDao->unsetDb();
$mesageOneDao->unsetDb();
}
/**
* 获得全部类型消息，每种消息一条数据，以及每种消息的未读条数
*
* @ccw
*/
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['toAvatar'] = $toMember['avatar'];
$val['message'] = $messageHistoryDao->convertMessage($val['message']);
$val['fromAvatar'] = $self['avatar'];
// $val['toAvatar']=$this->getAvatar($val['toType'],$val['toId']);
// $val['fromAvatar']=$this->getAvatar($val['fromType'],$val['fromId']);
}
return $messageOneList;
}
public function getUserByMemberIdAndSelfType($memberId, $type)
{
$member = array();
if ($type == ApiConst::systemMessageType || $type == ApiConst::orderMessageType || $type == ApiConst::deliveryMessageType) {
$member['uid'] = $type;
$member['name'] = ArrayConst::messageName[$type];
}
if ($type == ApiConst::storeMessageType) {
$storeDao = \DAO\StoreModel::getInstance();
$store = $storeDao->getInfoByMemberId($memberId, 'store_id,store_name,store_label');
$member['uid'] = $store['store_id'];
$member['name'] = $store['store_name'];
}
if ($type == ApiConst::memberMessageType || $type == ApiConst::serviceMessageType) {
$memberDao = \DAO\MemberModel::getInstance();
$member = $memberDao->getOneByMemberId($memberId, 'member_id,member_name');
$member['uid'] = $member['member_id'];
$member['name'] = $member['member_name'];
}
$member['type'] = $type;
$member['avatar'] = $this->getAvatar($type, $member['uid'], DbNameConst::salveDBConnectName);
return $member;
}
public function getMemberIdByOtherIdAndType($otherId, $type)
{
if($type==ApiConst::storeMessageType){
$storeDao=\DAO\StoreModel::getInstance();
$condition['store_id'] = $otherId;
$store = \Our\RedisHelper::cachedFunction(\Redis\Db6\StoreRedisModel::getInstance(), array(&$storeDao, 'getInfo'), array($condition), ApiConst::oneDaySecond, array($otherId));
return $store['member_id'];
}
ErrorModel::throwException(CodeConfigModel::paramsError);
}
/**
* 根据用户的消息类型获得消息列表
*
* @ccw
*/
public function getMemberList($memberId, $selfType, $toId, $otherId, $toType = ApiConst::systemMessageType, $field = '*', $pageIndex = ApiConst::pageIndex, $pageSize = ApiConst::pageSize)
{
$messageHistory = \DAO\MessageHistoryModel::getInstance();
$self = $this->getUserByMemberIdAndSelfType($memberId, $selfType);
$toMember = $this->getUserByMemberIdAndSelfType($toId, $toType);
if (empty($toId)) {
$toId =$this->getMemberIdByOtherIdAndType($otherId,$toType);
}
$returnMemeber['toId'] = (int)$toId;
$returnMemeber['toUserId'] = (int)$toMember['uid'];
$returnMemeber['toUserName'] = $toMember['name'];
$returnMemeber['toType'] = (int)$toMember['type'];
$returnMemeber['toAvatar'] = $toMember['avatar'];
$returnMemeber['fromId'] = $memberId;
$returnMemeber['fromUserId'] = (int)$self['uid'];
$returnMemeber['fromUserName'] = $self['name'];
$returnMemeber['fromType'] = (int)$self['type'];
$returnMemeber['fromAvatar'] = $self['avatar'];
$memberMessages = $messageHistory->getListByMemberIdAndToIdAndToType($memberId, $selfType, $toId, $toType, $field, $pageIndex, $pageSize);
foreach ($memberMessages['list'] as &$val) {
$val['message'] = $messageHistory->convertMessage($val['message']);
}
$memberMessages['list'] = array_reverse($memberMessages['list']);
$returnMemeber['messages'] = $memberMessages;
return $returnMemeber;
}
/**
* 删除用户消息
*
* @ccw
*/
public function remove($memberId, $messageHistoryId)
{
$memageHistoryDao = \DAO\MessageHistoryModel::getInstance();
$memberHistory = $memageHistoryDao->getOneById($messageHistoryId);
$isSuccess = false;
if ($memberHistory['fromId'] == $memberId) {
if ($memberHistory['isDel'] == ApiConst::recieveRemove) {
$isSuccess = $memageHistoryDao->update($messageHistoryId, 'isDel', ApiConst::remove);
} else {
$isSuccess = $memageHistoryDao->update($messageHistoryId, 'isDel', ApiConst::sendRemove);
}
}
if ($memberHistory['toId'] == $memberId) {
if ($memberHistory['isDel'] == ApiConst::sendRemove) {
$isSuccess = $memageHistoryDao->update($messageHistoryId, 'isDel', ApiConst::remove);
} else {
$isSuccess = $memageHistoryDao->update($messageHistoryId, 'isDel', ApiConst::recieveRemove);
}
}
return $isSuccess;
}
/**
* 获得消息按钮
*
* @ccw
*/
public function getMessageButton($id, $buttonId)
{
$memageHistoryDao = \DAO\MessageHistoryModel::getInstance();
$memberHistory = $memageHistoryDao->getOneById($id);
if (empty($memberHistory)) {
ErrorModel::throwException(CodeConfigModel::noExistMessage);
}
$message = unserialize($memberHistory['message']);
$buttonIndex = $buttonId - ApiConst::one;
$button = $message['buttons'][$buttonIndex];
if (empty($button)) {
ErrorModel::throwException(CodeConfigModel::noExistButton);
}
$retrunButton = $button;
$button['status'] = ApiConst::messageButtonIsClick;
$button['showType'] = ApiConst::messageButtonShowTypeGray;
$message['buttons'][$buttonIndex] = $button;
$message = serialize($message);
$messageHistoryDao = \DAO\MessageHistoryModel::getInstance();
$messageHistoryDao->update($id, 'message', $message);
return $retrunButton;
}
public function update($fromId, $fromType, $toId, $toType)
{
$messageHistoryDao = \DAO\MessageHistoryModel::getInstance();
$messageOneDao = \DAO\MessageOneModel::getInstance();
$messageOneDao->setDb(DbNameConst::masterDBConnectName);
$messageOneDao->updateUnreadField($fromId, $fromType, $toId, $toType);
$isSuccess = $messageHistoryDao->updateByFromIdAndSelfTypeAndToIdAndToType($fromId, $fromType, $toId, $toType);
return $isSuccess;
}
public function checkIsCanSend($memberId)
{
$memberDao = \DAO\MemberModel::getInstance();
$sendTime = $memberDao->getInfo($memberId, 'sendTime');
if (!empty($sendTime)) {
if (TIMESTAMP - $sendTime < 1) {
ErrorModel::throwException(CodeConfigModel::sendLimitError);
}
}
}
public function addMessage($fromId, $selfId, $fromName, $fromType, $message, $toId, $toUserId, $toName, $toType, $messageId = false)
{
$messageHistoryDao = \DAO\MessageHistoryModel::getInstance();
$mesageOneDao = \DAO\MessageOneModel::getInstance();
$message['gmtCreate'] = TIMESTAMP;
$message['isRead'] = ApiConst::unread;
$message['type'] = (int)$message['type'];
$message['content'] = base64_encode($message['content']);
$serializeMessage = serialize($message);
//将消息添加到表messageHistory
$mesageHistory['fromId'] = $fromId;
$mesageHistory['fromType'] = $fromType;
$mesageHistory['toId'] = $toId;
$mesageHistory['toType'] = $toType;
$mesageHistory['title'] = $message['title'];
$mesageHistory['message'] = $serializeMessage;
$mesageHistory['type'] = $message['type'];
$mesageHistory['gmtCreate'] = time();
$mesageHistory['gmtUpdate'] = time();
if ($messageId) {
$mesageHistory['id'] = $messageId;
}
$messageHistoryDao->setDb(DbNameConst::masterDBConnectName);
$messageHistoryDao->db->doTransaction();
$res1 = $messageHistoryDao->add($mesageHistory);
//将最后一条消息更新到消息用户表messageOne
$messageOne['fromId'] = $fromId;
$messageOne['toUserId'] = $toUserId;
$messageOne['toUserName'] = $toName;
$messageOne['toType'] = $toType;
$messageOne['fromUserId'] = $selfId;
$messageOne['fromUserName'] = $fromName;
$messageOne['fromType'] = $fromType;
$messageOne['toId'] = $toId;
$messageOne['message'] = $serializeMessage;
//推送补充
$mesageHistory['fromUserId'] = $selfId;
$mesageHistory['fromUserName'] = $fromName;
$mesageHistory['fromAvatar'] = $this->getAvatar($fromType, $selfId);
$mesageHistory['toUserId'] = $toUserId;
$mesageHistory['toUserName'] = $toName;
//register_shutdown_function(array($messageHistoryDao,'sendMessage'),array($mesageHistory,$toId));
$mesageOneDao->setDb(DbNameConst::masterDBConnectName);
$res2 = $mesageOneDao->insertOrUpdate($messageOne);
$messageHistoryDao->db->doCommit();
unset($messageHistoryDao->db);
unset($messageHistoryDao);
unset($mesageOneDao);
//$messageHistoryDao->sendMessage($mesageHistory,$toId);
if ($res1 && $res2) {
return $res1;
} else {
return false;
}
}
public function addMessageCenterToDb()
{
$conf = \Yaf\Registry::get('config')->get('redis.database.params');
$this->baseRedis = new \Redis();
$this->baseRedis->pconnect($conf['host'], $conf['port']);
if (!empty($conf['password'])) {
$this->baseRedis->auth($conf['password']);
}
while ($center = $this->baseRedis->lPop('message_center')) {
$this->baseRedis->rPush('push_center', $center);
$addData = unserialize($center);
$addData['message'] = unserialize($addData['message']);
$this->addMessage($addData['fromId'], $addData['fromUserId'], $addData['fromUserName'], $addData['fromType'], $addData['message'], $addData['toId'], $addData['toUserId'], $addData['toUserName'], $addData['toType'], $addData['id']);
}
return true;
}
/**
* 新增用户消息
*
* @ccw`
*/
public function add($fromId, $selfId, $fromName, $fromType, $message, $toId, $toUserId, $toName, $toType)
{
$messageHistoryDao = \DAO\MessageHistoryModel::getInstance();
$mesageOneDao = \DAO\MessageOneModel::getInstance();
$message['gmtCreate'] = TIMESTAMP;
$message['isRead'] = ApiConst::unread;
$message['type'] = (int)$message['type'];
$serializeMessage = serialize($message);
//将消息添加到表messageHistory
$mesageHistory['fromId'] = $fromId;
$mesageHistory['fromType'] = $fromType;
$mesageHistory['toId'] = $toId;
$mesageHistory['toType'] = $toType;
$mesageHistory['title'] = $message['title'];
$mesageHistory['message'] = $serializeMessage;
$mesageHistory['type'] = $message['type'];
$mesageHistory['gmtCreate'] = TIMESTAMP;
$mesageHistory['gmtUpdate'] = TIMESTAMP;
$messageHistoryDao->setDb(DbNameConst::masterDBConnectName);
$messageHistoryDao->db->doTransaction();
$res1 = $messageHistoryDao->add($mesageHistory);
//将最后一条消息更新到消息用户表messageOne
$messageOne['fromId'] = $fromId;
$messageOne['toUserId'] = $toUserId;
$messageOne['toUserName'] = $toName;
$messageOne['toType'] = $toType;
$messageOne['fromUserId'] = $selfId;
$messageOne['fromUserName'] = $fromName;
$messageOne['fromType'] = $fromType;
$messageOne['toId'] = $toId;
$messageOne['message'] = $serializeMessage;
//推送补充
$mesageHistory['fromUserId'] = $selfId;
$mesageHistory['fromUserName'] = $fromName;
$mesageHistory['fromAvatar'] = $this->getAvatar($fromType, $selfId);
$mesageHistory['toUserId'] = $toUserId;
$mesageHistory['toUserName'] = $toName;
//register_shutdown_function(array($messageHistoryDao,'sendMessage'),array($mesageHistory,$toId));
$mesageOneDao->setDb(DbNameConst::masterDBConnectName);
$res2 = $mesageOneDao->insertOrUpdate($messageOne);
$messageHistoryDao->db->doCommit();
register_shutdown_function(array($messageHistoryDao, "sendMessage"), $mesageHistory, $toId);
//$messageHistoryDao->sendMessage($mesageHistory,$toId);
if ($res1 && $res2) {
return $res1;
} else {
return false;
}
}
public function set($memberId, $pushData)
{
$memberDao = \DAO\MemberModel::getInstance(DbNameConst::masterDBConnectName);
if ($memberDao->setIsWxsend($memberId, $pushData) !== false) {
return true;
}
return false;
}
}
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