| | |
| | | * @param s sql语句 |
| | | */ |
| | | @Async |
| | | public void FTP1(String s) { |
| | | //为防止外网尚未更新完成,休眠2秒发送第一次 |
| | | try { |
| | | Thread.sleep(2); |
| | | } catch (InterruptedException e) { |
| | | e.printStackTrace(); |
| | | } |
| | | FtpUtil.sqlFileUpload(s); |
| | | FTP2(s); |
| | | } |
| | | |
| | | /** |
| | | * FTP 审查结果推送 |
| | | * @param s sql语句 |
| | | */ |
| | | @Async |
| | | public void FTP2(String s) { |
| | | //休眠30s,再次发送一次 |
| | | try { |
| | | Thread.sleep(30); |
| | | } catch (InterruptedException e) { |
| | | e.printStackTrace(); |
| | | } |
| | | FtpUtil.sqlFileUpload(s); |
| | | public void FTP1(String s,String id) { |
| | | FtpUtil.sqlFileUploadUserExamine(s,id); |
| | | } |
| | | |
| | | |
| | |
| | | user.setId(user0.getId()); |
| | | //远程调用接口 |
| | | String body = InvestigateUtil.httpGetOne(user0.getCardid()); |
| | | System.out.println("user0 = " + user0.getCardid()); |
| | | JSONObject jsonObject = new JSONObject(body); |
| | | Object data = jsonObject.get("data"); |
| | | JSONObject jsonData = new JSONObject(data.toString()); |
| | |
| | | String s1 = "update blade_user set examination_type = " + user.getExaminationType() + |
| | | ",update_time = " + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(user.getUpdateTime()) + "'" + |
| | | " where id = " + "'" + user.getId() + "'"; |
| | | FTP1(s1); |
| | | FTP1(s1,user.getId().toString()); |
| | | } |
| | | |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 异步新增用户从业记录 |
| | | * @param user |