Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| e58137c319 |
@@ -10,6 +10,7 @@ import org.springframework.stereotype.Service;
|
|||||||
|
|
||||||
import javax.annotation.Resource;
|
import javax.annotation.Resource;
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
import java.time.Instant;
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
import java.util.Arrays;
|
import java.util.Arrays;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
@@ -101,7 +102,8 @@ public class SpecificTimeTaskService {
|
|||||||
json.put("resCode",1);
|
json.put("resCode",1);
|
||||||
json.put("resMsg", "");
|
json.put("resMsg", "");
|
||||||
json.put("result", jsonObject.toJSONString());
|
json.put("result", jsonObject.toJSONString());
|
||||||
Message message = Message.builder().clientId(request.getClientId()).dataType(request.getDataType()).data(jsonObject.toJSONString()).build();
|
json.put("timestamp", Instant.now().getEpochSecond());
|
||||||
|
Message message = Message.builder().clientId(request.getClientId()).dataType(request.getDataType()).data(json.toJSONString()).build();
|
||||||
if (Objects.nonNull(sessionManager.getSessionById(request.getClientId()))) {
|
if (Objects.nonNull(sessionManager.getSessionById(request.getClientId()))) {
|
||||||
System.out.println("发送执行结果: " + json.toJSONString()); // 注意:toJSONString()
|
System.out.println("发送执行结果: " + json.toJSONString()); // 注意:toJSONString()
|
||||||
sessionManager.writeAndFlush(sessionManager.getSessionById(request.getClientId()).getChannel(), message);
|
sessionManager.writeAndFlush(sessionManager.getSessionById(request.getClientId()).getChannel(), message);
|
||||||
|
|||||||
Reference in New Issue
Block a user