package com.ruoyi.auction.controller;
|
|
import com.ruoyi.common.core.constant.SecurityConstants;
|
import com.ruoyi.common.core.domain.R;
|
import com.ruoyi.common.core.enums.ClientTypeEnum;
|
import com.ruoyi.system.api.domain.WebsocketMessageDTO;
|
import com.ruoyi.system.api.feignClient.SysUserClient;
|
import javax.annotation.Resource;
|
import org.springframework.web.bind.annotation.GetMapping;
|
import org.springframework.web.bind.annotation.PathVariable;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
|
@RestController
|
@RequestMapping("/websocket")
|
public class WebSocketController {
|
|
@Resource
|
private SysUserClient sysUserClient;
|
|
@GetMapping("/push/{type}/{msg}")
|
public R<?> push(@PathVariable("type") Integer type, @PathVariable("msg") String msg) {
|
sysUserClient.pushByClientType(WebsocketMessageDTO.builder().clientType(ClientTypeEnum.getEnumByCode(type)).message(msg).build(), SecurityConstants.INNER);
|
return R.ok();
|
}
|
|
@GetMapping("/push2All/{msg}")
|
public R<?> push(@PathVariable("msg") String msg) {
|
sysUserClient.pushAll(msg, SecurityConstants.INNER);
|
return R.ok();
|
}
|
}
|
