From c0ba6b0d452524c0b93dfd66393749af0b3552b2 Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期日, 03 十一月 2024 15:36:48 +0800
Subject: [PATCH] #同步tag
---
src/main/java/com/zy/asrs/entity/param/TagParam.java | 8 ++++
src/main/java/com/zy/asrs/controller/OpenController.java | 11 ++++-
src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java | 57 ++++++++++++++++++++++++++++
3 files changed, 74 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/zy/asrs/controller/OpenController.java b/src/main/java/com/zy/asrs/controller/OpenController.java
index 232f521..8417294 100644
--- a/src/main/java/com/zy/asrs/controller/OpenController.java
+++ b/src/main/java/com/zy/asrs/controller/OpenController.java
@@ -19,6 +19,7 @@
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
+import java.util.Map;
/**
* Created by vincent on 2022/4/8
@@ -42,13 +43,19 @@
@PostMapping("/tagSync/v1")
@AppAuth(memo = "鐗╂枡鍒嗙被鍚屾")
public synchronized R tagSync(@RequestHeader(required = false) String appkey,
- @RequestBody(required = false) List<TagParam> param,
+ @RequestBody(required = false) List<Map<String,String>> param,
HttpServletRequest request) {
auth(appkey, param, request);
if (Cools.isEmpty(param)) {
return R.parse(BaseRes.PARAM);
}
- openService.syncTag(param);
+ ArrayList<TagParam> params = new ArrayList<>();
+ for (Map<String,String> map : param) {
+ TagParam tagParam = new TagParam(map);
+ params.add(tagParam);
+ }
+
+ openService.syncTag(params);
return R.ok();
}
diff --git a/src/main/java/com/zy/asrs/entity/param/TagParam.java b/src/main/java/com/zy/asrs/entity/param/TagParam.java
index 3e1256d..26ec294 100644
--- a/src/main/java/com/zy/asrs/entity/param/TagParam.java
+++ b/src/main/java/com/zy/asrs/entity/param/TagParam.java
@@ -3,6 +3,7 @@
import lombok.Data;
import java.util.List;
+import java.util.Map;
@Data
public class TagParam {
@@ -12,4 +13,11 @@
private String SysActive;
private String ParentName;
+ public TagParam(Map<String, String> map) {
+ this.ItemClassId = map.get("ItemClassId");
+ this.ParentItemClassId = map.get("ParentItemClassId");
+ this.Name = map.get("Name");
+ this.SysActive = map.get("SysActive");
+ this.ParentName = map.get("ParentName");
+ }
}
diff --git a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
index a828246..142597d 100644
--- a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
@@ -705,6 +705,63 @@
throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
}
}
+
+ // 浜岀骇鍒嗙被
+ Tag secTag = tagService.selectOne(new EntityWrapper<Tag>().eq("memo", tag.getItemClassId()));
+ NodeUtils nodeUtils = new NodeUtils();
+ nodeUtils.executePath(priTag.getId());
+ if (secTag == null) {
+ secTag = new Tag(
+ null, // 缂栧彿
+ tag.getName(), // 鍚嶇О
+ priTag.getId(), // 鐖剁骇
+ priTag.getName(), // 鐖剁骇鍚嶇О
+ nodeUtils.path.toString(), // 鍏宠仈璺緞
+ nodeUtils.pathName.toString(), // 鍏宠仈璺緞鍚�
+ 0, // 绫诲瀷
+ null, // 璐熻矗浜�
+ null, // 鍥剧墖
+ null, // 绠�瑕佹弿杩�
+ null, // 鏁伴噺
+ 2, // 绛夌骇
+ null, // 鎺掑簭
+ 1, // 鐘舵��
+ now, // 娣诲姞鏃堕棿
+ null, // 娣诲姞浜哄憳
+ now, // 淇敼鏃堕棿
+ null, // 淇敼浜哄憳
+ tag.getItemClassId() // 澶囨敞
+ );
+ if (tagMapper.insert(secTag) == 0) {
+ throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
+ }
+ }else {
+ secTag.setName(tag.getName());
+ secTag.setParentId(priTag.getId());
+ secTag.setParentName(priTag.getName());
+ secTag.setPath(nodeUtils.path.toString());
+ secTag.setPathName(nodeUtils.pathName.toString());
+ if (tagMapper.updateById(secTag) == 0) {
+ throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
+ }
+
+ List<Tag> tags = tagService.selectList(new EntityWrapper<Tag>().eq("parent_id", secTag.getId()));
+ if (!Cools.isEmpty(tags)) {
+ for (Tag tag1 : tags) {
+ tag1.setPath(nodeUtils.path.toString()+","+secTag.getId());
+ tag1.setPathName(nodeUtils.pathName.toString()+","+secTag.getName());
+ if (tagMapper.updateById(tag1) == 0) {
+ throw new CoolException("鏈嶅姟鍣ㄥ唴閮ㄩ敊璇紝璇疯仈绯荤鐞嗗憳");
+ }
+ }
+ }
+
+
+
+
+ }
+
+
}
});
}
--
Gitblit v1.9.1