पृष्ठभूमि

लीटर में बोनस और कूपन की एक प्रणाली होती है जो पर्यावरणीय नियमितता के साथ दिखाई देती है। अपनी पत्नी को खुश करने के लिए, और सामान्य तौर पर, वह अपने लिए एक दिलचस्प पुस्तक पा सकता है, उसने उस साइट की निगरानी करना शुरू कर दिया जिसमें ताजे कूपन दिखाई देते हैं और उन्हें टेलीग्राम में गिरा दिया जाता है। लेकिन कुछ दिनों बाद मैं इस व्यवसाय से थक गया था और मैंने इस प्रक्रिया को स्वचालित करने का फैसला किया ताकि यह हर किसी के लिए उपलब्ध हो जो इसे चाहता है।

कार्यान्वयन

चूंकि मैंने लगातार टेलीग्राम में नए कूपन पोस्ट किए हैं, और सामान्य तौर पर मुझे यह उपकरण पसंद है, इसलिए मैंने टेलीग्राम के लिए एक और बॉट बनाने का फैसला किया, जब तक कि इसके लिए पर्याप्त संख्या में पुस्तकालय तैयार नहीं हो गए। भाषा के रूप में गोलंग और टेलीग्राम-बॉट- एप लाइब्रेरी को लें । हमें एक संसाधन का चयन करने की आवश्यकता है, जिसमें से जानकारी खींचने के लिए, मेरे मन में कई साइटें थीं और मैंने एक समग्र पार्सर लिखने की सोची, लेकिन कुछ बिंदु पर मैं आलसी हो गया, और मैंने एक संसाधन चुनने का फैसला किया। पुनरारंभ होने के बाद भी कूपन स्टोर करने के लिए, मैंने एक साधारण sqlite3 डेटाबेस का उपयोग करने का निर्णय लिया। हम इसमें कूपन के बारे में जानकारी संग्रहीत करेंगे, साथ ही टेलीग्राम बॉट में पंजीकृत उपयोगकर्ताओं के बारे में भी जानकारी देंगे, साथ ही यह भी जानकारी देंगे कि उपयोगकर्ता को कौन से कूपन पहले ही मिल चुके हैं और जो अभी तक नहीं हैं।

यह कुछ इस तरह दिखता है

साइट पार्सिंग

साइट की पार्सिंग बकरी की लाइब्रेरी द्वारा की जाएगी - यह बहुत कुछ उसी तरह से काम करता है जैसे कि jquery। Goquery.Document
संरचना का उपयोग करना html . , , . . unixtime, . , , . , , js .

Telegram bot

BotFather , telegram . telegram api , http websocket. , telegram-bot-api updater .

type SNBot struct {
    cfg *Config
    bot *tgbotapi.BotAPI
    upd tgbotapi.UpdatesChannel
}

func New(cfg *Config) (*SNBot, error) {
    bot, err := tgbotapi.NewBotAPI(cfg.Token)
    if err != nil {
        return nil, err
    }
    level.Info(cfg.Logger).Log("msg", "Authorized on account", "bot-name", bot.Self.UserName)
    u := tgbotapi.NewUpdate(0)
    u.Timeout = cfg.UpdateTime
    updates, err := bot.GetUpdatesChan(u)
    if err != nil {
        return nil, err
    }
    return &SNBot{
        cfg: cfg,
        bot: bot,
        upd: updates,
    }, nil
}

, , gocron. task gocron storage storage .

func task(bot *snbot.SNBot, s *storage.Storage, c *collector.Collector, logger kitlog.Logger) {
    c.Collect(collector.ConditionQuery{
        URI: "https://lovikod.ru/knigi/promokody-litres",
    })
    chats, err := s.GetChat()
    if err != nil {
        level.Error(logger).Log("msg", "failed get chats", "err", err)
    }
    for _, id := range chats {
        records, err := s.GetNotUseCoupon(id)
        if err != nil {
            level.Error(logger).Log("msg", "failed get coupons", "err", err)
            return
        }
        var msg string
        for i, rec := range records {
            msg = fmt.Sprintf("%v%v:\t%s \n--->: %s\n : %v\n: %s\n\n", msg, i+1, rec.Link, rec.Code, time.Unix(rec.Date, 0).Format("02.01.2006"), rec.Description)
        }
        if len(msg) != 0 {
            err = bot.Send(id, msg)
            if err != nil {
                level.Error(logger).Log("msg", "failed send message", "err", err)
                continue
            }
            err = s.MarkAsRead(id, records)
            if err != nil {
                level.Error(logger).Log("msg", "failed marked as read", "err", err)
                continue
            }
        }
    }
    level.Info(logger).Log("msg", "send all chats new coupons")
}

- , , , .

func (s *SNBot) Send(chatID int64, msg string) error {
    level.Error(s.cfg.Logger).Log("msg", "try send", "chatID", chatID)
    var numericKeyboard = tgbotapi.NewReplyKeyboard(
        tgbotapi.NewKeyboardButtonRow(
            tgbotapi.NewKeyboardButton("/print5"),
        ),
    )
    m := tgbotapi.NewMessage(chatID, msg)
    m.ReplyMarkup = numericKeyboard
    _, err := s.bot.Send(m)
    if err != nil {
        if err.Error() == errBlockedByUser {
            s.cfg.Storage.UpdChatActivity(chatID, false)
        }
        return err
    }
    return nil
}

  Dockerfile

,   .

# build binary
FROM golang:1.10.3-alpine3.8 AS build
RUN apk add --no-cache linux-headers gcc g++
ARG VERSION=dev
WORKDIR /go/src/github.com/wenkaler/xfreehack
COPY . /go/src/github.com/wenkaler/xfreehack
RUN CGO_ENABLED=1 go build \
    -o /out/xfree \
    -ldflags "-X main.serviceVersion=$VERSION" \
    github.com/wenkaler/xfreehack/cmd

# copy to alpine image
FROM alpine:3.8
WORKDIR /app
RUN mkdir /db
COPY --from=build /out/xfree /app
RUN apk add --no-cache tzdata
RUN apk --no-cache add ca-certificates
ENV TZ Europe/Moscow
RUN ln -snf /usr/share/zoneinfo/$TZ /etc/localtime && echo $TZ > /etc/timezone
CMD ["/app/xfree"]

Systemd

. 2.6, upgrad- systemd. ? — 3.

[Unit]
Description=Xfree service
After=network.target
After=network-online.target

[Service]
ExecStart=/urs/local/bin/xfree
Environment="TELEGRAM_TOKEN=$TELEGRAM_TOKEN" "PATH_DB=/db/xfree.db"
TimeoutSec=30
Restart=on-failure
RestartSec=30

[Install]
WantedBy=multi-user.target

 अब मेरी पत्नी खुश है कि वह लीटर पर मुफ्त किताबें प्राप्त कर सकती है, लेकिन मैं सिर्फ इस समस्या को हल करने के लिए इच्छुक था। अभी भी कुछ ऐसा है जिसे बेहतर किया जा सकता है, एक चेतावनी प्रणाली जोड़ें यदि MarkAsRead विफल हो जाता है, (अब तक ऐसा नहीं हुआ है, लेकिन आप कभी नहीं जानते हैं। , वह अब भी सदस्यता समाप्त करता है और अब उन लोगों को संदेश नहीं भेजता है जो उससे सदस्यता समाप्त कर चुके हैं और आपको फिर से / स्टार्ट कमांड दबाने के बाद उन्हें सक्रिय स्थिति में वापस करने की आवश्यकता है। खैर, सामान्य तौर पर, वितरण के समय और कूपन की पसंद का चयन करने की क्षमता जोड़ें, क्योंकि साइट में लाइटऑन से कूपन ही नहीं हैं। लेकिन यह सब आवश्यक है, अभी तक इस तरह के कोई आवेदन प्राप्त नहीं हुए हैं।

संदर्भ

1. खुद प्रोजेक्ट करें
2. कूपन वेबसाइट
3. बॉट नाम @xFreeCouponBot