package com.j1.mai.action;import java.io.BufferedReader;import java.io.DataOutputStream;import java.io.IOException;import java.io.InputStream;import java.io.InputStreamReader;import java.net.HttpURLConnection;import java.net.URL;import java.util.HashMap;import java.util.Iterator;import java.util.Map;import javax.servlet.http.HttpServletRequest;import javax.servlet.http.HttpServletResponse;import net.sf.json.JSONObject;import org.apache.log4j.Logger;import org.springframework.context.annotation.Scope;import org.springframework.stereotype.Controller;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RequestParam;import org.springframework.web.bind.annotation.ResponseBody;import com.alibaba.fastjson.JSON;import com.alibaba.fastjson.JSONArray;import com.j1.base.type.MsgStatus;import com.j1.mai.model.common.SoaApiBaseAction;import com.j1.mai.util.PropertyConfigurer;import com.j1.soa.common.DateUtils;import com.j1.soa.common.Md5Util;@Controller@Scope("request")@RequestMapping("/storeConsumptionLogin")public class StoreLoginAction extends SoaApiBaseAction {// final static String url ="http://localhost:8080/httpServer/c_i/common_i";    static Logger LOG = Logger.getLogger(StoreLoginAction.class);    @RequestMapping("/login")        public  Object loginStoreConsumption(            HttpServletRequest request,            HttpServletResponse response,            @RequestParam(value = "empName", required = true) String empName,// 用户名            @RequestParam(value = "http://www.mamicode.com/loginPassWd", required = true) String loginPassWd// 密码    ) {        /**         * 调用接口         */        Map<String, Object> mapRes = new HashMap<String, Object>();        // 读取配置文件         String promoteUrl =(String)PropertyConfigurer.getString("storeConsumptiondLoginUrl");        String message = null;        JSONObject jsonObject = null;        message = httpSend(promoteUrl, empName, loginPassWd);        try {                        // 解析json字符串                message = message.replaceAll("\\\\", "");                String jsonStr = message.substring(message.indexOf("[") + 1,                        message.indexOf("]"));                jsonObject = JSONObject.fromObject(jsonStr);                String responseCode = jsonObject.getString("msg");                            if (responseCode.equals("用户名或密码错误")) {                    mapRes.put("status", 1);                    mapRes.put("msg", "loginFalse");                } else {                    mapRes.put("status", 0);                    mapRes.put("msg", "ok");                            }        } catch (Exception e) {                        e.printStackTrace();        } finally {            /**             *将操作的个人信息存在Session中,传给前台             *以便于在前台在录入会员的时候传递到后台             */            //操作人名称            String empNameAdd=jsonObject.getString("empName");            //操作门店名称            String deptNameAdd=jsonObject.getString("deptName");            //门店编码            String deptNo=jsonObject.getString("deptNo");            //登录名            String loginName=jsonObject.getString("loginName");            //操作人ID            String empId=jsonObject.getString("empId");            request.getSession().setAttribute("empNameAdd", empNameAdd);            request.getSession().setAttribute("deptNameAdd", deptNameAdd);            request.getSession().setAttribute("deptNo",deptNo );            request.getSession().setAttribute("empId", empId);            request.getSession().setAttribute("loginName", loginName);//            this.write(request, response);                    }                 JSON o=(JSON) com.alibaba.fastjson.JSONObject.toJSON(mapRes);        System.out.println("查看=============="+o);        return com.alibaba.fastjson.JSONObject.toJSON(mapRes);                             }    /**     * 发送HTTP请求     *     * @param url     * @param propsMap     *            发送的参数     */    public String httpSend(String promoteUrl, String empName, String loginPassWd) {        StringBuffer buffer = new StringBuffer();        String responseContent = null;        try {            URL url_new = new URL(promoteUrl);// 创建连接            HttpURLConnection connection = (HttpURLConnection) url_new                    .openConnection();            connection.setDoOutput(true);            connection.setDoInput(true);            connection.setRequestMethod("POST");            connection.setUseCaches(false);            connection.setInstanceFollowRedirects(true);            connection.setRequestProperty("Accept", "application/json"); // 设置接收数据的格式            connection.setRequestProperty("Content-Type", "application/json"); // 设置发送数据的格式            connection.connect();            // POST请求            DataOutputStream out = new DataOutputStream(                    connection.getOutputStream()); // utf-8编码 ;            String sign = null;            String time = DateUtils.longToDateAll(System.currentTimeMillis());            String token = "91A1643059824847938125BA0AC0F557"; // token 不产于传送            String format = "json"; // 传送方式            String method = "queryTbl_Employee";// 调用方法            String sessionKey = "123456789078945";// sessionkey            String up_date = time;// 上传日期 yyyy-mm-dd            String version = "1.0.2";// 版本号            try {                sign = Md5Util.Bit32(format + method + sessionKey + token                        + up_date + version);            } catch (Exception e1) {                e1.printStackTrace();            }            JSONObject obj = new JSONObject();            obj.element("sessionKey", sessionKey);            obj.element("method", method);            obj.element("format", format);            obj.element("up_Date", time);            obj.element("sign", sign);            obj.element("version", version);            JSONObject objbusinessdate = new JSONObject();            objbusinessdate.element("username", empName);// username ,            objbusinessdate.element("password", loginPassWd); // password            obj.element("businessData", objbusinessdate);            System.out.println(obj.toString());            out.writeBytes(obj.toString());            out.flush();            // 读取响应            int length = (int) connection.getContentLength();// 获取长度            System.out.println("length:" + length);                         if (connection.getResponseCode() != HttpURLConnection.HTTP_OK) {                   System.out.println("网络错误异常！!!!");               }            InputStream in = connection.getInputStream();            BufferedReader rds = new BufferedReader(new InputStreamReader(in,                    "UTF-8"));            String tempLine = rds.readLine();            StringBuffer tempStr = new StringBuffer();            if (tempLine != null) {                tempStr.append(tempLine);                tempLine = rds.readLine();            }            responseContent = tempStr.toString();            // BufferedReader rd = new BufferedReader(new InputStreamReader(            // connection.getInputStream(), "UTF-8"));            // while( (responseMsg = rd.readLine())!=null){            // buffer.append(responseMsg);            //            // }            out.close();            rds.close();            connection.disconnect();            System.out.println("  Buffer============= " + buffer.toString());            return responseContent;        } catch (IOException e) {            e.printStackTrace();        }        // return buffer.toString(); // 自定义错误信息        return responseContent; // 自定义错误信息    }}