|
@@ -20,16 +20,19 @@ import org.springblade.constant.BusinessConstant;
|
|
|
import org.springblade.core.boot.ctrl.BladeController;
|
|
import org.springblade.core.boot.ctrl.BladeController;
|
|
|
import org.springblade.core.tool.api.R;
|
|
import org.springblade.core.tool.api.R;
|
|
|
import org.springblade.core.tool.utils.Func;
|
|
import org.springblade.core.tool.utils.Func;
|
|
|
-import org.springblade.modules.business.check.order.dto.CheckOrderInfoDTO;
|
|
|
|
|
-import org.springblade.modules.business.check.process.vo.OrderProcessInfoVO;
|
|
|
|
|
-import org.springblade.modules.business.check.process.wrapper.RtuOrderProcessWrapper;
|
|
|
|
|
|
|
+import org.springblade.etl.entity.EtlWarningInfoEntity;
|
|
|
|
|
+import org.springblade.etl.service.IEtlWarningService;
|
|
|
import org.springblade.modules.system.entity.User;
|
|
import org.springblade.modules.system.entity.User;
|
|
|
import org.springblade.modules.system.service.IUserService;
|
|
import org.springblade.modules.system.service.IUserService;
|
|
|
-import org.springblade.modules.yjxt.business.check.dto.DanagerAreaCheckInfoDTO;
|
|
|
|
|
-import org.springblade.modules.yjxt.business.check.entity.DanagerAreaCheckInfoEntity;
|
|
|
|
|
-import org.springblade.modules.yjxt.business.check.service.IDanagerAreaCheckService;
|
|
|
|
|
|
|
+import org.springblade.modules.yjxt.business.check.dto.DangerAreaCheckInfoDTO;
|
|
|
|
|
+import org.springblade.modules.yjxt.business.check.entity.DangerAreaCheckInfoEntity;
|
|
|
|
|
+import org.springblade.modules.yjxt.business.check.service.IDangerAreaCheckService;
|
|
|
|
|
+import org.springblade.modules.yjxt.business.resident.dto.DangerAreaResidentInfoDTO;
|
|
|
|
|
+import org.springblade.modules.yjxt.business.resident.service.IDangerAreaResidentService;
|
|
|
import org.springblade.modules.yjxt.business.transfer.dto.DamageTransferPersonInfoDTO;
|
|
import org.springblade.modules.yjxt.business.transfer.dto.DamageTransferPersonInfoDTO;
|
|
|
|
|
+import org.springblade.modules.yjxt.business.transfer.entity.DamageTransferPersonInfoEntity;
|
|
|
import org.springblade.modules.yjxt.business.transfer.service.IDamageTransferPersonService;
|
|
import org.springblade.modules.yjxt.business.transfer.service.IDamageTransferPersonService;
|
|
|
|
|
+import org.springblade.modules.yjxt.business.transfer.vo.DamageTransferPersonInfoVO;
|
|
|
import org.springframework.web.bind.annotation.GetMapping;
|
|
import org.springframework.web.bind.annotation.GetMapping;
|
|
|
import org.springframework.web.bind.annotation.RequestMapping;
|
|
import org.springframework.web.bind.annotation.RequestMapping;
|
|
|
import org.springframework.web.bind.annotation.RestController;
|
|
import org.springframework.web.bind.annotation.RestController;
|
|
@@ -51,8 +54,11 @@ import java.util.*;
|
|
|
public class DataShareController extends BladeController {
|
|
public class DataShareController extends BladeController {
|
|
|
|
|
|
|
|
private final IUserService userService;
|
|
private final IUserService userService;
|
|
|
- private final IDanagerAreaCheckService danagerAreaCheckService;
|
|
|
|
|
|
|
+ private final IDangerAreaCheckService danagerAreaCheckService;
|
|
|
private final IDamageTransferPersonService damageTransferPersonService;
|
|
private final IDamageTransferPersonService damageTransferPersonService;
|
|
|
|
|
+ private final IDangerAreaResidentService dangerAreaResidentService;
|
|
|
|
|
+
|
|
|
|
|
+ private final IEtlWarningService warningService;
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
|
* 巡查巡检列表查询,不分页
|
|
* 巡查巡检列表查询,不分页
|
|
@@ -63,17 +69,17 @@ public class DataShareController extends BladeController {
|
|
|
})
|
|
})
|
|
|
@ApiOperationSupport(order = 1)
|
|
@ApiOperationSupport(order = 1)
|
|
|
@ApiOperation(value = "不分页", notes = "")
|
|
@ApiOperation(value = "不分页", notes = "")
|
|
|
- public R<List<JSONObject>> yjCheckList(DanagerAreaCheckInfoDTO dto) {
|
|
|
|
|
|
|
+ public R<List<JSONObject>> yjCheckList(DangerAreaCheckInfoDTO dto) {
|
|
|
if (Func.isNull(dto.getWarnId())) {
|
|
if (Func.isNull(dto.getWarnId())) {
|
|
|
return R.fail("参数错误");
|
|
return R.fail("参数错误");
|
|
|
}
|
|
}
|
|
|
- LambdaQueryWrapper<DanagerAreaCheckInfoEntity> wrapper = Wrappers.<DanagerAreaCheckInfoEntity>query().lambda();
|
|
|
|
|
- wrapper.eq(DanagerAreaCheckInfoEntity::getIsDeleted, 0);
|
|
|
|
|
- wrapper.eq(DanagerAreaCheckInfoEntity::getWarnId, dto.getWarnId());
|
|
|
|
|
- wrapper.orderByAsc(DanagerAreaCheckInfoEntity::getCreateTime);
|
|
|
|
|
- List<DanagerAreaCheckInfoEntity> list = danagerAreaCheckService.list(wrapper);
|
|
|
|
|
|
|
+ LambdaQueryWrapper<DangerAreaCheckInfoEntity> wrapper = Wrappers.<DangerAreaCheckInfoEntity>query().lambda();
|
|
|
|
|
+ wrapper.eq(DangerAreaCheckInfoEntity::getIsDeleted, 0);
|
|
|
|
|
+ wrapper.eq(DangerAreaCheckInfoEntity::getWarnId, dto.getWarnId());
|
|
|
|
|
+ wrapper.orderByAsc(DangerAreaCheckInfoEntity::getCreateTime);
|
|
|
|
|
+ List<DangerAreaCheckInfoEntity> list = danagerAreaCheckService.list(wrapper);
|
|
|
List<JSONObject> datas = new ArrayList<>(list.size());
|
|
List<JSONObject> datas = new ArrayList<>(list.size());
|
|
|
- for (DanagerAreaCheckInfoEntity entity : list) {
|
|
|
|
|
|
|
+ for (DangerAreaCheckInfoEntity entity : list) {
|
|
|
JSONObject d = new JSONObject();
|
|
JSONObject d = new JSONObject();
|
|
|
d.put("warnId", entity.getWarnId());
|
|
d.put("warnId", entity.getWarnId());
|
|
|
User user = userService.getById(entity.getCreateUser());
|
|
User user = userService.getById(entity.getCreateUser());
|
|
@@ -126,49 +132,50 @@ public class DataShareController extends BladeController {
|
|
|
if (Func.isNull(dto.getWarnId())) {
|
|
if (Func.isNull(dto.getWarnId())) {
|
|
|
return R.fail("参数错误");
|
|
return R.fail("参数错误");
|
|
|
}
|
|
}
|
|
|
- LambdaQueryWrapper<DanagerAreaCheckInfoEntity> wrapper = Wrappers.<DanagerAreaCheckInfoEntity>query().lambda();
|
|
|
|
|
- wrapper.eq(DanagerAreaCheckInfoEntity::getIsDeleted, 0);
|
|
|
|
|
- wrapper.eq(DanagerAreaCheckInfoEntity::getWarnId, dto.getWarnId());
|
|
|
|
|
- wrapper.orderByAsc(DanagerAreaCheckInfoEntity::getCreateTime);
|
|
|
|
|
- List<DanagerAreaCheckInfoEntity> list = danagerAreaCheckService.list(wrapper);
|
|
|
|
|
- List<JSONObject> datas = new ArrayList<>(list.size());
|
|
|
|
|
- for (DanagerAreaCheckInfoEntity entity : list) {
|
|
|
|
|
- JSONObject d = new JSONObject();
|
|
|
|
|
- d.put("warnId", entity.getWarnId());
|
|
|
|
|
- User user = userService.getById(entity.getCreateUser());
|
|
|
|
|
- if (!Func.isNull(user)) {
|
|
|
|
|
- d.put("checkPerson", user.getRealName());
|
|
|
|
|
- } else {
|
|
|
|
|
- d.put("checkPerson", "");
|
|
|
|
|
- }
|
|
|
|
|
- d.put("checkTime", entity.getCreateTime().getTime());
|
|
|
|
|
- if (!Func.isNull(entity.getLongitude())) {
|
|
|
|
|
- d.put("lng", entity.getLongitude());
|
|
|
|
|
- }
|
|
|
|
|
- if (!Func.isNull(entity.getLatitude())) {
|
|
|
|
|
- d.put("lat", entity.getLatitude());
|
|
|
|
|
- }
|
|
|
|
|
- if (!Func.isNull(entity.getAddress())) {
|
|
|
|
|
- d.put("location", entity.getAddress());
|
|
|
|
|
- }
|
|
|
|
|
- d.put("isFlood", entity.getIsFlood());
|
|
|
|
|
- d.put("isDamage", entity.getIsDamage());
|
|
|
|
|
- if (!Func.isNull(entity.getRemark())) {
|
|
|
|
|
- d.put("remark", entity.getRemark());
|
|
|
|
|
- }
|
|
|
|
|
- JSONArray photos = new JSONArray();
|
|
|
|
|
- if (!Func.isNull(entity.getCheckPhotos())) {
|
|
|
|
|
- String photo = entity.getCheckPhotos();
|
|
|
|
|
- String[] photoArr = photo.trim().split(",");
|
|
|
|
|
- for (String url : photoArr) {
|
|
|
|
|
- JSONObject p = new JSONObject();
|
|
|
|
|
- p.put("url", BusinessConstant.OSS_BASE_PATH + url);
|
|
|
|
|
- photos.add(p);
|
|
|
|
|
- }
|
|
|
|
|
|
|
+
|
|
|
|
|
+ LambdaQueryWrapper<EtlWarningInfoEntity> wrapper = Wrappers.<EtlWarningInfoEntity>query().lambda();
|
|
|
|
|
+ wrapper.eq(EtlWarningInfoEntity::getIsDeleted, 0);
|
|
|
|
|
+ wrapper.eq(EtlWarningInfoEntity::getRelWarnId, dto.getWarnId());
|
|
|
|
|
+
|
|
|
|
|
+ EtlWarningInfoEntity warningInfoEntity = warningService.getOne(wrapper);
|
|
|
|
|
+
|
|
|
|
|
+ if (Func.isNull(warningInfoEntity)){
|
|
|
|
|
+ return R.fail("预警数据空");
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ List<JSONObject> datas = new ArrayList<>(1);
|
|
|
|
|
+
|
|
|
|
|
+ JSONObject vo = new JSONObject();
|
|
|
|
|
+ DangerAreaResidentInfoDTO residentInfoDTO=new DangerAreaResidentInfoDTO();
|
|
|
|
|
+ residentInfoDTO.setAdCode(warningInfoEntity.getUserAdcd());
|
|
|
|
|
+ long totalTransferPerson =dangerAreaResidentService.residentCount(residentInfoDTO);
|
|
|
|
|
+
|
|
|
|
|
+ DamageTransferPersonInfoDTO transferPersonInfoDTO = new DamageTransferPersonInfoDTO();
|
|
|
|
|
+ transferPersonInfoDTO.setWarnId(dto.getWarnId());
|
|
|
|
|
+ long safetyTransferPerson = damageTransferPersonService.transferPersonCount(transferPersonInfoDTO);
|
|
|
|
|
+
|
|
|
|
|
+ vo.put("totalTransferPerson",totalTransferPerson);
|
|
|
|
|
+ vo.put("safetyTransferPerson",safetyTransferPerson);
|
|
|
|
|
+
|
|
|
|
|
+ JSONArray personList = new JSONArray();
|
|
|
|
|
+
|
|
|
|
|
+ LambdaQueryWrapper<DamageTransferPersonInfoEntity> wrapper2 = Wrappers.<DamageTransferPersonInfoEntity>query().lambda();
|
|
|
|
|
+ wrapper2.eq(DamageTransferPersonInfoEntity::getIsDeleted, 0);
|
|
|
|
|
+ wrapper2.eq(DamageTransferPersonInfoEntity::getWarnId, dto.getWarnId());
|
|
|
|
|
+ List<DamageTransferPersonInfoEntity> transferPersonInfoEntityList = damageTransferPersonService.list(wrapper2);
|
|
|
|
|
+ if (!Func.isNull(transferPersonInfoEntityList)){
|
|
|
|
|
+ for (DamageTransferPersonInfoEntity transferPersonInfoEntity:transferPersonInfoEntityList){
|
|
|
|
|
+ JSONObject person = new JSONObject();
|
|
|
|
|
+ person.put("personName",transferPersonInfoEntity.getPersonName());
|
|
|
|
|
+ person.put("recordTime",transferPersonInfoEntity.getCreateTime().getTime());
|
|
|
|
|
+ personList.add(person);
|
|
|
}
|
|
}
|
|
|
- d.put("photos", photos);
|
|
|
|
|
- datas.add(d);
|
|
|
|
|
}
|
|
}
|
|
|
|
|
+
|
|
|
|
|
+ vo.put("transferPersonList",personList);
|
|
|
|
|
+
|
|
|
|
|
+ datas.add(vo);
|
|
|
|
|
+
|
|
|
return R.data(datas);
|
|
return R.data(datas);
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|