Selaa lähdekoodia

配置项修改

WH01243 1 kuukausi sitten
vanhempi
commit
98a1534a84
3 muutettua tiedostoa jossa 88 lisäystä ja 72 poistoa
  1. 3 7
      entity/entity.go
  2. 56 51
      rpc/etc/biservice.yaml
  3. 29 14
      service/acceptance.go

+ 3 - 7
entity/entity.go

@@ -81,13 +81,9 @@ type ProductMap struct {
 	PersonArr   []Person
 }
 type Person struct {
-	Name       string
-	Phone      string
-	Mail       string `header:"mail,optional"`
-	DeptId     int64  `header:"deptId,optional"`
-	DeptName   string `header:"deptName,optional"`
-	PositionId int64  `header:"positionId,optional"`
-	IsResign   bool   `header:"isResign,optional"`
+	Name     string
+	Phone    string
+	IsResign bool
 }
 type SelectProductMap struct {
 	Product   []string

+ 56 - 51
rpc/etc/biservice.yaml

@@ -1,5 +1,5 @@
 Name: biservice.rpc
-ListenOn: 0.0.0.0:9996
+ListenOn: 0.0.0.0:9986
 Etcd:
   Hosts:
     - 127.0.0.1:2379
@@ -7,18 +7,25 @@ Etcd:
 Timeout: 300000
 Mode: test
 Mysql:
+  WorkOrder:
+    DBName: work_order
+    Address: 127.0.0.1:33063
+    UserName: datagroup
+    PassWord: "Dgrpdb#2024@36"
+    MaxOpenConns: 5
+    MaxIdleConns: 5
   JianYu:
     DBName: jianyu
-    Address: 172.20.45.129:4000
-    UserName: root
-    PassWord: =PDT49#80Z!RVv52_z
+    Address: 127.0.0.1:33063
+    UserName: datagroup
+    PassWord: "Dgrpdb#2024@36"
     MaxOpenConns: 5
     MaxIdleConns: 5
   JyDoc:
     DBName: jydocs
-    Address: 172.20.45.129:4000
-    UserName: root
-    PassWord: =PDT49#80Z!RVv52_z
+    Address: 127.0.0.1:33063
+    UserName: datagroup
+    PassWord: "Dgrpdb#2024@36"
     MaxOpenConns: 5
     MaxIdleConns: 5
   Bi:
@@ -26,13 +33,13 @@ Mysql:
     Address: 127.0.0.1:33063
     UserName: datagroup
     PassWord: "Dgrpdb#2024@36"
-    MaxOpenConns: 30
-    MaxIdleConns: 30
+    MaxOpenConns: 5
+    MaxIdleConns: 5
   Tidb:
     DBName: base_service
-    Address: 172.20.45.129:4000
-    UserName: root
-    PassWord: =PDT49#80Z!RVv52_z
+    Address: 127.0.0.1:33063
+    UserName: datagroup
+    PassWord: "Dgrpdb#2024@36"
     MaxOpenConns: 5
     MaxIdleConns: 5
   BiTidb:
@@ -51,43 +58,30 @@ Mysql:
     MaxIdleConns: 5
   BiService:
     DBName: bi_service
-    Address: 172.20.45.129:4000
-    UserName: root
-    PassWord: =PDT49#80Z!RVv52_z
-    MaxOpenConns: 5
-    MaxIdleConns: 5
-  WorkOrder:
-    DBName: work_order
-    Address: 172.20.45.129:4000
-    UserName: root
-    PassWord: =PDT49#80Z!RVv52_z
+    Address: 127.0.0.1:33063
+    UserName: datagroup
+    PassWord: "Dgrpdb#2024@36"
     MaxOpenConns: 5
     MaxIdleConns: 5
 Mongo:
   Qfw:
-    MongodbAddr: 172.20.45.129:27002
+    MongodbAddr: 127.0.0.1:27002,172.20.45.130:27080
     DbName: qfw
     Size: 10
   Bidding:
-    MongodbAddr: 172.20.45.129:27002
+    MongodbAddr: 127.0.0.1:27002,172.20.45.130:27080
     DbName: qfw
     UserName:
     Password:
     Size: 10
   Qyxy:
-    MongodbAddr: 172.20.45.129:27002
+    MongodbAddr: 127.0.0.1:27002,172.20.45.130:27080
     DbName: mixdata
-    UserName: jyDevGroup
-    Password: jy@DevGroup
+    UserName: ""
+    Password: ""
     Size: 10
-  PingAn:
-    MongodbAddr: 172.20.45.129:27002
-    UserName: root
-    DbName: mixdata
-    Password: jy@DevGroup
-    Size: 4
 Es:
-  Address: http://172.20.45.129:9206,http://172.20.45.130:9306
+  Address: http://127.0.0.1:9206,http://172.20.45.130:9306
   DbSize: 10
   Version: v7
   UserName: ""
@@ -95,13 +89,13 @@ Es:
   Index: bidding
   IType: bidding
 EntEs:
-  Address: http://172.20.45.129:9206,http://172.20.45.130:9306
+  Address: http://127.0.0.1:9206,http://172.20.45.130:9306
   DbSize: 10
   Version: v7
   UserName: ""
   Password: ""
 Logx:
-  Mode: file #console|file|volume
+  Mode: console #console|file|volume
   Path: logs
   Level: info #info|error|severe
   KeepDays: 100
@@ -109,7 +103,7 @@ CustomerCol: customer
 AddCountLimit: 500
 DrawCountLimit: 1000
 TopicName: jy_position_sync
-NsqUrl: 192.168.3.240:4161
+NsqUrl: 127.0.0.1:4161
 #合力亿捷account_token存储
 RedisAddress:
   - newother=172.20.45.129:1712
@@ -132,55 +126,66 @@ Mail:
   - Addr: smtp.exmail.qq.com
     Port: 465
     Pwd: "ue9Rg9Sf4CVtdm5a"
-    User: "public03@topnet.net"
-UpdateProjectUrl: "http://192.168.3.206:7778/updateProject"
+    User: "public03@topnet.net.cn"
+UpdateProjectUrl: "http://127.0.0.1:7778/updateProject"
 ExportDirectory: "/home/tietaRes"
 ExportUrl: "https://jybx-webtest.jydev.jianyu360.com/tietaRes"
 ExportCount: 15000
 #新增
 ComFileDir: "/home/biComFileRes"
-ComFileUrl: "https://jybx2-webtest.jydev.jianyu360.com/biComFileRes"
+ComFileUrl: "https://jybx-webtest.jydev.jianyu360.com/biComFileRes"
 ResourceCenterKey: resource.rpc
 FileCenterRpc:
   Etcd:
     Hosts:
-      - 172.31.31.203:2379
+      - 127.0.0.1:2379
     Key: filecenter.rpc
 ossBucketName: jytest2022
 ossUrl: https://jytest2022.oss-cn-beijing.aliyuncs.com
 allocationCap: 20
 entId: 25917
 productArr:
-  - product: 数据流量包,结构化数据,API接口,广告服务,广告服务
+  - product: 数据流量包,结构化数据,API接口,广告服务,市场分析报告
     productCode: dk
     personArr:
       - name: 孙振杰
-        phone: '18103853130'
+        phone: '19838689199'
+        isResign: false
       - name: 朱凤超
-        phone: '13027770072'
-      - name: 张文福
-        phone: '15615600992'
-      - name: 王普
-        phone: '13683808356'
+        phone: '18539272857'
+        isResign: false
+      - name: 郭静
+        phone: '13203888592'
+        isResign: true
   - product: 物业专版
     productCode: scdk
     personArr:
       - name: 朱凤超
-        phone: '13027770072'
+        phone: '18539272857'
+        isResign: false
+      - name: 郭静
+        phone: '13203888592'
+        isResign: false
   - product: 咨询服务
     productCode: zx
     personArr:
       - name: 张鹏
-        phone: '13027770072'
+        phone: '13001173386'
+        isResign: false
   - product: 渠道合作
     productCode: sc
     personArr:
       - name: 郑爽
         phone: '18595618858'
+        isResign: false
       - name: 蒋鹏
         phone: '18625550083'
+        isResign: false
   - product: 三方服务
     productCode: sc1
     personArr:
       - name: 郑爽
-        phone: '18595618858'
+        phone: '18595618858'
+        isResign: false
+
+

+ 29 - 14
service/acceptance.go

@@ -186,13 +186,23 @@ func AddOrderWork(orderType, acceptance_no, nowTime, phone, company string, tx *
 
 }
 
+type PersonJson struct {
+	Name       string
+	Phone      string
+	Mail       string
+	DeptId     int64
+	DeptName   string
+	PositionId int64
+	IsResign   bool
+}
+
 // 大客人员选择
 func FindCandidate(personArr []Person, entId int64, orderType string) map[string]interface{} {
 	person := map[string]interface{}{}
-	personEntity := Person{}
+	personEntity := PersonJson{}
 	personMap := make(map[string]map[string]interface{})
 	phoneArr := make([]string, len(personArr))
-
+	persons := make([]PersonJson, len(personArr))
 	// Populate phoneArr and personMap
 	for k, v := range personArr {
 		phone := gconv.String(v.Phone)
@@ -200,6 +210,11 @@ func FindCandidate(personArr []Person, entId int64, orderType string) map[string
 		personMap[phone] = map[string]interface{}{
 			"name": gconv.String(v.Name),
 		}
+		persons[k] = PersonJson{
+			Name:     v.Name,
+			Phone:    v.Phone,
+			IsResign: v.IsResign,
+		}
 	}
 
 	// Fetch personal email and department information
@@ -234,13 +249,13 @@ func FindCandidate(personArr []Person, entId int64, orderType string) map[string
 	}
 
 	// Update personArr with additional information
-	for k, v := range personArr {
+	for k, v := range persons {
 		phone := v.Phone
 		if info, exists := personMap[phone]; exists {
-			personArr[k].Mail = gconv.String(info["mail"])
-			personArr[k].DeptId = gconv.Int64(info["deptId"])
-			personArr[k].DeptName = gconv.String(info["deptName"])
-			personArr[k].PositionId = gconv.Int64(info["positionId"])
+			persons[k].Mail = gconv.String(info["mail"])
+			persons[k].DeptId = gconv.Int64(info["deptId"])
+			persons[k].DeptName = gconv.String(info["deptName"])
+			persons[k].PositionId = gconv.Int64(info["positionId"])
 		}
 	}
 
@@ -251,14 +266,14 @@ func FindCandidate(personArr []Person, entId int64, orderType string) map[string
 
 	var k int
 	if orderWorkMap == nil || len(*orderWorkMap) == 0 {
-		k = findNextPersonIndex(personArr, 0)
+		k = findNextPersonIndex(persons, 0)
 	} else {
 		currentName := gconv.String((*orderWorkMap)[0]["current_name"])
-		k = findPersonIndexByName(personArr, currentName)
-		k = findNextPersonIndex(personArr, k)
+		k = findPersonIndexByName(persons, currentName)
+		k = findNextPersonIndex(persons, k)
 	}
 
-	personEntity = personArr[k]
+	personEntity = persons[k]
 
 	// Set person details
 	person["positionId"] = personEntity.PositionId
@@ -276,7 +291,7 @@ func FindCandidate(personArr []Person, entId int64, orderType string) map[string
 }
 
 // Helper function to find the next person index
-func findNextPersonIndex(personArr []Person, startIndex int) int {
+func findNextPersonIndex(personArr []PersonJson, startIndex int) int {
 	n := len(personArr)
 	// 如果当前索引是最后一个,则从 0 开始
 	if startIndex >= n-1 {
@@ -295,7 +310,7 @@ func findNextPersonIndex(personArr []Person, startIndex int) int {
 }
 
 // Helper function to find a person's index by name
-func findPersonIndexByName(personArr []Person, name string) int {
+func findPersonIndexByName(personArr []PersonJson, name string) int {
 	for i, v := range personArr {
 		if v.Name == name {
 			return i
@@ -367,7 +382,7 @@ func WorkMail(gmailAuth []*mail.GmailAuth, personMap map[string]interface{}, pro
 	if len(mailArr) > 0 {
 		toMail = fmt.Sprintf("%s|%s", toMail, toCc)
 	}
-	log.Println(toMail, "", title, content)
+	log.Println(toMail, title, content)
 	for k, v := range gmailAuth {
 		fool := mail.GSendMail_q("剑鱼标讯", toMail, "", "", title, content, "", "", v)
 		if fool {