cvt功能开发
This commit is contained in:
hzj
@@ -0,0 +1,116 @@
|
||||
package com.njcn.device.pq.controller;
|
||||
|
||||
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
||||
import com.njcn.common.pojo.annotation.OperateInfo;
|
||||
import com.njcn.common.pojo.constant.OperateType;
|
||||
import com.njcn.common.pojo.enums.common.LogEnum;
|
||||
import com.njcn.common.pojo.enums.response.CommonResponseEnum;
|
||||
import com.njcn.common.pojo.response.HttpResult;
|
||||
import com.njcn.common.utils.HttpResultUtil;
|
||||
import com.njcn.device.pq.pojo.dto.CvtHarmonicCorrectionFactorsDTO;
|
||||
import com.njcn.device.pq.pojo.param.CvtHarmonicCorrectionFactorsParam;
|
||||
import com.njcn.device.pq.pojo.param.NodeParam;
|
||||
import com.njcn.device.pq.pojo.po.CvtHarmonicCorrectionFactors;
|
||||
import com.njcn.device.pq.pojo.vo.CvtHarmonicCorrectionFactorsVO;
|
||||
import com.njcn.device.pq.service.CvtHarmonicCorrectionFactorsService;
|
||||
import com.njcn.web.controller.BaseController;
|
||||
import io.swagger.annotations.Api;
|
||||
import io.swagger.annotations.ApiImplicitParam;
|
||||
import io.swagger.annotations.ApiOperation;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.beans.BeanUtils;
|
||||
import org.springframework.validation.annotation.Validated;
|
||||
import org.springframework.web.bind.annotation.*;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* Description:
|
||||
* Date: 2025/02/10 下午 1:53【需求编号】
|
||||
*
|
||||
* @author clam
|
||||
* @version V1.0.0
|
||||
*/
|
||||
@Validated
|
||||
@Slf4j
|
||||
@Api(tags = "cvt系数配置")
|
||||
@RestController
|
||||
@RequestMapping("/cvt")
|
||||
@RequiredArgsConstructor
|
||||
public class CvtHarmonicCorrectionFactorsController extends BaseController {
|
||||
|
||||
private final CvtHarmonicCorrectionFactorsService cvtHarmonicCorrectionFactorsService;
|
||||
|
||||
@OperateInfo(info = LogEnum.BUSINESS_COMMON,operateType = OperateType.ADD)
|
||||
@ApiOperation("新增cvt系数")
|
||||
@ApiImplicitParam(value = "cvt系数信息",name = "cvtHarmonicCorrectionFactorsParam",required = true)
|
||||
@PostMapping("add")
|
||||
public HttpResult<Boolean> add(@Validated @RequestBody CvtHarmonicCorrectionFactorsParam cvtHarmonicCorrectionFactorsParam){
|
||||
String methodDescribe = getMethodDescribe("add");
|
||||
boolean result = cvtHarmonicCorrectionFactorsService.add(cvtHarmonicCorrectionFactorsParam);
|
||||
if (result){
|
||||
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, true, methodDescribe);
|
||||
} else {
|
||||
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.FAIL, false, methodDescribe);
|
||||
}
|
||||
}
|
||||
|
||||
@OperateInfo(info = LogEnum.BUSINESS_COMMON,operateType = OperateType.ADD)
|
||||
@ApiOperation("修改cvt系数")
|
||||
@ApiImplicitParam(value = "cvt系数信息",name = "updateParam",required = true)
|
||||
@PostMapping("updateCvt")
|
||||
public HttpResult<Boolean> updateCvt(@Validated @RequestBody CvtHarmonicCorrectionFactorsParam.CvtHarmonicCorrectionFactorsParamUpdateParam updateParam){
|
||||
String methodDescribe = getMethodDescribe("updateCvt");
|
||||
boolean result = cvtHarmonicCorrectionFactorsService.updateCvt(updateParam);
|
||||
if (result){
|
||||
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, true, methodDescribe);
|
||||
} else {
|
||||
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.FAIL, false, methodDescribe);
|
||||
}
|
||||
}
|
||||
|
||||
@OperateInfo(info = LogEnum.BUSINESS_COMMON,operateType = OperateType.ADD)
|
||||
@ApiOperation("分页查询")
|
||||
@ApiImplicitParam(value = "cvt系数信息",name = "queryParam",required = true)
|
||||
@PostMapping("queryPage")
|
||||
public HttpResult<Page<CvtHarmonicCorrectionFactorsVO>> queryPage(@Validated @RequestBody CvtHarmonicCorrectionFactorsParam.CvtHarmonicCorrectionFactorsParamQueryParam queryParam){
|
||||
String methodDescribe = getMethodDescribe("queryPage");
|
||||
Page<CvtHarmonicCorrectionFactorsVO> result = cvtHarmonicCorrectionFactorsService.queryPage(queryParam);
|
||||
|
||||
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, result, methodDescribe);
|
||||
|
||||
}
|
||||
|
||||
@OperateInfo(info = LogEnum.BUSINESS_COMMON,operateType = OperateType.ADD)
|
||||
@ApiOperation("列表查询")
|
||||
@PostMapping("queryList")
|
||||
public HttpResult<List<CvtHarmonicCorrectionFactorsDTO>> queryList( @Validated @RequestBody CvtHarmonicCorrectionFactorsParam.CvtHarmonicCorrectionFactorsParamQueryParam queryParam){
|
||||
String methodDescribe = getMethodDescribe("queryList");
|
||||
List<CvtHarmonicCorrectionFactorsDTO> result = cvtHarmonicCorrectionFactorsService.queryList(queryParam);
|
||||
|
||||
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, result, methodDescribe);
|
||||
|
||||
}
|
||||
|
||||
@OperateInfo(info = LogEnum.BUSINESS_COMMON,operateType = OperateType.ADD)
|
||||
@ApiOperation("根据id查询")
|
||||
@PostMapping("queryById")
|
||||
public HttpResult<CvtHarmonicCorrectionFactorsDTO> queryById( @RequestParam String id){
|
||||
String methodDescribe = getMethodDescribe("queryById");
|
||||
CvtHarmonicCorrectionFactorsDTO result = new CvtHarmonicCorrectionFactorsDTO();
|
||||
CvtHarmonicCorrectionFactors cvt = cvtHarmonicCorrectionFactorsService.getById(id);
|
||||
BeanUtils.copyProperties(result,cvt);
|
||||
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, result, methodDescribe);
|
||||
|
||||
}
|
||||
@OperateInfo(info = LogEnum.BUSINESS_COMMON,operateType = OperateType.ADD)
|
||||
@ApiOperation("根据id删除")
|
||||
@PostMapping("deleteById")
|
||||
public HttpResult<Boolean> deleteById( @RequestParam String id){
|
||||
String methodDescribe = getMethodDescribe("deleteById");
|
||||
boolean result = cvtHarmonicCorrectionFactorsService.removeById(id);
|
||||
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, result, methodDescribe);
|
||||
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,64 @@
|
||||
package com.njcn.device.pq.controller;
|
||||
|
||||
import com.njcn.common.pojo.annotation.OperateInfo;
|
||||
import com.njcn.common.pojo.constant.OperateType;
|
||||
import com.njcn.common.pojo.enums.common.LogEnum;
|
||||
import com.njcn.common.pojo.enums.response.CommonResponseEnum;
|
||||
import com.njcn.common.pojo.response.HttpResult;
|
||||
import com.njcn.common.utils.HttpResultUtil;
|
||||
import com.njcn.device.pq.pojo.dto.CvtHarmonicCorrectionFactorsDTO;
|
||||
import com.njcn.device.pq.pojo.param.CvtHarmonicCorrectionFactorsParam;
|
||||
import com.njcn.device.pq.pojo.param.CvtLineRelationParam;
|
||||
import com.njcn.device.pq.pojo.po.CvtHarmonicCorrectionFactors;
|
||||
import com.njcn.device.pq.pojo.vo.CvtHarmonicCorrectionFactorsVO;
|
||||
import com.njcn.device.pq.service.CvtHarmonicCorrectionFactorsService;
|
||||
import com.njcn.device.pq.service.CvtLineRelationService;
|
||||
import com.njcn.web.controller.BaseController;
|
||||
import io.swagger.annotations.Api;
|
||||
import io.swagger.annotations.ApiImplicitParam;
|
||||
import io.swagger.annotations.ApiOperation;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.beans.BeanUtils;
|
||||
import org.springframework.validation.annotation.Validated;
|
||||
import org.springframework.web.bind.annotation.*;
|
||||
|
||||
/**
|
||||
* Description:
|
||||
* Date: 2025/02/11 上午 9:29【需求编号】
|
||||
*
|
||||
* @author clam
|
||||
* @version V1.0.0
|
||||
*/
|
||||
@Validated
|
||||
@Slf4j
|
||||
@Api(tags = "cvt系数绑定")
|
||||
@RestController
|
||||
@RequestMapping("/cvtBind")
|
||||
@RequiredArgsConstructor
|
||||
public class CvtLineRelationController extends BaseController {
|
||||
private final CvtLineRelationService cvtLineRelationService;
|
||||
@OperateInfo(info = LogEnum.BUSINESS_COMMON,operateType = OperateType.ADD)
|
||||
@ApiOperation("新增cvt系数绑定")
|
||||
@ApiImplicitParam(value = "cvt系数绑定信息",name = "cvtLineRelationParam",required = true)
|
||||
@PostMapping("add")
|
||||
public HttpResult<Boolean> add(@Validated @RequestBody CvtLineRelationParam cvtLineRelationParam){
|
||||
String methodDescribe = getMethodDescribe("add");
|
||||
boolean result = cvtLineRelationService.add(cvtLineRelationParam);
|
||||
if (result){
|
||||
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, true, methodDescribe);
|
||||
} else {
|
||||
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.FAIL, false, methodDescribe);
|
||||
}
|
||||
}
|
||||
|
||||
@OperateInfo(info = LogEnum.BUSINESS_COMMON,operateType = OperateType.ADD)
|
||||
@ApiOperation("根据监测点id查询绑定cvt系数")
|
||||
@PostMapping("queryByLineId")
|
||||
public HttpResult<CvtHarmonicCorrectionFactorsDTO> queryByLineId(@RequestParam String lineId){
|
||||
String methodDescribe = getMethodDescribe("queryByLineId");
|
||||
CvtHarmonicCorrectionFactorsDTO result = cvtLineRelationService.queryByLineId(lineId);
|
||||
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, result, methodDescribe);
|
||||
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,20 @@
|
||||
package com.njcn.device.pq.mapper;
|
||||
|
||||
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
||||
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
||||
import com.njcn.device.pq.pojo.po.CvtHarmonicCorrectionFactors;
|
||||
import com.njcn.device.pq.pojo.vo.CvtHarmonicCorrectionFactorsVO;
|
||||
import org.apache.ibatis.annotations.Param;
|
||||
|
||||
/**
|
||||
*
|
||||
* Description:
|
||||
* Date: 2025/02/10 下午 1:45【需求编号】
|
||||
*
|
||||
* @author clam
|
||||
* @version V1.0.0
|
||||
*/
|
||||
public interface CvtHarmonicCorrectionFactorsMapper extends BaseMapper<CvtHarmonicCorrectionFactors> {
|
||||
Page<CvtHarmonicCorrectionFactorsVO> queryPage(Page<Object> objectPage,@Param("ew") QueryWrapper<CvtHarmonicCorrectionFactorsVO> queryWrapper);
|
||||
}
|
||||
@@ -0,0 +1,15 @@
|
||||
package com.njcn.device.pq.mapper;
|
||||
|
||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
||||
import com.njcn.device.pq.pojo.po.CvtLineRelation;
|
||||
|
||||
/**
|
||||
*
|
||||
* Description:
|
||||
* Date: 2025/02/11 上午 9:22【需求编号】
|
||||
*
|
||||
* @author clam
|
||||
* @version V1.0.0
|
||||
*/
|
||||
public interface CvtLineRelationMapper extends BaseMapper<CvtLineRelation> {
|
||||
}
|
||||
@@ -0,0 +1,77 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
||||
<mapper namespace="com.njcn.device.pq.mapper.CvtHarmonicCorrectionFactorsMapper">
|
||||
<resultMap id="BaseResultMap" type="com.njcn.device.pq.pojo.po.CvtHarmonicCorrectionFactors">
|
||||
<!--@mbg.generated-->
|
||||
<!--@Table cvt_harmonic_correction_factors-->
|
||||
<id column="id" jdbcType="VARCHAR" property="id" />
|
||||
<result column="cvt_name" jdbcType="VARCHAR" property="cvtName" />
|
||||
<result column="cvt_model" jdbcType="VARCHAR" property="cvtModel" />
|
||||
<result column="h2" jdbcType="DECIMAL" property="h2" />
|
||||
<result column="h3" jdbcType="DECIMAL" property="h3" />
|
||||
<result column="h4" jdbcType="DECIMAL" property="h4" />
|
||||
<result column="h5" jdbcType="DECIMAL" property="h5" />
|
||||
<result column="h6" jdbcType="DECIMAL" property="h6" />
|
||||
<result column="h7" jdbcType="DECIMAL" property="h7" />
|
||||
<result column="h8" jdbcType="DECIMAL" property="h8" />
|
||||
<result column="h9" jdbcType="DECIMAL" property="h9" />
|
||||
<result column="h10" jdbcType="DECIMAL" property="h10" />
|
||||
<result column="h11" jdbcType="DECIMAL" property="h11" />
|
||||
<result column="h12" jdbcType="DECIMAL" property="h12" />
|
||||
<result column="h13" jdbcType="DECIMAL" property="h13" />
|
||||
<result column="h14" jdbcType="DECIMAL" property="h14" />
|
||||
<result column="h15" jdbcType="DECIMAL" property="h15" />
|
||||
<result column="h16" jdbcType="DECIMAL" property="h16" />
|
||||
<result column="h17" jdbcType="DECIMAL" property="h17" />
|
||||
<result column="h18" jdbcType="DECIMAL" property="h18" />
|
||||
<result column="h19" jdbcType="DECIMAL" property="h19" />
|
||||
<result column="h20" jdbcType="DECIMAL" property="h20" />
|
||||
<result column="h21" jdbcType="DECIMAL" property="h21" />
|
||||
<result column="h22" jdbcType="DECIMAL" property="h22" />
|
||||
<result column="h23" jdbcType="DECIMAL" property="h23" />
|
||||
<result column="h24" jdbcType="DECIMAL" property="h24" />
|
||||
<result column="h25" jdbcType="DECIMAL" property="h25" />
|
||||
<result column="h26" jdbcType="DECIMAL" property="h26" />
|
||||
<result column="h27" jdbcType="DECIMAL" property="h27" />
|
||||
<result column="h28" jdbcType="DECIMAL" property="h28" />
|
||||
<result column="h29" jdbcType="DECIMAL" property="h29" />
|
||||
<result column="h30" jdbcType="DECIMAL" property="h30" />
|
||||
<result column="h31" jdbcType="DECIMAL" property="h31" />
|
||||
<result column="h32" jdbcType="DECIMAL" property="h32" />
|
||||
<result column="h33" jdbcType="DECIMAL" property="h33" />
|
||||
<result column="h34" jdbcType="DECIMAL" property="h34" />
|
||||
<result column="h35" jdbcType="DECIMAL" property="h35" />
|
||||
<result column="h36" jdbcType="DECIMAL" property="h36" />
|
||||
<result column="h37" jdbcType="DECIMAL" property="h37" />
|
||||
<result column="h38" jdbcType="DECIMAL" property="h38" />
|
||||
<result column="h39" jdbcType="DECIMAL" property="h39" />
|
||||
<result column="h40" jdbcType="DECIMAL" property="h40" />
|
||||
<result column="h41" jdbcType="DECIMAL" property="h41" />
|
||||
<result column="h42" jdbcType="DECIMAL" property="h42" />
|
||||
<result column="h43" jdbcType="DECIMAL" property="h43" />
|
||||
<result column="h44" jdbcType="DECIMAL" property="h44" />
|
||||
<result column="h45" jdbcType="DECIMAL" property="h45" />
|
||||
<result column="h46" jdbcType="DECIMAL" property="h46" />
|
||||
<result column="h47" jdbcType="DECIMAL" property="h47" />
|
||||
<result column="h48" jdbcType="DECIMAL" property="h48" />
|
||||
<result column="h49" jdbcType="DECIMAL" property="h49" />
|
||||
<result column="h50" jdbcType="DECIMAL" property="h50" />
|
||||
<result column="Create_By" jdbcType="CHAR" property="createBy" />
|
||||
<result column="Create_Time" jdbcType="TIMESTAMP" property="createTime" />
|
||||
<result column="Update_By" jdbcType="CHAR" property="updateBy" />
|
||||
<result column="Update_Time" jdbcType="TIMESTAMP" property="updateTime" />
|
||||
</resultMap>
|
||||
<sql id="Base_Column_List">
|
||||
<!--@mbg.generated-->
|
||||
id, cvt_name, cvt_model, h2, h3, h4, h5, h6, h7, h8, h9, h10, h11, h12, h13, h14,
|
||||
h15, h16, h17, h18, h19, h20, h21, h22, h23, h24, h25, h26, h27, h28, h29, h30, h31,
|
||||
h32, h33, h34, h35, h36, h37, h38, h39, h40, h41, h42, h43, h44, h45, h46, h47, h48,
|
||||
h49, h50, Create_By, Create_Time, Update_By, Update_Time
|
||||
</sql>
|
||||
|
||||
<select id="queryPage" resultType="com.njcn.device.pq.pojo.vo.CvtHarmonicCorrectionFactorsVO">
|
||||
SELECT cvt_harmonic_correction_factors.*
|
||||
FROM cvt_harmonic_correction_factors cvt_harmonic_correction_factors
|
||||
WHERE ${ew.sqlSegment}
|
||||
</select>
|
||||
</mapper>
|
||||
@@ -0,0 +1,15 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
|
||||
<mapper namespace="com.njcn.device.pq.mapper.CvtLineRelationMapper">
|
||||
<resultMap id="BaseResultMap" type="com.njcn.device.pq.pojo.po.CvtLineRelation">
|
||||
<!--@mbg.generated-->
|
||||
<!--@Table cvt_line_relation-->
|
||||
<id column="id" jdbcType="VARCHAR" property="id" />
|
||||
<result column="line_id" jdbcType="VARCHAR" property="lineId" />
|
||||
<result column="cvt_id" jdbcType="VARCHAR" property="cvtId" />
|
||||
</resultMap>
|
||||
<sql id="Base_Column_List">
|
||||
<!--@mbg.generated-->
|
||||
id, line_id, cvt_id
|
||||
</sql>
|
||||
</mapper>
|
||||
@@ -0,0 +1,30 @@
|
||||
package com.njcn.device.pq.service;
|
||||
|
||||
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
||||
import com.njcn.device.pq.pojo.dto.CvtHarmonicCorrectionFactorsDTO;
|
||||
import com.njcn.device.pq.pojo.param.CvtHarmonicCorrectionFactorsParam;
|
||||
import com.njcn.device.pq.pojo.po.CvtHarmonicCorrectionFactors;
|
||||
import com.baomidou.mybatisplus.extension.service.IService;
|
||||
import com.njcn.device.pq.pojo.vo.CvtHarmonicCorrectionFactorsVO;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
*
|
||||
* Description:
|
||||
* Date: 2025/02/10 下午 1:45【需求编号】
|
||||
*
|
||||
* @author clam
|
||||
* @version V1.0.0
|
||||
*/
|
||||
public interface CvtHarmonicCorrectionFactorsService extends IService<CvtHarmonicCorrectionFactors>{
|
||||
|
||||
|
||||
boolean add(CvtHarmonicCorrectionFactorsParam cvtHarmonicCorrectionFactorsParam);
|
||||
|
||||
boolean updateCvt(CvtHarmonicCorrectionFactorsParam.CvtHarmonicCorrectionFactorsParamUpdateParam updateParam);
|
||||
|
||||
Page<CvtHarmonicCorrectionFactorsVO> queryPage(CvtHarmonicCorrectionFactorsParam.CvtHarmonicCorrectionFactorsParamQueryParam queryParam);
|
||||
|
||||
List<CvtHarmonicCorrectionFactorsDTO> queryList(CvtHarmonicCorrectionFactorsParam.CvtHarmonicCorrectionFactorsParamQueryParam queryParam);
|
||||
}
|
||||
@@ -0,0 +1,21 @@
|
||||
package com.njcn.device.pq.service;
|
||||
|
||||
import com.njcn.device.pq.pojo.dto.CvtHarmonicCorrectionFactorsDTO;
|
||||
import com.njcn.device.pq.pojo.param.CvtLineRelationParam;
|
||||
import com.njcn.device.pq.pojo.po.CvtLineRelation;
|
||||
import com.baomidou.mybatisplus.extension.service.IService;
|
||||
/**
|
||||
*
|
||||
* Description:
|
||||
* Date: 2025/02/11 上午 9:22【需求编号】
|
||||
*
|
||||
* @author clam
|
||||
* @version V1.0.0
|
||||
*/
|
||||
public interface CvtLineRelationService extends IService<CvtLineRelation>{
|
||||
|
||||
|
||||
boolean add(CvtLineRelationParam cvtLineRelationParam);
|
||||
|
||||
CvtHarmonicCorrectionFactorsDTO queryByLineId(String lineId);
|
||||
}
|
||||
@@ -0,0 +1,136 @@
|
||||
package com.njcn.device.pq.service.impl;
|
||||
|
||||
import cn.hutool.core.collection.CollUtil;
|
||||
import cn.hutool.core.collection.CollectionUtil;
|
||||
import cn.hutool.core.date.DateUtil;
|
||||
import cn.hutool.core.text.StrPool;
|
||||
import cn.hutool.core.util.StrUtil;
|
||||
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
||||
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
||||
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
||||
import com.njcn.common.pojo.constant.PatternRegex;
|
||||
import com.njcn.common.pojo.enums.common.DataStateEnum;
|
||||
import com.njcn.common.pojo.exception.BusinessException;
|
||||
import com.njcn.device.pms.pojo.po.Monitor;
|
||||
import com.njcn.device.pq.pojo.dto.CvtHarmonicCorrectionFactorsDTO;
|
||||
import com.njcn.device.pq.pojo.param.CvtHarmonicCorrectionFactorsParam;
|
||||
import com.njcn.device.pq.pojo.vo.CvtHarmonicCorrectionFactorsVO;
|
||||
import com.njcn.web.constant.ValidMessage;
|
||||
import com.njcn.web.factory.PageFactory;
|
||||
import com.njcn.web.utils.RequestUtil;
|
||||
import org.apache.commons.lang.StringUtils;
|
||||
import org.springframework.beans.BeanUtils;
|
||||
import org.springframework.stereotype.Service;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
import java.util.Objects;
|
||||
import java.util.regex.Pattern;
|
||||
import java.util.stream.Collectors;
|
||||
|
||||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
||||
import com.njcn.device.pq.mapper.CvtHarmonicCorrectionFactorsMapper;
|
||||
import com.njcn.device.pq.pojo.po.CvtHarmonicCorrectionFactors;
|
||||
import com.njcn.device.pq.service.CvtHarmonicCorrectionFactorsService;
|
||||
import org.springframework.transaction.annotation.Transactional;
|
||||
|
||||
/**
|
||||
*
|
||||
* Description:
|
||||
* Date: 2025/02/10 下午 1:45【需求编号】
|
||||
*
|
||||
* @author clam
|
||||
* @version V1.0.0
|
||||
*/
|
||||
@Service
|
||||
public class CvtHarmonicCorrectionFactorsServiceImpl extends ServiceImpl<CvtHarmonicCorrectionFactorsMapper, CvtHarmonicCorrectionFactors> implements CvtHarmonicCorrectionFactorsService{
|
||||
|
||||
|
||||
@Override
|
||||
@Transactional(rollbackFor = Exception.class)
|
||||
public boolean add(CvtHarmonicCorrectionFactorsParam cvtHarmonicCorrectionFactorsParam) {
|
||||
//校验
|
||||
checkParam(cvtHarmonicCorrectionFactorsParam, false);
|
||||
CvtHarmonicCorrectionFactors cvtHarmonicCorrectionFactors = new CvtHarmonicCorrectionFactors();
|
||||
BeanUtils.copyProperties(cvtHarmonicCorrectionFactorsParam,cvtHarmonicCorrectionFactors);
|
||||
boolean save = this.save(cvtHarmonicCorrectionFactors);
|
||||
return save;
|
||||
}
|
||||
|
||||
@Override
|
||||
public boolean updateCvt(CvtHarmonicCorrectionFactorsParam.CvtHarmonicCorrectionFactorsParamUpdateParam updateParam) {
|
||||
//校验
|
||||
checkParam(updateParam, true);
|
||||
CvtHarmonicCorrectionFactors cvtHarmonicCorrectionFactors = new CvtHarmonicCorrectionFactors();
|
||||
BeanUtils.copyProperties(updateParam,cvtHarmonicCorrectionFactors);
|
||||
boolean update = this.updateById(cvtHarmonicCorrectionFactors);
|
||||
return update;
|
||||
}
|
||||
|
||||
@Override
|
||||
public Page<CvtHarmonicCorrectionFactorsVO> queryPage(CvtHarmonicCorrectionFactorsParam.CvtHarmonicCorrectionFactorsParamQueryParam queryParam) {
|
||||
|
||||
QueryWrapper<CvtHarmonicCorrectionFactorsVO> queryWrapper = new QueryWrapper<>();
|
||||
if (Objects.nonNull(queryParam)) {
|
||||
if (StringUtils.isNotEmpty(queryParam.getSearchBeginTime()) && StringUtils.isNotEmpty(queryParam.getSearchEndTime())) {
|
||||
queryWrapper.between("cvt_harmonic_correction_factors.create_time",
|
||||
DateUtil.beginOfDay(DateUtil.parse(queryParam.getSearchBeginTime())),
|
||||
DateUtil.endOfDay(DateUtil.parse(queryParam.getSearchEndTime())));
|
||||
}
|
||||
|
||||
queryWrapper.and(temp->temp.like("cvt_harmonic_correction_factors.cvt_name", queryParam.getSearchValue())
|
||||
.or()
|
||||
.like("cvt_harmonic_correction_factors.cvt_model", queryParam.getSearchValue()));
|
||||
|
||||
|
||||
}
|
||||
queryWrapper
|
||||
.orderByDesc("cvt_harmonic_correction_factors.Update_Time");
|
||||
Page<CvtHarmonicCorrectionFactorsVO> page = this.baseMapper.queryPage(new Page<>(PageFactory.getPageNum(queryParam), PageFactory.getPageSize(queryParam)), queryWrapper);
|
||||
return page;
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<CvtHarmonicCorrectionFactorsDTO> queryList(CvtHarmonicCorrectionFactorsParam.CvtHarmonicCorrectionFactorsParamQueryParam queryParam) {
|
||||
List<CvtHarmonicCorrectionFactorsDTO> result = new ArrayList<>();
|
||||
List<CvtHarmonicCorrectionFactors> list = this.lambdaQuery().and(item -> item.like(CvtHarmonicCorrectionFactors::getCvtName, queryParam.getSearchValue()).or()
|
||||
.like(CvtHarmonicCorrectionFactors::getCvtModel, queryParam.getSearchValue())).list();
|
||||
if(CollectionUtil.isNotEmpty(list)){
|
||||
result = list.stream().map(temp->{
|
||||
CvtHarmonicCorrectionFactorsDTO cvtHarmonicCorrectionFactorsDTO = new CvtHarmonicCorrectionFactorsDTO();
|
||||
BeanUtils.copyProperties(temp,cvtHarmonicCorrectionFactorsDTO);
|
||||
return cvtHarmonicCorrectionFactorsDTO;
|
||||
}).collect(Collectors.toList());
|
||||
}
|
||||
|
||||
return result;
|
||||
}
|
||||
|
||||
private void checkParam(CvtHarmonicCorrectionFactorsParam cvtHarmonicCorrectionFactorsParam, Boolean updateFlag) {
|
||||
|
||||
// Pattern pattern = Pattern.compile(PatternRegex.SPECIALCHARACTER);
|
||||
// if(pattern.matcher(cvtHarmonicCorrectionFactorsParam.getCvtName()).find()){
|
||||
// throw new BusinessException(ValidMessage.NAME_SPECIAL_REGEX);
|
||||
// }
|
||||
// if(pattern.matcher(cvtHarmonicCorrectionFactorsParam.getCvtModel()).find()){
|
||||
// throw new BusinessException(ValidMessage.NAME_SPECIAL_REGEX);
|
||||
// }
|
||||
|
||||
LambdaQueryWrapper<CvtHarmonicCorrectionFactors> lambdaQueryWrapper = new LambdaQueryWrapper<>();
|
||||
lambdaQueryWrapper.and(item->item.eq(CvtHarmonicCorrectionFactors::getCvtName,cvtHarmonicCorrectionFactorsParam.getCvtName()).or()
|
||||
.eq(CvtHarmonicCorrectionFactors::getCvtModel,cvtHarmonicCorrectionFactorsParam.getCvtModel()));
|
||||
|
||||
if (updateFlag) {
|
||||
if (cvtHarmonicCorrectionFactorsParam instanceof CvtHarmonicCorrectionFactorsParam.CvtHarmonicCorrectionFactorsParamUpdateParam) {
|
||||
//修改
|
||||
lambdaQueryWrapper.ne(CvtHarmonicCorrectionFactors::getId, ((CvtHarmonicCorrectionFactorsParam.CvtHarmonicCorrectionFactorsParamUpdateParam) cvtHarmonicCorrectionFactorsParam).getId());
|
||||
}
|
||||
}
|
||||
|
||||
int count = this.count(lambdaQueryWrapper);
|
||||
if (count > 0) {
|
||||
throw new BusinessException("存在同名cvt名称或cvt型号");
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,59 @@
|
||||
package com.njcn.device.pq.service.impl;
|
||||
|
||||
import com.njcn.device.pq.pojo.dto.CvtHarmonicCorrectionFactorsDTO;
|
||||
import com.njcn.device.pq.pojo.param.CvtLineRelationParam;
|
||||
import com.njcn.device.pq.pojo.po.CvtHarmonicCorrectionFactors;
|
||||
import com.njcn.device.pq.service.CvtHarmonicCorrectionFactorsService;
|
||||
import lombok.AllArgsConstructor;
|
||||
import org.apache.commons.lang.StringUtils;
|
||||
import org.springframework.beans.BeanUtils;
|
||||
import org.springframework.stereotype.Service;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import java.util.List;
|
||||
import java.util.Objects;
|
||||
|
||||
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
||||
import com.njcn.device.pq.pojo.po.CvtLineRelation;
|
||||
import com.njcn.device.pq.mapper.CvtLineRelationMapper;
|
||||
import com.njcn.device.pq.service.CvtLineRelationService;
|
||||
/**
|
||||
*
|
||||
* Description:
|
||||
* Date: 2025/02/11 上午 9:22【需求编号】
|
||||
*
|
||||
* @author clam
|
||||
* @version V1.0.0
|
||||
*/
|
||||
@Service
|
||||
@AllArgsConstructor
|
||||
public class CvtLineRelationServiceImpl extends ServiceImpl<CvtLineRelationMapper, CvtLineRelation> implements CvtLineRelationService{
|
||||
|
||||
private final CvtHarmonicCorrectionFactorsService cvtHarmonicCorrectionFactorsService;
|
||||
|
||||
|
||||
@Override
|
||||
public boolean add(CvtLineRelationParam cvtLineRelationParam) {
|
||||
CvtLineRelation one = this.lambdaQuery().eq(CvtLineRelation::getLineId, cvtLineRelationParam.getLineId()).one();
|
||||
if(Objects.isNull(one)){
|
||||
CvtLineRelation cvtLineRelation = new CvtLineRelation();
|
||||
BeanUtils.copyProperties(cvtLineRelationParam,cvtLineRelation);
|
||||
|
||||
this.save(cvtLineRelation);
|
||||
}else {
|
||||
one.setCvtId(cvtLineRelationParam.getCvtId());
|
||||
this.updateById(one);
|
||||
}
|
||||
return true;
|
||||
}
|
||||
|
||||
@Override
|
||||
public CvtHarmonicCorrectionFactorsDTO queryByLineId(String lineId) {
|
||||
CvtHarmonicCorrectionFactorsDTO cvtHarmonicCorrectionFactorsDTO = new CvtHarmonicCorrectionFactorsDTO();
|
||||
CvtLineRelation one = this.lambdaQuery().eq(CvtLineRelation::getLineId, lineId).one();
|
||||
if(Objects.nonNull(one)&& StringUtils.isNotEmpty(one.getCvtId())){
|
||||
CvtHarmonicCorrectionFactors byId = cvtHarmonicCorrectionFactorsService.getById(one.getCvtId());
|
||||
BeanUtils.copyProperties(byId,cvtHarmonicCorrectionFactorsDTO);
|
||||
}
|
||||
return cvtHarmonicCorrectionFactorsDTO;
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user