package com.casic.service.impl;

import com.alibaba.druid.util.StringUtils;
import com.alibaba.fastjson.JSON;
import com.casic.service.MessagePusherService;
import com.casic.util.WebSocket;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.*;

@Slf4j
@Service
public class MessagePusherImpl implements MessagePusherService {

    @Resource
    private WebSocket webSocket;

    @Override
    public void updateSinkJob(String id, String msg) {
        if (!(StringUtils.isEmpty(msg))) {
            sendAlarm(msg);//推送告警至pc端
        }
    }

    private void sendAlarm(String msg) {
        List<String> userIds = new ArrayList<>();
//        String appMsg = "设备编号[" + devcode + "]发生" + msg + ",工单编号为[" + jobId + "]";
        // PC推送
        userIds.add("123456");
        if (userIds.size() > 0) {
            Map<String, Object> map = new HashMap<String, Object>();
            map.put("message", msg);
            map.put("type", "alarm");
            webSocket.sendListMessage(userIds, JSON.toJSONString(map));
        } else {
            log.info("告警消息找不到责任人，pc端未推送:" + msg);
        }
    }

}