36 lines
1008 B
Go
36 lines
1008 B
Go
package Nmysql
|
|
|
|
import (
|
|
// "fmt"
|
|
l4g "proxy/logger"
|
|
)
|
|
|
|
func SetAlertSmsState2Sent(alertId int) error {
|
|
stmt, _ := MySqlDb.Prepare("update tb_sms_info set sms_state=2 where sms_alert_id=?;")
|
|
defer stmt.Close()
|
|
|
|
_, err := stmt.Exec(alertId)
|
|
if err != nil {
|
|
l4g.MysqlLog.Errorf("SetAlertSmsState2Sent err: %v", err)
|
|
return err
|
|
}
|
|
|
|
l4g.MysqlLog.Debugf("SetAlertSmsState2Sent succ!")
|
|
return nil
|
|
}
|
|
|
|
func InsertExpiredNotifySms(accountId uint32, planId uint32, expiredDate int64) error {
|
|
stmt, _ := MySqlDb.Prepare("INSERT into tb_sync_msg SET msg_type=1, acct_id=?, ofr_inst_id=?, exp_date=FROM_UNIXTIME(?), state=1;")
|
|
defer stmt.Close()
|
|
|
|
_, err := stmt.Exec(accountId, planId, expiredDate)
|
|
if err != nil {
|
|
l4g.MysqlLog.Errorf("InsertExpiredNotifySms acctId[%d], planId[%d], expiredDate[%d] err: %v", accountId, planId, expiredDate, err)
|
|
return err
|
|
}
|
|
|
|
l4g.MysqlLog.Debugf("InsertExpiredNotifySms acctId[%d], planId[%d], expiredDate[%d] succ!", accountId, planId, expiredDate)
|
|
return nil
|
|
}
|
|
|