1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

try {
    java.net.URL url = new java.net.URL("http://localhost:5000/api/wms/update_counters");
    java.net.HttpURLConnection conn = (java.net.HttpURLConnection) url.openConnection();
    conn.setRequestMethod("POST");
    conn.setRequestProperty("Content-Type", "application/json; utf-8");
    conn.setDoOutput(true);
    
    String jsonInputString = "{\"agent_id\": \"" + agent.id + "\", \"status\": \"normal\"}";
    try(java.io.OutputStream os = conn.getOutputStream()) {
        byte[] input = jsonInputString.getBytes("utf-8");
        os.write(input, 0, input.length);           
    }
    int code = conn.getResponseCode();
    conn.disconnect();
} catch (Exception e) {
    e.printStackTrace();
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

name: wms_project
 
services:
  webdb:
    image: postgres:15
    environment:
      - POSTGRES_DB=postgres
      - POSTGRES_PASSWORD=odoo
      - POSTGRES_USER=odoo
    volumes:
      - odoo-db-data:/var/lib/postgresql/data
 
  odoo_wms:
    image: odoo:17.0
    depends_on:
      - webdb
    ports:
      - "8069:8069"
    environment:
      - HOST=webdb
      - USER=odoo
      - PASSWORD=odoo
    volumes:
      - odoo-web-data:/var/lib/odoo
 
volumes:
  odoo-db-data:
  odoo-web-data:

1
2
3
4
5
6
7
8
9
10
11

import cupy as cp
 
def analyze_box_positions_gpu(coordinates_list):
    # Перенос массива координат из хоста (CPU) в память устройства (GPU)
    gpu_coordinates = cp.array(coordinates_list)
    
    # Высокоскоростной матричный расчет дистанций и коллизий между коробками
    distances = cp.linalg.norm(gpu_coordinates[:, None, :] - gpu_coordinates[None, :, :], axis=-1)
    
    # Возврат результатов анализа обратно на CPU
    return cp.asnumpy(distances)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55

import xmlrpc.client
from flask import Flask, request, jsonify
from flask_cors import CORS
import requests
 
app = Flask(__name__)
CORS(app)
 
# Конфигурация шины интеграции
ODOO_URL = 'http://localhost:8069'
ODOO_DB = 'wms'
ODOO_USER = 'odoo'
ODOO_PASS = 'odoo'
COLAB_CUDA_URL = "https://loca.lt"
 
latest_cuda_positions = []
 
@app.route('/api/wms/update_counters', methods=['POST'])
def update_counters():
    global latest_cuda_positions
    data = request.json
    if not data:
        return jsonify({"status": "empty"}), 400
        
    # Мгновенная фиксация объекта в буфере для поддержания 50 FPS на 3D-сайте
    latest_cuda_positions.append(data)
    if len(latest_cuda_positions) > 50:
        latest_cuda_positions.pop(0)
 
    response_data = {"status": "success"}
 
    # === СЦЕНАРИЙ А: ФИКСАЦИЯ И КОРРЕКТИРОВКА БРАКА В ODOO 17 ERP ===
    if data.get("status") == "damaged" or data.get("event") == "box_damaged":
        sku = data.get("sku", "E-COM12")
        response_data = {"status": "damage_registered", "action_required": "TRIGGER_3D_RED_ALERT"}
        
        try:
            common = xmlrpc.client.ServerProxy(f'{ODOO_URL}/xmlrpc/2/common', allow_none=True)
            uid = common.authenticate(ODOO_DB, ODOO_USER, ODOO_PASS, {})
            
            if uid:
                models = xmlrpc.client.ServerProxy(f'{ODOO_URL}/xmlrpc/2/object', allow_none=True)
                # Поиск товара по внутреннему артикулу (Internal Reference)
                product_ids = models.execute_kw(ODOO_DB, uid, ODOO_PASS, 'product.product', 'search', [[['default_code', '=', sku]]])
                
                if product_ids:
                    product_id = product_ids if isinstance(product_ids, list) else product_ids
                    # Поиск главной внутренней локации склада
                    location_ids = models.execute_kw(ODOO_DB, uid, ODOO_PASS, 'stock.location', 'search', [[['usage', '=', 'internal']]])
                    
                    if location_ids:
                        loc_id = location_ids if isinstance(location_ids, list) else location_ids
                        # Поиск существующего кванта остатков
                        quant_ids = models.execute_kw(ODOO_DB, uid, ODOO_PASS, 'stock.quant', 'search', [[['product_id', '=', product_id], ['location_id', '=', loc_id]]])
if quant_ids:# Обновление текущего баланса бракаmodels.execute_kw(ODOO_DB, uid, ODOO_PASS, 'stock.quant', 'write', [quant_ids, {'quantity': float(data.get("red_qty", 1))}])print(f"[ODOO 17 SUCCESS] Складской квант для {sku} успешно скорректирован!")else:# Первичная инициализация полки под данный артикулmodels.execute_kw(ODOO_DB, uid, ODOO_PASS, 'stock.quant', 'create', [{'product_id': product_id,'location_id': loc_id,'quantity': float(data.get("red_qty", 1))}])print(f"[ODOO 17 SUCCESS] Инициализирована полка под бракованный товар {sku}.")else:print(f"[WMS WARNING] Артикул {sku} отсутствует в номенклатуре Odoo.")else:print("[WMS ERROR] Отказ XML-RPC авторизации. Проверьте res.users.")except Exception as odoo_err:# Изоляция ошибки: сбой СУБД Odoo НЕ ломает основной поток вычислений и AnyLogic!print(f"[CORE GATEWAY] ⚠️ Ошибка шины Odoo WMS: {odoo_err}. Конвейер продолжает работу.")# === СЦЕНАРИЙ Б: ОБЫЧНОЕ ДВИЖЕНИЕ (Стриминг потока координат на GPU) ===else:try:requests.post(COLAB_CUDA_URL, json=data, timeout=3)except Exception as e:pass# Гарантированный ответ клиенту при любом исходе транзакции ERPreturn jsonify(response_data), 200if name == 'main':app.run(host='0.0.0.0', port=5000, debug=True)