package com.xiaopeng.pushMessage.webSocket.handler;

import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.xiaopeng.api.feignClient.maintenance.XpTaskClient;
import com.xiaopeng.api.model.maintenance.XpTask;
import com.xiaopeng.pushMessage.webSocket.service.WebSocketUserService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;
import javax.annotation.Resource;
import java.util.HashMap;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

//@Component
@Slf4j
//public class TestMsgHandler implements BusinessMsgHandler{
public class TestMsgSchedule  {


    @Resource
    XpTaskClient xpTaskClient;

    @Autowired
    private WebSocketUserService webSocketUserService;

    @PostConstruct
    public void setup() {
        Executors.newSingleThreadScheduledExecutor()
                .scheduleWithFixedDelay(this::send, 10, 1, TimeUnit.MINUTES);
    }

    public void send() {
        String msg;
        XpTask xpTask = xpTaskClient.queryInfoByVehicleId(20L).getData();
        HashMap<String, Object> ret = new HashMap<>();
        ret.put("type", "task");
        ret.put("data", xpTask);
        try {
            msg = om.writeValueAsString(ret);
        } catch (JsonProcessingException e) {
            throw new RuntimeException("Message serialization failed", e);
        }
        webSocketUserService.broadcastMessage(msg);
    }
    @Autowired ObjectMapper om;
    @Autowired MongoTemplate mongoTemplate;


}