package com.ld.igds.phone35.service.impl; import com.alibaba.fastjson.JSONObject; import com.ld.igds.constant.RespCodeEnum; import com.ld.igds.grain.dto.GrainParam; import com.ld.igds.grain.manager.GrainManager; import com.ld.igds.io.constant.OrderRespEnum; import com.ld.igds.io.response.GrainResponse; 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 Phone35ServiceImpl5303 implements Phone35Service { @Autowired private GrainManager grainManager; @Override public String getInterfaceId() { return Phone35Constant.API_PHONE_5303; } @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, "参数有误,请重试!!"); } GrainParam grainParam = new GrainParam(); grainParam.setCompanyId(phone35AuthUser.getCompanyId()); grainParam.setDepotId(param.getDepotId()); GrainResponse grainResponse = grainManager.checkSingle(grainParam); if(OrderRespEnum.ORDER_ERROR.getCode().equals(grainResponse.getCode())){ return PhoneRespUtil.error(RespCodeEnum.CODE_1111,grainResponse.getMsg()); }else { return PhoneRespUtil.success(grainResponse.getMsg(), req); } } }