feat(pocket): 新增历史数据查询功能

- 创建历史数据实体类Klptcm1ProPlantStateHistory历史
- 实现数据业务逻辑接口与实现类
- 添加历史数据Mapper及XML映射文件
- 提供历史数据分页查询与列表查询接口- 构建历史数据查询条件封装方法- 注解历史数据Controller并暴露查询接口
- 移除Vo类中冗余的JSON格式化与Excel字典转换注解
This commit is contained in:
JR
2025-10-27 18:29:21 +08:00
parent bbecc3c55f
commit 07582bbdb0
17 changed files with 1291 additions and 109 deletions

View File

@@ -0,0 +1,34 @@
package com.klp.pocket.service;
import com.klp.pocket.domain.vo.Klptcm1ProPlantStateHistoryVo;
import com.klp.pocket.domain.bo.Klptcm1ProPlantStateHistoryBo;
import com.klp.common.core.page.TableDataInfo;
import com.klp.common.core.domain.PageQuery;
import java.util.Date;
import java.util.List;
/**
* 历史Service接口
*
* @author klp
* @date 2025-10-27
*/
public interface IKlptcm1ProPlantStateHistoryService {
/**
* 查询历史
*/
Klptcm1ProPlantStateHistoryVo queryById(Date INSDATE);
/**
* 查询历史列表
*/
TableDataInfo<Klptcm1ProPlantStateHistoryVo> queryPageList(Klptcm1ProPlantStateHistoryBo bo, PageQuery pageQuery);
/**
* 查询历史列表
*/
List<Klptcm1ProPlantStateHistoryVo> queryList(Klptcm1ProPlantStateHistoryBo bo);
}

View File

@@ -0,0 +1,32 @@
package com.klp.pocket.service;
import com.klp.pocket.domain.vo.Klptcm1ProStoppageVo;
import com.klp.pocket.domain.bo.Klptcm1ProStoppageBo;
import com.klp.common.core.page.TableDataInfo;
import com.klp.common.core.domain.PageQuery;
import java.util.List;
/**
* 停机Service接口
*
* @author klp
* @date 2025-10-27
*/
public interface IKlptcm1ProStoppageService {
/**
* 查询停机
*/
Klptcm1ProStoppageVo queryById(Long STOPID);
/**
* 查询停机列表
*/
TableDataInfo<Klptcm1ProStoppageVo> queryPageList(Klptcm1ProStoppageBo bo, PageQuery pageQuery);
/**
* 查询停机列表
*/
List<Klptcm1ProStoppageVo> queryList(Klptcm1ProStoppageBo bo);
}

View File

@@ -0,0 +1,172 @@
package com.klp.pocket.service.impl;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.klp.common.core.page.TableDataInfo;
import com.klp.common.core.domain.PageQuery;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import com.klp.pocket.domain.bo.Klptcm1ProPlantStateHistoryBo;
import com.klp.pocket.domain.vo.Klptcm1ProPlantStateHistoryVo;
import com.klp.pocket.domain.Klptcm1ProPlantStateHistory;
import com.klp.pocket.mapper.Klptcm1ProPlantStateHistoryMapper;
import com.klp.pocket.service.IKlptcm1ProPlantStateHistoryService;
import java.util.Date;
import java.util.List;
import java.util.Map;
/**
* 历史Service业务层处理
*
* @author klp
* @date 2025-10-27
*/
@RequiredArgsConstructor
@DS("slave")
@Service
public class Klptcm1ProPlantStateHistoryServiceImpl implements IKlptcm1ProPlantStateHistoryService {
private final Klptcm1ProPlantStateHistoryMapper baseMapper;
/**
* 查询历史
*/
@Override
public Klptcm1ProPlantStateHistoryVo queryById(Date INSDATE){
return baseMapper.selectVoById(INSDATE);
}
/**
* 查询历史列表
*/
@Override
public TableDataInfo<Klptcm1ProPlantStateHistoryVo> queryPageList(Klptcm1ProPlantStateHistoryBo bo, PageQuery pageQuery) {
LambdaQueryWrapper<Klptcm1ProPlantStateHistory> lqw = buildQueryWrapper(bo);
Page<Klptcm1ProPlantStateHistoryVo> result = baseMapper.selectVoPage(pageQuery.build(), lqw);
return TableDataInfo.build(result);
}
/**
* 查询历史列表
*/
@Override
public List<Klptcm1ProPlantStateHistoryVo> queryList(Klptcm1ProPlantStateHistoryBo bo) {
LambdaQueryWrapper<Klptcm1ProPlantStateHistory> lqw = buildQueryWrapper(bo);
return baseMapper.selectVoList(lqw);
}
private LambdaQueryWrapper<Klptcm1ProPlantStateHistory> buildQueryWrapper(Klptcm1ProPlantStateHistoryBo bo) {
Map<String, Object> params = bo.getParams();
LambdaQueryWrapper<Klptcm1ProPlantStateHistory> lqw = Wrappers.lambdaQuery();
lqw.eq(bo.getINSDATE() != null, Klptcm1ProPlantStateHistory::getInsdate, bo.getINSDATE());
lqw.eq(bo.getYEAR() != null, Klptcm1ProPlantStateHistory::getYear, bo.getYEAR());
lqw.eq(bo.getMONTH() != null, Klptcm1ProPlantStateHistory::getMonth, bo.getMONTH());
lqw.eq(bo.getDAY() != null, Klptcm1ProPlantStateHistory::getDay, bo.getDAY());
lqw.eq(bo.getHOUR() != null, Klptcm1ProPlantStateHistory::getHour, bo.getHOUR());
lqw.eq(bo.getMINUTE() != null, Klptcm1ProPlantStateHistory::getMinute, bo.getMINUTE());
lqw.eq(bo.getTYPE() != null, Klptcm1ProPlantStateHistory::getType, bo.getTYPE());
lqw.eq(bo.getVALUE1() != null, Klptcm1ProPlantStateHistory::getValue1, bo.getVALUE1());
lqw.eq(bo.getVALUE2() != null, Klptcm1ProPlantStateHistory::getValue2, bo.getVALUE2());
lqw.eq(bo.getVALUE3() != null, Klptcm1ProPlantStateHistory::getValue3, bo.getVALUE3());
lqw.eq(bo.getVALUE4() != null, Klptcm1ProPlantStateHistory::getValue4, bo.getVALUE4());
lqw.eq(bo.getVALUE5() != null, Klptcm1ProPlantStateHistory::getValue5, bo.getVALUE5());
lqw.eq(bo.getVALUE6() != null, Klptcm1ProPlantStateHistory::getValue6, bo.getVALUE6());
lqw.eq(bo.getVALUE7() != null, Klptcm1ProPlantStateHistory::getValue7, bo.getVALUE7());
lqw.eq(bo.getVALUE8() != null, Klptcm1ProPlantStateHistory::getValue8, bo.getVALUE8());
lqw.eq(bo.getVALUE9() != null, Klptcm1ProPlantStateHistory::getValue9, bo.getVALUE9());
lqw.eq(bo.getVALUE10() != null, Klptcm1ProPlantStateHistory::getValue10, bo.getVALUE10());
lqw.eq(bo.getVALUE11() != null, Klptcm1ProPlantStateHistory::getValue11, bo.getVALUE11());
lqw.eq(bo.getVALUE12() != null, Klptcm1ProPlantStateHistory::getValue12, bo.getVALUE12());
lqw.eq(bo.getVALUE13() != null, Klptcm1ProPlantStateHistory::getValue13, bo.getVALUE13());
lqw.eq(bo.getVALUE14() != null, Klptcm1ProPlantStateHistory::getValue14, bo.getVALUE14());
lqw.eq(bo.getVALUE15() != null, Klptcm1ProPlantStateHistory::getValue15, bo.getVALUE15());
lqw.eq(bo.getVALUE16() != null, Klptcm1ProPlantStateHistory::getValue16, bo.getVALUE16());
lqw.eq(bo.getVALUE17() != null, Klptcm1ProPlantStateHistory::getValue17, bo.getVALUE17());
lqw.eq(bo.getVALUE18() != null, Klptcm1ProPlantStateHistory::getValue18, bo.getVALUE18());
lqw.eq(bo.getVALUE19() != null, Klptcm1ProPlantStateHistory::getValue19, bo.getVALUE19());
lqw.eq(bo.getVALUE20() != null, Klptcm1ProPlantStateHistory::getValue20, bo.getVALUE20());
lqw.eq(bo.getVALUE21() != null, Klptcm1ProPlantStateHistory::getValue21, bo.getVALUE21());
lqw.eq(bo.getVALUE22() != null, Klptcm1ProPlantStateHistory::getValue22, bo.getVALUE22());
lqw.eq(bo.getVALUE23() != null, Klptcm1ProPlantStateHistory::getValue23, bo.getVALUE23());
lqw.eq(bo.getVALUE24() != null, Klptcm1ProPlantStateHistory::getValue24, bo.getVALUE24());
lqw.eq(bo.getVALUE25() != null, Klptcm1ProPlantStateHistory::getValue25, bo.getVALUE25());
lqw.eq(bo.getVALUE26() != null, Klptcm1ProPlantStateHistory::getValue26, bo.getVALUE26());
lqw.eq(bo.getVALUE27() != null, Klptcm1ProPlantStateHistory::getValue27, bo.getVALUE27());
lqw.eq(bo.getVALUE28() != null, Klptcm1ProPlantStateHistory::getValue28, bo.getVALUE28());
lqw.eq(bo.getVALUE29() != null, Klptcm1ProPlantStateHistory::getValue29, bo.getVALUE29());
lqw.eq(bo.getVALUE30() != null, Klptcm1ProPlantStateHistory::getValue30, bo.getVALUE30());
lqw.eq(bo.getVALUE31() != null, Klptcm1ProPlantStateHistory::getValue31, bo.getVALUE31());
lqw.eq(bo.getVALUE32() != null, Klptcm1ProPlantStateHistory::getValue32, bo.getVALUE32());
lqw.eq(bo.getVALUE33() != null, Klptcm1ProPlantStateHistory::getValue33, bo.getVALUE33());
lqw.eq(bo.getVALUE34() != null, Klptcm1ProPlantStateHistory::getValue34, bo.getVALUE34());
lqw.eq(bo.getVALUE35() != null, Klptcm1ProPlantStateHistory::getValue35, bo.getVALUE35());
lqw.eq(bo.getVALUE36() != null, Klptcm1ProPlantStateHistory::getValue36, bo.getVALUE36());
lqw.eq(bo.getVALUE37() != null, Klptcm1ProPlantStateHistory::getValue37, bo.getVALUE37());
lqw.eq(bo.getVALUE38() != null, Klptcm1ProPlantStateHistory::getValue38, bo.getVALUE38());
lqw.eq(bo.getVALUE39() != null, Klptcm1ProPlantStateHistory::getValue39, bo.getVALUE39());
lqw.eq(bo.getVALUE40() != null, Klptcm1ProPlantStateHistory::getValue40, bo.getVALUE40());
lqw.eq(bo.getVALUE41() != null, Klptcm1ProPlantStateHistory::getValue41, bo.getVALUE41());
lqw.eq(bo.getVALUE42() != null, Klptcm1ProPlantStateHistory::getValue42, bo.getVALUE42());
lqw.eq(bo.getVALUE43() != null, Klptcm1ProPlantStateHistory::getValue43, bo.getVALUE43());
lqw.eq(bo.getVALUE44() != null, Klptcm1ProPlantStateHistory::getValue44, bo.getVALUE44());
lqw.eq(bo.getVALUE45() != null, Klptcm1ProPlantStateHistory::getValue45, bo.getVALUE45());
lqw.eq(bo.getVALUE46() != null, Klptcm1ProPlantStateHistory::getValue46, bo.getVALUE46());
lqw.eq(bo.getVALUE47() != null, Klptcm1ProPlantStateHistory::getValue47, bo.getVALUE47());
lqw.eq(bo.getVALUE48() != null, Klptcm1ProPlantStateHistory::getValue48, bo.getVALUE48());
lqw.eq(bo.getVALUE49() != null, Klptcm1ProPlantStateHistory::getValue49, bo.getVALUE49());
lqw.eq(bo.getVALUE50() != null, Klptcm1ProPlantStateHistory::getValue50, bo.getVALUE50());
lqw.eq(bo.getVALUE51() != null, Klptcm1ProPlantStateHistory::getValue51, bo.getVALUE51());
lqw.eq(bo.getVALUE52() != null, Klptcm1ProPlantStateHistory::getValue52, bo.getVALUE52());
lqw.eq(bo.getVALUE53() != null, Klptcm1ProPlantStateHistory::getValue53, bo.getVALUE53());
lqw.eq(bo.getVALUE54() != null, Klptcm1ProPlantStateHistory::getValue54, bo.getVALUE54());
lqw.eq(bo.getVALUE55() != null, Klptcm1ProPlantStateHistory::getValue55, bo.getVALUE55());
lqw.eq(bo.getVALUE56() != null, Klptcm1ProPlantStateHistory::getValue56, bo.getVALUE56());
lqw.eq(bo.getVALUE57() != null, Klptcm1ProPlantStateHistory::getValue57, bo.getVALUE57());
lqw.eq(bo.getVALUE58() != null, Klptcm1ProPlantStateHistory::getValue58, bo.getVALUE58());
lqw.eq(bo.getVALUE59() != null, Klptcm1ProPlantStateHistory::getValue59, bo.getVALUE59());
lqw.eq(bo.getVALUE60() != null, Klptcm1ProPlantStateHistory::getValue60, bo.getVALUE60());
lqw.eq(bo.getVALUE61() != null, Klptcm1ProPlantStateHistory::getValue61, bo.getVALUE61());
lqw.eq(bo.getVALUE62() != null, Klptcm1ProPlantStateHistory::getValue62, bo.getVALUE62());
lqw.eq(bo.getVALUE63() != null, Klptcm1ProPlantStateHistory::getValue63, bo.getVALUE63());
lqw.eq(bo.getVALUE64() != null, Klptcm1ProPlantStateHistory::getValue64, bo.getVALUE64());
lqw.eq(bo.getVALUE65() != null, Klptcm1ProPlantStateHistory::getValue65, bo.getVALUE65());
lqw.eq(bo.getVALUE66() != null, Klptcm1ProPlantStateHistory::getValue66, bo.getVALUE66());
lqw.eq(bo.getVALUE67() != null, Klptcm1ProPlantStateHistory::getValue67, bo.getVALUE67());
lqw.eq(bo.getVALUE68() != null, Klptcm1ProPlantStateHistory::getValue68, bo.getVALUE68());
lqw.eq(bo.getVALUE69() != null, Klptcm1ProPlantStateHistory::getValue69, bo.getVALUE69());
lqw.eq(bo.getVALUE70() != null, Klptcm1ProPlantStateHistory::getValue70, bo.getVALUE70());
lqw.eq(bo.getVALUE71() != null, Klptcm1ProPlantStateHistory::getValue71, bo.getVALUE71());
lqw.eq(bo.getVALUE72() != null, Klptcm1ProPlantStateHistory::getValue72, bo.getVALUE72());
lqw.eq(bo.getVALUE73() != null, Klptcm1ProPlantStateHistory::getValue73, bo.getVALUE73());
lqw.eq(bo.getVALUE74() != null, Klptcm1ProPlantStateHistory::getValue74, bo.getVALUE74());
lqw.eq(bo.getVALUE75() != null, Klptcm1ProPlantStateHistory::getValue75, bo.getVALUE75());
lqw.eq(bo.getVALUE76() != null, Klptcm1ProPlantStateHistory::getValue76, bo.getVALUE76());
lqw.eq(bo.getVALUE77() != null, Klptcm1ProPlantStateHistory::getValue77, bo.getVALUE77());
lqw.eq(bo.getVALUE78() != null, Klptcm1ProPlantStateHistory::getValue78, bo.getVALUE78());
lqw.eq(bo.getVALUE79() != null, Klptcm1ProPlantStateHistory::getValue79, bo.getVALUE79());
lqw.eq(bo.getVALUE80() != null, Klptcm1ProPlantStateHistory::getValue80, bo.getVALUE80());
lqw.eq(bo.getVALUE81() != null, Klptcm1ProPlantStateHistory::getValue81, bo.getVALUE81());
lqw.eq(bo.getVALUE82() != null, Klptcm1ProPlantStateHistory::getValue82, bo.getVALUE82());
lqw.eq(bo.getVALUE83() != null, Klptcm1ProPlantStateHistory::getValue83, bo.getVALUE83());
lqw.eq(bo.getVALUE84() != null, Klptcm1ProPlantStateHistory::getValue84, bo.getVALUE84());
lqw.eq(bo.getVALUE85() != null, Klptcm1ProPlantStateHistory::getValue85, bo.getVALUE85());
lqw.eq(bo.getVALUE86() != null, Klptcm1ProPlantStateHistory::getValue86, bo.getVALUE86());
lqw.eq(bo.getVALUE87() != null, Klptcm1ProPlantStateHistory::getValue87, bo.getVALUE87());
lqw.eq(bo.getVALUE88() != null, Klptcm1ProPlantStateHistory::getValue88, bo.getVALUE88());
lqw.eq(bo.getVALUE89() != null, Klptcm1ProPlantStateHistory::getValue89, bo.getVALUE89());
lqw.eq(bo.getVALUE90() != null, Klptcm1ProPlantStateHistory::getValue90, bo.getVALUE90());
lqw.eq(bo.getVALUE91() != null, Klptcm1ProPlantStateHistory::getValue91, bo.getVALUE91());
lqw.eq(bo.getVALUE92() != null, Klptcm1ProPlantStateHistory::getValue92, bo.getVALUE92());
lqw.eq(bo.getVALUE93() != null, Klptcm1ProPlantStateHistory::getValue93, bo.getVALUE93());
lqw.eq(bo.getVALUE94() != null, Klptcm1ProPlantStateHistory::getValue94, bo.getVALUE94());
lqw.eq(bo.getVALUE95() != null, Klptcm1ProPlantStateHistory::getValue95, bo.getVALUE95());
lqw.eq(bo.getVALUE96() != null, Klptcm1ProPlantStateHistory::getValue96, bo.getVALUE96());
lqw.eq(bo.getVALUE97() != null, Klptcm1ProPlantStateHistory::getValue97, bo.getVALUE97());
lqw.eq(bo.getVALUE98() != null, Klptcm1ProPlantStateHistory::getValue98, bo.getVALUE98());
lqw.eq(bo.getVALUE99() != null, Klptcm1ProPlantStateHistory::getValue99, bo.getVALUE99());
return lqw;
}
}

View File

@@ -0,0 +1,80 @@
package com.klp.pocket.service.impl;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.klp.common.core.page.TableDataInfo;
import com.klp.common.core.domain.PageQuery;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.klp.common.utils.StringUtils;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import com.klp.pocket.domain.bo.Klptcm1ProStoppageBo;
import com.klp.pocket.domain.vo.Klptcm1ProStoppageVo;
import com.klp.pocket.domain.Klptcm1ProStoppage;
import com.klp.pocket.mapper.Klptcm1ProStoppageMapper;
import com.klp.pocket.service.IKlptcm1ProStoppageService;
import java.util.List;
import java.util.Map;
/**
* 停机Service业务层处理
*
* @author klp
* @date 2025-10-27
*/
@RequiredArgsConstructor
@DS("slave")
@Service
public class Klptcm1ProStoppageServiceImpl implements IKlptcm1ProStoppageService {
private final Klptcm1ProStoppageMapper baseMapper;
/**
* 查询停机
*/
@Override
public Klptcm1ProStoppageVo queryById(Long STOPID){
return baseMapper.selectVoById(STOPID);
}
/**
* 查询停机列表
*/
@Override
public TableDataInfo<Klptcm1ProStoppageVo> queryPageList(Klptcm1ProStoppageBo bo, PageQuery pageQuery) {
LambdaQueryWrapper<Klptcm1ProStoppage> lqw = buildQueryWrapper(bo);
Page<Klptcm1ProStoppageVo> result = baseMapper.selectVoPage(pageQuery.build(), lqw);
return TableDataInfo.build(result);
}
/**
* 查询停机列表
*/
@Override
public List<Klptcm1ProStoppageVo> queryList(Klptcm1ProStoppageBo bo) {
LambdaQueryWrapper<Klptcm1ProStoppage> lqw = buildQueryWrapper(bo);
return baseMapper.selectVoList(lqw);
}
private LambdaQueryWrapper<Klptcm1ProStoppage> buildQueryWrapper(Klptcm1ProStoppageBo bo) {
Map<String, Object> params = bo.getParams();
LambdaQueryWrapper<Klptcm1ProStoppage> lqw = Wrappers.lambdaQuery();
lqw.eq(bo.getSTOPID() != null, Klptcm1ProStoppage::getStopid, bo.getSTOPID());
lqw.eq(StringUtils.isNotBlank(bo.getENCOILID()), Klptcm1ProStoppage::getEncoilid, bo.getENCOILID());
lqw.eq(StringUtils.isNotBlank(bo.getSHIFT()), Klptcm1ProStoppage::getShift, bo.getSHIFT());
lqw.eq(StringUtils.isNotBlank(bo.getCREW()), Klptcm1ProStoppage::getCrew, bo.getCREW());
lqw.eq(StringUtils.isNotBlank(bo.getAREA()), Klptcm1ProStoppage::getArea, bo.getAREA());
lqw.eq(StringUtils.isNotBlank(bo.getUNIT()), Klptcm1ProStoppage::getUnit, bo.getUNIT());
lqw.eq(StringUtils.isNotBlank(bo.getSETON()), Klptcm1ProStoppage::getSeton, bo.getSETON());
lqw.eq(StringUtils.isNotBlank(bo.getREMARK()), Klptcm1ProStoppage::getRemark, bo.getREMARK());
lqw.eq(bo.getStartDate() != null, Klptcm1ProStoppage::getStartDate, bo.getStartDate());
lqw.eq(bo.getEndDate() != null, Klptcm1ProStoppage::getEndDate, bo.getEndDate());
lqw.eq(bo.getDURATION() != null, Klptcm1ProStoppage::getDuration, bo.getDURATION());
lqw.eq(bo.getInsDate() != null, Klptcm1ProStoppage::getInsDate, bo.getInsDate());
lqw.eq(StringUtils.isNotBlank(bo.getStopType()), Klptcm1ProStoppage::getStopType, bo.getStopType());
return lqw;
}
}