| | |
|---|
| | | |
|---|
| | | # 保存数据,返回保存数据的条数 |
|---|
| | | def save(self, code, limit_up_price, buy_1_price, buy_1_time, queues): |
|---|
| | | # 如果买1不为涨停价就不需要保存 |
|---|
| | | if queues == self.last_buy_queue_data.get(code): |
|---|
| | | # 2个以上的数据才有处理价值 |
|---|
| | | if not queues or len(queues) < 2: |
|---|
| | | return None |
|---|
| | | # 如果买1不为涨停价就不需要保存 |
|---|
| | | old_queues = self.last_buy_queue_data.get(code) |
|---|
| | | if old_queues and len(old_queues) == len(queues): |
|---|
| | | # 元素相同就不需要再次处理 |
|---|
| | | old_str = ",".join([str(k) for k in old_queues[1:]]) |
|---|
| | | new_str = ",".join([str(k) for k in queues[1:]]) |
|---|
| | | if old_str == new_str: |
|---|
| | | return None |
|---|
| | | self.last_buy_queue_data[code] = queues |
|---|
| | | |
|---|
| | | if abs(float(buy_1_price) - float(limit_up_price)) >= 0.01: |
|---|
| | | # 保存最近的涨停起始时间 |
|---|
| | | self.__save_latest_not_limit_up_time(code, buy_1_time) |
|---|
| | | return None |
|---|
| | | |
|---|
| | | self.last_buy_queue_data[code] = queues |
|---|
| | | min_num = round(constant.L2_MIN_MONEY / (limit_up_price * 100)) |
|---|
| | | num_list = [] |
|---|
| | | # 忽略第一条数据 |
|---|
| | |
|---|
| | | today_num_operate_map = l2.l2_data_util.local_today_num_operate_map.get(code) |
|---|
| | | index = None |
|---|
| | | if True: |
|---|
| | | buyQueueBigTemp = buyQueueBig |
|---|
| | | # 最多5个数据 |
|---|
| | | buyQueueBigTemp = buyQueueBig[:5] |
|---|
| | | last_index, is_default = self.get_traded_index(code) |
|---|
| | | c_last_index = 0 |
|---|
| | | if not is_default and last_index is not None: |
|---|
| | |
|---|
| | | self.__save_buy_progress_index(code, index, False) |
|---|
| | | |
|---|
| | | |
|---|
| | | if __name__ == '__main': |
|---|
| | | pass |
|---|
| | | if __name__ == '__main__': |
|---|
| | | a = [1, 2, 3, 4] |
|---|
| | | results = [str(k) for k in a] |
|---|
| | | b = [1, 2, 3] |
|---|
| | | result = (",".join([str(k) for k in a]) == ",".join([str(k) for k in b])) |
|---|
| | | print(result) |
|---|
