日志分割

rpc/biservice.go

@@ -14,6 +14,7 @@ import (
 	"bp.jydev.jianyu360.cn/BaseService/biService/rpc/pb"
 	"github.com/nsqio/go-nsq"
 	"github.com/zeromicro/go-zero/core/conf"
+	"github.com/zeromicro/go-zero/core/logx"
 	"github.com/zeromicro/go-zero/zrpc"
 	"google.golang.org/grpc"
 )
@@ -55,7 +56,7 @@ func main() {
 	s := zrpc.MustNewServer(c.RpcServerConf, func(grpcServer *grpc.Server) {
 		pb.RegisterBiServiceServer(grpcServer, srv)
 	})
-
+	logx.MustSetup(c.Logx)
 	defer s.Stop()
 
 	fmt.Printf("Starting rpc server at %s...\n", c.ListenOn)

service/clue.go

@@ -6,7 +6,6 @@ import (
 	"encoding/json"
 	"fmt"
 	"io/ioutil"
-	"log"
 	"math"
 	"net/http"
 	"net/url"
@@ -23,6 +22,7 @@ import (
 	"app.yhyue.com/moapp/jybase/es"
 	. "bp.jydev.jianyu360.cn/BaseService/biService/entity"
 	"bp.jydev.jianyu360.cn/BaseService/biService/rpc/biservice"
+	"github.com/zeromicro/go-zero/core/logx"
 )
 
 const (
@@ -70,19 +70,19 @@ func ClueImportTtSync(this *biservice.ClueImportReq) (string, int) {
 					id_new := common.GetMd5String(fmt.Sprintf("%s_%d", common.ObjToString(v["id"]), common.Int64All(v["multipackage_id"])))
 					v["id_new"] = id_new
 					if BiService.Count("customer_data_ttzl", map[string]interface{}{"id_new": id_new}) > 0 {
-						log.Println("数据重复", id)
+						logx.Info("数据重复", id)
 						return
 					}
 					if dataId := BiService.Insert("customer_data_ttzl", v); dataId > 0 {
 						if details, ok := CreateEs(v); ok {
 							BiService.Insert("customer_data_ttzl_gl", map[string]interface{}{"msg_id": dataId, "info_id": id, "details": details, "isHistory": "否"})
 							atomic.AddInt64(&counts, 1)
-							log.Println("es存入成功", id)
+							logx.Info("es存入成功", id)
 						} else {
-							log.Println("es存入失败！！", id)
+							logx.Info("es存入失败！！", id)
 						}
 					} else {
-						log.Println("tidb存入失败！！", id)
+						logx.Info("tidb存入失败！！", id)
 					}
 				}(v)
 			}
@@ -107,7 +107,7 @@ func ClueImportTtSync(this *biservice.ClueImportReq) (string, int) {
 func CreateEsById(newId string) bool {
 	data := BiService.FindOne("customer_data_ttzl", map[string]interface{}{"id_new": newId}, "", "")
 	if data == nil || len(*data) == 0 {
-		log.Println("没有找到该数据", newId)
+		logx.Info("没有找到该数据", newId)
 		return false
 	}
 	_, ok := CreateEs(*data)
@@ -144,7 +144,7 @@ func CreateEs(v map[string]interface{}) (string, bool) {
 	client.Delete().Index("ttbid").Id(newId).Refresh("true").Do(context.TODO())
 	_, err := client.Index().Index("ttbid").Id(newId).BodyJson(v).Refresh("true").Do(context.TODO())
 	if err != nil {
-		log.Println("保存到ES出错", err.Error())
+		logx.Info("保存到ES出错", err.Error())
 		return details, false
 	} else {
 		return details, true
@@ -157,7 +157,7 @@ func DelById(index, id string) bool {
 	defer esV7.DestoryEsConn(client)
 	_, err := client.Delete().Index(index).Id(id).Refresh("true").Do(context.TODO())
 	if err != nil {
-		log.Println("删除es出错:", id, err)
+		logx.Info("删除es出错:", id, err)
 		return false
 	}
 	return true
@@ -214,7 +214,7 @@ func ClueAdd(this *biservice.ClueAddReq, col string) *biservice.AddProjectResp {
 	bs, err := doGet(url)
 	if err != nil {
 		status = -1
-		log.Println("调用接口失败")
+		logx.Info("调用接口失败")
 	} else {
 		resMap := common.StringToMap(string(bs))
 		if resMap["success"] != nil && resMap["success"].(bool) {
@@ -235,7 +235,7 @@ func ClueAdd(this *biservice.ClueAddReq, col string) *biservice.AddProjectResp {
 
 func DistributeClue(this *biservice.DistributeClueReq) *biservice.AddProjectResp {
 	count, status := DistributeClueSync(this)
-	log.Println("分配数量 ", count)
+	logx.Info("分配数量 ", count)
 	return &biservice.AddProjectResp{
 		ErrorCode: 0,
 		Data: &biservice.AddProject{
@@ -249,7 +249,7 @@ func getToken() string {
 	url := "https://a1.7x24cc.com/accessToken?account=N000000029739&appid=w4w2ex0bnt1n61or&secret=3c8f7dd04d2c11edb786132b38c4d48a"
 	bs, err := doGet(url)
 	if err != nil {
-		log.Println("token生成失败", err)
+		logx.Info("token生成失败", err)
 		return ""
 	}
 	tokenMap := common.StringToMap(string(bs))
@@ -387,7 +387,7 @@ func DistributeClueMore(saleMap map[string]map[string]interface{}, distributedAr
 							"operator_id":  thispositionId,
 						})
 					} else {
-						log.Println("私海修改失败 ", v, positionId, seatNumber)
+						logx.Info("私海修改失败 ", v, positionId, seatNumber)
 					}
 				} else {
 					updateClue := map[string]interface{}{
@@ -477,7 +477,7 @@ func DistributeClueMore(saleMap map[string]map[string]interface{}, distributedAr
 							})
 						}
 					} else {
-						log.Println("私海插入失败 ", v, positionId, seatNumber)
+						logx.Info("私海插入失败 ", v, positionId, seatNumber)
 					}
 				}
 			}
@@ -488,7 +488,7 @@ func DistributeClueMore(saleMap map[string]map[string]interface{}, distributedAr
 
 func DrawClue(this *biservice.DrawClueReq) *biservice.AddProjectResp {
 	count, status := DrawClueSync(this)
-	log.Println("领取数量 ", count)
+	logx.Info("领取数量 ", count)
 	return &biservice.AddProjectResp{
 		ErrorCode: 0,
 		Data: &biservice.AddProject{
@@ -524,8 +524,8 @@ func DrawClueSync(this *biservice.DrawClueReq) (int, int) {
 			counts3 += counts2 - count2
 			counts2 = count2
 		}
-		log.Println(count1, count2)
-		log.Println(counts1, counts2, counts3)
+		logx.Info(count1, count2)
+		logx.Info(counts1, counts2, counts3)
 		return DrawClues(this.PositionId, counts1, counts2, counts3), 1
 	} else {
 		return 0, 2
@@ -758,10 +758,10 @@ func batchDraw(data []map[string]interface{}, nowTime, seatNumber, name string,
 			}
 			return ok1 && recordId > 0 && recordId1 > 0 && recordId2 > 0 && recordId3 > -1 && recordId4 > -1
 		}) {
-			log.Println("领取线索成功")
+			logx.Info("领取线索成功")
 			count++
 		} else {
-			log.Println("领取线索失败")
+			logx.Info("领取线索失败")
 		}
 	}
 	return count
@@ -1214,6 +1214,6 @@ func doGet(url string) ([]byte, error) {
 	defer func() {
 		_ = resp.Body.Close()
 	}()
-	log.Println(url, "调用结果 ", string(bs))
+	logx.Info(url, "调用结果 ", string(bs))
 	return bs, nil
 }

service/company.go

@@ -4,7 +4,6 @@ import (
 	"strconv"
 	"strings"
 
-	"log"
 	"sync"
 	"time"
 
@@ -12,6 +11,7 @@ import (
 	"app.yhyue.com/moapp/jybase/date"
 	. "bp.jydev.jianyu360.cn/BaseService/biService/entity"
 	"bp.jydev.jianyu360.cn/BaseService/biService/rpc/biservice"
+	"github.com/zeromicro/go-zero/core/logx"
 )
 
 // 判断是不是集团公司 判断在不在工商库 return 1集团公司 2工商库  3都是  -1都不是
@@ -66,7 +66,7 @@ func DistributeClueShow(this *biservice.DistributeClueShowReq) *biservice.Distri
 	clueArrs := []string{}
 	clueArrSync := &sync.Mutex{}
 	sql1 := `SELECT b.cluename,b.position_id,count(*) as count FROM dwd_f_crm_clue_info a INNER JOIN (SELECT cluename,position_id FROM dwd_f_crm_clue_info WHERE position_id in (` + strings.Join(pArr, ",") + `) AND id not in (` + this.ClueIdList + `) AND company_nature = 0 AND company_verification = 1 GROUP BY cluename) AS b ON a.cluename = b.cluename WHERE id in (` + this.ClueIdList + `) GROUP BY cluename`
-	log.Println("sql1 ", sql1)
+	logx.Info("sql1 ", sql1)
 	sdata := JyBiTidb.SelectBySql(sql1) //查这一批线索中属于当前分配人员的线索提前分配数量
 	if sdata != nil && len(*sdata) > 0 {
 		for _, v := range *sdata {
@@ -90,7 +90,7 @@ func DistributeClueShow(this *biservice.DistributeClueShowReq) *biservice.Distri
 		}
 	}
 	sql2 := `SELECT a.id,b.position_id FROM dwd_f_crm_clue_info a INNER JOIN (SELECT id,cluename,position_id FROM dwd_f_crm_clue_info WHERE position_id in (` + strings.Join(pArr, ",") + `) AND id not in (` + this.ClueIdList + `) AND company_nature = 0 AND company_verification = 1 GROUP BY cluename) AS b ON a.cluename = b.cluename WHERE a.id in (` + this.ClueIdList + `)`
-	log.Println("sql2 ", sql2) //查这一批线索中属于当前分配人员的线索id,分出去,并且排除掉
+	logx.Info("sql2 ", sql2) //查这一批线索中属于当前分配人员的线索id,分出去,并且排除掉
 	ldata := JyBiTidb.SelectBySql(sql2)
 	if ldata != nil && len(*ldata) > 0 {
 		wg := new(sync.WaitGroup)
@@ -126,10 +126,10 @@ func DistributeClueShow(this *biservice.DistributeClueShowReq) *biservice.Distri
 	} else {
 		clueArrs = strings.Split(this.ClueIdList, ",")
 	}
-	log.Println("clueArrs ", clueArrs)
+	logx.Info("clueArrs ", clueArrs)
 	if len(clueArrs) > 0 {
 		sql0 := `SELECT a.cluename,a.id,b.position_id FROM dwd_f_crm_clue_info a INNER JOIN (SELECT a.cluename,a.position_id FROM dwd_f_crm_clue_info a INNER JOIN dwd_f_crm_personnel_management b on a.position_id = b.position_id WHERE a.cluename in (SELECT cluename FROM dwd_f_crm_clue_info WHERE id in (` + strings.Join(clueArrs, ",") + `) GROUP BY cluename) AND a.id not in (` + strings.Join(clueArrs, ",") + `) AND b.resign = 1 GROUP BY a.cluename) as b on b.cluename = a.cluename where a.id in (` + strings.Join(clueArrs, ",") + `)`
-		log.Println("sql0", sql0)
+		logx.Info("sql0", sql0)
 		mdata := JyBiTidb.SelectBySql(sql0)
 		if mdata != nil && len(*mdata) > 0 {
 			nameMap := map[string][]int64{}
@@ -144,8 +144,8 @@ func DistributeClueShow(this *biservice.DistributeClueShowReq) *biservice.Distri
 				ids := strconv.FormatInt(id, 10)
 				idMap[ids] = true
 			}
-			log.Println("nameMap ", nameMap)
-			log.Println("namePMap ", namePMap)
+			logx.Info("nameMap ", nameMap)
+			logx.Info("namePMap ", namePMap)
 			for _, v := range clueArrs {
 				if !idMap[v] {
 					clueArrs1 = append(clueArrs1, v)
@@ -182,7 +182,7 @@ func DistributeClueShow(this *biservice.DistributeClueShowReq) *biservice.Distri
 							}
 						}
 					}
-					log.Println("RDATA ", rdata[sindex].CompanyCount, rdata[sindex].MinCount, rdata[sindex].CompanyCounts, rdata[sindex].ClueCount, len(v))
+					logx.Info("RDATA ", rdata[sindex].CompanyCount, rdata[sindex].MinCount, rdata[sindex].CompanyCounts, rdata[sindex].ClueCount, len(v))
 					if isOk {
 						if this.DataType == 1 {
 							rdata[sindex].CompanyCount++
@@ -199,17 +199,17 @@ func DistributeClueShow(this *biservice.DistributeClueShowReq) *biservice.Distri
 							}
 						}
 					}
-					log.Println("RDATA2 ", rdata[sindex].CompanyCount, rdata[sindex].MinCount, rdata[sindex].CompanyCounts, rdata[sindex].ClueCount, len(v))
+					logx.Info("RDATA2 ", rdata[sindex].CompanyCount, rdata[sindex].MinCount, rdata[sindex].CompanyCounts, rdata[sindex].ClueCount, len(v))
 				}
 			}
 		} else {
 			clueArrs1 = clueArrs
 		}
 	}
-	log.Println("clueArrs1 ", clueArrs1)
+	logx.Info("clueArrs1 ", clueArrs1)
 	if len(clueArrs1) > 0 {
 		sql3 := `SELECT cluename,COUNT(*) AS count FROM dwd_f_crm_clue_info WHERE id in (` + strings.Join(clueArrs1, ",") + `) GROUP BY cluename ORDER BY count desc`
-		log.Println("sql3 ", sql3) //从大到小排列这一列线索名称分组及数量情况
+		logx.Info("sql3 ", sql3) //从大到小排列这一列线索名称分组及数量情况
 		cdata := JyBiTidb.SelectBySql(sql3)
 		if cdata != nil && len(*cdata) > 0 {
 			for _, v := range *cdata {
@@ -380,7 +380,7 @@ func dclue(v, positionId, isTask, thispositionId int64) {
 					"operator_id":  thispositionId,
 				})
 			} else {
-				log.Println("私海修改失败 ", v, positionId, seatNumber)
+				logx.Info("私海修改失败 ", v, positionId, seatNumber)
 			}
 		} else {
 			updateClue := map[string]interface{}{
@@ -457,7 +457,7 @@ func dclue(v, positionId, isTask, thispositionId int64) {
 					})
 				}
 			} else {
-				log.Println("私海插入失败 ", v, positionId, seatNumber)
+				logx.Info("私海插入失败 ", v, positionId, seatNumber)
 			}
 		}
 	}

service/exprot.go

@@ -1,13 +1,8 @@
 package service
 
 import (
-	"app.yhyue.com/moapp/jybase/common"
-	"app.yhyue.com/moapp/jybase/mail"
 	"archive/zip"
-	. "bp.jydev.jianyu360.cn/BaseService/biService/entity"
 	"fmt"
-	"github.com/gogf/gf/v2/util/gconv"
-	"github.com/xuri/excelize/v2"
 	"io"
 	"log"
 	"math/rand"
@@ -15,6 +10,13 @@ import (
 	"path/filepath"
 	"strings"
 	"time"
+
+	"app.yhyue.com/moapp/jybase/common"
+	"app.yhyue.com/moapp/jybase/mail"
+	. "bp.jydev.jianyu360.cn/BaseService/biService/entity"
+	"github.com/gogf/gf/v2/util/gconv"
+	"github.com/xuri/excelize/v2"
+	"github.com/zeromicro/go-zero/core/logx"
 )
 
 var (
@@ -133,7 +135,7 @@ func dataHandle(writer *excelize.StreamWriter, l *[]map[string]interface{}, a in
 
 // 入excel
 func Warehousing(writer *excelize.StreamWriter, file *excelize.File, fileCounter int, key []interface{}, timeStr string) (*excelize.StreamWriter, *excelize.File, string) {
-	log.Println(fmt.Sprintf("开始第%d数据", fileCounter))
+	logx.Info(fmt.Sprintf("开始第%d数据", fileCounter))
 	writer.Flush()
 	folderPath := fmt.Sprintf("%s/%s", ExportDirectory, timeStr)
 	_, err := os.Stat(folderPath)
@@ -141,13 +143,13 @@ func Warehousing(writer *excelize.StreamWriter, file *excelize.File, fileCounter
 		//创建文件夹
 		err := os.MkdirAll(folderPath, os.ModePerm)
 		if err != nil {
-			log.Println("创建文件夹失败:", err)
+			logx.Info("创建文件夹失败:", err)
 		}
 	}
 	fileName := fmt.Sprintf("%s/output%d.xlsx", folderPath, fileCounter)
 	err = file.SaveAs(fileName)
 	if err != nil {
-		log.Println(err)
+		logx.Info(err)
 	}
 	writer, file = InirWrite(key)
 	return writer, file, fileName
@@ -174,13 +176,13 @@ func sendMail(title, target_mail string, path string) bool {
 	for k, v := range GmailAuth {
 		fool := mail.GSendMail("剑鱼标讯", target_mail, "", "", fmt.Sprintf("铁塔全量%s数据导出", title), html, "", "", v)
 		if fool {
-			log.Println(target_mail, fmt.Sprintf("使用%s发送邮件成功", v.User))
+			logx.Info(target_mail, fmt.Sprintf("使用%s发送邮件成功", v.User))
 			break
 		}
 		if k < len(GmailAuth)-1 {
-			log.Println(target_mail, fmt.Sprintf("使用%s发送邮件失败！3s后使用其他邮箱尝试", v.User))
+			logx.Info(target_mail, fmt.Sprintf("使用%s发送邮件失败！3s后使用其他邮箱尝试", v.User))
 		} else {
-			log.Println(target_mail, fmt.Sprintf("使用%s发送邮件失败！", v.User))
+			logx.Info(target_mail, fmt.Sprintf("使用%s发送邮件失败！", v.User))
 		}
 		time.Sleep(time.Second * 3)
 	}
@@ -195,7 +197,7 @@ func compressFiles(filePattern []string, timeStr string) string {
 		//创建文件夹
 		err := os.MkdirAll(folderPath, os.ModePerm)
 		if err != nil {
-			log.Println("创建文件夹失败:", err)
+			logx.Info("创建文件夹失败:", err)
 		}
 	}
 	zipFilename := fmt.Sprintf("%s/%s.zip", folderPath, timeStr)
@@ -319,13 +321,13 @@ func sendMailA(title, target_mail, content string, path string) bool {
 	for k, v := range GmailAuth {
 		fool := mail.GSendMail("剑鱼标讯", target_mail, "", "", fmt.Sprintf("%s数据导出", title), html, "", "", v)
 		if fool {
-			log.Println(target_mail, fmt.Sprintf("使用%s发送邮件成功", v.User))
+			logx.Info(target_mail, fmt.Sprintf("使用%s发送邮件成功", v.User))
 			break
 		}
 		if k < len(GmailAuth)-1 {
-			log.Println(target_mail, fmt.Sprintf("使用%s发送邮件失败！3s后使用其他邮箱尝试", v.User))
+			logx.Info(target_mail, fmt.Sprintf("使用%s发送邮件失败！3s后使用其他邮箱尝试", v.User))
 		} else {
-			log.Println(target_mail, fmt.Sprintf("使用%s发送邮件失败！", v.User))
+			logx.Info(target_mail, fmt.Sprintf("使用%s发送邮件失败！", v.User))
 		}
 		time.Sleep(time.Second * 3)
 	}

service/hlyj.go

@@ -3,18 +3,17 @@ package service
 import (
 	"context"
 	"encoding/json"
-	"log"
 	"time"
 
 	"app.yhyue.com/moapp/jybase/common"
 
-	"bp.jydev.jianyu360.cn/BaseService/biService/rpc/biservice"
-
 	"app.yhyue.com/moapp/jybase/date"
 	"app.yhyue.com/moapp/jybase/redis"
 	. "bp.jydev.jianyu360.cn/BaseService/biService/entity"
+	"bp.jydev.jianyu360.cn/BaseService/biService/rpc/biservice"
 	"github.com/gogf/gf/v2/frame/g"
 	"github.com/gogf/gf/v2/util/gconv"
+	"github.com/zeromicro/go-zero/core/logx"
 )
 
 type HlyjStruct struct {
@@ -60,7 +59,7 @@ func Get(url string, param map[string]interface{}) (str string) {
 	} else {
 		defer r.Close()
 		str = r.ReadAllString()
-		log.Println(url, "-", str)
+		logx.Info(url, "-", str)
 	}
 	return
 }
@@ -70,13 +69,13 @@ func (this *HlyjStruct) Call(phone string, positionId int64) string {
 	//获取token
 	// token := this.GetAccessToken()
 	// if token == "" {
-	// 	log.Println("未获取到token")
+	// 	logx.Info("未获取到token")
 	// 	return false
 	// }
 	//获取坐席id
 	integratedid, _ := getSeatNumber(positionId)
 	if integratedid == "" {
-		log.Println("未获取到坐席id")
+		logx.Info("未获取到坐席id")
 		return ""
 	}
 	id := JyBiTidb.Insert("call_history", map[string]interface{}{

service/infoService.go

@@ -1,21 +1,20 @@
 package service
 
 import (
+	"encoding/base64"
+	"encoding/json"
+
 	"app.yhyue.com/moapp/jybase/common"
 	"app.yhyue.com/moapp/jybase/redis"
 	"bp.jydev.jianyu360.cn/BaseService/biService/entity"
-	"encoding/base64"
-	"encoding/json"
 	"github.com/gogf/gf/v2/util/gconv"
 	"github.com/tjfoc/gmsm/sm4"
-	"log"
 )
 
 type InfoService struct {
 }
 
 func (l *InfoService) Myinfo(sid string) []byte {
-	log.Println("1111", sid)
 	infoMap := map[string]string{}
 	info_i := redis.Get("session", sid)
 	if info_i != nil {

service/operate.go

@@ -4,10 +4,10 @@ import (
 	"bytes"
 	"encoding/json"
 	"io/ioutil"
-	"log"
 	"net/http"
 
 	. "bp.jydev.jianyu360.cn/BaseService/biService/entity"
+	"github.com/zeromicro/go-zero/core/logx"
 )
 
 type Operate struct {
@@ -19,7 +19,7 @@ func (a *Operate) InfoOperate() bool {
 	//数据查询
 	data := BiService.FindOne("customer_data_ttzl", map[string]interface{}{"id_new": a.NewId}, "", "")
 	if data == nil || len(*data) == 0 {
-		log.Println("没有找到该数据", a.NewId)
+		logx.Info("没有找到该数据", a.NewId)
 		return false
 	}
 	sendParam := map[string]interface{}{
@@ -66,6 +66,6 @@ func DoPost(url string, body []byte) ([]byte, error) {
 	defer func() {
 		_ = resp.Body.Close()
 	}()
-	log.Println(url, "调用结果 ", string(bs))
+	logx.Info(url, "调用结果 ", string(bs))
 	return bs, nil
 }

service/sqlService.go

@@ -4,10 +4,11 @@ import (
 	"app.yhyue.com/moapp/jybase/common"
 	"app.yhyue.com/moapp/jybase/encrypt"
 
+	"fmt"
+
 	"app.yhyue.com/moapp/jybase/redis"
 	MC "bp.jydev.jianyu360.cn/BaseService/biService/entity"
 	"bp.jydev.jianyu360.cn/BaseService/biService/rpc/biservice"
-	"fmt"
 	"github.com/gogf/gf/v2/util/gconv"
 )
 

service/yearEndReport.go

@@ -2,7 +2,6 @@ package service
 
 import (
 	"fmt"
-	"log"
 	"strings"
 	"time"
 
@@ -10,6 +9,7 @@ import (
 	util "app.yhyue.com/moapp/jybase/encrypt"
 	. "bp.jydev.jianyu360.cn/BaseService/biService/entity"
 	"bp.jydev.jianyu360.cn/BaseService/biService/rpc/biservice"
+	"github.com/zeromicro/go-zero/core/logx"
 )
 
 func AddProject(this *biservice.AddProjectReq, addCountLimit int) *biservice.AddProjectResp {
@@ -26,11 +26,11 @@ func AddProject(this *biservice.AddProjectReq, addCountLimit int) *biservice.Add
 	}
 	for _, v := range infoIdArr {
 		infoid := util.DecodeArticleId2ByCheck(v)[0]
-		log.Println("infoid", infoid)
+		logx.Info("infoid", infoid)
 		query := `{"query": {"bool": {"must": [{"term": {"_id": "%s"}}],"must_not": [],"should": []}}}`
 		querys := fmt.Sprintf(query, infoid)
 		data := Es.Get("bidding", "bidding", querys)
-		// log.Println("data", data)
+		// logx.Info("data", data)
 		if data != nil && *data != nil && len(*data) > 0 {
 			project := (*data)[0]
 			nowTime := time.Now().Format("2006-01-02 15:04:05")