...
|
...
|
@@ -112,30 +112,11 @@ public class ElectricityMeterServiceImp implements ElectricityMeterService { |
|
|
}
|
|
|
if ("0".equals(rechargeDevicesResult.getErrcode()) && message == true) {
|
|
|
log.info("电表充值成功,充值额度:{}", money);
|
|
|
ElectricityMeter energyInfoForRealTime = getEnergyInfoForRealTime(deviceId);
|
|
|
if (energyInfoForRealTime.getBalance() != null){
|
|
|
int i = energyInfoForRealTime.getBalance().compareTo(BigDecimal.ZERO);
|
|
|
if (i > 0){
|
|
|
/**
|
|
|
* 通知送电
|
|
|
*/
|
|
|
Map<String, Object> map = new HashMap<>();
|
|
|
map.put("deviceId", deviceId);
|
|
|
map.put("action", "1");
|
|
|
String postResult = HttpsUtils.sendPost(remoteControlDevices, map);
|
|
|
RechargeDevicesResult rechargeDevicesResult1 = JSON.parseObject(postResult, RechargeDevicesResult.class);
|
|
|
if ("0".equals(rechargeDevicesResult1.getErrcode())){
|
|
|
// 成功不处理
|
|
|
log.info("送电成功------------------------");
|
|
|
}else {
|
|
|
// 失败插入临时表
|
|
|
ElectrifyInfo electrifyInfo = new ElectrifyInfo();
|
|
|
electrifyInfo.setDeviceid(deviceId);
|
|
|
electrifyInfoMapper.insertSelective(electrifyInfo);
|
|
|
log.info("送电失败插入临时表-----------------------------");
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
// 插入临时表交由定时服务处理
|
|
|
ElectrifyInfo electrifyInfo1 = new ElectrifyInfo();
|
|
|
electrifyInfo1.setDeviceid(deviceId);
|
|
|
electrifyInfoMapper.insertSelective(electrifyInfo1);
|
|
|
log.info("送电信息插入临时表-----------------------------------");
|
|
|
return 1;
|
|
|
} else {
|
|
|
log.info("电表充值失败,充值额度:{}", money);
|
...
|
...
|
|