From 9f2c35bcddcd835efc25ed53d3a9c8816781bb5f Mon Sep 17 00:00:00 2001
From: k94314517 <8417338+k94314517@user.noreply.gitee.com>
Date: 星期二, 27 二月 2024 14:36:42 +0800
Subject: [PATCH] ERP接口

---
 server/dmvisit_service/src/main/java/com/doumee/service/business/impl/VisitsServiceImpl.java |  131 ++++++++++++++++++++++++++++++-------------
 1 files changed, 92 insertions(+), 39 deletions(-)

diff --git a/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/VisitsServiceImpl.java b/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/VisitsServiceImpl.java
index 2009aaa..a2a4137 100644
--- a/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/VisitsServiceImpl.java
+++ b/server/dmvisit_service/src/main/java/com/doumee/service/business/impl/VisitsServiceImpl.java
@@ -127,6 +127,7 @@
         //璁垮淇℃伅(浣跨敤韬唤璇佸彿鏌ヨ鏄惁宸插瓨鍦ㄦ敼鏅�氳瀹紝娌℃湁鍒欐柊澧烇紝瀛樺湪鍒欐洿鏂皁penid绛変俊鎭�),鍖呮嫭闅忚浜哄憳鏍¢獙鍜屽鐞�
         Member member =dealMemberAndVisits(visits);
         visits.setMemberId(member.getId());
+        visits.setVisitType(Integer.valueOf(systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.MDJ_VISIT_REQUIRED).getCode()));
         //鍒濆鍖栬瀹俊鎭�
         initVisitInfo(visits,date);
         visitsMapper.insert(visits);
@@ -134,6 +135,7 @@
         String erpId = startSendErpCheck(visits,visitMember);
         if(StringUtils.isNotBlank(erpId)){
             visits.setErpId(erpId);
+            visits.setStatus(Constants.VisitStatus.submitCheck);
             visitsMapper.updateById(visits);
         }else{
             throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "瀵逛笉璧凤紝鍙戣捣鎷滆瀹℃壒鐢宠澶辫触锛�");
@@ -475,7 +477,7 @@
     private void isValidBaseParam(Visits visits) {
         if(visits.getEndtime() == null
                 || visits.getStarttime() == null
-                ||  StringUtils.isBlank(visits.getReason())
+//                ||  StringUtils.isBlank(visits.getReason())
                 ||  StringUtils.isBlank( visits.getName())
                 ||  StringUtils.isBlank( visits.getPhone())
                 ||  visits.getIdcardType() == null
@@ -484,9 +486,9 @@
                 || visits.getReceptMemberId() == null){
             throw  new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "瀵逛笉璧凤紝淇℃伅濉啓涓嶆纭紒");
         }
-        if(visits.getStarttime().getTime() < System.currentTimeMillis()){
-            throw  new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "瀵逛笉璧凤紝棰勭害寮�濮嬫椂闂村繀椤诲ぇ浜庡綋鍓嶆椂闂达紒");//
-        }
+//        if(visits.getStarttime().getTime() < System.currentTimeMillis()){
+//            throw  new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "瀵逛笉璧凤紝棰勭害寮�濮嬫椂闂村繀椤诲ぇ浜庡綋鍓嶆椂闂达紒");//
+//        }
         if(visits.getEndtime().getTime() <= visits.getStarttime().getTime()){
             throw  new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "瀵逛笉璧凤紝棰勭害缁撴潫鏃堕棿蹇呴』澶т簬寮�濮嬫椂闂达紒");//
         }
@@ -532,6 +534,7 @@
     private void initWithVisitInfo(Visits visits) {
         if(CollectionUtils.isNotEmpty(visits.getWithUserList())){
             for(Visits v :visits.getWithUserList()){
+                v.setBirthday(Constants.getBirthdyByCardNo(v.getIdcardNo()));
                 v.setParentId(visits.getId());
                 v.setStarttime(visits.getStarttime());
                 v.setEndtime(visits.getEndtime());
@@ -541,8 +544,14 @@
                 v.setIdcardDecode(Constants.getTuominStr(v.getIdcardNo()));//鑴辨晱韬唤璇佸彿
                 v.setIdcardNo(DESUtil.encrypt(Constants.EDS_PWD, v.getIdcardNo()));//韬唤璇佸彿鍔犲瘑
                 v.setErpId(visits.getErpId());
+                v.setReceptMemberId(visits.getReceptMemberId());
+                v.setMemberNum(Constants.ZERO);
                 v.setHkStatus(Constants.ZERO);
-                v.setStatus(Constants.ZERO);
+                v.setReason(visits.getReason());
+                v.setDoors(visits.getDoors());
+                v.setType(visits.getType());
+                v.setVisitType(visits.getVisitType());
+                v.setStatus(Constants.VisitStatus.submitCheck);
             }
             //鎵归噺鎻掑叆鏁版嵁
             visitsMapper.insertBatchSomeColumn(visits.getWithUserList());
@@ -652,31 +661,40 @@
         //闅忚浜哄憳淇℃伅澶勭悊
         if(visits.getWithUserList()!= null && visits.getWithUserList().size()>0){
             for(Visits model:visits.getWithUserList()){
+                model.setBirthday(Constants.getBirthdyByCardNo(model.getIdcardNo()));
                 model.setStarttime(visits.getStarttime());
                 model.setEndtime(visits.getEndtime());
                 //鏍¢獙闅忚浜哄憳濉姤鏁版嵁鍚堟硶鎬�
                 isValidWithVisitParam(model,addList,editList);
                 model.setCreateDate(visits.getCreateDate());
-                getMemberListParam(model.getIdcardNo(),model,addList,editList);
+                Member visitsMember = getMemberListParam(model.getIdcardNo(),model,addList,editList);
+                model.setMemberId(visitsMember.getId());
             }
         }
 
-        if(CollectionUtils.isNotEmpty(addList)){
-            memberMapper.insertBatchSomeColumn(addList);
-        }
-        if(CollectionUtils.isNotEmpty(editList)){
-            editList.forEach(i->{
-                memberMapper.updateById(i);
-            });
-
-        }
+//        if(CollectionUtils.isNotEmpty(addList)){
+//            memberMapper.insertBatchSomeColumn(addList);
+//        }
+//        if(CollectionUtils.isNotEmpty(editList)){
+//            editList.forEach(i->{
+//                memberMapper.updateById(i);
+//            });
+//
+//        }
 
         return  m;
     }
 
     private Member getMemberListParam(String cardno, Visits visits, List<Member> addList, List<Member> editList) {
-        if(StringUtils.isNotBlank(visits.getCarNos())&&!Constants.checkCarNo(visits.getCarNos())){
+        if(!StringUtils.isNotBlank(visits.getCarNos())
+                &&Objects.isNull(Constants.getVehiclePlateNo(visits.getCarNos()))
+        ){
             throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "瀵逛笉璧凤紝杞︾墝鍙枫��"+visits.getCarNos()+"銆戜笉鍚堟硶锛岃鏍稿疄鍚庨噸璇晘");
+        }
+        if(Constants.equalsInteger(Constants.ZERO, visits.getIdcardType())&&cardno.length()!=18
+            //&&!IdcardUtil.isValidCard(cardno)
+        ){
+            throw  new BusinessException(ResponseStatus.BAD_REQUEST.getCode(), "瀵逛笉璧凤紝韬唤璇佸彿鐮佹湁璇紝璇锋牳瀹炲悗閲嶈瘯锛�");
         }
         Member member = memberMapper.selectOne(new QueryWrapper<Member>().lambda()
                 .eq(Member::getType,Constants.memberType.visitor)
@@ -689,6 +707,7 @@
             member.setCreateDate(visits.getCreateDate());
             member.setIsdeleted(Constants.ZERO);
             member.setIdcardNo(visits.getIdcardNo());
+            member.setBirthday(Constants.getBirthdyByCardNo(cardno));
             member.setIdcardDecode(visits.getIdcardDecode());
             member.setIdcardNo(DESUtil.encrypt(Constants.EDS_PWD, cardno));//韬唤璇佸彿鍔犲瘑
             member.setIdcardDecode(Constants.getTuominStr(cardno));//鑴辨晱鎵嬫満鍙�
@@ -704,15 +723,19 @@
             member.setSex(Constants.getSexByCardNo(cardno));
             member.setHkStatus(Constants.ZERO);
             member.setErpStatus(Constants.ZERO);
-            // 鏂板璁垮璁板綍
-            addList.add(member);
+            member.setVisitCompanyName(visits.getCompanyName());
+            memberMapper.insert(member);
+            // 鏂板璁垮
+//            addList.add(member);
         }else{
             if(!Constants.equalsInteger(Constants.ZERO,member.getStatus() )){
                 //濡傛灉鐢ㄦ埛鐘舵�佸紓甯革紝鍒欐彁绀�
                 throw  new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(), "瀵逛笉璧凤紝璇ヨ韩浠借瘉鍙疯绂佹璁块棶鐢宠锛屽鏈夌枒闂紝璇疯仈绯绘偍鐨勬嫓璁夸汉杩涜鏍稿疄");
             }
             //鏍告煡棰勭害鐢ㄦ埛鏄惁瀛樺湪鏈绂荤殑棰勭害璁板綍
-            isExsitNoOutVisisRecord(member);
+
+//            isExsitNoOutVisisRecord(member);
+
             member.setFaceImg(visits.getFaceImg());
             member.setImgurl(StringUtils.isNotBlank(visits.getImgurl())?visits.getImgurl():null);
             member.setEditDate(visits.getCreateDate());
@@ -726,13 +749,17 @@
             member.setSex(Constants.getSexByCardNo(cardno));
             member.setHkStatus(Constants.ZERO);
             member.setErpStatus(Constants.ZERO);
+            member.setVisitCompanyName(visits.getCompanyName());
+            memberMapper.updateById(member);
             // 鏇存柊璁垮淇℃伅,
-            editList.add(member);
+//            editList.add(member);
         }
         //鏍规嵁鎵嬫満鍙峰拰韬唤璇佸彿鐮佹煡璇� 褰撳墠棰勭害鐨勬椂闂存槸鍚︿笌鍏朵粬棰勭害璁板綍鏈夊啿绐�
         if (visitsMapper.selectCount(new QueryWrapper<Visits>().lambda()
-                .and(ms -> ms.eq(Visits::getPhone, visits.getPhone())
-                        .or().eq(Visits::getIdcardDecode, Constants.getTuominStr(cardno)))
+                        .notIn(Visits::getStatus,Constants.VisitStatus.cancel,Constants.VisitStatus.noPass,Constants.VisitStatus.xfFail)
+//                .and(ms -> ms.eq(Visits::getPhone, visits.getPhone())
+//                        .or().eq(Visits::getIdcardDecode, Constants.getTuominStr(cardno)))
+                .eq(Visits::getIdcardDecode, Constants.getTuominStr(cardno))
                 .and(ms -> ms.apply(" visits.STARTTIME <= '" + DateUtil.DateToStr(visits.getStarttime(),"yyyy-MM-dd HH:mm:ss") + "' and visits.ENDTIME >= '" + DateUtil.DateToStr(visits.getStarttime(),"yyyy-MM-dd HH:mm:ss") + "' ")
                         .or().apply(" visits.STARTTIME <= '" + DateUtil.DateToStr(visits.getEndtime(),"yyyy-MM-dd HH:mm:ss") + "' and visits.ENDTIME >= '" + DateUtil.DateToStr(visits.getEndtime(),"yyyy-MM-dd HH:mm:ss") + "' ")
                 )) > Constants.ZERO) {
@@ -909,7 +936,7 @@
         queryWrapper.selectAs(Member::getName,Visits::getReceptMemberName);
         queryWrapper.selectAs(Company::getName,Visits::getReceptMemberDepartment);
         queryWrapper.leftJoin(Member.class,Member::getId,Visits::getReceptMemberId);
-        queryWrapper.leftJoin(Company.class,Company::getId,Member::getCompanyId);
+        queryWrapper.leftJoin(Company.class,Company::getErpId,Member::getErpOrgId);
 
         queryWrapper.eq(Visits::getId,id);
         Visits result = visitsJoinMapper.selectJoinOne(Visits.class,queryWrapper);
@@ -917,10 +944,10 @@
         if(result!=null){
             if(StringUtils.isNotBlank(result.getDoors())){
                 String[] doorList=result.getDoors().split(",");
-                MPJLambdaWrapper<Device> deviceQuery = new MPJLambdaWrapper<>();
-                deviceQuery.in(Device::getId,doorList);
-                List<Device> deviceList= deviceJoinMapper.selectList(deviceQuery);
-                result.setDeviceList(deviceList);
+                MPJLambdaWrapper<DeviceRole> deviceQuery = new MPJLambdaWrapper<>();
+                deviceQuery.in(DeviceRole::getId,doorList);
+                List<DeviceRole> deviceRoleList= deviceRoleMapper.selectList(deviceQuery);
+                result.setDeviceRoleList(deviceRoleList);
             }
         }
 
@@ -957,6 +984,7 @@
         MPJLambdaWrapper<Visits> queryWrapper = new MPJLambdaWrapper<>();
 
         queryWrapper.selectAll(Visits.class);
+        queryWrapper.select("  ( select count(distinct(v.CAR_NOS)) from visits v where v.PARENT_ID = t.ID and v.CAR_NOS is not null  and v.CAR_NOS != ''  and v.CAR_NOS != t.CAR_NOS ) as carNum  ");
         queryWrapper.selectAs(Member::getName,Visits::getReceptMemberName);
         queryWrapper.selectAs(Company::getName,Visits::getReceptMemberDepartment);
         queryWrapper.leftJoin(Member.class,Member::getId,Visits::getReceptMemberId);
@@ -972,6 +1000,12 @@
         queryWrapper.isNull(Visits::getParentId);
         queryWrapper.orderByDesc(Visits::getCreateDate);
         IPage<Visits> result = visitsJoinMapper.selectJoinPage(page, Visits.class,queryWrapper);
+
+        for (Visits visits:result.getRecords()) {
+            if(StringUtils.isNotBlank(visits.getCarNos())){
+                visits.setCarNum(visits.getCarNum() + Constants.ONE);
+            }
+        }
         return PageData.from(result);
     }
 
@@ -984,17 +1018,21 @@
 
     @Override
     public PageData<Visits> retentionPage(PageWrap<Visits> pageWrap) {
+        String code= systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.TIMEOUT_WARNING).getCode();
         IPage<Visits> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
         MPJLambdaWrapper<Visits> queryWrapper = new MPJLambdaWrapper<>();
-
         queryWrapper.selectAll(Visits.class);
         queryWrapper.selectAs(Member::getName,Visits::getReceptMemberName);
-        queryWrapper.select("TIMESTAMPDIFF(MINUTE,t.ENDTIME , NOW()) AS timeOut");
+        queryWrapper.select("TIMESTAMPDIFF( MINUTE, NOW(), t.OUT_DATE) AS timeOut");
         queryWrapper.selectAs(Member::getType,Visits::getMemberType);
         queryWrapper.selectAs(Company::getName,Visits::getReceptMemberDepartment);
         queryWrapper.leftJoin(Member.class,Member::getId,Visits::getReceptMemberId);
         queryWrapper.leftJoin(Company.class,Company::getId,Member::getCompanyId);
         queryWrapper.leftJoin(" member m on m.id=t.MEMBER_ID");
+
+        queryWrapper.eq(Objects.nonNull(pageWrap.getModel().getLevelStatus()),Visits::getStatus,Constants.VisitStatus.signin);
+
+        queryWrapper.apply(Objects.nonNull(pageWrap.getModel().getLevelStatus())," TIMESTAMPDIFF( MINUTE, NOW(), t.OUT_DATE) <= "+code+"  ");
 
         queryWrapper.ne("m.type ",Constants.TWO);
         queryWrapper.eq(Visits::getIsdeleted,Constants.ZERO);
@@ -1004,20 +1042,20 @@
                 .eq(StringUtils.isNotBlank(pageWrap.getModel().getIdcardNo()),Visits::getIdcardNo,StringUtils.isNotBlank(pageWrap.getModel().getIdcardNo()))
                 .eq(StringUtils.isNotBlank(pageWrap.getModel().getCompanyName()),Visits::getCompanyName,pageWrap.getModel().getCompanyName())
                 .eq(Objects.nonNull(pageWrap.getModel().getStatus()),Visits::getStatus,pageWrap.getModel().getStatus());
-        queryWrapper.isNull(Visits::getOutDate);
+        queryWrapper.isNull(!Objects.nonNull(pageWrap.getModel().getLevelStatus()),Visits::getOutDate);
         queryWrapper.orderByDesc(Visits::getEditDate);
-       String code= systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.TIMEOUT_FREEZE).getCode();
         IPage<Visits> result = visitsJoinMapper.selectJoinPage(page, Visits.class,queryWrapper);
         if(result!=null&&result.getRecords()!=null){
             result.getRecords().stream().forEach(s ->{
-                if(s.getTimeOut()>=Constants.ZERO){
-                    s.setOutStatus(Constants.ONE);
-                }else if(s.getTimeOut()<=Integer.valueOf(code)&&s.getTimeOut()>0){
-                    s.setOutStatus(Constants.TWO);
-                }else{
-                    s.setOutStatus(Constants.ZERO);
+                if(s.getStatus().equals(Constants.VisitStatus.signin)){
+                    if(s.getTimeOut()<=Integer.valueOf(code)&&s.getTimeOut()>=0){
+                        s.setOutStatus(Constants.TWO);
+                    }else if(s.getTimeOut()>Constants.ZERO){
+                        s.setOutStatus(Constants.ZERO);
+                    }else{
+                        s.setOutStatus(Constants.ONE);
+                    }
                 }
-
             });
         }
 
@@ -1039,6 +1077,7 @@
         VisitDetailVO visitDetailVO = new VisitDetailVO();
         visitDetailVO.setStatus(visits.getStatus());
         visitDetailVO.setCarNos(visits.getCarNos());
+        visitDetailVO.setPhone(visits.getPhone());
         visitDetailVO.setVisitUserName(member.getName());
         visitDetailVO.setVisitReason(visits.getReason());
         visitDetailVO.setVisitTime(DateUtil.DateToStr(visits.getStarttime(),"yyyy-MM-dd HH:mm") + " 鑷� " + DateUtil.DateToStr(visits.getEndtime(),"yyyy-MM-dd HH:mm") );
@@ -1067,7 +1106,7 @@
         }
         visitDetailVO.setWithVisitsList(
                 visitsMapper.selectList(new QueryWrapper<Visits>().lambda()
-                .select(Visits::getName,Visits::getPhone,Visits::getFaceImg,Visits::getImgurl,Visits::getIdcardDecode)
+                .select(Visits::getName,Visits::getPhone,Visits::getFaceImg,Visits::getImgurl,Visits::getIdcardDecode,Visits::getStatus)
                 .eq(Visits::getParentId,id)));
         return visitDetailVO;
     }
@@ -1110,4 +1149,18 @@
 
 
 
+    @Override
+    public void  visitLevel(Integer visitId){
+        Visits visits = visitsMapper.selectById(visitId);
+        if(Objects.isNull(visits)){
+            throw new BusinessException(ResponseStatus.DATA_EMPTY);
+        }
+        if(!visits.getStatus().equals(Constants.VisitStatus.signin)){
+            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"璁垮璁板綍鐘舵�侀敊璇紝璇峰埛鏂伴噸璇�");
+        }
+        visitsMapper.update(null,new UpdateWrapper<Visits>().lambda().set(Visits::getStatus,Constants.VisitStatus.signout)
+                .eq(Visits::getId,visitId));
+
+    }
+
 }

--
Gitblit v1.9.3