添加皮肤相关

fill-manager/src/main/java/com/mortals/xhx/daemon/task/SyncSiteDeviceTaskImpl.java

@@ -130,13 +130,13 @@ public class SyncSiteDeviceTaskImpl implements ITaskExcuteService {
     private void syncSkin() {
 
         SkinBasePdu skinBasePdu = new SkinBasePdu();
-        skinBasePdu.setProductName("填单机");
+        skinBasePdu.setProductName("样表机");
         skinBasePdu.setSize(-1);
 
         Rest<RespData<List<SkinBasePdu>>> skinBaseRest = skinBaseFeign.list(skinBasePdu);
         if (skinBaseRest.getCode() == YesNoEnum.YES.getValue()) {
             List<SkinBasePdu>  skinBasePduList = skinBaseRest.getData().getData();
-            log.info("填单机皮肤总数量：{}", skinBasePduList.size());
+            log.info("样表机皮肤总数量：{}", skinBasePduList.size());
             if (!ObjectUtils.isEmpty(skinBasePduList)) {
                 List<SkinEntity> newSkinList = skinBasePduList.stream().map(newSkin -> {
                     SkinEntity skinEntity = new SkinEntity();
@@ -147,6 +147,8 @@ public class SyncSiteDeviceTaskImpl implements ITaskExcuteService {
 
                 List<SkinEntity> oldSkinList = skinService.find(new SkinQuery());
                 Map<Long, SkinEntity> oldSkinMap = oldSkinList.stream().collect(Collectors.toMap(x -> x.getId(), y -> y, (o, n) -> n));
+                Map<Long, SkinEntity> newSkinMap = newSkinList.stream().collect(Collectors.toMap(x -> x.getId(), y -> y, (o, n) -> n));
+
 
 
                 List<SkinEntity> updateSkinLsit = newSkinList.stream().map(item -> {
@@ -169,6 +171,15 @@ public class SyncSiteDeviceTaskImpl implements ITaskExcuteService {
                 }).filter(f -> f != null).collect(Collectors.toList());
 
 
+                //做差集
+                List<Long> delSkinList = oldSkinList.stream().map(item -> {
+                    if (!newSkinMap.containsKey(item.getId())) {
+                        return item.getId();
+                    }
+                    return null;
+                }).filter(f -> f != null).collect(Collectors.toList());
+
+
                 if (!ObjectUtils.isEmpty(updateSkinLsit)) {
                     log.info("皮肤更新，size:{}", updateSkinLsit.size());
                     skinService.update(updateSkinLsit);
@@ -179,6 +190,11 @@ public class SyncSiteDeviceTaskImpl implements ITaskExcuteService {
                     skinService.save(saveSkinList);
                 }
 
+                if (!ObjectUtils.isEmpty(delSkinList)) {
+                    log.info("皮肤删除，size:{}", delSkinList.size());
+                    skinService.remove(delSkinList,null);
+                }
+
             }
         }
     }