fast()增加地图

muyu-modules/muyu-goods-enterprise/muyu-goods-enterprise-common/src/main/java/com/muyu/goods/pojo/HttpClient.java

@@ -0,0 +1,38 @@
+package com.muyu.goods.pojo;
+
+import com.muyu.goods.domain.Enterprise;
+
+import java.io.IOException;
+import java.net.URI;
+import java.net.http.HttpRequest;
+import java.net.http.HttpResponse;
+
+public class HttpClient {
+
+    public static void http(Enterprise enterprise) throws IOException, InterruptedException {
+        //创建HttpClient实例
+        java.net.http.HttpClient httpClient = java.net.http.HttpClient.newHttpClient();
+
+        // 创建请求体（以JSON为例）
+        StringBuilder jsonBuilder = new StringBuilder();
+        jsonBuilder.append("{");
+        jsonBuilder.append("\"entId\":\"").append("enterprise"+enterprise.getId()).append("\",");
+        jsonBuilder.append("\"mysqlPort\":\"").append(Integer.valueOf(String.valueOf((int) (3306+enterprise.getId())))).append("\"");
+        jsonBuilder.append("}");
+        // 将 StringBuilder 转换为字符串
+        String jsonBuilderString = jsonBuilder.toString();
+        //创建httpRequest
+        HttpRequest builder = HttpRequest.newBuilder()
+                .uri(URI.create("http://129.211.23.219/webhook/%E6%B5%8B%E8%AF%95%E8%83%BD%E8%8E%B7%E5%8F%96home%E9%A1%B9%E7%9B%AE"))
+                .header("Content-Type", "application/json")// 设置 Content-Type 为 application/json
+                .POST(HttpRequest.BodyPublishers.ofString(jsonBuilderString))// 使用 POST 方法并设置请求体
+                .build();
+        //发送请求并获取响应
+        HttpResponse<String> send = httpClient.send(builder, HttpResponse.BodyHandlers.ofString());
+        //处理响应
+        int statusCode = send.statusCode();
+        String responseBody = send.body();
+        System.out.println("状态码: " + statusCode);
+        System.out.println("响应: " + responseBody);
+    }
+}

muyu-modules/muyu-goods-enterprise/muyu-goods-enterprise-server/src/main/java/com/muyu/goods/controller/EnterpriseController.java

@@ -1,5 +1,6 @@
 package com.muyu.goods.controller;
 
+import java.io.IOException;
 import java.util.List;
 import javax.servlet.http.HttpServletResponse;
 
@@ -91,8 +92,7 @@ public class EnterpriseController extends BaseController
     @RequiresPermissions("goods:enterprise:add")
     @Log(title = "企业", businessType = BusinessType.INSERT)
     @PostMapping
-    public Result add(@RequestBody Enterprise enterprise)
-    {
+    public Result add(@RequestBody Enterprise enterprise) throws IOException, InterruptedException {
         return toAjax(enterpriseService.insertEnterprise(enterprise));
     }
 

muyu-modules/muyu-goods-enterprise/muyu-goods-enterprise-server/src/main/java/com/muyu/goods/service/IEnterpriseService.java

@@ -1,5 +1,6 @@
 package com.muyu.goods.service;
 
+import java.io.IOException;
 import java.util.List;
 
 import com.muyu.common.system.domain.SysUser;
@@ -35,7 +36,7 @@ public interface IEnterpriseService
      * @param enterprise 企业
      * @return 结果
      */
-    public int insertEnterprise(Enterprise enterprise);
+    public int insertEnterprise(Enterprise enterprise) throws IOException, InterruptedException;
 
     /**
      * 修改企业

muyu-modules/muyu-goods-enterprise/muyu-goods-enterprise-server/src/main/java/com/muyu/goods/service/impl/EnterpriseServiceImpl.java

@@ -1,5 +1,12 @@
 package com.muyu.goods.service.impl;
 
+import java.io.IOException;
+import java.net.URI;
+import java.net.http.HttpRequest;
+import java.net.http.HttpRequest;
+import java.net.http.HttpRequest.BodyPublishers;
+import java.net.http.HttpResponse;
+import java.net.http.HttpResponse.BodyHandlers;
 import java.util.List;
 import java.util.UUID;
 import java.util.stream.Collectors;
@@ -10,6 +17,7 @@ import com.muyu.common.security.utils.SecurityUtils;
 import com.muyu.common.system.domain.LoginUser;
 import com.muyu.common.system.domain.SysUser;
 import com.muyu.goods.manage.SysUserRemote;
+import com.muyu.goods.pojo.HttpClient;
 import com.muyu.system.remote.RemoteSystemManageService;
 import muyu.goods.enterprise.client.config.EnterpriseConfig;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -66,8 +74,7 @@ public class EnterpriseServiceImpl implements IEnterpriseService
      * @return 结果
      */
     @Override
-    public int insertEnterprise(Enterprise enterprise)
-    {
+    public int insertEnterprise(Enterprise enterprise) throws IOException, InterruptedException {
         enterprise.setCreateTime(DateUtils.getNowDate());
         enterprise.setRegistrationDate(DateUtils.getNowDate());
         LoginUser loginUser = SecurityUtils.getLoginUser();
@@ -77,6 +84,8 @@ public class EnterpriseServiceImpl implements IEnterpriseService
         if (i>0){
             Enterprise enterprise1 = enterpriseMapper.queryDateEnterprise();
             enterpriseConfig.index(enterprise1);
+            //新建的企业绑定mysql服务
+            HttpClient.http(enterprise1);
         }
         return i;
     }