可视化提取案件、人员提交

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

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

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

@@ -4,6 +4,8 @@ import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 
+import java.util.List;
+
 /**
  * @author yangyang
  * @date 2022/7/27  --  19:19
@@ -39,4 +41,6 @@ public class TbYwShseTh{
 
 	@ApiModelProperty(value = "每页数")
 	private int  limit;
+
+	List<String> ListBhs;
 }

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

@@ -2,10 +2,13 @@ package com.founder.publicapi.controller.ZtypService;
 
 import com.alibaba.excel.EasyExcel;
 import com.alibaba.excel.read.builder.ExcelReaderBuilder;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
 import com.founder.commonutils.model.newPublicEntity.MapRestResult;
 import com.founder.commonutils.model.newPublicEntity.ztypEntity.*;
 import com.founder.commonutils.util.JwtUser;
 import com.founder.commonutils.util.KeyUtil;
+import com.founder.commonutils.util.StringUtil;
 import com.founder.publicapi.service.KshHdImportListener;
 import com.founder.publicapi.service.KshYhkImportListener;
 import com.founder.publicapi.service.ZtypService;
@@ -22,10 +25,12 @@ import javax.servlet.http.HttpServletRequest;
 import java.io.BufferedInputStream;
 import java.io.IOException;
 import java.io.InputStream;
+import java.lang.reflect.Field;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.stream.Collectors;
 
 @Api(tags = "主题研判管理")
 @RestController
@@ -188,6 +193,49 @@ public class ZtypController {
         }
     }
 
+    @PostMapping("getThgaByKsh")
+    @ApiOperation(value = "查询可视化关联案件信息")
+    @OperLog(message = "查询可视化关联案件信息", operation = OperationType.QUERY)
+    public R getThgaByKsh(@RequestBody KsjResultParams ksjResultParams) {
+        try {
+            List<TbStAsj> ajlist = new ArrayList<>();
+            int count = 0;
+            if(null!=ksjResultParams.getData().getNodes()){
+                List<KsjResultParams.Nodes> listNodes =  ksjResultParams.getData().getNodes();
+                List<String> ListBhs= listNodes.stream().map(KsjResultParams.Nodes::getId).collect(Collectors.toList());
+                TbYwShseTh tbYwShseTh = new TbYwShseTh();
+                tbYwShseTh.setListBhs(ListBhs);
+                ajlist = ztypService.getThgaByKsh(tbYwShseTh);
+            }
+            return R.ok().data("rows", ajlist).data("total", ajlist.size());
+
+        } catch (Exception e) {
+            e.printStackTrace();
+            return R.error(e.getMessage());
+        }
+    }
+
+    @PostMapping("getThxyrByKsh")
+    @ApiOperation(value = "查询可视化关联人员信息")
+    @OperLog(message = "查询可视化关联人员信息", operation = OperationType.QUERY)
+    public R getThxyrByKsh(@RequestBody KsjResultParams ksjResultParams) {
+        try {
+            List<TbXwZbfzxyr> xyrlist = new ArrayList<>();
+            int count = 0;
+            if(null!=ksjResultParams.getData().getNodes()){
+                List<KsjResultParams.Nodes> listNodes =  ksjResultParams.getData().getNodes();
+                List<String> ListBhs= listNodes.stream().map(KsjResultParams.Nodes::getId).collect(Collectors.toList());
+                TbYwShseTh tbYwShseTh = new TbYwShseTh();
+                tbYwShseTh.setListBhs(ListBhs);
+                xyrlist = ztypService.getThxyrByKsh(tbYwShseTh);
+            }
+            return R.ok().data("rows", xyrlist).data("total", xyrlist.size());
+
+        } catch (Exception e) {
+            e.printStackTrace();
+            return R.error(e.getMessage());
+        }
+    }
     @OperLog(message = "获取手机号机主信息",operation = OperationType.QUERY)
     @ApiOperation(value = "获取手机号机主信息")
     @PostMapping("/txxx/getSjhJzxx")

service/publicapi/src/main/java/com/founder/publicapi/mapper/mysqlMapper/ZtypMapper.java

@@ -42,9 +42,15 @@ public interface ZtypMapper{
     //查询团伙关联案件信息数量
     int getThgaByThbhCount(TbYwShseTh tbYwShseTh);
 
+    //查询团伙关联案件信息
+    List<TbStAsj> getThgaByKsh(TbYwShseTh tbYwShseTh);
+
     //查询团伙关联嫌疑人信息
     List<TbXwZbfzxyr> getThxyrByThbh(TbYwShseTh tbYwShseTh);
 
+    //查询团伙关联嫌疑人信息
+    List<TbXwZbfzxyr> getThxyrByKsh(TbYwShseTh tbYwShseTh);
+
     //查询团伙关联嫌疑人信息数量
     int getThxyrByThbhCount(TbYwShseTh tbYwShseTh);
 

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

@@ -54,9 +54,15 @@ public interface ZtypService{
     //查询团伙关联案件信息数量
     int getThgaByThbhCount(TbYwShseTh tbYwShseTh);
 
+    //查询团伙关联案件信息
+    List<TbStAsj> getThgaByKsh(TbYwShseTh tbYwShseTh);
+
     //查询团伙关联嫌疑人信息
     List<TbXwZbfzxyr> getThxyrByThbh(TbYwShseTh tbYwShseTh);
 
+    //查询团伙关联嫌疑人信息
+    List<TbXwZbfzxyr> getThxyrByKsh(TbYwShseTh tbYwShseTh);
+
     //查询团伙关联嫌疑人信息数量
     int getThxyrByThbhCount(TbYwShseTh tbYwShseTh);
 

service/publicapi/src/main/java/com/founder/publicapi/service/serviceimpl/ZtypServiceImpl.java

@@ -924,6 +924,11 @@ public class ZtypServiceImpl implements ZtypService {
     }
 
     @Override
+    public List<TbStAsj> getThgaByKsh(TbYwShseTh tbYwShseTh) {
+        return ztypMapper.getThgaByKsh(tbYwShseTh);
+    }
+
+    @Override
     public List<TbXwZbfzxyr> getThxyrByThbh(TbYwShseTh tbYwShseTh) {
         tbYwShseTh.setPage((tbYwShseTh.getPage()-1)*tbYwShseTh.getLimit());
         tbYwShseTh.setLimit(tbYwShseTh.getLimit());
@@ -931,6 +936,11 @@ public class ZtypServiceImpl implements ZtypService {
     }
 
     @Override
+    public List<TbXwZbfzxyr> getThxyrByKsh(TbYwShseTh tbYwShseTh) {
+        return ztypMapper.getThxyrByKsh(tbYwShseTh);
+    }
+
+    @Override
     public int getThxyrByThbhCount(TbYwShseTh tbYwShseTh) {
         return ztypMapper.getThxyrByThbhCount(tbYwShseTh);
     }