From e59a768f56efb64bf2fad412f62eca2a836b652f Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期四, 28 十二月 2023 14:13:00 +0800
Subject: [PATCH] 海康接口对接开发

---
 server/dmvisit_service/src/main/java/com/doumee/service/business/impl/erp/ErpSyncServiceImpl.java |   21 ++++++++++++++++-----
 1 files changed, 16 insertions(+), 5 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 4d8d692..973bcec 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
@@ -110,7 +110,7 @@
     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.userListUrl=systemDictDataBiz.queryByCode(Constants.ERP,Constants.ERP_USERLIST_URL).getCode();
         ErpConstants.userStatusUrl=systemDictDataBiz.queryByCode(Constants.ERP,Constants.ERP_USERSTATUS_RL).getCode();
         return  0;
     }
@@ -122,6 +122,9 @@
     @Override
     @Transactional
     public String syncCompany(OrgListRequest param){
+        if(!StringUtils.equals(Constants.ONE+"", systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.ORG_USER_ORIGIN).getCode())){
+            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "瀵逛笉璧凤紝褰撳墠涓嶆敮鎸佺粍缁囧悓姝ユ搷浣渵");
+        }
         //鑾峰彇ERP缁勭粐淇℃伅锛堝叏閲忓悓姝ワ級
         List<ErpOrgListResponse>  list = ErpTool.getErpOrgList(ErpConstants.orgListUrl,param);
         if(list !=null && list.size()>0){
@@ -177,13 +180,15 @@
                     //濡傛灉宸插垹闄わ紝鍔犲叆鍒犻櫎闆嗗悎涓�
                     delIds.add(company.getId());
                     continue;
+                }else{
+                    company.setIsdeleted(Constants.ZERO);
                 }
                 updateList.add(addUpdateCompanyModel(respone,company,date));
             }
         }
         if(allList!=null && allList.size()>0){
             for(Company  c : allList){
-                if(isCompanyDeleted(c,list)){
+                if(!isCompanyDeleted(c,list)){
                     delIds.add(c.getId());
                 }
             }
@@ -221,6 +226,7 @@
         company.setName(respone.getName());
         company.setErpId(respone.getId());
         company.setCreateDate(date);
+        company.setType(Constants.ONE);
         company.setCode(respone.getCode());
         company.setErpParentId(respone.getParentOrgId());
         company.setErpDate(date);
@@ -259,6 +265,9 @@
     @Override
     @Transactional
     public  String syncUsers(UserListRequest param){
+        if(!StringUtils.equals(Constants.ONE+"", systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.ORG_USER_ORIGIN).getCode())){
+            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "瀵逛笉璧凤紝褰撳墠涓嶆敮鎸佷汉鍛樺悓姝ユ搷浣渵");
+        }
         List<ErpUserListResponse>  list = ErpTool.getErpUserList(ErpConstants.userListUrl,param);
         if(list !=null && list.size()>0) {
             List<Member> addList = new ArrayList<>();
@@ -291,10 +300,11 @@
                         .set(Member::getHkStatus,Constants.ZERO)
                         .set(Member::getIsdeleted, Constants.ONE).in(Member::getId,delIds));
             }
+            return "鍚屾鏁版嵁锛氭柊澧炪��"+addList.size()+"銆戞潯锛屾洿鏂般��"+updateList.size()+"銆戞潯锛屽垹闄ゃ��"+delIds.size()+"銆戞潯";
         }else{
             throw  new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "鍚屾ERP鏁版嵁涓虹┖锛�");
         }
-        return  null;
+
     }
 
     public void dealRoleEmpower(Member member,Date startTime , Date endTime){
@@ -338,9 +348,8 @@
         }
         if(allList!=null && allList.size()>0){
             for(Member  c : allList){
-                if(isUserDeleted(c,list)){
+                if(!Constants.equalsInteger(c.getIsdeleted(),Constants.ONE) &&  !isUserDeleted(c,list)){
                     delList.add(c);
-//                    delIds.add(c.getId());
                 }
             }
         }
@@ -355,6 +364,7 @@
         member.setErpDate(new Date());
         member.setErpId(param.getId());
         member.setFsStatus(Constants.ZERO);
+        member.setStatus(param.getStatus());
         member.setType(Constants.memberType.internal);
         String encryptIdNo = DESUtil.encrypt(Constants.EDS_PWD,param.getIdNo());
         member.setIdcardNo(encryptIdNo);
@@ -373,6 +383,7 @@
         member.setIdcardDecode(Constants.getTuominStr(param.getIdNo()));
         member.setErpOrgId(param.getOrgId());
         member.setEditDate(new Date());
+        member.setStatus(param.getStatus());
         member.setErpDate(new Date());
         member.setHkStatus(Constants.ZERO);
         member.setRoleIds(param.getRoleIds());

--
Gitblit v1.9.3