Commit 502e67e9 authored by litengwei's avatar litengwei

省测卡片问题

parent f07b4320
...@@ -2065,7 +2065,7 @@ public class PlanTaskServiceImpl implements IPlanTaskService { ...@@ -2065,7 +2065,7 @@ public class PlanTaskServiceImpl implements IPlanTaskService {
for (Map<String, Object> map : statics for (Map<String, Object> map : statics
) { ) {
if(map.get("code").equals("xfxchgzb")) { if(map.get("code").equals("xfxchgzb")) {
map.put("value",String.valueOf((((double)hgdw / (double)xcdw)) *100)); map.put("value",String.format("%.2f", (((double)hgdw / (double)xcdw)) *100));
} }
} }
} }
...@@ -2080,7 +2080,7 @@ public class PlanTaskServiceImpl implements IPlanTaskService { ...@@ -2080,7 +2080,7 @@ public class PlanTaskServiceImpl implements IPlanTaskService {
for (Map<String, Object> map : statics for (Map<String, Object> map : statics
) { ) {
if(map.get("code").equals("xfxclcl")) { if(map.get("code").equals("xfxclcl")) {
map.put("value",String.valueOf((((double)lcdw / (double)zxcdw))*100) ); map.put("value", String.format("%.2f", (((double)lcdw / (double)zxcdw))*100) );
} }
} }
} }
......
...@@ -86,6 +86,7 @@ public class KafkaConsumerService { ...@@ -86,6 +86,7 @@ public class KafkaConsumerService {
*/ */
@KafkaListener(id = "provinceMessage", groupId = "province", topics = "#{'${kafka.topics}'.split(',')}", concurrency = "2") @KafkaListener(id = "provinceMessage", groupId = "province", topics = "#{'${kafka.topics}'.split(',')}", concurrency = "2")
public void consumerSingle1(String message, Acknowledgment ack) { public void consumerSingle1(String message, Acknowledgment ack) {
log.info("省级消息转发打印" + message);
if(isZxj) { if(isZxj) {
Optional<?> messages = Optional.ofNullable(message); Optional<?> messages = Optional.ofNullable(message);
if (messages.isPresent()) { if (messages.isPresent()) {
......
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