package com.thhy.mobile.modules.biz.pipeinfo.service.impl;
|
|
import com.alibaba.nacos.api.utils.StringUtils;
|
import com.thhy.general.common.BasicStatus;
|
import com.thhy.general.config.SysUserInfo;
|
import com.thhy.general.exception.BasicException;
|
import com.thhy.general.utils.DeepCopyUtils;
|
import com.thhy.general.utils.UserInfoUtils;
|
import com.thhy.mobile.modules.biz.cultivated.entity.PipeCultivated;
|
import com.thhy.mobile.modules.biz.cultivated.entity.PipeIntoListVo;
|
import com.thhy.mobile.modules.biz.pipecheckrecord.entity.PipeCheckRecord;
|
import com.thhy.mobile.modules.biz.pipecheckrecord.mapper.PipeCheckRecordMapper;
|
import com.thhy.mobile.modules.biz.pipeinfo.entity.*;
|
import com.thhy.mobile.modules.biz.pipeinfo.mapper.PipeInfoMapper;
|
import com.thhy.mobile.modules.biz.pipeinfo.service.PipeInfoService;
|
import com.thhy.mobile.modules.biz.repo.entity.RepoRecord;
|
import com.thhy.mobile.modules.biz.steelproduce.entity.ProduceDto;
|
import com.thhy.mobile.modules.biz.steelproduce.entity.ProduceMonthVo;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.io.Serializable;
|
import java.math.BigDecimal;
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
|
/**
|
* 服务实现类
|
* @author zhang_xiao_bo
|
* @since 2023-05-08 15:28:37
|
*/
|
@Service
|
public class PipeInfoServiceImpl implements PipeInfoService {
|
|
|
|
@Autowired
|
private PipeInfoMapper pipeInfoMapper;
|
|
@Autowired
|
private PipeCheckRecordMapper recordMapper;
|
|
public PipeInfo get(Serializable id){
|
return pipeInfoMapper.queryById(id);
|
}
|
|
public List<PipeInfo> findList(PipeInfo pipeInfo){
|
return pipeInfoMapper.findList(pipeInfo);
|
}
|
|
@Override
|
public List<PipeListVo> pipelist(PipeDto pipeDto) {
|
SysUserInfo sysUserInfo = UserInfoUtils.getInstance().getUserInfo();
|
if (pipeDto == null) pipeDto = new PipeDto();
|
pipeDto.setCompanyId(sysUserInfo.getCompanyId());
|
return pipeInfoMapper.pipelist(pipeDto);
|
}
|
|
@Override
|
public List<PipeListVo> pipeThingJsInfo(String token) {
|
SysUserInfo sysUserInfo = UserInfoUtils.getInstance().getUserInfo(token);
|
String companyId = sysUserInfo.getCompanyId();
|
List<PipeListVo> pipeListVos = pipeInfoMapper.pipeThingJsInfo(companyId);
|
for (PipeListVo pipeListVo :pipeListVos){
|
ModIdlThing modIdlThing = pipeInfoMapper.modIdlThing(pipeListVo.getModId());
|
SteelProduceThing steelProduceThing = pipeInfoMapper.steelProduceThing(pipeListVo.getProduceNumber());
|
pipeListVo.setModIdlThing(modIdlThing);
|
pipeListVo.setSteelProduceThing(steelProduceThing);
|
}
|
return pipeListVos;
|
}
|
|
@Override
|
public List<PipeListVo> pipelist(PipeDto pipeDto, String token) {
|
SysUserInfo sysUserInfo = UserInfoUtils.getInstance().getUserInfo(token);
|
if (pipeDto == null) pipeDto = new PipeDto();
|
pipeDto.setCompanyId(sysUserInfo.getCompanyId());
|
return pipeInfoMapper.pipelist(pipeDto);
|
}
|
|
/**
|
* 增加和修改
|
* @param pipeInfo
|
*/
|
@Transactional
|
public void addPipeInfo(PipeInfo pipeInfo){
|
if(pipeInfo.getPipeId() == null){
|
//增加操作
|
pipeInfoMapper.insert(pipeInfo);
|
}else{
|
//修改操作
|
pipeInfoMapper.update(pipeInfo);
|
}
|
|
}
|
|
/**
|
* 修改
|
* @param pipeInfo
|
*/
|
public void update(PipeInfo pipeInfo){
|
pipeInfoMapper.update(pipeInfo);
|
}
|
|
/**
|
* 删除
|
* @param pipeId
|
*/
|
public void delete(Serializable pipeId){
|
pipeInfoMapper.deletelogic(pipeId);
|
}
|
|
@Override
|
public PipeInfoVo checkHistory(PipeDto pipeDto) {
|
return pipeInfoMapper.queryPipeInfoByPipeId(pipeDto);
|
}
|
|
@Override
|
@Transactional
|
public void setscrap(ProblemInfoVo problemInfoVo) {
|
pipeInfoMapper.updateProblem(problemInfoVo);
|
//更新 只更新问题 不改状态
|
//pipeInfoMapper.updateCheckResult(new PipeInfo(pipeDto.getPipeId(),pipeDto.getCheckResult(),userInfo.getUserId()));
|
}
|
|
@Override
|
public ProblemInfoVo problemInfo(PipeDto pipeDto) {
|
ProblemInfoVo problemInfoVo = pipeInfoMapper.problemInfo(pipeDto);
|
String reasonName = "";
|
if(!StringUtils.isEmpty(problemInfoVo.getExistProblem())){
|
String[] strings = new String[]{problemInfoVo.getExistProblem()};
|
if(problemInfoVo.getExistProblem().contains(",")){
|
strings = problemInfoVo.getExistProblem().split(",");
|
}
|
reasonName = pipeInfoMapper.queryReasons(strings);
|
}
|
problemInfoVo.setExistProblem(reasonName+",备注："+(StringUtils.isEmpty(problemInfoVo.getRemark())?"无":problemInfoVo.getRemark()));
|
if ("3".equals(problemInfoVo.getCheckResult())) {
|
List<String> files = pipeInfoMapper.checkfiles(problemInfoVo.getPipeCheckId());
|
problemInfoVo.setFiles(files);
|
}
|
return problemInfoVo;
|
}
|
|
@Override
|
public List<ProduceMonthVo> pipeMonth(ProduceDto produceDto) {
|
SysUserInfo userInfo = UserInfoUtils.getInstance().getUserInfo();
|
if(produceDto==null)produceDto = new ProduceDto();
|
produceDto.setCompanyId(userInfo.getCompanyId());
|
List<ProduceMonthVo> produceMonthVoList = pipeInfoMapper.pipeMonthData(produceDto);
|
for(int i = 1;i<produceMonthVoList.size();i++){
|
ProduceMonthVo now = produceMonthVoList.get(i);
|
ProduceMonthVo before = produceMonthVoList.get(i-1);
|
if(before.getCount()==0){
|
now.setRate(new BigDecimal(0));
|
}else{
|
BigDecimal bigDecimal = new BigDecimal(now.getCount()-before.getCount()).divide(new BigDecimal(before.getCount()),2,BigDecimal.ROUND_HALF_UP);
|
now.setRate(bigDecimal.multiply(new BigDecimal(100)));
|
}
|
}
|
produceMonthVoList.remove(0);
|
return produceMonthVoList;
|
}
|
|
@Override
|
public List<ProduceMonthVo> pipeComparePlan(ProduceDto produceDto) {
|
SysUserInfo userInfo = UserInfoUtils.getInstance().getUserInfo();
|
if(produceDto==null)produceDto = new ProduceDto();
|
produceDto.setCompanyId(userInfo.getCompanyId());
|
List<ProduceMonthVo> produceMonthVoList = pipeInfoMapper.pipeCompare(produceDto);
|
|
produceMonthVoList.remove(0);
|
return produceMonthVoList;
|
}
|
|
@Override
|
public List<PipeListVo> h5Pipelist(PipeDto pipeDto) {
|
return pipeInfoMapper.pipelist(pipeDto);
|
}
|
|
@Override
|
public List<ScreenPipeCompare> pipePlanProduct(String token) {
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
SysUserInfo userInfo = UserInfoUtils.getInstance().getUserInfo(token);
|
List<ScreenPipeCompare> pipeCompareList = pipeInfoMapper.queryAllProject();
|
for(ScreenPipeCompare pipeCompare : pipeCompareList){
|
ProduceDto produceDto = new ProduceDto();
|
produceDto.setCompanyId(userInfo.getCompanyId());
|
produceDto.setProId(pipeCompare.getProId());
|
try {
|
produceDto.setStartTime(sdf.parse("2023-01-01 00:00:00"));
|
produceDto.setEndTime(sdf.parse("2023-12-31 23:59:59"));
|
} catch (ParseException e) {
|
throw new RuntimeException(e);
|
}
|
List<ProduceMonthVo> produceMonthVoList = pipeInfoMapper.pipeCompareByPro(produceDto);
|
if (produceMonthVoList.size()>0) {
|
produceMonthVoList.remove(0);
|
}
|
pipeCompare.setProduceMonthVoList(produceMonthVoList);
|
}
|
return pipeCompareList;
|
}
|
|
@Override
|
public List<HashMap<String, Object>> TableHeader() {
|
return pipeInfoMapper.TableHeader();
|
}
|
|
@Override
|
public List<HashMap<String, Object>> queryMaterias(String companyId) {
|
return pipeInfoMapper.queryMaterias(companyId);
|
}
|
|
@Override
|
public List<MaterialInfo> materialTotalStock(String companyId) {
|
return pipeInfoMapper.materialTotalStock(companyId);
|
}
|
|
@Override
|
public void updateRingNum(PipeInfo pipeInfo) {
|
int count = pipeInfoMapper.countByRingNum(pipeInfo.getRingNum());
|
if(count>0){
|
throw new BasicException(BasicStatus.RING_NUM_IS_REPEAT);
|
}
|
PipeInfo pipeInfo1 = pipeInfoMapper.queryByPipeNum(pipeInfo.getPipeNum());
|
pipeInfoMapper.updateRingNum(pipeInfo1.getRingNum(), pipeInfo.getRingNum());
|
}
|
|
@Override
|
public Map<String, Object> updateDateInfo(PipeInfo pipeInfo) {
|
Map<String, Object> map = new HashMap<>();
|
PipeInfo pinfos = pipeInfoMapper.queryByPipeNum(pipeInfo.getPipeNum());
|
|
Boolean result = pipeInfoMapper.compelteByRingNumAndPro(pinfos.getRingNum(), pinfos.getProId());
|
if(result==null||!result){
|
throw new BasicException(BasicStatus.RING_NOT_COMPLETE);
|
}
|
List<PipeIntoListVo> intoListVos = pipeInfoMapper.queryByRingNumAndPro(pinfos.getRingNum(),pinfos.getProId());
|
|
PipeInfo pinfo = pipeInfoMapper.queryByPipeNum(intoListVos.get(0).getPipeNum());
|
if(pinfo.getCheckResult().equals(0)){
|
//水养
|
//PipeCultivated pipeCultivated = pipeInfoMapper.queryWaterTimeByPipeNum(pipeInfo.getPipeNum());
|
|
}
|
|
map.put("inModTime",pinfo.getIntoModTime());
|
map.put("outModTime",pinfo.getOutModTime());
|
map.put("placingInTime",pinfo.getPlacingInTime());
|
map.put("placingOutTime",pinfo.getPlacingOutTime());
|
map.put("pouringTime",pinfo.getPouringTime());
|
|
map.put("checkTime",pinfo.getCheckTime());
|
|
PipeCultivated pipeCultivated = pipeInfoMapper.queryWaterTimeByPipeNum(pipeInfo.getPipeNum());
|
map.put("inWaterFlag",false);
|
map.put("OutWaterFlag",false);
|
map.put("inRepoFlag",false);
|
if(pipeCultivated!=null){
|
map.put("inWaterFlag",true);
|
map.put("inWaterTime",pipeCultivated.getCreateTime());
|
|
if(pipeCultivated.getOutWater()==2){
|
map.put("OutWaterFlag",true);
|
map.put("OutWaterTime",pipeCultivated.getOutTime());
|
RepoRecord repoRecord = pipeInfoMapper.queryRepoDate(pipeInfo.getPipeNum());
|
if(repoRecord!=null){
|
map.put("inRepoFlag",true);
|
map.put("inRepoTime",repoRecord.getCreateTime());
|
}
|
return map;
|
}else{
|
return map;
|
}
|
}else{
|
return map;
|
}
|
}
|
|
@Transactional
|
@Override
|
public void updatePipeDate(PipeDateDto pipeDateDto) {
|
PipeInfo pinfo = pipeInfoMapper.queryByPipeNum(pipeDateDto.getPipeNum());
|
|
Boolean result = pipeInfoMapper.compelteByRingNumAndPro(pinfo.getRingNum(), pinfo.getProId());
|
if(result==null||!result){
|
throw new BasicException(BasicStatus.RING_NOT_COMPLETE);
|
}
|
List<PipeIntoListVo> intoListVos = pipeInfoMapper.queryByRingNumAndPro(pinfo.getRingNum(),pinfo.getProId());
|
|
for(int i=0;i<intoListVos.size();i++){
|
PipeDateDto pd = createNewDate(pipeDateDto,i);
|
pd.setPipeNum(intoListVos.get(i).getPipeNum());
|
pipeInfoMapper.updatePipeDateByNum(pd);
|
//入模
|
}
|
PipeCultivated pipeCultivated = pipeInfoMapper.queryWaterTimeByPipeNum(pipeDateDto.getPipeNum());
|
if (pipeCultivated!=null) {
|
pipeCultivated.setCreateTime(pipeDateDto.getInWaterTime());
|
pipeInfoMapper.updateInWaterTime(pipeCultivated);
|
if(pipeCultivated.getOutWater()==2){
|
pipeCultivated.setOutTime(pipeDateDto.getOutWaterTime());
|
pipeInfoMapper.updateOutWaterTime(pipeCultivated);
|
}
|
}
|
|
RepoRecord repoRecord = pipeInfoMapper.queryRepoDate(pipeDateDto.getPipeNum());
|
|
if (repoRecord!=null) {
|
repoRecord.setCreateTime(pipeDateDto.getInRepoTime());
|
pipeInfoMapper.updateInRepoTime(repoRecord);
|
}
|
}
|
|
public PipeDateDto createNewDate(PipeDateDto pipeDateDto,int index){
|
PipeDateDto pd = new PipeDateDto();
|
if(index==0){
|
DeepCopyUtils.copy(pipeDateDto,pd);
|
}else{
|
pd.setInModTime(addMiu(pipeDateDto.getInModTime(),5*index));
|
pd.setOutModTime(addMiu(pipeDateDto.getOutModTime(),5*index));
|
pd.setPouringTime(addMiu(pipeDateDto.getPouringTime(),5*index));
|
pd.setCheckTime(addMiu(pipeDateDto.getCheckTime(),5*index));
|
pd.setPlacingInTime(addMiu(pipeDateDto.getPlacingInTime(),5*index));
|
pd.setPlacingOutTime(addMiu(pipeDateDto.getPlacingOutTime(),5*index));
|
if (pipeDateDto.getInRepoTime()!=null) {
|
pd.setInRepoTime(addMiu(pipeDateDto.getInRepoTime(),5*index));
|
}
|
if (pipeDateDto.getInWaterTime()!=null) {
|
pd.setInWaterTime(addMiu(pipeDateDto.getInWaterTime(),5*index));
|
}
|
if (pipeDateDto.getOutWaterTime()!=null) {
|
pd.setOutWaterTime(addMiu(pipeDateDto.getOutWaterTime(),5*index));
|
}
|
}
|
return pd;
|
}
|
|
public Date addMiu(Date oldTime,int amount){
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(oldTime);
|
calendar.add(Calendar.MINUTE,amount);
|
return calendar.getTime();
|
}
|
@Override
|
public Map<String, Object> materialInfo() {
|
List<MaterialThingDto> materialThingDtos1 = pipeInfoMapper.materialInfo();
|
List<MaterialThingDto> materialThingDtos2 = pipeInfoMapper.materialInfoTwo();
|
HashMap<String, Object> map = new HashMap<>();
|
map.put("materialThingDtos1",materialThingDtos1);
|
map.put("materialThingDtos2",materialThingDtos2);
|
return map;
|
}
|
|
@Override
|
public List<MaterialThingNumDto> materialNumInfo() {
|
List<MaterialThingNumDto> materialThingNumDtos = pipeInfoMapper.materialNumInfo();
|
|
return materialThingNumDtos;
|
}
|
}
|
