查询ai列表

ch-dao/src/main/java/com/wwdz/ch/db/dao/UserDao.java

@@ -53,7 +53,7 @@ public interface UserDao {
      * @param user
      * @return
      */
-    int insert(User user);
+    long insert(User user);
 
     /**
      * 更新记录

ch-dao/src/main/java/com/wwdz/ch/db/impl/UserDaoImpl.java

@@ -52,8 +52,9 @@ public class UserDaoImpl implements UserDao {
     }
 
     @Override
-    public int insert(User user) {
-        return userMapper.insert(user);
+    public long insert(User user) {
+        userMapper.insert(user);
+        return user.getId();
     }
 
     @Override

ch-wx-api/src/main/java/com/wwdz/ch/wx/impl/AiAssistantServiceImpl.java

@@ -20,6 +20,7 @@ import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -64,6 +65,9 @@ public class AiAssistantServiceImpl implements AiAssistantService {
                     return Result.failed("获取列表失败");
                 }
                 List<IMChatVo> imChatVoList = chatResult.getData().getDataList();
+                if (CollectionUtils.isEmpty(imChatVoList)) {
+                    isContinue = false;
+                }
                 List<String> ids = imChatVoList.stream().map(IMChatVo::getOrginalToAccount).collect(Collectors.toList());
                 converstionUserIdList.addAll(ids);
                 if (chatResult.getData().getCompleteFlag() == 1) {

ch-wx-api/src/main/java/com/wwdz/ch/wx/impl/UserServiceImpl.java

@@ -530,7 +530,7 @@ public class UserServiceImpl implements UserService {
             user.setLastLoginTime(now);
             user.setLastLoginIp(IpUtil.client(request));
             user.setShareUserId(0L);
-            int userId = userDao.insert(user);
+            long userId = userDao.insert(user);
 
             //把新增用户同步到IM
             Result synUserResult = chatUserApi.importUser(user);

ch-wx-api/src/main/java/com/wwdz/ch/wx/manager/WxLoginManager.java

@@ -60,14 +60,14 @@ public class WxLoginManager {
      * @return
      */
     public String getWxOpenId(String loginCode) {
-        logger.info("开始获取openId-----------------------");
         String openId = "";
         try {
+            logger.info(">>>>>>>>> 获取微信openid, 参数loginCode:{}", loginCode);
             WxMaJscode2SessionResult result = this.wxMaService.getUserService().getSessionInfo(loginCode);
             //实际获取的是unionid,为了和公众号订阅用户关联
             openId = result.getUnionid();
             logger.info("获取WxMaJscode2SessionResult :{}", result);
-            logger.info("loginCode:{},获取openId成功 openId :{}", loginCode, openId);
+            logger.info("loginCode:{},获取openId成功 unionid :{}", loginCode, openId);
         } catch (Exception e) {
             logger.error("loginCode:{}, 获取微信登录用户的openId失败:{}", loginCode, e);
         }

ch-wx-api/src/test/java/com/wwdz/ch/wx/api/ChatApiTest.java

@@ -90,11 +90,12 @@ public class ChatApiTest {
     @Test
     public void sendChatMsg() {
         SendChatMsgRequestDto sendChatMsgRequestDto = new SendChatMsgRequestDto();
-        sendChatMsgRequestDto.setToAccount("241");
+        sendChatMsgRequestDto.setToAccount("285");
         sendChatMsgRequestDto.setFromAccount("ai10001");
         sendChatMsgRequestDto.setMsgType(IMEnum.MsgTypeEnum.TIMTextElem.getCode());
         long timestamp = System.currentTimeMillis();
-        String msgContent = timestamp + " >> ai测试消息的数据, 是否可以接收到";
+    //    String msgContent = timestamp + " >> ai测试消息的数据, 是否可以接收到";
+        String msgContent = "Hi，欢迎来到小藏的世界";
         sendChatMsgRequestDto.setMsgContent(msgContent);
         Result<String> result = conversationApi.sendChatMsg(sendChatMsgRequestDto);
         String msgKey = result.getData();
@@ -115,7 +116,7 @@ public class ChatApiTest {
             sendChatMsgRequestDto.setFromAccount("ai10000");
             sendChatMsgRequestDto.setMsgType(IMEnum.MsgTypeEnum.TIMTextElem.getCode());
             long timestamp = System.currentTimeMillis();
-            String msgContent = timestamp + " >> ai测试消息的数据, 是否可以接收到";
+            String msgContent = "Hi，欢迎来到小藏的世界";
             sendChatMsgRequestDto.setMsgContent(msgContent);
             conversationApi.sendChatMsg(sendChatMsgRequestDto);
         });
@@ -127,7 +128,7 @@ public class ChatApiTest {
     @Test
     public void getChatList() {
         IMChatRequestDto imChatRequestDto = new IMChatRequestDto();
-        imChatRequestDto.setUserId(242L);
+        imChatRequestDto.setUserId(243L);
         conversationApi.getChatList(imChatRequestDto);
     }