Jelajahi Sumber

【fix】配标器更新添加同步时间

chengjing 2 tahun lalu
induk
melakukan
d7807e75f3

+ 2 - 0
huimv-eartag2-platform/huimv-eartag2-manage2/src/main/java/com/huimv/eartag2/manage2/service/impl/EartagDeviceRegisterServiceImpl.java

@@ -221,6 +221,8 @@ public class EartagDeviceRegisterServiceImpl extends ServiceImpl<EartagDeviceReg
             String substring = maxDeviceCode.substring(maxDeviceCode.length() - 6);
             int code = Integer.parseInt(substring)+1;
             String format = String.format("%6d", code);
+
+            System.out.println("--------------------"+format);
             return new Result(ResultCode.SUCCESS,farmCode+format);
         }
     }

+ 14 - 0
huimv-eartag2-platform/huimv-eartag2-manage2/src/main/java/com/huimv/eartag2/manage2/service/impl/SysBaseConfigServiceImpl.java

@@ -1,8 +1,11 @@
 package com.huimv.eartag2.manage2.service.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.huimv.eartag2.common.utils.DateUtil;
 import com.huimv.eartag2.common.utils.Result;
 import com.huimv.eartag2.common.utils.ResultCode;
+import com.huimv.eartag2.manage2.mapper.EartagDeviceRegisterMapper;
+import com.huimv.eartag2.manage2.pojo.EartagDeviceRegister;
 import com.huimv.eartag2.manage2.pojo.SysBaseConfig;
 import com.huimv.eartag2.manage2.mapper.SysBaseConfigMapper;
 import com.huimv.eartag2.manage2.service.SysBaseConfigService;
@@ -33,6 +36,9 @@ public class SysBaseConfigServiceImpl extends ServiceImpl<SysBaseConfigMapper, S
     @Resource
     RabbitTemplate rabbitTemplate;
 
+    @Resource
+    private EartagDeviceRegisterMapper eartagDeviceRegisterMapper;
+
     @Override
     public Result add(List<Map<String, String>> mapList) {
         //SysBaseConfigEntity
@@ -173,6 +179,14 @@ public class SysBaseConfigServiceImpl extends ServiceImpl<SysBaseConfigMapper, S
         paramsMap.put("areaName",sysBaseConfigVo.getAreaName());
         rabbitTemplate.convertAndSend(EXCHANGE_SYNC_SYS_CONFIG,ROUTING_KEY_SYNC_SYS_CONFIG,paramsMap);
         System.out.println("--------------------------------------- 发送设备请求原始数据 >>"+paramsMap);
+        //更新同步时间
+        String chipId = paramsMap.get("chipId");
+        QueryWrapper<EartagDeviceRegister> queryWrapper1 = new QueryWrapper<>();
+        queryWrapper1.eq("chip_id",chipId);
+        List<EartagDeviceRegister> eartagDeviceRegisters = eartagDeviceRegisterMapper.selectList(queryWrapper1);
+        for (EartagDeviceRegister eartagDeviceRegister : eartagDeviceRegisters) {
+            eartagDeviceRegister.setSyncTime(new DateUtil().getTimestamp());
+        }
         return new Result(ResultCode.SUCCESS);
     }