提交 消费

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/AbstractXlsRedisReceiver.java

@@ -17,6 +17,7 @@ import org.springframework.data.redis.stream.StreamListener;
 
 import java.net.URL;
 import java.time.LocalDateTime;
+import java.util.HashMap;
 import java.util.LinkedList;
 import java.util.Map;
 
@@ -87,34 +88,35 @@ public abstract class AbstractXlsRedisReceiver implements StreamListener<String,
                 objs.add(new Object[]{skuId, xlsPath, type, 1, LocalDateTime.now()});
                 aBoolean = baseDao.batchSql(SQL_INSERT_GOODS_BUY_ROSTER_LOG, objs);
             } else if (finalType.equals(3) || finalType.equals(4)) {
-                if (xlsPath != null) {//添加
-                    EasyExcel.read(new URL(xlsPath).openStream(), PhoneUnIdDto.class, new PageReadListener<PhoneUnIdDto>(dataList -> {
-                        for (PhoneUnIdDto data : dataList) {
-                            if (data.getMobile() == null) {
+                if (xlsPath != null && !xlsPath.equals("")) {//添加
+                    EasyExcel.read(new URL(xlsPath).openStream(), new PageReadListener<HashMap<String, String>>(dataList -> {
+                        for (HashMap<String, String> data : dataList) {
+                            if (data.get(0) == null) {
                                 continue;
                             }
                             if (finalType.equals(3)) {
-                                redisUtil.set(GoblinRedisConst.REDIS_WHITE.concat(finalSkuId + ":").concat(data.getMobile()), 1);
+                                redisUtil.set(GoblinRedisConst.REDIS_WHITE.concat(finalSkuId + ":").concat(data.get(0)), 1);
                             } else {
-                                redisUtil.set(GoblinRedisConst.REDIS_BLACK.concat(finalSkuId + ":").concat(data.getMobile()), 1);
+                                redisUtil.set(GoblinRedisConst.REDIS_BLACK.concat(finalSkuId + ":").concat(data.get(0)), 1);
                             }
                         }
                     })).sheet().doRead();
                 }
-                if (oXlsPath != null) {//删除旧的黑白名单
-                    EasyExcel.read(new URL(oXlsPath).openStream(), PhoneUnIdDto.class, new PageReadListener<PhoneUnIdDto>(dataList -> {
-                        for (PhoneUnIdDto data : dataList) {
-                            if (data.getMobile() == null) {
+                if (oXlsPath != null&& !oXlsPath.equals("")) {//删除旧的黑白名单
+                    EasyExcel.read(new URL(oXlsPath).openStream(), new PageReadListener<HashMap<String, String>>(dataList -> {
+                        for (HashMap<String, String> data : dataList) {
+                            if (data.get(0) == null) {
                                 continue;
                             }
                             if (finalType.equals(3)) {
-                                redisUtil.del(GoblinRedisConst.REDIS_WHITE.concat(finalSkuId + ":").concat(data.getMobile()));
+                                redisUtil.del(GoblinRedisConst.REDIS_WHITE.concat(finalSkuId + ":").concat(data.get(0)));
                             } else {
-                                redisUtil.del(GoblinRedisConst.REDIS_BLACK.concat(finalSkuId + ":").concat(data.getMobile()));
+                                redisUtil.del(GoblinRedisConst.REDIS_BLACK.concat(finalSkuId + ":").concat(data.get(0)));
                             }
                         }
                     })).sheet().doRead();
                 }
+                aBoolean = true;
             }
         } catch (Exception e) {
             log.error("CONSUMER MSG EX_HANDLE ==> [{}]:{}", this.getRedisStreamKey(), message, e);