jy_docs/rpc/partnerlib/crontab/service/docinUpdate.go

package service

import (
	"app.yhyue.com/moapp/jy_docs/rpc/partnerlib/entity"
	"app.yhyue.com/moapp/jy_docs/rpc/partnerlib/model"
	sm "app.yhyue.com/moapp/jy_docs/services/model"
	"app.yhyue.com/moapp/jy_docs/services/partner"
	"app.yhyue.com/moapp/jybase/date"
	"encoding/json"
	"fmt"
	"time"
)

func UpdateDocinInfos(b []byte) (err error, lastId int64, expectTotal, actualTotal int) {
	var docinInfos model.DocinInfoRes
	err = json.Unmarshal(b, &docinInfos)
	if err == nil {
		if expectTotal = len(docinInfos.Data); expectTotal > 0 {
			//更新doc
			for _, v := range docinInfos.Data {
				var (
					id  = fmt.Sprintf("%s-%d", entity.PartnerName, v.ProductId)
					doc = sm.Doc{}
				)
				lastId = v.ProductId
				doc.Id = id
				doc.UpdateDate, _ = time.ParseInLocation(date.Date_Full_Layout, v.ModifyDate, time.Local)
				doc.Price = int(v.Price * entity.Multiple)
				doc.PriceVip = v.PriceVip
				doc.ProductType = int64(v.Ifcharge + entity.Charge)
				doc.DownOrUp = v.State
				if err := partner.DocsUpdate(doc); err == nil {
					actualTotal++
				}
			}
		}
	}
	return
}