productDev/dmvisit.git

			@@ -2,6 +2,7 @@

			import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
			import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
			import com.doumee.biz.system.SystemDictDataBiz;
			import com.doumee.core.constants.ResponseStatus;
			import com.doumee.core.exception.BusinessException;
			import com.doumee.core.haikang.model.HKConstants;
			@@ -38,6 +39,8 @@
			@Autowired
			private EmpowerJoinMapper empowerMapper;
			@Autowired
			private SystemDictDataBiz systemDictDataBiz;
			@Autowired
			private MemberMapper memberMapper;
			@Autowired
			private DeviceMapper deviceMapper;
			@@ -59,6 +62,12 @@
			if(list == null \|\| list.size() ==0){
			return;
			}
			int tryNum = 1;
			try {
			tryNum = Integer.parseInt(systemDictDataBiz.queryByCode(Constants.HK_PARAM,Constants.RETRY_CONNECT_NUM).getCode());
			}catch (Exception e){

			}
			for(Empower c : list){
			TaskPersonDetailRequest param = new TaskPersonDetailRequest();
			param.setPageNo(1);
			@@ -76,45 +85,74 @@
			BaseResponse<TaskPersonDetailListResponse> response = HKService.taskPersoDetail(param);
			if(response!=null
			&& StringUtils.equals(response.getCode(),HKConstants.RESPONSE_SUCCEE) && response.getData()!=null
			){
			if( response.getData().getList() != null
			&& response.getData().getList().size()>0 ){
			TaskPersonDetailResponse model = response.getData().getList().get(0);
			if(model != null && StringUtils.equals(model.getPersondownloadResult(),"0")){
			//更新已完成下载任务
			) {
			if (response.getData().getList() != null
			&& response.getData().getList().size() > 0) {
			TaskPersonDetailResponse model = response.getData().getList().get(0);
			if (model != null && StringUtils.equals(model.getPersondownloadResult(), "0")) {
			//更新已完成下载任务
			String remark = "";
			String cardInfo = "卡片下发失败";
			TaskPersonDetailCardFaceResponse d = model.getPersonDownloadDetail();
			if(d.getCards() !=null && d.getCards().size()>0){
			cardInfo = "卡片：【" ;
			for(TaskPersonDetailCardInfoResponse card : d.getCards()){
			cardInfo +=card.getId()+" ";
			}
			cardInfo += "】下发成功";
			}
			if(d.getFaces() == null \|\| d.getFaces().size() ==0){
			remark = cardInfo+"，不支持人脸设备！";
			}else{
			remark = ""+cardInfo+"，人脸下发成功！";
			if (d.getCards() != null && d.getCards().size() > 0) {
			cardInfo = "卡片：【";
			for (TaskPersonDetailCardInfoResponse card : d.getCards()) {
			cardInfo += card.getId() + " ";
			}
			cardInfo += "】下发成功";
			}
			empowerMapper.update(null,new UpdateWrapper<Empower>()
			if (d.getFaces() == null \|\| d.getFaces().size() == 0) {
			remark = cardInfo + "，不支持人脸设备！";
			} else {
			remark = "" + cardInfo + "，人脸下发成功！";
			}
			empowerMapper.update(null, new UpdateWrapper<Empower>()
			.lambda()
			.eq(Empower::getId,c.getId() )
			.set(Empower::getRemark,remark )
			.set(Empower::getSendInfo,remark )
			.set(Empower::getSendStatus,Constants.EmpowerStatus.pass) );
			.eq(Empower::getId, c.getId())
			.set(Empower::getRemark, remark)
			.set(Empower::getSendInfo, remark)
			.set(Empower::getSendStatus, Constants.EmpowerStatus.pass));
			} else {
			empowerMapper.update(null, new UpdateWrapper<Empower>()
			.lambda()
			.eq(Empower::getId, c.getId())
			.set(Empower::getRemark, "下发失败")
			.set(Empower::getSendInfo, "下发失败")
			.set(Empower::getSendStatus, Constants.EmpowerStatus.fail));
			}
			}else{
			empowerMapper.update(null,new UpdateWrapper<Empower>()
			.lambda()
			.eq(Empower::getId,c.getId() )
			.set(Empower::getRemark,"下发失败" )
			.set(Empower::getSendInfo,"下发失败" )
			.set(Empower::getSendStatus,Constants.EmpowerStatus.fail) );
			}
			} else {
			//如果是已删除的数据，下发失败（防止设备离线），则尝试重新下发任务
			if(Constants.equalsInteger(c.getIsdeleted(), Constants.ONE) ){
			// && Constants.formatIntegerNum(c.getTryNum())+1 < tryNum ){
			empowerMapper.update(null, new UpdateWrapper<Empower>()
			.lambda()
			.eq(Empower::getId, c.getId())
			.set(Empower::getRemark, "下发失败，等待重新删除权限")
			// .set(Empower::getHkId,null)
			// .set(Empower::getSendDate,null)
			.set(Empower::getTryNum,Constants.formatIntegerNum(c.getTryNum())+1)
			.set(Empower::getSendInfo, "下发失败，等待重新删除权限")
			.set(Empower::getSendStatus, Constants.EmpowerStatus.wait));
			}else{
			empowerMapper.update(null, new UpdateWrapper<Empower>()
			.lambda()
			.eq(Empower::getId, c.getId())
			.set(Empower::getRemark, "下发失败")
			.set(Empower::getSendInfo, "下发失败")
			.set(Empower::getSendStatus, Constants.EmpowerStatus.fail));
			}

			/* empowerMapper.update(null, new UpdateWrapper<Empower>()
			.lambda()
			.eq(Empower::getId, c.getId())
			.set(Empower::getRemark, Constants.equalsInteger(c.getIsdeleted(), Constants.ZERO) ? "下发失败" : "删除权限成功")
			.set(Empower::getSendInfo, "删除权限成功")
			.set(Empower::getSendStatus, Constants.equalsInteger(c.getIsdeleted(), Constants.ZERO) ? Constants.EmpowerStatus.fail : Constants.EmpowerStatus.pass));
			*/
			}
			checkDelMemberTask(c.getMemberId());
			}
			}
			checkDelMemberTask();
			}catch (Exception e){
			e.printStackTrace();
			}finally {
			@@ -141,12 +179,14 @@
			log.info("海康删除用户失败：==============="+result.getData().get(0).getPersonId());
			memberMapper.update(null,new UpdateWrapper<Member>().lambda()
			.set(Member::getHkStatus,Constants.TWO)//同步失败
			.set(Member::getRemark,"同步海康删除失败")//同步失败
			.set(Member::getHkDate,date)
			.in(Member::getId, id));
			}else{
			//标记删除成功的数据（海康对接状态为已同步，，同步失败的仍为待同步，等下一次继续处理，知道全部删除完毕）
			memberMapper.update(null,new UpdateWrapper<Member>().lambda()
			.set(Member::getHkStatus,Constants.ONE)//同步成功
			.set(Member::getRemark,"同步海康删除失败")//同步失败
			.set(Member::getHkDate,date)
			.in(Member::getId, id));
			//删除所有绑定的卡片信息
			@@ -160,20 +200,16 @@
			/**
			* 检查删除人员的权限是否都删除完成，如果权限删除完成，进行海康人员的删除操作
			*/
			private void checkDelMemberTask() {
			List<Member> memberList = memberMapper.selectList(new QueryWrapper<Member>().lambda()
			.eq(Member::getIsdeleted,Constants.ONE)
			.eq(Member::getHkStatus,Constants.FOUR));
			if(memberList!=null &&memberList.size()>0 ){
			private void checkDelMemberTask(Integer memberId) {
			Date date = new Date();
			for(Member member : memberList){
			Member member = memberMapper.selectById(memberId);
			if(member!=null && Constants.equalsInteger(member.getIsdeleted(),Constants.ONE) ){
			if(empowerMapper.selectCount(new QueryWrapper<Empower>().lambda()
			.eq(Empower::getMemberId,member.getId())
			.eq(Empower::getIsdeleted,Constants.ONE)
			.ne(Empower::getSendStatus,Constants.EmpowerStatus.pass)) ==0){
			//如果权限都已经删除成功，则删除海康人员和卡片数据
			doHkDeleteUser(member.getId(),member.getHkId(),date);
			}
			}
			}
			}