移入公海加入事务

opms_parent/app/service/cust/cust_customer.go

@@ -253,10 +253,10 @@ func (s *CustomerService) MoveToPubic(Ids []int64) (err error) {
 		return
 	}
 	userName := s.GetCxtUserName()
-	currentTime := gtime.Now()
+	currentTime := gtime.Now() //  当前时间
 	s.Dao.Transaction(context.TODO(), func(ctx context.Context, tx *gdb.TX) error {
 		//更新客户信息
-		_, err = s.Dao.Data(g.Map{
+		_, err = s.Dao.TX(tx).Data(g.Map{
 			"is_public":    isPublic,
 			"sales_id":     0,
 			"dept_id":      0,
@@ -271,7 +271,7 @@ func (s *CustomerService) MoveToPubic(Ids []int64) (err error) {
 			return err
 		}
 		//更新销售归属表结束时间
-		_, err = s.BelongDao.Data(
+		_, err = s.BelongDao.TX(tx).Data(
 			g.Map{
 				"updated_by":   s.GetCxtUserId(),
 				"updated_name": userName,