From 80f9adf3f7682edf1d997f48c65a9bac2e4c1605 Mon Sep 17 00:00:00 2001
From: rk <94314517@qq.com>
Date: 星期日, 28 九月 2025 15:25:42 +0800
Subject: [PATCH] 钉钉授权 与 通知开发

---
 server/system_service/src/main/java/com/doumee/dao/system/dto/LoginDTO.java                         |    3 
 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/MemberService.java          |    3 
 server/system_service/src/main/java/com/doumee/dao/system/dto/LoginH5DTO.java                       |    3 
 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java |   86 +++++++++++++++++++++
 server/system_service/src/main/java/com/doumee/service/system/impl/SystemLoginServiceImpl.java      |   33 +++++++-
 server/system_service/src/main/java/com/doumee/dao/system/model/SystemUser.java                     |    2 
 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/VisitsServiceImpl.java |   18 ----
 server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/web/VisitorWebController.java            |   16 ++++
 server/system_service/src/main/java/com/doumee/dao/system/dto/LoginPhoneDTO.java                    |    2 
 server/visits/dmvisit_service/src/main/java/com/doumee/dao/web/response/DDAuthorizeVO.java          |   24 ++++++
 server/visits/dmvisit_service/src/main/java/com/doumee/core/dingTalk/DingTalk.java                  |   48 ++++++++++++
 11 files changed, 215 insertions(+), 23 deletions(-)

diff --git a/server/system_service/src/main/java/com/doumee/dao/system/dto/LoginDTO.java b/server/system_service/src/main/java/com/doumee/dao/system/dto/LoginDTO.java
index 4e53960..6239c13 100644
--- a/server/system_service/src/main/java/com/doumee/dao/system/dto/LoginDTO.java
+++ b/server/system_service/src/main/java/com/doumee/dao/system/dto/LoginDTO.java
@@ -22,6 +22,9 @@
     @ApiModelProperty(value = "寰俊openId")
     private String openid;
 
+    @ApiModelProperty(value = "閽夐拤 unionId")
+    private String ddUnionId;
+
     @NotBlank(message = "瀵嗙爜涓嶈兘涓虹┖")
     @ApiModelProperty(value = "瀵嗙爜")
     private String password;
diff --git a/server/system_service/src/main/java/com/doumee/dao/system/dto/LoginH5DTO.java b/server/system_service/src/main/java/com/doumee/dao/system/dto/LoginH5DTO.java
index 5cda109..9df4bde 100644
--- a/server/system_service/src/main/java/com/doumee/dao/system/dto/LoginH5DTO.java
+++ b/server/system_service/src/main/java/com/doumee/dao/system/dto/LoginH5DTO.java
@@ -22,6 +22,9 @@
     @ApiModelProperty(value = "寰俊openId")
     private String openid;
 
+    @ApiModelProperty(value = "閽夐拤 unionId")
+    private String ddUnionId;
+
     @NotBlank(message = "瀵嗙爜涓嶈兘涓虹┖")
     @ApiModelProperty(value = "瀵嗙爜")
     private String password;
diff --git a/server/system_service/src/main/java/com/doumee/dao/system/dto/LoginPhoneDTO.java b/server/system_service/src/main/java/com/doumee/dao/system/dto/LoginPhoneDTO.java
index 4f8a018..647c679 100644
--- a/server/system_service/src/main/java/com/doumee/dao/system/dto/LoginPhoneDTO.java
+++ b/server/system_service/src/main/java/com/doumee/dao/system/dto/LoginPhoneDTO.java
@@ -23,6 +23,8 @@
     private String code;
     @ApiModelProperty(value = "openid")
     private String openid;
+    @ApiModelProperty(value = "閽夐拤 unionId")
+    private String ddUnionId;
     @ApiModelProperty(value = "鐢ㄦ埛绫诲瀷锛�0=鍙告満锛�1=璁垮锛�2=鍐呴儴鍛樺伐")
     private Integer userType;
 }
diff --git a/server/system_service/src/main/java/com/doumee/dao/system/model/SystemUser.java b/server/system_service/src/main/java/com/doumee/dao/system/model/SystemUser.java
index ad790af..48f88b9 100644
--- a/server/system_service/src/main/java/com/doumee/dao/system/model/SystemUser.java
+++ b/server/system_service/src/main/java/com/doumee/dao/system/model/SystemUser.java
@@ -98,6 +98,8 @@
     private String openidHkInfo;
     @ApiModelProperty(value = "寰俊openid鎺ㄩ�佹捣搴锋椂闂�", example = "1", hidden = true)
     private Date openidHkDate;
+    @ApiModelProperty(value = "閽夐拤 unionId", example = "1", hidden = true)
+    private String ddUnionId;
 
     //2024骞�12鏈�6鏃�11:00:30 绫诲瀷 0鍙告満浜哄憳 1鏅�氳瀹�  2鍐呴儴浜哄憳 3tms绠℃帶浜哄憳
     @ApiModelProperty(value = "绫诲瀷 0鍙告満浜哄憳 1鏅�氳瀹�  2鍐呴儴浜哄憳 3tms绠℃帶浜哄憳", example = "0")
diff --git a/server/system_service/src/main/java/com/doumee/service/system/impl/SystemLoginServiceImpl.java b/server/system_service/src/main/java/com/doumee/service/system/impl/SystemLoginServiceImpl.java
index 0fdc117..5334a12 100644
--- a/server/system_service/src/main/java/com/doumee/service/system/impl/SystemLoginServiceImpl.java
+++ b/server/system_service/src/main/java/com/doumee/service/system/impl/SystemLoginServiceImpl.java
@@ -156,7 +156,7 @@
             }
         }
         try {
-            LoginUserInfo user = dealLoginByPwdNewBiz(dto.getUsername(),dto.getPassword(),null,dto.getOpenid(),request);
+            LoginUserInfo user = dealLoginByPwdNewBiz(dto.getUsername(),dto.getPassword(),null,dto.getOpenid(),dto.getDdUnionId(),request);
             systemLoginLogService.create(loginLog);
             return  user;
         }catch (BusinessException e){
@@ -186,7 +186,7 @@
                 throw e;
             }
         }
-        LoginUserInfo user = dealLoginByPwdNewBiz(dto.getUsername(),dto.getPassword(),null,dto.getOpenid(),request);
+        LoginUserInfo user = dealLoginByPwdNewBiz(dto.getUsername(),dto.getPassword(),null,dto.getOpenid(),dto.getDdUnionId(),request);
         systemLoginLogService.create(loginLog);
         return  user;
     }
@@ -213,7 +213,7 @@
         isCaptcheValide(dto.getPhone(),dto.getCode());//妫�鏌ラ獙璇佺爜
         SystemLoginLog loginLog = getInitLoginlog(dto.getPhone(),request);
         try{
-            LoginUserInfo userInfo = dealLoginByPwdNewBiz(null,null,dto.getPhone(),dto.getOpenid(), request );
+            LoginUserInfo userInfo = dealLoginByPwdNewBiz(null,null,dto.getPhone(),dto.getOpenid(),dto.getDdUnionId(), request );
             systemLoginLogService.create(loginLog);
             return userInfo;
         }catch (BusinessException e){
@@ -227,7 +227,7 @@
             throw e;
         }
     }
-    private LoginUserInfo dealLoginByPwdNewBiz(String username,String pwd, String phone, String openid, ServerHttpRequest request) {
+    private LoginUserInfo dealLoginByPwdNewBiz(String username,String pwd, String phone, String openid, String ddUnionId, ServerHttpRequest request) {
         // 鏍规嵁鐢ㄦ埛鍚嶆煡璇㈢敤鎴峰璞�
         SystemUser queryDto = new SystemUser();
         queryDto.setMobile(phone);
@@ -248,7 +248,12 @@
                 throw new BusinessException(ResponseStatus.ACCOUNT_INCORRECT);
             }
         }
-        dealOpenIdBiz(user,openid);
+        if(StringUtils.isNotBlank(openid)){
+            dealOpenIdBiz(user,openid);
+        }
+        if(StringUtils.isNotBlank(ddUnionId)){
+            dealDDUnionIdBiz(user,ddUnionId);
+        }
         Company company = new Company();
         if(Objects.nonNull(user.getCompanyId())){
             company = companyMapper.selectById(user.getCompanyId());
@@ -320,6 +325,24 @@
                     .eq(SystemUser::getId,user.getId()));
         }
     }
+
+    private void dealDDUnionIdBiz(SystemUser user, String ddUnionId) {
+        if(StringUtils.isNotBlank(ddUnionId)){
+            //濡傛灉openId涓嶄负绌�,缁戝畾璇ョ敤鎴穙penid
+            systemUserMapper.update(null,new UpdateWrapper<SystemUser>().lambda()
+                    .set(SystemUser::getDdUnionId,null)
+                    .set(SystemUser::getOpenidHkStatus,Constants.ZERO)
+                    .ne(SystemUser::getType,Constants.memberType.gkuser)
+                    .eq(SystemUser::getDdUnionId,ddUnionId)
+            );
+            systemUserMapper.update(null,new UpdateWrapper<SystemUser>().lambda()
+                    .set(SystemUser::getDdUnionId,ddUnionId)
+                    .set(SystemUser::getOpenidHkStatus,Constants.ZERO)
+                    .set(SystemUser::getOpenidHkDate,null)
+                    .set(SystemUser::getOpenidHkInfo,null)
+                    .eq(SystemUser::getId,user.getId()));
+        }
+    }
     private void dealOpenIdBizForGk(SystemUser user, String openid) {
         if(StringUtils.isNotBlank(openid)){
             //濡傛灉openId涓嶄负绌�,缁戝畾璇ョ敤鎴穙penid
diff --git a/server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/web/VisitorWebController.java b/server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/web/VisitorWebController.java
index 6ec9c82..c8bb46b 100644
--- a/server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/web/VisitorWebController.java
+++ b/server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/web/VisitorWebController.java
@@ -3,6 +3,7 @@
 import com.doumee.api.BaseController;
 import com.doumee.config.annotation.LoginNoRequired;
 import com.doumee.core.annotation.trace.Trace;
+import com.doumee.dao.web.response.DDAuthorizeVO;
 import com.doumee.service.business.third.model.ApiResponse;
 import com.doumee.service.business.third.model.LoginUserInfo;
 import com.doumee.service.business.third.model.PageData;
@@ -17,6 +18,7 @@
 import com.doumee.service.business.MemberService;
 import com.doumee.service.business.VisitReasonService;
 import com.doumee.service.business.VisitsService;
+import com.taobao.api.ApiException;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiImplicitParams;
@@ -65,6 +67,18 @@
         return ApiResponse.success("鏌ヨ鎴愬姛",wxAuthorizeVO);
     }
 
+
+    @ApiOperation(value = "閽夐拤寰俊鎺堟潈", notes = "璁垮寰俊鎺堟潈鑾峰彇openId")
+    @GetMapping("/ddAuthorize")
+    @ApiImplicitParams({
+            @ApiImplicitParam(paramType = "query", dataType = "String", name = "code", value = "鎺堟潈鐮�", required = true),
+            @ApiImplicitParam(paramType = "query", dataType = "Integer", name = "source", value = "鏉ユ簮:0=鍙告満锛�1=璁垮锛�2=鍐呴儴鍛樺伐", required = true)
+    })
+    public ApiResponse<DDAuthorizeVO> ddAuthorize(@RequestParam String code, @RequestParam Integer source) throws ApiException {
+        DDAuthorizeVO ddAuthorizeVO =  memberService.ddAuthorize(code,source);
+        return ApiResponse.success("鏌ヨ鎴愬姛",ddAuthorizeVO);
+    }
+
     @ApiOperation(value = "鏌ヨ琚闂汉淇℃伅", notes = "鏌ヨ琚闂汉淇℃伅")
     @PostMapping("/getVisitedMember")
     public ApiResponse<List<MemberVO>> getVisitedMember(@Valid @RequestBody CheckVisitedDTO checkVisitedDTO) {
@@ -78,6 +92,8 @@
         visits.setSourceType(Constants.ZERO);
         return ApiResponse.success("鏌ヨ鎴愬姛", visitsService.createFk(visits,false,Constants.ZERO));
     }
+
+
     @ApiOperation(value = "鏉ヨ浜嬬敱", notes = "鏉ヨ浜嬬敱")
     @PostMapping("/visitReason")
     public ApiResponse<List<VisitReason>> visitReason() {
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/core/dingTalk/DingTalk.java b/server/visits/dmvisit_service/src/main/java/com/doumee/core/dingTalk/DingTalk.java
index 05bda56..e4a88b3 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/core/dingTalk/DingTalk.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/core/dingTalk/DingTalk.java
@@ -105,6 +105,19 @@
     }
 
 
+    public OapiV2UserGetuserinfoResponse.UserGetByCodeResponse  getDDUserByCode(String code) throws ApiException {
+        DingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/v2/user/getuserinfo");
+        OapiV2UserGetuserinfoRequest req = new OapiV2UserGetuserinfoRequest();
+        req.setCode(code);
+        OapiV2UserGetuserinfoResponse rsp = client.execute(req, getToken());
+        if(rsp.getErrcode().equals(Constants.DD_ERR_CODE)){
+           return  rsp.getResult();
+        }else{
+            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),rsp.getMessage());
+        }
+    }
+
+
     /**
      * 鍏ㄩ噺鍚屾 閮ㄩ棬淇℃伅
      * 鎺ュ彛鏂囨。鍦板潃 https://open.dingtalk.com/document/orgapp/obtain-the-department-list-v2
@@ -364,6 +377,41 @@
         }
     }
 
+    public void workInfoOANotice(Long agentId,String userIds,OapiMessageCorpconversationAsyncsendV2Request.Msg msg)throws ApiException {
+        DingTalkClient client = new DefaultDingTalkClient("https://oapi.dingtalk.com/topapi/message/corpconversation/asyncsend_v2");
+        OapiMessageCorpconversationAsyncsendV2Request request = new OapiMessageCorpconversationAsyncsendV2Request();
+        request.setAgentId(agentId);
+        request.setUseridList(userIds);
+        request.setToAllUser(false);
+//        OapiMessageCorpconversationAsyncsendV2Request.Msg msg = new OapiMessageCorpconversationAsyncsendV2Request.Msg();
+//        msg.setMsgtype("oa");
+//        OapiMessageCorpconversationAsyncsendV2Request.OA oa = new OapiMessageCorpconversationAsyncsendV2Request.OA();
+//        oa.setMessageUrl("");
+//        OapiMessageCorpconversationAsyncsendV2Request.Head head = new OapiMessageCorpconversationAsyncsendV2Request.Head();
+//        head.setText("");
+//        head.setBgcolor("#279BAA");
+//
+//        oa.setHead(head);
+//
+//        OapiMessageCorpconversationAsyncsendV2Request.Body body = new OapiMessageCorpconversationAsyncsendV2Request.Body();
+//        body.setTitle("");
+//        List<OapiMessageCorpconversationAsyncsendV2Request.Form> form = new ArrayList<>();
+//
+//        body.setForm(form);
+//        oa.setBody(body);
+//        msg.setOa(oa);
+        request.setMsg(msg);
+        OapiMessageCorpconversationAsyncsendV2Response rsp = client.execute(request, getToken());
+        if(rsp.getErrcode().equals(Constants.DD_ERR_CODE)){
+
+        }else{
+            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),rsp.getMessage());
+        }
+    }
+
+
+
+
 
 
 }
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/dao/web/response/DDAuthorizeVO.java b/server/visits/dmvisit_service/src/main/java/com/doumee/dao/web/response/DDAuthorizeVO.java
new file mode 100644
index 0000000..8ad2562
--- /dev/null
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/dao/web/response/DDAuthorizeVO.java
@@ -0,0 +1,24 @@
+package com.doumee.dao.web.response;
+
+import com.doumee.dao.business.model.Member;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * Created by IntelliJ IDEA.
+ *
+ * @Author : Rk
+ * @create 2023/12/7 11:19
+ */
+@Data
+public class DDAuthorizeVO {
+
+    @ApiModelProperty(value = "鎺堟潈 unionId ")
+    private String unionId;
+
+    @ApiModelProperty(value = "鐢ㄦ埛token")
+    private String token;
+
+    @ApiModelProperty(value = "鐢ㄦ埛淇℃伅")
+    private Member member;
+}
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/MemberService.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/MemberService.java
index d425932..06d9df9 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/MemberService.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/MemberService.java
@@ -1,5 +1,6 @@
 package com.doumee.service.business;
 
+import com.doumee.dao.web.response.DDAuthorizeVO;
 import com.doumee.service.business.third.model.LoginUserInfo;
 import com.doumee.service.business.third.model.PageData;
 import com.doumee.service.business.third.model.PageWrap;
@@ -13,6 +14,7 @@
 import com.doumee.dao.web.reqeust.VisitMemberDTO;
 import com.doumee.dao.web.response.MemberVO;
 import com.doumee.dao.web.response.WxAuthorizeVO;
+import com.taobao.api.ApiException;
 import org.springframework.web.multipart.MultipartFile;
 
 import java.util.List;
@@ -172,6 +174,7 @@
      */
     WxAuthorizeVO wxAuthorize(String code,Integer source);
 
+    DDAuthorizeVO ddAuthorize(String code, Integer source) throws ApiException;
 
 
     List<MemberVO> getVisitedMember(CheckVisitedDTO checkVisitedDTO);
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java
index 43c2c6f..624ce03 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/MemberServiceImpl.java
@@ -9,6 +9,7 @@
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.dingtalk.api.response.OapiV2DepartmentGetResponse;
 import com.dingtalk.api.response.OapiV2UserGetResponse;
+import com.dingtalk.api.response.OapiV2UserGetuserinfoResponse;
 import com.doumee.biz.system.SystemDictDataBiz;
 import com.doumee.config.DataSyncConfig;
 import com.doumee.core.annotation.excel.ExcelImporter;
@@ -22,6 +23,7 @@
 import com.doumee.core.haikang.model.param.respose.UserAddResponse;
 import com.doumee.core.haikang.model.param.respose.UserDelResponse;
 import com.doumee.core.haikang.service.HKService;
+import com.doumee.dao.web.response.DDAuthorizeVO;
 import com.doumee.service.business.third.TmsService;
 import com.doumee.service.business.third.model.LoginUserInfo;
 import com.doumee.service.business.third.model.PageData;
@@ -1845,6 +1847,12 @@
         return wxAuthorizeVO;
     }
 
+    /**
+     * 寰俊鎺堟潈 鍐呴儴浜哄憳鐧诲綍
+     * @param wxAuthorizeVO
+     * @param openId
+     * @param source
+     */
     private void dealSystemUserAuthBiz(WxAuthorizeVO wxAuthorizeVO, String openId, Integer source) {
         SystemUser user = systemUserMapper.selectOne(new QueryWrapper<SystemUser>().lambda()
                 .eq(SystemUser::getOpenid,openId)
@@ -1874,6 +1882,44 @@
             wxAuthorizeVO.setToken(token);
         }
     }
+
+    /**
+     * 閽夐拤鎺堟潈鑾峰彇鍐呴儴浜哄憳鐧诲綍淇℃伅
+     * @param ddAuthorizeVO
+     * @param unionId
+     * @param source
+     */
+    private void dealSystemUserAuthBizByDD(DDAuthorizeVO ddAuthorizeVO, String unionId, Integer source) {
+        SystemUser user = systemUserMapper.selectOne(new QueryWrapper<SystemUser>().lambda()
+                .eq(SystemUser::getDdUnionId,unionId)
+                .in(SystemUser::getType,Constants.memberType.internal)
+                .eq(SystemUser::getDeleted,Constants.ZERO)
+                .last(" limit 1 "));
+        //闈炶瀹㈢敤鎴� 杩涜鍒ゆ柇鏄惁瀛樺湪鐢ㄦ埛
+        if(!Objects.isNull(user)){
+            Member member = memberMapper.selectById(user.getMemberId());
+            if(member == null || member.getIsdeleted() == Constants.ONE){
+                return;
+//                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鐢ㄦ埛宸插垹闄�,璇疯仈绯荤鐞嗗憳");
+            }
+            if(member.getStatus() != Constants.ZERO){
+                return;
+//                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鐢ㄦ埛宸茬鐢�,璇疯仈绯荤鐞嗗憳");
+            }
+            if(StringUtils.isNotBlank(member.getIdcardNo())){
+                member.setIdcardDecode(DESUtil.decrypt(Constants.EDS_PWD, member.getIdcardNo()));
+            }
+            String prefixUrl = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode() +
+                    systemDictDataBiz.queryByCode(Constants.FTP,Constants.MEMBER_IMG).getCode();
+            member.setPrefixUrl(prefixUrl);
+            ddAuthorizeVO.setMember(member);
+            //鍙告満 涓� 鍐呴儴浜哄憳 鎻愪緵token
+            String token = systemLoginService.loginByUserId(user.getId());
+            ddAuthorizeVO.setToken(token);
+        }
+    }
+
+
     private void dealDriverUserAuthBiz(WxAuthorizeVO wxAuthorizeVO, String openId, Integer source) {
         SystemUser user = systemUserMapper.selectOne(new QueryWrapper<SystemUser>().lambda()
                 .eq(SystemUser::getOpenid,openId)
@@ -2568,5 +2614,45 @@
         }
     }
 
+    /**
+     * 閽夐拤鎺堟潈鐧诲綍
+     * @param code
+     * @param source
+     * @return
+     * @throws ApiException
+     */
+    @Override
+    public DDAuthorizeVO ddAuthorize(String code, Integer source) throws ApiException {
+        if(StringUtils.isBlank(code)||Objects.isNull(source)){
+            throw new BusinessException(ResponseStatus.BAD_REQUEST);
+        }
+        OapiV2UserGetuserinfoResponse.UserGetByCodeResponse userGetByCodeResponse = dingTalk.getDDUserByCode(code);
+        if(Objects.isNull(userGetByCodeResponse)
+                || StringUtils.isBlank(userGetByCodeResponse.getUnionid())){
+            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"閽夐拤鎺堟潈澶辫触");
+        }
+        String unionId = userGetByCodeResponse.getUnionid();
+
+        DDAuthorizeVO ddAuthorizeVO = new DDAuthorizeVO();
+        if(StringUtils.isBlank(unionId)){
+            return ddAuthorizeVO;
+        }
+        ddAuthorizeVO.setUnionId(unionId);
+//        if(source==1){
+//            //澶勭悊鏅�氳瀹汉鍛樿嚜鍔ㄦ巿鏉冮�昏緫
+//            dealVisitUserAuthBiz(wxAuthorizeVO,openId,source);
+//        }else if(source == 3){
+//            //澶勭悊tms绠℃帶浜哄憳鑷姩鎺堟潈閫昏緫
+//            dealGkUserAuthBiz(wxAuthorizeVO,openId,source);
+//        }else if(source == 0){
+//            //濡傛灉鏄徃鏈猴紝鍒欎粠system_user鏌ヨ
+//            dealDriverUserAuthBiz(wxAuthorizeVO,openId,source);
+//        }else{
+            //濡傛灉鏄唴閮ㄤ汉鍛橈紝鍒欎粠system_user鏌ヨ
+            dealSystemUserAuthBizByDD(ddAuthorizeVO,unionId,source);
+//        }
+        return ddAuthorizeVO;
+    }
+
 
 }
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/VisitsServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/VisitsServiceImpl.java
index d9ab31f..a98b0e8 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/VisitsServiceImpl.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/VisitsServiceImpl.java
@@ -258,24 +258,6 @@
         //鍒濆鍖栬瀹俊鎭�
         initVisitInfo(visits,date);
 
-//        if(StringUtils.isNotBlank(visits.getFaceImg())&&(Constants.equalsInteger(visits.getType(),Constants.ZERO)|| Constants.equalsInteger(visits.getType(),Constants.TWO))){
-//            //浜鸿劯璇勫垎
-//            FacePictureCheckRequest param = new FacePictureCheckRequest();
-//            String prefixUrl = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_LOCAL_RESOURCE_PATH).getCode() +
-//                    systemDictDataBiz.queryByCode(Constants.FTP,Constants.MEMBER_IMG).getCode();
-//            param.setFacePicUrl(prefixUrl + visits.getFaceImg());
-//            BaseResponse<FacePictureCheckResponse> response = HKService.facePictureCheck(param);
-//            if(response == null || !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)){
-//                throw  new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "瀵逛笉璧凤紝浜鸿劯璇勫垎鑾峰彇鏁版嵁澶辫触~");
-//            }
-//            FacePictureCheckResponse facePictureCheckResponse = response.getData();
-//            if(Objects.isNull(facePictureCheckResponse) || Objects.isNull(facePictureCheckResponse.getCheckResult())){
-//                throw  new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), "瀵逛笉璧凤紝浜鸿劯璇勫垎鑾峰彇鏁版嵁澶辫触~");
-//            }
-//            if(!facePictureCheckResponse.getCheckResult()){
-//                throw  new BusinessException(ResponseStatus.SERVER_ERROR.getCode(), facePictureCheckResponse.getStatusMessage());
-//            }
-//        }
         visits.setSendTimeOutNotice(Constants.ZERO);
         visitsMapper.insert(visits);
 

--
Gitblit v1.9.3