package org.springblade.modules.FTP;
|
|
import org.json.JSONArray;
|
import org.json.JSONObject;
|
import org.springblade.common.utils.DesensitizedUtil;
|
import org.springblade.common.utils.InvestigateUtil;
|
import org.springblade.modules.experience.entity.Experience;
|
import org.springblade.modules.experience.service.IExperienceService;
|
import org.springblade.modules.system.entity.Dept;
|
import org.springblade.modules.system.entity.User;
|
import org.springblade.modules.system.service.IDeptService;
|
import org.springblade.modules.system.service.IUserService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Async;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.PostConstruct;
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
|
/**
|
* @author Administrator
|
*/
|
@Service
|
public class MyAsyncService {
|
|
@Autowired
|
private IUserService userService;
|
|
@Autowired
|
private IDeptService iDeptService;
|
|
@Autowired
|
private IExperienceService experienceService;
|
|
/**
|
* FTP
|
* @param s sql语句
|
*/
|
@Async
|
public void FTP(String s) {
|
FtpUtil.sqlFileUpload(s);
|
}
|
|
/**
|
* FTP 审查结果推送
|
* @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);
|
}
|
|
|
/**
|
* 异步审查新增的保安员
|
* @param user0
|
*/
|
@Async
|
public void checkUserExamineByCardNo(User user0){
|
//如果是保安员
|
if (user0.getRoleId().equals("1412226235153731586")){
|
//创建用户对象
|
User user = new User();
|
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());
|
JSONArray res = jsonData.getJSONArray("res");
|
//设置审核时间
|
user.setAuditTime(new Date());
|
//如果有结果返回
|
if (res.length() == 0) {
|
//没有数据正常
|
user.setExaminationType("0");
|
} else {
|
int count = 0;
|
user.setExaminationType("1");
|
for (int i = 0; i < res.length(); i++) {
|
if (res.getJSONObject(i).get("zdrylbjh").toString() != null
|
&& res.getJSONObject(i).get("zdrylbjh").toString() != ""
|
&& res.getJSONObject(i).get("zdrylbjh").toString() != "null"
|
) {
|
user.setExaminationMx(res.getJSONObject(i).get("zdrylbjh").toString());
|
//更新用户数据
|
// userService.updateById(user);
|
break;
|
}
|
if (res.getJSONObject(i).get("zdryxlmc").toString() != null
|
&& res.getJSONObject(i).get("zdryxlmc").toString() != ""
|
&& res.getJSONObject(i).get("zdryxlmc").toString() != "null"
|
) {
|
user.setExaminationMx(res.getJSONObject(i).get("zdryxlmc").toString());
|
//更新用户数据
|
// userService.updateById(user);
|
break;
|
}
|
if (res.getJSONObject(i).get("ztrylx").toString() != null
|
&& res.getJSONObject(i).get("ztrylx").toString() != ""
|
&& res.getJSONObject(i).get("ztrylx").toString() != "null"
|
) {
|
user.setExaminationMx(res.getJSONObject(i).get("ztrylx").toString());
|
//更新用户数据
|
// userService.updateById(user);
|
break;
|
}
|
count++;
|
//条件中的数据都为空，则审查为正常
|
if (count==res.length()){
|
//更新用户数据,设为正常
|
user.setExaminationType("0");
|
// userService.updateById(user);
|
}
|
}
|
}
|
//更新用户数据
|
userService.updateById(user);
|
//同时更新外网用户信息
|
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() + "'";
|
FTP(s1);
|
}
|
|
}
|
|
/**
|
* 异步新增用户从业记录
|
* @param user
|
*/
|
@Async
|
public void insertExperience(User user) {
|
//根据公司名查询单位
|
Dept dept = iDeptService.getById(user.getDeptId());
|
Experience experience = new Experience();
|
experience.setCompanyname(dept.getDeptName());
|
//新增
|
if (null != user.getRtime()) {
|
experience.setEntrytime(user.getRtime());
|
} else {
|
experience.setEntrytime(new Date());
|
}
|
experience.setDeparturetime(new Date());
|
experience.setName(user.getRealName());
|
if (null != user.getReasonForLeav() && !user.getReasonForLeav().equals("")) {
|
experience.setLeaving(user.getReasonForLeav());
|
}
|
experience.setCardid(user.getCardid());
|
experience.setSecurityid(user.getId().toString());
|
//新增
|
experienceService.save(experience);
|
|
// 身份证号脱敏
|
String cardid = DesensitizedUtil.desensitizedIdNumberBy4(user.getCardid());
|
//内网同步
|
String s = "insert into sys_experience(id,name,entryTime,departureTime,leaving,cardId,companyname,securityId) " +
|
"values(" + "'" + experience.getId() + "'" +
|
"," + "'" + experience.getName() + "'" +
|
"," + "'" + new SimpleDateFormat("yyyy-MM-dd").format(experience.getEntrytime()) + "'" +
|
"," + "'" + new SimpleDateFormat("yyyy-MM-dd").format(experience.getDeparturetime()) + "'" +
|
"," + "'" + experience.getLeaving() + "'" +
|
"," + "'" + cardid + "'" +
|
"," + "'" + experience.getCompanyname() + "'" +
|
"," + "'" + experience.getSecurityid() + "'"
|
+ ")";
|
//向外网推送
|
FTP(s);
|
}
|
}
|
