Commit bbc60d56 authored by hanbing's avatar hanbing

[update] 修改绿波记录表结构

parent 960c5597
...@@ -702,7 +702,7 @@ public class MainlineEvaluateServiceImpl implements MainlineEvaluateService { ...@@ -702,7 +702,7 @@ public class MainlineEvaluateServiceImpl implements MainlineEvaluateService {
List<BaseCrossPlanPO> baseCrossPlanPOList = baseCrossPlanMapper.selectAll(); List<BaseCrossPlanPO> baseCrossPlanPOList = baseCrossPlanMapper.selectAll();
for (GreenwaveHistPO greenwaveHistPO : filteredList) { for (GreenwaveHistPO greenwaveHistPO : filteredList) {
Integer histGreenwaveId = greenwaveHistPO.getId(); Integer histGreenwaveId = greenwaveHistPO.getGreenId();
Date histGreenwaveGmtModified = greenwaveHistPO.getGmtModified(); Date histGreenwaveGmtModified = greenwaveHistPO.getGmtModified();
for (GreenwaveCrossPO greenwaveCrossPO : greenwaveCrossPOList) { for (GreenwaveCrossPO greenwaveCrossPO : greenwaveCrossPOList) {
...@@ -712,7 +712,7 @@ public class MainlineEvaluateServiceImpl implements MainlineEvaluateService { ...@@ -712,7 +712,7 @@ public class MainlineEvaluateServiceImpl implements MainlineEvaluateService {
histGreenwaveGmtModified, sectionId, baseCrossSectionPOList, baseCrossPlanPOList); histGreenwaveGmtModified, sectionId, baseCrossSectionPOList, baseCrossPlanPOList);
if (greenwaveInSectionDTO.isGreenwaveInSection()) { if (greenwaveInSectionDTO.isGreenwaveInSection()) {
String greenwaveName = greenwaveHistPO.getGreenwaveName(); String greenwaveName = greenwaveHistPO.getGreenwaveName();
Integer greenwaveId = greenwaveHistPO.getId(); Integer greenwaveId = greenwaveHistPO.getGreenId();
String planName = greenwaveInSectionDTO.getPlanName(); String planName = greenwaveInSectionDTO.getPlanName();
Integer planId = greenwaveInSectionDTO.getPlanId(); Integer planId = greenwaveInSectionDTO.getPlanId();
...@@ -1881,7 +1881,7 @@ public class MainlineEvaluateServiceImpl implements MainlineEvaluateService { ...@@ -1881,7 +1881,7 @@ public class MainlineEvaluateServiceImpl implements MainlineEvaluateService {
if (greenwaveHistPOList != null) { if (greenwaveHistPOList != null) {
for (GreenwaveHistPO greenwaveHistPO : greenwaveHistPOList) { for (GreenwaveHistPO greenwaveHistPO : greenwaveHistPOList) {
if (greenwaveHistPO != null && if (greenwaveHistPO != null &&
Objects.equals(greenwaveHistPO.getId(), greenwaveId) && Objects.equals(greenwaveHistPO.getGreenId(), greenwaveId) &&
Objects.equals(greenwaveHistPO.getGmtModified(), gmtModified)) { Objects.equals(greenwaveHistPO.getGmtModified(), gmtModified)) {
return key; return key;
} }
......
...@@ -40,7 +40,7 @@ ...@@ -40,7 +40,7 @@
</select> </select>
<select id="selectByTimeSection" resultType="net.wanji.databus.dao.entity.GreenwaveHistPO"> <select id="selectByTimeSection" resultType="net.wanji.databus.dao.entity.GreenwaveHistPO">
select t1.id, select t1.green_id,
t1.status, t1.status,
t1.type, t1.type,
t1.traffic_index, t1.traffic_index,
...@@ -69,7 +69,7 @@ ...@@ -69,7 +69,7 @@
select select
<include refid="Base_Column_List"/> <include refid="Base_Column_List"/>
from t_greenwave_hist from t_greenwave_hist
where id = #{greenwaveId} where green_id = #{greenwaveId}
and gmt_modified <![CDATA[ <= ]]> #{endTimeStr} and gmt_modified <![CDATA[ <= ]]> #{endTimeStr}
and gmt_modified <![CDATA[ >= ]]> #{startTimeStr} and gmt_modified <![CDATA[ >= ]]> #{startTimeStr}
</select> </select>
......
...@@ -32,7 +32,7 @@ ...@@ -32,7 +32,7 @@
select select
<include refid="Base_Column_List"/> <include refid="Base_Column_List"/>
from t_greenwave_realtime from t_greenwave_realtime
where id = #{id} where green_id = #{id}
</select> </select>
<insert id="insertBatch" parameterType="net.wanji.databus.dao.entity.GreenwaveRealtimePO"> <insert id="insertBatch" parameterType="net.wanji.databus.dao.entity.GreenwaveRealtimePO">
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment