// // JXMessageObject.m // // Created by Reese on 13-8-11. // Copyright (c) 2013年 Reese. All rights reserved. // #import "JXMessageObject.h" #import "FMDatabase.h" #import "FMResultSet.h" #import "JXFriendObject.h" #import "JXBlogObject.h" #import "NSData+XMPP.h" #import "versionManage.h" //#import "ChatCacheFileUtil.h" #import "FileInfo.h" #import "JXRoomRemind.h" #import "GDataXMLNode.h" #ifdef Live_Version #import "JXLiveJidManager.h" #endif #define SameResource [g_myself.multipleDevices intValue] > 0 ? @"ios" : @"youjob" #import "JXBaseChatCell.h" #import "JXMessageCell.h" #import "JXImageCell.h" #import "JXFaceCustomCell.h" #import "JXEmojiCell.h" #import "JXFileCell.h" #import "JXVideoCell.h" #import "JXAudioCell.h" #import "JXLocationCell.h" #import "JXCardCell.h" #import "JXRedPacketCell.h" #import "JXRemindCell.h" #import "JXGifCell.h" #import "JXSystemImage1Cell.h" #import "JXSystemImage2Cell.h" #import "JXAVCallCell.h" #import "JXLinkCell.h" #import "JXShakeCell.h" #import "JXMergeRelayCell.h" #import "JXShareCell.h" #import "JXTransferCell.h" #import "JXReplyCell.h" #import "JXUserPublicKeyObj.h" #import "JLGroupActivityModel.h" @implementation JXMessageObject MJCodingImplementation @synthesize content,timeSend,fromUserId,toUserId,type,messageNo, messageId,timeReceive,fileName,fileData,fileSize,location_x,location_y,timeLen,isSend,isRead,progress,dictionary,index,fromUserName,objectId,toUserName,isReceive,fromId,toId,isEncrypt; @synthesize isUpload; NSString* current_chat_userId = nil; NSString* current_meeting_no=nil; static JXMessageObject *shared; +(JXMessageObject*)sharedInstance{ static dispatch_once_t onceToken; dispatch_once(&onceToken, ^{ shared=[[JXMessageObject alloc]init]; }); return shared; } -(id)init{ self = [super init]; if(self){ dictionary = [[NSMutableDictionary alloc] init]; fileData = nil; self.isReceive = [NSNumber numberWithInt:transfer_status_yes]; self.isSend = [NSNumber numberWithInt:transfer_status_yes]; self.isRead = [NSNumber numberWithBool:YES]; self.type = [NSNumber numberWithInt:0]; self.isUpload = [NSNumber numberWithBool:YES]; self.fromId = nil; self.toId = nil; self.fromUserId = nil; self.toUserId = nil; self.location_x = nil; self.location_y = nil; self.isEncrypt = nil; self.isReadDel = nil; self.readTime = nil; self.readPersons= nil; self.chatMsgHeight = nil; self.isShowTime = NO; self.sendCount = 0; self.isDelay = 0; self.updateLastContent = 1; _isGroup = NO; _isMySend = 0; self.signature = nil; self.isVerifySignatureFailed = nil; } return self; } -(void)dealloc{ // NSLog(@"JXMessageObject.dealloc"); [dictionary removeAllObjects]; // [dictionary release]; self.fromUserId = nil; self.toUserId = nil; self.content = nil; self.timeSend = nil; self.timeReceive = nil; self.type = nil; self.messageNo = nil; self.messageId = nil; self.fileName = nil; self.fileSize = nil; self.fileData = nil; self.location_x = nil; self.location_y = nil; self.isSend = nil; self.isRead = nil; self.timeLen = nil; self.isReceive = nil; self.isUpload = nil; self.imageHeight = nil; self.imageWidth = nil; self.deleteTime = nil; // [downloads release]; // [super dealloc]; } -(void)fromDictionary:(NSMutableDictionary*)p { if(p==nil) p = dictionary; NSDateFormatter* f=[[NSDateFormatter alloc]init]; [f setDateFormat:@"yyyy-MM-dd HH:mm:ss"]; self.fromUserId = [NSString stringWithFormat:@"%@",[p objectForKey:kMESSAGE_FROM]]; self.toUserId = [NSString stringWithFormat:@"%@",[p objectForKey:kMESSAGE_TO]]; self.fromUserName = [p objectForKey:kMESSAGE_FROM_NAME]; self.toUserName = [p objectForKey:kMESSAGE_TO_NAME]; if ([p objectForKey:@"to"]) { self.toId = [p objectForKey:@"to"]; } if ([p objectForKey:kMESSAGE_ID]) { self.messageId = [p objectForKey:kMESSAGE_ID]; } NSDictionary *messageHead = [p objectForKey:@"messageHead"]; if ([messageHead objectForKey:kMESSAGE_ID]) { self.messageId = [messageHead objectForKey:kMESSAGE_ID]; } if ([p objectForKey:kMESSAGE_isReadDel]) { self.isReadDel = [p objectForKey:kMESSAGE_isReadDel]; }else{ self.isReadDel = [NSNumber numberWithInt:NO]; } // self.timeReceive = [f dateFromString:[p objectForKey:kMESSAGE_TIMERECEIVE]]; self.timeSend = [NSDate dateWithTimeIntervalSince1970:[[p objectForKey:kMESSAGE_TIMESEND] doubleValue]]; self.deleteTime = [NSDate dateWithTimeIntervalSince1970:[[p objectForKey:kMESSAGE_DELETETIME] doubleValue]]; NSString * messCont = [p objectForKey:kMESSAGE_CONTENT]; self.isEncrypt = [p objectForKey:kMESSAGE_isEncrypt]; if (self.isEncrypt == nil) { self.isEncrypt = [NSNumber numberWithBool:NO]; } self.timeReceive = [NSDate dateWithTimeIntervalSince1970:[[p objectForKey:kMESSAGE_TIMERECEIVE] longLongValue]]; self.type = [p objectForKey:kMESSAGE_TYPE]; self.messageNo = [p objectForKey:kMESSAGE_No]; self.fileName = [p objectForKey:kMESSAGE_FILENAME]; self.fileData = [NSData dataWithBase64EncodedString:[p objectForKey:kMESSAGE_FILEDATA]]; // [fileData release]; self.location_x = [p objectForKey:kMESSAGE_LOCATION_X]; self.location_y = [p objectForKey:kMESSAGE_LOCATION_Y]; self.timeLen = [p objectForKey:kMESSAGE_TIMELEN]; self.fileSize = [p objectForKey:kMESSAGE_FILESIZE]; self.objectId = [p objectForKey:kMESSAGE_OBJECTID]; //放入图片宽高 // self.location_x = [p objectForKey:KMESSAGE_imHeight]; // self.location_y = [p objectForKey:kMESSAGE_imWidth]; self.isReceive = [NSNumber numberWithInt:transfer_status_yes]; self.isSend = [NSNumber numberWithInt:transfer_status_yes]; self.isRead = [p objectForKey:kMESSAGE_ISREAD]; if (self.isRead == nil) { self.isRead = [NSNumber numberWithBool:NO]; } self.isUpload = [NSNumber numberWithBool:YES]; self.readPersons = [p objectForKey:kMESSAGE_readPersons]; self.readTime = [NSDate dateWithTimeIntervalSince1970:[[p objectForKey:kMESSAGE_readTime] longValue]]; self.chatMsgHeight = [p objectForKey:kMESSAGE_chatMsgHeight]; self.isShowTime = [[p objectForKey:kMESSAGE_isShowTime] boolValue]; self.isVerifySignatureFailed = [p objectForKey:kMESSAGE_isVerifySignatureFailed]; // 其他的一些群设置 self.other = [p objectForKey:@"other"]; // [f release]; #ifdef IS_MsgEncrypt // 消息验签字段 self.signature = [p objectForKey:@"signature"]; // 从朋友表拿出好友DH公钥 JXUserObject *user = [[JXUserObject sharedInstance]getUserById:self.fromUserId]; if ([self.fromUserId isEqualToString:MY_USER_ID] || self.isGroup) { user = [[JXUserObject sharedInstance]getUserById:self.toUserId]; } if (self.isGroup) { if (!user.roomId || user.roomId.length <= 0 || messCont.length <= 0 || !messCont) { return; } NSString *chatKeyGroup = [g_msgUtil decryptRoomMsgKey:user.roomId randomKey:user.chatKeyGroup]; NSData *contentData = [[NSData alloc] initWithBase64EncodedString:messCont options:NSDataBase64DecodingIgnoreUnknownCharacters]; NSData *deContentData = [AESUtil decryptAESData:contentData key:[chatKeyGroup dataUsingEncoding:NSUTF8StringEncoding]]; NSString *deContent = [[NSString alloc] initWithData:deContentData encoding:NSUTF8StringEncoding]; NSString *signature = [g_msgUtil getRoomMsgMacWithContent:messCont fromUserId:fromUserId isEncrypt:[isEncrypt integerValue] msgId:messageId randomKey:chatKeyGroup]; if ([signature isEqualToString:self.signature]) { // 验签成功 self.content = deContent; }else { self.isVerifySignatureFailed = [NSNumber numberWithBool:YES]; // 将消息标明为验签失败消息 // 将消息放入缓存队列 NSMutableArray *arr = [g_msgUtil.verifyFailedDic objectForKey:user.userId]; if (!arr) { arr = [NSMutableArray array]; } self.content = messCont; JXMessageObject *msg = [[JXMessageObject alloc] init]; [msg copy:self]; [arr addObject:msg]; [g_msgUtil.verifyFailedDic setObject:arr forKey:user.userId]; if (![g_msgUtil.getDHListIds containsObject:user.userId]) { [g_msgUtil.getDHListIds addObject:user.userId]; // 获取服务器公钥表 [g_msgUtil getDHPublicKeyWithUserId:user.userId]; } } }else { if (user.publicKeyDH && user.publicKeyDH.length > 0) { // 签名 NSString *signature = [g_msgUtil getChatMsgMacWithContent:messCont fromUserId:fromUserId toUserId:toUserId isEncrypt:[isEncrypt integerValue] msgId:messageId publicKey:user.publicKeyDH]; if ([signature isEqualToString:self.signature]) { // 验签成功 self.content = [g_msgUtil decryptContentWithPublicKey:user.publicKeyDH content:messCont msgId:self.messageId]; }else { // 验签失败 // 获取好友公钥表 NSMutableArray *keys = [[JXUserPublicKeyObj sharedManager] fetchPublicKeyWithUserId:user.userId]; BOOL flag = NO; // 公钥表里公钥依次解密 for (NSInteger i = 0; i < keys.count; i ++) { JXUserPublicKeyObj *obj = keys[i]; if (obj.publicKey && obj.publicKey.length > 0) { NSString *signature = [g_msgUtil getChatMsgMacWithContent:messCont fromUserId:fromUserId toUserId:toUserId isEncrypt:[isEncrypt integerValue] msgId:messageId publicKey:obj.publicKey]; if ([signature isEqualToString:self.signature]) { flag = YES; self.content = [g_msgUtil decryptContentWithPublicKey:obj.publicKey content:messCont msgId:self.messageId]; break; } } } if (!flag) { // 解密失败，调用获取服务器公钥表接口 self.isVerifySignatureFailed = [NSNumber numberWithBool:YES]; // 将消息标明为验签失败消息 // 将消息放入缓存队列 NSMutableArray *arr = [g_msgUtil.verifyFailedDic objectForKey:user.userId]; if (!arr) { arr = [NSMutableArray array]; } self.content = messCont; JXMessageObject *msg = [[JXMessageObject alloc] init]; [msg copy:self]; [arr addObject:msg]; [g_msgUtil.verifyFailedDic setObject:arr forKey:user.userId]; if (![g_msgUtil.getDHListIds containsObject:user.userId]) { [g_msgUtil.getDHListIds addObject:user.userId]; // 获取服务器公钥表 [g_msgUtil getDHPublicKeyWithUserId:user.userId]; } } } }else { // 朋友表没有此用户公钥 if (user) { self.isVerifySignatureFailed = [NSNumber numberWithBool:YES]; // 将消息标明为验签失败消息 // 将消息放入缓存队列 NSMutableArray *arr = [g_msgUtil.verifyFailedDic objectForKey:user.userId]; if (!arr) { arr = [NSMutableArray array]; } self.content = messCont; JXMessageObject *msg = [[JXMessageObject alloc] init]; [msg copy:self]; [arr addObject:msg]; [g_msgUtil.verifyFailedDic setObject:arr forKey:user.userId]; if (![g_msgUtil.getDHListIds containsObject:user.userId]) { [g_msgUtil.getDHListIds addObject:user.userId]; // 获取服务器公钥表 [g_msgUtil getDHPublicKeyWithUserId:user.userId]; } }else { self.content = messCont; } } } #else if ([self.isEncrypt boolValue]) { // self.content = [DESUtil decryptDESStr:messCont key:[NSString stringWithFormat:@"%@",[p objectForKey:kMESSAGE_TIMESEND]]]; NSMutableString *str = [NSMutableString string]; [str appendString:APIKEY]; [str appendString:[NSString stringWithFormat:@"%ld",(long)[self.timeSend timeIntervalSince1970]]]; [str appendString:self.messageId]; NSString *keyStr = [g_server getMD5String:str]; self.content = [DESUtil decryptDESStr:messCont key:keyStr]; if (IsStringNull(self.content)) { self.content = messCont; } }else{ self.content = messCont; } #endif } - (void)fromXmlDict:(NSDictionary *)xmlDict{ SBJsonParser *parser = [[SBJsonParser alloc] init]; //body NSString * repr = [xmlDict objectForKey:@"body"]; //"替换成\" repr = [repr stringByReplacingOccurrencesOfString:@""" withString:@"\""]; NSDictionary *bodyDict = [parser objectWithString:repr]; //message NSString * reprM = [xmlDict objectForKey:@"message"]; //"替换成\" reprM = [reprM stringByReplacingOccurrencesOfString:@""" withString:@"\""]; GDataXMLElement * xmlElement = [[GDataXMLElement alloc]initWithXMLString:reprM error:nil]; NSString * xmlFrom = [[[xmlElement attributeForName:@"from"] stringValue]componentsSeparatedByString:@"@"][0]; NSString * xmlTo = [[[xmlElement attributeForName:@"to"] stringValue]componentsSeparatedByString:@"@"][0]; if (xmlDict[@"messageId"]) { self.messageId = xmlDict[@"messageId"]; } [self fromDictionary:bodyDict]; if (xmlFrom) { if (!self.fromUserId || self.fromUserId.length <= 0) { self.fromUserId = [NSString stringWithFormat:@"%lld",[xmlFrom longLongValue]]; } } if (xmlTo) { if (!self.toUserId || self.toUserId.length <= 0) { self.toUserId = [NSString stringWithFormat:@"%lld",[xmlTo longLongValue]]; } } } // 群聊 -(void)fromGroupXmlDict:(NSDictionary *)xmlDict { SBJsonParser *parser = [[SBJsonParser alloc] init]; //body NSString * repr = [xmlDict objectForKey:@"body"]; //"替换成\" repr = [repr stringByReplacingOccurrencesOfString:@""" withString:@"\""]; NSDictionary *bodyDict = [parser objectWithString:repr]; [self fromDictionary:bodyDict]; } //将对象转换为字典 -(NSMutableDictionary*)toDictionary { NSDateFormatter* f=[[NSDateFormatter alloc]init]; [f setDateFormat:@"yyyy-MM-dd HH:mm:ss"]; //离线消息，单聊时ID可能在里传过来，但群聊的离线或者历史消息，的ID为NULL //方案：单聊的messageId放在的ID里,群聊除此之外，messageId也放在的MessageID里 if(self.messageId.length > 0) [dictionary setValue:messageId forKey:kMESSAGE_ID]; [dictionary setValue:fromUserName forKey:kMESSAGE_FROM_NAME]; [dictionary setValue:toUserName forKey:kMESSAGE_TO_NAME]; [dictionary setValue:[NSNumber numberWithDouble:[self.timeSend timeIntervalSince1970]] forKey:kMESSAGE_TIMESEND]; [dictionary setValue:[NSNumber numberWithLongLong:[self.deleteTime timeIntervalSince1970]] forKey:kMESSAGE_DELETETIME]; [dictionary setValue:type forKey:kMESSAGE_TYPE]; // if([self getIsGroup]) [dictionary setValue:fromUserId forKey:kMESSAGE_FROM]; [dictionary setValue:toUserId forKey:kMESSAGE_TO]; if(self.fileData) [dictionary setValue:[fileData xmpp_base64Encoded] forKey:kMESSAGE_FILEDATA]; if(self.objectId) [dictionary setValue:objectId forKey:kMESSAGE_OBJECTID]; if(self.fileName) [dictionary setValue:fileName forKey:kMESSAGE_FILENAME]; if(self.fileSize) [dictionary setValue:fileSize forKey:kMESSAGE_FILESIZE]; if(self.location_x) [dictionary setValue:location_x forKey:kMESSAGE_LOCATION_X]; if(self.location_y) [dictionary setValue:location_y forKey:kMESSAGE_LOCATION_Y]; if(self.timeLen) [dictionary setValue:timeLen forKey:kMESSAGE_TIMELEN]; if ([self.isReadDel boolValue]) [dictionary setObject:_isReadDel forKey:kMESSAGE_isReadDel]; if (self.isShowTime) { [dictionary setObject:[NSNumber numberWithBool:self.isShowTime] forKey:kMESSAGE_isShowTime]; } #ifdef IS_MsgEncrypt JXUserObject *user = [[JXUserObject sharedInstance]getUserById:toUserId]; if (self.isGroup) { NSString *chatKeyGroup = [g_msgUtil decryptRoomMsgKey:user.roomId randomKey:user.chatKeyGroup]; NSData *encryptData = [AESUtil encryptAESData:[content dataUsingEncoding:NSUTF8StringEncoding] key:[chatKeyGroup dataUsingEncoding:NSUTF8StringEncoding]]; NSString *encryptStr = [encryptData base64EncodedStringWithOptions:0]; NSString *signature = [g_msgUtil getRoomMsgMacWithContent:encryptStr fromUserId:fromUserId isEncrypt:[isEncrypt integerValue] msgId:messageId randomKey:chatKeyGroup]; [dictionary setValue:encryptStr forKey:kMESSAGE_CONTENT]; [dictionary setValue:signature forKey:kMESSAGE_signature]; }else { if (user.publicKeyDH && user.publicKeyDH.length > 0) { NSString *encryptStr = [g_msgUtil encryptContentWithPublicKey:user.publicKeyDH content:content msgId:messageId ]; NSString *signature = [g_msgUtil getChatMsgMacWithContent:encryptStr fromUserId:fromUserId toUserId:toUserId isEncrypt:[isEncrypt integerValue] msgId:messageId publicKey:user.publicKeyDH]; [dictionary setValue:encryptStr forKey:kMESSAGE_CONTENT]; [dictionary setValue:signature forKey:kMESSAGE_signature]; } } #else if([self.isEncrypt boolValue]){ [dictionary setValue:isEncrypt forKey:kMESSAGE_isEncrypt]; // NSString * keyStr = [NSString stringWithFormat:@"%f",[self.timeSend timeIntervalSince1970]]; NSMutableString *str = [NSMutableString string]; [str appendString:APIKEY]; [str appendString:[NSString stringWithFormat:@"%@",[NSNumber numberWithLongLong:[self.timeSend timeIntervalSince1970]]]]; [str appendString:self.messageId]; NSString *keyStr = [g_server getMD5String:str]; [dictionary setValue:[DESUtil encryptDESStr:content key:keyStr] forKey:kMESSAGE_CONTENT]; } else [dictionary setValue:content forKey:kMESSAGE_CONTENT]; #endif if (self.timeReceive) { [dictionary setValue:[NSNumber numberWithDouble:[self.timeReceive timeIntervalSince1970]] forKey:kMESSAGE_TIMERECEIVE]; } if ([self.isRead boolValue]) [dictionary setObject:self.isRead forKey:kMESSAGE_ISREAD]; if ([self.isSend boolValue]) [dictionary setObject:self.isSend forKey:kMESSAGE_ISSEND]; if ([self.isReceive boolValue]) [dictionary setObject:self.isReceive forKey:kMESSAGE_isReceive]; if ([self.isUpload boolValue]) [dictionary setObject:[NSNumber numberWithInt:[self.isUpload intValue]] forKey:kMESSAGE_isUpload]; if (self.fromId) [dictionary setObject:self.fromId forKey:kMESSAGE_FROMID]; if (self.toId) [dictionary setObject:self.toId forKey:kMESSAGE_TOID]; if (self.readPersons) [dictionary setObject:self.readPersons forKey:kMESSAGE_readPersons]; if (self.readTime) { [dictionary setValue:[NSNumber numberWithDouble:[self.readTime timeIntervalSince1970]] forKey:kMESSAGE_readTime]; } if (self.chatMsgHeight) { [dictionary setObject:self.chatMsgHeight forKey:kMESSAGE_chatMsgHeight]; } if (self.isShowTime) [dictionary setObject:[NSNumber numberWithBool:self.isShowTime] forKey:kMESSAGE_isShowTime]; if (self.isGroup) [dictionary setObject:[NSNumber numberWithBool:self.isGroup] forKey:@"isGroup"]; if ([self.isVerifySignatureFailed boolValue]) { [dictionary setObject:self.isVerifySignatureFailed forKey:kMESSAGE_isVerifySignatureFailed]; } return dictionary; } -(void)fromRs:(FMResultSet*)rs{ self.fromUserId = [rs stringForColumn:kMESSAGE_FROM]; self.fromUserName = [rs stringForColumn:kMESSAGE_FROM_NAME]; self.toUserId = [rs stringForColumn:kMESSAGE_TO]; self.content = [rs stringForColumn:kMESSAGE_CONTENT]; self.timeSend = [rs dateForColumn:kMESSAGE_TIMESEND]; self.deleteTime = [rs dateForColumn:kMESSAGE_DELETETIME]; self.timeReceive = [rs dateForColumn:kMESSAGE_TIMERECEIVE]; self.type = [rs objectForColumnName:kMESSAGE_TYPE]; self.messageId = [rs stringForColumn:kMESSAGE_ID]; self.messageNo = [rs objectForColumnName:kMESSAGE_No]; self.fileName = [rs stringForColumn:kMESSAGE_FILENAME]; if([rs objectForColumnName:kMESSAGE_FILEDATA] != [NSNull null]){ self.fileData = [NSData dataWithBase64EncodedString:[rs objectForColumnName:kMESSAGE_FILEDATA]]; // [self.fileData release]; } //聊天图片宽高 // self.location_x = [rs objectForColumnName:kMESSAGE_imWidth]; // self.location_y = [rs objectForColumnName:KMESSAGE_imHeight]; self.location_x = [rs objectForColumnName:kMESSAGE_LOCATION_X]; self.location_y = [rs objectForColumnName:kMESSAGE_LOCATION_Y]; self.isSend = [rs objectForColumnName:kMESSAGE_ISSEND]; self.isRead = [rs objectForColumnName:kMESSAGE_ISREAD]; self.timeLen = [rs objectForColumnName:kMESSAGE_TIMELEN]; self.fileSize = [rs objectForColumnName:kMESSAGE_FILESIZE]; self.objectId = [rs stringForColumn:kMESSAGE_OBJECTID]; self.isReceive = [rs objectForColumnName:kMESSAGE_isReceive]; self.isUpload = [rs objectForColumnName:kMESSAGE_isUpload]; self.isReadDel = [NSNumber numberWithBool:[rs boolForColumn:kMESSAGE_isReadDel]]; self.isGroup = [self getIsGroup]; // if([isSend intValue]==transfer_status_ing) // self.isSend = [NSNumber numberWithInt:transfer_status_no]; if([isReceive intValue]==transfer_status_ing) self.isReceive = [NSNumber numberWithInt:transfer_status_no]; self.fromId = [rs stringForColumn:@"fromId"]; self.toId = [rs stringForColumn:@"toId"]; self.readPersons = [rs objectForColumnName:kMESSAGE_readPersons]; self.readTime = [rs dateForColumn:kMESSAGE_readTime]; self.chatMsgHeight = [rs stringForColumn:kMESSAGE_chatMsgHeight]; self.isShowTime = [rs boolForColumn:kMESSAGE_isShowTime]; self.signature = [rs stringForColumn:kMESSAGE_signature]; self.isVerifySignatureFailed = [rs objectForColumnName:kMESSAGE_isVerifySignatureFailed]; #ifdef IS_MsgEncrypt // if (!self.isGroup) { self.content = [g_msgUtil decryptInsertChatMsgContent:self.content msgId:self.messageId]; // } #endif } -(BOOL)delete{ NSString* sql= [NSString stringWithFormat:@"delete from msg_%@ where messageId=?",[self getTableName]]; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID]; BOOL worked=[db executeUpdate:sql,self.messageId]; [g_App copyDbWithUserId:MY_USER_ID]; return worked; } -(BOOL)deleteAll{ NSString* sql= [NSString stringWithFormat:@"delete from msg_%@",[self getTableName]]; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID]; BOOL worked=[db executeUpdate:sql]; return worked; } -(BOOL)deleteWithFromUser:(NSString*)userId roomId:(NSString*)roomId{ NSString* sql= [NSString stringWithFormat:@"delete from msg_%@ where fromUserId=?",roomId]; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID]; BOOL worked=[db executeUpdate:sql,userId]; return worked; } //增删改查 -(BOOL)insert:(NSString*)room { if(_isMySend){//发送 if ([self.isSend integerValue] == 0) { // 消息发送时间更新 NSTimeInterval time = [self.timeSend timeIntervalSince1970]; self.timeSend = [NSDate dateWithTimeIntervalSince1970:(time *1000 + g_server.timeDifference)/1000]; } JXUserObject *user = [[JXUserObject sharedInstance] getUserById:self.toUserId]; if ([user.chatRecordTimeOut doubleValue] <= 0) { self.deleteTime = nil; }else { double n = [user.chatRecordTimeOut doubleValue] * 24 * 3600; double m = [[NSDate date] timeIntervalSince1970]; self.deleteTime = [NSDate dateWithTimeIntervalSince1970:n + m]; } if([self isRoomControlMsg]){ room = self.objectId; if ([self.type intValue] == kRoomRemind_NeedVerify) { SBJsonParser * resultParser = [[SBJsonParser alloc] init] ; NSDictionary *resultObject = [resultParser objectWithString:self.objectId]; if (resultObject) { room = [resultObject objectForKey:@"roomJid"]; } } // 重复收到控制消息不做处理 if ([self getMsgWithMsgId:self.messageId toUserId:room]) { return NO; } [self doReceiveRoomRemind];//必须在前面 if (![self doNewRemindMsg]) { return NO; } } if([messageId length]<=0){ [self setMsgId]; if (!self.isGroup) { self.fromUserName = MY_USER_NAME; } } // 发送的阅后即焚情况下的截屏消息不存到数据库 if ([self.type intValue] == kWCMessageTypeDelMsgScreenshots) { return NO; } }else{//接收 if([self isRoomControlMsg]){ room = self.objectId; if ([self.type intValue] == kRoomRemind_NeedVerify) { SBJsonParser * resultParser = [[SBJsonParser alloc] init] ; NSDictionary *resultObject = [resultParser objectWithString:self.objectId]; if (resultObject) { room = [resultObject objectForKey:@"roomJid"]; } } // 重复收到控制消息不做处理 if ([self getMsgWithMsgId:self.messageId toUserId:room]) { return NO; } [self doReceiveRoomRemind];//必须在前面 NSNumber *type = self.type; if (![self doNewRemindMsg]) { return NO; } // 更改为toId // room = self.objectId; room = self.toId; if ([type intValue] == kRoomRemind_NeedVerify) { SBJsonParser * resultParser = [[SBJsonParser alloc] init] ; NSDictionary *resultObject = [resultParser objectWithString:self.objectId]; if (resultObject) { room = [resultObject objectForKey:@"roomJid"]; } } } if([self.type intValue]==kWCMessageTypeTransferReceive){// 转账被领取 self.type = [NSNumber numberWithInt:kWCMessageTypeRemind]; JXMessageObject *msg = [[JXMessageObject alloc] init]; msg.objectId = self.content; msg.toUserId = self.fromUserId; NSMutableArray *msgs = [msg getMsgWithObjectId:msg.objectId]; for (int i = 0; i < msgs.count; i++) { JXMessageObject *msg1 = msgs[i]; msg1.fileSize = [NSNumber numberWithInt:2]; [msg1 updateFileSize]; } [g_notify postNotificationName:kUpdateTransferMsgFileSize object:self.content]; self.content = [NSString stringWithFormat:@"%@%@",self.fromUserName,Localized(@"JX_ReceivedYourTransfer")]; self.isShowRemind = YES; } if([self.type intValue]==kWCMessageTypeTransferBack){// 转账被退回 // self.type = [NSNumber numberWithInt:kWCMessageTypeRemind]; // self.content = [NSString stringWithFormat:@"%@%@",self.fromUserName,@"转账过期，金额已退回零钱"]; // self.isShowRemind = YES; } if([self.type intValue]==kWCMessageTypeRedPacketReceive){// 红包被领取 if ([self.toUserId isEqualToString:self.fromUserId]) { return NO; } self.type = [NSNumber numberWithInt:kWCMessageTypeRemind]; self.isShowRemind = YES; if(self.objectId.length > 0){//群聊红包 self.toUserId = self.objectId; room = self.objectId; self.isGroup = YES; } self.objectId = self.content; NSString *overStr = [NSString string]; if ([self.fileSize intValue] == 1) { overStr = [NSString stringWithFormat:Localized(@"JX_,YourRedEnvelopeIsAt%@"),[self getTimeForRow:self.fileName overTime:self.timeSend]]; } self.content = [NSString stringWithFormat:@"%@%@%@",self.fromUserName,Localized(@"JXRed_whoGet"),overStr]; } if([self.type intValue]==kWCMessageTypeRedPacketReturn){// 红包退回 self.type = [NSNumber numberWithInt:kWCMessageTypeRemind]; self.isShowRemind = YES; if(self.objectId.length > 0){//群聊红包 self.toUserId = self.objectId; room = self.objectId; self.isGroup = YES; } self.objectId = self.content; self.content = [NSString stringWithFormat:@"%@",Localized(@"JX_ RedEnvelopeExpired")]; } if([self.type intValue]==kWCMessageTypeDelMsgScreenshots){// 截屏消息(对方在聊天中进行了截屏) self.type = [NSNumber numberWithInt:kWCMessageTypeRemind]; self.isShowRemind = YES; } if([messageId length]<=0){ [self setMsgId]; } } if([type intValue]==kWCMessageTypeTransferReceive){// 转账被领取 self.type = [NSNumber numberWithInt:kWCMessageTypeRemind]; JXMessageObject *msg = [[JXMessageObject alloc] init]; msg.objectId = self.content; msg.toUserId = self.fromUserId; NSMutableArray *msgs = [msg getMsgWithObjectId:msg.objectId]; for (int i = 0; i < msgs.count; i++) { JXMessageObject *msg1 = msgs[i]; msg1.fileSize = [NSNumber numberWithInt:2]; [msg1 updateFileSize]; } [g_notify postNotificationName:kUpdateTransferMsgFileSize object:self.content]; self.content = [NSString stringWithFormat:@"%@%@",self.fromUserName,Localized(@"JX_ReceivedYourTransfer")]; self.isShowRemind = YES; } if([type intValue]==kWCMessageTypeRedPacketReceive){// 红包被领取 if ([self.toUserId isEqualToString:self.fromUserId]) { return NO; } self.type = [NSNumber numberWithInt:kWCMessageTypeRemind]; self.isShowRemind = YES; if(self.objectId){//群聊红包 self.toUserId = self.objectId; room = self.objectId; self.isGroup = YES; } self.objectId = self.content; NSString *overStr = [NSString string]; if ([self.fileSize intValue] == 1) { overStr = [NSString stringWithFormat:Localized(@"JX_,YourRedEnvelopeIsAt%@"),[self getTimeForRow:self.fileName overTime:self.timeSend]]; } self.content = [NSString stringWithFormat:@"%@%@%@",self.fromUserName,Localized(@"JXRed_whoGet"),overStr]; } [self changeVideoChatContent]; // 普通消息最终存数据库 if([self isVisible] || [type intValue] == kWCMessageTypeIsRead || [self isAddFriendMsg]){//消息可见才保存 if([room length]>0 || _isGroup) { //将image宽高存入数据库 return [self doInsertRoomMsg:room]; } else{ return [self doInsertMsg:MY_USER_ID tableName:[self getTableName]]; } } [g_App copyDbWithUserId:MY_USER_ID]; return NO; } - (NSString *)getTimeForRow:(NSString *)createTime overTime:(NSDate *)overTime { // 时间差 NSTimeInterval time = [overTime timeIntervalSince1970] - [createTime integerValue]; if (time < 60) { return [NSString stringWithFormat:@"%d%@",(int)time,Localized(@"JX_second")]; } NSInteger sec = time/60; if (sec<60) { return [NSString stringWithFormat:@"%ld%@",(long)sec,Localized(@"JX_Min")]; } // 秒转小时 NSInteger hours = time/3600; if (hours<24) { return [NSString stringWithFormat:@"%ld%@",(long)hours,Localized(@"JX_Hour")]; } return nil; } -(BOOL)doInsertRoomMsg:(NSString*)room { if(room==nil) room = [self getTableName]; NSString* myUserId = MY_USER_ID; self.isGroup = YES; return [self doInsertMsg:myUserId tableName:room]; } -(BOOL)doInsertMsg:(NSString*)dbName tableName:(NSString*)tableName{ if([dbName length]<=0) return NO; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:dbName]; //添加了image宽高2参数 NSString *createStr=[NSString stringWithFormat:@"CREATE TABLE IF NOT EXISTS 'msg_%@' ('messageNo' INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL UNIQUE , 'fromUserId' VARCHAR, 'toUserId' VARCHAR, 'content' VARCHAR, 'timeSend' DATETIME,'timeReceive' DATETIME,'type' INTEGER, 'messageId' VARCHAR, 'fileData' VARCHAR, 'fileName' VARCHAR,'fileSize' INTEGER,'location_x' INTEGER,'location_y' INTEGER,'timeLen' INTEGER,'isRead' INTEGER,'isSend' INTEGER,'objectId' INTEGER,'isReceive' INTEGER,'isUpload' INTEGER,'fromUserName' VARCHAR,'toUserName' VARCHAR,'isReadDel' INTEGER,'fromId' VARCHAR,'toId' VARCHAR,'readPersons' INTEGER,'readTime' DATETIME, 'deleteTime' DATETIME,'chatMsgHeight' VARCHAR,'isShowTime' INTEGER,'signature' VARCHAR,'isVerifySignatureFailed' INTEGER)",tableName]; // NSString *createStr=[NSString stringWithFormat:@"CREATE TABLE IF NOT EXISTS 'msg_%@' ('messageNo' INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL UNIQUE , 'fromUserId' VARCHAR, 'toUserId' VARCHAR, 'content' VARCHAR, 'timeSend' DATETIME,'timeReceive' DATETIME,'type' INTEGER, 'messageId' VARCHAR, 'fileData' VARCHAR, 'fileName' VARCHAR,'fileSize' INTEGER,'location_x' INTEGER,'location_y' INTEGER,'timeLen' INTEGER,'isRead' INTEGER,'isSend' INTEGER,'objectId' INTEGER,'isReceive' INTEGER,'isUpload' INTEGER,'fromUserName' VARCHAR,'toUserName' VARCHAR,'isReadDel' INTEGER,'fromId' VARCHAR,'toId' VARCHAR,'readPersons' INTEGER,'readTime' DATETIME, 'deleteTime' DATETIME,'chatMsgHeight' VARCHAR,'isShowTime' INTEGER,'signature' VARCHAR,'isVerifySignatureFailed' INTEGER,'groupType' VARCHAR,)",tableName]; BOOL worked = [db executeUpdate:createStr]; // FMDBQuickCheck(worked); NSString* sql= [NSString stringWithFormat:@"select messageId from msg_%@ where messageId=?",tableName]; FMResultSet *rs=[db executeQuery:sql,self.messageId]; while ([rs next]) { // NSLog(@"不必重复保存:%@",self.messageId); return NO; } if ([self.type intValue] == kWCMessageTypeIsRead && self.isGroup){ NSString *content = self.content; #ifdef IS_MsgEncrypt // if (!self.isGroup) { content = [g_msgUtil encryptInsertChatMsgContent:self.content msgId:self.messageId]; // } #endif NSString* sql= [NSString stringWithFormat:@"select messageId from msg_%@ where content=? and fromUserId=?",tableName]; FMResultSet *rs=[db executeQuery:sql,content,self.fromUserId]; while ([rs next]) //已读回执消息不重复保存 return NO; } NSString *content = self.content; #ifdef IS_MsgEncrypt // if (!self.isGroup) { content = [g_msgUtil encryptInsertChatMsgContent:self.content msgId:self.messageId]; // } #endif // 如果是系统推送消息 if (self.isGroup && [self.fromId containsString:@"/Server"]) { self.toUserId = toId; tableName = toId; } NSString *insertStr=[NSString stringWithFormat:@"INSERT INTO msg_%@ (fromUserId,toUserId,content,type,messageId,timeSend,timeReceive,fileData,fileName,fileSize,location_x,location_y,timeLen,isRead,isSend,objectId,isReceive,isUpload,fromUserName,toUserName,isReadDel,fromId,toId,readPersons,readTime,deleteTime,chatMsgHeight,isShowTime,signature,isVerifySignatureFailed) VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)",tableName]; worked = [db executeUpdate:insertStr,self.fromUserId,self.toUserId,content,self.type,self.messageId,self.timeSend,self.timeReceive,[self.fileData xmpp_base64Encoded],self.fileName,self.fileSize,self.location_x,self.location_y,self.timeLen,self.isRead,self.isSend,self.objectId,self.isReceive,self.isUpload,self.fromUserName,self.toUserName,self.isReadDel,self.fromId,self.toId,self.readPersons, self.readTime,self.deleteTime,self.chatMsgHeight,[NSNumber numberWithBool:self.isShowTime],self.signature,self.isVerifySignatureFailed]; // FMDBQuickCheck(worked); return worked; } -(void)updateLastSend:(UpdateLastSendType)newMsgType{ if(!self.isVisible && ![self isAddFriendMsg])//加好友消息要更新 return; if(!self.updateLastContent) return; NSString* tableName = [self getTableName]; if(self.isMySend)//假如是自己发送的 newMsgType = UpdateLastSendType_None; if([current_chat_userId isEqualToString:tableName])//假如正在这个界面 newMsgType = UpdateLastSendType_None; if([self.type intValue] == kWCMessageTypeRemind)//假如是提示消息，新数量总是0 newMsgType = UpdateLastSendType_None; if([self.type intValue] == kWCMessageTypeAudioMeetingInvite || [self.type intValue] == kWCMessageTypeVideoMeetingInvite)//一律不提醒 newMsgType = UpdateLastSendType_None; // if([current_meeting_no isEqualToString:self.fileName])//如果是邀请会议消息，且正在开会，则不提醒 if([self.type intValue] == kWCMessageTypeGroupActivity)//假如是提示消息，新数量总是0 newMsgType = UpdateLastSendType_None; // kRoomRemind_RoomIsOpenIntegral if([self.type intValue] == kRoomRemind_RoomChangeOpenIntegral)//假如是提示消息，新数量总是0 newMsgType = UpdateLastSendType_None; if([self.type intValue] == kRoomRemind_RoomIsOpenIntegral)//假如是提示消息，新数量总是0 newMsgType = UpdateLastSendType_None; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID]; NSString* s=[self getLastContent]; BOOL worked; NSString* sql; if(self.timeSend == nil) self.timeSend = [NSDate date]; NSString* t=nil; switch (newMsgType) { case UpdateLastSendType_Add: t = @",newMsgs=ifnull(newMsgs,0)+1";//此处更新内容，数量+1,ifnull很重要 break; case UpdateLastSendType_None: t = @""; //此处只更新内容，数量不变 break; case UpdateLastSendType_Dec: t = @",newMsgs=ifnull(newMsgs,1)-1"; //此处更新内容，数量置0 break; default: break; } JXUserObject *user = [[JXUserObject sharedInstance] getUserById:tableName]; // 如果downloadTime 跟timeSend一致表示没有要同步的消息，所以可以更新downloadTime 否则不更新 if ([user.downloadTime timeIntervalSince1970] == [user.timeSend timeIntervalSince1970]) { sql = [NSString stringWithFormat:@"update friend set content=?,type=?,timeSend=?,downloadTime=?%@ where userId=?",t]; worked=[db executeUpdate:sql,s,self.type,self.timeSend,self.timeSend,tableName]; }else { sql = [NSString stringWithFormat:@"update friend set content=?,type=?,timeSend=?%@ where userId=?",t]; worked=[db executeUpdate:sql,s,self.type,self.timeSend,tableName]; } return; } // 更新新消息数量 -(void)updateNewMsgCount:(int)count withUserId:(NSString *)userId { NSString *sql = [NSString stringWithFormat:@"update friend set newMsgs=? where userId=?"]; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID]; [db executeUpdate:sql,[NSNumber numberWithInt:count],userId]; } -(NSString*)getTableName{ if([self isAddFriendMsg]) return FRIEND_CENTER_USERID; if(self.isGroup)//假如是群聊 return self.toUserId; NSString* tableName; NSString* myUserId = MY_USER_ID; if([self.toUserId isEqualToString:myUserId])//如果是发给我，取发送者作为表名 tableName = self.fromUserId; else tableName = self.toUserId; if (!tableName) { if(fromId) return fromId; } return tableName; } -(BOOL)checkSystemMsg:(NSString*)dbName tableName:(NSString*)tableName{ return NO; } -(NSString*)getTypeName{ NSString* s; int n = [self.type intValue]; switch (n) { case kWCMessageTypeLink: s = [NSString stringWithFormat:@"[%@]",Localized(@"JXLink")]; break; case kWCMessageTypeSystemImage1: case kWCMessageTypeSystemImage2: s = [NSString stringWithFormat:@"[%@]",Localized(@"JXGraphic")]; break; case kWCMessageTypeImage: s = [NSString stringWithFormat:@"[%@]",Localized(@"JX_Image")]; break; case kWCMessageTypeCustomFace: case kWCMessageTypeEmoji: s = [NSString stringWithFormat:@"[%@]",Localized(@"emojiVC_Emoji")]; break; case kWCMessageTypeGif: s = [NSString stringWithFormat:@"[%@]",Localized(@"emojiVC_Emoji")]; break; case kWCMessageTypeVoice: s = [NSString stringWithFormat:@"[%@]",Localized(@"JX_Voice")]; break; case kWCMessageTypeLocation: s = [NSString stringWithFormat:@"[%@]",Localized(@"JX_Location")]; break; case kWCMessageTypeVideo: s = [NSString stringWithFormat:@"[%@]",Localized(@"JX_Video")]; break; case kWCMessageTypeAudio: s = [NSString stringWithFormat:@"[%@]",Localized(@"JXAudio")]; break; case kWCMessageTypeFile: s = [NSString stringWithFormat:@"[%@]",Localized(@"JX_File")]; break; case kWCMessageTypeCard: s = [NSString stringWithFormat:@"[%@]",Localized(@"JX_Card")]; break; case kWCMessageTypeRedPacket: s = [NSString stringWithFormat:@"[%@]",Localized(@"JX_RED")]; break; case kWCMessageTypeTransfer: s = [NSString stringWithFormat:@"[%@]",Localized(@"JX_Transfer")]; break; default: s = self.content; break; } return s; } -(NSString*)getLastContent{ NSString* s; int n = [self.type intValue]; switch (n) { case kWCMessageTypeLink: s = [NSString stringWithFormat:@"[%@]",Localized(@"JXLink")]; break; case kWCMessageTypeSystemImage1: case kWCMessageTypeSystemImage2: s = [NSString stringWithFormat:@"[%@]",Localized(@"JXGraphic")]; break; case kWCMessageTypeImage: s = [NSString stringWithFormat:@"[%@]",Localized(@"JX_Image")]; break; case kWCMessageTypeEmoji: case kWCMessageTypeCustomFace: s = [NSString stringWithFormat:@"[%@]",Localized(@"emojiVC_Emoji")]; break; case kWCMessageTypeGif: s = [NSString stringWithFormat:@"[%@]",Localized(@"emojiVC_Emoji")]; break; case kWCMessageTypeVoice: s = [NSString stringWithFormat:@"[%@]",Localized(@"JX_Voice")]; break; case kWCMessageTypeLocation: s = [NSString stringWithFormat:@"[%@]",Localized(@"JX_Location")]; break; case kWCMessageTypeVideo: s = [NSString stringWithFormat:@"[%@]",Localized(@"JX_Video")]; break; case kWCMessageTypeAudio: s = [NSString stringWithFormat:@"[%@]",Localized(@"JXAudio")]; break; case kWCMessageTypeFile: s = [NSString stringWithFormat:@"[%@]",Localized(@"JX_File")]; break; case kWCMessageTypeCard: s = [NSString stringWithFormat:@"[%@]",Localized(@"JX_Card")]; break; case kWCMessageTypeRedPacket: s = [NSString stringWithFormat:@"[%@]",Localized(@"JX_RED")]; break; case kWCMessageTypeTransfer: s = [NSString stringWithFormat:@"[%@]%@",Localized(@"JX_Transfer"),self.isMySend ? Localized(@"JX_WaitForYourFriend'sConfirmation") : @""]; break; case kWCMessageTypeTransferReceive: s = [NSString stringWithFormat:@"[%@]%@",Localized(@"JX_Transfer"),Localized(@"JX_TheFriendHasConfirmedTheCharge")]; break; case kWCMessageTypeTransferBack: s = [NSString stringWithFormat:@"%@",Localized(@"JX_RefundNoticeOfOverdueTransfer")]; break; case kWCMessageTypeShake: //Localized(@"JX_Shake") s = [NSString stringWithFormat:@"[%@]",@"抖TA"]; break; case kWCMessageTypeMergeRelay: s = [NSString stringWithFormat:@"[%@]",Localized(@"JX_ChatRecord")]; break; case kWCMessageTypeShare: s = [NSString stringWithFormat:@"[%@]",Localized(@"JXLink")]; break; case kWCMessageTypePaymentOut: case kWCMessageTypeReceiptOut: case kWCMessageTypeOpenPaySuccess: s = [NSString stringWithFormat:@"%@",Localized(@"JX_NoticeOfPayment")]; break; case kWCMessageTypePaymentGet: case kWCMessageTypeReceiptGet: s = [NSString stringWithFormat:@"%@",Localized(@"JX_ReceiptNotice")]; break; /* case XMPP_TYPE_SAYHELLO: // s = [NSString stringWithFormat:@"有人打招呼:%@",self.content]; s = self.content; break; case XMPP_TYPE_PASS: if(self.isMySend) s = Localized(@"JXFriendObject_Passed"); else s = Localized(@"JXFriendObject_PassGo"); break; case XMPP_TYPE_FEEDBACK: s = self.content; break; case XMPP_TYPE_NEWSEE: if(self.isMySend) s = Localized(@"JXFriendObject_Followed"); else s = Localized(@"JXFriendObject_FollowYour"); break; case XMPP_TYPE_DELSEE: if(self.isMySend) s = Localized(@"JXFriendObject_CencalFollowed"); else s = Localized(@"JXFriendObject_CancelFollow"); break; case XMPP_TYPE_RECOMMEND: s = Localized(@"JXFriendObject_RecomYou"); */ default: s = self.content; break; } if ([self.isReadDel boolValue]) { s = [NSString stringWithFormat:@"[%@]", Localized(@"JX_ReadDelMsg")]; } if (self.isGroup && [self.type intValue] != kWCMessageTypeRemind) { JXUserObject *allUser = [[JXUserObject alloc] init]; allUser = [allUser getUserById:self.fromUserId]; JXUserObject *roomUser = [[JXUserObject sharedInstance] getUserById:self.toUserId]; NSDictionary * groupDict = [roomUser toDictionary]; memberData *data = [[memberData alloc] init]; data.roomId = roomUser.roomId; data = [data getCardNameById:self.fromUserId]; roomData * roomdata = [[roomData alloc] init]; [roomdata getDataFromDict:groupDict]; NSArray * allMem = [memberData fetchAllMembers:roomUser.roomId]; roomdata.members = [allMem mutableCopy]; memberData *data1 = [roomdata getMember:MY_USER_ID]; NSString *nickName; if ([data1.role intValue] == 1) { nickName = data.lordRemarkName.length > 0 ? data.lordRemarkName : allUser.remarkName.length > 0 ? allUser.remarkName : data.userNickName.length > 0 ? data.userNickName : self.fromUserName; }else { nickName = allUser.remarkName.length > 0 ? allUser.remarkName : data.userNickName.length > 0 ? data.userNickName : self.fromUserName; } NSRange range = [s rangeOfString:[NSString stringWithFormat:@"%@:",nickName]]; if (range.location == 0 || !self.fromUserName) { return s; }else { return [NSString stringWithFormat:@"%@:%@",nickName,s]; } } return s; } /* -(BOOL)updateIsRead:(BOOL)b{//单聊更新已读标志，弃用 if(!self.isReceive) return NO; self.isRead = [NSNumber numberWithBool:b]; self.readTime = [NSDate date]; NSString* sql= [NSString stringWithFormat:@"update msg_%@ set isRead=?,readTime=? where messageId=?",[self getTableName]]; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID]; BOOL worked=[db executeUpdate:sql,self.isRead,self.readTime,self.messageId]; // FMDBQuickCheck(worked); return worked; } */ -(void)updateIsReadWithContent{//更新已读类型消息的Content即MsgId指向的消息的已读 if(self.isGroup) [self updateReadPersons:self.content]; else [self updateIsRead:self.timeSend msgId:self.content]; } -(BOOL)updateIsRead:(NSDate *)time msgId:(NSString*)msgId{//更新已读时间 // if(!self.isReceive) // return NO; if (time==nil) time = [NSDate date]; self.isRead = [NSNumber numberWithBool:YES]; self.isSend = [NSNumber numberWithBool:YES]; self.readTime = time; NSString* sql= [NSString stringWithFormat:@"update msg_%@ set isSend=1,isRead=1,readTime=? where messageId=?",[self getTableName]]; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID]; BOOL worked=[db executeUpdate:sql,self.readTime, msgId]; // FMDBQuickCheck(worked); return worked; } -(BOOL)updateReadPersons:(NSString*)msgId{//更新群聊已读人数 NSString *tableName = [self getTableName]; if(self.isMySend){ self.isRead = [NSNumber numberWithBool:YES]; self.isSend = [NSNumber numberWithBool:YES]; } self.readPersons = [NSNumber numberWithInt:[self.readPersons intValue]+1]; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID]; NSString* sql,* s; if(self.isMySend) s = @"isRead=1,"; else s = @""; sql= [NSString stringWithFormat:@"update msg_%@ set %@ isSend=1,readPersons=ifnull(readPersons,0)+1 where messageId=?",tableName,s];//ifnull很重要 BOOL worked = [db executeUpdate:sql,msgId]; return worked; } -(BOOL)updateIsUpload:(BOOL)b{ if(!self.isSend) return NO; NSString *content = self.content; #ifdef IS_MsgEncrypt // if (!self.isGroup) { content = [g_msgUtil encryptInsertChatMsgContent:self.content msgId:self.messageId]; // } #endif self.isUpload = [NSNumber numberWithBool:b]; NSString* sql= [NSString stringWithFormat:@"update msg_%@ set isUpload=?,content=? where messageId=?",[self getTableName]]; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID]; BOOL worked=[db executeUpdate:sql,self.isUpload,content,self.messageId]; // FMDBQuickCheck(worked); return worked; } -(BOOL)updateIsReceive:(int)n{ self.isReceive = [NSNumber numberWithInt:n]; NSString* sql= [NSString stringWithFormat:@"update msg_%@ set isReceive=?,fileName=? where messageId=?",[self getTableName]]; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID]; BOOL worked=[db executeUpdate:sql,self.isReceive,self.fileName,self.messageId]; // FMDBQuickCheck(worked); return worked; } -(BOOL)updateIsSend:(int)n{ self.isSend = [NSNumber numberWithInt:n]; self.timeReceive = [NSDate date]; NSString* sql= [NSString stringWithFormat:@"update msg_%@ set isSend=?,timeReceive=? where messageId=?",[self getTableName]]; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID]; BOOL worked=[db executeUpdate:sql,self.isSend,self.timeReceive,self.messageId]; // FMDBQuickCheck(worked); return worked; } //获取某联系人聊天记录 -(NSMutableArray *)fetchMessageListWithUser:(NSString *)userId byAllNum:(NSInteger)num pageCount:(int)pageCount startTime:(NSDate *)startTime { // NSLog(@"fetchMessageListWithUser.begin"); NSString* myUserId = MY_USER_ID; if([myUserId length]<=0) return nil; JXUserObject *user = [[JXUserObject sharedInstance] getUserById:userId]; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId]; NSMutableArray *messageList=[[NSMutableArray alloc]init]; NSString *queryString=[NSString stringWithFormat:@"select * from msg_%@ where (fromUserId=? or toUserId=?) and type<>26 and timeSend >= ? order by timeSend desc,messageNo desc limit %ld,%d",userId,num,pageCount]; // NSString *queryString=[NSString stringWithFormat:@"select * from msg_%@ order by timeSend desc,messageNo desc limit ?*%d,%d",userId,PAGE_SHOW_COUNT,PAGE_SHOW_COUNT]; CGFloat chatAllHeight = 0; NSMutableArray* temp = [[NSMutableArray alloc]init]; FMResultSet *rs=[db executeQuery:queryString,userId,userId,startTime]; while ([rs next]) { JXMessageObject *p=[[JXMessageObject alloc] init]; p.isGroup = [user.roomFlag boolValue]; [p fromRs:rs]; p.isGroup = [user.roomFlag boolValue]; // 去除文本阅后即焚计时结束的消息 if ([p.type intValue] == 1 && !p.isMySend && [p.fileName isKindOfClass:[NSString class]] && [p.fileName length] > 0 && [p.fileName intValue] > 0) { NSString *messageR = [p.content stringByReplacingOccurrencesOfString:@"\r" withString:@""]; //去掉回车键 NSString *messageN = [messageR stringByReplacingOccurrencesOfString:@"\n" withString:@""]; //去掉回车键 NSString *messageText = [messageN stringByReplacingOccurrencesOfString:@" " withString:@""]; //去掉空格 CGSize size = [messageText boundingRectWithSize:CGSizeMake(JX_SCREEN_WIDTH-INSETS-HEAD_SIZE - 100 + 5, MAXFLOAT) options:NSStringDrawingUsesLineFragmentOrigin attributes:@{NSFontAttributeName:SYSFONT(g_constant.chatFont)} context:nil].size; NSInteger count = size.height / g_constant.chatFont; NSLog(@"countcount === %ld-----%f-----%@",count,[[NSDate date] timeIntervalSince1970],p.fileName); // NSLog(@"countcount === %ld,,,,%f,,,,%@",count,[[NSDate date] timeIntervalSince1970], self.msg.fileName); count = count * 10 - ([[NSDate date] timeIntervalSince1970] - [p.fileName longLongValue]); if (count <= 0) { [p delete]; continue; } } // CGFloat height = [self getMsgChatHeight:p]; // p.chatMsgHeight = [NSString stringWithFormat:@"%f",height]; // chatAllHeight += height; // // if (num <= 0) { // // if (chatAllHeight < JX_SCREEN_HEIGHT || temp.count <= 5) { // [temp addObject:p]; // } // // }else { [temp addObject:p]; // } } // NSLog(@"聊天记录第%d页:%d",pageIndex,temp.count); [rs close]; for(NSInteger i=[temp count]-1;i>=0;i--){ [messageList addObject:[temp objectAtIndex:i]]; } if([messageList count]==0) messageList = nil; return messageList; } - (CGFloat)getMsgChatHeight:(JXMessageObject *)msg { switch ([msg.type intValue]) { case kWCMessageTypeText: return [JXMessageCell getChatCellHeight:msg]; break; case kWCMessageTypeImage: return [JXImageCell getChatCellHeight:msg]; break; case kWCMessageTypeCustomFace: return [JXFaceCustomCell getChatCellHeight:msg]; break; case kWCMessageTypeEmoji: return [JXEmojiCell getChatCellHeight:msg]; break; case kWCMessageTypeVoice: return [JXAudioCell getChatCellHeight:msg]; break; case kWCMessageTypeLocation: return [JXLocationCell getChatCellHeight:msg]; break; case kWCMessageTypeGif: return [JXGifCell getChatCellHeight:msg]; break; case kWCMessageTypeVideo: return [JXVideoCell getChatCellHeight:msg]; break; case kWCMessageTypeAudio: return [JXVideoCell getChatCellHeight:msg]; break; case kWCMessageTypeCard: return [JXCardCell getChatCellHeight:msg]; break; case kWCMessageTypeFile: return [JXFileCell getChatCellHeight:msg]; break; case kWCMessageTypeRemind: return [JXRemindCell getChatCellHeight:msg]; break; case kWCMessageTypeRedPacket: return [JXRedPacketCell getChatCellHeight:msg]; break; case kWCMessageTypeTransfer: return [JXTransferCell getChatCellHeight:msg]; break; case kWCMessageTypeSystemImage1: return [JXSystemImage1Cell getChatCellHeight:msg]; break; case kWCMessageTypeSystemImage2: return [JXSystemImage2Cell getChatCellHeight:msg]; break; case kWCMessageTypeAudioMeetingInvite: case kWCMessageTypeVideoMeetingInvite: case kWCMessageTypeAudioChatCancel: case kWCMessageTypeAudioChatEnd: case kWCMessageTypeVideoChatCancel: case kWCMessageTypeVideoChatEnd: case kWCMessageTypeAVBusy: return [JXAVCallCell getChatCellHeight:msg]; break; case kWCMessageTypeLink: return [JXLinkCell getChatCellHeight:msg]; break; case kWCMessageTypeShake: return [JXShakeCell getChatCellHeight:msg]; break; case kWCMessageTypeMergeRelay: return [JXMergeRelayCell getChatCellHeight:msg]; break; case kWCMessageTypeShare: return [JXShareCell getChatCellHeight:msg]; break; case kWCMessageTypeReply: return [JXReplyCell getChatCellHeight:msg]; break; default: return [JXBaseChatCell getChatCellHeight:msg]; break; } } //获取某联系人所有聊天记录 -(NSMutableArray*)fetchAllMessageListWithUser:(NSString *)userId { NSString* myUserId = MY_USER_ID; if([myUserId length]<=0) return nil; JXUserObject *user = [[JXUserObject sharedInstance] getUserById:userId]; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId]; NSMutableArray *messageList=[[NSMutableArray alloc]init]; NSString *queryString=[NSString stringWithFormat:@"select * from msg_%@ where (fromUserId=? or toUserId=?) and type<>26 order by timeSend desc,messageNo desc",userId]; // NSString *queryString=[NSString stringWithFormat:@"select * from msg_%@ order by timeSend desc,messageNo desc",userId]; NSMutableArray* temp = [[NSMutableArray alloc]init]; FMResultSet *rs=[db executeQuery:queryString,userId,userId]; while ([rs next]) { JXMessageObject *p=[[JXMessageObject alloc]init]; [p fromRs:rs]; p.isGroup = [user.roomFlag boolValue]; // 去除文本阅后即焚计时结束的消息 if ([p.type intValue] == 1 && !p.isMySend && [p.fileName isKindOfClass:[NSString class]] && [p.fileName length] > 0 && [p.fileName intValue] > 0) { NSString *messageR = [p.content stringByReplacingOccurrencesOfString:@"\r" withString:@""]; //去掉回车键 NSString *messageN = [messageR stringByReplacingOccurrencesOfString:@"\n" withString:@""]; //去掉回车键 NSString *messageText = [messageN stringByReplacingOccurrencesOfString:@" " withString:@""]; //去掉空格 CGSize size = [messageText boundingRectWithSize:CGSizeMake(JX_SCREEN_WIDTH-INSETS-HEAD_SIZE - 100 + 5, MAXFLOAT) options:NSStringDrawingUsesLineFragmentOrigin attributes:@{NSFontAttributeName:SYSFONT(g_constant.chatFont)} context:nil].size; NSInteger count = size.height / g_constant.chatFont; NSLog(@"countcount === %ld-----%f-----%@",count,[[NSDate date] timeIntervalSince1970],p.fileName); // NSLog(@"countcount === %ld,,,,%f,,,,%@",count,[[NSDate date] timeIntervalSince1970], self.msg.fileName); count = count * 10 - ([[NSDate date] timeIntervalSince1970] - [p.fileName longLongValue]); if (count <= 0) { [p delete]; continue; } } // CGFloat height = [self getMsgChatHeight:p]; // p.chatMsgHeight = [NSString stringWithFormat:@"%f",height]; [temp addObject:p]; } // NSLog(@"聊天记录第%d页:%d",pageIndex,temp.count); [rs close]; for(NSInteger i=[temp count]-1;i>=0;i--){ [messageList addObject:[temp objectAtIndex:i]]; } if([messageList count]==0) messageList = nil; return messageList; } //获取某联系人某个type的所有聊天记录 -(NSMutableArray*)fetchAllMessageListWithUser:(NSString *)userId withTypes:(NSArray *)types { NSString* myUserId = MY_USER_ID; if([myUserId length]<=0) return nil; JXUserObject *user = [[JXUserObject sharedInstance] getUserById:userId]; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId]; NSMutableString *typeStr = [NSMutableString string]; for (NSInteger i = 0; i < types.count; i ++) { NSNumber *type = types[i]; if (i == 0) { [typeStr appendString:[NSString stringWithFormat:@"type = %@",type]]; }else { [typeStr appendString:[NSString stringWithFormat:@" or type = %@",type]]; } } NSMutableArray *messageList=[[NSMutableArray alloc]init]; NSString *queryString=[NSString stringWithFormat:@"select * from msg_%@ where (fromUserId=? or toUserId=?) and (%@) order by timeSend desc,messageNo desc",userId,typeStr]; // NSString *queryString=[NSString stringWithFormat:@"select * from msg_%@ order by timeSend desc,messageNo desc",userId]; NSMutableArray* temp = [[NSMutableArray alloc]init]; FMResultSet *rs=[db executeQuery:queryString,userId,userId,type]; while ([rs next]) { JXMessageObject *p=[[JXMessageObject alloc]init]; [p fromRs:rs]; p.isGroup = [user.roomFlag boolValue]; // 去除文本阅后即焚计时结束的消息 if ([p.type intValue] == 1 && !p.isMySend && [p.fileName isKindOfClass:[NSString class]] && [p.fileName length] > 0 && [p.fileName intValue] > 0) { NSString *messageR = [p.content stringByReplacingOccurrencesOfString:@"\r" withString:@""]; //去掉回车键 NSString *messageN = [messageR stringByReplacingOccurrencesOfString:@"\n" withString:@""]; //去掉回车键 NSString *messageText = [messageN stringByReplacingOccurrencesOfString:@" " withString:@""]; //去掉空格 CGSize size = [messageText boundingRectWithSize:CGSizeMake(JX_SCREEN_WIDTH-INSETS-HEAD_SIZE - 100 + 5, MAXFLOAT) options:NSStringDrawingUsesLineFragmentOrigin attributes:@{NSFontAttributeName:SYSFONT(g_constant.chatFont)} context:nil].size; NSInteger count = size.height / g_constant.chatFont; NSLog(@"countcount === %ld-----%f-----%@",count,[[NSDate date] timeIntervalSince1970],p.fileName); // NSLog(@"countcount === %ld,,,,%f,,,,%@",count,[[NSDate date] timeIntervalSince1970], self.msg.fileName); count = count * 10 - ([[NSDate date] timeIntervalSince1970] - [p.fileName longLongValue]); if (count <= 0) { [p delete]; continue; } } [temp addObject:p]; } // NSLog(@"聊天记录第%d页:%d",pageIndex,temp.count); [rs close]; // for(NSInteger i=[temp count]-1;i>=0;i--){ // [messageList addObject:[temp objectAtIndex:i]]; // } // if([messageList count]==0) // messageList = nil; return temp; } // 获取某个时间段聊天记录 - (NSMutableArray *) fetchMessageListUserId:(NSString *)userId StartTime:(NSDate *)startTime endTime:(NSDate *)endTime { NSString* myUserId = MY_USER_ID; if([myUserId length]<=0) return nil; JXUserObject *user = [[JXUserObject sharedInstance] getUserById:userId]; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId]; NSMutableArray *messageList=[[NSMutableArray alloc]init]; NSString *queryString=[NSString stringWithFormat:@"select * from msg_%@ where (fromUserId=? or toUserId=?) and type<>26 and timeSend > ? and timeSend < ? order by timeSend desc,messageNo desc",userId]; NSMutableArray* temp = [[NSMutableArray alloc]init]; FMResultSet *rs=[db executeQuery:queryString,userId,userId,startTime,endTime]; while ([rs next]) { JXMessageObject *p=[[JXMessageObject alloc] init]; [p fromRs:rs]; p.isGroup = [user.roomFlag boolValue]; [temp addObject:p]; } [rs close]; for(NSInteger i=[temp count]-1;i>=0;i--){ [messageList addObject:[temp objectAtIndex:i]]; } return messageList; } //获取客服号，公众号内容 -(NSMutableArray *)getSystemChatByPage:(int)pageIndex types:(NSString*)types { NSString* myUserId = MY_USER_ID; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId]; NSMutableArray *messageList=[[NSMutableArray alloc]init]; NSString *queryString=[NSString stringWithFormat:@"select * from msg_%@ where type in (%@) order by timeSend desc,messageNo desc limit ?*%d,%d",CALL_CENTER_USERID,types,PAGE_SHOW_COUNT,PAGE_SHOW_COUNT]; FMResultSet *rs=[db executeQuery:queryString,[NSNumber numberWithInt:pageIndex]]; while ([rs next]) { JXMessageObject *p=[[JXMessageObject alloc]init]; [p fromRs:rs]; [messageList addObject:p]; // [p release]; } // NSLog(@"最近聊天人第%d页:%d",pageIndex,messageList.count); if([messageList count]==0) messageList = nil; return messageList; } //获取最近联系人 -(NSMutableArray *)fetchRecentChatByPage:(int)pageIndex { NSString* myUserId = MY_USER_ID; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId]; NSMutableArray *messageList=[[NSMutableArray alloc]init]; NSString *queryString=[NSString stringWithFormat:@"select * from friend where status<=8 and length(content)>0 order by timeSend desc limit ?*%d,%d",PAGE_SHOW_COUNT,PAGE_SHOW_COUNT]; FMResultSet *rs=[db executeQuery:queryString,[NSNumber numberWithInt:pageIndex]]; while ([rs next]) { JXMessageObject *p=[[JXMessageObject alloc]init]; // [p fromRs:rs]; p.content = [rs stringForColumn:kMESSAGE_CONTENT]; p.type = [rs objectForColumnName:kMESSAGE_TYPE]; p.timeSend = [rs dateForColumn:kMESSAGE_TIMESEND]; p.fromUserId = [rs stringForColumn:kUSER_ID]; p.toUserId = myUserId; JXUserObject *user=[[JXUserObject alloc]init]; [user userFromDataset:user rs:rs]; JXMsgAndUserObject *unionObject=[JXMsgAndUserObject unionWithMessage:p andUser:user ]; [messageList addObject:unionObject]; } db = nil; if([messageList count]==0) messageList = nil; // NSLog(@"最近聊天人第%d页:%d",pageIndex,messageList.count); return messageList; } -(NSMutableArray *)fetchRecentChat { NSString* myUserId = MY_USER_ID; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId]; NSMutableArray *messageList=[[NSMutableArray alloc]init]; // NSString *queryString=[NSString stringWithFormat:@"select * from friend where (status=8 or status=2 or status=0) and userId != %@ order by timeSend desc", FRIEND_CENTER_USERID]; // NSString *queryString=[NSString stringWithFormat:@"select * from friend where (status=8 or status=2 or status=0) and topTime > 0 and userId != %@ order by timeSend desc", FRIEND_CENTER_USERID]; NSString *queryString=[NSString stringWithFormat:@"select * from friend where (status=8 or status=2 or status=0 or status=10) and length(content)>0 and topTime > 0 and userId != %@ order by timeSend desc", FRIEND_CENTER_USERID]; FMResultSet *rs=[db executeQuery:queryString]; while ([rs next]) { JXMessageObject *p=[[JXMessageObject alloc]init]; // [p fromRs:rs]; p.content = [rs stringForColumn:kMESSAGE_CONTENT]; p.type = [rs objectForColumnName:kMESSAGE_TYPE]; p.timeSend = [rs dateForColumn:kMESSAGE_TIMESEND]; p.fromUserId = [rs stringForColumn:kUSER_ID]; p.toUserId = myUserId; JXUserObject *user=[[JXUserObject alloc]init]; [user userFromDataset:user rs:rs]; // if (user.roomFlag || user.roomId.length > 0) { // p.isGroup = YES; // } JXMsgAndUserObject *unionObject=[JXMsgAndUserObject unionWithMessage:p andUser:user ]; [messageList addObject:unionObject]; } // queryString=[NSString stringWithFormat:@"select * from friend where (status=8 or status=2 or status=0) and (topTime is null or topTime = 0) and userId != %@ order by timeSend desc", FRIEND_CENTER_USERID]; queryString=[NSString stringWithFormat:@"select * from friend where (status=8 or status=2 or status=0 or status=10) and length(content)>0 and (topTime is null or topTime = 0) and userId != %@ order by timeSend desc", FRIEND_CENTER_USERID]; rs=[db executeQuery:queryString]; while ([rs next]) { JXMessageObject *p=[[JXMessageObject alloc]init]; // [p fromRs:rs]; p.content = [rs stringForColumn:kMESSAGE_CONTENT]; p.type = [rs objectForColumnName:kMESSAGE_TYPE]; p.timeSend = [rs dateForColumn:kMESSAGE_TIMESEND]; p.fromUserId = [rs stringForColumn:kUSER_ID]; p.toUserId = myUserId; JXUserObject *user=[[JXUserObject alloc]init]; [user userFromDataset:user rs:rs]; // if (user.roomFlag || user.roomId.length > 0) { // p.isGroup = YES; // } JXMsgAndUserObject *unionObject=[JXMsgAndUserObject unionWithMessage:p andUser:user ]; [messageList addObject:unionObject]; } db = nil; if([messageList count]==0) messageList = nil; return messageList; } //只获取某联系人图片聊天记录 -(NSMutableArray*)fetchImageMessageListWithUser:(NSString *)userId { NSLog(@"fetchMessageListWithUser.begin"); NSString* myUserId = MY_USER_ID; if([myUserId length]<=0) return nil; JXUserObject *user = [[JXUserObject sharedInstance] getUserById:userId]; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId]; NSMutableArray *messageList=[[NSMutableArray alloc]init]; NSString *queryString = nil; queryString = [NSString stringWithFormat:@"select * from msg_%@ where type=2 order by timeSend asc,messageNo asc",userId]; FMResultSet *rs=[db executeQuery:queryString]; while ([rs next]) { JXMessageObject *p=[[JXMessageObject alloc]init]; p.isGroup = [user.roomFlag boolValue]; [p fromRs:rs]; [messageList addObject:p]; p = nil; } [rs close]; db = nil; NSLog(@"fetchMessageListWithUser.end"); if([messageList count]==0) messageList = nil; return messageList; } //获取某联系人聊天记录 -(NSMutableArray*)fetchBlogMsgListWithUser:(int)pageIndex { NSString* myUserId = MY_USER_ID; if([myUserId length]<=0) return nil; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId]; NSString *queryString=[NSString stringWithFormat:@"select objectId,type,sum(timeLen) from msg_%@ group by objectId,type order by objectId desc limit 0,1",BLOG_CENTER_USERID]; FMResultSet *rs=[db executeQuery:queryString]; NSMutableArray *messageList=[[NSMutableArray alloc]init]; while ([rs next]) { JXMessageObject *p=[[JXMessageObject alloc]init]; [p fromRs:rs]; [messageList addObject:p]; // [p release]; } [rs close]; db = nil; if([messageList count]==0) messageList = nil; return messageList; } // 搜索聊天记录 -(NSArray *)fetchSearchMessageWithUserId:(NSString *)userId String:(NSString *)str { NSString* myUserId = MY_USER_ID; if([myUserId length]<=0) return nil; JXUserObject *user = [[JXUserObject sharedInstance] getUserById:userId]; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId]; NSString *queryString=[NSString stringWithFormat:@"select * from msg_%@ where content like '%%%@%%' and type = 1 and isReadDel != 1 order by timeSend desc",userId, str]; FMResultSet *rs=[db executeQuery:queryString]; NSMutableArray * resultArray = [NSMutableArray array]; while ([rs next]) { JXMessageObject *p=[[JXMessageObject alloc]init]; p.isGroup = [user.roomFlag boolValue]; [p fromRs:rs]; [resultArray addObject:p]; } return resultArray; } -(NSArray *)fetchDelMessageWithUserId:(NSString *)userId { NSString* myUserId = MY_USER_ID; if([myUserId length]<=0) return nil; JXUserObject *user = [[JXUserObject sharedInstance] getUserById:userId]; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId]; NSString *queryString=[NSString stringWithFormat:@"select * from msg_%@ where isReadDel = 1 and fromUserId != %@ order by timeSend desc",userId,myUserId]; FMResultSet *rs=[db executeQuery:queryString]; NSMutableArray * resultArray = [NSMutableArray array]; while ([rs next]) { JXMessageObject *p=[[JXMessageObject alloc]init]; p.isGroup = [user.roomFlag boolValue]; [p fromRs:rs]; [resultArray addObject:p]; } return resultArray; } // 根据content获取最新行 - (int) getLineNumWithUserId:(NSString *)userId { NSString* myUserId = MY_USER_ID; if([myUserId length]<=0) return 0; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId]; NSString *queryString=[NSString stringWithFormat:@"select count(*) num from msg_%@ where timeSend <= %lf and type<>26",userId, [self.timeSend timeIntervalSince1970]]; FMResultSet *rs=[db executeQuery:queryString]; int p = 0; while ([rs next]) { p = [[rs objectForColumnName:@"num"] intValue]; break; } return p; } -(CGPoint)getLocation{ return CGPointMake([location_x floatValue],[location_y floatValue]); } -(BOOL)updateNewMsgsTo0{ FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID]; BOOL worked=[db executeUpdate:[NSString stringWithFormat:@"update friend set newMsgs=0 where userId=?"],[self getTableName]]; return worked; } -(void)notifyNewMsg{ if([self.type intValue] == kWCMessageTypeNone)//如果是被踢出群或解散群时,type为0 return; if([self.type intValue] == kWCMessageTypeGroupActivity)//如果群活动信息,type为2100 return; if([self.type intValue] == kRoomRemind_RoomChangeOpenIntegral)//如果是修改群组显示头衔时,type为2003 return; if([self.type intValue] == kRoomRemind_RoomIsOpenIntegral)//如果是群组显示头衔时,type为2002 return; // NSString* s; // s = [self getTableName]; // BOOL isMeeting = [self.type intValue] == kWCMessageTypeAudioMeetingInvite || [self.type intValue] == kWCMessageTypeVideoMeetingInvite; // if(g_xmpp.newMsgAfterLogin==0 && ![current_chat_userId isEqualToString:s] && self.isVisible && !isMeeting){ //假如不在和目标对象的聊天记录界面里，则延迟统一一次性刷新: // g_xmpp.lastNewMsgTime = [[NSDate date] timeIntervalSince1970]; // [g_xmpp performSelector:@selector(notifyNewMsg) withObject:nil afterDelay:0.7]; //// }else{ // g_xmpp.newMsgAfterLogin++; // [g_notify postNotificationName:kXMPPNewMsgNotifaction object:nil userInfo:nil];//刷新首页 // } if (g_xmpp.msgTimer) { dispatch_cancel(g_xmpp.msgTimer); g_xmpp.msgTimer = nil; g_xmpp.lastMsgTime = 0.00; } dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_HIGH, 0); g_xmpp.msgTimer = dispatch_source_create(DISPATCH_SOURCE_TYPE_TIMER, 0, 0, queue); dispatch_time_t start = DISPATCH_TIME_NOW; dispatch_time_t interval = 0.25 * NSEC_PER_SEC; dispatch_source_set_timer(g_xmpp.msgTimer, start, interval, 0); dispatch_source_set_event_handler(g_xmpp.msgTimer, ^{ g_xmpp.lastMsgTime = g_xmpp.lastMsgTime + 0.25; }); dispatch_resume(g_xmpp.msgTimer); [g_xmpp performSelector:@selector(notifyNewMsg) withObject:nil afterDelay:0.75]; [g_notify postNotificationName:kXMPPNewMsgNotifaction object:self userInfo:nil];//刷新聊天详情页 if ([[UIApplication sharedApplication] applicationState] == UIApplicationStateActive) { }else{//如果程序在后台运行，收到消息以通知类型来显示 UILocalNotification *localNotification = [[UILocalNotification alloc] init]; localNotification.alertAction = @"Ok"; // NSLog(@"%@", self.toUserId); JXUserObject *user; if ([toUserId isEqualToString:MY_USER_ID]) { // 单聊 user = [[JXUserObject sharedInstance] getUserById: self.fromUserId]; }else { // 群聊 user = [[JXUserObject sharedInstance] getUserById: self.toUserId]; } if ([user.offlineNoPushMsg intValue] == 1) { return; } if ([self.fromUserId isEqualToString:@"10000"]){ NSString *msg = [NSString stringWithFormat:@"[%@]",self.fromUserName]; localNotification.alertBody = msg;//通知主体 }else { NSString *msg = [NSString stringWithFormat:@"%@:%@",self.fromUserName,self.getTypeName]; localNotification.alertBody = msg;//通知主体 } // localNotification.soundName = @"newmsg2.mp3";//通知声音 // localNotification.applicationIconBadgeNumber = 1;//标记数 [[UIApplication sharedApplication] presentLocalNotificationNow:localNotification];//发送通知 } } -(void)notifyReceipt{ [g_notify postNotificationName:kXMPPReceiptNotifaction object:self userInfo:nil]; } -(void)notifyReceive{ [g_notify postNotificationName:kXMPPReceiveFileNotifaction object:self userInfo:nil]; } -(void)notifyTimeout{ [g_notify postNotificationName:kXMPPSendTimeOutNotifaction object:self userInfo:nil]; if (self.isGroupSend) { [g_notify postNotificationName:kKeepOnSendGroupSendMessage object:self]; } } -(void)notifyMyLastSend{ [g_notify postNotificationName:kXMPPMyLastSendNotifaction object:self userInfo:nil]; } -(BOOL)getIsGroup{ // return toUserId.length>12 || _isGroup || _roomJid != nil; // return toUserId.length>12 || _isGroup; return _isGroup; } -(int)getMaxWaitTime{ int maxTime = 20;//图片或视频在上传完成之后，才调SendMessage，才开始计时 /* if([self.type intValue] == kWCMessageTypeImage || [self.type intValue] == kWCMessageTypeVideo) maxTime = 60; if([self.type intValue] == kWCMessageTypeVoice){ maxTime = [self.timeLen intValue]; if(maxTime < 20) maxTime = 20; if(maxTime > 60) maxTime = 60; } */ return maxTime; } //-(void)doReceiveRemind{ // if(![self.fromId isEqualToString:REMIND_CENTER_USERID]) // return; // JXRemindObject* p = [[JXRemindObject alloc]init]; // [p fromObject:self]; // [p insert]; // [p notify]; //// [p release]; //} -(void)doReceiveRoomRemind{ if(![self isRoomControlMsg]) return; JXRoomRemind* p = [[JXRoomRemind alloc] init]; [p fromObject:self]; // [p insert]; [p notify]; // [p release]; } -(void)doReceiveNewBlog{ if(![self.fromId isEqualToString:BLOG_CENTER_USERID]) return; if([self.type intValue] != XMPP_TYPE_NEWBLOG) return; JXBlogObject* p = [[JXBlogObject alloc] init]; [p fromObject:self]; [p insert]; // [p release]; } -(BOOL)getIsMySend{ // if(fromId) // return [self.fromId isEqualToString:MY_USER_ID]; // else if (self.changeMySend == 1) { return NO; }else if (self.changeMySend == 2) { return YES; } //此处不能转换成intValue，多点登录userid，无法比较 return [self.fromUserId isEqualToString:MY_USER_ID]; } -(void)setMsgId{ self.messageId = [[[NSUUID UUID].UUIDString stringByReplacingOccurrencesOfString:@"-" withString:@""] lowercaseString]; } -(void)setFileName:(NSString *)value{ if(value == fileName){ return; } // if(value == nil){ // [fileName release]; // } // fileName = [value retain]; fileName = value; if ([type intValue] == kWCMessageTypeRedPacket || [type intValue] == kWCMessageTypeTransfer) { self.fileSize = [NSNumber numberWithInt:1]; return; } if(self.isMySend) self.fileSize = [NSNumber numberWithLongLong:[FileInfo getFileSize:value]]; } -(BOOL)doNewRemindMsg{ NSString* room = self.objectId; if ([self.type intValue] == kRoomRemind_NeedVerify) { SBJsonParser * resultParser = [[SBJsonParser alloc] init] ; NSDictionary *resultObject = [resultParser objectWithString:self.objectId]; if (resultObject) { room = [resultObject objectForKey:@"roomJid"]; } } JXMessageObject* msg = self; // bool是否是直播间 BOOL isLiveMsg = NO; #ifdef Live_Version isLiveMsg = [[JXLiveJidManager shareArray] contains:msg.objectId]; #endif NSString* s=nil;BOOL b=1; JXUserObject* user = [[JXUserObject sharedInstance] getUserById:msg.objectId]; memberData *data = [[memberData alloc] init]; data.roomId = user.roomId; memberData *cardData = [data getCardNameById:msg.fromUserId]; if (cardData.cardName) { msg.fromUserName = cardData.cardName; } switch ([msg.type intValue]) { case kRoomRemind_RoomName: s = [NSString stringWithFormat:@"%@%@%@",msg.fromUserName,Localized(@"JXMessageObject_UpdateRoomName"),msg.content]; break; case kRoomRemind_NickName:{ s = [NSString stringWithFormat:@"%@%@%@",msg.fromUserName,Localized(@"JXMessageObject_UpdateNickName"),msg.content]; [self updateFromUserName]; data.userId = [msg.fromUserId longLongValue]; data.cardName = msg.content; [data updateCardName]; } break; case kRoomRemind_DelRoom: if ([msg.toUserId isEqualToString:MY_USER_ID]) { s = [NSString stringWithFormat:Localized(@"JX_DissolutionGroup"),msg.fromUserName]; }else { s = [NSString stringWithFormat:@"%@%@:%@",msg.fromUserName,Localized(@"JXMessage_delRoom"),msg.content]; } // b = 0;//假如是解散了房间，则不发通知，不显示提醒文字 （现在注释，解散房间后也提醒） // if (![msg.fromUserId isEqualToString:MY_USER_ID]) { // // 删除房间弹框提醒 // [g_App showAlert:[NSString stringWithFormat:@"%@%@",msg.content,Localized(@"JX_DissolutionGroup")]]; // } break; case kRoomRemind_AddMember: if([msg.toUserId isEqualToString:msg.fromUserId] || IS_OTHER_DEVICE(msg.toUserId)) s = [NSString stringWithFormat:@"%@%@",msg.fromUserName,Localized(@"JXMessageObject_GroupChat")]; else s = [NSString stringWithFormat:@"%@%@%@",msg.fromUserName,Localized(@"JXMessageObject_InterFriend"),msg.toUserName]; break; case kLiveRemind_ExitRoom: if([msg.toUserId isEqualToString:msg.fromUserId]){ s = [NSString stringWithFormat:@"%@%@",msg.fromUserName,Localized(@"EXITED_LIVE_ROOM")];//退出 }else{ s = [NSString stringWithFormat:@"%@%@",msg.toUserName,Localized(@"JX_LiveVC_kickLive")];//被踢出 } break; case kRoomRemind_DelMember: if([msg.toUserId isEqualToString:msg.fromUserId]){ if(isLiveMsg){ s = [NSString stringWithFormat:@"%@%@",msg.fromUserName,Localized(@"EXITED_LIVE_ROOM")];//退出 }else{ s = [NSString stringWithFormat:@"%@%@",msg.fromUserName,Localized(@"JXMessageObject_OutGroupChat")]; } }else{ if(isLiveMsg){ s = [NSString stringWithFormat:@"%@%@",msg.toUserName,Localized(@"JX_LiveVC_kickLive")];//被踢出 }else{ if ([msg.toUserId isEqualToString:MY_USER_ID]) { s = [NSString stringWithFormat:Localized(@"JX_OutOfTheGroup"),msg.fromUserName]; }else { if ([msg.fromUserName isEqualToString:msg.toUserName]) { s = [NSString stringWithFormat:@"%@%@",msg.fromUserName,Localized(@"JXRoomMemberVC_OutPutRoom")]; }else { #pragma mark -- 踢人不显示 // s = [NSString stringWithFormat:@"%@%@%@",msg.fromUserName,Localized(@"JXMessageObject_KickOut"),msg.toUserName]; return NO; } } // if (![msg.fromUserId isEqualToString:MY_USER_ID]) { // // 被踢出房间弹框提醒 // [g_App showAlert:[NSString stringWithFormat:@"%@：%@",Localized(@"JX_OutOfTheGroup"),msg.content]]; // } } } // if([self.toUserId isEqualToString:MY_USER_ID])//假如是自己被踢出了房间，则不发通知，不显示提醒文字（现在注释，踢出房间也提醒） // b = 0; break; case kRoomRemind_NewNotice: case kRoomRemind_editNotice: s = [NSString stringWithFormat:@"%@%@%@",msg.fromUserName,Localized(@"JXMessageObject_AddNewAdv"),msg.content]; break; case kLiveRemind_ShatUp: case kRoomRemind_DisableSay:{ if([msg.content longLongValue]==0){ s = [NSString stringWithFormat:@"%@%@%@%@",msg.fromUserName,Localized(@"JXMessageObject_Yes"),msg.toUserName,Localized(@"JXMessageObject_CancelGag")]; }else{ NSDate* d = [NSDate dateWithTimeIntervalSince1970:[msg.content longLongValue]]; NSString* t = [TimeUtil formatDate:d format:@"MM-dd HH:mm"]; s = [NSString stringWithFormat:@"%@%@%@%@%@",msg.fromUserName,Localized(@"JXMessageObject_Yes"),msg.toUserName,Localized(@"JXMessageObject_SetGagWithTime"),t]; d = nil; } break; } case kLiveRemind_SetManager: case kRoomRemind_SetManage:{ if ([msg.content integerValue] == 1) { s = [NSString stringWithFormat:@"%@%@%@%@",Localized(@"JXGroup_Owner"),Localized(@"JXSettingVC_Set"),msg.toUserName,Localized(@"JXMessage_admin")]; }else { s = [NSString stringWithFormat:@"%@%@%@",Localized(@"JXGroup_Owner"),Localized(@"CANCEL_ADMINISTRATOR"),msg.toUserName]; } break; } case kRoomRemind_EnterLiveRoom:{ s = [NSString stringWithFormat:@"%@%@",msg.toUserName,Localized(@"Enter_LiveRoom")];//加入房间消息 break; } case kRoomRemind_ShowRead:{ if ([msg.content integerValue] == 1) s = [NSString stringWithFormat:@"%@%@%@",Localized(@"JXGroup_Owner"),Localized(@"JX_Enable"),Localized(@"JX_RoomReadMode")]; else s = [NSString stringWithFormat:@"%@%@%@",Localized(@"JXGroup_Owner"),Localized(@"JX_Disable"),Localized(@"JX_RoomReadMode")]; break; } case kRoomRemind_NeedVerify:{ if (!msg.content || msg.content.length <= 0) { SBJsonParser * resultParser = [[SBJsonParser alloc] init] ; NSDictionary *resultObject = [resultParser objectWithString:self.objectId]; NSString *userIdStr = [resultObject objectForKey:@"userIds"]; BOOL isInvite = [[resultObject objectForKey:@"isInvite"] boolValue]; if (isInvite) { s = [NSString stringWithFormat:@"%@%@",msg.fromUserName,Localized(@"JX_JoinTheGroupToConfirm")]; }else { NSArray *userIds = [userIdStr componentsSeparatedByString:@","]; s = [NSString stringWithFormat:@"\"%@\"%@%ld%@",self.fromUserName,Localized(@"JX_WouldLikeToInvite"),userIds.count,Localized(@"JX_JoinGroupToConfirm")]; } }else { if ([msg.content integerValue] == 1) s = Localized(@"JX_GroupOwnersOpenValidation"); else s = Localized(@"JX_GroupOwnersCloseValidation"); } break; } case kRoomRemind_IsLook:{ if ([msg.content integerValue] == 0) s = Localized(@"JX_GroupOwnersPublicGroup"); else s = Localized(@"JX_GroupOwnersPrivateGroup"); break; } case kRoomRemind_ShowMember:{ if ([msg.content integerValue] == 1) s = Localized(@"JX_GroupOwnersShowMembers"); else s = Localized(@"JX_GroupOwnersNotShowMembers"); break; } case kRoomRemind_allowSendCard:{ if ([msg.content integerValue] == 1) s = Localized(@"JX_ManagerOpenChat"); else s = Localized(@"JX_ManagerOffChat"); break; } case kRoomRemind_RoomAllBanned:{ if ([msg.content integerValue] > 0) s = Localized(@"JX_ManagerOpenSilence"); else s = Localized(@"JX_ManagerOffSilence"); break; } case kRoomRemind_RoomAllowInviteFriend:{ if ([msg.content integerValue] > 0) s = Localized(@"JX_ManagerOpenInviteFriends"); else s = Localized(@"JX_ManagerOffInviteFriends"); break; } case kRoomRemind_RoomAllowUploadFile:{ if ([msg.content integerValue] > 0) s = Localized(@"JX_ManagerOpenSharedFiles"); else s = Localized(@"JX_ManagerOffSharedFiles"); break; } case kRoomRemind_RoomAllowConference:{ if ([msg.content integerValue] > 0) s = Localized(@"JX_ManagerOpenMeetings"); else s = Localized(@"JX_ManagerOffMeetings"); break; } case kRoomRemind_RoomAllowSpeakCourse:{ if ([msg.content integerValue] > 0) s = Localized(@"JX_ManagerOpenLectures"); else s = Localized(@"JX_ManagerOffLectures"); break; } case kRoomRemind_RoomTransfer:{ s = [NSString stringWithFormat:@"\"%@\"%@", msg.toUserName,Localized(@"JX_NewGroupManager")]; break; } case kRoomRemind_SetInvisible:{ // 自己设置隐身人 和 别人设置自己为隐身人显示 if ([msg.toUserId isEqualToString:g_myself.userId] || [msg.fromUserId isEqualToString:g_myself.userId]){ if ([msg.content integerValue] == 1) { s = [NSString stringWithFormat:@"%@%@%@%@",msg.fromUserName,Localized(@"JXSettingVC_Set"),msg.toUserName,Localized(@"JX_ForTheInvisibleMan")]; }else if ([msg.content integerValue] == -1){ s = [NSString stringWithFormat:@"%@%@%@",msg.fromUserName,Localized(@"JX_EliminateTheInvisible"),msg.toUserName]; }else if ([msg.content integerValue] == 2){ s = [NSString stringWithFormat:@"%@%@%@%@",msg.fromUserName,Localized(@"JXSettingVC_Set"),msg.toUserName,@"为监控人"]; }else if ([msg.content integerValue] == 0){ s = [NSString stringWithFormat:@"%@%@%@",msg.fromUserName,@"取消监控人",msg.toUserName]; } break; }else { if ([msg.content integerValue] == 1) { // s = [NSString stringWithFormat:@"%@%@%@%@",msg.fromUserName,Localized(@"JXSettingVC_Set"),msg.toUserName,Localized(@"JX_ForTheInvisibleMan")]; return NO; }else if ([msg.content integerValue] == -1){ // s = [NSString stringWithFormat:@"%@%@%@",msg.fromUserName,Localized(@"JX_EliminateTheInvisible"),msg.toUserName]; return NO; }else if ([msg.content integerValue] == 2){ // s = [NSString stringWithFormat:@"%@%@%@%@",msg.fromUserName,Localized(@"JXSettingVC_Set"),msg.toUserName,@"为监控人"]; return NO; }else if ([msg.content integerValue] == 0){ // s = [NSString stringWithFormat:@"%@%@%@",msg.fromUserName,@"取消监控人",msg.toUserName]; return NO; } break; } } case kRoomRemind_RoomDisable:{ if ([msg.content integerValue] == 1) { s = [NSString stringWithFormat:@"%@",Localized(@"JX_ThisGroupHasBeenDisabled")]; }else { s = [NSString stringWithFormat:@"%@",Localized(@"JX_GroupNotUse")]; } break; } case kRoomRemind_SetRecordTimeOut:{ NSArray *pickerArr = @[Localized(@"JX_Forever"), Localized(@"JX_OneHour"), Localized(@"JX_OneDay"), Localized(@"JX_OneWeeks"), Localized(@"JX_OneMonth"), Localized(@"JX_OneQuarter"), Localized(@"JX_OneYear")]; double outTime = [msg.content doubleValue]; NSString *str; if (outTime <= 0) { str = pickerArr[0]; }else if (outTime == 0.04) { str = pickerArr[1]; }else if (outTime == 1) { str = pickerArr[2]; }else if (outTime == 7) { str = pickerArr[3]; }else if (outTime == 30) { str = pickerArr[4]; }else if (outTime == 90) { str = pickerArr[5]; }else{ str = pickerArr[6]; } s = [NSString stringWithFormat:@"%@%@",Localized(@"JX_GroupManagerSetMsgDelTime"),str]; } } if(b) msg.type = [NSNumber numberWithInt:kWCMessageTypeRemind]; else msg.type = [NSNumber numberWithInt:kWCMessageTypeNone]; msg.fromId = nil; msg.toId = nil; msg.fromUserId = msg.fromUserId; msg.toUserId = room; msg.content = s; if ([msg haveTheMessage]) { return NO; } return b; } -(void)copy:(JXMessageObject*)p{ self.messageNo = p.messageNo;//序列号，数值型 self.type = p.type;//消息类型 self.messageId = p.messageId;//消息标识号，字符串 self.fromId = p.fromId;//源 self.toId = p.toId;//目标 self.fromUserName = p.fromUserName;//源 self.fromUserId = p.fromUserId;//源 self.toUserId = p.toUserId;//目标 self.toUserName = p.toUserName;//目标 self.content = p.content;//内容 self.fileName = p.fileName;//文件名 self.objectId = p.objectId;//对象ID self.fileSize = p.fileSize;//文件尺寸 self.timeLen = p.timeLen;//录音时长 self.isSend = p.isSend;//是否已送达 self.isRead = p.isRead;//是否已读 self.isReceive = p.isReceive;//是否下载 self.isUpload = p.isUpload;//是否上传完成 self.location_x = p.location_x;//位置经度 self.location_y = p.location_y;//位置纬度 self.timeSend = p.timeSend;//发送的时间 self.deleteTime = p.deleteTime; // 消息过期时间 self.timeReceive = p.timeReceive;//收到回执的时间 self.fileData = p.fileData;//文件内容 self.isMySend = p.isMySend;//是否是自己发送 self.isGroup = p.isGroup;//是否群聊 self.isReadDel = p.isReadDel;//是否阅后即焚 self.readTime = p.readTime; // 已读时间 self.readPersons = p.readPersons; // 已读人数 self.chatMsgHeight = p.chatMsgHeight; // 聊天消息行高 self.isShowTime = p.isShowTime; self.signature = p.signature; self.isVerifySignatureFailed = p.isVerifySignatureFailed; } +(void)msgWithFriendStatus:(NSString*)userId status:(int)status{ JXMessageObject *msg=[[JXMessageObject alloc] init]; BOOL isRoom = [userId length]>15; int n = kWCMessageTypeRemind; NSString* s=nil; switch (status) { case friend_status_black: if(isRoom) s = Localized(@"JXMessageObject_ShieldMessage"); else s = Localized(@"JXMessageObject_AddBlack"); break; case friend_status_none: s = Localized(@"JXMessageObject_NotFriend"); break; case friend_status_see: s = Localized(@"JXMessageObject_FollowHim"); break; case friend_status_friend: if(isRoom) s = Localized(@"JXMessageObject_ReceMessage"); else{ // s = Localized(@"JXFriendObject_StartChat"); // n = kWCMessageTypeText; s = Localized(@"JXMessageObject_BeFriendAndChat"); } break; } msg.type = [NSNumber numberWithInt:n]; msg.toUserId = userId; msg.fromUserId = MY_USER_ID; msg.fromUserName = MY_USER_NAME; msg.content = s; msg.timeSend = [NSDate date]; [msg insert:nil]; [msg updateLastSend:UpdateLastSendType_None]; [msg notifyNewMsg]; } -(NSString*)getContentValue:(NSString*)key{ SBJsonParser * resultParser = [[SBJsonParser alloc] init]; NSDictionary* resultObject = [resultParser objectWithString:self.content]; // [resultParser release]; return [resultObject objectForKey:key]; } -(NSString*)getContentValue:(NSString*)key subKey:(NSString*)subKey{ SBJsonParser * resultParser = [[SBJsonParser alloc] init]; NSDictionary* resultObject = [resultParser objectWithString:self.content]; // [resultParser release]; return [(NSDictionary *)[resultObject objectForKey:key] objectForKey:subKey]; } -(NSString*)getContentValue:(NSString*)key index:(int)i{ SBJsonParser * resultParser = [[SBJsonParser alloc] init]; NSDictionary* resultObject = [resultParser objectWithString:self.content]; // [resultParser release]; return [[resultObject objectForKey:key] objectAtIndex:i]; } //-(void)downloadFile:(JXImageView*)iv{ // if([content length]<=0) // return; // if(self.isMySend && [[NSFileManager defaultManager] fileExistsAtPath:fileName] ){//如本地文件存在 // if([[fileName pathExtension] isEqualToString:@"jpg"] && iv!=nil){ // UIImage* p = [[UIImage alloc] initWithContentsOfFile:fileName]; // iv.image = p; // } // return; // } // // NSString* ext = [[content lastPathComponent] pathExtension]; // NSString *filepath = [myTempFilePath stringByAppendingPathComponent:[content lastPathComponent]]; // // if( ![[NSFileManager defaultManager] fileExistsAtPath:filepath]){ // [g_server addTask:content param:iv toView:self]; // } // else{ // if([ext isEqualToString:@"jpg"] && iv!=nil){ // UIImage* p = [[UIImage alloc] initWithContentsOfFile:filepath]; // iv.image = p; // } // [self doSaveOK]; // } // // filepath = nil; // ext = nil; //} - (void)didServerResultSucces:(JXConnection *)task dict:(NSDictionary *)dict array:(NSArray *)array1{ [self doSaveOK]; } -(int) didServerResultFailed:(JXConnection*)aDownload dict:(NSDictionary*)dict{ [self doSaveError]; return hide_error; } -(int) didServerConnectError:(JXConnection*)aDownload error:(NSError *)error{ [self doSaveError]; return hide_error; } -(void) didServerConnectStart:(JXConnection*)aDownload{ } -(void)doSaveError{ NSLog(@"http失败"); [self updateIsReceive:transfer_status_no]; [g_notify postNotificationName:kMsgDrawIsReceiveNotifaction object:self]; } -(void)doSaveOK{ self.fileName = [myTempFilePath stringByAppendingPathComponent:[content lastPathComponent]]; [self updateIsReceive:transfer_status_yes]; [g_notify postNotificationName:kMsgDrawIsReceiveNotifaction object:self]; } -(void)sendAlreadyReadMsg{//发送“已读”消息 if(![self.isSend boolValue])//消息未送达，不发 return; if(self.isGroup && !self.showRead)//单聊消息，未@我，showRead为假，均不发；语音消息，发 return; if(![self isVisible]) return; if ([self.isRead intValue] == 0 && !self.isMySend){//未读并且不是我发送的 if(self.messageId==nil) [self setMsgId]; JXMessageObject * p = [[JXMessageObject alloc]init]; NSString* room=nil; p.content = self.messageId; p.type = [NSNumber numberWithInt:kWCMessageTypeIsRead]; if(self.isGroup){ p.toUserId = self.toUserId; room = p.toUserId; } else p.toUserId = self.fromUserId; p.fromUserId = MY_USER_ID; p.fromUserName = MY_USER_NAME; p.isRead = [NSNumber numberWithInt:1]; p.timeSend = [NSDate date]; p.sendCount = 10; p.isGroup = self.isGroup; //获取msgID [p setMsgId]; [p insert:nil]; [g_xmpp sendMessage:p roomName:room]; } } // 更新消息 -(BOOL)update{ NSString* myUserId = MY_USER_ID; if([myUserId length]<=0) return NO; NSString *content = self.content; #ifdef IS_MsgEncrypt // if (!self.isGroup) { content = [g_msgUtil encryptInsertChatMsgContent:self.content msgId:self.messageId]; // } #endif FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId]; NSString *sql=[NSString stringWithFormat:@"update msg_%@ set content=?,type=? where messageId=?",[self getTableName]]; BOOL worked=[db executeUpdate:sql,content, self.type, self.messageId]; // FMDBQuickCheck(worked); db = nil; [g_App copyDbWithUserId:MY_USER_ID]; return worked; } -(BOOL)queryIsRead{ FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID]; NSString* sql= [NSString stringWithFormat:@"select isRead from msg_%@ where messageId=?",[self getTableName]]; FMResultSet *rs=[db executeQuery:sql,self.messageId]; while ([rs next]) { return [[rs objectForColumnName:kMESSAGE_ISREAD] boolValue]; } return NO; } -(NSTimeInterval)queryReadTime{ FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID]; NSString* sql= [NSString stringWithFormat:@"select readTime from msg_%@ where messageId=?",[self getTableName]]; FMResultSet *rs=[db executeQuery:sql,self.messageId]; while ([rs next]) { return [[rs objectForColumnName:kMESSAGE_readTime] doubleValue]; } return 0; } -(void)doGroupFileMsg{ NSString* room = self.objectId; JXMessageObject* msg = self; NSString* s=nil; switch ([msg.type intValue]) { case kWCMessageTypeGroupFileUpload: s = [NSString stringWithFormat:@"%@%@:%@",msg.fromUserName,Localized(@"JXMessage_fileUpload"),msg.fileName]; break; case kWCMessageTypeGroupFileDelete: s = [NSString stringWithFormat:@"%@%@:%@",msg.fromUserName,Localized(@"JXMessage_fileDelete"),msg.fileName]; break; case kWCMessageTypeGroupFileDownload: s = [NSString stringWithFormat:@"%@%@:%@",msg.fromUserName,Localized(@"JXMessage_fileDownload"),msg.fileName]; break; default: break; } msg.type = [NSNumber numberWithInt:kWCMessageTypeRemind]; msg.fromId = nil; msg.toId = nil; msg.fromUserId = msg.fromUserId; msg.toUserId = room; msg.content = s; if ([msg insert:room]){ [msg updateLastSend:UpdateLastSendType_Add]; }else { msg.isRepeat = YES; } [msg notifyNewMsg]; } -(void)changeVideoChatContent{//改变音视频通话消息的content if(([type intValue]<100 || [type intValue]>120) && [type intValue] != kWCMessageTypeAVBusy) return; switch ([type intValue]) { //以下不可见消息，不需要赋值 case kWCMessageTypeAudioChatAsk: content = [NSString stringWithFormat:@"%@%@",Localized(@"JXSip_invite"),Localized(@"JXSip_Audiocall")]; break; case kWCMessageTypeVideoChatAsk: content = [NSString stringWithFormat:@"%@%@",Localized(@"JXSip_invite"),Localized(@"JXSip_Videocall")]; break; case kWCMessageTypeAudioChatReady: content = [NSString stringWithFormat:@"%@%@",Localized(@"JXSip_ready"),Localized(@"JXSip_Audiocall")]; break; case kWCMessageTypeVideoChatReady: content = [NSString stringWithFormat:@"%@%@",Localized(@"JXSip_ready"),Localized(@"JXSip_Videocall")]; break; case kWCMessageTypeAudioChatAccept: content = [NSString stringWithFormat:@"%@%@",Localized(@"JXSip_Accepted"),Localized(@"JXSip_Audiocall")]; break; case kWCMessageTypeVideoChatAccept: content = [NSString stringWithFormat:@"%@%@",Localized(@"JXSip_Accepted"),Localized(@"JXSip_Videocall")]; break; //以上不可见消息，不需要赋值 case kWCMessageTypeAudioChatCancel: if([timeLen intValue]>0){ content = [NSString stringWithFormat:@"%@",@"对方无应答"]; } // else if([timeLen intValue]>0&&[timeLen intValue]<31){ // content = self.isMySend ? Localized(@"JX_MeetingHangUpToMe") : Localized(@"JXSip_noanswer"); } else{ content = [NSString stringWithFormat:@"%@%@",Localized(@"JXSip_Canceled"),Localized(@"JXSip_Audiocall")]; } break; case kWCMessageTypeVideoChatCancel: if([timeLen intValue]>0) content = self.isMySend ? Localized(@"JX_MeetingHangUpToMe") : Localized(@"JXSip_noanswer"); else content = [NSString stringWithFormat:@"%@%@",Localized(@"JXSip_Canceled"),Localized(@"JXSip_Videocall")]; break; case kWCMessageTypeAudioChatEnd:{ NSString *timeLenStr = [TimeUtil getTimeShort1:[timeLen longLongValue]]; content = [NSString stringWithFormat:@"%@%@,%@:%@",Localized(@"JXSip_finished"),Localized(@"JXSip_Audiocall"),Localized(@"JXSip_timeLenth"),timeLenStr]; } break; case kWCMessageTypeVideoChatEnd:{ NSString *timeLenStr = [TimeUtil getTimeShort1:[timeLen longLongValue]]; content = [NSString stringWithFormat:@"%@%@,%@:%@",Localized(@"JXSip_finished"),Localized(@"JXSip_Videocall"),Localized(@"JXSip_timeLenth"),timeLenStr]; } break; case kWCMessageTypeAudioMeetingInvite: content = Localized(@"JXMeeting_InviteAudioMeeting"); break; case kWCMessageTypeVideoMeetingInvite: content = Localized(@"JXMeeting_InviteVideoMeeting"); break; case kWCMessageTypeAVBusy:{ if ([self.fromUserId isEqualToString:MY_USER_ID]) { self.fromUserId = [self.toUserId copy]; self.toUserId = MY_USER_ID; content = @"忙线未接听"; }else { self.toUserId = [self.fromUserId copy]; self.fromUserId = MY_USER_ID; content = @"对方忙线中"; } } break; } } -(BOOL)isVisible{//如果为NO则不发送已读消息，且不更新最近聊天内容字段，且发通知和可见消息分开，走另一通知 switch ([self.type intValue]) { case kWCMessageTypeNone: case kWCMessageTypeIsRead: case kWCMessageTypeAudioChatAsk: case kWCMessageTypeAudioChatReady: case kWCMessageTypeAudioChatAccept: case kWCMessageTypeVideoChatAsk: case kWCMessageTypeVideoChatReady: case kWCMessageTypeVideoChatAccept: case kWCMessageTypeRelay: case kWCMessageTypeAudioMeetingInvite: case kWCMessageTypeVideoMeetingInvite: case kWCMessageTypeTalkInvite: case kWCMessageTypeTalkJoin: case kWCMessageTypeTalkQuit: case kWCMessageTypeAudioMeetingSetSpeaker: case kWCMessageTypeAudioMeetingAllSpeaker: case kWCMessageTypeTalkOnline: case kWCMessageTypeTalkOut: case kWCMessageTypeDelMsgTwoSides: // case kWCMessageTypeWithdraw: return NO; case kWCMessageTypeAudioChatCancel: case kWCMessageTypeAudioChatEnd: case kWCMessageTypeVideoChatCancel: case kWCMessageTypeVideoChatEnd: case kWCMessageTypeWithdraw: case kWCMessageTypeSuperDelete: case kWCMessageTypeAVBusy: return YES; default: return [self.type intValue]<100; } } -(BOOL)isPinbaMsg{ switch ([self.type intValue]) { // case kWCMessageTypeEnterpriseJob: case kWCMessageTypePersonJob: // case kWCMessageTypeResume: case kWCMessageTypePhoneAsk: case kWCMessageTypePhoneAnswer: case kWCMessageTypeResumeAsk: case kWCMessageTypeResumeAnswer: case kWCMessageTypeExamSend: case kWCMessageTypeExamAccept: case kWCMessageTypeExamEnd: return YES; break; default: return NO; } } -(BOOL)isRoomControlMsg{//房间控制消息 return [self.type intValue]/100==9; // switch ([self.type intValue]) { // case kRoomRemind_RoomName: // case kRoomRemind_NickName: // case kRoomRemind_DelRoom: // case kRoomRemind_DelMember: // case kRoomRemind_NewNotice: // case kRoomRemind_DisableSay: // case kRoomRemind_AddMember: // case kRoomRemind_LiveBarrage: // case kRoomRemind_LiveGift: // case kRoomRemind_LivePraise: // case kRoomRemind_SetManage: // case kRoomRemind_EnterLiveRoom: // case kRoomRemind_ShowRead: // return YES; // break; // default: // return NO; // } } -(BOOL)isAudioMeetingMsg{//语音会议消息 switch ([self.type intValue]) { case kWCMessageTypeAudioMeetingInvite: case kWCMessageTypeAudioMeetingJoin: case kWCMessageTypeAudioMeetingQuit: // case kWCMessageTypeAudioMeetingKick: // case kWCMessageTypeAudioMeetingSetSpeaker: // case kWCMessageTypeAudioMeetingAllSpeaker: return YES; break; default: return NO; } } -(BOOL)isAddFriendMsg{ return [self.type intValue]/100==5; } // 获取已读列表 - (NSMutableArray *)fetchReadList { NSString* myUserId = MY_USER_ID; if([myUserId length]<=0) return nil; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId]; NSMutableArray *messageList=[[NSMutableArray alloc]init]; NSString *queryString = nil; NSString *messageId = self.messageId; #ifdef IS_MsgEncrypt // if (!self.isGroup) { messageId = [g_msgUtil encryptInsertChatMsgContent:self.messageId msgId:self.messageId]; // } #endif queryString = [NSString stringWithFormat:@"select * from msg_%@ where content=?",[self getTableName]]; FMResultSet *rs=[db executeQuery:queryString,messageId]; while ([rs next]) { JXUserObject *user = [[JXUserObject alloc] init]; user.userId = [rs objectForColumnName:kMESSAGE_FROM]; user.userNickname = [rs objectForColumnName:kMESSAGE_FROM_NAME]; user.timeSend = [rs dateForColumn:kMESSAGE_TIMESEND]; [messageList addObject:user]; } [rs close]; db = nil; return messageList; } -(void)getHistory:(NSArray*)array userId:(NSString*)userId{//获取聊天历史记录 for (NSInteger i = 0; i < array.count; i ++) { NSDictionary *dict = array[i]; NSString *jsonMsg = dict[@"message"]; SBJsonParser * resultParser = [[SBJsonParser alloc] init] ; NSDictionary *jsonDic = [resultParser objectWithString:jsonMsg]; JXMessageObject *msg = [[JXMessageObject alloc] init]; [msg fromDictionary:jsonDic]; if ([msg.type isEqual: @2100]) { NSString *str = jsonDic[@"content"]; JLGroupActivityModel *model = [JLGroupActivityModel mj_objectWithKeyValues:str]; model.roomJid = userId; if (model.type == 2) { msg.type = @1; msg.content = model.content; msg.toUserId = model.roomJid; } } msg.timeSend = [NSDate dateWithTimeIntervalSince1970:[[jsonDic objectForKey:kMESSAGE_TIMESEND] doubleValue] / 1000.0]; msg.messageId = [(NSDictionary *)[jsonDic objectForKey:@"messageHead"] objectForKey:@"messageId"]; // if([userId length]>15){ // [msg fromDictionary:jsonDic]; // msg.isGroup = YES; // } // else // [msg fromXmlDict:jsonDic]; [self setRemindMsg:msg]; msg.toUserId = userId; // if(![msg isVisible] && [msg.type intValue]!=kWCMessageTypeIsRead) // continue; //调整是不是自己发的 if ([msg.fromUserId isEqualToString:MY_USER_ID]) msg.isMySend = YES; if (jsonDic[@"isRead"] && msg.isMySend) { msg.isRead = jsonDic[@"isRead"]; }else { msg.isRead = [NSNumber numberWithInt:1]; } msg.updateLastContent = 0;//临时不更新的标志 [msg insert:userId]; msg.updateLastContent = 1;//恢复 // msg.chatMsgHeight = [NSString stringWithFormat:@"%f",[self getMsgChatHeight:msg]]; // [msg updateChatMsgHeight]; } } - (void)setRemindMsg:(JXMessageObject *)msg { NSString *content; NSString *fromUserId = msg.fromUserId; NSString *fromUserName = msg.fromUserName; if (!fromUserName) { fromUserName = @""; } NSString *toUserId = msg.toUserId; NSString *toUserName = msg.toUserName; if (IsStringNull(toUserName)) { toUserName = @""; } switch ([msg.type integerValue]) { case kWCMessageTypeWithdraw:{ if (msg.isGroup) { if ([fromUserId isEqualToString:MY_USER_ID]) { content = Localized(@"JX_AlreadyWithdraw"); }else { content = [NSString stringWithFormat:@"%@ %@",fromUserName, Localized(@"JX_OtherWithdraw")]; } }else { if ([fromUserId isEqualToString:MY_USER_ID]) { content = Localized(@"JX_AlreadyWithdraw"); }else { content = [NSString stringWithFormat:@"%@ %@",fromUserName, Localized(@"JX_OtherWithdraw")]; } } } break; case kWCMessageTypeRedPacketReceive: if (![fromUserId isEqualToString:MY_USER_ID]) { content = [NSString stringWithFormat:@"%@%@",fromUserName,Localized(@"JXRed_whoGet")]; }else { content = [NSString stringWithFormat:Localized(@"JX_GetRedPacketFromFriend"),toUserName]; } break; case kWCMessageTypeRedPacketReturn: content = [NSString stringWithFormat:@"%@",Localized(@"JX_ RedEnvelopeExpired")]; break; case kWCMessageTypeGroupFileUpload: content = [NSString stringWithFormat:@"%@%@:%@",msg.fromUserName,Localized(@"JXMessage_fileUpload"),msg.fileName]; // content = [NSString stringWithFormat:@"%@%@",fromUserName,Localized(@"JXMessage_fileUpload")]; break; case kWCMessageTypeGroupFileDelete: content = [NSString stringWithFormat:@"%@%@:%@",msg.fromUserName,Localized(@"JXMessage_fileDelete"),msg.fileName]; // content = [NSString stringWithFormat:@"%@%@",fromUserName,Localized(@"JXMessage_fileDelete")]; break; case kWCMessageTypeGroupFileDownload: content = [NSString stringWithFormat:@"%@%@:%@",msg.fromUserName,Localized(@"JXMessage_fileDownload"),msg.fileName]; // content = [NSString stringWithFormat:@"%@%@",fromUserName,Localized(@"JXMessage_fileDownload")]; break; case kRoomRemind_RoomName: content = [NSString stringWithFormat:@"%@%@%@",fromUserName,Localized(@"JXMessageObject_UpdateRoomName"),msg.content]; break; case kRoomRemind_NickName:{ content = [NSString stringWithFormat:@"%@%@%@",fromUserName,Localized(@"JXMessageObject_UpdateNickName"),msg.content]; } break; case kRoomRemind_DelRoom: if ([toUserId isEqualToString:MY_USER_ID]) { content = [NSString stringWithFormat:Localized(@"JX_DissolutionGroup"),fromUserName]; }else { content = [NSString stringWithFormat:@"%@%@:%@",fromUserName,Localized(@"JXMessage_delRoom"),msg.content]; } break; case kRoomRemind_AddMember: if([toUserId isEqualToString:fromUserId] || IS_OTHER_DEVICE(toUserId) || IS_OTHER_DEVICE(fromUserId)) content = [NSString stringWithFormat:@"%@%@",fromUserName,Localized(@"JXMessageObject_GroupChat")]; else content = [NSString stringWithFormat:@"%@%@%@",fromUserName,Localized(@"JXMessageObject_InterFriend"),toUserName]; break; case kLiveRemind_ExitRoom: if([toUserId isEqualToString:fromUserId]){ content = [NSString stringWithFormat:@"%@%@",fromUserName,Localized(@"EXITED_LIVE_ROOM")];//退出 }else{ content = [NSString stringWithFormat:@"%@%@",toUserName,Localized(@"JX_LiveVC_kickLive")];//被踢出 } break; case kRoomRemind_DelMember: if([toUserId isEqualToString:fromUserId]){ content = [NSString stringWithFormat:@"%@%@",fromUserName,Localized(@"JXMessageObject_OutGroupChat")]; }else{ if ([toUserId isEqualToString:MY_USER_ID]) { content = [NSString stringWithFormat:Localized(@"JX_OutOfTheGroup"),fromUserName]; }else { if ([fromUserName isEqualToString:toUserName]) { content = [NSString stringWithFormat:@"%@%@",fromUserName,Localized(@"JXRoomMemberVC_OutPutRoom")]; }else { content = [NSString stringWithFormat:@"%@%@%@",fromUserName,Localized(@"JXMessageObject_KickOut"),toUserName]; } } } break; case kRoomRemind_NewNotice: case kRoomRemind_editNotice: content = [NSString stringWithFormat:@"%@%@%@",fromUserName,Localized(@"JXMessageObject_AddNewAdv"),msg.content]; break; case kLiveRemind_ShatUp: case kRoomRemind_DisableSay:{ if([msg.content longLongValue]==0){ content = [NSString stringWithFormat:@"%@%@%@%@",fromUserName,Localized(@"JXMessageObject_Yes"),toUserName,Localized(@"JXMessageObject_CancelGag")]; }else{ NSDate* d = [NSDate dateWithTimeIntervalSince1970:[msg.content longLongValue]]; NSString* t = [TimeUtil formatDate:d format:@"MM-dd HH:mm"]; content = [NSString stringWithFormat:@"%@%@%@%@%@",fromUserName,Localized(@"JXMessageObject_Yes"),toUserName,Localized(@"JXMessageObject_SetGagWithTime"),t]; d = nil; } break; } case kLiveRemind_SetManager: case kRoomRemind_SetManage:{ if ([msg.content integerValue] == 1) { content = [NSString stringWithFormat:@"%@%@%@%@",Localized(@"JXGroup_Owner"),Localized(@"JXSettingVC_Set"),toUserName,Localized(@"JXMessage_admin")]; }else { content = [NSString stringWithFormat:@"%@%@%@",Localized(@"JXGroup_Owner"),Localized(@"CANCEL_ADMINISTRATOR"),toUserName]; } break; } case kRoomRemind_EnterLiveRoom:{ content = [NSString stringWithFormat:@"%@%@",toUserName,Localized(@"Enter_LiveRoom")];//加入房间消息 break; } case kRoomRemind_ShowRead:{ if ([msg.content integerValue] == 1) content = [NSString stringWithFormat:@"%@%@%@",Localized(@"JXGroup_Owner"),Localized(@"JX_Enable"),Localized(@"JX_RoomReadMode")]; else content = [NSString stringWithFormat:@"%@%@%@",Localized(@"JXGroup_Owner"),Localized(@"JX_Disable"),Localized(@"JX_RoomReadMode")]; break; } case kRoomRemind_NeedVerify:{ if (!msg.content || msg.content.length <= 0) { content = Localized(@"JX_GroupInvitationConfirmation"); }else { if ([msg.content integerValue] == 1) content = Localized(@"JX_GroupOwnersOpenValidation"); else content = Localized(@"JX_GroupOwnersCloseValidation"); } break; } case kRoomRemind_IsLook:{ if ([msg.content integerValue] == 0) content = Localized(@"JX_GroupOwnersPublicGroup"); else content = Localized(@"JX_GroupOwnersPrivateGroup"); break; } case kRoomRemind_ShowMember:{ if ([msg.content integerValue] == 1) content = Localized(@"JX_GroupOwnersShowMembers"); else content = Localized(@"JX_GroupOwnersNotShowMembers"); break; } case kRoomRemind_allowSendCard:{ if ([msg.content integerValue] == 1) content = Localized(@"JX_ManagerOpenChat"); else content = Localized(@"JX_ManagerOffChat"); break; } case kRoomRemind_RoomAllBanned:{ if ([msg.content integerValue] > 0) content = Localized(@"JX_ManagerOpenSilence"); else content = Localized(@"JX_ManagerOffSilence"); break; } case kRoomRemind_RoomAllowInviteFriend:{ if ([msg.content integerValue] > 0) content = Localized(@"JX_ManagerOpenInviteFriends"); else content = Localized(@"JX_ManagerOffInviteFriends"); break; } case kRoomRemind_RoomAllowUploadFile:{ if ([msg.content integerValue] > 0) content = Localized(@"JX_ManagerOpenSharedFiles"); else content = Localized(@"JX_ManagerOffSharedFiles"); break; } case kRoomRemind_RoomAllowConference:{ if ([msg.content integerValue] > 0) content = Localized(@"JX_ManagerOpenMeetings"); else content = Localized(@"JX_ManagerOffMeetings"); break; } case kRoomRemind_RoomAllowSpeakCourse:{ if ([msg.content integerValue] > 0) content = Localized(@"JX_ManagerOpenLectures"); else content = Localized(@"JX_ManagerOffLectures"); break; } case kRoomRemind_RoomTransfer:{ content = [NSString stringWithFormat:@"\"%@\"%@", toUserName,Localized(@"JX_NewGroupManager")]; break; } case kRoomRemind_SetInvisible:{ // 自己设置隐身人 和 别人设置自己为隐身人显示 if ([msg.toUserId isEqualToString:g_myself.userId] || [msg.fromUserId isEqualToString:g_myself.userId]) { if ([msg.content integerValue] == 1) { content = [NSString stringWithFormat:@"%@%@%@%@",fromUserName,Localized(@"JXSettingVC_Set"),toUserName,Localized(@"JX_ForTheInvisibleMan")]; }else if ([msg.content integerValue] == -1){ content = [NSString stringWithFormat:@"%@%@%@",fromUserName,Localized(@"JX_EliminateTheInvisible"),toUserName]; }else if ([msg.content integerValue] == 2){ content = [NSString stringWithFormat:@"%@%@%@%@",fromUserName,Localized(@"JXSettingVC_Set"),toUserName,@"为监控人"]; }else if ([msg.content integerValue] == 0){ content = [NSString stringWithFormat:@"%@%@%@",fromUserName,@"取消监控人",toUserName]; } break; }else { if ([msg.content integerValue] == 1) { // content = [NSString stringWithFormat:@"%@%@%@%@",fromUserName,Localized(@"JXSettingVC_Set"),toUserName,Localized(@"JX_ForTheInvisibleMan")]; return; }else if ([msg.content integerValue] == -1){ // content = [NSString stringWithFormat:@"%@%@%@",fromUserName,Localized(@"JX_EliminateTheInvisible"),toUserName]; return; }else if ([msg.content integerValue] == 2){ // content = [NSString stringWithFormat:@"%@%@%@%@",fromUserName,Localized(@"JXSettingVC_Set"),toUserName,@"为监控人"]; return; }else if ([msg.content integerValue] == 0){ // content = [NSString stringWithFormat:@"%@%@%@",fromUserName,@"取消监控人",toUserName]; return; } break; } } case kRoomRemind_RoomDisable:{ if ([msg.content integerValue] == 1) { content = [NSString stringWithFormat:@"%@",Localized(@"JX_ThisGroupHasBeenDisabled")]; }else { content = [NSString stringWithFormat:@"%@",Localized(@"JX_GroupNotUse")]; } break; } case kRoomRemind_SetRecordTimeOut:{ NSArray *pickerArr = @[Localized(@"JX_Forever"), Localized(@"JX_OneHour"), Localized(@"JX_OneDay"), Localized(@"JX_OneWeeks"), Localized(@"JX_OneMonth"), Localized(@"JX_OneQuarter"), Localized(@"JX_OneYear")]; double outTime = [msg.content doubleValue]; NSString *str; if (outTime <= 0) { str = pickerArr[0]; }else if (outTime == 0.04) { str = pickerArr[1]; }else if (outTime == 1) { str = pickerArr[2]; }else if (outTime == 7) { str = pickerArr[3]; }else if (outTime == 30) { str = pickerArr[4]; }else if (outTime == 90) { str = pickerArr[5]; }else{ str = pickerArr[6]; } content = [NSString stringWithFormat:@"%@%@",Localized(@"JX_GroupManagerSetMsgDelTime"),str]; } default: break; } if (content.length > 0) { msg.type = [NSNumber numberWithInt:kWCMessageTypeRemind]; msg.content = content; } } -(BOOL)isAtMe{//是否@了我 if(!self.isGroup || self.objectId==nil) return 0; if (![self.objectId isKindOfClass:[NSString class]]) { self.objectId = [NSString stringWithFormat:@"%@",self.objectId]; } if([self.objectId isEqualToString:self.toUserId] && [self.type intValue] == 1) return 1; return [self.objectId rangeOfString:MY_USER_ID].location != NSNotFound; } - (BOOL)updateFromUserName{ NSString* myUserId = MY_USER_ID; if([myUserId length]<=0) return NO; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId]; NSString *sql=[NSString stringWithFormat:@"update msg_%@ set fromUserName=? where fromUserId=?",self.objectId]; BOOL worked=[db executeUpdate:sql,self.content, self.fromUserId]; // FMDBQuickCheck(worked); db = nil; return worked; } - (id)copyWithZone:(NSZone *)zone { JXMessageObject* newMsg = [[JXMessageObject allocWithZone:zone] init]; newMsg.messageId = self.messageId; newMsg.fromId = self.fromId; newMsg.toId = self.toId; newMsg.type = self.type; newMsg.fromUserId = self.fromUserId; newMsg.fromUserName = self.fromUserName; newMsg.toUserId = self.toUserId; newMsg.toUserName = self.toUserName; newMsg.content = self.content; newMsg.fileName = self.fileName; newMsg.objectId = self.objectId; newMsg.fileSize = self.fileSize; newMsg.timeLen = self.timeLen; newMsg.location_x = self.location_x; newMsg.location_y = self.location_y; newMsg.isReadDel = self.isReadDel; newMsg.isEncrypt = self.isEncrypt; newMsg.timeSend = self.timeSend; newMsg.deleteTime = self.deleteTime; newMsg.messageNo = self.messageNo; newMsg.isSend = self.isSend; newMsg.isRead = self.isRead; newMsg.isReceive = self.isReceive; newMsg.isUpload = self.isUpload; newMsg.timeReceive = self.timeReceive; newMsg.fileData = self.fileData; newMsg.readPersons = self.readPersons; newMsg.readTime = self.readTime; newMsg.isMySend = self.isMySend; newMsg.isGroup = self.isGroup; newMsg.isShowTime = self.isShowTime; newMsg.isDelay = self.isDelay; newMsg.imageWidth = self.imageWidth; newMsg.imageHeight = self.imageHeight; newMsg.dictionary = self.dictionary; newMsg.progress = self.progress; newMsg.index = self.index; newMsg.sendCount = self.sendCount; newMsg.updateLastContent = self.updateLastContent; newMsg.showRead = self.showRead; newMsg.chatMsgHeight = self.chatMsgHeight; newMsg.isShowTime = self.isShowTime; newMsg.signature = self.signature; newMsg.isVerifySignatureFailed = self.isVerifySignatureFailed; return newMsg; } - (BOOL)haveTheMessage { FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID]; NSString* sql= [NSString stringWithFormat:@"select messageId from msg_%@ where messageId=?",[self getTableName]]; FMResultSet *rs=[db executeQuery:sql,self.messageId]; while ([rs next]) { // NSLog(@"不必重复保存:%@",self.messageId); return YES; } return NO; } - (BOOL)updateFileName { NSString* myUserId = MY_USER_ID; if([myUserId length]<=0) return NO; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId]; NSString *sql=[NSString stringWithFormat:@"update msg_%@ set fileName=? where messageId=?",[self getTableName]]; BOOL worked=[db executeUpdate:sql,self.fileName, self.messageId]; // FMDBQuickCheck(worked); db = nil; return worked; } - (BOOL)updateFileSize { NSString* myUserId = MY_USER_ID; if([myUserId length]<=0) return NO; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId]; NSString *sql=[NSString stringWithFormat:@"update msg_%@ set fileSize=? where messageId=?",[self getTableName]]; BOOL worked=[db executeUpdate:sql,self.fileSize, self.messageId]; // FMDBQuickCheck(worked); db = nil; return worked; } // 更新邀请群好友验证文件名，用于判断是否已确认验证 - (BOOL)updateNeedVerifyFileName; { NSString* myUserId = MY_USER_ID; if([myUserId length]<=0) return NO; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId]; SBJsonParser * resultParser = [[SBJsonParser alloc] init] ; NSDictionary *resultObject = [resultParser objectWithString:self.objectId]; NSString *roomJid = [resultObject objectForKey:@"roomJid"]; NSString *sql=[NSString stringWithFormat:@"update msg_%@ set fileName=? where messageId=?",roomJid]; BOOL worked=[db executeUpdate:sql,self.fileName, self.messageId]; // FMDBQuickCheck(worked); db = nil; return worked; } // 更新消息行高 - (BOOL)updateChatMsgHeight { NSString* myUserId = MY_USER_ID; if([myUserId length]<=0) return NO; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId]; NSString *sql=[NSString stringWithFormat:@"update msg_%@ set chatMsgHeight=? where messageId=? and type=?",[self getTableName]]; BOOL worked=[db executeUpdate:sql,self.chatMsgHeight, self.messageId, self.type]; return worked; } // 根据objectId获取消息 - (NSMutableArray *)getMsgWithObjectId:(NSString *)objectId { NSString* myUserId = MY_USER_ID; NSMutableArray *resultArr = [NSMutableArray array]; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId]; NSString *sql=[NSString stringWithFormat:@"select * from msg_%@ where objectId=?",[self getTableName]]; FMResultSet *rs=[db executeQuery:sql,objectId]; while ([rs next]) { JXMessageObject *p=[[JXMessageObject alloc] init]; [p fromRs:rs]; [resultArr addObject:p]; } [rs close]; if([resultArr count]==0){ resultArr = nil; } return resultArr; } // 更新所有消息行高 - (BOOL)updateAllChatMsgHeight { NSString* myUserId = MY_USER_ID; if([myUserId length]<=0) return NO; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId]; NSString *sql=[NSString stringWithFormat:@"select * from sqlite_master where type='table'"]; FMResultSet *rs=[db executeQuery:sql]; while ([rs next]) { NSString *name = [rs stringForColumn:@"name"]; if ([name rangeOfString:@"msg_"].location != NSNotFound) { NSString *sql=[NSString stringWithFormat:@"update %@ set chatMsgHeight=? ",name]; [db executeUpdate:sql,@"0"]; } } return YES; } // 更新是否显示时间 - (BOOL)updateIsShowTime { NSString* myUserId = MY_USER_ID; if([myUserId length]<=0) return NO; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId]; NSString *sql=[NSString stringWithFormat:@"update msg_%@ set isShowTime=? where messageId=?",[self getTableName]]; BOOL worked=[db executeUpdate:sql,[NSNumber numberWithBool:self.isShowTime], self.messageId]; return worked; } // 删除过期聊天记录 - (BOOL)deleteTimeOutMsg:(NSString *)userId chatRecordTimeOut:(NSString *)ChatRecordTimeOut { NSString* myUserId = MY_USER_ID; if([myUserId length]<=0) return NO; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId]; NSString *sql=[NSString stringWithFormat:@"delete from msg_%@ where deleteTime < %f and deleteTime > 0",userId,[[NSDate date] timeIntervalSince1970]]; BOOL worked=[db executeUpdate:sql]; // FMDBQuickCheck(worked); db = nil; return worked; } - (JXMessageObject *)getMsgWithMsgId:(NSString *)msgId { JXUserObject *user = [[JXUserObject sharedInstance] getUserById:[self getTableName]]; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID]; NSString* sql= [NSString stringWithFormat:@"select * from msg_%@ where messageId=?",[self getTableName]]; FMResultSet *rs=[db executeQuery:sql,msgId]; while ([rs next]) { JXMessageObject *p=[[JXMessageObject alloc] init]; p.isGroup = [user.roomFlag boolValue]; [p fromRs:rs]; return p; } return nil; } - (JXMessageObject *)getMsgWithMsgId:(NSString *)msgId toUserId:(NSString *)toUserId { JXUserObject *user = [[JXUserObject sharedInstance] getUserById:toUserId]; FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID]; NSString* sql= [NSString stringWithFormat:@"select * from msg_%@ where messageId=?",toUserId]; FMResultSet *rs=[db executeQuery:sql,msgId]; while ([rs next]) { JXMessageObject *p=[[JXMessageObject alloc] init]; p.isGroup = [user.roomFlag boolValue]; [p fromRs:rs]; return p; } return nil; } // Message.pbobjc 转 JXMessageObject + (JXMessageObject *)getMsgObjWithPbobjc:(ChatMessage *)message { JXMessageObject *msg = [[JXMessageObject alloc] init]; msg.fromId = message.messageHead.from; msg.toId = message.messageHead.to; msg.messageId = message.messageHead.messageId; msg.fromUserId = message.fromUserId; msg.fromUserName = message.fromUserName; if (message.toUserId && message.toUserId.length > 0) { msg.toUserId = message.toUserId; }else { msg.toUserId = MY_USER_ID; } msg.toUserName = message.toUserName; msg.timeSend = [NSDate dateWithTimeIntervalSince1970:message.timeSend / 1000.0]; msg.type = [NSNumber numberWithInt:message.type]; msg.objectId = message.objectId; msg.fileName = message.fileName; msg.isEncrypt = [NSNumber numberWithBool:message.isEncrypt]; msg.deleteTime = [NSDate dateWithTimeIntervalSince1970:message.deleteTime]; msg.isReadDel = [NSNumber numberWithBool:message.isReadDel]; msg.fileSize = [NSNumber numberWithLongLong:message.fileSize]; msg.location_x = [NSNumber numberWithDouble:message.locationX]; msg.location_y = [NSNumber numberWithDouble:message.locationY]; msg.chatType = message.messageHead.chatType; msg.isDelay = message.messageHead.offline; msg.isRead = [NSNumber numberWithInt:0]; msg.timeLen = [NSNumber numberWithLongLong:message.fileTime]; if ([msg.isEncrypt boolValue]) { // self.content = [DESUtil decryptDESStr:messCont key:[NSString stringWithFormat:@"%@",[p objectForKey:kMESSAGE_TIMESEND]]]; NSMutableString *str = [NSMutableString string]; [str appendString:APIKEY]; [str appendString:[NSString stringWithFormat:@"%lld",message.timeSend]]; [str appendString:msg.messageId]; NSString *keyStr = [g_server getMD5String:str]; msg.content = [DESUtil decryptDESStr:message.content key:keyStr]; if (IsStringNull(msg.content)) { msg.content = message.content; } }else{ msg.content = message.content; } return msg; } // JXMessageObject 转 Message.pbobjc - (ChatMessage *)getPbobjcObjWithMsg:(JXMessageObject *)msg { ChatMessage *message = [[ChatMessage alloc] init]; if ( msg.tempChat==11) { message.messageHead.from = [NSString stringWithFormat:@"%@/%@/1",msg.fromUserId,SameResource]; }else{ message.messageHead.from = [NSString stringWithFormat:@"%@/%@",msg.fromUserId,SameResource]; } message.messageHead.to = msg.toUserId ? msg.toUserId : @""; message.messageHead.messageId = msg.messageId ? msg.messageId : @""; message.messageHead.chatType = msg.chatType; message.messageHead.offline = msg.isDelay; //message.useInfoTempChat = msg.tempChat ? msg.tempChat : 0; message.fromUserId = msg.fromUserId ? msg.fromUserId : @""; message.fromUserName = msg.fromUserName ? msg.fromUserName : @""; message.toUserId = msg.toUserId ? msg.toUserId : @""; message.toUserName = msg.toUserName ? msg.toUserName : @""; message.timeSend = [msg.timeSend timeIntervalSince1970] * 1000; message.type = [msg.type intValue]; message.objectId = msg.objectId ? msg.objectId : @""; message.fileName = [NSString stringWithFormat:@"%@",msg.fileName ? msg.fileName : @""]; message.isEncrypt = [msg.isEncrypt boolValue]; message.deleteTime = [msg.deleteTime timeIntervalSince1970]; message.isReadDel = [msg.isReadDel boolValue]; message.fileSize = [msg.fileSize longLongValue]; message.locationX = [msg.location_x doubleValue]; message.locationY = [msg.location_y doubleValue]; message.fileTime = [msg.timeLen intValue]; if([self.isEncrypt boolValue]){ NSMutableString *str = [NSMutableString string]; [str appendString:APIKEY]; [str appendString:[NSString stringWithFormat:@"%@",[NSNumber numberWithLongLong:message.timeSend]]]; [str appendString:msg.messageId]; NSString *keyStr = [g_server getMD5String:str]; message.content = [DESUtil encryptDESStr:msg.content key:keyStr]; // [dictionary setValue:[DESUtil encryptDESStr:msg.content key:keyStr] forKey:kMESSAGE_CONTENT]; } else message.content = msg.content ? msg.content : @""; return message; } @end