Haarausfall - Allgemeines Forum : Off topic allgemein

Verschenke 80.000€ [Beitrag #412708] :: Mi., 06 Juni 2018 21:48

Bitteschön:

import datetime

from flask import jsonify, request, make_response, Blueprint
from flask_babel import gettext as _, format_date
from webapp.models.production import Production
from webapp.models.production_state import ProductionState
from webapp.models.assembly import Assembly
from webapp.models.current_worker import CurrentWorker

from webapp.models.event_log import EventLog
from webapp.app import db
from webapp import exceptions
from webapp.helper import ensure_in_request_data, remove_leading_zeroes
from webapp.logger import logger
from webapp.helper import errorhandler, format_time_ticket
from webapp.SAPConnector.sap_conector import SAPConnector

blueprint_api_sap = Blueprint('api_sap', __name__)
blueprint_api_sap.errorhandler(exceptions.DA645Exception)(errorhandler)

@blueprint_api_sap.route('/production/orders/released', methods=['GET'])
def api_sap_get_released_orders():
sap_api_connector = SAPConnector()
released_orders = sap_api_connector.get_released_orders()
return make_response(jsonify(released_orders), 200)

@blueprint_api_sap.route('/production/orders/released/table', methods=['GET'])
def api_sap_get_released_orders_table():
sap_api_connector = SAPConnector()
released_orders = sap_api_connector.get_released_orders()
return make_response(jsonify(released_orders), 200)

@blueprint_api_sap.route('/production/orders/released/<string:capacity_number>', methods=['GET'])
def api_sap_get_released_orders_by_capacity_id(capacity_number):
sap_api_connector = SAPConnector()
sap_released_orders = sap_api_connector.get_released_orders()
released_orders = []

for sap_released_order in sap_released_orders['IT_RELEASED_ORDERS_JSON']:
if sap_released_order['ARBPL'] == capacity_number:
released_orders.append(sap_released_order)

return make_response(jsonify(released_orders), 200)

@blueprint_api_sap.route('/production/orders/released/<string:capacity_number>/table', methods=['GET'])
def api_sap_get_released_orders_table_by_capacity_id(capacity_number):
sap_api_connector = SAPConnector()
sap_released_orders = sap_api_connector.get_released_orders()
released_orders = {'data': []}

for sap_released_order in sap_released_orders['IT_RELEASED_ORDERS_JSON']:
if sap_released_order['ARBPL'] != capacity_number:
continue

sap_order_details = sap_api_connector.get_order_details(sap_released_order['AUFNR'])
sap_operation = None
operation_sequence = 0

for operation_sequence in range(operation_sequence, len(sap_order_details['LT_OPERATION'])):
if sap_order_details['LT_OPERATION'][operation_sequence]['OPERATION_NUMBER'] == sap_released_order['VORNR']:
sap_operation = sap_order_details['LT_OPERATION'][operation_sequence]
break

if sap_operation is None:
raise exceptions.SAPNotFound(_('Operation not found'))

start_date = datetime.datetime.strptime(sap_released_order['SSAVD'], '%Y-%m-%d')
end_date = datetime.datetime.strptime(sap_released_order['SSEDD'], '%Y-%m-%d')

row = [remove_leading_zeroes(sap_released_order['AUFNR']),
sap_released_order['VORNR'],
remove_leading_zeroes(sap_operation['CONF_NO']),
sap_operation['DESCRIPTION'] + " " + sap_operation['DESCRIPTION2'],
sap_released_order['LTXA1'],
format_date(start_date, format='short'),
format_date(end_date, format='short'),
sap_released_order['STTXT'],
]

if operation_sequence == 0:
row.append('table-success')
else:
sap_previous_operation = sap_order_details['LT_OPERATION'][operation_sequence - 1]
sap_previous_operation_status_list = sap_previous_operation['SYSTEM_STATUS'].split(' ')
if 'CNF' in sap_previous_operation_status_list:
row.append('table-success')
elif 'PCNF' in sap_previous_operation_status_list and sap_previous_operation['QUANTITY'] > 0:
row.append('table-warning')
else:
row.append('table-danger')

released_orders['data'].append(row)

return make_response(jsonify(released_orders), 200)

@blueprint_api_sap.route('/hr/authenticate/<string:worker_id>', methods=['GET'])
def api_sap_authenticate_worker(worker_id):
worker_id_expected_length = 8

if not worker_id.isdigit() or len(worker_id) > worker_id_expected_length:
raise exceptions.RequestDataInvalidWorkerId(_('Invalid worker id'))

if len(worker_id) < worker_id_expected_length:
worker_id = "0" * (worker_id_expected_length - len(worker_id)) + worker_id

sap_api_connector = SAPConnector()
sap_worker = sap_api_connector.get_worker_by_id(worker_id)

worker = {
"id": worker_id,
"name": "{forename} {lastname}".format(
forename=sap_worker["WA_EMPLOYEE_JSON"]["VORNA"],
lastname=sap_worker["WA_EMPLOYEE_JSON"]["NACHN"]
)
}
return make_response(jsonify(worker), 200)

@blueprint_api_sap.route('/production/operation/start',
methods=['POST'])
def api_sap_start_operation():
request_data = request.get_json()

ensure_in_request_data(request_data, ("production_id", int, lambda x: x > 0),
error=exceptions.RequestDataInvalidProductionId(_('Invalid production id')))

ensure_in_request_data(request_data, ('operation_confirmation_number', str, lambda x: len(x) > 0),
error=exceptions.RequestDataInvalidOperationNumber(_('Invalid operation number')))

ensure_in_request_data(request_data, ("worker.id", str, lambda x: len(x) is Cool

,
error=exceptions.RequestDataInvalidWorkerId(_('Invalid worker id')))

production = Production.query.get_or_404(request_data['production_id'])
production_state = ProductionState.query.filter_by(name='Production').first_or_404()

if production.assembly:
raise exceptions.RequestInvalidassemblyState(_('Assembly already started'))

request_worker = request_data["worker"]
request_operation_confirmation_number = request_data["operation_confirmation_number"]
operation_confirmation_number_expected_length = 10

current_worker_production = CurrentWorker.query.filter_by(worker_id=request_worker["id"]).first()

if current_worker_production:
raise exceptions.RequestInvalidWorkerState(_('{worker_name} already working on {production_name}'.format(
worker_name=current_worker_production.worker_name,
production_name=current_worker_production.assembly.production.name)))

if len(request_operation_confirmation_number) < operation_confirmation_number_expected_length:
request_operation_confirmation_number = "0" * (operation_confirmation_number_expected_length - len(
request_operation_confirmation_number)) + request_operation_confirmation_number

sap_api_connector = SAPConnector()
sap_timeticket_proposal = sap_api_connector.get_timeticket_proposal(request_operation_confirmation_number)
sap_order_details = sap_api_connector.get_order_details(sap_timeticket_proposal['LT_TIMETICKETS'][0]['ORDERID'])

sap_order_details_operation = None

for sap_operation in sap_order_details['LT_OPERATION']:
if sap_operation['CONF_NO'] == request_operation_confirmation_number:
sap_order_details_operation = sap_operation
break

if not sap_order_details_operation:
raise exceptions.SAPNotFound(_('Confirmation number not in SAP order details'))

if production.capacity_number != sap_order_details_operation['WORK_CENTER']:
raise exceptions.RequestDataInvalidOperationState(_('Operation not assigned to this capacity'))

production_already_assembling = Production.query.join(Assembly).filter(
Assembly.order_number == sap_order_details['LS_HEADER']['ORDER_NUMBER']).filter(
Assembly.operation_confirmation_number != request_operation_confirmation_number).first()

if production_already_assembling:
raise exceptions.RequestDataInvalidOperationState(_(
'Another Operation of order {order_number} already in assembly at {production_name}'.format(
order_number=remove_leading_zeroes(production_already_assembling.assembly.order_number),
production_name=production_already_assembling.name
)))

sap_order_details_operation_status = sap_order_details_operation['SYSTEM_STATUS'].split(' ')

if 'REL' not in sap_order_details_operation_status:
raise exceptions.RequestDataInvalidOperationState(_('Operation not released'))

if 'CNF' in sap_order_details_operation_status:
raise exceptions.RequestDataInvalidOperationState(_('Operation already confirmed'))

assembly = Assembly()
assembly.order_number = sap_order_details['LS_HEADER']['ORDER_NUMBER']
assembly.operation_confirmation_number = sap_order_details_operation['CONF_NO']
assembly.production_id = Production.id

production.production_state = production_state
production.assembly = assembly

try:
db.session.add(assembly)
db.session.flush()
current_worker = CurrentWorker(worker_name=request_worker["name"],
worker_id=request_worker["id"],
assembly_id=assembly.id)
db.session.add(current_worker)
db.session.flush()

ev_start_op = EventLog(event='start_operation', value=
{"assembly_id": assembly.id,
"order_number": assembly.order_number,
"operation_confirmation_number": assembly.operation_confirmation_number,
"production_id": production.id,
"production_name": production.name,
"production_workplace_number": production.workplace_number,
"worker_id": current_worker.worker_id})

ev_prod_state = EventLog(event='production_state', value=
{"production_state_id": production.production_state_id,
"production_state_name": production.production_state.name,
"production_id": production.id,
"production_name": production.name,
"production_workplace_number": production.workplace_number,
"worker_id": current_worker.worker_id})

ev_start_work = EventLog(event="start_work", value=
{"assembly_id": production.assembly.id,
"order_number": assembly.order_number,
"operation_confirmation_number": assembly.operation_confirmation_number,
"production_id": production.id,
"production_name": production.name,
"production_workplace_number": production.workplace_number,
"worker_id": current_worker.worker_id})

db.session.add(ev_start_op)
db.session.add(ev_prod_state)
db.session.add(ev_start_work)
db.session.add(current_worker)

db.session.commit()

except Exception as e:
logger.error(str(e))
raise exceptions.RequestGenericError(str(e))

return make_response(jsonify(production.get_dict()), 200)

@blueprint_api_sap.route('/production/operation/finish',
methods=['POST'])
def api_sap_finish_operation():
request_data = request.get_json()

ensure_in_request_data(request_data, ("production_id", int, lambda x: x > 0),
error=exceptions.RequestDataInvalidProductionId(_('Invalid production id')))

ensure_in_request_data(request_data, ("worker.id", str, lambda x: len(x) is Cool

,
error=exceptions.RequestDataInvalidWorkerId(_('Invalid worker id')))
ensure_in_request_data(request_data, ("parts", int, lambda x: x >= 0),
error=exceptions.RequestDataInvalidPartAmount(_('Invalid part amount')))

production = Production.query.get_or_404(request_data['production_id'])

request_worker = request_data['worker']

if not production.assembly:
raise exceptions.RequestInvalidassemblyState(_('No assembly in progress'))

current_worker = CurrentWorker.query.join(Assembly).filter(
CurrentWorker.assembly_id == production.assembly.id,
CurrentWorker.worker_id == request_worker[
"id"]).first()

if not current_worker:
raise exceptions.RequestInvalidWorkerState(
_('{worker_name} not working on {production_name}'.format(worker_name=request_worker['name'],
production_name=production.name)))

request_parts = request_data['parts']

sap_api_connector = SAPConnector()
sap_timeticket_proposal = sap_api_connector.get_timeticket_proposal(
production.assembly.operation_confirmation_number)

if request_parts > sap_timeticket_proposal['LT_TIMETICKETS'][0]['YIELD']:
raise exceptions.SAPException(_('Maximum bookable parts {parts_yield} exceeded by {diff_parts}'.format(
parts_yield=int(sap_timeticket_proposal['LT_TIMETICKETS'][0]['YIELD']),
diff_parts=int(request_parts - sap_timeticket_proposal['LT_TIMETICKETS'][0]['YIELD'])
)))

assemblies_to_finish = [production.assembly]

if request_parts == sap_timeticket_proposal['LT_TIMETICKETS'][0]['YIELD']:
assemblies_to_finish = Assembly.query.join(Production).filter(
Assembly.operation_confirmation_number == production.assembly.operation_confirmation_number).all()

time_tickets_jar = []

for assembly_to_finish in assemblies_to_finish:
for assembly_to_finish_worker in assembly_to_finish.current_worker:
if assembly_to_finish_worker.id != current_worker.id or production.id != assembly_to_finish.production.id:
time_ticket_assembly_worker = format_time_ticket(sap_timeticket_proposal,
assembly_to_finish_worker.worker_id,
's',
assembly_to_finish_worker.get_work_time_seconds(),
0,
assembly_to_finish.production.printer_id
)
time_tickets_jar.append(time_ticket_assembly_worker)

time_ticket_current_worker = format_time_ticket(
sap_timeticket_proposal,
current_worker.worker_id,
's',
current_worker.get_work_time_seconds(),
request_parts,
production.printer_id)

time_tickets_jar.append(time_ticket_current_worker)
sap_api_connector.create_time_ticket(time_tickets_jar)

try:
for assembly_to_finish in assemblies_to_finish:
for assembly_to_finish_worker in assembly_to_finish.current_worker:
worker_parts = 0
if assembly_to_finish.production.id == production.id and current_worker.worker_id == request_worker[
"id"]:
worker_parts = request_parts

ev_stop_work = EventLog(event="stop_work", value=
{"assembly_id": assembly_to_finish.id,
"order_number": assembly_to_finish.order_number,
"operation_confirmation_number": assembly_to_finish.operation_confirmation_number,
"parts": worker_parts,
"production_id": assembly_to_finish.production.id,
"production_name": assembly_to_finish.production.name,
"production_workplace_number": assembly_to_finish.production.workplace_number,
"worker_id": assembly_to_finish_worker.worker_id})
db.session.add(ev_stop_work)
db.session.delete(assembly_to_finish_worker)

ev_prod_state = EventLog(event='production_state', value=
{"production_state_id": assembly_to_finish.production.production_state.id,
"production_state_name": assembly_to_finish.production.production_state.name,
"production_name": assembly_to_finish.production.name,
"production_workplace_number": assembly_to_finish.production.workplace_number,
"worker_id": current_worker.worker_id})

ev_fin_op = EventLog(event='finish_operation', value=
{"assembly_id": assembly_to_finish.id,
"order_number": assembly_to_finish.order_number,
"operation_confirmation_number": assembly_to_finish.operation_confirmation_number,
"parts": request_parts,
"production_id": assembly_to_finish.production.id,
"production_name": assembly_to_finish.production.name,
"production_workplace_number": assembly_to_finish.production.workplace_number,
"worker_id": current_worker.worker_id})

db.session.add(ev_prod_state)
db.session.add(ev_fin_op)
assembly_to_finish.production.production_state = None
assembly_to_finish.finish_date = datetime.datetime.utcnow()
assembly_to_finish.production.assembly = None

db.session.commit()
except Exception as e:
logger.error(str(e))
raise exceptions.RequestGenericError(str(e))

return make_response(jsonify(production.get_dict()), 200)

@blueprint_api_sap.route('/production/work/start',
methods=['POST'])
def api_sap_start_work():
request_data = request.get_json()

ensure_in_request_data(request_data, ("production_id", int, lambda x: x > 0),
error=exceptions.RequestDataInvalidProductionId(_('Invalid production id')))

ensure_in_request_data(request_data, ("worker.id", str, lambda x: len(x) is Cool

,
error=exceptions.RequestDataInvalidWorkerId(_('Invalid worker id')))

production = Production.query.get_or_404(request_data['production_id'])
request_worker = request_data["worker"]

if not production.assembly:
raise exceptions.RequestInvalidassemblyState(_('No assembly in progress'))

if CurrentWorker.query.filter(
CurrentWorker.assembly_id == production.assembly.id,
CurrentWorker.worker_id == request_worker[
"id"]).first():
raise exceptions.RequestInvalidassemblyState(
_('Worker already working on {production_name}'.format(production_name=production.name)))

current_worker_production = CurrentWorker.query.filter_by(worker_id=request_worker["id"]).first()

if current_worker_production:
raise exceptions.RequestInvalidWorkerState(_('{worker_name} already working on {production_name}'.format(
worker_name=current_worker_production.worker_name,
production_name=current_worker_production.assembly.production.name)))

current_worker = CurrentWorker(
worker_name=request_worker["name"],
worker_id=request_worker["id"],
assembly_id=production.assembly.id)

if production.production_state.type == 'error':
current_worker.interrupt_work_date = datetime.datetime.utcnow()

try:
db.session.add(current_worker)
db.session.flush()

ev_start_work = EventLog(event="start_work", value={
"assembly_id": production.assembly.id,
"order_number": production.assembly.order_number,
"production_id": production.id,
"production_name": production.name,
"production_workplace_number": production.workplace_number,
"worker_id": current_worker.worker_id})

db.session.add(ev_start_work)
db.session.commit()
except Exception as e:
logger.error(str(e))
raise exceptions.RequestGenericError(str(e))

return make_response(jsonify(production.get_dict()), 200)

@blueprint_api_sap.route('/production/work/stop', methods=['POST'])
def api_sap_stop_work():
request_data = request.get_json()

ensure_in_request_data(request_data, ("worker.id", str, lambda x: len(x) is Cool

,
error=exceptions.RequestDataInvalidWorkerId(_('Invalid worker id')))

ensure_in_request_data(request_data, ("production_id", int, lambda x: x > 0),
error=exceptions.RequestDataInvalidProductionId(_('Invalid production id')))

ensure_in_request_data(request_data, ("parts", int, lambda x: x >= 0),
error=exceptions.RequestDataInvalidPartAmount(_('Invalid part amount')))

production = Production.query.get_or_404(request_data['production_id'])
request_worker = request_data["worker"]
request_parts = request_data["parts"]

if not production.assembly.id:
raise exceptions.RequestInvalidassemblyState(_('No assembly in progress'))

current_worker = CurrentWorker.query.join(Assembly).filter(
CurrentWorker.assembly_id == production.assembly.id,
CurrentWorker.worker_id == request_worker[
"id"]).first()

if not current_worker:
raise exceptions.RequestInvalidassemblyState(
_('{worker_name} not working on {production_name}'.format(worker_name=request_worker['name'],
production_name=production.name)))

sap_api_connector = SAPConnector()
sap_timeticket_proposal = sap_api_connector.get_timeticket_proposal(
production.assembly.operation_confirmation_number)

if request_parts > sap_timeticket_proposal['LT_TIMETICKETS'][0]['YIELD']:
raise exceptions.SAPException(_('Maximum bookable parts {parts_yield} exceeded by {diff_parts}'.format(
parts_yield=int(sap_timeticket_proposal['LT_TIMETICKETS'][0]['YIELD']),
diff_parts=int(request_parts - sap_timeticket_proposal['LT_TIMETICKETS'][0]['YIELD'])
)))
elif request_parts == sap_timeticket_proposal['LT_TIMETICKETS'][0]['YIELD']:
raise exceptions.SAPException(_('Maximum bookable parts of {parts_yield} would be reached, '
'please finish Operation'
''.format(parts_yield=int(sap_timeticket_proposal['LT_TIMETICKETS'][0]['YIELD'])
)))

time_ticket = format_time_ticket(sap_timeticket_proposal,
current_worker.worker_id,
's',
current_worker.get_work_time_seconds(),
request_parts,
production.printer_id)

sap_api_connector.create_time_ticket([time_ticket])

try:
ev_stop_work = EventLog(event="stop_work", value={
"assembly_id": production.assembly.id,
"order_number": production.assembly.order_number,
"operation_confirmation_number": production.assembly.operation_confirmation_number,
"parts": request_parts,
"production_id": production.id,
"production_name": production.name,
"production_workplace_number": production.workplace_number,
"worker_id": current_worker.worker_id})

db.session.add(ev_stop_work)
db.session.delete(current_worker)
db.session.commit()

except Exception as e:
logger.error(str(e))
raise exceptions.RequestGenericError(str(e))

return make_response(jsonify(production.get_dict()), 200)

@blueprint_api_sap.route('/production/state', methods=['POST'])
def api_set_production_state():
request_data = request.get_json()

ensure_in_request_data(request_data, ("production_id", int, lambda x: x > 0),
error=exceptions.RequestDataInvalidProductionId(_('Invalid production id')))

ensure_in_request_data(request_data, ("production_state_id", int, lambda x: x > 0),
error=exceptions.RequestDataInvalidProductionStateId(_('Invalid production state id')))

ensure_in_request_data(request_data, ("worker.id", str, lambda x: len(x) is Cool

,
error=exceptions.RequestDataInvalidWorkerId(_('Invalid worker id')))

request_worker = request_data['worker']
production = Production.query.get_or_404(request_data['production_id'])
production_state = ProductionState.query.get_or_404(request_data['production_state_id'])
production.production_state = production_state

if production.assembly:
if production_state.type == "ok":
for current_worker in production.assembly.current_worker:
current_worker.interrupt_work_date = None
current_worker.start_work_date = datetime.datetime.utcnow()
else:
for current_worker in production.assembly.current_worker:
if not current_worker.interrupt_work_date:
current_worker.interrupt_work_date = datetime.datetime.utcnow()

try:
ev_pro_state = EventLog(event='production_state', value=
{"production_state_id": production.production_state_id,
"production_state_name": production.production_state.name,
"production_id": production.id,
"production_name": production.name,
"production_workplace_number": production.workplace_number,
"worker_id": request_worker["id"]})

db.session.add(ev_pro_state)
db.session.commit()
except Exception as e:
logger.error(str(e))
raise exceptions.RequestGenericError(str(e))

return make_response(jsonify(production.get_dict()), 200)

Hattingen Hair 21.02.19 & 22.02.19 5200 FUT

Den Beitrag einem Moderator melden

Aw: Verschenke 80.000€ [Beitrag #412712 ist eine Antwort auf Beitrag #412708] :: Mi., 06 Juni 2018 22:38

Echt jetzt?? Very Happy

Mittlerweile 27 Jahre alt
Koshine826(Kx826) 2x2 ml , momentan 0.5% bei Release 1%.
Alfatradiol 0.1% 2ml am Tag
2x 2ml Minox 5%
Ket Lotion nach Pilos
1.5 mm Dermarolling Weekly
--------------
Abgesetzt: RU 2024 / Fin 2015-2018

Status: NW 1 mit Ausdünnung

Den Beitrag einem Moderator melden

Aw: Verschenke 80.000€ [Beitrag #412714 ist eine Antwort auf Beitrag #412712] :: Mi., 06 Juni 2018 22:51

IchBinAmEnde® schrieb am Wed, 06 June 2018 22:38

Echt jetzt??

Jetzt erst recht!

Hattingen Hair 21.02.19 & 22.02.19 5200 FUT

Den Beitrag einem Moderator melden

Aw: Verschenke 80.000€ [Beitrag #412716 ist eine Antwort auf Beitrag #412708] :: Mi., 06 Juni 2018 23:28

Aber erst wenn dir diesen SAP Kram da in geil coded?! Laughing

Den Beitrag einem Moderator melden

Aw: Verschenke 80.000€ [Beitrag #412718 ist eine Antwort auf Beitrag #412708] :: Mi., 06 Juni 2018 23:50

Zahlst du per Überweisung? Ich würde dir dann per PN meine Bankverbindung geben.
Danke im Voraus! Surprised

forschungsgruppe-aga.xobor.de

Den Beitrag einem Moderator melden

Aw: Verschenke 80.000€ [Beitrag #412719 ist eine Antwort auf Beitrag #412708] :: Do., 07 Juni 2018 00:48

BIN FIT UND SPITZ

Den Beitrag einem Moderator melden