调整供应链商品同步到自研的分类问题

src/main/java/zs/payment/controller/YunMallGoodsController.java

@@ -1,6 +1,7 @@
 package zs.payment.controller;
 
 
+import com.alibaba.fastjson.JSONObject;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -25,6 +26,7 @@ public class YunMallGoodsController {
      */
     @PostMapping("/save")
     public Boolean saveGoods(@Valid  @RequestBody GoodsSaveReq req){
+        log.info("---/yunmall/goods/save传入的参数为{}---", JSONObject.toJSONString(req));
         return goodsService.saveGoods(req.getGdId(),req.getOp());
     }
 

src/main/java/zs/payment/messages/KafkaConsumer.java

@@ -146,7 +146,7 @@ public class KafkaConsumer {
         groupId = "pay2-group"
     )
     @Transactional(rollbackFor = Exception.class)
-    public void goodsAlter(String messsage) {
+    public void goodsSync(String messsage) {
 
         log.info("---准备开始商品入库{}---",messsage);
         List<Integer> ids = JSONArray.parseArray(messsage, Integer.class);
@@ -219,8 +219,10 @@ public class KafkaConsumer {
                     goods.setIsrecommand(1);
                     //商品分类
                     goods.setPcate(pcate);
-                    goods.setPcates(pcate.toString());
-                    goods.setCcates(ccate.toString());
+                    goods.setCcate(ccate);
+                    goods.setTcate(tcate);
+//                    goods.setPcates(pcate.toString());
+//                    goods.setCcates(ccate.toString());
                     goods.setTcates(tcate.toString());
                     goods.setType(1);
                     //启用商品规格
@@ -237,7 +239,7 @@ public class KafkaConsumer {
                     //================价格====================
                     //原价-市场价
                     goods.setProductprice(new BigDecimal(dto.getGuide_price() / 100));
-                    //售价-用户需要支持的价格
+                    //售价-用户需要支付的价格
                     goods.setMarketprice(new BigDecimal(dto.getMarket_price() / 100));
                     // 生态供应价
                     goods.setCostprice(new BigDecimal(0));
@@ -253,6 +255,8 @@ public class KafkaConsumer {
                     goods.setIsnew(0);
                     goods.setIshot(0);
                     goods.setIsdiscount(0);
+                    //默认值，避免金额为0
+                    goods.setWeight(new BigDecimal(1));
                     //商品来源
                     goods.setSupply_source("yunxin");
                     //芸信商城的商品主键
@@ -344,7 +348,7 @@ public class KafkaConsumer {
             });
             log.info("=======productId:{} goodsAlter end=======", ids);
         } else {
-            log.error("kafka consumer goods.alter 商品{}详情查询失败", messsage);
+            log.error("kafka consumer goods.sync 商品{}详情查询失败", messsage);
         }
 
 

src/main/java/zs/payment/service/supply/product/impl/ProductSupplyServiceImpl.java

@@ -120,7 +120,8 @@ public class ProductSupplyServiceImpl implements ProductSupplyService {
                 Map<String, Object> params = new HashMap<>();
                 params.put("page", page);
                 params.put("pageSize", pageSize);
-                params.put("create_sort", "desc");
+                //1-倒序 2-升序
+                params.put("create_sort", 1);
 
                 String resp = HttpUtil.restTemplatePost(
                     prefixUrl + "/supplyapi/app/product/storage/getMyStorageIdsList",