| | |
| | | package org.springblade.modules.system.service; |
| | | |
| | | import com.alibaba.fastjson.JSON; |
| | | import net.sf.json.JSONObject; |
| | | import org.springblade.common.utils.HttpClientUtils; |
| | | import org.springblade.modules.FTP.FtpUtil; |
| | | import org.springblade.modules.FTP.Result; |
| | | import org.springblade.modules.system.dto.UserDTO; |
| | | import org.springblade.modules.system.entity.User; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.scheduling.annotation.Async; |
| | | import org.springframework.stereotype.Service; |
| | | |
| | |
| | | import java.util.Map; |
| | | |
| | | import static org.springblade.common.config.FtpConfig.qfqkBaseApiUrl; |
| | | import static org.springblade.modules.FTP.DataHandler.handlerUserInfo; |
| | | |
| | | @Service |
| | | public class MyAsyncService { |
| | |
| | | JSONObject jsonObject = JSONObject.fromObject(userDTO); |
| | | //发送请求 |
| | | try { |
| | | System.out.println("发起异步推送qfqk----用户新增"); |
| | | HttpClientUtils.httpPostWithjson(requestUrl,jsonObject.toString()); |
| | | System.out.println("用户新增请求已发送...."); |
| | | } catch (IOException e) { |
| | |
| | | JSONObject jsonObject = JSONObject.fromObject(userDTO); |
| | | //发送请求 |
| | | try { |
| | | System.out.println("发起异步推送qfqk----用户更新"); |
| | | HttpClientUtils.httpPostWithjson(requestUrl,jsonObject.toString()); |
| | | } catch (IOException e) { |
| | | e.printStackTrace(); |