From cd75cdf2861ea1694c727718c0b5bbbe81ea2ea2 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=8E=8B=E7=86=99=E6=9C=9D?= <13694051+wangxizhao123@user.noreply.gitee.com> Date: Sat, 1 Jun 2024 20:05:09 +0800 Subject: [PATCH] =?UTF-8?q?fast()=E5=A2=9E=E5=8A=A0=E5=9C=B0=E5=9B=BE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/muyu/goods/pojo/HttpClient.java | 38 +++++++++++++++++++ .../controller/EnterpriseController.java | 4 +- .../goods/service/IEnterpriseService.java | 3 +- .../service/impl/EnterpriseServiceImpl.java | 13 ++++++- 4 files changed, 53 insertions(+), 5 deletions(-) create mode 100644 muyu-modules/muyu-goods-enterprise/muyu-goods-enterprise-common/src/main/java/com/muyu/goods/pojo/HttpClient.java 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; }