productDev/dmvisit.git

			@@ -28,6 +28,7 @@
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.scheduling.annotation.Async;
			import org.springframework.stereotype.Service;
			import org.springframework.transaction.annotation.Transactional;

			import java.util.ArrayList;
			import java.util.Date;
			@@ -57,6 +58,7 @@
			*/
			@Override
			public Integer syncEmpowerDetailData(Integer endId){
			log.error("");
			// if(Constants.DEALING_HK_EMPOWER_DETAIL){
			// return ;
			// }
			@@ -435,7 +437,12 @@
			Thread t1=new Thread(new Runnable() {
			@Override
			public void run() {
			dealAllListTask(allList);
			try {
			dealAllListTask(allList);
			}catch (Exception e){
			log.info("======================下发授权异常："+e.getMessage());
			e.printStackTrace();
			}
			}
			});
			t1.start();
			@@ -524,21 +531,7 @@

			}
			}
			public class TaskRuner implements Runnable{
			private List<Empower> list ;
			@Override
			public void run() {
			dealNewListTask(list);
			}

			public List<Empower> getList() {
			return list;
			}

			public void setList(List<Empower> list) {
			this.list = list;
			}
			}
			@Transactional(rollbackFor = {BusinessException.class,Exception.class})
			private void dealAllListTask(List<Empower> list) {
			//按照父级申请分批处理每次申请数据
			if(list ==null \|\| list.size()==0){
			@@ -562,6 +555,12 @@
			cacenList.add(c);
			continue;
			}
			if(Constants.equalsInteger(c.getMemberDeleted(),Constants.ONE)
			&& Constants.equalsInteger(c.getIsdeleted(),1)){
			//如果人员已离职，新增授权无需下发，取消下发
			cacenList.add(c);
			continue;
			}
			if(c.getDeviceOnline() !=null && Constants.equalsInteger(c.getDeviceOnline(),0)){
			waitList.add(c);
			continue;
			@@ -571,7 +570,7 @@
			continue;
			}
			HKConstants.OPERA_TYPE flag = HKConstants.OPERA_TYPE.ADD;
			if(Constants.equalsObject(c.getIsdeleted(),Constants.ONE)){
			if(Constants.equalsInteger(c.getIsdeleted(),Constants.ONE)){
			flag = HKConstants.OPERA_TYPE.DEL;
			}
			if(addTaskData(c,taskId,flag.getKey())){