用户物品的查询改成gorse

This commit is contained in:
2023-11-24 00:26:02 +08:00
parent eeb87693d4
commit da3fb87975
8 changed files with 148 additions and 38 deletions

View File

@@ -134,11 +134,11 @@ public class GorseController extends BaseController {
@GetMapping(value = "/query_users")
public ResponseData queryUsers(@RequestParam("cursor") String cursor) throws Exception {
GorsePage page = gorseService.getUserPageByCursor(cursor);
if(page.getUsers() == null || page.getUsers().size() == 0) {
if (page.getUsers() == null || page.getUsers().size() == 0) {
return success(page);
}
List<String> ids = new ArrayList<>();
for(User user : page.getUsers()) {
for (User user : page.getUsers()) {
ids.add(user.getUserId());
}
Map mQ = new HashMap<>();
@@ -150,14 +150,31 @@ public class GorseController extends BaseController {
return success(obj);
}
@GetMapping(value = "/query_user/{id}")
public ResponseData queryUser(@PathVariable("id") String id) {
User user = null;
try {
user = gorseService.getUserById(id);
} catch (Exception e) {
}
if (user == null) {
return success();
}
Map mQ = new HashMap<>();
mQ.put("EQS_fid", user.getUserId());
return success(riskUserService.queryUnique(mQ));
}
@GetMapping(value = "/query_items")
public ResponseData queryItems(@RequestParam("cursor") String cursor) throws Exception {
GorsePage page = gorseService.getItemPageByCursor(cursor);
if(page.getItems() == null || page.getItems().size() == 0) {
if (page.getItems() == null || page.getItems().size() == 0) {
return success(page);
}
List<String> ids = new ArrayList<>();
for(Item item : page.getItems()) {
for (Item item : page.getItems()) {
ids.add(item.getItemId());
}
Map mQ = new HashMap<>();
@@ -169,4 +186,22 @@ public class GorseController extends BaseController {
return success(obj);
}
@GetMapping(value = "/query_item/{id}")
public ResponseData queryItem(@PathVariable("id") String id) {
Item item = null;
try {
item = gorseService.getItemById(id);
} catch (Exception e) {
}
if (item == null) {
return success();
}
Map mQ = new HashMap<>();
mQ.put("EQS_fid", item.getItemId());
return success(entrysService.queryUnique(mQ));
}
}

View File

@@ -101,6 +101,13 @@ public class GorseService {
return this.request("GET", baseUrl, null, GorsePage.class);
}
/**
* 查询用户
*/
public User getUserById(String id) throws IOException {
return this.request("GET", this.endpoint + "/api/dashboard/user/" + id, null, User.class);
}
/**
* 分页查询物品
*/
@@ -112,6 +119,13 @@ public class GorseService {
return this.request("GET", baseUrl, null, GorsePage.class);
}
/**
* 查询物品
*/
public Item getItemById(String id) throws IOException {
return this.request("GET", this.endpoint + "/api/item/" + id, null, Item.class);
}
/**
* 洞悉(根据用户获取推荐)
*/