sap库存同步调整为先删除数据再插入

op-modules/op-sap/src/main/java/com/op/sap/mapper/SapBaseProductMapper.java

@@ -69,5 +69,7 @@ public interface SapBaseProductMapper {
 
     void UpdateSapZmesGetMchb(SapZmesGetMchb sapZmesGetMchb1);
 
+    void deleteSapOdsMateStorage();
+
     void insertSapZmesGetMchb(SapZmesGetMchb sapZmesGetMchb1);
 }

op-modules/op-sap/src/main/java/com/op/sap/service/impl/SapItemSyncImpl.java

@@ -1334,6 +1334,12 @@ public class SapItemSyncImpl implements SapItemSyncService {
                 log.info("物料号:"+MATNR+"工厂:"+WERKS+"库存地点:"+LGORT+"批号:"+CHARG+"物料描述:"+MAKTX+"物料组:"+MATKL+
                         "基本计量单位:"+MEINS+"非限制库存:"+CLABS+"质检库存:"+CINSM+"限制库存:"+CEINM+"冻结库存:"+CSPEM);
             }
+
+            //先删除数据后再插入
+            sapBaseProductMapper.deleteSapOdsMateStorage();
+
+            //批量插入数据
+
             for (SapZmesGetMchb sapZmesGetMchb1:
             sapZmesGetMchbs) {
                 SapZmesGetMchb      sapZmesGetMchb2=new SapZmesGetMchb();//
@@ -1344,31 +1350,18 @@ public class SapItemSyncImpl implements SapItemSyncService {
                 sapZmesGetMchb2.setMaktx(sapZmesGetMchb1.getMaktx());
                 sapZmesGetMchb2.setMatkl(sapZmesGetMchb1.getMatkl());
                 sapZmesGetMchb2.setMeins(sapZmesGetMchb1.getMeins());
-                SapZmesGetMchb  sapZmesGetMchb3=  sapBaseProductMapper.selectSapZmesGetMchb(sapZmesGetMchb2);
+                sapZmesGetMchb1.setStorageId(IdUtils.fastSimpleUUID());
-                if (sapZmesGetMchb3!=null){//修改
+                sapZmesGetMchb1.setClabs(sapZmesGetMchb1.getClabs());
-                    sapZmesGetMchb1.setClabs(sapZmesGetMchb1.getClabs());
+                sapZmesGetMchb1.setCinsm(sapZmesGetMchb1.getCinsm());
-                    sapZmesGetMchb1.setCinsm(sapZmesGetMchb1.getCinsm());
+                sapZmesGetMchb1.setMeins(sapZmesGetMchb1.getMeins());
-                    sapZmesGetMchb1.setMeins(sapZmesGetMchb1.getMeins());
+                sapZmesGetMchb1.setCeinm(sapZmesGetMchb1.getCeinm());
-                    sapZmesGetMchb1.setCeinm(sapZmesGetMchb1.getCeinm());
+                sapZmesGetMchb1.setCspem(sapZmesGetMchb1.getCspem());
-                    sapZmesGetMchb1.setCspem(sapZmesGetMchb1.getCspem());
+                sapZmesGetMchb1.setCreateBy("task");
-                    sapZmesGetMchb1.setStorageId(sapZmesGetMchb3.getStorageId());
+                sapZmesGetMchb1.setActiveFlag("1");
-                    sapZmesGetMchb1.setCreateBy("task");
+                sapZmesGetMchb1.setGmtCreate(new Date());
-                    sapZmesGetMchb1.setGmtCreate(new Date());
+                sapZmesGetMchb1.setFactoryCode(sapZmesGetMchb1.getWerks());
-                    sapBaseProductMapper.UpdateSapZmesGetMchb(sapZmesGetMchb1);
+                sapZmesGetMchb1.setSapFactoryCode(sapZmesGetMchb1.getWerks());
-                }else {//添加
+                sapBaseProductMapper.insertSapZmesGetMchb(sapZmesGetMchb1);
-                    sapZmesGetMchb1.setStorageId(IdUtils.fastSimpleUUID());
-                    sapZmesGetMchb1.setClabs(sapZmesGetMchb1.getClabs());
-                    sapZmesGetMchb1.setCinsm(sapZmesGetMchb1.getCinsm());
-                    sapZmesGetMchb1.setMeins(sapZmesGetMchb1.getMeins());
-                    sapZmesGetMchb1.setCeinm(sapZmesGetMchb1.getCeinm());
-                    sapZmesGetMchb1.setCspem(sapZmesGetMchb1.getCspem());
-                    sapZmesGetMchb1.setCreateBy("task");
-                    sapZmesGetMchb1.setActiveFlag("1");
-                    sapZmesGetMchb1.setGmtCreate(new Date());
-                    sapZmesGetMchb1.setFactoryCode(sapZmesGetMchb1.getWerks());
-                    sapZmesGetMchb1.setSapFactoryCode(sapZmesGetMchb1.getWerks());
-                    sapBaseProductMapper.insertSapZmesGetMchb(sapZmesGetMchb1);
-                }
             }
             return R.ok();
         } catch (Exception e) {

op-modules/op-sap/src/main/resources/mapper/sap/SapBaseProductMapper.xml

@@ -301,6 +301,11 @@
             gmt_modified=getdate()
         where storage_id=#{storageId}
     </update>
+
+    <delete id="deleteSapOdsMateStorage">
+        delete from sap_ods_mate_storage_news
+    </delete>
+
     <insert id="insertSapZmesGetMchb"   parameterType="com.op.system.api.domain.sap.SapZmesGetMchb"     >
         insert into sap_ods_mate_storage_news
         <trim prefix="(" suffix=")" suffixOverrides=",">