视频会员同步

SpringBatchServiceServer/src/main/java/com/zswl/cloud/springBtach/server/core/publish/Video2Publish.java

@@ -0,0 +1,83 @@
+package com.zswl.cloud.springBtach.server.core.publish;
+
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.json.JSONArray;
+import cn.hutool.json.JSONObject;
+import cn.hutool.json.JSONUtil;
+import com.eeext.openapi.entity.RechargeProductResp;
+import com.github.microservice.productcenter.client.model.LocationModel;
+import com.github.microservice.productcenter.client.model.ProductPushModel;
+import com.github.microservice.productcenter.client.model.ProductTriggerTaskModel;
+import com.github.microservice.productcenter.client.publish.ProductPublish;
+import com.github.microservice.productcenter.client.service.ProductPushService;
+import com.github.microservice.productcenter.client.stream.ProductCenterStream;
+import com.github.microservice.productcenter.client.type.ProductType;
+import com.github.microservice.productcenter.client.type.RegionType;
+import com.zswl.cloud.springBtach.server.core.api.video2.Video2Api;
+import com.zswl.cloud.springBtach.server.core.api.ypp.YppApi;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.math.BigDecimal;
+import java.util.Collection;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.stream.Collectors;
+
+@Slf4j
+@Component
+public class Video2Publish implements ProductPublish {
+
+    @Autowired
+    private ProductCenterStream productCenterStream;
+
+    @Autowired
+    private Video2Api video2Api;
+
+    @Override
+    public String regionCode() {
+        return null;
+    }
+
+    @Override
+    public Collection<RegionType> regionType() {
+        return Set.of(RegionType.City);
+    }
+
+    @Override
+    public Collection<ProductType> productTypes() {
+        return Set.of(
+                ProductType.Recharge
+        );
+    }
+
+
+    @Override
+    public void trigger(ProductPushService updateService, ProductTriggerTaskModel productTriggerTask) {
+        RechargeProductResp rechargeProductResp = video2Api.rechargeProduct();
+
+        rechargeProductResp.getProducts().forEach(it -> {
+            try {
+                BigDecimal bigDecimal = new BigDecimal(it.getChannelPrice());
+                BigDecimal multiply = bigDecimal.multiply(BigDecimal.valueOf(100));
+                productCenterStream.send(List.of(
+                        ProductPushModel.builder()
+                                .regionCode(productTriggerTask.getRegion().getCode())
+                                .pid(String.valueOf(it.getProductId()))
+                                .productType(ProductType.Cinema)
+                                .title(it.getItemName())
+                                .salePrice(multiply.longValue())
+                                .meta(Map.of("goods", it))
+                                .build()
+                ));
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+
+        });
+
+
+    }
+}

SpringBatchServiceServer/src/main/java/com/zswl/cloud/springBtach/server/core/publish/YqdPublish.java

@@ -1,91 +1,91 @@
-package com.zswl.cloud.springBtach.server.core.publish;
-
-import cn.hutool.json.JSONArray;
-import cn.hutool.json.JSONObject;
-import cn.hutool.json.JSONUtil;
-import com.alibaba.fastjson.JSON;
-import com.github.microservice.core.util.net.apache.ResponseModel;
-import com.github.microservice.productcenter.client.model.ProductPushModel;
-import com.github.microservice.productcenter.client.model.ProductTriggerTaskModel;
-import com.github.microservice.productcenter.client.publish.ProductPublish;
-import com.github.microservice.productcenter.client.service.ProductPushService;
-import com.github.microservice.productcenter.client.stream.ProductCenterStream;
-import com.github.microservice.productcenter.client.type.ProductType;
-import com.github.microservice.productcenter.client.type.RegionType;
-import com.zswl.cloud.shop.client.vo.yqd.CatalogVo;
-import com.zswl.cloud.shop.client.vo.yqd.CommodityVo;
-import com.zswl.cloud.springBtach.server.core.api.video.YqdServiceImpl;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
-
-import java.math.BigDecimal;
-import java.math.RoundingMode;
-import java.util.Collection;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-
-@Slf4j
-@Component
-public class YqdPublish implements ProductPublish {
-
-    @Autowired
-    YqdServiceImpl yqdService;
-
-
-    @Autowired
-    private ProductCenterStream productCenterStream;
-
-    @Override
-    public String regionCode() {
-        return null;
-    }
-
-    @Override
-    public Collection<RegionType> regionType() {
-        return Set.of(RegionType.City);
-    }
-
-    @Override
-    public Collection<ProductType> productTypes() {
-        return Set.of(
-                ProductType.Recharge
-        );
-    }
-
-
-    @Override
-    public void trigger(ProductPushService updateService, ProductTriggerTaskModel productTriggerTask) {
-
-        for (CatalogVo catalogVo : yqdService.getCatalog()) {
-            ResponseModel responseModel = yqdService.requestCommodityList("0", "100", catalogVo.getId());
-            JSONObject entries = JSONUtil.parseObj(responseModel.getBody());
-            JSONArray jsonArray = (JSONArray) entries.get("data");
-            if (!jsonArray.isEmpty()) {
-                List<CommodityVo> commodityVos = com.alibaba.fastjson.JSONArray.parseArray(JSON.toJSONString(jsonArray), CommodityVo.class);
-                commodityVos.forEach(it -> {
-                    BigDecimal price = it.getPrice();
-                    BigDecimal rate = price.multiply(new BigDecimal("0.06"));
-                    BigDecimal withdraw = price.add(rate).multiply(new BigDecimal("0.0028"));
-                    price = price.add(rate).add(withdraw).setScale(2, RoundingMode.UP);
-
-                    productCenterStream.send(List.of(
-                            ProductPushModel.builder()
-                                    .regionCode(productTriggerTask.getRegion().getCode())
-                                    .pid(it.getMainId().toString())
-                                    .productType(ProductType.Recharge)
-                                    .cover(new String[]{it.getMainImg()})
-                                    .title(it.getName())
-                                    .salePrice(price.multiply(BigDecimal.valueOf(100)).longValue())
-                                    .meta(Map.of("goods", it))
-                                    .build()));
-                });
-                System.out.println(commodityVos);
-            }
-
-        }
-
-
-    }
-}
+//package com.zswl.cloud.springBtach.server.core.publish;
+//
+//import cn.hutool.json.JSONArray;
+//import cn.hutool.json.JSONObject;
+//import cn.hutool.json.JSONUtil;
+//import com.alibaba.fastjson.JSON;
+//import com.github.microservice.core.util.net.apache.ResponseModel;
+//import com.github.microservice.productcenter.client.model.ProductPushModel;
+//import com.github.microservice.productcenter.client.model.ProductTriggerTaskModel;
+//import com.github.microservice.productcenter.client.publish.ProductPublish;
+//import com.github.microservice.productcenter.client.service.ProductPushService;
+//import com.github.microservice.productcenter.client.stream.ProductCenterStream;
+//import com.github.microservice.productcenter.client.type.ProductType;
+//import com.github.microservice.productcenter.client.type.RegionType;
+//import com.zswl.cloud.shop.client.vo.yqd.CatalogVo;
+//import com.zswl.cloud.shop.client.vo.yqd.CommodityVo;
+//import com.zswl.cloud.springBtach.server.core.api.video.YqdServiceImpl;
+//import lombok.extern.slf4j.Slf4j;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.stereotype.Component;
+//
+//import java.math.BigDecimal;
+//import java.math.RoundingMode;
+//import java.util.Collection;
+//import java.util.List;
+//import java.util.Map;
+//import java.util.Set;
+//
+//@Slf4j
+//@Component
+//public class YqdPublish implements ProductPublish {
+//
+//    @Autowired
+//    YqdServiceImpl yqdService;
+//
+//
+//    @Autowired
+//    private ProductCenterStream productCenterStream;
+//
+//    @Override
+//    public String regionCode() {
+//        return null;
+//    }
+//
+//    @Override
+//    public Collection<RegionType> regionType() {
+//        return Set.of(RegionType.City);
+//    }
+//
+//    @Override
+//    public Collection<ProductType> productTypes() {
+//        return Set.of(
+//                ProductType.Recharge
+//        );
+//    }
+//
+//
+//    @Override
+//    public void trigger(ProductPushService updateService, ProductTriggerTaskModel productTriggerTask) {
+//
+//        for (CatalogVo catalogVo : yqdService.getCatalog()) {
+//            ResponseModel responseModel = yqdService.requestCommodityList("0", "100", catalogVo.getId());
+//            JSONObject entries = JSONUtil.parseObj(responseModel.getBody());
+//            JSONArray jsonArray = (JSONArray) entries.get("data");
+//            if (!jsonArray.isEmpty()) {
+//                List<CommodityVo> commodityVos = com.alibaba.fastjson.JSONArray.parseArray(JSON.toJSONString(jsonArray), CommodityVo.class);
+//                commodityVos.forEach(it -> {
+//                    BigDecimal price = it.getPrice();
+//                    BigDecimal rate = price.multiply(new BigDecimal("0.06"));
+//                    BigDecimal withdraw = price.add(rate).multiply(new BigDecimal("0.0028"));
+//                    price = price.add(rate).add(withdraw).setScale(2, RoundingMode.UP);
+//
+//                    productCenterStream.send(List.of(
+//                            ProductPushModel.builder()
+//                                    .regionCode(productTriggerTask.getRegion().getCode())
+//                                    .pid(it.getMainId().toString())
+//                                    .productType(ProductType.Recharge)
+//                                    .cover(new String[]{it.getMainImg()})
+//                                    .title(it.getName())
+//                                    .salePrice(price.multiply(BigDecimal.valueOf(100)).longValue())
+//                                    .meta(Map.of("goods", it))
+//                                    .build()));
+//                });
+//                System.out.println(commodityVos);
+//            }
+//
+//        }
+//
+//
+//    }
+//}