Merge branch 'base-modify' of http://113.105.137.151:22280/youjj/cloud-platform into base-modify

ace-common/src/main/java/com/github/wxiaoqi/security/common/rest/BaseController.java

@@ -86,4 +86,6 @@ public class BaseController<Biz extends BaseBiz,Entity> extends CommonBaseContro
         //查询列表数据
         return ObjectRestResponse.succ(baseBiz.selectList(entity));
     }
+
+
 }

ace-modules/ace-admin-api/src/main/java/com/github/wxiaoqi/security/admin/dto/AppUserManageDTO.java

+package com.github.wxiaoqi.security.admin.dto;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.Data;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.util.Date;
+
+/**
+ * 用户信息表
+ */
+@Data
+public class AppUserManageDTO {
+    /**
+     * 每页条数
+     */
+    private Integer limit;
+
+    /**
+     * 当前页数
+     */
+    private Integer page;
+
+    /**
+     * 手机号
+     */
+    private Integer mobile;
+
+    /**
+     * 注册终端
+     */
+    private Integer channel;
+
+    /**
+     * 会员等级
+     */
+    private Integer memberLevel;
+
+    /**
+     * 注册时间(开始)
+     */
+    @JsonFormat(pattern = "yyyy-MM-DD HH:mm", timezone = "GMT+8")
+    @DateTimeFormat(pattern = "yyyy-MM-DD HH:mm")
+    private Date registrationTimeBegin;
+
+    /**
+     * 注册时间(结束)
+     */
+    @JsonFormat(pattern = "yyyy-MM-DD HH:mm", timezone = "GMT+8")
+    @DateTimeFormat(pattern = "yyyy-MM-DD HH:mm")
+    private Date registrationTimeEnd;
+
+    public Long getRegistrationTimeBegin() {
+        return registrationTimeBegin.getTime();
+    }
+
+
+    public Long getRegistrationTimeEnd() {
+        return registrationTimeEnd.getTime();
+    }
+}

ace-modules/ace-admin-api/src/main/java/com/github/wxiaoqi/security/admin/dto/BaseUserMemberVO.java

+package com.github.wxiaoqi.security.admin.dto;
+
+import java.io.Serializable;
+import java.util.Date;
+import javax.persistence.*;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * 用户会员信息
+ */
+@Data
+public class BaseUserMemberVO implements Serializable {
+    private static final long serialVersionUID = 1L;
+    /**
+     *  主键id
+     */
+    @Id
+    @GeneratedValue(generator = "JDBC")
+    @ApiModelProperty("主键id")
+    private Integer id;
+
+    /**
+     * 用户id
+     */
+    @Column(name = "user_id")
+    @ApiModelProperty(value = "用户id")
+    private Integer userId;
+
+    /**
+     * 会员等级
+     */
+    @Column(name = "member_level")
+    @ApiModelProperty(value = "会员等级")
+    private Integer memberLevel;
+
+
+
+    /**
+     * 赠送总天数
+     */
+    @Column(name = "total_number")
+    @ApiModelProperty(value = "赠送总天数")
+    private Integer totalNumber;
+
+    /**
+     * 剩余天数
+     */
+    @Column(name = "rent_free_days")
+    @ApiModelProperty(value = "剩余天数")
+    private Integer rentFreeDays;
+
+
+    /**
+     * 购买会员次数
+     */
+    @Column(name = "buy_count")
+    @ApiModelProperty(value = "购买会员次数")
+    private Integer buyCount;
+
+
+
+    /**
+     * 有效期;0代表永久
+     */
+    @Column(name = "valid_time")
+    @ApiModelProperty(value = "有效期;0代表永久")
+    private Long validTime;
+
+
+
+
+
+}

ace-modules/ace-admin-api/src/main/java/com/github/wxiaoqi/security/admin/entity/BaseUserMember.java

@@ -132,6 +132,9 @@ public class BaseUserMember implements Serializable {
     @Column(name = "is_del")
 	@ApiModelProperty(value = "是否删除；0-正常；1-删除")
     private Integer isDel;
+
+    @Column(name = "recent_recharge")
+	private Long recentRecharge;
 	
 
 }

ace-modules/ace-admin-api/src/main/java/com/github/wxiaoqi/security/admin/vo/AppUserManageVo.java

+package com.github.wxiaoqi.security.admin.vo;
+
+import lombok.Data;
+
+import javax.persistence.Column;
+
+/**
+ * 用户信息表
+ */
+@Data
+public class AppUserManageVo {
+    /**
+     * 用户id
+     */
+    @Column(name = "userid")
+    private Integer userId;
+
+    /**
+     * 注册终端
+     */
+    @Column(name = "channel")
+    private String channel;
+
+    /**
+     * 是否是会员：0-不是；1-会员
+     */
+    @Column(name = "is_member")
+    private Integer isMember;
+
+    /**
+     * 真实姓名
+     */
+    @Column(name = "realname")
+    private String realName;
+
+    /**
+     * 状态：0-正常，1-禁用
+     */
+    @Column(name = "isdel")
+    private Integer isDel;
+
+    /**
+     * 昵称
+     */
+    @Column(name = "nickname")
+    private String nickName;
+
+    /**
+     * 用户来源:0-自来,1-公司人员推荐,2-用户推荐
+     */
+    @Column(name = "source")
+    private Integer source;
+
+    /**
+     * 邀请人id
+     */
+    @Column(name = "Inviter_account")
+    private Integer InviterAccount;
+
+    /**
+     * 账号申请所在地
+     */
+    @Column(name = "address")
+    private String address;
+
+    /**
+     * 用户性别
+     */
+    @Column(name = "sex")
+    private Integer sex;
+
+    /**
+     * 用户邮箱
+     */
+    @Column(name = "email")
+    private String email;
+
+    /**
+     * 用户名（手机号码）
+     */
+    @Column(name = "username")
+    private String username;
+
+    /**
+     * 实名认证状态:0-未认证，1-已认证
+     */
+    @Column(name = "certification_status")
+    private String certification_status;
+
+    /**
+     * 身份证号
+     */
+    @Column(name = "id_number")
+    private String idNumber;
+
+    /**
+     * 会员等级
+     */
+    @Column(name = "member_level")
+    private Integer memberLevel;
+
+    /**
+     * 有效期;0代表永久
+     */
+    @Column(name = "valid_time")
+    private Integer validTime;
+
+    /**
+     * 创建时间
+     */
+    @Column(name = "createtime")
+    private Long createTime;
+
+    /**
+     * 最后的登录时间
+     */
+    @Column(name = "last_time")
+    private Long lastTime;
+
+    /**
+     * 购买会员次数
+     */
+    @Column(name = "buy_count")
+    private String buyCount;
+
+    /**
+     * 赠送总天数
+     */
+    @Column(name = "total_number")
+    private String totalNumber;
+
+    /**
+     * 剩余天数
+     */
+    @Column(name = "rent_free_days")
+    private String rentFreeDays;
+
+    /**
+     * 加入会员时间
+     */
+    private Long timeOfMembership;
+
+    /**
+     * 最近充值时间
+     */
+    @Column(name = "recent_recharge")
+    private Long recentRecharge;
+
+    /**
+     * 会员名称
+     */
+    private String memberName;
+
+}

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/biz/AppUserManageBiz.java

 package com.github.wxiaoqi.security.admin.biz;
 
+import com.github.wxiaoqi.security.admin.dto.AppUserManageDTO;
 import com.github.wxiaoqi.security.admin.entity.*;
 import com.github.wxiaoqi.security.admin.mapper.*;
+import com.github.wxiaoqi.security.admin.vo.AppUserManageVo;
 import com.github.wxiaoqi.security.admin.vo.AppUserVo;
 import com.github.wxiaoqi.security.common.biz.BaseBiz;
 import org.apache.commons.beanutils.BeanUtilsBean;
@@ -24,42 +26,58 @@ public class AppUserManageBiz extends BaseBiz<AppUserDetailMapper, AppUserDetail
     @Autowired
     private AppUserLoginMapper appUserLoginMapper;
 
+    @Autowired
+    private BaseUserMemberMapper baseUserMemberMapper;
+
     /**
      * 根据条件查询
      *
-     * @param appUserVo
+     * @param appUserManageDTO 查询条件
      * @return
      */
-    public AppUserVo findAllByQuery(AppUserVo appUserVo) {
-        return mapper.selectAppUserManage(appUserVo);
+    public AppUserManageVo findAllByQuery(AppUserManageDTO appUserManageDTO) {
+        return mapper.selectAppUserManage(appUserManageDTO);
     }
 
-
-    @Transactional
-    public void deleteAppUser(Integer id) {
+    /**
+     * 禁用账户
+     * @param id
+     */
+    @Transactional(rollbackFor =Exception.class)
+    public void deleteAppUser(Integer id,Integer isDel) {
         AppUserLogin appUserLogin = new AppUserLogin();
-        appUserLogin.setIsdel(1);
+        //修改为禁用并设置修改时间
+        appUserLogin.setIsdel(isDel);
+        appUserLogin.setUpdatetime(System.currentTimeMillis());
         Example example = new Example(AppUserLogin.class);
         Example.Criteria criteria = example.createCriteria();
         criteria.andEqualTo("id", id);
-        appUserLogin.setUpdatetime(System.currentTimeMillis());
         appUserLoginMapper.updateByExampleSelective(appUserLogin, example);
 
+        //设置
         AppUserDetail appUserDetail = new AppUserDetail();
-        appUserDetail.setIsdel(1);
+        appUserDetail.setIsdel(isDel);
         appUserDetail.setUpdatetime(System.currentTimeMillis());
         Example detailExample = new Example(AppUserLogin.class);
         Example.Criteria detailCriteria = detailExample.createCriteria();
         criteria.andEqualTo("id", id);
         mapper.updateByExampleSelective(appUserDetail, detailCriteria);
-
     }
 
+    /**
+     * 查询一条
+     * @param id
+     * @return
+     */
     public AppUserVo findOneById(Integer id) {
         return mapper.getUserInfo(id);
     }
 
-    @Transactional
+    /**
+     *
+     * @param appUserVo
+     */
+    @Transactional(rollbackFor =Exception.class)
     public void save(AppUserVo appUserVo) {
         AppUserLogin appUserLogin = new AppUserLogin();
         AppUserDetail appUserDetail = new AppUserDetail();

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/biz/BaseUserMemberBiz.java

@@ -2,18 +2,28 @@ package com.github.wxiaoqi.security.admin.biz;
 
 import com.ace.cache.annotation.Cache;
 import com.ace.cache.annotation.CacheClear;
+import com.github.wxiaoqi.security.admin.dto.BaseUserMemberVO;
 import com.github.wxiaoqi.security.admin.dto.UserMemberDTO;
 import com.github.wxiaoqi.security.admin.vo.AppUserVo;
 import com.github.wxiaoqi.security.admin.vo.UserMemberVo;
+import com.github.wxiaoqi.security.common.exception.BaseException;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.beanutils.BeanUtils;
+import org.apache.commons.beanutils.BeanUtilsBean;
 import org.springframework.aop.framework.AopContext;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.core.task.TaskExecutor;
+import org.springframework.integration.amqp.dsl.Amqp;
 import org.springframework.stereotype.Service;
 import com.github.wxiaoqi.security.admin.entity.BaseUserMember;
 import com.github.wxiaoqi.security.admin.mapper.BaseUserMemberMapper;
 import com.github.wxiaoqi.security.common.biz.BaseBiz;
 import org.springframework.transaction.annotation.Transactional;
+import tk.mybatis.mapper.entity.Example;
+import tk.mybatis.mapper.weekend.WeekendSqls;
+
+import java.lang.reflect.InvocationTargetException;
+import java.util.List;
 
 /**
  * 用户会员表
@@ -30,6 +40,9 @@ public class BaseUserMemberBiz extends BaseBiz<BaseUserMemberMapper,BaseUserMemb
     @Autowired
     AppUserDetailBiz detailBiz;
 
+    @Autowired
+    private TaskExecutor taskExecutor;
+
    //获取用户会员信息
    @Cache(key = "user:member{1}")
     public UserMemberVo getMemberInfoByUserId(Integer userId){
@@ -155,5 +168,56 @@ public class BaseUserMemberBiz extends BaseBiz<BaseUserMemberMapper,BaseUserMemb
         return AopContext.currentProxy() != null ? (BaseUserMemberBiz) AopContext.currentProxy() : this;
     }
 
+    /**
+     * 获取用户会员信息
+     * @param userId
+     * @return
+     */
+    public BaseUserMember findOneByUserId(Integer userId) {
+        Example exa = new Example(BaseUserMember.class);
+        Example.Criteria criteria = exa.createCriteria();
+        criteria.andEqualTo("userId",userId);
+        List<BaseUserMember> baseUserMembers = mapper.selectByExample(exa);
+
+        if (baseUserMembers.size()>1) {
+            throw new BaseException("Member purchase repeat!");
+        }
+        return baseUserMembers!=null&&baseUserMembers.size()!=0 ? baseUserMembers.get(0): null;
+    }
+
+
+    /**
+     * 设置用户会员
+     * @param baseUserMemberVO
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public void setUserMember(BaseUserMemberVO baseUserMemberVO) throws InvocationTargetException, IllegalAccessException {
+
+        Example exa = Example.builder(BaseUserMember.class).where(
+                WeekendSqls.<BaseUserMember>custom()
+                        .andEqualTo(BaseUserMember::getUserId, baseUserMemberVO.getUserId())
+        ).build();
+
+        List<BaseUserMember> baseUserMembers = mapper.selectByExample(exa);
+
+        BaseUserMember baseUserMember = new BaseUserMember();
+        BeanUtilsBean.getInstance().copyProperties(baseUserMember,baseUserMemberVO);
+        if (baseUserMembers==null||baseUserMembers.size()==0) {
+            baseUserMember.setCrtTime(System.currentTimeMillis());
+            baseUserMember.setIsDel(0);
+            baseUserMember.setPayCount(0);
+            baseUserMember.setCardLeave(0);
+            baseUserMember.setRecentRecharge(System.currentTimeMillis());
+            insertSelective(baseUserMember);
+            return;
+        }else if (baseUserMembers.size()==1){
+         baseUserMember.setUpdTime(System.currentTimeMillis());
+         updateSelectiveById(baseUserMember);
+        }else {
+            throw new BaseException("Member purchase repeat!");
+        }
+    }
+
+
 
 }
\ No newline at end of file

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/mapper/AppUserDetailMapper.java

 package com.github.wxiaoqi.security.admin.mapper;
 
+import com.github.wxiaoqi.security.admin.dto.AppUserManageDTO;
 import com.github.wxiaoqi.security.admin.entity.AppUserDetail;
-import com.github.wxiaoqi.security.admin.entity.AppUserManage;
+import com.github.wxiaoqi.security.admin.vo.AppUserManageVo;
 import com.github.wxiaoqi.security.admin.vo.AppUserVo;
 import org.apache.ibatis.annotations.Param;
 import tk.mybatis.mapper.common.Mapper;
@@ -11,5 +12,5 @@ public interface AppUserDetailMapper extends Mapper<AppUserDetail> {
     //查询用户信息
     public AppUserVo getUserInfo(@Param("userId") Integer userId);
 
-    AppUserVo selectAppUserManage(AppUserVo appUserVo);
+    AppUserManageVo selectAppUserManage(AppUserManageDTO appUserManageDTO);
 }
\ No newline at end of file

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/rest/AppUsersManageController.java

 package com.github.wxiaoqi.security.admin.rest;
 
 import com.github.wxiaoqi.security.admin.biz.AppUserManageBiz;
+import com.github.wxiaoqi.security.admin.dto.AppUserManageDTO;
+import com.github.wxiaoqi.security.admin.dto.BaseUserMemberVO;
 import com.github.wxiaoqi.security.admin.entity.AppUserManage;
+import com.github.wxiaoqi.security.admin.vo.AppUserManageVo;
 import com.github.wxiaoqi.security.admin.vo.AppUserVo;
 import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
 import com.github.wxiaoqi.security.common.rest.BaseController;
@@ -20,18 +23,18 @@ public class AppUsersManageController extends BaseController<AppUserManageBiz,Ap
      * @return
      */
     @GetMapping("/findAll")
-    public ObjectRestResponse<AppUserVo> findAllByQuery(@RequestBody AppUserVo  appUserVo){
-        return ObjectRestResponse.succ(baseBiz.findAllByQuery(appUserVo));
+    public ObjectRestResponse<AppUserManageVo> findAllByQuery(@RequestBody AppUserManageDTO appUserManageDTO){
+        return ObjectRestResponse.succ(baseBiz.findAllByQuery(appUserManageDTO));
     }
 
     /**
-     * 删除
+     * 禁用
      * @param id
      * @return
      */
-    @DeleteMapping("/deleteById/{id}")
-    public  ObjectRestResponse deleteById(@PathVariable Integer id){
-          baseBiz.deleteAppUser(id);
+    @DeleteMapping("/deleteById/{id}/{isDel}")
+    public  ObjectRestResponse deleteById(@PathVariable Integer id,@PathVariable Integer isDel){
+          baseBiz.deleteAppUser(id,isDel);
         return ObjectRestResponse.succ();
     }
 
@@ -45,6 +48,11 @@ public class AppUsersManageController extends BaseController<AppUserManageBiz,Ap
         return ObjectRestResponse.succ(baseBiz.findOneById(id));
     }
 
+    /**
+     * 保存
+     * @param appUserVo
+     * @return
+     */
     @PostMapping("/save")
     public ObjectRestResponse save(@RequestBody AppUserVo  appUserVo){
         baseBiz.save(appUserVo);

ace-modules/ace-admin/src/main/java/com/github/wxiaoqi/security/admin/rest/BaseUserMemberController.java

+package com.github.wxiaoqi.security.admin.rest;
+
+import com.github.wxiaoqi.security.admin.biz.BaseUserMemberBiz;
+import com.github.wxiaoqi.security.admin.dto.BaseUserMemberVO;
+import com.github.wxiaoqi.security.admin.entity.AppUserManage;
+import com.github.wxiaoqi.security.admin.entity.BaseUserMember;
+import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
+import com.github.wxiaoqi.security.common.rest.BaseController;
+import org.springframework.web.bind.annotation.*;
+
+import java.lang.reflect.InvocationTargetException;
+
+/**
+ * 用户会员
+ * @author Administrator
+ */
+@RestController
+@RequestMapping("baseUserMember")
+public class BaseUserMemberController extends BaseController<BaseUserMemberBiz, BaseUserMember> {
+    @RequestMapping("/findOne/{userId}")
+    public ObjectRestResponse<AppUserManage> findOneByUserId(@PathVariable Integer userId){
+        BaseUserMember oneByUserId = baseBiz.findOneByUserId(userId);
+        if (oneByUserId==null) {
+            return ObjectRestResponse.succ();
+        }
+        return  ObjectRestResponse.succ(oneByUserId);
+    }
+
+
+
+    /**
+     * 设置用户会员
+     * @param baseUserMemberVO
+     * @return
+     */
+    @PostMapping("/setUserMember")
+    public ObjectRestResponse setUserMember(@RequestBody BaseUserMemberVO baseUserMemberVO)
+            throws InvocationTargetException, IllegalAccessException {
+        baseBiz.setUserMember(baseUserMemberVO);
+        return ObjectRestResponse.succ();
+    }
+}

ace-modules/ace-admin/src/main/resources/mapper/AppUserDetailMapper.xml

@@ -32,85 +32,69 @@
      where d.userid = #{userId}  limit 1
   </select>
 
-  <select id="selectAppUserManage" parameterType="Integer" resultMap="AppUserVoMap">
-    select l.im_userid,l.username,l.wx_openid,l.unionid,l.openid,l.status,l.id_number,l.certification_status,d.*  from app_user_login l
-    left join  app_user_detail d
-    on d.userid = l.id where 1=1
-
-      <if test="id != null">
-        and  d.id =#{id}
-      </if>
-
-      <if test="userid != null" >
-        and d.userid = #{userId}
-      </if>
-
-    <if test="username != null" >
-      and l.username=#{username}
-    </if>
-
-
-    <if test="imUserd != null" >
-      and l.im_userid=#{imUserid}
-    </if>
-
-    <if test="wxOpenid != null" >
-      and l.wx_openid=#{wxOpenid}
-    </if>
-
-    <if test="unionid != null" >
-      and l.unionid=#{unionid}
-    </if>
-
-    <if test="openid != null" >
-      and l.openid=#{openid}
-    </if>
-
-    <if test="status != null" >
-      and l.status=#{status}
-    </if>
-
-    <if test="idNumber != null" >
-      and l.id_number=#{idNumber}
-    </if>
-
-    <if test="certificationStatus != null" >
-      and l.certification_status=#{certificationStatus}
-    </if>
-
-    <if test="isMember != null" >
-      and d.is member=#{isMember}
-    </if>
-
-    <if test="nickname != null" >
-      and d.nickname=#{nickname}
-    </if>
-
-    <if test="realname != null" >
-      and d.realname=#{realname}
-    </if>
-
-    <if test="email != null" >
-      and d.email=#{email}
-    </if>
-
-    <if test="sex != null" >
-      and d.sex=#{sex}
-    </if>
-
-
-    <if test="birthday != null" >
-      and d.birthday=#{birthday}
-    </if>
-
-
-    <if test="personSign != null" >
-      and d.person_sign=#{personSign}
-    </if>
-
-    <if test="remark != null" >
-      and d.remark=#{remark}
-    </if>
+    <select id="selectAppUserManage" parameterType="com.github.wxiaoqi.security.admin.dto.AppUserManageDTO"
+            resultType="com.github.wxiaoqi.security.admin.vo.AppUserManageVo">
+        select
+        d.userid,
+        d.channel,
+        d.is_member,
+        d.realname,
+        d.isdel,
+        d.nickname,
+        d.source,
+        d.Inviter_account,
+        d.address,
+        d.sex,
+        d.email,
+        l.username,
+        l.certification_status,
+        l.id_number,
+        l.createtime,
+        l.last_time,
+        m.member_level,
+        m.valid_time,
+        m.buy_count,
+        m.total_number,
+        m.rent_free_days,
+        m.crt_time AS timeOfMembership,
+        m.recent_recharge,
+        m.name as memberName
+        from
+        app_user_login l
+        left join
+        app_user_detail d
+        on d.userid = l.id
+        left join
+        (
+        select
+        b.*,
+        ml.name
+        from
+        base_user_member b
+        left join
+        base_user_member_level ml
+        on
+        ml.id = b.member_level
+        )  m
+        on
+        l.id = m.user_id
+        where 1=1
+
+        <if test="mobile !=null || mobile ! = ''">
+            and l.username=#{mobile}
+        </if>
+        <if test="channel !=null || channel != ''">
+            and d.channel=#{channel}
+        </if>
+        <if test="memberLevel !=null || memberLevel  != ''">
+            and m.member_level = #{memberLevel}
+        </if>
+        <if test="registrationTimeBegin !=null || registrationTimeBegin  != ''">
+            and l.createtime &gt;= #{registrationTimeBegin}
+        </if>
+        <if test="registrationTimeEnd!=null || registrationTimeEnd != ''">
+            and l.createtime &lt;= #{registrationTimeEn}
+        </if>
 
 
   </select>

xx-app/xx-app-api/src/main/java/com/xxfc/platform/app/utils/UploadUtil.java

+//package com.xxfc.platform.app.utils;
+//
+//import lombok.extern.slf4j.Slf4j;
+//
+//import java.io.*;
+//import java.net.*;
+//import java.util.Map;
+//import java.util.UUID;
+//@Slf4j
+//public class UploadUtil {
+//
+//
+//    public static final String TAG = UploadUtil.class.getName();
+//
+//    private static final String CHARSET = "utf-8"; // 设置编码
+//    private static final int TIME_OUT = 8*1000;
+//    public static String result = null;
+//    /**
+//     * Android上传文件到服务端
+//     *
+//     * @param file 需要上传的文件
+//     * @param RequestURL 请求的url
+//     * @return 返回响应的内容
+//     */
+//    public static String uploadFile(final File file, final String RequestURL) {
+//
+////        Thread thread = new Thread(new Runnable() {
+////            @Override
+////            public void run() {
+//                String result = null;
+//                String BOUNDARY = UUID.randomUUID().toString(); // 边界标识 随机生成
+//                String PREFIX = "--", LINE_END = "\r\n";
+//                String CONTENT_TYPE = "multipart/form-data"; // 内容类型
+//                try {
+//                    URL url = new URL(RequestURL);
+//                    HttpURLConnection conn = (HttpURLConnection) url.openConnection();
+//
+//                    conn.setReadTimeout(TIME_OUT);
+//                    conn.setConnectTimeout(TIME_OUT);
+//                    conn.setDoInput(true); // 允许输入流
+//                    conn.setDoOutput(true); // 允许输出流
+//                    conn.setUseCaches(false); // 不允许使用缓存
+//                    conn.setRequestMethod("POST"); // 请求方式
+//                    conn.setRequestProperty("Charset", CHARSET); // 设置编码
+//                    conn.setRequestProperty("connection", "keep-alive");
+//                    conn.setRequestProperty("Content-Type", CONTENT_TYPE + ";boundary=" + BOUNDARY);
+//
+//
+//                    if (file != null) {
+//                        /**
+//                         * 当文件不为空，把文件包装并且上传
+//                         */
+//                        DataOutputStream dos = new DataOutputStream(conn.getOutputStream());
+//                        StringBuffer sb = new StringBuffer();
+//                        sb.append(PREFIX);
+//                        sb.append(BOUNDARY);
+//                        sb.append(LINE_END);
+//                        /**
+//                         * 这里重点注意： name里面的值为服务端需要key 只有这个key 才可以得到对应的文件
+//                         * filename是文件的名字，包含后缀名的 比如:abc.png
+//                         */
+//
+//                        sb.append("Content-Disposition: form-data; name=\"upload\"; filename=\""
+//                                + file.getName() + "\"" + LINE_END);
+//                        sb.append("Content-Type: application/octet-stream; charset=" + CHARSET + LINE_END);
+//                        sb.append(LINE_END);
+//                        dos.write(sb.toString().getBytes());
+//                        InputStream is = new FileInputStream(file);
+//                        byte[] bytes = new byte[1024];
+//                        int len = 0;
+//                        while ((len = is.read(bytes)) != -1) {
+//                            dos.write(bytes, 0, len);
+//                        }
+//                        is.close();
+//                        dos.write(LINE_END.getBytes());
+//                        byte[] end_data = (PREFIX + BOUNDARY + PREFIX + LINE_END).getBytes();
+//                        dos.write(end_data);
+//                        dos.flush();
+//                        /**
+//                         * 获取响应码 200=成功 当响应成功，获取响应的流
+//                         */
+//                        int res = conn.getResponseCode();
+//                        LOG.i(TAG, "response code:" + res);
+//                        if(res==200)
+//                        {
+//                        LOG.i(TAG, "request success");
+//                        InputStream input = conn.getInputStream();
+//                        StringBuffer sb1 = new StringBuffer();
+//                        int ss;
+//                        while ((ss = input.read()) != -1) {
+//                            sb1.append((char) ss);
+//                        }
+//                        result = sb1.toString();
+//                        UploadUtil.result = new String(result.getBytes("iso-8859-1"),"utf-8");
+//                        LOG.i(TAG, "result : " + UploadUtil.result);
+//                            input.close();
+//                        }
+//                        else{
+//                             LOG.e(TAG, "request error");
+//                        }
+//
+//                    }
+//                } catch (MalformedURLException e) {
+//                    e.printStackTrace();
+//                } catch (IOException e) {
+//                    e.printStackTrace();
+//                } catch (UnsupportedEncodingException e) {
+//                    e.printStackTrace();
+//                } catch (ProtocolException e) {
+//                    e.printStackTrace();
+//                } catch (MalformedURLException e) {
+//                    e.printStackTrace();
+//                } catch (IOException e) {
+//                    e.printStackTrace();
+//                }
+//
+////            }
+////        });
+////        thread.start();
+//        LOG.i(TAG, "---"+UploadUtil.result+"---");
+//        return  UploadUtil.result;
+//    }
+//
+//
+//    /**
+//     * 通过拼接的方式构造请求内容，实现参数传输以及文件传输
+//     *
+//     * @param url Service net address
+//     * @param params text content
+//     * @param files pictures
+//     * @return String result of Service response
+//     * @throws IOException
+//     */
+//    public static String post(String url, Map<String, String> params, Map<String, File> files)
+//            throws IOException {
+//        String BOUNDARY = java.util.UUID.randomUUID().toString();
+//        String PREFIX = "--", LINEND = "\r\n";
+//        String MULTIPART_FROM_DATA = "multipart/form-data";
+//        String CHARSET = "UTF-8";
+//
+//
+//        URL uri = new URL(url);
+//        HttpURLConnection conn = (HttpURLConnection) uri.openConnection();
+//        conn.setReadTimeout(10 * 1000); // 缓存的最长时间
+//        conn.setDoInput(true);// 允许输入
+//        conn.setDoOutput(true);// 允许输出
+//        conn.setUseCaches(false); // 不允许使用缓存
+//        conn.setRequestMethod("POST");
+//        conn.setRequestProperty("connection", "keep-alive");
+//        conn.setRequestProperty("Charsert", "UTF-8");
+//        conn.setRequestProperty("Content-Type", MULTIPART_FROM_DATA + ";boundary=" + BOUNDARY);
+//
+//
+//        // 首先组拼文本类型的参数
+//        StringBuilder sb = new StringBuilder();
+//        for (Map.Entry<String, String> entry : params.entrySet()) {
+//            sb.append(PREFIX);
+//            sb.append(BOUNDARY);
+//            sb.append(LINEND);
+//            sb.append("Content-Disposition: form-data; name=\"" + entry.getKey() + "\"" + LINEND);
+//            sb.append("Content-Type: text/plain; charset=" + CHARSET + LINEND);
+//            sb.append("Content-Transfer-Encoding: 8bit" + LINEND);
+//            sb.append(LINEND);
+//            sb.append(entry.getValue());
+//            sb.append(LINEND);
+//        }
+//
+//
+//        DataOutputStream outStream = new DataOutputStream(conn.getOutputStream());
+//        outStream.write(sb.toString().getBytes());
+//        // 发送文件数据
+//        if (files != null)
+//            for (Map.Entry<String, File> file : files.entrySet()) {
+//                StringBuilder sb1 = new StringBuilder();
+//                sb1.append(PREFIX);
+//                sb1.append(BOUNDARY);
+//                sb1.append(LINEND);
+//                sb1.append("Content-Disposition: form-data; name=\"upload\"; filename=\""
+//                        + file.getValue().getName() + "\"" + LINEND);
+//                sb1.append("Content-Type: application/octet-stream; charset=" + CHARSET + LINEND);
+//                sb1.append(LINEND);
+//                outStream.write(sb1.toString().getBytes());
+//
+//
+//                InputStream is = new FileInputStream(file.getValue());
+//                byte[] buffer = new byte[1024];
+//                int len = 0;
+//                while ((len = is.read(buffer)) != -1) {
+//                    outStream.write(buffer, 0, len);
+//                }
+//
+//
+//                is.close();
+//                outStream.write(LINEND.getBytes());
+//            }
+//
+//
+//        // 请求结束标志
+//        byte[] end_data = (PREFIX + BOUNDARY + PREFIX + LINEND).getBytes();
+//        outStream.write(end_data);
+//        outStream.flush();
+//        // 得到响应码
+//        int res = conn.getResponseCode();
+//        InputStream in = conn.getInputStream();
+//        StringBuilder sb2 = new StringBuilder();
+//        if (res == 200) {
+//            int ch;
+//            while ((ch = in.read()) != -1) {
+//                sb2.append((char) ch);
+//            }
+//        }
+//        outStream.close();
+//        conn.disconnect();
+//        return sb2.toString();
+//    }
+//
+//}

xx-app/xx-app-server/src/main/java/com/xxfc/platform/app/biz/AppVersionBiz.java

 package com.xxfc.platform.app.biz;
 
+import com.github.wxiaoqi.security.auth.client.annotation.IgnoreUserToken;
 import com.github.wxiaoqi.security.common.constant.RestCode;
 import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
 import com.github.wxiaoqi.security.common.util.process.ResultCode;
+import com.xxfc.platform.vehicle.common.RestResponse;
+import com.xxfc.platform.vehicle.constant.RedisKey;
+import io.swagger.annotations.ApiOperation;
+import org.apache.commons.io.FileUtils;
 import org.apache.commons.lang3.StringUtils;
+import org.joda.time.DateTime;
+import org.joda.time.format.DateTimeFormat;
+import org.joda.time.format.DateTimeFormatter;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Service;
 import com.xxfc.platform.app.entity.AppVersion;
 import com.xxfc.platform.app.mapper.AppVersionMapper;
 import com.github.wxiaoqi.security.common.biz.BaseBiz;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.multipart.MultipartFile;
 import tk.mybatis.mapper.entity.Example;
+import tk.mybatis.mapper.weekend.WeekendSqls;
 
+import java.io.File;
+import java.io.IOException;
 import java.util.List;
+import java.util.concurrent.TimeUnit;
 
 /**
  * 
@@ -22,6 +46,13 @@ import java.util.List;
 @Service
 public class AppVersionBiz extends BaseBiz<AppVersionMapper,AppVersion> {
 
+     @Value("${app.uploadPath}")
+    private  String uploadPath;
+     @Autowired
+     private RedisTemplate redisTemplate;
+
+    public static final DateTimeFormatter DEFAULT_DATE_TIME_FORMATTER = DateTimeFormat.forPattern("yyyy-MM-dd");
+
 
     public ObjectRestResponse getVersion(String version,Integer type){
         if (StringUtils.isBlank(version)||type==null){
@@ -49,4 +80,79 @@ public class AppVersionBiz extends BaseBiz<AppVersionMapper,AppVersion> {
         }
            return  ObjectRestResponse.succ();
     }
+
+    public RestResponse uploadDrivingLicense(MultipartFile file) throws IOException {
+        DateTime now = DateTime.now();
+        String dirPathToday =  File.separator + now.toString(DEFAULT_DATE_TIME_FORMATTER);
+        String redisNoKey = RedisKey.UPLOAD_FILE_NO_PREFIX + now.toString(DEFAULT_DATE_TIME_FORMATTER);
+//        Long no = redisTemplate.opsForValue().increment(redisNoKey);
+//        if(no.equals(1L)){
+//            redisTemplate.expire(redisNoKey,1, TimeUnit.DAYS);
+//        }
+        String fileName = file.getOriginalFilename();
+        String realFileRelPath = dirPathToday + File.separator+fileName.substring(fileName.lastIndexOf("/"));
+
+        String filePath = uploadPath + realFileRelPath;
+
+        FileUtils.copyInputStreamToFile(file.getInputStream(), new File(filePath));
+        return RestResponse.suc(filePath);
+    }
+
+
+    /**
+     * 下载行驶证图片
+     * @param realFileRelPath
+     * @return
+     * @throws Exception
+     */
+    public ResponseEntity<byte[]> downloadInstallationPackage(String realFileRelPath) throws Exception{
+        String filePath = uploadPath + realFileRelPath;
+        File file = new File(filePath);//新建一个文件
+        HttpHeaders headers = new HttpHeaders();//http头信息
+        String downloadFileName = new String(file.getName());//设置编码
+        headers.setContentDispositionFormData("attachment", downloadFileName);
+        headers.setContentType(MediaType.APPLICATION_OCTET_STREAM);
+        return new ResponseEntity<byte[]>(FileUtils.readFileToByteArray(file),headers, HttpStatus.CREATED);
+    }
+
+    /**
+     * 添加版本信息
+     * @param appVersion
+     */
+    @Transactional
+    public void insertAppVersion(AppVersion appVersion) {
+        appVersion.setDownloadSwitch(0);
+        insertSelective(appVersion);
+    }
+
+    public AppVersion get(Integer id) {
+
+        if (id==null) {
+            throw new IllegalArgumentException("Parameter is null");
+        }
+
+        return selectById(id);
+    }
+
+    /**
+     * 修改一条信息
+     * @param appVersion
+     */
+    @Transactional
+    public void updateAppVersionById(AppVersion appVersion) {
+        updateSelectiveById(appVersion);
+    }
+
+    /**
+     * 删除
+     * @param id
+     */
+    public void remove(Integer id) {
+        AppVersion appVersion = new AppVersion();
+        appVersion.setIsDel(1);
+        Example example = Example.builder(AppVersion.class)
+                .where(WeekendSqls.<AppVersion>custom().andEqualTo(AppVersion::getId,id))
+                .build();
+        mapper.updateByExampleSelective(appVersion,example);
+    }
 }
\ No newline at end of file

xx-app/xx-app-server/src/main/java/com/xxfc/platform/app/rest/AppHomeController.java

@@ -2,17 +2,15 @@ package com.xxfc.platform.app.rest;
 
 import com.github.wxiaoqi.security.auth.client.annotation.IgnoreClientToken;
 import com.github.wxiaoqi.security.auth.client.annotation.IgnoreUserToken;
-import com.github.wxiaoqi.security.common.exception.BaseException;
 import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
 import com.github.wxiaoqi.security.common.rest.BaseController;
-import com.github.wxiaoqi.security.common.util.process.ResultCode;
 import com.github.wxiaoqi.security.common.vo.GoodDataVO;
 import com.xxfc.platform.app.biz.CofigBiz;
 import com.xxfc.platform.app.entity.Cofig;
 import com.xxfc.platform.campsite.feign.CampsiteFeign;
 import com.xxfc.platform.tour.feign.TourFeign;
+import com.xxfc.platform.vehicle.feign.VehicleFeign;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestMethod;
@@ -35,6 +33,11 @@ public class AppHomeController extends BaseController<CofigBiz,Cofig> {
     @Autowired
     TourFeign tourFeign;
 
+    @Autowired
+    VehicleFeign vehicleFeign;
+
+
+
     @RequestMapping(value ="/app/unauth/goodList",method = RequestMethod.GET)
     @IgnoreUserToken
     public ObjectRestResponse<List<GoodDataVO>> goodList(
@@ -47,6 +50,8 @@ public class AppHomeController extends BaseController<CofigBiz,Cofig> {
             list=tourFeign.goodList(page,limit);
         }else if (type==3){
             list=campsiteFeign.goodList(page,limit);
+        }else if (type==4){
+            list=vehicleFeign.goodList(page,limit);
         }
         return  new ObjectRestResponse<>().rel(true).data(list);
     }

xx-app/xx-app-server/src/main/java/com/xxfc/platform/app/rest/AppVersionController.java

@@ -9,14 +9,24 @@ import com.github.wxiaoqi.security.common.util.process.ResultCode;
 import com.xxfc.platform.app.biz.AppVersionBiz;
 import com.xxfc.platform.app.entity.AppVersion;
 import com.xxfc.platform.app.entity.Cofig;
+import com.xxfc.platform.vehicle.common.RestResponse;
+import com.xxfc.platform.vehicle.constant.ResCode.ResCode;
 import io.swagger.annotations.ApiModelProperty;
+import io.swagger.annotations.ApiOperation;
+import lombok.Data;
+import org.apache.commons.io.FileUtils;
 import org.apache.commons.lang3.StringUtils;
+import org.apache.ibatis.annotations.Delete;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Controller;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestMethod;
-import org.springframework.web.bind.annotation.RequestParam;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.util.Assert;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
 
+import java.io.File;
 import java.util.ArrayList;
 import java.util.List;
 
@@ -24,7 +34,9 @@ import java.util.List;
 @RequestMapping("version")
 @IgnoreClientToken
 public class AppVersionController extends BaseController<AppVersionBiz,AppVersion> {
-
+      //最大上传500MB
+     private Long MAX_DRIVING_LICENSE_SIZE =1024*1024*500L;
+    private int id;
 
     @ApiModelProperty("app自动更新")
     @RequestMapping(value ="/app/unauth/info",method = RequestMethod.GET)
@@ -36,4 +48,63 @@ public class AppVersionController extends BaseController<AppVersionBiz,AppVersio
         return baseBiz.getVersion(version,type);
     }
 
+
+    @Override
+    @ApiOperation("添加")
+    @RequestMapping(value = "/add",method = RequestMethod.POST)
+    public ObjectRestResponse<AppVersion> add(@RequestBody AppVersion appVersion){
+        baseBiz.insertAppVersion(appVersion);
+        return new ObjectRestResponse<AppVersion>();
+    }
+
+
+    @ApiOperation("查询")
+    @RequestMapping(value = "/{id}",method = RequestMethod.GET)
+    public ObjectRestResponse<AppVersion> get(@PathVariable Integer id){
+        return ObjectRestResponse.succ(baseBiz.get(id));
+    }
+
+    @Override
+    @ApiOperation("修改")
+    @RequestMapping(value = "/update/{id}",method = RequestMethod.PUT)
+    public ObjectRestResponse<AppVersion> update(@RequestBody AppVersion appVersion){
+        baseBiz.updateAppVersionById(appVersion);
+        return new ObjectRestResponse<AppVersion>();
+    }
+
+    @ApiOperation("删除")
+    @DeleteMapping(value = "/remove/{id}")
+    public ObjectRestResponse<AppVersion> remove(@PathVariable Integer id){
+        baseBiz.remove(id);
+        return new ObjectRestResponse<AppVersion>();
+    }
+
+
+
+    @PostMapping(value = "/upload/installationPackage")
+    @ApiOperation(value = "上传app安装包")
+    public RestResponse uploadInstallationPackage(@RequestParam("file") MultipartFile file)
+            throws Exception {
+        Assert.notNull(file);
+        String contentType = file.getContentType();   //文件类型
+////        String fileName = file.getOriginalFilename();  //文件名
+        if (!contentType.equals("apk") && !contentType.equals("ipa")) {
+            return RestResponse.code(ResCode.INVALID_REST_REQ_PARAM.getCode());
+        }
+        if (file.getSize() > MAX_DRIVING_LICENSE_SIZE) {
+            return RestResponse.code(ResCode.INVALID_REST_REQ_PARAM.getCode());
+        }
+        return baseBiz.uploadDrivingLicense(file);
+    }
+
+
+
+
+    @IgnoreUserToken
+    @GetMapping(value = "/download/installationPackage/{realFileRelPath}") //匹配的是href中的download请求
+    @ApiOperation(value = "下载app安装包")
+    public ResponseEntity<byte[]> downloadInstallationPackage(@RequestParam("realFileRelPath") String realFileRelPath) throws Exception {
+        return baseBiz.downloadInstallationPackage(realFileRelPath);
+    }
+
 }
\ No newline at end of file

xx-universal/xx-universal-api/src/main/java/com/xxfc/platform/universal/api/BaseAuthentication.java

+package com.xxfc.platform.universal.api;
+
+
+import com.xxfc.platform.universal.api.pojo.Authentication;
+import com.xxfc.platform.universal.entity.IdInformation;
+
+/**
+ * 调用外部接口实现类。调用不同的外部接口，需要编写不同了类实现该类
+ */
+public interface BaseAuthentication {
+
+    Authentication getAuthentication(IdInformation idInformation);
+
+}

xx-universal/xx-universal-api/src/main/java/com/xxfc/platform/universal/api/impl/FQAuthentication.java

+package com.xxfc.platform.universal.api.impl;
+
+import com.xxfc.platform.universal.api.BaseAuthentication;
+import com.xxfc.platform.universal.api.pojo.Authentication;
+import com.xxfc.platform.universal.entity.IdInformation;
+
+public class FQAuthentication implements BaseAuthentication {
+    @Override
+    public Authentication getAuthentication(IdInformation idInformation) {
+
+        return null;
+    }
+}

xx-universal/xx-universal-api/src/main/java/com/xxfc/platform/universal/api/pojo/Authentication.java

+package com.xxfc.platform.universal.api.pojo;
+
+public class Authentication {
+}

xx-universal/xx-universal-api/src/main/java/com/xxfc/platform/universal/constant/RedisKey.java

+
 package com.xxfc.platform.universal.constant;
+
+
 public class RedisKey {
 
     /**
@@ -94,4 +97,5 @@ public class RedisKey {
 
     public static final String CACHE_DICTIONARY_ALL =CACHE_DICTIONARY_PREFIX + "all:";
     public static final String CACHE_DICTIONARY_ALL_MAP =CACHE_DICTIONARY_ALL + "map:";
+    public static final String ILLEGAL_VEHICLE_ENQUIRIES ="cache:violation";
 }

xx-universal/xx-universal-api/src/main/java/com/xxfc/platform/universal/entity/IdInformation.java

@@ -3,7 +3,6 @@ package com.xxfc.platform.universal.entity;
 
 
 import com.fasterxml.jackson.annotation.JsonFormat;
-import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 import org.springframework.format.annotation.DateTimeFormat;
 
@@ -12,8 +11,6 @@ import javax.persistence.GeneratedValue;
 import javax.persistence.Id;
 import javax.persistence.Table;
 import java.io.Serializable;
-import java.text.ParseException;
-import java.text.SimpleDateFormat;
 import java.util.Date;
 
 /**

xx-universal/xx-universal-api/src/main/java/com/xxfc/platform/universal/feign/ThirdFeign.java

@@ -57,7 +57,6 @@ public interface ThirdFeign {
     @GetMapping("/LicensePlateType")
     ObjectRestResponse getLicensePlateType();
 
-
     /*****************************************  数据字典 ********************************************/
 
 
@@ -65,7 +64,7 @@ public interface ThirdFeign {
     @RequestMapping(value = "/dictionary/getParents", method = RequestMethod.GET)
     public ObjectRestResponse<List<Dictionary>> dictionaryGetParent(@RequestParam(value = "type") String type);
 
-//    @GetMapping(value = "/dictionary/get")
+    //    @GetMapping(value = "/dictionary/get")
     @RequestMapping(value = "/dictionary/get", method = RequestMethod.GET)
     public ObjectRestResponse<List<Dictionary>> dictionaryGet(@RequestParam(value = "dictionary") Map<String, Object> dictionary);
 
@@ -77,4 +76,5 @@ public interface ThirdFeign {
     @GetMapping("/3p/tv/getRentViolation")
     public ObjectRestResponse<List<ViolationVO>> getRentViolation(@RequestParam(value = "rentViolationDTO") Map<String, Object> rentViolationDTO);
 
+
 }

xx-universal/xx-universal-server/src/main/java/com/xxfc/platform/universal/controller/TrafficViolationsController.java

@@ -2,21 +2,24 @@ package com.xxfc.platform.universal.controller;
 
 import com.alibaba.fastjson.JSONObject;
 import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
+import com.github.wxiaoqi.security.common.util.process.ResultCode;
+
 import com.xxfc.platform.universal.service.TrafficViolationsService;
 import com.xxfc.platform.universal.vo.RentViolationDTO;
 import com.xxfc.platform.universal.vo.TrafficViolations;
 import com.xxfc.platform.universal.vo.ViolationVO;
+import com.xxfc.platform.vehicle.entity.Vehicle;
+import com.xxfc.platform.vehicle.feign.VehicleFeign;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
-import java.math.BigDecimal;
-import java.util.ArrayList;
 import java.util.List;
 
 @RestController
 @RequestMapping("3p/tv")
 public class TrafficViolationsController {
-
+    @Autowired
+     private VehicleFeign vehicleFeign;
     @Autowired
     TrafficViolationsService tvService;
 
@@ -64,10 +67,17 @@ public class TrafficViolationsController {
 
     @GetMapping("/getRentViolation")
     public ObjectRestResponse<List<ViolationVO>> getRentViolation(RentViolationDTO rentViolationDTO) {
-        return ObjectRestResponse.succ(new ArrayList<ViolationVO>(){{
-            add(new ViolationVO(){{setPrice(new BigDecimal("100.00"));}});
-            add(new ViolationVO(){{setPrice(new BigDecimal("200.00"));}});
-        }});
+        String vehicleId = rentViolationDTO.getVehicleId();
+        if (rentViolationDTO==null||rentViolationDTO.getVehicleId()==null) {
+            return ObjectRestResponse.createFailedResult(ResultCode.FAILED_CODE,"Vehicle information is empty");
+        }
+
+        Vehicle vehicle = vehicleFeign.get(vehicleId).getData();
+        if (vehicle==null) {
+            return ObjectRestResponse.createFailedResult(ResultCode.FAILED_CODE,"No corresponding vehicle information");
+        }
+
+        return ObjectRestResponse.succ(tvService.getRentViolation(rentViolationDTO,vehicle));
     }
 
 

xx-universal/xx-universal-server/src/main/java/com/xxfc/platform/universal/service/TrafficViolationsService.java

@@ -3,9 +3,12 @@ package com.xxfc.platform.universal.service;
 import com.alibaba.fastjson.JSONObject;
 import com.github.wxiaoqi.security.common.exception.BaseException;
 import com.xxfc.platform.universal.biz.LicensePlateTypeBiz;
+import com.xxfc.platform.universal.constant.RedisKey;
 import com.xxfc.platform.universal.entity.LicensePlateType;
 import com.xxfc.platform.universal.utils.CertifHttpUtils;
+import com.xxfc.platform.universal.vo.RentViolationDTO;
 import com.xxfc.platform.universal.vo.TrafficViolations;
+import com.xxfc.platform.vehicle.entity.Vehicle;
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.http.HttpEntity;
@@ -14,6 +17,7 @@ import org.apache.http.util.EntityUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.core.task.TaskExecutor;
+import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Service;
 
@@ -60,6 +64,9 @@ public class TrafficViolationsService {
     private static final String FRAMENO_NAME="frameno";
     private static final String AUTHORIZATION="Authorization";
 
+     @Autowired
+     private RedisTemplate redisTemplate;
+
 
     /**
      * 支持查询的城市
@@ -209,4 +216,18 @@ public class TrafficViolationsService {
          licensePlateTypeBiz.insertLicensePlateType(finalLicensePlateTypes);
     }
 
+    /**
+     * 订单完成后调用接口获取车辆信息
+     * @param rentViolationDTO
+     * @param vehicle
+     * @return
+     */
+    public String getRentViolation(RentViolationDTO rentViolationDTO, Vehicle vehicle) {
+        String stringViolationVOS = (String) redisTemplate.opsForValue()
+                .get(RedisKey.ILLEGAL_VEHICLE_ENQUIRIES+rentViolationDTO.getVehicleId());
+        if (StringUtils.isBlank(stringViolationVOS)) {
+
+        }
+        return null;
+    }
 }

xx-universal/xx-universal-server/src/main/java/com/xxfc/platform/universal/service/UploadService.java

@@ -2,7 +2,7 @@ package com.xxfc.platform.universal.service;
 
 
 import com.github.wxiaoqi.security.common.util.process.SystemConfig;
-import com.xxfc.platform.vehicle.constant.RedisKey;
+import com.xxfc.platform.universal.constant.RedisKey;
 import org.apache.commons.io.FileUtils;
 import org.joda.time.DateTime;
 import org.joda.time.format.DateTimeFormat;

xx-vehicle/xx-vehicle-api/src/main/java/com/xxfc/platform/vehicle/entity/AccompanyingItem.java

 package com.xxfc.platform.vehicle.entity;
 
 import lombok.Data;
+import tk.mybatis.mapper.annotation.KeySql;
 
 import javax.persistence.Column;
 import javax.persistence.Id;

xx-vehicle/xx-vehicle-api/src/main/java/com/xxfc/platform/vehicle/feign/VehicleFeign.java

 package com.xxfc.platform.vehicle.feign;
 
 import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
+import com.github.wxiaoqi.security.common.vo.GoodDataVO;
 import com.xxfc.platform.vehicle.common.RestResponse;
 import com.xxfc.platform.vehicle.entity.*;
 import com.xxfc.platform.vehicle.pojo.CompanyDetail;
@@ -63,4 +64,13 @@ public interface VehicleFeign {
     @RequestMapping(value = "/user/license/company/getOne", method = RequestMethod.GET)
     public RestResponse<VehicleUserLicense> getOne(
             @RequestParam(value="id",defaultValue="0")Integer  id) throws Exception ;
+
+    /**
+     * 获取优质车型接口
+     * @param page
+     * @param limit
+     * @return 返回
+     */
+    @GetMapping(value = "/vehicleModel/goodList")
+    List<GoodDataVO> goodList(@RequestParam(value = "page") Integer page, @RequestParam("limit") Integer limit);
 }

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/biz/VehicleBiz.java

@@ -126,6 +126,7 @@ public class VehicleBiz extends BaseBiz<VehicleMapper, Vehicle> {
      * @throws Exception
      */
     public ResponseEntity<byte[]> downloadDrivingLicense(String realFileRelPath) throws Exception{
+
         String filePath = baseUploadPath + realFileRelPath;
         File file = new File(filePath);//新建一个文件
         HttpHeaders headers = new HttpHeaders();//http头信息
@@ -152,7 +153,7 @@ public class VehicleBiz extends BaseBiz<VehicleMapper, Vehicle> {
         params.put("vehicle",vehicle);
         params.put("yearMonth",yearMonth);
         List<VehicleBookInfo> vehicleBookInfoList = vehicleBookInfoMapper.getByVehicleIdAndYearMonth(params);
-        return CollectionUtils.isEmpty(vehicleBookInfoList)?null:vehicleBookInfoList.get(0);
+        return CollectionUtils.isEmpty(vehicleBookInfoList)? null:vehicleBookInfoList.get(0);
     }
 
     /**

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/biz/VehicleModelBiz.java

 package com.xxfc.platform.vehicle.biz;
 
+import com.github.pagehelper.Page;
+import com.github.pagehelper.PageHelper;
+import com.github.pagehelper.PageInfo;
 import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
+import com.github.wxiaoqi.security.common.vo.GoodDataVO;
 import com.github.wxiaoqi.security.common.vo.PageDataVO;
+import com.xxfc.platform.vehicle.entity.Vehicle;
 import com.xxfc.platform.vehicle.pojo.VehicleModelQueryCondition;
 import com.xxfc.platform.vehicle.pojo.VehicleModelVo;
 import lombok.extern.slf4j.Slf4j;
@@ -12,7 +17,10 @@ import com.xxfc.platform.vehicle.mapper.VehicleModelMapper;
 import com.github.wxiaoqi.security.common.biz.BaseBiz;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.transaction.interceptor.TransactionAspectSupport;
+import tk.mybatis.mapper.entity.Example;
+import tk.mybatis.mapper.weekend.WeekendSqls;
 
+import java.util.Arrays;
 import java.util.List;
 import java.util.stream.Collectors;
 
@@ -36,20 +44,19 @@ public class VehicleModelBiz extends BaseBiz<VehicleModelMapper, VehicleModel> {
         updateSelectiveById(model);
     }
 
+    /**
+     * 分页查询车型列表
+     * @param vmqc
+     * @return
+     */
     public ObjectRestResponse findVehicleModelPage(VehicleModelQueryCondition vmqc) {
 
-//        List<VehicleModelVo > vehicleModelPage = mapper.findVehicleModelPage(vmqc);
 
-//    log.debug("vehicleModelPage"+vehicleModelPage);
 
 
         try {
             PageDataVO<VehicleModelVo> mPageDataVO = PageDataVO.pageInfo(vmqc.getPage(),
                     vmqc.getLimit(), () -> mapper.findVehicleModelPage(vmqc));
-
-//            List<VehicleModelVo> vehicleModelVos = mPageDataVO.getData();
-//            vehicleModelVos.parallelStream().forEach(vehicleModelVo -> vehicleModelVo.setPicture(vehicleModelVo.getPicture().split(",")[0]));
-
             return ObjectRestResponse.succ(mPageDataVO);
         } catch (Exception e) {
             e.printStackTrace();
@@ -85,4 +92,34 @@ public class VehicleModelBiz extends BaseBiz<VehicleModelMapper, VehicleModel> {
     public void updateByPrimaryKeySelective(VehicleModel vm){
         mapper.updateByPrimaryKeySelective(vm);
     }
+
+    /**
+     * 分页查询返回List<GoodDataVO>
+     * @param page
+     * @param limit
+     * @return
+     */
+    public List<GoodDataVO> goodList(Integer page, Integer limit) {
+        List<GoodDataVO> goodDataVOS = Arrays.asList();
+        /*设置分页*/
+        Page<VehicleModel> pages = PageHelper.startPage(page, limit);
+
+        Example example = Example.builder(VehicleModel.class)
+                .where(WeekendSqls.<VehicleModel>custom().andEqualTo(VehicleModel::getIsdel, 0)).orderByDesc("hot_sign").build();
+        selectByExample(example);
+
+        PageInfo<VehicleModel> pageInfo= PageInfo.of(pages.getResult());
+        List<VehicleModel> vehicleModelList = pageInfo.getList();
+        /*遍历车型列表设置List<GoodDataVO>*/
+        for (VehicleModel vm : vehicleModelList) {
+            GoodDataVO goodDataVO = new GoodDataVO();
+            goodDataVO.setId(vm.getId());
+            goodDataVO.setImgUrl(vm.getPicture());
+            goodDataVO.setName(vm.getName());
+            goodDataVO.setName1(vm.getKeyword());
+            goodDataVO.setPrice(String.valueOf(vm.getBuyPrice()));
+            goodDataVOS.add(goodDataVO);
+        }
+        return goodDataVOS;
+    }
 }
\ No newline at end of file

xx-vehicle/xx-vehicle-server/src/main/java/com/xxfc/platform/vehicle/rest/VehicleModelController.java

 package com.xxfc.platform.vehicle.rest;
 
 import cn.hutool.core.bean.BeanUtil;
+import com.github.pagehelper.PageInfo;
 import com.github.wxiaoqi.security.admin.feign.UserFeign;
 import com.github.wxiaoqi.security.admin.feign.dto.UserDTO;
 import com.github.wxiaoqi.security.auth.client.config.UserAuthConfig;
@@ -9,6 +10,7 @@ import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
 import com.github.wxiaoqi.security.common.rest.BaseController;
 import com.github.wxiaoqi.security.common.util.Query;
 import com.github.wxiaoqi.security.common.util.process.ResultCode;
+import com.github.wxiaoqi.security.common.vo.GoodDataVO;
 import com.xxfc.platform.vehicle.biz.VehicleBiz;
 import com.xxfc.platform.vehicle.biz.VehicleCataBiz;
 import com.xxfc.platform.vehicle.biz.VehicleModelBiz;
@@ -37,6 +39,7 @@ import tk.mybatis.mapper.entity.Example;
 import tk.mybatis.mapper.weekend.WeekendSqls;
 
 import javax.servlet.http.HttpServletRequest;
+import java.awt.print.Pageable;
 import java.math.BigDecimal;
 import java.util.ArrayList;
 import java.util.Date;
@@ -93,28 +96,22 @@ public class VehicleModelController extends BaseController<VehicleModelBiz, Vehi
      * @return
      */
     @ApiOperation("车型列表")
-    @PostMapping(value = "/app/findVehicleModelPage")
-    public ObjectRestResponse<VehicleModelVo> findVehicleModelPage(
+    @PostMapping(value = "/app/unauthfind/VehicleModelPage")
+    public ObjectRestResponse<VehicleModelVo> findVehicleModelPageUnauthfind(
             @RequestBody @ApiParam("查询条件") VehicleModelQueryCondition vmqc ,HttpServletRequest request) {
 
-//        UserDTO user = userFeign.userinfoByToken(userAuthConfig.getToken(request)).getData();
-//
-//        if (user!=null) {
-//            if (user.getDataAll()==2) {
-//
-//            }
-//        }
         if (vmqc.getIsDel()==null) {
             vmqc.setIsDel(0);
         }
 
-
         if (vmqc == null || vmqc.getPage() == null || vmqc.getLimit() == null || vmqc.getPage() < 0 || vmqc.getLimit() <= 0) {
             return ObjectRestResponse.createDefaultFail();
         }
         return vehicleModelBiz.findVehicleModelPage(vmqc);
     }
 
+
+
     /**
      * 添加车型
      *
@@ -124,7 +121,6 @@ public class VehicleModelController extends BaseController<VehicleModelBiz, Vehi
      */
     @ApiOperation("添加")
     @PostMapping(value = "/app/add")
-    @ResponseBody
     @Transactional
     public ObjectRestResponse<VehicleModel> add(@RequestBody VehicleModel vm, HttpServletRequest request) {
         if (vm == null) {
@@ -156,6 +152,7 @@ public class VehicleModelController extends BaseController<VehicleModelBiz, Vehi
         //设置信息
         vm.setCrtName(uorr.getData().getName());
         vm.setCrtUser(uorr.getData().getId());
+        vm.setHotSign(2);
         vm.setCrtTime(new Date());
         vm.setCrtHost(host);
         vm.setIsdel(0);
@@ -193,7 +190,6 @@ public class VehicleModelController extends BaseController<VehicleModelBiz, Vehi
 
     @ApiOperation("修改")
     @PutMapping(value = "/app/update")
-    @ResponseBody
     @Transactional
     public ObjectRestResponse<VehicleModel> update(@RequestBody VehicleModel vm, HttpServletRequest request) {
 
@@ -252,26 +248,9 @@ public class VehicleModelController extends BaseController<VehicleModelBiz, Vehi
     @Override
     @ApiOperation("删除")
     @DeleteMapping(value = "/app/{id}")
-    @ResponseBody
     @Transactional
     public ObjectRestResponse<VehicleModel> remove(@PathVariable int id) {
 
-        //1.先判断是否有属于该车型可用的车辆,有不能删除,无可以进行删除
-        //根据车型查询对应的车辆
-//        Example exa = Example.builder(Vehicle.class).where(
-//                WeekendSqls.<Vehicle>custom()
-//                        .andEqualTo(Vehicle::getModelId, id)
-//                        .andEqualTo(Vehicle::getStatus, 1)
-//                        .orEqualTo(Vehicle::getStatus,"2")
-//        ).build();
-//
-//        List<Vehicle> vehicles = vehicleBiz.selectByExample(exa);
-//
-//        //判断是查询到对应的车辆
-//        if (vehicles != null) {
-//            ObjectRestResponse.createFailedResult(ResultCode.FAILED_CODE, "该车型,无法删除");
-//        }
-
         if (id==1||id==14) {
             return ObjectRestResponse.createFailedResult(ResultCode.FAILED_CODE,"The label cannot be deleted");
         }
@@ -302,4 +281,34 @@ public class VehicleModelController extends BaseController<VehicleModelBiz, Vehi
         return ObjectRestResponse.succ(baseBiz.selectList(vehicleModel));
     }
 
+
+    @ApiOperation("查询所有")
+    @GetMapping(value = "/goodList")
+    public List<GoodDataVO> goodList(@RequestParam("page") Integer page,@RequestParam("limit") Integer limit){
+        return baseBiz.goodList(page,limit);
+    }
+
+
+    /**
+     * 车型列表查
+     *
+     * @param vmqc 条件
+     * @return
+     */
+    @ApiOperation("车型列表")
+    @PostMapping(value = "/app/VehicleModelPage")
+    public ObjectRestResponse<VehicleModelVo> findVehicleModelPage(
+            @RequestBody @ApiParam("查询条件") VehicleModelQueryCondition vmqc ,HttpServletRequest request) {
+
+        if (vmqc.getIsDel()==null) {
+            vmqc.setIsDel(0);
+        }
+
+        if (vmqc == null || vmqc.getPage() == null || vmqc.getLimit() == null || vmqc.getPage() < 0 || vmqc.getLimit() <= 0) {
+            return ObjectRestResponse.createDefaultFail();
+        }
+        return vehicleModelBiz.findVehicleModelPage(vmqc);
+    }
+
+
 }
\ No newline at end of file

xx-vehicle/xx-vehicle-server/src/test/java/com/xxfc/platform/vehicle/ListTest.java

+package com.xxfc.platform.vehicle;
+
+import org.junit.Test;
+
+import java.lang.reflect.Array;
+import java.util.Arrays;
+import java.util.List;
+
+public class ListTest {
+    @Test
+    public void ListTest(){
+        List<Object> objects = Arrays.asList();
+        System.out.println("objects.size()"+objects.get(0));
+    }
+}

xx-vehicle/xx-vehicle-server/src/test/java/com/xxfc/platform/vehicle/TimeTest.java

 package com.xxfc.platform.vehicle;
 
-import cn.hutool.core.date.DateUtil;
-import cn.hutool.core.io.file.FileWriter;
-import cn.hutool.json.JSONUtil;
-import com.github.wxiaoqi.security.common.msg.TableResultResponse;
-import com.github.wxiaoqi.security.common.util.Query;
-import com.xxfc.platform.vehicle.biz.SysRegionBiz;
-import com.xxfc.platform.vehicle.entity.SysRegion;
-import lombok.Data;
+import com.xxfc.platform.vehicle.entity.SimpleGenId;
+import com.xxfc.platform.vehicle.entity.Student;
 import org.joda.time.DateTime;
 import org.joda.time.format.DateTimeFormat;
 import org.joda.time.format.DateTimeFormatter;
 import org.junit.Test;
 import org.junit.runner.RunWith;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
 
-import java.io.Serializable;
 import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
 
 @RunWith(SpringJUnit4ClassRunner.class)
 @SpringBootTest(classes={VehicleApplication.class})
@@ -48,22 +38,16 @@ public class TimeTest {
 
     }
 
+    @Test
+    public void testMapper(){
+        Student sOne = new Student("张4", "14",1);
+        sOne.getId();
+//        Assert.assertEquals();
+        SimpleGenId simpleGenId = new SimpleGenId();
+        Long aLong = simpleGenId.genId("6696", "122223");
 
-}
+    }
 
-@Data
-class Student implements Serializable {
-    private String name;
-    private String age;
-    private int code;
 
-    public Student(String name, String age, int code) {
-        this.name=name;
-        this.age=age;
-        this.code=code;
-    }
-    public Student(String name, String age) {
-        this.name=name;
-        this.age=age;
-    }
 }
+

xx-vehicle/xx-vehicle-server/src/test/java/com/xxfc/platform/vehicle/TimedTaskTest.java

+package com.xxfc.platform.vehicle;
+
+import org.junit.Test;
+import org.springframework.core.task.TaskExecutor;
+
+import java.util.concurrent.Callable;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
+
+public class TimedTaskTest {
+
+    public static void main(String[] args) {
+        ScheduledExecutorService executorService = Executors.newSingleThreadScheduledExecutor();
+        executorService.scheduleWithFixedDelay(new MyRunnable(),0,4000,TimeUnit.MILLISECONDS);
+    }
+
+//    @Test
+//    public void fn1() {
+//        TaskExecutor taskExecutor = new TaskExecutor() {
+//            @Override
+//            public void execute(Runnable task) {
+//
+//                ScheduledExecutorService executorService = Executors.newSingleThreadScheduledExecutor();
+//                executorService.scheduleAtFixedRate(
+//                        () -> System.out.println("测试定时任务11111111111111" + System.currentTimeMillis()), 0, 100, TimeUnit.MILLISECONDS);
+//                System.out.println("========================================================================");
+//                executorService.schedule(new Runnable() {
+//                    @Override
+//                    public void run() {
+//                        System.out.println("测试定时任务222222222222222222" + System.currentTimeMillis());
+//                    }
+//                }, 10, TimeUnit.MILLISECONDS);
+//            }
+//        };
+//
+//    }
+
+    private static class MyRunnable implements Runnable {
+
+        @Override
+        public void run() {
+
+            System.out.println("测试+++++++++++"+System.currentTimeMillis());
+//            ScheduledExecutorService executorService = Executors.newSingleThreadScheduledExecutor();
+//
+//            executorService.scheduleWithFixedDelay(new Runnable() {
+//                @Override
+//                public void run() {
+//                    System.out.println("测试+++++++"+System.currentTimeMillis());
+//                }
+//            },0,100,TimeUnit.MILLISECONDS);
+        }
+    }
+}

xx-vehicle/xx-vehicle-server/src/test/java/com/xxfc/platform/vehicle/entity/IdService.java

+package com.xxfc.platform.vehicle.entity;
+
+public class IdService {
+}

xx-vehicle/xx-vehicle-server/src/test/java/com/xxfc/platform/vehicle/entity/SimpleGenId.java

+package com.xxfc.platform.vehicle.entity;
+
+import tk.mybatis.mapper.genid.GenId;
+
+public class SimpleGenId implements GenId<Long> {
+        private Long    time;
+        private Integer seq;
+
+        @Override
+        public synchronized Long genId(String table, String column) {
+            long current = System.currentTimeMillis();
+            if (time == null || time != current) {
+                time = current;
+                seq = 1;
+            } else if (current == time) {
+                seq++;
+            }
+            return (time << 20) | seq;
+        }
+    }
\ No newline at end of file

xx-vehicle/xx-vehicle-server/src/test/java/com/xxfc/platform/vehicle/entity/Student.java

+package com.xxfc.platform.vehicle.entity;
+
+import com.xxfc.platform.vehicle.entity.UUIdGenId;
+import lombok.Data;
+import tk.mybatis.mapper.annotation.KeySql;
+
+import javax.persistence.Id;
+import java.io.Serializable;
+
+@Data
+public class Student implements Serializable {
+    public static final Integer NO_AMOUNT_LIMIT = -1;
+
+    @Id
+    @KeySql(genId = UUIdGenId.class)
+    private Integer id;
+    private String name;
+    private String age;
+    private int code;
+
+    public Student(String name, String age, int code) {
+        this.name=name;
+        this.age=age;
+        this.code=code;
+    }
+    public Student(String name, String age) {
+        this.name=name;
+        this.age=age;
+    }
+
+    
+}

xx-vehicle/xx-vehicle-server/src/test/java/com/xxfc/platform/vehicle/entity/UUIdGenId.java

+package com.xxfc.platform.vehicle.entity;
+
+import tk.mybatis.mapper.genid.GenId;
+
+import java.util.UUID;
+
+public class UUIdGenId implements GenId {
+    @Override
+    public Object genId(String table, String column) {
+        return UUID.randomUUID().toString();
+    }
+}

xx-vehicle/xx-vehicle-server/src/test/java/com/xxfc/platform/vehicle/entity/VestaGenId.java

+//package com.xxfc.platform.vehicle.entity;
+
+//import tk.mybatis.mapper.genid.GenId;
+//
+//public class VestaGenId implements GenId<Long> {
+//   public Long genId(String table, String column){
+//       //ApplicationUtil.getBean 需要自己实现
+//       IdService idService = ApplicationUtil.getBean(IdService.class);
+//       return idService.genId();
+//   }
+//}
\ No newline at end of file