diff --git a/muyu-modules/muyu-goods-enterprise/muyu-goods-enterprise-common/src/main/java/com/muyu/goods/pojo/HttpClient.java b/muyu-modules/muyu-goods-enterprise/muyu-goods-enterprise-common/src/main/java/com/muyu/goods/pojo/HttpClient.java new file mode 100644 index 0000000..7666319 --- /dev/null +++ b/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 send = httpClient.send(builder, HttpResponse.BodyHandlers.ofString()); + //处理响应 + int statusCode = send.statusCode(); + String responseBody = send.body(); + System.out.println("状态码: " + statusCode); + System.out.println("响应: " + responseBody); + } +} diff --git a/muyu-modules/muyu-goods-enterprise/muyu-goods-enterprise-server/src/main/java/com/muyu/goods/controller/EnterpriseController.java b/muyu-modules/muyu-goods-enterprise/muyu-goods-enterprise-server/src/main/java/com/muyu/goods/controller/EnterpriseController.java index f56e65f..3eb6532 100644 --- a/muyu-modules/muyu-goods-enterprise/muyu-goods-enterprise-server/src/main/java/com/muyu/goods/controller/EnterpriseController.java +++ b/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)); } diff --git a/muyu-modules/muyu-goods-enterprise/muyu-goods-enterprise-server/src/main/java/com/muyu/goods/service/IEnterpriseService.java b/muyu-modules/muyu-goods-enterprise/muyu-goods-enterprise-server/src/main/java/com/muyu/goods/service/IEnterpriseService.java index ab5dcdf..10b403c 100644 --- a/muyu-modules/muyu-goods-enterprise/muyu-goods-enterprise-server/src/main/java/com/muyu/goods/service/IEnterpriseService.java +++ b/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; /** * 修改企业 diff --git a/muyu-modules/muyu-goods-enterprise/muyu-goods-enterprise-server/src/main/java/com/muyu/goods/service/impl/EnterpriseServiceImpl.java b/muyu-modules/muyu-goods-enterprise/muyu-goods-enterprise-server/src/main/java/com/muyu/goods/service/impl/EnterpriseServiceImpl.java index 70cb07b..3be0711 100644 --- a/muyu-modules/muyu-goods-enterprise/muyu-goods-enterprise-server/src/main/java/com/muyu/goods/service/impl/EnterpriseServiceImpl.java +++ b/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; }