actitve-process/.svn/pristine/26/268cf177cbf90d927fc8c7a90c36717f86fd3fe6.svn-base

package com.chinacreator.process.job;

import java.net.URLEncoder;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.apache.log4j.Logger;
import org.quartz.DisallowConcurrentExecution;
import org.quartz.PersistJobDataAfterExecution;
import org.springframework.beans.factory.annotation.Autowired;

import com.chinacreator.common.util.DESUtil;
import com.chinacreator.common.util.URLUtil;
import com.chinacreator.process.bean.SmsSendBean;
import com.chinacreator.process.dao.SmsSendDao;
import com.chinacreator.process.util.JsonUtil;

@PersistJobDataAfterExecution
@DisallowConcurrentExecution
public class VIPSmsSendJob {
	
	private Logger log = Logger.getLogger("smslog");

	@Autowired
	private SmsSendDao smsSendDao;

	public void doProcess() throws Exception {
		System.out.println("VIPSmsSendJob开始启动");
		List<SmsSendBean> list = null;
		list = smsSendDao.selectVipSms();
		if (list != null) {
			Map<String, String> map = null;
			for (SmsSendBean smsSendBean : list) {
				map = new HashMap<String, String>();
				//map.put("content", "尊敬的联通用户：您好！您订购的WO+腾讯定向流量包月视频风暴产品中，本月腾讯视频会员尚未领取，请开启腾讯视频app进行激活、领取，有效期至本月月底。本月腾讯视频会员领取教程：http://v.wo.cn/44IhAt");
				String resultcode = "0";
				String errorinfo = "";
				try {
					map.put("userid", smsSendBean.getUserid());
					map.put("channel","vipsms");
					String url = "http://114.255.201.228:86/videoif/channelSmsSend.do";
					url = addUlrPar(url,"userid",URLEncoder.encode(DESUtil.encode(map.get("userid"),"idfdse33"),"UTF-8"));
					url = addUlrPar(url,"apptype","2");
					url = addUlrPar(url,"channel",map.get("channel"));
					url = addUlrPar(url,"content",map.get("content"));
					String result = URLUtil.get(url,15000);
					Map<?, ?> inMap = JsonUtil.jsonToMap(result);
					resultcode = (String) inMap.get("resultCode");
					errorinfo = (String) inMap.get("errorInfo");
				} catch (Exception e) {
					e.printStackTrace();
					resultcode = "8000";
					errorinfo = "系统错误";
				} finally {
					map.put("resultcode", resultcode);
					map.put("errorinfo", errorinfo);
					smsSendDao.updateVipSms(smsSendBean.getId(),resultcode.equals("0") ? "1" : "2");
					log.info(JsonUtil.objectToJson(map));
				}
			}
		}
	}
	
	public static String addUlrPar(String url, String key,String value){
		if (value == null)
			return url;
		if (url.indexOf("?") == -1) {
			url += "?";
		} else {
			url += "&";
		}
		return url + key + "=" + value;
	}
	
	public static void main(String[] args) throws Exception { 
		System.out.println(DESUtil.encode("18511774220", "idfdse33"));
	}
}