ceiling_break.py 文件源码

def break_ceil(self, code):
        print threading.current_thread().name
        while 1:
            #print code
            time.sleep(2)
            try:
                df = ts.get_realtime_quotes(code)
            except:
                time.sleep(5)
                continue
            v = long(df['b1_v'].values[0])

            if v <= 1000:
                print datetime.datetime.now().strftime("%H:%M:%S")
                print u"?????????"
                print self.bases[self.bases['code']==code]['name'].values[0]
                if self.send==True:
                    self.push_msg('break', 10, 10, 'down')
                #???????????????s