consolidator

1
import os
2
import sys
3
import pandas as pd
4
import datetime
5
from MainConsolidator import MainConsolidator
6

7
class handler(object):
8
    @staticmethod
9
    def module_name():
10
        return 'Штрипс ТЭСЦ-5'
11
    @staticmethod
12
    def handle(row:pd.Series,consolidator:MainConsolidator)->pd.Series:
13
        product_up=None
14
        try:
15
            product = row["Первичный продукт"]
16
            gmsps = row["ГМСПС"]
17
            ntd = row["НТД качества (прокат) <Производство>"]
18
            gmsps_oto = consolidator.scalar_in_guid("Признак по НТД",f"`Производство`=='Штрипс ТЭСЦ-5' and `НТД качества (трубы стальные) <Производство>`=='{ntd}'","Доп параметр1")
19
            if "ГЮ" in gmsps and pd.notna(gmsps_oto): gmsps=gmsps_oto
20
            thickness = row["Толщина, мм <Производство>"]
21
            thickness = round(thickness,1)
22
            width_led = consolidator.nearest_in_guid("Параметры по Продукту ТЭСЦ-5",
23
                f"`Производство`=='Штрипс ТЭСЦ-5' and `Продукт`=='{product}' and `Доп параметр2` == '{gmsps[:2]}'",
24
                "Доп параметр1",
25
                row["Ширина штрипса, мм <Производство>"],
26
                "Доп параметр1")
27
            width_led_s=str(width_led).replace(".0","")
28
            print(f"product: {product}; gmsps: {gmsps}; thickness: {thickness}; ntd: {ntd}; width_led: {width_led_s}")
29
            product_up = None
30
            thickness_range = None
31
            if "ГУ" in gmsps:
32
                thickness_range = consolidator.scalar_in_guid("Параметры по Продукту ТЭСЦ-5",
33
                    f"`Производство`=='Штрипс ТЭСЦ-5' and `Продукт`=='{product}' and `Доп параметр2` == 'ГУ' and `Мин`<={thickness}<=`Макс`","Диапазон")
34
                product_up=f"{product} {thickness_range} Ш{width_led_s} ГУ"
35
            else:
36
                product_up=f"{product} Ш{width_led_s} {gmsps}"
37
            row["error"] = pd.NA
38
        except Exception as exp: 
39
            consolidator.mlog.error("handler error",exc_info=True)
40
            row["error"] = f"{exp}"
41
        finally:
42
            row["Продукт УП"]=product_up
43
            row["Время укрупнения"]=datetime.datetime.now()
44
            return row
45
        
46
    def debug_handle(self,inputDf:pd.DataFrame,consolidator:MainConsolidator,module:str=None)->pd.DataFrame:
47
        try:
48
            if module is None: return inputDf.apply(lambda row: self.handle(row,consolidator), axis=1)
49
            else: return inputDf[inputDf["Производство2"]==module].apply(lambda row: self.handle(row,consolidator), axis=1)
50
        except: raise
51
    
52
    def get_compiled(self):
53
        code:str=f"print('{__file__}')"
54
        try:
55
            with open(__file__,encoding="utf-8",mode="r") as f:
56
                code=f.read()
57
        except Exception as exp: 
58
            code=f"print('error: {exp}')"
59
        finally:
60
            cc = compile(code,"","exec")
61
            return cc
62

63
if __name__=="__strips_t5__":
64
    consolidator:MainConsolidator
65
    record:pd.Series
66
    result:pd.Series
67
    result = handler.handle(record,consolidator)
68

69