From 5f01b1bf63bd3dd242fc29e012e15c37fc03a190 Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期一, 10 十二月 2018 17:30:17 +0800 Subject: [PATCH] 分享赚比例修改 增加单品的分享记录 --- fanli/src/main/java/com/yeshi/fanli/controller/client/ShareController.java | 177 ++++++++++++++++++++++++++++++++++++++++++++++++++++------ 1 files changed, 157 insertions(+), 20 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/controller/client/ShareController.java b/fanli/src/main/java/com/yeshi/fanli/controller/client/ShareController.java index 5bce526..076deeb 100644 --- a/fanli/src/main/java/com/yeshi/fanli/controller/client/ShareController.java +++ b/fanli/src/main/java/com/yeshi/fanli/controller/client/ShareController.java @@ -7,29 +7,38 @@ import java.util.List; import javax.annotation.Resource; +import javax.servlet.http.HttpServletRequest; + +import net.sf.json.JSONArray; +import net.sf.json.JSONObject; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; - -import com.mongodb.util.ThreadUtil; -import com.yeshi.fanli.entity.accept.AcceptData; -import com.yeshi.fanli.entity.bus.share.UserShareGoodsHistory; -import com.yeshi.fanli.entity.bus.user.UserInfo; -import com.yeshi.fanli.entity.taobao.TaoBaoLink; -import com.yeshi.fanli.exception.ShareGoodsException; -import com.yeshi.fanli.service.impl.goods.ShareGoodsServiceImpl; -import com.yeshi.fanli.service.inter.config.ConfigService; -import com.yeshi.fanli.service.inter.goods.ShareGoodsService; -import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService; -import com.yeshi.fanli.util.AESUtil; -import com.yeshi.fanli.util.Constant; -import com.yeshi.fanli.util.StringUtil; -import com.yeshi.fanli.util.taobao.TaoBaoUtil; +import org.springframework.web.bind.annotation.RequestMethod; import org.yeshi.utils.HttpUtil; import org.yeshi.utils.JsonUtil; import org.yeshi.utils.taobao.TbImgUtil; -import net.sf.json.JSONObject; +import com.yeshi.fanli.entity.accept.AcceptData; +import com.yeshi.fanli.entity.bus.share.UserShareGoodsGroup; +import com.yeshi.fanli.entity.bus.share.UserShareGoodsHistory; +import com.yeshi.fanli.entity.bus.share.UserShareGoodsRecord; +import com.yeshi.fanli.entity.bus.share.UserShareGoodsRecord.ShareSourceTypeEnum; +import com.yeshi.fanli.entity.bus.user.UserInfo; +import com.yeshi.fanli.entity.taobao.TaoBaoLink; +import com.yeshi.fanli.exception.ShareGoodsException; +import com.yeshi.fanli.exception.share.UserShareGoodsRecordException; +import com.yeshi.fanli.service.inter.config.ConfigService; +import com.yeshi.fanli.service.inter.goods.ShareGoodsService; +import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService; +import com.yeshi.fanli.service.inter.monitor.MonitorService; +import com.yeshi.fanli.service.inter.user.UserShareGoodsGroupService; +import com.yeshi.fanli.service.inter.user.UserShareGoodsRecordService; +import com.yeshi.fanli.util.AESUtil; +import com.yeshi.fanli.util.Constant; +import com.yeshi.fanli.util.StringUtil; +import com.yeshi.fanli.util.factory.MonitorFactory; +import com.yeshi.fanli.util.taobao.TaoBaoUtil; @Controller(value = "ShareController1") @RequestMapping("api/v1/share") @@ -43,6 +52,15 @@ @Resource private HongBaoManageService hongBaoManageService; + + @Resource + private MonitorService monitorService; + + @Resource + private UserShareGoodsRecordService userShareGoodsRecordService; + + @Resource + private UserShareGoodsGroupService userShareGoodsGroupService; // 鑾峰彇鍟嗗搧鍒嗕韩閾炬帴 @RequestMapping(value = "getGoodsShareUrl") @@ -61,7 +79,8 @@ * @param out */ @RequestMapping(value = "gettaobaosharelink") - public void getTaobaoShareLink(AcceptData acceptData, Long uid, Long auctionId, PrintWriter out) { + public void getTaobaoShareLink(AcceptData acceptData, Long uid, Long auctionId, HttpServletRequest request, + PrintWriter out) { if (uid == null || uid <= 0) { out.print(JsonUtil.loadFalseResult(1, "鐢ㄦ埛ID涓嶈兘涓虹┖")); return; @@ -87,7 +106,8 @@ data.put("clickUrl", url); data.put("token", taoBaoLink.getTaoToken()); - data.put("rule", "http://flq.yeshitv.com/fanli/client/html/help_item.html?id=8"); + data.put("rule", + "http://apph5.yeshitv.com/apppage/all_help_content.html?id=148&from=singlemessage&isappinstalled=0"); data.put("pictUrl", TbImgUtil.getTBSizeImg(taoBaoLink.getGoods().getPictUrl(), 500)); String shareText = ""; @@ -107,10 +127,20 @@ } shareText = shareText.replace("[浠锋牸绫诲瀷]", shopType); data.put("shareText", shareText); - data.put("descText", shareText.replace(taoBaoLink.getGoods().getTitle(), "")); + String descText = shareText.replace(taoBaoLink.getGoods().getTitle() + "\r\n", ""); + if (descText.startsWith("\\r\\n")) + descText = descText.substring(0); + data.put("descText", descText); + // + String imgs = configService.get("goods_share_notify_imgs"); + JSONArray array = JSONArray.fromObject(imgs); + int p = (int) (array.size() * Math.random()); + if (p < array.size()) + data.put("notifyPicture", array.optString(p)); + data.put("notifyDesc", configService.get("goods_share_notify")); // 娣诲姞鍒嗕韩璁板綍 - BigDecimal rate = new BigDecimal(hongBaoManageService.get("hongbao_goods_proportion")); + BigDecimal rate = hongBaoManageService.getFanLiRate(); UserShareGoodsHistory history = new UserShareGoodsHistory(); history.setTkCode(taoBaoLink.getTaoToken()); history.setLink(taoBaoLink.getClickUrl()); @@ -136,13 +166,120 @@ @Override public void run() { shareGoodsService.addShareGoodsHistory(history); + try { + userShareGoodsRecordService.save(uid, ShareSourceTypeEnum.goodsDetail, taoBaoLink.getGoods()); + } catch (UserShareGoodsRecordException e) { + e.printStackTrace(); + } } }); return; } catch (ShareGoodsException e) { + try { + monitorService.addClientAPIMonitor(MonitorFactory.createClientAPI(request, e.getCode(), 0, "鍒嗕韩鍑洪敊")); + } catch (Exception e1) { + } out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMessage())); } } + /** + * 鍒嗕韩璁板綍缁熻鍒楄〃 + * + * @param acceptData + * @param page + * 鍒濆1 + * @param uid + * @param source + * @param out + */ + @RequestMapping(value = "getlistrecord", method = RequestMethod.POST) + public void getListRecord(AcceptData acceptData, Integer page, Long uid, String source, PrintWriter out) { + + if (page == null || page < 1) { + out.print(JsonUtil.loadFalseResult("椤电爜涓嶆纭�")); + } + + if (uid == null) { + out.print(JsonUtil.loadFalseResult("鐢ㄦ埛鏈櫥褰�")); + } + + try { + int pageSize = Constant.PAGE_SIZE; + + JSONObject data = new JSONObject(); + List<UserShareGoodsRecord> list = new ArrayList<UserShareGoodsRecord>(); + + long count = userShareGoodsRecordService.countQueryByUid(uid, source); + + if (count > 0) { + list = userShareGoodsRecordService.getMyShareGoodsRecords((page - 1) * pageSize, pageSize, uid, source); + } + + data.put("count", count); + data.put("result_list", list); + out.print(JsonUtil.loadTrueResult(data)); + + } catch (Exception e) { + out.print(JsonUtil.loadFalseResult("鍔犺浇澶辫触")); + e.printStackTrace(); + } + } + + /** + * 鑾峰彇鍒嗕韩鍟嗗搧 + * + * @param acceptData + * @param recordId + * @param out + */ + @RequestMapping(value = "getrecordgoods", method = RequestMethod.POST) + public void getRecordGoods(AcceptData acceptData, Long recordId, PrintWriter out) { + + if (recordId == null) { + out.print(JsonUtil.loadFalseResult("鍙傛暟涓嶆纭�")); + } + + try { + JSONObject data = userShareGoodsGroupService.getGoodsGroup(recordId); + out.print(JsonUtil.loadTrueResult(data)); + } catch (Exception e) { + out.print(JsonUtil.loadFalseResult("鍔犺浇澶辫触")); + e.printStackTrace(); + } + } + + /** + * 鑾峰彇鍒嗕韩鍟嗗搧鍗曚釜缁熻淇℃伅 + * + * @param acceptData + * @param groupId + * @param out + */ + @RequestMapping(value = "getgoodsdata", method = RequestMethod.POST) + public void getGoodsData(AcceptData acceptData, Long groupId, PrintWriter out) { + + if (groupId == null) { + out.print(JsonUtil.loadFalseResult("鍙傛暟涓嶆纭�")); + } + + try { + UserShareGoodsGroup userShareGoodsGroup = userShareGoodsGroupService.selectByPrimaryKey(groupId); + if (userShareGoodsGroup != null) { + userShareGoodsGroup.setBrowseTime(null); + userShareGoodsGroup.setCreateTime(null); + userShareGoodsGroup.setUpdateTime(null); + userShareGoodsGroup.setRecordId(null); + } + + JSONObject data = new JSONObject(); + data.put("goodsData", userShareGoodsGroup); + out.print(JsonUtil.loadTrueResult(data)); + } catch (Exception e) { + out.print(JsonUtil.loadFalseResult("鍔犺浇澶辫触")); + e.printStackTrace(); + } + } + } -- Gitblit v1.8.0