Commit 1a04eeea1549d23aa47fd5a0ff8a4e6e97d7dd6f

Authored by 潘钊
1 parent 9fe2d881

update...

src/main/java/com/bsth/data/msg_queue/DirectivePushQueue.java
@@ -108,15 +108,15 @@ public class DirectivePushQueue implements ApplicationContextAware { @@ -108,15 +108,15 @@ public class DirectivePushQueue implements ApplicationContextAware {
108 code = qd.getCode(); 108 code = qd.getCode();
109 109
110 if(code.equals("60_02")){ 110 if(code.equals("60_02")){
111 - //directiveService.send60Dispatch(qd.getSch(), qd.getFinish(), qd.getSender()); 111 + directiveService.send60Dispatch(qd.getSch(), qd.getFinish(), qd.getSender());
112 log.info("directive 60_02 sch id: " + qd.getSch().getId()); 112 log.info("directive 60_02 sch id: " + qd.getSch().getId());
113 } 113 }
114 else if(code.equals("60_03")){ 114 else if(code.equals("60_03")){
115 - //directiveService.send60Operation(qd.getNbbm(), qd.getState(), qd.getUpDown(), qd.getSender()); 115 + directiveService.send60Operation(qd.getNbbm(), qd.getState(), qd.getUpDown(), qd.getSender());
116 log.info("directive 60_03 nbbm: " + qd.getNbbm()); 116 log.info("directive 60_03 nbbm: " + qd.getNbbm());
117 } 117 }
118 else if(code.equals("64")){ 118 else if(code.equals("64")){
119 - //directiveService.lineChange(qd.getNbbm(), qd.getLineCode(), qd.getSender()); 119 + directiveService.lineChange(qd.getNbbm(), qd.getLineCode(), qd.getSender());
120 log.info("directive 64 nbbm: " + qd.getNbbm() + " lineCode: " + qd.getLineCode()); 120 log.info("directive 64 nbbm: " + qd.getNbbm() + " lineCode: " + qd.getLineCode());
121 } 121 }
122 122