zyos_camp_task/back/one/main.go

package main

import (
	"applet/app/cfg"
	"applet/app/comm/db"
	db2 "code.fnuoos.com/go_rely_warehouse/zyos_go_order_relate_rule.git/db"
	"code.fnuoos.com/go_rely_warehouse/zyos_go_order_relate_rule.git/db/model"
	"code.fnuoos.com/go_rely_warehouse/zyos_go_order_relate_rule.git/md"
	"code.fnuoos.com/go_rely_warehouse/zyos_go_order_relate_rule.git/rule"
	"fmt"
	"sort"
	"strconv"
)

// 系统初始化
func init() {
	cfg.InitCfg()   //配置初始化
	cfg.InitLog()   //日志初始化
	cfg.InitCache() //缓存初始化
	if cfg.Debug {  //判断是否是debug
		if err := db.InitDB(cfg.DB); err != nil { //主数据库初始化
			panic(err)
		}
		//channel := make(chan int, 0) //开辟管道，缓冲为
		////go model.InitDBs(channel)
		//<-channel
	}
	fmt.Println("init success")

}

func main() {
	data1, err := db2.UserSmallPublicPlatoonRelationCopyFindByParams(db.Db, map[string]interface{}{
		"key":   nil,
		"value": "",
	})
	if err != nil {
		fmt.Println(">>>>>>>>>>>>>", err)
	}
	data2, err := db2.UserSmallPublicPlatoonRelationFindByParams(db.Db, map[string]interface{}{
		"key":   nil,
		"value": "",
	})
	if err != nil {
		fmt.Println(">>>>>>>>>>>>>", err)
	}
	var mapData2 = map[int]model.UserSmallPublicPlatoonRelationCopy{}
	var mapData1 = map[int]interface{}{}
	for _, v := range *data2 {
		mapData1[v.Uid] = v
	}
	for _, v := range *data1 {
		mapData2[v.Uid] = v
	}

	var mapData3 = map[int]model.UserSmallPublicPlatoonRelationCopy{}
	for k, v := range mapData2 {
		if mapData1[k] == nil {
			mapData3[v.Uid] = v
		}
	}
	var keys []int
	for k, v := range mapData3 {
		if v.Uid < 0 {
			continue
		}
		keys = append(keys, k)
	}
	sort.Ints(keys)
	var addSmallPublicPlatoonRelateCommissionReqList []*md.SmallAddPublicPlatoonRelateCommissionReq
	for _, k := range keys {
		addSmallPublicPlatoonRelateCommissionReqList = append(addSmallPublicPlatoonRelateCommissionReqList, &md.SmallAddPublicPlatoonRelateCommissionReq{
			Uid:          strconv.Itoa(mapData3[k].Uid),
			RecommendUid: strconv.Itoa(mapData3[k].RecommendUid),
		})
	}
	//var addSmallPublicPlatoonRelateCommissionReqList []*md.SmallAddPublicPlatoonRelateCommissionReq
	//for _, v := range mapData3 {
	//	if v.Uid < 0 {
	//		continue
	//	}
	//	//1、 查找当前 user_small_public_platoon_relation 中 recommendUid 的记录
	//	//m, err := db2.UserSmallPublicPlatoonRelationGetOneByParams(engine, map[string]interface{}{
	//	//	"key":   "uid",
	//	//	"value": strconv.Itoa(v.RecommendUid),
	//	//})
	//	//if err != nil {
	//	//	fmt.Println(">>>>>>>>>>>>>", err)
	//	//}
	//	addSmallPublicPlatoonRelateCommissionReqList = append(addSmallPublicPlatoonRelateCommissionReqList, &md.SmallAddPublicPlatoonRelateCommissionReq{
	//		Uid:          strconv.Itoa(v.Uid),
	//		RecommendUid: strconv.Itoa(v.RecommendUid),
	//	})
	//}
	_, err = rule.AddSmallPublicPlatoonRelateCommission(db.Db, addSmallPublicPlatoonRelateCommissionReqList)
	fmt.Println(">>>>>>>>>>>>>>>>>", err)
	fmt.Println(len(mapData3))
	fmt.Println("")

}