Browse Source

添加功能

suntianwu 3 years ago
parent
commit
db6690c7b4

+ 71 - 0
src/main/java/com/iden/bms/controller/WarningEveningComeStaController.java

@@ -0,0 +1,71 @@
+package com.iden.bms.controller;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.iden.bms.service.WarningEveningComeStaService;
+import com.iden.common.annotation.Permission;
+import com.iden.common.exception.BDException;
+import com.iden.common.util.PageResult;
+import com.iden.common.util.Result;
+import com.iden.common.util.WebPageUtils;
+import com.iden.common.vo.WarningEveningComeStaVO;
+import com.iden.common.vo.PageReqVO;
+import com.iden.common.vo.UserLogindConvertVO;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.List;
+
+/**
+ * @Author: lilt
+ * @Date: 2021/5/26
+ * @Desc:
+ */
+@RestController
+@Api(value = "WarningEveningComeStaController", tags = { "预警管理" })
+@Slf4j
+@RequestMapping("/bms/warningEveningComeSta")
+@Permission
+public class WarningEveningComeStaController {
+
+    @Autowired
+    private WarningEveningComeStaService warningEveningComeStaService;
+
+
+
+    @GetMapping("/listWarningEveningComeSta")
+    @ApiOperation(value = "昼伏夜出人员预警列表分页 ")
+    @ApiImplicitParams(value = {
+            @ApiImplicitParam(paramType = "query", name = "district", value = "所属区域"),
+            @ApiImplicitParam(paramType = "query", name = "subdistrict", value = "所属街道"),
+            @ApiImplicitParam(paramType = "query", name = "communityName", value = "小区名称"),
+            @ApiImplicitParam(paramType = "query", name = "beginDate", value = "开始时间"),
+            @ApiImplicitParam(paramType = "query", name = "endDate", value = "结束时间")
+
+    })
+    public PageResult<List<WarningEveningComeStaVO>> listWarningEveningComeSta(HttpServletRequest request, @RequestHeader(value = "token") String token,
+                                                                               @RequestParam(value = "district", required = false) String district,
+                                                                               @RequestParam(value = "subdistrict", required = false) String subdistrict,
+                                                                               @RequestParam(value = "communityName", required = false) String communityName,
+                                                                               @RequestParam(value = "beginDate", required = false) String beginDate,
+                                                                               @RequestParam(value = "endDate", required = false) String endDate,
+                                                                                PageReqVO pageReqVo){
+        try {
+            UserLogindConvertVO loginUser = WebPageUtils.getCurrentLoginedUser(request);
+            IPage<WarningEveningComeStaVO> pageResponse = this.warningEveningComeStaService.listWarningEveningComeSta(district,subdistrict,communityName,beginDate,endDate,loginUser ,pageReqVo);
+            return PageResult.success(pageResponse.getRecords(),pageResponse.getCurrent(),pageResponse.getSize(),pageResponse.getTotal());
+        }catch (BDException e) {
+            log.error("昼伏夜出人员预警列表查询-分页列表出现异常",e);
+            return  PageResult.error(e.getMessage());
+        } catch (Exception e) {
+            log.error("昼伏夜出人员预警管理: 昼伏夜出人员预警列表查询出现异常",e);
+            return PageResult.error( "获取列表失败");
+        }
+    }
+    
+}

+ 71 - 0
src/main/java/com/iden/bms/controller/WarningKeynoteStaComeStaController.java

@@ -0,0 +1,71 @@
+package com.iden.bms.controller;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+
+import com.iden.bms.service.WarningKeynoteStaService;
+import com.iden.common.annotation.Permission;
+import com.iden.common.exception.BDException;
+import com.iden.common.util.PageResult;
+import com.iden.common.util.WebPageUtils;
+import com.iden.common.vo.PageReqVO;
+import com.iden.common.vo.UserLogindConvertVO;
+import com.iden.common.vo.WarningKeynoteStaVO;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.List;
+
+/**
+ * @Author: lilt
+ * @Date: 2021/5/26
+ * @Desc:
+ */
+@RestController
+@Api(value = "WarningKeynoteStaController", tags = { "预警管理" })
+@Slf4j
+@RequestMapping("/bms/warningKeynoteSta")
+@Permission
+public class WarningKeynoteStaComeStaController {
+
+    @Autowired
+    private WarningKeynoteStaService warningKeynoteStaService;
+
+
+
+    @GetMapping("/listWarningKeynoteSta")
+    @ApiOperation(value = "重点人员预警列表分页 ")
+    @ApiImplicitParams(value = {
+            @ApiImplicitParam(paramType = "query", name = "district", value = "所属区域"),
+            @ApiImplicitParam(paramType = "query", name = "subdistrict", value = "所属街道"),
+            @ApiImplicitParam(paramType = "query", name = "communityName", value = "小区名称"),
+            @ApiImplicitParam(paramType = "query", name = "beginDate", value = "开始时间"),
+            @ApiImplicitParam(paramType = "query", name = "endDate", value = "结束时间")
+
+    })
+    public PageResult<List<WarningKeynoteStaVO>> listWarningKeynoteSta(HttpServletRequest request, @RequestHeader(value = "token") String token,
+                                                                               @RequestParam(value = "district", required = false) String district,
+                                                                               @RequestParam(value = "subdistrict", required = false) String subdistrict,
+                                                                               @RequestParam(value = "communityName", required = false) String communityName,
+                                                                               @RequestParam(value = "beginDate", required = false) String beginDate,
+                                                                               @RequestParam(value = "endDate", required = false) String endDate,
+                                                                                PageReqVO pageReqVo){
+        try {
+            UserLogindConvertVO loginUser = WebPageUtils.getCurrentLoginedUser(request);
+            IPage<WarningKeynoteStaVO> pageResponse = this.warningKeynoteStaService.listWarningKeynoteSta(district,subdistrict,communityName,beginDate,endDate,loginUser ,pageReqVo);
+            return PageResult.success(pageResponse.getRecords(),pageResponse.getCurrent(),pageResponse.getSize(),pageResponse.getTotal());
+        }catch (BDException e) {
+            log.error("重点人员预警列表查询-分页列表出现异常",e);
+            return  PageResult.error(e.getMessage());
+        } catch (Exception e) {
+            log.error("重点人员预警管理: 重点人员预警列表查询出现异常",e);
+            return PageResult.error( "获取列表失败");
+        }
+    }
+    
+}

+ 70 - 0
src/main/java/com/iden/bms/controller/WarningPermanentStaController.java

@@ -0,0 +1,70 @@
+package com.iden.bms.controller;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.iden.bms.service.WarningPermanentStaService;
+import com.iden.common.annotation.Permission;
+import com.iden.common.exception.BDException;
+import com.iden.common.util.PageResult;
+import com.iden.common.util.WebPageUtils;
+import com.iden.common.vo.PageReqVO;
+import com.iden.common.vo.UserLogindConvertVO;
+import com.iden.common.vo.WarningPermanentStaVO;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.List;
+
+/**
+ * @Author: lilt
+ * @Date: 2021/5/26
+ * @Desc:
+ */
+@RestController
+@Api(value = "WarningPermanentStaController", tags = { "预警管理" })
+@Slf4j
+@RequestMapping("/bms/warningPermanentSta")
+@Permission
+public class WarningPermanentStaController {
+
+    @Autowired
+    private WarningPermanentStaService warningPermanentStaService;
+
+
+
+    @GetMapping("/listWarningPermanentSta")
+    @ApiOperation(value = "常住人员预警列表分页 ")
+    @ApiImplicitParams(value = {
+            @ApiImplicitParam(paramType = "query", name = "district", value = "所属区域"),
+            @ApiImplicitParam(paramType = "query", name = "subdistrict", value = "所属街道"),
+            @ApiImplicitParam(paramType = "query", name = "communityName", value = "小区名称"),
+            @ApiImplicitParam(paramType = "query", name = "beginDate", value = "开始时间"),
+            @ApiImplicitParam(paramType = "query", name = "endDate", value = "结束时间")
+
+    })
+    public PageResult<List<WarningPermanentStaVO>> listWarningPermanentSta(HttpServletRequest request, @RequestHeader(value = "token") String token,
+                                                                               @RequestParam(value = "district", required = false) String district,
+                                                                               @RequestParam(value = "subdistrict", required = false) String subdistrict,
+                                                                               @RequestParam(value = "communityName", required = false) String communityName,
+                                                                               @RequestParam(value = "beginDate", required = false) String beginDate,
+                                                                               @RequestParam(value = "endDate", required = false) String endDate,
+                                                                                PageReqVO pageReqVo){
+        try {
+            UserLogindConvertVO loginUser = WebPageUtils.getCurrentLoginedUser(request);
+            IPage<WarningPermanentStaVO> pageResponse = this.warningPermanentStaService.listWarningPermanentSta(district,subdistrict,communityName,beginDate,endDate,loginUser ,pageReqVo);
+            return PageResult.success(pageResponse.getRecords(),pageResponse.getCurrent(),pageResponse.getSize(),pageResponse.getTotal());
+        }catch (BDException e) {
+            log.error("常住人员预警列表查询-分页列表出现异常",e);
+            return  PageResult.error(e.getMessage());
+        } catch (Exception e) {
+            log.error("常住人员预警管理: 常住人员预警列表查询出现异常",e);
+            return PageResult.error( "获取列表失败");
+        }
+    }
+    
+}

+ 70 - 0
src/main/java/com/iden/bms/controller/WarningStrangerStaController.java

@@ -0,0 +1,70 @@
+package com.iden.bms.controller;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.iden.bms.service.WarningStrangerStaService;
+import com.iden.common.annotation.Permission;
+import com.iden.common.exception.BDException;
+import com.iden.common.util.PageResult;
+import com.iden.common.util.WebPageUtils;
+import com.iden.common.vo.PageReqVO;
+import com.iden.common.vo.UserLogindConvertVO;
+import com.iden.common.vo.WarningStrangerStaVO;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.List;
+
+/**
+ * @Author: lilt
+ * @Date: 2021/5/26
+ * @Desc:
+ */
+@RestController
+@Api(value = "WarningStrangerStaController", tags = { "预警管理" })
+@Slf4j
+@RequestMapping("/bms/warningStrangerSta")
+@Permission
+public class WarningStrangerStaController {
+
+    @Autowired
+    private WarningStrangerStaService warningStrangerStaService;
+
+
+
+    @GetMapping("/listWarningStrangerSta")
+    @ApiOperation(value = "陌生人员预警列表分页 ")
+    @ApiImplicitParams(value = {
+            @ApiImplicitParam(paramType = "query", name = "district", value = "所属区域"),
+            @ApiImplicitParam(paramType = "query", name = "subdistrict", value = "所属街道"),
+            @ApiImplicitParam(paramType = "query", name = "communityName", value = "小区名称"),
+            @ApiImplicitParam(paramType = "query", name = "beginDate", value = "开始时间"),
+            @ApiImplicitParam(paramType = "query", name = "endDate", value = "结束时间")
+
+    })
+    public PageResult<List<WarningStrangerStaVO>> listWarningStrangerSta(HttpServletRequest request, @RequestHeader(value = "token") String token,
+                                                                               @RequestParam(value = "district", required = false) String district,
+                                                                               @RequestParam(value = "subdistrict", required = false) String subdistrict,
+                                                                               @RequestParam(value = "communityName", required = false) String communityName,
+                                                                               @RequestParam(value = "beginDate", required = false) String beginDate,
+                                                                               @RequestParam(value = "endDate", required = false) String endDate,
+                                                                                PageReqVO pageReqVo){
+        try {
+            UserLogindConvertVO loginUser = WebPageUtils.getCurrentLoginedUser(request);
+            IPage<WarningStrangerStaVO> pageResponse = this.warningStrangerStaService.listWarningStrangerSta(district,subdistrict,communityName,beginDate,endDate,loginUser ,pageReqVo);
+            return PageResult.success(pageResponse.getRecords(),pageResponse.getCurrent(),pageResponse.getSize(),pageResponse.getTotal());
+        }catch (BDException e) {
+            log.error("陌生人员预警列表查询-分页列表出现异常",e);
+            return  PageResult.error(e.getMessage());
+        } catch (Exception e) {
+            log.error("陌生人员预警管理: 陌生人员预警列表查询出现异常",e);
+            return PageResult.error( "获取列表失败");
+        }
+    }
+    
+}

+ 74 - 0
src/main/java/com/iden/bms/service/WarningEveningComeStaService.java

@@ -0,0 +1,74 @@
+package com.iden.bms.service;
+
+import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.iden.common.entity.IdenWarningEveningComeSta;
+import com.iden.common.service.IdenWarningEveningComeStaService;
+
+import com.iden.common.vo.WarningEveningComeStaVO;
+import com.iden.common.vo.PageReqVO;
+import com.iden.common.vo.UserLogindConvertVO;
+import org.springframework.beans.BeanUtils;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ *
+ * @author makejava
+ * @since 2021-05-21 00:08:38
+ */
+@Service
+public class WarningEveningComeStaService {
+
+    @Resource
+    private IdenWarningEveningComeStaService idenWarningEveningComeStaService;
+
+    
+
+    /**
+     * 查询昼伏夜出人员预警列表
+     * @return
+             */
+    public IPage<WarningEveningComeStaVO> listWarningEveningComeSta(String district, String subdistrict,String communityName, String beginDate,String endDate,UserLogindConvertVO loginUser, PageReqVO pageReqVo) {
+            IPage<IdenWarningEveningComeSta> page = new Page<>(pageReqVo.getCurrent(), pageReqVo.getPageSize());
+            QueryWrapper<IdenWarningEveningComeSta> queryWrapper = new QueryWrapper<>();
+            queryWrapper.lambda().like(StrUtil.isNotEmpty(communityName),IdenWarningEveningComeSta::getCommunityName,communityName)
+                    .eq(StrUtil.isNotEmpty(district),IdenWarningEveningComeSta::getDistrict,district)
+                    .eq(StrUtil.isNotEmpty(subdistrict),IdenWarningEveningComeSta::getSubdistrict,subdistrict)
+                    .ge(StrUtil.isNotEmpty(beginDate),IdenWarningEveningComeSta::getDataDate,beginDate)
+                    .le(StrUtil.isNotEmpty(endDate),IdenWarningEveningComeSta::getDataDate,endDate)
+                    .orderByAsc(IdenWarningEveningComeSta::getId);
+
+        queryWrapper.groupBy("community_id");
+        queryWrapper.select(
+                "community_id communityId",
+                "max(community_code) communityCode",
+                "max(community_name) communityName",
+                "max(district) district",
+                "max(subdistrict) subdistrict",
+                "max(data_date) dataDate",
+                "IFNULL(SUM(evening_come_count),0) eveningComeCount"
+        );
+
+            IPage<IdenWarningEveningComeSta> pageRes = this.idenWarningEveningComeStaService.page(page, queryWrapper);
+            IPage<WarningEveningComeStaVO> results = new Page<>(pageRes.getCurrent(),pageRes.getSize(),pageRes.getTotal());
+            if(CollUtil.isNotEmpty(pageRes.getRecords())){
+                List<WarningEveningComeStaVO> list = new ArrayList<>();
+                pageRes.getRecords().forEach(item -> {
+                    WarningEveningComeStaVO resVO = new WarningEveningComeStaVO();
+                    BeanUtils.copyProperties(item,resVO);
+                    list.add(resVO);
+                });
+                results.setRecords(list);
+            }
+            return results;
+    }
+
+
+}

+ 73 - 0
src/main/java/com/iden/bms/service/WarningKeynoteStaService.java

@@ -0,0 +1,73 @@
+package com.iden.bms.service;
+
+import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.iden.common.entity.IdenWarningKeynoteSta;
+import com.iden.common.service.IdenWarningKeynoteStaService;
+import com.iden.common.vo.PageReqVO;
+import com.iden.common.vo.UserLogindConvertVO;
+import com.iden.common.vo.WarningKeynoteStaVO;
+import org.springframework.beans.BeanUtils;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ *
+ * @author makejava
+ * @since 2021-05-21 00:08:38
+ */
+@Service
+public class WarningKeynoteStaService {
+
+    @Resource
+    private IdenWarningKeynoteStaService idenWarningKeynoteStaService;
+
+    
+
+    /**
+     * 查询重点人员预警列表
+     * @return
+             */
+    public IPage<WarningKeynoteStaVO> listWarningKeynoteSta(String district, String subdistrict,String communityName, String beginDate,String endDate,UserLogindConvertVO loginUser, PageReqVO pageReqVo) {
+            IPage<IdenWarningKeynoteSta> page = new Page<>(pageReqVo.getCurrent(), pageReqVo.getPageSize());
+            QueryWrapper<IdenWarningKeynoteSta> queryWrapper = new QueryWrapper<>();
+            queryWrapper.lambda().like(StrUtil.isNotEmpty(communityName),IdenWarningKeynoteSta::getCommunityName,communityName)
+                    .eq(StrUtil.isNotEmpty(district),IdenWarningKeynoteSta::getDistrict,district)
+                    .eq(StrUtil.isNotEmpty(subdistrict),IdenWarningKeynoteSta::getSubdistrict,subdistrict)
+                     .ge(StrUtil.isNotEmpty(beginDate),IdenWarningKeynoteSta::getDataDate,beginDate)
+                     .le(StrUtil.isNotEmpty(endDate),IdenWarningKeynoteSta::getDataDate,endDate)
+                    .orderByAsc(IdenWarningKeynoteSta::getId);
+
+        queryWrapper.groupBy("community_id");
+        queryWrapper.select(
+                "community_id communityId",
+                "max(community_code) communityCode",
+                "max(community_name) communityName",
+                "max(district) district",
+                "max(subdistrict) subdistrict",
+                "max(data_date) dataDate",
+                "IFNULL(SUM(keynote_count),0) keynoteCount"
+        );
+
+            IPage<IdenWarningKeynoteSta> pageRes = this.idenWarningKeynoteStaService.page(page, queryWrapper);
+            IPage<WarningKeynoteStaVO> results = new Page<>(pageRes.getCurrent(),pageRes.getSize(),pageRes.getTotal());
+            if(CollUtil.isNotEmpty(pageRes.getRecords())){
+                List<WarningKeynoteStaVO> list = new ArrayList<>();
+                pageRes.getRecords().forEach(item -> {
+                    WarningKeynoteStaVO resVO = new WarningKeynoteStaVO();
+                    BeanUtils.copyProperties(item,resVO);
+                    list.add(resVO);
+                });
+                results.setRecords(list);
+            }
+            return results;
+    }
+
+
+}

+ 73 - 0
src/main/java/com/iden/bms/service/WarningPermanentStaService.java

@@ -0,0 +1,73 @@
+package com.iden.bms.service;
+
+import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.iden.common.entity.IdenWarningPermanentSta;
+import com.iden.common.service.IdenWarningPermanentStaService;
+import com.iden.common.vo.PageReqVO;
+import com.iden.common.vo.UserLogindConvertVO;
+import com.iden.common.vo.WarningPermanentStaVO;
+import org.springframework.beans.BeanUtils;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ *
+ * @author makejava
+ * @since 2021-05-21 00:08:38
+ */
+@Service
+public class WarningPermanentStaService {
+
+    @Resource
+    private IdenWarningPermanentStaService idenWarningPermanentStaService;
+
+    
+
+    /**
+     * 查询常住人员预警列表
+     * @return
+             */
+    public IPage<WarningPermanentStaVO> listWarningPermanentSta(String district, String subdistrict,String communityName, String beginDate,String endDate,UserLogindConvertVO loginUser, PageReqVO pageReqVo) {
+            IPage<IdenWarningPermanentSta> page = new Page<>(pageReqVo.getCurrent(), pageReqVo.getPageSize());
+            QueryWrapper<IdenWarningPermanentSta> queryWrapper = new QueryWrapper<>();
+            queryWrapper.lambda().like(StrUtil.isNotEmpty(communityName),IdenWarningPermanentSta::getCommunityName,communityName)
+                    .eq(StrUtil.isNotEmpty(district),IdenWarningPermanentSta::getDistrict,district)
+                    .eq(StrUtil.isNotEmpty(subdistrict),IdenWarningPermanentSta::getSubdistrict,subdistrict)
+                    .ge(StrUtil.isNotEmpty(beginDate),IdenWarningPermanentSta::getDataDate,beginDate)
+                    .le(StrUtil.isNotEmpty(endDate),IdenWarningPermanentSta::getDataDate,endDate)
+                    .orderByAsc(IdenWarningPermanentSta::getId);
+
+        queryWrapper.groupBy("community_id");
+        queryWrapper.select(
+                "community_id communityId",
+                "max(community_code) communityCode",
+                "max(community_name) communityName",
+                "max(district) district",
+                "max(subdistrict) subdistrict",
+                "max(data_date) dataDate",
+                "IFNULL(SUM(permanent_count),0) permanentCount"
+        );
+
+            IPage<IdenWarningPermanentSta> pageRes = this.idenWarningPermanentStaService.page(page, queryWrapper);
+            IPage<WarningPermanentStaVO> results = new Page<>(pageRes.getCurrent(),pageRes.getSize(),pageRes.getTotal());
+            if(CollUtil.isNotEmpty(pageRes.getRecords())){
+                List<WarningPermanentStaVO> list = new ArrayList<>();
+                pageRes.getRecords().forEach(item -> {
+                    WarningPermanentStaVO resVO = new WarningPermanentStaVO();
+                    BeanUtils.copyProperties(item,resVO);
+                    list.add(resVO);
+                });
+                results.setRecords(list);
+            }
+            return results;
+    }
+
+
+}

+ 73 - 0
src/main/java/com/iden/bms/service/WarningStrangerStaService.java

@@ -0,0 +1,73 @@
+package com.iden.bms.service;
+
+import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.iden.common.entity.IdenWarningStrangerSta;
+import com.iden.common.service.IdenWarningStrangerStaService;
+import com.iden.common.vo.PageReqVO;
+import com.iden.common.vo.UserLogindConvertVO;
+import com.iden.common.vo.WarningStrangerStaVO;
+import org.springframework.beans.BeanUtils;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ *
+ * @author makejava
+ * @since 2021-05-21 00:08:38
+ */
+@Service
+public class WarningStrangerStaService {
+
+    @Resource
+    private IdenWarningStrangerStaService idenWarningStrangerStaService;
+
+    
+
+    /**
+     * 查询陌生人员预警列表
+     * @return
+             */
+    public IPage<WarningStrangerStaVO> listWarningStrangerSta(String district, String subdistrict,String communityName, String beginDate,String endDate,UserLogindConvertVO loginUser, PageReqVO pageReqVo) {
+            IPage<IdenWarningStrangerSta> page = new Page<>(pageReqVo.getCurrent(), pageReqVo.getPageSize());
+            QueryWrapper<IdenWarningStrangerSta> queryWrapper = new QueryWrapper<>();
+            queryWrapper.lambda().like(StrUtil.isNotEmpty(communityName),IdenWarningStrangerSta::getCommunityName,communityName)
+                    .eq(StrUtil.isNotEmpty(district),IdenWarningStrangerSta::getDistrict,district)
+                    .eq(StrUtil.isNotEmpty(subdistrict),IdenWarningStrangerSta::getSubdistrict,subdistrict)
+                    .ge(StrUtil.isNotEmpty(beginDate),IdenWarningStrangerSta::getDataDate,beginDate)
+                    .le(StrUtil.isNotEmpty(endDate),IdenWarningStrangerSta::getDataDate,endDate)
+                    .orderByAsc(IdenWarningStrangerSta::getId);
+
+        queryWrapper.groupBy("community_id");
+        queryWrapper.select(
+                "community_id communityId",
+                "max(community_code) communityCode",
+                "max(community_name) communityName",
+                "max(district) district",
+                "max(subdistrict) subdistrict",
+                "max(data_date) dataDate",
+                "IFNULL(SUM(stranger_count),0) strangerCount"
+        );
+
+            IPage<IdenWarningStrangerSta> pageRes = this.idenWarningStrangerStaService.page(page, queryWrapper);
+            IPage<WarningStrangerStaVO> results = new Page<>(pageRes.getCurrent(),pageRes.getSize(),pageRes.getTotal());
+            if(CollUtil.isNotEmpty(pageRes.getRecords())){
+                List<WarningStrangerStaVO> list = new ArrayList<>();
+                pageRes.getRecords().forEach(item -> {
+                    WarningStrangerStaVO resVO = new WarningStrangerStaVO();
+                    BeanUtils.copyProperties(item,resVO);
+                    list.add(resVO);
+                });
+                results.setRecords(list);
+            }
+            return results;
+    }
+
+
+}

+ 3 - 0
src/main/java/com/iden/common/entity/IdenWarningEveningComeSta.java

@@ -66,6 +66,9 @@ public class IdenWarningEveningComeSta implements Serializable {
     @TableField("EVENING_COME_COUNT")
     @TableField("EVENING_COME_COUNT")
     private Long eveningComeCount;
     private Long eveningComeCount;
 
 
+    @ApiModelProperty("数据日期")
+    @TableField("DATA_DATE")
+    private Date dataDate;
 
 
     @ApiModelProperty("createTime")
     @ApiModelProperty("createTime")
     @TableField("CREATE_TIME")
     @TableField("CREATE_TIME")

+ 3 - 0
src/main/java/com/iden/common/entity/IdenWarningKeynoteSta.java

@@ -66,6 +66,9 @@ public class IdenWarningKeynoteSta implements Serializable {
     @TableField("KEYNOTE_COUNT")
     @TableField("KEYNOTE_COUNT")
     private Long keynoteCount;
     private Long keynoteCount;
 
 
+    @ApiModelProperty("数据日期")
+    @TableField("DATA_DATE")
+    private Date dataDate;
 
 
     @ApiModelProperty("createTime")
     @ApiModelProperty("createTime")
     @TableField("CREATE_TIME")
     @TableField("CREATE_TIME")

+ 3 - 0
src/main/java/com/iden/common/entity/IdenWarningPermanentSta.java

@@ -66,6 +66,9 @@ public class IdenWarningPermanentSta implements Serializable {
     @TableField("PERMANENT_COUNT")
     @TableField("PERMANENT_COUNT")
     private Long permanentCount;
     private Long permanentCount;
 
 
+    @ApiModelProperty("数据日期")
+    @TableField("DATA_DATE")
+    private Date dataDate;
 
 
     @ApiModelProperty("createTime")
     @ApiModelProperty("createTime")
     @TableField("CREATE_TIME")
     @TableField("CREATE_TIME")

+ 3 - 0
src/main/java/com/iden/common/entity/IdenWarningStrangerSta.java

@@ -66,6 +66,9 @@ public class IdenWarningStrangerSta implements Serializable {
     @TableField("STRANGER_COUNT")
     @TableField("STRANGER_COUNT")
     private Long strangerCount;
     private Long strangerCount;
 
 
+    @ApiModelProperty("数据日期")
+    @TableField("DATA_DATE")
+    private Date dataDate;
 
 
     @ApiModelProperty("createTime")
     @ApiModelProperty("createTime")
     @TableField("CREATE_TIME")
     @TableField("CREATE_TIME")

+ 64 - 0
src/main/java/com/iden/common/vo/WarningEveningComeStaVO.java

@@ -0,0 +1,64 @@
+package com.iden.common.vo;
+
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 昼伏夜出人口识别预警统计表(IdenWarningEveningComeSta)实体类
+ *
+ * @author makejava
+ * @since 2021-12-22 20:19:16
+ */
+
+@Data
+@ApiModel(value = "昼伏夜出人口识别预警统计表", description = "")
+public class WarningEveningComeStaVO implements Serializable {
+    private static final long serialVersionUID = 985331715970898803L;
+
+    private Long id;
+
+
+    @ApiModelProperty("所属小区id")
+    private Long communityId;
+
+
+    @ApiModelProperty("小区编号")
+    private String communityCode;
+
+
+    @ApiModelProperty("小区名称")
+    private String communityName;
+
+
+    @ApiModelProperty("所属区域")
+    private String district;
+
+
+    @ApiModelProperty("所属街道")
+    private String subdistrict;
+
+
+    @ApiModelProperty("昼伏夜出人员总数")
+    private Long eveningComeCount;
+
+    @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8")
+    @ApiModelProperty("数据日期")
+    private Date dataDate;
+
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
+    @ApiModelProperty("createTime")
+    private Date createTime;
+
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
+    @ApiModelProperty("modifyTime")
+    private Date modifyTime;
+
+
+}

+ 64 - 0
src/main/java/com/iden/common/vo/WarningKeynoteStaVO.java

@@ -0,0 +1,64 @@
+package com.iden.common.vo;
+
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 重点人员识别预警统计表(IdenWarningKeynoteSta)实体类
+ *
+ * @author makejava
+ * @since 2021-12-23 11:08:19
+ */
+
+@Data
+@ApiModel(value = "重点人员识别预警统计表", description = "")
+public class WarningKeynoteStaVO implements Serializable {
+    private static final long serialVersionUID = -48099154074943251L;
+
+    private Long id;
+
+
+    @ApiModelProperty("所属小区id")
+    private Long communityId;
+
+
+    @ApiModelProperty("小区编号")
+    private String communityCode;
+
+
+    @ApiModelProperty("小区名称")
+    private String communityName;
+
+
+    @ApiModelProperty("所属区域")
+    private String district;
+
+
+    @ApiModelProperty("所属街道")
+    private String subdistrict;
+
+
+    @ApiModelProperty("重点人员总数")
+    private Long keynoteCount;
+
+    @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8")
+    @ApiModelProperty("数据日期")
+    private Date dataDate;
+
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
+    @ApiModelProperty("createTime")
+    private Date createTime;
+
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
+    @ApiModelProperty("modifyTime")
+    private Date modifyTime;
+
+
+}

+ 63 - 0
src/main/java/com/iden/common/vo/WarningPermanentStaVO.java

@@ -0,0 +1,63 @@
+package com.iden.common.vo;
+
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 常住人口识别预警统计表(IdenWarningPermanentSta)实体类
+ *
+ * @author makejava
+ * @since 2021-12-22 20:19:17
+ */
+
+@Data
+@ApiModel(value = "常住人口识别预警统计表", description = "")
+public class WarningPermanentStaVO implements Serializable {
+    private static final long serialVersionUID = 780363491063638399L;
+
+    private Long id;
+
+
+    @ApiModelProperty("所属小区id")
+    private Long communityId;
+
+
+    @ApiModelProperty("小区编号")
+    private String communityCode;
+
+
+    @ApiModelProperty("小区名称")
+    private String communityName;
+
+
+    @ApiModelProperty("所属区域")
+    private String district;
+
+
+    @ApiModelProperty("所属街道")
+    private String subdistrict;
+
+
+    @ApiModelProperty("大于7天未出现常住人总数")
+    private Long permanentCount;
+
+    @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8")
+    @ApiModelProperty("数据日期")
+    private Date dataDate;
+
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
+    @ApiModelProperty("createTime")
+    private Date createTime;
+
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
+    @ApiModelProperty("modifyTime")
+    private Date modifyTime;
+
+
+}

+ 64 - 0
src/main/java/com/iden/common/vo/WarningStrangerStaVO.java

@@ -0,0 +1,64 @@
+package com.iden.common.vo;
+
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 陌生人员识别预警统计表(IdenWarningStrangerSta)实体类
+ *
+ * @author makejava
+ * @since 2021-12-22 20:19:17
+ */
+
+@Data
+@ApiModel(value = "陌生人员识别预警统计表", description = "")
+public class WarningStrangerStaVO implements Serializable {
+    private static final long serialVersionUID = 618456629263970444L;
+
+    private Long id;
+
+
+    @ApiModelProperty("所属小区id")
+    private Long communityId;
+
+
+    @ApiModelProperty("小区编号")
+    private String communityCode;
+
+
+    @ApiModelProperty("小区名称")
+    private String communityName;
+
+
+    @ApiModelProperty("所属区域")
+    private String district;
+
+
+    @ApiModelProperty("所属街道")
+    private String subdistrict;
+
+
+    @ApiModelProperty("陌生人总数")
+    private Long strangerCount;
+
+    @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8")
+    @ApiModelProperty("数据日期")
+    private Date dataDate;
+
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
+    @ApiModelProperty("createTime")
+    private Date createTime;
+
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
+    @ApiModelProperty("modifyTime")
+    private Date modifyTime;
+
+
+}