From 75d710137ad9098e36e41f6ce8f2ccde0b6becc4 Mon Sep 17 00:00:00 2001
From: Administrator <admin>
Date: Sat, 21 Aug 2021 20:15:25 +0800
Subject: [PATCH] ftp 数据同步，考试报名，取消，导入同步
---
src/main/java/org/springblade/modules/apply/service/impl/ApplyServiceImpl.java | 42 ++++++++++++++++++++++++++++++++++++++++++
1 files changed, 42 insertions(+), 0 deletions(-)
diff --git a/src/main/java/org/springblade/modules/apply/service/impl/ApplyServiceImpl.java b/src/main/java/org/springblade/modules/apply/service/impl/ApplyServiceImpl.java
index 1cbeef8..cbc1d89 100644
--- a/src/main/java/org/springblade/modules/apply/service/impl/ApplyServiceImpl.java
+++ b/src/main/java/org/springblade/modules/apply/service/impl/ApplyServiceImpl.java
@@ -1,6 +1,7 @@
package org.springblade.modules.apply.service.impl;
+import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import lombok.AllArgsConstructor;
@@ -12,6 +13,8 @@
import org.springblade.common.utils.arg;
import org.springblade.core.mp.support.Condition;
import org.springblade.core.tool.api.R;
+import org.springblade.modules.FTP.FtpUtil;
+import org.springblade.modules.FTP.OutJson;
import org.springblade.modules.apply.entity.Apply;
import org.springblade.modules.apply.excel.ApplyExcel;
import org.springblade.modules.apply.excel.ApplyInfoExcel;
@@ -30,9 +33,15 @@
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.FileNotFoundException;
import java.text.DecimalFormat;
import java.text.SimpleDateFormat;
import java.util.*;
+
+import static org.springblade.common.constant.FtpConstant.*;
+import static org.springblade.common.constant.FtpConstant.fileName;
/**
* 考试报名服务实现类
@@ -116,6 +125,22 @@
//修改保安报名状态
user1.setIsApply(1);
userService.updateById(user1);
+
+ String formatStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
+ Long id = apply1.getId();
+ String s = "insert into sys_apply(id,user_id,apply_time,apply_status,is_exam) " +
+ "values(" + "'" + id + "'" + "," + "'" + apply1.getUserId() + "'" + "," + "'" + formatStr +
+ "'" + "," + "'" + apply1.getApplyStatus() + "'" + "," +"'" + apply1.getIsExam() + "'" + ");" +
+ "update blade_user set is_apply = " + "'" + user1.getIsApply() + "'" +"where id = " + "'" + user1.getId() + "'";
+ String json = JSON.toJSONString(s);
+ OutJson.createJsonFile(json, "d:/", "wsql");
+ FileInputStream in = null;
+ try {
+ in = new FileInputStream(new File("D:\\" + fileName));
+ } catch (FileNotFoundException e) {
+ e.printStackTrace();
+ }
+ FtpUtil.uploadFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", "/", fileName, in);
}else {
if (user1.getIsApply()!=1) {
Apply apply1 = new Apply();
@@ -128,6 +153,23 @@
//修改保安报名状态
user1.setIsApply(1);
userService.updateById(user1);
+
+ //内网数据同步
+ String formatStr = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
+ Long id = apply1.getId();
+ String s = "insert into sys_apply(id,user_id,apply_time,apply_status,is_exam) " +
+ "values(" + "'" + id + "'" + "," + "'" + apply1.getUserId() + "'" + "," + "'" + formatStr +
+ "'" + "," + "'" + apply1.getApplyStatus() + "'" + "," +"'" + apply1.getIsExam() + "'" + ");" +
+ "update blade_user set is_apply = " + "'" + user1.getIsApply() + "'" +"where id = " + "'" + user1.getId() + "'";
+ String json = JSON.toJSONString(s);
+ OutJson.createJsonFile(json, "d:/", "wsql");
+ FileInputStream in = null;
+ try {
+ in = new FileInputStream(new File("D:\\" + fileName));
+ } catch (FileNotFoundException e) {
+ e.printStackTrace();
+ }
+ FtpUtil.uploadFile(ftpHost, ftpPort, ftpUserName, ftpPassword, "anbao/", "/", fileName, in);
}
}
}
--
Gitblit v1.9.3