english_company.go 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773
  1. package english_report
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "github.com/rdlucklib/rdluck_tools/paging"
  6. "hongze/hz_crm_api/controllers"
  7. "hongze/hz_crm_api/models"
  8. "hongze/hz_crm_api/models/system"
  9. "hongze/hz_crm_api/services"
  10. "hongze/hz_crm_api/services/alarm_msg"
  11. "hongze/hz_crm_api/utils"
  12. "strconv"
  13. "strings"
  14. "time"
  15. )
  16. // EnglishCompanyController 英文客户
  17. type EnglishCompanyController struct {
  18. controllers.BaseAuthController
  19. }
  20. // List
  21. // @Title 英文客户列表
  22. // @Description 英文客户列表
  23. // @Param Keywords query string false "关键词:客户名称/联系人邮箱/联系人手机号"
  24. // @Param SortType query int false "点击量排序:1-降序; 2-升序"
  25. // @Param EnPermissionIds query string false "品种权限IDs(字符串)"
  26. // @Success 200 {object} models.EnglishCompanyPageListResp
  27. // @router /company/list [get]
  28. func (this *EnglishCompanyController) List() {
  29. br := new(models.BaseResponse).Init()
  30. br.IsSendEmail = false
  31. defer func() {
  32. this.Data["json"] = br
  33. this.ServeJSON()
  34. }()
  35. sysUser := this.SysUser
  36. if sysUser == nil {
  37. br.Msg = "请登录"
  38. br.ErrMsg = "请登录,SysUser Is Empty"
  39. br.Ret = 408
  40. return
  41. }
  42. var startSize int
  43. pageSize, _ := this.GetInt("PageSize")
  44. currentIndex, _ := this.GetInt("CurrentIndex")
  45. if pageSize <= 0 {
  46. pageSize = utils.PageSize20
  47. }
  48. if currentIndex <= 0 {
  49. currentIndex = 1
  50. }
  51. startSize = paging.StartIndex(currentIndex, pageSize)
  52. keywords := this.GetString("Keywords", "")
  53. sortType, _ := this.GetInt("SortType", 0)
  54. sortParam := this.GetString("SortParam", "")
  55. strPermissionIds := this.GetString("EnPermissionIds", "")
  56. var cond, order string
  57. var pars []interface{}
  58. if keywords != "" {
  59. k := "%" + keywords + "%"
  60. companyIds, e := models.GetEnCompanyIdsByKeyword(k)
  61. if e != nil {
  62. br.Msg = "获取失败"
  63. br.ErrMsg = "关键词获取英文客户IDs失败, Err: " + e.Error()
  64. return
  65. }
  66. if len(companyIds) == 0 {
  67. page := paging.GetPaging(currentIndex, pageSize, 0)
  68. resp := &models.EnglishCompanyPageListResp{
  69. Paging: page,
  70. List: make([]*models.EnglishCompanyResp, 0),
  71. }
  72. br.Ret = 200
  73. br.Success = true
  74. br.Msg = "获取成功"
  75. br.Data = resp
  76. return
  77. }
  78. cond += fmt.Sprintf(` AND c.company_id IN (%s) `, utils.GetOrmInReplace(len(companyIds)))
  79. pars = append(pars, companyIds)
  80. }
  81. // 品种权限
  82. if strPermissionIds != "" {
  83. permissionIdArr := strings.Split(strPermissionIds, ",")
  84. permissionIds := make([]int, 0)
  85. for _, s := range permissionIdArr {
  86. p, e := strconv.Atoi(s)
  87. if e != nil {
  88. br.Msg = "品种权限有误"
  89. br.ErrMsg = "品种权限筛选有误"
  90. return
  91. }
  92. permissionIds = append(permissionIds, p)
  93. }
  94. if len(permissionIds) == 0 {
  95. br.Msg = "品种权限有误"
  96. br.ErrMsg = "品种权限筛选ID为空"
  97. return
  98. }
  99. queryCond := fmt.Sprintf(` AND %s IN (%s)`, models.EnCompanyPermissionColumns.EnPermissionId, utils.GetOrmInReplace(len(permissionIds)))
  100. queryPars := make([]interface{}, 0)
  101. queryPars = append(queryPars, permissionIds)
  102. queryOB := new(models.EnCompanyPermission)
  103. queryList, e := queryOB.GetItemsByCondition(queryCond, queryPars, []string{"DISTINCT en_company_id"}, "")
  104. if e != nil {
  105. br.Msg = "品种筛选有误"
  106. br.ErrMsg = "品种筛选失败, Err: " + e.Error()
  107. return
  108. }
  109. companyIds := make([]int, 0)
  110. for _, q := range queryList {
  111. companyIds = append(companyIds, q.EnCompanyId)
  112. }
  113. if len(companyIds) == 0 {
  114. page := paging.GetPaging(currentIndex, pageSize, 0)
  115. resp := &models.EnglishCompanyPageListResp{
  116. Paging: page,
  117. List: make([]*models.EnglishCompanyResp, 0),
  118. }
  119. br.Ret = 200
  120. br.Success = true
  121. br.Msg = "获取成功"
  122. br.Data = resp
  123. return
  124. }
  125. cond += fmt.Sprintf(` AND c.company_id IN (%s) `, utils.GetOrmInReplace(len(companyIds)))
  126. pars = append(pars, companyIds)
  127. }
  128. if sortParam == "" {
  129. if sortType == 1 {
  130. order = ` ORDER BY c.view_total DESC`
  131. }
  132. if sortType == 2 {
  133. order = ` ORDER BY c.view_total ASC`
  134. }
  135. } else if sortParam == "deadLine" {
  136. order = ` ORDER BY todo_end_time asc, c.view_total desc, c.company_id desc`
  137. } else if sortParam == "todoStatusStr" {
  138. order = ` ORDER BY FIELD (todo_status_str,'进行中','已完成','无任务'), c.view_total desc, c.company_id desc`
  139. }
  140. total, list, e := models.GetEnglishCompanyPageList(cond, pars, order, startSize, pageSize)
  141. if e != nil {
  142. br.Msg = "获取失败"
  143. br.ErrMsg = "获取英文客户列表失败, Err: " + e.Error()
  144. return
  145. }
  146. // 客户列表TODO信息
  147. todoMap := services.GetEnglishCompanyListTodoMap(list, sysUser)
  148. // 品种权限
  149. permissionMap := make(map[int][]int)
  150. {
  151. companyIds := make([]int, 0)
  152. for _, v := range list {
  153. companyIds = append(companyIds, v.CompanyId)
  154. }
  155. if len(companyIds) > 0 {
  156. cond := fmt.Sprintf(` AND %s IN (%s)`, models.EnCompanyPermissionColumns.EnCompanyId, utils.GetOrmInReplace(len(companyIds)))
  157. pars := make([]interface{}, 0)
  158. pars = append(pars, companyIds)
  159. ob := new(models.EnCompanyPermission)
  160. items, e := ob.GetItemsByCondition(cond, pars, []string{}, "")
  161. if e != nil {
  162. br.Msg = "获取失败"
  163. br.ErrMsg = "获取客户权限列表失败, Err: " + e.Error()
  164. return
  165. }
  166. for _, v := range items {
  167. if permissionMap[v.EnCompanyId] == nil {
  168. permissionMap[v.EnCompanyId] = make([]int, 0)
  169. }
  170. permissionMap[v.EnCompanyId] = append(permissionMap[v.EnCompanyId], v.EnPermissionId)
  171. }
  172. }
  173. }
  174. respList := make([]*models.EnglishCompanyResp, 0)
  175. for i := range list {
  176. respList = append(respList, &models.EnglishCompanyResp{
  177. CompanyId: list[i].CompanyId,
  178. CompanyName: list[i].CompanyName,
  179. CountryCode: list[i].CountryCode,
  180. Country: list[i].Country,
  181. SellerId: list[i].SellerId,
  182. SellerName: list[i].SellerName,
  183. ViewTotal: list[i].ViewTotal,
  184. CreateTime: list[i].CreateTime.Format(utils.FormatDateTime),
  185. Enabled: list[i].Enabled,
  186. TodoInfo: todoMap[list[i].CompanyId],
  187. EnPermissions: permissionMap[list[i].CompanyId],
  188. })
  189. }
  190. page := paging.GetPaging(currentIndex, pageSize, total)
  191. resp := &models.EnglishCompanyPageListResp{
  192. Paging: page,
  193. List: respList,
  194. }
  195. br.Ret = 200
  196. br.Success = true
  197. br.Msg = "获取成功"
  198. br.Data = resp
  199. }
  200. // Save
  201. // @Title 保存英文客户
  202. // @Description 保存英文客户
  203. // @Param request body models.EnglishCompanySaveReq true "type json string"
  204. // @Success 200 string "操作成功"
  205. // @router /company/save [post]
  206. func (this *EnglishCompanyController) Save() {
  207. br := new(models.BaseResponse).Init()
  208. br.IsSendEmail = false
  209. defer func() {
  210. this.Data["json"] = br
  211. this.ServeJSON()
  212. }()
  213. sysUser := this.SysUser
  214. if sysUser == nil {
  215. br.Msg = "请登录"
  216. br.ErrMsg = "请登录,SysUser Is Empty"
  217. br.Ret = 408
  218. return
  219. }
  220. var req models.EnglishCompanySaveReq
  221. if err := json.Unmarshal(this.Ctx.Input.RequestBody, &req); err != nil {
  222. br.Msg = "参数解析异常!"
  223. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  224. return
  225. }
  226. req.CompanyName = strings.TrimSpace(req.CompanyName)
  227. if req.CompanyName == "" {
  228. br.Msg = "请输入客户名称"
  229. return
  230. }
  231. if req.CountryCode == "" || req.Country == "" {
  232. br.Msg = "请选择国家"
  233. return
  234. }
  235. if req.SellerId <= 0 {
  236. br.Msg = "请选择销售"
  237. return
  238. }
  239. if len(req.EnPermissions) <= 0 {
  240. br.Msg = "请至少选择一个品种权限"
  241. return
  242. }
  243. seller, e := system.GetSysAdminById(req.SellerId)
  244. if e != nil {
  245. br.Msg = "销售信息有误"
  246. br.ErrMsg = "获取销售信息失败, Err:" + e.Error()
  247. return
  248. }
  249. if seller.Enabled != 1 {
  250. br.Msg = "该销售已被禁用"
  251. return
  252. }
  253. // 重名校验
  254. exist, e := models.GetEnglishCompanyByName(req.CompanyName)
  255. if e != nil && e.Error() != utils.ErrNoRow() {
  256. br.Msg = "保存失败"
  257. br.ErrMsg = "获取客户信息失败, Err:" + e.Error()
  258. return
  259. }
  260. item := new(models.EnglishCompany)
  261. nowTime := time.Now().Local()
  262. opType := 0
  263. if req.CompanyId <= 0 {
  264. if exist != nil {
  265. br.Msg = "客户名称已存在"
  266. return
  267. }
  268. opType = models.EnglishCompanyLogOptionTypeAdd
  269. // 新增
  270. item.CompanyName = req.CompanyName
  271. item.CountryCode = req.CountryCode
  272. item.Country = req.Country
  273. item.SellerId = req.SellerId
  274. item.SellerName = seller.RealName
  275. item.CreateTime = nowTime
  276. item.ModifyTime = nowTime
  277. item.Status = 1
  278. item.Enabled = 1
  279. item.Nation = req.Nation
  280. item.OverseasLabel = 1
  281. if e = item.Create(); e != nil {
  282. br.Msg = "保存失败"
  283. br.ErrMsg = "新增英文客户失败, Err:" + e.Error()
  284. return
  285. }
  286. } else {
  287. if exist != nil && exist.CompanyId != req.CompanyId {
  288. br.Msg = "客户名称已存在"
  289. return
  290. }
  291. opType = models.EnglishCompanyLogOptionTypeEdit
  292. // 编辑
  293. ec, e := models.GetEnglishCompanyById(req.CompanyId)
  294. if e != nil {
  295. br.Msg = "保存失败"
  296. br.ErrMsg = "获取英文客户信息失败, Err:" + e.Error()
  297. return
  298. }
  299. item = ec
  300. item.CompanyName = req.CompanyName
  301. item.CountryCode = req.CountryCode
  302. item.Country = req.Country
  303. item.SellerId = req.SellerId
  304. item.SellerName = seller.RealName
  305. item.ModifyTime = nowTime
  306. updateCols := []string{"CompanyName", "CountryCode", "Country", "SellerId", "SellerName", "ModifyTime"}
  307. if e = item.Update(updateCols); e != nil {
  308. br.Msg = "保存失败"
  309. br.ErrMsg = "更新英文客户信息失败, Err:" + e.Error()
  310. return
  311. }
  312. }
  313. // 品种权限
  314. permissions := make([]*models.EnCompanyPermission, 0)
  315. for _, p := range req.EnPermissions {
  316. v := new(models.EnCompanyPermission)
  317. v.EnPermissionId = p
  318. v.EnCompanyId = item.CompanyId
  319. v.CreateTime = nowTime
  320. permissions = append(permissions, v)
  321. }
  322. if e = models.ClearAndCreateEnCompanyPermissions(item.CompanyId, permissions); e != nil {
  323. br.Msg = "保存失败"
  324. br.ErrMsg = "更新客户品种权限失败, Err: " + e.Error()
  325. return
  326. }
  327. // 记录日志
  328. go func() {
  329. opByte, e := json.Marshal(req)
  330. if e != nil {
  331. return
  332. }
  333. opData := string(opByte)
  334. opLog := &models.EnglishCompanyLog{
  335. CompanyId: item.CompanyId,
  336. AdminId: sysUser.AdminId,
  337. OptionData: opData,
  338. OptionType: opType,
  339. CreateTime: nowTime,
  340. }
  341. if e = opLog.Create(); e != nil {
  342. return
  343. }
  344. }()
  345. br.Ret = 200
  346. br.Success = true
  347. br.Msg = "操作成功"
  348. }
  349. // Del
  350. // @Title 删除英文客户及联系人
  351. // @Description 删除英文客户及联系人
  352. // @Param request body models.EnglishCompanyDelReq true "type json string"
  353. // @Success 200 string "操作成功"
  354. // @router /company/del [post]
  355. func (this *EnglishCompanyController) Del() {
  356. br := new(models.BaseResponse).Init()
  357. br.IsSendEmail = false
  358. defer func() {
  359. this.Data["json"] = br
  360. this.ServeJSON()
  361. }()
  362. sysUser := this.SysUser
  363. if sysUser == nil {
  364. br.Msg = "请登录"
  365. br.ErrMsg = "请登录,SysUser Is Empty"
  366. br.Ret = 408
  367. return
  368. }
  369. var req models.EnglishCompanyDelReq
  370. if err := json.Unmarshal(this.Ctx.Input.RequestBody, &req); err != nil {
  371. br.Msg = "参数解析异常!"
  372. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  373. return
  374. }
  375. if req.CompanyId <= 0 {
  376. br.Msg = "参数有误"
  377. return
  378. }
  379. item, e := models.GetEnglishCompanyById(req.CompanyId)
  380. if e != nil {
  381. br.Msg = "删除失败"
  382. br.ErrMsg = "获取英文客户信息失败, Err:" + e.Error()
  383. return
  384. }
  385. if e := models.DeleteEnglishCompanyAndEmails(req.CompanyId); e != nil {
  386. br.Msg = "删除失败"
  387. br.ErrMsg = "删除英文客户及联系人失败, Err: " + e.Error()
  388. return
  389. }
  390. // 删除权限
  391. if e = models.ClearAndCreateEnCompanyPermissions(item.CompanyId, make([]*models.EnCompanyPermission, 0)); e != nil {
  392. br.Msg = "删除失败"
  393. br.ErrMsg = "删除英文客户权限失败, Err: " + e.Error()
  394. return
  395. }
  396. // 记录日志
  397. go func() {
  398. nowTime := time.Now().Local()
  399. opByte, e := json.Marshal(req)
  400. if e != nil {
  401. return
  402. }
  403. opData := string(opByte)
  404. opLog := &models.EnglishCompanyLog{
  405. CompanyId: item.CompanyId,
  406. AdminId: sysUser.AdminId,
  407. OptionData: opData,
  408. OptionType: models.EnglishCompanyLogOptionTypeDel,
  409. CreateTime: nowTime,
  410. }
  411. if e = opLog.Create(); e != nil {
  412. return
  413. }
  414. }()
  415. // 同步删除客户TODO
  416. go func() {
  417. if e = models.DeleteEnglishCompanyTodoByCompanyId(req.CompanyId); e != nil {
  418. alarm_msg.SendAlarmMsg("删除英文客户同步删除TODO失败, ErrMsg: "+e.Error(), 3)
  419. }
  420. }()
  421. br.Ret = 200
  422. br.Success = true
  423. br.Msg = "操作成功"
  424. }
  425. // Detail
  426. // @Title 英文客户详情
  427. // @Description 英文客户详情
  428. // @Param CompanyId query int true "客户ID"
  429. // @Success 200 {object} models.EnglishCompanyResp
  430. // @router /company/detail [get]
  431. func (this *EnglishCompanyController) Detail() {
  432. br := new(models.BaseResponse).Init()
  433. br.IsSendEmail = false
  434. defer func() {
  435. this.Data["json"] = br
  436. this.ServeJSON()
  437. }()
  438. sysUser := this.SysUser
  439. if sysUser == nil {
  440. br.Msg = "请登录"
  441. br.ErrMsg = "请登录,SysUser Is Empty"
  442. br.Ret = 408
  443. return
  444. }
  445. companyId, _ := this.GetInt("CompanyId", 0)
  446. if companyId <= 0 {
  447. br.Msg = "参数有误"
  448. return
  449. }
  450. item, e := models.GetEnglishCompanyById(companyId)
  451. if e != nil {
  452. br.Msg = "获取失败, 客户或已被删除"
  453. return
  454. }
  455. // 品种权限
  456. permissions := make([]int, 0)
  457. {
  458. cond := fmt.Sprintf(` AND %s = ?`, models.EnCompanyPermissionColumns.EnCompanyId)
  459. pars := make([]interface{}, 0)
  460. pars = append(pars, item.CompanyId)
  461. ob := new(models.EnCompanyPermission)
  462. list, e := ob.GetItemsByCondition(cond, pars, []string{}, "")
  463. if e != nil {
  464. br.Msg = "获取失败"
  465. br.ErrMsg = "获取英文客户权限失败, Err: " + e.Error()
  466. return
  467. }
  468. for _, v := range list {
  469. permissions = append(permissions, v.EnPermissionId)
  470. }
  471. }
  472. resp := &models.EnglishCompanyResp{
  473. CompanyId: item.CompanyId,
  474. CompanyName: item.CompanyName,
  475. CountryCode: item.CountryCode,
  476. Country: item.Country,
  477. SellerId: item.SellerId,
  478. SellerName: item.SellerName,
  479. ViewTotal: item.ViewTotal,
  480. CreateTime: item.CreateTime.Format(utils.FormatDateTime),
  481. EnPermissions: permissions,
  482. }
  483. br.Ret = 200
  484. br.Success = true
  485. br.Msg = "获取成功"
  486. br.Data = resp
  487. }
  488. // ViewList
  489. // @Title 英文客户-点击量详情列表
  490. // @Description 英文客户-点击量详情列表
  491. // @Param CompanyId query int false "客户ID"
  492. // @Param SortParam query int false "排序字段:1-点击量;2-点击时间"
  493. // @Param SortType query int false "排序方式:1-倒序;2-正序"
  494. // @Success 200 {object} models.GetEnglishCompanyViewPageListResp
  495. // @router /company/view_list [get]
  496. func (this *EnglishCompanyController) ViewList() {
  497. br := new(models.BaseResponse).Init()
  498. br.IsSendEmail = false
  499. defer func() {
  500. this.Data["json"] = br
  501. this.ServeJSON()
  502. }()
  503. sysUser := this.SysUser
  504. if sysUser == nil {
  505. br.Msg = "请登录"
  506. br.ErrMsg = "请登录,SysUser Is Empty"
  507. br.Ret = 408
  508. return
  509. }
  510. // 默认点击时间降序
  511. companyId, _ := this.GetInt("CompanyId", 0)
  512. sortParam, _ := this.GetInt("SortParam", 2)
  513. sortType, _ := this.GetInt("SortType", 1)
  514. var cond, order string
  515. var pars []interface{}
  516. if companyId > 0 {
  517. cond += ` AND company_id = ?`
  518. pars = append(pars, companyId)
  519. }
  520. sortArr := []int{1, 2}
  521. if utils.InArrayByInt(sortArr, sortParam) && utils.InArrayByInt(sortArr, sortType) {
  522. pMap := map[int]string{1: "view_total", 2: "last_view_time"}
  523. tMap := map[int]string{1: "DESC", 2: "ASC"}
  524. order = fmt.Sprintf(` ORDER BY %s %s`, pMap[sortParam], tMap[sortType])
  525. }
  526. var startSize int
  527. pageSize, _ := this.GetInt("PageSize")
  528. currentIndex, _ := this.GetInt("CurrentIndex")
  529. if pageSize <= 0 {
  530. pageSize = utils.PageSize20
  531. }
  532. if currentIndex <= 0 {
  533. currentIndex = 1
  534. }
  535. startSize = paging.StartIndex(currentIndex, pageSize)
  536. // 注:点击量列表是包含被删除的联系人的历史点击量
  537. total, list, e := models.GetEnglishCompanyViewPageList(cond, pars, order, startSize, pageSize)
  538. if e != nil {
  539. br.Msg = "获取失败"
  540. br.ErrMsg = "获取英文客户点击量详情列表失败, Err: " + e.Error()
  541. return
  542. }
  543. respList := make([]*models.EnglishCompanyViewResp, 0)
  544. for i := range list {
  545. v := &models.EnglishCompanyViewResp{
  546. EmailId: list[i].Id,
  547. UserName: list[i].Name,
  548. Email: list[i].Email,
  549. ViewTotal: list[i].ViewTotal,
  550. LastViewTime: list[i].LastViewTime.Format(utils.FormatDateTime),
  551. }
  552. if v.LastViewTime == "0001-01-01 00:00:00" {
  553. v.LastViewTime = ""
  554. }
  555. respList = append(respList, v)
  556. }
  557. page := paging.GetPaging(currentIndex, pageSize, total)
  558. resp := &models.GetEnglishCompanyViewPageListResp{
  559. Paging: page,
  560. List: respList,
  561. }
  562. br.Ret = 200
  563. br.Success = true
  564. br.Msg = "获取成功"
  565. br.Data = resp
  566. }
  567. // EditEnabled
  568. // @Title 英文客户-启用/禁用
  569. // @Description 英文客户-启用/禁用
  570. // @Param request body models.EnglishCompanyEditEnabledReq true "type json string"
  571. // @Success 200 string "操作成功"
  572. // @router /company/edit_enabled [post]
  573. func (this *EnglishCompanyController) EditEnabled() {
  574. br := new(models.BaseResponse).Init()
  575. br.IsSendEmail = false
  576. defer func() {
  577. this.Data["json"] = br
  578. this.ServeJSON()
  579. }()
  580. sysUser := this.SysUser
  581. if sysUser == nil {
  582. br.Msg = "请登录"
  583. br.ErrMsg = "请登录,SysUser Is Empty"
  584. br.Ret = 408
  585. return
  586. }
  587. var req models.EnglishCompanyEditEnabledReq
  588. if err := json.Unmarshal(this.Ctx.Input.RequestBody, &req); err != nil {
  589. br.Msg = "参数解析异常!"
  590. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  591. return
  592. }
  593. if req.CompanyId <= 0 {
  594. br.Msg = "参数有误"
  595. return
  596. }
  597. if req.Enabled != 0 && req.Enabled != 1 {
  598. br.Msg = "参数有误"
  599. return
  600. }
  601. item, e := models.GetEnglishCompanyById(req.CompanyId)
  602. if e != nil {
  603. br.Msg = "客户已被删除, 请刷新页面"
  604. return
  605. }
  606. // 更新客户
  607. nowTime := time.Now().Local()
  608. item.Enabled = req.Enabled
  609. item.ModifyTime = nowTime
  610. updateCols := []string{"Enabled", "ModifyTime"}
  611. if e = item.Update(updateCols); e != nil {
  612. br.Msg = "操作失败"
  613. br.ErrMsg = "更新英文客户状态失败, Err:" + e.Error()
  614. return
  615. }
  616. // 更新其下联系人状态
  617. if e = models.UpdateEnglishEmailEnabledByCompanyId(item.CompanyId, req.Enabled); e != nil {
  618. br.Msg = "操作失败"
  619. br.ErrMsg = "更新英文客户下的联系人状态失败, Err: " + e.Error()
  620. return
  621. }
  622. // 记录日志
  623. go func() {
  624. opByte, e := json.Marshal(req)
  625. if e != nil {
  626. return
  627. }
  628. opData := string(opByte)
  629. opLog := &models.EnglishCompanyLog{
  630. CompanyId: item.CompanyId,
  631. AdminId: sysUser.AdminId,
  632. OptionData: opData,
  633. OptionType: models.EnglishCompanyLogOptionTypeEditEnabled,
  634. CreateTime: nowTime,
  635. }
  636. if e = opLog.Create(); e != nil {
  637. return
  638. }
  639. }()
  640. br.Ret = 200
  641. br.Success = true
  642. br.Msg = "操作成功"
  643. }
  644. // SavePermission
  645. // @Title 英文客户-保存权限
  646. // @Description 英文客户-保存权限
  647. // @Param request body models.EnglishCompanySaveReq true "type json string"
  648. // @Success 200 string "操作成功"
  649. // @router /company/save_permission [post]
  650. func (this *EnglishCompanyController) SavePermission() {
  651. br := new(models.BaseResponse).Init()
  652. br.IsSendEmail = false
  653. defer func() {
  654. this.Data["json"] = br
  655. this.ServeJSON()
  656. }()
  657. sysUser := this.SysUser
  658. if sysUser == nil {
  659. br.Msg = "请登录"
  660. br.ErrMsg = "请登录,SysUser Is Empty"
  661. br.Ret = 408
  662. return
  663. }
  664. var req models.EnglishCompanySaveReq
  665. if err := json.Unmarshal(this.Ctx.Input.RequestBody, &req); err != nil {
  666. br.Msg = "参数解析异常!"
  667. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  668. return
  669. }
  670. if req.CompanyId <= 0 {
  671. br.Msg = "参数有误"
  672. br.ErrMsg = "参数有误"
  673. return
  674. }
  675. if len(req.EnPermissions) <= 0 {
  676. br.Msg = "请至少选择一个品种权限"
  677. return
  678. }
  679. nowTime := time.Now().Local()
  680. item, e := models.GetEnglishCompanyById(req.CompanyId)
  681. if e != nil {
  682. if e.Error() == utils.ErrNoRow() {
  683. br.Msg = "客户已被删除, 请刷新页面"
  684. return
  685. }
  686. br.Msg = "操作失败"
  687. br.ErrMsg = "获取客户信息失败, Err: " + e.Error()
  688. return
  689. }
  690. // 品种权限
  691. permissions := make([]*models.EnCompanyPermission, 0)
  692. for _, p := range req.EnPermissions {
  693. v := new(models.EnCompanyPermission)
  694. v.EnPermissionId = p
  695. v.EnCompanyId = item.CompanyId
  696. v.CreateTime = nowTime
  697. permissions = append(permissions, v)
  698. }
  699. if e := models.ClearAndCreateEnCompanyPermissions(item.CompanyId, permissions); e != nil {
  700. br.Msg = "保存失败"
  701. br.ErrMsg = "更新客户品种权限失败, Err: " + e.Error()
  702. return
  703. }
  704. // 记录日志
  705. go func() {
  706. opByte, e := json.Marshal(req)
  707. if e != nil {
  708. return
  709. }
  710. opData := string(opByte)
  711. opLog := &models.EnglishCompanyLog{
  712. CompanyId: item.CompanyId,
  713. AdminId: sysUser.AdminId,
  714. OptionData: opData,
  715. OptionType: models.EnglishCompanyLogOptionTypeSavePermission,
  716. CreateTime: nowTime,
  717. }
  718. if e = opLog.Create(); e != nil {
  719. return
  720. }
  721. }()
  722. br.Ret = 200
  723. br.Success = true
  724. br.Msg = "操作成功"
  725. }