Browse Source

更新时同步到product数据表上

pull/119/head
zhangxin 3 years ago
parent
commit
bdd0da082c
1 changed files with 21 additions and 5 deletions
  1. +21
    -5
      services/base/implments/Article.service.impl.go

+ 21
- 5
services/base/implments/Article.service.impl.go View File

@ -294,6 +294,7 @@ func (impl *ArticleServiceImplement) UpdateOne(user *global.User, entity *model.
if err := session.Begin(); err != nil {
return err
}
productDao := meDal.NewProductDAO(session, user.PlantNr, user.UserId)
dao := dal.NewArticleDAO(session, user.PlantNr, user.UserId)
record, err := dao.SelectOne(entity.ArtId, entity.ProjectId)
if err != nil {
@ -307,7 +308,7 @@ func (impl *ArticleServiceImplement) UpdateOne(user *global.User, entity *model.
}
err = dao.UpdateOne(entity)
if err != nil {
session.Rollback()
_ = session.Rollback()
return err
}
@ -327,16 +328,31 @@ func (impl *ArticleServiceImplement) UpdateOne(user *global.User, entity *model.
meta.ArticleAtcodLst_ArtId.NewPredicate(grmi.Equal, entity.ArtId),
})
if err != nil {
session.Rollback()
_ = session.Rollback()
return err
}
err = lstdao.Insert(&AtcodLst)
if err != nil {
session.Rollback()
_ = session.Rollback()
return err
}
session.Commit()
if entity.ArtSpec1 == model.ART_TYPE_FINISHED && (record.CustArtId != entity.CustArtId || record.Descr1 != entity.Descr1) {
product, err := productDao.SelectOne(entity.ArtId, entity.ProjectId)
if err != nil {
_ = session.Rollback()
return grmi.NewBusinessError("查询总成数据失败, error:" + err.Error())
}
if product != nil {
product.Descr = entity.Descr1
product.CustPartId = entity.CustArtId
err = productDao.UpdateOne(product)
if err != nil {
_ = session.Rollback()
return grmi.NewBusinessError("查询更新总成数据失败, error:" + err.Error())
}
}
}
_ = session.Commit()
return nil
}


Loading…
Cancel
Save