fix

app/service/upload_sku_sync.go

@@ -91,6 +91,7 @@ func (this *UploadSkuSync)Sync()  error{
 //开始处理
 func (this *UploadSkuSync) handle()  {
 
+	fmt.Printf("加1")
 	dao.IncrSyncQueue(this.SkuRes.UpSn)//redis 完成同步+1
 	if(this.SkuRes.UpSn=="" || this.SkuRes.UploadLogId==0){
 		msg:=fmt.Sprintf("回调的消息UploadLogId 和 UpSn 为空或者为0%s",this.SkuReStr)
@@ -193,7 +194,7 @@ func (this *UploadSkuSync) IshandleSucess() (bool,error) {
 	}
 	countSend,err:=dao.GetShouldSendQueueCount(this.SkuRes.UpSn)
 	fmt.Printf("up_sn:%s:应该发送的数量为:%d\n",this.SkuRes.UpSn,countSend)
-	if(countSync==countSend){
+	if(countSync>=countSend){
 		return true,nil
 	}
 	return  false,nil