Topic: [OFFLINE]P2Pmining.com-Hybrid P2Pool-NO FEE!!!-BTC/NMC/IXC/I0C/DEV/LTC - page 26. (Read 56648 times)

SELECT DATE_FORMAT( FROM_UNIXTIME( t1.time ) ,  '%Y-%m-%d' ) 
DAY , UNIX_TIMESTAMP( DATE_FORMAT( FROM_UNIXTIME( t1.time ) ,  '%Y-%m-%d' ) ) TIMESTAMP, SUM( 
SHARE * amount ) btc
FROM 
(SELECT TIME, payouts.amount AS 
SHARE , pool_blocks.amount
FROM  `payouts` ,  `pool_blocks` , 
(SELECT MAX( TIME ) AS mtime
FROM pool_blocks)maxt
WHERE payouts.txid = pool_blocks.txid
AND pool_blocks.time > UNIX_TIMESTAMP( ) -60 *60 *24 *30
AND address =  '1KgFh9kWBpz4TsX92xcx78VQ2Fo1jP2Ddx'
AND NOT (
maxt.mtime > pool_blocks.time
AND pool_blocks.confirmations =1
)
)t1
GROUP BY DAY

                    if pow_hash > target:
                        print 'Worker %s submitted share with hash > target:' % (request.getUser(),)
                        print '    Hash:   %56x' % (pow_hash,)
                        print '    Target: %56x' % (target,)
                    elif header_hash in received_header_hashes:
                        print >>sys.stderr, 'Worker %s @ %s submitted share more than once!' % (request.getUser(), request.getClientIP())
                    else:
                        received_header_hashes.add(header_hash)
                        
                        #Enter Share to database
                        try:
                            dbf_user = request.getUser()
                            dbuser_items = dbf_user.split('+')
                            db_diff = bitcoin_data.target_to_difficulty(target) * 1000
                            proxy_db = MySQLdb.connect(host="localhost",user="mysqluser",passwd="mysqlpassword",db="p2pmining")
                            pdb_c = proxy_db.cursor()
                            pdb_c.execute("""INSERT INTO miner_data (id,address,hashrate,timestamp,difficulty,ontime) VALUES (NULL, %s , %s , UNIX_TIMESTAMP() , %s, %s)""", (dbuser_items[0], db_diff * on_time, db_diff , on_time ) )
                            proxy_db.close()
                        except:
                            log.err(None, 'Error with database:')
                        #End Enter Share Code
                        
                        pseudoshare_received.happened(bitcoin_data.target_to_average_attempts(target), not on_time, user)
                        self.recent_shares_ts_work.append((time.time(), bitcoin_data.target_to_average_attempts(target)))
                        while len(self.recent_shares_ts_work) > 50:
                            self.recent_shares_ts_work.pop(0)
                        local_rate_monitor.add_datum(dict(work=bitcoin_data.target_to_average_attempts(target), dead=not on_time, user=user))

def got_response(header, request):
                    assert header['merkle_root'] == merkle_root
                    
                    header_hash = bitcoin_data.hash256(bitcoin_data.block_header_type.pack(header))
                    pow_hash = net.PARENT.POW_FUNC(bitcoin_data.block_header_type.pack(header))
                    on_time = current_work.value['best_share_hash'] == share_info['share_data']['previous_share_hash']

import MySQLdb

                       #Enter Share to database
                        try:
                            dbf_user = request.getUser()
                            dbuser_items = dbf_user.split('+')
                            db_diff = bitcoin_data.target_to_difficulty(target) * 1000
                            proxy_db = MySQLdb.connect(host="localhost",user="mysqluser",passwd="mysqlpassword",db="p2pmining")
                            pdb_c = proxy_db.cursor()
                            pdb_c.execute("""INSERT INTO miner_data (id,address,hashrate,timestamp,difficulty,ontime) VALUES (NULL, %s , %s , UNIX_TIMESTAMP() , %s, %s)""", (dbuser_items[0], db_diff * on_time, db_diff , on_time ) )
                            proxy_db.close()
                        except:
                            log.err(None, 'Error with database:')
                        ###