package com.fzzy.order.ordersx2023;

import com.fzzy.order.ordersx2023.data.OrderSxConstant;
import com.fzzy.order.ordersx2023.data.OrderSxReq;
import com.fzzy.order.ordersx2023.data.OrderSxResp;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

/**
 * @Description 陕西省平台指令接收服务
 * @Author CZT
 * @Date 2024/4/23 11:11
 */
@Slf4j
@Controller
@RequestMapping("Acquisition")
public class OrderSxController {

    @Autowired
    private OrderSxManager orderSxManager;
    /**
     * 指令入口
     * @param req
     * @return
     */
    @SuppressWarnings("unchecked")
    @ResponseBody
    @RequestMapping("")
    public OrderSxResp order(@RequestBody OrderSxReq req){
        log.debug("陕西省平台：接收的指令信息={}", req);
        //判断参数
        if(null == req){
            //解析失败
            log.error("陕西省平台：指令解析失败，收到的指令信息为空！");
            return new OrderSxResp(OrderSxConstant.ORDER_SX_CODE_400);
        }

        //心跳指令，直接返回
        if(OrderSxConstant.ORDER_SX_TYPE_0.equals(req.getType())){
            log.info("陕西省平台：收到心跳指令，指令信息={}", req);
            return new OrderSxResp(OrderSxConstant.ORDER_SX_CODE_200);
        }

        try {

            //异步执行
            orderSxManager.execute(req);

            return new OrderSxResp(OrderSxConstant.ORDER_SX_CODE_200);

        } catch (Exception e) {
            log.error("陕西省平台：指令解析失败，指令信息={}", req);
            return new OrderSxResp(OrderSxConstant.ORDER_SX_CODE_400);
        }

    }
}