network.go 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991
  1. package service
  2. import (
  3. "context"
  4. "database/sql"
  5. "fmt"
  6. "math"
  7. "sort"
  8. "strings"
  9. "sync"
  10. "time"
  11. . "app.yhyue.com/moapp/jybase/common"
  12. . "app.yhyue.com/moapp/jybase/date"
  13. "app.yhyue.com/moapp/jybase/encrypt"
  14. . "app.yhyue.com/moapp/jybase/es"
  15. . "app.yhyue.com/moapp/jybase/sort"
  16. . "bp.jydev.jianyu360.cn/CRM/application/api/common"
  17. "bp.jydev.jianyu360.cn/CRM/application/api/internal/types"
  18. "github.com/shopspring/decimal"
  19. "github.com/zeromicro/go-zero/core/logx"
  20. )
  21. var Network = &network{}
  22. type network struct {
  23. }
  24. type networkTree struct {
  25. Count int64 `json:"count"`
  26. Name string `json:"name"`
  27. Children []*networkTreeChild `json:"children"`
  28. }
  29. type networkTreeChild struct {
  30. Count int64 `json:"count"`
  31. Id int64 `json:"id"`
  32. CompanyId string `json:"companyId"`
  33. CompanyName string `json:"companyName"`
  34. Type string `json:"type"`
  35. CreateTime string `json:"createTime"`
  36. }
  37. func (s *networkTree) Len() int {
  38. return len(s.Children)
  39. }
  40. func (s *networkTree) Less(i, j int) bool {
  41. if s.Name == "甲方" {
  42. return s.Children[i].CompanyName < s.Children[j].CompanyName
  43. }
  44. it, err1 := time.ParseInLocation(Date_Full_Layout, s.Children[i].CreateTime, time.Local)
  45. if err1 != nil {
  46. return true
  47. }
  48. jt, err2 := time.ParseInLocation(Date_Full_Layout, s.Children[j].CreateTime, time.Local)
  49. if err2 != nil {
  50. return true
  51. }
  52. return it.Unix() < jt.Unix()
  53. }
  54. func (s *networkTree) Swap(i, j int) {
  55. s.Children[i], s.Children[j] = s.Children[j], s.Children[i]
  56. }
  57. type projectInfo struct {
  58. BuyerCount int64
  59. ProjectCount int64
  60. ProjectAmount float64
  61. MonitorCount int64
  62. ExportId []string
  63. }
  64. type firstpartyNetwork struct {
  65. CompanyId string
  66. CompanyName string
  67. Name string
  68. }
  69. //人脉库-添加/修改人脉
  70. func (n *network) AddOrUpdate(in *types.AddOrUpdateReq) *types.Reply {
  71. reply := &types.Reply{Data: map[string]interface{}{
  72. "status": 0,
  73. }}
  74. if in.Type != "middleman" && in.Company_id == "" {
  75. return reply
  76. }
  77. if in.Company_name == "" {
  78. in.Company_name = "未填写"
  79. }
  80. nowFormat := NowFormat(Date_Full_Layout)
  81. var saveIntroduce = func(tx *sql.Tx, cid int64, isUpdate bool) bool {
  82. if in.Type != "middleman" {
  83. return true
  84. } else if in.Introduce_owner_id == "" || in.Introduce_project_id == "" {
  85. return false
  86. }
  87. values := []interface{}{}
  88. ioi := strings.Split(in.Introduce_owner_id, ",")
  89. ioqi := strings.Split(in.Introduce_owner_qyxy_id, ",")
  90. ion := strings.Split(in.Introduce_owner_name, ",")
  91. if len(ioi) != len(ion) || len(ioi) != len(ioqi) {
  92. return false
  93. }
  94. for k, v := range ioi {
  95. values = append(values, in.PositionId, in.EntId, in.EntDeptId, in.EntUserId, cid, ioqi[k], v, ion[k], 1, nowFormat)
  96. }
  97. ipi := strings.Split(in.Introduce_project_id, ",")
  98. ipn := strings.Split(in.Introduce_project_name, ",")
  99. if len(ipi) != len(ipn) {
  100. return false
  101. }
  102. for k, v := range ipi {
  103. values = append(values, in.PositionId, in.EntId, in.EntDeptId, in.EntUserId, cid, nil, v, ipn[k], 2, nowFormat)
  104. }
  105. var r2 int64
  106. if isUpdate {
  107. r2 = CrmMysql.UpdateOrDeleteBySqlByTx(tx, `delete from crm.connection_introduce where connection_id=? and position_id=?`, in.Id, in.PositionId)
  108. }
  109. r3, _ := CrmMysql.InsertBatchByTx(tx, "crm.connection_introduce", []string{"position_id", "ent_id", "ent_dept_id", "ent_user_id", "connection_id", "qyxy_id", "relate_id", "relate_name", "itype", "create_time"}, values)
  110. return r2 >= 0 && r3 > 0
  111. }
  112. itype := n.TypeStrConvert(in.Type)
  113. if in.Id > 0 {
  114. if CrmMysql.ExecTx("更新人脉", func(tx *sql.Tx) bool {
  115. if in.Company_id != "" {
  116. count := CrmMysql.CountBySql(`select count(1) as count from crm.connection where position_id=? and company_id=? and itype=? and id<>? and status=1`, in.PositionId, in.Company_id, itype, in.Id)
  117. if count == -1 {
  118. return false
  119. } else if count > 0 {
  120. reply.Data = map[string]interface{}{
  121. "status": -1,
  122. }
  123. return false
  124. }
  125. }
  126. r1 := CrmMysql.UpdateOrDeleteBySqlByTx(tx, `update crm.connection set company_name=?,company_id=?,contact_person=?,contact_phone=?,update_time=? where id=? and position_id=?`, in.Company_name, in.Company_id, in.Contact_person, in.Contact_phone, nowFormat, in.Id, in.PositionId)
  127. return r1 >= 0 && saveIntroduce(tx, in.Id, true)
  128. }) {
  129. reply.Data = map[string]interface{}{
  130. "status": 1,
  131. }
  132. }
  133. } else {
  134. if in.Company_id != "" {
  135. count := CrmMysql.CountBySql(`select count(1) as count from crm.connection where position_id=? and company_id=? and itype=? and status=1`, in.PositionId, in.Company_id, itype)
  136. if count == -1 {
  137. return reply
  138. } else if count > 0 {
  139. reply.Data = map[string]interface{}{
  140. "status": -1,
  141. }
  142. return reply
  143. }
  144. }
  145. var r1 int64
  146. if CrmMysql.ExecTx("新增人脉", func(tx *sql.Tx) bool {
  147. _, r1 = CrmMysql.InsertBatchByTx(tx, "crm.connection", []string{"position_id", "ent_id", "ent_dept_id", "ent_user_id", "itype", "company_name", "company_id", "qyxy_id", "contact_person", "contact_phone", "status", "create_time", "update_time"}, []interface{}{in.PositionId, in.EntId, in.EntDeptId, in.EntUserId, itype, in.Company_name, in.Company_id, in.Qyxy_id, in.Contact_person, in.Contact_phone, 1, nowFormat, nowFormat})
  148. return r1 > 0 && saveIntroduce(tx, r1, false)
  149. }) {
  150. reply.Data = map[string]interface{}{
  151. "status": 1,
  152. "id": r1,
  153. }
  154. }
  155. }
  156. return reply
  157. }
  158. //人脉库-业主名称联想
  159. func (n *network) Associate(in *types.AssociateReq) (reply *types.Reply) {
  160. //类型;firstparty:甲方 supplier:供应商 adiffb:同甲异业 middleman:中间人 middleman_owner:中间人-业主 middleman_project:中间人-项目 agency:招标代理机构
  161. res := []map[string]string{}
  162. reply = &types.Reply{Data: res}
  163. in.Name = strings.TrimSpace(in.Name)
  164. if in.Name == "" {
  165. return
  166. }
  167. pageSize := 10
  168. if in.Type == "adiffb" {
  169. probusfors := NetworkCom.GetMyProbusfor(in.EntAccountId)
  170. if len(probusfors) > 0 {
  171. args := []interface{}{in.EntName}
  172. wh, newArgs := NetworkCom.WhArgs(probusfors)
  173. args = append(args, newArgs...)
  174. q := `select DISTINCT winner_id,winner from information.transaction_info where buyer_id in (select buyer_id from information.transaction_info where has(winner, ?) and buyer_id<>'') and hasAny(property_form,[` + wh + `])=0 ORDER BY project_id`
  175. rows, err := ClickhouseConn.Query(context.Background(), q, args...)
  176. if err != nil {
  177. logx.Error(err)
  178. } else {
  179. repeat := map[string]bool{}
  180. ids := []string{}
  181. for rows.Next() {
  182. var (
  183. winner_id []string
  184. winner []string
  185. )
  186. if err := rows.Scan(&winner_id, &winner); err != nil {
  187. logx.Error(err)
  188. continue
  189. }
  190. for k, v := range winner {
  191. if repeat[v] || !strings.Contains(v, in.Name) {
  192. continue
  193. }
  194. repeat[v] = true
  195. if k >= len(winner_id) {
  196. continue
  197. }
  198. ids = append(ids, winner_id[k])
  199. res = append(res, map[string]string{
  200. "company_name": v,
  201. "company_id": winner_id[k],
  202. })
  203. if len(res) == pageSize {
  204. break
  205. }
  206. }
  207. }
  208. rows.Close()
  209. if err := rows.Err(); err != nil {
  210. logx.Error(err)
  211. }
  212. qyxyId := n.GetQyxyId(ids)
  213. for _, v := range res {
  214. v["qyxy_id"] = qyxyId[v["company_id"]]
  215. }
  216. }
  217. }
  218. } else {
  219. must := []string{fmt.Sprintf(`{"multi_match":{"query":"%s","type":"phrase","fields":["company_name"]}}`, in.Name)}
  220. switch in.Type {
  221. case "firstparty":
  222. must = append(must, fmt.Sprintf(`{"terms":{"company_label":["%s"]}}`, strings.Join(NetworkCom.GetEntTagSeat(2), `","`)))
  223. must = append(must, `{"terms":{"company_unit_type":[1,2]}}`)
  224. case "supplier":
  225. must = append(must, fmt.Sprintf(`{"terms":{"company_label":["%s"]}}`, strings.Join(NetworkCom.GetEntTagSeat(2), `","`)))
  226. must = append(must, `{"term":{"company_unit_type":3}}`)
  227. case "middleman_owner":
  228. must = append(must, `{"terms":{"company_unit_type":[1,2]}}`)
  229. case "agency":
  230. must = append(must, `{"term":{"company_unit_type":4}}`)
  231. }
  232. q := fmt.Sprintf(`{"query":{"bool":{"must":[%s]}},"size":%d,"_source":["id","company_id","company_name"]}`, strings.Join(must, ","), pageSize)
  233. logx.Info("人脉库-业主名称联想", q)
  234. datas := VarEs.Get("ent_info", "ent_info", q)
  235. if datas != nil {
  236. for _, v := range *datas {
  237. res = append(res, map[string]string{
  238. "company_name": ObjToString(v["company_name"]),
  239. "company_id": ObjToString(v["id"]),
  240. "qyxy_id": ObjToString(v["company_id"]),
  241. })
  242. }
  243. }
  244. }
  245. reply.Data = res
  246. return
  247. }
  248. //人脉库-全部人脉项目
  249. func (n *network) AllProject(in *types.AllprojectReq) (reply *types.Reply) {
  250. pool := make(chan bool, 5)
  251. wait := &sync.WaitGroup{}
  252. lock := &sync.Mutex{}
  253. reply = &types.Reply{}
  254. wh, newArgs := NetworkCom.WhArgs(NetworkCom.GetMyProbusfor(in.EntAccountId))
  255. var count int64
  256. var list []*networkTree
  257. if in.Id != "" {
  258. if in.Type == "firstparty" {
  259. result := n.FirstpartyNetwork(in.Name, []string{in.Id})
  260. if result[in.Id] != nil {
  261. nameIndex := map[string]int{}
  262. for _, v := range result[in.Id] {
  263. if _, ok := nameIndex[v.Name]; !ok {
  264. nameIndex[v.Name] = len(list)
  265. list = append(list, &networkTree{
  266. Name: v.Name,
  267. })
  268. }
  269. pool <- true
  270. wait.Add(1)
  271. go func(cIndex int, cId, cName string) {
  272. defer func() {
  273. <-pool
  274. wait.Done()
  275. }()
  276. ntc := &networkTreeChild{
  277. CompanyName: cName,
  278. CompanyId: cId,
  279. Type: "firstparty",
  280. }
  281. if wh != "" {
  282. thisArgs := []interface{}{ntc.CompanyId}
  283. thisArgs = append(thisArgs, newArgs...)
  284. ntc.Count = NetworkCom.Count(`select count(1) from information.transaction_info where buyer_id=? and hasAny(property_form,[`+wh+`])`, thisArgs...)
  285. }
  286. lock.Lock()
  287. count++
  288. list[cIndex].Count += ntc.Count
  289. list[cIndex].Children = append(list[cIndex].Children, ntc)
  290. lock.Unlock()
  291. }(nameIndex[v.Name], v.CompanyId, v.CompanyName)
  292. }
  293. wait.Wait()
  294. }
  295. }
  296. } else {
  297. q := `SELECT a.id,a.company_id,a.company_name,a.itype,a.create_time,COUNT(b.id) AS ipc FROM crm.connection a
  298. LEFT JOIN crm.connection_introduce b ON (b.position_id=? AND b.itype=2 AND a.id=b.connection_id) WHERE a.position_id=?`
  299. args := []interface{}{in.PositionId, in.PositionId}
  300. if in.Name != "" {
  301. q += ` and company_name like ?`
  302. args = append(args, "%"+in.Name+"%")
  303. }
  304. q += ` GROUP BY a.id ORDER BY a.create_time DESC`
  305. datas := CrmMysql.SelectBySql(q, args...)
  306. list = []*networkTree{
  307. &networkTree{
  308. Name: "甲方",
  309. Children: []*networkTreeChild{},
  310. },
  311. &networkTree{
  312. Name: "供应商",
  313. Children: []*networkTreeChild{},
  314. },
  315. &networkTree{
  316. Name: "同甲异业渠道",
  317. Children: []*networkTreeChild{},
  318. },
  319. &networkTree{
  320. Name: "中间人",
  321. Children: []*networkTreeChild{},
  322. },
  323. &networkTree{
  324. Name: "招标代理",
  325. Children: []*networkTreeChild{},
  326. },
  327. }
  328. //
  329. for _, vt := range *datas {
  330. pool <- true
  331. wait.Add(1)
  332. go func(v map[string]interface{}) {
  333. defer func() {
  334. <-pool
  335. wait.Done()
  336. }()
  337. itype := IntAll(v["itype"])
  338. if itype <= 0 || itype > len(list) {
  339. return
  340. }
  341. company_name := ObjToString(v["company_name"])
  342. ntc := &networkTreeChild{
  343. Id: Int64All(v["id"]),
  344. CompanyName: company_name,
  345. CompanyId: ObjToString(v["company_id"]),
  346. Type: n.TypeIntConvert(Int64All(v["itype"])),
  347. CreateTime: ObjToString(v["create_time"]),
  348. }
  349. if wh != "" {
  350. thisArgs := []interface{}{ntc.CompanyId}
  351. thisArgs = append(thisArgs, newArgs...)
  352. if itype == 1 {
  353. ntc.Count = NetworkCom.Count(`select count(1) from information.transaction_info where buyer_id=? and hasAny(property_form,[`+wh+`])`, thisArgs...)
  354. } else if itype == 2 || itype == 3 {
  355. ntc.Count = NetworkCom.Count(`select count(1) from information.transaction_info where has(winner_id,?) and hasAny(property_form,[`+wh+`])`, thisArgs...)
  356. } else if itype == 4 {
  357. ntc.Count = Int64All(v["ipc"])
  358. } else if itype == 5 {
  359. ntc.Count = NetworkCom.Count(`select count(1) from information.transaction_info where agency_id=? and hasAny(property_form,[`+wh+`])`, thisArgs...)
  360. }
  361. }
  362. lock.Lock()
  363. count += ntc.Count
  364. list[itype-1].Count += ntc.Count
  365. list[itype-1].Children = append(list[itype-1].Children, ntc)
  366. lock.Unlock()
  367. }(vt)
  368. }
  369. wait.Wait()
  370. }
  371. convList := []map[string]interface{}{}
  372. for _, v := range list {
  373. pm := map[string]interface{}{
  374. "CODE": v.Name,
  375. "NAME": v.Name,
  376. "SZ_PID0": v.Name,
  377. "SZ_LEVEL": 0,
  378. "DATACOUNT": 0,
  379. }
  380. if len(v.Children) > 0 {
  381. pm["SZ_LEAF"] = 0
  382. } else {
  383. pm["SZ_LEAF"] = 1
  384. }
  385. ID := ""
  386. pType := ""
  387. sort.Sort(v)
  388. for _, vv := range v.Children {
  389. if ID != "" {
  390. ID += ","
  391. }
  392. if pType != "" {
  393. pType += ","
  394. }
  395. tempId := vv.CompanyId
  396. if vv.Type == "middleman" {
  397. tempId = fmt.Sprint(vv.Id)
  398. }
  399. ID += tempId
  400. pType += vv.Type
  401. cm := map[string]interface{}{
  402. "NAME": vv.CompanyName,
  403. "ID": tempId,
  404. "SZ_PID0": v.Name,
  405. "SZ_PID1": v.Name + ":" + tempId,
  406. "CODE": v.Name + ":" + tempId,
  407. "PCODE": v.Name,
  408. "DATACOUNT": vv.Count,
  409. "SZ_LEVEL": 1,
  410. "SZ_LEAF": 1,
  411. "TYPE": vv.Type,
  412. }
  413. convList = append(convList, cm)
  414. }
  415. pm["ID"] = ID
  416. pm["TYPE"] = pType
  417. convList = append(convList, pm)
  418. }
  419. reply = &types.Reply{
  420. Data: map[string]interface{}{
  421. "count": count,
  422. "list": convList,
  423. },
  424. }
  425. return reply
  426. }
  427. //人脉库-列表
  428. func (n *network) List(in *types.NetWorkListReq) *types.Reply {
  429. if in.Page_size <= 0 {
  430. in.Page_size = 10
  431. }
  432. q := `select a.id,a.company_id,a.company_name,a.qyxy_id,a.itype,a.contact_person as person,a.contact_phone as phone,count(DISTINCT if(b.itype=1,b.relate_id,null)) as buyer_count,count(DISTINCT if(b.itype=2,b.relate_id,null)) as project_count,GROUP_CONCAT(IF(b.itype=1,b.relate_id,NULL)) AS relate_buyer_id,GROUP_CONCAT(IF(b.itype=2,b.relate_id,NULL)) AS relate_project_id,a.create_time from crm.connection a
  433. left join crm.connection_introduce b on (a.id=b.connection_id) where a.position_id=?`
  434. args := []interface{}{in.PositionId}
  435. if in.Type != "" {
  436. q += ` and a.itype=?`
  437. args = append(args, n.TypeStrConvert(in.Type))
  438. }
  439. if in.Starttime != "" {
  440. q += ` and a.create_time>=?`
  441. args = append(args, in.Starttime+" 00:00:00")
  442. }
  443. if in.Endtime != "" {
  444. q += ` and a.create_time<=?`
  445. if in.Starttime == in.Endtime {
  446. in.Endtime += " 23:59:59"
  447. } else {
  448. in.Endtime += " 00:00:00"
  449. }
  450. args = append(args, in.Endtime)
  451. }
  452. if in.Name != "" {
  453. q += ` and a.company_name like ?`
  454. args = append(args, "%"+in.Name+"%")
  455. }
  456. q += ` GROUP BY a.id order by a.create_time desc`
  457. // if in.Buyercount_start == 0 && in.Buyercount_end == 0 && in.Monitor == 0 && in.Monitorcount_start == 0 && in.Monitorcount_end == 0 && in.Project_matchme == 0 {
  458. // q += ` limit ?`
  459. // args = append(args, in.Page_size)
  460. // }
  461. listTemp := CrmMysql.SelectBySql(q, args...)
  462. firstparty_array, supplier_array, adiffb_array, agency_array, middleman_project_array := []string{}, []string{}, []string{}, []string{}, []string{}
  463. for _, v := range *listTemp {
  464. switch Int64All(v["itype"]) {
  465. case 1:
  466. firstparty_array = append(firstparty_array, ObjToString(v["company_id"]))
  467. case 2:
  468. supplier_array = append(supplier_array, ObjToString(v["company_id"]))
  469. case 3:
  470. adiffb_array = append(adiffb_array, ObjToString(v["company_id"]))
  471. case 4:
  472. if relate_project_id := ObjToString(v["relate_project_id"]); relate_project_id != "" {
  473. middleman_project_array = append(middleman_project_array, strings.Split(relate_project_id, ",")...)
  474. }
  475. case 5:
  476. agency_array = append(agency_array, ObjToString(v["company_id"]))
  477. }
  478. }
  479. //
  480. firstparty_count, supplier_count, adiffb_count, middleman_count, agency_count := 0, 0, 0, 0, 0
  481. list := []*map[string]interface{}{}
  482. isGoNextSetp := true
  483. probusfors := []string{}
  484. if in.Project_matchme == 1 {
  485. probusfors = NetworkCom.GetMyProbusfor(in.EntAccountId)
  486. if len(probusfors) == 0 {
  487. isGoNextSetp = false
  488. }
  489. }
  490. if isGoNextSetp {
  491. entMonitor := NetworkCom.EntMonitor(in.UserId)
  492. fpn := n.FirstpartyNetwork("", firstparty_array)
  493. firstparty_project := n.Introduce_Firstparty(fpn, entMonitor, in.Project_matchme, probusfors)
  494. supplier_project := n.Introduce_Supplier(supplier_array, entMonitor, in.Project_matchme, probusfors)
  495. adiffb_project := n.Introduce_Supplier(adiffb_array, entMonitor, in.Project_matchme, probusfors)
  496. agency_project := n.Introduce_Agency(agency_array, entMonitor, in.Project_matchme, probusfors)
  497. middleman_project := n.Introduce_Middleman(middleman_project_array, entMonitor, in.Project_matchme, probusfors)
  498. for _, v := range *listTemp {
  499. itype := ""
  500. buyer_count, project_count, expect_amount, monitor_count := int64(0), int64(0), float64(0), int64(0)
  501. company_id := ObjToString(v["company_id"])
  502. export_id := []string{}
  503. jump_type, jump_id := "", ""
  504. switch Int64All(v["itype"]) {
  505. case 1:
  506. itype = "甲方"
  507. jump_type = "firstparty"
  508. for _, vv := range fpn[company_id] {
  509. if jump_id != "" {
  510. jump_id += ","
  511. }
  512. jump_id += vv.CompanyId
  513. }
  514. firstparty_count++
  515. if firstparty_project[company_id] != nil {
  516. buyer_count = firstparty_project[company_id].BuyerCount
  517. project_count = firstparty_project[company_id].ProjectCount
  518. expect_amount = firstparty_project[company_id].ProjectAmount
  519. monitor_count = firstparty_project[company_id].MonitorCount
  520. export_id = firstparty_project[company_id].ExportId
  521. }
  522. case 2:
  523. itype = "供应商"
  524. jump_type = "supplier"
  525. jump_id = company_id
  526. supplier_count++
  527. if supplier_project[company_id] != nil {
  528. buyer_count = supplier_project[company_id].BuyerCount
  529. project_count = supplier_project[company_id].ProjectCount
  530. expect_amount = supplier_project[company_id].ProjectAmount
  531. monitor_count = supplier_project[company_id].MonitorCount
  532. export_id = supplier_project[company_id].ExportId
  533. }
  534. case 3:
  535. itype = "同甲异业渠道"
  536. jump_type = "adiffb"
  537. jump_id = company_id
  538. adiffb_count++
  539. if adiffb_project[company_id] != nil {
  540. buyer_count = adiffb_project[company_id].BuyerCount
  541. project_count = adiffb_project[company_id].ProjectCount
  542. expect_amount = adiffb_project[company_id].ProjectAmount
  543. monitor_count = adiffb_project[company_id].MonitorCount
  544. export_id = adiffb_project[company_id].ExportId
  545. }
  546. case 4:
  547. itype = "中间人"
  548. jump_type = "middleman"
  549. jump_id = fmt.Sprint(Int64All(v["id"]))
  550. middleman_count++
  551. buyer_count = Int64All(v["buyer_count"])
  552. project_count = Int64All(v["project_count"])
  553. if relate_buyer_id := ObjToString(v["relate_buyer_id"]); relate_buyer_id != "" {
  554. for _, v := range strings.Split(relate_buyer_id, ",") {
  555. if v == "" {
  556. continue
  557. }
  558. if entMonitor[v] {
  559. monitor_count++
  560. }
  561. }
  562. }
  563. if relate_project_id := ObjToString(v["relate_project_id"]); relate_project_id != "" {
  564. export_id = strings.Split(relate_project_id, ",")
  565. for _, v := range export_id {
  566. if middleman_project[v] != nil {
  567. expect_amount += middleman_project[v].ProjectAmount
  568. }
  569. }
  570. }
  571. case 5:
  572. itype = "招标代理机构"
  573. jump_type = "agency"
  574. jump_id = company_id
  575. agency_count++
  576. if agency_project[company_id] != nil {
  577. buyer_count = agency_project[company_id].BuyerCount
  578. project_count = agency_project[company_id].ProjectCount
  579. expect_amount = agency_project[company_id].ProjectAmount
  580. monitor_count = agency_project[company_id].MonitorCount
  581. export_id = agency_project[company_id].ExportId
  582. }
  583. }
  584. if buyer_count < in.Buyercount_start {
  585. continue
  586. } else if in.Buyercount_end > 0 && buyer_count > in.Buyercount_end {
  587. continue
  588. } else if in.Monitor == 1 && monitor_count <= 0 {
  589. continue
  590. } else if in.Monitor == -1 && monitor_count > 0 {
  591. continue
  592. } else if monitor_count < in.Monitorcount_start {
  593. continue
  594. } else if in.Monitorcount_end > 0 && monitor_count > in.Monitorcount_end {
  595. continue
  596. } else if in.Project_matchme == 1 && project_count == 0 {
  597. continue
  598. }
  599. export_url := ""
  600. if len(export_id) > 0 {
  601. export_url = "/subscribepay/network/projectExport?export_id=" + encrypt.SE.EncodeStringByCheck(strings.Join(export_id, ","))
  602. }
  603. url := ""
  604. company_name, _ := v["company_name"].(string)
  605. if qyxy_id := ObjToString(v["qyxy_id"]); qyxy_id != "" && (jump_type == "supplier" || jump_type == "adiffb") {
  606. url = "/swordfish/page_big_pc/ent_portrait/" + encrypt.EncodeArticleId2ByCheck(qyxy_id)
  607. } else if jump_type == "firstparty" && company_name != "" {
  608. url = "/swordfish/page_big_pc/unit_portrayal/" + company_name
  609. }
  610. list = append(list, &map[string]interface{}{
  611. "company_id": company_id,
  612. "company_name": company_name,
  613. "type": itype,
  614. "jump_type": jump_type,
  615. "jump_id": jump_id,
  616. "person": v["person"],
  617. "phone": v["phone"],
  618. "buyer_count": buyer_count,
  619. "monitor_count": 0,
  620. "expect_amount": RetainDecimal(expect_amount/10000, 2),
  621. "project_count": project_count,
  622. "create_time": v["create_time"],
  623. "export_url": export_url,
  624. "url": url,
  625. })
  626. }
  627. }
  628. csList := &ComSortList{
  629. SortKeys: []*ComSortKey{
  630. &ComSortKey{
  631. Keys: []string{"expect_amount"},
  632. Order: 1,
  633. Type: "float",
  634. },
  635. },
  636. List: list,
  637. }
  638. if in.Order_amount == -1 {
  639. csList.SortKeys[0].Order = -1
  640. }
  641. if in.Order_amount != 0 {
  642. sort.Sort(csList)
  643. }
  644. length := int64(len(csList.List))
  645. total_page := int64(math.Ceil(float64(length) / float64(in.Page_size)))
  646. finalList := []*map[string]interface{}{}
  647. if length > 0 {
  648. if in.Current_page <= 0 {
  649. in.Current_page = 1
  650. }
  651. if in.Current_page > total_page {
  652. in.Current_page = total_page
  653. }
  654. start := (in.Current_page - 1) * in.Page_size
  655. end := start + in.Page_size
  656. if end > length {
  657. end = length
  658. }
  659. finalList = csList.List[start:end]
  660. }
  661. return &types.Reply{
  662. Data: map[string]interface{}{
  663. "count": length,
  664. "total_page": total_page,
  665. "firstparty_count": firstparty_count,
  666. "supplier_count": supplier_count,
  667. "adiffb_count": adiffb_count,
  668. "middleman_count": middleman_count,
  669. "agency_count": agency_count,
  670. "list": finalList,
  671. },
  672. }
  673. }
  674. //
  675. func (n *network) FirstpartyNetwork(name string, values []string) map[string][]*firstpartyNetwork {
  676. result := map[string][]*firstpartyNetwork{}
  677. wh, args := NetworkCom.WhArgs(values)
  678. q := `select DISTINCT a.a_id,a.b_id as company_id,a.b_name as company_name,b.name from information.ent_map_code a
  679. inner join information.ent_code b on (a.a_id in (` + wh + `) and b.pcode in ('0100','0200') and a.code=b.code)`
  680. if name != "" {
  681. q += ` where c.company_name like ?`
  682. args = append(args, "%"+name+"%")
  683. }
  684. q += ` order by b.name,a.a_id,a.b_name`
  685. rows, err := ClickhouseConn.Query(context.Background(), q, args...)
  686. if err != nil {
  687. logx.Error(err)
  688. return result
  689. }
  690. for rows.Next() {
  691. var (
  692. a_id string
  693. company_id string
  694. company_name string
  695. name string
  696. )
  697. if err := rows.Scan(&a_id, &company_id, &company_name, &name); err != nil {
  698. logx.Error(err)
  699. continue
  700. }
  701. result[a_id] = append(result[a_id], &firstpartyNetwork{
  702. CompanyId: company_id,
  703. CompanyName: company_name,
  704. Name: name,
  705. })
  706. }
  707. return result
  708. }
  709. //
  710. func (n *network) Introduce_Firstparty(fpn map[string][]*firstpartyNetwork, entMonitor map[string]bool, matchme int64, probusfors []string) map[string]*projectInfo {
  711. values := []string{}
  712. vm := map[string]*projectInfo{}
  713. for _, v := range fpn {
  714. for _, vv := range v {
  715. vm[vv.CompanyId] = &projectInfo{}
  716. values = append(values, vv.CompanyId)
  717. }
  718. }
  719. wh, args := NetworkCom.WhArgs(values)
  720. q := `select buyer_id,count(project_id) AS project_count,sum(project_money) AS project_amount,groupUniqArray(project_id) from information.transaction_info where buyer_id in (` + wh + `)`
  721. if matchme == 1 {
  722. newWh, newArgs := NetworkCom.WhArgs(probusfors)
  723. q += ` and hasAny(property_form,[` + newWh + `])`
  724. args = append(args, newArgs...)
  725. }
  726. q += ` group by buyer_id`
  727. rows, err := ClickhouseConn.Query(context.Background(), q, args...)
  728. if err != nil {
  729. logx.Error(err)
  730. return nil
  731. }
  732. for rows.Next() {
  733. var (
  734. buyer_id string
  735. project_count uint64
  736. project_amount decimal.Decimal
  737. project_id []string
  738. )
  739. if err := rows.Scan(&buyer_id, &project_count, &project_amount, &project_id); err != nil {
  740. logx.Error(err)
  741. continue
  742. }
  743. if vm[buyer_id] == nil {
  744. continue
  745. }
  746. vm[buyer_id].ProjectCount += int64(project_count)
  747. pf, _ := project_amount.Float64()
  748. vm[buyer_id].ProjectAmount += pf
  749. vm[buyer_id].ExportId = project_id
  750. }
  751. rows.Close()
  752. if err := rows.Err(); err != nil {
  753. logx.Error(err)
  754. }
  755. result := map[string]*projectInfo{}
  756. for k, v := range fpn {
  757. if result[k] == nil {
  758. result[k] = &projectInfo{}
  759. }
  760. result[k].BuyerCount = int64(len(v))
  761. for _, vv := range v {
  762. if entMonitor[vv.CompanyName] {
  763. result[k].MonitorCount++
  764. }
  765. if vm[vv.CompanyId] == nil {
  766. continue
  767. }
  768. result[k].ProjectCount += vm[vv.CompanyId].ProjectCount
  769. result[k].ProjectAmount += vm[vv.CompanyId].ProjectAmount
  770. }
  771. }
  772. return result
  773. }
  774. //
  775. func (n *network) Introduce_Supplier(values []string, entMonitor map[string]bool, matchme int64, probusfors []string) map[string]*projectInfo {
  776. vm := map[string]*projectInfo{}
  777. for _, v := range values {
  778. vm[v] = &projectInfo{}
  779. }
  780. wh, args := NetworkCom.WhArgs(values)
  781. q := `select a.winner_id,count(DISTINCT b.buyer_id) AS buyer_count,count(DISTINCT b.project_id) AS project_count,sum(b.project_money) AS project_amount,groupUniqArray(b.buyer),groupUniqArray(b.project_id) from information.transaction_info a
  782. inner join information.transaction_info b on (hasAny(a.winner_id,[` + wh + `]) and a.buyer_id<>'' and a.buyer_id=b.buyer_id`
  783. if matchme == 1 {
  784. newWh, newArgs := NetworkCom.WhArgs(probusfors)
  785. q += ` and hasAny(b.property_form,[` + newWh + `])`
  786. args = append(args, newArgs...)
  787. }
  788. q += `) group by a.winner_id`
  789. rows, err := ClickhouseConn.Query(context.Background(), q, args...)
  790. if err != nil {
  791. logx.Error(err)
  792. return nil
  793. }
  794. for rows.Next() {
  795. var (
  796. winner_id []string
  797. buyer_count uint64
  798. project_count uint64
  799. project_amount decimal.Decimal
  800. buyers []string
  801. project_id []string
  802. )
  803. if err := rows.Scan(&winner_id, &buyer_count, &project_count, &project_amount, &buyers, &project_id); err != nil {
  804. logx.Error(err)
  805. continue
  806. }
  807. for _, v := range winner_id {
  808. if vm[v] == nil {
  809. continue
  810. }
  811. vm[v].BuyerCount += int64(buyer_count)
  812. vm[v].ProjectCount += int64(project_count)
  813. pf, _ := project_amount.Float64()
  814. vm[v].ProjectAmount += pf
  815. vm[v].ExportId = project_id
  816. for _, v := range buyers {
  817. if entMonitor[v] {
  818. vm[v].MonitorCount++
  819. }
  820. }
  821. }
  822. }
  823. rows.Close()
  824. if err := rows.Err(); err != nil {
  825. logx.Error(err)
  826. }
  827. return vm
  828. }
  829. //
  830. func (n *network) Introduce_Agency(values []string, entMonitor map[string]bool, matchme int64, probusfors []string) map[string]*projectInfo {
  831. vm := map[string]*projectInfo{}
  832. for _, v := range values {
  833. vm[v] = &projectInfo{}
  834. }
  835. wh, args := NetworkCom.WhArgs(values)
  836. q := `select a.agency_id,count(DISTINCT b.buyer_id) AS buyer_count,count(DISTINCT b.project_id) AS project_count,sum(b.project_money) AS project_amount,groupUniqArray(b.buyer),groupUniqArray(b.project_id) from information.transaction_info a
  837. inner join information.transaction_info b on (a.agency_id in (` + wh + `) and a.buyer_id<>'' and a.buyer_id=b.buyer_id`
  838. if matchme == 1 {
  839. newWh, newArgs := NetworkCom.WhArgs(probusfors)
  840. q += ` and hasAny(b.property_form,[` + newWh + `])`
  841. args = append(args, newArgs...)
  842. }
  843. q += `) group by a.agency_id`
  844. rows, err := ClickhouseConn.Query(context.Background(), q, args...)
  845. if err != nil {
  846. logx.Error(err)
  847. return nil
  848. }
  849. for rows.Next() {
  850. var (
  851. agency_id string
  852. buyer_count uint64
  853. project_count uint64
  854. project_amount decimal.Decimal
  855. buyers []string
  856. project_id []string
  857. )
  858. if err := rows.Scan(&agency_id, &buyer_count, &project_count, &project_amount, &buyers, &project_id); err != nil {
  859. logx.Error(err)
  860. continue
  861. }
  862. if vm[agency_id] == nil {
  863. continue
  864. }
  865. vm[agency_id].BuyerCount += int64(buyer_count)
  866. vm[agency_id].ProjectCount += int64(project_count)
  867. pf, _ := project_amount.Float64()
  868. vm[agency_id].ProjectAmount += pf
  869. vm[agency_id].ExportId = project_id
  870. for _, v := range buyers {
  871. if entMonitor[v] {
  872. vm[agency_id].MonitorCount++
  873. }
  874. }
  875. }
  876. rows.Close()
  877. if err := rows.Err(); err != nil {
  878. logx.Error(err)
  879. }
  880. return vm
  881. }
  882. //
  883. func (n *network) Introduce_Middleman(values []string, entMonitor map[string]bool, matchme int64, probusfors []string) map[string]*projectInfo {
  884. vm := map[string]*projectInfo{}
  885. wh, newArgs := NetworkCom.WhArgs(values)
  886. rows, err := ClickhouseConn.Query(context.Background(), `select project_id,project_money from information.transaction_info where project_id in (`+wh+`)`, newArgs...)
  887. if err != nil {
  888. logx.Error(err)
  889. return nil
  890. }
  891. for rows.Next() {
  892. var (
  893. project_id string
  894. project_money decimal.Decimal
  895. )
  896. if err := rows.Scan(&project_id, &project_money); err != nil {
  897. logx.Error(err)
  898. continue
  899. }
  900. pf, _ := project_money.Float64()
  901. vm[project_id] = &projectInfo{
  902. ProjectAmount: pf,
  903. }
  904. }
  905. rows.Close()
  906. if err := rows.Err(); err != nil {
  907. logx.Error(err)
  908. }
  909. return vm
  910. }
  911. //
  912. func (n *network) TypeStrConvert(itype string) int {
  913. //firstparty:甲方 supplier:供应商 adiffb:同甲异业 middleman:中间人 agency:招标代理机构
  914. switch itype {
  915. case "firstparty":
  916. return 1
  917. case "supplier":
  918. return 2
  919. case "adiffb":
  920. return 3
  921. case "middleman":
  922. return 4
  923. case "agency":
  924. return 5
  925. }
  926. return 0
  927. }
  928. //
  929. func (n *network) TypeIntConvert(itype int64) string {
  930. //firstparty:甲方 supplier:供应商 adiffb:同甲异业 middleman:中间人 agency:招标代理机构
  931. switch itype {
  932. case 1:
  933. return "firstparty"
  934. case 2:
  935. return "supplier"
  936. case 3:
  937. return "adiffb"
  938. case 4:
  939. return "middleman"
  940. case 5:
  941. return "agency"
  942. }
  943. return ""
  944. }
  945. //
  946. func (n *network) GetQyxyId(ids []string) map[string]string {
  947. wh, args := NetworkCom.WhArgs(ids)
  948. q := `select id,company_id from information.ent_info where id in (` + wh + `)`
  949. rows, err := ClickhouseConn.Query(context.Background(), q, args...)
  950. m := map[string]string{}
  951. if err != nil {
  952. logx.Error(err)
  953. } else {
  954. for rows.Next() {
  955. var (
  956. id string
  957. company_id string
  958. )
  959. if err := rows.Scan(&id, &company_id); err != nil {
  960. logx.Error(err)
  961. continue
  962. }
  963. m[id] = company_id
  964. }
  965. rows.Close()
  966. if err := rows.Err(); err != nil {
  967. logx.Error(err)
  968. }
  969. }
  970. return m
  971. }