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 docinInfos.Code == 0 {
			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++
					}
				}
			}
		} else {
			err = fmt.Errorf(docinInfos.Msg)
		}
	}
	return
}