项目开发笔记-传单下发 名片替换 文件复制上传/html静态内容替换/json解析/html解析

//////////////////////////// 注意: 此博客是个人工作笔记 非独立demo//////////////////////////////////

........................................................................................................................................................................................................................

业务介绍:

          最近搞的新系统有一个传单发放的功能,因为要赶着新系统先上线使用,所以老大说先使用老系统的代码,就是先写个接口调用支撑一下 下面是新系统调用老系统接口的方法
URL json(gson) html(jsoup)文件 及 IO流的使用

下面首先是http远程调用的方法  先称之为工具类

public String postTelentService(String urlStr,String urlParameter) throws IOException{
    //java.net.URL 主要用于基于Internet的网络通信编程
    URL url = new URL(urlStr);//URL的构造方法
    //参数是值 请求的URL连接的地址(就是url)  字符串类型的
    HttpURLConnection urlcon = (HttpURLConnection)url.openConnection();//打开这个url连接  此方法声明抛出IO异常  返回值是URLConnection类型的 连接对象
    //我们强制转型为他的一个实现类:HttpURLConnection
    urlcon.setDoOutput(true);//设置是否向connection输出
    //因为我们是个post类型的请求  参数要放在http正文当中,所以我们要设置成true
    urlcon.setDoInput(true);// read from the connection.Defult is true 
    urlcon.setRequestMethod("POST");//设置http请求的方法 默认是GET方式

    urlcon.setUseCaches(false);//POST请求不能使用缓存
    urlcon.setInstanceFollowRedirects(true);//前者设置所有的http连接是否自动处理重定向


    urlcon.setRequestProperty("Content-Type","application/x-www-form-urlencoded");//配置本次连接的Content-type,配置为application/x-www-form-urlencoded的意思是 正文是urlencoded编码过的form参数 下面我们可以看到我们对正文内容使用URLEncoder.encode 进行编码
    /*google大神解释: 
     * 这个是告诉服务器 你的客户端的配置/需求
     比如说你要取某个文件的多少字节到多少字节就通过这个东西告诉服务器
     你的客户端支持压缩，也可以告诉服务器 服务器会压缩传输
     你的客户端支持什么编码 也可以告诉服务器 服务器会尽量按照你的编码传递数据
     还有比如你的客户端是什么类型，IE，FIrefox之类，有的服务器会按照你的客户端类型给你传送文本
     你啥都不告诉 服务器就按缺省配置传递内容给你的客户端
     */
/**  还有注意点: 
 *          1 连接,从openConnection()至此的相关配置设定 必须在connect()之前完成!
 *          2 connection.getOutputStream会隐含的进行connect()方法
 */
    urlcon.connect();//配置完后  (规定好格式的传输对象? 打开对象的连接?)
    
    DataOutputStream out = new DataOutputStream(urlcon.getOutputStream());//获取 当前连接对象的输出流  然后包装成数据流
    
    String content = urlParameter;//post方法的http请求正文起始跟 url中?后的参数字符串一致
    out.writeBytes(content);//byte=8bit 以bate的形式讲内容写到向外的流内  
    out.flush();//强行刷入内存
    out.close();//关闭输出流

    InputStream is = urlcon.getInputStream();//为了获取结果的 输入流  原始流
    BufferedReader buffer = new BufferedReader(new InputStreamReader(is));//包装成字符输出流  再转换成字节输出流
    StringBuffer bs = new StringBuffer();
    String l = null;
    while((l=buffer.readLine())!=null){  //读取一行  如果不为空则 in √ 
    bs.append(l).append("/n");//换行
    }
    String str1 = bs.toString();// 将Stringbuffer转换成字符串
    str1 = new String(str1.getBytes("GBK"),"UTF-8");//gbk转成utf-8
    String str2 = str1.subString(0,str1.length()-2);//获取字符串 截取后面最后一位
    return str2;
}

好了  方法封装完毕  io流有些日子没写过  生疏了不少  下面是调用方法的时候的代码 简单的写写

String assUserIds = RequestUtil.getStringParam(request, "assUserIds");
String urlStr="http://"+ Config.getMkpUrl()+"/marketa/remotePassFlyers.do";   //  调用其他系统的方法  基于http调用   路径配置
//        urlStr+="?userId="+userId+"&maId="+maId+"&flyerId="+flyerId+"&userIds="+userIds+"&assUserIds="+assUserIds;
String urlParameter="userId="+userId+"&maId="+maId+"&flyerId="+flyerId+"&userIds="+userIds+"&assUserIds="+assUserIds;
//  userId=8665&maId=1015&flyerId=38273&userIds=8665,8687,8688
String result = null;
    inviteAllUsers(request);
try {
    result = this.postTelentService(urlStr,urlParameter);//路径和参数传递 请求
} catch (IOException e) {
    e.printStackTrace();
}

//---------------------------------------------------------------------------------------------------------------------------------------------------------

好了新系统的 调用方法撰写完毕 

//=============================================================================================//
新系统用的springMVC spring MyBatis
老系统相信通过那个url路径就能看出以前用的是struts
又因为老系统已经上线了几年了 老员工告诉我尽量不要动他们写好的代码 直接调用或者自己重写一个 到时候更新.class文件就行了
//============================================================================================//
分析业务逻辑 及 需求分析
涉及到两个表 第一个表 d_flyer是传单对应表 里面存放的有 传单的id 复制的谁的模板 更新时间 所属人和活动 等等
d_flyer_detail 里面存放了 对应的个人内容==
老系统传单模块分析: 首先由 主管 创建一个活动 然后为此活动创建一个相应的推广的传单
传单: 一个静态的html文件 里面有需要展示的内容 :
1 名片 ./

-------------------------------------
2 反馈表 用于采集有意向的用户的信息
当 主管 创建完成后 传单的名片(如果此电子传单有名片)内部是主管的相关的信息 然后 主管 邀请 组织内部人员参加此活动 并为人员下发此传单 因为主管点击邀请后 被邀请人需要登录账号 进入软件后接受邀请 然后主管才能给其发送传单 而且这样太繁琐

因为下发传单也涉及到了传单的复制(即 主管传单的静态html文件要复制一份给当前的用户) 他复制的地址一直是在老系统中 所以说只能让老系统提供给新系统一个调用接口 来进行调用

新系统对应需求是: 勾选相应的人员 给他们发送传单 跳过了邀请接受的繁琐

即:批量发送功能

//~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

由url的http请求内容(即参数)我们看出 调用老系统的参数有:
"userId=" userId //当前账号的id
"&maId=" maId //当前活动的id
"&flyerId=" flyerId //当前活动绑定传单的id
"&userIds=" userIds //被邀请人的id s 多个
"&assUserIds=" assUserIds //其他被邀请人的id s
//
//下面是老系统写的接口:
//刚才已经说了 老系统是拿struts spring 和JdbcTemplate写的
//本人并不知道jdbcTemplate的原理 但是感觉应该就是一个数据库框架 没有时间研究它了 同事也说已经过时很久了 不是主流了 只能先放着
//其他的不说了 struts是action了 接口如下:

public class Action{
    /**
     * 这个方法是给另一个系统调用的
     *   传递过来的参数分析:                              业务分析:
     *                  1 userId 当前登录的用户的id              有一个单独的人(主管)专门做传单 传单完成后进行下发
     *                                                              所以说他就是在做传单的模板
     *                  2 maId 指的是当前活动的id                下发传单实际上是对现有(某个活动某个用户)模板传单进行复制
     *                                                              在表d_flyer中
     *                                                              进行了赋值  穿但是的user_id字段赋以接受传单人的id
     *                  3 flyerId 指的是传单id       它现在写的应该是错误的(但是有个逻辑就是 一个活动只有一个原本的传单模板)
     *                  4 userIds 指的是下发到的目标用户  本来是个数组 后来传过来的时候是用了 toString()方法
     *                  5 assUserIds  已经废弃
     * 远程下发传单
     * @return
     */
    public String remotePassFlyers(){
        //远程调用的参数示例为:  userId=8665&maId=1015&flyerId=38273&userIds=8665,8687,8688&assUserIds=
        System.out.println("This is in:Action.remotePassFlyers() ; 
 " +
                "---wunian7yulian testing...-----The var is: null , And The value is: " + "--flag1--" + "      	 ---------");
        Integer userId = Integer.parseInt(this.getRequest().getParameter("userId"));
        Integer maId = Integer.parseInt(this.getRequest().getParameter("maId"));
        Integer flyerId = Integer.parseInt(this.getRequest().getParameter("flyerId"));

        String userIds = this.getRequest().getParameter("userIds");
        String assUserIds = this.getRequest().getParameter("assUserIds");

        if(isBlank(maId) || isBlank(flyerId)){  //如果没有活动参数或者传单参数
            return "ERROR INPUT PARAM";
        }
        //................................................主要方法.......................
        this.getMarketaService().passFlyerToUsers(userId, maId, flyerId, userIds, assUserIds);//spring注入的service层实例对象
        return SUCCESS;
//        return maId+";"+flyerId+";"+userIds+";"+assUserIds;
    }

    private boolean isBlank(Integer i){
        boolean flag = true;
        if(null!=i && 0!=i){
            flag = false;
        }
        return flag;
    }
}
//=======================================================================================================

下面是service层的代码  有详细清楚的的注释:  

//==============================================================service层=====================================================================
public class MarketaService extends BaseService{
    /**
     *     =====================================远程action层调用此方法发送传单==================================================================
     */
    ///远程调用的参数为:  userId=8665&maId=1015&flyerId=38273&userIds=8665,8687,8688&assUserIds=
    /**  服务层对接控制层  调用数据层
     *   对接 action中的 远程下发传单 方法  remotePassFlyers ()
     * 下发活动传单
     * @param userId   当前用户的id
     * @param maId     当前活动的id
     * @param flyerId  传单的id
     * @param userIds  目标用户的id
     * @param assUserIds --null
     * @return ProcResult --> 专门用于存放(封装)返回值的工具bean类
     */
    public ProcResult passFlyerToUsers(Integer userId, Integer maId, Integer flyerId, String userIds, String assUserIds){
        /**辅助方法清单 方法一*/
        List<Map<String, Object>> users = getInvitedUserInfos(maId, flyerId, userIds, assUserIds);//获取用户的信息对应传单id 没有传单id的为null 就是指没有收到过传单
        //里面都有 --- 用户id  和创建用户组织的id  和 传单id
        if(null != users && !users.isEmpty()){//非空才进去  (只要userIds有值就行)
            //声明两个list集合 分别用于存放:
            List<Integer> hasSharedList = new ArrayList<Integer>();//已经被分享了的成员
            List<Integer> notSharedList = new ArrayList<Integer>();//还没有被分享的成员   id的集合

            for(int i=0; i<users.size(); i++){
                Map<String, Object> user = users.get(i);  //每个用户遍历出来 取出来的个体对象都是一个map  
                                                                            //map的entity是[列名:值]的方式
                                                                            //   String : Object
                                                                            //例{"user_id":8875,"id":9999}
                Integer inviteUserId = Integer.parseInt(user.get("user_id").toString()) ;//用户的id 
                boolean isShared = user.get("id")!=null;// 传单id  传单id不为空则说明已经有了  就是已经复制了模板
                if(isShared){ //已经分享了的 用户id ~s
                    hasSharedList.add(inviteUserId);
                } else { //还没有传单的 用户的id ~s
                    notSharedList.add(inviteUserId);//没有分享的用户的id
                }
            }
            System.out.println("This is in:com.chanjet.mkp.marketa.MarketaService.passFlyerToUsers() ; 
 " +
                    "---wunian testing...-----The var is: 已经分享的:没有分享的 , And The value is: " + hasSharedList.size() +"//"+ notSharedList.size() + "      	 ---------");
            //上面是对 已派发过的和未派发过的进行了 !!!分类!!!  整理到了两个list里面
            /* ***************************************************************华丽丽的分割线***************************************************/
            /* ***************************************************************华丽丽的分割线***************************************************/
            /* ***************************************************************华丽丽的分割线***************************************************/

            //对所有已经派发过的批量修改
            if(!hasSharedList.isEmpty()){//已经派发的   hasSharedList 数组里面保存的是 已经有的传单的user_id  ~s
                /**辅助方法清单:方法二*/
                List<Map<String, Object>> sharedFlyers = getSharedFlyerDetaiInfo(maId, flyerId);// 所有在活动下父传单为模板传单的 子传单的详细信息   询已经共享的传单的user_id
                Integer[] sharedFlyerArray = new Integer[sharedFlyers.size()];//查看一共有多少个已经派送了的传单  以多少作为长度 声明一个Integer类型的数组
                for(int i=0; i<sharedFlyers.size(); i++){  //循环遍历出相关的子传单的详细信息来
                    Map<String, Object> flyer = sharedFlyers.get(i);
                    Integer sFlyerId = (Integer) flyer.get("flyer_id");//传单的id
                    sharedFlyerArray[i] = sFlyerId;//这样把现有的传单的id 放在一个数组里面 叫做sharedFlyerArray
                }
                /**辅助方法清单:方法三*/
                String sharedUserIds = castArrayToString(hasSharedList.toArray());//把已经分享的用户(list集合)弄出来  转换成数组  变成字符串 被分享的用户的id ~s 
                String sharedFlyerIds = castArrayToString(sharedFlyerArray); // 把现有的传单的id的数组转换成一个字符串
                //  对应的传单的id ~s

                 /**辅助方法清单:方法四*/
                String updateFlyerSql = getPassFlyerSql(1).replace("{user_ids}", sharedUserIds); //肯定是sql的in用
                //更新了 已经被分享的用户的id的所有需要更新的相关信息的sql语句
                //
                String updateDlyerDetailSql = getPassFlyerSql(3).replace("{flyer_ids}", sharedFlyerIds);//  same
                //更新 已经被分享用户的传单的 详细表(子表)的相关详细信息的sql语句

                Object[] flyerParam = new Object[]{flyerId, maId, flyerId};
                Object[] flyerDetailParam = new Object[]{flyerId};
                this.getDao().update(updateFlyerSql, flyerParam);//更新 d_flyer表
                this.getDao().update(updateDlyerDetailSql, flyerDetailParam); // 更新了他的子表
            }
//~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
            //对所有未发送过的批量添加    没有什么传单的  
            if(!notSharedList.isEmpty()){ //   没有发送过的 就是d_flyer 所属人 缺少穿过来的那些  的
                /**辅助方法清单:方法三*/
                String notSharedUserIds = castArrayToString(notSharedList.toArray());
                /**辅助方法清单:方法四*/
                String addFlyerSql = getPassFlyerSql(5);// 多行插入 d_flyer 语句(复制传单语句)
                addFlyerSql = addFlyerSql.replace("{parent_id}",flyerId+"").replace("{user_ids}", notSharedUserIds);
                //填充数据 批量复制传单语句   最后一个parent_id字段要写上模板(父传单的id值 )的id值
                Object[] addFlyerParams = new Object[]{flyerId,userId};
                this.getDao().update(addFlyerSql, addFlyerParams);
                /**辅助方法清单:方法四*/
                List<Map<String, Object>> newAddFlyerList = getSharedFlyerInfoByUserIds(maId, flyerId, castArrayToString(notSharedList.toArray()));//查询出刚刚分发出的传单的
                Object[] newAddFlyerIds = new Object[newAddFlyerList.size()]; //新增加的传单个数  声明一个数组
                for(int i=0; i<newAddFlyerList.size(); i++){ //
                    Map<String, Object> newF = newAddFlyerList.get(i);
                    newAddFlyerIds[i] = newF.get("flyer_id"); //新传单的id存放到数组里面   获得传单id 并放到数组中
                }
                /**辅助方法清单:方法三*/
                String newAddFIds = castArrayToString(newAddFlyerIds); //数组转换成字符串  去掉了空格
                /**辅助方法清单:方法四*/
                String addFlyerDetailSql = getPassFlyerSql(4).replace("{flyer_ids}", newAddFIds);// 插入对应的子表的数据
                Object[] addFlyerDetailParams = new Object[]{flyerId};
                this.getDao().update(addFlyerDetailSql, addFlyerDetailParams);//因为关联到了子表
            }
            //~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~相对应的数据库的所有表的查询 更新操作结束!!!~~~~~~~~~~~
            //获取 所有属于此活动的 父传单id为flyerId的 所有复制版本员工传单
            // 返回数据字段有:
            //              用户的id 传单id 用户对应组织id 传单详细信息表的内容 发布后的内容 
            //                  邮箱 电话 qq 微信 名称 职位
            /**辅助方法清单:方法二*/
            List<Map<String, Object>> allSharedFlyers = getSharedFlyerDetaiInfo(maId, flyerId);//插入完成后再次重新获取所有相关的传单
            //重新上传html文件
            try {
                /**辅助方法清单:方法六*/
                refreshNameCard(allSharedFlyers); //更新传单名片信息(数据库中的content字段的更新)
                //重新生成静态html页面
                Integer orgId=0;
                /**辅助方法清单:方法十一 */
                uploadShareFlyerHtmlFile(maId, flyerId, userId, orgId, allSharedFlyers);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        return ProcResult.success();
    }

    /**
     *     =====================================辅助方法清单:方法一==================================================================
     *     返回值为 此活动 模板传单是相应传单模板的 未删除 的且user_id 在参数里面的所有满足条件的 用户id 传单id
     *     即 在此活动被邀请 且有传单的所有人   
     *     传入的userIds作为了左表!!!!!  (9876有无对应的fid都会有一条对应  生成 9876 null)
     */
    private List<Map<String, Object>> getInvitedUserInfos(Integer maId, Integer flyerId, String userIds, String assUserIds){
        String sql = "select " +
                " u.user_id as user_id,f.id as id " +  //用户id  和创建用户组织的id  和 传单id
                " from m_user u " +
                " left join d_flyer f " +
                "    on u.user_id = f.user_id " +
                "       and f.ma_id=? " +   //  所属活动限定
                "       and f.parent_id=? " +    //这填充的是 传单模板(父传单)的id值  这样就又是一个小型的无线分类  知道了模板的来源
                "       and f.deleted = 0" +   // 删除 ? 否限定
                " where (u.user_id in ({userIds}) ) and del = 0 ";//  用户限定  穿过来的用户
        /**
         * select u.user_id as user_id,f.id as id 
         * from m_user u 
         * left join d_flyer f on u.user_id = f.user_id And f.ma_id =? and parent_id=? and f.deleted =0
         * where (u.user_id in ({userIds}) ) and del =0;
         由此看出是preparedstatement  in 为什么用替换?   我试了一下用?  出错了
         */
        sql = sql.replace("{userIds}",userIds);//参数填充
        Object[] params = new Object[]{maId, flyerId}; //准备参数
        System.out.println(sql + "=========>");
        System.out.println(
                "==========
"+"maId:"+maId +"
 flyerId:"+flyerId +"
 userIds:" + userIds);
        List<Map<String, Object>> list = this.getDao().query(sql, params, null);// 
        System.out.println("查询列表长度为: "+ list.size() +"==="+list+ "      	 ---------");
        return list;
    }
    //==================================================================================================

    /**
     *     =====================================辅助方法清单:方法二==================================================================
     */
    private List<Map<String, Object>> getSharedFlyerDetaiInfo(Integer maId, Integer parentFlyerId){
        List<Map<String, Object>> list = null;
        String sql = "SELECT t.user_id, t.id AS flyer_id, t.orgid, d.content, d.updated_content," +
            " m.email, m.mobile, m.phone, m.qq, m.weixin, m.user_name as realname ,mou.position AS job " +
            " FROM d_flyer t" +
            " left join d_flyer_detail d on t.id=d.flyer_id" +
            " left join m_user m on t.user_id = m.user_id"+
            " left join m_org_user mou on mou.user_id = m.user_id and mou.dept_id !=0" +
            " WHERE t.parent_id = ? AND t.ma_id = ? AND t.deleted = 0";
/*
             SELECT ? FROM d_flyer t
             left join d_flyer_detail d on t.id=d.flyer_id
             left join m_user m on t.user_id = m.user_id
             left join m_org_user mou on mou.user_id = m.user_id and mou.dept_id !=0
             WHERE t.parent_id = ? AND t.ma_id = ? AND t.deleted = 0
*/
        list = this.getDao().query(sql, new Object[]{parentFlyerId, maId}, null);
        return list;
    }
 /**
     *     =====================================辅助方法清单:方法三==================================================================
     */
    /**
     * 把数组拼接成以","隔开的字符串
     * @param array
     * @return
     */
    private String castArrayToString(Object[] array){
        String str = "";
        if(null==array){
            return str;
        }
        switch (array.length){
            case 1:
                str = array[0].toString();
                break;
            default:
                for(int i=0; i<array.length; i++){
                    if(i==array.length-1){
                        str += array[array.length-1].toString();
                        break;
                    }
                    str += array[i].toString() + ",";
                }
        }
        return str;
    }

 /**
     *     =====================================辅助方法清单:方法四==================================================================
     */
    private String getPassFlyerSql(Integer type){
        String sql = "";
        switch (type) {
            case 1:  // updateFlyer
                sql = "UPDATE d_flyer t1, d_flyer t2 SET t1.title = t2.title," +
                        " t1.status = t2.status," +
                        " t1.create_time = NOW()," +
                        " t1.notice = t2.notice," +
                        " t1.template = t2.template," +
                        " t1.update_time = NOW()," +
                        " t1.description = t2.description," +
                        " t1.beau_sel = t2.beau_sel, " +
                        " t1.refer_count = t2.refer_count," +
                        " t1.refer_id = t2.refer_id," +
                        " t1.isdraw  = t2.isdraw," +
                        " t1.iscopy = t2.iscopy," +
                        " t1.is_marketa_enjoy = 0," +
                        " t1.showTitle = t2.showTitle," +
                        " t1.searchKeyword = t2.searchKeyword," +
                        " t1.music = t2.music," +
                        " t1.classify_id  = t2.classify_id," +
                        " t1.template_status = t2.template_status," +
                        " t1.option_id  = t2.option_id," +
                        " t1.approvedBy = t2.approvedBy," +
                        " t1.deleteReason = t2.deleteReason" +
                        " WHERE t1.user_id IN ({user_ids}) AND t1.parent_id= ? AND t1.ma_id= ? AND t2.id=?";
                break;
            case 2:// insertFlyer
                sql = "INSERT INTO d_flyer(title,status,create_time,notice,template,user_id,update_time,description,deleted,orgid,hit,notice_days,visitor_count,feedback_count,ishot,version,is_edit,is_add,beau_sel,ma_id,isorg,refer_count,refer_id,isdraw,iscopy,is_marketa_enjoy,showTitle,searchKeyword,music,classify_id,template_status,option_id,approvedBy,deleteReason,parent_id)" +
                        " SELECT t1.title,t1.status,NOW(),t1.notice,t1.template,t2.invite_user_id,NOW(),t1.description,0,t2.adscription_org,0,t1.notice_days,0,0,t1.ishot,2.00,t1.is_edit,t1.is_add,t1.beau_sel,t1.ma_id,t1.isorg,t1.refer_count,t1.refer_id,t1.isdraw,t1.iscopy,0,t1.showTitle,t1.searchKeyword,t1.music,t1.classify_id,t1.template_status,t1.option_id,t1.approvedBy,t1.deleteReason,{parent_id}" +
                        "   FROM d_flyer t1," +
                        "       (SELECT m.invite_user_id,m.adscription_org FROM m_market_invite_user m WHERE m.invite_user_id IN ({user_ids}) AND m.ma_id=?" +
                        "         {add_admin_user}) t2 " +
                        " WHERE t1.id=? AND t1.ma_id=? AND t1.deleted=0 AND t1.user_id=?";
                break;
            case 3:// updateFlyerDetail
                sql =     "UPDATE d_flyer_detail t1,d_flyer_detail t2" +
                        "   SET t1.content = t2.content," +
                        "       t1.updated_content = t2.updated_content," +
                        "       t1.dsc=t2.dsc" +
                        " WHERE t1.flyer_id IN({flyer_ids}) AND t2.flyer_id = ?";
                break;
            case 4:// insertFlyerDetail
                sql = "INSERT INTO d_flyer_detail(flyer_id, content, updated_content, dsc) " +
                        " SELECT t2.id, t1.content, t1.updated_content, t1.dsc " +
                        " FROM d_flyer_detail t1,(SELECT id ,user_id FROM d_flyer  WHERE id IN({flyer_ids})) t2" +
                        " WHERE t1.flyer_id=?";
                break;
            case 5:
                sql =" INSERT INTO d_flyer(title,status,create_time,notice,template,user_id,update_time,description,deleted,orgid,hit,notice_days,visitor_count,feedback_count,ishot,version,is_edit,is_add,beau_sel,ma_id,isorg,refer_count,refer_id,isdraw,iscopy,is_marketa_enjoy,showTitle,searchKeyword,music,classify_id,template_status,option_id,approvedBy,deleteReason,parent_id) " +
                        " (SELECT t1.title,t1.status,NOW(),t1.notice,t1.template,t2.user_id,NOW(),t1.description,0,t2.org_id,0,t1.notice_days,0,0,t1.ishot,2.00,t1.is_edit,t1.is_add,t1.beau_sel,t1.ma_id,0,t1.refer_count,t1.refer_id,t1.isdraw,t1.iscopy,0,t1.showTitle,t1.searchKeyword,t1.music,t1.classify_id,t1.template_status,t1.option_id,t1.approvedBy,t1.deleteReason, " +
                        " {parent_id} " +
                        " FROM d_flyer t1, " +
                        " (select DISTINCT user_id, org_id from m_org_user where user_id in({user_ids}) and del=0 and dept_id !=0 ) t2 " +
                        " WHERE t1.id=?  AND t1.deleted=0 AND t1.user_id=?)";
            default:

        }

        return sql;
    }

/**
     *     =====================================辅助方法清单:方法五==================================================================
     */
    private List<Map<String, Object>> getSharedFlyerInfoByUserIds(Integer maId, Integer parentId, String userIds){
        List<Map<String, Object>> flyers = null;
        String sql = "SELECT t.id AS flyer_id,t.user_id, t.orgid FROM d_flyer t WHERE t.user_id IN ({user_ids}) AND t.ma_id=? AND t.parent_id=?";
        sql = sql.replace("{user_ids}", userIds);
        Object[] params = new Object[]{maId, parentId};
        flyers = this.getDao().query(sql, params, null);
        return flyers;
    }
/**
     *     =====================================辅助方法清单:方法六==================================================================
     */
    private void refreshNameCard(List<Map<String, Object>> flyerDetails){
        if(null==flyerDetails || flyerDetails.isEmpty()){  //如果没有任何相关的表
            return;
        }
        for(int i=0; i<flyerDetails.size(); i++){//获取
            Map<String, Object> flyer = flyerDetails.get(i);
            Integer userId = Integer.parseInt(flyer.get("user_id").toString());//获取传单所属用户
            Integer flyerId = Integer.parseInt(flyer.get("flyer_id").toString());// 相关的传单id
            String content = flyer.get("content").toString();// 传单设置的内容
            //String updateContent = flyer.get("updated_content").toString();//传单发布后设置的内容  为空!!!!!!!
            /**辅助方法清单:方法七*/
            Map<String, Object> m = JsonUtil.jsonToMap(content);/**content 格式化后长度过长 会在最下面展示*/
            //m 是json解析的总根   ~
            List<Map<String,String>> widgets = (List<Map<String, String>>) m.get("widgets");
            for(int j=0; j<widgets.size(); j++){
                Map<String, String> widget = widgets.get(j);
                String wdUname = widget.get("wd_u_name");
                if("bio".equals(wdUname)){//  找到名片   复制了简单的我们需要的json数据
                    /**辅助方法清单:方法九*/
                    Map<String, String> newCard = replaceCardInfo(widget, userId, flyerId, flyer);//生成用户   新的名片
                    widgets.set(j, newCard);//应该就一个 - -!  设置回去
                }
            }
            m.put("widgets", widgets);//用新的替换了之前的
            /**辅助方法清单:方法八*/
            String newContent = JsonUtil.objToJson(m);//重新转换成json字符串
            //访问数据库，开始修改detail表的数据
            /**辅助方法清单:方法十*/
            updateDetailContent(flyerId, newContent);// 更改详细信息表里面的content数据

        }
        /**辅助方法六调用结束  返回passFlyerToUsers() 方法的调用处(倒数7行左右)*/
    }
/**
     *     =====================================辅助方法清单:方法九==================================================================
     */
    private Map<String, String> replaceCardInfo(Map<String, String> widget, Integer userId, Integer flyerId, Map<String, Object> userInfo){
      /*"wd_u_name":"bio","company":"贵州限责任公司","job":"职位","realname":"李小姐",
    "qq":"1234578","tell":"085-1234567","sina":"http://webo.com/baogs/ome?vr=5","email":"255123456@qq.com",
    "web":"http://www.e.com/","address":"贵阳号",*/
        Map<String, String> card = new HashMap<String, String>();
        Set<String> keySet = widget.keySet();// company job realname ==的key集合 
        System.out.println("----------Start replace mobile card info[userId="+userId+",flyerId="+flyerId+"]---------------");
        for(String key : keySet){
            Object userObj = null;
            if("realname".equals(key)){
                userObj = userInfo.get("realname");
            } else if("qq".equals(key)){
                userObj = userInfo.get("qq");
            } else if("tell".equals(key)){
                userObj = userInfo.get("mobile");
            } else if("email".equals(key)){
                userObj = userInfo.get("email");
            } else if("phone".equals(key)){
                userObj = userInfo.get("phone");
            } else if("weixin".equals(key)){
                userObj = userInfo.get("weixin");
            } else if("job".equals(key)){
                userObj = userInfo.get("job")
            }
            System.out.println(key+" = "+String.valueOf(userObj));
            String value = "";
            if(null==userObj){
                value = String.valueOf(widget.get(key));  //没有的话 用原来的
            } else {
                value = String.valueOf(userObj);  //有的话 设置进去
            }
            card.put(key, value); //放到map里面
        }
        System.out.println("----------End replace mobile card info---------------");
        return card; //返回回去
    }

/**
     *     =====================================辅助方法清单:方法十==================================================================
     */
    private void updateDetailContent(Integer flyerId, String content){
        String sql = "update d_flyer_detail set content = ? where flyer_id = ?";
        Object[] params = new Object[]{content, flyerId};
        this.getDao().update(sql,params);
    }

/**
     *     =====================================辅助方法清单:方法十一==================================================================
     */
    private void uploadShareFlyerHtmlFile(Integer maId, Integer flyerId, Integer userId, Integer orgId, List<Map<String, Object>> members) throws Exception{
        //本地html保存路径
        //获取ServletAction上下文对象，getServletContext()获取Servlet上下文对象(项目地址)，getRealPath("file")获取file的!绝对路径! 加上/加上flyer   
        String localHtmlRoot = ServletActionContext.getServletContext().getRealPath("file")+ File.separatorChar +"flyer";
        //本地共享传单路径
        String shareHtmlPath = localHtmlRoot + File.separator + "html" + File.separator + userId+ File.separator;
        //共享传单文件名称
        String shareFileName = flyerId + ".html";  //被共享的传单的地址拼接完成

        //上传路径
        final String realPath = ServletActionContext.getServletContext().getRealPath("");//获取项目的绝对路径
        File shareFile = new File(shareHtmlPath + shareFileName); //被共享传单的File对象
        if(!shareFile.exists()){ // 如果不存在  则抛出异常
            throw new RuntimeException("共享失败，共享传单不存在！");
        }
        for(int i=0; i<members.size(); i++){  //为每一个用户复制被共享的一份传单 放到自己的/user_id/flyer_id下面
            String uploadFilePath = "";
            String tmpFileName = "";
            Map<String, Object> mem = members.get(i); 
            Integer inviteUserId = (Integer) mem.get("user_id");
            Integer inviteUserOrg = (Integer) mem.get("orgid");
            Integer inviteUserFlyerId = (Integer) mem.get("flyer_id");
            tmpFileName = inviteUserFlyerId + ".html";
            String tmpFilePath = localHtmlRoot + File.separator + "html" +File.separator + inviteUserId+ File.separator;
            String tmpFileFullName = tmpFilePath + tmpFileName;
            //文件名 和文件路径判断   先有路径才能创建文件
            File tmpFile = new File(tmpFileFullName);
            File tmpDirs = new File(tmpFilePath);
            if(!tmpDirs.exists()){//文件路径不存在的情况下  创建文件路径
                tmpDirs.mkdirs();
            }
            if(tmpFile.exists()){ //如果先前文件已经存在(未删除)则进行删除
                tmpFile.delete();
            }
            //复制共享传单
            /**辅助方法清单:方法十二*/
            FileUtil.copyFile(shareFile, tmpFile);//建立流 复制传单
            if(!tmpFile.exists()){  //再次判断是否复制了传单
                throw new RuntimeException("共享失败，复制传单"+tmpFileName+"失败！");
            }
            // 更改了成员传单的 名片 等详细信息
            /**辅助方法清单:方法十三*/
            reloadCardHtml(tmpFile, mem);
            //上传成员传单html文件
            uploadFilePath = localHtmlRoot.replace(realPath, "") + File.separator + "html" + File.separator + inviteUserOrg + File.separator + tmpFileName;
            try {
                FileService.UpYunWriteFile(uploadFilePath, tmpFile, false);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }//for循环右括号
    }
 /**
     *     =====================================辅助方法清单:方法十三==================================================================
     */  
    /** 使用了 Jsoup解析了 html文档树*/
    private void reloadCardHtml(File html, Map<String, Object> userInfo){
//        FileWriter fw = null;
        OutputStreamWriter writer = null;
        boolean flag = false;
        try {
            Integer inviteUserId = (Integer) userInfo.get("user_id");
            Integer inviteUserOrg = (Integer) userInfo.get("orgid");
            Integer inviteUserFlyerId = (Integer) userInfo.get("flyer_id");
            System.out.println("==========Start replace html bio[userId="+inviteUserId+",flyerId="+inviteUserFlyerId+"]========================");
            //http://www.jb51.net/article/43485.htm        Jsoup的使用
            //<span class="realname" data-key="realname">“构享家”团队</span>
            Document doc = Jsoup.parse(html, "UTF-8");

            Elements companies = doc.getElementsByAttributeValue("data-key", "company");
            Elements jobs = doc.getElementsByAttributeValue("data-key","job");
            Elements realname = doc.getElementsByAttributeValue("data-key","realname");
            Elements qq = doc.getElementsByAttributeValue("data-key","qq");
            Elements wechats = doc.getElementsByAttributeValue("data-key","weixin");
            Elements mobile = doc.getElementsByAttributeValue("data-key","tell");
            Elements phone = doc.getElementsByAttributeValue("data-key","mobile");
            Elements weibos = doc.getElementsByAttributeValue("data-key","sina");
            Elements emails = doc.getElementsByAttributeValue("data-key","email");
            Elements webs = doc.getElementsByAttributeValue("data-key","web");
            Elements address = doc.getElementsByAttributeValue("data-key","address");

            String userCompany = String.valueOf(userInfo.get("company")==null?"":userInfo.get("company"));
            String userJob = String.valueOf(userInfo.get("job") == null ? "" : userInfo.get("job"));
            String userQQ = String.valueOf(userInfo.get("qq")==null?"":userInfo.get("qq"));
            String userMobile = String.valueOf(userInfo.get("mobile")==null?"":userInfo.get("mobile"));
            String userPhone = String.valueOf(userInfo.get("phone")==null?"":userInfo.get("phone"));
            String userRealname = String.valueOf(userInfo.get("realname")==null?"":userInfo.get("realname"));
            String userEmail = String.valueOf(userInfo.get("email")==null?"":userInfo.get("email"));
            String userWeixin = String.valueOf(userInfo.get("weixin")==null?"":userInfo.get("weixin"));
            if(null!=realname && realname.size()>0){
                Element e = realname.get(0);
                e.text(userRealname);//给元素内容设置数据 
                System.out.println("realname="+userRealname);
                flag = true;
            }

            if(null!=phone && phone.size()>0){
                Element e = phone.get(0);
                e.text(userPhone);
                System.out.println("phone="+userPhone);
                flag = true;
            }

            if(null!=mobile && mobile.size()>0){
                Element e = mobile.get(0);
                e.text(userMobile);
                System.out.println("mobile="+userMobile);
                flag = true;
            }

            if(null!=qq && qq.size()>0){
                Element e = qq.get(0);
                e.text(userQQ);
                System.out.println("qq="+userQQ);
                flag = true;
            }

            if(null!=emails && emails.size()>0){
                Element e = emails.get(0);
                e.text(userEmail);
                System.out.println("email="+userEmail);
                flag = true;
            }

            if(null!=wechats && wechats.size()>0){
                Element e = wechats.get(0);
                e.text(userWeixin);
                System.out.println("weixin="+userWeixin);
                flag = true;
            }
            System.out.println("==========End replace html bio[userId="+inviteUserId+",flyerId="+inviteUserFlyerId+"]========================");
            if(flag){ //如果有更改  in √
                String htmlContent = doc.html();//doc对象的内容已经变了?   现在实际上是jsoup一次性解析了html文件
                    // 生成 Document对象   一直在内存中 我们只是操作了对象  
//            String aaa = doc.data(); 测试代码
//            String bbb = doc.html();
//            String ccc = doc.val();
//            fw = new FileWriter(html);
//            fw.write(htmlContent);
                writer = new OutputStreamWriter(new FileOutputStream(html), "UTF-8"); //开启了到更新文件的 输出流
                writer.write(htmlContent); //把文档输出到里面去    内存到硬盘的写入
                writer.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

两个工具类(不完全):

//--------------------------JsonUtil类---------使用了google提供的 gson类 解析json-a------------------------------------------------------
import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.google.gson.reflect.TypeToken;

public class JsonUtil{
    private static Gson gson;
    /** JSON字符串转化为HashMap对象*/
    /**
     *     =====================================辅助方法清单:方法七==================================================================
     */
    public static Map<String, Object> jsonToMap(String string) {
        Map<String, Object> obj = null;
        try {  //s使用 google的gson包
            obj = JsonUtil.getGson().fromJson(string, new TypeToken<Map<String, Object>>(){}.getType());
        }catch (Exception e) {
            e.printStackTrace();
        }
        return obj;
    }
    /**
     *     =====================================辅助方法清单:方法八==================================================================
     */
    public static String objToJson(Object data) {
        try {
            return JsonUtil.getGson().toJson(data);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return "";
    }
}

//--------------------------FileUtil类---------使用了google提供的 gson类 解析json-a------------------------------------------------------
public class FileUtil {
    /**
     *     =====================================辅助方法清单:方法十二==================================================================
     */  
    public static boolean copyFile(File sourceFile, File targetFile) {
        try {
            BufferedInputStream inBuff = null;
            BufferedOutputStream outBuff = null;
            try {
                // 新建文件输入流并对它进行缓冲
                inBuff = new BufferedInputStream(new FileInputStream(sourceFile));

                // 新建文件输出流并对它进行缓冲
                outBuff = new BufferedOutputStream(new FileOutputStream(targetFile));
                // 缓冲数组
                byte[] b = new byte[1024 * 100];
                int len;
                while ((len = inBuff.read(b)) != -1) {
                    outBuff.write(b, 0, len);
                }
                // 刷新此缓冲的输出流
                outBuff.flush();
            } finally {
                // 关闭流
                if (inBuff != null)
                    inBuff.close();
                if (outBuff != null)
                    outBuff.close();
            }
        } catch (Throwable e) {
            e.printStackTrace();
            return false;
        }
        return true;
    }

}

/**~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ content内容展~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

/*
{"widgets":
    [
       {"wd_u_name":"title",
        "value":"找工作去劳联，电信送手机",
        "href":"http://baidu.com",
        "color":"#000000",
        "colors":[
            "#000000",
            "#ff7418",
            "#f14444",
            "#a25c18",
            "#b62450"],
        "fontSize":"25px",
        "fontFamily":"Microsoft YaHei,Microsoft YaHei",
        "marginTop":"10px",
        "textAlign":"center"},

        {"wd_u_name":"map",
            "value":"北京市海淀区上地信息路28号科实大厦",
            "marginTop":"5px"},
        {"wd_u_name":"media",
            "value":"http://player.youku.com/player.php/sid/XNjY0NDI4MjE2/v.swf",
            "color":"#000000",
            "marginTop":"5px"},

        {"wd_u_name":"feedback",   //反馈表
            "btnLabel":"抢购",
            "items":
                [
                {"name":"name",
                    "allowBlank":"false",
                    "label":"姓     名    "},
                {"name":"weibo",
                    "label":"微博",
                    "maxlength":64,
                    "input":"string",
                    "width":"100",
                    "allowBlank":"true"},
                {"name":"phone",
                    "label":"电话",
                    "maxlength":32,
                    "sortable":true,
                    "type":"string",
                    "width":"100",
                    "allowBlank":"false"},
                {"name":"mobile",
                    "label":"手     机",
                    "allowBlank":"false"},
                {"name":"appellation",
                    "label":"称呼",
                    "maxlength":32,
                    "input":"string",
                    "width":"100",
                    "allowBlank":"true"},
                {"name":"email",
                    "label":"邮     箱    ",
                    "allowBlank":"true"},
                {"name":"position",
                    "label":"经纪人",
                    "maxlength":32,
                    "input":"string",
                    "width":"100",
                    "allowBlank":"false"},
                {"name":"note",
                    "label":"备注",
                    "maxlength":200,
                    "type":"string",
                    "input":"textarea",
                    "width":"150"},
                {"name":"company",
                    "label":"公司",
                    "maxlength":64,
                    "sortable":true,
                    "input":"string",
                    "width":"150"},
                {"name":"qq",
                    "label":"QQ",
                    "allowBlank":"true"},
                {"name":"address",
                    "label":"地址",
                    "maxlength":128,
                    "type":"string",
                    "width":"100",
                    "allowBlank":"true"}
            ],
                "fontSize":"13px",
                "marginTop":"10px"},

  -------------//名片表-----------------------主要是他更新  因为传单的名片应该是发到A的账号中去的时候就变成A的相关的信息   当然也可以编辑 
{"wd_u_name":"bio",
    "company":"贵州限责任公司",
    "job":"职位",
    "realname":"李小姐",
    "qq":"",
    "tell":"08516550",
    "sina":"http://webo.com/baogs/ome?vr=5",
    "email":"2556890@qq.com",
    "web":"http://www.e.com/",
    "address":"贵阳号",
    "marginTop":"0px",
    "imgsrc":"/file/flyer/tdcode/png201431118063553.png",
    "status":2,
    "fontSize":"18px",
    "color":"rgb(0,
    0,
    0)",
    "colors":["#000000",
    "#7f8c2f",
    "#85622a",
    "#b66c2a",
    "#a92e2e"]}
    ],
    "meta":{"color":"#fedac2",
        "bgImg":"/flyer/images/flyerimg/flyer_bg_6.jpg",
        "shadingImg":"/flyer/images/bgimg/06.png"}}
        */

OK  结束   再次声明 此博客为个人笔记      并不是独立demo