anto: 初始化

This commit is contained in:
zheng020 2026-04-03 10:59:33 +08:00
parent 9b9ed034d0
commit 42010e766f
86 changed files with 3995 additions and 0 deletions

38
txw-mhzc/.gitignore vendored Normal file
View File

@ -0,0 +1,38 @@
target/
!.mvn/wrapper/maven-wrapper.jar
!**/src/main/**/target/
!**/src/test/**/target/
### IntelliJ IDEA ###
.idea/modules.xml
.idea/jarRepositories.xml
.idea/compiler.xml
.idea/libraries/
*.iws
*.iml
*.ipr
### Eclipse ###
.apt_generated
.classpath
.factorypath
.project
.settings
.springBeans
.sts4-cache
### NetBeans ###
/nbproject/private/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/
build/
!**/src/main/**/build/
!**/src/test/**/build/
### VS Code ###
.vscode/
### Mac OS ###
.DS_Store

87
txw-mhzc/README.md Normal file
View File

@ -0,0 +1,87 @@
# 1、项目启动类
无需再编写启动类
### 开发环境可使用
`com.css.txw.mhzc.app.DevAppStarter`
### 其他环境使用
`com.css.ggzc.framework.app.ApplicationStarter`
# 2、目录结构
```
│ .gitignore
│ pom.xml
│ README.md
├─txw-mhzc-service-api api包
│ │ pom.xml
│ └─src
│ └─main
│ ├─java
│ │ └─com.css.txw.mhzc 模块包
│ │ ├─api api接口
│ │ │ IMhzcApi.java
│ │ │
│ │ ├─configuration 模块自动装配配置 需要在org.springframework.boot.autoconfigure.AutoConfiguration.imports中配置基于插件化开发各模块在该类中可指定要扫描的包等配置启动类不会自动扫描
│ │ │ MhzcApiConfiguration.java
│ │ │
│ │ ├─constants api常量
│ │ │ MhzcConstants.java
│ │ │
│ │ └─pojo api pojo
│ │
│ └─resources 模块相关的配置说明注意使用config类
│ │ additional-spring-configuration-metadata.json
│ │
│ └─META-INF
│ └─spring 模块自动装配配置
│ org.springframework.boot.autoconfigure.AutoConfiguration.imports
└─txw-mhzc-service-biz service包
│ pom.xml
└─src
└─main
├─java
│ └─com.css.txw.mhzc 模块包
│ ├─configuration 本模块自动装配设置 需要在org.springframework.boot.autoconfigure.AutoConfiguration.imports中配置基于插件化开发各模块在该类中可指定要扫描的包等配置启动类不会自动扫描
│ │ MhzcServiceConfiguration.java
│ │
│ ├─constants
│ │
│ ├─consumer kafaka消费服务
│ │
│ ├─controller controller 建议按业务分包 注意禁止在controller中写跟sql相关的逻辑一律写到mapper中
│ │
│ ├─job 定时任务
│ │
│ ├─mapper mapper 建议按业务分包
│ │
│ ├─pojo
│ │ ├─domain
│ │ │
│ │ ├─dto
│ │ │
│ │ └─vo
│ │
│ │-properties 配置类
│ │
│ ├─service service 建议按业务分包 注意SQL相关内容写到mapper中不要写在service中
│ │
│ └─util 本业务域工具类 跟业务相关的写在这里 公共类的请优先使用framework中有的或者在framework中增加
└─resources
│ additional-spring-configuration-metadata.json 模块相关的配置说明注意使用config类
│ application.yaml 模块主配置文件
│ bootstrap-env.yml 模块env环境配置文件
│ bootstrap-local.yml 模块开发环境配置文件
│ bootstrap-nacos.yml 模块nacos配置文件
│ bootstrap.yml 模块主配置文件
│ logback-spring.xml 模块日志配置文件
├─mapper 模块mapper
└─META-INF
└─spring 模块自动装配配置
org.springframework.boot.autoconfigure.AutoConfiguration.imports
```

39
txw-mhzc/pom.xml Normal file
View File

@ -0,0 +1,39 @@
<?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">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.css.ggzc</groupId>
<artifactId>ggzc-framework-dependencies</artifactId>
<version>1.0.0-SNAPSHOT</version>
</parent>
<artifactId>txw-mhzc</artifactId>
<groupId>com.css.txw</groupId>
<version>1.0.0-SNAPSHOT</version>
<packaging>pom</packaging>
<name>${project.artifactId}</name>
<description>mhzc</description>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>com.css.ggzc</groupId>
<artifactId>ggzc-framework-starter</artifactId>
<version>1.0.0-SNAPSHOT</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<build>
<finalName>${project.artifactId}</finalName>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-resources-plugin</artifactId>
<version>3.3.1</version>
</plugin>
</plugins>
</build>
<modules>
<module>txw-mhzc-service-api</module>
<module>txw-mhzc-service-biz</module>
</modules>
</project>

61
txw-mhzc/settings.xml Normal file
View File

@ -0,0 +1,61 @@
<settings xmlns="http://maven.apache.org/SETTINGS/1.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/SETTINGS/1.0.0 http://maven.apache.org/xsd/settings-1.0.0.xsd">
<!--<localRepository>[本地maven库目录]</localRepository>-->
<!-- omitted xml -->
<!-- 请妥善保管好您的配置,不要随意分享给他人 -->
<servers>
<server>
<id>codingcorp-qyd_repo-mvn_public</id>
<username>coding-user</username>
<password>coding-pwd</password>
</server>
</servers>
<!-- omitted xml -->
<profiles>
<profile>
<id>Repository Proxy</id>
<activation>
<activeByDefault>true</activeByDefault>
</activation>
<repositories>
<repository>
<!--必须与 settings.xml 的 id 一致-->
<id>codingcorp-qyd_repo-mvn_public</id>
<name>mvn_public</name>
<url>http://codingcorp-maven.pkg.codingstd.xc01.cloud.sat.tax/repository/qyd_repo/mvn_public/</url>
<releases>
<enabled>true</enabled>
</releases>
<snapshots>
<enabled>true</enabled>
<updatePolicy>always</updatePolicy>
</snapshots>
</repository>
</repositories>
<pluginRepositories>
<pluginRepository>
<id>codingcorp-qyd_repo-mvn_public</id>
<releases>
<enabled>true</enabled>
</releases>
<snapshots>
<enabled>true</enabled>
</snapshots>
<url>http://codingcorp-maven.pkg.codingstd.xc01.cloud.sat.tax/repository/qyd_repo/mvn_public/</url>
</pluginRepository>
</pluginRepositories>
</profile>
</profiles>
<mirrors>
<mirror>
<id>codingcorp-qyd_repo-mvn_public</id>
<!-- 此配置避免了本仓库制品的拉取流量被切换到腾讯云镜像源,保证您在使用镜像加速的同时可以从本仓库拉取制品 -->
<mirrorOf>central</mirrorOf>
<name>mvn_public</name>
<url>http://codingcorp-maven.pkg.codingstd.xc01.cloud.sat.tax/repository/qyd_repo/mvn_public/</url>
</mirror>
</mirrors>
</settings>

View File

@ -0,0 +1,88 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://maven.apache.org/POM/4.0.0"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<!--api的parent由于编译需要请自行修改 修改后需要调整 本模块groupId-->
<parent>
<groupId>com.css.ggzc</groupId>
<artifactId>ggzc-framework-dependencies</artifactId>
<version>1.0.0-SNAPSHOT</version>
<relativePath/>
</parent>
<groupId>com.css.txw</groupId>
<artifactId>txw-mhzc-service-api</artifactId>
<version>1.0.0-SNAPSHOT</version>
<name>${project.artifactId}</name>
<description>mhzc service api</description>
<properties>
<version.ggzc-framework-dependencies>1.0.0-SNAPSHOT</version.ggzc-framework-dependencies>
</properties>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>com.css.ggzc</groupId>
<artifactId>ggzc-framework-starter</artifactId>
<version>${version.ggzc-framework-dependencies}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-validation</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>com.css.ggzc</groupId>
<artifactId>ggzc-framework-starter-common</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
<dependency>
<groupId>io.swagger.core.v3</groupId>
<artifactId>swagger-annotations</artifactId>
<scope>compile</scope>
</dependency>
</dependencies>
<distributionManagement>
<repository>
<!--必须与 settings.xml 的 id 一致-->
<id>codingcorp-qyd_repo-mvn_public</id>
<name>mvn_public</name>
<url>http://codingcorp-maven.pkg.codingstd.xc01.cloud.sat.tax/repository/qyd_repo/mvn_public/</url>
</repository>
</distributionManagement>
<build>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-source-plugin</artifactId>
<version>3.3.0</version>
<configuration>
<attach>true</attach>
</configuration>
<executions>
<execution>
<phase>compile</phase>
<goals>
<goal>jar</goal>
</goals>
</execution>
</executions>
</plugin>
</plugins>
</build>
</project>

View File

@ -0,0 +1,67 @@
package com.css.txw.mhzc.api;
import com.css.ggzc.framework.common.pojo.CommonResult;
import com.css.txw.mhzc.constants.MhzcConstants;
import com.css.txw.mhzc.pojo.HtYhxxbDTO;
import com.css.txw.mhzc.pojo.QyrzReqDTO;
import com.css.txw.mhzc.pojo.YhxxReqDTO;
import com.css.txw.mhzc.pojo.YhxxbDTO;
import io.swagger.v3.oas.annotations.Operation;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import java.util.List;
@FeignClient(name = MhzcConstants.NAME)
public interface IMhzcApi {
String PREFIX = MhzcConstants.PREFIX + "/user";
String QYRZ_PREFIX = MhzcConstants.PREFIX + "/company";
@PostMapping(PREFIX+"/initSessionByYhuuid")
@Operation(summary = "初始化用户信息")
CommonResult<YhxxbDTO> initSessionByYhuuid(@RequestBody YhxxReqDTO reqDTO);
@PostMapping(PREFIX+"/initSessionByDlzh")
@Operation(summary = "初始化用户信息")
CommonResult<YhxxbDTO> initSessionByDlzh(@RequestBody YhxxReqDTO reqDTO);
@PostMapping(PREFIX+"/initHtSessionByYhuuid")
@Operation(summary = "初始化用户信息")
CommonResult<HtYhxxbDTO> initHtSessionByYhuuid(@RequestBody YhxxReqDTO reqDTO);
@PostMapping(PREFIX+"/initHtSessionByDlzh")
@Operation(summary = "初始化用户信息")
CommonResult<HtYhxxbDTO> initHtSessionByDlzh(@RequestBody YhxxReqDTO reqDTO);
@Operation(summary = "企业入驻",description = "企业入驻")
@PostMapping(QYRZ_PREFIX+"/qyrz")
CommonResult<String> qyrz(@RequestBody QyrzReqDTO reqDTO);
@PostMapping(PREFIX+"/getAllUserId")
@Operation(summary = "用户列表")
CommonResult<List<String>> getAllUserId();
@PostMapping(PREFIX+"/initSessionByDid")
@Operation(summary = "初始化用户信息")
CommonResult<YhxxbDTO> initSessionByDid(@RequestBody YhxxReqDTO reqDTO);
@PostMapping(PREFIX+"/initSessionBySfzjhm")
@Operation(summary = "根据身份证号初始化用户信息")
CommonResult<YhxxbDTO> initSessionBySfzjhm(@RequestBody YhxxReqDTO reqDTO);
@PostMapping(PREFIX+"/saveYhxxByDid")
@Operation(summary = "保存did用户信息")
CommonResult<YhxxbDTO> saveYhxxByDid(@RequestBody YhxxbDTO yhxx);
@PostMapping(QYRZ_PREFIX+"/intQyxxByDid")
@Operation(summary = "did企业认证信息")
CommonResult<YhxxbDTO> intQyxxByDid(@RequestBody YhxxbDTO qyxx);
@PostMapping(PREFIX+"/updateDid")
@Operation(summary = "更新用户did信息")
CommonResult<YhxxbDTO> updateDid(@RequestBody YhxxbDTO yhxx);
}

View File

@ -0,0 +1,13 @@
package com.css.txw.mhzc.configuration;
import com.css.txw.mhzc.api.IMhzcApi;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.context.annotation.Configuration;
@Configuration(proxyBeanMethods = false)
@EnableFeignClients(clients = {
IMhzcApi.class
})
public class MhzcApiConfiguration {
}

View File

@ -0,0 +1,12 @@
package com.css.txw.mhzc.constants;
public class MhzcConstants {
private MhzcConstants() {
// 构造方法
}
public static final String NAME = "txw-mhzc";
public static final String PREFIX = "/mhzc";
}

View File

@ -0,0 +1,35 @@
package com.css.txw.mhzc.pojo;
import lombok.Data;
import java.io.Serializable;
import java.util.Date;
@Data
public class HtYhxxbDTO implements Serializable {
private String yhUuid;
private String sjhm1;
private String dlmm;
private String dlzh;
private String zsxm1;
private String yxdz;
private String sfzjlx;
private String sfzjhm;
private String txdzurl;
private String yxbz;
private Date lrrq;
private String yhlx;
}

View File

@ -0,0 +1,14 @@
package com.css.txw.mhzc.pojo;
import lombok.Data;
import java.io.Serializable;
@Data
public class QyrzReqDTO implements Serializable {
private String nsrsbh;
private String ywlxDm;
}

View File

@ -0,0 +1,21 @@
package com.css.txw.mhzc.pojo;
import lombok.Data;
import java.io.Serializable;
@Data
public class YhxxReqDTO implements Serializable {
private String sjhm1;
private String yhuuid;
private String dlzh;
private String rzbz;
private String scxzmx;
private String did;
private String sfzjhm;
}

View File

@ -0,0 +1,41 @@
package com.css.txw.mhzc.pojo;
import lombok.Data;
import java.io.Serializable;
import java.util.Date;
@Data
public class YhxxbDTO implements Serializable {
private String yhUuid;
private String did;
private String sjhm1;
private String dlmm;
private String dlzh;
private String zsxm1;
private String yxdz;
private String sfzjlx;
private String sfzjhm;
private String txdzurl;
private String yxbz;
private Date lrrq;
private String yhlx;
private String qyuuid;
private String qymc;
private String nsrsbh;
}

View File

@ -0,0 +1 @@
com.css.txw.mhzc.configuration.MhzcApiConfiguration

View File

@ -0,0 +1,127 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://maven.apache.org/POM/4.0.0"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<artifactId>txw-mhzc</artifactId>
<groupId>com.css.txw</groupId>
<version>1.0.0-SNAPSHOT</version>
</parent>
<artifactId>txw-mhzc-service-biz</artifactId>
<packaging>jar</packaging>
<name>${project.artifactId}</name>
<description>mhzc service</description>
<properties>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<!-- Spring Cloud 基础 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-bootstrap</artifactId>
</dependency>
<!-- Web 相关 -->
<dependency>
<groupId>com.css.ggzc</groupId>
<artifactId>ggzc-framework-starter-web</artifactId>
</dependency>
<dependency>
<groupId>com.css.ggzc</groupId>
<artifactId>ggzc-framework-starter-common</artifactId>
</dependency>
<!-- DB 相关 -->
<dependency>
<groupId>com.css.ggzc</groupId>
<artifactId>ggzc-framework-starter-mybatis</artifactId>
</dependency>
<dependency>
<groupId>com.css.ggzc</groupId>
<artifactId>ggzc-framework-starter-cache</artifactId>
</dependency>
<!-- RPC 远程调用相关 -->
<dependency>
<groupId>com.css.ggzc</groupId>
<artifactId>ggzc-framework-starter-rpc</artifactId>
</dependency>
<!-- <dependency>
<groupId>com.css.ggzc</groupId>
<artifactId>ggzc-framework-starter-trace</artifactId>
</dependency>-->
<!-- Job 相关 -->
<dependency>
<groupId>com.css.ggzc</groupId>
<artifactId>ggzc-framework-starter-job</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>com.css.txw</groupId>
<artifactId>txw-sso-service-api</artifactId>
<version>1.0.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.css.txw</groupId>
<artifactId>txw-mhzc-service-api</artifactId>
<version>1.0.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.css.ggzc</groupId>
<artifactId>ggzc-framework-starter-xxzx-api</artifactId>
<version>1.0.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.dameng</groupId>
<artifactId>DmJdbcDriver18</artifactId>
</dependency>
</dependencies>
<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>
<fork>true</fork>
</configuration>
<executions>
<execution>
<goals>
<goal>repackage</goal> <!-- 将引入的 jar 打入其中 -->
</goals>
</execution>
</executions>
</plugin>
</plugins>
</build>
</project>

View File

@ -0,0 +1,19 @@
package com.css.txw.mhzc.app;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.EnableAspectJAutoProxy;
/**
* 仅开发使用正式环境不使用写在此处的配置在生产环境不会生效
*/
@Slf4j
@SpringBootApplication
@EnableAspectJAutoProxy(proxyTargetClass = true)
public class DevAppStarter {
public static void main(String[] args) {
SpringApplication.run(DevAppStarter.class, args);
log.info("txw-mhzc-0.0.3");
}
}

View File

@ -0,0 +1,12 @@
package com.css.txw.mhzc.configuration;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.autoconfigure.AutoConfiguration;
import org.springframework.context.annotation.ComponentScan;
@AutoConfiguration
@ComponentScan("com.css")
@MapperScan("com.css.txw.mhzc.mapper")
public class MhzcServiceConfiguration {
}

View File

@ -0,0 +1,47 @@
package com.css.txw.mhzc.constants;
import com.css.ggzc.framework.common.exception.ErrorCode;
/**
* System 错误码枚举类
*
* system 系统使用 1-002-000-000
*/
public interface ErrorCodeConstants {
// ========== AUTH 模块 1-002-000-000 ==========
ErrorCode AUTH_LOGIN_BAD_CREDENTIALS = new ErrorCode(1004001, "登录失败,账号密码不正确");
ErrorCode AUTH_LOGIN_USER_DISABLED = new ErrorCode(1004002, "登录失败,账号被禁用");
ErrorCode AUTH_LOGIN_CAPTCHA_CODE_ERROR = new ErrorCode(1004003, "请重新滑动验证");
ErrorCode AUTH_LOGIN_PASSWORD_ERROR_LOCK = new ErrorCode(1004004, "密码输入错误次数过多,账户锁定,请稍后再试");
ErrorCode AUTH_LOGIN_ACCOUNT_LOCK = new ErrorCode(1004005, "密码输入错误次数过多,账户锁定,请联系管理员解锁");
// ========== OAuth2 客户端 1-002-020-000 =========
ErrorCode OAUTH2_CLIENT_NOT_EXISTS = new ErrorCode(1004006, "OAuth2 客户端不存在");
ErrorCode OAUTH2_CLIENT_EXISTS = new ErrorCode(1004007, "OAuth2 客户端编号已存在");
ErrorCode OAUTH2_CLIENT_DISABLE = new ErrorCode(1004008, "OAuth2 客户端已禁用");
ErrorCode OAUTH2_CLIENT_REDIRECT_URI_NOT_MATCH = new ErrorCode(1004009, "无效 redirect_uri: {}");
ErrorCode OAUTH2_CLIENT_CLIENT_SECRET_ERROR = new ErrorCode(1004010, "无效 client_secret: {}");
// ========== OAuth2 授权 1-002-021-000 =========
ErrorCode OAUTH2_GRANT_CLIENT_ID_MISMATCH = new ErrorCode(1004011, "client_id 不匹配");
ErrorCode OAUTH2_GRANT_REDIRECT_URI_MISMATCH = new ErrorCode(1004012, "redirect_uri 不匹配");
ErrorCode OAUTH2_GRANT_STATE_MISMATCH = new ErrorCode(1004013, "state 不匹配");
ErrorCode OAUTH2_GRANT_CODE_NOT_EXISTS = new ErrorCode(1004014, "code 不存在");
// ========== OAuth2 授权 1-002-022-000 =========
ErrorCode OAUTH2_CODE_NOT_EXISTS = new ErrorCode(1004015, "code 不存在");
ErrorCode OAUTH2_CODE_EXPIRE = new ErrorCode(1004016, "code 已过期");
ErrorCode OAUTH2_SJHM_NOT_EXISTS = new ErrorCode(1004017, "手机号码不存在");
ErrorCode OAUTH2_LOGIN_SJHM_NOT_EXISTS = new ErrorCode(1004018, "验证码无效");
ErrorCode OAUTH2_SJHM_LOCK = new ErrorCode(1004019, "距离上次发送验证码不超过1分钟");
ErrorCode YHXX_IS_EXISTS = new ErrorCode(1004020, "账号已存在");
}

View File

@ -0,0 +1 @@
# kafaka消费服务

View File

@ -0,0 +1,78 @@
package com.css.txw.mhzc.controller;
import com.css.ggzc.framework.common.pojo.CommonResult;
import com.css.txw.mhzc.pojo.QyrzReqDTO;
import com.css.txw.mhzc.pojo.YhxxbDTO;
import com.css.txw.mhzc.pojo.vo.*;
import com.css.txw.mhzc.service.TxwMhzcQyrzsqjlbService;
import com.css.txw.mhzc.service.TxwMhzcQyxxbService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.extern.slf4j.Slf4j;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import java.util.List;
@Tag(name = "企业信息接口")
@RestController
@RequestMapping("/company")
@Validated
@Slf4j
public class CompanyController {
@Resource
private TxwMhzcQyxxbService qyxxbService;
@Resource
private TxwMhzcQyrzsqjlbService qyrzsqjlbService;
@PostMapping("/register")
@Operation(summary = "企业认证",description = "企业认证")
public CommonResult<String> register(@RequestBody RegisterCompanyReqVO reqDTO){
return CommonResult.success(qyxxbService.register(reqDTO));
}
@PostMapping("/qyRzSp")
@Operation(summary = "企业认证审批",description = "企业认证审批")
public CommonResult<String> qyRzSp(@RequestBody CompanySpReqVO reqVO){
return CommonResult.success(qyxxbService.qyRzSp(reqVO));
}
@PostMapping("/intQyxxByDid")
@Operation(summary = "did企业认证信息",description ="did企业认证信息")
public CommonResult<YhxxbDTO> intQyxxByDid(@RequestBody YhxxbDTO qyxx){
return CommonResult.success(qyxxbService.intQyxxByDid(qyxx));
}
@GetMapping("/revokeSq")
@Operation(summary = "企业认证审批",description = "企业认证审批")
public CommonResult<String> revokeSq(@RequestParam("uuid") String uuid){
return CommonResult.success(qyrzsqjlbService.revokeSq(uuid));
}
@Operation(summary = "获取企业申请列表",description = "获取企业申请列表")
@PostMapping("/getRegisterList")
public CommonResult<List<RegisterCompanySqVO>> getRegisterList(@RequestBody GetRegisterListReqVO reqVO){
return CommonResult.success(qyrzsqjlbService.getRegisterList(reqVO));
}
@Operation(summary = "获取企业申请列表",description = "获取企业申请列表")
@PostMapping("/getCurrentRegisterList")
public CommonResult<List<RegisterCompanySqVO>> getCurrentRegisterList(){
return CommonResult.success(qyrzsqjlbService.getCurrentRegisterList());
}
@Operation(summary = "企业入驻",description = "企业入驻")
@PostMapping("/qyrz")
public CommonResult<String> qyrz(@RequestBody QyrzReqDTO reqDTO){
return CommonResult.success(qyxxbService.qyrz(reqDTO));
}
@Operation(summary = "根据业务类型查询入驻的企业",description = "根据业务类型查询入驻的企业")
@GetMapping("/getQyxxListByYwlx")
public CommonResult<List<CompanyVO>> getQyxxListByYwlx(@RequestParam("ywlx") String ywlx){
return CommonResult.success(qyxxbService.getQyxxListByYwlx(ywlx));
}
}

View File

@ -0,0 +1,124 @@
package com.css.txw.mhzc.controller;
import cn.hutool.core.util.IdUtil;
import com.css.ggzc.framework.cache.utils.CacheUtils;
import com.css.ggzc.framework.common.pojo.CommonResult;
import com.css.ggzc.framework.common.util.gy.GyUtils;
import com.css.ggzc.framework.file.utils.GgzcFileUtils;
import com.css.ggzc.framework.session.SessionUtils;
import com.css.txw.mhzc.constants.ErrorCodeConstants;
import com.css.txw.mhzc.pojo.QyrzReqDTO;
import com.css.txw.mhzc.pojo.vo.*;
import com.css.txw.mhzc.service.*;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.extern.slf4j.Slf4j;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletResponse;
import javax.validation.constraints.NotBlank;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.List;
import java.util.Map;
@Tag(name = "企业信息接口")
@RestController
@RequestMapping("/sy")
@Validated
@Slf4j
public class SyController {
@Resource
private TxwMhzcZxxxbService zxxxbService;
@Resource
private TxwMhzcSyxxbService syxxbService;
@Resource
private TxwMhzcGglbService gglbService;
@PostMapping("/zxxx")
@Operation(summary = "资讯",description = "企业认证")
public CommonResult<Map<String, List<SyzxxxVO>>> zxxx(){
return CommonResult.success(zxxxbService.zxxx());
}
@GetMapping("/sjkb")
@Operation(summary = "数据看板",description = "数据看板")
public CommonResult<String> sjkb(){
return CommonResult.success(CacheUtils.dm2mc("cs_ggzc_xtcs","sjkb"));
}
@GetMapping("/hzhb")
@Operation(summary = "合作伙伴",description = "合作伙伴")
public CommonResult<String> hzhb(){
return CommonResult.success(CacheUtils.dm2mc("cs_ggzc_xtcs","hzhb"));
}
@GetMapping("/getCdxx")
@Operation(summary = "查询菜单",description = "查询菜单")
public CommonResult<Map<String,Object>> getCdxx(){
return CommonResult.success(syxxbService.getCdxx());
}
@PostMapping("/saveGgxx")
@Operation(summary = "保存广告信息",description = "保存广告信息")
public CommonResult<String> saveGgxx(@RequestBody GglbVO gglbVO){
return CommonResult.success(gglbService.saveGgxx(gglbVO));
}
@PostMapping("/getGgxxList")
@Operation(summary = "查询广告栏",description = "查询广告栏")
public CommonResult<List<GglbVO>> getGgxxList(@RequestBody GglbReqVO reqVO){
return CommonResult.success(gglbService.getGgxxList(reqVO));
}
@GetMapping("/delGgxx")
@Operation(summary = "删除广告栏",description = "删除广告栏")
public CommonResult<String> delGgxx(@RequestParam("uuid") @NotBlank String uuid){
return CommonResult.success(gglbService.delGgxx(uuid));
}
// @PostMapping("/uploadFile")
@PostMapping(value = {"/uploadFile"}, consumes = {"multipart/form-data"})
@Operation(summary = "上传头像url")
public CommonResult<String> uploadFile(@RequestBody MultipartFile file, @RequestParam(required = false) String delid) throws IOException {
if (!GyUtils.isNull(delid)) GgzcFileUtils.delete(delid);
String name = IdUtil.fastSimpleUUID();
GgzcFileUtils.upload(file.getBytes(), name, file.getContentType());
return CommonResult.success(name);
}
@GetMapping("/delFile")
@Operation(summary = "获取文件")
public CommonResult<String> delFile(@RequestParam @NotBlank String delid) {
GgzcFileUtils.delete(delid);
return CommonResult.success("success");
}
@GetMapping("/getResources")
@Operation(summary = "获取文件")
public CommonResult<String> getResources(HttpServletResponse response, @RequestParam @NotBlank String url) throws Exception {
byte[] content = GgzcFileUtils.getContent(url);
if (GyUtils.isNull(content)){
log.info("获取图片为空,id:{}",url);
return CommonResult.success("");
}
InputStream inputStream = new ByteArrayInputStream(content);
byte[] buffer = new byte[16384];
int bytesRead;
while ((bytesRead = inputStream.read(buffer)) != -1) {
response.getOutputStream().write(buffer, 0, bytesRead);
}
buffer = null;
response.flushBuffer();
inputStream.close();
return CommonResult.success("success");
}
}

View File

@ -0,0 +1,122 @@
package com.css.txw.mhzc.controller;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.css.ggzc.framework.common.pojo.CommonResult;
import com.css.txw.mhzc.pojo.HtYhxxbDTO;
import com.css.txw.mhzc.pojo.YhxxReqDTO;
import com.css.txw.mhzc.pojo.YhxxbDTO;
import com.css.txw.mhzc.pojo.vo.*;
import com.css.txw.mhzc.service.TxwMhzcHtyhxxbService;
import com.css.txw.mhzc.service.TxwMhzcYhxxbService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.extern.slf4j.Slf4j;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import java.util.List;
@Tag(name = "用户信息接口")
@RestController
@RequestMapping("/user")
@Validated
@Slf4j
public class UserController {
@Resource
private TxwMhzcYhxxbService yhxxbService;
@Resource
private TxwMhzcHtyhxxbService htyhxxbService;
@PostMapping("/initSessionByYhuuid")
@Operation(summary = "初始化会话信息",description = "登录后提供用户初始化会话信息")
public CommonResult<YhxxbDTO> initSessionByYhuuid(@RequestBody YhxxReqDTO reqDTO){
return CommonResult.success(yhxxbService.initSessionByYhuuid(reqDTO));
}
@PostMapping("/initSessionByDid")
@Operation(summary = "初始化会话信息",description = "根据did提供用户初始化会话信息")
public CommonResult<YhxxbDTO> initSessionByDid(@RequestBody YhxxReqDTO reqDTO){
return CommonResult.success(yhxxbService.initSessionByDid(reqDTO));
}
@PostMapping("/initSessionBySfzjhm")
@Operation(summary = "初始化会话信息",description = "根据身份证号提供用户初始化会话信息")
public CommonResult<YhxxbDTO> initSessionBySfzjhm(@RequestBody YhxxReqDTO reqDTO){
return CommonResult.success(yhxxbService.initSessionBySfzjhm(reqDTO));
}
@PostMapping("/initSessionByDlzh")
@Operation(summary = "初始化会话信息",description = "登录后提供用户初始化会话信息")
public CommonResult<YhxxbDTO> initSessionByDlzh(@RequestBody YhxxReqDTO reqDTO){
return CommonResult.success(yhxxbService.initSessionByDlzh(reqDTO));
}
@PostMapping("/register")
@Operation(summary = "注册",description = "注册")
public CommonResult<String> register(@RequestBody UserRegisterReqVO reqVO){
return CommonResult.success(yhxxbService.register(reqVO));
}
@PostMapping("/saveYhxxByDid")
@Operation(summary = "保存did用户信息",description = "保存did用户信息")
public CommonResult<YhxxbDTO> saveYhxxByDid(@RequestBody YhxxbDTO yhxx){
return CommonResult.success(yhxxbService.saveYhxxByDid(yhxx));
}
@PostMapping("/updateDid")
@Operation(summary = "更新用户did信息",description = "更新用户did信息")
public CommonResult<YhxxbDTO> updateDid(@RequestBody YhxxbDTO yhxx){
return CommonResult.success(yhxxbService.updateDid(yhxx));
}
@PostMapping("/initHtSessionByDlzh")
@Operation(summary = "初始化用户信息")
CommonResult<HtYhxxbDTO> initHtSessionByDlzh(@RequestBody YhxxReqDTO reqDTO){
return CommonResult.success(htyhxxbService.initHtSessionByDlzh(reqDTO));
}
@PostMapping("/initHtSessionByYhuuid")
@Operation(summary = "初始化用户信息")
CommonResult<HtYhxxbDTO> initHtSessionByYhuuid(@RequestBody YhxxReqDTO reqDTO){
return CommonResult.success(htyhxxbService.initHtSessionByYhuuid(reqDTO));
}
@PostMapping("/lockUser")
@Operation(summary = "锁定用户")
public CommonResult<Integer> lockUser(@RequestBody UserLockVO lockVO){
return CommonResult.success(yhxxbService.lockUser(lockVO));
}
@PostMapping("/unlockUser")
@Operation(summary = "解锁用户")
public CommonResult<Integer> unlockUser(@RequestBody UserLockVO infoVO){
return CommonResult.success(yhxxbService.unlockUser(infoVO));
}
@PostMapping("/init")
@Operation(summary = "初始化用户信息")
CommonResult<SessionVO> init(){
return CommonResult.success(yhxxbService.init());
}
@PostMapping("/getAllUser")
@Operation(summary = "用户列表")
CommonResult<Page<UserVO>> getAllUser(@RequestBody UserReqVO reqVO){
return CommonResult.success(yhxxbService.getAllUser(reqVO));
}
@PostMapping("/getAllUserId")
@Operation(summary = "用户列表")
CommonResult<List<String>> getAllUserId(){
return CommonResult.success(yhxxbService.getAllUserId());
}
@GetMapping("/resetPassword")
@Operation(summary = "用户列表")
CommonResult<String> resetPassword(@RequestParam("yhUuid") String yhuuid){
return CommonResult.success(yhxxbService.resetPassword(yhuuid));
}
}

View File

@ -0,0 +1 @@
# 定时任务

View File

@ -0,0 +1,31 @@
package com.css.txw.mhzc.mapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.css.ggzc.framework.common.util.gy.GyUtils;
import com.css.txw.mhzc.pojo.domain.TxwMhzcGglbDO;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.css.txw.mhzc.pojo.vo.GglbReqVO;
import java.util.List;
/**
* @author AirlH
* @description 针对表txw_mhzc_gglb(广告栏表)的数据库操作Mapper
* @createDate 2025-10-20 10:24:42
* @Entity com.css.txw.gxzx.pojo.domain.TxwMhzcGglb
*/
public interface TxwMhzcGglbMapper extends BaseMapper<TxwMhzcGglbDO> {
default List<TxwMhzcGglbDO> getGgxxList(GglbReqVO reqVO){
QueryWrapper<TxwMhzcGglbDO> wrapper = new QueryWrapper<>();
wrapper.lambda()
.like(!GyUtils.isNull(reqVO.getGgNr()),TxwMhzcGglbDO::getGgNr,reqVO.getGgNr())
.like(!GyUtils.isNull(reqVO.getBt1()),TxwMhzcGglbDO::getBt1,reqVO.getBt1())
.eq(!GyUtils.isNull(reqVO.getYxbz()),TxwMhzcGglbDO::getYxbz,reqVO.getYxbz());
return selectList(wrapper);
}
}

View File

@ -0,0 +1,35 @@
package com.css.txw.mhzc.mapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.css.txw.mhzc.pojo.YhxxReqDTO;
import com.css.txw.mhzc.pojo.domain.TxwMhzcHtyhxxbDO;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
/**
* @author AirlH
* @description 针对表txw_mhzc_htyhxxb(后台用户信息表)的数据库操作Mapper
* @createDate 2025-09-09 09:41:02
* @Entity com.css.txw.mhzc.pojo.domain.TxwMhzcHtyhxxb
*/
public interface TxwMhzcHtyhxxbMapper extends BaseMapper<TxwMhzcHtyhxxbDO> {
default TxwMhzcHtyhxxbDO initHtSessionByDlzh(YhxxReqDTO reqDTO){
QueryWrapper<TxwMhzcHtyhxxbDO> wrapper = new QueryWrapper<>();
wrapper.lambda().eq(TxwMhzcHtyhxxbDO::getDlzh,reqDTO.getDlzh())
.eq(TxwMhzcHtyhxxbDO::getYxbz,"Y")
.eq(TxwMhzcHtyhxxbDO::getSdbz,"N");
return selectOne(wrapper);
}
default TxwMhzcHtyhxxbDO initHtSessionByYhuuid(YhxxReqDTO reqDTO){
QueryWrapper<TxwMhzcHtyhxxbDO> wrapper = new QueryWrapper<>();
wrapper.lambda().eq(TxwMhzcHtyhxxbDO::getYhUuid,reqDTO.getYhuuid())
.eq(TxwMhzcHtyhxxbDO::getYxbz,"Y")
.eq(TxwMhzcHtyhxxbDO::getSdbz,"N");
return selectOne(wrapper);
}
}

View File

@ -0,0 +1,41 @@
package com.css.txw.mhzc.mapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.css.ggzc.framework.common.util.gy.GyUtils;
import com.css.txw.mhzc.pojo.domain.TxwMhzcQyrzsqjlbDO;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.css.txw.mhzc.pojo.vo.GetRegisterListReqVO;
import java.util.List;
/**
* @author AirlH
* @description 针对表txw_mhzc_qyrzsqjlb(企业认证申请记录表)的数据库操作Mapper
* @createDate 2025-09-12 18:51:04
* @Entity com.css.txw.mhzc.pojo.domain.TxwMhzcQyrzsqjlb
*/
public interface TxwMhzcQyrzsqjlbMapper extends BaseMapper<TxwMhzcQyrzsqjlbDO> {
default List<TxwMhzcQyrzsqjlbDO> getRegisterList(GetRegisterListReqVO reqVO){
QueryWrapper<TxwMhzcQyrzsqjlbDO> wrapper = new QueryWrapper<>();
wrapper.lambda()
.eq(!GyUtils.isNull(reqVO.getShjg1()), TxwMhzcQyrzsqjlbDO::getShjg1, reqVO.getShjg1())
.like(!GyUtils.isNull(reqVO.getNsrsbh()),TxwMhzcQyrzsqjlbDO::getNsrsbh,reqVO.getNsrsbh())
.like(!GyUtils.isNull(reqVO.getQymc()),TxwMhzcQyrzsqjlbDO::getQymc,reqVO.getQymc())
// .isNull(TxwMhzcQyrzsqjlbDO::getShjg1)
.ge(!GyUtils.isNull(reqVO.getSqsjq()), TxwMhzcQyrzsqjlbDO::getLrrq, reqVO.getSqsjq())
.le(!GyUtils.isNull(reqVO.getSqsjz()), TxwMhzcQyrzsqjlbDO::getLrrq, reqVO.getSqsjz())
.orderByDesc(TxwMhzcQyrzsqjlbDO::getLrrq);
return selectList(wrapper);
}
default List<TxwMhzcQyrzsqjlbDO> getCurrentRegisterList(String yhUuid){
QueryWrapper<TxwMhzcQyrzsqjlbDO> wrapper = new QueryWrapper<>();
wrapper.lambda().eq(TxwMhzcQyrzsqjlbDO::getLrruuid,yhUuid);
return selectList(wrapper);
}
}

View File

@ -0,0 +1,41 @@
package com.css.txw.mhzc.mapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.css.txw.mhzc.pojo.domain.TxwMhzcQyxxbDO;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import java.util.List;
/**
* @author AirlH
* @description 针对表txw_mhzc_qyxxb(企业信息表)的数据库操作Mapper
* @createDate 2025-09-11 14:10:56
* @Entity com.css.txw.mhzc.pojo.domain.TxwMhzcQyxxb
*/
public interface TxwMhzcQyxxbMapper extends BaseMapper<TxwMhzcQyxxbDO> {
default List<TxwMhzcQyxxbDO> getByNsrsbh(String nsrsbh){
QueryWrapper<TxwMhzcQyxxbDO> wrapper = new QueryWrapper<>();
wrapper.lambda().eq(TxwMhzcQyxxbDO::getNsrsbh,nsrsbh);
return selectList(wrapper);
}
default List<TxwMhzcQyxxbDO> getGxQy(String ywlx){
QueryWrapper<TxwMhzcQyxxbDO> wrapper = new QueryWrapper<>();
wrapper.eq(ywlx,"Y").lambda()
.eq(TxwMhzcQyxxbDO::getYxbz,"Y");
return selectList(wrapper);
}
default void qyrz(String nsrsbh){
UpdateWrapper<TxwMhzcQyxxbDO> wrapper = new UpdateWrapper<>();
wrapper.lambda().eq(TxwMhzcQyxxbDO::getNsrsbh,nsrsbh)
.set(TxwMhzcQyxxbDO::getGxdtrzbz,"Y");
update(wrapper);
}
}

View File

@ -0,0 +1,26 @@
package com.css.txw.mhzc.mapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.css.txw.mhzc.pojo.domain.TxwMhzcYhqygxbDO;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import java.util.List;
/**
* @author AirlH
* @description 针对表txw_mhzc_yhqygxb(用户企业关系表)的数据库操作Mapper
* @createDate 2025-09-13 14:47:54
* @Entity com.css.txw.mhzc.pojo.domain.TxwMhzcYhqygxb
*/
public interface TxwMhzcYhqygxbMapper extends BaseMapper<TxwMhzcYhqygxbDO> {
default List<TxwMhzcYhqygxbDO> getByYhuuid(String yhuuid){
QueryWrapper<TxwMhzcYhqygxbDO> wrapper = new QueryWrapper<>();
wrapper.lambda().eq(TxwMhzcYhqygxbDO::getYhUuid,yhuuid);
return selectList(wrapper);
}
}

View File

@ -0,0 +1,95 @@
package com.css.txw.mhzc.mapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.css.ggzc.framework.common.util.gy.GyUtils;
import com.css.ggzc.framework.mybatis.core.mapper.BaseMapperX;
import com.css.txw.mhzc.pojo.domain.TxwMhzcYhxxbDO;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.css.txw.mhzc.pojo.vo.UserReqVO;
import java.util.Date;
import java.util.List;
/**
* @author AirlH
* @description 针对表txw_mhzc_yhxxb(用户信息表)的数据库操作Mapper
* @createDate 2025-09-08 17:08:12
* @Entity com.css.txw.mhzc.pojo.domain.TxwMhzcYhxxb
*/
public interface TxwMhzcYhxxbMapper extends BaseMapperX<TxwMhzcYhxxbDO> {
default TxwMhzcYhxxbDO getYhxxByYhuuid(String yhuuid){
QueryWrapper<TxwMhzcYhxxbDO> wrapper = new QueryWrapper<>();
wrapper.lambda().eq(TxwMhzcYhxxbDO::getYhUuid,yhuuid)
.eq(TxwMhzcYhxxbDO::getYxbz,"Y")
.eq(TxwMhzcYhxxbDO::getSdbz,"N");
return selectOne(wrapper);
}
default TxwMhzcYhxxbDO getYhxxByDlzh(String dlzh){
QueryWrapper<TxwMhzcYhxxbDO> wrapper = new QueryWrapper<>();
wrapper.lambda().eq(TxwMhzcYhxxbDO::getDlzh,dlzh)
.eq(TxwMhzcYhxxbDO::getYxbz,"Y")
.eq(TxwMhzcYhxxbDO::getSdbz,"N");
return selectOne(wrapper);
}
default TxwMhzcYhxxbDO getYhxxByDlzhNoYxbzNoSdbz(String dlzh){
QueryWrapper<TxwMhzcYhxxbDO> wrapper = new QueryWrapper<>();
wrapper.lambda().eq(TxwMhzcYhxxbDO::getDlzh,dlzh);
return selectOne(wrapper);
}
default Page<TxwMhzcYhxxbDO> getAllUser(UserReqVO reqVO){
Page<TxwMhzcYhxxbDO> page = new Page<>(reqVO.getPageNo(),reqVO.getPageSize());
QueryWrapper<TxwMhzcYhxxbDO> wrapper = new QueryWrapper<>();
wrapper.lambda().like(TxwMhzcYhxxbDO::getDlzh,reqVO.getDlzh())
.like(TxwMhzcYhxxbDO::getZsxm1,reqVO.getZsxm1())
.eq(GyUtils.isNotNull(reqVO.getSdbz()), TxwMhzcYhxxbDO::getSdbz, reqVO.getSdbz())
.eq(GyUtils.isNotNull(reqVO.getYxbz()), TxwMhzcYhxxbDO::getYxbz, reqVO.getYxbz())
.orderByDesc(TxwMhzcYhxxbDO::getLrrq);
return selectPage(page,wrapper);
}
default List<TxwMhzcYhxxbDO> getAllUserId(){
QueryWrapper<TxwMhzcYhxxbDO> wrapper = new QueryWrapper<>();
wrapper.lambda().select(TxwMhzcYhxxbDO::getYhUuid)
.eq(TxwMhzcYhxxbDO::getYxbz,"Y");
return selectList(wrapper);
}
default Integer unlock(String yhuuid, Date xgrq,String xgrsfid){
UpdateWrapper<TxwMhzcYhxxbDO> wrapper = new UpdateWrapper<>();
wrapper.lambda()
.set(TxwMhzcYhxxbDO::getSdbz,"N")
.set(TxwMhzcYhxxbDO::getSdyy,"")
.set(TxwMhzcYhxxbDO::getSdsj1,null)
.set(TxwMhzcYhxxbDO::getSdryid,"")
.set(TxwMhzcYhxxbDO::getXgrq,xgrq)
.set(TxwMhzcYhxxbDO::getXgrsfid, xgrsfid)
.eq(TxwMhzcYhxxbDO::getYhUuid, yhuuid);
return update(wrapper);
}
default TxwMhzcYhxxbDO getYhxxByDid(String did){
QueryWrapper<TxwMhzcYhxxbDO> wrapper = new QueryWrapper<>();
wrapper.lambda().eq(TxwMhzcYhxxbDO::getDid,did)
.eq(TxwMhzcYhxxbDO::getYxbz,"Y")
.eq(TxwMhzcYhxxbDO::getSdbz,"N");
return selectOne(wrapper);
}
default TxwMhzcYhxxbDO getYhxxBySfzjhm(String sfzjhm){
QueryWrapper<TxwMhzcYhxxbDO> wrapper = new QueryWrapper<>();
wrapper.lambda().eq(TxwMhzcYhxxbDO::getSfzjhm,sfzjhm)
.eq(TxwMhzcYhxxbDO::getYxbz,"Y")
.eq(TxwMhzcYhxxbDO::getSdbz,"N");
return selectOne(wrapper);
}
}

View File

@ -0,0 +1,26 @@
package com.css.txw.mhzc.mapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.css.txw.mhzc.pojo.domain.TxwMhzcZxxxbDO;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import java.util.List;
/**
* @author AirlH
* @description 针对表txw_mhzc_zxxxb(咨询信息表)的数据库操作Mapper
* @createDate 2025-09-18 16:39:32
* @Entity com.css.txw.mhzc.pojo.domain.TxwMhzcZxxxb
*/
public interface TxwMhzcZxxxbMapper extends BaseMapper<TxwMhzcZxxxbDO> {
default List<TxwMhzcZxxxbDO> getAll(){
QueryWrapper<TxwMhzcZxxxbDO> wrapper = new QueryWrapper<>();
wrapper.lambda().orderByDesc(TxwMhzcZxxxbDO::getFbsj);
return selectList(wrapper);
}
}

View File

@ -0,0 +1,86 @@
package com.css.txw.mhzc.pojo.domain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.util.Date;
import lombok.Data;
/**
* 广告栏表
* @TableName txw_mhzc_gglb
*/
@TableName(value ="txw_mhzc_gglb")
@Data
public class TxwMhzcGglbDO implements Serializable {
/**
* UUID||uuid
*/
@TableId(value = "uuid")
private String uuid;
/**
* 标题
*/
@TableField(value = "bt_1")
private String bt1;
/**
* 广告内容||广告内容
*/
@TableField(value = "gg_nr")
private String ggNr;
/**
* 图片id||图片id
*/
@TableField(value = "tpid")
private String tpid;
/**
* 跳转地址
*/
@TableField(value = "tzdz")
private String tzdz;
/**
* 序号
*/
@TableField(value = "xh")
private Long xh;
/**
* 录入日期
*/
@TableField(value = "lrrq")
private Date lrrq;
/**
* 修改日期
*/
@TableField(value = "xgrq")
private Date xgrq;
/**
* 录入人UUID
*/
@TableField(value = "lrruuid")
private String lrruuid;
/**
* 修改人UUID
*/
@TableField(value = "xgruuid")
private String xgruuid;
/**
* 有效标志
*/
@TableField(value = "yxbz")
private String yxbz;
@TableField(exist = false)
private static final long serialVersionUID = 1L;
}

View File

@ -0,0 +1,140 @@
package com.css.txw.mhzc.pojo.domain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.time.LocalDateTime;
import lombok.Data;
/**
* 后台用户信息表
* @TableName txw_mhzc_htyhxxb
*/
@TableName(value ="txw_mhzc_htyhxxb")
@Data
public class TxwMhzcHtyhxxbDO implements Serializable {
/**
* 用户UUID
*/
@TableId(value = "yh_uuid")
private String yhUuid;
/**
* 登录账号
*/
@TableField(value = "dlzh")
private String dlzh;
/**
* 登录密码||登录密码
*/
@TableField(value = "dlmm")
private String dlmm;
/**
* 真实姓名||真实姓名
*/
@TableField(value = "zsxm_1")
private String zsxm1;
/**
* 手机号码||手机号码
*/
@TableField(value = "sjhm_1")
private String sjhm1;
/**
* 邮箱地址||邮箱地址
*/
@TableField(value = "yxdz")
private String yxdz;
/**
* 头像地址url||头像地址url
*/
@TableField(value = "txdzurl")
private String txdzurl;
/**
* 锁定标志||Y为锁定N或空不锁定
*/
@TableField(value = "sdbz")
private String sdbz;
/**
* 锁定原因
*/
@TableField(value = "sdyy")
private String sdyy;
/**
* 锁定时间||锁定时间
*/
@TableField(value = "sdsj_1")
private LocalDateTime sdsj1;
/**
* 锁定人员ID||锁定人员ID
*/
@TableField(value = "sdryid")
private String sdryid;
/**
* 业务渠道代码
*/
@TableField(value = "ywqd_dm")
private String ywqdDm;
/**
* 录入日期
*/
@TableField(value = "lrrq")
private LocalDateTime lrrq;
/**
* 修改日期
*/
@TableField(value = "xgrq")
private LocalDateTime xgrq;
/**
* 数据产生地区
*/
@TableField(value = "sjcsdq")
private String sjcsdq;
/**
* 数据归属地区
*/
@TableField(value = "sjgsdq")
private String sjgsdq;
/**
* 修改人身份id
*/
@TableField(value = "xgrsfid")
private String xgrsfid;
/**
* 录入人身份id
*/
@TableField(value = "lrrsfid")
private String lrrsfid;
/**
* 数据同步时间
*/
@TableField(value = "sjtb_sj")
private LocalDateTime sjtbSj;
/**
* 有效标志
*/
@TableField(value = "yxbz")
private String yxbz;
@TableField(exist = false)
private static final long serialVersionUID = 1L;
}

View File

@ -0,0 +1,104 @@
package com.css.txw.mhzc.pojo.domain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.time.LocalDateTime;
import java.util.Date;
import lombok.Data;
/**
* 企业认证申请记录表
* @TableName txw_mhzc_qyrzsqjlb
*/
@TableName(value ="txw_mhzc_qyrzsqjlb")
@Data
public class TxwMhzcQyrzsqjlbDO implements Serializable {
/**
* UUID||uuid
*/
@TableId(value = "uuid")
private String uuid;
/**
* 企业名称
*/
@TableField(value = "qymc")
private String qymc;
/**
* 纳税人识别号
*/
@TableField(value = "nsrsbh")
private String nsrsbh;
/**
* 申请说明||申请说明
*/
@TableField(value = "sqsm")
private String sqsm;
/**
* 录入人UUID
*/
@TableField(value = "lrruuid")
private String lrruuid;
/**
* 录入日期
*/
@TableField(value = "lrrq")
private Date lrrq;
/**
* 审核人
*/
@TableField(value = "shrsfid")
private String shrsfid;
/**
* 审核结果
*/
@TableField(value = "shjg_1")
private String shjg1;
/**
* 审核意见
*/
@TableField(value = "shyj_1")
private String shyj1;
/**
* 审核时间
*/
@TableField(value = "shsj")
private Date shsj;
/**
* 手机号码
*/
@TableField(value = "sjhm_1")
private String sjhm1;
@TableField(exist = false)
private static final long serialVersionUID = 1L;
/**
* 登录账号
*/
@TableField(value = "dlzh")
private String dlzh;
/**
* 真实姓名||真实姓名
*/
@TableField(value = "zsxm_1")
private String zsxm1;
/**
* 用户UUID
*/
@TableField(value = "yh_uuid")
private String yhUuid;
}

View File

@ -0,0 +1,97 @@
package com.css.txw.mhzc.pojo.domain;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.util.Date;
import lombok.Data;
/**
* 企业信息表
* @TableName txw_mhzc_qyxxb
*/
@TableName(value ="txw_mhzc_qyxxb")
@Data
public class TxwMhzcQyxxbDO implements Serializable {
/**
* 企业uuid
*/
@TableId(value = "qyuuid")
private String qyuuid;
/**
* 企业名称
*/
@TableField(value = "qymc")
private String qymc;
/**
* 纳税人识别号
*/
@TableField(value = "nsrsbh")
private String nsrsbh;
/**
* 供需大厅入驻标志||供需大厅入驻标志
*/
@TableField(value = "gxdtrzbz")
private String gxdtrzbz;
/**
* 有效标志||有效标志
*/
@TableField(value = "yxbz")
private String yxbz;
/**
* 业务渠道代码||业务渠道代码
*/
@TableField(value = "ywqd_dm")
private String ywqdDm;
/**
* 录入日期
*/
@TableField(value = "lrrq")
private Date lrrq;
/**
* 修改日期
*/
@TableField(value = "xgrq")
private Date xgrq;
/**
* 数据产生地区
*/
@TableField(value = "sjcsdq")
private String sjcsdq;
/**
* 数据归属地区
*/
@TableField(value = "sjgsdq")
private String sjgsdq;
/**
* 修改人身份id
*/
@TableField(value = "xgrsfid")
private String xgrsfid;
/**
* 录入人身份id
*/
@TableField(value = "lrrsfid")
private String lrrsfid;
/**
* 数据同步时间
*/
@TableField(value = "sjtb_sj")
private Date sjtbSj;
@TableField(exist = false)
private static final long serialVersionUID = 1L;
}

View File

@ -0,0 +1,37 @@
package com.css.txw.mhzc.pojo.domain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import lombok.Data;
/**
* 用户企业关系表
* @TableName txw_mhzc_yhqygxb
*/
@TableName(value ="txw_mhzc_yhqygxb")
@Data
public class TxwMhzcYhqygxbDO implements Serializable {
/**
* UUID||uuid
*/
@TableId(value = "uuid")
private String uuid;
/**
* 用户UUID
*/
@TableField(value = "yh_uuid")
private String yhUuid;
/**
* 企业uuid
*/
@TableField(value = "qyuuid")
private String qyuuid;
@TableField(exist = false)
private static final long serialVersionUID = 1L;
}

View File

@ -0,0 +1,163 @@
package com.css.txw.mhzc.pojo.domain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.time.LocalDateTime;
import java.util.Date;
import lombok.Data;
/**
* 用户信息表
* @TableName txw_mhzc_yhxxb
*/
@TableName(value ="txw_mhzc_yhxxb")
@Data
public class TxwMhzcYhxxbDO implements Serializable {
/**
* 用户UUID
*/
@TableId(value = "yh_uuid")
private String yhUuid;
@TableField(value = "did")
private String did;
/**
* 登录账号
*/
@TableField(value = "dlzh")
private String dlzh;
/**
* 登录密码||登录密码
*/
@TableField(value = "dlmm")
private String dlmm;
/**
* 真实姓名||真实姓名
*/
@TableField(value = "zsxm_1")
private String zsxm1;
/**
* 手机号码||手机号码
*/
@TableField(value = "sjhm_1")
private String sjhm1;
/**
* 邮箱地址||邮箱地址
*/
@TableField(value = "yxdz")
private String yxdz;
/**
* 头像地址url||头像地址url
*/
@TableField(value = "txdzurl")
private String txdzurl;
/**
* 锁定标志||Y为锁定N或空不锁定
*/
@TableField(value = "sdbz")
private String sdbz;
/**
* 锁定原因
*/
@TableField(value = "sdyy")
private String sdyy;
/**
* 锁定时间||锁定时间
*/
@TableField(value = "sdsj_1")
private Date sdsj1;
/**
* 锁定人员ID||锁定人员ID
*/
@TableField(value = "sdryid")
private String sdryid;
/**
* 有效标志
*/
@TableField(value = "yxbz")
private String yxbz;
/**
* 业务渠道代码
*/
@TableField(value = "ywqd_dm")
private String ywqdDm;
/**
* 录入日期
*/
@TableField(value = "lrrq")
private Date lrrq;
/**
* 修改日期
*/
@TableField(value = "xgrq")
private Date xgrq;
/**
* 数据产生地区
*/
@TableField(value = "sjcsdq")
private String sjcsdq;
/**
* 数据归属地区
*/
@TableField(value = "sjgsdq")
private String sjgsdq;
/**
* 修改人身份id
*/
@TableField(value = "xgrsfid")
private String xgrsfid;
/**
* 录入人身份id
*/
@TableField(value = "lrrsfid")
private String lrrsfid;
/**
* 数据同步时间
*/
@TableField(value = "sjtb_sj")
private Date sjtbSj;
/**
* 身份证件类型
*/
@TableField(value = "sfzjlx")
private String sfzjlx;
/**
* 身份证件号码
*/
@TableField(value = "sfzjhm")
private String sfzjhm;
/**
* 上次登录机构UUID||上次登录机构UUID
*/
@TableField(value = "scdljguuid")
private String scdljguuid;
@TableField(exist = false)
private static final long serialVersionUID = 1L;
}

View File

@ -0,0 +1,50 @@
package com.css.txw.mhzc.pojo.domain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.time.LocalDateTime;
import lombok.Data;
/**
* 咨询信息表
* @TableName txw_mhzc_zxxxb
*/
@TableName(value ="txw_mhzc_zxxxb")
@Data
public class TxwMhzcZxxxbDO implements Serializable {
/**
* UUID||uuid
*/
@TableId(value = "uuid")
private String uuid;
/**
* 标题
*/
@TableField(value = "bt_1")
private String bt1;
/**
* 内容
*/
@TableField(value = "zx_nr")
private String zxNr;
/**
* 发布时间
*/
@TableField(value = "fbsj")
private LocalDateTime fbsj;
/**
* 资源分类
*/
@TableField(value = "zx_lx")
private String zxLx;
@TableField(exist = false)
private static final long serialVersionUID = 1L;
}

View File

@ -0,0 +1,16 @@
package com.css.txw.mhzc.pojo.vo;
import lombok.Data;
import java.io.Serializable;
@Data
public class CompanySpReqVO implements Serializable {
private String uuid;
private String shjg1;
private String shyj1;
}

View File

@ -0,0 +1,23 @@
package com.css.txw.mhzc.pojo.vo;
import com.baomidou.mybatisplus.annotation.TableField;
import lombok.Data;
import java.io.Serializable;
@Data
public class CompanyVO implements Serializable {
private String qyuuid;
/**
* 企业名称
*/
private String qymc;
/**
* 纳税人识别号
*/
private String nsrsbh;
}

View File

@ -0,0 +1,17 @@
package com.css.txw.mhzc.pojo.vo;
import lombok.Data;
import java.io.Serializable;
@Data
public class GetRegisterListReqVO implements Serializable {
private String nsrsbh;
private String qymc;
// 查询条件增加审核状态申请时间范围
private String shjg1;
private String sqsjq;
private String sqsjz;
}

View File

@ -0,0 +1,69 @@
package com.css.txw.mhzc.pojo.vo;
import lombok.Data;
import java.io.Serializable;
import java.util.Date;
/**
* 广告栏表
* @TableName txw_mhzc_gglb
*/
@Data
public class GglbReqVO implements Serializable {
/**
* UUID||uuid
*/
private String uuid;
/**
* 标题
*/
private String bt1;
/**
* 广告内容||广告内容
*/
private String ggNr;
/**
* 图片id||图片id
*/
private String tpid;
/**
* 跳转地址
*/
private String tzdz;
/**
* 序号
*/
private Long xh;
/**
* 录入日期
*/
private Date lrrq;
/**
* 修改日期
*/
private Date xgrq;
/**
* 录入人UUID
*/
private String lrruuid;
/**
* 修改人UUID
*/
private String xgruuid;
/**
* 有效标志
*/
private String yxbz;
}

View File

@ -0,0 +1,75 @@
package com.css.txw.mhzc.pojo.vo;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;
import java.io.Serializable;
import java.util.Date;
/**
* 广告栏表
* @TableName txw_mhzc_gglb
*/
@Data
public class GglbVO implements Serializable {
/**
* UUID||uuid
*/
private String uuid;
/**
* 标题
*/
private String bt1;
/**
* 广告内容||广告内容
*/
private String ggNr;
/**
* 图片id||图片id
*/
private String tpid;
/**
* 跳转地址
*/
private String tzdz;
/**
* 序号
*/
private Long xh;
/**
* 录入日期
*/
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
private Date lrrq;
/**
* 修改日期
*/
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
private Date xgrq;
/**
* 录入人UUID
*/
private String lrruuid;
/**
* 修改人UUID
*/
private String xgruuid;
/**
* 有效标志
*/
private String yxbz;
}

View File

@ -0,0 +1,18 @@
package com.css.txw.mhzc.pojo.vo;
import lombok.Data;
import java.io.Serializable;
@Data
public class RegisterCompanyReqVO implements Serializable {
private String sjhm1;
private String nsrsbh;
private String qymc;
private String sqsm;
}

View File

@ -0,0 +1,37 @@
package com.css.txw.mhzc.pojo.vo;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
import java.io.Serializable;
import java.util.Date;
@Data
public class RegisterCompanySqVO implements Serializable {
private String uuid;
private String sjhm1;
private String nsrsbh;
private String qymc;
private String sqsm;
private String lrruuid;
private String shjg1;
@Schema(description = "登陆账号")
private String dlzh;
@Schema(description = "真实姓名")
private String zsxm1;
@Schema(description = "用户uuid")
private String yhUuid;
@JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8")
private Date lrrq;
}

View File

@ -0,0 +1,39 @@
package com.css.txw.mhzc.pojo.vo;
import lombok.Data;
import java.io.Serializable;
import java.util.Date;
@Data
public class SessionVO implements Serializable {
private String yhUuid;
private String sjhm1;
private String dlzh;
private String zsxm1;
private String yxdz;
private String sfzjlx;
private String sfzjhm;
private String txdzurl;
private String yxbz;
private String yhlx;
private String nsrsbh;
private String qymc;
private String qyuuid;
private String gxdtRzbz;
}

View File

@ -0,0 +1,18 @@
package com.css.txw.mhzc.pojo.vo;
import lombok.Data;
import java.io.Serializable;
@Data
public class SyzxxxVO implements Serializable {
private String bt1;
private String fbsj;
private String zxNr;
private String zxLx;
}

View File

@ -0,0 +1,14 @@
package com.css.txw.mhzc.pojo.vo;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
@Data
public class UserLockVO {
@Schema(description = "用户UUID")
private String yhuuid;
@Schema(description = "锁定原因")
private String sdyy;
}

View File

@ -0,0 +1,19 @@
package com.css.txw.mhzc.pojo.vo;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
@Schema(description = "用户注册")
@Data
public class UserRegisterReqVO {
@Schema(description = "用户名")
private String dlzh;
@Schema(description = "密码")
private String password;
@Schema(description = "真实姓名")
private String zsxm1;
@Schema(description = "验证码")
private String sms;
}

View File

@ -0,0 +1,18 @@
package com.css.txw.mhzc.pojo.vo;
import com.css.ggzc.framework.common.pojo.PageParam;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
@Schema(description = "用户信息")
@Data
public class UserReqVO extends PageParam {
@Schema(description = "登陆账号")
private String dlzh;
@Schema(description = "真实姓名")
private String zsxm1;
private String yxbz;
private String sdbz;
}

View File

@ -0,0 +1,29 @@
package com.css.txw.mhzc.pojo.vo;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
import java.util.Date;
@Schema(description = "用户信息")
@Data
public class UserVO {
@Schema(description = "登陆账号")
private String dlzh;
@Schema(description = "真实姓名")
private String zsxm1;
@Schema(description = "用户uuid")
private String yhUuid;
@Schema(description = "手机号码")
private String sjhm1;
@Schema(description = "手机号码")
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
private Date lrrq;
@Schema(description = "手机号码")
private String yxbz;
@Schema(description = "手机号码")
private String sdbz;
}

View File

@ -0,0 +1,30 @@
package com.css.txw.mhzc.properties;
import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.context.annotation.Configuration;
/**
*
* @project qyd-txw
* @package com.css.txw.sso.properties
* @file SsoProperties.java 创建时间:2025/11/25 20:19
* @title 标题要求能简洁地表达出类的功能和职责
* @description 描述简要描述类的职责实现方式使用注意事项等
* @copyright Copyright (c) 2025 中国软件与技术服务股份有限公司
* @company 中国软件与技术服务股份有限公司
* @module 模块: 智能申报
* @author 商健
* @reviewer 审核人
* @version 1.0.0
* @history 修订历史历次修订内容修订人修订时间等
*
*/
@Configuration
@RefreshScope
@ConfigurationProperties(prefix = "css.mhzc")
@Data
public class MhzcProperties {
private boolean registerSmsCheck = true;
}

View File

@ -0,0 +1,22 @@
package com.css.txw.mhzc.service;
import com.css.txw.mhzc.pojo.domain.TxwMhzcGglbDO;
import com.baomidou.mybatisplus.extension.service.IService;
import com.css.txw.mhzc.pojo.vo.GglbReqVO;
import com.css.txw.mhzc.pojo.vo.GglbVO;
import java.util.List;
/**
* @author AirlH
* @description 针对表txw_mhzc_gglb(广告栏表)的数据库操作Service
* @createDate 2025-10-20 10:24:42
*/
public interface TxwMhzcGglbService extends IService<TxwMhzcGglbDO> {
String saveGgxx(GglbVO gglbVO);
List<GglbVO> getGgxxList(GglbReqVO reqVO);
String delGgxx(String uuid);
}

View File

@ -0,0 +1,19 @@
package com.css.txw.mhzc.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.css.txw.mhzc.pojo.HtYhxxbDTO;
import com.css.txw.mhzc.pojo.YhxxReqDTO;
import com.css.txw.mhzc.pojo.domain.TxwMhzcHtyhxxbDO;
/**
* @author AirlH
* @description 针对表txw_mhzc_htyhxxb(后台用户信息表)的数据库操作Service
* @createDate 2025-09-09 09:41:02
*/
public interface TxwMhzcHtyhxxbService extends IService<TxwMhzcHtyhxxbDO> {
HtYhxxbDTO initHtSessionByDlzh(YhxxReqDTO reqDTO);
HtYhxxbDTO initHtSessionByYhuuid(YhxxReqDTO reqDTO);
}

View File

@ -0,0 +1,23 @@
package com.css.txw.mhzc.service;
import com.css.txw.mhzc.pojo.QyrzReqDTO;
import com.css.txw.mhzc.pojo.domain.TxwMhzcQyrzsqjlbDO;
import com.baomidou.mybatisplus.extension.service.IService;
import com.css.txw.mhzc.pojo.vo.GetRegisterListReqVO;
import com.css.txw.mhzc.pojo.vo.RegisterCompanySqVO;
import java.util.List;
/**
* @author AirlH
* @description 针对表txw_mhzc_qyrzsqjlb(企业认证申请记录表)的数据库操作Service
* @createDate 2025-09-12 14:27:18
*/
public interface TxwMhzcQyrzsqjlbService extends IService<TxwMhzcQyrzsqjlbDO> {
List<RegisterCompanySqVO> getRegisterList(GetRegisterListReqVO reqVO);
List<RegisterCompanySqVO> getCurrentRegisterList();
String revokeSq(String uuid);
}

View File

@ -0,0 +1,30 @@
package com.css.txw.mhzc.service;
import com.css.txw.mhzc.pojo.QyrzReqDTO;
import com.css.txw.mhzc.pojo.YhxxbDTO;
import com.css.txw.mhzc.pojo.vo.CompanySpReqVO;
import com.css.txw.mhzc.pojo.vo.CompanyVO;
import com.css.txw.mhzc.pojo.vo.RegisterCompanyReqVO;
import com.css.txw.mhzc.pojo.domain.TxwMhzcQyxxbDO;
import com.baomidou.mybatisplus.extension.service.IService;
import java.util.List;
/**
* @author AirlH
* @description 针对表txw_mhzc_qyxxb(企业信息表)的数据库操作Service
* @createDate 2025-09-11 14:10:56
*/
public interface TxwMhzcQyxxbService extends IService<TxwMhzcQyxxbDO> {
String register(RegisterCompanyReqVO reqDTO);
String qyRzSp(CompanySpReqVO reqVO);
String qyrz(QyrzReqDTO reqDTO);
List<CompanyVO> getQyxxListByYwlx(String ywlx);
YhxxbDTO intQyxxByDid(YhxxbDTO qyxx);
}

View File

@ -0,0 +1,19 @@
package com.css.txw.mhzc.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.css.txw.mhzc.pojo.domain.TxwMhzcZxxxbDO;
import com.css.txw.mhzc.pojo.vo.SyzxxxVO;
import java.util.List;
import java.util.Map;
/**
* @author AirlH
* @description 针对表txw_mhzc_zxxxb(咨询信息表)的数据库操作Service
* @createDate 2025-09-18 16:39:32
*/
public interface TxwMhzcSyxxbService extends IService<TxwMhzcZxxxbDO> {
Map<String, Object> getCdxx();
}

View File

@ -0,0 +1,18 @@
package com.css.txw.mhzc.service;
import com.css.txw.mhzc.pojo.domain.TxwMhzcYhqygxbDO;
import java.util.List;
import com.baomidou.mybatisplus.extension.service.IService;
/**
* @author AirlH
* @description 针对表txw_mhzc_yhqygxb(用户企业关系表)的数据库操作Service
* @createDate 2025-09-13 14:47:54
*/
public interface TxwMhzcYhqygxbService extends IService<TxwMhzcYhqygxbDO> {
List<TxwMhzcYhqygxbDO> query(String qyuuid, String yhUuid);
}

View File

@ -0,0 +1,45 @@
package com.css.txw.mhzc.service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService;
import com.css.txw.mhzc.pojo.HtYhxxbDTO;
import com.css.txw.mhzc.pojo.YhxxReqDTO;
import com.css.txw.mhzc.pojo.YhxxbDTO;
import com.css.txw.mhzc.pojo.domain.TxwMhzcYhxxbDO;
import com.css.txw.mhzc.pojo.vo.*;
import java.util.List;
/**
* @author AirlH
* @description 针对表txw_mhzc_yhxxb(用户信息表)的数据库操作Service
* @createDate 2025-09-08 17:08:12
*/
public interface TxwMhzcYhxxbService extends IService<TxwMhzcYhxxbDO> {
YhxxbDTO initSessionByYhuuid(YhxxReqDTO reqDTO);
YhxxbDTO initSessionByDlzh(YhxxReqDTO reqDTO);
String register(UserRegisterReqVO reqVO);
SessionVO init();
Page<UserVO> getAllUser(UserReqVO reqVO);
String resetPassword(String yhuuid);
List<String> getAllUserId();
Integer lockUser(UserLockVO infoVO);
Integer unlockUser(UserLockVO infoVO);
YhxxbDTO initSessionByDid(YhxxReqDTO reqDTO);
YhxxbDTO initSessionBySfzjhm(YhxxReqDTO reqDTO);
YhxxbDTO saveYhxxByDid(YhxxbDTO yhxx);
YhxxbDTO updateDid(YhxxbDTO yhxx);
}

View File

@ -0,0 +1,19 @@
package com.css.txw.mhzc.service;
import com.css.txw.mhzc.pojo.domain.TxwMhzcZxxxbDO;
import com.baomidou.mybatisplus.extension.service.IService;
import com.css.txw.mhzc.pojo.vo.SyzxxxVO;
import java.util.List;
import java.util.Map;
/**
* @author AirlH
* @description 针对表txw_mhzc_zxxxb(咨询信息表)的数据库操作Service
* @createDate 2025-09-18 16:39:32
*/
public interface TxwMhzcZxxxbService extends IService<TxwMhzcZxxxbDO> {
Map<String, List<SyzxxxVO>> zxxx();
}

View File

@ -0,0 +1,72 @@
package com.css.txw.mhzc.service.impl;
import cn.hutool.core.util.IdUtil;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.css.ggzc.framework.common.util.gy.GyUtils;
import com.css.ggzc.framework.common.util.object.BeanUtils;
import com.css.ggzc.framework.file.utils.GgzcFileUtils;
import com.css.ggzc.framework.session.SessionUtils;
import com.css.txw.mhzc.pojo.domain.TxwMhzcGglbDO;
import com.css.txw.mhzc.mapper.TxwMhzcGglbMapper;
import com.css.txw.mhzc.pojo.vo.GglbReqVO;
import com.css.txw.mhzc.pojo.vo.GglbVO;
import com.css.txw.mhzc.service.TxwMhzcGglbService;
import com.css.txw.mhzc.service.TxwMhzcGglbService;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.Date;
import java.util.List;
/**
* @author AirlH
* @description 针对表txw_mhzc_gglb(广告栏表)的数据库操作Service实现
* @createDate 2025-10-20 10:24:42
*/
@Service
public class TxwMhzcGglbServiceImpl extends ServiceImpl<TxwMhzcGglbMapper, TxwMhzcGglbDO>
implements TxwMhzcGglbService {
@Resource
private TxwMhzcGglbMapper gglbMapper;
@Override
public String saveGgxx(GglbVO gglbVO) {
TxwMhzcGglbDO txwMhzcGglbDO = BeanUtils.toBean(gglbVO, TxwMhzcGglbDO.class);
if (GyUtils.isNull(gglbVO.getUuid())){
txwMhzcGglbDO.setYxbz("Y");
txwMhzcGglbDO.setLrrq(new Date());
txwMhzcGglbDO.setUuid(IdUtil.fastSimpleUUID());
txwMhzcGglbDO.setLrruuid(SessionUtils.getYhUuid());
this.save(txwMhzcGglbDO);
}else {
txwMhzcGglbDO.setXgrq(new Date());
txwMhzcGglbDO.setXgruuid(SessionUtils.getYhUuid());
this.updateById(txwMhzcGglbDO);
}
return "success";
}
@Override
public List<GglbVO> getGgxxList(GglbReqVO reqVO) {
List<TxwMhzcGglbDO> ggxxList = gglbMapper.getGgxxList(reqVO);
if (GyUtils.isNull(ggxxList)) return null;
return BeanUtils.toBean(ggxxList,GglbVO.class);
}
@Override
public String delGgxx(String uuid) {
TxwMhzcGglbDO gglbDO = this.getById(uuid);
if (!GyUtils.isNull(gglbDO)){//删除图片
String tpid = gglbDO.getTpid();
GgzcFileUtils.delete(tpid);
}
this.removeById(uuid);
return "success";
}
}

View File

@ -0,0 +1,44 @@
package com.css.txw.mhzc.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.css.ggzc.framework.common.util.gy.GyUtils;
import com.css.ggzc.framework.common.util.object.BeanUtils;
import com.css.txw.mhzc.pojo.HtYhxxbDTO;
import com.css.txw.mhzc.pojo.YhxxReqDTO;
import com.css.txw.mhzc.service.TxwMhzcHtyhxxbService;
import com.css.txw.mhzc.pojo.domain.TxwMhzcHtyhxxbDO;
import com.css.txw.mhzc.mapper.TxwMhzcHtyhxxbMapper;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
/**
* @author AirlH
* @description 针对表txw_mhzc_htyhxxb(后台用户信息表)的数据库操作Service实现
* @createDate 2025-09-09 09:41:02
*/
@Service
public class TxwMhzcHtyhxxbServiceImpl extends ServiceImpl<TxwMhzcHtyhxxbMapper, TxwMhzcHtyhxxbDO>
implements TxwMhzcHtyhxxbService {
@Resource
private TxwMhzcHtyhxxbMapper htyhxxbMapper;
@Override
public HtYhxxbDTO initHtSessionByDlzh(YhxxReqDTO reqDTO) {
TxwMhzcHtyhxxbDO txwMhzcHtyhxxbDO = htyhxxbMapper.initHtSessionByDlzh(reqDTO);
if (GyUtils.isNull(txwMhzcHtyhxxbDO)) return null;
return BeanUtils.toBean(txwMhzcHtyhxxbDO,HtYhxxbDTO.class);
}
@Override
public HtYhxxbDTO initHtSessionByYhuuid(YhxxReqDTO reqDTO) {
TxwMhzcHtyhxxbDO txwMhzcHtyhxxbDO = htyhxxbMapper.initHtSessionByYhuuid(reqDTO);
if (GyUtils.isNull(txwMhzcHtyhxxbDO)) return null;
return BeanUtils.toBean(txwMhzcHtyhxxbDO,HtYhxxbDTO.class);
}
}

View File

@ -0,0 +1,57 @@
package com.css.txw.mhzc.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.css.ggzc.framework.common.util.gy.GyUtils;
import com.css.ggzc.framework.common.util.object.BeanUtils;
import com.css.ggzc.framework.session.SessionUtils;
import com.css.txw.mhzc.mapper.TxwMhzcQyrzsqjlbMapper;
import com.css.txw.mhzc.pojo.domain.TxwMhzcQyrzsqjlbDO;
import com.css.txw.mhzc.pojo.vo.GetRegisterListReqVO;
import com.css.txw.mhzc.pojo.vo.RegisterCompanySqVO;
import com.css.txw.mhzc.service.TxwMhzcQyrzsqjlbService;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.Date;
import java.util.List;
/**
* @author AirlH
* @description 针对表txw_mhzc_qyrzsqjlb(企业认证申请记录表)的数据库操作Service实现
* @createDate 2025-09-12 14:27:18
*/
@Service
public class TxwMhzcQyrzsqjlbServiceImpl extends ServiceImpl<TxwMhzcQyrzsqjlbMapper, TxwMhzcQyrzsqjlbDO>
implements TxwMhzcQyrzsqjlbService {
@Resource
private TxwMhzcQyrzsqjlbMapper qyrzsqjlbMapper;
@Override
public List<RegisterCompanySqVO> getRegisterList(GetRegisterListReqVO reqVO) {
List<TxwMhzcQyrzsqjlbDO> registerList = qyrzsqjlbMapper.getRegisterList(reqVO);
if (GyUtils.isNull(registerList)) return null;
return BeanUtils.toBean(registerList,RegisterCompanySqVO.class);
}
@Override
public List<RegisterCompanySqVO> getCurrentRegisterList() {
List<TxwMhzcQyrzsqjlbDO> registerList = qyrzsqjlbMapper.getCurrentRegisterList(SessionUtils.getYhUuid());
if (GyUtils.isNull(registerList)) return null;
return BeanUtils.toBean(registerList,RegisterCompanySqVO.class);
}
@Override
public String revokeSq(String uuid) {
TxwMhzcQyrzsqjlbDO qyrzsqjlbDO = new TxwMhzcQyrzsqjlbDO();
qyrzsqjlbDO.setUuid(uuid);
qyrzsqjlbDO.setShjg1("5");
qyrzsqjlbDO.setShsj(new Date());
updateById(qyrzsqjlbDO);
return "success";
}
}

View File

@ -0,0 +1,248 @@
package com.css.txw.mhzc.service.impl;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import javax.annotation.Resource;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.css.ggzc.framework.common.util.gy.GyUtils;
import com.css.ggzc.framework.common.util.object.BeanUtils;
import com.css.ggzc.framework.session.SessionUtils;
import com.css.ggzc.framework.xxzx.api.XxzxApi;
import com.css.ggzc.framework.xxzx.pojo.XxReqVO;
import com.css.txw.mhzc.mapper.TxwMhzcQyrzsqjlbMapper;
import com.css.txw.mhzc.mapper.TxwMhzcQyxxbMapper;
import com.css.txw.mhzc.pojo.QyrzReqDTO;
import com.css.txw.mhzc.pojo.YhxxbDTO;
import com.css.txw.mhzc.pojo.domain.TxwMhzcQyrzsqjlbDO;
import com.css.txw.mhzc.pojo.domain.TxwMhzcQyxxbDO;
import com.css.txw.mhzc.pojo.domain.TxwMhzcYhqygxbDO;
import com.css.txw.mhzc.pojo.vo.CompanySpReqVO;
import com.css.txw.mhzc.pojo.vo.CompanyVO;
import com.css.txw.mhzc.pojo.vo.RegisterCompanyReqVO;
import com.css.txw.mhzc.service.TxwMhzcQyrzsqjlbService;
import com.css.txw.mhzc.service.TxwMhzcQyxxbService;
import com.css.txw.mhzc.service.TxwMhzcYhqygxbService;
import com.css.txw.sso.api.yhxx.SwitchSessionApi;
import com.css.txw.sso.pojo.yhxx.SwitchCompanyResDTO;
import cn.hutool.core.util.IdUtil;
import lombok.extern.slf4j.Slf4j;
/**
* @author AirlH
* @description 针对表txw_mhzc_qyxxb(企业信息表)的数据库操作Service实现
* @createDate 2025-09-11 14:10:56
*/
@Service
@Slf4j
public class TxwMhzcQyxxbServiceImpl extends ServiceImpl<TxwMhzcQyxxbMapper, TxwMhzcQyxxbDO>
implements TxwMhzcQyxxbService {
@Resource
private TxwMhzcQyxxbMapper qyxxbMapper;
@Resource
private TxwMhzcQyrzsqjlbService qyrzsqjlbService;
@Resource
private TxwMhzcQyrzsqjlbMapper qyrzsqjlbMapper;
@Resource
private TxwMhzcYhqygxbService yhqygxbService;
@Resource
private SwitchSessionApi switchSessionApi;
@Resource
private XxzxApi xxzxApi;
@Override
public String register(RegisterCompanyReqVO reqDTO) {
List<TxwMhzcQyxxbDO> byNsrsbh = qyxxbMapper.getByNsrsbh(reqDTO.getNsrsbh());
if (!GyUtils.isNull(byNsrsbh) || byNsrsbh.size() > 0)
throw new IllegalStateException("企业已认证");
TxwMhzcQyrzsqjlbDO qyrzsqjlbDO = new TxwMhzcQyrzsqjlbDO();
qyrzsqjlbDO.setUuid(IdUtil.fastSimpleUUID());
qyrzsqjlbDO.setQymc(reqDTO.getQymc());
qyrzsqjlbDO.setNsrsbh(reqDTO.getNsrsbh());
qyrzsqjlbDO.setLrrq(new Date());
qyrzsqjlbDO.setLrruuid(SessionUtils.getYhUuid());
qyrzsqjlbDO.setSjhm1(SessionUtils.getSjhm());
qyrzsqjlbDO.setSqsm(reqDTO.getSqsm());
qyrzsqjlbDO.setYhUuid(SessionUtils.getYhUuid());
qyrzsqjlbDO.setDlzh(SessionUtils.getDlzh());
qyrzsqjlbDO.setZsxm1(SessionUtils.getZsxm());
qyrzsqjlbMapper.insert(qyrzsqjlbDO);
return "success";
}
@Transactional
@Override
public String qyRzSp(CompanySpReqVO reqVO) {
LocalDateTime now = LocalDateTime.now();
// 定义格式
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
// 生成时间字符串
String timeString = now.format(formatter);
TxwMhzcQyrzsqjlbDO qyrzsqjlbDO = qyrzsqjlbService.getById(reqVO.getUuid());
qyrzsqjlbDO.setShjg1(reqVO.getShjg1());
qyrzsqjlbDO.setShyj1(reqVO.getShyj1());
qyrzsqjlbDO.setShrsfid(SessionUtils.getYhUuid());
qyrzsqjlbDO.setShsj(new Date());
qyrzsqjlbService.updateById(qyrzsqjlbDO);
if ("3".equals(reqVO.getShjg1())) {
TxwMhzcQyxxbDO qyxxbDO = BeanUtils.toBean(qyrzsqjlbDO, TxwMhzcQyxxbDO.class);
qyxxbDO.setQyuuid(IdUtil.fastSimpleUUID());
qyxxbDO.setYxbz("Y");
qyxxbDO.setLrrq(new Date());
this.save(qyxxbDO);
TxwMhzcYhqygxbDO yhqygxbDO = new TxwMhzcYhqygxbDO();
yhqygxbDO.setQyuuid(qyxxbDO.getQyuuid());
yhqygxbDO.setYhUuid(qyrzsqjlbDO.getLrruuid());
yhqygxbDO.setUuid(IdUtil.fastSimpleUUID());
yhqygxbService.save(yhqygxbDO);
String lrruuid = qyrzsqjlbDO.getLrruuid();
SwitchCompanyResDTO resDTO = new SwitchCompanyResDTO();
resDTO.setYhuuid(lrruuid);
resDTO.setQyuuid(qyxxbDO.getQyuuid());
resDTO.setQymc(qyxxbDO.getQymc());
resDTO.setNsrsbh(qyxxbDO.getNsrsbh());
switchSessionApi.addCompany(resDTO);
XxReqVO xxReqVO = new XxReqVO();
Map<String, String> btMap = new HashMap<>();
btMap.put("qymc", qyxxbDO.getQymc());
Map<String, String> nrMap = new HashMap<>();
nrMap.put("qymc", qyxxbDO.getQymc());
nrMap.put("rq", timeString);
xxReqVO.setMbuuid("mhzc_qyrz_sptg");
xxReqVO.setXxbtMap(btMap);
xxReqVO.setXxnrMap(nrMap);
xxReqVO.setYhuuid(qyrzsqjlbDO.getLrruuid());
xxzxApi.xtxxfb(xxReqVO);
} else {
XxReqVO xxReqVO = new XxReqVO();
Map<String, String> btMap = new HashMap<>();
btMap.put("qymc", qyrzsqjlbDO.getQymc());
Map<String, String> nrMap = new HashMap<>();
nrMap.put("qymc", qyrzsqjlbDO.getQymc());
nrMap.put("rq", timeString);
xxReqVO.setMbuuid("mhzc_qyrz_spsb");
xxReqVO.setXxbtMap(btMap);
xxReqVO.setXxnrMap(nrMap);
xxReqVO.setYhuuid(qyrzsqjlbDO.getLrruuid());
xxzxApi.xtxxfb(xxReqVO);
}
return "success";
}
@Override
public YhxxbDTO intQyxxByDid(YhxxbDTO qyxx) {
log.info("qyxx:{}",qyxx);
if (GyUtils.isNull(qyxx)
|| GyUtils.isNull(qyxx.getNsrsbh())
|| GyUtils.isNull(qyxx.getQymc())
|| GyUtils.isNull(qyxx.getYhUuid())) {
return null;
}
String lrruuid = qyxx.getYhUuid();
LocalDateTime now = LocalDateTime.now();
// 定义格式
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
// 生成时间字符串
String timeString = now.format(formatter);
List<TxwMhzcQyxxbDO> qyxxList = qyxxbMapper.getByNsrsbh(qyxx.getNsrsbh());
TxwMhzcQyxxbDO qyxxbDO = null;
boolean isNew = false;// 是否新增
if (GyUtils.isNull(qyxxList)) {
qyxxbDO = new TxwMhzcQyxxbDO();
qyxxbDO.setQyuuid(IdUtil.fastSimpleUUID());
qyxxbDO.setQymc(qyxx.getQymc());
qyxxbDO.setNsrsbh(qyxx.getNsrsbh());
qyxxbDO.setGxdtrzbz("N");
qyxxbDO.setYwqdDm("did");
qyxxbDO.setYxbz("Y");
qyxxbDO.setLrrq(new Date());
log.info("qyxxbDO:{}",qyxxbDO);
this.save(qyxxbDO);
isNew = true;
}
else {
qyxxbDO = qyxxList.get(0);
}
if (isNew) {
TxwMhzcYhqygxbDO yhqygxbDO = new TxwMhzcYhqygxbDO();
yhqygxbDO.setQyuuid(qyxxbDO.getQyuuid());
yhqygxbDO.setYhUuid(lrruuid);
yhqygxbDO.setUuid(IdUtil.fastSimpleUUID());
log.info("yhqygxbDO:{}",yhqygxbDO);
yhqygxbService.save(yhqygxbDO);
}
else {
String qyuuid = qyxxbDO.getQyuuid();
List<TxwMhzcYhqygxbDO> gxList = yhqygxbService.query(qyuuid,lrruuid);
if (GyUtils.isNull(gxList)) {
TxwMhzcYhqygxbDO yhqygxbDO = new TxwMhzcYhqygxbDO();
yhqygxbDO.setQyuuid(qyxxbDO.getQyuuid());
yhqygxbDO.setYhUuid(lrruuid);
yhqygxbDO.setUuid(IdUtil.fastSimpleUUID());
log.info("yhqygxbDO:{}",yhqygxbDO);
yhqygxbService.save(yhqygxbDO);
}
}
// 切换token
SwitchCompanyResDTO resDTO = new SwitchCompanyResDTO();
resDTO.setYhuuid(lrruuid);
resDTO.setQyuuid(qyxxbDO.getQyuuid());
resDTO.setQymc(qyxxbDO.getQymc());
resDTO.setNsrsbh(qyxxbDO.getNsrsbh());
log.info("SwitchCompanyResDTO:{}",resDTO);
switchSessionApi.addCompany(resDTO);
// XxReqVO xxReqVO = new XxReqVO();
// Map<String, String> btMap = new HashMap<>();
// btMap.put("qymc", qyxxbDO.getQymc());
// Map<String, String> nrMap = new HashMap<>();
// nrMap.put("qymc", qyxxbDO.getQymc());
// nrMap.put("rq", timeString);
// xxReqVO.setMbuuid("mhzc_qyrz_sptg");
// xxReqVO.setXxbtMap(btMap);
// xxReqVO.setXxnrMap(nrMap);
// xxReqVO.setYhuuid(lrruuid);
// log.info("xxReqVO:{}",xxReqVO);
// xxzxApi.xtxxfb(xxReqVO);
return qyxx;
}
@Override
public String qyrz(QyrzReqDTO reqDTO) {
switch (reqDTO.getYwlxDm()) {
case "01":
qyxxbMapper.qyrz(reqDTO.getNsrsbh());
break;
case "02":
qyxxbMapper.qyrz(reqDTO.getNsrsbh());
break;
}
return "success";
}
@Override
public List<CompanyVO> getQyxxListByYwlx(String ywlx) {
List<TxwMhzcQyxxbDO> list = qyxxbMapper.getGxQy(ywlx);
if (GyUtils.isNull(list))
return null;
return BeanUtils.toBean(list, CompanyVO.class);
}
}

View File

@ -0,0 +1,42 @@
package com.css.txw.mhzc.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.css.ggzc.framework.cache.utils.CacheUtils;
import com.css.ggzc.framework.common.util.gy.GyUtils;
import com.css.ggzc.framework.common.util.object.BeanUtils;
import com.css.txw.mhzc.mapper.TxwMhzcZxxxbMapper;
import com.css.txw.mhzc.pojo.domain.TxwMhzcZxxxbDO;
import com.css.txw.mhzc.pojo.vo.SyzxxxVO;
import com.css.txw.mhzc.service.TxwMhzcSyxxbService;
import com.css.txw.mhzc.service.TxwMhzcZxxxbService;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
/**
* @author AirlH
* @description 针对表txw_mhzc_zxxxb(咨询信息表)的数据库操作Service实现
* @createDate 2025-09-18 16:39:32
*/
@Service
public class TxwMhzcSyxxbServiceImpl extends ServiceImpl<TxwMhzcZxxxbMapper, TxwMhzcZxxxbDO>
implements TxwMhzcSyxxbService {
@Override
public Map<String, Object> getCdxx() {
Map<String,Object> cdMap = new HashMap<>();
cdMap.put("kxtfwzx",CacheUtils.dm2mc("cs_ggzc_xtcs","kxtfwzx"));
cdMap.put("kxtcx",CacheUtils.dm2mc("cs_ggzc_xtcs","kxtcx"));
cdMap.put("kxttg",CacheUtils.dm2mc("cs_ggzc_xtcs","kxttg"));
cdMap.put("kxtcz",CacheUtils.dm2mc("cs_ggzc_xtcs","kxtcz"));
return cdMap;
}
}

View File

@ -0,0 +1,39 @@
package com.css.txw.mhzc.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.css.txw.mhzc.pojo.domain.TxwMhzcYhqygxbDO;
import com.css.txw.mhzc.mapper.TxwMhzcYhqygxbMapper;
import com.css.txw.mhzc.service.TxwMhzcYhqygxbService;
import java.util.List;
import javax.annotation.Resource;
import org.springframework.stereotype.Service;
/**
* @author AirlH
* @description 针对表txw_mhzc_yhqygxb(用户企业关系表)的数据库操作Service实现
* @createDate 2025-09-13 14:47:54
*/
@Service
public class TxwMhzcYhqygxbServiceImpl extends ServiceImpl<TxwMhzcYhqygxbMapper, TxwMhzcYhqygxbDO>
implements TxwMhzcYhqygxbService {
@Resource
private TxwMhzcYhqygxbMapper yhqygxbMapper;
@Override
public List<TxwMhzcYhqygxbDO> query(String qyuuid, String yhUuid) {
QueryWrapper<TxwMhzcYhqygxbDO> queryWrapper1 = new QueryWrapper<>();
queryWrapper1.lambda()
.eq(TxwMhzcYhqygxbDO::getYhUuid, yhUuid)
.eq(TxwMhzcYhqygxbDO::getQyuuid, qyuuid);
List<TxwMhzcYhqygxbDO> dos = yhqygxbMapper.selectList(queryWrapper1);
return dos;
}
}

View File

@ -0,0 +1,284 @@
package com.css.txw.mhzc.service.impl;
import static com.css.ggzc.framework.common.exception.util.ServiceExceptionUtil.exception;
import static com.css.txw.mhzc.constants.ErrorCodeConstants.OAUTH2_LOGIN_SJHM_NOT_EXISTS;
import static com.css.txw.mhzc.constants.ErrorCodeConstants.YHXX_IS_EXISTS;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;
import javax.annotation.Resource;
import org.springframework.stereotype.Service;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.css.ggzc.framework.cache.utils.CacheUtils;
import com.css.ggzc.framework.common.util.gy.GyUtils;
import com.css.ggzc.framework.common.util.object.BeanUtils;
import com.css.ggzc.framework.redis.utils.RedisUtils;
import com.css.ggzc.framework.session.SessionUtils;
import com.css.txw.mhzc.mapper.TxwMhzcYhqygxbMapper;
import com.css.txw.mhzc.mapper.TxwMhzcYhxxbMapper;
import com.css.txw.mhzc.pojo.YhxxReqDTO;
import com.css.txw.mhzc.pojo.YhxxbDTO;
import com.css.txw.mhzc.pojo.domain.TxwMhzcQyxxbDO;
import com.css.txw.mhzc.pojo.domain.TxwMhzcYhqygxbDO;
import com.css.txw.mhzc.pojo.domain.TxwMhzcYhxxbDO;
import com.css.txw.mhzc.pojo.vo.SessionVO;
import com.css.txw.mhzc.pojo.vo.UserLockVO;
import com.css.txw.mhzc.pojo.vo.UserRegisterReqVO;
import com.css.txw.mhzc.pojo.vo.UserReqVO;
import com.css.txw.mhzc.pojo.vo.UserVO;
import com.css.txw.mhzc.properties.MhzcProperties;
import com.css.txw.mhzc.service.TxwMhzcQyxxbService;
import com.css.txw.mhzc.service.TxwMhzcYhxxbService;
import cn.hutool.core.util.IdUtil;
import cn.hutool.crypto.digest.MD5;
import lombok.extern.slf4j.Slf4j;
/**
* @author AirlH
* @description 针对表txw_mhzc_yhxxb(用户信息表)的数据库操作Service实现
* @createDate 2025-09-08 17:08:11
*/
@Service
@Slf4j
public class TxwMhzcYhxxbServiceImpl extends ServiceImpl<TxwMhzcYhxxbMapper, TxwMhzcYhxxbDO>
implements TxwMhzcYhxxbService {
@Resource
private TxwMhzcYhxxbMapper yhxxbMapper;
@Resource
private TxwMhzcYhqygxbMapper yhqygxbMapper;
@Resource
private TxwMhzcQyxxbService qyxxbService;
@Resource
private MhzcProperties mhzcProperties;
@Override
public YhxxbDTO initSessionByYhuuid(YhxxReqDTO reqDTO) {
TxwMhzcYhxxbDO yhxxbDO = yhxxbMapper.getYhxxByYhuuid(reqDTO.getYhuuid());
if (GyUtils.isNull(yhxxbDO)) return null;
YhxxbDTO yhxxbDTO = BeanUtils.toBean(yhxxbDO, YhxxbDTO.class);
List<TxwMhzcYhqygxbDO> byYhuuid = yhqygxbMapper.getByYhuuid(reqDTO.getYhuuid());
if (GyUtils.isNull(byYhuuid)) return yhxxbDTO;
String qyuuid = byYhuuid.get(0).getQyuuid();
TxwMhzcQyxxbDO qyxxbDO = qyxxbService.getById(qyuuid);
yhxxbDTO.setQyuuid(qyuuid);
yhxxbDTO.setQymc(qyxxbDO.getQymc());
yhxxbDTO.setNsrsbh(qyxxbDO.getNsrsbh());
return yhxxbDTO;
}
@Override
public YhxxbDTO initSessionByDid(YhxxReqDTO reqDTO) {
if (GyUtils.isNull(reqDTO) || GyUtils.isNull(reqDTO.getDid())) return null;
TxwMhzcYhxxbDO yhxxbDO = yhxxbMapper.getYhxxByDid(reqDTO.getDid());
if (GyUtils.isNull(yhxxbDO)) return null;
YhxxbDTO yhxxbDTO = BeanUtils.toBean(yhxxbDO, YhxxbDTO.class);
List<TxwMhzcYhqygxbDO> byYhuuid = yhqygxbMapper.getByYhuuid(yhxxbDTO.getYhUuid());
if (GyUtils.isNull(byYhuuid)) return yhxxbDTO;
String qyuuid = byYhuuid.get(0).getQyuuid();
TxwMhzcQyxxbDO qyxxbDO = qyxxbService.getById(qyuuid);
yhxxbDTO.setQyuuid(qyuuid);
yhxxbDTO.setQymc(qyxxbDO.getQymc());
yhxxbDTO.setNsrsbh(qyxxbDO.getNsrsbh());
return yhxxbDTO;
}
@Override
public YhxxbDTO updateDid(YhxxbDTO reqDTO) {
if (GyUtils.isNull(reqDTO)
|| GyUtils.isNull(reqDTO.getDid())
|| GyUtils.isNull(reqDTO.getYhUuid())
) return null;
log.info("reqDTO:{}",reqDTO);
LambdaUpdateWrapper<TxwMhzcYhxxbDO> updateWrapper = new LambdaUpdateWrapper<>();
updateWrapper.set(TxwMhzcYhxxbDO::getDid, reqDTO.getDid())
.eq(TxwMhzcYhxxbDO::getYhUuid,reqDTO.getYhUuid());
yhxxbMapper.update(null,updateWrapper);
return reqDTO;
}
@Override
public YhxxbDTO initSessionBySfzjhm(YhxxReqDTO reqDTO) {
if (GyUtils.isNull(reqDTO) || GyUtils.isNull(reqDTO.getSfzjhm())) return null;
TxwMhzcYhxxbDO yhxxbDO = yhxxbMapper.getYhxxBySfzjhm(reqDTO.getSfzjhm());
if (GyUtils.isNull(yhxxbDO)) return null;
YhxxbDTO yhxxbDTO = BeanUtils.toBean(yhxxbDO, YhxxbDTO.class);
List<TxwMhzcYhqygxbDO> byYhuuid = yhqygxbMapper.getByYhuuid(yhxxbDTO.getYhUuid());
if (GyUtils.isNull(byYhuuid)) return yhxxbDTO;
String qyuuid = byYhuuid.get(0).getQyuuid();
TxwMhzcQyxxbDO qyxxbDO = qyxxbService.getById(qyuuid);
yhxxbDTO.setQyuuid(qyuuid);
yhxxbDTO.setQymc(qyxxbDO.getQymc());
yhxxbDTO.setNsrsbh(qyxxbDO.getNsrsbh());
return yhxxbDTO;
}
@Override
public YhxxbDTO initSessionByDlzh(YhxxReqDTO reqDTO) {
TxwMhzcYhxxbDO yhxxbDO = yhxxbMapper.getYhxxByDlzh(reqDTO.getDlzh());
if (GyUtils.isNull(yhxxbDO)) return null;
YhxxbDTO yhxxbDTO = BeanUtils.toBean(yhxxbDO, YhxxbDTO.class);
List<TxwMhzcYhqygxbDO> byYhuuid = yhqygxbMapper.getByYhuuid(reqDTO.getYhuuid());
if (GyUtils.isNull(byYhuuid)) return yhxxbDTO;
String qyuuid = byYhuuid.get(0).getQyuuid();
TxwMhzcQyxxbDO qyxxbDO = qyxxbService.getById(qyuuid);
yhxxbDTO.setQyuuid(qyuuid);
yhxxbDTO.setQymc(qyxxbDO.getQymc());
yhxxbDTO.setNsrsbh(qyxxbDO.getNsrsbh());
return yhxxbDTO;
}
@Override
public String register(UserRegisterReqVO reqVO) {
String sms = reqVO.getSms();
String dlzh = reqVO.getDlzh();
String s = RedisUtils.get(formatKey(dlzh + sms));
if (this.mhzcProperties.isRegisterSmsCheck() && (GyUtils.isNull(s) || !dlzh.equals(s))) {
throw exception(OAUTH2_LOGIN_SJHM_NOT_EXISTS);
}
TxwMhzcYhxxbDO yhxxByDlzh = yhxxbMapper.getYhxxByDlzhNoYxbzNoSdbz(dlzh);
if (!GyUtils.isNull(yhxxByDlzh)) {
throw exception(YHXX_IS_EXISTS);
}
TxwMhzcYhxxbDO yhxxbDO = new TxwMhzcYhxxbDO();
yhxxbDO.setYhUuid(IdUtil.fastSimpleUUID());
yhxxbDO.setDlzh(reqVO.getDlzh());
yhxxbDO.setZsxm1(reqVO.getZsxm1());
yhxxbDO.setSjhm1(reqVO.getDlzh());
yhxxbDO.setDlmm(MD5.create().digestHex(reqVO.getPassword()));
Date now = new Date();
yhxxbDO.setLrrq(now);
yhxxbDO.setXgrq(now);
yhxxbDO.setYxbz("Y");
yhxxbDO.setSdbz("N");
yhxxbDO.setYwqdDm("mhzc");
yhxxbDO.setSjcsdq("mhzc");
yhxxbDO.setSjgsdq("mhzc");
yhxxbDO.setLrrsfid("mhzc");
yhxxbDO.setSjtbSj(now);
this.save(yhxxbDO);
return "ok";
}
@Override
public YhxxbDTO saveYhxxByDid(YhxxbDTO reqVO) {
String dlzh = reqVO.getDlzh();
TxwMhzcYhxxbDO yhxxByDlzh = yhxxbMapper.getYhxxByDlzhNoYxbzNoSdbz(dlzh);
if (!GyUtils.isNull(yhxxByDlzh)) {
throw exception(YHXX_IS_EXISTS);
}
TxwMhzcYhxxbDO yhxxbDO = new TxwMhzcYhxxbDO();
if (GyUtils.isNull(reqVO.getYhUuid())) {
yhxxbDO.setYhUuid(IdUtil.fastSimpleUUID());
}
else {
yhxxbDO.setYhUuid(reqVO.getYhUuid());
}
yhxxbDO.setDlzh(reqVO.getDlzh());
yhxxbDO.setZsxm1(reqVO.getZsxm1());
yhxxbDO.setSjhm1(reqVO.getDlzh());
yhxxbDO.setDlmm(MD5.create().digestHex("did"+reqVO.getDlzh()));
yhxxbDO.setSfzjhm(reqVO.getSfzjhm());
yhxxbDO.setDid(reqVO.getDid());
Date now = new Date();
yhxxbDO.setLrrq(now);
yhxxbDO.setXgrq(now);
yhxxbDO.setYxbz("Y");
yhxxbDO.setSdbz("N");
yhxxbDO.setYwqdDm("did");
yhxxbDO.setSjcsdq("did");
yhxxbDO.setSjgsdq("did");
yhxxbDO.setLrrsfid("did");
yhxxbDO.setSjtbSj(now);
this.save(yhxxbDO);
return reqVO;
}
private static String formatKey(String sms) {
String VERIFY_TOKEN = "sms_token:%s";
return String.format(VERIFY_TOKEN, sms);
}
@Override
public SessionVO init() {
SessionVO sessionVO = new SessionVO();
sessionVO.setYhUuid(SessionUtils.getYhUuid());
sessionVO.setSjhm1(SessionUtils.getSjhm());
sessionVO.setZsxm1(SessionUtils.getZsxm());
List<TxwMhzcYhqygxbDO> list = yhqygxbMapper.getByYhuuid(SessionUtils.getYhUuid());
if (GyUtils.isNull(list)) return sessionVO;
TxwMhzcQyxxbDO qyxxbDO = qyxxbService.getById(list.get(0).getQyuuid());
if (GyUtils.isNull(qyxxbDO)) return sessionVO;
// sessionVO.setNsrsbh(SessionUtils.getNsrsbh());
// sessionVO.setQymc((String) SessionUtils.get("qymc"));
sessionVO.setNsrsbh(qyxxbDO.getNsrsbh());
sessionVO.setQymc(qyxxbDO.getQymc());
sessionVO.setQyuuid(qyxxbDO.getQyuuid());
sessionVO.setGxdtRzbz(qyxxbDO.getGxdtrzbz());
return sessionVO;
}
@Override
public Page<UserVO> getAllUser(UserReqVO reqVO) {
Page<TxwMhzcYhxxbDO> page = yhxxbMapper.getAllUser(reqVO);
if (GyUtils.isNull(page)) return null;
List<TxwMhzcYhxxbDO> records = page.getRecords();
List<UserVO> userVOS = BeanUtils.toBean(records, UserVO.class);
Page<UserVO> resPage = new Page<>();
resPage.setCurrent(page.getCurrent());
resPage.setTotal(page.getTotal());
resPage.setPages(page.getPages());
resPage.setSize(page.getSize());
resPage.setRecords(userVOS);
return resPage;
}
@Override
public String resetPassword(String yhuuid) {
TxwMhzcYhxxbDO yhxxbDO = new TxwMhzcYhxxbDO();
yhxxbDO.setYhUuid(yhuuid);
yhxxbDO.setDlmm(CacheUtils.dm2mc("cs_ggzc_xtcs", "dlmm"));
this.updateById(yhxxbDO);
return "success";
}
@Override
public List<String> getAllUserId() {
List<TxwMhzcYhxxbDO> allUserId = yhxxbMapper.getAllUserId();
if (GyUtils.isNull(allUserId)) return null;
return allUserId.stream().map(TxwMhzcYhxxbDO::getYhUuid).collect(Collectors.toList());
}
@Override
public Integer lockUser(UserLockVO infoVO) {
final Date date = new Date();
final TxwMhzcYhxxbDO txwMhzcYhxxbDO = new TxwMhzcYhxxbDO();
txwMhzcYhxxbDO.setYhUuid(infoVO.getYhuuid());
txwMhzcYhxxbDO.setSdbz("Y");
txwMhzcYhxxbDO.setSdyy(infoVO.getSdyy());
txwMhzcYhxxbDO.setSdsj1(date);
txwMhzcYhxxbDO.setSdryid(SessionUtils.getYhUuid());
txwMhzcYhxxbDO.setXgrq(date);
txwMhzcYhxxbDO.setXgrsfid(SessionUtils.getYhUuid());
return yhxxbMapper.updateById(txwMhzcYhxxbDO);
}
@Override
public Integer unlockUser(UserLockVO infoVO) {
return yhxxbMapper.unlock(infoVO.getYhuuid(), new Date(), SessionUtils.getYhUuid());
}
}

View File

@ -0,0 +1,40 @@
package com.css.txw.mhzc.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.css.ggzc.framework.common.util.gy.GyUtils;
import com.css.ggzc.framework.common.util.object.BeanUtils;
import com.css.txw.mhzc.pojo.vo.SyzxxxVO;
import com.css.txw.mhzc.service.TxwMhzcZxxxbService;
import com.css.txw.mhzc.pojo.domain.TxwMhzcZxxxbDO;
import com.css.txw.mhzc.mapper.TxwMhzcZxxxbMapper;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
/**
* @author AirlH
* @description 针对表txw_mhzc_zxxxb(咨询信息表)的数据库操作Service实现
* @createDate 2025-09-18 16:39:32
*/
@Service
public class TxwMhzcZxxxbServiceImpl extends ServiceImpl<TxwMhzcZxxxbMapper, TxwMhzcZxxxbDO>
implements TxwMhzcZxxxbService {
@Resource
private TxwMhzcZxxxbMapper zxxxbMapper;
@Override
public Map<String, List<SyzxxxVO>> zxxx() {
List<TxwMhzcZxxxbDO> all = zxxxbMapper.getAll();
if (GyUtils.isNull(all)) return null;
List<SyzxxxVO> syzxxxVOS = BeanUtils.toBean(all, SyzxxxVO.class);
return syzxxxVOS.stream().collect(Collectors.groupingBy(SyzxxxVO::getZxLx));
}
}

View File

@ -0,0 +1,3 @@
# 本业务域工具类
跟业务相关的写在这里
公共类的请优先使用framework中有的或者在framework中增加

View File

@ -0,0 +1 @@
com.css.txw.mhzc.configuration.MhzcServiceConfiguration

View File

@ -0,0 +1,112 @@
spring:
main:
allow-circular-references: true # 允许循环依赖,因为项目是三层架构,无法避免这个情况。
allow-bean-definition-overriding: true # 允许 Bean 覆盖,例如说 Feign 等会存在重复定义的服务
# Servlet 配置
servlet:
# 文件上传相关配置项
multipart:
max-file-size: 16MB # 单个文件大小
max-request-size: 32MB # 设置总上传的文件大小
mvc:
pathmatch:
matching-strategy: ANT_PATH_MATCHER # 解决 SpringFox 与 SpringBoot 2.6.x 不兼容的问题,参见 SpringFoxHandlerProviderBeanPostProcessor 类
# Jackson 配置项
jackson:
serialization:
write-dates-as-timestamps: false # 设置 LocalDateTime 的格式,使用时间戳
write-date-timestamps-as-nanoseconds: false # 设置不使用 nanoseconds 的格式。例如说 1611460870.401,而是直接 1611460870401
write-durations-as-timestamps: false # 设置 Duration 的格式,使用时间戳
fail-on-empty-beans: false # 允许序列化无属性的 Bean
date-format: yyyy-MM-dd HH:MM:ss
timeZone: GMT+8
# Cache 配置项
cache:
type: REDIS
redis:
time-to-live: 1h # 设置过期时间为 1 小时
--- #################### 接口文档配置 ####################
springdoc:
api-docs:
enabled: true # 1. 是否开启 Swagger 接文档的元数据
path: /v3/api-docs
swagger-ui:
enabled: true # 2.1 是否开启 Swagger 文档的官方 UI 界面
path: /swagger-ui.html
default-flat-param-object: true # 参见 https://doc.xiaominfo.com/docs/faq/v4/knife4j-parameterobject-flat-param 文档
knife4j:
enable: true # 2.2 是否开启 Swagger 文档的 Knife4j UI 界面
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 打印
enable-sql-runner: true #使用SQLrunner
type-aliases-package: ${znsb.info.base-package}.*.dal.dataobject
encryptor:
password: XDV71a+xqStEA3WH # 加解密的秘钥,可使用 https://www.imaegoo.com/2020/aes-key-generator/ 网站生成
mybatis-plus-join:
banner: false # 关闭控制台的 Banner 打印
# 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 打印日志
com.css.txw.mhzc.pojo: debug
css:
application:
version: 1.0.0-SNAPSHOT
base-package: com.css.txw
swagger:
title: ${spring.application.name}
description: ${spring.application.name}
version: ${css.application.version}
base-package: ${css.application.base-package}
tenant: # 多租户相关配置项
enable: true
debug: false

View File

@ -0,0 +1,22 @@
--- #################### 注册中心相关配置 ####################
spring:
cloud:
nacos:
server-addr: 10.23.10.91:8848
discovery:
namespace: qyd-txw # 命名空间。这里使用 dev 开发环境
--- #################### 配置中心相关配置 ####################
spring:
cloud:
nacos:
# Nacos Config 配置项,对应 NacosConfigProperties 配置属性类
config:
server-addr: 10.23.10.91:8848 # Nacos 服务器地址
namespace: qyd-txw # 命名空间。这里使用 dev 开发环境
group: DEFAULT_GROUP # 使用的 Nacos 配置分组,默认为 DEFAULT_GROUP
name: ${spring.application.name} # 使用的 Nacos 配置集的 dataId默认为 spring.application.name
file-extension: yaml # 使用的 Nacos 配置集的 dataId 的文件拓展名,同时也是 Nacos 配置集的配置格式,默认为 properties

View File

@ -0,0 +1,27 @@
--- #################### 注册中心相关配置 ####################
spring:
cloud:
nacos:
server-addr: 10.23.10.91:8848
username: qyddev
password: 9!1%Sw#QydNacosDev
discovery:
namespace: 0ac06fee-c2c9-4ca0-9a26-4921d553adde # 命名空间。这里使用开发环境
metadata:
version: 1.0.0-SNAPSHOT # 服务实例的版本号,可用于灰度发布
--- #################### 配置中心相关配置 ####################
spring:
cloud:
nacos:
# Nacos Config 配置项,对应 NacosConfigProperties 配置属性类
config:
server-addr: 10.23.10.91:8848 # Nacos 服务器地址
username: qyddev
password: 9!1%Sw#QydNacosDev
namespace: 0ac06fee-c2c9-4ca0-9a26-4921d553adde # 命名空间。这里使用 dev 开发环境
group: DEFAULT_GROUP # 使用的 Nacos 配置分组,默认为 DEFAULT_GROUP
name: ${spring.application.name} # 使用的 Nacos 配置集的 dataId默认为 spring.application.name
file-extension: yaml # 使用的 Nacos 配置集的 dataId 的文件拓展名,同时也是 Nacos 配置集的配置格式,默认为 properties

View File

@ -0,0 +1,71 @@
--- #################### sentinel相关配置 ####################
spring:
cloud:
sentinel:
transport:
dashboard: sentinel_IP:PORT #控制台地址
http-method-specify: true #开启请求方式前缀
feign:
sentinel:
enabled: true
--- #################### xxl-job相关配置 ####################
xxl:
job:
enable: false
admin:
addresses: http://XXL_IP:PORT/xxl-job-admin
executor:
appname: ${spring.application.name} # 执行器 AppName
logpath: ${user.dir}/logs/xxl-job/${spring.application.name} # 执行器运行日志文件存储磁盘路径
access-token: xxl_password
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: 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: znsb_mhzc
datasource:
znsb_mhzc:
url: jdbc:mysql://DB_IP:PORT/DBNAME?allowMultiQueries=true&useUnicode=true&useSSL=false&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai&autoReconnect=true&nullCatalogMeansCurrent=true # MySQL Connector/J 8.X 连接的示例
username: DB_username
password: DB_password
# Redis 配置。Redisson 默认的配置足够使用,一般不需要进行调优
redis:
host: REDIS_IP # 地址
port: 6379 # 端口
password: REDIS_password
database: 0 # 数据库索引

View File

@ -0,0 +1,16 @@
spring:
application:
name: txw-mhzc
profiles:
active: local
server:
port: 9302
servlet:
context-path: /mhzc
# 日志文件配置。注意,如果 logging.file.name 不放在 bootstrap.yaml 配置文件,而是放在 application.yaml 中,会导致出现 LOG_FILE_IS_UNDEFINED 文件
logging:
file:
name: ${user.dir}/logs/${spring.application.name}.log # 日志文件名,全路径

View File

@ -0,0 +1,75 @@
<configuration>
<!-- 引用 Spring Boot 的 logback 基础配置 -->
<include resource="org/springframework/boot/logging/logback/defaults.xml"/>
<conversionRule conversionWord="hhid" converterClass="com.css.ggzc.framework.common.log.LogbackPatternConverter"/>
<!-- 变量 yudao.info.base-package基础业务包 -->
<springProperty scope="context" name="css.application.base-package" source="css.application.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}} ${LOG_LEVEL_PATTERN:-%5p} ${PID:- } --- [%thread] [%hhid:%X{TRACE_ID}] %-40.40logger{39} : %m%n${LOG_EXCEPTION_CONVERSION_WORD:-%wEx}"/>
<!-- 控制台 Appender -->
<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">     
<encoder>
<pattern>${PATTERN_DEFAULT}</pattern>
</encoder>
</appender>
<!-- 文件 Appender -->
<!-- 参考 Spring Boot 的 file-appender.xml 编写 -->
<appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
<encoder>
<pattern>${PATTERN_DEFAULT}</pattern>
</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,jc,nacos,oracle">
<root level="INFO">
<appender-ref ref="STDOUT"/>
</root>
</springProfile>
<!-- 其它环境 -->
<springProfile name="test,stage,prod,default,env">
<root level="INFO">
<appender-ref ref="STDOUT"/>
<appender-ref ref="ASYNC"/>
</root>
</springProfile>
</configuration>

View File

@ -0,0 +1,27 @@
<?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="com.css.txw.mhzc.mapper.TxwMhzcGglbMapper">
<resultMap id="BaseResultMap" type="com.css.txw.mhzc.pojo.domain.TxwMhzcGglbDO">
<id property="uuid" column="uuid" jdbcType="VARCHAR"/>
<result property="bt1" column="bt_1" jdbcType="VARCHAR"/>
<result property="ggNr" column="gg_nr" jdbcType="VARCHAR"/>
<result property="tpid" column="tpid" jdbcType="VARCHAR"/>
<result property="tzdz" column="tzdz" jdbcType="VARCHAR"/>
<result property="xh" column="xh" jdbcType="DECIMAL"/>
<result property="lrrq" column="lrrq" jdbcType="TIMESTAMP"/>
<result property="xgrq" column="xgrq" jdbcType="TIMESTAMP"/>
<result property="lrruuid" column="lrruuid" jdbcType="VARCHAR"/>
<result property="xgruuid" column="xgruuid" jdbcType="VARCHAR"/>
<result property="yxbz" column="yxbz" jdbcType="CHAR"/>
</resultMap>
<sql id="Base_Column_List">
uuid,bt_1,gg_nr,
tpid,tzdz,xh,
lrrq,xgrq,lrruuid,
xgruuid,yxbz
</sql>
</mapper>

View File

@ -0,0 +1,39 @@
<?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="com.css.txw.mhzc.mapper.TxwMhzcHtyhxxbMapper">
<resultMap id="BaseResultMap" type="com.css.txw.mhzc.pojo.domain.TxwMhzcHtyhxxbDO">
<id property="yhUuid" column="yh_uuid" jdbcType="VARCHAR"/>
<result property="dlzh" column="dlzh" jdbcType="VARCHAR"/>
<result property="dlmm" column="dlmm" jdbcType="VARCHAR"/>
<result property="zsxm1" column="zsxm_1" jdbcType="VARCHAR"/>
<result property="sjhm1" column="sjhm_1" jdbcType="VARCHAR"/>
<result property="yxdz" column="yxdz" jdbcType="VARCHAR"/>
<result property="txdzurl" column="txdzurl" jdbcType="VARCHAR"/>
<result property="sdbz" column="sdbz" jdbcType="CHAR"/>
<result property="sdyy" column="sdyy" jdbcType="VARCHAR"/>
<result property="sdsj1" column="sdsj_1" jdbcType="TIMESTAMP"/>
<result property="sdryid" column="sdryid" jdbcType="VARCHAR"/>
<result property="ywqdDm" column="ywqd_dm" jdbcType="VARCHAR"/>
<result property="lrrq" column="lrrq" jdbcType="TIMESTAMP"/>
<result property="xgrq" column="xgrq" jdbcType="TIMESTAMP"/>
<result property="sjcsdq" column="sjcsdq" jdbcType="CHAR"/>
<result property="sjgsdq" column="sjgsdq" jdbcType="CHAR"/>
<result property="xgrsfid" column="xgrsfid" jdbcType="VARCHAR"/>
<result property="lrrsfid" column="lrrsfid" jdbcType="VARCHAR"/>
<result property="sjtbSj" column="sjtb_sj" jdbcType="TIMESTAMP"/>
<result property="yxbz" column="yxbz" jdbcType="CHAR"/>
</resultMap>
<sql id="Base_Column_List">
yh_uuid,dlzh,dlmm,
zsxm_1,sjhm_1,yxdz,
txdzurl,sdbz,sdyy,
sdsj_1,sdryid,ywqd_dm,
lrrq,xgrq,sjcsdq,
sjgsdq,xgrsfid,lrrsfid,
sjtb_sj,yxbz
</sql>
</mapper>

View File

@ -0,0 +1,26 @@
<?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="com.css.txw.mhzc.mapper.TxwMhzcQyrzsqjlbMapper">
<resultMap id="BaseResultMap" type="com.css.txw.mhzc.pojo.domain.TxwMhzcQyrzsqjlbDO">
<id property="uuid" column="uuid" jdbcType="VARCHAR"/>
<result property="qymc" column="qymc" jdbcType="VARCHAR"/>
<result property="nsrsbh" column="nsrsbh" jdbcType="VARCHAR"/>
<result property="sqsm" column="sqsm" jdbcType="VARCHAR"/>
<result property="lrruuid" column="lrruuid" jdbcType="VARCHAR"/>
<result property="lrrq" column="lrrq" jdbcType="TIMESTAMP"/>
<result property="shrsfid" column="shr" jdbcType="VARCHAR"/>
<result property="shjg1" column="shjg_1" jdbcType="CHAR"/>
<result property="shyj1" column="shyj_1" jdbcType="VARCHAR"/>
<result property="shsj" column="shsj" jdbcType="TIMESTAMP"/>
</resultMap>
<sql id="Base_Column_List">
uuid,qymc,nsrsbh,
sqsm,lrruuid,lrrq,
shrsfid,shjg_1,shyj_1,
shsj
</sql>
</mapper>

View File

@ -0,0 +1,28 @@
<?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="com.css.txw.mhzc.mapper.TxwMhzcQyxxbMapper">
<resultMap id="BaseResultMap" type="com.css.txw.mhzc.pojo.domain.TxwMhzcQyxxbDO">
<id property="qyuuid" column="qyuuid" jdbcType="VARCHAR"/>
<result property="qymc" column="qymc" jdbcType="VARCHAR"/>
<result property="nsrsbh" column="nsrsbh" jdbcType="VARCHAR"/>
<result property="gxdtrzbz" column="gxdtrzbz" jdbcType="CHAR"/>
<result property="ywqdDm" column="ywqd_dm" jdbcType="VARCHAR"/>
<result property="lrrq" column="lrrq" jdbcType="TIMESTAMP"/>
<result property="xgrq" column="xgrq" jdbcType="TIMESTAMP"/>
<result property="sjcsdq" column="sjcsdq" jdbcType="CHAR"/>
<result property="sjgsdq" column="sjgsdq" jdbcType="CHAR"/>
<result property="xgrsfid" column="xgrsfid" jdbcType="VARCHAR"/>
<result property="lrrsfid" column="lrrsfid" jdbcType="VARCHAR"/>
<result property="sjtbSj" column="sjtb_sj" jdbcType="TIMESTAMP"/>
</resultMap>
<sql id="Base_Column_List">
qyuuid,qymc,nsrsbh,
gxdtrzbz,ywqd_dm,lrrq,
xgrq,sjcsdq,sjgsdq,
xgrsfid,lrrsfid,sjtb_sj
</sql>
</mapper>

View File

@ -0,0 +1,16 @@
<?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="com.css.txw.mhzc.mapper.TxwMhzcYhqygxbMapper">
<resultMap id="BaseResultMap" type="com.css.txw.mhzc.pojo.domain.TxwMhzcYhqygxbDO">
<id property="uuid" column="uuid" jdbcType="VARCHAR"/>
<result property="yhUuid" column="yh_uuid" jdbcType="VARCHAR"/>
<result property="qyuuid" column="qyuuid" jdbcType="VARCHAR"/>
</resultMap>
<sql id="Base_Column_List">
uuid,yh_uuid,qyuuid
</sql>
</mapper>

View File

@ -0,0 +1,43 @@
<?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="com.css.txw.mhzc.mapper.TxwMhzcYhxxbMapper">
<resultMap id="BaseResultMap" type="com.css.txw.mhzc.pojo.domain.TxwMhzcYhxxbDO">
<id property="yhUuid" column="yh_uuid" jdbcType="VARCHAR"/>
<result property="dlzh" column="dlzh" jdbcType="VARCHAR"/>
<result property="dlmm" column="dlmm" jdbcType="VARCHAR"/>
<result property="zsxm1" column="zsxm_1" jdbcType="VARCHAR"/>
<result property="sjhm1" column="sjhm_1" jdbcType="VARCHAR"/>
<result property="yxdz" column="yxdz" jdbcType="VARCHAR"/>
<result property="txdzurl" column="txdzurl" jdbcType="VARCHAR"/>
<result property="sdbz" column="sdbz" jdbcType="CHAR"/>
<result property="sdyy" column="sdyy" jdbcType="VARCHAR"/>
<result property="sdsj1" column="sdsj_1" jdbcType="TIMESTAMP"/>
<result property="sdryid" column="sdryid" jdbcType="VARCHAR"/>
<result property="yxbz" column="yxbz" jdbcType="CHAR"/>
<result property="ywqdDm" column="ywqd_dm" jdbcType="VARCHAR"/>
<result property="lrrq" column="lrrq" jdbcType="TIMESTAMP"/>
<result property="xgrq" column="xgrq" jdbcType="TIMESTAMP"/>
<result property="sjcsdq" column="sjcsdq" jdbcType="CHAR"/>
<result property="sjgsdq" column="sjgsdq" jdbcType="CHAR"/>
<result property="xgrsfid" column="xgrsfid" jdbcType="VARCHAR"/>
<result property="lrrsfid" column="lrrsfid" jdbcType="VARCHAR"/>
<result property="sjtbSj" column="sjtb_sj" jdbcType="TIMESTAMP"/>
<result property="sfzjlx" column="sfzjlx" jdbcType="CHAR"/>
<result property="sfzjhm" column="sfzjhm" jdbcType="VARCHAR"/>
<result property="scdljguuid" column="scdljguuid" jdbcType="VARCHAR"/>
</resultMap>
<sql id="Base_Column_List">
yh_uuid,dlzh,dlmm,
zsxm_1,sjhm_1,yxdz,
txdzurl,sdbz,sdyy,
sdsj_1,sdryid,yxbz,
ywqd_dm,lrrq,xgrq,
sjcsdq,sjgsdq,xgrsfid,
lrrsfid,sjtb_sj,sfzjlx,
sfzjhm,scdljguuid
</sql>
</mapper>

View File

@ -0,0 +1,19 @@
<?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="com.css.txw.mhzc.mapper.TxwMhzcZxxxbMapper">
<resultMap id="BaseResultMap" type="com.css.txw.mhzc.pojo.domain.TxwMhzcZxxxbDO">
<id property="uuid" column="uuid" jdbcType="VARCHAR"/>
<result property="bt1" column="bt_1" jdbcType="VARCHAR"/>
<result property="zxNr" column="zx_nr" jdbcType="VARCHAR"/>
<result property="fbsj" column="fbsj" jdbcType="TIMESTAMP"/>
<result property="zxLx" column="zx_lx" jdbcType="CHAR"/>
</resultMap>
<sql id="Base_Column_List">
uuid,bt_1,nr,
fbsj,zyfl
</sql>
</mapper>