package com.ld.igds.phone35.service.impl; import com.alibaba.fastjson.JSONObject; import com.ld.igds.constant.RespCodeEnum; import com.ld.igds.gas.dto.GasParam; import com.ld.igds.gas.manager.GasManager; import com.ld.igds.io.constant.OrderRespEnum; import com.ld.igds.io.response.GasResponse; import com.ld.igds.phone35.constant.Phone35Constant; import com.ld.igds.phone35.dto.Phone35AuthUser; import com.ld.igds.phone35.dto.PhoneResponse; import com.ld.igds.phone35.param.Phone35DepotCommonParam; import com.ld.igds.phone35.param.Phone35Request; import com.ld.igds.phone35.service.Phone35Service; import com.ld.igds.phone35.util.PhoneRespUtil; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; /** * 粮情展示-气体采集接口实现 * * @author chen */ @Service public class Phone35ServiceImpl5305 implements Phone35Service { @Autowired private GasManager gasManager; @Override public String getInterfaceId() { return Phone35Constant.API_PHONE_5305; } @SuppressWarnings("unchecked") @Override public PhoneResponse execute(Phone35Request req, Phone35AuthUser phone35AuthUser) throws Exception { Phone35DepotCommonParam param = JSONObject.parseObject(req.getData().toString(), Phone35DepotCommonParam.class); if (null == param) { return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "参数有误,请重试!!"); } //参数验证 if (StringUtils.isEmpty(param.getDeptId()) || StringUtils.isEmpty(param.getDepotId())) { return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "参数有误,请重试!!"); } GasParam gasParam = new GasParam(); gasParam.setCompanyId(phone35AuthUser.getCompanyId()); gasParam.setDepotId(param.getDepotId()); GasResponse gasResponse = gasManager.checkGas(gasParam); if(OrderRespEnum.ORDER_ERROR.getCode().equals(gasResponse.getCode())){ return PhoneRespUtil.error(RespCodeEnum.CODE_1111,gasResponse.getMsg()); }else { return PhoneRespUtil.success(gasResponse.getMsg(), req); } } }