From 3796a24b94531458097cba59f882a9197b050ff2 Mon Sep 17 00:00:00 2001 From: xiang2lin <251481237@qq.com> Date: Mon, 12 May 2025 13:44:58 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BA=94=E7=94=A8=E8=B4=A6=E6=88=B7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../dao/ISysApplicationAccountDao.java | 15 + .../impl/SysApplicationAccountDaoImpl.java | 17 + .../entity/SysApplicationAccountEntity.java | 137 +++++++ .../entity/SysApplicationAccountEntity.xml | 333 ++++++++++++++++++ .../ISysApplicationAccountService.java | 57 +++ .../SysApplicationAccountServiceImpl.java | 107 ++++++ 6 files changed, 666 insertions(+) create mode 100644 base-service/src/main/java/com/hzya/frame/sysnew/application/appAcount/dao/ISysApplicationAccountDao.java create mode 100644 base-service/src/main/java/com/hzya/frame/sysnew/application/appAcount/dao/impl/SysApplicationAccountDaoImpl.java create mode 100644 base-service/src/main/java/com/hzya/frame/sysnew/application/appAcount/entity/SysApplicationAccountEntity.java create mode 100644 base-service/src/main/java/com/hzya/frame/sysnew/application/appAcount/entity/SysApplicationAccountEntity.xml create mode 100644 base-service/src/main/java/com/hzya/frame/sysnew/application/appAcount/service/ISysApplicationAccountService.java create mode 100644 base-service/src/main/java/com/hzya/frame/sysnew/application/appAcount/service/impl/SysApplicationAccountServiceImpl.java diff --git a/base-service/src/main/java/com/hzya/frame/sysnew/application/appAcount/dao/ISysApplicationAccountDao.java b/base-service/src/main/java/com/hzya/frame/sysnew/application/appAcount/dao/ISysApplicationAccountDao.java new file mode 100644 index 00000000..598bfc10 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sysnew/application/appAcount/dao/ISysApplicationAccountDao.java @@ -0,0 +1,15 @@ +package com.hzya.frame.sysnew.application.appAcount.dao; + +import com.hzya.frame.sysnew.application.appAcount.entity.SysApplicationAccountEntity; +import com.hzya.frame.basedao.dao.IBaseDao; + +/** + * 应用账户表(sys_application_account: table)表数据库访问层 + * + * @author xiang2lin + * @since 2025-05-10 15:52:21 + */ +public interface ISysApplicationAccountDao extends IBaseDao { + +} + diff --git a/base-service/src/main/java/com/hzya/frame/sysnew/application/appAcount/dao/impl/SysApplicationAccountDaoImpl.java b/base-service/src/main/java/com/hzya/frame/sysnew/application/appAcount/dao/impl/SysApplicationAccountDaoImpl.java new file mode 100644 index 00000000..359a8503 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sysnew/application/appAcount/dao/impl/SysApplicationAccountDaoImpl.java @@ -0,0 +1,17 @@ +package com.hzya.frame.sysnew.application.appAcount.dao.impl; + +import com.hzya.frame.sysnew.application.appAcount.entity.SysApplicationAccountEntity; +import com.hzya.frame.sysnew.application.appAcount.dao.ISysApplicationAccountDao; +import org.springframework.stereotype.Repository; +import com.hzya.frame.basedao.dao.MybatisGenericDao; +/** + * 应用账户表(SysApplicationAccount)表数据库访问层 + * + * @author xiang2lin + * @since 2025-05-10 15:52:23 + */ +@Repository(value = "SysApplicationAccountDaoImpl") +public class SysApplicationAccountDaoImpl extends MybatisGenericDao implements ISysApplicationAccountDao{ + +} + diff --git a/base-service/src/main/java/com/hzya/frame/sysnew/application/appAcount/entity/SysApplicationAccountEntity.java b/base-service/src/main/java/com/hzya/frame/sysnew/application/appAcount/entity/SysApplicationAccountEntity.java new file mode 100644 index 00000000..3542e200 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sysnew/application/appAcount/entity/SysApplicationAccountEntity.java @@ -0,0 +1,137 @@ +package com.hzya.frame.sysnew.application.appAcount.entity; + +import java.util.Date; +import com.hzya.frame.web.entity.BaseEntity; +/** + * 应用账户表(SysApplicationAccount)实体类 + * + * @author xiang2lin + * @since 2025-05-10 15:52:24 + */ +public class SysApplicationAccountEntity extends BaseEntity { + + /** + * 应用id + */ + private String appId; + /** 账户名称 */ + private String name; + /** ip地址 */ + private String ipAddress; + /** 端口 */ + private String port; + /** 数据库名称 */ + private String dbName; + /** 用户名 */ + private String userName; + /** 密码 */ + private String password; + /** 数据库类型 */ + private String dbType; + /** 应用key */ + private String appKey; + /** 应用密钥 */ + private String appSecret; + /** 企业id */ + private String corpid; + /** 应用id */ + private String agentid; + + public String getAppId() { + return appId; + } + + public void setAppId(String appId) { + this.appId = appId; + } + + public String getName() { + return name; + } + + public void setName(String name) { + this.name = name; + } + + public String getIpAddress() { + return ipAddress; + } + + public void setIpAddress(String ipAddress) { + this.ipAddress = ipAddress; + } + + public String getPort() { + return port; + } + + public void setPort(String port) { + this.port = port; + } + + public String getDbName() { + return dbName; + } + + public void setDbName(String dbName) { + this.dbName = dbName; + } + + public String getUserName() { + return userName; + } + + public void setUserName(String userName) { + this.userName = userName; + } + + public String getPassword() { + return password; + } + + public void setPassword(String password) { + this.password = password; + } + + public String getDbType() { + return dbType; + } + + public void setDbType(String dbType) { + this.dbType = dbType; + } + + public String getAppKey() { + return appKey; + } + + public void setAppKey(String appKey) { + this.appKey = appKey; + } + + public String getAppSecret() { + return appSecret; + } + + public void setAppSecret(String appSecret) { + this.appSecret = appSecret; + } + + public String getCorpid() { + return corpid; + } + + public void setCorpid(String corpid) { + this.corpid = corpid; + } + + public String getAgentid() { + return agentid; + } + + public void setAgentid(String agentid) { + this.agentid = agentid; + } + +} + diff --git a/base-service/src/main/java/com/hzya/frame/sysnew/application/appAcount/entity/SysApplicationAccountEntity.xml b/base-service/src/main/java/com/hzya/frame/sysnew/application/appAcount/entity/SysApplicationAccountEntity.xml new file mode 100644 index 00000000..b29ae0fe --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sysnew/application/appAcount/entity/SysApplicationAccountEntity.xml @@ -0,0 +1,333 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + id + ,create_user_id + ,create_time + ,modify_user_id + ,modify_time + ,sts + ,sorts + ,appId + ,name + ,ip_address + ,port + ,db_name + ,user_name + ,password + ,db_type + ,app_key + ,app_secret + ,corpId + ,agentId + + + + + + + + + + + + + + + + insert into sys_application_account( + + id , + create_user_id , + create_time , + modify_user_id , + modify_time , + sts , + sorts , + name , + ip_address , + port , + db_name , + user_name , + password , + db_type , + app_key , + app_secret , + corpId , + agentId , + sorts, + sts, + + )values( + + #{id} , + #{create_user_id} , + #{create_time} , + #{modify_user_id} , + #{modify_time} , + #{sts} , + #{sorts} , + #{name} , + #{ipAddress} , + #{port} , + #{dbName} , + #{userName} , + #{password} , + #{dbType} , + #{appKey} , + #{appSecret} , + #{corpid} , + #{agentid} , + COALESCE((select (max(IFNULL( a.sorts, 0 )) + 1) as sort from sys_application_account a + WHERE a.sts = 'Y' )1), + + 'Y', + + ) + + + + insert into sys_application_account(create_user_id, create_time, modify_user_id, modify_time, sts, sorts, name, + ip_address, port, db_name, user_name, password, db_type, app_key, app_secret, corpId, agentId, sts) + values + + (#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.sorts},#{entity.name},#{entity.ipAddress},#{entity.port},#{entity.dbName},#{entity.userName},#{entity.password},#{entity.dbType},#{entity.appKey},#{entity.appSecret},#{entity.corpid},#{entity.agentid}, + 'Y') + + + + + insert into sys_application_account(create_user_id, create_time, modify_user_id, modify_time, sts, sorts, name, + ip_address, port, db_name, user_name, password, db_type, app_key, app_secret, corpId, agentId) + values + + (#{entity.create_user_id},#{entity.create_time},#{entity.modify_user_id},#{entity.modify_time},#{entity.sts},#{entity.sorts},#{entity.name},#{entity.ipAddress},#{entity.port},#{entity.dbName},#{entity.userName},#{entity.password},#{entity.dbType},#{entity.appKey},#{entity.appSecret},#{entity.corpid},#{entity.agentid}) + + on duplicate key update + create_user_id = values(create_user_id), + create_time = values(create_time), + modify_user_id = values(modify_user_id), + modify_time = values(modify_time), + sts = values(sts), + sorts = values(sorts), + name = values(name), + ip_address = values(ip_address), + port = values(port), + db_name = values(db_name), + user_name = values(user_name), + password = values(password), + db_type = values(db_type), + app_key = values(app_key), + app_secret = values(app_secret), + corpId = values(corpId), + agentId = values(agentId) + + + + update sys_application_account set + + create_user_id = #{create_user_id}, + create_time = #{create_time}, + modify_user_id = #{modify_user_id}, + modify_time = #{modify_time}, + sts = #{sts}, + sorts = #{sorts}, + name = #{name}, + ip_address = #{ipAddress}, + port = #{port}, + db_name = #{dbName}, + user_name = #{userName}, + password = #{password}, + db_type = #{dbType}, + app_key = #{appKey}, + app_secret = #{appSecret}, + corpId = #{corpid}, + agentId = #{agentid}, + + where id = #{id} + + + + update sys_application_account + set sts= 'N', + modify_time = #{modify_time}, + modify_user_id = #{modify_user_id} + where id = #{id} + + + + update sys_application_account set sts= 'N' ,modify_time = #{modify_time},modify_user_id = #{modify_user_id} + + and id = #{id} + and sts = #{sts} + and sorts = #{sorts} + and name = #{name} + and ip_address = #{ipAddress} + and port = #{port} + and db_name = #{dbName} + and user_name = #{userName} + and password = #{password} + and db_type = #{dbType} + and app_key = #{appKey} + and app_secret = #{appSecret} + and corpId = #{corpid} + and agentId = #{agentid} + and sts='Y' + + + + + delete + from sys_application_account + where id = #{id} + + + + diff --git a/base-service/src/main/java/com/hzya/frame/sysnew/application/appAcount/service/ISysApplicationAccountService.java b/base-service/src/main/java/com/hzya/frame/sysnew/application/appAcount/service/ISysApplicationAccountService.java new file mode 100644 index 00000000..c06d2ed8 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sysnew/application/appAcount/service/ISysApplicationAccountService.java @@ -0,0 +1,57 @@ +package com.hzya.frame.sysnew.application.appAcount.service; + +import com.alibaba.fastjson.JSONObject; +import com.hzya.frame.sysnew.application.appAcount.entity.SysApplicationAccountEntity; +import com.hzya.frame.basedao.service.IBaseService; +import com.hzya.frame.web.entity.JsonResultEntity; + +/** + * 应用账户表(SysApplicationAccount)表服务接口 + * + * @author xiang2lin + * @since 2025-05-10 15:52:25 + */ +public interface ISysApplicationAccountService extends IBaseService{ + + /** + * 保存账户信息 + * @param object + * @return + */ + JsonResultEntity saveAccount(JSONObject object); + + /** + * 更新账户信息 + * @param object + * @return + */ + JsonResultEntity updateAccount(JSONObject object); + + /** + * 删除账户信息 + * @param object + * @return + */ + JsonResultEntity deleteAccount(JSONObject object); + + /** + * 查询账户详情 + * @param object + * @return + */ + JsonResultEntity getAccount(JSONObject object); + + /** + * 查询账户列表数据 + * @param object + * @return + */ + JsonResultEntity queryAccountList(JSONObject object); + + /** + * 查询账户分页数据 + * @param object + * @return + */ + JsonResultEntity queryAccountPaged(JSONObject object); +} diff --git a/base-service/src/main/java/com/hzya/frame/sysnew/application/appAcount/service/impl/SysApplicationAccountServiceImpl.java b/base-service/src/main/java/com/hzya/frame/sysnew/application/appAcount/service/impl/SysApplicationAccountServiceImpl.java new file mode 100644 index 00000000..486e4526 --- /dev/null +++ b/base-service/src/main/java/com/hzya/frame/sysnew/application/appAcount/service/impl/SysApplicationAccountServiceImpl.java @@ -0,0 +1,107 @@ +package com.hzya.frame.sysnew.application.appAcount.service.impl; + +import com.alibaba.fastjson.JSONObject; +import com.hzya.frame.sysnew.application.appAcount.entity.SysApplicationAccountEntity; +import com.hzya.frame.sysnew.application.appAcount.dao.ISysApplicationAccountDao; +import com.hzya.frame.sysnew.application.appAcount.service.ISysApplicationAccountService; +import com.hzya.frame.web.entity.BaseResult; +import com.hzya.frame.web.entity.JsonResultEntity; +import org.springframework.stereotype.Service; +import org.springframework.beans.factory.annotation.Autowired; +import javax.annotation.Resource; +import com.hzya.frame.basedao.service.impl.BaseService; +/** + * 应用账户表(SysApplicationAccount)表服务实现类 + * + * @author xiang2lin + * @since 2025-05-10 15:52:26 + */ +@Service(value = "sysApplicationAccountService") +public class SysApplicationAccountServiceImpl extends BaseService implements ISysApplicationAccountService { + + private ISysApplicationAccountDao sysApplicationAccountDao; + + @Autowired + public void setSysApplicationAccountDao(ISysApplicationAccountDao dao) { + this.sysApplicationAccountDao = dao; + this.dao = dao; + } + + /** + * 保存账户信息 + * + * @param object + * @return + */ + @Override + public JsonResultEntity saveAccount(JSONObject object) { + SysApplicationAccountEntity entity = getData("jsonStr", object, SysApplicationAccountEntity.class); + try { + checkParam(entity,"save"); + }catch (Exception e){ + return BaseResult.getFailureMessageEntity(e.getMessage()); + } + sysApplicationAccountDao.save(entity); + return BaseResult.getSuccessMessageEntity("新增成功"); + } + + /** + * 更新账户信息 + * + * @param object + * @return + */ + @Override + public JsonResultEntity updateAccount(JSONObject object) { + return null; + } + + /** + * 删除账户信息 + * + * @param object + * @return + */ + @Override + public JsonResultEntity deleteAccount(JSONObject object) { + return null; + } + + /** + * 查询账户详情 + * + * @param object + * @return + */ + @Override + public JsonResultEntity getAccount(JSONObject object) { + return null; + } + + /** + * 查询账户列表数据 + * + * @param object + * @return + */ + @Override + public JsonResultEntity queryAccountList(JSONObject object) { + return null; + } + + /** + * 查询账户分页数据 + * + * @param object + * @return + */ + @Override + public JsonResultEntity queryAccountPaged(JSONObject object) { + return null; + } + + //数据检查 + private void checkParam(SysApplicationAccountEntity entity,String type){ + + } +}