From 62eb499b0c969f246d3245d1429a97da4de1ce28 Mon Sep 17 00:00:00 2001
From: 钟日健 <arsn163@163.com>
Date: Mon, 01 Jun 2026 20:46:13 +0800
Subject: [PATCH] feat: 成绩查询增加年龄查询返回
---
src/main/java/org/springblade/modules/directive/controller/DirectiveController.java | 59 +++++++++++++++++++++++++++++++++++------------------------
1 files changed, 35 insertions(+), 24 deletions(-)
diff --git a/src/main/java/org/springblade/modules/directive/controller/DirectiveController.java b/src/main/java/org/springblade/modules/directive/controller/DirectiveController.java
index 2cbd28e..e05f695 100644
--- a/src/main/java/org/springblade/modules/directive/controller/DirectiveController.java
+++ b/src/main/java/org/springblade/modules/directive/controller/DirectiveController.java
@@ -4,7 +4,7 @@
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import lombok.AllArgsConstructor;
-import org.springblade.common.constant.FtpConstant;
+import org.springblade.common.config.FtpConfig;
import org.springblade.common.utils.arg;
import org.springblade.core.mp.support.Condition;
import org.springblade.core.mp.support.Query;
@@ -15,6 +15,7 @@
import org.springblade.modules.directive.entity.DirectiveFile;
import org.springblade.modules.directive.service.DirectiveService;
import org.springblade.modules.directive.vo.DirectiveVo;
+import org.springblade.modules.system.service.MyAsyncService;
import org.springframework.web.bind.annotation.*;
import java.text.SimpleDateFormat;
@@ -31,6 +32,7 @@
public class DirectiveController {
private final DirectiveService directiveService;
+ private final MyAsyncService myAsyncService;
/**
* 自定义分页
@@ -67,27 +69,31 @@
boolean status = false;
directive.setSendTime(new Date());
status = directiveService.save(directive);
- //数据同步
- String s1 =
- "insert into sys_directive(id,type,send_directive_id,receive_directive_ids,send_time,content) " +
- "values(" + "'" + directive.getId() + "'" + "," +
- "'" + directive.getType() + "'" + "," +
- "'" + directive.getSendDirectiveId() + "'" + "," +
- "'" + directive.getReceiveDirectiveIds() + "'" + "," +
- "'" + directive.getSendTime() + "'" + "," +
- "'" + directive.getContent() + "'" + ")";
- FtpUtil.sqlFileUpload(s1);
+ if (status){
+ //数据同步
+ String s1 =
+ "insert into sys_directive(id,type,send_directive_id,receive_directive_ids,send_time,content) " +
+ "values(" + "'" + directive.getId() + "'" + "," +
+ "'" + directive.getType() + "'" + "," +
+ "'" + directive.getSendDirectiveId() + "'" + "," +
+ "'" + directive.getReceiveDirectiveIds() + "'" + "," +
+ "'" + directive.getSendTime() + "'" + "," +
+ "'" + directive.getContent() + "'" + ")";
+ //FtpUtil.sqlFileUpload(s1);
+ myAsyncService.dataSync(s1);
+ }
if (status) {
//新增图片
if (null != directive.getUrl() && directive.getUrl() != "") {
String[] directiveUrl = directive.getUrl().split(",");
for (String url : directiveUrl) {
String s = url.substring(26, url.length());
- String urls = FtpConstant.ip + s;
+ //内网url
+ String urls = FtpConfig.ip + s;
DirectiveFile directiveFile = new DirectiveFile();
directiveFile.setType(1);
directiveFile.setDirectiveId(directive.getId());
- directiveFile.setUrl(urls);
+ directiveFile.setUrl(url);
status = directiveService.saveDirectiveFile(directiveFile);
String s2 =
"insert into sys_directive_file(id,type,directive_id,url) " +
@@ -95,7 +101,8 @@
"'" + directiveFile.getType() + "'" + "," +
"'" + directiveFile.getDirectiveId() + "'" + "," +
"'" + urls+ "'"+ ")";
- FtpUtil.sqlFileUpload(s2);
+ //FtpUtil.sqlFileUpload(s2);
+ myAsyncService.dataSync(s2);
if (!status) {
return R.status(false);
}
@@ -117,14 +124,17 @@
public R updateDirectiveAndFile(@RequestBody DirectiveVo directive) throws Exception {
//新增指令信息
boolean update = directiveService.updateById(directive);
- //内网同步
- String s1 = "update sys_directive set type = " + "'" + directive.getType() + "'" +
- ",send_directive_id = " + "'" + directive.getSendDirectiveId() + "'" +
- ",receive_directive_ids = " + "'" + directive.getReceiveDirectiveIds() + "'" +
- ",send_time = " + "'" + directive.getSendTime() + "'" +
- ",content = " + "'" + directive.getContent() + "'" +
- " " + "where id = " + "'" + directive.getId() + "'";
- FtpUtil.sqlFileUpload(s1);
+ if (update) {
+ //内网同步
+ String s1 = "update sys_directive set type = " + "'" + directive.getType() + "'" +
+ ",send_directive_id = " + "'" + directive.getSendDirectiveId() + "'" +
+ ",receive_directive_ids = " + "'" + directive.getReceiveDirectiveIds() + "'" +
+ ",send_time = " + "'" + directive.getSendTime() + "'" +
+ ",content = " + "'" + directive.getContent() + "'" +
+ " " + "where id = " + "'" + directive.getId() + "'";
+ //FtpUtil.sqlFileUpload(s1);
+ myAsyncService.dataSync(s1);
+ }
boolean status = false;
if (update) {
//先删除图片
@@ -134,7 +144,7 @@
String[] directiveUrl = directive.getUrl().split(",");
for (String url : directiveUrl) {
String s = url.substring(26, url.length());
- String urls = FtpConstant.ip + s;
+ String urls = FtpConfig.ip + s;
DirectiveFile directiveFile = new DirectiveFile();
directiveFile.setType(1);
directiveFile.setDirectiveId(directive.getId());
@@ -146,7 +156,8 @@
"'" + directiveFile.getType() + "'" + "," +
"'" + directiveFile.getDirectiveId() + "'" + "," +
"'" + urls + "'"+ ")";
- FtpUtil.sqlFileUpload(s2);
+ //FtpUtil.sqlFileUpload(s2);
+ myAsyncService.dataSync(s2);
if (!status) {
R.status(false);
}
--
Gitblit v1.9.3