Package com.bytedesk.service.visitor

Class VisitorRestControllerVisitor

java.lang.Object

com.bytedesk.service.visitor.VisitorRestControllerVisitor

@RestController
@RequestMapping("/visitor/api/v1")
public class VisitorRestControllerVisitor
extends Object

anonymous api, no need to login

Field Summary

Fields

Modifier and Type	Field	Description
private final ExecutorService	executorService
private final IpService	ipService
private final MessageRestService	messageRestService
private final IMessageSendService	messageSendService
private final MessageUnreadRestService	messageUnreadRestService
private final RobotService	robotService
private final VisitorRestService	visitorRestService

Constructor Summary

Constructors

Constructor	Description
VisitorRestControllerVisitor()

Method Summary

Modifier and Type	Method	Description
org.springframework.http.ResponseEntity<?>	clearMessageUnread(MessageUnreadRequest request)
void	destroy()
org.springframework.http.ResponseEntity<?>	getMessageUnread(MessageUnreadRequest request)
org.springframework.http.ResponseEntity<?>	getMessageUnreadCount(MessageUnreadRequest request)
org.springframework.http.ResponseEntity<?>	init(VisitorRequest request, jakarta.servlet.http.HttpServletRequest httpRequest)
org.springframework.http.ResponseEntity<?>	ping(MessageUnreadRequest request)
org.springframework.http.ResponseEntity<?>	queryByThreadTopic(MessageRequest request)	根据主题查询消息
org.springframework.http.ResponseEntity<?>	queryByThreadUid(MessageRequest request)	根据会话UID查询消息
org.springframework.http.ResponseEntity<?>	requestThread(VisitorRequest request, jakarta.servlet.http.HttpServletRequest httpRequest)
org.springframework.http.ResponseEntity<?>	sendRestMessage(Map<String,String> map)
org.springframework.web.servlet.mvc.method.annotation.SseEmitter	sendSseMemberMessage(String message)
org.springframework.web.servlet.mvc.method.annotation.SseEmitter	sendSseVisitorMessage(String message)
org.springframework.http.ResponseEntity<?>	sync(VisitorRequest visitorRequest)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

visitorRestService

private final VisitorRestService visitorRestService

messageUnreadRestService

private final MessageUnreadRestService messageUnreadRestService

messageSendService

private final IMessageSendService messageSendService

messageRestService

private final MessageRestService messageRestService

ipService

private final IpService ipService

robotService

private final RobotService robotService

executorService

private final ExecutorService executorService

Constructor Details

VisitorRestControllerVisitor

public VisitorRestControllerVisitor()

Method Details

init

@ApiRateLimiter(value=1.0,
                timeout=1)
@PostMapping("/init")
public org.springframework.http.ResponseEntity<?> init(@RequestBody
 VisitorRequest request,
 jakarta.servlet.http.HttpServletRequest httpRequest)

requestThread

@PostMapping("/thread")
public org.springframework.http.ResponseEntity<?> requestThread(@RequestBody
 VisitorRequest request,
 jakarta.servlet.http.HttpServletRequest httpRequest)

ping

@GetMapping("/ping")
public org.springframework.http.ResponseEntity<?> ping(MessageUnreadRequest request)

queryByThreadTopic

@GetMapping("/message/thread/topic")
public org.springframework.http.ResponseEntity<?> queryByThreadTopic(MessageRequest request)

根据主题查询消息

Parameters:

request - 查询请求

Returns:

分页消息列表

queryByThreadUid

@GetMapping("/message/thread/uid")
public org.springframework.http.ResponseEntity<?> queryByThreadUid(MessageRequest request)

根据会话UID查询消息

Parameters:

request - 查询请求

Returns:

分页消息列表

getMessageUnread

@GetMapping("/message/unread")
public org.springframework.http.ResponseEntity<?> getMessageUnread(MessageUnreadRequest request)

getMessageUnreadCount

@GetMapping("/message/unread/count")
public org.springframework.http.ResponseEntity<?> getMessageUnreadCount(MessageUnreadRequest request)

clearMessageUnread

@PostMapping("/message/unread/clear")
public org.springframework.http.ResponseEntity<?> clearMessageUnread(@RequestBody
 MessageUnreadRequest request)

sendRestMessage

@BlackIpFilter(title="black",
               action="sendRestMessage")
@BlackUserFilter(title="black",
                 action="sendRestMessage")
@TabooJsonFilter(title="\u654f\u611f\u8bcd",
                 action="sendRestMessage")
@VisitorAnnotation(title="visitor",
                   action="sendRestMessage",
                   description="sendRestMessage")
@PostMapping("/message/send")
public org.springframework.http.ResponseEntity<?> sendRestMessage(@RequestBody
 Map<String,String> map)

sendSseMemberMessage

@TabooJsonFilter(title="\u654f\u611f\u8bcd",
                 action="sendSseMemberMessage")
@VisitorAnnotation(title="visitor",
                   action="sendSseMemberMessage",
                   description="sendSseMemberMessage")
@GetMapping(value="/member/message/sse",
            produces="text/event-stream")
public org.springframework.web.servlet.mvc.method.annotation.SseEmitter sendSseMemberMessage(@RequestParam("message")
 String message)

sendSseVisitorMessage

@BlackIpFilter(title="black",
               action="sendSseVisitorMessage")
@BlackUserFilter(title="black",
                 action="sendSseVisitorMessage")
@TabooJsonFilter(title="\u654f\u611f\u8bcd",
                 action="sendSseVisitorMessage")
@VisitorAnnotation(title="visitor",
                   action="sendSseVisitorMessage",
                   description="sendSseVisitorMessage")
@GetMapping(value="/message/sse",
            produces="text/event-stream")
public org.springframework.web.servlet.mvc.method.annotation.SseEmitter sendSseVisitorMessage(@RequestParam("message")
 String message)

sync

@BlackIpFilter(title="black",
               action="sync")
@BlackUserFilter(title="black",
                 action="sync")
@TabooJsonFilter(title="\u654f\u611f\u8bcd",
                 action="sync")
@ApiRateLimiter(value=10.0,
                timeout=1)
@VisitorAnnotation(title="visitor",
                   action="sync",
                   description="sync visitor message")
@PostMapping("/message/sync")
public org.springframework.http.ResponseEntity<?> sync(@RequestBody
 VisitorRequest visitorRequest)

destroy

public void destroy()