liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

新增方法，对比美团团和门店

Browse Source
This commit is contained in:
qidongsheng
2020-06-29 09:14:19 +08:00
parent 35b2cd951e
commit b297499b0d
1 changed files with 331 additions and 48 deletions
Download Patch File Download Diff File Expand all files Collapse all files

379
business/jxstore/cms/store_sku_check.go
View File

@@ -1,10 +1,15 @@
package cms
import (
"encoding/json"
"fmt"
"git.rosy.net.cn/baseapi/platformapi/dingdingapi"
"git.rosy.net.cn/cms"
"git.rosy.net.cn/jx-callback/business/jxutils/ddmsg"
"git.rosy.net.cn/jx-callback/globals/api"
"github.com/astaxie/beego"
"io/ioutil"
"net/http"
"strconv"
"strings"
"sync"
@@ -565,62 +570,340 @@ func CompareJxAndMultiVenderDepot(ctx *jxcontext.Context, vendorMap map[int]bool
}
func StoreOpenAll(ctx *jxcontext.Context) {
db := dao.GetDB()
StoreLists, err := dao.GetStoreList(db, nil, nil, []int{1}, nil, "")
if err != nil {
globals.SugarLogger.Debugf("商店列表获取失败")
/* 美团配送的门店营业状态，如果是休息，则京西这边不发单，如果是营业，京西这边状态就是发单
美团配送的门店营业状态要通过网页扒取（应该是接了的代码里要找一下）*/
/*获取门店信息*/
type DataList struct {
OuterPoiId string `json:"outerPoiId"` //店ID
PoiName string `json:"poiName"` //店名
OpenType int `json:"openType"` //营业状态 1是营业 0是休息
}
var StoreMapLists []*model.StoreMap
for _, StoreList := range StoreLists {
if StoreMapLists, err = dao.GetStoresMapList(db, []int{0, 1, 3}, []int{StoreList.ID}, nil, 1, -1, "", ""); err != nil {
globals.SugarLogger.Debugf("商店列表获取失败")
type jdData struct {
PageNum int `json:"pageNum"`
PageSize int `json:"pageSize"`
DataList []DataList `json:"dataList"`
}
type JdStore struct {
Code int `json:"code"`
Msg string `json:"msg"`
Data1 jdData `json:"data"`
}
client := &http.Client{}
var StoreInfoList []*JdStore
num := 1
for {
/* cookie还需要修改*/
/* context.TODO()*/
cookie := "_lxsdk_cuid=172c5ed322ac8-081f1f7ebdcbeb-f7d1d38-149c48-172c5ed322ac8; " +
"_lxsdk=172c5ed322ac8-081f1f7ebdcbeb-f7d1d38-149c48-172c5ed322ac8; " +
"uuid=fa1894be8819a84be4ef.1592458555.1.0.0; wm_order_channel=sjzxpc; " +
"cssVersion=82f258e3; utm_source=60376; au_trace_key_net=default; " +
"openh5_uuid=172c5ed322ac8-081f1f7ebdcbeb-f7d1d38-149c48-172c5ed322ac8; " +
"bmm-uuid=dbdc11bf-fcfe-84a0-0586-97e3d7d23ec7; " +
"token=-MfbU7noKEgDWuNA559DeG6LmYZ51CCiH8bYrH-eYuaugCOqJL7863lKoAWfx8HoydOzJE8r9gGM3QJ0IC3niA; " +
"_lxsdk_s=172fa436aed-861-103-c9b%7C%7C7"
url := "https://peisong.meituan.com/api/haikuiopen/haikui/open/partner/poi/search?pageSize=20&pageNum=" + strconv.Itoa(num) + ""
req, _ := http.NewRequest("POST", url, nil)
req.Header.Set("Cookie", cookie)
req.Header.Set("Referer", "https://peisong.meituan.com/open/admin/accountList")
res, _ := client.Do(req)
defer res.Body.Close()
if res.Body != nil {
StoreInfo := &JdStore{}
body, _ := ioutil.ReadAll(res.Body)
json.Unmarshal(body, StoreInfo)
StoreInfoList = append(StoreInfoList, StoreInfo)
if StoreInfo.Data1.DataList == nil {
break
}
num++
} else {
break
}
if len(StoreMapLists) > 0 {
/*将map查询的结果全部放进数组*/
for _, StoreMapList := range StoreMapLists {
/*二元运算符*/
StoreMapList.SyncStatus = StoreMapList.SyncStatus | model.SyncFlagModifiedMask
StoreMapList.UpdatedAt = time.Now()
StoreMapList.LastOperator = ctx.GetUserName()
dao.UpdateEntity(db, StoreMapList, "SyncStatus", "UpdatedAt", "LastOperator")
//}
/*同步*/
if _, err = CurVendorSync.SyncStore(ctx, db, StoreMapList.VendorID, StoreList.ID, false, ctx.GetUserName()); err != nil {
globals.SugarLogger.Debugf("同步失败")
}
/*StoreInfoList1 map[11691658]=1*/
StoreInfoList1 := make(map[string]int)
for _, store := range StoreInfoList {
for _, data := range store.Data1.DataList {
StoreInfoList1[data.OuterPoiId] = data.OpenType
}
}
/* fmt.Println(num)
fmt.Println(StoreInfoList)*/
db := dao.GetDB()
/*比较营业状态*/
StoreCourierList, err := dao.GetStoreCourierList(db, []int{0}, -9, -9)
for _, StoreCourierList1 := range StoreCourierList {
if _, ok := StoreInfoList1[StoreCourierList1.VendorStoreID]; ok {
/*营业状态是没有营业的，但是京西却关联美团了*/
if StoreInfoList1[StoreCourierList1.VendorStoreID] == 0 {
//调用方法解绑 {"status":0,"vendorStoreID":"667222"}
sl := make(map[string]interface{})
sl["status"] = 0
sl["vendorStoreID"] = "667222"
cms.UpdateStoreCourierMap(ctx, nil, StoreCourierList1.StoreID, StoreCourierList1.VendorID, sl, ctx.GetUserName())
}
}
}
/* 美团配送的门店是否存在，调用美团配送的api（有可能接了），查询京西门店对应的美团配送门店是否存在，若不存在则要在京西这边解绑美团配送门店
怎么解绑可以在网页上门店管理那点一下看看调的什么接口，传的什么参数*/
/*获取所有门店信息*/
StoreLists, err := dao.GetStoreList(db, nil, nil, []int{}, nil, "")
if err != nil {
globals.SugarLogger.Debug(err.Error())
}
for _, StoreList := range StoreLists {
StoreCourierList, err := dao.GetStoreCourierList(db, []int{StoreList.ID}, -9, -9)
if err != nil {
globals.SugarLogger.Debug(err.Error())
}
for _, StoreCourierList1 := range StoreCourierList {
if StoreCourierList1.VendorID != 102 {
continue
}
/*京西不为空*/
if StoreCourierList1.VendorStoreID != "" {
/*调用API获取美团的商店信息*/
MTPSInfo, _ := api.MtpsAPI.ShopQuery(StoreCourierList1.VendorStoreID)
if MTPSInfo.ShopID != "" {
if MTPSInfo.ShopName == StoreList.Name {
/*平台上有且名字相同*/
continue
} else {
/*平台上但是名字不同,解绑*/
if _, err := cms.DeleteStoreCourierMap(ctx, db, StoreCourierList1.StoreID, StoreCourierList1.VendorID, ctx.GetUserName()); err != nil {
globals.SugarLogger.Debug(err.Error())
return
}
}
} else {
/*美团平台上面没找到,解绑*/
if _, err := cms.DeleteStoreCourierMap(ctx, db, StoreCourierList1.StoreID, StoreCourierList1.VendorID, ctx.GetUserName()); err != nil {
globals.SugarLogger.Debug(err.Error())
return
}
//} else {
// 美团平台上有，京西没得，调用方法可能需要做一些修改
// context.TODO()
//}
}
}
}
if StoreMapLists, err = dao.GetStoresMapList(db, []int{9}, []int{StoreList.ID}, nil, 1, -1, "", ""); err != nil {
globals.SugarLogger.Debugf("商店列表获取失败")
}
if len(StoreMapLists) == 0 {
/*遍历，绑定*/
Map := &model.StoreMap{}
Map.VendorStoreID = strconv.Itoa(StoreList.ID)
Map.AutoPickup = 1
Map.DeliveryCompetition = 1
Map.PricePercentage = 100
Map.IsSync = 1
Map.PricePercentagePack = "京西100-100"
Map.DeliveryFeeDeductionSill = 0
Map.DeliveryFeeDeductionFee = 0
Map.IsOrder = 0
if _, err := AddStoreVendorMap(ctx, db, 9, "", StoreList.ID, Map); err != nil {
globals.SugarLogger.Debugf("AddStoreVendorMap调用出错，StoreID是" + strconv.Itoa(StoreList.ID))
globals.SugarLogger.Debugf(err.Error())
}
}
/*改配送范围*/
//deliverrangetype 3
//deliverrange 3000
StoreList.DeliveryRange = "3000"
StoreList.DeliveryRangeType = 3
StoreList.UpdatedAt = time.Now()
StoreList.LastOperator = ctx.GetUserName()
dao.UpdateEntity(db, StoreList, "DeliveryRange", "DeliveryRangeType", "LastOperator", "UpdatedAt")
/* 果园和菜市的门店ID可能有重复，导致在美团配送上建的门店只有一方的门店是生效的，可以根据ID在美团配送上查，查到是果园的店，那菜市的店则要重新绑定美团配送（要换一个美团配送的门店ID。不然要重复），
反之也要，可根据其他信息，比如门店名（传到平台上的规则都是一样的），坐标等判断是果园的还是菜市的*/
}
}
//func StoreOpenAll(ctx *jxcontext.Context) {
//db := dao.GetDB()
///*获取所有门店信息*/
//StoreLists, err := dao.GetStoreList(db, nil, nil, []int{}, nil, "")
//if err != nil {
// globals.SugarLogger.Debugf("商店列表获取失败")
//}
///*距离结构体*/
//type Distance struct {
// StoreID string `json:"门店ID"`
// StoreStatus string `json:"门店状态"`
// StoreName string `json:"门店名"`
// Tel string `json:"电话"`
// City string `json:"城市"`
// Address string `json:"地址"`
// DistanceId string `json:"附近门店ID"`
// DistanceStatus string `json:"附近门店状态"`
// DistanceName string `json:"附近门店名"`
// DistanceAddress string `json:"附近门店地址"`
// DistanceValue string `json:"距离附近门店距离(m)"`
//}
//distanceStore := make(map[int][]Distance)
//var isCloud []string
//var CloudBool bool
//for _, StoreList := range StoreLists {
// /*循环内部声明，1对多*/
// var a []Distance
// lng := jxutils.IntCoordinate2Standard(StoreList.Lng)
// lat := jxutils.IntCoordinate2Standard(StoreList.Lat)
// for _, StoreList1 := range StoreLists {
// if StoreList1.ID == StoreList.ID {
// continue
// }
// /*把s与提前存好的字段对比，如果相同说明 A+B=B+A的情况，直接跳过*/
// s := strconv.Itoa(StoreList1.ID) + strconv.Itoa(StoreList.ID)
// for _, x := range isCloud {
// if s == x {
// CloudBool = true
// break
// }
// }
// if CloudBool == true{
// CloudBool = false
// continue
// }
// lng1 := jxutils.IntCoordinate2Standard(StoreList1.Lng)
// lat1 := jxutils.IntCoordinate2Standard(StoreList1.Lat)
// if jxutils.EarthDistance(lng, lat, lng1, lat1) < 0.5 {
// //门店ID，门店名，电话，城市，地址，附近门店ID，附近门店名，距离附近门店距离（m)
// b := &Distance{
// strconv.Itoa(StoreList.ID),
// strconv.Itoa(StoreList.Status),
// StoreList.Name,
// StoreList.Tel1,
// strconv.Itoa(StoreList.CityCode),
// StoreList.Address,
// strconv.Itoa(StoreList1.ID),
// strconv.Itoa(StoreList1.Status),
// StoreList1.Name,
// StoreList1.Address,
// fmt.Sprintf("%.2f", jxutils.EarthDistance(lng, lat, lng1, lat1)*1000),
// }
// a = append(a, *b)
// distanceStore[StoreList.ID] = a
// isCloud = append(isCloud, strconv.Itoa(StoreList.ID)+strconv.Itoa(StoreList1.ID))
// }
// }
//}
//
////DistanceTitle := []string{
//// "门店ID",
//// "门店名",
//// "电话",
//// "城市",
//// "地址",
//// "附近门店ID",
//// "附近门店名",
//// "距离附近门店距离(m)",
////}
//fmt.Println(len(distanceStore))
//xlsx := excelize.NewFile()
//index := xlsx.NewSheet("Sheet1")
//xlsx.SetCellValue("Sheet1", "A1", "门店ID")
//xlsx.SetCellValue("Sheet1", "B1", "门店状态")
//xlsx.SetCellValue("Sheet1", "C1", "门店名")
//xlsx.SetCellValue("Sheet1", "D1", "电话")
//xlsx.SetCellValue("Sheet1", "E1", "城市")
//xlsx.SetCellValue("Sheet1", "F1", "地址")
//xlsx.SetCellValue("Sheet1", "G1", "附近门店ID")
//xlsx.SetCellValue("Sheet1", "H1", "附近门店状态")
//xlsx.SetCellValue("Sheet1", "I1", "附近门店名")
//xlsx.SetCellValue("Sheet1", "J1", "附近门店地址")
//xlsx.SetCellValue("Sheet1", "K1", "距离附近门店距离(M)")
//i := 2
//for _, value := range distanceStore {
// for _, value1 := range value {
// xlsx.SetCellValue("Sheet1", "A"+strconv.Itoa(i), value1.StoreID)
// xlsx.SetCellValue("Sheet1", "B"+strconv.Itoa(i), value1.StoreStatus)
// xlsx.SetCellValue("Sheet1", "C"+strconv.Itoa(i), value1.StoreName)
// xlsx.SetCellValue("Sheet1", "D"+strconv.Itoa(i), value1.Tel)
// xlsx.SetCellValue("Sheet1", "E"+strconv.Itoa(i), value1.City)
// xlsx.SetCellValue("Sheet1", "F"+strconv.Itoa(i), value1.Address)
// xlsx.SetCellValue("Sheet1", "G"+strconv.Itoa(i), value1.DistanceId)
// xlsx.SetCellValue("Sheet1", "H"+strconv.Itoa(i), value1.DistanceStatus)
// xlsx.SetCellValue("Sheet1", "I"+strconv.Itoa(i), value1.DistanceName)
// xlsx.SetCellValue("Sheet1", "J"+strconv.Itoa(i), value1.DistanceAddress)
// xlsx.SetCellValue("Sheet1", "K"+strconv.Itoa(i), value1.DistanceValue)
// i++
// }
//}
//// Set active sheet of the workbook.
//xlsx.SetActiveSheet(index)
//// Save xlsx file by the given path.
//err = xlsx.SaveAs("C:\\Users\\86159\\Desktop\\WorkForTemp\\距离小于500米门店信息.xlsx")
//if err != nil {
// fmt.Println(err)
//}
//var sheetList []*excel.Obj2ExcelSheetConfig
//sheetName := "附近500米门店信息"
//for _, value := range distanceStore {
// excelConf := &excel.Obj2ExcelSheetConfig{
// Title: sheetName,
// Data: value,
// CaptionList: DistanceTitle,
// }
// file,err := os.OpenFile("C:\\Users\\86159\\Desktop\\WorkForTemp\\haha.txt",os.O_APPEND|os.O_RDWR,6660)
// if err != nil{
// fmt.Println(err.Error())
// }
// file.WriteString(fmt.Sprintln(excelConf.Data))
// sheetList = append(sheetList, excelConf)
// baseapi.SugarLogger.Debugf("WriteToExcel:append:%s count:%d", sheetName, len(value))
//}
//if len(sheetList) > 0 {
// excelBin := excel.Obj2Excel(sheetList)
// sheetList = nil
// timeStr := utils.Int64ToStr(time.Now().Unix())
// diffFullFileName := "附近500米门店信息数据" + timeStr + fileExt
// baseapi.SugarLogger.Debugf("WriteToExcel:save %s success", diffFullFileName)
// //上传
// downloadURL, err := jxutils.UploadExportContent(excelBin, diffFullFileName)
// if err != nil {
// baseapi.SugarLogger.Errorf("WriteToExcel:upload %s failed error:%v", diffFullFileName, err)
// } else {
// baseapi.SugarLogger.Debugf("WriteToExcel:upload %s success, downloadURL: %s", diffFullFileName, downloadURL)
// /*************发送钉钉消息**************/
// //ddmsg.SendUserMessage(dingdingapi.MsgTyeText, "", "异步任务完成", "附近500米门店信息数据上传成功：Excel下载地址是 "+downloadURL)
// }
//} else {
// baseapi.SugarLogger.Debug("WriteToExcel:No diff data!!!")
//}
//}
//}func StoreOpenAll(ctx *jxcontext.Context) {
// db := dao.GetDB()
// StoreLists, err := dao.GetStoreList(db, nil, nil, []int{1}, nil, "")
// if err != nil {
// globals.SugarLogger.Debugf("商店列表获取失败")
// }
// var StoreMapLists []*model.StoreMap
// for _, StoreList := range StoreLists {
// if StoreMapLists, err = dao.GetStoresMapList(db, []int{0, 1, 3}, []int{StoreList.ID}, nil, 1, -1, "", ""); err != nil {
// globals.SugarLogger.Debugf("商店列表获取失败")
// }
// if len(StoreMapLists) > 0 {
// /*将map查询的结果全部放进数组*/
// for _, StoreMapList := range StoreMapLists {
// /*二元运算符*/
// StoreMapList.SyncStatus = StoreMapList.SyncStatus | model.SyncFlagModifiedMask
// StoreMapList.UpdatedAt = time.Now()
// StoreMapList.LastOperator = ctx.GetUserName()
// dao.UpdateEntity(db, StoreMapList, "SyncStatus", "UpdatedAt", "LastOperator")
// //}
// /*同步*/
// if _, err = CurVendorSync.SyncStore(ctx, db, StoreMapList.VendorID, StoreList.ID, false, ctx.GetUserName()); err != nil {
// globals.SugarLogger.Debugf("同步失败")
// }
// }
// }
// if StoreMapLists, err = dao.GetStoresMapList(db, []int{9}, []int{StoreList.ID}, nil, 1, -1, "", ""); err != nil {
// globals.SugarLogger.Debugf("商店列表获取失败")
// }
// if len(StoreMapLists) == 0 {
// /*遍历，绑定*/
// Map := &model.StoreMap{}
// Map.VendorStoreID = strconv.Itoa(StoreList.ID)
// Map.AutoPickup = 1
// Map.DeliveryCompetition = 1
// Map.PricePercentage = 100
// Map.IsSync = 1
// Map.PricePercentagePack = "京西100-100"
// Map.DeliveryFeeDeductionSill = 0
// Map.DeliveryFeeDeductionFee = 0
// Map.IsOrder = 0
// if _, err := AddStoreVendorMap(ctx, db, 9, "", StoreList.ID, Map); err != nil {
// globals.SugarLogger.Debugf("AddStoreVendorMap调用出错，StoreID是" + strconv.Itoa(StoreList.ID))
// globals.SugarLogger.Debugf(err.Error())
// }
// }
// /*改配送范围*/
// //deliverrangetype 3
// //deliverrange 3000
// StoreList.DeliveryRange = "3000"
// StoreList.DeliveryRangeType = 3
// StoreList.UpdatedAt = time.Now()
// StoreList.LastOperator = ctx.GetUserName()
// dao.UpdateEntity(db, StoreList, "DeliveryRange", "DeliveryRangeType", "LastOperator", "UpdatedAt")
// }
//}
func TestDiff(ctx *jxcontext.Context, vendorIDList []int, storeIDList []int) {
baseapi.SugarLogger.Debugf("CheckSkuDiffBetweenJxAndVendor start time: %v", time.Now())
startProcessTime := time.Now().Unix()