短信添加开关

@@ -41,4 +41,18 @@ public class OpsSmsOnOffController {
     public BaseResponse getVoiceSmsSwitchValue(){
         return smsLogService.getVoiceSmsSwitchValue();
     }
+
+
+    /// 短信开发:dev.yohops.com
+    @RequestMapping("/turnDev")
+    @ResponseBody
+    public BaseResponse turnDev(String key){
+        return smsLogService.setDevSmsTurnOnOff(key);
+    }
+
+    @RequestMapping("/getDevSmsSwitchValue")
+    @ResponseBody
+    public BaseResponse getDevSmsSwitchValue(){
+        return smsLogService.getDevSmsSwitchValue();
+    }
 }

@@ -18,4 +18,7 @@ public interface SmsLogService {
 
     BaseResponse setVoiceSmsTurnOnOff(String key);
     BaseResponse getVoiceSmsSwitchValue();
+
+    BaseResponse setDevSmsTurnOnOff(String key);
+    BaseResponse getDevSmsSwitchValue();
 }

@@ -33,74 +33,72 @@ public class SmsLogServiceImpl implements SmsLogService {
     private String ZK_PATH = "/yh/config/";
     private String smsSendSwitch="ops.sendsms.open";
     private String smsSendVoiceSwitch="ops.sendvoicesms.open";
-
+    private String dev_smsSendSwitch="devops.sendsms.open";
     @Override
     public BaseResponse setSmsTurnOnOff(String key){
-        BaseResponse res=null;
-        try{
-            String value="true";
-            if("off".equals(key)){
-                value="false";
-            }
-            Stat stat=zkClient.getCuratorFramework().checkExists().forPath(ZK_PATH + smsSendSwitch);
-            // Stat 就是对zonde所有属性的一个映射， stat=null表示节点不存在！
-            if(stat==null){
-                zkClient.getCuratorFramework().create().forPath(ZK_PATH + smsSendSwitch);
-            }
-            zkClient.getCuratorFramework().setData().forPath(ZK_PATH + smsSendSwitch,value.getBytes("UTF-8"));
-            res= new BaseResponse(200,"sms send is "+value);
-        } catch (Exception e) {
-            logger.error("set ZK_PATH smsSendSwitch error",e);
-            res=new BaseResponse("set zk data error");
-        }
-        return res;
+        return setTurnOnOff(smsSendSwitch,key);
     }
-
     @Override
     public BaseResponse getSmsSwitchValue(){
-        return getSwitchValue(smsSendVoiceSwitch);
+        return getSwitchValue(smsSendSwitch);
     }
 
+
     @Override
     public BaseResponse setVoiceSmsTurnOnOff(String key){
+        return setTurnOnOff(smsSendVoiceSwitch,key);
+    }
+    @Override
+    public BaseResponse getVoiceSmsSwitchValue(){
+        return getSwitchValue(smsSendVoiceSwitch);
+    }
+
+    @Override
+    public BaseResponse setDevSmsTurnOnOff(String key){
+        return setTurnOnOff(dev_smsSendSwitch,key);
+    }
+
+    @Override
+    public BaseResponse getDevSmsSwitchValue(){
+        return getSwitchValue(dev_smsSendSwitch);
+    }
+
+    private BaseResponse setTurnOnOff(String pathCode,String key){
         BaseResponse res=null;
         try{
             String value="true";
             if("off".equals(key)){
                 value="false";
             }
-            Stat stat=zkClient.getCuratorFramework().checkExists().forPath(ZK_PATH + smsSendVoiceSwitch);
+            Stat stat=zkClient.getCuratorFramework().checkExists().forPath(ZK_PATH + pathCode);
             // Stat 就是对zonde所有属性的一个映射， stat=null表示节点不存在！
             if(stat==null){
-                zkClient.getCuratorFramework().create().forPath(ZK_PATH + smsSendVoiceSwitch);
+                zkClient.getCuratorFramework().create().forPath(ZK_PATH + pathCode);
             }
-            zkClient.getCuratorFramework().setData().forPath(ZK_PATH + smsSendVoiceSwitch,value.getBytes("UTF-8"));
-            res= new BaseResponse(200,"sms voice send is "+value);
+            zkClient.getCuratorFramework().setData().forPath(ZK_PATH + pathCode,value.getBytes("UTF-8"));
+            res= new BaseResponse(200,pathCode+" is "+value);
         } catch (Exception e) {
-            logger.error("set ZK_PATH smsVoiceSendSwitch error",e);
-            res=new BaseResponse("set zk data error");
+            logger.error("set ZK_PATH "+pathCode+" error",e);
+            res=new BaseResponse("set zk data error:"+pathCode);
         }
         return res;
     }
 
-    @Override
-    public BaseResponse getVoiceSmsSwitchValue(){
-        return getSwitchValue(smsSendVoiceSwitch);
-    }
 
-    private BaseResponse getSwitchValue(String key){
+
+    private BaseResponse getSwitchValue(String pathCode){
         BaseResponse res=null;
         try{
             String value="";
-            Stat stat=zkClient.getCuratorFramework().checkExists().forPath(ZK_PATH + key);
+            Stat stat=zkClient.getCuratorFramework().checkExists().forPath(ZK_PATH + pathCode);
             // Stat 就是对zonde所有属性的一个映射， stat=null表示节点不存在！
             if(stat!=null){
-                value = new String(zkClient.getCuratorFramework().getData().forPath(ZK_PATH + key));
+                value = new String(zkClient.getCuratorFramework().getData().forPath(ZK_PATH + pathCode));
             }
             res= new BaseResponse(200,value);
         } catch (Exception e) {
-            logger.error("get ZK_PATH "+key+" error",e);
-            res=new BaseResponse("get zk data error "+key);
+            logger.error("get ZK_PATH "+pathCode+" error",e);
+            res=new BaseResponse("get zk data error "+pathCode);
         }
         return res;
     }