1

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/controller/kylin/DataController.java

@@ -44,11 +44,11 @@ public class DataController {
 //        Boolean result = data.childAccount();
 //        return ResponseDto.success(result);
 //    }
-
-    @PostMapping("SurplusRedis")
-    @ApiOperation("redis库存迁移")
-    public ResponseDto<Boolean> SurplusRedis() {
-        Boolean result = data.SurplusRedis();
-        return ResponseDto.success(result);
-    }
+//
+//    @PostMapping("SurplusRedis")
+//    @ApiOperation("redis库存迁移")
+//    public ResponseDto<Boolean> SurplusRedis() {
+//        Boolean result = data.SurplusRedis();
+//        return ResponseDto.success(result);
+//    }
 }

liquidnet-bus-service/liquidnet-service-platform/liquidnet-service-platform-impl/src/main/java/com/liquidnet/service/platform/service/impl/kylin/DataImpl.java

@@ -935,46 +935,48 @@ public class DataImpl {
         }
     }
 
-    // redis 库存迁移
-    private static final JedisPool jedisPool;
-    private static final ObjectMapper toObjMapper;
-
-    static {
-//        DefaultJedisClientConfig.Builder builder = DefaultJedisClientConfig.builder().password("NBs$%6hW").database(15);
-//        jedis = new Jedis(new HostAndPort("zhengzai.redis.rds.aliyuncs.com", 6380), builder.build());
-
-        jedisPool = new JedisPool("zhengzai.redis.rds.aliyuncs.com", 6380);
-
-        toObjMapper = new ObjectMapper();
-        toObjMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
-        toObjMapper.disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS);
-        toObjMapper.registerModule(new JavaTimeModule());
-        toObjMapper.activateDefaultTyping(toObjMapper.getPolymorphicTypeValidator(), ObjectMapper.DefaultTyping.NON_FINAL);
-    }
-
-    @Autowired
-    public boolean SurplusRedis() {
-
-        Jedis jedis = null;
-        try {
-            jedis = jedisPool.getResource();
-            jedis.auth("NBs$%6hW");
-            jedis.select(15);
-
-            List<KylinTicketStatus> ticketStatus = ticketStatusMapper.selectList(Wrappers.lambdaQuery(KylinTicketStatus.class));
-            for (KylinTicketStatus item : ticketStatus) {
-                String ticketId = item.getTicketId();
-                dataUtils.setSurplusGeneral(ticketId, toObjMapper.readValue(jedis.get(KylinRedisConst.PERFORMANCES_INVENTORY + ticketId + ":" + KylinRedisConst.SURPLUS_GENERAL), Integer.class));
-                dataUtils.setSurplusExchange(ticketId, toObjMapper.readValue(jedis.get(KylinRedisConst.PERFORMANCES_INVENTORY + ticketId + ":" + KylinRedisConst.SURPLUS_EXCHANGE), Integer.class));
-            }
-            return true;
-        } catch (Exception e) {
-            e.printStackTrace();
-            return false;
-        } finally {
-            if (jedis != null) {
-                jedis.close();
-            }
-        }
-    }
+//    // redis 库存迁移
+//    private static final JedisPool jedisPool;
+//    private static final ObjectMapper toObjMapper;
+//
+//    static {
+////        DefaultJedisClientConfig.Builder builder = DefaultJedisClientConfig.builder().password("NBs$%6hW").database(15);
+////        jedis = new Jedis(new HostAndPort("zhengzai.redis.rds.aliyuncs.com", 6380), builder.build());
+//
+//        jedisPool = new JedisPool("zhengzai.redis.rds.aliyuncs.com", 6380);
+//
+//        toObjMapper = new ObjectMapper();
+//        toObjMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
+//        toObjMapper.disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS);
+//        toObjMapper.registerModule(new JavaTimeModule());
+//        toObjMapper.activateDefaultTyping(toObjMapper.getPolymorphicTypeValidator(), ObjectMapper.DefaultTyping.NON_FINAL);
+//    }
+
+//    public boolean SurplusRedis() {
+//        Jedis jedis = null;
+//        try {
+//            jedis = jedisPool.getResource();
+//            jedis.auth("NBs$%6hW");
+//            jedis.select(15);
+//
+//            List<KylinTicketStatus> ticketStatus = ticketStatusMapper.selectList(Wrappers.lambdaQuery(KylinTicketStatus.class));
+//            for (KylinTicketStatus item : ticketStatus) {
+//                String ticketId = item.getTicketId();
+//                try {
+//                    dataUtils.setSurplusGeneral(ticketId, toObjMapper.readValue(jedis.get(KylinRedisConst.PERFORMANCES_INVENTORY + ticketId + ":" + KylinRedisConst.SURPLUS_GENERAL), Integer.class));
+//                    dataUtils.setSurplusExchange(ticketId, toObjMapper.readValue(jedis.get(KylinRedisConst.PERFORMANCES_INVENTORY + ticketId + ":" + KylinRedisConst.SURPLUS_EXCHANGE), Integer.class));
+//                } catch (Exception e) {
+//                    e.printStackTrace();
+//                }
+//            }
+//            return true;
+//        } catch (Exception e) {
+//            e.printStackTrace();
+//            return false;
+//        } finally {
+//            if (jedis != null) {
+//                jedis.close();
+//            }
+//        }
+//    }
 }