yfwlwCut/script_file/cbd_send_msg.py

from qcloudsms_py import SmsSingleSender
from qcloudsms_py.httpclient import HTTPError
from qcloudsms_py import SmsMultiSender
import os
import django

import sys

BASE_DIR = os.path.dirname(os.path.abspath(__file__))  # 定位到你的django根目录
sys.path.append(os.path.abspath(os.path.join(BASE_DIR, os.pardir)))

os.environ.setdefault("DJANGO_SETTINGS_MODULE",
                      "yfwlw_pro.settings")  # project_name 项目名称
django.setup()
import json
import time
import requests
import datetime
from apps.ReportManage.all_dict import mobile_list, insect_dict_new
from apps.AppInfoManage.models import Equip, Equip_type, CBDphoto, Msg_Send, Msg_Conf


# 短信应用 SDK AppID
appid = 1400227496  # SDK AppID 以1400开头
# 短信应用 SDK AppKey
appkey = "c9aba961bd30072f1e1b9272077abaea"
while True:
    
    end_date = datetime.datetime.now()
    one_day = datetime.timedelta(days=1)
    one_day_later = datetime.datetime.now() - one_day
    print(one_day_later)
    new_time = "%s-%s-%s %s:%s:%s" %(one_day_later.year,one_day_later.month,one_day_later.day,"19","00","00")
    start_date = datetime.datetime.strptime(new_time,"%Y-%m-%d %H:%M:%S")

    if end_date.hour == 8:
        msg_conf_list = Msg_Conf.objects.all()
        for i in msg_conf_list:
            cbd_obj = Equip.objects.get(equip_id=i.equip_id)
            equip_name = ""
            if cbd_obj.equip_name == "" or cbd_obj.equip_name == None:
                equip_name = cbd_obj.equip_id
            else:
                equip_name = cbd_obj.equip_name
            msgconf = eval(i.conf)

            # 害虫种类超限预警
            if msgconf["pestCategory"] == "on":
                photo_list = CBDphoto.objects.filter(equip_id=i.equip_id,upl_time__range=(start_date, end_date))
                pest_name = []
                pest_list = []
                for x in photo_list:
                    if x.indentify_result == None or x.indentify_result == "":
                        pass
                    else:
                        for a in x.indentify_result.split("#"):
                            pest_name.append(a.split(",")[0])
                for a in pest_name:
                    if a not in pest_list:
                        pest_list.append(a)
                if int(msgconf["pestCategoryNum"]) <= len(pest_list):
                    # 需要发送短信的手机号码
                    phone_numbers = msgconf["phone"]
                    # 短信模板ID，需要在短信控制台中申请
                    template_id = 456159  # NOTE: 这里的模板 ID`7839`只是示例，真实的模板 ID 需要在短信控制台中申请
                    # 签名
                    sms_sign = "云飞科技"  # NOTE: 签名参数使用的是`签名内容`，而不是`签名ID`。这里的签名"腾讯云"只是示例，真实的签名需要在短信控制台中申请

                    ssender = SmsSingleSender(appid, appkey)
                    params = [equip_name,one_day_later.strftime("%Y-%m-%d"),len(pest_list)]  # 当模板没有参数时，`params = []`
                    try:
                        result = ssender.send_with_param(86, phone_numbers,
                            template_id, params, sign=sms_sign, extend="", ext="")  # 签名参数未提供或者为空时，会使用默认签名发送短信
                    except HTTPError as e:
                        print(e)
                    except Exception as e:
                        print(e)
                    print(result)
                    Msg_Send.objects.create(mobile=msgconf["phone"],equip_id=i.equip_id,send_dec=params,result_desc=result)
                    pest_name = []
                    print("----发送成功")

            # 指定害虫监测
            if msgconf["appointPest"] == "on":
                pest_num = 0
                pest_name = []
                pest_nums = []
                pest_dict = {}
                pest_dict_new = {}

                cbd_list = CBDphoto.objects.filter(equip_id=i.equip_id,upl_time__range=(start_date, end_date))
                for x in cbd_list:
                    if x.indentify_result == None or x.indentify_result == "":
                        pass
                    else:
                        for a in x.indentify_result.split("#"):
                            pest_num = pest_num + int(a.split(",")[1])
                            pest_name.append(int(a.split(",")[0]))
                            pest_nums.append(int(a.split(",")[1]))


                for xx in range(len(pest_name)):
                    c = {pest_name[xx]:pest_nums[xx]}
                    for d in c:
                        if d in pest_dict:
                            pest_dict[d] = pest_dict[d] + c[d]
                        else:
                            pest_dict.update(c)
                print(pest_dict)
                send_dict = {}

                print(msgconf["appointPestName"].split("#"))
                print(msgconf["appointPestNum"].split("#"))
                msg_name = msgconf["appointPestName"].split("#")
                msg_num = msgconf["appointPestNum"].split("#")
                for i in range(len(msg_name)):
                    if int(msg_name[i]) != 0:
                        if pest_dict[int(msg_name[i])] > int(msg_num[i]):
                            aaa = {insect_dict_new[msg_name[i]]:"%s头"%int(msg_num[i])}
                            send_dict.update(aaa)
                print(send_dict)

                # 需要发送短信的手机号码
                phone_numbers = msgconf["phone"]
                # 短信模板ID，需要在短信控制台中申请
                template_id = 467892  # NOTE: 这里的模板 ID`7839`只是示例，真实的模板 ID 需要在短信控制台中申请
                # 签名
                sms_sign = "云飞科技"  # NOTE: 签名参数使用的是`签名内容`，而不是`签名ID`。这里的签名"腾讯云"只是示例，真实的签名需要在短信控制台中申请

                ssender = SmsSingleSender(appid, appkey)
                params = [equip_name,one_day_later.strftime("%Y-%m-%d"),send_dict]  # 当模板没有参数时，`params = []`
                try:
                    result = ssender.send_with_param(86, phone_numbers,
                        template_id, params, sign=sms_sign, extend="", ext="")  # 签名参数未提供或者为空时，会使用默认签名发送短信
                except HTTPError as e:
                    print(e)
                except Exception as e:
                    print(e)
                print(result)
                Msg_Send.objects.create(mobile=msgconf["phone"],equip_id=i.equip_id,send_dec=params,result_desc=result)
                pest_name = []
                print("----发送成功")
                send_dict = {}
                pest_num = 0
                pest_name = []
                pest_nums = []
                pest_dict = {}
                pest_dict_new = {}

            # 害虫总数超限预警
            if msgconf["pestTotal"] == "on":
                
                pest_num = 0
                pest_name = []
                pest_nums = []
                pest_dict = {}
                pest_dict_new = {}

                cbd_list = CBDphoto.objects.filter(equip_id=i.equip_id,upl_time__range=(start_date, end_date))
                for x in cbd_list:
                    if x.indentify_result == None or x.indentify_result == "":
                        pass
                    else:
                        for a in x.indentify_result.split("#"):
                            pest_num = pest_num + int(a.split(",")[1])
                            pest_name.append(int(a.split(",")[0]))
                            pest_nums.append(int(a.split(",")[1]))
                for xx in range(len(pest_name)):
                    c = {pest_name[xx]:pest_nums[xx]}
                    for d in c:
                        if d in pest_dict:
                            pest_dict[d] = pest_dict[d] + c[d]
                        else:
                            pest_dict.update(c)
                print(pest_dict)
                TotalNum = 0
                for a in pest_dict:
                    TotalNum = TotalNum + pest_dict[a]
                if TotalNum >= msgconf["pestTotalNum"]:
                    # 需要发送短信的手机号码
                    phone_numbers = msgconf["phone"]
                    # 短信模板ID，需要在短信控制台中申请
                    template_id = 456173  # NOTE: 这里的模板 ID`7839`只是示例，真实的模板 ID 需要在短信控制台中申请
                    # 签名
                    sms_sign = "云飞科技"  # NOTE: 签名参数使用的是`签名内容`，而不是`签名ID`。这里的签名"腾讯云"只是示例，真实的签名需要在短信控制台中申请

                    ssender = SmsSingleSender(appid, appkey)
                    params = [equip_name,one_day_later.strftime("%Y-%m-%d"),TotalNum]  # 当模板没有参数时，`params = []`
                    try:
                        result = ssender.send_with_param(86, phone_numbers,
                            template_id, params, sign=sms_sign, extend="", ext="")  # 签名参数未提供或者为空时，会使用默认签名发送短信
                    except HTTPError as e:
                        print(e)
                    except Exception as e:
                        print(e)
                    print(result)
                    Msg_Send.objects.create(mobile=msgconf["phone"],equip_id=i.equip_id,send_dec=params,result_desc=result)
                    pest_name = []
                    print("----发送成功")

                TotalNum = 0
                pest_num = 0
                pest_name = []
                pest_nums = []
                pest_dict = {}
                pest_dict_new = {}

            # 害虫总体预警
            if msgconf["pestWarn"] == "on":
                pest_num = 0
                pest_name = []
                pest_nums = []
                pest_dict = {}
                pest_dict_new = {}
                cbd_list = CBDphoto.objects.filter(equip_id=i.equip_id,upl_time__range=(start_date, end_date))
                # cbd_list = CBDphoto.objects.filter(equip_id=i.equip_id)
                for x in cbd_list:
                    if x.indentify_result == None or x.indentify_result == "":
                        pass
                    else:
                        for a in x.indentify_result.split("#"):
                            pest_num = pest_num + int(a.split(",")[1])
                            pest_name.append(int(a.split(",")[0]))
                            pest_nums.append(int(a.split(",")[1]))
                for xx in range(len(pest_name)):
                    c = {pest_name[xx]:pest_nums[xx]}
                    for d in c:
                        if d in pest_dict:
                            pest_dict[d] = pest_dict[d] + c[d]
                        else:
                            pest_dict.update(c)
                print(pest_dict)
                for k in pest_dict:
                    dict_b = {insect_dict_new[str(k)]:"%s头"%pest_dict[k]}
                    pest_dict_new.update(dict_b)
                cbd_obj = Equip.objects.get(equip_id=i.equip_id)
                # 需要发送短信的手机号码
                phone_numbers = msgconf["phone"]
                # 短信模板ID，需要在短信控制台中申请
                template_id = 435309  # NOTE: 这里的模板 ID`7839`只是示例，真实的模板 ID 需要在短信控制台中申请
                # 签名
                sms_sign = "云飞科技"  # NOTE: 签名参数使用的是`签名内容`，而不是`签名ID`。这里的签名"腾讯云"只是示例，真实的签名需要在短信控制台中申请

                ssender = SmsSingleSender(appid, appkey)
                params = [equip_name,one_day_later.strftime("%Y-%m-%d"),str(pest_dict_new)]  # 当模板没有参数时，`params = []`
                try:
                    result = ssender.send_with_param(86, phone_numbers,
                        template_id, params, sign=sms_sign, extend="", ext="")  # 签名参数未提供或者为空时，会使用默认签名发送短信
                except HTTPError as e:
                    print(e)
                except Exception as e:
                    print(e)
                print(result)
                print("害虫总数为",pest_num)
                Msg_Send.objects.create(mobile=phone_numbers,equip_id=i.equip_id,send_dec=params,result_desc=result)

                pest_num = 0
                pest_name = []
                pest_nums = []
                pest_dict = {}
                pest_dict_new = {}
                print("----发送成功")
    time.sleep(3600)