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); } }