| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112 |
- from .DataStream import EMchPosmap
- import numpy as np
- import logging
- logger = logging.getLogger('calcer')
- def calc_chratios(data, pos_map, start, end):
- view = data[[pos_map.succ_count, pos_map.fail_count, pos_map.commit_count], :]
- view = view[:, start:end]
- all = np.cumsum(view, axis=1)
- succ = all[0, :]
- commit = all[0, :] + all[1, :]
- commit += 0.0000001
- y = succ / commit
- y = y.ravel()
- return int(all[0, -1]), int(all[0, -1] + all[1, -1]), y
- def calc_chspeed(data, pos_map, start, end):
- view = data[[pos_map.commit_count], :]
- view = view[:, start:end]
- speed = np.sum(view, axis=1)
- return int(speed[0])
- def calc_chratio(data, pos_map, start, end):
- view = data[[pos_map.succ_count, pos_map.fail_count, pos_map.succ_periods, pos_map.fail_periods, pos_map.commit_count], :]
- view = view[:, start:end]
- sums = np.sum(view, axis=1)
- succs = sums[0]
- fails = sums[1]
- succ_periods = sums[2]
- fail_periods = sums[3]
- commit_count = int(sums[4])
- all = int(succs + fails)
- ratio = succs / (all + 0.00001)
- back_time = (succ_periods + fail_periods) / (succs + fails + 0.00001)
- return round(ratio, 5), commit_count, round(back_time, 5)
- def calc_commit(data, pos_map, start, end):
- view = data[[pos_map.commit_count], :]
- view = view[:, start:end]
- sums = np.sum(view, axis=1)
- commit_count = int(sums[0])
- return commit_count
- def calc_mchratios(data, pos_map, start, end):
- view = data[[pos_map.succ_count, pos_map.fail_count, pos_map.submit_count], :]
- view = view[:, start:end]
- all = np.cumsum(view, axis=1)
- succ = all[0, :]
- commit = all[0, :] + all[1, :]
- commit += 0.0000001
- y = succ / commit
- y = y.ravel()
- return int(all[0, -1]), int(all[0, -1] + all[1, -1]), y
- def calc_morder_send(data, pos_map: type(EMchPosmap), start: int, end: int):
- view = data[:, start:end]
- sums = np.sum(view, axis=1)
- all_return = sums[pos_map.succ_mch_amounts] + sums[pos_map.fail_mch_amounts] + 0.0000001
- ratio = sums[pos_map.succ_mch_amounts] / all_return
- send_count = sums[pos_map.submit_count] - sums[pos_map.succ_count] - sums[pos_map.fail_count]
- send_amounts = sums[pos_map.submit_amounts] - sums[pos_map.succ_mch_amounts] - sums[pos_map.fail_mch_amounts]
- lack_amounts = send_amounts * ratio
- return send_count, sums[pos_map.submit_count], sums[pos_map.succ_count], sums[pos_map.fail_count], sums[pos_map.submit_amounts], \
- sums[pos_map.succ_mch_amounts], sums[pos_map.fail_mch_amounts], send_amounts, lack_amounts
- def calc_morder_lack(data, pos_map: type(EMchPosmap), start: int, end: int):
- view = data[:, start:end]
- sums = np.sum(view, axis=1)
- all_return = sums[pos_map.succ_count] + sums[pos_map.fail_count] + 0.0000001
- ratio = sums[pos_map.succ_count] / all_return
- send_count = sums[pos_map.submit_count] - sums[pos_map.succ_count] - sums[pos_map.fail_count]
- send_amounts = sums[pos_map.submit_amounts] - sums[pos_map.succ_mch_amounts] - sums[pos_map.fail_mch_amounts]
- lack_amounts = send_amounts * ratio
- logger.info("send_count=%d send_amounts=%.4f ratio=%.4f lack_amounts=%.4f", send_count, send_amounts, ratio, lack_amounts)
- return send_amounts, lack_amounts
- # 用于计算成功率及利润率
- # succ_count, fail_count, succ_ratio, profit,profit_ratio
- def calc_mch_profit(data, pos_map: type(EMchPosmap), start: int, end: int):
- view = data[:, start:end]
- sums = np.sum(view, axis=1)
- submit_count = sums[pos_map.submit_count]
- succ_count = sums[pos_map.succ_count]
- fail_count = sums[pos_map.fail_count]
- succ_ratio = succ_count / (succ_count + fail_count + 0.0000001)
- ch_amounts = sums[pos_map.succ_ch_amounts]
- mch_amounts = sums[pos_map.succ_mch_amounts]
- profit = mch_amounts - ch_amounts
- return int(submit_count), int(succ_count), int(fail_count), round(succ_ratio, 5), round(profit, 3)
|
