Please enable JavaScript.

Coggle requires JavaScript to display documents.

ZALO, be-pima, customer chat, fe-crm-pima, customer chat, hiện các tên…

- - - - lấy tất cả record trong bảng zaloUserMini và có include ZaloUser
  - - - zalochatlistService.findBy_user_id_employee_real
        
        findMany by user_id_employee_real
        
        quan trọng là có trả ra mảng unseenMessages chứa các id của message seen false chưa đọc cho FE biết
    - - zalochatlistService.updateEmployeeRealByCustomerId
        
        tìm record dựa trên user_id_customer và update vào cái user_id_employee_real là user_id của employee được chọn
    - - zalochatlistService.updateSocketIdByCustomerId
        
        tìm record dựa trên user_id_customer và update vào cái socketId
  - - - FE gửi cái socketId và user_id_customer đến gateway
        
        save socketId vào bảng zaloChatList theo user_id_customer
        => như vậy mỗi user_id_customer có socketId riêng
    - - Gửi ra FE client cái socketId và record zaloChat mới
    - - FE: Kết nối với BE thông qua socket.id
        
        zaloChat.tsx
        
        FE: socket.emit('register_Chat_SocketId'
        
        gửi socketId và user_id_customer cho BE websocket với sự kiện register_Chat_SocketId
        
        zalo-chat.gateway.ts
        
        BE: SubscribeMessage('register_Chat_SocketId')
        
        Lưu socketId vào zaloChatList ứng với user_id_customer
        
        webhook
        
        ZalowebhookController
        
        khi webhook có sự kiện user_send_text, và oa_send_text thì gọi hàm zalochatgatewayService.create để vừa lưu vào database vừa kích hoạt emit thông qua websocket tới FE
        
        zalochatgatewayService.create để vừa lưu vào database vừa kích hoạt emit thông qua websocket tới FE
        
        1 more item...
  - - - save cái zalochat mới vào bảng
        
        lấy ra cái user_id_customer
        
        tìm cái socketId trong bảng zaloChatList dựa trên user_id_customer
        
        gọi hàm emitToSpecificClient để nó truyền ra FE đoạn chat vừa save và cái socketId
- - - - handleWebhook
        
        nếu event_name là user_send_text
        
        Thì cập nhật message đó vào bảng zalochat
        
        ZalowebhookController
        
        kiểm tra from_id và to_id đã có trong bảng ZaloUser chưa, nếu chưa thì phải gọi api lên zalo để lấy đầy dủ thông tin của user đó mà đổ vào bảng zaloUser
        
        Gọi hàm zalouserService.getFullInfoOfUser để nó lấy full info của user
        
        nếu accessToken hay refreshToken invalid thì phải update vào bảng ZaloTokenStatus để ngoài FE biết mà update
        
        ZalouserService hàm getFullInfoOfUser
        
        Nếu cả 2 token đều valid thì....xử lý tiếp logic này thế nào, gửi ra zalo hay sao, vì bảng zalotokenstatus đã hiện invalid rồi
        
        1 more item...
        
        ZalowebhookController
        
        Kiểm tra from_id và to_id đã có trong bảng zaloChatList chưa
        
        bảng zalochatlist nghĩa là lưu các cặp userid khách hàng và nhân viên, để xem cái message này nó thuộc hội thoại nào để sau này groupby ra cho dễ và nhanh
        
        zalochatlistService hàm findPairOrReturnNull
        
        nếu ko tìm thấy thì ta thêm record mới vào zalochatlist và trích xuất ra zaloChatListId
        
        nếu tìm thấy thì trích xuất ra zaloChatListId
        
        Lấy ra zaloChatListId và lưu cùng với ZaloChat
        
        ZalowebhookController
        
        classify cái message xem đây là câu gì, dùng gemini api
        
        textclassifyService
        
        Nhưng phải đảm bảo bảng zaloUserMini đã có id của from_id và to_id,
        
        vì vậy để chắc cú, trước khi thêm vào bảng zalochat ta kiểm tra trước, nếu không có thì thêm from_id và to_id vào bảng zalousermini trước
        
        zalouserminiService.create
        
        sau khi đã vượt qua các bước trên thì cập nhật vào bảng zalochat
        
        tuy nhiên ta muốn khi cập nhật vào bảng zalo chat thì cũng muốn báo sự kiện có tin nhắn mới đển FE, nên ta phải dùng gateway, nhưng ta ko thể tích hợp gateway vào zalochatservice, do service này dùng ở nhiều nơi chồng chéo, nên tích hợp vào bị lỗi. vì vậy ta phải tạo riêng một service để thao tác với bảng ZaloChat
        
        zalochatgatewayService.create(obj)
        
        zalochatgatewayService.create(obj)
        
        hàm này ngoài nhiệm vụ chính là thêm tin nhắn mới vào bảng zalochat
        
        Nó còn phát tín hiệu đến zaloChatGateway.emitToSpecificClient(socketId, newChat)
        
        để thông báo rằng có tin nhắn mới đối với socketId này
        
        socketId là của khách hàng này
        
        1 more item...
        
        nếu event_name là oa_send_text
        
        zalochatlistService hàm findPairOrReturnNull
        
        nếu ko tìm thấy thì ta thêm record mới vào zalochatlist và trích xuất ra zaloChatListId
        
        nếu tìm thấy thì trích xuất ra zaloChatListId
        
        Lấy ra zaloChatListId và lưu cùng với ZaloChat
        
        ZalowebhookController
        => Sau khi đã có các data ở trên thì giờ mình đã có đủ data để thêm vào bảng ZaloChat
        
        Nếu event là user_send_image hoặc user_send_file
        
        thì làm giống user_send_text, chỉ có điều là có thêm url mà msg xử lý có thể là ""
        
        Nếu event là oa_send_image hoặc oa_send_file
        
        Thì làm giống oa_send_text, và thêm url và text có thể là ""
    - - ZaloapioasendmessageController
        
        khi attachmentID === "" thì dùng hàm này chỉ để gửi tin nhắn
        
        gọi zaloapioasendmessageService.oasendTextMessage
        
        zaloapioasendmessageService
        
        lấy accessToken và refreshToken
        
        gọi api tới zalo để oa send message
        
        nếu token invalid thì update invalid
      - khi attachmentID !== "" thì dùng hàm này chỉ để gửi tin nhắn kèm hình ảnh
        
        zaloapioasendmessageService.sendMessageWithAttachmentId(user_id, finalAnswer, attachmentId)
    - - fetchAllUsers
        
        Lấy toàn bộ user_id trên zalo server, sau đó update vào bảng zaloUserMini và ZaloUser, nếu có rồi thì ignore, chưa có thì thêm vào
    - - Khi đã lấy được token và refresh token ta lưu vào bảng Zalotoken và zalo tokenStatus
        
        cách dùng
        
        const resultToken = await this.gettokenService.refreshAccessToken();
        const accessTokenNew = resultToken.access_token;
    - - fetchAllGroups
        
        lấy toàn bộ group zalo trên zalo server
        
        thêm vào bảng zaloGroup nếu chưa có [BE111]
    - - Hàm readAllFiles
        
        excelService.processFilesAndSheets()
        
        ExcelService
        
        processFilesAndSheets
        
        readExcelFromGoogleDrive(fileId: string, sheetNames: string[])
        
        Tùy theo sheet name mà ta convert theo từng kiểu, vì mỗi sheet có cấu trúc data khác nhau, sau đó save vào file BGG.json thông qua hàm saveJsonData
        
        iterate theo từng fileId
        
        truyền vào từng hàm theo fileId và sheetName
        
        lưu ý sheetName và fileId mình định nghĩa sẵn trong file fileSheetsMapping
        
        nên sheetname mình truyền vào hàm là do mình set trước
        
        có thể dùng sheetName thực tế khi lấy file về từ google drive để iterate, nhưng nếu lấy kiểu đó thì sẽ iterate cả những sheetName mình không cần, còn mình set trước thì chủ đích mình chỉ muốn iterate những cái đó thôi, đỡ tốn tài nguyên, nhưng nếu sheetName thực tế thay đổi trên GD, thì sẽ bị lỗi
        
        Đối với mỗi fileId thì mình phải tạo hàm riêng, tách ra cho đơn giản
        
        hàm tiền tố readExcelFromGoogleDrive
        
        lưu các sheetName vào ExcelFile để theo dõi sự thay đổi của sheetName
        
        trong mỗi sheet sẽ có một hày nhiều mặt hàng , vì vậy ta phải tạo nhiều hàm convert để đổ vào từng ngành hàng khác nhau
      - hàm readtest
        
        truyền vào là fileId của file excel trên google drive
        
        sheetname
        
        để nó lưu vào file test,json, để ta đọc thử nội dung của 1 sheet của 1 file để ta xem có lấy đc data không
        
        ExcelService
        
        readExcelFromGoogleDriveTest
        
        download file từ google drive theo fileId
        
        lưu nội dung của sheet vào file test.json
    - - uploadImage
        
        Lấy toàn bộ sanphamTen mà url ko null
        
        sau đó upload hình lên zalo server thông qua hàm this.zaloUploadPictureService.uploadImageFromUrl(url)
        
        zalo server sẽ trả về cái attachmentId, mình update vào sanphamten cái attachmentId theo id,
        
        vậy là sanphamten sẽ có url từ firebase và attachmentId từ zalo server
- - - - aichatService.getGeminiGenerateAnswer
- - - - lấy tất cả tên hình và url từ google firebase storage
        
        sau đó gán url của mỗi hình vào sanphamten dựa theo tên của hình
        
        firebasestorage service
        
        this.firebaseStorageService.getAllPictures()
        
        this.sanphamtenService.searchSanPhamByTen(name)
        
        this.sanphamtenService.updateUrlById(sanPhamTenId, url)
- - - - Trả ra TextclassifyController type và try
        
        TextclassifyController
        
        lưu vào testChat type và try thông qua testchatService
        
        testchatService
        
        hiện ra FE đoạn vừa lưu vào TestChat
- - - - request_AI_answer
        
        AichatController
        
        request_AI_answer
        
        others type
        
        trả lời chung chung AutoResponse1
        
        nếu type là QUESTION
        
        aichatService
        
        getGeminiContent
        
        1 more item...
        
        Nếu type là PRAISE
        
        lấy các câu sẵn có
        
        negative
        
        lấy các câu sẵn có
- - - - Lấy toàn bộ user
        
        tách thành các mảng employee, customerFollow, not follow
        
        getAllZaloUser
        
        zalousermini/getAllZaloUser
      - Nhân viên Pima sẽ phụ trách tổng những khách hàng chưa phân cho nhân viên cụ thể
        
        Khi nhấn vào nhân viên thì sẽ hiện ra các khách hàng mà nhân viên đó phụ trách
        
        gọi hàm selectEmployee
        
        gọi hàm getChatList(user_id)
        
        để lấy danh sách single chat mà employee đó quản lý
        
        danh sách trả về có mảng unseenMessages chứa các id của message chưa đọc seen false
        
        gọi hàm findManyByMainUserEmployeeInChargeId để lấy danh sách group chat mà đc quản lý bởi employee đc click vào
      - rê chuột vào tin nhắn của khách hàng để hiện nút ai
        
        khi click vào nút này thì kích hoạt hàm mutation_request_AI_answer
        
        Để yêu cầu AI phản hồi cầu nói đó của khách hàng
        
        gọi hàm request_AI_answer
        
        /aichat/request_AI_answer
      - chỉ định khách hàng cho employee phụ trách
        
        tạo select cho chọn các employee để lấy user_id của empoyee đó
        
        mỗi lần chọn gọi hàm handleChangeEmployeeAssign_user_id
        
        hàm này sẽ update cái user_id_employee_real có giá trị user_id của emp được chọn
      - employee nhập vào ô input để gửi message đến customer trong ô chat bên tay phải
        
        mục đích :
        
        gửi tin nhắn này lên OA cho customer thấy
        
        sau đó listen từ webhook có sự kiện oa_send_text và sẽ lưu vào bảng ZaloChat
      - Nhận tin nhắn từ zalo server gửi về từ webhook zalo thông qua websocket của nestjs
        
        websocket
        
        useeffect
        
        socket.emit('register_Chat_SocketId'
        
        Kết nối với BE thông qua socket.id
      - Nhấn vào single chat nào thì gọi hàm selectChatSingle
        
        mục đích là lấy tất cả đoạn chat của khách hàng đc lick vào
        
        zalochat/chatsingle
      - Nhấn vào group chat nào thì gọi hàm selectGroup, chỉ mới bật màu xanh, chưa hiện các message của group đó
- - - - Nếu step 2 thì tìm trong NganhHang
        
        tìm nằm ở bảng NganhHang, tức đây là lần chọn thứ 2 của họ
        
        tìm tên trong bảng NganhHang
        
        nếu có thì lấy ra id của nganhhang đó
        
        Tìm nganhHangId trong bảng sanphamTen, để trả ra các sản phẩm thuộc ngành hàng id đó
        
        render ra cho khách hàng chọn số theo tên, và cho qua step 3
      - Nếu step 1 thì tìm trong tên trongNganhHangOng
        
        Khi tìm được tên thì sẽ có được type
        
        thì tìm tiếp là type của nó là gì trong NganhHangOng
        
        nếu typesp là general thì tìm nganhHangId trong NganhHang
        
        từ nganhHangId tìm ra sanPhamTen
        
        trả ra các sản phẩm tên theo nganhHangId cho khách hàng chọn, cho qua step 3 luôn ___,
        
        bỏ qua step 2 vì các ngành hàng general không có nhóm lại, mà sau nó chỉ co sanphamong, và sanphamTen, các ngành hàng có type là cuc hay ecp hay ts thì mới có nhóm nên mới có step 2
        
        Nếu là typesp là cua, ts, hay ecp thì tìm type trong nganhhang để hiện ra cho khách hàng chọn tiếp, message trả ra có đánh dấu ,__ tức là đã chuyển qua step 2
      - step 3: tìm tên trong sanphamOng
        
        Tìm tenduocchon trong sanphamOng, đây là step số 3
        
        render ra cho khách hàng chọn, và chuyển qua step 4, đặt hàng hay không
        
        Nếu đặt hàng đúng thì thông báo đã ghi nhận đơn hàng và cập nhật vào bảng order
        
        nếu đặt hàng sai thì render previous message cho đặt hàng lại
        
        hoặc cho back lại
- - - - trong prompt có chứa chữ "gia" không => isHoiBaoGia
      - trong prompt có chứa chữ "ecp","re" không => isHoiGiaRe
      - trong prompt có chứa chữ 'ts','thuy san' => isThuySan
      - có chứa từ thuế hay giao hàng hay thanh toán
        
        không
        
        có chứa tên sản phẩm không
        
        Không
        
        thì trả ra câu answer sẵn , là chúng tôi có các sản phẩm sau => responses.baogia_begin
        
        có
        
        isCua && isHoanThien
        
        BGCuaHoanThien + BGCuaHoanThien2
        
        có
        
        thì return ra các câu trả lời sẵn về các chủ đề thuế hay giao hàng hay thanh toán
        
        responses.tax
        
        responses.delivery
        
        responses.thanhtoan
- - - - ExcelServices
        
        processFilesAndSheets
        
        phải có file fileSheetsMapping
        
        Chứa các fileId và sheetName của mỗi file excel đặt trên google drive
        
        loop qua quá file và đọc từng file và sheet name thông qua các hàm thiết kế cho từng file
        
        Tạo sẵn các file json và import vào, sau đó đọc từng sheet ra và dùng các hàm convert để đổ vào file json cho đúng
  - - - trước khi chạy thì dùng hàm clearTable để xóa hết dữ liệu 3 bảng NganhHangOng, NganhHang, SanPhamOng để làm lại từ đầu
        
        loop through các file json
        
        Lấy ra ngành hàng Nếu ngành hàng là cửa hay, ecp, hay ts hay "" tì phân ra thành các loại tương ứng theo type và đổ vào bảng NganhHangOng
        
        sau đó đổ hết vào bảng NganhHang
        
        các sản phẩm theo id của NganhHang thì đổ vào SanPhamOng
        
        Tóm lại NganhHangOng chứa 4 nhóm hàng chính là cửa, ts, ecp và general
        
        NganhHang chứa tất cả ngành hàng, hiện ra tất cả cửa và ecp và thủy sản
        
        sanPhamOng chứa tất cả sản phẩm và có nganhHangId
  - - - truyền vào fileId và sheetName trên post man để gọi hàm này,
        
        gọi hàm excelService.readExcelFromGoogleDriveTest(fileId, sheetName)
        
        ExcelServices
        
        readExcelFromGoogleDriveTest(fileId: string, sheetName: string)
        
        Đọc file và đổ kết quả vào file test.json trong folder cache
  - - - Lấy tên và nganhHangId unique
        
        sanphamongService.getUniqueTenAndNganhHangId()
      - Sau đó đổ vào bảng SanPhamTen
        
        this.sanphamtenService.createMany(result)