diff --git a/src/main/java/com/czg/mergedata/cur/service/impl/CurProdSkuServiceImpl.java b/src/main/java/com/czg/mergedata/cur/service/impl/CurProdSkuServiceImpl.java
index b634fdd..db544db 100644
--- a/src/main/java/com/czg/mergedata/cur/service/impl/CurProdSkuServiceImpl.java
+++ b/src/main/java/com/czg/mergedata/cur/service/impl/CurProdSkuServiceImpl.java
@@ -61,7 +61,9 @@ public class CurProdSkuServiceImpl extends ServiceImpl<CurProdSkuMapper, CurProd
             curProdSku.setProductId(Long.valueOf(oldProductSku.getProductId()));
             curProdSku.setOriginPrice(oldProductSku.getOriginPrice());
             curProdSku.setCostPrice(oldProductSku.getCostPrice());
-            curProdSku.setMemberPrice(oldProductSku.getMemberPrice());
+//            curProdSku.setMemberPrice(oldProductSku.getMemberPrice());
+            curProdSku.setMemberPrice((oldProductSku.getMemberPrice() == null || oldProductSku.getMemberPrice().compareTo(BigDecimal.ZERO) <= 0)
+                    ? oldProductSku.getSalePrice() : oldProductSku.getMemberPrice());
             curProdSku.setSalePrice(oldProductSku.getSalePrice());
             curProdSku.setSuitNum(oldProductSku.getSuit());
             curProdSku.setSpecInfo(oldProductSku.getSpecSnap());
diff --git a/src/main/java/com/czg/mergedata/cur/service/impl/CurShopPayTypeServiceImpl.java b/src/main/java/com/czg/mergedata/cur/service/impl/CurShopPayTypeServiceImpl.java
index 721e97c..fbd8a38 100644
--- a/src/main/java/com/czg/mergedata/cur/service/impl/CurShopPayTypeServiceImpl.java
+++ b/src/main/java/com/czg/mergedata/cur/service/impl/CurShopPayTypeServiceImpl.java
@@ -11,6 +11,8 @@ import com.czg.mergedata.cur.service.CurShopPayTypeService;
 import jakarta.annotation.Resource;
 import org.springframework.stereotype.Service;
 
+import java.util.Date;
+
 /**
  * 店铺支付类型 服务层实现。
  *
@@ -27,8 +29,8 @@ public class CurShopPayTypeServiceImpl extends ServiceImpl<CurShopPayTypeMapper,
         mapper.truncateTable();
         oldShopPayTypeService.list().forEach(item -> {
             CurShopPayType payType = BeanUtil.copyProperties(item, CurShopPayType.class);
-            payType.setCreateTime(DateUtil.date(item.getCreatedAt()).toLocalDateTime());
-            payType.setUpdateTime(DateUtil.date(item.getUpdatedAt()).toLocalDateTime());
+            payType.setCreateTime(DateUtil.toLocalDateTime(item.getCreatedAt() == null ? new Date() : new Date(item.getCreatedAt())));
+            payType.setUpdateTime(DateUtil.toLocalDateTime(item.getUpdatedAt() == null ? new Date() : new Date(item.getUpdatedAt())));
             save(payType);
         });
         return null;
diff --git a/src/main/java/com/czg/mergedata/old/mapper/OldShopPayTypeMapper.java b/src/main/java/com/czg/mergedata/old/mapper/OldShopPayTypeMapper.java
index 51010fc..7e64662 100644
--- a/src/main/java/com/czg/mergedata/old/mapper/OldShopPayTypeMapper.java
+++ b/src/main/java/com/czg/mergedata/old/mapper/OldShopPayTypeMapper.java
@@ -1,5 +1,6 @@
 package com.czg.mergedata.old.mapper;
 
+import com.mybatisflex.annotation.UseDataSource;
 import com.mybatisflex.core.BaseMapper;
 import com.czg.mergedata.old.entity.OldShopPayType;
 
@@ -9,6 +10,7 @@ import com.czg.mergedata.old.entity.OldShopPayType;
  * @author Administrator
  * @since 2025-03-25
  */
+@UseDataSource("ds2")
 public interface OldShopPayTypeMapper extends BaseMapper<OldShopPayType> {
 
 }