销售订单同步 添加同步允许更新操作

jeecg-boot-module-system/src/main/java/org/jeecg/modules/documents/orderData/mapper/SyOrderDataItemMapper.java

@@ -20,4 +20,6 @@ public interface SyOrderDataItemMapper extends BaseMapper<SyOrderDataItem> {
      IPage<SyOrderDataItem> queryList(@Param("syOrderDataId") String syOrderDataId, Page<SyOrderDataItem> page);
 
      List<Map<String,String>> querySupplier();
+
+     void deleteByID(@Param("id") String id);
 }

jeecg-boot-module-system/src/main/java/org/jeecg/modules/documents/orderData/mapper/SyOrderDataMapper.java

@@ -16,4 +16,8 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  */
 public interface SyOrderDataMapper extends BaseMapper<SyOrderData> {
     IPage<SyOrderData> queryList(@Param("sy") SyOrderData sy, Page<SyOrderData> page);
+
+    void deleteByID(@Param("id") String id);
+
+    String queryIDBYOrderNumber(@Param("orderNumber") String orderNumber);
 }

jeecg-boot-module-system/src/main/java/org/jeecg/modules/documents/orderData/mapper/xml/SyOrderDataItemMapper.xml

@@ -25,4 +25,8 @@
     <select id="querySupplier" resultType="Map">
          select supplier_code,supplier from sy_order_data_item  where supplier!='' and supplier_code!='' group by supplier,supplier_code
     </select>
+
+    <delete id="deleteByID">
+        DELETE FROM sy_order_data_item where sy_order_data_id =  #{id}
+    </delete>
 </mapper>

jeecg-boot-module-system/src/main/java/org/jeecg/modules/documents/orderData/mapper/xml/SyOrderDataMapper.xml

@@ -83,5 +83,13 @@
         ORDER BY
             order_date DESC
     </select>
+    
+    <delete id="deleteByID">
+        DELETE FROM sy_order_data where id = #{id}
+    </delete>
+    
+    <select id="queryIDBYOrderNumber" resultType="String">
+        select id from sy_order_data where order_number=#{orderNumber}
+    </select>
 
 </mapper>

jeecg-boot-module-system/src/main/java/org/jeecg/modules/documents/orderData/service/ISyOrderDataItemService.java

@@ -17,4 +17,5 @@ import java.util.Map;
 public interface ISyOrderDataItemService extends IService<SyOrderDataItem> {
     IPage<SyOrderDataItem> queryList(String syOrderDataId, Page<SyOrderDataItem> page);
     List<Map<String,String>> querySupplier();
+    void deleteByID(String id);
 }

jeecg-boot-module-system/src/main/java/org/jeecg/modules/documents/orderData/service/ISyOrderDataService.java

@@ -15,4 +15,8 @@ public interface ISyOrderDataService extends IService<SyOrderData> {
      void doQuerySyOrder();
 
      IPage<SyOrderData> queryList(SyOrderData sy, Page<SyOrderData> page);
+
+     void deleteByID(String id);
+
+     String queryIDBYOrderNumber(String orderNumber);
 }

jeecg-boot-module-system/src/main/java/org/jeecg/modules/documents/orderData/service/impl/SyOrderDataItemServiceImpl.java

@@ -35,4 +35,9 @@ public class SyOrderDataItemServiceImpl extends ServiceImpl<SyOrderDataItemMappe
         return syOrderDataItemMapper.querySupplier();
     }
 
+    @Override
+    public void deleteByID(String id) {
+        syOrderDataItemMapper.deleteByID(id);
+    }
+
 }

jeecg-boot-module-system/src/main/java/org/jeecg/modules/documents/orderData/service/impl/SyOrderDataServiceImpl.java

@@ -62,6 +62,16 @@ public class SyOrderDataServiceImpl extends ServiceImpl<SyOrderDataMapper, SyOrd
         return syOrderDataMapper.queryList(sy,page);
     }
 
+    @Override
+    public void deleteByID(String id) {
+        syOrderDataMapper.deleteByID(id);
+    }
+
+    @Override
+    public String queryIDBYOrderNumber(String orderNumber) {
+        return syOrderDataMapper.queryIDBYOrderNumber(orderNumber);
+    }
+
     @Override
     public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
 

jeecg-boot-module-system/src/main/java/org/jeecg/modules/quartz/job/AddOrderJob.java

@@ -134,6 +134,12 @@ public class AddOrderJob implements Job,ApplicationContextAware {
                     sql=sql+" order by s.dDate desc ";
                 }else {
                     sql=sql+" s.cSOCode = "+this.parameter+" order by s.dDate desc ";
+                    //查找是否是更新数据，如为更新数据 删除老数据重新添加新数据
+                    String id = syOrderDataService.queryIDBYOrderNumber(this.parameter);
+                    if(id!=null){
+                        syOrderDataService.deleteByID(id);
+                        syOrderDataItemService.deleteByID(id);
+                    }
                 }
                 List<Map<String, Object>> list = new ArrayList<>();
                 if(pkorgValue[0].equals("one")){