diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/mapper/PlatformOrderMapper.java b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/mapper/PlatformOrderMapper.java index 5871009d7..150d2e61f 100644 --- a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/mapper/PlatformOrderMapper.java +++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/mapper/PlatformOrderMapper.java @@ -13,6 +13,7 @@ import org.jeecg.modules.business.vo.clientPlatformOrder.section.OrderQuantity; import org.springframework.stereotype.Repository; import java.time.LocalDateTime; +import java.util.Collection; import java.util.Date; import java.util.List; import java.util.Map; @@ -224,4 +225,6 @@ public interface PlatformOrderMapper extends BaseMapper { void anonymizePersonalData(@Param("period") int indirectClientAnonymizationPeriod); List ordersByShop(@Param("shopID") String shopID); + + void updateShopifySynced(@Param("platformOrderIds") Collection platformOrderIds); } diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/mapper/xml/PlatformOrderMapper.xml b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/mapper/xml/PlatformOrderMapper.xml index ba302500b..cdd85c385 100644 --- a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/mapper/xml/PlatformOrderMapper.xml +++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/mapper/xml/PlatformOrderMapper.xml @@ -463,6 +463,7 @@ #{shop} AND ready_for_shopify_sync = 1 + AND shopify_synced = 0 AND erp_status = 3 ORDER BY shipping_time; @@ -898,4 +899,13 @@ WHERE shop_id = #{shopID} AND erp_status IN (1,2,3) + + + UPDATE platform_order + SET shopify_synced = 1 + WHERE platform_order_id IN + + #{platformOrderId} + + diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/service/IPlatformOrderService.java b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/service/IPlatformOrderService.java index 9b38243a3..b9b9b68dc 100644 --- a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/service/IPlatformOrderService.java +++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/service/IPlatformOrderService.java @@ -248,4 +248,6 @@ public interface IPlatformOrderService extends IService { void anonymizePersonalData(int indirectClientAnonymizationPeriod); List ordersByShop(String shopID); + + void updateShopifySynced(Collection platformOrderIds); } diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/service/impl/PlatformOrderServiceImpl.java b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/service/impl/PlatformOrderServiceImpl.java index d2c4cd04b..4f125d788 100644 --- a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/service/impl/PlatformOrderServiceImpl.java +++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/business/service/impl/PlatformOrderServiceImpl.java @@ -501,4 +501,9 @@ public class PlatformOrderServiceImpl extends ServiceImpl ordersByShop(String shopID) { return platformOrderMap.ordersByShop(shopID); } + + @Override + public void updateShopifySynced(Collection platformOrderIds) { + platformOrderMap.updateShopifySynced(platformOrderIds); + } }