send_company_user.go 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393
  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. //c
  42. func SendComapnyToShanghai(url, jsonCompany, postType string) (err error) {
  43. var msg string
  44. defer func() {
  45. if err != nil {
  46. go utils.SendEmail("同步策略平台获取数据信息失败"+"【"+utils.APPNAME+"】"+time.Now().Format("2006-01-02 15:04:05"), msg+";Err:"+err.Error(), utils.EmailSendToExpert)
  47. }
  48. }()
  49. method := "POST"
  50. //fmt.Println(string(jsonCompany))
  51. //utils.FileLog.Info(string(jsonCompany))
  52. payload := strings.NewReader(jsonCompany)
  53. client := &http.Client{}
  54. req, err := http.NewRequest(method, url, payload)
  55. if err != nil {
  56. msg = "NewRequest Err:" + err.Error()
  57. return err
  58. }
  59. req.Header.Add("Content-Type", "application/json")
  60. res, err := client.Do(req)
  61. if err != nil {
  62. msg = "client.Do Err:" + err.Error()
  63. return err
  64. }
  65. defer res.Body.Close()
  66. body, err := ioutil.ReadAll(res.Body)
  67. if err != nil {
  68. msg = "ioutil.ReadAll Err:" + err.Error()
  69. return err
  70. }
  71. var result GetShangHaiTokenResultApiComPany
  72. err = json.Unmarshal(body, &result)
  73. if err != nil {
  74. msg = "json.Unmarshal Err:" + err.Error()
  75. return err
  76. }
  77. //if result.Code != 1 {
  78. // go utils.SendEmail("同步策略平台信息失败"+"【"+utils.APPNAME+"】"+time.Now().Format("2006-01-02 15:04:05"), url, utils.EmailSendToExpert)
  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. if strings.Index(string(body), "必填") > 0 || strings.Index(string(body), "失败") > 0 || strings.Index(string(body), "社会信用代码格式错误") > 0 {
  87. go utils.SendEmail("同步策略平台信息失败"+"【"+utils.APPNAME+"】"+time.Now().Format("2006-01-02 15:04:05"), string(body), utils.EmailSendToExpert)
  88. }
  89. //var companyCode string
  90. for _, v := range result.Data.FailInfo {
  91. if v.ErrMsg != "" {
  92. //companyCode += "'" + v.ErrVal + "',"
  93. item := new(models.CygxShanghaiErrLog)
  94. item.CreateTime = time.Now()
  95. item.ErrMsg = v.ErrMsg
  96. item.ErrVal = v.ErrVal
  97. item.ErrType = postType
  98. go models.AddCygxShanghaiErrLog(item)
  99. }
  100. }
  101. return
  102. //给产品导数据用,别删
  103. //companyCode = postType + companyCode
  104. ////fmt.Println(result.Data.FailInfo)
  105. //utils.FileLog.Info(string(companyCode))
  106. //utils.FileLog.Info(string(body))
  107. //fmt.Println(string(body))
  108. }
  109. func DotongbuShangHai(cont context.Context) (err error) {
  110. var msg string
  111. defer func() {
  112. if err != nil {
  113. go utils.SendEmail("同步策略平台获取数据信息失败"+"【"+utils.APPNAME+"】"+time.Now().Format("2006-01-02 15:04:05"), msg+";Err:"+err.Error(), utils.EmailSendToExpert)
  114. }
  115. }()
  116. //同步24小时之前的数据到上海平台,为防止遗漏改成30小时
  117. var condition string
  118. updateTime := time.Now().Add(-time.Hour * 30).Format("2006-01-02 15:04:05")
  119. condition = ` AND p.modify_time > ` + "'" + updateTime + "'"
  120. fmt.Println(condition)
  121. //获取token
  122. url := "https://crm.hzinsights.com/openapi/v1/auth/getAccessToken?app_key=26945134&app_secret=b99cb2bdec70d20156000f664ec5ac30"
  123. method := "GET"
  124. client := &http.Client{}
  125. req, err := http.NewRequest(method, url, nil)
  126. if err != nil {
  127. msg = "GetToken Err:" + err.Error()
  128. return err
  129. }
  130. res, err := client.Do(req)
  131. if err != nil {
  132. msg = "client Err:" + err.Error()
  133. return err
  134. }
  135. defer res.Body.Close()
  136. body, err := ioutil.ReadAll(res.Body)
  137. if err != nil {
  138. msg = "body Err:" + err.Error()
  139. return
  140. }
  141. var result GetShangHaiTokenResultApi
  142. err = json.Unmarshal(body, &result)
  143. if err != nil {
  144. msg = "Get result Err:" + err.Error()
  145. return
  146. }
  147. accessToken := result.Data.AccessToken
  148. fmt.Println(accessToken)
  149. //同步权益客户
  150. companyList, err := models.GetSendCompanyList(condition)
  151. if err != nil {
  152. msg = "GetSendCompanyList Err:" + err.Error()
  153. return
  154. }
  155. fmt.Println("权益客户", len(companyList))
  156. var companyItems []*models.CompanyJson
  157. if len(companyList) > 0 {
  158. url = "https://crm.hzinsights.com/openapi/v1/Customer/batchSyncFiccCustomer?access_token=" + accessToken
  159. for k, _ := range companyList {
  160. companyList[k].Fe = "权益"
  161. companyList[k].EndDate = strconv.Itoa(int(companyList[k].EndDateTime.Unix()))
  162. //一次同步一百条
  163. companyItems = append(companyItems, companyList[k])
  164. if (k+1)%100 == 0 {
  165. data, err := json.Marshal(companyItems)
  166. if err != nil {
  167. msg = "companyItems Err:" + err.Error()
  168. return err
  169. }
  170. jsonstr := string(data)
  171. jsonstr = "{\"sync_data\": " + jsonstr + " }"
  172. SendComapnyToShanghai(url, jsonstr, "权益")
  173. companyItems = make([]*models.CompanyJson, 0)
  174. }
  175. }
  176. //如果剩下还有则同步剩下的部分
  177. if len(companyItems) > 0 {
  178. data, err := json.Marshal(companyItems)
  179. if err != nil {
  180. msg = "companyItems Err:" + err.Error()
  181. return err
  182. }
  183. jsonstr := string(data)
  184. jsonstr = "{\"sync_data\": " + jsonstr + " }"
  185. SendComapnyToShanghai(url, jsonstr, "权益")
  186. companyItems = make([]*models.CompanyJson, 0)
  187. }
  188. }
  189. //同步FICC客户
  190. companyFiccList, err := models.GetSendCompanyFiccList(condition)
  191. if err != nil {
  192. msg = "GetSendCompanyFiccList Err:" + err.Error()
  193. return err
  194. }
  195. fmt.Println("FICC客户", len(companyFiccList))
  196. var companyFiccItems []*models.CompanyJson
  197. if len(companyFiccList) > 0 {
  198. url = "https://crm.hzinsights.com/openapi/v1/Customer/batchSyncFiccCustomer?access_token=" + accessToken
  199. for k, _ := range companyFiccList {
  200. companyFiccList[k].Fe = "FICC"
  201. companyFiccList[k].EndDate = strconv.Itoa(int(companyFiccList[k].EndDateTime.Unix()))
  202. //一次同步一百条
  203. companyFiccItems = append(companyFiccItems, companyFiccList[k])
  204. if (k+1)%100 == 0 {
  205. data, err := json.Marshal(companyFiccItems)
  206. if err != nil {
  207. msg = "companyFiccItems Err:" + err.Error()
  208. return err
  209. }
  210. jsonstr := string(data)
  211. jsonstr = "{\"sync_data\": " + jsonstr + " }"
  212. SendComapnyToShanghai(url, jsonstr, "FICC")
  213. companyFiccItems = make([]*models.CompanyJson, 0)
  214. }
  215. }
  216. //如果剩下还有则同步剩下的部分
  217. if len(companyFiccItems) > 0 {
  218. data, err := json.Marshal(companyFiccItems)
  219. if err != nil {
  220. msg = "companyFiccItems Err:" + err.Error()
  221. return err
  222. }
  223. jsonstr := string(data)
  224. jsonstr = "{\"sync_data\": " + jsonstr + " }"
  225. SendComapnyToShanghai(url, jsonstr, "FICC")
  226. }
  227. }
  228. userList, err := models.GetSendUserList(condition)
  229. if err != nil {
  230. msg = "GetSendUserList Err:" + err.Error()
  231. return err
  232. }
  233. fmt.Println("用户", len(userList))
  234. var userItems []*models.UserJson
  235. if len(userList) > 0 {
  236. url = "https://crm.hzinsights.com/openapi/v1/CustomerContact/batchSyncFiccCustomerContact?access_token=" + accessToken
  237. for k, v := range userList {
  238. if v.Sex == "1" {
  239. userList[k].Sex = "男"
  240. } else {
  241. userList[k].Sex = "女"
  242. }
  243. if v.IsMaker == "1" {
  244. userList[k].IsMaker = "是"
  245. } else {
  246. userList[k].IsMaker = "否"
  247. }
  248. userList[k].CountryCode = "+" + v.CountryCode
  249. userList[k].OutboundCountryCode = "+" + v.OutboundCountryCode
  250. if userList[k].Mobile != "" && userList[k].OutboundMobile != "" && userList[k].Mobile == userList[k].OutboundMobile {
  251. userList[k].OutboundMobile = ""
  252. userList[k].OutboundCountryCode = ""
  253. }
  254. //一次同步一百条
  255. userItems = append(userItems, userList[k])
  256. if (k+1)%100 == 0 {
  257. data, err := json.Marshal(userItems)
  258. if err != nil {
  259. msg = "userItems Err:" + err.Error()
  260. return err
  261. }
  262. fmt.Println(k)
  263. jsonstr := string(data)
  264. jsonstr = "{\"sync_data\": " + jsonstr + " }"
  265. SendComapnyToShanghai(url, jsonstr, "user")
  266. userItems = make([]*models.UserJson, 0)
  267. }
  268. }
  269. //如果剩下还有则同步剩下的部分
  270. if len(userItems) > 0 {
  271. data, err := json.Marshal(userItems)
  272. if err != nil {
  273. msg = "userItems Err:" + err.Error()
  274. return err
  275. }
  276. jsonstr := string(data)
  277. jsonstr = "{\"sync_data\": " + jsonstr + " }"
  278. SendComapnyToShanghai(url, jsonstr, "user")
  279. companyItems = make([]*models.CompanyJson, 0)
  280. }
  281. }
  282. return
  283. }
  284. func DotongbuShangHaiSendEmail(cont context.Context) (err error) {
  285. var msg string
  286. defer func() {
  287. if err != nil {
  288. go utils.SendEmail("发送邮件同步策略平台获取数据信息失败"+"【"+utils.APPNAME+"】"+time.Now().Format("2006-01-02 15:04:05"), msg+";Err:"+err.Error(), utils.EmailSendToExpert)
  289. }
  290. }()
  291. list, err := models.GetCygxShanghaiCompanyLog()
  292. if err != nil {
  293. msg = "GetCygxShanghaiCompanyLog Err:" + err.Error()
  294. return err
  295. }
  296. mapErrMsg := make(map[string]string)
  297. for _, v := range list {
  298. data := new(GetShangHaiTokenResultApiComPany)
  299. err := json.Unmarshal([]byte(v.Result), &data)
  300. if err != nil {
  301. msg = "GetShangHaiTokenResultApiComPany Err:" + err.Error()
  302. return err
  303. }
  304. if len(data.Data.FailInfo) > 0 {
  305. for _, vCompany := range data.Data.FailInfo {
  306. mapErrMsg[vCompany.ErrVal] = vCompany.ErrMsg
  307. }
  308. }
  309. }
  310. //创建excel
  311. dir, err := os.Executable()
  312. exPath := filepath.Dir(dir)
  313. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + utils.GetRandDigit(5) + ".xlsx"
  314. xlsxFile := xlsx.NewFile()
  315. if err != nil {
  316. return
  317. }
  318. style := xlsx.NewStyle()
  319. alignment := xlsx.Alignment{
  320. Horizontal: "center",
  321. Vertical: "center",
  322. WrapText: true,
  323. }
  324. style.Alignment = alignment
  325. style.ApplyAlignment = true
  326. sheet, err := xlsxFile.AddSheet("上海策略品台同步名单")
  327. if err != nil {
  328. return
  329. }
  330. //设置宽度
  331. _ = sheet.SetColWidth(0, 1, 30)
  332. _ = sheet.SetColWidth(2, 2, 10)
  333. _ = sheet.SetColWidth(3, 3, 30)
  334. //标头
  335. rowTitle := sheet.AddRow()
  336. cellA := rowTitle.AddCell()
  337. cellA.Value = "客户名称"
  338. cellB := rowTitle.AddCell()
  339. cellB.Value = "社会信用码"
  340. cellC := rowTitle.AddCell()
  341. cellC.Value = "客户类型"
  342. cellD := rowTitle.AddCell()
  343. cellD.Value = "错误消息"
  344. for _, v := range list {
  345. data := new(models.CompanyUnJsonList)
  346. err := json.Unmarshal([]byte(v.Body), &data)
  347. if err != nil {
  348. msg = "CompanyUnJsonList Err:" + err.Error()
  349. return err
  350. }
  351. if len(data.SyncData) > 0 {
  352. for _, item := range data.SyncData {
  353. row := sheet.AddRow()
  354. cellA := row.AddCell()
  355. cellA.Value = item.CompanyName
  356. cellB := row.AddCell()
  357. cellB.Value = item.CreditCode
  358. cellC := row.AddCell()
  359. cellC.Value = item.Fe
  360. if mapErrMsg[item.CreditCode] != "" {
  361. cellD := row.AddCell()
  362. cellD.Value = mapErrMsg[item.CreditCode]
  363. }
  364. }
  365. }
  366. }
  367. title := time.Now().Format(utils.FormatDate) + "上海策略品台同步名单"
  368. content := time.Now().Format(utils.FormatDate) + "上海策略品台同步名单"
  369. fileName := downLoadnFilePath
  370. err = xlsxFile.Save(downLoadnFilePath)
  371. if err != nil {
  372. return
  373. }
  374. if len(list) > 0 {
  375. utils.SendEmailByHongze(title, content, "cxzhang@hzinsights.com;tshen@hzinsights.com", fileName, title+".xlsx")
  376. }
  377. os.Remove(downLoadnFilePath)
  378. go models.DeleteCygxShanghaiCompanyLog()
  379. return
  380. }