package com.fzzy.gateway.controller;

import com.fzzy.async.fzzy40.entity.Fz40Grain;
import com.fzzy.gateway.GatewayUtils;
import com.fzzy.gateway.api.GatewayDeviceReportService;
import com.fzzy.gateway.api.GatewayRemoteManager;
import com.fzzy.gateway.data.BaseReqData;
import com.fzzy.gateway.data.BaseResp;
import com.fzzy.gateway.entity.GatewayDevice;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

import javax.annotation.Resource;


/**
 * 与网关相关的接口数据对接，由第三方对接
 */
@Slf4j
@Controller
@RequestMapping("/gateway/api/v1")
public class GatewayDataApi {

    @Resource
    private GatewayRemoteManager gatewayRemoteManager;


    /**
     * 粮情数据推送，第三方软件平台推送粮情数据到网关
     *
     * @param grainData
     * @return
     * @throws Exception
     */
    @PostMapping("/push-grain")
    public @ResponseBody
    BaseResp pushGrain(@RequestBody Fz40Grain grainData) {

        BaseResp resp = new BaseResp();
        try {

            log.info("----------主动推送粮情接口执行----{}",grainData);

            //根据系统仓库编码获取配置设备信息
            GatewayDevice device = GatewayUtils.getCacheByDepotSysId(grainData.getDepotId());

            if (null == device) {
                resp.setMsg("网关中没有获取到配置的终端设备信息,无法执行。仓库编码=" + grainData.getDepotId());
                resp.setCode(BaseResp.CODE_500);
                return resp;
            }

            //数据封装转换
            GatewayDeviceReportService reportService = gatewayRemoteManager.getDeviceReportService(device.getPushProtocol());
            if (null == reportService) {
                log.error("------------粮情推送失败，系统不存在当前协议执行类----{}", device.getDeviceName());
                resp.setMsg("粮情推送失败，系统不存在当前协议执行类，网关设备=" + device.getDeviceName());
                resp.setCode(BaseResp.CODE_500);
                return resp;
            }

            //数据封装
            resp = reportService.grainData2GatewayApiInfo(grainData, device);

            BaseReqData reqData = new BaseReqData();
            reqData.setProductId(device.getProductId());
            reqData.setDeviceName(device.getDeviceName());
            reqData.setDeviceId(device.getDeviceId());

            reqData.setDevice(device);
            reqData.setData(resp.getData());

            //手动推送到平台
            resp = reportService.reportGrainDataByHand(reqData);

        } catch (Exception e) {
            log.error("-----------手动推送粮情数据执行异常---{}", e);
            resp.setCode(BaseResp.CODE_500);
            resp.setMsg("执行异常:" + e.getMessage());
        }
        return resp;
    }
}