package com.tianbo.messagebus.controller;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.tianbo.messagebus.controller.response.ResultJson;
import com.tianbo.messagebus.model.HEADER;
import com.tianbo.messagebus.model.MSG;
import com.tianbo.messagebus.model.MSGS;
import com.tianbo.messagebus.myinterface.KafkaReciveApi;
import com.tianbo.messagebus.myinterface.KafkaSendApi;
import com.tianbo.messagebus.service.MessageBusProcessor;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.Serializable;
import java.util.Date;

@RestController()
@Slf4j
@RequestMapping("/")
public class HeartbeatController implements Serializable {
    private static final long serialVersionUID = 1L;

    @Autowired
    KafkaReciveApi kafkaReciveApi;

    @Autowired
    KafkaSendApi kafkaSendApi;

    @Autowired
    private HttpServletRequest request;

    @Autowired
    MessageBusProcessor messageBusProcessor;

    @PostMapping("login")
    public void login(){
        messageBusProcessor.login();
    }

    @PostMapping("getmsg")
    public void getmsg(){
        log.error("for test");
        messageBusProcessor.getMsg();
    }

    @GetMapping("getOneMsg")
    public void getonemsg(@RequestParam(value = "username") String username){
        ResultJson resultJson=  kafkaReciveApi.recive(username);
        log.info("收到结果为:{}",resultJson.toString());
    }

    @PostMapping("send")
    public void sendMsg(@RequestParam("msg") String msgBody){
        MSGS msgs = new MSGS();
        MSG msg = new MSG();

        HEADER header = new HEADER();
        header.setSNDR("TXD");
        header.setDDTM("20210429103322081");
        header.setSEQNO(2021042910);
        header.setTYPE("HYXX");
        header.setSTYPE("ISLI");



        msg.setHEADER(header);
        msg.setBODY(msgBody);




        msgs.setMSG(msg);

        ResultJson response = kafkaSendApi.send(msgs);
        log.info(response.toString());
    }

}