Project

General

Profile

« Previous | Next » 

Revision 60657

Added by Michele Artini about 3 years ago

author format: surname, name

View differences:

PimpaUpdateJobNode.java
13 13 
import eu.dnetlib.clients.pimpa.PimpaStubFactory;
14 14 
import eu.dnetlib.data.db.AffiliationsDao;
15 15 
import eu.dnetlib.data.utils.IstiConstants;
16 
import eu.dnetlib.data.utils.XsltFunctions;
17 16 
import eu.dnetlib.msro.workflows.graph.Arc;
18 17 
import eu.dnetlib.msro.workflows.procs.Env;
18 
import eu.dnetlib.rmi.manager.MSROException;
19 19 

  		




  
  20
  
    
@Deprecated


  		




  20
  21
  
    
public class PimpaUpdateJobNode extends SimpleJobNode {


  		




  21
  22
  
    

  		




  22
  23
  
    
	@Autowired


  		




  ......




  33
  34
  
    

  		




  34
  35
  
    
	@Override


  		




  35
  36
  
    
	protected String execute(final Env env) throws Exception {


  		




  
  37
  
    
		throw new MSROException("THIS NODE IS DEPRECATED");


  		




  
  38
  
    
		// return _execute(env);


  		




  
  39
  
    
	}


  		




  
  40
  
    

  		




  
  41
  
    
	private String _execute(final Env env) throws Exception {


  		




  36
  42
  
    
		log.info("Reimport records from PIMPA - START");


  		




  37
  43
  
    

  		




  38
  44
  
    
		final Map<String, Boolean> oldPids = dao.getPersonIds().stream().collect(Collectors.toMap(s -> s, s -> true));


  		




  ......




  52
  58
  
    
							final String pid = "matricola:" + p.getCode().trim();


  		




  53
  59
  
    

  		




  54
  60
  
    
							if (!oldPids.containsKey(pid)) {


  		




  55
  
  
    
								dao.registerPerson(pid, String.format("%s %s", p.getName().trim(), p.getSurname().trim()));


  		




  
  61
  
    
								dao.registerPerson(pid, p.getName().trim(), p.getSurname().trim());


  		




  56
  62
  
    
								oldPids.put(pid, false);


  		




  57
  63
  
    
							} else if (overridePersons && oldPids.get(pid)) {


  		




  58
  64
  
    
								log.info("Overriding person " + pid);


  		




  59
  
  
    
								dao.updatePerson(pid, String.format("%s %s", p.getName().trim(), p.getSurname().trim()));


  		




  
  65
  
    
								dao.updatePerson(pid, p.getName().trim(), p.getSurname().trim());


  		




  60
  66
  
    
								oldPids.put(pid, false);


  		




  61
  67
  
    
							}


  		




  62
  68
  
    
							p.getLabs().getList().forEach(lab -> {


  		




  ......




  77
  83
  
    
				});


  		




  78
  84
  
    

  		




  79
  85
  
    
		if (capitalizeFullnames) {


  		




  80
  
  
    
			log.info("Capitalizing person fullnames");


  		




  81
  
  
    
			dao.listPersons().forEach(p -> {


  		




  82
  
  
    
				dao.updatePerson(p.getId(), XsltFunctions.capitalize(p.getName()));


  		




  83
  
  
    
			});;


  		




  
  86
  
    
			log.info("Capitalizing person fullnames - DEPRECATED - NOT PERFROMED");


  		




  
  87
  
    
			// dao.listPersons().forEach(p -> { dao.updatePerson(p.getId(), XsltFunctions.capitalize(p.getName())); });;


  		




  84
  88
  
    
		}


  		




  85
  89
  
    

  		




  86
  90
  
    
		log.info("Reimport records from PIMPA - END");


  		












Also available in:  Unified diff