package com.fzzy.igds.app.v1.service.impl;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.fzzy.common.constant.RespCodeEnum;
|
import com.fzzy.common.utils.DateUtil;
|
import com.fzzy.igds.app.v1.constant.PhoneConstant;
|
import com.fzzy.igds.app.v1.data.AuthUser;
|
import com.fzzy.igds.app.v1.data.ParamDepot;
|
import com.fzzy.igds.app.v1.data.PhoneRequest;
|
import com.fzzy.igds.app.v1.data.PhoneResponse;
|
import com.fzzy.igds.app.v1.dto.PDetailDto;
|
import com.fzzy.igds.app.v1.dto.PGrainDto;
|
import com.fzzy.igds.app.v1.dto.PPointDto;
|
import com.fzzy.igds.app.v1.service.PhoneService;
|
import com.fzzy.igds.app.v1.util.PhoneRespUtil;
|
import com.fzzy.igds.app.v1.util.PhoneUtil;
|
import com.fzzy.igds.data.GrainData;
|
import com.fzzy.igds.data.GrainLay;
|
import com.fzzy.igds.data.GrainParam;
|
import com.fzzy.igds.data.GrainPoint;
|
import com.fzzy.igds.domain.Depot;
|
import com.fzzy.igds.domain.DepotConf;
|
import com.fzzy.igds.domain.Grain;
|
import com.fzzy.igds.service.DepotConfService;
|
import com.fzzy.igds.service.DepotService;
|
import com.fzzy.igds.service.GrainService;
|
import com.fzzy.igds.utils.GrainDataBuilder;
|
import org.apache.commons.lang3.StringUtils;
|
import org.apache.commons.lang3.time.DateUtils;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* @Author: YYC
|
* @Description: 粮情数据查看-历史数据(根据页码查询)接口
|
* @DateTime: 2026-1-12 14:43
|
**/
|
@Service
|
public class ServiceImpl5204 implements PhoneService {
|
|
@Autowired
|
private PhoneUtil phoneUtil;
|
@Autowired
|
private DepotService depotService;
|
@Autowired
|
private GrainService coreGrainService;
|
@Autowired
|
private DepotConfService depotConfService;
|
|
@Override
|
public String getInterfaceId() {
|
return PhoneConstant.API_PHONE_5204;
|
}
|
|
@Override
|
public PhoneResponse<Object> execute(PhoneRequest<JSONObject> req, AuthUser authUser) throws Exception {
|
ParamDepot param = JSONObject.parseObject(req.getData().toString(), ParamDepot.class);
|
if (null == param) {
|
return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "参数有误，请重试！！");
|
}
|
//参数验证
|
if (StringUtils.isEmpty(param.getDeptId()) || StringUtils.isEmpty(param.getDepotId()) || null == param.getDateTime()) {
|
return PhoneRespUtil.error(RespCodeEnum.CODE_1111, "参数有误，请重试！！");
|
}
|
GrainParam grainParam = new GrainParam();
|
grainParam.setDepotId(param.getDepotId());
|
grainParam.setCompanyId(authUser.getCompanyId());
|
Date date = DateUtils.parseDate(param.getDateTime(), "yyyy-MM");
|
//设置查询时间,月的第一天到最后一天
|
grainParam.setStart(DateUtil.getMonthFirst(date));
|
grainParam.setEnd(DateUtil.getNextMonthFirst(date));
|
grainParam.setDeptId(param.getDeptId());
|
|
//查询粮情数据
|
List<Grain> list = coreGrainService.listData(grainParam);
|
Depot depot = depotService.getCacheDepot(authUser.getCompanyId(), param.getDepotId());
|
if (null == list || list.isEmpty()) {
|
return PhoneRespUtil.error(RespCodeEnum.CODE_1005, "该仓库暂无粮情数据！");
|
}
|
|
//返回数据封装
|
List<PGrainDto> dtoList = new ArrayList<>();
|
PGrainDto dto;
|
List<PPointDto> listPoints;
|
List<PDetailDto> listDetail;
|
PPointDto pointDto;
|
PDetailDto detailDto;
|
|
DepotConf depotConf;
|
GrainData data;
|
Depot depotData;
|
List<GrainData> result = new ArrayList<>();
|
for (Grain grain : list) {
|
depotConf = depotConfService.getCacheDepotConfByDepotId(grain.getCompanyId(), grain.getDepotId());
|
data = new GrainData();
|
BeanUtils.copyProperties(grain, data);
|
// 添加仓库信息
|
depotData = depotService.getCacheDepot(param.getCompanyId(), param.getDepotId());
|
GrainDataBuilder.updateGrainData(data, depotConf, depotData.getDepotType());
|
result.add(data);
|
}
|
for (GrainData grainData : result) {
|
dto = new PGrainDto();
|
dto.setDepotId(grainData.getDepotId());
|
dto.setDepotName(phoneUtil.getDepotName(authUser.getCompanyId(),dto.getDepotId()));
|
dto.setDepotType(depot.getDepotType());
|
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(",","-"));
|
if(StringUtils.isNotEmpty(grainData.getCableCir())){
|
dto.setCableCir(grainData.getCableCir().replaceAll(",", "-"));
|
}
|
|
listPoints = new ArrayList<>();
|
for (GrainPoint point : grainData.getListPoints()) {
|
pointDto = new PPointDto();
|
pointDto.setX(point.getX());
|
pointDto.setY(point.getY());
|
pointDto.setZ(point.getZ());
|
pointDto.setFz(point.getFz());
|
pointDto.setTemp(point.getTemp());
|
listPoints.add(pointDto);
|
}
|
dto.setPoints(listPoints);
|
|
listDetail = new ArrayList<>();
|
for (GrainLay lay : grainData.getListLays()) {
|
detailDto = new PDetailDto();
|
detailDto.setFz(lay.getFz());
|
detailDto.setFzName(lay.getFz() + "层");
|
detailDto.setTempMax(lay.getTempMax());
|
detailDto.setTempMin(lay.getTempMin());
|
detailDto.setTempAve(lay.getTempAve());
|
listDetail.add(detailDto);
|
}
|
dto.setDetails(listDetail);
|
|
dtoList.add(dto);
|
}
|
return PhoneRespUtil.success(dtoList, req);
|
}
|
}
|
