diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/alertmessage/AlertMessageController.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/alertmessage/AlertMessageController.java index 04bcbf787b..e4b9daa060 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/alertmessage/AlertMessageController.java +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/alertmessage/AlertMessageController.java @@ -80,6 +80,13 @@ public class AlertMessageController { return success(BeanUtils.toBean(pageResult, AlertMessageRespVO.class)); } + @GetMapping("/statistics-summary") + @Operation(summary = "获取预警统计数据") + public CommonResult getAlertStatistics(@RequestParam Integer orgid) { + AlertStatisticsVO data = alertMessageService.getAlertStatistics(orgid); + return success(data); + } + @GetMapping("/statistics") @Operation(summary = "统计预警信息") public CommonResult getAlertMessageStatistics(@Valid AlertMessageStatisticsReqVO statisticsReqVO) { diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/alertmessage/vo/AlertMessageStatisticsReqVO.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/alertmessage/vo/AlertMessageStatisticsReqVO.java index c194af9da9..1bffd1b656 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/alertmessage/vo/AlertMessageStatisticsReqVO.java +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/alertmessage/vo/AlertMessageStatisticsReqVO.java @@ -15,13 +15,11 @@ public class AlertMessageStatisticsReqVO { @Schema(description = "开始时间", requiredMode = Schema.RequiredMode.REQUIRED) @NotNull(message = "开始时间不能为空") - @DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND) - private LocalDateTime startTime; + private String startTime; @Schema(description = "结束时间", requiredMode = Schema.RequiredMode.REQUIRED) @NotNull(message = "结束时间不能为空") - @DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND) - private LocalDateTime endTime; + private String endTime; @Schema(description = "机构ID", requiredMode = Schema.RequiredMode.REQUIRED, example = "30089") @NotNull(message = "机构ID不能为空") diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/alertmessage/vo/AlertMessageStatisticsRespVO.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/alertmessage/vo/AlertMessageStatisticsRespVO.java index 0997d083ea..9f5dfcb173 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/alertmessage/vo/AlertMessageStatisticsRespVO.java +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/alertmessage/vo/AlertMessageStatisticsRespVO.java @@ -18,6 +18,24 @@ public class AlertMessageStatisticsRespVO { @Schema(description = "未读数量", example = "20") private Long unreadCount; + @Schema(description = "SOS预警数量", example = "60") + private Long sosCount; + + @Schema(description = "分析预警数量", example = "40") + private Long analysisCount; + + @Schema(description = "SOS预警已读数量", example = "50") + private Long sosReadCount; + + @Schema(description = "SOS预警未读数量", example = "10") + private Long sosUnreadCount; + + @Schema(description = "分析预警已读数量", example = "30") + private Long analysisReadCount; + + @Schema(description = "分析预警未读数量", example = "10") + private Long analysisUnreadCount; + @Schema(description = "按日期分组的预警信息数据") private List dailyData; @@ -26,15 +44,32 @@ public class AlertMessageStatisticsRespVO { public static class DailyAlertData { @Schema(description = "日期", example = "2024-01-01") private LocalDate date; - + @Schema(description = "该日期的预警总数", example = "10") private Long totalCount; - + @Schema(description = "该日期的已读数量", example = "8") private Long readCount; - + @Schema(description = "该日期的未读数量", example = "2") private Long unreadCount; - } -} \ No newline at end of file + @Schema(description = "该日期的SOS预警数量", example = "6") + private Long sosCount; + + @Schema(description = "该日期的分析预警数量", example = "4") + private Long analysisCount; + + @Schema(description = "该日期的SOS预警已读数量", example = "5") + private Long sosReadCount; + + @Schema(description = "该日期的SOS预警未读数量", example = "1") + private Long sosUnreadCount; + + @Schema(description = "该日期的分析预警已读数量", example = "3") + private Long analysisReadCount; + + @Schema(description = "该日期的分析预警未读数量", example = "1") + private Long analysisUnreadCount; + } +} \ No newline at end of file diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/alertmessage/vo/AlertStatisticsVO.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/alertmessage/vo/AlertStatisticsVO.java new file mode 100644 index 0000000000..29739838fd --- /dev/null +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/alertmessage/vo/AlertStatisticsVO.java @@ -0,0 +1,14 @@ +package cn.iocoder.yudao.module.system.controller.admin.alertmessage.vo; + +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.Data; + +@Data +public class AlertStatisticsVO { + + @Schema(description = "预警总数", required = true, example = "8") + private Integer alertTotal; + + @Schema(description = "未处理预警数", required = true, example = "3") + private Integer alertUnhandled; +} diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/device/DeviceController.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/device/DeviceController.java index 82106cf11c..4244fdbef0 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/device/DeviceController.java +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/device/DeviceController.java @@ -77,7 +77,12 @@ public class DeviceController { DeviceDO device = deviceService.getDeviceId(devicecode); return success(BeanUtils.toBean(device, DeviceRespVO.class)); } - + @GetMapping("/getDeviceidCount") + @Operation(summary = "统计设备数量和在线离线 首页") + public CommonResult getDeviceStatistics(@RequestParam Integer orgid) { + DeviceStatistics statistics = deviceService.getDeviceStatistics(orgid); + return success(statistics); + } @GetMapping("/page") @Operation(summary = "获得设备分页") public CommonResult> getDevicePage(@Valid DevicePageReqVO pageReqVO) { @@ -114,4 +119,11 @@ public class DeviceController { return success(BeanUtils.toBean(pageResult, DeviceRespVO.class)); } + @GetMapping("/map-data") + @Operation(summary = "获取设备分布地图数据") + public CommonResult getDeviceMapData(@RequestParam Integer orgid) { + DeviceMapVO data = deviceService.getDeviceMapData(orgid); + return success(data); + } + } \ No newline at end of file diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/device/vo/AlertStatistics.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/device/vo/AlertStatistics.java new file mode 100644 index 0000000000..7eda9a82c8 --- /dev/null +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/device/vo/AlertStatistics.java @@ -0,0 +1,9 @@ +package cn.iocoder.yudao.module.system.controller.admin.device.vo; + +import lombok.Data; + +@Data +public class AlertStatistics { + private Integer total; + private Integer unhandled; +} diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/device/vo/DeviceMapVO.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/device/vo/DeviceMapVO.java new file mode 100644 index 0000000000..6ae46a4718 --- /dev/null +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/device/vo/DeviceMapVO.java @@ -0,0 +1,30 @@ +package cn.iocoder.yudao.module.system.controller.admin.device.vo; + +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.Data; + +import java.util.List; + +@Data +public class DeviceMapVO { + @Schema(description = "总设备数", required = true, example = "156") + private Integer totalCount; + + @Schema(description = "在线设备数", required = true, example = "142") + private Integer onlineCount; + + @Schema(description = "离线设备数", required = true, example = "14") + private Integer offlineCount; + + @Schema(description = "预警总数", required = true, example = "8") + private Integer alertTotal; + + @Schema(description = "未处理预警数", required = true, example = "3") + private Integer alertUnhandled; + + @Schema(description = "地图数据", required = true) + private List mapData; + + @Schema(description = "散点图数据", required = true) + private List scatterData; +} diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/device/vo/DeviceStatistics.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/device/vo/DeviceStatistics.java new file mode 100644 index 0000000000..09eaf3d22b --- /dev/null +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/device/vo/DeviceStatistics.java @@ -0,0 +1,16 @@ +package cn.iocoder.yudao.module.system.controller.admin.device.vo; + +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.*; + +@Data +public class DeviceStatistics { + @Schema(description = "设备总数", required = true, example = "8") + private Integer totalCount; + + @Schema(description = "在线设备数", required = true, example = "5") + private Integer onlineCount; + + @Schema(description = "离线设备数", required = true, example = "3") + private Integer offlineCount; +} diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/device/vo/MapDataItem.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/device/vo/MapDataItem.java new file mode 100644 index 0000000000..0631e7e831 --- /dev/null +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/device/vo/MapDataItem.java @@ -0,0 +1,13 @@ +package cn.iocoder.yudao.module.system.controller.admin.device.vo; + +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.Data; + +@Data +public class MapDataItem { + @Schema(description = "省份名称", required = true, example = "辽宁省") + private String name; + + @Schema(description = "设备数量", required = true, example = "45") + private Integer value; +} diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/device/vo/ProvinceCoords.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/device/vo/ProvinceCoords.java new file mode 100644 index 0000000000..c339cdfab5 --- /dev/null +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/device/vo/ProvinceCoords.java @@ -0,0 +1,10 @@ +package cn.iocoder.yudao.module.system.controller.admin.device.vo; + +import lombok.Data; + +@Data +public class ProvinceCoords { + private String provinceName; + private Double longitude; + private Double latitude; +} diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/device/vo/ProvinceDeviceCount.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/device/vo/ProvinceDeviceCount.java new file mode 100644 index 0000000000..8f1beed7f2 --- /dev/null +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/device/vo/ProvinceDeviceCount.java @@ -0,0 +1,9 @@ +package cn.iocoder.yudao.module.system.controller.admin.device.vo; + +import lombok.Data; + +@Data +public class ProvinceDeviceCount { + private String province; + private Integer count; +} diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/device/vo/ScatterDataItem.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/device/vo/ScatterDataItem.java new file mode 100644 index 0000000000..c228d5cab4 --- /dev/null +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/device/vo/ScatterDataItem.java @@ -0,0 +1,16 @@ +package cn.iocoder.yudao.module.system.controller.admin.device.vo; + +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.Data; + +@Data +public class ScatterDataItem { + @Schema(description = "省份名称", required = true, example = "辽宁省") + private String name; + + @Schema(description = "坐标和数量 [经度, 纬度, 数量]", required = true, example = "[123.4315, 41.8057, 45]") + private double[] value; + + @Schema(description = "设备数量", required = true, example = "45") + private Integer count; +} diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/person/PersonController.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/person/PersonController.java index 082b17a4a5..a04b490598 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/person/PersonController.java +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/person/PersonController.java @@ -72,12 +72,16 @@ public class PersonController { } @GetMapping("/get") @Operation(summary = "获得用户基本信息") - @Parameter(name = "id", description = "编号", required = true, example = "1024") public CommonResult getPerson(@RequestParam("id") Integer id) { PersonDO person = personService.getPerson(id); return success(BeanUtils.toBean(person, PersonRespVO.class)); } - + @GetMapping("/member-growth-data") + @Operation(summary = "首页统计会员增长趋势") + public CommonResult> getMemberGrowthData(@RequestParam Integer orgid) { + List growthData = personService.getMemberGrowthData(orgid); + return success(growthData); + } @GetMapping("/page") @Operation(summary = "获得用户基本信息分页") public CommonResult> getPersonPage(@Valid PersonPageReqVO pageReqVO) { diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/person/vo/MemberGrowthVO.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/person/vo/MemberGrowthVO.java new file mode 100644 index 0000000000..402e61aae5 --- /dev/null +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/person/vo/MemberGrowthVO.java @@ -0,0 +1,13 @@ +package cn.iocoder.yudao.module.system.controller.admin.person.vo; + +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.Data; + +@Data +public class MemberGrowthVO { + + @Schema(description = "日期") + private String date; + @Schema(description = "数量") + private Integer count; +} diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/record/RecordController.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/record/RecordController.java index 752d985402..b6556cc443 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/record/RecordController.java +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/controller/admin/record/RecordController.java @@ -66,6 +66,14 @@ public class RecordController { RecordDO record = recordService.getRecord(id); return success(BeanUtils.toBean(record, RecordRespVO.class)); } + @GetMapping("/getstatistics") + @Operation(summary = "获得会员回访记录") + public CommonResult>> getVipCountByDay(@RequestParam("orgid") Integer orgid, + @RequestParam("startDate") String startDate, + @RequestParam("endDate") String endDate) { + List> result = recordService.getVipCountByDay(orgid, startDate, endDate); + return success(result); + } @GetMapping("/page") @Operation(summary = "获得会员回访记录分页") diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/dal/mysql/alertmessage/AlertMessageMapper.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/dal/mysql/alertmessage/AlertMessageMapper.java index a55dde3b27..58749dcfa0 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/dal/mysql/alertmessage/AlertMessageMapper.java +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/dal/mysql/alertmessage/AlertMessageMapper.java @@ -55,4 +55,51 @@ public interface AlertMessageMapper extends BaseMapperX { @Param("startTime") LocalDateTime startTime, @Param("endTime") LocalDateTime endTime); + @Select("SELECT " + + "COUNT(*) as totalCount, " + + "SUM(CASE WHEN status = 1 THEN 1 ELSE 0 END) as readCount, " + + "SUM(CASE WHEN status = 0 THEN 1 ELSE 0 END) as unreadCount, " + + "SUM(CASE WHEN alerttype = 1 THEN 1 ELSE 0 END) as sosCount, " + + "SUM(CASE WHEN alerttype = 2 THEN 1 ELSE 0 END) as analysisCount, " + + "SUM(CASE WHEN alerttype = 1 AND status = 1 THEN 1 ELSE 0 END) as sosReadCount, " + + "SUM(CASE WHEN alerttype = 1 AND status = 0 THEN 1 ELSE 0 END) as sosUnreadCount, " + + "SUM(CASE WHEN alerttype = 2 AND status = 1 THEN 1 ELSE 0 END) as analysisReadCount, " + + "SUM(CASE WHEN alerttype = 2 AND status = 0 THEN 1 ELSE 0 END) as analysisUnreadCount " + + "FROM tb_alert_message " + + "WHERE orgid = #{orgid} " + + "AND createtime BETWEEN #{startTime} AND #{endTime}") + Map selectAlertMessageStatistics(@Param("orgid") Integer orgid, + @Param("startTime") String startTime, + @Param("endTime") String endTime); + + @Select("SELECT " + + "DATE(createtime) as date, " + + "COUNT(*) as totalCount, " + + "SUM(CASE WHEN status = 1 THEN 1 ELSE 0 END) as readCount, " + + "SUM(CASE WHEN status = 0 THEN 1 ELSE 0 END) as unreadCount, " + + "SUM(CASE WHEN alerttype = 1 THEN 1 ELSE 0 END) as sosCount, " + + "SUM(CASE WHEN alerttype = 2 THEN 1 ELSE 0 END) as analysisCount, " + + "SUM(CASE WHEN alerttype = 1 AND status = 1 THEN 1 ELSE 0 END) as sosReadCount, " + + "SUM(CASE WHEN alerttype = 1 AND status = 0 THEN 1 ELSE 0 END) as sosUnreadCount, " + + "SUM(CASE WHEN alerttype = 2 AND status = 1 THEN 1 ELSE 0 END) as analysisReadCount, " + + "SUM(CASE WHEN alerttype = 2 AND status = 0 THEN 1 ELSE 0 END) as analysisUnreadCount " + + "FROM tb_alert_message " + + "WHERE orgid = #{orgid} " + + "AND createtime BETWEEN #{startTime} AND #{endTime} " + + "GROUP BY DATE(createtime) " + + "ORDER BY date ASC") + List> selectDailyAlertMessageStatistics(@Param("orgid") Integer orgid, + @Param("startTime") String startTime, + @Param("endTime") String endTime); + + + /** + * 获取预警统计数据 首页 + */ + @Select("SELECT " + + "COUNT(*) as alertTotal, " + + "SUM(CASE WHEN status = 0 THEN 1 ELSE 0 END) as alertUnhandled " + + "FROM tb_alert_message WHERE orgid = #{orgid}") + AlertStatisticsVO getAlertStatistics(@Param("orgid") Integer orgid); + } \ No newline at end of file diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/dal/mysql/device/DeviceMapper.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/dal/mysql/device/DeviceMapper.java index b8fb54a18e..9be7cd733f 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/dal/mysql/device/DeviceMapper.java +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/dal/mysql/device/DeviceMapper.java @@ -9,6 +9,8 @@ import cn.iocoder.yudao.module.system.dal.dataobject.device.DeviceDO; import com.baomidou.mybatisplus.annotation.InterceptorIgnore; import org.apache.ibatis.annotations.Mapper; import cn.iocoder.yudao.module.system.controller.admin.device.vo.*; +import org.apache.ibatis.annotations.Param; +import org.apache.ibatis.annotations.Select; /** * 设备 Mapper @@ -54,5 +56,36 @@ public interface DeviceMapper extends BaseMapperX { wrapper.orderByDesc(DeviceDO::getId); return selectPage(reqVO, wrapper); } + /** + * 获取设备基础统计 + */ + @Select("SELECT " + + "COUNT(*) as totalCount, " + + "SUM(CASE WHEN devicestatus = 1 THEN 1 ELSE 0 END) as onlineCount, " + + "SUM(CASE WHEN devicestatus = 2 THEN 1 ELSE 0 END) as offlineCount " + + "FROM tb_device WHERE orgid = #{orgid}") + DeviceStatistics getDeviceStatistics(@Param("orgid") Integer orgid); + /** + * 获取省份设备数量统计 + */ + @Select("SELECT " + + "SUBSTRING_INDEX(location, '/', 1) as province, " + + "COUNT(*) as count " + + "FROM tb_device " + + "WHERE orgid = #{orgid} " + + "GROUP BY SUBSTRING_INDEX(location, '/', 1)") + List getProvinceDeviceCount(@Param("orgid") Integer orgid); + + /** + * 根据省份名称获取经纬度 + */ + @Select("SELECT province_name, longitude, latitude " + + "FROM province_coords " + + "WHERE province_name = #{provinceName}") + ProvinceCoords getByProvince(@Param("provinceName") String provinceName); + /* + * 首页查询设备数量统计 + * */ + DeviceStatistics getDevice_Statistics(@Param("orgid") Integer orgid); } \ No newline at end of file diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/dal/mysql/person/PersonMapper.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/dal/mysql/person/PersonMapper.java index ddd2a4f685..32bbdc97de 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/dal/mysql/person/PersonMapper.java +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/dal/mysql/person/PersonMapper.java @@ -48,5 +48,9 @@ public interface PersonMapper extends BaseMapperX { * 按天统计开通会员的人数 */ List> countVipByDay(@Param("startDate") String startDate, @Param("endDate") String endDate); + /* + * 首页统计 会员增长趋势 一周 + * */ + List getMemberGrowthData(@Param("orgid") Integer orgid); } \ No newline at end of file diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/dal/mysql/record/RecordMapper.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/dal/mysql/record/RecordMapper.java index ceea2cd570..56f3a9c9d1 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/dal/mysql/record/RecordMapper.java +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/dal/mysql/record/RecordMapper.java @@ -58,4 +58,11 @@ public interface RecordMapper extends BaseMapperX { @Param("startTime") LocalDateTime startTime, @Param("endTime") LocalDateTime endTime); + /** + * 按日期分组查询会员回访记录统计,包含结果 + */ + List> selectDailyStatisticsWithResult(@Param("orgid") Integer orgid, + @Param("startTime") String startTime, + @Param("endTime") String endTime); + } \ No newline at end of file diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/alertmessage/AlertMessageService.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/alertmessage/AlertMessageService.java index 53f4ff9192..ce573df8d4 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/alertmessage/AlertMessageService.java +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/alertmessage/AlertMessageService.java @@ -33,6 +33,10 @@ public interface AlertMessageService { * 根据机构ID查询所有未读预警信息 * */ List getAlertMessageList(Integer deptid); + /* + * 预警信息统计 首页 + * */ + AlertStatisticsVO getAlertStatistics(Integer orgid); /** * 删除预警信息 diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/alertmessage/AlertMessageServiceImpl.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/alertmessage/AlertMessageServiceImpl.java index 6ac582fc83..1ae15e3ce3 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/alertmessage/AlertMessageServiceImpl.java +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/alertmessage/AlertMessageServiceImpl.java @@ -46,6 +46,7 @@ public class AlertMessageServiceImpl implements AlertMessageService { AlertMessageDO updateObj = BeanUtils.toBean(updateReqVO, AlertMessageDO.class); alertMessageMapper.updateById(updateObj); } + @Override public List getAlertMessageList(Integer deptid) { // 创建 LambdaQueryWrapper 实例 @@ -58,6 +59,21 @@ public class AlertMessageServiceImpl implements AlertMessageService { // 执行查询 return alertMessageMapper.selectList(queryWrapper); } + @Override + public AlertStatisticsVO getAlertStatistics(Integer orgid) { + // 直接调用Mapper,一次查询获取所有数据 + AlertStatisticsVO result = alertMessageMapper.getAlertStatistics(orgid); + + // 处理null值,确保返回的数据不为null + if (result == null) { + result = new AlertStatisticsVO(); + result.setAlertTotal(0); + result.setAlertUnhandled(0); + } + + return result; + } + @Override public void deleteAlertMessage(Integer id) { // 校验存在 @@ -82,41 +98,23 @@ public class AlertMessageServiceImpl implements AlertMessageService { return alertMessageMapper.selectPage(pageReqVO); } + // 修改你的Service方法 @Override public AlertMessageStatisticsRespVO getAlertMessageStatistics(AlertMessageStatisticsReqVO statisticsReqVO) { - // 创建查询条件 - LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); - - // 添加时间范围条件 - queryWrapper.between(AlertMessageDO::getCreatetime, statisticsReqVO.getStartTime(), statisticsReqVO.getEndTime()); - - // 添加机构ID条件 - queryWrapper.eq(AlertMessageDO::getOrgid, statisticsReqVO.getOrgid()); - - // 查询总数量 - Long totalCount = alertMessageMapper.selectCount(queryWrapper); - - // 查询已读数量 - LambdaQueryWrapper readQueryWrapper = new LambdaQueryWrapper<>(); - readQueryWrapper.between(AlertMessageDO::getCreatetime, statisticsReqVO.getStartTime(), statisticsReqVO.getEndTime()) - .eq(AlertMessageDO::getOrgid, statisticsReqVO.getOrgid()) - .eq(AlertMessageDO::getStatus, 1); // status = 1 表示已读 - Long readCount = alertMessageMapper.selectCount(readQueryWrapper); - - // 查询未读数量 - LambdaQueryWrapper unreadQueryWrapper = new LambdaQueryWrapper<>(); - unreadQueryWrapper.between(AlertMessageDO::getCreatetime, statisticsReqVO.getStartTime(), statisticsReqVO.getEndTime()) - .eq(AlertMessageDO::getOrgid, statisticsReqVO.getOrgid()) - .eq(AlertMessageDO::getStatus, 0); // status = 0 表示未读 - Long unreadCount = alertMessageMapper.selectCount(unreadQueryWrapper); - - // 查询按日期分组的数据 - List> dailyStatistics = alertMessageMapper.selectDailyStatistics( - statisticsReqVO.getOrgid(), - statisticsReqVO.getStartTime(), + // 查询总体统计 + Map totalStats = alertMessageMapper.selectAlertMessageStatistics( + statisticsReqVO.getOrgid(), + statisticsReqVO.getStartTime(), statisticsReqVO.getEndTime() ); - + + // 查询按日期分组的数据 + List> dailyStatistics = alertMessageMapper.selectDailyAlertMessageStatistics( + statisticsReqVO.getOrgid(), + statisticsReqVO.getStartTime(), + statisticsReqVO.getEndTime() + ); + // 转换按日期分组的数据 List dailyData = new ArrayList<>(); for (Map stat : dailyStatistics) { @@ -131,17 +129,29 @@ public class AlertMessageServiceImpl implements AlertMessageService { dailyAlertData.setTotalCount(((Number) stat.get("totalCount")).longValue()); dailyAlertData.setReadCount(((Number) stat.get("readCount")).longValue()); dailyAlertData.setUnreadCount(((Number) stat.get("unreadCount")).longValue()); + dailyAlertData.setSosCount(((Number) stat.get("sosCount")).longValue()); + dailyAlertData.setAnalysisCount(((Number) stat.get("analysisCount")).longValue()); + dailyAlertData.setSosReadCount(((Number) stat.get("sosReadCount")).longValue()); + dailyAlertData.setSosUnreadCount(((Number) stat.get("sosUnreadCount")).longValue()); + dailyAlertData.setAnalysisReadCount(((Number) stat.get("analysisReadCount")).longValue()); + dailyAlertData.setAnalysisUnreadCount(((Number) stat.get("analysisUnreadCount")).longValue()); dailyData.add(dailyAlertData); } - + // 构建返回结果 AlertMessageStatisticsRespVO result = new AlertMessageStatisticsRespVO(); - result.setTotalCount(totalCount); - result.setReadCount(readCount); - result.setUnreadCount(unreadCount); + result.setTotalCount(((Number) totalStats.get("totalCount")).longValue()); + result.setReadCount(((Number) totalStats.get("readCount")).longValue()); + result.setUnreadCount(((Number) totalStats.get("unreadCount")).longValue()); + result.setSosCount(((Number) totalStats.get("sosCount")).longValue()); + result.setAnalysisCount(((Number) totalStats.get("analysisCount")).longValue()); + result.setSosReadCount(((Number) totalStats.get("sosReadCount")).longValue()); + result.setSosUnreadCount(((Number) totalStats.get("sosUnreadCount")).longValue()); + result.setAnalysisReadCount(((Number) totalStats.get("analysisReadCount")).longValue()); + result.setAnalysisUnreadCount(((Number) totalStats.get("analysisUnreadCount")).longValue()); result.setDailyData(dailyData); - - return result; - } + return result; + + } } \ No newline at end of file diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/device/DeviceService.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/device/DeviceService.java index c4c79a057f..dcd27f48fb 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/device/DeviceService.java +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/device/DeviceService.java @@ -59,6 +59,11 @@ public interface DeviceService { * @return 设备分页 */ PageResult getDevicePage(DevicePageReqVO pageReqVO); + /* + * + * 首页 获取设备数量统计 + * */ + DeviceStatistics getDeviceStatistics(Integer orgid); /** * 根据设备ID更新设备状态 @@ -75,5 +80,9 @@ public interface DeviceService { * @return 设备分页 */ PageResult getDeviceNotBind(DevicePageReqVO pageReqVO); - + /* + * + * 首页查询设备地图分布接口 + * */ + DeviceMapVO getDeviceMapData(Integer orgid); } \ No newline at end of file diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/device/DeviceServiceImpl.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/device/DeviceServiceImpl.java index 28354c4bea..7c8337e511 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/device/DeviceServiceImpl.java +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/device/DeviceServiceImpl.java @@ -12,6 +12,9 @@ import cn.iocoder.yudao.framework.common.util.object.BeanUtils; import cn.iocoder.yudao.module.system.dal.mysql.device.DeviceMapper; +import java.util.ArrayList; +import java.util.List; + import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception; import static cn.iocoder.yudao.module.system.enums.ErrorCodeConstants.*; @@ -80,7 +83,10 @@ public class DeviceServiceImpl implements DeviceService { public PageResult getDevicePage(DevicePageReqVO pageReqVO) { return deviceMapper.selectPage(pageReqVO); } - + @Override + public DeviceStatistics getDeviceStatistics(Integer orgid) { + return deviceMapper.getDevice_Statistics(orgid); + } @Override public void updateDeviceStatus(Integer devicecode, Integer devicestatus) { // 校验设备是否存在 @@ -101,5 +107,45 @@ public class DeviceServiceImpl implements DeviceService { public PageResult getDeviceNotBind(DevicePageReqVO pageReqVO) { return deviceMapper.selectNotBindPage(pageReqVO); } + @Override + public DeviceMapVO getDeviceMapData(Integer orgid) { + DeviceMapVO result = new DeviceMapVO(); + + // 1. 获取设备基础统计 + DeviceStatistics stats = deviceMapper.getDeviceStatistics(orgid); + result.setTotalCount(stats.getTotalCount()); + result.setOnlineCount(stats.getOnlineCount()); + result.setOfflineCount(stats.getOfflineCount()); + + + + // 3. 获取省份分布数据 + List provinceData = deviceMapper.getProvinceDeviceCount(orgid); + List mapData = new ArrayList<>(); + List scatterData = new ArrayList<>(); + + for (ProvinceDeviceCount item : provinceData) { + // 地图数据 + MapDataItem mapItem = new MapDataItem(); + mapItem.setName(item.getProvince()); + mapItem.setValue(item.getCount()); + mapData.add(mapItem); + + // 散点图数据 + ProvinceCoords coords = deviceMapper.getByProvince(item.getProvince()); + if (coords != null) { + ScatterDataItem scatterItem = new ScatterDataItem(); + scatterItem.setName(item.getProvince()); + scatterItem.setValue(new double[]{coords.getLongitude(), coords.getLatitude(), item.getCount()}); + scatterItem.setCount(item.getCount()); + scatterData.add(scatterItem); + } + } + + result.setMapData(mapData); + result.setScatterData(scatterData); + + return result; + } } \ No newline at end of file diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/person/PersonService.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/person/PersonService.java index 8088408c8d..1b5cc28f82 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/person/PersonService.java +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/person/PersonService.java @@ -28,6 +28,11 @@ public interface PersonService { * @param updateReqVO 更新信息 */ void updatePerson(@Valid PersonSaveReqVO updateReqVO); + /* + * 首页统计会员增长趋势 一周 + * */ + List getMemberGrowthData(Integer orgid); + /* * 根据主键ID 更新家庭成员 信息 * */ diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/person/PersonServiceImpl.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/person/PersonServiceImpl.java index 334cb36a60..53c39ac903 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/person/PersonServiceImpl.java +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/person/PersonServiceImpl.java @@ -48,6 +48,10 @@ public class PersonServiceImpl implements PersonService { personMapper.updateById(updateObj); } @Override + public List getMemberGrowthData(Integer orgid) { + return personMapper.getMemberGrowthData(orgid); + } + @Override public Integer updatefamilyinfo(PersonUpfamilyInfoVO updateReqVO) { Integer maxfamilyid = generateNextFamilyId(); diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/record/RecordService.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/record/RecordService.java index 270e78d586..f3eff67562 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/record/RecordService.java +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/record/RecordService.java @@ -28,6 +28,10 @@ public interface RecordService { * @param updateReqVO 更新信息 */ void updateRecord(@Valid RecordSaveReqVO updateReqVO); + /* + * 回访记录统计信息 + * */ + List> getVipCountByDay(Integer orgid, String startDate, String endDate); /** * 删除会员回访记录 diff --git a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/record/RecordServiceImpl.java b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/record/RecordServiceImpl.java index c0e4453e5e..a053b2bc83 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/record/RecordServiceImpl.java +++ b/yudao-module-system/yudao-module-system-biz/src/main/java/cn/iocoder/yudao/module/system/service/record/RecordServiceImpl.java @@ -1,17 +1,14 @@ package cn.iocoder.yudao.module.system.service.record; -import com.alibaba.druid.wall.violation.ErrorCode; import org.springframework.stereotype.Service; import javax.annotation.Resource; import org.springframework.validation.annotation.Validated; -import org.springframework.transaction.annotation.Transactional; import java.util.*; import java.time.LocalDate; import cn.iocoder.yudao.module.system.controller.admin.record.vo.*; import cn.iocoder.yudao.module.system.dal.dataobject.record.RecordDO; import cn.iocoder.yudao.framework.common.pojo.PageResult; -import cn.iocoder.yudao.framework.common.pojo.PageParam; import cn.iocoder.yudao.framework.common.util.object.BeanUtils; import cn.iocoder.yudao.module.system.dal.mysql.record.RecordMapper; @@ -49,6 +46,10 @@ public class RecordServiceImpl implements RecordService { RecordDO updateObj = BeanUtils.toBean(updateReqVO, RecordDO.class); recordMapper.updateById(updateObj); } + @Override + public List> getVipCountByDay(Integer orgid, String startDate, String endDate) { + return recordMapper.selectDailyStatisticsWithResult(orgid,startDate, endDate); + } @Override public void deleteRecord(Integer id) { diff --git a/yudao-module-system/yudao-module-system-biz/src/main/resources/mapper/device/DeviceMapper.xml b/yudao-module-system/yudao-module-system-biz/src/main/resources/mapper/device/DeviceMapper.xml index 8d57277074..ab0ca09abe 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/resources/mapper/device/DeviceMapper.xml +++ b/yudao-module-system/yudao-module-system-biz/src/main/resources/mapper/device/DeviceMapper.xml @@ -8,5 +8,12 @@ 代码生成器暂时只生成 Mapper XML 文件本身,更多推荐 MybatisX 快速开发插件来生成查询。 文档可见:https://www.iocoder.cn/MyBatis/x-plugins/ --> - + \ No newline at end of file diff --git a/yudao-module-system/yudao-module-system-biz/src/main/resources/mapper/person/PersonMapper.xml b/yudao-module-system/yudao-module-system-biz/src/main/resources/mapper/person/PersonMapper.xml index 101cb09ca1..f6478ac0b4 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/resources/mapper/person/PersonMapper.xml +++ b/yudao-module-system/yudao-module-system-biz/src/main/resources/mapper/person/PersonMapper.xml @@ -20,5 +20,40 @@ GROUP BY DATE_FORMAT(vipStartTime, '%Y-%m-%d') ORDER BY date - + \ No newline at end of file diff --git a/yudao-module-system/yudao-module-system-biz/src/main/resources/mapper/record/RecordMapper.xml b/yudao-module-system/yudao-module-system-biz/src/main/resources/mapper/record/RecordMapper.xml index 39bbfc69d1..9ed65b6aee 100644 --- a/yudao-module-system/yudao-module-system-biz/src/main/resources/mapper/record/RecordMapper.xml +++ b/yudao-module-system/yudao-module-system-biz/src/main/resources/mapper/record/RecordMapper.xml @@ -8,5 +8,19 @@ 代码生成器暂时只生成 Mapper XML 文件本身,更多推荐 MybatisX 快速开发插件来生成查询。 文档可见:https://www.iocoder.cn/MyBatis/x-plugins/ --> - + \ No newline at end of file