JXUserObject.m 67 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685
  1. //
  2. // JXUserObject.m
  3. //
  4. // Created by Reese on 13-8-11.
  5. // Copyright (c) 2013年 Reese. All rights reserved.
  6. //
  7. #import "JXUserObject.h"
  8. #import "FMDatabase.h"
  9. #import "FMResultSet.h"
  10. #import "AppDelegate.h"
  11. #import "JXFriendObject.h"
  12. #import "JXMessageObject.h"
  13. #import "roomData.h"
  14. #import "resumeData.h"
  15. #import "DESUtil.h"
  16. #import "JXRoomRemind.h"
  17. @implementation JXUserObject
  18. MJCodingImplementation
  19. @synthesize
  20. telephone,
  21. password,
  22. birthday,
  23. companyName,
  24. model,
  25. osVersion,
  26. serialNumber,
  27. location,
  28. //description,
  29. sex,
  30. countryId,
  31. provinceId,
  32. cityId,
  33. areaId,
  34. latitude,
  35. longitude,
  36. level,
  37. vip,
  38. fansCount,
  39. veryCare,
  40. veryCareTones,
  41. attCount,
  42. membershipAccount;
  43. static JXUserObject *sharedUser;
  44. +(JXUserObject*)sharedInstance{
  45. static dispatch_once_t onceToken;
  46. dispatch_once(&onceToken, ^{
  47. sharedUser=[[JXUserObject alloc]init];
  48. });
  49. return sharedUser;
  50. }
  51. -(id)init{
  52. self = [super init];
  53. if(self){
  54. _tableName = @"friend";
  55. _favorites = [NSMutableArray array];
  56. _phoneDic = [NSMutableDictionary dictionary];
  57. _msgBackGroundUrl = [NSString string];
  58. }
  59. return self;
  60. }
  61. -(void)dealloc{
  62. self.telephone = nil;
  63. self.password = nil;
  64. self.userType = nil;
  65. self.birthday = nil;
  66. self.companyName = nil;
  67. self.model = nil;
  68. self.osVersion = nil;
  69. self.serialNumber = nil;
  70. self.location = nil;
  71. self.sex = nil;
  72. self.role = nil;
  73. self.countryId = nil;
  74. self.provinceId = nil;
  75. self.cityId = nil;
  76. self.areaId = nil;
  77. self.latitude = nil;
  78. self.longitude = nil;
  79. self.level = nil;
  80. self.vip = nil;
  81. self.fansCount = nil;
  82. self.attCount = nil;
  83. self.myInviteCode = nil;
  84. self.membershipAccount = nil;
  85. // NSLog(@"JXUserObject.dealloc");
  86. // [super dealloc];
  87. }
  88. -(BOOL)insert{
  89. self.roomFlag = [NSNumber numberWithInt:0];
  90. self.companyId = [NSNumber numberWithInt:0];
  91. if ([self.offlineNoPushMsg intValue] <= 0) {
  92. self.offlineNoPushMsg = [NSNumber numberWithInt:0];
  93. }
  94. self.isAtMe = [NSNumber numberWithInt:0];
  95. self.talkTime = [NSNumber numberWithLong:0];
  96. return [super insert];
  97. }
  98. -(BOOL)insertRoom
  99. {
  100. self.roomFlag= [NSNumber numberWithInt:1];
  101. self.companyId= [NSNumber numberWithInt:0];
  102. self.status= [NSNumber numberWithInt:2];
  103. if ([self.offlineNoPushMsg intValue] <= 0) {
  104. self.offlineNoPushMsg = [NSNumber numberWithInt:0];
  105. }
  106. self.isAtMe = [NSNumber numberWithInt:0];
  107. return [super insert];
  108. }
  109. -(JXUserObject*)userFromDictionary:(NSDictionary*)aDic
  110. {
  111. JXUserObject* user = [[JXUserObject alloc]init];
  112. [super userFromDictionary:user dict:aDic];
  113. return user;
  114. }
  115. //好友关系
  116. -(NSMutableArray*)fetchAllFriendsFromLocal
  117. {
  118. NSString* sql = @"select * from friend where (status=2 or status=10) and companyId=0 and roomFlag=0 and isDevice=0 and userType <> 2 order by status desc, timeCreate desc";
  119. return [self doFetch:sql];
  120. }
  121. // 获取系统公众号
  122. -(NSMutableArray*)fetchSystemUser {
  123. NSString* sql = @"select * from friend where (userType=2 and (status=8 or status=2) and companyId=0 and roomFlag=0 and isDevice=0) or userId=1100 order by timeCreate asc";
  124. return [self doFetch:sql];
  125. }
  126. //搜索好友
  127. -(NSMutableArray*)fetchFriendsFromLocalWhereLike:(NSString *)searchStr
  128. {
  129. NSString* sql = [NSString stringWithFormat:@"select * from friend where (status=8 or status=2) and companyId=0 and roomFlag=0 and userNickname like '%%%@%%' order by status desc, timeCreate desc",searchStr];
  130. return [self doFetch:sql];
  131. }
  132. //搜索好友
  133. -(NSMutableArray*)fetchFriendsFromLocalWhereLikeNickNameOrRemarkNameOrTelephone:(NSString *)searchStr
  134. {
  135. NSString* sql = [NSString stringWithFormat:@"select * from friend where (status=8 or status=2) and companyId=0 and roomFlag=0 and userNickname like '%%%@%%' order by status desc, timeCreate desc",searchStr];
  136. NSMutableArray *userNicknameArray = [self doFetch:sql];
  137. sql = [NSString stringWithFormat:@"select * from friend where (status=8 or status=2) and companyId=0 and roomFlag=0 and remarkName like '%%%@%%' order by status desc, timeCreate desc",searchStr];
  138. NSMutableArray *remarkNameArray = [self doFetch:sql];
  139. sql = [NSString stringWithFormat:@"select * from friend where (status=8 or status=2) and companyId=0 and roomFlag=0 and telephone like '%%%@%%' order by status desc, timeCreate desc",searchStr];
  140. NSMutableArray *telephoneArray = [self doFetch:sql];
  141. // 三个都有值返回合成
  142. if (userNicknameArray!=nil && remarkNameArray!=nil && telephoneArray!=nil ) {
  143. NSMutableArray * bigArray = [[NSMutableArray alloc] initWithArray:userNicknameArray];
  144. [bigArray addObjectsFromArray:remarkNameArray];
  145. [bigArray addObjectsFromArray:telephoneArray];
  146. NSMutableDictionary *tmpDict = [NSMutableDictionary dictionary];
  147. for (JXUserObject *userObject in bigArray) {
  148. [tmpDict setObject:userObject forKey:userObject.userId];
  149. }
  150. return [tmpDict.allValues mutableCopy];
  151. }
  152. // 二个有值合成
  153. if (userNicknameArray!=nil && remarkNameArray!=nil) {
  154. NSMutableArray * bigArray = [[NSMutableArray alloc] initWithArray:userNicknameArray];
  155. [bigArray addObjectsFromArray:remarkNameArray];
  156. NSMutableDictionary *tmpDict = [NSMutableDictionary dictionary];
  157. for (JXUserObject *userObject in bigArray) {
  158. [tmpDict setObject:userObject forKey:userObject.userId];
  159. }
  160. return [tmpDict.allValues mutableCopy];
  161. }
  162. if (remarkNameArray!=nil && telephoneArray!=nil) {
  163. NSMutableArray * bigArray = [[NSMutableArray alloc] initWithArray:remarkNameArray];
  164. [bigArray addObjectsFromArray:telephoneArray];
  165. NSMutableDictionary *tmpDict = [NSMutableDictionary dictionary];
  166. for (JXUserObject *userObject in bigArray) {
  167. [tmpDict setObject:userObject forKey:userObject.userId];
  168. }
  169. return [tmpDict.allValues mutableCopy];
  170. }
  171. if (userNicknameArray!=nil && telephoneArray!=nil) {
  172. NSMutableArray * bigArray = [[NSMutableArray alloc] initWithArray:userNicknameArray];
  173. [bigArray addObjectsFromArray:telephoneArray];
  174. NSMutableDictionary *tmpDict = [NSMutableDictionary dictionary];
  175. for (JXUserObject *userObject in bigArray) {
  176. [tmpDict setObject:userObject forKey:userObject.userId];
  177. }
  178. return [tmpDict.allValues mutableCopy];
  179. }
  180. // 一个
  181. if (userNicknameArray) {
  182. return userNicknameArray;
  183. }
  184. if (remarkNameArray) {
  185. return remarkNameArray;
  186. }
  187. if (telephoneArray) {
  188. return telephoneArray;
  189. }
  190. return @[].mutableCopy;
  191. }
  192. //获取数据库好友列表所有的好友、公众号、群组
  193. -(NSMutableArray*)fetchAllFriends
  194. {
  195. NSString* sql = @"select * from friend where (status=-1 or status=1 or status=2 or status=8) and companyId=0 order by status desc, timeCreate desc";
  196. return [self doFetch:sql];
  197. }
  198. //所有联系人,0没任何关系,-1黑名单,2好友关系,8系统账号,1单向关注
  199. -(NSMutableArray*)fetchAllFriendsOrNotFromLocal
  200. {
  201. NSString* sql = @"select * from friend where (status=-1 or status=1 or status=2) and companyId=0 and roomFlag=0 order by status desc, timeCreate desc";
  202. return [self doFetch:sql];
  203. }
  204. -(NSMutableArray*)fetchAllRoomsFromLocal
  205. {
  206. NSString* sql = @"select * from friend where roomFlag=1 and companyId =0 and groupStatus = 0 order by status desc, timeCreate desc";
  207. return [self doFetch:sql];
  208. }
  209. // 获取指定类型群组
  210. -(NSMutableArray*)fetchRoomsFromLocalWithCategory:(NSNumber *)category
  211. {
  212. NSString* sql = [NSString stringWithFormat:@"select * from friend where roomFlag=1 and category=%@ and companyId =0 order by status desc, timeCreate desc",category];
  213. ;
  214. return [self doFetch:sql];
  215. }
  216. -(NSMutableArray*)fetchAllCompanyFromLocal
  217. {
  218. NSString* sql = [NSString stringWithFormat:@"select * from friend where companyId>0 and roomFlag=0 and userId!='%@' order by status desc, timeCreate desc",MY_USER_ID];
  219. return [self doFetch:sql];
  220. }
  221. //主动打招呼后status=1
  222. -(NSMutableArray*)fetchAllPayFromLocal
  223. {
  224. NSString* sql = [NSString stringWithFormat:@"select * from friend where status=1 and companyId=0 and roomFlag=0 and userId!='%@' order by status desc, timeCreate desc",MY_USER_ID];
  225. return [self doFetch:sql];
  226. }
  227. -(NSMutableArray*)fetchAllUserFromLocal
  228. {
  229. NSString* sql = [NSString stringWithFormat:@"select * from friend where status=2 and userType != 2 and companyId=0 and roomFlag=0 and userId!='%@' order by status desc, timeCreate desc",MY_USER_ID];
  230. return [self doFetch:sql];
  231. }
  232. -(NSMutableArray*)fetchAllBlackFromLocal
  233. {
  234. NSString* sql = @"select * from friend where status=-1 order by status desc, timeCreate desc";
  235. return [self doFetch:sql];
  236. }
  237. -(NSMutableArray*)fetchBlackFromLocalWhereLike:(NSString *)searchStr
  238. {
  239. NSString* sql = [NSString stringWithFormat:@"select * from friend where status<0 and (userNickname like '%%%@%%' or remarkName like '%%%@%%') order by status desc, timeCreate desc",searchStr,searchStr];
  240. return [self doFetch:sql];
  241. }
  242. //插入本地不存在的好友
  243. - (void)insertFriend{
  244. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:g_server.myself.userId];
  245. FMResultSet * rs = [db executeQuery:[NSString stringWithFormat:@"select * from friend where userId=?"],self.userId];
  246. if (![rs next]) {
  247. NSString *insertStr=[NSString stringWithFormat:@"INSERT INTO friend ('userId','userNickname','remarkName','role','createUserId','userDescription','userHead','roomFlag','category','timeCreate','newMsgs','status','userType','companyId','type','content','isMySend','roomId','timeSend','downloadTime','lastInput','showRead','showMember','allowSendCard','allowInviteFriend','allowUploadFile','allowConference','allowSpeakCourse','isNeedVerify','topTime','groupStatus','isOnLine','isOpenReadDel','isSendRecipt','isDevice','chatRecordTimeOut','offlineNoPushMsg','isAtMe','talkTime','publicKeyDH','publicKeyRSARoom','chatKeyGroup','veryCare','veryCareTones','telephone') VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"];
  248. BOOL worked = [db executeUpdate:insertStr,self.userId,self.userNickname,self.remarkName,self.role,self.createUserId,self.userDescription,nil,self.roomFlag,self.category,self.timeCreate,self.msgsNew,self.status,self.userType,self.companyId,self.type,self.content,self.isMySend,self.roomId,self.timeSend,self.downloadTime,self.lastInput,self.showRead,self.showMember,self.allowSendCard,self.allowInviteFriend,self.allowUploadFile,self.allowConference,self.allowSpeakCourse,self.isNeedVerify,self.topTime,self.groupStatus,self.isOnLine,self.isOpenReadDel, self.isSendRecipt,self.isDevice,self.chatRecordTimeOut,self.offlineNoPushMsg,self.isAtMe,self.talkTime,self.publicKeyDH,self.publicKeyRSARoom,self.chatKeyGroup,self.veryCare,self.veryCareTones,self.telephone];
  249. NSLog(@"%d",worked);
  250. }else{
  251. //因为以前的漏洞,取消黑名单后status出现与服务端不一致
  252. // NSString * status=[rs objectForColumnName:kUSER_STATUS];
  253. // if ([status intValue] != [self.status intValue]) {
  254. NSString *insertStr=[NSString stringWithFormat:@"update friend set userNickname =?,status=?,userType=? where userId=?"];
  255. BOOL worked = [db executeUpdate:insertStr,self.userNickname,self.status,self.userType,self.userId];
  256. NSLog(@"%d",worked);
  257. // }
  258. }
  259. [g_App copyDbWithUserId:MY_USER_ID];
  260. }
  261. -(void)createSystemFriend{
  262. JXUserObject* user = [[JXUserObject alloc] init];
  263. user.userId = CALL_CENTER_USERID;
  264. user.userNickname = Localized(@"JXUserObject_SysMessage");
  265. // status 暂不用8, 改为2. 消息界面需要用到好友关系
  266. user.status = [NSNumber numberWithInt:2];
  267. user.userType = [NSNumber numberWithInt:2];
  268. user.roomFlag = [NSNumber numberWithInt:0];
  269. // user.role = [NSNumber numberWithInt:2];
  270. user.content = Localized(@"JXUserObject_Wealcome");
  271. user.timeSend = [NSDate date];
  272. user.chatRecordTimeOut = g_myself.chatRecordTimeOut;
  273. if(!user.haveTheUser)
  274. [user insert];
  275. else {
  276. [user updateUserNickname];
  277. }
  278. user.userId = FRIEND_CENTER_USERID;
  279. user.userNickname = Localized(@"JXNewFriendVC_NewFirend");
  280. user.status = [NSNumber numberWithInt:8];
  281. user.userType = [NSNumber numberWithInt:0];
  282. user.roomFlag = [NSNumber numberWithInt:0];
  283. // user.content = Localized(@"JXUserObject_Friend");
  284. user.content = nil;
  285. user.timeSend = [NSDate date];
  286. user.chatRecordTimeOut = g_myself.chatRecordTimeOut;
  287. if(!user.haveTheUser)
  288. [user insert];
  289. else {
  290. [user updateUserNickname];
  291. }
  292. user.userId = BLOG_CENTER_USERID;
  293. user.userNickname = Localized(@"JXUserObject_BusinessMessage");
  294. user.status = [NSNumber numberWithInt:9];
  295. user.userType = [NSNumber numberWithInt:0];
  296. user.roomFlag = [NSNumber numberWithInt:0];
  297. user.content = nil;
  298. user.timeSend = [NSDate date];
  299. user.chatRecordTimeOut = g_myself.chatRecordTimeOut;
  300. if(!user.haveTheUser)
  301. [user insert];
  302. else {
  303. [user update];
  304. }
  305. // 我的其他端设备
  306. NSArray *names = @[Localized(@"JX_MyAndroid"), Localized(@"JX_MyWindowsComputer"), Localized(@"JX_MyMacComputer"), Localized(@"JX_MyWebPage")];
  307. NSArray *userIds = @[ANDROID_USERID, PC_USERID, MAC_USERID, WEB_USERID];
  308. for (NSInteger i = 0; i < names.count; i ++) {
  309. // BOOL isMultipleLogin = [[g_default objectForKey:kISMultipleLogin] boolValue];
  310. BOOL isMultipleLogin = [g_myself.multipleDevices intValue] > 0 ? YES : NO;
  311. user.userId = userIds[i];
  312. user.userNickname = names[i];
  313. user.status = [NSNumber numberWithInt:10];
  314. user.userType = [NSNumber numberWithInt:0];
  315. user.roomFlag = [NSNumber numberWithInt:0];
  316. user.isDevice = [NSNumber numberWithInt:1];
  317. user.isOnLine = [NSNumber numberWithInt:0];
  318. user.content = nil;
  319. user.timeSend = [NSDate date];
  320. user.chatRecordTimeOut = g_myself.chatRecordTimeOut;
  321. if (isMultipleLogin) {
  322. if (![user haveTheUser]) {
  323. [user insert];
  324. }else {
  325. [user updateIsOnLine];
  326. [g_notify postNotificationName:kUpdateIsOnLineMultipointLogin object:nil];
  327. }
  328. }else {
  329. [user delete];
  330. }
  331. }
  332. }
  333. -(NSMutableArray*)doFetch:(NSString*)sql
  334. {
  335. NSMutableArray *resultArr=[[NSMutableArray alloc]init];
  336. NSString* myUserId = MY_USER_ID;
  337. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  338. [super checkTableCreatedInDb:db];
  339. FMResultSet *rs=[db executeQuery:sql];
  340. while ([rs next]) {
  341. JXUserObject *user=[[JXUserObject alloc] init];
  342. [super userFromDataset:user rs:rs];
  343. // [self userFromDataset:rs];
  344. [resultArr addObject:user];
  345. // [user release];
  346. }
  347. [rs close];
  348. if([resultArr count]==0){
  349. // [resultArr release];
  350. resultArr = nil;
  351. }
  352. return resultArr;
  353. }
  354. -(JXUserObject*)getUserById:(NSString*)aUserId
  355. {
  356. NSString* myUserId = MY_USER_ID;
  357. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  358. FMResultSet *rs=[db executeQuery:[NSString stringWithFormat:@"select * from %@ where userId=?",_tableName],aUserId];
  359. if ([rs next]) {
  360. JXUserObject *user=[[JXUserObject alloc]init];
  361. [super userFromDataset:user rs:rs];
  362. [rs close];
  363. return user;
  364. };
  365. return nil;
  366. }
  367. -(JXUserObject*)getUserByRoomId:(NSString*)roomId {
  368. NSString* myUserId = MY_USER_ID;
  369. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  370. FMResultSet *rs=[db executeQuery:[NSString stringWithFormat:@"select * from %@ where roomId=?",_tableName],roomId];
  371. if ([rs next]) {
  372. JXUserObject *user=[[JXUserObject alloc]init];
  373. [super userFromDataset:user rs:rs];
  374. [rs close];
  375. return user;
  376. };
  377. return nil;
  378. }
  379. -(int)getNewTotal
  380. {
  381. NSString* myUserId = MY_USER_ID;
  382. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  383. int n = 0;
  384. FMResultSet *rs=[db executeQuery:[NSString stringWithFormat:@"select sum(newMsgs) from %@ where newMsgs>0",_tableName]];
  385. if ([rs next]) {
  386. n = [[rs objectForColumnIndex:0] intValue];
  387. [rs close];
  388. };
  389. return n;
  390. }
  391. -(void)getDataFromDict:(NSDictionary*)dict{
  392. [self userFromDictionary:dict];
  393. self.type = nil;
  394. self.content = nil;
  395. // self.timeSend = nil;
  396. self.msgsNew = nil;
  397. self.timeCreate = [NSDate date];
  398. self.roomFlag = [NSNumber numberWithInt:0];
  399. /*
  400. 我是A,调user/get?userId=B
  401. friends->isBeenBlack,A是不是被B拉黑
  402. friends->Blacklist,A是不是拉黑B
  403. */
  404. self.status = [(NSDictionary *)[dict objectForKey:@"friends"] objectForKey:@"status"];
  405. self.userType = [dict objectForKey:@"userType"];
  406. if([[(NSDictionary *)[dict objectForKey:@"friends"] objectForKey:@"blacklist"] boolValue])
  407. self.status = [NSNumber numberWithInt:friend_status_black];
  408. self.isBeenBlack = [(NSDictionary *)[dict objectForKey:@"friends"] objectForKey:@"isBeenBlack"];
  409. if ([self.isBeenBlack intValue] == 1) {
  410. self.status = [NSNumber numberWithInt:friend_status_hisBlack];
  411. }
  412. // if([[[dict objectForKey:@"friends"] objectForKey:@"isBeenBlack"] boolValue])
  413. // self.status = [NSNumber numberWithInt:friend_status_hisBlack];
  414. self.userId = [[dict objectForKey:@"userId"] stringValue];
  415. NSString *remarkName = [(NSDictionary *)[dict objectForKey:@"friends"] objectForKey:@"remarkName"];
  416. if (remarkName.length > 0) {
  417. self.remarkName = remarkName;
  418. }
  419. NSString *describe = [(NSDictionary *)[dict objectForKey:@"friends"] objectForKey:@"describe"];
  420. if (describe.length > 0) {
  421. self.describe = describe;
  422. }
  423. // if ([dict objectForKey:@"toFriendsRole"]) {
  424. // NSArray *roleDict = [dict objectForKey:@"toFriendsRole"];
  425. // self.role = @([[[roleDict firstObject] objectForKey:@"role"] intValue]);
  426. // }
  427. self.userNickname = [dict objectForKey:@"nickname"];
  428. self.userDescription = [dict objectForKey:@"description"];
  429. self.companyId = [dict objectForKey:@"companyId"];
  430. self.companyName = [(NSDictionary *)[dict objectForKey:@"company"] objectForKey:@"name"];
  431. self.msgBackGroundUrl = [dict objectForKey:@"msgBackGroundUrl"];
  432. self.showLastLoginTime = [dict objectForKey:@"showLastLoginTime"];
  433. self.showLastLoginTime = [dict objectForKey:@"showLastLoginTime"];
  434. self.membershipAccount = [dict objectForKey:@"membershipAccount"];
  435. self.telephone = [dict objectForKey:@"telephone"];
  436. self.phone = [dict objectForKey:@"phone"];
  437. self.password = [dict objectForKey:@"password"];
  438. self.userType = [dict objectForKey:@"userType"];
  439. self.birthday = [NSDate dateWithTimeIntervalSince1970:[[dict objectForKey:@"birthday"] longLongValue]];
  440. self.sex = [dict objectForKey:@"sex"];
  441. self.countryId = [dict objectForKey:@"countryId"];
  442. self.provinceId = [dict objectForKey:@"provinceId"];
  443. self.cityId = [dict objectForKey:@"cityId"];
  444. self.areaId = [dict objectForKey:@"areaId"];
  445. self.fansCount = [dict objectForKey:@"fansCount"];
  446. self.attCount = [dict objectForKey:@"attCount"];
  447. self.level = [dict objectForKey:@"level"];
  448. self.vip = [dict objectForKey:@"vip"];
  449. self.notSeeHim = [dict objectForKey:@"notSeeHim"];
  450. self.notLetSeeHim = [dict objectForKey:@"notLetSeeHim"];
  451. self.model = [dict objectForKey:@"model"];
  452. self.osVersion = [dict objectForKey:@"osVersion"];
  453. self.serialNumber = [dict objectForKey:@"serialNumber"];
  454. self.location = [dict objectForKey:@"location"];
  455. // self.latitude = [dict objectForKey:@"latitude"];
  456. // self.longitude = [dict objectForKey:@"longitude"];
  457. self.latitude = [(NSDictionary *)[dict objectForKey:@"loc"] objectForKey:@"lat"];
  458. self.longitude = [(NSDictionary *)[dict objectForKey:@"loc"] objectForKey:@"lng"];
  459. if ([dict objectForKey:@"friends"]) {
  460. self.offlineNoPushMsg = [(NSDictionary *)[dict objectForKey:@"friends"] objectForKey:@"offlineNoPushMsg"];
  461. self.isOpenReadDel = [(NSDictionary *)[dict objectForKey:@"friends"] objectForKey:@"isOpenSnapchat"];
  462. long time = [[(NSDictionary *)[dict objectForKey:@"friends"] objectForKey:@"openTopChatTime"] longLongValue];
  463. self.topTime = [NSDate dateWithTimeIntervalSince1970:time];
  464. self.chatRecordTimeOut = [NSString stringWithFormat:@"%@", [(NSDictionary *)[dict objectForKey:@"friends"] objectForKey:@"chatRecordTimeOut"]];
  465. self.veryCare = [(NSDictionary *)[dict objectForKey:@"friends"] objectForKey:@"veryCare"];
  466. self.veryCareTones = [(NSDictionary *)[dict objectForKey:@"friends"] objectForKey:@"veryCareTones"];
  467. }
  468. if ([dict objectForKey:@"member"]) {
  469. long time = [[(NSDictionary *)[dict objectForKey:@"member"] objectForKey:@"openTopChatTime"] longLongValue];
  470. self.topTime = [NSDate dateWithTimeIntervalSince1970:time];
  471. self.offlineNoPushMsg = [(NSDictionary *)[dict objectForKey:@"member"] objectForKey:@"offlineNoPushMsg"];
  472. }
  473. self.talkTime = [dict objectForKey:@"talkTime"];
  474. self.myInviteCode = [dict objectForKey:@"myInviteCode"];
  475. self.setAccountCount = [dict objectForKey:@"setAccountCount"];
  476. self.account = [dict objectForKey:@"account"];
  477. self.publicKeyDH = [dict objectForKey:@"publicKeyDH"];
  478. self.publicKeyRSARoom = [dict objectForKey:@"publicKeyRSARoom"];
  479. self.chatKeyGroup = [dict objectForKey:@"chatKeyGroup"];
  480. }
  481. -(void)getDataFromDictSmall:(NSDictionary*)dict{
  482. self.type = nil;
  483. self.content = nil;
  484. self.timeSend = nil;
  485. self.msgsNew = nil;
  486. self.roomFlag = [NSNumber numberWithInt:0];
  487. self.timeCreate = [dict objectForKey:@"createTime"];
  488. self.status = [dict objectForKey:@"status"];
  489. if ([[dict objectForKey:@"isBeenBlack"] intValue] == 1) {
  490. self.status = [NSNumber numberWithInt:friend_status_hisBlack];
  491. }
  492. self.userType = [dict objectForKey:@"toUserType"];
  493. if ([[dict objectForKey:@"blacklist"] integerValue] == 1) {
  494. self.status = [NSNumber numberWithInt:-1];
  495. }
  496. // if ([dict objectForKey:@"toFriendsRole"]) {
  497. // NSArray *roleDict = [dict objectForKey:@"toFriendsRole"];
  498. // self.role = @([[[roleDict firstObject] objectForKey:@"role"] intValue]);
  499. // }
  500. self.userId = [[dict objectForKey:@"toUserId"] stringValue];
  501. self.remarkName = [dict objectForKey:@"remarkName"];
  502. if ([[dict objectForKey:@"remarkName"] length] > 0) {
  503. self.userNickname = [dict objectForKey:@"remarkName"];
  504. }else {
  505. self.userNickname = [dict objectForKey:@"toNickname"];
  506. }
  507. self.describe = [dict objectForKey:@"describe"];
  508. if ([dict objectForKey:@"companyId"]) {
  509. self.companyId = [dict objectForKey:@"companyId"];
  510. }else {
  511. self.companyId = [NSNumber numberWithInt:0];
  512. }
  513. if ([dict objectForKey:@"chatRecordTimeOut"]) {
  514. self.chatRecordTimeOut = [NSString stringWithFormat:@"%@",[dict objectForKey:@"chatRecordTimeOut"]];
  515. }
  516. if ([dict objectForKey:@"talkTime"]) {
  517. self.talkTime = [dict objectForKey:@"talkTime"];
  518. }
  519. if ([dict objectForKey:@"offlineNoPushMsg"]) {
  520. self.offlineNoPushMsg = [dict objectForKey:@"offlineNoPushMsg"];
  521. }
  522. if ([dict objectForKey:@"veryCare"]) {
  523. self.veryCare = [dict objectForKey:@"veryCare"];
  524. }
  525. if ([dict objectForKey:@"veryCareTones"]) {
  526. self.veryCareTones = [dict objectForKey:@"veryCareTones"];
  527. }
  528. if ([dict objectForKey:@"telephone"]) {
  529. self.telephone = [dict objectForKey:@"telephone"];
  530. }
  531. if ([dict objectForKey:@"openTopChatTime"]) {
  532. long time = [[dict objectForKey:@"openTopChatTime"] longLongValue];
  533. if (time > 0) {
  534. self.topTime = [NSDate dateWithTimeIntervalSince1970:time];
  535. }
  536. }
  537. if ([dict objectForKey:@"dhMsgPublicKey"]) {
  538. self.publicKeyDH = [dict objectForKey:@"dhMsgPublicKey"];
  539. }
  540. if ([dict objectForKey:@"rsaMsgPublicKey"]) {
  541. self.publicKeyRSARoom = [dict objectForKey:@"rsaMsgPublicKey"];
  542. }
  543. if ([dict objectForKey:@"chatKeyGroup"]) {
  544. self.chatKeyGroup = [dict objectForKey:@"chatKeyGroup"];
  545. }
  546. }
  547. -(void)copyFromResume:(resumeBaseData*)resume{
  548. // self.telephone = resume.telephone;
  549. self.userNickname= resume.name;
  550. self.birthday = [NSDate dateWithTimeIntervalSince1970:resume.birthday];
  551. self.sex = [NSNumber numberWithBool:resume.sex];
  552. self.countryId = [NSNumber numberWithInt:resume.countryId];
  553. self.provinceId = [NSNumber numberWithInt:resume.provinceId];
  554. self.cityId = [NSNumber numberWithInt:resume.cityId];
  555. self.areaId = [NSNumber numberWithInt:resume.areaId];
  556. self.latitude = [NSNumber numberWithDouble:g_server.latitude];
  557. self.longitude = [NSNumber numberWithDouble:g_server.longitude];
  558. }
  559. +(void)deleteUserAndMsg:(NSString*)s{
  560. JXUserObject* p = [[JXUserObject alloc]init];
  561. p.userId = s;
  562. [p notifyDelFriend];
  563. [p delete];
  564. // [p release];
  565. JXMessageObject* m = [[JXMessageObject alloc]init];
  566. m.fromUserId = MY_USER_ID;
  567. m.toUserId = s;
  568. [m deleteAll];
  569. // [m release];
  570. }
  571. +(BOOL)updateNewMsgsTo0{
  572. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID];
  573. BOOL worked=[db executeUpdate:[NSString stringWithFormat:@"update friend set newMsgs=0"]];
  574. return worked;
  575. }
  576. -(void)copyFromRoomMember:(memberData*)p{
  577. self.userId = [NSString stringWithFormat:@"%ld",p.userId];
  578. self.userNickname = p.userNickName;
  579. }
  580. // 更新最后输入
  581. - (BOOL) updateLastInput {
  582. NSString* myUserId = MY_USER_ID;
  583. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  584. [self checkTableCreatedInDb:db];
  585. NSString* sql = [NSString stringWithFormat:@"update %@ set lastInput=? where userId=?",_tableName];
  586. BOOL worked = [db executeUpdate:sql,self.lastInput,self.userId];
  587. return worked;
  588. }
  589. // 更新消息界面显示的最后一条消息
  590. - (BOOL) updateLastContent {
  591. NSString* myUserId = MY_USER_ID;
  592. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  593. [self checkTableCreatedInDb:db];
  594. NSString* sql = [NSString stringWithFormat:@"update %@ set content=? where userId=?",_tableName];
  595. BOOL worked = [db executeUpdate:sql,self.content,self.userId];
  596. return worked;
  597. }
  598. +(NSString*)getUserNameWithUserId:(NSString*)userId{
  599. if(userId==nil)
  600. return nil;
  601. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID];
  602. //获取用户名
  603. NSString* sql= [NSString stringWithFormat:@"select userNickname from friend where userId=%@",userId];
  604. FMResultSet *rs=[db executeQuery:sql];
  605. if([rs next]) {
  606. NSString* s = [rs objectForColumnName:@"userNickname"];
  607. return s;
  608. }
  609. return nil;
  610. }
  611. +(NSMutableArray *)getUserNameWithUserIdsArray:(NSArray *)userIdsArray{
  612. if (userIdsArray.count == 0) {
  613. return nil;
  614. }
  615. NSMutableArray *userNamesArray = [NSMutableArray array];
  616. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID];
  617. //获取用户名
  618. for (NSInteger i = 0; i < userIdsArray.count; i++) {
  619. NSString *userId = userIdsArray[i];
  620. NSString* sql= [NSString stringWithFormat:@"select userNickname from friend where userId=%@",userId];
  621. FMResultSet *rs=[db executeQuery:sql];
  622. if([rs next]) {
  623. NSString* s = [rs objectForColumnName:@"userNickname"];
  624. if (!s) {
  625. s = @"";
  626. }
  627. [userNamesArray addObject:s];
  628. }
  629. }
  630. if (userNamesArray.count > 0) {
  631. return userNamesArray;
  632. }
  633. return nil;
  634. }
  635. // 更新置顶时间
  636. - (BOOL) updateTopTime {
  637. NSString* myUserId = MY_USER_ID;
  638. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  639. [self checkTableCreatedInDb:db];
  640. NSString* sql = [NSString stringWithFormat:@"update %@ set topTime=? where userId=?",_tableName];
  641. BOOL worked = [db executeUpdate:sql,self.topTime,self.userId];
  642. return worked;
  643. }
  644. // 更新群组有效性
  645. - (BOOL) updateGroupInvalid {
  646. NSString* myUserId = MY_USER_ID;
  647. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  648. [self checkTableCreatedInDb:db];
  649. NSString* sql = [NSString stringWithFormat:@"update %@ set groupStatus=? where userId=?",_tableName];
  650. BOOL worked = [db executeUpdate:sql,self.groupStatus,self.userId];
  651. return worked;
  652. }
  653. // 更新用户昵称
  654. - (BOOL) updateUserNickname {
  655. NSString* myUserId = MY_USER_ID;
  656. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  657. [self checkTableCreatedInDb:db];
  658. NSString *nickName;
  659. if (self.remarkName.length > 0) {
  660. nickName = self.userNickname;
  661. }else {
  662. nickName = self.userNickname;
  663. }
  664. NSString* sql = [NSString stringWithFormat:@"update %@ set userNickname=? where userId=?",_tableName];
  665. BOOL worked = [db executeUpdate:sql,nickName,self.userId];
  666. return worked;
  667. }
  668. // 更新群groupType
  669. - (BOOL) updateGroupType {
  670. NSString* myUserId = MY_USER_ID;
  671. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  672. [self checkTableCreatedInDb:db];
  673. NSString* sql = [NSString stringWithFormat:@"update %@ set groupType=? where userId=?",_tableName];
  674. BOOL worked = [db executeUpdate:sql,self.groupType,self.userId];
  675. return worked;
  676. }
  677. // 更新群roomId
  678. - (BOOL) updateRoomId {
  679. NSString* myUserId = MY_USER_ID;
  680. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  681. [self checkTableCreatedInDb:db];
  682. NSString* sql = [NSString stringWithFormat:@"update %@ set roomId=? where userId=?",_tableName];
  683. BOOL worked = [db executeUpdate:sql,self.roomId,self.userId];
  684. return worked;
  685. }
  686. // 更新用户备注
  687. - (BOOL) updateRemarkName {
  688. NSString* myUserId = MY_USER_ID;
  689. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  690. [self checkTableCreatedInDb:db];
  691. NSString* sql = [NSString stringWithFormat:@"update %@ set remarkName=? where userId=?",_tableName];
  692. BOOL worked = [db executeUpdate:sql,self.remarkName,self.userId];
  693. return worked;
  694. }
  695. // 更新用户电话
  696. - (BOOL) updateTelephone {
  697. NSString* myUserId = MY_USER_ID;
  698. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  699. [self checkTableCreatedInDb:db];
  700. NSString* sql = [NSString stringWithFormat:@"update %@ set telephone=? where userId=?",_tableName];
  701. BOOL worked = [db executeUpdate:sql,self.telephone,self.userId];
  702. return worked;
  703. }
  704. // 更新用户聊天记录过期时间
  705. - (BOOL) updateUserChatRecordTimeOut {
  706. NSString* myUserId = MY_USER_ID;
  707. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  708. [self checkTableCreatedInDb:db];
  709. NSString* sql = [NSString stringWithFormat:@"update %@ set chatRecordTimeOut=? where userId=?",_tableName];
  710. BOOL worked = [db executeUpdate:sql,self.chatRecordTimeOut,self.userId];
  711. return worked;
  712. }
  713. // 更新列表最近一条消息记录
  714. - (BOOL) updateUserLastChatList:(NSArray *)array {
  715. NSMutableArray *userArray = [NSMutableArray array];
  716. for (NSInteger i = 0; i < array.count; i ++) {
  717. NSDictionary *dict = array[i];
  718. if ([g_xmpp.blackList containsObject:dict[@"jid"]]) {
  719. continue;
  720. }
  721. JXUserObject *user = [[JXUserObject sharedInstance] getUserById:dict[@"jid"]];
  722. NSNumber *isEncrypt = dict[@"isEncrypt"];
  723. NSString *messageId = dict[@"messageId"];
  724. long timeSend = [dict[@"timeSend"] longLongValue];
  725. NSString *content = dict[@"content"];
  726. if ([current_chat_userId isEqualToString:user.userId]) {
  727. dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(1 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
  728. [g_notify postNotificationName:kChatVCMessageSync object:@(timeSend)];
  729. });
  730. }
  731. content = [self getLastListContent:dict];
  732. if ([isEncrypt boolValue]) {
  733. NSMutableString *str = [NSMutableString string];
  734. [str appendString:APIKEY];
  735. [str appendString:[NSString stringWithFormat:@"%ld",timeSend]];
  736. [str appendString:messageId];
  737. NSString *keyStr = [g_server getMD5String:str];
  738. content = [DESUtil decryptDESStr:content key:keyStr];
  739. }else{
  740. content = content;
  741. }
  742. user.content = content;
  743. user.type = dict[@"type"];
  744. user.timeSend = [NSDate dateWithTimeIntervalSince1970:timeSend / 1000.0];
  745. if (user) {
  746. if (user.content.length > 0) {
  747. [user update];
  748. [userArray addObject:user];
  749. }
  750. }else {
  751. user = [[JXUserObject alloc] init];
  752. user.content = content;
  753. user.type = dict[@"type"];
  754. if ([dict[@"isRoom"] boolValue]) {
  755. user.roomFlag= [NSNumber numberWithInt:1];
  756. user.companyId= [NSNumber numberWithInt:0];
  757. user.status= [NSNumber numberWithInt:2];
  758. user.offlineNoPushMsg = [NSNumber numberWithInt:0];
  759. user.isAtMe = [NSNumber numberWithInt:0];
  760. }
  761. user.timeSend = [NSDate dateWithTimeIntervalSince1970:timeSend];
  762. user.userId = dict[@"jid"];
  763. user.userNickname = dict[@"toUserName"];
  764. [user insert];
  765. }
  766. }
  767. [self updateLastListContent:userArray withTransaction:YES];
  768. return YES;
  769. }
  770. - (void)updateLastListContent:(NSArray *)dataArray withTransaction:(BOOL )useTransaction{
  771. NSString* myUserId = MY_USER_ID;
  772. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  773. [self checkTableCreatedInDb:db];
  774. if (useTransaction) {
  775. [db beginTransaction];
  776. BOOL isRollBack = NO;
  777. @try {
  778. for (NSInteger i = 0; i < dataArray.count; i++) {
  779. JXUserObject *user = dataArray[i];
  780. if (user.roomId.length > 0) {
  781. user.roomFlag= [NSNumber numberWithInt:1];
  782. user.companyId= [NSNumber numberWithInt:0];
  783. if (!user.status) {
  784. user.status= [NSNumber numberWithInt:2];
  785. }
  786. }
  787. if(!user.timeSend)
  788. user.timeSend = [NSDate date];
  789. if (!user.companyId) {
  790. user.companyId = [NSNumber numberWithInt:0];
  791. }
  792. if ([user.userId intValue] == [SHIKU_TRANSFER intValue]) {
  793. user.userNickname = Localized(@"JX_PaymentNo.");
  794. }
  795. if ([user.topTime timeIntervalSince1970] > 0) {
  796. user.topTime = self.topTime;
  797. }else {
  798. user.topTime = nil;
  799. }
  800. NSString* sql = [NSString stringWithFormat:@"update %@ set userNickname=?,remarkName=?,describe=?,role=?,userDescription=?,userHead=?,roomFlag=?,type=?,companyId=?,content=?,timeCreate=?,status=?,userType=?,isMySend=?,newMsgs=?,timeSend=?,downloadTime=?,roomId=?,showRead=?,showMember=?,allowSendCard=?,allowInviteFriend=?,allowUploadFile=?,allowConference=?,allowSpeakCourse=?,isNeedVerify=?,topTime=?,groupStatus=?,isOnLine=?,isOpenReadDel=?,isSendRecipt=?,isDevice=?,chatRecordTimeOut=?,offlineNoPushMsg=?,isAtMe=?,talkTime=?,joinTime=? where userId=?",_tableName];
  801. [db executeUpdate:sql,user.userNickname,user.remarkName,user.describe,user.role,user.userDescription,user.userHead,user.roomFlag,user.type,user.companyId,user.content,user.timeCreate,user.status,user.userType,user.isMySend,user.msgsNew,user.timeSend,user.downloadTime,user.roomId,user.showRead,user.showMember,user.allowSendCard,user.allowInviteFriend,user.allowUploadFile,user.allowConference,user.allowSpeakCourse,user.isNeedVerify,user.topTime,user.groupStatus,user.isOnLine,user.isOpenReadDel,user.isSendRecipt,user.isDevice,user.chatRecordTimeOut,user.offlineNoPushMsg,user.isAtMe,user.talkTime,user.joinTime,user.userId];
  802. }
  803. } @catch (NSException *exception) {
  804. isRollBack = YES;
  805. [db rollback];
  806. } @finally {
  807. if (!isRollBack) {
  808. [db commit];
  809. [db close];
  810. [g_App copyDbWithUserId:MY_USER_ID];
  811. }else{
  812. [db close];
  813. [self updateLastListContent:dataArray withTransaction:NO];
  814. }
  815. }
  816. }else{
  817. for (NSInteger i = 0; i < dataArray.count; i++) {
  818. JXUserObject *user = dataArray[i];
  819. if(!user.timeSend)
  820. user.timeSend = [NSDate date];
  821. if (!user.companyId) {
  822. user.companyId = [NSNumber numberWithInt:0];
  823. }
  824. if ([user.userId intValue] == [SHIKU_TRANSFER intValue]) {
  825. user.userNickname = Localized(@"JX_PaymentNo.");
  826. }
  827. if ([user.topTime timeIntervalSince1970] > 0) {
  828. user.topTime = self.topTime;
  829. }else {
  830. user.topTime = nil;
  831. }
  832. NSString* sql = [NSString stringWithFormat:@"update %@ set userNickname=?,remarkName=?,describe=?,role=?,userDescription=?,userHead=?,roomFlag=?,type=?,companyId=?,content=?,timeCreate=?,status=?,userType=?,isMySend=?,newMsgs=?,timeSend=?,downloadTime=?,roomId=?,showRead=?,showMember=?,allowSendCard=?,allowInviteFriend=?,allowUploadFile=?,allowConference=?,allowSpeakCourse=?,isNeedVerify=?,topTime=?,groupStatus=?,isOnLine=?,isOpenReadDel=?,isSendRecipt=?,isDevice=?,chatRecordTimeOut=?,offlineNoPushMsg=?,isAtMe=?,talkTime=?,joinTime=? where userId=?",_tableName];
  833. BOOL worked = [db executeUpdate:sql,user.userNickname,user.remarkName,user.describe,user.role,user.userDescription,user.userHead,user.roomFlag,user.type,user.companyId,user.content,user.timeCreate,user.status,user.userType,user.isMySend,user.msgsNew,user.timeSend,user.downloadTime,user.roomId,user.showRead,user.showMember,user.allowSendCard,user.allowInviteFriend,user.allowUploadFile,user.allowConference,user.allowSpeakCourse,user.isNeedVerify,user.topTime,user.groupStatus,user.isOnLine,user.isOpenReadDel,user.isSendRecipt,user.isDevice,user.chatRecordTimeOut,user.offlineNoPushMsg,user.isAtMe,user.talkTime,user.joinTime,user.userId];
  834. if (!worked) {
  835. NSLog(@"存失败");
  836. }
  837. }
  838. [db close];
  839. [g_App copyDbWithUserId:MY_USER_ID];
  840. }
  841. }
  842. - (NSString *)getLastListContent:(NSDictionary *)dict {
  843. int type = [dict[@"type"] intValue];
  844. NSString *content = dict[@"content"];
  845. NSString *fromUserId = dict[@"from"];
  846. NSString *fromUserName = dict[@"fromUserName"];
  847. if (!fromUserName) {
  848. fromUserName = @"";
  849. }
  850. NSString *toUserId = dict[@"to"];
  851. NSString *toUserName = dict[@"toUserName"];
  852. if (!toUserName) {
  853. toUserName = @"";
  854. }
  855. switch (type) {
  856. case kWCMessageTypeWithdraw:{
  857. if ([dict[@"isRoom"] boolValue]) {
  858. if ([fromUserId isEqualToString:MY_USER_ID]) {
  859. content = Localized(@"JX_AlreadyWithdraw");
  860. }else {
  861. content = [NSString stringWithFormat:@"%@ %@",fromUserName, Localized(@"JX_OtherWithdraw")];
  862. }
  863. }else {
  864. if ([fromUserId isEqualToString:MY_USER_ID]) {
  865. content = Localized(@"JX_AlreadyWithdraw");
  866. }else {
  867. content = [NSString stringWithFormat:@"%@ %@",fromUserName, Localized(@"JX_OtherWithdraw")];
  868. }
  869. }
  870. }
  871. break;
  872. case kWCMessageTypeShare:
  873. content = [NSString stringWithFormat:@"[%@]",Localized(@"JXLink")];
  874. break;
  875. case kWCMessageTypeRedPacketReceive:
  876. content = [NSString stringWithFormat:@"%@%@",fromUserName,Localized(@"JXRed_whoGet")];
  877. break;
  878. case kWCMessageTypeRedPacketReturn:
  879. content = [NSString stringWithFormat:@"%@",Localized(@"JX_ RedEnvelopeExpired")];
  880. break;
  881. case kWCMessageTypeGroupFileUpload:
  882. content = [NSString stringWithFormat:@"%@%@",fromUserName,Localized(@"JXMessage_fileUpload")];
  883. break;
  884. case kWCMessageTypeGroupFileDelete:
  885. content = [NSString stringWithFormat:@"%@%@",fromUserName,Localized(@"JXMessage_fileDelete")];
  886. break;
  887. case kWCMessageTypeGroupFileDownload:
  888. content = [NSString stringWithFormat:@"%@%@",fromUserName,Localized(@"JXMessage_fileDownload")];
  889. break;
  890. case kRoomRemind_RoomName:
  891. content = [NSString stringWithFormat:@"%@%@%@",fromUserName,Localized(@"JXMessageObject_UpdateRoomName"),content];
  892. break;
  893. case kRoomRemind_NickName:{
  894. content = [NSString stringWithFormat:@"%@%@%@",fromUserName,Localized(@"JXMessageObject_UpdateNickName"),content];
  895. }
  896. break;
  897. case kRoomRemind_DelRoom:
  898. if ([toUserId isEqualToString:MY_USER_ID]) {
  899. content = [NSString stringWithFormat:Localized(@"JX_DissolutionGroup"),fromUserName];
  900. }else {
  901. content = [NSString stringWithFormat:@"%@%@:%@",fromUserName,Localized(@"JXMessage_delRoom"),content];
  902. }
  903. break;
  904. case kRoomRemind_AddMember:
  905. if([toUserId isEqualToString:fromUserId])
  906. content = [NSString stringWithFormat:@"%@%@",fromUserName,Localized(@"JXMessageObject_GroupChat")];
  907. else
  908. content = [NSString stringWithFormat:@"%@%@%@",fromUserName,Localized(@"JXMessageObject_InterFriend"),toUserName];
  909. break;
  910. case kLiveRemind_ExitRoom:
  911. if([toUserId isEqualToString:fromUserId]){
  912. content = [NSString stringWithFormat:@"%@%@",fromUserName,Localized(@"EXITED_LIVE_ROOM")];//退出
  913. }else{
  914. content = [NSString stringWithFormat:@"%@%@",toUserName,Localized(@"JX_LiveVC_kickLive")];//被踢出
  915. }
  916. break;
  917. case kRoomRemind_DelMember:
  918. if([toUserId isEqualToString:fromUserId]){
  919. content = [NSString stringWithFormat:@"%@%@",fromUserName,Localized(@"JXMessageObject_OutGroupChat")];
  920. }else{
  921. if ([toUserId isEqualToString:MY_USER_ID]) {
  922. content = [NSString stringWithFormat:Localized(@"JX_OutOfTheGroup"),fromUserName];
  923. }else {
  924. if ([fromUserName isEqualToString:toUserName]) {
  925. content = [NSString stringWithFormat:@"%@%@",fromUserName,Localized(@"JXRoomMemberVC_OutPutRoom")];
  926. }else {
  927. content = [NSString stringWithFormat:@"%@%@%@",fromUserName,Localized(@"JXMessageObject_KickOut"),toUserName];
  928. }
  929. }
  930. }
  931. break;
  932. case kRoomRemind_NewNotice:
  933. content = [NSString stringWithFormat:@"%@%@%@",fromUserName,Localized(@"JXMessageObject_AddNewAdv"),content];
  934. break;
  935. case kLiveRemind_ShatUp:
  936. case kRoomRemind_DisableSay:{
  937. if([content longLongValue]==0){
  938. content = [NSString stringWithFormat:@"%@%@%@%@",fromUserName,Localized(@"JXMessageObject_Yes"),toUserName,Localized(@"JXMessageObject_CancelGag")];
  939. }else{
  940. NSDate* d = [NSDate dateWithTimeIntervalSince1970:[content longLongValue]];
  941. NSString* t = [TimeUtil formatDate:d format:@"MM-dd HH:mm"];
  942. content = [NSString stringWithFormat:@"%@%@%@%@%@",fromUserName,Localized(@"JXMessageObject_Yes"),toUserName,Localized(@"JXMessageObject_SetGagWithTime"),t];
  943. d = nil;
  944. }
  945. break;
  946. }
  947. case kLiveRemind_SetManager:
  948. case kRoomRemind_SetManage:{
  949. if ([content integerValue] == 1) {
  950. content = [NSString stringWithFormat:@"%@%@%@%@",Localized(@"JXGroup_Owner"),Localized(@"JXSettingVC_Set"),toUserName,Localized(@"JXMessage_admin")];
  951. }else {
  952. content = [NSString stringWithFormat:@"%@%@%@",Localized(@"JXGroup_Owner"),Localized(@"CANCEL_ADMINISTRATOR"),toUserName];
  953. }
  954. break;
  955. }
  956. case kRoomRemind_EnterLiveRoom:{
  957. content = [NSString stringWithFormat:@"%@%@",toUserName,Localized(@"Enter_LiveRoom")];//加入房间消息
  958. break;
  959. }
  960. case kRoomRemind_ShowRead:{
  961. if ([content integerValue] == 1)
  962. content = [NSString stringWithFormat:@"%@%@%@",Localized(@"JXGroup_Owner"),Localized(@"JX_Enable"),Localized(@"JX_RoomReadMode")];
  963. else
  964. content = [NSString stringWithFormat:@"%@%@%@",Localized(@"JXGroup_Owner"),Localized(@"JX_Disable"),Localized(@"JX_RoomReadMode")];
  965. break;
  966. }
  967. case kRoomRemind_NeedVerify:{
  968. if (!content || content.length <= 0) {
  969. content = Localized(@"JX_GroupInvitationConfirmation");
  970. }else {
  971. if ([content integerValue] == 1)
  972. content = Localized(@"JX_GroupOwnersOpenValidation");
  973. else
  974. content = Localized(@"JX_GroupOwnersCloseValidation");
  975. }
  976. break;
  977. }
  978. case kRoomRemind_IsLook:{
  979. if ([content integerValue] == 0)
  980. content = Localized(@"JX_GroupOwnersPublicGroup");
  981. else
  982. content = Localized(@"JX_GroupOwnersPrivateGroup");
  983. break;
  984. }
  985. case kRoomRemind_ShowMember:{
  986. if ([content integerValue] == 1)
  987. content = Localized(@"JX_GroupOwnersShowMembers");
  988. else
  989. content = Localized(@"JX_GroupOwnersNotShowMembers");
  990. break;
  991. }
  992. case kRoomRemind_allowSendCard:{
  993. if ([content integerValue] == 1)
  994. content = Localized(@"JX_ManagerOpenChat");
  995. else
  996. content = Localized(@"JX_ManagerOffChat");
  997. break;
  998. }
  999. case kRoomRemind_RoomAllBanned:{
  1000. if ([content integerValue] > 0)
  1001. content = Localized(@"JX_ManagerOpenSilence");
  1002. else
  1003. content = Localized(@"JX_ManagerOffSilence");
  1004. break;
  1005. }
  1006. case kRoomRemind_RoomAllowInviteFriend:{
  1007. if ([content integerValue] > 0)
  1008. content = Localized(@"JX_ManagerOpenInviteFriends");
  1009. else
  1010. content = Localized(@"JX_ManagerOffInviteFriends");
  1011. break;
  1012. }
  1013. case kRoomRemind_RoomAllowUploadFile:{
  1014. if ([content integerValue] > 0)
  1015. content = Localized(@"JX_ManagerOpenSharedFiles");
  1016. else
  1017. content = Localized(@"JX_ManagerOffSharedFiles");
  1018. break;
  1019. }
  1020. case kRoomRemind_RoomAllowConference:{
  1021. if ([content integerValue] > 0)
  1022. content = Localized(@"JX_ManagerOpenMeetings");
  1023. else
  1024. content = Localized(@"JX_ManagerOffMeetings");
  1025. break;
  1026. }
  1027. case kRoomRemind_RoomAllowSpeakCourse:{
  1028. if ([content integerValue] > 0)
  1029. content = Localized(@"JX_ManagerOpenLectures");
  1030. else
  1031. content = Localized(@"JX_ManagerOffLectures");
  1032. break;
  1033. }
  1034. case kRoomRemind_RoomTransfer:{
  1035. content = [NSString stringWithFormat:@"\"%@\"%@", toUserName,Localized(@"JX_NewGroupManager")];
  1036. break;
  1037. }
  1038. case kRoomRemind_SetInvisible:{
  1039. if ([content integerValue] == 1) {
  1040. content = [NSString stringWithFormat:@"%@%@%@%@",fromUserName,Localized(@"JXSettingVC_Set"),toUserName,Localized(@"JX_ForTheInvisibleMan")];
  1041. }else if ([content integerValue] == -1){
  1042. content = [NSString stringWithFormat:@"%@%@%@",fromUserName,Localized(@"JX_EliminateTheInvisible"),toUserName];
  1043. }else if ([content integerValue] == 2){
  1044. content = [NSString stringWithFormat:@"%@%@%@%@",fromUserName,Localized(@"JXSettingVC_Set"),toUserName,@"为监控人"];
  1045. }else if ([content integerValue] == 0){
  1046. content = [NSString stringWithFormat:@"%@%@%@",fromUserName,@"取消监控人",toUserName];
  1047. }
  1048. break;
  1049. }
  1050. case kRoomRemind_RoomDisable:{
  1051. if ([content integerValue] == 1) {
  1052. content = [NSString stringWithFormat:@"%@",Localized(@"JX_ThisGroupHasBeenDisabled")];
  1053. }else {
  1054. content = [NSString stringWithFormat:@"%@",Localized(@"JX_GroupNotUse")];
  1055. }
  1056. break;
  1057. }
  1058. case kRoomRemind_SetRecordTimeOut:{
  1059. NSArray *pickerArr = @[Localized(@"JX_Forever"), Localized(@"JX_OneHour"), Localized(@"JX_OneDay"), Localized(@"JX_OneWeeks"), Localized(@"JX_OneMonth"), Localized(@"JX_OneQuarter"), Localized(@"JX_OneYear")];
  1060. double outTime = [content doubleValue];
  1061. NSString *str;
  1062. if (outTime <= 0) {
  1063. str = pickerArr[0];
  1064. }else if (outTime == 0.04) {
  1065. str = pickerArr[1];
  1066. }else if (outTime == 1) {
  1067. str = pickerArr[2];
  1068. }else if (outTime == 7) {
  1069. str = pickerArr[3];
  1070. }else if (outTime == 30) {
  1071. str = pickerArr[4];
  1072. }else if (outTime == 90) {
  1073. str = pickerArr[5];
  1074. }else{
  1075. str = pickerArr[6];
  1076. }
  1077. content = [NSString stringWithFormat:@"%@%@",Localized(@"JX_GroupManagerSetMsgDelTime"),str];
  1078. }
  1079. default:
  1080. break;
  1081. }
  1082. return content;
  1083. }
  1084. // 更新群组全员禁言时间
  1085. - (BOOL) updateGroupTalkTime {
  1086. NSString* myUserId = MY_USER_ID;
  1087. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1088. [self checkTableCreatedInDb:db];
  1089. NSString* sql = [NSString stringWithFormat:@"update %@ set talkTime=? where userId=?",_tableName];
  1090. BOOL worked = [db executeUpdate:sql,self.talkTime,self.userId];
  1091. return worked;
  1092. }
  1093. // 更新是否开启阅后即焚标志
  1094. - (BOOL) updateIsOpenReadDel {
  1095. NSString* myUserId = MY_USER_ID;
  1096. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1097. [self checkTableCreatedInDb:db];
  1098. NSString* sql = [NSString stringWithFormat:@"update %@ set isOpenReadDel=? where userId=?",_tableName];
  1099. BOOL worked = [db executeUpdate:sql,self.isOpenReadDel,self.userId];
  1100. return worked;
  1101. }
  1102. // 更新消息免打扰
  1103. - (BOOL) updateOfflineNoPushMsg {
  1104. NSString* myUserId = MY_USER_ID;
  1105. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1106. [self checkTableCreatedInDb:db];
  1107. NSString* sql = [NSString stringWithFormat:@"update %@ set offlineNoPushMsg=? where userId=?",_tableName];
  1108. BOOL worked = [db executeUpdate:sql,self.offlineNoPushMsg,self.userId];
  1109. return worked;
  1110. }
  1111. // 更新@我
  1112. - (BOOL) updateIsAtMe{
  1113. NSString* myUserId = MY_USER_ID;
  1114. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1115. [self checkTableCreatedInDb:db];
  1116. NSString* sql = [NSString stringWithFormat:@"update %@ set isAtMe=? where userId=?",_tableName];
  1117. BOOL worked = [db executeUpdate:sql,self.isAtMe,self.userId];
  1118. return worked;
  1119. }
  1120. // 更新userType
  1121. - (BOOL) updateUserType {
  1122. NSString* myUserId = MY_USER_ID;
  1123. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1124. [self checkTableCreatedInDb:db];
  1125. NSString* sql = [NSString stringWithFormat:@"update %@ set userType=? where userId=?",_tableName];
  1126. BOOL worked = [db executeUpdate:sql,self.userType,self.userId];
  1127. return worked;
  1128. }
  1129. // 更新创建者
  1130. - (BOOL)updateCreateUser {
  1131. NSString* myUserId = MY_USER_ID;
  1132. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1133. [self checkTableCreatedInDb:db];
  1134. NSString* sql = [NSString stringWithFormat:@"update %@ set createUserId=? where userId=?",_tableName];
  1135. BOOL worked = [db executeUpdate:sql,self.createUserId,self.userId];
  1136. return worked;
  1137. }
  1138. // 更新群组设置
  1139. - (BOOL)updateGroupSetting {
  1140. NSString* myUserId = MY_USER_ID;
  1141. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1142. [self checkTableCreatedInDb:db];
  1143. NSString* sql = [NSString stringWithFormat:@"update %@ set showRead=?,allowSendCard=?,allowConference=?,allowSpeakCourse=?,isNeedVerify=?,talkTime=? where userId=?",_tableName];
  1144. BOOL worked = [db executeUpdate:sql,self.showRead,self.allowSendCard,self.allowConference,self.allowSpeakCourse,self.isNeedVerify,self.talkTime,self.userId];
  1145. return worked;
  1146. }
  1147. // 更新好友关系
  1148. - (BOOL)updateStatus {
  1149. NSString* myUserId = MY_USER_ID;
  1150. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1151. [self checkTableCreatedInDb:db];
  1152. NSString* sql = [NSString stringWithFormat:@"update %@ set status=? where userId=?",_tableName];
  1153. BOOL worked = [db executeUpdate:sql,self.status,self.userId];
  1154. return worked;
  1155. }
  1156. // 更新新消息数量
  1157. - (BOOL)updateNewMsgNum {
  1158. NSString* myUserId = MY_USER_ID;
  1159. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1160. [self checkTableCreatedInDb:db];
  1161. NSString* sql = [NSString stringWithFormat:@"update %@ set newMsgs=? where userId=?",_tableName];
  1162. BOOL worked = [db executeUpdate:sql,self.msgsNew,self.userId];
  1163. return worked;
  1164. }
  1165. // 更新我的设备是否在线
  1166. - (BOOL)updateIsOnLine {
  1167. NSString* myUserId = MY_USER_ID;
  1168. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1169. [self checkTableCreatedInDb:db];
  1170. NSString* sql = [NSString stringWithFormat:@"update %@ set isOnLine=? where userId=?",_tableName];
  1171. BOOL worked = [db executeUpdate:sql,self.isOnLine,self.userId];
  1172. return worked;
  1173. }
  1174. // 更新群组最后群成员加入时间
  1175. - (BOOL)updateJoinTime {
  1176. NSString* myUserId = MY_USER_ID;
  1177. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1178. [self checkTableCreatedInDb:db];
  1179. NSString* sql = [NSString stringWithFormat:@"update %@ set joinTime=? where userId=?",_tableName];
  1180. BOOL worked = [db executeUpdate:sql,self.joinTime,self.userId];
  1181. return worked;
  1182. }
  1183. // 删除用户过期聊天记录
  1184. - (BOOL) deleteUserChatRecordTimeOutMsg {
  1185. NSMutableArray *array = [[JXMessageObject sharedInstance] fetchRecentChat];
  1186. for (NSInteger i = 0; i < array.count; i ++) {
  1187. JXMsgAndUserObject *userObj = array[i];
  1188. [[JXMessageObject sharedInstance] deleteTimeOutMsg:userObj.user.userId chatRecordTimeOut:userObj.user.chatRecordTimeOut];
  1189. }
  1190. return YES;
  1191. }
  1192. - (BOOL) deleteAllUser {
  1193. NSString* myUserId = MY_USER_ID;
  1194. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1195. [self checkTableCreatedInDb:db];
  1196. NSString *sql = [NSString stringWithFormat:@"delete from %@ where length(userId) > 5 and length(userId) < 10",_tableName];
  1197. BOOL worked=[db executeUpdate:sql,self.userId];
  1198. return worked;
  1199. }
  1200. // 清除所有黑名单好友
  1201. - (BOOL)deleteAllBlackUser {
  1202. NSString* myUserId = MY_USER_ID;
  1203. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1204. [self checkTableCreatedInDb:db];
  1205. NSString *sql = [NSString stringWithFormat:@"delete from %@ where status=-1",_tableName];
  1206. BOOL worked=[db executeUpdate:sql];
  1207. return worked;
  1208. }
  1209. //插入已拨打的电话号码
  1210. - (BOOL) insertPhone:(NSString *)phone time:(NSDate *)time {
  1211. NSString* myUserId = MY_USER_ID;
  1212. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1213. [self checkPhoneTableCreatedInDb:db];
  1214. FMResultSet * rs = [db executeQuery:[NSString stringWithFormat:@"select * from telePhone where phone=?"],phone];
  1215. BOOL flag = NO;
  1216. if([rs next]) {
  1217. flag = YES;
  1218. }
  1219. // FMDBQuickCheck(worked);
  1220. if (!flag) {
  1221. NSString *insertStr=[NSString stringWithFormat:@"INSERT INTO '%@' ('phone','time') VALUES (?,?)",@"telePhone"];
  1222. BOOL worked = [db executeUpdate:insertStr,phone, time];
  1223. return worked;
  1224. }
  1225. return YES;
  1226. }
  1227. // 删除已拨打的电话号码
  1228. - (BOOL) deletePhone:(NSString *)phone {
  1229. NSString* myUserId = MY_USER_ID;
  1230. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1231. [self checkPhoneTableCreatedInDb:db];
  1232. BOOL worked = [db executeUpdate:[NSString stringWithFormat:@"delete from telePhone where phone=?"],phone];
  1233. return worked;
  1234. }
  1235. - (NSMutableDictionary *) getPhoneDic {
  1236. NSString* myUserId = MY_USER_ID;
  1237. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1238. [self checkPhoneTableCreatedInDb:db];
  1239. NSString* sql = [NSString stringWithFormat:@"select * from telePhone"];
  1240. FMResultSet *rs = [db executeQuery:sql];
  1241. NSMutableDictionary *dict = [NSMutableDictionary dictionary];
  1242. while ([rs next]) {
  1243. [dict setObject:[rs dateForColumn:@"time"] forKey:[rs stringForColumn:@"phone"]];
  1244. }
  1245. return dict;
  1246. }
  1247. -(BOOL)checkPhoneTableCreatedInDb:(FMDatabase *)db
  1248. {
  1249. NSString *createStr=[NSString stringWithFormat:@"CREATE TABLE IF NOT EXISTS '%@' ('phone' VARCHAR, 'time' DATETIME)",@"telePhone"];
  1250. BOOL worked = [db executeUpdate:createStr];
  1251. // FMDBQuickCheck(worked);
  1252. return worked;
  1253. }
  1254. // 更新好友DH公钥和RSA公钥
  1255. - (BOOL)updateDHPublicKeyAndRSAPublicKey {
  1256. NSString* myUserId = MY_USER_ID;
  1257. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1258. [self checkTableCreatedInDb:db];
  1259. NSString* sql = [NSString stringWithFormat:@"update %@ set publicKeyDH=?,publicKeyRSARoom=? where userId=?",_tableName];
  1260. BOOL worked = [db executeUpdate:sql,self.publicKeyDH,self.publicKeyRSARoom,self.userId];
  1261. return worked;
  1262. }
  1263. //查找好友
  1264. - (NSMutableArray *)searchContacts:(NSString *)searchtext{
  1265. NSString *sql = [NSString stringWithFormat:@"select * from friend where (status=2 and companyId=0 and roomFlag=0 and isDevice=0) and ((userNickname like '%%%@%%') or (userId like '%%%@%%')) order by timeCreate",searchtext,searchtext];
  1266. return [self doFetch:sql];
  1267. }
  1268. //查找群组昵称
  1269. - (NSMutableArray *)searchGroup:(NSString *)searchtext withContent:(NSString *)content{
  1270. NSString *sql = [NSString stringWithFormat:@"select * from friend where roomFlag=1 and %@ like '%%%@%%' order by timeCreate",content,searchtext];
  1271. return [self doFetch:sql];
  1272. }
  1273. //查找成员
  1274. - (NSMutableArray *)searchGroupMember:(NSString *)searchtext{
  1275. NSString *sql = [NSString stringWithFormat:@"select * from friend where roomFlag=1"];
  1276. NSMutableArray *array = [self doFetch:sql];
  1277. NSMutableArray *roomIdArray = [NSMutableArray array];
  1278. for (JXUserObject *user in array) {
  1279. [roomIdArray addObject:user.roomId];
  1280. }
  1281. NSMutableArray *searchArray = [NSMutableArray array];
  1282. for (NSInteger i = 0; i<roomIdArray.count; i++) {
  1283. memberData *member = [memberData fetchMembersWithText:searchtext withRoomId:roomIdArray[i]];
  1284. if (member != nil) {
  1285. [searchArray addObject:member];
  1286. }
  1287. }
  1288. return searchArray;
  1289. }
  1290. //根据roomId查找群组
  1291. - (JXUserObject *)groupForRoomId:(NSString *)roomId{
  1292. NSString *sql = [NSString stringWithFormat:@"select * from friend where roomFlag=1 and roomId='%@'",roomId];
  1293. return [self doFetchOneGroup:sql];
  1294. }
  1295. - (JXUserObject *)doFetchOneGroup:(NSString*)sql
  1296. { JXUserObject *group = [[JXUserObject alloc] init];
  1297. NSString* myUserId = MY_USER_ID;
  1298. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1299. [super checkTableCreatedInDb:db];
  1300. FMResultSet *rs=[db executeQuery:sql];
  1301. while ([rs next]) {
  1302. JXUserObject *user=[[JXUserObject alloc] init];
  1303. [super userFromDataset:user rs:rs];
  1304. group = user;
  1305. }
  1306. [rs close];
  1307. return group;
  1308. }
  1309. //获取公众号
  1310. - (NSMutableArray *)searchPublic:(NSString *)searchtext{
  1311. NSString *sql = [NSString stringWithFormat:@"select * from friend where userType=2 and userNickname like '%%%@%%' order by timeCreate",searchtext];
  1312. return [self doFetch:sql];
  1313. }
  1314. //获取联系人和群聊
  1315. - (NSMutableArray *)getAllContactsAndGroup{
  1316. NSString *sql = [NSString stringWithFormat:@"select * from friend where ((status=2 or status=0) and companyId=0 and roomFlag=0 and isDevice=0) or roomFlag = 1 order by timeCreate"];
  1317. return [self doFetch:sql];
  1318. }
  1319. //获取消息
  1320. - (NSMutableDictionary *)searchChatRecordWithText:(NSString *)text{
  1321. NSMutableDictionary *allMsg = [NSMutableDictionary dictionary];
  1322. NSMutableArray<JXUserObject *> *all = [self getAllContactsAndGroup];
  1323. for (NSInteger i = 0; i<all.count; i++) {
  1324. NSMutableArray *array = [self getSearchMsgWithUserId:all[i].userId withSearchText:text];
  1325. [allMsg setObject:array forKey:all[i].userId];
  1326. }
  1327. return allMsg;
  1328. }
  1329. - (NSMutableArray *)getSearchMsgWithUserId:(NSString *)userId withSearchText:(NSString *)searchtext{
  1330. NSString *sql = [NSString stringWithFormat:@"select * from msg_%@ where content like '%%%@%%' and type=1 order by timeSend desc",userId,searchtext];
  1331. NSMutableArray *array = [[NSMutableArray alloc] init];
  1332. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID];
  1333. FMResultSet *rs=[db executeQuery:sql];
  1334. while ([rs next]) {
  1335. JXMessageObject *p=[[JXMessageObject alloc] init];
  1336. [p fromRs:rs];
  1337. NSString *content = p.content;
  1338. NSMutableArray *contentArray = [NSMutableArray array];
  1339. [self getMessageRange:content :contentArray];
  1340. NSMutableArray *stringArray = [NSMutableArray array];
  1341. _num = 0;
  1342. [self splicingString:contentArray inArray:stringArray];
  1343. for (NSString *object in stringArray) {
  1344. if ([object hasSuffix:@"]"]&&[object hasPrefix:@"["]) {
  1345. }else{
  1346. if ([object localizedCaseInsensitiveContainsString:searchtext]) {
  1347. [array addObject:p];
  1348. break;
  1349. }
  1350. }
  1351. }
  1352. }
  1353. return array;
  1354. }
  1355. // 更新群组秘钥
  1356. - (BOOL)updateChatKeyGroup {
  1357. NSString* myUserId = MY_USER_ID;
  1358. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1359. [self checkTableCreatedInDb:db];
  1360. NSString* sql = [NSString stringWithFormat:@"update %@ set chatKeyGroup=? where userId=?",_tableName];
  1361. BOOL worked = [db executeUpdate:sql,self.chatKeyGroup,self.userId];
  1362. return worked;
  1363. }
  1364. //排除表情包
  1365. - (void)getMessageRange:(NSString*)message :(NSMutableArray*)array {
  1366. NSRange range=[message rangeOfString: @"["];
  1367. NSRange range1=[message rangeOfString: @"]"];
  1368. // 动画过滤
  1369. if ([message isEqualToString:[NSString stringWithFormat:@"[%@]",Localized(@"emojiVC_Emoji")]]) {
  1370. [array addObject:message];
  1371. return;
  1372. }
  1373. //判断当前字符串是否还有表情的标志。
  1374. if (range.length>0 && range1.length>0 && range1.location > range.location) {
  1375. if (range.location > 0) {
  1376. NSString *str = [message substringToIndex:range.location];
  1377. NSString *str1 = [message substringFromIndex:range.location];
  1378. [array addObject:str];
  1379. [self getMessageRange:str1 :array];
  1380. }else {
  1381. NSString *emojiString = [message substringWithRange:NSMakeRange(range.location + 1, range1.location - 1)];
  1382. BOOL isEmoji = NO;
  1383. NSString *str;
  1384. NSString *str1;
  1385. for (NSMutableDictionary *dic in g_constant.emojiArray) {
  1386. NSString *emoji = [dic objectForKey:@"english"];
  1387. if ([emoji isEqualToString:emojiString]) {
  1388. isEmoji = YES;
  1389. break;
  1390. }
  1391. }
  1392. if (isEmoji) {
  1393. str = [message substringWithRange:NSMakeRange(range.location, range1.location + 1)];
  1394. str1 = [message substringFromIndex:range1.location + 1];
  1395. [array addObject:str];
  1396. }else{
  1397. NSString *posString = [message substringWithRange:NSMakeRange(range.location + 1, range1.location)];
  1398. NSRange posRange = [posString rangeOfString:@"["];
  1399. if (posRange.location != NSNotFound) {
  1400. str = [message substringToIndex:posRange.location + 1];
  1401. str1 = [message substringFromIndex:posRange.location + 1];
  1402. [array addObject:str];
  1403. }else{
  1404. str = [message substringToIndex:range.location + 1];
  1405. str1 = [message substringFromIndex:range.location + 1];
  1406. [array addObject:str];
  1407. }
  1408. }
  1409. [self getMessageRange:str1 :array];
  1410. }
  1411. }else if (range.length>0 && range1.length>0 && range1.location < range.location){
  1412. NSString *str = [message substringToIndex:range1.location + 1];
  1413. NSString *str1 = [message substringFromIndex:range1.location + 1];
  1414. [array addObject:str];
  1415. [self getMessageRange:str1 :array];
  1416. }else if (message != nil) {
  1417. [array addObject:message];
  1418. }
  1419. }
  1420. //拼接字符串
  1421. - (void)splicingString:(NSMutableArray *)array inArray:(NSMutableArray *)contentArray{
  1422. if (_num >= array.count) {
  1423. return;
  1424. }
  1425. NSString *str = [NSString string];
  1426. for (NSInteger i = _num; i < array.count; i++) {
  1427. NSString *object = array[i];
  1428. if ([object hasSuffix:@"]"]&&[object hasPrefix:@"["]) {
  1429. [contentArray addObject:str];
  1430. [contentArray addObject:object];
  1431. _num = i + 1;
  1432. break;
  1433. }else{
  1434. _num = i + 1;
  1435. str = [str stringByAppendingString:object];
  1436. if (_num >= array.count) {
  1437. [contentArray addObject:str];
  1438. return;
  1439. }
  1440. }
  1441. }
  1442. [self splicingString:array inArray:contentArray];
  1443. }
  1444. - (NSMutableArray *)fetchAllSearchRecordWithTable:(NSString *)tableName{
  1445. FMDatabase *db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID];
  1446. NSString *str = [NSString stringWithFormat:@"CREATE TABLE IF NOT EXISTS '%@'('ID' INTEGER PRIMARY KEY AUTOINCREMENT,'record' TEXT NOT NULL)",tableName];
  1447. BOOL success = [db executeUpdate:str];
  1448. if (!success) {
  1449. NSLog(@"创建搜索记录表失败");
  1450. }
  1451. NSString *allRecord = [NSString stringWithFormat:@"select * from '%@' order by ID",tableName];
  1452. FMResultSet *rs = [db executeQuery:allRecord];
  1453. NSMutableArray *array = [NSMutableArray array];
  1454. while ([rs next]) {
  1455. NSString *record = [rs stringForColumn:@"record"];
  1456. if (record != nil && record != NULL) {
  1457. [array addObject:record];
  1458. }
  1459. }
  1460. return array;
  1461. }
  1462. - (BOOL)insertSearchRecord:(NSString *)searchRecord withTable:(NSString *)tableName{
  1463. FMDatabase *db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID];
  1464. NSString *create = [NSString stringWithFormat:@"CREATE TABLE IF NOT EXISTS '%@'('ID' INTEGER PRIMARY KEY AUTOINCREMENT,'record' TEXT NOT NULL)",tableName];
  1465. BOOL createSuccess = [db executeUpdate:create];
  1466. if (!createSuccess) {
  1467. NSLog(@"创建搜索记录表失败");
  1468. }
  1469. [self deleteOneSearchRecord:searchRecord withTable:tableName];
  1470. NSString *record = [NSString stringWithFormat:@"INSERT INTO '%@' (record) VALUES (?)",tableName];
  1471. return [db executeUpdate:record,searchRecord];
  1472. }
  1473. - (BOOL)deleteOneSearchRecord:(NSString *)searchRecord withTable:(NSString *)tableName{
  1474. FMDatabase *db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID];
  1475. NSString *deleteOne = [NSString stringWithFormat:@"delete from '%@' where record = '%@'",tableName,searchRecord];
  1476. return [db executeUpdate:deleteOne];
  1477. }
  1478. - (BOOL)deleteAllSearchRecordWithTable:(NSString *)tableName{
  1479. FMDatabase *db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID];
  1480. NSString *deleteAll = [NSString stringWithFormat:@"delete from '%@'",tableName];
  1481. return [db executeUpdate:deleteAll];
  1482. }
  1483. @end