黑灰名单2020.04.22_02

src/main/java/cn/quantgroup/qgblservice/service/impl/BlackGreyListServiceImpl.java

@@ -745,7 +745,7 @@ public class BlackGreyListServiceImpl implements IBlackGreyListService {
 
         Integer maxId = 0;
         try {
-            maxId = xyqbJdbcTemplate.queryForObject(ConstantBlackGrey.SQL.BL_QUERY_BLACKLIST_RESULT_MAX_ID, Integer.class);
+            maxId = blackListJdbcTemplate.queryForObject(ConstantBlackGrey.SQL.BL_QUERY_BLACKLIST_RESULT_MAX_ID, Integer.class);
         }catch (EmptyResultDataAccessException e){
             log.error("查询结果表-黑名单最大Id异常, sql: {} ", ConstantBlackGrey.SQL.BL_QUERY_BLACKLIST_RESULT_MAX_ID, e);
         }
@@ -873,7 +873,7 @@ public class BlackGreyListServiceImpl implements IBlackGreyListService {
 
         Integer maxId = 0;
         try {
-            maxId = xyqbJdbcTemplate.queryForObject(ConstantBlackGrey.SQL.BL_QUERY_BLACKLIST_RESULT_MAX_ID, Integer.class);
+            maxId = blackListJdbcTemplate.queryForObject(ConstantBlackGrey.SQL.BL_QUERY_BLACKLIST_RESULT_MAX_ID, Integer.class);
         }catch (EmptyResultDataAccessException e){
             log.error("查询结果表-黑名单最大Id异常, sql: {} ", ConstantBlackGrey.SQL.BL_QUERY_BLACKLIST_RESULT_MAX_ID, e);
         }

src/main/java/cn/quantgroup/qgblservice/service/impl/BlackToGreyListParallel.java

@@ -174,11 +174,13 @@ public class BlackToGreyListParallel implements ParallelComputingProcess<BlackGr
                                 }
 
                             }else{
+                                if(detailsVo.getStatus()==0){
                                     err_count.getAndIncrement();
                                     optSet.add("otherType:"+blackResult.getRId());
                                     writeLogByName(ConstantBlackGrey.PARAM.SAVELOGPATH + dateName + ConstantBlackGrey.PARAM.SEPA + "error.log", "black_list_result_not_find_details>>"+blackResult.getRId());
                                 }
                             }
+                        }
 
                         //type=11, 恶意投诉客服，一直待在黑名单
                         if(is_type_11){
@@ -240,6 +242,7 @@ public class BlackToGreyListParallel implements ParallelComputingProcess<BlackGr
                     }
 
                 } catch (Exception e) {
+                    err_count.getAndIncrement();
                     optSet.add("ERR:" + blackResult.getRId());
                     log.error(log_inf + "process() threadId:" + threadId + ",ERROR!", e);
                 }
@@ -249,7 +252,7 @@ public class BlackToGreyListParallel implements ParallelComputingProcess<BlackGr
 
 
         }
-        log.info(log_inf + "处理结束 CPU_{} , remove_count:{} , 失败:{} , this_list_size: {} ", threadId, remove_count.get(), err_count.get(), list_size);
+        log.info(log_inf + "处理结束 CPU_{} , remove_count:{} , type_11: {} , 失败:{} , this_list_size: {} ", threadId, remove_count.get(), type_11.get(), err_count.get(), list_size);
     }
 
 

src/main/java/cn/quantgroup/qgblservice/service/impl/UpdateBlackListOverdueDayParallel.java

@@ -208,14 +208,9 @@ public class UpdateBlackListOverdueDayParallel implements ParallelComputingProce
 
                         //如果明细表有修改，更新一下结果表修改时间
                         if(details_is_update){
-                           /* //更新结果表
-                            BlackGreyListResult updateResult = new BlackGreyListResult();
-                            updateResult.setRId(blackResult.getRId());//条件
-                            updateResult.setUpdatedAt(new Timestamp(System.currentTimeMillis()));//结果
-                            int update_r = blackGreyListMapper.updateBlackGreyListResult(updateResult);
-                            */
-                            update_count.getAndIncrement();
+                           //更新结果表
                             updateResultUpdatedAt(blackResult.getRId());
+                            update_count.getAndIncrement();
                         }
 
                     }else {
@@ -226,9 +221,11 @@ public class UpdateBlackListOverdueDayParallel implements ParallelComputingProce
 
                 } catch (Exception e) {
                     optSet.add("ERR:" + blackResult.getRId());
+                    err_count.getAndIncrement();
                     log.error(log_inf + "process() threadId:" + threadId + ",ERROR!", e);
                 }
             }else {
+                err_count.getAndIncrement();
                 log.error("查询黑名单逾期天-发现uuid为空, threadId_{} , r_Id: {} , uuid: {} , blackType: {} ", threadId, rId, uuid, blackResult.getBlackType());
             }
 
@@ -304,7 +301,6 @@ public class UpdateBlackListOverdueDayParallel implements ParallelComputingProce
 
 
     //更新结果表,updatedAt时间
-    @Async
     private int updateResultUpdatedAt(String rId){
         int update_r = 0;
         try{