rsyncd基本功能

plugins/rsyncd/index.html

@@ -6,7 +6,7 @@
 			<p onclick="pluginConfig('rsyncd');">配置修改</p>
 			<p onclick="rsyncdReceive();">接收配置</p>
 			<p onclick="pluginLogs('rsyncd','','run_log');">日志</p>
-			<!-- <p onclick="rsRead()">说明</p> -->
+			<p onclick="rsRead()">说明</p>
 		</div>
 		<div class="bt-w-con pd15">
 			<div class="soft-man-con"></div>

plugins/rsyncd/index.py

@@ -82,7 +82,6 @@ def getLog():
 
 
 def initConf():
-    import re
     conf_path = appConf()
     conf = public.readFile(conf_path)
     conf = re.sub('#*(.*)', '', conf)
@@ -105,6 +104,7 @@ def start():
 
 
 def stop():
+    initConf()
     if public.isAppleSystem():
         return "Apple Computer does not support"
     data = public.execShell('systemctl stop rsyncd.service')
@@ -114,6 +114,7 @@ def stop():
 
 
 def restart():
+    initConf()
     if public.isAppleSystem():
         return "Apple Computer does not support"
     data = public.execShell('systemctl restart rsyncd.service')
@@ -123,6 +124,7 @@ def restart():
 
 
 def reload():
+    initConf()
     if public.isAppleSystem():
         return "Apple Computer does not support"
 
@@ -161,6 +163,99 @@ def initdUinstall():
     return 'ok'
 
 
+def getRecListData():
+    path = appConf()
+    content = public.readFile(path)
+
+    flist = re.findall("\[(.*)\]", content)
+    flist_len = len(flist)
+    ret_list = []
+    for i in range(flist_len):
+        tmp = {}
+        tmp['name'] = flist[i]
+        n = i + 1
+        reg = ''
+        if n == flist_len:
+            reg = '\[' + flist[i] + '\](.*)\[?'
+        else:
+            reg = '\[' + flist[i] + '\](.*)\[' + flist[n] + '\]'
+
+        t1 = re.search(reg, content, re.S)
+        if t1:
+            args = t1.groups()[0]
+            # print 'args start', args, 'args_end'
+            t2 = re.findall('\s*(.*)\s*=\s*(.*)', args, re.M)
+            for i in range(len(t2)):
+                tmp[t2[i][0].strip()] = t2[i][1]
+        ret_list.append(tmp)
+    return ret_list
+
+
+def getRecList():
+    ret_list = getRecListData()
+    return public.returnJson(True, 'ok', ret_list)
+
+
+def addRec():
+    args = getArgs()
+
+    data = checkArgs(args, ['name', 'path', 'ps'])
+    if not data[0]:
+        return data[1]
+
+    args_name = args['name']
+    args_path = args['path']
+    args_ps = args['ps']
+
+    path = appConf()
+    content = public.readFile(path)
+
+    con = "\n\n" + '[' + args_name + ']' + "\n"
+    con += 'path = ' + args_path + "\n"
+    con += 'comment = ' + args_ps + "\n"
+    con += 'read only = false'
+
+    content = content + con
+    public.writeFile(path, content)
+    return public.returnJson(True, '添加成功')
+
+
+def delRec():
+    args = getArgs()
+
+    data = checkArgs(args, ['name'])
+    if not data[0]:
+        return data[1]
+
+    args_name = args['name']
+
+    path = appConf()
+    content = public.readFile(path)
+
+    ret_list = getRecListData()
+    ret_list_len = len(ret_list)
+    is_end = False
+    next_name = ''
+    for x in range(ret_list_len):
+        tmp = ret_list[x]
+        if tmp['name'] == args_name:
+            if x == ret_list_len:
+                is_end = True
+            else:
+                next_name = ret_list[x + 1]['name']
+
+    reg = ''
+    if is_end:
+        reg = '\[' + args_name + '\]\s*(.*)'
+    else:
+        reg = '\[' + args_name + '\]\s*(.*)\s*\[' + next_name + '\]'
+
+    conre = re.search(reg,  content, re.S)
+    content = content.replace("[" + args_name + "]\n" + conre.groups()[0], '')
+    public.writeFile(path, content)
+    return public.returnJson(True, '删除成功!')
+
+
 # rsyncdReceive
 if __name__ == "__main__":
     func = sys.argv[1]
@@ -184,5 +279,11 @@ if __name__ == "__main__":
         print appConf()
     elif func == 'run_log':
         print getLog()
+    elif func == 'rec_list':
+        print getRecList()
+    elif func == 'add_rec':
+        print addRec()
+    elif func == 'del_rec':
+        print delRec()
     else:
         print 'error'

plugins/rsyncd/js/rsyncd.js

@@ -1,8 +1,140 @@
+function str2Obj(str){
+    var data = {};
+    kv = str.split('&');
+    for(i in kv){
+        v = kv[i].split('=');
+        data[v[0]] = v[1];
+    }
+    return data;
+}
+
+function rsPost(method,args,callback, title){
+
+    var _args = null; 
+    if (typeof(args) == 'string'){
+        _args = JSON.stringify(str2Obj(args));
+    } else {
+        _args = JSON.stringify(args);
+    }
+
+    var _title = '正在获取...';
+    if (typeof(title) != 'undefined'){
+        _title = title;
+    }
+
+    var loadT = layer.msg(_title, { icon: 16, time: 0, shade: 0.3 });
+    $.post('/plugins/run', {name:'rsyncd', func:method, args:_args}, function(data) {
+        layer.close(loadT);
+        if (!data.status){
+            layer.msg(data.msg,{icon:0,time:2000,shade: [0.3, '#000']});
+            return;
+        }
+
+        if(typeof(callback) == 'function'){
+            callback(data);
+        }
+    },'json'); 
+}
+
+
+function rsyncdReceive(){
+	rsPost('rec_list', '', function(data){
+		var rdata = $.parseJSON(data.data);
+		if (!rdata.status){
+			layer.msg(rdata.msg,{icon:rdata.status?1:2,time:2000,shade: [0.3, '#000']});
+			return;
+		}
+		console.log(rdata);
+		var list = rdata.data;
+		var con = '';
+        con += '<div class="divtable" style="margin-top:5px;"><table class="table table-hover" width="100%" cellspacing="0" cellpadding="0" border="0">';
+        con += '<thead><tr>';
+        con += '<th>服务名</th>';
+        con += '<th>路径</th>';
+        con += '<th>备注</th>';
+        con += '<th>操作(<a class="btlink" onclick="addReceive()">添加</a>)</th>';
+        con += '</tr></thead>';
+
+        con += '<tbody>';
+
+        for (var i = 0; i < list.length; i++) {
+            con += '<tr>'+
+                '<td>' + list[i]['name']+'</td>' +
+                '<td>' + list[i]['path']+'</td>' +
+                '<td>' + list[i]['comment']+'</td>' +
+                '<td><a class="btlink" onclick="modUser(\''+list[i]['name']+'\')">改密</a>|<a class="btlink" onclick="delReceive(\''+list[i]['name']+'\')">删除</a></td></tr>';
+        }
+
+        con += '</tbody>';
+        con += '</table></div>';
+
+        $(".soft-man-con").html(con);
+	});
+}
+
+function addReceive(){
+    var loadOpen = layer.open({
+        type: 1,
+        title: '创建接收',
+        area: '400px',
+        content:"<div class='bt-form pd20 pb70 c6'>\
+            <div class='line'>\
+                <span class='tname'>项目名</span>\
+                <div class='info-r c4'>\
+                	<input id='name' class='bt-input-text' type='text' name='name' placeholder='项目名' style='width:200px' />\
+                </div>\
+            </div>\
+            <div class='line'>\
+                <span class='tname'>同步到</span>\
+                <div class='info-r c4'>\
+                	<input id='inputPath' class='bt-input-text' type='text' name='path' placeholder='/' style='width:200px' />\
+                	<span class='glyphicon glyphicon-folder-open cursor' onclick=\"changePath('inputPath')\"></span>\
+                </div>\
+            </div>\
+            <div class='line'>\
+                <span class='tname'>备注</span>\
+                <div class='info-r c4'>\
+                	<input id='ps' class='bt-input-text' type='text' name='ps' placeholder='备注' style='width:200px' />\
+                </div>\
+            </div>\
+            <div class='bt-form-submit-btn'>\
+                <button type='button' id='add_ok' class='btn btn-success btn-sm btn-title bi-btn'>确认</button>\
+            </div>\
+        </div>"
+    });
+
+    $('#add_ok').click(function(){
+        _data = {};
+        _data['name'] = $('#name').val();
+        _data['path'] = $('#inputPath').val();
+        _data['ps'] = $('#ps').val();
+        var loadT = layer.msg('正在获取...', { icon: 16, time: 0, shade: 0.3 });
+        rsPost('add_rec', _data, function(data){
+            var rdata = $.parseJSON(data.data);
+            layer.close(loadOpen);
+            layer.msg(rdata.msg,{icon:rdata.status?1:2,time:2000,shade: [0.3, '#000']});
+            setTimeout(function(){rsyncdReceive();},2000);
+        });
+    });
+}
+
+
+function delReceive(name){
+	safeMessage('删除['+name+']', '您真的要删除['+name+']吗？', function(){
+		var _data = {};
+		_data['name'] = name;
+		rsPost('del_rec', _data, function(data){
+            var rdata = $.parseJSON(data.data);
+            layer.msg(rdata.msg,{icon:rdata.status?1:2,time:2000,shade: [0.3, '#000']});
+            setTimeout(function(){rsyncdReceive();},2000);
+        });
+	});
+}
 
 
 function rsRead(){
 	var readme = '<ul class="help-info-text c7">';
-    readme += '<li></li>';    
+    readme += '<li>如需将其他服务器数据同步到本地服务器，请在接受配置中 "创建接受任务" </li>';
     readme += '</ul>';
 
     $('.soft-man-con').html(readme);