店铺对接企业微信

src/main/java/com/kiisoo/ic/employee/mapper/PrivilageCpUserDOMapper.java

@@ -0,0 +1,9 @@
+package com.kiisoo.ic.employee.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.kiisoo.ic.employee.entity.PrivilageCpUserDO;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface PrivilageCpUserDOMapper extends BaseMapper<PrivilageCpUserDO> {
+}

src/main/java/com/kiisoo/ic/employee/service/EmployeeService.java

@@ -1,6 +1,9 @@
 package com.kiisoo.ic.employee.service;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.kiisoo.ic.employee.entity.EmployeeDO;
+import com.kiisoo.ic.employee.entity.PrivilageCpUserDO;
+import com.kiisoo.ic.employee.mapper.PrivilageCpUserDOMapper;
 import com.kiisoo.ic.wx.service.QWMailListManageService;
 import me.chanjar.weixin.common.error.WxErrorException;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -19,6 +22,9 @@ public class EmployeeService {
     @Autowired
     private QWMailListManageService qwMailListManageService;
 
+    @Autowired
+    private PrivilageCpUserDOMapper privilageCpUserDOMapper;
+
     @Transactional(rollbackFor = Exception.class)
     public Boolean addUser(EmployeeDO employee) throws WxErrorException {
         //数据库创建用户
@@ -30,4 +36,15 @@ public class EmployeeService {
 
         return true;
     }
+
+    /**
+     * 找到微信
+     * @param phone
+     */
+    public PrivilageCpUserDO getUserWX(String phone){
+        PrivilageCpUserDO privilageCpUserDO = new PrivilageCpUserDO();
+        privilageCpUserDO.setMobile(phone);
+        return privilageCpUserDOMapper.selectOne(new QueryWrapper<>(privilageCpUserDO));
+    }
+
 }

src/main/java/com/kiisoo/ic/test/Test.java

@@ -0,0 +1,21 @@
+package com.kiisoo.ic.test;
+
+import com.kiisoo.ic.app.IcApplication;
+import com.kiisoo.ic.wx.service.AddWXService;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+
+@RunWith(SpringRunner.class)
+@SpringBootTest(classes = IcApplication.class)
+public class Test {
+
+    @Autowired
+    AddWXService addWXService;
+
+    @org.junit.Test
+    public void te(){
+        addWXService.addWX("a","b");
+    }
+}

src/main/java/com/kiisoo/ic/wechat/web/CreateWechatController.java

@@ -1,15 +0,0 @@
-package com.kiisoo.ic.wechat.web;
-
-import org.springframework.stereotype.Controller;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestParam;
-
-@Controller
-@RequestMapping("/wechat")
-public class CreateWechatController {
-
-    @RequestMapping("/create")
-    public void createWechat(@RequestParam("code") String code){
-        System.out.println(code) ;
-    }
-}

src/main/java/com/kiisoo/ic/wx/constants/Constant.java

@@ -0,0 +1,14 @@
+package com.kiisoo.ic.wx.constants;
+
+/***
+ * 微信相关常量
+ */
+public class Constant {
+
+    /**增加企业微信返回状态码*/
+    public static String ADD_URL_RETURN_PARAM = "errcode";
+
+    /**增企业微信成功返回码*/
+    public static int ADD_URL_SUCC_CODE = 0;
+
+}

src/main/java/com/kiisoo/ic/wx/controller/CreateWechatController.java

@@ -0,0 +1,44 @@
+package com.kiisoo.ic.wx.controller;
+
+import com.alibaba.fastjson.JSON;
+import com.kiisoo.ic.common.BaseController;
+import com.kiisoo.ic.wx.entity.CreateWXDO;
+import com.kiisoo.ic.wx.service.AddWXService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.*;
+
+import javax.annotation.PostConstruct;
+import java.util.HashMap;
+import java.util.Map;
+
+@Controller
+@RequestMapping("/wechat")
+public class CreateWechatController extends BaseController {
+
+    @RequestMapping("/create")
+    public void createWechat(@RequestParam("code") String code){
+        System.out.println(code) ;
+    }
+
+    @Autowired
+    private AddWXService addWXService;
+    /**
+     * 登录账号
+     * @return 成功/失败
+     */
+    @RequestMapping(value = "/test",method = RequestMethod.POST)
+    @ResponseBody
+    public String loginAccount(@RequestBody CreateWXDO createWXDO){
+        Map<String, Object> m = new HashMap<>();
+        m.put("errcode",0);
+        return JSON.toJSONString(m);
+    }
+
+//    @Scheduled(cron = "59 05 17 * * ?")
+    public void a(){
+        addWXService.addWX("a","b");
+    }
+}

src/main/java/com/kiisoo/ic/wx/entity/CreateWXDO.java

@@ -0,0 +1,82 @@
+package com.kiisoo.ic.wx.entity;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import lombok.Data;
+
+/**
+ * 创建企业微信参数
+ */
+@Data
+public class CreateWXDO {
+
+    /**调用接口凭证。获取方法查看“获取access_token”*/
+    @JSONField(name = "access_token")
+    private String accessToken;
+
+    /**成员UserID。对应管理端的帐号，企业内必须唯一。不区分大小写，长度为1~64个字节。只能由数字、字母和“_-@.”四种字符组成，且第一个字符必须是数字或字母。*/
+    private String userid;
+
+    /**成员名称。长度为1~64个utf8字符*/
+    private String name;
+
+    /**成员别名。长度1~32个utf8字符*/
+    private String alias;
+
+    /**手机号码。企业内必须唯一，mobile/email二者不能同时为空*/
+    private String mobile;
+
+    /**成员所属部门id列表,不超过20个*/
+    private long[] department;
+
+    /**部门内的排序值，默认为0，成员次序以创建时间从小到大排列。
+     * 数量必须和department一致，数值越大排序越前面。有效的值范围是[0, 2^32)*/
+    private int[] order;
+
+    /**职务信息。长度为0~128个字符*/
+    private String position;
+
+    /**1表示男性，2表示女性*/
+    private int gender;
+
+    /**邮箱。长度6~64个字节，且为有效的email格式。企业内必须唯一，mobile/email二者不能同时为空*/
+    private String email;
+
+    /**	座机。32字节以内，由纯数字或’-‘号组成。*/
+    private String telephone;
+
+    /**个数必须和department一致，表示在所在的部门内是否为上级。
+     * 1表示为上级，0表示非上级。在审批等应用里可以用来标识上级审批人*/
+    @JSONField(name = "is_leader_in_dept")
+    private long[] isLeaderInIept;
+
+    /**成员头像的mediaid，通过素材管理接口上传图片获得的mediaid*/
+    @JSONField(name = "avatar_mediaid")
+    private long avatarMediaid;
+
+    /**启用/禁用成员。1表示启用成员，0表示禁用成员*/
+    private int enable;
+
+    /**自定义字段。自定义字段需要先在WEB管理端添加，见扩展属性添加方法，否则忽略未知属性的赋值。
+     * 与对外属性一致，不过只支持type=0的文本和type=1的网页类型，详细描述查看对外属性*/
+    private String extattr;
+
+    /**是否邀请该成员使用企业微信
+     * （将通过微信服务通知或短信或邮件下发邀请，每天自动下发一次，最多持续3个工作日），默认值为true。*/
+    @JSONField(name = "to_invite")
+    private boolean toInvite = true;
+
+    /**成员对外属性，字段详情见对外属性*/
+    @JSONField(name = "external_profile")
+    private String externalProfile;
+
+    /**对外职务，如果设置了该值，则以此作为对外展示的职务，否则以position来展示。长度12个汉字内*/
+    @JSONField(name = "external_position")
+    private String externalPosition;
+
+    /**地址。长度最大128个字符*/
+    private String address;
+
+    /**主部门*/
+    @JSONField(name = "main_department")
+    private int mainDepartment;
+}

src/main/java/com/kiisoo/ic/wx/service/AddWXService.java

@@ -0,0 +1,48 @@
+package com.kiisoo.ic.wx.service;
+
+import com.alibaba.fastjson.JSON;
+import com.kiisoo.ic.common.utils.httpClientUtil.HttpClientUtil;
+import com.kiisoo.ic.common.utils.httpClientUtil.HttpResult;
+import com.kiisoo.ic.employee.entity.PrivilageCpUserDO;
+import com.kiisoo.ic.employee.service.EmployeeService;
+import com.kiisoo.ic.wx.constants.Constant;
+import com.kiisoo.ic.wx.utils.UrlUtil;
+import com.kiisoo.ic.wx.entity.CreateWXDO;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+/**
+ * 增加企业微信
+ */
+@Service
+public class AddWXService {
+
+    @Autowired
+    private EmployeeService employeeServicel;
+    String token = "a";
+    boolean ifHad = false;
+    String tock = "";
+    /**
+     * 增加企业微信
+     */
+    public void addWX(String phone, String name){
+        //查看此人是否已经创建过企业微信
+        PrivilageCpUserDO privilageCpUserDO = employeeServicel.getUserWX(phone);
+        //如果已经创建过
+        if(privilageCpUserDO == null){
+            return;
+        }
+        //创建企业微信基础数据
+        CreateWXDO createWXDO = new CreateWXDO();
+        createWXDO.setUserid(phone);
+        createWXDO.setName(name);
+        //未创建，则创建
+        HttpResult result = HttpClientUtil.httpPost(UrlUtil.getAddWXUrl(token), JSON.toJSONString(createWXDO), tock);
+        //是否添加微信成功
+        boolean ifAdd = UrlUtil.compHttpResult(result, Constant.ADD_URL_RETURN_PARAM, Constant.ADD_URL_SUCC_CODE);
+        //如果成功，则添加对应的表信息
+//        if(ifAdd){
+//
+//        }
+    }
+}

src/main/java/com/kiisoo/ic/wx/utils/UrlUtil.java

@@ -0,0 +1,36 @@
+package com.kiisoo.ic.wx.utils;
+
+import com.alibaba.fastjson.JSONObject;
+import com.kiisoo.ic.common.utils.httpClientUtil.HttpResult;
+
+/**
+ * 公共变量
+ */
+public class UrlUtil {
+
+    /**增加企业微信路径*/
+    private static String ADD_WX_URL = "https://qyapi.weixin.qq.com/cgi-bin/user/create";
+
+    /**
+     * 获取增加企业微信的url路径
+     * @param token
+     * @return
+     */
+    public static String getAddWXUrl(String token){
+        return ADD_WX_URL+token;
+    }
+
+    /**
+     * 从返回实体中，找到对应的参数名称值，与期待的值进行对比
+     * @param httpResult 返回实体
+     * @param resultParam 返回实体参数名称
+     * @param compData 期待值
+     * @return
+     */
+    public static boolean compHttpResult(HttpResult httpResult, String resultParam, int compData){
+       //http返回参数
+       String resultEntity = httpResult.getMessage();
+       int resultData = JSONObject.parseObject(resultEntity).getInteger(resultParam);
+       return resultData == compData;
+    }
+}