python实现多线程软件分发(局域网)

程序说明：
1、适用于局域网C类地址，如要适用CIDR，则需要改造程序；
2、多并发下发软件，但没有进行安装；
3、需要有远程PC的管理员帐号密码，比较适合域控环境；
4、比较适合企业IT管理员使用。

#-*- coding:cp936 -*-
#import sys
#reload(sys)
#sys.setdefaultencoding('utf8')


import subprocess
import threading
import os
print '开启软件分发程序'
print '-----------------------------------'
ipstart=raw_input('请键入你的起始IP地址 :')
ipend=raw_input('请键入你的结束IP地址 :')
user=raw_input('请输入客户端的管理员用户 :')
password=raw_input('请输入客户端管理员密码 :')
print '-----------------------------------'
print '\n'
ipstart='x.x.x.x'
ipend='x.x.xx'
user='xxx'
password='xxx'
ipstartlist=ipstart.split('.')
ipendlist=ipend.split('.')
a=ipstartlist[0]
b=ipstartlist[1]
c=ipstartlist[2]
start=int(ipstartlist[3])
end=int(ipendlist[3])
cmd="cmd.exe"
f=open(r'c:\cmd.txt','a')
h=1
n=1
#线程数
ep=(end-start+1)/n
remain=(end-start+1)%n

def deploy(start1,end1):
    global h
    while start1 <= end1:
        p=subprocess.Popen(cmd,shell=True,stdout=subprocess.PIPE,
                           stdin=subprocess.PIPE,
                           stderr=subprocess.PIPE)
        #ping 进程
        
        pp=subprocess.Popen(cmd,shell=True,stdout=subprocess.PIPE,
                            stdin=subprocess.PIPE,
                            stderr=subprocess.PIPE)
        #net use进程
        
        ppp=subprocess.Popen(cmd,shell=True,stdout=subprocess.PIPE,
                             stdin=subprocess.PIPE,
                             stderr=subprocess.PIPE)
        #copy进程
        
        ipk=a,b,c,str(start1)
        ip='.'.join(ipk)

        cmd1=r'net use \\%s\ipc$ "%s" /user:"%s"'%(ip,password,user)+"\n"
        cmd2=r'cmd /k xcopy /i /s /e /y D:\winxp\*.* \\"%s"\c$\winxp'%ip+"\n"
        p.stdin.write("ping %s"%ip+"\n")
    
        p.stdin.close()
        #pp.wait()
        print p.stdout.read()

        pout=p.communicate()[0]
        if pout.find('Reply from')>=0:
            print '(%s)&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&'%h
            print '* %s 客户端在线!!!'%ip
            pp.stdin.write(cmd1)
            
            pp.stdin.close()
            #p.wait()
            ppout=pp.stdout.read()
            if ppout[143:145]=='命':

                print "* 成功连接客户端: %s"%ip
                print '\n'
                f.write('%s %s 成功连接客户端'%(h,ip)+'\n')
                f.write('\n')
                ppp.stdin.write(cmd2)
                ppp.stdin.close()
                #ppp.wait()
                pppout=ppp.stdout.read()
                if pppout.find('11')==468:
                    f.write('%s %s 成功复制所有文件'%(h,ip)+'\n')
                    print "&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&"
                    print '\n'
                else:
                    print "文件复制失败"
                    f.write('%s 文件复制失败'%ip)
                    print "&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&"
                    print '\n'
            else:
                print "* 客户端：%s连接失败"%ip
                print '\n'
                f.write('%s %s 客户端连接失败'%(h,ip)+'\n')
                f.write('\n')

        else:
            print '\n\n'
            print '(%s)##################################################'%h
            print '* %s 客户端不在线'%ip
            print '####################################################'
            print '\n'
            f.write('%s %s 客户端不在线'%(h,ip)+'\n')
        start1=start1+1
        h=h+1

if __name__=='__main__':
    threads=[]
    if ep >=1:
        if remain == 0:
            for i in xrange(0,n):
                d=start+i*ep
                endd=start+ep*(i+1)-1
                threads.append(threading.Thread(None,target=deploy,args=(d,endd)))
        else:
            for i in xrange(0,n):
                d=start+i*ep
                endd=start+ep*(i+1)-1
                threads.append(threading.Thread(None,target=deploy,args=(d,endd)))
            threads.append(threading.Thread(None,target=deploy,args=(start+n*ep,end)))
    else:
        threading.Thread(None,target=deploy,args=(start,end))

    for t in threads:
        t.start()

    for t in threads:
        t.join()