Compare commits

..

No commits in common. "a1d3c745539f8c717563f405430cf7cb028d25e9" and "e634c4c78972053a7736b089b3ce87396450602c" have entirely different histories.

46 changed files with 207 additions and 291 deletions

View File

@ -90,7 +90,6 @@ public class PositionController extends ControllerBase {
}
}
result.setLanguage(positionLanguageResult);
result.setTicketManage(ent.getTicketManage());
return ApiResult.success(result);
@ -122,7 +121,6 @@ public class PositionController extends ControllerBase {
// ent.setDataModifyUserNo(AdminUserUtil.getUserNo());
// ent.setDataModifyUserName(AdminUserUtil.getUserName());
// ent.setDataModifyTime(LocalDateTime.now());
ent.setTicketManage(positionDetailDto.getTicketManage());
positionService.save(ent);
return ApiResult.success(true);
}
@ -138,7 +136,6 @@ public class PositionController extends ControllerBase {
ent.setDataModifyUserNo(AdminUserUtil.getUserNo());
ent.setDataModifyUserName(AdminUserUtil.getUserName());
ent.setDataModifyTime(LocalDateTime.now());
ent.setTicketManage(positionDetailDto.getTicketManage());
positionService.updateById(ent);
return ApiResult.success(true);
}

View File

@ -166,7 +166,7 @@ public class ProductBaseController extends ControllerBase{
* @param request 请求参数
*/
@PostMapping("/publishHonor")
public ApiResult<Void> publishHonor(@Valid @RequestBody BatchPublishRequest request) {
public ApiResult<Void> publishHonor(@Valid @RequestBody ProductPublishRequest request){
productHonorService.publish(request);
return ApiResult.success();
}
@ -233,7 +233,7 @@ public class ProductBaseController extends ControllerBase{
* @param request 请求参数
*/
@PostMapping("/publishCase")
public ApiResult<Void> publishCase(@Valid @RequestBody BatchPublishRequest request) {
public ApiResult<Void> publishCase(@Valid @RequestBody ProductPublishRequest request){
productCaseService.publish(request);
return ApiResult.success();
}

View File

@ -62,6 +62,9 @@ public class ProductModelController extends ControllerBase{
@Resource
private IProductModelParamsItemService productModelParamsItemService;
@Resource
private IProductModelImageService productModelImageService;
@Resource
private IProductModelVideoService productModelVideoService;
@ -845,7 +848,7 @@ public class ProductModelController extends ControllerBase{
* @param request 请求参数
*/
@PostMapping("/publishVideo")
public ApiResult<Void> publishVideo(@Valid @RequestBody BatchPublishRequest request) {
public ApiResult<Void> publishVideo(@Valid @RequestBody ProductPublishRequest request){
productModelVideoService.publish(request);
return ApiResult.success();
}
@ -931,7 +934,7 @@ public class ProductModelController extends ControllerBase{
* @param request 请求参数
*/
@PostMapping("/publishFile")
public ApiResult<Void> publishFile(@Valid @RequestBody BatchPublishRequest request) {
public ApiResult<Void> publishFile(@Valid @RequestBody ProductModelPublishRequest request) {
productModelFileService.publish(request);
return ApiResult.success();
}

View File

@ -49,10 +49,10 @@ public class TestController extends ControllerBase{
}
}
// @GetMapping("test")
// public ApiResult<Boolean> test(@RequestParam Integer userId){
// return ApiResult.success(ticketCallService.isInCall(userId));
// }
@GetMapping("test")
public ApiResult<Boolean> test(@RequestParam Integer userId){
return ApiResult.success(ticketCallService.isInCall(userId));
}
/**
* 翻译为日语

View File

@ -6,6 +6,7 @@ import lombok.Data;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotNull;
import java.time.LocalDateTime;
import java.util.List;
/**
@ -30,11 +31,6 @@ public class PositionDetailDTO {
@NotNull(message = "属性不能为空")
private Integer positionAttribute;
/**
* 是否授予工单权限
*/
private Boolean ticketManage;

View File

@ -28,11 +28,6 @@ public class PositionDetailVO {
*/
private Integer positionAttribute;
/**
* 是否授予工单权限
*/
private Boolean ticketManage;
/**
* 创建人-账号
*/

View File

@ -0,0 +1,33 @@
package com.nflg.mobilebroken.admin.task;
import com.nflg.mobilebroken.repository.entity.ProductModel;
import com.nflg.mobilebroken.repository.service.IProductModelService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.time.LocalDateTime;
@Slf4j
@Component
public class ProductScheduledTasks {
@Resource
private IProductModelService productModelService;
/**
* 机型是否新版本设置
* 每天午夜12点执行一次
*/
@Scheduled(cron = "0 0 0 * * ?")
public void resetRecommend() {
log.info("【产品中心-机型-新品】开始执行");
productModelService.lambdaUpdate()
.set(ProductModel::getRecommend, false)
.eq(ProductModel::getRecommend, true)
.gt(ProductModel::getRecommendTime, LocalDateTime.now().minusYears(2))
.update();
log.info("【产品中心-机型-新品】执行完毕");
}
}

View File

@ -1,5 +1,9 @@
package com.nflg.mobilebroken.common.constant;
import cn.hutool.core.collection.ListUtil;
import java.util.List;
public class Constant {
public static final String FROM_APP = "app";
@ -108,8 +112,9 @@ public class Constant {
public static final String DICTIONARY_ITEM_ACCOUNT_HAS_EXPIRED="AccountHasExpired";
public static final String DICTIONARY_SOLUTION_MEASURES = "SolutionMeasures";
public static final List<String> ROLE_CODE_TICKET_MANAGERS = ListUtil.of(TITLE_DIRECTOROF_BUSINESS_UNIT,TITLE_TECHNICAL_MANAGER,TITLE_SALES_MANAGER,TITLE_TEST_MANAGER,TITLE_QUALITY_MANAGER,DICTIONARY_TYPE_TITLE_CQM);
public static final String DICTIONARY_SOLUTION_MEASURES = "SolutionMeasures";
public static final String DICTIONARY_SOLUTION_REVIEW_DEPARTMENT = "SolutionReviewDepartment";
public static final String DICTIONARY_DEVICE_STATE ="deviceState";

View File

@ -2,6 +2,7 @@ package com.nflg.mobilebroken.common.pojo.request;
import lombok.Data;
import javax.validation.constraints.NotEmpty;
import javax.validation.constraints.NotNull;
import java.util.List;
@ -17,5 +18,6 @@ public class FileDefaultConfigRequest {
/**
* 配置项
*/
@NotEmpty
private List<FileDefaultConfigItemRequest> items;
}

View File

@ -4,7 +4,6 @@ import lombok.Data;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotNull;
import java.time.LocalDateTime;
@Data
public class ProductModelAddRequest {
@ -49,11 +48,6 @@ public class ProductModelAddRequest {
*/
private Boolean recommend;
/**
* 新品过期时间
*/
private LocalDateTime recommendExpireTime;
/**
* 是否发布
*/

View File

@ -1,15 +1,13 @@
package com.nflg.mobilebroken.common.pojo.request;
import lombok.Data;
import lombok.experimental.Accessors;
import javax.validation.constraints.NotEmpty;
import javax.validation.constraints.NotNull;
import java.util.List;
@Data
@Accessors(chain = true)
public class BatchPublishRequest {
public class ProductModelPublishRequest {
@NotEmpty
private List<Integer> ids;

View File

@ -3,9 +3,7 @@ package com.nflg.mobilebroken.common.pojo.vo;
import lombok.Data;
import lombok.experimental.Accessors;
import java.time.LocalDateTime;
import java.util.List;
import java.util.Objects;
@Data
@Accessors
@ -58,15 +56,6 @@ public class FrontendProductModelSearchVO {
*/
private Boolean recommend;
public Boolean getRecommend() {
return recommend && (Objects.nonNull(recommendExpireTime) && LocalDateTime.now().isBefore(recommendExpireTime));
}
/**
* 新品过期时间
*/
private LocalDateTime recommendExpireTime;
/**
* 机型介绍
*/

View File

@ -54,11 +54,6 @@ public class ProductModelSearchVO {
*/
private Boolean recommend;
/**
* 新品过期时间
*/
private LocalDateTime recommendExpireTime;
/**
* 是否启用
*/

View File

@ -3,9 +3,7 @@ package com.nflg.mobilebroken.common.pojo.vo;
import lombok.Data;
import lombok.experimental.Accessors;
import java.time.LocalDateTime;
import java.util.List;
import java.util.Objects;
@Data
@Accessors(chain = true)
@ -28,15 +26,6 @@ public class ProductModelVO {
*/
private Boolean recommend;
public Boolean getRecommend() {
return recommend && (Objects.nonNull(recommendExpireTime) && LocalDateTime.now().isBefore(recommendExpireTime));
}
/**
* 新品过期时间
*/
private LocalDateTime recommendExpireTime;
/**
* 主要参数列表
*/

View File

@ -1,5 +1,5 @@
# Nacos 地址
nacos.server-addr=${NACOS_SERVER_ADDR:192.168.0.194:8848}
nacos.server-addr=${NACOS_SERVER_ADDR:112.74.186.154:8848}
#nacos.server-addr=192.168.0.194:8848
#spring.cloud.nacos.discovery.username=nacos
#spring.cloud.nacos.discovery.password=ZLQ8vgmjoJ4?EPJ4]fs_

View File

@ -65,9 +65,9 @@ public class ProductModel implements Serializable {
private Boolean recommend;
/**
* 新品过期时间
* 设置为新品的时间
*/
private LocalDateTime recommendExpireTime;
private LocalDateTime recommendTime;
/**
* 排序

View File

@ -32,7 +32,7 @@ public class ProductModelFileItem implements Serializable {
private Integer modelId;
/**
* 产品机型文件id
* 产品机型id
*/
private Integer modelFileId;

View File

@ -3,13 +3,12 @@ package com.nflg.mobilebroken.repository.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import java.io.Serializable;
import java.time.LocalDateTime;
import lombok.Getter;
import lombok.Setter;
import lombok.experimental.Accessors;
import java.io.Serializable;
import java.time.LocalDateTime;
/**
* <p>
* 职位管理
@ -86,9 +85,4 @@ public class TBasePosition implements Serializable {
* 语言-json
*/
private String positionLanguage;
/**
* 是否授予工单权限
*/
private Boolean ticketManage;
}

View File

@ -1,6 +1,7 @@
package com.nflg.mobilebroken.repository.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Getter;
@ -34,16 +35,16 @@ public class TicketCall implements Serializable {
*/
private Integer ticketId;
// /**
// * 呼叫来源app或者admin
// */
// @TableField("`from`")
// private String from;
//
// /**
// * 呼叫人id
// */
// private Integer callerUserId;
/**
* 呼叫来源app或者admin
*/
@TableField("`from`")
private String from;
/**
* 呼叫人id
*/
private Integer callerUserId;
/**
* 状态0-呼叫中1-通话中2-已结束

View File

@ -20,7 +20,5 @@ public interface AdminUserMapper extends BaseMapper<AdminUser> {
List<AdminUserSimpleVO> getSimples(List<Integer> userIds);
List<Integer> getTickerMangagers();
List<Integer> getCQMIds(String titleCode);
List<Integer> getTickerMangagers(List<String> titleCodes);
}

View File

@ -13,5 +13,5 @@ import com.nflg.mobilebroken.repository.entity.TicketCallJoin;
*/
public interface TicketCallJoinMapper extends BaseMapper<TicketCallJoin> {
boolean isInCall(Integer ticketId, String from, Integer userId);
boolean isInCall(Integer userId);
}

View File

@ -34,7 +34,7 @@ public interface IProductCaseService extends IService<ProductCase> {
void delete(@Valid BatchDeleteRequest request);
void publish(@Valid BatchPublishRequest request);
void publish(@Valid ProductPublishRequest request);
ProductCaseInfoVO getInfo(@Valid @NotNull Integer caseId);

View File

@ -30,7 +30,7 @@ public interface IProductHonorService extends IService<ProductHonor> {
List<ProductHonorVO> get(String language);
void publish(@Valid BatchPublishRequest request);
void publish(@Valid ProductPublishRequest request);
void delete(@Valid BatchDeleteRequest request);

View File

@ -5,7 +5,6 @@ import com.nflg.mobilebroken.common.pojo.request.FileDefaultConfigRequest;
import com.nflg.mobilebroken.common.pojo.request.ProductModelFileItemAddRequest;
import com.nflg.mobilebroken.repository.entity.ProductModelFileItem;
import javax.validation.constraints.NotEmpty;
import java.util.List;
/**
@ -25,6 +24,4 @@ public interface IProductModelFileItemService extends IService<ProductModelFileI
void setFileDefaultCondig(FileDefaultConfigRequest request);
List<ProductModelFileItem> getPublishedByLanguage(Integer modelId);
void removeByFileIds(@NotEmpty List<Integer> ids);
}

View File

@ -31,7 +31,7 @@ public interface IProductModelFileService extends IService<ProductModelFile> {
void delete(@Valid BatchDeleteRequest request);
void publish(@Valid BatchPublishRequest request);
void publish(@Valid ProductModelPublishRequest request);
IPage<ProductModelFile> getList(@Valid ProductModelImageSearchRequest request);

View File

@ -39,5 +39,5 @@ public interface IProductModelHotimageService extends IService<ProductModelHotim
void copyTo(Integer oldId, Integer newId);
ProductHotImageInfoVO getListByLanguage(Integer modelId, String language);
ProductHotImageInfoVO getListByLanguage(Integer modelId);
}

View File

@ -27,7 +27,7 @@ public interface IProductModelImageService extends IService<ProductModelImage> {
void delete(@Valid BatchDeleteRequest request);
void publish(@Valid BatchPublishRequest request);
void publish(@Valid ProductPublishRequest request);
IPage<ProductModelImage> getList(@Valid ProductModelImageSearchRequest request);

View File

@ -29,7 +29,7 @@ public interface IProductModelVideoService extends IService<ProductModelVideo> {
void delete(@Valid BatchDeleteRequest request);
void publish(@Valid BatchPublishRequest request);
void publish(@Valid ProductPublishRequest request);
IPage<ProductModelVideo> getList(@Valid ProductModelImageSearchRequest request);

View File

@ -16,7 +16,7 @@ import javax.validation.constraints.NotNull;
*/
public interface ITicketCallJoinService extends IService<TicketCallJoin> {
boolean isInCall(Integer ticketId, String from, Integer userId);
boolean isInCall(Integer userId);
void join(@Valid @NotNull Integer ticketId, Integer userId, String from);
@ -25,4 +25,6 @@ public interface ITicketCallJoinService extends IService<TicketCallJoin> {
boolean hangUp(Integer callId, Integer userId, String from, boolean reject);
void add(Integer callId, Integer userId, String from);
void hangUpAll(Integer id);
}

View File

@ -15,11 +15,11 @@ import javax.validation.constraints.NotNull;
*/
public interface ITicketCallService extends IService<TicketCall> {
// boolean isInCall(Integer userId);
boolean isInCall(Integer userId);
void add(Integer ticketId, Integer callerUserId,String callerUserFrom, Integer calledUserId, String calledUserFrom);
// boolean hangUp(@NotNull Integer ticketId, Integer userId, String from, boolean reject);
boolean hangUp(@NotNull Integer ticketId, Integer userId, String from, boolean reject);
TicketCall getLast(@NotNull Integer ticketId);
}

View File

@ -1,6 +1,7 @@
package com.nflg.mobilebroken.repository.service.impl;
import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.collection.ListUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
@ -350,12 +351,12 @@ public class AdminUserServiceImpl extends ServiceImpl<AdminUserMapper, AdminUser
@Override
public List<Integer> getTickerMangagers() {
return baseMapper.getTickerMangagers();
return baseMapper.getTickerMangagers(Constant.ROLE_CODE_TICKET_MANAGERS);
}
@Override
public List<Integer> getCQMIds() {
return baseMapper.getCQMIds(Constant.DICTIONARY_TYPE_TITLE_CQM);
return baseMapper.getTickerMangagers(ListUtil.of(Constant.DICTIONARY_TYPE_TITLE_CQM));
}
private String getDepartmentName(Long departmentId) {

View File

@ -1,9 +1,7 @@
package com.nflg.mobilebroken.repository.service.impl;
import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.convert.Convert;
import cn.hutool.core.util.RandomUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@ -29,7 +27,6 @@ import javax.annotation.Resource;
import java.time.LocalDateTime;
import java.util.List;
import java.util.Objects;
import java.util.stream.Collectors;
/**
* <p>
@ -57,8 +54,8 @@ public class ProductCaseServiceImpl extends ServiceImpl<ProductCaseMapper, Produ
.setCreateTime(LocalDateTime.now());
save(entity);
if (request.getPublish()) {
publish(new BatchPublishRequest()
.setIds(List.of(entity.getId()))
publish(new ProductPublishRequest()
.setId(entity.getId())
.setState(PublishState.Published.getState()));
}
productCaseInfoService.add(entity.getId(), request.getItems());
@ -82,8 +79,8 @@ public class ProductCaseServiceImpl extends ServiceImpl<ProductCaseMapper, Produ
info.setUpdateTime(LocalDateTime.now());
updateById(info);
if (request.getPublish()) {
publish(new BatchPublishRequest()
.setIds(List.of(info.getId()))
publish(new ProductPublishRequest()
.setId(info.getId())
.setState(PublishState.Published.getState()));
}
productCaseInfoService.update(request.getItems());
@ -148,20 +145,14 @@ public class ProductCaseServiceImpl extends ServiceImpl<ProductCaseMapper, Produ
productCaseInfoService.delete(request.getIds());
}
@Transactional
@Override
public void publish(BatchPublishRequest request) {
List<ProductCase> list = listByIds(request.getIds());
public void publish(ProductPublishRequest request) {
ProductCase info = getById(request.getId());
VUtils.trueThrowBusinessError(Objects.isNull(info)).throwMessage("无效的数据");
VUtils.trueThrowBusinessError(Objects.equals(info.getState(), request.getState()))
.throwMessage("请勿重复操作");
if (Objects.equals(request.getState(), PublishState.Published.getState())) {
List<String> names = list.stream().filter(ph -> !ph.getEnable()).map(ProductCase::getTitle).collect(Collectors.toList());
VUtils.trueThrowBusinessError(CollectionUtil.isNotEmpty(names)).throwMessage("以下案例被禁用不能发布:" + StrUtil.join(",", names));
}
list.forEach(it -> publish(it, request.getState()));
}
private void publish(ProductCase info, Integer state) {
if (Objects.equals(state, info.getState())) return;
if (Objects.equals(state, PublishState.Published.getState())) {
VUtils.trueThrowBusinessError(!info.getEnable()).throwMessage("不能发布已禁用的数据");
info.setState(PublishState.Published.getState());
info.setPublishBy(AdminUserUtil.getUserName());
info.setPublishTime(LocalDateTime.now());

View File

@ -1,6 +1,5 @@
package com.nflg.mobilebroken.repository.service.impl;
import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@ -24,7 +23,6 @@ import javax.annotation.Resource;
import java.time.LocalDateTime;
import java.util.List;
import java.util.Objects;
import java.util.stream.Collectors;
/**
* <p>
@ -57,8 +55,8 @@ public class ProductHonorServiceImpl extends ServiceImpl<ProductHonorMapper, Pro
.setCreateTime(LocalDateTime.now());
save(productHonor);
if (request.getPublish()) {
publish(new BatchPublishRequest()
.setIds(List.of(productHonor.getId()))
publish(new ProductPublishRequest()
.setId(productHonor.getId())
.setState(PublishState.Published.getState()));
}
productHonorInfoService.add(productHonor.getId(), request.getItems());
@ -88,8 +86,8 @@ public class ProductHonorServiceImpl extends ServiceImpl<ProductHonorMapper, Pro
.eq(ProductHonor::getId, request.getId())
.update();
if (request.getPublish()) {
publish(new BatchPublishRequest()
.setIds(List.of(request.getId()))
publish(new ProductPublishRequest()
.setId(request.getId())
.setState(PublishState.Published.getState()));
}
productHonorInfoService.update(request.getItems());
@ -107,20 +105,14 @@ public class ProductHonorServiceImpl extends ServiceImpl<ProductHonorMapper, Pro
return baseMapper.get(language);
}
@Transactional
@Override
public void publish(BatchPublishRequest request) {
List<ProductHonor> list = listByIds(request.getIds());
public void publish(ProductPublishRequest request) {
ProductHonor info = getById(request.getId());
VUtils.trueThrowBusinessError(Objects.isNull(info)).throwMessage("无效的数据");
VUtils.trueThrowBusinessError(Objects.equals(info.getState(), request.getState()))
.throwMessage("请勿重复操作");
if (Objects.equals(request.getState(), PublishState.Published.getState())) {
List<String> names = list.stream().filter(ph -> !ph.getEnable()).map(ProductHonor::getTitle).collect(Collectors.toList());
VUtils.trueThrowBusinessError(CollectionUtil.isNotEmpty(names)).throwMessage("以下荣誉被禁用不能发布:" + StrUtil.join(",", names));
}
list.forEach(it -> publish(it, request.getState()));
}
private void publish(ProductHonor info, Integer state) {
if (Objects.equals(state, info.getState())) return;
if (Objects.equals(state, PublishState.Published.getState())) {
VUtils.trueThrowBusinessError(!info.getEnable()).throwMessage("不能发布已禁用的数据");
info.setState(PublishState.Published.getState());
info.setPublishBy(AdminUserUtil.getUserName());
info.setPublishTime(LocalDateTime.now());

View File

@ -72,7 +72,6 @@ public class ProductModelFileItemServiceImpl extends ServiceImpl<ProductModelFil
.set(ProductModelFileItem::getShowInList, false)
.eq(ProductModelFileItem::getModelId, request.getModelId())
.update();
if (CollectionUtil.isNotEmpty(request.getItems())) {
request.getItems().forEach(item -> {
if (Objects.nonNull(item.getFileItemId())) {
lambdaUpdate()
@ -82,17 +81,9 @@ public class ProductModelFileItemServiceImpl extends ServiceImpl<ProductModelFil
}
});
}
}
@Override
public List<ProductModelFileItem> getPublishedByLanguage(Integer modelId) {
return baseMapper.getPublishedByLanguage(modelId);
}
@Override
public void removeByFileIds(List<Integer> ids) {
remove(new LambdaQueryWrapper<ProductModelFileItem>()
.in(ProductModelFileItem::getModelFileId, ids)
);
}
}

View File

@ -116,7 +116,6 @@ public class ProductModelFileServiceImpl extends ServiceImpl<ProductModelFileMap
}
}
@Transactional
@Override
public void delete(BatchDeleteRequest request) {
VUtils.trueThrowBusinessError(lambdaQuery()
@ -129,12 +128,11 @@ public class ProductModelFileServiceImpl extends ServiceImpl<ProductModelFileMap
.ne(ProductModelFile::getCreateBy, AdminUserUtil.getUserName())
.exists()).throwMessage("不能删除其他人创建的数据");
removeByIds(request.getIds());
productModelFileItemService.removeByFileIds(request.getIds());
}
@Transactional
@Override
public void publish(BatchPublishRequest request) {
public void publish(ProductModelPublishRequest request) {
List<ProductModelFile> datas = listByIds(request.getIds());
datas.removeIf(item -> !item.getEnable());
datas.forEach(info -> {
@ -249,12 +247,12 @@ public class ProductModelFileServiceImpl extends ServiceImpl<ProductModelFileMap
.setLanguageCode(language.getCode())
.setLanguageName(language.getName())
.setItems(list.stream().filter(item -> StrUtil.equals(language.getCode(), item.getLanguageCode()))
.map(item -> new FileDefaultConfigItemVO()
.map(item -> {
return new FileDefaultConfigItemVO()
.setId(item.getId())
.setName(item.getName())
.setSelected(item.getShowInList())
).collect(Collectors.toList())
);
.setSelected(item.getShowInList());
}).collect(Collectors.toList()));
vos.add(vo);
});
return vos;

View File

@ -1,10 +1,6 @@
package com.nflg.mobilebroken.repository.service.impl;
import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import cn.hutool.core.convert.Convert;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@ -15,15 +11,11 @@ import com.nflg.mobilebroken.common.pojo.vo.ProductHotImageInfoVO;
import com.nflg.mobilebroken.common.util.AdminUserUtil;
import com.nflg.mobilebroken.common.util.VUtils;
import com.nflg.mobilebroken.repository.entity.ProductModelHotimage;
import com.nflg.mobilebroken.repository.entity.ProductPartInfo;
import com.nflg.mobilebroken.repository.mapper.ProductModelHotimageMapper;
import com.nflg.mobilebroken.repository.service.IProductModelHotimageService;
import com.nflg.mobilebroken.repository.service.IProductPartInfoService;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.List;
import java.util.Objects;
@ -38,9 +30,6 @@ import java.util.Objects;
@Service
public class ProductModelHotimageServiceImpl extends ServiceImpl<ProductModelHotimageMapper, ProductModelHotimage> implements IProductModelHotimageService {
@Resource
private IProductPartInfoService productPartInfoService;
@Override
public Integer add(ProductModelHotImageAddRequest request) {
ProductModelHotimage info=new ProductModelHotimage()
@ -154,33 +143,10 @@ public class ProductModelHotimageServiceImpl extends ServiceImpl<ProductModelHot
}
@Override
public ProductHotImageInfoVO getListByLanguage(Integer modelId, String language) {
ProductModelHotimage info = lambdaQuery()
public ProductHotImageInfoVO getListByLanguage(Integer modelId) {
return Convert.convert(ProductHotImageInfoVO.class,lambdaQuery()
.eq(ProductModelHotimage::getModelId, modelId)
.eq(ProductModelHotimage::getState, PublishState.Published.getState())
.one();
if (Objects.isNull(info)) return null;
JSONArray jsonArray = JSONUtil.parseArray(info.getData());
List<JSONObject> jsonObjects = new ArrayList<>();
if (CollectionUtil.isNotEmpty(jsonArray)) {
List<Integer> ids = new ArrayList<>();
jsonArray.forEach(item -> {
JSONObject jsonObject = JSONUtil.parseObj(item);
ids.add(jsonObject.getInt("id"));
});
List<ProductPartInfo> partInfos = productPartInfoService.lambdaQuery().eq(ProductPartInfo::getLanguageCode, language).in(ProductPartInfo::getPartId, ids).list();
jsonArray.forEach(obj -> {
JSONObject jsonObject = (JSONObject) obj;
ProductPartInfo pi = partInfos.stream().filter(partInfo -> Objects.equals(partInfo.getPartId(), jsonObject.getInt("id"))).findFirst().orElse(null);
if (Objects.nonNull(pi) && StrUtil.isNotBlank(pi.getName()) && Objects.equals(jsonObject.getInt("id"), pi.getPartId())) {
jsonObject.set("name", pi.getName());
}
jsonObjects.add(jsonObject);
});
}
return new ProductHotImageInfoVO()
.setImage(info.getImage())
.setImgRect(info.getImgRect())
.setData(JSONUtil.toJsonStr(jsonObjects));
.one());
}
}

View File

@ -1,6 +1,5 @@
package com.nflg.mobilebroken.repository.service.impl;
import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.util.RandomUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@ -26,7 +25,6 @@ import javax.annotation.Resource;
import java.time.LocalDateTime;
import java.util.List;
import java.util.Objects;
import java.util.stream.Collectors;
/**
* <p>
@ -91,18 +89,13 @@ public class ProductModelImageServiceImpl extends ServiceImpl<ProductModelImageM
}
@Override
public void publish(BatchPublishRequest request) {
List<ProductModelImage> list = listByIds(request.getIds());
public void publish(ProductPublishRequest request) {
ProductModelImage info = getById(request.getId());
VUtils.trueThrowBusinessError(Objects.isNull(info)).throwMessage("无效的数据");
VUtils.trueThrowBusinessError(Objects.equals(info.getState(), request.getState()))
.throwMessage("请勿重复操作");
if (Objects.equals(request.getState(), PublishState.Published.getState())) {
List<String> names = list.stream().filter(ph -> !ph.getEnable()).map(ProductModelImage::getName).collect(Collectors.toList());
VUtils.trueThrowBusinessError(CollectionUtil.isNotEmpty(names)).throwMessage("以下图片被禁用不能发布:" + StrUtil.join(",", names));
}
list.forEach(it -> publish(it, request.getState()));
}
private void publish(ProductModelImage info, Integer state) {
if (Objects.equals(state, info.getState())) return;
if (Objects.equals(state, PublishState.Published.getState())) {
VUtils.trueThrowBusinessError(!info.getEnable()).throwMessage("不能发布已禁用的数据");
info.setState(PublishState.Published.getState());
info.setPublishBy(AdminUserUtil.getUserName());
info.setPublishTime(LocalDateTime.now());

View File

@ -67,11 +67,13 @@ public class ProductModelServiceImpl extends ServiceImpl<ProductModelMapper, Pro
// .setBatchNumber(request.getBatchNumber())
.setNo(request.getNo())
.setRecommend(request.getRecommend())
.setRecommendExpireTime(request.getRecommendExpireTime())
.setSort(RandomUtil.randomInt(0,10000))
.setImage(request.getImage())
.setCreateBy(AdminUserUtil.getUserName())
.setCreateTime(LocalDateTime.now());
if (request.getRecommend()){
productModel.setRecommendTime(LocalDateTime.now());
}
save(productModel);
if (request.getPublish()) {
publish(new ProductPublishRequest()
@ -93,8 +95,15 @@ public class ProductModelServiceImpl extends ServiceImpl<ProductModelMapper, Pro
} else {
info.setNo(request.getNo());
// info.setSort(request.getSort());
info.setRecommend(request.getRecommend());
info.setRecommendExpireTime(request.getRecommendExpireTime());
if (request.getRecommend()) {
if (!info.getRecommend()) {
info.setRecommend(true);
info.setRecommendTime(LocalDateTime.now());
}
} else {
info.setRecommend(false);
info.setRecommendTime(null);
}
info.setModuleId(request.getModuleId());
info.setSeriesNumber(request.getSeriesNumber());
info.setTypeNumber(request.getTypeNumber());
@ -196,7 +205,6 @@ public class ProductModelServiceImpl extends ServiceImpl<ProductModelMapper, Pro
.setId(item.getId())
.setNo(item.getNo())
.setRecommend(item.getRecommend())
.setRecommendExpireTime(item.getRecommendExpireTime())
.setImage(item.getImage())
.setParams(productPartParamsService.getMainListByLanguage(item.getId(), language))
.setFile(productModelFileService.getDefaultByLanguage(item.getId(), language)))
@ -298,7 +306,7 @@ public class ProductModelServiceImpl extends ServiceImpl<ProductModelMapper, Pro
.setDesc(Objects.isNull(intro)?"":intro.getDesc())
.setFeature(Objects.isNull(intro)?"":intro.getFeature())
.setMerits(Objects.isNull(intro)?"":intro.getMerits())
.setHotImage(productModelHotimageService.getListByLanguage(modelId, language))
.setHotImage(productModelHotimageService.getListByLanguage(modelId))
.setParams(productPartParamsService.getAListByLanguage(modelId, language))
.setMainParams(productPartParamsService.getMainListByLanguage(modelId, language))
.setImportantParams(productPartParamsService.getImportantListByLanguage(modelId, language))

View File

@ -1,6 +1,5 @@
package com.nflg.mobilebroken.repository.service.impl;
import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.util.RandomUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@ -26,7 +25,6 @@ import javax.annotation.Resource;
import java.time.LocalDateTime;
import java.util.List;
import java.util.Objects;
import java.util.stream.Collectors;
/**
* <p>
@ -112,18 +110,13 @@ public class ProductModelVideoServiceImpl extends ServiceImpl<ProductModelVideoM
}
@Override
public void publish(BatchPublishRequest request) {
List<ProductModelVideo> list = listByIds(request.getIds());
public void publish(ProductPublishRequest request) {
ProductModelVideo info = getById(request.getId());
VUtils.trueThrowBusinessError(Objects.isNull(info)).throwMessage("无效的数据");
VUtils.trueThrowBusinessError(Objects.equals(info.getState(), request.getState()))
.throwMessage("请勿重复操作");
if (Objects.equals(request.getState(), PublishState.Published.getState())) {
List<String> names = list.stream().filter(ph -> !ph.getEnable()).map(ProductModelVideo::getName).collect(Collectors.toList());
VUtils.trueThrowBusinessError(CollectionUtil.isNotEmpty(names)).throwMessage("以下视频被禁用不能发布:" + StrUtil.join(",", names));
}
list.forEach(it -> publish(it, request.getState()));
}
private void publish(ProductModelVideo info, Integer state) {
if (Objects.equals(state, info.getState())) return;
if (Objects.equals(state, PublishState.Published.getState())) {
VUtils.trueThrowBusinessError(!info.getEnable()).throwMessage("不能发布已禁用的数据");
info.setState(PublishState.Published.getState());
info.setPublishBy(AdminUserUtil.getUserName());
info.setPublishTime(LocalDateTime.now());

View File

@ -31,8 +31,8 @@ public class TicketCallJoinServiceImpl extends ServiceImpl<TicketCallJoinMapper,
private ITicketCallService ticketCallService;
@Override
public boolean isInCall(Integer ticketId, String from, Integer userId) {
return baseMapper.isInCall(ticketId, from, userId);
public boolean isInCall(Integer userId) {
return baseMapper.isInCall(userId);
}
@Transactional
@ -84,14 +84,7 @@ public class TicketCallJoinServiceImpl extends ServiceImpl<TicketCallJoinMapper,
.set(TicketCallJoin::getState, 2)
.set(reject, TicketCallJoin::getHangupTime, LocalDateTime.now())
.eq(TicketCallJoin::getCallId, callId)
.update();
} else {
lambdaUpdate()
.set(TicketCallJoin::getState, 2)
.set(reject, TicketCallJoin::getHangupTime, LocalDateTime.now())
.eq(TicketCallJoin::getCallId, callId)
.eq(TicketCallJoin::getUserId, userId)
.eq(TicketCallJoin::getFrom, from)
.ne(TicketCallJoin::getFrom, from)
.update();
}
if (!lambdaQuery()
@ -126,4 +119,12 @@ public class TicketCallJoinServiceImpl extends ServiceImpl<TicketCallJoinMapper,
);
}
}
@Override
public void hangUpAll(Integer id) {
lambdaUpdate()
.set(TicketCallJoin::getState, 2)
.eq(TicketCallJoin::getCallId, id)
.update();
}
}

View File

@ -1,6 +1,8 @@
package com.nflg.mobilebroken.repository.service.impl;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.nflg.mobilebroken.common.constant.Constant;
import com.nflg.mobilebroken.repository.entity.TicketCall;
import com.nflg.mobilebroken.repository.entity.TicketCallJoin;
import com.nflg.mobilebroken.repository.mapper.TicketCallMapper;
@ -11,6 +13,7 @@ import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
import java.time.LocalDateTime;
import java.util.Objects;
/**
* <p>
@ -26,33 +29,26 @@ public class TicketCallServiceImpl extends ServiceImpl<TicketCallMapper, TicketC
@Resource
private ITicketCallJoinService ticketCallJoinService;
// @Override
// public boolean isInCall(Integer userId) {
// return lambdaQuery()
// .eq(TicketCall::getState, 1)
// .eq(TicketCall::getCallerUserId, userId)
// .exists()
// ||
// ticketCallJoinService.isInCall(userId);
// }
@Override
public boolean isInCall(Integer userId) {
return lambdaQuery()
.eq(TicketCall::getState, 1)
.eq(TicketCall::getCallerUserId, userId)
.exists()
||
ticketCallJoinService.isInCall(userId);
}
@Transactional
@Override
public void add(Integer ticketId, Integer callerUserId,String callerUserFrom, Integer calledUserId, String calledUserFrom) {
TicketCall ticketCall = new TicketCall()
.setTicketId(ticketId)
// .setCallerUserId(callerUserId)
.setCallerUserId(callerUserId)
.setState(0)
// .setFrom(callerUserFrom)
.setFrom(callerUserFrom)
.setCreateTime(LocalDateTime.now());
save(ticketCall);
ticketCallJoinService.save(new TicketCallJoin()
.setCallId(ticketCall.getId())
.setFrom(callerUserFrom)
.setUserId(callerUserId)
.setState(0)
.setCreateTime(LocalDateTime.now())
);
ticketCallJoinService.save(new TicketCallJoin()
.setCallId(ticketCall.getId())
.setFrom(calledUserFrom)
@ -62,24 +58,24 @@ public class TicketCallServiceImpl extends ServiceImpl<TicketCallMapper, TicketC
);
}
// @Override
// public boolean hangUp(Integer ticketId, Integer userId, String from, boolean reject) {
// TicketCall ticketCall = getLast(ticketId);
// boolean flag = false;
// if (Objects.nonNull(ticketCall)){
// if ((Objects.equals(ticketCall.getCallerUserId(), userId) && StrUtil.equals(ticketCall.getFrom(), Constant.FROM_APP))
// || ticketCallJoinService.allIsHangUp(ticketCall.getId())){
// ticketCall.setState(2);
// ticketCallJoinService.hangUpAll(ticketCall.getId());
// if (reject) {
// ticketCall.setHangupTime(LocalDateTime.now());
// }
// updateById(ticketCall);
// }
// flag=ticketCallJoinService.hangUp(ticketCall.getId(), userId, from, reject);
// }
// return flag;
// }
@Override
public boolean hangUp(Integer ticketId, Integer userId, String from, boolean reject) {
TicketCall ticketCall = getLast(ticketId);
boolean flag = false;
if (Objects.nonNull(ticketCall)){
if ((Objects.equals(ticketCall.getCallerUserId(), userId) && StrUtil.equals(ticketCall.getFrom(), Constant.FROM_APP))
|| ticketCallJoinService.allIsHangUp(ticketCall.getId())){
ticketCall.setState(2);
ticketCallJoinService.hangUpAll(ticketCall.getId());
if (reject) {
ticketCall.setHangupTime(LocalDateTime.now());
}
updateById(ticketCall);
}
flag=ticketCallJoinService.hangUp(ticketCall.getId(), userId, from, reject);
}
return flag;
}
@Override
public TicketCall getLast(Integer ticketId) {

View File

@ -28,13 +28,9 @@
SELECT au.id
FROM t_base_position p
INNER JOIN admin_user au ON au.title_id=p.id
WHERE au.state=1 AND au.is_del=0 AND p.ticket_manage
</select>
<select id="getCQMIds" resultType="java.lang.Integer">
SELECT au.id
FROM t_base_position p
INNER JOIN admin_user au ON au.title_id=p.id
WHERE au.state=1 AND au.is_del=0 AND p.position_code=#{titleCode}
WHERE au.state=1 AND au.is_del=0 AND p.position_code IN
<foreach collection="titleCodes" item="titleCode" separator="," open="(" close=")">
#{titleCode}
</foreach>
</select>
</mapper>

View File

@ -7,6 +7,6 @@
from product_model_file pmf
inner join product_model_file_item pmfi on pmfi.model_file_id=pmf.id
where pmf.state=1 and pmf.enable=1 and pmf.model_id=#{modelId}
order by pmfi.language_code,pmfi.show_in_list desc,pmfi.id desc
order by pmfi.language_code,pmfi.show_in_list desc
</select>
</mapper>

View File

@ -2,7 +2,7 @@
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.nflg.mobilebroken.repository.mapper.ProductModelFileMapper">
<select id="getDefaultByLanguage" resultType="com.nflg.mobilebroken.common.pojo.vo.ProductFileVO">
SELECT pmfi.name,pmf.*
SELECT pmfi.name, pmfi.*
FROM product_model_file pmf
INNER JOIN product_model_file_item pmfi ON pmf.id = pmfi.model_file_id
WHERE pmf.`enable` = 1

View File

@ -12,7 +12,9 @@
</sql>
<select id="getList" resultType="com.nflg.mobilebroken.repository.entity.TBasePosition">
select *
select id, position_code, position_name, position_attribute, data_create_user_no,
data_create_user_name, data_create_time, data_modify_user_no, data_modify_user_name,
data_modify_time
from t_base_position
where data_valid_state=1 <include refid="whr" />
</select>

View File

@ -7,6 +7,6 @@
INNER JOIN ticket_call_join tcj ON tc.id = tcj.call_id
WHERE tc.state = 1
AND tcj.state = 1
AND tcj.user_id = #{userId} and tcj.from = #{from} and tc.ticket_id = #{ticketId}
AND tcj.user_id = #{userId}
</select>
</mapper>