group.js 9.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280
  1. /**
  2. * 聊天组模型。
  3. */
  4. "use strict";
  5. let BaseModel = require('./base.model');
  6. let log = require("../util/log.js");
  7. let modelUtil = require('../util/modelUtil');
  8. let getui = require('getui');
  9. let Patient = new require("../models/patient");
  10. let Doctor = new require('../models/doctor');
  11. let groupRepo = require('../repository/group.repo');
  12. let gmRepo = require('../repository/group.msg.repo');
  13. let statsRepo = require("../repository/stats.msg.repo");
  14. let objectUtil = require("../util/objectUtil.js");
  15. const GROUP_TYPE = require('../include/commons').GROUP_TYPE;
  16. const MAX_INT = require('../include/commons').MAX_INT;
  17. class GroupMessage extends BaseModel {
  18. constructor() {
  19. super();
  20. }
  21. /**
  22. * 发送消息。
  23. *
  24. * @param message
  25. */
  26. sendMessage(message) {
  27. let self = this;
  28. groupRepo.isGroupMember(message.group, message.groupType, message.from, function (err, result) {
  29. if (err) {
  30. modelUtil.emitDbError(self.eventEmitter, 'Check group member failed', err);
  31. return;
  32. }
  33. if (result.length == 0) {
  34. modelUtil.emitDataNotFound(self.eventEmitter, 'Member with id "' + message.from + '" is not in group "' + message.group + '"');
  35. return;
  36. }
  37. // 保存群组消息
  38. gmRepo.save(message.from, message.group, message.at, message.contentType, message.content, function (err, insertedRow) {
  39. if (err) {
  40. modelUtil.emitDbError(self.eventEmitter, 'Save group message failed', err);
  41. return;
  42. }
  43. gmRepo.findOneMessage(insertedRow.insertId, function (err, groupMsg) {
  44. if (err) {
  45. modelUtil.emitDbError(self.eventEmitter, 'Save group message success, but return this message failed', err);
  46. return;
  47. }
  48. // 关闭网络连接后执行后续操作
  49. let feedback = Doctor.fillMessages(groupMsg);
  50. modelUtil.emitData(self.eventEmitter, feedback);
  51. // 推送通知消息给群组成员
  52. groupRepo.getMembers(message.group, message.groupType, function (err, members) {
  53. if (err) {
  54. log.error('Get group members failed: ', err);
  55. return;
  56. }
  57. if (members.length == 0) {
  58. log.warn('No members in group ', message.group,
  59. message.groupType === GROUP_TYPE.AdminTeam ? " of admin team." : "of discussion group.");
  60. return;
  61. }
  62. // 逐个推送通知,患者与医生推送方式不一样
  63. for (let i = 0; i < members.length; i++) {
  64. let member = members[i];
  65. if (member.user_id === message.from) continue;
  66. (function (userId) {
  67. Patient.isPatientCode(userId,
  68. function () {
  69. Patient.sendMessage(userId, 2, feedback);
  70. },
  71. function () {
  72. Doctor.pushMessage(message, 'group_msg');
  73. // 更新用户组内消息摘要
  74. let at = message.at == userId ? 1 : 0;
  75. statsRepo.updateGroupChatSummary(userId,
  76. message.group,
  77. message.from,
  78. at,
  79. message.contentType,
  80. message.content,
  81. true,
  82. function (err, result) {
  83. if (err) log.error(err);
  84. });
  85. });
  86. })(member.user_id);
  87. }
  88. });
  89. });
  90. // 更新组内统计信息
  91. statsRepo.updateGroupChatSummary(message.from, message.group, message.from, 0, message.contentType, message.content, false, function (err, result) {
  92. if (err) log.error(err);
  93. });
  94. });
  95. });
  96. }
  97. /**
  98. * 获取组消息。
  99. */
  100. getMessages(groupId, memberId, contentType, msgStartId, msgEndId, count) {
  101. let self = this;
  102. gmRepo.findAllMessages(groupId, !contentType ? "1,2,3,5,6" : contentType, msgStartId, msgEndId, count, function (err, rows) {
  103. if (err) {
  104. modelUtil.emitDbError(self.eventEmitter, 'Get group message failed', err);
  105. return;
  106. }
  107. // 先给客户端返回数据
  108. let messages = Doctor.fillMessages(rows);
  109. modelUtil.emitData(self.eventEmitter, messages);
  110. // 清空统计信息
  111. statsRepo.clearGroupChatSummary(memberId, groupId, function (err, result) {
  112. if (err) console.log(err);
  113. });
  114. });
  115. }
  116. /**
  117. * 获取组内未读消息。
  118. * @param groupId
  119. */
  120. getUnreadMessages(groupId, memberId) {
  121. let self = this;
  122. statsRepo.getGroupChatSummary(memberId, groupId, function (err, summary) {
  123. if (err) {
  124. modelUtil.emitDbError(self.eventEmitter, "Get unread group messages failed", err);
  125. return;
  126. }
  127. let messages = {startId: 0, count: 0, records: []};
  128. if (summary.length == 0 || summary[0].new_msg_count === 0) {
  129. modelUtil.emitData(messages);
  130. return;
  131. }
  132. messages.count = summary[0].new_msg_count;
  133. gmRepo.findUnread(groupId, MAX_INT, messages.count, function (err, rows) {
  134. if (err) {
  135. modelUtil.emitDbError(self.eventEmitter, "Get unread group messages failed", err);
  136. return;
  137. }
  138. let feedback = Doctor.fillMessages(rows);
  139. modelUtil.emitData(feedback);
  140. });
  141. }
  142. )
  143. ;
  144. }
  145. /**
  146. * 获取未读消息数量。
  147. *
  148. * @param memberId
  149. */
  150. getUnreadMessageCount(memberId) {
  151. let self = this;
  152. statsRepo.getGroupChatAllUnReadCount(memberId, function (err, result) {
  153. if (err) {
  154. modelUtil.emitDbError(self.eventEmitter, 'Get all unread messages failed', err);
  155. return;
  156. }
  157. let data = {
  158. userId: memberId,
  159. messageType: 2,
  160. newMessageCount: 0
  161. };
  162. if (result.length > 0) {
  163. for (let index = 0; index < result.length; index++) {
  164. data.newMessageCount += result[index].new_msg_count;
  165. }
  166. }
  167. modelUtil.emitData(self.eventEmitter, data);
  168. });
  169. }
  170. /**
  171. * 获取特定群组消息统计情况.
  172. *
  173. * @param groupId
  174. * @param memberId
  175. */
  176. getChatSummary(groupId, memberId) {
  177. let self = this;
  178. statsRepo.getGroupChatSummary(memberId, groupId, function (err, result) {
  179. if (err) {
  180. modelUtil.emitDbError(self.eventEmitter, 'Get group stats failed', err);
  181. return;
  182. }
  183. let data = {
  184. userId: userId,
  185. from: "",
  186. groupId: groupId,
  187. atMe: 0,
  188. lastContentType: 1,
  189. lastContent: "",
  190. newMessageCount: 0,
  191. timestamp: 0
  192. };
  193. if (result.length > 0) {
  194. let row = result[0];
  195. data.from = row.from_uid;
  196. data.groupId = row.gid;
  197. data.atMe = row.at_me;
  198. data.lastContentType = row.last_content_type;
  199. data.lastContent = row.lastContent;
  200. data.newMessageCount = row.new_msg_count;
  201. data.timestamp = objectUtil.timestampToLong(row.timestamp)
  202. }
  203. modelUtil.emitData(self.eventEmitter, data);
  204. });
  205. }
  206. /**
  207. * 获取成员头像。
  208. *
  209. * @param groups 要获取的组ID列表。
  210. */
  211. getMemberAvatars(groups) {
  212. let self = this;
  213. let avatars = [];
  214. groupRepo.getMembersAvatar(groups, function (err, members) {
  215. if (err) {
  216. modelUtil.emitDbError(self.eventEmitter, "Get group member's avatar list failed", err);
  217. return;
  218. }
  219. let lastGroup;
  220. let lastGroupCode = '';
  221. for (let i = 0; i < members.length; ++i) {
  222. let member = members[i];
  223. let groupCode = member.g_code;
  224. if (lastGroupCode !== groupCode) {
  225. lastGroupCode = groupCode;
  226. lastGroup = {groupCode: groupCode, avatars: []};
  227. if (lastGroupCode !== '') {
  228. avatars.push(lastGroup);
  229. }
  230. }
  231. lastGroup.avatars.push({
  232. code: member.code,
  233. name: member.name,
  234. avatar: member.photo === null ? "" : member.photo,
  235. role: member.type
  236. });
  237. }
  238. modelUtil.emitData(self.eventEmitter, avatars);
  239. });
  240. }
  241. }
  242. module.exports = GroupMessage;