Merged in sj_tele (pull request #416)

Sj tele

3 files changed, 147 insertions, 1 deletions

diff --git a/indoteknik_custom/models/__init__.py b/indoteknik_custom/models/__init__.py
index 3a9f9312..c0aa7085 100755
--- a/indoteknik_custom/models/__init__.py
+++ b/indoteknik_custom/models/__init__.py
@@ -156,4 +156,5 @@ from . import refund_sale_order
 # from . import patch
 from . import tukar_guling
 from . import tukar_guling_po
-from . import update_date_planned_po_wizard
\ No newline at end of file
+from . import update_date_planned_po_wizard
+from . import sj_tele
\ No newline at end of file
diff --git a/indoteknik_custom/models/report_logbook_sj.py b/indoteknik_custom/models/report_logbook_sj.py
index 66edbf99..b45eab03 100644
--- a/indoteknik_custom/models/report_logbook_sj.py
+++ b/indoteknik_custom/models/report_logbook_sj.py
@@ -4,6 +4,11 @@ from odoo import models, fields, api
 from odoo.exceptions import UserError
 from pytz import timezone
 from datetime import datetime
+import requests
+import json
+import logging
+
+_logger = logging.getLogger(__name__)
 
 class ReportLogbookSJ(models.Model):
     _name = 'report.logbook.sj'
@@ -83,6 +88,44 @@ class ReportLogbookSJ(models.Model):
 
 from odoo import models, fields, api
 
+
+
+    def action_send_to_telegram(self):
+
+        entries = []
+        pickings = self.report_logbook_sj_line.mapped('picking_id')
+        for p in pickings:
+            if p:
+                entries.append((p.name, p.id))
+
+        fallback_names = [l.name for l in self.report_logbook_sj_line if not l.picking_id and l.name]
+        if fallback_names:
+            picks = self.env['stock.picking'].search([('name', 'in', list(set(fallback_names)))])
+            name2id = {p.name: p.id for p in picks}
+            for n in fallback_names:
+                entries.append((n, name2id.get(n)))
+
+        seen, unique_entries = set(), []
+        for name, pid in entries:
+            key = pid or name
+            if key and key not in seen:
+                seen.add(key)
+                unique_entries.append((name, pid))
+
+        header = f"{self.env.user.name} sudah mengisi di Logbook SJ Report:\n"
+        body = "\n".join(f"{name} ({pid or '-'})" for name, pid in unique_entries) if unique_entries else "- (tidak ada)"
+        text = header + body
+
+        bot_mqdd = '8203414501:AAHy_XwiUAVrgRM2EJzW7sZx9npRLITZpb8'
+        chat_id_mqdd = '-4885333032'
+        apiURL = f'https://api.telegram.org/bot{bot_mqdd}/sendMessage'
+        try:
+            hehe = requests.post(apiURL, json={'chat_id': chat_id_mqdd, 'text': text})
+            _logger.info(hehe)
+        except Exception as e:
+            print(e)
+
+
 class ReportLogbookSJLine(models.Model):
     _name = 'report.logbook.sj.line'
     _order = 'sequence, id'  # urut default di UI & ORM (drag pakai sequence)
diff --git a/indoteknik_custom/models/sj_tele.py b/indoteknik_custom/models/sj_tele.py
new file mode 100644
index 00000000..029adcbe
--- /dev/null
+++ b/indoteknik_custom/models/sj_tele.py
@@ -0,0 +1,102 @@
+from odoo import models, fields, api
+from odoo.exceptions import UserError
+import requests
+import json
+import logging, subprocess
+import time
+from collections import OrderedDict
+
+_logger = logging.getLogger(__name__)
+
+class SjTele(models.Model):
+    _name = 'sj.tele'
+    _description = 'sj.tele'
+
+    picking_id = fields.Many2one('stock.picking', string='Picking')
+    sale_id = fields.Many2one('sale.order', string='Sales Order')
+    picking_name = fields.Char(string='Picking Name')
+    sale_name = fields.Char(string='Sale Name')
+    create_date = fields.Datetime(string='Create Date')
+    date_doc_kirim = fields.Datetime(string='Tanggal Kirim SJ')
+
+    # @api.model
+    # def run_pentaho_carte(self):
+    #     carte = "http://127.0.0.1:8080"
+    #     job_kjb = r"C:/Users/Indoteknik/Desktop/tes.kjb"
+    #     params = {"job": job_kjb, "level": "Basic", "block": "Y"}
+    #     try:
+    #         r = requests.get(
+    #             f"{carte}/kettle/executeJob/",
+    #             params=params,
+    #             auth=("cluster", "cluster"),
+    #             timeout=900,
+    #         )
+    #         r.raise_for_status()
+    #         # kalau Carte mengembalikan <result>ERROR</result>, anggap gagal
+    #         if "<result>ERROR</result>" in r.text:
+    #             raise UserError(f"Carte error: {r.text}")
+    #     except Exception as e:
+    #         _logger.exception("Carte call failed: %s", e)
+    #         raise UserError(f"Gagal memanggil Carte: {e}")
+        
+    #     time.sleep(3)
+
+    #     self.env['sj.tele'].sudo().woi()
+
+    #     return True
+
+    def woi(self):
+        bot_mqdd = '8203414501:AAHy_XwiUAVrgRM2EJzW7sZx9npRLITZpb8'
+        chat_id_mqdd = '-4885333032'
+        api_base = f'https://api.telegram.org/bot{bot_mqdd}'
+
+        data = self.search([], order='create_date asc', limit=15)
+
+        if not data:
+            text = "Berikut merupakan nomor BU/OUT yang belum ada di Logbook SJ report:\n✅ tidak ada data (semua sudah tercatat)."
+            try:
+                r = requests.post(api_base + "/sendMessage",
+                                  json={'chat_id': chat_id_mqdd, 'text': text},
+                                  timeout=20)
+                r.raise_for_status()
+            except Exception as e:
+                _logger.exception("Gagal kirim Telegram (no data): %s", e)
+            return True
+
+
+        lines = []
+        groups = OrderedDict()
+
+        for rec in data:
+            name = rec.picking_name or (rec.picking_id.name if rec.picking_id else '')
+            pid  = rec.picking_id.id if rec.picking_id else ''
+            so   = rec.sale_id.name or rec.sale_name or ''
+            dttm = (rec.picking_id.date_doc_kirim if (rec.picking_id and rec.picking_id.date_doc_kirim)
+                    else getattr(rec, 'date_doc_kirim', None))
+
+            # format header tanggal (string), tanpa konversi Waktu/WIB
+            if dttm:
+                date_header = dttm if isinstance(dttm, str) else fields.Datetime.to_string(dttm)
+                date_header = date_header[:10]
+            else:
+                date_header = '(Tidak ada tanggal kirim SJ)'
+
+            if name:
+                groups.setdefault(date_header, []).append(f"- ({pid}) - {name} - {so}")
+
+        # build output berurutan per tanggal
+        for header_date, items in groups.items():
+            lines.append(header_date)
+            lines.extend(items)
+
+
+        header = "Berikut merupakan nomor BU/OUT yang belum ada di Logbook SJ report:\n"
+        text = header + "\n".join(lines)
+
+        try:
+            r = requests.post(api_base + "/sendMessage",
+                              json={'chat_id': chat_id_mqdd, 'text': text})
+            r.raise_for_status()
+        except Exception as e:
+            _logger.exception("Gagal kirim Telegram: %s", e)
+        return True
\ No newline at end of file