tags

src/main/java/com/smcic/api/epg/controller/TagsController.java

@@ -1,27 +0,0 @@
-package com.smcic.api.epg.controller;
-
-import com.baomidou.mybatisplus.core.metadata.IPage;
-import com.smcic.api.epg.entity.KeywordDisableConfig;
-import com.smcic.api.epg.entity.SspTags;
-import com.smcic.api.epg.service.impl.KeywordDisableConfigService;
-import com.smcic.api.epg.service.impl.SspTagsService;
-import org.apache.ibatis.annotations.Param;
-import org.springframework.web.bind.annotation.*;
-
-import javax.annotation.Resource;
-import java.util.List;
-
-@RestController
-@RequestMapping("tags")
-public class TagsController {
-
-    @Resource
-    private SspTagsService sspTagsService;
-
-    @RequestMapping("list")
-    public List<SspTags>  sspTags(){
-        return sspTagsService.sspTags();
-    }
-
-
-}

src/main/java/com/smcic/api/tags/controller/TagsController.java

@@ -0,0 +1,34 @@
+package com.smcic.api.tags.controller;
+
+import com.smcic.api.tags.dto.UserTagsDTO;
+import com.smcic.api.tags.entity.SspTags;
+import com.smcic.api.tags.entity.UserTags;
+import com.smcic.api.tags.service.impl.SspTagsService;
+import com.smcic.api.tags.service.impl.UserTagsService;
+import org.springframework.web.bind.annotation.*;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+@RestController
+@RequestMapping("tags")
+public class TagsController {
+
+    @Resource
+    private SspTagsService sspTagsService;
+
+    @Resource
+    private UserTagsService userTagsService;
+
+    @RequestMapping("list")
+    public List<SspTags>  sspTags(){
+        return sspTagsService.sspTags();
+    }
+
+    @RequestMapping("store")
+    public void store(@RequestBody UserTagsDTO userTags){
+        userTagsService.insert(userTags);
+    }
+
+
+}

src/main/java/com/smcic/api/epg/entity/SspTags.java → src/main/java/com/smcic/api/tags/entity/SspTags.java

@@ -1,4 +1,4 @@
-package com.smcic.api.epg.entity;
+package com.smcic.api.tags.entity;
 
 import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableId;

src/main/java/com/smcic/api/epg/mapper/SspTagsMapper.java → src/main/java/com/smcic/api/tags/mapper/SspTagsMapper.java

@@ -1,7 +1,7 @@
-package com.smcic.api.epg.mapper;
+package com.smcic.api.tags.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import com.smcic.api.epg.entity.SspTags;
+import com.smcic.api.tags.entity.SspTags;
 
 public interface SspTagsMapper extends BaseMapper<SspTags> {
 

src/main/java/com/smcic/api/epg/service/ISspTagsService.java → src/main/java/com/smcic/api/tags/service/ISspTagsService.java

@@ -1,7 +1,7 @@
-package com.smcic.api.epg.service;
+package com.smcic.api.tags.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
-import com.smcic.api.epg.entity.SspTags;
+import com.smcic.api.tags.entity.SspTags;
 
 public interface ISspTagsService extends IService<SspTags> {
 }

src/main/java/com/smcic/api/epg/service/impl/SspTagsService.java → src/main/java/com/smcic/api/tags/service/impl/SspTagsService.java

@@ -1,12 +1,9 @@
-package com.smcic.api.epg.service.impl;
+package com.smcic.api.tags.service.impl;
 
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.smcic.api.epg.entity.KeywordDisableConfig;
-import com.smcic.api.epg.entity.SspTags;
-import com.smcic.api.epg.mapper.KeywordDisableConfigMapper;
-import com.smcic.api.epg.mapper.SspTagsMapper;
-import com.smcic.api.epg.service.IKeywordDisableConfigService;
-import com.smcic.api.epg.service.ISspTagsService;
+import com.smcic.api.tags.entity.SspTags;
+import com.smcic.api.tags.mapper.SspTagsMapper;
+import com.smcic.api.tags.service.ISspTagsService;
 import org.springframework.stereotype.Service;
 
 import java.util.List;

src/main/java/com/smcic/core/conf/ThreadPoolFactory.java

@@ -0,0 +1,30 @@
+package com.smcic.core.conf;
+
+import com.google.common.util.concurrent.ThreadFactoryBuilder;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.ThreadFactory;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
+
+@Configuration
+public class ThreadPoolFactory {
+
+    @Bean(name="threadPoolExecutor")
+    public ThreadPoolExecutor getThreadPool(){
+        // 给线程指定名称，方便查看线程编号
+        ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()
+                .setNameFormat("conf-thread-pool-%d").build();
+
+        // 创建线程池
+
+        return new ThreadPoolExecutor(24,
+                128,
+                300,
+                TimeUnit.SECONDS,
+                new LinkedBlockingQueue<>(),
+                namedThreadFactory);
+    }
+}

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

@@ -0,0 +1,13 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!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)
+                values
+        <foreach collection="userTagsList" item="item" separator=",">
+                (#{item.uuid}, #{item.sex}, #{item.ageRange}, #{item.province},
+            #{item.city}, #{item.tags}, #{item.userId}, #{item.createTime})
+        </foreach>
+    </select>
+
+</mapper>