This commit is contained in:
Paidax
2025-10-17 15:49:02 +08:00
parent 1cb3ee9d58
commit ca2e204395
28 changed files with 1841 additions and 30 deletions
+41 -25
View File
@@ -14,12 +14,14 @@ import cn.hutool.http.HttpUtil;
import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import com.budwk.app.base.utils.ManyAddOrRenewUtil;
import com.budwk.app.base.utils.PwdUtil;
import com.budwk.app.sys.models.*;
import com.budwk.app.sys.services.SysDictService;
import com.budwk.app.sys.services.SysUnitService;
import com.budwk.app.sys.services.SysUserService;
import com.budwk.app.web.commons.auth.utils.SecurityUtil;
import com.budwk.app.zhgh.democratic.teachercongress.delegate.models.Teacher_congress_delegate;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import lombok.Data;
@@ -219,37 +221,51 @@ public class JugTest {
dao.update(users,"password|salt");
}
@Inject
private ManyAddOrRenewUtil manyAddOrRenewUtil;
@Test
public void test11111(){
File file = new File("C:\\temp\\response.json");
JSONObject entries = JSONUtil.parseObj(FileUtil.readUtf8String(file));
JSONArray records = entries.getJSONArray("records");
List<JSONObject> list = records.stream().map(item -> (JSONObject) item).toList();
// 工号集合
List<String> loginNameList = list.stream().map(v -> v.getStr("rydm")).toList();
// Sql sql = Sqls.create("update sys_user set member = 1, welfareMember = 1 where loginname in (@loginNameList)")
// .setParam("loginNameList", loginNameList);
// File file = new File("C:\\temp\\response.json");
//
// JSONObject entries = JSONUtil.parseObj(FileUtil.readUtf8String(file));
//
// JSONArray records = entries.getJSONArray("records");
// List<JSONObject> list = records.stream().map(item -> (JSONObject) item).toList();
//
// // 工号集合
// List<String> loginNameList = list.stream().map(v -> v.getStr("rydm")).toList();
//// Sql sql = Sqls.create("update sys_user set member = 1, welfareMember = 1 where loginname in (@loginNameList)")
//// .setParam("loginNameList", loginNameList);
//// dao.execute(sql);
//
// Sql sql = Sqls.create("select id from sys_user where loginname in (@loginNameList)").setParam("loginNameList", loginNameList);
// sql.setCallback(Sqls.callback.strList());
// dao.execute(sql);
// List<String> userIds = sql.getList(String.class);
//
// List<Sys_user_role> roleList = userIds.stream().map(v -> {
// Sys_user_role userRole = new Sys_user_role();
// userRole.setUserId(v);
// userRole.setRoleId("6d603b652abee584ba6274dc1fcee3bb");
// return userRole;
// }).toList();
//
// dao.clear(Sys_user_role.class, Cnd.where("userId", "in", userIds));
// dao.insert(roleList);
Sql sql = Sqls.create("select id from sys_user where loginname in (@loginNameList)").setParam("loginNameList", loginNameList);
sql.setCallback(Sqls.callback.strList());
dao.execute(sql);
List<String> userIds = sql.getList(String.class);
List<Sys_user_role> roleList = userIds.stream().map(v -> {
Sys_user_role userRole = new Sys_user_role();
userRole.setUserId(v);
userRole.setRoleId("6d603b652abee584ba6274dc1fcee3bb");
return userRole;
}).toList();
dao.clear(Sys_user_role.class, Cnd.where("userId", "in", userIds));
dao.insert(roleList);
// Sql sql = Sqls.create("select id from sys_user group by id");
// sql.setCallback(Sqls.callback.strList());
// dao.execute(sql);
// List<String> userIds = sql.getList(String.class);
// List<Sys_user_role> roleList = userIds.stream().map(v -> {
// Sys_user_role userRole = new Sys_user_role();
// userRole.setUserId(v);
// userRole.setRoleId("65195ad8f52c4d7d8864624e583b801b");
// return userRole;
// }).toList();
// dao.insert(roleList);
}
}