JXUserObject.m 68 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687
  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. NSString *dicJid=dict[@"jid"];
  719. //修改了修改了 //||dicJid.length>=10
  720. if ([g_xmpp.blackList containsObject:dict[@"jid"]]) {
  721. continue;
  722. }
  723. JXUserObject *user = [[JXUserObject sharedInstance] getUserById:dict[@"jid"]];
  724. NSNumber *isEncrypt = dict[@"isEncrypt"];
  725. NSString *messageId = dict[@"messageId"];
  726. long timeSend = [dict[@"timeSend"] longLongValue];
  727. NSString *content = dict[@"content"];
  728. if ([current_chat_userId isEqualToString:user.userId]) {
  729. dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(1 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
  730. [g_notify postNotificationName:kChatVCMessageSync object:@(timeSend)];
  731. });
  732. }
  733. content = [self getLastListContent:dict];
  734. if ([isEncrypt boolValue]) {
  735. NSMutableString *str = [NSMutableString string];
  736. [str appendString:APIKEY];
  737. [str appendString:[NSString stringWithFormat:@"%ld",timeSend]];
  738. [str appendString:messageId];
  739. NSString *keyStr = [g_server getMD5String:str];
  740. content = [DESUtil decryptDESStr:content key:keyStr];
  741. }else{
  742. content = content;
  743. }
  744. user.content = content;
  745. user.type = dict[@"type"];
  746. user.timeSend = [NSDate dateWithTimeIntervalSince1970:timeSend / 1000.0];
  747. if (user) {
  748. if (user.content.length > 0) {
  749. [user update];
  750. [userArray addObject:user];
  751. }
  752. }else {
  753. user = [[JXUserObject alloc] init];
  754. user.content = content;
  755. user.type = dict[@"type"];
  756. if ([dict[@"isRoom"] boolValue]) {
  757. user.roomFlag= [NSNumber numberWithInt:1];
  758. user.companyId= [NSNumber numberWithInt:0];
  759. user.status= [NSNumber numberWithInt:2];
  760. user.offlineNoPushMsg = [NSNumber numberWithInt:0];
  761. user.isAtMe = [NSNumber numberWithInt:0];
  762. }
  763. user.timeSend = [NSDate dateWithTimeIntervalSince1970:timeSend];
  764. user.userId = dict[@"jid"];
  765. user.userNickname = dict[@"toUserName"];
  766. [user insert];
  767. }
  768. }
  769. [self updateLastListContent:userArray withTransaction:YES];
  770. return YES;
  771. }
  772. - (void)updateLastListContent:(NSArray *)dataArray withTransaction:(BOOL )useTransaction{
  773. NSString* myUserId = MY_USER_ID;
  774. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  775. [self checkTableCreatedInDb:db];
  776. if (useTransaction) {
  777. [db beginTransaction];
  778. BOOL isRollBack = NO;
  779. @try {
  780. for (NSInteger i = 0; i < dataArray.count; i++) {
  781. JXUserObject *user = dataArray[i];
  782. if (user.roomId.length > 0) {
  783. user.roomFlag= [NSNumber numberWithInt:1];
  784. user.companyId= [NSNumber numberWithInt:0];
  785. if (!user.status) {
  786. user.status= [NSNumber numberWithInt:2];
  787. }
  788. }
  789. if(!user.timeSend)
  790. user.timeSend = [NSDate date];
  791. if (!user.companyId) {
  792. user.companyId = [NSNumber numberWithInt:0];
  793. }
  794. if ([user.userId intValue] == [SHIKU_TRANSFER intValue]) {
  795. user.userNickname = Localized(@"JX_PaymentNo.");
  796. }
  797. if ([user.topTime timeIntervalSince1970] > 0) {
  798. user.topTime = self.topTime;
  799. }else {
  800. user.topTime = nil;
  801. }
  802. 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];
  803. [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];
  804. }
  805. } @catch (NSException *exception) {
  806. isRollBack = YES;
  807. [db rollback];
  808. } @finally {
  809. if (!isRollBack) {
  810. [db commit];
  811. [db close];
  812. [g_App copyDbWithUserId:MY_USER_ID];
  813. }else{
  814. [db close];
  815. [self updateLastListContent:dataArray withTransaction:NO];
  816. }
  817. }
  818. }else{
  819. for (NSInteger i = 0; i < dataArray.count; i++) {
  820. JXUserObject *user = dataArray[i];
  821. if(!user.timeSend)
  822. user.timeSend = [NSDate date];
  823. if (!user.companyId) {
  824. user.companyId = [NSNumber numberWithInt:0];
  825. }
  826. if ([user.userId intValue] == [SHIKU_TRANSFER intValue]) {
  827. user.userNickname = Localized(@"JX_PaymentNo.");
  828. }
  829. if ([user.topTime timeIntervalSince1970] > 0) {
  830. user.topTime = self.topTime;
  831. }else {
  832. user.topTime = nil;
  833. }
  834. 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];
  835. 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];
  836. if (!worked) {
  837. NSLog(@"存失败");
  838. }
  839. }
  840. [db close];
  841. [g_App copyDbWithUserId:MY_USER_ID];
  842. }
  843. }
  844. - (NSString *)getLastListContent:(NSDictionary *)dict {
  845. int type = [dict[@"type"] intValue];
  846. NSString *content = dict[@"content"];
  847. NSString *fromUserId = dict[@"from"];
  848. NSString *fromUserName = dict[@"fromUserName"];
  849. if (!fromUserName) {
  850. fromUserName = @"";
  851. }
  852. NSString *toUserId = dict[@"to"];
  853. NSString *toUserName = dict[@"toUserName"];
  854. if (!toUserName) {
  855. toUserName = @"";
  856. }
  857. switch (type) {
  858. case kWCMessageTypeWithdraw:{
  859. if ([dict[@"isRoom"] boolValue]) {
  860. if ([fromUserId isEqualToString:MY_USER_ID]) {
  861. content = Localized(@"JX_AlreadyWithdraw");
  862. }else {
  863. content = [NSString stringWithFormat:@"%@ %@",fromUserName, Localized(@"JX_OtherWithdraw")];
  864. }
  865. }else {
  866. if ([fromUserId isEqualToString:MY_USER_ID]) {
  867. content = Localized(@"JX_AlreadyWithdraw");
  868. }else {
  869. content = [NSString stringWithFormat:@"%@ %@",fromUserName, Localized(@"JX_OtherWithdraw")];
  870. }
  871. }
  872. }
  873. break;
  874. case kWCMessageTypeShare:
  875. content = [NSString stringWithFormat:@"[%@]",Localized(@"JXLink")];
  876. break;
  877. case kWCMessageTypeRedPacketReceive:
  878. content = [NSString stringWithFormat:@"%@%@",fromUserName,Localized(@"JXRed_whoGet")];
  879. break;
  880. case kWCMessageTypeRedPacketReturn:
  881. content = [NSString stringWithFormat:@"%@",Localized(@"JX_ RedEnvelopeExpired")];
  882. break;
  883. case kWCMessageTypeGroupFileUpload:
  884. content = [NSString stringWithFormat:@"%@%@",fromUserName,Localized(@"JXMessage_fileUpload")];
  885. break;
  886. case kWCMessageTypeGroupFileDelete:
  887. content = [NSString stringWithFormat:@"%@%@",fromUserName,Localized(@"JXMessage_fileDelete")];
  888. break;
  889. case kWCMessageTypeGroupFileDownload:
  890. content = [NSString stringWithFormat:@"%@%@",fromUserName,Localized(@"JXMessage_fileDownload")];
  891. break;
  892. case kRoomRemind_RoomName:
  893. content = [NSString stringWithFormat:@"%@%@%@",fromUserName,Localized(@"JXMessageObject_UpdateRoomName"),content];
  894. break;
  895. case kRoomRemind_NickName:{
  896. content = [NSString stringWithFormat:@"%@%@%@",fromUserName,Localized(@"JXMessageObject_UpdateNickName"),content];
  897. }
  898. break;
  899. case kRoomRemind_DelRoom:
  900. if ([toUserId isEqualToString:MY_USER_ID]) {
  901. content = [NSString stringWithFormat:Localized(@"JX_DissolutionGroup"),fromUserName];
  902. }else {
  903. content = [NSString stringWithFormat:@"%@%@:%@",fromUserName,Localized(@"JXMessage_delRoom"),content];
  904. }
  905. break;
  906. case kRoomRemind_AddMember:
  907. if([toUserId isEqualToString:fromUserId])
  908. content = [NSString stringWithFormat:@"%@%@",fromUserName,Localized(@"JXMessageObject_GroupChat")];
  909. else
  910. content = [NSString stringWithFormat:@"%@%@%@",fromUserName,Localized(@"JXMessageObject_InterFriend"),toUserName];
  911. break;
  912. case kLiveRemind_ExitRoom:
  913. if([toUserId isEqualToString:fromUserId]){
  914. content = [NSString stringWithFormat:@"%@%@",fromUserName,Localized(@"EXITED_LIVE_ROOM")];//退出
  915. }else{
  916. content = [NSString stringWithFormat:@"%@%@",toUserName,Localized(@"JX_LiveVC_kickLive")];//被踢出
  917. }
  918. break;
  919. case kRoomRemind_DelMember:
  920. if([toUserId isEqualToString:fromUserId]){
  921. content = [NSString stringWithFormat:@"%@%@",fromUserName,Localized(@"JXMessageObject_OutGroupChat")];
  922. }else{
  923. if ([toUserId isEqualToString:MY_USER_ID]) {
  924. content = [NSString stringWithFormat:Localized(@"JX_OutOfTheGroup"),fromUserName];
  925. }else {
  926. if ([fromUserName isEqualToString:toUserName]) {
  927. content = [NSString stringWithFormat:@"%@%@",fromUserName,Localized(@"JXRoomMemberVC_OutPutRoom")];
  928. }else {
  929. content = [NSString stringWithFormat:@"%@%@%@",fromUserName,Localized(@"JXMessageObject_KickOut"),toUserName];
  930. }
  931. }
  932. }
  933. break;
  934. case kRoomRemind_NewNotice:
  935. content = [NSString stringWithFormat:@"%@%@%@",fromUserName,Localized(@"JXMessageObject_AddNewAdv"),content];
  936. break;
  937. case kLiveRemind_ShatUp:
  938. case kRoomRemind_DisableSay:{
  939. if([content longLongValue]==0){
  940. content = [NSString stringWithFormat:@"%@%@%@%@",fromUserName,Localized(@"JXMessageObject_Yes"),toUserName,Localized(@"JXMessageObject_CancelGag")];
  941. }else{
  942. NSDate* d = [NSDate dateWithTimeIntervalSince1970:[content longLongValue]];
  943. NSString* t = [TimeUtil formatDate:d format:@"MM-dd HH:mm"];
  944. content = [NSString stringWithFormat:@"%@%@%@%@%@",fromUserName,Localized(@"JXMessageObject_Yes"),toUserName,Localized(@"JXMessageObject_SetGagWithTime"),t];
  945. d = nil;
  946. }
  947. break;
  948. }
  949. case kLiveRemind_SetManager:
  950. case kRoomRemind_SetManage:{
  951. if ([content integerValue] == 1) {
  952. content = [NSString stringWithFormat:@"%@%@%@%@",Localized(@"JXGroup_Owner"),Localized(@"JXSettingVC_Set"),toUserName,Localized(@"JXMessage_admin")];
  953. }else {
  954. content = [NSString stringWithFormat:@"%@%@%@",Localized(@"JXGroup_Owner"),Localized(@"CANCEL_ADMINISTRATOR"),toUserName];
  955. }
  956. break;
  957. }
  958. case kRoomRemind_EnterLiveRoom:{
  959. content = [NSString stringWithFormat:@"%@%@",toUserName,Localized(@"Enter_LiveRoom")];//加入房间消息
  960. break;
  961. }
  962. case kRoomRemind_ShowRead:{
  963. if ([content integerValue] == 1)
  964. content = [NSString stringWithFormat:@"%@%@%@",Localized(@"JXGroup_Owner"),Localized(@"JX_Enable"),Localized(@"JX_RoomReadMode")];
  965. else
  966. content = [NSString stringWithFormat:@"%@%@%@",Localized(@"JXGroup_Owner"),Localized(@"JX_Disable"),Localized(@"JX_RoomReadMode")];
  967. break;
  968. }
  969. case kRoomRemind_NeedVerify:{
  970. if (!content || content.length <= 0) {
  971. content = Localized(@"JX_GroupInvitationConfirmation");
  972. }else {
  973. if ([content integerValue] == 1)
  974. content = Localized(@"JX_GroupOwnersOpenValidation");
  975. else
  976. content = Localized(@"JX_GroupOwnersCloseValidation");
  977. }
  978. break;
  979. }
  980. case kRoomRemind_IsLook:{
  981. if ([content integerValue] == 0)
  982. content = Localized(@"JX_GroupOwnersPublicGroup");
  983. else
  984. content = Localized(@"JX_GroupOwnersPrivateGroup");
  985. break;
  986. }
  987. case kRoomRemind_ShowMember:{
  988. if ([content integerValue] == 1)
  989. content = Localized(@"JX_GroupOwnersShowMembers");
  990. else
  991. content = Localized(@"JX_GroupOwnersNotShowMembers");
  992. break;
  993. }
  994. case kRoomRemind_allowSendCard:{
  995. if ([content integerValue] == 1)
  996. content = Localized(@"JX_ManagerOpenChat");
  997. else
  998. content = Localized(@"JX_ManagerOffChat");
  999. break;
  1000. }
  1001. case kRoomRemind_RoomAllBanned:{
  1002. if ([content integerValue] > 0)
  1003. content = Localized(@"JX_ManagerOpenSilence");
  1004. else
  1005. content = Localized(@"JX_ManagerOffSilence");
  1006. break;
  1007. }
  1008. case kRoomRemind_RoomAllowInviteFriend:{
  1009. if ([content integerValue] > 0)
  1010. content = Localized(@"JX_ManagerOpenInviteFriends");
  1011. else
  1012. content = Localized(@"JX_ManagerOffInviteFriends");
  1013. break;
  1014. }
  1015. case kRoomRemind_RoomAllowUploadFile:{
  1016. if ([content integerValue] > 0)
  1017. content = Localized(@"JX_ManagerOpenSharedFiles");
  1018. else
  1019. content = Localized(@"JX_ManagerOffSharedFiles");
  1020. break;
  1021. }
  1022. case kRoomRemind_RoomAllowConference:{
  1023. if ([content integerValue] > 0)
  1024. content = Localized(@"JX_ManagerOpenMeetings");
  1025. else
  1026. content = Localized(@"JX_ManagerOffMeetings");
  1027. break;
  1028. }
  1029. case kRoomRemind_RoomAllowSpeakCourse:{
  1030. if ([content integerValue] > 0)
  1031. content = Localized(@"JX_ManagerOpenLectures");
  1032. else
  1033. content = Localized(@"JX_ManagerOffLectures");
  1034. break;
  1035. }
  1036. case kRoomRemind_RoomTransfer:{
  1037. content = [NSString stringWithFormat:@"\"%@\"%@", toUserName,Localized(@"JX_NewGroupManager")];
  1038. break;
  1039. }
  1040. case kRoomRemind_SetInvisible:{
  1041. if ([content integerValue] == 1) {
  1042. content = [NSString stringWithFormat:@"%@%@%@%@",fromUserName,Localized(@"JXSettingVC_Set"),toUserName,Localized(@"JX_ForTheInvisibleMan")];
  1043. }else if ([content integerValue] == -1){
  1044. content = [NSString stringWithFormat:@"%@%@%@",fromUserName,Localized(@"JX_EliminateTheInvisible"),toUserName];
  1045. }else if ([content integerValue] == 2){
  1046. content = [NSString stringWithFormat:@"%@%@%@%@",fromUserName,Localized(@"JXSettingVC_Set"),toUserName,@"为监控人"];
  1047. }else if ([content integerValue] == 0){
  1048. content = [NSString stringWithFormat:@"%@%@%@",fromUserName,@"取消监控人",toUserName];
  1049. }
  1050. break;
  1051. }
  1052. case kRoomRemind_RoomDisable:{
  1053. if ([content integerValue] == 1) {
  1054. content = [NSString stringWithFormat:@"%@",Localized(@"JX_ThisGroupHasBeenDisabled")];
  1055. }else {
  1056. content = [NSString stringWithFormat:@"%@",Localized(@"JX_GroupNotUse")];
  1057. }
  1058. break;
  1059. }
  1060. case kRoomRemind_SetRecordTimeOut:{
  1061. NSArray *pickerArr = @[Localized(@"JX_Forever"), Localized(@"JX_OneHour"), Localized(@"JX_OneDay"), Localized(@"JX_OneWeeks"), Localized(@"JX_OneMonth"), Localized(@"JX_OneQuarter"), Localized(@"JX_OneYear")];
  1062. double outTime = [content doubleValue];
  1063. NSString *str;
  1064. if (outTime <= 0) {
  1065. str = pickerArr[0];
  1066. }else if (outTime == 0.04) {
  1067. str = pickerArr[1];
  1068. }else if (outTime == 1) {
  1069. str = pickerArr[2];
  1070. }else if (outTime == 7) {
  1071. str = pickerArr[3];
  1072. }else if (outTime == 30) {
  1073. str = pickerArr[4];
  1074. }else if (outTime == 90) {
  1075. str = pickerArr[5];
  1076. }else{
  1077. str = pickerArr[6];
  1078. }
  1079. content = [NSString stringWithFormat:@"%@%@",Localized(@"JX_GroupManagerSetMsgDelTime"),str];
  1080. }
  1081. default:
  1082. break;
  1083. }
  1084. return content;
  1085. }
  1086. // 更新群组全员禁言时间
  1087. - (BOOL) updateGroupTalkTime {
  1088. NSString* myUserId = MY_USER_ID;
  1089. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1090. [self checkTableCreatedInDb:db];
  1091. NSString* sql = [NSString stringWithFormat:@"update %@ set talkTime=? where userId=?",_tableName];
  1092. BOOL worked = [db executeUpdate:sql,self.talkTime,self.userId];
  1093. return worked;
  1094. }
  1095. // 更新是否开启阅后即焚标志
  1096. - (BOOL) updateIsOpenReadDel {
  1097. NSString* myUserId = MY_USER_ID;
  1098. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1099. [self checkTableCreatedInDb:db];
  1100. NSString* sql = [NSString stringWithFormat:@"update %@ set isOpenReadDel=? where userId=?",_tableName];
  1101. BOOL worked = [db executeUpdate:sql,self.isOpenReadDel,self.userId];
  1102. return worked;
  1103. }
  1104. // 更新消息免打扰
  1105. - (BOOL) updateOfflineNoPushMsg {
  1106. NSString* myUserId = MY_USER_ID;
  1107. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1108. [self checkTableCreatedInDb:db];
  1109. NSString* sql = [NSString stringWithFormat:@"update %@ set offlineNoPushMsg=? where userId=?",_tableName];
  1110. BOOL worked = [db executeUpdate:sql,self.offlineNoPushMsg,self.userId];
  1111. return worked;
  1112. }
  1113. // 更新@我
  1114. - (BOOL) updateIsAtMe{
  1115. NSString* myUserId = MY_USER_ID;
  1116. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1117. [self checkTableCreatedInDb:db];
  1118. NSString* sql = [NSString stringWithFormat:@"update %@ set isAtMe=? where userId=?",_tableName];
  1119. BOOL worked = [db executeUpdate:sql,self.isAtMe,self.userId];
  1120. return worked;
  1121. }
  1122. // 更新userType
  1123. - (BOOL) updateUserType {
  1124. NSString* myUserId = MY_USER_ID;
  1125. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1126. [self checkTableCreatedInDb:db];
  1127. NSString* sql = [NSString stringWithFormat:@"update %@ set userType=? where userId=?",_tableName];
  1128. BOOL worked = [db executeUpdate:sql,self.userType,self.userId];
  1129. return worked;
  1130. }
  1131. // 更新创建者
  1132. - (BOOL)updateCreateUser {
  1133. NSString* myUserId = MY_USER_ID;
  1134. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1135. [self checkTableCreatedInDb:db];
  1136. NSString* sql = [NSString stringWithFormat:@"update %@ set createUserId=? where userId=?",_tableName];
  1137. BOOL worked = [db executeUpdate:sql,self.createUserId,self.userId];
  1138. return worked;
  1139. }
  1140. // 更新群组设置
  1141. - (BOOL)updateGroupSetting {
  1142. NSString* myUserId = MY_USER_ID;
  1143. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1144. [self checkTableCreatedInDb:db];
  1145. NSString* sql = [NSString stringWithFormat:@"update %@ set showRead=?,allowSendCard=?,allowConference=?,allowSpeakCourse=?,isNeedVerify=?,talkTime=? where userId=?",_tableName];
  1146. BOOL worked = [db executeUpdate:sql,self.showRead,self.allowSendCard,self.allowConference,self.allowSpeakCourse,self.isNeedVerify,self.talkTime,self.userId];
  1147. return worked;
  1148. }
  1149. // 更新好友关系
  1150. - (BOOL)updateStatus {
  1151. NSString* myUserId = MY_USER_ID;
  1152. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1153. [self checkTableCreatedInDb:db];
  1154. NSString* sql = [NSString stringWithFormat:@"update %@ set status=? where userId=?",_tableName];
  1155. BOOL worked = [db executeUpdate:sql,self.status,self.userId];
  1156. return worked;
  1157. }
  1158. // 更新新消息数量
  1159. - (BOOL)updateNewMsgNum {
  1160. NSString* myUserId = MY_USER_ID;
  1161. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1162. [self checkTableCreatedInDb:db];
  1163. NSString* sql = [NSString stringWithFormat:@"update %@ set newMsgs=? where userId=?",_tableName];
  1164. BOOL worked = [db executeUpdate:sql,self.msgsNew,self.userId];
  1165. return worked;
  1166. }
  1167. // 更新我的设备是否在线
  1168. - (BOOL)updateIsOnLine {
  1169. NSString* myUserId = MY_USER_ID;
  1170. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1171. [self checkTableCreatedInDb:db];
  1172. NSString* sql = [NSString stringWithFormat:@"update %@ set isOnLine=? where userId=?",_tableName];
  1173. BOOL worked = [db executeUpdate:sql,self.isOnLine,self.userId];
  1174. return worked;
  1175. }
  1176. // 更新群组最后群成员加入时间
  1177. - (BOOL)updateJoinTime {
  1178. NSString* myUserId = MY_USER_ID;
  1179. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1180. [self checkTableCreatedInDb:db];
  1181. NSString* sql = [NSString stringWithFormat:@"update %@ set joinTime=? where userId=?",_tableName];
  1182. BOOL worked = [db executeUpdate:sql,self.joinTime,self.userId];
  1183. return worked;
  1184. }
  1185. // 删除用户过期聊天记录
  1186. - (BOOL) deleteUserChatRecordTimeOutMsg {
  1187. NSMutableArray *array = [[JXMessageObject sharedInstance] fetchRecentChat];
  1188. for (NSInteger i = 0; i < array.count; i ++) {
  1189. JXMsgAndUserObject *userObj = array[i];
  1190. [[JXMessageObject sharedInstance] deleteTimeOutMsg:userObj.user.userId chatRecordTimeOut:userObj.user.chatRecordTimeOut];
  1191. }
  1192. return YES;
  1193. }
  1194. - (BOOL) deleteAllUser {
  1195. NSString* myUserId = MY_USER_ID;
  1196. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1197. [self checkTableCreatedInDb:db];
  1198. NSString *sql = [NSString stringWithFormat:@"delete from %@ where length(userId) > 5 and length(userId) < 10",_tableName];
  1199. BOOL worked=[db executeUpdate:sql,self.userId];
  1200. return worked;
  1201. }
  1202. // 清除所有黑名单好友
  1203. - (BOOL)deleteAllBlackUser {
  1204. NSString* myUserId = MY_USER_ID;
  1205. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1206. [self checkTableCreatedInDb:db];
  1207. NSString *sql = [NSString stringWithFormat:@"delete from %@ where status=-1",_tableName];
  1208. BOOL worked=[db executeUpdate:sql];
  1209. return worked;
  1210. }
  1211. //插入已拨打的电话号码
  1212. - (BOOL) insertPhone:(NSString *)phone time:(NSDate *)time {
  1213. NSString* myUserId = MY_USER_ID;
  1214. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1215. [self checkPhoneTableCreatedInDb:db];
  1216. FMResultSet * rs = [db executeQuery:[NSString stringWithFormat:@"select * from telePhone where phone=?"],phone];
  1217. BOOL flag = NO;
  1218. if([rs next]) {
  1219. flag = YES;
  1220. }
  1221. // FMDBQuickCheck(worked);
  1222. if (!flag) {
  1223. NSString *insertStr=[NSString stringWithFormat:@"INSERT INTO '%@' ('phone','time') VALUES (?,?)",@"telePhone"];
  1224. BOOL worked = [db executeUpdate:insertStr,phone, time];
  1225. return worked;
  1226. }
  1227. return YES;
  1228. }
  1229. // 删除已拨打的电话号码
  1230. - (BOOL) deletePhone:(NSString *)phone {
  1231. NSString* myUserId = MY_USER_ID;
  1232. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1233. [self checkPhoneTableCreatedInDb:db];
  1234. BOOL worked = [db executeUpdate:[NSString stringWithFormat:@"delete from telePhone where phone=?"],phone];
  1235. return worked;
  1236. }
  1237. - (NSMutableDictionary *) getPhoneDic {
  1238. NSString* myUserId = MY_USER_ID;
  1239. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1240. [self checkPhoneTableCreatedInDb:db];
  1241. NSString* sql = [NSString stringWithFormat:@"select * from telePhone"];
  1242. FMResultSet *rs = [db executeQuery:sql];
  1243. NSMutableDictionary *dict = [NSMutableDictionary dictionary];
  1244. while ([rs next]) {
  1245. [dict setObject:[rs dateForColumn:@"time"] forKey:[rs stringForColumn:@"phone"]];
  1246. }
  1247. return dict;
  1248. }
  1249. -(BOOL)checkPhoneTableCreatedInDb:(FMDatabase *)db
  1250. {
  1251. NSString *createStr=[NSString stringWithFormat:@"CREATE TABLE IF NOT EXISTS '%@' ('phone' VARCHAR, 'time' DATETIME)",@"telePhone"];
  1252. BOOL worked = [db executeUpdate:createStr];
  1253. // FMDBQuickCheck(worked);
  1254. return worked;
  1255. }
  1256. // 更新好友DH公钥和RSA公钥
  1257. - (BOOL)updateDHPublicKeyAndRSAPublicKey {
  1258. NSString* myUserId = MY_USER_ID;
  1259. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1260. [self checkTableCreatedInDb:db];
  1261. NSString* sql = [NSString stringWithFormat:@"update %@ set publicKeyDH=?,publicKeyRSARoom=? where userId=?",_tableName];
  1262. BOOL worked = [db executeUpdate:sql,self.publicKeyDH,self.publicKeyRSARoom,self.userId];
  1263. return worked;
  1264. }
  1265. //查找好友
  1266. - (NSMutableArray *)searchContacts:(NSString *)searchtext{
  1267. 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];
  1268. return [self doFetch:sql];
  1269. }
  1270. //查找群组昵称
  1271. - (NSMutableArray *)searchGroup:(NSString *)searchtext withContent:(NSString *)content{
  1272. NSString *sql = [NSString stringWithFormat:@"select * from friend where roomFlag=1 and %@ like '%%%@%%' order by timeCreate",content,searchtext];
  1273. return [self doFetch:sql];
  1274. }
  1275. //查找成员
  1276. - (NSMutableArray *)searchGroupMember:(NSString *)searchtext{
  1277. NSString *sql = [NSString stringWithFormat:@"select * from friend where roomFlag=1"];
  1278. NSMutableArray *array = [self doFetch:sql];
  1279. NSMutableArray *roomIdArray = [NSMutableArray array];
  1280. for (JXUserObject *user in array) {
  1281. [roomIdArray addObject:user.roomId];
  1282. }
  1283. NSMutableArray *searchArray = [NSMutableArray array];
  1284. for (NSInteger i = 0; i<roomIdArray.count; i++) {
  1285. memberData *member = [memberData fetchMembersWithText:searchtext withRoomId:roomIdArray[i]];
  1286. if (member != nil) {
  1287. [searchArray addObject:member];
  1288. }
  1289. }
  1290. return searchArray;
  1291. }
  1292. //根据roomId查找群组
  1293. - (JXUserObject *)groupForRoomId:(NSString *)roomId{
  1294. NSString *sql = [NSString stringWithFormat:@"select * from friend where roomFlag=1 and roomId='%@'",roomId];
  1295. return [self doFetchOneGroup:sql];
  1296. }
  1297. - (JXUserObject *)doFetchOneGroup:(NSString*)sql
  1298. { JXUserObject *group = [[JXUserObject alloc] init];
  1299. NSString* myUserId = MY_USER_ID;
  1300. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1301. [super checkTableCreatedInDb:db];
  1302. FMResultSet *rs=[db executeQuery:sql];
  1303. while ([rs next]) {
  1304. JXUserObject *user=[[JXUserObject alloc] init];
  1305. [super userFromDataset:user rs:rs];
  1306. group = user;
  1307. }
  1308. [rs close];
  1309. return group;
  1310. }
  1311. //获取公众号
  1312. - (NSMutableArray *)searchPublic:(NSString *)searchtext{
  1313. NSString *sql = [NSString stringWithFormat:@"select * from friend where userType=2 and userNickname like '%%%@%%' order by timeCreate",searchtext];
  1314. return [self doFetch:sql];
  1315. }
  1316. //获取联系人和群聊
  1317. - (NSMutableArray *)getAllContactsAndGroup{
  1318. 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"];
  1319. return [self doFetch:sql];
  1320. }
  1321. //获取消息
  1322. - (NSMutableDictionary *)searchChatRecordWithText:(NSString *)text{
  1323. NSMutableDictionary *allMsg = [NSMutableDictionary dictionary];
  1324. NSMutableArray<JXUserObject *> *all = [self getAllContactsAndGroup];
  1325. for (NSInteger i = 0; i<all.count; i++) {
  1326. NSMutableArray *array = [self getSearchMsgWithUserId:all[i].userId withSearchText:text];
  1327. [allMsg setObject:array forKey:all[i].userId];
  1328. }
  1329. return allMsg;
  1330. }
  1331. - (NSMutableArray *)getSearchMsgWithUserId:(NSString *)userId withSearchText:(NSString *)searchtext{
  1332. NSString *sql = [NSString stringWithFormat:@"select * from msg_%@ where content like '%%%@%%' and type=1 order by timeSend desc",userId,searchtext];
  1333. NSMutableArray *array = [[NSMutableArray alloc] init];
  1334. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID];
  1335. FMResultSet *rs=[db executeQuery:sql];
  1336. while ([rs next]) {
  1337. JXMessageObject *p=[[JXMessageObject alloc] init];
  1338. [p fromRs:rs];
  1339. NSString *content = p.content;
  1340. NSMutableArray *contentArray = [NSMutableArray array];
  1341. [self getMessageRange:content :contentArray];
  1342. NSMutableArray *stringArray = [NSMutableArray array];
  1343. _num = 0;
  1344. [self splicingString:contentArray inArray:stringArray];
  1345. for (NSString *object in stringArray) {
  1346. if ([object hasSuffix:@"]"]&&[object hasPrefix:@"["]) {
  1347. }else{
  1348. if ([object localizedCaseInsensitiveContainsString:searchtext]) {
  1349. [array addObject:p];
  1350. break;
  1351. }
  1352. }
  1353. }
  1354. }
  1355. return array;
  1356. }
  1357. // 更新群组秘钥
  1358. - (BOOL)updateChatKeyGroup {
  1359. NSString* myUserId = MY_USER_ID;
  1360. FMDatabase* db = [[JXXMPP sharedInstance] openUserDb:myUserId];
  1361. [self checkTableCreatedInDb:db];
  1362. NSString* sql = [NSString stringWithFormat:@"update %@ set chatKeyGroup=? where userId=?",_tableName];
  1363. BOOL worked = [db executeUpdate:sql,self.chatKeyGroup,self.userId];
  1364. return worked;
  1365. }
  1366. //排除表情包
  1367. - (void)getMessageRange:(NSString*)message :(NSMutableArray*)array {
  1368. NSRange range=[message rangeOfString: @"["];
  1369. NSRange range1=[message rangeOfString: @"]"];
  1370. // 动画过滤
  1371. if ([message isEqualToString:[NSString stringWithFormat:@"[%@]",Localized(@"emojiVC_Emoji")]]) {
  1372. [array addObject:message];
  1373. return;
  1374. }
  1375. //判断当前字符串是否还有表情的标志。
  1376. if (range.length>0 && range1.length>0 && range1.location > range.location) {
  1377. if (range.location > 0) {
  1378. NSString *str = [message substringToIndex:range.location];
  1379. NSString *str1 = [message substringFromIndex:range.location];
  1380. [array addObject:str];
  1381. [self getMessageRange:str1 :array];
  1382. }else {
  1383. NSString *emojiString = [message substringWithRange:NSMakeRange(range.location + 1, range1.location - 1)];
  1384. BOOL isEmoji = NO;
  1385. NSString *str;
  1386. NSString *str1;
  1387. for (NSMutableDictionary *dic in g_constant.emojiArray) {
  1388. NSString *emoji = [dic objectForKey:@"english"];
  1389. if ([emoji isEqualToString:emojiString]) {
  1390. isEmoji = YES;
  1391. break;
  1392. }
  1393. }
  1394. if (isEmoji) {
  1395. str = [message substringWithRange:NSMakeRange(range.location, range1.location + 1)];
  1396. str1 = [message substringFromIndex:range1.location + 1];
  1397. [array addObject:str];
  1398. }else{
  1399. NSString *posString = [message substringWithRange:NSMakeRange(range.location + 1, range1.location)];
  1400. NSRange posRange = [posString rangeOfString:@"["];
  1401. if (posRange.location != NSNotFound) {
  1402. str = [message substringToIndex:posRange.location + 1];
  1403. str1 = [message substringFromIndex:posRange.location + 1];
  1404. [array addObject:str];
  1405. }else{
  1406. str = [message substringToIndex:range.location + 1];
  1407. str1 = [message substringFromIndex:range.location + 1];
  1408. [array addObject:str];
  1409. }
  1410. }
  1411. [self getMessageRange:str1 :array];
  1412. }
  1413. }else if (range.length>0 && range1.length>0 && range1.location < range.location){
  1414. NSString *str = [message substringToIndex:range1.location + 1];
  1415. NSString *str1 = [message substringFromIndex:range1.location + 1];
  1416. [array addObject:str];
  1417. [self getMessageRange:str1 :array];
  1418. }else if (message != nil) {
  1419. [array addObject:message];
  1420. }
  1421. }
  1422. //拼接字符串
  1423. - (void)splicingString:(NSMutableArray *)array inArray:(NSMutableArray *)contentArray{
  1424. if (_num >= array.count) {
  1425. return;
  1426. }
  1427. NSString *str = [NSString string];
  1428. for (NSInteger i = _num; i < array.count; i++) {
  1429. NSString *object = array[i];
  1430. if ([object hasSuffix:@"]"]&&[object hasPrefix:@"["]) {
  1431. [contentArray addObject:str];
  1432. [contentArray addObject:object];
  1433. _num = i + 1;
  1434. break;
  1435. }else{
  1436. _num = i + 1;
  1437. str = [str stringByAppendingString:object];
  1438. if (_num >= array.count) {
  1439. [contentArray addObject:str];
  1440. return;
  1441. }
  1442. }
  1443. }
  1444. [self splicingString:array inArray:contentArray];
  1445. }
  1446. - (NSMutableArray *)fetchAllSearchRecordWithTable:(NSString *)tableName{
  1447. FMDatabase *db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID];
  1448. NSString *str = [NSString stringWithFormat:@"CREATE TABLE IF NOT EXISTS '%@'('ID' INTEGER PRIMARY KEY AUTOINCREMENT,'record' TEXT NOT NULL)",tableName];
  1449. BOOL success = [db executeUpdate:str];
  1450. if (!success) {
  1451. NSLog(@"创建搜索记录表失败");
  1452. }
  1453. NSString *allRecord = [NSString stringWithFormat:@"select * from '%@' order by ID",tableName];
  1454. FMResultSet *rs = [db executeQuery:allRecord];
  1455. NSMutableArray *array = [NSMutableArray array];
  1456. while ([rs next]) {
  1457. NSString *record = [rs stringForColumn:@"record"];
  1458. if (record != nil && record != NULL) {
  1459. [array addObject:record];
  1460. }
  1461. }
  1462. return array;
  1463. }
  1464. - (BOOL)insertSearchRecord:(NSString *)searchRecord withTable:(NSString *)tableName{
  1465. FMDatabase *db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID];
  1466. NSString *create = [NSString stringWithFormat:@"CREATE TABLE IF NOT EXISTS '%@'('ID' INTEGER PRIMARY KEY AUTOINCREMENT,'record' TEXT NOT NULL)",tableName];
  1467. BOOL createSuccess = [db executeUpdate:create];
  1468. if (!createSuccess) {
  1469. NSLog(@"创建搜索记录表失败");
  1470. }
  1471. [self deleteOneSearchRecord:searchRecord withTable:tableName];
  1472. NSString *record = [NSString stringWithFormat:@"INSERT INTO '%@' (record) VALUES (?)",tableName];
  1473. return [db executeUpdate:record,searchRecord];
  1474. }
  1475. - (BOOL)deleteOneSearchRecord:(NSString *)searchRecord withTable:(NSString *)tableName{
  1476. FMDatabase *db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID];
  1477. NSString *deleteOne = [NSString stringWithFormat:@"delete from '%@' where record = '%@'",tableName,searchRecord];
  1478. return [db executeUpdate:deleteOne];
  1479. }
  1480. - (BOOL)deleteAllSearchRecordWithTable:(NSString *)tableName{
  1481. FMDatabase *db = [[JXXMPP sharedInstance] openUserDb:MY_USER_ID];
  1482. NSString *deleteAll = [NSString stringWithFormat:@"delete from '%@'",tableName];
  1483. return [db executeUpdate:deleteAll];
  1484. }
  1485. @end