zkr/shz-dataDashboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

添加功能

Browse Source
This commit is contained in:
马宝龙
2026-06-26 20:59:07 +08:00
parent 6b575480ce
commit fd834d3647
9 changed files with 619 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

86
ruoyi-bussiness/src/main/java/com/ruoyi/cms/service/AnalysisJobDemandTreadService.java Normal file
View File

@@ -0,0 +1,86 @@
package com.ruoyi.cms.service;
import com.ruoyi.cms.domain.dto.QueryParamDto;
import com.ruoyi.cms.domain.vo.DictVo;
import com.ruoyi.cms.domain.vo.EchartsVo;
import com.ruoyi.cms.domain.vo.JobDemandTreadDemandVo;
import com.ruoyi.cms.domain.vo.JobDemandTreadEconomyCorrelationVo;
import com.ruoyi.cms.domain.vo.JobDemandTreadGDPCorrelationVo;
import com.ruoyi.cms.domain.vo.JobDemandTreadOverviewVo;
import com.ruoyi.cms.domain.vo.QueryResultVo;
import com.ruoyi.cms.domain.vo.SkillKeywordVo;
import java.util.List;
/**
* 岗位需求趋势变化分析
*
* @author 马宝龙
* @date 2026/6/26
*/
public interface AnalysisJobDemandTreadService {
/**
* 数据总览
*
* @param dto 查询参数
* @return 数据总览
*/
JobDemandTreadOverviewVo overview(QueryParamDto dto);
/**
* 宏观经济与岗位需求关联
*
* @param dto 查询参数
* @return 结果列表
*/
List<JobDemandTreadEconomyCorrelationVo> economyAndJobDemandCorrelation(QueryParamDto dto);
/**
* 热门岗位Top10排名
*
* @param dto 查询参数
* @return 结果列表
*/
List<QueryResultVo> hotJobRank(QueryParamDto dto);
/**
* GDP与岗位需求相关性分析
*
* @param dto 查询参数
* @return 结果列表
*/
List<JobDemandTreadGDPCorrelationVo> gdpAndJobDemandCorrelation(QueryParamDto dto);
/**
* 岗位类型占比变化趋势
*
* @param dto 查询参数
* @return 趋势数据
*/
EchartsVo jobTypePercentageTread(QueryParamDto dto);
/**
* 岗位需求总量
*
* @param dto 查询参数
* @return 趋势数据
*/
List<JobDemandTreadDemandVo> jobDemandCountTread(QueryParamDto dto);
/**
* 查询职业列表
*
* @return 职业列表
*/
List<DictVo> occupationList();
/**
* 技能关键词
*
* @param dto 查询参数
* @return 结果列表
*/
List<SkillKeywordVo> skillKeyword(QueryParamDto dto);
}

200
ruoyi-bussiness/src/main/java/com/ruoyi/cms/service/impl/AnalysisJobDemandTreadServiceImpl.java Normal file
View File

@@ -0,0 +1,200 @@
package com.ruoyi.cms.service.impl;
import com.ruoyi.cms.domain.dto.QueryParamDto;
import com.ruoyi.cms.domain.vo.DictVo;
import com.ruoyi.cms.domain.vo.EchartsSeriesVo;
import com.ruoyi.cms.domain.vo.EchartsVo;
import com.ruoyi.cms.domain.vo.JobDemandTreadDemandVo;
import com.ruoyi.cms.domain.vo.JobDemandTreadEconomyCorrelationVo;
import com.ruoyi.cms.domain.vo.JobDemandTreadGDPCorrelationVo;
import com.ruoyi.cms.domain.vo.JobDemandTreadOverviewVo;
import com.ruoyi.cms.domain.vo.QueryResultVo;
import com.ruoyi.cms.domain.vo.SkillKeywordVo;
import com.ruoyi.cms.service.AnalysisJobDemandTreadService;
import com.ruoyi.cms.util.MathUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.validation.annotation.Validated;
import reactor.util.function.Tuple2;
import reactor.util.function.Tuples;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.IntStream;
/**
* 岗位需求趋势变化分析
*
* @author 马宝龙
* @date 2026/6/26
*/
@Service
@Validated
@Slf4j
public class AnalysisJobDemandTreadServiceImpl implements AnalysisJobDemandTreadService {
@Override
public JobDemandTreadOverviewVo overview(QueryParamDto dto) {
return JobDemandTreadOverviewVo.builder()
.jobDemandCount(85000L)
.jobDemandCountMom(BigDecimal.valueOf(6.2))
.demandSupplyRate(BigDecimal.valueOf(1.35))
.demandSupplyRateMom(BigDecimal.valueOf(0.05))
.technicalJobPercentage(BigDecimal.valueOf(42.5))
.technicalJobPercentageMom(BigDecimal.valueOf(2.3))
.hardSkillDemandCount(32000L)
.hardSkillDemandCountMom(BigDecimal.valueOf(8.1))
.build();
}
@Override
public List<JobDemandTreadEconomyCorrelationVo> economyAndJobDemandCorrelation(QueryParamDto dto) {
List<JobDemandTreadEconomyCorrelationVo> list = new ArrayList<>();
for (int i = 0; i < 12; i++) {
list.add(JobDemandTreadEconomyCorrelationVo.builder()
.code(i + 1 + "")
.desc(i + 1 + "月")
.gdpGrowthRate(BigDecimal.valueOf(Math.random() * 5 + 2).setScale(1, RoundingMode.HALF_UP))
.cpiYoyRate(BigDecimal.valueOf(Math.random() * 3 + 1).setScale(1, RoundingMode.HALF_UP))
.pmiIndex(BigDecimal.valueOf(Math.random() * 10 + 45).setScale(1, RoundingMode.HALF_UP))
.jobDemandCount((long) Math.floor(Math.random() * 20000) + 5000)
.build());
}
return list;
}
@Override
public List<QueryResultVo> hotJobRank(QueryParamDto dto) {
List<QueryResultVo> list = new ArrayList<>();
List<Tuple2<String, String>> jobList =
Collections.unmodifiableList(new ArrayList<>(Arrays.asList(
Tuples.of("1", "软件工程师"),
Tuples.of("2", "数据分析师"),
Tuples.of("3", "销售经理"),
Tuples.of("4", "机械工程师"),
Tuples.of("5", "电气工程师"),
Tuples.of("6", "财务会计"),
Tuples.of("7", "市场营销"),
Tuples.of("8", "人力资源"),
Tuples.of("9", "客服专员"),
Tuples.of("10", "物流管理")
)));
for (Tuple2<String, String> job : jobList) {
list.add(QueryResultVo.builder()
.code(job.getT1())
.desc(job.getT2())
.count((long) Math.floor(Math.random() * 100000) + 1)
.build());
}
return list;
}
@Override
public List<JobDemandTreadGDPCorrelationVo> gdpAndJobDemandCorrelation(QueryParamDto dto) {
List<JobDemandTreadGDPCorrelationVo> list = new ArrayList<>();
for (int i = 0; i < 12; i++) {
list.add(JobDemandTreadGDPCorrelationVo.builder()
.gdpIndex(BigDecimal.valueOf(Math.random() * 5 + 1).setScale(1, RoundingMode.HALF_UP))
.jobDemandCount((long) Math.floor(Math.random() * 20000) + 5000)
.build());
}
return list;
}
@Override
public EchartsVo jobTypePercentageTread(QueryParamDto dto) {
List<String> xAxis = IntStream.rangeClosed(1, 12)
.mapToObj(i -> i + "月")
.collect(Collectors.toList());
List<Tuple2<String, String>> typeList =
Collections.unmodifiableList(new ArrayList<>(Arrays.asList(
Tuples.of("1", "技术类"),
Tuples.of("2", "管理类"),
Tuples.of("3", "操作类"),
Tuples.of("4", "其他")
)));
List<EchartsSeriesVo> series = new ArrayList<>();
for (Tuple2<String, String> type : typeList) {
List<Long> dataList = new ArrayList<>();
for (int i = 0; i < 12; i++) {
dataList.add((long) Math.floor(Math.random() * 40) + 10);
}
series.add(EchartsSeriesVo.builder().name(type.getT2()).data(dataList).build());
}
return EchartsVo.builder().xAxis(xAxis).series(series).build();
}
@Override
public List<JobDemandTreadDemandVo> jobDemandCountTread(QueryParamDto dto) {
List<JobDemandTreadDemandVo> list = new ArrayList<>();
for (int i = 0; i < 12; i++) {
long demand = (long) Math.floor(Math.random() * 20000) + 5000;
long supply = (long) Math.floor(Math.random() * 15000) + 3000;
BigDecimal rate = MathUtil.calculatePercentage(demand, supply);
list.add(JobDemandTreadDemandVo.builder()
.code(i + 1 + "")
.desc(i + 1 + "月")
.jobDemandCount(demand)
.lobarSupplyCount(supply)
.demandSupplyRate(rate)
.demandSupplyRateMom(BigDecimal.valueOf(Math.random() * 0.3 - 0.15).setScale(2,
RoundingMode.HALF_UP))
.build());
}
return list;
}
@Override
public List<DictVo> occupationList() {
List<DictVo> list = new ArrayList<>();
List<Tuple2<String, String>> occupationList =
Collections.unmodifiableList(new ArrayList<>(Arrays.asList(
Tuples.of("1", "软件开发"),
Tuples.of("2", "数据分析"),
Tuples.of("3", "机械制造"),
Tuples.of("4", "电气工程"),
Tuples.of("5", "财务会计"),
Tuples.of("6", "市场营销"),
Tuples.of("7", "行政管理"),
Tuples.of("8", "物流配送")
)));
for (Tuple2<String, String> occupation : occupationList) {
list.add(DictVo.builder().code(occupation.getT1()).desc(occupation.getT2()).build());
}
return list;
}
@Override
public List<SkillKeywordVo> skillKeyword(QueryParamDto dto) {
List<SkillKeywordVo> list = new ArrayList<>();
List<Tuple2<String, String>> keywordList =
Collections.unmodifiableList(new ArrayList<>(Arrays.asList(
Tuples.of("Python", "硬技能"),
Tuples.of("Java", "硬技能"),
Tuples.of("数据分析", "硬技能"),
Tuples.of("项目管理", "软技能"),
Tuples.of("团队协作", "软技能"),
Tuples.of("机器学习", "硬技能"),
Tuples.of("沟通能力", "软技能"),
Tuples.of("SQL", "硬技能"),
Tuples.of("智能制造", "硬技能"),
Tuples.of("英语", "硬技能")
)));
for (Tuple2<String, String> keyword : keywordList) {
list.add(SkillKeywordVo.builder()
.keyword(keyword.getT1())
.type(keyword.getT2())
.count((long) Math.floor(Math.random() * 2000) + 1)
.build());
}
return list;
}
}