卖出规则制定

Administrator

2023-11-23 2df06f818c76bde7d741a72edd45edd7aaf0ce45

 trade/sell_rule_manager.py

@@ -7,7 +7,8 @@


class SellRule:
    def __init__(self, id_=None, code=None, buy1_volume=None, sell_volume=None, day=None, create_time=None, excuted=0):
    def __init__(self, id_=None, code=None, buy1_volume=None, sell_volume=None, day=None, create_time=None, excuted=0,
                 end_time=None):
        self.day = day
        self.create_time = create_time
        self.sell_volume = sell_volume
@@ -15,6 +16,7 @@
        self.code = code
        self.id_ = id_
        self.excuted = 0
        self.end_time = end_time

    def to_json_str(self):
        return json.dumps(vars(self))
@@ -48,8 +50,8 @@
        for rule in rules:
            self.__sell_rules_dict_cache[rule.id_] = rule

    def __list_rules(self):
        results = mysql_data.Mysqldb().select_all(f"select * from sell_rules r where r.day='{tool.get_now_date_str()}'")
    def list_rules(self, day=tool.get_now_date_str()):
        results = mysql_data.Mysqldb().select_all(f"select * from sell_rules r where r.day='{day}'")
        fresults = []
        if results:
            for r in results:
@@ -61,6 +63,7 @@
                rule.day = r[4]
                rule.create_time = r[5]
                rule.excuted = r[6]
                rule.end_time = r[7]
                fresults.append(rule)
        return fresults

@@ -72,8 +75,8 @@
        if not rule.day:
            rule.day = tool.get_now_date_str()
        mysql_data.Mysqldb().execute(
            "insert into sell_rules(_id,code,buy1_volume,sell_volume,day,create_time,excuted) values ('%s','%s','%s','%s','%s',now() ,'%s') " % (
                rule.id_, rule.code, rule.buy1_volume, rule.sell_volume, rule.day, rule.excuted))
            "insert into sell_rules(_id,code,buy1_volume,sell_volume,day,create_time,excuted,end_time) values ('%s','%s','%s','%s','%s',now() ,'%s','%s') " % (
                rule.id_, rule.code, rule.buy1_volume, rule.sell_volume, rule.day, rule.excuted, rule.end_time))
        self.__sell_rules_dict_cache[_id] = rule

    # 删除规则