overseas_custom_seller.go 2.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677
  1. package overseas_custom
  2. import (
  3. "github.com/beego/beego/v2/client/orm"
  4. "time"
  5. )
  6. // 海外客户销售
  7. type OverseasCustomerSale struct {
  8. OverseasCustomSellerId int `orm:"column(overseas_custorm_seller_id);pk"`
  9. SellerId int `description:"销售id"`
  10. CreateTime time.Time `description:"创建时间"`
  11. }
  12. // 海外客户销售
  13. type OverseasCustomerSaleView struct {
  14. SellerId int `description:"销售id"`
  15. RealName string `description:"销售姓名"`
  16. }
  17. func (m *OverseasCustomerSale) Create() (err error) {
  18. o := orm.NewOrm()
  19. id, err := o.Insert(m)
  20. if err != nil {
  21. return
  22. }
  23. m.OverseasCustomSellerId = int(id)
  24. return
  25. }
  26. func (m *OverseasCustomerSale) Delete() (err error) {
  27. o := orm.NewOrm()
  28. sql := ` DELETE FROM overseas_custom_seller WHERE seller_id=? `
  29. _, err = o.Raw(sql, m.SellerId).Exec()
  30. return
  31. }
  32. func (m *OverseasCustomerSale) TableName() string {
  33. return "overseas_custom_seller"
  34. }
  35. // OverseasCustomerSaleSaveReq 保存销售
  36. type OverseasCustomerSaleSaveReq struct {
  37. AddSellerIdArr []int `description:"新增销售id,数组"`
  38. DelSellerIdArr []int `description:"删除销售id,数组"`
  39. }
  40. func (m *OverseasCustomerSale) GetOverseasCustomerSaleAll() (list []*OverseasCustomerSaleView, err error) {
  41. o := orm.NewOrm()
  42. sql := ` SELECT a.*,b.real_name FROM overseas_custom_seller AS a
  43. INNER JOIN admin AS b ON a.seller_id=b.admin_id `
  44. _, err = o.Raw(sql).QueryRows(&list)
  45. return
  46. }
  47. type AdminItem struct {
  48. AdminId int `description:"系统用户id"`
  49. AdminName string `description:"系统用户名称"`
  50. RealName string `description:"系统用户姓名"`
  51. Mobile string `description:"手机号"`
  52. }
  53. func (m *OverseasCustomerSale) HandelOverseasCustomerSale(sellerId, isOverseas int) (err error) {
  54. o := orm.NewOrm()
  55. sellerItem := new(AdminItem)
  56. sql := ` SELECT * FROM admin WHERE admin_id=? `
  57. err = o.Raw(sql, sellerId).QueryRow(&sellerItem)
  58. if err != nil {
  59. return err
  60. }
  61. if sellerItem.Mobile == "13065778668" {
  62. sql = ` UPDATE company_product SET is_overseas = ? WHERE seller_id=? AND company_id IN (SELECT company_id FROM company WHERE region_type='国内') `
  63. _, err = o.Raw(sql, isOverseas, sellerId).Exec()
  64. return err
  65. }
  66. return err
  67. }