package com.cloud.user.service.impl;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.cloud.common.utils.FastDFSUtil;
|
import com.cloud.common.utils.RestTemplateUtil;
|
import com.cloud.user.dao.BbEmployeeDao;
|
import com.cloud.user.dao.PersonMergeDao;
|
import com.cloud.user.model.*;
|
import com.cloud.user.service.BbPersonToDevService;
|
import com.cloud.user.utils.Base64Utils;
|
import com.cloud.user.utils.EnumStr;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.http.MediaType;
|
import org.springframework.stereotype.Service;
|
|
import java.io.UnsupportedEncodingException;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
@Slf4j
|
@Service
|
public class BbPersonToDevSerImpl implements BbPersonToDevService {
|
|
@Value("${c_server.port}")
|
private String c_ser_port = "";
|
@Value("${dev_server.ip_host}")
|
private String devServer = "";
|
@Value("${dev_server.port}")
|
private String devPort = "";
|
@Value("${dev_server.addpath}")
|
private String addPath = "";
|
@Autowired
|
private RestTemplateUtil restTempUtil;
|
@Autowired
|
private EnumStr enumStr;
|
@Autowired
|
private BbEmployeeDao bbEmployeeDao;
|
@Autowired
|
private PersonMergeDao perMergeDao;
|
|
private SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
@Autowired
|
private FastDFSUtil fastDFSUtil;
|
|
private Integer times = 0 ;
|
@Override
|
public JSONArray getAllCluListData() {
|
JSONArray dbClues = new JSONArray();
|
log.info("devServer:"+devServer+"addPath:"+addPath);
|
JSONObject devJson = restTempUtil.post(devServer + ":" + devPort + addPath + "/getAllCluListData",
|
null, MediaType.APPLICATION_JSON_UTF8, JSONObject.class, true);
|
JSONArray dbJson = null;
|
log.info("设备返回json：data:"+ devJson.getJSONArray("data"));
|
if (devJson.getBoolean("success")){
|
dbJson = devJson.getJSONArray("data");
|
}else{
|
throw new RuntimeException("设备模块查询集群设备信息："+devJson.getString("msg"));
|
}
|
for (Object db : dbJson) {
|
JSONObject dBaseCluster = new JSONObject(); // 空值
|
JSONObject dbo = (JSONObject)db;
|
dBaseCluster.put("id",dbo.getString("cluster_id"));
|
dBaseCluster.put("label",dbo.getString("cluster_name"));
|
dBaseCluster.put("parentId","0");
|
List<ClusterNode> cluList = new ArrayList<ClusterNode>();
|
log.info("集群设备遍历查询:"+dBaseCluster.toJSONString());
|
// 2. 第二种方式
|
JSONArray list = dbo.getJSONArray("list");
|
JSONArray children = new JSONArray();
|
if (list != null && list.size() > 0){
|
for (Object o : list) {
|
JSONObject obj = (JSONObject)o;
|
JSONObject jsonObj = new JSONObject();
|
jsonObj.put("parentId",dbo.getString("cluster_id"));
|
jsonObj.put("id",obj.getString("uuid"));
|
jsonObj.put("label",obj.getString("dev_name"));
|
jsonObj.put("children",new JSONArray());
|
children.add(jsonObj);
|
}
|
log.info("集群设备查询：设备遍历;--->"+list);
|
}
|
dBaseCluster .put("children",children);
|
dbClues.add(dBaseCluster);
|
}
|
// ============ 接口 未通调用下方
|
/* DBaseCluster dBaseCluster = new DBaseCluster(); // 空值
|
dBaseCluster.setCluId("uuid-ts");
|
dBaseCluster.setCluName("cluster-name");
|
ArrayList<ClusterNode> cluList = new ArrayList<>();
|
ClusterNode clusterNode = new ClusterNode();
|
clusterNode.setUuid("wp-test-uuid1");
|
clusterNode.setNode_ip("192.168.1.148");
|
clusterNode.setDev_name("wp-test1");
|
cluList.add(clusterNode);
|
dBaseCluster.setCluList(cluList);
|
dbClues.add(dBaseCluster);*/
|
return dbClues;
|
}
|
|
@Override
|
public List<DBaseCluster> getAllCluDataBaseList(){
|
List<DBaseCluster> dbClues = new ArrayList<DBaseCluster>();
|
log.info("devServer:"+devServer+"addPath:"+addPath);
|
JSONObject devJson = restTempUtil.post(devServer + ":" + devPort + addPath +"/getAllCluDataBaseList",
|
null, MediaType.APPLICATION_JSON_UTF8, JSONObject.class, true);
|
log.info("设备返回:devJson：----》"+ devJson);
|
if (devJson != null && devJson.getBoolean("success") ){
|
JSONArray clues = devJson.getJSONArray("data");
|
log.info("各集群底库列表查询----》"+clues.toJSONString());
|
if (clues!=null && clues.size()>0)
|
for (Object clue : clues){
|
JSONObject clu = (JSONObject)clue;
|
DBaseCluster cluster = new DBaseCluster();
|
cluster.setCluId(clu.getString("cluster_id"));
|
cluster.setCluName(clu.getString("cluster_name"));
|
JSONArray syncDataBase = clu.getJSONArray("syncDataBase");
|
List<SyncDataBase> sdb = new ArrayList<>();
|
if (syncDataBase != null){
|
sdb = JSONObject.parseArray(syncDataBase.toJSONString(), SyncDataBase.class);
|
}
|
cluster.setSyncDataBase(sdb);
|
JSONArray cluIPList = clu.getJSONArray("cluIPList");
|
List<CluIP> Ips = new ArrayList<>();
|
if (cluIPList != null){
|
Ips = JSONObject.parseArray(cluIPList.toJSONString(), CluIP.class);
|
}
|
cluster.setCluIPList(Ips);
|
dbClues.add(cluster); // 将封装 集群数据 加入集合
|
}
|
}else {
|
throw new RuntimeException("各集群底库列表查询异常。");
|
}
|
// 接口 未 通 调用 下方 内容
|
/* DBaseCluster dBaseCluster = new DBaseCluster(); // 空值
|
dBaseCluster.setCluId("uuid-db");
|
dBaseCluster.setCluName("cluster-name");
|
ArrayList<SyncDataBase> dataBase = new ArrayList<>();
|
SyncDataBase syncDataBase = new SyncDataBase();
|
syncDataBase.setTableName("wp-test-db1");
|
syncDataBase.setUuid("wp-uuid-db1");
|
dataBase.add(syncDataBase);
|
SyncDataBase syncDataBase2 = new SyncDataBase();
|
syncDataBase2.setTableName("wp-test-db2");
|
syncDataBase2.setUuid("wp-uuid-db2");
|
dataBase.add(syncDataBase2);
|
dBaseCluster.setSyncDataBase(dataBase);
|
dbClues.add(dBaseCluster);*/
|
log.info("各集群底库列表 service 返回信息----》"+dbClues.toString());
|
return dbClues;
|
}
|
|
/**
|
* String ipes = JSONArray.toJSONString(cips);
|
* JSONArray objects = JSONArray.parseArray(ipes);
|
* 调用 c 服务 添加 人员
|
* @param persons
|
* @param ipInfos
|
* @return
|
*/
|
@Override
|
public List<PerInDBStatus> addSyncPersons(List<CServerPerson> persons, List<IpTable> ipInfos){
|
List<PerInDBStatus> perDBStatus = new ArrayList<PerInDBStatus>();
|
List<CSerResult> dbClues = null;
|
JSONObject objects = new JSONObject();
|
|
log.info("分享service添加人员:===>"+persons);
|
String peres = JSONArray.toJSONString(persons);// 将对象 序列化成json string
|
JSONArray perJsons = JSONArray.parseArray(peres); // 对象 json 序列化
|
objects.put("personList",perJsons);
|
|
// 将人员 id 加入 到 perDBStatus 中
|
for (CServerPerson person : persons){
|
PerInDBStatus perInDBS = new PerInDBStatus();
|
perInDBS.setPersonId(person.getPersonId());
|
perDBStatus.add(perInDBS); //
|
}
|
log.info("分享service添加底库ipInfos:===>"+ipInfos);
|
int ipInfoIndex = 1,ipInfoMax = ipInfos.size();
|
for (IpTable ipTab : ipInfos){ // 遍历 集群 信息
|
List<String> tableIds = ipTab.getTableIds();
|
for (String tableId : tableIds){
|
objects.put("uuid",tableId);
|
String dbClueJsons = restTempUtil.post( "http://"+ipTab.getIp()+ ":" + c_ser_port + "/addPersons", // ipTab.getIp() 192.168.1.124
|
objects, MediaType.APPLICATION_JSON_UTF8, String.class, false);
|
dbClues = JSONArray.parseArray(dbClueJsons, CSerResult.class);
|
log.info("分享service添加底库http 参数:===>"+objects.toJSONString());
|
// 假数据
|
/* int times = 1 ;
|
String testAddPersonJson = "["; // 1 true/-1 false\
|
for (CServerPerson person : persons){
|
if (times != persons.size()){
|
if (times%2==0){
|
testAddPersonJson += "{\"personId\":\""+person.getPersonId()+"\",\"result\":\"-1\",\"msg\":\"error\"},";
|
}else {
|
testAddPersonJson += "{\"personId\":\""+person.getPersonId()+"\",\"result\":\"1\",\"msg\":\"success\"},";
|
}
|
}else {
|
testAddPersonJson += "{\"personId\":\""+person.getPersonId()+"\",\"result\":\"-1\",\"msg\":\"error\"}]";
|
}
|
times++;
|
}
|
dbClues = JSONArray.parseArray(testAddPersonJson, CSerResult.class);*/
|
// 待修改。。。。。。。。。
|
log.info("分享service添加底库http return 返回信息:===>"+dbClues);
|
for (CSerResult cResult : dbClues){
|
for (PerInDBStatus perStatus : perDBStatus){
|
if (perStatus.getPersonId().equalsIgnoreCase(cResult.getPersonId())){
|
String result = cResult.getResult();
|
String msg = cResult.getMsg();
|
if (result == null || "".equals(result)){
|
msg = "c 服务调用失败。";
|
perStatus.setIsSuccess(false);
|
if (ipInfoIndex == 1){
|
perStatus.setIsSomeSuccess(false);
|
}
|
}else if("-1".equalsIgnoreCase(result)){
|
perStatus.setIsSuccess(false);
|
if (ipInfoIndex == 1){
|
perStatus.setIsSomeSuccess(false);
|
}
|
}else{
|
if (ipInfoIndex == 1){ // 第一次成功 ，后续在成功 则全部成功，
|
perStatus.setIsSuccess(true);
|
}
|
if (ipInfoIndex == 1 || !perStatus.getIsSomeSuccess()){ // 判断全部失败 则false
|
perStatus.setIsSomeSuccess(true);
|
}
|
}
|
DataBaseStatus dataBaseStatus = new DataBaseStatus(tableId,
|
null,result,msg);
|
if (perStatus.getIsSomeSuccess())perStatus.getCluList().add(ipTab.getCluId()); // 集群信息
|
perStatus.getDbStatus().add(dataBaseStatus);
|
}
|
}
|
}
|
}
|
++ipInfoIndex; // 集群 遍历坐标
|
}
|
log.info("分享service添加底库多人状态 service return 返回信息:===>"+perDBStatus);
|
return perDBStatus;
|
}
|
|
/**
|
* 依据 ids 获取多人数据
|
* @param personIds
|
* @return
|
*/
|
public List<CServerPerson> findByPersonIds(List<String> personIds){
|
List<CServerPerson> byPersonIds = new ArrayList<>();
|
if (personIds== null){
|
log.info("查询人员id为空null,当然查不到人啦！~~");
|
return byPersonIds;
|
}
|
log.info(personIds.size()+"查询多人总库bb_person_base信息："+personIds);
|
byPersonIds = bbEmployeeDao.findByPersonIds(new HashSet(personIds),null);
|
log.info(byPersonIds.size()+"查询多人总库bb_person_base return返回信息："+byPersonIds);
|
return byPersonIds;
|
}
|
|
@Override
|
public List<JSONObject> addPersonsToEs(List<String> personIds) {
|
List<JSONObject> esPersonIds = new ArrayList<>();
|
if (personIds== null){
|
log.info("查询人员id为空null,当然查不到人啦！~~");
|
return esPersonIds;
|
}
|
List<PadPersonInfo> byPersonIds = bbEmployeeDao.findByPersonIds(new HashSet(personIds),null);
|
|
for (PadPersonInfo byPersonId : byPersonIds) {
|
byte[] feature = byPersonId.getByteFeature();
|
if (feature == null || feature.length < 10){
|
JSONObject esAddPerson = new JSONObject();
|
esAddPerson.put("status",false);
|
esAddPerson.put("personId",byPersonId.getPersonId());
|
esAddPerson.put("msg","feature 人员特征值不存在。");
|
esPersonIds.add(esAddPerson);
|
log.info(byPersonId.getPersonId()+"该人员缺特征值不能加入es索引");
|
}else {
|
JSONObject jsonEs = JSONObject.parseObject(JSONObject.toJSONString(byPersonId));
|
jsonEs.put("id",byPersonId.getPersonId());
|
jsonEs.put("update_time",sdf.format(new Date()));
|
String photos = byPersonId.getPhotos();
|
if (StringUtils.isBlank(photos) || photos.length() < 5 ){
|
// 暂无特征值
|
}else{
|
try {
|
byte[] bytes = fastDFSUtil.downloadFDFS(byPersonId.getPhotos());
|
String s = Base64Utils.byteToBase64(bytes);
|
jsonEs.put("personImage",s); //
|
} catch (Exception e){
|
e.printStackTrace();
|
JSONObject esAddPerson = new JSONObject();
|
esAddPerson.put("status",false);
|
esAddPerson.put("personId",byPersonId.getPersonId());
|
esAddPerson.put("msg",byPersonId.getPhotos()+"人员图片路径有误，"+e.getLocalizedMessage());
|
esPersonIds.add(esAddPerson);
|
log.info("图片base64下载失败。");
|
break;
|
}
|
}
|
jsonEs.put("id_card_number",byPersonId.getIdcard()); //
|
jsonEs.put("personFeature",Base64Utils.byteToBase64(feature)); //
|
jsonEs.put("camera_image_fastdfs_path",photos);
|
jsonEs.put("synchronization_status","0");
|
if (byPersonId.getPersonId().startsWith("PSVAD")){ // 分析设备
|
jsonEs.put("indevice_type","1");
|
}else if (byPersonId.getPersonId().startsWith("PSSVR")){ // 后台添加人员
|
jsonEs.put("indevice_type","2");
|
}else if (byPersonId.getPersonId().startsWith("PSPAD")){ // 进出入pad
|
jsonEs.put("indevice_type","3");
|
}else {
|
jsonEs.put("indevice_type","4");
|
}
|
// 移除 非必要 字段
|
jsonEs.remove("idcard"); // 移除
|
jsonEs.remove("feature");
|
jsonEs.remove("personPic");
|
jsonEs.remove("byteFeature");
|
JSONObject jsonParam = new JSONObject();
|
jsonParam.put("doc",jsonEs);
|
jsonParam.put("doc_as_upsert",true);
|
// 人员数据 待 加入 es 新建 索引中
|
String esUrl = "http://"+enumStr.getEsHOSTNAME()+":"+enumStr.getEsHTTP_PORT()+EnumStr.esUserIndex+"/"+jsonEs.getString("id")+"/_update";
|
String post1 = RestTemplateUtil.post(esUrl, jsonParam, MediaType.APPLICATION_JSON_UTF8, false);
|
JSONObject jsonObject = JSONObject.parseObject(post1);
|
JSONObject shards = jsonObject.getJSONObject("_shards");
|
if (shards != null ){ // successful
|
Integer successful = shards.getInteger("successful");
|
if (successful != null){
|
// 成功
|
JSONObject esAddPerson = new JSONObject();
|
esAddPerson.put("status",true);
|
esAddPerson.put("personId",byPersonId.getPersonId());
|
esAddPerson.put("msg","人员 数据上传es成功。");
|
esPersonIds.add(esAddPerson);
|
log.info("加入es成功");
|
}else {
|
JSONObject esAddPerson = new JSONObject();
|
esAddPerson.put("status",false);
|
esAddPerson.put("personId",byPersonId.getPersonId());
|
esAddPerson.put("msg","人员 数据上传es 存在问题,"+shards);
|
esPersonIds.add(esAddPerson);
|
log.info("加入es失败："+jsonObject.getJSONObject("error"));
|
}
|
}else {
|
JSONObject esAddPerson = new JSONObject();
|
esAddPerson.put("status",false);
|
esAddPerson.put("personId",byPersonId.getPersonId());
|
esAddPerson.put("msg","人员 数据上传es 存在问题,"+jsonObject.getJSONObject("error"));
|
esPersonIds.add(esAddPerson);
|
log.info("加入es失败："+jsonObject.getJSONObject("error"));
|
}
|
}
|
}
|
return esPersonIds;
|
}
|
|
/**
|
* 查询人员状态
|
* @param personId
|
* @param ips
|
* @return
|
*/
|
@Override
|
public List<CSerResult> isExists(String personId, List<String> ips) throws UnsupportedEncodingException {
|
List<CSerResult> cResults = new ArrayList<CSerResult>();
|
JSONObject object = new JSONObject();
|
object.put("personId",personId);
|
log.info("service isExists 查询单人底库信息：--->"+personId);
|
// int times = 0 ;
|
log.info("service isExists 查询单人底库信息：--->"+ips);
|
for (String ip : ips){
|
// CSerResult cResult
|
// JSONObject result = restTempUtil.post("http://"+ip + ":" + c_ser_port + "/personIsExists",
|
// object, MediaType.APPLICATION_JSON_UTF8, JSONObject.class, false);
|
String result = restTempUtil.post("http://"+ip + ":" + c_ser_port + "/personIsExists",
|
object, MediaType.APPLICATION_JSON_UTF8, String.class, false);
|
|
CSerResult cResult = JSONObject.parseObject(new String(result.getBytes("ISO8859-1"),"utf-8"),CSerResult.class);
|
cResult.setPersonId(personId);
|
|
|
cResults.add(cResult);
|
}
|
return cResults;
|
}
|
|
/**
|
* 更新 人员 service
|
* @param personIds
|
* @param ips
|
* @return
|
*/
|
@Override
|
public Map<String,List<UpdatePerToViewResult>> updateSyncPersons(List<String> personIds, List<String> ips) throws UnsupportedEncodingException {
|
log.info("待更新人员数据--->:"+personIds+"待更新人员集群ip--->:"+ips);
|
List<CServerPerson> byPersonIds = bbEmployeeDao.findByPersonIds(new HashSet(personIds),null);
|
|
Map<String,List<UpdatePerToViewResult>> cResult = new HashMap<String,List<UpdatePerToViewResult>>();
|
if (byPersonIds.size()<1){
|
throw new RuntimeException("请选择总库存在人员");
|
}
|
/* if (personIds.size()!=byPersonIds.size()){
|
throw new RuntimeException("选择的总库人员中有人数据信息不完善，不能进行分享。");
|
}*/
|
for (CServerPerson byPersonId : byPersonIds){
|
// 获取 当前 新人员 所 关联 待更新人员
|
PersonMerge personMerge = perMergeDao.selectPersonMergeByPersonId(byPersonId.getPersonId());
|
String oldPerIds = null;String[] persones = {};
|
List<UpdatePerToViewResult> viewResults = new ArrayList<UpdatePerToViewResult>();
|
if (personMerge !=null){ // 返回该人员所须 合并人员信息
|
oldPerIds = personMerge.getMergeFrom();
|
persones = oldPerIds.split(",");
|
//
|
/* for (String persone : persones) {
|
UpdatePerToViewResult upPerViewResult = new UpdatePerToViewResult();
|
upPerViewResult.setPersonId(persone);
|
List<CSerResult> exists = isExists(persone, ips);
|
for (CSerResult exist : exists) {
|
upPerViewResult.getAllDataBase().addAll(exist.getExistDataBase());
|
}
|
|
}*/
|
cResult.put(byPersonId.getPersonId(),viewResults);
|
}else {
|
CSerResult dbClues = new CSerResult();
|
dbClues.setPersonId(byPersonId.getPersonId());
|
cResult.put(byPersonId.getPersonId(),null);
|
// return cResult;
|
}
|
Set<String> personls = new HashSet(Arrays.asList(persones));
|
for (int i = 0,item = ips.size();i < item; ++i){
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("newPerId",byPersonId.getPersonId());
|
jsonObject.put("idcard",byPersonId.getIdcard());
|
jsonObject.put("perPicUrl",byPersonId.getPersonPic());
|
if (byPersonId.getByteFeature() == null || byPersonId.getByteFeature().length < 5){
|
throw new RuntimeException(byPersonId.getPersonId()+"该人员特征值为空，请管理员处理。");
|
}
|
jsonObject.put("feature", Base64Utils.byteToBase64(byPersonId.getByteFeature()));
|
if (oldPerIds != null && personls.size() > 0){
|
// String testAddPersonJson = "["; // 测试使用json
|
for (String person : personls){
|
UpdatePerToViewResult upPerViewResult = new UpdatePerToViewResult();
|
upPerViewResult.setPersonId(person);
|
List<CSerResult> exists = isExists(person, ips);
|
for (CSerResult exist : exists) {
|
upPerViewResult.getAllDataBase().addAll(exist.getExistDataBase());
|
}
|
/*if (exists ==null || exists .size()<1){ // wp 修改于2018-12-13 ,考虑人员不存在于分析各节点上的情况
|
upPerViewResult.setResult("0");
|
}*/
|
// viewResults.add(upPerViewResult);
|
jsonObject.put("oldId",person);
|
log.info(jsonObject+"===>>>跟新人员发送信息");
|
String dbClueJsons = restTempUtil.post("http://"+ips.get(i) + ":" + c_ser_port + "/updatePersonByOldId",
|
jsonObject, MediaType.APPLICATION_JSON_UTF8, String.class, false);
|
new String();
|
UpdatePerToViewResult dbClues = JSONObject.parseObject(dbClueJsons,UpdatePerToViewResult.class);
|
log.info("返回人员更新后的信息===>>>"+dbClues);
|
|
dbClues.setPersonId(person); // 赋值
|
|
if ("1".equals(dbClues.getResult())){ // 说明 存在
|
// UpdatePerToViewResult cSerResult = cResult.get(person);
|
if (upPerViewResult.getResult()==null){upPerViewResult.setResult("1");
|
upPerViewResult.setMsg("success");}
|
upPerViewResult.getExistDataBase().addAll(dbClues.getExistDataBase());
|
// cResult.put(person,cSerResult);
|
}else if ("-1".equals(dbClues.getResult())){
|
// UpdatePerToViewResult cSerResult = cResult.get(person);
|
upPerViewResult.setResult("-1");
|
upPerViewResult.setMsg("error");
|
// cResult.put(person,upPerViewResult);
|
}else {
|
// UpdatePerToViewResult cSerResult = cResult.get(person);
|
if (upPerViewResult.getResult()==null){upPerViewResult.setResult("0");
|
upPerViewResult.setMsg("succes"); //cResult.put(person,cSerResult);
|
}
|
}
|
viewResults.add(upPerViewResult);
|
}
|
}else{ // 不包含 待更新人员 也需要将人员更新一便
|
jsonObject.put("oldId","");
|
String dbClueJsons1 = restTempUtil.post("http://"+ips.get(i) + ":" + c_ser_port + "/updatePersonByOldId",
|
jsonObject, MediaType.APPLICATION_JSON_UTF8, String.class, false);
|
|
UpdatePerToViewResult dbClues = // new UpdatePerToViewResult();
|
JSONObject.parseObject(dbClueJsons1,UpdatePerToViewResult.class); // 测试时给空对象，实际要调用c接口
|
|
dbClues.setPersonId(byPersonId.getPersonId()); // 赋值
|
viewResults.add(dbClues);
|
}
|
}
|
cResult.put(byPersonId.getPersonId(),viewResults);
|
}
|
return cResult;
|
}
|
|
@Override
|
public List<MergePersonView> queryUpdatingPerson(String personLike) {
|
List<MergePersonView> allMergePerson = bbEmployeeDao.findAllMergePerson();
|
MergePersonView mergePerson = null;
|
for (int i = 0;i < allMergePerson.size();++i){
|
mergePerson = allMergePerson.get(i);
|
boolean flag = true;
|
if (personLike!=null && !personLike.isEmpty()){
|
String idCard = mergePerson.getIdcard();
|
String perName = mergePerson.getName();
|
if ((idCard!=null && idCard.contains(personLike))||(perName!=null && perName.contains(personLike))){
|
}else { flag = false;}
|
}
|
String mergeFrom = mergePerson.getMergeFrom();
|
if (mergeFrom!=null){
|
String[] split = mergeFrom.split(",");
|
mergePerson.setMergePersonIds(new HashSet(Arrays.asList(split)));
|
List<CServerPerson> byPersonIds = bbEmployeeDao.findByPersonIds(new HashSet(Arrays.asList(split)),personLike);
|
if (flag || byPersonIds.size()>0 ){
|
mergePerson.setMergePersonList(byPersonIds);
|
}else{
|
allMergePerson.remove(i--);
|
}
|
}
|
}
|
return allMergePerson;
|
}
|
|
@Override
|
public Integer queryUpdatingPersonCount() {
|
return bbEmployeeDao.queryUpdatingPersonCount();
|
}
|
|
@Override
|
public Integer deleteMergePersonByPersonId(String personId) {
|
return bbEmployeeDao.deleteMergePerson(personId);
|
}
|
|
@Override
|
public Integer updatePersonForCluInfo(Set<String> cluInfos, String personId) {
|
if (cluInfos==null || cluInfos.size()<1){
|
return 0;}else {
|
return bbEmployeeDao.updateBbPersonBaseForCluInfo(cluInfos,personId);
|
}
|
}
|
|
|
}
|
