工作调度

nidapeng

2024-04-20 51a208c7715ecfea9faeccd5ee56ed2d0a697c95

 server/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncEmpowerServiceImpl.java

@@ -1,5 +1,6 @@
package com.doumee.service.business.impl.hksync;

import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.doumee.biz.system.SystemDictDataBiz;
@@ -7,6 +8,7 @@
import com.doumee.core.exception.BusinessException;
import com.doumee.core.haikang.model.HKConstants;
import com.doumee.core.haikang.model.HKResponseCode;
import com.doumee.core.haikang.model.param.BaseListPageResponse;
import com.doumee.core.haikang.model.param.BaseResponse;
import com.doumee.core.haikang.model.param.request.*;
import com.doumee.core.haikang.model.param.respose.*;
@@ -189,25 +191,42 @@
     * @param id
     * @param date
     */
    private boolean doHkDeleteUser(Integer  id,String delHkIds,  Date date ) {
    public static boolean doHkDeleteUser(Integer  id,String delHkIds,  Date date ,MemberMapper memberMapper,MemberCardMapper memberCardMapper) {
        if(StringUtils.isBlank(delHkIds)){

            return true;
        }
        UserDelRequest request = new UserDelRequest();
        request.setPersonIds(new String[]{delHkIds});
        BaseResponse<List<UserDelResponse>> result =  HKService.delBatchUser(request);
        boolean succes = false;
        if(result !=null && StringUtils.equals(result.getCode(),HKConstants.RESPONSE_SUCCEE)){
            List<String> fIds = new ArrayList<>();
            //标记删除成功的数据（海康对接状态为已同步，，同步失败的仍为待同步，等下一次继续处理，知道全部删除完毕）
            if(result.getData()!=null && result.getData().size()>0){
                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));
                UserDelResponse tem = result.getData().get(0);
                if(tem!=null && StringUtils.equals(tem.getPersonId(),delHkIds)){
                    UserByParamListRequest param = new UserByParamListRequest();
                    param.setPersonIds(delHkIds);
                    param.setPageNo(1);
                    param.setPageSize(2);
                    BaseResponse<BaseListPageResponse<UserInfoResponse>>  t =  HKService.personList(param);
                    if(t!=null && t.getData()!=null && t.getData().getTotal()  ==0){
                        //人员信息已被删除的异常 作为已删除成功处理
                        succes =true;
                    }else{
                        //排除人员信息已被删除的异常
                        memberMapper.update(null,new UpdateWrapper<Member>().lambda()
                                .set(Member::getHkStatus,Constants.TWO)//同步失败
                                .set(Member::getRemark,"同步海康删除失败" + JSONObject.toJSONString(result.getData().get(0)))//同步失败
                                .set(Member::getHkDate,date)
                                .in(Member::getId, id));
                    }
                }
            }else{
                //标记删除成功的数据（海康对接状态为已同步，，同步失败的仍为待同步，等下一次继续处理，知道全部删除完毕）
                succes =true;
            }
            if(succes){
                memberMapper.update(null,new UpdateWrapper<Member>().lambda()
                        .set(Member::getHkStatus,Constants.ONE)//同步成功
                        .set(Member::getRemark,"已同步")//同步失败
@@ -216,9 +235,8 @@
                //删除所有绑定的卡片信息
                memberCardMapper.delete(new QueryWrapper<MemberCard>().lambda().eq(MemberCard::getMemberId,id));
            }
            return true;
        }
        return false;
        return succes;
    }

    /**
@@ -234,7 +252,7 @@
                        .ne(Empower::getFailFlag,Constants.ONE)
                        .ne(Empower::getSendStatus,Constants.EmpowerStatus.pass)) ==0){
                    //如果权限都已经删除成功，则删除海康人员和卡片数据
                     doHkDeleteUser(memberId,memberHkid,date);
                     doHkDeleteUser(memberId,memberHkid,date,memberMapper,memberCardMapper);
//            }
        }
    }
@@ -325,6 +343,15 @@
                                            .set(Empower::getSendStatus,Constants.EmpowerStatus.downloaded) );

                                }
                            }else if(response!=null
                                    && StringUtils.equals(response.getCode(),HKConstants.RESPONSE_SUCCEE)
                                    && response.getData()==null){
                                empowerMapper.update(null,new UpdateWrapper<Empower>()
                                        .lambda()
                                        .eq(Empower::getHkId,c.getHkId() )
                                        .set(Empower::getSendInfo,"任务已被删除，下发失败" )
                                        .set(Empower::getRemark,"任务已被删除，下发失败" )
                                        .set(Empower::getSendStatus,Constants.EmpowerStatus.fail) );
                            }
                        }
                    }catch (Exception e1){
@@ -770,8 +797,8 @@
        queryWrapper.ne(Device::getOnline,Constants.ZERO+"");//非离线
        queryWrapper.eq(Empower::getSendStatus,Constants.EmpowerStatus.fail);
        queryWrapper.gt(Empower::getId,endId);
        queryWrapper.and(w-> w.eq( Empower::getFailFlag,Constants.ZERO).or().isNull(Empower::getFailFlag));
        queryWrapper.orderByAsc(Empower::getId );
        queryWrapper.ne( Empower::getFailFlag,Constants.ONE);
        List<Empower> list = empowerMapper.selectJoinList(Empower.class,queryWrapper);
        return list;
    }