luozhun
/
policeSecurity
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: luozhun:fd690f31951ca630d8ed6e3e85389c2d275a11f9
Branches Tags
luozhun:main
..
compare: luozhun:85db3000d93c6109441fcfd48f54b2c8d3c68ead
Branches Tags
luozhun:main

No commits in common. "fd690f31951ca630d8ed6e3e85389c2d275a11f9" and "85db3000d93c6109441fcfd48f54b2c8d3c68ead" have entirely different histories.
fd690f3195 ... 85db3000d9

33 changed files with 70 additions and 862 deletions
Show Stats Expand all files Collapse all files

3
policeSecurityServer/.gitignore vendored
View File

@ -2,5 +2,4 @@
target
logs
temp
HELP.md
rebel.xml
HELP.md

12
policeSecurityServer/src/main/java/com/changhu/common/annotation/Desensitized.java
View File

@ -15,17 +15,5 @@ import java.lang.annotation.Target;
@Target(ElementType.FIELD)
@Retention(RetentionPolicy.RUNTIME)
public @interface Desensitized {
/**
* 脱敏类型
*
* @return 脱敏类型
*/
DesensitizedUtil.DesensitizedType value();
/**
* 是否保留原字段
*
* @return 原字段+加密字段 的map
*/
boolean keepOriginalField() default false;
}

14
policeSecurityServer/src/main/java/com/changhu/common/annotation/RealDelete.java Normal file
View File

@ -0,0 +1,14 @@
package com.changhu.common.annotation;
import java.lang.annotation.*;
/**
* @author 20252
* @createTime 2024/6/26 上午9:41
* @desc RealDelete...
*/
@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface RealDelete {
}

14
policeSecurityServer/src/main/java/com/changhu/common/cache/GlobalCacheManager.java vendored
View File

@ -35,19 +35,19 @@ public class GlobalCacheManager {
}
static void initEnum() {
//在包下扫描出BaseEnum的子类
log.info("初始化枚举字典数据----");
Set<Class<?>> classes = ClassUtil.scanPackageBySuper("com.changhu.common.db.enums", BaseEnum.class);
//序列化方法
Method superSerializer = ClassUtil.getDeclaredMethod(BaseEnum.class, "serializer");
for (Class<?> aClass : classes) {
Method childrenSerializer = ClassUtil.getDeclaredMethod(aClass, "serializer");
BaseEnum<?>[] enumConstants = (BaseEnum<?>[]) aClass.getEnumConstants();
if (enumConstants == null) {
continue;
}
//子类是否重写了父类的serializer方法
boolean isRewriteSerializer = !superSerializer.equals(ClassUtil.getDeclaredMethod(aClass, "serializer"));
// 获取所有字段并过滤出非静态字段并带有 IsExtData 注解的字段
List<Field> extDataFields = Arrays.stream(aClass.getDeclaredFields())
// 获取所有字段
Field[] fields = aClass.getDeclaredFields();
// 过滤出非静态字段并带有 IsExtData 注解的字段
List<Field> extDataFields = Arrays.stream(fields)
.filter(field -> !Modifier.isStatic(field.getModifiers()))
.filter(field -> field.getAnnotation(IsExtData.class) != null)
.collect(Collectors.toList());
@ -56,7 +56,7 @@ public class GlobalCacheManager {
Stream.of(enumConstants).forEach(v -> {
//如果子类重写父类的方法 则直接使用子类的结果
if (isRewriteSerializer) {
if (!superSerializer.equals(childrenSerializer)) {
map.put(v, v.serializer());
} else {
SelectNodeVo<Object> vo = new SelectNodeVo<>();

28
policeSecurityServer/src/main/java/com/changhu/common/db/enums/ServiceProjectTwoType.java
View File

@ -1,28 +0,0 @@
package com.changhu.common.db.enums;
import com.baomidou.mybatisplus.annotation.IEnum;
import com.changhu.common.annotation.IsExtData;
import com.changhu.common.db.BaseEnum;
import lombok.AllArgsConstructor;
import lombok.Getter;
/**
* @author 20252
* @createTime 2024/9/5 上午11:04
* @desc 服务项目二级类型
*/
@AllArgsConstructor
@Getter
public enum ServiceProjectTwoType implements BaseEnum<String>, IEnum<String> {
SECURITY("outsource", "外包", ServiceProjectType.SECURITY.getValue()),
PROPERTY_RECRUITMENT("property_recruitment", "物业自招", ServiceProjectType.SECURITY.getValue()),
OTHER_RECRUITMENT("other_recruitment", "其他自招", ServiceProjectType.SECURITY.getValue()),
;
private final String value;
private final String label;
@IsExtData
private final String parentType;
}

1
policeSecurityServer/src/main/java/com/changhu/common/db/enums/ServiceProjectType.java
View File

@ -15,6 +15,7 @@ import lombok.Getter;
public enum ServiceProjectType implements BaseEnum<String>, IEnum<String> {
SECURITY("security", "安保"),
PROPERTY("property", "物业"),
;

26
policeSecurityServer/src/main/java/com/changhu/common/pojo/vo/DesensitizedVo.java
View File

@ -1,26 +0,0 @@
package com.changhu.common.pojo.vo;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @author 20252
* @createTime 2024/11/19 上午9:17
* @desc 脱敏数据
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
public class DesensitizedVo {
/**
* 原始数据
*/
private String originalValue;
/**
* 脱敏数据
*/
private String desensitizedValue;
}

89
policeSecurityServer/src/main/java/com/changhu/controller/AccessKeysController.java
View File

@ -1,89 +0,0 @@
package com.changhu.controller;
import cn.hutool.core.annotation.AnnotationUtil;
import cn.hutool.core.lang.Dict;
import com.alibaba.fastjson2.JSON;
import com.changhu.common.annotation.CheckUserType;
import com.changhu.common.annotation.JsonBody;
import com.changhu.common.db.enums.UserType;
import com.changhu.common.pojo.vo.SelectNodeVo;
import com.changhu.pojo.entity.AccessKeys;
import com.changhu.pojo.params.GeneratedAccessKeyParams;
import com.changhu.service.AccessKeysService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.annotation.AnnotatedElementUtils;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import java.util.Arrays;
import java.util.List;
/**
* @author 20252
* @createTime 2024/11/19 上午10:38
* @desc AccessKeysController...
*/
@Tag(name = "开放平台")
@RequestMapping("/accessKeys")
@JsonBody
@CheckUserType(userTypes = UserType.MANAGEMENT_SUPER)
public class AccessKeysController {
@Autowired
private AccessKeysService accessKeysService;
@GetMapping("/listOpenApi")
public List<SelectNodeVo<String>> listOpenApi() {
Class<OpenController> openControllerClass = OpenController.class;
RequestMapping requestMapping = AnnotatedElementUtils.findMergedAnnotation(openControllerClass, RequestMapping.class);
String controllerPath = requestMapping.value()[0];
return Arrays.stream(openControllerClass.getMethods())
.filter(m -> AnnotationUtil.hasAnnotation(m, RequestMapping.class))
.map(m -> {
Operation operation = m.getAnnotation(Operation.class);
RequestMapping mReq = AnnotatedElementUtils.findMergedAnnotation(m, RequestMapping.class);
return SelectNodeVo.<String>builder()
.value(controllerPath + mReq.value()[0])
.label(operation.summary())
.extData(Dict.of("methods", mReq.method()))
.build();
})
.toList();
}
@Operation(summary = "生成访问凭证")
@PostMapping("/generatedAccessKey")
public void generatedAccessKey(@RequestBody GeneratedAccessKeyParams params) {
accessKeysService.generatedAccessKey(params);
}
@Operation(summary = "访问凭证列表")
@GetMapping("/tableList")
public List<AccessKeys> tableList() {
return accessKeysService.list();
}
public static void main(String[] args) {
Class<OpenController> openControllerClass = OpenController.class;
RequestMapping requestMapping = AnnotatedElementUtils.findMergedAnnotation(openControllerClass, RequestMapping.class);
String controllerPath = requestMapping.value()[0];
List<SelectNodeVo<String>> method = Arrays.stream(openControllerClass.getMethods())
.filter(m -> AnnotationUtil.hasAnnotation(m, RequestMapping.class))
.map(m -> {
Operation operation = m.getAnnotation(Operation.class);
RequestMapping mReq = AnnotatedElementUtils.findMergedAnnotation(m, RequestMapping.class);
return SelectNodeVo.<String>builder()
.value(controllerPath + mReq.value()[0])
.label(operation.summary())
.extData(Dict.of("method", mReq.method()))
.build();
})
.toList();
method.forEach(i -> System.out.println(JSON.toJSONString(i)));
}
}

17
policeSecurityServer/src/main/java/com/changhu/controller/OpenController.java
View File

@ -6,8 +6,6 @@ import com.changhu.common.enums.OpenApiType;
import com.changhu.common.pojo.vo.SelectNodeVo;
import com.changhu.pojo.dto.DataViewDTO;
import com.changhu.pojo.dto.EnterprisesUnitDetailDTO;
import com.changhu.pojo.dto.SecurityUnitUseStatisticsDTO;
import com.changhu.pojo.dto.ServiceProjectSecurityUserRosterDTO;
import com.changhu.service.OpenApiService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.media.Schema;
@ -53,19 +51,4 @@ public class OpenController {
public DataViewDTO dataView() {
return openApiService.dataView();
}
@Operation(summary = "保安单位使用情况统计")
@CheckOpenApi(value = OpenApiType.Information_on_enterprises_and_institutions)
@GetMapping("/securityUnitUseStatistics")
public List<SecurityUnitUseStatisticsDTO> securityUnitUseStatistics(@Schema(description = "代码") @RequestParam String code,
@Schema(description = "等级") @RequestParam Integer level) {
return openApiService.securityUnitUseStatistics(code, level);
}
@Operation(summary = "服务项目安保人员花名册")
@CheckOpenApi(value = OpenApiType.Information_on_enterprises_and_institutions)
@GetMapping("/serviceProjectUserRoster")
public List<ServiceProjectSecurityUserRosterDTO> serviceProjectUserRoster(@Schema(description = "服务项目id") Long serviceProjectId) {
return openApiService.serviceProjectUserRoster(serviceProjectId);
}
}

15
policeSecurityServer/src/main/java/com/changhu/mapper/AccessKeysMapper.java
View File

@ -1,15 +0,0 @@
package com.changhu.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.changhu.pojo.entity.AccessKeys;
import org.apache.ibatis.annotations.Mapper;
/**
* access_keys (开放接口的授权) 固化类
* author: luozhun
* desc 由groovy脚本自动生成
*/
@Mapper
public interface AccessKeysMapper extends BaseMapper<AccessKeys> {
}

20
policeSecurityServer/src/main/java/com/changhu/mapper/OpenApiMapper.java
View File

@ -1,8 +1,6 @@
package com.changhu.mapper;
import com.changhu.common.pojo.vo.SelectNodeVo;
import com.changhu.pojo.dto.SecurityUnitUseStatisticsDTO;
import com.changhu.pojo.dto.ServiceProjectSecurityUserRosterDTO;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
@ -25,22 +23,4 @@ public interface OpenApiMapper {
*/
List<SelectNodeVo<Long>> getEnterprisesUnit(@Param("code") String code,
@Param("level") Integer level);
/**
* 保安单位使用情况统计
*
* @param code 代码
* @param level 等级
* @return 结果
*/
List<SecurityUnitUseStatisticsDTO> securityUnitUseStatistics(@Param("code") String code,
@Param("level") Integer level);
/**
* 获取服务人员花名册
*
* @param serviceProjectId 服务项目id
* @return 结果
*/
List<ServiceProjectSecurityUserRosterDTO> serviceProjectUserRoster(@Param("serviceProjectId") Long serviceProjectId);
}

17
policeSecurityServer/src/main/java/com/changhu/module/management/pojo/entity/ServiceProject.java
View File

@ -2,7 +2,6 @@ package com.changhu.module.management.pojo.entity;
import com.baomidou.mybatisplus.annotation.TableName;
import com.changhu.common.db.enums.IsOrNot;
import com.changhu.common.db.enums.ServiceProjectTwoType;
import com.changhu.common.db.enums.ServiceProjectType;
import com.changhu.support.mybatisplus.pojo.entity.BaseEntity;
import lombok.AllArgsConstructor;
@ -57,22 +56,12 @@ public class ServiceProject extends BaseEntity implements Serializable {
private ServiceProjectType type;
/**
* 二级类型(外包/物业自招/其他自招)
* 是否自招保安(只有当type为property 此字段必填)
*/
private ServiceProjectTwoType twoType;
private IsOrNot isRecruitSecurity;
/**
* 若二级类型选择外包 这里需填写外包公司名称
*/
private String outsourceName;
/**
* 是否备案
*/
private IsOrNot isFiling;
/**
* 证件号(保安服务许可证/备案证)
* 证件号(服务类型为保安必填 服务类型为物业则需自招保安为必填)
*/
private String idNumber;

13
policeSecurityServer/src/main/java/com/changhu/module/management/pojo/params/ServiceProjectSaveOrUpdateParams.java
View File

@ -1,7 +1,6 @@
package com.changhu.module.management.pojo.params;
import com.changhu.common.db.enums.IsOrNot;
import com.changhu.common.db.enums.ServiceProjectTwoType;
import com.changhu.common.db.enums.ServiceProjectType;
import io.swagger.v3.oas.annotations.media.Schema;
import jakarta.validation.constraints.NotNull;
@ -33,16 +32,10 @@ public class ServiceProjectSaveOrUpdateParams {
@NotNull(message = "服务类型不能为空")
private ServiceProjectType type;
@Schema(description = "二级类型")
private ServiceProjectTwoType twoType;
@Schema(description = "是否自招保安(只有当type为property 此字段必填)")
private IsOrNot isRecruitSecurity;
@Schema(description = "外包公司名称")
private String outsourceName;
@Schema(description = "是否备案")
private IsOrNot isFiling;
@Schema(description = "证件号(保安服务许可证/备案证)")
@Schema(description = "证件号(服务类型为保安必填 服务类型为物业则需自招保安为必填)")
private String idNumber;
@Schema(description = "服务区域面积")

10
policeSecurityServer/src/main/java/com/changhu/module/management/pojo/vo/ServiceProjectPagerVo.java
View File

@ -1,7 +1,6 @@
package com.changhu.module.management.pojo.vo;
import com.changhu.common.db.enums.IsOrNot;
import com.changhu.common.db.enums.ServiceProjectTwoType;
import com.changhu.common.db.enums.ServiceProjectType;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
@ -37,13 +36,10 @@ public class ServiceProjectPagerVo {
@Schema(description = "服务类型")
private ServiceProjectType type;
@Schema(description = "二级类型")
private ServiceProjectTwoType twoType;
@Schema(description = "外包公司名称")
private String outsourceName;
@Schema(description = "是否备案")
private IsOrNot isFiling;
@Schema(description = "是否自招保安(只有当type为property 此字段必填)")
private IsOrNot isRecruitSecurity;
@Schema(description = "证件号(服务类型为保安必填 服务类型为物业则需自招保安为必填)")
private String idNumber;

3
policeSecurityServer/src/main/java/com/changhu/module/miniProgram/pojo/vo/IndexServiceProjectListVo.java
View File

@ -2,6 +2,7 @@ package com.changhu.module.miniProgram.pojo.vo;
import cn.hutool.core.lang.Dict;
import com.changhu.common.db.enums.EnterprisesUnitType;
import com.changhu.common.db.enums.IsOrNot;
import com.changhu.common.db.enums.ServiceProjectType;
import com.changhu.module.management.pojo.model.ContactPersonInfo;
import io.swagger.v3.oas.annotations.media.Schema;
@ -68,6 +69,8 @@ public class IndexServiceProjectListVo {
private String name;
@Schema(description = "服务项目类型")
private ServiceProjectType type;
@Schema(description = "是否自招保安(只有当type为property 此字段必填)")
private IsOrNot isRecruitSecurity;
@Schema(description = "证件号(服务类型为保安必填 服务类型为物业则需自招保安为必填)")
private String idNumber;
@Schema(description = "服务区域面积")

4
policeSecurityServer/src/main/java/com/changhu/module/miniProgram/pojo/vo/ServiceProjectSecurityUserPagerVo.java
View File

@ -29,7 +29,7 @@ public class ServiceProjectSecurityUserPagerVo {
@Schema(description = "名称")
private String name;
@Desensitized(value = DesensitizedUtil.DesensitizedType.MOBILE_PHONE, keepOriginalField = true)
@Desensitized(value = DesensitizedUtil.DesensitizedType.MOBILE_PHONE)
@Schema(description = "手机号")
private String telephone;
@ -42,7 +42,7 @@ public class ServiceProjectSecurityUserPagerVo {
@Schema(description = "籍贯")
private String nativePlace;
@Desensitized(value = DesensitizedUtil.DesensitizedType.ID_CARD, keepOriginalField = true)
@Desensitized(value = DesensitizedUtil.DesensitizedType.ID_CARD)
@Schema(description = "身份证")
private String idCard;

50
policeSecurityServer/src/main/java/com/changhu/pojo/dto/SecurityUnitUseStatisticsDTO.java
View File

@ -1,50 +0,0 @@
package com.changhu.pojo.dto;
import com.changhu.common.db.enums.IsOrNot;
import com.changhu.common.db.enums.ServiceProjectTwoType;
import com.changhu.common.db.enums.ServiceProjectType;
import com.changhu.module.management.pojo.model.LegalPersonInfo;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
/**
* @author 20252
* @createTime 2024/11/18 上午10:32
* @desc SecurityUnitUseStatisticsDTO...
*/
@Data
public class SecurityUnitUseStatisticsDTO {
@Schema(description = "服务项目id")
private Long serviceProjectId;
@Schema(description = "公安单位名称")
private String policeUnitName;
@Schema(description = "保安单位名称")
private String securityUnitName;
@Schema(description = "服务项目名称")
private String serviceProjectName;
@Schema(description = "保安服务类别")
private ServiceProjectType type;
@Schema(description = "二级类型")
private ServiceProjectTwoType twoType;
@Schema(description = "外包公司名称")
private String outsourceName;
@Schema(description = "保安人员总数")
private Integer securityUserTotal;
@Schema(description = "持证保安数量")
private Integer haveCardSecurityUserCount;
@Schema(description = "是否备案")
private IsOrNot isFiling;
@Schema(description = "证件号(保安服务许可证/备案证)")
private String idNumber;
@Schema(description = "保安单位法人信息")
private LegalPersonInfo securityUnitLegalPersonInfo;
@Schema(description = "项目经理")
private String serviceProjectManager;
@Schema(description = "项目经理联系方式")
private String serviceProjectManagerTelephone;
}

3
policeSecurityServer/src/main/java/com/changhu/pojo/dto/ServiceProjectDTO.java
View File

@ -1,6 +1,7 @@
package com.changhu.pojo.dto;
import com.alibaba.fastjson2.annotation.JSONField;
import com.changhu.common.db.enums.IsOrNot;
import com.changhu.common.db.enums.ServiceProjectType;
import com.changhu.common.db.enums.Sex;
import com.changhu.module.management.pojo.model.LegalPersonInfo;
@ -28,6 +29,8 @@ public class ServiceProjectDTO {
private String name;
@Schema(description = "类型")
private ServiceProjectType type;
@Schema(description = "是否自招保安")
private IsOrNot isRecruitSecurity;
@Schema(description = "保安证号")
private String idNumber;
@Schema(description = "服务面积")

36
policeSecurityServer/src/main/java/com/changhu/pojo/dto/ServiceProjectSecurityUserRosterDTO.java
View File

@ -1,36 +0,0 @@
package com.changhu.pojo.dto;
import cn.hutool.core.util.DesensitizedUtil;
import com.changhu.common.annotation.Desensitized;
import com.changhu.common.db.enums.Sex;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
/**
* @author 20252
* @createTime 2024/11/18 上午10:43
* @desc ServiceProjectSecurityUserRosterDTO...
*/
@Data
public class ServiceProjectSecurityUserRosterDTO {
@Schema(description = "id")
private Long snowFlakeId;
@Schema(description = "名称")
private String name;
@Schema(description = "性别")
private Sex sex;
@Schema(description = "年龄")
private Integer age;
@Desensitized(value = DesensitizedUtil.DesensitizedType.ID_CARD, keepOriginalField = true)
@Schema(description = "身份证")
private String idCard;
@Desensitized(value = DesensitizedUtil.DesensitizedType.MOBILE_PHONE, keepOriginalField = true)
@Schema(description = "手机号")
private String telephone;
@Schema(description = "企事业单位名")
private String enterprisesUnitName;
@Schema(description = "保安单位名")
private String securityUnitName;
@Schema(description = "保安证号")
private String securityNumber;
}

72
policeSecurityServer/src/main/java/com/changhu/pojo/entity/AccessKeys.java
View File

@ -1,72 +0,0 @@
package com.changhu.pojo.entity;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import com.baomidou.mybatisplus.extension.handlers.Fastjson2TypeHandler;
import com.changhu.common.db.enums.IsEnable;
import com.changhu.support.mybatisplus.pojo.entity.BaseEntity;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder;
import java.io.Serial;
import java.io.Serializable;
import java.util.List;
/**
* 开放接口的授权 实体类
* author: luozhun
* desc 由groovy脚本自动生成
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@SuperBuilder
@EqualsAndHashCode(callSuper = true)
@TableName(autoResultMap = true)
public class AccessKeys extends BaseEntity implements Serializable {
@Serial
private static final long serialVersionUID = 1L;
/**
* 调用方
*/
private String name;
/**
* 有效时间
*/
private Integer effectiveTime;
/**
* AccessKey
*/
private String accessKey;
/**
* SecretKey
*/
private String secretKey;
/**
* 允许访问的资源
*/
@TableField(typeHandler = Fastjson2TypeHandler.class)
private List<String> allowedResources;
/**
* 是否启用
*/
private IsEnable isEnable;
/**
* 备注
*/
private String remark;
}

37
policeSecurityServer/src/main/java/com/changhu/pojo/params/GeneratedAccessKeyParams.java
View File

@ -1,37 +0,0 @@
package com.changhu.pojo.params;
import com.changhu.common.db.enums.IsEnable;
import io.swagger.v3.oas.annotations.media.Schema;
import jakarta.validation.constraints.NotBlank;
import jakarta.validation.constraints.NotNull;
import lombok.Data;
import java.util.List;
/**
* @author 20252
* @createTime 2024/11/19 上午11:19
* @desc GeneratedAccessKeyParams...
*/
@Data
public class GeneratedAccessKeyParams {
private Long snowFlakeId;
@Schema(description = "调用方")
@NotBlank(message = "调用方不能为空")
private String name;
@NotNull(message = "请输入有效时间")
@Schema(description = "有效时间")
private Integer effectiveTime;
@Schema(description = "允许访问的资源")
private List<String> allowedResources;
@NotNull
@Schema(description = "是否启用")
private IsEnable isEnable;
@Schema(description = "备注")
private String remark;
}

20
policeSecurityServer/src/main/java/com/changhu/service/AccessKeysService.java
View File

@ -1,20 +0,0 @@
package com.changhu.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.changhu.pojo.entity.AccessKeys;
import com.changhu.pojo.params.GeneratedAccessKeyParams;
/**
* access_keys (开放接口的授权) 服务类
* author: luozhun
* desc 由groovy脚本自动生成
*/
public interface AccessKeysService extends IService<AccessKeys> {
/**
* 生成访问凭证
*
* @param params 参数
*/
void generatedAccessKey(GeneratedAccessKeyParams params);
}

20
policeSecurityServer/src/main/java/com/changhu/service/OpenApiService.java
View File

@ -3,8 +3,7 @@ package com.changhu.service;
import com.changhu.common.pojo.vo.SelectNodeVo;
import com.changhu.pojo.dto.DataViewDTO;
import com.changhu.pojo.dto.EnterprisesUnitDetailDTO;
import com.changhu.pojo.dto.SecurityUnitUseStatisticsDTO;
import com.changhu.pojo.dto.ServiceProjectSecurityUserRosterDTO;
import com.changhu.pojo.queryParams.OpenGetEnterprisesUnit;
import java.util.List;
@ -37,21 +36,4 @@ public interface OpenApiService {
* @return 数据总览
*/
DataViewDTO dataView();
/**
* 保安单位使用情况统计
*
* @param code 代码
* @param level 等级
* @return 使用情况
*/
List<SecurityUnitUseStatisticsDTO> securityUnitUseStatistics(String code, Integer level);
/**
* 服务项目安保人员花名册
*
* @param serviceProjectId 服务项目id
* @return 花名册
*/
List<ServiceProjectSecurityUserRosterDTO> serviceProjectUserRoster(Long serviceProjectId);
}

41
policeSecurityServer/src/main/java/com/changhu/service/impl/AccessKeysServiceImpl.java
View File

@ -1,41 +0,0 @@
package com.changhu.service.impl;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.util.IdUtil;
import cn.hutool.core.util.RandomUtil;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.changhu.mapper.AccessKeysMapper;
import com.changhu.pojo.entity.AccessKeys;
import com.changhu.pojo.params.GeneratedAccessKeyParams;
import com.changhu.service.AccessKeysService;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
/**
* access_keys (开放接口的授权) 服务实现类
* author: luozhun
* desc 由groovy脚本自动生成
*/
@Service
public class AccessKeysServiceImpl extends ServiceImpl<AccessKeysMapper, AccessKeys> implements AccessKeysService {
@Transactional(rollbackFor = Exception.class)
@Override
public void generatedAccessKey(GeneratedAccessKeyParams params) {
AccessKeys accessKeys = BeanUtil.copyProperties(params, AccessKeys.class);
if (accessKeys.getSnowFlakeId() == null) {
// 生成一个32位的随机字符串，包含大小写字母和数字
String accessKey = RandomUtil.randomString(RandomUtil.BASE_CHAR + RandomUtil.BASE_NUMBER, 32);
String secretKey = IdUtil.randomUUID();
accessKeys.setAccessKey(accessKey);
accessKeys.setSecretKey(secretKey);
}
this.saveOrUpdate(accessKeys);
}
public static void main(String[] args) {
String randomPart = RandomUtil.randomString(RandomUtil.BASE_CHAR + RandomUtil.BASE_NUMBER, 32);
System.out.println(randomPart);
System.out.println(IdUtil.randomUUID());
}
}

13
policeSecurityServer/src/main/java/com/changhu/service/impl/OpenApiServiceImpl.java
View File

@ -11,8 +11,7 @@ import com.changhu.module.management.service.ServiceProjectService;
import com.changhu.module.miniProgram.pojo.entity.SecurityUser;
import com.changhu.pojo.dto.DataViewDTO;
import com.changhu.pojo.dto.EnterprisesUnitDetailDTO;
import com.changhu.pojo.dto.SecurityUnitUseStatisticsDTO;
import com.changhu.pojo.dto.ServiceProjectSecurityUserRosterDTO;
import com.changhu.pojo.queryParams.OpenGetEnterprisesUnit;
import com.changhu.service.OpenApiService;
import com.changhu.support.mybatisplus.pojo.entity.BaseEntity;
import lombok.SneakyThrows;
@ -96,14 +95,4 @@ public class OpenApiServiceImpl implements OpenApiService {
countDownLatch.await();
return dataViewDTO;
}
@Override
public List<SecurityUnitUseStatisticsDTO> securityUnitUseStatistics(String code, Integer level) {
return openApiMapper.securityUnitUseStatistics(code, level);
}
@Override
public List<ServiceProjectSecurityUserRosterDTO> serviceProjectUserRoster(Long serviceProjectId) {
return openApiMapper.serviceProjectUserRoster(serviceProjectId);
}
}

75
policeSecurityServer/src/main/java/com/changhu/support/fastjson2/filter/DesensitizedFilter.java
View File

@ -1,16 +1,12 @@
package com.changhu.support.fastjson2.filter;
import cn.hutool.core.annotation.AnnotationUtil;
import cn.hutool.core.util.ClassUtil;
import cn.hutool.core.util.DesensitizedUtil;
import com.alibaba.fastjson2.filter.ValueFilter;
import com.changhu.common.annotation.Desensitized;
import com.changhu.common.pojo.vo.DesensitizedVo;
import lombok.extern.slf4j.Slf4j;
import java.lang.reflect.Field;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
/**
@ -23,62 +19,41 @@ public class DesensitizedFilter implements ValueFilter {
public static final DesensitizedFilter instance = new DesensitizedFilter();
private static final Map<FieldKey, Desensitized> cache = new ConcurrentHashMap<>();
private final Map<String, DesensitizedUtil.DesensitizedType> cache = new ConcurrentHashMap<>();
private DesensitizedFilter() {
}
static {
preProcessAnnotations();
}
@Override
public Object apply(Object object, String name, Object value) {
//只针对string类型生效
if (value instanceof String strValue && !strValue.isEmpty()) {
FieldKey fieldKey = new FieldKey(object.getClass(), name);
Desensitized desensitized = cache.get(fieldKey);
if (desensitized != null) {
if (desensitized.keepOriginalField()) {
return DesensitizedVo.builder()
.originalValue(strValue)
.desensitizedValue(DesensitizedUtil.desensitized(strValue, desensitized.value()))
.build();
try {
String path = object.getClass().getName() + "$$" + name;
//先看是否有缓存
if (cache.containsKey(path)) {
return DesensitizedUtil.desensitized(strValue, cache.get(path));
}
return DesensitizedUtil.desensitized(strValue, desensitized.value());
}
}
return value;
}
/**
* 脱敏字段预处理 初始化缓存信息
*/
private static void preProcessAnnotations() {
Set<Class<?>> classes = ClassUtil.scanPackage("com.changhu");
for (Class<?> clazz : classes) {
Field[] fields = clazz.getDeclaredFields();
for (Field field : fields) {
Desensitized annotation = AnnotationUtil.getAnnotation(field, Desensitized.class);
if (annotation != null) {
cache.put(new FieldKey(clazz, field.getName()), annotation);
Class<?> aClass = object.getClass();
Field declaredField = aClass.getDeclaredField(name);
Desensitized annotation = declaredField.getAnnotation(Desensitized.class);
if (annotation == null) {
return value;
}
//加入缓存
cache.put(path, annotation.value());
return DesensitizedUtil.desensitized(strValue, annotation.value());
} catch (NoSuchFieldException e) {
return value;
} catch (SecurityException e) {
log.error("字段：{} 安全异常: {}", name, e.getMessage());
return null;
} catch (Exception e) {
log.error("数据脱敏失败:{}", e.getMessage());
return null;
}
}
}
private record FieldKey(Class<?> clazz, String fieldName) {
@Override
public boolean equals(Object o) {
if (this == o) return true;
if (o == null || getClass() != o.getClass()) return false;
FieldKey fieldKey = (FieldKey) o;
return clazz.equals(fieldKey.clazz) && fieldName.equals(fieldKey.fieldName);
}
@Override
public int hashCode() {
return clazz.hashCode() ^ fieldName.hashCode();
} else {
return value;
}
}

69
policeSecurityServer/src/main/resources/mapper/OpenApiMapper.xml
View File

@ -28,73 +28,4 @@
</choose>
order by eu.create_time desc
</select>
<resultMap id="SecurityUnitUseStatisticsDTOResultMap" type="com.changhu.pojo.dto.SecurityUnitUseStatisticsDTO">
<result
column="securityUnitLegalPersonInfo"
typeHandler="com.baomidou.mybatisplus.extension.handlers.Fastjson2TypeHandler"
property="securityUnitLegalPersonInfo"/>
</resultMap>
<select id="securityUnitUseStatistics" resultMap="SecurityUnitUseStatisticsDTOResultMap">
select
sp.snow_flake_id as 'serviceProjectId',
pu.name as 'policeUnitName',
su.name as 'securityUnitName',
sp.name as 'serviceProjectName',
sp.type as 'type',
sp.two_type as 'twoType',
sp.outsource_name as 'outsourceName',
count(suu.snow_flake_id) as 'securityUserTotal',
SUM(IF(suu.security_number != '', 1, 0)) as 'haveCardSecurityUserCount',
sp.is_filing as 'isFiling',
sp.id_number,
su.legal_person_info as 'securityUnitLegalPersonInfo',
mpu.name as 'serviceProjectManagerName',
mpu.telephone as 'serviceProjectManagerTelephone'
from police_unit pu
join enterprises_unit eu on pu.snow_flake_id = eu.police_unit_id and eu.delete_flag = 0
join service_project sp on eu.snow_flake_id = sp.enterprises_unit_id and sp.delete_flag = 0
join security_unit su on sp.security_unit_id = su.snow_flake_id and su.delete_flag = 0
LEFT join mini_program_user mpu on sp.project_manager_mini_program_user_id = mpu.snow_flake_id
LEFT join security_user suu on suu.service_project_id = sp.snow_flake_id and suu.delete_flag = 0
where pu.delete_flag = 0
<choose>
<when test="level==1">
and eu.province = #{code}
</when>
<when test="level==2">
and eu.city = #{code}
</when>
<when test="level==3">
and eu.districts = #{code}
</when>
<when test="level==4">
and eu.street = #{code}
</when>
<when test="level==5">
and pu.code = #{code}
</when>
<otherwise>and eu.snow_flake_id = -1</otherwise>
</choose>
group by sp.snow_flake_id
order by sp.create_time desc
</select>
<select id="serviceProjectUserRoster"
resultType="com.changhu.pojo.dto.ServiceProjectSecurityUserRosterDTO">
select su.snow_flake_id,
su.name,
su.sex,
TIMESTAMPDIFF(YEAR, su.date_of_birth, CURDATE()) AS 'age',
su.id_card,
su.telephone,
eu.name as 'enterprisesUnitName',
suu.name as 'securityUnitName',
su.security_number
from enterprises_unit eu
left join service_project sp on sp.enterprises_unit_id = eu.snow_flake_id and sp.delete_flag = 0
left join security_user su on su.service_project_id = sp.snow_flake_id and su.delete_flag = 0
left join security_unit suu on su.security_unit_id = suu.snow_flake_id and suu.delete_flag = 0
where eu.delete_flag = 0
and sp.snow_flake_id = #{serviceProjectId}
order by su.create_time desc
</select>
</mapper>

3
policeSecurityServer/src/main/resources/mapper/ServiceProjectMapper.xml
View File

@ -52,6 +52,7 @@
'securityUnitName',su.name,
'name', sp.name,
'type', sp.type,
'isRecruitSecurity', sp.is_recruit_security,
'idNumber', sp.id_number,
'serviceArea', sp.service_area,
'buildingTotal', sp.building_total,
@ -64,7 +65,7 @@
'idCard',mpu.id_card),
'remark', sp.remark)) as 'service_project_list'
from enterprises_unit eu
left join service_project sp on eu.snow_flake_id = sp.enterprises_unit_id and sp.delete_flag = 0
join service_project sp on eu.snow_flake_id = sp.enterprises_unit_id and sp.delete_flag = 0
left join security_unit su on sp.security_unit_id = su.snow_flake_id and su.delete_flag = 0
left join mini_program_user mpu on sp.project_manager_mini_program_user_id = mpu.snow_flake_id and mpu.delete_flag = 0
left join administrative_division ad1 on eu.province = ad1.code and ad1.delete_flag = 0

6
superManagement/src/config/index.ts
View File

@ -59,11 +59,5 @@ export const SYSTEM_MENUS: SystemMenu[] = [
type: 'menu',
isFull: true,
component: () => import('@/views/data/dataOverview.vue')
}, {
title: '开放平台',
name: 'openPlatform',
path: '/openPlatform',
type: 'menu',
component: () => import('@/views/openPlatform/index.vue')
}
]

8
superManagement/src/global.d.ts vendored
View File

@ -62,11 +62,3 @@ interface BaseEnum<T> {
label: string,
extData?: Record<string, any>
}
/**
* 脱敏数据
*/
interface DesensitizedVo {
originalValue: string;
desensitizedValue: string;
}

2
superManagement/src/stores/modules/userStore.ts
View File

@ -20,7 +20,7 @@ export const useUserStore = defineStore({
getTokenInfo: (state): TokenInfo => state.tokenInfo as TokenInfo,
},
persist: {
key: "spUserStore",
key: "useUserStore",
storage: window.localStorage,
paths: ["tokenInfo"],
}

28
superManagement/src/types/views/openPlatform/openPlatform.ts
View File

@ -1,28 +0,0 @@
// Parameter interface
import {BaseTableRowRecord} from "@/types/components/table";
export interface GeneratedAccessKeyParams {
/* */
snowFlakeId?: string;
/*调用方 */
name: string;
/*有效时间 */
effectiveTime: number;
/*允许访问的资源 */
allowedResources?: string[];
/*是否启用,可用值:TRUE,FALSE */
isEnable: number;
/*备注 */
remark?: string;
}
// Response interface
export interface AccessKeyRes extends BaseTableRowRecord {
name: string;
effectiveTime: number;
accessKey: string;
secretKey: string;
allowedResources: string[];
isEnable: BaseEnum<number>;
remark: string;
}

163
superManagement/src/views/openPlatform/index.vue
View File

@ -1,163 +0,0 @@
<template>
<table-pro-max
ref="tableRef"
:request-api="reqApi"
:is-pagination="false"
:columns="columns"
>
<template #tableHeader>
<a-space>
<a-button class="btn-success" @click="saveOrUpdateAccessKey({
name: '',
effectiveTime: 300000,
isEnable:0
})">添加accessKey
</a-button>
<a-button @click="a">a</a-button>
</a-space>
</template>
</table-pro-max>
</template>
<script setup lang="tsx">
import {message} from "ant-design-vue";
import api from "@/axios";
import {onMounted, ref} from "vue";
import {submitSimpleFormModal} from "@/components/tsx/ModalPro.tsx";
import {dictSelectNodes} from "@/config/dict.ts";
import TableProMax from "@/components/table/TableProMax.vue";
import {TableProMaxProps} from "@/types/components/table";
import {AccessKeyRes, GeneratedAccessKeyParams} from "@/types/views/openPlatform/openPlatform.ts";
import {ComponentExposed} from "vue-component-type-helpers";
import axios from "axios";
import {useUserStore} from "@/stores/modules/userStore.ts";
type TableProps = TableProMaxProps<AccessKeyRes>
const tableRef = ref<ComponentExposed<typeof TableProMax>>(null)
const columns: TableProps['columns'] = [
{
dataIndex: 'name',
title: '调用方'
}, {
dataIndex: 'accessKey',
title: 'accessKey'
}, {
dataIndex: 'secretKey',
title: 'secretKey'
}, {
dataIndex: 'effectiveTime',
title: '有效时间(ms)'
}, {
dataIndex: 'isEnable',
title: '状态',
customRender: ({text}) => <a-tag color={text.extData?.color}>{text.label}</a-tag>
}, {
dataIndex: 'remark',
title: '备注',
}, {
dataIndex: 'createTime',
title: '创建时间'
}, {
dataIndex: 'opt',
title: '操作',
customRender: ({record}) => {
return <a-space>
<a-button class="btn-warn" onClick={() => saveOrUpdateAccessKey({
snowFlakeId: record.snowFlakeId,
name: record.name,
effectiveTime: record.effectiveTime,
isEnable: record.isEnable.value,
allowedResources: record.allowedResources,
remark: record.remark
})}>编辑
</a-button>
</a-space>
}
}
]
const reqApi: TableProps["requestApi"] = () => api.get('/accessKeys/tableList')
const saveOrUpdateAccessKey = (params: GeneratedAccessKeyParams) => {
submitSimpleFormModal<GeneratedAccessKeyParams>({
title: '',
formOptions: {
name: {
type: 'input',
label: '调用方',
required: true
},
effectiveTime: {
type: 'inputNumber',
label: '有效时间(ms)',
required: true,
componentsProps: {
precision: 0
}
},
allowedResources: {
type: 'select',
label: '可访问资源',
options: allowedResources.value,
componentsProps: {
mode: 'multiple'
}
},
isEnable: {
type: "radioGroup",
label: '是否启用',
options: dictSelectNodes("IsEnable")
},
remark: {
type: 'inputTextArea',
label: '备注'
}
},
formParams: {...params},
submit: async (p) => {
const resp = await api.post('/accessKeys/generatedAccessKey', p, {loading: true})
message.success(resp.message)
await tableRef.value?.requestGetTableData()
}
})
}
const userStore = useUserStore()
const a = () => {
axios.get('http://127.0.0.1:8765/open/dataView', {
headers: {
'X-API-KEY': '123',
'access-key': '123',
'time-stamp': '123',
'sign': '123',
'nonce': '123'
}
}).then(resp => {
console.log(resp);
})
// api.get('/open/dataView', null, {
// headers: {
// 'X-API-KEY': '123',
// 'access-key': '123',
// 'time-stamp': '123',
// 'sign': '123',
// 'nonce': '123'
// }
// })
}
const allowedResources = ref<SelectNodeVo<string>[]>([])
onMounted(() => {
api.get<SelectNodeVo<string>[]>('/accessKeys/listOpenApi').then(resp => {
allowedResources.value = resp.data
})
})
</script>
<style scoped lang="scss">
</style>