| | |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.beans.factory.annotation.Value; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | |
| | | import java.util.ArrayList; |
| | | import java.util.List; |
| | |
| | | logger.info("查询人员"+perId+":"+content); |
| | | MqUtils.createClient(emqxConfig,sns,content); |
| | | } |
| | | |
| | | @Override |
| | | @Transactional |
| | | public void deleteNotify(String mess) { |
| | | JSONObject jsonObject = JSON.parseObject(mess); |
| | | if(jsonObject.containsKey("success")&&jsonObject.getBooleanValue("success")){ |
| | | JSONObject paramJson = jsonObject.getJSONObject("param"); |
| | | List<String> userIds = JSONArray.parseArray(paramJson.getString("userIds"),String.class); |
| | | userMapper.syncResult(3,userIds); |
| | | } |
| | | } |
| | | } |