AnotherDay

파이썬으로 작성되었으며 데이터베이스는 오라클을 이용

오라클을 이용하기 위해 cx_Oracle 이 설치 되어 있어야됨.

#!/usr/bin/python
# -*-coding:utf-8-*-
import time
import cx_Oracle
import smtplib
import mimetypes
from email.mime.multipart import MIMEMultipart
from email.mime.text import MIMEText


__Author__ = "webprog.tistory.com"
__version__ = "0.1"

Db = ""  #데이터베이스 커넥터
mailFrom = "보내는 사람의 메일 주소"

class mailSend :

#생성자
    def __init__(self):
        global log
        self.setconfig()
        log = logger()
        log.info("Server Initialized Complete")

#소멸자
    def __del__(self):
    try :
        Db.close();
    except:
        print ""
    log.info("Server ShutDown ")

    ''' 시작 '''
    def start(self):
        while 1 :
            res = self.readyFetch()
            for row in res :
                self.mailInterface(row)
        log.info("Iddle Time")
            time.sleep(60)    #1분간 쉬어라
           
    ''' 데이터 베이스 환경 설정 '''
    def setconfig(self):
        global idfcDb
        cxO = cx_Oracle.makedsn("오라클 DBMS서버 IP", 1521, "ORCL")
        idfcDb = cx_Oracle.connect("데이터베이스아이디", "데이터베이스패스워드", cxO)
       
   
    ''' 전송할 메일이 있는지 쿼리 날려 보기 ~~ '''
    def readyFetch(self):
        qry = "SELECT * FROM MAILLING WHERE STATUS='READY' AND CREATETIME < SYSDATE"
        cur = Db.cursor()
        cur.execute(qry)
        res = cur.fetchall()
        cur.close()
        return res
   
    def getMailContent(self, contentsID):
        qry = "SELECT B.DESCHTML DESCHTML FROM CONTENTS C, BODY B WHERE C.CONTENTSID="+str(contentsID)+" AND B.CONTENTSID=C.CONTENTSID"
        cur = Db.cursor()
       
        cur.execute(qry)
       
        contents = ''
        ''' CLOB 타입처리를 위해 다음과 같이 처리 '''
        for val, in cur:
            contents += val.read().decode('cp949')
           
        cur.close()
        return contents
       
    ''' 메일 전송 결과에 따른 데이터베이스에 업데이트 하기 '''
    def resultUpdate(self,mailID, status):
        qry = "UPDATE MAILLING SET STATUS='"+status+"' WHERE MAILID="+str(mailID)
        cur = Db.cursor()
        cur.execute(qry)
        Db.commit()
        cur.close()
   
    def mailInterface(self, row):
        subject = row[6].decode('cp949')

       ''' 제목과 내용 부분에 #name#, #userid# 를 찾아서 회원의 이름과 아이디로 치환처리 '''
        if row[3] :
        subject = subject.replace('#name#',row[3].decode('cp949'))
        if row[2] :
        subject = subject.replace('#userid',row[2])

        contents = self.getMailContent(row[5])
      
        mailContents = contents
        if row[3] :
        mailContents = mailContents.replace('#name#',row[3].decode('cp949'))
        if row[2] :
        mailContents = mailContents.replace('#userid#', row[2])
        #log.info(mailContents.encode('cp949'))
        result = self.mailSend(row[4], subject, mailContents)
    if result :
        self.resultUpdate(row[0],'FAIL')
    else :
        self.resultUpdate(row[0],'SUCCESS')

  
    ''' 메일을 보낸다 '''
    def mailSend(self, mailTo, mailSubject, mailContents):
       log.info(mailTo)
       log.info(mailSubject.encode('cp949'))
        self.mailFrom = mailFrom
   
       self.mailMsg = MIMEMultipart('alternative')
       self.mailMsg['Subject'] = mailSubject
       self.mailMsg['From'] = self.mailFrom
       self.mailMsg['To'] = mailTo

       part = MIMEText(mailContents.encode('cp949'), 'html')
       self.mailMsg.attach(part)



    try :
            server = smtplib.SMTP('localhost')
            server.sendmail(self.mailFrom, mailTo, self.mailMsg.as_string()) #self.mailMsg.encode('cp949'))
            server.quit()
        except :
            logmsg = "SMTP failed"
            log.error(logmsg)
   
#디버깅을 하기위해 로그 클래스 정의  
class logger :
    def __init__(self):
        global fd
        fd = open(time.strftime("./log/%Y%m%d")+'.log','a+')
       
    def waring(self,msg):
        self.writing("WARNNING",msg)
   
    def info(self,msg):
        self.writing("INFO",msg)
   
    def debug(self,msg):
        self.writing("DEBUG",msg)

    def error(self,msg):
    self.writing("ERROR",msg)

    def writing(self,type,msg):
        fd.write(time.ctime() + " ["+type+"]: " + msg +'\n')
        fd.flush()
   
    def __del__(self):
        fd.close()

   
if __name__ == '__main__' :
    sender = mailSend()
    sender.start()

 <script>

$(document).ready(function(){
 imageResize();
});

function imageResize() {
 $('#bbsContents .bbsContentImg').each(function() {
     var oimg = new Image();
     oimg.src = this.src;
     if(oimg.width > 90) {
         $(this).attr({width:90});
     }
 });
}

</script>

<body>

<div id="bbsContents">

<img src=http://.....jpg class="bbsConentImg"/>

<img src=http://.....jpg class="bbsConentImg"/>

<img src=http://.....jpg class="bbsConentImg"/>

<img src=http://.....jpg class="bbsConentImg"/>

</div>

</dody>