| | |
| | | import com.java110.common.smartMeter.ISmartMeterCoreRead; |
| | | import com.java110.common.smartMeter.ISmartMeterFactoryAdapt; |
| | | import com.java110.core.factory.GenerateCodeFactory; |
| | | import com.java110.dto.meterMachine.MeterMachineDto; |
| | | import com.java110.dto.meterMachineDetail.MeterMachineDetailDto; |
| | | import com.java110.dto.meterMachineSpec.MeterMachineSpecDto; |
| | | import com.java110.dto.meter.MeterMachineDto; |
| | | import com.java110.dto.meter.MeterMachineDetailDto; |
| | | import com.java110.dto.meter.MeterMachineSpecDto; |
| | | import com.java110.intf.common.IMeterMachineDetailV1InnerServiceSMO; |
| | | import com.java110.intf.common.IMeterMachineSpecV1InnerServiceSMO; |
| | | import com.java110.intf.common.IMeterMachineV1InnerServiceSMO; |
| | | import com.java110.intf.user.IUserInnerServiceSMO; |
| | | import com.java110.po.meterMachineDetail.MeterMachineDetailPo; |
| | | import com.java110.po.meter.MeterMachineDetailPo; |
| | | import com.java110.utils.cache.UrlCache; |
| | | import com.java110.vo.ResultVo; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | |
| | | |
| | | private static final String RECHARGE_URL = "http://api2.tqdianbiao.com/Api_v2/ele_security/recharge"; |
| | | |
| | | private static final String NOTIFY_URL = "/app/smartMeter/notify/tqDianBiaoRemoteDanFeiLvPreFactoryAdaptImpl/992020051967020024"; |
| | | private static final String NOTIFY_URL = "/app/smartMeter/notify/b"; |
| | | @Autowired |
| | | private IMeterMachineSpecV1InnerServiceSMO meterMachineSpecV1InnerServiceSMOImpl; |
| | | |
| | |
| | | if (meterMachineDetailPos.size() > 0) { |
| | | meterMachineDetailV1InnerServiceSMOImpl.saveMeterMachineDetails(meterMachineDetailPos); |
| | | } |
| | | |
| | | //todo 下发查询余额 |
| | | requestRead(meterMachineDto); |
| | | |
| | | return new ResultVo(ResultVo.CODE_OK, "请求已发送,等待电表反馈数据"); |
| | | } |
| | | |
| | |
| | | String detailId = GenerateCodeFactory.getGeneratorId("11"); |
| | | Map<String, Object> item = new HashMap<>(); |
| | | item.put("opr_id", detailId); |
| | | item.put("time_out", 0); |
| | | item.put("time_out", 3); |
| | | item.put("must_online", true); |
| | | item.put("retry_times", 1); |
| | | item.put("cid", meterMachineSpecDtos.get(0).getSpecValue()); |
| | | item.put("address", meterMachineDto.getAddress()); |
| | | item.put("type", 3); |
| | | item.put("type", 22); |
| | | req.add(item); |
| | | List<MeterMachineDetailPo> meterMachineDetailPos = new ArrayList<>(); |
| | | MeterMachineDetailPo meterMachineDetailPo = new MeterMachineDetailPo(); |
| | |
| | | if (meterMachineDetailPos.size() > 0) { |
| | | meterMachineDetailV1InnerServiceSMOImpl.saveMeterMachineDetails(meterMachineDetailPos); |
| | | } |
| | | return new ResultVo(ResultVo.CODE_OK, "提交重置"); |
| | | return new ResultVo(ResultVo.CODE_OK, "提交查询"); |
| | | } |
| | | |
| | | @Override |
| | |
| | | item.put("retry_times", 1); |
| | | item.put("cid", meterMachineSpecDtos.get(0).getSpecValue()); |
| | | item.put("address", meterMachineDto.getAddress()); |
| | | item.put("type", 3); |
| | | item.put("type", 22); |
| | | req.add(item); |
| | | |
| | | MeterMachineDetailPo meterMachineDetailPo = new MeterMachineDetailPo(); |