项目相关事宜

项目结构

我们主要是分为两个region：

1. cloud-activiti，主要负责与前端进行对接，负责整个 activiti 流程的管控
2. cloud-produce，提供企业关系的微服务

其中，cloud-activiti 提供了任务下发、获取任务的实时进度两个接口、调用其他模块的微服务，cloud-produce 提供了分析接口、结果展示接口。

采集模块的数据存储在 139.9.246.214 「mongo」

分析模块的数据存储在 212.129.248.93 「mongo」

Activiti 的表的数据和任务表在 rm-bp1k8havcf27iw5ml125010hm.mysql.rds.aliyuncs.com 「」

接口

1. 任务下发接口

接口如下：

public ProcessStatusResult startEnterpriseRelationshipAnalyse()

返回的对象 Result 包含的变量有：

String msg
int code

由于全部采用 GraphQL 接口形式，所以访问方式需要如以下形式：

query{
	startProcess(taskId: "111", userId: "jerome", module: "Indeed", organizationName: "Apple", organizationUrl: ""){
			code
      msg
	}
}

2. 任务进度查询接口

获取当前任务进度接口如下：

public ProcessCurrentTaskResult currentTask(String processInstanceId)

返回的对象 xxx 包含的变量有：

String

访问方式如下：

query{
  currentTask(processInstanceId: "xxxxx"){
    ProcessCurrentTaskResult
  }
}

3. 特定企业关系结果展示接口

接口如下：

public List<AnalysisJsonResponse> getSpecialCompanyBusinessRelationShips(String companyName, String taskId)

返回的对象 AnalysisJsonResponse 包含的变量有：

private String fromCompanyName;
private String toCompanyName;
private String relation;

访问方式如下：

query{
  getSpecialCompanyBusinessRelationShips(companyName:"Apple",taskId:"111"){
    fromCompanyName
    toCompanyName
    relation   
  }
}

4. 企业关系全部结果展示接口

接口如下：

public List<AnalysisJsonResponse> getAllCompaniesBusinessRelationShips(String taskId)

访问方式如下：

query{
  getAllCompaniesBusinessRelationShips(taskId:"111"){
    fromCompanyName
    toCompanyName
    relation   
  }
}

5. 待补充「任务相关接口」

相关表结构

• 企业关系结果展示表结构：

• 任务表结构

名	类型	含义
task_id	varchar	任务表的主键
process_code	varchar	流程名称，一套流程拥有同一个process_code
process_id	varchar	单个流程的主键
user_id	varchar	用户id
organization_name	varchar	要调查的组织名称
organization_url	varchar	要调查的组织对应的url
odule	varchar	要调查的模块，如 Indeed
progress	varchar	任务进度
status	varchar	任务状态，如已完成，分析中
create_time	varchar	任务开始时间
end_time	varchar	任务结束时间