workScript/run/orderFlush/other.go

package main

import (
	"context"
	"github.com/gogf/gf/v2/frame/g"
	"github.com/gogf/gf/v2/util/gconv"
)

func FlushEntNicheOrderId(ctx context.Context) error {
	res, err := g.DB().Query(ctx, "SELECT id,order_id FROM entniche_order")
	if err != nil {
		return err
	}
	for _, re := range res {
		var (
			id       = gconv.Int(re["id"])
			order_id = gconv.Int(re["order_id"])
		)
		res, err := g.DB().GetOne(ctx, "SELECT o.id FROM dataexport_order d inner join jy_order_detail o on (d.order_code = o.order_code) WHERE d.id=?", order_id)
		if err != nil {
			g.Log().Error(ctx, "更新商机管理order异常，获取订单信息异常", id)
			continue
		}
		orderDetailId := gconv.Int(res.Map()["id"])
		if orderDetailId <= 0 {
			g.Log().Error(ctx, "更新商机管理order异常,订单明细表异常", id)
			continue
		}
		_, err = g.DB().Update(ctx, "entniche_order", g.Map{
			"order_detail_id": orderDetailId,
		}, "id=?", id)
		if err != nil {
			g.Log().Error(ctx, "更新商机管理order异常,订单明细表异常", id)
		}
	}
	return nil
}

// FlushReturnPlan 回款计划
func FlushReturnPlan(ctx context.Context) error {
	res, err := g.DB().Query(ctx, "SELECT filter,order_code FROM dataexport_order WHERE `filter`  LIKE '%paybackList%'")
	if err != nil {
		return err
	}
	var insert []g.Map
	for _, re := range res {
		var (
			filter     = gconv.Map(re["filter"])
			orderCode  = gconv.String(re["order_code"])
			paybackNum = gconv.Int(filter["paybackNum"])

			paybackWorkDayNum = gconv.Int(filter["paybackWorkDayNum"])
			paybackExpectDate = gconv.String(filter["paybackExpectDate"])
			paybackList       = filter["paybackList"]
		)
		t := g.Map{
			"order_code":  orderCode,
			"state":       1,
			"day_num":     paybackNum,
			"create_time": "2025-05-01 00:00:00",
		}
		if paybackNum == 1 {
			if paybackExpectDate != "" {
				t["expect_time"] = paybackExpectDate
			}
			t["day_num"] = paybackWorkDayNum
		} else {
			t["plantList"] = paybackList
		}
		insert = append(insert, t)
	}
	r, err := g.DB("jianyu2").Insert(ctx, "return_money_plant", insert, 100)
	if err != nil {
		return err
	}
	num, _ := r.RowsAffected()
	g.Log().Info(ctx, "共插入%d个回款计划数据", num)
	return nil
}

// FlushReturnTransfer 对公转账
func FlushReturnTransfer(ctx context.Context) error {
	//res, err := g.DB().Query(ctx, "SELECT filter,order_code,course_status FROM dataexport_order WHERE `filter`  LIKE '%transferV%'")
	res, err := g.DB().Query(ctx, "SELECT filter,order_code,course_status FROM dataexport_order WHERE course_status!=0")
	if err != nil {
		return err
	}
	var insert []g.Map
	for _, re := range res {
		var (
			filter       = gconv.Map(re["filter"])
			orderCode    = gconv.String(re["order_code"])
			courseStatus = gconv.Int(re["course_status"])

			transferV      = gconv.String(filter["transferV"])
			transferVTime  = gconv.String(filter["transferVTime"])
			originalAmount = filter["originalAmount"]
		)
		t := g.Map{
			"order_code":   orderCode,
			"state":        courseStatus,
			"price":        originalAmount,
			"voucher":      transferV,
			"audit_person": "",
		}
		if transferVTime != "" {
			t["create_time"] = transferVTime
		}
		insert = append(insert, t)

	}
	r, err := g.DB("jianyu2").Insert(ctx, "jy_order_transfer", insert, 100)
	if err != nil {
		return err
	}
	num, _ := r.RowsAffected()
	g.Log().Info(ctx, "对公转账共插入%d个回款计划数据", num)
	return nil
}

// FlushSale 业绩变更表刷新
func FlushSale(ctx context.Context) error {
	//查询管理后台id和entUserId关联关系
	var t = map[int]int{}
	res, err := g.DB().Query(ctx, `SELECT
			e.id as adminId,
			u.id as entUserId,
			u.name as userName,
			u.phone as phone
		FROM
			jianyu.entniche_user u
			INNER JOIN cadmin.admin_user e
			on
			( u.phone = e.phone  ) 
		WHERE
			 u.ent_id = ?`, g.Cfg().MustGet(ctx, "powerEntId", 25917).Int64())
	if err != nil {
		return err
	}
	for _, m := range res.List() {
		t[gconv.Int(m["adminId"])] = gconv.Int(m["entUserId"])
	}

	res2, err := g.DB("jianyu2").Query(ctx, "SELECT saler_Id,count(1) as total FROM order_sale_record group by saler_Id HAVING saler_Id!=-1")
	if err != nil {
		return err
	}
	for _, m := range res2.List() {
		saler_Id := gconv.Int(m["saler_Id"])
		if entUserId, ok := t[saler_Id]; ok && entUserId > 0 {
			_, err := g.DB("jianyu2").Update(ctx, "order_sale_record", g.Map{
				"ent_userId": entUserId,
			}, "saler_Id=?", saler_Id)
			if err != nil {
				g.Log().Error(ctx, "更新业绩变更异常 %d %d", saler_Id, entUserId)
			}
		}
	}
	return nil
}