diff --git a/holiday03-GTP/src/main/java/com/sikadi/user/controller/GTPController.java b/holiday03-GTP/src/main/java/com/sikadi/user/controller/GTPController.java new file mode 100644 index 0000000..1347de8 --- /dev/null +++ b/holiday03-GTP/src/main/java/com/sikadi/user/controller/GTPController.java @@ -0,0 +1,25 @@ +package com.sikadi.user.controller; + +import com.bwie.common.domain.StringAppGTP; +import com.sikadi.user.service.GTPService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RestController; +import top.hualuo.XhStreamClient; + +@RestController +public class GTPController { + + @Autowired + private GTPService gtpService; + + + + @PostMapping("/chat") + public String chat(@RequestBody StringAppGTP stringAppGTP){ + + return gtpService.chat(stringAppGTP); + } + +} diff --git a/holiday03-GTP/src/main/java/com/sikadi/user/service/GTPService.java b/holiday03-GTP/src/main/java/com/sikadi/user/service/GTPService.java new file mode 100644 index 0000000..bfb4829 --- /dev/null +++ b/holiday03-GTP/src/main/java/com/sikadi/user/service/GTPService.java @@ -0,0 +1,7 @@ +package com.sikadi.user.service; + +import com.bwie.common.domain.StringAppGTP; + +public interface GTPService { + String chat(StringAppGTP stringAppGTP); +} diff --git a/holiday03-GTP/src/main/java/com/sikadi/user/service/impl/GTPServiceImpl.java b/holiday03-GTP/src/main/java/com/sikadi/user/service/impl/GTPServiceImpl.java new file mode 100644 index 0000000..20555e4 --- /dev/null +++ b/holiday03-GTP/src/main/java/com/sikadi/user/service/impl/GTPServiceImpl.java @@ -0,0 +1,27 @@ +package com.sikadi.user.service.impl; + +import com.bwie.common.domain.StringAppGTP; +import com.bwie.common.utils.XfXhListener; +import com.sikadi.user.service.GTPService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; +import top.hualuo.XhStreamClient; +import top.hualuo.dto.MsgDTO; + +import java.util.Arrays; + +@Service +public class GTPServiceImpl implements GTPService { + + @Autowired + private XhStreamClient xhStreamClient; + + @Override + public String chat(StringAppGTP stringAppGTP) { + + MsgDTO dto = MsgDTO.builder().role(MsgDTO.Role.USER.getName()).content(stringAppGTP.getProblem()).build(); + + + return xhStreamClient.sendMsg("123", Arrays.asList(dto),new XfXhListener());; + } +}