tags

src/main/java/com/smcic/api/tags/job/UserTagsConsumer.java

@@ -86,8 +86,8 @@ 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);
                             tableContent.clear();
-                            userTagsMapper.replaceUser(userTagsList.stream().peek(ut -> ut.setStatus(1)).collect(Collectors.toList()));
                         }catch (Exception e){
                             log.error("推荐系统异常", e);
                         }

src/main/java/com/smcic/api/tags/mapper/UserTagsMapper.java

@@ -2,9 +2,11 @@ package com.smcic.api.tags.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.smcic.api.tags.entity.UserTags;
+import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
 
 public interface UserTagsMapper extends BaseMapper<UserTags> {
 Integer replaceUser(List<UserTags> userTagsList);
+Integer updateStatus(@Param("uuidList") List<String> uuidList, @Param("status") Integer status);
 }

src/main/resources/com/smcic/UserTagsMapper.xml

@@ -10,4 +10,13 @@
         </foreach>
     </select>
 
+    <select id="updateStatus" resultType="java.lang.Integer">
+        update user_tags set status = #{status}
+        where uuid in (
+        <foreach collection="uuidList" item="item" separator=",">
+            #{item}
+        </foreach>
+        )
+    </select>
+
 </mapper>