| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152 |
- package com.goafanti.baiduAI.controller;
- import com.goafanti.baiduAI.bo.InputSendChat;
- import com.goafanti.baiduAI.bo.Messages;
- import com.goafanti.baiduAI.bo.SseMap;
- import com.goafanti.baiduAI.bo.SseResult;
- import com.goafanti.baiduAI.service.BaiduAiService;
- import com.goafanti.common.bo.Result;
- import com.goafanti.common.bo.SseEmitterUTF8;
- import com.goafanti.common.constant.ErrorConstants;
- import com.goafanti.common.controller.BaseController;
- import com.goafanti.common.controller.CertifyApiController;
- import com.goafanti.common.error.BusinessException;
- import com.goafanti.common.model.AftUser;
- import com.goafanti.common.utils.LoggerUtils;
- import com.goafanti.common.utils.StringUtils;
- import com.goafanti.core.shiro.token.TokenManager;
- import org.springframework.beans.factory.annotation.Autowired;
- import org.springframework.web.bind.annotation.*;
- import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
- import java.io.IOException;
- import java.util.ArrayList;
- import java.util.Calendar;
- import java.util.List;
- import java.util.UUID;
- @RestController
- @RequestMapping(value = "/chat")
- public class BaiduAiController extends CertifyApiController{
- @Autowired
- private BaiduAiService baiduAiService;
- @RequestMapping(value = "/send")
- public Object sendChat(@RequestBody InputSendChat in){
- if (in.getUserId()==null ){
- in.setUserId(UUID.randomUUID().toString());
- in.setStream(true);
- }
- if (in.getMessages()==null||in.getMessages().isEmpty()){
- Result res= new Result();
- res.getError().add(buildError(ErrorConstants.PARAM_ERROR,"访问参数"));
- return res;
- }
- return baiduAiService.sendChat(in);
- }
- }
|