diff --git a/hake-module-agent/hake-module-agent-api/pom.xml b/hake-module-agent/hake-module-agent-api/pom.xml new file mode 100644 index 0000000..043f989 --- /dev/null +++ b/hake-module-agent/hake-module-agent-api/pom.xml @@ -0,0 +1,45 @@ + + + + cn.iocoder.cloud + hake-module-agent + ${revision} + + 4.0.0 + hake-module-agent-api + jar + + ${project.artifactId} + + agent 模块 API，暴露给其它模块调用 + + + + + cn.iocoder.cloud + hake-common + + + + + org.springframework.boot + spring-boot-starter-validation + true + + + + + central + Central Repository + http://192.168.1.200:19081/repository/maven-hake/ + + + snapshots + Nexus Snapshot Repository + http://192.168.1.200:19081/repository/maven-snapshots/ + + + + \ No newline at end of file diff --git a/hake-module-agent/hake-module-agent-api/src/main/java/cn/iocoder/hake/module/agent/api/package-info.java b/hake-module-agent/hake-module-agent-api/src/main/java/cn/iocoder/hake/module/agent/api/package-info.java new file mode 100644 index 0000000..e1f3a0c --- /dev/null +++ b/hake-module-agent/hake-module-agent-api/src/main/java/cn/iocoder/hake/module/agent/api/package-info.java @@ -0,0 +1,4 @@ +/** + * agent API 包，定义暴露给其它模块的 API + */ +package cn.iocoder.hake.module.erp.api; diff --git a/hake-module-agent/hake-module-agent-api/src/main/java/cn/iocoder/hake/module/agent/enums/ApiConstants.java b/hake-module-agent/hake-module-agent-api/src/main/java/cn/iocoder/hake/module/agent/enums/ApiConstants.java new file mode 100644 index 0000000..daf4e01 --- /dev/null +++ b/hake-module-agent/hake-module-agent-api/src/main/java/cn/iocoder/hake/module/agent/enums/ApiConstants.java @@ -0,0 +1,23 @@ +package cn.iocoder.hake.module.agent.enums; + +import cn.iocoder.hake.framework.common.enums.RpcConstants; + +/** + * API 相关的枚举 + * + * @author hake + */ +public class ApiConstants { + + /** + * 服务名 + * + * 注意，需要保证和 spring.application.name 保持一致 + */ + public static final String NAME = "agent-server"; + + public static final String PREFIX = RpcConstants.RPC_API_PREFIX + "/agent"; + + public static final String VERSION = "1.0.0"; + +} diff --git a/hake-module-agent/hake-module-agent-api/src/main/java/cn/iocoder/hake/module/agent/enums/ErrorCodeConstants.java b/hake-module-agent/hake-module-agent-api/src/main/java/cn/iocoder/hake/module/agent/enums/ErrorCodeConstants.java new file mode 100644 index 0000000..55d2d18 --- /dev/null +++ b/hake-module-agent/hake-module-agent-api/src/main/java/cn/iocoder/hake/module/agent/enums/ErrorCodeConstants.java @@ -0,0 +1,9 @@ +package cn.iocoder.hake.module.agent.enums; + +import cn.iocoder.hake.framework.common.exception.ErrorCode; +public interface ErrorCodeConstants { + // TODO 待办：请将下面的错误码复制到 hake-module-agent 模块的 ErrorCodeConstants 类中。注意，请给“TODO 补充编号”设置一个错误码编号！！！ +// ========== 代理商管理 TODO 补充编号 ========== + ErrorCode AGENT_NOT_EXISTS = new ErrorCode(1_050_100_000, "代理商不存在"); + +} \ No newline at end of file diff --git a/hake-module-agent/hake-module-agent-api/src/main/java/cn/iocoder/hake/module/agent/enums/agent/AuditStatusEnum.java b/hake-module-agent/hake-module-agent-api/src/main/java/cn/iocoder/hake/module/agent/enums/agent/AuditStatusEnum.java new file mode 100644 index 0000000..22c8dfb --- /dev/null +++ b/hake-module-agent/hake-module-agent-api/src/main/java/cn/iocoder/hake/module/agent/enums/agent/AuditStatusEnum.java @@ -0,0 +1,92 @@ +package cn.iocoder.hake.module.agent.enums.agent; + +import lombok.AllArgsConstructor; +import lombok.Getter; + +/** + * 代理商审核状态的枚举值 + * + * @author hake + */ +@Getter +/** + * 审核状态枚举类 + * 定义了系统中各种审核相关的状态 + */ +public enum AuditStatusEnum { + /** + * 禁用状态 + */ + DISABLED(0, "禁用"), + + /** + * 未认证状态 + */ + UNVERIFIED(1, "未认证"), + + /** + * 审核中状态 + */ + UNDER_REVIEW(2, "审核中"), + + /** + * 审核驳回状态 + */ + REJECTED(3, "审核驳回"), + + /** + * 启用状态 + */ + ENABLED(4, "启用"); + + /** + * 状态编码 + */ + private final Integer code; + + /** + * 状态描述 + */ + private final String description; + + /** + * 构造方法 + * @param code 状态编码 + * @param description 状态描述 + */ + AuditStatusEnum(Integer code, String description) { + this.code = code; + this.description = description; + } + + /** + * 获取状态编码 + * @return 状态编码 + */ + public Integer getCode() { + return code; + } + + /** + * 获取状态描述 + * @return 状态描述 + */ + public String getDescription() { + return description; + } + + /** + * 根据编码获取枚举实例 + * @param code 状态编码 + * @return 对应的枚举实例，如果没有匹配的则返回null + */ + public static AuditStatusEnum getByCode(Integer code) { + for (AuditStatusEnum status : values()) { + if (status.code == code) { + return status; + } + } + return null; + } +} + diff --git a/hake-module-agent/hake-module-agent-api/src/main/java/cn/iocoder/hake/module/agent/enums/agent/JudgeFlagEnum.java b/hake-module-agent/hake-module-agent-api/src/main/java/cn/iocoder/hake/module/agent/enums/agent/JudgeFlagEnum.java new file mode 100644 index 0000000..01ce6d7 --- /dev/null +++ b/hake-module-agent/hake-module-agent-api/src/main/java/cn/iocoder/hake/module/agent/enums/agent/JudgeFlagEnum.java @@ -0,0 +1,67 @@ +package cn.iocoder.hake.module.agent.enums.agent; + +import lombok.Getter; + + +@Getter +/** + * 是否允许枚举值：0-否；1-是 + * + * @author hake + */ +public enum JudgeFlagEnum { +// 是否允许发展下级：0-否；1-是 + IS_FLAG(0, "是"), + NO_FLAG(1, "否"); + + /** + * 状态编码 + */ + private final Integer code; + + /** + * 状态描述 + */ + private final String description; + + /** + * 构造方法 + * @param code 状态编码 + * @param description 状态描述 + */ + JudgeFlagEnum(Integer code, String description) { + this.code = code; + this.description = description; + } + + /** + * 获取状态编码 + * @return 状态编码 + */ + public Integer getCode() { + return code; + } + + /** + * 获取状态描述 + * @return 状态描述 + */ + public String getDescription() { + return description; + } + + /** + * 根据编码获取枚举实例 + * @param code 状态编码 + * @return 对应的枚举实例，如果没有匹配的则返回null + */ + public static JudgeFlagEnum getByCode(Integer code) { + for (JudgeFlagEnum status : values()) { + if (status.code == code) { + return status; + } + } + return null; + } +} + diff --git a/hake-module-agent/hake-module-agent-server/Dockerfile b/hake-module-agent/hake-module-agent-server/Dockerfile new file mode 100644 index 0000000..b5cfe47 --- /dev/null +++ b/hake-module-agent/hake-module-agent-server/Dockerfile @@ -0,0 +1,19 @@ +## AdoptOpenJDK 停止发布 OpenJDK 二进制，而 Eclipse Temurin 是它的延伸，提供更好的稳定性 +## 感谢复旦核博士的建议！灰子哥，牛皮！ +FROM eclipse-temurin:8-jre + +## 创建目录，并使用它作为工作目录 +RUN mkdir -p /hake-module-agent-server +WORKDIR /hake-module-agent-server +## 将后端项目的 Jar 文件，复制到镜像中 +COPY ./target/hake-module-agent-server.jar app.jar + +## 设置 TZ 时区 +## 设置 JAVA_OPTS 环境变量，可通过 docker run -e "JAVA_OPTS=" 进行覆盖 +ENV TZ=Asia/Shanghai JAVA_OPTS="-Xms512m -Xmx512m" + +## 暴露后端项目的 48088 端口 +EXPOSE 48090 + +## 启动后端项目 +CMD java ${JAVA_OPTS} -Djava.security.egd=file:/dev/./urandom -jar app.jar diff --git a/hake-module-agent/hake-module-agent-server/pom.xml b/hake-module-agent/hake-module-agent-server/pom.xml new file mode 100644 index 0000000..ba56d44 --- /dev/null +++ b/hake-module-agent/hake-module-agent-server/pom.xml @@ -0,0 +1,135 @@ + + + + cn.iocoder.cloud + hake-module-agent + ${revision} + + 4.0.0 + hake-module-agent-server + + ${project.artifactId} + + agent 包下，代理商管理 + + + + + + cn.iocoder.cloud + hake-spring-boot-starter-env + + + + + cn.iocoder.cloud + hake-module-system-api + ${revision} + + + cn.iocoder.cloud + hake-module-agent-api + ${revision} + + + + + cn.iocoder.cloud + hake-spring-boot-starter-biz-tenant + + + + + cn.iocoder.cloud + hake-spring-boot-starter-security + + + + + cn.iocoder.cloud + hake-spring-boot-starter-mybatis + + + + cn.iocoder.cloud + hake-spring-boot-starter-redis + + + + + cn.iocoder.cloud + hake-spring-boot-starter-rpc + + + + + com.alibaba.cloud + spring-cloud-starter-alibaba-nacos-discovery + + + + + com.alibaba.cloud + spring-cloud-starter-alibaba-nacos-config + + + + + cn.iocoder.cloud + hake-spring-boot-starter-excel + + + + + cn.iocoder.cloud + hake-spring-boot-starter-monitor + + + + + cn.iocoder.cloud + hake-spring-boot-starter-test + + + + + + central + Central Repository + http://192.168.1.200:19081/repository/maven-hake/ + + + snapshots + Nexus Snapshot Repository + http://192.168.1.200:19081/repository/maven-snapshots/ + + + + + + ${project.artifactId} + + + + org.springframework.boot + spring-boot-maven-plugin + ${spring.boot.version} + + agent +../../packge + + + + + + repackage + + + + + + + + \ No newline at end of file diff --git a/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/AgentServerApplication.java b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/AgentServerApplication.java new file mode 100644 index 0000000..9879c94 --- /dev/null +++ b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/AgentServerApplication.java @@ -0,0 +1,19 @@ +package cn.iocoder.hake.module.agent; + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; + +/** + * 项目的启动类 + * + * @author hake + */ +@SpringBootApplication +public class AgentServerApplication { + + public static void main(String[] args) { + + SpringApplication.run(AgentServerApplication.class, args); + } + +} diff --git a/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/controller/admin/agent/AgentController.java b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/controller/admin/agent/AgentController.java new file mode 100644 index 0000000..573b114 --- /dev/null +++ b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/controller/admin/agent/AgentController.java @@ -0,0 +1,110 @@ +package cn.iocoder.hake.module.agent.controller.admin.agent; + +import org.springframework.web.bind.annotation.*; +import javax.annotation.Resource; +import org.springframework.validation.annotation.Validated; +import org.springframework.security.access.prepost.PreAuthorize; +import io.swagger.v3.oas.annotations.tags.Tag; +import io.swagger.v3.oas.annotations.Parameter; +import io.swagger.v3.oas.annotations.Operation; + +import javax.validation.*; +import javax.servlet.http.*; +import java.util.*; +import java.io.IOException; + +import cn.iocoder.hake.framework.common.pojo.PageParam; +import cn.iocoder.hake.framework.common.pojo.PageResult; +import cn.iocoder.hake.framework.common.pojo.CommonResult; +import cn.iocoder.hake.framework.common.util.object.BeanUtils; +import static cn.iocoder.hake.framework.common.pojo.CommonResult.success; + +import cn.iocoder.hake.framework.excel.core.util.ExcelUtils; + +import cn.iocoder.hake.framework.apilog.core.annotation.ApiAccessLog; +import static cn.iocoder.hake.framework.apilog.core.enums.OperateTypeEnum.*; + +import cn.iocoder.hake.module.agent.controller.admin.agent.vo.*; +import cn.iocoder.hake.module.agent.dal.dataobject.agent.AgentDO; +import cn.iocoder.hake.module.agent.service.agent.AgentService; + +@Tag(name = "管理后台 - 代理商管理") +@RestController +@RequestMapping("/agent/agent") +@Validated +public class AgentController { + + @Resource + private AgentService agentService; + + @PostMapping("/create") + @Operation(summary = "创建代理商管理") + @PreAuthorize("@ss.hasPermission('agent:info:create')") + public CommonResult createAgent(@Valid @RequestBody AgentSaveReqVO createReqVO) { + return success(agentService.createAgent(createReqVO)); + } + + @PostMapping("/updateStatus") + @Operation(summary = "代理商审核") + @PreAuthorize("@ss.hasPermission('agent:info:audit')") + public CommonResult updateAgentStatus(@Valid @RequestBody AuditRespVO auditRespVO) { + return success(agentService.updateAgentStatus(auditRespVO)); + } + + @PutMapping("/update") + @Operation(summary = "更新代理商管理") + @PreAuthorize("@ss.hasPermission('agent:info:update')") + public CommonResult updateAgent(@Valid @RequestBody AgentSaveReqVO updateReqVO) { + agentService.updateAgent(updateReqVO); + return success(true); + } + + @DeleteMapping("/delete") + @Operation(summary = "删除代理商管理") + @Parameter(name = "id", description = "编号", required = true) + @PreAuthorize("@ss.hasPermission('agent:info:delete')") + public CommonResult deleteAgent(@RequestParam("id") Long id) { + agentService.deleteAgent(id); + return success(true); + } + + @DeleteMapping("/delete-list") + @Parameter(name = "ids", description = "编号", required = true) + @Operation(summary = "批量删除代理商管理") + @PreAuthorize("@ss.hasPermission('agent:info:delete')") + public CommonResult deleteAgentList(@RequestParam("ids") List ids) { + agentService.deleteAgentListByIds(ids); + return success(true); + } + + @GetMapping("/get") + @Operation(summary = "获得代理商管理") + @Parameter(name = "id", description = "编号", required = true, example = "1024") + @PreAuthorize("@ss.hasPermission('agent:info:query')") + public CommonResult getAgent(@RequestParam("id") Long id) { + AgentDO agent = agentService.getAgent(id); + return success(BeanUtils.toBean(agent, AgentRespVO.class)); + } + + @GetMapping("/page") + @Operation(summary = "获得代理商管理分页") + @PreAuthorize("@ss.hasPermission('agent:info:query')") + public CommonResult> getAgentPage(@Valid AgentPageReqVO pageReqVO) { + PageResult pageResult = agentService.getAgentPage(pageReqVO); + return success(BeanUtils.toBean(pageResult, AgentRespVO.class)); + } + + @GetMapping("/export-excel") + @Operation(summary = "导出代理商管理 Excel") + @PreAuthorize("@ss.hasPermission('agent:info:export')") + @ApiAccessLog(operateType = EXPORT) + public void exportAgentExcel(@Valid AgentPageReqVO pageReqVO, + HttpServletResponse response) throws IOException { + pageReqVO.setPageSize(PageParam.PAGE_SIZE_NONE); + List list = agentService.getAgentPage(pageReqVO).getList(); + // 导出 Excel + ExcelUtils.write(response, "代理商管理.xls", "数据", AgentRespVO.class, + BeanUtils.toBean(list, AgentRespVO.class)); + } + +} \ No newline at end of file diff --git a/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/controller/admin/agent/vo/AgentPageReqVO.java b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/controller/admin/agent/vo/AgentPageReqVO.java new file mode 100644 index 0000000..d09a7a8 --- /dev/null +++ b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/controller/admin/agent/vo/AgentPageReqVO.java @@ -0,0 +1,104 @@ +package cn.iocoder.hake.module.agent.controller.admin.agent.vo; + +import lombok.*; + +import java.time.LocalDate; + +import io.swagger.v3.oas.annotations.media.Schema; +import cn.iocoder.hake.framework.common.pojo.PageParam; +import org.springframework.format.annotation.DateTimeFormat; +import java.time.LocalDateTime; + +import static cn.iocoder.hake.framework.common.util.date.DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND; + +@Schema(description = "管理后台 - 代理商管理分页 Request VO") +@Data +public class AgentPageReqVO extends PageParam { + + @Schema(description = "代理商登陆名", example = "哈客") + private String agentName; + + @Schema(description = "代理商编码（系统自动生成，格式如AGT+日期+序号，用于业务标识）") + private String agentCode; + + @Schema(description = "代理商全称（需与营业执照一致）", example = "哈客") + private String agentNickname; + + @Schema(description = "代理商简称（用于日常展示）", example = "李四") + private String agentShortNickname; + + @Schema(description = "审核状态（枚举：0-禁用;1-未认证；2-待审核；3-审核中；4-审核驳回；05-启用；）", example = "2") + private Integer status; + + @Schema(description = "是否允许发展下级代理：0-否；1-是") + private Integer childAgentFlag; + + @Schema(description = "是否允许发展下级商户：0-否；1-是") + private Integer childMchFlag; + + @Schema(description = "是否发送开通提醒：0-否；1-是") + private Integer informFlag; + + @Schema(description = "代理商类型（枚举：1-个人代理；2-企业代理）", example = "2") + private Integer agentType; + + @Schema(description = "代理商等级（枚举：1-一级；2-二级）") + private Integer agentLevel; + + @Schema(description = "上级代理商ID（自关联agent_id，用于多级代理体系，无上级则为空）", example = "29314") + private Long parentAgentId; + + @Schema(description = "主要联系人（日常对接人）") + private String contactPerson; + + @Schema(description = "联系电话（必填，用于系统通知和业务沟通）") + private String contactPhone; + + @Schema(description = "联系邮箱（用于合同发送、对账通知等）") + private String contactEmail; + + @Schema(description = "联系人或法人身份证人像面照片的URL路径") + private String cardFrontPhoto; + + @Schema(description = "联系人或法人身份证国徽面照片的URL路径；与上一字段关联，需同时上传") + private String cardReversePhoto; + + @Schema(description = "联系人或法人手持承诺函照片的URL路径") + private String commitmentPhoto; + + @Schema(description = "营业执照照片的URL路径") + private String businessLicensePhoto; + + @Schema(description = "开户许可证照片的URL路径") + private String bankAccountPermit; + + @Schema(description = "合作状态（枚举：0-待合作；1-合作中；2-暂停合作；3-终止合作）", example = "2") + private Integer cooperationStatus; + + @Schema(description = "收款账户类型（枚举：1 - 银行卡；2 - 支付宝；3 - 微信支付）", example = "1") + private Integer receiveAccountType; + + @Schema(description = "账户姓名（需与证件姓名一致，用于收款账户实名校验）", example = "赵六") + private String accountName; + + @Schema(description = "支付宝账号（当receive_account_type=2时必填，格式为手机号或邮箱）", example = "1677") + private String alipayAccount; + + @Schema(description = "开户银行名称（当receive_account_type=1时必填，如 中国工商银行）", example = "赵六") + private String bankName; + + @Schema(description = "收款账号（银行卡号或对公账户号，当receive_account_type=1时必填）", example = "13854") + private String bankAccount; + + @Schema(description = "开户行支行名称（当receive_account_type=1时必填，如 北京朝阳支行）") + private String bankBranch; + + @Schema(description = "签约日期（合同签订时间）") + @DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND) + private LocalDate[] signDate; + + @Schema(description = "创建时间") + @DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND) + private LocalDateTime[] createTime; + +} \ No newline at end of file diff --git a/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/controller/admin/agent/vo/AgentRespVO.java b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/controller/admin/agent/vo/AgentRespVO.java new file mode 100644 index 0000000..70f539b --- /dev/null +++ b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/controller/admin/agent/vo/AgentRespVO.java @@ -0,0 +1,137 @@ +package cn.iocoder.hake.module.agent.controller.admin.agent.vo; + +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.*; + +import java.time.LocalDate; +import java.time.LocalDateTime; +import com.alibaba.excel.annotation.*; + +@Schema(description = "管理后台 - 代理商管理 Response VO") +@Data +@ExcelIgnoreUnannotated +public class AgentRespVO { + + @Schema(description = "代理商唯一标识（自增ID，建议用雪花算法确保分布式系统唯一性）", requiredMode = Schema.RequiredMode.REQUIRED, example = "16582") + @ExcelProperty("代理商唯一标识（自增ID，建议用雪花算法确保分布式系统唯一性）") + private Long id; + + @Schema(description = "代理商登陆名", requiredMode = Schema.RequiredMode.REQUIRED, example = "哈客") + @ExcelProperty("代理商登陆名") + private String agentName; + + @Schema(description = "代理商编码（系统自动生成，格式如AGT+日期+序号，用于业务标识）", requiredMode = Schema.RequiredMode.REQUIRED) + @ExcelProperty("代理商编码（系统自动生成，格式如AGT+日期+序号，用于业务标识）") + private String agentCode; + + @Schema(description = "代理商全称（需与营业执照一致）", example = "哈客") + @ExcelProperty("代理商全称（需与营业执照一致）") + private String agentNickname; + + @Schema(description = "代理商简称（用于日常展示）", example = "李四") + @ExcelProperty("代理商简称（用于日常展示）") + private String agentShortNickname; + + @Schema(description = "审核状态（枚举：0-禁用;1-未认证；2-待审核；3-审核中；4-审核驳回；05-启用；）", example = "2") + @ExcelProperty("审核状态（枚举：0-禁用;1-未认证；2-待审核；3-审核中；4-审核驳回；05-启用；）") + private Integer status; + + @Schema(description = "是否允许发展下级代理：0-否；1-是") + @ExcelProperty("是否允许发展下级代理：0-否；1-是") + private Integer childAgentFlag; + + @Schema(description = "是否允许发展下级商户：0-否；1-是") + @ExcelProperty("是否允许发展下级商户：0-否；1-是") + private Integer childMchFlag; + + @Schema(description = "是否发送开通提醒：0-否；1-是") + @ExcelProperty("是否发送开通提醒：0-否；1-是") + private Integer informFlag; + + @Schema(description = "代理商类型（枚举：1-个人代理；2-企业代理）", example = "2") + @ExcelProperty("代理商类型（枚举：1-个人代理；2-企业代理）") + private Integer agentType; + + @Schema(description = "代理商等级（枚举：1-一级；2-二级）") + @ExcelProperty("代理商等级（枚举：1-一级；2-二级）") + private Integer agentLevel; + + @Schema(description = "上级代理商ID（自关联agent_id，用于多级代理体系，无上级则为空）", example = "29314") + @ExcelProperty("上级代理商ID（自关联agent_id，用于多级代理体系，无上级则为空）") + private Long parentAgentId; + + @Schema(description = "主要联系人（日常对接人）") + @ExcelProperty("主要联系人（日常对接人）") + private String contactPerson; + + @Schema(description = "联系电话（必填，用于系统通知和业务沟通）") + @ExcelProperty("联系电话（必填，用于系统通知和业务沟通）") + private String contactPhone; + + @Schema(description = "联系邮箱（用于合同发送、对账通知等）") + @ExcelProperty("联系邮箱（用于合同发送、对账通知等）") + private String contactEmail; + + @Schema(description = "联系人或法人身份证人像面照片的URL路径") + @ExcelProperty("联系人或法人身份证人像面照片的URL路径") + private String cardFrontPhoto; + + @Schema(description = "联系人或法人身份证国徽面照片的URL路径；与上一字段关联，需同时上传") + @ExcelProperty("联系人或法人身份证国徽面照片的URL路径；与上一字段关联，需同时上传") + private String cardReversePhoto; + + @Schema(description = "联系人或法人手持承诺函照片的URL路径") + @ExcelProperty("联系人或法人手持承诺函照片的URL路径") + private String commitmentPhoto; + + @Schema(description = "营业执照照片的URL路径") + @ExcelProperty("营业执照照片的URL路径") + private String businessLicensePhoto; + + @Schema(description = "开户许可证照片的URL路径") + @ExcelProperty("开户许可证照片的URL路径") + private String bankAccountPermit; + + @Schema(description = "合作状态（枚举：0-待合作；1-合作中；2-暂停合作；3-终止合作）", example = "2") + @ExcelProperty("合作状态（枚举：0-待合作；1-合作中；2-暂停合作；3-终止合作）") + private Integer cooperationStatus; + + @Schema(description = "收款账户类型（枚举：1 - 银行卡；2 - 支付宝；3 - 微信支付）", example = "1") + @ExcelProperty("收款账户类型（枚举：1 - 银行卡；2 - 支付宝；3 - 微信支付）") + private Integer receiveAccountType; + + @Schema(description = "账户姓名（需与证件姓名一致，用于收款账户实名校验）", example = "赵六") + @ExcelProperty("账户姓名（需与证件姓名一致，用于收款账户实名校验）") + private String accountName; + + @Schema(description = "支付宝账号（当receive_account_type=2时必填，格式为手机号或邮箱）", example = "1677") + @ExcelProperty("支付宝账号（当receive_account_type=2时必填，格式为手机号或邮箱）") + private String alipayAccount; + + @Schema(description = "开户银行名称（当receive_account_type=1时必填，如 中国工商银行）", example = "赵六") + @ExcelProperty("开户银行名称（当receive_account_type=1时必填，如 中国工商银行）") + private String bankName; + + @Schema(description = "收款账号（银行卡号或对公账户号，当receive_account_type=1时必填）", example = "13854") + @ExcelProperty("收款账号（银行卡号或对公账户号，当receive_account_type=1时必填）") + private String bankAccount; + + @Schema(description = "开户行支行名称（当receive_account_type=1时必填，如 北京朝阳支行）") + @ExcelProperty("开户行支行名称（当receive_account_type=1时必填，如 北京朝阳支行）") + private String bankBranch; + + @Schema(description = "签约日期（合同签订时间）") + @ExcelProperty("签约日期（合同签订时间）") + private LocalDate signDate; + + + @Schema(description = "这是审核备注信息") + @ExcelProperty("审核备注") + + private String auditRemark; + + @Schema(description = "创建时间") + @ExcelProperty("创建时间") + private LocalDateTime createTime; + +} \ No newline at end of file diff --git a/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/controller/admin/agent/vo/AgentSaveReqVO.java b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/controller/admin/agent/vo/AgentSaveReqVO.java new file mode 100644 index 0000000..ee08b24 --- /dev/null +++ b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/controller/admin/agent/vo/AgentSaveReqVO.java @@ -0,0 +1,104 @@ +package cn.iocoder.hake.module.agent.controller.admin.agent.vo; + +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.*; + +import java.time.LocalDate; +import javax.validation.constraints.*; + +@Schema(description = "管理后台 - 代理商管理新增/修改 Request VO") +@Data +public class AgentSaveReqVO { + + @Schema(description = "代理商唯一标识（自增ID，建议用雪花算法确保分布式系统唯一性）", requiredMode = Schema.RequiredMode.REQUIRED, example = "16582") + private Long id; + + @Schema(description = "代理商登陆名", requiredMode = Schema.RequiredMode.REQUIRED, example = "哈客") + @NotEmpty(message = "代理商登陆名不能为空") + private String agentName; + + @Schema(description = "代理商编码（系统自动生成，格式如 AGT+日期+序号，用于业务标识）", requiredMode = Schema.RequiredMode.REQUIRED) + @NotEmpty(message = "代理商编码（系统自动生成，格式如AGT+日期+序号，用于业务标识）不能为空") + private String agentCode; + + @Schema(description = "代理商全称（需与营业执照一致）", example = "哈客") + private String agentNickname; + + @Schema(description = "代理商简称（用于日常展示）", example = "李四") + private String agentShortNickname; + + @Schema(description = "审核状态（枚举：0-禁用;1-未认证；2-待审核；3-审核中；4-审核驳回；05-启用；）", example = "2") + private Integer status; + + @Schema(description = "是否允许发展下级代理：0-否；1-是") + private Integer childAgentFlag; + + @Schema(description = "是否允许发展下级商户：0-否；1-是") + private Integer childMchFlag; + + @Schema(description = "是否发送开通提醒：0-否；1-是") + private Integer informFlag; + + @Schema(description = "代理商类型（枚举：1-个人代理；2-企业代理）", example = "2") + private Integer agentType; + + @Schema(description = "代理商等级（枚举：1-一级；2-二级）") + private Integer agentLevel; + + @Schema(description = "上级代理商ID（自关联agent_id，用于多级代理体系，无上级则为空）", example = "29314") + private Long parentAgentId; + + @Schema(description = "主要联系人（日常对接人）") + private String contactPerson; + + @Schema(description = "联系电话（必填，用于系统通知和业务沟通）") + private String contactPhone; + + @Schema(description = "联系邮箱（用于合同发送、对账通知等）") + private String contactEmail; + + @Schema(description = "联系人或法人身份证人像面照片的URL路径") + private String cardFrontPhoto; + + @Schema(description = "联系人或法人身份证国徽面照片的URL路径；与上一字段关联，需同时上传") + private String cardReversePhoto; + + @Schema(description = "联系人或法人手持承诺函照片的URL路径") + private String commitmentPhoto; + + @Schema(description = "营业执照照片的URL路径") + private String businessLicensePhoto; + + @Schema(description = "开户许可证照片的URL路径") + private String bankAccountPermit; + + @Schema(description = "合作状态（枚举：0-待合作；1-合作中；2-暂停合作；3-终止合作）", example = "2") + private Integer cooperationStatus; + + @Schema(description = "收款账户类型（枚举：1 - 银行卡；2 - 支付宝；3 - 微信支付）", example = "1") + private Integer receiveAccountType; + + @Schema(description = "账户姓名（需与证件姓名一致，用于收款账户实名校验）", example = "赵六") + private String accountName; + + @Schema(description = "支付宝账号（当receive_account_type=2时必填，格式为手机号或邮箱）", example = "1677") + private String alipayAccount; + + @Schema(description = "开户银行名称（当receive_account_type=1时必填，如 中国工商银行）", example = "赵六") + private String bankName; + + @Schema(description = "收款账号（银行卡号或对公账户号，当receive_account_type=1时必填）", example = "13854") + private String bankAccount; + + @Schema(description = "开户行支行名称（当receive_account_type=1时必填，如 北京朝阳支行）") + private String bankBranch; + + @Schema(description = "这是审核备注信息") + private String auditRemark; + + @Schema(description = "签约日期（合同签订时间）") + private LocalDate signDate; + + + +} \ No newline at end of file diff --git a/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/controller/admin/agent/vo/AuditRespVO.java b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/controller/admin/agent/vo/AuditRespVO.java new file mode 100644 index 0000000..8dc3726 --- /dev/null +++ b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/controller/admin/agent/vo/AuditRespVO.java @@ -0,0 +1,25 @@ +package cn.iocoder.hake.module.agent.controller.admin.agent.vo; + +import com.alibaba.excel.annotation.ExcelIgnoreUnannotated; +import com.alibaba.excel.annotation.ExcelProperty; +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.Data; + +import java.time.LocalDate; +import java.time.LocalDateTime; + +@Schema(description = "管理后台 - 代理商审核 Response VO") +@Data +public class AuditRespVO { + + @Schema(description = "主键ID", requiredMode = Schema.RequiredMode.REQUIRED, example = "16582") + private Long id; + + + @Schema(description = "审核状态（枚举：0-禁用;1-未认证；2-待审核；3-审核中；4-审核驳回；05-启用；）", example = "2") + private Integer status; + + @Schema(description = "这是审核备注信息") + private String auditRemark; + +} \ No newline at end of file diff --git a/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/dal/dataobject/agent/AgentDO.java b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/dal/dataobject/agent/AgentDO.java new file mode 100644 index 0000000..332cfae --- /dev/null +++ b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/dal/dataobject/agent/AgentDO.java @@ -0,0 +1,143 @@ +package cn.iocoder.hake.module.agent.dal.dataobject.agent; + +import lombok.*; + +import java.time.LocalDate; + +import com.baomidou.mybatisplus.annotation.*; +import cn.iocoder.hake.framework.mybatis.core.dataobject.BaseDO; + +/** + * 代理商管理 DO + * + * @author hake + */ +@TableName("agent_info") +@Data +@EqualsAndHashCode(callSuper = true) +@ToString(callSuper = true) +@Builder +@NoArgsConstructor +@AllArgsConstructor +public class AgentDO extends BaseDO { + + /** + * 代理商唯一标识（自增ID，建议用雪花算法确保分布式系统唯一性） + */ + @TableId + private Long id; + /** + * 代理商登陆名 + */ + private String agentName; + /** + * 代理商编码（系统自动生成，格式如"AGT+日期+序号"，用于业务标识） + */ + private String agentCode; + /** + * 代理商全称（需与营业执照一致） + */ + private String agentNickname; + /** + * 代理商简称（用于日常展示） + */ + private String agentShortNickname; + /** + * 审核状态（枚举：0-禁用;1-未认证；2-待审核；3-审核中；4-审核驳回；05-启用；） + */ + private Integer status; + /** + * 是否允许发展下级代理：0-否；1-是 + */ + private Integer childAgentFlag; + /** + * 是否允许发展下级商户：0-否；1-是 + */ + private Integer childMchFlag; + /** + * 是否发送开通提醒：0-否；1-是 + */ + private Integer informFlag; + /** + * 代理商类型（枚举：1-个人代理；2-企业代理） + */ + private Integer agentType; + /** + * 代理商等级（枚举：1-一级；2-二级） + */ + private Integer agentLevel; + /** + * 上级代理商ID（自关联agent_id，用于多级代理体系，无上级则为空） + */ + private Long parentAgentId; + /** + * 主要联系人（日常对接人） + */ + private String contactPerson; + /** + * 联系电话（必填，用于系统通知和业务沟通） + */ + private String contactPhone; + /** + * 联系邮箱（用于合同发送、对账通知等） + */ + private String contactEmail; + /** + * 联系人或法人身份证人像面照片的URL路径 + */ + private String cardFrontPhoto; + /** + * 联系人或法人身份证国徽面照片的URL路径；与上一字段关联，需同时上传 + */ + private String cardReversePhoto; + /** + * 联系人或法人手持承诺函照片的URL路径 + */ + private String commitmentPhoto; + /** + * 营业执照照片的URL路径 + */ + private String businessLicensePhoto; + /** + * 开户许可证照片的URL路径 + */ + private String bankAccountPermit; + /** + * 合作状态（枚举：0-待合作；1-合作中；2-暂停合作；3-终止合作） + */ + private Integer cooperationStatus; + /** + * 收款账户类型（枚举：1 - 银行卡；2 - 支付宝；3 - 微信支付） + */ + private Integer receiveAccountType; + /** + * 账户姓名（需与证件姓名一致，用于收款账户实名校验） + */ + private String accountName; + /** + * 支付宝账号（当receive_account_type=2时必填，格式为手机号或邮箱） + */ + private String alipayAccount; + /** + * 开户银行名称（当receive_account_type=1时必填，如 "中国工商银行"） + */ + private String bankName; + /** + * 收款账号（银行卡号或对公账户号，当receive_account_type=1时必填） + */ + private String bankAccount; + /** + * 开户行支行名称（当receive_account_type=1时必填，如 "北京朝阳支行"） + */ + private String bankBranch; + /** + * 签约日期（合同签订时间） + */ + private LocalDate signDate; + + /** + * 这是审核备注信息 + */ + private String auditRemark; + +} \ No newline at end of file diff --git a/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/dal/mysql/agent/AgentMapper.java b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/dal/mysql/agent/AgentMapper.java new file mode 100644 index 0000000..f1bab17 --- /dev/null +++ b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/dal/mysql/agent/AgentMapper.java @@ -0,0 +1,51 @@ +package cn.iocoder.hake.module.agent.dal.mysql.agent; + +import cn.iocoder.hake.framework.common.pojo.PageResult; +import cn.iocoder.hake.framework.mybatis.core.query.LambdaQueryWrapperX; +import cn.iocoder.hake.framework.mybatis.core.mapper.BaseMapperX; +import cn.iocoder.hake.module.agent.dal.dataobject.agent.AgentDO; +import org.apache.ibatis.annotations.Mapper; +import cn.iocoder.hake.module.agent.controller.admin.agent.vo.*; + +/** + * 代理商管理 Mapper + * + * @author hake + */ +@Mapper +public interface AgentMapper extends BaseMapperX { + + default PageResult selectPage(AgentPageReqVO reqVO) { + return selectPage(reqVO, new LambdaQueryWrapperX() + .likeIfPresent(AgentDO::getAgentName, reqVO.getAgentName()) + .eqIfPresent(AgentDO::getAgentCode, reqVO.getAgentCode()) + .likeIfPresent(AgentDO::getAgentNickname, reqVO.getAgentNickname()) + .likeIfPresent(AgentDO::getAgentShortNickname, reqVO.getAgentShortNickname()) + .eqIfPresent(AgentDO::getStatus, reqVO.getStatus()) + .eqIfPresent(AgentDO::getChildAgentFlag, reqVO.getChildAgentFlag()) + .eqIfPresent(AgentDO::getChildMchFlag, reqVO.getChildMchFlag()) + .eqIfPresent(AgentDO::getInformFlag, reqVO.getInformFlag()) + .eqIfPresent(AgentDO::getAgentType, reqVO.getAgentType()) + .eqIfPresent(AgentDO::getAgentLevel, reqVO.getAgentLevel()) + .eqIfPresent(AgentDO::getParentAgentId, reqVO.getParentAgentId()) + .eqIfPresent(AgentDO::getContactPerson, reqVO.getContactPerson()) + .eqIfPresent(AgentDO::getContactPhone, reqVO.getContactPhone()) + .eqIfPresent(AgentDO::getContactEmail, reqVO.getContactEmail()) + .eqIfPresent(AgentDO::getCardFrontPhoto, reqVO.getCardFrontPhoto()) + .eqIfPresent(AgentDO::getCardReversePhoto, reqVO.getCardReversePhoto()) + .eqIfPresent(AgentDO::getCommitmentPhoto, reqVO.getCommitmentPhoto()) + .eqIfPresent(AgentDO::getBusinessLicensePhoto, reqVO.getBusinessLicensePhoto()) + .eqIfPresent(AgentDO::getBankAccountPermit, reqVO.getBankAccountPermit()) + .eqIfPresent(AgentDO::getCooperationStatus, reqVO.getCooperationStatus()) + .eqIfPresent(AgentDO::getReceiveAccountType, reqVO.getReceiveAccountType()) + .likeIfPresent(AgentDO::getAccountName, reqVO.getAccountName()) + .eqIfPresent(AgentDO::getAlipayAccount, reqVO.getAlipayAccount()) + .likeIfPresent(AgentDO::getBankName, reqVO.getBankName()) + .eqIfPresent(AgentDO::getBankAccount, reqVO.getBankAccount()) + .eqIfPresent(AgentDO::getBankBranch, reqVO.getBankBranch()) + .betweenIfPresent(AgentDO::getSignDate, reqVO.getSignDate()) + .betweenIfPresent(AgentDO::getCreateTime, reqVO.getCreateTime()) + .orderByDesc(AgentDO::getId)); + } + +} \ No newline at end of file diff --git a/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/framework/package-info.java b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/framework/package-info.java new file mode 100644 index 0000000..10f099c --- /dev/null +++ b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/framework/package-info.java @@ -0,0 +1,6 @@ +/** + * 属于 erp 模块的 framework 封装 + * + * @author hake + */ +package cn.iocoder.hake.module.agent.framework; diff --git a/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/framework/rpc/config/RpcConfiguration.java b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/framework/rpc/config/RpcConfiguration.java new file mode 100644 index 0000000..3abf87d --- /dev/null +++ b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/framework/rpc/config/RpcConfiguration.java @@ -0,0 +1,10 @@ +package cn.iocoder.hake.module.agent.framework.rpc.config; + +import cn.iocoder.hake.module.system.api.user.AdminUserApi; +import org.springframework.cloud.openfeign.EnableFeignClients; +import org.springframework.context.annotation.Configuration; + +@Configuration(value = "agentRpcConfiguration", proxyBeanMethods = false) +@EnableFeignClients(clients = AdminUserApi.class) +public class RpcConfiguration { +} diff --git a/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/framework/rpc/package-info.java b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/framework/rpc/package-info.java new file mode 100644 index 0000000..9c6b738 --- /dev/null +++ b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/framework/rpc/package-info.java @@ -0,0 +1,4 @@ +/** + * 占位 + */ +package cn.iocoder.hake.module.agent.framework.rpc; diff --git a/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/framework/security/config/SecurityConfiguration.java b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/framework/security/config/SecurityConfiguration.java new file mode 100644 index 0000000..cabaa4f --- /dev/null +++ b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/framework/security/config/SecurityConfiguration.java @@ -0,0 +1,39 @@ +package cn.iocoder.hake.module.agent.framework.security.config; + +import cn.iocoder.hake.framework.security.config.AuthorizeRequestsCustomizer; +import cn.iocoder.hake.module.agent.enums.ApiConstants; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; +import org.springframework.security.config.annotation.web.builders.HttpSecurity; +import org.springframework.security.config.annotation.web.configurers.AuthorizeHttpRequestsConfigurer; + +/** + * Erp 模块的 Security 配置 + */ +@Configuration("agentSecurityConfiguration") +public class SecurityConfiguration { + + @Bean("agentAuthorizeRequestsCustomizer") + public AuthorizeRequestsCustomizer authorizeRequestsCustomizer() { + return new AuthorizeRequestsCustomizer() { + + @Override + public void customize(AuthorizeHttpRequestsConfigurer.AuthorizationManagerRequestMatcherRegistry registry) { + // Swagger 接口文档 + registry.requestMatchers("/v3/api-docs/**").permitAll() + .requestMatchers("/webjars/**").permitAll() + .requestMatchers("/swagger-ui").permitAll() + .requestMatchers("/swagger-ui/**").permitAll(); + // Spring Boot Actuator 的安全配置 + registry.requestMatchers("/actuator").permitAll() + .requestMatchers("/actuator/**").permitAll(); + // Druid 监控 + registry.requestMatchers("/druid/**").permitAll(); + // RPC 服务的安全配置 + registry.requestMatchers(ApiConstants.PREFIX + "/**").permitAll(); + } + + }; + } + +} diff --git a/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/framework/security/core/package-info.java b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/framework/security/core/package-info.java new file mode 100644 index 0000000..f663785 --- /dev/null +++ b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/framework/security/core/package-info.java @@ -0,0 +1,4 @@ +/** + * 占位 + */ +package cn.iocoder.hake.module.agent.framework.security.core; diff --git a/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/package-info.java b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/package-info.java new file mode 100644 index 0000000..eef5b1e --- /dev/null +++ b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/package-info.java @@ -0,0 +1,10 @@ +/** + * erp 包下，企业资源管理（Enterprise Resource Planning）。 + * 例如说：采购、销售、库存、财务、产品等等 + * + * 1. Controller URL：以 /erp/ 开头，避免和其它 Module 冲突 + * 2. DataObject 表名：以 erp_ 开头，方便在数据库中区分 + * + * 注意，由于 Erp 模块下，容易和其它模块重名，所以类名都加载 Erp 的前缀~ + */ +package cn.iocoder.hake.module.agent; diff --git a/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/service/agent/AgentService.java b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/service/agent/AgentService.java new file mode 100644 index 0000000..21cf0e6 --- /dev/null +++ b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/service/agent/AgentService.java @@ -0,0 +1,67 @@ +package cn.iocoder.hake.module.agent.service.agent; + +import java.util.*; +import javax.validation.*; +import cn.iocoder.hake.module.agent.controller.admin.agent.vo.*; +import cn.iocoder.hake.module.agent.dal.dataobject.agent.AgentDO; +import cn.iocoder.hake.framework.common.pojo.PageResult; + +/** + * 代理商管理 Service 接口 + * + * @author hake + */ +public interface AgentService { + + /** + * 创建代理商管理 + * + * @param createReqVO 创建信息 + * @return 编号 + */ + Long createAgent(@Valid AgentSaveReqVO createReqVO); + + /** + * 代理商审核 + * @return + */ + Long updateAgentStatus(@Valid AuditRespVO auditRespVO); + + /** + * 更新代理商管理 + * + * @param updateReqVO 更新信息 + */ + void updateAgent(@Valid AgentSaveReqVO updateReqVO); + + /** + * 删除代理商管理 + * + * @param id 编号 + */ + void deleteAgent(Long id); + + /** + * 批量删除代理商管理 + * + * @param ids 编号 + */ + void deleteAgentListByIds(List ids); + + /** + * 获得代理商管理 + * + * @param id 编号 + * @return 代理商管理 + */ + AgentDO getAgent(Long id); + + /** + * 获得代理商管理分页 + * + * @param pageReqVO 分页查询 + * @return 代理商管理分页 + */ + PageResult getAgentPage(AgentPageReqVO pageReqVO); + +} \ No newline at end of file diff --git a/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/service/agent/AgentServiceImpl.java b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/service/agent/AgentServiceImpl.java new file mode 100644 index 0000000..07fa72b --- /dev/null +++ b/hake-module-agent/hake-module-agent-server/src/main/java/cn/iocoder/hake/module/agent/service/agent/AgentServiceImpl.java @@ -0,0 +1,134 @@ +package cn.iocoder.hake.module.agent.service.agent; + +import cn.hutool.core.collection.CollUtil; +import cn.iocoder.hake.module.agent.enums.agent.AuditStatusEnum; +import org.springframework.stereotype.Service; +import javax.annotation.Resource; +import org.springframework.validation.annotation.Validated; + +import java.text.SimpleDateFormat; +import java.util.*; +import cn.iocoder.hake.module.agent.controller.admin.agent.vo.*; +import cn.iocoder.hake.module.agent.dal.dataobject.agent.AgentDO; +import cn.iocoder.hake.framework.common.pojo.PageResult; + +import cn.iocoder.hake.framework.common.util.object.BeanUtils; + +import cn.iocoder.hake.module.agent.dal.mysql.agent.AgentMapper; + +import static cn.iocoder.hake.framework.common.exception.util.ServiceExceptionUtil.exception; +import static cn.iocoder.hake.module.agent.enums.ErrorCodeConstants.*; + +/** + * 代理商管理 Service 实现类 + * + * @author hake + */ +@Service +@Validated +public class AgentServiceImpl implements AgentService { + + @Resource + private AgentMapper agentMapper; + + @Override + public Long createAgent(AgentSaveReqVO createReqVO) { + // 插入 + AgentDO agent = BeanUtils.toBean(createReqVO, AgentDO.class); + agent.setStatus(AuditStatusEnum.UNVERIFIED.getCode()); + agent.setAgentCode(erateAgentCode(new StringBuilder("AGT"))); + agentMapper.insert(agent); + // 返回 + return agent.getId(); + } + + /** + * 生成代理商编码 + * @return 格式如"AGT202507301234"的代理商编码 + */ + public static String erateAgentCode(StringBuilder codeHeadStr) { + if(codeHeadStr == null || codeHeadStr.length() == 0) { + codeHeadStr=new StringBuilder("ST"); + } + // 固定前缀 + StringBuilder codeBuilder = new StringBuilder(codeHeadStr); + // 添加当前日期（yyyyMMdd格式） + SimpleDateFormat dateFormat = new SimpleDateFormat("yyyyMMdd"); + String dateStr = dateFormat.format(new Date()); + codeBuilder.append(dateStr); + + // 生成4个随机数（0000-9999） + Random random = new Random(); + // 生成0-9999的随机数，并补全为4位数字 + int randomNum = random.nextInt(10000); + codeBuilder.append(String.format("%04d", randomNum)); + return codeBuilder.toString(); + } + + @Override + public Long updateAgentStatus( AuditRespVO auditRespVO) { + // 校验存在 + validateagentExists(auditRespVO.getId()); + // 更新 + AgentDO updateObj = BeanUtils.toBean(auditRespVO, AgentDO.class); + agentMapper.updateById(updateObj); + return auditRespVO.getId(); + } + + + @Override + public void updateAgent(AgentSaveReqVO updateReqVO) { + // 校验存在 + AgentDO agentDO =validateagentExists(updateReqVO.getId()); + //如果当前为未认证、审核驳回的状态，再次修改提交后应该变成待审核状态 + if(Objects.equals(agentDO.getStatus(), AuditStatusEnum.REJECTED.getCode()) || Objects.equals(agentDO.getStatus(), AuditStatusEnum.UNVERIFIED.getCode())) { + updateReqVO.setStatus(AuditStatusEnum.UNDER_REVIEW.getCode()); + } + // 更新 + AgentDO updateObj = BeanUtils.toBean(updateReqVO, AgentDO.class); + agentMapper.updateById(updateObj); + } + + + @Override + public void deleteAgent(Long id) { + // 校验存在 + validateagentExists(id); + // 删除 + agentMapper.deleteById(id); + } + + @Override + public void deleteAgentListByIds(List ids) { + // 校验存在 + validateAgentExists(ids); + // 删除 + agentMapper.deleteByIds(ids); + } + + private void validateAgentExists(List ids) { + List list = agentMapper.selectByIds(ids); + if (CollUtil.isEmpty(list) || list.size() != ids.size()) { + throw exception(AGENT_NOT_EXISTS); + } + } + + private AgentDO validateagentExists(Long id) { + AgentDO agentDO =agentMapper.selectById(id); + if (agentDO == null) { + throw exception(AGENT_NOT_EXISTS); + } + return agentDO; + } + + @Override + public AgentDO getAgent(Long id) { + return agentMapper.selectById(id); + } + + @Override + public PageResult getAgentPage(AgentPageReqVO pageReqVO) { + return agentMapper.selectPage(pageReqVO); + } + +} \ No newline at end of file diff --git a/hake-module-agent/hake-module-agent-server/src/main/resources/application-dev.yaml b/hake-module-agent/hake-module-agent-server/src/main/resources/application-dev.yaml new file mode 100644 index 0000000..0fd2849 --- /dev/null +++ b/hake-module-agent/hake-module-agent-server/src/main/resources/application-dev.yaml @@ -0,0 +1,110 @@ +--- #################### 注册中心 + 配置中心相关配置 #################### + +spring: + cloud: + nacos: + server-addr: 192.168.1.16:8848 # Nacos 服务器地址 + username: nacos# Nacos 账号 + password: nacos# Nacos 密码 + discovery: # 【配置中心】配置项 + namespace: dev # 命名空间。这里使用 dev 开发环境 + group: DEFAULT_GROUP # 使用的 Nacos 配置分组，默认为 DEFAULT_GROUP + metadata: + version: 1.0.0 # 服务实例的版本号，可用于灰度发布 + config: # 【注册中心】配置项 + namespace: dev # 命名空间。这里使用 dev 开发环境 + group: DEFAULT_GROUP # 使用的 Nacos 配置分组，默认为 DEFAULT_GROUP + +--- #################### 数据库相关配置 #################### +spring: + # 数据源配置项 + autoconfigure: + exclude: + datasource: + druid: # Druid 【监控】相关的全局配置 + web-stat-filter: + enabled: true + stat-view-servlet: + enabled: true + allow: # 设置白名单，不填则允许所有访问 + url-pattern: /druid/* + login-username: # 控制台管理用户名和密码 + login-password: + filter: + stat: + enabled: true + log-slow-sql: true # 慢 SQL 记录 + slow-sql-millis: 100 + merge-sql: true + wall: + config: + multi-statement-allow: true + dynamic: # 多数据源配置 + druid: # Druid 【连接池】相关的全局配置 + initial-size: 5 # 初始连接数 + min-idle: 10 # 最小连接池数量 + max-active: 20 # 最大连接池数量 + max-wait: 600000 # 配置获取连接等待超时的时间，单位：毫秒 + time-between-eviction-runs-millis: 60000 # 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位：毫秒 + min-evictable-idle-time-millis: 300000 # 配置一个连接在池中最小生存的时间，单位：毫秒 + max-evictable-idle-time-millis: 900000 # 配置一个连接在池中最大生存的时间，单位：毫秒 + validation-query: SELECT 1 FROM DUAL # 配置检测连接是否有效 + test-while-idle: true + test-on-borrow: false + test-on-return: false + primary: master + datasource: + master: + url: jdbc:mysql://192.168.1.16:3306/hake?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&nullCatalogMeansCurrent=true&rewriteBatchedStatements=true # MySQL Connector/J 8.X 连接的示例 + username: haketest + password: test1234 + slave: # 模拟从库，可根据自己需要修改 # 模拟从库，可根据自己需要修改 + lazy: true # 开启懒加载，保证启动速度 + url: jdbc:mysql://192.168.1.16:3306/hake?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&nullCatalogMeansCurrent=true&rewriteBatchedStatements=true # MySQL Connector/J 8.X 连接的示例 + username: haketest + password: test1234 + + # Redis 配置。Redisson 默认的配置足够使用，一般不需要进行调优 + redis: + host: 192.168.1.16 # 地址 + port: 6379 # 端口 + database: 0 # 数据库索引 + # password: 123456 # 密码，建议生产环境开启 + +--- #################### MQ 消息队列相关配置 #################### + +--- #################### 定时任务相关配置 #################### + +--- #################### 服务保障相关配置 #################### + +# Lock4j 配置项 +lock4j: + acquire-timeout: 3000 # 获取分布式锁超时时间，默认为 3000 毫秒 + expire: 30000 # 分布式锁的超时时间，默认为 30 毫秒 + +--- #################### 监控相关配置 #################### + +# Actuator 监控端点的配置项 +management: + endpoints: + web: + base-path: /actuator # Actuator 提供的 API 接口的根目录。默认为 /actuator + exposure: + include: '*' # 需要开放的端点。默认值只打开 health 和 info 两个端点。通过设置 * ，可以开放所有端点。 + +# Spring Boot Admin 配置项 +spring: + boot: + admin: + # Spring Boot Admin Client 客户端的相关配置 + client: + instance: + service-host-type: IP # 注册实例时，优先使用 IP [IP, HOST_NAME, CANONICAL_HOST_NAME] + +--- #################### 哈客相关配置 #################### + +# 哈客配置项，设置当前项目所有自定义的配置 +hake: + access-log: # 访问日志的配置项 + enable: false + demo: false # 关闭演示模式 diff --git a/hake-module-agent/hake-module-agent-server/src/main/resources/application-local.yaml b/hake-module-agent/hake-module-agent-server/src/main/resources/application-local.yaml new file mode 100644 index 0000000..e9e29b0 --- /dev/null +++ b/hake-module-agent/hake-module-agent-server/src/main/resources/application-local.yaml @@ -0,0 +1,135 @@ +--- #################### 注册中心 + 配置中心相关配置 #################### + +spring: + cloud: + nacos: + server-addr: 127.0.0.1:8848 # Nacos 服务器地址 + username: nacos# Nacos 账号 + password: nacos# Nacos 密码 + discovery: # 【配置中心】配置项 + namespace: dev # 命名空间。这里使用 dev 开发环境 + group: DEFAULT_GROUP # 使用的 Nacos 配置分组，默认为 DEFAULT_GROUP + metadata: + version: 1.0.0 # 服务实例的版本号，可用于灰度发布 + config: # 【注册中心】配置项 + namespace: dev # 命名空间。这里使用 dev 开发环境 + group: DEFAULT_GROUP # 使用的 Nacos 配置分组，默认为 DEFAULT_GROUP + +--- #################### 数据库相关配置 #################### +spring: + # 数据源配置项 + autoconfigure: + exclude: + - de.codecentric.boot.admin.client.config.SpringBootAdminClientAutoConfiguration # 禁用 Spring Boot Admin 的 Client 的自动配置 + datasource: + druid: # Druid 【监控】相关的全局配置 + web-stat-filter: + enabled: true + stat-view-servlet: + enabled: true + allow: # 设置白名单，不填则允许所有访问 + url-pattern: /druid/* + login-username: # 控制台管理用户名和密码 + login-password: + filter: + stat: + enabled: true + log-slow-sql: true # 慢 SQL 记录 + slow-sql-millis: 100 + merge-sql: true + wall: + config: + multi-statement-allow: true + dynamic: # 多数据源配置 + druid: # Druid 【连接池】相关的全局配置 + initial-size: 1 # 初始连接数 + min-idle: 1 # 最小连接池数量 + max-active: 20 # 最大连接池数量 + max-wait: 600000 # 配置获取连接等待超时的时间，单位：毫秒 + time-between-eviction-runs-millis: 60000 # 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位：毫秒 + min-evictable-idle-time-millis: 300000 # 配置一个连接在池中最小生存的时间，单位：毫秒 + max-evictable-idle-time-millis: 900000 # 配置一个连接在池中最大生存的时间，单位：毫秒 + validation-query: SELECT 1 FROM DUAL # 配置检测连接是否有效 + test-while-idle: true + test-on-borrow: false + test-on-return: false + primary: master + datasource: + master: + url: jdbc:mysql://127.0.0.1:3306/hake?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&nullCatalogMeansCurrent=true&rewriteBatchedStatements=true # MySQL Connector/J 8.X 连接的示例 + # url: jdbc:mysql://127.0.0.1:3306/ruoyi-vue-pro?useSSL=true&allowPublicKeyRetrieval=true&useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&rewriteBatchedStatements=true # MySQL Connector/J 5.X 连接的示例 + # url: jdbc:postgresql://127.0.0.1:5432/ruoyi-vue-pro # PostgreSQL 连接的示例 + # url: jdbc:oracle:thin:@127.0.0.1:1521:xe # Oracle 连接的示例 + # url: jdbc:sqlserver://127.0.0.1:1433;DatabaseName=ruoyi-vue-pro # SQLServer 连接的示例 + # url: jdbc:dm://10.211.55.4:5236?schema=RUOYI_VUE_PRO # DM 连接的示例 + username: haketest + password: test1234 + # username: sa # SQL Server 连接的示例 + # password: JSm:g(*%lU4ZAkz06cd52KqT3)i1?H7W # SQL Server 连接的示例 + # username: SYSDBA # DM 连接的示例 + # password: SYSDBA # DM 连接的示例 + slave: # 模拟从库，可根据自己需要修改 + lazy: true # 开启懒加载，保证启动速度 + url: jdbc:mysql://127.0.0.1:3306/hake?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&nullCatalogMeansCurrent=true&rewriteBatchedStatements=true + username: root + password: 123456 + + # Redis 配置。Redisson 默认的配置足够使用，一般不需要进行调优 + redis: + host: 127.0.0.1 # 地址 + port: 6379 # 端口 + database: 0 # 数据库索引 +# password: 123456 # 密码，建议生产环境开启 + +--- #################### MQ 消息队列相关配置 #################### + +--- #################### 定时任务相关配置 #################### +xxl: + job: + enabled: false # 是否开启调度中心，默认为 true 开启 + admin: + addresses: http://127.0.0.1:9090/xxl-job-admin # 调度中心部署跟地址 + +--- #################### 服务保障相关配置 #################### + +# Lock4j 配置项 +lock4j: + acquire-timeout: 3000 # 获取分布式锁超时时间，默认为 3000 毫秒 + expire: 30000 # 分布式锁的超时时间，默认为 30 毫秒 + +--- #################### 监控相关配置 #################### + +# Actuator 监控端点的配置项 +management: + endpoints: + web: + base-path: /actuator # Actuator 提供的 API 接口的根目录。默认为 /actuator + exposure: + include: '*' # 需要开放的端点。默认值只打开 health 和 info 两个端点。通过设置 * ，可以开放所有端点。 + +# Spring Boot Admin 配置项 +spring: + boot: + admin: + # Spring Boot Admin Client 客户端的相关配置 + client: + instance: + service-host-type: IP # 注册实例时，优先使用 IP [IP, HOST_NAME, CANONICAL_HOST_NAME] + +# 日志文件配置 +logging: + level: + # 配置自己写的 MyBatis Mapper 打印日志 + cn.iocoder.hake.module.agent.dal.mysql: debug + org.springframework.context.support.PostProcessorRegistrationDelegate: ERROR # TODO 哈客：先禁用，Spring Boot 3.X 存在部分错误的 WARN 提示 + +--- #################### 哈客相关配置 #################### + +# 哈客配置项，设置当前项目所有自定义的配置 +hake: + env: # 多环境的配置项 + tag: ${HOSTNAME} + security: + mock-enable: true + access-log: # 访问日志的配置项 + enable: false \ No newline at end of file diff --git a/hake-module-agent/hake-module-agent-server/src/main/resources/application.yaml b/hake-module-agent/hake-module-agent-server/src/main/resources/application.yaml new file mode 100644 index 0000000..f8c0d65 --- /dev/null +++ b/hake-module-agent/hake-module-agent-server/src/main/resources/application.yaml @@ -0,0 +1,124 @@ +spring: + application: + name: agent-server + + profiles: + active: dev + + main: + allow-circular-references: true # 允许循环依赖，因为项目是三层架构，无法避免这个情况。 + allow-bean-definition-overriding: true # 允许 Bean 覆盖，例如说 Feign 等会存在重复定义的服务 + + config: + import: + - optional:classpath:application-${spring.profiles.active}.yaml # 加载【本地】配置 + - optional:nacos:${spring.application.name}-${spring.profiles.active}.yaml # 加载【Nacos】的配置 + + # Servlet 配置 + servlet: + # 文件上传相关配置项 + multipart: + max-file-size: 16MB # 单个文件大小 + max-request-size: 32MB # 设置总上传的文件大小 + + # Jackson 配置项 + jackson: + serialization: + write-dates-as-timestamps: true # 设置 LocalDateTime 的格式，使用时间戳 + write-date-timestamps-as-nanoseconds: false # 设置不使用 nanoseconds 的格式。例如说 1611460870.401，而是直接 1611460870401 + write-durations-as-timestamps: true # 设置 Duration 的格式，使用时间戳 + fail-on-empty-beans: false # 允许序列化无属性的 Bean + + # Cache 配置项 + cache: + type: REDIS + redis: + time-to-live: 1h # 设置过期时间为 1 小时 + +server: + port: 48090 + +logging: + file: + name: ${user.home}/logs/${spring.application.name}.log # 日志文件名，全路径 + +--- #################### 接口文档配置 #################### + +springdoc: + api-docs: + enabled: true # 1. 是否开启 Swagger 接文档的元数据 + path: /v3/api-docs + swagger-ui: + enabled: true # 2.1 是否开启 Swagger 文档的官方 UI 界面 + path: /swagger-ui + default-flat-param-object: true # 参见 https://doc.xiaominfo.com/docs/faq/v4/knife4j-parameterobject-flat-param 文档 + +knife4j: + enable: false # TODO 哈客：需要关闭增强，具体原因见：https://github.com/xiaoymin/knife4j/issues/874 + setting: + language: zh_cn + +# MyBatis Plus 的配置项 +mybatis-plus: + configuration: + map-underscore-to-camel-case: true # 虽然默认为 true ，但是还是显示去指定下。 + global-config: + db-config: + id-type: NONE # “智能”模式，基于 IdTypeEnvironmentPostProcessor + 数据源的类型，自动适配成 AUTO、INPUT 模式。 + # id-type: AUTO # 自增 ID，适合 MySQL 等直接自增的数据库 + # id-type: INPUT # 用户输入 ID，适合 Oracle、PostgreSQL、Kingbase、DB2、H2 数据库 + # id-type: ASSIGN_ID # 分配 ID，默认使用雪花算法。注意，Oracle、PostgreSQL、Kingbase、DB2、H2 数据库时，需要去除实体类上的 @KeySequence 注解 + logic-delete-value: 1 # 逻辑已删除值(默认为 1) + logic-not-delete-value: 0 # 逻辑未删除值(默认为 0) + banner: false # 关闭控制台的 Banner 打印 + type-aliases-package: ${hake.info.base-package}.dal.dataobject + encryptor: + password: XDV71a+xqStEA3WH # 加解密的秘钥，可使用 https://www.imaegoo.com/2020/aes-key-generator/ 网站生成 + +mybatis-plus-join: + banner: false # 关闭控制台的 Banner 打印 + +# Spring Data Redis 配置 +spring: + data: + redis: + repositories: + enabled: false # 项目未使用到 Spring Data Redis 的 Repository，所以直接禁用，保证启动速度 + +# VO 转换（数据翻译）相关 +easy-trans: + is-enable-global: true # 启用全局翻译（拦截所有 SpringMVC ResponseBody 进行自动翻译 )。如果对于性能要求很高可关闭此配置，或通过 @IgnoreTrans 忽略某个接口 + +--- #################### MQ 消息队列相关配置 #################### + +--- #################### 定时任务相关配置 #################### + +xxl: + job: + executor: + appname: ${spring.application.name} # 执行器 AppName + logpath: ${user.home}/logs/xxl-job/${spring.application.name} # 执行器运行日志文件存储磁盘路径 + accessToken: default_token # 执行器通讯TOKEN + +--- #################### 哈客相关配置 #################### + +hake: + info: + version: 1.0.0 + base-package: cn.iocoder.hake.module.agent + web: + admin-ui: + url: http://dashboard.hake.iocoder.cn # Admin 管理后台 UI 的地址 + xss: + enable: false + exclude-urls: # 如下 url，仅仅是为了演示，去掉配置也没关系 + - ${management.endpoints.web.base-path}/** # 不处理 Actuator 的请求 + swagger: + title: 管理后台 + description: 提供管理员管理的所有功能 + version: ${hake.info.version} + tenant: # 多租户相关配置项 + enable: true + ignore-urls: + +debug: false diff --git a/hake-module-agent/hake-module-agent-server/src/main/resources/logback-spring.xml b/hake-module-agent/hake-module-agent-server/src/main/resources/logback-spring.xml new file mode 100644 index 0000000..e4cf06d --- /dev/null +++ b/hake-module-agent/hake-module-agent-server/src/main/resources/logback-spring.xml @@ -0,0 +1,76 @@ + + + + + + + + + + 　　　　　 + + + ${PATTERN_DEFAULT} + + + + + + + + + + ${PATTERN_DEFAULT} + + + + ${LOG_FILE} + + + ${LOGBACK_ROLLINGPOLICY_FILE_NAME_PATTERN:-${LOG_FILE}.%d{yyyy-MM-dd}.%i.gz} + + ${LOGBACK_ROLLINGPOLICY_CLEAN_HISTORY_ON_START:-false} + + ${LOGBACK_ROLLINGPOLICY_MAX_FILE_SIZE:-10MB} + + ${LOGBACK_ROLLINGPOLICY_TOTAL_SIZE_CAP:-0} + + ${LOGBACK_ROLLINGPOLICY_MAX_HISTORY:-30} + + + + + + 0 + + 256 + + + + + + + + ${PATTERN_DEFAULT} + + + + + + + + + + + + + + + + + + + + + + diff --git a/hake-module-agent/hake-module-agent-server/src/main/resources/mapper/agent/AgentMapper.xml b/hake-module-agent/hake-module-agent-server/src/main/resources/mapper/agent/AgentMapper.xml new file mode 100644 index 0000000..dfcfc3c --- /dev/null +++ b/hake-module-agent/hake-module-agent-server/src/main/resources/mapper/agent/AgentMapper.xml @@ -0,0 +1,12 @@ + + + + + + + \ No newline at end of file diff --git a/hake-module-agent/pom.xml b/hake-module-agent/pom.xml new file mode 100644 index 0000000..7722a8b --- /dev/null +++ b/hake-module-agent/pom.xml @@ -0,0 +1,23 @@ + + + + cn.iocoder.cloud + hake + ${revision} + + + hake-module-agent-api + hake-module-agent-server + + 4.0.0 + hake-module-agent + pom + + ${project.artifactId} + + erp 包下，代理商管理 + + + \ No newline at end of file diff --git a/hake-module-op/hake-module-op-api/pom.xml b/hake-module-op/hake-module-op-api/pom.xml new file mode 100644 index 0000000..42f9fdd --- /dev/null +++ b/hake-module-op/hake-module-op-api/pom.xml @@ -0,0 +1,40 @@ + + + + hake-module-op + cn.iocoder.cloud + ${revision} + + + ${project.artifactId} + + 4.0.0 + hake-module-op-api + jar + + + op-api，暴露远程服务连接的入口，例如：需要提供API其他服务，请求此服务API业务 + + + + + cn.iocoder.cloud + hake-common + + + + + central + Central Repository + http://192.168.1.200:19081/repository/maven-hake/ + + + snapshots + Nexus Snapshot Repository + http://192.168.1.200:19081/repository/maven-snapshots/ + + + + diff --git a/hake-module-op/hake-module-op-server/Dockerfile b/hake-module-op/hake-module-op-server/Dockerfile new file mode 100644 index 0000000..362e08e --- /dev/null +++ b/hake-module-op/hake-module-op-server/Dockerfile @@ -0,0 +1,19 @@ +## AdoptOpenJDK 停止发布 OpenJDK 二进制，而 Eclipse Temurin 是它的延伸，提供更好的稳定性 +## 感谢复旦核博士的建议！灰子哥，牛皮！ +FROM eclipse-temurin:8-jre + +## 创建目录，并使用它作为工作目录 +RUN mkdir -p /hake-module-op-server +WORKDIR /hake-module-op-server +## 将后端项目的 Jar 文件，复制到镜像中 +COPY ./target/hake-module-op-server.jar app.jar + +## 设置 TZ 时区 +## 设置 JAVA_OPTS 环境变量，可通过 docker run -e "JAVA_OPTS=" 进行覆盖 +ENV TZ=Asia/Shanghai JAVA_OPTS="-Xms512m -Xmx512m" + +## 暴露后端项目的 48080 端口 +EXPOSE 48086 + +## 启动后端项目 +CMD java ${JAVA_OPTS} -Djava.security.egd=file:/dev/./urandom -jar app.jar diff --git a/hake-module-op/hake-module-op-server/pom.xml b/hake-module-op/hake-module-op-server/pom.xml new file mode 100644 index 0000000..c65a35f --- /dev/null +++ b/hake-module-op/hake-module-op-server/pom.xml @@ -0,0 +1,149 @@ + + + + hake-module-op + cn.iocoder.cloud + ${revision} + + + ${project.artifactId} + 4.0.0 + hake-module-op-server + jar + + op-server,运营中心服务实现接口、业务逻辑、工具类等其他相应开发实现 + + + + + + cn.iocoder.cloud + hake-spring-boot-starter-env + + + + cn.iocoder.cloud + hake-module-op-api + ${revision} + + + cn.iocoder.cloud + hake-module-system-api + ${revision} + + + cn.iocoder.cloud + hake-module-infra-api + ${revision} + + + + cn.iocoder.cloud + hake-spring-boot-starter-biz-tenant + + + + + cn.iocoder.cloud + hake-spring-boot-starter-security + + + + org.springframework.boot + spring-boot-starter-validation + + + + + cn.iocoder.cloud + hake-spring-boot-starter-mybatis + + + + cn.iocoder.cloud + hake-spring-boot-starter-redis + + + + + cn.iocoder.cloud + hake-spring-boot-starter-rpc + + + + + com.alibaba.cloud + spring-cloud-starter-alibaba-nacos-discovery + + + + + com.alibaba.cloud + spring-cloud-starter-alibaba-nacos-config + + + + + cn.iocoder.cloud + hake-spring-boot-starter-test + test + + + + + cn.iocoder.cloud + hake-spring-boot-starter-monitor + + + + + cn.iocoder.cloud + hake-spring-boot-starter-excel + + + + + com.github.binarywang + wx-java-mp-spring-boot-starter + + + + + central + Central Repository + http://192.168.1.200:19081/repository/maven-hake/ + + + snapshots + Nexus Snapshot Repository + http://192.168.1.200:19081/repository/maven-snapshots/ + + + + + + ${project.artifactId} + + + + org.springframework.boot + spring-boot-maven-plugin + ${spring.boot.version} + + op + ../../packge + + + + + repackage + + + + + + + + diff --git a/hake-module-op/hake-module-op-server/src/main/java/cn/iocoder/hake/module/op/OpServerApplication.java b/hake-module-op/hake-module-op-server/src/main/java/cn/iocoder/hake/module/op/OpServerApplication.java new file mode 100644 index 0000000..f0e4643 --- /dev/null +++ b/hake-module-op/hake-module-op-server/src/main/java/cn/iocoder/hake/module/op/OpServerApplication.java @@ -0,0 +1,18 @@ +package cn.iocoder.hake.module.op; + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; + +/** + * OP项目启动类 + * + * @author chenjr + * @since 2025-07-30 + */ +@SpringBootApplication +public class OpServerApplication { + + public static void main(String[] args) { + SpringApplication.run(OpServerApplication.class, args); + } +} diff --git a/hake-module-op/hake-module-op-server/src/main/java/cn/iocoder/hake/module/op/framework/rpc/config/RpcConfiguration.java b/hake-module-op/hake-module-op-server/src/main/java/cn/iocoder/hake/module/op/framework/rpc/config/RpcConfiguration.java new file mode 100644 index 0000000..bb2330e --- /dev/null +++ b/hake-module-op/hake-module-op-server/src/main/java/cn/iocoder/hake/module/op/framework/rpc/config/RpcConfiguration.java @@ -0,0 +1,10 @@ +package cn.iocoder.hake.module.op.framework.rpc.config; + +import cn.iocoder.hake.module.infra.api.file.FileApi; +import org.springframework.cloud.openfeign.EnableFeignClients; +import org.springframework.context.annotation.Configuration; + +@Configuration(value = "mpRpcConfiguration", proxyBeanMethods = false) +@EnableFeignClients(clients = FileApi.class) +public class RpcConfiguration { +} diff --git a/hake-module-op/hake-module-op-server/src/main/java/cn/iocoder/hake/module/op/framework/security/config/SecurityConfiguration.java b/hake-module-op/hake-module-op-server/src/main/java/cn/iocoder/hake/module/op/framework/security/config/SecurityConfiguration.java new file mode 100644 index 0000000..9b25c3c --- /dev/null +++ b/hake-module-op/hake-module-op-server/src/main/java/cn/iocoder/hake/module/op/framework/security/config/SecurityConfiguration.java @@ -0,0 +1,40 @@ +package cn.iocoder.hake.module.op.framework.security.config; + +import cn.iocoder.hake.framework.security.config.AuthorizeRequestsCustomizer; +import cn.iocoder.hake.module.system.enums.ApiConstants; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; +import org.springframework.security.config.annotation.web.builders.HttpSecurity; +import org.springframework.security.config.annotation.web.configurers.AuthorizeHttpRequestsConfigurer; + +/** + * MP 模块的 Security 配置 + */ +@Configuration(proxyBeanMethods = false, value = "mpSecurityConfiguration") +public class SecurityConfiguration { + + @Bean("mpAuthorizeRequestsCustomizer") + public AuthorizeRequestsCustomizer authorizeRequestsCustomizer() { + return new AuthorizeRequestsCustomizer() { + + @Override + public void customize(AuthorizeHttpRequestsConfigurer.AuthorizationManagerRequestMatcherRegistry registry) { + // TODO 哈客：这个每个项目都需要重复配置，得捉摸有没通用的方案 + // Swagger 接口文档 + registry.requestMatchers("/v3/api-docs/**").permitAll() + .requestMatchers("/webjars/**").permitAll() + .requestMatchers("/swagger-ui").permitAll() + .requestMatchers("/swagger-ui/**").permitAll(); + // Druid 监控 + registry.requestMatchers("/druid/**").permitAll(); + // Spring Boot Actuator 的安全配置 + registry.requestMatchers("/actuator").permitAll() + .requestMatchers("/actuator/**").permitAll(); + // RPC 服务的安全配置 + registry.requestMatchers(ApiConstants.PREFIX + "/**").permitAll(); + } + + }; + } + +} diff --git a/hake-module-op/hake-module-op-server/src/main/resources/application-dev.yaml b/hake-module-op/hake-module-op-server/src/main/resources/application-dev.yaml new file mode 100644 index 0000000..238ff5b --- /dev/null +++ b/hake-module-op/hake-module-op-server/src/main/resources/application-dev.yaml @@ -0,0 +1,109 @@ +--- #################### 注册中心 + 配置中心相关配置 #################### + +spring: + cloud: + nacos: + server-addr: 192.168.1.16:8848 # Nacos 服务器地址 + username: nacos# Nacos 账号 + password: nacos# Nacos 密码 + discovery: # 【配置中心】配置项 + namespace: dev # 命名空间。这里使用 dev 开发环境 + group: DEFAULT_GROUP # 使用的 Nacos 配置分组，默认为 DEFAULT_GROUP + metadata: + version: 1.0.0 # 服务实例的版本号，可用于灰度发布 + config: # 【注册中心】配置项 + namespace: dev # 命名空间。这里使用 dev 开发环境 + group: DEFAULT_GROUP # 使用的 Nacos 配置分组，默认为 DEFAULT_GROUP + +--- #################### 数据库相关配置 #################### +spring: + # 数据源配置项 + autoconfigure: + exclude: + - com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceAutoConfigure # 排除 Druid 的自动配置，使用 dynamic-datasource-spring-boot-starter 配置多数据源 + datasource: + druid: # Druid 【监控】相关的全局配置 + web-stat-filter: + enabled: true + stat-view-servlet: + enabled: true + allow: # 设置白名单，不填则允许所有访问 + url-pattern: /druid/* + login-username: # 控制台管理用户名和密码 + login-password: + filter: + stat: + enabled: true + log-slow-sql: true # 慢 SQL 记录 + slow-sql-millis: 100 + merge-sql: true + wall: + config: + multi-statement-allow: true + dynamic: # 多数据源配置 + druid: # Druid 【连接池】相关的全局配置 + initial-size: 5 # 初始连接数 + min-idle: 10 # 最小连接池数量 + max-active: 20 # 最大连接池数量 + max-wait: 600000 # 配置获取连接等待超时的时间，单位：毫秒 + time-between-eviction-runs-millis: 60000 # 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位：毫秒 + min-evictable-idle-time-millis: 300000 # 配置一个连接在池中最小生存的时间，单位：毫秒 + max-evictable-idle-time-millis: 900000 # 配置一个连接在池中最大生存的时间，单位：毫秒 + validation-query: SELECT 1 FROM DUAL # 配置检测连接是否有效 + test-while-idle: true + test-on-borrow: false + test-on-return: false + primary: master + datasource: + master: + url: jdbc:mysql://192.168.1.16:3306/hake?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&nullCatalogMeansCurrent=true&rewriteBatchedStatements=true # MySQL Connector/J 8.X 连接的示例 + username: haketest + password: test1234 + slave: # 模拟从库，可根据自己需要修改 # 模拟从库，可根据自己需要修改 + lazy: true # 开启懒加载，保证启动速度 + url: jdbc:mysql://192.168.1.16:3306/ruoyi-vue-pro?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&nullCatalogMeansCurrent=true&rewriteBatchedStatements=true # MySQL Connector/J 8.X 连接的示例 + username: haketest + password: test1234 + + # Redis 配置。Redisson 默认的配置足够使用，一般不需要进行调优 + redis: + host: 192.168.1.16 # 地址 + port: 6379 # 端口 + database: 1 # 数据库索引 +# password: 123456 # 密码，建议生产环境开启 + +--- #################### MQ 消息队列相关配置 #################### + +--- #################### 定时任务相关配置 #################### + +--- #################### 服务保障相关配置 #################### + +# Lock4j 配置项 +lock4j: + acquire-timeout: 3000 # 获取分布式锁超时时间，默认为 3000 毫秒 + expire: 30000 # 分布式锁的超时时间，默认为 30 毫秒 + +--- #################### 监控相关配置 #################### + +# Actuator 监控端点的配置项 +management: + endpoints: + web: + base-path: /actuator # Actuator 提供的 API 接口的根目录。默认为 /actuator + exposure: + include: '*' # 需要开放的端点。默认值只打开 health 和 info 两个端点。通过设置 * ，可以开放所有端点。 + +# Spring Boot Admin 配置项 +spring: + boot: + admin: + # Spring Boot Admin Client 客户端的相关配置 + client: + instance: + service-host-type: IP # 注册实例时，优先使用 IP [IP, HOST_NAME, CANONICAL_HOST_NAME] + +--- #################### 哈客相关配置 #################### + +# 哈客配置项，设置当前项目所有自定义的配置 +hake: + demo: false # 关闭演示模式 diff --git a/hake-module-op/hake-module-op-server/src/main/resources/application-local.yaml b/hake-module-op/hake-module-op-server/src/main/resources/application-local.yaml new file mode 100644 index 0000000..f6aeb5a --- /dev/null +++ b/hake-module-op/hake-module-op-server/src/main/resources/application-local.yaml @@ -0,0 +1,131 @@ +--- #################### 注册中心 + 配置中心相关配置 #################### + +spring: + cloud: + nacos: + server-addr: 127.0.0.1:8848 # Nacos 服务器地址 + username: nacos# Nacos 账号 + password: nacos# Nacos 密码 + discovery: # 【配置中心】配置项 + namespace: dev # 命名空间。这里使用 dev 开发环境 + group: DEFAULT_GROUP # 使用的 Nacos 配置分组，默认为 DEFAULT_GROUP + metadata: + version: 1.0.0 # 服务实例的版本号，可用于灰度发布 + config: # 【注册中心】配置项 + namespace: dev # 命名空间。这里使用 dev 开发环境 + group: DEFAULT_GROUP # 使用的 Nacos 配置分组，默认为 DEFAULT_GROUP + +--- #################### 数据库相关配置 #################### +spring: + # 数据源配置项 + autoconfigure: + exclude: + - com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceAutoConfigure # 排除 Druid 的自动配置，使用 dynamic-datasource-spring-boot-starter 配置多数据源 + - de.codecentric.boot.admin.client.config.SpringBootAdminClientAutoConfiguration # 禁用 Spring Boot Admin 的 Client 的自动配置 + datasource: + druid: # Druid 【监控】相关的全局配置 + web-stat-filter: + enabled: true + stat-view-servlet: + enabled: true + allow: # 设置白名单，不填则允许所有访问 + url-pattern: /druid/* + login-username: # 控制台管理用户名和密码 + login-password: + filter: + stat: + enabled: true + log-slow-sql: true # 慢 SQL 记录 + slow-sql-millis: 100 + merge-sql: true + wall: + config: + multi-statement-allow: true + dynamic: # 多数据源配置 + druid: # Druid 【连接池】相关的全局配置 + initial-size: 1 # 初始连接数 + min-idle: 1 # 最小连接池数量 + max-active: 20 # 最大连接池数量 + max-wait: 600000 # 配置获取连接等待超时的时间，单位：毫秒 + time-between-eviction-runs-millis: 60000 # 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位：毫秒 + min-evictable-idle-time-millis: 300000 # 配置一个连接在池中最小生存的时间，单位：毫秒 + max-evictable-idle-time-millis: 900000 # 配置一个连接在池中最大生存的时间，单位：毫秒 + validation-query: SELECT 1 FROM DUAL # 配置检测连接是否有效 + test-while-idle: true + test-on-borrow: false + test-on-return: false + primary: master + datasource: + master: + url: jdbc:mysql://127.0.0.1:3306/hake?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&nullCatalogMeansCurrent=true&rewriteBatchedStatements=true # MySQL Connector/J 8.X 连接的示例 + # url: jdbc:mysql://127.0.0.1:3306/ruoyi-vue-pro?useSSL=true&allowPublicKeyRetrieval=true&useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&rewriteBatchedStatements=true # MySQL Connector/J 5.X 连接的示例 + # url: jdbc:postgresql://127.0.0.1:5432/ruoyi-vue-pro # PostgreSQL 连接的示例 + # url: jdbc:oracle:thin:@127.0.0.1:1521:xe # Oracle 连接的示例 + # url: jdbc:sqlserver://127.0.0.1:1433;DatabaseName=ruoyi-vue-pro # SQLServer 连接的示例 + # url: jdbc:dm://10.211.55.4:5236?schema=RUOYI_VUE_PRO # DM 连接的示例 + username: haketest + password: test1234 + # username: sa # SQL Server 连接的示例 + # password: JSm:g(*%lU4ZAkz06cd52KqT3)i1?H7W # SQL Server 连接的示例 + # username: SYSDBA # DM 连接的示例 + # password: SYSDBA # DM 连接的示例 + slave: # 模拟从库，可根据自己需要修改 + lazy: true # 开启懒加载，保证启动速度 + url: jdbc:mysql://127.0.0.1:3306/hake?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true&nullCatalogMeansCurrent=true&rewriteBatchedStatements=true + username: haketest + password: test1234 + + # Redis 配置。Redisson 默认的配置足够使用，一般不需要进行调优 + redis: + host: 127.0.0.1 # 地址 + port: 6379 # 端口 + database: 0 # 数据库索引 +# password: 123456 # 密码，建议生产环境开启 + +--- #################### MQ 消息队列相关配置 #################### + +--- #################### 定时任务相关配置 #################### + +--- #################### 服务保障相关配置 #################### + +# Lock4j 配置项 +lock4j: + acquire-timeout: 3000 # 获取分布式锁超时时间，默认为 3000 毫秒 + expire: 30000 # 分布式锁的超时时间，默认为 30 毫秒 + +--- #################### 监控相关配置 #################### + +# Actuator 监控端点的配置项 +management: + endpoints: + web: + base-path: /actuator # Actuator 提供的 API 接口的根目录。默认为 /actuator + exposure: + include: '*' # 需要开放的端点。默认值只打开 health 和 info 两个端点。通过设置 * ，可以开放所有端点。 + +# Spring Boot Admin 配置项 +spring: + boot: + admin: + # Spring Boot Admin Client 客户端的相关配置 + client: + instance: + service-host-type: IP # 注册实例时，优先使用 IP [IP, HOST_NAME, CANONICAL_HOST_NAME] + +# 日志文件配置 +logging: + level: + # 配置自己写的 MyBatis Mapper 打印日志 + cn.iocoder.hake.module.mp.dal.mysql: debug + org.springframework.context.support.PostProcessorRegistrationDelegate: ERROR # TODO 哈客：先禁用，Spring Boot 3.X 存在部分错误的 WARN 提示 + +--- #################### 哈客相关配置 #################### + +# 哈客配置项，设置当前项目所有自定义的配置 +hake: + env: # 多环境的配置项 + tag: ${HOSTNAME} + security: + mock-enable: true + access-log: # 访问日志的配置项 + enable: false \ No newline at end of file diff --git a/hake-module-op/hake-module-op-server/src/main/resources/application.yaml b/hake-module-op/hake-module-op-server/src/main/resources/application.yaml new file mode 100644 index 0000000..883c059 --- /dev/null +++ b/hake-module-op/hake-module-op-server/src/main/resources/application.yaml @@ -0,0 +1,128 @@ +server: + port: 8081 +spring: + application: + name: op-server + + profiles: + active: dev + + main: + allow-circular-references: true # 允许循环依赖，因为项目是三层架构，无法避免这个情况。 + allow-bean-definition-overriding: true # 允许 Bean 覆盖，例如说 Feign 等会存在重复定义的服务 + + config: + import: + - optional:classpath:application-${spring.profiles.active}.yaml # 加载【本地】配置 + - optional:nacos:${spring.application.name}-${spring.profiles.active}.yaml # 加载【Nacos】的配置 + + # Servlet 配置 + servlet: + # 文件上传相关配置项 + multipart: + max-file-size: 16MB # 单个文件大小 + max-request-size: 32MB # 设置总上传的文件大小 + + # Jackson 配置项 + jackson: + serialization: + write-dates-as-timestamps: true # 设置 LocalDateTime 的格式，使用时间戳 + write-date-timestamps-as-nanoseconds: false # 设置不使用 nanoseconds 的格式。例如说 1611460870.401，而是直接 1611460870401 + write-durations-as-timestamps: true # 设置 Duration 的格式，使用时间戳 + fail-on-empty-beans: false # 允许序列化无属性的 Bean + + # Cache 配置项 + cache: + type: REDIS + redis: + time-to-live: 1h # 设置过期时间为 1 小时 +logging: + file: + name: ${user.home}/logs/${spring.application.name}.log # 日志文件名，全路径 + +--- #################### 接口文档配置 #################### + +springdoc: + api-docs: + enabled: true # 1. 是否开启 Swagger 接文档的元数据 + path: /v3/api-docs + swagger-ui: + enabled: true # 2.1 是否开启 Swagger 文档的官方 UI 界面 + path: /swagger-ui + default-flat-param-object: true # 参见 https://doc.xiaominfo.com/docs/faq/v4/knife4j-parameterobject-flat-param 文档 + +knife4j: + enable: false # TODO 哈客：需要关闭增强，具体原因见：https://github.com/xiaoymin/knife4j/issues/874 + setting: + language: zh_cn + +# MyBatis Plus 的配置项 +mybatis-plus: + configuration: + map-underscore-to-camel-case: true # 虽然默认为 true ，但是还是显示去指定下。 + global-config: + db-config: + id-type: NONE # “智能”模式，基于 IdTypeEnvironmentPostProcessor + 数据源的类型，自动适配成 AUTO、INPUT 模式。 + # id-type: AUTO # 自增 ID，适合 MySQL 等直接自增的数据库 + # id-type: INPUT # 用户输入 ID，适合 Oracle、PostgreSQL、Kingbase、DB2、H2 数据库 + # id-type: ASSIGN_ID # 分配 ID，默认使用雪花算法。注意，Oracle、PostgreSQL、Kingbase、DB2、H2 数据库时，需要去除实体类上的 @KeySequence 注解 + logic-delete-value: 1 # 逻辑已删除值(默认为 1) + logic-not-delete-value: 0 # 逻辑未删除值(默认为 0) + banner: false # 关闭控制台的 Banner 打印 + type-aliases-package: ${hake.info.base-package}.dal.dataobject + encryptor: + password: XDV71a+xqStEA3WH # 加解密的秘钥，可使用 https://www.imaegoo.com/2020/aes-key-generator/ 网站生成 + +mybatis-plus-join: + banner: false # 关闭控制台的 Banner 打印 + +# Spring Data Redis 配置 +spring: + data: + redis: + repositories: + enabled: false # 项目未使用到 Spring Data Redis 的 Repository，所以直接禁用，保证启动速度 + +# VO 转换（数据翻译）相关 +easy-trans: + is-enable-global: true # 启用全局翻译（拦截所有 SpringMVC ResponseBody 进行自动翻译 )。如果对于性能要求很高可关闭此配置，或通过 @IgnoreTrans 忽略某个接口 + +--- #################### MQ 消息队列相关配置 #################### + +--- #################### 定时任务相关配置 #################### + +--- #################### 微信公众号相关配置 #################### +wx: + mp: # 公众号配置（必填），参见 https://github.com/Wechat-Group/WxJava/blob/develop/spring-boot-starters/wx-java-mp-spring-boot-starter/README.md 文档 + # 存储配置，解决 AccessToken 的跨节点的共享 + config-storage: + type: RedisTemplate # 采用 RedisTemplate 操作 Redis，会自动从 Spring 中获取 + key-prefix: wx # Redis Key 的前缀 + http-client-type: HttpClient # 采用 HttpClient 请求微信公众号平台 + app-id: null # 避免 weixin-java-mp starter 报错 + +--- #################### 哈客相关配置 #################### + +hake: + info: + version: 1.0.0 + base-package: cn.iocoder.hake.module.mp + web: + admin-ui: + url: http://dashboard.hake.iocoder.cn # Admin 管理后台 UI 的地址 + xss: + enable: false + exclude-urls: # 如下 url，仅仅是为了演示，去掉配置也没关系 + - ${management.endpoints.web.base-path}/** # 不处理 Actuator 的请求 + security: + permit-all_urls: + - /admin-api/mp/open/** # 微信公众号开放平台，微信回调接口，不需要登录 + swagger: + title: 管理后台 + description: 提供管理员管理的所有功能 + version: ${hake.info.version} + tenant: # 多租户相关配置项 + enable: true + ignore-urls: + +debug: false diff --git a/hake-module-op/hake-module-op-server/src/main/resources/logback-spring.xml b/hake-module-op/hake-module-op-server/src/main/resources/logback-spring.xml new file mode 100644 index 0000000..e4cf06d --- /dev/null +++ b/hake-module-op/hake-module-op-server/src/main/resources/logback-spring.xml @@ -0,0 +1,76 @@ + + + + + + + + + + 　　　　　 + + + ${PATTERN_DEFAULT} + + + + + + + + + + ${PATTERN_DEFAULT} + + + + ${LOG_FILE} + + + ${LOGBACK_ROLLINGPOLICY_FILE_NAME_PATTERN:-${LOG_FILE}.%d{yyyy-MM-dd}.%i.gz} + + ${LOGBACK_ROLLINGPOLICY_CLEAN_HISTORY_ON_START:-false} + + ${LOGBACK_ROLLINGPOLICY_MAX_FILE_SIZE:-10MB} + + ${LOGBACK_ROLLINGPOLICY_TOTAL_SIZE_CAP:-0} + + ${LOGBACK_ROLLINGPOLICY_MAX_HISTORY:-30} + + + + + + 0 + + 256 + + + + + + + + ${PATTERN_DEFAULT} + + + + + + + + + + + + + + + + + + + + + + diff --git a/hake-module-op/pom.xml b/hake-module-op/pom.xml new file mode 100644 index 0000000..1959988 --- /dev/null +++ b/hake-module-op/pom.xml @@ -0,0 +1,23 @@ + + + + hake + cn.iocoder.cloud + ${revision} + + 4.0.0 + + hake-module-op + pom + + + op 模块，主要实现运营平台数据展示功能；例如：进件管理、商户列表、 + 门店管理、代理商服务管理等数据整合 + + + hake-module-op-api + hake-module-op-server + + diff --git a/pom.xml b/pom.xml index aa78125..96b9cd1 100644 --- a/pom.xml +++ b/pom.xml @@ -24,6 +24,8 @@ hake-module-mall hake-module-erp hake-module-crm + hake-module-op + hake-module-agent ${project.artifactId} diff --git a/sql/mysql/2.0/op.sql b/sql/mysql/2.0/op.sql new file mode 100644 index 0000000..8d02ff5 --- /dev/null +++ b/sql/mysql/2.0/op.sql @@ -0,0 +1,192 @@ +/* + 2.0 MysqlTable in OperatingCenter System DDL、DML +*/ +-- ---------------------------- +-- Table structure for op_merchant_list +-- ---------------------------- + +CREATE TABLE IF NOT EXISTS `op_merchant_list` ( + `id` INT AUTO_INCREMENT PRIMARY KEY COMMENT '主键ID', + `merchant_number` varchar(32) NOT NULL DEFAULT '' COMMENT '商户编号', + `merchant_name` varchar(64) NOT NULL DEFAULT '' COMMENT '商户名称', + `login_name` varchar(32) NOT NULL DEFAULT '' COMMENT '登录名', + `merchant_short_name` varchar(64) NOT NULL DEFAULT '' COMMENT '商户简称', + `contact_name` varchar(64) NOT NULL DEFAULT '' COMMENT '联系人姓名', + `contact_email` varchar(64) NULL DEFAULT NULL COMMENT '联系人邮箱', + `contact_phone` TINYINT(11) DEFAULT 0 COMMENT '联系人手机号', + `merchant_level` TINYINT(1) DEFAULT 0 COMMENT '商户级别(0:简单模式|M0-页面简洁，仅基础收款功能, 1:高级模式|M1-支持api调用， 支持配置应用及分账、转账功能)', + `refund_method` TINYINT(1) DEFAULT 0 COMMENT '退款方式(0:平台退款, 1:接口退款)', + `merchant_type` TINYINT(1) DEFAULT 0 COMMENT '商户类型(0:特约商户, 1:普通商户)', + `agent_id` varchar(64) NULL DEFAULT '' COMMENT '代理商ID', + `service_id` varchar(64) NULL DEFAULT '' COMMENT '服务商ID', + `notes` varchar(256) NULL DEFAULT NULL COMMENT '备注', + `reserved_field_1` varchar(64) NULL DEFAULT NULL COMMENT '预留字段1', + `reserved_field_2` varchar(64) NULL DEFAULT NULL COMMENT '预留字段2', + `reserved_field_3` varchar(64) NULL DEFAULT NULL COMMENT '预留字段3', + `created_user` VARCHAR(64) NOT NULL COMMENT '创建人', + `created_time` TIMESTAMP DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', + `updated_user` VARCHAR(64) NOT NULL COMMENT '更新人', + `updated_time` TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间', + `is_deleted` TINYINT(1) DEFAULT 0 NOT NULL COMMENT '逻辑删除标识 (0:未删除, 1:已删除)', + INDEX idx_is_deleted (is_deleted), -- 为逻辑删除字段创建索引，提高查询性能 + INDEX idx_merchant_number (merchant_number) -- 商户编号创建索引、提高查询性能 + ) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci COMMENT = '商户列表'; + +-- ---------------------------- +-- Table structure for op_store_management +-- ---------------------------- + +CREATE TABLE IF NOT EXISTS `op_store_management` ( + `id` INT AUTO_INCREMENT PRIMARY KEY COMMENT '主键ID', + `merchant_number` varchar(32) NOT NULL DEFAULT '' COMMENT '商户编号', + `enter_piece_id` varchar(32) NOT NULL DEFAULT '' COMMENT '进件Id', + `store_number` varchar(32) NOT NULL DEFAULT '' COMMENT '门店编号', + `store_name` varchar(64) NOT NULL DEFAULT '' COMMENT '门店名称', + `contact_phone` TINYINT(11) DEFAULT 0 COMMENT '联系人电话', + `logo_photo` varchar(64) NULL DEFAULT '' COMMENT '门店logo', + `indoor_scene_photo` varchar(64) NULL DEFAULT '' COMMENT '门店内景照片', + `environment_photo` varchar(64) NULL DEFAULT '' COMMENT '门店环境照片', + `door_sign_photo` varchar(64) NULL DEFAULT '' COMMENT '门头照片', + `province` varchar(64) NULL DEFAULT '' COMMENT '省份', + `city` varchar(64) NULL DEFAULT '' COMMENT '城市', + `urban_area` varchar(64) NULL DEFAULT '' COMMENT '城区', + `specific_location` varchar(64) NULL DEFAULT '' COMMENT '具体位置', + `latitude_longitude` varchar(32) NULL DEFAULT '' COMMENT '经纬度', + `customer_service_phone` varchar(256) NULL DEFAULT NULL COMMENT '客服电话', + `reserved_field_1` varchar(64) NULL DEFAULT NULL COMMENT '预留字段1', + `reserved_field_2` varchar(64) NULL DEFAULT NULL COMMENT '预留字段2', + `reserved_field_3` varchar(64) NULL DEFAULT NULL COMMENT '预留字段3', + `created_user` VARCHAR(64) NOT NULL COMMENT '创建人', + `created_time` TIMESTAMP DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', + `updated_user` VARCHAR(64) NOT NULL COMMENT '更新人', + `updated_time` TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间', + `is_deleted` TINYINT(1) DEFAULT 0 NOT NULL COMMENT '逻辑删除标识 (0:未删除, 1:已删除)', + INDEX idx_is_deleted (is_deleted), -- 为逻辑删除字段创建索引，提高查询性能 + INDEX idx_merchant_number (merchant_number) -- 商户编号创建索引、提高查询性能 + ) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci COMMENT = '门店管理'; + +-- ---------------------------- +-- Table structure for op_enter_piece_management +-- ---------------------------- + +CREATE TABLE IF NOT EXISTS `op_enter_piece_management` ( + `id` INT AUTO_INCREMENT PRIMARY KEY COMMENT '主键ID', + `merchant_number` varchar(32) NOT NULL DEFAULT '' COMMENT '商户编号', + `apply_number` varchar(32) NOT NULL DEFAULT '' COMMENT '申请单号', + `channel` TINYINT(1) DEFAULT 0 COMMENT '渠道（TODO：暂定0-汇付天下，完善渠道后，补充对应的注释）', + `product_name` varchar(64) NULL DEFAULT '' COMMENT '进件商户名', + `merchant_type` TINYINT(1) DEFAULT 0 COMMENT '商户类型(0:个体工商户, 1:企业)', + `submit_status` varchar(64) NULL DEFAULT '' COMMENT '提交状态(0-拟稿，1-审核中，2-进件成功)', + `source` TINYINT(1) DEFAULT 0 COMMENT '来源(0-运营中心，1-商户系统)', + `submit_time` TIMESTAMP DEFAULT CURRENT_TIMESTAMP COMMENT '' COMMENT '提交时间', + `reserved_field_1` varchar(64) NULL DEFAULT NULL COMMENT '预留字段1', + `reserved_field_2` varchar(64) NULL DEFAULT NULL COMMENT '预留字段2', + `reserved_field_3` varchar(64) NULL DEFAULT NULL COMMENT '预留字段3', + `reserved_field_4` varchar(64) NULL DEFAULT NULL COMMENT '预留字段4', + `created_user` VARCHAR(64) NOT NULL COMMENT '创建人', + `created_time` TIMESTAMP DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', + `updated_user` VARCHAR(64) NOT NULL COMMENT '更新人', + `updated_time` TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间', + `is_deleted` TINYINT(1) DEFAULT 0 NOT NULL COMMENT '逻辑删除标识 (0:未删除, 1:已删除)', + INDEX idx_is_deleted (is_deleted), -- 为逻辑删除字段创建索引，提高查询性能 + INDEX idx_merchant_number (merchant_number) -- 商户编号创建索引、提高查询性能 + ) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci COMMENT = '进件管理'; + +-- ---------------------------- +-- Table structure for op_merchant_info +-- ---------------------------- + +CREATE TABLE IF NOT EXISTS `op_merchant_info` ( + `id` INT AUTO_INCREMENT PRIMARY KEY COMMENT '主键ID', + `enter_piece_id` varchar(32) NOT NULL DEFAULT '' COMMENT '进件ID', + `license_photo` varchar(32) NOT NULL DEFAULT '' COMMENT '营业执照照片', + `license_number` varchar(32) NOT NULL DEFAULT '' COMMENT '营业执照编号', + `merchant_full_name` varchar(32) NOT NULL DEFAULT '' COMMENT '商户名称全称', + `registered_address` varchar(64) NOT NULL DEFAULT '' COMMENT '营业执照注册地址', + `issue_date` DATE COMMENT '营业执照有效期开始时间', + `expiry_date` DATE COMMENT '营业执照有效期截止时间', + `reserved_field_1` varchar(64) NULL DEFAULT NULL COMMENT '预留字段1', + `reserved_field_2` varchar(64) NULL DEFAULT NULL COMMENT '预留字段2', + `created_user` VARCHAR(64) NOT NULL COMMENT '创建人', + `created_time` TIMESTAMP DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', + `updated_user` VARCHAR(64) NOT NULL COMMENT '更新人', + `updated_time` TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间', + `is_deleted` TINYINT(1) DEFAULT 0 NOT NULL COMMENT '逻辑删除标识 (0:未删除, 1:已删除)', + INDEX idx_is_deleted (is_deleted), -- 为逻辑删除字段创建索引，提高查询性能 + INDEX idx_enter_piece_id (enter_piece_id) -- 进件Id创建索引、提高查询性能 + ) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci COMMENT = '商户信息'; + + + +-- ---------------------------- +-- Table structure for op_legal_entity_id_card_info +-- ---------------------------- + +CREATE TABLE IF NOT EXISTS `op_legal_entity_id_card_info` ( + `id` INT AUTO_INCREMENT PRIMARY KEY COMMENT '主键ID', + `enter_piece_id` varchar(32) NOT NULL DEFAULT '' COMMENT '进件ID', + `card_front_photo` varchar(32) NOT NULL DEFAULT '' COMMENT '法人身份证人像面照片', + `card_reverse_photo` varchar(32) NOT NULL DEFAULT '' COMMENT '法人身份证国徽面照片', + `card_name` varchar(32) NOT NULL DEFAULT '' COMMENT '法人身份证姓名', + `card_number` varchar(32) NOT NULL DEFAULT '' COMMENT '法人身份证号', + `start_date` varchar(32) NOT NULL DEFAULT '' COMMENT '法人身份证起始有效时间', + `end_date` varchar(32) NOT NULL DEFAULT '' COMMENT '法人身份证结束有效时间', + `reserved_field_1` varchar(64) NULL DEFAULT NULL COMMENT '预留字段1', + `reserved_field_2` varchar(64) NULL DEFAULT NULL COMMENT '预留字段2', + `created_user` VARCHAR(64) NOT NULL COMMENT '创建人', + `created_time` TIMESTAMP DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', + `updated_user` VARCHAR(64) NOT NULL COMMENT '更新人', + `updated_time` TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间', + `is_deleted` TINYINT(1) DEFAULT 0 NOT NULL COMMENT '逻辑删除标识 (0:未删除, 1:已删除)', + INDEX idx_is_deleted (is_deleted), -- 为逻辑删除字段创建索引，提高查询性能 + INDEX idx_enter_piece_id (enter_piece_id) -- 进件Id创建索引、提高查询性能 + ) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci COMMENT = '法人身份证信息'; + +-- ---------------------------- +-- Table structure for op_Settlement_rules +-- ---------------------------- + +CREATE TABLE IF NOT EXISTS `op_settlement_rules` ( + `id` INT AUTO_INCREMENT PRIMARY KEY COMMENT '主键ID', + `enter_piece_id` varchar(32) NOT NULL DEFAULT '' COMMENT '进件ID', + `settlement_info` varchar(32) NOT NULL DEFAULT '' COMMENT '结算规则信息（todo 目前结算规则业务不完善，待产品确认规则再指定，占坑）', + `industry` varchar(32) NOT NULL DEFAULT '' COMMENT '选择行业', + `special_qualifications_photo` varchar(32) NOT NULL DEFAULT '' COMMENT '特殊资质', + `rate_activity` TINYINT(1) DEFAULT 0 COMMENT '优惠费率活动(0-不参与，1-参与)', + `server_bid_price` varchar(32) NOT NULL DEFAULT '' COMMENT '服务商底价', + `agent_rate` varchar(32) NOT NULL DEFAULT '' COMMENT '代理商费率', + `enter_piece_rate` varchar(64) NULL DEFAULT NULL COMMENT '进件费率', + `reserved_field_1` varchar(64) NULL DEFAULT NULL COMMENT '预留字段1', + `reserved_field_2` varchar(64) NULL DEFAULT NULL COMMENT '预留字段2', + `created_user` VARCHAR(64) NOT NULL COMMENT '创建人', + `created_time` TIMESTAMP DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', + `updated_user` VARCHAR(64) NOT NULL COMMENT '更新人', + `updated_time` TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间', + `is_deleted` TINYINT(1) DEFAULT 0 NOT NULL COMMENT '逻辑删除标识 (0:未删除, 1:已删除)', + INDEX idx_is_deleted (is_deleted), -- 为逻辑删除字段创建索引，提高查询性能 + INDEX idx_enter_piece_id (enter_piece_id) -- 进件Id创建索引、提高查询性能 + ) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci COMMENT = '结算规则'; + +-- ---------------------------- +-- Table structure for op_legal_entity_id_card_info +-- ---------------------------- + +CREATE TABLE IF NOT EXISTS `op_legal_entity_id_card_info` ( + `id` INT AUTO_INCREMENT PRIMARY KEY COMMENT '主键ID', + `enter_piece_id` varchar(32) NOT NULL DEFAULT '' COMMENT '进件ID', + `account_type` TINYINT(1) DEFAULT 0 COMMENT '账户类型(0:对私, 1:对公)', + `open_account_name` varchar(32) NOT NULL DEFAULT '' COMMENT '开户名称', + `bank_account` varchar(32) NOT NULL DEFAULT '' COMMENT '银行账号', + `open_account_bank` varchar(32) NOT NULL DEFAULT '' COMMENT '开户行', + `bank_address` varchar(32) NOT NULL DEFAULT '' COMMENT '开户行地址', + `reserved_field_1` varchar(64) NULL DEFAULT NULL COMMENT '预留字段1', + `reserved_field_2` varchar(64) NULL DEFAULT NULL COMMENT '预留字段2', + `created_user` VARCHAR(64) NOT NULL COMMENT '创建人', + `created_time` TIMESTAMP DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', + `updated_user` VARCHAR(64) NOT NULL COMMENT '更新人', + `updated_time` TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间', + `is_deleted` TINYINT(1) DEFAULT 0 NOT NULL COMMENT '逻辑删除标识 (0:未删除, 1:已删除)', + INDEX idx_is_deleted (is_deleted), -- 为逻辑删除字段创建索引，提高查询性能 + INDEX idx_enter_piece_id (enter_piece_id) -- 进件Id创建索引、提高查询性能 + ) ENGINE = InnoDB AUTO_INCREMENT = 1 CHARACTER SET = utf8mb4 COLLATE = utf8mb4_unicode_ci COMMENT = '结算账户'; +