|
@@ -73,8 +73,6 @@ public class Nexilis: NSObject {
|
|
|
|
|
|
IncomingThread.default.run()
|
|
|
|
|
|
- OutgoingThread.default.run()
|
|
|
-
|
|
|
if let _ = UserDefaults.standard.stringArray(forKey: "address") {
|
|
|
|
|
|
}
|
|
@@ -178,6 +176,9 @@ public class Nexilis: NSObject {
|
|
|
}
|
|
|
}
|
|
|
Nexilis.destroyAll()
|
|
|
+ OutgoingThread.default.run()
|
|
|
+
|
|
|
+ InquiryThread.default.run()
|
|
|
}
|
|
|
catch {
|
|
|
print(error)
|
|
@@ -262,7 +263,8 @@ public class Nexilis: NSObject {
|
|
|
}
|
|
|
|
|
|
public static func addQueueMessage(message: TMessage) {
|
|
|
- OutgoingThread.default.addQueue(message: message)
|
|
|
+// OutgoingThread.default.addQueue(message: message)
|
|
|
+ InquiryThread.default.addQueue(message: message)
|
|
|
}
|
|
|
|
|
|
private static var wbDelegate: WhiteboardDelegate?
|
|
@@ -879,15 +881,22 @@ public class Nexilis: NSObject {
|
|
|
guard !f_pin.isEmpty else {
|
|
|
return
|
|
|
}
|
|
|
- let l_pin = message.getBody(key : CoreMessage_TMessageKey.L_PIN, default_value : "")
|
|
|
- let scope = message.getBody(key : CoreMessage_TMessageKey.MESSAGE_SCOPE_ID, default_value : "3")
|
|
|
- let status = message.getBody(key : CoreMessage_TMessageKey.STATUS, default_value : "")
|
|
|
- let chat_id = message.getBody(key : CoreMessage_TMessageKey.CHAT_ID, default_value : "")
|
|
|
- let broadcast_flag = message.getBody(key: CoreMessage_TMessageKey.BROADCAST_FLAG, default_value: "0")
|
|
|
- let is_call_center = message.getBody(key: CoreMessage_TMessageKey.IS_CALL_CENTER, default_value: "0")
|
|
|
- let call_center_id = message.getBody(key: CoreMessage_TMessageKey.CALL_CENTER_ID, default_value: "")
|
|
|
- print("prepare save db")
|
|
|
Database.shared.database?.inTransaction({ (fmdb, rollback) in
|
|
|
+ if let cursor = Database.shared.getRecords(fmdb: fmdb, query: "select message_id from MESSAGE where message_id = '\(message_id)'") {
|
|
|
+ if cursor.next() {
|
|
|
+ print("message exist")
|
|
|
+ return
|
|
|
+ }
|
|
|
+ cursor.close()
|
|
|
+ }
|
|
|
+ let l_pin = message.getBody(key : CoreMessage_TMessageKey.L_PIN, default_value : "")
|
|
|
+ let scope = message.getBody(key : CoreMessage_TMessageKey.MESSAGE_SCOPE_ID, default_value : "3")
|
|
|
+ let status = message.getBody(key : CoreMessage_TMessageKey.STATUS, default_value : "")
|
|
|
+ let chat_id = message.getBody(key : CoreMessage_TMessageKey.CHAT_ID, default_value : "")
|
|
|
+ let broadcast_flag = message.getBody(key: CoreMessage_TMessageKey.BROADCAST_FLAG, default_value: "0")
|
|
|
+ let is_call_center = message.getBody(key: CoreMessage_TMessageKey.IS_CALL_CENTER, default_value: "0")
|
|
|
+ let call_center_id = message.getBody(key: CoreMessage_TMessageKey.CALL_CENTER_ID, default_value: "")
|
|
|
+ print("prepare save db")
|
|
|
do {
|
|
|
_ = try Database.shared.insertRecord(fmdb: fmdb, table: "MESSAGE", cvalues: [
|
|
|
"message_id" : message_id,
|
|
@@ -923,10 +932,8 @@ public class Nexilis: NSObject {
|
|
|
rollback.pointee = true
|
|
|
print(error)
|
|
|
}
|
|
|
- })
|
|
|
-
|
|
|
- if withStatus {
|
|
|
- Database.shared.database?.inTransaction({ (fmdb, rollback) in
|
|
|
+
|
|
|
+ if withStatus {
|
|
|
do {
|
|
|
if scope == "4" {
|
|
|
for pin in getGroupMembers(fmdb: fmdb, l_pin: l_pin) {
|
|
@@ -950,35 +957,31 @@ public class Nexilis: NSObject {
|
|
|
rollback.pointee = true
|
|
|
print(error)
|
|
|
}
|
|
|
- })
|
|
|
- }
|
|
|
- var pin = l_pin
|
|
|
- if l_pin == me {
|
|
|
- pin = f_pin
|
|
|
- }
|
|
|
- if !chat_id.isEmpty {
|
|
|
- pin = chat_id
|
|
|
- }
|
|
|
- var counter : Int? = nil
|
|
|
- if l_pin == me || (scope == "4" && f_pin != me) {
|
|
|
- Database.shared.database?.inTransaction({ (fmdb, rollback) in
|
|
|
+ }
|
|
|
+ var pin = l_pin
|
|
|
+ if l_pin == me {
|
|
|
+ pin = f_pin
|
|
|
+ }
|
|
|
+ if !chat_id.isEmpty {
|
|
|
+ pin = chat_id
|
|
|
+ }
|
|
|
+ var counter : Int? = nil
|
|
|
+ if l_pin == me || (scope == "4" && f_pin != me) {
|
|
|
if let cursor = Database.shared.getRecords(fmdb: fmdb, query: "select counter from MESSAGE_SUMMARY where l_pin = '\(pin)'"), cursor.next() {
|
|
|
counter = Int(cursor.int(forColumnIndex: 0))
|
|
|
counter! += 1
|
|
|
cursor.close()
|
|
|
print("select db message summary")
|
|
|
}
|
|
|
- })
|
|
|
+ if counter == nil {
|
|
|
+ counter = 1
|
|
|
+ print("set counter message summary")
|
|
|
+ }
|
|
|
+ }
|
|
|
if counter == nil {
|
|
|
- counter = 1
|
|
|
- print("set counter message summary")
|
|
|
+ counter = 0
|
|
|
}
|
|
|
- }
|
|
|
- if counter == nil {
|
|
|
- counter = 0
|
|
|
- }
|
|
|
- if is_call_center == "0" {
|
|
|
- Database.shared.database?.inTransaction({ (fmdb, rollback) in
|
|
|
+ if is_call_center == "0" {
|
|
|
do {
|
|
|
_ = try Database.shared.insertRecord(fmdb: fmdb, table: "MESSAGE_SUMMARY", cvalues: [
|
|
|
"l_pin" : pin,
|
|
@@ -989,9 +992,9 @@ public class Nexilis: NSObject {
|
|
|
rollback.pointee = true
|
|
|
print(error)
|
|
|
}
|
|
|
- })
|
|
|
- }
|
|
|
- print("insert db message summary \(message_id)")
|
|
|
+ }
|
|
|
+ print("insert db message summary \(message_id)")
|
|
|
+ })
|
|
|
|
|
|
}
|
|
|
|