| | |
|---|
| | | query.eq(AiMemberTalk::getState,AiTypeEnum.AI_MEMBER_TALK_STATE_ING.getCode()); |
|---|
| | | query.orderByDesc(AiMemberTalk::getCreatedTime); |
|---|
| | | query.last("limit 1"); |
|---|
| | | AiMemberTalk aiMemberTalk = aiMemberTalkService.getByQuery(query); |
|---|
| | | if (ObjectUtil.isNull(aiMemberTalk)){ |
|---|
| | | aiMemberTalk = aiMemberTalkService.add(memberUuid,companyId,productId,nowTime,questionCount); |
|---|
| | | } |
|---|
| | | |
|---|
| | | ApiMemberTalkStreamVo apiMemberTalkVo = new ApiMemberTalkStreamVo(); |
|---|
| | | |
|---|
| | | AiMemberTalk aiMemberTalk = aiMemberTalkService.getByQuery(query); |
|---|
| | | String title = "加载时间过程，请重试！"; |
|---|
| | | if (ObjectUtil.isNull(aiMemberTalk)){ |
|---|
| | | aiMemberTalk = aiMemberTalkService.add(memberUuid,companyId,productId,nowTime,questionCount); |
|---|
| | | AiProductQuestion question = aiProductQuestionService.createQuestion(productId); |
|---|
| | | if (ObjectUtil.isNotNull(question)){ |
|---|
| | | title = question.getTitle(); |
|---|
| | |
|---|
| | | apiMemberTalkVo.setMemberTalkItemId(aiMemberTalkItem.getId()); |
|---|
| | | aiMemberTalkService.updateTimeUpdate(nowTime,aiMemberTalk.getId()); |
|---|
| | | } |
|---|
| | | }else{ |
|---|
| | | AiMemberTalkItem oneByQuery = aiMemberTalkItemService.getOneByQuery( |
|---|
| | | Wrappers.lambdaQuery(AiMemberTalkItem.class) |
|---|
| | | .eq(AiMemberTalkItem::getMemberTalkId, aiMemberTalk.getId()) |
|---|
| | | .eq(AiMemberTalkItem::getType, 1) |
|---|
| | | .orderByDesc(AiMemberTalkItem::getCreatedTime) |
|---|
| | | .last("limit 1") |
|---|
| | | ); |
|---|
| | | if (ObjectUtil.isNotNull(oneByQuery)){ |
|---|
| | | title = oneByQuery.getContext(); |
|---|
| | | apiMemberTalkVo.setMemberTalkItemId(oneByQuery.getId()); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | apiMemberTalkVo.setMemberTalkId(aiMemberTalk.getId()); |
|---|
| | | apiMemberTalkVo.setType(1); |
|---|
| | | apiMemberTalkVo.setContext(title); |
|---|
