@ -1,11 +1,7 @@
package com.zdxt.code.service.impl ;
import com.zdxt.code.domain.ComplaintStatistics ;
import com.zdxt.code.domain.EnterpriseComplaint ;
import com.zdxt.code.domain.StatisticsIndicatorPart ;
import com.zdxt.code.service.ComplaintStatisticsService ;
import com.zdxt.code.service.IEnterpriseComplaintService ;
import com.zdxt.code.service.StatisticalPaneService ;
import com.zdxt.code.domain.* ;
import com.zdxt.code.service.* ;
import org.springframework.beans.factory.annotation.Autowired ;
import org.springframework.stereotype.Service ;
@ -16,17 +12,153 @@ import java.util.ArrayList;
import java.util.List ;
import java.util.Map ;
import java.util.stream.Collectors ;
/ * *
* 年度 : year ! = = null , quarter = = null , month = = null
* 季度 : year ! = = null , quarter ! = = null , month = = null
* 月度 : year ! = = null , quarter ! = = null , month ! = = null
* /
@Service
public class StatisticalPaneImpl implements StatisticalPaneService {
@Autowired
private ComplaintStatisticsService complaintStatisticsService ;
@Autowired
private ILawEnforcementWarningListService iLawEnforcementWarningListService ;
@Autowired
private IEnforcementRegistrationService enforcementRegistrationService ;
@Autowired
private IEnterpriseInformationService iEnterpriseInformationService ;
/ * *
* 企业 - - 无权限
* @param statisticsIndicatorPart
* @return
* /
@Override
public StatisticsIndicatorPart enterprise ( StatisticsIndicatorPart statisticsIndicatorPart ) {
StatisticsIndicatorPart sNow = nowDataMake ( statisticsIndicatorPart ) ;
StatisticsIndicatorPart sLast = lastDataMake ( statisticsIndicatorPart , sNow . getBeginTime ( ) ) ;
EnterpriseInformation enterpriseNow = new EnterpriseInformation ( ) ;
EnterpriseInformation enterpriseLast = new EnterpriseInformation ( ) ;
enterpriseNow . setBeginTime ( sNow . getBeginTime ( ) ) ;
enterpriseNow . setEndTime ( sNow . getEndTime ( ) ) ;
enterpriseLast . setBeginTime ( sLast . getBeginTime ( ) ) ;
enterpriseLast . setEndTime ( sLast . getEndTime ( ) ) ;
List < EnterpriseInformation > enterpriseNowList = iEnterpriseInformationService . selectEnterpriseInformationList1 ( enterpriseNow ) ;
List < EnterpriseInformation > enterpriseLastList = iEnterpriseInformationService . selectEnterpriseInformationList1 ( enterpriseLast ) ;
List < EnterpriseInformation > existListNow = enterpriseNowList . stream ( ) . filter ( item - > item . getIsDelete ( ) = = 0 ) . collect ( Collectors . toList ( ) ) ;
List < EnterpriseInformation > logoutListNow = enterpriseNowList . stream ( ) . filter ( item - > item . getIsDelete ( ) = = 1 ) . collect ( Collectors . toList ( ) ) ;
List < EnterpriseInformation > existListLast = enterpriseLastList . stream ( ) . filter ( item - > item . getIsDelete ( ) = = 0 ) . collect ( Collectors . toList ( ) ) ;
List < EnterpriseInformation > logoutListLast = enterpriseLastList . stream ( ) . filter ( item - > item . getIsDelete ( ) = = 1 ) . collect ( Collectors . toList ( ) ) ;
StatisticsIndicatorPart p1 = new StatisticsIndicatorPart ( ) ;
p1 . setName ( "企业数量" ) ;
p1 . setTotal ( enterpriseNowList . size ( ) ) ;
p1 . setHuan ( enterpriseNowList . size ( ) - enterpriseLastList . size ( ) ) ;
StatisticsIndicatorPart p2 = new StatisticsIndicatorPart ( ) ;
p2 . setName ( "续存企业数量" ) ;
p2 . setTotal ( existListNow . size ( ) ) ;
p2 . setHuan ( existListNow . size ( ) - existListLast . size ( ) ) ;
StatisticsIndicatorPart p3 = new StatisticsIndicatorPart ( ) ;
p3 . setName ( "注销企业数量" ) ;
p3 . setTotal ( logoutListNow . size ( ) ) ;
p3 . setHuan ( logoutListNow . size ( ) - logoutListLast . size ( ) ) ;
StatisticsIndicatorPart p = new StatisticsIndicatorPart ( ) ;
List < StatisticsIndicatorPart > statisticsIndicatorPartList = new ArrayList < > ( ) ;
p . setName ( "企业数量" ) ;
statisticsIndicatorPartList . add ( p1 ) ;
statisticsIndicatorPartList . add ( p2 ) ;
statisticsIndicatorPartList . add ( p3 ) ;
p . setStatisticsIndicatorPartList ( statisticsIndicatorPartList ) ;
return p ;
}
/ * *
* 执法检查 - - 本单位执法检查需设权限未设
* @param statisticsIndicatorPart
* @return
* /
@Override
public StatisticsIndicatorPart registration ( StatisticsIndicatorPart statisticsIndicatorPart ) {
StatisticsIndicatorPart sNow = nowDataMake ( statisticsIndicatorPart ) ;
StatisticsIndicatorPart sLast = lastDataMake ( statisticsIndicatorPart , sNow . getBeginTime ( ) ) ;
EnforcementRegistration enforcementRegistrationNow = new EnforcementRegistration ( ) ;
EnforcementRegistration enforcementRegistrationLast = new EnforcementRegistration ( ) ;
enforcementRegistrationNow . setBeginTime ( sNow . getBeginTime ( ) ) ;
enforcementRegistrationNow . setEndTime ( sNow . getEndTime ( ) ) ;
enforcementRegistrationLast . setBeginTime ( sLast . getBeginTime ( ) ) ;
enforcementRegistrationLast . setEndTime ( sLast . getEndTime ( ) ) ;
List < EnforcementRegistration > now = enforcementRegistrationService . selectEnforcementRegistrationList1 ( enforcementRegistrationNow ) ;
List < EnforcementRegistration > last = enforcementRegistrationService . selectEnforcementRegistrationList1 ( enforcementRegistrationLast ) ;
List < EnforcementRegistration > uniteListNow = now . stream ( ) . filter ( item - > item . getUniteCheck ( ) ! = null & & ! "" . equals ( item . getUniteCheck ( ) ) ) . collect ( Collectors . toList ( ) ) ;
List < EnforcementRegistration > uniteListLast = last . stream ( ) . filter ( item - > item . getUniteCheck ( ) ! = null & & ! "" . equals ( item . getUniteCheck ( ) ) ) . collect ( Collectors . toList ( ) ) ;
StatisticsIndicatorPart p1 = new StatisticsIndicatorPart ( ) ;
p1 . setName ( "执法检查数量" ) ;
p1 . setTotal ( now . size ( ) ) ;
p1 . setHuan ( now . size ( ) - last . size ( ) ) ;
StatisticsIndicatorPart p2 = new StatisticsIndicatorPart ( ) ;
p2 . setName ( "执法检查数量" ) ;
p2 . setTotal ( uniteListNow . size ( ) ) ;
p2 . setHuan ( uniteListNow . size ( ) - uniteListLast . size ( ) ) ;
StatisticsIndicatorPart p3 = new StatisticsIndicatorPart ( ) ;
p3 . setName ( "本单位检查数量" ) ;
p3 . setTotal ( now . size ( ) ) ;
p3 . setHuan ( now . size ( ) - last . size ( ) ) ;
StatisticsIndicatorPart p = new StatisticsIndicatorPart ( ) ;
List < StatisticsIndicatorPart > statisticsIndicatorPartList = new ArrayList < > ( ) ;
p . setName ( "执法检查" ) ;
statisticsIndicatorPartList . add ( p1 ) ;
statisticsIndicatorPartList . add ( p2 ) ;
statisticsIndicatorPartList . add ( p3 ) ;
p . setStatisticsIndicatorPartList ( statisticsIndicatorPartList ) ;
return p ;
}
/ * *
* 预警部分 - - 本部门需设权限未设
* @param statisticsIndicatorPart
* @return
* /
@Override
public StatisticsIndicatorPart warning ( StatisticsIndicatorPart statisticsIndicatorPart ) {
StatisticsIndicatorPart sNow = nowDataMake ( statisticsIndicatorPart ) ;
StatisticsIndicatorPart sLast = lastDataMake ( statisticsIndicatorPart , sNow . getBeginTime ( ) ) ;
LawEnforcementWarningList warningStatisticsNow = new LawEnforcementWarningList ( ) ;
LawEnforcementWarningList warningStatisticsLast = new LawEnforcementWarningList ( ) ;
warningStatisticsNow . setBeginTime ( sNow . getBeginTime ( ) ) ;
warningStatisticsNow . setEndTime ( sNow . getEndTime ( ) ) ;
warningStatisticsLast . setBeginTime ( sLast . getBeginTime ( ) ) ;
warningStatisticsLast . setEndTime ( sLast . getEndTime ( ) ) ;
List < LawEnforcementWarningList > lListNow1 = iLawEnforcementWarningListService . selectLawEnforcementWarningListList2 ( warningStatisticsNow ) ;
List < LawEnforcementWarningList > lListLast1 = iLawEnforcementWarningListService . selectLawEnforcementWarningListList2 ( warningStatisticsLast ) ;
StatisticsIndicatorPart p1 = new StatisticsIndicatorPart ( ) ;
p1 . setName ( "执法预警数量" ) ;
p1 . setTotal ( lListNow1 . size ( ) ) ;
p1 . setHuan ( lListNow1 . size ( ) - lListLast1 . size ( ) ) ;
Map < String , Long > mapNow = lListNow1 . stream ( ) . collect ( Collectors . groupingBy ( LawEnforcementWarningList : : getEnforcementDepartmentId , Collectors . counting ( ) ) ) ;
Map < String , Long > mapLast = lListLast1 . stream ( ) . collect ( Collectors . groupingBy ( LawEnforcementWarningList : : getEnforcementDepartmentId , Collectors . counting ( ) ) ) ;
StatisticsIndicatorPart p2 = new StatisticsIndicatorPart ( ) ;
p2 . setName ( "涉事单位" ) ;
p2 . setTotal ( mapNow . size ( ) ) ;
p2 . setHuan ( mapNow . size ( ) - mapLast . size ( ) ) ;
StatisticsIndicatorPart p3 = new StatisticsIndicatorPart ( ) ;
p3 . setName ( "本单位发布预警数量" ) ;
p3 . setTotal ( lListNow1 . size ( ) ) ;
p3 . setHuan ( lListNow1 . size ( ) - lListLast1 . size ( ) ) ;
StatisticsIndicatorPart p = new StatisticsIndicatorPart ( ) ;
List < StatisticsIndicatorPart > statisticsIndicatorPartList = new ArrayList < > ( ) ;
p . setName ( "执法预警" ) ;
statisticsIndicatorPartList . add ( p1 ) ;
statisticsIndicatorPartList . add ( p2 ) ;
statisticsIndicatorPartList . add ( p3 ) ;
p . setStatisticsIndicatorPartList ( statisticsIndicatorPartList ) ;
return p ;
}
/ * *
* 年度 : year ! = = null , quarter = = null , month = = null
* 季度 : year ! = = null , quarter ! = = null , month = = null
* 月度 : year ! = = null , quarter ! = = null , month ! = = null
* 投诉部分 - - 无权限
* @param statisticsIndicatorPart
* @return
* /
@Override
public StatisticsIndicatorPart complaint ( StatisticsIndicatorPart statisticsIndicatorPart ) {
StatisticsIndicatorPart sNow = nowDataMake ( statisticsIndicatorPart ) ;
StatisticsIndicatorPart sLast = lastDataMake ( statisticsIndicatorPart , sNow . getBeginTime ( ) ) ;
@ -42,24 +174,24 @@ public class StatisticalPaneImpl implements StatisticalPaneService {
p1 . setName ( "执法投诉数量" ) ;
p1 . setTotal ( complaintStatisticsListNow . size ( ) ) ;
p1 . setHuan ( complaintStatisticsListNow . size ( ) - complaintStatisticsListLast . size ( ) ) ;
List < ComplaintStatistics > rqbsmNow = complaintStatisticsListNow . stream ( ) . filter ( item - > item . getComplaintType ( ) = = 3 ) . collect ( Collectors . toList ( ) ) ;
List < ComplaintStatistics > rqbsmLast = complaintStatisticsListLast . stream ( ) . filter ( item - > item . getComplaintType ( ) = = 3 ) . collect ( Collectors . toList ( ) ) ;
StatisticsIndicatorPart p2 = new StatisticsIndicatorPart ( ) ;
p2 . setName ( "入企不扫码" ) ;
p2 . setTotal ( rqbsmNow . size ( ) ) ;
p2 . setHuan ( rqbsmNow . size ( ) - rqbsmLast . size ( ) ) ;
Map < String , Long > btsbmNow = complaintStatisticsListNow . stream ( ) . collect ( Collectors . groupingBy ( ComplaintStatistics : : getComplaintDepartmentId , Collectors . counting ( ) ) ) ;
Map < String , Long > btsbmLast = complaintStatisticsListLast . stream ( ) . collect ( Collectors . groupingBy ( ComplaintStatistics : : getComplaintDepartmentId , Collectors . counting ( ) ) ) ;
StatisticsIndicatorPart p2 = new StatisticsIndicatorPart ( ) ;
p2 . setName ( "被投诉部门数量" ) ;
p2 . setTotal ( btsbmNow . size ( ) ) ;
p2 . setHuan ( btsbmNow . size ( ) - btsbmLast . size ( ) ) ;
Map < String , Long > tsqyNowList = complaintStatisticsListNow . stream ( ) . collect ( Collectors . groupingBy ( ComplaintStatistics : : getEnterpriseNumber , Collectors . counting ( ) ) ) ;
Map < String , Long > tsqyLastList = complaintStatisticsListLast . stream ( ) . collect ( Collectors . groupingBy ( ComplaintStatistics : : getEnterpriseNumber , Collectors . counting ( ) ) ) ;
StatisticsIndicatorPart p3 = new StatisticsIndicatorPart ( ) ;
p3 . setName ( "被投诉部门" ) ;
p3 . setTotal ( btsbmNow . size ( ) ) ;
p3 . setHuan ( btsbmNow . size ( ) - btsbmLast . size ( ) ) ;
p3 . setName ( "投诉企业数量 " ) ;
p3 . setTotal ( tsqyNowList . size ( ) ) ;
p3 . setHuan ( tsqyNowList . size ( ) - tsqyLastLi st. size ( ) ) ;
StatisticsIndicatorPart p = new StatisticsIndicatorPart ( ) ;
List < StatisticsIndicatorPart > statisticsIndicatorPartList = new ArrayList < > ( ) ;
p . setName ( "执法投诉" ) ;
statisticsIndicatorPartList . add ( p1 ) ;
statisticsIndicatorPartList . add ( p2 ) ;
statisticsIndicatorPartList . add ( p2 ) ;
statisticsIndicatorPartList . add ( p3 ) ;
p . setStatisticsIndicatorPartList ( statisticsIndicatorPartList ) ;
return p ;
}