youxiw2000 / trash · Files

package com.trash.quartz.task;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;

import javax.swing.Spring;

import org.springframework.beans.BeansException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.multipart.MultipartFile;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.google.gson.Gson;
import com.google.gson.JsonObject;
import com.google.gson.reflect.TypeToken;
import com.trash.activiti.service.IActTaskService;
import com.trash.business.domain.CompanyCredit;
import com.trash.business.domain.DriverCredit;
import com.trash.business.domain.SupervisionTrack;
import com.trash.business.domain.TruckCredit;
import com.trash.business.mapper.CompanyCreditMapper;
import com.trash.business.service.ICompanyCreditService;
import com.trash.business.service.IDriverCreditService;
import com.trash.business.service.ISupervisionThreestepService;
import com.trash.business.service.ISupervisionTrackService;
import com.trash.business.service.ITruckActivateService;
import com.trash.business.service.ITruckCreditService;
import com.trash.caseOffline.domain.CaseOffline;
import com.trash.caseOffline.mapper.CaseOfflineMapper;
import com.trash.casefile.domain.KafkaCompensation;
import com.trash.casefile.domain.ReplyApprovalProcess;
import com.trash.casefile.domain.ViolationCaseFile;
import com.trash.casefile.kafka.Consumer;
import com.trash.casefile.mapper.KafkaCompensationMapper;
import com.trash.casefile.mapper.ReplyApprovalProcessMapper;
import com.trash.casefile.mapper.ViolationCaseFileMapper;
import com.trash.casefile.service.IViolationCaseFileService;
import com.trash.common.config.trashConfig;
import com.trash.common.core.redis.RedisCache;
import com.trash.common.utils.LogUtils;
import com.trash.common.utils.RemoteServerUtils;
import com.trash.common.utils.SecurityUtils;
import com.trash.common.utils.file.FileUploadUtils;
import com.trash.common.utils.spring.SpringUtils;
import com.trash.common.utils.util.PostSms;
import com.trash.common.utils.vo.mt.JsonSmsSend;
import com.trash.common.utils.vo.mt.Mobile;
import com.trash.office.domain.LogisticsManagement;
import com.trash.office.domain.UploadFile;
import com.trash.office.mapper.LogisticsManagementMapper;
import com.trash.office.mapper.UploadFileMapper;
import com.trash.workflow.service.IWorkflowService;

/**
 * 定时任务调度测试
 * 
 * @author trash
 */
@Component("DriverTask")
public class DriverTask {

	String TOKEN;

	SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
	/** 系统基础配置 */
	@Autowired
	private trashConfig trashConfig;

	@Autowired
	private RedisCache redisCache;

	public void getUpCase() {
		JSONArray array = RemoteServerUtils.getCaseList();
		Map map = new HashMap<>();
		List<String> ids = new ArrayList<String>();

		if (array != null && array.size() > 0) {
			for (Object object : array) {
				JSONObject json = (JSONObject) object;
				try {
					ViolationCaseFile caseFile = new ViolationCaseFile(json);

					for (Object fileObj : json.getJSONArray("attchList")) {

						JSONObject fileJSON = (JSONObject) fileObj;
						UploadFile uploadFile = new UploadFile();
						uploadFile.setTableName("violation_case_file");
						uploadFile.setTableNumber(caseFile.getId().toString());
						uploadFile.setFileName(fileJSON.getString("attchFileName"));
						uploadFile.setFilePath(fileJSON.getString("attchFilePath"));

						SpringUtils.getBean(UploadFileMapper.class).insertUploadFile(uploadFile);
					}

					SpringUtils.getBean(ViolationCaseFileMapper.class).insertViolationCaseFile(caseFile);

					ids.add(caseFile.getId());

				} catch (BeansException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}

			}

			map.put("taskIds", ids);
			map.put("taskType", "Q2");
			RemoteServerUtils.updateUpCase(map);
		}

	}

	public void getUpCaseState() {

		getCaseStateIntoDB("/api/thirdApi/query/urgeList", "urgeUser", "urgeDesc", "urgeTime", "Q5");

		getCaseStateIntoDB("/api/thirdApi/query/superviseList", "supUser", "supDesc", "supTime", "Q4");

		JSONArray array = RemoteServerUtils.getUpCaseResult();
		Map map = new HashMap<>();
		List<String> ids = new ArrayList<String>();

		if (array != null && array.size() > 0) {
			for (Object object : array) {
				JSONObject json = (JSONObject) object;

				ViolationCaseFile casefile = SpringUtils.getBean(ViolationCaseFileMapper.class)
						.selectViolationCaseFileById(json.getString("thirdCaseId"));

				if (casefile == null) {
					continue;
				} else {

					Date d = new Date(json.getString("reportTime"));

					ids.add(json.getString("acceptId"));

					ReplyApprovalProcess rap = new ReplyApprovalProcess();
					rap.setTableName("workflow_casefile:" + json.getString("thirdCaseId"));
					rap.setReplyPeople("综管服");
					rap.setReply(json.getString("replyContent"));
					rap.setReplyTime(new Date(json.getString("handleTime")));

					JSONArray images = json.getJSONArray("attchList");
					String path = "";
					try {
						for (Object obj : images) {
							JSONObject img = (JSONObject) obj;
							path += img.getString("attchFilePath") + ",";
						}
					} catch (Exception e) {
						e.printStackTrace();
					}
					rap.setReplyImg(path.substring(0, path.length() - 1));
				}
			}

			map.put("taskIds", ids);
			map.put("taskType", "Q1");
			RemoteServerUtils.updateUpCase(map);
		}

	}

	private void getCaseStateIntoDB(String url, String arg0, String arg1, String arg2, String type) {
		try {

			JSONArray array = RemoteServerUtils.getUpCaseState(url);
			Map map = new HashMap<>();
			List<String> ids = new ArrayList<String>();

			if (array != null && array.size() > 0) {
				SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
				for (Object object : array) {
					JSONObject json = (JSONObject) object;

					ViolationCaseFile caseFile = new ViolationCaseFile();

					caseFile.setNumber(json.getString("evtId"));

					List<ViolationCaseFile> list = SpringUtils.getBean(ViolationCaseFileMapper.class)
							.selectViolationCaseFileList(caseFile);

					if (list.size() == 0) {
						continue;
					}

					ReplyApprovalProcess rap = new ReplyApprovalProcess();
					rap.setTableName("workflow_casefile:" + list.get(0).getId());
					rap.setReplyPeople(json.getString(arg0));
					rap.setReply(json.getString(arg1));
					try {
						rap.setReplyTime(sdf.parse(json.getString(arg2)));
					} catch (ParseException e) {

						rap.setReplyTime(new Date());

						e.printStackTrace();
					}

					SpringUtils.getBean(ReplyApprovalProcessMapper.class).insertReplyApprovalProcess(rap);

					ids.add(json.getString("taskId"));
				}

				map.put("taskIds", ids);
				map.put("taskType", type);
				RemoteServerUtils.updateUpCase(map);
			}

		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	Map<String, String> paramsMap = new HashMap<String, String>();

	public void createTrackData() {

		File file = new File("./settings.txt");

		String params = "2 1 10 2 1 10 2 1 10 2 1 10 2 1 10 2 1 10 2 1 10 2 1 10";

		if (!file.exists()) {
			try {
				file.createNewFile();

				FileOutputStream fos = new FileOutputStream(file);

				fos.write(params.getBytes());
				fos.flush();

				fos.close();

			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		} else {
			try {
				FileInputStream fis = new FileInputStream(file);

				byte[] bs = new byte[fis.available()];

				fis.read(bs);

				params = new String(bs);

			} catch (Exception e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}

		}

		String[] arr = params.split(" ");

		for (int i = 0; i < 8; i++) {
			paramsMap.put("type_" + i + "_timeout", arr[i * 3]);
			paramsMap.put("type_" + i + "_season", arr[i * 3 + 1]);
			paramsMap.put("type_" + i + "_pect", arr[i * 3 + 2]);
		}

		JSONArray areas = redisCache.getCacheObject("areaList");
		Map<String, String> area = new HashMap<>();

		for (Object object : areas) {
			JSONObject json = (JSONObject) object;
			area.put(json.getString("code"), json.getString("name"));
		}

		try {

			int type = 5;
			LogisticsManagement logisticsManagement = new LogisticsManagement();

			Date d = new Date();

			d.setMonth(d.getMonth() - (Integer.parseInt(paramsMap.get("type_" + type + "_season")) * 3));
			d.setDate(0);
			d.setHours(23);
			d.setMinutes(59);
			d.setSeconds(59);

			logisticsManagement.setCreateTime(d);

			List<LogisticsManagement> logs = SpringUtils.getBean(LogisticsManagementMapper.class)
					.selectLogisticsManagementList(logisticsManagement);

			Collections.shuffle(logs);

			double pect = Double.parseDouble(paramsMap.get("type_" + type + "_pect")) / 100;

			logs = logs.subList(0, (int) (logs.size() * pect));

			for (LogisticsManagement l : logs) {

				String title = (l.getType().equals("0") ? "用章申请" : l.getType().equals("1") ? "物品申请" : "采购申请");

				insertData(l.getId() + "", title, type, "综合管理部", l.getDeptName());
			}

		} catch (Exception e) {
			e.printStackTrace();
		}

		try {

			int type = 6;
			CaseOffline caseOffline = new CaseOffline();

			Date d = new Date();

			d.setMonth(d.getMonth() - (Integer.parseInt(paramsMap.get("type_" + type + "_season")) * 3));
			d.setDate(0);
			d.setHours(23);
			d.setMinutes(59);
			d.setSeconds(59);

			caseOffline.setCreateTime(d);

			List<CaseOffline> logs = SpringUtils.getBean(CaseOfflineMapper.class).selectCaseOfflineList(caseOffline);

			Collections.shuffle(logs);

			double pect = Double.parseDouble(paramsMap.get("type_" + type + "_pect")) / 100;

			logs = logs.subList(0, (int) (logs.size() * pect));

			for (CaseOffline l : logs) {
				insertData(l.getId() + "", "电子交办案卷:" + l.getSiteName(), type, "治理事务部", area.get(l.getPlace()));
			}

		} catch (Exception e) {
			e.printStackTrace();
		}

		try {

			int type = 7;
			ViolationCaseFile caseOffline = new ViolationCaseFile();

			Date d = new Date();

			d.setMonth(d.getMonth() - (Integer.parseInt(paramsMap.get("type_" + type + "_season")) * 3));
			d.setDate(0);
			d.setHours(23);
			d.setMinutes(59);
			d.setSeconds(59);

			caseOffline.setCreateTime(d);

			List<ViolationCaseFile> logs = SpringUtils.getBean(ViolationCaseFileMapper.class)
					.selectViolationCaseFileList(caseOffline);

			Collections.shuffle(logs);

			double pect = Double.parseDouble(paramsMap.get("type_" + type + "_pect")) / 100;

			logs = logs.subList(0, (int) (logs.size() * pect));

			for (ViolationCaseFile l : logs) {
				insertData(l.getId() + "", "违规案卷:" + l.getProjectName(), type, "科技信息部", l.getOwningRegion());
			}

		} catch (Exception e) {
			e.printStackTrace();
		}

		Gson g = new Gson();

		JSONArray array;

		array = redisCache.getCacheObject("truckList");// 车辆
		if (array != null && array.size() > 0) {

			int type = 4;

			List<JSONObject> list = ShuffleData(g, array, type);

			for (JSONObject json : list) {
				try {
					insertData(json.getString("id"), json.getString("licenseplateNo"), type, "行业事务部",
							json.getString("areaName"));
				} catch (Exception e) {
					e.printStackTrace();
				}
			}

		}

		array = redisCache.getCacheObject("contractList");// 合同
		if (array != null && array.size() > 0) {

			int type = 3;

			List<JSONObject> list = ShuffleData(g, array, type);

			for (JSONObject json : list) {

				try {
					insertData(json.getString("id"), json.getString("constructionSiteName"), type, "综合管理部",
							area.get(json.getString("earthSiteAreaCode")));
				} catch (Exception e) {
					e.printStackTrace();
				}
			}

		}

		array = redisCache.getCacheObject("companyList");// 公司
		if (array != null && array.size() > 0) {
			int type = 2;

			List<JSONObject> list = ShuffleData(g, array, type);

			for (JSONObject json : list) {
				try {
					insertData(json.getString("id"), json.getString("name"), type, "行业事务部",
							area.get(json.getString("areaCode")));
				} catch (Exception e) {
					e.printStackTrace();
				}
			}

		}

		array = redisCache.getCacheObject("constructionList");// 工地

		if (array != null && array.size() > 0) {

			int type = 0;

			List<JSONObject> list = ShuffleData(g, array, type);

			for (JSONObject json : list) {
				try {
					insertData(json.getString("id"), json.getString("name"), type, "勘察事务部",
							area.get(json.getString("areaCode").split("\\.")[0]));
				} catch (Exception e) {
					e.printStackTrace();
				}

			}
		}

		array = redisCache.getCacheObject("earthSitesList"); // 消纳场

		if (array != null && array.size() > 0) {

			int type = 1;

			List<JSONObject> list = ShuffleData(g, array, type);

			for (JSONObject json : list) {
				try {
					insertData(json.getString("id"), json.getString("name"), type, "消纳事务部",
							area.get(json.getString("areaCode")));
				} catch (Exception e) {
					e.printStackTrace();
				}
			}
		}

	}

	public List ShuffleData(Gson g, JSONArray array, int type) {
		List<JSONObject> list = g.fromJson(array.toJSONString(), new TypeToken<List<JSONObject>>() {
		}.getType());

		Date d = new Date();

		d.setMonth(d.getMonth() - (Integer.parseInt(paramsMap.get("type_" + type + "_season")) * 3));
		d.setDate(0);
		d.setHours(23);
		d.setMinutes(59);
		d.setSeconds(59);

		try {
			list = list.parallelStream().filter(p -> {

				SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
				String editTime = p.getString("editedAt");
				String createdTime = p.getString("createdAt");
				long newTime = 0;
				try {
					if (editTime == null) {
						if (createdTime == null) {
							return false;
						} else {
							newTime = simpleDateFormat.parse(p.getString("createdAt")).getTime();
						}
					} else {
						newTime = simpleDateFormat.parse(p.getString("editedAt")).getTime();
					}
				} catch (Exception e) {
					e.printStackTrace();
				}
				return d.getTime() < newTime;

			}).collect(Collectors.toList());
		} catch (Exception e) {
			e.printStackTrace();
		}

		Collections.shuffle(list);

		double pect = Double.parseDouble(paramsMap.get("type_" + type + "_pect")) / 100;

		list = list.subList(0, (int) (list.size() * pect));

		return list;
	}

	public void insertData(String id, String name, int type, String dept, String place) {
		try {
			SupervisionTrack track = new SupervisionTrack();
			track.setObjectId(id);
			track.setTitle(name);
			track.setType(type);
			track.setCreateTime(new Date());
			track.setCreateBy("长沙市建筑垃圾智慧监管平台");
			track.setDept(dept);
			track.setPlace(place);
			SpringUtils.getBean(ISupervisionTrackService.class).insertSupervisionTrack(track);

		} catch (Exception e) {
			e.printStackTrace();
		}

	}

	public void checkCredit() {

		if (RemoteServerUtils.remote == null) {
			RemoteServerUtils.remote = trashConfig.getRemotePath();
		}
		if (TOKEN == null) {
			TOKEN = trashConfig.getToken();
		}

		LogUtils.getBlock("=================== checkCredit 定时器执行 当前时间:      " + simpleDateFormat.format(new Date()));

		try {
			checkTruckActive();
		} catch (Exception e) {
			e.printStackTrace();
		}

	}

	@SuppressWarnings("deprecation")
	private void checkTruckActive() {
		if (TOKEN == null) {
			TOKEN = trashConfig.getToken();
		}
		try {
			SpringUtils.getBean(ISupervisionThreestepService.class).checkDataToActiveTruck(TOKEN);
		} catch (Exception e) {
			// TODO: handle exception
		}

	}

	private void checkDriverCredit() {

		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
		if (RemoteServerUtils.remote == null) {
			RemoteServerUtils.remote = trashConfig.getRemotePath();
		}
		if (TOKEN == null) {
			TOKEN = trashConfig.getToken();
		}

		JSONArray drivers = RemoteServerUtils.getDriverList(TOKEN);

		for (Object object : drivers) {

			JSONObject json = (JSONObject) object;

			try {
				if (sdf.parse(json.getString("endAt")).getTime() < sdf.parse(sdf.format(new Date())).getTime()
						|| sdf.parse(json.getString("qualificationCertValidEndAt")).getTime() < sdf
								.parse(sdf.format(new Date())).getTime()) {
					DriverCredit driver = new DriverCredit();

					driver.setIdNumber(json.getString("identityNo"));
					driver.setName(json.getString("name"));
					driver.setCreateBy("长沙市建筑垃圾智慧监管平台");
					driver.setReason("证件过期");
					driver.setTime(new Date());
					driver.setStatus(0L);
					driver.setObjectId(json.getString("id"));

					SpringUtils.getBean(IDriverCreditService.class).insertDriverCredit(driver);
				}
			} catch (Exception e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}

		}

	}

	@SuppressWarnings({ "unchecked", "rawtypes" })
	private void checkTruckCredit() {

		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
		Map map = new HashMap<>();
		map.put("size", 9999);
		map.put("valid", 0);
		map.put("page", 1);

		JSONArray trucks = RemoteServerUtils.getTruckList(map, TOKEN);

		List<Map> listParam = new ArrayList<Map>();

		if (trucks != null) {
			for (Object jsonObject : trucks) {
				JSONObject truck = (JSONObject) jsonObject;

				try {
					if (sdf.parse(truck.getString("transportCertValid")).getTime() < sdf.parse(sdf.format(new Date()))
							.getTime()
							|| sdf.parse(truck.getString("licenseValid")).getTime() < sdf.parse(sdf.format(new Date()))
									.getTime()) {

						TruckCredit truckCredit = new TruckCredit();
						truckCredit.setTime(new Date());
						truckCredit.setCreateBy("长沙市建筑垃圾智慧监管平台");
						truckCredit.setReason("道路运输证有效期:" + truck.getString("transportCertValid") + " 行驶证有效期:"
								+ truck.getString("licenseValid") + ",证件过期");
						truckCredit.setLostCredit(1L);
						truckCredit.setObjectId(truck.getString("id"));
						truckCredit.setLicensePlate(truck.getString("licenseplateNo"));
						truckCredit.setCompanyId(truck.getString("companyName"));
						truckCredit.setStatus(0L);

						Map param = new HashMap<>();

						param.put("id", truck.getString("id"));
						param.put("creditStatus", 1);

						listParam.add(param);

						SpringUtils.getBean(ITruckCreditService.class).insertTruckCredit(truckCredit, 0);
					}
				} catch (BeansException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				} catch (ParseException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				} catch (Exception e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}

			if (listParam.size() > 0)
				RemoteServerUtils.updateTruckList(listParam, TOKEN);

		}

	}

	public void checkCompanyCredit() {
		try {
			checkTruckCredit();
		} catch (Exception e) {
			e.printStackTrace();
		}

		try {
			checkDriverCredit(); // 检查驾驶员信用
		} catch (Exception e) {
			e.printStackTrace();
		}

		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");

		Map map = new HashMap<>();
		map.put("size", 9999);
		map.put("page", 1);

		JSONArray companys = RemoteServerUtils.getCompanyList(map, TOKEN);
		if (companys != null) {
			for (Object jsonObject : companys) {
				JSONObject company = (JSONObject) jsonObject;
				try {
					if (sdf.parse(company.getString("registrationValidTime")).getTime() < sdf
							.parse(sdf.format(new Date())).getTime()
							|| sdf.parse(company.getString("businessLicenseValidTime")).getTime() < sdf
									.parse(sdf.format(new Date())).getTime()) {
						CompanyCredit companyCredit = new CompanyCredit();
						companyCredit.setTime(new Date());
						companyCredit.setCreateBy("长沙市建筑垃圾智慧监管平台");
						companyCredit.setReason("企业道路运输经营许可证有效期:" + company.getString("businessLicenseValidTime")
								+ " 企业营业执照有效期:" + company.getString("registrationValidTime") + ",证件过期");
						companyCredit.setLostCredit(1L);
						companyCredit.setObjectId(company.getString("id"));
						companyCredit.setName(company.getString("name"));
						companyCredit.setPlace(company.getString("areaName"));
						companyCredit.setStatus(0L);
						SpringUtils.getBean(ICompanyCreditService.class).insertCompanyCredit(companyCredit, TOKEN);
					}
				} catch (Exception e) {
					e.printStackTrace();
				}

			}
		}

		CompanyCredit companyCredit = new CompanyCredit();
		companyCredit.setLostCredit(1L);
		companyCredit.setStatus(0L);

		List<CompanyCredit> companyList = SpringUtils.getBean(CompanyCreditMapper.class)
				.selectCompanyCreditList(companyCredit);

		for (CompanyCredit c : companyList) {
			SpringUtils.getBean(ICompanyCreditService.class).updateRemoteCompanyAndTruck(c, TOKEN);
		}

		try {
			checkToSendSMS(); // 检查驾驶员信用
		} catch (Exception e) {
			e.printStackTrace();
		}

	}

	private void checkToSendSMS() {
		if (RemoteServerUtils.remote == null) {
			RemoteServerUtils.remote = trashConfig.getRemotePath();
		}
		
		
		Map<String, Object> map = new HashMap<>();
		map.put("size", 99999);
		map.put("page", 1);
		JSONArray cList = redisCache.getCacheObject("constructionList");
		if(cList == null){
			cList = RemoteServerUtils.getConstructionList(map, trashConfig.getToken());
			redisCache.setCacheObject("constructionList", cList,60,TimeUnit.MINUTES);
		}
		
		JSONArray eList = redisCache.getCacheObject("earthSitesList");
		if(eList == null){
			eList = RemoteServerUtils.getEarthSitesList(map, trashConfig.getToken());
			redisCache.setCacheObject("earthSitesList", cList,60,TimeUnit.MINUTES);
		}

		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
		long now = 0;
		try {
			now = sdf.parse(sdf.format(new Date())).getTime();
		} catch (ParseException e1) {
			// TODO Auto-generated catch block
			e1.printStackTrace();
		}
		
		if(cList != null){
			for(Object obj:cList){
				try{
					
				JSONObject json = (JSONObject) obj;
				long endTime = 0;
				try {
					now = sdf.parse(sdf.format(new Date())).getTime();
					endTime = sdf.parse(json.getString("effectiveEnd")).getTime();
				} catch (ParseException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				
				// 1 * 60 分 60  时 24
				
				if((endTime - now) == 15*1000*60*60*24){
					List<Mobile> mobileList = new ArrayList<>();
						

//						String p = json.getString("constructionCompanyPhone");
//			            if(p != null){
//							Mobile mobile=new Mobile();
//				            mobile.setMobile(p);
//				            mobileList.add(mobile);
//			            }
//					
//						String p1 = json.getString("projectnCompanyPhone");
//			            if(p1 != null){
//			            	Mobile mobile2=new Mobile();
//				            mobile2.setMobile(p1);
//				            mobileList.add(mobile2);
//			            }

	            	Mobile mobile2=new Mobile();
		            mobile2.setMobile("19520553054");
		            mobileList.add(mobile2);
					
			            String smsString = "【长沙渣管】到期提醒："+json.getString("name")+"将于"+json.getString("effectiveEnd")+"到期（截止日），请在到期日前及时办理相关手续。";
							
							JsonSmsSend jsonSmsSend= PostSms.sendSms(mobileList,smsString);
				            if(jsonSmsSend!=null){
				                if(jsonSmsSend.getState()==0){
				                	System.out.println("发送成功");
				                }else{
				                	System.out.println(jsonSmsSend.getMessage());
				                }
				            }else{
				            	System.out.println("发送返回空");
				            }
				}
				
				
				} catch (Exception e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
			
		}

		if(eList != null){
			for(Object obj:eList){
				try{
					
				
				JSONObject json = (JSONObject) obj;
				long endTime = 0;
				try {
					endTime = sdf.parse(json.getString("effectiveEnd")).getTime();
				} catch (ParseException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				if((endTime - now) == 15*1000*60*60*24){
					List<Mobile> mobileList = new ArrayList<>();
						String p = json.getString("principalPhoneNo");
			            if(p != null){
//							Mobile mobile=new Mobile();
//				            mobile.setMobile(p);
//				            mobileList.add(mobile);
				            
			            	Mobile mobile2=new Mobile();
				            mobile2.setMobile("19520553054");
				            mobileList.add(mobile2);
				            
				            String smsString = "【长沙渣管】到期提醒："+json.getString("name")+"将于"+json.getString("effectiveEnd")+"到期（截止日），请在到期日前及时办理相关手续。";
							
							JsonSmsSend jsonSmsSend= PostSms.sendSms(mobileList,smsString);
				            if(jsonSmsSend!=null){
				                if(jsonSmsSend.getState()==0){
				                	System.out.println("发送成功");
				                }else{
				                	System.out.println(jsonSmsSend.getMessage());
				                }
				            }else{
				            	System.out.println("发送返回空");
				            }
			            }
				}
				
				
				
			}catch(Exception e){
				e.printStackTrace();
			}
			}
		}
		
		
		
	}

	public void checkAllTask() {
		LogUtils.getBlock("===================  删除超时报工数据     定时器执行 当前时间:      " + simpleDateFormat.format(new Date()));

		if (TOKEN == null) {
			TOKEN = trashConfig.getToken();
		}
		try {
			SpringUtils.getBean(ISupervisionThreestepService.class).updateTodayData(TOKEN);
		} catch (Exception e) {
			e.printStackTrace();
		}
		try {
			SpringUtils.getBean(IActTaskService.class).endAllThreesteptask("workflow_threestep");
		} catch (Exception e) {
			e.printStackTrace();
		}
		try {
			SpringUtils.getBean(IWorkflowService.class).deleteWorkflowByName("workflow_threestep");
		} catch (Exception e) {
			e.printStackTrace();
		}
		try {
			SpringUtils.getBean(ITruckActivateService.class).endAllTruckUnActive();
		} catch (Exception e) {
			e.printStackTrace();
		}

	}

	/**
	 * kafka补偿机制，每半小时一次
	 * 
	 * @throws InterruptedException
	 */
	public void kafkaCompensation() throws InterruptedException, IOException {
		KafkaCompensation kafkaCompensation = new KafkaCompensation();
		kafkaCompensation.setStatus(0);
		List<KafkaCompensation> kafkaCompensationList = SpringUtils.getBean(KafkaCompensationMapper.class)
				.selectKafkaCompensationList(kafkaCompensation);
		for (KafkaCompensation k : kafkaCompensationList) {
			SpringUtils.getBean(Consumer.class).autoViolationWarning(k.getData(), k.getId().toString());
		}
	}

	/**
	 * 每分钟更新一次公司列表
	 */
	public void getCompanyList() {
		if (RemoteServerUtils.remote == null) {
			RemoteServerUtils.remote = trashConfig.getRemotePath();
		}
		Map<String, Object> map = new HashMap<>();
		map.put("size", 99999);
		map.put("page", 1);
		JSONArray jsonArray = RemoteServerUtils.getCompanyList(map, trashConfig.getToken());
		if (jsonArray != null) {
			redisCache.setCacheObject("companyList", jsonArray, 60, TimeUnit.MINUTES);
		}
	}

	public void getContractList() {
		if (RemoteServerUtils.remote == null) {
			RemoteServerUtils.remote = trashConfig.getRemotePath();
		}
		Map<String, Object> map = new HashMap<>();
		map.put("size", 99999);
		map.put("page", 1);
		map.put("contractStatus", 1);
		map.put("auditStatus", 1);
		JSONArray jsonArray = RemoteServerUtils.getContractList(map, trashConfig.getToken());
		if (jsonArray != null) {
			redisCache.setCacheObject("contractList", jsonArray, 60, TimeUnit.MINUTES);
		}
	}

	/**
	 * 每分钟更新一次工地列表
	 */
	public void getConstructionList() {
		if (RemoteServerUtils.remote == null) {
			RemoteServerUtils.remote = trashConfig.getRemotePath();
		}
		Map<String, Object> map = new HashMap<>();
		map.put("size", 99999);
		map.put("page", 1);
		JSONArray jsonArray = RemoteServerUtils.getConstructionList(map, trashConfig.getToken());
		if (jsonArray != null) {
			redisCache.setCacheObject("constructionList", jsonArray, 60, TimeUnit.MINUTES);
		}
	}

	/**
	 * 每分钟更新一次消纳场列表
	 */
	public void getEarthSitesList() {
		if (RemoteServerUtils.remote == null) {
			RemoteServerUtils.remote = trashConfig.getRemotePath();
		}
		Map<String, Object> map = new HashMap<>();
		map.put("size", 99999);
		map.put("page", 1);
		JSONArray jsonArray = RemoteServerUtils.getEarthSitesList(map, trashConfig.getToken());
		if (jsonArray != null) {
			redisCache.setCacheObject("earthSitesList", jsonArray, 60, TimeUnit.MINUTES);
		}
	}

	/**
	 * 每分钟更新一次区域列表
	 */
	public void getTruckList() {
		if (RemoteServerUtils.remote == null) {
			RemoteServerUtils.remote = trashConfig.getRemotePath();
		}
		Map<String, Object> map = new HashMap<>();
		map.put("size", 99999);
		map.put("valid", 0);
		map.put("page", 1);

		JSONArray jsonArray = RemoteServerUtils.getTruckList(map, trashConfig.getToken());
		if (jsonArray != null) {
			redisCache.setCacheObject("truckList", jsonArray, 60, TimeUnit.MINUTES);
		}
	}

	/**
	 * 每分钟更新一次区域列表
	 */
	public void getAreaList() {
		if (RemoteServerUtils.remote == null) {
			RemoteServerUtils.remote = trashConfig.getRemotePath();
		}
		Map<String, Object> map = new HashMap<>();
		map.put("size", 99999);
		map.put("page", 1);
		JSONArray jsonArray = RemoteServerUtils.getAreas(trashConfig.getToken());
		if (jsonArray != null) {
			redisCache.setCacheObject("areaList", jsonArray, 60, TimeUnit.MINUTES);
		}
	}
}