1

src/main/java/com/fdkankan/manage/config/SaTokenConfigure.java

@@ -46,7 +46,7 @@ public class SaTokenConfigure {
     public SaServletFilter getSaServletFilter() {
         return new SaServletFilter()
                 // 指定 拦截路由 与 放行路由
-                .addInclude("/**").addExclude("/**/reMyselfPassword","/test/**","/**/external/**","/**/inner/**","/**/index/**")
+                .addInclude("/**").addExclude("/**/reMyselfPassword","/**/test/**","/**/external/**","/**/inner/**","/**/index/**")
                 // 认证函数: 每次请求执行
                 .setAuth(obj -> {
                     // 登录认证 -- 拦截所有路由，并排除/user/doLogin 用于开放登录

src/main/java/com/fdkankan/manage/service/impl/SceneProServiceImpl.java

@@ -28,6 +28,7 @@ import com.fdkankan.manage.vo.request.SceneParam;
 import com.fdkankan.manage.vo.response.CameraDataVo;
 import com.fdkankan.manage.vo.response.GroupByCount;
 import com.fdkankan.manage.vo.response.SceneVo;
+import com.fdkankan.rabbitmq.util.RabbitMqProducer;
 import lombok.extern.slf4j.Slf4j;
 import net.sf.jsqlparser.parser.JJTCCJSqlParserState;
 import org.apache.commons.lang3.StringUtils;
@@ -110,6 +111,8 @@ public class SceneProServiceImpl extends ServiceImpl<ISceneProMapper, ScenePro>
     ICaseService caseService;
     @Autowired
     ManageConfig manageConfig;
+    @Autowired
+    RabbitMqProducer rabbitMqProducer;
 
 
     @Override
@@ -665,6 +668,8 @@ public class SceneProServiceImpl extends ServiceImpl<ISceneProMapper, ScenePro>
         if(sceneSource != null && (sceneSource == 4 || sceneSource == 5)){
             laserService.delete(num);
         }
+        rabbitMqProducer.sendByWorkQueue("fanout-exchange-iterrupt-calling","",num);
+
 //        if(cameraId != null){
 //            cameraDetailService.addUsedSpace(cameraId,space);
 //        }

src/main/java/com/fdkankan/manage/test/TestController.java

@@ -10,6 +10,7 @@ import com.fdkankan.manage.common.FilePath;
 import com.fdkankan.manage.httpClient.service.LaserService;
 import com.fdkankan.manage.util.Dateutils;
 import com.fdkankan.manage.util.RsaUtils;
+import com.fdkankan.rabbitmq.util.RabbitMqProducer;
 import org.apache.http.HttpEntity;
 import org.apache.http.HttpResponse;
 import org.apache.http.client.methods.HttpPost;
@@ -27,29 +28,13 @@ import java.util.*;
 @RestController
 public class TestController {
 
+    @Autowired
+    RabbitMqProducer rabbitMqProducer;
     @RequestMapping("/test")
     public ResultData test(){
+        rabbitMqProducer.sendByWorkQueue("fanout-exchange-iterrupt-calling","","xxxxxxx");
         return ResultData.ok();
     }
 
-    public static void main(String[] args) throws IOException {
-        String url = "http://192.168.0.25/service/manage/external/getByRyId";
-        JSONObject jsonObject = new JSONObject();
-        jsonObject.put("ryId","13800138001");
-        String encipher = RsaUtils.encipher(jsonObject.toJSONString());
-
-        HttpPost httpPost = new HttpPost(url);
-        CloseableHttpClient client = HttpClients.createDefault();
-        StringEntity entity = new StringEntity(encipher,"utf-8");
-        entity.setContentEncoding("utf-8");
-        entity.setContentType("application/json");
-        httpPost.setEntity(entity);
-        HttpResponse response = client.execute(httpPost);
-        if(response.getStatusLine().getStatusCode() == 200){
-            HttpEntity httpEntity = response.getEntity();
-            String result = EntityUtils.toString(httpEntity, "utf-8");
-            System.out.println(result);
-        }
-    }
 
 }