ソースを参照

增加线下版本队列处理v2

xiewenjie 3 年 前
コミット
300fdc3350

+ 2 - 3
sxz-core/src/main/java/com/fdkk/sxz/other/listener/Model3dBuild.java

@@ -54,7 +54,7 @@ public class Model3dBuild {
     @RabbitListener(queues = TopicRabbitConfig.MODEL_BIZ_3D)
     public void modelBiz3d(Message<RequestQueue> message) {
         Model3dBuild.log.info("modelBiz3d同步消息开始:" + message + ",开始同步");
-        String token = RedisUtil.tryLock(message.getPayload().getTaskId().toString(), 60 * 60 * 1000);
+        String token = RedisUtil.tryLock("modelBiz3d:" + message.getPayload().getName().toString(), 60 * 60 * 1000);
         try {
             if (token != null) {
                 modelBiz3dHandler(message.getPayload());
@@ -88,11 +88,10 @@ public class Model3dBuild {
             }
             break;
         }
-        
+
         boolean over = false;
         int times = 0;
         //是否处理obj文件
-        boolean uploadObj = true;
         JSONObject jsonObject = new JSONObject();
         jsonObject.put("name", str.getName());
         jsonObject.put("taskType", "localDataUpload");