erp推送状态为 2的

cmd/cron/merge/cron.go

@@ -27,8 +27,6 @@ func main()  {
 	if err := boot.Boot(path); err != nil {
 	if err := boot.Boot(path); err != nil {
 		panic(err)
 		panic(err)
 	}
 	}
-	//service.NewServiceSupplier().MappingHandle(1)
-	//return
 	switch taskName {
 	switch taskName {
 	case "supplierMerge":
 	case "supplierMerge":
 		fmt.Println("供应商合并")
 		fmt.Println("供应商合并")

conf/dev/database.ini

 [xorm]
 [xorm]
-ShowSQL = false
+ShowSQL = true
 
 
 [pool_class]
 [pool_class]
 user_name = root
 user_name = root

service/service_erp.go

@@ -67,7 +67,8 @@ func (this *ErpService) SyncErp()  {
 	for{
 	for{
 		poolSupplierEntity:=&PoolSupplierEntity{}
 		poolSupplierEntity:=&PoolSupplierEntity{}
 		count:=0
 		count:=0
-		rows,err:= dbSpu.Table("lie_supplier_channel").Where("is_type=? and status in (?,?) and supplier_id>? ",0,2,-2,supplierId).Limit(10).Rows(poolSupplierEntity)
+		rows,err:= dbSpu.Table("lie_supplier_channel").Where("is_type=? and status = ? and supplier_id>? ",0,2,supplierId).Limit(10).Rows(poolSupplierEntity)
+
 		if err != nil {
 		if err != nil {
 			syncLog.SyncInsertLog("erp_merger",ErpTaskName+"查询供应商列表出错,err:"+err.Error())
 			syncLog.SyncInsertLog("erp_merger",ErpTaskName+"查询供应商列表出错,err:"+err.Error())
 			panic(nil)
 			panic(nil)