进客成调整

clueSync/kc.go

@@ -56,18 +56,18 @@ ORDER BY
 			productType := gconv.String(v["product_type"])
 			vipStarttime := gconv.String(v["service_starttime"])
 			vipEndtime := gconv.String(v["service_endtime"])
-			orderChange := gconv.Int64(v["order_change"])
+			service_type := gconv.Int64(v["service_type"])
 			difference := gconv.Int(v["difference"])
-			if (orderChange != 0) || (orderChange == 0 && difference > 95) {
+			if (service_type != 4) || (service_type == 4 && difference > 95) {
 				isExit := false
 				for _, v := range customList {
 					if v == orderCode {
 						isExit = true
-						//continue
+						continue
 					}
 				}
 				if isExit {
-					//continue
+					continue
 				}
 				//判断一下服务周期
 				_, productInt64, _ := GetOrderProduct(productType, gconv.String(v["productFilter"]))
@@ -138,9 +138,6 @@ func kcJob(data map[string]interface{}) int {
 		if saleDep == "客户成功组" {
 			//新增线索
 			position_id = 0
-		} else if saleDep == "销售部" {
-			log.Println("该订单数据销售部业绩,不会创建线索")
-			return 0
 		} else {
 			position_id = orderPositionId
 			//其他信息
@@ -540,7 +537,7 @@ func ordersClue() {
 	sql := fmt.Sprintf(`select a.*,b.product_type as productType ,b.service_starttime,b.service_endtime,b.filter AS productFilter     from  dataexport_order  a  
     INNER JOIN   jy_order_detail   b    on   a.order_code=b.order_code
     and    a.autoUpdate>="%s"  AND a.user_phone NOT LIKE "%s"   and   a.user_id  !=""
-    and b.product_type in  (%s) and a.order_status = 0 and   a.is_backstage_order = 1  order by a.autoUpdate asc`, lastOrderClueId, "9%", product_type_str2)
+    and b.product_type in  (%s) and a.order_status = 1 and   a.is_backstage_order = 1  order by a.autoUpdate asc`, lastOrderClueId, "9%", product_type_str2)
 
 	data := Mysql.SelectBySql(sql)
 	if data != nil && *data != nil && len(*data) > 0 {

csrSync/go.sum

@@ -1,4 +1,3 @@
-app.yhyue.com/moapp/esv1 v0.0.0-20220414031211-3da4123e648d h1:WPsYuuptAd3UEgN+jPzpnsDe/OvcshDUUtOTZPYGSJ8=
 app.yhyue.com/moapp/esv1 v0.0.0-20220414031211-3da4123e648d/go.mod h1:91/lSD/hS+ckMVP3WdidRzDhC60lLMdyce9QHy0cSMA=
 app.yhyue.com/moapp/jybase v0.0.0-20230405040249-a36a23595798 h1:seczpucZNVIcwMpHN/tr1t9l7Qf533nm69FqJLq24qs=
 app.yhyue.com/moapp/jybase v0.0.0-20230405040249-a36a23595798/go.mod h1:zB47XTeJvpcbtBRYgkQuxOICWNexiZfbUO+7aUf6mNs=
@@ -114,7 +113,6 @@ github.com/evanphx/json-patch v4.11.0+incompatible/go.mod h1:50XU6AFN0ol/bzJsmQL
 github.com/fatih/color v1.13.0/go.mod h1:kLAiJbzzSOZDVNGyDpeOxJ47H46qBXwg5ILebYFFOfk=
 github.com/form3tech-oss/jwt-go v3.2.2+incompatible/go.mod h1:pbq4aXjuKjdthFRnoDwaVPLA+WlJuPGy+QneDUgJi2k=
 github.com/form3tech-oss/jwt-go v3.2.3+incompatible/go.mod h1:pbq4aXjuKjdthFRnoDwaVPLA+WlJuPGy+QneDUgJi2k=
-github.com/fortytw2/leaktest v1.3.0 h1:u8491cBMTQ8ft8aeV+adlcytMZylmA5nnwwkRZjI8vw=
 github.com/fortytw2/leaktest v1.3.0/go.mod h1:jDsjWgpAGjm2CA7WthBh/CdZYEPF31XHquHwclZch5g=
 github.com/frankban/quicktest v1.11.3/go.mod h1:wRf/ReqHper53s+kmmSZizM8NamnL3IM0I9ntUbOk+k=
 github.com/fsnotify/fsnotify v1.4.7/go.mod h1:jwhsz4b93w/PPRr/qN1Yymfu8t87LnFCMoQvtojpjFo=
@@ -256,7 +254,6 @@ github.com/jinzhu/now v1.1.1/go.mod h1:d3SSVoowX0Lcu0IBviAWJpolVfI5UJVZZ7cO71lE/
 github.com/jmespath/go-jmespath v0.4.0/go.mod h1:T8mJZnbsbmF+m6zOOFylbeCJqk5+pHWvzYPziyZiYoo=
 github.com/jmespath/go-jmespath/internal/testify v1.5.1/go.mod h1:L3OGu8Wl2/fWfCI6z80xFu9LTZmf1ZRjMHUOPmWr69U=
 github.com/jmoiron/sqlx v1.2.0/go.mod h1:1FEQNm3xlJgrMD+FBdI9+xvCksHtbpVBBw5dYhBSsks=
-github.com/josharian/intern v1.0.0 h1:vlS4z54oSdjm0bgjRigI+G1HpF+tI+9rE5LLzOg8HmY=
 github.com/josharian/intern v1.0.0/go.mod h1:5DoeVV0s6jJacbCEi61lwdGj/aVlrQvzHFFd8Hwg//Y=
 github.com/jpillora/backoff v1.0.0/go.mod h1:J/6gKK9jxlEcS3zixgDgUAsiuZ7yrSoa/FX5e0EB2j4=
 github.com/json-iterator/go v1.1.6/go.mod h1:+SdeFBvtyEkXs7REEP0seUULqWtbJapLOCVDaaPEHmU=
@@ -288,7 +285,6 @@ github.com/lib/pq v1.10.6/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o=
 github.com/mailru/easyjson v0.0.0-20190614124828-94de47d64c63/go.mod h1:C1wdFJiN94OJF2b5HbByQZoLdCWB1Yqtg26g4irojpc=
 github.com/mailru/easyjson v0.0.0-20190626092158-b2ccc519800e/go.mod h1:C1wdFJiN94OJF2b5HbByQZoLdCWB1Yqtg26g4irojpc=
 github.com/mailru/easyjson v0.7.6/go.mod h1:xzfreul335JAWq5oZzymOObrkdz5UnU4kGfJJLY9Nlc=
-github.com/mailru/easyjson v0.7.7 h1:UGYAvKxe3sBsEDzO8ZeWOSlIQfWFlxbzLZe7hwFURr0=
 github.com/mailru/easyjson v0.7.7/go.mod h1:xzfreul335JAWq5oZzymOObrkdz5UnU4kGfJJLY9Nlc=
 github.com/mattn/go-colorable v0.1.9/go.mod h1:u6P/XSegPjTcexA+o6vUJrdnUu04hMope9wVRipJSqc=
 github.com/mattn/go-isatty v0.0.12/go.mod h1:cbi8OIDigv2wuxKPP5vlRcQ1OAZbq2CE4Kysco4FUpU=
@@ -316,7 +312,6 @@ github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e/go.mod h1:zD1mROLA
 github.com/nxadm/tail v1.4.4/go.mod h1:kenIhsEOeOJmVchQTgglprH7qJGnHDVpk1VPCcaMI8A=
 github.com/nxadm/tail v1.4.8/go.mod h1:+ncqLTQzXmGhMZNUePPaPqPvBxHAIsmXswZKocGu+AU=
 github.com/olekukonko/tablewriter v0.0.5/go.mod h1:hPp6KlRPjbx+hW8ykQs1w3UBbZlj6HuIJcUGPhkA7kY=
-github.com/olivere/elastic v6.2.37+incompatible h1:UfSGJem5czY+x/LqxgeCBgjDn6St+z8OnsCuxwD3L0U=
 github.com/olivere/elastic v6.2.37+incompatible/go.mod h1:J+q1zQJTgAz9woqsbVRqGeB5G1iqDKVBWLNSYW8yfJ8=
 github.com/olivere/elastic/v7 v7.0.22/go.mod h1:VDexNy9NjmtAkrjNoI7tImv7FR4tf5zUA3ickqu5Pc8=
 github.com/onsi/ginkgo v0.0.0-20170829012221-11459a886d9c/go.mod h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE=

csrSync/job.go

@@ -114,7 +114,6 @@ L:
 			requestsss.ResTextFormat = common.Uint64Ptr(0)
 			requestsss.SourceType = common.Uint64Ptr(0)
 			requestsss.Url = common.StringPtr(util.ObjToString(data["MonitorFilename"]))
-
 			responses, errss := client.CreateRecTask(requestsss)
 			if _, ok := errss.(*errors.TencentCloudSDKError); ok {
 				<-ch

csrSync/main.go

@@ -1,13 +1,17 @@
 package main
 
 import (
+	util "app.yhyue.com/moapp/jybase/common"
+	"app.yhyue.com/moapp/jybase/mysql"
 	"flag"
 	"fmt"
-	"log"
-
-	"app.yhyue.com/moapp/jybase/common"
-	"app.yhyue.com/moapp/jybase/mysql"
 	"github.com/robfig/cron"
+	asr "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/asr/v20190614"
+	"github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common"
+	"github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common/errors"
+	"github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common/profile"
+	"log"
+	"time"
 )
 
 var (
@@ -19,8 +23,42 @@ var (
 
 func main() {
 	flag.Parse()
-	common.ReadConfig(&cfg)
-	log.Println("cfg ", cfg)
+	util.ReadConfig(&cfg)
+	credential := common.NewCredential(
+		cfg.KeyId,
+		cfg.Key,
+	)
+	cpf := profile.NewClientProfile()
+	cpf.HttpProfile.Endpoint = "asr.tencentcloudapi.com"
+	client, _ = asr.NewClient(credential, "ap-guangzhou", cpf)
+	defer util.Catch()
+	request := asr.NewCreateRecTaskRequest()
+	request.EngineModelType = common.StringPtr("8k_zh")
+	request.ChannelNum = common.Uint64Ptr(1)
+	request.SpeakerDiarization = common.Int64Ptr(1)
+	request.SpeakerNumber = common.Int64Ptr(2)
+	request.ResTextFormat = common.Uint64Ptr(0)
+	request.SourceType = common.Uint64Ptr(0)
+	//request.Url = common.StringPtr(util.ObjToString(data["MonitorFilename"]))
+	request.Url = common.StringPtr("https://storage.7x24cc.com/storage-server/presigned/ss1/a6-online-work-phone-record/workPhoneRecord/20250224/20250224151935_18595503318_177****8064_dab6d83a-5011-4019-b7c9-2771b5d26a84.mp3")
+	response, err := client.CreateRecTask(request)
+	log.Println(response)
+	if _, ok := err.(*errors.TencentCloudSDKError); ok {
+		<-ch
+		fmt.Printf("An API error has returned: %s", err)
+		return
+	}
+	taskId := response.Response.Data.TaskId
+	requestss := asr.NewDescribeTaskStatusRequest()
+	log.Println("任务id ", *taskId)
+	requestss.TaskId = taskId
+	r, errs := client.DescribeTaskStatus(requestss)
+	log.Println("查询结果======", r.ToJsonString(), errs)
+	if _, oks := errs.(*errors.TencentCloudSDKError); oks {
+		fmt.Printf("An API error has returned: %s", errs)
+		time.Sleep(time.Duration(cfg.WaitingTime) * time.Second)
+	}
+	log.Println("cfg ", r)
 	//
 	ch = make(chan bool, cfg.Chan)
 	//

telemarketingEtl/config.yaml

@@ -1,22 +1,22 @@
 tidb:
   jianyuSubjectdb:
     dbName: jianyu_subjectdb_test
-    address: 192.168.3.149:4000
-    userName: root
-    password: 'Tibi#20211222'
+    address: 172.17.162.27:14000
+    userName: datagroup
+    password: Dgrpdb#2024@36
     maxOpenConns: 80
     maxIdleConns: 5
   callAccount:
     dbName: Call_Accounting
-    address: 192.168.3.149:4000
+    address: 172.20.45.129:4000
     userName: root
-    password: 'Tibi#20211222'
+    password: '=PDT49#80Z!RVv52_z'
     maxOpenConns: 80
     maxIdleConns: 5
 mysql:
   main:
     dbName: jianyu
-    address: 192.168.3.14:4000
+    address: 172.20.45.129:4000
     userName: root
     password: '=PDT49#80Z!RVv52_z'
     maxOpenConns: 80
@@ -25,23 +25,23 @@ mongo:
   main:
     dbName: qfw
     size: 50
-    address: 192.168.3.149:27180
+    address: 172.20.45.129:27002
   log:
     dbName: qfw
     size: 50
-    address: 192.168.3.149:27190
+    address: 172.20.45.129:27002
     userName: admin
     password: 123456
   ent:
     dbName: mixdata
     size: 50
-    address: 192.168.3.149:27102
+    address: 172.20.45.129:27002
     collection: qyxy
     collectionChange: qyxy_change
     userName: jyDevGroup
     password: jy@DevGroup
   bidding:
-    address: 192.168.3.149:27102
+    address: 172.20.45.129:27002
     size: 50
     dbName: qfw_data
     collection: bidding