新增每天00:15:00执行统计路口及干线问题统计定时任务

signal-optimize-service/src/main/java/net/wanji/opt/dao/mapper/judgeanalysis/AnalysisProblemCrossDayMapper.java

@@ -73,6 +73,18 @@ public interface AnalysisProblemCrossDayMapper extends BaseMapper<AnalysisProble
 	 *  @param
 	 */
 	List<CrossPoint> findAreaPoint();
+
+	/**
+	 *  查询表t_base_area_info信息
+	 *  @param
+	 */
+	List<AnalysisProblemCrossDay> checkData();
+
+	/**
+	 *  新增表t_analysis_problem_cross_day信息
+	 *  @param
+	 */
+	Integer insertAnalysisProblemCrossDay();
 	
 }
 

signal-optimize-service/src/main/java/net/wanji/opt/dao/mapper/judgeanalysis/AnalysisProblemGreenDayMapper.java

@@ -41,6 +41,19 @@ public interface AnalysisProblemGreenDayMapper extends BaseMapper<AnalysisProble
 	  *  @param analysisProblemGreenDay
 	  */
 	 Integer addAnalysisProblemGreenDay(AnalysisProblemGreenDay analysisProblemGreenDay);
+
+	/**
+	 *  新增表t_analysis_problem_green_day信息
+	 *  @param
+	 */
+	Integer insertAnalysisProblemGreenDay();
+
+	/**
+	 *  根据条件查询表t_analysis_problem_green_day信息
+	 *  @param 
+	 */
+	List<AnalysisProblemGreenDay> checkData();
+
 	
 }
 

signal-optimize-service/src/main/java/net/wanji/opt/task/AnalysisProblemDayTask.java

+package net.wanji.opt.task;
+
+import lombok.extern.slf4j.Slf4j;
+import net.wanji.opt.dao.mapper.judgeanalysis.AnalysisProblemCrossDayMapper;
+import net.wanji.opt.dao.mapper.judgeanalysis.AnalysisProblemGreenDayMapper;
+import net.wanji.opt.entity.judgeanalysis.AnalysisProblemCrossDay;
+import net.wanji.opt.entity.judgeanalysis.AnalysisProblemGreenDay;
+import net.wanji.opt.servicev2.judgeanalysis.impl.AnalysisProblemCrossDayServiceImpl;
+import net.wanji.opt.servicev2.judgeanalysis.impl.AnalysisProblemGreenDayServiceImpl;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Configurable;
+import org.springframework.context.annotation.Profile;
+import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.PostConstruct;
+import java.util.List;
+
+@Component
+@Configurable
+@EnableScheduling
+@Slf4j
+@Profile("!dev")
+public class AnalysisProblemDayTask {
+    @Autowired
+    private AnalysisProblemCrossDayServiceImpl analysisProblemCrossDayServiceImpl;
+    @Autowired
+    private AnalysisProblemCrossDayMapper analysisProblemCrossDayMapper;
+    @Autowired
+    private AnalysisProblemGreenDayMapper analysisProblemGreenDayMapper;
+    @Autowired
+    private AnalysisProblemGreenDayServiceImpl nalysisProblemGreenDayServiceImpl;
+
+    @Scheduled(cron = "0 15 0 ? * *")
+    @PostConstruct
+    public  void task(){
+        //执行检查路口id是否还有area_id没赋值的数据
+        analysisProblemCrossDayServiceImpl.updateCrossAreaIdByCondition();
+        //执行检查绿波id是否还有area_id没赋值的数据
+        nalysisProblemGreenDayServiceImpl.updateGreenAreaIdByCondition();
+        //检查昨日数据是否有统计
+        List<AnalysisProblemCrossDay> list = analysisProblemCrossDayMapper.checkData();
+        if(list.isEmpty())
+        {
+            analysisProblemCrossDayMapper.insertAnalysisProblemCrossDay();
+        }
+        //检查昨日数据是否有统计
+        List<AnalysisProblemGreenDay> list1 = analysisProblemGreenDayMapper.checkData();
+        if(list1.isEmpty())
+        {
+            analysisProblemGreenDayMapper.insertAnalysisProblemGreenDay();
+        }
+    }
+}

signal-optimize-service/src/main/resources/mapper/judgeanalysis/AnalysisProblemCrossDayMapper.xml

@@ -201,4 +201,22 @@
             id=#{id}
     </update>
 
+    <!-- 新增表t_analysis_problem_cross_day信息 -->
+    <insert id="insertAnalysisProblemCrossDay">
+        insert into  t_analysis_problem_cross_day (id,green_id,area_id,event_category,event_type,event_number,event_total_time,dt,insert_time)
+        select UUID(), a.cross_id, b.area_id,a.category,a.type,count(1) as event_number , sum( TIMESTAMPDIFF(SECOND, a.start_time , a.end_time) ) as duration ,
+               DATE_FORMAT(DATE_SUB(now(),INTERVAL 1 DAY),'%Y%m%d') as dt , now()
+        from t_event_info a
+                 left join t_base_cross_info b on a.cross_id = b.id
+        where DATE_FORMAT(a.start_time,'%Y-%m-%d')  = DATE_FORMAT(DATE_SUB(now(),INTERVAL 1 DAY),'%Y-%m-%d') and a.type in (701,702,703)
+        group by a.cross_id, b.area_id,a.category,a.type
+    </insert>
+
+    <!-- 根据条件查询表t_analysis_problem_cross_day信息 -->
+    <select id="checkData" resultMap="AnalysisProblemCrossDayMap">
+        SELECT dt
+        FROM t_analysis_problem_cross_day
+        WHERE dt = DATE_FORMAT(DATE_SUB(now(),INTERVAL 1 DAY),'%Y%m%d')
+    </select>
+
 </mapper>

signal-optimize-service/src/main/resources/mapper/judgeanalysis/AnalysisProblemGreenDayMapper.xml

@@ -163,4 +163,23 @@
             ,#{insertTime}
         )
     </insert>
+
+    <!-- 新增表t_analysis_problem_green_day信息 -->
+    <insert id="insertAnalysisProblemGreenDay">
+        insert into  t_analysis_problem_green_day (id,cross_id,area_id,event_category,event_type,event_number,event_total_time,dt,insert_time)
+        select UUID(), a.green_id, b.area_id,a.category,a.type,count(1) as event_number , sum( TIMESTAMPDIFF(SECOND, a.start_time , a.end_time) ) as duration ,
+               DATE_FORMAT(DATE_SUB(now(),INTERVAL 1 DAY),'%Y%m%d') as dt , now()
+        from t_event_info a
+                 left join t_greenwave_info b on a.green_id = b.id
+        where DATE_FORMAT(a.start_time,'%Y-%m-%d')  = DATE_FORMAT(DATE_SUB(now(),INTERVAL 1 DAY),'%Y-%m-%d') and a.type in (705,706,707) and a.green_id != ''
+        group by a.cross_id, b.area_id,a.category,a.type
+    </insert>
+
+    <!-- 根据条件查询表t_analysis_problem_green_day信息 -->
+    <select id="checkData" resultMap="AnalysisProblemGreenDayMap">
+        SELECT dt
+        FROM t_analysis_problem_green_day
+        WHERE dt = DATE_FORMAT(DATE_SUB(now(),INTERVAL 1 DAY),'%Y%m%d')
+    </select>
+
 </mapper>