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 }