新增日志

services/report2img.go

@@ -124,12 +124,14 @@ func CreateReportImgAndPdf(req Report2ImgQueueReq) {
 			errImg = fmt.Errorf("初始化OSS服务失败")
 			return
 		}
+		fmt.Println("start UploadFile")
 		si, e := ossClient.UploadFile(imgFileName, apiResult[0], "")
 		if e != nil {
+			fmt.Println("UploadFile,Err:" + err.Error())
 			errImg = fmt.Errorf("文件上传失败, Err: %s", e.Error())
 			return
 		}
-
+		fmt.Println("end UploadFile:" + imgFileName)
 		//if utils.ObjectStorageClient == "minio" {
 		//	si, e := UploadMinIoToDir(imgFileName, apiResult[0], uploadDir, fileDir)
 		//	if e != nil {
@@ -208,6 +210,8 @@ func CreateReportImgAndPdf(req Report2ImgQueueReq) {
 		return
 	}
 
+	fmt.Println("imgUrl:" + imgUrl + ";pdfUrl:" + pdfUrl)
+
 	// 更新报告链接
 	item.DetailImgUrl = imgUrl
 	item.DetailPdfUrl = pdfUrl

services/task.go

@@ -26,8 +26,12 @@ func ListenReport2ImgQueue() {
 	}()
 	for {
 		utils.Rc.Brpop(utils.CACHE_CREATE_REPORT_IMGPDF_QUEUE, func(b []byte) {
+			fmt.Println("ListenReport2ImgQueue Brpop:" + string(b))
 			var req Report2ImgQueueReq
-			_ = json.Unmarshal(b, &req)
+			err := json.Unmarshal(b, &req)
+			if err != nil {
+				fmt.Println("ListenReport2ImgQueue json.Unmarshal Err:" + err.Error())
+			}
 			CreateReportImgAndPdf(req)
 		})
 	}