更新定时任务

lhb-basic/lhb-basic-api/src/main/java/com/kxs/lhb/basic/api/constant/enums/ChannelCodeEnum.java

@@ -36,6 +36,13 @@ public enum ChannelCodeEnum {
         return CHANNEL_CODE_ENUM_MAP.get(ifCode);
     }
 
+    /**
+     * 获取所有通道列表
+     */
+    public static ChannelCodeEnum[] getChannelList() {
+        return ChannelCodeEnum.values();
+    }
+
 
     /**
      * 主通道

lhb-basic/lhb-basic-biz/src/main/java/com/kxs/lhb/basic/biz/service/impl/LhbGoodsServiceImpl.java

@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.github.yulichang.base.MPJBaseServiceImpl;
 import com.kxs.common.core.constant.CommonConstants;
 import com.kxs.common.core.exception.GlobalCustomerException;
+import com.kxs.lhb.basic.api.constant.enums.ChannelCodeEnum;
 import com.kxs.lhb.basic.api.dto.cusmoter.goods.NumbersDTO;
 import com.kxs.lhb.basic.api.dto.tongyi.NumbersReq;
 import com.kxs.lhb.basic.api.dto.tongyi.PackagesReq;
@@ -159,8 +160,13 @@ public class LhbGoodsServiceImpl extends MPJBaseServiceImpl<LhbGoodsMapper, LhbG
     public void goodsInfoTask() {
 
         List<LhbGoods> list = list(Wrappers.lambdaQuery(LhbGoods.class).eq(LhbGoods::getStatus, CommonConstants.SUCCESS));
+        ChannelCodeEnum[] channelList = ChannelCodeEnum.getChannelList();
 
-        List<PackagesRes> packages = channelFactory.getChannel(CommonConstants.DEFAULT_IF_CODE).getPackages(PackagesReq.builder().build());
+        List<PackagesRes> packages = new ArrayList<>();
+        for (ChannelCodeEnum channelCodeEnum : channelList) {
+            List<PackagesRes> packageIfCodeList = channelFactory.getChannel(channelCodeEnum.getCode()).getPackages(PackagesReq.builder().build());
+            packages.addAll(packageIfCodeList);
+        }
 
         list.forEach(goods -> {
             Optional<PackagesRes> first = packages.stream().filter(item -> goods.getExternalId().equals(item.getId())).findFirst();