youngee_b_api/service/sectask_service/logistics.go

package sectask_service

import (
	"context"
	"github.com/issue9/conv"
	"github.com/sirupsen/logrus"
	"time"
	"youngee_b_api/db"
	"youngee_b_api/model/gorm_model"
	"youngee_b_api/model/http_model"
)

var Logistics *logistics

type logistics struct {
}

func (*logistics) Create(ctx context.Context, request http_model.CreateSecTaskLogisticsRequest) (*http_model.CreateSecTaskLogisticsData, error) {
	ThingsType := request.ThingsType
	newLogistics := gorm_model.YoungeeTaskLogistics{
		TaskID:                request.TaskID,
		ThingsType:            int64(ThingsType),
		ExplorestoreStarttime: time.Now(),
		ExplorestoreEndtime:   time.Now(),
		DeliveryTime:          time.Now(),
	}
	//实物
	if ThingsType == 1 {
		newLogistics.CompanyName = request.CompanyName
		newLogistics.LogisticsNumber = request.LogisticsNumber
		newLogistics.DeliveryTime = time.Now()
	} else if ThingsType == 3 {
		ExplorestoreStarttime, _ := time.ParseInLocation("2006-01-02 15:04:05", request.ExplorestoreStarttime, time.Local)
		ExplorestoreEndtime, _ := time.ParseInLocation("2006-01-02 15:04:05", request.ExplorestoreEndtime, time.Local)
		newLogistics.ExplorestoreStarttime = ExplorestoreStarttime
		newLogistics.ExplorestoreEndtime = ExplorestoreEndtime
	}

	_, err := db.CreateSecTaskLogistics(ctx, newLogistics)
	if err != nil {
		logrus.WithContext(ctx).Errorf("[newLogistics service] call CreatenewLogistics error,err:%+v", err)
		return nil, err
	}

	var createLogisticUserType int
	var createLogisticUserId string
	if request.SubAccountId == 0 {
		createLogisticUserType = 1
		createLogisticUserId = request.EnterpriseId
	} else if request.SubAccountId != 0 {
		createLogisticUserType = 2
		createLogisticUserId = conv.MustString(request.SubAccountId)
	}

	// 修改task_info中发货时间、任务阶段
	updatdSecTask := gorm_model.YounggeeSecTaskInfo{
		TaskID:                 request.TaskID,
		LogisticsStatus:        2,
		TaskStage:              8,
		DeliveryDate:           time.Now(),
		FreeStage:              4,
		CreateLogisticUserId:   createLogisticUserId,
		CreateLogisticUserType: createLogisticUserType,
	}

	_, err = db.UpdateSecTask(ctx, updatdSecTask)
	if err != nil {
		logrus.WithContext(ctx).Errorf("[sectask logistics service] call UpdateSecTask error,err:%+v", err)
		return nil, err
	}

	taskInfo, taskErr := db.GetSecTaskById(ctx, request.TaskID)
	if taskErr != nil {
		return nil, taskErr
	}

	// 更新带货任务已发货人数
	err = db.UpdateSelectionNum(ctx, taskInfo.SelectionID)
	if err != nil {
		return nil, err
	}

	// 插入任务日志、达人消息
	err = db.CreateTaskLog(ctx, newLogistics.TaskID, "发货时间")
	if err != nil {
		logrus.WithContext(ctx).Errorf("[newLogistics service] call CreateTaskLog error,err:%+v", err)
		return nil, err
	}

	err = db.CreateMessageBySecTaskId(ctx, 8, 2, newLogistics.TaskID)
	if err != nil {
		logrus.WithContext(ctx).Errorf("[newLogistics service] call CreateMessageByTaskId error,err:%+v", err)
		return nil, err
	}

	data := http_model.CreateSecTaskLogisticsData{}

	return &data, nil
}

func (*logistics) Update(ctx context.Context, request http_model.UpdateSecTaskLogisticsRequest) (*http_model.UpdateSecTaskLogisticsData, error) {
	ThingsType := request.ThingsType
	// 根据任务查询物流id
	logisticsInfo, err := db.GetLogistics(ctx, request.TaskID)
	if err != nil {
		logrus.WithContext(ctx).Errorf("[newLogistics service] call UpdatenewLogistics error,err:%+v", err)
		return nil, err
	}
	newLogistics := gorm_model.YoungeeTaskLogistics{
		LogisticsID:           logisticsInfo.LogisticsID,
		TaskID:                request.TaskID,
		ThingsType:            int64(ThingsType),
		ExplorestoreStarttime: time.Now(),
		ExplorestoreEndtime:   time.Now(),
		DeliveryTime:          time.Now(),
	}
	//实物
	if ThingsType == 1 {
		newLogistics.CompanyName = request.CompanyName
		newLogistics.LogisticsNumber = request.LogisticsNumber
		newLogistics.DeliveryTime = time.Now()
	} else if ThingsType == 3 {
		ExplorestoreStarttime, _ := time.ParseInLocation("2006-01-02 15:04:05", request.ExplorestoreStarttime, time.Local)
		ExplorestoreEndtime, _ := time.ParseInLocation("2006-01-02 15:04:05", request.ExplorestoreEndtime, time.Local)
		newLogistics.ExplorestoreStarttime = ExplorestoreStarttime
		newLogistics.ExplorestoreEndtime = ExplorestoreEndtime
	}

	_, err = db.UpdateSecTaskLogistics(ctx, newLogistics)
	if err != nil {
		logrus.WithContext(ctx).Errorf("[newLogistics service] call UpdatenewLogistics error,err:%+v", err)
		return nil, err
	}

	data := http_model.UpdateSecTaskLogisticsData{}

	return &data, nil
}