qcloudOnly：mysql主从同步校验

@@ -206,6 +206,7 @@ public class HttpUriContants {
     //双中心切换
     public static final String CENTERSWITCH_GET = "/centerSwitch/getSwitchList";
     public static final String CENTERSWITCH_SWITCH = "/centerSwitch/doExe";
+    public static final String CENTERSWITCH_SWITCH_CHECK_MYSQL_STATUS = "/centerSwitch/switchMysqlCheckStatus";
     public static final String CENTERSWITCH_SWITCH_CHECK = "/centerSwitch/doExeAndCheck";
     public static final String CENTERSWITCH_SWITCH_BEFORE = "/centerSwitch/doExeAndCheckBefore";
     public static final String CENTERSWITCH_SWITCH_SMS_CHECK = "/centerSwitch/checkSmsCode";

@@ -4,6 +4,7 @@ import com.ui.contants.HttpUriContants;
 import com.ui.http.HttpRestClient;
 import com.ui.model.BaseResponse;
 import com.ui.model.domain.CenterSwitchModel;
+import org.apache.commons.lang.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -56,6 +57,54 @@ public class CenterSwitchCtrl {
         return new ModelAndView("switch/new_center_switch");
     }
 
+    @RequestMapping("/switchMysqlCheckStatus")
+    @ResponseBody
+    public BaseResponse switchMysqlCheckStatus(){
+        BaseResponse baseResponse =  httpClient.defaultPost(HttpUriContants.CENTERSWITCH_SWITCH_CHECK_MYSQL_STATUS, null, BaseResponse.class);
+        String checkStatus=(String)baseResponse.getData();
+        String desc[]=checkStatus.split("</br>");
+        int count=0;
+        int dbnums=0;
+        for(String str:desc){
+            if(StringUtils.isBlank(str)||str.indexOf("begin")>=0||str.indexOf("end")>=0){
+                continue;
+            }
+            log.error("mysqlstatus==="+str);
+            if(count==0){
+                if(str.startsWith("172")||str.startsWith("10")){
+                    dbnums++;
+                    count++;
+                }else{
+                    baseResponse.setCode(201);
+                    baseResponse.setMessage("db状态校验不通过");
+                    break;
+                }
+            }else if(count==1||count==2){
+                if(str.equalsIgnoreCase("yes")){
+                    count++;
+                }else{
+                    baseResponse.setCode(202);
+                    baseResponse.setMessage("db状态校验不通过");
+                    break;
+                }
+            }else if(count==3){
+                if(str.equalsIgnoreCase("0")){
+                    count=0;
+                }else{
+                    baseResponse.setCode(203);
+                    baseResponse.setMessage("db状态校验不通过");
+                    break;
+                }
+            }
+
+        }
+        if(dbnums<=0){
+            baseResponse.setCode(204);
+            baseResponse.setMessage("db状态校验不通过,dbnum is 0");
+        }
+        return baseResponse;
+    }
+
     @RequestMapping("/doExeAndCheck")
     public BaseResponse doExeAndCheck(CenterSwitchModel centerSwitchModel){
         BaseResponse baseResponse =  httpClient.defaultPost(HttpUriContants.CENTERSWITCH_SWITCH_CHECK, centerSwitchModel, BaseResponse.class);