lanyuanxiaoyao/leopard
1
0
Fork 0
Code Activity

Compare commits

base: lanyuanxiaoyao:33fc47df87b31d62a2e5a0a730b813cf62b21c5f
Branches Tags
lanyuanxiaoyao:master
...
compare: lanyuanxiaoyao:efd7f5e9f23f7c1a9e083cf9ca37af3056be4908
Branches Tags
lanyuanxiaoyao:master

4 Commits
33fc47df87 ... efd7f5e9f2

Author SHA1 Message Date
lanyuanxiaoyao
efd7f5e9f2 feat: liteflow任务保存到数据库 2025-09-11 00:13:09 +08:00
lanyuanxiaoyao
ced4cde3e3 fix: 避免日志无限增长 2025-09-10 23:39:19 +08:00
lanyuanxiaoyao
5669fd3aa7 feat: 本地调试使用测试表 2025-09-10 23:38:53 +08:00
lanyuanxiaoyao
74eac6f825 feat: 增加财务报表表 2025-09-10 23:38:32 +08:00
12 changed files with 170 additions and 9 deletions
Expand all files Collapse all files

32
leopard-core/src/main/java/com/lanyuanxiaoyao/leopard/core/entity/BalanceSheet.java Normal file
View File

@@ -0,0 +1,32 @@
package com.lanyuanxiaoyao.leopard.core.entity;
import com.lanyuanxiaoyao.leopard.core.Constants;
import com.lanyuanxiaoyao.service.template.entity.SimpleEntity;
import jakarta.persistence.Entity;
import jakarta.persistence.EntityListeners;
import jakarta.persistence.ManyToOne;
import jakarta.persistence.Table;
import lombok.Getter;
import lombok.Setter;
import lombok.ToString;
import lombok.experimental.FieldNameConstants;
import org.hibernate.annotations.DynamicInsert;
import org.hibernate.annotations.DynamicUpdate;
import org.springframework.data.jpa.domain.support.AuditingEntityListener;
/**
* 资产负债表
*/
@Setter
@Getter
@ToString(callSuper = true)
@FieldNameConstants
@Entity
@DynamicUpdate
@DynamicInsert
@EntityListeners(AuditingEntityListener.class)
@Table(name = Constants.DATABASE_PREFIX + "balance_sheet")
public class BalanceSheet extends SimpleEntity {
@ManyToOne
private Stock stock;
}

32
leopard-core/src/main/java/com/lanyuanxiaoyao/leopard/core/entity/CashFlow.java Normal file
View File

@@ -0,0 +1,32 @@
package com.lanyuanxiaoyao.leopard.core.entity;
import com.lanyuanxiaoyao.leopard.core.Constants;
import com.lanyuanxiaoyao.service.template.entity.SimpleEntity;
import jakarta.persistence.Entity;
import jakarta.persistence.EntityListeners;
import jakarta.persistence.ManyToOne;
import jakarta.persistence.Table;
import lombok.Getter;
import lombok.Setter;
import lombok.ToString;
import lombok.experimental.FieldNameConstants;
import org.hibernate.annotations.DynamicInsert;
import org.hibernate.annotations.DynamicUpdate;
import org.springframework.data.jpa.domain.support.AuditingEntityListener;
/**
* 现金流量表
*/
@Setter
@Getter
@ToString(callSuper = true)
@FieldNameConstants
@Entity
@DynamicUpdate
@DynamicInsert
@EntityListeners(AuditingEntityListener.class)
@Table(name = Constants.DATABASE_PREFIX + "cash_flow")
public class CashFlow extends SimpleEntity {
@ManyToOne
private Stock stock;
}

32
leopard-core/src/main/java/com/lanyuanxiaoyao/leopard/core/entity/Income.java Normal file
View File

@@ -0,0 +1,32 @@
package com.lanyuanxiaoyao.leopard.core.entity;
import com.lanyuanxiaoyao.leopard.core.Constants;
import com.lanyuanxiaoyao.service.template.entity.SimpleEntity;
import jakarta.persistence.Entity;
import jakarta.persistence.EntityListeners;
import jakarta.persistence.ManyToOne;
import jakarta.persistence.Table;
import lombok.Getter;
import lombok.Setter;
import lombok.ToString;
import lombok.experimental.FieldNameConstants;
import org.hibernate.annotations.DynamicInsert;
import org.hibernate.annotations.DynamicUpdate;
import org.springframework.data.jpa.domain.support.AuditingEntityListener;
/**
* 利润表
*/
@Setter
@Getter
@ToString(callSuper = true)
@FieldNameConstants
@Entity
@DynamicUpdate
@DynamicInsert
@EntityListeners(AuditingEntityListener.class)
@Table(name = Constants.DATABASE_PREFIX + "income")
public class Income extends SimpleEntity {
@ManyToOne
private Stock stock;
}

12
leopard-core/src/main/java/com/lanyuanxiaoyao/leopard/core/entity/Stock.java
View File

@@ -62,6 +62,18 @@ public class Stock extends SimpleEntity {
@ToString.Exclude
private Set<Daily> dailies;
@OneToMany(mappedBy = "stock", cascade = CascadeType.REMOVE)
@ToString.Exclude
private Set<Income> incomes;
@OneToMany(mappedBy = "stock", cascade = CascadeType.REMOVE)
@ToString.Exclude
private Set<BalanceSheet> balanceSheets;
@OneToMany(mappedBy = "stock", cascade = CascadeType.REMOVE)
@ToString.Exclude
private Set<CashFlow> cashFlows;
@ManyToMany
@ToString.Exclude
private Set<StockCollection> collections;

4
leopard-core/src/main/java/com/lanyuanxiaoyao/leopard/core/entity/TaskTemplate.java
View File

@@ -29,5 +29,9 @@ public class TaskTemplate extends SimpleEntity {
@Column(nullable = false, length = 500)
private String description;
@Column(nullable = false)
private String application;
@Column(nullable = false)
private String chain;
@Column(nullable = false)
private String expression;
}

4
leopard-server/pom.xml
View File

@@ -45,6 +45,10 @@
<groupId>com.yomahub</groupId>
<artifactId>liteflow-spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>com.yomahub</groupId>
<artifactId>liteflow-rule-sql</artifactId>
</dependency>
<dependency>
<groupId>cn.hutool</groupId>

13
leopard-server/src/main/java/com/lanyuanxiaoyao/leopard/server/controller/TaskTemplateController.java
View File

@@ -1,10 +1,12 @@
package com.lanyuanxiaoyao.leopard.server.controller;
import cn.hutool.core.util.IdUtil;
import com.lanyuanxiaoyao.leopard.core.entity.TaskTemplate;
import com.lanyuanxiaoyao.leopard.server.service.TaskTemplateService;
import com.lanyuanxiaoyao.service.template.controller.SimpleControllerSupport;
import java.util.function.Function;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@@ -12,6 +14,9 @@ import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("task_template")
public class TaskTemplateController extends SimpleControllerSupport<TaskTemplate, TaskTemplateController.Item, TaskTemplateController.Item, TaskTemplateController.Item> {
@Value("${spring.application.name}")
private String application;
public TaskTemplateController(TaskTemplateService service) {
super(service);
}
@@ -23,7 +28,9 @@ public class TaskTemplateController extends SimpleControllerSupport<TaskTemplate
template.setId(item.id());
template.setName(item.name());
template.setDescription(item.description());
template.setChain(item.chain());
template.setApplication(application);
template.setChain(IdUtil.simpleUUID());
template.setExpression(item.expression());
return template;
};
}
@@ -33,7 +40,7 @@ public class TaskTemplateController extends SimpleControllerSupport<TaskTemplate
template.getId(),
template.getName(),
template.getDescription(),
template.getChain()
template.getExpression()
);
}
@@ -51,7 +58,7 @@ public class TaskTemplateController extends SimpleControllerSupport<TaskTemplate
Long id,
String name,
String description,
String chain
String expression
) {
}
}

26
leopard-server/src/main/java/com/lanyuanxiaoyao/leopard/server/service/TaskTemplateService.java
View File

@@ -3,6 +3,7 @@ package com.lanyuanxiaoyao.leopard.server.service;
import com.lanyuanxiaoyao.leopard.core.entity.TaskTemplate;
import com.lanyuanxiaoyao.leopard.core.repository.TaskTemplateRepository;
import com.lanyuanxiaoyao.service.template.service.SimpleServiceSupport;
import com.yomahub.liteflow.meta.LiteflowMetaOperator;
import org.springframework.stereotype.Service;
@Service
@@ -10,4 +11,29 @@ public class TaskTemplateService extends SimpleServiceSupport<TaskTemplate> {
public TaskTemplateService(TaskTemplateRepository repository) {
super(repository);
}
@Override
public Long save(TaskTemplate entity) {
Long id = super.save(entity);
LiteflowMetaOperator.reloadAllChain();
return id;
}
@Override
public void save(Iterable<TaskTemplate> taskTemplates) {
super.save(taskTemplates);
LiteflowMetaOperator.reloadAllChain();
}
@Override
public void remove(Iterable<Long> ids) {
super.remove(ids);
LiteflowMetaOperator.reloadAllChain();
}
@Override
public void remove(Long id) {
super.remove(id);
LiteflowMetaOperator.reloadAllChain();
}
}

12
leopard-server/src/main/resources/application.yml
View File

@@ -11,7 +11,7 @@ spring:
datasource:
# url: jdbc:mysql://mysql.lanyuanxiaoyao.com:43780/leopard?useSSL=false
# url: jdbc:mysql://192.168.31.127:3780/leopard?useSSL=false
url: jdbc:postgresql://81.71.3.24:6785/leopard
url: jdbc:postgresql://81.71.3.24:6785/leopard_dev
username: leopard
password: '9NEzFzovnddf@PyEP?e*AYAWnCyd7UhYwQK$pJf>7?ccFiN^x4$eKEZ5~E<7<+~X'
# driver-class-name: com.mysql.cj.jdbc.Driver
@@ -37,5 +37,11 @@ fenix:
print-banner: false
liteflow:
print-banner: false
rule-source: flow.xml
check-node-exists: false
check-node-exists: false
rule-source-ext-data-map:
applicationName: ${spring.application.name}
sqlLogEnabled: true
chainTableName: leopard_task_template
chainApplicationNameField: application
chainNameField: chain
elDataField: expression

3
leopard-server/src/main/resources/logback-spring.xml
View File

@@ -20,6 +20,7 @@
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<fileNamePattern>${LOGGING_PARENT:-.}/archive/${APP_NAME:-run}-%d{yyyy-MM-dd}.gz</fileNamePattern>
<MaxHistory>7</MaxHistory>
<totalSizeCap>5GB</totalSizeCap>
</rollingPolicy>
<encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} %p [${HOSTNAME}] [%t] %logger: %m%n%wEx</pattern>
@@ -27,7 +28,7 @@
</appender>
<logger name="com.zaxxer.hikari" level="ERROR"/>
<!--<logger name="org.hibernate.SQL" level="DEBUG"/>-->
<logger name="org.hibernate.SQL" level="DEBUG"/>
<root level="INFO">
<appender-ref ref="Console"/>

4
leopard-web/src/pages/task/TaskTemplateSave.tsx
View File

@@ -55,8 +55,8 @@ function TaskTemplateSave() {
},
{
type: 'input-text',
name: 'chain',
label: '流程编号',
name: 'expression',
label: 'EL表达式',
required: true,
clearable: true,
},

5
pom.xml
View File

@@ -68,6 +68,11 @@
<artifactId>liteflow-spring-boot-starter</artifactId>
<version>${liteflow.version}</version>
</dependency>
<dependency>
<groupId>com.yomahub</groupId>
<artifactId>liteflow-rule-sql</artifactId>
<version>${liteflow.version}</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>