data

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

@@ -16,14 +16,23 @@ public interface AdvertDao {
     Integer getAdvertDataCount(@Param("startTime") String startTime, @Param("endTime") String endTime);
 
     @Select("select advertiser_id advertiserId,advertiser_name advertiserName from advertiser_user_map t where user_id={#userId}")
-    List<AdvertiserData> getAdvertiserByUserId(@Param("userId") String userId);
+    List<AdvertiserData> getAdvertiserByUserId(@Param("userId") Long userId);
 
     @Select("select code_id codeId from advert_list t where advertiser_id={#advertiserId}")
-    List<AdvertiserData> getAdvertDataById(@Param("advertiserId") String advertiserId);
+    List<AdvertiserData> getAdvertDataById(@Param("advertiserId") Integer advertiserId);
 
     @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}")
-    List<AdvertiserData> getAdvertiserDataById(@Param("advertiserId") String advertiserId);
+    AdvertiserData getAdvertiserDataById(@Param("advertiserId") Integer advertiserId);
 
     @Select("select minutes,sum(exposure) exposure,sum(click) click from advertiser_data_minutes t where advertiser_id={#advertiserId} and report_date<={#day} and report_date<={#day} group by minutes")
-    List<AdvertiserData> getAdvertExCl(@Param("advertiserId") String advertiserId,@Param("day") String day);
+    List<AdvertiserData> getAdvertExCl(@Param("advertiserId") Integer advertiserId,@Param("day") String day);
+
+    @Select("select minutes,sum(exposure) exposure,sum(click) click from advertiser_data_minutes t where advertiser_id={#advertiserId} and report_date<={#day} and report_date<={#day} and code_id={#codeId} group by minutes")
+    List<AdvertiserData> getAdvertExCl(@Param("advertiserId") Integer advertiserId,@Param("codeId") String codeId,@Param("day") String day);
+
+    @Select("select report_date reportDate,sum(exposure) exposure,sum(click) click from advertiser_data_minutes t where advertiser_id={#advertiserId} and report_date>={#startTime} and report_date<={#endTime} and code_id={#codeId} group by report_date")
+    List<AdvertiserData> getAdvertExClDays(@Param("advertiserId") Integer advertiserId,@Param("startTime") String startTime,@Param("endTime") String endTime);
+
+    @Select("select report_date reportDate,sum(exposure) exposure,sum(click) click from advertiser_data_minutes t where advertiser_id={#advertiserId} and report_date>={#startTime} and report_date<={#endTime} and code_id={#codeId} group by report_date")
+    List<AdvertiserData> getAdvertExClDays(@Param("advertiserId") Integer advertiserId,@Param("codeId") String codeId,@Param("startTime") String startTime,@Param("endTime") String endTime);
 }

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

@@ -7,8 +7,8 @@ public class AdvertiserData {
     public String codeId;
     public Double ecpm;
     public Double cpc;
-    public Long exposure;
-    public Long click;
+    public Integer exposure;
+    public Integer click;
     public Double income;
     public Double balance;
     public Double totalIncome;
@@ -122,19 +122,19 @@ public class AdvertiserData {
         this.cpc = cpc;
     }
 
-    public Long getExposure() {
+    public Integer getExposure() {
         return exposure;
     }
 
-    public void setExposure(Long exposure) {
+    public void setExposure(Integer exposure) {
         this.exposure = exposure;
     }
 
-    public Long getClick() {
+    public Integer getClick() {
         return click;
     }
 
-    public void setClick(Long click) {
+    public void setClick(Integer click) {
         this.click = click;
     }
 

src/main/java/com/boot/security/server/service/AdvertiserService.java

+package com.boot.security.server.service;
+
+import com.boot.security.server.model.AdvertiserData;
+import com.boot.security.server.page.table.PageTableRequest;
+
+import java.util.Map;
+
+public interface AdvertiserService {
+    /**
+     * 根据请求参数获取广告商信息、广告信息、数据概要信息、图标信息
+     *
+     */
+     Map<String,Object> getAdvertiserData(PageTableRequest request);
+}

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

+package com.boot.security.server.service.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.boot.security.server.dao.AdvertDao;
+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.UserUtil;
+import com.boot.security.server.utils.redis.JedisHelper;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import java.text.SimpleDateFormat;
+import java.util.*;
+import java.util.stream.Collectors;
+
+public class AdvertiserServiceImpl implements AdvertiserService {
+    @Autowired
+    private AdvertDao advertDao;
+
+    @Override
+    public JSONObject getAdvertiserData(PageTableRequest request) {
+        String today = new SimpleDateFormat("yyyy-MM-dd").format(new Date());
+        String startTime = request.getStartTime();
+        String endTime = request.getEndTime();
+        Integer advertiserId = request.getAdvertiserId();
+        String advertId = request.getAdvertId();
+        List<AdvertiserData> advertiser=new ArrayList<>();
+        List<AdvertiserData> advert=new ArrayList<>();
+        AdvertiserData schema=new AdvertiserData();
+        JSONObject jsonObject = new JSONObject();
+        jsonObject.put("advertiser",advertiser);
+        jsonObject.put("advert",advert);
+        jsonObject.put("schema",schema);
+        LoginUser loginUser = UserUtil.getLoginUser();
+
+        if(startTime.equals(endTime)&&startTime.equals(today)){
+            if(advertiserId==null&&advertId.equals("all")){
+                advertiser=advertDao.getAdvertiserByUserId(loginUser.getId());
+                advert=advertDao.getAdvertDataById(advertiser.get(0).getAdvertiserId());
+                schema=advertDao.getAdvertiserDataById(advertiser.get(0).getAdvertiserId());
+                JSONObject chartInfo = getRedisChartInfo(advertiser.get(0).getAdvertiserId(), advertId);
+                jsonObject.put("dataTime",chartInfo.get("dataTime"));
+                jsonObject.put("exposure",chartInfo.get("exposure"));
+                jsonObject.put("click",chartInfo.get("click"));
+            }else if(advertiserId!=null&&advertId!=null){
+                schema=advertDao.getAdvertiserDataById(advertiserId);
+                JSONObject chartInfo = getRedisChartInfo(advertiserId, advertId);
+                jsonObject.put("dataTime",chartInfo.get("dataTime"));
+                jsonObject.put("exposure",chartInfo.get("exposure"));
+                jsonObject.put("click",chartInfo.get("click"));
+            }
+        }else if(startTime.equals(endTime)&&!startTime.equals(today)){
+            if(advertiserId==null&&advertId.equals("all")){
+                advertiser=advertDao.getAdvertiserByUserId(loginUser.getId());
+                advert=advertDao.getAdvertDataById(advertiser.get(0).getAdvertiserId());
+                schema=advertDao.getAdvertiserDataById(advertiser.get(0).getAdvertiserId());
+                List<AdvertiserData> advertExCl = advertDao.getAdvertExCl(advertiser.get(0).getAdvertiserId(), startTime);
+                JSONObject mysqlChartInfo = getMysqlChartInfo(advertExCl);
+                jsonObject.put("dataTime",mysqlChartInfo.get("dataTime"));
+                jsonObject.put("exposure",mysqlChartInfo.get("exposure"));
+                jsonObject.put("click",mysqlChartInfo.get("click"));
+            }else if(advertiserId!=null&&advertId!=null){
+                schema=advertDao.getAdvertiserDataById(advertiserId);
+                List<AdvertiserData> advertExCl=null;
+                if(advertId.equals("all")){
+                    advertExCl = advertDao.getAdvertExCl(advertiserId, advertId,startTime);
+                }else {
+                    advertExCl = advertDao.getAdvertExCl(advertiserId,startTime);
+                }
+                JSONObject mysqlChartInfo = getMysqlChartInfo(advertExCl);
+                jsonObject.put("dataTime",mysqlChartInfo.get("dataTime"));
+                jsonObject.put("exposure",mysqlChartInfo.get("exposure"));
+                jsonObject.put("click",mysqlChartInfo.get("click"));
+            }
+        }else {
+            if(advertId.equals("all")){
+                schema=advertDao.getAdvertiserDataById(advertiserId);
+                List<AdvertiserData> advertExClDays = advertDao.getAdvertExClDays(advertiserId, startTime, endTime);
+                JSONObject mysqlChartInfo = getMysqlChartInfo(advertExClDays);
+                jsonObject.put("dataTime",mysqlChartInfo.get("dataTime"));
+                jsonObject.put("exposure",mysqlChartInfo.get("exposure"));
+                jsonObject.put("click",mysqlChartInfo.get("click"));
+            }else {
+                schema=advertDao.getAdvertiserDataById(advertiserId);
+                List<AdvertiserData> advertExClDays = advertDao.getAdvertExClDays(advertiserId, advertId,startTime, endTime);
+                JSONObject mysqlChartInfo = getMysqlChartInfo(advertExClDays);
+                jsonObject.put("dataTime",mysqlChartInfo.get("dataTime"));
+                jsonObject.put("exposure",mysqlChartInfo.get("exposure"));
+                jsonObject.put("click",mysqlChartInfo.get("click"));
+            }
+        }
+        return jsonObject;
+    }
+    private JSONObject getRedisChartInfo(Integer advertiserId,String advertId){
+        JSONObject jsonObject = new JSONObject();
+        String date = new SimpleDateFormat("yyyy-MM-dd").format(new Date());
+        String clickKey="redisAdvertDataDayClick:"+date+":"+advertiserId;
+        Map<String, Integer> clickMap = JedisHelper.hgetAll(Integer.class, clickKey);
+        List<String> minutesCodeIdClick = mapToList(clickMap);
+        String exposureKey="redisAdvertDataDayExposure:"+date+":"+advertiserId;
+        Map<String, Integer> exposureMap = JedisHelper.hgetAll(Integer.class, exposureKey);
+        List<String> minutesCodeIdExposure = mapToList(exposureMap);
+        if(advertId.equals("all")){
+            Map<String, List<String>> click = minutesCodeIdClick.stream().collect(Collectors.groupingBy(x -> x.split(",")[0]));
+            Map<String, List<String>> exposure = minutesCodeIdExposure.stream().collect(Collectors.groupingBy(x -> x.split(",")[0]));
+            JSONObject resultClick = sumByKey(click);
+            JSONObject resultExposure = sumByKey(exposure);
+            jsonObject.put("dataTime",resultClick.get("dataTime"));
+            jsonObject.put("click",resultClick.get("sum"));
+            jsonObject.put("exposure",resultExposure.get("sum"));
+        }else {
+            Map<String, List<String>> click = minutesCodeIdClick.stream().filter(x->x.split(",")[1].equals(advertId)).collect(Collectors.groupingBy(x -> x.split(",")[0]));
+            Map<String, List<String>> exposure = minutesCodeIdExposure.stream().filter(x->x.split(",")[1].equals(advertId)).collect(Collectors.groupingBy(x -> x.split(",")[0]));
+            JSONObject resultClick = sumByKey(click);
+            JSONObject resultExposure = sumByKey(exposure);
+            jsonObject.put("dataTime",resultClick.get("dataTime"));
+            jsonObject.put("click",resultClick.get("sum"));
+            jsonObject.put("exposure",resultExposure.get("sum"));
+        }
+        return jsonObject;
+    }
+
+    public static List mapToList(Map<String, Integer> map){
+        List<String> list=new ArrayList();
+        Iterator it=map.keySet().iterator();
+        while(it.hasNext()){
+            String key=it.next().toString();
+            Integer value = map.get(key);
+            list.add(key+","+value);
+        }
+        return list;
+    }
+
+    public static JSONObject sumByKey(Map<String, List<String>> map){
+        JSONObject jsonObject = new JSONObject();
+        List<String> dataTime=new ArrayList<>();
+        List<Integer> sum=new ArrayList<>();
+        Iterator it=map.keySet().iterator();
+        while(it.hasNext()){
+            String key=it.next().toString();
+            dataTime.add(key.split(",")[0]);
+            Integer count=0;
+            List<String> list = map.get(key);
+            for (String s : list) {
+                Integer i = Integer.valueOf(s.split(",")[2]);
+                count+=i;
+            }
+            sum.add(count);
+        }
+        jsonObject.put("dataTime",dataTime);
+        jsonObject.put("sum",sum);
+        return jsonObject;
+    }
+
+    public static JSONObject getMysqlChartInfo(List<AdvertiserData> advertExCl){
+        JSONObject jsonObject = new JSONObject();
+        List<String> dataTime=new ArrayList<>();
+        List<Integer> exposure=new ArrayList<>();
+        List<Integer> click=new ArrayList<>();
+        for (AdvertiserData advertiserData : advertExCl) {
+            if(advertiserData.getMinutes()!=null){
+                dataTime.add(advertiserData.getMinutes());
+            }else {
+                dataTime.add(advertiserData.getReportDate());
+            }
+            exposure.add(advertiserData.getExposure());
+            click.add(advertiserData.getClick());
+        }
+        jsonObject.put("dataTime",dataTime);
+        jsonObject.put("exposure",exposure);
+        jsonObject.put("click",click);
+        return jsonObject;
+    }
+}

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

@@ -48,7 +48,7 @@
             </div>
             <div class="" style="width: 160px;float: right">
                 <select name=""  style="" id="advert">
-                    <!--<option value="101">请选择一个广告id</option>-->
+                    <option value="all">全部</option>
                     <!--<option value="010">912</option>-->
                     <!--<option value="021">917</option>-->
                     <!--<option value="0571">967</option>-->