english_company.go 21 KB

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