package com.ld.igds.protocol.bhzn.grainv2;

import com.ld.igds.common.CoreCommonService;
import com.ld.igds.io.RemoteGrainService;
import com.ld.igds.io.constant.OrderRespEnum;
import com.ld.igds.io.constant.ProtocolEnum;
import com.ld.igds.io.request.CheckGrainRequest;
import com.ld.igds.io.response.GrainResponse;
import com.ld.igds.models.Depot;
import com.ld.igds.protocol.bhzn.grainv2.msg.builder.CommandBuild;
import com.ld.igds.protocol.bhzn.grainv2.server.BhznGrainV2ServerEngine;
import com.ld.igds.util.BytesUtil;
import com.ld.io.api.InvokeResult;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;


/**
 * @Desc: 粮情业务接口
 * @author: Andy
 * @update-time: 2023/5/11
 */
@Slf4j
@Component(RemoteGrainV2ServiceImpl.BEAN_ID)
public class RemoteGrainV2ServiceImpl implements RemoteGrainService {

    public static final String BEAN_ID = "bhznGrainv2.remoteGrainService";

    @Autowired
    private CoreCommonService coreCommonService;
    @Autowired
    private BhznGrainV2ServerEngine bhznGrainServerEngine;

    @Override
    public String getProtocol() {
        return ProtocolEnum.TCP_BHZH_GRAIN_V2.getCode();
    }

    @Override
    public GrainResponse checkGrain(CheckGrainRequest request) {
        try {
            String depotId = request.getDepotId();

            //判断邦海仓库编码是否配置
            Depot depot = coreCommonService.getCacheDepot(request.getCompanyId(), request.getDepotId());
            if(null != depot && StringUtils.isNotEmpty(depot.getBhId())){
                depotId = depot.getBhId();
            }

            // 生成粮情信息
            String hexStr = CommandBuild.getInstance().getMsgCheck(request.getSerId(), depotId);

            // 发送命令
            InvokeResult result = bhznGrainServerEngine.push(request.getIp(),request.getPort(), BytesUtil.hexStrToBytes(hexStr));

            log.error("平台------>>>>控制柜：粮情检测-{}", hexStr);

            // 封装返回信息
            if (InvokeResult.SUCCESS == result) {
                return new GrainResponse(OrderRespEnum.ORDER_SUCCESS.getCode(),
                        "粮情粮情发送成功！");
            } else {
                log.error("平台------>>>>控制柜：粮情检测-失败{}", result.getMessage());
                return new GrainResponse(OrderRespEnum.ORDER_ERROR.getCode(),
                        "命令发送异常：" + result.getMessage());
            }

        } catch (Exception e) {
            log.error("粮情检测异常：{}", e);
            return new GrainResponse(OrderRespEnum.ORDER_ERROR.getCode(), "后端异常：" + e.getMessage());
        }
    }
}