tags

src/main/java/com/smcic/api/tags/entity/UserTags.java

@@ -27,6 +27,8 @@ public class UserTags {
 
     private LocalDateTime createTime;
 
+    private Integer status = 0;
+
     public UserTags() {
 
     }

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

@@ -80,24 +80,26 @@ public class UserTagsConsumer {
                 long curr = System.currentTimeMillis();
                 if(count > 300 || (count > 0 && curr - time > 2000)){
                     userTagsMapper.replaceUser(userTagsList);
-                    userTagsList.clear();
-                    count = 0;
-                    time = curr;
 
                     this.threadPoolExecutor.execute(() -> {
                         try {
                             recommend.setTableContent(tableContent);
-                            ResponseEntity<Object> mapResponseEntity = restTemplate.postForEntity("https://receiver.sxtvs.net/user/qmtssp", recommend, Object.class);
+                            ResponseEntity<Object> mapResponseEntity = restTemplate.postForEntity("https://receiver1.sxtvs.net/user/qmtssp", recommend, Object.class);
                             log.info("发送数据{}, 推荐系统响应{}", recommend, mapResponseEntity.getBody());
                             tableContent.clear();
+                            userTagsMapper.replaceUser(userTagsList.stream().peek(ut -> ut.setStatus(1)).collect(Collectors.toList()));
                         }catch (Exception e){
-                            log.info("推荐系统异常", e);
+                            log.error("推荐系统异常", e);
                         }
                     });
 
+                    userTagsList.clear();
+                    count = 0;
+                    time = curr;
+
                 }
             }catch (Exception e){
-                log.info("队列处理异常", e);
+                log.error("队列处理异常", e);
             }
         }
     }

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

@@ -2,11 +2,11 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.smcic.api.tags.mapper.UserTagsMapper">
     <select id="replaceUser" resultType="java.lang.Integer">
-        replace into user_tags (uuid, sex, age_range, province, city, tags, user_id, create_time)
+        replace into user_tags (uuid, sex, age_range, province, city, tags, user_id, create_time, status)
                 values
         <foreach collection="userTagsList" item="item" separator=",">
                 (#{item.uuid}, #{item.sex}, #{item.ageRange}, #{item.province},
-            #{item.city}, #{item.tags}, #{item.userId}, #{item.createTime})
+            #{item.city}, #{item.tags}, #{item.userId}, #{item.createTime}, #{item.status})
         </foreach>
     </select>