|
@@ -109,6 +109,26 @@ public class SMSSelfGetArrivedServiceImpl {
|
|
|
}
|
|
|
|
|
|
|
|
|
+ @Transactional(rollbackFor = Exception.class)
|
|
|
+ public void insertDataGDtest(){
|
|
|
+ List<String> mobiles = new ArrayList<>();
|
|
|
+
|
|
|
+
|
|
|
+ List<FaExceptionMobile> fems = faExceptionMobileService.lambdaQuery().list();
|
|
|
+ if (CollectionUtils.isNotEmpty(fems)){
|
|
|
+ fems.stream().forEach(event->{
|
|
|
+ mobiles.add(event.getMobile());
|
|
|
+ });
|
|
|
+ fems.clear();
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ syncSmsRecordtest();
|
|
|
+
|
|
|
+
|
|
|
+ addFaExceptionMobiletest(mobiles);
|
|
|
+
|
|
|
+ }
|
|
|
|
|
|
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
@@ -145,6 +165,18 @@ public class SMSSelfGetArrivedServiceImpl {
|
|
|
|
|
|
}
|
|
|
|
|
|
+ private void addFaExceptionMobiletest(List<String> mobiles) {
|
|
|
+ if (!mobiles.contains("16626205908")){
|
|
|
+ String content = "3";
|
|
|
+ if (content.length()==2 && "QX".equals(content)){
|
|
|
+ FaExceptionMobile fem = new FaExceptionMobile();
|
|
|
+ fem.setMobile("16626205908");
|
|
|
+ fem.setCreatetime(new Date());
|
|
|
+ fem.insert();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
private void addFaExceptionMobile(List<String> mobiles, JSONObject data) {
|
|
|
if (!mobiles.contains(data.getString("fromNum"))){
|
|
|
String content = data.getString("content").toUpperCase();
|
|
@@ -218,6 +250,34 @@ public class SMSSelfGetArrivedServiceImpl {
|
|
|
|
|
|
}
|
|
|
|
|
|
+ private void syncSmsRecordtest() {
|
|
|
+ Map<String,String> orderPjnr = new HashMap<>();
|
|
|
+
|
|
|
+
|
|
|
+ List<SmsRecord> rec = smsRecordService.lambdaQuery()
|
|
|
+ .eq(SmsRecord::getPhone, "16626205908")
|
|
|
+ .eq(SmsRecord::getFsma, "6103")
|
|
|
+ .ge(SmsRecord::getCreateTime,publicService.stepMonth(new Date(),-2)).list();
|
|
|
+ if (CollectionUtils.isNotEmpty(rec)){
|
|
|
+ List<SmsRecord> u = new ArrayList<>();
|
|
|
+ for (SmsRecord item:rec){
|
|
|
+ item.setReplyContent("3");
|
|
|
+ item.setReplyTime(new Date());
|
|
|
+ u.add(item);
|
|
|
+
|
|
|
+ orderPjnr.put(item.getOrderBaseId(),item.getReplyContent().trim());
|
|
|
+ }
|
|
|
+ smsRecordService.updateBatchById(u);
|
|
|
+ u.clear();
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ getOrderAppeal(orderPjnr);
|
|
|
+
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
private void syncSmsRecord(JSONObject data) {
|
|
|
Map<String,String> orderPjnr = new HashMap<>();
|
|
|
|