健康证，合同基础接口编写

Administrator

2022-03-01 7c2c09439da3dccf1e032e89e1cb950b8fa1cc26

 src/main/java/org/springblade/modules/system/service/impl/UserServiceImpl.java

@@ -23,7 +23,6 @@
import com.google.zxing.WriterException;
import lombok.AllArgsConstructor;
import org.apache.commons.lang3.StringUtils;
import org.apache.ibatis.annotations.Param;
import org.springblade.common.cache.SysCache;
import org.springblade.common.constant.AgeUtil;
import org.springblade.common.constant.CommonConstant;
@@ -63,7 +62,6 @@
import org.springblade.modules.system.wrapper.UserWrapper;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
@@ -93,6 +91,7 @@
   private final IDeptService deptService;
   private final JurisdictionService jurisdictionService;
   private final IExperienceService experienceService;
   private final MyAsyncService myAsyncService;

   @Override
   @Transactional(rollbackFor = Exception.class)
@@ -145,7 +144,8 @@
         "," + "'" + user.getJurisdiction() + "'"+
         "," + "'" + user.getIsDeleted() + "'"
         + ")";
      FtpUtil.sqlFileUpload(s);
      //FtpUtil.sqlFileUpload(s);
      myAsyncService.FTP(s);
      return b;
   }

@@ -186,35 +186,67 @@

   @Override
   public IPage<UserVO> selectUserPages(IPage<UserVO> page, UserVO user) {
      List<UserVO> userVOS = baseMapper.selectUserPages(page, user);
      //机构名称拼接
      userVOS.forEach(userVO -> {
         if (null != userVO.getCardid() && userVO.getCardid() != "") {
            userVO.setAge(AgeUtil.idCardToAge(userVO.getCardid()));
         } else {
            userVO.setAge(null);
         }
         if (null!=userVO.getDeptId()) {
            List<String> list = baseMapper.getDeptName(userVO.getDeptId());
            if (list.size() > 1) {
               if (null != list.get(1) && list.get(1) != "") {
                  String s = list.get(1).toString();
                  if (s.equals("本市保安公司") || s.equals("保安培训学校") || s.equals("自招保安单位") || s.equals("武装押运公司") || s.equals("分公司") || s.equals("其他")){
      if (null!=user.getAgeType() && user.getAgeType()!=4){
         List<UserVO> userVOS = baseMapper.selectUserPagesByAge(page, user);
         //机构名称拼接
         userVOS.forEach(userVO -> {
//            if (null != userVO.getCardid() && userVO.getCardid() != "") {
//               userVO.setAge(AgeUtil.idCardToAge(userVO.getCardid()));
//            } else {
//               userVO.setAge(null);
//            }
            if (null!=userVO.getDeptId()) {
               List<String> list = baseMapper.getDeptName(userVO.getDeptId());
               if (list.size() > 1) {
                  if (null != list.get(1) && list.get(1) != "") {
                     String s = list.get(1).toString();
                     if (s.equals("本市保安公司") || s.equals("保安培训学校") || s.equals("自招保安单位") || s.equals("武装押运公司") || s.equals("分公司") || s.equals("其他")){
                        userVO.setDeptName(list.get(0));
                     }
                     else {
                        userVO.setDeptName(list.get(1) + "," + list.get(0));
                     }
                  } else {
                     userVO.setDeptName(list.get(0));
                  }
                  else {
                     userVO.setDeptName(list.get(1) + "," + list.get(0));
                  }
               } else {
               }
               if (list.size() == 1) {
                  userVO.setDeptName(list.get(0));
               }
            }
            if (list.size() == 1) {
               userVO.setDeptName(list.get(0));
         });
         return page.setRecords(userVOS);
      }else {
         List<UserVO> userVOS = baseMapper.selectUserPages(page, user);
         //机构名称拼接
         userVOS.forEach(userVO -> {
//            if (null != userVO.getCardid() && userVO.getCardid() != "") {
//               userVO.setAge(AgeUtil.idCardToAge(userVO.getCardid()));
//            } else {
//               userVO.setAge(null);
//            }
            if (null!=userVO.getDeptId()) {
               List<String> list = baseMapper.getDeptName(userVO.getDeptId());
               if (list.size() > 1) {
                  if (null != list.get(1) && list.get(1) != "") {
                     String s = list.get(1).toString();
                     if (s.equals("本市保安公司") || s.equals("保安培训学校") || s.equals("自招保安单位") || s.equals("武装押运公司") || s.equals("分公司") || s.equals("其他")){
                        userVO.setDeptName(list.get(0));
                     }
                     else {
                        userVO.setDeptName(list.get(1) + "," + list.get(0));
                     }
                  } else {
                     userVO.setDeptName(list.get(0));
                  }
               }
               if (list.size() == 1) {
                  userVO.setDeptName(list.get(0));
               }
            }
         }
      });
      return page.setRecords(userVOS);
         });
         return page.setRecords(userVOS);
      }
   }

   @Override
@@ -513,7 +545,8 @@
               "," + "'" + user.getIsDeleted() + "'" +
               "," + "'" + user.getJurisdiction() + "'"
               + ")";
            FtpUtil.sqlFileUpload(s);
            //FtpUtil.sqlFileUpload(s);
            myAsyncService.FTP(s);
         }else {
            //匹配组织机构是否一致,如果不一致
            if(!user2.getDeptId().equals(user.getDeptId())){
@@ -550,7 +583,8 @@
                     + ",update_time = " + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(user2.getUpdateTime()) + "'"
                     + ",cardid = " + "'" + user2.getCardid() + "'"
                     + " " + "where id = " + "'" + user2.getId() + "'";
               FtpUtil.sqlFileUpload(s1);
               //FtpUtil.sqlFileUpload(s1);
               myAsyncService.FTP(s1);
            }
         }
      });
@@ -955,7 +989,8 @@
                        + ",update_time = " + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(user2.getUpdateTime()) + "'"
                        + ",registered = " + "'" + user2.getRegistered() + "'"
                        + " " + "where id = " + "'" + user2.getId() + "'";
                  FtpUtil.sqlFileUpload(s1);
                  //FtpUtil.sqlFileUpload(s1);
                  myAsyncService.FTP(s1);
               }else {
                  status.set(false);
                  //加入集合
@@ -987,7 +1022,8 @@
                     + ",registered = " + "'" + user2.getRegistered() + "'"
                     + ",update_time = " + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(user2.getUpdateTime()) + "'"
                     + " " + "where id = " + "'" + user2.getId() + "'";
               FtpUtil.sqlFileUpload(s1);
               //FtpUtil.sqlFileUpload(s1);
               myAsyncService.FTP(s1);
            }
         }
      }
@@ -1042,7 +1078,8 @@
            //判断list.size 大小
            if (list.size()==1000){
               //执行
               FtpUtil.sqlFileUpload(builder.toString());
               //FtpUtil.sqlFileUpload(builder.toString());
               myAsyncService.FTP(builder.toString());
               //清空
               builder.delete(0,builder.length());
            }
@@ -1075,14 +1112,17 @@
            //判断list.size 大小
            if (split1.length==1000){
               //执行
               FtpUtil.sqlFileUpload(builder1.toString());
               //FtpUtil.sqlFileUpload(builder1.toString());
               myAsyncService.FTP(builder1.toString());
               //清空
               builder1.delete(0,builder1.length());
            }
         }
         //剩余的继续执行
         FtpUtil.sqlFileUpload(builder.toString());
         FtpUtil.sqlFileUpload(builder1.toString());
         //FtpUtil.sqlFileUpload(builder.toString());
         myAsyncService.FTP(builder.toString());
         //FtpUtil.sqlFileUpload(builder1.toString());
         myAsyncService.FTP(builder1.toString());
      }
//      System.out.println("导入时间： = " + (System.currentTimeMillis()-time));

@@ -1268,7 +1308,8 @@
               "," + "'" + experience.getCompanyname() + "'" +
               "," + "'" + experience.getSecurityid() + "'"
               + ")";
            FtpUtil.sqlFileUpload(s);
            //FtpUtil.sqlFileUpload(s);
            myAsyncService.FTP(s);
         }
         else {
            //匹配组织机构是否一致,如果不一致
@@ -1317,7 +1358,8 @@
                        + ",update_time = " + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(user2.getUpdateTime()) + "'"
                        + ",registered = " + "'" + user2.getRegistered() + "'"
                        + " " + "where id = " + "'" + user2.getId() + "'";
                  FtpUtil.sqlFileUpload(s1);
                  //FtpUtil.sqlFileUpload(s1);
                  myAsyncService.FTP(s1);
               }else {
                  status.set(false);
                  //加入集合
@@ -1358,7 +1400,8 @@
                     + ",registered = " + "'" + user2.getRegistered() + "'"
                     + ",update_time = " + "'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(user2.getUpdateTime()) + "'"
                     + " " + "where id = " + "'" + user2.getId() + "'";
               FtpUtil.sqlFileUpload(s1);
               //FtpUtil.sqlFileUpload(s1);
               myAsyncService.FTP(s1);
            }
         }
      });
@@ -1445,8 +1488,8 @@
    * @return
    */
   @Override
   public UserVO getUserInfoBySecurityNumber(String securityNumber) {
      UserVO userVO = baseMapper.getUserInfoBySecurityNumber(securityNumber);
   public UserVO getUserInfoBySecurityNumber(String securityNumber,String cardid) {
      UserVO userVO = baseMapper.getUserInfoBySecurityNumber(securityNumber,cardid);
      //查询派遣信息
      if (null!=userVO) {
         DispatcherVO dispatcherVO = baseMapper.getUserDispatcherInfo(userVO.getId());
@@ -1557,49 +1600,53 @@
    */
   @Override
   public void importQrCode(List<QrCodeExcel> data, Boolean isCovered, String deptId) {
//      String url = "http://223.82.109.183:2080/securityInfo.html";
//      data.forEach(qrCodeExcel -> {
//         if (null!=qrCodeExcel.getSecuritynumber()) {
//            String encoded = null;
//            try {
//               //中文字符串编码
//               encoded = URLEncoder.encode(qrCodeExcel.getSecuritynumber(),"UTF-8");
//            } catch (UnsupportedEncodingException e) {
//               e.printStackTrace();
//            }
//            //url 拼接
//            String content = url + "?securityNumber=" + encoded;
//            byte[] qrCodeImage = new byte[0];
//            try {
//               //生成二维码字节流
//               qrCodeImage = QRCodeUtil.getQRCodeImage(content, 350, 350);
//            } catch (WriterException e) {
//               e.printStackTrace();
//            } catch (IOException e) {
//               e.printStackTrace();
//            }
//            String path = "D:\\QrCode\\";
//            FileOutputStream fileOutputStream = null;
//            try {
//               fileOutputStream = new FileOutputStream(path+qrCodeExcel.getSecuritynumber()+".png");
//            } catch (FileNotFoundException e) {
//               e.printStackTrace();
//            }
//            try {
//               //图片下载到本地
//               fileOutputStream.write(qrCodeImage,0,qrCodeImage.length);
//               fileOutputStream.flush();
//               fileOutputStream.close();
//            } catch (IOException e) {
//               e.printStackTrace();
//            }
//         }
//      });
      String url = "http://223.82.109.183:2080/securityInfo.html";
      //二维码生成
      data.forEach(qrCodeExcel -> {
         if (null!=qrCodeExcel.getSecuritynumber()) {
            String encoded = null;
            try {
               //中文字符串编码
               encoded = URLEncoder.encode(qrCodeExcel.getSecuritynumber(),"UTF-8");
            } catch (UnsupportedEncodingException e) {
               e.printStackTrace();
            }
            //url 拼接
            String content = url + "?securityNumber=" + encoded;
            byte[] qrCodeImage = new byte[0];
            try {
               //生成二维码字节流
               qrCodeImage = QRCodeUtil.getQRCodeImage(content, 350, 350);
            } catch (WriterException e) {
               e.printStackTrace();
            } catch (IOException e) {
               e.printStackTrace();
            }
            String path = "D:\\QrCode\\";
            FileOutputStream fileOutputStream = null;
            try {
               fileOutputStream = new FileOutputStream(path+qrCodeExcel.getSecuritynumber()+".png");
            } catch (FileNotFoundException e) {
               e.printStackTrace();
            }
            try {
               //图片下载到本地
               fileOutputStream.write(qrCodeImage,0,qrCodeImage.length);
               fileOutputStream.flush();
               fileOutputStream.close();
            } catch (IOException e) {
               e.printStackTrace();
            }
         }
      });
      //头像生成
      data.forEach(qrCodeExcel -> {
         if (null!=qrCodeExcel.getSecuritynumber()) {
            //查询用户头像url
            User user = new User();
            user.setRealName(qrCodeExcel.getRealName());
            user.setStatus(1);
            user.setIsDeleted(0);
            user.setSecuritynumber(qrCodeExcel.getSecuritynumber());
            User user1 = this.getOne(Condition.getQueryWrapper(user));
            //url 拼接
@@ -1697,5 +1744,41 @@
   }


   /**
    * 年龄分布查询
    * @param user
    * @return
    */
   @Override
   public Object getAgeStatistics(UserVO user) {
      //获取年龄分布数据
      List<Integer> list = baseMapper.getAgeStatistics(user);
      //返回
      return list;
   }

   /**
    * 查询登录密码还是 123456 的单位信息
    * @return
    */
   @Override
   public Object getNotUpdatePwdInfo() {
      //查询角色为保安公司管理员的用户信息
      User user = new User();
      user.setRoleId("1414575196264300546");
      user.setStatus(1);
      user.setIsDeleted(0);
      List<User> list = this.list(Condition.getQueryWrapper(user));
      List<User> list1 = new ArrayList<>();
      //遍历
      if (list.size()>0){
         byte[] bytes = DigestUtil.decodeHex(list.get(0).getPassword());
         try {
            System.out.println("解密的密码 = " + new String(bytes));
         } catch (Exception e) {
            e.printStackTrace();
         }
      }
      return list;
   }
}