From 625ba344010b4efa42984980628393a44cb8240e Mon Sep 17 00:00:00 2001
From: Hai Liang Wang <hain@chatopera.com>
Date: Thu, 5 Aug 2021 20:45:13 +0800
Subject: [PATCH] https://github.com/chatopera/cskefu/issues/455 Fix session
 time period, upgrade chatopera sdk

---
 .../com/chatopera/cc/basic/Constants.java     |   3 ++
 .../com/chatopera/cc/model/FbMessenger.java   |  19 +++++++++
 .../resources/static/images/messenger.png     | Bin 0 -> 3898 bytes
 .../config/sql/cosinee-MySQL-slim.sql         |   4 +-
 ...009.alter_uk_agentservice_sessiontimes.sql |   6 +++
 .../009.alter_uk_agentuser_sessiontimes.sql   |   6 +++
 contact-center/root/pom.xml                   |   2 +-
 .../chatbot/classes/ChatbotConstants.java     |   2 +
 .../classes/ChatbotEventSubscription.java     |  39 ++++++++++++++----
 9 files changed, 71 insertions(+), 10 deletions(-)
 create mode 100644 contact-center/app/src/main/resources/static/images/messenger.png
 create mode 100644 contact-center/config/sql/upgrade/009.alter_uk_agentservice_sessiontimes.sql
 create mode 100644 contact-center/config/sql/upgrade/009.alter_uk_agentuser_sessiontimes.sql

diff --git a/contact-center/app/src/main/java/com/chatopera/cc/basic/Constants.java b/contact-center/app/src/main/java/com/chatopera/cc/basic/Constants.java
index b3d6ab65..f9f00b19 100644
--- a/contact-center/app/src/main/java/com/chatopera/cc/basic/Constants.java
+++ b/contact-center/app/src/main/java/com/chatopera/cc/basic/Constants.java
@@ -131,6 +131,9 @@ public class Constants {
     public static final String AUDIT_AGENT_MESSAGE = "cskefu.agent.audit";
     // 机器人返回的结果数据来源为faq
     public final static String PROVIDER_FAQ = "faq";
+    public final static String PROVIDER_FEEDBACK = "feedback";
+    public final static String PROVIDER_FEEDBACK_EVAL_POSITIVE = "positive";
+    public final static String PROVIDER_FEEDBACK_EVAL_NEGATIVE = "negative";
 
     // Facebook OTN 发送
     public final static String INSTANT_MESSAGING_MQ_QUEUE_FACEBOOK_OTN = "cskefu.outbound.faceboot.otn";
diff --git a/contact-center/app/src/main/java/com/chatopera/cc/model/FbMessenger.java b/contact-center/app/src/main/java/com/chatopera/cc/model/FbMessenger.java
index e735f4ea..ab2f3715 100644
--- a/contact-center/app/src/main/java/com/chatopera/cc/model/FbMessenger.java
+++ b/contact-center/app/src/main/java/com/chatopera/cc/model/FbMessenger.java
@@ -16,11 +16,14 @@
 
 package com.chatopera.cc.model;
 
+import com.alibaba.fastjson.JSONObject;
+import org.apache.commons.lang.StringUtils;
 import org.hibernate.annotations.GenericGenerator;
 
 import javax.persistence.*;
 import java.io.Serializable;
 import java.util.Date;
+import java.util.Map;
 
 @Entity
 @Table(name = "cs_fb_messenger")
@@ -151,7 +154,23 @@ public class FbMessenger implements Serializable {
         return config;
     }
 
+    /**
+     * Get config as map object
+     *
+     * @return
+     */
+    public Map<String, String> parseConfigMap() {
+        Map<String, String> configMap = (Map<String, String>) JSONObject.parse(StringUtils.isNotBlank(getConfig()) ? getConfig() : "{}");
+        return configMap;
+    }
+
     public void setConfig(String config) {
         this.config = config;
     }
+
+    public <K, V> void setConfigMap(Map<K, V> config) {
+        String data = JSONObject.toJSONString(config);
+        this.config = data;
+    }
+
 }
diff --git a/contact-center/app/src/main/resources/static/images/messenger.png b/contact-center/app/src/main/resources/static/images/messenger.png
new file mode 100644
index 0000000000000000000000000000000000000000..00082f03d1cc6d2d0be3a28c2b32859563cf7cb7
GIT binary patch
literal 3898
zcmY*ccRZVG*iK^a6`N9<A}A^mqiu}XBt}spp@Jqx%tJNyZfmyoirN)Q)z+38ZOtmB
zTdA5y)jFy^diwQz-}C<N_qv|@x$f(J?)Sep$;!frjai5p006KdjS)7-2tNr%`r|k3
z$LoM&0FrEsE&%S0h<rWX#CkX&ub7(y6plF~fDXtFpgEBoKLDT*fbJIu08D_wf4B`$
z?zaX603>(;Xn$)QkMU#~AIEX^Z=@*!{^wW%`lE)I(EP_w%0d@nU5|mu&-fAv0AS%c
z2_PV^K;YQzk{8+`(81gchVvyTySe*fJ(NQUekWA`cqr_c5<CLk#6t;Ji6mI4j>Ino
z?3kaVArj)hB!NCU5)S58;un1bJj6AXRg_gEbeYA)#o+<&S70^>!{6n{I~@spV4xoi
z0tpETQ4Tq)>>J<-QH4UG5EV6unwrwFLWvYc40H=sB9bKkHThp3ga-*1;N=(S<x3Pl
z@pZ%c1_kO!NSrkKv;Mtjpx2fEIuS{~$2uMma&iJuRaSxg@jfnvpJZW{0bU-*olpFA
zRpGys|1bBu4;*sR{Qq3$-${REk4M#IhC}{*HeF^xmyZkp0P8XmaUPAQdz;UaT4=yK
zF#2YI7-D)lxesiDFju-Prtyk`IA4NkraYCQ^ohs4#K+;&$h^sG>u(=mgq8AyP|ONk
zsY2eInPrH6x$%FJ$=NxYKHg|K&BT_hVAqh1y@Sy=8@j<8>s=um6RWWNjf2JT=g;?x
zrwgE@=}WcJUr>SRO$E>FgR-}_9$x1k(0)D_agRUm{xquC{LqX&`*v7xhNn@r80FnS
zkk~-x_g#_cfT4ZXb96=g!yNeyZHxI}C&nc%)44997CfmJQq~Ou*z5lQJp(Df;2Axw
zW~8u;cFWu>jPuQC?-pb?)9ULOXbX>>50NhMiFh?qQHcZ<(_%KRrg@m?PaoU|?)WFV
zzG&>76}N1<@$D3_?gMi(%k?1*-O0l4M0=e{du-I_YFuJDCP8aGf$KdL(tbM>EAwI3
z8_a*e!Ld@DN7Fe`NoaNN7jHe7o>A=Jwef9Y4_E4AbO#1VmxEi->3jd6Q-5Aywc?0g
zrr86VX{@v!jeW5Yrmj7h5{*e2vHP|_tW*_NNTYd2XQX$@=KZMtpdq<?gkErf;bFDD
z^Tj8c`_}GdcXC^TXLsg$s(lUXLt={*ylN+dXvk;Kd+d6*Pxs&oAApsg$s`Cm*eS5U
zMGd&c-1-z}J%WcLfppWaFR#ZL+D2e6=wL|t8Mxv71y&M(9nxRHT7ETszLKL(K;i6A
ze4{}Op3A&UX>8DG9DZK#$YWy6tpVB-b>kevilWM`FGLuaL8*!Obw))dhvZ~JHV8?x
z5%!awIn|Rnv|#vB7Df+E|B5cVCVVBwaBIEMC1es&;#2#bSj{f7yy;q6F1*IOC)=R?
zwl{gR4B4DyIIfUq(4q2D4kzXv*+GBq{hIH^rs94{6M~w95rI%O{?+Tc)GVSL&-<e6
zvOuf{x|*I#h9rV+I8uoSml|wQvl5sJoqa0<G~?ToL`3MU8;ytaSE3k|Y1q%xIqyeb
zr|E?0XO5`QnHgymB~CVZnP<~=TD)stwb%_YrH<dLoA9M8GRZN%!iUiq7*VH|xvHlG
zyK(Ym(+W>9I-KF6n}=Q(CC#ZtC&QhE%8yDn&9stE&fSt{z`3Rs8rBJI57^e>DX<<U
zcKM}Zmr2X}sX5-2`_JawtdwchpK)$D4DdzquA=&$g0#=thN)lVp5l{nLjipP9XT4A
zVdTI`#g|87lzg%!1&+P;uput5ri@JwXJ0nlaB9Z=h43VR35xQc!d~F<T;r~Qb5ofl
zr9r{L1Z1PnxxybPE~yM~JLO5JQUxA#8e3vRBlr)hhwj3SP5qRiZ-$SJk*{BL$1L8)
zwT)M-d_`wVagGUT`ikL}4iaPg+!s`3oUqCsnr+#ghbi;n<Rt${cSKN6MnGS18};rg
zD>p$<yEtC;Zq3h#Zy`d?v4H@;!B=xKA$mmtY#)2e;V6kJ=$IpespH!DdnSi(U%X|0
z>hL`CtbqBlj@<~ecAUAuqdd@2hDv8*?G&czmH~$03G0j|ndqSlHZJcj@a*vx2+S&4
zL@OPj+#OEQ%tm19=7(CDRNjHakve&v0+dhSel2d5XxlR-aUv+EW{WgT4}I?(uvUHD
zig8nYf-79lZkHjk(0C$aMx|sT;&$myI7SJ#-<o=gog@;=#DXbOm!{=)9)NJ+Za<u$
z8*uNzO}YJ8obTaE7ac4sX2p%9A4pKY$~U2hG!24=Ewnno*y2+(u)JtHeDdObGTh8{
zdUD!8<R)D)O5FEte3s-)6?7g2ZtTzcFqfqUg*XhnR6L3YrB|+Y7=Pl4igz)rdaf(y
zCU)^P@SSsX^16{t5~W-=mu@WjkU#tg4qaktJYu-$n#@1aT>N;<pgGfhCC2umTPA~_
zroDoW?B6{>OdNC_tF2-*JLN)^Rl~T-Qne-fy=APi9$3G%G*6=befMyXu6_?#t-^o$
z5#x=>K>_}Aim&x)W!*AOVt9kL0%o@f;$F@NFff|byW<F<mDjY)anDFj=KEZ3+Vs<9
zWAwaT&*C=FxPx~pJ1wt%do5T~hCAknK>)}59PivznpuN#5n1~(E^<T5$F9qF>581O
z(azEgmdhdPjky!FmKN{l{ORmQri9b0*6D}*Ys4dqj{c;ahqZpvCSBZqs#DE8L-&|p
z+f0`T$>NrT7HYSw;wMe_9zo?Y7`;aPht3a8vVT(5Ub_~YFAQ)O4p5*9--1N{WIXh4
znc%U7v!dvg;u8fywJVW$PRSc|hH?!L3cIrr1wS%u4W)IqcABIjSg(fyrA!{D@tf-q
zv~Hh15Wd#QPnEr8V}vw;9uZ-4(Tx$}gHm5~N=Rhvn&{$-Zw@w>!bk(Q(l8BZs|agX
z1*7I$@U?|^<*^GzU81t%>(|L9E@_fupWoh5V!0|q)=9piD3kUrqWXyKXIke<RMNTF
zcl0st@L13B*wJ*)SzXvD+Pl^SJN-6N$-9##CUY(2&0=#y4GM1+tBDU+=g@oYZXXtZ
z+ud@apI4gdba+X{SGb16>35Dcjmtr`v3GnF>f<U?{;>UFrfRUs_^I@lZF3FL`cc^<
zEzFu1_-#B#P0B`TPbJ4}+rl_XSl^%FiO3D=I3%x9Zff8MMFBbqwf<5?dfsMPHxix<
z=Uz+E9I)O<s1M*#tPVM--CvCQkRoXy(X!3mxJGi9A7zLRey<&aeu@(9e=7LF@Qf4f
zqXY3Df62WDjO|DDMsO{KUX$Cir@u4|#oDWm{*)sB<k`)*I^x<tXY@qCku{ZHY^&^}
z#3+S}h1!8(DZl)EZ@^#CGz^R?z=codsl`RJ2Xv=4fallCUSOB~`BfKtmrW(te@e42
z*$C_+1c>E5vAV@_YB)ITsg2!6($mSuxWt*RX{98EFPEYyKt(15gUh;%^_eJ*j!Ya|
zI~5ioD4Nkdm?QkMy1&35E2MX^#+QSr<e`_4i!Hia{ItNcu=KGHq0R^RiEwkhJoend
z{@_(T8ijaUal4&FF6xMp)|IUgyT1$kxqafO@Ny3_zfMH_oya>KhMvjfyCd@PHjgtB
z(l0;g->$eoxj()Q+;Kxd_|OUDXow7jaek6)3*ek;<)xOPF-A+foqkoi*%*yzDr08p
zBeFrhO}1vM<ln71<+u9!>jlzUnANQ~EmVi>N?aS&pT1dWMOkOQPcJ316$S~0dBp`Y
ze<u+k5V6Pe!<Al+)ymf6&uUx_A7pE*c4chVf43!`VSTI?y+{o1k$<|{uTE&%{j_?;
zd6Eh6jH#cg>P^2{O;RwS75}13ne$#ht8{=}W8H=J0&URqAPoXEQt#}Dn(pCJKhN;u
zn~&uBy~(>x3jIlX1}an*$d7A6#=|c>_$nE+v9Ao063y3F0??<c<R|Rtoso68B2lU?
zh=o8+Yxy$lTZy{doV*x$!0_GGDW%!FSM`2LJ<6c(nO7tT>gh>~hsuw`1j=GLW;KmE
z?^WRahb|#p=T>A)o6RG+iVj-;uA^D7yW6;#Si=|YTJLGy<oIZNKKmWbU}Y_z4DY<1
zsaDwOaK0ttt|z5~b__zFpL6z(g|uPRaHV`<xcZm^wM=I}_p{tzJ~Xe4K=smdS9bZ=
z+pTyPq9={R{vz{<{-c4BMYA=j;APXK95Xex<w}MKglvm<%XxLE>~5&V0|f$qY-xsk
z{kOSE>zk^bpZo}&OZ=gsSSM4FuQBe@RZPQs+!jJe4RDhD(4tlT9oE`n1>;%EDO-Jy
z+GLs*N!90NxEbBpu1FY}H!Y|)IqM(tw(zabyMvDOMHW>^S_p?Cj@!zn{^8vYhdxEX
zYSD+JY=9ZQ?#YKmKF~PQ>`lehGc|>FXB@qdGTY`xT{VTT8j#_H0PoFvJwR4(a<Q^@
zuynwBLsX(oFbSKX@LrSQVbj7)`zQN~mG82jTA0(M@A?euQ|ytHd+mHO6PkzeX<2po
zS&bst>9MWaUN~mE1J4Uw`&cNveN+15LSN-8ppn<-)94;M%Tl5x-6!~0v4Jc*YS^B2
z*LX4IRPO2ajP~AVyI-tdx|LBn57RrkB92TcVYmKL1S#0Xbya_MBTWwhZ{&!1RACTX
zAIM#R8FNmOWfCpd9kw3j(6gh9=a-%J@lHmiT{77`&X${I`)j&0-$XFQl{XPTRTvId
z+0<_8dySdoihKaMSKP`c@6faqN8D%8KAdGs9r}(lKniH{Y%(?o!Mu8qbKY2!H)+PH
z<)w=}*ItTXh7bXSFP2iQGw0fNGE$E`1*BpraCvhMV_Ale?m{4P8!$F^qDdhIiq^aB
z(xJuf_gO20P3zj({t9UC4RBEaLUstiSC>DySgn7Pybh`o*7?fA%Gmo{!5C@46MpkL
mCr4Wu;`$vv2j7vBZ+a`KUofPa{FDD*0Mft$aqj{q`hNhT^}w9~

literal 0
HcmV?d00001

diff --git a/contact-center/config/sql/cosinee-MySQL-slim.sql b/contact-center/config/sql/cosinee-MySQL-slim.sql
index 18c00c62..43348643 100644
--- a/contact-center/config/sql/cosinee-MySQL-slim.sql
+++ b/contact-center/config/sql/cosinee-MySQL-slim.sql
@@ -529,7 +529,7 @@ CREATE TABLE `uk_agentservice` (
   `ipaddr` varchar(50) DEFAULT NULL COMMENT 'IP地址',
   `osname` varchar(100) DEFAULT NULL COMMENT '操作系统名称',
   `browser` varchar(100) DEFAULT NULL COMMENT '浏览器',
-  `sessiontimes` int(20) DEFAULT NULL COMMENT '会话时长',
+  `sessiontimes` bigint(64) DEFAULT NULL COMMENT '会话时长',
   `servicetime` datetime DEFAULT NULL COMMENT '服务时长',
   `region` varchar(255) DEFAULT NULL COMMENT '区域',
   `agentusername` varchar(50) DEFAULT NULL COMMENT '坐席用户名',
@@ -666,7 +666,7 @@ CREATE TABLE `uk_agentuser` (
   `ipaddr` varchar(50) DEFAULT NULL COMMENT 'IP地址',
   `osname` varchar(100) DEFAULT NULL COMMENT '操作系统名称',
   `browser` varchar(100) DEFAULT NULL COMMENT '浏览器',
-  `sessiontimes` int(20) DEFAULT NULL COMMENT '会话时长',
+  `sessiontimes` bigint(64) DEFAULT NULL COMMENT '会话时长',
   `servicetime` datetime DEFAULT NULL COMMENT '服务次数',
   `region` varchar(255) DEFAULT NULL COMMENT '地区',
   `agentservice` varchar(32) DEFAULT NULL COMMENT '服务ID',
diff --git a/contact-center/config/sql/upgrade/009.alter_uk_agentservice_sessiontimes.sql b/contact-center/config/sql/upgrade/009.alter_uk_agentservice_sessiontimes.sql
new file mode 100644
index 00000000..420c4bc4
--- /dev/null
+++ b/contact-center/config/sql/upgrade/009.alter_uk_agentservice_sessiontimes.sql
@@ -0,0 +1,6 @@
+USE `cosinee`;
+-- -----------------
+-- prepare variables
+-- -----------------
+
+ALTER TABLE `uk_agentservice` MODIFY COLUMN  `sessiontimes` BIGINT(64) NULL DEFAULT NULL COMMENT '会话时长';
diff --git a/contact-center/config/sql/upgrade/009.alter_uk_agentuser_sessiontimes.sql b/contact-center/config/sql/upgrade/009.alter_uk_agentuser_sessiontimes.sql
new file mode 100644
index 00000000..13904372
--- /dev/null
+++ b/contact-center/config/sql/upgrade/009.alter_uk_agentuser_sessiontimes.sql
@@ -0,0 +1,6 @@
+USE `cosinee`;
+-- -----------------
+-- prepare variables
+-- -----------------
+
+ALTER TABLE `uk_agentuser` MODIFY COLUMN  `sessiontimes` BIGINT(64) NULL DEFAULT NULL COMMENT '会话时长';
diff --git a/contact-center/root/pom.xml b/contact-center/root/pom.xml
index 0cdd8a07..d9b2668c 100644
--- a/contact-center/root/pom.xml
+++ b/contact-center/root/pom.xml
@@ -375,7 +375,7 @@
         <dependency>
             <groupId>com.chatopera.bot</groupId>
             <artifactId>sdk</artifactId>
-            <version>3.3.2</version>
+            <version>3.5.0</version>
         </dependency>
     </dependencies>
     <repositories>
diff --git a/public/plugins/chatbot/classes/ChatbotConstants.java b/public/plugins/chatbot/classes/ChatbotConstants.java
index 1cfd6222..3011a1f2 100644
--- a/public/plugins/chatbot/classes/ChatbotConstants.java
+++ b/public/plugins/chatbot/classes/ChatbotConstants.java
@@ -20,4 +20,6 @@ public class ChatbotConstants {
     public static final String THRESHOLD_FAQ_BEST_REPLY = "BOT_THRESHOLD_FAQ_BEST_REPLY";
     public static final String THRESHOLD_FAQ_SUGG_REPLY = "BOT_THRESHOLD_FAQ_SUGG_REPLY";
     public static final String DEFAULT_BOT_PROVIDER = "https://bot.chatopera.com";
+    public static final String PROVIDER_FEEDBACK_EVAL_POSITIVE_REPLY_PLACEHOLDER = "${evaluationYesReply}";
+    public static final String PROVIDER_FEEDBACK_EVAL_NEGATIVE_REPLY_PLACEHOLDER = "${evaluationNoReply}";
 }
diff --git a/public/plugins/chatbot/classes/ChatbotEventSubscription.java b/public/plugins/chatbot/classes/ChatbotEventSubscription.java
index e405f087..c421056f 100644
--- a/public/plugins/chatbot/classes/ChatbotEventSubscription.java
+++ b/public/plugins/chatbot/classes/ChatbotEventSubscription.java
@@ -17,10 +17,10 @@
 package com.chatopera.cc.plugins.chatbot;
 
 import com.chatopera.bot.exception.ChatbotException;
+import com.chatopera.bot.sdk.Response;
 import com.chatopera.cc.basic.Constants;
 import com.chatopera.cc.basic.MainContext;
 import com.chatopera.cc.cache.Cache;
-import com.chatopera.cc.controller.api.request.RestUtils;
 import com.chatopera.cc.model.Chatbot;
 import com.chatopera.cc.persistence.repository.AgentUserRepository;
 import com.chatopera.cc.persistence.repository.ChatMessageRepository;
@@ -105,21 +105,29 @@ public class ChatbotEventSubscription {
         // Get response from Conversational Engine.
         com.chatopera.bot.sdk.Chatbot bot = new com.chatopera.bot.sdk.Chatbot(
                 c.getClientId(), c.getSecret(), botServiceProvider);
-        JSONObject result = bot.conversation(
-                request.getUserid(), request.getMessage(), faqBestReplyThreshold, faqSuggReplyThreshold);
+
+
+        JSONObject body = new JSONObject();
+        body.put("fromUserId", request.getUserid());
+        body.put("textMessage", request.getMessage());
+        body.put("faqBestReplyThreshold", faqBestReplyThreshold);
+        body.put("faqSuggReplyThreshold", faqSuggReplyThreshold);
+        Response result = bot.command("POST", "/conversation/query", body);
 
         // parse response
         if (result != null) {
             logger.info("[chat] chat response {}", result.toString());
-            if (result.getInt(RestUtils.RESP_KEY_RC) == 0) {
+            if (result.getRc() == 0) {
                 // reply
-                JSONObject data = result.getJSONObject("data");
+                JSONObject data = (JSONObject) result.getData();
                 if (data.has("logic_is_fallback")) {
                     ChatMessage resp = creatChatMessage(request, c);
                     resp.setMessage(data.getString("string"));
                     ChatMessage respHelp = new ChatMessage();
                     JSONArray respParams = new JSONArray();
                     if (!StringUtils.equals(MainContext.ChannelType.WEBIM.toString(), c.getChannel())) {
+                        // 非 WEBIM 情况，比如 Facebook Messenger，使用下面的方法
+                        // 如果在更多渠道下，此处可能仅适应于 Messenger，那么宜将检测条件调整为 ChannelType.MESSENGER
                         if (data.getBoolean("logic_is_fallback")) {
                             if (!StringUtils.equals(Constants.CHATBOT_HUMAN_FIRST, c.getWorkmode())) {
                                 JSONArray faqReplies = data.getJSONArray("faq");
@@ -157,6 +165,20 @@ public class ChatbotEventSubscription {
                                 message.put("attachment", attachment);
                                 resp.setExpmsg(message.toString());
                             }
+                        } else if (StringUtils.equals(Constants.PROVIDER_FEEDBACK, data.getJSONObject("service").get("provider").toString())) {
+                            respHelp = null;
+                            // 反馈回复内容
+                            String sentiment = data.getJSONObject("service").get("sentiment").toString();
+                            if (StringUtils.equals(Constants.PROVIDER_FEEDBACK_EVAL_POSITIVE, sentiment)) {
+                                // 积极评价
+                                resp.setMessage(ChatbotConstants.PROVIDER_FEEDBACK_EVAL_POSITIVE_REPLY_PLACEHOLDER);
+                            } else if (StringUtils.equals(Constants.PROVIDER_FEEDBACK_EVAL_NEGATIVE, sentiment)) {
+                                // 消极评价
+                                resp.setMessage(ChatbotConstants.PROVIDER_FEEDBACK_EVAL_NEGATIVE_REPLY_PLACEHOLDER);
+                            } else {
+                                // no response
+                                resp.setMessage("${leaveMeAlone}");
+                            }
                         } else if (StringUtils.equals(Constants.PROVIDER_FAQ, data.getJSONObject("service").get("provider").toString())) {
                             if (data.has("params")) {
                                 resp.setMessage(data.getJSONArray("params").getJSONObject(0).getString("content"));
@@ -197,6 +219,7 @@ public class ChatbotEventSubscription {
                             }
                         }
                     } else {
+                        // 当前渠道为 WEBIM
                         if (data.getBoolean("logic_is_fallback")) {
                             // 兜底回复，检查FAQ
                             JSONArray faqReplies = data.getJSONArray("faq");
@@ -221,11 +244,13 @@ public class ChatbotEventSubscription {
 
                     // 更新聊天机器人累计值
                     updateAgentUserWithRespData(request.getUserid(), request.getOrgi(), data);
-                    // 保存并发送
 
+                    // 保存并发送
                     if (MainContext.ChannelType.WEBIM.toString().equals(resp.getChannel())) {
+                        // WEBIM 渠道
                         chatbotProxy.saveAndPublish(resp);
                     } else {
+                        // 其他渠道
                         chatMessageRes.save(resp);
                         if (respParams.length() > 0) {
                             for (int i = 0; i < respParams.length(); i++) {
@@ -244,7 +269,7 @@ public class ChatbotEventSubscription {
                 }
             }
         } else {
-            logger.warn("[chat] can not get expected response {}", result.toString());
+            logger.warn("[chat] can not get expected response rc {}, error {}", result.getRc(), result.getError());
         }
     }