Browse Source

crm单点登录优化

shenjingwei 4 months ago
parent
commit
4192f6980b
1 changed files with 9 additions and 14 deletions
  1. 9 14
      src/custom/common/crm/sso.java

+ 9 - 14
src/custom/common/crm/sso.java

@@ -272,23 +272,18 @@ public class sso extends Basic {
                 roleids.remove(5211L);
                 roleids.remove(5206L);
             }
-
             String siteid = "MD";
-            SQLDump sqlDump = new SQLDump();
-            sqlDump.add("update sys_users set name='" + name + "',phonenumber='" + phonenumber + "' where userid=" + userid);
-            sqlDump.add("update sys_enterprise_hr set name='" + name + "',phonenumber='" + phonenumber + "' where userid=" + userid);
-            sqlDump.add("delete from sys_userrole where userid=" + userid + " and siteid='" + siteid + "'");
 
-            if (!roleids.isEmpty()) {
-                for (long roleid : roleids) {
-                    InsertSQL adduserrole = SQLFactory.createInsertSQL(dbConnect, "sys_userrole");
-                    adduserrole.setValue("userid", userid);
-                    adduserrole.setValue("roleid", roleid);
-                    adduserrole.setValue("siteid", siteid);
-                    sqlDump.add(adduserrole);
-                }
+            dbConnect.runSqlUpdate("update sys_users set name='" + name + "',phonenumber='" + phonenumber + "' where userid=" + userid);
+            dbConnect.runSqlUpdate("update sys_enterprise_hr set name='" + name + "',phonenumber='" + phonenumber + "' where userid=" + userid);
+            dbConnect.runSqlUpdate("delete from sys_userrole where userid=" + userid + " and siteid='" + siteid + "'");
+            for (long roleid : roleids) {
+                InsertSQL adduserrole = SQLFactory.createInsertSQL(dbConnect, "sys_userrole");
+                adduserrole.setValue("userid", userid);
+                adduserrole.setValue("roleid", roleid);
+                adduserrole.setValue("siteid", siteid);
+                adduserrole.insert();
             }
-            sqlDump.commit(dbConnect);
             return true;
         } catch (Exception e) {
             e.printStackTrace();