|
@@ -5,7 +5,6 @@ import (
|
|
|
"encoding/json"
|
|
|
"fmt"
|
|
|
"hongze/hongze_task/models"
|
|
|
- "hongze/hongze_task/services/alarm_msg"
|
|
|
"hongze/hongze_task/utils"
|
|
|
"io/ioutil"
|
|
|
"net/http"
|
|
@@ -21,7 +20,8 @@ func DailyUpdateCompanyProfile(cont context.Context) (err error) {
|
|
|
defer func() {
|
|
|
if err != nil {
|
|
|
utils.FileLog.Info("DailyUpdateCompanyProfile ErrMsg: %s", err.Error())
|
|
|
- alarm_msg.SendAlarmMsg(fmt.Sprintf("每日更新客户档案失败, ErrMsg: %s", err.Error()), 3)
|
|
|
+ // 出错的话hongze_admin那边有报错, 这边只要定时请求了就行...
|
|
|
+ //alarm_msg.SendAlarmMsg(fmt.Sprintf("每日更新客户档案失败, ErrMsg: %s", err.Error()), 3)
|
|
|
}
|
|
|
}()
|
|
|
|
|
@@ -48,6 +48,10 @@ func DailyUpdateCompanyProfile(cont context.Context) (err error) {
|
|
|
err = fmt.Errorf("resp body read err: %s", e.Error())
|
|
|
return
|
|
|
}
|
|
|
+ if len(b) == 0 {
|
|
|
+ err = fmt.Errorf("resp body is empty")
|
|
|
+ return
|
|
|
+ }
|
|
|
// 解密
|
|
|
bo := utils.DesBase64Decrypt(b)
|
|
|
result := new(models.BaseResponse)
|