路口优化记录修正-修改查询的表

signal-optimize-service/src/main/java/net/wanji/opt/dao/mapper/eventoptimize/TEventOptimizeInfoMapper.java

@@ -51,4 +51,11 @@ public interface TEventOptimizeInfoMapper extends BaseMapper<TEventOptimizeInfo>
                                                     @Param("startDuration") Integer startDuration,
                                                     @Param("endDuration") Integer endDuration
                                                     );
+
+    List<String> getCrossIdList(@Param("greenId") Integer greenId);
+
+    Page<TEventOptimizeInfo> selectPageWithCrossIds(@Param("page") Page<TEventOptimizeInfo> page,
+                                                    @Param("startTime") String startTime,
+                                                    @Param("endTime") String endTime,
+                                                    @Param("crossIds") List<String> crossIds);
 }
\ No newline at end of file

signal-optimize-service/src/main/java/net/wanji/opt/servicev2/eventoptimize/impl/TEventOptimizeInfoServiceImpl.java

 package net.wanji.opt.servicev2.eventoptimize.impl;
 
+import cn.hutool.core.util.ObjectUtil;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -38,19 +39,39 @@ public class TEventOptimizeInfoServiceImpl extends ServiceImpl<TEventOptimizeInf
 
     @Override
     public Page<TEventOptimizeInfoVO> selectPageWithCrossIdAndGreenId(int currentPage, int pageSize, String startTime, String endTime, String crossId, Integer greenId) {
-        Page<TEventOptimizeInfo> page = new Page<>(currentPage, pageSize);
-        Page<TEventOptimizeInfo> tEventOptimizeInfoPage = baseMapper.selectPageWithCrossIdAndGreenId(page, startTime, endTime, crossId, greenId);
-        List<TEventOptimizeInfoVO> collect = tEventOptimizeInfoPage.getRecords().stream().map(x -> {
-            TEventOptimizeInfoVO tEventOptimizeInfoVO = new TEventOptimizeInfoVO();
-            BeanUtils.copyProperties(x, tEventOptimizeInfoVO);
-            tEventOptimizeInfoVO.setEventLabal(getEventLabel(x.getEventType()));
-            return tEventOptimizeInfoVO;
-        }).collect(Collectors.toList());
-
-        Page<TEventOptimizeInfoVO> pageVO = new Page<>(currentPage, pageSize);
-        pageVO.setTotal(page.getTotal());
-        pageVO.setRecords(collect);
-        return pageVO;
+        if(ObjectUtil.isNotEmpty(greenId)){
+            List<String> crossIds = tEventOptimizeInfoMapper.getCrossIdList(greenId);
+            Page<TEventOptimizeInfo> page = new Page<>(currentPage, pageSize);
+            Page<TEventOptimizeInfo> tEventOptimizeInfoPage = baseMapper.selectPageWithCrossIds(page, startTime, endTime, crossIds);
+            List<TEventOptimizeInfoVO> collect = tEventOptimizeInfoPage.getRecords().stream().map(x -> {
+                TEventOptimizeInfoVO tEventOptimizeInfoVO = new TEventOptimizeInfoVO();
+                BeanUtils.copyProperties(x, tEventOptimizeInfoVO);
+                tEventOptimizeInfoVO.setEventLabal(getEventLabel1(x.getEventType()));
+                tEventOptimizeInfoVO.setOptStatus(1);
+                tEventOptimizeInfoVO.setGreenId(greenId);
+                return tEventOptimizeInfoVO;
+            }).collect(Collectors.toList());
+
+            Page<TEventOptimizeInfoVO> pageVO = new Page<>(currentPage, pageSize);
+            pageVO.setTotal(page.getTotal());
+            pageVO.setRecords(collect);
+            return pageVO;
+        }else {
+            Page<TEventOptimizeInfo> page = new Page<>(currentPage, pageSize);
+            Page<TEventOptimizeInfo> tEventOptimizeInfoPage = baseMapper.selectPageWithCrossIdAndGreenId(page, startTime, endTime, crossId, greenId);
+            List<TEventOptimizeInfoVO> collect = tEventOptimizeInfoPage.getRecords().stream().map(x -> {
+                TEventOptimizeInfoVO tEventOptimizeInfoVO = new TEventOptimizeInfoVO();
+                BeanUtils.copyProperties(x, tEventOptimizeInfoVO);
+                tEventOptimizeInfoVO.setEventLabal(getEventLabel1(x.getEventType()));
+                tEventOptimizeInfoVO.setOptStatus(1);
+                return tEventOptimizeInfoVO;
+            }).collect(Collectors.toList());
+
+            Page<TEventOptimizeInfoVO> pageVO = new Page<>(currentPage, pageSize);
+            pageVO.setTotal(page.getTotal());
+            pageVO.setRecords(collect);
+            return pageVO;
+        }
     }
 
     @Override
@@ -113,7 +134,19 @@ public class TEventOptimizeInfoServiceImpl extends ServiceImpl<TEventOptimizeInf
             return eventLabel;
         }
     }
-
+    // 获取事件名称（可以根据实际需求扩展）
+    private String getEventLabel1(String eventType) {
+        switch (eventType){
+            case "1":
+                return "绿灯空放";
+            case "2":
+                return "失衡";
+            case "3":
+                return "溢出";
+            default:
+                return "未知事件";
+        }
+    }
     // 新增干线接口用于带有条件的分页查询
     @Override
     public Page<TEventOptimizeInfo> pageWithLineConditions(int currentPage, int pageSize, String startTime, String endTime, Integer greenId, String eventType, Integer optStatus, Integer duration,Integer startOptDuration,Integer endOptDuration,Integer startDuration, Integer endDuration) {

signal-optimize-service/src/main/java/net/wanji/opt/servicev2/report/impl/GreenWaveWeekDataServiceImpl.java

 package net.wanji.opt.servicev2.report.impl;
 
+import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.StrUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
@@ -328,11 +329,14 @@ public class GreenWaveWeekDataServiceImpl extends ServiceImpl<GreenWaveWeekDataM
     public List<GreenReportSamePeriodCompareData>  getSamePeriodCompare(Integer year, Integer week, String ids) {
         Integer yearWeek = Integer.valueOf(year + "" + week);
         Integer yearWeekLast = Integer.valueOf(year + "" + (week-1));
-        List<Integer> greenIdList = Arrays.stream(ids.split(","))
-                .map(String::trim) // 去除可能的空格
-                .filter(s -> !s.isEmpty()) // 过滤掉空字符串
-                .map(Integer::parseInt) // 转换为整数
-                .collect(Collectors.toList());
+        List<Integer> greenIdList = new ArrayList<>();
+        if(ObjectUtil.isNotEmpty(ids)){
+            greenIdList = Arrays.stream(ids.split(","))
+                    .map(String::trim) // 去除可能的空格
+                    .filter(s -> !s.isEmpty()) // 过滤掉空字符串
+                    .map(Integer::parseInt) // 转换为整数
+                    .collect(Collectors.toList());
+        }
         List<GreenWaveWeekData> greenWaveWeekDatas = greenWaveWeekDataMapper.getDataByWeek(greenIdList,yearWeek);
         List<GreenWaveWeekData> greenWaveWeekDatasLast = greenWaveWeekDataMapper.getDataByWeek(greenIdList,yearWeek-1);
         List<GreenReportSamePeriodCompareData> result = new ArrayList<>();

signal-optimize-service/src/main/resources/mapper/eventoptimize/TEventOptimizeInfoMapper.xml

@@ -37,14 +37,34 @@
         ORDER BY happen_start_time desc
     </select>
    <select id="selectPageWithCrossIdAndGreenId" parameterType="map" resultType="net.wanji.opt.entity.eventoptimize.TEventOptimizeInfo">
-        SELECT *
-        FROM t_event_optimize_info
-        WHERE (#{startTime} IS NULL OR happen_start_time >= #{startTime})
-        AND (#{endTime} IS NULL OR happen_end_time &lt;= #{endTime})
-        AND (#{crossId} IS NULL OR cross_id = #{crossId})
-        AND (#{greenId} IS NULL OR green_id = #{greenId})
-        AND opt_status != 0
+       SELECT
+       cross_id,
+       current_algo AS event_type,
+       issue_time AS opt_start_time,
+       duration AS opt_duration,
+       DATE_ADD( issue_time, INTERVAL duration SECOND ) AS opt_end_time
+       FROM
+       t_strategy_cross_result
+       WHERE
+             1=1
+       <if test="startTime != null and endTime != null">
+           AND issue_time >= #{startTime}
+           AND issue_time &lt; #{endTime}
+       </if>
+       <if test="crossId != null" >
+           AND cross_id = #{crossId}
+       </if>
+       AND response_code = 200
     </select>
+<!--    <select id="selectPageWithCrossIdAndGreenId" parameterType="map" resultType="net.wanji.opt.entity.eventoptimize.TEventOptimizeInfo">-->
+<!--        SELECT *-->
+<!--        FROM t_event_optimize_info-->
+<!--        WHERE (#{startTime} IS NULL OR happen_start_time >= #{startTime})-->
+<!--        AND (#{endTime} IS NULL OR happen_end_time &lt;= #{endTime})-->
+<!--        AND (#{crossId} IS NULL OR cross_id = #{crossId})-->
+<!--        AND (#{greenId} IS NULL OR green_id = #{greenId})-->
+<!--        AND opt_status != 0-->
+<!--    </select>-->
 
     <select id="getCrossOptimizeDistribute" parameterType="map" resultType="java.util.Map">
         SELECT
@@ -123,4 +143,30 @@
         </if>
         ORDER BY happen_start_time desc
     </select>
+    <select id="getCrossIdList" resultType="java.lang.String">
+        select cross_id from t_greenwave_cross where green_id = #{greenId}
+    </select>
+    <select id="selectPageWithCrossIds" resultType="net.wanji.opt.entity.eventoptimize.TEventOptimizeInfo">
+        SELECT
+        cross_id,
+        current_algo AS event_type,
+        issue_time AS opt_start_time,
+        duration AS opt_duration,
+        DATE_ADD( issue_time, INTERVAL duration SECOND ) AS opt_end_time
+        FROM
+        t_strategy_cross_result
+        WHERE
+        1=1
+        <if test="startTime != null and endTime != null">
+            AND issue_time >= #{startTime}
+            AND issue_time &lt; #{endTime}
+        </if>
+        <if test="crossIds != null" >
+            AND cross_id in
+          <foreach collection="crossIds" item="crossId" open="(" close=")" separator=",">
+               #{crossId}
+          </foreach>
+        </if>
+        AND response_code = 200
+    </select>
 </mapper>
\ No newline at end of file