box-cost/boxcost/api/aadiffupdatetest.go

package api

import (
	"box-cost/db/model"
	"box-cost/db/repo"
	"box-cost/log"
	"errors"
	"fmt"
	"time"

	"github.com/gin-gonic/gin"
)

// 更新生产计划
func DiffUpdatePlanTest(c *gin.Context, apictx *ApiSession) (interface{}, error) {
	var plan model.ProductPlan
	err := c.ShouldBindJSON(&plan)
	if err != nil {
		fmt.Println(err)
		log.Error(err)
		return nil, errors.New("参数错误")
	}
	if plan.Id.Hex() == "" {
		return nil, errors.New("id的为空")
	}
	plan.UpdateTime = time.Now()
	// repo.RepoSeachDoc(apictx.CreateRepoCtx(), &repo.DocSearchOptions{
	// 	CollectName: "product-plan_copy1",
	// 	Query:       repo.Map{"_id": plan.Id.Hex()},
	// }, &plan)
	// return plan, nil

	// ========================记录更新日志 查询更新前数据============================
	// planModel1 := &model.ProductPlan{}
	// oldPlan := getDataById(apictx, plan.Id.Hex(), planModel1, "product-plan_copy1")
	// // ============================================================================

	result, err1 := repo.RepoUpdateSetDoc1(apictx.CreateRepoCtx(), "product-plan_copy1", plan.Id.Hex(), &plan, &repo.RecordLogReq{
		Path:     c.Request.URL.Path,
		TargetId: plan.Id.Hex(),
	})

	// ========================记录更新日志 查询更新后数据============================
	// planModel2 := &model.ProductPlan{}
	// newPlan := getDataById(apictx, plan.Id.Hex(), planModel2, "product-plan_copy1")
	// // ============================================================================

	// // ============================记录更新前后差异================================
	// diffStr, err := diffUpdateData(oldPlan, newPlan)
	// if err != nil {
	// 	fmt.Println(err)
	// }

	// // 记录到数据库中
	// changeLogs := &model.Logs{
	// 	Path:       c.Request.URL.Path,
	// 	UserId:     apictx.User.ID,
	// 	TargetId:   plan.Id.Hex(),
	// 	Diff:       diffStr,
	// 	CreateTime: time.Now(),
	// 	UpdateTime: time.Now(),
	// }
	// repo.RepoAddDoc(apictx.CreateRepoCtx(), repo.CollectionLogs, changeLogs)
	// ==========================================================================
	return result, err1
}

// 更新生产计划
func DiffUpdateProduceTest(c *gin.Context, apictx *ApiSession) (interface{}, error) {
	var produce model.ProduceBill
	err := c.ShouldBindJSON(&produce)
	if err != nil {
		fmt.Println(err)
		log.Error(err)
		return nil, errors.New("参数错误")
	}
	if produce.Id.Hex() == "" {
		return nil, errors.New("id的为空")
	}
	produce.UpdateTime = time.Now()

	result, err1 := repo.RepoUpdateSetDoc1(apictx.CreateRepoCtx(), "bill-produce_copy1", produce.Id.Hex(), &produce, &repo.RecordLogReq{
		Path:     c.Request.URL.Path,
		TargetId: produce.Id.Hex(),
	})

	// ========================记录更新日志 查询更新后数据============================
	// planModel2 := &model.ProductPlan{}
	// newPlan := getDataById(apictx, plan.Id.Hex(), planModel2, "product-plan_copy1")
	// // ============================================================================

	// // ============================记录更新前后差异================================
	// diffStr, err := diffUpdateData(oldPlan, newPlan)
	// if err != nil {
	// 	fmt.Println(err)
	// }

	// // 记录到数据库中
	// changeLogs := &model.Logs{
	// 	Path:       c.Request.URL.Path,
	// 	UserId:     apictx.User.ID,
	// 	TargetId:   plan.Id.Hex(),
	// 	Diff:       diffStr,
	// 	CreateTime: time.Now(),
	// 	UpdateTime: time.Now(),
	// }
	// repo.RepoAddDoc(apictx.CreateRepoCtx(), repo.CollectionLogs, changeLogs)
	// ==========================================================================
	return result, err1
}