1.消息订阅同步保存昵称头像

2.小程序规格获取
This commit is contained in:
SongZhang 2024-08-08 10:36:39 +08:00
parent fbabdc5763
commit 6ee7b54311
7 changed files with 182 additions and 150 deletions

View File

@ -1,5 +1,6 @@
package com.chaozhanggui.system.cashierservice.controller; package com.chaozhanggui.system.cashierservice.controller;
import cn.hutool.core.util.StrUtil;
import com.chaozhanggui.system.cashierservice.dao.TbPlatformDictMapper; import com.chaozhanggui.system.cashierservice.dao.TbPlatformDictMapper;
import com.chaozhanggui.system.cashierservice.entity.TbPlatformDict; import com.chaozhanggui.system.cashierservice.entity.TbPlatformDict;
import com.chaozhanggui.system.cashierservice.entity.dto.WxMsgSubDTO; import com.chaozhanggui.system.cashierservice.entity.dto.WxMsgSubDTO;
@ -221,7 +222,7 @@ public class CommonController {
} }
String msg = wxMsgSubDTO.getShopId().replace("msg", ""); String msg = wxMsgSubDTO.getShopId().replace("msg", "");
String[] split = msg.split(","); String[] split = msg.split(",");
loginService.addShopId(wxMsgSubDTO.getOpenId(), split[0], split.length > 1 ? Integer.valueOf(split[1]) : null); loginService.addShopId(wxMsgSubDTO.getOpenId(), split[0], split.length > 1 ? Integer.valueOf(split[1]) : null, wxMsgSubDTO.getNickname(), wxMsgSubDTO.getAvatar());
return Result.success(CodeEnum.SUCCESS); return Result.success(CodeEnum.SUCCESS);
} }
} }

View File

@ -3,6 +3,7 @@ package com.chaozhanggui.system.cashierservice.dao;
import com.chaozhanggui.system.cashierservice.entity.TbShopOpenId; import com.chaozhanggui.system.cashierservice.entity.TbShopOpenId;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select; import org.apache.ibatis.annotations.Select;
import org.apache.ibatis.annotations.Update;
import java.util.List; import java.util.List;
@ -30,4 +31,11 @@ public interface TbShopOpenIdMapper {
@Select("select * from tb_shop_open_id where shop_id=#{shopId} and status=1") @Select("select * from tb_shop_open_id where shop_id=#{shopId} and status=1")
List<TbShopOpenId> selectByShopId(@Param("shopId") Integer shopId); List<TbShopOpenId> selectByShopId(@Param("shopId") Integer shopId);
@Select("select * from tb_shop_open_id where open_id=#{openId} and status=1")
List<TbShopOpenId> selectByOpenId(@Param("openId") String openId);
@Update("update tb_shop_open_id set nickname=#{nickName}, avatar=#{avatar} where open_id=#{openId} and status=1 ")
int updateBaseInfoByOpenId(@Param("openId") String openId, @Param("nickName") String nickName, @Param("avatar") String avatar);
} }

View File

@ -3,15 +3,17 @@ package com.chaozhanggui.system.cashierservice.entity;
import java.io.Serializable; import java.io.Serializable;
import java.util.Date; import java.util.Date;
import lombok.Data; import lombok.Data;
import lombok.EqualsAndHashCode;
/** /**
* 商家openid信息表 * 商家openid信息表
* @TableName tb_shop_open_id * @TableName tb_shop_open_id
*/ */
@EqualsAndHashCode
@Data @Data
public class TbShopOpenId implements Serializable { public class TbShopOpenId implements Serializable {
/** /**
* *
*/ */
private Integer id; private Integer id;
@ -26,69 +28,24 @@ public class TbShopOpenId implements Serializable {
private String openId; private String openId;
/** /**
* *
*/ */
private Integer status; private Integer status;
/** /**
* *
*/ */
private Date createTime; private Date createTime;
/** /**
* *
*/ */
private Date updateTime; private Date updateTime;
private String nickname;
private String avatar;
private Integer type;
private static final long serialVersionUID = 1L; private static final long serialVersionUID = 1L;
@Override }
public boolean equals(Object that) {
if (this == that) {
return true;
}
if (that == null) {
return false;
}
if (getClass() != that.getClass()) {
return false;
}
TbShopOpenId other = (TbShopOpenId) that;
return (this.getId() == null ? other.getId() == null : this.getId().equals(other.getId()))
&& (this.getShopId() == null ? other.getShopId() == null : this.getShopId().equals(other.getShopId()))
&& (this.getOpenId() == null ? other.getOpenId() == null : this.getOpenId().equals(other.getOpenId()))
&& (this.getStatus() == null ? other.getStatus() == null : this.getStatus().equals(other.getStatus()))
&& (this.getCreateTime() == null ? other.getCreateTime() == null : this.getCreateTime().equals(other.getCreateTime()))
&& (this.getUpdateTime() == null ? other.getUpdateTime() == null : this.getUpdateTime().equals(other.getUpdateTime()));
}
@Override
public int hashCode() {
final int prime = 31;
int result = 1;
result = prime * result + ((getId() == null) ? 0 : getId().hashCode());
result = prime * result + ((getShopId() == null) ? 0 : getShopId().hashCode());
result = prime * result + ((getOpenId() == null) ? 0 : getOpenId().hashCode());
result = prime * result + ((getStatus() == null) ? 0 : getStatus().hashCode());
result = prime * result + ((getCreateTime() == null) ? 0 : getCreateTime().hashCode());
result = prime * result + ((getUpdateTime() == null) ? 0 : getUpdateTime().hashCode());
return result;
}
@Override
public String toString() {
StringBuilder sb = new StringBuilder();
sb.append(getClass().getSimpleName());
sb.append(" [");
sb.append("Hash = ").append(hashCode());
sb.append(", id=").append(id);
sb.append(", shopId=").append(shopId);
sb.append(", openId=").append(openId);
sb.append(", status=").append(status);
sb.append(", createTime=").append(createTime);
sb.append(", updateTime=").append(updateTime);
sb.append(", serialVersionUID=").append(serialVersionUID);
sb.append("]");
return sb.toString();
}
}

View File

@ -7,4 +7,6 @@ public class WxMsgSubDTO {
private String shopId; private String shopId;
private String openId; private String openId;
private Integer type; private Integer type;
private String nickname;
private String avatar;
} }

View File

@ -3,9 +3,11 @@ package com.chaozhanggui.system.cashierservice.service;
import cn.hutool.core.date.DateUtil; import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.RandomUtil; import cn.hutool.core.util.RandomUtil;
import cn.hutool.core.util.StrUtil;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.chaozhanggui.system.cashierservice.dao.*; import com.chaozhanggui.system.cashierservice.dao.*;
import com.chaozhanggui.system.cashierservice.entity.*; import com.chaozhanggui.system.cashierservice.entity.*;
import com.chaozhanggui.system.cashierservice.exception.MsgException;
import com.chaozhanggui.system.cashierservice.redis.RedisCst; import com.chaozhanggui.system.cashierservice.redis.RedisCst;
import com.chaozhanggui.system.cashierservice.redis.RedisUtil; import com.chaozhanggui.system.cashierservice.redis.RedisUtil;
import com.chaozhanggui.system.cashierservice.sign.CodeEnum; import com.chaozhanggui.system.cashierservice.sign.CodeEnum;
@ -62,37 +64,33 @@ public class LoginService {
this.shopOpenIdMapper = shopOpenIdMapper; this.shopOpenIdMapper = shopOpenIdMapper;
} }
public void addShopId(String openId, String shopId, Integer type) { public void addShopId(String openId, String shopId, Integer type, String nickName, String avatar) {
TbUserShopMsg shopMsg= tbUserShopMsgMapper.selectByShopIdAndOpenId(Integer.valueOf(shopId),openId);
if(Objects.isNull(shopMsg)){
shopMsg=new TbUserShopMsg();
shopMsg.setShopId(Integer.valueOf(shopId));
shopMsg.setOpenId(openId);
shopMsg.setCreateTime(new Date());
shopMsg.setStatus("1");
tbUserShopMsgMapper.insert(shopMsg);
}
// 为商家绑定openid // 为商家绑定openid
TbShopOpenId tbShopOpenId = shopOpenIdMapper.countByOpenId(openId, Integer.valueOf(shopId), type); TbShopOpenId tbShopOpenId = shopOpenIdMapper.countByOpenId(openId, Integer.valueOf(shopId), type);
if ( tbShopOpenId == null) { if (tbShopOpenId == null) {
TbShopOpenId shopOpenId = new TbShopOpenId(); TbShopOpenId shopOpenId = new TbShopOpenId();
shopOpenId.setOpenId(openId); shopOpenId.setOpenId(openId);
shopOpenId.setCreateTime(DateUtil.date()); shopOpenId.setCreateTime(DateUtil.date());
shopOpenId.setShopId(Integer.valueOf(shopId)); shopOpenId.setShopId(Integer.valueOf(shopId));
shopOpenId.setStatus(1); shopOpenId.setStatus(1);
shopOpenId.setNickname(nickName);
shopOpenId.setAvatar(avatar);
shopOpenId.setType(type == null ? -1 : type);
shopOpenIdMapper.insert(shopOpenId); shopOpenIdMapper.insert(shopOpenId);
}else { } else {
tbShopOpenId.setUpdateTime(DateUtil.date()); tbShopOpenId.setUpdateTime(DateUtil.date());
tbShopOpenId.setNickname(nickName);
tbShopOpenId.setAvatar(avatar);
shopOpenIdMapper.updateByPrimaryKeySelective(tbShopOpenId); shopOpenIdMapper.updateByPrimaryKeySelective(tbShopOpenId);
} }
} }
public Result wxBusinessLogin(String openId,String shopId){ public Result wxBusinessLogin(String openId, String shopId) {
TbUserShopMsg shopMsg= tbUserShopMsgMapper.selectByShopIdAndOpenId(Integer.valueOf(shopId),openId); TbUserShopMsg shopMsg = tbUserShopMsgMapper.selectByShopIdAndOpenId(Integer.valueOf(shopId), openId);
if(Objects.isNull(shopMsg)){ if (Objects.isNull(shopMsg)) {
shopMsg=new TbUserShopMsg(); shopMsg = new TbUserShopMsg();
shopMsg.setShopId(Integer.valueOf(shopId)); shopMsg.setShopId(Integer.valueOf(shopId));
shopMsg.setOpenId(openId); shopMsg.setOpenId(openId);
shopMsg.setCreateTime(new Date()); shopMsg.setCreateTime(new Date());
@ -109,14 +107,14 @@ public class LoginService {
shopOpenId.setStatus(1); shopOpenId.setStatus(1);
// shopOpenIdMapper.insert(shopOpenId); // shopOpenIdMapper.insert(shopOpenId);
} }
return Result.success(CodeEnum.SUCCESS,shopMsg); return Result.success(CodeEnum.SUCCESS, shopMsg);
} }
public Result wxCustomLogin(String openId,String headImage,String nickName,String telephone,String ip) { public Result wxCustomLogin(String openId, String headImage, String nickName, String telephone, String ip) {
TbUserInfo userInfo= tbUserInfoMapper.selectByOpenId(openId); TbUserInfo userInfo = tbUserInfoMapper.selectByOpenId(openId);
if(ObjectUtil.isNull(userInfo)){ if (ObjectUtil.isNull(userInfo)) {
userInfo=new TbUserInfo(); userInfo = new TbUserInfo();
userInfo.setAmount(BigDecimal.ZERO); userInfo.setAmount(BigDecimal.ZERO);
userInfo.setChargeAmount(BigDecimal.ZERO); userInfo.setChargeAmount(BigDecimal.ZERO);
userInfo.setLineOfCredit(BigDecimal.ZERO); userInfo.setLineOfCredit(BigDecimal.ZERO);
@ -124,9 +122,9 @@ public class LoginService {
userInfo.setConsumeAmount(BigDecimal.ZERO); userInfo.setConsumeAmount(BigDecimal.ZERO);
userInfo.setTotalScore(0); userInfo.setTotalScore(0);
userInfo.setLockScore(0); userInfo.setLockScore(0);
userInfo.setHeadImg(ObjectUtil.isNotNull(headImage)?headImage:""); userInfo.setHeadImg(ObjectUtil.isNotNull(headImage) ? headImage : "");
userInfo.setNickName(ObjectUtil.isNotNull(nickName)?nickName:"微信用户"); userInfo.setNickName(ObjectUtil.isNotNull(nickName) ? nickName : "微信用户");
userInfo.setTelephone(ObjectUtil.isNotNull(telephone)?telephone:""); userInfo.setTelephone(ObjectUtil.isNotNull(telephone) ? telephone : "");
userInfo.setMiniAppOpenId(openId); userInfo.setMiniAppOpenId(openId);
userInfo.setStatus(Byte.parseByte("1")); userInfo.setStatus(Byte.parseByte("1"));
userInfo.setParentType("PERSON"); userInfo.setParentType("PERSON");
@ -142,7 +140,7 @@ public class LoginService {
userInfo.setLastLogInAt(System.currentTimeMillis()); userInfo.setLastLogInAt(System.currentTimeMillis());
userInfo.setUpdatedAt(System.currentTimeMillis()); userInfo.setUpdatedAt(System.currentTimeMillis());
tbUserInfoMapper.insert(userInfo); tbUserInfoMapper.insert(userInfo);
}else { } else {
userInfo.setUpdatedAt(System.currentTimeMillis()); userInfo.setUpdatedAt(System.currentTimeMillis());
userInfo.setLastLogInAt(System.currentTimeMillis()); userInfo.setLastLogInAt(System.currentTimeMillis());
tbUserInfoMapper.updateByPrimaryKeySelective(userInfo); tbUserInfoMapper.updateByPrimaryKeySelective(userInfo);
@ -283,7 +281,7 @@ public class LoginService {
* @param nickName * @param nickName
* @return * @return
*/ */
public TbUserInfo register(String phone, String openId,String password, String nickName) { public TbUserInfo register(String phone, String openId, String password, String nickName) {
TbUserInfo userInfo = new TbUserInfo(); TbUserInfo userInfo = new TbUserInfo();
userInfo.setAmount(BigDecimal.ZERO); userInfo.setAmount(BigDecimal.ZERO);
@ -313,7 +311,7 @@ public class LoginService {
if (StringUtils.isNotBlank(password)) { if (StringUtils.isNotBlank(password)) {
userInfo.setPassword(MD5Utils.MD5Encode(password, "UTF-8")); userInfo.setPassword(MD5Utils.MD5Encode(password, "UTF-8"));
} }
List<TbShopUser> tbShopUsers = tbShopUserMapper.selectByPhone(phone); List<TbShopUser> tbShopUsers = tbShopUserMapper.selectByPhone(phone);
for (TbShopUser tbShopUser : tbShopUsers) { for (TbShopUser tbShopUser : tbShopUsers) {
tbShopUser.setUserId(userInfo.getId() + ""); tbShopUser.setUserId(userInfo.getId() + "");
tbShopUserMapper.updateByPrimaryKey(tbShopUser); tbShopUserMapper.updateByPrimaryKey(tbShopUser);
@ -342,13 +340,13 @@ public class LoginService {
} }
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public Result appLogin(String username,String openId, String password) { public Result appLogin(String username, String openId, String password) {
TbUserInfo userInfo = tbUserInfoMapper.selectByPhone(username); TbUserInfo userInfo = tbUserInfoMapper.selectByPhone(username);
if (ObjectUtil.isNull(userInfo)) { if (ObjectUtil.isNull(userInfo)) {
if (StringUtils.isNotBlank(password)) { if (StringUtils.isNotBlank(password)) {
return Result.fail("暂未设置密码,请使用验证码登录"); return Result.fail("暂未设置密码,请使用验证码登录");
} }
userInfo = register(username,openId, password, username); userInfo = register(username, openId, password, username);
} else { } else {
if (StringUtils.isNotBlank(userInfo.getMiniAppOpenId())) { if (StringUtils.isNotBlank(userInfo.getMiniAppOpenId())) {
if (!userInfo.getMiniAppOpenId().equals(openId)) { if (!userInfo.getMiniAppOpenId().equals(openId)) {
@ -423,7 +421,7 @@ public class LoginService {
tbShopUserMapper.updateByPrimaryKeySelective(tbShopUser); tbShopUserMapper.updateByPrimaryKeySelective(tbShopUser);
return Result.success(CodeEnum.SUCCESS, "46"+dynamicCode); return Result.success(CodeEnum.SUCCESS, "46" + dynamicCode);
} }
@ -439,14 +437,14 @@ public class LoginService {
public Result upPhone(String openId, String phone, String shopId) { public Result upPhone(String openId, String phone, String shopId) {
TbUserInfo userInfo = tbUserInfoMapper.selectByOpenId(openId); TbUserInfo userInfo = tbUserInfoMapper.selectByOpenId(openId);
// 同一个手机号 同一个店 userId 不为空 // 同一个手机号 同一个店 userId 不为空
TbShopUser tbShopUserPC = tbShopUserMapper.selectPCByPhoneAndShopId(userInfo.getTelephone(),shopId); TbShopUser tbShopUserPC = tbShopUserMapper.selectPCByPhoneAndShopId(userInfo.getTelephone(), shopId);
if (tbShopUserPC != null) { if (tbShopUserPC != null) {
TbShopUser tbShopUserSM = tbShopUserMapper.selectByUserIdAndShopId(userInfo.getId().toString(),shopId); TbShopUser tbShopUserSM = tbShopUserMapper.selectByUserIdAndShopId(userInfo.getId().toString(), shopId);
tbShopUserMapper.deleteByPrimaryKey(tbShopUserSM.getId()); tbShopUserMapper.deleteByPrimaryKey(tbShopUserSM.getId());
tbShopUserPC.setUserId(userInfo.getId().toString()); tbShopUserPC.setUserId(userInfo.getId().toString());
tbShopUserMapper.updateByPrimaryKey(tbShopUserPC); tbShopUserMapper.updateByPrimaryKey(tbShopUserPC);
}else { } else {
TbShopUser tbShopUserSM = tbShopUserMapper.selectByUserIdAndShopId(userInfo.getId().toString(),shopId); TbShopUser tbShopUserSM = tbShopUserMapper.selectByUserIdAndShopId(userInfo.getId().toString(), shopId);
if (tbShopUserSM != null) { if (tbShopUserSM != null) {
tbShopUserSM.setIsVip(Byte.parseByte("1")); tbShopUserSM.setIsVip(Byte.parseByte("1"));
tbShopUserSM.setTelephone(phone); tbShopUserSM.setTelephone(phone);
@ -460,7 +458,7 @@ public class LoginService {
return Result.success(CodeEnum.SUCCESS); return Result.success(CodeEnum.SUCCESS);
} }
public void registerShopUser(TbUserInfo userInfo,String shopId) { public void registerShopUser(TbUserInfo userInfo, String shopId) {
TbShopUser shopUser = new TbShopUser(); TbShopUser shopUser = new TbShopUser();
shopUser.setName(userInfo.getNickName()); shopUser.setName(userInfo.getNickName());
shopUser.setSex(userInfo.getSex()); shopUser.setSex(userInfo.getSex());

View File

@ -162,7 +162,7 @@ public class ProductService {
return Result.success(CodeEnum.SUCCESS, concurrentMap); return Result.success(CodeEnum.SUCCESS, concurrentMap);
} }
public JSONArray querySpec(QuerySpecDTO querySpecDTO) { public Object querySpec(QuerySpecDTO querySpecDTO) {
TbProduct tbProduct = tbProductMapper.selectById(querySpecDTO.getProductId()); TbProduct tbProduct = tbProductMapper.selectById(querySpecDTO.getProductId());
if (tbProduct == null) { if (tbProduct == null) {
throw new MsgException("商品不存在"); throw new MsgException("商品不存在");
@ -171,71 +171,128 @@ public class ProductService {
// 重组有效规格数据 // 重组有效规格数据
String tagSnap = skuResult != null ? skuResult.getTagSnap() : null; String tagSnap = skuResult != null ? skuResult.getTagSnap() : null;
List<TbProductSku> tbProductSkus = tbProductSkuMapper.selectGroundingByProId(querySpecDTO.getProductId());
JSONArray finalSnap = new JSONArray(); JSONArray finalSnap = new JSONArray();
// if (tagSnap != null) {
// JSONArray tagSnaps = JSONObject.parseArray(tagSnap);
// HashMap<String, String> reverseTagSnapMap = new HashMap<>();
// JSONObject snapJSON;
// for (Object snap : tagSnaps) {
// snapJSON = (JSONObject)snap;
// reverseTagSnapMap.put(snapJSON.getString("value"), snapJSON.getString("name"));
// }
// // 上下架对应的sku
// HashSet<String> specSet = new HashSet<>();
// for (TbProductSku item : tbProductSkus) {
// String specSnap = item.getSpecSnap();
//
// ArrayList<QuerySpecDTO.QuerySpec> skuSpecList = new ArrayList<>();
// if (specSnap != null) {
// String[] split = specSnap.split(",");
// for (String snap : split) {
// reverseTagSnapMap.forEach((k, v) -> {
// if (k.contains(snap)) {
// skuSpecList.add(new QuerySpecDTO.QuerySpec(v, snap));
// }
// });
// }
//
// boolean isHave = false;
// for (QuerySpecDTO.QuerySpec spec : querySpecDTO.getQuerySpecList()) {
// for (QuerySpecDTO.QuerySpec querySpec : skuSpecList) {
// isHave = querySpec.equals(spec);
// if (isHave) break;
// }
//
// }
// if (querySpecDTO.getQuerySpecList().isEmpty() || isHave) {
// specSet.addAll(Arrays.asList(split));
// }
// }
// }
//
//
// for (Object snap : tagSnaps) {
// snapJSON = (JSONObject) snap;
// String values = snapJSON.getString("value");
//
// ArrayList<LinkedHashMap<String, Object>> data = new ArrayList<>();
// if (StrUtil.isNotBlank(values)) {
// String[] valueList = values.split(",");
// for (String value : valueList) {
// LinkedHashMap<String, Object> finalValue = new LinkedHashMap<>();
// finalValue.put("info", value);
// finalValue.put("isGrounding", specSet.contains(value));
// data.add(finalValue);
// }
// if (!data.isEmpty()) {
// snapJSON.put("value", data);
// finalSnap.add(snapJSON);
// }
//
// }
// }
// }
List<String> result = new ArrayList<>();
if (tagSnap != null) { if (tagSnap != null) {
JSONArray tagSnaps = JSONObject.parseArray(tagSnap); JSONArray tagSnaps = JSONObject.parseArray(tagSnap);
HashMap<String, String> reverseTagSnapMap = new HashMap<>(); List<List<String>> valuesList = new ArrayList<>();
JSONObject snapJSON;
for (Object snap : tagSnaps) { // 提取所有 value 的列表
snapJSON = (JSONObject)snap; for (int i = 0; i < tagSnaps.size(); i++) {
reverseTagSnapMap.put(snapJSON.getString("value"), snapJSON.getString("name")); JSONObject jsonObject = tagSnaps.getJSONObject(i);
String[] values = jsonObject.getString("value").split(",");
valuesList.add(Arrays.asList(values));
} }
List<TbProductSku> tbProductSkus = tbProductSkuMapper.selectGroundingByProId(querySpecDTO.getProductId()); // 生成所有可能的排列组合
// 上下架对应的sku generateCombinations(valuesList, 0, new ArrayList<>(), result);
HashSet<String> specSet = new HashSet<>();
for (TbProductSku item : tbProductSkus) {
String specSnap = item.getSpecSnap();
ArrayList<QuerySpecDTO.QuerySpec> skuSpecList = new ArrayList<>();
if (specSnap != null) {
String[] split = specSnap.split(",");
for (String snap : split) {
reverseTagSnapMap.forEach((k, v) -> {
if (k.contains(snap)) {
skuSpecList.add(new QuerySpecDTO.QuerySpec(v, snap));
}
});
}
boolean isHave = false;
for (QuerySpecDTO.QuerySpec spec : querySpecDTO.getQuerySpecList()) {
for (QuerySpecDTO.QuerySpec querySpec : skuSpecList) {
isHave = querySpec.equals(spec);
if (isHave) break;
}
}
if (querySpecDTO.getQuerySpecList().isEmpty() || isHave) {
specSet.addAll(Arrays.asList(split));
}
}
}
for (Object snap : tagSnaps) {
snapJSON = (JSONObject) snap;
String values = snapJSON.getString("value");
ArrayList<LinkedHashMap<String, Object>> data = new ArrayList<>();
if (StrUtil.isNotBlank(values)) {
String[] valueList = values.split(",");
for (String value : valueList) {
LinkedHashMap<String, Object> finalValue = new LinkedHashMap<>();
finalValue.put("info", value);
finalValue.put("isGrounding", specSet.contains(value));
data.add(finalValue);
}
if (!data.isEmpty()) {
snapJSON.put("value", data);
finalSnap.add(snapJSON);
}
}
}
} }
return finalSnap; ArrayList<HashMap<String, Object>> specList = new ArrayList<>();
tbProductSkus.forEach(item -> {
HashMap<String, Object> itemMap = new HashMap<>();
itemMap.put("specSnap", item.getSpecSnap());
itemMap.put("skuId", item.getId());
specList.add(itemMap);
});
ArrayList<HashMap<String, Object>> otherVal = new ArrayList<>();
for (String res : result) {
boolean found = false;
for (HashMap<String, Object> spec : specList) {
if (res.equals(spec.get("specSnap").toString())) {
spec.put("isGrounding", true);
found = true;
break;
}
}
if (!found) {
HashMap<String, Object> itemMap = new HashMap<>();
itemMap.put("specSnap", res);
itemMap.put("skuId", null);
itemMap.put("isGrounding", false);
otherVal.add(itemMap);
}
}
specList.addAll(otherVal);
return specList;
} }
private static void generateCombinations(List<List<String>> valuesList, int index, List<String> current, List<String> result) {
if (index == valuesList.size()) {
result.add(String.join(",", current));
return;
}
for (String value : valuesList.get(index)) {
current.add(value);
generateCombinations(valuesList, index + 1, current, result);
current.remove(current.size() - 1); // 回溯
}
}
public List<TbProduct> handleDate(List<TbProduct> products){ public List<TbProduct> handleDate(List<TbProduct> products){
if (!CollectionUtils.isEmpty(products)) { if (!CollectionUtils.isEmpty(products)) {

View File

@ -41,10 +41,10 @@
<insert id="insert" keyColumn="id" keyProperty="id" parameterType="com.chaozhanggui.system.cashierservice.entity.TbShopOpenId" useGeneratedKeys="true"> <insert id="insert" keyColumn="id" keyProperty="id" parameterType="com.chaozhanggui.system.cashierservice.entity.TbShopOpenId" useGeneratedKeys="true">
insert into tb_shop_open_id insert into tb_shop_open_id
( id,shop_id,open_id ( id,shop_id,open_id
,status,create_time,update_time ,status,create_time,update_time, type, nickname, avatar
) )
values (#{id,jdbcType=INTEGER},#{shopId,jdbcType=INTEGER},#{openId,jdbcType=VARCHAR} values (#{id,jdbcType=INTEGER},#{shopId,jdbcType=INTEGER},#{openId,jdbcType=VARCHAR}
,#{status,jdbcType=TINYINT},#{createTime,jdbcType=TIMESTAMP},#{updateTime,jdbcType=TIMESTAMP} ,#{status,jdbcType=TINYINT},#{createTime,jdbcType=TIMESTAMP},#{updateTime,jdbcType=TIMESTAMP},#{type,jdbcType=INTEGER}, #{nickname,jdbcType=VARCHAR}, #{avatar,jdbcType=VARCHAR}
) )
</insert> </insert>
<insert id="insertSelective" keyColumn="id" keyProperty="id" parameterType="com.chaozhanggui.system.cashierservice.entity.TbShopOpenId" useGeneratedKeys="true"> <insert id="insertSelective" keyColumn="id" keyProperty="id" parameterType="com.chaozhanggui.system.cashierservice.entity.TbShopOpenId" useGeneratedKeys="true">
@ -84,6 +84,15 @@
<if test="updateTime != null"> <if test="updateTime != null">
update_time = #{updateTime,jdbcType=TIMESTAMP}, update_time = #{updateTime,jdbcType=TIMESTAMP},
</if> </if>
<if test="type != null">
`type` = #{type,jdbcType=INTEGER},
</if>
<if test="nickname != null">
`nickname` = #{nickname,jdbcType=INTEGER},
</if>
<if test="avatar != null">
`avatar` = #{avatar,jdbcType=INTEGER},
</if>
</set> </set>
where id = #{id,jdbcType=INTEGER} where id = #{id,jdbcType=INTEGER}
</update> </update>