权限控制

src/main/java/com/boot/security/server/controller/AdvertiserController.java

@@ -63,4 +63,12 @@ public class AdvertiserController {
     public void updateAdvertiserData(@RequestBody PageTableRequest request) {
         advertiserService.updateAdvertiserManagerData(request.getAdvertiserData());
     }
+
+    //更新广告主数据
+    @PostMapping("/syncAdvertiserData")
+    @ApiOperation(value = "同步cms广告主数据")
+    @ResponseBody
+    public void syncAdvertiserData(@RequestBody PageTableRequest request) {
+        advertiserService.syncAdvertiserAndAdvert();
+    }
 }

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

@@ -62,4 +62,28 @@ public interface AdvertDao {
     int insertAdvertiserData(List<AdvertiserData> list);
 
     int insertAdvertiserUserMap(List<AdvertiserData> list);
+
+    //获得总收入
+    @Select("SELECT advertiser_id advertiserId,advertiser_name advertiserName,SUM(income) totalIncome FROM advert_data_count GROUP BY advertiser_id,advertiser_name")
+    List<AdvertiserData> getAdvertiserDataTotalIncome();
+
+    int insertAdvertiserDataTotalIncome(List<AdvertiserData> list);
+
+    //获得昨日收入
+    @Select("SELECT advertiser_id,advertiser_name,SUM(income) income FROM advert_data_count WHERE report_date>=DATE_SUB(DATE_FORMAT(NOW(),'%Y-%m-%d'),INTERVAL 1 DAY) AND report_date<=DATE_SUB(DATE_FORMAT(NOW(),'%Y-%m-%d'),INTERVAL 1 DAY) GROUP BY advertiser_id,advertiser_name")
+    List<AdvertiserData> getAdvertiserDataIncome();
+
+    int insertAdvertiserDataIncome(List<AdvertiserData> list);
+
+    //获得七日收入
+    @Select("SELECT advertiser_id,advertiser_name,SUM(income) incomeSeven FROM advert_data_count WHERE report_date>=DATE_SUB(DATE_FORMAT(NOW(),'%Y-%m-%d'),INTERVAL 7 DAY) AND report_date<=DATE_SUB(DATE_FORMAT(NOW(),'%Y-%m-%d'),INTERVAL 1 DAY) GROUP BY advertiser_id,advertiser_name")
+    List<AdvertiserData> getAdvertiserDataSevenIncome();
+
+    int insertAdvertiserDataSevenIncome(List<AdvertiserData> list);
+
+    //获得三十日收入
+    @Select("SELECT advertiser_id,advertiser_name,SUM(income) incomeThirty FROM advert_data_count WHERE report_date>=DATE_SUB(DATE_FORMAT(NOW(),'%Y-%m-%d'),INTERVAL 30 DAY) AND report_date<=DATE_SUB(DATE_FORMAT(NOW(),'%Y-%m-%d'),INTERVAL 1 DAY) GROUP BY advertiser_id,advertiser_name")
+    List<AdvertiserData> getAdvertiserDataThirtyIncome();
+
+    int insertAdvertiserDataThirtyIncome(List<AdvertiserData> list);
 }

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

@@ -117,6 +117,7 @@ public class AdvertiserServiceImpl implements AdvertiserService {
         advertDao.updateAdvertiserData(advertiserData.getAdvertiserId(),advertiserData.getBalance(),advertiserData.getExposureView(),advertiserData.getClickView());
     }
 
+    //同步cms广告主和广告数据
     @Override
     public void syncAdvertiserAndAdvert() {
         //读cms广告商和广告信息(广告商id、广告商名称、广告id、广告名称、平台id)

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

@@ -143,7 +143,14 @@ public class FileServiceImpl implements FileService {
 
 		advertDao.insertAdvertDataCount(list);
 		//根据advert_data_count计算总收入、昨日收入、七日收入、30日收入插入到advertiser_data_count
-
+		List<AdvertiserData> advertiserDataIncome = advertDao.getAdvertiserDataIncome();
+		advertDao.insertAdvertiserDataIncome(advertiserDataIncome);
+		List<AdvertiserData> advertiserDataTotalIncome = advertDao.getAdvertiserDataTotalIncome();
+		advertDao.insertAdvertiserDataTotalIncome(advertiserDataTotalIncome);
+		List<AdvertiserData> advertiserDataSevenIncome = advertDao.getAdvertiserDataSevenIncome();
+		advertDao.insertAdvertiserDataSevenIncome(advertiserDataSevenIncome);
+		List<AdvertiserData> advertiserDataThirtyIncome = advertDao.getAdvertiserDataThirtyIncome();
+		advertDao.insertAdvertiserDataThirtyIncome(advertiserDataThirtyIncome);
 	}
 
 }

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

@@ -61,4 +61,52 @@
         advertiser_name = VALUES(advertiser_name),
         user_id = VALUES(user_id)
     </insert>
+
+    <insert id="insertAdvertiserDataTotalIncome" parameterType="java.util.List">
+        INSERT INTO advertiser_data_count(advertiser_id, advertiser_name,total_income)
+        VALUES
+        <foreach collection="list" item="item" index="index" separator=",">
+            (#{item.advertiserId},#{item.advertiserName},#{item.totalIncome})
+        </foreach>
+        ON DUPLICATE KEY UPDATE
+        advertiser_id = VALUES(advertiser_id),
+        advertiser_name = VALUES(advertiser_name),
+        total_income = VALUES(total_income)
+    </insert>
+
+    <insert id="insertAdvertiserDataIncome" parameterType="java.util.List">
+        INSERT INTO advertiser_data_count(advertiser_id, advertiser_name,income)
+        VALUES
+        <foreach collection="list" item="item" index="index" separator=",">
+            (#{item.advertiserId},#{item.advertiserName},#{item.income})
+        </foreach>
+        ON DUPLICATE KEY UPDATE
+        advertiser_id = VALUES(advertiser_id),
+        advertiser_name = VALUES(advertiser_name),
+        income = VALUES(income)
+    </insert>
+
+    <insert id="insertAdvertiserDataSevenIncome" parameterType="java.util.List">
+        INSERT INTO advertiser_data_count(advertiser_id, advertiser_name,income_seven)
+        VALUES
+        <foreach collection="list" item="item" index="index" separator=",">
+            (#{item.advertiserId},#{item.advertiserName},#{item.incomeSeven})
+        </foreach>
+        ON DUPLICATE KEY UPDATE
+        advertiser_id = VALUES(advertiser_id),
+        advertiser_name = VALUES(advertiser_name),
+        income_seven = VALUES(income_seven)
+    </insert>
+
+    <insert id="insertAdvertiserDataThirtyIncome" parameterType="java.util.List">
+        INSERT INTO advertiser_data_count(advertiser_id, advertiser_name,income_thirty)
+        VALUES
+        <foreach collection="list" item="item" index="index" separator=",">
+            (#{item.advertiserId},#{item.advertiserName},#{item.incomeThirty})
+        </foreach>
+        ON DUPLICATE KEY UPDATE
+        advertiser_id = VALUES(advertiser_id),
+        advertiser_name = VALUES(advertiser_name),
+        income_thirty = VALUES(income_thirty)
+    </insert>
 </mapper>
\ No newline at end of file

src/main/resources/static/pages/advertiserManager/advertiserManager.html

@@ -8,7 +8,9 @@
 <link rel="stylesheet" href="../../css/treetable/jquery.treetable.theme.default.css" />
 <link rel="stylesheet" type="text/css" media="screen" href="../../layui/css/layui.css">
 <body>
-
+<button type="button" class="layui-btn">
+    <i class="layui-icon">&#xe669;</i>cms同步
+</button>
 <table id="demo" lay-filter="adveriserManagerTable"></table>
 
 </body>
@@ -24,6 +26,28 @@
 </script>
 <script>
 
+    $(".layui-btn").click(function() {
+        $.ajax({
+            //请求方式
+            type : "post",
+            //请求的媒体类型
+            contentType: "application/json;charset=UTF-8",
+            //请求地址
+            url : "/advertiserController/syncAdvertiserData",
+            async:false,
+            //数据，json字符串
+            data : JSON.stringify(json),
+            //请求成功
+            success : function(result) {
+                layer.msg("同步成功");
+            },
+            //请求失败
+            error: function (xhr) {
+                layer.msg("同步失败");
+            }
+        });
+    });
+
     layui.use('table', function(){
         var table = layui.table;
         //第一个实例
@@ -71,8 +95,7 @@
                 ,btn: ['确定', '取消']
                 ,yes: function(index, layero){
                     var advertiserData=obj.data;
-                    var json={advertiserData:advertiserData}
-                    //console.log(advertiserData);
+                    var json={advertiserData:advertiserData};
                     $.ajax({
                         //请求方式
                         type : "post",