diff --git a/op-api/op-api-system/src/main/java/com/op/system/api/RemoteEnergyService.java b/op-api/op-api-system/src/main/java/com/op/system/api/RemoteEnergyService.java index b5ceaef0f..95a0bc93f 100644 --- a/op-api/op-api-system/src/main/java/com/op/system/api/RemoteEnergyService.java +++ b/op-api/op-api-system/src/main/java/com/op/system/api/RemoteEnergyService.java @@ -24,15 +24,6 @@ public interface RemoteEnergyService { @PostMapping("/buildInfo/removeDatasource") public R removeDatasource(@RequestBody DataSourcePropertyDTO dataSourceProperty); - @PostMapping(value = "/record/dnbInstant/getNhEnergy") - public R SyncNhEnergy(); - - @PostMapping(value = "/record/dnbInstant/getNhEnergyDetail") - public R SyncNhEnergyDetail(@RequestHeader Map header); - - @PostMapping(value = "/record/dnbInstant/fixWwEnergyData") - public R syncFixWwEnergyData(@RequestBody Map map, @RequestHeader Map header); - @PostMapping(value = "/report/dayDnb/genDailyEnergyData") public AjaxResult genDalyEnergyData(@RequestBody Map map, @RequestHeader Map header); } diff --git a/op-api/op-api-system/src/main/java/com/op/system/api/factory/RemoteEnergyFallbackFactory.java b/op-api/op-api-system/src/main/java/com/op/system/api/factory/RemoteEnergyFallbackFactory.java index f9ec9ac83..07bcd9f6b 100644 --- a/op-api/op-api-system/src/main/java/com/op/system/api/factory/RemoteEnergyFallbackFactory.java +++ b/op-api/op-api-system/src/main/java/com/op/system/api/factory/RemoteEnergyFallbackFactory.java @@ -30,21 +30,6 @@ public class RemoteEnergyFallbackFactory implements FallbackFactory header) { - return R.fail("同步电表实时数据失败:" + throwable.getMessage()); - } - - @Override - public R syncFixWwEnergyData(Map map, Map header) { - return R.fail("修正威伟电表数据失败:" + throwable.getMessage()); - } - @Override public AjaxResult genDalyEnergyData(Map map, Map header) { return AjaxResult.error("生成日报表数据失败:" + throwable.getMessage()); diff --git a/op-modules/op-energy/src/main/java/com/op/energy/record/controller/RecordDnbInstantController.java b/op-modules/op-energy/src/main/java/com/op/energy/record/controller/RecordDnbInstantController.java index dde20e5cc..a8a52df0c 100644 --- a/op-modules/op-energy/src/main/java/com/op/energy/record/controller/RecordDnbInstantController.java +++ b/op-modules/op-energy/src/main/java/com/op/energy/record/controller/RecordDnbInstantController.java @@ -190,27 +190,6 @@ public class RecordDnbInstantController extends BaseController { return AjaxResult.success(recordDnbInstantService.voltageCurrentCurve(baseDnbInstant)); } - /** - * 获取威伟电表能耗明细获取 - **/ - @PostMapping("/getNhEnergyDetail") - @ResponseBody - public AjaxResult getNhEnergyDetail() { - recordDnbInstantService.getNhEnergyDetail(); - return AjaxResult.success(); - } - - - /** - * 获取威伟电表能耗获取 - **/ - @PostMapping("/getNhEnergy") - @ResponseBody - public AjaxResult getNhEnergy() { - recordDnbInstantService.getNhEnergy(); - return AjaxResult.success(); - } - /** * 获取威伟电表能耗明细导出 **/ @@ -221,14 +200,4 @@ public class RecordDnbInstantController extends BaseController { ExcelUtil util = new ExcelUtil(RecordDnbInstant.class); util.exportExcel(response, list, "导出"); } - - /** - * 修正威伟电表数据 - **/ - @PostMapping("/fixWwEnergyData") - @ResponseBody - public AjaxResult fixWwEnergyData(@RequestBody Map params) { - recordDnbInstantService.fixWwEnergyData(params); - return AjaxResult.success(); - } } diff --git a/op-modules/op-energy/src/main/java/com/op/energy/record/service/IRecordDnbInstantService.java b/op-modules/op-energy/src/main/java/com/op/energy/record/service/IRecordDnbInstantService.java index af83344bd..c0232850f 100644 --- a/op-modules/op-energy/src/main/java/com/op/energy/record/service/IRecordDnbInstantService.java +++ b/op-modules/op-energy/src/main/java/com/op/energy/record/service/IRecordDnbInstantService.java @@ -88,11 +88,5 @@ public interface IRecordDnbInstantService { List voltageCurrentCurve(RecordDnbInstant baseDnbInstant); - void getNhEnergyDetail(); - - void getNhEnergy(); - List testGetNhEnergyDetail(Map params); - - void fixWwEnergyData(Map params); } diff --git a/op-modules/op-energy/src/main/java/com/op/energy/record/service/impl/RecordDnbInstantServiceImpl.java b/op-modules/op-energy/src/main/java/com/op/energy/record/service/impl/RecordDnbInstantServiceImpl.java index 4a9fe94e3..0b2d94308 100644 --- a/op-modules/op-energy/src/main/java/com/op/energy/record/service/impl/RecordDnbInstantServiceImpl.java +++ b/op-modules/op-energy/src/main/java/com/op/energy/record/service/impl/RecordDnbInstantServiceImpl.java @@ -253,155 +253,6 @@ public class RecordDnbInstantServiceImpl implements IRecordDnbInstantService { return recordDnbInstantMapper.selectRecordDnbInstantList(dnbInstant); } - @Override - @DS("#header.poolName") - public void getNhEnergyDetail() { - Map params = new HashMap<>(); - params.put("dateType", "mi15"); - Date nowTime = DateUtils.getNowDate(); - String startTime = DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM_SS, DateUtils.addMinutes(nowTime, -20)); - String endTime = DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM_SS, DateUtils.addMinutes(nowTime, -10)); - params.put("startTime", startTime); - params.put("endTime", endTime); -// params.put("startTime","2025-07-30 13:40:00"); -// params.put("endTime","2025-07-30 13:50:00"); - params.put("valueType", "SJZ"); - - - /** - * 电压/电流 - * **/ - AjaxResult voltageRes = remoteOpenService.getVoltageCurrent(params); - List list = new ArrayList<>(); - if (voltageRes.isSuccess()) { - JSONObject resData = JSONObject.parseObject(JSON.toJSONString(voltageRes.get(AjaxResult.DATA_TAG))); - JSONArray array = JSONArray.parseArray(resData.get("Data").toString()); - for (int i = 0; i < array.size(); i++) { - RecordDnbInstant instant = new RecordDnbInstant(); - instant.setVA(getSafeBigDecimal(array.getJSONObject(i), "ADY")); - instant.setVB(getSafeBigDecimal(array.getJSONObject(i), "BDY")); - instant.setVC(getSafeBigDecimal(array.getJSONObject(i), "CDY")); - instant.setIA(getSafeBigDecimal(array.getJSONObject(i), "ADL")); - instant.setIB(getSafeBigDecimal(array.getJSONObject(i), "BDL")); - instant.setIC(getSafeBigDecimal(array.getJSONObject(i), "CDL")); - instant.setMonitorId(array.getJSONObject(i).getString("Address")); - instant.setRecordTime(nowTime); - instant.setCollectTime(DateUtils.dateTime("yyyy-MM-dd HH:mm", array.getJSONObject(i).getString("ReadingDate"))); - list.add(instant); - } - } - - /** - * 功率 - * **/ - AjaxResult electricPowerRes = remoteOpenService.getElectricPower(params); - if (electricPowerRes.isSuccess()) { - JSONObject resData = JSONObject.parseObject(JSON.toJSONString(electricPowerRes.get(AjaxResult.DATA_TAG))); - JSONArray array = JSONArray.parseArray(resData.get("Data").toString()); - for (int i = 0; i < array.size(); i++) { - for (RecordDnbInstant item : list) { - String address = array.getJSONObject(i).getString("Address"); - if (address.equals(item.getMonitorId())) { - item.setGlys(getSafeBigDecimal(array.getJSONObject(i), "GLYS")); - item.setActivePower(getSafeBigDecimal(array.getJSONObject(i), "YGGL")); - item.setReactivePower(getSafeBigDecimal(array.getJSONObject(i), "WGGL")); - } - } - } - } - - /** - * 电量 - * **/ - AjaxResult electricQuantityRes = remoteOpenService.getElectricQuantity(params); - if (electricQuantityRes.isSuccess()) { - JSONObject resData = JSONObject.parseObject(JSON.toJSONString(electricQuantityRes.get(AjaxResult.DATA_TAG))); - JSONArray array = JSONArray.parseArray(resData.get("Data").toString()); - for (int i = 0; i < array.size(); i++) { - for (RecordDnbInstant item : list) { - String address = array.getJSONObject(i).getString("Address"); - if (address.equals(item.getMonitorId())) { - item.setZxyg(getSafeBigDecimal(array.getJSONObject(i), "ZYGDNSZ")); - item.setReactivePower(getSafeBigDecimal(array.getJSONObject(i), "ZYGDN")); - } - } - } - } - - for (RecordDnbInstant item : list) { - BaseMonitorInfo temp = new BaseMonitorInfo(); - temp.setAddressCode(item.getMonitorId()); - List baseList = baseMonitorInfoMapper.selectBaseMonitorInfoList(temp); - for (BaseMonitorInfo base : baseList) { - item.setMonitorId(base.getMonitorId()); - recordDnbInstantMapper.insertRecordDnbInstant(item); - } - } - - } - - @Override - public void getNhEnergy() { - Map params = new HashMap<>(); - params.put("dateType", "mi15"); - //获取当前时间的前后5分钟 - Date nowDate = DateUtils.getNowDate(); - //取整点数据 - String nowDateStr = DateUtils.parseDateToStr("yyyy-MM-dd HH", nowDate) + ":00:00"; - String startTime = DateUtils.parseDateToStr("yyyy-MM-dd HH", DateUtils.addHours(nowDate, -1)) + ":00:00"; - params.put("startTime", startTime); - params.put("endTime", nowDateStr); - params.put("valueType", "SJZ"); - - /** - * 电量 - * **/ - List list = new ArrayList<>(); - AjaxResult electricQuantityRes = remoteOpenService.getElectricQuantity(params); - if (electricQuantityRes.isSuccess()) { - JSONObject resData = JSONObject.parseObject(JSON.toJSONString(electricQuantityRes.get(AjaxResult.DATA_TAG))); - JSONArray array = JSONArray.parseArray(resData.get("Data").toString()); - //根据Address分类 - List addressList = new ArrayList<>(); - for (int i = 0; i < array.size(); i++) { - addressList.add(array.getJSONObject(i).getString("Address")); - } - //addressList去重 - addressList = addressList.stream().distinct().collect(Collectors.toList()); - - DynamicDataSourceContextHolder.push("ds_1000"); - try { - for (String address : addressList) { - ReportPointDnb dnb = new ReportPointDnb(); - BigDecimal electricQuantity = BigDecimal.ZERO; - for (int i = 0; i < array.size(); i++) { - if (address.equals(array.getJSONObject(i).getString("Address"))) { - electricQuantity = electricQuantity.add(getSafeBigDecimal(array.getJSONObject(i), "ZYGDN")); - } - } - dnb.setMeterValue(array.getJSONObject(0).getBigDecimal("ZYGDNSZ")); - dnb.setExpend(electricQuantity); - dnb.setMonitorId(address); - dnb.setBeginTime(DateUtils.dateTime(DateUtils.YYYY_MM_DD_HH_MM_SS, startTime)); - dnb.setEndTime(DateUtils.dateTime(DateUtils.YYYY_MM_DD_HH_MM_SS, nowDateStr)); - dnb.setRecordTime(new Date()); - dnb.setPointTime(removeLeadingZeros(DateUtils.parseDateToStr("HH", DateUtils.dateTime(DateUtils.YYYY_MM_DD_HH_MM_SS, startTime)))); - BaseMonitorInfo temp = new BaseMonitorInfo(); - temp.setConnCode(dnb.getMonitorId()); - List BaseList = baseMonitorInfoMapper.selectBaseMonitorInfoList(temp); - for (BaseMonitorInfo base : BaseList) { - dnb.setMonitorId(base.getMonitorId()); - reportPointDnbMapper.insertReportPointDnb(dnb); - } - } - } finally { - DynamicDataSourceContextHolder.poll(); - } - - - } - } - /** * 移除前面的0 **/ @@ -480,19 +331,4 @@ public class RecordDnbInstantServiceImpl implements IRecordDnbInstantService { return list; } - - @Override - @DS("#header.poolName") - public void fixWwEnergyData(Map params) { - //获取威伟电表 - BaseMonitorInfo query = new BaseMonitorInfo(); - query.setElectricityMeterType("2"); - List list = baseMonitorInfoMapper.selectBaseMonitorInfoList(query); - - for (BaseMonitorInfo info : list) { - params.put("monitorId", info.getMonitorId()); - reportPointDnbMapper.fixWwEnergyData(params); - } - - } } diff --git a/op-modules/op-energy/src/main/java/com/op/energy/report/mapper/ReportPointDnbMapper.java b/op-modules/op-energy/src/main/java/com/op/energy/report/mapper/ReportPointDnbMapper.java index 035416201..2ca2bf9d1 100644 --- a/op-modules/op-energy/src/main/java/com/op/energy/report/mapper/ReportPointDnbMapper.java +++ b/op-modules/op-energy/src/main/java/com/op/energy/report/mapper/ReportPointDnbMapper.java @@ -95,8 +95,6 @@ public interface ReportPointDnbMapper { List> datePointDnbGroupList(ReportPointDnb lineDnb); - Integer fixWwEnergyData(@Param("params") Map params); - int batchInsertReportPointDnb(@Param("list") List list); /** diff --git a/op-modules/op-energy/src/main/resources/mapper/report/ReportPointDnbMapper.xml b/op-modules/op-energy/src/main/resources/mapper/report/ReportPointDnbMapper.xml index 790909759..167a98d68 100644 --- a/op-modules/op-energy/src/main/resources/mapper/report/ReportPointDnbMapper.xml +++ b/op-modules/op-energy/src/main/resources/mapper/report/ReportPointDnbMapper.xml @@ -534,46 +534,6 @@ order by ert.pointTime asc - -