no message

kxs-transfer/src/main/java/com/kxs/transfer/api/controller/DtsController.java

@@ -14,6 +14,7 @@ import com.kxs.transfer.api.service.KxsDtsErrorLogService;
 import com.kxs.transfer.api.service.KxsDtsLogService;
 import com.kxs.transfer.api.service.product.*;
 import com.kxs.transfer.api.service.product.impl.KxsMachineTrackService;
+import com.kxs.transfer.api.service.product.impl.KxsShopOrderService;
 import com.kxs.transfer.api.service.store.KxsMachineRecycleService;
 import com.kxs.transfer.api.service.store.KxsWarehouseService;
 import com.kxs.transfer.api.service.sys.KxsMorningLogService;
@@ -77,6 +78,7 @@ public class DtsController {
     private final KxsMerchantService kxsMerchantService;
     private final KxsMachineTransferService kxsMachineTransferService;
     private final KxsMachineTrackService kxsMachineTrackService;
+    private final KxsShopOrderService kxsShopOrderService;
 
     //仓库模块
     private final KxsWarehouseService kxsWarehouseService;
@@ -197,6 +199,14 @@ public class DtsController {
             if ("Products".equals(dmlData.getTableName())) {
                 kxsShopGoodsService.changeData(dmlData);
             }
+            //商品订单同步
+            if ("Orders".equals(dmlData.getTableName())) {
+                kxsShopOrderService.changeData(dmlData);
+            }
+            //商品订单详情
+            if ("OrderProduct".equals(dmlData.getTableName())) {
+                kxsShopOrderService.changeInfoData(dmlData);
+            }
             //每日晨会同步
             if ("SchoolMorningMeet".equals(dmlData.getTableName())) {
                 kxsMorningService.changeData(dmlData);

kxs-transfer/src/main/java/com/kxs/transfer/api/mapper/product/KxsShopOrderInfoMapper.java

@@ -0,0 +1,19 @@
+package com.kxs.transfer.api.mapper.product;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.kxs.product.api.model.KxsShopOrderInfo;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * 商城订单详情表(KxsShopOrderInfo)表数据库访问层
+ *
+ * @author 系统
+ * @since 2023-12-20 10:09:35
+ */
+@Mapper
+@DS("product")
+public interface KxsShopOrderInfoMapper extends BaseMapper<KxsShopOrderInfo> {
+
+}
+

kxs-transfer/src/main/java/com/kxs/transfer/api/mapper/product/KxsShopOrderMapper.java

@@ -0,0 +1,23 @@
+package com.kxs.transfer.api.mapper.product;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.kxs.product.api.model.KxsShopOrder;
+import com.kxs.product.api.vo.kxsapp.shop.ShopOrderListVO;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+/**
+ * 商城订单表(KxsShopOrder)表数据库访问层
+ *
+ * @author 系统
+ * @since 2023-12-20 10:09:35
+ */
+@Mapper
+@DS("product")
+public interface KxsShopOrderMapper extends BaseMapper<KxsShopOrder> {
+
+}
+

kxs-transfer/src/main/java/com/kxs/transfer/api/service/product/impl/KxsShopOrderInfoServiceImpl.java

@@ -0,0 +1,18 @@
+package com.kxs.transfer.api.service.product.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.kxs.product.api.model.KxsShopOrderInfo;
+import com.kxs.transfer.api.mapper.product.KxsShopOrderInfoMapper;
+import org.springframework.stereotype.Service;
+
+/**
+ * 商城订单详情表(KxsShopOrderInfo)表服务实现类
+ *
+ * @author 系统
+ * @since 2023-12-20 10:09:36
+ */
+@Service("kxsShopOrderInfoService")
+public class KxsShopOrderInfoServiceImpl extends ServiceImpl<KxsShopOrderInfoMapper, KxsShopOrderInfo>  {
+
+}
+

kxs-transfer/src/main/java/com/kxs/transfer/api/service/product/impl/KxsShopOrderService.java

@@ -0,0 +1,31 @@
+package com.kxs.transfer.api.service.product.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.kxs.product.api.model.KxsShopOrder;
+import com.kxs.transfer.api.mapper.product.KxsShopOrderInfoMapper;
+import com.kxs.transfer.api.mapper.product.KxsShopOrderMapper;
+import com.kxs.transfer.api.model.table.DMLData;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+/**
+ * 商城订单表(KxsShopOrder)表服务实现类
+ *
+ * @author 系统
+ * @since 2023-12-20 10:09:35
+ */
+@Service("kxsShopOrderService")
+@RequiredArgsConstructor
+public class KxsShopOrderService extends ServiceImpl<KxsShopOrderMapper, KxsShopOrder>  {
+
+    private final KxsShopOrderInfoMapper kxsShopOrderInfoMapper;
+
+    public void changeData(DMLData dmlData) {
+
+    }
+
+    public void changeInfoData(DMLData dmlData) {
+
+    }
+}
+