sourcecode/server/gateway-api/src/main/java/com/qxgmat/service/inline/UserAskCourseService.java

package com.qxgmat.service.inline;

import com.github.pagehelper.Page;
import com.nuliji.tools.AbstractService;
import com.nuliji.tools.Tools;
import com.nuliji.tools.Transform;
import com.nuliji.tools.exception.ParameterException;
import com.nuliji.tools.exception.SystemException;
import com.nuliji.tools.mybatis.Example;
import com.qxgmat.data.constants.enums.status.AskStatus;
import com.qxgmat.data.constants.enums.status.DirectionStatus;
import com.qxgmat.data.constants.enums.user.MoneyRange;
import com.qxgmat.data.dao.UserAskCourseMapper;
import com.qxgmat.data.dao.entity.UserAskCourse;
import com.qxgmat.data.relation.UserAskCourseRelationMapper;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.util.Collection;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@Service
public class UserAskCourseService extends AbstractService {
    private static final Logger logger = LoggerFactory.getLogger(UserAskCourseService.class);

    @Resource
    private UserAskCourseMapper userAskCourseMapper;

    @Resource
    private UserAskCourseRelationMapper userAskCourseRelationMapper;

    private Map<String, String> adminMap = new HashMap<String, String>(){{
        put("", "uac");
    }};

    public Page<UserAskCourse> listAdmin(int page, int size, Integer structId, Number courseId, AskStatus status, Integer showStatus, Integer userId, MoneyRange moneyRange, String startTime, String endTime, String order, DirectionStatus direction){
        Integer statusIndex = status != null ? status.index : null;
        Integer max = moneyRange != null ? moneyRange.max == Integer.MAX_VALUE ? null : moneyRange.max : null;
        Integer min = moneyRange != null ? moneyRange.min : null;
        if(order == null || order.isEmpty()){
            order = "id";
        }
        if(adminMap.containsKey(order)){
            order = adminMap.get(order)+".`"+Tools.underscoreName(order)+"`";
        }else{
            order = adminMap.get("")+".`"+Tools.underscoreName(order)+"`";
        }
        if (direction == null){
            direction = DirectionStatus.DESC;
        }
        String finalOrder = order;
        DirectionStatus finalDirection = direction;
        Page<UserAskCourse> p = page(
                ()-> userAskCourseRelationMapper.listAdmin(structId, courseId, statusIndex, showStatus, userId, min, max, startTime, endTime, finalOrder, finalDirection.key)
        , page, size);

        Collection ids = Transform.getIds(p, UserAskCourse.class, "id");
        Transform.replace(p, select(ids), UserAskCourse.class, "id");
        return p;
    }

    public List<UserAskCourse> listByCoursePosition(Number courseNoId, String position, Boolean showStatus){
        Example example = new Example(UserAskCourse.class);
        example.and(
                example.createCriteria()
                        .andEqualTo("courseNoId", courseNoId)
                        .andEqualTo("position", position)

        );
        if (showStatus != null)
            example.and(
                    example.createCriteria()
                            .andEqualTo("showStatus", showStatus?1:0)
                            .andEqualTo("answerStatus", 1)

            );
        example.orderBy("sort").desc();
        return select(userAskCourseMapper, example);
    }

    /**
     * 根据列表顺序全部更新排序：从大到小
     * @param ids
     */
    @Transactional
    public void updateOrder(Integer[] ids){
        int sort = ids.length;
        List<UserAskCourse> userAskCourseList = select(userAskCourseMapper, ids);
        Map userAskCourseMap = Transform.getMap(userAskCourseList, UserAskCourse.class, "id");
        for (Integer id : ids){
            sort -= 1;
            UserAskCourse userAskCourse = (UserAskCourse)userAskCourseMap.get(id);
            if (userAskCourse == null) continue;
            if (userAskCourse.getSort() == sort) continue;
            update(userAskCourseMapper, UserAskCourse.builder()
                    .id(id)
                    .sort(sort)
                    .showStatus(1)
                    .build()
            );
        }
    }

    public UserAskCourse add(UserAskCourse message){
        int result = insert(userAskCourseMapper, message);
        message = one(userAskCourseMapper, message.getId());
        if(message == null){
            throw new SystemException("提问添加失败");
        }
        return message;
    }

    public UserAskCourse edit(UserAskCourse message){
        UserAskCourse in = one(userAskCourseMapper, message.getId());
        if(in == null){
            throw new ParameterException("提问不存在");
        }
        int result = update(userAskCourseMapper, message);
        return message;
    }

    public boolean delete(Number id){
        UserAskCourse in = one(userAskCourseMapper, id);
        if(in == null){
            throw new ParameterException("提问不存在");
        }
        int result = delete(userAskCourseMapper, id);
        return result > 0;
    }

    public UserAskCourse get(Number id){
        UserAskCourse in = one(userAskCourseMapper, id);

        if(in == null){
            throw new ParameterException("提问不存在");
        }
        return in;
    }

    public Page<UserAskCourse> select(int page, int pageSize){
        return select(userAskCourseMapper, page, pageSize);
    }

    public Page<UserAskCourse> select(Integer[] ids){
        return page(()->select(userAskCourseMapper, ids), 1, ids.length);
    }

    public List<UserAskCourse> select(Collection ids){
        return select(userAskCourseMapper, ids);
    }

}