package com.yeshi.fanli.controller.admin;
|
|
import java.io.IOException;
|
import java.io.PrintWriter;
|
import java.math.BigDecimal;
|
import java.util.List;
|
import java.util.UUID;
|
import java.util.regex.Matcher;
|
import java.util.regex.Pattern;
|
|
import javax.annotation.Resource;
|
|
import org.springframework.stereotype.Controller;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RequestMethod;
|
import org.springframework.web.bind.annotation.RequestParam;
|
import org.springframework.web.multipart.commons.CommonsMultipartFile;
|
import org.yeshi.utils.JsonUtil;
|
import org.yeshi.utils.tencentcloud.COSManager;
|
|
import com.yeshi.fanli.entity.bus.recommend.DynamicRecommend;
|
import com.yeshi.fanli.entity.bus.recommend.MaskKey;
|
import com.yeshi.fanli.entity.bus.recommend.RecommendReply;
|
import com.yeshi.fanli.entity.bus.user.UserInfo;
|
import com.yeshi.fanli.entity.taobao.SearchFilter;
|
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
|
import com.yeshi.fanli.entity.taobao.TaoBaoSearchResult;
|
import com.yeshi.fanli.service.MaskKeyService;
|
import com.yeshi.fanli.service.inter.goods.RecommendDetailsService;
|
import com.yeshi.fanli.service.inter.goods.RecommendReplyService;
|
import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;
|
import com.yeshi.fanli.service.inter.user.DynamicRecommendService;
|
import com.yeshi.fanli.service.inter.user.UserInfoService;
|
import com.yeshi.fanli.tag.PageEntity;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.GsonUtil;
|
import com.yeshi.fanli.util.MoneyBigDecimalUtil;
|
import com.yeshi.fanli.util.taobao.TaoBaoUtil;
|
|
import net.sf.json.JSONObject;
|
|
@Controller
|
@RequestMapping("admin/new/api/v1/dynamic")
|
public class DynamicRecommendAdminController {
|
|
@Resource
|
private DynamicRecommendService dynamicRecommendService;
|
|
@Resource
|
private RecommendReplyService recommendReplyService;
|
|
@Resource
|
private RecommendDetailsService recommendDetailsService;
|
|
@Resource
|
private MaskKeyService maskKeyService;
|
|
@Resource
|
private HongBaoManageService hongBaoManageService;
|
|
@Resource
|
private UserInfoService userInfoService;
|
|
/**
|
*
|
* @param key
|
* 1.用户ID 2.用户名称 3.发布内容
|
* @param page
|
* @param out
|
*/
|
@RequestMapping(value = "getDynamicRecommends", method = RequestMethod.POST)
|
public void getDynamicRecommends(String key, int page, int type, PrintWriter out) {
|
List<DynamicRecommend> dynamicRecommends = dynamicRecommendService.getDynamicRecommendList(key, type, page);
|
int count = dynamicRecommendService.getCount(key, type);
|
PageEntity pe = new PageEntity();
|
pe.setPageIndex(page);
|
pe.setPageSize(Constant.PAGE_SIZE);
|
pe.setTotalCount(count);
|
JSONObject data = new JSONObject();
|
data.put("count", count);
|
data.put("pe", pe);
|
data.put("dynamicRecommends", GsonUtil.toJsonByUserAp(dynamicRecommends));
|
out.append(JsonUtil.loadTrueResult(data));
|
}
|
|
@RequestMapping(value = "deleteDynamicRecommends", method = RequestMethod.POST)
|
public void deleteDynamicRecommends(long[] drids, PrintWriter out) {
|
for (long id : drids) {
|
dynamicRecommendService.delete(id);
|
}
|
out.print(JsonUtil.loadTrueResult(""));
|
}
|
|
@RequestMapping(value = "getRecommendReplys", method = RequestMethod.POST)
|
public void getRecommendReplys(long drid, int page, PrintWriter out) {
|
List<RecommendReply> list = recommendReplyService.getRecommendReplys(drid, page);
|
int count = recommendReplyService.getCount(drid);
|
PageEntity pe = new PageEntity();
|
pe.setPageIndex(page);
|
pe.setPageSize(Constant.PAGE_SIZE);
|
pe.setTotalCount(count);
|
JSONObject data = new JSONObject();
|
data.put("count", count);
|
data.put("pe", pe);
|
data.put("list", GsonUtil.toJsonByUserAp(list));
|
out.append(JsonUtil.loadTrueResult(data));
|
}
|
|
@RequestMapping(value = "deleteRecommendReplys", method = RequestMethod.POST)
|
public void deleteRecommendReplys(long[] rrids, PrintWriter out) {
|
for (long id : rrids) {
|
recommendReplyService.delete(id);
|
}
|
out.print(JsonUtil.loadTrueResult(""));
|
}
|
|
@RequestMapping(value = "getMaskKeys", method = RequestMethod.POST)
|
public void getMaskKeys(String key, int page, PrintWriter out) {
|
List<MaskKey> list = maskKeyService.getMaskKeys(key, page);
|
int count = maskKeyService.getCount(key);
|
PageEntity pe = new PageEntity();
|
pe.setPageIndex(page);
|
pe.setPageSize(Constant.PAGE_SIZE);
|
pe.setTotalCount(count);
|
JSONObject data = new JSONObject();
|
data.put("count", count);
|
data.put("pe", pe);
|
data.put("list", GsonUtil.toJson(list));
|
out.append(JsonUtil.loadTrueResult(data));
|
}
|
|
@RequestMapping(value = "addMaskKey", method = RequestMethod.POST)
|
public void addMaskKey(String key, PrintWriter out) {
|
long id = maskKeyService.addMaskKey(key);
|
if (id > 0) {
|
out.append(JsonUtil.loadTrueResult(""));
|
return;
|
} else {
|
out.append(JsonUtil.loadFalseResult("添加失败"));
|
}
|
}
|
|
@RequestMapping(value = "deleteMaskKeys", method = RequestMethod.POST)
|
public void deleteMaskKeys(long[] ids, PrintWriter out) {
|
for (long id : ids) {
|
maskKeyService.delete(id);
|
}
|
out.append(JsonUtil.loadTrueResult(""));
|
}
|
|
@RequestMapping(value = "getGoodsInfo", method = RequestMethod.POST)
|
public void getGoodsInfo(String url, PrintWriter out) {
|
|
TaoBaoGoodsBrief tb = null;
|
String URL_REGEX = "(((http|https)://)|(www\\.))[a-zA-Z0-9\\._-]+\\.[a-zA-Z]{2,6}(:[0-9]{1,4})?(/[a-zA-Z0-9\\&%_\\./-~-]*)?";
|
|
Pattern p = Pattern.compile(URL_REGEX);
|
Matcher matcher = p.matcher(url);
|
if (!matcher.find()) {
|
out.print(JsonUtil.loadFalseResult("暂不支持该类型！"));
|
return;
|
}
|
url = matcher.group();
|
if (url.contains("ju.taobao.com") || url.contains(".juhuasuan.com")) {// 聚划�?
|
int index = url.indexOf("item_id");
|
if (index < 0) {
|
out.println(JsonUtil.loadFalseResult("暂未找到该商品，请稍后再试！"));
|
return;
|
}
|
url = url.substring(index);
|
int last = url.indexOf("&");
|
String id = "";
|
if (last > 0)
|
id = url.substring(url.indexOf("=") + 1, url.indexOf("&"));
|
else {
|
id = url.substring(url.indexOf("=" + 1));
|
}
|
tb = TaoBaoUtil.isAlimama(id);
|
if (tb == null) {
|
tb = TaoBaoUtil.parsePhoneTmAndTb(id);
|
}
|
} else if (url.contains("http://zmnxbc.com")) { // 手机端天猫APP分享
|
tb = TaoBaoUtil.parsePhoneShareUrlByTM(url);
|
} else if (url.contains("c.b1yt.com")) { // 手机端淘宝和�?��APP分享
|
tb = TaoBaoUtil.parsePhoneShareUrlByTB(url);
|
} else if (url.contains("h5.m.taobao") || url.contains("detail.m.tmall") || url.contains("item.taobao")
|
|| url.contains("detail.tmall")) { // 手机页面和电脑页�?
|
int index = url.indexOf("id");
|
if (index < 0) {
|
out.println(JsonUtil.loadFalseResult("暂未找到该商品，请稍后再试！"));
|
return;
|
}
|
url = url.substring(index);
|
int last = url.indexOf("&");
|
String id = "";
|
if (last > 0)
|
id = url.substring(url.indexOf("=") + 1, url.indexOf("&"));
|
else {
|
id = url.substring(url.indexOf("=") + 1);
|
}
|
tb = TaoBaoUtil.isAlimama(id);
|
if (tb == null) {
|
tb = TaoBaoUtil.parsePhoneTmAndTb(id);
|
}
|
}
|
|
if (tb == null) {
|
out.println(JsonUtil.loadFalseResult("暂未找到该商品，请稍后再试！"));
|
return;
|
}
|
JSONObject data = new JSONObject();
|
JSONObject taoBaoGoodsJSON = new JSONObject();
|
taoBaoGoodsJSON.put("title", tb.getTitle());
|
taoBaoGoodsJSON.put("zkPrice", tb.getZkPrice());
|
taoBaoGoodsJSON.put("auctionId", tb.getAuctionId());
|
data.put("taoBaoGoodsBrief", taoBaoGoodsJSON);
|
data.put("tbImgs", tb.getImgList());
|
out.print(JsonUtil.loadTrueResult(data));
|
|
}
|
|
@RequestMapping(value = "makePublic", method = RequestMethod.POST)
|
public void makePublic(DynamicRecommend dynamicRecommend,
|
@RequestParam(value = "files", required = false) CommonsMultipartFile[] files, PrintWriter out) {
|
if (dynamicRecommend == null) {
|
out.print(JsonUtil.loadFalseResult("dynamicRecommend不能为空"));
|
return;
|
}
|
if (dynamicRecommend.getReason() == null || "".equals(dynamicRecommend.getReason().trim())) {
|
out.print(JsonUtil.loadFalseResult("推荐理由不能为空"));
|
return;
|
}
|
if (dynamicRecommend.getAuctionId() == null) {
|
out.print(JsonUtil.loadFalseResult("商品ID不能为空"));
|
return;
|
}
|
if (dynamicRecommend.getUrl() == null || "".equals(dynamicRecommend.getUrl().trim())) {
|
out.print(JsonUtil.loadFalseResult("url不能为空"));
|
return;
|
}
|
if (dynamicRecommend.getuPicUrl() == null && files == null) {
|
out.print(JsonUtil.loadFalseResult("请选择一张图片"));
|
return;
|
}
|
|
String URL_REGEX = "(((http|https)://)|(www\\.))[a-zA-Z0-9\\._-]+\\.[a-zA-Z]{2,6}(:[0-9]{1,4})?(/[a-zA-Z0-9\\&%_\\./-~-]*)?";
|
|
Pattern p = Pattern.compile(URL_REGEX);
|
Matcher matcher = p.matcher(dynamicRecommend.getUrl());
|
if (!matcher.find()) {
|
out.print(JsonUtil.loadFalseResult("暂不支持该类型！"));
|
return;
|
}
|
String url = matcher.group();
|
dynamicRecommend.setUrl(url);
|
if (files != null) {
|
COSManager cosManager = COSManager.getInstance();
|
String paths = "";
|
for (CommonsMultipartFile file : files) {
|
try {
|
String filename = file.getOriginalFilename();
|
int index = filename.lastIndexOf(".");
|
String type = filename.substring(index);
|
String filePath = cosManager
|
.uploadFile(file.getInputStream(), UUID.randomUUID().toString().replace("-", "") + type)
|
.getUrl();
|
paths += "," + filePath;
|
} catch (IOException e) {
|
e.printStackTrace();
|
out.println(JsonUtil.loadFalseResult("上传图片失败"));
|
return;
|
}
|
}
|
paths = paths.replaceFirst(",", "");
|
String getuPicUrl = dynamicRecommend.getuPicUrl();
|
if (getuPicUrl == null) {
|
dynamicRecommend.setuPicUrl(paths);
|
} else {
|
dynamicRecommend.setuPicUrl(getuPicUrl + "," + paths);
|
}
|
}
|
|
TaoBaoGoodsBrief taoBaoGoodsBrief = null;
|
taoBaoGoodsBrief = TaoBaoUtil.isAlimama(dynamicRecommend.getAuctionId());
|
if (taoBaoGoodsBrief == null) {
|
taoBaoGoodsBrief = TaoBaoUtil.parsePhoneTmAndTb(dynamicRecommend.getAuctionId());
|
dynamicRecommend.setHongbao(new BigDecimal(0));
|
} else {
|
SearchFilter filter = new SearchFilter();
|
filter.setKey(String.format(TaoBaoUtil.TB_URL, dynamicRecommend.getAuctionId()));
|
TaoBaoSearchResult search = TaoBaoUtil.search(filter);
|
List<TaoBaoGoodsBrief> taoBaoGoodsBriefs = search.getTaoBaoGoodsBriefs();
|
if (taoBaoGoodsBriefs.size() == 0) {
|
out.println(JsonUtil.loadFalseResult("发布失败,商品已下架"));
|
return;
|
}
|
taoBaoGoodsBrief = taoBaoGoodsBriefs.get(0);
|
BigDecimal proportion = hongBaoManageService.getFanLiRate();
|
BigDecimal tkRate = taoBaoGoodsBrief.getTkRate();
|
BigDecimal zkPrice = taoBaoGoodsBrief.getZkPrice();
|
BigDecimal tkp = proportion.divide(BigDecimal.valueOf(100))
|
.multiply(tkRate.divide(BigDecimal.valueOf(100)));
|
BigDecimal hongbao = MoneyBigDecimalUtil.mul(zkPrice, tkp);
|
dynamicRecommend.setHongbao(hongbao);
|
}
|
String title = taoBaoGoodsBrief.getTitle();
|
int type = taoBaoGoodsBrief.getUserType();
|
dynamicRecommend.setGname(title);
|
dynamicRecommend.setZkPrice(taoBaoGoodsBrief.getZkPrice());
|
dynamicRecommend.setgPicUrl(taoBaoGoodsBrief.getPictUrl());
|
dynamicRecommend.setCreatetime(System.currentTimeMillis());
|
if (type == 0) { // tb
|
dynamicRecommend.setGoodsType(1); // tb
|
} else {
|
dynamicRecommend.setGoodsType(2); // 天猫
|
}
|
String reason = dynamicRecommend.getReason();
|
reason = maskKeyService.maskAction(reason);
|
dynamicRecommend.setReason(reason);
|
|
long u = userInfoService.getRandomShamUser();
|
if (u == 0) {
|
out.print(JsonUtil.loadFalseResult("暂无虚拟用户"));
|
return;
|
}
|
dynamicRecommend.setUserInfo(new UserInfo(u));
|
dynamicRecommend.setType(1);
|
long makePublic = dynamicRecommendService.makePublic(dynamicRecommend);
|
if (makePublic > 0) {
|
JSONObject data = new JSONObject();
|
data.put("auctionId", makePublic);
|
out.println(JsonUtil.loadTrueResult(data));
|
} else {
|
out.println(JsonUtil.loadFalseResult("发布失败"));
|
}
|
}
|
|
}
|
