完成智能水电表导入功能

service-job/src/main/java/com/java110/job/importData/adapt/ImportMeterMachineQueueDataAdapt.java

@@ -1,18 +1,55 @@
 package com.java110.job.importData.adapt;
 
+import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
+import com.java110.core.factory.GenerateCodeFactory;
+import com.java110.dto.fee.FeeConfigDto;
 import com.java110.dto.importData.ImportMeterMachineDto;
 import com.java110.dto.importData.ImportOwnerRoomDto;
 import com.java110.dto.log.AssetImportLogDetailDto;
+import com.java110.dto.meter.MeterMachineDto;
+import com.java110.dto.meter.MeterTypeDto;
+import com.java110.dto.room.RoomDto;
+import com.java110.intf.common.IMeterMachineSpecV1InnerServiceSMO;
+import com.java110.intf.common.IMeterMachineV1InnerServiceSMO;
+import com.java110.intf.community.IRoomV1InnerServiceSMO;
+import com.java110.intf.fee.IFeeConfigInnerServiceSMO;
+import com.java110.intf.fee.IMeterTypeV1InnerServiceSMO;
 import com.java110.job.importData.DefaultImportData;
 import com.java110.job.importData.IImportDataAdapt;
+import com.java110.po.meter.MeterMachinePo;
+import com.java110.po.meter.MeterMachineSpecPo;
+import com.java110.utils.exception.CmdException;
+import com.java110.utils.util.Assert;
 import com.java110.utils.util.BeanConvertUtil;
+import com.java110.utils.util.DateUtil;
+import com.java110.utils.util.StringUtil;
+import com.java110.vo.ResultVo;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.util.List;
 
 @Service("importMeterMachineQueueData")
 public class ImportMeterMachineQueueDataAdapt extends DefaultImportData implements IImportDataAdapt {
+
+    public static final String CODE_PREFIX_ID = "10";
+
+    @Autowired
+    private IMeterMachineV1InnerServiceSMO meterMachineV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IFeeConfigInnerServiceSMO feeConfigInnerServiceSMOImpl;
+
+    @Autowired
+    private IMeterMachineSpecV1InnerServiceSMO meterMachineSpecV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IRoomV1InnerServiceSMO roomV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IMeterTypeV1InnerServiceSMO meterTypeV1InnerServiceSMOImpl;
+
     @Override
     public void importData(List<AssetImportLogDetailDto> assetImportLogDetailDtos) {
         for (AssetImportLogDetailDto assetImportLogDetailDto : assetImportLogDetailDtos) {
@@ -34,11 +71,67 @@ public class ImportMeterMachineQueueDataAdapt extends DefaultImportData implemen
      */
     private void doImportData(AssetImportLogDetailDto assetImportLogDetailDto) {
         JSONObject data = JSONObject.parseObject(assetImportLogDetailDto.getContent());
-        ImportMeterMachineDto importOwnerRoomDto = BeanConvertUtil.covertBean(data, ImportMeterMachineDto.class);
-//        int flag = importOwnerRoomInnerServiceSMOImpl.saveOwnerRoom(importOwnerRoomDto);
-//        if (flag < 1) {
-//            throw new IllegalArgumentException("导入失败");
-//        }
+        ImportMeterMachineDto importMeterMachineDto = BeanConvertUtil.covertBean(data, ImportMeterMachineDto.class);
+        FeeConfigDto feeConfigDto = new FeeConfigDto();
+        feeConfigDto.setFeeName(importMeterMachineDto.getFeeName());
+        feeConfigDto.setCommunityId(importMeterMachineDto.getCommunityId());
+        List<FeeConfigDto> feeConfigDtos = feeConfigInnerServiceSMOImpl.queryFeeConfigs(feeConfigDto);
+        Assert.listOnlyOne(feeConfigDtos, "费用项不存在或存在多条");
+
+        String[] roomItems = importMeterMachineDto.getRoomName().split("-", 3);
+        //查询房屋
+        RoomDto roomDto = new RoomDto();
+        roomDto.setFloorNum(roomItems[0]);
+        roomDto.setUnitNum(roomItems[1]);
+        roomDto.setRoomNum(roomItems[2]);
+        roomDto.setCommunityId(importMeterMachineDto.getCommunityId());
+        List<RoomDto> roomDtos = roomV1InnerServiceSMOImpl.queryRooms(roomDto);
+        Assert.listOnlyOne(roomDtos, "房屋不存在");
+
+        MeterTypeDto meterTypeDto = new MeterTypeDto();
+        meterTypeDto.setCommunityId(importMeterMachineDto.getCommunityId());
+        meterTypeDto.setTypeName(importMeterMachineDto.getMeterType());
+        List<MeterTypeDto> meterTypeDtos = meterTypeV1InnerServiceSMOImpl.queryMeterTypes(meterTypeDto);
+
+        Assert.listOnlyOne(meterTypeDtos, "房屋不存在");
+
+
+        MeterMachinePo meterMachinePo = BeanConvertUtil.covertBean(importMeterMachineDto, MeterMachinePo.class);
+        meterMachinePo.setMachineId(GenerateCodeFactory.getGeneratorId(CODE_PREFIX_ID));
+        meterMachinePo.setFeeConfigName(feeConfigDtos.get(0).getFeeName());
+        meterMachinePo.setCurDegrees("0");
+        meterMachinePo.setCurReadingTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
+        meterMachinePo.setPrestoreDegrees("0");
+        meterMachinePo.setHeartbeatTime(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
+        meterMachinePo.setFeeConfigId(feeConfigDtos.get(0).getConfigId());
+        meterMachinePo.setReadDay(1);
+        meterMachinePo.setReadHours(1);
+        meterMachinePo.setRoomId(roomDtos.get(0).getRoomId());
+        meterMachinePo.setMeterType(meterTypeDtos.get(0).getTypeId());
+
+        int flag = meterMachineV1InnerServiceSMOImpl.saveMeterMachine(meterMachinePo);
+
+        if (flag < 1) {
+            throw new CmdException("保存数据失败");
+        }
+        if (!StringUtil.isEmpty(importMeterMachineDto.getValue1())) {
+            return;
+        }
+
+        MeterMachineSpecPo meterMachineSpecPo = null;
+        meterMachineSpecPo = new MeterMachineSpecPo();
+        meterMachineSpecPo.setMachineId(meterMachinePo.getMachineId());
+        meterMachineSpecPo.setSpecId("120101");
+        meterMachineSpecPo.setSpecName("采集器ID");
+        meterMachineSpecPo.setSpecValue(importMeterMachineDto.getValue1());
+        meterMachineSpecPo.setMmsId(GenerateCodeFactory.getGeneratorId(CODE_PREFIX_ID));
+        meterMachineSpecPo.setCommunityId(meterMachinePo.getCommunityId());
+        flag = meterMachineSpecV1InnerServiceSMOImpl.saveMeterMachineSpec(meterMachineSpecPo);
+
+        if (flag < 1) {
+            throw new CmdException("保存数据失败");
+        }
+
 
     }
 }