欢迎语间隔时间

pcloud-service-book/src/main/java/com/pcloud/book/pcloudkeyword/biz/impl/PcloudRobotBizImpl.java

@@ -27,6 +27,7 @@ import com.pcloud.book.pcloudkeyword.entity.PcloudTd;
 import com.pcloud.book.pcloudkeyword.entity.PcloudTdRecord;
 import com.pcloud.book.pcloudkeyword.enums.WelcomeReplyTypeEnum;
 import com.pcloud.book.push.biz.SelfPushBiz;
+import com.pcloud.book.util.common.ThreadPoolUtils;
 import com.pcloud.common.core.aspect.ParamLog;
 import com.pcloud.common.page.PageBeanNew;
 import com.pcloud.common.page.PageParam;
@@ -42,6 +43,8 @@ import com.sdk.wxgroup.SendMessageTypeEnum;
 import com.sdk.wxgroup.SendPicMessageVO;
 import com.sdk.wxgroup.SendTextMessageVO;
 import com.sdk.wxgroup.WxGroupSDK;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
@@ -57,6 +60,9 @@ import java.util.stream.Collectors;
 @Component("pcloudRobotBiz")
 public class PcloudRobotBizImpl implements PcloudRobotBiz {
 
+    private static final Logger LOGGER = LoggerFactory.getLogger(PcloudRobotBizImpl.class);
+
+
     @Autowired
     private PcloudRobotDao pcloudRobotDao;
     @Autowired
@@ -182,53 +188,61 @@ public class PcloudRobotBizImpl implements PcloudRobotBiz {
 
     @Override
     public void sendWelcomeReply(String robotWxId, String userWxId, String ip) {
-        Map<String, Object> map = new HashMap<>();
-        map.put("robotWxId", robotWxId);
-        PcloudRobot pcloudRobot = (PcloudRobot)pcloudRobotDao.getBy(map, "getByRobotWxId");
-        if(pcloudRobot != null) {
-            List<PcloudRobotWelcome> robotWelcomeList = pcloudRobotWelcomeDao.getRobotWelcomeListByPcloudRobotId(pcloudRobot.getId());
-            fillRobotWelcome(robotWelcomeList);
-            for (PcloudRobotWelcome robotWelcome : robotWelcomeList) {
-                Integer replyType = robotWelcome.getReplyType();
-                if(WelcomeReplyTypeEnum.TEXT.value.equals(replyType)) {
-                    SendTextMessageVO sendTextMessageVO = new SendTextMessageVO();
-                    sendTextMessageVO.setContent(robotWelcome.getContent());
-                    sendTextMessageVO.setAltId(robotWxId);
-                    sendTextMessageVO.setWxGroupId(userWxId);
-                    sendTextMessageVO.setIp(ip);
-                    sendTextMessageVO.setCode(SendMessageTypeEnum.SELF.getCode());
-                    WxGroupSDK.sendTextMessage(sendTextMessageVO);
-                } else if(WelcomeReplyTypeEnum.IMAGE.value.equals(replyType)) {
-                    SendPicMessageVO sendPicMessageVO = new SendPicMessageVO();
-                    sendPicMessageVO.setWxGroupId(userWxId);
-                    sendPicMessageVO.setAltId(robotWxId);
-                    sendPicMessageVO.setPicUrl(robotWelcome.getPicUrl());
-                    sendPicMessageVO.setIp(ip);
-                    sendPicMessageVO.setCode(SendMessageTypeEnum.SELF.getCode());
-                    WxGroupSDK.sendPicMessage(sendPicMessageVO);
-                } else if(WelcomeReplyTypeEnum.RESOURCE.value.equals(replyType)) {
-                    SendFileVO sendFileVO = new SendFileVO();
-                    sendFileVO.setFileUrl(robotWelcome.getResourceUrl());
-                    sendFileVO.setFileName(robotWelcome.getResourceName());
-                    sendFileVO.setIp(ip);
-                    sendFileVO.setAltId(robotWxId);
-                    sendFileVO.setWxId(userWxId);
-                    sendFileVO.setCode(SendMessageTypeEnum.SELF.getCode());
-                    WxGroupSDK.sendFile(sendFileVO);
+        ThreadPoolUtils.OTHER_THREAD_POOL.execute(() -> {
+            Map<String, Object> map = new HashMap<>();
+            map.put("robotWxId", robotWxId);
+            PcloudRobot pcloudRobot = (PcloudRobot)pcloudRobotDao.getBy(map, "getByRobotWxId");
+            if(pcloudRobot != null) {
+                Integer welcomeDuration = pcloudRobot.getWelcomeDuration() == null ? 3 : pcloudRobot.getWelcomeDuration();
+                List<PcloudRobotWelcome> robotWelcomeList = pcloudRobotWelcomeDao.getRobotWelcomeListByPcloudRobotId(pcloudRobot.getId());
+                fillRobotWelcome(robotWelcomeList);
+                for (PcloudRobotWelcome robotWelcome : robotWelcomeList) {
+                    try {
+                        Thread.sleep(1000 * welcomeDuration);
+                    } catch (InterruptedException e) {
+                        LOGGER.error("线程睡眠出错==", e);
+                    }
+                    Integer replyType = robotWelcome.getReplyType();
+                    if(WelcomeReplyTypeEnum.TEXT.value.equals(replyType)) {
+                        SendTextMessageVO sendTextMessageVO = new SendTextMessageVO();
+                        sendTextMessageVO.setContent(robotWelcome.getContent());
+                        sendTextMessageVO.setAltId(robotWxId);
+                        sendTextMessageVO.setWxGroupId(userWxId);
+                        sendTextMessageVO.setIp(ip);
+                        sendTextMessageVO.setCode(SendMessageTypeEnum.SELF.getCode());
+                        WxGroupSDK.sendTextMessage(sendTextMessageVO);
+                    } else if(WelcomeReplyTypeEnum.IMAGE.value.equals(replyType)) {
+                        SendPicMessageVO sendPicMessageVO = new SendPicMessageVO();
+                        sendPicMessageVO.setWxGroupId(userWxId);
+                        sendPicMessageVO.setAltId(robotWxId);
+                        sendPicMessageVO.setPicUrl(robotWelcome.getPicUrl());
+                        sendPicMessageVO.setIp(ip);
+                        sendPicMessageVO.setCode(SendMessageTypeEnum.SELF.getCode());
+                        WxGroupSDK.sendPicMessage(sendPicMessageVO);
+                    } else if(WelcomeReplyTypeEnum.RESOURCE.value.equals(replyType)) {
+                        SendFileVO sendFileVO = new SendFileVO();
+                        sendFileVO.setFileUrl(robotWelcome.getResourceUrl());
+                        sendFileVO.setFileName(robotWelcome.getResourceName());
+                        sendFileVO.setIp(ip);
+                        sendFileVO.setAltId(robotWxId);
+                        sendFileVO.setWxId(userWxId);
+                        sendFileVO.setCode(SendMessageTypeEnum.SELF.getCode());
+                        WxGroupSDK.sendFile(sendFileVO);
+                    }
                 }
+                //发送H5链接
+                String endUrl = wechatLinkPrefix + "/dialog" + "?book_group_id=" + 0 + "&wxId=" + userWxId + "&robotWxId=" + robotWxId;
+                String resultUrl = UrlUtils.getShortUrl4Own(endUrl);
+                String h5Content = "你可以通过点击" + resultUrl + "，或者输入【】内关键词唤醒我\n" + "小睿会在这里时时陪伴你";
+                SendTextMessageVO sendTextMessageVO = new SendTextMessageVO();
+                sendTextMessageVO.setContent(h5Content);
+                sendTextMessageVO.setAltId(robotWxId);
+                sendTextMessageVO.setWxGroupId(userWxId);
+                sendTextMessageVO.setIp(ip);
+                sendTextMessageVO.setCode(SendMessageTypeEnum.SELF.getCode());
+                WxGroupSDK.sendTextMessage(sendTextMessageVO);
             }
-            //发送H5链接
-            String endUrl = wechatLinkPrefix + "/dialog" + "?book_group_id=" + 0 + "&wxId=" + userWxId + "&robotWxId=" + robotWxId;
-            String resultUrl = UrlUtils.getShortUrl4Own(endUrl);
-            String h5Content = "你可以通过点击" + resultUrl + "，或者输入【】内关键词唤醒我\n" + "小睿会在这里时时陪伴你";
-            SendTextMessageVO sendTextMessageVO = new SendTextMessageVO();
-            sendTextMessageVO.setContent(h5Content);
-            sendTextMessageVO.setAltId(robotWxId);
-            sendTextMessageVO.setWxGroupId(userWxId);
-            sendTextMessageVO.setIp(ip);
-            sendTextMessageVO.setCode(SendMessageTypeEnum.SELF.getCode());
-            WxGroupSDK.sendTextMessage(sendTextMessageVO);
-        }
+        });
     }
 
     @Override

pcloud-service-book/src/main/java/com/pcloud/book/pcloudkeyword/entity/PcloudRobot.java

@@ -55,4 +55,7 @@ public class PcloudRobot extends BaseEntity {
 
     @ApiModelProperty("编号")
     private String uniqueNumber;
+
+    @ApiModelProperty("欢迎语间隔时长")
+    private Integer welcomeDuration;
 }

pcloud-service-book/src/main/resources/mapper/pcloudkeyword/PcloudRobot.Mapper.xml

@@ -12,9 +12,10 @@
     <result column="state" property="state" jdbcType="INTEGER" />
       <result column="wake_up" property="wakeUp" jdbcType="INTEGER" />
     <result column="unique_number" property="uniqueNumber" jdbcType="VARCHAR"/>
+      <result column="welcome_duration" property="welcomeDuration" jdbcType="INTEGER" />
   </resultMap>
   <sql id="Base_Column_List" >
-    id, wx_id, nick_name, head, qrcode_url, robot_type, keyword_classify_id, state, wake_up, unique_number
+    id, wx_id, nick_name, head, qrcode_url, robot_type, keyword_classify_id, state, wake_up, unique_number,welcome_duration
   </sql>
 
   <insert id="insert" parameterType="PcloudRobot" useGeneratedKeys="true" keyProperty="id">
@@ -27,7 +28,8 @@
         keyword_classify_id,
         state,
         wake_up,
-        unique_number
+        unique_number,
+        welcome_duration
       )
     values (
       #{wxId,jdbcType=VARCHAR},
@@ -38,7 +40,8 @@
       #{keywordClassifyId,jdbcType=BIGINT},
       #{state,jdbcType=INTEGER},
       #{wakeUp,jdbcType=INTEGER},
-      #{uniqueNumber, jdbcType=VARCHAR}
+      #{uniqueNumber, jdbcType=VARCHAR},
+      #{welcomeDuration, jdbcType=INTEGER}
       )
   </insert>
 
@@ -72,6 +75,9 @@
             <if test="uniqueNumber != null">
                 unique_number = #{uniqueNumber, jdbcType=VARCHAR},
             </if>
+            <if test="welcomeDuration != null">
+                welcome_duration = #{welcomeDuration,jdbcType=INTEGER},
+            </if>
         </set>
         where id = #{id,jdbcType=INTEGER}
     </update>
@@ -98,6 +104,7 @@
         r.keyword_classify_id keywordClassifyId,
         r.state state,
         r.unique_number uniqueNumber,
+        r.welcome_duration welcomeDuration,
         rc.classify_name classifyName
         FROM
             pcloud_robot r