From 26bada56d6b3fbbad87b324d484aa84d46c3def3 Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期三, 20 十二月 2023 10:35:04 +0800
Subject: [PATCH] 海康接口对接开发

---
 server/dmvisit_service/src/main/java/com/doumee/service/business/impl/erp/ErpSyncServiceImpl.java |  351 ++++++++++++++++++++++++++++++++++++++++++++++++++-------
 1 files changed, 305 insertions(+), 46 deletions(-)

diff --git a/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/erp/ErpSyncServiceImpl.java b/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/erp/ErpSyncServiceImpl.java
index 7c59fe5..436a7bc 100644
--- a/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/erp/ErpSyncServiceImpl.java
+++ b/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/erp/ErpSyncServiceImpl.java
@@ -40,6 +40,7 @@
 import com.doumee.service.business.InterfaceLogService;
 import com.github.yulichang.wrapper.MPJLambdaWrapper;
 import com.hikvision.artemis.sdk.config.ArtemisConfig;
+import io.swagger.models.auth.In;
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.checkerframework.checker.units.qual.C;
@@ -91,6 +92,10 @@
 
     @Autowired
     private CompanyMapper companyMapper;
+    @Autowired
+    private EmpowerMapper empowerMapper;
+    @Autowired
+    private ParkBookMapper parkBookMapper;
 
     @Autowired
     private MemberMapper memberMapper;
@@ -143,7 +148,10 @@
             }
             if(delIds.size()>0){
                 //鍒犻櫎鎵�鏈夐渶瑕佸垹闄ょ殑缁勭粐淇℃伅(閫昏緫鍒犻櫎锛�
-                companyMapper.update(null,new UpdateWrapper<Company>().lambda().set(Company::getIsdeleted, Constants.ONE).in(Company::getId,delIds));
+                companyMapper.update(null,new UpdateWrapper<Company>().lambda()
+                        .set(Company::getIsdeleted, Constants.ONE)
+                        .set(Company::getHkStatus, Constants.ZERO)
+                        .in(Company::getId,delIds));
             }
             return "鍚屾鏁版嵁锛氭柊澧炪��"+addList.size()+"銆戞潯锛屾洿鏂般��"+updateList.size()+"銆戞潯锛屽垹闄ゃ��"+delIds.size()+"銆戞潯";
         }else{
@@ -224,8 +232,7 @@
         company.setCode(respone.getCode());
         company.setErpParentId(respone.getParentOrgId());
         company.setErpDate(date);
-        //娴峰悍鏁版嵁
-        company.setHkId(HKConstants.RES_INDEX+UUID.randomUUID().toString());
+        company.setHkStatus(Constants.ZERO);
         return  company;
     }
 
@@ -249,17 +256,126 @@
         return  null;
     }
 
+
+
+
     /**
      * 鍚屾ERP浜哄憳淇℃伅
      * @param param
      * @return
      */
     @Override
-    public    String syncUsers(UserListRequest param){
-        //TODO----------------RK------------------
-        List<UserListRespone>  allList = ErpTool.getErpUserList(ErpConstants.userListUrl,param);
+    public  String syncUsers(UserListRequest param){
+        List<UserListRespone>  list = ErpTool.getErpUserList(ErpConstants.userListUrl,param);
+        if(list !=null && list.size()>0) {
+            List<Member> addList = new ArrayList<>();
+            List<Member> updateList = new ArrayList<>();
+            List<Integer> delIds = new ArrayList<>(); 
+            List<Member> allList = memberMapper.selectList(new QueryWrapper<Member>().lambda()
+                    .eq(Member::getIsdeleted,Constants.ZERO)
+                    .eq(Member::getType, Constants.memberType.internal));
+            dealUserChangeList(list,addList,updateList,delIds,allList);
+            if(addList.size()>0){
+                memberMapper.insertBatchSomeColumn(addList);
+            }
+            if(updateList.size()>0){
+                for(Member c : updateList){
+                    memberMapper.updateById(c);
+                }
+            }
+            if(delIds.size()>0){
+                //鍒犻櫎鎵�鏈夐渶瑕佸垹闄ょ殑缁勭粐淇℃伅(閫昏緫鍒犻櫎锛�
+                memberMapper.update(null,new UpdateWrapper<Member>().lambda().set(Member::getHkStatus,Constants.ZERO)
+                        .set(Member::getIsdeleted, Constants.ONE).in(Member::getId,delIds));
+            }
+
+        }else{
+            throw  new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "鍚屾ERP鏁版嵁涓虹┖锛�");
+        }
         return  null;
     }
+
+    private void dealUserChangeList(List<UserListRespone> list, List<Member> addList, List<Member> updateList, List<Integer> delIds, List<Member> allList) {
+        Date date = new Date();
+        for(UserListRespone response : list){
+            //鏍规嵁 erpId 鏌ヨ鐢ㄦ埛淇℃伅锛屽垽鏂槸鏂板杩樻槸鏇存柊
+            Member member = findUserByERPId(allList,response.getId());
+            if(member == null){
+                //濡傛灉鏄柊澧�
+                if(Constants.formatIntegerNum(response.getIsdeleted()) == Constants.ONE){
+                    continue;
+                }
+                //灏佽鏂板缁勭粐瀵硅薄鏁版嵁
+                addList.add(getAddMemberModel(response,date));
+            }else{
+                //濡傛灉鏄洿鏂�
+                if(Constants.formatIntegerNum(response.getIsdeleted()) == Constants.ONE){
+                    //濡傛灉宸插垹闄わ紝鍔犲叆鍒犻櫎闆嗗悎涓�
+                    delIds.add(member.getId());
+                    continue;
+                }
+                updateList.add(addUpdateMemberModel(response,member,date));
+            }
+        }
+        if(allList!=null && allList.size()>0){
+            for(Member  c : allList){
+                if(isUserDeleted(c,list)){
+                    delIds.add(c.getId());
+                }
+            }
+        }
+    }
+
+    private Member getAddMemberModel(UserListRespone param, Date date) {
+        Member member = new Member();
+        BeanUtils.copyProperties(param,member);
+        member.setCreateDate(new Date());
+        member.setHkStatus(Constants.ZERO);
+        member.setErpStatus(Constants.ONE);
+        member.setErpDate(new Date());
+        member.setErpId(param.getId());
+        member.setFsStatus(Constants.ZERO);
+        member.setType(Constants.memberType.internal);
+        String encryptIdNo = DESUtil.encrypt(Constants.EDS_PWD,param.getIdNo());
+        member.setIdcardNo(encryptIdNo);
+        member.setIdcardDecode(Constants.getTuominStr(param.getIdNo()));
+        member.setCompanyId(param.getOrgId());
+        member.setHkStatus(Constants.ZERO);
+        return  member;
+    }
+
+    private Member addUpdateMemberModel(UserListRespone param,Member member,Date date) {
+        BeanUtils.copyProperties(param,member);
+        String encryptIdNo = DESUtil.encrypt(Constants.EDS_PWD,param.getIdNo());
+        member.setIdcardNo(encryptIdNo);
+        member.setIdcardDecode(Constants.getTuominStr(param.getIdNo()));
+        member.setCompanyId(param.getOrgId());
+        member.setEditDate(new Date());
+        member.setErpDate(new Date());
+        member.setHkStatus(Constants.ZERO);
+        return  member;
+    }
+
+    private boolean isUserDeleted(Member c, List<UserListRespone> list) {
+        for(UserListRespone m : list){
+            if(StringUtils.equals(c.getErpId(),m.getId().toString())){
+                return  true;
+            }
+        }
+        return false;
+    }
+
+    private Member findUserByERPId(List<Member> allList, String id) {
+        if(allList!=null){
+            for(Member com :allList){
+                if(StringUtils.equals(com.getErpId(),id)){
+                    return com;
+                }
+            }
+        }
+        return  null;
+    }
+
 
 
     /**
@@ -570,21 +686,29 @@
             Company company = companyMapper.selectOne(new QueryWrapper<Company>().lambda().eq(Company::getErpId,param.getId()).last("limit 1"));
             if(Objects.isNull(company)){
                 company = new Company();
-                BeanUtils.copyProperties(param,company);
+//                BeanUtils.copyProperties(param,company);
                 company.setId(null);
                 company.setCreateDate(new Date());
                 company.setHkStatus(Constants.ZERO);
                 company.setErpStatus(Constants.ONE);
                 company.setErpDate(new Date());
                 company.setErpId(param.getId());
+                company.setErpParentId(param.getParentId());
                 company.setFsStatus(Constants.ZERO);
                 company.setType(Constants.ONE);
+                company.setLinkName(param.getLinkName());
+                company.setLinkPhone(param.getLinkPhone());
                 companyMapper.insert(company);
                 //TODO 娴峰悍鏁版嵁鍒涘缓
             }else{
-                BeanUtils.copyProperties(param,company);
+//                BeanUtils.copyProperties(param,company);
                 company.setEditDate(new Date());
+                company.setErpId(param.getId());
+                company.setHkStatus(Constants.ZERO);
                 company.setErpDate(new Date());
+                company.setErpParentId(param.getParentId());
+                company.setLinkName(param.getLinkName());
+                company.setLinkPhone(param.getLinkPhone());
                 companyMapper.updateById(company);
                 //TODO 娴峰悍鏁版嵁鏇存柊
             }
@@ -615,9 +739,11 @@
                 throw new BusinessException(ResponseStatus.BAD_REQUEST);
             }
             Member member = memberMapper.selectOne(new QueryWrapper<Member>().lambda().eq(Member::getErpId,param.getId()).last("limit 1"));
-            if(Objects.isNull(member)){
+            List<Integer> doorIds = null;
+              if(Objects.isNull(member)){
                 member = new Member();
                 BeanUtils.copyProperties(param,member);
+                member.setId(null);
                 member.setCreateDate(new Date());
                 member.setHkStatus(Constants.ZERO);
                 member.setErpStatus(Constants.ONE);
@@ -629,62 +755,195 @@
                 member.setIdcardNo(encryptIdNo);
                 member.setIdcardDecode(Constants.getTuominStr(param.getIdNo()));
                 member.setCompanyId(param.getOrgId());
+                doorIds = getRoleIdByParam(param.getRoleIds(),member);
                 memberMapper.insert(member);
-
                 //TODO 娴峰悍鏁版嵁鍒涘缓
             }else{
+                Integer id = member.getId();
                 BeanUtils.copyProperties(param,member);
+                member.setId(id);
                 String encryptIdNo = DESUtil.encrypt(Constants.EDS_PWD,param.getIdNo());
                 member.setIdcardNo(encryptIdNo);
                 member.setIdcardDecode(Constants.getTuominStr(param.getIdNo()));
                 member.setCompanyId(param.getOrgId());
                 member.setEditDate(new Date());
+                doorIds = getRoleIdByParam(param.getRoleIds(),member);
                 member.setErpDate(new Date());
+                member.setHkStatus(Constants.ZERO);
                 memberMapper.updateById(member);
                 //鍒犻櫎鐢ㄦ埛鍗$墖鏁版嵁  浜哄憳瑙掕壊鍏宠仈
                 memberCardMapper.delete(new QueryWrapper<MemberCard>().lambda().eq(MemberCard::getMemberId,member.getId()));
-                memberRoleMapper.delete(new QueryWrapper<MemberRole>().lambda().eq(MemberRole::getMemberId,member.getId()));
                 //TODO 娴峰悍鏁版嵁鏇存柊
             }
-            //娣诲姞浜哄憳瑙掕壊鍏宠仈鏁版嵁
-            if(!Objects.isNull(param.getRoleIds())&&param.getRoleIds().length>Constants.ZERO){
-                //鏌ヨ鏁版嵁搴撳瓨鍦ㄧ殑鏉冮檺
-                List<DeviceRole> deviceRoleList
-                        = deviceRoleMapper.selectList(new QueryWrapper<DeviceRole>().lambda().eq(DeviceRole::getId,param.getRoleIds()));
-                if(CollectionUtils.isNotEmpty(deviceRoleList)){
-                    List<MemberRole> memberRoleList = new ArrayList<>();
-                    for (DeviceRole deviceRole:deviceRoleList) {
-                        MemberRole memberRole = new MemberRole();
-                        memberRole.setCreateDate(new Date());
-                        memberRole.setMemberId(member.getId());
-                        memberRole.setIsdeleted(Constants.ZERO);
-                        memberRole.setRoleId(deviceRole.getId().toString());
-                        memberRoleList.add(memberRole);
-                    }
-                    memberRoleMapper.insertBatchSomeColumn(memberRoleList);
-                }
-            }
-
+            //濡傛灉鏈夋巿鏉冮棬绂佹暟鎹紝杩涜鐢ㄦ埛鎺堟潈鏁版嵁涓嬪彂浠诲姟鍒涘缓
+            dealMemberRoleEmpower(member,doorIds,param.getValidStartTime(),param.getValidEndTime());
             //娣诲姞浜哄憳鍗$墖鏁版嵁
-            if(!Objects.isNull(param.getCardList())&&param.getCardList().size()>Constants.ZERO){
-                if(CollectionUtils.isNotEmpty(param.getCardList())){
-                    List<MemberCard> memberCardList = new ArrayList<>();
-                    for (String id:param.getCardList()) {
-                        MemberCard memberCard = new MemberCard();
-                        memberCard.setCreateDate(new Date());
-                        memberCard.setMemberId(member.getId());
-                        memberCard.setIsdeleted(Constants.ZERO);
-                        memberCard.setCode(id);
-                        memberCardList.add(memberCard);
-                    }
-                    memberCardMapper.insertBatchSomeColumn(memberCardList);
-                }
-            }
+            dealMemberCard(member,param);
         }catch (Exception e){
             e.printStackTrace();
         }finally {
             saveInterfaceLog(param,"/visitBiz/resource/userUpdate",null,Constants.ZERO);
         }
+    }
+
+    /**
+     * 娣诲姞浜哄憳鍗$墖鏁版嵁
+     * @param member
+     * @param param
+     */
+    private void dealMemberCard(Member member, UserUpdateRequest param) {
+        if(!Objects.isNull(param.getCardList())&&param.getCardList().size()>Constants.ZERO){
+            if(CollectionUtils.isNotEmpty(param.getCardList())){
+                List<MemberCard> memberCardList = new ArrayList<>();
+                for (String id:param.getCardList()) {
+                    MemberCard memberCard = new MemberCard();
+                    memberCard.setCreateDate(new Date());
+                    memberCard.setMemberId(member.getId());
+                    memberCard.setIsdeleted(Constants.ZERO);
+                    memberCard.setCode(id);
+                    memberCardList.add(memberCard);
+                }
+                memberCardMapper.insertBatchSomeColumn(memberCardList);
+            }
+        }
+    }
+
+    /**
+     * //濡傛灉鏈夋巿鏉冮棬绂佹暟鎹紝杩涜鐢ㄦ埛鎺堟潈鏁版嵁涓嬪彂浠诲姟鍒涘缓
+     * @param member
+     */
+    private void dealMemberRoleEmpower(Member member, List<Integer> doorIds,Date startTime,Date endTime ) {
+        //鍒犻櫎鎵�鏈夎�佺殑鎺堟潈淇℃伅
+//        empowerMapper.update(null,new UpdateWrapper<Empower>().lambda()
+//                .eq(Empower::getMemberId,member.getId())
+//                .set(Empower::getIsdeleted,Constants.ONE)
+//                .set(Empower::getSendStatus,Constants.ZERO)
+//                );
+        empowerMapper.delete(new UpdateWrapper<Empower>().lambda()
+                .eq(Empower::getMemberId,member.getId())
+                );
+        if(doorIds==null || doorIds.size() == 0){
+          return;
+        }
+        List<Empower> list = new ArrayList<>();
+        List<Device> deviceList = deviceMapper.selectList(new QueryWrapper<Device>().lambda().in(Device::getId,doorIds));
+        if(deviceList == null || deviceList.size() == 0){
+            return;
+        }
+        for (Device deviceRole:deviceList) {
+            Empower model = new Empower();
+            model.setCreateDate(new Date());
+            model.setMemberId(member.getId());
+            model.setIsdeleted(Constants.ZERO);
+            model.setDeviceId(deviceRole.getId());
+            model.setSendStatus(Constants.ZERO);
+            model.setStartTime(startTime);
+            model.setEndTime(endTime);
+            model.setSendType(Constants.ZERO);
+            list.add(model);
+        }
+        //瀵煎叆鏂板鐨勬巿鏉冧俊鎭�
+        empowerMapper.insertBatchSomeColumn(list);
+    }
+
+    private   List<Integer>  getRoleIdByParam(Integer[] param, Member member) {
+        //娣诲姞浜哄憳瑙掕壊鍏宠仈鏁版嵁
+        memberRoleMapper.delete(new QueryWrapper<MemberRole>().lambda().eq(MemberRole::getMemberId,member.getId()));
+        if(!Objects.isNull(param)&&param.length>Constants.ZERO){
+            //鏌ヨ鏁版嵁搴撳瓨鍦ㄧ殑鏉冮檺
+            List<DeviceRole> deviceRoleList= deviceRoleMapper.selectList(new QueryWrapper<DeviceRole>().lambda()
+                    .eq(DeviceRole::getType,Constants.TWO)
+                    .in(DeviceRole::getId,param));
+            if(CollectionUtils.isNotEmpty(deviceRoleList)){
+                List<MemberRole> memberRoleList = new ArrayList<>();
+                String ids = "";
+                List<Integer> r = new ArrayList<>();
+                for (int i = 0; i < deviceRoleList.size(); i++) {
+                    DeviceRole deviceRole =deviceRoleList.get(i);
+                    if(i>0){
+                        ids += ",";
+                    }
+                    Integer id =deviceRole.getId();
+                    ids += "["+id+"]";
+                    String doorids =deviceRole.getDoorIds();
+                    if(StringUtils.isNotBlank(doorids)){
+                        String[] ss = doorids.split(",");
+                        try {
+                            for(String s :ss){
+                                r.add(Integer.parseInt(s));
+                            }
+                        }catch (Exception e){
+                            //鑴忔暟鎹笉澶勭悊
+                        }
+                    }
+                    MemberRole memberRole = new MemberRole();
+                    memberRole.setCreateDate(new Date());
+                    memberRole.setMemberId(member.getId());
+                    memberRole.setIsdeleted(Constants.ZERO);
+                    memberRole.setRoleId(deviceRole.getId().toString());
+                    memberRoleList.add(memberRole);
+                }
+                memberRoleMapper.insertBatchSomeColumn(memberRoleList);
+                member.setRoleId(ids);
+
+                return  r;
+            }
+        }
+        return  null;
+    }
+
+    @Override
+    public void roleUserAuthor(UserAuthorRequest param){
+        if(Objects.isNull(param)
+                ||StringUtils.isBlank(param.getUserId())){
+            throw new BusinessException(ResponseStatus.BAD_REQUEST);
+        }
+        Member member = memberMapper.selectOne(new QueryWrapper<Member>().lambda().eq(Member::getErpId,param.getUserId()).last("limit 1"));
+        if(Objects.isNull(member)){
+            return;
+        }
+        List<Integer> doorIds = getRoleIdByParam(param.getRoleIds(),member);
+        //濡傛灉鏈夋巿鏉冮棬绂佹暟鎹紝杩涜鐢ㄦ埛鎺堟潈鏁版嵁涓嬪彂浠诲姟鍒涘缓
+        dealMemberRoleEmpower(member,doorIds,param.getValidStartTime(),param.getValidEndTime());
+
+    }
+    @Override
+    public void parkCarAuthor(CarAuthorRequest param){
+        if(Objects.isNull(param)
+                ||StringUtils.isBlank(param.getCarCode())){
+            throw new BusinessException(ResponseStatus.BAD_REQUEST);
+        }
+        Member member = memberMapper.selectOne(new QueryWrapper<Member>().lambda().eq(Member::getErpId,param.getUserId()).last("limit 1"));
+        if(Objects.isNull(member)){
+            return;
+        }
+        //鍒犻櫎杞﹂噺搴撹褰曟暟鎹�
+        parkBookMapper.update(null,new UpdateWrapper<ParkBook>().lambda()
+                .eq(ParkBook::getCarCode,param.getCarCode())
+                .set(ParkBook::getIsdeleted,Constants.ONE)
+                .set(ParkBook::getHkStatus,Constants.ZERO)
+        );
+        //鏌ヨ杞﹀簱淇℃伅
+        List<Parks> parksList = parksMapper.selectList(new QueryWrapper<Parks>().lambda().in(Parks::getId,param.getPartIdList()));
+        if(CollectionUtils.isNotEmpty(parksList)){
+            List<ParkBook> parkBookList = new ArrayList<>();
+            for (Parks parks:parksList) {
+                ParkBook parkBook = new ParkBook();
+                parkBook.setIsdeleted(Constants.ZERO);
+                parkBook.setCreateDate(new Date());
+                parkBook.setCarCode(param.getCarCode());
+                parkBook.setParkId(parks.getId());
+                parkBook.setOrigin(Constants.ZERO);
+                parkBook.setStartTime(Objects.isNull(param.getValidStartTime())?new Date():param.getValidStartTime());
+                parkBook.setEndTime(param.getValidEndTime());
+                parkBook.setTimeType(Objects.isNull(param.getValidEndTime())?Constants.ZERO:Constants.ONE);
+                parkBook.setMemberId(member.getId());
+                parkBook.setHkStatus(Constants.ZERO);
+                parkBookList.add(parkBook);
+            }
+            parkBookMapper.insertBatchSomeColumn(parkBookList);
+        }
+
     }
 
 
@@ -693,8 +952,7 @@
         try{
             if(Objects.isNull(param)
                     ||Objects.isNull(param.getId())
-                    ||Objects.isNull(param.getStatus())
-            ){
+                    ||Objects.isNull(param.getStatus())){
                 throw new BusinessException(ResponseStatus.BAD_REQUEST);
             }
             if(!(param.getStatus()==Constants.ZERO||param.getStatus()==Constants.ONE)){
@@ -709,6 +967,7 @@
                 visitsList.forEach(i->{
                     i.setStatus(param.getStatus().equals(Constants.ZERO)?Constants.VisitStatus.pass:Constants.VisitStatus.noPass);
                     i.setEndCheckDate(DateUtil.StringToDate(param.getApproveDate(),"yyyy-MM-dd HH:mm:ss"));
+                    i.setHkStatus(Constants.ZERO);
                     visitsMapper.updateById(i);
                 });
             }

--
Gitblit v1.9.3