english_company.go 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777
  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. if req.Country != "" && req.Nation == "" {
  280. item.Nation = req.Country
  281. } else {
  282. item.Nation = req.Nation
  283. }
  284. item.OverseasLabel = 1
  285. if e = item.Create(); e != nil {
  286. br.Msg = "保存失败"
  287. br.ErrMsg = "新增英文客户失败, Err:" + e.Error()
  288. return
  289. }
  290. } else {
  291. if exist != nil && exist.CompanyId != req.CompanyId {
  292. br.Msg = "客户名称已存在"
  293. return
  294. }
  295. opType = models.EnglishCompanyLogOptionTypeEdit
  296. // 编辑
  297. ec, e := models.GetEnglishCompanyById(req.CompanyId)
  298. if e != nil {
  299. br.Msg = "保存失败"
  300. br.ErrMsg = "获取英文客户信息失败, Err:" + e.Error()
  301. return
  302. }
  303. item = ec
  304. item.CompanyName = req.CompanyName
  305. item.CountryCode = req.CountryCode
  306. item.Country = req.Country
  307. item.SellerId = req.SellerId
  308. item.SellerName = seller.RealName
  309. item.ModifyTime = nowTime
  310. updateCols := []string{"CompanyName", "CountryCode", "Country", "SellerId", "SellerName", "ModifyTime"}
  311. if e = item.Update(updateCols); e != nil {
  312. br.Msg = "保存失败"
  313. br.ErrMsg = "更新英文客户信息失败, Err:" + e.Error()
  314. return
  315. }
  316. }
  317. // 品种权限
  318. permissions := make([]*models.EnCompanyPermission, 0)
  319. for _, p := range req.EnPermissions {
  320. v := new(models.EnCompanyPermission)
  321. v.EnPermissionId = p
  322. v.EnCompanyId = item.CompanyId
  323. v.CreateTime = nowTime
  324. permissions = append(permissions, v)
  325. }
  326. if e = models.ClearAndCreateEnCompanyPermissions(item.CompanyId, permissions); e != nil {
  327. br.Msg = "保存失败"
  328. br.ErrMsg = "更新客户品种权限失败, Err: " + e.Error()
  329. return
  330. }
  331. // 记录日志
  332. go func() {
  333. opByte, e := json.Marshal(req)
  334. if e != nil {
  335. return
  336. }
  337. opData := string(opByte)
  338. opLog := &models.EnglishCompanyLog{
  339. CompanyId: item.CompanyId,
  340. AdminId: sysUser.AdminId,
  341. OptionData: opData,
  342. OptionType: opType,
  343. CreateTime: nowTime,
  344. }
  345. if e = opLog.Create(); e != nil {
  346. return
  347. }
  348. }()
  349. br.Ret = 200
  350. br.Success = true
  351. br.Msg = "操作成功"
  352. }
  353. // Del
  354. // @Title 删除英文客户及联系人
  355. // @Description 删除英文客户及联系人
  356. // @Param request body models.EnglishCompanyDelReq true "type json string"
  357. // @Success 200 string "操作成功"
  358. // @router /company/del [post]
  359. func (this *EnglishCompanyController) Del() {
  360. br := new(models.BaseResponse).Init()
  361. br.IsSendEmail = false
  362. defer func() {
  363. this.Data["json"] = br
  364. this.ServeJSON()
  365. }()
  366. sysUser := this.SysUser
  367. if sysUser == nil {
  368. br.Msg = "请登录"
  369. br.ErrMsg = "请登录,SysUser Is Empty"
  370. br.Ret = 408
  371. return
  372. }
  373. var req models.EnglishCompanyDelReq
  374. if err := json.Unmarshal(this.Ctx.Input.RequestBody, &req); err != nil {
  375. br.Msg = "参数解析异常!"
  376. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  377. return
  378. }
  379. if req.CompanyId <= 0 {
  380. br.Msg = "参数有误"
  381. return
  382. }
  383. item, e := models.GetEnglishCompanyById(req.CompanyId)
  384. if e != nil {
  385. br.Msg = "删除失败"
  386. br.ErrMsg = "获取英文客户信息失败, Err:" + e.Error()
  387. return
  388. }
  389. if e := models.DeleteEnglishCompanyAndEmails(req.CompanyId); e != nil {
  390. br.Msg = "删除失败"
  391. br.ErrMsg = "删除英文客户及联系人失败, Err: " + e.Error()
  392. return
  393. }
  394. // 删除权限
  395. if e = models.ClearAndCreateEnCompanyPermissions(item.CompanyId, make([]*models.EnCompanyPermission, 0)); e != nil {
  396. br.Msg = "删除失败"
  397. br.ErrMsg = "删除英文客户权限失败, Err: " + e.Error()
  398. return
  399. }
  400. // 记录日志
  401. go func() {
  402. nowTime := time.Now().Local()
  403. opByte, e := json.Marshal(req)
  404. if e != nil {
  405. return
  406. }
  407. opData := string(opByte)
  408. opLog := &models.EnglishCompanyLog{
  409. CompanyId: item.CompanyId,
  410. AdminId: sysUser.AdminId,
  411. OptionData: opData,
  412. OptionType: models.EnglishCompanyLogOptionTypeDel,
  413. CreateTime: nowTime,
  414. }
  415. if e = opLog.Create(); e != nil {
  416. return
  417. }
  418. }()
  419. // 同步删除客户TODO
  420. go func() {
  421. if e = models.DeleteEnglishCompanyTodoByCompanyId(req.CompanyId); e != nil {
  422. alarm_msg.SendAlarmMsg("删除英文客户同步删除TODO失败, ErrMsg: "+e.Error(), 3)
  423. }
  424. }()
  425. br.Ret = 200
  426. br.Success = true
  427. br.Msg = "操作成功"
  428. }
  429. // Detail
  430. // @Title 英文客户详情
  431. // @Description 英文客户详情
  432. // @Param CompanyId query int true "客户ID"
  433. // @Success 200 {object} models.EnglishCompanyResp
  434. // @router /company/detail [get]
  435. func (this *EnglishCompanyController) Detail() {
  436. br := new(models.BaseResponse).Init()
  437. br.IsSendEmail = false
  438. defer func() {
  439. this.Data["json"] = br
  440. this.ServeJSON()
  441. }()
  442. sysUser := this.SysUser
  443. if sysUser == nil {
  444. br.Msg = "请登录"
  445. br.ErrMsg = "请登录,SysUser Is Empty"
  446. br.Ret = 408
  447. return
  448. }
  449. companyId, _ := this.GetInt("CompanyId", 0)
  450. if companyId <= 0 {
  451. br.Msg = "参数有误"
  452. return
  453. }
  454. item, e := models.GetEnglishCompanyById(companyId)
  455. if e != nil {
  456. br.Msg = "获取失败, 客户或已被删除"
  457. return
  458. }
  459. // 品种权限
  460. permissions := make([]int, 0)
  461. {
  462. cond := fmt.Sprintf(` AND %s = ?`, models.EnCompanyPermissionColumns.EnCompanyId)
  463. pars := make([]interface{}, 0)
  464. pars = append(pars, item.CompanyId)
  465. ob := new(models.EnCompanyPermission)
  466. list, e := ob.GetItemsByCondition(cond, pars, []string{}, "")
  467. if e != nil {
  468. br.Msg = "获取失败"
  469. br.ErrMsg = "获取英文客户权限失败, Err: " + e.Error()
  470. return
  471. }
  472. for _, v := range list {
  473. permissions = append(permissions, v.EnPermissionId)
  474. }
  475. }
  476. resp := &models.EnglishCompanyResp{
  477. CompanyId: item.CompanyId,
  478. CompanyName: item.CompanyName,
  479. CountryCode: item.CountryCode,
  480. Country: item.Country,
  481. SellerId: item.SellerId,
  482. SellerName: item.SellerName,
  483. ViewTotal: item.ViewTotal,
  484. CreateTime: item.CreateTime.Format(utils.FormatDateTime),
  485. EnPermissions: permissions,
  486. }
  487. br.Ret = 200
  488. br.Success = true
  489. br.Msg = "获取成功"
  490. br.Data = resp
  491. }
  492. // ViewList
  493. // @Title 英文客户-点击量详情列表
  494. // @Description 英文客户-点击量详情列表
  495. // @Param CompanyId query int false "客户ID"
  496. // @Param SortParam query int false "排序字段:1-点击量;2-点击时间"
  497. // @Param SortType query int false "排序方式:1-倒序;2-正序"
  498. // @Success 200 {object} models.GetEnglishCompanyViewPageListResp
  499. // @router /company/view_list [get]
  500. func (this *EnglishCompanyController) ViewList() {
  501. br := new(models.BaseResponse).Init()
  502. br.IsSendEmail = false
  503. defer func() {
  504. this.Data["json"] = br
  505. this.ServeJSON()
  506. }()
  507. sysUser := this.SysUser
  508. if sysUser == nil {
  509. br.Msg = "请登录"
  510. br.ErrMsg = "请登录,SysUser Is Empty"
  511. br.Ret = 408
  512. return
  513. }
  514. // 默认点击时间降序
  515. companyId, _ := this.GetInt("CompanyId", 0)
  516. sortParam, _ := this.GetInt("SortParam", 2)
  517. sortType, _ := this.GetInt("SortType", 1)
  518. var cond, order string
  519. var pars []interface{}
  520. if companyId > 0 {
  521. cond += ` AND company_id = ?`
  522. pars = append(pars, companyId)
  523. }
  524. sortArr := []int{1, 2}
  525. if utils.InArrayByInt(sortArr, sortParam) && utils.InArrayByInt(sortArr, sortType) {
  526. pMap := map[int]string{1: "view_total", 2: "last_view_time"}
  527. tMap := map[int]string{1: "DESC", 2: "ASC"}
  528. order = fmt.Sprintf(` ORDER BY %s %s`, pMap[sortParam], tMap[sortType])
  529. }
  530. var startSize int
  531. pageSize, _ := this.GetInt("PageSize")
  532. currentIndex, _ := this.GetInt("CurrentIndex")
  533. if pageSize <= 0 {
  534. pageSize = utils.PageSize20
  535. }
  536. if currentIndex <= 0 {
  537. currentIndex = 1
  538. }
  539. startSize = paging.StartIndex(currentIndex, pageSize)
  540. // 注:点击量列表是包含被删除的联系人的历史点击量
  541. total, list, e := models.GetEnglishCompanyViewPageList(cond, pars, order, startSize, pageSize)
  542. if e != nil {
  543. br.Msg = "获取失败"
  544. br.ErrMsg = "获取英文客户点击量详情列表失败, Err: " + e.Error()
  545. return
  546. }
  547. respList := make([]*models.EnglishCompanyViewResp, 0)
  548. for i := range list {
  549. v := &models.EnglishCompanyViewResp{
  550. EmailId: list[i].Id,
  551. UserName: list[i].Name,
  552. Email: list[i].Email,
  553. ViewTotal: list[i].ViewTotal,
  554. LastViewTime: list[i].LastViewTime.Format(utils.FormatDateTime),
  555. }
  556. if v.LastViewTime == "0001-01-01 00:00:00" {
  557. v.LastViewTime = ""
  558. }
  559. respList = append(respList, v)
  560. }
  561. page := paging.GetPaging(currentIndex, pageSize, total)
  562. resp := &models.GetEnglishCompanyViewPageListResp{
  563. Paging: page,
  564. List: respList,
  565. }
  566. br.Ret = 200
  567. br.Success = true
  568. br.Msg = "获取成功"
  569. br.Data = resp
  570. }
  571. // EditEnabled
  572. // @Title 英文客户-启用/禁用
  573. // @Description 英文客户-启用/禁用
  574. // @Param request body models.EnglishCompanyEditEnabledReq true "type json string"
  575. // @Success 200 string "操作成功"
  576. // @router /company/edit_enabled [post]
  577. func (this *EnglishCompanyController) EditEnabled() {
  578. br := new(models.BaseResponse).Init()
  579. br.IsSendEmail = false
  580. defer func() {
  581. this.Data["json"] = br
  582. this.ServeJSON()
  583. }()
  584. sysUser := this.SysUser
  585. if sysUser == nil {
  586. br.Msg = "请登录"
  587. br.ErrMsg = "请登录,SysUser Is Empty"
  588. br.Ret = 408
  589. return
  590. }
  591. var req models.EnglishCompanyEditEnabledReq
  592. if err := json.Unmarshal(this.Ctx.Input.RequestBody, &req); err != nil {
  593. br.Msg = "参数解析异常!"
  594. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  595. return
  596. }
  597. if req.CompanyId <= 0 {
  598. br.Msg = "参数有误"
  599. return
  600. }
  601. if req.Enabled != 0 && req.Enabled != 1 {
  602. br.Msg = "参数有误"
  603. return
  604. }
  605. item, e := models.GetEnglishCompanyById(req.CompanyId)
  606. if e != nil {
  607. br.Msg = "客户已被删除, 请刷新页面"
  608. return
  609. }
  610. // 更新客户
  611. nowTime := time.Now().Local()
  612. item.Enabled = req.Enabled
  613. item.ModifyTime = nowTime
  614. updateCols := []string{"Enabled", "ModifyTime"}
  615. if e = item.Update(updateCols); e != nil {
  616. br.Msg = "操作失败"
  617. br.ErrMsg = "更新英文客户状态失败, Err:" + e.Error()
  618. return
  619. }
  620. // 更新其下联系人状态
  621. if e = models.UpdateEnglishEmailEnabledByCompanyId(item.CompanyId, req.Enabled); e != nil {
  622. br.Msg = "操作失败"
  623. br.ErrMsg = "更新英文客户下的联系人状态失败, Err: " + e.Error()
  624. return
  625. }
  626. // 记录日志
  627. go func() {
  628. opByte, e := json.Marshal(req)
  629. if e != nil {
  630. return
  631. }
  632. opData := string(opByte)
  633. opLog := &models.EnglishCompanyLog{
  634. CompanyId: item.CompanyId,
  635. AdminId: sysUser.AdminId,
  636. OptionData: opData,
  637. OptionType: models.EnglishCompanyLogOptionTypeEditEnabled,
  638. CreateTime: nowTime,
  639. }
  640. if e = opLog.Create(); e != nil {
  641. return
  642. }
  643. }()
  644. br.Ret = 200
  645. br.Success = true
  646. br.Msg = "操作成功"
  647. }
  648. // SavePermission
  649. // @Title 英文客户-保存权限
  650. // @Description 英文客户-保存权限
  651. // @Param request body models.EnglishCompanySaveReq true "type json string"
  652. // @Success 200 string "操作成功"
  653. // @router /company/save_permission [post]
  654. func (this *EnglishCompanyController) SavePermission() {
  655. br := new(models.BaseResponse).Init()
  656. br.IsSendEmail = false
  657. defer func() {
  658. this.Data["json"] = br
  659. this.ServeJSON()
  660. }()
  661. sysUser := this.SysUser
  662. if sysUser == nil {
  663. br.Msg = "请登录"
  664. br.ErrMsg = "请登录,SysUser Is Empty"
  665. br.Ret = 408
  666. return
  667. }
  668. var req models.EnglishCompanySaveReq
  669. if err := json.Unmarshal(this.Ctx.Input.RequestBody, &req); err != nil {
  670. br.Msg = "参数解析异常!"
  671. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  672. return
  673. }
  674. if req.CompanyId <= 0 {
  675. br.Msg = "参数有误"
  676. br.ErrMsg = "参数有误"
  677. return
  678. }
  679. if len(req.EnPermissions) <= 0 {
  680. br.Msg = "请至少选择一个品种权限"
  681. return
  682. }
  683. nowTime := time.Now().Local()
  684. item, e := models.GetEnglishCompanyById(req.CompanyId)
  685. if e != nil {
  686. if e.Error() == utils.ErrNoRow() {
  687. br.Msg = "客户已被删除, 请刷新页面"
  688. return
  689. }
  690. br.Msg = "操作失败"
  691. br.ErrMsg = "获取客户信息失败, Err: " + e.Error()
  692. return
  693. }
  694. // 品种权限
  695. permissions := make([]*models.EnCompanyPermission, 0)
  696. for _, p := range req.EnPermissions {
  697. v := new(models.EnCompanyPermission)
  698. v.EnPermissionId = p
  699. v.EnCompanyId = item.CompanyId
  700. v.CreateTime = nowTime
  701. permissions = append(permissions, v)
  702. }
  703. if e := models.ClearAndCreateEnCompanyPermissions(item.CompanyId, permissions); e != nil {
  704. br.Msg = "保存失败"
  705. br.ErrMsg = "更新客户品种权限失败, Err: " + e.Error()
  706. return
  707. }
  708. // 记录日志
  709. go func() {
  710. opByte, e := json.Marshal(req)
  711. if e != nil {
  712. return
  713. }
  714. opData := string(opByte)
  715. opLog := &models.EnglishCompanyLog{
  716. CompanyId: item.CompanyId,
  717. AdminId: sysUser.AdminId,
  718. OptionData: opData,
  719. OptionType: models.EnglishCompanyLogOptionTypeSavePermission,
  720. CreateTime: nowTime,
  721. }
  722. if e = opLog.Create(); e != nil {
  723. return
  724. }
  725. }()
  726. br.Ret = 200
  727. br.Success = true
  728. br.Msg = "操作成功"
  729. }