Преглед на файлове

消息队列发送方数据格式问题修改

luyanwen преди 4 години
родител
ревизия
8874f83648
променени са 1 файла, в които са добавени 6 реда и са изтрити 2 реда
  1. 6 2
      abi-cloud-qr-platform-server/src/main/java/com/abi/qms/platform/service/impl/QrPackageServiceImpl.java

+ 6 - 2
abi-cloud-qr-platform-server/src/main/java/com/abi/qms/platform/service/impl/QrPackageServiceImpl.java

@@ -2,6 +2,7 @@ package com.abi.qms.platform.service.impl;
 
 import cn.hutool.core.io.FileUtil;
 import cn.hutool.core.io.IoUtil;
+import cn.hutool.json.JSONUtil;
 import com.abi.qms.platform.dao.entity.QrPackage;
 import com.abi.qms.platform.dao.entity.QrPackageDownloadRecord;
 import com.abi.qms.platform.dao.enums.QrPackageApplyStatusEnum;
@@ -22,6 +23,7 @@ import com.abi.qms.platform.service.QrDataService;
 import com.abi.qms.platform.service.QrPackageService;
 import com.abi.task.common.api.exception.BusinessException;
 import com.abi.task.common.utils.PojoConverterUtils;
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.toolkit.IdWorker;
@@ -103,7 +105,8 @@ public class QrPackageServiceImpl implements QrPackageService {
 		} else {
 			qrPackage.setBatchNumber(IdWorker.getIdStr());
 			qrPackage.setCreateBy(userId);
-			qrPackageMapper.insert(qrPackage);
+			int insert = qrPackageMapper.insert(qrPackage);
+			System.out.println(insert);
 		}
 
 	}
@@ -182,7 +185,8 @@ public class QrPackageServiceImpl implements QrPackageService {
 
 		// 码库类型为系统生成时,放入rabbitmq,生成码
 		if (QrRepertoryTypeEnum.SYSTEM_GENERATE.is(qrPackage.getQrRepertoryType())) {
-			amqpTemplate.convertAndSend(GenerateCodeConsumer.GENERATE_CODE_BY_REPERTORY_QUEUE, qrPackage);
+			amqpTemplate.convertAndSend(GenerateCodeConsumer.GENERATE_CODE_BY_REPERTORY_QUEUE, JSONObject.toJSONString(qrPackage) );
+			System.out.println("rabbitmq结束。。。。。。。。。。。。。。。。");
 		}
 	}