send_company_user.go 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682
  1. package services
  2. import (
  3. "context"
  4. "encoding/json"
  5. "fmt"
  6. "github.com/tealeg/xlsx"
  7. "hongze/hongze_cygx/models"
  8. "hongze/hongze_cygx/utils"
  9. "io/ioutil"
  10. "net/http"
  11. "os"
  12. "path/filepath"
  13. "strconv"
  14. "strings"
  15. "time"
  16. )
  17. type GetShangHaiTokenResultApi struct {
  18. Code int `json:"code"`
  19. Msg string `json:"msg"`
  20. Time int `json:"time"`
  21. Data ShangHaiResultApidate `json:"data"`
  22. }
  23. type ShangHaiResultApidate struct {
  24. AccessToken string `json:"access_token"`
  25. ExpireIn int `json:"expire_in"`
  26. }
  27. type GetShangHaiTokenResultApiComPany struct {
  28. Code int `json:"code"`
  29. Msg string `json:"msg"`
  30. Time int `json:"time"`
  31. Data FailInfos `json:"data"`
  32. }
  33. type FailInfos struct {
  34. TotalCount int `json:"total_count"`
  35. FailInfo []ShangHaiResultApidateComPany `json:"fail_info"`
  36. }
  37. type ShangHaiResultApidateComPany struct {
  38. ErrVal string `json:"errVal"`
  39. ErrMsg string `json:"errMsg"`
  40. }
  41. type OriginalUserInfoResp struct {
  42. Mobile string `json:"Mobile"`
  43. RealName string `json:"RealName"`
  44. }
  45. //c
  46. func SendComapnyToShanghai(url, jsonCompany, postType string) (err error) {
  47. var msg string
  48. defer func() {
  49. if err != nil {
  50. go utils.SendAlarmMsg(msg, 1)
  51. go utils.SendEmail("同步策略平台获取数据信息失败"+"【"+utils.APPNAME+"】"+time.Now().Format("2006-01-02 15:04:05"), msg+";Err:"+err.Error(), utils.EmailSendToExpert)
  52. }
  53. }()
  54. method := "POST"
  55. payload := strings.NewReader(jsonCompany)
  56. client := &http.Client{}
  57. req, err := http.NewRequest(method, url, payload)
  58. if err != nil {
  59. msg = "NewRequest Err:" + err.Error()
  60. return err
  61. }
  62. req.Header.Add("Content-Type", "application/json")
  63. res, err := client.Do(req)
  64. if err != nil {
  65. msg = "client.Do Err:" + err.Error()
  66. return err
  67. }
  68. defer res.Body.Close()
  69. body, err := ioutil.ReadAll(res.Body)
  70. if err != nil {
  71. msg = "ioutil.ReadAll Err:" + err.Error()
  72. return err
  73. }
  74. var result GetShangHaiTokenResultApiComPany
  75. err = json.Unmarshal(body, &result)
  76. if err != nil {
  77. msg = "json.Unmarshal Err:" + err.Error()
  78. return err
  79. }
  80. item := new(models.CygxShanghaiCompanyLog)
  81. item.CreateTime = time.Now()
  82. item.Url = url
  83. item.Body = jsonCompany
  84. item.Result = string(body)
  85. go models.AddCygxShanghaiCompanyLog(item)
  86. for _, v := range result.Data.FailInfo {
  87. if v.ErrMsg != "" {
  88. //companyCode += "'" + v.ErrVal + "',"
  89. item := new(models.CygxShanghaiErrLog)
  90. item.CreateTime = time.Now()
  91. item.ErrMsg = v.ErrMsg
  92. item.ErrVal = v.ErrVal
  93. item.ErrType = postType
  94. go models.AddCygxShanghaiErrLog(item)
  95. }
  96. }
  97. return
  98. }
  99. func DotongbuShangHai(cont context.Context) (err error) {
  100. //func DotongbuShangHai() (err error) {
  101. //先删除被禁用的用户
  102. DeleteUserDotongbuShangHaiApi()
  103. var condition string
  104. updateTime := time.Now().Add(-time.Minute * 22).Format("2006-01-02 15:04:05")
  105. listUpdateUser, err := models.GetWxUserOpLog(updateTime)
  106. if err != nil && err.Error() != utils.ErrNoRow() {
  107. fmt.Println(err)
  108. return err
  109. }
  110. var companyIds string
  111. if len(listUpdateUser) > 0 {
  112. for _, v := range listUpdateUser {
  113. companyIds += strconv.Itoa(v.CompanyId) + ","
  114. }
  115. }
  116. ////获取冻结跟流失的客户
  117. listFreezeAndLoss, err := models.GetCompanyFreezeAndLoss(updateTime)
  118. if err != nil && err.Error() != utils.ErrNoRow() {
  119. return err
  120. }
  121. if len(listFreezeAndLoss) > 0 {
  122. for _, v := range listFreezeAndLoss {
  123. companyIds += strconv.Itoa(v.CompanyId) + ","
  124. }
  125. }
  126. listDeleteUser, err := models.GetWxUserOpLogDelete(updateTime)
  127. if err != nil && err.Error() != utils.ErrNoRow() {
  128. return err
  129. }
  130. ////获取删除客户
  131. if len(listDeleteUser) > 0 {
  132. for _, v := range listDeleteUser {
  133. companyIds += strconv.Itoa(v.CompanyId) + ","
  134. }
  135. }
  136. //获取指定时间内被移动的客户
  137. listOperationRecord, err := models.GetCompanyOperationRecord(updateTime)
  138. if err != nil && err.Error() != utils.ErrNoRow() {
  139. return err
  140. }
  141. if len(listOperationRecord) > 0 {
  142. for _, v := range listOperationRecord {
  143. companyIds += strconv.Itoa(v.CompanyId) + ","
  144. }
  145. }
  146. condition = ` AND p.is_suspend = 0 AND p.modify_time > ` + "'" + updateTime + "'"
  147. companyIds = strings.TrimRight(companyIds, ",")
  148. fmt.Println("获取冻结跟流失的用户", len(listFreezeAndLoss))
  149. //return err
  150. if companyIds != "" {
  151. //这一部分先不推送,避免并发推送
  152. condition += ` AND c.company_id NOT IN (` + companyIds + ") "
  153. }
  154. //偶尔需要单独同步某一个公司的人员
  155. //condition = ` AND c.company_id = 5676 `
  156. //同30小时有变更的公司
  157. DotongbuShangHaApi(condition)
  158. //原有的公司如果新增了也同步
  159. companyIds = strings.TrimRight(companyIds, ",")
  160. if companyIds != "" {
  161. condition = ` AND p.is_suspend = 0 AND c.company_id IN (` + companyIds + ")"
  162. DotongbuShangHaApi(condition)
  163. }
  164. //处理被禁用的用户,将禁用用户的状态同步
  165. CompanySuspend()
  166. return
  167. }
  168. func DotongbuShangHaApi(condition string) (err error) {
  169. var msg string
  170. defer func() {
  171. if err != nil {
  172. fmt.Println(err)
  173. go utils.SendAlarmMsg("同步策略平台获取数据信息失败", 2)
  174. go utils.SendEmail("同步策略平台获取数据信息失败"+"【"+utils.APPNAME+"】"+time.Now().Format("2006-01-02 15:04:05"), msg+";Err:"+err.Error(), utils.EmailSendToExpert)
  175. }
  176. }()
  177. var url string
  178. accessToken, err := GetShangHaiCrmApiToken()
  179. if err != nil {
  180. return
  181. }
  182. //同步权益客户
  183. companyList, err := models.GetSendCompanyList(condition)
  184. if err != nil {
  185. msg = "GetSendCompanyList Err:" + err.Error()
  186. return
  187. }
  188. fmt.Println("权益客户", len(companyList))
  189. var companyItems []*models.CompanyJson
  190. if len(companyList) > 0 {
  191. //url = "https://crm.hzinsights.com/openapi/v1/Customer/batchSyncFiccCustomer?access_token=" + accessToken
  192. url = utils.ShangHaiCrmApiLink + "openapi/v1/Customer/batchSyncFiccCustomer?access_token=" + accessToken
  193. for k, _ := range companyList {
  194. companyList[k].Fe = "权益"
  195. companyList[k].EndDate = strconv.Itoa(int(companyList[k].EndDateTime.Unix()))
  196. //一次同步一百条
  197. companyItems = append(companyItems, companyList[k])
  198. if (k+1)%100 == 0 {
  199. data, err := json.Marshal(companyItems)
  200. if err != nil {
  201. msg = "companyItems Err:" + err.Error()
  202. return err
  203. }
  204. jsonstr := string(data)
  205. jsonstr = "{\"sync_data\": " + jsonstr + " }"
  206. SendComapnyToShanghai(url, jsonstr, "权益")
  207. companyItems = make([]*models.CompanyJson, 0)
  208. }
  209. }
  210. //如果剩下还有则同步剩下的部分
  211. if len(companyItems) > 0 {
  212. data, err := json.Marshal(companyItems)
  213. if err != nil {
  214. msg = "companyItems Err:" + err.Error()
  215. return err
  216. }
  217. jsonstr := string(data)
  218. jsonstr = "{\"sync_data\": " + jsonstr + " }"
  219. SendComapnyToShanghai(url, jsonstr, "权益")
  220. companyItems = make([]*models.CompanyJson, 0)
  221. }
  222. }
  223. //同步FICC客户
  224. companyFiccList, err := models.GetSendCompanyFiccList(condition)
  225. if err != nil {
  226. msg = "GetSendCompanyFiccList Err:" + err.Error()
  227. return err
  228. }
  229. fmt.Println("FICC客户", len(companyFiccList))
  230. var companyFiccItems []*models.CompanyJson
  231. if len(companyFiccList) > 0 {
  232. //url = "https://crm.hzinsights.com/openapi/v1/Customer/batchSyncFiccCustomer?access_token=" + accessToken
  233. url = utils.ShangHaiCrmApiLink + "openapi/v1/Customer/batchSyncFiccCustomer?access_token=" + accessToken
  234. for k, _ := range companyFiccList {
  235. companyFiccList[k].Fe = "FICC"
  236. companyFiccList[k].EndDate = strconv.Itoa(int(companyFiccList[k].EndDateTime.Unix()))
  237. //一次同步一百条
  238. companyFiccItems = append(companyFiccItems, companyFiccList[k])
  239. if (k+1)%100 == 0 {
  240. data, err := json.Marshal(companyFiccItems)
  241. if err != nil {
  242. msg = "companyFiccItems Err:" + err.Error()
  243. return err
  244. }
  245. jsonstr := string(data)
  246. jsonstr = "{\"sync_data\": " + jsonstr + " }"
  247. SendComapnyToShanghai(url, jsonstr, "FICC")
  248. companyFiccItems = make([]*models.CompanyJson, 0)
  249. }
  250. }
  251. //如果剩下还有则同步剩下的部分
  252. if len(companyFiccItems) > 0 {
  253. data, err := json.Marshal(companyFiccItems)
  254. if err != nil {
  255. msg = "companyFiccItems Err:" + err.Error()
  256. return err
  257. }
  258. jsonstr := string(data)
  259. jsonstr = "{\"sync_data\": " + jsonstr + " }"
  260. SendComapnyToShanghai(url, jsonstr, "FICC")
  261. }
  262. }
  263. userList, err := models.GetSendUserList(condition)
  264. if err != nil {
  265. msg = "GetSendUserList Err:" + err.Error()
  266. return err
  267. }
  268. fmt.Println("用户", len(userList))
  269. var userItems []*models.UserJson
  270. if len(userList) > 0 {
  271. //url = "https://crm.hzinsights.com/openapi/v1/CustomerContact/batchSyncFiccCustomerContact?access_token=" + accessToken
  272. url = utils.ShangHaiCrmApiLink + "openapi/v1/CustomerContact/batchSyncFiccCustomerContact?access_token=" + accessToken
  273. for k, v := range userList {
  274. if v.Sex == "1" {
  275. userList[k].Sex = "男"
  276. } else {
  277. userList[k].Sex = "女"
  278. }
  279. if v.IsMaker == "1" {
  280. userList[k].IsMaker = "是"
  281. } else {
  282. userList[k].IsMaker = "否"
  283. }
  284. userList[k].CountryCode = "+" + v.CountryCode
  285. userList[k].OutboundCountryCode = "+" + v.OutboundCountryCode
  286. if userList[k].Mobile != "" && userList[k].OutboundMobile != "" && userList[k].Mobile == userList[k].OutboundMobile {
  287. userList[k].OutboundMobile = ""
  288. userList[k].OutboundCountryCode = ""
  289. }
  290. //一次同步一百条
  291. userItems = append(userItems, userList[k])
  292. if (k+1)%100 == 0 {
  293. data, err := json.Marshal(userItems)
  294. if err != nil {
  295. msg = "userItems Err:" + err.Error()
  296. return err
  297. }
  298. fmt.Println(k)
  299. jsonstr := string(data)
  300. jsonstr = "{\"sync_data\": " + jsonstr + " }"
  301. SendComapnyToShanghai(url, jsonstr, "user")
  302. userItems = make([]*models.UserJson, 0)
  303. }
  304. }
  305. //如果剩下还有则同步剩下的部分
  306. if len(userItems) > 0 {
  307. data, err := json.Marshal(userItems)
  308. if err != nil {
  309. msg = "userItems Err:" + err.Error()
  310. return err
  311. }
  312. jsonstr := string(data)
  313. jsonstr = "{\"sync_data\": " + jsonstr + " }"
  314. SendComapnyToShanghai(url, jsonstr, "user")
  315. companyItems = make([]*models.CompanyJson, 0)
  316. }
  317. }
  318. return
  319. }
  320. func DotongbuShangHaiSendEmail(cont context.Context) (err error) {
  321. var msg string
  322. defer func() {
  323. if err != nil {
  324. go utils.SendAlarmMsg("发送邮件:同步用户到策略平台信息失败", 2)
  325. go utils.SendEmail("发送邮件:同步用户到策略平台信息失败"+"【"+utils.APPNAME+"】"+time.Now().Format("2006-01-02 15:04:05"), msg+";Err:"+err.Error(), utils.EmailSendToExpert)
  326. }
  327. }()
  328. list, err := models.GetCygxShanghaiCompanyLog()
  329. if err != nil {
  330. msg = "GetCygxShanghaiCompanyLog Err:" + err.Error()
  331. return err
  332. }
  333. mapErrMsg := make(map[string]string)
  334. for _, v := range list {
  335. data := new(GetShangHaiTokenResultApiComPany)
  336. err := json.Unmarshal([]byte(v.Result), &data)
  337. if err != nil {
  338. msg = "GetShangHaiTokenResultApiComPany Err:" + err.Error()
  339. return err
  340. }
  341. if len(data.Data.FailInfo) > 0 {
  342. for _, vCompany := range data.Data.FailInfo {
  343. mapErrMsg[vCompany.ErrVal] = vCompany.ErrMsg
  344. }
  345. }
  346. }
  347. //创建excel
  348. dir, err := os.Executable()
  349. exPath := filepath.Dir(dir)
  350. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + utils.GetRandDigit(5) + ".xlsx"
  351. xlsxFile := xlsx.NewFile()
  352. if err != nil {
  353. return
  354. }
  355. style := xlsx.NewStyle()
  356. alignment := xlsx.Alignment{
  357. Horizontal: "center",
  358. Vertical: "center",
  359. WrapText: true,
  360. }
  361. style.Alignment = alignment
  362. style.ApplyAlignment = true
  363. sheet, err := xlsxFile.AddSheet("上海策略品台同步名单")
  364. if err != nil {
  365. return
  366. }
  367. //设置宽度
  368. _ = sheet.SetColWidth(0, 1, 30)
  369. _ = sheet.SetColWidth(2, 2, 10)
  370. _ = sheet.SetColWidth(3, 3, 30)
  371. //标头
  372. rowTitle := sheet.AddRow()
  373. cellA := rowTitle.AddCell()
  374. cellA.Value = "客户名称"
  375. cellB := rowTitle.AddCell()
  376. cellB.Value = "社会信用码"
  377. cellC := rowTitle.AddCell()
  378. cellC.Value = "客户类型"
  379. cellD := rowTitle.AddCell()
  380. cellD.Value = "错误消息"
  381. for _, v := range list {
  382. data := new(models.CompanyUnJsonList)
  383. err := json.Unmarshal([]byte(v.Body), &data)
  384. if err != nil {
  385. msg = "CompanyUnJsonList Err:" + err.Error()
  386. return err
  387. }
  388. if len(data.SyncData) > 0 {
  389. for _, item := range data.SyncData {
  390. row := sheet.AddRow()
  391. cellA := row.AddCell()
  392. cellA.Value = item.CompanyName
  393. cellB := row.AddCell()
  394. cellB.Value = item.CreditCode
  395. cellC := row.AddCell()
  396. cellC.Value = item.Fe
  397. if mapErrMsg[item.CreditCode] != "" {
  398. cellD := row.AddCell()
  399. cellD.Value = mapErrMsg[item.CreditCode]
  400. }
  401. }
  402. }
  403. }
  404. title := time.Now().Format(utils.FormatDate) + "上海策略品台同步名单"
  405. content := time.Now().Format(utils.FormatDate) + "上海策略品台同步名单"
  406. fileName := downLoadnFilePath
  407. err = xlsxFile.Save(downLoadnFilePath)
  408. if err != nil {
  409. return
  410. }
  411. if len(list) > 0 {
  412. utils.SendEmailByHongze(title, content, "cxzhang@hzinsights.com;tshen@hzinsights.com", fileName, title+".xlsx")
  413. }
  414. os.Remove(downLoadnFilePath)
  415. go models.DeleteCygxShanghaiCompanyLog()
  416. return
  417. }
  418. //DeleteUserDotongbuShangHaApi 删除用户进行同步
  419. func DeleteUserDotongbuShangHaiApi() (err error) {
  420. var msg string
  421. defer func() {
  422. if err != nil {
  423. go utils.SendAlarmMsg("同步策略平台获取数据信息失败 DeleteUserDotongbuShangHaApi"+err.Error()+msg, 2)
  424. }
  425. }()
  426. updateTime := time.Now().Add(-time.Minute * 22).Format("2006-01-02 15:04:05")
  427. listDeleteUser, err := models.GetWxUserOpLogDelete(updateTime)
  428. if err != nil && err.Error() != utils.ErrNoRow() {
  429. return err
  430. }
  431. fmt.Println("删除用户", len(listDeleteUser))
  432. if len(listDeleteUser) > 0 {
  433. var deleteCompanyIds string
  434. for k, v := range listDeleteUser {
  435. deleteCompanyIds += strconv.Itoa(v.CompanyId) + ","
  436. var resultUser OriginalUserInfoResp
  437. if err := json.Unmarshal([]byte(v.OriginalUserInfo), &resultUser); err == nil {
  438. listDeleteUser[k].RealName = resultUser.RealName
  439. } else {
  440. return err
  441. }
  442. }
  443. } else {
  444. return err
  445. }
  446. var url string
  447. accessToken, err := GetShangHaiCrmApiToken()
  448. if err != nil {
  449. return
  450. }
  451. var userItems []*models.ShangHaiCrmUserDeleteResp
  452. if len(listDeleteUser) > 0 {
  453. url = utils.ShangHaiCrmApiLink + "openapi/v1/CustomerContact/batchDisableCustomerContact?access_token=" + accessToken
  454. for k, v := range listDeleteUser {
  455. userItem := new(models.ShangHaiCrmUserDeleteResp)
  456. userItem.Name = v.RealName
  457. userItem.Mobile = v.Mobile
  458. userItem.Social = v.CreditCode
  459. //一次同步一百条
  460. userItems = append(userItems, userItem)
  461. if (k+1)%100 == 0 {
  462. data, err := json.Marshal(userItems)
  463. if err != nil {
  464. msg = "companyItems Err:" + err.Error()
  465. return err
  466. }
  467. jsonstr := string(data)
  468. jsonstr = "{\"data\": " + jsonstr + " }"
  469. SendComapnyToShanghai(url, jsonstr, "权益")
  470. userItems = make([]*models.ShangHaiCrmUserDeleteResp, 0)
  471. }
  472. }
  473. //如果剩下还有则同步剩下的部分
  474. if len(userItems) > 0 {
  475. data, err := json.Marshal(userItems)
  476. if err != nil {
  477. msg = "companyItems Err:" + err.Error()
  478. return err
  479. }
  480. jsonstr := string(data)
  481. jsonstr = "{\"data\": " + jsonstr + " }"
  482. SendComapnyToShanghai(url, jsonstr, "权益")
  483. userItems = make([]*models.ShangHaiCrmUserDeleteResp, 0)
  484. }
  485. }
  486. return
  487. }
  488. //获取用户的Token
  489. func GetShangHaiCrmApiToken() (token string, err error) {
  490. var msg string
  491. defer func() {
  492. if err != nil {
  493. go utils.SendAlarmMsg("同步策略平台获取数据信息失败 DeleteUserDotongbuShangHaApi"+err.Error()+msg, 2)
  494. }
  495. }()
  496. cacheKey := utils.SHANG_HAI_CRM_API_TOKEN
  497. ttlTime := utils.Rc.GetRedisTTL(cacheKey)
  498. if ttlTime > 0 {
  499. token, _ = utils.Rc.RedisString(cacheKey)
  500. }
  501. if token == "" {
  502. //获取token
  503. url := utils.ShangHaiCrmApiLink + "openapi/v1/auth/getAccessToken?app_key=26945134&app_secret=b99cb2bdec70d20156000f664ec5ac30"
  504. method := "GET"
  505. client := &http.Client{}
  506. req, errReq := http.NewRequest(method, url, nil)
  507. if errReq != nil {
  508. err = errReq
  509. return
  510. }
  511. res, errReq := client.Do(req)
  512. if errReq != nil {
  513. err = errReq
  514. return
  515. }
  516. defer res.Body.Close()
  517. body, errReq := ioutil.ReadAll(res.Body)
  518. if errReq != nil {
  519. err = errReq
  520. return
  521. }
  522. var result GetShangHaiTokenResultApi
  523. errReq = json.Unmarshal(body, &result)
  524. if errReq != nil {
  525. err = errReq
  526. return
  527. }
  528. token = result.Data.AccessToken
  529. utils.Rc.Put(cacheKey, token, time.Second*7000)
  530. }
  531. return
  532. }
  533. //处理被禁用的用户,将禁用用户的状态转冻结
  534. func CompanySuspend() (err error) {
  535. var msg string
  536. defer func() {
  537. if err != nil {
  538. fmt.Println(err)
  539. go utils.SendAlarmMsg("同步策略平台处理被禁用的用户,将禁用用户的状态转冻结失败", 2)
  540. go utils.SendEmail("同步策略平台处理被禁用的用户,将禁用用户的状态转冻结失败"+"【"+utils.APPNAME+"】"+time.Now().Format("2006-01-02 15:04:05"), msg+";Err:"+err.Error(), utils.EmailSendToExpert)
  541. }
  542. }()
  543. var url string
  544. accessToken, err := GetShangHaiCrmApiToken()
  545. if err != nil {
  546. return
  547. }
  548. updateTime := time.Now().Add(-time.Minute * 22).Format("2006-01-02 15:04:05")
  549. listSuspendCompany, err := models.GetWxUserOpLogSuspend(updateTime)
  550. if err != nil && err.Error() != utils.ErrNoRow() {
  551. return err
  552. }
  553. fmt.Println("禁用的用户", len(listSuspendCompany))
  554. var suspendCompanyIds string
  555. if len(listSuspendCompany) > 0 {
  556. for _, v := range listSuspendCompany {
  557. suspendCompanyIds += strconv.Itoa(v.CompanyId) + ","
  558. }
  559. } else {
  560. return err
  561. }
  562. fmt.Println(suspendCompanyIds)
  563. //同步权益客户
  564. if suspendCompanyIds == "" {
  565. return err
  566. }
  567. suspendCompanyIds = strings.TrimRight(suspendCompanyIds, ",")
  568. condition := ` AND c.company_id IN (` + suspendCompanyIds + ")"
  569. companyList, err := models.GetSendCompanyList(condition)
  570. if err != nil {
  571. msg = "GetSendCompanyList Err:" + err.Error()
  572. fmt.Println(err)
  573. return err
  574. }
  575. fmt.Println("权益客户", len(companyList))
  576. var companyItems []*models.CompanyJson
  577. if len(companyList) > 0 {
  578. //url = "https://crm.hzinsights.com/openapi/v1/Customer/batchSyncFiccCustomer?access_token=" + accessToken
  579. url = utils.ShangHaiCrmApiLink + "openapi/v1/Customer/batchSyncFiccCustomer?access_token=" + accessToken
  580. for k, _ := range companyList {
  581. companyList[k].Fe = "权益"
  582. companyList[k].Status = "暂停"
  583. companyList[k].EndDate = strconv.Itoa(int(companyList[k].EndDateTime.Unix()))
  584. //一次同步一百条
  585. companyItems = append(companyItems, companyList[k])
  586. if (k+1)%100 == 0 {
  587. data, err := json.Marshal(companyItems)
  588. if err != nil {
  589. msg = "companyItems Err:" + err.Error()
  590. return err
  591. }
  592. jsonstr := string(data)
  593. jsonstr = "{\"sync_data\": " + jsonstr + " }"
  594. SendComapnyToShanghai(url, jsonstr, "权益")
  595. companyItems = make([]*models.CompanyJson, 0)
  596. }
  597. }
  598. //如果剩下还有则同步剩下的部分
  599. if len(companyItems) > 0 {
  600. data, err := json.Marshal(companyItems)
  601. if err != nil {
  602. msg = "companyItems Err:" + err.Error()
  603. return err
  604. }
  605. jsonstr := string(data)
  606. jsonstr = "{\"sync_data\": " + jsonstr + " }"
  607. SendComapnyToShanghai(url, jsonstr, "权益")
  608. companyItems = make([]*models.CompanyJson, 0)
  609. }
  610. }
  611. //同步FICC客户
  612. companyFiccList, err := models.GetSendCompanyFiccList(condition)
  613. if err != nil {
  614. msg = "GetSendCompanyFiccList Err:" + err.Error()
  615. return err
  616. }
  617. fmt.Println("FICC客户", len(companyFiccList))
  618. var companyFiccItems []*models.CompanyJson
  619. if len(companyFiccList) > 0 {
  620. url = utils.ShangHaiCrmApiLink + "openapi/v1/Customer/batchSyncFiccCustomer?access_token=" + accessToken
  621. for k, _ := range companyFiccList {
  622. companyFiccList[k].Fe = "FICC"
  623. companyList[k].Status = "暂停"
  624. companyFiccList[k].EndDate = strconv.Itoa(int(companyFiccList[k].EndDateTime.Unix()))
  625. //一次同步一百条
  626. companyFiccItems = append(companyFiccItems, companyFiccList[k])
  627. if (k+1)%100 == 0 {
  628. data, err := json.Marshal(companyFiccItems)
  629. if err != nil {
  630. msg = "companyFiccItems Err:" + err.Error()
  631. return err
  632. }
  633. jsonstr := string(data)
  634. jsonstr = "{\"sync_data\": " + jsonstr + " }"
  635. SendComapnyToShanghai(url, jsonstr, "FICC")
  636. companyFiccItems = make([]*models.CompanyJson, 0)
  637. }
  638. }
  639. //如果剩下还有则同步剩下的部分
  640. if len(companyFiccItems) > 0 {
  641. data, err := json.Marshal(companyFiccItems)
  642. if err != nil {
  643. msg = "companyFiccItems Err:" + err.Error()
  644. return err
  645. }
  646. jsonstr := string(data)
  647. jsonstr = "{\"sync_data\": " + jsonstr + " }"
  648. SendComapnyToShanghai(url, jsonstr, "FICC")
  649. }
  650. }
  651. return
  652. }