1

README.md

@@ -181,7 +181,8 @@
 1,添加接口，
     /service/manage/authorizeCamera/orderList      相机授权订单列表
     /service/manage/authorizeCamera/export         相机授权订单列表导出
-
+需求3:
+    openApi授权管理
 需求4：
     列表旧接口service/manage/rtkDevice/list  多加参数，账号类型 accountType 0账号池，1专用账号,2账号池限期
     

src/main/java/com/fdkankan/manage/common/ResultCode.java

@@ -122,6 +122,7 @@ public enum ResultCode  {
     RTK_TIME_ERROR2(50094, "到期日期不能早于生效日期。"),
 
     RTK_SN_CODE_NOT_AUTH(50095, "板卡暂无授权信息"),
+    VISIT_OPENAPI_ERROR(50096, "访问openApi接口出错"),
 
     ;
 

src/main/java/com/fdkankan/manage/controller/AuthorizeOpenApiController.java

@@ -0,0 +1,59 @@
+package com.fdkankan.manage.controller;
+
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.fdkankan.manage.common.CacheUtil;
+import com.fdkankan.manage.common.ResultCode;
+import com.fdkankan.manage.common.ResultData;
+import com.fdkankan.manage.entity.AuthorizeCamera;
+import com.fdkankan.manage.entity.AuthorizeCameraLog;
+import com.fdkankan.manage.exception.BusinessException;
+import com.fdkankan.manage.httpClient.param.OpenApiAddParam;
+import com.fdkankan.manage.httpClient.param.OpenApiPageParam;
+import com.fdkankan.manage.httpClient.param.OpenApiUpdateParam;
+import com.fdkankan.manage.service.IAuthorizeCameraLogService;
+import com.fdkankan.manage.service.IAuthorizeCameraService;
+import com.fdkankan.manage.service.impl.OpenApiService;
+import com.fdkankan.manage.vo.request.AuthorizeParam;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+/**
+ * <p>
+ *  前端控制器
+ * </p>
+ *
+ * @author 
+ * @since 2023-07-07
+ */
+@RestController
+@RequestMapping("/service/manage/authorizeOpenApi")
+public class AuthorizeOpenApiController {
+
+    @Autowired
+    OpenApiService openApiService;
+
+    @PostMapping("/list")
+    public Object list(@RequestBody OpenApiPageParam param){
+        return openApiService.pageList(param);
+    }
+
+    @PostMapping("/add")
+    public Object add(@RequestBody OpenApiAddParam param){
+        return openApiService.add(param);
+    }
+
+    @PostMapping("/updateStatus")
+    public Object updateStatus(@RequestBody OpenApiUpdateParam param){
+        return openApiService.updateStatus(param);
+    }
+
+    @PostMapping("/delete")
+    public Object delete(@RequestBody OpenApiUpdateParam param){
+        return openApiService.delete(param);
+    }
+}
+

src/main/java/com/fdkankan/manage/httpClient/address/OpenApiAddressSource.java

@@ -0,0 +1,20 @@
+package com.fdkankan.manage.httpClient.address;
+
+import com.dtflys.forest.callback.AddressSource;
+import com.dtflys.forest.http.ForestAddress;
+import com.dtflys.forest.http.ForestRequest;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+
+@Component
+public class OpenApiAddressSource implements AddressSource {
+
+    @Value("${4dkk.openApiService.basePath}")
+    private String basePath;
+
+
+    @Override
+    public ForestAddress getAddress(ForestRequest forestRequest) {
+        return new ForestAddress("","",null,basePath);
+    }
+}

src/main/java/com/fdkankan/manage/httpClient/client/OpenApiClient.java

@@ -0,0 +1,41 @@
+package com.fdkankan.manage.httpClient.client;
+
+import com.dtflys.forest.annotation.*;
+import com.fdkankan.manage.httpClient.address.OpenApiAddressSource;
+import com.fdkankan.manage.httpClient.param.OpenApiAddParam;
+import com.fdkankan.manage.httpClient.param.OpenApiPageParam;
+import com.fdkankan.manage.httpClient.param.OpenApiUpdateParam;
+import com.fdkankan.manage.httpClient.vo.FdkkResponse;
+
+/**
+ * 获取，调用4dkkopenApi服务
+ */
+@Address(source = OpenApiAddressSource.class)
+public interface OpenApiClient {
+
+
+    /**
+     * 修改状态 是否启用（0-停用，1-启用）
+     */
+    @Post("/account/updateStatus")
+    FdkkResponse updateStatus(@JSONBody OpenApiUpdateParam param);
+
+    /**
+     * 新增
+     */
+    @Post("/account/add")
+    FdkkResponse add(@JSONBody OpenApiAddParam param);
+
+
+    /**
+     * 新增
+     */
+    @Post("/account/page")
+    FdkkResponse page(@JSONBody OpenApiPageParam param);
+
+    /**
+     * 删除
+     */
+    @Post("/account/delete")
+    FdkkResponse delete(@JSONBody OpenApiUpdateParam param);
+}

src/main/java/com/fdkankan/manage/httpClient/param/OpenApiAddParam.java

@@ -0,0 +1,20 @@
+package com.fdkankan.manage.httpClient.param;
+
+import lombok.Data;
+
+@Data
+public class OpenApiAddParam {
+    private String userName;
+    private String customerName;
+    private Integer useType;
+    private String companyName;
+    private String businessDept;
+    private String businessName;
+    private Integer customerType;
+    private String endCustomer;
+    private String remark;
+    private Long createrId;
+    private Long updaterId;
+
+
+}

src/main/java/com/fdkankan/manage/httpClient/param/OpenApiPageParam.java

@@ -0,0 +1,13 @@
+package com.fdkankan.manage.httpClient.param;
+
+import lombok.Data;
+
+@Data
+public class OpenApiPageParam {
+
+    private String apiKey;
+    private String userName;
+    private Integer pageNum;
+    private Integer pageSize;
+
+}

src/main/java/com/fdkankan/manage/httpClient/param/OpenApiUpdateParam.java

@@ -0,0 +1,11 @@
+package com.fdkankan.manage.httpClient.param;
+
+import lombok.Data;
+
+@Data
+public class OpenApiUpdateParam {
+    private Integer id;
+    private Integer status;
+    private Long updaterId;
+
+}

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

@@ -0,0 +1,105 @@
+package com.fdkankan.manage.service.impl;
+
+import cn.dev33.satoken.stp.StpUtil;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.fdkankan.manage.common.DictUtil;
+import com.fdkankan.manage.common.ResultCode;
+import com.fdkankan.manage.entity.SysUser;
+import com.fdkankan.manage.exception.BusinessException;
+import com.fdkankan.manage.httpClient.client.OpenApiClient;
+import com.fdkankan.manage.httpClient.param.OpenApiAddParam;
+import com.fdkankan.manage.httpClient.param.OpenApiPageParam;
+import com.fdkankan.manage.httpClient.param.OpenApiUpdateParam;
+import com.fdkankan.manage.httpClient.vo.FdkkResponse;
+import com.fdkankan.manage.service.ISysUserService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+import java.util.List;
+
+@Service
+@Slf4j
+public class OpenApiService {
+
+    @Autowired
+    OpenApiClient openApiClient;
+    @Autowired
+    ISysUserService sysUserService;
+
+
+    public Object pageList(OpenApiPageParam param){
+        try {
+            List<SysUser> sysUserList = sysUserService.list();
+            HashMap<Long,SysUser> map = new HashMap<>();
+            sysUserList.forEach( e -> map.put(e.getId(),e));
+
+            FdkkResponse response = openApiClient.page(param);
+            if(response.getCode() == 0 && response.getData() != null){
+                JSONObject data = response.getData();
+                JSONArray list = data.getJSONArray("list");
+                for (Object object : list) {
+                    JSONObject jsonObject = (JSONObject) object;
+                    Integer useType = jsonObject.getInteger("useType");
+                    if(useType != null){
+                        jsonObject.put("useTypeStr",DictUtil.toStringUseType(useType));
+                    }
+                    Integer customerType = jsonObject.getInteger("customerType");
+                    if(customerType != null){
+                        jsonObject.put("customerTypeStr",DictUtil.toStringCustomerType(customerType));
+                    }
+                    Long createrId = jsonObject.getLong("createrId");
+                    if(createrId != null){
+                        SysUser sysUser = map.get(createrId);
+                        jsonObject.put("createrName",sysUser != null ?sysUser.getNickName():"");
+                    }
+                    Long updaterId = jsonObject.getLong("updaterId");
+                    if(updaterId != null){
+                        SysUser sysUser = map.get(updaterId);
+                        jsonObject.put("updaterName",sysUser != null ?sysUser.getNickName():"");
+                    }
+                }
+            }
+            return response;
+        }catch (Exception e){
+            log.info("访问openApi接口出错：{}",e);
+            throw new BusinessException(ResultCode.VISIT_OPENAPI_ERROR);
+        }
+    }
+
+    public Object add(OpenApiAddParam param){
+        try {
+            param.setUpdaterId(Long.valueOf(StpUtil.getLoginId().toString()));
+            param.setCreaterId(Long.valueOf(StpUtil.getLoginId().toString()));
+            FdkkResponse response = openApiClient.add(param);
+            return response;
+        }catch (Exception e){
+            log.info("访问openApi接口出错：{}",e);
+            throw new BusinessException(ResultCode.VISIT_OPENAPI_ERROR);
+        }
+    }
+
+    public Object updateStatus(OpenApiUpdateParam param){
+        try {
+            param.setUpdaterId(Long.valueOf(StpUtil.getLoginId().toString()));
+            FdkkResponse response = openApiClient.updateStatus(param);
+            return response;
+        }catch (Exception e){
+            log.info("访问openApi接口出错：{}",e);
+            throw new BusinessException(ResultCode.VISIT_OPENAPI_ERROR);
+        }
+    }
+
+    public Object delete(OpenApiUpdateParam param){
+        try {
+            param.setUpdaterId(Long.valueOf(StpUtil.getLoginId().toString()));
+            FdkkResponse response = openApiClient.delete(param);
+            return response;
+        }catch (Exception e){
+            log.info("访问openApi接口出错：{}",e);
+            throw new BusinessException(ResultCode.VISIT_OPENAPI_ERROR);
+        }
+    }
+}