Selaa lähdekoodia

数据入库,将表kuaishou_supply_chain_ceshi 改为 kuaishou_supply_chain

zhaoxian 6 kuukautta sitten
vanhempi
commit
0c36f296a7

+ 14 - 11
ruixuan-live/src/main/java/com/ruixuan/isc/controller/SupplyChainController.java

@@ -2219,6 +2219,8 @@ public class SupplyChainController extends BaseController {
                                 supplyChainService.updateOrder(eventJSon);
                             } else if ("kwaishop_distribute_activity_item_change".equals(event)) {
                                 supplyChainService.updateItem(eventJSon);
+                            } else if ("kwaishop_distribution_regimentalOrder".equals(event)) {
+                                supplyChainService.insertOrder(eventJSon);
                             }
                         }
                     } catch (Exception e) {
@@ -2328,17 +2330,6 @@ public class SupplyChainController extends BaseController {
         return result;
     }
 
-    @PostMapping(value = "/test111")
-    @ApiOperation(value = "---------测试")
-    public Map<String, Object> test111(@RequestBody JSONObject eventsEncoded) {
-
-        supplyChainService.insertOrder(eventsEncoded);
-        Map<String, Object> result = new HashMap<>();
-        result.put("result", 1);
-        return result;
-    }
-
-
     @PostMapping(value = "/dfcAccept")
     public Map<String, Object> dfcAccept(@RequestBody String eventsEncoded) {
         try {
@@ -2355,6 +2346,8 @@ public class SupplyChainController extends BaseController {
                                 supplyChainService.updateOrder(eventJSon);
                             } else if ("kwaishop_distribute_activity_item_change".equals(event)) {
                                 supplyChainService.updateItem(eventJSon);
+                            } else if ("kwaishop_distribution_regimentalOrder".equals(event)) {
+                                supplyChainService.insertOrder(eventJSon);
                             }
                         }
                     } catch (Exception e) {
@@ -2389,6 +2382,8 @@ public class SupplyChainController extends BaseController {
                                 supplyChainService.updateOrder(eventJSon);
                             } else if ("kwaishop_distribute_activity_item_change".equals(event)) {
                                 supplyChainService.updateItem(eventJSon);
+                            } else if ("kwaishop_distribution_regimentalOrder".equals(event)) {
+                                supplyChainService.insertOrder(eventJSon);
                             }
                         }
                     } catch (Exception e) {
@@ -2423,6 +2418,8 @@ public class SupplyChainController extends BaseController {
                                 supplyChainService.updateOrder(eventJSon);
                             } else if ("kwaishop_distribute_activity_item_change".equals(event)) {
                                 supplyChainService.updateItem(eventJSon);
+                            } else if ("kwaishop_distribution_regimentalOrder".equals(event)) {
+                                supplyChainService.insertOrder(eventJSon);
                             }
                         }
                     } catch (Exception e) {
@@ -2457,6 +2454,8 @@ public class SupplyChainController extends BaseController {
                                 supplyChainService.updateOrder(eventJSon);
                             } else if ("kwaishop_distribute_activity_item_change".equals(event)) {
                                 supplyChainService.updateItem(eventJSon);
+                            } else if ("kwaishop_distribution_regimentalOrder".equals(event)) {
+                                supplyChainService.insertOrder(eventJSon);
                             }
                         }
                     } catch (Exception e) {
@@ -2491,6 +2490,8 @@ public class SupplyChainController extends BaseController {
                                 supplyChainService.updateOrder(eventJSon);
                             } else if ("kwaishop_distribute_activity_item_change".equals(event)) {
                                 supplyChainService.updateItem(eventJSon);
+                            } else if ("kwaishop_distribution_regimentalOrder".equals(event)) {
+                                supplyChainService.insertOrder(eventJSon);
                             }
                         }
                     } catch (Exception e) {
@@ -2525,6 +2526,8 @@ public class SupplyChainController extends BaseController {
                                 supplyChainService.updateOrder(eventJSon);
                             } else if ("kwaishop_distribute_activity_item_change".equals(event)) {
                                 supplyChainService.updateItem(eventJSon);
+                            } else if ("kwaishop_distribution_regimentalOrder".equals(event)) {
+                                supplyChainService.insertOrder(eventJSon);
                             }
                         }
                     } catch (Exception e) {

+ 1 - 0
ruixuan-live/src/main/java/com/ruixuan/isc/service/impl/SupplyChainServiceImpl.java

@@ -801,6 +801,7 @@ public class SupplyChainServiceImpl implements ISupplyChainService {
             //新增
             if (1 == messageType) {
                 KuaishouSupplyChain supplyChain = new KuaishouSupplyChain(info);
+                log.info("新增订阅-oid:{}", supplyChain.getOid());
                 String ownership = null;
                 Criteria criteria = new Criteria();
                 criteria = Criteria.where("_id").is(supplyChain.getItemId());