@ -12,6 +12,7 @@ import com.zdxt.enforcementcode.mapper.*;
import com.zdxt.enforcementcode.service.ICimDashboardOverviewDataSumService ;
import com.zdxt.enforcementcode.service.ICimDashboardOverviewDataSumService ;
import lombok.RequiredArgsConstructor ;
import lombok.RequiredArgsConstructor ;
import lombok.extern.slf4j.Slf4j ;
import lombok.extern.slf4j.Slf4j ;
import org.dromara.common.core.utils.StringUtils ;
import org.springframework.stereotype.Service ;
import org.springframework.stereotype.Service ;
import org.springframework.transaction.annotation.Transactional ;
import org.springframework.transaction.annotation.Transactional ;
@ -102,17 +103,96 @@ public class CimDashboardOverviewDataSumSserviceImpl implements ICimDashboardOve
/ * vo . setQyzs ( 0L ) ;
/ * vo . setQyzs ( 0L ) ;
vo . setQyzshb ( 0L ) ;
vo . setQyzshb ( 0L ) ;
vo . setQyzstb ( 0L ) ; * /
vo . setQyzstb ( 0L ) ; * /
/ * *
* 暂存需要确认数据来源
//执法人员数:未传区域编码时查询结果是各区明细,需要汇总求和
* 暂时未取数 - 执法人员数 , 执法单位数 ( 月 )
long zfrysSum = 0L ;
*
List < CimDashboardOverviewVo > lawPersonnelList = cimDashboardOverviewMapper . getLawPersonnelCount ( bo ) ;
* 暂时未取数 - 区域 - 企业数量 - 执法单位数 - 执法人员数 ( 月 )
if ( lawPersonnelList ! = null ) {
* /
for ( CimDashboardOverviewVo item : lawPersonnelList ) {
if ( item . getZfrys ( ) ! = null ) {
zfrysSum + = item . getZfrys ( ) ;
}
}
}
vo . setZfrys ( zfrysSum ) ;
//执法单位数:未传区域编码时查询结果是各区明细,需要汇总求和
long zfdwsSum = 0L ;
List < CimDashboardOverviewVo > lawUnitList = cimDashboardOverviewMapper . getLawUnitCount ( bo ) ;
if ( lawUnitList ! = null ) {
for ( CimDashboardOverviewVo item : lawUnitList ) {
if ( item . getZfdws ( ) ! = null ) {
zfdwsSum + = item . getZfdws ( ) ;
}
}
}
vo . setZfdws ( zfdwsSum ) ;
//添加月度数据
//添加月度数据
Boolean flag = insertNewData ( vo ) ;
Boolean flag = insertNewData ( vo ) ;
return flag ;
return flag ;
}
}
/ * *
* Cim大屏 - 按区域统计 - 企业数量 - 执法人员数 - 执法单位数
* 定时任务调用方法
* @return
* /
@Override
public Boolean getAreaMonthDataSum ( ) {
CimDashboardOverviewQueryBo bo = getDateTime ( ) ;
bo . setMonthTime ( getDateTime ( ) . getMonthTime ( ) ) ;
List < CimDashboardOverviewVo > list = cimDashboardOverviewMapper . getLawPersonnelCount ( bo ) ;
List < CimDashboardOverviewVo > list1 = cimDashboardOverviewMapper . getLawUnitCount ( bo ) ;
// 1. 高频检查区域:VO(code/name/number) → 实体(areaCode/areaName/gpjcqy)
List < DashboardOverviewPersonnel > areaPersonnelList = new ArrayList < > ( ) ;
if ( list ! = null ) {
for ( CimDashboardOverviewVo vo : list ) {
DashboardOverviewPersonnel entity = new DashboardOverviewPersonnel ( ) ;
entity . setCityCode ( "440300" ) ;
entity . setCityName ( "深圳市" ) ;
entity . setDistrictCode ( vo . getCode ( ) ) ;
entity . setDistrictName ( vo . getName ( ) ) ;
entity . setZfrys ( vo . getZfrys ( ) ) ;
entity . setLevel ( 2L ) ;
entity . setYear ( getDateTime ( ) . getYear ( ) ) ;
entity . setMonth ( getDateTime ( ) . getMonth ( ) ) ;
entity . setIsDelete ( "0" ) ;
areaPersonnelList . add ( entity ) ;
}
}
// 2. 高频检查区域执法单位联合执法数:VO(bueauDeptId/bureauDeptName/number) → 实体(bureauDeptId/bureauDeptName/lhzfcs)
List < DashboardOverviewUnit > areaUnionList = new ArrayList < > ( ) ;
if ( list1 ! = null ) {
for ( CimDashboardOverviewVo vo : list1 ) {
DashboardOverviewUnit entity = new DashboardOverviewUnit ( ) ;
entity . setCityCode ( "440300" ) ;
entity . setCityName ( "深圳市" ) ;
entity . setDistrictCode ( vo . getCode ( ) ) ;
entity . setDistrictName ( vo . getName ( ) ) ;
entity . setZfdws ( vo . getZfdws ( ) ) ;
entity . setLevel ( 2L ) ;
entity . setYear ( getDateTime ( ) . getYear ( ) ) ;
entity . setMonth ( getDateTime ( ) . getMonth ( ) ) ;
entity . setIsDelete ( "0" ) ;
areaUnionList . add ( entity ) ;
}
}
//新增数据到数据汇总表
if ( ! areaPersonnelList . isEmpty ( ) ) {
dashboardOverviewPersonnelMapper . insertBatch ( areaPersonnelList ) ;
}
if ( ! areaUnionList . isEmpty ( ) ) {
dashboardOverviewUnitMapper . insertBatch ( areaUnionList ) ;
}
return true ;
}
/ * *
/ * *
* Cim - 大屏总览
* Cim - 大屏总览
* 获取月度数据
* 获取月度数据
@ -120,15 +200,48 @@ public class CimDashboardOverviewDataSumSserviceImpl implements ICimDashboardOve
* @return
* @return
* /
* /
@Override
@Override
public List < CimDashboardOverviewVo > getDashboardOverviewMonthDataSum ( ) {
public Map < String , Object > getDashboardOverviewMonthDataSum ( CimDashboardOverviewQueryBo bo ) {
Map < String , Object > map = new HashMap < > ( ) ;
LambdaQueryWrapper < DashboardOverview > queryWrapper = new LambdaQueryWrapper < > ( ) ;
LambdaQueryWrapper < DashboardOverview > queryWrapper = new LambdaQueryWrapper < > ( ) ;
queryWrapper . eq ( DashboardOverview : : getIsDelete , "0" ) ;
queryWrapper . eq ( DashboardOverview : : getIsDelete , "0" ) ;
queryWrapper . eq ( DashboardOverview : : getYear , getDateTime ( ) . getYear ( ) ) ;
queryWrapper . eq ( DashboardOverview : : getYear , getDateTime ( ) . getYear ( ) ) ;
queryWrapper . eq ( DashboardOverview : : getMonth , getDateTime ( ) . getMonth ( ) ) ;
queryWrapper . eq ( DashboardOverview : : getMonth , getDateTime ( ) . getMonth ( ) ) ;
return cimDashboardOverviewMapper . selectVoList ( queryWrapper ) ;
map . put ( "monthData" , cimDashboardOverviewMapper . selectVoList ( queryWrapper ) ) ;
map . put ( "areaMonthData" , getDashboardOverviewAreaMonthDataSum ( bo ) ) ;
return map ;
}
}
/ * *
* Cim大屏 - 按区域条件查询月度数据
* /
@Override
public CimDashboardOverviewVo getDashboardOverviewAreaMonthDataSum ( CimDashboardOverviewQueryBo bo ) {
CimDashboardOverviewVo vo = new CimDashboardOverviewVo ( ) ;
// 区域计划总数
bo . setMonthTime ( getDateTime ( ) . getMonthTime ( ) ) ;
Long jhzs = cimDashboardOverviewMapper . getPlanCount ( bo ) ;
vo . setJhzs ( jhzs ) ;
//区域预告总数
Long ygzs = cimDashboardOverviewMapper . getNoticeCount ( bo ) ;
vo . setYgzs ( ygzs ) ;
//涉企执法总数
Long sqzfzs = cimDashboardOverviewMapper . getEnfLawCount ( bo ) ;
vo . setSqzfzs ( sqzfzs ) ;
//稽查反馈总数
Long jcfkzs = cimDashboardOverviewMapper . getLawEvaluateCount ( bo ) ;
vo . setJcpjzs ( jcfkzs ) ;
//检查投诉总数
Long jctszs = cimDashboardOverviewMapper . getComplaintCount ( bo ) ;
vo . setJctszs ( jctszs ) ;
//平均检查频次
Long bzfqy = cimDashboardOverviewMapper . getSubLawEntCount ( bo ) ;
Long xzzf = cimDashboardOverviewMapper . getEnfRegistrationCount ( bo ) ;
if ( bzfqy ! = 0 ) {
vo . setPjjcpc ( xzzf / bzfqy ) ;
}
return vo ;
}
/ * *
/ * *
* Cim大屏 - 大屏总览企业数量 - 执法单位数 - 执法人员数
* Cim大屏 - 大屏总览企业数量 - 执法单位数 - 执法人员数
@ -201,8 +314,10 @@ public class CimDashboardOverviewDataSumSserviceImpl implements ICimDashboardOve
add . setJctszs ( vo . getJctszs ( ) ) ;
add . setJctszs ( vo . getJctszs ( ) ) ;
add . setPjjcpc ( vo . getPjjcpc ( ) ) ;
add . setPjjcpc ( vo . getPjjcpc ( ) ) ;
add . setQyzs ( vo . getQyzs ( ) ) ;
add . setQyzs ( vo . getQyzs ( ) ) ;
add . setQyzshb ( vo . getQyzshb ( ) ) ;
/ * add . setQyzshb ( vo . getQyzshb ( ) ) ;
add . setQyzstb ( vo . getQyzstb ( ) ) ;
add . setQyzstb ( vo . getQyzstb ( ) ) ; * /
add . setZfrys ( vo . getZfrys ( ) ) ;
add . setZfdws ( vo . getZfdws ( ) ) ;
// 年份、月份
// 年份、月份
add . setYear ( cal . get ( Calendar . YEAR ) ) ;
add . setYear ( cal . get ( Calendar . YEAR ) ) ;
add . setMonth ( cal . get ( Calendar . MONTH ) + 1 ) ;
add . setMonth ( cal . get ( Calendar . MONTH ) + 1 ) ;
@ -258,7 +373,7 @@ public class CimDashboardOverviewDataSumSserviceImpl implements ICimDashboardOve
entity . setCityName ( "深圳市" ) ;
entity . setCityName ( "深圳市" ) ;
entity . setBureauDeptId ( vo . getBueauDeptId ( ) ) ;
entity . setBureauDeptId ( vo . getBueauDeptId ( ) ) ;
entity . setBureauDeptName ( vo . getBureauDeptName ( ) ) ;
entity . setBureauDeptName ( vo . getBureauDeptName ( ) ) ;
entity . setLhzfcs ( vo . getNumber ( ) ) ;
entity . setLhzfcs ( vo . getLhzfcs ( ) ) ;
entity . setLevel ( 2L ) ;
entity . setLevel ( 2L ) ;
entity . setYear ( getDateTime ( ) . getYear ( ) ) ;
entity . setYear ( getDateTime ( ) . getYear ( ) ) ;
entity . setMonth ( getDateTime ( ) . getMonth ( ) ) ;
entity . setMonth ( getDateTime ( ) . getMonth ( ) ) ;
@ -276,7 +391,7 @@ public class CimDashboardOverviewDataSumSserviceImpl implements ICimDashboardOve
entity . setCityName ( "深圳市" ) ;
entity . setCityName ( "深圳市" ) ;
entity . setBureauDeptId ( vo . getBueauDeptId ( ) ) ;
entity . setBureauDeptId ( vo . getBueauDeptId ( ) ) ;
entity . setBureauDeptName ( vo . getBureauDeptName ( ) ) ;
entity . setBureauDeptName ( vo . getBureauDeptName ( ) ) ;
entity . setJccs ( vo . getNumber ( ) ) ;
entity . setJccs ( vo . getJccs ( ) ) ;
entity . setLevel ( 2L ) ;
entity . setLevel ( 2L ) ;
entity . setYear ( getDateTime ( ) . getYear ( ) ) ;
entity . setYear ( getDateTime ( ) . getYear ( ) ) ;
entity . setMonth ( getDateTime ( ) . getMonth ( ) ) ;
entity . setMonth ( getDateTime ( ) . getMonth ( ) ) ;
@ -323,34 +438,39 @@ public class CimDashboardOverviewDataSumSserviceImpl implements ICimDashboardOve
* @return
* @return
* /
* /
@Override
@Override
public Map < String , Object > getHighCheckAreaMonthDataSumMap ( ) {
public Map < String , Object > getHighCheckAreaMonthDataSumMap ( CimDashboardOverviewQueryBo bo ) {
LambdaQueryWrapper < DashboardHighCheckArea > queryWrapper = new LambdaQueryWrapper < > ( ) ;
LambdaQueryWrapper < DashboardHighCheckArea > queryWrapper = new LambdaQueryWrapper < > ( ) ;
queryWrapper . eq ( DashboardHighCheckArea : : getLevel , 2 ) ;
queryWrapper . eq ( DashboardHighCheckArea : : getLevel , 2 ) ;
queryWrapper . eq ( DashboardHighCheckArea : : getIsDelete , "0" ) ;
queryWrapper . eq ( DashboardHighCheckArea : : getIsDelete , "0" ) ;
queryWrapper . eq ( DashboardHighCheckArea : : getYear , getDateTime ( ) . getYear ( ) ) ;
queryWrapper . eq ( DashboardHighCheckArea : : getYear , getDateTime ( ) . getYear ( ) ) ;
queryWrapper . eq ( DashboardHighCheckArea : : getMonth , getDateTime ( ) . getMonth ( ) ) ;
queryWrapper . eq ( DashboardHighCheckArea : : getMonth , getDateTime ( ) . getMonth ( ) ) ;
queryWrapper . eq ( StringUtils . isNotBlank ( bo . getCode ( ) ) , DashboardHighCheckArea : : getAreaCode , bo . getCode ( ) ) ;
List < DashboardHighCheckArea > areaList = dashboardHighCheckAreaMapper . selectList ( queryWrapper ) ;
List < DashboardHighCheckArea > areaList = dashboardHighCheckAreaMapper . selectList ( queryWrapper ) ;
LambdaQueryWrapper < DashboardHighCheckUnionArea > queryWrapper1 = new LambdaQueryWrapper < > ( ) ;
/ * LambdaQueryWrapper < DashboardHighCheckUnionArea > queryWrapper1 = new LambdaQueryWrapper < > ( ) ;
queryWrapper1 . eq ( DashboardHighCheckUnionArea : : getLevel , 2 ) ;
queryWrapper1 . eq ( DashboardHighCheckUnionArea : : getLevel , 2 ) ;
queryWrapper1 . eq ( DashboardHighCheckUnionArea : : getIsDelete , "0" ) ;
queryWrapper1 . eq ( DashboardHighCheckUnionArea : : getIsDelete , "0" ) ;
queryWrapper1 . eq ( DashboardHighCheckUnionArea : : getYear , getDateTime ( ) . getYear ( ) ) ;
queryWrapper1 . eq ( DashboardHighCheckUnionArea : : getYear , getDateTime ( ) . getYear ( ) ) ;
queryWrapper1 . eq ( DashboardHighCheckUnionArea : : getMonth , getDateTime ( ) . getMonth ( ) ) ;
queryWrapper1 . eq ( DashboardHighCheckUnionArea : : getMonth , getDateTime ( ) . getMonth ( ) ) ;
List < DashboardHighCheckUnionArea > unionList = dashboardhighcheckunionMapper . selectList ( queryWrapper1 ) ;
List < DashboardHighCheckUnionArea > unionList = dashboardhighcheckunionMapper . selectList ( queryWrapper1 ) ; * /
bo . setMonthTime ( getDateTime ( ) . getMonthTime ( ) ) ;
List < CimDashboardOverviewVo > unionList = cimDashboardOverviewMapper . getHighCheckAreaUnionNoRanking ( bo ) ;
LambdaQueryWrapper < DashboardHighCheckFrequencyArea > queryWrapper2 = new LambdaQueryWrapper < > ( ) ;
/ * LambdaQueryWrapper < DashboardHighCheckFrequencyArea > queryWrapper2 = new LambdaQueryWrapper < > ( ) ;
queryWrapper2 . eq ( DashboardHighCheckFrequencyArea : : getLevel , 2 ) ;
queryWrapper2 . eq ( DashboardHighCheckFrequencyArea : : getLevel , 2 ) ;
queryWrapper2 . eq ( DashboardHighCheckFrequencyArea : : getIsDelete , "0" ) ;
queryWrapper2 . eq ( DashboardHighCheckFrequencyArea : : getIsDelete , "0" ) ;
queryWrapper2 . eq ( DashboardHighCheckFrequencyArea : : getYear , getDateTime ( ) . getYear ( ) ) ;
queryWrapper2 . eq ( DashboardHighCheckFrequencyArea : : getYear , getDateTime ( ) . getYear ( ) ) ;
queryWrapper2 . eq ( DashboardHighCheckFrequencyArea : : getMonth , getDateTime ( ) . getMonth ( ) ) ;
queryWrapper2 . eq ( DashboardHighCheckFrequencyArea : : getMonth , getDateTime ( ) . getMonth ( ) ) ;
List < DashboardHighCheckFrequencyArea > freqList = dashboardHighCheckFrequencyAreaMapper . selectList ( queryWrapper2 ) ;
List < DashboardHighCheckFrequencyArea > freqList = dashboardHighCheckFrequencyAreaMapper . selectList ( queryWrapper2 ) ; * /
List < CimDashboardOverviewVo > freqList = cimDashboardOverviewMapper . getHighCheckAreaenfRegistraionRanking ( bo ) ;
LambdaQueryWrapper < DashboardHighCheckEnterprise > queryWrapper3 = new LambdaQueryWrapper < > ( ) ;
LambdaQueryWrapper < DashboardHighCheckEnterprise > queryWrapper3 = new LambdaQueryWrapper < > ( ) ;
queryWrapper3 . eq ( DashboardHighCheckEnterprise : : getLevel , 2 ) ;
queryWrapper3 . eq ( DashboardHighCheckEnterprise : : getLevel , 2 ) ;
queryWrapper3 . eq ( DashboardHighCheckEnterprise : : getIsDelete , "0" ) ;
queryWrapper3 . eq ( DashboardHighCheckEnterprise : : getIsDelete , "0" ) ;
queryWrapper3 . eq ( DashboardHighCheckEnterprise : : getYear , getDateTime ( ) . getYear ( ) ) ;
queryWrapper3 . eq ( DashboardHighCheckEnterprise : : getYear , getDateTime ( ) . getYear ( ) ) ;
queryWrapper3 . eq ( DashboardHighCheckEnterprise : : getMonth , getDateTime ( ) . getMonth ( ) ) ;
queryWrapper3 . eq ( DashboardHighCheckEnterprise : : getMonth , getDateTime ( ) . getMonth ( ) ) ;
queryWrapper . eq ( StringUtils . isNotBlank ( bo . getCode ( ) ) , DashboardHighCheckArea : : getAreaCode , bo . getCode ( ) ) ;
List < DashboardHighCheckEnterprise > enterpriseList = dashboardHighCheckEnterpriseMapper . selectList ( queryWrapper3 ) ;
List < DashboardHighCheckEnterprise > enterpriseList = dashboardHighCheckEnterpriseMapper . selectList ( queryWrapper3 ) ;
Map < String , Object > map = new HashMap < > ( ) ;
Map < String , Object > map = new HashMap < > ( ) ;
map . put ( "areaList" , areaList ) ;
map . put ( "areaList" , areaList ) ;
@ -1070,7 +1190,7 @@ public class CimDashboardOverviewDataSumSserviceImpl implements ICimDashboardOve
* @return
* @return
* /
* /
@Override
@Override
public Map < String , Object > getTrendAreaMonthDataSumMap ( ) {
public Map < String , Object > getTrendAreaMonthDataSumMap ( CimDashboardOverviewQueryBo bo ) {
LambdaQueryWrapper < DashboardTrendStatArea > queryWrapper = new LambdaQueryWrapper < > ( ) ;
LambdaQueryWrapper < DashboardTrendStatArea > queryWrapper = new LambdaQueryWrapper < > ( ) ;
queryWrapper . eq ( DashboardTrendStatArea : : getIsDelete , "0" ) ;
queryWrapper . eq ( DashboardTrendStatArea : : getIsDelete , "0" ) ;
@ -1123,9 +1243,26 @@ public class CimDashboardOverviewDataSumSserviceImpl implements ICimDashboardOve
map . put ( "highAreas" , highAreas ) ;
map . put ( "highAreas" , highAreas ) ;
// 低频区域:每季度最低各1条,共4条
// 低频区域:每季度最低各1条,共4条
map . put ( "lowAreas" , lowAreas ) ;
map . put ( "lowAreas" , lowAreas ) ;
// 查询街道
List < CimDashboardOverviewVo > streetList = cimDashboardOverviewMapper . getAreaQuarterlyRegionList ( bo ) ;
map . put ( "streetList" , streetList ) ;
return map ;
return map ;
}
}
/ * *
* 下转联动某个区域查询对应区域街道的数据
* @param bo
* @return
* /
@Override
public List < CimDashboardOverviewVo > getAreaQuarterlyRegionList ( CimDashboardOverviewQueryBo bo ) {
List < CimDashboardOverviewVo > list = cimDashboardOverviewMapper . getAreaQuarterlyRegionList ( bo ) ;
return list ;
}
/ * *
/ * *
* 构建区域趋势统计数据副本 ( 用于高频 / 低频区域结果 )
* 构建区域趋势统计数据副本 ( 用于高频 / 低频区域结果 )
* 单独构建新对象 , 避免同一区域在多个季度上榜时 jccs 值被覆盖
* 单独构建新对象 , 避免同一区域在多个季度上榜时 jccs 值被覆盖
@ -1206,7 +1343,7 @@ public class CimDashboardOverviewDataSumSserviceImpl implements ICimDashboardOve
* @return
* @return
* /
* /
@Override
@Override
public Map < String , Object > getTrendFieldMonthDataSumMap ( ) {
public Map < String , Object > getTrendFieldMonthDataSumMap ( CimDashboardOverviewQueryBo bo ) {
LambdaQueryWrapper < DashboardTrendStatDomain > queryWrapper = new LambdaQueryWrapper < > ( ) ;
LambdaQueryWrapper < DashboardTrendStatDomain > queryWrapper = new LambdaQueryWrapper < > ( ) ;
queryWrapper . eq ( DashboardTrendStatDomain : : getIsDelete , "0" ) ;
queryWrapper . eq ( DashboardTrendStatDomain : : getIsDelete , "0" ) ;
@ -1258,10 +1395,25 @@ public class CimDashboardOverviewDataSumSserviceImpl implements ICimDashboardOve
map . put ( "highDomains" , highDomains ) ;
map . put ( "highDomains" , highDomains ) ;
// 低频领域:每季度最低各1条,共4条
// 低频领域:每季度最低各1条,共4条
map . put ( "lowDomains" , lowDomains ) ;
map . put ( "lowDomains" , lowDomains ) ;
List < CimDashboardOverviewVo > areaDomainList = cimDashboardOverviewMapper . getAreaDomainQuarterList ( bo ) ;
map . put ( "areaDomainList" , areaDomainList ) ;
return map ;
return map ;
}
}
/ * *
* 下转联动某个区域查询对应区域领域的数据 ( 季度 )
* @param bo
* @return
* /
@Override
public List < CimDashboardOverviewVo > getAreaDomainQuarterList ( CimDashboardOverviewQueryBo bo ) {
List < CimDashboardOverviewVo > list = cimDashboardOverviewMapper . getAreaDomainQuarterList ( bo ) ;
return list ;
}
/ * *
/ * *
* 构建领域结果
* 构建领域结果
*
*