删除HongBaoMessage相关代码

admin

2018-12-18 6a04b2680d414714ce922f7d694224ff65202c67

删除HongBaoMessage相关代码

 fanli/src/main/java/com/yeshi/fanli/controller/ClientJspController.java

@@ -21,6 +21,10 @@
import org.springframework.web.bind.annotation.PathVariable;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.yeshi.utils.HttpUtil;

import org.yeshi.utils.JsonUtil;

import org.yeshi.utils.NumberUtil;

import org.yeshi.utils.wx.WXUtil;



import com.google.gson.Gson;

import com.google.gson.GsonBuilder;

@@ -64,7 +68,6 @@
import com.yeshi.fanli.service.inter.goods.TaoBaoCouponService;

import com.yeshi.fanli.service.inter.goods.TaoBaoGoodsBriefService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoMessageService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoService;

import com.yeshi.fanli.service.inter.hongbao.ThreeSaleRankService;

import com.yeshi.fanli.service.inter.hongbao.ThreeSaleSerivce;

@@ -82,10 +85,6 @@
import com.yeshi.fanli.util.taobao.TaoBaoUtil;

import com.yeshi.fanli.util.taobao.TaoKeApiUtil;

import com.yeshi.fanli.util.wx.WXLoginUtil;

import org.yeshi.utils.HttpUtil;

import org.yeshi.utils.JsonUtil;

import org.yeshi.utils.NumberUtil;

import org.yeshi.utils.wx.WXUtil;



import net.sf.json.JSONArray;

import net.sf.json.JSONObject;

@@ -144,9 +143,6 @@


    @Resource

    private UserInfoService userInfoService;



    @Resource

    private HongBaoMessageService hongBaoMessageService;



    @Resource

    private ThreeSaleRankService threeSaleRankService;

@@ -618,7 +614,8 @@
        List<TaoBaoGoodsBriefExtra> list = new ArrayList<TaoBaoGoodsBriefExtra>();

        BigDecimal proportion = hongBaoManageService.getFanLiRate();

        for (RecommendSectionGoods recommendSectionGoods : recommendSectionGoodsList) {

            list.add(TaoBaoUtil.getTaoBaoGoodsBriefExtra(recommendSectionGoods.getTaoBaoGoodsBrief(), proportion.toString(), ""));

            list.add(TaoBaoUtil.getTaoBaoGoodsBriefExtra(recommendSectionGoods.getTaoBaoGoodsBrief(),

                    proportion.toString(), ""));

        }



        Gson gson = JsonUtil.getApiCommonGson();


 fanli/src/main/java/com/yeshi/fanli/controller/client/UserAccountController.java

@@ -31,7 +31,6 @@
import com.yeshi.fanli.service.inter.config.InviteGetMoneyService;

import com.yeshi.fanli.service.inter.config.SystemService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoMessageService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoService;

import com.yeshi.fanli.service.inter.hongbao.ThreeSaleSerivce;

import com.yeshi.fanli.service.inter.order.LostOrderService;

@@ -94,8 +93,7 @@
    @Resource

    private SystemService systemService;



    @Resource

    private HongBaoMessageService hongBaoMessageService;

	


    @Resource

    private ShamUserService shamUserService;


 fanli/src/main/java/com/yeshi/fanli/controller/client/UserInfoController.java

@@ -40,7 +40,6 @@
import com.yeshi.fanli.entity.bus.user.ExtractRecord;

import com.yeshi.fanli.entity.bus.user.HongBao;

import com.yeshi.fanli.entity.bus.user.HongBaoExtra;

import com.yeshi.fanli.entity.bus.user.HongBaoMessage;

import com.yeshi.fanli.entity.bus.user.LostOrder;

import com.yeshi.fanli.entity.bus.user.MoneyRecord;

import com.yeshi.fanli.entity.bus.user.OrderItem;

@@ -67,7 +66,6 @@
import com.yeshi.fanli.service.inter.config.SystemService;

import com.yeshi.fanli.service.inter.goods.CollectionGoodsV2Service;

import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoMessageService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoService;

import com.yeshi.fanli.service.inter.hongbao.ThreeSaleExtraInfoSerivce;

import com.yeshi.fanli.service.inter.hongbao.ThreeSaleSerivce;

@@ -133,9 +131,6 @@


    @Resource

    private SystemService systemService;



    @Resource

    private HongBaoMessageService hongBaoMessageService;



    @Resource

    private ShamUserService shamUserService;

@@ -1253,7 +1248,7 @@
                    json.put("timeStamp", java.lang.System.currentTimeMillis());

                    json.put("adminId", 4L);

                    String sign = AESUtil.encrypt(json.toString(), Constant.ADMINH5_AESKEY);

                    String url="";

                    String url = "";

                    try {

                        url = String.format("%s?from=emailh5&sign=%s",

                                Constant.systemCommonConfig.getExtractNotifyUrl(), URLEncoder.encode(sign, "UTF-8"));

@@ -1334,14 +1329,6 @@
        data.put("hongBao", GsonUtil.toJsonExpose(hbx));

        out.print(JsonUtil.loadTrueResult(data));

        LogHelper.userInfo("[ip:" + IPUtil.getRemotIP(request) + "] 打开红包[id=" + hid + "]成功！");

    }



    @RequestMapping(value = "getHongBaoMessages", method = RequestMethod.POST)

    public void getHongBaoMessages(AcceptData acceptData, PrintWriter out) {

        List<HongBaoMessage> list = shamUserService.getManyData();

        JSONObject data = new JSONObject();

        data.put("list", list);

        out.print(JsonUtil.loadTrueResult(data));

    }



    @RequestMapping("findLostOrder")


 fanli/src/main/java/com/yeshi/fanli/controller/xcx/XcxUserInfoController.java

@@ -5,7 +5,6 @@
import java.util.ArrayList;

import java.util.Arrays;

import java.util.List;

import java.util.Map;

import java.util.UUID;



import javax.annotation.Resource;

@@ -32,7 +31,6 @@
import com.yeshi.fanli.service.inter.config.ConfigService;

import com.yeshi.fanli.service.inter.goods.CollectionGoodsV2Service;

import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoMessageService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoService;

import com.yeshi.fanli.service.inter.hongbao.ThreeSaleSerivce;

import com.yeshi.fanli.service.inter.order.LostOrderService;

@@ -87,9 +85,6 @@


    @Resource

    private XcxMiniControllerUtil xcxMiniControllerUtil;



    @Resource

    private HongBaoMessageService hongBaoMessageService;



    @Resource

    private ShamUserService shamUserService;


 fanli/src/main/java/com/yeshi/fanli/dao/hongbao/HongBaoMessageDao.java

File was deleted

 fanli/src/main/java/com/yeshi/fanli/entity/bus/user/HongBaoMessage.java

File was deleted

 fanli/src/main/java/com/yeshi/fanli/service/impl/hongbao/HongBaoMessageServiceImpl.java

File was deleted

 fanli/src/main/java/com/yeshi/fanli/service/impl/user/ShamUserServiceImpl.java

@@ -1,15 +1,11 @@
package com.yeshi.fanli.service.impl.user;



import java.math.BigDecimal;

import java.text.DecimalFormat;

import java.util.ArrayList;

import java.util.Collections;

import java.util.Comparator;

import java.util.List;



import javax.annotation.Resource;



import net.sf.json.JSONArray;



import org.hibernate.HibernateException;

import org.hibernate.SQLQuery;

@@ -20,13 +16,12 @@


import com.yeshi.fanli.dao.mybatis.user.ShamUserMapper;

import com.yeshi.fanli.dao.user.ShamUserDao;

import com.yeshi.fanli.entity.bus.user.HongBaoMessage;

import com.yeshi.fanli.entity.bus.user.ShamUser;

import com.yeshi.fanli.service.inter.config.ConfigService;

import com.yeshi.fanli.service.inter.user.ShamUserService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.Utils;



import net.sf.json.JSONArray;



@Service

public class ShamUserServiceImpl implements ShamUserService {

@@ -66,35 +61,7 @@
        });

    }

    

    @SuppressWarnings("unchecked")

    public List<HongBaoMessage> getManyData() {

		
        return (List<HongBaoMessage>) dao.excute(new HibernateCallback<List<HongBaoMessage>>() {



            public List<HongBaoMessage> doInHibernate(Session session)

                    throws HibernateException {

                SQLQuery query = session.createSQLQuery("SELECT * FROM yeshi_ec_sham_user ORDER BY RAND()").addEntity(ShamUser.class);

                query.setFirstResult(0);

                query.setMaxResults(Constant.PAGE_SIZE);

                List<ShamUser> list = query.list();

                List<HongBaoMessage> hbmList=new ArrayList<HongBaoMessage>();

                if(list.size()>0){

                    HongBaoMessage hbm = null;

                    DecimalFormat df = new DecimalFormat("######0.00");  
                    for (ShamUser shamUser : list) {

                        hbm=new HongBaoMessage();

                        hbm.setName(shamUser.getName());

                        hbm.setPicUrl(shamUser.getPicUrl());

                        double random = (Math.random()+0.01)*20;

                        String format = df.format(random);

                        hbm.setContent("悄悄领取了"+format+"元红包");

                        hbmList.add(hbm);

                    }

                }

                return hbmList;

            }

        });

    }

	
    @Transactional

    public void delete(final long id) {

        dao.excute(new HibernateCallback() {

@@ -106,53 +73,7 @@
        });

    }



    @SuppressWarnings("unchecked")

    public List<HongBaoMessage> findShamThreeSaleInfo() {



        return (List<HongBaoMessage>) dao.excute(new HibernateCallback<List<HongBaoMessage>>() {



            public List<HongBaoMessage> doInHibernate(Session session)

                    throws HibernateException {

                SQLQuery query = session.createSQLQuery("SELECT * FROM yeshi_ec_sham_user ORDER BY RAND()").addEntity(ShamUser.class);

                query.setFirstResult(0);

                query.setMaxResults(5);

                List<ShamUser> list = query.list();

                List<HongBaoMessage> hbmList=new ArrayList<HongBaoMessage>();

                if(list.size()>0){

                    HongBaoMessage hbm = null;

                    DecimalFormat df = new DecimalFormat("######0.00");  
                    for (ShamUser shamUser : list) {

                        String name = shamUser.getName();

                        if(name != null){

                            if(name.length() > 2){

                                name = Utils.getStarString(name,1,name.length()-1);

                            }else{

                                name = name.substring(0, 1)+"**"+name.substring(name.length()-1);

                            }

                        }

                        shamUser.setName(name);

                        hbm=new HongBaoMessage();

                        hbm.setName(shamUser.getName());

                        hbm.setPicUrl(shamUser.getPicUrl());

                        double random = (Math.random()+100)*10;

                        String format = df.format(random);

                        hbm.setContent(format+"");

                        hbmList.add(hbm);

                    }

                }

                Collections.sort(hbmList, new Comparator<HongBaoMessage>() {

                    public int compare(HongBaoMessage o1, HongBaoMessage o2) {

                        double o1m = Double.parseDouble(o1.getContent());

                        double o2m = Double.parseDouble(o2.getContent());

                        double m=o1m-o2m;

                        return m<0?1:-1;

                    }

                });

                return hbmList;

            }

        });

	
    }



    @Override

    public int deleteByPrimaryKey(Long id) {


 fanli/src/main/java/com/yeshi/fanli/service/inter/hongbao/HongBaoMessageService.java

File was deleted

 fanli/src/main/java/com/yeshi/fanli/service/inter/user/ShamUserService.java

@@ -3,7 +3,6 @@
import java.math.BigDecimal;

import java.util.List;



import com.yeshi.fanli.entity.bus.user.HongBaoMessage;

import com.yeshi.fanli.entity.bus.user.ShamUser;



/**

@@ -18,11 +17,9 @@


    public List<ShamUser> getAll();



    public List<HongBaoMessage> getManyData();



    public void delete(long id);



    public List<HongBaoMessage> findShamThreeSaleInfo();



    public List<ShamUser> findShamUserList(int sum);

    


 fanli/src/main/java/com/yeshi/fanli/util/ShamHongBaoUtil.java

@@ -2,7 +2,6 @@


import java.io.File;

import java.io.IOException;

import java.text.DecimalFormat;

import java.util.ArrayList;

import java.util.List;

import java.util.UUID;

@@ -15,10 +14,8 @@
import org.apache.commons.httpclient.methods.PostMethod;

import org.springframework.stereotype.Component;



import com.yeshi.fanli.entity.bus.user.HongBaoMessage;

import com.yeshi.fanli.entity.bus.user.ShamUser;

import com.yeshi.fanli.entity.bus.user.UserInfo;

import com.yeshi.fanli.service.inter.hongbao.HongBaoMessageService;

import com.yeshi.fanli.service.inter.user.ShamUserService;

import com.yeshi.fanli.service.inter.user.UserInfoService;



@@ -31,36 +28,33 @@


@Component

public class ShamHongBaoUtil {

	


    @Resource

    private ShamUserService shamUserService;

	


    @Resource

    private UserInfoService userInfoService;

	
    @Resource

    private HongBaoMessageService hongBaoMessageService;

	
    public void addShamUserInfo(){

        List<ShamUser> list =shamUserService.getAll();



    public void addShamUserInfo() {

        List<ShamUser> list = shamUserService.getAll();

        for (ShamUser shamUser : list) {

            UserInfo form = new UserInfo();

            form.setNickName(shamUser.getName());

            form.setPortrait(shamUser.getPicUrl());

            form.setLoginType(-1);

            form.setOpenid(UUID.randomUUID().toString().replaceAll("-", "")+"-1");

            form.setOpenid(UUID.randomUUID().toString().replaceAll("-", "") + "-1");

            userInfoService.addUser(form, "23649898");

        }

    }

	
    public void deleteShamUser(String path){



    public void deleteShamUser(String path) {

        try {

            Workbook workbook = Workbook.getWorkbook(new File(path));

            Sheet sheet = workbook.getSheet(0);

            for (int ii=0;ii<sheet.getRows();ii++) {

                Cell cell = sheet.getCell(0,ii);

                if(cell.getContents()==null || "".equals(cell.getContents().trim())){

                    continue;	
            for (int ii = 0; ii < sheet.getRows(); ii++) {

                Cell cell = sheet.getCell(0, ii);

                if (cell.getContents() == null || "".equals(cell.getContents().trim())) {

                    continue;

                }

                shamUserService.delete(Long.parseLong(cell.getContents()));

            }

@@ -69,37 +63,20 @@
        } catch (IOException e) {

            e.printStackTrace();

        }

		


    }

	
    private void addHongBaoMessage(){

        List<ShamUser> all = shamUserService.getAll();

        List<HongBaoMessage> list = new ArrayList<HongBaoMessage>();

        HongBaoMessage message;

        DecimalFormat df = new DecimalFormat("######0.00");   
        for (ShamUser shamUser : all) {

            message = new HongBaoMessage();

            message.setName(shamUser.getName());

            message.setPicUrl(shamUser.getPicUrl());

            double random = (Math.random()+0.01)*20;

            String format = df.format(random);

            message.setContent("悄悄领取了"+format+"元红包");

            list.add(message);

        }

        hongBaoMessageService.add(list);

    }

	
    public void addShamUser(String pid) throws Exception{

         HttpClient client = new HttpClient();

         HttpMethod method = getPostMethod(pid);

         client.executeMethod(method);

         java.lang.System.out.println(method.getStatusLine());   //打印结果页面  
          String response=new String(method.getResponseBodyAsString().getBytes("UTF-8"));  
          //打印返回的信息  
          method.releaseConnection();  
          List<ShamUser> list = parseQQresult(response);

          for (ShamUser shamUser : list) {

              shamUserService.addShamUser(shamUser);



    public void addShamUser(String pid) throws Exception {

        HttpClient client = new HttpClient();

        HttpMethod method = getPostMethod(pid);

        client.executeMethod(method);

        java.lang.System.out.println(method.getStatusLine()); // 打印结果页面

        String response = new String(method.getResponseBodyAsString().getBytes("UTF-8"));

        // 打印返回的信息

        method.releaseConnection();

        List<ShamUser> list = parseQQresult(response);

        for (ShamUser shamUser : list) {

            shamUserService.addShamUser(shamUser);

        }

    }



@@ -107,25 +84,25 @@
        JSONObject json = JSONObject.fromObject(response);

        List<ShamUser> list = new ArrayList<ShamUser>();

        String code = String.valueOf(json.opt("retcode"));

        if("0".equals(code)){

        if ("0".equals(code)) {

            JSONArray jsonArray = json.optJSONObject("result").optJSONObject("buddy").optJSONArray("info_list");

            ShamUser user = null;

            String patterns = "[^\u4e00-\u9fa5\\w\\s]+";

            if(jsonArray==null){

                return list; 
            if (jsonArray == null) {

                return list;

            }

            for (Object object : jsonArray) {

                JSONObject  data = (JSONObject)object;

                JSONObject data = (JSONObject) object;

                String name = (String) data.opt("nick");

                name=name.replaceAll(patterns, "").replaceAll(" ", "");

                if(name.length() < 2){

                name = name.replaceAll(patterns, "").replaceAll(" ", "");

                if (name.length() < 2) {

                    continue;

                }

                String picUrl =  (String) data.opt("url"); 	
                String picUrl = (String) data.opt("url");

                user = new ShamUser();

                user.setName(new String(name.getBytes(),"utf-8"));

                if(picUrl.contains("pub.idqqimg.com")){

                    picUrl="https://gw.alicdn.com/tps/i3/TB1yeWeIFXXXXX5XFXXuAZJYXXX-210-210.png_160x160.jpg";

                user.setName(new String(name.getBytes(), "utf-8"));

                if (picUrl.contains("pub.idqqimg.com")) {

                    picUrl = "https://gw.alicdn.com/tps/i3/TB1yeWeIFXXXXX5XFXXuAZJYXXX-210-210.png_160x160.jpg";

                }

                user.setPicUrl(picUrl);

                list.add(user);

@@ -135,27 +112,32 @@
    }



    private static HttpMethod getPostMethod(String pid) {

         PostMethod post = new PostMethod( "http://cgi.find.qq.com/qqfind/buddy/search_v3" ); //recommendDetails voteGoods recommendReplys makePublic replys

         NameValuePair num = new NameValuePair( "num" , "100" );

         NameValuePair page = new NameValuePair( "page" , "0" );

         NameValuePair sessionid = new NameValuePair( "sessionid" , "0" );

         NameValuePair agerg = new NameValuePair( "agerg" , "13" );

         NameValuePair sex = new NameValuePair( "sex" , "0" );

         NameValuePair firston = new NameValuePair( "firston" , "0" );

         NameValuePair video = new NameValuePair( "video" , "0" );

         NameValuePair country = new NameValuePair( "country" , "1" );

         NameValuePair province = new NameValuePair( "province" , pid );

         NameValuePair city = new NameValuePair( "city" , "0" );

         NameValuePair district = new NameValuePair( "district" , "0" );

         NameValuePair hcountry = new NameValuePair( "hcountry" , "1" );

         NameValuePair hprovince = new NameValuePair( "hprovince" , "0" );

         NameValuePair hcity = new NameValuePair( "hcity" , "0" );

         NameValuePair hdistrict = new NameValuePair( "hdistrict" , "0" );

         NameValuePair online = new NameValuePair( "online" , "0" );

         NameValuePair ldw = new NameValuePair( "ldw" , "814539287" );

         post.setRequestHeader("Cookie", "RK=7dVSTqdaSf; pt2gguin=o0424539852; ptisp=ctc; ptcz=555762bb1a6cef860451fe47677c82eaf80a1388eee045b8cf2d546ed1c96534; _qpsvr_localtk=tk70; pgv_info=ssid=s852802188; pgv_pvid=9584824304; uin=o424539852; skey=Z9PWyiIOuI; itkn=2002088896");

         post.setRequestBody( new NameValuePair[] {num,page,sessionid,agerg,sex,firston,video,country,province,city,

                 district,hcountry,hprovince,hcity,hdistrict,online,ldw});  
        PostMethod post = new PostMethod("http://cgi.find.qq.com/qqfind/buddy/search_v3"); // recommendDetails

                                                                                            // voteGoods

                                                                                            // recommendReplys

                                                                                            // makePublic

                                                                                            // replys

        NameValuePair num = new NameValuePair("num", "100");

        NameValuePair page = new NameValuePair("page", "0");

        NameValuePair sessionid = new NameValuePair("sessionid", "0");

        NameValuePair agerg = new NameValuePair("agerg", "13");

        NameValuePair sex = new NameValuePair("sex", "0");

        NameValuePair firston = new NameValuePair("firston", "0");

        NameValuePair video = new NameValuePair("video", "0");

        NameValuePair country = new NameValuePair("country", "1");

        NameValuePair province = new NameValuePair("province", pid);

        NameValuePair city = new NameValuePair("city", "0");

        NameValuePair district = new NameValuePair("district", "0");

        NameValuePair hcountry = new NameValuePair("hcountry", "1");

        NameValuePair hprovince = new NameValuePair("hprovince", "0");

        NameValuePair hcity = new NameValuePair("hcity", "0");

        NameValuePair hdistrict = new NameValuePair("hdistrict", "0");

        NameValuePair online = new NameValuePair("online", "0");

        NameValuePair ldw = new NameValuePair("ldw", "814539287");

        post.setRequestHeader("Cookie",

                "RK=7dVSTqdaSf; pt2gguin=o0424539852; ptisp=ctc; ptcz=555762bb1a6cef860451fe47677c82eaf80a1388eee045b8cf2d546ed1c96534; _qpsvr_localtk=tk70; pgv_info=ssid=s852802188; pgv_pvid=9584824304; uin=o424539852; skey=Z9PWyiIOuI; itkn=2002088896");

        post.setRequestBody(new NameValuePair[] { num, page, sessionid, agerg, sex, firston, video, country, province,

                city, district, hcountry, hprovince, hcity, hdistrict, online, ldw });

        return post;

    }