• 首页
  • 栏目
  • CRM
  • Java连接Dynamics 365 CRM并请求数据，通过Oauth2.0认证

Java连接Dynamics 365 CRM并请求数据，通过Oauth2.0认证

  • 2021-12-15
  • Admin
  1. import com.microsoft.aad.adal4j.AuthenticationResult;
  2. import com.microsoft.aad.adal4j.AuthenticationContext;
  3. import io.vertx.core.json.JsonObject;
  4. import netscape.javascript.JSObject;
  5.  
  6.  
  7. import org.apache.http.HttpResponse;
  8. import org.apache.http.client.HttpClient;
  9. import org.apache.http.client.methods.HttpPost;
  10. import org.apache.http.entity.StringEntity;
  11. import org.apache.http.impl.client.DefaultHttpClient;
  12. import org.apache.http.protocol.HTTP;
  13. import org.apache.http.util.EntityUtils;
  14. import org.apache.olingo.client.api.ODataClient;
  15. import org.apache.olingo.client.api.ODataClientBuilder;
  16. import org.apache.olingo.client.api.domain.ClientEntity;
  17. import org.apache.olingo.client.api.domain.ClientEntitySet;
  18. import org.apache.olingo.client.api.domain.ClientProperty;
  19. import org.apache.olingo.client.core.ODataClientFactory;
  20. import org.apache.olingo.client.core.http.HttpPatch;
  21. import org.apache.olingo.commons.api.format.ContentType;
  22. import org.springframework.security.oauth2.client.DefaultOAuth2ClientContext;
  23. import org.springframework.security.oauth2.client.OAuth2ClientContext;
  24. import org.springframework.security.oauth2.client.OAuth2RestTemplate;
  25. import org.springframework.security.oauth2.client.token.AccessTokenRequest;
  26. import org.springframework.security.oauth2.client.token.DefaultAccessTokenRequest;
  27. import org.springframework.security.oauth2.client.token.grant.password.ResourceOwnerPasswordResourceDetails;
  28. import org.springframework.security.oauth2.common.OAuth2AccessToken;
  29.  
  30. import java.io.*;
  31. import java.net.HttpURLConnection;
  32. import java.net.MalformedURLException;
  33. import java.net.URL;
  34. import java.net.URLEncoder;
  35. import java.nio.charset.StandardCharsets;
  36. import java.util.Arrays;
  37. import java.util.HashMap;
  38. import java.util.List;
  39. import java.util.Map;
  40. import java.util.concurrent.*;
  41. import java.util.zip.GZIPInputStream;
  42.  
  43.  
  44. public class demo {
  45.  
  46.     private HttpURLConnection urlConnection =null;
  47.     public  demo()
  48.     {
  49.  
  50.     }
  51.     public static void main(String[] args) throws Exception {
  52.         System.out.println("Hello World!");
  53.  
  54.         String _token = GetDynamics365Token();// getToken().getAccessToken().toString();
  55.  
  56.         System.out.println(_token);
  57.  
  58.          //String ret = GetAccount(_token);
  59.         // testcreateContact(_token);
  60.         // testGetContact(_token);
  61.          testupdateContact(_token);
  62.     }
  63.     private  static  void testupdateContact(String _token)
  64.     {
  65.         String api = APIUrl+"procontacts"+"(1948d283-a404-ec11-b6e6-000d3aa2e3d2)";
  66.  
  67.  
  68.         JsonObject json = new JsonObject();
  69.         json.put("name","tested by JAVA API(Data patch)");
  70.         json.put("phone","18824158458_patch");
  71.         json.put("email","7874108@qq.com_patch");
  72.         json.put("fullname","fullname test of java call api");
  73.         json.put("contactid@odata.bind","/contacts(40a42e1b-9900-ec11-94ef-00224858241d)");
  74.  
  75.  
  76.  
  77.         //String b = HttpUtil.doPostToJson(api,json.toString(),_token,"Patch");
  78.         String b = HttpPatch(api,_token,json);
  79.         if(String.valueOf(b).contains("No-Content"))
  80.         {
  81.             System.out.println("Updated.");
  82.         }
  83.  
  84.     }
  85.     /**
  86.      * patch请求
  87.      *author：fantabulous24
  88.      * @date 2020年7月9日 下午3:24:50
  89.      */
  90.     public static String HttpPatch(String url,String _token,JsonObject json) {
  91.        String  resultObj = null;
  92.  
  93.         HttpClient httpClient = new DefaultHttpClient();
  94.         HttpPatch httpPatch = new HttpPatch(url);
  95.         httpPatch.setHeader("Content-type", "application/json");
  96.         httpPatch.setHeader("Charset", HTTP.UTF_8);
  97.         httpPatch.setHeader("Accept", "application/json");
  98.         httpPatch.setHeader("Accept-Charset", HTTP.UTF_8);
  99.         httpPatch.setHeader("Authorization","Bearer "+_token);
  100.         try {
  101.             StringEntity entity=null;
  102.             if(json !=null)
  103.             {
  104.                entity = new StringEntity(json.toString(),StandardCharsets.UTF_8);
  105.             }
  106.             else
  107.             {
  108.                 return  "";
  109.             }
  110.  
  111.             httpPatch.setEntity(entity);
  112.             HttpResponse response = httpClient.execute(httpPatch);
  113.  
  114.             resultObj = response.toString();
  115.  
  116.         } catch (IOException e) {
  117.             e.printStackTrace();
  118.         }
  119.         return resultObj;
  120.     }
  121.  
  122.     private  static void testcreateContact(String _token) throws Exception {
  123.  
  124.         String api = APIUrl+"procontacts";
  125.         JsonObject json = new JsonObject();
  126.         json.put("name","tested by JAVA API");
  127.         json.put("phone","18824158458");
  128.         json.put("email","7874108@qq.com");
  129.  
  130.  
  131.        String a =  HttpUtil.doPostToJson(api,json.toString(),_token,"POST");
  132.  
  133.        if(a=="")
  134.        {
  135.            System.out.println("Created!");
  136.        }
  137.  
  138.     }
  139.  
  140.     private  static void testGetContact(String token) throws Exception {
  141.         String ret = null;
  142.  
  143.         String queryurl = APIUrl + "procontacts?$select=procontactid,email,phone,name,createdon&$top=3";
  144.  
  145.         ret = HttpUtil.doPostToJson(queryurl,null,token,"GET");
  146.  
  147.         System.out.println(ret);
  148.  
  149.     }
  150.  
  151.         private  static String GetAccount(String token) throws Exception {
  152.         String ret =null;
  153.         HttpURLConnection connection =null;
  154.         String queryurl = APIUrl+ "accounts?$select=accountid,accountnumber,createdon,telephone1&$top=3";
  155.         URL url = new URL(queryurl);
  156.  
  157.         connection = buildConnection(url,token,"GET");
  158.  
  159.         int res = connection.getResponseCode();
  160.  
  161.         if(res==200)
  162.         {
  163.  
  164.             ClientEntitySet odataEntitySet = GetConnectionResult(connection);
  165.  
  166.             for (ClientEntity odataEntity: odataEntitySet.getEntities())
  167.             {
  168.                 for (ClientProperty curProperty: odataEntity.getProperties())
  169.                 {
  170.                     String propertyContent = curProperty.getName()+":"+curProperty.getValue().toString();
  171.                     ret += propertyContent +"\n";
  172.                     System.out.println(propertyContent);
  173.                 }
  174.             }
  175.         }
  176.  
  177.         return ret;
  178.     }
  179.  
  180.     private static ClientEntitySet GetConnectionResult(HttpURLConnection conn) throws Exception {
  181.  
  182.         ODataClient client = ODataClientFactory.getClient();
  183.  
  184.         String jsonObject =null;
  185.         if("gzip".equals(conn.getContentEncoding()))
  186.         {
  187.             Reader reader = new InputStreamReader(new GZIPInputStream(conn.getInputStream()));
  188.  
  189.             String jsonRawOutput ="";
  190.             while (true)
  191.             {
  192.                 int ch = reader.read();
  193.  
  194.                 if(ch==1)
  195.                 {
  196.                     break;
  197.                 }
  198.                 jsonRawOutput += (char)ch;
  199.             }
  200.             jsonObject = jsonRawOutput;
  201.         }
  202.         else
  203.         {
  204.             BufferedReader in = new BufferedReader(new InputStreamReader(conn.getInputStream()));
  205.             String jsonoutput ="";
  206.             while (true)
  207.             {
  208.                 int ch = in.read();
  209.                 if(ch==-1)
  210.                 {
  211.                     break;
  212.                 }
  213.                 jsonoutput += (char)ch;
  214.             }
  215.             jsonObject = jsonoutput;
  216.         }
  217.  
  218.         InputStream inputStream = new ByteArrayInputStream(jsonObject.getBytes(StandardCharsets.UTF_8));
  219.  
  220.         return client.getReader().readEntitySet(inputStream, ContentType.APPLICATION_JSON);
  221.     }
  222.  
  223.     private  static HttpURLConnection buildConnection( URL _url,String _token,String _RequestMethod ) throws Exception {
  224.  
  225.         if(_RequestMethod.trim()=="")
  226.         {
  227.             return  null;
  228.         }
  229.         HttpURLConnection _connect = (HttpURLConnection) _url.openConnection();
  230.         _connect.setRequestMethod(_RequestMethod);
  231.  
  232.         _connect.setRequestProperty("OData-MaxVersion","4.0");
  233.         _connect.setRequestProperty("OData-Version","4.0");
  234.         _connect.setRequestProperty("Accept","application/json");
  235.         _connect.setRequestProperty("Content-Type","application/json");
  236.         _connect.setRequestProperty("Prefer","odata.include-annotations=OData.Community.Display.V1.FormattedValue");
  237.        // _connect.setRequestProperty("Prefer","odata.include-annotations=\\\"Microsoft.Dynamics.CRM.fetchxmlpagingcookie\\");
  238.         _connect.setRequestProperty("Authorization","Bearer "+_token);
  239.         _connect.connect();
  240.  
  241.         return  _connect;
  242.  
  243.     }
  244.  
  245.     private static String tokenUrl = "https://login.microsoftonline.com/common/oauth2/token";
  246.     private static String resource = "https://url.crm5.dynamics.com";
  247.     private static String clientId ="xxxxxxx-e055-4f71-b3c0-xxxxxxxf3";
  248.     private static String username = "youraccount of CLOUD.onmicrosoft.com";
  249.     private static String password = "pwd";
  250.     private static String APIUrl = "https://youraddress.crm5.dynamics.com/api/data/v9.0/";
  251.  
  252.     private  static  AuthenticationResult getToken() {
  253.         AuthenticationResult token = null;
  254.         AuthenticationContext context = null;
  255.         ExecutorService service = null;
  256.         try
  257. 
			
    
	
    
		
    免费ERP
    
	
    
		
    61ebf17978942.jpg
     注册    登录 
    用户名: demo; 密码: 123456
    
	
    

    
	
    
		
    最新
    
	
    
			
	
    

    
	
    
		
    最热

ERP

联系站长

QQ：769220720

Copyright © SibooSoft All right reserved 津ICP备19011444号