From 609d3518a2fc031d42d28e242e32dd09c7e16c39 Mon Sep 17 00:00:00 2001 From: even <827656971@qq.com> Date: Mon, 28 Apr 2025 15:20:12 +0800 Subject: [PATCH] =?UTF-8?q?service=E4=BB=A5=E5=8F=8AserviceImpl=E4=BB=A5?= =?UTF-8?q?=E5=8F=8A=E7=9B=B8=E5=85=B3=E7=B1=BB=EF=BC=88=E6=9A=82=E6=97=B6?= =?UTF-8?q?=E5=8C=85=E5=90=AB=E7=94=A8=E6=88=B7=E4=BD=93=E7=B3=BB=E5=90=8E?= =?UTF-8?q?=E7=BB=AD=E9=80=90=E6=B8=90=E6=9B=BF=E6=8D=A2=EF=BC=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/HomeCountServiceImpl.java | 159 ++++++++++++++ .../service/impl/PipelineHomeServiceImpl.java | 197 ++++++++++++++++++ .../licence/appauth/model/ApplyAuth.java | 10 + .../licence/appauth/model/ApplyAuthUser.java | 19 ++ .../appauth/model/ApplyAuthUserQuery.java | 16 ++ .../appauth/service/ApplyAuthService.java | 24 +++ .../licence/licence/model/Version.java | 12 ++ .../licence/service/VersionService.java | 7 + .../process/message/MessageNoticeService.java | 36 ++++ .../message/SendMessageNoticeService.java | 14 ++ .../message/message/model/Message.java | 35 ++++ .../message/model/MessageReceiver.java | 10 + .../message/model/SendMessageNotice.java | 25 +++ .../process/message/model/MessageNotice.java | 34 +++ .../model/message/MessageNoticeQuery.java | 19 ++ .../message/model/message/MessageSync.java | 15 ++ .../model/message/MessageTemplate.java | 33 +++ .../model/setting/MessageSendType.java | 11 + .../model/setting/MessageSendTypeQuery.java | 14 ++ .../message/model/setting/MessageType.java | 13 ++ .../setting/MessageSendTypeService.java | 34 +++ .../process/privilege/vRole/model/VRole.java | 11 + .../privilege/vRole/model/VRoleDomain.java | 12 ++ .../security/backups/model/Backups.java | 14 ++ .../backups/service/BackupsDbService.java | 13 ++ .../logging/logging/model/Logging.java | 45 ++++ .../logging/logging/model/LoggingType.java | 13 ++ .../logging/service/LoggingByTempService.java | 9 + .../casic/module/process/user/user/User.java | 19 ++ 29 files changed, 873 insertions(+) create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/home/service/impl/HomeCountServiceImpl.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/home/service/impl/PipelineHomeServiceImpl.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/licence/appauth/model/ApplyAuth.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/licence/appauth/model/ApplyAuthUser.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/licence/appauth/model/ApplyAuthUserQuery.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/licence/appauth/service/ApplyAuthService.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/licence/licence/model/Version.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/licence/licence/service/VersionService.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/MessageNoticeService.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/message/SendMessageNoticeService.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/message/model/Message.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/message/model/MessageReceiver.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/message/model/SendMessageNotice.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/model/MessageNotice.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/model/message/MessageNoticeQuery.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/model/message/MessageSync.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/model/message/MessageTemplate.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/model/setting/MessageSendType.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/model/setting/MessageSendTypeQuery.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/model/setting/MessageType.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/setting/MessageSendTypeService.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/privilege/vRole/model/VRole.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/privilege/vRole/model/VRoleDomain.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/security/backups/model/Backups.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/security/backups/service/BackupsDbService.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/security/logging/logging/model/Logging.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/security/logging/logging/model/LoggingType.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/security/logging/logging/service/LoggingByTempService.java create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/module/process/user/user/User.java diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/home/service/impl/HomeCountServiceImpl.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/home/service/impl/HomeCountServiceImpl.java new file mode 100644 index 0000000..8b65486 --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/home/service/impl/HomeCountServiceImpl.java @@ -0,0 +1,159 @@ +package cd.casic.module.process.home.service.impl; + + +import cd.casic.module.process.home.service.HomeCountService; +import cd.casic.module.process.licence.appauth.service.ApplyAuthService; +import cd.casic.module.process.licence.licence.model.Version; +import cd.casic.module.process.licence.licence.service.VersionService; +import cd.casic.module.process.message.MessageNoticeService; +import cd.casic.module.process.message.setting.MessageSendTypeService; +import cd.casic.module.process.security.backups.service.BackupsDbService; +import cd.casic.module.process.setting.service.*; +import cd.casic.module.process.support.util.util.PipelineFinal; +import jakarta.annotation.Resource; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.util.HashMap; +import java.util.Map; + +@Service +public class HomeCountServiceImpl implements HomeCountService { + + +// @Resource +// UserService userService; +// +// @Resource +// OrgaService orgaService; +// +// @Resource +// UserDirService userDirService; +// +// @Resource +// UserGroupService userGroupService; +// +// @Resource +// RoleService roleService; + + @Resource + MessageNoticeService noticeService; + + @Resource + MessageSendTypeService sendTypeService; + + @Resource + VersionService versionService; + + @Resource + ApplyAuthService applyAuthService; + + @Resource + BackupsDbService backupsDbService; + + @Resource + EnvService envService; + + @Resource + ScmService scmService; + + @Resource + GroupService groupService; + + @Resource + AuthService authService; + + @Resource + AuthHostService authHostService; + + @Resource + AuthThirdService authThirdService; + + @Resource + AuthHostGroupService authHostGroupService; + + @Override + public Map findCount(){ + + Map map = new HashMap<>(); + // TODO 用户相关先空置 +// Integer userNumber = userService.findUserNumber(); +// map.put("userNumber",userNumber); +// +// Integer orgaNumber = orgaService.findOrgaNumber(); +// map.put("orgaNumber",orgaNumber); +// +// Integer userDirNumber = userDirService.findUserDirNumber(); +// map.put("userDirNumber",userDirNumber); +// +// Integer userGroupNumber = userGroupService.findUserGroupNumber(); +// map.put("userGroupNumber",userGroupNumber); +// +// Integer roleNumber = roleService.findRoleNumber(); +// map.put("roleNumber",roleNumber); + + Integer noticeNumber = noticeService.findNoticeNumber(PipelineFinal.appName); + map.put("noticeNumber",noticeNumber); + + Integer sendTypeNumber = sendTypeService.findSendTypeNumber(); + map.put("sendTypeNumber",sendTypeNumber); + + Version version = versionService.getVersion(); + map.put("version",version.getExpired()); + + Integer applyAuthNumber = applyAuthService.findApplyAuthNumber(); + map.put("applyAuthNumber",applyAuthNumber); + + String lastBackupsTime = backupsDbService.findLastBackupsTime(); + map.put("lastBackupsTime",lastBackupsTime); + + Integer envNumber = envService.findEnvNumber(); + map.put("envNumber",envNumber); + + Integer scmNumber = scmService.findScmNumber(); + map.put("scmNumber",scmNumber); + + Integer groupNumber = groupService.findGroupNumber(); + map.put("groupNumber",groupNumber); + + Integer authNumber = authService.findAuthNumber(); + map.put("authNumber",authNumber); + + Integer hostNumber = authHostService.findHostNumber(); + map.put("hostNumber",hostNumber); + + Integer serverNumber = authThirdService.findAuthServerNumber(); + map.put("serverNumber",serverNumber); + + Integer hostGroupNumber = authHostGroupService.findHostGroupNumber(); + map.put("hostGroupNumber",hostGroupNumber); + + return map; + } + + + +} + + + + + + + + + + + + + + + + + + + + + + + diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/home/service/impl/PipelineHomeServiceImpl.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/home/service/impl/PipelineHomeServiceImpl.java new file mode 100644 index 0000000..e8b1991 --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/home/service/impl/PipelineHomeServiceImpl.java @@ -0,0 +1,197 @@ +package cd.casic.module.process.home.service.impl; + +import cd.casic.ci.commons.bean.process.definition.Pipeline; +import cd.casic.module.process.home.service.PipelineHomeService; +import cd.casic.module.process.message.message.SendMessageNoticeService; +import cd.casic.module.process.message.message.model.Message; +import cd.casic.module.process.message.message.model.MessageReceiver; +import cd.casic.module.process.message.message.model.SendMessageNotice; +import cd.casic.module.process.message.model.setting.MessageType; +import cd.casic.module.process.security.logging.logging.model.Logging; +import cd.casic.module.process.security.logging.logging.model.LoggingType; +import cd.casic.module.process.security.logging.logging.service.LoggingByTempService; +import cd.casic.module.process.support.util.util.PipelineFinal; +import cd.casic.module.process.user.user.User; +import com.alibaba.fastjson.JSONObject; +import jakarta.annotation.Resource; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; + +import java.util.*; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.Executors; + +public class PipelineHomeServiceImpl implements PipelineHomeService { +// @Resource +// UserService userService; + + @Resource + LoggingByTempService logService; + + @Resource + SendMessageNoticeService dispatchNoticeService; + + @Value("${base.url:null}") + String baseUrl; + + String appName = PipelineFinal.appName; + + private final Logger logger = LoggerFactory.getLogger(this.getClass()); + + public final ExecutorService executorService = Executors.newCachedThreadPool(); + + /** + * 初始化消息，日志信息 + * @param pipeline 流水线 + * @return 信息 + */ + @Override + public HashMap initMap(Pipeline pipeline){ + HashMap map = new HashMap<>(); + // TODO 整合成我们自己的用户体系 +// String userId = LoginContext.getLoginId(); +// if (Objects.isNull(userId)){ +// userId = pipeline.getUser().getId(); +// } +// User user = userService.findOne(userId); +// map.put("pipelineId", pipeline.getId()); +// map.put("pipelineName", pipeline.getName()); +// map.put("userName", user.getName()); +// if (user.getNickname() != null){ +// map.put("userName", user.getNickname()); +// } + return map; + } + + /** + * 创建日志 + * @param logType 日志类型 + * @param map 日志信息 + */ + @Override + public void log(String logType, Map map){ + logger.info("创建日志......"); + executorService.submit(() -> { + try { + Logging log = new Logging(); + + //消息类型 + LoggingType opLogType = new LoggingType(); + opLogType.setId(logType); + log.setActionType(opLogType); + log.setModule("pipeline"); + +// //用户信息 +// String userId = LoginContext.getLoginId(); +// User user = userService.findOne(userId); + + String link = (String) map.get("link"); + String pipelineName = (String) map.get("pipelineName"); + +// log.setUser(user); + log.setLink(link); + log.setAction(pipelineName); + log.setBaseUrl(baseUrl); + log.setBgroup(appName); + log.setData(JSONObject.toJSONString(map)); + + logService.createLog(log); + }catch (Exception e){ + logger.error("日志创建失败:{}",e.getMessage()); + } + }); + } + + /** + * 配置全局消息 + * @param templateId 方案id + * @param map 信息 + */ + @Override + public void settingMessage(String templateId,Map map){ + logger.info("发送消息......"); + executorService.submit(() -> { + try { + String link = (String) map.get("link"); + map.put("qywxurl", link); + SendMessageNotice dispatchNotice = new SendMessageNotice(); + dispatchNotice.setId(templateId); + String jsonString = JSONObject.toJSONString(map); + dispatchNotice.setEmailData(jsonString); + dispatchNotice.setDingdingData(jsonString); + dispatchNotice.setSiteData(jsonString); + dispatchNotice.setQywechatData(jsonString); + dispatchNotice.setBaseUrl(baseUrl); + String pipelineName = (String) map.get("pipelineName"); + dispatchNotice.setLink(link); + dispatchNotice.setAction(pipelineName); + // TODO 替换成系统自带的上下文 +// dispatchNotice.setSendId(LoginContext.getLoginId()); + if (!Objects.isNull(map.get("dmMessage")) && (Boolean)map.get("dmMessage")){ + String pipelineId = (String) map.get("pipelineId"); + dispatchNotice.setDomainId(pipelineId); + dispatchNoticeService.sendDmMessageNotice(dispatchNotice); + }else { + dispatchNoticeService.sendMessageNotice(dispatchNotice); + } + }catch (Exception e){ + logger.error(e.getMessage()); + }; + }); + + + } + + /** + * 发送消息（指定类型） + * @param receiver 接收信息 + * @param map 信息 + */ + @Override + public void message(Map map, List receiver){ + logger.info("发送指定类型消息......"); + Message message = new Message(); + + String sendWay = (String)map.get("sendWay"); + String mesType = (String)map.get("mesType"); + + //消息类型 + MessageType messageType = new MessageType(); + messageType.setId(mesType); + message.setMessageType(messageType); + + //发送方式 + message.setMessageSendTypeId(sendWay); + message.setData(map); + message.setBaseUrl(baseUrl); + + List list = new ArrayList<>(); + for (String s : receiver) { + MessageReceiver messageReceiver = new MessageReceiver(); + messageReceiver.setUserId(s); + messageReceiver.setPhone(s); + messageReceiver.setEmail(s); + list.add(messageReceiver); + } + message.setMessageReceiverList(list); +// message.setSendId(LoginContext.getLoginId()); + String pipelineName = (String) map.get("pipelineName"); + message.setAction(pipelineName); + dispatchNoticeService.sendMessage(message); + } + + + + /** + * 发送短信 + * @param map 短信内容 + */ + @Override + public void smsMessage(Map map){ + + } + + +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/licence/appauth/model/ApplyAuth.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/licence/appauth/model/ApplyAuth.java new file mode 100644 index 0000000..2075c25 --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/licence/appauth/model/ApplyAuth.java @@ -0,0 +1,10 @@ +package cd.casic.module.process.licence.appauth.model; + +import java.util.List; + +public class ApplyAuth { + private Integer userNumber; + private Integer residueNumber; + private Integer allUserNumber; + private List userList; +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/licence/appauth/model/ApplyAuthUser.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/licence/appauth/model/ApplyAuthUser.java new file mode 100644 index 0000000..5de1048 --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/licence/appauth/model/ApplyAuthUser.java @@ -0,0 +1,19 @@ +package cd.casic.module.process.licence.appauth.model; + +import cd.casic.module.process.user.user.User; +import jakarta.validation.constraints.NotNull; + +public class ApplyAuthUser { + private String id; + @NotNull +// @Mappings({@Mapping( +// source = "user.id", +// target = "userId" +// )}) +// @JoinQuery( +// key = "id" +// ) + private User user; + private Integer type; + private String state; +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/licence/appauth/model/ApplyAuthUserQuery.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/licence/appauth/model/ApplyAuthUserQuery.java new file mode 100644 index 0000000..f3db92a --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/licence/appauth/model/ApplyAuthUserQuery.java @@ -0,0 +1,16 @@ +package cd.casic.module.process.licence.appauth.model; + +import cd.casic.ci.commons.bean.order.Order; +import cd.casic.ci.commons.bean.order.OrderBuilders; +import cd.casic.framework.commons.pojo.PageParam; +import lombok.Data; + +import java.util.List; +@Data +public class ApplyAuthUserQuery { + private String id; + private String userId; + private String state; + private List orderParams = OrderBuilders.instance().desc("id").get(); + private PageParam pageParam = new PageParam(); +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/licence/appauth/service/ApplyAuthService.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/licence/appauth/service/ApplyAuthService.java new file mode 100644 index 0000000..7636954 --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/licence/appauth/service/ApplyAuthService.java @@ -0,0 +1,24 @@ +package cd.casic.module.process.licence.appauth.service; + +import cd.casic.framework.commons.pojo.PageResult; +import cd.casic.module.process.licence.appauth.model.ApplyAuth; +import cd.casic.module.process.licence.appauth.model.ApplyAuthUser; +import cd.casic.module.process.licence.appauth.model.ApplyAuthUserQuery; + +public interface ApplyAuthService { + ApplyAuth findApplyAuth(); + + Integer findApplyAuthNumber(); + + void createUserApplyAuth(String var1, String var2); + + void addUserApplyAuth(String var1); + + void deleteUserApplyAuth(String var1); + + String findUserApplyAuth(String var1); + + void removeUserApplyAuth(String var1); + + PageResult findApplyAuthPage(ApplyAuthUserQuery var1); +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/licence/licence/model/Version.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/licence/licence/model/Version.java new file mode 100644 index 0000000..bb22ef5 --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/licence/licence/model/Version.java @@ -0,0 +1,12 @@ +package cd.casic.module.process.licence.licence.model; + +import jakarta.validation.constraints.NotNull; +import lombok.Data; + +@Data +public class Version { + @NotNull + private Integer release; + @NotNull + private Boolean expired; +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/licence/licence/service/VersionService.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/licence/licence/service/VersionService.java new file mode 100644 index 0000000..49d54bf --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/licence/licence/service/VersionService.java @@ -0,0 +1,7 @@ +package cd.casic.module.process.licence.licence.service; + +import cd.casic.module.process.licence.licence.model.Version; + +public interface VersionService { + Version getVersion(); +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/MessageNoticeService.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/MessageNoticeService.java new file mode 100644 index 0000000..6be76c8 --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/MessageNoticeService.java @@ -0,0 +1,36 @@ +package cd.casic.module.process.message; + +import cd.casic.framework.commons.pojo.PageResult; +import cd.casic.module.process.message.model.MessageNotice; +import cd.casic.module.process.message.model.message.MessageNoticeQuery; +import cd.casic.module.process.message.model.message.MessageSync; +import jakarta.validation.Valid; +import jakarta.validation.constraints.NotNull; + +import java.util.List; + +public interface MessageNoticeService { + String createMessageNotice(@NotNull @Valid MessageNotice var1); + + String cloneMessageNotice(String var1); + + void updateMessageNotice(@NotNull @Valid MessageNotice var1); + + void deleteMessageNotice(@NotNull String var1); + +// @FindOne + MessageNotice findOne(@NotNull String var1); + +// @FindList + List findList(List var1); + + void updateMessageNoticeState(String var1); + + List findMessageNoticeList(MessageNoticeQuery var1); + + PageResult findMessageNoticePage(MessageNoticeQuery var1); + + void syncMessageNotice(MessageSync var1); + + Integer findNoticeNumber(String var1); +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/message/SendMessageNoticeService.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/message/SendMessageNoticeService.java new file mode 100644 index 0000000..9f2e741 --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/message/SendMessageNoticeService.java @@ -0,0 +1,14 @@ +package cd.casic.module.process.message.message; + +import cd.casic.module.process.message.message.model.Message; +import cd.casic.module.process.message.message.model.SendMessageNotice; +import jakarta.validation.Valid; +import jakarta.validation.constraints.NotNull; + +public interface SendMessageNoticeService { + String sendMessageNotice(@NotNull @Valid SendMessageNotice var1); + + String sendDmMessageNotice(SendMessageNotice var1); + + String sendMessage(Message var1); +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/message/model/Message.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/message/model/Message.java new file mode 100644 index 0000000..fe7c1e3 --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/message/model/Message.java @@ -0,0 +1,35 @@ +package cd.casic.module.process.message.message.model; + +import cd.casic.module.process.message.model.setting.MessageType; +import jakarta.validation.constraints.NotNull; +import lombok.Data; + +import java.util.ArrayList; +import java.util.List; +import java.util.Map; +@Data +public class Message { + private String id; + @NotNull +// @Mappings({@Mapping( +// source = "messageType.id", +// target = "messageTypeId" +// )}) +// @JoinQuery( +// key = "id" +// ) + private MessageType messageType; + @NotNull + private String baseUrl; + private String messageSendTypeId; + private Map data; + private List messageReceiverList = new ArrayList(); + private String link; + private String action; + private String sendId; + private String receiverName; + private String receiverAccent; + private String sendUserName; + private String sendUserAccent; + private String otherMessage; +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/message/model/MessageReceiver.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/message/model/MessageReceiver.java new file mode 100644 index 0000000..b7895ba --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/message/model/MessageReceiver.java @@ -0,0 +1,10 @@ +package cd.casic.module.process.message.message.model; + +import lombok.Data; + +@Data +public class MessageReceiver { + private String userId; + private String phone; + private String email; +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/message/model/SendMessageNotice.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/message/model/SendMessageNotice.java new file mode 100644 index 0000000..4f89619 --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/message/model/SendMessageNotice.java @@ -0,0 +1,25 @@ +package cd.casic.module.process.message.message.model; + +import cd.casic.module.process.privilege.vRole.model.VRoleDomain; +import cd.casic.module.process.user.user.User; +import jakarta.validation.constraints.NotNull; +import lombok.Data; + +import java.util.List; +@Data +public class SendMessageNotice { + private String id; + private String siteData; + private String emailData; + private String qywechatData; + private String dingdingData; + private String appData; + private String domainId; + private VRoleDomain vRoleDomain = new VRoleDomain(); + @NotNull + private String baseUrl; + private String link; + private String action; + private String sendId; + private List userList; +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/model/MessageNotice.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/model/MessageNotice.java new file mode 100644 index 0000000..455966a --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/model/MessageNotice.java @@ -0,0 +1,34 @@ +package cd.casic.module.process.message.model; + +import cd.casic.module.process.message.model.setting.MessageType; +import jakarta.validation.constraints.NotNull; +import lombok.Data; + +import java.util.List; + +@Data +public class MessageNotice { + private String id; + @NotNull +// @Mappings({@Mapping( +// source = "messageType.id", +// target = "messageTypeId" +// )}) +// @JoinQuery( +// key = "id" +// ) + private MessageType messageType; + @NotNull + private Integer type; + @NotNull + private String bgroup; + private int scope = 1; + @NotNull + private String messageSendTypeId; + private Boolean open; + private List sendTypeList; + private List groupList; + private List orgaList; + private List userList; + private List roleList; +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/model/message/MessageNoticeQuery.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/model/message/MessageNoticeQuery.java new file mode 100644 index 0000000..90a31dd --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/model/message/MessageNoticeQuery.java @@ -0,0 +1,19 @@ +package cd.casic.module.process.message.model.message; + +import cd.casic.ci.commons.bean.order.Order; +import cd.casic.ci.commons.bean.order.OrderBuilders; +import cd.casic.framework.commons.pojo.PageParam; +import lombok.Data; + +import java.io.Serializable; +import java.util.List; +@Data +public class MessageNoticeQuery implements Serializable { + private String messageTypeId; + private String messageSendTypeId; + private Integer type; + private int scope = 1; + private String bgroup; + private List orderParams = OrderBuilders.instance().desc("type").get(); + private PageParam pageParam = new PageParam(); +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/model/message/MessageSync.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/model/message/MessageSync.java new file mode 100644 index 0000000..fd6e034 --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/model/message/MessageSync.java @@ -0,0 +1,15 @@ +package cd.casic.module.process.message.model.message; + +import cd.casic.module.process.message.model.MessageNotice; +import cd.casic.module.process.message.model.setting.MessageType; +import lombok.Data; + +import java.util.List; +@Data +public class MessageSync { + private String id; + private String bGroup; + private List messageTemplateList; + private List messageTypeList; + private List messageNoticeList; +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/model/message/MessageTemplate.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/model/message/MessageTemplate.java new file mode 100644 index 0000000..edc1ffd --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/model/message/MessageTemplate.java @@ -0,0 +1,33 @@ +package cd.casic.module.process.message.model.message; + +import cd.casic.module.process.message.model.setting.MessageType; +import jakarta.validation.constraints.NotNull; +import lombok.Data; + +@Data +public class MessageTemplate { + private String id; + @NotNull +// @Mappings({@Mapping( +// source = "msgType.id", +// target = "msgTypeId" +// )}) +// @JoinQuery( +// key = "id" +// ) + private MessageType msgType; + @NotNull +// @Mappings({@Mapping( +// source = "msgSendType.id", +// target = "msgSendTypeId" +// )}) +// @JoinQuery( +// key = "id" +// ) + private MessageSendType msgSendType; + private String title; + private String content; + private String link; + private String linkParams; + private String bgroup; +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/model/setting/MessageSendType.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/model/setting/MessageSendType.java new file mode 100644 index 0000000..9f96e0d --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/model/setting/MessageSendType.java @@ -0,0 +1,11 @@ +package cd.casic.module.process.message.model.setting; + +import jakarta.validation.constraints.NotNull; + +public class MessageSendType { + @NotNull + private String id; + @NotNull + private String name; + private String desc; +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/model/setting/MessageSendTypeQuery.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/model/setting/MessageSendTypeQuery.java new file mode 100644 index 0000000..1fda200 --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/model/setting/MessageSendTypeQuery.java @@ -0,0 +1,14 @@ +package cd.casic.module.process.message.model.setting; + +import cd.casic.ci.commons.bean.order.Order; +import cd.casic.ci.commons.bean.order.OrderBuilders; +import cd.casic.framework.commons.pojo.PageParam; +import lombok.Data; + +import java.util.List; +@Data +public class MessageSendTypeQuery { + private String name; + private List orderParams = OrderBuilders.instance().asc("name").get(); + private PageParam pageParam = new PageParam(); +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/model/setting/MessageType.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/model/setting/MessageType.java new file mode 100644 index 0000000..330ff11 --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/model/setting/MessageType.java @@ -0,0 +1,13 @@ +package cd.casic.module.process.message.model.setting; + +import jakarta.validation.constraints.NotNull; +import lombok.Data; + +@Data +public class MessageType { + private String id; + @NotNull + private String name; + private String desc; + private String bgroup; +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/setting/MessageSendTypeService.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/setting/MessageSendTypeService.java new file mode 100644 index 0000000..38558ac --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/message/setting/MessageSendTypeService.java @@ -0,0 +1,34 @@ +package cd.casic.module.process.message.setting; + +import cd.casic.framework.commons.pojo.PageResult; +import cd.casic.module.process.message.model.setting.MessageSendType; +import cd.casic.module.process.message.model.setting.MessageSendTypeQuery; +import jakarta.validation.Valid; +import jakarta.validation.constraints.NotNull; + +import java.util.List; + +public interface MessageSendTypeService { + String createMessageSendType(@NotNull @Valid MessageSendType var1); + + void updateMessageSendType(@NotNull @Valid MessageSendType var1); + + void deleteMessageSendType(@NotNull String var1); + +// @FindOne + MessageSendType findOne(@NotNull String var1); + +// @FindList + List findList(List var1); + + MessageSendType findMessageSendType(@NotNull String var1); + +// @FindAll + List findAllMessageSendType(); + + List findMessageSendTypeList(MessageSendTypeQuery var1); + + PageResult findMessageSendTypePage(MessageSendTypeQuery var1); + + Integer findSendTypeNumber(); +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/privilege/vRole/model/VRole.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/privilege/vRole/model/VRole.java new file mode 100644 index 0000000..bbdc073 --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/privilege/vRole/model/VRole.java @@ -0,0 +1,11 @@ +package cd.casic.module.process.privilege.vRole.model; + +import lombok.Data; + +@Data +public class VRole { + private String id; + private String name; + private String des; + private Integer type; +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/privilege/vRole/model/VRoleDomain.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/privilege/vRole/model/VRoleDomain.java new file mode 100644 index 0000000..a0336e9 --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/privilege/vRole/model/VRoleDomain.java @@ -0,0 +1,12 @@ +package cd.casic.module.process.privilege.vRole.model; + +import lombok.Data; + +import java.util.List; +@Data +public class VRoleDomain { + private List vRoleList; + private String domainId; + private String type; + private String modelId; +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/security/backups/model/Backups.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/security/backups/model/Backups.java new file mode 100644 index 0000000..e31de30 --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/security/backups/model/Backups.java @@ -0,0 +1,14 @@ +package cd.casic.module.process.security.backups.model; + +import lombok.Data; + +@Data +public class Backups { + private String id; + private String type; + private String runState; + private String createTime; + private String dir; + private String log; + private Boolean scheduled; +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/security/backups/service/BackupsDbService.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/security/backups/service/BackupsDbService.java new file mode 100644 index 0000000..1064cbc --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/security/backups/service/BackupsDbService.java @@ -0,0 +1,13 @@ +package cd.casic.module.process.security.backups.service; + +import cd.casic.module.process.security.backups.model.Backups; + +public interface BackupsDbService { + void backups(); + + Backups findBackupsResult(); + + String findLastBackupsTime(); + + void updateBackups(Boolean var1); +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/security/logging/logging/model/Logging.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/security/logging/logging/model/Logging.java new file mode 100644 index 0000000..bc5a092 --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/security/logging/logging/model/Logging.java @@ -0,0 +1,45 @@ +package cd.casic.module.process.security.logging.logging.model; + +import cd.casic.module.process.user.user.User; +import com.fasterxml.jackson.annotation.JsonFormat; +import jakarta.validation.constraints.NotNull; +import lombok.Data; + +import java.sql.Timestamp; +@Data +public class Logging { + private String id; + @NotNull +// @Mappings({@Mapping( +// source = "user.id", +// target = "userId" +// )}) +// @JoinQuery( +// key = "id" +// ) + private User user; + @JsonFormat( + pattern = "yyyy-MM-dd HH:mm:ss", + timezone = "GMT+8" + ) + private Timestamp createTime = new Timestamp(System.currentTimeMillis()); + private String module; + @NotNull +// @Mappings({@Mapping( +// source = "actionType.id", +// target = "actionType" +// )}) +// @JoinQuery( +// key = "id" +// ) + private LoggingType actionType; + @NotNull + private String baseUrl; + private String content; + private String bgroup; + private String data; + @NotNull + private String link; + @NotNull + private String action; +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/security/logging/logging/model/LoggingType.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/security/logging/logging/model/LoggingType.java new file mode 100644 index 0000000..bca127f --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/security/logging/logging/model/LoggingType.java @@ -0,0 +1,13 @@ +package cd.casic.module.process.security.logging.logging.model; + +import jakarta.validation.constraints.NotNull; +import lombok.Data; + +@Data +public class LoggingType { + private String id; + @NotNull + private String name; + @NotNull + private String bgroup; +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/security/logging/logging/service/LoggingByTempService.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/security/logging/logging/service/LoggingByTempService.java new file mode 100644 index 0000000..e83033d --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/security/logging/logging/service/LoggingByTempService.java @@ -0,0 +1,9 @@ +package cd.casic.module.process.security.logging.logging.service; + +import cd.casic.module.process.security.logging.logging.model.Logging; +import jakarta.validation.Valid; +import jakarta.validation.constraints.NotNull; + +public interface LoggingByTempService { + String createLog(@NotNull @Valid Logging var1); +} diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/user/user/User.java b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/user/user/User.java new file mode 100644 index 0000000..dab7570 --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/module/process/user/user/User.java @@ -0,0 +1,19 @@ +package cd.casic.module.process.user.user; + +import lombok.Data; + +@Data +public class User { + private String id; + private String name; + private String phone; + private String email; + private String avatar; + private String nickname; + private String dirId; + private String password; + private Integer status; + private Integer type; + private String openId; + private String newPassword; +}