package com.matrix.system.dataMove;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.dynamic.datasource.annotation.DS;
|
import com.matrix.component.redis.RedisClient;
|
import com.matrix.core.tools.StringUtils;
|
import com.matrix.system.shopXcx.bean.ShopProduct;
|
import com.matrix.system.shopXcx.bean.ShopProductAttribute;
|
import com.matrix.system.shopXcx.bean.ShopProductImg;
|
import com.matrix.system.shopXcx.bean.ShopSku;
|
import com.matrix.system.shopXcx.dao.ShopProductAttributeDao;
|
import com.matrix.system.shopXcx.dao.ShopProductDao;
|
import com.matrix.system.shopXcx.dao.ShopProductImgDao;
|
import com.matrix.system.shopXcx.dao.ShopSkuDao;
|
import org.apache.commons.lang3.StringEscapeUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.jdbc.core.JdbcTemplate;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.math.BigDecimal;
|
import java.util.*;
|
|
/**
|
* @author wzy
|
* @date 2021-08-11
|
**/
|
@Service
|
public class SjfDataMoveServiceImpl {
|
|
@Autowired
|
private JdbcTemplate jdbcTemplate;
|
|
@Autowired
|
private ShopProductAttributeDao shopProductAttributeDao;
|
@Autowired
|
private ShopProductDao shopProductDao;
|
@Autowired
|
private ShopSkuDao shopSkuDao;
|
@Autowired
|
private ShopProductImgDao shopProductImgDao;
|
|
@Autowired
|
private RedisClient redisClient;
|
|
public <T> List<T> mapsToListBean(List<Map<String, Object>> maps, Class<T> t) {
|
List<T> list = new ArrayList<>();
|
for (Map<String, Object> map : maps) {
|
String s = JSONObject.toJSONString(map);
|
T object = JSONObject.parseObject(s, t);
|
list.add(object);
|
}
|
return list;
|
}
|
|
public <T> T mapToBane(Map<String, Object> map, Class<T> t) {
|
String s = JSONObject.toJSONString(map);
|
return JSONObject.parseObject(s, t);
|
}
|
|
private final Long companyId = 37L;
|
private final Long shopId = 53L;
|
|
@DS("slave")
|
public List<ShopProductAttribute> oldProductAttr() {
|
List<Map<String, Object>> maps = jdbcTemplate.queryForList("select * from eb_store_category where is_show=1 and pid=0");
|
|
List<ShopProductAttribute> list = new ArrayList<>();
|
for (Map<String, Object> map : maps) {
|
Object classifyId = map.get("id");
|
|
List<Map<String, Object>> subMaps = jdbcTemplate.queryForList("select * from eb_store_category where pid=" + classifyId.toString());
|
|
List<ShopProductAttribute> child = new ArrayList<>();
|
for (Map<String, Object> subMap : subMaps) {
|
ShopProductAttribute subAttr = new ShopProductAttribute();
|
subAttr.setAttrId((int) Long.parseLong(subMap.get("id").toString()));
|
subAttr.setParentId(Integer.parseInt(subMap.get("pid").toString()));
|
String subName = subMap.get("cate_name").toString();
|
subAttr.setAttrName(subName);
|
subAttr.setAttrCode(StringUtils.toHanyuPinyin(subName));
|
subAttr.setAttrUrl(map.get("pic").toString());
|
|
subAttr.setCreateBy("善吉凡");
|
subAttr.setUpdateBy("善吉凡");
|
subAttr.setCreateTime(new Date());
|
subAttr.setUpdateTime(new Date());
|
subAttr.setShopId(shopId);
|
subAttr.setCompanyId(companyId);
|
child.add(subAttr);
|
}
|
|
ShopProductAttribute attr = new ShopProductAttribute();
|
attr.setAttrId((int) Long.parseLong(map.get("id").toString()));
|
attr.setParentId(198);
|
attr.setAttrUrl(map.get("pic").toString());
|
String name = map.get("cate_name").toString();
|
attr.setAttrName(name);
|
attr.setAttrCode(StringUtils.toHanyuPinyin(name));
|
attr.setChild(child);
|
|
attr.setCreateBy("善吉凡");
|
attr.setUpdateBy("善吉凡");
|
attr.setCreateTime(new Date());
|
attr.setUpdateTime(new Date());
|
attr.setShopId(shopId);
|
attr.setCompanyId(companyId);
|
list.add(attr);
|
}
|
return list;
|
}
|
|
public void productAttr(List<ShopProductAttribute> list) {
|
Map<Integer, Integer> map = new HashMap<>();
|
for (ShopProductAttribute shopProductAttribute : list) {
|
Integer oldId = shopProductAttribute.getAttrId();
|
shopProductAttribute.setAttrId(null);
|
shopProductAttributeDao.insert(shopProductAttribute);
|
|
for (ShopProductAttribute productAttribute : shopProductAttribute.getChild()) {
|
Integer oldChildId = productAttribute.getAttrId();
|
productAttribute.setAttrId(null);
|
productAttribute.setParentId(shopProductAttribute.getAttrId());
|
shopProductAttributeDao.insert(productAttribute);
|
map.put(oldChildId, productAttribute.getAttrId());
|
}
|
map.put(oldId, shopProductAttribute.getAttrId());
|
}
|
|
redisClient.saveMapValue("attrIds", map);
|
}
|
|
@DS("slave")
|
public List<ShopProduct> oldProduct() {
|
List<Map<String, Object>> products = jdbcTemplate.queryForList("select * from eb_store_product where is_show=1 and is_del=0");
|
|
List<ShopProduct> result = new ArrayList<>();
|
for (Map<String, Object> product : products) {
|
ShopProduct shopProduct = new ShopProduct();
|
shopProduct.setCategoryId(Integer.parseInt(product.get("cate_id").toString()));
|
shopProduct.setTitle(product.get("store_name").toString());
|
shopProduct.setBriefIntroduction(product.get("store_info").toString());
|
shopProduct.setImgMobile(product.get("image").toString());
|
shopProduct.setPrice(Double.parseDouble(product.get("price").toString()));
|
shopProduct.setMarkedPrice(Double.parseDouble(product.get("ot_price").toString()));
|
shopProduct.setRsVolume(Integer.parseInt(product.get("sales").toString()));
|
shopProduct.setDsVolume(Integer.parseInt(product.get("ficti").toString()));
|
|
String imagesStr = product.get("slider_image").toString();
|
List<String> images = JSONObject.parseArray(imagesStr, String.class);
|
int i = 1;
|
List<ShopProductImg> imgs = new ArrayList<>();
|
for (String image : images) {
|
ShopProductImg shopProductImg = new ShopProductImg();
|
shopProductImg.setImgPath(image);
|
shopProductImg.setSort(i);
|
shopProductImg.setCreateBy("善吉凡");
|
shopProductImg.setUpdateBy("善吉凡");
|
shopProductImg.setCreateTime(new Date());
|
shopProductImg.setUpdateTime(new Date());
|
i++;
|
|
imgs.add(shopProductImg);
|
}
|
shopProduct.setProductImgs(imgs);
|
|
// 商品属性 即sku
|
Map<String, Object> attrValue = jdbcTemplate.queryForMap("select * from eb_store_product_attr_value where product_id=" + product.get("id"));
|
ShopSku shopSku = new ShopSku();
|
shopSku.setName(product.get("store_name").toString());
|
shopSku.setStock(Integer.parseInt(attrValue.get("stock").toString()));
|
shopSku.setImgPath(attrValue.get("image").toString());
|
shopSku.setPrice(new BigDecimal(attrValue.get("price").toString()));
|
shopSku.setCreateBy("善吉凡");
|
shopSku.setUpdateBy("善吉凡");
|
shopSku.setCreateTime(new Date());
|
shopSku.setUpdateTime(new Date());
|
shopSku.setScore(0);
|
shopSku.setSort(0);
|
shopSku.setSealCount(Integer.parseInt(product.get("ficti").toString()));
|
List<ShopSku> skus = new ArrayList<>();
|
skus.add(shopSku);
|
shopProduct.setSkus(skus);
|
|
Map<String, Object> desc = jdbcTemplate.queryForMap("select * from eb_store_product_description where product_id=" + product.get("id"));
|
shopProduct.setMobileDetails(desc.get("description").toString());
|
|
|
shopProduct.setDelFlag(2);
|
shopProduct.setShopIds(shopId.toString());
|
shopProduct.setCompanyId(companyId);
|
shopProduct.setAbleSales(1);
|
shopProduct.setAbleScorePay(2);
|
shopProduct.setStatus(1);
|
shopProduct.setCreateBy("善吉凡");
|
shopProduct.setUpdateBy("善吉凡");
|
shopProduct.setCreateTime(new Date());
|
shopProduct.setUpdateTime(new Date());
|
result.add(shopProduct);
|
}
|
return result;
|
}
|
|
@Transactional
|
public void newShopProduct(List<ShopProduct> list) {
|
String sysUsersIds = redisClient.getCachedValue("attrIds");
|
Map attrIds = JSONObject.parseObject(sysUsersIds, Map.class);
|
|
|
for (ShopProduct shopProduct : list) {
|
Object o = attrIds.get(shopProduct.getCategoryId().toString());
|
shopProduct.setCategoryId(Integer.parseInt(o.toString()));
|
|
shopProduct.setAttrValues("");
|
shopProduct.setScoreCategoryId(202L);
|
shopProduct.setId(null);
|
String s = StringEscapeUtils.unescapeHtml4(shopProduct.getMobileDetails());
|
shopProduct.setMobileDetails(s);
|
|
shopProductDao.insert(shopProduct);
|
|
for (ShopProductImg productImg : shopProduct.getProductImgs()) {
|
productImg.setPId(shopProduct.getId());
|
|
shopProductImgDao.insert(productImg);
|
}
|
|
for (ShopSku skus : shopProduct.getSkus()) {
|
skus.setPId(shopProduct.getId());
|
|
shopSkuDao.insert(skus);
|
}
|
}
|
}
|
|
}
|
