package com.yeshi.fanli.controller.client.v2;
|
|
import java.io.PrintWriter;
|
import java.util.ArrayList;
|
import java.util.HashSet;
|
import java.util.List;
|
import java.util.Set;
|
|
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.yeshi.utils.JsonUtil;
|
|
import com.google.gson.Gson;
|
import com.google.gson.GsonBuilder;
|
import com.google.gson.reflect.TypeToken;
|
import com.yeshi.fanli.dto.ConfigParamsDTO;
|
import com.yeshi.fanli.entity.accept.AcceptData;
|
import com.yeshi.fanli.entity.bus.user.UserGoodsStorage;
|
import com.yeshi.fanli.entity.goods.CommonGoods;
|
import com.yeshi.fanli.entity.system.ConfigKeyEnum;
|
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
|
import com.yeshi.fanli.exception.share.UserShareGoodsRecordException;
|
import com.yeshi.fanli.exception.taobao.TaoKeApiException;
|
import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;
|
import com.yeshi.fanli.exception.user.UserGoodsStorageException;
|
import com.yeshi.fanli.service.inter.config.ConfigService;
|
import com.yeshi.fanli.service.inter.order.OrderHongBaoMoneyComputeService;
|
import com.yeshi.fanli.service.inter.order.config.HongBaoManageService;
|
import com.yeshi.fanli.service.inter.user.UserGoodsStorageService;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.StringUtil;
|
import com.yeshi.fanli.util.VersionUtil;
|
import com.yeshi.fanli.util.factory.goods.GoodsDetailVOFactory;
|
import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
|
import com.yeshi.fanli.vo.goods.GoodsDetailVO;
|
|
import net.sf.json.JSONArray;
|
import net.sf.json.JSONObject;
|
|
/**
|
* 用户商品分享库
|
*
|
* @author Administrator
|
*
|
*/
|
@Controller
|
@RequestMapping("api/v2/shraeStorage")
|
public class ShareStorageControllerV2 {
|
|
@Resource
|
private ConfigService configService;
|
|
@Resource
|
private HongBaoManageService hongBaoManageService;
|
|
@Resource
|
private OrderHongBaoMoneyComputeService orderHongBaoMoneyComputeService;
|
|
@Resource
|
private UserGoodsStorageService userGoodsStorageService;
|
|
/**
|
* 单个商品加入选品库
|
*
|
* @param callback
|
* @param storageIds
|
* id数组
|
* @param out
|
*/
|
@RequestMapping(value = "accordtorage", method = RequestMethod.POST)
|
public void accordtorage(AcceptData acceptData, Long uid, long id, Integer goodsType, PrintWriter out) {
|
|
if (uid == null) {
|
out.print(JsonUtil.loadFalseResult("用户未登录"));
|
return;
|
}
|
|
if (goodsType == null) {
|
goodsType = Constant.SOURCE_TYPE_TAOBAO;
|
}
|
|
try {
|
UserGoodsStorage userGoodsStorage = userGoodsStorageService.getByUidAndAuctionId(uid, id, goodsType);
|
boolean storageState = false;
|
if (userGoodsStorage != null) {
|
// 取消加入选品库
|
userGoodsStorageService.deleteByPrimaryKey(userGoodsStorage.getId());
|
} else {
|
// 加入选品库
|
Set<Long> set = new HashSet<Long>();
|
set.add(id);
|
userGoodsStorageService.save(uid, set, goodsType);
|
storageState = true;
|
}
|
|
JSONObject data = new JSONObject();
|
data.put("storageState", storageState);
|
out.print(JsonUtil.loadTrueResult(data));
|
} catch (Exception e) {
|
out.print(JsonUtil.loadFalseResult("操作失败"));
|
e.printStackTrace();
|
}
|
}
|
|
/**
|
* 批量添加选品库
|
*
|
* @param acceptData
|
* @param uid
|
* 用户id
|
* @param ids
|
* 简版商品id
|
* @param out
|
*/
|
@RequestMapping(value = "addStorage", method = RequestMethod.POST)
|
public void addStorage(AcceptData acceptData, Long uid, String ids, PrintWriter out) {
|
try {
|
Gson gson = new Gson();
|
Set<Long> set = gson.fromJson(ids, new TypeToken<HashSet<Long>>() {
|
}.getType());
|
if (set == null || set.size() == 0) {
|
out.print(JsonUtil.loadFalseResult("未选择商品"));
|
return;
|
}
|
|
userGoodsStorageService.addCommonGoods(uid, set);
|
out.print(JsonUtil.loadTrueResult("添加成功"));
|
} catch (UserGoodsStorageException e) {
|
out.print(JsonUtil.loadFalseResult(e.getMsg()));
|
}
|
}
|
|
/**
|
* 查询用户选品库数据
|
*
|
* @param acceptData
|
* @param page
|
* 页码 初始值 1
|
* @param uid
|
* 用户id
|
* @param out
|
*/
|
@RequestMapping(value = "getlist", method = RequestMethod.POST)
|
public void getlist(AcceptData acceptData, Integer page, Long uid, Integer goodsType, PrintWriter out) {
|
|
if (uid == null) {
|
out.print(JsonUtil.loadFalseResult("用户未登录"));
|
return;
|
}
|
|
if (goodsType == null) {
|
out.print(JsonUtil.loadFalseResult("平台类型不能为空"));
|
return;
|
}
|
|
if (page == null || page < 1) {
|
page = 1;
|
}
|
|
int pageSize = Constant.PAGE_SIZE;
|
JSONArray array = new JSONArray();
|
JSONObject data = new JSONObject();
|
|
if (goodsType == Constant.SOURCE_TYPE_JD) {
|
String open = configService.get(ConfigKeyEnum.shareOpenJD.getKey());
|
if (!"1".equals(open.trim())) {
|
data.put("count", 0);
|
data.put("result_list", array);
|
out.print(JsonUtil.loadTrueResult(data));
|
return;
|
}
|
}
|
|
List<UserGoodsStorage> listStorage = userGoodsStorageService.listQueryByUid((page - 1) * pageSize, pageSize,
|
uid, goodsType);
|
if (listStorage == null || listStorage.size() == 0) {
|
data.put("count", 0);
|
data.put("result_list", array);
|
out.print(JsonUtil.loadTrueResult(data));
|
return;
|
}
|
|
// API网络接口验证是否在售
|
List<TaoBaoGoodsBrief> listTaoKeGoods = null;
|
if (goodsType == Constant.SOURCE_TYPE_TAOBAO) {
|
List<Long> listGid = new ArrayList<Long>();
|
for (UserGoodsStorage userGoodsStorage : listStorage) {
|
CommonGoods commonGoods = userGoodsStorage.getCommonGoods();
|
if (commonGoods == null) {
|
continue;
|
}
|
listGid.add(commonGoods.getGoodsId());
|
}
|
|
try {
|
listTaoKeGoods = TaoKeApiUtil.getBatchGoodsInfo(listGid);
|
} catch (TaoKeApiException e) {
|
e.printStackTrace();
|
} catch (TaobaoGoodsDownException e) {
|
e.printStackTrace();
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())
|
.excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();
|
|
ConfigParamsDTO paramsDTO = orderHongBaoMoneyComputeService.getShowComputeRate(acceptData.getPlatform(),
|
acceptData.getVersion());
|
|
for (UserGoodsStorage userGoodsStorage : listStorage) {
|
CommonGoods commonGoods = userGoodsStorage.getCommonGoods();
|
if (commonGoods == null) {
|
continue;
|
}
|
|
// 淘宝商品验证在售
|
if (goodsType == Constant.SOURCE_TYPE_TAOBAO) {
|
if (listTaoKeGoods != null && listTaoKeGoods.size() > 0) {
|
int state = 1; // 默认停售
|
Long goodsId = commonGoods.getGoodsId();
|
for (TaoBaoGoodsBrief taoKeGoods : listTaoKeGoods) {
|
Long auctionId = taoKeGoods.getAuctionId();
|
if (goodsId == auctionId || goodsId.equals(auctionId)) {
|
state = 0; // 在售
|
break;
|
}
|
}
|
commonGoods.setState(state);
|
}
|
}
|
|
// 判断是否已分享， 已分享显示已下架
|
Integer storageState = userGoodsStorage.getState();
|
if (storageState != null && storageState == UserGoodsStorage.STATE_SHARED) {
|
Integer goodsState = commonGoods.getState();
|
if (goodsState != null && goodsState != 1) {
|
commonGoods.setState(2);
|
}
|
}
|
|
GoodsDetailVO detailVO = GoodsDetailVOFactory.convertCommonGoods(commonGoods, paramsDTO);
|
detailVO.setId(commonGoods.getId());
|
|
JSONObject dataObject = new JSONObject();
|
dataObject.put("storageId", userGoodsStorage.getId());
|
dataObject.put("goods", gson.toJson(detailVO));
|
array.add(dataObject);
|
}
|
|
long count = userGoodsStorageService.countQueryByUid(uid, goodsType);
|
data.put("count", count);
|
data.put("result_list", array);
|
out.print(JsonUtil.loadTrueResult(data));
|
}
|
|
/**
|
* 分享商品返回二维码图片
|
*
|
* @param callback
|
* @param storageIds
|
* id数组
|
* @param out
|
*/
|
@RequestMapping(value = "createShare", method = RequestMethod.POST)
|
public void createShare(AcceptData acceptData, Long uid, String storageIds, PrintWriter out) {
|
|
if (StringUtil.isNullOrEmpty(storageIds)) {
|
out.print(JsonUtil.loadFalseResult("分享商品不能为空"));
|
return;
|
}
|
|
if (uid == null) {
|
out.print(JsonUtil.loadFalseResult("用户未登录"));
|
return;
|
}
|
|
try {
|
Gson gson = new Gson();
|
List<Long> listStorageID = gson.fromJson(storageIds, new TypeToken<ArrayList<Long>>() {
|
}.getType());
|
|
if (!VersionUtil.greaterThan_2_0_5(acceptData.getPlatform(), acceptData.getVersion())) {
|
|
if (listStorageID == null || listStorageID.size() < 9) {
|
out.print(JsonUtil.loadFalseResult("分享商品数量不足"));
|
return;
|
}
|
|
if (listStorageID.size() != 9) {
|
out.print(JsonUtil.loadFalseResult("分享商品数量只能是9个"));
|
return;
|
}
|
|
JSONObject data = userGoodsStorageService.createShareV2(uid, listStorageID, true);
|
out.print(JsonUtil.loadTrueResult(data));
|
} else {
|
JSONObject data = userGoodsStorageService.createShareV2(uid, listStorageID, false);
|
out.print(JsonUtil.loadTrueResult(data));
|
}
|
|
} catch (UserGoodsStorageException e) {
|
out.print(JsonUtil.loadFalseResult("分享失败"));
|
e.printStackTrace();
|
} catch (UserShareGoodsRecordException e) {
|
out.print(JsonUtil.loadFalseResult("分享失败"));
|
e.printStackTrace();
|
} catch (Exception e) {
|
out.print(JsonUtil.loadFalseResult("分享失败"));
|
e.printStackTrace();
|
}
|
}
|
}
|
