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.PersonObtainEvidenceService;
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 RyBackupQuartzJob extends BaseController{
	@Autowired
	private PersonObtainEvidenceService personobtainevidenceService;

	@Autowired
	private SMSManagementService smsmanagementService;

	@Autowired
	private UsersService usersService;
	@Autowired
	private CorpInfoService corpInfoService;

	@Autowired
	private MSMLoginService msmloginService;

	@Scheduled(cron ="0 0 12 * * ?")
	//	@Scheduled(cron ="0 */1 * * * ?")
    public void scheduled(){
		System.out.println("进来了");
		try {
			System.out.println( "============定时查询人员证件到期==========");
			PageData pd = new PageData();
			try {
				List<PageData> qList =personobtainevidenceService.listAll(pd);
				for(PageData q:qList) {
					long a=DateUtil.getDaySub(DateUtil.getDay(),q.getString("EXPIRATIONDATE"));
					PageData corpinfo=corpInfoService.findById(q);
					PageData lpd = new PageData();
					lpd.put("STATE", "OK");
					lpd.put("CORPINFO_ID", pd.getString("CORPINFO_ID"));
				    int usedCount = msmloginService.msUsedCount(lpd);
					if(a==90) {
						q.put("ISNEAREXPIRATION", "1");
						personobtainevidenceService.edit(q);
						if(corpinfo.getString("ISRECEIVE").equals("1")&&Integer.parseInt(corpinfo.getString("SMS_COUNT"))-usedCount>0) {
								Map<String,Object> mes = new HashMap<String,Object>();
//								String code=getCode();
								mes.put("phone", q.getString("REMINDPEOPLEPHONE"));
								mes.put("templateCode", "SMS_215795793");
								mes.put("pname", q.getString("PERSONNAME"));
								mes.put("qname", q.getString("CERTIFICATENAME"));
								mes.put("month", "三");
								mes.put("time", q.getString("EXPIRATIONDATE"));
								mes.put("type", "4");
//								mes.put("code", code);
								SendSmsResponse ssms= AliSmsUtil.sendSms(mes);
								msmloginService.addForAliSmsUtil(mes, corpinfo.getString("CORPINFO_ID"), ssms);
								//System.out.println(ssms.getCode());
								PageData sms = new PageData();
								sms.put("CORPINFO_ID",  corpinfo.getString("CORPINFO_ID"));
								sms.put("ISENABLE",  "1");
								sms.put("SMSTYPE",  "SMS_215795793");
								List<PageData>	sList =smsmanagementService.listAll(sms);
								if(sList.size()>0) {
										String[] uid=sList.get(0).getString("ADDRESSEE").split(",");
										for(int i=0;i<uid.length;i++) {
											PageData suser = new PageData();
											suser.put("USER_ID", uid[i].toString());
											suser = usersService.findById(suser);
											if(suser.get("USERNAME") != null && Tools.notEmpty(suser.get("USERNAME").toString())) {
												String uphone=suser.get("USERNAME").toString();
												Map<String,Object> umes = new HashMap<String,Object>();
												umes.put("phone", uphone);
												umes.put("templateCode", "SMS_215795793");
												umes.put("pname", corpinfo.getString("PERSONNAME"));
												umes.put("qname", q.getString("CERTIFICATENAME"));
												umes.put("month", "三");
												umes.put("time", q.getString("EXPIRATIONDATE"));
												umes.put("type", "4");
												PageData ewpd = new PageData();
												ewpd.put("STATE", "OK");
												ewpd.put("CORPINFO_ID", pd.getString("CORPINFO_ID"));
											    int ewusedCount = msmloginService.msUsedCount(lpd);
											    if(Integer.parseInt(corpinfo.getString("SMS_COUNT"))-ewusedCount>0) {
												SendSmsResponse ussms= AliSmsUtil.sendSms(umes);
												msmloginService.addForAliSmsUtil(umes, corpinfo.getString("CORPINFO_ID"), ussms);
											    }
											}
											
											}
									}
						}
						
					}else if(a==30){
						if(corpinfo.getString("ISRECEIVE").equals("1")&&Integer.parseInt(corpinfo.getString("SMS_COUNT"))-usedCount>0) {
								Map<String,Object> mes = new HashMap<String,Object>();
//								String code=getCode();
								mes.put("phone", q.getString("REMINDPEOPLEPHONE"));
								mes.put("templateCode", "SMS_215795793");
								mes.put("pname", q.getString("PERSONNAME"));
								mes.put("qname", q.getString("CERTIFICATENAME"));
								mes.put("month", "一");
								mes.put("time", q.getString("EXPIRATIONDATE"));
								mes.put("type", "4");
								SendSmsResponse ssms= AliSmsUtil.sendSms(mes);
								msmloginService.addForAliSmsUtil(mes, corpinfo.getString("CORPINFO_ID"), ssms);
								//System.out.println(ssms.getCode());
								PageData sms = new PageData();
								sms.put("CORPINFO_ID",  corpinfo.getString("CORPINFO_ID"));
								sms.put("ISENABLE",  "1");
								sms.put("SMSTYPE",  "SMS_215795793");
								List<PageData>	sList =smsmanagementService.listAll(sms);
								if(sList.size()>0) {
										String[] uid=sList.get(0).getString("ADDRESSEE").split(",");
										for(int i=0;i<uid.length;i++) {
											PageData suser = new PageData();
											suser.put("USER_ID", uid[i].toString());
											suser = usersService.findById(suser);
											if(suser.get("USERNAME") != null && Tools.notEmpty(suser.get("USERNAME").toString())) {
												String uphone=suser.get("USERNAME").toString();
												Map<String,Object> umes = new HashMap<String,Object>();
												umes.put("phone", uphone);
												umes.put("templateCode", "SMS_215795793");
												umes.put("pname", corpinfo.getString("PERSONNAME"));
												umes.put("qname", q.getString("CERTIFICATENAME"));
												umes.put("month", "一");
												umes.put("time", q.getString("EXPIRATIONDATE"));
												umes.put("type", "4");
												PageData ewpd = new PageData();
												ewpd.put("STATE", "OK");
												ewpd.put("CORPINFO_ID", pd.getString("CORPINFO_ID"));
											    int ewusedCount = msmloginService.msUsedCount(lpd);
											    if(Integer.parseInt(corpinfo.getString("SMS_COUNT"))-ewusedCount>0) {
												SendSmsResponse ussms= AliSmsUtil.sendSms(umes);
												msmloginService.addForAliSmsUtil(umes, corpinfo.getString("CORPINFO_ID"), ussms);
											    }
											}
											
											}
									}
						}
					}else if(a==15){
						if(corpinfo.getString("ISRECEIVE").equals("1")&&Integer.parseInt(corpinfo.getString("SMS_COUNT"))-usedCount>0) {
								Map<String,Object> mes = new HashMap<String,Object>();
//								String code=getCode();
								mes.put("phone", q.getString("REMINDPEOPLEPHONE"));
								mes.put("templateCode", "SMS_215795793");
								mes.put("pname", q.getString("PERSONNAME"));
								mes.put("qname", q.getString("CERTIFICATENAME"));
								mes.put("month","半");
								mes.put("time", q.getString("EXPIRATIONDATE"));
								mes.put("type", "4");
//								mes.put("code", code);
								SendSmsResponse ssms= AliSmsUtil.sendSms(mes);
								msmloginService.addForAliSmsUtil(mes, corpinfo.getString("CORPINFO_ID"), ssms);
								//System.out.println(ssms.getCode());
								PageData sms = new PageData();
								sms.put("CORPINFO_ID",  corpinfo.getString("CORPINFO_ID"));
								sms.put("ISENABLE",  "1");
								sms.put("SMSTYPE",  "SMS_215795793");
								List<PageData>	sList =smsmanagementService.listAll(sms);
								if(sList.size()>0) {
										String[] uid=sList.get(0).getString("ADDRESSEE").split(",");
										for(int i=0;i<uid.length;i++) {
											PageData suser = new PageData();
											suser.put("USER_ID", uid[i].toString());
											suser = usersService.findById(suser);
											if(suser.get("USERNAME") != null && Tools.notEmpty(suser.get("USERNAME").toString())) {
												String uphone=suser.get("USERNAME").toString();
												Map<String,Object> umes = new HashMap<String,Object>();
												umes.put("phone", uphone);
												umes.put("templateCode", "SMS_215795793");
												umes.put("pname", q.getString("PERSONNAME"));
												umes.put("qname", q.getString("CERTIFICATENAME"));
												umes.put("month", "半");
												umes.put("time", q.getString("EXPIRATIONDATE"));
												umes.put("type", "4");
												PageData ewpd = new PageData();
												ewpd.put("STATE", "OK");
												ewpd.put("CORPINFO_ID", pd.getString("CORPINFO_ID"));
											    int ewusedCount = msmloginService.msUsedCount(lpd);
											    if(Integer.parseInt(corpinfo.getString("SMS_COUNT"))-ewusedCount>0) {
												SendSmsResponse ussms= AliSmsUtil.sendSms(umes);
												msmloginService.addForAliSmsUtil(umes, corpinfo.getString("CORPINFO_ID"), ussms);
											    }
											}
											
											}
									}
						}
					}
				}
				
			} catch (Exception e) {
				try {
					//shutdownJob(context,pd,parameter);
				} catch (Exception e1) {
					e1.printStackTrace();
				}
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
    }
	
	
}