Explorar o código

feat(user): 添加用户权限查询功能

- 新增 UserPermissions 数据传输对象
- 实现 UserPermissionsController 控制器,提供用户权限查询接口
- 添加 OkHttpClient 配置和相关工具类
- 在 EEnterpriseBasicInfo 中增加企业介绍字段并更新相关映射
林仔 hai 9 meses
pai
achega
911069c6f5

+ 5 - 0
pom.xml

@@ -113,6 +113,11 @@
             <artifactId>itext-asian</artifactId>
             <version>5.2.0</version>
         </dependency>
+        <!--okhttp请求包-->
+        <dependency>
+            <groupId>com.squareup.okhttp3</groupId>
+            <artifactId>okhttp</artifactId>
+        </dependency>
     </dependencies>
 
 

+ 16 - 0
src/main/java/com/zksy/common/domain/dto/UserPermissions.java

@@ -0,0 +1,16 @@
+package com.zksy.common.domain.dto;
+
+import lombok.Data;
+
+/**
+ * @author Administrator
+ * @version 1.0
+ * @project enterprise-assets-service
+ * @description 用户权限
+ * @date 2025/8/11 10:58:48
+ */
+@Data
+public class UserPermissions {
+private String appToken;
+private String appId;
+}

+ 16 - 0
src/main/java/com/zksy/config/InitConfig.java

@@ -0,0 +1,16 @@
+package com.zksy.config;
+
+import com.zksy.utils.UnsafeOkHttpClient;
+import okhttp3.OkHttpClient;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class InitConfig {
+
+    @Bean
+    public OkHttpClient okHttpClient() {
+        // 创建 OkHttpClient 实例
+        return UnsafeOkHttpClient.getUnsafeOkHttpClient();
+    }
+}

+ 78 - 0
src/main/java/com/zksy/controller/common/UserPermissionsController.java

@@ -0,0 +1,78 @@
+package com.zksy.controller.common;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.zksy.common.domain.dto.UserPermissions;
+import com.zksy.utils.AjaxResult;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import okhttp3.*;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.io.IOException;
+
+/**
+ * @author Administrator
+ * @version 1.0
+ * @project enterprise-assets-service
+ * @description 用户权限
+ * @date 2025/8/11 10:26:24
+ */
+@RestController
+@Api(tags = "用户权限", description = "用户权限")
+@RequestMapping("/userPermissions")
+@Slf4j
+public class UserPermissionsController {
+    private static final MediaType JSON = MediaType.parse("application/json; charset=utf-8");
+    @Autowired
+    private OkHttpClient httpClient;
+    @ApiOperation(value = "用户权限查询")
+    @PostMapping("/queryUserPermissions")
+    public AjaxResult queryUserPermissions(UserPermissions request){
+        ObjectMapper objectMapper = new ObjectMapper();
+        String jsonParams = null;
+        try {
+            jsonParams = objectMapper.writeValueAsString(request);
+        } catch (JsonProcessingException e) {
+            log.error("JSON序列化失败: {}", e);
+            return AjaxResult.error("请求失败");
+        }
+        // 创建请求体
+        RequestBody body = RequestBody.create(jsonParams, JSON);
+        // 构建请求
+        Request requestHttp = new Request.Builder()
+                .url("http://172.168.80.14:8082/minto/extTask/findUsers")
+                .post(body)
+                .build();
+        // 发送请求
+        try (Response response = httpClient.newCall(requestHttp).execute()) {
+            if (!response.isSuccessful()) {
+                return AjaxResult.error("请求失败");
+            }
+            ResponseBody responseBody = response.body();
+            if (responseBody != null) {
+                String responseString = responseBody.string();
+                JsonNode rootNode = objectMapper.readTree(responseString);
+                JsonNode success = rootNode.path("success");
+                if("true".equals(success.asText())) {
+                    JsonNode dataNode = rootNode.path("data");
+                    if (dataNode != null) {
+                        return AjaxResult.success(dataNode);
+                    } else {
+                        return AjaxResult.success(null);
+                    }
+                }else {
+                    return AjaxResult.error("用户权限查询失败");
+                }
+            }
+        } catch (IOException e) {
+            log.error("请求失败: {}", e);
+        }
+        return AjaxResult.error("请求失败");
+    }
+}

+ 1 - 4
src/main/java/com/zksy/controller/property/ATenantManagementController.java

@@ -1,9 +1,6 @@
 package com.zksy.controller.property;
 
-import cn.hutool.core.date.DateTime;
-import com.zksy.property.domain.AAssetManagement;
 import com.zksy.property.domain.ATenantManagement;
-import com.zksy.property.service.AAssetManagementService;
 import com.zksy.property.service.ATenantManagementService;
 import com.zksy.utils.AjaxResult;
 import com.zksy.utils.ExcelExportUtil;
@@ -15,7 +12,6 @@ import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
 
 import javax.servlet.http.HttpServletResponse;
-import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.util.Arrays;
 
@@ -54,6 +50,7 @@ public class ATenantManagementController {
     }
     @PostMapping("/update")
     @ApiOperation(value = "租户信息管理信息修改")
+
     public AjaxResult update(@RequestBody ATenantManagement atenantManagement) {
         atenantManagement.setUpdateTime(LocalDateTime.now());
         return service.updateById(atenantManagement) ? AjaxResult.success(atenantManagement) : AjaxResult.error("修改失败");

+ 7 - 0
src/main/java/com/zksy/info/domain/EEnterpriseBasicInfo.java

@@ -122,6 +122,13 @@ public class EEnterpriseBasicInfo implements Serializable {
     @ExcelProperty(value = "联系方式", index = 12)
     private String contactInformation;
 
+    /**
+     * 企业介绍
+     */
+    @ExcelProperty(value = "企业介绍",index = 13)
+    @ApiModelProperty(value = "企业介绍")
+    private String enterpriseIntroduce;
+
     /**
      * 创建时间
      */

+ 8 - 0
src/main/java/com/zksy/utils/OkhttpClientUtil.java

@@ -0,0 +1,8 @@
+package com.zksy.utils;
+
+import org.springframework.stereotype.Component;
+
+@Component
+public class OkhttpClientUtil {
+
+}

+ 50 - 0
src/main/java/com/zksy/utils/UnsafeOkHttpClient.java

@@ -0,0 +1,50 @@
+package com.zksy.utils;
+
+import okhttp3.OkHttpClient;
+
+import javax.net.ssl.*;
+import java.security.GeneralSecurityException;
+import java.security.cert.X509Certificate;
+
+public class UnsafeOkHttpClient {
+    public static OkHttpClient getUnsafeOkHttpClient() {
+        // Create a trust manager that does not validate certificate chains
+        final TrustManager[] trustAllCerts = new TrustManager[] {
+            new X509TrustManager() {
+                @Override
+                public void checkClientTrusted(X509Certificate[] chain, String authType) {
+                }
+
+                @Override
+                public void checkServerTrusted(X509Certificate[] chain, String authType) {
+                }
+
+                @Override
+                public X509Certificate[] getAcceptedIssuers() {
+                    return new X509Certificate[0];
+                }
+            }
+        };
+
+        // Install the all-trusting trust manager
+        try {
+            final SSLContext sslContext = SSLContext.getInstance("SSL");
+            sslContext.init(null, trustAllCerts, new java.security.SecureRandom());
+            // Create an ssl socket factory with our all-trusting manager
+            final SSLSocketFactory sslSocketFactory = sslContext.getSocketFactory();
+
+            OkHttpClient okHttpClient = new OkHttpClient.Builder()
+                    .sslSocketFactory(sslSocketFactory, (X509TrustManager)trustAllCerts[0])
+                    .hostnameVerifier(new HostnameVerifier() {
+                        @Override
+                        public boolean verify(String hostname, SSLSession session) {
+                            return true;
+                        }
+                    })
+                    .build();
+            return okHttpClient;
+        } catch (GeneralSecurityException e) {
+            throw new RuntimeException(e);
+        }
+    }
+}

+ 2 - 1
src/main/resources/mapper/info/EEnterpriseBasicInfoMapper.xml

@@ -19,6 +19,7 @@
             <result property="isHighTech" column="is_high_tech" jdbcType="VARCHAR"/>
             <result property="enterpriseLeader" column="enterprise_leader" jdbcType="VARCHAR"/>
             <result property="contactInformation" column="contact_information" jdbcType="VARCHAR"/>
+            <result property="enterpriseIntroduce" column="enterprise_introduce" jdbcType="VARCHAR"/>
             <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
             <result property="updateTime" column="update_time" jdbcType="TIMESTAMP"/>
     </resultMap>
@@ -28,7 +29,7 @@
         registration_date,output_value,output_value_yoy,
         tax_revenue,tax_revenue_yoy,revenue,
         revenue_yoy,is_above_designated_size,is_high_tech,
-        enterprise_leader,contact_information,create_time,
+        enterprise_leader,contact_information,enterprise_introduce,create_time,
         update_time
     </sql>
 </mapper>