up

app/service/crm/cron_sendmsg/cron_sendmsg_service.go

@@ -2,14 +2,13 @@ package cron_sendmsg
 
 import (
 	"errors"
-	"fmt"
+	cfg "github.com/ichunt2019/cfg/lib"
 	"github.com/tidwall/gjson"
 	"golang-asynctask/app/dao/crm/cron_sendmsg"
+	comfunc "golang-asynctask/util/lib"
 	"net/http"
 	"net/url"
 	"time"
-	cfg "github.com/ichunt2019/cfg/lib"
-	comfunc "golang-asynctask/util/lib"
 )
 
 func SendMsg() (err error){
@@ -23,7 +22,7 @@ func SendMsg() (err error){
 	if err != nil{
 		return err
 	}
-	fmt.Println(res)
+	//fmt.Println(res)
 
 	if(len(res) <= 0){
 		return

cmd/crm/cron_sendmsg/main.go

@@ -18,6 +18,5 @@ func main(){
 	flag.StringVar(&logPath, "logdir", "./logs/", "日志文件存储目录")
 	flag.Parse()
 	boot.Init(configPath,logPath)
-
 	cron_sendmsg.SendMsg()
 }

config/prod/config.toml

@@ -3,6 +3,8 @@ title = "TOML 例子"
 viewpath = "/home/www/templates/"
 
 pushErpDomain = "http://crm.ichunt.net/api/pushComUserRelationToErp"
+crmSendMsgByconflictSale = "http://crm.ichunt.net/api/sendMsgByconflictSale"
+sendMsgByChangeInvoiceCom = "http://crm.ichunt.net/api/sendMsgByChangeInvoiceCom"
 apiKey = "crm a1b2c3d4e5f6g7h8i9jk"
 
 [rabbitmq_crm_comuser_fenfa]
@@ -19,4 +21,12 @@ queue_name="crm_pushcomuser_toerp"
 routing_key="crm_pushcomuser_toerp"
 exchange=""
 type="direct"
+dns="amqp://WmsQue:EizM9I1TAxoO0tmzoOm@172.18.137.33:5672/"
+
+
+[rabbitmq_crm_invoice_com_apply]
+queue_name="crm_invoice_com_apply"
+routing_key="crm_invoice_com_apply"
+exchange=""
+type="direct"
 dns="amqp://WmsQue:EizM9I1TAxoO0tmzoOm@172.18.137.33:5672/"
\ No newline at end of file