姜永辉 2 лет назад
Родитель
Сommit
3ab40cb07f

+ 27 - 0
src/main/java/com/dk/mdm/feign/UserFeign.java

@@ -0,0 +1,27 @@
+package com.dk.mdm.feign;
+
+
+import com.dk.common.infrastructure.constant.Constant;
+import com.dk.common.response.ResponseResultVO;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+
+import java.util.Map;
+
+/**
+ * @author : 姜永辉
+ * @desc : OauthServerFeign
+ * @date : 2024-038-10 10:56
+ */
+@FeignClient(name = Constant.OAUTH_PREFIX + Constant.SERVER+ "-jyh", path = "/oauth/wx", contextId = "user")
+public interface UserFeign {
+    /**
+     * @desc   : 注册-创建员工的时候保存微信用户信息
+     * @author : 姜永辉
+     * @date   : 2023-11-02 16:27
+     */
+    @PostMapping({"/register_feign"})
+    ResponseResultVO<Boolean> registerFeign(@RequestBody Map<String, Object> collectQuery) ;
+
+}

+ 12 - 1
src/main/java/com/dk/mdm/service/mst/StaffService.java

@@ -11,6 +11,7 @@ import com.dk.common.response.ResponseCodeEnum;
 import com.dk.common.response.ResponseResultUtil;
 import com.dk.common.response.ResponseResultVO;
 import com.dk.mdm.feign.CompanyFeign;
+import com.dk.mdm.feign.UserFeign;
 import com.dk.mdm.infrastructure.convert.mst.StaffConvert;
 import com.dk.mdm.infrastructure.util.AuthUtils;
 import com.dk.mdm.mapper.common.CommonMapper;
@@ -41,7 +42,8 @@ import java.util.*;
 public class StaffService extends BaseService<Staff> {
     @Resource
     private CompanyFeign companyFeign;
-
+    @Resource
+    private UserFeign userFeign;
 
     @Override
     public BaseMapper<Staff> getRepository() {
@@ -117,6 +119,15 @@ public class StaffService extends BaseService<Staff> {
         staff.setStaffId(codeMap.get("outId").toString());
         staff.setStaffCode(codeMap.get("outNote").toString());
         super.insert(staff);
+        // 讲电话和名称插入微信用户表里
+
+        // 更新 被邀请人员的微信用户的cpid 加入公司
+        Map<String, Object> collectQuery = new HashMap<>();
+        collectQuery.put("currentCp", staff.getCpId());
+        collectQuery.put("userName", staff.getStaffName());
+        collectQuery.put("userPhone", staff.getStaffPhone());
+        userFeign.registerFeign(collectQuery);
+
         return ResponseResultUtil.success(staff);
     }