【用友物料同步】ts信息获取

mes-module-majoys/mes-module-majoys-biz/src/main/java/com/chanko/yunxi/mes/module/biz/dal/mysql/material/MaterialMapper.java

@@ -50,6 +50,13 @@ public interface MaterialMapper extends BaseMapperX<MaterialDO> {
         return selectPage(reqVO, query);
     }
 
+    default MaterialDO selectMaxts(){
+        MPJLambdaWrapperX<MaterialDO> query = new MPJLambdaWrapperX<>();
+        query.selectAll(MaterialDO.class).last("LIMIT 1").orderByDesc(MaterialDO::getTs);
+
+        return selectOne(query);
+    }
+
     default List<Map<String, Object>> selectSimpleList() {
 
         return selectMaps(new QueryWrapper<MaterialDO>().select("id", "name","short_name","code","material_type","spec","unit","brand").eq("virtual_part", YesOrNoEnum.N.name()).lambda());

mes-module-majoys/mes-module-majoys-biz/src/main/java/com/chanko/yunxi/mes/module/biz/manager/ChanjetManager.java

@@ -553,9 +553,10 @@ public class ChanjetManager {
         // 设置为“否”，关闭所有与用友通信的接口
         if(!getSystemParameters()) return ;
 
-        MaterialDO materialDOMaxTs = materialMapper.selectList(new LambdaUpdateWrapper<MaterialDO>(){{
-            orderByDesc(MaterialDO::getTs);
-        }}).get(0);
+//        MaterialDO materialDOMaxTs = materialMapper.selectList(new LambdaUpdateWrapper<MaterialDO>(){{
+//            orderByDesc(MaterialDO::getTs);
+//        }}).get(0);
+        MaterialDO materialDOMaxTs = materialMapper.selectMaxts();
 
         String maxTs = materialDOMaxTs== null?null:materialDOMaxTs.getTs();
         HashSet<Long> materialIds = new HashSet<>();
@@ -677,13 +678,15 @@ public class ChanjetManager {
 
         }while (maxTs != null);
 
-        // 删除
-        LambdaQueryWrapper<MaterialDO> wrapper = new LambdaQueryWrapper<MaterialDO>(){{
-        }};
+
         if(!materialIds.isEmpty()){
+            // 删除
+            LambdaQueryWrapper<MaterialDO> wrapper = new LambdaQueryWrapper<MaterialDO>(){{
+            }};
             wrapper.notIn(MaterialDO::getId, materialIds);
+            materialMapper.delete(wrapper);
         }
-        materialMapper.delete(wrapper);
+
     }
 
     private void saveMaterialColor(List<QueryMaterialFreeItemBriefResVO> freeitembriefinfo,Long matId){