From 8d43111bd0e598bc0b2014cbfa69a32e74959dff Mon Sep 17 00:00:00 2001
From: Administrator <admin>
Date: Wed, 15 Dec 2021 19:24:05 +0800
Subject: [PATCH] ftp sql 同步封装

---
 src/main/java/org/springblade/modules/accreditation/service/impl/AccreditationRecordsServiceImpl.java |   82 ++++++++++++++++++++++++++++++++++++-----
 1 files changed, 72 insertions(+), 10 deletions(-)

diff --git a/src/main/java/org/springblade/modules/accreditation/service/impl/AccreditationRecordsServiceImpl.java b/src/main/java/org/springblade/modules/accreditation/service/impl/AccreditationRecordsServiceImpl.java
index 73306df..d221fdf 100644
--- a/src/main/java/org/springblade/modules/accreditation/service/impl/AccreditationRecordsServiceImpl.java
+++ b/src/main/java/org/springblade/modules/accreditation/service/impl/AccreditationRecordsServiceImpl.java
@@ -6,6 +6,7 @@
 import lombok.AllArgsConstructor;
 import org.springblade.common.utils.QRCodeUtil;
 import org.springblade.modules.FTP.FtpUtil;
+import org.springblade.modules.accreditation.excel.ExportSecurityBookPaperExcel;
 import org.springblade.modules.accreditation.excel.ExportSecurityPaperExcel;
 import org.springblade.modules.accreditation.entity.AccreditationRecords;
 import org.springblade.modules.accreditation.mapper.AccreditationRecordsMapper;
@@ -57,18 +58,50 @@
 			records.setCreateTime(new Date());
 			records.setCreateUser(accreditationRecords.getCreateUser());
 			records.setStatus(1);
+			records.setAuditStatus(1);
+			records.setType(accreditationRecords.getType());
 			records.setUserId(Long.parseLong(id));
-			//新增
-			this.save(records);
+			//判断类型,如果是上岗证则判断是否有申请,有申请的不在新增记录
+			if (accreditationRecords.getType()==1){
+				//查询当前人员是否有申请记录
+				int count  = baseMapper.getAccreditationRecordsByUserIdCount(id);
+				if (count<1){
+					//新增
+					this.save(records);
 
-			//内网新增
-			String s = "insert into sys_apply(id,user_id,create_time,create_user,status) " +
-				"values(" + "'" + records.getId() + "'" + ","
-				+ "'" + records.getUserId() + "'" + ","
-				+ "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(records.getCreateTime()) + "'" + ","
-				+ "'" + records.getCreateUser() +"'" + ","
-				+"'" + records.getStatus() + "'" + ")";
-			FtpUtil.sqlFileUpload(s);
+					//内网新增
+					String s = "insert into sys_accreditation_records(id,user_id,create_time,create_user,status,type,audit_status) " +
+						"values(" + "'" + records.getId() + "'" + ","
+						+ "'" + records.getUserId() + "'" + ","
+						+ "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(records.getCreateTime()) + "'" + ","
+						+ "'" + records.getCreateUser() +"'" + ","
+						+ "'" + records.getStatus() +"'" + ","
+						+ "'" + records.getType() +"'" + ","
+						+"'" + records.getAuditStatus() + "'" + ")";
+					FtpUtil.sqlFileUpload(s);
+				}
+			}
+			//判断类型,如果是证书的,审核未通过的可以再次申请,审核通过的,暂时不给于新增记录
+			if (accreditationRecords.getType()==2){
+				//查询当前人员是否有待审核和审核通过的记录数
+				int count  = baseMapper.getAccreditationRecordsByUserIdAuditCount(id,2);
+				if (count<1){
+					//新增
+					this.save(records);
+
+					//内网新增
+					String s = "insert into sys_accreditation_records(id,user_id,create_time,create_user,status,type,audit_status) " +
+						"values(" + "'" + records.getId() + "'" + ","
+						+ "'" + records.getUserId() + "'" + ","
+						+ "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(records.getCreateTime()) + "'" + ","
+						+ "'" + records.getCreateUser() +"'" + ","
+						+ "'" + records.getStatus() +"'" + ","
+						+ "'" + records.getType() +"'" + ","
+						+"'" + records.getAuditStatus() + "'" + ")";
+					FtpUtil.sqlFileUpload(s);
+				}
+			}
+
 		});
 		return true;
 	}
@@ -102,6 +135,12 @@
 				excel.setRealName(accreditationRecordsVo.getRealName());
 				excel.setIdCardNo(accreditationRecordsVo.getIdCardNo());
 				excel.setDeptName(accreditationRecordsVo.getDeptName());
+				if (accreditationRecordsVo.getSex().equals("1")){
+					excel.setSex("男");
+				}else {
+					excel.setSex("女");
+				}
+				excel.setPaperTime(new SimpleDateFormat("yyyy-MM-dd").format(new Date()));
 				//如果头像有
 				if (null != accreditationRecordsVo.getAvatar() && accreditationRecordsVo.getAvatar() != "") {
 					try {
@@ -135,4 +174,27 @@
 		}
 		return null;
 	}
+
+	/**
+	 * 导出证书制证信息
+	 * @param accreditationRecords
+	 * @return
+	 */
+	@Override
+	public List<ExportSecurityBookPaperExcel> exportSecurityBookPaper(AccreditationRecordsVo accreditationRecords) {
+		//查询数据
+		List<ExportSecurityBookPaperExcel> accreditationRecordsVos = baseMapper.exportSecurityBookPaper(accreditationRecords);
+		return accreditationRecordsVos;
+	}
+
+	/**
+	 * 导出证书制证信息(包含照片)
+	 */
+	@Override
+	public List<AccreditationRecordsVo> exportSecurityBookPapers(AccreditationRecordsVo accreditationRecords) {
+		//查询数据
+		List<AccreditationRecordsVo> accreditationRecordsVos = baseMapper.exportSecurityBookPapers(accreditationRecords);
+//		System.out.println("accreditationRecordsVos = " + accreditationRecordsVos.size());
+		return accreditationRecordsVos;
+	}
 }

--
Gitblit v1.9.3