package com.ld.igds.phone.service.impl;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.ld.igds.constant.RespCodeEnum;
|
import com.ld.igds.grain.service.CoreGrainService;
|
import com.ld.igds.grain.dto.GrainData;
|
import com.ld.igds.grain.dto.GrainLay;
|
import com.ld.igds.grain.dto.GrainParam;
|
import com.ld.igds.grain.dto.GrainPoint;
|
import com.ld.igds.phone.constant.PhoneConstant;
|
import com.ld.igds.phone.dto.*;
|
import com.ld.igds.phone.param.ParamDepot;
|
import com.ld.igds.phone.param.PhoneRequest;
|
import com.ld.igds.phone.service.PhoneService;
|
import com.ld.igds.phone.util.PhoneRespUtil;
|
import com.ld.igds.phone.util.PhoneUtil;
|
import com.ld.igds.util.DateUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
|
/**
|
* 粮情展示-历史数据(根据页码查询)
|
*
|
* @author chen
|
*/
|
@Service
|
public class ServiceImpl5310 implements PhoneService {
|
|
@Autowired
|
private PhoneUtil phoneUtil;
|
@Autowired
|
private CoreGrainService coreGrainService;
|
|
@Override
|
public String getInterfaceId() {
|
return PhoneConstant.API_PHONE_5310;
|
}
|
|
@SuppressWarnings("unchecked")
|
@Override
|
public PhoneResponse<Object> execute(PhoneRequest<JSONObject> req, AuthUser authUser)
|
throws Exception {
|
ParamDepot param = JSONObject.parseObject(req.getData().toString(), ParamDepot.class);
|
|
GrainParam grainParam = new GrainParam();
|
grainParam.setDepotId(param.getDepotId());
|
grainParam.setCompanyId(authUser.getCompanyId());
|
//设置查询时间,月的第一天到最后一天
|
grainParam.setStart(DateUtil.getMonthFirst(param.getDateTime()));
|
grainParam.setEnd(DateUtil.getNextMonthFirst(param.getDateTime()));
|
|
//查询粮情数据
|
List<GrainData> list = coreGrainService.listGrainData(grainParam);
|
|
if (null == list || list.isEmpty()) {
|
return PhoneRespUtil.error(RespCodeEnum.CODE_1005, req, "该仓库暂无粮情数据！");
|
}
|
|
//返回数据封装
|
List<Dto5302> dtoList = new ArrayList<>();
|
Dto5302 dto;
|
List<DtoPoint5302> listPoints;
|
List<DtoDetail5302> listDetail;
|
DtoPoint5302 dtoPoint5302;
|
DtoDetail5302 dtoDetail5302;
|
for (GrainData grainData : list) {
|
dto = new Dto5302();
|
dto.setDepotId(grainData.getDepotId());
|
dto.setDepotName(phoneUtil.getDepotName(authUser.getCompanyId(),dto.getDepotId()));
|
dto.setDepotType(param.getType());
|
dto.setReceiveDate(grainData.getReceiveDate());
|
dto.setTempIn(grainData.getTempIn());
|
dto.setHumidityIn(grainData.getHumidityIn());
|
dto.setTempOut(grainData.getTempOut());
|
dto.setHumidityOut(grainData.getHumidityOut());
|
dto.setTempMax(grainData.getTempMax());
|
dto.setTempMin(grainData.getTempMin());
|
dto.setTempAve(grainData.getTempAve());
|
dto.setCable(grainData.getCable().replaceAll(",","-"));
|
|
listPoints = new ArrayList<>();
|
for (GrainPoint point : grainData.getListPoints()) {
|
if("02".equals(param.getType()) || "04".equals(param.getType())){
|
//筒仓时
|
point.setFz(point.getFz()+1);
|
point.setZ(point.getZ()+1);
|
}
|
dtoPoint5302 = new DtoPoint5302();
|
dtoPoint5302.setX(point.getX());
|
dtoPoint5302.setY(point.getY());
|
dtoPoint5302.setZ(point.getZ());
|
dtoPoint5302.setFz(point.getFz());
|
dtoPoint5302.setTemp(point.getTemp());
|
listPoints.add(dtoPoint5302);
|
}
|
dto.setPoints(listPoints);
|
|
listDetail = new ArrayList<>();
|
for (GrainLay lay : grainData.getListLays()) {
|
dtoDetail5302 = new DtoDetail5302();
|
dtoDetail5302.setFz(lay.getFz());
|
dtoDetail5302.setFzName(lay.getFz() + "层");
|
dtoDetail5302.setTempMax(lay.getTempMax());
|
dtoDetail5302.setTempMin(lay.getTempMin());
|
dtoDetail5302.setTempAve(lay.getTempAve());
|
listDetail.add(dtoDetail5302);
|
}
|
dto.setDetails(listDetail);
|
|
dtoList.add(dto);
|
}
|
return PhoneRespUtil.success(dtoList, req);
|
}
|
}
|
