From 8853292babb2ad94de4a3207966f1e83b767cd2d Mon Sep 17 00:00:00 2001
From: zhongrj <646384940@qq.com>
Date: Sun, 17 Sep 2023 16:38:34 +0800
Subject: [PATCH] 新增流程节点进程查询接口

---
 src/main/java/org/springblade/modules/member/controller/MemberController.java |   53 +++++++++++++++++++++++++++++++++++------------------
 1 files changed, 35 insertions(+), 18 deletions(-)

diff --git a/src/main/java/org/springblade/modules/member/controller/MemberController.java b/src/main/java/org/springblade/modules/member/controller/MemberController.java
index 31d2d1f..c78d2c5 100644
--- a/src/main/java/org/springblade/modules/member/controller/MemberController.java
+++ b/src/main/java/org/springblade/modules/member/controller/MemberController.java
@@ -38,6 +38,7 @@
 import org.springblade.modules.member.vo.MemberVO;
 import org.springblade.modules.shareholder.excel.shareExcel;
 import org.springblade.modules.shareholder.excel.shareImporter;
+import org.springblade.modules.system.service.MyAsyncService;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
 
@@ -60,6 +61,7 @@
 public class MemberController extends BladeController {
 
 	private final IMemberService memberService;
+	private final MyAsyncService myAsyncService;
 
 	/**
 	 * 详情
@@ -102,15 +104,19 @@
 	@ApiOperation(value = "新增", notes = "传入member")
 	public R save(@Valid @RequestBody Member member) throws Exception {
 		boolean save = memberService.save(member);
-		String s1 =
-			"insert into sys_member(id,name,post,cardid,cell,creditCode) " +
-				"values(" + "'" + member.getId() + "'" + "," +
-				"'" + member.getName() + "'" + "," +
-				"'" + member.getPost() + "'" + "," +
-				"'" + member.getCardid() + "'" + "," +
-				"'" + member.getCell() + "'"+"," +
-				"'" + member.getCreditcode() + "'"+")";
-		FtpUtil.sqlFileUpload(s1);
+		if (save) {
+			String s1 =
+				"insert into sys_member(id,name,post,cardid,cell,creditCode,dept_id) " +
+					"values(" + "'" + member.getId() + "'" + "," +
+					"'" + member.getName() + "'" + "," +
+					"'" + member.getPost() + "'" + "," +
+					"'" + member.getCardid() + "'" + "," +
+					"'" + member.getCell() + "'" + "," +
+					"'" + member.getCreditcode() + "'" + "," +
+					"'" + member.getDeptId() + "'" + ")";
+			//FtpUtil.sqlFileUpload(s1);
+			myAsyncService.dataSync(s1);
+		}
 		return R.status(save);
 	}
 
@@ -122,14 +128,18 @@
 	@ApiOperation(value = "修改", notes = "传入member")
 	public R update(@Valid @RequestBody Member member) throws Exception {
 		boolean b = memberService.updateById(member);
-		String s1 = "update sys_member set name = " + "'" + member.getName() + "'" +
-			",post = " + "'" + member.getPost() + "'" +
-			",cardid = " + "'" + member.getCardid() + "'" +
-			",cell = " + "'" + member.getCell() + "'" +
-			",cardid = " + "'" + member.getCardid() + "'" +
-			",creditCode = " + "'" + member.getCreditcode() + "'" +
-			" " + "where id = " + "'" + member.getId() + "'";
-		FtpUtil.sqlFileUpload(s1);
+		if (b) {
+			String s1 = "update sys_member set name = " + "'" + member.getName() + "'" +
+				",post = " + "'" + member.getPost() + "'" +
+				",cardid = " + "'" + member.getCardid() + "'" +
+				",cell = " + "'" + member.getCell() + "'" +
+				",cardid = " + "'" + member.getCardid() + "'" +
+				",creditCode = " + "'" + member.getCreditcode() + "'" +
+				",dept_id = " + "'" + member.getDeptId() + "'" +
+				" " + "where id = " + "'" + member.getId() + "'";
+			//FtpUtil.sqlFileUpload(s1);
+			myAsyncService.dataSync(s1);
+		}
 		return R.status(b);
 	}
 
@@ -151,6 +161,13 @@
 	@ApiOperationSupport(order = 8)
 	@ApiOperation(value = "删除", notes = "传入ids")
 	public R remove(@ApiParam(value = "主键集合", required = true) @RequestParam String ids) {
+		//内网同步
+		List<Long> list = Func.toLongList(ids);
+		list.forEach(id -> {
+			String s1 = "delete from sys_member where id = " + "'" + id + "'";
+			//FtpUtil.sqlFileUpload(s1);
+			myAsyncService.dataSync(s1);
+		});
 		return R.status(memberService.removeByIds(Func.toLongList(ids)));
 	}
 
@@ -188,7 +205,7 @@
 	public void exportMember(HttpServletResponse response) {
 		List<memberExcel> list = new ArrayList<>();
 		memberExcel member = new memberExcel();
-		member.setCreditcode("xx12351214112");
+		member.setDeptId("xxx保安服务有限公司");
 		member.setName("张三");
 		member.setPost("经理");
 		member.setCardid("360***********0001");

--
Gitblit v1.9.3