From 068fc7f2e81178e55fa191a13709af64b1a163f6 Mon Sep 17 00:00:00 2001 From: EricsHu <hrr145632> Date: 星期一, 05 十二月 2022 14:27:43 +0800 Subject: [PATCH] 处理编码 --- src/main/java/com/qxueyou/scc/school/service/impl/RankMsgDealService.java | 44 ++++++++++++++++++++++---------------------- 1 files changed, 22 insertions(+), 22 deletions(-) diff --git a/src/main/java/com/qxueyou/scc/school/service/impl/RankMsgDealService.java b/src/main/java/com/qxueyou/scc/school/service/impl/RankMsgDealService.java index 3b0a5c4..9f076ab 100644 --- a/src/main/java/com/qxueyou/scc/school/service/impl/RankMsgDealService.java +++ b/src/main/java/com/qxueyou/scc/school/service/impl/RankMsgDealService.java @@ -47,7 +47,7 @@ private static Logger log = LogManager.getLogger("ONSExceptionLogService"); /** - * 排名更新时间,默认60秒 + * 鎺掑悕鏇存柊鏃堕棿,榛樿60绉� */ @SuppressWarnings("unused") private int updateRankMinutes = 60; @@ -70,10 +70,10 @@ // String scopeType = msg.getUserProperties("scopeType"); // String scopeId = msg.getUserProperties("scopeId"); // -// // 判断哪些需要更新排名 +// // 鍒ゆ柇鍝簺闇�瑕佹洿鏂版帓鍚� // List<SchRank> rankLst = getRankLstNeedUpdate(userId,rankType,scopeType,scopeId); // -// // 如果有,则更新排名 +// // 濡傛灉鏈夛紝鍒欐洿鏂版帓鍚� // updateRankLst(rankLst); // // }catch(Exception e){ @@ -84,7 +84,7 @@ // ";scopeType:" + msg.getUserProperties("scopeType") + // ";scopeId:" + msg.getUserProperties("scopeId") ; // -// log.error( businessId + " :排名消息发送失败:" + e , e); +// log.error( businessId + " :鎺掑悕娑堟伅鍙戦�佸け璐�:" + e , e); // onsExceptionLogService.logSaveExceptionLog(cfg.getConfigByEnv("ons-common-topic"), "SCH_RANK", businessId , desp ); // } // @@ -92,7 +92,7 @@ // } /** - * 更新排名 + * 鏇存柊鎺掑悕 * * @param rankLst */ @@ -106,16 +106,16 @@ } /** - * 更新排名 + * 鏇存柊鎺掑悕 * * @param rank */ private void updateRank(SchRank rank) { - // 查询所有待排名实时数据列表 + // 鏌ヨ鎵�鏈夊緟鎺掑悕瀹炴椂鏁版嵁鍒楄〃 List<SchRank> rankLst = querySchRankLstByRank(rank); - // 按value排序 + // 鎸塿alue鎺掑簭 Collections.sort(rankLst, new Comparator<SchRank>() { @Override public int compare(SchRank r1, SchRank r2) { @@ -129,19 +129,19 @@ } }); - // 新建版本记录 + // 鏂板缓鐗堟湰璁板綍 SchRankVer version = insertRankVersion(rank); - // 插入rank_his数据 + // 鎻掑叆rank_his鏁版嵁 saveRankHisData(version, rankLst); - // 插入缓存记录,标记本次更新排名时间 + // 鎻掑叆缂撳瓨璁板綍锛屾爣璁版湰娆℃洿鏂版帓鍚嶆椂闂� updateUpdateTime(rank); } /** - * 插入缓存记录,标记本次更新排名时间 + * 鎻掑叆缂撳瓨璁板綍锛屾爣璁版湰娆℃洿鏂版帓鍚嶆椂闂� * * @param rank */ @@ -150,7 +150,7 @@ } /** - * 获取cacheId + * 鑾峰彇cacheId * * @param rank * @return @@ -163,14 +163,14 @@ } /** - * 创建新的版本记录 + * 鍒涘缓鏂扮殑鐗堟湰璁板綍 * * @param rank * @return */ private SchRankVer insertRankVersion(SchRank rank) { - // 更新旧的最新版本 + // 鏇存柊鏃х殑鏈�鏂扮増鏈� String hql = "from SchRankVer where rankType=? and scopeId=? and scopeType=? and latest is true order by version desc"; List<SchRankVer> oldLastestVerLst = dao.find(hql, CollectionUtils.newList( rank.getRankType(), rank.getScopeId(), rank.getScopeType()), @@ -184,7 +184,7 @@ dao.saveOrUpdate(oldVer); } - // 创建新的版本 + // 鍒涘缓鏂扮殑鐗堟湰 SchRankVer ver = new SchRankVer(); TraceUtils.setCreateTrace(ver); @@ -204,7 +204,7 @@ } /** - * 根据任何一条排名数据查询所有待排名实时数据列表 + * 鏍规嵁浠讳綍涓�鏉℃帓鍚嶆暟鎹煡璇㈡墍鏈夊緟鎺掑悕瀹炴椂鏁版嵁鍒楄〃 * * @param rank * @return @@ -222,7 +222,7 @@ } /** - * 判断哪些需要更新排名 + * 鍒ゆ柇鍝簺闇�瑕佹洿鏂版帓鍚� * * @param userId * @return @@ -231,11 +231,11 @@ private List<SchRank> getRankLstNeedUpdate(String userId,String rankType,String scopeType,String scopeId) { StringBuffer sb = new StringBuffer("from SchRank where userId=? and rankType = ? and scopeType = ? "); - // 参数集合 + // 鍙傛暟闆嗗悎 List<Object> args = CollectionUtils.newList(userId,rankType,scopeType); if(!SchRank.SCOPE_TYPE_QXUEYOU.equals(scopeType) - && StringUtils.isNotBlank(scopeId)){// qxueyou排名 不需要 + && StringUtils.isNotBlank(scopeId)){// qxueyou鎺掑悕 涓嶉渶瑕� sb.append(" and scopeId = ?"); args.add(scopeId); } @@ -257,7 +257,7 @@ } /** - * 插入rank_his数据 + * 鎻掑叆rank_his鏁版嵁 * * @param version * @param rankLst @@ -272,7 +272,7 @@ for (SchRank rank : rankLst) { - // Q学友只处理前一百名 + // Q瀛﹀弸鍙鐞嗗墠涓�鐧惧悕 if (i > 100 && SchRank.SCOPE_TYPE_QXUEYOU.equals(rank.getScopeType())) { break; -- Gitblit v1.8.0