yaowang
/
kn-vordm
10
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

代码提交

This commit is contained in:
glj 2023-03-22 18:42:48 +08:00
parent 04908e7fe4
commit 7fc1ca4497
41 changed files with 747 additions and 864 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
kn-common/src/main/java/org/springblade/common/utils/DatesUtil.java Normal file
View File

@ -0,0 +1,36 @@
package org.springblade.common.utils;
import java.util.Calendar;
import java.util.Date;
/**
* 日期工具类
*/
public class DatesUtil {
/**
* 获取任意时间
* @param days 天数 1 加一天 -1 减一天
* @return
*/
public static Date getArbitrarilyTime(Integer days) {
Date date = new Date();
if (date == null) {
return null;
}
Calendar cal = Calendar.getInstance();
cal.setTime(date);
cal.add(Calendar.DATE, days);
return cal.getTime();
}
// 获取当天的开始时间
public static java.util.Date getTime() {
Calendar calendar= Calendar.getInstance();
return calendar.getTime();
}
}

47
kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/entity/DownloadRecord.java Normal file
View File

@ -0,0 +1,47 @@
package com.kening.vordm.entity;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import java.io.Serializable;
/**
*
* @TableName download_record
*/
@TableName(value ="download_record")
@Data
public class DownloadRecord implements Serializable {
/**
* 数据自增列
*/
@TableId
private Integer id;
/**
* 灾害id
*/
private Integer diasterId;
/**
* 大的数据源：1为新闻资讯，2为社交媒体，3实体数据
4、遥感元数据；5图形数据（词云和热点区域）
*/
private Integer bigType;
/**
* 数据类型 : 1_1为新闻资讯-baidu;1_2新闻资讯-bing,2_1为社交媒体-twitter;2_2为社交媒体-weibo；3_1是实体数据-basic_data,3_2 是实体数据-respond_report ,3_3 是实体数据-cartographic_product ;4_1是遥感影像-landset,4_2是遥感影像-sentinel;5_1为图形数据-hotspot,5_2为图形数据-word_clouds
*/
private String smallType;
/**
* 下载次数统计
*/
private Integer count;
@TableField(exist = false)
private static final long serialVersionUID = 1L;
}

96
kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/entity/EntityData.java
View File

@ -1,96 +0,0 @@
package com.kening.vordm.entity;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.util.Date;
import lombok.Data;
/**
* 其他上传的实体数据
* @TableName entity_data
*/
@TableName(value ="entity_data")
@Data
public class EntityData implements Serializable {
/**
* 数据自增列
*/
@TableId
private Long id;
/**
* 数据来源机构
*/
private String source;
/**
* 数据名称
*/
private String title;
/**
* 数据产品提供者
*/
private String provider;
/**
* 数据产品的大小
*/
private Integer size;
/**
* 数据类型（制图产品，减灾产品和其他数据）
*/
private String type;
/**
* 数据下载链接（网站上，对象存储路径）
*/
private String link;
/**
* 数据备注
*/
private String remark;
/**
* 提交时间
*/
private Date applyTime;
/**
* 灾害id
*/
private Integer disasterId;
/**
* 可视化可视化标志0-不可可视化；1-表示可以可视化
*/
private Integer visualFlag;
/**
* 可视化跳转中心经度
*/
private Double visualLon;
/**
* 可视化跳转中心纬度
*/
private Double visualLat;
/**
* 是否由志愿者上传（0-不是；1-是）
*/
private Integer voluntaryFlag;
/**
* 数据条目创建时间
*/
private Date createTime;
@TableField(exist = false)
private static final long serialVersionUID = 1L;
}

34
kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/entity/ExportHotspot.java Normal file
View File

@ -0,0 +1,34 @@
package com.kening.vordm.entity;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import java.io.Serializable;
/**
*
* @TableName export_hotspot
*/
@TableName(value ="export_hotspot")
@Data
public class ExportHotspot implements Serializable {
/**
* 区域_中文
*/
private String areaCn;
/**
* 区域_英文
*/
private String areaEn;
/**
* 出现频次
*/
private Integer frequency;
@TableField(exist = false)
private static final long serialVersionUID = 1L;
}

29
kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/entity/ExportNews.java Normal file
View File

@ -0,0 +1,29 @@
package com.kening.vordm.entity;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import java.io.Serializable;
/**
*
* @TableName export_news
*/
@TableName(value ="export_news")
@Data
public class ExportNews implements Serializable {
/**
* 新闻名称
*/
private String title;
/**
* 新闻内容
*/
private String content;
@TableField(exist = false)
private static final long serialVersionUID = 1L;
}

38
kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/entity/Websites.java → kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/entity/ExportSocialMedia.java
View File

@ -3,47 +3,47 @@ package com.kening.vordm.entity;
import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName; import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.util.Date;
import lombok.Data; import lombok.Data;
import java.io.Serializable;
import java.util.Date;
/** /**
* 减灾网址 *
* @TableName websites * @TableName export_social_media
*/ */
@TableName(value ="websites") @TableName(value ="export_social_media")
@Data @Data
public class Websites implements Serializable { public class ExportSocialMedia implements Serializable {
/** /**
* 数据自增列 * 推文发表时间
*/ */
@TableId private Date time;
private Long id;
/** /**
* 减灾网站名称 * 推文内容
*/ */
private String title; private String content;
/** /**
* 减灾网站链接 * 点赞数量
*/ */
private String link; private Integer favoriteCount;
/** /**
* 提供者 * 回复数
*/ */
private String provider; private Integer replyCount;
/** /**
* 灾害id * 访问树量
*/ */
private Integer disasterId; private Integer visitCount;
/** /**
* 数据条目创建时间 * 转发次数
*/ */
private Date createTime; private Integer retweetCount;
@TableField(exist = false) @TableField(exist = false)
private static final long serialVersionUID = 1L; private static final long serialVersionUID = 1L;

38
kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/entity/WordColuds.java → kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/entity/ExportWordClouds.java
View File

@ -3,23 +3,18 @@ package com.kening.vordm.entity;
import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName; import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.util.Date;
import lombok.Data; import lombok.Data;
/** import java.io.Serializable;
* 词云数据 import java.util.Date;
* @TableName word_coluds
*/
@TableName(value ="word_coluds")
@Data
public class WordColuds implements Serializable {
/**
* 数据自增列
*/
@TableId
private Long id;
/**
*
* @TableName export_word_clouds
*/
@TableName(value ="export_word_clouds")
@Data
public class ExportWordClouds implements Serializable {
/** /**
* 该词组归属的时间 * 该词组归属的时间
*/ */
@ -35,21 +30,6 @@ public class WordColuds implements Serializable {
*/ */
private String word; private String word;
/**
* 灾害id
*/
private Integer disasterId;
/**
* 数据条目创建时间
*/
private Date createTime;
/**
* 审核状态，0为未审核，1为审核保留，2为审核不保留
*/
private Integer status;
@TableField(exist = false) @TableField(exist = false)
private static final long serialVersionUID = 1L; private static final long serialVersionUID = 1L;

56
kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/entity/Hotspot.java
View File

@ -1,56 +0,0 @@
package com.kening.vordm.entity;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.util.Date;
import lombok.Data;
/**
* 热点区域数据
* @TableName hotspot
*/
@TableName(value ="hotspot")
@Data
public class Hotspot implements Serializable {
/**
* 数据自增列
*/
@TableId
private Long id;
/**
* 区域_中文
*/
private String areaCn;
/**
* 区域_英文
*/
private String areaEn;
/**
* 出现频次
*/
private Integer frequency;
/**
* 灾害id
*/
private Integer disasterId;
/**
* 数据条目创建时间
*/
private Date createTime;
/**
* 是否保留此条目，0为未审核，1为审核保留，2为审核不保留
*/
private Integer status;
@TableField(exist = false)
private static final long serialVersionUID = 1L;
}

46
kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/entity/MapServer.java
View File

@ -1,46 +0,0 @@
package com.kening.vordm.entity;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import lombok.Data;
/**
* 上传基础地理数据，并发布到geoserver上，记录geoserver的存储信息
* @TableName map_server
*/
@TableName(value ="map_server")
@Data
public class MapServer implements Serializable {
/**
* 数据自增列
*/
@TableId
private Long id;
/**
* 展示在前端的名字
*/
private String name;
/**
* 灾害id
*/
private Integer disasterId;
/**
* 缩放纬度
*/
private Double lat;
/**
* 缩放经度
*/
private Double lon;
@TableField(exist = false)
private static final long serialVersionUID = 1L;
}

61
kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/entity/News.java
View File

@ -1,61 +0,0 @@
package com.kening.vordm.entity;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.util.Date;
import lombok.Data;
/**
* 新闻咨询数据表
* @TableName news
*/
@TableName(value ="news")
@Data
public class News implements Serializable {
/**
* 数据自增列
*/
@TableId
private Long id;
/**
* 新闻名称
*/
private String title;
/**
* 新闻内容
*/
private String content;
/**
* 新闻链接
*/
private String link;
/**
* 新闻类型（baidu,bing）0-baidu ,1-bing
*/
private Integer type;
/**
* 灾害id
*/
private Integer disasterId;
/**
* 数据条目创建时间
*/
private Date createTime;
/**
* 是否保留此条目，0为未审核，1为审核保留，2为审核不保留
*/
private Integer status;
@TableField(exist = false)
private static final long serialVersionUID = 1L;
}

56
kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/entity/PictureInfo.java
View File

@ -1,56 +0,0 @@
package com.kening.vordm.entity;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.util.Date;
import lombok.Data;
/**
*
* @TableName picture_info
*/
@TableName(value ="picture_info")
@Data
public class PictureInfo implements Serializable {
/**
* 数据自增列
*/
@TableId
private Long id;
/**
* 数据存储链接
*/
private String link;
/**
* 数据大小（byte）
*/
private Integer size;
/**
* 数据格式，jpg、png
*/
private String type;
/**
* 灾害id
*/
private Integer disasterId;
/**
* 创建时间
*/
private Date createTime;
/**
* 是否为主页显示，0为不是，1为是
*/
private Integer isMain;
@TableField(exist = false)
private static final long serialVersionUID = 1L;
}

151
kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/entity/RemoteSensingSourceData.java
View File

@ -1,151 +0,0 @@
package com.kening.vordm.entity;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.util.Date;
import lombok.Data;
/**
* 遥感影像源数据
* @TableName remote_sensing_source_data
*/
@TableName(value ="remote_sensing_source_data")
@Data
public class RemoteSensingSourceData implements Serializable {
/**
* 主键
*/
@TableId
private Long id;
/**
* 影像缩略图地址
*/
private String thumbnailLink;
/**
* 产品级别
*/
private String productLevel;
/**
* 产品序列号
*/
private String productSerialNum;
/**
* 生产时间
*/
private Date productTime;
/**
* 产品波段树
*/
private Integer productBandsNum;
/**
* 产品分辨率
*/
private Double productResolution;
/**
* 原始数据条带号
*/
private Integer rawDataStripeNum;
/**
* 云层覆盖量
*/
private Integer cloudCover;
/**
* 产品大小(MB为单位)
*/
private Integer productSize;
/**
* 投影带号
*/
private Integer projectBandNum;
/**
* 覆盖区域
*/
private String coverageArea;
/**
* 卫星代号
*/
private String satelliteCode;
/**
* 接收时间
*/
private Date receivingTime;
/**
* 左上纬度
*/
private Double upperLeftLat;
/**
* 左上经度
*/
private Double upperLeftLon;
/**
* 右上纬度
*/
private Double upperRightLat;
/**
* 右上经度
*/
private Double upperRightLon;
/**
* 景中心纬度
*/
private Double viewCenterLat;
/**
* 景中心经度
*/
private Double viewCenterLon;
/**
* 右下纬度
*/
private Double lowerRightLat;
/**
* 右下经度
*/
private Double lowerRightLon;
/**
* 左下纬度
*/
private Double lowerLeftLat;
/**
* 左下经度
*/
private Double lowerLeftLon;
/**
* 灾害id
*/
private Integer disasterId;
/**
* 数据条目创建时间
*/
private Date createTime;
@TableField(exist = false)
private static final long serialVersionUID = 1L;
}

207
kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/entity/RespondInfo.java
View File

@ -18,107 +18,152 @@ public class RespondInfo implements Serializable {
* 唯一值 * 唯一值
*/ */
@TableId @TableId
private Long id; private Long id;
/** /**
* 用户姓名 * 用户姓名
*/ */
private String userName; private String userName;
/** /**
* 邮箱 * 邮箱
*/ */
private String email; private String email;
/** /**
* 组织机构 * 组织机构
*/ */
private String organization; private String organization;
/** /**
* 地区 * 地区
*/ */
private String region; private String region;
/** /**
* 灾害类型 * 灾害类型
*/ */
private String disasterType; private String disasterType;
/** /**
* 灾害关键词 * 灾害关键词
*/ */
private String disasterKeyword; private String disasterKeyword;
/** /**
* 灾害发生时间 * 灾害发生时间
*/ */
private Date disasterTime; private Date disasterTime;
/** /**
* 灾害响应时间 * 灾害响应时间
*/ */
private Date respondTime; private Date respondTime;
/** /**
* 用户职业 * 用户职业
*/ */
private String userProfession; private String userProfession;
/** /**
* 用户研究领域 * 用户研究领域
*/ */
private String userResearchField; private String userResearchField;
/** /**
* 灾害发生地经度 * 灾害发生地经度
*/ */
private Double disasterLon; private Double disasterLon;
/** /**
* 灾害发生地纬度 * 灾害发生地纬度
*/ */
private Double disasterLat; private Double disasterLat;
/** /**
* 灾害强度或震级 * 灾害强度或震级
*/ */
private String disasterLevel; private String disasterLevel;
/** /**
* 受灾国家 * 受灾国家
*/ */
private String disasterCountry; private String disasterCountry;
/** /**
* 响应状态，0未响应，1响应中，2响应已完成 * 响应状态，0未审批，1审批未通过。2审批通过并正在响应，3审批通过并且响应完成
*/ */
private Integer respondStatus; private Integer respondStatus;
/** /**
* 爬虫类型 * 本灾害的用户访问次数
*/ */
private Integer spidertype; private Integer visitCount;
/** /**
* 爬虫起始时间 * 爬虫类型
*/ */
private Date tempendtime; private Integer spiderType;
/** /**
* 爬虫区域范围 * 爬虫起始时间
*/ */
private String tempregion; private Date tempEndTime;
/** /**
* 爬虫终止时间 * 爬虫区域范围
*/ */
private Date tempstarttime; private String disasterRegion;
/** /**
* 数据条目创建时间 * 爬虫终止时间
*/ */
private Date createTime; private Date tempStartTime;
/**
* 数据条目创建时间
*/
private Date createTime;
/**
* 灾害id,审批通过后生成
*/
private String disasterId;
/**
* 下载次数
*/
private Integer downloadFrequency;
/**
* 时间段 0 最近一周 / 1 最近一个月 / 2 最近半年
*/
@TableField(exist = false)
private Integer timePeriod;
/**
* 排序字段 0 Visits / 1 Downloads / 2 Update time
*/
@TableField(exist = false)
private Integer sort;
/**
* 排序字段
*/
@TableField(exist = false)
private String sortName;
/**
* 开始时间
*/
@TableField(exist = false)
private String startTime;
/**
* 结束时间
*/
@TableField(exist = false)
private String endTime;
@TableField(exist = false) @TableField(exist = false)
private static final long serialVersionUID = 1L; private static final long serialVersionUID = 1L;

106
kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/entity/SocialMedia.java
View File

@ -1,106 +0,0 @@
package com.kening.vordm.entity;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.util.Date;
import lombok.Data;
/**
* 社交媒体数据表，主要指twitter，facebook,微博等数据来源，重要字段 time-content
* @TableName social_media
*/
@TableName(value ="social_media")
@Data
public class SocialMedia implements Serializable {
/**
* 数据自增列
*/
@TableId
private Long id;
/**
* 推文标签链接
*/
private String link;
/**
* 推文发表时间
*/
private Date time;
/**
* 推文内容
*/
private String content;
/**
* 用户id
*/
private Integer userId;
/**
* 点赞数量
*/
private Integer favoriteCount;
/**
* 回复数
*/
private Integer replyCount;
/**
* 转发次数
*/
private Integer retweetCount;
/**
* 地理字段
*/
private String geo;
/**
* 坐标
*/
private String coordinates;
/**
* 发文地
*/
private String place;
/**
* 贡献者
*/
private String contributors;
/**
* 推文主题
*/
private String topic;
/**
* 数据条目创建时间
*/
private Date createTime;
/**
* 灾害id
*/
private Integer disasterId;
/**
* 数据类型，0-twitter ,1-weibo
*/
private Integer type;
/**
* 审核状态，0为未审核，1为审核保留，2为审核不保留
*/
private Integer status;
@TableField(exist = false)
private static final long serialVersionUID = 1L;
}

61
kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/entity/Tool.java
View File

@ -1,61 +0,0 @@
package com.kening.vordm.entity;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.util.Date;
import lombok.Data;
/**
* 模型工具表
* @TableName tool
*/
@TableName(value ="tool")
@Data
public class Tool implements Serializable {
/**
* 数据自增列
*/
@TableId
private Long id;
/**
* 工具名称
*/
private String toolName;
/**
* 数据标签
*/
private String label;
/**
* 导论
*/
private String introduction;
/**
* 工具链接
*/
private String link;
/**
* 联系方式
*/
private String email;
/**
* 对模型的进一步描述
*/
private String detail;
/**
* 数据条目创建时间
*/
private Date createTime;
@TableField(exist = false)
private static final long serialVersionUID = 1L;
}

91
kn-service-api/biz-vordm-api/src/main/java/com/kening/vordm/entity/VoluntaryUploadingData.java
View File

@ -1,91 +0,0 @@
package com.kening.vordm.entity;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.util.Date;
import lombok.Data;
/**
* 自愿者上传数据
* @TableName voluntary_uploading_data
*/
@TableName(value ="voluntary_uploading_data")
@Data
public class VoluntaryUploadingData implements Serializable {
/**
*
*/
@TableId
private Long id;
/**
* 真实姓名
*/
private String realName;
/**
* 所在单位
*/
private String place;
/**
* 职业
*/
private String profession;
/**
* 职称
*/
private String jobTitle;
/**
* 领域
*/
private String field;
/**
* 邮箱
*/
private String email;
/**
* 数据格式
*/
private String type;
/**
* 数据大小(MB存储)
*/
private Integer size;
/**
* 数据说明
*/
private String details;
/**
* 上传时间
*/
private Date uploadtime;
/**
* 灾害id
*/
private Integer disasterId;
/**
* 数据存储地址
*/
private String link;
/**
* 数据条目创建时间
*/
private Date createTime;
@TableField(exist = false)
private static final long serialVersionUID = 1L;
}

34
kn-service/biz-vordm/src/main/java/com/kening/vordm/controller/RespondInfoController.java Normal file
View File

@ -0,0 +1,34 @@
package com.kening.vordm.controller;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.kening.vordm.entity.RespondInfo;
import com.kening.vordm.service.RespondInfoService;
import lombok.RequiredArgsConstructor;
import org.springblade.core.mp.support.Condition;
import org.springblade.core.mp.support.Query;
import org.springblade.core.tool.api.R;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
//灾害数据
@RestController
@RequiredArgsConstructor
@RequestMapping("/respondInfo")
public class RespondInfoController {
//灾害信息服务层
private final RespondInfoService respondInfoService;
/**
* 灾害列表信息
* @param respondInfo 灾害条件信息
* @param query current当前页 size 每页数据量
* @return
*/
@GetMapping("/list")
public R<IPage<RespondInfo>> getRespondInfoList(RespondInfo respondInfo, Query query) {
return R.data(respondInfoService.getRespondInfoList(Condition.getPage(query), respondInfo));
}
}

15
kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/DownloadRecordMapper.java Normal file
View File

@ -0,0 +1,15 @@
package com.kening.vordm.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.kening.vordm.entity.DownloadRecord;
/**
* @author G1393
* @description 针对表【download_record】的数据库操作Mapper
* @createDate 2023-03-22 16:42:20
* @Entity new.domain.DownloadRecord
*/
public interface DownloadRecordMapper extends BaseMapper<DownloadRecord> {
}

19
kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/DownloadRecordMapper.xml Normal file
View File

@ -0,0 +1,19 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.kening.vordm.mapper.DownloadRecordMapper">
<resultMap id="BaseResultMap" type="com.kening.vordm.entity.DownloadRecord">
<id property="id" column="id" jdbcType="INTEGER"/>
<result property="diasterId" column="diaster_id" jdbcType="INTEGER"/>
<result property="bigType" column="big_type" jdbcType="INTEGER"/>
<result property="smallType" column="small_type" jdbcType="VARCHAR"/>
<result property="count" column="count" jdbcType="INTEGER"/>
</resultMap>
<sql id="Base_Column_List">
id,diaster_id,big_type,
small_type,count
</sql>
</mapper>

16
kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/ExportHotspotMapper.java Normal file
View File

@ -0,0 +1,16 @@
package com.kening.vordm.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.kening.vordm.entity.ExportHotspot;
/**
* @author G1393
* @description 针对表【export_hotspot】的数据库操作Mapper
* @createDate 2023-03-22 16:42:20
* @Entity new.domain.ExportHotspot
*/
public interface ExportHotspotMapper extends BaseMapper<ExportHotspot> {
}

16
kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/ExportHotspotMapper.xml Normal file
View File

@ -0,0 +1,16 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.kening.vordm.mapper.ExportHotspotMapper">
<resultMap id="BaseResultMap" type="com.kening.vordm.entity.ExportHotspot">
<result property="areaCn" column="area_cn" jdbcType="VARCHAR"/>
<result property="areaEn" column="area_en" jdbcType="VARCHAR"/>
<result property="frequency" column="frequency" jdbcType="INTEGER"/>
</resultMap>
<sql id="Base_Column_List">
area_cn,area_en,frequency
</sql>
</mapper>

16
kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/ExportNewsMapper.java Normal file
View File

@ -0,0 +1,16 @@
package com.kening.vordm.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.kening.vordm.entity.ExportNews;
/**
* @author G1393
* @description 针对表【export_news】的数据库操作Mapper
* @createDate 2023-03-22 16:42:20
* @Entity new.domain.ExportNews
*/
public interface ExportNewsMapper extends BaseMapper<ExportNews> {
}

15
kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/ExportNewsMapper.xml Normal file
View File

@ -0,0 +1,15 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.kening.vordm.mapper.ExportNewsMapper">
<resultMap id="BaseResultMap" type="com.kening.vordm.entity.ExportNews">
<result property="title" column="title" jdbcType="VARCHAR"/>
<result property="content" column="content" jdbcType="VARCHAR"/>
</resultMap>
<sql id="Base_Column_List">
title,content
</sql>
</mapper>

16
kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/ExportSocialMediaMapper.java Normal file
View File

@ -0,0 +1,16 @@
package com.kening.vordm.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.kening.vordm.entity.ExportSocialMedia;
/**
* @author G1393
* @description 针对表【export_social_media】的数据库操作Mapper
* @createDate 2023-03-22 16:42:20
* @Entity new.domain.ExportSocialMedia
*/
public interface ExportSocialMediaMapper extends BaseMapper<ExportSocialMedia> {
}

20
kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/ExportSocialMediaMapper.xml Normal file
View File

@ -0,0 +1,20 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.kening.vordm.mapper.ExportSocialMediaMapper">
<resultMap id="BaseResultMap" type="com.kening.vordm.entity.ExportSocialMedia">
<result property="time" column="time" jdbcType="TIMESTAMP"/>
<result property="content" column="content" jdbcType="VARCHAR"/>
<result property="favoriteCount" column="favorite_count" jdbcType="INTEGER"/>
<result property="replyCount" column="reply_count" jdbcType="INTEGER"/>
<result property="visitCount" column="visit_count" jdbcType="INTEGER"/>
<result property="retweetCount" column="retweet_count" jdbcType="INTEGER"/>
</resultMap>
<sql id="Base_Column_List">
time,content,favorite_count,
reply_count,visit_count,retweet_count
</sql>
</mapper>

16
kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/ExportWordCloudsMapper.java Normal file
View File

@ -0,0 +1,16 @@
package com.kening.vordm.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.kening.vordm.entity.ExportWordClouds;
/**
* @author G1393
* @description 针对表【export_word_clouds】的数据库操作Mapper
* @createDate 2023-03-22 16:42:20
* @Entity new.domain.ExportWordClouds
*/
public interface ExportWordCloudsMapper extends BaseMapper<ExportWordClouds> {
}

16
kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/ExportWordCloudsMapper.xml Normal file
View File

@ -0,0 +1,16 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.kening.vordm.mapper.ExportWordCloudsMapper">
<resultMap id="BaseResultMap" type="com.kening.vordm.entity.ExportWordClouds">
<result property="time" column="time" jdbcType="TIMESTAMP"/>
<result property="frequency" column="frequency" jdbcType="INTEGER"/>
<result property="word" column="word" jdbcType="VARCHAR"/>
</resultMap>
<sql id="Base_Column_List">
time,frequency,word
</sql>
</mapper>

3
kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/RespondInfoMapper.java
View File

@ -1,7 +1,9 @@
package com.kening.vordm.mapper; package com.kening.vordm.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.kening.vordm.entity.RespondInfo; import com.kening.vordm.entity.RespondInfo;
import org.apache.ibatis.annotations.Param;
/** /**
* @author G1393 * @author G1393
@ -12,4 +14,5 @@ import com.kening.vordm.entity.RespondInfo;
public interface RespondInfoMapper extends BaseMapper<RespondInfo> { public interface RespondInfoMapper extends BaseMapper<RespondInfo> {
IPage<RespondInfo> getRespondInfoList(@Param("respondInfo") RespondInfo respondInfo, IPage<Object> page);
} }

50
kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/RespondInfoMapper.xml
View File

@ -21,20 +21,48 @@
<result property="disasterLevel" column="disaster_level" jdbcType="VARCHAR"/> <result property="disasterLevel" column="disaster_level" jdbcType="VARCHAR"/>
<result property="disasterCountry" column="disaster_country" jdbcType="VARCHAR"/> <result property="disasterCountry" column="disaster_country" jdbcType="VARCHAR"/>
<result property="respondStatus" column="respond_status" jdbcType="SMALLINT"/> <result property="respondStatus" column="respond_status" jdbcType="SMALLINT"/>
<result property="spidertype" column="spidertype" jdbcType="INTEGER"/> <result property="visitCount" column="visit_count" jdbcType="INTEGER"/>
<result property="tempendtime" column="tempendtime" jdbcType="TIMESTAMP"/> <result property="spiderType" column="spider_type" jdbcType="INTEGER"/>
<result property="tempregion" column="tempregion" jdbcType="VARCHAR"/> <result property="tempEndTime" column="temp_end_time" jdbcType="TIMESTAMP"/>
<result property="tempstarttime" column="tempstarttime" jdbcType="TIMESTAMP"/> <result property="disasterRegion" column="disaster_region" jdbcType="VARCHAR"/>
<result property="tempStartTime" column="temp_start_time" jdbcType="TIMESTAMP"/>
<result property="createTime" column="create_time" jdbcType="TIMESTAMP"/> <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
<result property="disasterId" column="disaster_id" jdbcType="TIMESTAMP"/>
<result property="downloadFrequency" column="download_frequency" jdbcType="TIMESTAMP"/>
</resultMap> </resultMap>
<sql id="Base_Column_List"> <sql id="Base_Column_List">
id,user_name,email, ri.id,ri.user_name,ri.email,
organization,region,disaster_type, ri.organization,ri.region,ri.disaster_type,
disaster_keyword,disaster_time,respond_time, ri.disaster_keyword,ri.disaster_time,ri.respond_time,
user_profession,user_research_field,disaster_lon, ri.user_profession,ri.user_research_field,ri.disaster_lon,
disaster_lat,disaster_level,disaster_country, ri.disaster_lat,ri.disaster_level,ri.disaster_country,
respond_status,spidertype,tempendtime, ri.respond_status,ri.visit_count,ri.spider_type,ri.temp_end_time,
tempregion,tempstarttime,create_time ri.disaster_region,ri.temp_start_time,ri.create_time,ri.disaster_id,ri.download_frequency
</sql> </sql>
<select id="getRespondInfoList" resultType="com.kening.vordm.entity.RespondInfo">
select
<include refid="Base_Column_List"/>
from respond_info ri
<where>
<if test="respondInfo.disasterType != null and respondInfo.disasterType != ''">
ri.disaster_type = #{respondInfo.disasterType}
</if>
<if test="respondInfo.respondStatus != null and respondInfo.respondStatus != ''">
and ri.respond_status = #{respondInfo.respondStatus}
</if>
<if test="respondInfo.region != null and respondInfo.region != ''">
and ri.region = #{respondInfo.region}
</if>
<if test="respondInfo.disasterCountry != null and respondInfo.disasterCountry != ''">
and ri.disasterCountry = #{respondInfo.disasterCountry}
</if>
<if test="respondInfo.startTime != null and respondInfo.endTime != null">
and ri.create_time BETWEEN #{respondInfo.startTime} AND #{respondInfo.endTime}
</if>
</where>
ORDER BY ${respondInfo.sortName} DESC
</select>
</mapper> </mapper>

14
kn-service/biz-vordm/src/main/java/com/kening/vordm/service/DownloadRecordService.java Normal file
View File

@ -0,0 +1,14 @@
package com.kening.vordm.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.kening.vordm.entity.DownloadRecord;
/**
* @author G1393
* @description 针对表【download_record】的数据库操作Service
* @createDate 2023-03-22 16:42:20
*/
public interface DownloadRecordService extends IService<DownloadRecord> {
}

14
kn-service/biz-vordm/src/main/java/com/kening/vordm/service/ExportHotspotService.java Normal file
View File

@ -0,0 +1,14 @@
package com.kening.vordm.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.kening.vordm.entity.ExportHotspot;
/**
* @author G1393
* @description 针对表【export_hotspot】的数据库操作Service
* @createDate 2023-03-22 16:42:20
*/
public interface ExportHotspotService extends IService<ExportHotspot> {
}

14
kn-service/biz-vordm/src/main/java/com/kening/vordm/service/ExportNewsService.java Normal file
View File

@ -0,0 +1,14 @@
package com.kening.vordm.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.kening.vordm.entity.ExportNews;
/**
* @author G1393
* @description 针对表【export_news】的数据库操作Service
* @createDate 2023-03-22 16:42:20
*/
public interface ExportNewsService extends IService<ExportNews> {
}

14
kn-service/biz-vordm/src/main/java/com/kening/vordm/service/ExportSocialMediaService.java Normal file
View File

@ -0,0 +1,14 @@
package com.kening.vordm.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.kening.vordm.entity.ExportSocialMedia;
/**
* @author G1393
* @description 针对表【export_social_media】的数据库操作Service
* @createDate 2023-03-22 16:42:20
*/
public interface ExportSocialMediaService extends IService<ExportSocialMedia> {
}

14
kn-service/biz-vordm/src/main/java/com/kening/vordm/service/ExportWordCloudsService.java Normal file
View File

@ -0,0 +1,14 @@
package com.kening.vordm.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.kening.vordm.entity.ExportWordClouds;
/**
* @author G1393
* @description 针对表【export_word_clouds】的数据库操作Service
* @createDate 2023-03-22 16:42:20
*/
public interface ExportWordCloudsService extends IService<ExportWordClouds> {
}

9
kn-service/biz-vordm/src/main/java/com/kening/vordm/service/RespondInfoService.java
View File

@ -1,5 +1,6 @@
package com.kening.vordm.service; package com.kening.vordm.service;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.kening.vordm.entity.RespondInfo; import com.kening.vordm.entity.RespondInfo;
@ -10,4 +11,12 @@ import com.kening.vordm.entity.RespondInfo;
*/ */
public interface RespondInfoService extends IService<RespondInfo> { public interface RespondInfoService extends IService<RespondInfo> {
/**
* 灾害列表信息
* @param respondInfo 灾害条件信息
* @param page current当前页 size 每页数据量
* @return
*/
IPage<RespondInfo> getRespondInfoList(IPage<Object> page, RespondInfo respondInfo);
} }

18
kn-service/biz-vordm/src/main/java/com/kening/vordm/service/impl/DownloadRecordServiceImpl.java Normal file
View File

@ -0,0 +1,18 @@
package com.kening.vordm.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.kening.vordm.entity.DownloadRecord;
import com.kening.vordm.mapper.DownloadRecordMapper;
import com.kening.vordm.service.DownloadRecordService;
import org.springframework.stereotype.Service;
/**
* @author G1393
* @description 针对表【download_record】的数据库操作Service实现
* @createDate 2023-03-22 16:42:20
*/
@Service
public class DownloadRecordServiceImpl extends ServiceImpl<DownloadRecordMapper, DownloadRecord>
implements DownloadRecordService {
}

18
kn-service/biz-vordm/src/main/java/com/kening/vordm/service/impl/ExportHotspotServiceImpl.java Normal file
View File

@ -0,0 +1,18 @@
package com.kening.vordm.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.kening.vordm.entity.ExportHotspot;
import com.kening.vordm.mapper.ExportHotspotMapper;
import com.kening.vordm.service.ExportHotspotService;
import org.springframework.stereotype.Service;
/**
* @author G1393
* @description 针对表【export_hotspot】的数据库操作Service实现
* @createDate 2023-03-22 16:42:20
*/
@Service
public class ExportHotspotServiceImpl extends ServiceImpl<ExportHotspotMapper, ExportHotspot>
implements ExportHotspotService {
}

18
kn-service/biz-vordm/src/main/java/com/kening/vordm/service/impl/ExportNewsServiceImpl.java Normal file
View File

@ -0,0 +1,18 @@
package com.kening.vordm.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.kening.vordm.entity.ExportNews;
import com.kening.vordm.mapper.ExportNewsMapper;
import com.kening.vordm.service.ExportNewsService;
import org.springframework.stereotype.Service;
/**
* @author G1393
* @description 针对表【export_news】的数据库操作Service实现
* @createDate 2023-03-22 16:42:20
*/
@Service
public class ExportNewsServiceImpl extends ServiceImpl<ExportNewsMapper, ExportNews>
implements ExportNewsService {
}

18
kn-service/biz-vordm/src/main/java/com/kening/vordm/service/impl/ExportSocialMediaServiceImpl.java Normal file
View File

@ -0,0 +1,18 @@
package com.kening.vordm.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.kening.vordm.entity.ExportSocialMedia;
import com.kening.vordm.mapper.ExportSocialMediaMapper;
import com.kening.vordm.service.ExportSocialMediaService;
import org.springframework.stereotype.Service;
/**
* @author G1393
* @description 针对表【export_social_media】的数据库操作Service实现
* @createDate 2023-03-22 16:42:20
*/
@Service
public class ExportSocialMediaServiceImpl extends ServiceImpl<ExportSocialMediaMapper, ExportSocialMedia>
implements ExportSocialMediaService {
}

18
kn-service/biz-vordm/src/main/java/com/kening/vordm/service/impl/ExportWordCloudsServiceImpl.java Normal file
View File

@ -0,0 +1,18 @@
package com.kening.vordm.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.kening.vordm.entity.ExportWordClouds;
import com.kening.vordm.mapper.ExportWordCloudsMapper;
import com.kening.vordm.service.ExportWordCloudsService;
import org.springframework.stereotype.Service;
/**
* @author G1393
* @description 针对表【export_word_clouds】的数据库操作Service实现
* @createDate 2023-03-22 16:42:20
*/
@Service
public class ExportWordCloudsServiceImpl extends ServiceImpl<ExportWordCloudsMapper, ExportWordClouds>
implements ExportWordCloudsService {
}

37
kn-service/biz-vordm/src/main/java/com/kening/vordm/service/impl/RespondInfoServiceImpl.java
View File

@ -1,11 +1,15 @@
package com.kening.vordm.service.impl; package com.kening.vordm.service.impl;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.kening.vordm.entity.RespondInfo; import com.kening.vordm.entity.RespondInfo;
import com.kening.vordm.mapper.RespondInfoMapper; import com.kening.vordm.mapper.RespondInfoMapper;
import com.kening.vordm.service.RespondInfoService; import com.kening.vordm.service.RespondInfoService;
import org.springblade.common.utils.DatesUtil;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.text.SimpleDateFormat;
/** /**
* @author G1393 * @author G1393
* @description 针对表【respond_info(存放具体灾害的数据库，其id用于作为灾害id，用于检索每个具体灾害的信息)】的数据库操作Service实现 * @description 针对表【respond_info(存放具体灾害的数据库，其id用于作为灾害id，用于检索每个具体灾害的信息)】的数据库操作Service实现
@ -15,4 +19,37 @@ import org.springframework.stereotype.Service;
public class RespondInfoServiceImpl extends ServiceImpl<RespondInfoMapper, RespondInfo> public class RespondInfoServiceImpl extends ServiceImpl<RespondInfoMapper, RespondInfo>
implements RespondInfoService { implements RespondInfoService {
@Override
public IPage<RespondInfo> getRespondInfoList(IPage<Object> page, RespondInfo respondInfo) {
//排序字段 0 Visits / 1 Downloads / 2 Update time
if (respondInfo.getSort() == 1){
respondInfo.setSortName("ri.visit_count");
}else if (respondInfo.getSort() == 2){
respondInfo.setSortName("ri.download_frequency");
}else if (respondInfo.getSort() == 3){
respondInfo.setSortName("ri.create_time");
}
if (respondInfo.getTimePeriod()!=null){
SimpleDateFormat dateFormat= new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
//获取当前时间
String format = dateFormat.format(DatesUtil.getTime());
respondInfo.setEndTime(format);
//时间段 0 最近一周 / 1 最近一个月 / 2 最近半年
if (respondInfo.getTimePeriod() == 1){
//一周前的时间
String format1 = dateFormat.format(DatesUtil.getArbitrarilyTime(-7));
respondInfo.setStartTime(format1);
}else if (respondInfo.getTimePeriod() == 2){
//一个月前的时间
String format1 = dateFormat.format(DatesUtil.getArbitrarilyTime(-30));
respondInfo.setStartTime(format1);
}else if (respondInfo.getTimePeriod() == 3){
//半年前的时间
String format1 = dateFormat.format(DatesUtil.getArbitrarilyTime(-180));
respondInfo.setStartTime(format1);
}
}
return baseMapper.getRespondInfoList(respondInfo,page);
}
} }