|
|
|
|
@ -5,13 +5,36 @@ import cn.hutool.core.util.StrUtil;
|
|
|
|
|
import cn.hutool.http.HttpRequest;
|
|
|
|
|
import com.alibaba.fastjson2.JSON;
|
|
|
|
|
import com.alibaba.fastjson2.JSONObject;
|
|
|
|
|
import com.mudu.base.domain.AjaxResult;
|
|
|
|
|
import com.mudu.entity.*;
|
|
|
|
|
import com.mudu.entity.ACheckQuatzEntity;
|
|
|
|
|
import com.mudu.entity.ACheckQuatzZichaEntity;
|
|
|
|
|
import com.mudu.entity.ASafeQyjcxx;
|
|
|
|
|
import com.mudu.entity.ASafeRwfj;
|
|
|
|
|
import com.mudu.entity.ASafeRwzq;
|
|
|
|
|
import com.mudu.entity.ASafeXcrw;
|
|
|
|
|
import com.mudu.entity.ASafeXcrwjcx;
|
|
|
|
|
import com.mudu.entity.ASafeXcrwjcxzgxx;
|
|
|
|
|
import com.mudu.entity.ASafeXcrwwz;
|
|
|
|
|
import com.mudu.entity.ASafeYhzgxx;
|
|
|
|
|
import com.mudu.entity.ASafeZcrw;
|
|
|
|
|
import com.mudu.entity.ASafeZcrwjl;
|
|
|
|
|
import com.mudu.entity.ASafeZcrwwz;
|
|
|
|
|
import com.mudu.entity.SzsASafeZcyhxx;
|
|
|
|
|
import com.mudu.entity.dto.request.ACheckQuatzRequest;
|
|
|
|
|
import com.mudu.entity.dto.request.ACheckQuatzZichaRequest;
|
|
|
|
|
import com.mudu.entity.dto.response.ACheckXcTpResponse;
|
|
|
|
|
import com.mudu.entity.dto.response.RwzqUuidResponse;
|
|
|
|
|
import com.mudu.service.*;
|
|
|
|
|
import com.mudu.service.ASafeQyjcxxService;
|
|
|
|
|
import com.mudu.service.ASafeRwfjService;
|
|
|
|
|
import com.mudu.service.ASafeRwzqService;
|
|
|
|
|
import com.mudu.service.ASafeXcrwService;
|
|
|
|
|
import com.mudu.service.ASafeXcrwjcxService;
|
|
|
|
|
import com.mudu.service.ASafeXcrwjcxzgxxService;
|
|
|
|
|
import com.mudu.service.ASafeXcrwwzService;
|
|
|
|
|
import com.mudu.service.ASafeYhzgxxService;
|
|
|
|
|
import com.mudu.service.ASafeZcrwService;
|
|
|
|
|
import com.mudu.service.ASafeZcrwjlService;
|
|
|
|
|
import com.mudu.service.ASafeZcrwwzService;
|
|
|
|
|
import com.mudu.service.SzsASafeZcyhxxService;
|
|
|
|
|
import org.springframework.beans.factory.annotation.Value;
|
|
|
|
|
import org.springframework.context.annotation.Configuration;
|
|
|
|
|
import org.springframework.scheduling.annotation.EnableScheduling;
|
|
|
|
|
@ -25,8 +48,6 @@ import java.util.Date;
|
|
|
|
|
import java.util.List;
|
|
|
|
|
import java.util.UUID;
|
|
|
|
|
|
|
|
|
|
import static com.mudu.base.domain.AjaxResult.success;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* @author dong
|
|
|
|
|
* @since 2024/3/12 16:37
|
|
|
|
|
@ -109,21 +130,21 @@ public class AcheckTaskQuartz {
|
|
|
|
|
|
|
|
|
|
@Value("${xczqUrl}")
|
|
|
|
|
private String xczqUrl;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* 新增创建时间为昨天且处于审批通过的工单数据
|
|
|
|
|
*
|
|
|
|
|
* @Param qymc 企业名称
|
|
|
|
|
*/
|
|
|
|
|
// @Scheduled(cron = "0 0 4 * * ? ")
|
|
|
|
|
|
|
|
|
|
@Scheduled(cron = "0 0/5 * * * ?")
|
|
|
|
|
// @PostMapping("/insert")
|
|
|
|
|
// @ApiOperation(value = "新增创建时间为昨天且处于审批通过的工单数据")
|
|
|
|
|
public AjaxResult selectAll() throws ParseException {
|
|
|
|
|
public void selectAll() throws ParseException {
|
|
|
|
|
// todo 查询巡查任务主表2月是否有记录就不推
|
|
|
|
|
Integer xcrwNum = aSafeXcrwService.xcrwNum();
|
|
|
|
|
if (xcrwNum > 0) {
|
|
|
|
|
throw new IllegalArgumentException("已存在数据");
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
//巡查任务周期id
|
|
|
|
|
RwzqUuidResponse rwzqUuidResponse = aSafeRwzqService.getXcUuid();
|
|
|
|
|
@ -132,11 +153,11 @@ public class AcheckTaskQuartz {
|
|
|
|
|
JSONObject jsonResponseList = JSON.parseObject(responseList);
|
|
|
|
|
String dataList = jsonResponseList.getString("data");
|
|
|
|
|
if (StrUtil.isEmpty(dataList)) {
|
|
|
|
|
return null;
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
List<ACheckQuatzRequest> list = JSON.parseArray(dataList, ACheckQuatzRequest.class);
|
|
|
|
|
if (CollectionUtil.isEmpty(list)) {
|
|
|
|
|
return null;
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
for (ACheckQuatzRequest a : list) {
|
|
|
|
|
//获取企业编号
|
|
|
|
|
@ -219,8 +240,6 @@ public class AcheckTaskQuartz {
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return success();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
@ -582,16 +601,16 @@ public class AcheckTaskQuartz {
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// @Scheduled(cron = "0 0 4 * * ? ")
|
|
|
|
|
@Scheduled(cron = "0 0/5 * * * ?")
|
|
|
|
|
// @Scheduled(cron = "0 0 4 * * ? ")
|
|
|
|
|
@Scheduled(cron = "0 0/5 * * * ?")
|
|
|
|
|
//@Scheduled(cron = "0 58 18 * * ?")
|
|
|
|
|
// @PostMapping("/zicha")
|
|
|
|
|
// @ApiOperation(value = "自查")
|
|
|
|
|
public AjaxResult zicha() throws ParseException {
|
|
|
|
|
public void zicha() throws ParseException {
|
|
|
|
|
// todo 查询自查任务主表本月是否有记录 有就不推
|
|
|
|
|
Integer zcrwNum = aSafeZcrwService.zcrwNum();
|
|
|
|
|
if (zcrwNum > 0) {
|
|
|
|
|
throw new IllegalArgumentException("已存在数据");
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
//自己查任务周期id
|
|
|
|
|
RwzqUuidResponse rwzqUuidResponse = aSafeRwzqService.getZcUuid();
|
|
|
|
|
@ -600,11 +619,11 @@ public class AcheckTaskQuartz {
|
|
|
|
|
JSONObject jsonResponseList = JSON.parseObject(responseList);
|
|
|
|
|
String dataList = jsonResponseList.getString("data");
|
|
|
|
|
if (StrUtil.isEmpty(dataList)) {
|
|
|
|
|
return null;
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
List<ACheckQuatzZichaRequest> list = JSON.parseArray(dataList, ACheckQuatzZichaRequest.class);
|
|
|
|
|
if (CollectionUtil.isEmpty(list)) {
|
|
|
|
|
return null;
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
for (ACheckQuatzZichaRequest a : list) {
|
|
|
|
|
JSONObject zcjsonObject = new JSONObject();
|
|
|
|
|
@ -666,7 +685,6 @@ public class AcheckTaskQuartz {
|
|
|
|
|
saveZihaYhzgxx(list, a, b, yhzgxxUuid, zcrwUuid, rwzqUuid, zcrwUuid);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
return success();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
|
