Browse Source

Merge remote-tracking branch 'origin/dev_pyscreen' into dev_temp

dev_shibei_match
wangchao 5 years ago
parent
commit
76762da205
  1. 10
      epmet-module/data-report/data-report-server/src/main/java/com/epmet/datareport/service/evaluationindex/screen/impl/GrassRootsGovernServiceImpl.java
  2. 41
      epmet-module/data-report/data-report-server/src/main/resources/mapper/screen/ScreenUserJoinDao.xml
  3. 2
      epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/group/service/impl/ResiGroupCodeServiceImpl.java

10
epmet-module/data-report/data-report-server/src/main/java/com/epmet/datareport/service/evaluationindex/screen/impl/GrassRootsGovernServiceImpl.java

@ -267,7 +267,7 @@ public class GrassRootsGovernServiceImpl implements GrassRootsGovernService {
Map<String,String> Xaxis = dateUtils.getXpro(); Map<String,String> Xaxis = dateUtils.getXpro();
List<UserJoinMonthlyResultDTO> monthlyData = screenUserJoinDao.selectUserJoinDataMonthly(param.getAgencyId(),Xaxis.keySet().iterator().next()); List<UserJoinMonthlyResultDTO> monthlyData = screenUserJoinDao.selectUserJoinDataMonthly(param.getAgencyId(),Xaxis.keySet().iterator().next());
PublicPartiChartResultDTO result = new PublicPartiChartResultDTO(); PublicPartiChartResultDTO result = new PublicPartiChartResultDTO();
result.setXAxis(Xaxis.values().stream().collect(Collectors.toList())); result.setXAxis(new ArrayList<>(Xaxis.values()));
List<Integer> defaultData = new LinkedList<>(); List<Integer> defaultData = new LinkedList<>();
for(int i = NumConstant.ZERO ; i < NumConstant.TWELVE ; i++){ for(int i = NumConstant.ZERO ; i < NumConstant.TWELVE ; i++){
defaultData.add(NumConstant.ZERO); defaultData.add(NumConstant.ZERO);
@ -282,17 +282,17 @@ public class GrassRootsGovernServiceImpl implements GrassRootsGovernService {
result.setJoinUserNumList(new ArrayList<>()); result.setJoinUserNumList(new ArrayList<>());
result.setAverageJoinNumList(new ArrayList<>()); result.setAverageJoinNumList(new ArrayList<>());
Map<String,List<UserJoinMonthlyResultDTO>> dataMap = monthlyData.stream().collect(Collectors.groupingBy(UserJoinMonthlyResultDTO :: getMonthId)); Map<String,List<UserJoinMonthlyResultDTO>> dataMap = monthlyData.stream().collect(Collectors.groupingBy(UserJoinMonthlyResultDTO :: getMonthId));
Xaxis.keySet().stream().forEach(monthId -> { Xaxis.keySet().forEach(monthId -> {
List<UserJoinMonthlyResultDTO> data = dataMap.get(monthId); List<UserJoinMonthlyResultDTO> data = dataMap.get(monthId);
if(null == data || data.isEmpty()){ if (null == data || data.isEmpty()) {
result.getOrganizeNumList().add(NumConstant.ZERO); result.getOrganizeNumList().add(NumConstant.ZERO);
result.getJoinUserNumList().add(NumConstant.ZERO); result.getJoinUserNumList().add(NumConstant.ZERO);
result.getAverageJoinNumList().add(NumConstant.ZERO); result.getAverageJoinNumList().add(NumConstant.ZERO);
}else{ } else {
Integer o = NumConstant.ZERO; Integer o = NumConstant.ZERO;
Integer j = NumConstant.ZERO; Integer j = NumConstant.ZERO;
Integer a = NumConstant.ZERO; Integer a = NumConstant.ZERO;
for(UserJoinMonthlyResultDTO unit : data){ for (UserJoinMonthlyResultDTO unit : data) {
o = null == unit.getOrganizeNum() ? NumConstant.ZERO : o + unit.getOrganizeNum(); o = null == unit.getOrganizeNum() ? NumConstant.ZERO : o + unit.getOrganizeNum();
j = null == unit.getJoinUserNum() ? NumConstant.ZERO : o + unit.getJoinUserNum(); j = null == unit.getJoinUserNum() ? NumConstant.ZERO : o + unit.getJoinUserNum();
a = null == unit.getAverageJoinNum() ? NumConstant.ZERO : o + unit.getAverageJoinNum(); a = null == unit.getAverageJoinNum() ? NumConstant.ZERO : o + unit.getAverageJoinNum();

41
epmet-module/data-report/data-report-server/src/main/resources/mapper/screen/ScreenUserJoinDao.xml

@ -6,46 +6,45 @@
<!-- 查询用户参与数据 --> <!-- 查询用户参与数据 -->
<select id="selectUserJoinData" resultType="com.epmet.evaluationindex.screen.dto.result.UserJoinIndicatorGrowthRateResultDTO"> <select id="selectUserJoinData" resultType="com.epmet.evaluationindex.screen.dto.result.UserJoinIndicatorGrowthRateResultDTO">
SELECT SELECT
JOIN_TOTAL AS total, IFNULL(JOIN_TOTAL,0) AS total,
ROUND( AVG_JOIN, 1 ) AS averageJoin, IFNULL(ROUND( AVG_JOIN, 1 ),0) AS averageJoin,
JOIN_TOTAL_UP_RATE AS monthIncr, IFNULL(JOIN_TOTAL_UP_RATE,0) AS monthIncr,
JOIN_TOTAL_UP_FLAG AS monthTrend, IFNULL(JOIN_TOTAL_UP_FLAG,0) AS monthTrend,
ROUND(AVG_ISSUE, 1) AS averageIssue, IFNULL(ROUND(AVG_ISSUE, 1),0) AS averageIssue,
AVG_ISSUE_UP_RATE AS issueCompareLatestMonth, IFNULL(AVG_ISSUE_UP_RATE,0) AS issueCompareLatestMonth,
AVG_ISSUE_UP_FLAG AS issueCompareLatestTrend, AVG_ISSUE_UP_FLAG AS issueCompareLatestTrend,
AGVG_JOIN_UP_RATE AS joinCompareLatestMonth, IFNULL(AGVG_JOIN_UP_RATE,0) AS joinCompareLatestMonth,
AGVG_JOIN_UP_FLAG AS joinCompareLatestTrend AGVG_JOIN_UP_FLAG AS joinCompareLatestTrend
FROM FROM
screen_user_join screen_user_join
WHERE WHERE
DEL_FLAG = '0' DEL_FLAG = '0'
AND ORG_ID = #{agencyId}
AND MONTH_ID = #{monthId} AND MONTH_ID = #{monthId}
AND ORG_ID = #{agencyId}
</select> </select>
<!-- 根据地区码查询用户参与数据 --> <!-- 根据地区码查询用户参与数据 -->
<select id="selectUserJoinDataByAreaCode" resultType="com.epmet.evaluationindex.screen.dto.result.UserJoinIndicatorGrowthRateResultDTO"> <select id="selectUserJoinDataByAreaCode" resultType="com.epmet.evaluationindex.screen.dto.result.UserJoinIndicatorGrowthRateResultDTO">
SELECT SELECT
avg( scj.JOIN_TOTAL ) AS total, IFNULL(avg( scj.JOIN_TOTAL ),0) AS total,
ROUND( avg( scj.AVG_JOIN ), 1 ) AS averageJoin, IFNULL(ROUND( avg( scj.AVG_JOIN ), 1 ),0) AS averageJoin,
avg( scj.JOIN_TOTAL_UP_RATE ) AS monthIncr, IFNULL(avg( scj.JOIN_TOTAL_UP_RATE ),0) AS monthIncr,
(case when avg( scj.JOIN_TOTAL_UP_RATE ) &gt;0 then 'incr' (case when IFNULL(avg( scj.JOIN_TOTAL_UP_RATE ),0) &gt;0 then 'incr'
when avg( scj.JOIN_TOTAL_UP_RATE ) &lt; 0 then 'decr' when IFNULL(avg( scj.JOIN_TOTAL_UP_RATE ),0) &lt; 0 then 'decr'
else 'eq' else 'eq'
end )as monthTrend, end )as monthTrend,
ROUND( avg( scj.AVG_ISSUE ), 1 ) AS averageIssue, ROUND( IFNULL(avg( scj.AVG_ISSUE ),0), 1 ) AS averageIssue,
avg( scj.AVG_ISSUE_UP_RATE ) AS issueCompareLatestMonth, IFNULL(avg( scj.AVG_ISSUE_UP_RATE ),0) AS issueCompareLatestMonth,
( (
case when avg( scj.AVG_ISSUE_UP_RATE )&gt; 0 then 'incr' case when IFNULL(avg( scj.AVG_ISSUE_UP_RATE ),0) &gt; 0 then 'incr'
when avg( scj.AVG_ISSUE_UP_RATE ) &lt; 0 then 'decr' when IFNULL(avg( scj.AVG_ISSUE_UP_RATE ),0) &lt; 0 then 'decr'
else 'eq' else 'eq'
end end
)as issueCompareLatestTrend, )as issueCompareLatestTrend,
avg( scj.AGVG_JOIN_UP_RATE ) AS joinCompareLatestMonth, IFNULL(avg( scj.AGVG_JOIN_UP_RATE) ,0) AS joinCompareLatestMonth,
( (
case when avg( scj.AGVG_JOIN_UP_RATE ) &gt; 0 then 'incr' case when IFNULL(avg( scj.AGVG_JOIN_UP_RATE ),0) &gt; 0 then 'incr'
when avg( scj.AGVG_JOIN_UP_RATE ) &lt; 0 then 'decr' when IFNULL(avg( scj.AGVG_JOIN_UP_RATE ),0) &lt; 0 then 'decr'
else 'eq' else 'eq'
end end
)as joinCompareLatestTrend )as joinCompareLatestTrend

2
epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/group/service/impl/ResiGroupCodeServiceImpl.java

@ -160,7 +160,7 @@ public class ResiGroupCodeServiceImpl extends BaseServiceImpl<ResiGroupCodeDao,
long endTs = System.currentTimeMillis(); long endTs = System.currentTimeMillis();
logger.info("异步创建群二维码成功,执行时长:{}", endTs - startTs); logger.info("异步创建群二维码成功,执行时长:{}", endTs - startTs);
} catch (Exception e) { } catch (Exception e) {
logger.error("异步创建群二维码失败,错误信息:{}", ExceptionUtils.getErrorStackTrace(e)); logger.error("异步创建群二维码失败,错误信息:{},堆栈信息:{}", e.getMessage(), ExceptionUtils.getErrorStackTrace(e));
} }
}); });
return ""; return "";

Loading…
Cancel
Save