package com.panzhihua.service_community.service.impl;
|
|
import cn.hutool.core.collection.CollectionUtil;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.panzhihua.common.model.vos.R;
|
import com.panzhihua.service_community.dao.*;
|
import com.panzhihua.service_community.entity.ComPbCheckUnit;
|
import com.panzhihua.service_community.entity.SysUser;
|
import com.panzhihua.service_community.model.dos.*;
|
import com.panzhihua.service_community.service.CodDataService;
|
import com.panzhihua.service_community.service.ComActActivityService;
|
import org.apache.poi.ss.usermodel.*;
|
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.http.HttpEntity;
|
import org.springframework.http.HttpHeaders;
|
import org.springframework.http.HttpMethod;
|
import org.springframework.http.ResponseEntity;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.LinkedMultiValueMap;
|
import org.springframework.util.MultiValueMap;
|
import org.springframework.web.client.RestTemplate;
|
import org.springframework.web.multipart.MultipartFile;
|
|
import javax.annotation.Resource;
|
import java.io.IOException;
|
import java.io.InputStream;
|
import java.nio.charset.StandardCharsets;
|
import java.security.MessageDigest;
|
import java.security.NoSuchAlgorithmException;
|
import java.time.Duration;
|
import java.time.LocalDateTime;
|
import java.time.ZoneOffset;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* @title: BigScreenStatisticsServiceImpl
|
* @projectName: 成都呐喊信息技术有限公司-智慧社区项目
|
* @description: 国务院防疫数据服务实现类
|
* @author: zzj
|
* @date: 2022/4/1 9:56
|
*/
|
@Service
|
public class CodDataServiceImpl implements CodDataService {
|
@Override
|
public void getCodData() {
|
//获取时间戳
|
long timestamp = LocalDateTime.now().toEpochSecond(ZoneOffset.of("+8"));
|
String url = "http://103.66.32.242:8005/zwfwMovePortal/interface/interfaceJson";
|
//以下常量值都是从网页源代码上获取到的------start
|
final String STATE_COUNCIL_SIGNATURE_KEY = "fTN2pfuisxTavbTuYVSsNJHetwq5bJvCQkjjtiLM2dCratiA";
|
final String STATE_COUNCIL_X_WIF_NONCE = "QkjjtiLM2dCratiA";
|
final String STATE_COUNCIL_X_WIF_PAASID = "smt-application";
|
//国务院疫情防控查询 appId
|
final String STATE_COUNCIL_APP_ID = "NcApplication";
|
//国务院疫情防控查询 PASSID
|
final String STATE_COUNCIL_PASSID = "zdww";
|
//国务院疫情防控查询 秘钥
|
final String STATE_COUNCIL_NONCE = "123456789abcdefg";
|
//国务院疫情防控查询 token
|
final String STATE_COUNCIL_TOEKN = "23y0ufFl5YxIyGrI8hWRUZmKkvtSjLQA";
|
//国务院疫情防控查询 key
|
final String STATE_COUNCIL_KEY = "3C502C97ABDA40D0A60FBEE50FAAD1DA";
|
//以下常量值都是从网页源代码上获取到的------end
|
HttpHeaders requestHeaders = new HttpHeaders();
|
Map<String,Object> body = new HashMap<>(10);
|
//计算签名要用的字符串
|
String signatureStr = String.format("%d%s%d",timestamp, STATE_COUNCIL_SIGNATURE_KEY,timestamp);
|
//计算签名
|
String signature = getSHA256StrJava(signatureStr).toUpperCase();
|
//请求头参数封装
|
requestHeaders.add( "x-wif-nonce",STATE_COUNCIL_X_WIF_NONCE);
|
requestHeaders.add( "x-wif-paasid",STATE_COUNCIL_X_WIF_PAASID);
|
requestHeaders.add( "x-wif-signature",signature);
|
requestHeaders.add( "x-wif-timestamp",String.valueOf(timestamp));
|
//body参数封装
|
body.put("appId",STATE_COUNCIL_APP_ID);
|
body.put("paasHeader",STATE_COUNCIL_PASSID);
|
body.put("timestampHeader",timestamp);
|
body.put("nonceHeader",STATE_COUNCIL_NONCE);
|
//请求参数
|
signatureStr = String.format("%d%s%s%d",timestamp,STATE_COUNCIL_TOEKN,STATE_COUNCIL_NONCE,timestamp);
|
String signatureHeader = getSHA256StrJava(signatureStr).toUpperCase();
|
body.put("signatureHeader",signatureHeader);
|
body.put("key",STATE_COUNCIL_KEY);
|
HttpEntity<String> httpEntity = new HttpEntity(body, requestHeaders);
|
ResponseEntity<String> response = new RestTemplate().exchange(url, HttpMethod.POST,httpEntity,String.class);
|
R r=JSONObject.parseObject(response.getBody(),R.class);
|
ReturnData returnData=JSONObject.parseObject(JSONObject.toJSONString(r.getData()), ReturnData.class);
|
List<Highlist> highlist=returnData.getHighlist();
|
List<Middlelist> middlelist=returnData.getMiddlelist();
|
}
|
//查社区的表
|
@Autowired
|
private ComActDAO comActDAO;
|
//单位表
|
@Autowired
|
private ComPbCheckUnitDao comPbCheckUnitDao;
|
//用户表
|
@Autowired
|
private SysUserDao sysUserDao;
|
//社区活动表
|
@Autowired
|
private ComActActivityDAO comActActivityDAO;
|
@Autowired
|
private ComActActivityService comActActivityService;
|
//活动报名表
|
@Autowired
|
private ComActActSignDAO comActActSignDAO;
|
//签到表
|
@Autowired
|
private ComActActRegistDAO comActActRegistDAO;
|
|
public static void main(String[] args) {
|
HashSet<Map<String,String>> set = new HashSet<>();
|
|
for (int i = 0; i < 10; i++) {
|
Map<String,String> map = new HashMap<>();
|
map.put("1","2");
|
set.add(map);
|
}
|
for (Map<String, String> map : set) {
|
System.out.println(map);
|
}
|
|
}
|
|
@Transactional(rollbackFor = Exception.class)
|
@Override
|
public void importData(MultipartFile file) throws IOException {
|
// InputStream inputStream = file.getInputStream();
|
// Workbook workbook = new XSSFWorkbook(inputStream);
|
// Sheet sheet = workbook.getSheetAt(0);
|
//
|
// List<String> signAndRegist = new ArrayList<>();
|
// //key: 活动名称 value：社区id
|
// MultiValueMap<String, String> map1 = new LinkedMultiValueMap<>();
|
// //key：活动名称 value： 活动开始时间
|
// MultiValueMap<String, Date> dateHashMap = new LinkedMultiValueMap<>();
|
//
|
// List<String> list = new ArrayList<>();
|
// int totalRowNum = sheet.getLastRowNum();
|
// for (int i = 1; i <= totalRowNum; i++){
|
// Row row = sheet.getRow(i);
|
// row.getCell(2).setCellType(CellType.STRING);
|
// String cellValue1 = row.getCell(2).getStringCellValue();
|
// list.add(cellValue1);
|
// }
|
// Map<String, Long> map = list.stream().collect(Collectors.groupingBy(s -> s, Collectors.counting()));
|
// for (int i = 1; i <= totalRowNum; i++) {
|
// Row row = sheet.getRow(i);
|
// System.out.println("第几行：" + i);
|
// //党组织名称
|
// row.getCell(1).setCellType(CellType.STRING);
|
// String cellValue = row.getCell(1).getStringCellValue();
|
// //活动名称
|
// row.getCell(2).setCellType(CellType.STRING);
|
// String cellValue1 = row.getCell(2).getStringCellValue();
|
// //活动内容
|
// row.getCell(3).setCellType(CellType.STRING);
|
// String cellValue2 = row.getCell(3).getStringCellValue();
|
// //活动时长
|
// row.getCell(4).setCellType(CellType.STRING);
|
// String cellValue3 = row.getCell(4).getStringCellValue();
|
// //活动所在社区名称
|
// row.getCell(5).setCellType(CellType.STRING);
|
// String cellValue4 = row.getCell(5).getStringCellValue();
|
// ComActDO comAct = comActDAO.queryByName(cellValue4);
|
// //参加活动党员姓名
|
// row.getCell(6).setCellType(CellType.STRING);
|
// String cellValue6 = row.getCell(6).getStringCellValue();
|
// QueryWrapper<SysUser> wrapper = new QueryWrapper<>();
|
//// wrapper.eq("community_id",comAct.getCommunityId());
|
// wrapper.eq("app_id","wx118de8a734d269f0");
|
// wrapper.eq("name",cellValue6);
|
// wrapper.eq("status",1);
|
// List<SysUser> sysUsers = sysUserDao.selectList(wrapper);
|
// if(CollectionUtil.isEmpty(sysUsers)){
|
// continue;
|
// }
|
// Long userId = sysUsers.get(0).getUserId();
|
// //单位
|
// row.getCell(7).setCellType(CellType.STRING);
|
// String cellValue7 = row.getCell(7).getStringCellValue();
|
//
|
// //管理员
|
// row.getCell(8).setCellType(CellType.STRING);
|
// String cellValue8 = row.getCell(8).getStringCellValue();
|
//
|
// QueryWrapper<ComPbCheckUnit> queryWrapper = new QueryWrapper<>();
|
// queryWrapper.eq("name",cellValue7);
|
// queryWrapper.eq("belong_to","仁和区");
|
// ComPbCheckUnit comPbCheckUnit = comPbCheckUnitDao.selectOne(queryWrapper);
|
//
|
// //活动发布时间
|
// Date date = row.getCell(10).getDateCellValue();
|
// //活动开始报名时间
|
// Date date1 = row.getCell(11).getDateCellValue();
|
// //活动结束报名时间
|
// Date date2 = row.getCell(12).getDateCellValue();
|
// //活动开始时间
|
// Date date3 = row.getCell(13).getDateCellValue();
|
// //活动结束时间
|
// Date date4 = row.getCell(14).getDateCellValue();
|
//
|
// ComActActivityDO comActActivity = new ComActActivityDO();
|
// comActActivity.setActivityName(cellValue1);
|
// comActActivity.setActivityAddr(comAct.getAddress());
|
// comActActivity.setLng(comAct.getLng());
|
// comActActivity.setLat(comAct.getLat());
|
// // comActActivity.setStatus();
|
// comActActivity.setPublishAt(date);
|
// comActActivity.setSignUpBegin(date1);
|
// comActActivity.setSignUpEnd(date2);
|
// comActActivity.setBeginAt(date3);
|
// comActActivity.setEndAt(date4);
|
// comActActivity.setAattendPeople("居民,志愿者,党员");
|
// comActActivity.setParticipantMax(-1);
|
// comActActivity.setActivityType("志愿服务");
|
// comActActivity.setHasPrize(0);
|
// comActActivity.setIsQrCode(1);
|
// comActActivity.setContactName(cellValue8);
|
// comActActivity.setContent(cellValue2);
|
// comActActivity.setCommunityId(comAct.getCommunityId());
|
// comActActivity.setCreateAt(new Date());
|
// int sum = map.get(cellValue1).intValue();
|
// comActActivity.setParticipantRewardWay(2);
|
// comActActivity.setVolunteerRewardWay(2);
|
// comActActivity.setPbRewardWay(2);
|
// comActActivity.setDuration(sum * Integer.parseInt(cellValue3));
|
// comActActivity.setType(3);
|
// comActActivity.setPartyMemberMax(-1);
|
// comActActivity.setSignOutRange(1000);
|
//
|
//
|
// if( i == 1){
|
// comActActivityService.save(comActActivity);
|
// dateHashMap.add(cellValue1,date3);
|
// } else {
|
// if(dateHashMap.containsKey(cellValue1)){
|
// List<Date> dateList = dateHashMap.get(cellValue1);
|
// assert dateList != null;
|
// if( !dateList.contains(date3)){
|
// comActActivityService.save(comActActivity);
|
// dateHashMap.add(cellValue1,date3);
|
// } else {
|
// QueryWrapper<ComActActivityDO> wrapper1 = new QueryWrapper<>();
|
// wrapper1.eq("activity_name",cellValue1);
|
// wrapper1.eq("begin_at",date3);
|
// System.out.println(cellValue1);
|
// System.out.println(comAct.getCommunityId());
|
// System.out.println(cellValue6);
|
// List<ComActActivityDO> doList = comActActivityDAO.selectList(wrapper1);
|
// comActActivity.setId(doList.get(doList.size() - 1).getId());
|
// }
|
// } else {
|
// comActActivityService.save(comActActivity);
|
// dateHashMap.add(cellValue1,date3);
|
// }
|
// }
|
//
|
//
|
// System.out.println(comActActivity.getId());
|
//
|
// if(!signAndRegist.contains(comActActivity.getId() + "-" + userId)) {
|
// ComActActSignDO comActActSign = new ComActActSignDO();
|
// comActActSign.setActivityId(comActActivity.getId());
|
// comActActSign.setUserId(userId);
|
// comActActSign.setCreateAt(date1);
|
// comActActSign.setSignIdentity(2);
|
// comActActSign.setStatus(1);
|
// comActActSign.setCheckUnitId(comPbCheckUnit.getId());
|
// comActActSignDAO.insert(comActActSign);
|
//
|
// ComActActRegistDO comActActRegist = new ComActActRegistDO();
|
// comActActRegist.setActivityId(comActActivity.getId());
|
// comActActRegist.setUserId(userId);
|
// comActActRegist.setCreateAt(date3);
|
// comActActRegist.setSignIdentity(2);
|
// comActActRegist.setCheckUnitId(comPbCheckUnit.getId());
|
// comActActRegist.setStartTime(date3);
|
//
|
// Calendar calendar = Calendar.getInstance();
|
// calendar.setTime(date3);
|
// calendar.add(Calendar.HOUR_OF_DAY, Integer.parseInt(cellValue3));
|
// Date time = calendar.getTime();
|
// comActActRegist.setEndTime(time);
|
// comActActRegist.setPosition(comAct.getAddress());
|
// comActActRegist.setTimes(1);
|
// comActActRegist.setCodeId(1768091384461426690L);
|
// comActActRegist.setAward(0);
|
// comActActRegist.setType(2);
|
// comActActRegistDAO.insert(comActActRegist);
|
// }
|
// signAndRegist.add(comActActivity.getId() + "-" + userId);
|
// }
|
}
|
|
public static String getSHA256StrJava(String str) {
|
MessageDigest messageDigest;
|
String encodeStr = "";
|
try {
|
messageDigest = MessageDigest.getInstance("SHA-256");
|
messageDigest.update(str.getBytes(StandardCharsets.UTF_8));
|
byte[] bytes = messageDigest.digest();
|
StringBuffer stringBuffer = new StringBuffer();
|
String temp = null;
|
for (int i = 0; i < bytes.length; i++) {
|
temp = Integer.toHexString(bytes[i] & 0xFF);
|
if (temp.length() == 1) {
|
//1得到一位的进行补0操作
|
stringBuffer.append("0");
|
}
|
stringBuffer.append(temp);
|
}
|
encodeStr = stringBuffer.toString();
|
} catch (NoSuchAlgorithmException e) {
|
e.printStackTrace();
|
}
|
return encodeStr;
|
}
|
}
|
