From 3fe2aea7827eafc7513159db9a337fdf567584c8 Mon Sep 17 00:00:00 2001
From: Your Name <you@example.com>
Date: 星期一, 08 五月 2023 01:21:13 +0800
Subject: [PATCH] Merge branch 'master' of http://git.homecommunity.cn/supervip/MicroCommunity
---
service-common/src/main/java/com/java110/common/smartMeter/factory/zhongkong/ZhongkongDianBiaoFactoryAdaptImpl.java | 106 +++++++++++++++++++++++++++++++++++++++++++++++++++--
1 files changed, 102 insertions(+), 4 deletions(-)
diff --git a/service-common/src/main/java/com/java110/common/smartMeter/factory/zhongkong/ZhongkongDianBiaoFactoryAdaptImpl.java b/service-common/src/main/java/com/java110/common/smartMeter/factory/zhongkong/ZhongkongDianBiaoFactoryAdaptImpl.java
index 446b6f3..f1730b4 100644
--- a/service-common/src/main/java/com/java110/common/smartMeter/factory/zhongkong/ZhongkongDianBiaoFactoryAdaptImpl.java
+++ b/service-common/src/main/java/com/java110/common/smartMeter/factory/zhongkong/ZhongkongDianBiaoFactoryAdaptImpl.java
@@ -1,16 +1,30 @@
package com.java110.common.smartMeter.factory.zhongkong;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
+import com.java110.common.smartMeter.ISmartMeterCoreRead;
import com.java110.common.smartMeter.ISmartMeterFactoryAdapt;
+import com.java110.common.smartMeter.factory.tqdianbiao.TdDianBiaoUtil;
+import com.java110.core.factory.GenerateCodeFactory;
import com.java110.dto.fee.FeeConfigDto;
+import com.java110.dto.meterMachine.MeterMachineDetailDto;
import com.java110.dto.meterMachine.MeterMachineDto;
+import com.java110.dto.meterMachine.MeterMachineSpecDto;
+import com.java110.intf.common.IMeterMachineDetailV1InnerServiceSMO;
+import com.java110.intf.common.IMeterMachineSpecV1InnerServiceSMO;
+import com.java110.intf.common.IMeterMachineV1InnerServiceSMO;
import com.java110.intf.fee.IPayFeeConfigV1InnerServiceSMO;
+import com.java110.po.meterMachineDetail.MeterMachineDetailPo;
+import com.java110.utils.cache.UrlCache;
+import com.java110.utils.util.Assert;
import com.java110.vo.ResultVo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpMethod;
import org.springframework.stereotype.Service;
import java.math.BigDecimal;
+import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -21,12 +35,30 @@
@Service("zhongkongDianBiaoFactoryAdaptImpl")
public class ZhongkongDianBiaoFactoryAdaptImpl implements ISmartMeterFactoryAdapt {
- private static final String RECHARGE_URL = "http://watergateway.dev.mj.ink:9900/mjkj-water/mjkj/open/wy/recharge";
- private static final String READ_URL = "http://watergateway.dev.mj.ink:9900/mjkj-water/mjkj/open/wy/get/amount";
+ private static final String RECHARGE_URL = "http://www.zhckxt.com/api/mjkj-water/mjkj/open/wy/recharge";
+
+ private static final String READ_URL = "http://www.zhckxt.com/api/mjkj-water/mjkj/open/wy/get/amount";
+
+ private static final String READS_URL = "http://www.zhckxt.com/api/mjkj-water/mjkj/open/wy/get/lastNum";
+
+ private static final String NOTIFY_URL = "/app/smartMeter/notify/zhongkongDianBiaoFactoryAdaptImpl/992020051967020024";
+
+
+ @Autowired
+ private IMeterMachineSpecV1InnerServiceSMO meterMachineSpecV1InnerServiceSMOImpl;
+
+ @Autowired
+ private IMeterMachineDetailV1InnerServiceSMO meterMachineDetailV1InnerServiceSMOImpl;
@Autowired
private IPayFeeConfigV1InnerServiceSMO feeConfigV1InnerServiceSMOImpl;
+
+ @Autowired
+ private IMeterMachineV1InnerServiceSMO meterMachineV1InnerServiceSMOImpl;
+
+ @Autowired
+ private ISmartMeterCoreRead smartMeterCoreReadImpl;
@Override
@@ -75,11 +107,77 @@
@Override
public ResultVo requestReads(List<MeterMachineDto> meterMachineDtos) {
- return null;
+
+ List<Map<String, Object>> req = new ArrayList<>();
+ List<MeterMachineDetailPo> meterMachineDetailPos = new ArrayList<>();
+ String detailId = "";
+ List<String> bhLists = new ArrayList<>();
+ for (MeterMachineDto meterMachineDto : meterMachineDtos) {
+ detailId = GenerateCodeFactory.getGeneratorId("11");
+ bhLists.add(meterMachineDto.getAddress());
+ MeterMachineDetailPo meterMachineDetailPo = new MeterMachineDetailPo();
+ meterMachineDetailPo.setCommunityId(meterMachineDto.getCommunityId());
+ meterMachineDetailPo.setDetailId(detailId);
+ meterMachineDetailPo.setMachineId(meterMachineDto.getMachineId());
+ meterMachineDetailPo.setDetailType(meterMachineDto.getMachineModel()); // 鎶勮〃
+ meterMachineDetailPo.setCurDegrees(meterMachineDto.getCurDegrees());
+ meterMachineDetailPo.setCurReadingTime(meterMachineDto.getCurReadingTime());
+ meterMachineDetailPo.setPrestoreDegrees(meterMachineDto.getPrestoreDegrees());
+ meterMachineDetailPo.setState(MeterMachineDetailDto.STATE_W);
+ meterMachineDetailPos.add(meterMachineDetailPo);
+ }
+
+ Map reqParams = new HashMap();
+ reqParams.put("callbackUrl",UrlCache.getOwnerUrl() + NOTIFY_URL);
+ reqParams.put("bhList",bhLists);
+
+ String response = WyRequestUtils.executeReads(READS_URL, reqParams, HttpMethod.POST);
+
+ JSONObject paramOut = JSONObject.parseObject(response);
+
+ if (paramOut.getIntValue("code") != 200) {
+ return new ResultVo(ResultVo.CODE_ERROR, paramOut.getString("msg"));
+ }
+
+
+
+ if (meterMachineDetailPos.size() > 0) {
+ meterMachineDetailV1InnerServiceSMOImpl.saveMeterMachineDetails(meterMachineDetailPos);
+ }
+
+ return new ResultVo(ResultVo.CODE_OK, "璇锋眰宸插彂閫侊紝绛夊緟鐢佃〃鍙嶉鏁版嵁");
}
@Override
public ResultVo notifyReadData(String readData) {
- return null;
+
+ JSONObject data = JSONObject.parseObject(readData);
+
+ MeterMachineDto meterMachineDto = new MeterMachineDto();
+ meterMachineDto.setAddress(data.getString("bh"));
+ List<MeterMachineDto> meterMachineDtos = meterMachineV1InnerServiceSMOImpl.queryMeterMachines(meterMachineDto);
+ Assert.listOnlyOne(meterMachineDtos,"琛ㄤ笉瀛樺湪");
+
+ MeterMachineDetailDto meterMachineDetailDto = new MeterMachineDetailDto();
+ meterMachineDetailDto.setCommunityId(meterMachineDtos.get(0).getCommunityId());
+ meterMachineDetailDto.setMachineId(meterMachineDtos.get(0).getMachineId());
+ meterMachineDetailDto.setState(MeterMachineDetailDto.STATE_W);
+ List<MeterMachineDetailDto> meterMachineDetailDtos = meterMachineDetailV1InnerServiceSMOImpl.queryMeterMachineDetails(meterMachineDetailDto);
+ if (meterMachineDetailDtos == null || meterMachineDetailDtos.size() < 1) {
+ return new ResultVo(ResultVo.CODE_ERROR, "娌℃湁鏁版嵁");
+ }
+
+ String batchId = smartMeterCoreReadImpl.generatorBatch(meterMachineDetailDtos.get(0).getCommunityId());
+ doBusiness(data, batchId,meterMachineDetailDtos);
+
+ return new ResultVo(ResultVo.CODE_OK, "鎴愬姛");
+ }
+
+
+ private void doBusiness(JSONObject contentObject, String batchId, List<MeterMachineDetailDto> meterMachineDetailDtos) {
+
+ double degree = contentObject.getDoubleValue("bqds");
+
+ smartMeterCoreReadImpl.saveMeterAndCreateFee(meterMachineDetailDtos.get(0), degree + "", batchId);
}
}
--
Gitblit v1.8.0