|
|
@ -6,6 +6,7 @@ import com.epmet.commons.tools.enums.GenderEnum; |
|
|
|
import com.epmet.commons.tools.enums.PartyOrgTypeEnum; |
|
|
|
import com.epmet.commons.tools.exception.EpmetErrorCode; |
|
|
|
import com.epmet.commons.tools.exception.EpmetException; |
|
|
|
import com.epmet.commons.tools.exception.ExceptionUtils; |
|
|
|
import com.epmet.commons.tools.feign.ResultDataResolver; |
|
|
|
import com.epmet.commons.tools.redis.common.CustomerOrgRedis; |
|
|
|
import com.epmet.commons.tools.redis.common.CustomerResiUserRedis; |
|
|
@ -96,7 +97,14 @@ public class LingShanScreenServiceImpl implements LingShanScreenService, ResultD |
|
|
|
|
|
|
|
@Override |
|
|
|
public List<LingShanScreenPartyActTypeAndQtyResultDTO> partyActTypeAndQuantity(String agencyId) { |
|
|
|
AgencyInfoCache agencyInfo = CustomerOrgRedis.getAgencyInfo(agencyId); |
|
|
|
AgencyInfoCache agencyInfo = null; |
|
|
|
try { |
|
|
|
agencyInfo = CustomerOrgRedis.getAgencyInfo(agencyId); |
|
|
|
} catch (Exception e) { |
|
|
|
logger.warn("【灵山大屏-按活动类型查询党建活动统计】" + ExceptionUtils.getErrorStackTrace(e)); |
|
|
|
return new ArrayList<>(); |
|
|
|
} |
|
|
|
|
|
|
|
if (agencyInfo == null) { |
|
|
|
throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "查询当前组织信息失败,agencyId:" + agencyId, "查询当前组织信息失败"); |
|
|
|
} |
|
|
@ -223,7 +231,15 @@ public class LingShanScreenServiceImpl implements LingShanScreenService, ResultD |
|
|
|
*/ |
|
|
|
@Override |
|
|
|
public List<LingShanScreenPartyActQtyStatsResultDTO> actQtyOfPartyOrgStats(String agencyId, Date holdTimeStart, Date holdTimeEnd) { |
|
|
|
AgencyInfoCache agencyInfo = CustomerOrgRedis.getAgencyInfo(agencyId); |
|
|
|
ArrayList<LingShanScreenPartyActQtyStatsResultDTO> rl = new ArrayList<>(); |
|
|
|
AgencyInfoCache agencyInfo = null; |
|
|
|
try { |
|
|
|
agencyInfo = CustomerOrgRedis.getAgencyInfo(agencyId); |
|
|
|
} catch (Exception e) { |
|
|
|
logger.warn("【灵山大屏-按组织查询党建活动统计】" + ExceptionUtils.getErrorStackTrace(e)); |
|
|
|
return rl; |
|
|
|
} |
|
|
|
|
|
|
|
if (agencyInfo == null) { |
|
|
|
throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "查询当前组织信息失败,agencyId:" + agencyId, "查询当前组织信息失败"); |
|
|
|
} |
|
|
@ -298,7 +314,6 @@ public class LingShanScreenServiceImpl implements LingShanScreenService, ResultD |
|
|
|
} |
|
|
|
|
|
|
|
// 将结果map转化为list,返回
|
|
|
|
ArrayList<LingShanScreenPartyActQtyStatsResultDTO> rl = new ArrayList<>(); |
|
|
|
|
|
|
|
orgDimMap.forEach((actType, orgStatsMap) -> { |
|
|
|
LingShanScreenPartyActQtyStatsResultDTO re = new LingShanScreenPartyActQtyStatsResultDTO(); |
|
|
|