Commit c098ea28 authored by chenzhao's avatar chenzhao

Merge remote-tracking branch 'origin/developer' into developer

parents a60d6dc2 8439db4e
...@@ -126,7 +126,7 @@ public class IdxBizFanWeightController extends BaseController { ...@@ -126,7 +126,7 @@ public class IdxBizFanWeightController extends BaseController {
if (!ObjectUtils.isEmpty(stdUserEmpower)) { if (!ObjectUtils.isEmpty(stdUserEmpower)) {
orgCode = stdUserEmpower.getAmosOrgCode().get(0); orgCode = stdUserEmpower.getAmosOrgCode().get(0);
} }
QueryWrapper< IdxBizFanWeight> qu=new QueryWrapper<>(); // QueryWrapper< IdxBizFanWeight> qu=new QueryWrapper<>();
String name=""; String name="";
switch(type){ switch(type){
case "1": case "1":
...@@ -160,11 +160,12 @@ public class IdxBizFanWeightController extends BaseController { ...@@ -160,11 +160,12 @@ public class IdxBizFanWeightController extends BaseController {
// qu.eq("POINT_NAME",pointName); // qu.eq("POINT_NAME",pointName);
break; break;
} }
qu.like("ORG_CODE",orgCode); // qu.like("ORG_CODE",orgCode);
qu.isNotNull(name); // qu.isNotNull(name);
qu.groupBy(name); // qu.groupBy(name);
qu.orderByAsc(name); // qu.orderByAsc(name);
List<IdxBizFanWeight> list = idxBizFanWeightMapper.selectList(qu); // List<IdxBizFanWeight> list = idxBizFanWeightMapper.selectList(qu);
List<IdxBizFanWeight> list = idxBizFanWeightMapper.selectAllByParams(name,"%"+orgCode+"%");
return ResponseHelper.buildResponse(list); return ResponseHelper.buildResponse(list);
} }
......
...@@ -134,7 +134,7 @@ public class IdxBizPvWeightController extends BaseController { ...@@ -134,7 +134,7 @@ public class IdxBizPvWeightController extends BaseController {
if (!ObjectUtils.isEmpty(stdUserEmpower)) { if (!ObjectUtils.isEmpty(stdUserEmpower)) {
orgCode = stdUserEmpower.getAmosOrgCode().get(0); orgCode = stdUserEmpower.getAmosOrgCode().get(0);
} }
QueryWrapper< IdxBizPvWeight> qu=new QueryWrapper<>(); // QueryWrapper< IdxBizPvWeight> qu=new QueryWrapper<>();
String name=""; String name="";
IdxBizPvWeight qt=new IdxBizPvWeight(); IdxBizPvWeight qt=new IdxBizPvWeight();
switch(type){ switch(type){
...@@ -170,11 +170,12 @@ public class IdxBizPvWeightController extends BaseController { ...@@ -170,11 +170,12 @@ public class IdxBizPvWeightController extends BaseController {
// qu.eq("POINT_NAME",pointName); // qu.eq("POINT_NAME",pointName);
break; break;
} }
qu.like("ORG_CODE",orgCode); // qu.like("ORG_CODE",orgCode);
qu.isNotNull(name); // qu.isNotNull(name);
qu.groupBy(name); // qu.groupBy(name);
qu.orderByAsc(name); // qu.orderByAsc(name);
List<IdxBizPvWeight> list = idxBizPvWeightMapper.selectList(qu); // List<IdxBizPvWeight> list = idxBizPvWeightMapper.selectList(qu);
List<IdxBizPvWeight> list = idxBizPvWeightMapper.selectAllByParams(name,"%"+orgCode+"%");
return ResponseHelper.buildResponse(list); return ResponseHelper.buildResponse(list);
} }
...@@ -211,11 +212,11 @@ public class IdxBizPvWeightController extends BaseController { ...@@ -211,11 +212,11 @@ public class IdxBizPvWeightController extends BaseController {
break; break;
case "3": case "3":
flagtype = idxBizFanWeight.getArae() + idxBizFanWeight.getStation()+ idxBizFanWeight.getSubarray(); flagtype = idxBizFanWeight.getArae() + idxBizFanWeight.getStation() ;
break; break;
case "4": case "4":
flagtype = idxBizFanWeight.getArae() + idxBizFanWeight.getStation() ; flagtype = idxBizFanWeight.getArae() + idxBizFanWeight.getStation()+ idxBizFanWeight.getSubarray();
break; break;
case "5": case "5":
...@@ -235,12 +236,12 @@ public class IdxBizPvWeightController extends BaseController { ...@@ -235,12 +236,12 @@ public class IdxBizPvWeightController extends BaseController {
} }
break; break;
case "3": case "3":
if (!flagtype.equals(idxBizFanWeight.getArae() + idxBizFanWeight.getStation()+ idxBizFanWeight.getSubarray())) { if (!flagtype.equals(idxBizFanWeight.getArae() + idxBizFanWeight.getStation() )) {
throw new BadRequest( "配置权重必须是同一个层级的数据"); throw new BadRequest( "配置权重必须是同一个层级的数据");
} }
break; break;
case "4": case "4":
if (!flagtype.equals(idxBizFanWeight.getArae() + idxBizFanWeight.getStation() )) { if (!flagtype.equals(idxBizFanWeight.getArae() + idxBizFanWeight.getStation()+ idxBizFanWeight.getSubarray())) {
throw new BadRequest( "配置权重必须是同一个层级的数据"); throw new BadRequest( "配置权重必须是同一个层级的数据");
} }
break; break;
...@@ -270,13 +271,13 @@ public class IdxBizPvWeightController extends BaseController { ...@@ -270,13 +271,13 @@ public class IdxBizPvWeightController extends BaseController {
qu.eq(!StringUtils.isEmpty(reviewDto.getType()), IdxBizPvWeight::getType, reviewDto.getType()); qu.eq(!StringUtils.isEmpty(reviewDto.getType()), IdxBizPvWeight::getType, reviewDto.getType());
qu.eq(!StringUtils.isEmpty(reviewDto.getArae()), IdxBizPvWeight::getArae, reviewDto.getArae()); qu.eq(!StringUtils.isEmpty(reviewDto.getArae()), IdxBizPvWeight::getArae, reviewDto.getArae());
qu.eq(!StringUtils.isEmpty(reviewDto.getStation()), IdxBizPvWeight::getStation, reviewDto.getStation()); qu.eq(!StringUtils.isEmpty(reviewDto.getStation()), IdxBizPvWeight::getStation, reviewDto.getStation());
qu.eq(!StringUtils.isEmpty(reviewDto.getSubarray()), IdxBizPvWeight::getSubarray, reviewDto.getSubarray());
break; break;
case "4": case "4":
qu.eq(!StringUtils.isEmpty(reviewDto.getType()), IdxBizPvWeight::getType, reviewDto.getType()); qu.eq(!StringUtils.isEmpty(reviewDto.getType()), IdxBizPvWeight::getType, reviewDto.getType());
qu.eq(!StringUtils.isEmpty(reviewDto.getArae()), IdxBizPvWeight::getArae, reviewDto.getArae()); qu.eq(!StringUtils.isEmpty(reviewDto.getArae()), IdxBizPvWeight::getArae, reviewDto.getArae());
qu.eq(!StringUtils.isEmpty(reviewDto.getStation()), IdxBizPvWeight::getStation, reviewDto.getStation()); qu.eq(!StringUtils.isEmpty(reviewDto.getStation()), IdxBizPvWeight::getStation, reviewDto.getStation());
qu.eq(!StringUtils.isEmpty(reviewDto.getSubarray()), IdxBizPvWeight::getSubarray, reviewDto.getSubarray());
break; break;
case "5": case "5":
......
...@@ -3,6 +3,9 @@ package com.yeejoin.amos.boot.module.jxiop.biz.mapper2; ...@@ -3,6 +3,9 @@ package com.yeejoin.amos.boot.module.jxiop.biz.mapper2;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizFanWeight; import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizFanWeight;
import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizFelk; import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizFelk;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/** /**
* @description: * @description:
...@@ -10,4 +13,5 @@ import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizFelk; ...@@ -10,4 +13,5 @@ import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizFelk;
* @createDate: 2023/10/23 * @createDate: 2023/10/23
*/ */
public interface IdxBizFanWeightMapper extends BaseMapper<IdxBizFanWeight> { public interface IdxBizFanWeightMapper extends BaseMapper<IdxBizFanWeight> {
List<IdxBizFanWeight> selectAllByParams(@Param("name") String name, @Param("orgCode") String orgCode);
} }
...@@ -2,6 +2,9 @@ package com.yeejoin.amos.boot.module.jxiop.biz.mapper2; ...@@ -2,6 +2,9 @@ package com.yeejoin.amos.boot.module.jxiop.biz.mapper2;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizPvWeight; import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizPvWeight;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/** /**
* @description: * @description:
...@@ -11,4 +14,5 @@ import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizPvWeight; ...@@ -11,4 +14,5 @@ import com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizPvWeight;
public interface IdxBizPvWeightMapper extends BaseMapper<IdxBizPvWeight> { public interface IdxBizPvWeightMapper extends BaseMapper<IdxBizPvWeight> {
List<IdxBizPvWeight> selectAllByParams(@Param("name") String name, @Param("orgCode") String orgCode);
} }
...@@ -100,7 +100,7 @@ public class IdxBizFanHealthIndexServiceImpl extends BaseService<IdxBizFanHealth ...@@ -100,7 +100,7 @@ public class IdxBizFanHealthIndexServiceImpl extends BaseService<IdxBizFanHealth
tdid=address+"_"+idxBizFanPointProcessVariableClassification.getGatewayId(); tdid=address+"_"+idxBizFanPointProcessVariableClassification.getGatewayId();
} }
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss'Z'"); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
Calendar calendar = Calendar.getInstance(TimeZone.getTimeZone("UTC")); Calendar calendar = Calendar.getInstance(TimeZone.getTimeZone("UTC"));
sdf.setTimeZone(TimeZone.getTimeZone("UTC")); sdf.setTimeZone(TimeZone.getTimeZone("UTC"));
//限制必须是区间时间段 //限制必须是区间时间段
......
<?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.yeejoin.amos.boot.module.jxiop.biz.mapper2.IdxBizFanWeightMapper">
<select id="selectAllByParams" resultType="com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizFanWeight">
SELECT ibfw.sequence_nbr,FLAG,ORG_CODE,POINT_NAME,STATION,ARAE,EQUIPMENT_NAME,TYPE,VALUE,SUBARRAY
FROM (SELECT MIN(sequence_nbr) as sequence_nbr
FROM idx_biz_fan_weight WHERE (ORG_CODE LIKE #{orgCode} AND ${name} IS NOT NULL)
GROUP BY ${name} ORDER BY ${name} ASC)aa
LEFT JOIN idx_biz_fan_weight ibfw ON ibfw.sequence_nbr=aa.sequence_nbr
</select>
</mapper>
<?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.yeejoin.amos.boot.module.jxiop.biz.mapper2.IdxBizPvWeightMapper">
<select id="selectAllByParams" resultType="com.yeejoin.amos.boot.module.jxiop.biz.entity.IdxBizPvWeight">
SELECT ibpw.sequence_nbr,FLAG,ORG_CODE,POINT_NAME,STATION,ARAE,EQUIPMENT_NAME,TYPE,VALUE,SUBARRAY
FROM (SELECT MIN(sequence_nbr) as sequence_nbr
FROM idx_biz_pv_weight WHERE (ORG_CODE LIKE #{orgCode} AND ${name} IS NOT NULL)
GROUP BY ${name} ORDER BY ${name} ASC)aa
LEFT JOIN idx_biz_pv_weight ibpw ON ibpw.sequence_nbr=aa.sequence_nbr
</select>
</mapper>
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment