Skip to content

G
gong-an
Commit fa8898b2 authored by wuqinghua's avatar wuqinghua
Browse files
Options

吴卿华-2021/11/11 公安经侦代码

parents
Expand all Hide whitespace changes
Inline Side-by-side
Showing with 2940 additions and 0 deletions
.gitignore 0 → 100644
View file @ fa8898b2
HELP.md
target/
!.mvn/wrapper/maven-wrapper.jar
!**/src/main/**/target/
!**/src/test/**/target/
### STS ###
.apt_generated
.classpath
.factorypath
.project
.settings
.springBeans
.sts4-cache
### IntelliJ IDEA ###
.idea
*.iws
*.iml
*.ipr
### NetBeans ###
/nbproject/private/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/
build/
!**/src/main/**/build/
!**/src/test/**/build/
### VS Code ###
.vscode/
.mvn/wrapper/MavenWrapperDownloader.java 0 → 100644
View file @ fa8898b2
/*
* Copyright 2007-present the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* https://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
import java.net.*;
import java.io.*;
import java.nio.channels.*;
import java.util.Properties;
public class MavenWrapperDownloader {
private static final String WRAPPER_VERSION = "0.5.6";
/**
* Default URL to download the maven-wrapper.jar from, if no 'downloadUrl' is provided.
*/
private static final String DEFAULT_DOWNLOAD_URL = "https://repo.maven.apache.org/maven2/io/takari/maven-wrapper/"
+ WRAPPER_VERSION + "/maven-wrapper-" + WRAPPER_VERSION + ".jar";
/**
* Path to the maven-wrapper.properties file, which might contain a downloadUrl property to
* use instead of the default one.
*/
private static final String MAVEN_WRAPPER_PROPERTIES_PATH =
".mvn/wrapper/maven-wrapper.properties";
/**
* Path where the maven-wrapper.jar will be saved to.
*/
private static final String MAVEN_WRAPPER_JAR_PATH =
".mvn/wrapper/maven-wrapper.jar";
/**
* Name of the property which should be used to override the default download url for the wrapper.
*/
private static final String PROPERTY_NAME_WRAPPER_URL = "wrapperUrl";
public static void main(String args[]) {
System.out.println("- Downloader started");
File baseDirectory = new File(args[0]);
System.out.println("- Using base directory: " + baseDirectory.getAbsolutePath());
// If the maven-wrapper.properties exists, read it and check if it contains a custom
// wrapperUrl parameter.
File mavenWrapperPropertyFile = new File(baseDirectory, MAVEN_WRAPPER_PROPERTIES_PATH);
String url = DEFAULT_DOWNLOAD_URL;
if (mavenWrapperPropertyFile.exists()) {
FileInputStream mavenWrapperPropertyFileInputStream = null;
try {
mavenWrapperPropertyFileInputStream = new FileInputStream(mavenWrapperPropertyFile);
Properties mavenWrapperProperties = new Properties();
mavenWrapperProperties.load(mavenWrapperPropertyFileInputStream);
url = mavenWrapperProperties.getProperty(PROPERTY_NAME_WRAPPER_URL, url);
} catch (IOException e) {
System.out.println("- ERROR loading '" + MAVEN_WRAPPER_PROPERTIES_PATH + "'");
} finally {
try {
if (mavenWrapperPropertyFileInputStream != null) {
mavenWrapperPropertyFileInputStream.close();
}
} catch (IOException e) {
// Ignore ...
}
}
}
System.out.println("- Downloading from: " + url);
File outputFile = new File(baseDirectory.getAbsolutePath(), MAVEN_WRAPPER_JAR_PATH);
if (!outputFile.getParentFile().exists()) {
if (!outputFile.getParentFile().mkdirs()) {
System.out.println(
"- ERROR creating output directory '" + outputFile.getParentFile().getAbsolutePath() + "'");
}
}
System.out.println("- Downloading to: " + outputFile.getAbsolutePath());
try {
downloadFileFromURL(url, outputFile);
System.out.println("Done");
System.exit(0);
} catch (Throwable e) {
System.out.println("- Error downloading");
e.printStackTrace();
System.exit(1);
}
}
private static void downloadFileFromURL(String urlString, File destination) throws Exception {
if (System.getenv("MVNW_USERNAME") != null && System.getenv("MVNW_PASSWORD") != null) {
String username = System.getenv("MVNW_USERNAME");
char[] password = System.getenv("MVNW_PASSWORD").toCharArray();
Authenticator.setDefault(new Authenticator() {
@Override
protected PasswordAuthentication getPasswordAuthentication() {
return new PasswordAuthentication(username, password);
}
});
}
URL website = new URL(urlString);
ReadableByteChannel rbc;
rbc = Channels.newChannel(website.openStream());
FileOutputStream fos = new FileOutputStream(destination);
fos.getChannel().transferFrom(rbc, 0, Long.MAX_VALUE);
fos.close();
rbc.close();
}
}
.mvn/wrapper/maven-wrapper.properties 0 → 100644
View file @ fa8898b2
distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.8.1/apache-maven-3.8.1-bin.zip
wrapperUrl=https://repo.maven.apache.org/maven2/io/takari/maven-wrapper/0.5.6/maven-wrapper-0.5.6.jar
pom.xml 0 → 100644
View file @ fa8898b2
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.4.0</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.example</groupId>
<artifactId>gajz</artifactId>
<version>0.0.1</version>
<name>gajz</name>
<description>Demo project for Spring Boot</description>
<properties>
<java.version>1.8</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-thymeleaf</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<!-- mybatis数据库依赖-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>1.3.2</version>
</dependency>
<dependency>
<groupId>org.mybatis.generator</groupId>
<artifactId>mybatis-generator-core</artifactId>
<version>1.3.5</version>
</dependency>
<!--数据库连接池依赖 druid数据库连接池 阿里巴巴-->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.1.8</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.19</version>
</dependency>
<dependency>
<groupId>org.assertj</groupId>
<artifactId>assertj-core</artifactId>
</dependency>
<dependency>
<groupId>net.bytebuddy</groupId>
<artifactId>byte-buddy</artifactId>
</dependency>
<!--接口参数校验依赖-->
<dependency>
<groupId>javax.validation</groupId>
<artifactId>validation-api</artifactId>
<version>2.0.1.Final</version>
</dependency>
<dependency>
<groupId>org.hibernate.validator</groupId>
<artifactId>hibernate-validator</artifactId>
<version>6.0.7.Final</version>
</dependency>
<!--百度图数据库 HugeGraph-Client 依赖-->
<dependency>
<groupId>com.baidu.hugegraph</groupId>
<artifactId>hugegraph-client</artifactId>
<version>1.9.1</version>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
<!--Springboot热部署-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-devtools</artifactId>
<scope>runtime</scope>
</dependency>
<!--easyExcel依赖-->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>easyexcel</artifactId>
<version>2.2.7</version>
</dependency>
<!-- Neo4j dependency -->
<dependency>
<groupId>org.neo4j</groupId>
<artifactId>neo4j</artifactId>
<version>3.2.6</version>
</dependency>
<dependency>
<groupId>org.neo4j.driver</groupId>
<artifactId>neo4j-java-driver</artifactId>
<version>4.3.4</version>
</dependency>
<!-- https://mvnrepository.com/artifact/redis.clients/jedis -->
<!--Redis-->
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>3.0.0</version>
</dependency>
<!-- 整合redis -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<!-- <version>3.5.1</version> -->
<configuration>
<compilerArgs>
<!-- 过期的方法的警告-->
<arg>-Xlint:deprecation</arg>
</compilerArgs>
<compilerArguments>
<!-- 是否输出所有的编译信息（包括类的加载等）-->
<!--<verbose />-->
<!-- 解决maven命令编译报错，因为rt.jar 和jce.jar在jre的lib下面，不在jdk的lib下面，
导致maven找不到（java7以后会出现这个问题），将这2个jar包拷贝到jdk的lib下面估计也好使-->
<bootclasspath>${java.home}\lib\rt.jar;${java.home}\lib\jce.jar</bootclasspath>
</compilerArguments>
</configuration>
</plugin>
</plugins>
<resources>
<resource>
<directory>src/main/resources</directory>
</resource>
<resource>
<directory>src/main/java</directory>
<includes>
<include>**/*.properties</include>
<include>**/*.xml</include>
</includes>
<filtering>false</filtering>
</resource>
</resources>
</build>
</project>
src/main/java/com/example/gajz/GajzApplication.java 0 → 100644
View file @ fa8898b2
package com.example.gajz;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class GajzApplication {
public static void main(String[] args) {
SpringApplication.run(GajzApplication.class, args);
System.out.println("启动完成");
}
}
src/main/java/com/example/gajz/redis/ConFigRedis.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.redis;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
/**
* redis连接池
* @author lenovo
*/
public class ConFigRedis {
private static JedisPool pool = null;
/**
* 获取jedis连接池
* */
public static JedisPool getPool(){
if(pool == null){
//创建jedis连接池配置
JedisPoolConfig config = new JedisPoolConfig();
//最大连接数
config.setMaxTotal(100);
//最大空闲连接
config.setMaxIdle(20);
//创建redis连接池
/**服务器*/
// pool = new JedisPool(config,"127.0.0.1",6379,30000,"1qaz2wsx3edc");
/**本地*/
pool = new JedisPool(config,"127.0.0.1",6379,30000);
}
return pool;
}
/**
* 获取jedis连接
* */
public static Jedis getConn()
{
return getPool().getResource();
}
}
src/main/java/com/example/gajz/result/Result.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.result;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data //提供getter、setter方法
@NoArgsConstructor //无参构造
public class Result {
private boolean success;
private Integer code;
private String message;
private Object data;
//不需要返回数据时使用
public Result(ResultCode code) {
this.success = code.success;
this.code = code.code;
this.message = code.message;
}
public Result(ResultCode code,Object data) {
this.success = code.success;
this.code = code.code;
this.message = code.message;
this.data = data;
}
public Result(Integer code,String message,boolean success) {
this.code = code;
this.message = message;
this.success = success;
}
/*
* 调用ResultCode类封装常用的返回数据
*/
public static Result SUCCESS(){
return new Result(ResultCode.SUCCESS);
}
public static Result ERROR(){
return new Result(ResultCode.SERVER_ERROR);
}
public static Result FAIL(){
return new Result(ResultCode.FAIL);
}
}
src/main/java/com/example/gajz/result/ResultCode.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.result;
/**
* 公共的返回码
* 返回码code：
* 成功：200
* 失败：500
* 未登录：10002
* 未授权：10003
* 抛出异常：99999
*/
public enum ResultCode {
SUCCESS(true,200,"成功"),
//---系统错误返回码-----
FAIL(false,500,"失败"),
UNAUTHENTICATED(false,10002,"您还未登录"),
UNAUTHORISE(false,10003,"权限不足"),
SERVER_ERROR(false,99999,"抱歉，系统繁忙，请稍后重试！"),
//---用户操作返回码 2xxxx----
MOBILEORPASSWORDERROR(false,20001,"用户名或密码错误");
//---企业操作返回码 3xxxx----
//---权限操作返回码----
//---其他操作返回码----
//操作是否成功
boolean success;
//操作代码
int code;
//提示信息
String message;
ResultCode(boolean success,int code, String message){
this.success = success;
this.code = code;
this.message = message;
}
public boolean success() {
return success;
}
public int code() {
return code;
}
public String message() {
return message;
}
}
src/main/java/com/example/gajz/transferrelationship/bean/dto/Source.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.bean.dto;
import lombok.Data;
import lombok.ToString;
/**
* @author lenovo
*/
@Data
@ToString
public class Source {
private String id;
}
src/main/java/com/example/gajz/transferrelationship/bean/dto/Target.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.bean.dto;
import lombok.Data;
import lombok.ToString;
/**
* @author lenovo
*/
@Data
@ToString
public class Target {
private String id;
}
src/main/java/com/example/gajz/transferrelationship/bean/dto/TransferRelationship.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.bean.dto;
import lombok.Data;
import lombok.ToString;
/**
* @author lenovo
*/
@Data
@ToString
public class TransferRelationship {
private Source source;
private Target target;
private TransferTimes TransferTimes;
}
src/main/java/com/example/gajz/transferrelationship/bean/dto/TransferTimes.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.bean.dto;
import lombok.Data;
import lombok.ToString;
/**
* 转账次数
*/
@Data
@ToString
public class TransferTimes {
/**
* 转账次数
*/
private int transferTimes;
/**
* 线大小
*/
private double lineSize;
}
src/main/java/com/example/gajz/transferrelationship/bean/dto/data.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.bean.dto;
import lombok.Data;
import lombok.ToString;
@Data
@ToString
public class data {
private String id;
private String name;
private String source;
}
src/main/java/com/example/gajz/transferrelationship/bean/excel/abcExcie.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.bean.excel;
import com.alibaba.excel.annotation.ExcelProperty;
import lombok.Data;
import lombok.ToString;
import java.math.BigDecimal;
import java.sql.Timestamp;
import java.time.DateTimeException;
import java.util.Date;
/**
* 转账关系图Excel封装类
*/
@Data
@ToString
public class abcExcie {
/**
* 主键
*/
@ExcelProperty(value = "id",index = 0)
private int id;
/**
* 身份证号
*/
@ExcelProperty(value = "id_card",index = 1)
private String id_card;
/**
* 手机号
*/
@ExcelProperty(value = "mobile",index = 2)
private String mobile;
/**
* 本端账户名
*/
@ExcelProperty(value = "bank_account_name",index = 3)
private String bank_account_name;
/**
* 本端账号
*/
@ExcelProperty(value = "bank_account_no",index = 4)
private String bank_account_no;
/**
* 本端卡号
*/
@ExcelProperty(value = "bank_card_no",index = 5)
private String bank_card_no;
/**
* 曾用卡号
*/
@ExcelProperty(value = "temp_a",index = 6)
private String temp_a;
/**
* 本端账户开户行
*/
@ExcelProperty(value = "bank_name",index = 7)
private String bank_name;
/**
* 是否属资金池,0是1否
*/
@ExcelProperty(value = "is_capital_pool",index = 8)
private int is_capital_pool;
/**
* 交易时间
*/
@ExcelProperty(value = "trade_date",index = 9)
private String trade_date;
/**
* 记账时间
*/
@ExcelProperty(value = "trade_time",index = 10)
private String trade_time;
/**
* 收付标志，0收1支
*/
@ExcelProperty(value = "payment_mark",index = 11)
private int payment_mark;
/**
* 借方发生额（支出）
*/
@ExcelProperty(value = "temp_c",index = 12)
private BigDecimal temp_c;
/**
* 贷方发生额（收入）
*/
@ExcelProperty(value = "temp_d",index = 13)
private BigDecimal temp_d;
/**
* 交易金额
*/
@ExcelProperty(value = "pay_amount",index = 14)
private BigDecimal pay_amount;
/**
* 余额
*/
@ExcelProperty(value = "balance",index = 15)
private BigDecimal balance;
/**
* 目的、用途
*/
@ExcelProperty(value = "purpose",index = 16)
private int purpose;
/**
* 分红性质类别
*/
@ExcelProperty(value = "bonus",index = 17)
private int bonus;
/**
* 其他交易性质
*/
@ExcelProperty(value = "trade_nature",index = 18)
private int trade_nature;
/**
* 审计备注列1
*/
@ExcelProperty(value = "temp_f",index = 19)
private String temp_f;
/**
* 审计备注列2
*/
@ExcelProperty(value = "temp_g",index = 20)
private String temp_g;
/**
* 对端户名
*/
@ExcelProperty(value = "end_account_name",index = 21)
private String end_account_name;
/**
* 对端卡号
*/
@ExcelProperty(value = "end_card_no",index = 22)
private String end_card_no;
/**
* 对端开户行
*/
@ExcelProperty(value = "end_bank_name",index = 23)
private String end_bank_name;
/**
* 交易摘要
*/
@ExcelProperty(value = "remark",index = 24)
private String remark;
/**
* 交易备注
*/
@ExcelProperty(value = "comment",index = 25)
private String comment;
/**
* 交易场所
*/
@ExcelProperty(value = "treade_place",index = 26)
private String treade_place;
}
src/main/java/com/example/gajz/transferrelationship/bean/param/Dot.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.bean.param;
import lombok.Data;
import lombok.ToString;
/**
* 关系图 点参数封装类
*/
@Data
@ToString
public class Dot {
/**
* 圆点 转账人 接收人卡号
*/
private String id;
/**
* 圆点 转账人 接收人姓名
*/
private String name;
/**
* 圆点颜色
*/
private String color;
/**
* 圆点x轴
*/
private int x;
/**
* 圆点y轴
*/
private int y;
/**
* 圆点大小
*/
private double size;
/**
* 转账次数
*/
private int TransferTimes;
/**
* 上级卡号
*/
private String relationship;
}
src/main/java/com/example/gajz/transferrelationship/bean/param/TransferAssociationParam.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.bean.param;
import lombok.Data;
import lombok.ToString;
/**
* 查询两人转账关系 (关系图) 接口参数封装类
*/
@Data
@ToString
public class TransferAssociationParam {
/**
* 转账人
*/
private String transfer;
/**
* 收款人
*/
private String payee;
}
src/main/java/com/example/gajz/transferrelationship/bean/param/data.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.bean.param;
import lombok.Data;
import lombok.ToString;
@Data
@ToString
public class data {
/**
* 转账人
*/
private String source;
/**
* 收款人
*/
private String target;
/**
* 收款人姓名
*/
private String name;
/**
* 转账次数
*/
private int transferTimes;
}
src/main/java/com/example/gajz/transferrelationship/bean/vo/EchartsUserVo.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.bean.vo;
import lombok.Data;
import lombok.ToString;
/**
* echarts转账人 接收人 返回值封装类
* @author lenovo
*/
@Data
@ToString
public class EchartsUserVo {
/**
* 点 id
*/
private String name;
/**
* x轴
*/
private int x;
/**
* y轴
*/
private int y;
}
src/main/java/com/example/gajz/transferrelationship/bean/vo/RelationshipVo.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.bean.vo;
import com.example.gajz.transferrelationship.bean.dto.data;
import lombok.Data;
import lombok.ToString;
/**
* @author lenovo
*/
@Data
@ToString
public class RelationshipVo {
private data data;
// private String group;
// private String classes;
}
src/main/java/com/example/gajz/transferrelationship/bean/vo/SearchRelationshipVo.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.bean.vo;
import lombok.Data;
import lombok.ToString;
/**
* 关系图搜索接口返回值封装类
*/
@Data
@ToString
public class SearchRelationshipVo {
/**
* 转账关系
*/
private String relationship;
/**
* 姓名
*/
private String name;
/**
* 卡号
*/
private String cardNumber;
/**
* 是否拥有下级
*/
private Boolean subordinate;
/**
* 转账次数
*/
private int transferTimes;
/**
* 圆点颜色
*/
private String color;
/**
* 圆点大小
*/
private int size;
/**
* x轴
*/
private int x;
/**
* y轴
*/
private int y;
/**
* 层级
*/
private int hierarchy;
/**
* 下级数量
*/
private int subordinateQuantity;
}
src/main/java/com/example/gajz/transferrelationship/bean/vo/Test.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.bean.vo;
import lombok.Data;
import lombok.ToString;
/**
*
* @author lenovo
*/
@Data
@ToString
public class Test {
/**
* 圆点 转账人 接收人卡号
*/
private String id;
/**
* 圆点 转账人 接收人姓名
*/
private String name;
/**
* 圆点颜色
*/
private String color;
/**
* 圆点x轴
*/
private int x;
/**
* 圆点y轴
*/
private int y;
/**
* 圆点大小
*/
private double size;
}
src/main/java/com/example/gajz/transferrelationship/bean/vo/TransferCardVo.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.bean.vo;
import lombok.Data;
import lombok.ToString;
/**
* 转账卡号返回值封装类
* @author lenovo
*/
@Data
@ToString
public class TransferCardVo {
/**
* 卡号
*/
private String bankCardNo;
/**
* 姓名
*/
private String name;
}
src/main/java/com/example/gajz/transferrelationship/bean/vo/TransferRelationshipVo.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.bean.vo;
import lombok.Data;
import lombok.ToString;
/**
* 转账关系封装类
* @author lenovo
*/
@Data
@ToString
public class TransferRelationshipVo {
private com.example.gajz.transferrelationship.bean.param.data data;
}
src/main/java/com/example/gajz/transferrelationship/bean/vo/TransferredPersonVo.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.bean.vo;
import lombok.Data;
/**
* 被转账人信息封装类
* @author lenovo
*/
@Data
public class TransferredPersonVo {
/**
* id
*/
private int id;
/**
* 转账人卡号
*/
private long bankCardNo;
/**
* 被转账人卡号
*/
private String endCardNo;
/**
* 转账次数（集合个数）
*/
private String number;
}
src/main/java/com/example/gajz/transferrelationship/bean/vo/personalTransferRelationshipVo.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.bean.vo;
import lombok.Data;
import lombok.ToString;
/**
* 查询单人转账关系返回值封装类
*/
@Data
@ToString
public class personalTransferRelationshipVo {
/**
* 转账人
*/
private String source;
/**
* 收款人
*/
private String target;
/**
* 转账次数
*/
private int transferTimes;
}
src/main/java/com/example/gajz/transferrelationship/dao/TransferRelationshipMapper.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.dao;
import com.example.gajz.transferrelationship.bean.excel.abcExcie;
import com.example.gajz.transferrelationship.bean.vo.SearchRelationshipVo;
import com.example.gajz.transferrelationship.bean.vo.TransferCardVo;
import com.example.gajz.transferrelationship.bean.vo.personalTransferRelationshipVo;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
/**
* @author lenovo
*/
@Mapper
public interface TransferRelationshipMapper {
/**
* 查询全部转账卡号方法
* @return
*/
List<TransferCardVo> selectTransferCard();
/**
* 转账关系
* @return
*/
List<com.example.gajz.transferrelationship.bean.param.data> edge();
/**
* 查询被转账人全部信息
* @return
* @param bankCardNo
*/
List<com.example.gajz.transferrelationship.bean.param.data> transferRelationship(String bankCardNo);
/**
* 查询转账记录
* @param cardNumber
* @param fullName
*/
List<SearchRelationshipVo> transferRecord(String cardNumber, String fullName);
/**
* 查询搜索人被转账记录
* @param cardNumber
* @param fullName
* @return
*/
List<SearchRelationshipVo> transferredRecord(String cardNumber, String fullName);
/**
* 查询搜索人信息 转账人
* @param cardnumbe
* @return
*/
List<SearchRelationshipVo> personalInformationTransferor(String cardnumbe);
/**
* 查询搜索人信息 被转账人
* @param cardnumbe
* @return
*/
List<SearchRelationshipVo> personalInformationTransferredPerson(String cardnumbe);
/**
* 清空关系图数据表
*/
void emptyTransferRelationship();
/**
* excel数据导入数据库
* @param eSerialsList
*/
void insertTransferRelationship(List<abcExcie> eSerialsList);
/**
*查询搜索人关联下一级数据
* @param cardNumber
* @return
*/
List<SearchRelationshipVo> querySubordinate(String cardNumber);
/**
* 查询转账人
* @param cardNumber
* @param fullName
* @return
*/
List<SearchRelationshipVo> queryTransferor(String cardNumber, String fullName);
/**
* 查询被转账人
* @param cardNumber
* @param fullName
* @return
*/
List<SearchRelationshipVo> queryTheTransferredPerson(String cardNumber, String fullName);
/**
* 查询单人转账关系
* @param cardnumbe
*/
List<personalTransferRelationshipVo> personalTransferRelationship(String cardnumbe);
/**
* 查询上级转账人方法
* @param cardNumbe
* @return
*/
List<SearchRelationshipVo> querySuperior(String cardNumbe);
/**
* 查询两人转账关系 关系 (关系图) 接口
* @param cardNumber
* @return
*/
List<personalTransferRelationshipVo> trBetweenTwoPersons(String cardNumber);
}
src/main/java/com/example/gajz/transferrelationship/file/SqlTest.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.file;
/**
* Project Name:cscm-base-vipshop
* File Name:SqlHelper.java
* Package Name:cn.ivg.controller
* Date:2019年7月28日上午12:45:08
* Copyright (c) 2019, bluemobi All Rights Reserved.
*
*/
import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import org.apache.ibatis.io.Resources;
/*
* 使用java以及jdbc执行sql脚本的工具示例代码
*/
public class SqlTest {
public static void main(String[] args) throws IOException {
String path = Resources.getResourceAsFile("D:\\abc_statement.sql").getAbsolutePath();
String sql = getText(path);
List<String> sqlarr = getSql(sql);
for (String string : sqlarr) {
System.out.println(string);
}
try {
SqlTest.execute(getConn(), sqlarr);
} catch (Exception e) {
e.printStackTrace();
}
}
public static void execute(Connection conn, List<String> sqlFile) throws Exception {
Statement stmt = null;
stmt = conn.createStatement();
for (String sql : sqlFile) {
sql = sql.trim();
if (sql != null && !sql.equals(""))
stmt.addBatch(sql);
}
int[] rows = stmt.executeBatch();
System.out.println("Row count:" + Arrays.toString(rows));
conn.close();
}
private static Connection getConn() {
String url = "jdbc:mysql://localhost:3306/ga?serverTimezone=UTC";
String username = "root";
String password = "123456";
String driver = "com.mysql.jdbc.Driver";
Connection conn = null;
try {
Class.forName(driver); // classLoader,加载对应驱动
conn = DriverManager.getConnection(url, username, password);
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
return conn;
}
/*
* getText方法吧path路径里面的文件按行读数来放入一个大的String里面去 并在换行的时候加入\r\n
*/
public static String getText(String path) {
File file = new File(path);
if (!file.exists() || file.isDirectory()) {
return null;
}
StringBuilder sb = new StringBuilder();
try {
FileInputStream fis = new FileInputStream(path);
InputStreamReader isr = new InputStreamReader(fis, "UTF-8");
BufferedReader br = new BufferedReader(isr);
String temp = null;
temp = br.readLine();
boolean flag = true;
while (temp != null) {
if (temp.length() >= 2) {
String str1 = temp.substring(0, 1);
String str2 = temp.substring(0, 2);
if (str1.equals("#") || str2.equals("--") || str2.equals("//")) {
temp = br.readLine();
continue;
}
if (str2.equals("/*")) {// 因为/**/是注释有/*时，直到遇到*/才开始添加
flag = false;
}
if (str2.equals("*/")) {
flag = true;
temp = "";
}
if (flag) {
sb.append(temp + "\r\n");
}
}
temp = br.readLine();
}
br.close();
} catch (Exception e) {
e.printStackTrace();
}
return sb.toString();
}
/*
* getSqlArray方法 从文件的sql字符串中分析出能够独立执行的sql语句并返回
*/
public static List<String> getSql(String sql) {
String s = sql;
s = s.replaceAll("\r\n", "\r");
s = s.replaceAll("\r", "\n");
List<String> ret = new ArrayList<String>();
String[] sqlarry = s.split(";"); // 用;把所有的语句都分开成一个个单独的句子
sqlarry = filter(sqlarry);
ret = Arrays.asList(sqlarry);
return ret;
}
public static String[] filter(String[] ss) {
List<String> strs = new ArrayList<String>();
for (String s : ss) {
if (s != null && !s.equals("")) {
strs.add(s);
}
}
String[] result = new String[strs.size()];
for (int i = 0; i < strs.size(); i++) {
result[i] = strs.get(i).toString();
}
return result;
}
}
\ No newline at end of file
src/main/java/com/example/gajz/transferrelationship/file/TestReadFile.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.file;
import java.io.*;
import java.sql.*;
/**
* 读取指定文件下sql脚本，执行到数据库
* 朱行读取分批处理批量插入数据库
*/
public class TestReadFile {
public static void main(String[] args) {
System.err.println("begin");
long start = System.currentTimeMillis();
String path = "D:\\abc_statement.sql";
getData(path);
System.err.print((System.currentTimeMillis() - start) / 1000);
}
private static void getData(String path) {
//读取文件
BufferedReader reader;
Connection conn = null;
Statement pst = null;
try {
Class.forName("com.mysql.cj.jdbc.Driver");
conn = DriverManager.getConnection(
"jdbc:mysql://localhost:3306/ga?serverTimezone=UTC", "root", "123456");
pst = conn.createStatement();
reader = new BufferedReader(new InputStreamReader(new FileInputStream(path), "UTF-8"));
String line;
int i = 0;
while ((line = reader.readLine()) != null) {
pst.addBatch(line);
/* System.out.println("-----------------------");
System.out.println(line);
System.out.println("-----------------------");*/
if (i % 100 == 0) {
System.out.println("执行了：" + i);
pst.executeBatch();
}
i += 1;
}
reader.close();
// 执行批量更新
pst.executeBatch();
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (pst != null) {
pst.close();
}
if (conn != null) {
conn.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
src/main/java/com/example/gajz/transferrelationship/hugegraphclient/SingleExample.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.hugegraphclient;
import com.baidu.hugegraph.driver.*;
import com.baidu.hugegraph.structure.constant.T;
import com.baidu.hugegraph.structure.graph.Vertex;
import java.io.IOException;
/**
* @author lenovo
*/
public class SingleExample {
public static void main(String[] args) throws IOException {
// If connect failed will throw a exception.
HugeClient hugeClient = HugeClient.builder("http://36.148.1.253:8289","hugegraph2")
/*** 默认未开启用户权限*/
.configUser("**", "**")
.build();
try {
SchemaManager schema = hugeClient.schema();
//删除顶点
// schema.propertyKey("姓名").remove();
// schema.propertyKey("卡号").remove();
// schema.propertyKey("转账次数").remove();
// schema.propertyKey("转账金额").remove();
//创建属性
// schema.propertyKey("姓名").asText().ifNotExist().create();
// schema.propertyKey("卡号").asText().ifNotExist().create();
// schema.propertyKey("转账次数").asText().ifNotExist().create();
// schema.propertyKey("转账金额").asText().ifNotExist().create();
schema.propertyKey("name").asText().ifNotExist().create();
schema.propertyKey("age").asInt().ifNotExist().create();
schema.propertyKey("city").asText().ifNotExist().create();
schema.propertyKey("weight").asDouble().ifNotExist().create();
schema.propertyKey("lang").asText().ifNotExist().create();
schema.propertyKey("date").asDate().ifNotExist().create();
schema.propertyKey("price").asInt().ifNotExist().create();
schema.vertexLabel("person")
.properties("name", "age", "city")
.primaryKeys("name")
.ifNotExist()
.create();
schema.vertexLabel("software")
.properties("name", "lang", "price")
.primaryKeys("name")
.ifNotExist()
.create();
schema.indexLabel("personByCity")
.onV("person")
.by("city")
.secondary()
.ifNotExist()
.create();
schema.indexLabel("personByAgeAndCity")
.onV("person")
.by("age", "city")
.secondary()
.ifNotExist()
.create();
schema.indexLabel("softwareByPrice")
.onV("software")
.by("price")
.range()
.ifNotExist()
.create();
schema.edgeLabel("knows")
.sourceLabel("person")
.targetLabel("person")
.properties("date", "weight")
.ifNotExist()
.create();
schema.edgeLabel("created")
.sourceLabel("person").targetLabel("software")
.properties("date", "weight")
.ifNotExist()
.create();
schema.indexLabel("createdByDate")
.onE("created")
.by("date")
.secondary()
.ifNotExist()
.create();
schema.indexLabel("createdByWeight")
.onE("created")
.by("weight")
.range()
.ifNotExist()
.create();
schema.indexLabel("knowsByWeight")
.onE("knows")
.by("weight")
.range()
.ifNotExist()
.create();
GraphManager graph = hugeClient.graph();
Vertex marko = graph.addVertex(T.label, "person", "name", "marko",
"age", 29, "city", "Beijing");
Vertex vadas = graph.addVertex(T.label, "person", "name", "vadas",
"age", 27, "city", "Hongkong");
Vertex lop = graph.addVertex(T.label, "software", "name", "lop",
"lang", "java", "price", 328);
Vertex josh = graph.addVertex(T.label, "person", "name", "josh",
"age", 32, "city", "Beijing");
Vertex ripple = graph.addVertex(T.label, "software", "name", "ripple",
"lang", "java", "price", 199);
Vertex peter = graph.addVertex(T.label, "person", "name", "peter",
"age", 35, "city", "Shanghai");
//
marko.addEdge("knows", vadas, "date", "2016-01-10", "weight", 0.5);
// marko.addEdge("knows", josh, "date", "2013-02-20", "weight", 1.0);
// marko.addEdge("created", lop, "date", "2017-12-10", "weight", 0.4);
// josh.addEdge("created", lop, "date", "2009-11-11", "weight", 0.4);
// josh.addEdge("created", ripple, "date", "2017-12-10", "weight", 1.0);
// peter.addEdge("created", lop, "date", "2017-03-24", "weight", 0.2);
// GremlinManager gremlin = hugeClient.gremlin();
// System.out.println("==== Path ====");
// ResultSet resultSet = gremlin.gremlin("g.V().outE().path()").execute();
// Iterator<Result> results = resultSet.iterator();
// results.forEachRemaining(result -> {
// System.out.println(result.getObject().getClass());
// Object object = result.getObject();
// if (object instanceof Vertex) {
// System.out.println(((Vertex) object).id());
// } else if (object instanceof Edge) {
// System.out.println(((Edge) object).id());
// } else if (object instanceof Path) {
// List<Object> elements = ((Path) object).objects();
// elements.forEach(element -> {
// System.out.println(element.getClass());
// System.out.println(element);
// });
// } else {
// System.out.println(object);
// }
// });
hugeClient.close();
}catch (Exception e){
hugeClient.close();
}
}
}
src/main/java/com/example/gajz/transferrelationship/hugegraphclient/test.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.hugegraphclient;
public class test {
public static void main(String[] args) {
Test2 test2 = new Test2();
Test3 test3=new Test3();
test2.ts2(1);
Thread thread = new Thread(test2);
Thread thread1 = new Thread(test3);
thread.start();
thread1.start();
}
}
class Test2 implements Runnable {
private int t2;
public void ts2(int s){
t2=s;
}
@Override
public void run() {
for (int i = 0; i < 1000; i++) {
System.out.println("------Test2"+this.t2);
}
}
}
class Test3 implements Runnable {
@Override
public void run() {
for (int i=0;i<1000;i++){
System.out.println("Test3------");
}
}
}
src/main/java/com/example/gajz/transferrelationship/neo4j/Colour.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.neo4j;
import java.util.Random;
public class Colour {
public String getColour(){
//红色
String red;
//绿色
String green;
//蓝色
String blue;
//生成随机对象
Random random = new Random();
//生成红色颜色代码
red = Integer.toHexString(random.nextInt(256)).toUpperCase();
//生成绿色颜色代码
green = Integer.toHexString(random.nextInt(256)).toUpperCase();
//生成蓝色颜色代码
blue = Integer.toHexString(random.nextInt(256)).toUpperCase();
//判断红色代码的位数
red = red.length()==1 ? "0" + red : red ;
//判断绿色代码的位数
green = green.length()==1 ? "0" + green : green ;
//判断蓝色代码的位数
blue = blue.length()==1 ? "0" + blue : blue ;
//生成十六进制颜色值
String color = "0x"+red+green+blue;
return color;
}
}
src/main/java/com/example/gajz/transferrelationship/neo4j/HelloWorldExample.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.neo4j;
import com.baidu.hugegraph.structure.constant.T;
import com.example.gajz.transferrelationship.bean.vo.TransferCardVo;
import com.example.gajz.transferrelationship.bean.vo.TransferredPersonVo;
import com.example.gajz.transferrelationship.dao.TransferRelationshipMapper;
import org.neo4j.driver.AuthTokens;
import org.neo4j.driver.Driver;
import org.neo4j.driver.GraphDatabase;
import org.neo4j.driver.Result;
import org.neo4j.driver.Session;
import org.neo4j.driver.Transaction;
import org.neo4j.driver.TransactionWork;
import org.springframework.beans.factory.annotation.Autowired;
import java.util.List;
import static org.neo4j.driver.Values.parameters;
public class HelloWorldExample implements AutoCloseable {
private final Driver driver;
public HelloWorldExample( String uri, String user, String password ) {
driver = GraphDatabase.driver( uri, AuthTokens.basic( user, password ) );
}
@Override
public void close() throws Exception
{
driver.close();
}
public void printGreeting( final String message )
{
try ( Session session = driver.session() )
{
String greeting = session.writeTransaction( new TransactionWork<String>()
{
@Override
public String execute( Transaction tx )
{
Result result = tx.run( "CREATE (a:Greeting) " +
"SET a.message = $message " +
"RETURN a.message + ', from node ' + id(a)",
parameters( "message", message ) );
return result.single().get( 0 ).asString();
}
} );
System.out.println( greeting );
}
}
public static void main(List<TransferredPersonVo> args) throws Exception {
try ( HelloWorldExample greeter = new HelloWorldExample( "bolt://localhost:7687", "neo4j", "123456" ) ) {
System.out.println(args.size());
for (int i=0;i<args.size();i++){
System.out.println(i);
greeter.printGreeting( args.get(i).getEndCardNo());
}
}
}
}
\ No newline at end of file
src/main/java/com/example/gajz/transferrelationship/neo4j/test.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.neo4j;
import com.example.gajz.redis.ConFigRedis;
import redis.clients.jedis.Jedis;
public class test {
public static void main(String[] args) {
Jedis conn = ConFigRedis.getConn();
conn.flushAll();
}
}
src/main/java/com/example/gajz/transferrelationship/service/TransferRelationshipService.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.service;
import com.example.gajz.result.Result;
import com.example.gajz.transferrelationship.bean.dto.data;
import com.example.gajz.transferrelationship.bean.excel.abcExcie;
import com.example.gajz.transferrelationship.bean.param.TransferAssociationParam;
import com.example.gajz.transferrelationship.bean.vo.SearchRelationshipVo;
import java.util.List;
/**
* @author lenovo
*/
public interface TransferRelationshipService {
/**
* 边
* @return
*/
List<data> edge();
/**
* 点
* @return
*/
List diagramSpot();
/**
* 关系图搜索 单人转账关系（关联关系）接口
* @param cardnumbe
* @return
*/
Result searchRelationship(String cardnumbe);
/**
* 转账关系图 信息搜索接口 查询某一个点的具体位置
* @param id
* @return
*/
Result specificLocation(String id);
/**
* 清空关系图数据表
*/
void emptyTransferRelationship();
/**
* excel数据导入数据库
* @param eSerialsList
*/
void insertTransferRelationship(List<abcExcie> eSerialsList);
/**
* 关系图 搜索接口
* @param name
* @return
*/
Result pointSearch(String name);
/**
* 查询两人转账关系 (关系图) 接口
* @param transferAssociationParam
* @return
*/
Result transferAssociation(TransferAssociationParam transferAssociationParam);
/**
* 关系图搜索 单人转账关系 转账信息信息查询接口
* @return
*/
Result personalTransferRelationship();
/**
* 查询两人转账关系 关系 (关系图) 接口
* @return
*/
Result trBetweenTwoPersons(List<SearchRelationshipVo> transferAssociationParam);
}
src/main/java/com/example/gajz/transferrelationship/thread/ThreadsMultipleVerticesEight.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.thread;
import com.baidu.hugegraph.driver.GraphManager;
import com.baidu.hugegraph.driver.HugeClient;
import com.baidu.hugegraph.structure.constant.T;
import com.example.gajz.transferrelationship.bean.vo.TransferredPersonVo;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* 收款人顶点数据导入线程8
* @author lenovo
*/
public class ThreadsMultipleVerticesEight implements Runnable{
List<TransferredPersonVo> transferredPersonList;
public void ThreadsMultipleVerticesEightList(List<TransferredPersonVo> transferredPersonVos){
this.transferredPersonList=transferredPersonVos;
}
@Override
public void run() {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("顶点数据导入线程8开始"+df.format(new Date()));
HugeClient hugeClient = HugeClient.builder("http://36.148.1.253:8289","hugegraph2")
/*** 默认未开启用户权限*/
.configUser("**", "**")
.build();
GraphManager graph = hugeClient.graph();
for (int i=0;i<transferredPersonList.size();i++){
/**添加收款人顶点数据*/
graph.addVertex(
/**设置ID*/
T.id, transferredPersonList.get(i).getEndCardNo(),
T.label, "收款人",
/**设置收款次数*/
"收款次数", transferredPersonList.get(i).getNumber());
}
System.out.println("顶点数据导入线程8结束"+df.format(new Date()));
// hugeClient.close();
}
}
src/main/java/com/example/gajz/transferrelationship/thread/ThreadsMultipleVerticesEleven.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.thread;
import com.baidu.hugegraph.driver.GraphManager;
import com.baidu.hugegraph.driver.HugeClient;
import com.baidu.hugegraph.structure.constant.T;
import com.example.gajz.transferrelationship.bean.vo.TransferredPersonVo;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* 收款人顶点数据导入线程11
* @author lenovo
*/
public class ThreadsMultipleVerticesEleven implements Runnable{
List<TransferredPersonVo> transferredPersonList;
public void ThreadsMultipleVerticesElevenList(List<TransferredPersonVo> transferredPersonVos){
this.transferredPersonList=transferredPersonVos;
}
@Override
public void run() {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("顶点数据导入线程11开始"+df.format(new Date()));
HugeClient hugeClient = HugeClient.builder("http://36.148.1.253:8289","hugegraph2")
/*** 默认未开启用户权限*/
.configUser("**", "**")
.build();
GraphManager graph = hugeClient.graph();
for (int i=0;i<transferredPersonList.size();i++){
/**添加收款人顶点数据*/
graph.addVertex(
/**设置ID*/
T.id, transferredPersonList.get(i).getEndCardNo(),
T.label, "收款人",
/**设置收款次数*/
"收款次数", transferredPersonList.get(i).getNumber());
}
System.out.println("顶点数据导入线程11结束"+df.format(new Date()));
hugeClient.close();
}
}
src/main/java/com/example/gajz/transferrelationship/thread/ThreadsMultipleVerticesFive.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.thread;
import com.baidu.hugegraph.driver.GraphManager;
import com.baidu.hugegraph.driver.HugeClient;
import com.baidu.hugegraph.structure.constant.T;
import com.example.gajz.transferrelationship.bean.vo.TransferredPersonVo;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* 收款人顶点数据导入线程5
* @author lenovo
*/
public class ThreadsMultipleVerticesFive implements Runnable{
List<TransferredPersonVo> transferredPersonList;
public void ThreadsMultipleVerticesFiveList(List<TransferredPersonVo> transferredPersonVos){
this.transferredPersonList=transferredPersonVos;
}
@Override
public void run() {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("顶点数据导入线程5开始"+df.format(new Date()));
HugeClient hugeClient = HugeClient.builder("http://36.148.1.253:8289","hugegraph2")
/*** 默认未开启用户权限*/
.configUser("**", "**")
.build();
GraphManager graph = hugeClient.graph();
for (int i=0;i<transferredPersonList.size();i++){
/**添加收款人顶点数据*/
graph.addVertex(
/**设置ID*/
T.id, transferredPersonList.get(i).getEndCardNo(),
T.label, "收款人",
/**设置收款次数*/
"收款次数", transferredPersonList.get(i).getNumber());
}
System.out.println("顶点数据导入线程5结束"+df.format(new Date()));
// hugeClient.close();
}
}
src/main/java/com/example/gajz/transferrelationship/thread/ThreadsMultipleVerticesFour.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.thread;
import com.baidu.hugegraph.driver.GraphManager;
import com.baidu.hugegraph.driver.HugeClient;
import com.baidu.hugegraph.structure.constant.T;
import com.example.gajz.transferrelationship.bean.vo.TransferredPersonVo;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* 收款人顶点数据导入线程4
* @author lenovo
*/
public class ThreadsMultipleVerticesFour implements Runnable{
List<TransferredPersonVo> transferredPersonList;
public void ThreadsMultipleVerticesFourList(List<TransferredPersonVo> transferredPersonVos){
this.transferredPersonList=transferredPersonVos;
}
@Override
public void run() {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("顶点数据导入线程4开始"+df.format(new Date()));
HugeClient hugeClient = HugeClient.builder("http://36.148.1.253:8289","hugegraph2")
/*** 默认未开启用户权限*/
.configUser("**", "**")
.build();
GraphManager graph = hugeClient.graph();
for (int i=0;i<transferredPersonList.size();i++){
/**添加收款人顶点数据*/
graph.addVertex(
/**设置ID*/
T.id, transferredPersonList.get(i).getEndCardNo(),
T.label, "收款人",
/**设置收款次数*/
"收款次数", transferredPersonList.get(i).getNumber());
}
System.out.println("顶点数据导入线程4结束"+df.format(new Date()));
// hugeClient.close();
}
}
src/main/java/com/example/gajz/transferrelationship/thread/ThreadsMultipleVerticesNine.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.thread;
import com.baidu.hugegraph.driver.GraphManager;
import com.baidu.hugegraph.driver.HugeClient;
import com.baidu.hugegraph.structure.constant.T;
import com.example.gajz.transferrelationship.bean.vo.TransferredPersonVo;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* 收款人顶点数据导入线程9
* @author lenovo
*/
public class ThreadsMultipleVerticesNine implements Runnable{
List<TransferredPersonVo> transferredPersonList;
public void ThreadsMultipleVerticesNineList(List<TransferredPersonVo> transferredPersonVos){
this.transferredPersonList=transferredPersonVos;
}
@Override
public void run() {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("顶点数据导入线程9开始"+df.format(new Date()));
HugeClient hugeClient = HugeClient.builder("http://36.148.1.253:8289","hugegraph2")
/*** 默认未开启用户权限*/
.configUser("**", "**")
.build();
GraphManager graph = hugeClient.graph();
for (int i=0;i<transferredPersonList.size();i++){
/**添加收款人顶点数据*/
graph.addVertex(
/**设置ID*/
T.id, transferredPersonList.get(i).getEndCardNo(),
T.label, "收款人",
/**设置收款次数*/
"收款次数", transferredPersonList.get(i).getNumber());
}
System.out.println("顶点数据导入线程9结束"+df.format(new Date()));
// hugeClient.close();
}
}
src/main/java/com/example/gajz/transferrelationship/thread/ThreadsMultipleVerticesOne.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.thread;
import com.baidu.hugegraph.driver.GraphManager;
import com.baidu.hugegraph.driver.HugeClient;
import com.baidu.hugegraph.structure.constant.T;
import com.example.gajz.transferrelationship.bean.vo.TransferredPersonVo;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* 收款人顶点数据导入线程1
* @author lenovo
*/
public class ThreadsMultipleVerticesOne implements Runnable{
List<TransferredPersonVo> transferredPersonList;
public void ThreadsMultipleVerticesOneList(List<TransferredPersonVo> transferredPersonVos){
this.transferredPersonList=transferredPersonVos;
}
@Override
public void run() {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("顶点数据导入线程1开始"+df.format(new Date()));
HugeClient hugeClient = HugeClient.builder("http://36.148.1.253:8289","hugegraph2")
/*** 默认未开启用户权限*/
.configUser("**", "**")
.build();
GraphManager graph = hugeClient.graph();
for (int i=0;i<transferredPersonList.size();i++){
/**添加收款人顶点数据*/
graph.addVertex(
/**设置ID*/
T.id, transferredPersonList.get(i).getEndCardNo(),
T.label, "收款人",
/**设置收款次数*/
"收款次数", transferredPersonList.get(i).getNumber());
}
System.out.println("顶点数据导入线程1结束"+df.format(new Date()));
// hugeClient.close();
}
}
src/main/java/com/example/gajz/transferrelationship/thread/ThreadsMultipleVerticesSeven.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.thread;
import com.baidu.hugegraph.driver.GraphManager;
import com.baidu.hugegraph.driver.HugeClient;
import com.baidu.hugegraph.structure.constant.T;
import com.example.gajz.transferrelationship.bean.vo.TransferredPersonVo;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* 收款人顶点数据导入线程7
* @author lenovo
*/
public class ThreadsMultipleVerticesSeven implements Runnable{
List<TransferredPersonVo> transferredPersonList;
public void ThreadsMultipleVerticesSevenList(List<TransferredPersonVo> transferredPersonVos){
this.transferredPersonList=transferredPersonVos;
}
@Override
public void run() {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("顶点数据导入线程7开始"+df.format(new Date()));
HugeClient hugeClient = HugeClient.builder("http://36.148.1.253:8289","hugegraph2")
/*** 默认未开启用户权限*/
.configUser("**", "**")
.build();
GraphManager graph = hugeClient.graph();
for (int i=0;i<transferredPersonList.size();i++){
/**添加收款人顶点数据*/
graph.addVertex(
/**设置ID*/
T.id, transferredPersonList.get(i).getEndCardNo(),
T.label, "收款人",
/**设置收款次数*/
"收款次数", transferredPersonList.get(i).getNumber());
}
System.out.println("顶点数据导入线程7结束"+df.format(new Date()));
// hugeClient.close();
}
}
src/main/java/com/example/gajz/transferrelationship/thread/ThreadsMultipleVerticesSix.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.thread;
import com.baidu.hugegraph.driver.GraphManager;
import com.baidu.hugegraph.driver.HugeClient;
import com.baidu.hugegraph.structure.constant.T;
import com.example.gajz.transferrelationship.bean.vo.TransferredPersonVo;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* 收款人顶点数据导入线程6
* @author lenovo
*/
public class ThreadsMultipleVerticesSix implements Runnable{
List<TransferredPersonVo> transferredPersonList;
public void ThreadsMultipleVerticesSixList(List<TransferredPersonVo> transferredPersonVos){
this.transferredPersonList=transferredPersonVos;
}
@Override
public void run() {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("顶点数据导入线程6开始"+df.format(new Date()));
HugeClient hugeClient = HugeClient.builder("http://36.148.1.253:8289","hugegraph2")
/*** 默认未开启用户权限*/
.configUser("**", "**")
.build();
GraphManager graph = hugeClient.graph();
for (int i=0;i<transferredPersonList.size();i++){
/**添加收款人顶点数据*/
graph.addVertex(
/**设置ID*/
T.id, transferredPersonList.get(i).getEndCardNo(),
T.label, "收款人",
/**设置收款次数*/
"收款次数", transferredPersonList.get(i).getNumber());
}
System.out.println("顶点数据导入线程6结束"+df.format(new Date()));
// hugeClient.close();
}
}
src/main/java/com/example/gajz/transferrelationship/thread/ThreadsMultipleVerticesTen.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.thread;
import com.baidu.hugegraph.driver.GraphManager;
import com.baidu.hugegraph.driver.HugeClient;
import com.baidu.hugegraph.structure.constant.T;
import com.example.gajz.transferrelationship.bean.vo.TransferredPersonVo;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* 收款人顶点数据导入线程10
* @author lenovo
*/
public class ThreadsMultipleVerticesTen implements Runnable{
List<TransferredPersonVo> transferredPersonList;
public void ThreadsMultipleVerticesTenList(List<TransferredPersonVo> transferredPersonVos){
this.transferredPersonList=transferredPersonVos;
}
@Override
public void run() {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("顶点数据导入线程10开始"+df.format(new Date()));
HugeClient hugeClient = HugeClient.builder("http://36.148.1.253:8289","hugegraph2")
/*** 默认未开启用户权限*/
.configUser("**", "**")
.build();
GraphManager graph = hugeClient.graph();
for (int i=0;i<transferredPersonList.size();i++){
/**添加收款人顶点数据*/
graph.addVertex(
/**设置ID*/
T.id, transferredPersonList.get(i).getEndCardNo(),
T.label, "收款人",
/**设置收款次数*/
"收款次数", transferredPersonList.get(i).getNumber());
}
System.out.println("顶点数据导入线程10结束"+df.format(new Date()));
hugeClient.close();
}
}
src/main/java/com/example/gajz/transferrelationship/thread/ThreadsMultipleVerticesThree.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.thread;
import com.baidu.hugegraph.driver.GraphManager;
import com.baidu.hugegraph.driver.HugeClient;
import com.baidu.hugegraph.structure.constant.T;
import com.example.gajz.transferrelationship.bean.vo.TransferredPersonVo;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* 收款人顶点数据导入线程3
* @author lenovo
*/
public class ThreadsMultipleVerticesThree implements Runnable{
List<TransferredPersonVo> transferredPersonList;
public void ThreadsMultipleVerticesThreeList(List<TransferredPersonVo> transferredPersonVos){
this.transferredPersonList=transferredPersonVos;
}
@Override
public void run() {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("顶点数据导入线程3开始"+df.format(new Date()));
HugeClient hugeClient = HugeClient.builder("http://36.148.1.253:8289","hugegraph2")
/*** 默认未开启用户权限*/
.configUser("**", "**")
.build();
GraphManager graph = hugeClient.graph();
for (int i=0;i<transferredPersonList.size();i++){
/**添加收款人顶点数据*/
graph.addVertex(
/**设置ID*/
T.id, transferredPersonList.get(i).getEndCardNo(),
T.label, "收款人",
/**设置收款次数*/
"收款次数", transferredPersonList.get(i).getNumber());
}
System.out.println("顶点数据导入线程3结束"+df.format(new Date()));
// hugeClient.close();
}
}
src/main/java/com/example/gajz/transferrelationship/thread/ThreadsMultipleVerticesTwelve.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.thread;
import com.baidu.hugegraph.driver.GraphManager;
import com.baidu.hugegraph.driver.HugeClient;
import com.baidu.hugegraph.structure.constant.T;
import com.example.gajz.transferrelationship.bean.vo.TransferredPersonVo;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* 收款人顶点数据导入线程12
* @author lenovo
*/
public class ThreadsMultipleVerticesTwelve implements Runnable{
List<TransferredPersonVo> transferredPersonList;
public void ThreadsMultipleVerticesTwelveList(List<TransferredPersonVo> transferredPersonVos){
this.transferredPersonList=transferredPersonVos;
}
@Override
public void run() {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("顶点数据导入线程12开始"+df.format(new Date()));
HugeClient hugeClient = HugeClient.builder("http://36.148.1.253:8289","hugegraph2")
/*** 默认未开启用户权限*/
.configUser("**", "**")
.build();
GraphManager graph = hugeClient.graph();
for (int i=0;i<transferredPersonList.size();i++){
/**添加收款人顶点数据*/
graph.addVertex(
/**设置ID*/
T.id, transferredPersonList.get(i).getEndCardNo(),
T.label, "收款人",
/**设置收款次数*/
"收款次数", transferredPersonList.get(i).getNumber());
}
System.out.println("顶点数据导入线程12结束"+df.format(new Date()));
hugeClient.close();
}
}
src/main/java/com/example/gajz/transferrelationship/thread/ThreadsMultipleVerticesTwo.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.thread;
import com.baidu.hugegraph.driver.GraphManager;
import com.baidu.hugegraph.driver.HugeClient;
import com.baidu.hugegraph.structure.constant.T;
import com.example.gajz.transferrelationship.bean.vo.TransferredPersonVo;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* 收款人顶点数据导入线程2
* @author lenovo
*/
public class ThreadsMultipleVerticesTwo implements Runnable{
List<TransferredPersonVo> transferredPersonList;
public void ThreadsMultipleVerticesTwoList(List<TransferredPersonVo> transferredPersonVos){
this.transferredPersonList=transferredPersonVos;
}
@Override
public void run() {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("顶点数据导入线程2开始"+df.format(new Date()));
HugeClient hugeClient = HugeClient.builder("http://36.148.1.253:8289","hugegraph2")
/*** 默认未开启用户权限*/
.configUser("**", "**")
.build();
GraphManager graph = hugeClient.graph();
for (int i=0;i<transferredPersonList.size();i++){
/**添加收款人顶点数据*/
graph.addVertex(
/**设置ID*/
T.id, transferredPersonList.get(i).getEndCardNo(),
T.label, "收款人",
/**设置收款次数*/
"收款次数", transferredPersonList.get(i).getNumber());
}
System.out.println("顶点数据导入线程2结束"+df.format(new Date()));
// hugeClient.close();
}
}
src/main/java/com/example/gajz/transferrelationship/thread/TransferAccountsEight.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.thread;
import com.baidu.hugegraph.driver.GraphManager;
import com.baidu.hugegraph.driver.HugeClient;
import com.baidu.hugegraph.structure.graph.Vertex;
import com.example.gajz.transferrelationship.bean.vo.TransferredPersonVo;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* 导入转账关系8号线程
* @author lenovo
*/
public class TransferAccountsEight implements Runnable{
List<TransferredPersonVo> transferList;
public void TransferAccountsEightList(List<TransferredPersonVo> transferCollectionList){
this.transferList=transferCollectionList;
}
@Override
public void run() {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("线程8开始"+df.format(new Date()));
HugeClient hugeClient = HugeClient.builder("http://36.148.1.253:8289","hugegraph2")
/*** 默认未开启用户权限*/
.configUser("**", "**")
.build();
GraphManager graph = hugeClient.graph();
for (int i=0;i<transferList.size();i++){
Vertex transferor = graph.getVertex(transferList.get(i).getBankCardNo());
Vertex payee = graph.getVertex(transferList.get(i).getEndCardNo());
//创建转账关系
transferor.addEdge("多人转账", payee, "转账次数", transferList.get(i).getNumber());
}
hugeClient.close();
System.out.println("线程8结束"+df.format(new Date()));
}
}
src/main/java/com/example/gajz/transferrelationship/thread/TransferAccountsEighteen.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.thread;
import com.baidu.hugegraph.driver.GraphManager;
import com.baidu.hugegraph.driver.HugeClient;
import com.baidu.hugegraph.structure.graph.Vertex;
import com.example.gajz.transferrelationship.bean.vo.TransferredPersonVo;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* 导入转账关系18号线程
* @author lenovo
*/
public class TransferAccountsEighteen implements Runnable{
List<TransferredPersonVo> transferList;
public void TransferAccountsEighteenList(List<TransferredPersonVo> transferCollectionList){
this.transferList=transferCollectionList;
}
@Override
public void run() {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("线程18开始"+df.format(new Date()));
HugeClient hugeClient = HugeClient.builder("http://36.148.1.253:8289","hugegraph2")
/*** 默认未开启用户权限*/
.configUser("**", "**")
.build();
GraphManager graph = hugeClient.graph();
for (int i=0;i<transferList.size();i++){
Vertex transferor = graph.getVertex(transferList.get(i).getBankCardNo());
Vertex payee = graph.getVertex(transferList.get(i).getEndCardNo());
//创建转账关系
transferor.addEdge("多人转账", payee, "转账次数", transferList.get(i).getNumber());
}
hugeClient.close();
System.out.println("线程18结束"+df.format(new Date()));
}
}
src/main/java/com/example/gajz/transferrelationship/thread/TransferAccountsEleven.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.thread;
import com.baidu.hugegraph.driver.GraphManager;
import com.baidu.hugegraph.driver.HugeClient;
import com.baidu.hugegraph.structure.graph.Vertex;
import com.example.gajz.transferrelationship.bean.vo.TransferredPersonVo;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* 导入转账关系11号线程
* @author lenovo
*/
public class TransferAccountsEleven implements Runnable{
List<TransferredPersonVo> transferList;
public void TransferAccountsElevenList(List<TransferredPersonVo> transferCollectionList){
this.transferList=transferCollectionList;
}
@Override
public void run() {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("线程11开始"+df.format(new Date()));
HugeClient hugeClient = HugeClient.builder("http://36.148.1.253:8289","hugegraph2")
/*** 默认未开启用户权限*/
.configUser("**", "**")
.build();
GraphManager graph = hugeClient.graph();
for (int i=0;i<transferList.size();i++){
Vertex transferor = graph.getVertex(transferList.get(i).getBankCardNo());
Vertex payee = graph.getVertex(transferList.get(i).getEndCardNo());
//创建转账关系
transferor.addEdge("多人转账", payee, "转账次数", transferList.get(i).getNumber());
}
hugeClient.close();
System.out.println("线程11结束"+df.format(new Date()));
}
}
src/main/java/com/example/gajz/transferrelationship/thread/TransferAccountsFifteen.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.thread;
import com.baidu.hugegraph.driver.GraphManager;
import com.baidu.hugegraph.driver.HugeClient;
import com.baidu.hugegraph.structure.graph.Vertex;
import com.example.gajz.transferrelationship.bean.vo.TransferredPersonVo;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* 导入转账关系15号线程
* @author lenovo
*/
public class TransferAccountsFifteen implements Runnable{
List<TransferredPersonVo> transferList;
public void TransferAccountsFifteenList(List<TransferredPersonVo> transferCollectionList){
this.transferList=transferCollectionList;
}
@Override
public void run() {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("线程15开始"+df.format(new Date()));
HugeClient hugeClient = HugeClient.builder("http://36.148.1.253:8289","hugegraph2")
/*** 默认未开启用户权限*/
.configUser("**", "**")
.build();
GraphManager graph = hugeClient.graph();
for (int i=0;i<transferList.size();i++){
Vertex transferor = graph.getVertex(transferList.get(i).getBankCardNo());
Vertex payee = graph.getVertex(transferList.get(i).getEndCardNo());
//创建转账关系
transferor.addEdge("多人转账", payee, "转账次数", transferList.get(i).getNumber());
}
hugeClient.close();
System.out.println("线程15结束"+df.format(new Date()));
}
}
src/main/java/com/example/gajz/transferrelationship/thread/TransferAccountsFive.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.thread;
import com.baidu.hugegraph.driver.GraphManager;
import com.baidu.hugegraph.driver.HugeClient;
import com.baidu.hugegraph.structure.graph.Vertex;
import com.example.gajz.transferrelationship.bean.vo.TransferredPersonVo;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* @author lenovo
*/
public class TransferAccountsFive implements Runnable{
List<TransferredPersonVo> transferList;
public void TransferAccountsFiveList(List<TransferredPersonVo> transferCollectionList){
this.transferList=transferCollectionList;
}
@Override
public void run() {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("线程5开始"+df.format(new Date()));
HugeClient hugeClient = HugeClient.builder("http://36.148.1.253:8289","hugegraph2")
/*** 默认未开启用户权限*/
.configUser("**", "**")
.build();
GraphManager graph = hugeClient.graph();
for (int i=0;i<transferList.size();i++){
Vertex transferor = graph.getVertex(transferList.get(i).getBankCardNo());
Vertex payee = graph.getVertex(transferList.get(i).getEndCardNo());
//创建转账关系
transferor.addEdge("多人转账", payee, "转账次数", transferList.get(i).getNumber());
}
hugeClient.close();
System.out.println("线程5结束"+df.format(new Date()));
}
}
src/main/java/com/example/gajz/transferrelationship/thread/TransferAccountsFour.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.thread;
import com.baidu.hugegraph.driver.GraphManager;
import com.baidu.hugegraph.driver.HugeClient;
import com.baidu.hugegraph.structure.graph.Vertex;
import com.example.gajz.transferrelationship.bean.vo.TransferredPersonVo;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* @author lenovo
*/
public class TransferAccountsFour implements Runnable{
List<TransferredPersonVo> transferList;
public void TransferAccountsFourList(List<TransferredPersonVo> transferCollectionList){
this.transferList=transferCollectionList;
}
@Override
public void run() {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("线程4开始"+df.format(new Date()));
HugeClient hugeClient = HugeClient.builder("http://36.148.1.253:8289","hugegraph2")
/*** 默认未开启用户权限*/
.configUser("**", "**")
.build();
GraphManager graph = hugeClient.graph();
for (int i=0;i<transferList.size();i++){
Vertex transferor = graph.getVertex(transferList.get(i).getBankCardNo());
Vertex payee = graph.getVertex(transferList.get(i).getEndCardNo());
//创建转账关系
transferor.addEdge("多人转账", payee, "转账次数", transferList.get(i).getNumber());
}
hugeClient.close();
System.out.println("线程4结束"+df.format(new Date()));
}
}
src/main/java/com/example/gajz/transferrelationship/thread/TransferAccountsFourteen.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.thread;
import com.baidu.hugegraph.driver.GraphManager;
import com.baidu.hugegraph.driver.HugeClient;
import com.baidu.hugegraph.structure.graph.Vertex;
import com.example.gajz.transferrelationship.bean.vo.TransferredPersonVo;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* 导入转账关系14号线程
* @author lenovo
*/
public class TransferAccountsFourteen implements Runnable{
List<TransferredPersonVo> transferList;
public void TransferAccountsFourteenList(List<TransferredPersonVo> transferCollectionList){
this.transferList=transferCollectionList;
}
@Override
public void run() {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("线程14开始"+df.format(new Date()));
HugeClient hugeClient = HugeClient.builder("http://36.148.1.253:8289","hugegraph2")
/*** 默认未开启用户权限*/
.configUser("**", "**")
.build();
GraphManager graph = hugeClient.graph();
for (int i=0;i<transferList.size();i++){
Vertex transferor = graph.getVertex(transferList.get(i).getBankCardNo());
Vertex payee = graph.getVertex(transferList.get(i).getEndCardNo());
//创建转账关系
transferor.addEdge("多人转账", payee, "转账次数", transferList.get(i).getNumber());
}
hugeClient.close();
System.out.println("线程14结束"+df.format(new Date()));
}
}
src/main/java/com/example/gajz/transferrelationship/thread/TransferAccountsNine.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.thread;
import com.baidu.hugegraph.driver.GraphManager;
import com.baidu.hugegraph.driver.HugeClient;
import com.baidu.hugegraph.structure.graph.Vertex;
import com.example.gajz.transferrelationship.bean.vo.TransferredPersonVo;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* 导入转账关系9号线程
* @author lenovo
*/
public class TransferAccountsNine implements Runnable{
List<TransferredPersonVo> transferList;
public void TransferAccountsNineList(List<TransferredPersonVo> transferCollectionList){
this.transferList=transferCollectionList;
}
@Override
public void run() {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("线程9开始"+df.format(new Date()));
HugeClient hugeClient = HugeClient.builder("http://36.148.1.253:8289","hugegraph2")
/*** 默认未开启用户权限*/
.configUser("**", "**")
.build();
GraphManager graph = hugeClient.graph();
for (int i=0;i<transferList.size();i++){
Vertex transferor = graph.getVertex(transferList.get(i).getBankCardNo());
Vertex payee = graph.getVertex(transferList.get(i).getEndCardNo());
//创建转账关系
transferor.addEdge("多人转账", payee, "转账次数", transferList.get(i).getNumber());
}
hugeClient.close();
System.out.println("线程9结束"+df.format(new Date()));
}
}
src/main/java/com/example/gajz/transferrelationship/thread/TransferAccountsNineteen.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.thread;
import com.baidu.hugegraph.driver.GraphManager;
import com.baidu.hugegraph.driver.HugeClient;
import com.baidu.hugegraph.structure.graph.Vertex;
import com.example.gajz.transferrelationship.bean.vo.TransferredPersonVo;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* 导入转账关系19号线程
* @author lenovo
*/
public class TransferAccountsNineteen implements Runnable{
List<TransferredPersonVo> transferList;
public void TransferAccountsNineteenList(List<TransferredPersonVo> transferCollectionList){
this.transferList=transferCollectionList;
}
@Override
public void run() {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("线程19开始"+df.format(new Date()));
HugeClient hugeClient = HugeClient.builder("http://36.148.1.253:8289","hugegraph2")
/*** 默认未开启用户权限*/
.configUser("**", "**")
.build();
GraphManager graph = hugeClient.graph();
for (int i=0;i<transferList.size();i++){
Vertex transferor = graph.getVertex(transferList.get(i).getBankCardNo());
Vertex payee = graph.getVertex(transferList.get(i).getEndCardNo());
//创建转账关系
transferor.addEdge("多人转账", payee, "转账次数", transferList.get(i).getNumber());
}
hugeClient.close();
System.out.println("线程19结束"+df.format(new Date()));
}
}
src/main/java/com/example/gajz/transferrelationship/thread/TransferAccountsOne.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.thread;
import com.baidu.hugegraph.driver.GraphManager;
import com.baidu.hugegraph.driver.HugeClient;
import com.baidu.hugegraph.structure.graph.Vertex;
import com.example.gajz.transferrelationship.bean.vo.TransferredPersonVo;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* @author lenovo
*/
public class TransferAccountsOne implements Runnable {
List<TransferredPersonVo> transferList;
public void TransferAccountsOneList(List<TransferredPersonVo> transferCollectionList){
System.out.println(transferCollectionList.size());
this.transferList=transferCollectionList;
}
@Override
public void run() {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("线程1开始"+df.format(new Date()));
HugeClient hugeClient = HugeClient.builder("http://36.148.1.253:8289","hugegraph2")
/*** 默认未开启用户权限*/
.configUser("**", "**")
.build();
GraphManager graph = hugeClient.graph();
for (int i=0;i<transferList.size();i++){
Vertex transferor = graph.getVertex(transferList.get(i).getBankCardNo());
Vertex payee = graph.getVertex(transferList.get(i).getEndCardNo());
//创建转账关系
transferor.addEdge("多人转账", payee, "转账次数", transferList.get(i).getNumber());
}
hugeClient.close();
System.out.println("线程1结束"+df.format(new Date()));
}
}
src/main/java/com/example/gajz/transferrelationship/thread/TransferAccountsSeven.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.thread;
import com.baidu.hugegraph.driver.GraphManager;
import com.baidu.hugegraph.driver.HugeClient;
import com.baidu.hugegraph.structure.graph.Vertex;
import com.example.gajz.transferrelationship.bean.vo.TransferredPersonVo;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* 导入转账关系7号线程
* @author lenovo
*/
public class TransferAccountsSeven implements Runnable{
List<TransferredPersonVo> transferList;
public void TransferAccountsSevenList(List<TransferredPersonVo> transferCollectionList){
this.transferList=transferCollectionList;
}
@Override
public void run() {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("线程7开始"+df.format(new Date()));
HugeClient hugeClient = HugeClient.builder("http://36.148.1.253:8289","hugegraph2")
/*** 默认未开启用户权限*/
.configUser("**", "**")
.build();
GraphManager graph = hugeClient.graph();
for (int i=0;i<transferList.size();i++){
Vertex transferor = graph.getVertex(transferList.get(i).getBankCardNo());
Vertex payee = graph.getVertex(transferList.get(i).getEndCardNo());
//创建转账关系
transferor.addEdge("多人转账", payee, "转账次数", transferList.get(i).getNumber());
}
hugeClient.close();
System.out.println("线程7结束"+df.format(new Date()));
}
}
src/main/java/com/example/gajz/transferrelationship/thread/TransferAccountsSeventeen.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.thread;
import com.baidu.hugegraph.driver.GraphManager;
import com.baidu.hugegraph.driver.HugeClient;
import com.baidu.hugegraph.structure.graph.Vertex;
import com.example.gajz.transferrelationship.bean.vo.TransferredPersonVo;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* 导入转账关系17号线程
* @author lenovo
*/
public class TransferAccountsSeventeen implements Runnable{
List<TransferredPersonVo> transferList;
public void TransferAccountsSeventeenList(List<TransferredPersonVo> transferCollectionList){
this.transferList=transferCollectionList;
}
@Override
public void run() {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("线程17开始"+df.format(new Date()));
HugeClient hugeClient = HugeClient.builder("http://36.148.1.253:8289","hugegraph2")
/*** 默认未开启用户权限*/
.configUser("**", "**")
.build();
GraphManager graph = hugeClient.graph();
for (int i=0;i<transferList.size();i++){
Vertex transferor = graph.getVertex(transferList.get(i).getBankCardNo());
Vertex payee = graph.getVertex(transferList.get(i).getEndCardNo());
//创建转账关系
transferor.addEdge("多人转账", payee, "转账次数", transferList.get(i).getNumber());
}
hugeClient.close();
System.out.println("线程17结束"+df.format(new Date()));
}
}
src/main/java/com/example/gajz/transferrelationship/thread/TransferAccountsSix.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.thread;
import com.baidu.hugegraph.driver.GraphManager;
import com.baidu.hugegraph.driver.HugeClient;
import com.baidu.hugegraph.structure.graph.Vertex;
import com.example.gajz.transferrelationship.bean.vo.TransferredPersonVo;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* 线程6
* @author lenovo
*/
public class TransferAccountsSix implements Runnable{
List<TransferredPersonVo> transferList;
public void TransferAccountsSixList(List<TransferredPersonVo> transferCollectionList){
this.transferList=transferCollectionList;
}
@Override
public void run() {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("线程6开始"+df.format(new Date()));
HugeClient hugeClient = HugeClient.builder("http://36.148.1.253:8289","hugegraph2")
/*** 默认未开启用户权限*/
.configUser("**", "**")
.build();
GraphManager graph = hugeClient.graph();
for (int i=0;i<transferList.size();i++){
Vertex transferor = graph.getVertex(transferList.get(i).getBankCardNo());
Vertex payee = graph.getVertex(transferList.get(i).getEndCardNo());
//创建转账关系
transferor.addEdge("多人转账", payee, "转账次数", transferList.get(i).getNumber());
}
hugeClient.close();
System.out.println("线程6结束"+df.format(new Date()));
}
}
src/main/java/com/example/gajz/transferrelationship/thread/TransferAccountsSixteen.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.thread;
import com.baidu.hugegraph.driver.GraphManager;
import com.baidu.hugegraph.driver.HugeClient;
import com.baidu.hugegraph.structure.graph.Vertex;
import com.example.gajz.transferrelationship.bean.vo.TransferredPersonVo;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* 导入转账关系16号线程
* @author lenovo
*/
public class TransferAccountsSixteen implements Runnable{
List<TransferredPersonVo> transferList;
public void TransferAccountsSixteenList(List<TransferredPersonVo> transferCollectionList){
this.transferList=transferCollectionList;
}
@Override
public void run() {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("线程16开始"+df.format(new Date()));
HugeClient hugeClient = HugeClient.builder("http://36.148.1.253:8289","hugegraph2")
/*** 默认未开启用户权限*/
.configUser("**", "**")
.build();
GraphManager graph = hugeClient.graph();
for (int i=0;i<transferList.size();i++){
Vertex transferor = graph.getVertex(transferList.get(i).getBankCardNo());
Vertex payee = graph.getVertex(transferList.get(i).getEndCardNo());
//创建转账关系
transferor.addEdge("多人转账", payee, "转账次数", transferList.get(i).getNumber());
}
hugeClient.close();
System.out.println("线程16结束"+df.format(new Date()));
}
}
src/main/java/com/example/gajz/transferrelationship/thread/TransferAccountsTen.java 0 → 100644
View file @ fa8898b2
package com.example.gajz.transferrelationship.thread;
import com.baidu.hugegraph.driver.GraphManager;
import com.baidu.hugegraph.driver.HugeClient;
import com.baidu.hugegraph.structure.graph.Vertex;
import com.example.gajz.transferrelationship.bean.vo.TransferredPersonVo;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
/**
* 导入转账关系10号线程
* @author lenovo
*/
public class TransferAccountsTen implements Runnable{
List<TransferredPersonVo> transferList;
public void TransferAccountsTenList(List<TransferredPersonVo> transferCollectionList){
this.transferList=transferCollectionList;
}
@Override
public void run() {
SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("线程10开始"+df.format(new Date()));
HugeClient hugeClient = HugeClient.builder("http://36.148.1.253:8289","hugegraph2")
/*** 默认未开启用户权限*/
.configUser("**", "**")
.build();
GraphManager graph = hugeClient.graph();
for (int i=0;i<transferList.size();i++){
Vertex transferor = graph.getVertex(transferList.get(i).getBankCardNo());
Vertex payee = graph.getVertex(transferList.get(i).getEndCardNo());
//创建转账关系
transferor.addEdge("多人转账", payee, "转账次数", transferList.get(i).getNumber());
}
hugeClient.close();
System.out.println("线程10结束"+df.format(new Date()));
}
}
src/main/resources/application.properties 0 → 100644
View file @ fa8898b2
#配置文件信息
spring.thymeleaf.prefix=classpath:/static/
spring.thymeleaf.suffix=.html
#整合mybatis
mybatis.mapper-locations=classpath:/mapper/*.xml
mybatis.type-aliases-package=com.example.boot.bean
logging.level.com.example.pas.dao=debug
#服务器 端口
server.port=8090
#设置单个文件大小
spring.servlet.multipart.max-file-size= 50MB
#设置单次请求文件的总大小
spring.servlet.multipart.max-request-size= 50MB
src/main/resources/application.yml 0 → 100644
View file @ fa8898b2
This diff is collapsed.
src/main/resources/banner.txt 0 → 100644
View file @ fa8898b2
This diff is collapsed.
src/main/resources/mapper/TransferRelationshipMapper.xml 0 → 100644
View file @ fa8898b2
This diff is collapsed.
src/test/java/com/example/gajz/GajzApplicationTests.java 0 → 100644
View file @ fa8898b2
package com.example.gajz;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
@SpringBootTest
class GajzApplicationTests {
@Test
void contextLoads() {
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment