package jdshop

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

	"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),
	}
	url, _ := api.JdShop2API.UploadImageNew(data, "2659335b16e3880e367759b8fc675933.tem.png")
	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"
	}
	var url2 string
	if store.Licence != "" {
		data2, _, _ := jxutils.DownloadFileByURL(store.Licence)
		fileName := store.Licence[strings.LastIndex(store.Licence, "/")+1 : len(store.Licence)]
		url2, _ = api.JdShop2API.UploadImageNew(data2, fileName)
	}
	storeName := store.Name
	if strings.Contains(storeName, "（") {
		storeName = storeName[0:strings.Index(storeName, "（")] + storeName[strings.Index(storeName, "）")+3:len(storeName)]
	}
	if strings.Contains(storeName, "(") {
		storeName = storeName[0:strings.Index(storeName, "(")] + storeName[strings.Index(storeName, ")")+3:len(storeName)]
	}
	if strings.Contains(storeName, ".") {
		storeName = strings.ReplaceAll(storeName, ".", "")
	}
	if strings.Contains(storeName, "-") {
		storeName = strings.ReplaceAll(storeName, "-", "")
	}
	if strings.Contains(storeName, " ") {
		storeName = strings.ReplaceAll(storeName, " ", "")
	}
	storeName = "京西菜市" + strings.ReplaceAll(storeName, "店", "") + "生鲜店"
	if len(storeName) > 30 {
		storeName = utils.LimitUTF8StringLen2(storeName, 30)
	}
	param := &jdshopapi.UpdateBasicParam{
		StoreName:          storeName,
		CategoryID2:        4,
		Coordinate:         utils.Float64ToStr(jxutils.IntCoordinate2Standard(store.Lat)) + "," + utils.Float64ToStr(jxutils.IntCoordinate2Standard(store.Lng)),
		BussinessBeginTime: int2TimeStr(int(store.OpenTime1)),
		BussinessEndTime:   int2TimeStr(int(store.CloseTime1)),
		ImgURL:             url,
		StorePhone:         store.Tel1,
		AddName:            store.Address,
		AddCode3:           store.JdsCode,
		CategoryID1:        3,
	}
	if url2 != "" {
		param.CategoryID1 = 34
		param.CategoryID2 = 62
		param.QualificationRequests = []*jdshopapi.QualificationRequests{
			&jdshopapi.QualificationRequests{
				QualificationID:   41,
				QualificationName: "营业执照",
				QualificationNo:   store.LicenceCode,
				QualificationURL:  url2,
				StartTime:         utils.Time2Str(utils.Str2Time(store.LicenceValid)),
				EndingTime:        ex,
				Time:              []string{utils.Time2Str(utils.Str2Time(store.LicenceValid)), ex},
			},
		}
	}
	if store.JdsStreetCode != 0 {
		createEntityStoreParam.AddCode = store.JdsStreetCode
		param.AddCode3 = store.JdsStreetCode
	}
	if createEntityStoreParam.AddCode == 0 {
		createEntityStoreParam.AddCode = store.JdCode
		param.AddCode3 = 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
										param.AddCode3 = vvv.AreaID
										break
									}
								}
							}
						}
					}
				}
			}
		}
	}
	vendorStoreID, err = api.JdShopAPI.CreateEntityStore(createEntityStoreParam)
	if vendorStroeID2, err := api.JdShop2API.SubmitBasic(param); err == nil {
		time.Sleep(time.Second)
		err = api.JdShop2API.UpdateExpand(int(vendorStroeID2))
		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",
		}
		err = dao.GetRow(db, &storeMap, sql, sqlParams)
		if storeMap != nil {
			storeMap.VendorStoreID = utils.Int64ToStr(vendorStroeID2)
			_, 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
}