From 8a3d7199725a52b555d46daae5e95cef914c9ab3 Mon Sep 17 00:00:00 2001
From: zqy <2522236926@qq.com>
Date: 星期二, 26 十一月 2024 13:59:43 +0800
Subject: [PATCH] 祖先修改&家谱生日搜索
---
ruoyi-admin/src/main/java/com/ruoyi/web/controller/zhang/ZfAncestorController.java | 50 +++++++++++++---
zhang-content/src/main/java/com/ruoyi/service/impl/ZInfoUserServiceImpl.java | 10 ++-
zhang-content/src/main/java/com/ruoyi/service/ZfAncestorService.java | 2
zhang-content/src/main/java/com/ruoyi/service/impl/ZfAncestorServiceImpl.java | 110 ++++++++++++++++++++++++++++--------
4 files changed, 132 insertions(+), 40 deletions(-)
diff --git a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/zhang/ZfAncestorController.java b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/zhang/ZfAncestorController.java
index 8e276dc..eace39e 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/web/controller/zhang/ZfAncestorController.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/web/controller/zhang/ZfAncestorController.java
@@ -176,12 +176,47 @@
*/
@Log(title = "绁栧厛", businessType = BusinessType.UPDATE)
@PutMapping
- public AjaxResult edit(@RequestBody ZfAncestor zfAncestor) {
+ public AjaxResult edit(@RequestBody AncestorHelper ancestorHelper) {
- ZfAncestor spouseSex = zfAncestorService.update(zfAncestor);
- updateAncestor(zfAncestor);
- if (spouseSex.getId() != null)
- updateAncestor(spouseSex);
+// ZfAncestor spouseSex = zfAncestorService.update(zfAncestor);
+// updateAncestor(zfAncestor);
+// if (spouseSex.getId() != null)
+// updateAncestor(spouseSex);
+
+ //淇敼sys_user琛�
+ SysUser us = new SysUser();
+ us.setNickName(ancestorHelper.getName());
+ // us.setStatus(String.valueOf(zfAncestor.getStatus()));
+ us.setSex(String.valueOf(ancestorHelper.getSex()));
+ us.setUserName(ancestorHelper.getName());
+// us.setClanId(ancestorHelper.getClanId());
+ us.setUserId(ancestorHelper.getSysId());
+
+ if (!userService.checkNickNameUnique(us)) {
+ return error("淇敼绁栧厛'" + us.getNickName() + "'澶辫触锛岀櫥褰曡处鍙峰凡瀛樺湪");
+ }
+ userService.updateUser(us);
+
+
+ //淇敼z_info_user琛�
+ ZInfoUser infoUser = new ZInfoUser();
+ infoUser.setSysId(us.getUserId());
+ infoUser.setNickName(us.getNickName());
+ infoUser.setOldName(us.getUserName());
+ infoUser.setSex(Integer.parseInt(us.getSex()));
+ ZInfoUser infoBysysId = zInfoUserService.getInfoBysysId(us.getUserId());
+ infoUser.setUserId(infoBysysId.getUserId());
+
+ zInfoUserService.saveOrUpdate(infoUser);
+
+ //淇敼zf_ancestor琛�
+ ZfAncestor zfAncestor = new ZfAncestor();
+// zfAncestor.setClanId(ancestorHelper.getClanId());
+ zfAncestor.setName(ancestorHelper.getName());
+ zfAncestor.setSex(ancestorHelper.getSex());
+ zfAncestor.setSysId(ancestorHelper.getSysId());
+
+ zfAncestorService.update(zfAncestor);
return AjaxResult.success();
}
@@ -307,10 +342,6 @@
zfAncestor1.setStatus(0);
zfAncestor1.setSysId(usa.getUserId());
zfAncestorService.addData(zfAncestor1);
-
-
-
-
}
else{
//淇濆瓨绁栧厛绠＄悊鍛�,涔熷厛淇濆瓨鍒皊ys_user
@@ -351,7 +382,6 @@
zfAncestor.setSysId(us.getUserId());
zfAncestorService.addData(zfAncestor);
-
}
diff --git a/zhang-content/src/main/java/com/ruoyi/service/ZfAncestorService.java b/zhang-content/src/main/java/com/ruoyi/service/ZfAncestorService.java
index 57cc54f..7e398ca 100644
--- a/zhang-content/src/main/java/com/ruoyi/service/ZfAncestorService.java
+++ b/zhang-content/src/main/java/com/ruoyi/service/ZfAncestorService.java
@@ -23,7 +23,7 @@
AjaxResult deleteData(Integer clanId, Integer id);
- ZfAncestor update(ZfAncestor zfAncestor);
+ AjaxResult update(ZfAncestor zfAncestor);
ZfAncestor selectZfAncestor(ZfAncestor zfAncestor);
diff --git a/zhang-content/src/main/java/com/ruoyi/service/impl/ZInfoUserServiceImpl.java b/zhang-content/src/main/java/com/ruoyi/service/impl/ZInfoUserServiceImpl.java
index 97b8046..3d94165 100644
--- a/zhang-content/src/main/java/com/ruoyi/service/impl/ZInfoUserServiceImpl.java
+++ b/zhang-content/src/main/java/com/ruoyi/service/impl/ZInfoUserServiceImpl.java
@@ -596,11 +596,13 @@
}
}
- if(genealogy.getBirth()!=null&&data.getBirth()!=null){
- if(data.getBirth().compareTo(genealogy.getBirth())!=0){
- it.remove();
- continue;
+ if(genealogy.getBirth()!=null){
+ if(data.getBirth()!=null) {
+ if (data.getBirth().compareTo(genealogy.getBirth()) != 0) {
+ it.remove();
+ }
}
+ else it.remove();
}
}
diff --git a/zhang-content/src/main/java/com/ruoyi/service/impl/ZfAncestorServiceImpl.java b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfAncestorServiceImpl.java
index 8a9342e..cbabd79 100644
--- a/zhang-content/src/main/java/com/ruoyi/service/impl/ZfAncestorServiceImpl.java
+++ b/zhang-content/src/main/java/com/ruoyi/service/impl/ZfAncestorServiceImpl.java
@@ -17,6 +17,7 @@
import com.ruoyi.mapper.ZfAncestorMapper;
import com.ruoyi.service.*;
import org.elasticsearch.action.delete.DeleteRequest;
+import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.beans.factory.annotation.Autowired;
@@ -24,6 +25,7 @@
import javax.annotation.Resource;
import java.io.IOException;
+import java.time.LocalDateTime;
import java.util.*;
@Service
@@ -45,6 +47,9 @@
@Resource
private ZfClanService zfClanService;
+
+ @Resource
+ ZfLogService zfLogService;
private LambdaQueryWrapper<ZfAncestor> buildCondition(ZfAncestor zfAncestor) {
@@ -274,35 +279,90 @@
}
@Override
- public ZfAncestor update(ZfAncestor zfAncestor) {
- LambdaQueryWrapper<ZfAncestor> lqw = uniqueCondition(zfAncestor);
- List<ZfAncestor> list = list(lqw);
+ public AjaxResult update(ZfAncestor zfAncestor) {
+// LambdaQueryWrapper<ZfAncestor> lqw = uniqueCondition(zfAncestor);
+// List<ZfAncestor> list = list(lqw);
// System.out.println(list);
- ZInfoUser updateDate =zInfoUserService.getInfoBysysId(zfAncestor.getSysId());
- ZfAncestor zfAncestor1 = new ZfAncestor();
- ZfAncestor zfAncestor2 = new ZfAncestor();
- zfAncestor1.setId(list.get(0).getId());
- zfAncestor1.setName(zfAncestor.getName());
- System.out.println(updateDate);
- if (zfAncestor.getSex() != null){
- if(updateDate.getSpouseId() != null && updateDate.getSpouseId() != 0){
- Long spouseId=updateDate.getSpouseId();
- if (zInfoUserService.getById(spouseId).getSex().equals(zfAncestor.getSex())){
+// ZInfoUser updateDate =zInfoUserService.getInfoBysysId(zfAncestor.getSysId());
+// ZfAncestor zfAncestor1 = new ZfAncestor();
+// ZfAncestor zfAncestor2 = new ZfAncestor();
+// zfAncestor1.setId(list.get(0).getId());
+// zfAncestor1.setName(zfAncestor.getName());
+// System.out.println(updateDate);
+// if (zfAncestor.getSex() != null){
+// if(updateDate.getSpouseId() != null && updateDate.getSpouseId() != 0){
+// Long spouseId=updateDate.getSpouseId();
+// if (zInfoUserService.getById(spouseId).getSex().equals(zfAncestor.getSex())){
+//
+// Long spouseSysId = zInfoUserService.getById(spouseId).getSysId();
+// zfAncestor2.setSysId(spouseSysId);
+// Integer spId = list(uniqueCondition(zfAncestor2)).get(0).getId();
+// zfAncestor2.setId(spId);
+// zfAncestor2.setSex(zfAncestor.getSex() == 0? 1: 0);
+// System.out.println(zfAncestor2);
+// zfAncestorService.updateById(zfAncestor2);
+// }}
+// zfAncestor1.setSex(zfAncestor.getSex());}
+//// System.out.println("1841vdndigrrr"+zfAncestor1);
+//
+// zfAncestorService.updateById(zfAncestor1);
- Long spouseSysId = zInfoUserService.getById(spouseId).getSysId();
- zfAncestor2.setSysId(spouseSysId);
- Integer spId = list(uniqueCondition(zfAncestor2)).get(0).getId();
- zfAncestor2.setId(spId);
- zfAncestor2.setSex(zfAncestor.getSex() == 0? 1: 0);
- System.out.println(zfAncestor2);
- zfAncestorService.updateById(zfAncestor2);
- }}
- zfAncestor1.setSex(zfAncestor.getSex());}
-// System.out.println("1841vdndigrrr"+zfAncestor1);
+ //鎿嶄綔鍚庡姞鍏ユ棩蹇�
+ ZfLog zfLog = new ZfLog();
+ zfLog.setUpdateTime(LocalDateTime.now());
+ zfLog.setModule("瀹舵棌淇敼");
+ zfLog.setUpdater(zInfoUserService.getMyself().getNickName());
+ zfLogService.save(zfLog);
+ System.out.println("===================================="+zfAncestor);
- zfAncestorService.updateById(zfAncestor1);
+ LambdaQueryWrapper<ZfAncestor> lqw = uniqueCondition(zfAncestor);
+ ZfAncestor zfAncestorList = list(lqw).get(0);
+ zfAncestor.setId(zfAncestorList.getId());
+ System.out.println(zfAncestorList);
+ if(updateById(zfAncestor)){
+ //鍒版暟鎹簱涓煡璇㈠搴旂殑鏁版嵁
+ ZfAncestor dataById = getById(zfAncestor.getId());
+ //鍏堝埌es涓煡璇㈠埌瀵瑰簲閭ｆ潯鏁版嵁鍦╡s鐨刬d
+ EsModel esResult = esSer.findByCtId(dataById.getId(), "瀹舵棌");
+ if (esResult == null){
+ return AjaxResult.success();
+ }
+ System.out.println("-------------------------"+zfAncestor);
+ //鎿嶄綔es淇敼鏁版嵁
+ EsModel newModel = new EsModel();
+// System.out.println(meeting);
+// System.out.println("=============="+meeting.getConnPhone());
+ if(zfAncestor.getSex() != null){
+ newModel.setBy8(zfAncestor.getSex());
+ }else {
+ newModel.setBy8(dataById.getSex());
+ }
- return zfAncestor2;
+ if(zfAncestor.getName() != null){
+ newModel.setBy2(zfAncestor.getName());
+ }else {
+ newModel.setBy2(dataById.getName());
+ }
+
+
+
+ UpdateRequest updateRequest = new UpdateRequest("allsearchdata", esResult.getId());
+ updateRequest.doc(
+ "by1",newModel.getBy8(),
+ "by2",newModel.getBy2()
+
+ );
+
+ try {
+ restHighLevelClient.update(updateRequest, RequestOptions.DEFAULT);
+ } catch (IOException e) {
+ throw new RuntimeException(e);
+ }
+
+ return AjaxResult.success();
+ } else {
+ return AjaxResult.error();
+ }
}
@Override
--
Gitblit v1.9.1