package com.xiaopeng.pushMessage.webSocket.handler;

import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.xiaopeng.api.vo.TaskVO;
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 java.math.BigDecimal;
import java.util.HashMap;

@Component
@Slf4j
public class TestMsgHandler implements BusinessMsgHandler{

    @Override
    public String getMessageType() {
        return "test";
    }
    @Autowired
    private WebSocketUserService webSocketUserService;
    @Override
    public void handle(String uid, String msg) {
        TaskVO vo = new TaskVO();

        vo.setHandleUserId("1");
        vo.setId(1L);
        vo.setStatus(1);
        vo.setTaskCode("1");
        vo.setTaskTypeId("1");
        vo.setTaskTypeName("1");
        vo.setTaskUrgencyLevel(1);
        vo.setVehicleId(1L);
        vo.setVehicleLocation("1");
        vo.setPlateNumber("1");
        vo.setVehicleLat(BigDecimal.ZERO);
        vo.setVehicleLon(BigDecimal.ZERO);
        vo.setCanArriveRange(1D);
        vo.setEndTime(null);
        vo.setHandleUserId("1");
        vo.setVehicleLocation("1");
        vo.setPlateNumber("1");
        vo.setVehicleId(1L);
        vo.setCanArriveRange(1D);
        vo.setEndTime(null);
        vo.setHandleUserId("1");
        vo.setVehicleLocation("1");
        vo.setPlateNumber("1");
        vo.setVehicleId(1L);
        vo.setHandleUserId("1341243234");
        HashMap<String, Object> ret = new HashMap<>();
        ret.put("type", "task");
        ret.put("data", vo);
        try {
            msg = om.writeValueAsString(ret);
        } catch (JsonProcessingException e) {
            log.error("Failed to serialize message for uid: {}", uid, e);
            throw new RuntimeException("Message serialization failed", e);
        }
        webSocketUserService.sendMessageToUser(uid, msg);
    }
    @Autowired ObjectMapper om;
    @Autowired MongoTemplate mongoTemplate;


}