Microservice/pqs
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

国网推送

Browse Source
This commit is contained in:
hzj
2023-12-14 14:37:31 +08:00
parent 704c241ca6
commit 3761955e81
10 changed files with 265 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/param/SendParam.java → pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/param/SendQueryParam.java
View File

@@ -17,20 +17,20 @@ import javax.validation.constraints.Pattern;
* @version V1.0.0
*/
@Data
public class SendParam {
public class SendQueryParam {
@ApiModelProperty(name = "deptIndex", value = "部门索引", required = true)
@NotBlank(message = "部门索引不可为空")
private String deptIndex;
@ApiModelProperty("开始时间")
@Pattern(regexp = PatternRegex.TIME_FORMAT, message = "时间格式错误")
@Pattern(regexp = PatternRegex.TIME_SECOND_FORMAT, message = "时间格式错误")
private String searchBeginTime;
@ApiModelProperty("结束时间")
@Pattern(regexp = PatternRegex.TIME_FORMAT, message = "时间格式错误")
@Pattern(regexp = PatternRegex.TIME_SECOND_FORMAT, message = "时间格式错误")
private String searchEndTime;
@Data
public static class SendPageParam extends SendParam{
public static class SendPageParam extends SendQueryParam {
@NotNull(message="当前页不能为空！")
@Min(value = 1, message = "当前页不能为0")
@ApiModelProperty(value = "当前页",name = "currentPage",dataType ="Integer",required = true)

18
pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/controller/send/ConverterdetailstatisticsController.java
View File

@@ -7,7 +7,7 @@ import com.njcn.common.pojo.enums.response.CommonResponseEnum;
import com.njcn.common.pojo.response.HttpResult;
import com.njcn.common.utils.HttpResultUtil;
import com.njcn.common.utils.LogUtil;
import com.njcn.harmonic.pojo.param.SendParam;
import com.njcn.harmonic.pojo.param.SendQueryParam;
import com.njcn.harmonic.pojo.po.send.ConverterdetailstatisticsPO;
import com.njcn.harmonic.service.send.ConverterdetailstatisticsPOService;
import com.njcn.web.controller.BaseController;
@@ -22,6 +22,8 @@ import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
/**
* Description:河北国网上送接口
* * 2.4.1.17接收电能质量主配网监测点统计数据接口
@@ -33,7 +35,7 @@ import org.springframework.web.bind.annotation.RestController;
@Slf4j
@RestController
@RequestMapping("/Converterdetail")
@Api(tags = "电能质量主配网监测点统计数据")
@Api(tags = "换流站指标统计明细数据")
@RequiredArgsConstructor
public class ConverterdetailstatisticsController extends BaseController {
@@ -42,11 +44,21 @@ public class ConverterdetailstatisticsController extends BaseController {
@PostMapping("/queryPage")
@ApiOperation("数据查询")
@ApiImplicitParam(name = "param", value = "实体参数", required = true)
public HttpResult<Page<ConverterdetailstatisticsPO>> queryPage(@Validated @RequestBody SendParam.SendPageParam param) {
public HttpResult<Page<ConverterdetailstatisticsPO>> queryPage(@Validated @RequestBody SendQueryParam.SendPageParam param) {
String methodDescribe = getMethodDescribe("queryPage");
LogUtil.njcnDebug(log, "{}，实体参数：{}", methodDescribe, param);
Page<ConverterdetailstatisticsPO> list = converterdetailstatisticsPOService.queryPage(param);
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, list, methodDescribe);
}
@PostMapping("send")
@OperateInfo(info = LogEnum.BUSINESS_COMMON)
@ApiOperation("上报")
@ApiImplicitParam(name = "ids",value = "请求体",required = true)
public HttpResult<String> send(@RequestBody List<String> ids){
String methodDescribe = getMethodDescribe("send");
String s = converterdetailstatisticsPOService.send(ids);
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, s, methodDescribe);
}
}

18
pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/controller/send/PqTypicalSourceCreateController.java
View File

@@ -7,7 +7,7 @@ import com.njcn.common.pojo.enums.response.CommonResponseEnum;
import com.njcn.common.pojo.response.HttpResult;
import com.njcn.common.utils.HttpResultUtil;
import com.njcn.common.utils.LogUtil;
import com.njcn.harmonic.pojo.param.SendParam;
import com.njcn.harmonic.pojo.param.SendQueryParam;
import com.njcn.harmonic.pojo.po.send.PqTypicalSourceCreatePO;
import com.njcn.harmonic.service.send.PqTypicalSourceCreatePOService;
import com.njcn.web.controller.BaseController;
@@ -22,6 +22,8 @@ import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
/**
* Description:2.4.1.9 接收电能质量典型源荷指标统计数据接口
* Date: 2023/12/13 14:52【需求编号】
@@ -33,7 +35,7 @@ import org.springframework.web.bind.annotation.RestController;
@Slf4j
@RestController
@RequestMapping("/pqTypicalSourceCreate")
@Api(tags = "能质量典型源荷指标统计数据")
@Api(tags = "典型源荷指标统计数据")
@RequiredArgsConstructor
public class PqTypicalSourceCreateController extends BaseController {
private final PqTypicalSourceCreatePOService pqTypicalSourceCreatePOService;
@@ -42,10 +44,20 @@ public class PqTypicalSourceCreateController extends BaseController {
@PostMapping("/queryPage")
@ApiOperation("数据查询")
@ApiImplicitParam(name = "param", value = "实体参数", required = true)
public HttpResult<Page<PqTypicalSourceCreatePO>> queryPage(@Validated @RequestBody SendParam.SendPageParam param) {
public HttpResult<Page<PqTypicalSourceCreatePO>> queryPage(@Validated @RequestBody SendQueryParam.SendPageParam param) {
String methodDescribe = getMethodDescribe("queryPage");
LogUtil.njcnDebug(log, "{}，实体参数：{}", methodDescribe, param);
Page<PqTypicalSourceCreatePO> list = pqTypicalSourceCreatePOService.queryPage(param);
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, list, methodDescribe);
}
@PostMapping("send")
@OperateInfo(info = LogEnum.BUSINESS_COMMON)
@ApiOperation("上报")
@ApiImplicitParam(name = "ids",value = "请求体",required = true)
public HttpResult<String> send(@RequestBody List<String> ids){
String methodDescribe = getMethodDescribe("send");
String s = pqTypicalSourceCreatePOService.send(ids);
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, s, methodDescribe);
}
}

17
pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/controller/send/SubstationQualityStatisticsController.java
View File

@@ -7,7 +7,7 @@ import com.njcn.common.pojo.enums.response.CommonResponseEnum;
import com.njcn.common.pojo.response.HttpResult;
import com.njcn.common.utils.HttpResultUtil;
import com.njcn.common.utils.LogUtil;
import com.njcn.harmonic.pojo.param.SendParam;
import com.njcn.harmonic.pojo.param.SendQueryParam;
import com.njcn.harmonic.pojo.po.send.SubstationQualityStatisticsPO;
import com.njcn.harmonic.service.send.SubstationQualityStatisticsPOService;
import com.njcn.web.controller.BaseController;
@@ -22,6 +22,8 @@ import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
/**
*需求：
* * FWJK-PMS3.0-TC0013-电能质量管理两级贯通接口V1.10
@@ -35,7 +37,7 @@ import org.springframework.web.bind.annotation.RestController;
@Slf4j
@RestController
@RequestMapping("/substationQuality")
@Api(tags = "接收电能质量换流站指标统计明细数据")
@Api(tags = "换流站指标统计明细数据")
@RequiredArgsConstructor
public class SubstationQualityStatisticsController extends BaseController {
@@ -46,12 +48,21 @@ public class SubstationQualityStatisticsController extends BaseController {
@PostMapping("/queryPage")
@ApiOperation("数据查询")
@ApiImplicitParam(name = "param", value = "实体参数", required = true)
public HttpResult<Page<SubstationQualityStatisticsPO>> queryPage(@Validated @RequestBody SendParam.SendPageParam param) {
public HttpResult<Page<SubstationQualityStatisticsPO>> queryPage(@Validated @RequestBody SendQueryParam.SendPageParam param) {
String methodDescribe = getMethodDescribe("queryPage");
LogUtil.njcnDebug(log, "{}，实体参数：{}", methodDescribe, param);
Page<SubstationQualityStatisticsPO> list = substationQualityStatisticsPOService.queryPage(param);
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, list, methodDescribe);
}
@PostMapping("send")
@OperateInfo(info = LogEnum.BUSINESS_COMMON)
@ApiOperation("上报")
@ApiImplicitParam(name = "ids",value = "请求体",required = true)
public HttpResult<String> send(@RequestBody List<String> ids){
String methodDescribe = getMethodDescribe("send");
String s = substationQualityStatisticsPOService.send(ids);
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, s, methodDescribe);
}
}

8
pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/send/ConverterdetailstatisticsPOService.java
View File

@@ -2,9 +2,11 @@ package com.njcn.harmonic.service.send;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService;
import com.njcn.harmonic.pojo.param.SendParam;
import com.njcn.harmonic.pojo.param.SendQueryParam;
import com.njcn.harmonic.pojo.po.send.ConverterdetailstatisticsPO;
import java.util.List;
/**
*
* Description:
@@ -16,5 +18,7 @@ import com.njcn.harmonic.pojo.po.send.ConverterdetailstatisticsPO;
public interface ConverterdetailstatisticsPOService extends IService<ConverterdetailstatisticsPO>{
Page<ConverterdetailstatisticsPO> queryPage(SendParam.SendPageParam param);
Page<ConverterdetailstatisticsPO> queryPage(SendQueryParam.SendPageParam param);
String send(List<String> ids);
}

8
pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/send/PqTypicalSourceCreatePOService.java
View File

@@ -2,9 +2,11 @@ package com.njcn.harmonic.service.send;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService;
import com.njcn.harmonic.pojo.param.SendParam;
import com.njcn.harmonic.pojo.param.SendQueryParam;
import com.njcn.harmonic.pojo.po.send.PqTypicalSourceCreatePO;
import java.util.List;
/**
*
* Description:
@@ -16,5 +18,7 @@ import com.njcn.harmonic.pojo.po.send.PqTypicalSourceCreatePO;
public interface PqTypicalSourceCreatePOService extends IService<PqTypicalSourceCreatePO>{
Page<PqTypicalSourceCreatePO> queryPage(SendParam.SendPageParam param);
Page<PqTypicalSourceCreatePO> queryPage(SendQueryParam.SendPageParam param);
String send(List<String> ids);
}

8
pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/send/SubstationQualityStatisticsPOService.java
View File

@@ -2,9 +2,11 @@ package com.njcn.harmonic.service.send;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService;
import com.njcn.harmonic.pojo.param.SendParam;
import com.njcn.harmonic.pojo.param.SendQueryParam;
import com.njcn.harmonic.pojo.po.send.SubstationQualityStatisticsPO;
import java.util.List;
/**
*
* Description:
@@ -16,5 +18,7 @@ import com.njcn.harmonic.pojo.po.send.SubstationQualityStatisticsPO;
public interface SubstationQualityStatisticsPOService extends IService<SubstationQualityStatisticsPO>{
Page<SubstationQualityStatisticsPO> queryPage(SendParam.SendPageParam param);
Page<SubstationQualityStatisticsPO> queryPage(SendQueryParam.SendPageParam param);
String send(List<String> ids);
}

68
pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/send/impl/ConverterdetailstatisticsPOServiceImpl.java
View File

@@ -1,17 +1,28 @@
package com.njcn.harmonic.service.send.impl;
import cn.hutool.core.bean.BeanUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.njcn.common.pojo.exception.BusinessException;
import com.njcn.harmonic.mapper.send.ConverterdetailstatisticsPOMapper;
import com.njcn.harmonic.pojo.param.SendParam;
import com.njcn.harmonic.pojo.dto.ConverterDetailStatisticsDTO;
import com.njcn.harmonic.pojo.param.SendQueryParam;
import com.njcn.harmonic.pojo.po.send.ConverterdetailstatisticsPO;
import com.njcn.harmonic.service.send.ConverterdetailstatisticsPOService;
import com.njcn.user.api.DeptFeignClient;
import com.njcn.web.enums.GWSendEnum;
import com.njcn.web.pojo.param.SendParam;
import com.njcn.web.utils.GwSendUtil;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
/**
*
@@ -23,11 +34,12 @@ import java.util.List;
*/
@Service
@RequiredArgsConstructor
@Slf4j
public class ConverterdetailstatisticsPOServiceImpl extends ServiceImpl<ConverterdetailstatisticsPOMapper, ConverterdetailstatisticsPO> implements ConverterdetailstatisticsPOService {
private final DeptFeignClient deptFeignClient;
@Override
public Page<ConverterdetailstatisticsPO> queryPage(SendParam.SendPageParam param) {
public Page<ConverterdetailstatisticsPO> queryPage(SendQueryParam.SendPageParam param) {
Page<ConverterdetailstatisticsPO> page = new Page<> (param.getCurrentPage ( ), param.getPageSize ( ));
List<String> deptIds = deptFeignClient.getDepSonSelfCodetByCode(param.getDeptIndex()).getData();
@@ -38,4 +50,56 @@ public class ConverterdetailstatisticsPOServiceImpl extends ServiceImpl<Converte
return converterdetailstatisticsPOPage;
}
@Override
public String send(List<String> ids) {
List<ConverterdetailstatisticsPO> list = this.lambdaQuery().eq(ConverterdetailstatisticsPO::getId, ids).list();
if (list.size() > 100) {
throw new BusinessException("一次最多上送100条数据");
}
List<ConverterDetailStatisticsDTO> converterDetailStatisticsDTOS = BeanUtil.copyToList(list, ConverterDetailStatisticsDTO.class);
SendParam param = new SendParam();
param.setStats(converterDetailStatisticsDTOS);
String s = JSONObject.toJSONStringWithDateFormat(param, JSON.DEFFAULT_DATE_FORMAT);
log.info(Thread.currentThread().getName() + "获取返回体 换流站指标统计明细数据接口数据：" + s + "开始----！");
Map<String, String> send = GwSendUtil.send(param, GWSendEnum.DETAIL_CREATE);
log.info(Thread.currentThread().getName() + "获取返回体换流站指标统计明细数据接口响应结果：" + send + "结束----！");
List<String> trIds = converterDetailStatisticsDTOS.stream().map(ConverterDetailStatisticsDTO::getId).distinct().collect(Collectors.toList());
return returnInformation(1, trIds, send);
}
/**
* 国网上送返回信息
*
* @param num
* @param ids
* @param send
* @return
*/
private String returnInformation(Integer num, List<String> ids, Map<String, String> send) {
if (send.containsKey("succeed")) {
String succeed = send.get("succeed");
if (succeed.indexOf("\\\"") != -1) {
succeed = succeed.replace("\\\"", "\"");
}
Map mapData = JSON.parseObject(succeed, Map.class);
String status = mapData.get("status").toString();
if ("000000".equals(status)) {
//修改信息状态
String result = mapData.get("result").toString();
Map mapCount = JSON.parseObject(result, Map.class);
String count = mapCount.get("count").toString();
return "操作成功:成功数据" + count + "条";
} else {
String errors = mapData.get("errors").toString();
throw new BusinessException("操作失败:" + status + "_" + errors);
}
} else {
// updateIsUploadHead(num, ids);
throw new BusinessException("当前时间段国网上送请求过多，请稍后再试");
// return "当前时间段国网上送请求过多，请稍后再试";
}
}
}

68
pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/send/impl/PqTypicalSourceCreatePOServiceImpl.java
View File

@@ -1,17 +1,28 @@
package com.njcn.harmonic.service.send.impl;
import cn.hutool.core.bean.BeanUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.njcn.common.pojo.exception.BusinessException;
import com.njcn.harmonic.mapper.send.PqTypicalSourceCreatePOMapper;
import com.njcn.harmonic.pojo.param.SendParam;
import com.njcn.harmonic.pojo.dto.PqTypicalSourceCreateDTO;
import com.njcn.harmonic.pojo.param.SendQueryParam;
import com.njcn.harmonic.pojo.po.send.PqTypicalSourceCreatePO;
import com.njcn.harmonic.service.send.PqTypicalSourceCreatePOService;
import com.njcn.user.api.DeptFeignClient;
import com.njcn.web.enums.GWSendEnum;
import com.njcn.web.pojo.param.SendParam;
import com.njcn.web.utils.GwSendUtil;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
/**
*
@@ -23,12 +34,13 @@ import java.util.List;
*/
@Service
@RequiredArgsConstructor
@Slf4j
public class PqTypicalSourceCreatePOServiceImpl extends ServiceImpl<PqTypicalSourceCreatePOMapper, PqTypicalSourceCreatePO> implements PqTypicalSourceCreatePOService {
private final DeptFeignClient deptFeignClient;
@Override
public Page<PqTypicalSourceCreatePO> queryPage(SendParam.SendPageParam param) {
public Page<PqTypicalSourceCreatePO> queryPage(SendQueryParam.SendPageParam param) {
Page<PqTypicalSourceCreatePO> page = new Page<> (param.getCurrentPage ( ), param.getPageSize ( ));
List<String> deptIds = deptFeignClient.getDepSonSelfCodetByCode(param.getDeptIndex()).getData();
@@ -39,4 +51,56 @@ public class PqTypicalSourceCreatePOServiceImpl extends ServiceImpl<PqTypicalSou
return pqTypicalSourceCreatePOPage;
}
@Override
public String send(List<String> ids) {
List<PqTypicalSourceCreatePO> list = this.lambdaQuery().eq(PqTypicalSourceCreatePO::getId, ids).list();
if (list.size() > 100) {
throw new BusinessException("一次最多上送100条数据");
}
List<PqTypicalSourceCreateDTO> pqTypicalSourceCreateDTOList = BeanUtil.copyToList(list, PqTypicalSourceCreateDTO.class);
SendParam param = new SendParam();
param.setStats(pqTypicalSourceCreateDTOList);
String s = JSONObject.toJSONStringWithDateFormat(param, JSON.DEFFAULT_DATE_FORMAT);
log.info(Thread.currentThread().getName() + "获取返回体 换流站指标统计明细数据接口数据：" + s + "开始----！");
Map<String, String> send = GwSendUtil.send(param, GWSendEnum.TYPICAL_SOURCE);
log.info(Thread.currentThread().getName() + "获取返回体换流站指标统计明细数据接口响应结果：" + send + "结束----！");
List<String> trIds = pqTypicalSourceCreateDTOList.stream().map(PqTypicalSourceCreateDTO::getId).distinct().collect(Collectors.toList());
return returnInformation(1, trIds, send);
}
/**
* 国网上送返回信息
*
* @param num
* @param ids
* @param send
* @return
*/
private String returnInformation(Integer num, List<String> ids, Map<String, String> send) {
if (send.containsKey("succeed")) {
String succeed = send.get("succeed");
if (succeed.indexOf("\\\"") != -1) {
succeed = succeed.replace("\\\"", "\"");
}
Map mapData = JSON.parseObject(succeed, Map.class);
String status = mapData.get("status").toString();
if ("000000".equals(status)) {
//修改信息状态
String result = mapData.get("result").toString();
Map mapCount = JSON.parseObject(result, Map.class);
String count = mapCount.get("count").toString();
return "操作成功:成功数据" + count + "条";
} else {
String errors = mapData.get("errors").toString();
throw new BusinessException("操作失败:" + status + "_" + errors);
}
} else {
// updateIsUploadHead(num, ids);
throw new BusinessException("当前时间段国网上送请求过多，请稍后再试");
// return "当前时间段国网上送请求过多，请稍后再试";
}
}
}

69
pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/send/impl/SubstationQualityStatisticsPOServiceImpl.java
View File

@@ -1,17 +1,28 @@
package com.njcn.harmonic.service.send.impl;
import cn.hutool.core.bean.BeanUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.njcn.common.pojo.exception.BusinessException;
import com.njcn.harmonic.mapper.send.SubstationQualityStatisticsPOMapper;
import com.njcn.harmonic.pojo.param.SendParam;
import com.njcn.harmonic.pojo.dto.SubstationQualityStatisticsDTO;
import com.njcn.harmonic.pojo.param.SendQueryParam;
import com.njcn.harmonic.pojo.po.send.SubstationQualityStatisticsPO;
import com.njcn.harmonic.service.send.SubstationQualityStatisticsPOService;
import com.njcn.user.api.DeptFeignClient;
import com.njcn.web.enums.GWSendEnum;
import com.njcn.web.pojo.param.SendParam;
import com.njcn.web.utils.GwSendUtil;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
/**
*
@@ -23,6 +34,7 @@ import java.util.List;
*/
@Service
@RequiredArgsConstructor
@Slf4j
public class SubstationQualityStatisticsPOServiceImpl extends ServiceImpl<SubstationQualityStatisticsPOMapper, SubstationQualityStatisticsPO> implements SubstationQualityStatisticsPOService {
@@ -30,7 +42,7 @@ public class SubstationQualityStatisticsPOServiceImpl extends ServiceImpl<Substa
@Override
public Page<SubstationQualityStatisticsPO> queryPage(SendParam.SendPageParam param) {
public Page<SubstationQualityStatisticsPO> queryPage(SendQueryParam.SendPageParam param) {
Page<SubstationQualityStatisticsPO> page = new Page<> (param.getCurrentPage ( ), param.getPageSize ( ));
List<String> deptIds = deptFeignClient.getDepSonSelfCodetByCode(param.getDeptIndex()).getData();
@@ -41,4 +53,57 @@ public class SubstationQualityStatisticsPOServiceImpl extends ServiceImpl<Substa
return substationQualityStatisticsPOPage;
}
@Override
public String send(List<String> ids) {
List<SubstationQualityStatisticsPO> list = this.lambdaQuery().eq(SubstationQualityStatisticsPO::getId, ids).list();
if (list.size() > 100) {
throw new BusinessException("一次最多上送100条数据");
}
List<SubstationQualityStatisticsDTO> substationQualityStatisticsDTOList = BeanUtil.copyToList(list, SubstationQualityStatisticsDTO.class);
SendParam param = new SendParam();
param.setStats(substationQualityStatisticsDTOList);
String s = JSONObject.toJSONStringWithDateFormat(param, JSON.DEFFAULT_DATE_FORMAT);
log.info(Thread.currentThread().getName() + "获取返回体 换流站指标统计明细数据接口数据：" + s + "开始----！");
Map<String, String> send = GwSendUtil.send(param, GWSendEnum.SUBSTATION_MONITOR);
log.info(Thread.currentThread().getName() + "获取返回体换流站指标统计明细数据接口响应结果：" + send + "结束----！");
List<String> trIds = substationQualityStatisticsDTOList.stream().map(SubstationQualityStatisticsDTO::getId).distinct().collect(Collectors.toList());
return returnInformation(1, trIds, send);
}
/**
* 国网上送返回信息
*
* @param num
* @param ids
* @param send
* @return
*/
private String returnInformation(Integer num, List<String> ids, Map<String, String> send) {
if (send.containsKey("succeed")) {
String succeed = send.get("succeed");
if (succeed.indexOf("\\\"") != -1) {
succeed = succeed.replace("\\\"", "\"");
}
Map mapData = JSON.parseObject(succeed, Map.class);
String status = mapData.get("status").toString();
if ("000000".equals(status)) {
//修改信息状态
String result = mapData.get("result").toString();
Map mapCount = JSON.parseObject(result, Map.class);
String count = mapCount.get("count").toString();
return "操作成功:成功数据" + count + "条";
} else {
String errors = mapData.get("errors").toString();
throw new BusinessException("操作失败:" + status + "_" + errors);
}
} else {
// updateIsUploadHead(num, ids);
throw new BusinessException("当前时间段国网上送请求过多，请稍后再试");
// return "当前时间段国网上送请求过多，请稍后再试";
}
}
}