IncomingThread.swift 124 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965
  1. //
  2. // IncomingThread.swift
  3. // Runner
  4. //
  5. // Created by Yayan Dwi on 16/04/20.
  6. // Copyright © 2020 The Chromium Authors. All rights reserved.
  7. //
  8. import Foundation
  9. import UIKit
  10. import NotificationBannerSwift
  11. import nuSDKService
  12. class IncomingThread {
  13. static let `default` = IncomingThread()
  14. private var isRunning = false
  15. private var semaphore = DispatchSemaphore(value: 0)
  16. private var dispatchQueue = DispatchQueue(label: "IncomingThread")
  17. private var queue = [TMessage]()
  18. func addQueue(message: TMessage) {
  19. queue.append(message)
  20. semaphore.signal()
  21. }
  22. func getQueue() -> TMessage {
  23. while queue.isEmpty || queue.count == 0 {
  24. semaphore.wait()
  25. }
  26. return queue.remove(at: 0)
  27. }
  28. func run() {
  29. if (isRunning) {
  30. return
  31. }
  32. isRunning = true
  33. dispatchQueue.async {
  34. while self.isRunning {
  35. self.process(message: self.getQueue())
  36. }
  37. }
  38. }
  39. private func process(message: TMessage) {
  40. print("incoming process", message.toLogString())
  41. if message.getCode() == CoreMessage_TMessageCode.LOGIN_FILE {
  42. loginFile(message: message)
  43. } else if message.getCode() == CoreMessage_TMessageCode.PUSH_MYSELF || message.getCode() == CoreMessage_TMessageCode.PUSH_MYSELF_ACK || message.getCode() == CoreMessage_TMessageCode.PULL_MYSELF {
  44. pushMyself(message: message)
  45. } else if message.getCode() == CoreMessage_TMessageCode.PUSH_BUDDY {
  46. DispatchQueue.main.asyncAfter(deadline: .now() + 0.5, execute: {
  47. self.initBatchBuddy(message: message)
  48. })
  49. makeNotifAddFriend(message: message)
  50. } else if message.getCode() == CoreMessage_TMessageCode.INIT_BATCH_BUDDY {
  51. initBatchBuddy(message: message)
  52. } else if message.getCode() == CoreMessage_TMessageCode.CHANGE_BATCH_PERSON_INFO {
  53. initBatchBuddy(message: message)
  54. } else if message.getCode() == CoreMessage_TMessageCode.DELETE_BUDDY {
  55. deleteBuddy(message: message)
  56. } else if message.getCode() == CoreMessage_TMessageCode.INIT_BATCH_GROUP {
  57. onInitGroupInfoBatch(message: message)
  58. } else if message.getCode() == CoreMessage_TMessageCode.INIT_BATCH_TOPIC {
  59. onInitForumInfoBatch(message: message)
  60. } else if message.getCode() == CoreMessage_TMessageCode.UPLOAD_FILE {
  61. uploadFile(message: message)
  62. } else if message.getCode() == CoreMessage_TMessageCode.SEND_CHAT {
  63. receiveMessage(message: message)
  64. } else if message.getCode() == CoreMessage_TMessageCode.UPDATE_CTEXT {
  65. receiveMessageStatus(message: message)
  66. } else if message.getCode() == CoreMessage_TMessageCode.PUSH_GROUP || message.getCode() == CoreMessage_TMessageCode.PUSH_GROUP_A {
  67. pushGroup(message: message)
  68. } else if message.getCode() == CoreMessage_TMessageCode.PUSH_GROUP_MEMBER {
  69. pushGroupMembers(message: message)
  70. } else if message.getCode() == CoreMessage_TMessageCode.PUSH_GROUP_MEMBER_BATCH {
  71. pushGroupMembers(message: message)
  72. } else if message.getCode() == CoreMessage_TMessageCode.CHANGE_GROUP_MEMBER_POSITION {
  73. changeGroupPosition(message: message)
  74. } else if message.getCode() == CoreMessage_TMessageCode.PUSH_CHAT {
  75. onInitForumInfoBatch(message: message, with: true)
  76. } else if message.getCode() == CoreMessage_TMessageCode.EXIT_GROUP {
  77. exitGroup(message: message)
  78. } else if message.getCode() == CoreMessage_TMessageCode.CHANGE_GROUP_INFO {
  79. changeGroupInfo(message: message)
  80. } else if message.getCode() == CoreMessage_TMessageCode.UPDATE_CHAT {
  81. updateChat(message: message)
  82. } else if message.getCode() == CoreMessage_TMessageCode.DELETE_CHAT {
  83. deleteChat(message: message)
  84. } else if message.getCode() == CoreMessage_TMessageCode.IMAGE_DOWNLOAD {
  85. imageDownload(message: message)
  86. } else if message.getCode() == CoreMessage_TMessageCode.PUSH_LIVE_VIDEO_LIST {
  87. getLiveVideoList(message: message)
  88. } else if message.getCode() == CoreMessage_TMessageCode.UPDATE_LIVE_VIDEO {
  89. getLSTitle(message: message)
  90. } else if message.getCode() == CoreMessage_TMessageCode.LIVE_PROFILE_PUSH_LEAVE {
  91. leftLiveVideo(message: message)
  92. } else if message.getCode() == CoreMessage_TMessageCode.LIVE_PROFILE_PUSH_JOIN {
  93. joinLivevideo(message: message)
  94. } else if message.getCode() == CoreMessage_TMessageCode.LIVE_PROFILE_EMOTION_GET {
  95. getLSData(message: message)
  96. } else if message.getCode() == CoreMessage_TMessageCode.DELETE_CTEXT {
  97. deleteMessage(message: message)
  98. } else if message.getCode() == CoreMessage_TMessageCode.SEND_UPDATE_TYPING {
  99. sendUpdateTyping(message: message)
  100. } else if message.getCode() == CoreMessage_TMessageCode.LIVE_PROFILE_PUSH_CHAT {
  101. getLSChat(message: message)
  102. } else if message.getCode() == CoreMessage_TMessageCode.SEMINAR_PUSH_JOIN {
  103. joinSeminar(message: message)
  104. } else if message.getCode() == CoreMessage_TMessageCode.SEMINAR_PUSH_LEFT {
  105. leftSeminar(message: message)
  106. } else if message.getCode() == CoreMessage_TMessageCode.SEMINAR_PUSH_CHAT {
  107. getSeminarChat(message: message)
  108. } else if message.getCode() == CoreMessage_TMessageCode.SEMINAR_PUSH_RAISE_HAND {
  109. getSeminarRaiseHand(message: message)
  110. } else if message.getCode() == CoreMessage_TMessageCode.SEMINAR_FACE_DETECTION {
  111. } else if message.getCode() == CoreMessage_TMessageCode.SCREEN_SHARING {
  112. incomingScreenSharing(message: message, state: 1)
  113. } else if message.getCode() == CoreMessage_TMessageCode.SCREEN_SHARING_STOP {
  114. incomingScreenSharing(message: message, state: 88 )
  115. } else if message.getCode() == CoreMessage_TMessageCode.CHANGE_PERSON_INFO {
  116. changePersonInfo(message: message)
  117. } else if message.getCode() == CoreMessage_TMessageCode.SEND_COMMENTS {
  118. receiveComment(message: message)
  119. } else if message.getCode() == CoreMessage_TMessageCode.DELETE_COMMENTS {
  120. deleteComment(message: message)
  121. } else if message.getCode() == CoreMessage_TMessageCode.BLOCK_BUDDY {
  122. blockBuddy(message: message)
  123. } else if message.getCode() == CoreMessage_TMessageCode.UNBLOCK_BUDDY {
  124. blockBuddy(message: message)
  125. } else if message.getCode() == CoreMessage_TMessageCode.SEND_SIGNUP_MSISDN {
  126. sendMSISDN(message: message)
  127. } else if message.getCode() == CoreMessage_TMessageCode.VERIFY_OTP {
  128. verifyOTP(message: message)
  129. } else if message.getCode() == CoreMessage_TMessageCode.REMOVE_FRIEND {
  130. deleteBuddy(message: message)
  131. } else if message.getCode() == CoreMessage_TMessageCode.PUSH_CALL_CENTER || message.getCode() == CoreMessage_TMessageCode.ACCEPT_CALL_CENTER || message.getCode() == CoreMessage_TMessageCode.END_CALL_CENTER || message.getCode() == CoreMessage_TMessageCode.TIMEOUT_CONTACT_CENTER || message.getCode() == CoreMessage_TMessageCode.INVITE_TO_ROOM_CONTACT_CENTER || message.getCode() == CoreMessage_TMessageCode.ACCEPT_CONTACT_CENTER || message.getCode() == CoreMessage_TMessageCode.PUSH_MEMBER_ROOM_CONTACT_CENTER || message.getCode() == CoreMessage_TMessageCode.INVITE_END_CONTACT_CENTER || message.getCode() == CoreMessage_TMessageCode.INVITE_EXIT_CONTACT_CENTER || message.getCode() == CoreMessage_TMessageCode.PUSH_SECOND_CONTACT_CENTER {
  132. handleCallCenter(message: message)
  133. } else if message.getCode() == CoreMessage_TMessageCode.PUSH_DISCUSSION_COMMENT {
  134. if let delegate = Nexilis.shared.messageDelegate {
  135. delegate.onReceiveComment(message: message)
  136. }
  137. ack(message: message)
  138. } else if message.getCode() == CoreMessage_TMessageCode.APPROVE_FORM {
  139. onApproveForm(message: message)
  140. } else if message.getCode() == CoreMessage_TMessageCode.END_CALL {
  141. endCall(message: message)
  142. } else if message.getCode() == CoreMessage_TMessageCode.PUSH_SERVICE_BNI {
  143. pushServiceBNI(message: message)
  144. } else if message.getCode() == CoreMessage_TMessageCode.MOBILE_INQUIRY {
  145. mobileInquiry(message: message)
  146. } else if message.getCode() == CoreMessage_TMessageCode.INQUIRY {
  147. inquiry(message: message)
  148. } else if message.getCode() == CoreMessage_TMessageCode.BACKUP_AVAILABILITY {
  149. backupAvailability(message: message)
  150. } else if message.getCode() == CoreMessage_TMessageCode.FORWARD_MESSAGE {
  151. incomingWBSS(message: message)
  152. } else if message.getCode() == CoreMessage_TMessageCode.INCOMING_CALL_CC {
  153. incomingCallCC(message: message)
  154. } else if message.getCode() == CoreMessage_TMessageCode.GET_WORKING_AREA_CONTACT_CENTER {
  155. saveWorkingArea(message: message)
  156. } else {
  157. print("unprocessed code", message.getCode())
  158. ack(message: message)
  159. }
  160. // case (CoreMessage_TMessageCode.FORM_PUSH_UPDATE):
  161. // onPushForm(msg);
  162. // break;
  163. }
  164. /**
  165. *
  166. */
  167. private func saveWorkingArea(message: TMessage) -> Void {
  168. let data = message.getBody(key: CoreMessage_TMessageKey.DATA)
  169. if !data.isEmpty {
  170. if let jsonArray = try! JSONSerialization.jsonObject(with: data.data(using: String.Encoding.utf8)!, options: JSONSerialization.ReadingOptions()) as? [AnyObject] {
  171. Database.shared.database?.inTransaction({ (fmdb, rollback) in
  172. do {
  173. for json in jsonArray {
  174. var parent = CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.PARENT_ID)
  175. if parent.isEmpty {
  176. parent = "-99"
  177. }
  178. _ = try Database.shared.insertRecord(fmdb: fmdb, table: "WORKING_AREA", cvalues: [
  179. "area_id" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.WORKING_AREA),
  180. "name" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.NAME),
  181. "parent" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.PARENT_ID),
  182. "level" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.LEVEL)
  183. ], replace: true)
  184. }
  185. ack(message: message)
  186. } catch {
  187. rollback.pointee = true
  188. print(error)
  189. }
  190. })
  191. }
  192. }
  193. }
  194. private func incomingCallCC(message: TMessage) {
  195. if let packetId = message.mBodies[CoreMessage_TMessageKey.PACKET_ID] {
  196. _ = Nexilis.responseString(packetId: packetId, message: "01")
  197. }
  198. ack(message: message)
  199. DispatchQueue.main.asyncAfter(deadline: .now() + 1, execute: {
  200. let onGoingCC = UserDefaults.standard.string(forKey: "onGoingCC") ?? ""
  201. let channelCC = UserDefaults.standard.string(forKey: "channelCC") ?? ""
  202. let complaintId = onGoingCC.components(separatedBy: ",")[2]
  203. let fPinCC = onGoingCC.isEmpty ? "" : onGoingCC.components(separatedBy: ",")[1]
  204. if fPinCC == User.getMyPin() {
  205. return
  206. }
  207. if channelCC == "1" {
  208. let controller = QmeraAudioViewController()
  209. controller.isOutgoing = false
  210. controller.user = User.getData(pin: fPinCC)
  211. controller.ticketId = complaintId
  212. controller.modalPresentationStyle = .overCurrentContext
  213. if UIApplication.shared.visibleViewController is UIAlertController {
  214. let vc = UIApplication.shared.visibleViewController as! UIAlertController
  215. vc.dismiss(animated: true, completion: {
  216. if UIApplication.shared.visibleViewController?.navigationController != nil {
  217. UIApplication.shared.visibleViewController?.navigationController?.present(controller, animated: true, completion: nil)
  218. } else {
  219. UIApplication.shared.visibleViewController?.present(controller, animated: true, completion: nil)
  220. }
  221. })
  222. return
  223. }
  224. if UIApplication.shared.visibleViewController?.navigationController != nil {
  225. UIApplication.shared.visibleViewController?.navigationController?.present(controller, animated: true, completion: nil)
  226. } else {
  227. UIApplication.shared.visibleViewController?.present(controller, animated: true, completion: nil)
  228. }
  229. } else if channelCC == "2" {
  230. let videoController = AppStoryBoard.Palio.instance.instantiateViewController(withIdentifier: "videoVCQmera") as! QmeraVideoViewController
  231. let user = User.getData(pin: fPinCC)
  232. videoController.fPin = user!.pin
  233. videoController.isInisiator = false
  234. videoController.users.append(user!)
  235. videoController.isAutoAccept = true
  236. videoController.ticketId = complaintId
  237. let navigationController = UINavigationController(rootViewController: videoController)
  238. navigationController.modalPresentationStyle = .fullScreen
  239. if UIApplication.shared.visibleViewController is UIAlertController {
  240. let vc = UIApplication.shared.visibleViewController as! UIAlertController
  241. vc.dismiss(animated: true, completion: {
  242. if UIApplication.shared.visibleViewController?.navigationController != nil {
  243. UIApplication.shared.visibleViewController?.navigationController?.present(navigationController, animated: true, completion: nil)
  244. } else {
  245. UIApplication.shared.visibleViewController?.present(navigationController, animated: true, completion: nil)
  246. }
  247. })
  248. return
  249. }
  250. if UIApplication.shared.visibleViewController?.navigationController != nil {
  251. UIApplication.shared.visibleViewController?.navigationController?.present(navigationController, animated: true, completion: nil)
  252. } else {
  253. UIApplication.shared.visibleViewController?.present(navigationController, animated: true, completion: nil)
  254. }
  255. }
  256. })
  257. }
  258. private func incomingWBSS(message: TMessage) {
  259. let type = message.getBody(key: CoreMessage_TMessageKey.TYPE, default_value: "")
  260. let status = message.getBody(key: CoreMessage_TMessageKey.STATUS, default_value: "")
  261. let f_pin = message.getBody(key: CoreMessage_TMessageKey.F_USER_ID, default_value: "")
  262. if type == "wb" {
  263. switch (Int(status)) {
  264. case CoreMessage_TMessageCode.WB_INCOMING:
  265. print("WB_INCOMING")
  266. DispatchQueue.main.async {
  267. let controller = AppStoryBoard.Palio.instance.instantiateViewController(identifier: "wbVC") as! WhiteboardViewController
  268. controller.modalPresentationStyle = .overFullScreen
  269. controller.fromContact = 1
  270. controller.user = User.getData(pin: f_pin)
  271. if UIApplication.shared.visibleViewController?.navigationController != nil {
  272. UIApplication.shared.visibleViewController?.navigationController?.present(controller, animated: true, completion: nil)
  273. } else {
  274. UIApplication.shared.visibleViewController?.present(controller, animated: true, completion: nil)
  275. }
  276. }
  277. default:
  278. print("default")
  279. var dataMessage: [AnyHashable : Any] = [:]
  280. dataMessage["message"] = message
  281. NotificationCenter.default.post(name: NSNotification.Name(rawValue: "wbSession"), object: nil, userInfo: dataMessage)
  282. }
  283. } else if type == "ss"{
  284. switch (Int(status)) {
  285. case CoreMessage_TMessageCode.SS_INCOMING:
  286. print("SS_INCOMING")
  287. DispatchQueue.main.async {
  288. let controller = ScreenSharingViewController()
  289. controller.modalPresentationStyle = .overFullScreen
  290. controller.fromContact = 1
  291. controller.user = User.getData(pin: f_pin)
  292. if UIApplication.shared.visibleViewController?.navigationController != nil {
  293. UIApplication.shared.visibleViewController?.navigationController?.present(controller, animated: true, completion: nil)
  294. } else {
  295. UIApplication.shared.visibleViewController?.present(controller, animated: true, completion: nil)
  296. }
  297. }
  298. default:
  299. print("default")
  300. var dataMessage: [AnyHashable : Any] = [:]
  301. dataMessage["message"] = message
  302. NotificationCenter.default.post(name: NSNotification.Name(rawValue: "ssSession"), object: nil, userInfo: dataMessage)
  303. }
  304. }
  305. ack(message: message)
  306. }
  307. private func backupAvailability(message: TMessage) {
  308. var dataMessage: [AnyHashable : Any] = [:]
  309. dataMessage["message"] = message
  310. NotificationCenter.default.post(name: NSNotification.Name(rawValue: "backupAvailability"), object: nil, userInfo: dataMessage)
  311. ack(message: message)
  312. }
  313. private func makeNotifAddFriend(message: TMessage) {
  314. let data = message.getBody(key: CoreMessage_TMessageKey.DATA)
  315. if let jsonArray = try! JSONSerialization.jsonObject(with: data.data(using: String.Encoding.utf8)!, options: JSONSerialization.ReadingOptions()) as? [AnyObject] {
  316. for json in jsonArray {
  317. DispatchQueue.main.async {
  318. let f_pin = CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.F_PIN)
  319. Database.shared.database?.inTransaction({ (fmdb, rollback) in
  320. if message.getPIN() == User.getMyPin() {
  321. return
  322. }
  323. if let cursorUser = Database.shared.getRecords(fmdb: fmdb, query: "SELECT f_pin FROM BUDDY where f_pin='\(f_pin)'"), cursorUser.next() {
  324. return
  325. }
  326. if message.getBody(key: "is_silent") == "1" {
  327. return
  328. }
  329. let firstname = CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.FIRST_NAME)
  330. let lastname = CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.LAST_NAME)
  331. let f_pin = CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.F_PIN)
  332. if (firstname + " " + lastname).trimmingCharacters(in: .whitespaces) == "USR\(f_pin)" {
  333. return
  334. }
  335. let onGoingCC = UserDefaults.standard.string(forKey: "onGoingCC") ?? ""
  336. if !onGoingCC.isEmpty {
  337. return
  338. }
  339. let container = UIView()
  340. container.backgroundColor = .gray
  341. let profileImage = UIImageView()
  342. profileImage.frame.size = CGSize(width: 60, height: 60)
  343. container.addSubview(profileImage)
  344. profileImage.translatesAutoresizingMaskIntoConstraints = false
  345. NSLayoutConstraint.activate([
  346. profileImage.leadingAnchor.constraint(equalTo: container.leadingAnchor, constant: 8.0),
  347. profileImage.centerYAnchor.constraint(equalTo: container.centerYAnchor),
  348. profileImage.widthAnchor.constraint(equalToConstant: 60),
  349. profileImage.heightAnchor.constraint(equalToConstant: 60),
  350. ])
  351. let title = UILabel()
  352. container.addSubview(title)
  353. title.translatesAutoresizingMaskIntoConstraints = false
  354. NSLayoutConstraint.activate([
  355. title.leadingAnchor.constraint(equalTo: profileImage.trailingAnchor, constant: 8.0),
  356. title.centerYAnchor.constraint(equalTo: container.centerYAnchor),
  357. title.trailingAnchor.constraint(equalTo: container.trailingAnchor, constant: -8.0)
  358. ])
  359. title.font = UIFont.systemFont(ofSize: 14)
  360. title.text = (firstname + " " + lastname).trimmingCharacters(in: .whitespaces) + " " + "added you as friend".localized()
  361. title.textColor = .white
  362. title.numberOfLines = 0
  363. if Nexilis.shared.floating != nil {
  364. Nexilis.shared.floating.dismiss()
  365. }
  366. Nexilis.shared.floating = FloatingNotificationBanner(customView: container)
  367. Nexilis.shared.floating.bannerHeight = 100.0
  368. Nexilis.shared.floating.transparency = 0.9
  369. let profile = CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.THUMB_ID)
  370. if profile != "" {
  371. profileImage.circle()
  372. do {
  373. let documentDir = try FileManager.default.url(for: .documentDirectory, in: .userDomainMask, appropriateFor: nil, create: true)
  374. let file = documentDir.appendingPathComponent(profile)
  375. if FileManager().fileExists(atPath: file.path) {
  376. profileImage.image = UIImage(contentsOfFile: file.path)
  377. profileImage.backgroundColor = .clear
  378. } else {
  379. Download().start(forKey: profile) { (name, progress) in
  380. guard progress == 100 else {
  381. return
  382. }
  383. DispatchQueue.main.async {
  384. profileImage.image = UIImage(contentsOfFile: file.path)
  385. profileImage.backgroundColor = .clear
  386. Nexilis.shared.floating.show(queuePosition: .front, bannerPosition: .top, queue: NotificationBannerQueue(maxBannersOnScreenSimultaneously: 1), on: nil, edgeInsets: UIEdgeInsets(top: 8.0, left: 8.0, bottom: 0, right: 8.0), cornerRadius: 8.0, shadowColor: .clear, shadowOpacity: .zero, shadowBlurRadius: .zero, shadowCornerRadius: .zero, shadowOffset: .zero, shadowEdgeInsets: nil)
  387. return
  388. }
  389. }
  390. }
  391. } catch {}
  392. profileImage.contentMode = .scaleAspectFill
  393. } else {
  394. profileImage.circle()
  395. profileImage.image = UIImage(systemName: "person")
  396. profileImage.contentMode = .scaleAspectFit
  397. profileImage.backgroundColor = .lightGray
  398. profileImage.tintColor = .white
  399. }
  400. Nexilis.shared.floating.show(queuePosition: .front, bannerPosition: .top, queue: NotificationBannerQueue(maxBannersOnScreenSimultaneously: 1), on: nil, edgeInsets: UIEdgeInsets(top: 8.0, left: 8.0, bottom: 0, right: 8.0), cornerRadius: 8.0, shadowColor: .clear, shadowOpacity: .zero, shadowBlurRadius: .zero, shadowCornerRadius: .zero, shadowOffset: .zero, shadowEdgeInsets: nil)
  401. })
  402. }
  403. }
  404. }
  405. }
  406. private func inquiry(message: TMessage) {
  407. let message_id = message.getBody(key: CoreMessage_TMessageKey.MESSAGE_ID, default_value: "")
  408. var err_code = "10"
  409. if !message_id.isEmpty {
  410. Database.shared.database?.inTransaction({ (fmdb, rollback) in
  411. if let cursor = Database.shared.getRecords(fmdb: fmdb, query: "select message_id from MESSAGE where message_id = '\(message_id)'") {
  412. if cursor.next() {
  413. err_code = "00"
  414. }
  415. _ = Nexilis.write(message: CoreMessage_TMessageBank.getInquiry(message_id: message_id, error_code: err_code, data: message_id))
  416. cursor.close()
  417. }
  418. })
  419. }
  420. }
  421. private func mobileInquiry(message: TMessage) {
  422. var message_id = message.getBody(key: CoreMessage_TMessageKey.MESSAGE_ID)
  423. let err_code = message.getBody(key: CoreMessage_TMessageKey.ERRCOD)
  424. let message_scope = message.getBody(key: CoreMessage_TMessageKey.MESSAGE_SCOPE_ID)
  425. if message_id.isEmpty {
  426. message_id = message.getStatus()
  427. }
  428. if err_code == "00" {
  429. self.updateInquiry(messageId: message_id)
  430. } else {
  431. print("MASUK MINQ SEND CHAT")
  432. Database.shared.database?.inTransaction({ (fmdb, rollback) in
  433. if let cursor = Database.shared.getRecords(fmdb: fmdb, query: "select message from INQUIRY where id = '\(message_id)'"), cursor.next() {
  434. if let message = cursor.string(forColumnIndex: 0) {
  435. print("MASUK MINQ ADA MESSAGE")
  436. OutgoingThread.default.addQueue(message: TMessage(data: message))
  437. if message_scope != "3" {
  438. DispatchQueue.main.async {
  439. self.updateInquiry(messageId: message_id)
  440. }
  441. }
  442. }
  443. cursor.close()
  444. }
  445. })
  446. }
  447. }
  448. private func updateInquiry(messageId: String) {
  449. print("UPDATE INQUIRY")
  450. Database.shared.database?.inTransaction({ (fmdb, rollback) in
  451. _ = Database.shared.updateRecord(fmdb: fmdb, table: "INQUIRY", cvalues: [
  452. "status" : "1"
  453. ], _where: "id = '\(messageId)'")
  454. })
  455. }
  456. private func endCall(message: TMessage) {
  457. if let call = Nexilis.shared.callManager.call(with: message.mPIN) {
  458. call.isReceiveEnd = true
  459. DispatchQueue.main.async {
  460. Nexilis.shared.callManager.end(call: call)
  461. }
  462. }
  463. ack(message: message)
  464. }
  465. private func onApproveForm(message: TMessage) {
  466. if let me = UserDefaults.standard.string(forKey: "me") {
  467. _ = Nexilis.write(message: CoreMessage_TMessageBank.getPostRegistration(p_pin: me))
  468. }
  469. ack(message: message)
  470. }
  471. private func handleCallCenter(message: TMessage) -> Void {
  472. if let delegate = Nexilis.shared.messageDelegate {
  473. delegate.onReceive(message: message)
  474. }
  475. if let packetId = message.mBodies[CoreMessage_TMessageKey.PACKET_ID], (message.getCode() == CoreMessage_TMessageCode.PUSH_CALL_CENTER || message.getCode() == CoreMessage_TMessageCode.PUSH_SECOND_CONTACT_CENTER) {
  476. _ = Nexilis.responseString(packetId: packetId, message: "00")
  477. }
  478. ack(message: message)
  479. // TODO: notif call center
  480. }
  481. private func blockBuddy(message: TMessage) -> Void {
  482. let l_pin = message.getBody(key: CoreMessage_TMessageKey.L_PIN)
  483. let block = message.getBody(key: CoreMessage_TMessageKey.BLOCK)
  484. print ("BLOCK INCOMING \(block)")
  485. Database.shared.database?.inTransaction({ (fmdb, rollback) in
  486. _ = Database.shared.updateRecord(fmdb: fmdb, table: "BUDDY", cvalues: [
  487. "ex_block" : block
  488. ], _where: "f_pin = '\(l_pin)'")
  489. })
  490. if let delegate = Nexilis.shared.personInfoDelegate {
  491. var object = [String:String]()
  492. let encoder = JSONEncoder()
  493. object["l_pin"] = l_pin
  494. object["block"] = block
  495. let data = try! encoder.encode(object)
  496. delegate.onUpdatePersonInfo(state: 01, message: String(data: data, encoding: .utf8)!)
  497. }
  498. ack(message: message)
  499. }
  500. private func deleteComment(message: TMessage) -> Void {
  501. if let delegate = Nexilis.shared.commentDelegate {
  502. delegate.onDeleteComment(message: message)
  503. }
  504. ack(message: message)
  505. }
  506. private func receiveComment(message: TMessage) -> Void {
  507. if let delegate = Nexilis.shared.commentDelegate {
  508. delegate.onReceiveComment(message: message)
  509. }
  510. ack(message: message)
  511. }
  512. private func sendUpdateTyping(message: TMessage) -> Void {
  513. print("update typing \(message)")
  514. if let delegate = Nexilis.shared.messageDelegate {
  515. delegate.onTyping(message: message)
  516. }
  517. ack(message: message)
  518. }
  519. private func deleteMessage(message: TMessage) -> Void {
  520. var messageId = message.getBody(key: CoreMessage_TMessageKey.MESSAGE_ID)
  521. if message.mBodies["message_id"] != nil {
  522. messageId = message.getBody(key: "message_id")
  523. }
  524. let type = message.getBody(key: CoreMessage_TMessageKey.DELETE_MESSAGE_FLAG)
  525. Database.shared.database?.inTransaction({ (fmdb, rollback) in
  526. if type == "1" {
  527. if !messageId.contains("'") {
  528. messageId = "'\(messageId)'"
  529. }
  530. _ = Database.shared.updateRecord(fmdb: fmdb, table: "MESSAGE", cvalues: [
  531. "message_text" : "🚫 _This message was deleted_",
  532. "lock" : "1",
  533. "thumb_id" : "",
  534. "image_id" : "",
  535. "file_id" : "",
  536. "audio_id" : "",
  537. "video_id" : "",
  538. "reff_id" : "",
  539. "attachment_flag" : 0,
  540. "is_stared" : "0",
  541. "credential" : "0",
  542. "read_receipts" : "4"
  543. ], _where: "message_id = \(messageId)")
  544. }
  545. if let delegate = Nexilis.shared.messageDelegate {
  546. delegate.onMessage(message: message)
  547. }
  548. })
  549. ack(message: message)
  550. }
  551. private func imageDownload(message: TMessage) -> Void {
  552. let key_filename = message.getBody(key: CoreMessage_TMessageKey.FILE_NAME)
  553. let key_part_size = message.getBodyAsInteger(key: CoreMessage_TMessageKey.PART_SIZE, default_value: 0)
  554. let key_part_of = message.getBodyAsInteger(key: CoreMessage_TMessageKey.PART_OF, default_value: 0)
  555. let key_file_size = message.getBodyAsInteger(key: CoreMessage_TMessageKey.FILE_SIZE, default_value: 0)
  556. let media = message.getMedia()
  557. var data = Data(media)
  558. if !key_filename.isEmpty, data.count == 0, let download = Nexilis.getDownload(forKey: key_filename) {
  559. print("corrupted...", key_filename)
  560. if let delegate = download.delegate {
  561. delegate.onDownloadProgress(fileName: key_filename, progress: -1)
  562. } else if let completion = download.onDownloadProgress {
  563. completion(key_filename, -1)
  564. }
  565. return
  566. }
  567. if media.count > 0 {
  568. if key_part_size > 0, let download = Nexilis.getDownload(forKey: key_filename) {
  569. download.put(part: key_part_of, buffer: Data(media))
  570. if download.size() == key_file_size {
  571. data = download.remove()
  572. } else {
  573. let progress = Double(download.size()) / Double(key_file_size) * 100.0
  574. if let delegate = download.delegate {
  575. delegate.onDownloadProgress(fileName: key_filename, progress: progress)
  576. } else if let completion = download.onDownloadProgress {
  577. completion(key_filename, progress)
  578. }
  579. return
  580. }
  581. }
  582. }
  583. do {
  584. let documentDir = try FileManager.default.url(for: .documentDirectory, in: .userDomainMask, appropriateFor: nil, create: true)
  585. let url = documentDir.appendingPathComponent(key_filename)
  586. print("write file \(url.path)")
  587. try data.write(to: url, options: .atomic)
  588. if let download = Nexilis.getDownload(forKey: key_filename) {
  589. if let delegate = download.delegate {
  590. delegate.onDownloadProgress(fileName: key_filename, progress: 100)
  591. } else if let completion = download.onDownloadProgress {
  592. completion(key_filename, 100)
  593. }
  594. }
  595. } catch {
  596. print(error)
  597. if let download = Nexilis.getDownload(forKey: key_filename) {
  598. if let delegate = download.delegate {
  599. delegate.onDownloadProgress(fileName: key_filename, progress: -1)
  600. } else if let completion = download.onDownloadProgress {
  601. completion(key_filename, -1)
  602. }
  603. }
  604. }
  605. ack(message: message)
  606. }
  607. private func deleteChat(message: TMessage) -> Void {
  608. let chat_id = message.getBody(key: CoreMessage_TMessageKey.CHAT_ID)
  609. Database.shared.database?.inTransaction({ (fmdb, rollback) in
  610. _ = Database.shared.deleteRecord(fmdb: fmdb, table: "DISCUSSION_FORUM", _where: "chat_id = '\(chat_id)'")
  611. })
  612. if let delegate = Nexilis.shared.groupDelegate {
  613. delegate.onTopic(code: message.getCode(), f_pin: message.getPIN(), topicId: chat_id)
  614. }
  615. ack(message: message)
  616. }
  617. private func updateChat(message: TMessage) -> Void {
  618. let chat_id = message.getBody(key: CoreMessage_TMessageKey.CHAT_ID)
  619. Database.shared.database?.inTransaction({ (fmdb, rollback) in
  620. _ = Database.shared.updateRecord(fmdb: fmdb, table: "DISCUSSION_FORUM", cvalues: [
  621. "title" : message.getBody(key: CoreMessage_TMessageKey.TITLE)
  622. ], _where: "chat_id = '\(chat_id)'")
  623. })
  624. if let delegate = Nexilis.shared.groupDelegate {
  625. delegate.onTopic(code: message.getCode(), f_pin: message.getPIN(), topicId: chat_id)
  626. }
  627. ack(message: message)
  628. }
  629. private func pushServiceBNI(message: TMessage) -> Void {
  630. let data = message.getBody(key: CoreMessage_TMessageKey.DATA)
  631. if !data.isEmpty {
  632. if let jsonArray = try! JSONSerialization.jsonObject(with: data.data(using: String.Encoding.utf8)!, options: JSONSerialization.ReadingOptions()) as? [AnyObject] {
  633. Database.shared.database?.inTransaction({ (fmdb, rollback) in
  634. do {
  635. for json in jsonArray {
  636. var parent = CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.PARENT_ID)
  637. if parent.isEmpty {
  638. parent = "-99"
  639. }
  640. _ = try Database.shared.insertRecord(fmdb: fmdb, table: "SERVICE_BANK", cvalues: [
  641. "service_id" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.CATEGORY_ID),
  642. "service_name" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.NAME),
  643. "description" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.DESCRIPTION),
  644. "parent" : parent,
  645. "is_tablet" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.PLATFORM)
  646. ], replace: true)
  647. }
  648. ack(message: message)
  649. } catch {
  650. rollback.pointee = true
  651. print(error)
  652. }
  653. })
  654. }
  655. }
  656. }
  657. private func changeGroupInfo(message: TMessage) -> Void {
  658. let group_id = message.getBody(key: CoreMessage_TMessageKey.GROUP_ID)
  659. let group_name = message.getBody(key: CoreMessage_TMessageKey.GROUP_NAME)
  660. let thumb_id = message.getBody(key: CoreMessage_TMessageKey.THUMB_ID)
  661. let quote = message.getBody(key: CoreMessage_TMessageKey.QUOTE)
  662. let chat_modifier = message.getBody(key: CoreMessage_TMessageKey.CHAT_MODIFIER)
  663. let last_update = message.getBody(key: CoreMessage_TMessageKey.LAST_UPDATE)
  664. let is_open = message.getBody(key: CoreMessage_TMessageKey.IS_OPEN)
  665. let official = message.getBody(key: CoreMessage_TMessageKey.OFFICIAL_ACCOUNT)
  666. let lvl_edu = message.getBody(key: CoreMessage_TMessageKey.LEVEL_EDU)
  667. let mtr_edu = message.getBody(key: CoreMessage_TMessageKey.MATERI_EDU)
  668. let is_edu = message.getBody(key: CoreMessage_TMessageKey.IS_EDUCATION)
  669. var cvalues = [String:String]()
  670. if (!group_name.isEmpty) { cvalues["f_name"] = group_name }
  671. if (!thumb_id.isEmpty) { cvalues["image_id"] = thumb_id }
  672. if (!quote.isEmpty) { cvalues["quote"] = quote }
  673. if (!chat_modifier.isEmpty) { cvalues["chat_modifier"] = chat_modifier }
  674. if (!last_update.isEmpty) { cvalues["last_update"] = last_update }
  675. if (!is_open.isEmpty) { cvalues["is_open"] = is_open }
  676. if (!official.isEmpty) { cvalues["official"] = official }
  677. if (!lvl_edu.isEmpty) { cvalues["level_edu"] = official }
  678. if (!mtr_edu.isEmpty) { cvalues["materi_edu"] = official }
  679. if (!is_edu.isEmpty) { cvalues["is_education"] = official }
  680. Database.shared.database?.inTransaction({ (fmdb, rollback) in
  681. _ = Database.shared.updateRecord(fmdb: fmdb, table: "GROUPZ", cvalues: cvalues, _where: "group_id = '\(group_id)'")
  682. })
  683. if let delegate = Nexilis.shared.groupDelegate {
  684. delegate.onGroup(code: message.getCode(), f_pin: message.getPIN(), groupId: group_id)
  685. }
  686. ack(message: message)
  687. }
  688. private func exitGroup(message: TMessage) -> Void {
  689. let f_pin = message.getBody(key: CoreMessage_TMessageKey.F_PIN)
  690. let group_id = message.getBody(key: CoreMessage_TMessageKey.GROUP_ID)
  691. if let me = UserDefaults.standard.string(forKey: "me"), me == f_pin {
  692. Database.shared.database?.inTransaction({ (fmdb, rollback) in
  693. if let cursorIsEducation = Database.shared.getRecords(fmdb: fmdb, query: "select is_education from GROUPZ where group_id='\(group_id)'"), cursorIsEducation.next() {
  694. let is_education = Int(cursorIsEducation.int(forColumnIndex: 0))
  695. if (is_education == 3 || is_education == 2 || is_education == 4) {
  696. _ = Database.shared.deleteRecord(fmdb: fmdb, table: "GROUPZ_MEMBER", _where: "group_id = '\(group_id)' and f_pin = '\(f_pin)'")
  697. _ = Database.shared.deleteRecord(fmdb: fmdb, table: "MESSAGE", _where: "l_pin='\(group_id)'")
  698. _ = Database.shared.deleteRecord(fmdb: fmdb, table: "MESSAGE_SUMMARY", _where: "l_pin='\(group_id)'")
  699. if let cursor = Database.shared.getRecords(fmdb: fmdb, query: "select chat_id from DISCUSSION_FORUM where group_id='\(group_id)'") {
  700. while cursor.next() {
  701. if let chat_id = cursor.string(forColumnIndex: 0) {
  702. _ = Database.shared.deleteRecord(fmdb: fmdb, table: "MESSAGE_SUMMARY", _where: "l_pin='\(chat_id)'")
  703. }
  704. }
  705. cursor.close()
  706. }
  707. } else {
  708. _ = Database.shared.deleteRecord(fmdb: fmdb, table: "GROUPZ", _where: "group_id = '\(group_id)'")
  709. _ = Database.shared.deleteRecord(fmdb: fmdb, table: "MESSAGE", _where: "l_pin='\(group_id)'")
  710. _ = Database.shared.deleteRecord(fmdb: fmdb, table: "MESSAGE_SUMMARY", _where: "l_pin='\(group_id)'")
  711. if let cursor = Database.shared.getRecords(fmdb: fmdb, query: "select chat_id from DISCUSSION_FORUM where group_id='\(group_id)'") {
  712. while cursor.next() {
  713. if let chat_id = cursor.string(forColumnIndex: 0) {
  714. _ = Database.shared.deleteRecord(fmdb: fmdb, table: "MESSAGE_SUMMARY", _where: "l_pin='\(chat_id)'")
  715. }
  716. }
  717. cursor.close()
  718. }
  719. if let cursorSub = Database.shared.getRecords(fmdb: fmdb, query: "select group_id from GROUPZ where parent='\(group_id)'") {
  720. while cursorSub.next() {
  721. if let subGroup = cursorSub.string(forColumnIndex: 0) {
  722. _ = Database.shared.deleteRecord(fmdb: fmdb, table: "GROUPZ", _where: "group_id = '\(subGroup)'")
  723. _ = Database.shared.deleteRecord(fmdb: fmdb, table: "MESSAGE", _where: "l_pin='\(subGroup)'")
  724. _ = Database.shared.deleteRecord(fmdb: fmdb, table: "MESSAGE_SUMMARY", _where: "l_pin='\(subGroup)'")
  725. if let cursorSubGroupTopic = Database.shared.getRecords(fmdb: fmdb, query: "select chat_id from DISCUSSION_FORUM where group_id='\(subGroup)'") {
  726. while cursorSubGroupTopic.next() {
  727. if let chat_id_sub = cursorSubGroupTopic.string(forColumnIndex: 0) {
  728. _ = Database.shared.deleteRecord(fmdb: fmdb, table: "MESSAGE_SUMMARY", _where: "l_pin='\(chat_id_sub)'")
  729. }
  730. }
  731. cursorSubGroupTopic.close()
  732. }
  733. }
  734. }
  735. cursorSub.close()
  736. }
  737. }
  738. cursorIsEducation.close()
  739. }
  740. })
  741. } else {
  742. Database.shared.database?.inTransaction({ (fmdb, rollback) in
  743. _ = Database.shared.deleteRecord(fmdb: fmdb, table: "GROUPZ_MEMBER", _where: "group_id = '\(group_id)' and f_pin = '\(f_pin)'")
  744. })
  745. }
  746. if let delegate = Nexilis.shared.groupDelegate {
  747. delegate.onMember(code: message.getCode(), f_pin: message.getPIN(), groupId: group_id, member: f_pin)
  748. }
  749. ack(message: message)
  750. }
  751. private func changeGroupPosition(message: TMessage) -> Void {
  752. let group_id = message.getBody(key: CoreMessage_TMessageKey.GROUP_ID)
  753. let f_pin = message.getBody(key: CoreMessage_TMessageKey.F_PIN)
  754. let position = message.getBody(key: CoreMessage_TMessageKey.POSITION)
  755. Database.shared.database?.inTransaction({ (fmdb, rollback) in
  756. _ = Database.shared.updateRecord(fmdb: fmdb, table: "GROUPZ_MEMBER", cvalues: [
  757. "position" : position
  758. ], _where: "group_id = '\(group_id)' and f_pin = '\(f_pin)'")
  759. })
  760. if let delegate = Nexilis.shared.groupDelegate {
  761. delegate.onMember(code: message.getCode(), f_pin: message.getPIN(), groupId: group_id, member: f_pin)
  762. }
  763. ack(message: message)
  764. }
  765. var listPushGroupMember: [TMessage] = []
  766. private func pushGroupMembers(message: TMessage, isFromIncoming: Bool = true) -> Void {
  767. let group_id = message.getBody(key: CoreMessage_TMessageKey.GROUP_ID)
  768. let f_pin = message.getBody(key: CoreMessage_TMessageKey.F_PIN)
  769. if(f_pin.isEmpty) {
  770. let data = message.getBody(key: CoreMessage_TMessageKey.DATA)
  771. if !data.isEmpty {
  772. if let jsonArray = try! JSONSerialization.jsonObject(with: data.data(using: String.Encoding.utf8)!, options: JSONSerialization.ReadingOptions()) as? [AnyObject] {
  773. Database.shared.database?.inTransaction({ (fmdb, rollback) in
  774. do {
  775. for json in jsonArray {
  776. _ = try Database.shared.insertRecord(fmdb: fmdb, table: "GROUPZ_MEMBER", cvalues: [
  777. "group_id" : group_id,
  778. "f_pin" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.F_PIN),
  779. "position" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.POSITION),
  780. "user_id" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.USER_ID),
  781. "ac" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.AC),
  782. "ac_desc" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.AC_DESC),
  783. "first_name" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.FIRST_NAME),
  784. "last_name" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.LAST_NAME),
  785. "msisdn" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.MSISDN),
  786. "thumb_id" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.THUMB_ID),
  787. "created_date" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.CREATED_DATE)
  788. ], replace: true)
  789. }
  790. if let delegate = Nexilis.shared.groupDelegate {
  791. delegate.onMember(code: message.getCode(), f_pin: message.getPIN(), groupId: group_id, member: "")
  792. }
  793. ack(message: message)
  794. } catch {
  795. rollback.pointee = true
  796. print(error)
  797. }
  798. })
  799. }
  800. }
  801. } else {
  802. if isFromIncoming {
  803. listPushGroupMember.append(message)
  804. }
  805. if listPushGroupMember.count == 1 || !isFromIncoming {
  806. Database.shared.database?.inTransaction({ (fmdb, rollback) in
  807. do {
  808. let result = try Database.shared.insertRecord(fmdb: fmdb, table: "GROUPZ_MEMBER", cvalues: [
  809. "group_id" : group_id,
  810. "f_pin" : f_pin,
  811. "position" : message.getBody(key: CoreMessage_TMessageKey.POSITION),
  812. "user_id" : message.getBody(key: CoreMessage_TMessageKey.USER_ID),
  813. "ac" : message.getBody(key: CoreMessage_TMessageKey.AC),
  814. "ac_desc" : message.getBody(key: CoreMessage_TMessageKey.AC_DESC),
  815. "first_name" : message.getBody(key: CoreMessage_TMessageKey.FIRST_NAME),
  816. "last_name" : message.getBody(key: CoreMessage_TMessageKey.LAST_NAME),
  817. "msisdn" : message.getBody(key: CoreMessage_TMessageKey.MSISDN),
  818. "thumb_id" : message.getBody(key: CoreMessage_TMessageKey.THUMB_ID),
  819. "created_date" : message.getBody(key: CoreMessage_TMessageKey.CREATED_DATE)
  820. ], replace: true)
  821. if result > 0 {
  822. if let delegate = Nexilis.shared.groupDelegate {
  823. delegate.onMember(code: message.getCode(), f_pin: message.getPIN(), groupId: group_id, member: f_pin)
  824. }
  825. self.listPushGroupMember.remove(at: 0)
  826. ack(message: message)
  827. if listPushGroupMember.count > 0 {
  828. dispatchQueue.asyncAfter(deadline: .now() + 1, execute: {
  829. self.pushGroupMembers(message: self.listPushGroupMember[0], isFromIncoming: false)
  830. })
  831. }
  832. }
  833. } catch {
  834. rollback.pointee = true
  835. print(error)
  836. }
  837. })
  838. }
  839. }
  840. }
  841. private func pushGroup(message: TMessage) -> Void {
  842. let data = message.getBody(key: CoreMessage_TMessageKey.DATA)
  843. if !data.isEmpty {
  844. if let jsonArray = try! JSONSerialization.jsonObject(with: data.data(using: String.Encoding.utf8)!, options: JSONSerialization.ReadingOptions()) as? [AnyObject] {
  845. Database.shared.database?.inTransaction({ (fmdb, rollback) in
  846. do {
  847. for json in jsonArray {
  848. let group_id = CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.GROUP_ID)
  849. _ = try Database.shared.insertRecord(fmdb: fmdb, table: "GROUPZ", cvalues: [
  850. "group_id" : group_id,
  851. "f_name" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.GROUP_NAME),
  852. "scope_id" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.MESSAGE_SCOPE_ID),
  853. "image_id": CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.THUMB_ID),
  854. "quote": CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.QUOTE),
  855. "last_update" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.LAST_UPDATE),
  856. "created_by" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.CREATED_BY),
  857. "created_date" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.CREATED_DATE),
  858. "ex_block" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.BLOCK),
  859. "folder_id" : "",
  860. "chat_modifier" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.CHAT_MODIFIER),
  861. "group_type" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.IS_ORGANIZATION),
  862. "parent" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.PARENT_ID),
  863. "level" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.LEVEL),
  864. "is_open" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.IS_OPEN),
  865. "official" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.OFFICIAL_ACCOUNT),
  866. "level_edu" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.LEVEL_EDU),
  867. "materi_edu" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.MATERI_EDU),
  868. "is_education" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.IS_EDUCATION)
  869. ], replace: true)
  870. if let delegate = Nexilis.shared.groupDelegate {
  871. delegate.onGroup(code: message.getCode(), f_pin: message.getPIN(), groupId: group_id)
  872. }
  873. }
  874. ack(message: message)
  875. } catch {
  876. rollback.pointee = true
  877. print(error)
  878. }
  879. })
  880. }
  881. } else {
  882. let group_id = message.getBody(key: CoreMessage_TMessageKey.GROUP_ID)
  883. Database.shared.database?.inTransaction({ (fmdb, rollback) in
  884. do {
  885. let result = try Database.shared.insertRecord(fmdb: fmdb, table: "GROUPZ", cvalues: [
  886. "group_id" : group_id,
  887. "f_name" : message.getBody(key: CoreMessage_TMessageKey.GROUP_NAME),
  888. "scope_id" : message.getBody(key: CoreMessage_TMessageKey.MESSAGE_SCOPE_ID),
  889. "image_id": message.getBody(key: CoreMessage_TMessageKey.THUMB_ID),
  890. "quote": message.getBody(key: CoreMessage_TMessageKey.QUOTE),
  891. "last_update" : message.getBody(key: CoreMessage_TMessageKey.LAST_UPDATE),
  892. "created_by" : message.getBody(key: CoreMessage_TMessageKey.CREATED_BY),
  893. "created_date" : message.getBody(key: CoreMessage_TMessageKey.CREATED_DATE),
  894. "ex_block" : message.getBody(key: CoreMessage_TMessageKey.BLOCK),
  895. "folder_id" : "",
  896. "chat_modifier" : message.getBody(key: CoreMessage_TMessageKey.CHAT_MODIFIER),
  897. "group_type" : message.getBody(key: CoreMessage_TMessageKey.IS_ORGANIZATION),
  898. "parent" : message.getBody(key: CoreMessage_TMessageKey.PARENT_ID),
  899. "level" : message.getBody(key: CoreMessage_TMessageKey.LEVEL),
  900. "is_open" : message.getBody(key: CoreMessage_TMessageKey.IS_OPEN),
  901. "official" : message.getBody(key: CoreMessage_TMessageKey.OFFICIAL_ACCOUNT),
  902. "level_edu" : message.getBody(key: CoreMessage_TMessageKey.LEVEL_EDU),
  903. "materi_edu" : message.getBody(key: CoreMessage_TMessageKey.MATERI_EDU),
  904. "is_education" : message.getBody(key: CoreMessage_TMessageKey.IS_EDUCATION)
  905. ], replace: true)
  906. if result > 0 {
  907. if let delegate = Nexilis.shared.groupDelegate {
  908. delegate.onGroup(code: message.getCode(), f_pin: message.getPIN(), groupId: group_id)
  909. }
  910. ack(message: message)
  911. }
  912. } catch {
  913. rollback.pointee = true
  914. print(error)
  915. }
  916. })
  917. }
  918. }
  919. private func receiveMessage(message: TMessage) -> Void {
  920. let message_id = message.getBody(key: CoreMessage_TMessageKey.MESSAGE_ID)
  921. guard let _ = UserDefaults.standard.string(forKey: "status") else {
  922. print("App not ready!!! skip receive message \(message_id)")
  923. ack(message: message)
  924. return
  925. }
  926. Database.shared.database?.inTransaction({ (fmdb, rollback) in
  927. if let cursor = Database.shared.getRecords(fmdb: fmdb, query: "select message_id from MESSAGE where message_id = '\(message_id)'"), cursor.next() {
  928. ack(message: message)
  929. cursor.close()
  930. return
  931. }
  932. })
  933. let media = message.getMedia()
  934. print("MEDIA \(media)");
  935. let thumb_id = message.getBody(key: CoreMessage_TMessageKey.THUMB_ID)
  936. if media.count > 0 {
  937. do {
  938. let data = Data(media)
  939. let documentDir = try FileManager.default.url(for: .documentDirectory, in: .userDomainMask, appropriateFor: nil, create: true)
  940. let url = documentDir.appendingPathComponent(thumb_id)
  941. print("write thumb \(url.path)")
  942. try data.write(to: url, options: .atomic)
  943. // let image = UIImage(data: data)
  944. // let save = UserDefaults.standard.bool(forKey: "saveToGallery")
  945. // if save {
  946. // UIImageWriteToSavedPhotosAlbum(image!, nil, nil, nil)
  947. // }
  948. } catch {
  949. print(error)
  950. }
  951. }
  952. if (!thumb_id.isEmpty) {
  953. Download().start(forKey: thumb_id) { (file, progress) in
  954. print ("masuk download \(progress)")
  955. if(progress == 100) {
  956. Nexilis.saveMessage(message: message, withStatus: false)
  957. print("save message incoming")
  958. }
  959. }
  960. ack(message: message)
  961. return
  962. }
  963. Nexilis.saveMessage(message: message, withStatus: false)
  964. print("save message incoming")
  965. ack(message: message)
  966. }
  967. private func receiveMessageStatus(message: TMessage) -> Void {
  968. let message_id = message.getBody(key: CoreMessage_TMessageKey.MESSAGE_ID)
  969. guard let _ = UserDefaults.standard.string(forKey: "status") else {
  970. print("App not ready!!! skip receive message \(message_id)")
  971. return
  972. }
  973. Nexilis.updateMessageStatus(message: message)
  974. if let delegate = Nexilis.shared.messageDelegate {
  975. delegate.onMessage(message: message)
  976. }
  977. ack(message: message)
  978. }
  979. private func uploadFile(message: TMessage) -> Void {
  980. let fileName = message.getBody(key: "file_id")
  981. guard !fileName.isEmpty else {
  982. return
  983. }
  984. guard let upload = Nexilis.getUploadFile(forKey: fileName) else {
  985. return
  986. }
  987. upload.uploadGroup.leave()
  988. ack(message: message)
  989. }
  990. private func initBatchBuddy(message: TMessage) -> Void {
  991. let data = message.getBody(key: CoreMessage_TMessageKey.DATA)
  992. if let jsonArray = try! JSONSerialization.jsonObject(with: data.data(using: String.Encoding.utf8)!, options: JSONSerialization.ReadingOptions()) as? [AnyObject] {
  993. Database.shared.database?.inTransaction({ (fmdb, rollback) in
  994. do {
  995. for json in jsonArray {
  996. _ = try Database.shared.insertRecord(fmdb: fmdb, table: "BUDDY", cvalues: [
  997. "f_pin" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.F_PIN),
  998. "upline_pin" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.UPLINE_PIN),
  999. "first_name" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.FIRST_NAME),
  1000. "last_name" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.LAST_NAME),
  1001. "image_id" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.THUMB_ID),
  1002. "user_id" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.USER_ID),
  1003. "quote" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.QUOTE),
  1004. "connected" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.CONNECTED),
  1005. "last_update" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.LAST_UPDATE),
  1006. "latitude" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.LATITUDE),
  1007. "longitude" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.LONGITUDE),
  1008. "altitude" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.ALTITUDE),
  1009. "cell" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.CELL),
  1010. "last_loc_update" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.LAST_LOC_UPDATE),
  1011. "type" : "0",
  1012. "empty_2" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.PLACE_NAME),
  1013. "timezone" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.TIMEZONE),
  1014. "privacy_flag" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.PRIVACY_FLAG),
  1015. "msisdn" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.MSISDN),
  1016. "email" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.EMAIL),
  1017. "created_date" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.CREATED_DATE),
  1018. "offline_mode" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.OFFLINE_MODE),
  1019. "network_type" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.NETWORK_TYPE),
  1020. "ex_block" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.BLOCK),
  1021. "ex_follow" : "0",
  1022. "ex_follower" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.TOTAL_FOLLOWERS),
  1023. "ex_offmp" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.OFFMP),
  1024. "ex_status" : "1",
  1025. "shop_code" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.SHOP_CODE),
  1026. "shop_name" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.SHOP_NAME),
  1027. "extension" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.EXTENSION),
  1028. "auto_quote" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.AUTO_QUOTE),
  1029. "auto_quote_type" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.AUTO_QUOTE_TYPE),
  1030. "android_version" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.ANDROID_VERSION),
  1031. "device_id" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.IMEI),
  1032. "be_info" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.BE_INFO),
  1033. "org_id" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.ORG_ID),
  1034. "org_name" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.ORG_NAME),
  1035. "org_thumb" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.ORG_THUMB),
  1036. "gender" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.GENDER),
  1037. "birthdate" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.BIRTHDATE),
  1038. "type_ads" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.TYPE_ADS),
  1039. "type_lp" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.TYPE_LP),
  1040. "type_post" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.TYPE_POST),
  1041. "address" : message.getBody(key: CoreMessage_TMessageKey.ADDRESS),
  1042. "bidang_industri" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.BIDANG_INDUSTRI),
  1043. "visi" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.VISI),
  1044. "misi" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.MISI),
  1045. "company_lat" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.COMPANY_LAT),
  1046. "company_lng" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.COMPANY_LNG),
  1047. "web" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.COMPANY_WEB),
  1048. "certificate_image" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.COMPANY_CERTIFICATE),
  1049. "card_id" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.CARD_ID),
  1050. "user_type" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.USER_TYPE),
  1051. "real_name" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.REAL_NAME),
  1052. "official_account" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.OFFICIAL_ACCOUNT),
  1053. "is_sub_account" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.IS_SUB_ACCOUNT),
  1054. "last_sign" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.LAST_SIGN),
  1055. "android_id" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.ANDROID_ID),
  1056. "is_change_profile" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.IS_CHANGE_PROFILE),
  1057. "area" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.WORKING_AREA),
  1058. "is_second_layer" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.IS_SECOND_LAYER),
  1059. ], replace: true)
  1060. _ = Database.shared.updateRecord(fmdb: fmdb, table: "GROUPZ_MEMBER", cvalues: [
  1061. "first_name" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.FIRST_NAME),
  1062. "last_name" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.LAST_NAME),
  1063. "thumb_id" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.THUMB_ID),
  1064. ], _where: "f_pin = '\(CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.F_PIN))'")
  1065. _ = Database.shared.updateRecord(fmdb: fmdb, table: "MESSAGE", cvalues: [
  1066. "f_display_name" : (CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.FIRST_NAME) + " " + CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.LAST_NAME)).trimmingCharacters(in: .whitespaces)
  1067. ], _where: "f_pin = '\(CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.F_PIN))'")
  1068. }
  1069. let device_id = UserDefaults.standard.string(forKey: "device_id") ?? ""
  1070. if !device_id.isEmpty, let cursorUser = Database.shared.getRecords(fmdb: fmdb, query: "SELECT f_pin FROM BUDDY where device_id='\(device_id)'"), cursorUser.next() {
  1071. UserDefaults.standard.setValue(cursorUser.string(forColumnIndex: 0), forKey: "me")
  1072. cursorUser.close()
  1073. }
  1074. if let delegate = Nexilis.shared.personInfoDelegate {
  1075. delegate.onUpdatePersonInfo(state: 99, message: "update_buddy")
  1076. }
  1077. ack(message: message)
  1078. } catch {
  1079. rollback.pointee = true
  1080. print(error)
  1081. }
  1082. })
  1083. }
  1084. }
  1085. private func deleteBuddy(message: TMessage) -> Void {
  1086. var l_pin = message.getBody(key: CoreMessage_TMessageKey.L_PIN)
  1087. l_pin = (l_pin == UserDefaults.standard.string(forKey: "me")) ? message.mPIN : l_pin
  1088. Database.shared.database?.inTransaction({ (fmdb, rollback) in
  1089. do {
  1090. if let cursor = Database.shared.getRecords(fmdb: fmdb, query: "select * from BUDDY where f_pin = '\(l_pin)'"), cursor.next() {
  1091. _ = Database.shared.deleteRecord(fmdb: fmdb, table: "BUDDY", _where: "f_pin = '\(l_pin)'")
  1092. _ = Database.shared.deleteRecord(fmdb: fmdb, table: "MESSAGE", _where: "(f_pin='\(l_pin)' or l_pin='\(l_pin)') and (message_scope_id='3' or message_scope_id='18')")
  1093. _ = Database.shared.deleteRecord(fmdb: fmdb, table: "MESSAGE_SUMMARY", _where: "l_pin='\(l_pin)'")
  1094. _ = Database.shared.deleteRecord(fmdb: fmdb, table: "POST", _where: "author_f_pin='\(l_pin)'")
  1095. cursor.close()
  1096. print("Buddy deleted: \(l_pin)")
  1097. if let delegate = Nexilis.shared.personInfoDelegate {
  1098. delegate.onUpdatePersonInfo(state: 99, message: "delete_buddy,\(l_pin)")
  1099. }
  1100. }
  1101. ack(message: message)
  1102. }
  1103. })
  1104. }
  1105. private func pushMyself(message: TMessage) -> Void {
  1106. Database.shared.database?.inTransaction({ (fmdb, rollback) in
  1107. do {
  1108. let result = try Database.shared.insertRecord(fmdb: fmdb, table: "BUDDY", cvalues: [
  1109. "f_pin" : message.getBody(key: CoreMessage_TMessageKey.F_PIN),
  1110. "upline_pin" : message.getBody(key: CoreMessage_TMessageKey.UPLINE_PIN),
  1111. "first_name" : message.getBody(key: CoreMessage_TMessageKey.FIRST_NAME),
  1112. "last_name" : message.getBody(key: CoreMessage_TMessageKey.LAST_NAME),
  1113. "image_id" : message.getBody(key: CoreMessage_TMessageKey.THUMB_ID),
  1114. "user_id" : message.getBody(key: CoreMessage_TMessageKey.USER_ID),
  1115. "quote" : message.getBody(key: CoreMessage_TMessageKey.QUOTE),
  1116. "connected" : message.getBody(key: CoreMessage_TMessageKey.CONNECTED),
  1117. "last_update" : message.getBody(key: CoreMessage_TMessageKey.LAST_UPDATE),
  1118. "latitude" : message.getBody(key: CoreMessage_TMessageKey.LATITUDE),
  1119. "longitude" : message.getBody(key: CoreMessage_TMessageKey.LONGITUDE),
  1120. "altitude" : message.getBody(key: CoreMessage_TMessageKey.ALTITUDE),
  1121. "cell" : message.getBody(key: CoreMessage_TMessageKey.CELL),
  1122. "last_loc_update" : message.getBody(key: CoreMessage_TMessageKey.LAST_LOC_UPDATE),
  1123. "type" : "1",
  1124. "empty_2" : message.getBody(key: CoreMessage_TMessageKey.PLACE_NAME),
  1125. "timezone" : message.getBody(key: CoreMessage_TMessageKey.TIMEZONE),
  1126. "privacy_flag" : message.getBody(key: CoreMessage_TMessageKey.PRIVACY_FLAG),
  1127. "msisdn" : message.getBody(key: CoreMessage_TMessageKey.MSISDN),
  1128. "email" : message.getBody(key: CoreMessage_TMessageKey.EMAIL),
  1129. "created_date" : message.getBody(key: CoreMessage_TMessageKey.CREATED_DATE),
  1130. "offline_mode" : message.getBody(key: CoreMessage_TMessageKey.OFFLINE_MODE),
  1131. "network_type" : message.getBody(key: CoreMessage_TMessageKey.NETWORK_TYPE),
  1132. "ex_block" : "0",
  1133. "ex_follow" : "0",
  1134. "ex_follower" : message.getBody(key: CoreMessage_TMessageKey.TOTAL_FOLLOWERS),
  1135. "ex_offmp" : message.getBody(key: CoreMessage_TMessageKey.OFFMP),
  1136. "ex_status" : "0",
  1137. "device_id" : message.getBody(key: CoreMessage_TMessageKey.IMEI),
  1138. "shop_code" : message.getBody(key: CoreMessage_TMessageKey.SHOP_CODE),
  1139. "shop_name" : message.getBody(key: CoreMessage_TMessageKey.SHOP_NAME),
  1140. "extension" : message.getBody(key: CoreMessage_TMessageKey.EXTENSION),
  1141. "auto_quote" : message.getBody(key: CoreMessage_TMessageKey.AUTO_QUOTE),
  1142. "auto_quote_type" : message.getBody(key: CoreMessage_TMessageKey.AUTO_QUOTE_TYPE),
  1143. "be_info" : message.getBody(key: CoreMessage_TMessageKey.BE_INFO),
  1144. "org_id" : message.getBody(key: CoreMessage_TMessageKey.ORG_ID),
  1145. "org_name" : message.getBody(key: CoreMessage_TMessageKey.ORG_NAME),
  1146. "org_thumb" : message.getBody(key: CoreMessage_TMessageKey.ORG_THUMB),
  1147. "gender" : message.getBody(key: CoreMessage_TMessageKey.GENDER),
  1148. "birthdate" : message.getBody(key: CoreMessage_TMessageKey.BIRTHDATE),
  1149. "type_ads" : message.getBody(key: CoreMessage_TMessageKey.TYPE_ADS),
  1150. "type_lp" : message.getBody(key: CoreMessage_TMessageKey.TYPE_LP),
  1151. "type_post" : message.getBody(key: CoreMessage_TMessageKey.TYPE_POST),
  1152. "address" : message.getBody(key: CoreMessage_TMessageKey.ADDRESS),
  1153. "bidang_industri" : message.getBody(key: CoreMessage_TMessageKey.BIDANG_INDUSTRI),
  1154. "visi" : message.getBody(key: CoreMessage_TMessageKey.VISI),
  1155. "misi" : message.getBody(key: CoreMessage_TMessageKey.MISI),
  1156. "company_lat" : message.getBody(key: CoreMessage_TMessageKey.COMPANY_LAT),
  1157. "company_lng" : message.getBody(key: CoreMessage_TMessageKey.COMPANY_LNG),
  1158. "web" : message.getBody(key: CoreMessage_TMessageKey.COMPANY_WEB),
  1159. "certificate_image" : message.getBody(key: CoreMessage_TMessageKey.COMPANY_CERTIFICATE),
  1160. "card_id" : message.getBody(key: CoreMessage_TMessageKey.CARD_ID),
  1161. "user_type" : message.getBody(key: CoreMessage_TMessageKey.USER_TYPE),
  1162. "real_name" : message.getBody(key: CoreMessage_TMessageKey.REAL_NAME),
  1163. "official_account" : message.getBody(key: CoreMessage_TMessageKey.OFFICIAL_ACCOUNT),
  1164. "is_sub_account" : message.getBody(key: CoreMessage_TMessageKey.IS_SUB_ACCOUNT),
  1165. "last_sign" : message.getBody(key: CoreMessage_TMessageKey.LAST_SIGN),
  1166. "android_id" : message.getBody(key: CoreMessage_TMessageKey.ANDROID_ID),
  1167. "is_change_profile" : message.getBody(key: CoreMessage_TMessageKey.IS_CHANGE_PROFILE),
  1168. "area" : message.getBody(key: CoreMessage_TMessageKey.WORKING_AREA),
  1169. "is_second_layer" : message.getBody(key: CoreMessage_TMessageKey.IS_SECOND_LAYER),
  1170. ], replace: true)
  1171. let device_id = UserDefaults.standard.string(forKey: "device_id") ?? ""
  1172. if !device_id.isEmpty, let cursorUser = Database.shared.getRecords(fmdb: fmdb, query: "SELECT f_pin FROM BUDDY where device_id='\(device_id)'"), cursorUser.next() {
  1173. UserDefaults.standard.setValue(cursorUser.string(forColumnIndex: 0), forKey: "me")
  1174. cursorUser.close()
  1175. }
  1176. ack(message: message)
  1177. let idMe = UserDefaults.standard.string(forKey: "me")!
  1178. if message.getBody(key: CoreMessage_TMessageKey.USER_TYPE) != "24" && message.getBody(key: CoreMessage_TMessageKey.F_PIN) == idMe {
  1179. let onGoingCC = UserDefaults.standard.string(forKey: "onGoingCC") ?? ""
  1180. if !onGoingCC.isEmpty {
  1181. let requester = onGoingCC.components(separatedBy: ",")[0]
  1182. let officer = onGoingCC.isEmpty ? "" : onGoingCC.components(separatedBy: ",")[1]
  1183. let complaintId = onGoingCC.isEmpty ? "" : onGoingCC.components(separatedBy: ",")[2]
  1184. let startTimeCC = UserDefaults.standard.string(forKey: "startTimeCC") ?? ""
  1185. let date = "\(Date().currentTimeMillis())"
  1186. if officer == idMe {
  1187. _ = Nexilis.write(message: CoreMessage_TMessageBank.endCallCenter(complaint_id: complaintId, l_pin: requester))
  1188. } else {
  1189. if requester == idMe {
  1190. _ = Nexilis.write(message: CoreMessage_TMessageBank.endCallCenter(complaint_id: complaintId, l_pin: officer))
  1191. } else {
  1192. _ = Nexilis.write(message: CoreMessage_TMessageBank.leaveCCRoomInvite(ticket_id: complaintId))
  1193. }
  1194. }
  1195. _ = try Database.shared.insertRecord(fmdb: fmdb, table: "CALL_CENTER_HISTORY", cvalues: [
  1196. "type" : "0",
  1197. "title" : "Contact Center".localized(),
  1198. "time" : startTimeCC,
  1199. "f_pin" : officer,
  1200. "data" : complaintId,
  1201. "time_end" : date,
  1202. "complaint_id" : complaintId,
  1203. "members" : "",
  1204. "requester": requester
  1205. ], replace: true)
  1206. UserDefaults.standard.removeObject(forKey: "onGoingCC")
  1207. UserDefaults.standard.removeObject(forKey: "membersCC")
  1208. UserDefaults.standard.removeObject(forKey: "startTimeCC")
  1209. DispatchQueue.main.async {
  1210. let imageView = UIImageView(image: UIImage(systemName: "info.circle"))
  1211. imageView.tintColor = .white
  1212. let banner = FloatingNotificationBanner(title: "Call Center Session has ended".localized(), subtitle: nil, titleFont: UIFont.systemFont(ofSize: 16), titleColor: nil, titleTextAlign: .left, subtitleFont: nil, subtitleColor: nil, subtitleTextAlign: nil, leftView: imageView, rightView: nil, style: .info, colors: nil, iconPosition: .center)
  1213. banner.show()
  1214. if UIApplication.shared.visibleViewController is UINavigationController {
  1215. let nc = UIApplication.shared.visibleViewController as! UINavigationController
  1216. if nc.visibleViewController is QmeraAudioViewController || nc.visibleViewController is QmeraVideoViewController {
  1217. API.terminateCall(sParty: nil)
  1218. }
  1219. if nc.visibleViewController is EditorPersonal{
  1220. let vc = nc.visibleViewController as! EditorPersonal
  1221. vc.timeoutCC.invalidate()
  1222. }
  1223. nc.visibleViewController?.dismiss(animated: true, completion: nil)
  1224. } else {
  1225. if UIApplication.shared.visibleViewController is QmeraAudioViewController || UIApplication.shared.visibleViewController is QmeraVideoViewController {
  1226. API.terminateCall(sParty: nil)
  1227. }
  1228. if UIApplication.shared.visibleViewController is EditorPersonal{
  1229. let vc = UIApplication.shared.visibleViewController as! EditorPersonal
  1230. vc.timeoutCC.invalidate()
  1231. }
  1232. UIApplication.shared.visibleViewController?.dismiss(animated: true, completion: nil)
  1233. }
  1234. }
  1235. }
  1236. }
  1237. } catch {
  1238. rollback.pointee = true
  1239. print(error)
  1240. }
  1241. })
  1242. }
  1243. private func onInitGroupInfoBatch(message: TMessage) -> Void {
  1244. let dataGroup = message.getBody(key: CoreMessage_TMessageKey.DATA)
  1245. if let jsonArray = try! JSONSerialization.jsonObject(with: dataGroup.data(using: String.Encoding.utf8)!, options: JSONSerialization.ReadingOptions()) as? [AnyObject] {
  1246. Database.shared.database?.inTransaction({ (fmdb, rollback) in
  1247. do {
  1248. for json in jsonArray {
  1249. _ = try Database.shared.insertRecord(fmdb: fmdb, table: "GROUPZ", cvalues: [
  1250. "group_id" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.GROUP_ID),
  1251. "f_name" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.GROUP_NAME),
  1252. "scope_id" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.MESSAGE_SCOPE_ID),
  1253. "image_id": CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.THUMB_ID),
  1254. "quote": CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.QUOTE),
  1255. "last_update" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.LAST_UPDATE),
  1256. "created_by" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.CREATED_BY),
  1257. "created_date" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.CREATED_DATE),
  1258. "ex_block" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.BLOCK),
  1259. "folder_id" : "",
  1260. "chat_modifier" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.CHAT_MODIFIER),
  1261. "group_type" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.IS_ORGANIZATION),
  1262. "parent" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.PARENT_ID),
  1263. "level" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.LEVEL),
  1264. "is_open" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.IS_OPEN),
  1265. "official" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.OFFICIAL_ACCOUNT),
  1266. "level_edu" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.LEVEL_EDU),
  1267. "materi_edu" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.MATERI_EDU),
  1268. "is_education" : CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.IS_EDUCATION)
  1269. ], replace: true)
  1270. let member = CoreMessage_TMessageUtil.getString(json: json, key: "member")
  1271. if let jsonArrayMember = try! JSONSerialization.jsonObject(with: member.data(using: String.Encoding.utf8)!, options: JSONSerialization.ReadingOptions()) as? [AnyObject] {
  1272. for jsonMember in jsonArrayMember {
  1273. _ = try Database.shared.insertRecord(fmdb: fmdb, table: "GROUPZ_MEMBER", cvalues: [
  1274. "group_id" :CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.GROUP_ID),
  1275. "f_pin" : CoreMessage_TMessageUtil.getString(json: jsonMember, key: CoreMessage_TMessageKey.F_PIN),
  1276. "position" : CoreMessage_TMessageUtil.getString(json: jsonMember, key: CoreMessage_TMessageKey.POSITION),
  1277. "user_id" : CoreMessage_TMessageUtil.getString(json: jsonMember, key: CoreMessage_TMessageKey.USER_ID),
  1278. "ac" : CoreMessage_TMessageUtil.getString(json: jsonMember, key: CoreMessage_TMessageKey.AC),
  1279. "ac_desc" : CoreMessage_TMessageUtil.getString(json: jsonMember, key: CoreMessage_TMessageKey.AC_DESC),
  1280. "first_name" : CoreMessage_TMessageUtil.getString(json: jsonMember, key: CoreMessage_TMessageKey.FIRST_NAME),
  1281. "last_name" : CoreMessage_TMessageUtil.getString(json: jsonMember, key: CoreMessage_TMessageKey.LAST_NAME),
  1282. "msisdn" : CoreMessage_TMessageUtil.getString(json: jsonMember, key: CoreMessage_TMessageKey.MSISDN),
  1283. "thumb_id" : CoreMessage_TMessageUtil.getString(json: jsonMember, key: CoreMessage_TMessageKey.THUMB_ID),
  1284. "created_date" : CoreMessage_TMessageUtil.getString(json: jsonMember, key: CoreMessage_TMessageKey.CREATED_DATE),
  1285. ], replace: true)
  1286. }
  1287. }
  1288. }
  1289. ack(message: message)
  1290. } catch {
  1291. rollback.pointee = true
  1292. print(error)
  1293. }
  1294. })
  1295. }
  1296. }
  1297. private func onInitForumInfoBatch(message: TMessage, with isDelegate: Bool = false) -> Void {
  1298. let dataForum = message.getBody(key: CoreMessage_TMessageKey.DATA)
  1299. if let jsonArray = try! JSONSerialization.jsonObject(with: dataForum.data(using: String.Encoding.utf8)!, options: JSONSerialization.ReadingOptions()) as? [AnyObject] {
  1300. Database.shared.database?.inTransaction({ (fmdb, rollback) in
  1301. do {
  1302. for json in jsonArray {
  1303. let chat_id = CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.CHAT_ID)
  1304. let group_id = CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.F_PIN)
  1305. _ = try Database.shared.insertRecord(fmdb: fmdb, table: "DISCUSSION_FORUM", cvalues: [
  1306. "chat_id": chat_id,
  1307. "title":CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.TITLE),
  1308. "group_id": group_id,
  1309. "anonym":CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.ANONYMOUS),
  1310. "scope_id":CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.SCOPE_ID),
  1311. "thumb":CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.IMAGE),
  1312. "category":CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.CATEGORY_ID),
  1313. "activity":CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.ACTVITY),
  1314. "milis":CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.EMAIL),
  1315. "sharing_flag":CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.SHARING_FLAG),
  1316. "clients":CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.CLIENTS),
  1317. "owner":CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.GROUP_ID),
  1318. "raci_r":CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.RACI_R),
  1319. "raci_a":CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.RACI_A),
  1320. "raci_c":CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.RACI_C),
  1321. "raci_i":CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.RACI_I),
  1322. "act_thumb":CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.THUMBNAIL_ACTIVITY),
  1323. "client_thumb":CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.THUMBNAIL_CLIENT)
  1324. ], replace: true)
  1325. if isDelegate {
  1326. if let delegate = Nexilis.shared.groupDelegate {
  1327. delegate.onTopic(code: message.getCode(), f_pin: message.getPIN(), topicId: chat_id)
  1328. }
  1329. }
  1330. }
  1331. ack(message: message)
  1332. } catch {
  1333. rollback.pointee = true
  1334. print(error)
  1335. }
  1336. })
  1337. }
  1338. }
  1339. func loginFile(message: TMessage) -> Void {
  1340. let response = TMessage()
  1341. var isSuccess = false
  1342. let media = message.getMedia()
  1343. if media.count != 0 {
  1344. let data = MyArchive.unzip(bytes: media)
  1345. let lines = data.components(separatedBy: .newlines)
  1346. let line_count = lines.count
  1347. var line_processed = 0
  1348. for line in lines {
  1349. let message = TMessage()
  1350. if message.unpack(data: line) {
  1351. isSuccess = true
  1352. line_processed = line_processed + 1
  1353. process(message: message)
  1354. let progress = line_processed * 100 / line_count
  1355. if let delegate = Nexilis.shared.loginDelegate {
  1356. delegate.onProgress(code: message.getCode(), progress: progress)
  1357. }
  1358. }
  1359. else {
  1360. response.mBodies[CoreMessage_TMessageKey.ERRCOD] = "Failed unpack"
  1361. }
  1362. }
  1363. if isSuccess {
  1364. response.mBodies[CoreMessage_TMessageKey.ERRCOD] = "00"
  1365. if let delegate = Nexilis.shared.loginDelegate {
  1366. delegate.onProgress(code: message.getCode(), progress: 100)
  1367. }
  1368. UserDefaults.standard.set("READY", forKey: "status")
  1369. }
  1370. }
  1371. else {
  1372. response.mBodies[CoreMessage_TMessageKey.ERRCOD] = "Media not found"
  1373. }
  1374. if let packetId = message.mBodies[CoreMessage_TMessageKey.PACKET_ID] {
  1375. _ = Nexilis.response(packetId: packetId, message: response)
  1376. if isSuccess {
  1377. _ = Nexilis.write(message: CoreMessage_TMessageBank.getVersionCheck())
  1378. Nexilis.initFollowing()
  1379. }
  1380. }
  1381. ack(message: message)
  1382. }
  1383. private func getLiveVideoList(message: TMessage) -> Void {
  1384. let data = message.getBody(key: CoreMessage_TMessageKey.DATA)
  1385. print(data)
  1386. if let delegate = Nexilis.shared.streamingDelagate {
  1387. delegate.onStartLS(state: 99, message: data)
  1388. }
  1389. ack(message: message)
  1390. }
  1391. private func getLSTitle(message: TMessage) -> Void {
  1392. let title = message.getBody(key: CoreMessage_TMessageKey.TITLE)
  1393. print(title)
  1394. if let delegate = Nexilis.shared.streamingDelagate {
  1395. delegate.onJoinLS(state: 999, message: title)
  1396. }
  1397. ack(message: message)
  1398. }
  1399. private func changePersonInfoPassword(message: TMessage) -> Void {
  1400. ack(message: message)
  1401. }
  1402. private func changePersonInfoName(message: TMessage) -> Void {
  1403. let fPin = message.getBody(key: CoreMessage_TMessageKey.F_PIN)
  1404. let fname = message.getBody(key: CoreMessage_TMessageKey.FIRST_NAME)
  1405. let lname = message.getBody(key: CoreMessage_TMessageKey.LAST_NAME)
  1406. let offline_mode = message.getBody(key: CoreMessage_TMessageKey.OFFLINE_MODE)
  1407. let auto_quote = message.getBody(key: CoreMessage_TMessageKey.AUTO_QUOTE)
  1408. let cell = message.getBody(key: CoreMessage_TMessageKey.CELL)
  1409. let connected = message.getBody(key: CoreMessage_TMessageKey.CONNECTED)
  1410. let latitude = message.getBody(key: CoreMessage_TMessageKey.LATITUDE)
  1411. let last_loc_update = message.getBody(key: CoreMessage_TMessageKey.LAST_LOC_UPDATE)
  1412. let user_type = message.getBody(key: CoreMessage_TMessageKey.USER_TYPE)
  1413. if let delegate = Nexilis.shared.personInfoDelegate {
  1414. print("INcoming \(connected)")
  1415. delegate.onUpdatePersonInfo(state: 00, message: connected)
  1416. }
  1417. Database.shared.database?.inTransaction({ (fmdb, rollback) in
  1418. _ = Database.shared.updateRecord(fmdb: fmdb, table: "BUDDY", cvalues: [
  1419. "first_name" : fname,
  1420. "last_name" : lname,
  1421. "offline_mode" : offline_mode,
  1422. "auto_quote" : auto_quote,
  1423. "cell" : cell,
  1424. "connected" : connected,
  1425. "latitude" : latitude,
  1426. "last_loc_update" : last_loc_update,
  1427. "user_type" : user_type
  1428. ], _where: "f_pin = '\(fPin)'")
  1429. })
  1430. ack(message: message)
  1431. }
  1432. private func ack(message: TMessage) -> Void {
  1433. _ = Nexilis.write(message: CoreMessage_TMessageBank.getAcknowledgment(p_id: message.mStatus))
  1434. }
  1435. private func joinLivevideo(message: TMessage) -> Void {
  1436. let broadcaster = message.getBody(key: CoreMessage_TMessageKey.L_PIN,default_value: "")
  1437. let f_pin = message.getBody(key: CoreMessage_TMessageKey.F_PIN,default_value: "")
  1438. let thumb_id = message.getBody(key: CoreMessage_TMessageKey.THUMB_ID,default_value: "")
  1439. let name = message.getBody(key: CoreMessage_TMessageKey.NAME,default_value: "")
  1440. let quantity = message.getBody(key: CoreMessage_TMessageKey.QUANTITY,default_value: "")
  1441. let data = broadcaster+","+f_pin+","+thumb_id+","+name+","+quantity
  1442. print(data)
  1443. if let delegate = Nexilis.shared.streamingDelagate {
  1444. delegate.onJoinLS(state: 98, message: data)
  1445. }
  1446. ack(message: message)
  1447. }
  1448. private func leftLiveVideo(message: TMessage) -> Void {
  1449. let broadcaster = message.getBody(key: CoreMessage_TMessageKey.L_PIN,default_value: "")
  1450. let f_pin = message.getBody(key: CoreMessage_TMessageKey.F_PIN,default_value: "")
  1451. let thumb_id = message.getBody(key: CoreMessage_TMessageKey.THUMB_ID,default_value: "")
  1452. let name = message.getBody(key: CoreMessage_TMessageKey.NAME,default_value: "")
  1453. let quantity = message.getBody(key: CoreMessage_TMessageKey.QUANTITY,default_value: "")
  1454. let data = broadcaster+","+f_pin+","+thumb_id+","+name+","+quantity
  1455. print(data)
  1456. if let delegate = Nexilis.shared.streamingDelagate {
  1457. delegate.onJoinLS(state: 97, message: data)
  1458. }
  1459. ack(message: message)
  1460. }
  1461. private func getLSEmotion(message: TMessage) -> Void {
  1462. let l_pin = message.getBody(key: CoreMessage_TMessageKey.L_PIN,default_value: "")
  1463. let likes = message.getBody(key: CoreMessage_TMessageKey.LIKES,default_value: "")
  1464. let quantity = message.getBody(key: CoreMessage_TMessageKey.QUANTITY,default_value: "")
  1465. let data = l_pin+","+likes+","+quantity
  1466. print(data)
  1467. if let delegate = Nexilis.shared.streamingDelagate {
  1468. delegate.onJoinLS(state: 96, message: data)
  1469. }
  1470. ack(message: message)
  1471. }
  1472. private func getLSChat(message: TMessage) -> Void {
  1473. let l_pin = message.getBody(key: CoreMessage_TMessageKey.L_PIN,default_value: "")
  1474. let f_pin = message.getBody(key: CoreMessage_TMessageKey.F_PIN,default_value: "")
  1475. let thumb_id = message.getBody(key: CoreMessage_TMessageKey.THUMB_ID,default_value: "")
  1476. let name = message.getBody(key: CoreMessage_TMessageKey.NAME,default_value: "")
  1477. let messages = message.getBody(key: CoreMessage_TMessageKey.MESSAGE_TEXT,default_value: "")
  1478. let data = l_pin+","+f_pin+","+thumb_id+","+name+","+messages
  1479. print(data)
  1480. if let delegate = Nexilis.shared.streamingDelagate {
  1481. delegate.onJoinLS(state: 95, message: data)
  1482. }
  1483. ack(message: message)
  1484. }
  1485. private func getLSData(message: TMessage) -> Void {
  1486. let l_pin = message.getBody(key: CoreMessage_TMessageKey.L_PIN,default_value: "")
  1487. let likes = message.getBody(key: CoreMessage_TMessageKey.LIKES,default_value: "")
  1488. let quantity = message.getBody(key: CoreMessage_TMessageKey.QUANTITY,default_value: "")
  1489. let data = l_pin+","+likes+","+quantity
  1490. print(data)
  1491. if let delegate = Nexilis.shared.streamingDelagate {
  1492. delegate.onJoinLS(state: 94, message: data)
  1493. }
  1494. ack(message: message)
  1495. }
  1496. private func joinSeminar(message: TMessage) -> Void {
  1497. let broadcaster = message.getBody(key: CoreMessage_TMessageKey.L_PIN,default_value: "")
  1498. let f_pin = message.getBody(key: CoreMessage_TMessageKey.F_PIN,default_value: "")
  1499. let thumb_id = message.getBody(key: CoreMessage_TMessageKey.THUMB_ID,default_value: "")
  1500. let name = message.getBody(key: CoreMessage_TMessageKey.NAME,default_value: "")
  1501. let quantity = message.getBody(key: CoreMessage_TMessageKey.QUANTITY,default_value: "")
  1502. let data = broadcaster+","+f_pin+","+thumb_id+","+name+","+quantity
  1503. print(data)
  1504. if let delegate = Nexilis.shared.seminarDelegate {
  1505. delegate.onJoinSeminar(state: 98, message: data)
  1506. }
  1507. ack(message: message)
  1508. }
  1509. private func leftSeminar(message: TMessage) -> Void {
  1510. let broadcaster = message.getBody(key: CoreMessage_TMessageKey.L_PIN,default_value: "")
  1511. let f_pin = message.getBody(key: CoreMessage_TMessageKey.F_PIN,default_value: "")
  1512. let thumb_id = message.getBody(key: CoreMessage_TMessageKey.THUMB_ID,default_value: "")
  1513. let name = message.getBody(key: CoreMessage_TMessageKey.NAME,default_value: "")
  1514. let quantity = message.getBody(key: CoreMessage_TMessageKey.QUANTITY,default_value: "")
  1515. let data = broadcaster+","+f_pin+","+thumb_id+","+name+","+quantity
  1516. print(data)
  1517. if let delegate = Nexilis.shared.seminarDelegate {
  1518. delegate.onJoinSeminar(state: 97, message: data)
  1519. }
  1520. ack(message: message)
  1521. }
  1522. private func getSeminarRaiseHand(message: TMessage) -> Void {
  1523. let l_pin = message.getBody(key: CoreMessage_TMessageKey.L_PIN,default_value: "")
  1524. let f_pin = message.getBody(key: CoreMessage_TMessageKey.F_PIN,default_value: "")
  1525. let status = message.getBody(key: CoreMessage_TMessageKey.STATUS,default_value: "")
  1526. let data = f_pin+","+l_pin+","+status
  1527. print(data)
  1528. if let delegate = Nexilis.shared.seminarDelegate {
  1529. delegate.onJoinSeminar(state: 96, message: data)
  1530. }
  1531. ack(message: message)
  1532. }
  1533. private func getSeminarChat(message: TMessage) -> Void {
  1534. let l_pin = message.getBody(key: CoreMessage_TMessageKey.L_PIN,default_value: "")
  1535. let f_pin = message.getBody(key: CoreMessage_TMessageKey.F_PIN,default_value: "")
  1536. let thumb_id = message.getBody(key: CoreMessage_TMessageKey.THUMB_ID,default_value: "")
  1537. let name = message.getBody(key: CoreMessage_TMessageKey.NAME,default_value: "")
  1538. let messages = message.getBody(key: CoreMessage_TMessageKey.MESSAGE_TEXT,default_value: "")
  1539. let data = l_pin+","+f_pin+","+thumb_id+","+name+","+messages
  1540. print(data)
  1541. if let delegate = Nexilis.shared.seminarDelegate {
  1542. delegate.onJoinSeminar(state: 95, message: data)
  1543. }
  1544. ack(message: message)
  1545. }
  1546. private func incomingScreenSharing(message: TMessage, state: Int) -> Void {
  1547. let f_pin = message.getBody(key: CoreMessage_TMessageKey.F_PIN,default_value: "")
  1548. let l_pin = message.getBody(key: CoreMessage_TMessageKey.L_PIN,default_value: "")
  1549. let data = f_pin
  1550. print("data ss")
  1551. print(data)
  1552. print(l_pin)
  1553. print(state)
  1554. if let delegate = Nexilis.shared.screenSharingDelegate {
  1555. delegate.onJoinScreenSharing(state: state, message: data)
  1556. }
  1557. ack(message: message)
  1558. }
  1559. private func sendMSISDN(message: TMessage) -> Void {
  1560. let errcod = message.getBody(key: CoreMessage_TMessageKey.ERRCOD,default_value: "")
  1561. let data = errcod
  1562. print(data)
  1563. if (errcod == "00"){
  1564. if let delegate = Nexilis.shared.loginDelegate {
  1565. delegate.onProcess(message: "Success", status: "1")
  1566. }
  1567. } else {
  1568. if let delegate = Nexilis.shared.loginDelegate {
  1569. delegate.onProcess(message: "Failed", status: "0")
  1570. }
  1571. }
  1572. ack(message: message)
  1573. }
  1574. private func verifyOTP(message: TMessage) -> Void {
  1575. let errcod = message.getBody(key: CoreMessage_TMessageKey.ERRCOD,default_value: "00")
  1576. if errcod == "00" {
  1577. let reg_status = message.getBody(key: CoreMessage_TMessageKey.REG_STATUS, default_value: "")
  1578. if reg_status == "1" {
  1579. let f_pin = message.getBody(key: CoreMessage_TMessageKey.F_PIN, default_value: "")
  1580. let f_name = message.getBody(key: CoreMessage_TMessageKey.FIRST_NAME, default_value: "")
  1581. let l_name = message.getBody(key: CoreMessage_TMessageKey.LAST_NAME, default_value: "")
  1582. let thumb_id = message.getBody(key: CoreMessage_TMessageKey.THUMB_ID, default_value: "")
  1583. let data = f_pin+"|"+f_name+"|"+l_name+"|"+thumb_id
  1584. print(data)
  1585. if let delegate = Nexilis.shared.loginDelegate {
  1586. delegate.onProcess(message: data, status: reg_status)
  1587. }
  1588. } else {
  1589. if let delegate = Nexilis.shared.loginDelegate {
  1590. delegate.onProcess(message: "Signup", status: reg_status)
  1591. }
  1592. }
  1593. } else {
  1594. if let delegate = Nexilis.shared.loginDelegate {
  1595. delegate.onProcess(message: "Wrong OTP", status: errcod)
  1596. }
  1597. }
  1598. ack(message: message)
  1599. }
  1600. private func signInOTP(message: TMessage) -> Void {
  1601. if (message.getBody(key: CoreMessage_TMessageKey.ERRCOD, default_value: "00") == "00") {
  1602. let f_pin = message.getBody(key: CoreMessage_TMessageKey.F_PIN, default_value: "00")
  1603. UserDefaults.standard.set(f_pin, forKey: "me")
  1604. if let delegate = Nexilis.shared.loginDelegate {
  1605. delegate.onProcess(message: f_pin, status: message.getBody(key: CoreMessage_TMessageKey.ERRCOD, default_value: "00"))
  1606. }
  1607. } else {
  1608. if let delegate = Nexilis.shared.loginDelegate {
  1609. delegate.onProcess(message: "Failed", status: message.getBody(key: CoreMessage_TMessageKey.ERRCOD, default_value: "00"))
  1610. }
  1611. }
  1612. ack(message: message)
  1613. }
  1614. private func updateTimeline(message:TMessage) -> Void {
  1615. Database.shared.database?.inTransaction({ (fmdb, rollback) in
  1616. do {
  1617. let _ = try Database.shared.insertRecord(fmdb: fmdb, table: "POST", cvalues: [
  1618. "post_id" : message.getBody(key: CoreMessage_TMessageKey.POST_ID,default_value: ""),
  1619. "author_f_pin" : message.getBody(key: CoreMessage_TMessageKey.F_PIN,default_value: ""),
  1620. "author_name" : message.getBody(key: CoreMessage_TMessageKey.NAME,default_value: ""),
  1621. "author_thumbnail" : message.getBody(key: CoreMessage_TMessageKey.THUMB_ID,default_value: ""),
  1622. "type" : message.getBodyAsInteger(key: CoreMessage_TMessageKey.TYPE,default_value: 2),
  1623. "created_date" : message.getBodyAsLong(key: CoreMessage_TMessageKey.CREATED_DATE,default_value: CLong(Utils.getCurrentTimeMillis())),
  1624. "title" : message.getBody(key: CoreMessage_TMessageKey.TITLE,default_value: ""),
  1625. "description" : message.getBody(key: CoreMessage_TMessageKey.DESCRIPTION,default_value: ""),
  1626. "privacy" : message.getBodyAsInteger(key: CoreMessage_TMessageKey.PRIVACY_FLAG,default_value: 3),
  1627. "audition_date" : message.getBodyAsLong(key: CoreMessage_TMessageKey.START_DATE,default_value: CLong(0)),
  1628. "total_comment" : message.getBodyAsInteger(key: CoreMessage_TMessageKey.COMMENTS,default_value: 0),
  1629. "total_like" : message.getBodyAsInteger(key: CoreMessage_TMessageKey.LIKES,default_value: 0),
  1630. "total_dislike" : message.getBodyAsInteger(key: CoreMessage_TMessageKey.DISLIKES,default_value: 0),
  1631. "last_update" : message.getBodyAsLong(key: CoreMessage_TMessageKey.LAST_UPDATE,default_value: CLong(Utils.getCurrentTimeMillis())),
  1632. "file_type" : message.getBodyAsInteger(key: CoreMessage_TMessageKey.MEDIA_TYPE,default_value: 3),
  1633. "thumb_id" : message.getBody(key: CoreMessage_TMessageKey.IMAGE_ID),
  1634. "file_id" : message.getBody(key: CoreMessage_TMessageKey.FILE_ID),
  1635. "video_duration" : message.getBodyAsLong(key: CoreMessage_TMessageKey.DURATION,default_value: CLong(0)),
  1636. "category_id" : message.getBody(key: CoreMessage_TMessageKey.USER_ID),
  1637. "like_flag" : message.getBodyAsInteger(key: CoreMessage_TMessageKey.FLAG_REACTION,default_value: 0),
  1638. "report_flag" : message.getBody(key: CoreMessage_TMessageKey.FLAG_REPORT,default_value: "0"),
  1639. "last_edit" : message.getBodyAsLong(key: CoreMessage_TMessageKey.LAST_EDIT,default_value: CLong(0)),
  1640. "post_id_participate" : message.getBody(key: CoreMessage_TMessageKey.PARTICIPATE_ID,default_value: ""),
  1641. "participate_date" : message.getBodyAsLong(key: CoreMessage_TMessageKey.PARTICIPATE_DATE,default_value: CLong(0)),
  1642. "certificates" : message.getBody(key: CoreMessage_TMessageKey.COMPANY_CERTIFICATE,default_value: ""),
  1643. "participate_size" : message.getBodyAsInteger(key: CoreMessage_TMessageKey.PARTICIPATE_SIZE, default_value: 0),
  1644. "total_view" : message.getBodyAsInteger(key: CoreMessage_TMessageKey.N_VIEWS,default_value: 0),
  1645. "view_flag" : message.getBodyAsInteger(key: CoreMessage_TMessageKey.VIEW_MEDIA_FLAG,default_value: 0),
  1646. "total_followers" : message.getBodyAsInteger(key: CoreMessage_TMessageKey.FOLLOWER_SIZE,default_value: 0),
  1647. "score" : message.getBodyAsLong(key: CoreMessage_TMessageKey.SCORE, default_value: CLong(0)),
  1648. "share_sosmed_type" : message.getBodyAsInteger(key: CoreMessage_TMessageKey.SHARING_FLAG, default_value: 0),
  1649. "link" : message.getBody(key: CoreMessage_TMessageKey.LINK, default_value: ""),
  1650. "category_flag" : message.getBody(key: CoreMessage_TMessageKey.CATEGORY_FLAG,default_value: ""),
  1651. "official_account" : message.getBodyAsInteger(key: CoreMessage_TMessageKey.OFFICIAL_ACCOUNT,default_value: 0)
  1652. // "roc_date" : message.getBody(key: CoreMessage_TMessageKey.LAST_NAME),
  1653. // "roc_size" : message.getBody(key: CoreMessage_TMessageKey.MSISDN),
  1654. // "level_edu" : message.getBody(key: CoreMessage_TMessageKey.THUMB_ID),
  1655. // "materi_edu" : message.getBody(key: CoreMessage_TMessageKey.USER_ID),
  1656. // "finaltest_edu" : message.getBody(key: CoreMessage_TMessageKey.AC),
  1657. // "file_summarization" : message.getBody(key: CoreMessage_TMessageKey.AC_DESC),
  1658. // "target" : message.getBody(key: CoreMessage_TMessageKey.FIRST_NAME),
  1659. // "pricing" : message.getBody(key: CoreMessage_TMessageKey.LAST_NAME),
  1660. // "pricing_money" : message.getBody(key: CoreMessage_TMessageKey.MSISDN)
  1661. ], replace: true)
  1662. ack(message: message)
  1663. } catch {
  1664. rollback.pointee = true
  1665. print(error)
  1666. }
  1667. })
  1668. }
  1669. private func changePersonInfo(message: TMessage){
  1670. let error_code = message.getBody(key: CoreMessage_TMessageKey.ERRCOD)
  1671. let first_name = message.getBody(key: CoreMessage_TMessageKey.FIRST_NAME,default_value: "")
  1672. let last_name = message.getBody(key: CoreMessage_TMessageKey.LAST_NAME,default_value: "")
  1673. let thumb_id = message.getBody(key: CoreMessage_TMessageKey.THUMB_ID,default_value: "")
  1674. let quote = message.getBody(key: CoreMessage_TMessageKey.QUOTE,default_value: "")
  1675. let email = message.getBody(key: CoreMessage_TMessageKey.EMAIL)
  1676. let last_update = message.getBody(key: CoreMessage_TMessageKey.LAST_UPDATE)
  1677. let connected = message.getBody(key: CoreMessage_TMessageKey.CONNECTED)
  1678. let msisdn = message.getBody(key: CoreMessage_TMessageKey.MSISDN)
  1679. let ext_text_1 = message.getBody(key: CoreMessage_TMessageKey.EXT_TEXT_1)
  1680. let auto_quote = message.getBody(key: CoreMessage_TMessageKey.AUTO_QUOTE,default_value: "")
  1681. let auto_quote_type = message.getBody(key: CoreMessage_TMessageKey.AUTO_QUOTE_TYPE,default_value: "")
  1682. let _extension = message.getBody(key: CoreMessage_TMessageKey.EXTENSION)
  1683. let be_info = message.getBody(key: CoreMessage_TMessageKey.BE_INFO)
  1684. let imei = message.getBody(key: CoreMessage_TMessageKey.IMEI)
  1685. let offline_mode = message.getBody(key: CoreMessage_TMessageKey.OFFLINE_MODE)
  1686. let card_id = message.getBody(key: CoreMessage_TMessageKey.CARD_ID,default_value: "")
  1687. let card_type = message.getBody(key: CoreMessage_TMessageKey.CARD_TYPE,default_value: "0")
  1688. let gender = message.getBody(key: CoreMessage_TMessageKey.GENDER,default_value: "0")
  1689. let birthdate = message.getBody(key: CoreMessage_TMessageKey.BIRTHDATE,default_value: "0")
  1690. let type_ads = message.getBody(key: CoreMessage_TMessageKey.TYPE_ADS,default_value: "")
  1691. let type_lp = message.getBody(key: CoreMessage_TMessageKey.TYPE_LP,default_value: "")
  1692. let type_post = message.getBody(key: CoreMessage_TMessageKey.TYPE_POST,default_value: "")
  1693. let address = message.getBody(key: CoreMessage_TMessageKey.ADDRESS,default_value: "")
  1694. let bidang_industri = message.getBody(key: CoreMessage_TMessageKey.BIDANG_INDUSTRI,default_value: "")
  1695. let visi = message.getBody(key: CoreMessage_TMessageKey.VISI, default_value: "")
  1696. let misi = message.getBody(key: CoreMessage_TMessageKey.MISI, default_value: "")
  1697. let company_lat = message.getBody(key: CoreMessage_TMessageKey.COMPANY_LAT, default_value: "")
  1698. let company_lng = message.getBody(key: CoreMessage_TMessageKey.COMPANY_LNG, default_value: "")
  1699. let web = message.getBody(key: CoreMessage_TMessageKey.COMPANY_WEB, default_value: "")
  1700. let certificate_image = message.getBody(key: CoreMessage_TMessageKey.COMPANY_CERTIFICATE, default_value: "")
  1701. let official_account = message.getBody(key: CoreMessage_TMessageKey.COMPANY_CERTIFICATE, default_value: "")
  1702. let user_type = message.getBody(key: CoreMessage_TMessageKey.USER_TYPE,default_value: "")
  1703. let real_name = message.getBody(key: CoreMessage_TMessageKey.REAL_NAME, default_value: "")
  1704. let is_sub_account = message.getBody(key: CoreMessage_TMessageKey.IS_SUB_ACCOUNT, default_value: "")
  1705. let last_sign = message.getBody(key: CoreMessage_TMessageKey.LAST_SIGN)
  1706. let android_id = message.getBody(key: CoreMessage_TMessageKey.ANDROID_ID)
  1707. let is_pull = message.getBody(key: CoreMessage_TMessageKey.IS_PULL, default_value: "0")
  1708. if(is_pull != "0"){
  1709. }
  1710. if(error_code == "00"){
  1711. var msisdnChanged = false
  1712. var emailChanged = false
  1713. var cvalues = [String:Any]()
  1714. if(!first_name.isEmpty){ cvalues["first_name"] = first_name}
  1715. if(!last_name.isEmpty){ cvalues["last_name"] = last_name}
  1716. if(!thumb_id.isEmpty){ cvalues["image_id"] = thumb_id}
  1717. if(!quote.isEmpty){cvalues["quote"] = quote}
  1718. if(!last_update.isEmpty){cvalues["last_update"] = last_update}
  1719. if(!auto_quote.isEmpty){cvalues["auto_quote"] = auto_quote}
  1720. if(!auto_quote_type.isEmpty){cvalues["auto_quote_type"] = auto_quote_type}
  1721. if(!email.isEmpty){cvalues["email"] = email; emailChanged = true}
  1722. if(!last_update.isEmpty){cvalues["last_update"] = last_update}
  1723. if(!msisdn.isEmpty){cvalues["msisdn"] = msisdn; msisdnChanged = true}
  1724. if(!_extension.isEmpty){cvalues["extension"] = _extension}
  1725. if(!be_info.isEmpty){cvalues["be_info"] = be_info}
  1726. if(!card_id.isEmpty){cvalues["card_id"] = card_id}
  1727. if(gender != "0"){cvalues["gender"] = gender}
  1728. if(birthdate != "0"){cvalues["birthdate"] = birthdate}
  1729. if(!offline_mode.isEmpty){cvalues["offline_mode"] = offline_mode}
  1730. if(!official_account.isEmpty){cvalues["official_account"] = official_account}
  1731. if(!connected.isEmpty){cvalues["connected"] = connected}
  1732. // "first_name" : message.getBody(key: CoreMessage_TMessageKey.FIRST_NAME),
  1733. // "last_name" : message.getBody(key: CoreMessage_TMessageKey.LAST_NAME),
  1734. // "image_id" : message.getBody(key: CoreMessage_TMessageKey.THUMB_ID),
  1735. // "quote" : message.getBody(key: CoreMessage_TMessageKey.QUOTE),
  1736. // "last_update" : message.getBody(key: CoreMessage_TMessageKey.LAST_UPDATE),
  1737. // "latitude" : message.getBody(key: CoreMessage_TMessageKey.LATITUDE),
  1738. // "longitude" : message.getBody(key: CoreMessage_TMessageKey.LONGITUDE),
  1739. // "altitude" : message.getBody(key: CoreMessage_TMessageKey.ALTITUDE),
  1740. // "cell" : message.getBody(key: CoreMessage_TMessageKey.CELL),
  1741. // "last_loc_update" : message.getBody(key: CoreMessage_TMessageKey.LAST_LOC_UPDATE),
  1742. // "type" : "1",
  1743. // "empty_2" : message.getBody(key: CoreMessage_TMessageKey.PLACE_NAME),
  1744. // "timezone" : message.getBody(key: CoreMessage_TMessageKey.TIMEZONE),
  1745. // "privacy_flag" : message.getBody(key: CoreMessage_TMessageKey.PRIVACY_FLAG),
  1746. // "msisdn" : message.getBody(key: CoreMessage_TMessageKey.MSISDN),
  1747. // "email" : message.getBody(key: CoreMessage_TMessageKey.EMAIL),
  1748. // "created_date" : message.getBody(key: CoreMessage_TMessageKey.CREATED_DATE),
  1749. // "offline_mode" : message.getBody(key: CoreMessage_TMessageKey.OFFLINE_MODE),
  1750. // "network_type" : message.getBody(key: CoreMessage_TMessageKey.NETWORK_TYPE),
  1751. // "ex_block" : "0",
  1752. // "ex_follow" : "0",
  1753. // "ex_follower" : message.getBody(key: CoreMessage_TMessageKey.TOTAL_FOLLOWERS),
  1754. // "ex_offmp" : message.getBody(key: CoreMessage_TMessageKey.OFFMP),
  1755. // "ex_status" : "0",
  1756. // "shop_code" : message.getBody(key: CoreMessage_TMessageKey.SHOP_CODE),
  1757. // "shop_name" : message.getBody(key: CoreMessage_TMessageKey.SHOP_NAME),
  1758. // "extension" : message.getBody(key: CoreMessage_TMessageKey.EXTENSION),
  1759. // "auto_quote" : message.getBody(key: CoreMessage_TMessageKey.AUTO_QUOTE),
  1760. // "auto_quote_type" : message.getBody(key: CoreMessage_TMessageKey.AUTO_QUOTE_TYPE),
  1761. // "be_info" : message.getBody(key: CoreMessage_TMessageKey.BE_INFO),
  1762. // "org_id" : message.getBody(key: CoreMessage_TMessageKey.ORG_ID),
  1763. // "org_name" : message.getBody(key: CoreMessage_TMessageKey.ORG_NAME),
  1764. // "org_thumb" : message.getBody(key: CoreMessage_TMessageKey.ORG_THUMB),
  1765. // "gender" : message.getBody(key: CoreMessage_TMessageKey.GENDER),
  1766. // "birthdate" : message.getBody(key: CoreMessage_TMessageKey.BIRTHDATE),
  1767. // "type_ads" : message.getBody(key: CoreMessage_TMessageKey.TYPE_ADS),
  1768. // "type_lp" : message.getBody(key: CoreMessage_TMessageKey.TYPE_LP),
  1769. // "type_post" : message.getBody(key: CoreMessage_TMessageKey.TYPE_POST),
  1770. // "address" : message.getBody(key: CoreMessage_TMessageKey.ADDRESS),
  1771. // "bidang_industri" : message.getBody(key: CoreMessage_TMessageKey.BIDANG_INDUSTRI),
  1772. // "visi" : message.getBody(key: CoreMessage_TMessageKey.VISI),
  1773. // "misi" : message.getBody(key: CoreMessage_TMessageKey.MISI),
  1774. // "company_lat" : message.getBody(key: CoreMessage_TMessageKey.COMPANY_LAT),
  1775. // "company_lng" : message.getBody(key: CoreMessage_TMessageKey.COMPANY_LNG),
  1776. // "web" : message.getBody(key: CoreMessage_TMessageKey.COMPANY_WEB),
  1777. // "certificate_image" : message.getBody(key: CoreMessage_TMessageKey.COMPANY_CERTIFICATE),
  1778. // "card_id" : message.getBody(key: CoreMessage_TMessageKey.CARD_ID),
  1779. // "user_type" : message.getBody(key: CoreMessage_TMessageKey.USER_TYPE),
  1780. // "real_name" : message.getBody(key: CoreMessage_TMessageKey.REAL_NAME),
  1781. // "official_account" : message.getBody(key: CoreMessage_TMessageKey.OFFICIAL_ACCOUNT),
  1782. Database.shared.database?.inTransaction({ (fmdb,rollback) in
  1783. do {
  1784. if let me = UserDefaults.standard.string(forKey: "me"), me == message.mPIN, !cvalues.isEmpty {
  1785. let update = Database.shared.updateRecord(fmdb: fmdb, table: "BUDDY", cvalues: cvalues, _where: "f_pin = '\(message.mPIN)'")
  1786. if(update > 0){
  1787. if let delegate = Nexilis.shared.personInfoDelegate {
  1788. if (!thumb_id.isEmpty){
  1789. delegate.onUpdatePersonInfo(state: 6, message: thumb_id)
  1790. }
  1791. }
  1792. }
  1793. } else if !cvalues.isEmpty {
  1794. let update = Database.shared.updateRecord(fmdb: fmdb, table: "BUDDY", cvalues: cvalues, _where: "f_pin = '\(message.mPIN)'")
  1795. if(update > 0){
  1796. if let delegate = Nexilis.shared.personInfoDelegate {
  1797. if (!thumb_id.isEmpty){
  1798. delegate.onUpdatePersonInfo(state: 5, message: thumb_id)
  1799. }
  1800. }
  1801. }
  1802. }
  1803. }
  1804. })
  1805. ack(message: message)
  1806. }
  1807. if let delegate = Nexilis.shared.personInfoDelegate {
  1808. if(!connected.isEmpty){
  1809. delegate.onUpdatePersonInfo(state: 55, message:connected)
  1810. }else{
  1811. delegate.onUpdatePersonInfo(state: 0, message:error_code)
  1812. }
  1813. }
  1814. }
  1815. private static func onPushForm(message: TMessage) {
  1816. // var form = Form()
  1817. // form.formId = message.getBody(key: CoreMessage_TMessageKey.FORM_ID)
  1818. // form.title = message.getBody(key: CoreMessage_TMessageKey.TITLE)
  1819. // form.createdDate = message.getBodyAsLong(key: CoreMessage_TMessageKey.CREATED_DATE, default_value: 0)
  1820. // form.createdBy = message.getBody(key: CoreMessage_TMessageKey.CREATED_BY)
  1821. // form.sqNo = message.getBodyAsInteger(key: CoreMessage_TMessageKey.SEQUENCE, default_value: 0)
  1822. // Database.shared.database?.inTransaction({ (fmdb, rollback) in
  1823. // _ = Database.shared.deleteRecord(fmdb: fmdb, table: "FORM", _where: "form_id = '\(form.formId)'")
  1824. // _ = Database.shared.deleteRecord(fmdb: fmdb, table: "FORM_ITEM", _where: "form_id = '\(form.formId)'")
  1825. // })
  1826. // if(message.getBody(key: CoreMessage_TMessageKey.STATUS) == "0"){
  1827. // return
  1828. // }
  1829. // Database.shared.database?.inTransaction({ (fmdb, rollback) in
  1830. // _ = try? Database.shared.insertRecord(fmdb: fmdb, table: "FORM", cvalues: [
  1831. // "form_id" : form.formId,
  1832. // "name": form.title,
  1833. // "created_date": form.createdDate,
  1834. // "created_by": form.createdBy,
  1835. // "sq_no": form.sqNo
  1836. // ],
  1837. // replace: true)
  1838. // })
  1839. // let data = message.getBody(key: CoreMessage_TMessageKey.DATA)
  1840. // if let jsonArray = try! JSONSerialization.jsonObject(with: data.data(using: String.Encoding.utf8)!, options: JSONSerialization.ReadingOptions()) as? [AnyObject] {
  1841. // Database.shared.database?.inTransaction({ (fmdb, rollback) in
  1842. // for json in jsonArray{
  1843. // _ = try? Database.shared.insertRecord(fmdb: fmdb, table: "FORM_ITEM",
  1844. // cvalues: [
  1845. // "form_id" : form.formId,
  1846. // "label": CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.LABEL),
  1847. // "value": CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.VALUE),
  1848. // "key": CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.KEY),
  1849. // "type": CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.TYPE),
  1850. // "sq_no": CoreMessage_TMessageUtil.getString(json: json, key: CoreMessage_TMessageKey.SEQUENCE)
  1851. // ],
  1852. // replace: false)
  1853. // }
  1854. // })
  1855. // }
  1856. }
  1857. // private static void onPushForm(TMessage p_tmessage) throws Exception {
  1858. // Form_FormHolder form = new Form_FormHolder();
  1859. // form.form_id = p_tmessage.getBody(CoreMessage_TMessageKey.FORM_ID);
  1860. // form.title = p_tmessage.getBody(CoreMessage_TMessageKey.TITLE);
  1861. // form.created_date = p_tmessage.getBodyAsLong(CoreMessage_TMessageKey.CREATED_DATE, 0);
  1862. // form.created_by = p_tmessage.getBody(CoreMessage_TMessageKey.CREATED_BY);
  1863. // form.sq_no = p_tmessage.getBodyAsInteger(CoreMessage_TMessageKey.SEQUENCE, 0);
  1864. // Form_FormDB.deleteRecord(Form_FormDB.FIELD_FORM_ID + "='" + form.form_id + "'");
  1865. // Form_FormItemDB.deleteRecord(Form_FormItemDB.FIELD_FORM_ID + "='" + form.form_id + "'");
  1866. // if (p_tmessage.getBody(CoreMessage_TMessageKey.STATUS, "").equals("0")) {//Delete
  1867. // return;
  1868. // }
  1869. // Form_FormDB.insertRecord(form.getContentValues());
  1870. // JSONArray array = new JSONArray(p_tmessage.getBody(CoreMessage_TMessageKey.DATA));
  1871. // for (int i = 0; i < array.length(); i++) {
  1872. // JSONObject jo = array.getJSONObject(i);
  1873. // Form_FormItemHolder item = new Form_FormItemHolder();
  1874. // item.form_id = form.form_id;
  1875. // item.label = getString(jo, CoreMessage_TMessageKey.LABEL);
  1876. // item.value = getString(jo, CoreMessage_TMessageKey.VALUE);
  1877. // item.key = getString(jo, CoreMessage_TMessageKey.KEY);
  1878. // item.sq_no = getLong(jo);
  1879. // item.type = getString(jo, CoreMessage_TMessageKey.TYPE);
  1880. // Form_FormItemDB.insertRecord(item.getContentValues());
  1881. // }
  1882. // App.postUI(Form_B.FORM_PUSH, form);
  1883. // }
  1884. }