mysql主从同步校验

@@ -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;
@@ -59,6 +60,41 @@ public class CenterSwitchCtrl {
     @RequestMapping("/switchMysqlCheckStatus")
     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;
+        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")){
+                    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;
+                }
+            }
+
+        }
         return baseResponse;
     }