'commit'

src/main/java/UnitTest/TestDingTalk.java

@@ -38,6 +38,11 @@ public class TestDingTalk {
         return druidPlugin;
     }
 
+    public static void writeDtDeptId(int orgId, String value) {
+        String sql = "update t_base_organization set dingtalk_dept_id=? where org_id=?";
+        Db.update(sql, value, orgId);
+    }
+
     public static void main(String[] args_) throws Exception {
         PropKit.use("dingtalk.properties");
         String corpId = PropKit.get("corpId");
@@ -70,12 +75,12 @@ public class TestDingTalk {
         ADD COLUMN `dingtalk_dept_id` bigint NULL COMMENT '钉钉中的部门ID' AFTER `zydz`,
         ADD INDEX(`dingtalk_dept_id`);
         */
-        String sql = "select org_id,org_name from t_base_organization where org_name = '长春市教育局'";
+        String sql = "select org_id,org_name from t_base_organization where org_name = '长春市东光学校'";
         Record record = Db.findFirst(sql);
         int orgId = record.getInt("org_id");
-        //单位需要清空一下这个属性
-        sql = "update t_base_organization set dingtalk_dept_id=null where org_id=?";
-        Db.update(sql, orgId);
+
+        //单位需要清空一下这个属性,有枣没枣都打一下子
+        writeDtDeptId(orgId, null);
 
         //  学校及学校下的部门
         sql = "select org_id,org_name,parent_id,sort_id from t_base_organization where bureau_id=? order by org_id";
@@ -99,8 +104,7 @@ public class TestDingTalk {
             //创建
             long dt_dept_id = DingTalkUtil.createDept(accessToken, dept_name, dingtalk_dept_id, sortId);
             //回写
-            sql = "update t_base_organization set dingtalk_dept_id=? where org_id=?";
-            Db.update(sql, dt_dept_id, orgId);
+            writeDtDeptId(orgId, String.valueOf(dt_dept_id));
         }
         System.out.println("恭喜，所有操作成功完成！");
     }