Startsida Utforska Hjälp
Logga in
SocialPlatform
/
messageCenter
2
0
Fork 0
Filer Ärenden 0 Pull-förfrågningar 0 Wiki
Gren: master
Grenar Taggar
messageCenter
/
service
/
coverage.html

coverage.html 38 KB
Permalänk Historik Rå

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656 
  1. 

  2. <!DOCTYPE html>
    3. 

  3. <html>
    4. 

  4. 	<head>
    5. 

  5. 		<meta http-equiv="Content-Type" content="text/html; charset=utf-8">
    6. 

  6. 		<title>service: Go Coverage Report</title>
    7. 

  7. 		<style>
    8. 

  8. 			body {
    9. 

  9. 				background: black;
    10. 

  10. 				color: rgb(80, 80, 80);
    11. 

  11. 			}
    12. 

  12. 			body, pre, #legend span {
    13. 

  13. 				font-family: Menlo, monospace;
    14. 

  14. 				font-weight: bold;
    15. 

  15. 			}
    16. 

  16. 			#topbar {
    17. 

  17. 				background: black;
    18. 

  18. 				position: fixed;
    19. 

  19. 				top: 0; left: 0; right: 0;
    20. 

  20. 				height: 42px;
    21. 

  21. 				border-bottom: 1px solid rgb(80, 80, 80);
    22. 

  22. 			}
    23. 

  23. 			#content {
    24. 

  24. 				margin-top: 50px;
    25. 

  25. 			}
    26. 

  26. 			#nav, #legend {
    27. 

  27. 				float: left;
    28. 

  28. 				margin-left: 10px;
    29. 

  29. 			}
    30. 

  30. 			#legend {
    31. 

  31. 				margin-top: 12px;
    32. 

  32. 			}
    33. 

  33. 			#nav {
    34. 

  34. 				margin-top: 10px;
    35. 

  35. 			}
    36. 

  36. 			#legend span {
    37. 

  37. 				margin: 0 5px;
    38. 

  38. 			}
    39. 

  39. 			.cov0 { color: rgb(192, 0, 0) }
    40. 

  40. .cov1 { color: rgb(128, 128, 128) }
    41. 

  41. .cov2 { color: rgb(116, 140, 131) }
    42. 

  42. .cov3 { color: rgb(104, 152, 134) }
    43. 

  43. .cov4 { color: rgb(92, 164, 137) }
    44. 

  44. .cov5 { color: rgb(80, 176, 140) }
    45. 

  45. .cov6 { color: rgb(68, 188, 143) }
    46. 

  46. .cov7 { color: rgb(56, 200, 146) }
    47. 

  47. .cov8 { color: rgb(44, 212, 149) }
    48. 

  48. .cov9 { color: rgb(32, 224, 152) }
    49. 

  49. .cov10 { color: rgb(20, 236, 155) }
    50. 

  50. 

  51. 		</style>
    52. 

  52. 	</head>
    53. 

  53. 	<body>
    54. 

  54. 		<div id="topbar">
    55. 

  55. 			<div id="nav">
    56. 

  56. 				<select id="files">
    57. 

  57. 				
    58. 

  58. 				<option value="file0">bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/service/message_mail_box.go (100.0%)</option>
    59. 

  59. 				
    60. 

  60. 				</select>
    61. 

  61. 			</div>
    62. 

  62. 			<div id="legend">
    63. 

  63. 				<span>not tracked</span>
    64. 

  64. 			
    65. 

  65. 				<span class="cov0">not covered</span>
    66. 

  66. 				<span class="cov8">covered</span>
    67. 

  67. 			
    68. 

  68. 			</div>
    69. 

  69. 		</div>
    70. 

  70. 		<div id="content">
    71. 

  71. 		
    72. 

  72. 		<pre class="file" id="file0" style="display: none">package service
    73. 

  73. 

  74. import (
    75. 

  75.         quitl "app.yhyue.com/moapp/jybase/common"
    76. 

  76.         util "bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/entity"
    77. 

  77.         "bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/rpc/messagecenter/messagecenter"
    78. 

  78.         "database/sql"
    79. 

  79.         "fmt"
    80. 

  80.         "log"
    81. 

  81.         "time"
    82. 

  82. )
    83. 

  83. 

  84. type MessaggeService struct{}
    85. 

  85. 

  86. //未读消息查询
    87. 

  87. func (b MessaggeService) Count(newUserId, userType, entUserId int64) (count int, last map[string]interface{}, err error) <span class="cov8" title="1">{
    88. 

  88.         v := make([]interface{}, 0)
    89. 

  89.         sqlStr := ""
    90. 

  90.         if userType == 1 </span><span class="cov8" title="1">{
    91. 

  91.                 sqlStr = fmt.Sprintf("select  count(b.id) from   %s a  "+
    92. 

  92.                         "LEFT  JOIN  %s  b ON a.id=b.own_id "+
    93. 

  93.                         "where  b.type=5 "+
    94. 

  94.                         "AND   a.customer_service_id=%d   "+
    95. 

  95.                         "AND  b.isread=0  "+
    96. 

  96.                         "AND own_type = 1 "+
    97. 

  97.                         "order by create_time", util.SOCIALIZE_CHAT_SESSION, util.SOCIALIZE_MESSAGE_MAILBOX, entUserId)
    98. 

  98. 

  99.         }</span> else<span class="cov8" title="1"> {
    100. 

  100.                 sqlStr = fmt.Sprintf("select  count(b.id) from    %s  b "+
    101. 

  101.                         "where   b.send_user_id != %d    "+
    102. 

  102.                         "AND   b.own_id=%d  "+
    103. 

  103.                         "AND  b.isread=0 "+
    104. 

  104.                         "AND own_type = 2 "+
    105. 

  105.                         "order by create_time", util.SOCIALIZE_MESSAGE_MAILBOX, newUserId, newUserId)
    106. 

  106. 

  107.         }</span>
    108. 

  108.         <span class="cov8" title="1">log.Println(sqlStr, v)
    109. 

  109.         rs := util.Mysql.CountBySql(sqlStr, v...)
    110. 

  110.         log.Println(rs)
    111. 

  111.         count = int(rs)
    112. 

  112.         //最后一条信息查询
    113. 

  113.         sqlStr=fmt.Sprintf("SELECT  c.* FROM %s  b   "+
    114. 

  114.                 "LEFT join %s c on  b.messag_id=c.id "+
    115. 

  115.                 "WHERE  b.send_user_id != %d   "+
    116. 

  116.                 "AND b.own_id = %d  "+
    117. 

  117.                 "AND   b.isread=0  "+
    118. 

  118.                 "AND own_type = 2  "+
    119. 

  119.                 "ORDER BY  create_time DESC   "+
    120. 

  120.                 "LIMIT 0,1",util.SOCIALIZE_MESSAGE_MAILBOX, util.SOCIALIZE_MESSAGE,
    121. 

  121.                 newUserId, newUserId)
    122. 

  122.         lastData := util.Mysql.SelectBySql(sqlStr)
    123. 

  123.         if len(*lastData) &gt; 0 </span><span class="cov8" title="1">{
    124. 

  124.                 last = (*lastData)[0]
    125. 

  125.         }</span>
    126. 

  126.         <span class="cov8" title="1">return</span>
    127. 

  127. }
    128. 

  128. 

  129. //用户列表查询
    130. 

  130. func (b MessaggeService) UserList(in *messagecenter.UserReq) (data *[]map[string]interface{}, err error) <span class="cov8" title="1">{
    131. 

  131.         sqlStr := ""
    132. 

  132.         if in.UserType == 2 </span><span class="cov8" title="1">{
    133. 

  133.                 //用户最后一次信息查询
    134. 

  134.                 userSql := fmt.Sprintf("SELECT  MAX( c.id )   as messageId  FROM  socialize_message_mailbox c "+
    135. 

  135.                         "WHERE  c.own_id = %d   "+
    136. 

  136.                         "AND c.type = 2   "+
    137. 

  137.                         "AND c.own_type = 2 "+
    138. 

  138.                         "GROUP BY  (  CASE  WHEN c.send_user_id &gt; c.receive_user_id "+
    139. 

  139.                         "THEN    CONCAT( c.send_user_id, c.receive_user_id )  "+
    140. 

  140.                         "WHEN c.send_user_id &lt; c.receive_user_id "+
    141. 

  141.                         "THEN  CONCAT( c.receive_user_id, c.send_user_id )  END  ) ", in.NewUserId,
    142. 

  142.                 )
    143. 

  143.                 data = util.Mysql.SelectBySql(userSql)
    144. 

  144.                 userMessageId := util.Inhandle(data)
    145. 

  145.                 //客服最后一次信息查询
    146. 

  146.                 customerSql := fmt.Sprintf("SELECT   max( c.id )   as messageId  FROM   %s c "+
    147. 

  147.                         "LEFT JOIN %s d ON  IF   ( c.send_user_type = 1, d.id = c.send_user_id, d.id = c.receive_user_id ) "+
    148. 

  148.                         "WHERE   c.own_id = %d  "+
    149. 

  149.                         "AND ( c.type = 4 OR c.type = 5  or c.type=6 or  c.type=7 ) "+
    150. 

  150.                         "AND c.own_type = 2 "+
    151. 

  151.                         "AND   d.user_id=c.own_id "+
    152. 

  152.                         "GROUP BY   d.ent_id  ", util.SOCIALIZE_MESSAGE_MAILBOX, util.SOCIALIZE_CHAT_SESSION, in.NewUserId)
    153. 

  153.                 data = util.Mysql.SelectBySql(customerSql)
    154. 

  154.                 customerMessageId := util.Inhandle(data)
    155. 

  155.                 //用户的列表
    156. 

  156.                 sqlStr = fmt.Sprintf("SELECT IF ( b.nickname = '', CONCAT(SUBSTR( b.phone, 1, 3 ),'****',SUBSTR( b.phone, 8, 11)), b.nickname ) AS name, b.id, e.title, b.headimg, e.type, e.link, e.content, 2 AS userType, a.create_time, a.type AS itemType, "+
    157. 

  157.                         "( SELECT  count( h.id )  FROM  %s h  "+
    158. 

  158.                         "WHERE  h.type = 2  "+
    159. 

  159.                         "AND h.own_id = %d  "+
    160. 

  160.                         "AND h.own_type = 2  "+
    161. 

  161.                         "AND   h.send_user_id=b.id   "+
    162. 

  162.                         "AND h.isread = 0  ) AS number  FROM  %s a "+
    163. 

  163.                         "LEFT JOIN  %s b ON  b.id = a.receive_user_id or  b.id = a.send_user_id  "+
    164. 

  164.                         "LEFT JOIN  %s e ON e.id = a.messag_id  "+
    165. 

  165.                         "WHERE a.id IN ( %s )  AND b.id != %d "+
    166. 

  166.                         "UNION ALL "+
    167. 

  167.                         "SELECT  f.nickname AS name,    b.ent_id AS id,  e.title,f.headimage AS headimg,  e.type,  e.link,  e.content,  1 AS userType,  a.create_time,  a.type AS itemType, "+
    168. 

  168.                         "(  SELECT   count( h.id )   FROM    %s h   WHERE   ( h.type = 4 OR h.type = 5  )    AND h.own_id = %d    AND h.own_type = 2   AND  h.send_user_type = 1 AND  h.receive_user_id = %d    AND h.isread = 0   ) AS number "+
    169. 

  169.                         "FROM  %s a  "+
    170. 

  170.                         "LEFT JOIN %s b ON IF  ( a.send_user_type = 1, b.id = a.send_user_id, b.id = a.receive_user_id )  "+
    171. 

  171.                         "LEFT JOIN %s e ON e.id = a.messag_id  "+
    172. 

  172.                         "LEFT join %s  f on f.ent_id=b.ent_id   "+
    173. 

  173.                         "WHERE  a.id IN (  %s )  "+
    174. 

  174.                         "ORDER BY create_time DESC",
    175. 

  175.                         util.SOCIALIZE_MESSAGE_MAILBOX,
    176. 

  176.                         in.NewUserId,
    177. 

  177.                         util.SOCIALIZE_MESSAGE_MAILBOX,
    178. 

  178.                         util.BASE_USER,
    179. 

  179.                         util.SOCIALIZE_MESSAGE,
    180. 

  180.                         userMessageId,
    181. 

  181.                         in.NewUserId,
    182. 

  182.                         util.SOCIALIZE_MESSAGE_MAILBOX,
    183. 

  183.                         in.NewUserId,
    184. 

  184.                         in.NewUserId,
    185. 

  185.                         util.SOCIALIZE_MESSAGE_MAILBOX,
    186. 

  186.                         util.SOCIALIZE_CHAT_SESSION,
    187. 

  187.                         util.SOCIALIZE_MESSAGE,
    188. 

  188.                         util.SOCIALIZE_TENANT_ROBOT,
    189. 

  189.                         customerMessageId)
    190. 

  190.         }</span> else<span class="cov8" title="1"> {
    191. 

  191.                 phoneSql := ""
    192. 

  192.                 if in.Phone != "" </span><span class="cov8" title="1">{
    193. 

  193.                         phoneSql = "AND  b.phone like '% " + in.Phone + "%'"
    194. 

  194.                 }</span>
    195. 

  195.                 <span class="cov8" title="1">startTimeSql := ""
    196. 

  196.                 if in.StartTime != "" </span><span class="cov8" title="1">{
    197. 

  197.                         startTimeSql = "AND  DATE_FORMAT(c.create_time,'%Y-%m-%d') &gt;= ' " + in.StartTime + "' "
    198. 

  198.                 }</span>
    199. 

  199.                 <span class="cov8" title="1">endTimeSql := ""
    200. 

  200.                 if in.EndTime != "" </span><span class="cov8" title="1">{
    201. 

  201.                         endTimeSql = "AND DATE_FORMAT(c.create_time,'%Y-%m-%d') &lt;= ' " + in.EndTime + "' "
    202. 

  202.                 }</span>
    203. 

  203.                 //先获取每个用户最后聊天记录
    204. 

  204.                 <span class="cov8" title="1">userSql := fmt.Sprintf("SELECT   MAX( c.id ) as messageId   FROM  %s c   "+
    205. 

  205.                         "LEFT JOIN %s d ON   c.own_type=1 AND  c.own_id=d.id   "+
    206. 

  206.                         "WHERE   c.own_type = 1    "+
    207. 

  207.                         "AND d.customer_service_id = %d   "+
    208. 

  208.                         "AND ( c.type = 4 OR c.type = 5 or  c.type=6 or  c.type=7 )   "+
    209. 

  209.                         "AND d.customer_service_id !=0   %s %s  "+
    210. 

  210.                         "GROUP BY   (   CASE  WHEN  c.send_user_type =2 THEN  CONCAT( c.send_user_id )   WHEN c.send_user_type =1 THEN  CONCAT( c.receive_user_id )  END  ) ",
    211. 

  211.                         util.SOCIALIZE_MESSAGE_MAILBOX, util.SOCIALIZE_CHAT_SESSION,
    212. 

  212.                         in.EntUserId, startTimeSql, endTimeSql)
    213. 

  213.                 data = util.Mysql.SelectBySql(userSql)
    214. 

  214.                 if data != nil </span><span class="cov8" title="1">{
    215. 

  215.                         customerMessageId := util.Inhandle(data)
    216. 

  216.                         //客服的用户列表
    217. 

  217.                         sqlStr = fmt.Sprintf("SELECT  IF  ( b.nickname = '', CONCAT(SUBSTR( b.phone, 1, 3 ),'****',SUBSTR( b.phone, 8, 11)), b.nickname ) AS name,  b.id,  e.title,  b.headimg,  e.type,  e.link,  e.content,  a.create_time,  "+
    218. 

  218.                                 "(  SELECT   count( h.id )   FROM   %s h   "+
    219. 

  219.                                 "LEFT JOIN %s i ON h.own_type = 1 AND h.own_id = i.id     "+
    220. 

  220.                                 "WHERE  h.own_type = 1  "+
    221. 

  221.                                 "AND i.ent_id=f.ent_id "+
    222. 

  222.                                 "AND  i.user_id=f.user_id    "+
    223. 

  223.                                 "AND h.isread = 0    "+
    224. 

  224.                                 "AND  i.customer_service_id= %d "+
    225. 

  225.                                 "FROM  %s a  "+
    226. 

  226.                                 "LEFT JOIN %s b ON if (a.send_user_type=1 ,a.receive_user_id=b.id,a.send_user_id=b.id)  "+
    227. 

  227.                                 "LEFT JOIN %s e ON e.id = a.messag_id  "+
    228. 

  228.                                 "LEFT JOIN %s f ON a.own_type=1 AND  a.own_id=f.id   "+
    229. 

  229.                                 "WHERE  a.id IN  ( %s) %s ORDER BY  a.create_time DESC",
    230. 

  230.                                 util.SOCIALIZE_MESSAGE_MAILBOX, util.SOCIALIZE_CHAT_SESSION,
    231. 

  231.                                 in.EntUserId, util.SOCIALIZE_MESSAGE_MAILBOX, util.BASE_USER, util.SOCIALIZE_MESSAGE, util.SOCIALIZE_CHAT_SESSION, customerMessageId, phoneSql)
    232. 

  232.                 }</span>
    233. 

  233.         }
    234. 

  234.         <span class="cov8" title="1">if sqlStr != "" </span><span class="cov8" title="1">{
    235. 

  235.                 log.Println(sqlStr)
    236. 

  236.                 data = util.Mysql.SelectBySql(sqlStr)
    237. 

  237.         }</span>
    238. 

  238.         <span class="cov8" title="1">return</span>
    239. 

  239. }
    240. 

  240. 

  241. //消息保存
    242. 

  242. func (b MessaggeService) SaveMessage(in *messagecenter.MessageEntity) (fool bool, errorMsg string, content string, messageId, nowInt int64) <span class="cov8" title="1">{
    243. 

  243.         //先插入信息表
    244. 

  244.         //判断会话标识是否属于本人
    245. 

  245.         nowForm := time.Now().Local()
    246. 

  246.         if in.ItemType != 2 </span><span class="cov8" title="1">{
    247. 

  247.                 userId := int64(0)
    248. 

  248.                 sessionId := int64(0)
    249. 

  249.                 switch in.ItemType </span>{
    250. 

  250.                 case 4, 5:<span class="cov8" title="1">
    251. 

  251.                         if in.OwnType == 1 </span><span class="cov8" title="1">{
    252. 

  252.                                 sessionId = in.ReceiveId
    253. 

  253.                                 userId = in.NewUserId
    254. 

  254.                         }</span> else<span class="cov8" title="1"> {
    255. 

  255.                                 sessionId = in.SendId
    256. 

  256.                                 userId = in.ReceiveId
    257. 

  257.                                 if in.ItemType == 4 </span><span class="cov8" title="1">{
    258. 

  258.                                         userId = in.NewUserId
    259. 

  259.                                 }</span>
    260. 

  260.                         }
    261. 

  261.                         <span class="cov8" title="1">break</span>
    262. 

  262.                 case 6:<span class="cov8" title="1">
    263. 

  263.                         if in.OwnType == 1 </span><span class="cov8" title="1">{
    264. 

  264.                                 sessionId = in.ReceiveId
    265. 

  265.                                 userId = in.NewUserId
    266. 

  266.                         }</span> else<span class="cov8" title="1"> if in.OwnType == 2 </span><span class="cov8" title="1">{
    267. 

  267.                                 sessionId = in.SendId
    268. 

  268.                                 userId = in.ReceiveId
    269. 

  269.                         }</span> else<span class="cov8" title="1"> {
    270. 

  270.                                 sessionId = in.ReceiveId
    271. 

  271.                                 userId = in.NewUserId
    272. 

  272.                         }</span>
    273. 

  273.                         <span class="cov8" title="1">break</span>
    274. 

  274.                 }
    275. 

  275.                 //查找会话信息
    276. 

  276.                 <span class="cov8" title="1">chatJson := util.Mysql.FindOne(util.SOCIALIZE_CHAT_SESSION, map[string]interface{}{"id": sessionId}, "user_id", "")
    277. 

  277.                 if chatJson == nil </span><span class="cov8" title="1">{
    278. 

  278.                         return false, "会话标识不存在", "", 0, nowForm.Unix()
    279. 

  279.                 }</span> else<span class="cov8" title="1"> {
    280. 

  280.                         if userId != quitl.Int64All((*chatJson)["user_id"]) </span><span class="cov8" title="1">{
    281. 

  281.                                 return false, "会话标识不属于此用户", "", 0, nowForm.Unix()
    282. 

  282.                         }</span>
    283. 

  283.                 }
    284. 

  284.         }
    285. 

  285.         <span class="cov8" title="1">fool = util.Mysql.ExecTx("聊天信息保存", func(tx *sql.Tx) bool </span><span class="cov8" title="1">{
    286. 

  286.                 //先插入信息表
    287. 

  287.                 message := map[string]interface{}{
    288. 

  288.                         "appid":         in.Appid,
    289. 

  289.                         "title":         in.Title,
    290. 

  290.                         "content":       in.Content,
    291. 

  291.                         "item":          in.Item,
    292. 

  292.                         "type":          in.Type,
    293. 

  293.                         "link":          in.Link,
    294. 

  294.                         "create_time":   nowForm.Format(util.Date_Full_Layout),
    295. 

  295.                         "create_person": in.SendId,
    296. 

  296.                 }
    297. 

  297.                 ok := util.Mysql.InsertByTx(tx, util.SOCIALIZE_MESSAGE, message)
    298. 

  298.                 receiveOk := int64(0)
    299. 

  299.                 messageId = ok
    300. 

  300.                 //在插入邮箱表socialize_message_mailbox
    301. 

  301.                 messageMailBox := map[string]interface{}{
    302. 

  302.                         "appid":         in.Appid,
    303. 

  303.                         "messag_id":     ok,
    304. 

  304.                         "type":          in.ItemType,
    305. 

  305.                         "create_time":   nowForm.Format(util.Date_Full_Layout),
    306. 

  306.                         "isread":        0,
    307. 

  307.                         "send_isdel":    0,
    308. 

  308.                         "receive_isdel": 0,
    309. 

  309.                         "iswithdraw":    0,
    310. 

  310.                 }
    311. 

  311.                 //系统信息处理
    312. 

  312.                 if in.ItemType == 6 </span><span class="cov8" title="1">{
    313. 

  313.                         messageMailBox = map[string]interface{}{
    314. 

  314.                                 "appid":         in.Appid,
    315. 

  315.                                 "messag_id":     ok,
    316. 

  316.                                 "type":          in.ItemType,
    317. 

  317.                                 "create_time":   nowForm.Format(util.Date_Full_Layout),
    318. 

  318.                                 "read_time":     nowForm.Format(util.Date_Full_Layout),
    319. 

  319.                                 "isread":        1,
    320. 

  320.                                 "send_isdel":    0,
    321. 

  321.                                 "receive_isdel": 0,
    322. 

  322.                                 "iswithdraw":    0,
    323. 

  323.                         }
    324. 

  324.                         if in.OwnType == 1 </span><span class="cov8" title="1">{
    325. 

  325.                                 //用户接受系统信息
    326. 

  326.                                 messageMailBox["own_type"] = 2
    327. 

  327.                                 messageMailBox["send_user_type"] = 1
    328. 

  328.                                 messageMailBox["receive_user_type"] = 2
    329. 

  329.                                 messageMailBox["own_id"] = in.NewUserId
    330. 

  330.                                 messageMailBox["send_user_id"] = in.ReceiveId
    331. 

  331.                                 messageMailBox["receive_user_id"] = in.NewUserId
    332. 

  332.                         }</span> else<span class="cov8" title="1"> if in.OwnType == 2 </span><span class="cov8" title="1">{
    333. 

  333.                                 //客服接受系统信息
    334. 

  334.                                 messageMailBox["own_type"] = 1
    335. 

  335.                                 messageMailBox["send_user_type"] = 2
    336. 

  336.                                 messageMailBox["receive_user_type"] = 1
    337. 

  337.                                 messageMailBox["own_id"] = in.SendId
    338. 

  338.                                 messageMailBox["send_user_id"] = in.ReceiveId
    339. 

  339.                                 messageMailBox["receive_user_id"] = in.SendId
    340. 

  340. 

  341.                         }</span> else<span class="cov8" title="1"> {
    342. 

  342.                                 //客服接受系统信息
    343. 

  343.                                 messageMailBox["own_type"] = 1
    344. 

  344.                                 messageMailBox["send_user_type"] = 2
    345. 

  345.                                 messageMailBox["receive_user_type"] = 1
    346. 

  346.                                 messageMailBox["own_id"] = in.ReceiveId
    347. 

  347.                                 messageMailBox["send_user_id"] = in.NewUserId
    348. 

  348.                                 messageMailBox["receive_user_id"] = in.ReceiveId
    349. 

  349.                         }</span>
    350. 

  350.                         <span class="cov8" title="1">receiveOk = util.Mysql.InsertByTx(tx, util.SOCIALIZE_MESSAGE_MAILBOX, messageMailBox)
    351. 

  351.                         return ok &gt; 1 &amp;&amp; receiveOk &gt; 1</span>
    352. 

  352.                 }
    353. 

  353.                 <span class="cov8" title="1">if in.ItemType == 4 || in.ItemType == 5 </span><span class="cov8" title="1">{
    354. 

  354.                         //客服或者机器人聊天
    355. 

  355.                         if in.OwnType == 1 </span><span class="cov8" title="1">{
    356. 

  356.                                 // (用户发送)客服接受
    357. 

  357.                                 messageMailBox["own_type"] = 1
    358. 

  358.                                 messageMailBox["send_user_type"] = 2
    359. 

  359.                                 messageMailBox["receive_user_type"] = 1
    360. 

  360.                                 messageMailBox["own_id"] = in.ReceiveId
    361. 

  361.                                 messageMailBox["send_user_id"] = in.NewUserId
    362. 

  362.                                 messageMailBox["receive_user_id"] = in.ReceiveId
    363. 

  363.                         }</span> else<span class="cov8" title="1"> {
    364. 

  364.                                 //客服发送(用户接收信息)
    365. 

  365.                                 messageMailBox["own_type"] = 2
    366. 

  366.                                 messageMailBox["send_user_type"] = 1
    367. 

  367.                                 messageMailBox["receive_user_type"] = 2
    368. 

  368.                                 messageMailBox["own_id"] = in.ReceiveId
    369. 

  369.                                 messageMailBox["send_user_id"] = in.SendId
    370. 

  370.                                 messageMailBox["receive_user_id"] = in.ReceiveId
    371. 

  371.                                 if in.ItemType == 4 </span><span class="cov8" title="1">{
    372. 

  372.                                         messageMailBox["receive_user_id"] = in.NewUserId
    373. 

  373.                                         messageMailBox["own_id"] = in.NewUserId
    374. 

  374.                                         messageMailBox["isread"] = 1
    375. 

  375.                                         messageMailBox["read_time"] = nowForm.Format(util.Date_Full_Layout)
    376. 

  376.                                 }</span>
    377. 

  377.                         }
    378. 

  378.                 } else<span class="cov8" title="1"> {
    379. 

  379.                         messageMailBox["own_type"] = 2
    380. 

  380.                         messageMailBox["send_user_type"] = 2
    381. 

  381.                         messageMailBox["receive_user_type"] = 2
    382. 

  382.                         messageMailBox["own_id"] = in.ReceiveId
    383. 

  383.                         messageMailBox["send_user_id"] = in.NewUserId
    384. 

  384.                         messageMailBox["receive_user_id"] = in.ReceiveId
    385. 

  385.                 }</span>
    386. 

  386.                 <span class="cov8" title="1">receiveOk = util.Mysql.InsertByTx(tx, util.SOCIALIZE_MESSAGE_MAILBOX, messageMailBox)
    387. 

  387.                 messageMailBox = map[string]interface{}{
    388. 

  388.                         "appid":         in.Appid,
    389. 

  389.                         "messag_id":     ok,
    390. 

  390.                         "type":          in.ItemType,
    391. 

  391.                         "create_time":   nowForm.Format(util.Date_Full_Layout),
    392. 

  392.                         "read_time":     nowForm.Format(util.Date_Full_Layout),
    393. 

  393.                         "isread":        1,
    394. 

  394.                         "send_isdel":    0,
    395. 

  395.                         "receive_isdel": 0,
    396. 

  396.                         "iswithdraw":    0,
    397. 

  397.                 }
    398. 

  398.                 if in.ItemType == 4 || in.ItemType == 5 </span><span class="cov8" title="1">{
    399. 

  399.                         //客服或者机器人聊天
    400. 

  400.                         if in.OwnType == 1 </span><span class="cov8" title="1">{
    401. 

  401.                                 //用户发送(用户接受)
    402. 

  402.                                 messageMailBox["own_type"] = 2
    403. 

  403.                                 messageMailBox["send_user_type"] = 2
    404. 

  404.                                 messageMailBox["receive_user_type"] = 1
    405. 

  405.                                 messageMailBox["own_id"] = in.NewUserId
    406. 

  406.                                 messageMailBox["send_user_id"] = in.NewUserId
    407. 

  407.                                 messageMailBox["receive_user_id"] = in.ReceiveId
    408. 

  408. 

  409.                         }</span> else<span class="cov8" title="1"> {
    410. 

  410.                                 //客服发送信息(用户接受)
    411. 

  411.                                 messageMailBox["own_type"] = 1
    412. 

  412.                                 messageMailBox["send_user_type"] = 1
    413. 

  413.                                 messageMailBox["receive_user_type"] = 2
    414. 

  414.                                 messageMailBox["own_id"] = in.SendId
    415. 

  415.                                 messageMailBox["send_user_id"] = in.SendId
    416. 

  416.                                 messageMailBox["receive_user_id"] = in.ReceiveId
    417. 

  417.                                 if in.ItemType == 4 </span><span class="cov8" title="1">{
    418. 

  418.                                         messageMailBox["receive_user_id"] = in.NewUserId
    419. 

  419.                                 }</span>
    420. 

  420.                         }
    421. 

  421.                 } else<span class="cov8" title="1"> {
    422. 

  422.                         messageMailBox["own_type"] = 2
    423. 

  423.                         messageMailBox["send_user_type"] = 2
    424. 

  424.                         messageMailBox["receive_user_type"] = 2
    425. 

  425.                         messageMailBox["own_id"] = in.NewUserId
    426. 

  426.                         messageMailBox["send_user_id"] = in.NewUserId
    427. 

  427.                         messageMailBox["receive_user_id"] = in.ReceiveId
    428. 

  428.                 }</span>
    429. 

  429.                 <span class="cov8" title="1">receiveOk = util.Mysql.InsertByTx(tx, util.SOCIALIZE_MESSAGE_MAILBOX, messageMailBox)
    430. 

  430.                 return ok &gt; 1 &amp;&amp; receiveOk &gt; 1</span>
    431. 

  431.         })
    432. 

  432.         <span class="cov8" title="1">return fool, "", in.Content, messageId, nowForm.Unix()</span>
    433. 

  433. }
    434. 

  434. 

  435. //历史信息查询
    436. 

  436. func (b MessaggeService) FindMessage(in *messagecenter.MessageReq) *[]map[string]interface{} <span class="cov8" title="1">{
    437. 

  437.         sqlStr := ""
    438. 

  438.         lastStr := ""
    439. 

  439.         if in.LastId &gt; 0 </span><span class="cov8" title="1">{
    440. 

  440.                 if in.Sort == "asc" </span><span class="cov8" title="1">{
    441. 

  441.                         lastStr = fmt.Sprintf("AND  a.messag_id &gt; %d ", in.LastId)
    442. 

  442.                 }</span> else<span class="cov8" title="1"> {
    443. 

  443.                         lastStr = fmt.Sprintf("AND  a.messag_id &lt; %d ", in.LastId)
    444. 

  444.                 }</span>
    445. 

  445.         }
    446. 

  446.         <span class="cov8" title="1">switch in.MsgType </span>{
    447. 

  447.         case 2:<span class="cov8" title="1"> //点对点聊天
    448. 

  448.                 sqlStr = fmt.Sprintf("SELECT  a.messag_id as messageId,b.* ,if(a.own_id = a.send_user_id,1,2) as fool  "+
    449. 

  449.                         "FROM  %s a  "+
    450. 

  450.                         "LEFT JOIN %s b on  a.messag_id=b.id  "+
    451. 

  451.                         "LEFT  JOIN  %s c on  c.id=a.send_user_id   "+
    452. 

  452.                         "LEFT JOIN  %s d on  d.id=a.receive_user_id  "+
    453. 

  453.                         "where  a.own_id=  %d "+
    454. 

  454.                         "AND ((a.send_user_id=   %d AND   a.receive_user_id=   %d) or (a.send_user_id=  %d AND  a.receive_user_id=  %d)) "+
    455. 

  455.                         "AND  a.type=2  %s "+
    456. 

  456.                         "ORDER BY a.create_time desc ,a.id   asc "+
    457. 

  457.                         "limit 0 ,  %d ",
    458. 

  458.                         util.SOCIALIZE_MESSAGE_MAILBOX, util.SOCIALIZE_MESSAGE, util.BASE_USER, util.BASE_USER,
    459. 

  459.                         in.NewUserId, in.NewUserId, in.SendId, in.SendId, in.NewUserId, lastStr, in.PageSize)
    460. 

  460.                 break</span>
    461. 

  461.         case 4, 5, 6, 7:<span class="cov8" title="1"> //客服聊天
    462. 

  462.                 if in.UserType == 1 </span><span class="cov8" title="1">{
    463. 

  463.                         //客服聊天记录查看
    464. 

  464.                         sqlStr = fmt.Sprintf("SELECT   a.messag_id as messageId,b.*,   IF   ( a.own_id = a.send_user_id, 1, 2 ) AS fool,   a.send_user_type,   a.type AS itemType,   '' AS robotName,   '' AS robotImg,   c.customer_service_name AS setName ,   c.user_id   "+
    465. 

  465.                                 "FROM   %s a   "+
    466. 

  466.                                 "LEFT JOIN %s b ON a.messag_id = b.id   "+
    467. 

  467.                                 "LEFT JOIN %s c ON   a.own_type = 1  AND  a.own_id=c.id    "+
    468. 

  468.                                 "WHERE   a.own_type = 1   "+
    469. 

  469.                                 "AND (a.type = 5 or a.type=4 or  a.type=6 or  a.type=7)   "+
    470. 

  470.                                 "AND c.ent_id =   %d "+
    471. 

  471.                                 "AND c.user_id =   %d  %s "+
    472. 

  472.                                 "ORDER BY a.create_time desc ,a.id   asc "+
    473. 

  473.                                 "limit 0 ,  %d ",
    474. 

  474.                                 util.SOCIALIZE_MESSAGE_MAILBOX, util.SOCIALIZE_MESSAGE, util.SOCIALIZE_CHAT_SESSION,
    475. 

  475.                                 in.EntId, in.SendId, lastStr, in.PageSize)
    476. 

  476.                 }</span> else<span class="cov8" title="1"> {
    477. 

  477.                         //用户聊天记录查看
    478. 

  478.                         sqlStr = fmt.Sprintf("SELECT a.messag_id as messageId,  b.*,   IF   ( a.own_id = a.send_user_id, 1, 2 ) AS fool ,   a.send_user_type,   a.type as  itemType,   d.nickname as  robotName,   d.headimage as  robotImg,   c.customer_service_name as  setName   "+
    479. 

  479.                                 "FROM   %s a   "+
    480. 

  480.                                 "LEFT JOIN %s b ON a.messag_id = b.id   "+
    481. 

  481.                                 "LEFT JOIN %s c ON   IF   ( a.send_user_type = 1, c.id = a.send_user_id, c.id = a.receive_user_id ) AND  c.ent_id = %d AND c.user_id = %d "+
    482. 

  482.                                 "LEFT JOIN  %s d on  c.ent_id=d.ent_id    "+
    483. 

  483.                                 "WHERE   a.own_type = 2    "+
    484. 

  484.                                 "AND a.own_id =  %d "+
    485. 

  485.                                 "AND  c.ent_id = %d "+
    486. 

  486.                                 "AND c.user_id =  %d "+
    487. 

  487.                                 "AND ( a.type = 4 OR a.type = 5 or a.type=6 or  a.type=7)  %s "+
    488. 

  488.                                 "ORDER BY a.create_time desc ,a.id   asc "+
    489. 

  489.                                 "limit 0 ,   %d ",
    490. 

  490.                                 util.SOCIALIZE_MESSAGE_MAILBOX, util.SOCIALIZE_MESSAGE, util.SOCIALIZE_CHAT_SESSION, in.SendId, in.NewUserId, util.SOCIALIZE_TENANT_ROBOT,
    491. 

  491.                                 in.NewUserId, in.SendId, in.NewUserId, lastStr, in.PageSize)
    492. 

  492.                 }</span>
    493. 

  493.                 <span class="cov8" title="1">break</span>
    494. 

  494.         }
    495. 

  495.         <span class="cov8" title="1">log.Println(sqlStr)
    496. 

  496.         data := util.Mysql.SelectBySql(sqlStr)
    497. 

  497.         //自己头像处理
    498. 

  498.         if in.UserType == 2 </span><span class="cov8" title="1">{
    499. 

  499.                 userData := util.Mysql.FindOne(util.BASE_USER, map[string]interface{}{"id": in.NewUserId}, "headimg", "")
    500. 

  500.                 if userData != nil </span><span class="cov8" title="1">{
    501. 

  501.                         for key := range *data </span><span class="cov8" title="1">{
    502. 

  502.                                 (*data)[key]["ownImg"] = (*userData)["headimg"]
    503. 

  503.                         }</span>
    504. 

  504.                 }
    505. 

  505. 

  506.         }
    507. 

  507.         <span class="cov8" title="1">go func() </span><span class="cov8" title="1">{
    508. 

  508.                 updateMap := map[string]interface{}{}
    509. 

  509.                 if len(*data) &gt; 0 </span><span class="cov8" title="1">{
    510. 

  510.                         //未读信息修改
    511. 

  511.                         switch in.MsgType </span>{
    512. 

  512.                         case 2:<span class="cov8" title="1"> //点对点聊天
    513. 

  513.                                 updateMap = map[string]interface{}{
    514. 

  514.                                         "own_type": 2,
    515. 

  515.                                         "own_id":   in.NewUserId,
    516. 

  516.                                         "type":     2,
    517. 

  517.                                         "isread":   0,
    518. 

  518.                                 }
    519. 

  519.                                 util.Mysql.Update(util.SOCIALIZE_MESSAGE_MAILBOX, updateMap, map[string]interface{}{"isread": 1, "read_time": time.Now().Local().Format(util.Date_Full_Layout)})
    520. 

  520.                                 break</span>
    521. 

  521.                         case 4, 5:<span class="cov8" title="1">
    522. 

  522.                                 sqlStr := ""
    523. 

  523.                                 if in.UserType == 1 </span><span class="cov8" title="1">{
    524. 

  524.                                         sqlStr = fmt.Sprintf("UPDATE %s a  SET a.isread = 1,    a.read_time = now( )  "+
    525. 

  525.                                                 "WHERE    a.own_type = 1  "+
    526. 

  526.                                                 "AND a.type IN ( 4,5,6,7)  "+
    527. 

  527.                                                 "AND a.isread = 0    "+
    528. 

  528.                                                 "AND a.own_id IN ( SELECT b.id FROM %s b WHERE   b.customer_service_id=%d AND    b.user_id=%d  )",
    529. 

  529.                                                 util.SOCIALIZE_MESSAGE_MAILBOX, util.SOCIALIZE_CHAT_SESSION, in.EntUserId, in.SendId)
    530. 

  530.                                 }</span> else<span class="cov8" title="1"> {
    531. 

  531.                                         sqlStr = fmt.Sprintf("UPDATE %s a  SET a.isread = 1,    a.read_time = now( )  "+
    532. 

  532.                                                 "WHERE    a.own_type = 2  "+
    533. 

  533.                                                 "AND a.type IN ( 4,5,6,7 )  "+
    534. 

  534.                                                 "AND a.isread = 0    "+
    535. 

  535.                                                 "AND a.own_id =%d ", util.SOCIALIZE_MESSAGE_MAILBOX, in.NewUserId)
    536. 

  536.                                 }</span>
    537. 

  537.                                 <span class="cov8" title="1">util.Mysql.UpdateOrDeleteBySql(sqlStr)
    538. 

  538.                                 break</span>
    539. 

  539.                         }
    540. 

  540.                 }
    541. 

  541.         }()
    542. 

  542.         <span class="cov8" title="1">return data</span>
    543. 

  543. }
    544. 

  544. 

  545. //创建会话
    546. 

  546. func (b MessaggeService) CreateChatSession(in *messagecenter.ChatSessionReq) (fool bool, sessionId int64) <span class="cov8" title="1">{
    547. 

  547.         fool = util.Mysql.ExecTx("会话新建", func(tx *sql.Tx) bool </span><span class="cov8" title="1">{
    548. 

  548.                 customerserviceName := in.CustomerserviceName
    549. 

  549.                 if in.CustomerServiceId != 0 </span><span class="cov8" title="1">{
    550. 

  550.                         sqlStr:=fmt.Sprintf("select  customer_service_name from  %s "+
    551. 

  551.                                 "where  ent_id= %d "+
    552. 

  552.                                 "AND customer_service_id= %d ",
    553. 

  553.                                 util.SOCIALIZE_CHAT_SESSION, in.EntId, in.CustomerServiceId)
    554. 

  554.                         customerList := util.Mysql.SelectBySql(sqlStr)
    555. 

  555.                         if len(*customerList) &gt; 0 </span><span class="cov8" title="1">{
    556. 

  556.                                 customerserviceName = quitl.InterfaceToStr((*customerList)[0]["customer_service_name"])
    557. 

  557.                         }</span>
    558. 

  558.                 }
    559. 

  559.                 <span class="cov8" title="1">chatMession := map[string]interface{}{
    560. 

  560.                         "handle_status":         0,
    561. 

  561.                         "start_time":            time.Now().Local().Format(util.Date_Full_Layout),
    562. 

  562.                         "appid":                 in.AppId,
    563. 

  563.                         "ent_id":                in.EntId,
    564. 

  564.                         "customer_service_id":   in.CustomerServiceId,
    565. 

  565.                         "user_id":               in.UserId,
    566. 

  566.                         "customer_service_name": customerserviceName,
    567. 

  567.                 }
    568. 

  568.                 sessionId = util.Mysql.InsertByTx(tx, util.SOCIALIZE_CHAT_SESSION, chatMession)
    569. 

  569.                 return sessionId &gt; 0</span>
    570. 

  570.         })
    571. 

  571.         <span class="cov8" title="1">return fool, sessionId</span>
    572. 

  572. }
    573. 

  573. 

  574. //结束会话
    575. 

  575. func (b MessaggeService) CloseChatSession(in *messagecenter.CloseSessionReq) bool <span class="cov8" title="1">{
    576. 

  576.         fool := util.Mysql.ExecTx("关闭会话", func(tx *sql.Tx) bool </span><span class="cov8" title="1">{
    577. 

  577.                 updateMap := map[string]interface{}{
    578. 

  578.                         "id": in.SessionId,
    579. 

  579.                 }
    580. 

  580.                 fool := util.Mysql.Update(util.SOCIALIZE_CHAT_SESSION, updateMap, map[string]interface{}{"start_time": time.Now().Local().Format(util.Date_Full_Layout)})
    581. 

  581.                 return fool
    582. 

  582.         }</span>)
    583. 

  583.         <span class="cov8" title="1">return fool</span>
    584. 

  584. }
    585. 

  585. 

  586. //创建会话并保存信息
    587. 

  587. func (b *MessaggeService) SaveAutoReplyMsg(userType, entId, entUserId, userId int64, content, appId, nowFormat string) (bool, int64) <span class="cov8" title="1">{
    588. 

  588.         messageId := int64(0)
    589. 

  589.         return util.Mysql.ExecTx("保存自动回复消息", func(tx *sql.Tx) bool </span><span class="cov8" title="1">{
    590. 

  590.                 entUserName := ""
    591. 

  591.                 if entUserId &gt; 0 </span><span class="cov8" title="1">{
    592. 

  592.                         list := util.Mysql.SelectBySql(`select ? from socialize_tenant_seat where appid=? AND ent_id=? AND customer_service_id=?`, util.SOCIALIZE_CHAT_SESSION, appId, entId, entUserId)
    593. 

  593.                         if list != nil &amp;&amp; len(*list) &gt; 0 </span><span class="cov8" title="1">{
    594. 

  594.                                 entUserName, _ = (*list)[0]["customer_service_name"].(string)
    595. 

  595.                         }</span>
    596. 

  596.                 }
    597. 

  597.                 <span class="cov8" title="1">messageId = util.Mysql.InsertBySqlByTx(tx, `insert into ? (appid,content,item,type,create_time,create_person) values (?,?,?,?,?,?)`, util.SOCIALIZE_MESSAGE, appId, content, 8, 1, nowFormat, "admin")
    598. 

  598.                 sessionId := util.Mysql.InsertBySqlByTx(tx, `insert into ? (appid,type,ent_id,customer_service_id,customer_service_name,user_id,start_time,end_time) values (?,?,?,?,?,?,?,?)`, util.SOCIALIZE_CHAT_SESSION, appId, 1, entId, entUserId, entUserName, userId, nowFormat, nowFormat)
    599. 

  599.                 ok := false
    600. 

  600.                 if userType == 0 </span><span class="cov8" title="1">{
    601. 

  601.                         ok1 := util.Mysql.InsertBySqlByTx(tx, `insert into ? (appid,messag_id,type,send_user_id,send_user_type,receive_user_id,receive_user_type,own_id,own_type,create_time,isread,read_time) values (?,?,?,?,?,?,?,?,?,?,?,?)`, util.SOCIALIZE_MESSAGE_MAILBOX, appId, messageId, 7, sessionId, 1, userId, 2, sessionId, 1, nowFormat, 1, nowFormat) &gt; 0
    602. 

  602.                         ok2 := util.Mysql.InsertBySqlByTx(tx, `insert into ? (appid,messag_id,type,send_user_id,send_user_type,receive_user_id,receive_user_type,own_id,own_type,create_time) values (?,?,?,?,?,?,?,?,?,?)`, util.SOCIALIZE_MESSAGE_MAILBOX, appId, messageId, 7, sessionId, 1, userId, 2, userId, 2, nowFormat) &gt; 0
    603. 

  603.                         ok = ok1 &amp;&amp; ok2
    604. 

  604.                 }</span> else<span class="cov8" title="1"> if userType == 1 </span><span class="cov8" title="1">{
    605. 

  605.                         ok = util.Mysql.InsertBySqlByTx(tx, `insert into ? (appid,messag_id,type,send_user_id,send_user_type,receive_user_id,receive_user_type,own_id,own_type,create_time,isread,read_time) values (?,?,?,?,?,?,?,?,?,?,?,?)`, util.SOCIALIZE_MESSAGE_MAILBOX, appId, messageId, 7, sessionId, 1, userId, 2, sessionId, 1, nowFormat, 1, nowFormat) &gt; 0
    606. 

  606.                 }</span> else<span class="cov8" title="1"> if userType == 2 </span><span class="cov8" title="1">{
    607. 

  607.                         ok = util.Mysql.InsertBySqlByTx(tx, `insert into ? (appid,messag_id,type,send_user_id,send_user_type,receive_user_id,receive_user_type,own_id,own_type,create_time) values (?,?,?,?,?,?,?,?,?,?)`, util.SOCIALIZE_MESSAGE_MAILBOX, appId, messageId, 7, sessionId, 1, userId, 2, userId, 2, nowFormat) &gt; 0
    608. 

  608.                 }</span>
    609. 

  609.                 <span class="cov8" title="1">return messageId &gt; 0 &amp;&amp; sessionId &gt; 0 &amp;&amp; ok</span>
    610. 

  610.         }), messageId
    611. 

  611. }
    612. 

  612. 

  613. //修改未读状态
    614. 

  614. func (b MessaggeService) UpdateReadById(in *messagecenter.ReadStateReq) bool <span class="cov8" title="1">{
    615. 

  615.         fool := util.Mysql.ExecTx("已读状态修改", func(tx *sql.Tx) bool </span><span class="cov8" title="1">{
    616. 

  616.                 updateMap := map[string]interface{}{
    617. 

  617.                         "messag_id": in.MessageId,
    618. 

  618.                         "isread":    0,
    619. 

  619.                 }
    620. 

  620.                 fool := util.Mysql.Update(util.SOCIALIZE_MESSAGE_MAILBOX, updateMap, map[string]interface{}{"read_time": time.Now().Local().Format(util.Date_Full_Layout), "isread": 1})
    621. 

  621.                 return fool
    622. 

  622.         }</span>)
    623. 

  623.         <span class="cov8" title="1">return fool</span>
    624. 

  624. }
    625. 

  625. </pre>
    626. 

  626. 		
    627. 

  627. 		</div>
    628. 

  628. 	</body>
    629. 

  629. 	<script>
    630. 

  630. 	(function() {
    631. 

  631. 		var files = document.getElementById('files');
    632. 

  632. 		var visible;
    633. 

  633. 		files.addEventListener('change', onChange, false);
    634. 

  634. 		function select(part) {
    635. 

  635. 			if (visible)
    636. 

  636. 				visible.style.display = 'none';
    637. 

  637. 			visible = document.getElementById(part);
    638. 

  638. 			if (!visible)
    639. 

  639. 				return;
    640. 

  640. 			files.value = part;
    641. 

  641. 			visible.style.display = 'block';
    642. 

  642. 			location.hash = part;
    643. 

  643. 		}
    644. 

  644. 		function onChange() {
    645. 

  645. 			select(files.value);
    646. 

  646. 			window.scrollTo(0, 0);
    647. 

  647. 		}
    648. 

  648. 		if (location.hash != "") {
    649. 

  649. 			select(location.hash.substr(1));
    650. 

  650. 		}
    651. 

  651. 		if (!visible) {
    652. 

  652. 			select("file0");
    653. 

  653. 		}
    654. 

  654. 	})();
    655. 

  655. 	</script>
    656. 

  656. </html>
    657.