package com.matrix.system.shopXcx.action;
|
|
|
import com.alibaba.fastjson.JSON;
|
import com.matrix.core.constance.MatrixConstance;
|
import com.matrix.core.constance.SystemMessageCode;
|
import com.matrix.core.pojo.PaginationVO;
|
import com.matrix.core.tools.StringUtils;
|
import com.matrix.core.constance.SystemErrorCode;
|
import com.matrix.core.anotations.RemoveRequestToken;
|
import com.matrix.system.common.bean.SysUsers;
|
import com.matrix.system.common.constance.AppConstance;
|
import com.matrix.system.common.tools.ServiceUtil;
|
import com.matrix.system.constance.Dictionary;
|
import com.matrix.system.hive.action.BaseController;
|
import com.matrix.system.shopXcx.bean.*;
|
import com.matrix.system.shopXcx.dao.*;
|
import org.apache.commons.collections.CollectionUtils;
|
import org.springframework.stereotype.Controller;
|
import com.matrix.core.exception.GlobleException;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
import com.matrix.core.anotations.SaveRequestToken;
|
import com.matrix.core.pojo.AjaxResult;
|
import com.matrix.core.tools.WebUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import java.util.*;
|
|
import org.springframework.web.servlet.ModelAndView;
|
|
/**
|
* @description 产品表
|
* @author jyy
|
* @date 2019-06-10 10:58
|
*/
|
@Controller
|
@RequestMapping(value = "admin/shopProduct")
|
public class ShopProductAction extends BaseController {
|
|
@Autowired
|
private ShopProductDao shopProductDao;
|
|
@Autowired
|
private ShopProductAttributeDao shopProductAttributeDao;
|
|
@Autowired
|
private ShopProductParamDao shopProductParamDao;
|
|
@Autowired
|
private ShopParamValueDao shopParamValueDao;
|
|
@Autowired
|
private ShopProductAttrRefDao shopProductAttrRefDao;
|
|
@Autowired
|
private ShopSkuDao shopSkuDao;
|
|
@Autowired
|
private ShopProductImgDao shopProductImgDao;
|
|
@Autowired
|
private ShopProductParamRefDao shopProductParamRefDao;
|
|
@Autowired
|
private ServiceUtil serviceUtil;
|
|
//记录编辑前的值Before_Edit_Value
|
public static final String BEV="ShopProduct_BEV";
|
|
|
/**
|
* 列表显示
|
*/
|
@RequestMapping(value = "/showList")
|
public @ResponseBody AjaxResult showList(ShopProduct shopProduct, PaginationVO pageVo) {
|
SysUsers sysUsers = getMe();
|
pageVo.setSort("createTime");
|
pageVo.setOrder("desc");
|
shopProduct.setDelFlag(AppConstance.DATA_USEABLE);
|
shopProduct.setCompanyId(sysUsers.getCompanyId());
|
List<ShopProduct> dataList = shopProductDao.selectInPage(shopProduct, pageVo);
|
AjaxResult result = new AjaxResult(AjaxResult.STATUS_SUCCESS, dataList,
|
shopProductDao.selectTotalRecord(shopProduct));
|
return result;
|
}
|
|
/**
|
* 新增
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
@RemoveRequestToken
|
@RequestMapping(value = "/addShopProduct")
|
public @ResponseBody AjaxResult addShopProduct(ShopProduct shopProduct) {
|
SysUsers user = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY);
|
shopProduct.setCreateBy(user.getSuName());
|
shopProduct.setUpdateBy(user.getSuName());
|
shopProduct.setCompanyId(user.getCompanyId());
|
shopProduct.setDelFlag(AppConstance.DATA_USEABLE);
|
if(StringUtils.isNotBlank(shopProduct.getAttrValues())){
|
String attrs = shopProduct.getAttrValues().replace("|", "").replace("-", "");
|
shopProduct.setAttrValues(attrs.trim());
|
}
|
|
// if (!user.getShopRole().equals(Dictionary.FLAG_YES_Y)) {
|
// shopProduct.setShopIds(user.getShopId().toString());
|
// }
|
|
int i=shopProductDao.insert(shopProduct);
|
if(i > 0){
|
if(StringUtils.isNotBlank(shopProduct.getAttrs())){
|
String[] attrs = shopProduct.getAttrs().split(",");
|
List<ShopProductAttrRef> shopProductAttrRefs = new ArrayList<>();
|
//产品属性关联表插入数据
|
for (int j = 0; j < attrs.length; j++) {
|
ShopProductAttribute shopProductAttribute = shopProductAttributeDao.selectById(Integer.valueOf(attrs[j]));
|
ShopProductAttrRef shopProductAttrRef = new ShopProductAttrRef();
|
shopProductAttrRef.setAttrId(shopProductAttribute.getAttrId());
|
shopProductAttrRef.setPId(shopProduct.getId());
|
shopProductAttrRef.setAttrFullPath(getParentName(shopProductAttribute.getAttrId())+"/"+shopProductAttribute.getAttrId()+"/");
|
shopProductAttrRef.setCreateBy(user.getSuName());
|
shopProductAttrRef.setUpdateBy(user.getSuName());
|
shopProductAttrRefs.add(shopProductAttrRef);
|
}
|
shopProductAttrRefDao.batchInsert(shopProductAttrRefs);
|
}
|
//插入产品规格数据
|
if(StringUtils.isNotBlank(shopProduct.getShopSku())){
|
List<ShopSku> shopSkus = JSON.parseArray(shopProduct.getShopSku(), ShopSku.class);
|
List<ShopSku> newShopSkus = new ArrayList<ShopSku>();
|
for(int k=0;k<shopSkus.size();k++){
|
ShopSku shopSku = shopSkus.get(k);
|
if(StringUtils.isNotBlank(shopSku.getAtrid())){
|
boolean isRepetition = serviceUtil.addCheckRepeat("shop_sku", "atrid", shopSku.getAtrid());
|
if(isRepetition){
|
return new AjaxResult(AjaxResult.STATUS_FAIL,"品种编码不能重复");
|
}
|
}
|
shopSku.setPId(shopProduct.getId());
|
shopSku.setCreateBy(user.getSuName());
|
shopSku.setUpdateBy(user.getSuName());
|
newShopSkus.add(shopSku);
|
}
|
shopSkuDao.batchInsert(newShopSkus);
|
}
|
|
//插入产品图片数据
|
if(StringUtils.isNotBlank(shopProduct.getShopProductImg())){
|
List<ShopProductImg> shopProductImgs = JSON.parseArray(shopProduct.getShopProductImg(), ShopProductImg.class);
|
List<ShopProductImg> newShopProductImgs = new ArrayList<ShopProductImg>();
|
for(int a=0;a<shopProductImgs.size();a++){
|
ShopProductImg shopProductImg = shopProductImgs.get(a);
|
shopProductImg.setPId(shopProduct.getId());
|
shopProductImg.setCreateBy(user.getSuName());
|
shopProductImg.setUpdateBy(user.getSuName());
|
newShopProductImgs.add(shopProductImg);
|
}
|
if(CollectionUtils.isNotEmpty(newShopProductImgs)){
|
shopProductImgDao.batchInsert(newShopProductImgs);
|
}
|
}
|
//插入产品参数
|
if(StringUtils.isNotBlank(shopProduct.getParamRefs())){
|
List<ShopProductParamRef> shopProductParamRefs = JSON.parseArray(shopProduct.getParamRefs(), ShopProductParamRef.class);
|
List<ShopProductParamRef> newShopProductParamRefs = new ArrayList<ShopProductParamRef>();
|
for(int b=0;b<shopProductParamRefs.size();b++){
|
ShopProductParamRef shopProductParamRef = shopProductParamRefs.get(b);
|
shopProductParamRef.setPId(shopProduct.getId());
|
shopProductParamRef.setCreateBy(user.getSuName());
|
shopProductParamRef.setUpdateBy(user.getSuName());
|
newShopProductParamRefs.add(shopProductParamRef);
|
}
|
shopProductParamRefDao.batchInsert(newShopProductParamRefs);
|
}
|
return new AjaxResult(AjaxResult.STATUS_SUCCESS, SystemMessageCode.ADD_SUCCES, "产品表");
|
}else {
|
throw new GlobleException(SystemErrorCode.DATA_ADD_FAIL);
|
}
|
}
|
|
/**
|
* 递归查询父节点id
|
* @param attrId
|
* @return
|
*/
|
private String getParentName(Integer attrId){
|
ShopProductAttribute shopProductAttribute = shopProductAttributeDao.selectById(attrId);
|
if(shopProductAttribute != null && shopProductAttribute.getParentId() != 0){
|
String attrfullpath ="/" + shopProductAttribute.getParentId();
|
String fullpath = getParentName(shopProductAttribute.getParentId());
|
return fullpath + attrfullpath;
|
}else{
|
return "";
|
}
|
}
|
|
|
|
|
/**
|
* 修改
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
@RemoveRequestToken
|
@RequestMapping(value = "/modifyShopProduct")
|
public @ResponseBody AjaxResult modifyShopProduct(ShopProduct newShopProduct) {
|
SysUsers user = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY);
|
if(StringUtils.isNotBlank(newShopProduct.getAttrValues())){
|
String attrs = newShopProduct.getAttrValues().replace("|", "").replace("-", "");
|
newShopProduct.setAttrValues(attrs.trim());
|
}
|
|
// if (!user.getShopRole().equals(Dictionary.FLAG_YES_Y)) {
|
// newShopProduct.setShopIds(user.getShopId().toString());
|
// }
|
|
int i = shopProductDao.updateByModel(newShopProduct);
|
if (i > 0) {
|
if(StringUtils.isNotBlank(newShopProduct.getAttrs())){
|
String[] attrs = newShopProduct.getAttrs().split(",");
|
shopProductAttrRefDao.deleteById(newShopProduct.getId());
|
List<ShopProductAttrRef> shopProductAttrRefs = new ArrayList<>();
|
//产品属性关联表插入数据
|
for (int j = 0; j < attrs.length; j++) {
|
ShopProductAttribute shopProductAttribute = shopProductAttributeDao.selectById(Integer.valueOf(attrs[j]));
|
ShopProductAttrRef shopProductAttrRef = new ShopProductAttrRef();
|
shopProductAttrRef.setAttrId(shopProductAttribute.getAttrId());
|
shopProductAttrRef.setPId(newShopProduct.getId());
|
shopProductAttrRef.setAttrFullPath(getParentName(shopProductAttribute.getAttrId())+"/"+shopProductAttribute.getAttrId()+"/");
|
shopProductAttrRef.setCreateBy(user.getSuName());
|
shopProductAttrRef.setUpdateBy(user.getSuName());
|
shopProductAttrRefs.add(shopProductAttrRef);
|
}
|
shopProductAttrRefDao.batchInsert(shopProductAttrRefs);
|
}else{
|
shopProductAttrRefDao.deleteById(newShopProduct.getId());
|
}
|
//插入产品规格数据
|
if(StringUtils.isNotBlank(newShopProduct.getShopSku())){
|
List<ShopSku> shopSkus = JSON.parseArray(newShopProduct.getShopSku(), ShopSku.class);
|
List<ShopSku> skuList = shopSkuDao.selectByPid(newShopProduct.getId());
|
List<Integer> ids = new ArrayList<>();
|
if(skuList != null && skuList.size()>0){
|
//查找被删除的数据
|
List<ShopSku> list = getList(shopSkus, skuList);
|
for(int c=0;c<list.size();c++){
|
shopSkuDao.deleteById(list.get(c).getId());
|
}
|
|
}
|
for(int k=0;k<shopSkus.size();k++){
|
ShopSku shopSku = shopSkus.get(k);
|
//id不为空做更新操作
|
if(shopSku.getId() != null){
|
ShopSku oldSku = shopSkuDao.selectById(shopSku.getId());
|
boolean isRepetition;
|
if(StringUtils.isNotBlank(shopSku.getAtrid())){
|
if(shopSku.getAtrid().equals(oldSku.getAtrid())){
|
isRepetition = serviceUtil.updateCheckRepeat("shop_sku", "atrid",oldSku.getAtrid(),"atrid",shopSku.getAtrid());
|
}else{
|
isRepetition = serviceUtil.addCheckRepeat("shop_sku","atrid",shopSku.getAtrid());
|
}
|
if(isRepetition){
|
return new AjaxResult(AjaxResult.STATUS_FAIL,"品种编码不能重复");
|
}
|
}
|
shopSkuDao.updateByModel(shopSku);
|
}else{
|
shopSku.setPId(newShopProduct.getId());
|
shopSku.setCreateBy(user.getSuName());
|
shopSku.setUpdateBy(user.getSuName());
|
if(StringUtils.isNotBlank(shopSku.getAtrid())){
|
boolean isRepetition = serviceUtil.addCheckRepeat("shop_sku", "atrid", shopSku.getAtrid());
|
if(isRepetition){
|
return new AjaxResult(AjaxResult.STATUS_FAIL,"品种编码不能重复");
|
}
|
}
|
shopSkuDao.insert(shopSku);
|
}
|
}
|
}else{
|
shopSkuDao.deleteById(newShopProduct.getId());
|
}
|
|
//插入产品图片数据
|
if(StringUtils.isNotBlank(newShopProduct.getShopProductImg())){
|
shopProductImgDao.deleteById(newShopProduct.getId());
|
List<ShopProductImg> shopProductImgs = JSON.parseArray(newShopProduct.getShopProductImg(), ShopProductImg.class);
|
List<ShopProductImg> newShopProductImgs = new ArrayList<>();
|
for(int a=0;a<shopProductImgs.size();a++){
|
ShopProductImg shopProductImg = shopProductImgs.get(a);
|
shopProductImg.setPId(newShopProduct.getId());
|
shopProductImg.setCreateBy(user.getSuName());
|
shopProductImg.setUpdateBy(user.getSuName());
|
newShopProductImgs.add(shopProductImg);
|
}
|
if(CollectionUtils.isNotEmpty(newShopProductImgs)){
|
shopProductImgDao.batchInsert(newShopProductImgs);
|
}
|
}else{
|
shopProductImgDao.deleteById(newShopProduct.getId());
|
}
|
//插入产品参数
|
if(StringUtils.isNotBlank(newShopProduct.getParamRefs())){
|
shopProductParamRefDao.deleteById(newShopProduct.getId());
|
List<ShopProductParamRef> shopProductParamRefs = JSON.parseArray(newShopProduct.getParamRefs(), ShopProductParamRef.class);
|
List<ShopProductParamRef> newShopProductParamRefs = new ArrayList<ShopProductParamRef>();
|
for(int b=0;b<shopProductParamRefs.size();b++){
|
ShopProductParamRef shopProductParamRef = shopProductParamRefs.get(b);
|
shopProductParamRef.setPId(newShopProduct.getId());
|
shopProductParamRef.setCreateBy(user.getSuName());
|
shopProductParamRef.setUpdateBy(user.getSuName());
|
newShopProductParamRefs.add(shopProductParamRef);
|
}
|
if(CollectionUtils.isNotEmpty(newShopProductParamRefs)){
|
shopProductParamRefDao.batchInsert(newShopProductParamRefs);
|
}
|
}else{
|
shopProductParamRefDao.deleteById(newShopProduct.getId());
|
}
|
return new AjaxResult(AjaxResult.STATUS_SUCCESS, SystemMessageCode.UPDATE_SUCCES, "产品表");
|
} else {
|
throw new GlobleException(SystemErrorCode.DATA_UPDATE_FAIL);
|
}
|
}
|
|
|
|
|
/**
|
* 进入修改界面
|
*/
|
@SaveRequestToken
|
@RequestMapping(value = "/editForm")
|
public ModelAndView editForm(Integer id) {
|
SysUsers sysUsers = getMe();
|
ShopProduct shopProduct = new ShopProduct();
|
ModelAndView modelAndView = new ModelAndView("admin/shop/shopProduct-form");
|
if (id != null) {
|
shopProduct = shopProductDao.selectById(id);
|
|
WebUtil.setSessionAttribute(BEV, shopProduct);
|
}
|
ShopProductParam shopProductParam = new ShopProductParam();
|
shopProductParam.setIsStart(AppConstance.IS_START);
|
List<ShopProductParam> paramList = shopProductParamDao.selectByModel(shopProductParam);
|
if(CollectionUtils.isNotEmpty(paramList)){
|
for (ShopProductParam bean :paramList) {
|
List<ShopParamValue> valueList = shopParamValueDao.selectByParamId(bean.getParamId());
|
bean.setValueList(valueList);
|
}
|
}
|
modelAndView.addObject("user", sysUsers);
|
modelAndView.addObject("obj",shopProduct);
|
modelAndView.addObject("valueList",paramList);
|
|
return modelAndView;
|
}
|
|
|
/**
|
* 删除
|
*/
|
@RequestMapping(value = "/del")
|
public @ResponseBody AjaxResult del(String keys) {
|
List<String> ids = StringUtils.strToCollToString(keys, ",");
|
ShopProduct shopProduct = new ShopProduct();
|
shopProduct.setDelFlag(AppConstance.DATA_DISABLE);
|
int i = shopProductDao.updateByIds(ids,shopProduct);
|
if (i > 0) {
|
return new AjaxResult(AjaxResult.STATUS_SUCCESS, SystemMessageCode.DELETE_SUCCES, ids.size());
|
} else {
|
throw new GlobleException(SystemErrorCode.DATA_DELETE_FAIL);
|
}
|
}
|
|
|
@RequestMapping(value = "/getParam")
|
@ResponseBody
|
public AjaxResult getParam(Integer id){
|
List<ShopSku> shopSkus = shopSkuDao.selectByPid(id);
|
List<ShopProductImg> shopProductImg = shopProductImgDao.selectByPid(id);
|
List<ShopProductAttrRef> attrRefs = shopProductAttrRefDao.selectByPid(id);
|
List<ShopProductParamRef> paramRefs = shopProductParamRefDao.selectByPid(id);
|
AjaxResult result= new AjaxResult();
|
result.setStatus(AjaxResult.STATUS_SUCCESS);
|
result.putInMap("shopSkus",shopSkus);
|
result.putInMap("shopImg",shopProductImg);
|
result.putInMap("AttrRefs",attrRefs);
|
result.putInMap("paramRefValues",paramRefs);
|
return result;
|
}
|
|
|
//查找不不同对象
|
private List<ShopSku> getList(List<ShopSku> list1,List<ShopSku> list2) {
|
List<ShopSku> list = new ArrayList<>();
|
for (ShopSku sku : list2) {
|
if (!list1.contains(sku)) {
|
list.add(sku);
|
}
|
}
|
return list;
|
}
|
|
/**
|
* @author jyy
|
* 查询所有产品
|
*/
|
@RequestMapping(value = "/getAll")
|
public @ResponseBody
|
AjaxResult getAll() {
|
SysUsers sysUsers = getMe();
|
ShopProduct shopProductParam = new ShopProduct();
|
shopProductParam.setCompanyId(sysUsers.getCompanyId());
|
shopProductParam.setDelFlag(AppConstance.DATA_USEABLE);
|
List<ShopProduct> productList = shopProductDao.selectByModel(shopProductParam);
|
return new AjaxResult(AjaxResult.STATUS_SUCCESS, productList, productList.size());
|
}
|
|
/**
|
* 商品上上下架
|
* @param ids
|
* @param status
|
* @return
|
*/
|
@RequestMapping(value = "/updateStatus")
|
@ResponseBody
|
public AjaxResult updateStatus(String ids,Integer status){
|
List<String> shopIds = StringUtils.strToCollToString(ids, ",");
|
ShopProduct shopProduct = new ShopProduct();
|
shopProduct.setStatus(status);
|
shopProductDao.updateByIds(shopIds, shopProduct);
|
return new AjaxResult(AjaxResult.STATUS_SUCCESS,"修改成功");
|
}
|
}
|
