Commit 11bb412a authored by litengwei's avatar litengwei

中心BUG修改

parent e98565f0
......@@ -1967,8 +1967,9 @@ public class EquipmentSpecificSerivceImpl extends ServiceImpl<EquipmentSpecificM
Date now = new Date();
String scrapTime = new SimpleDateFormat(DateUtils.DATE_TIME_PATTERN).format(calendar.getTime());
int day = DateUtils.dateBetween(now, calendar.getTime());
log.info("报废时间:{}" , day);
log.info("报废时间ID:{}" , e.get("id").toString());
if (day < Integer.parseInt(equipmentScrapDay) && day > -1) {
syncSystemctlMsg(e, scrapTime, day);
} else if (day == -1) {
......
......@@ -214,9 +214,9 @@ public class SignServiceImpl extends BaseService<SignDto,Sign,SignMapper> implem
if(mapSign.size() == 0) {
Map<String, Object> map = new HashMap<>();
map.put("bizOrgCode", "");
mapSign.add(map);
mapList.add(map);
try {
emqKeeper.getMqttClient().publish("jcs/sign/put", JSONObject.toJSONString(mapSign).getBytes(), 1, false);
emqKeeper.getMqttClient().publish("jcs/sign/put", JSONObject.toJSONString(mapList).getBytes(), 1, false);
} catch (MqttException exp) {
log.info(String.format("发送eqm转kafka消息失败:%s", exp.getMessage()));
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment