package Ġcn . nav club . fish p ond . server . service . impl Ċ Ċ import Ġcn . nav club . fish p ond . core . config . Constant Ċ import Ġcn . nav club . fish p ond . protocol . enums . Service Code Ċ import Ġcn . nav club . fish p ond . protocol . model . T Pro Message Ċ import Ġcn . nav club . fish p ond . server . service . Base Service Ċ import Ġcn . nav club . fish p ond . server . service . Message Service Ċ import Ġio . vertx . core . Vert x Ċ import Ġio . vertx . core . json . JsonObject Ċ import Ġio . vertx . kotlin . coroutines . await Ċ import Ġio . vertx . sql client . templates . Sql Template Ċ import Ġjava . time . LocalDateTime ĊĊ Ċ class ĠMessage ServiceImpl ( vertx : ĠVert x , Ġconfig : ĠJsonObject ) Ġ: ĠMessage Service , ĠBase Service ( vertx , Ġconfig ) Ġ{ ĊĠĠĠ Ġoverride Ġsuspend Ġfun Ġsave ( t Pro : ĠT Pro Message ) Ġ{ ĊĠĠĠĠĠĠĠ Ġif Ġ( t Pro . service Code Ġ== ĠService Code . TCP _ REGISTER ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ|| Ġt Pro . service Code Ġ== ĠService Code . HE ART _ BE AT ) Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠ Ġreturn ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġval Ġsql Ġ= ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ" INSERT ĠINTO Ġfp _ message ( id , type , sender , receiver , message , create _ time , s _ code ) ĠVALUES ( #{ id }, #{ type }, #{ sender }, #{ receiver }, #{ message }, #{ create Time }, #{ service Code })" ĊĠĠĠĠĠĠĠ Ġthis . transaction Ġ{ Ġcon , Ġ_ Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠ Ġval Ġmap : ĠMutable Map < String , ĠAny > Ġ= ĠHashMap () ĊĊĠĠĠĠĠĠĠĠĠĠĠ Ġmap [ Constant . SEND ER ] Ġ= Ġt Pro . from ĊĠĠĠĠĠĠĠĠĠĠĠ Ġmap [ Constant . RECE IVER ] Ġ= Ġt Pro . to ĊĠĠĠĠĠĠĠĠĠĠĠ Ġmap [ Constant . TYPE ] Ġ= Ġt Pro . type .` val ` ĊĠĠĠĠĠĠĠĠĠĠĠ Ġmap [ Constant . MESSAGE ] Ġ= Ġt Pro . data Str ĊĠĠĠĠĠĠĠĠĠĠĠ Ġmap [ Constant . ID ] Ġ= Ġthis . auto Increment Id () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġmap [ Constant . CREATE _ TIME ] Ġ= ĠLocalDateTime . now () ĊĠĠĠĠĠĠĠĠĠĠĠ Ġmap [ Constant . SERVICE _ CODE ] Ġ= Ġt Pro . service Code . value ĊĊĠĠĠĠĠĠĠĠĠĠĠ ĠSql Template . for Update ( con , Ġsql ). execute ( map ). await () ĊĠĠĠĠĠĠĠ Ġ} ĊĠĠĠ Ġ} Ċ }