同步单据相关修改

src/main/java/com/glxp/api/controller/sync/SpsSyncDownloadController.java

@@ -94,7 +94,7 @@ public class SpsSyncDownloadController {
     }
 
     //    接收中继服务、UDI管理系统上传单据
-//    @AuthRuleAnnotation("sps/sync/order/upload")
+    @AuthRuleAnnotation("sps/sync/order/upload")
     @PostMapping("/sps/sync/order/upload")
     public BaseResponse save(@RequestBody @Valid SpsSyncOrderResponse syncDataResponse) {
         BasicDownloadStatusEntity basicDownloadStatusEntity = new BasicDownloadStatusEntity();
@@ -221,7 +221,7 @@ public class SpsSyncDownloadController {
 
 
     //    接收中级服务，UDI管理系统上传业务单据
-//    @AuthRuleAnnotation("/sps/sync/busOrder/upload")
+    @AuthRuleAnnotation("/sps/sync/busOrder/upload")
     @PostMapping("/sps/sync/busOrder/upload")
     public BaseResponse busOrderSava(@RequestBody @Valid SpsSyncBusOrderResponse spsSyncBusOrderResponse) {
         BasicDownloadStatusEntity basicDownloadStatusEntity = new BasicDownloadStatusEntity();

src/main/java/com/glxp/api/service/inout/IoOrderService.java

@@ -7,6 +7,7 @@ import com.glxp.api.req.inout.FilterUploadOrderRequest;
 import com.glxp.api.req.inout.OrderEditRequest;
 import com.glxp.api.res.inout.IoOrderResponse;
 
+import java.util.Date;
 import java.util.List;
 
 public interface IoOrderService {
@@ -22,7 +23,7 @@ public interface IoOrderService {
 
     IoOrderEntity findByBillNo(String billNO);
 
-    List<IoOrderEntity> findByStatus(String action, Integer status);
+    List<IoOrderEntity> findByStatus(String action, Integer status, Date lastUpdateTime);
 
     int insertOrder(IoOrderEntity orderEntity);
 

src/main/java/com/glxp/api/service/inout/impl/IoOrderServiceImpl.java

@@ -138,10 +138,11 @@ public class IoOrderServiceImpl implements IoOrderService {
     }
 
     @Override
-    public List<IoOrderEntity> findByStatus(String action, Integer status) {
-        return orderDao.selectList(new QueryWrapper<IoOrderEntity>().eq("action", action).eq("status", status));
+    public List<IoOrderEntity> findByStatus(String action, Integer status, Date lastUpdateTime) {
+        return orderDao.selectList(new QueryWrapper<IoOrderEntity>().eq("action", action).eq("status", status).gt("updateTime", lastUpdateTime));
     }
 
+
     @Override
     public int insertOrder(IoOrderEntity orderEntity) {
         orderEntity.setId(null);

src/main/java/com/glxp/api/service/sync/SpsSyncDownloadService.java

@@ -15,6 +15,7 @@ import com.glxp.api.res.sync.SpsSyncOrderResponse;
 import com.glxp.api.res.system.SyncDataSetResponse;
 import com.glxp.api.service.inout.*;
 import com.glxp.api.util.CustomUtil;
+import com.glxp.api.util.DateUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
@@ -82,7 +83,7 @@ public class SpsSyncDownloadService {
         BeanUtils.copyProperties(spsSyncDataRequest, orderFilterRequest);
         if (CollUtil.isNotEmpty(syncDataSetEntity.getBusTypes())) {
             for (SyncDataBustypeEntity syncDataBustypeEntity : syncDataSetEntity.getBusTypes()) {
-                List<IoOrderEntity> temps = orderService.findByStatus(syncDataBustypeEntity.getAction(), syncDataBustypeEntity.getOrderStatus());
+                List<IoOrderEntity> temps = orderService.findByStatus(syncDataBustypeEntity.getAction(), syncDataBustypeEntity.getOrderStatus(), DateUtil.parseDate(spsSyncDataRequest.getLastUpdateTime()));
                 if (CollUtil.isNotEmpty(temps)) {
                     orderEntities.addAll(temps);
                 }