黑灰名单2020.04.20---测试test

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

@@ -286,7 +286,7 @@ public class BlackGreyListServiceImpl implements IBlackGreyListService {
 
                        /* int insert_result = blackGreyListMapper.insertBlackGreyListResult(insertResult);
                         int insert_details =blackGreyListMapper.insertBlackGreyListDetails(insertdetails);*/
-                       // log.info("黑灰名单增加结束-结果表插入: {} , 明细表插入: {} ", insertResult.toString(), insertdetails.toString());
+                       log.info("黑灰名单增加结束-结果表插入: {} , 明细表插入: {} ", insertResult.toString(), insertdetails.toString());
 
                     }else{
 
@@ -375,7 +375,7 @@ public class BlackGreyListServiceImpl implements IBlackGreyListService {
                             }
                             int insert_details = blackGreyListMapper.insertBlackGreyListDetails(insertdetails);
                             int update_result = blackGreyListMapper.updateBlackGreyListResult(updateResult);*/
-                      //  log.info("黑灰名单增加结束-结果表修改: {} , 明细表插入: {} ,  明细表修改: {} , blackGreyObj : {} ", updateResult.toString(), insertdetails.toString(), deleteDetails, blackGreyObj.toString());
+                       log.info("黑灰名单增加结束-结果表修改: {} , 明细表插入: {} ,  明细表修改: {} , blackGreyObj : {} ", updateResult.toString(), insertdetails.toString(), deleteDetails, blackGreyObj.toString());
                     }
 
                 }catch (Exception e){
@@ -385,6 +385,9 @@ public class BlackGreyListServiceImpl implements IBlackGreyListService {
                     continue;
                 }
 
+                /**
+                   //测试不操作数据
+
                 if(deleteDetails!=null){
                     StringBuffer sql_buff = new StringBuffer("UPDATE black_grey_list_details set ");
                     sql_buff.append(" status=").append(deleteDetails.getStatus()).append(", ");
@@ -474,6 +477,7 @@ public class BlackGreyListServiceImpl implements IBlackGreyListService {
                     }
                 }
 
+                 */
             }
 
 

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

@@ -232,7 +232,10 @@ public class BlackToGreyListParallel implements ParallelComputingProcess<BlackGr
                         detailUpdateParam.setRId(blackResult.getRId());
                         detailUpdateParam.setWEqStatus(10);
                         detailUpdateParam.setWInType(Arrays.asList(ConstantBlackGrey.PARAM.BLACK_LIST_TYPES)); //('1','2','10')
-                        int update_d = blackGreyListMapper.updateDetailsStatusByparams(detailUpdateParam);
+                        //int update_d = blackGreyListMapper.updateDetailsStatusByparams(detailUpdateParam);
+                        //测试不操作数据
+                        int update_d = 1;
+                        log.warn("测试不操作数据,updateDetailsStatusByparams:{}", JSONObject.toJSONString(detailUpdateParam));
 
                         //更新结果表
                         BlackGreyListResult updateResult = new BlackGreyListResult();
@@ -243,7 +246,10 @@ public class BlackToGreyListParallel implements ParallelComputingProcess<BlackGr
                         if(reasonsList!=null){
                             updateResult.setReasons(JSON.toJSONString(reasonsList));
                         }
-                        int update_r = blackGreyListMapper.updateBlackGreyListResult(updateResult);
+                        //int update_r = blackGreyListMapper.updateBlackGreyListResult(updateResult);
+                        //测试不操作数据
+                        int update_r = 0;
+                        log.warn("测试不操作数据,updateBlackGreyListResult:{}", JSONObject.toJSONString(updateResult));
 
                         if(update_d>0 && update_r>0){
                             remove_count.getAndIncrement();
@@ -320,7 +326,9 @@ public class BlackToGreyListParallel implements ParallelComputingProcess<BlackGr
                     detailUpdateParam.setRId(rJoinDVo.getRId());
                     detailUpdateParam.setWEqType(rJoinDVo.getType());
                     detailUpdateParam.setWEqStatus(0);
-                    int update = blackGreyListMapper.updateDetailsStatusByparams(detailUpdateParam);
+                    //int update = blackGreyListMapper.updateDetailsStatusByparams(detailUpdateParam);
+                    int update = 1;
+                    log.warn("测试不操作数据, log_inf: {} , updateDetailStatus10:{}", log_inf, JSONObject.toJSONString(detailUpdateParam));
                     if(update>0){
                         //用于修改结果表标记
                         rJoinDVo.setStatus(10);

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

@@ -224,7 +224,10 @@ public class UpdateBlackListOverdueDayParallel implements ParallelComputingProce
                             BlackGreyListResult updateResult = new BlackGreyListResult();
                             updateResult.setRId(blackResult.getRId());//条件
                             updateResult.setUpdatedAt(new Timestamp(System.currentTimeMillis()));//结果
-                            int update_r = blackGreyListMapper.updateBlackGreyListResult(updateResult);
+                            //int update_r = blackGreyListMapper.updateBlackGreyListResult(updateResult);
+                            //测试不操作数据
+                            int update_r = 1;
+                            log.warn("测试不操作数据, 更新时间, updateBlackGreyListResult:{}", JSONObject.toJSONString(updateResult));
                             update_count.getAndIncrement();
                         }
 
@@ -301,7 +304,11 @@ public class UpdateBlackListOverdueDayParallel implements ParallelComputingProce
                 //detailUpdateParam.setRId(detailsVo.getRId());
                 //detailUpdateParam.setWEqType(detailsVo.getType());
                 //detailUpdateParam.setWEqStatus(0);
-                int update = blackGreyListMapper.updateDetailOverdueDayById(detailUpdateParam);
+
+                //int update = blackGreyListMapper.updateDetailOverdueDayById(detailUpdateParam);
+                log.warn("测试不操作数据, log_inf: {} , updateOverdueDay:{}", log_inf, JSONObject.toJSONString(detailUpdateParam));
+                //测试不操作数据
+                int update = 1;
                 return update;
 
             }