From a6897f50cd0bff23ac2ea0d0ce5b489aff0dd2c4 Mon Sep 17 00:00:00 2001 From: ACat <809642793@qq.com> Date: Wed, 29 May 2019 14:58:25 +0800 Subject: [PATCH] =?UTF-8?q?=E5=81=87=E8=A3=85=E8=87=AA=E5=B7=B1=E6=98=AF?= =?UTF-8?q?=E8=B4=9F=E8=BD=BD=E5=9D=87=E8=A1=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- java/ChannleSubMerPoolBANKService.java | 241 +++++++++++++++++++++++++ 1 file changed, 241 insertions(+) create mode 100644 java/ChannleSubMerPoolBANKService.java diff --git a/java/ChannleSubMerPoolBANKService.java b/java/ChannleSubMerPoolBANKService.java new file mode 100644 index 0000000..f902ed4 --- /dev/null +++ b/java/ChannleSubMerPoolBANKService.java @@ -0,0 +1,241 @@ +package service.pay.service; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.stereotype.Service; +import service.BaseService; +import service.pay.ChannelSubMerPoolConfig; +import utils.Dao; + +/** + * Created by 80964 on 2018/10/11. + */ +@Service +class ChannleSubMerPoolBANKService extends BaseService{ + private static final Logger log = LoggerFactory.getLogger(ChannleSubMerPoolBANKService.class); + private String index0= "index0"; + private String index1= "index1"; + private String index2= "index2"; + private String index3= "index3"; + private String index4= "index4"; + private String index5= "index5"; + private String index6= "index6"; + private String index7= "index7"; + private String index8= "index8"; + private String index9= "index9"; + private String index10= "index10"; + private String index11= "index11"; + private String index12= "index12"; + private String index13= "index12"; + private String index14= "index14"; + private String index15= "index15"; + private String index16= "index16"; + private String index17= "index17"; + private String index18= "index18"; + private String index19= "index19"; + private String index20= "index20"; + private String indexDef= "indexDef"; + private String IndexPri= "IndexPri"; + + public Map findFastPool(params){ + int Index = 1; + synchronized (IndexPri){ + if(ChannelSubMerPoolConfig.BANKINDEX == 21){ + ChannelSubMerPoolConfig.BANKINDEX = 0; + } + Index = ChannelSubMerPoolConfig.BANKINDEX; + ChannelSubMerPoolConfig.BANKINDEX = ChannelSubMerPoolConfig.BANKINDEX + 1; + } + Map entity = null; + switch (Index){ + case 0: entity = findFastPool0(params); break; + case 1: entity = findFastPool1(params); break; + case 2: entity = findFastPool2(params);break; + case 3: entity = findFastPool3(params);break; + case 4: entity = findFastPool4(params);break; + case 5: entity = findFastPool5(params);break; + case 6: entity = findFastPool6(params);break; + case 7: entity = findFastPool7(params);break; + case 8: entity = findFastPool8(params);break; + case 9: entity = findFastPool9(params);break; + case 10: entity = findFastPool10(params);break; + case 11: entity = findFastPool11(params);break; + case 12: entity = findFastPool12(params);break; + case 13: entity = findFastPool13(params);break; + case 14: entity = findFastPool14(params);break; + case 15: entity = findFastPool15(params);break; + case 16: entity = findFastPool16(params);break; + case 17: entity = findFastPool17(params);break; + case 18: entity = findFastPool18(params);break; + case 19: entity = findFastPool19(params);break; + case 20: entity = findFastPool20(params);break; + default: entity = findFastPoolDef(params);break; + } + return entity; + } + + public Map findFastPoolDef(params){ + synchronized(indexDef){ + Map acqSubMer = findAndUpdata(params,"0"); + return acqSubMer; + } + } + public Map findFastPool0(params){ + synchronized(index0){ + Map acqSubMer = findAndUpdata(params,"0"); + return acqSubMer; + } + } + + public Map findFastPool1(params){ + synchronized(index1){ + Map acqSubMer = findAndUpdata(params,"5"); + return acqSubMer; + } + } + + public Map findFastPool2(params){ + synchronized(index2){ + Map acqSubMer = findAndUpdata(params,"10"); + return acqSubMer; + } + } + + public Map findFastPool3(params){ + synchronized(index3){ + Map acqSubMer = findAndUpdata(params,"15"); + return acqSubMer; + } + } + + public Map findFastPool4(params){ + synchronized(index4){ + Map acqSubMer = findAndUpdata(params,"20"); + return acqSubMer; + } + } + + public Map findFastPool5(params){ + synchronized(index5){ + Map acqSubMer = findAndUpdata(params,"25"); + return acqSubMer; + } + } + public Map findFastPool6(params){ + synchronized(index6){ + Map acqSubMer = findAndUpdata(params,"30"); + return acqSubMer; + } + } + public Map findFastPool7(params){ + synchronized(index7){ + Map acqSubMer = findAndUpdata(params,"35"); + return acqSubMer; + } + } + public Map findFastPool8(params){ + synchronized(index8){ + Map acqSubMer = findAndUpdata(params,"40"); + return acqSubMer; + } + } + public Map findFastPool9(params){ + synchronized(index9){ + Map acqSubMer = findAndUpdata(params,"45"); + return acqSubMer; + } + } + public Map findFastPool10(params){ + synchronized(index10){ + Map acqSubMer = findAndUpdata(params,"50"); + return acqSubMer; + } + } + + public Map findFastPool11(params){ + synchronized(index11){ + Map acqSubMer = findAndUpdata(params,"55"); + return acqSubMer; + } + } + + public Map findFastPool12(params){ + synchronized(index12){ + Map acqSubMer = findAndUpdata(params,"60"); + return acqSubMer; + } + } + + public Map findFastPool13(params){ + synchronized(index13){ + Map acqSubMer = findAndUpdata(params,"65"); + return acqSubMer; + } + } + + public Map findFastPool14(params){ + synchronized(index14){ + Map acqSubMer = findAndUpdata(params,"70"); + return acqSubMer; + } + } + + public Map findFastPool15(params){ + synchronized(index15){ + Map acqSubMer = findAndUpdata(params,"75"); + return acqSubMer; + } + } + public Map findFastPool16(params){ + synchronized(index16){ + Map acqSubMer = findAndUpdata(params,"80"); + return acqSubMer; + } + } + public Map findFastPool17(params){ + synchronized(index17){ + Map acqSubMer = findAndUpdata(params,"85"); + return acqSubMer; + } + } + public Map findFastPool18(params){ + synchronized(index18){ + Map acqSubMer = findAndUpdata(params,"90"); + return acqSubMer; + } + } + public Map findFastPool19(params){ + synchronized(index19){ + Map acqSubMer = findAndUpdata(params,"95"); + return acqSubMer; + } + } + public Map findFastPool20(params){ + synchronized(index20){ + Map acqSubMer = findAndUpdata(params,"100"); + return acqSubMer; + } + } + + public Map findAndUpdata(params,indxe){ + String sql = "select ID,MER_NO,ORG_MER_NO,MER_NAME,BODY,STORE_NO from channel_sub_merchant_pool_bank where AMOUNT_LEVEL = '"+params.get("AMOUNT_LEVEL")+"' "; + if (params.TIME_TYPE && params.TIME_TYPE != "1"){ + sql += " and TIME_TYPE = '${params.TIME_TYPE}' "; + } + sql += " and POOL_MER_TYPE = '"+params.get("POOL_MER_TYPE")+"' and IS_OPEN = '1' and MER_STATUS = 'normal' "; + sql += " and CHANNEL_CODE = '"+params.get("CHANNEL_CODE")+"' ORDER BY CONUT LIMIT "+indxe+",1"; + Map acqSubMer = Dao.db.rows(sql).get(0); + upDataConutUp(acqSubMer); + return acqSubMer; + } + + /** + * 计数 + 1 + * @param entity + */ + private int upDataConutUp(entity){ + def id = entity.get("ID"); + def sql = "UPDATE channel_sub_merchant_pool_bank set CONUT = CONUT+1 ,UPDATE_TIME = now() where ID = "+id; + dao.db.execute(sql.toString()); + } +} -- Gitee