|
@@ -84,7 +84,7 @@ public class UserTagsConsumer {
|
|
this.threadPoolExecutor.execute(() -> {
|
|
this.threadPoolExecutor.execute(() -> {
|
|
try {
|
|
try {
|
|
recommend.setTableContent(tableContent);
|
|
recommend.setTableContent(tableContent);
|
|
- ResponseEntity<Object> mapResponseEntity = restTemplate.postForEntity("https://receiver1.sxtvs.net/user/qmtssp", recommend, Object.class);
|
|
|
|
|
|
+ ResponseEntity<Object> mapResponseEntity = restTemplate.postForEntity("https://receiver.sxtvs.net/user/qmtssp", recommend, Object.class);
|
|
log.info("发送数据{}, 推荐系统响应{}", recommend, mapResponseEntity.getBody());
|
|
log.info("发送数据{}, 推荐系统响应{}", recommend, mapResponseEntity.getBody());
|
|
tableContent.clear();
|
|
tableContent.clear();
|
|
userTagsMapper.replaceUser(userTagsList.stream().peek(ut -> ut.setStatus(1)).collect(Collectors.toList()));
|
|
userTagsMapper.replaceUser(userTagsList.stream().peek(ut -> ut.setStatus(1)).collect(Collectors.toList()));
|