[fix] 上推数据修改

sdddl_project/wizard/__init__.py

 from . import assign_workcenter_wizard
 from . import assign_workcenter_wizard
 from . import product_import_wizard
 from . import product_import_wizard
 from . import inherit_roke_bom_create_picking_wizard
 from . import inherit_roke_bom_create_picking_wizard
+from . import inherit_result_put_warehose_wizard

sdddl_project/wizard/inherit_result_put_warehose_wizard.py

+import pymssql
+from odoo import models, fields, api, _
+from odoo.exceptions import ValidationError
+
+
+# 修正数量
+class InheritRokeResultPutWarehouseWizard(models.TransientModel):
+    _inherit = "roke.result.put.warehouse.wizard"
+
+    @api.model
+    def default_get(self, field_names):
+        default = super().default_get(field_names)
+        if self.env.context.get('active_model') != "roke.production.result":
+            return default
+        results = self.env['roke.production.result'].browse(self.env.context.get('active_ids'))
+        system_id = self.env.ref("roke_workstation_sync_ps.roke_workstation_sync_ps_integrate_system")
+        sync_address = system_id.sync_address
+        sync_port = system_id.sync_port
+        sync_uname = system_id.sync_uname
+        sync_passwd = system_id.sync_passwd
+        db_name = system_id.db_name
+        try:
+            conn = pymssql.connect(host=sync_address, user=sync_uname, password=sync_passwd, database=db_name)
+            cur = conn.cursor()
+        except Exception as e:
+            raise ValidationError("数据库链接失败，请检查数据库链接参数")
+        ids = results.ids
+        if not ids:
+            return super(InheritRokeResultPutWarehouseWizard, self).default_get()
+        try:
+            cur.execute(f"""
+                select WBCCB_CCID
+                from WBCCB 
+                where WBCCB_CCID not in ('{"', '".join(ids)}')
+            """)
+            rows = cur.fetchall()
+            rowdesc = cur.description
+        except Exception as e:
+            raise ValidationError("数据库查询失败")
+        finally:
+            cur.close()
+            conn.close()
+        rows_data = [
+            dict(zip([col[0] for col in rowdesc], row))
+            for row in rows
+        ]
+        insert_id = []
+        for v in rows_data:
+            insert_id.append(v.get("WBCCB_CCID", 0))
+        insert_sql_data = []
+        for v in results:
+            if v.id not in insert_id:
+                continue
+            insert_sql_data.append(f"""
+                ('{v.product_id.code}', '{v.wo_id.code}', {v.qty or 0}, {v.id}, '{v.pt_id.code}', '{v.pt_id.task_type}')
+            """)
+        sql = """
+            INSERT INTO WBCCB (WBCCB_CPBH, WBCCB_GDBH, WBCCB_CCSL, WBCCB_CCID, WBCCB_RWBH, WBCCB_RWLX)
+            VALUES 
+        """
+        if not insert_sql_data:
+            raise ValidationError("数据错误")
+        sql += " , ".join(insert_sql_data)
+        try:
+            cur.execute(sql)
+            conn.commit()
+        except Exception as e:
+            raise ValidationError("数据库查询失败")
+        finally:
+            cur.close()
+            conn.close()
+        return super(InheritRokeResultPutWarehouseWizard, self).default_get()

sdddl_project/wizard/inherit_roke_bom_create_picking_wizard.py

@@ -31,7 +31,7 @@ class InheritRokeBomCreatePickingWizard(models.TransientModel):
         sql_list = []
         sql_list = []
         for v in self.line_ids:
         for v in self.line_ids:
             sql_list.append(f"""
             sql_list.append(f"""
-                ('{task_id.code}', '{v.material_id.code}', '{v.demand_qty}', '{v.qty}')
+                ('{task_id.code}', '{v.material_id.code}', {v.demand_qty or 0}, {v.qty or 0})
             """)
             """)
         if not sql_list:
         if not sql_list:
             raise ValidationError("数据错误")
             raise ValidationError("数据错误")