Commit 4a162f66d3238e76137801bf124a0116525c5f22

Authored by 娄高锋
2 parents 2f962e3b 158804f2

Merge branch 'pudong_jdk8' of http://101.95.0.106:8888/panzhaov5/bsth_control into pudong_jdk8

src/main/java/com/bsth/service/realcontrol/impl/ScheduleRealInfoServiceImpl.java
@@ -32,6 +32,7 @@ import java.util.regex.Pattern; @@ -32,6 +32,7 @@ import java.util.regex.Pattern;
32 import org.apache.commons.io.IOUtils; 32 import org.apache.commons.io.IOUtils;
33 import org.apache.commons.lang3.StringEscapeUtils; 33 import org.apache.commons.lang3.StringEscapeUtils;
34 import org.apache.commons.lang3.StringUtils; 34 import org.apache.commons.lang3.StringUtils;
  35 +import org.joda.time.DateTime;
35 import org.joda.time.format.DateTimeFormat; 36 import org.joda.time.format.DateTimeFormat;
36 import org.joda.time.format.DateTimeFormatter; 37 import org.joda.time.format.DateTimeFormatter;
37 import org.slf4j.Logger; 38 import org.slf4j.Logger;
@@ -621,7 +622,15 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl<ScheduleRealInf @@ -621,7 +622,15 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl<ScheduleRealInf
621 public Map<String, Object> addToHistory(ScheduleRealInfo t) { 622 public Map<String, Object> addToHistory(ScheduleRealInfo t) {
622 Map<String, Object> rs = new HashMap<>(); 623 Map<String, Object> rs = new HashMap<>();
623 try { 624 try {
  625 + // 检查调度日期
  626 + DateTimeFormatter formatter = DateTimeFormat.forPattern("yyyy-MM-dd");
  627 + long today = formatter.parseMillis(new DateTime().toString("yyyy-MM-dd")), scheduleDate = formatter.parseMillis(t.getScheduleDateStr());
624 String clZbh = t.getClZbh(), lpName = t.getLpName(); 628 String clZbh = t.getClZbh(), lpName = t.getLpName();
  629 + if (today < scheduleDate || today - scheduleDate > 172800000) {
  630 + rs.put("status", ResponseCode.ERROR);
  631 + rs.put("msg", "无效的调度日期");
  632 + return rs;
  633 + }
625 if (StringUtils.isEmpty(lpName) || StringUtils.isEmpty(lpName.trim())) { 634 if (StringUtils.isEmpty(lpName) || StringUtils.isEmpty(lpName.trim())) {
626 rs.put("status", ResponseCode.ERROR); 635 rs.put("status", ResponseCode.ERROR);
627 rs.put("msg", "路牌信息缺失"); 636 rs.put("msg", "路牌信息缺失");
@@ -4667,6 +4676,14 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl&lt;ScheduleRealInf @@ -4667,6 +4676,14 @@ public class ScheduleRealInfoServiceImpl extends BaseServiceImpl&lt;ScheduleRealInf
4667 rs.put("status", ResponseCode.ERROR); 4676 rs.put("status", ResponseCode.ERROR);
4668 4677
4669 ScheduleRealInfo oldSch = super.findById(sch.getId()); 4678 ScheduleRealInfo oldSch = super.findById(sch.getId());
  4679 + // 检查调度日期
  4680 + DateTimeFormatter formatter = DateTimeFormat.forPattern("yyyy-MM-dd");
  4681 + long today = formatter.parseMillis(new DateTime().toString("yyyy-MM-dd")), scheduleDate = formatter.parseMillis(sch.getScheduleDateStr());
  4682 + if (today < scheduleDate || today - scheduleDate > 172800000) {
  4683 + rs.put("status", ResponseCode.ERROR);
  4684 + rs.put("msg", "无效的调度日期");
  4685 + return rs;
  4686 + }
4670 //事后日志记录 4687 //事后日志记录
4671 AfterwardsLogger aflog = AfterwardsLogger.start(oldSch, "事后调整"); 4688 AfterwardsLogger aflog = AfterwardsLogger.start(oldSch, "事后调整");
4672 4689
src/main/resources/application-test.properties
@@ -32,7 +32,7 @@ spring.datasource.hikari.register-mbeans=true @@ -32,7 +32,7 @@ spring.datasource.hikari.register-mbeans=true
32 32
33 kafka.use= true 33 kafka.use= true
34 spring.kafka.consumer.bootstrap-servers= 192.170.100.114:9092,192.170.100.114:9093,192.170.100.114:9094 34 spring.kafka.consumer.bootstrap-servers= 192.170.100.114:9092,192.170.100.114:9093,192.170.100.114:9094
35 -spring.kafka.consumer.group-id= schedule-system 35 +spring.kafka.consumer.group-id= schedule-system-test
36 spring.kafka.consumer.auto-offset-reset= latest 36 spring.kafka.consumer.auto-offset-reset= latest
37 spring.kafka.consumer.key-deserializer= org.apache.kafka.common.serialization.StringDeserializer 37 spring.kafka.consumer.key-deserializer= org.apache.kafka.common.serialization.StringDeserializer
38 spring.kafka.consumer.value-deserializer= org.apache.kafka.common.serialization.StringDeserializer 38 spring.kafka.consumer.value-deserializer= org.apache.kafka.common.serialization.StringDeserializer
src/main/resources/static/pages/home.html
@@ -59,14 +59,11 @@ @@ -59,14 +59,11 @@
59 } 59 }
60 </style> 60 </style>
61 <div class="system_change_log"> 61 <div class="system_change_log">
62 - <h2 style="text-indent: 35px;margin: 10px 0 5px;">2023-08-06 更新说明 Changelog</h2> 62 + <h2 style="text-indent: 35px;margin: 10px 0 5px;">2023-09-16 更新说明 Changelog</h2>
63 <br><br> 63 <br><br>
64 <ul> 64 <ul>
65 - <li class="sub_title"><h6>线调</h6></li>  
66 - <li><span class="label s_c_change">新增</span>1.线调增加企业信息化运行监控中心推送的异常停车信息</li>  
67 - <li><span class="label s_c_change">新增</span>2.线调模拟图、地图增加车辆的实时电量信息显示</li>  
68 - <li class="sub_title"><h6>系统安全</h6></li>  
69 - <li><span class="label s_c_change">新增</span>1.启用统一门户集群调度的单点登录功能,原登录页面暂时沿用</li> 65 + <li class="sub_title"><h6>线调、油电管理</h6></li>
  66 + <li><span class="label s_c_change">修改</span>1.历史路单维护、进出场存油(恒定)、进出场存电(恒定)的编辑限制统一为T+2(以今日为锚点,可以编辑今日、昨日、前日的数据)</li>
70 </ul> 67 </ul>
71 68
72 </div> 69 </div>