|
@@ -86,7 +86,10 @@ public class UserTagsConsumer {
|
|
|
recommend.setTableContent(tableContent);
|
|
|
ResponseEntity<Object> mapResponseEntity = restTemplate.postForEntity("https://receiver.sxtvs.net/user/qmtssp", recommend, Object.class);
|
|
|
log.info("发送数据{}, 推荐系统响应{}", recommend, mapResponseEntity.getBody());
|
|
|
- userTagsMapper.updateStatus(tableContent.stream().map(tc -> tc.getFields().getImei()).collect(Collectors.toList()), 1);
|
|
|
+ List<String> uuids = tableContent.stream().map(tc -> tc.getFields().getImei()).collect(Collectors.toList());
|
|
|
+ if(!uuids.isEmpty()){
|
|
|
+ userTagsMapper.updateStatus(uuids, 1);
|
|
|
+ }
|
|
|
tableContent.clear();
|
|
|
}catch (Exception e){
|
|
|
log.error("推荐系统异常", e);
|