erxes/erxes-integrations#69

erxes · Dec 16, 2019 · fdef0db · fdef0db
1 parent 411c57b
commit fdef0db
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 4 deletions.
diff --git a/src/data/schema/user.ts b/src/data/schema/user.ts
@@ -6,6 +6,7 @@ export const types = `
     position: String
     location: String
     description: String
+    operatorPhone: String
   }
 
   input UserLinks {
@@ -35,6 +36,7 @@ export const types = `
     position: String
     location: String
     description: String
+    operatorPhone: String
   }
 
   type UserLinksType {

diff --git a/src/db/models/definitions/users.ts b/src/db/models/definitions/users.ts
@@ -15,6 +15,7 @@ export interface IDetail {
   position?: string;
   location?: string;
   description?: string;
+  operatorPhone?: string;
 }
 
 export interface IDetailDocument extends IDetail, Document {}
@@ -76,6 +77,7 @@ const detailSchema = new Schema(
     position: field({ type: String, label: 'Position' }),
     location: field({ type: String, optional: true, label: 'Location' }),
     description: field({ type: String, optional: true, label: 'Description' }),
+    operatorPhone: field({ type: String, optional: true, label: 'Company phone' }),
   },
   { _id: false },
 );

diff --git a/src/middlewares/integrationsApiMiddleware.ts b/src/middlewares/integrationsApiMiddleware.ts
@@ -1,4 +1,4 @@
-import { ConversationMessages, Conversations, Customers, Integrations } from '../db/models';
+import { ConversationMessages, Conversations, Customers, Integrations, Users } from '../db/models';
 import { CONVERSATION_STATUSES } from '../db/models/definitions/constants';
 import { graphqlPubsub } from '../pubsub';
 
@@ -48,14 +48,18 @@ const integrationsApiMiddleware = async (req, res) => {
   }
 
   if (action === 'create-or-update-conversation') {
-    if (doc.conversationId) {
-      const { conversationId, content } = doc;
+    const { conversationId, content, owner } = doc;
+    const user = await Users.findOne({ 'details.operatorPhone': owner });
+    const assignedUserId = user ? user._id : '';
 
-      await Conversations.updateConversation(conversationId, { content });
+    if (conversationId) {
+      await Conversations.updateConversation(conversationId, { content, assignedUserId });
 
       return res.json({ _id: conversationId });
     }
 
+    doc.assignedUserId = assignedUserId;
+
     const conversation = await Conversations.createConversation(doc);
 
     return res.json({ _id: conversation._id });