fanli-server.git

			@@ -8,7 +8,9 @@
			import java.io.PrintWriter;
			import java.math.BigDecimal;
			import java.util.ArrayList;
			import java.util.Iterator;
			import java.util.List;
			import java.util.Set;
			import java.util.UUID;

			import javax.annotation.Resource;
			@@ -36,16 +38,15 @@
			import com.google.gson.GsonBuilder;
			import com.yeshi.fanli.dao.dynamic.DynamicInfoDao;
			import com.yeshi.fanli.dao.mybatis.help.HelpCenterMapper;
			import com.yeshi.fanli.dto.ConfigParamsDTO;
			import com.yeshi.fanli.dto.jd.JDSearchResult;
			import com.yeshi.fanli.entity.bus.activity.ActivityShareResult;
			import com.yeshi.fanli.entity.bus.activity.RecommendActivity;
			import com.yeshi.fanli.entity.dynamic.DynamicInfo;
			import com.yeshi.fanli.entity.dynamic.GoodsPicture;
			import com.yeshi.fanli.entity.dynamic.InviteMaterial;
			import com.yeshi.fanli.entity.jd.JDGoods;
			import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
			import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBriefExtra;
			import com.yeshi.fanli.exception.ActivityException;
			import com.yeshi.fanli.exception.push.PushException;
			import com.yeshi.fanli.exception.share.UserShareGoodsRecordException;
			import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;
			import com.yeshi.fanli.log.LogHelper;
			@@ -54,19 +55,25 @@
			import com.yeshi.fanli.service.inter.dynamic.DynamicInfoService;
			import com.yeshi.fanli.service.inter.dynamic.InviteMaterialService;
			import com.yeshi.fanli.service.inter.goods.TaoBaoGoodsBriefService;
			import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;
			import com.yeshi.fanli.service.inter.money.UserMoneyExtraService;
			import com.yeshi.fanli.service.inter.order.config.HongBaoManageService;
			import com.yeshi.fanli.service.inter.user.integral.IntegralGetService;
			import com.yeshi.fanli.tag.PageEntity;
			import com.yeshi.fanli.util.Constant;
			import com.yeshi.fanli.util.FileUtil;
			import com.yeshi.fanli.util.RedisManager;
			import com.yeshi.fanli.util.StringUtil;
			import com.yeshi.fanli.util.TimeUtil;
			import com.yeshi.fanli.util.db.MongoDBManager;
			import com.yeshi.fanli.util.factory.goods.GoodsDetailVOFactory;
			import com.yeshi.fanli.util.jd.JDApiUtil;
			import com.yeshi.fanli.util.push.OPPOPushUtil;
			import com.yeshi.fanli.vo.goods.GoodsDetailVO;

			import net.sf.json.JSONArray;
			import net.sf.json.JSONObject;
			import redis.clients.jedis.Jedis;
			import redis.clients.jedis.JedisPool;

			@Controller
			@RequestMapping("test")
			@@ -97,63 +104,26 @@

			@Resource
			private ConfigService configService;


			@Resource
			private HongBaoManageService hongBaoManageService;

			@Resource
			private InviteMaterialService inviteMaterialService;


			@Resource
			private DynamicInfoDao dynamicInfoDao;

			@Resource
			private JedisPool jedisPool;

			@Resource
			private IntegralGetService integralGetService;

			@Resource
			private UserMoneyExtraService userMoneyExtraService;


			@RequestMapping(value = "testimg")
			public void testImg(HttpServletRequest request, PrintWriter out) {
			long startTime = System.currentTimeMillis();

			List<String> list = new ArrayList<>();
			for (int i = 0; i < 10; i++) {
			list.add("i" + i);
			}

			try {
			final TaoBaoGoodsBrief goods = redisManager.getTaoBaoGoodsBrief(569823237075L);
			} catch (TaobaoGoodsDownException e1) {
			e1.printStackTrace();
			}
			String url = "http://www.baidu.com";
			list.parallelStream().forEach(ids -> {
			InputStream portrait = HttpUtil.getAsInputStream(
			"https://wwc.alicdn.com/avatar/getAvatar.do?userId=1889722423&width=160&height=160&type=sns");
			System.out.println(ids + "开始时间:" + System.currentTimeMillis());
			String uid = "123";
			String auctionId = "test-" + ids;

			String destPath = FileUtil.getCacheDir() + "/" + auctionId + ".jpg";

			String shareImgPath = FileUtil.getCacheDir() + "/share_" + uid + "_" + auctionId + ".png";

			try {
			QRCodeUtil.getInstance(500).encode(url, destPath);
			} catch (Exception e) {
			e.printStackTrace();
			}
			long startDTime = System.currentTimeMillis();

			/*
			* try { //ImageUtil.drawGoodsShareImg(new FileInputStream(new
			* File(destPath)), portrait, goods, shareImgPath); } catch
			* (FileNotFoundException e) { e.printStackTrace(); }
			*/
			System.out.println(System.currentTimeMillis() - startDTime);

			String shareImgUrl = COSManager.getInstance()
			.uploadFile(new File(shareImgPath), "share_" + uid + "_" + auctionId + ".png").getUrl();
			System.out.println(ids + "结束时间:" + System.currentTimeMillis());
			});
			System.out.println("整体耗时:" + (System.currentTimeMillis() - startTime));
			}


			@RequestMapping(value = "kefu")
			public void kefu(HttpServletRequest request, PrintWriter out) {
			@@ -277,76 +247,6 @@
			}
			}

			@RequestMapping(value = "insertShop")
			public void insertShop(PrintWriter out) {
			try {
			dynamicInfoService.insertShopInfo();
			dynamicInfoService.insertTimeHotSale();
			dynamicInfoService.insertTimeRecommend();
			} catch (Exception e) {
			e.printStackTrace();
			}
			}

			/**
			* 插入邀请素材
			*
			* @param out
			*/
			@RequestMapping(value = "uploadInviteMaterial")
			public void uploadInviteMaterial(PrintWriter out) {
			try {
			List<InviteMaterial> list = new ArrayList<InviteMaterial>();

			// 图片文件
			File file = new File("E:\\Invite\\Picture");
			File[] files = file.listFiles();
			for (File filePic : files) {// 遍历这个数组
			String name = filePic.getName();
			String prefix = name.substring(name.lastIndexOf(".") + 1);
			// 上传文件相对位置
			String filePath = "/resource/invite/everyday/" + UUID.randomUUID().toString().replace("-", "") + "."
			+ prefix;

			String fileUrl = COSManager.getInstance().uploadFile(filePic, filePath).getUrl();

			System.out.println("FileName:" + name);
			System.out.println("url:" + fileUrl);

			InviteMaterial inviteMaterial = new InviteMaterial();
			inviteMaterial.setState(0);
			inviteMaterial.setPicture(fileUrl);
			list.add(inviteMaterial);
			}

			List<String> listTxt = new ArrayList<String>();
			File textfile = new File("E:\\Invite\\content.txt");// Text文件
			BufferedReader br = new BufferedReader(new FileReader(textfile));// 构造一个BufferedReader类来读取文件
			String s = "";
			while ((s = br.readLine()) != null) {// 使用readLine方法，一次读一行
			if (StringUtil.isNullOrEmpty(s)) {
			continue;
			}
			listTxt.add(s);
			}
			br.close();

			if (list.size() == 0 \|\| listTxt.size() == 0 \|\| listTxt.size() < list.size()) {
			return;
			}

			for (int i = 0; i < list.size(); i++) {
			InviteMaterial invite = list.get(i);
			invite.setText(listTxt.get(i));
			inviteMaterialService.insert(invite);
			}
			JsonUtil.printMode(out, null, JsonUtil.loadTrueResult("上传成功"));
			} catch (Exception e) {
			JsonUtil.printMode(out, null, JsonUtil.loadFalseResult("上传失败"));
			e.printStackTrace();
			}
			}

			/**
			* 插入邀请素材
			*
			@@ -431,9 +331,10 @@
			e.printStackTrace();
			}
			}


			/**
			* 插入邀请素材
			*
			* @param out
			*/
			@RequestMapping(value = "getJingFenList")
			@@ -453,10 +354,13 @@
			if (goodsList != null && goodsList.size() > 0) {
			BigDecimal fanLiRate = hongBaoManageService.getFanLiRate();
			BigDecimal shareRate = hongBaoManageService.getShareRate();
			ConfigParamsDTO paramsDTO = new ConfigParamsDTO(fanLiRate, shareRate, Constant.MAX_REWARD_RATE,
			hongBaoManageService.getVIPFanLiRate());

			Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())
			.excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();
			for (JDGoods goods : goodsList) {
			GoodsDetailVO goodsDetailVO = GoodsDetailVOFactory.convertJDGoods(goods, fanLiRate, shareRate);
			GoodsDetailVO goodsDetailVO = GoodsDetailVOFactory.convertJDGoods(goods, paramsDTO);
			array.add(gson.toJson(goodsDetailVO));
			}
			}
			@@ -470,46 +374,73 @@
			e.printStackTrace();
			}
			}


			/**
			* 插入邀请素材
			*
			* @param out
			*/
			@RequestMapping(value = "queryExistsId")
			public void queryExistsAuctionId(PrintWriter out) {

			@RequestMapping(value = "getWaitingThreadsCount")
			public void getWaitingThreadsCount(PrintWriter out) {
			out.print(Constant.waitingThreadSet.size());
			}

			@RequestMapping(value = "getBinFaRedisKey")
			public void getPinFaRedisKey(PrintWriter out) {
			JSONArray array = new JSONArray();
			Jedis jedis = jedisPool.getResource();
			try {
			List<DynamicInfo> list = dynamicInfoDao.queryExistsAuctionId();
			for (DynamicInfo dynamicInfo: list) {
			List<GoodsPicture> imgs = dynamicInfo.getImgs();
			if (imgs == null \|\| imgs.size() == 0) {
			continue;
			}

			boolean update = false;
			for (GoodsPicture goodsPicture: imgs) {
			TaoBaoGoodsBriefExtra goods = goodsPicture.getGoods();
			if (goods == null) {
			continue;
			}

			if (goods.getAuctionId() == null) {
			update = true;
			goods.setAuctionId(goods.getId());
			}
			}

			if (update) {
			dynamicInfo.setImgs(imgs);
			dynamicInfoDao.updateGoodInfo(dynamicInfo);
			}
			}
			JsonUtil.printMode(out, null, JsonUtil.loadTrueResult("操作成功"));
			// JsonUtil.printMode(out, null, JsonUtil.loadTrueResult(JsonUtil.getSimpleGson().toJson(list)));
			} catch (Exception e) {
			JsonUtil.printMode(out, null, JsonUtil.loadFalseResult("操作失败"));
			Set<String> sets = jedis.keys("rs-*");
			for (Iterator<String> its = sets.iterator(); its.hasNext();)
			array.add(its.next());
			} finally {
			jedis.close();
			}
			out.println(array.toString());
			}

			@RequestMapping(value = "pushOppo")
			public void pushOppo(String registerId, PrintWriter out) {
			List<String> registerIds = new ArrayList<>();
			registerIds.add(registerId);
			try {
			OPPOPushUtil.pushUrl(registerIds, "测试网页推送", "测试网页推送内容", "http://www.baidu.com");
			} catch (PushException e) {
			e.printStackTrace();
			}

			try {
			OPPOPushUtil.pushGoods(registerIds, "测试商品网页推送", "测试商品推送内容", 1, 577628549116L);
			} catch (PushException e) {
			e.printStackTrace();
			}

			try {
			OPPOPushUtil.pushUserSignInNotification(registerIds, "测试签到推送", "测试签到推送");
			} catch (PushException e) {
			e.printStackTrace();
			}
			try {
			OPPOPushUtil.pushWelfareCenter(registerIds, "测试福利中心推送", "测试福利中心推送");
			} catch (PushException e) {
			e.printStackTrace();
			}
			try {
			OPPOPushUtil.pushZNX(registerIds, "测试站内信推送", "测试站内信推送");
			} catch (PushException e) {
			e.printStackTrace();
			}

			out.print("success");
			}

			@RequestMapping("getLocalTime")
			public void getLocalTime(PrintWriter out) {
			out.print(TimeUtil.getGernalTime(System.currentTimeMillis(), "yyyy-MM-dd HH:mm:ss"));
			}

			@RequestMapping("getSchedulerList")
			public void getSchedulerList(PrintWriter out) {
			try {
			for (String groupName : scheduler.getJobGroupNames()) {
			System.out.println(groupName);
			}
			} catch (Exception e) {
			}
			}
			}