|
@@ -13,11 +13,13 @@ import com.slibra.business.service.IFrontService;
|
|
|
import com.slibra.common.core.controller.BaseController;
|
|
|
import com.slibra.common.core.domain.AjaxResult;
|
|
|
import com.slibra.common.core.domain.entity.SysUser;
|
|
|
+import com.slibra.common.utils.StringUtils;
|
|
|
import com.slibra.common.utils.poi.ExcelUtil;
|
|
|
import io.micrometer.core.annotation.Timed;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.checkerframework.checker.units.qual.C;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.transaction.annotation.Transactional;
|
|
|
import org.springframework.util.CollectionUtils;
|
|
|
import org.springframework.web.bind.annotation.*;
|
|
|
|
|
@@ -86,6 +88,7 @@ public class ExcelController extends BaseController {
|
|
|
* @return
|
|
|
*/
|
|
|
@GetMapping("/moreExcel2DB")
|
|
|
+// @Transactional
|
|
|
public String moreExcel2DB(){
|
|
|
//Excel转JSON
|
|
|
List<BZXQLHInfo> excelFormBZXQLH = getExcelFormBZXQLH();
|
|
@@ -98,6 +101,9 @@ public class ExcelController extends BaseController {
|
|
|
bzxqlhInfo.setNeighbourName(bzxqlhInfo.getArea() + bzxqlhInfo.getNeighbourName());
|
|
|
//2024年12月31日10:30:16 将区+泵站名称拼接作为泵站名称
|
|
|
bzxqlhInfo.setPumpingStationName(bzxqlhInfo.getArea() + bzxqlhInfo.getPumpingStationName());
|
|
|
+ //2024年12月31日11:23:14 解决楼号不存在,无法插入数据库的问题
|
|
|
+ if(StringUtils.isBlank(bzxqlhInfo.getBuildingName()))
|
|
|
+ bzxqlhInfo.setBuildingName("无");
|
|
|
}
|
|
|
Map<String, List<BZXQLHInfo>> map = excelFormBZXQLH.stream().collect(Collectors.groupingBy(BZXQLHInfo::getNeighbourName));
|
|
|
map.forEach((k, v) -> {
|
|
@@ -121,6 +127,7 @@ public class ExcelController extends BaseController {
|
|
|
if(CollectionUtils.isEmpty(pumpingStations)){
|
|
|
log.info("A第一次添加泵站信息,泵站名称是{}", pumpingStationName);
|
|
|
//新增泵站,然后再通过小区和楼号查询对应的数据,绑定关系
|
|
|
+ tPumpingStation.setName(pumpingStationName);
|
|
|
this.tPumpingStationMapper.insertTPumpingStation(tPumpingStation);
|
|
|
}else{
|
|
|
log.info("Z已经添加过泵站信息,泵站名称是{}", pumpingStationName);
|