wip:豆丁更新ossid

rpc/partnerlib/crontab/service/docinUpdate.go

@@ -21,12 +21,16 @@ func UpdateDocinInfos(b []byte) (err error, lastId int64, expectTotal, actualTot
 				//更新doc
 				for _, v := range docinInfos.Data {
 					var (
-						id  = fmt.Sprintf("%s-%d", entity.PartnerName, v.ProductId)
-						doc = sm.Doc{}
+						id     = fmt.Sprintf("%s-%d", entity.PartnerName, v.ProductId)
+						doc    = sm.Doc{}
+						nowStr = date.NowFormat(date.Date_Full_Layout)
 					)
+					if v.ModifyDate != "" {
+						nowStr = v.ModifyDate
+					}
 					lastId = v.ProductId
 					doc.Id = id
-					doc.UpdateDate, _ = time.ParseInLocation(date.Date_Full_Layout, v.ModifyDate, time.Local)
+					doc.UpdateDate, _ = time.ParseInLocation(date.Date_Full_Layout, nowStr, time.Local)
 					doc.Price = int(v.Price * entity.Multiple)
 					doc.PriceVip = v.PriceVip
 					doc.ProductType = int64(v.Ifcharge + entity.Charge)

rpc/partnerlib/service/docDownload.go

@@ -14,6 +14,7 @@ import (
 	"fmt"
 	"net/url"
 	"strings"
+	"time"
 )
 
 type DRes struct {
@@ -65,7 +66,11 @@ func DocDownload(in *partnerlib.UserDownloadRequest) (res *partnerlib.UDRes, err
 				if fileRes.OssDocId != "" {
 					res.OssDocId = fileId
 					//更新doc
-					if errUpdate := partner.DocsUpdate(0, model.Doc{Id: in.DocId, OssDocId: res.OssDocId}); errUpdate != nil {
+					if errUpdate := partner.DocsUpdate(0, model.Doc{
+						Id:         in.DocId,
+						OssDocId:   res.OssDocId,
+						UpdateDate: time.Now(),
+					}); errUpdate != nil {
 						warn.SendMsgByWXURL(fmt.Sprintf("文档id：%s,文档名称：%s 上传tidb doc 异常：%s", docInfo.Id, docInfo.DocName, err.Error()))
 					}
 					return