package com.cloud.user.service;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.cloud.user.model.*;
|
|
import java.io.UnsupportedEncodingException;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Set;
|
|
public interface BbPersonToDevService {
|
|
/**
|
* 获取所有 集群名称
|
*
|
* @return
|
*/
|
JSONArray getAllCluListData();
|
/**
|
* 获取集群下所有底库
|
* [{
|
* "cluId": "",
|
* "cluName": "",
|
* "cluIPList": [{
|
* "uuid": "317026e2-6df8-5bac-aea4-166d2ee250fb",
|
* "node_ip": ""
|
* },
|
* {
|
* "uuid": "317026e2-6df8-5bac-aea4-166d2ee250fb",
|
* "node_ip": ""
|
* }
|
* ],
|
* "syncDataBase": [{
|
* "uuid": "e92a005e-fc19-56b5-8a23-53570bc270ae", //表uuid
|
* "tableName": "test", //表名
|
* "tableType": "person", //表类型
|
* "bwType": "1" //黑白名单* }]
|
* }]
|
*
|
* @return
|
*/
|
List<DBaseCluster> getAllCluDataBaseList();
|
/**
|
* 人员添加-----c服务
|
* ip:port/addPersons
|
* {"uuid":"", // tableName的uuid
|
* "personList":[{"personId":"","idcard":"","personPic":"url"},
|
* {"personId":"","idcard":"","personPic":"url"}]}
|
* // 人员添加 id 存在则更新，不存在则 添加
|
*/
|
List<PerInDBStatus> addSyncPersons(List<CServerPerson> persons, List<IpTable> ipInfos);
|
|
/**
|
* 依据personsIds 获取 多人返回数据 需要判断 personIds sizes 不能为 0
|
* @param personIds
|
* @return
|
*/
|
List<CServerPerson> findByPersonIds(List<String> personIds);
|
|
/**
|
* 依据personsIds 获取 多人返回数据 需要判断 personIds sizes 不能为 0
|
* @param personIds
|
* @return
|
*/
|
List<JSONObject> addPersonsToEs(List<String> personIds);
|
/**
|
* 人员查询状态--c服务
|
* 接收：{"personId":""}
|
* 返回：{"result":"true/false",
|
* "data":"exist/notexist","msg":"success/error"}
|
* // result "true" 执行成功 false 失败
|
* // true 时 data 给定 1 exist/0 notexist false -1
|
* // msg 给定判定执行信息
|
*/
|
List<CSerResult> isExists(String personId, List<String> ip) throws UnsupportedEncodingException;
|
|
/**
|
* 人员更新-----c服务
|
* ip:port/updatePersonByOldId
|
* 接收：{"newPerId":"","idcard":"","perPicUrl":"","oldId",""}
|
* 返回：{"result":"true/false",
|
* "data":"exist/notexist","msg":"success/error"}
|
* // 存在则更新，不存在则不执行 返回不存在
|
* // result "true" 执行成功 false 失败
|
* // true 时 data 给定 1 exist/0 notexist false -1
|
* // msg 给定判定执行信息 Map<String,CSerResult> 改为 Map<String,List<CSerResult>>
|
*/
|
Map<String,List<UpdatePerToViewResult>> updateSyncPersons(List<String> personIds, List<String> ips) throws UnsupportedEncodingException;
|
|
/**
|
* 查询待更新人员
|
* @return
|
*/
|
List<MergePersonView> queryUpdatingPerson(String personLike);
|
/**
|
* 查询待更新人员总数
|
* @return
|
*/
|
Integer queryUpdatingPersonCount();
|
/**
|
* 删除更新人员
|
* @return
|
*/
|
Integer deleteMergePersonByPersonId(String personId);
|
/**
|
*
|
*/
|
Integer updatePersonForCluInfo(Set<String> cluInfos, String personId);
|
}
|
