添加线程发送消息

base-manager/src/main/java/com/mortals/xhx/common/utils/SendSkinRefreshTask.java

+package com.mortals.xhx.common.utils;
+
+import com.mortals.framework.util.HttpUtil;
+import com.mortals.xhx.feign.skin.ISkinFillFeign;
+import com.mortals.xhx.feign.skin.ISkinSampleFeign;
+import com.mortals.xhx.utils.SpringUtils;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import javax.annotation.PostConstruct;
+import java.util.HashMap;
+import java.util.Map;
+
+import static com.mortals.framework.util.HttpUtil.HEADER_CONTENT_TYPE;
+
+/**
+ * 发通知第三方
+ *
+ * @author: zxfei
+ * @date: 2022/4/28 10:56
+ * @description:
+ **/
+@Slf4j
+public class SendSkinRefreshTask implements Runnable {
+
+    private ISkinSampleFeign skinSampleFeign;
+
+    private ISkinFillFeign skinFillFeign;
+
+    @PostConstruct
+    public void init() {
+        skinSampleFeign = SpringUtils.getBean(ISkinSampleFeign.class);
+        skinFillFeign = SpringUtils.getBean(ISkinFillFeign.class);
+    }
+
+    @Override
+    public void run() {
+        String resp = null;
+        try {
+            Thread.sleep(2000L);
+            skinSampleFeign.refreshSkin();
+            skinFillFeign.refreshSkin();
+        } catch (Exception e) {
+            log.error("异常:", e);
+        }
+    }
+}

base-manager/src/main/java/com/mortals/xhx/module/skin/service/impl/SkinBaseServiceImpl.java

@@ -11,12 +11,14 @@ import com.mortals.framework.exception.AppException;
 import com.mortals.framework.model.Context;
 import com.mortals.framework.model.PageInfo;
 import com.mortals.framework.service.impl.AbstractCRUDServiceImpl;
+import com.mortals.framework.util.ThreadPool;
 import com.mortals.xhx.base.system.param.service.ParamService;
 import com.mortals.xhx.base.system.upload.service.UploadService;
 import com.mortals.xhx.common.code.FiletypeEnum;
 import com.mortals.xhx.common.key.Constant;
 import com.mortals.xhx.common.utils.BeanUtil;
 import com.mortals.xhx.common.utils.FreeMarkerUtils;
+import com.mortals.xhx.common.utils.SendSkinRefreshTask;
 import com.mortals.xhx.feign.skin.ISkinFillFeign;
 import com.mortals.xhx.feign.skin.ISkinSampleFeign;
 import com.mortals.xhx.module.product.model.ProductEntity;
@@ -102,7 +104,7 @@ public class SkinBaseServiceImpl extends AbstractCRUDServiceImpl<SkinBaseDao, Sk
 
         for (SkinBaseEntity item : list) {
             List<SkinFieldEntity> skinFieldEntities = skinFieldService.find(new SkinFieldQuery().skinId(item.getId()));
-          //  String domain = GlobalSysInfo.getParamValue(Constant.DOMAIN, "http://192.168.0.98:11071/");
+            //  String domain = GlobalSysInfo.getParamValue(Constant.DOMAIN, "http://192.168.0.98:11071/");
             for (SkinFieldEntity field : skinFieldEntities) {
                 if ("2".equals(field.getFieldType())) {
                     String fieldUrl = String.format("%s/%s", domainUrl, field.getFieldValue());
@@ -116,9 +118,9 @@ public class SkinBaseServiceImpl extends AbstractCRUDServiceImpl<SkinBaseDao, Sk
             item.setImageResolutionValue(imageResolutionMap.get(entity.getImageResolution() == null ? "1" : entity.getImageResolution()));
             item.setSkinFieldList(skinFieldEntities);
             if (!ObjectUtils.isEmpty(item.getPreviewImagePath())) {
-               // UrlBuilder builder = UrlBuilder.ofHttp(domainUrl, CharsetUtil.CHARSET_UTF_8).addPath(item.getPreviewImagePath());
+                // UrlBuilder builder = UrlBuilder.ofHttp(domainUrl, CharsetUtil.CHARSET_UTF_8).addPath(item.getPreviewImagePath());
                 String fieldUrl = String.format("%s/%s", domainUrl, item.getPreviewImagePath());
-               // item.setPreviewImagePath(builder.build());
+                // item.setPreviewImagePath(builder.build());
                 item.setPreviewImagePath(fieldUrl);
                 //log.info("cssUrl:" + URLDecoder.decode(item.getPreviewImagePath(), CharsetUtil.CHARSET_UTF_8));
             }
@@ -167,9 +169,9 @@ public class SkinBaseServiceImpl extends AbstractCRUDServiceImpl<SkinBaseDao, Sk
             });
             skinFieldService.save(entity.getSkinFieldList(), context);
         }
-        //通知子系统同步皮肤数据
-        skinSampleFeign.refreshSkin();
-        skinFillFeign.refreshSkin();
+
+        SendSkinRefreshTask sendSkinRefreshTask = new SendSkinRefreshTask();
+        ThreadPool.getInstance().execute(sendSkinRefreshTask);
     }
 
     @Override

base-manager/src/test/java/com/mortals/httpclient/app/AppController.http

@@ -23,9 +23,12 @@ client.global.set("authToken", JSON.parse(response.body).data.token);
 POST {{baseUrl}}/app/list
 Content-Type: application/json
 
-
-
-{"siteId":"22",appTypeList,"page":1,"size":-1}
+{
+  "siteId": 1,
+  "appTypeNotList": [4],
+  "page": 1,
+  "size": -1
+}
 
 
 ###自助终端应用更新与保存

base-manager/src/test/java/com/mortals/httpclient/skin/SkinBaseController.http

@@ -4,7 +4,7 @@ POST {{baseUrl}}/skin/base/list
 Content-Type: application/json
 
 {
-  "fieldName": "背景大图",
+  "productName": "样表机",
   "page": 1,
   "size": 10
 }