package com.zcloud.util;

import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.quartz.Job;
import org.quartz.JobDataMap;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import com.aliyuncs.dysmsapi.model.v20170525.SendSmsResponse;
import com.zcloud.controller.base.BaseController;
import com.zcloud.entity.PageData;
import com.zcloud.service.bus.CorpInfoService;
import com.zcloud.service.bus.MSMLoginService;
import com.zcloud.service.bus.QualificationsService;
import com.zcloud.service.bus.SMSManagementService;
import com.zcloud.service.fhdb.BRdbService;
import com.zcloud.service.system.UsersService;
import com.zcloud.util.AliSmsUtil;
import com.zcloud.util.DateUtil;
import com.zcloud.util.DbFH;
import com.zcloud.util.FileUtil;
import com.zcloud.util.SpringUtil;
import com.zcloud.util.Tools;


@Configuration      //1.主要用于标记配置类，兼备Component的效果。
public class DxtxQuartzJob extends BaseController{
	@Autowired
	private QualificationsService qualificationsService;

	@Autowired
	private SMSManagementService smsmanagementService;

	@Autowired
	private UsersService usersService;
	@Autowired
	private CorpInfoService corpInfoService;
	@Autowired
	private MSMLoginService msmloginService;
	
	@Scheduled(cron ="0 0 12 * * ?")
	//	@Scheduled(cron ="0 */5 * * * ?")
    public void scheduled(){
		System.out.println("进来了");
		try {
			System.out.println( "============定时查询企业证件到期==========");
			PageData pd = new PageData();
			try {
				pd.put("ISRECEIVE", "1");
				List<PageData> qList =corpInfoService.listAll(pd);
				for(PageData q:qList) {
					if(!q.getString("ISREMIND").equals("1")) {
					PageData lpd = new PageData();
					lpd.put("STATE", "OK");
					lpd.put("CORPINFO_ID", q.getString("CORPINFO_ID"));
					List<PageData>	lList =msmloginService.listAll(lpd);
					if(Integer.parseInt(q.getString("SMS_COUNT"))-lList.size()>1000) {
						Map<String,Object> mes = new HashMap<String,Object>();
//						String code=getCode();
						mes.put("phone", q.getString("CHECKPERSONPHONE"));
						mes.put("templateCode", "SMS_215820680");
						mes.put("qname", q.getString("CORP_NAME"));
						mes.put("type", "6");
//						mes.put("code", code);
						SendSmsResponse ssms= AliSmsUtil.sendSms(mes);
						msmloginService.addForAliSmsUtil(mes, "系统通知", ssms);
						PageData cpd = new PageData();
						cpd.put("ISREMIND", "1");
						cpd.put("CORPINFO_ID", q.getString("CORPINFO_ID"));
						corpInfoService.editISRemind(cpd);
					}
					}
					
				}
			} catch (Exception e) {
				try {
					//shutdownJob(context,pd,parameter);
				} catch (Exception e1) {
					e1.printStackTrace();
				}
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
    }
	
	
}