diff --git a/.gitignore b/.gitignore index 49023702..583388bc 100644 --- a/.gitignore +++ b/.gitignore @@ -48,3 +48,4 @@ log temp/ docker-compose.yml +/src/main/resources/application-local.properties diff --git a/src/main/java/com/ai/da/model/dto/GenerateLikeDTO.java b/src/main/java/com/ai/da/model/dto/GenerateLikeDTO.java index 58734272..9e76dae3 100644 --- a/src/main/java/com/ai/da/model/dto/GenerateLikeDTO.java +++ b/src/main/java/com/ai/da/model/dto/GenerateLikeDTO.java @@ -22,6 +22,9 @@ public class GenerateLikeDTO { @ApiModelProperty("当一级类型为Sketchboard时,二级类型 Outwear Dress Blouse Skirt Trousers;当一级类型为Printboard时,二级类型 Slogan Logo Pattern") private String level2Type; + @ApiModelProperty("年龄段") + private String ageGroup; + @ApiModelProperty("性别") private String gender; diff --git a/src/main/java/com/ai/da/python/PythonService.java b/src/main/java/com/ai/da/python/PythonService.java index 10dad374..83a31a0e 100644 --- a/src/main/java/com/ai/da/python/PythonService.java +++ b/src/main/java/com/ai/da/python/PythonService.java @@ -4092,9 +4092,11 @@ public class PythonService { content.put("pose_id", String.valueOf(poseId)); RequestBody body = RequestBody.create(mediaType, JSON.toJSONString(content)); - log.info("poseTransformation 请求地址: {}", accessPythonIp + ":" + accessPythonPort + "/api/pose_transform"); +// String uri = "/api/pose_transform"; + String uri = "/api/comfyui_pose_transform"; + log.info("poseTransformation 请求地址: {}", accessPythonIp + ":" + accessPythonPort + uri); Request request = new Request.Builder() - .url(accessPythonIp + ":" + accessPythonPort + "/api/pose_transform") + .url(accessPythonIp + ":" + accessPythonPort + uri) .method("POST", body) .addHeader("Content-Type", "application/json") .build(); diff --git a/src/main/java/com/ai/da/service/impl/AffiliateServiceImpl.java b/src/main/java/com/ai/da/service/impl/AffiliateServiceImpl.java index 8d535cbf..551f86a2 100644 --- a/src/main/java/com/ai/da/service/impl/AffiliateServiceImpl.java +++ b/src/main/java/com/ai/da/service/impl/AffiliateServiceImpl.java @@ -173,7 +173,7 @@ public class AffiliateServiceImpl extends ServiceImpl wrapper = new LambdaQueryWrapper() + .eq(CollectionSort::getProjectId, projectId) + .orderByAsc(CollectionSort::getSort); + + if (parentId != null) { + wrapper.eq(CollectionSort::getParentId, parentId); + } else { + wrapper.isNull(CollectionSort::getParentId); + } // 2. 查询同组数据,按原排序升序 - List list = baseMapper.selectList( - new LambdaQueryWrapper() - .eq(CollectionSort::getProjectId, projectId) - .eq(CollectionSort::getParentId, parentId) - .orderByAsc(CollectionSort::getSort) - ); + List list = baseMapper.selectList(wrapper); // 3. 重新编号 sort,从 1 开始 for (int i = 0; i < list.size(); i++) { diff --git a/src/main/java/com/ai/da/service/impl/ConvenientInquiryServiceImpl.java b/src/main/java/com/ai/da/service/impl/ConvenientInquiryServiceImpl.java index 63acfb1d..3381c369 100644 --- a/src/main/java/com/ai/da/service/impl/ConvenientInquiryServiceImpl.java +++ b/src/main/java/com/ai/da/service/impl/ConvenientInquiryServiceImpl.java @@ -827,9 +827,7 @@ public class ConvenientInquiryServiceImpl extends ServiceImpl i // 2.2、添加到library AuthPrincipalVo userInfo = UserContext.getUserHolder(); Long accountId = userInfo.getId(); - Library library = setLibrary(accountId, generateLikeDTO, generateDetail.getUrl()); + Library library = setLibrary(accountId, generateLikeDTO, generateDetail.getUrl(), generateLikeDTO.getAgeGroup()); libraryService.save(library); // 3、更新generateDetail表的isLike列和libraryId列 @@ -555,12 +555,13 @@ public class GenerateServiceImpl extends ServiceImpl i return Boolean.TRUE; } - public Library setLibrary(Long accountId, GenerateLikeDTO generateLikeDTO, String imageUrl) { + public Library setLibrary(Long accountId, GenerateLikeDTO generateLikeDTO, String imageUrl, String ageGroup) { Library library = new Library(); library.setAccountId(accountId); library.setLevel1Type(generateLikeDTO.getLevel1Type()); library.setLevel2Type(StringUtil.isNullOrEmpty(generateLikeDTO.getLevel2Type()) ? null : generateLikeDTO.getLevel2Type()); library.setLevel3Type(StringUtil.isNullOrEmpty(generateLikeDTO.getGender()) ? null : generateLikeDTO.getGender()); + library.setAgeGroup(ageGroup); library.setName(DateUtil.getTimeStamp(generateLikeDTO.getTimeZone()) + "_N_G"); library.setUrl(imageUrl); try { @@ -2554,7 +2555,7 @@ public class GenerateServiceImpl extends ServiceImpl i if (Objects.nonNull(poseTransformDTO.getParentId()) && !poseTransformDTO.getParentId().equals(0L)) { return disOrLikePose(poseTransformationId, "like", - poseTransformDTO.getProjectId(), poseTransformDTO.getParentId()); + poseTransformDTO.getProjectId(), poseTransformDTO.getUserLikeSortId()); } return null; } diff --git a/src/main/java/com/ai/da/service/impl/PaymentInfoServiceImpl.java b/src/main/java/com/ai/da/service/impl/PaymentInfoServiceImpl.java index 9442d076..b39843ce 100644 --- a/src/main/java/com/ai/da/service/impl/PaymentInfoServiceImpl.java +++ b/src/main/java/com/ai/da/service/impl/PaymentInfoServiceImpl.java @@ -27,6 +27,7 @@ import io.netty.util.internal.StringUtil; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; import org.springframework.util.CollectionUtils; import javax.annotation.Resource; @@ -224,6 +225,7 @@ public class PaymentInfoServiceImpl extends ServiceImpl qwSI = new QueryWrapper<>(); if (!StringUtil.isNullOrEmpty(subscriptionId)) { - qwSI.eq("subscription_id", subscriptionId); + // 区分当前订阅的时段,从而确定是新订单还是续订订单的记录 + qwSI.lambda().eq(SubscriptionInfo::getSubscriptionId, subscriptionId) + .lt(SubscriptionInfo::getCurrentPeriodStart, secondsTimestamp) + .gt(SubscriptionInfo::getCurrentPeriodEnd, secondsTimestamp); List subscriptionInfoList = subscriptionInfoMapper.selectList(qwSI); if (subscriptionInfoList.isEmpty()){ @@ -1024,7 +1036,9 @@ public class StripeServiceImpl implements StripeService { } } }else if (!StringUtil.isNullOrEmpty(orderNo)) { - qwSI.eq("order_no", orderNo); + qwSI.lambda().eq(SubscriptionInfo::getOrderNo, orderNo) + .lt(SubscriptionInfo::getCurrentPeriodStart, secondsTimestamp) + .gt(SubscriptionInfo::getCurrentPeriodEnd, secondsTimestamp); subscriptionInfo = subscriptionInfoMapper.selectOne(qwSI); if (Objects.isNull(subscriptionInfo)){ log.info("不发送邮件,原因:【根据order_no:{},查询到的subscriptionInfo为空】", orderNo); @@ -1036,7 +1050,12 @@ public class StripeServiceImpl implements StripeService { } QueryWrapper qwPI = new QueryWrapper<>(); - qwPI.eq("order_no", subscriptionInfo.getOrderNo()).orderByDesc("id"); + String periodStart = DateUtil.changeTimeStampFormat(subscriptionInfo.getCurrentPeriodStart(), "seconds", CommonConstant.TIME_FORMAT_yyyy_MM_dd_HH_mm_ss); + String periodEnd = DateUtil.changeTimeStampFormat(subscriptionInfo.getCurrentPeriodEnd(), "seconds", CommonConstant.TIME_FORMAT_yyyy_MM_dd_HH_mm_ss); + + qwPI.lambda().eq(PaymentInfo::getOrderNo, subscriptionInfo.getOrderNo()) + .between(PaymentInfo::getCreateTime, periodStart, periodEnd) + .orderByDesc(PaymentInfo::getId); List paymentInfos = paymentInfoMapper.selectList(qwPI); if (paymentInfos.isEmpty()) { log.info("不发送邮件,原因:【根据order_no:{},查询到的paymentInfos为空】", orderNo);