feat: 把modev表数据导入nsensor表

haikang
huangfeng 1 year ago
parent 23e1774ac5
commit 9b3e959ae9

@ -150,4 +150,11 @@ public class NSensorController extends BasicController {
reportService.exportSensor(detail, response.getOutputStream());
}
@PostMapping("importFromModev")
@ApiOperation("从modev表导入")
public Response<String> importFromModev() throws Exception {
String str = service.importFromModev();
return Response.success(str);
}
}

@ -119,4 +119,14 @@ public class Modev {
@ApiModelProperty("监测设备类型名称")
@Transient
private String modevtname;
public NSensor transform(){
NSensor sensor = NSensor.builder()
.name(name)
.typeId(modevtid)
.devId(id)
.zsbId(zsbid)
.build();
return sensor;
}
}

@ -20,4 +20,6 @@ public interface NSensorRepository extends JpaRepository<NSensor, Integer>, JpaS
List<NSensor> findByIcdIdAndIdIsNot(Integer icdid, Integer id);
List<NSensor> findByTypeId(Integer typeId);
List<NSensor> findByDevId(Integer devId);
}

@ -28,4 +28,6 @@ public interface NSensorService {
void importOne(NSensor sensor);
String importFromModev() throws Exception;
}

@ -1,11 +1,13 @@
package com.xydl.cac.service.impl;
import com.xydl.cac.entity.*;
import com.xydl.cac.entity.constants.Constants;
import com.xydl.cac.exception.BusinessException;
import com.xydl.cac.model.ConditionModel;
import com.xydl.cac.model.OnePage;
import com.xydl.cac.model.SensorDetail;
import com.xydl.cac.model.SensorUpdateModel;
import com.xydl.cac.repository.ModevRepository;
import com.xydl.cac.repository.NSensorRepository;
import com.xydl.cac.service.*;
import lombok.extern.slf4j.Slf4j;
@ -34,6 +36,8 @@ public class NSensorServiceImpl implements NSensorService {
ModevTypeService modevTypeService;
@Resource
ModevTypePointService modevTypePointService;
@Resource
ModevRepository modevRepository;
@Override
public List<NSensor> listAll(Integer zsbid) throws Exception {
@ -88,6 +92,7 @@ public class NSensorServiceImpl implements NSensorService {
@Override
public NSensor add(NSensor item) throws Exception {
item.setId(null);
item.setStatus(Constants.NORMAL);
return repository.save(item);
}
@ -185,4 +190,22 @@ public class NSensorServiceImpl implements NSensorService {
repository.save(item);
}
@Override
public String importFromModev() throws Exception {
int success = 0;
int skip = 0;
List<Modev> list = modevRepository.findAll();
for (Modev item : list) {
NSensor sensor = item.transform();
List<NSensor> slist = repository.findByDevId(sensor.getDevId());
if (CollectionUtils.isEmpty(list)) {
this.add(sensor);
success++;
} else {
skip++;
}
}
return "成功导入" + success + "个,跳过" + skip + "个";
}
}

Loading…
Cancel
Save