Merged in iman/telegram (pull request #268)

Iman/telegram

8 files changed, 291 insertions, 0 deletions

diff --git a/indoteknik_custom/__manifest__.py b/indoteknik_custom/__manifest__.py
index d44f85db..2e8ecbc1 100755
--- a/indoteknik_custom/__manifest__.py
+++ b/indoteknik_custom/__manifest__.py
@@ -60,6 +60,7 @@
         'views/website_brand_homepage.xml',
         'views/website_categories_homepage.xml',
         'views/website_categories_management.xml',
+        'views/website_telegram.xml',
         'views/website_categories_lob.xml',
         'views/sales_target.xml',
         'views/purchase_outstanding.xml',
diff --git a/indoteknik_custom/models/__init__.py b/indoteknik_custom/models/__init__.py
index 3990e81c..76e4611c 100755
--- a/indoteknik_custom/models/__init__.py
+++ b/indoteknik_custom/models/__init__.py
@@ -131,6 +131,7 @@ from . import account_tax
 from . import approval_unreserve
 from . import vendor_approval
 from . import partner
+from . import website_telegram
 from . import find_page
 from . import user_pengajuan_tempo_line
 from . import user_pengajuan_tempo
@@ -139,3 +140,4 @@ from . import va_multi_approve
 from . import va_multi_reject
 from . import stock_immediate_transfer
 from . import coretax_fatur
+from  . import ir_actions_report
diff --git a/indoteknik_custom/models/ir_actions_report.py b/indoteknik_custom/models/ir_actions_report.py
new file mode 100644
index 00000000..e6b9c303
--- /dev/null
+++ b/indoteknik_custom/models/ir_actions_report.py
@@ -0,0 +1,33 @@
+from odoo import models
+from odoo.http import request
+class IrActionsReport(models.Model):
+    _inherit = 'ir.actions.report'
+
+    def _get_readable_fields(self):
+        self.send_to_telegram()
+        return super()._get_readable_fields()
+
+    def send_to_telegram(self):
+        so_id = self.env.context.get('active_id')
+        if so_id:
+            sale_order = self.env['sale.order'].browse(so_id)
+            if sale_order.amount_total < 200000000:
+                return
+            # id ci vita 79160
+            # id iman 112718
+            partner = request.env['res.partner'].search([('id', '=', 79160)], limit=1)
+            telegram_data = {
+                    'tittle': sale_order.name,
+                    'about': sale_order.name,
+                    'user_id': partner,
+                    'id_data': sale_order.id,
+                    'username': '@' + sale_order.name.replace('/', '')
+                }
+            channel_data = self.env['website.telegram'].search([('tittle', '=', sale_order.name)])
+            if channel_data:
+                channel_data.send_to_telegram(sale_order.name + " Telah di print Oleh " + self.env.user.name)
+                for pick in self:
+                    self._check_telegram(pick)
+            else:
+                telegram = self.env['website.telegram'].create(telegram_data)
+                telegram.create_channel(sale_order.name + " Telah di print Oleh " + self.env.user.name)
diff --git a/indoteknik_custom/models/res_partner.py b/indoteknik_custom/models/res_partner.py
index f081e274..5322515a 100644
--- a/indoteknik_custom/models/res_partner.py
+++ b/indoteknik_custom/models/res_partner.py
@@ -147,6 +147,7 @@ class ResPartner(models.Model):
                                        "customer is crossed blocking amount."
                                        "Set its value to 0.00 to disable "
                                        "this feature", tracking=3)
+    telegram_id = fields.Char(string="Telegram")
 
     @api.model
     def _default_payment_term(self):
diff --git a/indoteknik_custom/models/website_telegram.py b/indoteknik_custom/models/website_telegram.py
new file mode 100644
index 00000000..c655143e
--- /dev/null
+++ b/indoteknik_custom/models/website_telegram.py
@@ -0,0 +1,193 @@
+import requests
+import clipboard
+from odoo import models, fields, api
+from telethon.sessions import StringSession
+from telethon.sync import TelegramClient
+from odoo.exceptions import UserError
+from telethon import functions, types
+from telethon.tl.types import InputPeerChannel
+import asyncio
+from telethon.tl.functions.messages import SendMessageRequest
+from telethon.tl.types import InputMediaPoll, Poll, PollAnswer, PeerChannel
+import datetime
+from telethon.tl.types import MessageMediaPoll
+from telethon.tl.functions.messages import SendMediaRequest
+from telethon.tl.types import TextWithEntities
+
+class WebsiteTelegram(models.Model):
+    _name = 'website.telegram'
+    _description = 'Telegram Channel'
+
+
+    tittle = fields.Char("Channel Title")
+    invite_link = fields.Char("Channel invite link")
+    username = fields.Char("Channel Name")
+    user_id = fields.Many2many('res.partner', string='User Member', store=True)
+    id_data = fields.Char("Channel ID")
+    about = fields.Char("Channel Description")
+    is_broadcast = fields.Boolean("Is Broadcast", default=True)
+    is_megagroup = fields.Boolean("Is Megagroup", default=False)
+    is_accept = fields.Boolean("Is Megagroup", default=False)
+
+    # session_string = 'MIIBCgKCAQEAyMEdY1aR+sCR3ZSJrtztKTKqigvO/vBfqACJLZtS7QMgCGXJ6XIRyy7mx66W0/sOFa7/1mAZtEoIokDP3ShoqF4fVNb6XeqgQfaUHd8wJpDWHcR2OFwvplUUI1PLTktZ9uW2WE23b+ixNwJjJGwBDJPQEQFBE+vfmH0JP503wr5INS1poWg/j25sIWeYPHYeOrFp/eXaqhISP6G+q2IeTaWTXpwZj4LzXq5YOpk4bYEQ6mvRq7D1aHWfYmlEGepfaYR8Q0YqvvhYtMte3ITnuSJs171+GDqpdKcSwHnd6FudwGO4pcCOj4WcDuXc2CTHgH8gFTNhp/Y8/SpDOhvn9QIDAQAB'
+
+            
+    def create_channel(self, message):
+        asyncio.run(self._async_create_channel(message))
+
+    async def _async_create_channel(self, message):
+        async with TelegramClient(StringSession(
+                '1BVtsOJABu30MWCBFwYvvaYbFoIWi43r5a7TUZ2IWwrnSlXIwEhJS5k2y4UKjoDeMPKwhgUWn9lMk02zQjM0ZDzq61YyhkRBvZuu3hCxMsrtP92bkuZtL2g3g1VgI8s7rMhOD_WaGrZbuj-TmbTwIEbN5i1J4raDW2kYzmlLRCbT74xxrGjpzWCnVv7CSS9L2juXuut0lLMgli3_JZbqDO1IyBYh4ZFQYbMf7zv6moDR4MQp1qfnFArsikQcfxjlNXKFcSoyA_GjiIFfCuymwQVtdERXOAH03M_lm8fYbjvgxEkJvxR6hdCnYMcKpIujEEo9SmMmK7Vnl29g1TCPO5tlrDNXq3Ng='),
+                                  27799517, 'df8ee44b0ed11108245037d47b511201') as client:
+            result = await client(functions.channels.CreateChannelRequest(
+                title=self.tittle,
+                about=self.about,
+                broadcast=False,
+                megagroup=True,
+            ))
+            channel = result.updates[3].message.peer_id
+            channel_link = await client(functions.messages.ExportChatInviteRequest(
+                        peer=InputPeerChannel(channel_id=channel.channel_id, access_hash=result.chats[0].access_hash),
+                    ))
+            self.invite_link = channel_link.link
+
+            # Iterasi untuk setiap username
+            for name in self.user_id:
+                if name.telegram_id:
+                    user_to_add = await client.get_entity(name.telegram_id)
+                    result_add_user = await client(functions.channels.InviteToChannelRequest(
+                        channel=channel,
+                        users=[user_to_add.id],
+                    ))
+                else:
+                    raise UserError('ID Telegram '+ name.name + ' salah atau belum diisi')
+            # message = 'https://erp.indoteknik.com/web#id=' + self.id_data + '&action=209&model=sale.order&view_type=form&cids=1&menu_id=101'
+            message_template = 'https://erp.indoteknik.com/web#id=' + self.id_data + '&action=357&model=sale.order&view_type=form&cids=1&menu_id=212'
+            message2 = self.tittle + ' di print oleh ' + self.env.user.name
+            result_massage = await client(SendMessageRequest(channel, message_template))
+            result_massage2 = await client(SendMessageRequest(channel, message))
+
+            # Send the poll to the channel using PeerChannel with the channel's ID
+            # result_polling = await client(SendMediaRequest(
+            #     peer=InputPeerChannel(channel_id=channel.channel_id, access_hash=result.chats[0].access_hash),
+            #     media=InputMediaPoll(poll=Poll(
+            #         question=TextWithEntities(text="ASK RETURN?", entities=[]),
+            #         answers=[
+            #             PollAnswer(text=TextWithEntities(text="Accept", entities=[]), option=b'\x01'),
+            #             PollAnswer(text=TextWithEntities(text="Reject", entities=[]), option=b'\x02'),
+            #         ],
+            #         id=2
+            #     )),
+            #     message='Ask Return Polling'
+            # ))
+
+    def receive_messages(self):
+        return asyncio.run(self._async_receive_messages())
+
+    async def _async_receive_messages(self):
+        async with TelegramClient(StringSession(
+                '1BVtsOJABu30MWCBFwYvvaYbFoIWi43r5a7TUZ2IWwrnSlXIwEhJS5k2y4UKjoDeMPKwhgUWn9lMk02zQjM0ZDzq61YyhkRBvZuu3hCxMsrtP92bkuZtL2g3g1VgI8s7rMhOD_WaGrZbuj-TmbTwIEbN5i1J4raDW2kYzmlLRCbT74xxrGjpzWCnVv7CSS9L2juXuut0lLMgli3_JZbqDO1IyBYh4ZFQYbMf7zv6moDR4MQp1qfnFArsikQcfxjlNXKFcSoyA_GjiIFfCuymwQVtdERXOAH03M_lm8fYbjvgxEkJvxR6hdCnYMcKpIujEEo9SmMmK7Vnl29g1TCPO5tlrDNXq3Ng='),
+                                  27799517, 'df8ee44b0ed11108245037d47b511201') as client:
+            channel = await client.get_entity(self.invite_link)
+            result = await client(functions.messages.GetHistoryRequest(
+                peer=channel,
+                offset_id=42,
+                offset_date=datetime.datetime(2024, 12, 31),
+                add_offset=0,
+                limit=100,
+                max_id=0,
+                min_id=0,
+                hash=channel.access_hash
+            ))
+            accept_found = False
+
+            for message in result.messages:
+                if not isinstance(message.media, MessageMediaPoll):
+                    continue
+                if message.media.results.total_voters > 0:
+                    if message.media.results.results[0].voters > message.media.results.results[1].voters:
+                        accept_found = True
+                        break
+
+            return accept_found
+
+    def send_to_telegram(self, message):
+        # apiURL = f'https://api.telegram.org/bot{self.bot_name}/sendMessage'
+        try:
+            # requests.post(apiURL, json={'chat_id': self.chatID, 'text': message})
+            asyncio.run(self._async_send_to_telegram(message))
+        except Exception as e:
+            print(e)
+
+    async def _async_send_to_telegram(self, message):
+        async with TelegramClient(StringSession(
+                '1BVtsOJABu30MWCBFwYvvaYbFoIWi43r5a7TUZ2IWwrnSlXIwEhJS5k2y4UKjoDeMPKwhgUWn9lMk02zQjM0ZDzq61YyhkRBvZuu3hCxMsrtP92bkuZtL2g3g1VgI8s7rMhOD_WaGrZbuj-TmbTwIEbN5i1J4raDW2kYzmlLRCbT74xxrGjpzWCnVv7CSS9L2juXuut0lLMgli3_JZbqDO1IyBYh4ZFQYbMf7zv6moDR4MQp1qfnFArsikQcfxjlNXKFcSoyA_GjiIFfCuymwQVtdERXOAH03M_lm8fYbjvgxEkJvxR6hdCnYMcKpIujEEo9SmMmK7Vnl29g1TCPO5tlrDNXq3Ng='),
+                                  27799517, 'df8ee44b0ed11108245037d47b511201') as client:
+            channel = await client.get_entity(self.invite_link)
+
+            # Iterasi untuk setiap username
+            for username in self.user_id:
+                if username:
+                    try:
+                        user_to_add = await client.get_entity(username.telegram_id)
+
+                        result_add_user = await client(functions.channels.InviteToChannelRequest(
+                            channel=channel,
+                            users=[user_to_add.id],
+                        ))
+                    except Exception as e:
+                        print(f"Error adding user {username}: {e}")
+
+            result_message = await client(SendMessageRequest(channel, message))
+
+    def test_send(self):
+        try:
+            self.env.cr.savepoint()
+
+            self.env['website.telegram'].search([('tittle', '=', self.tittle)])[0].send_to_telegram('test message')
+        except Exception as e:
+            print(e)
+
+    @api.depends('name', 'chatID', 'bot_name')
+    def _calc_python_code(self):
+        for record in self:
+            if not record.name:
+                record.python_code = "pleas put a name"
+            elif not record.test_message:
+                record.test_message = "test"
+            else:
+                record.python_code = "self.env['website.telegram'].search([('name', '=', '" + record.name + "')])[0].send_to_telegram('" + record.test_message + "')"
+
+    def copy_chat_id(self):
+        record = self.browse(self.id)
+        clipboard.copy(record.python_code)
+
+    def paste_chat_id(self):
+        record = self.browse(self.id)
+        chat_id = clipboard.paste()
+        record.write({'chatID': chat_id})
+
+    def paste_bot_name(self):
+        record = self.browse(self.id)
+        bot_name = clipboard.paste()
+        record.write({'bot_name': bot_name})
+
+    def get_updates(self):
+        apiURL = f'https://api.telegram.org/bot{self.bot_name}/getUpdates'
+        try:
+            response = requests.get(apiURL)
+            updates = response.json()
+            return updates
+        except Exception as e:
+            print(e)
+            return None
+
+    # def receive_messages(self):
+    #     updates = self.get_updates()
+    #     if updates and 'result' in updates:
+    #         for update in updates['result']:
+    #             if 'text' in update['channel_post']:
+    #                 message_text = update['channel_post']['text']
+    #                 chat_id = update['channel_post']['chat']['id']
+    #                 chat_name = update['channel_post']['chat']['username']
+    #                 print(f"Received message: {message_text} from chat_id: {chat_id}, that is: {chat_name}")
diff --git a/indoteknik_custom/security/ir.model.access.csv b/indoteknik_custom/security/ir.model.access.csv
index 4e1ecd7d..188a9619 100755
--- a/indoteknik_custom/security/ir.model.access.csv
+++ b/indoteknik_custom/security/ir.model.access.csv
@@ -24,6 +24,7 @@ access_website_categories_homepage,access.website.categories.homepage,model_webs
 access_website_categories_lob,access.website.categories.lob,model_website_categories_lob,,1,1,1,1
 access_website_categories_management,access.website.categories.management,model_website_categories_management,,1,1,1,1
 access_website_categories_management_line,access.website.categories.management.line,model_website_categories_management_line,,1,1,1,1
+access_website_telegram,access.website.telegram,model_website_telegram,,1,1,1,1
 access_sales_target,access.sales.target,model_sales_target,,1,1,1,1
 access_purchase_outstanding,access.purchase.outstanding,model_purchase_outstanding,,1,1,1,1
 access_sales_outstanding,access.sales.outstanding,model_sales_outstanding,,1,1,1,1
diff --git a/indoteknik_custom/views/res_partner.xml b/indoteknik_custom/views/res_partner.xml
index bd664890..af5e0db3 100644
--- a/indoteknik_custom/views/res_partner.xml
+++ b/indoteknik_custom/views/res_partner.xml
@@ -68,6 +68,7 @@
                 <field name="vat" position="after">
                     <field name="email_finance" widget="email"/>
                     <field name="email_sales" widget="email"/>
+                    <field name="telegram_id"/>
                     <field name="use_so_approval" attrs="{'invisible': [('parent_id', '!=', False), ('company_type', '!=', 'company')]}" />
                     <field name="use_only_ready_stock" attrs="{'invisible': [('parent_id', '!=', False), ('company_type', '!=', 'company')]}" />
                     <field name="web_role" attrs="{'invisible': ['|', ('parent_id', '=', False), ('company_type', '=', 'company')]}" />
diff --git a/indoteknik_custom/views/website_telegram.xml b/indoteknik_custom/views/website_telegram.xml
new file mode 100644
index 00000000..d8590fc0
--- /dev/null
+++ b/indoteknik_custom/views/website_telegram.xml
@@ -0,0 +1,59 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<odoo>
+    <data>
+        <record id="website_telegram_action" model="ir.actions.act_window">
+            <field name="name">Channel Telegram</field>
+            <field name="res_model">website.telegram</field>
+            <field name="view_mode">tree,form</field>
+        </record>
+
+        <record id="website_telegram_tree" model="ir.ui.view">
+            <field name="name">website.telegram.tree</field>
+            <field name="model">website.telegram</field>
+            <field name="arch" type="xml">
+                <tree string="Channel List">
+                        <field name="tittle"/>
+                        <field name="about"/>
+                        <field name="user_id"/>
+                    <button name="test_send" type="object" icon="fa-paper-plane" string="Send Test"/>
+<!--                    <button name="create_channel" type="object" icon="fa-paper-plane" string="Create Channel"/>-->
+<!--                    <button name="receive_messages" type="object" icon="fa-paper-plane" string="GET Test"/>-->
+                </tree>
+            </field>
+        </record>
+
+        <record id="website_telegram_form" model="ir.ui.view">
+            <field name="name">website.telegram.form</field>
+            <field name="model">website.telegram</field>
+            <field name="arch" type="xml">
+                <form create="0">
+                    <sheet>
+                        <group>
+                            <group>
+                                <field name="tittle"/>
+                                <field name="about"/>
+                                <field name="user_id" widget="many2many_tags"/>
+                            </group>
+                        </group>
+                    </sheet>
+                </form>
+            </field>
+        </record>
+
+        <record id="ir_actions_server_website_telegram_sync_to_solr" model="ir.actions.server">
+            <field name="name">Sync to solr</field>
+            <field name="model_id" ref="indoteknik_custom.model_website_telegram"/>
+            <field name="binding_model_id" ref="indoteknik_custom.model_website_telegram"/>
+            <field name="state">code</field>
+            <field name="code">model.action_sync_to_solr()</field>
+        </record>
+
+        <menuitem
+            id="website_telegram"
+            name="Channel Telegram"
+            parent="website_sale.menu_orders"
+            sequence="1"
+            action="website_telegram_action"
+        />
+    </data>
+</odoo>