You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

275 lines
14 KiB

  1. package com.example.demo.Mysql;
  2. import com.example.demo.Util.BaseDES;
  3. import com.example.demo.domain.entity.User;
  4. import com.example.demo.service.AdminService;
  5. import com.example.demo.service.UserService;
  6. import org.apache.commons.lang3.ObjectUtils;
  7. import org.apache.commons.lang3.StringUtils;
  8. import org.slf4j.Logger;
  9. import org.slf4j.LoggerFactory;
  10. import org.springframework.beans.factory.annotation.Autowired;
  11. import org.springframework.beans.factory.annotation.Qualifier;
  12. import org.springframework.boot.autoconfigure.security.SecurityProperties;
  13. import org.springframework.http.*;
  14. import org.springframework.scheduling.annotation.Scheduled;
  15. import org.springframework.stereotype.Service;
  16. import org.springframework.transaction.annotation.Transactional;
  17. import org.springframework.web.client.RestTemplate;
  18. import javax.sql.DataSource;
  19. import java.sql.*;
  20. import java.time.LocalDateTime;
  21. import java.time.Month;
  22. import java.time.format.DateTimeFormatter;
  23. import java.util.*;
  24. @Service
  25. @Transactional
  26. public class MysqlServiceImpl implements MysqlService {
  27. @Autowired
  28. private RestTemplate restTemplate;
  29. Set<Integer> validZeroTypes = new HashSet<>(Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 11, 12, 13, 14, 18, 19, 20, 21, 22, 23, 24, 26, 28, 29, 35, 36, 40, 45, 46, 47, 48, 49, 53, 54, 60));
  30. Set<Integer> validOneTypes = new HashSet<>(Arrays.asList(9, 15, 17, 25, 27, 37, 41, 42, 43, 50, 51, 62));
  31. Set<Integer> validTwoTypes = new HashSet<>(Arrays.asList(52,61));
  32. Set<Integer> validThreeTypes = new HashSet<>(Arrays.asList(10, 16, 30, 31, 32, 33, 34, 39, 44));
  33. Set<Integer> validFourTypes = new HashSet<>(Arrays.asList(55, 56, 57, 58, 59, 63, 64, 65));
  34. LocalDateTime now = LocalDateTime.now();
  35. Month currentMonth = now.getMonth();
  36. @Autowired
  37. private AdminService adminService;
  38. @Autowired
  39. private UserService userService;
  40. @Autowired
  41. @Qualifier("sqlserver1DataSource")
  42. private DataSource sqlserver1DataSource;
  43. @Autowired
  44. @Qualifier("mysql1DataSource")
  45. private DataSource mysql1DataSource;
  46. private static final Logger logger = LoggerFactory.getLogger(MysqlServiceImpl.class);
  47. @Override
  48. @Scheduled(cron = "0 0 * * * ?") // 每小时执行一次
  49. public void getSqlserverData() throws Exception {
  50. logger.info("开始从 SQL Server 同步数据到 MySQL");
  51. try (Connection sqlServerConn = sqlserver1DataSource.getConnection();
  52. Connection mysqlConn = mysql1DataSource.getConnection()) {
  53. logger.info("开始查询数据...");
  54. // 从 SQL Server 查询数据
  55. String querySql = "SELECT gtype,jwcode,free,core_jb,buy_jb,cz_time,cz_user,cz_bz,operation_platform,goods_name " +
  56. "FROM user_gold_records WHERE flag=1 and cz_time> ?";
  57. try (PreparedStatement sqlServerStmt = sqlServerConn.prepareStatement(querySql)) {
  58. sqlServerStmt.setTimestamp(1, Timestamp.valueOf(LocalDateTime.now().minusHours(1))); // 获取最近一小时的数据
  59. ResultSet resultSet = sqlServerStmt.executeQuery();
  60. logger.info("查询数据完毕!");
  61. // 插入到 MySQL
  62. //退款类型 61:ERP退款(退金币)
  63. String insertSql = "INSERT INTO user_gold_record (order_code,jwcode,sum_gold,permanent_gold,free_june,free_december," +
  64. "task_gold,pay_platform,goods_name,refund_type,refund_model,remark,type,admin_id," +
  65. "audit_status,create_time,flag) VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?) ";
  66. try (PreparedStatement mysqlStmt = mysqlConn.prepareStatement(insertSql)) {
  67. while (resultSet.next()) {
  68. int gtype = resultSet.getInt("gtype");
  69. Integer jwcode = resultSet.getInt("jwcode");
  70. int free = resultSet.getInt("free");
  71. int core_jb = resultSet.getInt("core_jb");
  72. int buy_jb = resultSet.getInt("buy_jb");
  73. Timestamp created_at = resultSet.getTimestamp("cz_time");
  74. String name = resultSet.getString("cz_user");
  75. String remark = resultSet.getString("cz_bz");
  76. String operation_platform = resultSet.getString("operation_platform");
  77. String goods_name = resultSet.getString("goods_name");
  78. String timestampPart = LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyyMMddHHmmssSSS"));
  79. if(StringUtils.isNumeric(name)){
  80. Integer admin_id = Integer.valueOf(adminService.getId(name));
  81. logger.info("用户传输完毕");
  82. mysqlStmt.setInt(14, admin_id);
  83. }else {
  84. mysqlStmt.setInt(14, 99999);
  85. }
  86. Random random = new Random();
  87. int randomNumber = random.nextInt(900) + 100;
  88. // 判断gtype
  89. mysqlStmt.setString(10,null);
  90. mysqlStmt.setNull(11, java.sql.Types.INTEGER);
  91. if(validFourTypes.contains(gtype)){
  92. continue;
  93. }
  94. if(validZeroTypes.contains(gtype)){
  95. mysqlStmt.setInt(13, 0);
  96. mysqlStmt.setString(1, "ERPCZ"+timestampPart+randomNumber);
  97. }
  98. if(validOneTypes.contains(gtype)){
  99. mysqlStmt.setInt(13, 1);
  100. mysqlStmt.setString(1, "ERPXF"+timestampPart+randomNumber);
  101. }
  102. if(validTwoTypes.contains(gtype)){
  103. mysqlStmt.setInt(13, 2);
  104. mysqlStmt.setString(1, "ERPTK"+timestampPart+randomNumber);
  105. mysqlStmt.setString(10,"退款商品");
  106. mysqlStmt.setInt(11, 0);
  107. }
  108. if(validThreeTypes.contains(gtype)){
  109. mysqlStmt.setInt(13, 3);
  110. mysqlStmt.setString(1, "ERPQT"+timestampPart+randomNumber);
  111. }
  112. mysqlStmt.setInt(2, jwcode);
  113. mysqlStmt.setInt(3, free+core_jb+buy_jb);
  114. mysqlStmt.setInt(4,buy_jb);
  115. // 判断月份
  116. if(currentMonth.getValue() >= 7){
  117. mysqlStmt.setInt(5, free);
  118. mysqlStmt.setInt(6, 0);
  119. }
  120. if(currentMonth.getValue() < 7){
  121. mysqlStmt.setInt(5, 0);
  122. mysqlStmt.setInt(6, free);
  123. }
  124. mysqlStmt.setInt(7, core_jb);
  125. if (operation_platform.equals("1")){
  126. mysqlStmt.setString(8, "ERP");
  127. }
  128. if (operation_platform.equals("2")){
  129. mysqlStmt.setString(8, "HomilyLink");
  130. }
  131. if(operation_platform.equals("3")){
  132. mysqlStmt.setString(8, "HomilyChart");
  133. }
  134. if(operation_platform.equals("4")){
  135. continue;
  136. }if(operation_platform.equals("0")){
  137. mysqlStmt.setString(8, "初始化金币");
  138. }
  139. else {
  140. mysqlStmt.setString(8, "其他");
  141. }
  142. mysqlStmt.setString(9, goods_name);
  143. mysqlStmt.setString(12, remark);
  144. mysqlStmt.setInt(15, 3);
  145. mysqlStmt.setTimestamp(16, created_at);
  146. if(remark.contains("测试")){
  147. mysqlStmt.setInt(17, 0);
  148. }else {
  149. mysqlStmt.setInt(17, 1);
  150. }
  151. // 更新时的值
  152. mysqlStmt.addBatch();
  153. logger.info("查询用户是否存在");
  154. User user = userService.selectAllUser(String.valueOf(jwcode));
  155. if(ObjectUtils.isEmpty(user)){
  156. logger.info("用户不存在");
  157. user = new User();
  158. String country = "未知";
  159. BaseDES des = new BaseDES();
  160. String desjwcode= des.encrypt(String.valueOf(jwcode));
  161. System.out.println("desjwcode:"+desjwcode);
  162. // 创建 JSON 请求体
  163. Map<String, String> requestBody = new HashMap<>();
  164. requestBody.put("jwcode", desjwcode);
  165. // 设置请求头
  166. HttpHeaders headers = new HttpHeaders();
  167. headers.setContentType(MediaType.APPLICATION_JSON);
  168. // 创建 HttpEntity
  169. HttpEntity<Map<String, String>> entity = new HttpEntity<>(requestBody, headers);
  170. // 发送 POST 请求
  171. try {
  172. ResponseEntity<Map> response = restTemplate.exchange(
  173. "http://hwapi.rzfwq.com/hwjnApp/hwhc-login/hwhclogin/hc/login/clent/info",
  174. HttpMethod.POST, entity, Map.class);
  175. // 检查响应状态码
  176. if (response.getStatusCode().is2xxSuccessful()) {
  177. Map<String, Object> responseBody = response.getBody();
  178. if (responseBody != null) {
  179. // 获取data部分
  180. Map<String, Object> data = (Map<String, Object>) responseBody.get("data");
  181. if (data != null) {
  182. // 提取name和country
  183. name = (String) data.get("name");
  184. country = (String) data.get("country");
  185. // 打印获取到的数据
  186. System.out.println("Name: " + name);
  187. System.out.println("Country: " + country);
  188. } else {
  189. System.out.println("Data is null");
  190. }
  191. } else {
  192. System.out.println("Response body is null");
  193. }
  194. } else {
  195. System.out.println("Request failed with status code: " + response.getStatusCode());
  196. }
  197. } catch (Exception e) {
  198. System.out.println("Error: " + e.getMessage());
  199. // 设置默认的 country 值
  200. country = "未知";
  201. }
  202. user.setJwcode(jwcode);
  203. user.setName( name);
  204. user.setMarket(country);
  205. logger.info("新添用户");
  206. userService.addUser(user);
  207. logger.info("用户添加成功");
  208. user = userService.selectAllUser(String.valueOf(jwcode));
  209. }
  210. if(currentMonth.getValue() >= 7){
  211. user.setCurrentFreeJune(user.getCurrentFreeJune()+free);
  212. }
  213. if(currentMonth.getValue() <7){
  214. user.setCurrentFreeDecember(user.getCurrentFreeDecember()+free);
  215. }
  216. user.setCurrentPermanentGold(user.getCurrentPermanentGold()+buy_jb);
  217. user.setCurrentTaskGold(user.getCurrentTaskGold()+core_jb);
  218. if(validZeroTypes.contains(gtype)) {
  219. user.setRechargeNum(user.getRechargeNum() + 1);
  220. user.setSumPermanentGold(user.getSumPermanentGold()+buy_jb);
  221. user.setSumTaskGold(user.getSumTaskGold()+core_jb);
  222. if(currentMonth.getValue() >= 7){
  223. user.setSumFreeJune(user.getSumFreeJune()+free);
  224. }
  225. if(currentMonth.getValue() < 7){
  226. user.setSumFreeDecember(user.getSumFreeDecember()+free);
  227. }
  228. }
  229. if (validOneTypes.contains(gtype)){
  230. user.setConsumeNum(user.getConsumeNum() + 1);
  231. user.setSumConsumePermanent(user.getSumConsumePermanent() + buy_jb);
  232. user.setSumConsumeTask(user.getSumConsumeTask() + core_jb);
  233. user.setSumConsumeFree(user.getSumConsumeFree() + free);
  234. }
  235. userService.updateAllGold(user);
  236. }
  237. mysqlStmt.executeBatch(); // 批量插入
  238. }
  239. }
  240. logger.info("数据同步完成");
  241. } catch (SQLException e) {
  242. logger.error("数据连接失败", e.getMessage());
  243. throw new RuntimeException("数据链接失败", e);
  244. }
  245. }
  246. }