aa

business/jxstore/cms/order.go

@@ -2,6 +2,7 @@ package cms
 
 import (
 	"fmt"
+	"git.rosy.net.cn/jx-callback/business/jxstore/partner"
 	"time"
 
 	"git.rosy.net.cn/jx-callback/business/auth2"
@@ -186,3 +187,32 @@ func GetManageStatisticsJob(ctx *jxcontext.Context, cityCodes []int, fromTime, t
 	)
 	return dao.GetManageStatisticsJob(db, cityCodes, utils.Str2Time(fromTime), utils.Str2Time(toTime), jobIDs, offset, pageSize)
 }
+
+func UnionOrderCallBack(unionOrder *partner.UnionOrderInfo) (err error) {
+	globals.SugarLogger.Debugf("UnionOrderCallBack unionOrder: %v", utils.Format4Output(unionOrder, true))
+	var (
+		jobOrder = &model.JobOrder{}
+		db       = dao.GetDB()
+	)
+	jobOrder.ID = unionOrder.JobOrderID
+	txDB, _ := dao.Begin(db)
+	defer func() {
+		if r := recover(); r != nil {
+			dao.Rollback(db, txDB)
+			panic(r)
+		}
+	}()
+	if err := dao.GetEntity(db, jobOrder); err != nil {
+		return err
+	}
+	userBill, err := dao.GetUserBill(db, jobOrder.UserID, "")
+	if userBill == nil {
+		return fmt.Errorf("未查询到该用户的账单！")
+	}
+	if err = financial.AddIncomeUpdateAccount(txDB, userBill, model.BillTypeUnionShare, int(unionOrder.Profit), jobOrder.JobID); err != nil {
+		dao.Rollback(db, txDB)
+		return err
+	}
+	dao.Commit(db, txDB)
+	return err
+}