Merge remote-tracking branch 'origin/master'

jiangping

2023-12-15 e0965debdfc7149b9490d66d45c8737ca574ed21

 server/dmvisit_service/src/main/java/com/doumee/service/business/impl/erp/ErpSyncServiceImpl.java

@@ -2,54 +2,54 @@

import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.doumee.biz.system.SystemDictDataBiz;
import com.doumee.config.Jwt.JwtPayLoad;
import com.doumee.config.Jwt.JwtTokenUtil;
import com.doumee.core.constants.ResponseStatus;
import com.doumee.core.erp.ErpConstants;
import com.doumee.core.erp.ErpTool;
import com.doumee.core.erp.model.openapi.request.erp.*;
import com.doumee.core.erp.model.openapi.response.erp.ApproveInfoResponse;
import com.doumee.core.erp.model.openapi.response.erp.ERPApiResponse;
import com.doumee.core.exception.BusinessException;
import com.doumee.core.haikang.model.HKConstants;
import com.doumee.core.haikang.model.param.request.AcsDeviceListRequest;
import com.doumee.core.haikang.model.param.request.DoorsListRequest;
import com.doumee.core.haikang.model.param.request.PrivilegeGroupRequest;
import com.doumee.core.haikang.model.param.request.event.acs.EventAcsRequest;
import com.doumee.core.haikang.model.param.request.event.parks.EventParkRequest;
import com.doumee.core.haikang.model.param.request.event.visit.EventVisitRequest;
import com.doumee.core.haikang.model.param.BaseResponse;
import com.doumee.core.haikang.model.param.request.OrgAddRequest;
import com.doumee.core.haikang.model.param.request.OrgDelRequest;
import com.doumee.core.haikang.service.HKService;
import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.core.model.openapi.request.*;
import com.doumee.core.model.openapi.request.erp.OrgListRequest;
import com.doumee.core.model.openapi.request.erp.UserInfoRequest;
import com.doumee.core.model.openapi.request.erp.UserListRequest;
import com.doumee.core.model.openapi.response.*;
import com.doumee.core.model.openapi.response.erp.OrgListRespone;
import com.doumee.core.erp.model.openapi.request.*;
import com.doumee.core.erp.model.openapi.response.*;
import com.doumee.core.erp.model.openapi.response.erp.OrgListRespone;
import com.doumee.core.erp.model.openapi.response.erp.UserListRespone;
import com.doumee.core.utils.Constants;
import com.doumee.core.utils.DESUtil;
import com.doumee.core.utils.DateUtil;
import com.doumee.core.utils.Utils;
import com.doumee.core.utils.redis.RedisUtil;
import com.doumee.dao.admin.response.MemberInfoDTO;
import com.doumee.dao.business.*;
import com.doumee.dao.business.join.CarEventJoinMapper;
import com.doumee.dao.business.join.DeviceEventJoinMapper;
import com.doumee.dao.business.join.VisitEventJoinMapper;
import com.doumee.dao.business.model.*;
import com.doumee.dao.web.reqeust.CheckVisitedDTO;
import com.doumee.dao.web.response.MemberVO;
import com.doumee.service.business.*;
import com.doumee.service.business.ERPSyncService;
import com.doumee.service.business.InterfaceLogService;
import com.github.yulichang.wrapper.MPJLambdaWrapper;
import io.swagger.models.auth.In;
import com.hikvision.artemis.sdk.config.ArtemisConfig;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.checkerframework.checker.units.qual.A;
import org.checkerframework.checker.units.qual.C;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.servlet.http.HttpServletResponse;
import javax.annotation.PostConstruct;
import java.util.*;
import java.util.stream.Collectors;

@@ -94,7 +94,7 @@

    @Autowired
    private MemberMapper memberMapper;
    

    @Autowired
    private MemberRoleMapper memberRoleMapper;

@@ -107,15 +107,145 @@
    @Autowired
    private InterfaceLogService interfaceLogService;


    @Override
    @PostConstruct
    public  int  initHkConfig(){
        ErpConstants.approveUrl=systemDictDataBiz.queryByCode(Constants.ERP,Constants.ERP_APPROVE_URL).getCode();
        ErpConstants.orgListUrl=systemDictDataBiz.queryByCode(Constants.ERP,Constants.ERP_ORGLIST_URL).getCode();
        ErpConstants.userListUrl=systemDictDataBiz.queryByCode(Constants.ERP,Constants.ERP_USERSTATUS_RL).getCode();
        ErpConstants.userStatusUrl=systemDictDataBiz.queryByCode(Constants.ERP,Constants.ERP_USERSTATUS_RL).getCode();
        return  0;
    }
    /**
     * 同步ERP组织信息
     * @param param
     * @return
     */
    @Override
    @Transactional
    public String syncCompany(OrgListRequest param){
        List<OrgListRespone>  allList = new ArrayList<>();
        //获取ERP组织信息（全量同步）
        List<OrgListRespone>  list = ErpTool.getErpOrgList(ErpConstants.orgListUrl,param);
        if(list !=null && list.size()>0){
            List<Company> addList = new ArrayList<>();
            List<Company> updateList = new ArrayList<>();
            List<Integer> delIds = new ArrayList<>();
            List<Company>  allList = companyMapper.selectList(new QueryWrapper<Company>().lambda().eq(Company::getType,Constants.ONE));
            dealCompanyChangeList(list,addList,updateList,delIds,allList);
            if(addList.size()>0){
                companyMapper.insertBatchSomeColumn(addList);
            }
            if(updateList.size()>0){
                for(Company c : updateList){
                    companyMapper.updateById(c);
                }
            }
            if(delIds.size()>0){
                //删除所有需要删除的组织信息(逻辑删除）
                companyMapper.update(null,new UpdateWrapper<Company>().lambda().set(Company::getIsdeleted, Constants.ONE).in(Company::getId,delIds));
            }
            return "同步数据：新增【"+addList.size()+"】条，更新【"+updateList.size()+"】条，删除【"+delIds.size()+"】条";
        }else{
            throw  new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "同步ERP数据为空！");
        }
    }

    /**
     * 根据同步erp的组织信息封装 组织新增、修改和删除的集合信息
     * @param list
     * @param addList
     * @param updateList
     * @param delIds
     * @param allList
     */
    private void dealCompanyChangeList(List<OrgListRespone> list, List<Company> addList, List<Company> updateList, List<Integer> delIds, List<Company> allList) {
        Date date = new Date();
        for(OrgListRespone respone : list){
            //根据erpid查询企业信息，判断是新增还是更新
            Company company = findCompanyByERPId(allList,respone.getId());
            if(company == null){
                //如果是新增
                if(Constants.formatIntegerNum(respone.getIsdeleted()) == Constants.ONE){
                    continue;
                }
                //封装新增组织对象数据
                addList.add(getAddCompanyModel(respone,date));
            }else{
                //如果是更新
                if(Constants.formatIntegerNum(respone.getIsdeleted()) == Constants.ONE){
                    //如果已删除，加入删除集合中
                    delIds.add(company.getId());
                    continue;
                }
                updateList.add(addUpdateCompanyModel(respone,company,date));
            }
        }
        if(allList!=null && allList.size()>0){
            for(Company  c : allList){
                if(isCompanyDeleted(c,list)){
                    delIds.add(c.getId());
                }
            }
        }

    }

    /**
     * 新增组织对象
     * @param respone
     * @param company
     * @param date
     * @return
     */
    private Company addUpdateCompanyModel(OrgListRespone respone,Company company,Date date) {
        company.setName(respone.getName());
        company.setErpId(respone.getId());
        company.setEditDate(date);
        company.setStatus(respone.getStatus());
        company.setCode(respone.getCode());
        company.setErpParentId(respone.getParentOrgId());
        company.setErpDate(date);
        company.setHkStatus(Constants.ZERO);
        return  company;
    }
    /**
     * 更新组织对象
     * @param respone
     * @param date
     * @return
     */
    private Company getAddCompanyModel(OrgListRespone respone, Date date) {
        Company    company = new Company();
        company.setIsdeleted(Constants.ZERO);
        company.setName(respone.getName());
        company.setErpId(respone.getId());
        company.setCreateDate(date);
        company.setCode(respone.getCode());
        company.setErpParentId(respone.getParentOrgId());
        company.setErpDate(date);
        //海康数据
        company.setHkId(HKConstants.RES_INDEX+UUID.randomUUID().toString());
        return  company;
    }

    private boolean isCompanyDeleted(Company c, List<OrgListRespone> list) {
        for(OrgListRespone m : list){
            if(StringUtils.equals(c.getErpId(),m.getId())){
                return  true;
            }
        }
        return false;
    }

    private Company findCompanyByERPId(List<Company> allList, String id) {
        if(allList!=null){
            for(Company com :allList){
                if(StringUtils.equals(com.getErpId(),id)){
                    return com;
                }
            }
        }
        return  null;
    }

@@ -126,19 +256,25 @@
     */
    @Override
    public    String syncUsers(UserListRequest param){
        //TODO----------------RK------------------
        List<UserListRespone>  allList = ErpTool.getErpUserList(ErpConstants.userListUrl,param);
        return  null;
    }


    /**
     * 获取ERP人员信息
     * 提交用户同步失败记录
     * @param param
     * @return
     */
    @Override
    public  String syncUserInfo(UserInfoRequest param){
        return  null;
    public  boolean noticeUserFail(UserFailRequest param){
        ERPApiResponse r  = ErpTool.noticeUserStatus(ErpConstants.userStatusUrl,param);
        if(r!=null && r.isSuccess()){
            return true;
        }
        return  false;
    }


    @Override
    public AccessTokenResponse createERPToken(String accessKey, String accessSecret){