From 41b5ef5719089fe8d0157358494a42b72a98d005 Mon Sep 17 00:00:00 2001 From: why <986973311@qq.com> Date: Mon, 24 Apr 2023 18:49:45 +0800 Subject: [PATCH 1/7] =?UTF-8?q?=E6=8E=A7=E5=88=B6=E5=8F=B0=E7=BB=9F?= =?UTF-8?q?=E8=AE=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/DisasterInfoController.java | 4 +- .../vordm/mapper/DisasterInfoMapper.java | 12 +++ .../vordm/mapper/DisasterInfoMapper.xml | 100 ++++++++++++++++++ .../vordm/service/DisasterInfoService.java | 2 +- .../service/impl/DisasterInfoServiceImpl.java | 67 ++++++++++-- 5 files changed, 171 insertions(+), 14 deletions(-) diff --git a/kn-service/biz-vordm/src/main/java/com/kening/vordm/controller/DisasterInfoController.java b/kn-service/biz-vordm/src/main/java/com/kening/vordm/controller/DisasterInfoController.java index b8b7595..4cd0e48 100644 --- a/kn-service/biz-vordm/src/main/java/com/kening/vordm/controller/DisasterInfoController.java +++ b/kn-service/biz-vordm/src/main/java/com/kening/vordm/controller/DisasterInfoController.java @@ -362,8 +362,8 @@ public class DisasterInfoController { * @return */ @GetMapping("/statistics") - public R statistics() { - return R.data(disasterInfoService.statistics()); + public R statistics(String year) { + return R.data(disasterInfoService.statistics(year)); } /** diff --git a/kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/DisasterInfoMapper.java b/kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/DisasterInfoMapper.java index 8259c97..76d20ce 100644 --- a/kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/DisasterInfoMapper.java +++ b/kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/DisasterInfoMapper.java @@ -68,4 +68,16 @@ public interface DisasterInfoMapper extends BaseMapper { List> getDisasterInfoByMouth(@Param("start") String start,@Param("end") String end,@Param("type") Integer type,@Param("chiefId") Long chiefId); void updataUserByEmail(@Param("email") String email,@Param("password") String password); + + List listGetByYear(String year); + + List> visitAndDownLoad(String year); + + List> initiateAndResponseData(String year); + + List> chiefData(String year); + + List> adminData(String year); + + List> disasterNum(String year); } diff --git a/kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/DisasterInfoMapper.xml b/kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/DisasterInfoMapper.xml index 9682464..6fc84ff 100644 --- a/kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/DisasterInfoMapper.xml +++ b/kn-service/biz-vordm/src/main/java/com/kening/vordm/mapper/DisasterInfoMapper.xml @@ -272,5 +272,105 @@ GROUP BY date + + + + + + diff --git a/kn-service/biz-vordm/src/main/java/com/kening/vordm/service/DisasterInfoService.java b/kn-service/biz-vordm/src/main/java/com/kening/vordm/service/DisasterInfoService.java index 9793fa6..b5a00a7 100644 --- a/kn-service/biz-vordm/src/main/java/com/kening/vordm/service/DisasterInfoService.java +++ b/kn-service/biz-vordm/src/main/java/com/kening/vordm/service/DisasterInfoService.java @@ -61,7 +61,7 @@ public interface DisasterInfoService extends IService { * 后台管理系统-控制台灾害各项统计 * @return */ - Map statistics(); + Map statistics(String year); boolean removeManage(List disasterInfoList); diff --git a/kn-service/biz-vordm/src/main/java/com/kening/vordm/service/impl/DisasterInfoServiceImpl.java b/kn-service/biz-vordm/src/main/java/com/kening/vordm/service/impl/DisasterInfoServiceImpl.java index 70e994e..e3e767c 100644 --- a/kn-service/biz-vordm/src/main/java/com/kening/vordm/service/impl/DisasterInfoServiceImpl.java +++ b/kn-service/biz-vordm/src/main/java/com/kening/vordm/service/impl/DisasterInfoServiceImpl.java @@ -28,6 +28,7 @@ import org.springframework.stereotype.Service; import java.time.LocalDate; import java.util.ArrayList; +import java.util.LinkedHashMap; import java.util.List; import java.util.Map; import java.util.stream.Collectors; @@ -223,29 +224,70 @@ public class DisasterInfoServiceImpl extends ServiceImpl statistics() { + public Map statistics(String year) { Map resultMap = Maps.newHashMap(); - boolean isAdmin = AuthUtil.getTenantId().equals(BladeConstant.ADMIN_TENANT_ID) ? true : false; + //boolean isAdmin = AuthUtil.getTenantId().equals(BladeConstant.ADMIN_TENANT_ID) ? true : false; //查询灾害表数据 - List disasterInfoList = isAdmin ? list():list(Wrappers.lambdaQuery().eq(DisasterInfo::getChiefId,AuthUtil.getUserId())); + List disasterInfoList = this.baseMapper.listGetByYear(year); //统计head头部的数据 Map headMap = headData(disasterInfoList); + //访问量和下载量 + List> visitAndDownLoadData = this.baseMapper.visitAndDownLoad(year); + //响应量和发起量 + List> initiateAndResponseData = this.baseMapper.initiateAndResponseData(year); //统计灾害发生区域占比 Map countryData = disasterCountryProportion(disasterInfoList); //统计当年的灾害申请次数 按月查询 - List> applyMonth = getDisasterReponseByMouth(1,isAdmin); - //统计灾害数量占比 - Map disasterNum = disasterNumProportion(isAdmin); + //List> applyMonth = getDisasterReponseByMouth(1,isAdmin); + //统计灾害数量占比 那个饼图 + List> disasterNum = this.baseMapper.disasterNum(year); + //统计chief + List> chiefMap = this.baseMapper.chiefData(year); + //统计admin + List> adminfMap = this.baseMapper.adminData(year); //统计当年的灾害响应次数 按月查询 - List> responseMonth = getDisasterReponseByMouth(2,isAdmin); + //List> responseMonth = getDisasterReponseByMouth(2,isAdmin); resultMap.put("header",headMap); + //响应量 + resultMap.put("line",initiateAndResponseData); + //下载量 + resultMap.put("vandd",visitAndDownLoadData); + //admin + resultMap.put("admin",adminfMap); + //chief + resultMap.put("chief",chiefMap); + //国家 resultMap.put("country",countryData); + //灾害类型分类 resultMap.put("disasterNum",disasterNum); - resultMap.put("responseMonth",responseMonth); - resultMap.put("applyMonth",applyMonth); return resultMap; } + + +// @Override +// public Map statistics(String year) { +// Map resultMap = Maps.newHashMap(); +// boolean isAdmin = AuthUtil.getTenantId().equals(BladeConstant.ADMIN_TENANT_ID) ? true : false; +// //查询灾害表数据 +// List disasterInfoList = isAdmin ? list():list(Wrappers.lambdaQuery().eq(DisasterInfo::getChiefId,AuthUtil.getUserId())); +// //统计head头部的数据 +// Map headMap = headData(disasterInfoList); +// //统计灾害发生区域占比 +// Map countryData = disasterCountryProportion(disasterInfoList); +// //统计当年的灾害申请次数 按月查询 +// List> applyMonth = getDisasterReponseByMouth(1,isAdmin); +// //统计灾害数量占比 +// Map disasterNum = disasterNumProportion(isAdmin); +// //统计当年的灾害响应次数 按月查询 +// List> responseMonth = getDisasterReponseByMouth(2,isAdmin); +// resultMap.put("header",headMap); +// resultMap.put("country",countryData); +// resultMap.put("disasterNum",disasterNum); +// resultMap.put("responseMonth",responseMonth); +// resultMap.put("applyMonth",applyMonth); +// return resultMap; +// } /** * 统计head头部信息 * @return @@ -273,9 +315,12 @@ public class DisasterInfoServiceImpl extends ServiceImpl disasterCountryProportion(List disasterInfoList){ - Map proportionMap; + Map proportionMap = new LinkedHashMap<>(); //根据国家分组统计次数以及总灾害的占比 - proportionMap = disasterInfoList.stream().filter(data->data.getDisasterCountry()!=null).collect(Collectors.groupingBy(DisasterInfo::getDisasterCountry,Collectors.counting())); + disasterInfoList.stream().filter(data-> + data.getDisasterCountry()!=null + ).collect(Collectors.groupingBy(DisasterInfo::getDisasterCountry,Collectors.counting())) + .entrySet().stream().sorted(Map.Entry.comparingByValue().reversed()).limit(15).forEachOrdered(e -> proportionMap.put(e.getKey(), e.getValue())); return proportionMap; } From a5913eae41de15ff508870091e4941c36f7d7e1b Mon Sep 17 00:00:00 2001 From: whq <460794335@qq.com> Date: Mon, 24 Apr 2023 19:28:36 +0800 Subject: [PATCH 2/7] Twitter --- kn-service/vordm-twitter/Dockerfile | 15 ++++++++++++++ kn-service/vordm-twitter/pom.xml | 20 +++++++++++++++++++ .../crawl/twitter/TwitterApplication.java | 7 +++++++ .../src/main/resources/application-dev.yaml | 0 .../src/main/resources/application-prod.yaml | 0 .../src/main/resources/application.yaml | 12 +++++++++++ 6 files changed, 54 insertions(+) create mode 100644 kn-service/vordm-twitter/Dockerfile create mode 100644 kn-service/vordm-twitter/pom.xml create mode 100644 kn-service/vordm-twitter/src/main/java/com/kening/crawl/twitter/TwitterApplication.java create mode 100644 kn-service/vordm-twitter/src/main/resources/application-dev.yaml create mode 100644 kn-service/vordm-twitter/src/main/resources/application-prod.yaml create mode 100644 kn-service/vordm-twitter/src/main/resources/application.yaml diff --git a/kn-service/vordm-twitter/Dockerfile b/kn-service/vordm-twitter/Dockerfile new file mode 100644 index 0000000..a8eeb9b --- /dev/null +++ b/kn-service/vordm-twitter/Dockerfile @@ -0,0 +1,15 @@ +FROM bladex/alpine-java:openjdk8-openj9_cn_slim + +LABEL maintainer=whq<460794335@qq.com> + +RUN mkdir -p /kn/vordm + +WORKDIR /kn/vordm + +EXPOSE 8989 + +ADD ./target/vordm-crawl.jar ./app.jar + +ENTRYPOINT ["java", "-Djava.security.egd=file:/dev/./urandom", "-jar", "app.jar"] + +CMD ["--spring.profiles.active=test"] diff --git a/kn-service/vordm-twitter/pom.xml b/kn-service/vordm-twitter/pom.xml new file mode 100644 index 0000000..78ba4e5 --- /dev/null +++ b/kn-service/vordm-twitter/pom.xml @@ -0,0 +1,20 @@ + + + + kn-service + com.kening.platform + 1.0.0-SNAPSHOT + + 4.0.0 + + vordm-twitter + + + 8 + 8 + UTF-8 + + + diff --git a/kn-service/vordm-twitter/src/main/java/com/kening/crawl/twitter/TwitterApplication.java b/kn-service/vordm-twitter/src/main/java/com/kening/crawl/twitter/TwitterApplication.java new file mode 100644 index 0000000..9822078 --- /dev/null +++ b/kn-service/vordm-twitter/src/main/java/com/kening/crawl/twitter/TwitterApplication.java @@ -0,0 +1,7 @@ +package com.kening.platform; + +public class Main { + public static void main(String[] args) { + System.out.println("Hello world!"); + } +} diff --git a/kn-service/vordm-twitter/src/main/resources/application-dev.yaml b/kn-service/vordm-twitter/src/main/resources/application-dev.yaml new file mode 100644 index 0000000..e69de29 diff --git a/kn-service/vordm-twitter/src/main/resources/application-prod.yaml b/kn-service/vordm-twitter/src/main/resources/application-prod.yaml new file mode 100644 index 0000000..e69de29 diff --git a/kn-service/vordm-twitter/src/main/resources/application.yaml b/kn-service/vordm-twitter/src/main/resources/application.yaml new file mode 100644 index 0000000..68512b0 --- /dev/null +++ b/kn-service/vordm-twitter/src/main/resources/application.yaml @@ -0,0 +1,12 @@ +server: + port: 8989 + +spring: + cloud: + gateway: + discovery: + locator: + enabled: true + loadbalancer: + retry: + enabled: true From 05fe6dd72faf9002ca16738fbb622ee02137d92f Mon Sep 17 00:00:00 2001 From: whq <460794335@qq.com> Date: Mon, 24 Apr 2023 19:28:56 +0800 Subject: [PATCH 3/7] Twitter --- kn-service/pom.xml | 1 + kn-service/vordm-twitter/Dockerfile | 2 +- kn-service/vordm-twitter/pom.xml | 54 +++++++++++++++++++ .../crawl/twitter/TwitterApplication.java | 12 +++-- .../src/main/resources/application-dev.yaml | 7 +++ .../src/main/resources/application.yaml | 2 +- 6 files changed, 73 insertions(+), 5 deletions(-) diff --git a/kn-service/pom.xml b/kn-service/pom.xml index e1b2c42..8406685 100644 --- a/kn-service/pom.xml +++ b/kn-service/pom.xml @@ -6,6 +6,7 @@ biz-vordm vordm-crawl + vordm-twitter diff --git a/kn-service/vordm-twitter/Dockerfile b/kn-service/vordm-twitter/Dockerfile index a8eeb9b..7fb149c 100644 --- a/kn-service/vordm-twitter/Dockerfile +++ b/kn-service/vordm-twitter/Dockerfile @@ -6,7 +6,7 @@ RUN mkdir -p /kn/vordm WORKDIR /kn/vordm -EXPOSE 8989 +EXPOSE 8987 ADD ./target/vordm-crawl.jar ./app.jar diff --git a/kn-service/vordm-twitter/pom.xml b/kn-service/vordm-twitter/pom.xml index 78ba4e5..9dbfdb2 100644 --- a/kn-service/vordm-twitter/pom.xml +++ b/kn-service/vordm-twitter/pom.xml @@ -17,4 +17,58 @@ UTF-8 + + + com.kening.platform + kn-launcher + + + org.springframework.boot + spring-boot-starter-web + + + org.springframework.boot + spring-boot-starter-undertow + + + wildfly-common + org.wildfly.common + + + + + com.itmuch + spring-cloud-wii + 2.2.6.RELEASE + + + de.codecentric + spring-boot-admin-starter-client + + + + org.springframework.cloud + spring-cloud-starter-netflix-hystrix + + + commons-logging + commons-logging + + + HdrHistogram + org.hdrhistogram + + + + + + com.alibaba.cloud + spring-cloud-starter-alibaba-nacos-discovery + + + com.alibaba.cloud + spring-cloud-starter-alibaba-nacos-config + + + diff --git a/kn-service/vordm-twitter/src/main/java/com/kening/crawl/twitter/TwitterApplication.java b/kn-service/vordm-twitter/src/main/java/com/kening/crawl/twitter/TwitterApplication.java index 9822078..a86ca1c 100644 --- a/kn-service/vordm-twitter/src/main/java/com/kening/crawl/twitter/TwitterApplication.java +++ b/kn-service/vordm-twitter/src/main/java/com/kening/crawl/twitter/TwitterApplication.java @@ -1,7 +1,13 @@ -package com.kening.platform; +package com.kening.crawl.twitter; -public class Main { +import org.springblade.core.launch.BladeApplication; +import org.springframework.cloud.client.SpringCloudApplication; +import org.springframework.context.annotation.ComponentScan; + +@SpringCloudApplication +@ComponentScan({"org.springblade", "com.kening.crawl.twitter"}) +public class TwitterApplication { public static void main(String[] args) { - System.out.println("Hello world!"); + BladeApplication.run("vordm-twitter", TwitterApplication.class, args); } } diff --git a/kn-service/vordm-twitter/src/main/resources/application-dev.yaml b/kn-service/vordm-twitter/src/main/resources/application-dev.yaml index e69de29..93c68f9 100644 --- a/kn-service/vordm-twitter/src/main/resources/application-dev.yaml +++ b/kn-service/vordm-twitter/src/main/resources/application-dev.yaml @@ -0,0 +1,7 @@ +wii: + # 异构微服务的IP + ip: 78.46.158.237 + # 异构微服务的端口 + port: 7000 + # 异构微服务的健康检查URL + #health-check-route: /health diff --git a/kn-service/vordm-twitter/src/main/resources/application.yaml b/kn-service/vordm-twitter/src/main/resources/application.yaml index 68512b0..bd57f03 100644 --- a/kn-service/vordm-twitter/src/main/resources/application.yaml +++ b/kn-service/vordm-twitter/src/main/resources/application.yaml @@ -1,5 +1,5 @@ server: - port: 8989 + port: 8980 spring: cloud: From 890c26bfb5c959c18204aa024620575fda843339 Mon Sep 17 00:00:00 2001 From: whq <460794335@qq.com> Date: Mon, 24 Apr 2023 19:55:20 +0800 Subject: [PATCH 4/7] Twitter --- kn-service/vordm-twitter/Dockerfile | 2 +- .../vordm-twitter/src/main/resources/application-dev.yaml | 7 ------- 2 files changed, 1 insertion(+), 8 deletions(-) diff --git a/kn-service/vordm-twitter/Dockerfile b/kn-service/vordm-twitter/Dockerfile index 7fb149c..457912a 100644 --- a/kn-service/vordm-twitter/Dockerfile +++ b/kn-service/vordm-twitter/Dockerfile @@ -6,7 +6,7 @@ RUN mkdir -p /kn/vordm WORKDIR /kn/vordm -EXPOSE 8987 +EXPOSE 8980 ADD ./target/vordm-crawl.jar ./app.jar diff --git a/kn-service/vordm-twitter/src/main/resources/application-dev.yaml b/kn-service/vordm-twitter/src/main/resources/application-dev.yaml index 93c68f9..e69de29 100644 --- a/kn-service/vordm-twitter/src/main/resources/application-dev.yaml +++ b/kn-service/vordm-twitter/src/main/resources/application-dev.yaml @@ -1,7 +0,0 @@ -wii: - # 异构微服务的IP - ip: 78.46.158.237 - # 异构微服务的端口 - port: 7000 - # 异构微服务的健康检查URL - #health-check-route: /health From 54ea3a9431f8b5a7c5ef680dd68cc2e0f75826b5 Mon Sep 17 00:00:00 2001 From: whq <460794335@qq.com> Date: Mon, 24 Apr 2023 19:58:10 +0800 Subject: [PATCH 5/7] Twitter --- kn-service/vordm-twitter/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kn-service/vordm-twitter/pom.xml b/kn-service/vordm-twitter/pom.xml index 9dbfdb2..01ce55a 100644 --- a/kn-service/vordm-twitter/pom.xml +++ b/kn-service/vordm-twitter/pom.xml @@ -5,7 +5,7 @@ kn-service com.kening.platform - 1.0.0-SNAPSHOT + ${revision} 4.0.0 From 9648ec944b8662ad2885706ac2f40f65bb5e2698 Mon Sep 17 00:00:00 2001 From: whq <460794335@qq.com> Date: Mon, 24 Apr 2023 19:59:47 +0800 Subject: [PATCH 6/7] Twitter --- kn-service/vordm-twitter/Dockerfile | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kn-service/vordm-twitter/Dockerfile b/kn-service/vordm-twitter/Dockerfile index 457912a..d2ba668 100644 --- a/kn-service/vordm-twitter/Dockerfile +++ b/kn-service/vordm-twitter/Dockerfile @@ -8,7 +8,7 @@ WORKDIR /kn/vordm EXPOSE 8980 -ADD ./target/vordm-crawl.jar ./app.jar +ADD ./target/vordm-twitter.jar ./app.jar ENTRYPOINT ["java", "-Djava.security.egd=file:/dev/./urandom", "-jar", "app.jar"] From 472d54963b9b4bdc66c323816cc494efe31aa8f1 Mon Sep 17 00:00:00 2001 From: whq <460794335@qq.com> Date: Mon, 24 Apr 2023 20:16:50 +0800 Subject: [PATCH 7/7] =?UTF-8?q?whq=EF=BC=9A=20=E8=BF=98=E5=8E=9F=E6=9C=8D?= =?UTF-8?q?=E5=8A=A1=E5=90=8D=E7=A7=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/kening/vordm/VoRdmApplication.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/kn-service/biz-vordm/src/main/java/com/kening/vordm/VoRdmApplication.java b/kn-service/biz-vordm/src/main/java/com/kening/vordm/VoRdmApplication.java index 3761a4f..cd32db5 100644 --- a/kn-service/biz-vordm/src/main/java/com/kening/vordm/VoRdmApplication.java +++ b/kn-service/biz-vordm/src/main/java/com/kening/vordm/VoRdmApplication.java @@ -11,6 +11,6 @@ import org.springframework.cloud.client.SpringCloudApplication; @SpringCloudApplication public class VoRdmApplication { public static void main(String[] args) { - BladeApplication.run("gljNew-"+CommonConstant.KN_VORDM_MODULE_NAME, VoRdmApplication.class, args); + BladeApplication.run(CommonConstant.KN_VORDM_MODULE_NAME, VoRdmApplication.class, args); } }