可视化提交(标准)

common/common_utils/src/main/java/com/founder/commonutils/model/newPublicEntity/ztypEntity/AjThKshfxPojo.java

+package com.founder.commonutils.model.newPublicEntity.ztypEntity;
+
+import lombok.Data;
+import org.apache.commons.lang.StringUtils;
+
+import java.lang.reflect.Field;
+import java.util.ArrayList;
+import java.util.HashSet;
+import java.util.List;
+
+/**
+ * @author zzj
+ * @description 案件团伙可视化分析
+ */
+@Data
+public class AjThKshfxPojo {
+	/**
+	 * 节点id
+	 */
+	private String id;
+	/**
+	 * 节点name
+	 */
+	private String name;
+	/**
+	 * 节点value
+	 */
+	private String value;
+	/**
+	 * 节点type,group表示团伙
+	 */
+	private String type;
+	/**
+	 * 子节点集合
+	 */
+	private List<AjThKshfxPojo> children;
+	/**
+	 * 是否高亮
+	 */
+	private boolean red;
+	/**
+	 * 父级类型
+	 */
+	private String parentType;
+	/**
+	 * 父级id
+	 */
+	private String parentId;
+
+	/**
+	 * 父级name(资金流处理双向指向时使用，为节点赋予正确的name值)
+	 */
+	private String parentName;
+
+	/**
+	 * 进出标志(资金流使用：转入、转出)
+	 */
+	private String jcbz;
+
+	/**
+	 * setChildrenList 设置子节点列表
+	 * @param children: 子节点列表
+	 * @author lystar
+	 * 2022/4/22 15:22
+	 */
+	public void setChildrenList(List<AjThKshfxPojo> children) {
+		if (children == null){
+			this.children = new ArrayList<>(0);
+			return;
+		}
+		if (children.isEmpty()){
+			this.children = children;
+			return;
+		}
+		//临时记录表，用于去重保存
+		HashSet<String> temp = new HashSet<>();
+		this.children = new ArrayList<>();
+		for (AjThKshfxPojo child : children) {
+			if (StringUtils.isEmpty(child.getType())){
+				continue;
+			}
+			if (!temp.contains(child.getId())) {
+				//克隆该节点再加入children
+				AjThKshfxPojo ajth = child.cloneAjth();
+				//设置副节点属性
+				ajth.setParentId(this.id);
+				ajth.setParentType(this.type);
+				ajth.setParentName(this.name);
+				temp.add(ajth.getId());
+				this.children.add(ajth);
+			}
+		}
+	}
+
+	/**
+	 * cloneAjth 深拷贝类信息，不拷贝children
+	 * @return org.springblade.founder.hcyprw.entity.AjThKshfxPojo
+	 * @author lystar
+	 * 2022/4/22 15:22
+	 */
+	public AjThKshfxPojo cloneAjth() {
+		AjThKshfxPojo clone = new AjThKshfxPojo();
+		try {
+			Class<AjThKshfxPojo> aClass = AjThKshfxPojo.class;
+			Field[] fields = aClass.getDeclaredFields();
+			for (Field field : fields) {
+				if ("children".equals(field.getName())){
+					continue;
+				}
+				field.setAccessible(true);
+				Object o = field.get(this);
+				if (o != null) {
+					field.set(clone, o);
+				}
+			}
+		} catch (Exception e){
+			e.printStackTrace();
+		}
+		return clone;
+	}
+}

common/common_utils/src/main/java/com/founder/commonutils/model/newPublicEntity/ztypEntity/KsjResultPojo.java

+package com.founder.commonutils.model.newPublicEntity.ztypEntity;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author yangyang
+ * @description 可视化分析
+ */
+@Data
+public class KsjResultPojo {
+	/**
+	 * 节点信息组（去重的）
+	 */
+	private List<Nodes> nodes;
+	/**
+	 * 关联关系组
+	 */
+	private List<Links> links;
+
+	@Data
+	public static class Nodes {
+		/**
+		 节点下面显示的名称，如果需要多个显示，请传
+		 "李xx\n23岁\n前端开发工程师" 单个的话就  "李xx"
+		 */
+		private String id;
+		/**
+		 * 节点信息的唯一值（例如证件号码），节点是否去重就是依据id
+		 */
+		private String lable;
+		/**
+		 * (idcard: 人，aj: 案件，cph：车，sjk：手机，yhk：银行卡)判断节点图片
+		 */
+		private String imgType;
+		/**
+		 * 将节点所有的信息全部放到这个字段中，包括id和label，注意的是，这个对象必须有一个字段imgType(idcard: 人，aj: 案件，cph：车，sjk：手机，yhk：银行卡)判断节点图片
+		 */
+		private Object properties;
+	}
+
+	@Data
+	public static class Links {
+		/**
+		 * 源节点id值
+		 */
+		private String source;
+		/**
+		 * 目标节点id值
+		 */
+		private String target;
+		/**
+		 * 节点连线显示文字
+		 */
+		private String label;
+		/**
+		 * (idcard: 人，aj: 案件，cph：车，sjk：手机，yhk：银行卡)判断节点图片
+		 */
+		private String imgType;
+		/**
+		 * 将连线所有的信息全部放到这个字段中，注意事项同上，没有必要字段imgType
+		 */
+		private Object properties;
+	}
+}

service/publicapi/src/main/java/com/founder/publicapi/controller/SkDataOperation/SkTrailController.java

@@ -182,7 +182,6 @@ public class SkTrailController extends ApiController implements ExcelControllerI
     @OperLog(message = "查询轨迹列表信息", operation = OperationType.QUERY)
     public MapRestResult query(@RequestBody SkTrailParam sktrailParam) {
         List<SkTrailVO> list = new ArrayList<>();
-        if("yssj".equals(sktrailParam.getLikeType())){
             //分页
             Page page = new Page(sktrailParam.getPage(), sktrailParam.getPageSize());
             QueryWrapper queryWrapper = new QueryWrapper();
@@ -213,8 +212,6 @@ public class SkTrailController extends ApiController implements ExcelControllerI
                 list.add(new SkTrailVO(skTrail, findByBh(skTrail.getObjectvalue(),skTrail.getObjecttype())));
             }
             return new MapRestResult(200, "OK", page1.getTotal(), list);
-        }
-        return new MapRestResult(200, "OK", 0, "");
     }
 
     @PostMapping("queryTj")

service/publicapi/src/main/java/com/founder/publicapi/controller/ZtypService/ZtypController.java

@@ -105,22 +105,21 @@ public class ZtypController {
         return R.ok().total(count).rows(records);
     }
 
-   /* @PostMapping("/kshdata")
-    public R kshdata(TbStZtypFwbsh fwbsh){
+    @PostMapping("/kshdata")
+    public MapRestResult kshdata(@RequestBody TbStZtypFwbsh fwbsh){
         try {
             if (StringUtils.isEmpty(fwbsh.getFwbshLb())){
-                return R.error("类别不能为空");
+                return MapRestResult.error("类别不能为空");
             }
-            Map<String, Object> resultMap = ztypService.kshdata(fwbsh);
-            if (null == resultMap){
-                return R.error("类别有误");
+            if (StringUtils.isEmpty(fwbsh.getFwbshHm())){
+                return MapRestResult.error("号码不能为空");
             }
-            return R.ok().data(resultMap);
+            return ztypService.kshdata(fwbsh);
         } catch (Exception e) {
             e.printStackTrace();
-            return R.error(e.getMessage());
+            return MapRestResult.error(e.getMessage());
         }
-    }*/
+    }
     /*@PostMapping("/getThfxAccompliceBythId")
     @ResponseBody
     @ApiOperation(value = "案件团伙分析可视化接口")

service/publicapi/src/main/java/com/founder/publicapi/service/ZtypService.java

@@ -46,7 +46,5 @@ public interface ZtypService{
      * @author lystar
      * 2022/4/24 09:11
      */
-/*
-    Map<String, Object> kshdata(TbStZtypFwbsh fwbsh);
-*/
+    MapRestResult kshdata(TbStZtypFwbsh fwbsh);
 }