package com.yeshi.fanli.controller.admin;
|
|
import java.io.PrintWriter;
|
import java.math.BigDecimal;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletRequest;
|
|
import org.springframework.stereotype.Controller;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.yeshi.utils.JsonUtil;
|
import org.yeshi.utils.taobao.TbImgUtil;
|
|
import com.google.gson.Gson;
|
import com.google.gson.GsonBuilder;
|
import com.google.gson.reflect.TypeToken;
|
import com.yeshi.fanli.entity.bus.lable.BoutiqueAutoRule;
|
import com.yeshi.fanli.entity.bus.lable.Label;
|
import com.yeshi.fanli.entity.bus.lable.LabelGoods;
|
import com.yeshi.fanli.entity.bus.lable.QualityFactory;
|
import com.yeshi.fanli.entity.common.AdminUser;
|
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
|
import com.yeshi.fanli.exception.goods.quality.QualityFactoryException;
|
import com.yeshi.fanli.service.inter.goods.TaoBaoGoodsBriefService;
|
import com.yeshi.fanli.service.inter.lable.LabelGoodsService;
|
import com.yeshi.fanli.service.inter.lable.LabelService;
|
import com.yeshi.fanli.service.inter.lable.QualityFactoryService;
|
import com.yeshi.fanli.service.inter.taobao.TaoBaoGoodsUpdateService;
|
import com.yeshi.fanli.tag.PageEntity;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.MoneyBigDecimalUtil;
|
import com.yeshi.fanli.util.RedisManager;
|
import com.yeshi.fanli.util.StringUtil;
|
import com.yeshi.fanli.util.taobao.TaoBaoUtil;
|
import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
|
import com.yeshi.fanli.vo.quality.QualityFactoryVO;
|
|
import net.sf.json.JSONObject;
|
|
@Controller
|
@RequestMapping("admin/new/api/v1/qualityFactory")
|
public class QualityFactoryAdminController {
|
|
@Resource
|
private RedisManager redisManager;
|
@Resource
|
private LabelService labelService;
|
@Resource
|
private LabelGoodsService labelGoodsService;
|
@Resource
|
private QualityFactoryService qualityFactoryService;
|
@Resource
|
private TaoBaoGoodsBriefService taoBaoGoodsBriefService;
|
@Resource
|
private TaoBaoGoodsUpdateService taoBaoGoodsUpdateService;
|
|
public static final int SALES_ASC = 1;
|
public static final int SALES_DESC = 2;
|
|
public static final int PRICE_ASC = 3;
|
public static final int PRICE_DESC = 4;
|
|
public static final int TKRATE_ASC = 5;
|
public static final int TKRATE_DESC = 6;
|
|
public static final int PROPOR_ASC = 7;
|
public static final int PROPOR_DESC = 8;
|
|
/**
|
* 保存修改精品库商品关联信息
|
*
|
* @param callback
|
* @param label
|
* @param request
|
* @param out
|
*/
|
@RequestMapping(value = "saveModify")
|
public void saveModify(String callback, QualityFactory selectionGoods, HttpServletRequest request,
|
PrintWriter out) {
|
|
try {
|
AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN);
|
|
if (admin == null) {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("当前账户已失效,请重新登陆")));
|
} else {
|
|
Long id = selectionGoods.getId();
|
QualityFactory resultObj = qualityFactoryService.selectByPrimaryKey(id);
|
|
if (resultObj == null) {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("该商品已不在精品库中")));
|
} else {
|
Date nowTime = new Date();
|
selectionGoods.setUpdatetime(nowTime);
|
selectionGoods.setUpdateUser(admin);
|
// 选择性更新数据
|
int result = qualityFactoryService.updateByPrimaryKeySelective(selectionGoods);
|
|
if (result > 0) {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult("修改成功")));
|
} else {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("修改失败")));
|
}
|
}
|
}
|
|
} catch (QualityFactoryException e) {
|
e.printStackTrace();
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常")));
|
}
|
|
}
|
|
/**
|
* 统计商品数量
|
*
|
* @param callback
|
* @param out
|
*/
|
@RequestMapping(value = "getCountAll")
|
public void getCountAll(String callback, PrintWriter out) {
|
|
try {
|
|
Map<String, Object> countMap = qualityFactoryService.getCountAll();
|
|
JSONObject data = new JSONObject();
|
data.put("countData", countMap);
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data)));
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("系统异常")));
|
}
|
}
|
|
/**
|
* 批量移除商品至精品库外-不删除商品
|
*
|
* @param callback
|
* @param ids
|
* 商品id
|
* @param out
|
*/
|
@RequestMapping(value = "removeGoods")
|
public void removeGoods(String callback, String ids, PrintWriter out) {
|
try {
|
Gson gson = new Gson();
|
List<Long> goodsIds = gson.fromJson(ids, new TypeToken<ArrayList<Long>>() {
|
}.getType());
|
|
if (goodsIds == null || goodsIds.size() == 0) {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("未检测到移除商品数据")));
|
return;
|
}
|
|
qualityFactoryService.deleteBatchByTaoBaoGoodsId(goodsIds);
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult("移除成功")));
|
} catch (Exception e) {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作失败")));
|
e.printStackTrace();
|
}
|
|
}
|
|
/**
|
* 查询
|
*
|
* @param out
|
*/
|
@RequestMapping(value = "query")
|
public void query(String callback, Integer pageIndex, Integer pageSize, Integer sort,
|
QualityFactoryVO qualityFactoryVO, PrintWriter out) {
|
|
try {
|
if (pageSize == null)
|
pageSize = Constant.PAGE_SIZE;
|
|
if (pageIndex == null)
|
pageIndex = 1;
|
|
Integer price = null;
|
Integer tkRate = null;
|
Integer totalSales = null;
|
Integer propor = null;
|
|
if (sort != null) {
|
switch (sort) {
|
case SALES_ASC:
|
totalSales = 1;
|
break;
|
case SALES_DESC:
|
totalSales = 2;
|
break;
|
case PRICE_ASC:
|
price = 1;
|
break;
|
case PRICE_DESC:
|
price = 2;
|
break;
|
case TKRATE_ASC:
|
tkRate = 1;
|
break;
|
case TKRATE_DESC:
|
tkRate = 2;
|
break;
|
case PROPOR_ASC:
|
propor = 1;
|
break;
|
case PROPOR_DESC:
|
propor = 2;
|
break;
|
default:
|
break;
|
}
|
}
|
|
qualityFactoryVO.setPrice(price);
|
qualityFactoryVO.setTkRate(tkRate);
|
qualityFactoryVO.setTotalSales(totalSales);
|
qualityFactoryVO.setPropor(propor);
|
qualityFactoryVO.setStart((pageIndex - 1) * pageSize);
|
qualityFactoryVO.setCount(pageSize);
|
|
List<QualityFactory> selectionList = qualityFactoryService.query(qualityFactoryVO);
|
|
/* 暂无数据显示 */
|
if (selectionList == null || selectionList.size() == 0) {
|
JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无数据"));
|
return;
|
}
|
|
/* 有数据：处理返回格式 */
|
|
long count = qualityFactoryService.queryCount(qualityFactoryVO);
|
|
int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);
|
|
PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage);
|
|
List<Map<String, Object>> listmap = new ArrayList<Map<String, Object>>();
|
|
/* 验证网络: 获取商品链接 图片链接 */
|
List<TaoBaoGoodsBrief> goodsBriefList = new ArrayList<TaoBaoGoodsBrief>();
|
|
StringBuffer idBuf = new StringBuffer();
|
StringBuffer auctionIdBuf = new StringBuffer();
|
|
int j = 0;
|
for (int i = 0; i < selectionList.size(); i++) {
|
QualityFactory selectionGoods = selectionList.get(i);
|
|
TaoBaoGoodsBrief taoBaoGoodsBrief = selectionGoods.getTaoBaoGoodsBrief();
|
if (taoBaoGoodsBrief == null)
|
continue; // 为空结束本次循环
|
|
Long id = taoBaoGoodsBrief.getId();
|
idBuf.append(id + ",");
|
|
Long auctionId = taoBaoGoodsBrief.getAuctionId();
|
if (auctionId != null) {
|
j++;
|
auctionIdBuf.append(auctionId + ",");
|
}
|
|
if (selectionList.size() <= 40) {
|
// 小于40个参数
|
if (i == selectionList.size() - 1) {
|
if (auctionIdBuf != null && auctionIdBuf.length() > 0) {
|
String auctionIds = auctionIdBuf.toString();
|
String ids = auctionIds.substring(0, auctionIds.length() - 1);
|
List<TaoBaoGoodsBrief> list = null;
|
try {
|
list = TaoKeApiUtil.getBatchGoodsInfos(ids);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
|
if (list != null && list.size() > 0) {
|
goodsBriefList.addAll(list);
|
}
|
|
auctionIdBuf = new StringBuffer();
|
}
|
}
|
} else {
|
if (j == 40) {
|
// 大于40参数
|
String auctionIds = auctionIdBuf.toString();
|
String ids = auctionIds.substring(0, auctionIds.length() - 1);
|
List<TaoBaoGoodsBrief> list = null;
|
try {
|
list = TaoKeApiUtil.getBatchGoodsInfos(ids);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
|
if (list != null && list.size() > 0) {
|
goodsBriefList.addAll(list);
|
}
|
|
j = 0;
|
auctionIdBuf = new StringBuffer();
|
|
} else if (i == selectionList.size() - 1) {
|
// 最后一个
|
String auctionIds = auctionIdBuf.toString();
|
String ids = auctionIds.substring(0, auctionIds.length() - 1);
|
List<TaoBaoGoodsBrief> list = null;
|
try {
|
list = TaoKeApiUtil.getBatchGoodsInfos(ids);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
|
if (list != null && list.size() > 0) {
|
goodsBriefList.addAll(list);
|
}
|
auctionIdBuf = new StringBuffer();
|
}
|
}
|
|
}
|
|
for (QualityFactory selectionGoods : selectionList) {
|
|
TaoBaoGoodsBrief taoBaoGoodsBrief = selectionGoods.getTaoBaoGoodsBrief();
|
|
if (taoBaoGoodsBrief == null)
|
continue; // 为空结束本次循环
|
|
// 设置图片大小
|
taoBaoGoodsBrief.setPictUrl(TbImgUtil.getTBSize220Img(taoBaoGoodsBrief.getPictUrl()));
|
|
String auctionUrl = taoBaoGoodsBrief.getAuctionUrl();
|
if (auctionUrl != null && auctionUrl.trim().length() > 0 && auctionUrl.contains("id=null")) {
|
auctionUrl = auctionUrl.replace("id=null", "id=" + taoBaoGoodsBrief.getAuctionId());
|
taoBaoGoodsBrief.setAuctionUrl(auctionUrl);
|
}
|
|
Map<String, Object> map = new HashMap<String, Object>();
|
|
BoutiqueAutoRule boutiqueAutoRule = selectionGoods.getBoutiqueAutoRule();
|
if (boutiqueAutoRule == null) {
|
boutiqueAutoRule = new BoutiqueAutoRule();
|
selectionGoods.setBoutiqueAutoRule(boutiqueAutoRule);
|
}
|
|
String reslutSource = "";
|
Integer gsSource = selectionGoods.getGoodsSource();
|
if (QualityFactory.SOURCE_TAOBAO == gsSource) {
|
reslutSource = "淘宝";
|
} else if (QualityFactory.SOURCE_TAOBAO_MATERIAL == gsSource) {
|
reslutSource = "淘宝推荐";
|
} else if (QualityFactory.SOURCE_TAOBAO_DATAOKE == gsSource) {
|
reslutSource = "大淘客";
|
} else if (QualityFactory.SOURCE_JINGDONG == gsSource) {
|
reslutSource = "京东";
|
} else if (QualityFactory.SOURCE_PINDUODUO == gsSource) {
|
reslutSource = "拼多多";
|
} else if (QualityFactory.SOURCE_WEIPINHUI == gsSource) {
|
reslutSource = "唯品会";
|
} else if (QualityFactory.SOURCE_OTHER == gsSource) {
|
reslutSource = "商务合作";
|
}
|
|
map.put("goodsSource", reslutSource);
|
|
map.put("selectionGoods", selectionGoods);
|
|
/* 商品销售状态： 0 在售 1停售 */
|
int saleStae = 1;
|
Long auctionId = taoBaoGoodsBrief.getAuctionId();
|
if (auctionId != null) {
|
if (goodsBriefList != null && goodsBriefList.size() > 0) {
|
for (TaoBaoGoodsBrief tb : goodsBriefList) {
|
Long auctionIdTB = tb.getAuctionId();
|
if (auctionId.equals(auctionIdTB)) {
|
saleStae = 0;
|
}
|
}
|
}
|
}
|
|
map.put("saleStae", saleStae);
|
|
/* 1 定向计划 2 营销返利 、高佣 3 普佣 */
|
Integer includeDxjh = taoBaoGoodsBrief.getIncludeDxjh();
|
String tkMktStatus = taoBaoGoodsBrief.getTkMktStatus();
|
|
boolean include = false;
|
if (includeDxjh != null) {
|
if (includeDxjh == 1) {
|
// 定向计划
|
map.put("yongjinType", 1);
|
include = true;
|
}
|
}
|
|
if (!include) {
|
|
if ("1".equals(tkMktStatus)) {
|
// 营销返利 、高佣
|
map.put("yongjinType", 2);
|
} else {
|
// 普佣
|
map.put("yongjinType", 3);
|
}
|
}
|
|
/* 券后价--计算 */
|
BigDecimal couponPrice = TaoBaoUtil.getAfterUseCouplePrice(taoBaoGoodsBrief);
|
map.put("couponPrice", couponPrice);
|
|
/* 预计收益： 公司、用户 */
|
BigDecimal tkRateBrief = taoBaoGoodsBrief.getTkRate();
|
BigDecimal zkPrice = taoBaoGoodsBrief.getZkPrice();
|
BigDecimal profit = MoneyBigDecimalUtil.mul(tkRateBrief, zkPrice);
|
// 计算结果
|
BigDecimal estimateProfit = MoneyBigDecimalUtil.div(profit, new BigDecimal("100"));
|
// 预计收益
|
map.put("estimateProfit", estimateProfit);
|
|
BigDecimal couponAmount = taoBaoGoodsBrief.getCouponAmount();
|
if (couponAmount != null && zkPrice != null) {
|
BigDecimal propors = couponAmount.divide(zkPrice, 10, BigDecimal.ROUND_HALF_DOWN);
|
BigDecimal resultPropor = MoneyBigDecimalUtil.mul(propors, new BigDecimal("100"));
|
map.put("propor", resultPropor);
|
} else {
|
map.put("propor", 0);
|
}
|
|
/* 商品标签列表 */
|
Long id = taoBaoGoodsBrief.getId();
|
int totalLabels = labelGoodsService.getCountQueryByGoodsId(id);
|
|
// List<LabelGoods> labelList = labelService.getByGoodsId(id);
|
|
map.put("totalLabels", totalLabels);
|
|
listmap.add(map);
|
}
|
|
GsonBuilder gsonBuilder = new GsonBuilder();
|
gsonBuilder.serializeNulls(); // 重点
|
Gson gson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create();
|
|
JSONObject data = new JSONObject();
|
data.put("pe", pe);
|
data.put("listGoods", gson.toJson(listmap));
|
JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));
|
|
} catch (Exception e) {
|
JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常"));
|
e.printStackTrace();
|
}
|
}
|
|
/**
|
* 获取商品信息 以及对应标签列表；此商品标签候选项
|
*
|
* @param callback
|
* @param id
|
* 精选id
|
* @param request
|
* @param out
|
*/
|
@RequestMapping(value = "getGoodsInfo")
|
public void getGoodsInfo(String callback, Long id, HttpServletRequest request, PrintWriter out) {
|
|
try {
|
|
QualityFactory resultObj = qualityFactoryService.selectByPrimaryKey(id);
|
|
if (resultObj == null) {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("该商品已不在精品库中")));
|
return;
|
}
|
|
TaoBaoGoodsBrief taobao = resultObj.getTaoBaoGoodsBrief();
|
if (taobao == null) {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("该商品已不在")));
|
return;
|
}
|
|
// 商品图片
|
List<String> imgList = TaoBaoUtil.getTbImg(taobao.getAuctionId() + "");
|
|
GsonBuilder gsonBuilder = new GsonBuilder();
|
gsonBuilder.serializeNulls(); // 重点
|
Gson gson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create();
|
|
JSONObject data = new JSONObject();
|
// data.put("taobao", gson.toJson(taobao));
|
data.put("imgList", gson.toJson(imgList));
|
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data)));
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常")));
|
}
|
|
}
|
|
/**
|
* 单个商品贴上标签
|
*
|
* @param callback
|
* @param id
|
* @param labId
|
* @param request
|
* @param out
|
*/
|
@RequestMapping(value = "addGoodsLable")
|
public void addGoodsLable(String callback, Long id, Long labId, HttpServletRequest request, PrintWriter out) {
|
|
try {
|
// 获取当前操作用户
|
AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN);
|
// if (admin == null) {
|
// out.print(JsonUtil.loadJSONP(callback,
|
// JsonUtil.loadFalseResult("当前账户失效,请重新登陆。")));
|
// return;
|
// }
|
|
if (id == null || labId == null) {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请传递正确的参数")));
|
return;
|
}
|
|
TaoBaoGoodsBrief taoBaoGoodsBrief = taoBaoGoodsBriefService.selectByPrimaryKey(id);
|
if (taoBaoGoodsBrief == null) {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("该商品已不存在")));
|
return;
|
}
|
|
Label label = labelService.selectByPrimaryKey(labId);
|
if (label == null) {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("该标签已不存在")));
|
return;
|
}
|
|
/* 贴上标签 ： 已贴不处理则 */
|
Long existence = labelGoodsService.isExistence(id, labId);
|
|
// 该商品不存在此标签则添加， 反之不做处理
|
if (existence == null || existence == 0l) {
|
Date nowTime = new Date();
|
// 贴上新标签
|
LabelGoods lg = new LabelGoods();
|
lg.setLabel(label);
|
lg.setCreateUser(admin);
|
lg.setCreatetime(nowTime);
|
lg.setTaoBaoGoodsBrief(taoBaoGoodsBrief);
|
|
int insert = labelGoodsService.insertSelective(lg);
|
if (insert > 0) {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult("添加成功")));
|
} else {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("添加失败")));
|
}
|
} else {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("此商品已存在该标签")));
|
}
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常")));
|
}
|
|
}
|
|
/**
|
* 删除商品关联的标签
|
*
|
* @param callback
|
* @param rid
|
* @param request
|
* @param out
|
*/
|
@RequestMapping(value = "removeSingle")
|
public void removeSingle(String callback, Long rid, HttpServletRequest request, PrintWriter out) {
|
|
try {
|
|
int deleteId = labelGoodsService.deleteByPrimaryKey(rid);
|
|
if (deleteId > 0) {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult("删除成功")));
|
} else {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("删除失败")));
|
}
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常")));
|
}
|
|
}
|
|
/**
|
* 设置商品权重、等信息
|
*
|
* @param callback
|
* @param label
|
* @param request
|
* @param out
|
*/
|
@RequestMapping(value = "saveInfo")
|
public void saveInfo(String callback, QualityFactory selectionGoods, HttpServletRequest request, PrintWriter out) {
|
|
try {
|
AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN);
|
//
|
// if (admin == null) {
|
// out.print(JsonUtil.loadJSONP(callback,
|
// JsonUtil.loadFalseResult("当前账户已失效,请重新登陆")));
|
// return;
|
// }
|
|
Long id = selectionGoods.getId();
|
QualityFactory resultObj = qualityFactoryService.selectByPrimaryKey(id);
|
|
if (resultObj == null) {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("该商品已不在精品库中")));
|
} else {
|
Date nowTime = new Date();
|
selectionGoods.setUpdatetime(nowTime);
|
selectionGoods.setUpdateUser(admin);
|
// 选择性更新数据
|
int result = qualityFactoryService.updateByPrimaryKeySelective(selectionGoods);
|
|
if (result > 0) {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult("修改成功")));
|
} else {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("修改失败")));
|
}
|
}
|
|
} catch (QualityFactoryException e) {
|
e.printStackTrace();
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常")));
|
}
|
|
}
|
|
@RequestMapping(value = "queryMyLabels")
|
public void queryMyLabels(String callback, Integer pageIndex, Integer pageSize, String ids,
|
HttpServletRequest request, PrintWriter out) {
|
|
try {
|
|
if (StringUtil.isNullOrEmpty(ids)) {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请传递正确参数:101")));
|
return;
|
}
|
|
Gson gson = new Gson();
|
List<Long> idList = gson.fromJson(ids, new TypeToken<ArrayList<Long>>() {
|
}.getType());
|
if (idList == null || idList.size() == 0) {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请传递正确参数:102")));
|
return;
|
}
|
|
if (idList.size() > 1) {
|
// 只处理单个商品
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请传递正确参数:103")));
|
return;
|
}
|
|
Long id = idList.get(0);
|
|
if (id == null) {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请传递正确参数:104")));
|
return;
|
}
|
|
if (pageIndex == null)
|
pageIndex = 1;
|
|
if (pageSize == null)
|
pageSize = Constant.PAGE_SIZE;
|
|
// 商品标签列表
|
List<LabelGoods> labelList = labelGoodsService.queryByGoodsId((pageIndex - 1) * pageSize, pageSize, id);
|
|
if (labelList == null || labelList.size() == 0) {
|
JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无标签"));
|
return;
|
}
|
|
int count = labelGoodsService.getCountQueryByGoodsId(id);
|
|
int totalPage = count % pageSize == 0 ? count / pageSize : count / pageSize + 1;
|
PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage);
|
|
GsonBuilder gsonBuilder = new GsonBuilder();
|
gsonBuilder.serializeNulls();
|
Gson rgson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create();
|
|
JSONObject data = new JSONObject();
|
data.put("pe", pe);
|
data.put("labelList", rgson.toJson(labelList));
|
|
JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));
|
|
} catch (Exception e) {
|
JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常"));
|
e.printStackTrace();
|
}
|
}
|
|
/**
|
* 查询商品添加标签候选项
|
*
|
* @param callback
|
* @param pageIndex
|
* @param pageSize
|
* @param key
|
* @param id
|
* @param request
|
* @param out
|
*/
|
@RequestMapping(value = "queryLabel")
|
public void queryLabel(String callback, Integer pageIndex, Integer pageSize, String key, String ids,
|
HttpServletRequest request, PrintWriter out) {
|
|
try {
|
|
if (StringUtil.isNullOrEmpty(ids)) {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请传递正确参数:101")));
|
return;
|
}
|
|
Gson gson = new Gson();
|
List<Long> idList = gson.fromJson(ids, new TypeToken<ArrayList<Long>>() {
|
}.getType());
|
if (idList == null || idList.size() == 0) {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请传递正确参数:102")));
|
return;
|
}
|
|
int count = 0;
|
List<Label> labelList = null;
|
|
if (pageIndex == null)
|
pageIndex = 1;
|
|
if (pageSize == null)
|
pageSize = Constant.PAGE_SIZE;
|
|
if (idList.size() > 1) {
|
// 多个商品 查询所有标签
|
labelList = labelService.query((pageIndex - 1) * pageSize, pageSize, key, null, null, null);
|
|
count = labelService.getQueryCount(key, null, null);
|
|
} else {
|
// 单个商品
|
Long id = idList.get(0);
|
if (id == null) {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请传递正确参数:104")));
|
return;
|
}
|
|
labelList = labelService.queryGoodsCandidate((pageIndex - 1) * pageSize, pageSize, key, id);
|
|
count = labelService.getCountQueryGoodsCandidate(key, id);
|
}
|
|
if (labelList == null || labelList.size() == 0) {
|
JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无标签"));
|
return;
|
}
|
|
int totalPage = count % pageSize == 0 ? count / pageSize : count / pageSize + 1;
|
PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage);
|
|
GsonBuilder gsonBuilder = new GsonBuilder();
|
gsonBuilder.serializeNulls(); // 重点
|
Gson rgson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create();
|
|
JSONObject data = new JSONObject();
|
data.put("pe", pe);
|
data.put("labelList", rgson.toJson(labelList));
|
|
JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));
|
|
} catch (Exception e) {
|
JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常"));
|
e.printStackTrace();
|
}
|
}
|
|
/**
|
* 单个商品批量添加标签-关联lableId
|
*
|
* @param callback
|
* @param id
|
* @param type
|
* @param request
|
* @param out
|
*/
|
@RequestMapping(value = "addBatchcGoodsLabel")
|
public void addBatchcGoodsLabel(String callback, String labIds, Long id, HttpServletRequest request,
|
PrintWriter out) {
|
|
try {
|
if (StringUtil.isNullOrEmpty(labIds)) {
|
JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("未选择标签"));
|
return;
|
}
|
|
if (id == null) {
|
JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("未选择商品"));
|
return;
|
}
|
|
Gson gson = new Gson();
|
List<String> labIdList = gson.fromJson(labIds, new TypeToken<ArrayList<String>>() {
|
}.getType());
|
if (labIdList == null || labIdList.size() == 0) {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请选择标签")));
|
return;
|
}
|
|
TaoBaoGoodsBrief taoBaoGoodsBrief = taoBaoGoodsBriefService.selectByPrimaryKey(id);
|
|
// 获取当前操作用户
|
AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN);
|
labelGoodsService.addBatchByLabId(taoBaoGoodsBrief, labIdList, admin);
|
|
JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("操作成功"));
|
|
} catch (Exception e) {
|
JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作异常"));
|
e.printStackTrace();
|
}
|
}
|
|
@RequestMapping(value = "updateGoodsBrief")
|
public void updateGoodsBrief(String callback, TaoBaoGoodsBrief tb, PrintWriter out) {
|
try {
|
|
// 实际未精选ID
|
Long id = tb.getId();
|
|
QualityFactory resultObj = qualityFactoryService.selectByPrimaryKey(id);
|
|
if (resultObj == null) {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("该商品已不在精品库中")));
|
return;
|
}
|
|
TaoBaoGoodsBrief taobao = resultObj.getTaoBaoGoodsBrief();
|
if (taobao == null) {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("该商品已不在")));
|
return;
|
}
|
|
String title = tb.getTitle();
|
String pictUrl = tb.getPictUrl();
|
|
if (!StringUtil.isNullOrEmpty(title))
|
taobao.setTitle(title);
|
|
if (!StringUtil.isNullOrEmpty(pictUrl))
|
taobao.setPictUrl(pictUrl);
|
|
if (!StringUtil.isNullOrEmpty(tb.getPictUrlWhite()))
|
taobao.setPictUrlWhite(tb.getPictUrlWhite());
|
|
// 更新商品
|
taoBaoGoodsUpdateService.getUpdateTaoBaoGoodsBrief(taobao);
|
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult("修改成功")));
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("修改失败")));
|
}
|
|
}
|
|
/**
|
* 批量添加标签 --- 精品库（随机权重）
|
*
|
* @param callback
|
* @param request
|
* @param out
|
* @param 权重范围
|
* 大值
|
* @param 佣金范围
|
* 小值
|
*/
|
@RequestMapping(value = "setWeightBatch")
|
public void setWeightBatch(String callback, String ids, Integer weight, Integer weightSmall, Integer weightLarge,
|
HttpServletRequest request, PrintWriter out) {
|
|
try {
|
|
if (StringUtil.isNullOrEmpty(ids)) {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("未选择需操作的商品")));
|
return;
|
}
|
|
Gson gson = new Gson();
|
List<Long> idList = gson.fromJson(ids, new TypeToken<ArrayList<Long>>() {
|
}.getType());
|
|
if (idList == null || idList.size() == 0) {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("请选择需操作的商品")));
|
return;
|
}
|
// 获取当前操作用户
|
AdminUser admin = (AdminUser) request.getSession().getAttribute(Constant.SESSION_ADMIN);
|
|
qualityFactoryService.setWeightBatch(idList, admin, weight, weightSmall, weightLarge);
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult("设置成功")));
|
|
} catch (Exception e) {
|
out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常")));
|
e.printStackTrace();
|
}
|
|
}
|
|
}
|
