Merge remote-tracking branch 'origin/main'

main
duanyuqing 6 months ago
commit 1179de7cfd

@ -0,0 +1,45 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>cn.iocoder.cloud</groupId>
<artifactId>hake-module-agent</artifactId>
<version>${revision}</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>hake-module-agent-api</artifactId>
<packaging>jar</packaging>
<name>${project.artifactId}</name>
<description>
agent 模块 API暴露给其它模块调用
</description>
<dependencies>
<dependency>
<groupId>cn.iocoder.cloud</groupId>
<artifactId>hake-common</artifactId>
</dependency>
<!-- 参数校验 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-validation</artifactId>
<optional>true</optional>
</dependency>
</dependencies>
<distributionManagement>
<repository>
<id>central</id>
<name>Central Repository</name>
<url>http://192.168.1.200:19081/repository/maven-hake/</url>
</repository>
<snapshotRepository>
<id>snapshots</id>
<name>Nexus Snapshot Repository</name>
<url>http://192.168.1.200:19081/repository/maven-snapshots/</url>
</snapshotRepository>
</distributionManagement>
</project>

@ -0,0 +1,4 @@
/**
* agent API API
*/
package cn.iocoder.hake.module.erp.api;

@ -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";
}

@ -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, "代理商不存在");
}

@ -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;
}
}

@ -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;
}
}

@ -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

@ -0,0 +1,135 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>cn.iocoder.cloud</groupId>
<artifactId>hake-module-agent</artifactId>
<version>${revision}</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>hake-module-agent-server</artifactId>
<name>${project.artifactId}</name>
<description>
agent 包下,代理商管理
</description>
<dependencies>
<!-- Spring Cloud 基础 -->
<dependency>
<groupId>cn.iocoder.cloud</groupId>
<artifactId>hake-spring-boot-starter-env</artifactId>
</dependency>
<!-- 依赖服务 -->
<dependency>
<groupId>cn.iocoder.cloud</groupId>
<artifactId>hake-module-system-api</artifactId>
<version>${revision}</version>
</dependency>
<dependency>
<groupId>cn.iocoder.cloud</groupId>
<artifactId>hake-module-agent-api</artifactId>
<version>${revision}</version>
</dependency>
<!-- 业务组件 -->
<dependency>
<groupId>cn.iocoder.cloud</groupId>
<artifactId>hake-spring-boot-starter-biz-tenant</artifactId>
</dependency>
<!-- Web 相关 -->
<dependency>
<groupId>cn.iocoder.cloud</groupId>
<artifactId>hake-spring-boot-starter-security</artifactId>
</dependency>
<!-- DB 相关 -->
<dependency>
<groupId>cn.iocoder.cloud</groupId>
<artifactId>hake-spring-boot-starter-mybatis</artifactId>
</dependency>
<dependency>
<groupId>cn.iocoder.cloud</groupId>
<artifactId>hake-spring-boot-starter-redis</artifactId>
</dependency>
<!-- RPC 远程调用相关 -->
<dependency>
<groupId>cn.iocoder.cloud</groupId>
<artifactId>hake-spring-boot-starter-rpc</artifactId>
</dependency>
<!-- Registry 注册中心相关 -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<!-- Config 配置中心相关 -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
</dependency>
<!-- 工具类相关 -->
<dependency>
<groupId>cn.iocoder.cloud</groupId>
<artifactId>hake-spring-boot-starter-excel</artifactId>
</dependency>
<!-- 监控相关 -->
<dependency>
<groupId>cn.iocoder.cloud</groupId>
<artifactId>hake-spring-boot-starter-monitor</artifactId>
</dependency>
<!-- Test 测试相关 -->
<dependency>
<groupId>cn.iocoder.cloud</groupId>
<artifactId>hake-spring-boot-starter-test</artifactId>
</dependency>
</dependencies>
<distributionManagement>
<repository>
<id>central</id>
<name>Central Repository</name>
<url>http://192.168.1.200:19081/repository/maven-hake/</url>
</repository>
<snapshotRepository>
<id>snapshots</id>
<name>Nexus Snapshot Repository</name>
<url>http://192.168.1.200:19081/repository/maven-snapshots/</url>
</snapshotRepository>
</distributionManagement>
<build>
<!-- 设置构建的 jar 包名 -->
<finalName>${project.artifactId}</finalName>
<plugins>
<!-- 打包 -->
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<version>${spring.boot.version}</version>
<configuration>
<finalName>agent</finalName> <!-- 指定新的文件名 -->
<outputDirectory>../../packge</outputDirectory>
</configuration>
<executions>
<execution>
<goals>
<goal>repackage</goal> <!-- 将引入的 jar 打入其中 -->
</goals>
</execution>
</executions>
</plugin>
</plugins>
</build>
</project>

@ -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);
}
}

@ -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<Long> createAgent(@Valid @RequestBody AgentSaveReqVO createReqVO) {
return success(agentService.createAgent(createReqVO));
}
@PostMapping("/updateStatus")
@Operation(summary = "代理商审核")
@PreAuthorize("@ss.hasPermission('agent:info:audit')")
public CommonResult<Long> updateAgentStatus(@Valid @RequestBody AuditRespVO auditRespVO) {
return success(agentService.updateAgentStatus(auditRespVO));
}
@PutMapping("/update")
@Operation(summary = "更新代理商管理")
@PreAuthorize("@ss.hasPermission('agent:info:update')")
public CommonResult<Boolean> 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<Boolean> 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<Boolean> deleteAgentList(@RequestParam("ids") List<Long> 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<AgentRespVO> 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<PageResult<AgentRespVO>> getAgentPage(@Valid AgentPageReqVO pageReqVO) {
PageResult<AgentDO> 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<AgentDO> list = agentService.getAgentPage(pageReqVO).getList();
// 导出 Excel
ExcelUtils.write(response, "代理商管理.xls", "数据", AgentRespVO.class,
BeanUtils.toBean(list, AgentRespVO.class));
}
}

@ -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;
}

@ -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;
}

@ -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;
}

@ -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;
}

@ -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;
/**
* IDagent_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;
}

@ -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<AgentDO> {
default PageResult<AgentDO> selectPage(AgentPageReqVO reqVO) {
return selectPage(reqVO, new LambdaQueryWrapperX<AgentDO>()
.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));
}
}

@ -0,0 +1,6 @@
/**
* erp framework
*
* @author hake
*/
package cn.iocoder.hake.module.agent.framework;

@ -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 {
}

@ -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<HttpSecurity>.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();
}
};
}
}

@ -0,0 +1,10 @@
/**
* erp Enterprise Resource Planning
*
*
* 1. Controller URL /erp/ Module
* 2. DataObject erp_ 便
*
* Erp Erp ~
*/
package cn.iocoder.hake.module.agent;

@ -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<Long> ids);
/**
*
*
* @param id
* @return
*/
AgentDO getAgent(Long id);
/**
*
*
* @param pageReqVO
* @return
*/
PageResult<AgentDO> getAgentPage(AgentPageReqVO pageReqVO);
}

@ -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<Long> ids) {
// 校验存在
validateAgentExists(ids);
// 删除
agentMapper.deleteByIds(ids);
}
private void validateAgentExists(List<Long> ids) {
List<AgentDO> 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<AgentDO> getAgentPage(AgentPageReqVO pageReqVO) {
return agentMapper.selectPage(pageReqVO);
}
}

@ -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 # 关闭演示模式

@ -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

@ -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

@ -0,0 +1,76 @@
<configuration>
<!-- 引用 Spring Boot 的 logback 基础配置 -->
<include resource="org/springframework/boot/logging/logback/defaults.xml" />
<!-- 变量 hake.info.base-package基础业务包 -->
<springProperty scope="context" name="hake.info.base-package" source="hake.info.base-package"/>
<!-- 格式化输出:%d 表示日期,%X{tid} SkWalking 链路追踪编号,%thread 表示线程名,%-5level级别从左显示 5 个字符宽度,%msg日志消息%n是换行符 -->
<property name="PATTERN_DEFAULT" value="%d{${LOG_DATEFORMAT_PATTERN:-yyyy-MM-dd HH:mm:ss.SSS}} | %highlight(${LOG_LEVEL_PATTERN:-%5p} ${PID:- }) | %boldYellow(%thread [%tid]) %boldGreen(%-40.40logger{39}) | %m%n${LOG_EXCEPTION_CONVERSION_WORD:-%wEx}"/>
<!-- 控制台 Appender -->
<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">     
<encoder class="ch.qos.logback.core.encoder.LayoutWrappingEncoder">
<layout class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.TraceIdPatternLogbackLayout">
<pattern>${PATTERN_DEFAULT}</pattern>
</layout>
</encoder>
</appender>
<!-- 文件 Appender -->
<!-- 参考 Spring Boot 的 file-appender.xml 编写 -->
<appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
<encoder class="ch.qos.logback.core.encoder.LayoutWrappingEncoder">
<layout class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.TraceIdPatternLogbackLayout">
<pattern>${PATTERN_DEFAULT}</pattern>
</layout>
</encoder>
<!-- 日志文件名 -->
<file>${LOG_FILE}</file>
<rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
<!-- 滚动后的日志文件名 -->
<fileNamePattern>${LOGBACK_ROLLINGPOLICY_FILE_NAME_PATTERN:-${LOG_FILE}.%d{yyyy-MM-dd}.%i.gz}</fileNamePattern>
<!-- 启动服务时,是否清理历史日志,一般不建议清理 -->
<cleanHistoryOnStart>${LOGBACK_ROLLINGPOLICY_CLEAN_HISTORY_ON_START:-false}</cleanHistoryOnStart>
<!-- 日志文件,到达多少容量,进行滚动 -->
<maxFileSize>${LOGBACK_ROLLINGPOLICY_MAX_FILE_SIZE:-10MB}</maxFileSize>
<!-- 日志文件的总大小0 表示不限制 -->
<totalSizeCap>${LOGBACK_ROLLINGPOLICY_TOTAL_SIZE_CAP:-0}</totalSizeCap>
<!-- 日志文件的保留天数 -->
<maxHistory>${LOGBACK_ROLLINGPOLICY_MAX_HISTORY:-30}</maxHistory>
</rollingPolicy>
</appender>
<!-- 异步写入日志,提升性能 -->
<appender name="ASYNC" class="ch.qos.logback.classic.AsyncAppender">
<!-- 不丢失日志。默认的,如果队列的 80% 已满,则会丢弃 TRACT、DEBUG、INFO 级别的日志 -->
<discardingThreshold>0</discardingThreshold>
<!-- 更改默认的队列的深度,该值会影响性能。默认值为 256 -->
<queueSize>256</queueSize>
<appender-ref ref="FILE"/>
</appender>
<!-- SkyWalking GRPC 日志收集实现日志中心。注意SkyWalking 8.4.0 版本开始支持 -->
<appender name="GRPC" class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.log.GRPCLogClientAppender">
<encoder class="ch.qos.logback.core.encoder.LayoutWrappingEncoder">
<layout class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.TraceIdPatternLogbackLayout">
<pattern>${PATTERN_DEFAULT}</pattern>
</layout>
</encoder>
</appender>
<!-- 本地环境 -->
<springProfile name="local">
<root level="INFO">
<appender-ref ref="STDOUT"/>
<appender-ref ref="GRPC"/> <!-- 本地环境下,如果不想接入 SkyWalking 日志服务,可以注释掉本行 -->
<appender-ref ref="ASYNC"/> <!-- 本地环境下,如果不想打印日志,可以注释掉本行 -->
</root>
</springProfile>
<!-- 其它环境 -->
<springProfile name="dev,test,stage,prod,default">
<root level="INFO">
<appender-ref ref="STDOUT"/>
<appender-ref ref="ASYNC"/>
<appender-ref ref="GRPC"/>
</root>
</springProfile>
</configuration>

@ -0,0 +1,12 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="cn.iocoder.hake.module.agent.dal.mysql.agent.AgentMapper">
<!--
一般情况下,尽可能使用 Mapper 进行 CRUD 增删改查即可。
无法满足的场景,例如说多表关联查询,才使用 XML 编写 SQL。
代码生成器暂时只生成 Mapper XML 文件本身,更多推荐 MybatisX 快速开发插件来生成查询。
文档可见https://www.iocoder.cn/MyBatis/x-plugins/
-->
</mapper>

@ -0,0 +1,23 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>cn.iocoder.cloud</groupId>
<artifactId>hake</artifactId>
<version>${revision}</version>
</parent>
<modules>
<module>hake-module-agent-api</module>
<module>hake-module-agent-server</module>
</modules>
<modelVersion>4.0.0</modelVersion>
<artifactId>hake-module-agent</artifactId>
<packaging>pom</packaging>
<name>${project.artifactId}</name>
<description>
erp 包下,代理商管理
</description>
</project>

@ -0,0 +1,40 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>hake-module-op</artifactId>
<groupId>cn.iocoder.cloud</groupId>
<version>${revision}</version>
</parent>
<name>${project.artifactId}</name>
<modelVersion>4.0.0</modelVersion>
<artifactId>hake-module-op-api</artifactId>
<packaging>jar</packaging>
<description>
op-api暴露远程服务连接的入口例如需要提供API其他服务请求此服务API业务
</description>
<dependencies>
<dependency>
<groupId>cn.iocoder.cloud</groupId>
<artifactId>hake-common</artifactId>
</dependency>
</dependencies>
<distributionManagement>
<repository>
<id>central</id>
<name>Central Repository</name>
<url>http://192.168.1.200:19081/repository/maven-hake/</url>
</repository>
<snapshotRepository>
<id>snapshots</id>
<name>Nexus Snapshot Repository</name>
<url>http://192.168.1.200:19081/repository/maven-snapshots/</url>
</snapshotRepository>
</distributionManagement>
</project>

@ -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

@ -0,0 +1,149 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>hake-module-op</artifactId>
<groupId>cn.iocoder.cloud</groupId>
<version>${revision}</version>
</parent>
<name>${project.artifactId}</name>
<modelVersion>4.0.0</modelVersion>
<artifactId>hake-module-op-server</artifactId>
<packaging>jar</packaging>
<description>
op-server,运营中心服务实现接口、业务逻辑、工具类等其他相应开发实现
</description>
<dependencies>
<!-- Spring Cloud 基础 -->
<dependency>
<groupId>cn.iocoder.cloud</groupId>
<artifactId>hake-spring-boot-starter-env</artifactId>
</dependency>
<!-- 依赖服务 -->
<dependency>
<groupId>cn.iocoder.cloud</groupId>
<artifactId>hake-module-op-api</artifactId>
<version>${revision}</version>
</dependency>
<dependency>
<groupId>cn.iocoder.cloud</groupId>
<artifactId>hake-module-system-api</artifactId>
<version>${revision}</version>
</dependency>
<dependency>
<groupId>cn.iocoder.cloud</groupId>
<artifactId>hake-module-infra-api</artifactId>
<version>${revision}</version>
</dependency>
<!-- 业务组件 -->
<dependency>
<groupId>cn.iocoder.cloud</groupId>
<artifactId>hake-spring-boot-starter-biz-tenant</artifactId>
</dependency>
<!-- Web 相关 -->
<dependency>
<groupId>cn.iocoder.cloud</groupId>
<artifactId>hake-spring-boot-starter-security</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-validation</artifactId>
</dependency>
<!-- DB 相关 -->
<dependency>
<groupId>cn.iocoder.cloud</groupId>
<artifactId>hake-spring-boot-starter-mybatis</artifactId>
</dependency>
<dependency>
<groupId>cn.iocoder.cloud</groupId>
<artifactId>hake-spring-boot-starter-redis</artifactId>
</dependency>
<!-- RPC 远程调用相关 -->
<dependency>
<groupId>cn.iocoder.cloud</groupId>
<artifactId>hake-spring-boot-starter-rpc</artifactId>
</dependency>
<!-- Registry 注册中心相关 -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<!-- Config 配置中心相关 -->
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
</dependency>
<!-- Test 测试相关 -->
<dependency>
<groupId>cn.iocoder.cloud</groupId>
<artifactId>hake-spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<!-- 监控相关 -->
<dependency>
<groupId>cn.iocoder.cloud</groupId>
<artifactId>hake-spring-boot-starter-monitor</artifactId>
</dependency>
<!-- 工具类相关 -->
<dependency>
<groupId>cn.iocoder.cloud</groupId>
<artifactId>hake-spring-boot-starter-excel</artifactId>
</dependency>
<!-- 三方云服务相关 -->
<dependency>
<groupId>com.github.binarywang</groupId>
<artifactId>wx-java-mp-spring-boot-starter</artifactId> <!-- 微信登录(公众号) -->
</dependency>
</dependencies>
<distributionManagement>
<repository>
<id>central</id>
<name>Central Repository</name>
<url>http://192.168.1.200:19081/repository/maven-hake/</url>
</repository>
<snapshotRepository>
<id>snapshots</id>
<name>Nexus Snapshot Repository</name>
<url>http://192.168.1.200:19081/repository/maven-snapshots/</url>
</snapshotRepository>
</distributionManagement>
<build>
<!-- 设置构建的 jar 包名 -->
<finalName>${project.artifactId}</finalName>
<plugins>
<!-- 打包 -->
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<version>${spring.boot.version}</version>
<configuration>
<finalName>op</finalName> <!-- 指定新的文件名 -->
<outputDirectory>../../packge</outputDirectory>
</configuration>
<executions>
<execution>
<goals>
<goal>repackage</goal> <!-- 将引入的 jar 打入其中 -->
</goals>
</execution>
</executions>
</plugin>
</plugins>
</build>
</project>

@ -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);
}
}

@ -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 {
}

@ -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<HttpSecurity>.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();
}
};
}
}

@ -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 # 关闭演示模式

@ -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

@ -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

@ -0,0 +1,76 @@
<configuration>
<!-- 引用 Spring Boot 的 logback 基础配置 -->
<include resource="org/springframework/boot/logging/logback/defaults.xml" />
<!-- 变量 hake.info.base-package基础业务包 -->
<springProperty scope="context" name="hake.info.base-package" source="hake.info.base-package"/>
<!-- 格式化输出:%d 表示日期,%X{tid} SkWalking 链路追踪编号,%thread 表示线程名,%-5level级别从左显示 5 个字符宽度,%msg日志消息%n是换行符 -->
<property name="PATTERN_DEFAULT" value="%d{${LOG_DATEFORMAT_PATTERN:-yyyy-MM-dd HH:mm:ss.SSS}} | %highlight(${LOG_LEVEL_PATTERN:-%5p} ${PID:- }) | %boldYellow(%thread [%tid]) %boldGreen(%-40.40logger{39}) | %m%n${LOG_EXCEPTION_CONVERSION_WORD:-%wEx}"/>
<!-- 控制台 Appender -->
<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">     
<encoder class="ch.qos.logback.core.encoder.LayoutWrappingEncoder">
<layout class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.TraceIdPatternLogbackLayout">
<pattern>${PATTERN_DEFAULT}</pattern>
</layout>
</encoder>
</appender>
<!-- 文件 Appender -->
<!-- 参考 Spring Boot 的 file-appender.xml 编写 -->
<appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
<encoder class="ch.qos.logback.core.encoder.LayoutWrappingEncoder">
<layout class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.TraceIdPatternLogbackLayout">
<pattern>${PATTERN_DEFAULT}</pattern>
</layout>
</encoder>
<!-- 日志文件名 -->
<file>${LOG_FILE}</file>
<rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
<!-- 滚动后的日志文件名 -->
<fileNamePattern>${LOGBACK_ROLLINGPOLICY_FILE_NAME_PATTERN:-${LOG_FILE}.%d{yyyy-MM-dd}.%i.gz}</fileNamePattern>
<!-- 启动服务时,是否清理历史日志,一般不建议清理 -->
<cleanHistoryOnStart>${LOGBACK_ROLLINGPOLICY_CLEAN_HISTORY_ON_START:-false}</cleanHistoryOnStart>
<!-- 日志文件,到达多少容量,进行滚动 -->
<maxFileSize>${LOGBACK_ROLLINGPOLICY_MAX_FILE_SIZE:-10MB}</maxFileSize>
<!-- 日志文件的总大小0 表示不限制 -->
<totalSizeCap>${LOGBACK_ROLLINGPOLICY_TOTAL_SIZE_CAP:-0}</totalSizeCap>
<!-- 日志文件的保留天数 -->
<maxHistory>${LOGBACK_ROLLINGPOLICY_MAX_HISTORY:-30}</maxHistory>
</rollingPolicy>
</appender>
<!-- 异步写入日志,提升性能 -->
<appender name="ASYNC" class="ch.qos.logback.classic.AsyncAppender">
<!-- 不丢失日志。默认的,如果队列的 80% 已满,则会丢弃 TRACT、DEBUG、INFO 级别的日志 -->
<discardingThreshold>0</discardingThreshold>
<!-- 更改默认的队列的深度,该值会影响性能。默认值为 256 -->
<queueSize>256</queueSize>
<appender-ref ref="FILE"/>
</appender>
<!-- SkyWalking GRPC 日志收集实现日志中心。注意SkyWalking 8.4.0 版本开始支持 -->
<appender name="GRPC" class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.log.GRPCLogClientAppender">
<encoder class="ch.qos.logback.core.encoder.LayoutWrappingEncoder">
<layout class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.TraceIdPatternLogbackLayout">
<pattern>${PATTERN_DEFAULT}</pattern>
</layout>
</encoder>
</appender>
<!-- 本地环境 -->
<springProfile name="local">
<root level="INFO">
<appender-ref ref="STDOUT"/>
<appender-ref ref="GRPC"/> <!-- 本地环境下,如果不想接入 SkyWalking 日志服务,可以注释掉本行 -->
<appender-ref ref="ASYNC"/> <!-- 本地环境下,如果不想打印日志,可以注释掉本行 -->
</root>
</springProfile>
<!-- 其它环境 -->
<springProfile name="dev,test,stage,prod,default">
<root level="INFO">
<appender-ref ref="STDOUT"/>
<appender-ref ref="ASYNC"/>
<appender-ref ref="GRPC"/>
</root>
</springProfile>
</configuration>

@ -0,0 +1,23 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>hake</artifactId>
<groupId>cn.iocoder.cloud</groupId>
<version>${revision}</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>hake-module-op</artifactId>
<packaging>pom</packaging>
<description>
op 模块,主要实现运营平台数据展示功能;例如:进件管理、商户列表、
门店管理、代理商服务管理等数据整合
</description>
<modules>
<module>hake-module-op-api</module>
<module>hake-module-op-server</module>
</modules>
</project>

@ -24,6 +24,8 @@
<module>hake-module-mall</module>
<module>hake-module-erp</module>
<module>hake-module-crm</module>
<module>hake-module-op</module>
<module>hake-module-agent</module>
</modules>
<name>${project.artifactId}</name>

@ -0,0 +1,192 @@
/*
2.0 MysqlTable in OperatingCenter System DDLDML
*/
-- ----------------------------
-- 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 = '结算账户';
Loading…
Cancel
Save