package com.yoho.rfid.controller;

import com.yoho.rfid.model.req.AppReportReq;
import com.yoho.rfid.model.req.InfoScreenHeartBeatPacket;
import com.yoho.rfid.service.MonitorService;
import com.yoho.rfid.util.ApiResponse;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;

import java.util.Map;

/**
 * Created by chenchao on 2017/10/16.
 */
@Controller
public class MonitorController {

    private Logger logger = LoggerFactory.getLogger(getClass());

    @Autowired
    private MonitorService monitorService;

    @RequestMapping(params = "method=offline.infoScreen.heartbeat")
    @ResponseBody
    public ApiResponse accept(@RequestParam(value="ip", required=true) String ip,
                              @RequestParam(value="mac", required=false) String mac,
                              @RequestParam(value="screenType", required=true) Integer screenType){
        InfoScreenHeartBeatPacket.DataBuilder builder = new InfoScreenHeartBeatPacket().new DataBuilder();
        InfoScreenHeartBeatPacket packet = builder.setIp(ip).setMac(mac).setScreenType(screenType).build();
        //logger.info("in offline.infoScreen.heartbeat, packet {}", packet);
        monitorService.acceptHeartBeat(packet);
        return new ApiResponse.ApiResponseBuilder().code(200).message("accept success").build();
    }


    @RequestMapping(params = "method=offline.infoScreen.appReport")
    @ResponseBody
    public ApiResponse appReport(@RequestParam(value="ip", required=true) String ip,
                              @RequestParam(value="mac", required=false) String mac,
                                 @RequestParam(value="screenType", required=false) Integer screenType,
                                 @RequestParam(value="event") String eventName){
        AppReportReq req = new AppReportReq().new DataBuilder().setIp(ip).setMac(mac)
                .setScreenType(screenType).setEventName(eventName).build();
        logger.info("in offline.infoScreen.appReport, req {}", req);
        monitorService.acceptAppReport(req);
        return new ApiResponse.ApiResponseBuilder().code(200).message("accept success").build();
    }


    @RequestMapping(params = "method=offline.infoScreen.appReportData")
    @ResponseBody
    public ApiResponse appReportDetail(@RequestParam(value="ip", required=false) String ip
                                 ){
        AppReportReq req = new AppReportReq().new DataBuilder().setIp(ip).build();
        logger.info("in offline.infoScreen.appReportData, req {}", req);
        Map<String, AppReportReq> data = monitorService.getAppReport(req);
        return new ApiResponse.ApiResponseBuilder().code(200).data(data).message("get appReportData success").build();
    }

    @RequestMapping(params = "method=offline.infoScreen.heartbeatData")
    @ResponseBody
    public ApiResponse acceptHeartbeatDetail(@RequestParam(value="ip", required=false) String ip){
        InfoScreenHeartBeatPacket.DataBuilder builder = new InfoScreenHeartBeatPacket().new DataBuilder();
        InfoScreenHeartBeatPacket packet = builder.setIp(ip).build();
        logger.info("in offline.infoScreen.heartbeatData, packet {}", packet);
        Map<String,InfoScreenHeartBeatPacket> data = monitorService.getHeartBeat(packet);
        return new ApiResponse.ApiResponseBuilder().code(200).data(data).message("get heartbeatData success").build();
    }

    @RequestMapping(params = "method=showWorkThreads")
    @ResponseBody
    public ApiResponse showWorkThreads(){
        logger.info("in showWorkThreads");
        return new ApiResponse.ApiResponseBuilder().code(200)
                .data(monitorService.getThreadNodeList()).message("invoke showWorkThreads success").build();
    }
}