package jdshop

import (
	"encoding/base64"
	"encoding/json"
	"fmt"
	"strings"

	"git.rosy.net.cn/baseapi/platformapi/jdshopapi"
	"git.rosy.net.cn/baseapi/utils"
	"git.rosy.net.cn/jx-callback/business/jxutils"
	"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
	"git.rosy.net.cn/jx-callback/business/jxutils/tasksch"
	"git.rosy.net.cn/jx-callback/business/model"
	"git.rosy.net.cn/jx-callback/business/model/dao"
	"git.rosy.net.cn/jx-callback/globals/api"
)

func (p *PurchaseHandler) ReadStore(ctx *jxcontext.Context, vendorOrgCode, vendorStoreID string) (storeDetail *dao.StoreDetail, err error) {
	// result, err := api.JdShopAPI.NewInfoList(utils.Str2Int64(vendorStoreID))
	// storeDetail.VendorStoreID = vendorStoreID
	// storeDetail.Status = JdsStatus2jxStatus(result.StoreStatus)
	result2, err := api.JdShopAPI.QueryEntityStore(utils.Str2Int64(vendorStoreID))
	if result2 == nil {
		return storeDetail, fmt.Errorf("未查询到该平台门店，平台门店ID：[%v]", vendorStoreID)
	}
	storeDetail = &dao.StoreDetail{}
	storeDetail.ID = utils.Str2Int(result2.ExStoreID)
	storeDetail.Name = result2.StoreName
	storeDetail.Address = result2.Address
	storeDetail.Tel1 = result2.Phone
	storeDetail.DistrictCode = result2.AddrCode
	zbs := strings.Split(result2.Coordinate, ",")
	storeDetail.Lat = jxutils.StandardCoordinate2Int(utils.Str2Float64(zbs[0]))
	storeDetail.Lng = jxutils.StandardCoordinate2Int(utils.Str2Float64(zbs[1]))
	return storeDetail, err
}

// stoerIDs为nil表示所有
func (p *PurchaseHandler) UpdateStore(db *dao.DaoDB, storeID int, userName string) (err error) {
	store, err := dao.GetStoreDetail(db, storeID, model.VendorIDJDShop, "")
	if err != nil {
		return err
	}
	data, _, err := jxutils.DownloadFileByURL(jdshopapi.JdsStoreImg)
	timeMap := map[string]string{
		"businessBeginTime": int2TimeStr(int(store.OpenTime1)),
		"businessEndTime":   int2TimeStr(int(store.CloseTime1)),
	}
	timeJSON, _ := json.Marshal(timeMap)
	updateEntityStoreParam := &jdshopapi.UpdateEntityStoreParam{
		StoreID:     utils.Str2Int(store.VendorStoreID),
		Name:        store.Name,
		AddCode:     store.JdsCode,
		AddCodeName: store.DistrictName,
		AddName:     store.ProvinceName + store.CityName + store.DistrictName + "@!" + store.Address,
		Coordinate:  utils.Float64ToStr(jxutils.IntCoordinate2Standard(store.Lat)) + "," + utils.Float64ToStr(jxutils.IntCoordinate2Standard(store.Lng)),
		Phone:       store.Tel1,
		ExtendJSON:  string(timeJSON),
		ImageFile:   base64.StdEncoding.EncodeToString(data),
		CustomerID:  utils.Int2Str(store.ID),
	}
	if store.JdsStreetCode != 0 {
		updateEntityStoreParam.AddCode = store.JdsStreetCode
	}
	if updateEntityStoreParam.AddCode == 0 {
		updateEntityStoreParam.AddCode = store.JdCode
	}
	err = api.JdShopAPI.UpdateEntityStore(updateEntityStoreParam)
	if err == nil {
		// if store.SyncStatus&(model.SyncFlagNewMask|model.SyncFlagStoreStatus) != 0 {
		// 	mergeStatus := jxutils.MergeStoreStatus(store.Status, store.VendorStatus)
		// 	err = api.JdShopAPI.UpdateStoreStatus(utils.Str2Int(store.VendorStoreID), jxStatus2JdsStatus(mergeStatus))
		// }
	}
	return err
}

func (p *PurchaseHandler) CreateStore2(db *dao.DaoDB, storeID int, userName string) (vendorStoreID string, err error) {
	store, err := dao.GetStoreDetail(db, storeID, model.VendorIDJDShop, "")
	if err != nil {
		return vendorStoreID, err
	}
	data, _, err := jxutils.DownloadFileByURL(jdshopapi.JdsStoreImg)
	timeMap := map[string]string{
		"businessBeginTime": int2TimeStr(int(store.OpenTime1)),
		"businessEndTime":   int2TimeStr(int(store.CloseTime1)),
	}
	timeJSON, _ := json.Marshal(timeMap)
	createEntityStoreParam := &jdshopapi.CreateEntityStoreParam{
		Name:         store.Name,
		AddCode:      store.JdsCode,
		AddCodeName:  store.DistrictName,
		AddName:      store.ProvinceName + store.CityName + store.DistrictName + "@!" + store.Address,
		Coordinate:   utils.Float64ToStr(jxutils.IntCoordinate2Standard(store.Lat)) + "," + utils.Float64ToStr(jxutils.IntCoordinate2Standard(store.Lng)),
		Phone:        store.Tel1,
		ExtendJSON:   string(timeJSON),
		ImageFile:    base64.StdEncoding.EncodeToString(data),
		CategoryName: jdshopapi.JdsStoreCategoryName,
		CustomerID:   utils.Int2Str(store.ID),
	}
	createEntityStoreParam2 := &jdshopapi.CreateEntityStoreParam{
		Name:         "京西菜市" + strings.ReplaceAll(store.Name, "店", "") + "生鲜店",
		AddCode:      store.JdsCode,
		AddCodeName:  store.DistrictName,
		AddName:      store.ProvinceName + store.CityName + store.DistrictName + "@!" + store.Address,
		Coordinate:   utils.Float64ToStr(jxutils.IntCoordinate2Standard(store.Lat)) + "," + utils.Float64ToStr(jxutils.IntCoordinate2Standard(store.Lng)),
		Phone:        store.Tel1,
		ExtendJSON:   string(timeJSON),
		ImageFile:    base64.StdEncoding.EncodeToString(data),
		CategoryName: "生鲜店",
		CustomerID:   utils.Int2Str(store.ID),
	}
	if store.JdsStreetCode != 0 {
		createEntityStoreParam.AddCode = store.JdsStreetCode
		createEntityStoreParam2.AddCode = store.JdsStreetCode
	}
	if createEntityStoreParam.AddCode == 0 {
		createEntityStoreParam.AddCode = store.JdCode
		createEntityStoreParam2.AddCode = store.JdCode
	}
	//证明这个店可能隶属直辖市或者东莞
	if model.ZXCityCodeMap[store.CityCode] != "" {
		result, _ := api.AutonaviAPI.GetCoordinateAreaInfo(jxutils.IntCoordinate2Standard(store.Lng), jxutils.IntCoordinate2Standard(store.Lat))
		if result["regeocode"] != nil {
			street := result["regeocode"].(map[string]interface{})["addressComponent"].(map[string]interface{})["township"].(string)
			if street != "" {
				result1, _ := api.JdShopAPI.GetProvince()
				for _, v := range result1 {
					if strings.Contains(store.CityName, v.AreaName) {
						result2, _ := api.JdShopAPI.GetCity(v.AreaID)
						for _, vv := range result2 {
							if strings.Contains(store.DistrictName, vv.AreaName) {
								result3, _ := api.JdShopAPI.GetCounty(vv.AreaID)
								for _, vvv := range result3 {
									if street == vvv.AreaName {
										createEntityStoreParam.AddCode = vvv.AreaID
										createEntityStoreParam2.AddCode = vvv.AreaID
										break
									}
								}
							}
						}
					}
				}
			}
		}
	}
	vendorStoreID, err = api.JdShopAPI.CreateEntityStore(createEntityStoreParam)
	vendorStoreID2, _ := api.JdShop2API.CreateEntityStore(createEntityStoreParam2)
	if shopDetailResult, err := api.JdShop2API.ShopDetail(utils.Str2Int(vendorStoreID2)); err == nil {
		if store.Licence != "" {
			var storeName string
			data, _, _ := jxutils.DownloadFileByURL(store.Licence)
			fileName := store.Licence[strings.LastIndex(store.Licence, "/")+1 : len(store.Licence)]
			url, _ := api.JdShop2API.UploadImageNew(data, fileName)
			ex := store.LicenceExpire
			if ex == "" {
				ex = utils.Time2Str(utils.Str2Time(store.LicenceValid).AddDate(0, 6, 0))
			}
			if !strings.Contains(ex, "00:00:00") {
				ex += " 00:00:00"
			}
			if strings.Contains(store.Name, "（") {
				storeName = store.Name[0:strings.Index(store.Name, "（")] + store.Name[strings.Index(store.Name, "）")+3:len(store.Name)]
			}
			if strings.Contains(store.Name, ".") {
				storeName = store.Name[0:strings.Index(store.Name, ".")] + store.Name[strings.Index(store.Name, ".")+1:len(store.Name)]
			}
			err = api.JdShop2API.UpdateBasic(&jdshopapi.UpdateBasicParam{
				StoreID:            utils.Str2Int(vendorStoreID2),
				StoreName:          storeName,
				CategoryID2:        62,
				Coordinate:         shopDetailResult.Coordinate,
				BussinessBeginTime: shopDetailResult.BussinessBeginTime,
				BussinessEndTime:   shopDetailResult.BussinessEndTime,
				ImgURL:             shopDetailResult.ImgURL,
				StorePhone:         shopDetailResult.StorePhone,
				AddName:            shopDetailResult.AddName,
				AddCode1:           shopDetailResult.AddCode1,
				AddCode2:           shopDetailResult.AddCode2,
				AddCode3:           shopDetailResult.AddCode3,
				CategoryID1:        34,
				QualificationRequests: []*jdshopapi.QualificationRequests{
					&jdshopapi.QualificationRequests{
						QualificationID:   41,
						QualificationName: "营业执照",
						QualificationNo:   store.LicenceCode,
						QualificationURL:  url,
						StartTime:         utils.Time2Str(utils.Str2Time(store.LicenceValid)),
						EndingTime:        ex,
						Time:              []string{utils.Time2Str(utils.Str2Time(store.LicenceValid)), ex},
					},
				},
			})
			if err == nil {
				var storeMap *model.StoreMap
				sql := ` 
					SELECT * FROM store_map WHERE deletad_at = ? AND store_id = ? AND vendor_id = ? AND vendor_org_code = ? 
				`
				sqlParams := []interface{}{
					utils.DefaultTimeValue, storeID, model.VendorIDJDShop, "2",
				}
				if err = dao.GetRow(db, &storeMap, sql, sqlParams); err == nil {
					if storeMap != nil {
						storeMap.VendorStoreID = vendorStoreID2
						_, err = dao.UpdateEntity(db, storeMap, "VendorStoreID")
					}
				}
			}
		}
	}
	return vendorStoreID, err
}

func (p *PurchaseHandler) DeleteStore(db *dao.DaoDB, storeID int, userName string) (err error) {
	// store, err := dao.GetStoreDetail(db, storeID, model.VendorIDJDShop)
	// if err != nil {
	// 	return err
	// }
	// err = api.JdShopAPI.DeleteStoresByID(utils.Str2Int64(store.VendorStoreID))
	return err
}

func (p *PurchaseHandler) RefreshAllStoresID(ctx *jxcontext.Context, parentTask tasksch.ITask, isAsync bool) (hint string, err error) {
	return hint, err
}

func (p *PurchaseHandler) GetStoreStatus(ctx *jxcontext.Context, vendorOrgCode string, storeID int, vendorStoreID string) (storeStatus int, err error) {
	return storeStatus, err
}

func (p *PurchaseHandler) EnableAutoAcceptOrder(ctx *jxcontext.Context, vendorOrgCode string, storeID int, vendorStoreID string, isSetEnable bool) (err error) {
	return err
}

func (c *PurchaseHandler) UpdateStoreStatus(ctx *jxcontext.Context, vendorOrgCode string, storeID int, vendorStoreID string, status int) (err error) {
	return err
}

func (c *PurchaseHandler) UpdateStoreOpTime(ctx *jxcontext.Context, vendorOrgCode string, storeID int, vendorStoreID string, opTimeList []int16) (err error) {
	return err
}

func (c *PurchaseHandler) GetAllStoresVendorID(ctx *jxcontext.Context, vendorOrgCode string) (vendorStoreIDs []string, err error) {
	return vendorStoreIDs, err
}

func (c *PurchaseHandler) UpdateStoreCustomID(ctx *jxcontext.Context, vendorOrgCode, vendorStoreID string, storeID int64) (err error) {
	return err
}

func int2TimeStr(time int) (str string) {
	str += utils.Int2Str(time / 1000)
	str += utils.Int2Str(time % 1000 / 100)
	str += ":"
	str += utils.Int2Str(time % 100 / 10)
	str += utils.Int2Str(time % 10)
	return str
}

func jxStatus2JdsStatus(status int) (result int) {
	if status == model.StoreStatusOpened {
		result = jdshopapi.JdsStoreStatusOnline
	} else if status == model.StoreStatusHaveRest || status == model.StoreStatusClosed {
		result = jdshopapi.JdsStoreStatusRest
	} else {
		result = jdshopapi.JdsStoreStatusDisable
	}
	return result
}

func JdsStatus2jxStatus(status int) (result int) {
	if status == jdshopapi.JdsStoreStatusOnline {
		result = model.StoreStatusOpened
	} else if status == jdshopapi.JdsStoreStatusRest {
		result = model.StoreStatusClosed
	} else {
		result = model.StoreStatusDisabled
	}
	return result
}