权限控制

src/main/java/com/boot/security/server/dao/AdvertDao.java

@@ -16,9 +16,18 @@ public interface AdvertDao {
     @Select("select advertiser_id advertiserId,advertiser_name advertiserName from advertiser_user_map t where user_id=#{userId} and status=1")
     List<AdvertiserData> getAdvertiserByUserId(@Param("userId") Long userId);
 
+    //根据广告商di查广告id
     @Select("select code_id codeId from advert_list t where advertiser_id=#{advertiserId}")
     List<AdvertiserData> getAdvertDataById(@Param("advertiserId") Integer advertiserId);
 
+    //从advert_list查询所有的广告商id和广告商名称
+    @Select("select advertiser_id advertiserId,advertiser_name advertiserName from advert_list t group by advertiser_id,advertiser_name")
+    List<AdvertiserData> getAdvertiserData();
+
+    //从advertiser_user_map查询所有的用户
+    @Select("select user_id userId from advertiser_user_map t group by user_id")
+    List<AdvertiserData> getAdvertiserUserMap();
+
     @Select("select *,advertiser_id advertiserId,advertiser_name,total_income totalIncome,income_seven incomeSeven,income_thirty incomeThirty,exposure_view exposureView,click_view clickView from advertiser_data_count t where advertiser_id=#{advertiserId}")
     AdvertiserData getAdvertiserDataById(@Param("advertiserId") Integer advertiserId);
 
@@ -46,4 +55,10 @@ public interface AdvertDao {
     int updateAdvertiserData(@Param("advertiserId") Integer advertiserId,@Param("balance") Double balance,@Param("exposureView") Integer exposureView,@Param("clickView") Integer clickView);
 
     int insertAdvertDataCount(List<AdvertiserData> list);
+
+    int insertAdvertList(List<AdvertiserData> list);
+
+    int insertAdvertiserData(List<AdvertiserData> list);
+
+    int insertAdvertiserUserMap(List<AdvertiserData> list);
 }

src/main/java/com/boot/security/server/model/AdvertiserData.java

@@ -19,6 +19,15 @@ public class AdvertiserData {
     public Integer clickView;
     public String minutes;
     public Integer platformId;
+    public Long userId;
+
+    public Long getUserId() {
+        return userId;
+    }
+
+    public void setUserId(Long userId) {
+        this.userId = userId;
+    }
 
     public Integer getPlatformId() {
         return platformId;

src/main/java/com/boot/security/server/service/impl/AdvertiserServiceImpl.java

@@ -6,6 +6,7 @@ import com.boot.security.server.dto.LoginUser;
 import com.boot.security.server.model.AdvertiserData;
 import com.boot.security.server.page.table.PageTableRequest;
 import com.boot.security.server.service.AdvertiserService;
+import com.boot.security.server.utils.ConnectionJDBC;
 import com.boot.security.server.utils.UserUtil;
 import com.boot.security.server.utils.redis.JedisHelper;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -118,7 +119,26 @@ public class AdvertiserServiceImpl implements AdvertiserService {
 
     @Override
     public void syncAdvertiserAndAdvert() {
-        
+        //读cms广告商和广告信息(广告商id、广告商名称、广告id、广告名称、平台id)
+        List<AdvertiserData> dataList = ConnectionJDBC.getInstance("SELECT b.advertiser_id,a.name,b.code_id,b.name,b.platform_id FROM advertiser a LEFT JOIN advert b ON a.id=b.advertiser_id WHERE TYPE=2");
+        //插入advert_list表里面(用duplicate)
+        advertDao.insertAdvertList(dataList);
+        //插入advertiser_data_count表(用duplicate，广告商id、广告商名称、曝光和点击系数默认为1)
+        List<AdvertiserData> advertiserData = advertDao.getAdvertiserData();
+        advertDao.insertAdvertiserData(advertiserData);
+        //插入advertiser_user_map表(用duplicate，用户id、广告商id、广告商名称)
+        List<AdvertiserData> advertiserUserList=new ArrayList<>();
+        List<AdvertiserData> advertiserUserMap = advertDao.getAdvertiserUserMap();
+        for (AdvertiserData advertiser : advertiserData) {
+            for (AdvertiserData user : advertiserUserMap) {
+                AdvertiserData data = new AdvertiserData();
+                data.setAdvertiserId(advertiser.getAdvertiserId());
+                data.setAdvertiserName(advertiser.getAdvertiserName());
+                data.setUserId(user.getUserId());
+                advertiserUserList.add(data);
+            }
+        }
+        advertDao.insertAdvertiserUserMap(advertiserUserList);
     }
 
     private JSONObject getRedisChartInfo(Integer advertiserId,String advertId){

src/main/java/com/boot/security/server/utils/ConnectionJDBC.java

@@ -16,7 +16,7 @@ public class ConnectionJDBC {
      * */
     public static Connection getConnection() throws Exception {
         //1.加载配置文件
-        InputStream is  = ClassLoader.getSystemResourceAsStream("jdbc.properties");
+        InputStream is  = ClassLoader.getSystemResourceAsStream("config.properties");
         Properties pros = new Properties();
         pros.load(is);
 

src/main/resources/config.properties

@@ -5,6 +5,15 @@ cassandra.port = 9014
 kafka.group.id=user_action_logs_test2
 cassnadra.keyspace=dmp
 
+#user=readbi
+#password=OxmQkfpS2019
+#url=jdbc:mysql://rm-2zeyw42052h06f905.mysql.rds.aliyuncs.com:3306/bi_report
+#driverClass=com.mysql.jdbc.Driver
+
+user=root
+password=(639Xn6
+url=jdbc:mysql://172.17.173.228:3306/lwby
+driverClass=com.mysql.jdbc.Driver
 
 ## redis配置
 #redis连接池最大空闲连接数

src/main/resources/mybatis-mappers/AdvertMapper.xml

@@ -23,4 +23,42 @@
         cpc = VALUES(cpc),
         income = VALUES(income)
     </insert>
+
+    <insert id="insertAdvertList" parameterType="java.util.List">
+        INSERT INTO advert_list(advertiser_id, advertiser_name, code_id,code_name,platform_id)
+        VALUES
+        <foreach collection="list" item="item" index="index" separator=",">
+            (#{item.advertiserId},#{item.advertiserName},
+            #{item.codeId},#{item.codeName},#{item.platformId})
+        </foreach>
+        ON DUPLICATE KEY UPDATE
+        advertiser_id = VALUES(advertiser_id),
+        advertiser_name = VALUES(advertiser_name),
+        code_id = VALUES(code_id),
+        code_name = VALUES(code_name),
+        platform_id = VALUES(platform_id)
+    </insert>
+
+    <insert id="insertAdvertiserData" parameterType="java.util.List">
+        INSERT INTO advertiser_data_count(advertiser_id, advertiser_name)
+        VALUES
+        <foreach collection="list" item="item" index="index" separator=",">
+            (#{item.advertiserId},#{item.advertiserName})
+        </foreach>
+        ON DUPLICATE KEY UPDATE
+        advertiser_id = VALUES(advertiser_id),
+        advertiser_name = VALUES(advertiser_name)
+    </insert>
+
+    <insert id="insertAdvertiserUserMap" parameterType="java.util.List">
+        INSERT INTO advertiser_user_map(advertiser_id, advertiser_name,user_id)
+        VALUES
+        <foreach collection="list" item="item" index="index" separator=",">
+            (#{item.advertiserId},#{item.advertiserName},#{item.userId})
+        </foreach>
+        ON DUPLICATE KEY UPDATE
+        advertiser_id = VALUES(advertiser_id),
+        advertiser_name = VALUES(advertiser_name),
+        user_id = VALUES(user_id)
+    </insert>
 </mapper>
\ No newline at end of file